domain

type ConnectionType int

type DelegateRepository interface {
	Add(ctx context.Context, task DelegateTask) error
	GetByID(ctx context.Context, id string) (*DelegateTask, error)
	// return status == pending tasks
	GetAllPending(ctx context.Context) ([]PendingDelegateTask, error)
	GetAll(ctx context.Context, status DelegateTaskStatus, limit int, offset int) ([]DelegateTask, error)
	GetPendingTaskByIntentTxID(ctx context.Context, txid string) (*PendingDelegateTask, error)
	// return pending tasks that have any of the given inputs
	GetPendingTaskIDsByInputs(ctx context.Context, inputs []wire.OutPoint) ([]string, error)
	CancelTasks(ctx context.Context, ids ...string) error
	CompleteTasks(ctx context.Context, commitmentTxid string, ids ...string) error
	FailTasks(ctx context.Context, reason string, ids ...string) error
	Close()
}

type DelegateTask struct {
	ID                 string
	Intent             Intent
	ForfeitTxs         map[wire.OutPoint]string // forfeit transaction per input
	Fee                uint64
	DelegatorPublicKey string
	ScheduledAt        time.Time
	Status             DelegateTaskStatus
	FailReason         string // set only when task is failed
	CommitmentTxid     string // set only when task is completed
}

type DelegateTaskStatus int

type Intent struct {
	Message string
	Proof   string
	Txid    string
	Inputs  []wire.OutPoint
}

type LnConnectionOpts struct {
	LnDatadir      string
	LnUrl          string
	ConnectionType ConnectionType
}

type PendingDelegateTask struct {
	ID          string
	ScheduledAt time.Time
}

type Settings struct {
	ApiRoot          string
	ServerUrl        string
	EsploraUrl       string
	Currency         string
	EventServer      string
	FullNode         string
	Unit             string
	LnConnectionOpts *LnConnectionOpts
}

type SettingsRepository interface {
	AddDefaultSettings(ctx context.Context) error
	AddSettings(ctx context.Context, settings Settings) error
	GetSettings(ctx context.Context) (*Settings, error)
	CleanSettings(ctx context.Context) error
	UpdateSettings(ctx context.Context, settings Settings) error
	Close()
}

type SubscribedScriptRepository interface {
	Get(ctx context.Context) ([]string, error)
	Add(ctx context.Context, subscribedScripts []string) (count int, err error)
	Delete(ctx context.Context, subscribedScripts []string) (count int, err error)
	Close()
}

type Swap struct {
	Id          string
	Amount      uint64
	Timestamp   int64
	To          boltz.Currency
	From        boltz.Currency
	Status      SwapStatus
	Type        SwapType
	Invoice     string
	Vhtlc       Vhtlc
	FundingTxId string // the txid of the virtual tx that funded the vhtlc
	RedeemTxId  string // the txid of the virtual tx that redeemed the funds, by either "claiming" or "refunding"
}

type SwapRepository interface {
	GetAll(ctx context.Context) ([]Swap, error)
	Get(ctx context.Context, swapId string) (*Swap, error)
	Add(ctx context.Context, swaps []Swap) (int, error)
	Update(ctx context.Context, swap Swap) error
	Close()
}

type SwapStatus int

type SwapType int

type VHTLCRepository interface {
	GetAll(ctx context.Context) ([]Vhtlc, error)
	Get(ctx context.Context, id string) (*Vhtlc, error)
	Add(ctx context.Context, vhtlc Vhtlc) error
	Close()
}

type Vhtlc struct {
	vhtlc.Opts
	Id string
}