fix(storagemarket): set miner peer id on deals

storagemarket/impl/provider.go

@@ -157,6 +157,7 @@ func (p *Provider) receiveDeal(s network.StorageDealStream) error {
 
 	deal := &storagemarket.MinerDeal{
 		Client:             s.RemotePeer(),
+		Miner:              p.net.ID(),
 		ClientDealProposal: *proposal.DealProposal,
 		ProposalCid:        proposalNd.Cid(),
 		State:              storagemarket.StorageDealUnknown,

storagemarket/integration_test.go

@@ -3,6 +3,7 @@ package storagemarket_test
 import (
 	"bytes"
 	"context"
+	"encoding/json"
 	"io/ioutil"
 	"math/rand"
 	"reflect"
@@ -44,7 +45,18 @@ func TestMakeDeal(t *testing.T) {
 
 	// set up a subscriber
 	dealChan := make(chan storagemarket.MinerDeal)
+	var checkedUnmarshalling bool
 	subscriber := func(event storagemarket.ProviderEvent, deal storagemarket.MinerDeal) {
+		if !checkedUnmarshalling {
+			// test that deal created can marshall and unmarshalled
+			jsonBytes, err := json.Marshal(deal)
+			require.NoError(t, err)
+			var unmarhalledDeal storagemarket.MinerDeal
+			err = json.Unmarshal(jsonBytes, &unmarhalledDeal)
+			require.NoError(t, err)
+			require.Equal(t, deal, unmarhalledDeal)
+			checkedUnmarshalling = true
+		}
 		dealChan <- deal
 	}
 	_ = h.Provider.SubscribeToEvents(subscriber)

storagemarket/network/libp2p_impl.go

@@ -83,3 +83,7 @@ func (impl *libp2pStorageMarketNetwork) handleNewDealStream(s network.Stream) {
 	ds := &dealStream{remotePID, s, buffered}
 	impl.receiver.HandleDealStream(ds)
 }
+
+func (impl *libp2pStorageMarketNetwork) ID() peer.ID {
+	return impl.host.ID()
+}

storagemarket/network/network.go

@@ -38,4 +38,5 @@ type StorageMarketNetwork interface {
 	NewDealStream(peer.ID) (StorageDealStream, error)
 	SetDelegate(StorageReceiver) error
 	StopHandlingRequests() error
+	ID() peer.ID
 }