openclaw/skills/gmail-reader/check-inbox.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,
    client_secret: creds.client_secret,
    refresh_token: creds.refresh_token,
    grant_type: "refresh_token",
  }).toString();

  const data = await httpsRequest("https://oauth2.googleapis.com/token", {
    method: "POST",
    headers: {
      "Content-Type": "application/x-www-form-urlencoded",
      "Content-Length": Buffer.byteLength(body),
    },
    body,
  });

  return data.access_token;
}

async function listMessages(accessToken, maxResults = 10) {
  const url = `https://gmail.googleapis.com/gmail/v1/users/me/messages?maxResults=${maxResults}&q=in:inbox%20is:unread`;
  return await httpsRequest(url, {
    headers: { Authorization: `Bearer ${accessToken}` },
  });
}

async function getMessage(accessToken, id) {
  const url = `https://gmail.googleapis.com/gmail/v1/users/me/messages/${id}`;
  return await httpsRequest(url, {
    headers: { Authorization: `Bearer ${accessToken}` },
  });
}

function getHeader(headers, name) {
  const h = headers.find((h) => h.name.toLowerCase() === name.toLowerCase());
  return h ? h.value : "";
}

async function main() {
  const credsPath = join(homedir(), ".openclaw/secrets/google-oauth.json");
  const creds = JSON.parse(fs.readFileSync(credsPath, "utf8"));

  console.log("📧 Fetching Gmail inbox...");
  const accessToken = await getAccessToken(creds);

  const list = await listMessages(accessToken, 10);

  if (!list.messages || list.messages.length === 0) {
    console.log("✅ No unread messages!");
    return;
  }

  console.log(`\n📬 ${list.messages.length} unread message(s):\n`);

  for (const msg of list.messages.slice(0, 5)) {
    const full = await getMessage(accessToken, msg.id);
    const from = getHeader(full.payload.headers, "From");
    const subject = getHeader(full.payload.headers, "Subject");
    const date = getHeader(full.payload.headers, "Date");

    console.log(`From: ${from}`);
    console.log(`Subject: ${subject}`);
    console.log(`Date: ${date}`);
    console.log(`Preview: ${full.snippet}`);
    console.log("---");
  }
}

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