fix(server): for putipns requests send errors back to the client

ipfs · Aug 30, 2022 · c294bed · c294bed
1 parent 14f45a8
commit c294bed
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/server.go b/server.go
@@ -242,7 +242,11 @@ func (d *delegatedRoutingProxy) GetIPNS(ctx context.Context, id []byte) (<-chan
 func (d *delegatedRoutingProxy) PutIPNS(ctx context.Context, id []byte, record []byte) (<-chan drc.PutIPNSAsyncResult, error) {
 	ctx, cancel := context.WithCancel(ctx)
 	defer cancel()
-	return nil, d.dht.PutValue(ctx, ipns.RecordKey(peer.ID(id)), record)
+	err := d.dht.PutValue(ctx, ipns.RecordKey(peer.ID(id)), record)
+	ch := make(chan drc.PutIPNSAsyncResult, 1)
+	ch <- drc.PutIPNSAsyncResult{Err: err}
+	close(ch)
+	return ch, nil
 }
 
 var _ drs.DelegatedRoutingService = (*delegatedRoutingProxy)(nil)