Add desktop API chat adapter package

packages/chat-adapter/.gitignore

@@ -0,0 +1,3 @@
+dist
+node_modules
+coverage

packages/chat-adapter/README.md

@@ -0,0 +1,70 @@
+# Beeper Desktop API Chat Adapter
+
+Chat SDK adapter for Beeper Desktop API built on top of `@beeper/desktop-api`.
+
+## Install
+
+```bash
+yarn add @beeper/chat-adapter-desktop-api
+```
+
+## Usage
+
+```ts
+import { Chat } from "chat";
+import { createMemoryState } from "@chat-adapter/state-memory";
+import { createBeeperDesktopAPIAdapter } from "@beeper/chat-adapter-desktop-api";
+
+const adapter = createBeeperDesktopAPIAdapter({
+  accessToken: process.env.BEEPER_DESKTOP_API_ACCESS_TOKEN!,
+  botUserID: process.env.BEEPER_DESKTOP_API_BOT_USER_ID,
+  defaultAccountID: process.env.BEEPER_DESKTOP_API_DEFAULT_ACCOUNT_ID,
+});
+
+const bot = new Chat({
+  userName: "bot",
+  adapters: { beeperDesktopAPI: adapter },
+  state: createMemoryState(),
+});
+
+await bot.initialize();
+console.log(adapter.getDesktopAPIServerInfo());
+await adapter.startEventsListener(["*"]);
+```
+
+## Implemented easy-win features
+
+- `openDM(userID)` with either:
+  - scoped input `<accountID>:<participantID>`, or
+  - `defaultAccountID` in adapter config
+- `fetchMessage(threadID, messageID)`
+- `fetchChannelInfo(channelId)`
+- `listThreads(channelId, { cursor, limit })`
+- auto reconnect for WS listener (`wsReconnectDelayMs`, default `3000`)
+- auto server version detection (`/v1/info` first, then response headers fallback)
+
+## Logger Example
+
+A runnable logger example is included in `examples/logger`.
+
+Run it:
+
+```bash
+BEEPER_DESKTOP_API_ACCESS_TOKEN=... yarn example:logger
+```
+
+If you run the example file directly:
+
+```bash
+yarn build
+cd examples/logger
+BEEPER_DESKTOP_API_ACCESS_TOKEN=... node index.mjs
+```
+
+Optional env vars:
+
+- `BEEPER_DESKTOP_API_BASE_URL` (default `http://localhost:23373`)
+- `BEEPER_DESKTOP_API_BOT_USER_ID`
+- `BEEPER_DESKTOP_API_BOT_NAME`
+- `BEEPER_DESKTOP_API_CHAT_IDS` (comma-separated, default `*`)
+- `BEEPER_DESKTOP_API_DEFAULT_ACCOUNT_ID`

packages/chat-adapter/examples/logger/index.mjs

@@ -0,0 +1,84 @@
+import { Chat } from "chat";
+import { createMemoryState } from "@chat-adapter/state-memory";
+import { createBeeperDesktopAPIAdapter } from "../../dist/index.js";
+
+const accessToken = process.env.BEEPER_DESKTOP_API_ACCESS_TOKEN;
+if (!accessToken) {
+  throw new Error("Missing BEEPER_DESKTOP_API_ACCESS_TOKEN");
+}
+
+const baseUrl = process.env.BEEPER_DESKTOP_API_BASE_URL ?? "http://localhost:23373";
+const botUserID = process.env.BEEPER_DESKTOP_API_BOT_USER_ID;
+const defaultAccountID = process.env.BEEPER_DESKTOP_API_DEFAULT_ACCOUNT_ID;
+const chatIDs = (process.env.BEEPER_DESKTOP_API_CHAT_IDS ?? "*")
+  .split(",")
+  .map((value) => value.trim())
+  .filter(Boolean);
+
+const adapter = createBeeperDesktopAPIAdapter({
+  baseUrl,
+  accessToken,
+  botUserID,
+  defaultAccountID,
+  autoConnectEvents: false,
+  userName: process.env.BEEPER_DESKTOP_API_BOT_NAME ?? "bot",
+});
+
+const bot = new Chat({
+  userName: process.env.BEEPER_DESKTOP_API_BOT_NAME ?? "bot",
+  adapters: {
+    beeperDesktopAPI: adapter,
+  },
+  state: createMemoryState(),
+  logger: "info",
+});
+
+bot.onNewMention(async (thread, message) => {
+  console.log("[mention]", {
+    threadId: thread.id,
+    messageId: message.id,
+    sender: message.author.userName,
+    text: message.text,
+  });
+  await thread.subscribe();
+});
+
+bot.onNewMessage(/[\s\S]*/u, async (thread, message) => {
+  console.log("[new-message]", {
+    threadId: thread.id,
+    messageId: message.id,
+    sender: message.author.userName,
+    isMention: message.isMention,
+    text: message.text,
+  });
+});
+
+bot.onSubscribedMessage(async (thread, message) => {
+  console.log("[subscribed-message]", {
+    threadId: thread.id,
+    messageId: message.id,
+    sender: message.author.userName,
+    text: message.text,
+  });
+});
+
+bot.onReaction(async (event) => {
+  console.log("[reaction]", {
+    threadId: event.threadId,
+    messageId: event.messageId,
+    added: event.added,
+    emoji: event.rawEmoji,
+    by: event.user.userName,
+  });
+});
+
+await bot.initialize();
+console.log("BeeperDesktopAPI server info", adapter.getDesktopAPIServerInfo());
+await adapter.startEventsListener(chatIDs);
+
+console.log("BeeperDesktopAPI logger is running", {
+  baseUrl,
+  chatIDs,
+});
+
+await new Promise(() => {});

