repository

Documentation

Index

• type Addresses
  • func NewAddressesRepo(db *gorm.DB) *Addresses
  • func (r *Addresses) FindByStringAddresses(ctx context.Context, addresses iter.Seq[string]) ([]*database.Address, error)
• type All
  • func NewRepositories(db *gorm.DB) *All
• type Operations
  • func NewOperationsRepo(db *gorm.DB) *Operations
  • func (o *Operations) PaginatedForUser(ctx context.Context, userID string, page filter.Page) (*dbquery.PagedResult[database.Operation], error)
  • func (o *Operations) SaveAll(ctx context.Context, opRows iter.Seq[*database.Operation]) error
• type Outputs
  • func NewOutputsRepo(db *gorm.DB) *Outputs
  • func (o *Outputs) FindByOutpoints(ctx context.Context, outpoints iter.Seq[bsv.Outpoint]) ([]*database.TrackedOutput, error)
• type Paymails
  • func NewPaymailsRepo(db *gorm.DB) *Paymails
  • func (p *Paymails) Get(ctx context.Context, alias, domain string) (*database.Paymail, error)
• type Users
  • func NewUsersRepo(db *gorm.DB) *Users
  • func (u *Users) AppendAddress(ctx context.Context, userRow *database.User, addressRow *database.Address) error
  • func (u *Users) GetBalance(ctx context.Context, userID string, bucket string) (bsv.Satoshis, error)
  • func (u *Users) Save(ctx context.Context, userRow *database.User) error

Types

type Addresses

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

Addresses is a repository for addresses.

func NewAddressesRepo

func NewAddressesRepo(db *gorm.DB) *Addresses

NewAddressesRepo creates a new repository for addresses.

func (*Addresses) FindByStringAddresses

func (r *Addresses) FindByStringAddresses(ctx context.Context, addresses iter.Seq[string]) ([]*database.Address, error)

FindByStringAddresses returns address rows from the database based on the provided iterator of string addresses.

type All

type All struct {
	Addresses  *Addresses
	Paymails   *Paymails
	Operations *Operations
	Users      *Users
	Outputs    *Outputs
}

All holds all repositories.

func NewRepositories

func NewRepositories(db *gorm.DB) *All

NewRepositories creates a new holder for all repositories.

type Operations

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

Operations is a repository for operations.

func NewOperationsRepo

func NewOperationsRepo(db *gorm.DB) *Operations

NewOperationsRepo creates a new repository for operations.

func (*Operations) PaginatedForUser

func (o *Operations) PaginatedForUser(ctx context.Context, userID string, page filter.Page) (*dbquery.PagedResult[database.Operation], error)

PaginatedForUser returns operations for a user based on userID and the provided paging options.

func (*Operations) SaveAll

func (o *Operations) SaveAll(ctx context.Context, opRows iter.Seq[*database.Operation]) error

SaveAll saves operations to the database.

type Outputs

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

Outputs is a repository for outputs.

func NewOutputsRepo

func NewOutputsRepo(db *gorm.DB) *Outputs

NewOutputsRepo creates a new repository for outputs.

func (*Outputs) FindByOutpoints

func (o *Outputs) FindByOutpoints(ctx context.Context, outpoints iter.Seq[bsv.Outpoint]) ([]*database.TrackedOutput, error)

FindByOutpoints returns outputs from the database based on the provided outpoints.

type Paymails

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

Paymails is a repository for paymails.

func NewPaymailsRepo

func NewPaymailsRepo(db *gorm.DB) *Paymails

NewPaymailsRepo creates a new repository for paymails.

func (*Paymails) Get

func (p *Paymails) Get(ctx context.Context, alias, domain string) (*database.Paymail, error)

Get returns a paymail by alias and domain.

type Users

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

Users is a repository for users.

func NewUsersRepo

func NewUsersRepo(db *gorm.DB) *Users

NewUsersRepo creates a new repository for users.

func (*Users) AppendAddress

func (u *Users) AppendAddress(ctx context.Context, userRow *database.User, addressRow *database.Address) error

AppendAddress appends an address to the database.

func (*Users) GetBalance

func (u *Users) GetBalance(ctx context.Context, userID string, bucket string) (bsv.Satoshis, error)

GetBalance returns the balance of a user in a given bucket.

func (*Users) Save

func (u *Users) Save(ctx context.Context, userRow *database.User) error

Save saves a user to the database.