Database: Add --txIndex to kaspad

app/appmessage/message.go

@@ -163,6 +163,30 @@ const (
 	CmdGetMempoolEntriesByAddressesResponseMessage
 	CmdGetCoinSupplyRequestMessage
 	CmdGetCoinSupplyResponseMessage
+	CmdGetAcceptingBlockHashOfTxRequestMessage
+	CmdGetAcceptingBlockHashOfTxResponseMessage
+	CmdGetAcceptingBlockHashesOfTxsRequestMessage
+	CmdGetAcceptingBlockHashesOfTxsResponseMessage
+	CmdGetAcceptingBlockOfTxRequestMessage
+	CmdGetAcceptingBlockOfTxResponseMessage
+	CmdGetAcceptingBlocksOfTxsRequestMessage
+	CmdGetAcceptingBlocksOfTxsResponseMessage
+	CmdGetIncludingBlockHashOfTxRequestMessage
+	CmdGetIncludingBlockHashOfTxResponseMessage
+	CmdGetIncludingBlockHashesOfTxsRequestMessage
+	CmdGetIncludingBlockHashesOfTxsResponseMessage
+	CmdGetIncludingBlockOfTxRequestMessage
+	CmdGetIncludingBlockOfTxResponseMessage
+	CmdGetIncludingBlocksOfTxsRequestMessage
+	CmdGetIncludingBlocksOfTxsResponseMessage
+	CmdGetTxRequestMessage
+	CmdGetTxResponseMessage
+	CmdGetTxsRequestMessage
+	CmdGetTxsResponseMessage
+	CmdGetTxConfirmationsRequestMessage
+	CmdGetTxConfirmationsResponseMessage
+	CmdGetTxsConfirmationsRequestMessage
+	CmdGetTxsConfirmationsResponseMessage
 )
 
 // ProtocolMessageCommandToString maps all MessageCommands to their string representation
@@ -300,6 +324,30 @@ var RPCMessageCommandToString = map[MessageCommand]string{
 	CmdGetMempoolEntriesByAddressesResponseMessage:                "GetMempoolEntriesByAddressesResponse",
 	CmdGetCoinSupplyRequestMessage:                                "GetCoinSupplyRequest",
 	CmdGetCoinSupplyResponseMessage:                               "GetCoinSupplyResponse",
+	CmdGetAcceptingBlockHashOfTxRequestMessage:                    "GetAcceptingBlockHashOfTxRequest",
+	CmdGetAcceptingBlockHashOfTxResponseMessage:                   "GetAcceptingBlockHashOfTxResponse",
+	CmdGetAcceptingBlockHashesOfTxsRequestMessage:                 "GetAcceptingBlockHashesOfTxsRequest",
+	CmdGetAcceptingBlockHashesOfTxsResponseMessage:                "GetAcceptingBlockHashesOfTxsResponse",
+	CmdGetAcceptingBlockOfTxRequestMessage:                        "GetAcceptingBlockOfTxRequest",
+	CmdGetAcceptingBlockOfTxResponseMessage:                       "GetAcceptingBlockOfTxResponse",
+	CmdGetAcceptingBlocksOfTxsRequestMessage:                      "GetAcceptingBlocksOfTxsRequest",
+	CmdGetAcceptingBlocksOfTxsResponseMessage:                     "GetAcceptingBlocksOfTxsResponse",
+	CmdGetIncludingBlockHashOfTxRequestMessage:                    "GetIncludingBlockHashOfTxRequest",
+	CmdGetIncludingBlockHashOfTxResponseMessage:                   "GetIncludingBlockHashOfTxResponse",
+	CmdGetIncludingBlockHashesOfTxsRequestMessage:                 "GetIncludingBlockHashesOfTxsRequest",
+	CmdGetIncludingBlockHashesOfTxsResponseMessage:                "GetIncludingBlockHashesOfTxsResponse",
+	CmdGetIncludingBlockOfTxRequestMessage:                        "GetIncludingBlockOfTxRequest",
+	CmdGetIncludingBlockOfTxResponseMessage:                       "GetIncludingBlockOfTxResponse",
+	CmdGetIncludingBlocksOfTxsRequestMessage:                      "GetIncludingBlocksOfTxsRequest",
+	CmdGetIncludingBlocksOfTxsResponseMessage:                     "GetIncludingBlocksOfTxsResponse",
+	CmdGetTxRequestMessage:                                        "GetTxRequest",
+	CmdGetTxResponseMessage:                                       "GetTxResponse",
+	CmdGetTxsRequestMessage:                                       "GetTxsRequest",
+	CmdGetTxsResponseMessage:                                      "GetTxsResponse",
+	CmdGetTxConfirmationsRequestMessage:                           "GetTxConfirmationsRequest",
+	CmdGetTxConfirmationsResponseMessage:                          "GetTxConfirmationsResponse",
+	CmdGetTxsConfirmationsRequestMessage:                          "GetTxsConfirmationsRequest",
+	CmdGetTxsConfirmationsResponseMessage:                         "GetTxsConfirmationsResponse",
 }
 
 // Message is an interface that describes a kaspa message. A type that

