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 __param = (this && this.__param) || function (paramIndex, decorator) { | |
| return function (target, key) { decorator(target, key, paramIndex); } | |
| }; | |
| var InternalRealtimeController_1; | |
| Object.defineProperty(exports, "__esModule", { value: true }); | |
| exports.InternalRealtimeController = void 0; | |
| const common_1 = require("@nestjs/common"); | |
| const prisma_service_1 = require("../prisma/prisma.service"); | |
| const chat_service_1 = require("./chat.service"); | |
| const internal_token_guard_1 = require("../auth/internal-token.guard"); | |
| let InternalRealtimeController = InternalRealtimeController_1 = class InternalRealtimeController { | |
| prisma; | |
| chat; | |
| logger = new common_1.Logger(InternalRealtimeController_1.name); | |
| constructor(prisma, chat) { | |
| this.prisma = prisma; | |
| this.chat = chat; | |
| } | |
| async getState(conversationId, workspaceId) { | |
| return this.statePayload(conversationId, workspaceId); | |
| } | |
| async postState(conversationId, workspaceId) { | |
| return this.statePayload(conversationId, workspaceId); | |
| } | |
| async postEvent(conversationId, body) { | |
| const event = body.event; | |
| const evType = String(event?.["eventType"] ?? event?.["type"] ?? "message"); | |
| if (evType === "typing") | |
| return { ok: true, skipped: "typing" }; | |
| if (evType === "read") | |
| return { ok: true, skipped: "read" }; | |
| if (evType === "presence") | |
| return { ok: true, skipped: "presence" }; | |
| const seq = Number(event?.["seq"] ?? 0); | |
| const exists = await this.prisma.conversationMessage.findUnique({ | |
| where: { conversationId_seq: { conversationId, seq } }, | |
| select: { id: true }, | |
| }); | |
| if (exists) | |
| return { ok: true, skipped: "duplicate" }; | |
| const created = await this.prisma.conversationMessage.create({ | |
| data: { | |
| conversationId, | |
| userId: event?.["userId"] ?? null, | |
| body: event?.["body"] ?? null, | |
| eventType: evType, | |
| metadata: (event?.["meta"] ?? event?.["metadata"] ?? {}), | |
| seq, | |
| }, | |
| }); | |
| await this.prisma.conversation.update({ | |
| where: { id: conversationId }, | |
| data: { lastMessageAt: created.createdAt }, | |
| }).catch(() => undefined); | |
| return { ok: true, id: created.id }; | |
| } | |
| async recent(conversationId, limitParam) { | |
| const limit = this.parseLimit(limitParam); | |
| const messages = await this.fetchRecent(conversationId, limit); | |
| return { messages, nextCursor: null }; | |
| } | |
| async recentPost(conversationId, body) { | |
| const limit = this.parseLimit(body?.limit === undefined ? undefined : String(body.limit)); | |
| const messages = await this.fetchRecent(conversationId, limit); | |
| return { messages, nextCursor: null }; | |
| } | |
| async getMembers(conversationId) { | |
| const members = (await this.membersPayload(conversationId)); | |
| return { members }; | |
| } | |
| async addMember(conversationId, body) { | |
| if (!body?.userId) | |
| throw new common_1.BadRequestException("userId required"); | |
| const role = body.role ?? "member"; | |
| return this.chat.ensureMember(conversationId, body.userId, role); | |
| } | |
| async userConversations(userId) { | |
| const memberships = await this.prisma.conversationMember.findMany({ | |
| where: { userId }, | |
| select: { | |
| conversation: { | |
| select: { id: true, title: true, lastMessageAt: true }, | |
| }, | |
| }, | |
| orderBy: { joinedAt: "desc" }, | |
| take: 100, | |
| }); | |
| return { | |
| conversations: memberships.map((m) => m.conversation), | |
| }; | |
| } | |
| async getUser(userId) { | |
| const user = await this.prisma.user.findUnique({ | |
| where: { id: userId }, | |
| select: { id: true, name: true, email: true, image: true }, | |
| }); | |
| if (!user) | |
| return { user: null }; | |
| return { user }; | |
| } | |
| async statePayload(conversationId, workspaceId) { | |
| if (!workspaceId) { | |
| throw new common_1.BadRequestException("workspaceId is required"); | |
| } | |
| const conv = await this.prisma.conversation.findUnique({ | |
| where: { id: conversationId }, | |
| include: { | |
| members: true, | |
| messages: { | |
| orderBy: { seq: "desc" }, | |
| take: 200, | |
| }, | |
| }, | |
| }); | |
| if (!conv || conv.workspaceId !== workspaceId) { | |
| throw new common_1.UnauthorizedException("conversation unavailable"); | |
| } | |
| const recent = conv.messages | |
| .slice() | |
| .reverse() | |
| .map((m) => ({ | |
| id: m.id, | |
| userId: m.userId, | |
| conversationId: m.conversationId, | |
| body: m.body, | |
| eventType: m.eventType, | |
| metadata: m.metadata, | |
| seq: m.seq, | |
| at: m.createdAt.toISOString(), | |
| })); | |
| const members = {}; | |
| for (const m of conv.members) { | |
| members[m.userId] = { | |
| role: m.role, | |
| lastReadSeq: m.lastReadSeq, | |
| }; | |
| } | |
| return { members, recent, sequence: conv.messages[0]?.seq ?? 0 }; | |
| } | |
| async fetchRecent(conversationId, limit) { | |
| const rows = await this.prisma.conversationMessage.findMany({ | |
| where: { conversationId }, | |
| orderBy: { seq: "desc" }, | |
| take: limit, | |
| }); | |
| return rows | |
| .slice() | |
| .reverse() | |
| .map((m) => ({ | |
| id: m.id, | |
| userId: m.userId, | |
| conversationId: m.conversationId, | |
| body: m.body, | |
| eventType: m.eventType, | |
| metadata: m.metadata, | |
| seq: m.seq, | |
| at: m.createdAt.toISOString(), | |
| })); | |
| } | |
| async membersPayload(conversationId) { | |
| const conv = await this.prisma.conversation.findUnique({ | |
| where: { id: conversationId }, | |
| select: { members: true }, | |
| }); | |
| const members = {}; | |
| for (const m of conv?.members ?? []) { | |
| members[m.userId] = { role: m.role, lastReadSeq: m.lastReadSeq }; | |
| } | |
| return members; | |
| } | |
| parseLimit(raw) { | |
| if (raw === undefined || raw === "") | |
| return 50; | |
| const n = Number(raw); | |
| if (!Number.isFinite(n)) { | |
| throw new common_1.BadRequestException("limit must be a number"); | |
| } | |
| return Math.min(Math.max(Math.trunc(n), 1), 200); | |
| } | |
| }; | |
| exports.InternalRealtimeController = InternalRealtimeController; | |
| __decorate([ | |
| (0, common_1.Get)("conversations/:conversationId/state"), | |
| __param(0, (0, common_1.Param)("conversationId")), | |
| __param(1, (0, common_1.Query)("workspaceId")), | |
| __metadata("design:type", Function), | |
| __metadata("design:paramtypes", [String, String]), | |
| __metadata("design:returntype", Promise) | |
| ], InternalRealtimeController.prototype, "getState", null); | |
| __decorate([ | |
| (0, common_1.Post)("conversations/:conversationId/state"), | |
| __param(0, (0, common_1.Param)("conversationId")), | |
| __param(1, (0, common_1.Query)("workspaceId")), | |
| __metadata("design:type", Function), | |
| __metadata("design:paramtypes", [String, String]), | |
| __metadata("design:returntype", Promise) | |
| ], InternalRealtimeController.prototype, "postState", null); | |
| __decorate([ | |
| (0, common_1.Post)("conversations/:conversationId/events"), | |
| __param(0, (0, common_1.Param)("conversationId")), | |
| __param(1, (0, common_1.Body)()), | |
| __metadata("design:type", Function), | |
| __metadata("design:paramtypes", [String, Object]), | |
| __metadata("design:returntype", Promise) | |
| ], InternalRealtimeController.prototype, "postEvent", null); | |
| __decorate([ | |
| (0, common_1.Get)("conversations/:conversationId/recent"), | |
| __param(0, (0, common_1.Param)("conversationId")), | |
| __param(1, (0, common_1.Query)("limit")), | |
| __metadata("design:type", Function), | |
| __metadata("design:paramtypes", [String, String]), | |
| __metadata("design:returntype", Promise) | |
| ], InternalRealtimeController.prototype, "recent", null); | |
| __decorate([ | |
| (0, common_1.Post)("conversations/:conversationId/recent"), | |
| __param(0, (0, common_1.Param)("conversationId")), | |
| __param(1, (0, common_1.Body)()), | |
| __metadata("design:type", Function), | |
| __metadata("design:paramtypes", [String, Object]), | |
| __metadata("design:returntype", Promise) | |
| ], InternalRealtimeController.prototype, "recentPost", null); | |
| __decorate([ | |
| (0, common_1.Get)("conversations/:conversationId/members"), | |
| __param(0, (0, common_1.Param)("conversationId")), | |
| __metadata("design:type", Function), | |
| __metadata("design:paramtypes", [String]), | |
| __metadata("design:returntype", Promise) | |
| ], InternalRealtimeController.prototype, "getMembers", null); | |
| __decorate([ | |
| (0, common_1.Post)("conversations/:conversationId/members"), | |
| __param(0, (0, common_1.Param)("conversationId")), | |
| __param(1, (0, common_1.Body)()), | |
| __metadata("design:type", Function), | |
| __metadata("design:paramtypes", [String, Object]), | |
| __metadata("design:returntype", Promise) | |
| ], InternalRealtimeController.prototype, "addMember", null); | |
| __decorate([ | |
| (0, common_1.Get)("users/:userId/conversations"), | |
| __param(0, (0, common_1.Param)("userId")), | |
| __metadata("design:type", Function), | |
| __metadata("design:paramtypes", [String]), | |
| __metadata("design:returntype", Promise) | |
| ], InternalRealtimeController.prototype, "userConversations", null); | |
| __decorate([ | |
| (0, common_1.Get)("users/:userId"), | |
| __param(0, (0, common_1.Param)("userId")), | |
| __metadata("design:type", Function), | |
| __metadata("design:paramtypes", [String]), | |
| __metadata("design:returntype", Promise) | |
| ], InternalRealtimeController.prototype, "getUser", null); | |
| exports.InternalRealtimeController = InternalRealtimeController = InternalRealtimeController_1 = __decorate([ | |
| (0, common_1.Controller)("internal/realtime"), | |
| (0, common_1.UseGuards)(internal_token_guard_1.InternalTokenGuard), | |
| __metadata("design:paramtypes", [prisma_service_1.PrismaService, | |
| chat_service_1.ChatService]) | |
| ], InternalRealtimeController); | |
| //# sourceMappingURL=internal-realtime.controller.js.map |