mtg

type Action struct {
	UTXOID    string
	CreatedAt time.Time
	State     int
}

type Clock struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type CollectibleOutput struct {
	Type               string
	UserId             string
	OutputId           string
	TokenId            string
	TransactionHash    crypto.Hash
	OutputIndex        int
	Amount             decimal.Decimal
	SendersThreshold   int64
	Senders            []string
	ReceiversThreshold int64
	Receivers          []string
	Memo               string
	CreatedAt          time.Time
	UpdatedAt          time.Time
	SignedBy           string
	SignedTx           string
	State              int
}

type CollectibleTransaction struct {
	TraceId   string
	State     int
	Receivers []string
	Threshold int
	Amount    string
	NFO       []byte
	Raw       []byte
	Hash      crypto.Hash
	UpdatedAt time.Time
	TokenId   string
}

type Configuration struct {
	App struct {
		ClientId   string `toml:"client-id"`
		SessionId  string `toml:"session-id"`
		PrivateKey string `toml:"private-key"`
		PinToken   string `toml:"pin-token"`
		PIN        string `toml:"pin"`
	} `toml:"app"`
	Genesis struct {
		Members   []string `toml:"members"`
		Threshold int      `toml:"threshold"`
		Timestamp int64    `toml:"timestamp"`
	} `toml:"genesis"`
	GroupSize        int   `toml:"group-size"`
	LoopWaitDuration int64 `toml:"loop-wait-duration"`
}

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

type Iteration struct {
	Action    int
	NodeId    string
	Threshold int
	CreatedAt time.Time
}

type NFOMemo struct {
	Prefix  string
	Version byte

	Mask       uint64
	Chain      uuid.UUID // 16 bytes
	Class      []byte    // 64 bytes contract address
	Collection uuid.UUID // 16 bytes
	Token      []byte    // 64 bytes hash of content

	Extra []byte
}

type Output struct {
	GroupId         string
	UserID          string
	UTXOID          string
	AssetID         string
	TransactionHash crypto.Hash
	OutputIndex     int
	Sender          string
	Amount          decimal.Decimal
	Threshold       uint8
	Members         []string
	Memo            string
	State           int
	CreatedAt       time.Time
	UpdatedAt       time.Time
	SignedBy        string
	SignedTx        string
}

type Store interface {
	WriteProperty(key, val []byte) error
	ReadProperty(key []byte) ([]byte, error)

	WriteIteration(ir *Iteration) error
	ListIterations() ([]*Iteration, error)

	WriteOutput(utxo *Output, traceId string) error
	WriteOutputs(utxos []*Output, traceId string) error

	ListOutputsForTransaction(traceId string) ([]*Output, error)
	ListOutputsForAsset(groupId string, state, assetId string, limit int) ([]*Output, error)

	WriteAction(act *Action) error
	ListActions(limit int) ([]*UnifiedOutput, error)

	WriteTransaction(tx *Transaction) error
	ReadTransactionByTraceId(traceId string) (*Transaction, error)
	ReadTransactionByHash(hash crypto.Hash) (*Transaction, error)
	ListTransactions(state int, limit int) ([]*Transaction, error)
	DeleteTransaction(tx *Transaction) error

	WriteCollectibleOutput(utxo *CollectibleOutput, traceId string) error
	WriteCollectibleOutputs(utxos []*CollectibleOutput, traceId string) error
	ListCollectibleOutputsForTransaction(traceId string) ([]*CollectibleOutput, error)
	ListCollectibleOutputsForToken(state, tokenId string, limit int) ([]*CollectibleOutput, error)

	WriteCollectibleTransaction(traceId string, tx *CollectibleTransaction) error
	ReadCollectibleTransaction(traceId string) (*CollectibleTransaction, error)
	ReadCollectibleTransactionByHash(hash crypto.Hash) (*CollectibleTransaction, error)
	ListCollectibleTransactions(state int, limit int) ([]*CollectibleTransaction, error)
}

type Transaction struct {
	GroupId    string
	TraceId    string
	State      int
	AssetId    string
	Receivers  []string
	Threshold  int
	Amount     string
	Memo       string
	Raw        []byte
	Hash       crypto.Hash
	References []crypto.Hash
	UpdatedAt  time.Time
}

type UnifiedOutput struct {
	Type            string          `json:"type"`
	UserId          string          `json:"user_id"`
	TransactionHash crypto.Hash     `json:"transaction_hash"`
	OutputIndex     int             `json:"output_index"`
	Amount          decimal.Decimal `json:"amount"`
	Memo            string          `json:"memo"`
	CreatedAt       time.Time       `json:"created_at"`
	UpdatedAt       time.Time       `json:"updated_at"`
	SignedBy        string          `json:"signed_by"`
	SignedTx        string          `json:"signed_tx"`
	State           string          `json:"state"`

	UnifiedOutputId           string   `json:"output_id"`
	UnifiedTokenId            string   `json:"token_id"`
	UnifiedSendersThreshold   int64    `json:"senders_threshold"`
	UnifiedSenders            []string `json:"senders"`
	UnifiedReceiversThreshold int64    `json:"receivers_threshold"`
	UnifiedReceivers          []string `json:"receivers"`

	UnifiedUTXOID    string   `json:"utxo_id"`
	UnifiedAssetId   string   `json:"asset_id"`
	UnifiedThreshold int64    `json:"threshold"`
	UnifiedMembers   []string `json:"members"`
	UnifiedSender    string   `json:"sender"`
}

type Worker interface {
	// handle the output and a true return value interrupts workers loop
	ProcessOutput(context.Context, *Output) bool
	ProcessCollectibleOutput(context.Context, *CollectibleOutput) bool
}