Connect Duve to Claude

claude mcp add --transport http duve-docs https://developers.duve.com/_mcp/server

mkdir duve-mcp
cd duve-mcp
npm init -y
npm install @modelcontextprotocol/sdk zod

{
  "name": "duve-mcp",
  "version": "1.0.0",
  "type": "module",
  "main": "index.js",
  "dependencies": {
    "@modelcontextprotocol/sdk": "^1.0.0",
    "zod": "^3.22.0"
  }
}

#!/usr/bin/env node
import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
import { z } from "zod";

const CLIENT_ID = process.env.DUVE_CLIENT_ID;
const CLIENT_SECRET = process.env.DUVE_CLIENT_SECRET;
// Sandbox by default. Swap for the production URL Duve
// gives you at certification.
const BASE_URL = process.env.DUVE_API_URL || "https://sandbox.duve.com";

if (!CLIENT_ID || !CLIENT_SECRET) {
  console.error("Missing DUVE_CLIENT_ID or DUVE_CLIENT_SECRET");
  process.exit(1);
}

// --- Token cache: Duve access tokens expire after 1 hour ---
let cachedToken = null;
let tokenExpiresAt = 0;

async function getToken() {
  if (cachedToken && Date.now() < tokenExpiresAt - 60_000) {
    return cachedToken;
  }
  const response = await fetch(`${BASE_URL}/api/openapi/v1/oauth2/token`, {
    method: "POST",
    headers: { "Content-Type": "application/x-www-form-urlencoded" },
    body: new URLSearchParams({
      client_id: CLIENT_ID,
      client_secret: CLIENT_SECRET,
      grant_type: "client_credentials",
    }),
  });
  if (!response.ok) {
    throw new Error(`Duve token request failed: ${response.status}`);
  }
  const data = await response.json();
  cachedToken = data.access_token;
  tokenExpiresAt = Date.now() + (data.expires_in || 3600) * 1000;
  return cachedToken;
}

async function duveGet(path, params = {}) {
  const token = await getToken();
  const url = new URL(`${BASE_URL}/api/openapi/v1${path}`);
  for (const [key, value] of Object.entries(params)) {
    if (value !== undefined && value !== null && value !== "") {
      url.searchParams.append(key, String(value));
    }
  }
  const response = await fetch(url.toString(), {
    headers: {
      Authorization: `Bearer ${token}`,
      Accept: "application/json",
      "User-Agent": "rapideye-duve-mcp/1.0",
    },
  });
  if (!response.ok) {
    const body = await response.text();
    throw new Error(`Duve API ${response.status}: ${body}`);
  }
  return response.json();
}

const server = new McpServer({ name: "duve", version: "1.0.0" });

// Tool 1: Guest links + last chat message for a reservation
server.tool(
  "get-guest-links",
  "Fetch the Duve guest app link, chat link, and online check-in link for a reservation, looked up by its PMS reservation ID (externalId) or CRS reservation ID. Optionally includes the last message in the guest chat with author, timestamp, and channel.",
  {
    externalId: z
      .string()
      .optional()
      .describe("The PMS reservation ID (provide this or crsExternalId)"),
    crsExternalId: z
      .string()
      .optional()
      .describe("The CRS reservation ID (provide this or externalId)"),
    includeLastMessage: z
      .boolean()
      .optional()
      .describe("Also return the last message sent in the guest's chat"),
  },
  async ({ externalId, crsExternalId, includeLastMessage }) => {
    const data = await duveGet("/reservations/links", {
      externalId,
      crsExternalId,
      includeLastMessage: includeLastMessage ? 1 : undefined,
    });
    return {
      content: [{ type: "text", text: JSON.stringify(data, null, 2) }],
    };
  }
);

// Tool 2: List accounts under the credential
server.tool(
  "list-accounts",
  "List the Duve accounts this credential can access. Use this first when the credential covers multiple properties or brands.",
  {},
  async () => {
    const data = await duveGet("/accounts");
    return {
      content: [{ type: "text", text: JSON.stringify(data, null, 2) }],
    };
  }
);

// Tool 3: List registered webhooks
server.tool(
  "list-webhooks",
  "List all webhooks registered on the Duve company: their events, target URLs, and conditions. Read-only; use it to audit what automations currently fire.",
  {},
  async () => {
    const data = await duveGet("/webhooks");
    return {
      content: [{ type: "text", text: JSON.stringify(data, null, 2) }],
    };
  }
);

const transport = new StdioServerTransport();
await server.connect(transport);

~/Library/Application Support/Claude/claude_desktop_config.json

%APPDATA%\Claude\claude_desktop_config.json

{
  "mcpServers": {
    "duve": {
      "command": "node",
      "args": ["/absolute/path/to/duve-mcp/index.js"],
      "env": {
        "DUVE_CLIENT_ID": "your_client_id",
        "DUVE_CLIENT_SECRET": "your_client_secret",
        "DUVE_API_URL": "https://sandbox.duve.com"
      }
    }
  }
}