Spaces:
Running
Running
| ; | |
| var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) { | |
| var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d; | |
| if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc); | |
| else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r; | |
| return c > 3 && r && Object.defineProperty(target, key, r), r; | |
| }; | |
| var __metadata = (this && this.__metadata) || function (k, v) { | |
| if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v); | |
| }; | |
| var AdminWorkspacesService_1; | |
| Object.defineProperty(exports, "__esModule", { value: true }); | |
| exports.AdminWorkspacesService = void 0; | |
| const common_1 = require("@nestjs/common"); | |
| const prisma_service_1 = require("../prisma/prisma.service"); | |
| const audit_service_1 = require("../audit/audit.service"); | |
| const client_1 = require("@prisma/client"); | |
| const shared_types_1 = require("@micprotocol/shared-types"); | |
| const admin_permission_decorator_1 = require("../common/decorators/admin-permission.decorator"); | |
| let AdminWorkspacesService = AdminWorkspacesService_1 = class AdminWorkspacesService { | |
| prisma; | |
| audit; | |
| logger = new common_1.Logger(AdminWorkspacesService_1.name); | |
| constructor(prisma, audit) { | |
| this.prisma = prisma; | |
| this.audit = audit; | |
| } | |
| async listWorkspaces(input = {}) { | |
| const limit = Math.min(Math.max(input.limit ?? 50, 1), 200); | |
| const where = { | |
| ...(input.search | |
| ? { | |
| OR: [ | |
| { name: { contains: input.search, mode: "insensitive" } }, | |
| { slug: { contains: input.search, mode: "insensitive" } }, | |
| ], | |
| } | |
| : {}), | |
| ...(input.suspended !== undefined | |
| ? { suspendedAt: input.suspended ? { not: null } : { equals: null } } | |
| : {}), | |
| }; | |
| const [total, items] = await Promise.all([ | |
| this.prisma.workspace.count({ where }), | |
| this.prisma.workspace.findMany({ | |
| where, | |
| orderBy: { createdAt: "desc" }, | |
| take: limit + 1, | |
| ...(input.cursor ? { skip: 1, cursor: { id: input.cursor } } : {}), | |
| select: { | |
| id: true, | |
| name: true, | |
| slug: true, | |
| subscriptionPlanId: true, | |
| subscriptionStatus: true, | |
| suspendedAt: true, | |
| createdAt: true, | |
| _count: { select: { members: true, podcasts: true } }, | |
| }, | |
| }), | |
| ]); | |
| const hasMore = items.length > limit; | |
| const page = hasMore ? items.slice(0, limit) : items; | |
| return { | |
| items: page.map((w) => ({ | |
| id: w.id, | |
| name: w.name, | |
| slug: w.slug, | |
| subscriptionPlanId: w.subscriptionPlanId, | |
| subscriptionStatus: w.subscriptionStatus, | |
| suspended: !!w.suspendedAt, | |
| suspendedAt: w.suspendedAt, | |
| memberCount: w._count.members, | |
| podcastCount: w._count.podcasts, | |
| createdAt: w.createdAt, | |
| })), | |
| total, | |
| nextCursor: hasMore ? page[page.length - 1]?.id ?? null : null, | |
| }; | |
| } | |
| async getWorkspace(workspaceId) { | |
| const workspace = await this.prisma.workspace.findUnique({ | |
| where: { id: workspaceId }, | |
| select: { | |
| id: true, | |
| name: true, | |
| slug: true, | |
| subscriptionPlanId: true, | |
| subscriptionStatus: true, | |
| billingSettings: true, | |
| suspendedAt: true, | |
| suspendedReason: true, | |
| verificationStatus: true, | |
| createdAt: true, | |
| updatedAt: true, | |
| _count: { select: { members: true, podcasts: true } }, | |
| }, | |
| }); | |
| if (!workspace) | |
| throw new common_1.NotFoundException(`Workspace ${workspaceId} not found`); | |
| return workspace; | |
| } | |
| async suspendWorkspace(workspaceId, reason, actorUserId) { | |
| const workspace = await this.prisma.workspace.findUnique({ | |
| where: { id: workspaceId }, | |
| select: { id: true, name: true, suspendedAt: true }, | |
| }); | |
| if (!workspace) | |
| throw new common_1.NotFoundException(`Workspace ${workspaceId} not found`); | |
| if (workspace.suspendedAt) | |
| throw new common_1.BadRequestException("Workspace is already suspended"); | |
| const suspendedAt = new Date(); | |
| const updated = await this.prisma.workspace.update({ | |
| where: { id: workspaceId }, | |
| data: { suspendedAt, suspendedReason: reason ?? null }, | |
| }); | |
| await this.audit.log({ | |
| userId: actorUserId, | |
| action: "admin.workspaces.suspend", | |
| entityType: "Workspace", | |
| entityId: workspaceId, | |
| metadata: { | |
| reason, | |
| before: { suspendedAt: null }, | |
| after: { suspendedAt, suspendedReason: reason }, | |
| }, | |
| }); | |
| return updated; | |
| } | |
| async reactivateWorkspace(workspaceId, actorUserId) { | |
| const workspace = await this.prisma.workspace.findUnique({ | |
| where: { id: workspaceId }, | |
| select: { id: true, name: true, suspendedAt: true }, | |
| }); | |
| if (!workspace) | |
| throw new common_1.NotFoundException(`Workspace ${workspaceId} not found`); | |
| if (!workspace.suspendedAt) | |
| throw new common_1.BadRequestException("Workspace is not suspended"); | |
| const updated = await this.prisma.workspace.update({ | |
| where: { id: workspaceId }, | |
| data: { suspendedAt: null, suspendedReason: null }, | |
| }); | |
| await this.audit.log({ | |
| userId: actorUserId, | |
| action: "admin.workspaces.reactivate", | |
| entityType: "Workspace", | |
| entityId: workspaceId, | |
| metadata: { | |
| before: { suspendedAt: workspace.suspendedAt }, | |
| after: { suspendedAt: null }, | |
| }, | |
| }); | |
| return updated; | |
| } | |
| async overridePlan(workspaceId, planId, actorUserId) { | |
| const workspace = await this.prisma.workspace.findUnique({ | |
| where: { id: workspaceId }, | |
| select: { id: true, name: true, subscriptionPlanId: true }, | |
| }); | |
| if (!workspace) | |
| throw new common_1.NotFoundException(`Workspace ${workspaceId} not found`); | |
| const updated = await this.prisma.workspace.update({ | |
| where: { id: workspaceId }, | |
| data: { subscriptionPlanId: planId }, | |
| }); | |
| await this.audit.log({ | |
| userId: actorUserId, | |
| action: "admin.workspaces.plan", | |
| entityType: "Workspace", | |
| entityId: workspaceId, | |
| metadata: { | |
| before: { subscriptionPlanId: workspace.subscriptionPlanId }, | |
| after: { subscriptionPlanId: planId }, | |
| }, | |
| }); | |
| return updated; | |
| } | |
| async setCredits(workspaceId, credits, actorUserId) { | |
| const workspace = await this.prisma.workspace.findUnique({ | |
| where: { id: workspaceId }, | |
| select: { id: true, name: true, billingSettings: true }, | |
| }); | |
| if (!workspace) | |
| throw new common_1.NotFoundException(`Workspace ${workspaceId} not found`); | |
| const settings = (workspace.billingSettings ?? {}); | |
| const before = settings["credits"]; | |
| const updated = await this.prisma.workspace.update({ | |
| where: { id: workspaceId }, | |
| data: { billingSettings: { ...settings, credits } }, | |
| }); | |
| await this.audit.log({ | |
| userId: actorUserId, | |
| action: "admin.workspaces.credits", | |
| entityType: "Workspace", | |
| entityId: workspaceId, | |
| metadata: { before, after: credits }, | |
| }); | |
| return updated; | |
| } | |
| async transferOwner(workspaceId, newOwnerUserId, actorUserId) { | |
| const workspace = await this.prisma.workspace.findUnique({ | |
| where: { id: workspaceId }, | |
| select: { id: true, name: true }, | |
| }); | |
| if (!workspace) | |
| throw new common_1.NotFoundException(`Workspace ${workspaceId} not found`); | |
| const newMember = await this.prisma.workspaceMember.findUnique({ | |
| where: { userId_workspaceId: { userId: newOwnerUserId, workspaceId } }, | |
| }); | |
| if (!newMember) | |
| throw new common_1.BadRequestException("Target user is not a member of this workspace"); | |
| const currentOwners = await this.prisma.workspaceMember.findMany({ | |
| where: { workspaceId, role: client_1.WorkspaceRole.owner }, | |
| }); | |
| for (const owner of currentOwners) { | |
| if (owner.id === newMember.id) | |
| continue; | |
| await this.prisma.workspaceMember.update({ | |
| where: { id: owner.id }, | |
| data: { role: client_1.WorkspaceRole.admin }, | |
| }); | |
| } | |
| await this.prisma.workspaceMember.update({ | |
| where: { id: newMember.id }, | |
| data: { role: client_1.WorkspaceRole.owner }, | |
| }); | |
| await this.audit.log({ | |
| userId: actorUserId, | |
| action: "admin.workspaces.transfer_owner", | |
| entityType: "Workspace", | |
| entityId: workspaceId, | |
| metadata: { newOwnerUserId, previousOwners: currentOwners.map((o) => o.userId) }, | |
| }); | |
| return { workspaceId, newOwnerUserId }; | |
| } | |
| async addWorkspaceNote(workspaceId, body, actorUserId) { | |
| const workspace = await this.prisma.workspace.findUnique({ | |
| where: { id: workspaceId }, | |
| select: { id: true }, | |
| }); | |
| if (!workspace) | |
| throw new common_1.NotFoundException(`Workspace ${workspaceId} not found`); | |
| const note = await this.prisma.adminNote.create({ | |
| data: { entityType: "Workspace", entityId: workspaceId, body, createdById: actorUserId }, | |
| }); | |
| await this.audit.log({ | |
| userId: actorUserId, | |
| action: "admin.workspaces.notes", | |
| entityType: "Workspace", | |
| entityId: workspaceId, | |
| metadata: { noteId: note.id }, | |
| }); | |
| return note; | |
| } | |
| }; | |
| exports.AdminWorkspacesService = AdminWorkspacesService; | |
| __decorate([ | |
| (0, admin_permission_decorator_1.requireAdminPermission)(shared_types_1.AdminPermission.WORKSPACES_SUSPEND), | |
| __metadata("design:type", Function), | |
| __metadata("design:paramtypes", [String, Object, String]), | |
| __metadata("design:returntype", Promise) | |
| ], AdminWorkspacesService.prototype, "suspendWorkspace", null); | |
| __decorate([ | |
| (0, admin_permission_decorator_1.requireAdminPermission)(shared_types_1.AdminPermission.WORKSPACES_SUSPEND), | |
| __metadata("design:type", Function), | |
| __metadata("design:paramtypes", [String, String]), | |
| __metadata("design:returntype", Promise) | |
| ], AdminWorkspacesService.prototype, "reactivateWorkspace", null); | |
| __decorate([ | |
| (0, admin_permission_decorator_1.requireAdminPermission)(shared_types_1.AdminPermission.WORKSPACES_PLAN), | |
| __metadata("design:type", Function), | |
| __metadata("design:paramtypes", [String, String, String]), | |
| __metadata("design:returntype", Promise) | |
| ], AdminWorkspacesService.prototype, "overridePlan", null); | |
| __decorate([ | |
| (0, admin_permission_decorator_1.requireAdminPermission)(shared_types_1.AdminPermission.WORKSPACES_CREDITS), | |
| __metadata("design:type", Function), | |
| __metadata("design:paramtypes", [String, Number, String]), | |
| __metadata("design:returntype", Promise) | |
| ], AdminWorkspacesService.prototype, "setCredits", null); | |
| __decorate([ | |
| (0, admin_permission_decorator_1.requireAdminPermission)(shared_types_1.AdminPermission.WORKSPACES_TRANSFER_OWNER), | |
| __metadata("design:type", Function), | |
| __metadata("design:paramtypes", [String, String, String]), | |
| __metadata("design:returntype", Promise) | |
| ], AdminWorkspacesService.prototype, "transferOwner", null); | |
| __decorate([ | |
| (0, admin_permission_decorator_1.requireAdminPermission)(shared_types_1.AdminPermission.WORKSPACES_NOTES), | |
| __metadata("design:type", Function), | |
| __metadata("design:paramtypes", [String, String, String]), | |
| __metadata("design:returntype", Promise) | |
| ], AdminWorkspacesService.prototype, "addWorkspaceNote", null); | |
| exports.AdminWorkspacesService = AdminWorkspacesService = AdminWorkspacesService_1 = __decorate([ | |
| (0, common_1.Injectable)(), | |
| __metadata("design:paramtypes", [prisma_service_1.PrismaService, | |
| audit_service_1.AuditService]) | |
| ], AdminWorkspacesService); | |
| //# sourceMappingURL=admin-workspaces.service.js.map |