mcp-server.js

import http from "http";
import fs from "fs";
import path from "path";
import { randomUUID } from "crypto";
import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
import { StreamableHTTPServerTransport } from "@modelcontextprotocol/sdk/server/streamableHttp.js";
import { isInitializeRequest } from "@modelcontextprotocol/sdk/types.js";
import { z } from "zod";

import { loadConfig, validateConfig } from "./core/config.js";
import { createServices } from "./core/services.js";
import { resolveStoreDir } from "./core/store.js";
import { acquireOwnerLock } from "./store-lock.js";
import { startOwnerIpc } from "./core/owner-ipc.js";
import { createOwnerOperations } from "./core/owner-operations.js";
import { OwnerCoordinator } from "./core/owner-coordinator.js";
import { startShutdownWatchdog } from "./core/shutdown.js";
import { parseRequiredWaitSeconds } from "./core/retry.js";

const SERVICE_STATE_FILE = "service-state.json";

const storeDir = resolveStoreDir();
const { config, path: configPath } = loadConfig(storeDir);
const missingConfig = validateConfig(config ?? {});
if (missingConfig.length > 0) {
  console.error(`[startup] Missing tgcli configuration at ${configPath}. Run "tgcli auth".`);
  process.exit(1);
}
const mcpConfig = config?.mcp ?? {};
const mcpEnabled = Boolean(mcpConfig.enabled);
const resolvedHost = mcpConfig.host ?? process.env.MCP_HOST ?? process.env.FASTMCP_HOST ?? "127.0.0.1";
const resolvedPort = Number(mcpConfig.port ?? process.env.MCP_PORT ?? process.env.FASTMCP_PORT ?? "8080");
const HOST = resolvedHost;
const PORT = Number.isFinite(resolvedPort) && resolvedPort > 0 ? resolvedPort : 8080;
const ownerLock = acquireOwnerLock(storeDir, { kind: "server", state: "starting" });
let services;
try {
  services = createServices({ storeDir, config });
} catch (error) {
  ownerLock.release();
  throw error;
}
const { telegramClient, messageSyncService } = services;
const ownerCoordinator = new OwnerCoordinator();

let telegramReady = false;
let dialogRefreshDeferred = false;
let serviceState = null;

function readVersion() {
  try {
    const pkgPath = new URL("./package.json", import.meta.url);
    const pkg = JSON.parse(fs.readFileSync(pkgPath, "utf8"));
    return pkg.version || "0.0.0";
  } catch (error) {
    return "0.0.0";
  }
}

function writeServiceState(nextState) {
  if (!nextState) {
    return;
  }
  try {
    fs.mkdirSync(storeDir, { recursive: true });
    fs.writeFileSync(
      path.join(storeDir, SERVICE_STATE_FILE),
      `${JSON.stringify(nextState, null, 2)}\n`,
      "utf8",
    );
  } catch (error) {
    console.error(`[startup] Failed to write service state: ${error?.message ?? error}`);
  }
}

function updateServiceState(patch) {
  if (!serviceState) {
    return;
  }
  serviceState = {
    ...serviceState,
    ...patch,
    updatedAt: new Date().toISOString(),
  };
  writeServiceState(serviceState);
}

async function initializeTelegram() {
  if (telegramReady) return;

  console.log("[startup] Initializing Telegram dialogs...");
  const dialogsReady = await telegramClient.initializeDialogCache();

  if (!dialogsReady) {
    throw new Error("Failed to initialize Telegram dialog list");
  }

  const cachedDialogCount = messageSyncService.getChannelCount();
  if (cachedDialogCount > 0) {
    console.log(`[startup] Using ${cachedDialogCount} dialogs from the archive registry.`);
  } else {
    try {
      const dialogCount = await messageSyncService.refreshChannelsFromDialogs();
      console.log(`[startup] Seeded ${dialogCount} dialogs into archive registry.`);
    } catch (error) {
      const waitSeconds = parseRequiredWaitSeconds(error);
      if (waitSeconds === null) throw error;
      dialogRefreshDeferred = true;
      console.warn(`[startup] Dialog refresh deferred after Telegram rate limit (${waitSeconds}s). ` +
        'The existing archive and owner IPC remain available; run `tgcli sync --once` to retry later.');
    }
  }
  messageSyncService.startRealtimeSync();
  if (!dialogRefreshDeferred) messageSyncService.resumePendingJobs();
  telegramReady = true;
}

/**
 * Represents an active MCP session – a transport plus its server instance.
 */
const sessions = new Map();
let shuttingDown = false;

function closeSessionRecord(record, context) {
  if (!record || record.closing) {
    return null;
  }
  record.closing = true;
  if (record.sessionId) {
    sessions.delete(record.sessionId);
  }
  if (record.transport?.close) {
    return record.transport.close().catch((error) => {
      console.error(`[server] error closing ${context}: ${error.message}`);
    });
  }
  return null;
}

const listChannelsSchema = {
  limit: z.number().int().positive().optional().describe("Maximum number of channels to return (default: 50)"),
};

const searchChannelsSchema = {
  keywords: z
    .string()
    .min(1)
    .describe("Keywords to search for in channel titles or usernames"),
  limit: z.number().int().positive().optional().describe("Maximum number of results to return (default: 100)"),
};

const setChannelTagsSchema = {
  channelId: z
    .union([
      z.number({ invalid_type_error: "channelId must be a number" }),
      z.string({ invalid_type_error: "channelId must be a string" }).min(1),
    ])
    .describe("Numeric channel ID or username"),
  tags: z
    .array(z.string().min(1))
    .min(1)
    .describe("List of tags to attach to the channel"),
  source: z
    .string()
    .optional()
    .describe("Tag source label (default: manual)"),
};

const listChannelTagsSchema = {
  channelId: z
    .union([
      z.number({ invalid_type_error: "channelId must be a number" }),
      z.string({ invalid_type_error: "channelId must be a string" }).min(1),
    ])
    .describe("Numeric channel ID or username"),
  source: z
    .string()
    .optional()
    .describe("Optional tag source to filter by"),
};

const listTaggedChannelsSchema = {
  tag: z
    .string()
    .min(1)
    .describe("Tag label to look up"),
  source: z
    .string()
    .optional()
    .describe("Optional tag source to filter by"),
  limit: z.number().int().positive().optional().describe("Maximum number of channels to return (default: 100)"),
};

const refreshChannelMetadataSchema = {
  channelIds: z
    .array(
      z.union([
        z.number({ invalid_type_error: "channelId must be a number" }),
        z.string({ invalid_type_error: "channelId must be a string" }).min(1),
      ]),
    )
    .optional()
    .describe("Optional list of channel IDs/usernames to refresh"),
  limit: z.number().int().positive().optional().describe("Maximum number of channels to refresh (default: 20)"),
  force: z
    .boolean({ invalid_type_error: "force must be a boolean" })
    .optional()
    .describe("Refresh even if cached metadata is fresh"),
  onlyMissing: z
    .boolean({ invalid_type_error: "onlyMissing must be a boolean" })
    .optional()
    .describe("Refresh only channels without cached metadata"),
};

const getChannelMetadataSchema = {
  channelId: z
    .union([
      z.number({ invalid_type_error: "channelId must be a number" }),
      z.string({ invalid_type_error: "channelId must be a string" }).min(1),
    ])
    .describe("Numeric channel ID or username"),
};

