3-Tier Sync & Universal Ingestion Engine

/**
 * SAM OS — macOS Apple Notes Sync Daemon
 * Reads local macOS Apple Notes via ScriptingBridge/JXA and syncs to SAM OS
 * Run via: node sam-apple-notes-sync.js
 */

const { execSync } = require('child_process');
const SAM_API_URL = 'http://localhost:3000/api/v1/ingest/apple-notes';
const API_KEY = 'sam_mac_live_key_token';

function getAppleNotes() {
  const script = `
    const Notes = Application('Notes');
    const notes = Notes.notes();
    const result = [];
    for (let i = 0; i < Math.min(notes.length, 25); i++) {
      const n = notes[i];
      result.push({
        externalId: n.id(),
        title: n.name(),
        content: n.body(),
        modifiedAt: n.modificationDate()
      });
    }
    JSON.stringify(result);
  `;

  try {
    const raw = execSync(`osascript -l JavaScript -e "${script.replace(/"/g, '\\"')}"`, { encoding: 'utf8' });
    return JSON.parse(raw);
  } catch (err) {
    console.error('Failed to query Apple Notes:', err.message);
    return [];
  }
}

async function syncToSam() {
  const notes = getAppleNotes();
  if (notes.length === 0) return;

  const res = await fetch(SAM_API_URL, {
    method: 'POST',
    headers: {
      'Content-Type': 'application/json',
      'x-api-key': API_KEY
    },
    body: JSON.stringify({ notes })
  });
  console.log('Synced to SAM OS:', await res.json());
}

syncToSam();
setInterval(syncToSam, 60000); // Poll every 60s