storage

type Celestial struct {
	bun.BaseModel `bun:"celestial" comment:"Table with celestial ids."`

	Id        string `bun:"id,pk,notnull"                 comment:"Celestial id"`
	AddressId uint64 `bun:"address_id"                    comment:"Internal address identity for connected address"`
	ImageUrl  string `bun:"image_url"                     comment:"Image url"`
	ChangeId  int64  `bun:"change_id"                     comment:"Id of the last change of celestial id"`
	Status    Status `bun:"status,type:celestials_status" comment:"Status of celestial domain"`
}

type CelestialState struct {
	bun.BaseModel `bun:"celestial_state" comment:"Table with celestial ids."`

	Name     string `bun:"name,pk,notnull" comment:"Celestial id indexer name"`
	ChangeId int64  `bun:"change_id"       comment:"Id of the last change of celestial id"`
}

type CelestialTransaction interface {
	SaveCelestials(ctx context.Context, celestials iter.Seq[Celestial]) error
	UpdateState(ctx context.Context, state *CelestialState) error
	UpdateStatusForAddress(ctx context.Context, addressId ...iter.Seq[uint64]) error

	sdk.Transaction
}

type ICelestial interface {
	ById(ctx context.Context, id string) (Celestial, error)
	ByAddressId(ctx context.Context, addressId uint64, limit, offset int) ([]Celestial, error)
	Primary(ctx context.Context, addressId uint64) (Celestial, error)
}

type ICelestialState interface {
	ByName(ctx context.Context, name string) (CelestialState, error)
	Save(ctx context.Context, state *CelestialState) error
}

type Status string