app/appmessage/rpc_get_accepting_block_of_tx.go

@@ -0,0 +1,43 @@
+package appmessage
+
+// GetAcceptingBlockOfTxRequestMessage is an appmessage corresponding to
+// its respective RPC message
+type GetAcceptingBlockOfTxRequestMessage struct {
+	baseMessage
+	TxID                string
+	IncludeTransactions bool
+}
+
+// Command returns the protocol command string for the message
+func (msg *GetAcceptingBlockOfTxRequestMessage) Command() MessageCommand {
+	return CmdGetAcceptingBlockOfTxRequestMessage
+}
+
+// NewGetAcceptingBlockOfTxRequest returns a instance of the message
+func NewGetAcceptingBlockOfTxRequest(txID string, includeTransactions bool) *GetAcceptingBlockOfTxRequestMessage {
+	return &GetAcceptingBlockOfTxRequestMessage{
+		TxID:                txID,
+		IncludeTransactions: includeTransactions,
+	}
+}
+
+// GetAcceptingBlockOfTxResponseMessage is an appmessage corresponding to
+// its respective RPC message
+type GetAcceptingBlockOfTxResponseMessage struct {
+	baseMessage
+	Block *RPCBlock
+
+	Error *RPCError
+}
+
+// Command returns the protocol command string for the message
+func (msg *GetAcceptingBlockOfTxResponseMessage) Command() MessageCommand {
+	return CmdGetAcceptingBlockOfTxResponseMessage
+}
+
+// NewGetAcceptingBlockOfTxResponse returns an instance of the message
+func NewGetAcceptingBlockOfTxResponse(block *RPCBlock) *GetAcceptingBlockOfTxResponseMessage {
+	return &GetAcceptingBlockOfTxResponseMessage{
+		Block: block,
+	}
+}

app/appmessage/rpc_get_accepting_blockhash_of_tx.go

@@ -0,0 +1,41 @@
+package appmessage
+
+// GetAcceptingBlockHashOfTxRequestMessage is an appmessage corresponding to
+// its respective RPC message
+type GetAcceptingBlockHashOfTxRequestMessage struct {
+	baseMessage
+	TxID string
+}
+
+// Command returns the protocol command string for the message
+func (msg *GetAcceptingBlockHashOfTxRequestMessage) Command() MessageCommand {
+	return CmdGetAcceptingBlockHashOfTxRequestMessage
+}
+
+// NewGetAcceptingBlockHashOfTxRequest returns a instance of the message
+func NewGetAcceptingBlockHashOfTxRequest(txID string) *GetAcceptingBlockHashOfTxRequestMessage {
+	return &GetAcceptingBlockHashOfTxRequestMessage{
+		TxID: txID,
+	}
+}
+
+// GetAcceptingBlockHashOfTxResponseMessage is an appmessage corresponding to
+// its respective RPC message
+type GetAcceptingBlockHashOfTxResponseMessage struct {
+	baseMessage
+	Hash string
+
+	Error *RPCError
+}
+
+// Command returns the protocol command string for the message
+func (msg *GetAcceptingBlockHashOfTxResponseMessage) Command() MessageCommand {
+	return CmdGetAcceptingBlockHashOfTxResponseMessage
+}
+
+// NewGetAcceptingBlockHashOfTxResponse returns an instance of the message
+func NewGetAcceptingBlockHashOfTxResponse(hash string) *GetAcceptingBlockHashOfTxResponseMessage {
+	return &GetAcceptingBlockHashOfTxResponseMessage{
+		Hash: hash,
+	}
+}

app/appmessage/rpc_get_accepting_blockhashes_of_txs.go

