server

type AddressReaderWriterModifier interface {
	FindAddress(ctx context.Context, search string, limit int) ([]string, error)
	CheckAddressExists(ctx context.Context, address string) (bool, error)
	WriteAddress(ctx context.Context, address string) error
	IsAddressSuspended(ctx context.Context, addr string) (bool, error)
	IsAddressStandard(ctx context.Context, addr string) (bool, error)
	IsAddressTrusted(ctx context.Context, addr string) (bool, error)
	IsAddressAdmin(ctx context.Context, addr string) (bool, error)
}

type AliveResponse struct {
	Alive      bool   `json:"alive"`
	APIVersion string `json:"api_version"`
	APIHeader  string `json:"api_header"`
}

type AwaitedIssuedTransactionRequest struct {
	Address   string   `json:"address"`
	Data      []byte   `json:"data"`
	Hash      [32]byte `json:"hash"`
	Signature []byte   `json:"signature"`
}

type AwaitedTransactionResponse struct {
	Success             bool                      `json:"success"`
	AwaitedTransactions []transaction.Transaction `json:"awaited_transactions"`
}

type Bookkeeper interface {
	Verifier
	Run(ctx context.Context)
	WriteCandidateTransaction(ctx context.Context, tx *transaction.Transaction) error
	WriteIssuerSignedTransactionForReceiver(ctx context.Context, trx *transaction.Transaction) error
}

type Config struct {
	Port             int    `yaml:"port"`              // Port to listen on.
	DataSizeBytes    int    `yaml:"data_size_bytes"`   // Size of the data to be stored in the transaction.
	WebsocketAddress string `yaml:"websocket_address"` // Address of the websocket server.
}

type CreateAddressRequest struct {
	Address   string   `json:"address"`
	Token     string   `json:"token"`
	Data      []byte   `json:"data"`
	Hash      [32]byte `json:"hash"`
	Signature []byte   `json:"signature"`
}

type CreateAddressResponse struct {
	Success bool   `json:"success"`
	Address string `json:"address"`
}

type DataToSignRequest struct {
	Address string `json:"address"`
}

type DataToSignResponse struct {
	Data []byte `json:"message"`
}

type GenerateTokenRequest struct {
	Address    string   `json:"address"`
	Expiration int64    `json:"expiration"`
	Data       []byte   `json:"data"`
	Hash       [32]byte `json:"hash"`
	Signature  []byte   `json:"signature"`
}

type GenerateTokenResponse = token.Token

type IssuedTransactionResponse struct {
	Success            bool                      `json:"success"`
	IssuedTransactions []transaction.Transaction `json:"issued_transactions"`
}

type Message struct {
	Command     string                  `json:"command"`               // Command is the command that refers to the action handler in websocket protocol.
	Error       string                  `json:"error,omitempty"`       // Error is the error message that is sent to the client.
	Block       block.Block             `json:"block,omitempty"`       // Block is the block that is sent to the client.
	Transaction transaction.Transaction `json:"transaction,omitempty"` // Transaction is the transaction validated by the central server and will be added to the next block.
	Sockets     []string                `json:"sockets,omitempty"`     // sockets is the list of central nodes web-sockets addresses.
}

type RandomDataProvideValidator interface {
	ProvideData(address string) []byte
	ValidateData(address string, data []byte) bool
}

type ReactiveSubscriberProvider interface {
	Cancel()
	Channel() <-chan block.Block
}

type Register interface {
	RegisterNode(ctx context.Context, n, ws string) error
	UnregisterNode(ctx context.Context, n string) error
	ReadRegisteredNodesAddresses(ctx context.Context) ([]string, error)
	CountRegistered(ctx context.Context) (int, error)
}

type Repository interface {
	Register
	AddressReaderWriterModifier
	TokenWriteInvalidateChecker
	FindTransactionInBlockHash(ctx context.Context, trxHash [32]byte) ([32]byte, error)
	ReadAwaitingTransactionsByIssuer(ctx context.Context, address string) ([]transaction.Transaction, error)
	ReadAwaitingTransactionsByReceiver(ctx context.Context, address string) ([]transaction.Transaction, error)
}

type SearchAddressRequest struct {
	Address string `json:"address"`
}

type SearchAddressResponse struct {
	Addresses []string `json:"addresses"`
}

type SearchBlockRequest struct {
	Address    string   `json:"address"`
	RawTrxHash [32]byte `json:"raw_trx_hash"`
}

type SearchBlockResponse struct {
	RawBlockHash [32]byte `json:"raw_block_hash"`
}

type TokenWriteInvalidateChecker interface {
	WriteToken(ctx context.Context, tkn string, expirationDate int64) error
	CheckToken(ctx context.Context, token string) (bool, error)
	InvalidateToken(ctx context.Context, token string) error
}

type TransactionConfirmProposeResponse struct {
	Success bool     `json:"success"`
	TrxHash [32]byte `json:"trx_hash"`
}

type TransactionProposeRequest struct {
	ReceiverAddr string                  `json:"receiver_addr"`
	Transaction  transaction.Transaction `json:"transaction"`
}

type Verifier interface {
	VerifySignature(message, signature []byte, hash [32]byte, address string) error
}