feat: update nodesale protocol to include sellerWallet

2026-04-29 20:25:24 +08:00 · 2024-06-11 15:04:30 +07:00
parent 9b5caa589c
commit 9e11dd3c67
12 changed files with 162 additions and 98 deletions
--- a/modules/nodesale/database/postgresql/migrations/000001_initialize.up.sql
+++ b/modules/nodesale/database/postgresql/migrations/000001_initialize.up.sql
@@ -41,6 +41,7 @@ CREATE TABLE IF NOT EXISTS node_sales (
    "max_per_address" INTEGER NOT NULL,
    "deploy_tx_hash" TEXT NOT NULL REFERENCES events(tx_hash) ON DELETE CASCADE,
    "max_discount_percentage" INTEGER NOT NULL,
+    "seller_wallet" TEXT NOT NULL,
    PRIMARY KEY ("block_height", "tx_index")
 );

--- a/modules/nodesale/database/postgresql/queries/nodesales.sql
+++ b/modules/nodesale/database/postgresql/queries/nodesales.sql
@@ -1,6 +1,6 @@
 -- name: AddNodesale :exec
-INSERT INTO node_sales("block_height", "tx_index", "name", "starts_at", "ends_at", "tiers", "seller_public_key", "max_per_address", "deploy_tx_hash", "max_discount_percentage")
-VALUES ( $1, $2, $3, $4, $5, $6, $7, $8, $9, $10);
+INSERT INTO node_sales("block_height", "tx_index", "name", "starts_at", "ends_at", "tiers", "seller_public_key", "max_per_address", "deploy_tx_hash", "max_discount_percentage", "seller_wallet")
+VALUES ( $1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11);

 -- name: GetNodesale :many
 SELECT *
