diff --git a/libraries/nestjs-libraries/src/database/prisma/posts/posts.repository.ts b/libraries/nestjs-libraries/src/database/prisma/posts/posts.repository.ts index 9508a26c..96fccaff 100644 --- a/libraries/nestjs-libraries/src/database/prisma/posts/posts.repository.ts +++ b/libraries/nestjs-libraries/src/database/prisma/posts/posts.repository.ts @@ -48,6 +48,11 @@ export class PostsRepository { searchForMissingThreeHoursPosts() { return this._post.model.post.findMany({ where: { + integration: { + refreshNeeded: false, + inBetweenSteps: false, + disabled: false, + }, publishDate: { gte: dayjs.utc().toDate(), lt: dayjs.utc().add(3, 'hour').toDate(), @@ -66,6 +71,11 @@ export class PostsRepository { getOldPosts(orgId: string, date: string) { return this._post.model.post.findMany({ where: { + integration: { + refreshNeeded: false, + inBetweenSteps: false, + disabled: false, + }, organizationId: orgId, publishDate: { lte: dayjs(date).toDate(), diff --git a/libraries/nestjs-libraries/src/database/prisma/schema.prisma b/libraries/nestjs-libraries/src/database/prisma/schema.prisma index 6027caa2..0958133a 100644 --- a/libraries/nestjs-libraries/src/database/prisma/schema.prisma +++ b/libraries/nestjs-libraries/src/database/prisma/schema.prisma @@ -338,9 +338,14 @@ model Integration { @@unique([organizationId, internalId]) @@index([rootInternalId]) @@index([organizationId]) + @@index([providerIdentifier]) @@index([updatedAt]) + @@index([createdAt]) @@index([deletedAt]) @@index([customerId]) + @@index([inBetweenSteps]) + @@index([refreshNeeded]) + @@index([disabled]) } model Signatures {