const autoTagChannelsSchema = {
  channelIds: z
    .array(
      z.union([
        z.number({ invalid_type_error: "channelId must be a number" }),
        z.string({ invalid_type_error: "channelId must be a string" }).min(1),
      ]),
    )
    .optional()
    .describe("Optional list of channel IDs/usernames to tag"),
  limit: z.number().int().positive().optional().describe("Maximum number of channels to tag (default: 50)"),
  source: z
    .string()
    .optional()
    .describe("Tag source label (default: auto)"),
  refreshMetadata: z
    .boolean({ invalid_type_error: "refreshMetadata must be a boolean" })
    .optional()
    .describe("Refresh cached metadata before tagging (default true)"),
};

const scheduleMessageSyncSchema = {
  channelId: z
    .union([
      z.number({ invalid_type_error: "channelId must be a number" }),
      z.string({ invalid_type_error: "channelId must be a string" }).min(1),
    ])
    .describe("Numeric channel ID or username"),
  depth: z
    .number({ invalid_type_error: "depth must be a number" })
    .int()
    .positive()
    .max(50000)
    .optional()
    .describe("Maximum messages to retain per channel (default 1000)"),
  minDate: z
    .string({ invalid_type_error: "minDate must be a string" })
    .min(1)
    .optional()
    .describe("Earliest ISO-8601 timestamp to backfill (optional)"),
};

const topicsListSchema = {
  channelId: z
    .union([
      z.number({ invalid_type_error: "channelId must be a number" }),
      z.string({ invalid_type_error: "channelId must be a string" }).min(1),
    ])
  .describe("Numeric channel ID or username"),
  limit: z.number().int().positive().optional().describe("Maximum number of topics to return (default: 100)"),
};

const topicsSearchSchema = {
  channelId: z
    .union([
      z.number({ invalid_type_error: "channelId must be a number" }),
      z.string({ invalid_type_error: "channelId must be a string" }).min(1),
    ])
    .describe("Numeric channel ID or username"),
  query: z
    .string({ invalid_type_error: "query must be a string" })
    .min(1)
    .describe("Search query for forum topic titles"),
  limit: z.number().int().positive().optional().describe("Maximum number of topics to return (default: 100)"),
};

const folderIdOrNameSchema = {
  folder: z
    .union([
      z.number({ invalid_type_error: "folder must be a number" }),
      z.string({ invalid_type_error: "folder must be a string" }).min(1),
    ])
    .describe("Folder ID (numeric) or title (string)"),
};

const createFolderSchema = {
  title: z.string().min(1).max(12).describe("Folder name (max 12 chars)"),
  emoji: z.string().optional().describe("Emoji icon"),
  contacts: z.boolean().optional().describe("Include contacts"),
  nonContacts: z.boolean().optional().describe("Include non-contacts"),
  groups: z.boolean().optional().describe("Include groups"),
  broadcasts: z.boolean().optional().describe("Include channels/broadcasts"),
  bots: z.boolean().optional().describe("Include bots"),
  excludeMuted: z.boolean().optional().describe("Exclude muted chats"),
  excludeRead: z.boolean().optional().describe("Exclude read chats"),
  excludeArchived: z.boolean().optional().describe("Exclude archived chats"),
  includePeers: z.array(z.union([z.number(), z.string()])).optional().describe("Chat IDs to include"),
  excludePeers: z.array(z.union([z.number(), z.string()])).optional().describe("Chat IDs to exclude"),
  pinnedPeers: z.array(z.union([z.number(), z.string()])).optional().describe("Chat IDs to pin"),
};

const editFolderSchema = {
  folder: z
    .union([
      z.number({ invalid_type_error: "folder must be a number" }),
      z.string({ invalid_type_error: "folder must be a string" }).min(1),
    ])
    .describe("Folder ID (numeric) or title (string)"),
  title: z.string().min(1).max(12).optional().describe("New folder name"),
  emoji: z.string().optional().describe("Emoji icon"),
  contacts: z.boolean().optional().describe("Include contacts"),
  nonContacts: z.boolean().optional().describe("Include non-contacts"),
  groups: z.boolean().optional().describe("Include groups"),
  broadcasts: z.boolean().optional().describe("Include channels/broadcasts"),
  bots: z.boolean().optional().describe("Include bots"),
  excludeMuted: z.boolean().optional().describe("Exclude muted chats"),
  excludeRead: z.boolean().optional().describe("Exclude read chats"),
  excludeArchived: z.boolean().optional().describe("Exclude archived chats"),
  includePeers: z.array(z.union([z.number(), z.string()])).optional().describe("Chat IDs to include"),
  excludePeers: z.array(z.union([z.number(), z.string()])).optional().describe("Chat IDs to exclude"),
  pinnedPeers: z.array(z.union([z.number(), z.string()])).optional().describe("Chat IDs to pin"),
};

const reorderFoldersSchema = {
  ids: z.array(z.number().int()).min(1).describe("Folder IDs in desired order"),
};

const folderChatSchema = {
  folder: z
    .union([
      z.number({ invalid_type_error: "folder must be a number" }),
      z.string({ invalid_type_error: "folder must be a string" }).min(1),
    ])
    .describe("Folder ID (numeric) or title (string)"),
  chatId: z
    .union([
      z.number({ invalid_type_error: "chatId must be a number" }),
      z.string({ invalid_type_error: "chatId must be a string" }).min(1),
    ])
    .describe("Chat ID to add/remove"),
};

const joinChatlistSchema = {
  link: z.string().min(1).describe("Shared folder invite link"),
};

const messageSourceSchema = z
  .enum(["archive", "live", "both"])
  .optional()
  .describe("Message source (default: archive)");

const channelIdSchema = z.union([
  z.number({ invalid_type_error: "channelId must be a number" }),
  z.string({ invalid_type_error: "channelId must be a string" }).min(1),
]);

const userIdSchema = z.union([
  z.number({ invalid_type_error: "userId must be a number" }),
  z.string({ invalid_type_error: "userId must be a string" }).min(1),
]);

const messagesListSchema = {
  channelId: channelIdSchema.optional().describe("Optional numeric channel ID or username"),
  topicId: z
    .number({ invalid_type_error: "topicId must be a number" })
    .int()
    .positive()
    .optional()
    .describe("Optional forum topic ID"),
  source: messageSourceSchema,
  fromDate: z
    .string({ invalid_type_error: "fromDate must be a string" })
    .min(1)
    .optional()
    .describe("Earliest ISO-8601 timestamp to include (optional)"),
  toDate: z
    .string({ invalid_type_error: "toDate must be a string" })
    .min(1)
    .optional()
    .describe("Latest ISO-8601 timestamp to include (optional)"),
  limit: z.number().int().positive().optional().describe("Maximum number of messages to return (default: 50)"),
};

const messagesGetSchema = {
  channelId: channelIdSchema.describe("Numeric channel ID or username"),
  messageId: z
    .number({ invalid_type_error: "messageId must be a number" })
    .int()
    .positive()
    .describe("Message ID"),
  source: messageSourceSchema,
};

const messagesContextSchema = {
  channelId: channelIdSchema.describe("Numeric channel ID or username"),
  messageId: z
    .number({ invalid_type_error: "messageId must be a number" })
    .int()
    .positive()
    .describe("Message ID"),
  before: z
    .number({ invalid_type_error: "before must be a number" })
    .int()
    .min(0)
    .optional()
    .describe("Number of messages to include before the target (default: 20)"),
  after: z
    .number({ invalid_type_error: "after must be a number" })
    .int()
    .min(0)
    .optional()
    .describe("Number of messages to include after the target (default: 20)"),
  source: messageSourceSchema,
};