--- a/modules/nodesale/delegate_test.go
+++ b/modules/nodesale/delegate_test.go
@@ -1,13 +1,13 @@
 package nodesale

 import (
-	"crypto/sha256"
 	"encoding/hex"
 	"testing"
 	"time"

 	"github.com/btcsuite/btcd/btcec/v2"
 	"github.com/btcsuite/btcd/btcutil"
+	"github.com/btcsuite/btcd/chaincfg/chainhash"
 	"github.com/btcsuite/btcd/txscript"
 	"github.com/decred/dcrd/dcrec/secp256k1/v4/ecdsa"
 	"github.com/gaze-network/indexer-network/core/types"
@@ -18,8 +18,12 @@ import (
 )

 func TestDelegate(t *testing.T) {
+	if testing.Short() {
+		t.Skip("skipping test in short mode.")
+	}
 	sellerPrivateKey, _ := btcec.NewPrivateKey()
 	sellerPubkeyHex := hex.EncodeToString(sellerPrivateKey.PubKey().SerializeCompressed())
+	sellerWallet := p.pubkeyToPkHashAddress(sellerPrivateKey.PubKey())
 	startAt := time.Now().Add(time.Hour * -1)
 	endAt := time.Now().Add(time.Hour * 1)
 	deployMessage := &protobuf.NodeSaleEvent{
@@ -48,6 +52,7 @@ func TestDelegate(t *testing.T) {
 			SellerPublicKey:       sellerPubkeyHex,
 			MaxPerAddress:         100,
 			MaxDiscountPercentage: 50,
+			SellerWallet:          sellerWallet.EncodeAddress(),
 		},
 	}
 	event, block := assembleTestEvent(sellerPrivateKey, "111111", "111111", 0, 0, deployMessage)
@@ -68,7 +73,7 @@ func TestDelegate(t *testing.T) {
 	}

 	payloadBytes, _ := proto.Marshal(payload)
-	payloadHash := sha256.Sum256(payloadBytes)
+	payloadHash := chainhash.DoubleHashB(payloadBytes)
 	signature := ecdsa.Sign(sellerPrivateKey, payloadHash[:])
 	signatureHex := hex.EncodeToString(signature.Serialize())

--- a/modules/nodesale/deploy.go
+++ b/modules/nodesale/deploy.go
@@ -17,14 +17,6 @@ func (p *Processor) processDeploy(ctx context.Context, qtx gen.Querier, block *t
 	valid := true
 	deploy := event.eventMessage.Deploy

-	/*
-		sellerAddr, err := p.pubkeyToTaprootAddress(deploy.SellerPublicKey, event.rawScript)
-		if err != nil || !bytes.Equal(
-			[]byte(sellerAddr.EncodeAddress()),
-			[]byte(event.txAddress.EncodeAddress()),
-		) {
-			valid = false
-		}*/
 	sellerPubKeyBytes, err := hex.DecodeString(deploy.SellerPublicKey)
 	if err != nil {
 		valid = false
@@ -83,6 +75,7 @@ func (p *Processor) processDeploy(ctx context.Context, qtx gen.Querier, block *t
 			MaxPerAddress:         int32(deploy.MaxPerAddress),
 			DeployTxHash:          event.transaction.TxHash.String(),
 			MaxDiscountPercentage: int32(deploy.MaxDiscountPercentage),
+			SellerWallet:          deploy.SellerWallet,
 		})
 		if err != nil {
 			return fmt.Errorf("Failed to insert nodesale : %w", err)
--- a/modules/nodesale/deploy_test.go
+++ b/modules/nodesale/deploy_test.go
@@ -11,7 +11,11 @@ import (
 )

 func TestDeployInvalid(t *testing.T) {
+	if testing.Short() {
+		t.Skip("skipping test in short mode.")
+	}
 	prvKey, _ := btcec.NewPrivateKey()
+	sellerWallet := p.pubkeyToPkHashAddress(prvKey.PubKey())
 	message := &protobuf.NodeSaleEvent{
 		Action: protobuf.Action_ACTION_DEPLOY,
 		Deploy: &protobuf.ActionDeploy{
@@ -30,8 +34,10 @@ func TestDeployInvalid(t *testing.T) {
 					MaxPerAddress: 100,
 				},
 			},
-			SellerPublicKey: "0102030405",
-			MaxPerAddress:   100,
+			SellerPublicKey:       "0102030405",
+			MaxPerAddress:         100,
+			MaxDiscountPercentage: 50,
+			SellerWallet:          sellerWallet.EncodeAddress(),
 		},
 	}

@@ -46,8 +52,12 @@ func TestDeployInvalid(t *testing.T) {
 }

 func TestDeployValid(t *testing.T) {
+	if testing.Short() {
+		t.Skip("skipping test in short mode.")
+	}
 	privateKey, _ := btcec.NewPrivateKey()
 	pubkeyHex := hex.EncodeToString(privateKey.PubKey().SerializeCompressed())
+	sellerWallet := p.pubkeyToPkHashAddress(privateKey.PubKey())
 	message := &protobuf.NodeSaleEvent{
 		Action: protobuf.Action_ACTION_DEPLOY,
 		Deploy: &protobuf.ActionDeploy{
@@ -69,6 +79,7 @@ func TestDeployValid(t *testing.T) {
 			SellerPublicKey:       pubkeyHex,
 			MaxPerAddress:         100,
 			MaxDiscountPercentage: 50,
+			SellerWallet:          sellerWallet.EncodeAddress(),
 		},
 	}

--- a/modules/nodesale/nodesale_test.go
+++ b/modules/nodesale/nodesale_test.go
@@ -2,6 +2,7 @@ package nodesale

 import (
 	"context"
+	"flag"
 	"os"
 	"testing"
 	"time"
@@ -39,7 +40,10 @@ var (
 )

 func TestMain(m *testing.M) {
-	// call flag.Parse() here if TestMain uses flags
+	flag.Parse()
+	if testing.Short() {
+		return
+	}

 	ctx = context.Background()

@@ -73,13 +77,6 @@ func assembleTestEvent(privateKey *secp256k1.PrivateKey, blockHashHex, txHashHex
 	builder.AddOp(txscript.OP_IF)
 	builder.AddData(rawData)
 	builder.AddOp(txscript.OP_ENDIF)
-	// script, _ := builder.Script()
-	// tapleaf := txscript.NewBaseTapLeaf(script)
-	// scriptTree := txscript.AssembleTaprootScriptTree(tapleaf)
-	// rootHash := scriptTree.RootNode.TapHash()
-	// tapkey := txscript.ComputeTaprootOutputKey(privateKey.PubKey(), rootHash[:])
-
-	// addressTaproot, _ := btcutil.NewAddressTaproot(schnorr.SerializePubKey(tapkey), p.network.ChainParams())

 	messageJson, _ := protojson.Marshal(message)

@@ -102,9 +99,7 @@ func assembleTestEvent(privateKey *secp256k1.PrivateKey, blockHashHex, txHashHex
 		rawData:      rawData,
 		eventMessage: message,
 		eventJson:    messageJson,
-		// txAddress:    addressTaproot,
-		txPubkey: privateKey.PubKey(),
-		// rawScript:    script,
+		txPubkey:     privateKey.PubKey(),
 	}
 	block := &types.Block{
 		Header: types.BlockHeader{
--- a/modules/nodesale/protobuf/nodesale.pb.go
+++ b/modules/nodesale/protobuf/nodesale.pb.go
@@ -154,6 +154,7 @@ type ActionDeploy struct {
 	SellerPublicKey       string  `protobuf:"bytes,5,opt,name=sellerPublicKey,proto3" json:"sellerPublicKey,omitempty"`
 	MaxPerAddress         uint32  `protobuf:"varint,6,opt,name=maxPerAddress,proto3" json:"maxPerAddress,omitempty"`
 	MaxDiscountPercentage uint32  `protobuf:"varint,7,opt,name=maxDiscountPercentage,proto3" json:"maxDiscountPercentage,omitempty"`
+	SellerWallet          string  `protobuf:"bytes,8,opt,name=sellerWallet,proto3" json:"sellerWallet,omitempty"`
 }

 func (x *ActionDeploy) Reset() {
@@ -237,6 +238,13 @@ func (x *ActionDeploy) GetMaxDiscountPercentage() uint32 {
 	return 0
 }

+func (x *ActionDeploy) GetSellerWallet() string {
+	if x != nil {
+		return x.SellerWallet
+	}
+	return ""
+}
+
 type Tier struct {
 	state         protoimpl.MessageState
 	sizeCache     protoimpl.SizeCache
@@ -575,7 +583,7 @@ var file_modules_nodesale_protobuf_nodesale_proto_rawDesc = []byte{
 	0x64, 0x65, 0x6c, 0x65, 0x67, 0x61, 0x74, 0x65, 0x88, 0x01, 0x01, 0x42, 0x09, 0x0a, 0x07, 0x5f,
 	0x64, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x42, 0x0b, 0x0a, 0x09, 0x5f, 0x70, 0x75, 0x72, 0x63, 0x68,
 	0x61, 0x73, 0x65, 0x42, 0x0b, 0x0a, 0x09, 0x5f, 0x64, 0x65, 0x6c, 0x65, 0x67, 0x61, 0x74, 0x65,
-	0x22, 0x82, 0x02, 0x0a, 0x0c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x44, 0x65, 0x70, 0x6c, 0x6f,
+	0x22, 0xa6, 0x02, 0x0a, 0x0c, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x44, 0x65, 0x70, 0x6c, 0x6f,
 	0x79, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52,
 	0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x1a, 0x0a, 0x08, 0x73, 0x74, 0x61, 0x72, 0x74, 0x73, 0x41,
 	0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x08, 0x73, 0x74, 0x61, 0x72, 0x74, 0x73, 0x41,
@@ -591,55 +599,57 @@ var file_modules_nodesale_protobuf_nodesale_proto_rawDesc = []byte{
 	0x34, 0x0a, 0x15, 0x6d, 0x61, 0x78, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x50, 0x65,
 	0x72, 0x63, 0x65, 0x6e, 0x74, 0x61, 0x67, 0x65, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x15,
 	0x6d, 0x61, 0x78, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x50, 0x65, 0x72, 0x63, 0x65,
-	0x6e, 0x74, 0x61, 0x67, 0x65, 0x22, 0x5e, 0x0a, 0x04, 0x54, 0x69, 0x65, 0x72, 0x12, 0x1a, 0x0a,
-	0x08, 0x70, 0x72, 0x69, 0x63, 0x65, 0x53, 0x61, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52,
-	0x08, 0x70, 0x72, 0x69, 0x63, 0x65, 0x53, 0x61, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x6c, 0x69, 0x6d,
-	0x69, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x12,
-	0x24, 0x0a, 0x0d, 0x6d, 0x61, 0x78, 0x50, 0x65, 0x72, 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73,
-	0x18, 0x03, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0d, 0x6d, 0x61, 0x78, 0x50, 0x65, 0x72, 0x41, 0x64,
-	0x64, 0x72, 0x65, 0x73, 0x73, 0x22, 0x6f, 0x0a, 0x0e, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x50,
-	0x75, 0x72, 0x63, 0x68, 0x61, 0x73, 0x65, 0x12, 0x33, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f,
-	0x61, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x6e, 0x6f, 0x64, 0x65, 0x73,
-	0x61, 0x6c, 0x65, 0x2e, 0x50, 0x75, 0x72, 0x63, 0x68, 0x61, 0x73, 0x65, 0x50, 0x61, 0x79, 0x6c,
-	0x6f, 0x61, 0x64, 0x52, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x12, 0x28, 0x0a, 0x0f,
-	0x73, 0x65, 0x6c, 0x6c, 0x65, 0x72, 0x53, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65, 0x18,
-	0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0f, 0x73, 0x65, 0x6c, 0x6c, 0x65, 0x72, 0x53, 0x69, 0x67,
-	0x6e, 0x61, 0x74, 0x75, 0x72, 0x65, 0x22, 0xcf, 0x01, 0x0a, 0x0f, 0x50, 0x75, 0x72, 0x63, 0x68,
-	0x61, 0x73, 0x65, 0x50, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x12, 0x2e, 0x0a, 0x08, 0x64, 0x65,
-	0x70, 0x6c, 0x6f, 0x79, 0x49, 0x44, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x6e,
-	0x6f, 0x64, 0x65, 0x73, 0x61, 0x6c, 0x65, 0x2e, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x44,
-	0x52, 0x08, 0x64, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x49, 0x44, 0x12, 0x26, 0x0a, 0x0e, 0x62, 0x75,
-	0x79, 0x65, 0x72, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x63, 0x4b, 0x65, 0x79, 0x18, 0x02, 0x20, 0x01,
-	0x28, 0x09, 0x52, 0x0e, 0x62, 0x75, 0x79, 0x65, 0x72, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x63, 0x4b,
-	0x65, 0x79, 0x12, 0x18, 0x0a, 0x07, 0x6e, 0x6f, 0x64, 0x65, 0x49, 0x44, 0x73, 0x18, 0x03, 0x20,
-	0x03, 0x28, 0x0d, 0x52, 0x07, 0x6e, 0x6f, 0x64, 0x65, 0x49, 0x44, 0x73, 0x12, 0x26, 0x0a, 0x0e,
-	0x74, 0x6f, 0x74, 0x61, 0x6c, 0x41, 0x6d, 0x6f, 0x75, 0x6e, 0x74, 0x53, 0x61, 0x74, 0x18, 0x04,
-	0x20, 0x01, 0x28, 0x03, 0x52, 0x0e, 0x74, 0x6f, 0x74, 0x61, 0x6c, 0x41, 0x6d, 0x6f, 0x75, 0x6e,
-	0x74, 0x53, 0x61, 0x74, 0x12, 0x22, 0x0a, 0x0c, 0x74, 0x69, 0x6d, 0x65, 0x4f, 0x75, 0x74, 0x42,
-	0x6c, 0x6f, 0x63, 0x6b, 0x18, 0x05, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0c, 0x74, 0x69, 0x6d, 0x65,
-	0x4f, 0x75, 0x74, 0x42, 0x6c, 0x6f, 0x63, 0x6b, 0x22, 0x3a, 0x0a, 0x08, 0x41, 0x63, 0x74, 0x69,
-	0x6f, 0x6e, 0x49, 0x44, 0x12, 0x14, 0x0a, 0x05, 0x62, 0x6c, 0x6f, 0x63, 0x6b, 0x18, 0x01, 0x20,
-	0x01, 0x28, 0x04, 0x52, 0x05, 0x62, 0x6c, 0x6f, 0x63, 0x6b, 0x12, 0x18, 0x0a, 0x07, 0x74, 0x78,
-	0x49, 0x6e, 0x64, 0x65, 0x78, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x07, 0x74, 0x78, 0x49,
-	0x6e, 0x64, 0x65, 0x78, 0x22, 0x8a, 0x01, 0x0a, 0x0e, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x44,
-	0x65, 0x6c, 0x65, 0x67, 0x61, 0x74, 0x65, 0x12, 0x2e, 0x0a, 0x12, 0x64, 0x65, 0x6c, 0x65, 0x67,
-	0x61, 0x74, 0x65, 0x65, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x63, 0x4b, 0x65, 0x79, 0x18, 0x01, 0x20,
-	0x01, 0x28, 0x09, 0x52, 0x12, 0x64, 0x65, 0x6c, 0x65, 0x67, 0x61, 0x74, 0x65, 0x65, 0x50, 0x75,
-	0x62, 0x6c, 0x69, 0x63, 0x4b, 0x65, 0x79, 0x12, 0x18, 0x0a, 0x07, 0x6e, 0x6f, 0x64, 0x65, 0x49,
-	0x44, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0d, 0x52, 0x07, 0x6e, 0x6f, 0x64, 0x65, 0x49, 0x44,
-	0x73, 0x12, 0x2e, 0x0a, 0x08, 0x64, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x49, 0x44, 0x18, 0x03, 0x20,
-	0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x6e, 0x6f, 0x64, 0x65, 0x73, 0x61, 0x6c, 0x65, 0x2e, 0x41,
-	0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x44, 0x52, 0x08, 0x64, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x49,
-	0x44, 0x2a, 0x45, 0x0a, 0x06, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x11, 0x0a, 0x0d, 0x41,
-	0x43, 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x44, 0x45, 0x50, 0x4c, 0x4f, 0x59, 0x10, 0x00, 0x12, 0x13,
-	0x0a, 0x0f, 0x41, 0x43, 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x50, 0x55, 0x52, 0x43, 0x48, 0x41, 0x53,
-	0x45, 0x10, 0x01, 0x12, 0x13, 0x0a, 0x0f, 0x41, 0x43, 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x44, 0x45,
-	0x4c, 0x45, 0x47, 0x41, 0x54, 0x45, 0x10, 0x02, 0x42, 0x43, 0x5a, 0x41, 0x67, 0x69, 0x74, 0x68,
-	0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x67, 0x61, 0x7a, 0x65, 0x2d, 0x6e, 0x65, 0x74, 0x77,
-	0x6f, 0x72, 0x6b, 0x2f, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x65, 0x72, 0x2d, 0x6e, 0x65, 0x74, 0x77,
-	0x6f, 0x72, 0x6b, 0x2f, 0x6d, 0x6f, 0x64, 0x75, 0x6c, 0x65, 0x73, 0x2f, 0x6e, 0x6f, 0x64, 0x65,
-	0x73, 0x61, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x62, 0x06, 0x70,
-	0x72, 0x6f, 0x74, 0x6f, 0x33,
+	0x6e, 0x74, 0x61, 0x67, 0x65, 0x12, 0x22, 0x0a, 0x0c, 0x73, 0x65, 0x6c, 0x6c, 0x65, 0x72, 0x57,
+	0x61, 0x6c, 0x6c, 0x65, 0x74, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x73, 0x65, 0x6c,
+	0x6c, 0x65, 0x72, 0x57, 0x61, 0x6c, 0x6c, 0x65, 0x74, 0x22, 0x5e, 0x0a, 0x04, 0x54, 0x69, 0x65,
+	0x72, 0x12, 0x1a, 0x0a, 0x08, 0x70, 0x72, 0x69, 0x63, 0x65, 0x53, 0x61, 0x74, 0x18, 0x01, 0x20,
+	0x01, 0x28, 0x0d, 0x52, 0x08, 0x70, 0x72, 0x69, 0x63, 0x65, 0x53, 0x61, 0x74, 0x12, 0x14, 0x0a,
+	0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x05, 0x6c, 0x69,
+	0x6d, 0x69, 0x74, 0x12, 0x24, 0x0a, 0x0d, 0x6d, 0x61, 0x78, 0x50, 0x65, 0x72, 0x41, 0x64, 0x64,
+	0x72, 0x65, 0x73, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x0d, 0x6d, 0x61, 0x78, 0x50,
+	0x65, 0x72, 0x41, 0x64, 0x64, 0x72, 0x65, 0x73, 0x73, 0x22, 0x6f, 0x0a, 0x0e, 0x41, 0x63, 0x74,
+	0x69, 0x6f, 0x6e, 0x50, 0x75, 0x72, 0x63, 0x68, 0x61, 0x73, 0x65, 0x12, 0x33, 0x0a, 0x07, 0x70,
+	0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x6e,
+	0x6f, 0x64, 0x65, 0x73, 0x61, 0x6c, 0x65, 0x2e, 0x50, 0x75, 0x72, 0x63, 0x68, 0x61, 0x73, 0x65,
+	0x50, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x52, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64,
+	0x12, 0x28, 0x0a, 0x0f, 0x73, 0x65, 0x6c, 0x6c, 0x65, 0x72, 0x53, 0x69, 0x67, 0x6e, 0x61, 0x74,
+	0x75, 0x72, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0f, 0x73, 0x65, 0x6c, 0x6c, 0x65,
+	0x72, 0x53, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65, 0x22, 0xcf, 0x01, 0x0a, 0x0f, 0x50,
+	0x75, 0x72, 0x63, 0x68, 0x61, 0x73, 0x65, 0x50, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x12, 0x2e,
+	0x0a, 0x08, 0x64, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x49, 0x44, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b,
+	0x32, 0x12, 0x2e, 0x6e, 0x6f, 0x64, 0x65, 0x73, 0x61, 0x6c, 0x65, 0x2e, 0x41, 0x63, 0x74, 0x69,
+	0x6f, 0x6e, 0x49, 0x44, 0x52, 0x08, 0x64, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x49, 0x44, 0x12, 0x26,
+	0x0a, 0x0e, 0x62, 0x75, 0x79, 0x65, 0x72, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x63, 0x4b, 0x65, 0x79,
+	0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 0x62, 0x75, 0x79, 0x65, 0x72, 0x50, 0x75, 0x62,
+	0x6c, 0x69, 0x63, 0x4b, 0x65, 0x79, 0x12, 0x18, 0x0a, 0x07, 0x6e, 0x6f, 0x64, 0x65, 0x49, 0x44,
+	0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0d, 0x52, 0x07, 0x6e, 0x6f, 0x64, 0x65, 0x49, 0x44, 0x73,
+	0x12, 0x26, 0x0a, 0x0e, 0x74, 0x6f, 0x74, 0x61, 0x6c, 0x41, 0x6d, 0x6f, 0x75, 0x6e, 0x74, 0x53,
+	0x61, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0e, 0x74, 0x6f, 0x74, 0x61, 0x6c, 0x41,
+	0x6d, 0x6f, 0x75, 0x6e, 0x74, 0x53, 0x61, 0x74, 0x12, 0x22, 0x0a, 0x0c, 0x74, 0x69, 0x6d, 0x65,
+	0x4f, 0x75, 0x74, 0x42, 0x6c, 0x6f, 0x63, 0x6b, 0x18, 0x05, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0c,
+	0x74, 0x69, 0x6d, 0x65, 0x4f, 0x75, 0x74, 0x42, 0x6c, 0x6f, 0x63, 0x6b, 0x22, 0x3a, 0x0a, 0x08,
+	0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x44, 0x12, 0x14, 0x0a, 0x05, 0x62, 0x6c, 0x6f, 0x63,
+	0x6b, 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x05, 0x62, 0x6c, 0x6f, 0x63, 0x6b, 0x12, 0x18,
+	0x0a, 0x07, 0x74, 0x78, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0d, 0x52,
+	0x07, 0x74, 0x78, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x22, 0x8a, 0x01, 0x0a, 0x0e, 0x41, 0x63, 0x74,
+	0x69, 0x6f, 0x6e, 0x44, 0x65, 0x6c, 0x65, 0x67, 0x61, 0x74, 0x65, 0x12, 0x2e, 0x0a, 0x12, 0x64,
+	0x65, 0x6c, 0x65, 0x67, 0x61, 0x74, 0x65, 0x65, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x63, 0x4b, 0x65,
+	0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x12, 0x64, 0x65, 0x6c, 0x65, 0x67, 0x61, 0x74,
+	0x65, 0x65, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x63, 0x4b, 0x65, 0x79, 0x12, 0x18, 0x0a, 0x07, 0x6e,
+	0x6f, 0x64, 0x65, 0x49, 0x44, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0d, 0x52, 0x07, 0x6e, 0x6f,
+	0x64, 0x65, 0x49, 0x44, 0x73, 0x12, 0x2e, 0x0a, 0x08, 0x64, 0x65, 0x70, 0x6c, 0x6f, 0x79, 0x49,
+	0x44, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x6e, 0x6f, 0x64, 0x65, 0x73, 0x61,
+	0x6c, 0x65, 0x2e, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x44, 0x52, 0x08, 0x64, 0x65, 0x70,
+	0x6c, 0x6f, 0x79, 0x49, 0x44, 0x2a, 0x45, 0x0a, 0x06, 0x41, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12,
+	0x11, 0x0a, 0x0d, 0x41, 0x43, 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x44, 0x45, 0x50, 0x4c, 0x4f, 0x59,
+	0x10, 0x00, 0x12, 0x13, 0x0a, 0x0f, 0x41, 0x43, 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x50, 0x55, 0x52,
+	0x43, 0x48, 0x41, 0x53, 0x45, 0x10, 0x01, 0x12, 0x13, 0x0a, 0x0f, 0x41, 0x43, 0x54, 0x49, 0x4f,
+	0x4e, 0x5f, 0x44, 0x45, 0x4c, 0x45, 0x47, 0x41, 0x54, 0x45, 0x10, 0x02, 0x42, 0x43, 0x5a, 0x41,
+	0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x67, 0x61, 0x7a, 0x65, 0x2d,
+	0x6e, 0x65, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x2f, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x65, 0x72, 0x2d,
+	0x6e, 0x65, 0x74, 0x77, 0x6f, 0x72, 0x6b, 0x2f, 0x6d, 0x6f, 0x64, 0x75, 0x6c, 0x65, 0x73, 0x2f,
+	0x6e, 0x6f, 0x64, 0x65, 0x73, 0x61, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75,
+	0x66, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
 }

 var (
--- a/modules/nodesale/protobuf/nodesale.proto
+++ b/modules/nodesale/protobuf/nodesale.proto
@@ -26,6 +26,7 @@ message ActionDeploy {
 	string sellerPublicKey = 5;
 	uint32 maxPerAddress = 6;
 	uint32 maxDiscountPercentage = 7;
+	string sellerWallet = 8;
 }

 message Tier {
--- a/modules/nodesale/purchase.go
+++ b/modules/nodesale/purchase.go
@@ -3,7 +3,6 @@ package nodesale
 import (
 	"bytes"
 	"context"
-	"crypto/sha256"
 	"encoding/hex"
 	"encoding/json"
 	"fmt"
@@ -11,6 +10,8 @@ import (

 	"github.com/btcsuite/btcd/btcec/v2"
 	"github.com/btcsuite/btcd/btcec/v2/ecdsa"
+	"github.com/btcsuite/btcd/btcutil"
+	"github.com/btcsuite/btcd/chaincfg/chainhash"
 	"github.com/btcsuite/btcd/txscript"
 	"github.com/gaze-network/indexer-network/core/types"
 	"github.com/gaze-network/indexer-network/modules/nodesale/protobuf"
@@ -45,14 +46,7 @@ func (p *Processor) processPurchase(ctx context.Context, qtx gen.Querier, block
 			valid = false
 		}
 	}
-	/*
-		buyerAddr, err := p.pubkeyToTaprootAddress(payload.BuyerPublicKey, event.rawScript)
-		if err != nil || !bytes.Equal(
-			[]byte(buyerAddr.EncodeAddress()),
-			[]byte(event.txAddress.EncodeAddress()),
-		) {
-			valid = false
-		}*/
+
 	var deploy *gen.NodeSale
 	if valid {
 		// check node existed
@@ -94,7 +88,7 @@ func (p *Processor) processPurchase(ctx context.Context, qtx gen.Querier, block
 			valid = false
 		}
 		if valid {
-			hash := sha256.Sum256(payloadBytes)
+			hash := chainhash.DoubleHashB(payloadBytes)
 			pubkeyBytes, _ := hex.DecodeString(deploy.SellerPublicKey)
 			pubKey, _ := btcec.ParsePubKey(pubkeyBytes)
 			verified := signature.Verify(hash[:], pubKey)
@@ -154,13 +148,18 @@ func (p *Processor) processPurchase(ctx context.Context, qtx gen.Querier, block
 		}
 	}

+	var sellerAddr btcutil.Address
+	if valid {
+		sellerAddr, err = btcutil.DecodeAddress(deploy.SellerWallet, p.network.ChainParams())
+		if err != nil {
+			valid = false
+		}
+	}
+
 	var txPaid int64 = 0
 	meta := metaData{}
 	if valid {
 		// get total amount paid to seller
-		sellerPubKeyBytes, _ := hex.DecodeString(deploy.SellerPublicKey)
-		sellerPubKey, _ := btcec.ParsePubKey(sellerPubKeyBytes)
-		sellerAddr := p.pubkeyToPkHashAddress(sellerPubKey)
 		for _, txOut := range event.transaction.TxOut {
 			_, txOutAddrs, _, _ := txscript.ExtractPkScriptAddrs(txOut.PkScript, p.network.ChainParams())
 			if len(txOutAddrs) == 1 && bytes.Equal(
--- a/modules/nodesale/purchase_test.go
+++ b/modules/nodesale/purchase_test.go
@@ -1,13 +1,13 @@
 package nodesale

 import (
-	"crypto/sha256"
 	"encoding/hex"
 	"testing"
 	"time"

 	"github.com/btcsuite/btcd/btcec/v2"
 	"github.com/btcsuite/btcd/btcutil"
+	"github.com/btcsuite/btcd/chaincfg/chainhash"
 	"github.com/btcsuite/btcd/txscript"
 	"github.com/decred/dcrd/dcrec/secp256k1/v4/ecdsa"
 	"github.com/gaze-network/indexer-network/core/types"
@@ -18,6 +18,9 @@ import (
 )

 func TestInvalidPurchase(t *testing.T) {
+	if testing.Short() {
+		t.Skip("skipping test in short mode.")
+	}
 	buyerPrivateKey, _ := btcec.NewPrivateKey()
 	buyerPubkeyHex := hex.EncodeToString(buyerPrivateKey.PubKey().SerializeCompressed())

@@ -31,6 +34,8 @@ func TestInvalidPurchase(t *testing.T) {
 				},
 				NodeIDs:        []uint32{1, 2},
 				BuyerPublicKey: buyerPubkeyHex,
+				TotalAmountSat: 500,
+				TimeOutBlock:   uint64(testBlockHeigh) + 5,
 			},
 		},
 	}
@@ -48,8 +53,12 @@ func TestInvalidPurchase(t *testing.T) {
 }

 func TestInvalidTimestamp(t *testing.T) {
+	if testing.Short() {
+		t.Skip("skipping test in short mode.")
+	}
 	sellerPrivateKey, _ := btcec.NewPrivateKey()
 	sellerPubkeyHex := hex.EncodeToString(sellerPrivateKey.PubKey().SerializeCompressed())
+	sellerWallet := p.pubkeyToPkHashAddress(sellerPrivateKey.PubKey())
 	startAt := time.Now().Add(time.Hour * -1)
 	endAt := time.Now().Add(time.Hour * 1)
 	deployMessage := &protobuf.NodeSaleEvent{
@@ -73,6 +82,7 @@ func TestInvalidTimestamp(t *testing.T) {
 			SellerPublicKey:       sellerPubkeyHex,
 			MaxPerAddress:         100,
 			MaxDiscountPercentage: 50,
+			SellerWallet:          sellerWallet.EncodeAddress(),
 		},
 	}
 	event, block := assembleTestEvent(sellerPrivateKey, "040404040404", "040404040404", 0, 0, deployMessage)
@@ -91,6 +101,8 @@ func TestInvalidTimestamp(t *testing.T) {
 				},
 				NodeIDs:        []uint32{1, 2},
 				BuyerPublicKey: buyerPubkeyHex,
+				TotalAmountSat: 200,
+				TimeOutBlock:   uint64(testBlockHeigh) + 5,
 			},
 		},
 	}
@@ -108,8 +120,12 @@ func TestInvalidTimestamp(t *testing.T) {
 }

 func TestInvalidBuyerKey(t *testing.T) {
+	if testing.Short() {
+		t.Skip("skipping test in short mode.")
+	}
 	sellerPrivateKey, _ := btcec.NewPrivateKey()
 	sellerPubkeyHex := hex.EncodeToString(sellerPrivateKey.PubKey().SerializeCompressed())
+	sellerWallet := p.pubkeyToPkHashAddress(sellerPrivateKey.PubKey())
 	startAt := time.Now().Add(time.Hour * -1)
 	endAt := time.Now().Add(time.Hour * 1)
 	deployMessage := &protobuf.NodeSaleEvent{
@@ -133,6 +149,7 @@ func TestInvalidBuyerKey(t *testing.T) {
 			SellerPublicKey:       sellerPubkeyHex,
 			MaxPerAddress:         100,
 			MaxDiscountPercentage: 50,
+			SellerWallet:          sellerWallet.EncodeAddress(),
 		},
 	}
 	event, block := assembleTestEvent(sellerPrivateKey, "060606060606", "060606060606", 0, 0, deployMessage)
@@ -150,6 +167,8 @@ func TestInvalidBuyerKey(t *testing.T) {
 				},
 				NodeIDs:        []uint32{1, 2},
 				BuyerPublicKey: sellerPubkeyHex,
+				TotalAmountSat: 200,
+				TimeOutBlock:   uint64(testBlockHeigh) + 5,
 			},
 		},
 	}
@@ -166,8 +185,12 @@ func TestInvalidBuyerKey(t *testing.T) {
 }

 func TestTimeOut(t *testing.T) {
+	if testing.Short() {
+		t.Skip("skipping test in short mode.")
+	}
 	sellerPrivateKey, _ := btcec.NewPrivateKey()
 	sellerPubkeyHex := hex.EncodeToString(sellerPrivateKey.PubKey().SerializeCompressed())
+	sellerWallet := p.pubkeyToPkHashAddress(sellerPrivateKey.PubKey())
 	startAt := time.Now().Add(time.Hour * -1)
 	endAt := time.Now().Add(time.Hour * 1)
 	deployMessage := &protobuf.NodeSaleEvent{
@@ -191,6 +214,7 @@ func TestTimeOut(t *testing.T) {
 			SellerPublicKey:       sellerPubkeyHex,
 			MaxPerAddress:         100,
 			MaxDiscountPercentage: 50,
+			SellerWallet:          sellerWallet.EncodeAddress(),
 		},
 	}
 	event, block := assembleTestEvent(sellerPrivateKey, "0808080808", "0808080808", 0, 0, deployMessage)
@@ -210,6 +234,7 @@ func TestTimeOut(t *testing.T) {
 				NodeIDs:        []uint32{1, 2},
 				BuyerPublicKey: buyerPubkeyHex,
 				TimeOutBlock:   uint64(testBlockHeigh) - 5,
+				TotalAmountSat: 200,
 			},
 		},
 	}
@@ -225,8 +250,12 @@ func TestTimeOut(t *testing.T) {
 }

 func TestSignatureInvalid(t *testing.T) {
+	if testing.Short() {
+		t.Skip("skipping test in short mode.")
+	}
 	sellerPrivateKey, _ := btcec.NewPrivateKey()
 	sellerPubkeyHex := hex.EncodeToString(sellerPrivateKey.PubKey().SerializeCompressed())
+	sellerWallet := p.pubkeyToPkHashAddress(sellerPrivateKey.PubKey())
 	startAt := time.Now().Add(time.Hour * -1)
 	endAt := time.Now().Add(time.Hour * 1)
 	deployMessage := &protobuf.NodeSaleEvent{
@@ -250,6 +279,7 @@ func TestSignatureInvalid(t *testing.T) {
 			SellerPublicKey:       sellerPubkeyHex,
 			MaxPerAddress:         100,
 			MaxDiscountPercentage: 50,
+			SellerWallet:          sellerWallet.EncodeAddress(),
 		},
 	}
 	event, block := assembleTestEvent(sellerPrivateKey, "0A0A0A0A", "0A0A0A0A", 0, 0, deployMessage)
@@ -269,7 +299,7 @@ func TestSignatureInvalid(t *testing.T) {
 	}

 	payloadBytes, _ := proto.Marshal(payload)
-	payloadHash := sha256.Sum256(payloadBytes)
+	payloadHash := chainhash.DoubleHashB(payloadBytes)
 	signature := ecdsa.Sign(buyerPrivateKey, payloadHash[:])
 	signatureHex := hex.EncodeToString(signature.Serialize())

@@ -292,8 +322,12 @@ func TestSignatureInvalid(t *testing.T) {
 }

 func TestValidPurchase(t *testing.T) {
+	if testing.Short() {
+		t.Skip("skipping test in short mode.")
+	}
 	sellerPrivateKey, _ := btcec.NewPrivateKey()
 	sellerPubkeyHex := hex.EncodeToString(sellerPrivateKey.PubKey().SerializeCompressed())
+	sellerWallet := p.pubkeyToPkHashAddress(sellerPrivateKey.PubKey())
 	startAt := time.Now().Add(time.Hour * -1)
 	endAt := time.Now().Add(time.Hour * 1)
 	deployMessage := &protobuf.NodeSaleEvent{
@@ -322,6 +356,7 @@ func TestValidPurchase(t *testing.T) {
 			SellerPublicKey:       sellerPubkeyHex,
 			MaxPerAddress:         100,
 			MaxDiscountPercentage: 50,
+			SellerWallet:          sellerWallet.EncodeAddress(),
 		},
 	}
 	event, block := assembleTestEvent(sellerPrivateKey, "0C0C0C0C0C", "0C0C0C0C0C", 0, 0, deployMessage)
@@ -342,7 +377,7 @@ func TestValidPurchase(t *testing.T) {
 	}

 	payloadBytes, _ := proto.Marshal(payload)
-	payloadHash := sha256.Sum256(payloadBytes)
+	payloadHash := chainhash.DoubleHashB(payloadBytes)
 	signature := ecdsa.Sign(sellerPrivateKey, payloadHash[:])
 	signatureHex := hex.EncodeToString(signature.Serialize())

@@ -382,8 +417,12 @@ func TestValidPurchase(t *testing.T) {
 }

 func TestBuyingLimit(t *testing.T) {
+	if testing.Short() {
+		t.Skip("skipping test in short mode.")
+	}
 	sellerPrivateKey, _ := btcec.NewPrivateKey()
 	sellerPubkeyHex := hex.EncodeToString(sellerPrivateKey.PubKey().SerializeCompressed())
+	sellerWallet := p.pubkeyToPkHashAddress(sellerPrivateKey.PubKey())
 	startAt := time.Now().Add(time.Hour * -1)
 	endAt := time.Now().Add(time.Hour * 1)
 	deployMessage := &protobuf.NodeSaleEvent{
@@ -412,6 +451,7 @@ func TestBuyingLimit(t *testing.T) {
 			SellerPublicKey:       sellerPubkeyHex,
 			MaxPerAddress:         2,
 			MaxDiscountPercentage: 50,
+			SellerWallet:          sellerWallet.EncodeAddress(),
 		},
 	}
 	event, block := assembleTestEvent(sellerPrivateKey, "2121212121", "2121212121", 0, 0, deployMessage)
@@ -432,7 +472,7 @@ func TestBuyingLimit(t *testing.T) {
 	}

 	payloadBytes, _ := proto.Marshal(payload)
-	payloadHash := sha256.Sum256(payloadBytes)
+	payloadHash := chainhash.DoubleHashB(payloadBytes)
 	signature := ecdsa.Sign(sellerPrivateKey, payloadHash[:])
 	signatureHex := hex.EncodeToString(signature.Serialize())

@@ -472,7 +512,7 @@ func TestBuyingLimit(t *testing.T) {
 	}

 	payloadBytes, _ = proto.Marshal(payload)
-	payloadHash = sha256.Sum256(payloadBytes)
+	payloadHash = chainhash.DoubleHashB(payloadBytes)
 	signature = ecdsa.Sign(sellerPrivateKey, payloadHash[:])
 	signatureHex = hex.EncodeToString(signature.Serialize())

@@ -511,8 +551,12 @@ func TestBuyingLimit(t *testing.T) {
 }

 func TestBuyingTierLimit(t *testing.T) {
+	if testing.Short() {
+		t.Skip("skipping test in short mode.")
+	}
 	sellerPrivateKey, _ := btcec.NewPrivateKey()
 	sellerPubkeyHex := hex.EncodeToString(sellerPrivateKey.PubKey().SerializeCompressed())
+	sellerWallet := p.pubkeyToPkHashAddress(sellerPrivateKey.PubKey())
 	startAt := time.Now().Add(time.Hour * -1)
 	endAt := time.Now().Add(time.Hour * 1)
 	deployMessage := &protobuf.NodeSaleEvent{
@@ -541,6 +585,7 @@ func TestBuyingTierLimit(t *testing.T) {
 			SellerPublicKey:       sellerPubkeyHex,
 			MaxPerAddress:         100,
 			MaxDiscountPercentage: 50,
+			SellerWallet:          sellerWallet.EncodeAddress(),
 		},
 	}
 	event, block := assembleTestEvent(sellerPrivateKey, "0E0E0E0E", "0E0E0E0E", 0, 0, deployMessage)
@@ -561,7 +606,7 @@ func TestBuyingTierLimit(t *testing.T) {
 	}

 	payloadBytes, _ := proto.Marshal(payload)
-	payloadHash := sha256.Sum256(payloadBytes)
+	payloadHash := chainhash.DoubleHashB(payloadBytes)
 	signature := ecdsa.Sign(sellerPrivateKey, payloadHash[:])
 	signatureHex := hex.EncodeToString(signature.Serialize())

@@ -601,7 +646,7 @@ func TestBuyingTierLimit(t *testing.T) {
 	}

 	payloadBytes, _ = proto.Marshal(payload)
-	payloadHash = sha256.Sum256(payloadBytes)
+	payloadHash = chainhash.DoubleHashB(payloadBytes)
 	signature = ecdsa.Sign(sellerPrivateKey, payloadHash[:])
 	signatureHex = hex.EncodeToString(signature.Serialize())

--- a/modules/nodesale/repository/postgres/gen/models.go
+++ b/modules/nodesale/repository/postgres/gen/models.go
@@ -50,4 +50,5 @@ type NodeSale struct {
 	MaxPerAddress         int32
 	DeployTxHash          string
 	MaxDiscountPercentage int32
+	SellerWallet          string
 }
--- a/modules/nodesale/repository/postgres/gen/nodesales.sql.go
+++ b/modules/nodesale/repository/postgres/gen/nodesales.sql.go
@@ -12,8 +12,8 @@ import (
 )

 const addNodesale = `-- name: AddNodesale :exec
-INSERT INTO node_sales("block_height", "tx_index", "name", "starts_at", "ends_at", "tiers", "seller_public_key", "max_per_address", "deploy_tx_hash", "max_discount_percentage")
-VALUES ( $1, $2, $3, $4, $5, $6, $7, $8, $9, $10)
+INSERT INTO node_sales("block_height", "tx_index", "name", "starts_at", "ends_at", "tiers", "seller_public_key", "max_per_address", "deploy_tx_hash", "max_discount_percentage", "seller_wallet")
+VALUES ( $1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11)
 `

 type AddNodesaleParams struct {
@@ -27,6 +27,7 @@ type AddNodesaleParams struct {
 	MaxPerAddress         int32
 	DeployTxHash          string
 	MaxDiscountPercentage int32
+	SellerWallet          string
 }

 func (q *Queries) AddNodesale(ctx context.Context, arg AddNodesaleParams) error {
@@ -41,12 +42,13 @@ func (q *Queries) AddNodesale(ctx context.Context, arg AddNodesaleParams) error
 		arg.MaxPerAddress,
 		arg.DeployTxHash,
 		arg.MaxDiscountPercentage,
+		arg.SellerWallet,
 	)
 	return err
 }

 const getNodesale = `-- name: GetNodesale :many
-SELECT block_height, tx_index, name, starts_at, ends_at, tiers, seller_public_key, max_per_address, deploy_tx_hash, max_discount_percentage
+SELECT block_height, tx_index, name, starts_at, ends_at, tiers, seller_public_key, max_per_address, deploy_tx_hash, max_discount_percentage, seller_wallet
 FROM node_sales
 WHERE block_height = $1 AND
    tx_index = $2
@@ -77,6 +79,7 @@ func (q *Queries) GetNodesale(ctx context.Context, arg GetNodesaleParams) ([]Nod
 			&i.MaxPerAddress,
 			&i.DeployTxHash,
 			&i.MaxDiscountPercentage,
+			&i.SellerWallet,
 		); err != nil {
 			return nil, err
 		}