engine

package
v0.28.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 16, 2024 License: MIT Imports: 59 Imported by: 0

Documentation

Overview

Package engine is the Bitcoin UTXO & xPub Management Engine

If you have any suggestions or comments, please feel free to open an issue on this GitHub repository!

By bitcoin-sv (https://github.com/bitcoin-sv)

Index

Constants

View Source 
const (
	CronJobNameDraftTransactionCleanUp  = "draft_transaction_clean_up"
	CronJobNameSyncTransactionBroadcast = "sync_transaction_broadcast"
	CronJobNameSyncTransactionSync      = "sync_transaction_sync"
	CronJobNameCalculateMetrics         = "calculate_metrics"
)

Cron job names to be used in WithCronCustomPeriod

View Source 
const (
	// BIP32DerivationMethod is the BIP32 derivation method
	BIP32DerivationMethod = "BIP32"
	// PIKEDerivationMethod is the PIKE derivation method
	PIKEDerivationMethod = "PIKE"
)
View Source 
const (
	// ResolutionTypeBasic is for the "deprecated" way to resolve an address from a Paymail
	ResolutionTypeBasic = "basic_resolution"

	// ResolutionTypeP2P is the current way to resolve a Paymail (prior to P4)
	ResolutionTypeP2P = "p2p"
)

Types of resolution methods

View Source 
const (
	// MetadataField is the field name used for metadata (params)
	MetadataField = "metadata"
)
View Source 
const (
	// ReferenceIDField is used for Paymail
	ReferenceIDField = "reference_id"
)
View Source 
const ReferenceIDLength = 16

ReferenceIDLength determine the length of the reference ID

Variables

View Source 
var AllModelNames = []ModelName{
	ModelAccessKey,
	ModelDestination,
	ModelMetadata,
	ModelPaymailAddress,
	ModelPaymailAddress,
	ModelSyncTransaction,
	ModelTransaction,
	ModelUtxo,
	ModelXPub,
	ModelContact,
	ModelWebhook,
}

AllModelNames is a list of all models

View Source 
var BaseModels = []interface{}{

	&Xpub{
		Model: *NewBaseModel(ModelXPub),
	},

	&AccessKey{
		Model: *NewBaseModel(ModelAccessKey),
	},

	&DraftTransaction{
		Model: *NewBaseModel(ModelDraftTransaction),
	},

	&Transaction{
		Model: *NewBaseModel(ModelTransaction),
	},

	&SyncTransaction{
		Model: *NewBaseModel(ModelSyncTransaction),
	},

	&Destination{
		Model: *NewBaseModel(ModelDestination),
	},

	&Utxo{
		Model: *NewBaseModel(ModelUtxo),
	},

	&Contact{
		Model: *NewBaseModel(ModelContact),
	},

	&Webhook{
		Model: *NewBaseModel(ModelWebhook),
	},
}

BaseModels is the list of models for loading the engine and AutoMigration (defaults)

View Source 
var ErrMissingFieldHex = spverrors.Newf("missing required field: hex")

ErrMissingFieldHex is an error when missing the hex field of a transaction

View Source 
var ErrNoMatchingOutputs = spverrors.Newf("transaction outputs do not match any known destinations")

ErrNoMatchingOutputs is when the transaction does not match any known destinations

Functions

func DisplayModels 

func DisplayModels(models interface{}) interface{}

DisplayModels process the (slice) of model(s) for display

func Get 

func Get(
	ctx context.Context,
	model ModelInterface,
	conditions map[string]interface{},
	_ bool,
	timeout time.Duration,
	forceWriteDB bool,
) error

Get will retrieve a model from the Cachestore or Datastore using the provided conditions

use bypassCache to skip checking the Cachestore for the record

func Save 

func Save(ctx context.Context, model ModelInterface) (err error)

Save will save the model(s) into the Datastore

func ToBeef 

func ToBeef(ctx context.Context, tx *Transaction, store TransactionGetter) (string, error)

ToBeef generates BEEF Hex for transaction

func ToEfHex 

func ToEfHex(ctx context.Context, tx *Transaction, store TransactionGetter) (efHex string, ok bool)

ToEfHex generates Extended Format hex of transaction

Types

type AccessKey 

type AccessKey struct {
	// Base model
	Model `bson:",inline"`

	// Model specific fields
	ID        string               `json:"id" toml:"id" yaml:"id" gorm:"<-:create;type:char(64);primaryKey;comment:This is the unique access key id" bson:"_id"`
	XpubID    string               `` /* 129-byte string literal not displayed */
	RevokedAt customTypes.NullTime `json:"revoked_at" toml:"revoked_at" yaml:"revoked_at" gorm:"<-;comment:When the key was revoked" bson:"revoked_at,omitempty"`

	// Private fields
	Key string `json:"key" gorm:"-" bson:"-"` // Used on "CREATE", shown to the user "once" only
}

AccessKey is an object representing an access key model

An AccessKey is a private key with a corresponding public key The public key is hashed and saved in this model for retrieval. When a request is made with an access key, the public key is sent in the headers, together with a signature (like normally done with xPriv signing)

Gorm related models & indexes: https://gorm.io/docs/models.html - https://gorm.io/docs/indexes.html

func (*AccessKey) BeforeCreating 

func (m *AccessKey) BeforeCreating(_ context.Context) error

BeforeCreating will fire before the model is being inserted into the Datastore

func (*AccessKey) GetID 

func (m *AccessKey) GetID() string

GetID will get the ID

func (*AccessKey) GetModelName 

func (m *AccessKey) GetModelName() string

GetModelName will get the name of the current model

func (*AccessKey) GetModelTableName 

func (m *AccessKey) GetModelTableName() string

GetModelTableName will get the db table name of the current model

func (*AccessKey) Migrate 

func (m *AccessKey) Migrate(client datastore.ClientInterface) error

Migrate model specific migration on startup

func (*AccessKey) Save 

func (m *AccessKey) Save(ctx context.Context) error

Save will save the model into the Datastore

type AccessKeyService 

type AccessKeyService interface {
	GetAccessKey(ctx context.Context, xPubID, pubAccessKey string) (*AccessKey, error)
	GetAccessKeys(ctx context.Context, metadata *Metadata, conditions map[string]interface{},
		queryParams *datastore.QueryParams, opts ...ModelOps) ([]*AccessKey, error)
	GetAccessKeysCount(ctx context.Context, metadata *Metadata,
		conditions map[string]interface{}, opts ...ModelOps) (int64, error)
	GetAccessKeysByXPubID(ctx context.Context, xPubID string, metadata *Metadata, conditions map[string]interface{},
		queryParams *datastore.QueryParams, opts ...ModelOps) ([]*AccessKey, error)
	GetAccessKeysByXPubIDCount(ctx context.Context, xPubID string, metadata *Metadata,
		conditions map[string]interface{}, opts ...ModelOps) (int64, error)
	NewAccessKey(ctx context.Context, rawXpubKey string, opts ...ModelOps) (*AccessKey, error)
	RevokeAccessKey(ctx context.Context, rawXpubKey, id string, opts ...ModelOps) (*AccessKey, error)
}

AccessKeyService is the access key actions

type AdminService 

type AdminService interface {
	GetStats(ctx context.Context, opts ...ModelOps) (*AdminStats, error)
	GetPaymailAddresses(ctx context.Context, metadataConditions *Metadata, conditions map[string]interface{},
		queryParams *datastore.QueryParams, opts ...ModelOps) ([]*PaymailAddress, error)
	GetPaymailAddressesCount(ctx context.Context, metadataConditions *Metadata,
		conditions map[string]interface{}, opts ...ModelOps) (int64, error)
	GetXPubs(ctx context.Context, metadataConditions *Metadata,
		conditions map[string]interface{}, queryParams *datastore.QueryParams, opts ...ModelOps) ([]*Xpub, error)
	GetXPubsCount(ctx context.Context, metadataConditions *Metadata,
		conditions map[string]interface{}, opts ...ModelOps) (int64, error)
}

AdminService is the SPV Wallet Engine admin service interface comprised of all services available for admins

type AdminStats 

type AdminStats struct {
	Balance            int64                  `json:"balance"`
	Destinations       int64                  `json:"destinations"`
	PaymailAddresses   int64                  `json:"paymail_addresses"`
	Transactions       int64                  `json:"transactions"`
	TransactionsPerDay map[string]interface{} `json:"transactions_per_day"`
	Utxos              int64                  `json:"utxos"`
	UtxosPerType       map[string]interface{} `json:"utxos_per_type"`
	XPubs              int64                  `json:"xpubs"`
}

AdminStats are statistics about the SPV Wallet server

type BUMP 

type BUMP struct {
	BlockHeight uint64       `json:"blockHeight,string"`
	Path        [][]BUMPLeaf `json:"path"`
	// contains filtered or unexported fields
}

BUMP represents BUMP (BSV Unified Merkle Path) format

func CalculateMergedBUMP 

func CalculateMergedBUMP(bumps []BUMP) (*BUMP, error)

CalculateMergedBUMP calculates Merged BUMP from a slice of BUMPs

func (*BUMP) Hex 

func (bump *BUMP) Hex() string

Hex returns BUMP in hex format

func (*BUMP) Scan 

func (bump *BUMP) Scan(value interface{}) error

Scan scan value into Json, implements sql.Scanner interface

func (BUMP) Value 

func (bump BUMP) Value() (driver.Value, error)

Value return json value, implement driver.Valuer interface

type BUMPLeaf 

type BUMPLeaf struct {
	Offset    uint64 `json:"offset,string"`
	Hash      string `json:"hash,omitempty"`
	TxID      bool   `json:"txid,omitempty"`
	Duplicate bool   `json:"duplicate,omitempty"`
}

BUMPLeaf represents each BUMP path element

type BUMPs 

type BUMPs []*BUMP

BUMPs represents a slice of BUMPs - BSV Unified Merkle Paths

func (*BUMPs) Bytes 

func (bumps *BUMPs) Bytes() []byte

Bytes returns BUMPs bytes

func (*BUMPs) Scan 

func (bumps *BUMPs) Scan(value interface{}) error

Scan scan value into Json, implements sql.Scanner interface

func (BUMPs) Value 

func (bumps BUMPs) Value() (driver.Value, error)

Value return json value, implement driver.Valuer interface

type ChangeStrategy 

type ChangeStrategy string

ChangeStrategy strategy to use for change 

const (
	// ChangeStrategyDefault is a strategy that divides the satoshis among the change destinations
	ChangeStrategyDefault ChangeStrategy = "default"

	// ChangeStrategyRandom is a strategy randomizing the output of satoshis among the change destinations
	ChangeStrategyRandom ChangeStrategy = "random"

	// ChangeStrategyNominations is a strategy using coin nominations for the outputs (10, 25, 50, 100, 250 etc.)
	ChangeStrategyNominations ChangeStrategy = "nominations"
)

Types of change destination strategies

type Client 

type Client struct {
	// contains filtered or unexported fields
}

Client is the SPV Wallet Engine client & options

func (*Client) AcceptContact 

func (c *Client) AcceptContact(ctx context.Context, xPubID, paymail string) error

AcceptContact marks the contact invitation as accepted, which makes it unconfirmed contact.

func (*Client) AddContactRequest 

func (c *Client) AddContactRequest(ctx context.Context, fullName, paymailAdress, requesterXPubID string, opts ...ModelOps) (*Contact, error)

AddContactRequest adds a new contact invitation if contact not exits or just checking if contact has still the same pub key if contact exists.

func (*Client) AddModels 

func (c *Client) AddModels(ctx context.Context, autoMigrate bool, models ...interface{}) error

AddModels will add additional models to the client

func (*Client) AdminChangeContactStatus 

func (c *Client) AdminChangeContactStatus(ctx context.Context, id string, status ContactStatus) (*Contact, error)

AdminChangeContactStatus changes the status of the contact, should be used only by the admin.

func (*Client) AuthenticateAccessKey 

func (c *Client) AuthenticateAccessKey(ctx context.Context, pubAccessKey string) (*AccessKey, error)

AuthenticateAccessKey check if access key exists

func (*Client) Cachestore 

func (c *Client) Cachestore() cachestore.ClientInterface

Cachestore will return the Cachestore IF: exists and is enabled

func (*Client) Chainstate 

func (c *Client) Chainstate() chainstate.ClientInterface

Chainstate will return the Chainstate service IF: exists and is enabled

func (*Client) Close 

func (c *Client) Close(ctx context.Context) error

Close will safely close any open connections (cache, datastore, etc.)

func (*Client) Cluster 

func (c *Client) Cluster() cluster.ClientInterface

Cluster will return the cluster coordinator client

func (*Client) ConfirmContact 

func (c *Client) ConfirmContact(ctx context.Context, xPubID, paymail string) error

ConfirmContact marks the contact as confirmed.

func (*Client) Datastore 

func (c *Client) Datastore() datastore.ClientInterface

Datastore will return the Datastore if it exists

func (*Client) Debug 

func (c *Client) Debug(on bool)

Debug will toggle the debug mode (for all resources)

func (*Client) DefaultModelOptions 

func (c *Client) DefaultModelOptions(opts ...ModelOps) []ModelOps

DefaultModelOptions will set any default model options (from Client options->model)

func (*Client) DefaultSyncConfig 

func (c *Client) DefaultSyncConfig() *SyncConfig

DefaultSyncConfig will return the default sync config from the client defaults (for chainstate)

func (*Client) DeleteContact 

func (c *Client) DeleteContact(ctx context.Context, id string) error

DeleteContact deletes the contact.

func (*Client) DeletePaymailAddress 

func (c *Client) DeletePaymailAddress(ctx context.Context, address string, opts ...ModelOps) error

DeletePaymailAddress will delete a paymail address

func (*Client) EnableNewRelic 

func (c *Client) EnableNewRelic()

EnableNewRelic will enable NewRelic tracing

func (*Client) GetAccessKey 

func (c *Client) GetAccessKey(ctx context.Context, xPubID, id string) (*AccessKey, error)

GetAccessKey will get an existing access key from the Datastore

func (*Client) GetAccessKeys 

func (c *Client) GetAccessKeys(ctx context.Context, metadataConditions *Metadata,
	conditions map[string]interface{}, queryParams *datastore.QueryParams, opts ...ModelOps,
) ([]*AccessKey, error)

GetAccessKeys will get all the access keys from the Datastore

func (*Client) GetAccessKeysByXPubID 

func (c *Client) GetAccessKeysByXPubID(ctx context.Context, xPubID string, metadataConditions *Metadata,
	conditions map[string]interface{}, queryParams *datastore.QueryParams, opts ...ModelOps,
) ([]*AccessKey, error)

GetAccessKeysByXPubID will get all existing access keys from the Datastore

metadataConditions is the metadata to match to the access keys being returned

func (*Client) GetAccessKeysByXPubIDCount 

func (c *Client) GetAccessKeysByXPubIDCount(ctx context.Context, xPubID string, metadataConditions *Metadata,
	conditions map[string]interface{}, opts ...ModelOps,
) (int64, error)

GetAccessKeysByXPubIDCount will get a count of all existing access keys from the Datastore

func (*Client) GetAccessKeysCount 

func (c *Client) GetAccessKeysCount(ctx context.Context, metadataConditions *Metadata,
	conditions map[string]interface{}, opts ...ModelOps,
) (int64, error)

GetAccessKeysCount will get a count of all the access keys from the Datastore

func (*Client) GetContacts 

func (c *Client) GetContacts(ctx context.Context, metadata *Metadata, conditions map[string]interface{}, queryParams *datastore.QueryParams) ([]*Contact, error)

GetContacts returns the contact filtered by conditions.

func (*Client) GetContactsByXPubIDCount 

func (c *Client) GetContactsByXPubIDCount(ctx context.Context, xPubID string, metadata *Metadata, conditions map[string]interface{}, opts ...ModelOps) (int64, error)

GetContactsByXPubIDCount returns the number of contacts by xpubID.

func (*Client) GetContactsByXpubID 

func (c *Client) GetContactsByXpubID(ctx context.Context, xPubID string, metadata *Metadata, conditions map[string]interface{}, queryParams *datastore.QueryParams) ([]*Contact, error)

GetContactsByXpubID returns the contacts by xpubID.

func (*Client) GetContactsCount 

func (c *Client) GetContactsCount(ctx context.Context, metadata *Metadata, conditions map[string]interface{}, opts ...ModelOps) (int64, error)

GetContactsCount returns the number of contacts.

func (*Client) GetDestinationByAddress 

func (c *Client) GetDestinationByAddress(ctx context.Context, xPubID, address string) (*Destination, error)

GetDestinationByAddress will get a destination for an address

func (*Client) GetDestinationByID 

func (c *Client) GetDestinationByID(ctx context.Context, xPubID, id string) (*Destination, error)

GetDestinationByID will get a destination by id

func (*Client) GetDestinationByLockingScript 

func (c *Client) GetDestinationByLockingScript(ctx context.Context, xPubID, lockingScript string) (*Destination, error)

GetDestinationByLockingScript will get a destination for a locking script

func (*Client) GetDestinations 

func (c *Client) GetDestinations(ctx context.Context, metadataConditions *Metadata,
	conditions map[string]interface{}, queryParams *datastore.QueryParams, opts ...ModelOps,
) ([]*Destination, error)

GetDestinations will get all the destinations from the Datastore

func (*Client) GetDestinationsByXpubID 

func (c *Client) GetDestinationsByXpubID(ctx context.Context, xPubID string, metadataConditions *Metadata,
	conditions map[string]interface{}, queryParams *datastore.QueryParams,
) ([]*Destination, error)

GetDestinationsByXpubID will get destinations based on an xPub

metadataConditions are the search criteria used to find destinations

func (*Client) GetDestinationsByXpubIDCount 

func (c *Client) GetDestinationsByXpubIDCount(ctx context.Context, xPubID string, metadataConditions *Metadata,
	conditions map[string]interface{},
) (int64, error)

GetDestinationsByXpubIDCount will get a count of all destinations based on an xPub

func (*Client) GetDestinationsCount 

func (c *Client) GetDestinationsCount(ctx context.Context, metadataConditions *Metadata,
	conditions map[string]interface{}, opts ...ModelOps,
) (int64, error)

GetDestinationsCount will get a count of all the destinations from the Datastore

func (*Client) GetDraftTransactionByID 

func (c *Client) GetDraftTransactionByID(ctx context.Context, id string, opts ...ModelOps) (*DraftTransaction, error)

GetDraftTransactionByID will get a draft transaction from the Datastore

func (*Client) GetDraftTransactions 

func (c *Client) GetDraftTransactions(ctx context.Context, metadataConditions *Metadata,
	conditions map[string]interface{}, queryParams *datastore.QueryParams, opts ...ModelOps,
) ([]*DraftTransaction, error)

GetDraftTransactions will get all the draft transactions from the Datastore

func (*Client) GetDraftTransactionsCount 

func (c *Client) GetDraftTransactionsCount(ctx context.Context, metadataConditions *Metadata,
	conditions map[string]interface{}, opts ...ModelOps,
) (int64, error)

GetDraftTransactionsCount will get a count of all the draft transactions from the Datastore

func (*Client) GetModelNames 

func (c *Client) GetModelNames() []string

GetModelNames will return the model names that have been loaded

func (*Client) GetOrStartTxn 

func (c *Client) GetOrStartTxn(ctx context.Context, name string) context.Context

GetOrStartTxn will check for an existing NewRelic transaction, if not found, it will make a new transaction

func (*Client) GetPaymailAddress 

func (c *Client) GetPaymailAddress(ctx context.Context, address string, opts ...ModelOps) (*PaymailAddress, error)

GetPaymailAddress will get a paymail address model

func (*Client) GetPaymailAddresses 

func (c *Client) GetPaymailAddresses(ctx context.Context, metadataConditions *Metadata,
	conditions map[string]interface{}, queryParams *datastore.QueryParams, opts ...ModelOps,
) ([]*PaymailAddress, error)

GetPaymailAddresses will get all the paymail addresses from the Datastore

func (*Client) GetPaymailAddressesByXPubID 

func (c *Client) GetPaymailAddressesByXPubID(ctx context.Context, xPubID string, metadataConditions *Metadata,
	conditions map[string]interface{}, queryParams *datastore.QueryParams,
) ([]*PaymailAddress, error)

GetPaymailAddressesByXPubID will get all the paymail addresses for an xPubID from the Datastore

func (*Client) GetPaymailAddressesCount 

func (c *Client) GetPaymailAddressesCount(ctx context.Context, metadataConditions *Metadata,
	conditions map[string]interface{}, opts ...ModelOps,
) (int64, error)

GetPaymailAddressesCount will get a count of all the paymail addresses from the Datastore

func (*Client) GetPaymailConfig 

func (c *Client) GetPaymailConfig() *PaymailServerOptions

GetPaymailConfig will return the Paymail server config if it exists

func (*Client) GetStats 

func (c *Client) GetStats(ctx context.Context, opts ...ModelOps) (*AdminStats, error)

GetStats will get stats for the SPV Wallet Console (admin)

func (*Client) GetTransaction 

func (c *Client) GetTransaction(ctx context.Context, xPubID, txID string) (*Transaction, error)

GetTransaction will get a transaction by its ID from the Datastore

func (*Client) GetTransactionByHex 

func (c *Client) GetTransactionByHex(ctx context.Context, hex string) (*Transaction, error)

GetTransactionByHex will get a transaction from the Datastore by its full hex string uses GetTransaction

func (*Client) GetTransactions 

func (c *Client) GetTransactions(ctx context.Context, metadataConditions *Metadata,
	conditions map[string]interface{}, queryParams *datastore.QueryParams, opts ...ModelOps,
) ([]*Transaction, error)

GetTransactions will get all the transactions from the Datastore

func (*Client) GetTransactionsByIDs 

func (c *Client) GetTransactionsByIDs(ctx context.Context, txIDs []string) ([]*Transaction, error)

GetTransactionsByIDs returns array of transactions by their IDs from the Datastore

func (*Client) GetTransactionsByXpubID 

func (c *Client) GetTransactionsByXpubID(ctx context.Context, xPubID string, metadataConditions *Metadata,
	conditions map[string]interface{}, queryParams *datastore.QueryParams,
) ([]*Transaction, error)

GetTransactionsByXpubID will get all transactions for a given xpub from the Datastore

ctx is the context rawXpubKey is the raw xPub key metadataConditions is added to the request for searching conditions is added the request for searching

func (*Client) GetTransactionsByXpubIDCount 

func (c *Client) GetTransactionsByXpubIDCount(ctx context.Context, xPubID string, metadataConditions *Metadata,
	conditions map[string]interface{},
) (int64, error)

GetTransactionsByXpubIDCount will get the count of all transactions matching the search criteria

func (*Client) GetTransactionsCount 

func (c *Client) GetTransactionsCount(ctx context.Context, metadataConditions *Metadata,
	conditions map[string]interface{}, opts ...ModelOps,
) (int64, error)

GetTransactionsCount will get a count of all the transactions from the Datastore

func (*Client) GetUtxo 

func (c *Client) GetUtxo(ctx context.Context, xPubKey, txID string, outputIndex uint32) (*Utxo, error)

GetUtxo will get a single utxo based on an xPub, the tx ID and the outputIndex

func (*Client) GetUtxoByTransactionID 

func (c *Client) GetUtxoByTransactionID(ctx context.Context, txID string, outputIndex uint32) (*Utxo, error)

GetUtxoByTransactionID will get a single utxo based on the tx ID and the outputIndex

func (*Client) GetUtxos 

func (c *Client) GetUtxos(ctx context.Context, metadataConditions *Metadata,
	conditions map[string]interface{}, queryParams *datastore.QueryParams, opts ...ModelOps,
) ([]*Utxo, error)

GetUtxos will get all the utxos from the Datastore

func (*Client) GetUtxosByXpubID 

func (c *Client) GetUtxosByXpubID(ctx context.Context, xPubID string, metadata *Metadata, conditions map[string]interface{},
	queryParams *datastore.QueryParams,
) ([]*Utxo, error)

GetUtxosByXpubID will get utxos based on an xPub

func (*Client) GetUtxosCount 

func (c *Client) GetUtxosCount(ctx context.Context, metadataConditions *Metadata,
	conditions map[string]interface{}, opts ...ModelOps,
) (int64, error)

GetUtxosCount will get a count of all the utxos from the Datastore

func (*Client) GetXPubs 

func (c *Client) GetXPubs(ctx context.Context, metadataConditions *Metadata,
	conditions map[string]interface{}, queryParams *datastore.QueryParams, opts ...ModelOps,
) ([]*Xpub, error)

GetXPubs gets all xpubs matching the conditions

func (*Client) GetXPubsCount 

func (c *Client) GetXPubsCount(ctx context.Context, metadataConditions *Metadata,
	conditions map[string]interface{}, opts ...ModelOps,
) (int64, error)

GetXPubsCount gets a count of all xpubs matching the conditions

func (*Client) GetXpub 

func (c *Client) GetXpub(ctx context.Context, xPubKey string) (*Xpub, error)

GetXpub will get an existing xPub from the Datastore

xPubKey is the raw public xPub

func (*Client) GetXpubByID 

func (c *Client) GetXpubByID(ctx context.Context, xPubID string) (*Xpub, error)

GetXpubByID will get an existing xPub from the Datastore

xPubID is the hash of the xPub

func (*Client) HTTPClient 

func (c *Client) HTTPClient() HTTPInterface

HTTPClient will return the http interface to use in the client

func (*Client) IsDebug 

func (c *Client) IsDebug() bool

IsDebug will return the debug flag (bool)

func (*Client) IsEncryptionKeySet 

func (c *Client) IsEncryptionKeySet() bool

IsEncryptionKeySet will return the flag (bool) if the encryption key has been set

func (*Client) IsIUCEnabled 

func (c *Client) IsIUCEnabled() bool

IsIUCEnabled will return the flag (bool)

func (*Client) IsMigrationEnabled 

func (c *Client) IsMigrationEnabled() bool

IsMigrationEnabled will return the flag (bool)

func (*Client) IsNewRelicEnabled 

func (c *Client) IsNewRelicEnabled() bool

IsNewRelicEnabled will return the flag (bool)

func (*Client) Logger 

func (c *Client) Logger() *zerolog.Logger

Logger will return the Logger if it exists

func (*Client) Metrics 

func (c *Client) Metrics() (metrics *metrics.Metrics, enabled bool)

Metrics will return the metrics client (if it's enabled)

func (*Client) NewAccessKey 

func (c *Client) NewAccessKey(ctx context.Context, rawXpubKey string, opts ...ModelOps) (*AccessKey, error)

NewAccessKey will create a new access key for the given xpub

opts are options and can include "metadata"

func (*Client) NewDestination 

func (c *Client) NewDestination(ctx context.Context, xPubKey string, chain uint32,
	destinationType string, opts ...ModelOps,
) (*Destination, error)

NewDestination will get a new destination for an existing xPub

xPubKey is the raw public xPub

func (*Client) NewDestinationForLockingScript 

func (c *Client) NewDestinationForLockingScript(ctx context.Context, xPubID, lockingScript string,
	opts ...ModelOps,
) (*Destination, error)

NewDestinationForLockingScript will create a new destination based on a locking script

func (*Client) NewPaymailAddress 

func (c *Client) NewPaymailAddress(ctx context.Context, xPubKey, address, publicName, avatar string,
	opts ...ModelOps,
) (*PaymailAddress, error)

NewPaymailAddress will create a new paymail address

func (*Client) NewTransaction 

func (c *Client) NewTransaction(ctx context.Context, rawXpubKey string, config *TransactionConfig,
	opts ...ModelOps,
) (*DraftTransaction, error)

NewTransaction will create a new draft transaction and return it

ctx is the context rawXpubKey is the raw xPub key config is the TransactionConfig metadata is added to the model opts are additional model options to be applied

func (*Client) NewXpub 

func (c *Client) NewXpub(ctx context.Context, xPubKey string, opts ...ModelOps) (*Xpub, error)

NewXpub will parse the xPub and save it into the Datastore

xPubKey is the raw public xPub opts are options and can include "metadata"

func (*Client) Notifications 

func (c *Client) Notifications() *notifications.Notifications

Notifications will return the Notifications if it exists

func (*Client) PaymailClient 

func (c *Client) PaymailClient() paymail.ClientInterface

PaymailClient will return the Paymail if it exists

func (*Client) RecordRawTransaction 

func (c *Client) RecordRawTransaction(ctx context.Context, txHex string,
	opts ...ModelOps,
) (*Transaction, error)

RecordRawTransaction will parse the transaction and save it into the Datastore directly, without any checks or broadcast but SPV Wallet Engine will ask network for information if transaction was mined The transaction is treat as external incoming transaction - transaction without a draft Only use this function when you know what you are doing!

txHex is the raw transaction hex opts are model options and can include "metadata"

func (*Client) RecordTransaction 

func (c *Client) RecordTransaction(ctx context.Context, xPubKey, txHex, draftID string, opts ...ModelOps) (*Transaction, error)

RecordTransaction will parse the outgoing transaction and save it into the Datastore xPubKey is the raw public xPub txHex is the raw transaction hex draftID is the unique draft id from a previously started New() transaction (draft_transaction.ID) opts are model options and can include "metadata"

func (*Client) RejectContact 

func (c *Client) RejectContact(ctx context.Context, xPubID, paymail string) error

RejectContact marks the contact invitation as rejected.

func (*Client) RevertTransaction 

func (c *Client) RevertTransaction(ctx context.Context, id string) error

RevertTransaction will revert a transaction created in the SPV Wallet Engine database, but only if it has not yet been synced on-chain and the utxos have not been spent. All utxos that are reverted will be marked as deleted (and spent)

func (*Client) RevokeAccessKey 

func (c *Client) RevokeAccessKey(ctx context.Context, rawXpubKey, id string, opts ...ModelOps) (*AccessKey, error)

RevokeAccessKey will revoke an access key by its id

opts are options and can include "metadata"

func (*Client) SubscribeWebhook 

func (c *Client) SubscribeWebhook(ctx context.Context, url, tokenHeader, token string) error

SubscribeWebhook adds URL to the list of subscribed webhooks

func (*Client) Taskmanager 

func (c *Client) Taskmanager() taskmanager.TaskEngine

Taskmanager will return the Taskmanager if it exists

func (*Client) UnReserveUtxos 

func (c *Client) UnReserveUtxos(ctx context.Context, xPubID, draftID string) error

UnReserveUtxos remove the reservation on the utxos for the given draft ID

func (*Client) UnconfirmContact 

func (c *Client) UnconfirmContact(ctx context.Context, xPubID, paymail string) error

UnconfirmContact marks the contact as unconfirmed.

func (*Client) UnsubscribeWebhook 

func (c *Client) UnsubscribeWebhook(ctx context.Context, url string) error

UnsubscribeWebhook removes URL from the list of subscribed webhooks

func (*Client) UpdateContact 

func (c *Client) UpdateContact(ctx context.Context, id, fullName string, metadata *Metadata) (*Contact, error)

UpdateContact updates the contact data.

func (*Client) UpdateDestinationMetadataByAddress 

func (c *Client) UpdateDestinationMetadataByAddress(ctx context.Context, xPubID, address string,
	metadata Metadata,
) (*Destination, error)

UpdateDestinationMetadataByAddress will update the metadata in an existing destination by address

func (*Client) UpdateDestinationMetadataByID 

func (c *Client) UpdateDestinationMetadataByID(ctx context.Context, xPubID, id string,
	metadata Metadata,
) (*Destination, error)

UpdateDestinationMetadataByID will update the metadata in an existing destination by id

func (*Client) UpdateDestinationMetadataByLockingScript 

func (c *Client) UpdateDestinationMetadataByLockingScript(ctx context.Context, xPubID,
	lockingScript string, metadata Metadata,
) (*Destination, error)

UpdateDestinationMetadataByLockingScript will update the metadata in an existing destination by locking script

func (*Client) UpdatePaymailAddress 

func (c *Client) UpdatePaymailAddress(ctx context.Context, address, publicName, avatar string,
	opts ...ModelOps,
) (*PaymailAddress, error)

UpdatePaymailAddress will update optional fields of the paymail address

func (*Client) UpdatePaymailAddressMetadata 

func (c *Client) UpdatePaymailAddressMetadata(ctx context.Context, address string,
	metadata Metadata, opts ...ModelOps,
) (*PaymailAddress, error)

UpdatePaymailAddressMetadata will update the metadata in an existing paymail address

func (*Client) UpdateTransaction 

func (c *Client) UpdateTransaction(ctx context.Context, callbackResp *broadcast.SubmittedTx) error

UpdateTransaction will update the broadcast callback transaction info, like: block height, block hash, status, bump.

func (*Client) UpdateTransactionMetadata 

func (c *Client) UpdateTransactionMetadata(ctx context.Context, xPubID, id string,
	metadata Metadata,
) (*Transaction, error)

UpdateTransactionMetadata will update the metadata in an existing transaction

func (*Client) UpdateXpubMetadata 

func (c *Client) UpdateXpubMetadata(ctx context.Context, xPubID string, metadata Metadata) (*Xpub, error)

UpdateXpubMetadata will update the metadata in an existing xPub

xPubID is the hash of the xP

func (*Client) UpsertContact 

func (c *Client) UpsertContact(ctx context.Context, ctcFName, ctcPaymail, requesterXPubID, requesterPaymail string, opts ...ModelOps) (*Contact, error)

UpsertContact adds a new contact if not exists or updates the existing one.

func (*Client) UserAgent 

func (c *Client) UserAgent() string

UserAgent will return the user agent

func (*Client) Version 

func (c *Client) Version() string

Version will return the version

type ClientInterface 

type ClientInterface interface {
	AccessKeyService
	AdminService
	ClientService
	DestinationService
	DraftTransactionService
	ModelService
	PaymailService
	TransactionService
	UTXOService
	XPubService
	ContactService
	AuthenticateAccessKey(ctx context.Context, pubAccessKey string) (*AccessKey, error)
	Close(ctx context.Context) error
	Debug(on bool)
	DefaultSyncConfig() *SyncConfig
	EnableNewRelic()
	GetOrStartTxn(ctx context.Context, name string) context.Context
	IsDebug() bool
	IsEncryptionKeySet() bool
	IsIUCEnabled() bool
	IsMigrationEnabled() bool
	IsNewRelicEnabled() bool
	UserAgent() string
	Version() string
	Metrics() (metrics *metrics.Metrics, enabled bool)
	SubscribeWebhook(ctx context.Context, url, tokenHeader, token string) error
	UnsubscribeWebhook(ctx context.Context, url string) error
}

ClientInterface is the client (spv wallet engine) interface comprised of all services/actions

func NewClient 

func NewClient(ctx context.Context, opts ...ClientOps) (ClientInterface, error)

NewClient creates a new client for all SPV Wallet Engine functionality

If no options are given, it will use the defaultClientOptions() ctx may contain a NewRelic txn (or one will be created)

type ClientOps 

type ClientOps func(c *clientOptions)

ClientOps allow functional options to be supplied that overwrite default client options.

func WithAutoMigrate 

func WithAutoMigrate(migrateModels ...interface{}) ClientOps

WithAutoMigrate will enable auto migrate database mode (given models)

Pointers of structs (IE: &models.Xpub{})

func WithBroadcastClient 

func WithBroadcastClient(broadcastClient broadcast.Client) ClientOps

WithBroadcastClient will set broadcast client

func WithCallback 

func WithCallback(callbackURL string, callbackToken string) ClientOps

WithCallback set callback settings

func WithChainstateOptions 

func WithChainstateOptions(broadcasting, broadcastInstant, paymailP2P, syncOnChain bool) ClientOps

WithChainstateOptions will set chainstate defaults

func WithClusterClient 

func WithClusterClient(clusterClient cluster.ClientInterface) ClientOps

WithClusterClient will set the cluster options on the client

func WithClusterKeyPrefix 

func WithClusterKeyPrefix(prefix string) ClientOps

WithClusterKeyPrefix will set the cluster key prefix to use for all keys in the cluster coordinator

func WithClusterRedis 

func WithClusterRedis(redisOptions *redis.Options) ClientOps

WithClusterRedis will set the cluster coordinator to use redis

func WithCronCustomPeriod 

func WithCronCustomPeriod(cronJobName string, period time.Duration) ClientOps

WithCronCustomPeriod will set the custom cron jobs period which will override the default

func WithCustomCachestore 

func WithCustomCachestore(cacheStore cachestore.ClientInterface) ClientOps

WithCustomCachestore will set the cachestore

func WithCustomChainstate 

func WithCustomChainstate(chainState chainstate.ClientInterface) ClientOps

WithCustomChainstate will set the chainstate

func WithCustomDatastore 

func WithCustomDatastore(dataStore datastore.ClientInterface) ClientOps

WithCustomDatastore will set the datastore

func WithDebugging 

func WithDebugging() ClientOps

WithDebugging will set debugging in any applicable configuration

func WithEncryption 

func WithEncryption(key string) ClientOps

WithEncryption will set the encryption key and encrypt values using this key

func WithExcludedProviders 

func WithExcludedProviders(providers []string) ClientOps

WithExcludedProviders will set a list of excluded providers

func WithFeeQuotes 

func WithFeeQuotes(enabled bool) ClientOps

WithFeeQuotes will find the lowest fee instead of using the fee set by the WithFeeUnit function

func WithFeeUnit 

func WithFeeUnit(feeUnit *utils.FeeUnit) ClientOps

WithFeeUnit will set the fee unit to use for broadcasting

func WithFreeCache 

func WithFreeCache() ClientOps

WithFreeCache will set the cache client for both Read & Write clients

func WithFreeCacheConnection 

func WithFreeCacheConnection(client *freecache.Cache) ClientOps

WithFreeCacheConnection will set the cache client to an active FreeCache connection

func WithHTTPClient 

func WithHTTPClient(httpClient HTTPInterface) ClientOps

WithHTTPClient will set the custom http interface

func WithIUCDisabled 

func WithIUCDisabled() ClientOps

WithIUCDisabled will disable checking the input utxos

func WithLogger 

func WithLogger(customLogger *zerolog.Logger) ClientOps

WithLogger will set the custom logger interface

func WithMetrics 

func WithMetrics(collector metrics.Collector) ClientOps

WithMetrics will set the metrics with a collector interface

func WithMigrationDisabled 

func WithMigrationDisabled() ClientOps

WithMigrationDisabled will disable all migrations from running in the Datastore

func WithModels 

func WithModels(models ...interface{}) ClientOps

WithModels will add additional models (will NOT migrate using datastore)

Pointers of structs (IE: &models.Xpub{})

func WithNewRelic 

func WithNewRelic(app *newrelic.Application) ClientOps

WithNewRelic will set the NewRelic application client

func WithNotifications 

func WithNotifications() ClientOps

WithNotifications will set the notifications config

func WithPaymailBeefSupport 

func WithPaymailBeefSupport(blockHeadersServiceURL, blockHeadersServiceAuthToken string) ClientOps

WithPaymailBeefSupport will enable Paymail BEEF format support (as a server) and create a Block Headers Service client for Merkle Roots verification.

func WithPaymailClient 

func WithPaymailClient(client paymail.ClientInterface) ClientOps

WithPaymailClient will set a custom paymail client

func WithPaymailPikeContactSupport 

func WithPaymailPikeContactSupport() ClientOps

WithPaymailPikeContactSupport will enable Paymail Pike Contact support

func WithPaymailPikePaymentSupport 

func WithPaymailPikePaymentSupport() ClientOps

WithPaymailPikePaymentSupport will enable Paymail Pike Payment support

func WithPaymailServerConfig 

func WithPaymailServerConfig(config *server.Configuration, defaultFromPaymail string) ClientOps

WithPaymailServerConfig will set the custom server configuration for Paymail

This will allow overriding the Configuration.actions (paymail service provider)

func WithPaymailSupport 

func WithPaymailSupport(domains []string, defaultFromPaymail string, domainValidation, senderValidation bool) ClientOps

WithPaymailSupport will set the configuration for Paymail support (as a server)

func WithRedis 

func WithRedis(config *cachestore.RedisConfig) ClientOps

WithRedis will set the redis cache client for both Read & Write clients

This will load new redis connections using the given parameters

func WithRedisConnection 

func WithRedisConnection(activeClient *cache.Client) ClientOps

WithRedisConnection will set the cache client to an active redis connection

func WithSQL 

func WithSQL(engine datastore.Engine, config *datastore.SQLConfig) ClientOps

WithSQL will set the datastore to use the SQL config

func WithSQLConfigs 

func WithSQLConfigs(engine datastore.Engine, configs []*datastore.SQLConfig) ClientOps

WithSQLConfigs will load multiple connections (replica & master)

func WithSQLConnection 

func WithSQLConnection(engine datastore.Engine, sqlDB *sql.DB, tablePrefix string) ClientOps

WithSQLConnection will set the Datastore to an existing connection for PostgreSQL

func WithSQLite 

func WithSQLite(config *datastore.SQLiteConfig) ClientOps

WithSQLite will set the Datastore to use SQLite

func WithTaskqConfig 

func WithTaskqConfig(config *taskq.QueueOptions) ClientOps

WithTaskqConfig will set the task manager to use TaskQ & in-memory

func WithUserAgent 

func WithUserAgent(userAgent string) ClientOps

WithUserAgent will overwrite the default useragent

type ClientService 

type ClientService interface {
	Cachestore() cachestore.ClientInterface
	Cluster() cluster.ClientInterface
	Chainstate() chainstate.ClientInterface
	Datastore() datastore.ClientInterface
	HTTPClient() HTTPInterface
	Logger() *zerolog.Logger
	Notifications() *notifications.Notifications
	PaymailClient() paymail.ClientInterface
	Taskmanager() taskmanager.TaskEngine
}

ClientService is the client related services

type Contact 

type Contact struct {
	// Base model
	Model `bson:",inline"`

	// Model specific fields
	ID          string        `json:"id" toml:"id" yaml:"id" gorm:"<-:create;type:char(36);primaryKey;comment:This is the unique contact id" bson:"_id"`
	OwnerXpubID string        `` /* 175-byte string literal not displayed */
	FullName    string        `json:"full_name" toml:"full_name" yaml:"full_name" gorm:"<-create;comment:This is the contact's full name" bson:"full_name"`
	Paymail     string        `` /* 128-byte string literal not displayed */
	PubKey      string        `json:"pub_key" toml:"pub_key" yaml:"pub_key" gorm:"<-:create;index;comment:This is the related public key" bson:"pub_key"`
	Status      ContactStatus `` /* 145-byte string literal not displayed */
}

Contact is a model that represents a known contacts of the user and invitations to contact.

func (*Contact) Accept 

func (m *Contact) Accept() error

Accept marks the contact invitation as accepted, what means that the contact invitation is treated as normal contact.

func (*Contact) BeforeCreating 

func (m *Contact) BeforeCreating(_ context.Context) (err error)

BeforeCreating is called before the model is saved to the DB

func (*Contact) BeforeUpdating 

func (m *Contact) BeforeUpdating(_ context.Context) (err error)

BeforeUpdating is called before the model is updated in the DB

func (*Contact) Confirm 

func (m *Contact) Confirm() error

Confirm marks the contact as confirmed

func (*Contact) Delete 

func (m *Contact) Delete()

Delete marks the contact as deleted

func (*Contact) GetID 

func (m *Contact) GetID() string

GetID will get the ID

func (*Contact) GetModelName 

func (m *Contact) GetModelName() string

GetModelName returns name of the model

func (*Contact) GetModelTableName 

func (m *Contact) GetModelTableName() string

GetModelTableName returns the model db table name

func (*Contact) Migrate 

func (m *Contact) Migrate(client datastore.ClientInterface) error

Migrate model specific migration on startup

func (*Contact) Reject 

func (m *Contact) Reject() error

Reject marks the contact invitation as rejected

func (*Contact) Save 

func (m *Contact) Save(ctx context.Context) (err error)

Save the model

func (*Contact) Unconfirm 

func (m *Contact) Unconfirm() error

Unconfirm marks the contact as unconfirmed

func (*Contact) UpdatePubKey 

func (m *Contact) UpdatePubKey(pk string) (updated bool)

UpdatePubKey updates the contact's public key

type ContactService 

type ContactService interface {
	UpsertContact(ctx context.Context, fullName, paymailAdress, requesterXPubID, requesterPaymail string, opts ...ModelOps) (*Contact, error)
	AddContactRequest(ctx context.Context, fullName, paymailAdress, requesterXPubID string, opts ...ModelOps) (*Contact, error)

	AdminChangeContactStatus(ctx context.Context, id string, status ContactStatus) (*Contact, error)
	UpdateContact(ctx context.Context, id, fullName string, metadata *Metadata) (*Contact, error)
	DeleteContact(ctx context.Context, id string) error

	AcceptContact(ctx context.Context, xPubID, paymail string) error
	RejectContact(ctx context.Context, xPubID, paymail string) error
	ConfirmContact(ctx context.Context, xPubID, paymail string) error
	UnconfirmContact(ctx context.Context, xPubID, paymail string) error

	GetContacts(ctx context.Context, metadata *Metadata, conditions map[string]interface{}, queryParams *datastore.QueryParams) ([]*Contact, error)
	GetContactsByXpubID(ctx context.Context, xPubID string, metadata *Metadata, conditions map[string]interface{}, queryParams *datastore.QueryParams) ([]*Contact, error)
	GetContactsByXPubIDCount(ctx context.Context, xPubID string, metadata *Metadata, conditions map[string]interface{}, opts ...ModelOps) (int64, error)
	GetContactsCount(ctx context.Context, metadata *Metadata, conditions map[string]interface{}, opts ...ModelOps) (int64, error)
}

ContactService is the service for managing contacts

type ContactStatus 

type ContactStatus string

ContactStatus represents statuses of contact model. 

const (
	// ContactNotConfirmed is a status telling that the contact model as not confirmed yet.
	ContactNotConfirmed ContactStatus = "unconfirmed"
	// ContactAwaitAccept is a status telling that the contact model as invitation to add to contacts.
	ContactAwaitAccept ContactStatus = "awaiting"
	// ContactConfirmed is a status telling that the contact model as confirmed.
	ContactConfirmed ContactStatus = "confirmed"
	// ContactRejected is a status telling that the contact invitation was rejected by user.
	ContactRejected ContactStatus = "rejected"
)

func (*ContactStatus) Scan 

func (t *ContactStatus) Scan(value interface{}) error

Scan will scan the value into Struct, implements sql.Scanner interface

func (ContactStatus) String 

func (t ContactStatus) String() string

String is the string version of the status

func (ContactStatus) Value 

func (t ContactStatus) Value() (driver.Value, error)

Value return json value, implement driver.Valuer interface

type Destination 

type Destination struct {
	// Base model
	Model `bson:",inline"`

	// Model specific fields
	ID                           string  `` /* 129-byte string literal not displayed */
	XpubID                       string  `` /* 129-byte string literal not displayed */
	LockingScript                string  `` /* 159-byte string literal not displayed */
	Type                         string  `json:"type" toml:"type" yaml:"type" gorm:"<-:create;type:text;comment:Type of output" bson:"type"`
	Chain                        uint32  `` /* 153-byte string literal not displayed */
	Num                          uint32  `` /* 145-byte string literal not displayed */
	PaymailExternalDerivationNum *uint32 `` /* 276-byte string literal not displayed */
	Address                      string  `` /* 135-byte string literal not displayed */
	DraftID                      string  `` /* 167-byte string literal not displayed */
	DerivationMethod             string  `` /* 201-byte string literal not displayed */
	SenderXpub                   string  `` /* 165-byte string literal not displayed */
	OutputIndex                  uint32  `` /* 179-byte string literal not displayed */
}

Destination is an object representing a BitCoin destination (address, script, etc)

Gorm related models & indexes: https://gorm.io/docs/models.html - https://gorm.io/docs/indexes.html

func (*Destination) AfterCreated 

func (m *Destination) AfterCreated(ctx context.Context) error

AfterCreated will fire after the model is created in the Datastore

func (*Destination) AfterDeleted 

func (m *Destination) AfterDeleted(ctx context.Context) error

AfterDeleted will fire after the model is deleted in the Datastore

func (*Destination) AfterUpdated 

func (m *Destination) AfterUpdated(ctx context.Context) error

AfterUpdated will fire after the model is updated in the Datastore

func (*Destination) BeforeCreating 

func (m *Destination) BeforeCreating(_ context.Context) error

BeforeCreating will fire before the model is being inserted into the Datastore

func (*Destination) GetID 

func (m *Destination) GetID() string

GetID will get the model ID

func (*Destination) GetModelName 

func (m *Destination) GetModelName() string

GetModelName will get the name of the current model

func (*Destination) GetModelTableName 

func (m *Destination) GetModelTableName() string

GetModelTableName will get the db table name of the current model

func (*Destination) Migrate 

func (m *Destination) Migrate(client datastore.ClientInterface) error

Migrate model specific migration on startup

func (*Destination) Save 

func (m *Destination) Save(ctx context.Context) (err error)

Save will save the model into the Datastore

type DestinationService 

type DestinationService interface {
	GetDestinationByID(ctx context.Context, xPubID, id string) (*Destination, error)
	GetDestinationByAddress(ctx context.Context, xPubID, address string) (*Destination, error)
	GetDestinationByLockingScript(ctx context.Context, xPubID, lockingScript string) (*Destination, error)
	GetDestinations(ctx context.Context, metadata *Metadata, conditions map[string]interface{},
		queryParams *datastore.QueryParams, opts ...ModelOps) ([]*Destination, error)
	GetDestinationsCount(ctx context.Context, metadata *Metadata,
		conditions map[string]interface{}, opts ...ModelOps) (int64, error)
	GetDestinationsByXpubID(ctx context.Context, xPubID string, usingMetadata *Metadata, conditions map[string]interface{},
		queryParams *datastore.QueryParams) ([]*Destination, error)
	GetDestinationsByXpubIDCount(ctx context.Context, xPubID string, usingMetadata *Metadata,
		conditions map[string]interface{}) (int64, error)
	NewDestination(ctx context.Context, xPubKey string, chain uint32, destinationType string,
		opts ...ModelOps) (*Destination, error)
	NewDestinationForLockingScript(ctx context.Context, xPubID, lockingScript string,
		opts ...ModelOps) (*Destination, error)
	UpdateDestinationMetadataByID(ctx context.Context, xPubID, id string, metadata Metadata) (*Destination, error)
	UpdateDestinationMetadataByLockingScript(ctx context.Context, xPubID,
		lockingScript string, metadata Metadata) (*Destination, error)
	UpdateDestinationMetadataByAddress(ctx context.Context, xPubID, address string,
		metadata Metadata) (*Destination, error)
}

DestinationService is the destination actions

type DraftStatus 

type DraftStatus string

DraftStatus draft transaction status 

const (
	// DraftStatusDraft is when the transaction is a draft
	DraftStatusDraft DraftStatus = statusDraft

	// DraftStatusCanceled is when the draft is canceled
	DraftStatusCanceled DraftStatus = statusCanceled

	// DraftStatusExpired is when the draft has expired
	DraftStatusExpired DraftStatus = statusExpired

	// DraftStatusComplete is when the draft transaction is complete
	DraftStatusComplete DraftStatus = statusComplete
)

func (*DraftStatus) Scan 

func (t *DraftStatus) Scan(value interface{}) error

Scan will scan the value into Struct, implements sql.Scanner interface

func (DraftStatus) Value 

func (t DraftStatus) Value() (driver.Value, error)

Value return json value, implement driver.Valuer interface

type DraftTransaction 

type DraftTransaction struct {
	// Base model
	Model `bson:",inline"`

	// Standard transaction model base fields
	TransactionBase `bson:",inline"`

	// Model specific fields
	XpubID        string            `` /* 129-byte string literal not displayed */
	ExpiresAt     time.Time         `json:"expires_at" toml:"expires_at" yaml:"expires_at" gorm:"<-:create;comment:Time when the draft expires" bson:"expires_at"`
	Configuration TransactionConfig `` /* 152-byte string literal not displayed */
	Status        DraftStatus       `` /* 128-byte string literal not displayed */
	FinalTxID     string            `` /* 157-byte string literal not displayed */
}

DraftTransaction is an object representing the draft BitCoin transaction prior to the final transaction

Gorm related models & indexes: https://gorm.io/docs/models.html - https://gorm.io/docs/indexes.html

func (*DraftTransaction) AfterUpdated 

func (m *DraftTransaction) AfterUpdated(ctx context.Context) error

AfterUpdated will fire after a successful update into the Datastore

func (*DraftTransaction) BeforeCreating 

func (m *DraftTransaction) BeforeCreating(_ context.Context) (err error)

BeforeCreating will fire before the model is being inserted into the Datastore

func (*DraftTransaction) GetID 

func (m *DraftTransaction) GetID() string

GetID will get the model ID

func (*DraftTransaction) GetModelName 

func (m *DraftTransaction) GetModelName() string

GetModelName will get the name of the current model

func (*DraftTransaction) GetModelTableName 

func (m *DraftTransaction) GetModelTableName() string

GetModelTableName will get the db table name of the current model

func (*DraftTransaction) Migrate 

func (m *DraftTransaction) Migrate(client datastore.ClientInterface) error

Migrate model specific migration on startup

func (*DraftTransaction) Save 

func (m *DraftTransaction) Save(ctx context.Context) (err error)

Save will save the model into the Datastore

func (*DraftTransaction) SignInputs 

func (m *DraftTransaction) SignInputs(xPriv *bip32.ExtendedKey) (signedHex string, err error)

SignInputs will sign all the inputs using the given xPriv key

func (*DraftTransaction) SignInputsWithKey 

func (m *DraftTransaction) SignInputsWithKey(xPrivKey string) (signedHex string, err error)

SignInputsWithKey will sign all the inputs using a key (string) (helper method)

type DraftTransactionService 

type DraftTransactionService interface {
	GetDraftTransactions(ctx context.Context, metadata *Metadata, conditions map[string]interface{},
		queryParams *datastore.QueryParams, opts ...ModelOps) ([]*DraftTransaction, error)
	GetDraftTransactionsCount(ctx context.Context, metadata *Metadata,
		conditions map[string]interface{}, opts ...ModelOps) (int64, error)
}

DraftTransactionService is the draft transactions actions

type EnumStringMapper 

type EnumStringMapper[T fmt.Stringer] struct {
	// contains filtered or unexported fields
}

EnumStringMapper is a helper struct that maps strings to "enum" like constants.

func NewEnumStringMapper 

func NewEnumStringMapper[T fmt.Stringer](elements ...T) EnumStringMapper[T]

NewEnumStringMapper creates a new EnumStringMapper.

func (*EnumStringMapper[T]) Get 

func (m *EnumStringMapper[T]) Get(key string) (T, bool)

Get returns the "enum" value for the given string.

type HTTPInterface 

type HTTPInterface interface {
	Do(req *http.Request) (*http.Response, error)
}

HTTPInterface is the HTTP client interface

type IDs 

type IDs []string

IDs are string ids saved as an array

func (IDs) GormDBDataType 

func (IDs) GormDBDataType(db *gorm.DB, _ *schema.Field) string

GormDBDataType the gorm data type for metadata

func (IDs) GormDataType 

func (i IDs) GormDataType() string

GormDataType type in gorm

func (*IDs) Scan 

func (i *IDs) Scan(value interface{}) error

Scan scan value into JSON, implements sql.Scanner interface

func (IDs) Value 

func (i IDs) Value() (driver.Value, error)

Value return json value, implement driver.Valuer interface

type MapProtocol 

type MapProtocol struct {
	App  string                 `json:"app,omitempty"`  // Application name
	Keys map[string]interface{} `json:"keys,omitempty"` // Keys to set
	Type string                 `json:"type,omitempty"` // Type of action
}

MapProtocol is a specific MAP protocol interface for an op_return

type Metadata 

type Metadata map[string]interface{}

Metadata is an object representing the metadata about the related record (standard across all tables)

Gorm related models & indexes: https://gorm.io/docs/models.html - https://gorm.io/docs/indexes.html

func (Metadata) GormDBDataType 

func (Metadata) GormDBDataType(db *gorm.DB, _ *schema.Field) string

GormDBDataType the gorm data type for metadata

func (Metadata) GormDataType 

func (m Metadata) GormDataType() string

GormDataType type in gorm

func (*Metadata) MarshalBSONValue 

func (m *Metadata) MarshalBSONValue() (bsontype.Type, []byte, error)

MarshalBSONValue method is called by bson.Marshal in Mongo for type = Metadata

func (*Metadata) Scan 

func (m *Metadata) Scan(value interface{}) error

Scan scan value into Json, implements sql.Scanner interface

func (*Metadata) UnmarshalBSONValue 

func (m *Metadata) UnmarshalBSONValue(t bsontype.Type, data []byte) error

UnmarshalBSONValue method is called by bson.Unmarshal in Mongo for type = Metadata

func (Metadata) Value 

func (m Metadata) Value() (driver.Value, error)

Value return json value, implement driver.Valuer interface

type MockTransactionStore 

type MockTransactionStore struct {
	Transactions map[string]*Transaction
}

MockTransactionStore is a mock implementation of TransactionGetter.

func NewMockTransactionStore 

func NewMockTransactionStore() *MockTransactionStore

NewMockTransactionStore creates new mock transaction store.

func (*MockTransactionStore) AddToStore 

func (m *MockTransactionStore) AddToStore(tx *Transaction)

AddToStore adds transaction to store.

func (*MockTransactionStore) GetTransactionsByIDs 

func (m *MockTransactionStore) GetTransactionsByIDs(_ context.Context, txIDs []string) ([]*Transaction, error)

GetTransactionsByIDs returns transactions by IDs.

type Model 

type Model struct {
	CreatedAt time.Time `` /* 134-byte string literal not displayed */
	UpdatedAt time.Time `` /* 138-byte string literal not displayed */
	Metadata  Metadata  `gorm:"type:json;comment:The JSON metadata for the record" json:"metadata,omitempty" bson:"metadata,omitempty"`

	// https://gorm.io/docs/indexes.html
	// DeletedAt gorm.DeletedAt `json:"deleted_at" toml:"deleted_at" yaml:"deleted_at" (@mrz: this was the original type)
	DeletedAt customTypes.NullTime `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

Model is the generic model field(s) and interface(s)

gorm: https://gorm.io/docs/models.html

func NewBaseModel 

func NewBaseModel(name ModelName, opts ...ModelOps) (m *Model)

NewBaseModel create an empty base model

func (*Model) AfterCreated 

func (m *Model) AfterCreated(_ context.Context) error

AfterCreated will fire after the model is created in the Datastore

func (*Model) AfterDeleted 

func (m *Model) AfterDeleted(_ context.Context) error

AfterDeleted will fire after a successful delete in the Datastore

func (*Model) AfterUpdated 

func (m *Model) AfterUpdated(_ context.Context) error

AfterUpdated will fire after a successful update into the Datastore

func (*Model) BeforeUpdating 

func (m *Model) BeforeUpdating(_ context.Context) error

BeforeUpdating will fire before updating a model in the Datastore

func (*Model) ChildModels 

func (m *Model) ChildModels() []ModelInterface

ChildModels will return any child models

func (*Model) Client 

func (m *Model) Client() ClientInterface

Client will return the current client

func (*Model) Display 

func (m *Model) Display() interface{}

Display filter the model for display

func (*Model) GetID 

func (m *Model) GetID() string

GetID will get the model id, if overwritten in the actual model

func (*Model) GetOptions 

func (m *Model) GetOptions(isNewRecord bool) (opts []ModelOps)

GetOptions will get the options that are set on that model

func (*Model) IsNew 

func (m *Model) IsNew() bool

IsNew returns true if the model is (or was) a new record

func (*Model) Name 

func (m *Model) Name() string

Name will get the collection name (model)

func (*Model) New 

func (m *Model) New()

New will set the record to new

func (*Model) NotNew 

func (m *Model) NotNew()

NotNew sets newRecord to false

func (*Model) RawXpub 

func (m *Model) RawXpub() string

RawXpub returns the rawXpubKey

func (*Model) SetOptions 

func (m *Model) SetOptions(opts ...ModelOps)

SetOptions will set the options on the model

func (*Model) SetRecordTime 

func (m *Model) SetRecordTime(created bool)

SetRecordTime will set the record timestamps (created is true for a new record)

func (*Model) UpdateMetadata 

func (m *Model) UpdateMetadata(metadata Metadata)

UpdateMetadata will update the metadata on the model any key set to nil will be removed, other keys updated or added

type ModelInterface 

type ModelInterface interface {
	AfterCreated(ctx context.Context) (err error)
	AfterDeleted(ctx context.Context) (err error)
	AfterUpdated(ctx context.Context) (err error)
	BeforeCreating(ctx context.Context) (err error)
	BeforeUpdating(ctx context.Context) (err error)
	ChildModels() []ModelInterface
	Client() ClientInterface
	Display() interface{}
	GetID() string
	GetModelName() string
	GetModelTableName() string
	GetOptions(isNewRecord bool) (opts []ModelOps)
	IsNew() bool
	Migrate(client datastore.ClientInterface) error
	Name() string
	New()
	NotNew()
	RawXpub() string
	Save(ctx context.Context) (err error)
	SetOptions(opts ...ModelOps)
	SetRecordTime(bool)
	UpdateMetadata(metadata Metadata)
}

ModelInterface is the interface that all models share

type ModelName 

type ModelName string

ModelName is the model name type 

const (
	ModelAccessKey        ModelName = "access_key"
	ModelDestination      ModelName = "destination"
	ModelDraftTransaction ModelName = "draft_transaction"
	ModelMetadata         ModelName = "metadata"
	ModelNameEmpty        ModelName = "empty"
	ModelPaymailAddress   ModelName = "paymail_address"
	ModelSyncTransaction  ModelName = "sync_transaction"
	ModelTransaction      ModelName = "transaction"
	ModelUtxo             ModelName = "utxo"
	ModelXPub             ModelName = "xpub"
	ModelContact          ModelName = "contact"
	ModelWebhook          ModelName = "webhook"
)

All the base models

func (ModelName) IsEmpty 

func (n ModelName) IsEmpty() bool

IsEmpty tests if the model name is empty

func (ModelName) String 

func (n ModelName) String() string

String is the string version of the name

type ModelOps 

type ModelOps func(m *Model)

ModelOps allow functional options to be supplied that overwrite default model options

func New 

func New() ModelOps

New set this model to a new record

func WithClient 

func WithClient(client ClientInterface) ModelOps

WithClient will set the Client on the model

func WithEncryptionKey 

func WithEncryptionKey(encryptionKey string) ModelOps

WithEncryptionKey will set the encryption key on the model (if needed)

func WithMetadata 

func WithMetadata(key string, value interface{}) ModelOps

WithMetadata will add the metadata record to the model

func WithMetadataFromJSON 

func WithMetadataFromJSON(jsonData []byte) ModelOps

WithMetadataFromJSON will add the metadata record to the model

func WithMetadatas 

func WithMetadatas(metadata map[string]interface{}) ModelOps

WithMetadatas will add multiple metadata records to the model

func WithPageSize 

func WithPageSize(pageSize int) ModelOps

WithPageSize will set the pageSize to use on the model in queries

func WithXPub 

func WithXPub(rawXpubKey string) ModelOps

WithXPub will set the xPub key on the model

type ModelService 

type ModelService interface {
	AddModels(ctx context.Context, autoMigrate bool, models ...interface{}) error
	DefaultModelOptions(opts ...ModelOps) []ModelOps
	GetModelNames() []string
}

ModelService is the "model" related services

type OpReturn 

type OpReturn struct {
	Hex         string       `json:"hex,omitempty"`          // Full hex
	HexParts    []string     `json:"hex_parts,omitempty"`    // Hex into parts
	Map         *MapProtocol `json:"map,omitempty"`          // MAP protocol
	StringParts []string     `json:"string_parts,omitempty"` // String parts
}

OpReturn is the op_return definition for the output

type PaymailAddress 

type PaymailAddress struct {
	// Base model
	Model `bson:",inline"`

	// Model specific fields
	ID string `` // Unique identifier
	/* 127-byte string literal not displayed */
	XpubID string `` // Related xPub ID
	/* 129-byte string literal not displayed */
	Alias      string `json:"alias" toml:"alias" yaml:"alias" gorm:"<-;type:varchar(64);comment:This is alias@" bson:"alias"`           // Alias part of the paymail
	Domain     string `json:"domain" toml:"domain" yaml:"domain" gorm:"<-;type:varchar(255);comment:This is @domain.com" bson:"domain"` // Domain of the paymail
	PublicName string ``                                                                                                                // Full username
	/* 160-byte string literal not displayed */
	Avatar string `json:"avatar" toml:"avatar" yaml:"avatar" gorm:"<-;type:text;comment:This is avatar url" bson:"avatar"` // This is the url of the user (public profile)

	ExternalXpubKey string `` // PublicKey hex encoded
	/* 204-byte string literal not displayed */
	ExternalXpubKeyNum uint32 `` /* 180-byte string literal not displayed */
	PubKeyNum          uint32 `` /* 148-byte string literal not displayed */
	XpubDerivationSeq  uint32 `` /* 228-byte string literal not displayed */
	// contains filtered or unexported fields
}

PaymailAddress is an "external model example" - this model is not part of the standard models loaded and runtime

This model must be included at runtime via WithAutoMigrate() etc...

Gorm related models & indexes: https://gorm.io/docs/models.html - https://gorm.io/docs/indexes.html

func (*PaymailAddress) AfterCreated 

func (m *PaymailAddress) AfterCreated(_ context.Context) error

AfterCreated will fire after the model is created in the Datastore

func (*PaymailAddress) BeforeCreating 

func (m *PaymailAddress) BeforeCreating(_ context.Context) (err error)

BeforeCreating is called before the model is saved to the DB

func (*PaymailAddress) GetID 

func (m *PaymailAddress) GetID() string

GetID will get the ID

func (*PaymailAddress) GetIdentityXpub 

func (m *PaymailAddress) GetIdentityXpub() (*bip32.ExtendedKey, error)

GetIdentityXpub will get the identity related to the xPub

func (*PaymailAddress) GetModelName 

func (m *PaymailAddress) GetModelName() string

GetModelName returns the model name

func (*PaymailAddress) GetModelTableName 

func (m *PaymailAddress) GetModelTableName() string

GetModelTableName returns the model db table name

func (*PaymailAddress) GetNextXpub 

func (m *PaymailAddress) GetNextXpub(ctx context.Context) (*bip32.ExtendedKey, error)

GetNextXpub will get the next child xPub for external operations.

func (*PaymailAddress) GetPubKey 

func (m *PaymailAddress) GetPubKey() (string, error)

GetPubKey will get the public key for the paymail address.

func (*PaymailAddress) Migrate 

func (m *PaymailAddress) Migrate(client datastore.ClientInterface) error

Migrate model specific migration on startup

func (*PaymailAddress) RotatePubKey 

func (m *PaymailAddress) RotatePubKey(ctx context.Context) error

RotatePubKey will rotate the public key

func (*PaymailAddress) Save 

func (m *PaymailAddress) Save(ctx context.Context) (err error)

Save the model

func (*PaymailAddress) String 

func (m *PaymailAddress) String() string

type PaymailDefaultServiceProvider 

type PaymailDefaultServiceProvider struct {
	// contains filtered or unexported fields
}

PaymailDefaultServiceProvider is an interface for overriding the paymail actions in go-paymail/server

This is an example and the default functionality for all the basic Paymail actions

func (*PaymailDefaultServiceProvider) AddContact 

func (p *PaymailDefaultServiceProvider) AddContact(
	ctx context.Context,
	requesterPaymailAddress string,
	contact *paymail.PikeContactRequestPayload,
) (err error)

AddContact will add a contact to the paymail address

func (*PaymailDefaultServiceProvider) CreateAddressResolutionResponse 

func (p *PaymailDefaultServiceProvider) CreateAddressResolutionResponse(
	ctx context.Context,
	alias, domain string,
	_ bool,
	requestMetadata *server.RequestMetadata,
) (*paymail.ResolutionPayload, error)

CreateAddressResolutionResponse will create the address resolution response

func (*PaymailDefaultServiceProvider) CreateP2PDestinationResponse 

func (p *PaymailDefaultServiceProvider) CreateP2PDestinationResponse(
	ctx context.Context,
	alias, domain string,
	satoshis uint64,
	requestMetadata *server.RequestMetadata,
) (*paymail.PaymentDestinationPayload, error)

CreateP2PDestinationResponse will create a p2p destination response

func (*PaymailDefaultServiceProvider) GetPaymailByAlias 

func (p *PaymailDefaultServiceProvider) GetPaymailByAlias(
	ctx context.Context,
	alias, domain string,
	_ *server.RequestMetadata,
) (*paymail.AddressInformation, error)

GetPaymailByAlias will get a paymail address and information by alias

func (*PaymailDefaultServiceProvider) RecordTransaction 

func (p *PaymailDefaultServiceProvider) RecordTransaction(ctx context.Context,
	p2pTx *paymail.P2PTransaction, requestMetadata *server.RequestMetadata,
) (*paymail.P2PTransactionPayload, error)

RecordTransaction will record the transaction TODO: rename to HandleReceivedP2pTransaction

func (*PaymailDefaultServiceProvider) VerifyMerkleRoots 

func (p *PaymailDefaultServiceProvider) VerifyMerkleRoots(
	ctx context.Context,
	merkleRoots []*spv.MerkleRootConfirmationRequestItem,
) (err error)

VerifyMerkleRoots will verify the merkle roots by checking them in external header service - Block Headers Service

type PaymailP4 

type PaymailP4 struct {
	Alias           string               `json:"alias" toml:"alias" yaml:"alias" bson:"alias,omitempty"`                                                       // Alias of the paymail {alias}@domain.com
	Domain          string               `json:"domain" toml:"domain" yaml:"domain" bson:"domain,omitempty"`                                                   // Domain of the paymail alias@{domain.com}
	FromPaymail     string               `json:"from_paymail,omitempty" toml:"from_paymail" yaml:"from_paymail" bson:"from_paymail,omitempty"`                 // From paymail address: alias@domain.com
	Note            string               `json:"note,omitempty" toml:"note" yaml:"note" bson:"note,omitempty"`                                                 // Friendly readable note to the paymail receiver
	PubKey          string               `json:"pub_key,omitempty" toml:"pub_key" yaml:"pub_key" bson:"pub_key,omitempty"`                                     // Used for validating the signature
	ReceiveEndpoint string               `json:"receive_endpoint,omitempty" toml:"receive_endpoint" yaml:"receive_endpoint" bson:"receive_endpoint,omitempty"` // P2P endpoint when notifying
	ReferenceID     string               `json:"reference_id,omitempty" toml:"reference_id" yaml:"reference_id" bson:"reference_id,omitempty"`                 // Reference ID saved from P2P request
	ResolutionType  string               `json:"resolution_type" toml:"resolution_type" yaml:"resolution_type" bson:"resolution_type,omitempty"`               // Type of address resolution (basic vs p2p)
	Format          PaymailPayloadFormat `json:"format,omitempty" toml:"format" yaml:"format" bson:"format,omitempty"`                                         // Use beef format for the transaction
}

PaymailP4 paymail configuration for the p2p payments on this output

type PaymailPayloadFormat 

type PaymailPayloadFormat uint32

PaymailPayloadFormat is the format of the paymail payload 

const (
	BasicPaymailPayloadFormat PaymailPayloadFormat = iota
	BeefPaymailPayloadFormat
)

Types of Paymail payload formats

func (PaymailPayloadFormat) String 

func (format PaymailPayloadFormat) String() string

type PaymailServant 

type PaymailServant struct {
	// contains filtered or unexported fields
}

PaymailServant is a service that aims to make easier paymail operations

func (*PaymailServant) AddContactRequest 

func (s *PaymailServant) AddContactRequest(ctx context.Context, receiverPaymail *paymail.SanitisedPaymail, contactData *paymail.PikeContactRequestPayload) (*paymail.PikeContactRequestResponse, error)

AddContactRequest sends a contact invitation via PIKE capability

func (*PaymailServant) GetPkiForPaymail 

func (s *PaymailServant) GetPkiForPaymail(ctx context.Context, sPaymail *paymail.SanitisedPaymail) (*paymail.PKIResponse, error)

GetPkiForPaymail retrieves the PKI for a paymail address

func (*PaymailServant) GetSanitizedPaymail 

func (s *PaymailServant) GetSanitizedPaymail(addr string) (*paymail.SanitisedPaymail, error)

GetSanitizedPaymail validates and returns the sanitized version of paymail address (alias@domain.tld)

type PaymailServerOptions 

type PaymailServerOptions struct {
	*server.Configuration // Server configuration if Paymail is enabled

	DefaultFromPaymail string // IE: from@domain.com
	// contains filtered or unexported fields
}

PaymailServerOptions is the options for the Paymail server

type PaymailService 

type PaymailService interface {
	DeletePaymailAddress(ctx context.Context, address string, opts ...ModelOps) error
	GetPaymailConfig() *PaymailServerOptions
	GetPaymailAddress(ctx context.Context, address string, opts ...ModelOps) (*PaymailAddress, error)
	GetPaymailAddressesByXPubID(ctx context.Context, xPubID string, metadataConditions *Metadata,
		conditions map[string]interface{}, queryParams *datastore.QueryParams) ([]*PaymailAddress, error)
	NewPaymailAddress(ctx context.Context, key, address, publicName,
		avatar string, opts ...ModelOps) (*PaymailAddress, error)
	UpdatePaymailAddress(ctx context.Context, address, publicName,
		avatar string, opts ...ModelOps) (*PaymailAddress, error)
	UpdatePaymailAddressMetadata(ctx context.Context, address string,
		metadata Metadata, opts ...ModelOps) (*PaymailAddress, error)
}

PaymailService is the paymail actions & services

type PikeContactServiceProvider 

type PikeContactServiceProvider struct {
	// contains filtered or unexported fields
}

PikeContactServiceProvider is an interface for handling the pike contact actions in go-paymail/server

func (*PikeContactServiceProvider) AddContact 

func (p *PikeContactServiceProvider) AddContact(
	ctx context.Context,
	requesterPaymailAddress string,
	contact *paymail.PikeContactRequestPayload,
) (err error)

AddContact is a method to add a new contact to the pike contact list

type PikePaymentServiceProvider 

type PikePaymentServiceProvider struct {
	// contains filtered or unexported fields
}

PikePaymentServiceProvider is an interface for handling the pike payment actions in go-paymail/server

func (*PikePaymentServiceProvider) CreatePikeOutputResponse 

func (p *PikePaymentServiceProvider) CreatePikeOutputResponse(
	ctx context.Context,
	alias, domain, senderPubKey string,
	satoshis uint64,
	requestMetadata *server.RequestMetadata,
) (*paymail.PikePaymentOutputsResponse, error)

CreatePikeOutputResponse is a method to create new output templates, save destinations and return formatted response

type ScriptOutput 

type ScriptOutput struct {
	Address    string `json:"address,omitempty"`  // Hex encoded locking script
	Satoshis   uint64 `json:"satoshis,omitempty"` // Number of satoshis for that output
	Script     string `json:"script"`             // Hex encoded locking script
	ScriptType string `json:"script_type"`        // The type of output
}

ScriptOutput is the actual script record (could be several for one output record)

type SyncConfig 

type SyncConfig struct {
	Broadcast        bool `json:"broadcast" toml:"broadcast" yaml:"broadcast"`                         // Transaction should be broadcasted
	BroadcastInstant bool `json:"broadcast_instant" toml:"broadcast_instant" yaml:"broadcast_instant"` // Transaction should be broadcasted instantly (ASAP)
	PaymailP2P       bool `json:"paymail_p2p" toml:"paymail_p2p" yaml:"paymail_p2p"`                   // Transaction will be sent to all related paymail providers if P2P is detected
	SyncOnChain      bool `json:"sync_on_chain" toml:"sync_on_chain" yaml:"sync_on_chain"`             // Transaction should be checked that it's on-chain

}

SyncConfig is the configuration used for syncing a transaction (on-chain)

func (*SyncConfig) Scan 

func (t *SyncConfig) Scan(value interface{}) error

Scan will scan the value into Struct, implements sql.Scanner interface

func (SyncConfig) Value 

func (t SyncConfig) Value() (driver.Value, error)

Value return json value, implement driver.Valuer interface

type SyncResult 

type SyncResult struct {
	Action        string    `json:"action"`             // type: broadcast, sync etc
	ExecutedAt    time.Time `json:"executed_at"`        // Time it was executed
	Provider      string    `json:"provider,omitempty"` // Provider used for attempt(s)
	StatusMessage string    `json:"status_message"`     // Success or failure message
}

SyncResult is the complete attempt/result to sync (multiple providers and strategies)

type SyncResults 

type SyncResults struct {
	Results []*SyncResult `json:"results"` // Each result of a sync task
}

SyncResults is the results from all sync attempts (broadcast or sync)

func (*SyncResults) Scan 

func (t *SyncResults) Scan(value interface{}) error

Scan will scan the value into Struct, implements sql.Scanner interface

func (SyncResults) Value 

func (t SyncResults) Value() (driver.Value, error)

Value return json value, implement driver.Valuer interface

type SyncStatus 

type SyncStatus string

SyncStatus sync status 

const (
	// SyncStatusPending is when the sync is pending (blocked by other constraints)
	SyncStatusPending SyncStatus = statusPending

	// SyncStatusReady is when the sync is ready (waiting for workers)
	SyncStatusReady SyncStatus = statusReady

	// SyncStatusProcessing is when the sync is processing (worker is running task)
	SyncStatusProcessing SyncStatus = statusProcessing

	// SyncStatusCanceled is when the sync is canceled
	SyncStatusCanceled SyncStatus = statusCanceled

	// SyncStatusSkipped is when the sync is skipped
	SyncStatusSkipped SyncStatus = statusSkipped

	// SyncStatusError is when the sync has an error
	SyncStatusError SyncStatus = statusError

	// SyncStatusComplete is when the sync is complete
	SyncStatusComplete SyncStatus = statusComplete
)

func (*SyncStatus) Scan 

func (t *SyncStatus) Scan(value interface{}) error

Scan will scan the value into Struct, implements sql.Scanner interface

func (SyncStatus) String 

func (t SyncStatus) String() string

String is the string version of the status

func (SyncStatus) Value 

func (t SyncStatus) Value() (driver.Value, error)

Value return json value, implement driver.Valuer interface

type SyncTransaction 

type SyncTransaction struct {
	// Base model
	Model `bson:",inline"`

	// Model specific fields
	ID              string      `json:"id" toml:"id" yaml:"id" gorm:"<-:create;type:char(64);primaryKey;comment:This is the unique transaction id" bson:"_id"`
	Configuration   SyncConfig  `` /* 152-byte string literal not displayed */
	Results         SyncResults `json:"results" toml:"results" yaml:"results" gorm:"<-;type:text;comment:This is the results struct in JSON" bson:"results"`
	BroadcastStatus SyncStatus  `` /* 172-byte string literal not displayed */
	P2PStatus       SyncStatus  `` /* 177-byte string literal not displayed */
	SyncStatus      SyncStatus  `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

SyncTransaction is an object representing the chain-state sync configuration and results for a given transaction

Gorm related models & indexes: https://gorm.io/docs/models.html - https://gorm.io/docs/indexes.html

func GetSyncTransactionByID 

func GetSyncTransactionByID(ctx context.Context, id string, opts ...ModelOps) (*SyncTransaction, error)

GetSyncTransactionByID will get a sync transaction

func GetSyncTransactionByTxID 

func GetSyncTransactionByTxID(ctx context.Context, txID string, opts ...ModelOps) (*SyncTransaction, error)

GetSyncTransactionByTxID will get a sync transaction by it's transaction id.

func (*SyncTransaction) AfterCreated 

func (m *SyncTransaction) AfterCreated(_ context.Context) error

AfterCreated will fire after the model is created in the Datastore

func (*SyncTransaction) BeforeCreating 

func (m *SyncTransaction) BeforeCreating(_ context.Context) error

BeforeCreating will fire before the model is being inserted into the Datastore

func (*SyncTransaction) BeforeUpdating 

func (m *SyncTransaction) BeforeUpdating(_ context.Context) error

BeforeUpdating will fire before the model is being updated

func (*SyncTransaction) GetID 

func (m *SyncTransaction) GetID() string

GetID will get the ID

func (*SyncTransaction) GetModelName 

func (m *SyncTransaction) GetModelName() string

GetModelName will get the name of the current model

func (*SyncTransaction) GetModelTableName 

func (m *SyncTransaction) GetModelTableName() string

GetModelTableName will get the db table name of the current model

func (*SyncTransaction) Migrate 

func (m *SyncTransaction) Migrate(client datastore.ClientInterface) error

Migrate model specific migration on startup

func (*SyncTransaction) Save 

func (m *SyncTransaction) Save(ctx context.Context) error

Save will save the model into the Datastore

type Transaction 

type Transaction struct {
	// Base model
	Model `bson:",inline"`

	// Standard transaction model base fields
	TransactionBase `bson:",inline"`

	// Model specific fields
	XpubInIDs       IDs             `json:"xpub_in_ids,omitempty" toml:"xpub_in_ids" yaml:"xpub_in_ids" gorm:"<-;type:json" bson:"xpub_in_ids,omitempty"`
	XpubOutIDs      IDs             `json:"xpub_out_ids,omitempty" toml:"xpub_out_ids" yaml:"xpub_out_ids" gorm:"<-;type:json" bson:"xpub_out_ids,omitempty"`
	BlockHash       string          `` /* 170-byte string literal not displayed */
	BlockHeight     uint64          `` /* 176-byte string literal not displayed */
	Fee             uint64          `json:"fee" toml:"fee" yaml:"fee" gorm:"<-create;type:bigint" bson:"fee,omitempty"`
	NumberOfInputs  uint32          `json:"number_of_inputs" toml:"number_of_inputs" yaml:"number_of_inputs" gorm:"<-;type:int" bson:"number_of_inputs,omitempty"`
	NumberOfOutputs uint32          `` /* 128-byte string literal not displayed */
	DraftID         string          `` /* 149-byte string literal not displayed */
	TotalValue      uint64          `json:"total_value" toml:"total_value" yaml:"total_value" gorm:"<-create;type:bigint" bson:"total_value,omitempty"`
	XpubMetadata    XpubMetadata    `json:"-" toml:"xpub_metadata" gorm:"<-;type:json;xpub_id specific metadata" bson:"xpub_metadata,omitempty"`
	XpubOutputValue XpubOutputValue `json:"-" toml:"xpub_output_value" gorm:"<-;type:json;xpub_id specific value" bson:"xpub_output_value,omitempty"`
	BUMP            BUMP            `json:"bump" toml:"bump" yaml:"bump" gorm:"<-;type:text;comment:BSV Unified Merkle Path (BUMP) Format" bson:"bump,omitempty"`
	TxStatus        string          `` /* 141-byte string literal not displayed */

	// Virtual Fields
	OutputValue int64                `json:"output_value" toml:"-" yaml:"-" gorm:"-" bson:"-,omitempty"`
	Status      SyncStatus           `json:"status" toml:"-" yaml:"-" gorm:"-" bson:"-"`
	Direction   TransactionDirection `json:"direction" toml:"-" yaml:"-" gorm:"-" bson:"-"`

	XPubID string `gorm:"-" bson:"-"` // XPub of the user registering this transaction
	// contains filtered or unexported fields
}

Transaction is an object representing the BitCoin transaction

Gorm related models & indexes: https://gorm.io/docs/models.html - https://gorm.io/docs/indexes.html

func (*Transaction) AfterCreated 

func (m *Transaction) AfterCreated(ctx context.Context) error

AfterCreated will fire after the model is created in the Datastore

func (*Transaction) AfterDeleted 

func (m *Transaction) AfterDeleted(_ context.Context) error

AfterDeleted will fire after the model is deleted in the Datastore

func (*Transaction) AfterUpdated 

func (m *Transaction) AfterUpdated(_ context.Context) error

AfterUpdated will fire after the model is updated in the Datastore

func (*Transaction) BeforeCreating 

func (m *Transaction) BeforeCreating(_ context.Context) error

BeforeCreating will fire before the model is being inserted into the Datastore

func (*Transaction) ChildModels 

func (m *Transaction) ChildModels() (childModels []ModelInterface)

ChildModels will get any related sub models

func (*Transaction) Display 

func (m *Transaction) Display() interface{}

Display filter the model for display

func (*Transaction) GetID 

func (m *Transaction) GetID() string

GetID will get the ID

func (*Transaction) GetModelName 

func (m *Transaction) GetModelName() string

GetModelName will get the name of the current model

func (*Transaction) GetModelTableName 

func (m *Transaction) GetModelTableName() string

GetModelTableName will get the db table name of the current model

func (*Transaction) IsXpubAssociated 

func (m *Transaction) IsXpubAssociated(rawXpubKey string) bool

IsXpubAssociated will check if this key is associated to this transaction

func (*Transaction) IsXpubIDAssociated 

func (m *Transaction) IsXpubIDAssociated(xPubID string) bool

IsXpubIDAssociated will check if an xPub ID is associated

func (*Transaction) Migrate 

func (m *Transaction) Migrate(client datastore.ClientInterface) error

Migrate model specific migration on startup

func (*Transaction) Save 

func (m *Transaction) Save(ctx context.Context) (err error)

Save will save the model into the Datastore

func (*Transaction) UpdateTransactionMetadata 

func (m *Transaction) UpdateTransactionMetadata(xPubID string, metadata Metadata) error

UpdateTransactionMetadata will update the transaction metadata by xPubID

type TransactionBase 

type TransactionBase struct {
	ID  string `` /* 142-byte string literal not displayed */
	Hex string `json:"hex" toml:"hex" yaml:"hex" gorm:"<-:create;type:text;comment:This is the raw transaction hex" bson:"hex"`
	// contains filtered or unexported fields
}

TransactionBase is the same fields share between multiple transaction models

type TransactionConfig 

type TransactionConfig struct {
	ChangeDestinations         []*Destination       `json:"change_destinations" toml:"change_destinations" yaml:"change_destinations" bson:"change_destinations"`
	ChangeDestinationsStrategy ChangeStrategy       `` /* 143-byte string literal not displayed */
	ChangeMinimumSatoshis      uint64               `json:"change_minimum_satoshis" toml:"change_minimum_satoshis" yaml:"change_minimum_satoshis" bson:"change_minimum_satoshis"`
	ChangeNumberOfDestinations int                  ``                                                                                            /* 147-byte string literal not displayed */
	ChangeSatoshis             uint64               `json:"change_satoshis" toml:"change_satoshis" yaml:"change_satoshis" bson:"change_satoshis"` // The satoshis used for change
	ExpiresIn                  time.Duration        `json:"expires_in" toml:"expires_in" yaml:"expires_in" bson:"expires_in"`                     // The expiration time for the draft and utxos
	Fee                        uint64               `json:"fee" toml:"fee" yaml:"fee" bson:"fee"`                                                 // The fee used for the transaction (auto generated)
	FeeUnit                    *utils.FeeUnit       `json:"fee_unit" toml:"fee_unit" yaml:"fee_unit" bson:"fee_unit"`                             // Fee unit to use (overrides chainstate if set)
	FromUtxos                  []*UtxoPointer       `json:"from_utxos" toml:"from_utxos" yaml:"from_utxos" bson:"from_utxos"`                     // Use these specific utxos for the transaction
	IncludeUtxos               []*UtxoPointer       `json:"include_utxos" toml:"include_utxos" yaml:"include_utxos" bson:"include_utxos"`         // Include these utxos for the transaction, among others necessary if more is needed for fees
	Inputs                     []*TransactionInput  `json:"inputs" toml:"inputs" yaml:"inputs" bson:"inputs"`                                     // All transaction inputs
	Outputs                    []*TransactionOutput `json:"outputs" toml:"outputs" yaml:"outputs" bson:"outputs"`                                 // All transaction outputs
	SendAllTo                  *TransactionOutput   `json:"send_all_to,omitempty" toml:"send_all_to" yaml:"send_all_to" bson:"send_all_to"`       // Send ALL utxos to the output
	Sync                       *SyncConfig          `json:"sync" toml:"sync" yaml:"sync" bson:"sync"`                                             // Sync config for broadcasting and on-chain sync

}

TransactionConfig is the configuration used to start a transaction

func (*TransactionConfig) Scan 

func (t *TransactionConfig) Scan(value interface{}) error

Scan will scan the value into Struct, implements sql.Scanner interface

func (TransactionConfig) Value 

func (t TransactionConfig) Value() (driver.Value, error)

Value return json value, implement driver.Valuer interface

type TransactionDirection 

type TransactionDirection string

TransactionDirection String describing the direction of the transaction (in / out) 

const (
	// TransactionDirectionIn The transaction is coming in to the wallet of the xpub
	TransactionDirectionIn TransactionDirection = "incoming"

	// TransactionDirectionOut The transaction is going out of to the wallet of the xpub
	TransactionDirectionOut TransactionDirection = "outgoing"

	// TransactionDirectionReconcile The transaction is an internal reconciliation transaction
	TransactionDirectionReconcile TransactionDirection = "reconcile"
)

type TransactionGetter 

type TransactionGetter interface {
	GetTransactionsByIDs(ctx context.Context, txIDs []string) ([]*Transaction, error)
}

TransactionGetter interface for getting transactions by their IDs

type TransactionInput 

type TransactionInput struct {
	Utxo
	Destination Destination `json:"destination" toml:"destination" yaml:"destination" bson:"destination"`
}

TransactionInput is an input on the transaction config

type TransactionOutput 

type TransactionOutput struct {
	OpReturn     *OpReturn       `json:"op_return,omitempty" toml:"op_return" yaml:"op_return" bson:"op_return,omitempty"`                     // Add op_return data as an output
	PaymailP4    *PaymailP4      `json:"paymail_p4,omitempty" toml:"paymail_p4" yaml:"paymail_p4" bson:"paymail_p4,omitempty"`                 // Additional information for P4 or Paymail
	Satoshis     uint64          `json:"satoshis" toml:"satoshis" yaml:"satoshis" bson:"satoshis"`                                             // Set the specific satoshis to send (when applicable)
	Script       string          `json:"script,omitempty" toml:"script" yaml:"script" bson:"script,omitempty"`                                 // custom (non-standard) script output
	Scripts      []*ScriptOutput `json:"scripts" toml:"scripts" yaml:"scripts" bson:"scripts"`                                                 // Add script outputs
	To           string          `json:"to,omitempty" toml:"to" yaml:"to" bson:"to,omitempty"`                                                 // To address, paymail, handle
	UseForChange bool            `json:"use_for_change,omitempty" toml:"use_for_change" yaml:"use_for_change" bson:"use_for_change,omitempty"` // if set, no change destinations will be created, but all outputs flagged will get the change
}

TransactionOutput is an output on the transaction config

type TransactionService 

type TransactionService interface {
	GetTransaction(ctx context.Context, xPubID, txID string) (*Transaction, error)
	GetTransactionsByIDs(ctx context.Context, txIDs []string) ([]*Transaction, error)
	GetTransactionByHex(ctx context.Context, hex string) (*Transaction, error)
	GetTransactions(ctx context.Context, metadata *Metadata, conditions map[string]interface{},
		queryParams *datastore.QueryParams, opts ...ModelOps) ([]*Transaction, error)
	GetTransactionsCount(ctx context.Context, metadata *Metadata,
		conditions map[string]interface{}, opts ...ModelOps) (int64, error)
	GetTransactionsByXpubID(ctx context.Context, xPubID string, metadata *Metadata, conditions map[string]interface{},
		queryParams *datastore.QueryParams) ([]*Transaction, error)
	GetTransactionsByXpubIDCount(ctx context.Context, xPubID string, metadata *Metadata,
		conditions map[string]interface{}) (int64, error)
	NewTransaction(ctx context.Context, rawXpubKey string, config *TransactionConfig,
		opts ...ModelOps) (*DraftTransaction, error)
	RecordTransaction(ctx context.Context, xPubKey, txHex, draftID string,
		opts ...ModelOps) (*Transaction, error)
	RecordRawTransaction(ctx context.Context, txHex string, opts ...ModelOps) (*Transaction, error)
	UpdateTransaction(ctx context.Context, txInfo *broadcast.SubmittedTx) error
	UpdateTransactionMetadata(ctx context.Context, xPubID, id string, metadata Metadata) (*Transaction, error)
	RevertTransaction(ctx context.Context, id string) error
}

TransactionService is the transaction actions

type UTXOService 

type UTXOService interface {
	GetUtxo(ctx context.Context, xPubKey, txID string, outputIndex uint32) (*Utxo, error)
	GetUtxoByTransactionID(ctx context.Context, txID string, outputIndex uint32) (*Utxo, error)
	GetUtxos(ctx context.Context, metadata *Metadata, conditions map[string]interface{},
		queryParams *datastore.QueryParams, opts ...ModelOps) ([]*Utxo, error)
	GetUtxosCount(ctx context.Context, metadata *Metadata,
		conditions map[string]interface{}, opts ...ModelOps) (int64, error)
	GetUtxosByXpubID(ctx context.Context, xPubID string, metadata *Metadata, conditions map[string]interface{},
		queryParams *datastore.QueryParams) ([]*Utxo, error)
	UnReserveUtxos(ctx context.Context, xPubID, draftID string) error
}

UTXOService is the utxo actions

type Utxo 

type Utxo struct {
	// Base model
	Model `bson:",inline"`

	// Standard utxo model base fields
	UtxoPointer `bson:",inline"`

	// Model specific fields
	ID           string                 `` /* 135-byte string literal not displayed */
	XpubID       string                 `` /* 129-byte string literal not displayed */
	Satoshis     uint64                 `` /* 143-byte string literal not displayed */
	ScriptPubKey string                 `` /* 149-byte string literal not displayed */
	Type         string                 `json:"type" toml:"type" yaml:"type" gorm:"<-:create;type:varchar(32);comment:Type of output" bson:"type"`
	DraftID      customTypes.NullString `` /* 148-byte string literal not displayed */
	ReservedAt   customTypes.NullTime   `json:"reserved_at" toml:"reserved_at" yaml:"reserved_at" gorm:"<-;comment:When it was reserved" bson:"reserved_at,omitempty"`
	SpendingTxID customTypes.NullString `` /* 172-byte string literal not displayed */

	// Virtual field holding the original transaction the utxo originated from
	// This is needed when signing a new transaction that spends the utxo
	Transaction *Transaction `json:"transaction,omitempty" toml:"-" yaml:"-" gorm:"-" bson:"-"`
}

Utxo is an object representing a BitCoin unspent transaction

Gorm related models & indexes: https://gorm.io/docs/models.html - https://gorm.io/docs/indexes.html

func (*Utxo) BeforeCreating 

func (m *Utxo) BeforeCreating(_ context.Context) error

BeforeCreating will fire before the model is being inserted into the Datastore

func (*Utxo) GenerateID 

func (m *Utxo) GenerateID() string

GenerateID will generate the id of the UTXO record based on the format: <txid>|<output_index>

func (*Utxo) GetID 

func (m *Utxo) GetID() string

GetID will get the ID

func (*Utxo) GetModelName 

func (m *Utxo) GetModelName() string

GetModelName will get the name of the current model

func (*Utxo) GetModelTableName 

func (m *Utxo) GetModelTableName() string

GetModelTableName will get the db table name of the current model

func (*Utxo) Migrate 

func (m *Utxo) Migrate(client datastore.ClientInterface) error

Migrate model specific migration on startup

func (*Utxo) Save 

func (m *Utxo) Save(ctx context.Context) (err error)

Save will save the model into the Datastore

type UtxoPointer 

type UtxoPointer struct {
	TransactionID string `` /* 174-byte string literal not displayed */
	OutputIndex   uint32 `` /* 165-byte string literal not displayed */
}

UtxoPointer is the actual pointer (index) for the UTXO

type Webhook 

type Webhook struct {
	// Base model
	Model `bson:",inline"`

	URL         string               `` /* 130-byte string literal not displayed */
	TokenHeader string               `` /* 144-byte string literal not displayed */
	Token       string               `json:"token" toml:"token" yaml:"token" gorm:"<-create;comment:This is optional token to be sent" bson:"token"`
	BannedTo    customTypes.NullTime `json:"banned_to" toml:"banned_to" yaml:"banned_to" gorm:"comment:The time until the webhook will be banned" bson:"banned_to"`
}

Webhook stores information about subscriptions to notifications via webhooks

Gorm related models & indexes: https://gorm.io/docs/models.html - https://gorm.io/docs/indexes.html

func (*Webhook) BanUntil 

func (m *Webhook) BanUntil(bannedTo time.Time)

BanUntil sets BannedTo field to the given time

func (*Webhook) Banned 

func (m *Webhook) Banned() bool

Banned returns true if the webhook is banned right now

func (*Webhook) BeforeCreating 

func (m *Webhook) BeforeCreating(_ context.Context) error

BeforeCreating will fire before the model is being inserted into the Datastore

func (*Webhook) Deleted 

func (m *Webhook) Deleted() bool

Deleted returns true if the webhook is deleted

func (*Webhook) GetID 

func (m *Webhook) GetID() string

GetID will get the ID

func (*Webhook) GetModelName 

func (m *Webhook) GetModelName() string

GetModelName will get the name of the current model

func (*Webhook) GetModelTableName 

func (m *Webhook) GetModelTableName() string

GetModelTableName will get the db table name of the current model

func (*Webhook) GetTokenHeader 

func (m *Webhook) GetTokenHeader() string

GetTokenHeader returns the token header of the webhook

func (*Webhook) GetTokenValue 

func (m *Webhook) GetTokenValue() string

GetTokenValue returns the token value of the webhook

func (*Webhook) GetURL 

func (m *Webhook) GetURL() string

GetURL returns the URL of the webhook

func (*Webhook) Migrate 

func (m *Webhook) Migrate(client datastore.ClientInterface) error

Migrate model specific migration on startup

func (*Webhook) Refresh 

func (m *Webhook) Refresh(tokenHeader, tokenValue string)

Refresh sets the DeletedAt and BannedTo fields to the zero value and updates the token header and value

func (*Webhook) Save 

func (m *Webhook) Save(ctx context.Context) error

Save will save the model into the Datastore

type WebhooksRepository 

type WebhooksRepository struct {
	// contains filtered or unexported fields
}

WebhooksRepository is the repository for webhooks. It implements the WebhooksRepository interface

func (*WebhooksRepository) Create 

func (wr *WebhooksRepository) Create(ctx context.Context, url, tokenHeader, tokenValue string) error

Create makes a new webhook instance and saves it to the database, it will fail if the webhook already exists in the database

func (*WebhooksRepository) Delete 

func (wr *WebhooksRepository) Delete(ctx context.Context, model notifications.ModelWebhook) error

Delete stores a model in the database

func (*WebhooksRepository) GetAll 

func (wr *WebhooksRepository) GetAll(ctx context.Context) ([]notifications.ModelWebhook, error)

GetAll gets all webhooks from the database

func (*WebhooksRepository) GetByURL 

func (wr *WebhooksRepository) GetByURL(ctx context.Context, url string) (notifications.ModelWebhook, error)

GetByURL gets a webhook by its URL. If the webhook does not exist, it returns a nil pointer and no error

func (*WebhooksRepository) Save 

func (wr *WebhooksRepository) Save(ctx context.Context, model notifications.ModelWebhook) error

Save stores a model in the database

type XPubService 

type XPubService interface {
	GetXpub(ctx context.Context, xPubKey string) (*Xpub, error)
	GetXpubByID(ctx context.Context, xPubID string) (*Xpub, error)
	NewXpub(ctx context.Context, xPubKey string, opts ...ModelOps) (*Xpub, error)
	UpdateXpubMetadata(ctx context.Context, xPubID string, metadata Metadata) (*Xpub, error)
}

XPubService is the xPub actions

type Xpub 

type Xpub struct {
	// Base model
	Model `bson:",inline"`

	// Model specific fields
	ID              string `json:"id" toml:"id" yaml:"id" gorm:"<-:create;type:char(64);primaryKey;comment:This is the sha256(xpub) hash" bson:"_id"`
	CurrentBalance  uint64 `` /* 149-byte string literal not displayed */
	NextInternalNum uint32 `` /* 248-byte string literal not displayed */
	NextExternalNum uint32 `` /* 249-byte string literal not displayed */
	// contains filtered or unexported fields
}

Xpub is an object representing an HD-Key or extended public key (xPub for short)

Gorm related models & indexes: https://gorm.io/docs/models.html - https://gorm.io/docs/indexes.html

func (*Xpub) AfterCreated 

func (m *Xpub) AfterCreated(ctx context.Context) error

AfterCreated will fire after the model is created in the Datastore

func (*Xpub) AfterUpdated 

func (m *Xpub) AfterUpdated(ctx context.Context) error

AfterUpdated will fire after a successful update into the Datastore

func (*Xpub) BeforeCreating 

func (m *Xpub) BeforeCreating(_ context.Context) error

BeforeCreating will fire before the model is being inserted into the Datastore

func (*Xpub) ChildModels 

func (m *Xpub) ChildModels() (childModels []ModelInterface)

ChildModels will get any related sub models

func (*Xpub) GetID 

func (m *Xpub) GetID() string

GetID will get the ID

func (*Xpub) GetModelName 

func (m *Xpub) GetModelName() string

GetModelName will get the name of the current model

func (*Xpub) GetModelTableName 

func (m *Xpub) GetModelTableName() string

GetModelTableName will get the db table name of the current model

func (*Xpub) GetNextExternalDerivationNum 

func (m *Xpub) GetNextExternalDerivationNum(ctx context.Context) (uint32, error)

GetNextExternalDerivationNum will return the next external derivation number

func (*Xpub) GetNextInternalDerivationNum 

func (m *Xpub) GetNextInternalDerivationNum(ctx context.Context) (uint32, error)

GetNextInternalDerivationNum will return the next internal derivation number

func (*Xpub) Migrate 

func (m *Xpub) Migrate(client datastore.ClientInterface) error

Migrate model specific migration on startup

func (*Xpub) RemovePrivateData 

func (m *Xpub) RemovePrivateData()

RemovePrivateData unset all fields that are sensitive

func (*Xpub) Save 

func (m *Xpub) Save(ctx context.Context) error

Save will save the model into the Datastore

type XpubMetadata 

type XpubMetadata map[string]Metadata

XpubMetadata XpubId specific metadata

func (XpubMetadata) GormDBDataType 

func (XpubMetadata) GormDBDataType(db *gorm.DB, _ *schema.Field) string

GormDBDataType the gorm data type for metadata

func (*XpubMetadata) MarshalBSONValue 

func (x *XpubMetadata) MarshalBSONValue() (bsontype.Type, []byte, error)

MarshalBSONValue method is called by bson.Marshal in Mongo for type = XpubMetadata

func (*XpubMetadata) Scan 

func (x *XpubMetadata) Scan(value interface{}) error

Scan scan value into Json, implements sql.Scanner interface

func (*XpubMetadata) UnmarshalBSONValue 

func (x *XpubMetadata) UnmarshalBSONValue(t bsontype.Type, data []byte) error

UnmarshalBSONValue method is called by bson.Unmarshal in Mongo for type = XpubMetadata

func (XpubMetadata) Value 

func (x XpubMetadata) Value() (driver.Value, error)

Value return json value, implement driver.Valuer interface

type XpubOutputValue 

type XpubOutputValue map[string]int64

XpubOutputValue Xpub specific output value of the transaction

func (XpubOutputValue) GormDBDataType 

func (XpubOutputValue) GormDBDataType(db *gorm.DB, _ *schema.Field) string

GormDBDataType the gorm data type for metadata

func (*XpubOutputValue) Scan 

func (x *XpubOutputValue) Scan(value interface{}) error

Scan scan value into Json, implements sql.Scanner interface

func (XpubOutputValue) Value 

func (x XpubOutputValue) Value() (driver.Value, error)

Value return json value, implement driver.Valuer interface

Source Files

View all Source files

Directories

Path Synopsis
Package chainstate is the on-chain data service abstraction layer
 Package chainstate is the on-chain data service abstraction layer
Package cluster is for clustering SPV Wallet Engine(s) or servers to work together for chainstate monitoring and other tasks
 Package cluster is for clustering SPV Wallet Engine(s) or servers to work together for chainstate monitoring and other tasks
Package datastore is the database service abstraction layer
 Package datastore is the database service abstraction layer
customtypes
Package customtypes encapsulates our custom database field types
 Package customtypes encapsulates our custom database field types
examples
client/broadcast_miners
client/chainstate
client/custom_cron
client/custom_models
client/custom_rates
client/custom_user_agent
client/debugging
client/encryption
client/logging
client/new
client/new_relic
client/paymail_support
client/pike
client/redis
Package metrics provides a way to track metrics in the application.
 Package metrics provides a way to track metrics in the application.
Package pike provides functionality to work with Pay-to-PubKey-Hash (P2PKH) scripts in a blockchain context.
 Package pike provides functionality to work with Pay-to-PubKey-Hash (P2PKH) scripts in a blockchain context.
script
template
Package template provides a collection of functions and types for working with script templates.
 Package template provides a collection of functions and types for working with script templates.
Package taskmanager is the task/job management service layer for concurrent and asynchronous tasks with cron scheduling.
 Package taskmanager is the task/job management service layer for concurrent and asynchronous tasks with cron scheduling.
Package tester is a generic testing package with helpful methods for all packages
 Package tester is a generic testing package with helpful methods for all packages
types
type42
Package utils is used for generic methods and values that are used across all packages
 Package utils is used for generic methods and values that are used across all packages

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.