openclaw/skills/gmail-reader/get-o365-message.cjs

#!/usr/bin/env node
const fs = require("fs");
const https = require("https");
const { homedir } = require("os");
const { join } = require("path");

function httpsRequest(url, options = {}) {
  return new Promise((resolve, reject) => {
    const req = https.request(url, options, (res) => {
      let data = "";
      res.on("data", (chunk) => (data += chunk));
      res.on("end", () => {
        if (res.statusCode >= 400) {
          reject(new Error(`HTTP ${res.statusCode}: ${data}`));
        } else {
          resolve(JSON.parse(data));
        }
      });
    });
    req.on("error", reject);
    if (options.body) req.write(options.body);
    req.end();
  });
}

async function getAccessToken(creds) {
  const body = new URLSearchParams({
    client_id: creds.client_id,
    refresh_token: creds.refresh_token,
    grant_type: "refresh_token",
    scope: "https://graph.microsoft.com/Mail.Read offline_access",
  }).toString();

  const tenant = creds.tenant || "common";
  const data = await httpsRequest(`https://login.microsoftonline.com/${tenant}/oauth2/v2.0/token`, {
    method: "POST",
    headers: {
      "Content-Type": "application/x-www-form-urlencoded",
      "Content-Length": Buffer.byteLength(body),
    },
    body,
  });

  return data.access_token;
}

async function searchMessages(accessToken, query) {
  const url = `https://graph.microsoft.com/v1.0/me/messages?$top=5&$search="${query}"`;
  return await httpsRequest(url, {
    headers: { Authorization: `Bearer ${accessToken}` },
  });
}

async function main() {
  const searchQuery = process.argv[2] || "sapphire";

  const creds = JSON.parse(
    fs.readFileSync(join(homedir(), ".openclaw/secrets/outlook-o365-oauth.json"), "utf8"),
  );
  const accessToken = await getAccessToken(creds);
  const result = await searchMessages(accessToken, searchQuery);

  if (!result.value || result.value.length === 0) {
    console.log("No matches found.\n");
    return;
  }

  // Show the most recent message
  const msg = result.value[0];

  console.log(`From: ${msg.from?.emailAddress?.address || "Unknown"}`);
  console.log(`Subject: ${msg.subject}`);
  console.log(`Date: ${msg.receivedDateTime}`);
  console.log(`\n━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n`);
  console.log(msg.body?.content?.replace(/<[^>]*>/g, "").substring(0, 2000));
}

main().catch((err) => {
  console.error("Error:", err.message);
  process.exit(1);
});