trigger-context.js

// trigger-context.js — see .ai/contexts/trigger-watcher.md
'use strict';

// Local session handle — see .ai/contexts/trigger-watcher.md, "Session handle".
function createLocalSessionHandle(ptyProcess) {
  return {
    write(data) { ptyProcess.write(data); },
    isAlive() {
      if (!ptyProcess || typeof ptyProcess.pid !== 'number') return false;
      try {
        process.kill(ptyProcess.pid, 0);
        return true;
      } catch (e) {
        return e.code === 'EPERM';
      }
    },
  };
}

/**
 * Build the `ctx` object trigger-watcher's `start(ctx)` expects.
 *
 * @param {object} deps
 * @param {Map} deps.activeSessions
 * @param {object} deps.log  electron-log compatible logger
 * @param {function} [deps.isPtyAlive]  (ptyProcess) => boolean
 * @returns {object} ctx
 */
function createTriggerContext({ activeSessions, log, isPtyAlive }) {
  const ctx = {
    log,
    getPtyForSession(sessionId) {
      const session = activeSessions.get(sessionId);
      if (!session || session.exited) return null;
      const handle = (session.host == null)
        ? createLocalSessionHandle(session.pty)
        : session.handle;
      // cwd: see .ai/contexts/trigger-watcher.md, "Target guard"
      return { ptyProcess: session.pty, cwd: session.cwd, handle };
    },
    isSessionBusy(sessionId) {
      const session = activeSessions.get(sessionId);
      return session ? !!session._cliBusy : false;
    },
    getComposerState(sessionId) {
      const session = activeSessions.get(sessionId);
      if (!session || session.exited || !session.composerState) return null;
      const { pending, lastInputAt } = session.composerState;
      return { pending, lastInputAt };
    },
  };
  if (isPtyAlive) ctx.isPtyAlive = isPtyAlive;
  return ctx;
}

module.exports = { createTriggerContext, createLocalSessionHandle };