lean-ctx 3.5.9

Context Runtime for AI Agents with CCP. 57 MCP tools, 10 read modes, 95+ compression patterns, cross-session memory (CCP), persistent AI knowledge with temporal facts + contradiction detection, multi-agent context sharing + diaries, LITM-aware positioning, AAAK compact format, adaptive compression with Thompson Sampling bandits. Supports 24 AI tools. Reduces LLM token consumption by up to 99%.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98

/**
 * Authenticated JSON fetch for LeanCTX dashboard API.
 */
function getAuthToken() {
  if (typeof window === 'undefined') return '';
  if (window.__LEAN_CTX_TOKEN__) return window.__LEAN_CTX_TOKEN__;
  try {
    const st = sessionStorage.getItem('lctx_token');
    if (st) {
      window.__LEAN_CTX_TOKEN__ = st;
      return st;
    }
  } catch (_) {}
  return '';
}

function mergeHeaders(base, extra) {
  const h = new Headers();
  if (base && typeof base.forEach === 'function') {
    base.forEach((v, k) => h.set(k, v));
  } else if (base && typeof base === 'object') {
    for (const k of Object.keys(base)) {
      const v = base[k];
      if (v !== undefined && v !== null) h.set(k, String(v));
    }
  }
  if (extra && typeof extra === 'object') {
    for (const k of Object.keys(extra)) {
      const v = extra[k];
      if (v !== undefined && v !== null) h.set(k, String(v));
    }
  }
  return h;
}

async function parseJsonBody(res) {
  const ct = (res.headers.get('content-type') || '').toLowerCase();
  const text = await res.text();
  if (!text) return null;
  if (ct.includes('application/json')) {
    try {
      return JSON.parse(text);
    } catch (_) {
      throw { error: 'invalid JSON response' };
    }
  }
  try {
    return JSON.parse(text);
  } catch (_) {
    return { error: text.slice(0, 200) || 'non-JSON response' };
  }
}

/**
 * @param {string} path
 * @param {RequestInit & { timeoutMs?: number }} [opts]
 */
async function apiFetch(path, opts) {
  const timeoutMs = opts && opts.timeoutMs != null ? opts.timeoutMs : 5000;
  const token = getAuthToken();
  const ctrl = new AbortController();
  const t = setTimeout(function () {
    ctrl.abort();
  }, timeoutMs);

  const extra = { Accept: 'application/json' };
  if (token) extra['Authorization'] = 'Bearer ' + token;

  let reqInit = Object.assign({}, opts || {});
  delete reqInit.timeoutMs;
  reqInit.headers = mergeHeaders(reqInit.headers, extra);
  reqInit.signal = ctrl.signal;
  reqInit.cache = reqInit.cache || 'no-store';

  try {
    const res = await fetch(path, reqInit);
    const body = await parseJsonBody(res);
    if (!res.ok) {
      const msg =
        body && typeof body === 'object' && body.error != null
          ? String(body.error)
          : 'HTTP ' + res.status;
      throw { error: msg };
    }
    return body;
  } catch (e) {
    if (e && e.error) throw e;
    if (e && e.name === 'AbortError') throw { error: 'timeout' };
    const msg = e && e.message ? String(e.message) : String(e || 'request failed');
    throw { error: msg };
  } finally {
    clearTimeout(t);
  }
}

window.LctxApi = { apiFetch, getAuthToken };

export { apiFetch, getAuthToken };