packages/chat-adapter/package.json

@@ -0,0 +1,63 @@
+{
+  "name": "@beeper/chat-adapter-desktop-api",
+  "version": "4.5.0",
+  "description": "Beeper Desktop API adapter for Chat SDK",
+  "type": "module",
+  "main": "./dist/index.js",
+  "module": "./dist/index.js",
+  "types": "./dist/index.d.ts",
+  "exports": {
+    ".": {
+      "types": "./dist/index.d.ts",
+      "import": "./dist/index.js"
+    }
+  },
+  "files": [
+    "dist"
+  ],
+  "author": "Beeper Desktop <help@beeper.com>",
+  "packageManager": "yarn@1.22.22",
+  "private": false,
+  "scripts": {
+    "build": "yarn clean && tsup && node ./scripts/prepare-dist.mjs",
+    "dev": "tsup --watch",
+    "test": "vitest run --coverage",
+    "test:watch": "vitest",
+    "typecheck": "tsc --noEmit",
+    "clean": "rm -rf dist",
+    "example:logger": "yarn build && node examples/logger/index.mjs"
+  },
+  "dependencies": {
+    "@beeper/desktop-api": "^4.2.3",
+    "@chat-adapter/shared": "^4.13.4",
+    "chat": "^4.13.4",
+    "ws": "^8.18.3"
+  },
+  "devDependencies": {
+    "@vitest/coverage-v8": "^2.1.8",
+    "@chat-adapter/state-memory": "^4.13.4",
+    "@types/node": "^22.10.2",
+    "@types/ws": "^8.18.1",
+    "tsup": "^8.3.5",
+    "typescript": "^5.7.2",
+    "vitest": "^2.1.8"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/beeper/desktop-api-js.git",
+    "directory": "packages/chat-adapter"
+  },
+  "homepage": "https://github.com/beeper/desktop-api-js/tree/main/packages/chat-adapter#readme",
+  "bugs": {
+    "url": "https://github.com/beeper/desktop-api-js/issues"
+  },
+  "publishConfig": {
+    "access": "public"
+  },
+  "keywords": [
+    "chat",
+    "beeper-desktop-api",
+    "adapter"
+  ],
+  "license": "MIT"
+}

packages/chat-adapter/scripts/prepare-dist.mjs

@@ -0,0 +1,54 @@
+import { cpSync, existsSync, mkdirSync, readFileSync, writeFileSync } from 'node:fs';
+import path from 'node:path';
+import { fileURLToPath } from 'node:url';
+
+const __dirname = path.dirname(fileURLToPath(import.meta.url));
+const packageDir = path.join(__dirname, '..');
+const distDir = path.join(packageDir, 'dist');
+const packageJsonPath = path.join(packageDir, 'package.json');
+
+if (!existsSync(distDir)) {
+  throw new Error(`Expected dist directory at ${distDir}`);
+}
+
+const packageJson = JSON.parse(readFileSync(packageJsonPath, 'utf8'));
+
+const mapPath = (value) => {
+  if (typeof value !== 'string') return value;
+  return value.replace(/^\.\/dist\//, './');
+};
+
+const mapExports = (value) => {
+  if (typeof value === 'string') return mapPath(value);
+  if (Array.isArray(value)) return value.map(mapExports);
+  if (value && typeof value === 'object') {
+    return Object.fromEntries(Object.entries(value).map(([key, inner]) => [key, mapExports(inner)]));
+  }
+  return value;
+};
+
+const publishPackage = {
+  name: packageJson.name,
+  version: packageJson.version,
+  description: packageJson.description,
+  type: packageJson.type,
+  main: mapPath(packageJson.main),
+  module: mapPath(packageJson.module),
+  types: mapPath(packageJson.types),
+  exports: mapExports(packageJson.exports),
+  author: packageJson.author,
+  repository: packageJson.repository,
+  homepage: packageJson.homepage,
+  bugs: packageJson.bugs,
+  publishConfig: packageJson.publishConfig,
+  keywords: packageJson.keywords,
+  license: packageJson.license,
+  dependencies: packageJson.dependencies,
+};
+
+writeFileSync(path.join(distDir, 'package.json'), JSON.stringify(publishPackage, null, 2) + '\n');
+
+mkdirSync(path.join(distDir, 'examples', 'logger'), { recursive: true });
+cpSync(path.join(packageDir, 'README.md'), path.join(distDir, 'README.md'));
+cpSync(path.join(packageDir, 'examples', 'logger', 'index.mjs'), path.join(distDir, 'examples', 'logger', 'index.mjs'));
+cpSync(path.join(packageDir, '..', '..', 'LICENSE'), path.join(distDir, 'LICENSE'));

packages/chat-adapter/src/beeper-desktop-api.d.ts

@@ -0,0 +1,14 @@
+declare module '@beeper/desktop-api' {
+  export default class BeeperDesktop {
+    constructor(options: { accessToken: string; baseURL: string });
+
+    messages: any;
+    accounts: any;
+    chats: any;
+
+    get<T = unknown>(path: string, options?: unknown): any;
+    put(path: string, options?: unknown): Promise<unknown>;
+    post(path: string, options?: unknown): Promise<unknown>;
+    delete(path: string, options?: unknown): Promise<unknown>;
+  }
+}