Database: Add --txIndex to kaspad

app/appmessage/message.go

@@ -163,6 +163,22 @@ const (
 	CmdGetMempoolEntriesByAddressesResponseMessage
 	CmdGetCoinSupplyRequestMessage
 	CmdGetCoinSupplyResponseMessage
+	CmdGetAcceptingBlockHashesOfTxsRequestMessage
+	CmdGetAcceptingBlockHashesOfTxsResponseMessage
+	CmdGetTxsRequestMessage
+	CmdGetTxsResponseMessage
+	CmdGetTxsConfirmationsRequestMessage
+	CmdGetTxsConfirmationsResponseMessage
+	CmdNotifyTxsConfirmationChangedRequestMessage
+	CmdNotifyTxsConfirmationChangedResponseMessage
+	CmdModifyNotifyingTxsConfirmationChangedRequestMessage
+	CmdModifyNotifyingTxsConfirmationChangedResponseMessage
+	CmdTxsConfirmationChangedNotificationMessage
+	CmdNotifyAddressesTxsRequestMessage
+	CmdNotifyAddressesTxsResponseMessage
+	CmdModifyNotifyingAddressesTxsRequestMessage
+	CmdModifyNotifyingAddressesTxsResponseMessage
+	CmdAddressesTxsNotificationMessage
 )
 
 // ProtocolMessageCommandToString maps all MessageCommands to their string representation
@@ -300,6 +316,22 @@ var RPCMessageCommandToString = map[MessageCommand]string{
 	CmdGetMempoolEntriesByAddressesResponseMessage:                "GetMempoolEntriesByAddressesResponse",
 	CmdGetCoinSupplyRequestMessage:                                "GetCoinSupplyRequest",
 	CmdGetCoinSupplyResponseMessage:                               "GetCoinSupplyResponse",
+	CmdGetAcceptingBlockHashesOfTxsRequestMessage:                 "GetAcceptingBlockHashesOfTxsRequest",
+	CmdGetAcceptingBlockHashesOfTxsResponseMessage:                "GetAcceptingBlockHashesOfTxsResponse",
+	CmdGetTxsRequestMessage:                                       "GetTxsRequest",
+	CmdGetTxsResponseMessage:                                      "GetTxsResponse",
+	CmdGetTxsConfirmationsRequestMessage:                          "GetTxsConfirmationsRequest",
+	CmdGetTxsConfirmationsResponseMessage:                         "GetTxsConfirmationsResponse",
+	CmdNotifyTxsConfirmationChangedRequestMessage:                 "NotifyTxsConfirmationChangedRequest",
+	CmdNotifyTxsConfirmationChangedResponseMessage:                "ModifyNotifyingTxsConfirmationChangedRequest",
+	CmdModifyNotifyingTxsConfirmationChangedRequestMessage:        "ModifyNotifyingTxsConfirmationChangedResponse",
+	CmdModifyNotifyingTxsConfirmationChangedResponseMessage:       "TxsConfirmationChangedNotification",
+	CmdTxsConfirmationChangedNotificationMessage:                  "TxsConfirmationChangedNotification",
+	CmdNotifyAddressesTxsRequestMessage:                           "NotifyAddressesTxsRequest",
+	CmdNotifyAddressesTxsResponseMessage:                          "NotifyAddressesTxsResponse",
+	CmdModifyNotifyingAddressesTxsRequestMessage:                  "ModifyNotifyingAddressesTxsRequest",
+	CmdModifyNotifyingAddressesTxsResponseMessage:                 "ModifyNotifyingAddressesTxsResponse",
+	CmdAddressesTxsNotificationMessage:                            "AddressesTxsNotification",
 }
 
 // Message is an interface that describes a kaspa message. A type that

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_info.go