const messagesSearchSchema = {
  query: z.string().optional().describe("Optional full-text query (archive) or search text (live)"),
  regex: z.string().optional().describe("Optional regex filter for message text"),
  source: messageSourceSchema,
  channelIds: z
    .union([channelIdSchema, z.array(channelIdSchema).min(1)])
    .optional()
    .describe("Channel IDs or usernames to search (optional)"),
  channelId: channelIdSchema.optional().describe("Alias for channelIds"),
  tags: z.array(z.string().min(1)).optional().describe("Channel tags to filter by (optional)"),
  tag: z.string().optional().describe("Alias for tags"),
  topicId: z
    .number({ invalid_type_error: "topicId must be a number" })
    .int()
    .positive()
    .optional()
    .describe("Optional forum topic ID"),
  fromDate: z
    .string({ invalid_type_error: "fromDate must be a string" })
    .min(1)
    .optional()
    .describe("Earliest ISO-8601 timestamp to include (optional)"),
  toDate: z
    .string({ invalid_type_error: "toDate must be a string" })
    .min(1)
    .optional()
    .describe("Latest ISO-8601 timestamp to include (optional)"),
  limit: z.number().int().positive().optional().describe("Maximum number of matches to return (default: 100)"),
  caseInsensitive: z
    .boolean({ invalid_type_error: "caseInsensitive must be a boolean" })
    .optional()
    .describe("Whether regex matching should be case-insensitive (default: true)"),
};

const messagesSendSchema = {
  channelId: channelIdSchema.describe("Numeric channel ID or username"),
  text: z
    .string({ invalid_type_error: "text must be a string" })
    .min(1)
    .describe("Message text to send"),
  topicId: z
    .number({ invalid_type_error: "topicId must be a number" })
    .int()
    .positive()
    .optional()
    .describe("Optional forum topic ID to send into"),
  replyToMessageId: z
    .number({ invalid_type_error: "replyToMessageId must be a number" })
    .int()
    .positive()
    .optional()
    .describe("Optional message ID to reply to"),
  noPreview: z
    .boolean({ invalid_type_error: "noPreview must be a boolean" })
    .optional()
    .describe("Disable link preview in the message"),
  silent: z.boolean().optional().describe("Send without notification sound"),
  noForwards: z.boolean().optional().describe("Protect message from forwarding/saving"),
  schedule: z.string().datetime({ offset: true }).optional().describe("ISO 8601 datetime for scheduled delivery"),
};

const messagesSendFileSchema = {
  channelId: channelIdSchema.describe("Numeric channel ID or username"),
  filePath: z
    .string({ invalid_type_error: "filePath must be a string" })
    .min(1)
    .describe("Path to a local file to upload"),
  caption: z.string().optional().describe("Optional caption for the file"),
  filename: z.string().optional().describe("Override file name shown in Telegram"),
  topicId: z
    .number({ invalid_type_error: "topicId must be a number" })
    .int()
    .positive()
    .optional()
    .describe("Optional forum topic ID to send into"),
  replyToMessageId: z
    .number({ invalid_type_error: "replyToMessageId must be a number" })
    .int()
    .positive()
    .optional()
    .describe("Optional message ID to reply to"),
  silent: z.boolean().optional().describe("Send without notification sound"),
  noForwards: z.boolean().optional().describe("Protect message from forwarding/saving"),
  captionAbove: z.boolean().optional().describe("Show caption above media"),
  spoiler: z.boolean().optional().describe("Blur media until tapped"),
  schedule: z.string().datetime({ offset: true }).optional().describe("ISO 8601 datetime for scheduled delivery"),
  forceDocument: z.boolean().optional().describe("Send as uncompressed document"),
};

const mediaDownloadSchema = {
  channelId: channelIdSchema.describe("Numeric channel ID or username"),
  messageId: z
    .number({ invalid_type_error: "messageId must be a number" })
    .int()
    .positive()
    .describe("Message ID containing media"),
  outputPath: z
    .string()
    .min(1)
    .optional()
    .describe("Optional file path or directory for the download"),
};

const contactsSearchSchema = {
  query: z
    .string({ invalid_type_error: "query must be a string" })
    .min(1)
    .describe("Search query for contacts"),
  limit: z.number().int().positive().optional().describe("Maximum number of contacts to return (default: 50)"),
};

const contactsGetSchema = {
  userId: userIdSchema.describe("User ID or username"),
};

const contactsAliasSetSchema = {
  userId: userIdSchema.describe("User ID or username"),
  alias: z
    .string({ invalid_type_error: "alias must be a string" })
    .min(1)
    .describe("Alias for the contact"),
};

const contactsAliasRemoveSchema = {
  userId: userIdSchema.describe("User ID or username"),
};

const contactsTagsAddSchema = {
  userId: userIdSchema.describe("User ID or username"),
  tags: z.array(z.string().min(1)).min(1).describe("Tags to add"),
};

const contactsTagsRemoveSchema = {
  userId: userIdSchema.describe("User ID or username"),
  tags: z.array(z.string().min(1)).min(1).describe("Tags to remove"),
};

const contactsNotesSetSchema = {
  userId: userIdSchema.describe("User ID or username"),
  notes: z
    .string({ invalid_type_error: "notes must be a string" })
    .describe("Notes to attach to the contact"),
};

const groupsListSchema = {
  query: z.string().optional().describe("Optional search query for group titles"),
  limit: z.number().int().positive().optional().describe("Maximum number of groups to return (default: 100)"),
};

const groupsInfoSchema = {
  channelId: channelIdSchema.describe("Group ID or username"),
};

const groupsRenameSchema = {
  channelId: channelIdSchema.describe("Group ID or username"),
  name: z
    .string({ invalid_type_error: "name must be a string" })
    .min(1)
    .describe("New group title"),
};

const groupsMembersAddSchema = {
  channelId: channelIdSchema.describe("Group ID or username"),
  userIds: z
    .array(userIdSchema)
    .min(1)
    .describe("User IDs or usernames to add"),
};

const groupsMembersRemoveSchema = {
  channelId: channelIdSchema.describe("Group ID or username"),
  userIds: z
    .array(userIdSchema)
    .min(1)
    .describe("User IDs or usernames to remove"),
};

const groupsInviteLinkGetSchema = {
  channelId: channelIdSchema.describe("Group ID or username"),
};

const groupsInviteLinkRevokeSchema = {
  channelId: channelIdSchema.describe("Group ID or username"),
};

const groupsJoinSchema = {
  invite: z
    .string({ invalid_type_error: "invite must be a string" })
    .min(1)
    .describe("Invite link or code"),
};

const groupsLeaveSchema = {
  channelId: channelIdSchema.describe("Group ID or username"),
};

function resolveSource(source) {
  const resolved = source ? String(source).toLowerCase() : "archive";
  if (!["archive", "live", "both"].includes(resolved)) {
    throw new Error(`Invalid source: ${source}`);
  }
  return resolved;
}

function resolveChannelIds(channelIds, channelId) {
  const resolved = [];
  if (Array.isArray(channelIds)) {
    resolved.push(...channelIds);
  } else if (channelIds) {
    resolved.push(channelIds);
  }
  if (channelId) {
    resolved.push(channelId);
  }
  const filtered = resolved.filter((id) => id !== null && id !== undefined && String(id).trim() !== "");
  return filtered.length ? filtered : null;
}

function parseDateMs(value, label) {
  if (!value) return null;
  const ts = Date.parse(value);
  if (Number.isNaN(ts)) {
    throw new Error(`${label} must be a valid ISO-8601 string`);
  }
  return ts;
}