@@ -0,0 +1,48 @@
+package appmessage
+
+// TxIDBlockHashPair is an appmessage corresponding to
+// its respective RPC message
+type TxIDBlockHashPair struct {
+	TxID string
+	Hash string
+}
+
+// GetAcceptingBlockHashesOfTxsRequestMessage is an appmessage corresponding to
+// its respective RPC message
+type GetAcceptingBlockHashesOfTxsRequestMessage struct {
+	baseMessage
+	TxIDs []string
+}
+
+// Command returns the protocol command string for the message
+func (msg *GetAcceptingBlockHashesOfTxsRequestMessage) Command() MessageCommand {
+	return CmdGetAcceptingBlockHashesOfTxsRequestMessage
+}
+
+// NewGetAcceptingBlockHashesOfTxsRequest returns a instance of the message
+func NewGetAcceptingBlockHashesOfTxsRequest(txIDs []string) *GetAcceptingBlockHashesOfTxsRequestMessage {
+	return &GetAcceptingBlockHashesOfTxsRequestMessage{
+		TxIDs: txIDs,
+	}
+}
+
+// GetAcceptingBlockHashesOfTxsResponseMessage is an appmessage corresponding to
+// its respective RPC message
+type GetAcceptingBlockHashesOfTxsResponseMessage struct {
+	baseMessage
+	TxIDBlockHashPairs []*TxIDBlockHashPair
+
+	Error *RPCError
+}
+
+// Command returns the protocol command string for the message
+func (msg *GetAcceptingBlockHashesOfTxsResponseMessage) Command() MessageCommand {
+	return CmdGetAcceptingBlockHashesOfTxsResponseMessage
+}
+
+// NewGetAcceptingBlockHashesOfTxsResponse returns an instance of the message
+func NewGetAcceptingBlockHashesOfTxsResponse(txIDBlockHashPairs []*TxIDBlockHashPair) *GetAcceptingBlockHashesOfTxsResponseMessage {
+	return &GetAcceptingBlockHashesOfTxsResponseMessage{
+		TxIDBlockHashPairs: txIDBlockHashPairs,
+	}
+}

app/appmessage/rpc_get_accepting_blocks_of_txs.go

@@ -0,0 +1,50 @@
+package appmessage
+
+// TxIDBlockPair is an appmessage corresponding to
+// its respective RPC message
+type TxIDBlockPair struct {
+	TxID  string
+	Block *RPCBlock
+}
+
+// GetAcceptingBlocksOfTxsRequestMessage is an appmessage corresponding to
+// its respective RPC message
+type GetAcceptingBlocksOfTxsRequestMessage struct {
+	baseMessage
+	TxIDs               []string
+	IncludeTransactions bool
+}
+
+// Command returns the protocol command string for the message
+func (msg *GetAcceptingBlocksOfTxsRequestMessage) Command() MessageCommand {
+	return CmdGetAcceptingBlocksOfTxsRequestMessage
+}
+
+// NewGetAcceptingBlocksOfTxsRequest returns a instance of the message
+func NewGetAcceptingBlocksOfTxsRequest(txIDs []string, includeTransactions bool) *GetAcceptingBlocksOfTxsRequestMessage {
+	return &GetAcceptingBlocksOfTxsRequestMessage{
+		TxIDs:               txIDs,
+		IncludeTransactions: includeTransactions,
+	}
+}
+
+// GetAcceptingBlocksOfTxsResponseMessage is an appmessage corresponding to
+// its respective RPC message
+type GetAcceptingBlocksOfTxsResponseMessage struct {
+	baseMessage
+	TxIDBlockPairs []*TxIDBlockPair
+
+	Error *RPCError
+}
+
+// Command returns the protocol command string for the message
+func (msg *GetAcceptingBlocksOfTxsResponseMessage) Command() MessageCommand {
+	return CmdGetAcceptingBlocksOfTxsResponseMessage
+}
+
+// NewGetAcceptingBlocksOfTxsResponse returns an instance of the message
+func NewGetAcceptingBlocksOfTxsResponse(txIDBlockPairs []*TxIDBlockPair) *GetAcceptingBlocksOfTxsResponseMessage {
+	return &GetAcceptingBlocksOfTxsResponseMessage{
+		TxIDBlockPairs: txIDBlockPairs,
+	}
+}

app/appmessage/rpc_get_including_block_of_tx.go