@@ -24,6 +24,8 @@ type GetInfoResponseMessage struct {
 	MempoolSize   uint64
 	ServerVersion string
 	IsUtxoIndexed bool
+	IsTxIndexed   bool
+	IsArchival    bool
 	IsSynced      bool
 
 	Error *RPCError
@@ -35,12 +37,15 @@ func (msg *GetInfoResponseMessage) Command() MessageCommand {
 }
 
 // NewGetInfoResponseMessage returns a instance of the message
-func NewGetInfoResponseMessage(p2pID string, mempoolSize uint64, serverVersion string, isUtxoIndexed bool, isSynced bool) *GetInfoResponseMessage {
+func NewGetInfoResponseMessage(p2pID string, mempoolSize uint64, serverVersion string, isUtxoIndexed bool,
+	isTxIndexed bool, isArchival bool, isSynced bool) *GetInfoResponseMessage {
 	return &GetInfoResponseMessage{
 		P2PID:         p2pID,
 		MempoolSize:   mempoolSize,
 		ServerVersion: serverVersion,
 		IsUtxoIndexed: isUtxoIndexed,
+		IsTxIndexed:   isTxIndexed,
+		IsArchival:    isArchival,
 		IsSynced:      isSynced,
 	}
 }

app/appmessage/rpc_get_txs.go

@@ -0,0 +1,41 @@
+package appmessage
+
+// GetTxsRequestMessage is an appmessage corresponding to
+// its respective RPC message
+type GetTxsRequestMessage struct {
+	baseMessage
+	TxIDs []string
+}
+
+// Command returns the protocol command string for the message
+func (msg *GetTxsRequestMessage) Command() MessageCommand {
+	return CmdGetTxsRequestMessage
+}
+
+// NewGetTxsRequest returns a instance of the message
+func NewGetTxsRequest(txIDs []string) *GetTxsRequestMessage {
+	return &GetTxsRequestMessage{
+		TxIDs: txIDs,
+	}
+}
+
+// GetTxsResponseMessage is an appmessage corresponding to
+// its respective RPC message
+type GetTxsResponseMessage struct {
+	baseMessage
+	Transactions []*RPCTransaction
+
+	Error *RPCError
+}
+
+// Command returns the protocol command string for the message
+func (msg *GetTxsResponseMessage) Command() MessageCommand {
+	return CmdGetTxsResponseMessage
+}
+
+// NewGetTxsResponse returns an instance of the message
+func NewGetTxsResponse(transactions []*RPCTransaction) *GetTxsResponseMessage {
+	return &GetTxsResponseMessage{
+		Transactions: transactions,
+	}
+}

app/appmessage/rpc_get_txs_confirmations.go

@@ -0,0 +1,48 @@
+package appmessage
+
+// TxIDConfirmationsPair is an appmessage corresponding to
+// its respective RPC message
+type TxIDConfirmationsPair struct {
+	TxID          string
+	Confirmations int64
+}
+
+// GetTxsConfirmationsRequestMessage is an appmessage corresponding to
+// its respective RPC message
+type GetTxsConfirmationsRequestMessage struct {
+	baseMessage
+	TxIDs []string
+}
+
+// Command returns the protocol command string for the message
+func (msg *GetTxsConfirmationsRequestMessage) Command() MessageCommand {
+	return CmdGetTxsConfirmationsRequestMessage
+}
+
+// NewGetTxsConfirmationsRequest returns a instance of the message
+func NewGetTxsConfirmationsRequest(txIDs []string) *GetTxsConfirmationsRequestMessage {
+	return &GetTxsConfirmationsRequestMessage{
+		TxIDs: txIDs,
+	}
+}
+
+// GetTxsConfirmationsResponseMessage is an appmessage corresponding to
+// its respective RPC message
+type GetTxsConfirmationsResponseMessage struct {
+	baseMessage
+	TxIDConfirmationsPairs []*TxIDConfirmationsPair
+
+	Error *RPCError
+}
+
+// Command returns the protocol command string for the message
+func (msg *GetTxsConfirmationsResponseMessage) Command() MessageCommand {
+	return CmdGetTxsConfirmationsResponseMessage
+}
+
+// NewGetTxsConfirmationsResponse returns an instance of the message
+func NewGetTxsConfirmationsResponse(txIDConfirmationsPairs []*TxIDConfirmationsPair) *GetTxsConfirmationsResponseMessage {
+	return &GetTxsConfirmationsResponseMessage{
+		TxIDConfirmationsPairs: txIDConfirmationsPairs,
+	}
+}

app/appmessage/rpc_modify_notifying_addresses_txs.go

@@ -0,0 +1,49 @@
+package appmessage
+
+// ModifyNotifyingAddressesTxsRequestMessage is an appmessage corresponding to
+// its respective RPC message
+type ModifyNotifyingAddressesTxsRequestMessage struct {
+	baseMessage
+	AddAddresses          []string
+	RemoveAddresses       []string
+	RequiredConfirmations uint32
+	IncludePending        bool
+	IncludeSending        bool
+	IncludeReceiving      bool
+}
+
+// Command returns the protocol command string for the message
+func (msg *ModifyNotifyingAddressesTxsRequestMessage) Command() MessageCommand {
+	return CmdModifyNotifyingAddressesTxsRequestMessage
+}
+
+// NewModifyNotifyingAddressesTxsRequestMessage returns a instance of the message
+func NewModifyNotifyingAddressesTxsRequestMessage(addAddresses []string, removeAddresses []string,
+	requiredConfirmations uint32, includePending bool, includeSending bool,
+	includeReceiving bool) *ModifyNotifyingAddressesTxsRequestMessage {
+	return &ModifyNotifyingAddressesTxsRequestMessage{
+		AddAddresses:          addAddresses,
+		RemoveAddresses:       removeAddresses,
+		RequiredConfirmations: requiredConfirmations,
+		IncludePending:        includePending,
+		IncludeSending:        includeSending,
+		IncludeReceiving:      includeReceiving,
+	}
+}
+
+// ModifyNotifyingAddressesTxsResponseMessage is an appmessage corresponding to
+// its respective RPC message
+type ModifyNotifyingAddressesTxsResponseMessage struct {
+	baseMessage
+	Error *RPCError
+}
+
+// Command returns the protocol command string for the message
+func (msg *ModifyNotifyingAddressesTxsResponseMessage) Command() MessageCommand {
+	return CmdModifyNotifyingAddressesTxsResponseMessage
+}
+
+// NewModifyNotifyingAddressesTxsResponseMessage returns a instance of the message
+func NewModifyNotifyingAddressesTxsResponseMessage() *NotifyAddressesTxsResponseMessage {
+	return &NotifyAddressesTxsResponseMessage{}
+}

app/appmessage/rpc_modify_notifying_txs_confirmation_changed.go

@@ -0,0 +1,44 @@
+package appmessage
+
+// ModifyNotifyingTxsConfirmationChangedRequestMessage is an appmessage corresponding to
+// its respective RPC message
+type ModifyNotifyingTxsConfirmationChangedRequestMessage struct {
+	baseMessage
+	AddTxIDs              []string
+	RemoveTxIDs           []string
+	RequiredConfirmations uint32
+	IncludePending        bool
+}
+
+// Command returns the protocol command string for the message
+func (msg *ModifyNotifyingTxsConfirmationChangedRequestMessage) Command() MessageCommand {
+	return CmdModifyNotifyingTxsConfirmationChangedRequestMessage
+}
+
+// NewModifyNotifyingTxsConfirmationChangedRequestMessage returns a instance of the message
+func NewModifyNotifyingTxsConfirmationChangedRequestMessage(addTxIDs []string, removeTxIDs []string,
+	requiredConfirmations uint32, includePending bool) *ModifyNotifyingTxsConfirmationChangedRequestMessage {
+	return &ModifyNotifyingTxsConfirmationChangedRequestMessage{
+		AddTxIDs:              addTxIDs,
+		RemoveTxIDs:           removeTxIDs,
+		RequiredConfirmations: requiredConfirmations,
+		IncludePending:        includePending,
+	}
+}
+
+// ModifyNotifyingTxsConfirmationChangedResponseMessage is an appmessage corresponding to
+// its respective RPC message
+type ModifyNotifyingTxsConfirmationChangedResponseMessage struct {
+	baseMessage
+	Error *RPCError
+}
+
+// Command returns the protocol command string for the message
+func (msg *ModifyNotifyingTxsConfirmationChangedResponseMessage) Command() MessageCommand {
+	return CmdModifyNotifyingTxsConfirmationChangedResponseMessage
+}
+
+// NewModifyNotifyingTxsChangedResponseMessage returns a instance of the message
+func NewModifyNotifyingTxsChangedResponseMessage() *NotifyTxsConfirmationChangedResponseMessage {
+	return &NotifyTxsConfirmationChangedResponseMessage{}
+}

app/appmessage/rpc_notify_addresses_txs.go

@@ -0,0 +1,87 @@
+package appmessage
+
+// NotifyAddressesTxsRequestMessage is an appmessage corresponding to
+// its respective RPC message
+type NotifyAddressesTxsRequestMessage struct {
+	baseMessage
+	Addresses             []string
+	RequiredConfirmations uint32
+	IncludePending        bool
+	IncludeSending        bool
+	IncludeReceiving      bool
+}
+
+// Command returns the protocol command string for the message
+func (msg *NotifyAddressesTxsRequestMessage) Command() MessageCommand {
+	return CmdNotifyAddressesTxsRequestMessage
+}
+
+// NewNotifyAddressesTxsRequestMessage returns a instance of the message
+func NewNotifyAddressesTxsRequestMessage(addresses []string, requiredConfirmations uint32,
+	includePending bool, includeSending bool, includeReceiving bool) *NotifyAddressesTxsRequestMessage {
+	return &NotifyAddressesTxsRequestMessage{
+		Addresses:             addresses,
+		RequiredConfirmations: requiredConfirmations,
+		IncludePending:        includePending,
+		IncludeSending:        includeSending,
+		IncludeReceiving:      includeReceiving,
+	}
+}
+
+// NotifyAddressesTxsResponseMessage is an appmessage corresponding to
+// its respective RPC message
+type NotifyAddressesTxsResponseMessage struct {
+	baseMessage
+	Error *RPCError
+}
+
+// Command returns the protocol command string for the message
+func (msg *NotifyAddressesTxsResponseMessage) Command() MessageCommand {
+	return CmdNotifyAddressesTxsResponseMessage
+}
+
+// NewNotifyAddressesTxsResponseMessage returns a instance of the message
+func NewNotifyAddressesTxsResponseMessage() *NotifyAddressesTxsResponseMessage {
+	return &NotifyAddressesTxsResponseMessage{}
+}
+
+// AddressesTxsNotificationMessage is an appmessage corresponding to
+// its respective RPC message
+type AddressesTxsNotificationMessage struct {
+	baseMessage
+	RequiredConfirmations uint32
+	Pending               *TxEntriesByAddresses
+	Confirmed             *TxEntriesByAddresses
+	Unconfirmed           *TxEntriesByAddresses
+}
+
+// Command returns the protocol command string for the message
+func (msg *AddressesTxsNotificationMessage) Command() MessageCommand {
+	return CmdAddressesTxsNotificationMessage
+}
+
+// NewAddressesTxsNotificationMessage returns a instance of the message
+func NewAddressesTxsNotificationMessage(requiredConfirmations uint32, pending *TxEntriesByAddresses,
+	confirmed *TxEntriesByAddresses, unconfirmed *TxEntriesByAddresses) *AddressesTxsNotificationMessage {
+	return &AddressesTxsNotificationMessage{
+		RequiredConfirmations: requiredConfirmations,
+		Pending:               pending,
+		Confirmed:             confirmed,
+		Unconfirmed:           unconfirmed,
+	}
+}
+
+// TxEntriesByAddresses is an appmessage corresponding to
+// its respective RPC message
+type TxEntriesByAddresses struct {
+	Sent     []*TxEntryByAddress
+	Received []*TxEntryByAddress
+}
+
+// TxEntryByAddress is an appmessage corresponding to
+// its respective RPC message
+type TxEntryByAddress struct {
+	Address       string
+	TxID          string
+	Confirmations uint32
+}