function filterLiveMessagesByDate(messages, fromDate, toDate) {
  const fromMs = parseDateMs(fromDate, "fromDate");
  const toMs = parseDateMs(toDate, "toDate");
  if (!fromMs && !toMs) {
    return messages;
  }
  return messages.filter((message) => {
    const ts = typeof message.date === "number" ? message.date * 1000 : null;
    if (!ts) {
      return false;
    }
    if (fromMs && ts < fromMs) {
      return false;
    }
    if (toMs && ts > toMs) {
      return false;
    }
    return true;
  });
}

function formatLiveMessage(message, context) {
  const dateIso = message.date ? new Date(message.date * 1000).toISOString() : null;
  return {
    channelId: context.channelId ?? message.peer_id ?? null,
    peerTitle: context.peerTitle ?? null,
    username: context.username ?? null,
    messageId: message.id,
    date: dateIso,
    fromId: message.from_id ?? null,
    fromUsername: message.from_username ?? null,
    fromDisplayName: message.from_display_name ?? null,
    fromPeerType: message.from_peer_type ?? null,
    fromIsBot: typeof message.from_is_bot === "boolean" ? message.from_is_bot : null,
    text: message.text ?? message.message ?? "",
    media: message.media ?? null,
    topicId: message.topic_id ?? null,
  };
}

function formatInviteLink(link) {
  if (!link) {
    return null;
  }
  return {
    link: link.link ?? null,
    isPrimary: typeof link.isPrimary === "boolean" ? link.isPrimary : null,
    isRevoked: typeof link.isRevoked === "boolean" ? link.isRevoked : null,
    createdAt: link.date ? link.date.toISOString() : null,
    startDate: link.startDate ? link.startDate.toISOString() : null,
    endDate: link.endDate ? link.endDate.toISOString() : null,
    usageLimit: typeof link.usageLimit === "number" ? link.usageLimit : null,
    usage: typeof link.usage === "number" ? link.usage : null,
    approvalNeeded: typeof link.approvalNeeded === "boolean" ? link.approvalNeeded : null,
    pendingApprovals: typeof link.pendingApprovals === "number" ? link.pendingApprovals : null,
  };
}

function messageDateMs(message) {
  const ts = Date.parse(message.date ?? "");
  return Number.isNaN(ts) ? 0 : ts;
}

function mergeMessageSets(sets, limit) {
  const map = new Map();
  for (const list of sets) {
    for (const message of list) {
      const channelId = message.channelId ?? "";
      const messageId = message.messageId ?? message.id;
      const key = `${String(channelId)}:${String(messageId)}`;
      if (!map.has(key) || message.source === "live") {
        map.set(key, message);
      }
    }
  }
  const merged = Array.from(map.values());
  merged.sort((a, b) => messageDateMs(b) - messageDateMs(a));
  return limit && limit > 0 ? merged.slice(0, limit) : merged;
}

