posimai-root/posimai-dev/server.js

'use strict';
const express = require('express');
const { WebSocketServer } = require('ws');
const pty = require('node-pty');
const http = require('http');
const https = require('https');
const fs = require('fs');
const path = require('path');
const os = require('os');

const app = express();
const PORT = process.env.PORT || 3333;

// セッションログ保存ディレクトリ
const SESSIONS_DIR = path.join(os.homedir(), 'posimai-dev-sessions');
if (!fs.existsSync(SESSIONS_DIR)) fs.mkdirSync(SESSIONS_DIR, { recursive: true });

app.use(express.json());
app.use(express.static(path.join(__dirname)));

// セッション一覧 API
app.get('/api/sessions', (req, res) => {
  const files = fs.readdirSync(SESSIONS_DIR)
    .filter((f) => f.endsWith('.log'))
    .map((f) => {
      const stat = fs.statSync(path.join(SESSIONS_DIR, f));
      return { id: f.replace('.log', ''), size: stat.size, mtime: stat.mtime };
    })
    .sort((a, b) => new Date(b.mtime) - new Date(a.mtime));
  res.json(files);
});

// セッション内容 API
app.get('/api/sessions/:id', (req, res) => {
  const file = path.join(SESSIONS_DIR, req.params.id + '.log');
  if (!fs.existsSync(file)) return res.status(404).json({ error: 'not found' });
  res.type('text/plain').send(fs.readFileSync(file, 'utf8'));
});

// Tailscale証明書を自動検出
function findCert() {
  const home = os.homedir();
  const crt = fs.readdirSync(home).find((f) => f.endsWith('.crt'));
  if (!crt) return null;
  const key = crt.replace('.crt', '.key');
  if (!fs.existsSync(path.join(home, key))) return null;
  return { cert: fs.readFileSync(path.join(home, crt)), key: fs.readFileSync(path.join(home, key)) };
}

const tlsOpts = findCert();
const server = tlsOpts ? https.createServer(tlsOpts, app) : http.createServer(app);
const proto = tlsOpts ? 'https' : 'http';

const wss = new WebSocketServer({ server, path: '/terminal' });

wss.on('connection', (ws) => {
  // セッションID・ログファイル作成
  const sessionId = new Date().toISOString().replace(/[:.]/g, '-').slice(0, 19);
  const logPath = path.join(SESSIONS_DIR, `${sessionId}.log`);
  const logStream = fs.createWriteStream(logPath, { flags: 'a' });
  logStream.write(`=== posimai-dev session ${sessionId} ===\n`);

  // セッションID をブラウザに通知
  ws.send(JSON.stringify({ type: 'session', id: sessionId }));

  const shell = process.env.SHELL || '/bin/bash';
  const ptyProc = pty.spawn(shell, [], {
    name: 'xterm-256color',
    cols: 80,
    rows: 24,
    cwd: path.join(os.homedir(), 'posimai-project'),
    env: { ...process.env, PATH: `${os.homedir()}/.npm-global/bin:${process.env.PATH}` }
  });

  // 起動時に posimai-project へ自動移動（cwd で指定済みだが source bashrc も通す）
  setTimeout(() => ptyProc.write(`source ~/.bashrc\n`), 300);

  ptyProc.onData((data) => {
    logStream.write(data);
    if (ws.readyState === 1) ws.send(JSON.stringify({ type: 'output', data }));
  });

  ws.on('message', (raw) => {
    try {
      const msg = JSON.parse(raw.toString());
      if (msg.type === 'input') {
        logStream.write(msg.data);
        ptyProc.write(msg.data);
      }
      if (msg.type === 'resize') ptyProc.resize(Number(msg.cols), Number(msg.rows));
    } catch {}
  });

  ws.on('close', () => {
    logStream.end(`\n=== session end ===\n`);
    try { ptyProc.kill(); } catch {}
  });
  ptyProc.onExit(() => { try { ws.close(); } catch {} });
});

server.listen(PORT, '0.0.0.0', () => {
  console.log(`posimai-dev running on ${proto}://0.0.0.0:${PORT}`);
});