database

Nov 6, 2024

Changes in this version

type FeedRepo

+ func (r *FeedRepo) FindOne(ctx context.Context, params domain.FindOneParams) (*domain.Feed, error)

type ReleaseRepo

+ func (repo *ReleaseRepo) Update(ctx context.Context, r *domain.Release) error

Sep 12, 2024

Changes in this version

+ func NewProxyRepo(log logger.Logger, db *DB) domain.ProxyRepo

type APIRepo

+ func (r *APIRepo) GetAllAPIKeys(ctx context.Context) ([]domain.APIKey, error)

+ func (r *APIRepo) GetKey(ctx context.Context, key string) (*domain.APIKey, error)

type ActionRepo

+ func (r *ActionRepo) FindByFilterIDTx(ctx context.Context, filterID int, active *bool) ([]*domain.Action, error)

+ type ProxyRepo struct

+ func (r *ProxyRepo) Delete(ctx context.Context, id int64) error

+ func (r *ProxyRepo) FindByID(ctx context.Context, id int64) (*domain.Proxy, error)

+ func (r *ProxyRepo) List(ctx context.Context) ([]domain.Proxy, error)

+ func (r *ProxyRepo) Store(ctx context.Context, p *domain.Proxy) error

+ func (r *ProxyRepo) ToggleEnabled(ctx context.Context, id int64, enabled bool) error

+ func (r *ProxyRepo) Update(ctx context.Context, p *domain.Proxy) error

Aug 25, 2024

Changes in this version

type IndexerRepo

+ func (r *IndexerRepo) GetBy(ctx context.Context, req domain.GetIndexerRequest) (*domain.Indexer, error)

Jun 18, 2024

Changes in this version

type ReleaseRepo

+ func (repo *ReleaseRepo) CheckSmartEpisodeCanDownload(ctx context.Context, p *domain.SmartEpisodeParams) (bool, error)

May 9, 2024

Changes in this version

type ReleaseRepo

+ func (repo *ReleaseRepo) UpdateBaseURL(ctx context.Context, indexer string, oldBaseURL, newBaseURL string) error

Dec 1, 2023

Changes in this version

type DB

+ func (db *DB) ILike(col string, val string) ILikeDynamic

type UserRepo

+ func (r *UserRepo) Delete(ctx context.Context, username string) error

Oct 27, 2023

Changes in this version

type FeedCacheRepo

+ func (r *FeedCacheRepo) PutMany(ctx context.Context, items []domain.FeedCacheItem) error

type IndexerRepo

+ func (r *IndexerRepo) ToggleEnabled(ctx context.Context, indexerID int, enabled bool) error

Sep 11, 2023

Changes in this version

type FeedCacheRepo

+ func (r *FeedCacheRepo) DeleteByFeed(ctx context.Context, feedId int) error

+ func (r *FeedCacheRepo) DeleteStale(ctx context.Context) error

+ func (r *FeedCacheRepo) GetByFeed(ctx context.Context, feedId int) ([]domain.FeedCacheItem, error)

+ func (r *FeedCacheRepo) GetCountByFeed(ctx context.Context, feedId int) (int, error)

type FilterRepo

+ func (r *FilterRepo) DeleteFilterExternal(ctx context.Context, filterID int) error

+ func (r *FilterRepo) FindExternalFiltersByID(ctx context.Context, filterId int) ([]domain.FilterExternal, error)

+ func (r *FilterRepo) StoreFilterExternal(ctx context.Context, filterID int, externalFilters []domain.FilterExternal) error

Jun 14, 2023

Changes in this version

type ReleaseRepo

+ func (repo *ReleaseRepo) DeleteOlder(ctx context.Context, duration int) error

May 15, 2023

Changes in this version

type ActionRepo

+ func (r *ActionRepo) Get(ctx context.Context, req *domain.GetActionRequest) (*domain.Action, error)

type ReleaseRepo

+ func (repo *ReleaseRepo) Get(ctx context.Context, req *domain.GetReleaseRequest) (*domain.Release, error)

+ func (repo *ReleaseRepo) GetActionStatus(ctx context.Context, req *domain.GetReleaseActionStatusRequest) (*domain.ReleaseActionStatus, error)

May 2, 2023

Changes in this version

+ func NewAPIRepo(log logger.Logger, db *DB) domain.APIRepo

+ func NewActionRepo(log logger.Logger, db *DB, clientRepo domain.DownloadClientRepo) domain.ActionRepo

+ func NewClientCache() *clientCache

+ func NewDownloadClientRepo(log logger.Logger, db *DB) domain.DownloadClientRepo

+ func NewFeedCacheRepo(log logger.Logger, db *DB) domain.FeedCacheRepo

+ func NewFeedRepo(log logger.Logger, db *DB) domain.FeedRepo

+ func NewFilterRepo(log logger.Logger, db *DB) domain.FilterRepo

+ func NewIndexerRepo(log logger.Logger, db *DB) domain.IndexerRepo

+ func NewIrcRepo(log logger.Logger, db *DB) domain.IrcRepo

