persistence

type ContentPersistence interface {
	GetContent(ctx context.Context, ref model.ContentRef) (movie model.Content, err error)
}

type Params struct {
	fx.In
	Query *dao.Query
}

type Persistence interface {
	TorrentPersistence
	ContentPersistence
}

type Result struct {
	fx.Out
	Persistence Persistence
}

type TorrentContentRef struct {
	model.ContentRef
	InfoHash model.Hash20
}

type TorrentPersistence interface {
	GetTorrent(ctx context.Context, infoHash model.Hash20) (torrent model.Torrent, err error)
	GetTorrents(ctx context.Context, infoHashes ...model.Hash20) (torrents []model.Torrent, missingInfoHashes []model.Hash20, err error)
	PutTorrent(ctx context.Context, torrent model.Torrent) error
	TorrentExists(ctx context.Context, infoHash model.Hash20) (bool, error)
	// GetPersistedInfoHashes returns the subset of provided hashes that are persisted in the database.
	GetPersistedInfoHashes(ctx context.Context, infoHashesToCheck []model.Hash20) ([]model.Hash20, error)
}