supabase

type Account struct {
	ID           string    `json:"id"`
	Address      string    `json:"address"`
	PublicKey    string    `json:"public_key,omitempty"`
	EncryptedWIF string    `json:"encrypted_wif,omitempty"`
	KeyVersion   int       `json:"key_version,omitempty"`
	GenBatch     string    `json:"generation_batch,omitempty"`
	CreatedAt    time.Time `json:"created_at"`
	LastUsedAt   time.Time `json:"last_used_at"`
	TxCount      int64     `json:"tx_count"`
	IsRetiring   bool      `json:"is_retiring"`
	LockedBy     string    `json:"locked_by,omitempty"`
	LockedAt     time.Time `json:"locked_at,omitempty"`
}

type AccountBalance struct {
	AccountID  string    `json:"account_id"`
	TokenType  string    `json:"token_type"`  // "NEO", "GAS", or custom NEP-17
	ScriptHash string    `json:"script_hash"` // NEP-17 contract address (script hash)
	Amount     int64     `json:"amount"`
	Decimals   int       `json:"decimals"`
	UpdatedAt  time.Time `json:"updated_at"`
}

type AccountWithBalances struct {
	Account
	Balances map[string]TokenBalance `json:"balances"` // key: token_type
}

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

type RepositoryInterface interface {
	// Account CRUD operations
	Create(ctx context.Context, acc *Account) error
	Update(ctx context.Context, acc *Account) error
	GetByID(ctx context.Context, id string) (*Account, error)
	GetByAddress(ctx context.Context, address string) (*Account, error)
	List(ctx context.Context) ([]Account, error)
	ListAvailable(ctx context.Context, limit int) ([]Account, error)
	ListByLocker(ctx context.Context, lockerID string) ([]Account, error)
	TryLockAccount(ctx context.Context, accountID, serviceID string, lockedAt time.Time) (bool, error)
	TryReleaseAccount(ctx context.Context, accountID, serviceID string) (bool, error)
	Delete(ctx context.Context, id string) error

	// Balance-aware account operations
	GetWithBalances(ctx context.Context, id string) (*AccountWithBalances, error)
	ListWithBalances(ctx context.Context) ([]AccountWithBalances, error)
	ListAvailableWithBalances(ctx context.Context, tokenType string, minBalance *int64, limit int) ([]AccountWithBalances, error)
	ListByLockerWithBalances(ctx context.Context, lockerID string) ([]AccountWithBalances, error)
	ListLowBalanceAccounts(ctx context.Context, tokenType string, maxBalance int64, limit int) ([]AccountWithBalances, error)

	// Balance operations
	UpsertBalance(ctx context.Context, accountID, tokenType, scriptHash string, amount int64, decimals int) error
	GetBalance(ctx context.Context, accountID, tokenType string) (*AccountBalance, error)
	GetBalances(ctx context.Context, accountID string) ([]AccountBalance, error)
	GetBalancesForAccounts(ctx context.Context, accountIDs []string) ([]AccountBalance, error)
	DeleteBalances(ctx context.Context, accountID string) error
	// UpdateBalanceWithLock atomically updates balance while verifying lock ownership
	// Returns (oldBalance, newBalance, txCount, wasUpdated, error)
	// wasUpdated is false if account is not locked by the given service
	UpdateBalanceWithLock(ctx context.Context, accountID, serviceID, tokenType string, delta int64, absolute *int64) (int64, int64, int, bool, error)

	// Statistics
	AggregateTokenStats(ctx context.Context, tokenType string) (*TokenStats, error)
}

type TokenBalance = neoaccountstypes.TokenBalance

type TokenStats = neoaccountstypes.TokenStats