log find requests

chord/httpnode/client.go

@@ -5,6 +5,7 @@ import (
 	"encoding/base64"
 	"errors"
 	"fmt"
+	"log/slog"
 	"net/http"
 	"net/url"
 	"path"
@@ -35,6 +36,7 @@ func (cl *Client) Find(ctx context.Context, s chord.Peer, id chord.ID) (chord.Pe
 	if err != nil {
 		return chord.Peer{}, "", err
 	}
+	slog.InfoContext(ctx, "find", slog.String("url", url.String()))
 	resp, err := cl.HTTP.Do(req)
 	if err != nil {
 		return chord.Peer{}, "", err
@@ -43,6 +45,7 @@ func (cl *Client) Find(ctx context.Context, s chord.Peer, id chord.ID) (chord.Pe
 	if err != nil {
 		return chord.Peer{}, "", fmt.Errorf("%w (%s)", err, resp.Status)
 	}
+	slog.InfoContext(ctx, "found", slog.String("peer", p.Peer.String()), slog.String("value", p.Value))
 	return chord.Address(p.Peer), p.Value, nil
 }
 

chord/httpnode/httpnode.go

@@ -28,6 +28,9 @@ func writeError(w http.ResponseWriter, status int, msg string) {
 }
 
 func readResponse[T any](r *http.Response) (x T, err error) {
+	if r.StatusCode != http.StatusOK {
+		return x, errors.New(r.Status)
+	}
 	var b struct {
 		Data  T      `json:"data"`
 		Error string `json:"error"`
@@ -38,7 +41,7 @@ func readResponse[T any](r *http.Response) (x T, err error) {
 	if b.Error != "" {
 		return x, errors.New(b.Error)
 	}
-	return x, nil
+	return b.Data, nil
 }
 
 type neighbors struct {

chord/httpnode/server.go

@@ -6,6 +6,7 @@ import (
 	"errors"
 	"fmt"
 	"io"
+	"log/slog"
 	"net"
 	"net/http"
 	"net/netip"
@@ -67,6 +68,7 @@ func (n *Node) Check(ctx context.Context) error {
 
 func (n *Node) key(w http.ResponseWriter, r *http.Request) {
 	s := r.PathValue("id")
+	slog.InfoContext(r.Context(), "received find", slog.String("id", s), slog.String("from", r.RemoteAddr))
 	id, err := chord.ParseID(s)
 	if err != nil {
 		writeError(w, http.StatusBadRequest, err.Error())
@@ -78,6 +80,7 @@ func (n *Node) key(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 	_, addr := p.Values()
+	slog.InfoContext(r.Context(), "tell found", slog.String("id", s), slog.String("addr", addr.String()), slog.String("value", v))
 	pv := peervalue{addr, v}
 	writeOk(w, pv)
 }

main.go

@@ -147,7 +147,8 @@ func cliJoin(ctx context.Context, cmd *cli.Command) error {
 	cl := &httpnode.Client{HTTP: http.Client{Timeout: 5 * time.Second}}
 	var node *chord.Node
 	if peer := cmd.String("c"); peer != "" {
-		p, err := netip.ParseAddrPort(peer)
+		var p netip.AddrPort
+		p, err = netip.ParseAddrPort(peer)
 		if err != nil {
 			return err
 		}