wip

routing/http/client/client.go

@@ -222,7 +222,7 @@ func (c *client) GetProviders(ctx context.Context, key cid.Cid) (provs iter.Resu
 		it = iter.ToResultIter(sliceIt)
 	case mediaTypeNDJSON:
 		skipBodyClose = true
-		it = ndjson.NewProvidersResponseIter(resp.Body)
+		it = ndjson.NewRecordsIter(resp.Body)
 	default:
 		logger.Errorw("unknown media type", "MediaType", mediaType, "ContentType", respContentType)
 		return nil, errors.New("unknown content type")

routing/http/client/client_test.go

@@ -35,6 +35,11 @@ func (m *mockContentRouter) GetProviders(ctx context.Context, key cid.Cid, limit
 	return args.Get(0).(iter.ResultIter[types.Record]), args.Error(1)
 }
 
+func (m *mockContentRouter) GetPeers(ctx context.Context, pid peer.ID, limit int) (iter.ResultIter[types.Record], error) {
+	args := m.Called(ctx, pid, limit)
+	return args.Get(0).(iter.ResultIter[types.Record]), args.Error(1)
+}
+
 func (m *mockContentRouter) GetIPNSRecord(ctx context.Context, name ipns.Name) (*ipns.Record, error) {
 	args := m.Called(ctx, name)
 	return args.Get(0).(*ipns.Record), args.Error(1)

routing/http/server/server.go

@@ -19,6 +19,7 @@ import (
 	"github.com/ipfs/boxo/routing/http/types/iter"
 	jsontypes "github.com/ipfs/boxo/routing/http/types/json"
 	"github.com/ipfs/go-cid"
+	"github.com/libp2p/go-libp2p/core/peer"
 
 	logging "github.com/ipfs/go-log/v2"
 )
@@ -37,6 +38,7 @@ var logger = logging.Logger("service/server/delegatedrouting")
 
 const (
 	GetProvidersPath  = "/routing/v1/providers/{cid}"
+	GetPeersPath      = "/routing/v1/peers/{peer-id}"
 	GetIPNSRecordPath = "/routing/v1/ipns/{cid}"
 )
 
@@ -50,6 +52,10 @@ type ContentRouter interface {
 	// Limit indicates the maximum amount of results to return; 0 means unbounded.
 	GetProviders(ctx context.Context, key cid.Cid, limit int) (iter.ResultIter[types.Record], error)
 
+	// GetPeers searches for peers who have the provided [peer.ID].
+	// Limit indicates the maximum amount of results to return; 0 means unbounded.
+	GetPeers(ctx context.Context, pid peer.ID, limit int) (iter.ResultIter[types.Record], error)
+
 	// GetIPNSRecord searches for an [ipns.Record] for the given [ipns.Name].
 	GetIPNSRecord(ctx context.Context, name ipns.Name) (*ipns.Record, error)
 
@@ -96,8 +102,10 @@ func Handler(svc ContentRouter, opts ...Option) http.Handler {
 
 	r := mux.NewRouter()
 	r.HandleFunc(GetProvidersPath, server.getProviders).Methods(http.MethodGet)
+	r.HandleFunc(GetPeersPath, server.getPeers).Methods(http.MethodGet)
 	r.HandleFunc(GetIPNSRecordPath, server.getIPNSRecord).Methods(http.MethodGet)
 	r.HandleFunc(GetIPNSRecordPath, server.putIPNSRecord).Methods(http.MethodPut)
+
 	return r
 }
 
@@ -222,6 +230,27 @@ func (s *server) getProvidersNDJSON(w http.ResponseWriter, provIter iter.ResultI
 	}
 }
 
+func (s *server) getPeers(w http.ResponseWriter, r *http.Request) {
+	pidStr := mux.Vars(r)["peer-id"]
+
+	// pidStr must be in CIDv1 format. Therefore, use [cid.Decode]. We can't use
+	// [peer.Decode] because that would allow other formats to pass through.
+	cid, err := cid.Decode(pidStr)
+	if err != nil {
+		writeErr(w, "GetPeers", http.StatusBadRequest, fmt.Errorf("unable to parse peer ID: %w", err))
+		return
+	}
+
+	pid, err := peer.FromCid(cid)
+	if err != nil {
+		writeErr(w, "GetPeers", http.StatusBadRequest, fmt.Errorf("unable to parse peer ID: %w", err))
+		return
+	}
+
+	// TODO
+	_ = pid
+}
+
 func (s *server) getIPNSRecord(w http.ResponseWriter, r *http.Request) {
 	if !strings.Contains(r.Header.Get("Accept"), mediaTypeIPNSRecord) {
 		writeErr(w, "GetIPNSRecord", http.StatusNotAcceptable, errors.New("content type in 'Accept' header is missing or not supported"))

routing/http/server/server_test.go

@@ -262,6 +262,11 @@ func (m *mockContentRouter) GetProviders(ctx context.Context, key cid.Cid, limit
 	return args.Get(0).(iter.ResultIter[types.Record]), args.Error(1)
 }
 
+func (m *mockContentRouter) GetPeers(ctx context.Context, pid peer.ID, limit int) (iter.ResultIter[types.Record], error) {
+	args := m.Called(ctx, pid, limit)
+	return args.Get(0).(iter.ResultIter[types.Record]), args.Error(1)
+}
+
 func (m *mockContentRouter) GetIPNSRecord(ctx context.Context, name ipns.Name) (*ipns.Record, error) {
 	args := m.Called(ctx, name)
 	return args.Get(0).(*ipns.Record), args.Error(1)

routing/http/types/json/providers.go → routing/http/types/json/responses.go

@@ -8,17 +8,25 @@ import (
 
 // ProvidersResponse is the result of a GET Providers request.
 type ProvidersResponse struct {
-	Providers []types.Record
+	Providers RecordsArray
 }
 
-func (r *ProvidersResponse) UnmarshalJSON(b []byte) error {
-	var tempFPR struct{ Providers []json.RawMessage }
-	err := json.Unmarshal(b, &tempFPR)
+// PeersResponse is the result of a GET Peers request.
+type PeersResponse struct {
+	Peers RecordsArray
+}
+
+// RecordsArray is an array of [types.Record]
+type RecordsArray []types.Record
+
+func (r *RecordsArray) UnmarshalJSON(b []byte) error {
+	var tempRecords []json.RawMessage
+	err := json.Unmarshal(b, &tempRecords)
 	if err != nil {
 		return err
 	}
 
-	for _, provBytes := range tempFPR.Providers {
+	for _, provBytes := range tempRecords {
 		var readProv types.UnknownRecord
 		err := json.Unmarshal(provBytes, &readProv)
 		if err != nil {
@@ -32,9 +40,9 @@ func (r *ProvidersResponse) UnmarshalJSON(b []byte) error {
 			if err != nil {
 				return err
 			}
-			r.Providers = append(r.Providers, &prov)
+			*r = append(*r, &prov)
 		default:
-			r.Providers = append(r.Providers, &readProv)
+			*r = append(*r, &readProv)
 		}
 
 	}

routing/http/types/ndjson/providers.go → routing/http/types/ndjson/records.go

@@ -8,8 +8,8 @@ import (
 	"github.com/ipfs/boxo/routing/http/types/iter"
 )
 
-// NewProvidersResponseIter returns an iterator that reads [types.Record] from the given [io.Reader].
-func NewProvidersResponseIter(r io.Reader) iter.Iter[iter.Result[types.Record]] {
+// NewRecordsIter returns an iterator that reads [types.Record] from the given [io.Reader].
+func NewRecordsIter(r io.Reader) iter.Iter[iter.Result[types.Record]] {
 	jsonIter := iter.FromReaderJSON[types.UnknownRecord](r)
 	mapFn := func(upr iter.Result[types.UnknownRecord]) iter.Result[types.Record] {
 		var result iter.Result[types.Record]