Connect real-time events

const CONNECTOR_URL       = process.env.CONNECTOR_URL ?? "https://mcp.autoplay.ai";
const MCP_KEY             = process.env.MCP_KEY ?? "";
const AUTOPLAY_PRODUCT_ID = process.env.PRODUCT_ID ?? "";
const PLAIN_API_KEY       = process.env.PLAIN_API_KEY ?? "";
const PLAIN_API_URL       = "https://core-api.uk.plain.com/graphql/v1";

async function plainRequest(query, variables) {
  const res = await fetch(PLAIN_API_URL, {
    method: "POST",
    headers: {
      "Content-Type": "application/json",
      Authorization: `Bearer ${PLAIN_API_KEY}`,
    },
    body: JSON.stringify({ query, variables }),
  });
  return res.json();
}

async function getPlainCustomerIdFromThread(threadId) {
  const data = await plainRequest(
    `query GetThread($threadId: ID!) {
      thread(threadId: $threadId) {
        customer { id }
      }
    }`,
    { threadId }
  );
  return data?.data?.thread?.customer?.id ?? null;
}


// Call this from your route/controller with the parsed JSON body.
export async function handlePlainChatWebhook({ customerId, threadId }) {
  if (!customerId || !threadId) return { ok: true };

  const url = `${CONNECTOR_URL}/users/${encodeURIComponent(AUTOPLAY_PRODUCT_ID)}/${encodeURIComponent(customerId)}/live-activity`;
  const res = await fetch(url, {
    headers: { Authorization: `Bearer ${MCP_KEY}` },
  });

  if (!res.ok) {
    console.log(`[plain-chat] Autoplay fetch failed: ${res.status} for user=${customerId}`);
    return { ok: true };
  }

  const { actions = [] } = await res.json();
  console.log(`[plain-chat] user=${customerId} actions=${actions.length}`);

  if (actions.length > 0) {
    const plainCustomerId = await getPlainCustomerIdFromThread(threadId);
    console.log(`[plain-chat] threadId=${threadId} plainCustomerId=${plainCustomerId ?? "null"}`);

    if (plainCustomerId) {
      const lines = actions
        .slice(-10)
        .reverse()
        .map((a, i) => `${i + 1}. ${a.description}`);

      const noteText = `Recent user activity (last 10 actions): ${lines.join(". ")}`;
      console.log(`[plain-chat] writing note (${lines.length} actions): ${noteText.slice(0, 80)}…`);
    }
  }

  return { ok: true };
}

(function (d, script) {
  script = d.createElement('script');
  script.async = false;
  script.onload = function () {
    Plain.init({
      appId: 'YOUR_PLAIN_APP_ID', // paste your liveChatApp_... ID here
      callbacks: {
        onNewThread: async function (data) {
          var uid = USER_ID || null;
          if (!uid) return;
          await fetch('/plain-chat-webhook', {
            method: 'POST',
            headers: { 'Content-Type': 'application/json' },
            body: JSON.stringify({
              customerId: uid,
              threadId: data.threadId,
            }),
          });
        },
      },
    });
  };
  script.src = 'https://chat.cdn-plain.com/index.js';
  d.getElementsByTagName('head')[0].appendChild(script);
})(document);