From 3cce024829b7a19c36ca765f5aff0a0c097d1517 Mon Sep 17 00:00:00 2001
From: Derrick Hammer <derrick@derrickhammer.com>
Date: Mon, 11 Mar 2024 11:50:27 -0400
Subject: [PATCH] chore: add debug logging gor registry query and set

---
 protocol/registry_entry.go | 16 ++++++++++++++++
 protocol/registry_query.go | 18 ++++++++++++++++++
 2 files changed, 34 insertions(+)

diff --git a/protocol/registry_entry.go b/protocol/registry_entry.go
index cd551e4..d78a83b 100644
--- a/protocol/registry_entry.go
+++ b/protocol/registry_entry.go
@@ -1,8 +1,11 @@
 package protocol
 
 import (
+	"git.lumeweb.com/LumeWeb/libs5-go/encoding"
+	"git.lumeweb.com/LumeWeb/libs5-go/internal/bases"
 	"git.lumeweb.com/LumeWeb/libs5-go/types"
 	"github.com/vmihailenco/msgpack/v5"
+	"go.uber.org/zap"
 )
 
 var _ IncomingMessage = (*RegistryEntryRequest)(nil)
@@ -50,5 +53,18 @@ func (s *RegistryEntryRequest) DecodeMessage(dec *msgpack.Decoder, message Incom
 }
 
 func (s *RegistryEntryRequest) HandleMessage(message IncomingMessageData) error {
+	entry, err := encoding.CIDFromRegistryPublicKey(s.sre.PK())
+	if err != nil {
+		return err
+	}
+	pid, err := message.Peer.Id().ToString()
+	if err != nil {
+		return err
+	}
+	b64, err := bases.ToBase64Url(s.sre.PK())
+	if err != nil {
+		return err
+	}
+	message.Logger.Debug("Handling registry entry set request", zap.Any("entryCID", entry), zap.Any("entryBase64", b64), zap.Any("peer", pid))
 	return message.Mediator.RegistrySet(s.sre, false, message.Peer)
 }
diff --git a/protocol/registry_query.go b/protocol/registry_query.go
index 0010155..fff646d 100644
--- a/protocol/registry_query.go
+++ b/protocol/registry_query.go
@@ -1,8 +1,11 @@
 package protocol
 
 import (
+	"git.lumeweb.com/LumeWeb/libs5-go/encoding"
+	"git.lumeweb.com/LumeWeb/libs5-go/internal/bases"
 	"git.lumeweb.com/LumeWeb/libs5-go/types"
 	"github.com/vmihailenco/msgpack/v5"
+	"go.uber.org/zap"
 )
 
 var _ IncomingMessage = (*RegistryQuery)(nil)
@@ -52,6 +55,21 @@ func (s *RegistryQuery) DecodeMessage(dec *msgpack.Decoder, message IncomingMess
 func (s *RegistryQuery) HandleMessage(message IncomingMessageData) error {
 	mediator := message.Mediator
 	peer := message.Peer
+
+	entry, err := encoding.CIDFromRegistryPublicKey(s.pk)
+	if err != nil {
+		return err
+	}
+	pid, err := peer.Id().ToString()
+	if err != nil {
+		return err
+	}
+	b64, err := bases.ToBase64Url(s.pk)
+	if err != nil {
+		return err
+	}
+	message.Logger.Debug("Handling registry entry query request", zap.Any("entryCID", entry), zap.Any("entryBase64", b64), zap.Any("peer", pid))
+
 	sre, err := mediator.RegistryGet(s.pk)
 	if err != nil {
 		return err