PrismaThreadRepository

@adamondo/backend

---

@adamondo/backend / infrastructure/prisma/repositories/PrismaThreadRepository

infrastructure/prisma/repositories/PrismaThreadRepository

Classes

PrismaThreadRepository

Defined in: src/infrastructure/prisma/repositories/PrismaThreadRepository.ts:12

Implements

• ThreadRepository

Constructors

Constructor

new PrismaThreadRepository(prisma): PrismaThreadRepository

Defined in: src/infrastructure/prisma/repositories/PrismaThreadRepository.ts:13

Parameters

prisma

PrismaClient

Returns

PrismaThreadRepository

Methods

findById()

findById(id): Promise<ThreadEntity | null>

Defined in: src/infrastructure/prisma/repositories/PrismaThreadRepository.ts:15

Parameters

id

number

Returns

Promise<ThreadEntity | null>

Implementation of

ThreadRepository.findById

findByUserIdAndThreadId()

findByUserIdAndThreadId(userId, id): Promise<ThreadEntity | null>

Defined in: src/infrastructure/prisma/repositories/PrismaThreadRepository.ts:34

Parameters

userId

string

id

number

Returns

Promise<ThreadEntity | null>

Implementation of

ThreadRepository.findByUserIdAndThreadId

updateIsRead()

updateIsRead(id, isRead): Promise<void>

Defined in: src/infrastructure/prisma/repositories/PrismaThreadRepository.ts:56

Parameters

id

number

isRead

boolean

Returns

Promise<void>

Implementation of

ThreadRepository.updateIsRead

updateMessageUpdatedDate()

updateMessageUpdatedDate(id, date): Promise<void>

Defined in: src/infrastructure/prisma/repositories/PrismaThreadRepository.ts:63

Parameters

id

number

date

Date

Returns

Promise<void>

Implementation of

ThreadRepository.updateMessageUpdatedDate

create()

create(data): Promise<ThreadEntity>

Defined in: src/infrastructure/prisma/repositories/PrismaThreadRepository.ts:70

Parameters

data

listId

number

host

string

guest

string

messageUpdatedDate?

Date

Returns

Promise<ThreadEntity>

Implementation of

ThreadRepository.create

findAllByUserIdAndRole()

findAllByUserIdAndRole(userId, role, limit, offset, options?): Promise<{ threads: ThreadEntity[]; count: number; }>

Defined in: src/infrastructure/prisma/repositories/PrismaThreadRepository.ts:92

Parameters

userId

string

role

"host" | "guest"

limit

number

offset

number

options?

reservationState?

string

orderBy?

string

unreadOnly?

boolean

Returns

Promise<{ threads: ThreadEntity[]; count: number; }>

Implementation of

ThreadRepository.findAllByUserIdAndRole

findAll()

findAll(limit, offset, options?): Promise<{ threads: ThreadEntity[]; count: number; }>

Defined in: src/infrastructure/prisma/repositories/PrismaThreadRepository.ts:172

Parameters

limit

number

offset

number

options?

reservationState?

string

orderBy?

string

Returns

Promise<{ threads: ThreadEntity[]; count: number; }>

Implementation of

ThreadRepository.findAll

countAll()

countAll(): Promise<number>

Defined in: src/infrastructure/prisma/repositories/PrismaThreadRepository.ts:238

Returns

Promise<number>

Implementation of

ThreadRepository.countAll

countByDateRange()

countByDateRange(startDate, endDate): Promise<number>

Defined in: src/infrastructure/prisma/repositories/PrismaThreadRepository.ts:242

Parameters

startDate

Date

endDate

Date

Returns

Promise<number>

Implementation of

ThreadRepository.countByDateRange

findIdsByUserId()

findIdsByUserId(userId): Promise<number[]>

Defined in: src/infrastructure/prisma/repositories/PrismaThreadRepository.ts:253

Parameters

userId

string

Returns

Promise<number[]>

Implementation of

ThreadRepository.findIdsByUserId

deleteAllThreadAndRelatedDataByIds()

deleteAllThreadAndRelatedDataByIds(ids, tx?): Promise<void>

Defined in: src/infrastructure/prisma/repositories/PrismaThreadRepository.ts:263

Parameters

ids

number[]

tx?

PrismaClient

Returns

Promise<void>

Implementation of

ThreadRepository.deleteAllThreadAndRelatedDataByIds