Class SubscriptionsDAO

Hierarchy (View Summary)

BaseDAO
- SubscriptionsDAO

Implements

ISubscriptionsDAO

Constructors

constructor

new SubscriptionsDAO(dbClient: IDbClient): SubscriptionsDAO
Parameters
- dbClient: IDbClient
Returns SubscriptionsDAO
Overrides BaseDAO.constructor
- Defined in src/dao/db/SubscriptionsDAO.ts:12

Properties

`Protected` `Readonly`db

Methods

addSubscription

addSubscription(
user_id: number,
streamer_id: number,
): Promise<Subscription | null>
Parameters
- user_id: number
- streamer_id: number
Returns Promise<Subscription | null>
Implementation of ISubscriptionsDAO.addSubscription
- Defined in src/dao/db/SubscriptionsDAO.ts:26

`Protected`executeQuery

executeQuery<T>(query: string, params?: any[]): Promise<T | null>
Type Parameters
- T
Parameters
- query: string
- Optionalparams: any[]
Returns Promise<T | null>
Inherited from BaseDAO.executeQuery
- Defined in src/dao/db/BaseDao.ts:83

`Protected`executeQueryMultiple

executeQueryMultiple<T>(query: string, params?: any[]): Promise<T[]>
Type Parameters
- T
Parameters
- query: string
- Optionalparams: any[]
Returns Promise<T[]>
Inherited from BaseDAO.executeQueryMultiple
- Defined in src/dao/db/BaseDao.ts:97

getRecentSubscriptionsByUser

getRecentSubscriptionsByUser(
user_id: number,
limit: number,
): Promise<UserAsSubscriber[]>
Parameters
- user_id: number
- limit: number
Returns Promise<UserAsSubscriber[]>
Implementation of ISubscriptionsDAO.getRecentSubscriptionsByUser
- Defined in src/dao/db/SubscriptionsDAO.ts:127

getSubscriberDetails

getSubscriberDetails(
subscriberId: number,
): Promise<UserAsSubscriberWithStreamer | null>
Parameters
- subscriberId: number
Returns Promise<UserAsSubscriberWithStreamer | null>
Implementation of ISubscriptionsDAO.getSubscriberDetails
- Defined in src/dao/db/SubscriptionsDAO.ts:104

getSubscribersByStreamer

getSubscribersByStreamer(streamer_id: number): Promise<UserAsSubscriber[]>
Parameters
- streamer_id: number
Returns Promise<UserAsSubscriber[]>
Implementation of ISubscriptionsDAO.getSubscribersByStreamer
- Defined in src/dao/db/SubscriptionsDAO.ts:52

getSubscribersPaginated

getSubscribersPaginated(
    streamer_id: number,
    offset?: number,
    limit?: number,
): Promise<UserAsSubscriber[]>
Parameters
- streamer_id: number
- offset: number = 0
- limit: number = 10
Returns Promise<UserAsSubscriber[]>
Implementation of ISubscriptionsDAO.getSubscribersPaginated
- Defined in src/dao/db/SubscriptionsDAO.ts:72

getSubscriptionCountByStreamer

getSubscriptionCountByStreamer(streamer_id: number): Promise<number>
Parameters
- streamer_id: number
Returns Promise<number>
Implementation of ISubscriptionsDAO.getSubscriptionCountByStreamer
- Defined in src/dao/db/SubscriptionsDAO.ts:65

getSubscriptionCountByUser

getSubscriptionCountByUser(user_id: number): Promise<number>
Parameters
- user_id: number
Returns Promise<number>
Implementation of ISubscriptionsDAO.getSubscriptionCountByUser
- Defined in src/dao/db/SubscriptionsDAO.ts:60

getSubscriptionDetails

getSubscriptionDetails(
user_id: number,
streamer_id: number,
): Promise<UserAsSubscriberWithStreamer | null>
Parameters
- user_id: number
- streamer_id: number
Returns Promise<UserAsSubscriberWithStreamer | null>
Implementation of ISubscriptionsDAO.getSubscriptionDetails
- Defined in src/dao/db/SubscriptionsDAO.ts:112

getSubscriptionsByUser

getSubscriptionsByUser(user_id: number): Promise<UserAsSubscriber[]>
Parameters
- user_id: number
Returns Promise<UserAsSubscriber[]>
Implementation of ISubscriptionsDAO.getSubscriptionsByUser
- Defined in src/dao/db/SubscriptionsDAO.ts:45

getSubscriptionsPaginated

getSubscriptionsPaginated(
    user_id: number,
    offset?: number,
    limit?: number,
): Promise<UserAsSubscriber[]>
Parameters
- user_id: number
- offset: number = 0
- limit: number = 10
Returns Promise<UserAsSubscriber[]>
Implementation of ISubscriptionsDAO.getSubscriptionsPaginated
- Defined in src/dao/db/SubscriptionsDAO.ts:82

getTopStreamersBySubscribers

getTopStreamersBySubscribers(limit: number): Promise<TopStreamer[]>
Parameters
- limit: number
Returns Promise<TopStreamer[]>
Implementation of ISubscriptionsDAO.getTopStreamersBySubscribers
- Defined in src/dao/db/SubscriptionsDAO.ts:121

`Protected`mapCacheError

mapCacheError(error: any): DaoError
Parameters
- error: any
Returns DaoError
Inherited from BaseDAO.mapCacheError
- Defined in src/dao/db/BaseDao.ts:47

`Protected`mapError

mapError(error: any): DaoError
Parameters
- error: any
Returns DaoError
Inherited from BaseDAO.mapError
- Defined in src/dao/db/BaseDao.ts:60

`Protected`mapPostgresError

mapPostgresError(error: any): DaoError
Parameters
- error: any
Returns DaoError
Inherited from BaseDAO.mapPostgresError
- Defined in src/dao/db/BaseDao.ts:16

removeAllSubscribersByStreamer

removeAllSubscribersByStreamer(streamer_id: number): Promise<number>
Parameters
- streamer_id: number
Returns Promise<number>
Implementation of ISubscriptionsDAO.removeAllSubscribersByStreamer
- Defined in src/dao/db/SubscriptionsDAO.ts:98

removeAllSubscriptionsByUser

removeAllSubscriptionsByUser(user_id: number): Promise<number>
Parameters
- user_id: number
Returns Promise<number>
Implementation of ISubscriptionsDAO.removeAllSubscriptionsByUser
- Defined in src/dao/db/SubscriptionsDAO.ts:92

removeSubscription

removeSubscription(user_id: number, streamer_id: number): Promise<boolean>
Parameters
- user_id: number
- streamer_id: number
Returns Promise<boolean>
Implementation of ISubscriptionsDAO.removeSubscription
- Defined in src/dao/db/SubscriptionsDAO.ts:35

`Protected`scalar

scalar<T = any>(query: string, params?: any[]): Promise<T>
Type Parameters
- T = any
Parameters
- query: string
- Optionalparams: any[]
Returns Promise<T>
Inherited from BaseDAO.scalar
- Defined in src/dao/db/BaseDao.ts:109

subscriptionExists

subscriptionExists(user_id: number, streamer_id: number): Promise<boolean>
Parameters
- user_id: number
- streamer_id: number
Returns Promise<boolean>
Implementation of ISubscriptionsDAO.subscriptionExists
- Defined in src/dao/db/SubscriptionsDAO.ts:16