Codec callback

Makefile

@@ -1,5 +1,5 @@
 .PHONY: build build-release build-sncli build-sn-manager
-.PHONY: install-lumera setup-supernodes system-test-setup 
+.PHONY: install-lumera setup-supernodes system-test-setup install-deps
 .PHONY: gen-cascade gen-supernode
 .PHONY: test-e2e test-unit test-integration test-system
 
@@ -140,9 +140,9 @@ test-e2e:
 # Run cascade e2e tests only
 test-cascade:
 	@echo "Running cascade e2e tests..."
-	@cd tests/system && go test -tags=system_test -v -run TestCascadeE2E .
+	@cd tests/system && go mod tidy && go test -tags=system_test -v -run TestCascadeE2E .
 
 # Run sn-manager e2e tests only
 test-sn-manager:
 	@echo "Running sn-manager e2e tests..."
-	@cd tests/system && go test -tags=system_test -v -run '^TestSNManager' .
+	@cd tests/system && go test -tags=system_test -v -run '^TestSNManager' .

go.mod

@@ -3,7 +3,6 @@ module github.com/LumeraProtocol/supernode/v2
 go 1.24.1
 
 replace (
-	github.com/LumeraProtocol/supernode/v2/supernode => ./supernode
 	github.com/bytedance/sonic => github.com/bytedance/sonic v1.14.0
 	github.com/bytedance/sonic/loader => github.com/bytedance/sonic/loader v0.3.0
 )

p2p/kademlia/network.go

@@ -2,7 +2,6 @@ package kademlia
 
 import (
 	"context"
-	"encoding/hex"
 	"fmt"
 	"io"
 	"net"
@@ -951,7 +950,7 @@ func (s *Network) handleGetValuesRequest(ctx context.Context, message *Message,
 		i++
 	}
 
-	values, count, err := s.dht.store.RetrieveBatchValues(ctx, keys, true)
+	values, count, err := s.dht.store.RetrieveBatchValues(ctx, keys, false)
 	if err != nil {
 		err = errors.Errorf("batch find values: %w", err)
 		s.appendRetrieveEntry(message.Sender.IP, RecentBatchRetrieveEntry{
@@ -976,17 +975,8 @@ func (s *Network) handleGetValuesRequest(ctx context.Context, message *Message,
 
 	for i, key := range keys {
 		val := KeyValWithClosest{
-			Value: values[i],
-		}
-		if len(val.Value) == 0 {
-			decodedKey, err := hex.DecodeString(keys[i])
-			if err != nil {
-				err = errors.Errorf("batch find vals: decode key: %w - key %s", err, keys[i])
-				return s.generateResponseMessage(BatchGetValues, message.Sender, ResultFailed, err.Error())
-			}
-
-			nodes, _ := s.dht.ht.closestContacts(Alpha, decodedKey, []*Node{message.Sender})
-			val.Closest = nodes.Nodes
+			Value:   values[i],
+			Closest: make([]*Node, 0), // for compatibility, not used - each node now has full view of the whole network
 		}
 
 		request.Data[key] = val