+ func NewNotificationRepo(log logger.Logger, db *DB) domain.NotificationRepo

+ func NewReleaseRepo(log logger.Logger, db *DB) domain.ReleaseRepo

+ func NewUserRepo(log logger.Logger, db *DB) domain.UserRepo

+ type APIRepo struct

+ func (r *APIRepo) Delete(ctx context.Context, key string) error

+ func (r *APIRepo) GetKeys(ctx context.Context) ([]domain.APIKey, error)

+ func (r *APIRepo) Store(ctx context.Context, key *domain.APIKey) error

+ type ActionRepo struct

+ func (r *ActionRepo) Delete(actionID int) error

+ func (r *ActionRepo) DeleteByFilterID(ctx context.Context, filterID int) error

+ func (r *ActionRepo) FindByFilterID(ctx context.Context, filterID int) ([]*domain.Action, error)

+ func (r *ActionRepo) List(ctx context.Context) ([]domain.Action, error)

+ func (r *ActionRepo) Store(ctx context.Context, action domain.Action) (*domain.Action, error)

+ func (r *ActionRepo) StoreFilterActions(ctx context.Context, actions []*domain.Action, filterID int64) ([]*domain.Action, error)

+ func (r *ActionRepo) ToggleEnabled(actionID int) error

+ func (r *ActionRepo) Update(ctx context.Context, action domain.Action) (*domain.Action, error)

+ type DB struct

+ DSN string

+ Driver string

+ func NewDB(cfg *domain.Config, log logger.Logger) (*DB, error)

+ func (db *DB) BeginTx(ctx context.Context, opts *sql.TxOptions) (*Tx, error)

+ func (db *DB) Close() error

+ func (db *DB) Open() error

+ func (db *DB) Ping() error

+ type DownloadClientRepo struct

+ func (r *DownloadClientRepo) Delete(ctx context.Context, clientID int) error

+ func (r *DownloadClientRepo) FindByID(ctx context.Context, id int32) (*domain.DownloadClient, error)

+ func (r *DownloadClientRepo) List(ctx context.Context) ([]domain.DownloadClient, error)

+ func (r *DownloadClientRepo) Store(ctx context.Context, client domain.DownloadClient) (*domain.DownloadClient, error)

+ func (r *DownloadClientRepo) Update(ctx context.Context, client domain.DownloadClient) (*domain.DownloadClient, error)

+ type FeedCacheRepo struct

+ func (r *FeedCacheRepo) Delete(ctx context.Context, bucket string, key string) error

+ func (r *FeedCacheRepo) DeleteBucket(ctx context.Context, bucket string) error

+ func (r *FeedCacheRepo) Exists(bucket string, key string) (bool, error)

+ func (r *FeedCacheRepo) Get(bucket string, key string) ([]byte, error)

+ func (r *FeedCacheRepo) GetByBucket(ctx context.Context, bucket string) ([]domain.FeedCacheItem, error)

+ func (r *FeedCacheRepo) GetCountByBucket(ctx context.Context, bucket string) (int, error)

+ func (r *FeedCacheRepo) Put(bucket string, key string, val []byte, ttl time.Time) error

+ type FeedRepo struct

+ func (r *FeedRepo) Delete(ctx context.Context, id int) error

+ func (r *FeedRepo) Find(ctx context.Context) ([]domain.Feed, error)

+ func (r *FeedRepo) FindByID(ctx context.Context, id int) (*domain.Feed, error)

+ func (r *FeedRepo) FindByIndexerIdentifier(ctx context.Context, indexer string) (*domain.Feed, error)

+ func (r *FeedRepo) GetLastRunDataByID(ctx context.Context, id int) (string, error)

+ func (r *FeedRepo) Store(ctx context.Context, feed *domain.Feed) error

+ func (r *FeedRepo) ToggleEnabled(ctx context.Context, id int, enabled bool) error

+ func (r *FeedRepo) Update(ctx context.Context, feed *domain.Feed) error

+ func (r *FeedRepo) UpdateLastRun(ctx context.Context, feedID int) error

+ func (r *FeedRepo) UpdateLastRunWithData(ctx context.Context, feedID int, data string) error

+ type FilterRepo struct

+ func (r *FilterRepo) Delete(ctx context.Context, filterID int) error

+ func (r *FilterRepo) DeleteIndexerConnections(ctx context.Context, filterID int) error

+ func (r *FilterRepo) Find(ctx context.Context, params domain.FilterQueryParams) ([]domain.Filter, error)

+ func (r *FilterRepo) FindByID(ctx context.Context, filterID int) (*domain.Filter, error)

+ func (r *FilterRepo) FindByIndexerIdentifier(ctx context.Context, indexer string) ([]domain.Filter, error)

+ func (r *FilterRepo) GetDownloadsByFilterId(ctx context.Context, filterID int) (*domain.FilterDownloads, error)

+ func (r *FilterRepo) ListFilters(ctx context.Context) ([]domain.Filter, error)

+ func (r *FilterRepo) Store(ctx context.Context, filter domain.Filter) (*domain.Filter, error)