@@ -0,0 +1,43 @@
+package appmessage
+
+// GetIncludingBlockOfTxRequestMessage is an appmessage corresponding to
+// its respective RPC message
+type GetIncludingBlockOfTxRequestMessage struct {
+	baseMessage
+	TxID                string
+	IncludeTransactions bool
+}
+
+// Command returns the protocol command string for the message
+func (msg *GetIncludingBlockOfTxRequestMessage) Command() MessageCommand {
+	return CmdGetIncludingBlockOfTxRequestMessage
+}
+
+// NewGetIncludingBlockOfTxRequest returns a instance of the message
+func NewGetIncludingBlockOfTxRequest(txID string, includeTransactions bool) *GetIncludingBlockOfTxRequestMessage {
+	return &GetIncludingBlockOfTxRequestMessage{
+		TxID:                txID,
+		IncludeTransactions: includeTransactions,
+	}
+}
+
+// GetIncludingBlockOfTxResponseMessage is an appmessage corresponding to
+// its respective RPC message
+type GetIncludingBlockOfTxResponseMessage struct {
+	baseMessage
+	Block *RPCBlock
+
+	Error *RPCError
+}
+
+// Command returns the protocol command string for the message
+func (msg *GetIncludingBlockOfTxResponseMessage) Command() MessageCommand {
+	return CmdGetIncludingBlockOfTxResponseMessage
+}
+
+// NewGetIncludingBlockOfTxResponse returns an instance of the message
+func NewGetIncludingBlockOfTxResponse(block *RPCBlock) *GetIncludingBlockOfTxResponseMessage {
+	return &GetIncludingBlockOfTxResponseMessage{
+		Block: block,
+	}
+}

app/appmessage/rpc_get_including_blockhash_of_tx.go

@@ -0,0 +1,41 @@
+package appmessage
+
+// GetIncludingBlockHashOfTxRequestMessage is an appmessage corresponding to
+// its respective RPC message
+type GetIncludingBlockHashOfTxRequestMessage struct {
+	baseMessage
+	TxID string
+}
+
+// Command returns the protocol command string for the message
+func (msg *GetIncludingBlockHashOfTxRequestMessage) Command() MessageCommand {
+	return CmdGetIncludingBlockHashOfTxRequestMessage
+}
+
+// NewGetIncludingBlockHashOfTxRequest returns a instance of the message
+func NewGetIncludingBlockHashOfTxRequest(txID string) *GetIncludingBlockHashOfTxRequestMessage {
+	return &GetIncludingBlockHashOfTxRequestMessage{
+		TxID: txID,
+	}
+}
+
+// GetIncludingBlockHashOfTxResponseMessage is an appmessage corresponding to
+// its respective RPC message
+type GetIncludingBlockHashOfTxResponseMessage struct {
+	baseMessage
+	Hash string
+
+	Error *RPCError
+}
+
+// Command returns the protocol command string for the message
+func (msg *GetIncludingBlockHashOfTxResponseMessage) Command() MessageCommand {
+	return CmdGetIncludingBlockHashOfTxResponseMessage
+}
+
+// NewGetIncludingBlockHashOfTxResponse returns an instance of the message
+func NewGetIncludingBlockHashOfTxResponse(hash string) *GetIncludingBlockHashOfTxResponseMessage {
+	return &GetIncludingBlockHashOfTxResponseMessage{
+		Hash: hash,
+	}
+}

app/appmessage/rpc_get_including_blockhashes_of_txs.go

@@ -0,0 +1,41 @@
+package appmessage
+
+// GetIncludingBlockHashesOfTxsRequestMessage is an appmessage corresponding to
+// its respective RPC message
+type GetIncludingBlockHashesOfTxsRequestMessage struct {
+	baseMessage
+	TxIDs []string
+}
+
+// Command returns the protocol command string for the message
+func (msg *GetIncludingBlockHashesOfTxsRequestMessage) Command() MessageCommand {
+	return CmdGetIncludingBlockHashesOfTxsRequestMessage
+}
+
+// NewGetIncludingBlockHashesOfTxsRequest returns a instance of the message
+func NewGetIncludingBlockHashesOfTxsRequest(txIDs []string) *GetIncludingBlockHashesOfTxsRequestMessage {
+	return &GetIncludingBlockHashesOfTxsRequestMessage{
+		TxIDs: txIDs,
+	}
+}
+
+// GetIncludingBlockHashesOfTxsResponseMessage is an appmessage corresponding to
+// its respective RPC message
+type GetIncludingBlockHashesOfTxsResponseMessage struct {
+	baseMessage
+	TxIDBlockHashPairs []*TxIDBlockHashPair
+
+	Error *RPCError
+}
+
+// Command returns the protocol command string for the message
+func (msg *GetIncludingBlockHashesOfTxsResponseMessage) Command() MessageCommand {
+	return CmdGetIncludingBlockHashesOfTxsResponseMessage
+}
+
+// NewGetIncludingBlockHashesOfTxsResponse returns an instance of the message
+func NewGetIncludingBlockHashesOfTxsResponse(txIDBlockHashPairs []*TxIDBlockHashPair) *GetIncludingBlockHashesOfTxsResponseMessage {
+	return &GetIncludingBlockHashesOfTxsResponseMessage{
+		TxIDBlockHashPairs: txIDBlockHashPairs,
+	}
+}