Method handleRequest

src/runtime/adapters/ipc.ts:161–434

(request: IpcRequest)

  }

  private async handleRequest(request: IpcRequest): Promise<void> {
    if (!this.agent || !this.conversationService) {
      this.replyError(request.id, "IPC adapter is not ready yet");
      return;
    }

    try {
      switch (request.type) {
        case "get_conversations": {
          const activeChannels = new Set(this.agent.getActiveChannelIds());
          for (const channelId of this.createdChannels) {
            activeChannels.add(channelId);
          }
          const conversations = this.conversationService.listConversations(
            activeChannels,
            {
              includeDefaultWeb: true,
              includeLegacyWeb: false,
            },
          );
          this.reply(request.id, conversations);
          return;
        }

        case "create_conversation": {
          const channelId = DEFAULT_WEB_CHANNEL_ID;
          this.createdChannels.add(channelId);
          this.reply(request.id, { channelId });
          return;
        }

        case "get_messages": {
          if (!request.channelId || typeof request.channelId !== "string") {
            this.replyError(request.id, "channelId is required");
            return;
          }
          const messages = this.conversationService.getMessages(
            request.channelId,
            request.limit ?? 100,
          );
          this.reply(request.id, messages);
          return;
        }

        case "send_message": {
          if (!request.channelId || typeof request.channelId !== "string") {
            this.replyError(request.id, "channelId is required");
            return;
          }
          if (typeof request.text !== "string") {
            this.replyError(request.id, "text is required");
            return;
          }

          const platform = this.detectPlatform(request.channelId);
          const attachments = this.normalizeAttachments(request.attachments);
          this.createdChannels.add(request.channelId);