function createServerInstance() {
  const server = new McpServer({
    name: "example-mcp-server",
    version: "1.0.0",
  });

  const archiveOnlyTools = new Set([
    "listActiveChannels", "listChannelTags", "listTaggedChannels",
    "getSyncedMessageStats", "listMessageSyncJobs",
  ]);
  const registerTool = (name, description, schema, handler) => server.tool(
    name, description, schema,
    (...args) => {
      if (archiveOnlyTools.has(name)) return handler(...args);
      const callerSignal = args.at(-1)?.signal;
      const timeout = AbortSignal.timeout(30000);
      const signal = callerSignal ? AbortSignal.any([timeout, callerSignal]) : timeout;
      return ownerCoordinator.runLive(() => handler(...args), { signal });
    },
  );

  registerTool(
    "listChannels",
    "Lists available Telegram dialogs for the authenticated account.",
    listChannelsSchema,
    async ({ limit }) => {
      await telegramClient.ensureLogin();
      const dialogs = await telegramClient.listDialogs(limit ?? 50);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(dialogs, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "searchChannels",
    "Searches dialogs by title or username.",
    searchChannelsSchema,
    async ({ keywords, limit }) => {
      await telegramClient.ensureLogin();
      const matches = await telegramClient.searchDialogs(keywords, limit ?? 100);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(matches, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "listActiveChannels",
    "Lists dialogs tracked in the local archive registry.",
    {},
    async () => {
      const channels = messageSyncService.listActiveChannels();

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(channels, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "setChannelTags",
    "Assign tags to a channel for later cross-channel search.",
    setChannelTagsSchema,
    async ({ channelId, tags, source }) => {
      const finalTags = messageSyncService.setChannelTags(channelId, tags, { source });

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify({ channelId, tags: finalTags }, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "listChannelTags",
    "List tags attached to a channel.",
    listChannelTagsSchema,
    async ({ channelId, source }) => {
      const tags = messageSyncService.listChannelTags(channelId, { source });

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(tags, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "listTaggedChannels",
    "List channels that carry a specific tag.",
    listTaggedChannelsSchema,
    async ({ tag, source, limit }) => {
      const channels = messageSyncService.listTaggedChannels(tag, { source, limit });

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(channels, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "refreshChannelMetadata",
    "Fetches and caches extended metadata for channels.",
    refreshChannelMetadataSchema,
    async ({ channelIds, limit, force, onlyMissing }) => {
      await telegramClient.ensureLogin();
      const results = await messageSyncService.refreshChannelMetadata({
        channelIds,
        limit,
        force,
        onlyMissing,
      });

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(results, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "getChannelMetadata",
    "Returns cached metadata for a channel.",
    getChannelMetadataSchema,
    async ({ channelId }) => {
      const metadata = messageSyncService.getChannelMetadata(channelId);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(metadata, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "autoTagChannels",
    "Auto-tags channels based on title, username, and cached metadata.",
    autoTagChannelsSchema,
    async ({ channelIds, limit, source, refreshMetadata }) => {
      await telegramClient.ensureLogin();
      const results = await messageSyncService.autoTagChannels({
        channelIds,
        limit,
        source,
        refreshMetadata,
      });

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(results, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "topicsList",
    "Lists forum topics for a supergroup.",
    topicsListSchema,
    async ({ channelId, limit }) => {
      await telegramClient.ensureLogin();
      const topics = await telegramClient.listForumTopics(channelId, { limit: limit ?? 100 });
      messageSyncService.upsertTopics(channelId, topics);

      const formatted = topics.map((topic) => {
        let lastMessage = null;
        try {
          const msg = topic.lastMessage;
          lastMessage = {
            id: msg.id,
            date: msg.date ? msg.date.toISOString() : null,
            text: msg.text ?? msg.message ?? "",
          };
        } catch (error) {
          lastMessage = null;
        }

        return {
          id: topic.id,
          title: topic.title,
          date: topic.date ? topic.date.toISOString() : null,
          isClosed: topic.isClosed,
          isPinned: topic.isPinned,
          unreadCount: topic.unreadCount,
          lastMessage,
        };
      });

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(
              {
                total: topics.total ?? formatted.length,
                returned: formatted.length,
                topics: formatted,
              },
              null,
              2,
            ),
          },
        ],
      };
    },
  );

  registerTool(
    "topicsSearch",
    "Searches forum topics by title.",
    topicsSearchSchema,
    async ({ channelId, query, limit }) => {
      await telegramClient.ensureLogin();
      const topics = await telegramClient.listForumTopics(channelId, { query, limit: limit ?? 100 });
      messageSyncService.upsertTopics(channelId, topics);

      const formatted = topics.map((topic) => ({
        id: topic.id,
        title: topic.title,
        date: topic.date ? topic.date.toISOString() : null,
        isClosed: topic.isClosed,
        isPinned: topic.isPinned,
        unreadCount: topic.unreadCount,
      }));

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(
              {
                total: topics.total ?? formatted.length,
                returned: formatted.length,
                topics: formatted,
              },
              null,
              2,
            ),
          },
        ],
      };
    },
  );

  registerTool(
    "messagesList",
    "Lists messages from the archive or live Telegram API.",
    messagesListSchema,
    async ({ channelId, topicId, source, fromDate, toDate, limit }) => {
      const resolvedSource = resolveSource(source);
      const finalLimit = limit ?? 50;
      const sets = [];

      if (resolvedSource === "archive" || resolvedSource === "both") {
        const archived = messageSyncService.listArchivedMessages({
          channelIds: channelId ? [channelId] : null,
          topicId,
          fromDate,
          toDate,
          limit: finalLimit,
        });
        sets.push(archived.map((message) => ({ ...message, source: "archive" })));
      }

      if (resolvedSource === "live" || resolvedSource === "both") {
        if (!channelId) {
          throw new Error("channelId is required for live source.");
        }
        await telegramClient.ensureLogin();
        const channelMeta = messageSyncService.getChannelMetadata(channelId);
        let peerTitle = channelMeta?.peerTitle ?? null;
        let username = channelMeta?.username ?? null;
        let peerId = channelMeta?.channelId ?? String(channelId);
        let liveMessages = [];

        if (topicId) {
          const results = await telegramClient.getTopicMessages(channelId, topicId, finalLimit);
          liveMessages = results.messages;
          if (!peerTitle || !username) {
            const meta = await telegramClient.getPeerMetadata(channelId);
            peerTitle = peerTitle ?? meta?.peerTitle ?? null;
            username = username ?? meta?.username ?? null;
          }
        } else {
          const results = await telegramClient.getMessagesByChannelId(channelId, finalLimit);
          liveMessages = results.messages;
          peerTitle = peerTitle ?? results.peerTitle ?? null;
          peerId = results.peerId ?? peerId;
        }

        const filtered = filterLiveMessagesByDate(liveMessages, fromDate, toDate);
        const formatted = filtered.map((message) => ({
          ...formatLiveMessage(message, { channelId: peerId, peerTitle, username }),
          source: "live",
        }));
        sets.push(formatted);
      }

      const messages = resolvedSource === "both"
        ? mergeMessageSets(sets, finalLimit)
        : (sets[0] ?? []);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(
              {
                source: resolvedSource,
                returned: messages.length,
                messages,
              },
              null,
              2,
            ),
          },
        ],
      };
    },
  );

  registerTool(
    "messagesGet",
    "Fetches a specific message from the archive or live Telegram API.",
    messagesGetSchema,
    async ({ channelId, messageId, source }) => {
      const resolvedSource = resolveSource(source);
      const channelMeta = messageSyncService.getChannelMetadata(channelId);
      let message = null;
      let resolvedFrom = null;

      if (resolvedSource === "live" || resolvedSource === "both") {
        await telegramClient.ensureLogin();
        const live = await telegramClient.getMessageById(channelId, messageId);
        if (live) {
          let peerTitle = channelMeta?.peerTitle ?? null;
          let username = channelMeta?.username ?? null;
          if (!peerTitle || !username) {
            const meta = await telegramClient.getPeerMetadata(channelId);
            peerTitle = peerTitle ?? meta?.peerTitle ?? null;
            username = username ?? meta?.username ?? null;
          }
          message = {
            ...formatLiveMessage(live, { channelId: String(channelId), peerTitle, username }),
            source: "live",
          };
          resolvedFrom = "live";
        }
      }

      if (!message && (resolvedSource === "archive" || resolvedSource === "both")) {
        const archived = messageSyncService.getArchivedMessage({ channelId, messageId });
        if (archived) {
          message = { ...archived, source: "archive" };
          resolvedFrom = "archive";
        }
      }

      if (!message) {
        throw new Error("Message not found.");
      }

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(
              {
                source: resolvedFrom ?? resolvedSource,
                message,
              },
              null,
              2,
            ),
          },
        ],
      };
    },
  );

  registerTool(
    "messagesContext",
    "Returns surrounding messages for a target message.",
    messagesContextSchema,
    async ({ channelId, messageId, before, after, source }) => {
      const resolvedSource = resolveSource(source);
      const safeBefore = Number.isFinite(before) ? before : 20;
      const safeAfter = Number.isFinite(after) ? after : 20;
      const channelMeta = messageSyncService.getChannelMetadata(channelId);
      let context = null;
      let resolvedFrom = null;

      if (resolvedSource === "live" || resolvedSource === "both") {
        await telegramClient.ensureLogin();
        const liveContext = await telegramClient.getMessageContext(channelId, messageId, {
          before: safeBefore,
          after: safeAfter,
        });
        if (liveContext.target) {
          let peerTitle = channelMeta?.peerTitle ?? null;
          let username = channelMeta?.username ?? null;
          if (!peerTitle || !username) {
            const meta = await telegramClient.getPeerMetadata(channelId);
            peerTitle = peerTitle ?? meta?.peerTitle ?? null;
            username = username ?? meta?.username ?? null;
          }
          context = {
            target: {
              ...formatLiveMessage(liveContext.target, { channelId: String(channelId), peerTitle, username }),
              source: "live",
            },
            before: liveContext.before.map((message) => ({
              ...formatLiveMessage(message, { channelId: String(channelId), peerTitle, username }),
              source: "live",
            })),
            after: liveContext.after.map((message) => ({
              ...formatLiveMessage(message, { channelId: String(channelId), peerTitle, username }),
              source: "live",
            })),
          };
          resolvedFrom = "live";
        }
      }

      if (!context && (resolvedSource === "archive" || resolvedSource === "both")) {
        const archiveContext = messageSyncService.getArchivedMessageContext({
          channelId,
          messageId,
          before: safeBefore,
          after: safeAfter,
        });
        if (archiveContext.target) {
          context = {
            target: { ...archiveContext.target, source: "archive" },
            before: archiveContext.before.map((message) => ({ ...message, source: "archive" })),
            after: archiveContext.after.map((message) => ({ ...message, source: "archive" })),
          };
          resolvedFrom = "archive";
        }
      }

      if (!context) {
        throw new Error("Message not found.");
      }

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(
              {
                source: resolvedFrom ?? resolvedSource,
                ...context,
              },
              null,
              2,
            ),
          },
        ],
      };
    },
  );

  registerTool(
    "messagesSearch",
    "Searches messages across the archive or live Telegram API.",
    messagesSearchSchema,
    async ({
      query,
      regex,
      source,
      channelIds,
      channelId,
      tags,
      tag,
      topicId,
      fromDate,
      toDate,
      limit,
      caseInsensitive,
    }) => {
      const resolvedSource = resolveSource(source);
      const finalLimit = limit ?? 100;
      const resolvedTags = Array.isArray(tags) ? tags : (tag ? [tag] : null);
      const resolvedChannelIds = resolveChannelIds(channelIds, channelId);

      if (!query && !regex && (!resolvedTags || resolvedTags.length === 0)) {
        throw new Error("Provide query, regex, or tags for messagesSearch.");
      }

      const sets = [];

      if (resolvedSource === "archive" || resolvedSource === "both") {
        const archived = messageSyncService.searchArchiveMessages({
          query,
          regex,
          tags: resolvedTags,
          channelIds: resolvedChannelIds,
          topicId,
          fromDate,
          toDate,
          limit: finalLimit,
          caseInsensitive,
        });
        sets.push(archived.map((message) => ({ ...message, source: "archive" })));
      }

      if (resolvedSource === "live" || resolvedSource === "both") {
        let liveChannelIds = resolvedChannelIds;
        if ((!liveChannelIds || liveChannelIds.length === 0) && resolvedTags?.length) {
          const tagged = new Map();
          for (const tagValue of resolvedTags) {
            const channels = messageSyncService.listTaggedChannels(tagValue, { limit: 200 });
            for (const channel of channels) {
              tagged.set(channel.channelId, channel);
            }
          }
          liveChannelIds = Array.from(tagged.keys());
        }

        if (!liveChannelIds || liveChannelIds.length === 0) {
          throw new Error("channelIds are required for live search.");
        }

        let liveRegex = null;
        if (regex) {
          try {
            liveRegex = new RegExp(regex, caseInsensitive === false ? "" : "i");
          } catch (error) {
            throw new Error(`Invalid regex: ${error.message}`);
          }
        }

        await telegramClient.ensureLogin();
        const liveResults = [];

        for (const id of liveChannelIds) {
          const channelMeta = messageSyncService.getChannelMetadata(id);
          let peerTitle = channelMeta?.peerTitle ?? null;
          let username = channelMeta?.username ?? null;
          let liveMessages = [];

          if (query) {
            const results = await telegramClient.searchChannelMessages(id, {
              query,
              limit: finalLimit,
              topicId,
            });
            liveMessages = results.messages;
            peerTitle = peerTitle ?? results.peerTitle ?? null;
          } else if (topicId) {
            const results = await telegramClient.getTopicMessages(id, topicId, finalLimit);
            liveMessages = results.messages;
          } else {
            const results = await telegramClient.getMessagesByChannelId(id, finalLimit);
            liveMessages = results.messages;
            peerTitle = peerTitle ?? results.peerTitle ?? null;
          }

          if (!peerTitle || !username) {
            const meta = await telegramClient.getPeerMetadata(id);
            peerTitle = peerTitle ?? meta?.peerTitle ?? null;
            username = username ?? meta?.username ?? null;
          }

          let filtered = filterLiveMessagesByDate(liveMessages, fromDate, toDate);
          if (liveRegex) {
            filtered = filtered.filter((message) =>
              liveRegex.test(message.text ?? message.message ?? ""),
            );
          }

          const formatted = filtered.map((message) => ({
            ...formatLiveMessage(message, { channelId: String(id), peerTitle, username }),
            source: "live",
          }));
          liveResults.push(...formatted);
        }

        sets.push(liveResults);
      }

      const messages = resolvedSource === "both"
        ? mergeMessageSets(sets, finalLimit)
        : (sets[0] ?? []);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(
              {
                source: resolvedSource,
                returned: messages.length,
                messages,
              },
              null,
              2,
            ),
          },
        ],
      };
    },
  );

  registerTool(
    "messagesSend",
    "Sends a text message to a channel or chat.",
    messagesSendSchema,
    async ({ channelId, text, topicId, replyToMessageId, noPreview, silent, noForwards, schedule }) => {
      await telegramClient.ensureLogin();
      const result = await telegramClient.sendTextMessage(channelId, text, {
        topicId,
        replyToMessageId,
        noPreview,
        silent,
        noForwards,
        schedule,
      });

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify({ channelId, ...result }, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "messagesSendFile",
    "Sends a file with an optional caption.",
    messagesSendFileSchema,
    async ({ channelId, filePath, caption, filename, topicId, replyToMessageId, silent, noForwards, captionAbove, spoiler, schedule, forceDocument }) => {
      await telegramClient.ensureLogin();
      const result = await telegramClient.sendFileMessage(channelId, filePath, {
        caption,
        filename,
        topicId,
        replyToMessageId,
        silent,
        noForwards,
        captionAbove,
        spoiler,
        schedule,
        forceDocument,
      });

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify({ channelId, ...result }, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "mediaDownload",
    "Downloads media from a message to a local file.",
    mediaDownloadSchema,
    async ({ channelId, messageId, outputPath }) => {
      await telegramClient.ensureLogin();
      const result = await telegramClient.downloadMessageMedia(channelId, messageId, {
        outputPath,
      });

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(result, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "contactsSearch",
    "Searches contacts/users with aliases, tags, and notes.",
    contactsSearchSchema,
    async ({ query, limit }) => {
      await telegramClient.ensureLogin();
      await messageSyncService.refreshContacts();
      const contacts = messageSyncService.searchContacts(query, { limit });

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(contacts, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "contactsGet",
    "Returns a contact profile from the local store.",
    contactsGetSchema,
    async ({ userId }) => {
      let contact = messageSyncService.getContact(userId);
      if (!contact) {
        await telegramClient.ensureLogin();
        await messageSyncService.refreshContacts();
        contact = messageSyncService.getContact(userId);
      }

      if (!contact) {
        throw new Error("Contact not found.");
      }

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(contact, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "contactsAliasSet",
    "Sets an alias for a contact.",
    contactsAliasSetSchema,
    async ({ userId, alias }) => {
      const value = messageSyncService.setContactAlias(userId, alias);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify({ userId, alias: value }, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "contactsAliasRemove",
    "Removes alias for a contact.",
    contactsAliasRemoveSchema,
    async ({ userId }) => {
      messageSyncService.removeContactAlias(userId);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify({ userId, removed: true }, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "contactsTagsAdd",
    "Adds tags to a contact.",
    contactsTagsAddSchema,
    async ({ userId, tags }) => {
      const updated = messageSyncService.addContactTags(userId, tags);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify({ userId, tags: updated }, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "contactsTagsRemove",
    "Removes tags from a contact.",
    contactsTagsRemoveSchema,
    async ({ userId, tags }) => {
      const updated = messageSyncService.removeContactTags(userId, tags);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify({ userId, tags: updated }, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "contactsNotesSet",
    "Sets notes for a contact.",
    contactsNotesSetSchema,
    async ({ userId, notes }) => {
      const updated = messageSyncService.setContactNotes(userId, notes);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify({ userId, notes: updated }, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "groupsList",
    "Lists group chats and supergroups.",
    groupsListSchema,
    async ({ query, limit }) => {
      await telegramClient.ensureLogin();
      const groups = await telegramClient.listGroups({ query, limit });

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(groups, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "groupsInfo",
    "Fetches group information and metadata.",
    groupsInfoSchema,
    async ({ channelId }) => {
      await telegramClient.ensureLogin();
      const info = await telegramClient.getGroupInfo(channelId);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(info, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "groupsRename",
    "Renames a group chat or supergroup.",
    groupsRenameSchema,
    async ({ channelId, name }) => {
      await telegramClient.ensureLogin();
      await telegramClient.renameGroup(channelId, name);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify({ channelId, name }, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "groupsMembersAdd",
    "Adds members to a group.",
    groupsMembersAddSchema,
    async ({ channelId, userIds }) => {
      await telegramClient.ensureLogin();
      const failed = await telegramClient.addGroupMembers(channelId, userIds);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify({ channelId, failed }, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "groupsMembersRemove",
    "Removes members from a group.",
    groupsMembersRemoveSchema,
    async ({ channelId, userIds }) => {
      await telegramClient.ensureLogin();
      const result = await telegramClient.removeGroupMembers(channelId, userIds);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify({ channelId, ...result }, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "groupsInviteLinkGet",
    "Gets the primary invite link for a group.",
    groupsInviteLinkGetSchema,
    async ({ channelId }) => {
      await telegramClient.ensureLogin();
      const link = await telegramClient.getGroupInviteLink(channelId);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(formatInviteLink(link), null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "groupsInviteLinkRevoke",
    "Revokes the primary invite link for a group.",
    groupsInviteLinkRevokeSchema,
    async ({ channelId }) => {
      await telegramClient.ensureLogin();
      const existing = await telegramClient.getGroupInviteLink(channelId);
      const link = await telegramClient.revokeGroupInviteLink(channelId, existing);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(formatInviteLink(link), null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "groupsJoin",
    "Joins a group using an invite link or code.",
    groupsJoinSchema,
    async ({ invite }) => {
      await telegramClient.ensureLogin();
      const chat = await telegramClient.joinGroup(invite);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(
              {
                id: chat.id?.toString?.() ?? null,
                title: chat.displayName || chat.title || "Unknown",
                username: chat.username ?? null,
                chatType: typeof chat.chatType === "string" ? chat.chatType : null,
              },
              null,
              2,
            ),
          },
        ],
      };
    },
  );

  registerTool(
    "groupsLeave",
    "Leaves a group chat or channel.",
    groupsLeaveSchema,
    async ({ channelId }) => {
      await telegramClient.ensureLogin();
      await telegramClient.leaveGroup(channelId);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify({ channelId, left: true }, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "scheduleMessageSync",
    "Schedules a background job to archive channel messages locally.",
    scheduleMessageSyncSchema,
    async ({ channelId, depth, minDate }) => {
      await telegramClient.ensureLogin();
      const job = messageSyncService.addJob(channelId, { depth, minDate });
      void messageSyncService.processQueue();

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(job, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "getSyncedMessageStats",
    "Returns summary statistics for stored messages in a channel.",
    {
      channelId: z
        .union([
          z.number({ invalid_type_error: "channelId must be a number" }),
          z.string({ invalid_type_error: "channelId must be a string" }).min(1),
        ])
        .describe("Numeric channel ID or username"),
    },
    async ({ channelId }) => {
      const stats = messageSyncService.getMessageStats(channelId);

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(stats, null, 2),
          },
        ],
      };
    },
  );

  registerTool(
    "listMessageSyncJobs",
    "Lists tracked message sync jobs and their current status.",
    {},
    async () => {
      const jobs = messageSyncService.listJobs();

      return {
        content: [
          {
            type: "text",
            text: JSON.stringify(jobs, null, 2),
          },
        ],
      };
    },
  );

  // --- Folder tools ---

  registerTool(
    "listFolders",
    "Lists all Telegram chat folders for the authenticated account.",
    {},
    async () => {
      await telegramClient.ensureLogin();
      const folders = await telegramClient.getFolders();
      return {
        content: [{ type: "text", text: JSON.stringify(folders, null, 2) }],
      };
    },
  );

  registerTool(
    "showFolder",
    "Shows detailed information about a specific chat folder.",
    folderIdOrNameSchema,
    async ({ folder }) => {
      await telegramClient.ensureLogin();
      const info = await telegramClient.showFolder(folder);
      return {
        content: [{ type: "text", text: JSON.stringify(info, null, 2) }],
      };
    },
  );

  registerTool(
    "createFolder",
    "Creates a new Telegram chat folder with specified filters and peers.",
    createFolderSchema,
    async (params) => {
      await telegramClient.ensureLogin();
      const result = await telegramClient.createFolder(params);
      return {
        content: [{ type: "text", text: JSON.stringify(result, null, 2) }],
      };
    },
  );

  registerTool(
    "editFolder",
    "Edits an existing Telegram chat folder.",
    editFolderSchema,
    async ({ folder, ...modification }) => {
      await telegramClient.ensureLogin();
      const result = await telegramClient.editFolder(folder, modification);
      return {
        content: [{ type: "text", text: JSON.stringify(result, null, 2) }],
      };
    },
  );

  registerTool(
    "deleteFolder",
    "Deletes a Telegram chat folder.",
    folderIdOrNameSchema,
    async ({ folder }) => {
      await telegramClient.ensureLogin();
      const result = await telegramClient.deleteFolder(folder);
      return {
        content: [{ type: "text", text: JSON.stringify(result, null, 2) }],
      };
    },
  );

  registerTool(
    "reorderFolders",
    "Reorders Telegram chat folders.",
    reorderFoldersSchema,
    async ({ ids }) => {
      await telegramClient.ensureLogin();
      const result = await telegramClient.setFoldersOrder(ids);
      return {
        content: [{ type: "text", text: JSON.stringify(result, null, 2) }],
      };
    },
  );

  registerTool(
    "addChatToFolder",
    "Adds a chat to a Telegram chat folder.",
    folderChatSchema,
    async ({ folder, chatId }) => {
      await telegramClient.ensureLogin();
      const result = await telegramClient.addChatToFolder(folder, chatId);
      return {
        content: [{ type: "text", text: JSON.stringify(result, null, 2) }],
      };
    },
  );

  registerTool(
    "removeChatFromFolder",
    "Removes a chat from a Telegram chat folder.",
    folderChatSchema,
    async ({ folder, chatId }) => {
      await telegramClient.ensureLogin();
      const result = await telegramClient.removeChatFromFolder(folder, chatId);
      return {
        content: [{ type: "text", text: JSON.stringify(result, null, 2) }],
      };
    },
  );

  registerTool(
    "joinChatlist",
    "Joins a shared Telegram chat folder via invite link.",
    joinChatlistSchema,
    async ({ link }) => {
      await telegramClient.ensureLogin();
      const result = await telegramClient.joinChatlist(link);
      return {
        content: [{ type: "text", text: JSON.stringify(result, null, 2) }],
      };
    },
  );

  return server;
}

async function ensureSession(req, res, body) {
  if (shuttingDown) {
    res.writeHead(503, { "Content-Type": "application/json" }).end(
      JSON.stringify({
        jsonrpc: "2.0",
        error: {
          code: -32000,
          message: "Server is shutting down",
        },
        id: null,
      }),
    );
    return null;
  }

  const sessionId = req.headers["mcp-session-id"];

  if (sessionId && typeof sessionId === "string") {
    const existing = sessions.get(sessionId);
    if (existing) {
      return existing;
    }

    res.writeHead(404, { "Content-Type": "application/json" }).end(
      JSON.stringify({
        jsonrpc: "2.0",
        error: {
          code: -32001,
          message: "Session not found",
        },
        id: null,
      }),
    );
    return null;
  }

  if (!isInitializeRequest(body)) {
    res.writeHead(400, { "Content-Type": "application/json" }).end(
      JSON.stringify({
        jsonrpc: "2.0",
        error: {
          code: -32000,
          message: "Bad Request: No valid session ID provided",
        },
        id: null,
      }),
    );
    return null;
  }

  const record = { server: null, transport: null, sessionId: null };

  const transport = new StreamableHTTPServerTransport({
    sessionIdGenerator: () => randomUUID(),
    onsessioninitialized: (sessionId) => {
      record.sessionId = sessionId;
      sessions.set(sessionId, record);
    },
    onsessionclosed: (sessionId) => {
      const existing = sessions.get(sessionId);
      if (existing) {
        existing.closing = true;
        sessions.delete(sessionId);
      }
    },
  });

  record.transport = transport;

  transport.onerror = (error) => {
    console.error(`[transport] error: ${error.message}`);
  };

  transport.onclose = () => {
    if (record.sessionId) {
      sessions.delete(record.sessionId);
    }
  };

  const serverInstance = createServerInstance();
  record.server = serverInstance;

  await serverInstance.connect(transport);

  return record;
}

function readBody(req) {
  return new Promise((resolve, reject) => {
    const chunks = [];
    req
      .on("data", (chunk) => chunks.push(chunk))
      .on("end", () => {
        try {
          const raw = Buffer.concat(chunks).toString("utf8");
          resolve(raw.length ? JSON.parse(raw) : {});
        } catch (error) {
          reject(error);
        }
      })
      .on("error", (error) => reject(error));
  });
}

async function handlePost(req, res) {
  const body = await readBody(req);
  const sessionRecord = await ensureSession(req, res, body);
  if (!sessionRecord) {
    return;
  }

  try {
    await sessionRecord.transport.handleRequest(req, res, body);
  } catch (error) {
    console.error(`[http] POST handling failed: ${error?.message ?? error}`);
    if (!res.headersSent) {
      res.writeHead(500, { "Content-Type": "application/json" }).end(
        JSON.stringify({
          jsonrpc: "2.0",
          error: {
            code: -32603,
            message: "Internal server error",
          },
          id: null,
        }),
      );
    }
  }
}

async function handleSessionRequest(req, res) {
  if (shuttingDown) {
    res.writeHead(503, { "Content-Type": "application/json" }).end(
      JSON.stringify({
        jsonrpc: "2.0",
        error: {
          code: -32000,
          message: "Server is shutting down",
        },
        id: null,
      }),
    );
    return;
  }

  const sessionIdHeader = req.headers["mcp-session-id"];
  if (!sessionIdHeader || typeof sessionIdHeader !== "string") {
    res.writeHead(400, { "Content-Type": "application/json" }).end(
      JSON.stringify({
        jsonrpc: "2.0",
        error: {
          code: -32000,
          message: "Invalid or missing session ID",
        },
        id: null,
      }),
    );
    return;
  }

  const record = sessions.get(sessionIdHeader);
  if (!record) {
    res.writeHead(404, { "Content-Type": "application/json" }).end(
      JSON.stringify({
        jsonrpc: "2.0",
        error: {
          code: -32001,
          message: "Session not found",
        },
        id: null,
      }),
    );
    return;
  }

  await record.transport.handleRequest(req, res);
}

let stopOwnerIpc;
await initializeTelegram().then(async () => {
  stopOwnerIpc = await startOwnerIpc({
    storeDir,
    ownerLock,
    operations: createOwnerOperations({ storeDir, telegramClient, messageSyncService,
      onAuthLogout: () => shutdown().finally(() => process.exit(0)),
      onDialogsRefreshed: () => {
        dialogRefreshDeferred = false;
        updateServiceState({ dialogRefreshDeferred: false });
      },
      getDialogRefreshDeferred: () => dialogRefreshDeferred,
      coordinator: ownerCoordinator }),
  });
}).catch(async (error) => {
  console.error(`[startup] Telegram initialization failed: ${error?.message ?? error}`);
  await messageSyncService.shutdown().catch(() => {});
  await telegramClient.destroy().catch(() => {});
  ownerLock.release();
  process.exit(1);
});

serviceState = {
  pid: process.pid,
  version: readVersion(),
  manager: process.env.TGCLI_SERVICE_MANAGER ?? "manual",
  startedAt: new Date().toISOString(),
  dialogRefreshDeferred,
  mcpEnabled,
  mcpHost: mcpEnabled ? HOST : null,
  mcpPort: mcpEnabled ? PORT : null,
};
writeServiceState(serviceState);

let httpServer = null;
if (mcpEnabled) {
  httpServer = http.createServer(async (req, res) => {
    try {
      const url = new URL(req.url ?? "", `http://${req.headers.host ?? `${HOST}:${PORT}`}`);

      if (req.method === "OPTIONS") {
        res.writeHead(204).end();
        return;
      }

      if (req.method === "GET" && url.pathname === "/health") {
        res.writeHead(200, { "Content-Type": "application/json" }).end(
          JSON.stringify({ status: "ok" }),
        );
        return;
      }

      if (req.method === "POST" && url.pathname === "/mcp") {
        await handlePost(req, res);
        return;
      }

      if ((req.method === "GET" || req.method === "DELETE") && url.pathname === "/mcp") {
        await handleSessionRequest(req, res);
        return;
      }

      if (req.method === "POST") {
        res.writeHead(404, { "Content-Type": "application/json" }).end(
          JSON.stringify({
            jsonrpc: "2.0",
            error: {
              code: -32601,
              message: "Endpoint not found",
            },
            id: null,
          }),
        );
        return;
      }

      res.writeHead(405, { Allow: "GET, POST, DELETE" }).end();
    } catch (error) {
      console.error(`[http] unexpected error: ${error?.message ?? error}`);
      if (!res.headersSent) {
        res.writeHead(500, { "Content-Type": "application/json" }).end(
          JSON.stringify({
            jsonrpc: "2.0",
            error: {
              code: -32603,
              message: "Internal server error",
            },
            id: null,
          }),
        );
      }
    }
  });

  httpServer.listen(PORT, HOST, () => {
    console.log(`[startup] MCP HTTP server listening on http://${HOST}:${PORT}/mcp`);
  });

  httpServer.on("error", (error) => {
    console.error(`[http] server error: ${error.message}`);
  });
} else {
  console.log("[startup] MCP disabled; running sync and local CLI service.");
}

async function shutdown() {
  if (shuttingDown) {
    return;
  }
  shuttingDown = true;
  const stopWatchdog = startShutdownWatchdog();
  try {
    ownerLock.update({ state: "stopping" });
  } catch (error) {
    console.error(`[shutdown] failed to update owner state: ${error?.message ?? error}`);
  }
  console.log("[shutdown] received termination signal, closing resources...");
  if (stopOwnerIpc) {
    try {
      await stopOwnerIpc();
    } catch (error) {
      console.error(`[shutdown] failed to close owner IPC: ${error?.message ?? error}`);
    }
  }
  const closeTasks = [];
  for (const record of sessions.values()) {
    const task = closeSessionRecord(record, "shutdown");
    if (task) {
      closeTasks.push(task);
    }
  }
  if (closeTasks.length) {
    await Promise.allSettled(closeTasks);
  }
  if (httpServer) {
    httpServer.closeAllConnections?.();
    await new Promise((resolve) => {
      httpServer.close(() => {
        console.log("[shutdown] HTTP server closed");
        resolve();
      });
    });
  }

  try {
    await messageSyncService.shutdown();
  } catch (error) {
    console.error(`[shutdown] error while stopping message sync: ${error?.message ?? error}`);
  }

  try {
    await telegramClient.destroy();
  } catch (error) {
    console.error(`[shutdown] error while closing Telegram client: ${error?.message ?? error}`);
  }

  try {
    ownerLock.release();
  } catch (error) {
    console.error(`[shutdown] failed to release store lock: ${error?.message ?? error}`);
  }

  updateServiceState({
    stoppedAt: new Date().toISOString(),
    pid: null,
  });
  stopWatchdog();
}

const handleShutdownSignal = () => {
  void shutdown().finally(() => process.exit(0));
};

process.prependListener("SIGINT", handleShutdownSignal);
process.prependListener("SIGTERM", handleShutdownSignal);