+ func (r *FilterRepo) StoreIndexerConnection(ctx context.Context, filterID int, indexerID int) error

+ func (r *FilterRepo) StoreIndexerConnections(ctx context.Context, filterID int, indexers []domain.Indexer) error

+ func (r *FilterRepo) ToggleEnabled(ctx context.Context, filterID int, enabled bool) error

+ func (r *FilterRepo) Update(ctx context.Context, filter domain.Filter) (*domain.Filter, error)

+ func (r *FilterRepo) UpdatePartial(ctx context.Context, filter domain.FilterUpdate) error

+ type ILikeDynamic interface

+ ToSql func() (sql string, args []interface{}, err error)

+ func ILike(col string, val string) ILikeDynamic

+ type IndexerRepo struct

+ func (r *IndexerRepo) Delete(ctx context.Context, id int) error

+ func (r *IndexerRepo) FindByFilterID(ctx context.Context, id int) ([]domain.Indexer, error)

+ func (r *IndexerRepo) FindByID(ctx context.Context, id int) (*domain.Indexer, error)

+ func (r *IndexerRepo) List(ctx context.Context) ([]domain.Indexer, error)

+ func (r *IndexerRepo) Store(ctx context.Context, indexer domain.Indexer) (*domain.Indexer, error)

+ func (r *IndexerRepo) Update(ctx context.Context, indexer domain.Indexer) (*domain.Indexer, error)

+ type IrcRepo struct

+ func (r *IrcRepo) CheckExistingNetwork(ctx context.Context, network *domain.IrcNetwork) (*domain.IrcNetwork, error)

+ func (r *IrcRepo) DeleteNetwork(ctx context.Context, id int64) error

+ func (r *IrcRepo) FindActiveNetworks(ctx context.Context) ([]domain.IrcNetwork, error)

+ func (r *IrcRepo) GetNetworkByID(ctx context.Context, id int64) (*domain.IrcNetwork, error)

+ func (r *IrcRepo) ListChannels(networkID int64) ([]domain.IrcChannel, error)

+ func (r *IrcRepo) ListNetworks(ctx context.Context) ([]domain.IrcNetwork, error)

+ func (r *IrcRepo) StoreChannel(networkID int64, channel *domain.IrcChannel) error

+ func (r *IrcRepo) StoreNetwork(network *domain.IrcNetwork) error

+ func (r *IrcRepo) StoreNetworkChannels(ctx context.Context, networkID int64, channels []domain.IrcChannel) error

+ func (r *IrcRepo) UpdateChannel(channel *domain.IrcChannel) error

+ func (r *IrcRepo) UpdateInviteCommand(networkID int64, invite string) error

+ func (r *IrcRepo) UpdateNetwork(ctx context.Context, network *domain.IrcNetwork) error

+ type NotificationRepo struct

+ func (r *NotificationRepo) Delete(ctx context.Context, notificationID int) error

+ func (r *NotificationRepo) Find(ctx context.Context, params domain.NotificationQueryParams) ([]domain.Notification, int, error)

+ func (r *NotificationRepo) FindByID(ctx context.Context, id int) (*domain.Notification, error)

+ func (r *NotificationRepo) List(ctx context.Context) ([]domain.Notification, error)

+ func (r *NotificationRepo) Store(ctx context.Context, notification domain.Notification) (*domain.Notification, error)

+ func (r *NotificationRepo) Update(ctx context.Context, notification domain.Notification) (*domain.Notification, error)

+ type ReleaseRepo struct

+ func (repo *ReleaseRepo) CanDownloadShow(ctx context.Context, title string, season int, episode int) (bool, error)

+ func (repo *ReleaseRepo) Delete(ctx context.Context) error

+ func (repo *ReleaseRepo) Find(ctx context.Context, params domain.ReleaseQueryParams) ([]*domain.Release, int64, int64, error)

+ func (repo *ReleaseRepo) FindRecent(ctx context.Context) ([]*domain.Release, error)

+ func (repo *ReleaseRepo) GetActionStatusByReleaseID(ctx context.Context, releaseID int64) ([]domain.ReleaseActionStatus, error)

+ func (repo *ReleaseRepo) GetIndexerOptions(ctx context.Context) ([]string, error)

+ func (repo *ReleaseRepo) Stats(ctx context.Context) (*domain.ReleaseStats, error)

+ func (repo *ReleaseRepo) Store(ctx context.Context, r *domain.Release) (*domain.Release, error)

+ func (repo *ReleaseRepo) StoreReleaseActionStatus(ctx context.Context, status *domain.ReleaseActionStatus) error

+ type Tx struct

+ type UserRepo struct

+ func (r *UserRepo) FindByUsername(ctx context.Context, username string) (*domain.User, error)

+ func (r *UserRepo) GetUserCount(ctx context.Context) (int, error)

+ func (r *UserRepo) Store(ctx context.Context, req domain.CreateUserRequest) error

+ func (r *UserRepo) Update(ctx context.Context, user domain.User) error