From 1edd2558466d98f0768f2553a1324589daee9ccd Mon Sep 17 00:00:00 2001 From: Lauris Skraucis Date: Wed, 4 Sep 2024 13:17:13 +0200 Subject: [PATCH] fix: use dbWrite in OrganizationsTeamsRepository (#16485) --- .../repositories/organizations-teams.repository.ts | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/apps/api/v2/src/modules/organizations/repositories/organizations-teams.repository.ts b/apps/api/v2/src/modules/organizations/repositories/organizations-teams.repository.ts index b81489aa6b..0520556e7f 100644 --- a/apps/api/v2/src/modules/organizations/repositories/organizations-teams.repository.ts +++ b/apps/api/v2/src/modules/organizations/repositories/organizations-teams.repository.ts @@ -1,11 +1,12 @@ import { CreateOrgTeamDto } from "@/modules/organizations/inputs/create-organization-team.input"; import { UpdateOrgTeamDto } from "@/modules/organizations/inputs/update-organization-team.input"; import { PrismaReadService } from "@/modules/prisma/prisma-read.service"; +import { PrismaWriteService } from "@/modules/prisma/prisma-write.service"; import { Injectable } from "@nestjs/common"; @Injectable() export class OrganizationsTeamsRepository { - constructor(private readonly dbRead: PrismaReadService) {} + constructor(private readonly dbRead: PrismaReadService, private readonly dbWrite: PrismaWriteService) {} async findOrgTeam(organizationId: number, teamId: number) { return this.dbRead.prisma.team.findUnique({ @@ -26,7 +27,7 @@ export class OrganizationsTeamsRepository { } async deleteOrgTeam(organizationId: number, teamId: number) { - return this.dbRead.prisma.team.delete({ + return this.dbWrite.prisma.team.delete({ where: { id: teamId, isOrganization: false, @@ -36,13 +37,13 @@ export class OrganizationsTeamsRepository { } async createOrgTeam(organizationId: number, data: CreateOrgTeamDto) { - return this.dbRead.prisma.team.create({ + return this.dbWrite.prisma.team.create({ data: { ...data, parentId: organizationId }, }); } async createPlatformOrgTeam(organizationId: number, oAuthClientId: string, data: CreateOrgTeamDto) { - return this.dbRead.prisma.team.create({ + return this.dbWrite.prisma.team.create({ data: { ...data, parentId: organizationId, @@ -61,7 +62,7 @@ export class OrganizationsTeamsRepository { } async updateOrgTeam(organizationId: number, teamId: number, data: UpdateOrgTeamDto) { - return this.dbRead.prisma.team.update({ + return this.dbWrite.prisma.team.update({ data: { ...data }, where: { id: teamId, parentId: organizationId, isOrganization: false }, });