@@ -335,7 +335,7 @@ func (service *OpenBazaarService) handleOrder(peer peer.ID, pmes *pb.Message, op
335
335
err = service .node .Datastore .Messages ().Put (
336
336
fmt .Sprintf ("%s-%d" , orderId , int (pb .Message_ORDER )),
337
337
orderId , pb .Message_ORDER , peer .Pretty (), repo.Message {Msg : * pmes },
338
- "" , time .Now ().UnixNano (), contract . VendorListings [ 0 ]. VendorID . Pubkeys . Identity )
338
+ "" , time .Now ().UnixNano (), [] byte ( peer ) )
339
339
if err != nil {
340
340
log .Errorf ("failed putting message (%s-%d): %v" , orderId , int (pb .Message_ORDER ), err )
341
341
}
@@ -410,7 +410,7 @@ func (service *OpenBazaarService) handleOrder(peer peer.ID, pmes *pb.Message, op
410
410
if err != nil {
411
411
return errorResponse (err .Error ()), err
412
412
}
413
- addr , err := wal .DecodeAddress (order .Payment .Address )
413
+ addr , err := wal .DecodeAddress (ut . NormalizeAddress ( order .Payment .Address ) )
414
414
if err != nil {
415
415
return errorResponse (err .Error ()), err
416
416
}
@@ -447,7 +447,7 @@ func (service *OpenBazaarService) handleOrder(peer peer.ID, pmes *pb.Message, op
447
447
if err != nil {
448
448
return errorResponse (err .Error ()), err
449
449
}
450
- addr , err := wal .DecodeAddress (order .Payment .Address )
450
+ addr , err := wal .DecodeAddress (ut . NormalizeAddress ( order .Payment .Address ) )
451
451
if err != nil {
452
452
return errorResponse (err .Error ()), err
453
453
}
@@ -532,7 +532,7 @@ func (service *OpenBazaarService) handleOrderConfirmation(p peer.ID, pmes *pb.Me
532
532
err = service .node .Datastore .Messages ().Put (
533
533
fmt .Sprintf ("%s-%d" , orderId , int (pb .Message_ORDER_CONFIRMATION )),
534
534
orderId , pb .Message_ORDER_CONFIRMATION , p .Pretty (), repo.Message {Msg : * pmes },
535
- "" , time .Now ().UnixNano (), vendorContract . BuyerOrder . BuyerID . Pubkeys . Identity )
535
+ "" , time .Now ().UnixNano (), [] byte ( p ) )
536
536
if err != nil {
537
537
log .Errorf ("failed putting message (%s-%d): %v" , orderId , int (pb .Message_ORDER_CONFIRMATION ), err )
538
538
}
@@ -634,7 +634,7 @@ func (service *OpenBazaarService) handleOrderCancel(p peer.ID, pmes *pb.Message,
634
634
err = service .node .Datastore .Messages ().Put (
635
635
fmt .Sprintf ("%s-%d" , orderId , int (pb .Message_ORDER_CANCEL )),
636
636
orderId , pb .Message_ORDER_CANCEL , p .Pretty (), repo.Message {Msg : * pmes },
637
- "" , time .Now ().UnixNano (), contract . BuyerOrder . BuyerID . Pubkeys . Identity )
637
+ "" , time .Now ().UnixNano (), [] byte ( p ) )
638
638
if err != nil {
639
639
log .Errorf ("failed putting message (%s-%d): %v" , orderId , int (pb .Message_ORDER_CANCEL ), err )
640
640
}
@@ -712,7 +712,7 @@ func (service *OpenBazaarService) handleReject(p peer.ID, pmes *pb.Message, opti
712
712
err = service .node .Datastore .Messages ().Put (
713
713
fmt .Sprintf ("%s-%d" , rejectMsg .OrderID , int (pb .Message_ORDER_REJECT )),
714
714
rejectMsg .OrderID , pb .Message_ORDER_REJECT , p .Pretty (), repo.Message {Msg : * pmes },
715
- "" , time .Now ().UnixNano (), contract . BuyerOrder . BuyerID . Pubkeys . Identity )
715
+ "" , time .Now ().UnixNano (), [] byte ( p ) )
716
716
if err != nil {
717
717
log .Errorf ("failed putting message (%s-%d): %v" , rejectMsg .OrderID , int (pb .Message_ORDER_REJECT ), err )
718
718
}
@@ -727,11 +727,11 @@ func (service *OpenBazaarService) handleReject(p peer.ID, pmes *pb.Message, opti
727
727
var txInputs []wallet.TransactionInput
728
728
for _ , r := range records {
729
729
if ! r .Spent && r .Value .Cmp (big .NewInt (0 )) > 0 {
730
- hash , err := hex .DecodeString (r .Txid )
730
+ hash , err := hex .DecodeString (ut . NormalizeAddress ( r .Txid ) )
731
731
if err != nil {
732
732
return nil , err
733
733
}
734
- addr , err := wal .DecodeAddress (r .Address )
734
+ addr , err := wal .DecodeAddress (ut . NormalizeAddress ( r .Address ) )
735
735
if err != nil {
736
736
return nil , err
737
737
}
@@ -762,7 +762,7 @@ func (service *OpenBazaarService) handleReject(p peer.ID, pmes *pb.Message, opti
762
762
if err != nil {
763
763
return nil , err
764
764
}
765
- refundAddress , err := wal .DecodeAddress (order .RefundAddress )
765
+ refundAddress , err := wal .DecodeAddress (ut . NormalizeAddress ( order .RefundAddress ) )
766
766
if err != nil {
767
767
return nil , err
768
768
}
@@ -775,7 +775,7 @@ func (service *OpenBazaarService) handleReject(p peer.ID, pmes *pb.Message, opti
775
775
outValue := big .NewInt (0 )
776
776
for _ , r := range records {
777
777
if ! r .Spent && r .Value .Cmp (big .NewInt (0 )) > 0 {
778
- outpointHash , err := hex .DecodeString (r .Txid )
778
+ outpointHash , err := hex .DecodeString (ut . NormalizeAddress ( r .Txid ) )
779
779
if err != nil {
780
780
return nil , err
781
781
}
@@ -785,7 +785,7 @@ func (service *OpenBazaarService) handleReject(p peer.ID, pmes *pb.Message, opti
785
785
}
786
786
}
787
787
788
- refundAddress , err := wal .DecodeAddress (order .RefundAddress )
788
+ refundAddress , err := wal .DecodeAddress (ut . NormalizeAddress ( order .RefundAddress ) )
789
789
if err != nil {
790
790
return nil , err
791
791
}
@@ -898,7 +898,7 @@ func (service *OpenBazaarService) handleRefund(p peer.ID, pmes *pb.Message, opti
898
898
err = service .node .Datastore .Messages ().Put (
899
899
fmt .Sprintf ("%s-%d" , rc .Refund .OrderID , int (pb .Message_REFUND )),
900
900
rc .Refund .OrderID , pb .Message_REFUND , p .Pretty (), repo.Message {Msg : * pmes },
901
- "" , time .Now ().UnixNano (), contract . VendorListings [ 0 ]. VendorID . Pubkeys . Identity )
901
+ "" , time .Now ().UnixNano (), [] byte ( p ) )
902
902
if err != nil {
903
903
log .Errorf ("failed putting message (%s-%d): %v" , rc .Refund .OrderID , int (pb .Message_REFUND ), err )
904
904
}
@@ -922,7 +922,7 @@ func (service *OpenBazaarService) handleRefund(p peer.ID, pmes *pb.Message, opti
922
922
outValue := big .NewInt (0 )
923
923
for _ , r := range records {
924
924
if ! r .Spent && r .Value .Cmp (big .NewInt (0 )) > 0 {
925
- outpointHash , err := hex .DecodeString (r .Txid )
925
+ outpointHash , err := hex .DecodeString (ut . NormalizeAddress ( r .Txid ) )
926
926
if err != nil {
927
927
return nil , err
928
928
}
@@ -932,7 +932,7 @@ func (service *OpenBazaarService) handleRefund(p peer.ID, pmes *pb.Message, opti
932
932
}
933
933
}
934
934
935
- refundAddress , err := wal .DecodeAddress (order .RefundAddress )
935
+ refundAddress , err := wal .DecodeAddress (ut . NormalizeAddress ( order .RefundAddress ) )
936
936
if err != nil {
937
937
return nil , err
938
938
}
@@ -1039,7 +1039,7 @@ func (service *OpenBazaarService) handleOrderFulfillment(p peer.ID, pmes *pb.Mes
1039
1039
err = service .node .Datastore .Messages ().Put (
1040
1040
fmt .Sprintf ("%s-%d" , rc .VendorOrderFulfillment [0 ].OrderId , int (pb .Message_ORDER_FULFILLMENT )),
1041
1041
rc .VendorOrderFulfillment [0 ].OrderId , pb .Message_ORDER_FULFILLMENT , p .Pretty (), repo.Message {Msg : * pmes },
1042
- "" , time .Now ().UnixNano (), rc . VendorListings [ 0 ]. VendorID . Pubkeys . Identity )
1042
+ "" , time .Now ().UnixNano (), [] byte ( p ) )
1043
1043
if err != nil {
1044
1044
log .Errorf ("failed putting message (%s-%d): %v" , rc .VendorOrderFulfillment [0 ].OrderId , int (pb .Message_ORDER_FULFILLMENT ), err )
1045
1045
}
@@ -1144,7 +1144,7 @@ func (service *OpenBazaarService) handleOrderCompletion(p peer.ID, pmes *pb.Mess
1144
1144
err = service .node .Datastore .Messages ().Put (
1145
1145
fmt .Sprintf ("%s-%d" , rc .BuyerOrderCompletion .OrderId , int (pb .Message_ORDER_COMPLETION )),
1146
1146
rc .BuyerOrderCompletion .OrderId , pb .Message_ORDER_COMPLETION , p .Pretty (), repo.Message {Msg : * pmes },
1147
- "" , time .Now ().UnixNano (), rc . BuyerOrder . BuyerID . Pubkeys . Identity )
1147
+ "" , time .Now ().UnixNano (), [] byte ( p ) )
1148
1148
if err != nil {
1149
1149
log .Errorf ("failed putting message (%s-%d): %v" , rc .BuyerOrderCompletion .OrderId , int (pb .Message_ORDER_COMPLETION ), err )
1150
1150
}
@@ -1202,7 +1202,8 @@ func (service *OpenBazaarService) handleOrderCompletion(p peer.ID, pmes *pb.Mess
1202
1202
}
1203
1203
var payoutAddress btcutil.Address
1204
1204
if len (contract .VendorOrderFulfillment ) > 0 {
1205
- payoutAddress , err = wal .DecodeAddress (contract .VendorOrderFulfillment [0 ].Payout .PayoutAddress )
1205
+ payoutAddress , err = wal .DecodeAddress (
1206
+ ut .NormalizeAddress (contract .VendorOrderFulfillment [0 ].Payout .PayoutAddress ))
1206
1207
if err != nil {
1207
1208
return nil , err
1208
1209
}
@@ -1240,7 +1241,7 @@ func (service *OpenBazaarService) handleOrderCompletion(p peer.ID, pmes *pb.Mess
1240
1241
err0 := service .node .Datastore .Messages ().Put (
1241
1242
fmt .Sprintf ("%s-%d" , rc .BuyerOrderCompletion .OrderId , int (pb .Message_ORDER_COMPLETION )),
1242
1243
rc .BuyerOrderCompletion .OrderId , pb .Message_ORDER_COMPLETION , p .Pretty (), repo.Message {Msg : * pmes },
1243
- err .Error (), time .Now ().UnixNano (), contract . BuyerOrder . BuyerID . Pubkeys . Identity )
1244
+ err .Error (), time .Now ().UnixNano (), [] byte ( p ) )
1244
1245
if err0 != nil {
1245
1246
log .Errorf ("failed putting message (%s-%d): %v" , rc .BuyerOrderCompletion .OrderId , int (pb .Message_ORDER_COMPLETION ), err0 )
1246
1247
}
@@ -1310,7 +1311,7 @@ func (service *OpenBazaarService) handleDisputeOpen(p peer.ID, pmes *pb.Message,
1310
1311
1311
1312
err = service .node .Datastore .Messages ().Put (
1312
1313
fmt .Sprintf ("%s-%d" , orderID , int (pb .Message_DISPUTE_OPEN )),
1313
- orderID , pb .Message_DISPUTE_OPEN , p .Pretty (), repo.Message {Msg : * pmes }, "" , time .Now ().UnixNano (), nil )
1314
+ orderID , pb .Message_DISPUTE_OPEN , p .Pretty (), repo.Message {Msg : * pmes }, "" , time .Now ().UnixNano (), [] byte ( p ) )
1314
1315
if err != nil {
1315
1316
log .Errorf ("failed putting message (%s-%d): %v" , orderID , int (pb .Message_DISPUTE_OPEN ), err )
1316
1317
}
@@ -1347,7 +1348,7 @@ func (service *OpenBazaarService) handleDisputeUpdate(p peer.ID, pmes *pb.Messag
1347
1348
orderID := update .OrderId
1348
1349
err = service .node .Datastore .Messages ().Put (
1349
1350
fmt .Sprintf ("%s-%d" , orderID , int (pb .Message_DISPUTE_UPDATE )),
1350
- orderID , pb .Message_DISPUTE_UPDATE , p .Pretty (), repo.Message {Msg : * pmes }, "" , time .Now ().UnixNano (), nil )
1351
+ orderID , pb .Message_DISPUTE_UPDATE , p .Pretty (), repo.Message {Msg : * pmes }, "" , time .Now ().UnixNano (), [] byte ( p ) )
1351
1352
if err != nil {
1352
1353
log .Errorf ("failed putting message (%s-%d): %v" , orderID , int (pb .Message_DISPUTE_UPDATE ), err )
1353
1354
}
@@ -1449,7 +1450,7 @@ func (service *OpenBazaarService) handleDisputeClose(p peer.ID, pmes *pb.Message
1449
1450
orderID := rc .DisputeResolution .OrderId
1450
1451
err = service .node .Datastore .Messages ().Put (
1451
1452
fmt .Sprintf ("%s-%d" , orderID , int (pb .Message_DISPUTE_CLOSE )),
1452
- orderID , pb .Message_DISPUTE_CLOSE , p .Pretty (), repo.Message {Msg : * pmes }, "" , time .Now ().UnixNano (), nil )
1453
+ orderID , pb .Message_DISPUTE_CLOSE , p .Pretty (), repo.Message {Msg : * pmes }, "" , time .Now ().UnixNano (), [] byte ( p ) )
1453
1454
if err != nil {
1454
1455
log .Errorf ("failed putting message (%s-%d): %v" , orderID , int (pb .Message_DISPUTE_CLOSE ), err )
1455
1456
}
@@ -1935,7 +1936,7 @@ func (service *OpenBazaarService) handleOrderPayment(peer peer.ID, pmes *pb.Mess
1935
1936
orderID := paymentDetails .OrderID
1936
1937
err = service .node .Datastore .Messages ().Put (
1937
1938
fmt .Sprintf ("%s-%d" , orderID , int (pb .Message_ORDER_PAYMENT )),
1938
- orderID , pb .Message_ORDER_PAYMENT , peer .Pretty (), repo.Message {Msg : * pmes }, "" , time .Now ().UnixNano (), nil )
1939
+ orderID , pb .Message_ORDER_PAYMENT , peer .Pretty (), repo.Message {Msg : * pmes }, "" , time .Now ().UnixNano (), [] byte ( peer ) )
1939
1940
if err != nil {
1940
1941
log .Errorf ("failed putting message (%s-%d): %v" , orderID , int (pb .Message_ORDER_PAYMENT ), err )
1941
1942
}
0 commit comments