total 596
drwxr-xr-x 1 byk byk    554 Jun  7 21:05 .
drwxr-xr-x 1 byk byk     96 Jun  7 14:13 ..
-rw-r--r-- 1 byk byk   9355 Jun  7 13:35 AGENTS.md
-rw-r--r-- 1 byk byk   1060 Jun  6 23:35 biome.json
-rw-r--r-- 1 byk byk 127704 Jun  7 19:56 bun.lock
-rw-r--r-- 1 byk byk  67582 Jun  6 23:35 CHANGELOG.md
-rw-r--r-- 1 byk byk   2133 Jun  6 23:35 .craft.yml
drwxr-xr-x 1 byk byk    428 Jun  7 12:45 docs
-rw-r--r-- 1 byk byk   8196 Jun  6 23:35 .DS_Store
-rw-r--r-- 1 byk byk     63 Jun  6 23:35 .git
drwxr-xr-x 1 byk byk     18 Jun  6 23:35 .github
-rw-r--r-- 1 byk byk    584 Jun  7 19:56 .gitignore
-rw-r--r-- 1 byk byk   3760 Jun  6 23:35 LICENSE
-rw-r--r-- 1 byk byk  41347 Jun  7 19:56 .lore.md
drwxr-xr-x 1 byk byk    252 Jun  7 19:57 node_modules
drwxr-xr-x 1 byk byk    112 Jun  7 13:48 .opencode
-rw-r--r-- 1 byk byk   1473 Jun  7 21:05 package.json
drwxr-xr-x 1 byk byk     68 Jun  7 19:56 packages
-rw-r--r-- 1 byk byk 264529 Jun  7 19:56 pnpm-lock.yaml
-rw-r--r-- 1 byk byk     27 Jun  6 ...

total 848
drwxr-xr-x 1 byk byk    844 Jun  7 19:56 .
drwxr-xr-x 1 byk byk    208 Jun  7 19:56 ..
-rw-r--r-- 1 byk byk  24660 Jun  6 23:35 agents-file.ts
-rw-r--r-- 1 byk byk  16205 Jun  6 23:35 config.ts
-rw-r--r-- 1 byk byk  32376 Jun  6 23:35 curator.ts
-rw-r--r-- 1 byk byk   2507 Jun  6 23:35 data-dir.ts
-rw-r--r-- 1 byk byk  30732 Jun  6 23:35 data.ts
drwxr-xr-x 1 byk byk     54 Jun  7 12:45 db
-rw-r--r-- 1 byk byk  87385 Jun  6 23:35 db.ts
-rw-r--r-- 1 byk byk  52368 Jun  6 23:35 distillation.ts
-rw-r--r-- 1 byk byk  55346 Jun  7 19:56 embedding.ts
-rw-r--r-- 1 byk byk   5585 Jun  6 23:35 embedding-vendor.ts
-rw-r--r-- 1 byk byk  15426 Jun  6 23:35 embedding-worker.ts
-rw-r--r-- 1 byk byk   5877 Jun  7 19:56 embedding-worker-types.ts
-rw-r--r-- 1 byk byk  64398 Jun  7 19:56 entities.ts
-rw-r--r-- 1 byk byk   6874 Jun  6 23:35 fetch-interceptor.ts
-rw-r--r-- 1 byk byk   6831 Jun  6 23:35 git.ts
-rw-r--r-- 1 byk byk 100516 Jun  7 13:18 gradient.ts
-rw-r--r-- 1 byk byk   1521 Jun  6 ...

total 828
drwxr-xr-x 1 byk byk    610 Jun  7 19:56 .
drwxr-xr-x 1 byk byk    134 Jun  7 20:56 ..
-rw-r--r-- 1 byk byk  19715 Jun  6 23:35 api.ts
-rw-r--r-- 1 byk byk   8525 Jun  6 23:35 auth.ts
-rw-r--r-- 1 byk byk   6463 Jun  6 23:35 background-limiter.ts
-rw-r--r-- 1 byk byk  41824 Jun  6 23:35 batch-queue.ts
-rw-r--r-- 1 byk byk  19990 Jun  6 23:35 cache-analytics.ts
-rw-r--r-- 1 byk byk  58944 Jun  6 23:35 cache-warmer.ts
-rw-r--r-- 1 byk byk  19841 Jun  6 23:35 cch.ts
drwxr-xr-x 1 byk byk    348 Jun  6 23:35 cli
-rw-r--r-- 1 byk byk  13638 Jun  6 23:35 compaction.ts
-rw-r--r-- 1 byk byk  24290 Jun  6 23:35 config.ts
-rw-r--r-- 1 byk byk  47153 Jun  6 23:35 cost-tracker.ts
-rw-r--r-- 1 byk byk   1022 Jun  6 23:35 fetch.ts
-rw-r--r-- 1 byk byk  25025 Jun  6 23:35 idle.ts
-rw-r--r-- 1 byk byk   2238 Jun  6 23:35 index.ts
-rw-r--r-- 1 byk byk  28540 Jun  7 19:56 llm-adapter.ts
-rw-r--r-- 1 byk byk 204026 Jun  7 19:56 pipeline.ts
-rw-r--r-- 1 byk byk   1799 Jun  6 23:35 ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/core/src/distillation.ts</path>
<type>file</type>
<content>
1: import { db, ensureProject } from "./db";
2: import { config } from "./config";
3: import * as temporal from "./temporal";
4: import { CHUNK_TERMINATOR } from "./temporal";
5: import * as embedding from "./embedding";
6: import * as ltm from "./ltm";
7: import * as log from "./log";
8: import {
9:   extractPatterns,
10:   extractActionTags,
11:   tagToTitle,
12: } from "./pattern-extract";
13: import * as toolTrace from "./tool-trace";
14: import { detectPatternEchoes } from "./pattern-echo";
15: import { hasNonAsciiLetters } from "./instruction-detect";
16: import {
17:   DISTILLATION_SYSTEM,
18:   distillationUser,
19:   RECURSIVE_SYSTEM,
20:   recursiveUser,
21: } from "./prompt";
22: import { toolStripAnnotation } from "./gradient";
23: import { workerSessionIDs } from "./worker";
24: import { distillLimiter } ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/core/src/curator.ts</path>
<type>file</type>
<content>
1: import { config } from "./config";
2: import {
3:   db,
4:   saveSessionTracking,
5:   loadSessionTracking,
6:   ensureProject,
7: } from "./db";
8: import * as temporal from "./temporal";
9: import * as distillation from "./distillation";
10: import * as ltm from "./ltm";
11: import * as entities from "./entities";
12: import * as embedding from "./embedding";
13: import * as log from "./log";
14: import {
15:   CURATOR_SYSTEM,
16:   curatorUser,
17:   CONSOLIDATION_SYSTEM,
18:   consolidationUser,
19: } from "./prompt";
20: import * as toolTrace from "./tool-trace";
21: import { detectAndFormat } from "./instruction-detect";
22: import { curatorLimiter } from "./session-limiter";
23: import type { LLMClient } from "./types";
24: import type { EntityType, AliasType, RelationType } from "./entities";
25: 
26: /**
27:  * ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/core/src/pattern-extract.ts</path>
<type>file</type>
<content>
1: /**
2:  * Lightweight regex-based pattern extraction from distillation observations.
3:  *
4:  * Scans for decision/preference/choice patterns and returns structured
5:  * extractions that can be stored as knowledge entries. No LLM required.
6:  *
7:  * Patterns target how decisions and preferences are typically expressed
8:  * in distilled engineering context:
9:  *   - "decided to use X"
10:  *   - "chose X over Y"
11:  *   - "switched from X to Y"
12:  *   - "prefers X for Y"
13:  *   - "going with X because Y"
14:  *
15:  * Also matches process instruction patterns from distilled observations
16:  * where the observer normalizes user assertions:
17:  *   - "User stated always X"
18:  *   - "User said never Y"
19:  *   - "User stated make sure to X"
20:  *   - "User stated don't forget to X"
21:  *
22:  * ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/llm-adapter.ts</path>
<type>file</type>
<content>
1: /**
2:  * Gateway LLM adapter: implements LLMClient via direct API calls.
3:  * Used by Lore's background workers (distillation, curation, query expansion)
4:  * running inside the gateway process.
5:  *
6:  * Supports both Anthropic Messages API and OpenAI Chat Completions API.
7:  * The wire protocol is determined by explicit protocol from the session's
8:  * UpstreamSnapshot (threaded via opts.protocol), with fallback to the
9:  * provider route registry (PROVIDER_ROUTES) and a safe default of
10:  * "anthropic" for unknown/aggregator providers:
11:  *   - Anthropic protocol → POST /v1/messages
12:  *   - OpenAI protocol    → POST /v1/chat/completions
13:  *
14:  * Protocol is decoupled from provider identity — proxy/aggregator
15:  * providers (e.g. ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/core/src/worker-model.ts</path>
<type>file</type>
<content>
1: /**
2:  * Worker model resolution.
3:  *
4:  * Background workers (distillation, curation, query expansion) default to
5:  * sonnet-4-6 when the session model is more expensive ($1.50+/M input).
6:  * Sonnet-4-6 produces equivalent-quality distillations at lower cost.
7:  * An explicit `workerModel` config override takes priority over this default.
8:  *
9:  * Resolution order:
10:  *   1. Explicit config override (`workerModel`)
11:  *   2. Cost-aware default (sonnet-4 for expensive session models)
12:  *   3. ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/worker-model.ts</path>
<type>file</type>
<content>
1: /**
2:  * Gateway model pricing and resolution.
3:  *
4:  * Fetches per-model pricing from models.dev (open-source model database)
5:  * for cost estimation in Sentry metrics and gradient cost-aware capping.
6:  *
7:  * Worker model resolution delegates to core's simple chain:
8:  *   explicit config override > session model fallback.
9:  */
10: 
11: import { workerModel, config as loreConfig, log } from "@loreai/core";
12: import type { ProviderRoute } from "./config";
13: import { upstreamFetch } from "./fetch";
14: 
15: // ---------------------------------------------------------------------------
16: // Cost lookup — models.dev
17: // ---------------------------------------------------------------------------
18: 
19: /**
20:  * models.dev JSON API endpoint — returns all providers/models with pricing. ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/core/src/worker.ts</path>
<type>file</type>
<content>
1: // Re-export for convenience
2: export type { LLMClient } from "./types";
3: 
4: // ---------------------------------------------------------------------------
5: // Shared worker session tracking
6: // ---------------------------------------------------------------------------
7: 
8: /** Set of ALL worker session IDs across distillation, curator, and query expansion.
9:  *  Used by shouldSkip() in host adapters to avoid storing/distilling worker messages. */
10: export const workerSessionIDs = new Set<string>();
11: 
12: export function isWorkerSession(sessionID: string): boolean {
13:   return workerSessionIDs.has(sessionID);
14: }

(End of file - total 14 lines)
</content>

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/core/src/types.ts</path>
<type>file</type>
<content>
1: /**
2:  * Host-agnostic message and part types for Lore's core memory engine.
3:  *
4:  * These replace the direct dependency on `@opencode-ai/sdk`'s `Message` and
5:  * `Part` types so the core can run under any host (OpenCode, Pi, future ACP
6:  * server, etc.). Each host adapter converts between its native types and these
7:  * Lore-internal types at the hook boundary.
8:  *
9:  * The type surface is intentionally minimal — only the fields that Lore's
10:  * runtime code actually reads/writes are included. Fields that only exist for
11:  * the host's UI or for features Lore doesn't touch are omitted. ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/auth.ts</path>
<type>file</type>
<content>
1: /**
2:  * Gateway authentication: typed credentials, per-session registry, and
3:  * two-level lookup for background workers.
4:  *
5:  * Replaces the bare `lastSeenApiKey` string with a typed `AuthCredential`
6:  * that supports both API-key (`x-api-key`) and OAuth Bearer token
7:  * (`Authorization: Bearer`) authentication schemes.
8:  *
9:  * The per-session registry ensures background workers (distillation,
10:  * curation, batch queue) use the correct credential for their session
11:  * even when multiple clients are connected simultaneously. ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/config.ts</path>
<type>file</type>
<content>
1: /**
2:  * Gateway configuration — loaded from environment variables with sensible
3:  * defaults. No Zod, no file-based config — minimal @loreai/core dependency
4:  * (only `normalizeRemoteUrl` for git URL canonicalization).
5:  */
6: 
7: import {
8:   normalizeRemoteUrl,
9:   discoverWorkspaceRoot,
10:   UNATTRIBUTED_PROJECT_PREFIX,
11:   isUnattributedProjectPath,
12: } from "@loreai/core";
13: 
14: // ---------------------------------------------------------------------------
15: // Port defaults
16: // ---------------------------------------------------------------------------
17: 
18: /**
19:  * Default port preference order when LORE_LISTEN_PORT is not set. ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/core/src/config.ts</path>
<type>file</type>
<content>
1: import { z } from "zod";
2: import { existsSync, readFileSync } from "node:fs";
3: import { join } from "node:path";
4: import { isHostedMode } from "./hosted";
5: import { warn } from "./log";
6: 
7: /**
8:  * Strip JS-style comments from a JSON string, enabling JSONC support for
9:  * `.lore.json`. Preserves `//` and `/* ... *​/` inside quoted strings.
10:  * Also removes trailing commas before `}` or `]`.
11:  */
12: function stripJsonComments(str: string): string {
13:   return str
14:     .replace(
15:       /("(?:[^"\\]|\\.)*")|\/\/[^\n]*|\/\*[\s\S]*?\*\//g,
16:       (_m, s) => s ?? "",
17:     )
18:     .replace(/,\s*([}\]])/g, "$1");
19: }
20: 
21: export const LoreConfig = z.object({
22:   model: z
23:     .object({
24:       providerID: z.string(),
25:       modelID: z.string(),
26:     })
27:     ...

Found 42 matches
/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/pipeline.ts:
  Line 141: import { createGatewayLLMClient } from "./llm-adapter";

  Line 160:   getWorkerModel,

  Line 904:     // Worker-specific auth: when LORE_WORKER_API_KEY is set, workers use a

  Line 908:     const workerApiKey = config.workerApiKey;

  Line 912:     ) => AuthCredential | null = workerApiKey

  Line 913:       ? () => ({ scheme: "api-key", value: workerApiKey })

  Line 916:     // Worker-specific upstream: when LORE_WORKER_UPSTREAM is set, all worker

  Line 922:     if (config.workerApiKey || config.workerUpstream) {

  Line 925:           `auth=${config.workerApiKey ? "dedicated key" : "session"}, ` +

  Line 930:     const rawClient = createGatewayLLMClient(

  Line 934:       { dedicatedWorkerKey: !!workerApiKey },

  Line 944:     // When a dedicated worker API key is set (LORE_WORKER_API_KEY), skip

  Line 948:         if ...

Found 25 matches
/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/ui.ts:
  Line 1522:         ? ` <span title="Provisional: created when the gateway couldn't determine a project. Will self-heal or can be consolidated via 'lore data consolidate'." style="font-size:0.72em;padding:1px 5px;border-radius:6px;background:var(--bg3);color:var(--fg3);vertical-align:middle">provisional</span>`


/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/pipeline.ts:
  Line 1083:   // what later lets self-heal and `lore data consolidate` match a provisional

  Line 3060:   // threshold to consolidate gen-0 segments earlier — shrinks the distilled

  Line 3098:           distillation.run({

  Line 3140:           () => curator.run({ llm, projectPath, sessionID, model }),

  Line 3192:   await distillation.run({

  Line 3237:             `### Chunk ${i + 1}${d.generation > 0 ? ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
895: 
896: function getLLMClient(config: GatewayConfig): LLMClient {
897:   if (!llmClient) {
898:     const cfg = loreConfig();
899:     const defaultModel = cfg.model ?? {
900:       providerID: "anthropic",
901:       modelID: "claude-sonnet-4-6",
902:     };
903: 
904:     // Worker-specific auth: when LORE_WORKER_API_KEY is set, workers use a
905:     // dedicated credential instead of the session's client key. This enables
906:     // routing workers to a different provider (e.g. MiniMax) while sessions
907:     // continue using Anthropic. Falls back to session auth when not set.
908:     const workerApiKey = config.workerApiKey;
909:     const getWorkerAuth: (
910:       sessionID?: string,
911:       providerID?: string,
912:     ) => AuthCredential | null = workerApiKey
913:       ? ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/idle.ts</path>
<type>file</type>
<content>
450:  *  4. Temporal pruning
451:  *  5. AGENTS.md export
452:  *  6. Dead reference cleanup
453:  *  7. lat.md refresh
454:  *
455:  * Each step is independently try/catch'd — one failure won't block the rest.
456:  *
457:  * @param llm - LLM client for worker calls (distillation, curation)
458:  */
459: export function buildIdleWorkHandler(
460:   llm: LLMClient,
461: ): (sessionID: string, state: SessionState) => Promise<void> {
462:   return async (sessionID: string, state: SessionState) => {
463:     const projectPath = state.projectPath;
464:     const cfg = loreConfig();
465:     const model = getWorkerModel(state.lastUpstream);
466: 
467:     // 1. Distillation — force-distill ALL pending messages on idle, even
468:     // below minMessages. ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
3040:   const { sessionID, projectPath } = sessionState;
3041: 
3042:   // Skip background work when the session's auth credential is stale and no
3043:   // fresh fallback is available — worker LLM calls would just 401.
3044:   // Auth refreshes when the next client request arrives via setSessionAuth().
3045:   if (isAuthStale(sessionID) && !resolveAuth(sessionID)) return;
3046: 
3047:   const llm = getLLMClient(config);
3048:   const cfg = loreConfig();
3049:   const model = getWorkerModel(sessionState.lastUpstream);
3050: 
3051:   // When the OAuth account is near quota exhaustion, skip non-urgent
3052:   // background work to preserve remaining entitlement for user-facing turns.
3053:   // Urgent distillation is exempt (it unblocks the next user turn). ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
3160:       })
3161:       .catch((e) => log.error("background curation failed:", e));
3162:   }
3163: }
3164: 
3165: // ---------------------------------------------------------------------------
3166: // Compaction summary generation — shared by HTTP interception and /v1/compact
3167: // ---------------------------------------------------------------------------
3168: 
3169: /**
3170:  * Generate a compaction summary for a session. Force-distills any pending
3171:  * messages, loads existing distillation summaries, builds a knowledge block,
3172:  * and calls the LLM to produce a compaction summary. ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
975:         getWorkerAuth,
976:         defaultModel,
977:       );
978:       batchQueueEnabled = true;
979:     }
980:   }
981:   return llmClient;
982: }
983: 
984: // ---------------------------------------------------------------------------
985: // Project path resolution with session cache
986: // ---------------------------------------------------------------------------
987: 
988: /**
989:  * Resolve the final project path for a session, applying sticky per-session
990:  * binding and (on remote gateways) synthetic "unattributed" bucketing.
991:  *
992:  * Context: some requests (Claude Code's haiku side-channel / prompt-cache
993:  * probes) carry stripped-down system prompts that lack any path reference, so
994:  * `getProjectPath()` returns `source: "cwd"`. ...

Found 38 matches
/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/translate/types.ts:
  Line 322:  *  lastProviderID, lastUpstreamUrl, lastAnthropicBeta. */

  Line 323: export interface UpstreamSnapshot {

  Line 432:   lastUpstream?: UpstreamSnapshot;

  Line 437:   upstreamByProvider: Map<string, UpstreamSnapshot>;


/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/pipeline.ts:
  Line 71:   UpstreamSnapshot,

  Line 940:     // protocol from the UpstreamSnapshot is the source of truth — it was

  Line 950:           if (state?.lastUpstream?.url) {

  Line 953:               upstreamUrl: state.lastUpstream.url,

  Line 954:               protocol: state.lastUpstream.protocol,

  Line 2885:             sessionState.lastUpstream?.model ?? req.model,

  Line 2934:     const upstreamSnapshot: UpstreamSnapshot = {

  Line 2945:     const prevUpstream = ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/translate/types.ts</path>
<type>file</type>
<content>
315:   bustCount: number;
316: };
317: 
318: /** Routing snapshot captured from the last successful session request.
319:  *  Workers (distillation, curation) and the cache warmer use this
320:  *  to route through the same upstream with matching credentials.
321:  *  Single source of truth — replaces lastModel, lastProtocol,
322:  *  lastProviderID, lastUpstreamUrl, lastAnthropicBeta. */
323: export interface UpstreamSnapshot {
324:   /** Resolved upstream base URL (e.g., "https://api.minimax.io/anthropic"). */
325:   url: string;
326:   /** Wire protocol used for the request. */
327:   protocol: "anthropic" | "openai" | "openai-responses";
328:   /** Provider ID from X-Lore-Provider header (for worker model selection). */
329:   providerID?: string;
330:   /** Session model ID (for cost-aware worker model ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
2920:     // warmer, and idle handler all read from this single source of truth
2921:     // instead of reconstructing from individual last* fields.
2922:     const lpProvider = extractProviderHeader(req.rawHeaders);
2923:     const lpRoute = lpProvider ? resolveProviderRoute(lpProvider) : null;
2924:     const lpHeaderUpstream = extractUpstreamUrlHeader(req.rawHeaders);
2925:     const lpRouteUsable =
2926:       lpRoute && (lpRoute.url != null || lpHeaderUpstream) ? lpRoute : null;
2927:     const snapshotProtocol: "anthropic" | "openai" | "openai-responses" =
2928:       req.protocol === "openai-responses"
2929:         ? "openai-responses"
2930:         : (lpRouteUsable?.protocol ??
2931:           resolveUpstreamRoute(req.model)?.protocol ??
2932:           req.protocol);
2933: 
2934:     const upstreamSnapshot: ...

Found 10 matches
/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/pipeline.ts:
  Line 872:     const llm = getLLMClient(config);

  Line 896: function getLLMClient(config: GatewayConfig): LLMClient {

  Line 899:     const defaultModel = cfg.model ?? {

  Line 933:       defaultModel,

  Line 976:         defaultModel,

  Line 1966:               getLLMClient(recallContext.config),

  Line 3047:   const llm = getLLMClient(config);

  Line 3187:   const llm = getLLMClient(config);

  Line 4642:         getLLMClient(config),

  Line 5343:   const llm = getLLMClient(config);

Found 4 matches
/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/pipeline.ts:
  Line 142: import { createBatchLLMClient } from "./batch-queue";

  Line 972:       llmClient = createBatchLLMClient(


/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/batch-queue.ts:
  Line 597: // BatchLLMClient

  Line 618: export function createBatchLLMClient(

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
2980:     }
2981: 
2982:     // --- Shadow context tracking for counterfactual compaction estimation ---
2983:     // Track how large the context *would* be without Lore's distillation
2984:     // compressing it. When the shadow counter crosses the auto-compact
2985:     // threshold, record a counterfactual compaction event.
2986:     updateShadowContext(
2987:       sessionID,
2988:       actualInput,
2989:       usage.outputTokens ?? 0,
2990:       getWorkerModel(sessionState.lastUpstream)?.modelID ?? "unknown",
2991:       req.model,
2992:       sessionState.resolvedConversationTTL,
2993:     );
2994: 
2995:     // Mark session dirty for periodic flush (gradient + warming + costs).
2996:     // The 30s idle tick will persist state only for dirty sessions.
2997:     sessionState._dirty = true;
2998: 
2999:     // --- ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/batch-queue.ts</path>
<type>file</type>
<content>
590:       // "validating", "in_progress", "finalizing", "cancelling" — still pending
591:       return { status: "pending" };
592:     },
593:   };
594: }
595: 
596: // ---------------------------------------------------------------------------
597: // BatchLLMClient
598: // ---------------------------------------------------------------------------
599: 
600: /**
601:  * Create a batch-aware LLMClient that wraps a synchronous inner client.
602:  *
603:  * - `urgent: true` calls → immediate delegation to `inner.prompt()`
604:  * - `urgent: false/undefined` calls → queued for batch processing
605:  * - On flush timer or queue full → submit to provider-specific batch API
606:  * - On poll timer → check status and resolve promises
607:  * - On error → fallback to synchronous calls for the failed batch
608:  *
609:  * ...

Found 7 matches
/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/pipeline.ts:
  Line 1617:   const modelRoute = resolveUpstreamRoute(req.model);

  Line 2931:           resolveUpstreamRoute(req.model)?.protocol ??

  Line 3933:         resolveUpstreamRoute(req.model)?.url ??

  Line 4555:           resolveUpstreamRoute(req.model)?.protocol ??


/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/config.ts:
  Line 217: export function resolveUpstreamRoute(model: string): UpstreamRoute | null {

  Line 237:  * gateway where to forward the request when `resolveUpstreamRoute()` returns


/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/cache-warmer.ts:
  Line 693:   const route = resolveUpstreamRoute(model);

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
5335:       req,
5336:       "No active session found for curation.",
5337:       "msg_lore_curate_none",
5338:     );
5339:   }
5340: 
5341:   const projectPath = state.projectPath;
5342:   const { distillation, curator } = await import("@loreai/core");
5343:   const llm = getLLMClient(config);
5344:   const model = getWorkerModel(state.lastUpstream);
5345: 
5346:   log.info(`/lore:curate: running for session=${sessionID.slice(0, 16)}`);
5347: 
5348:   // Force-distill all pending messages (urgent bypasses batch queue)
5349:   let distilled = 0;
5350:   try {
5351:     const dResult = await distillation.run({
5352:       llm,
5353:       projectPath,
5354:       sessionID,
5355:       model,
5356:       force: true,
5357:       skipMeta: true,
5358:       urgent: true,
5359:       callType: "direct",
5360:     });
5361: ...

Found 2 matches
/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/batch-queue.ts:
  Line 194: export function createAnthropicBatchProvider(

  Line 479: export function createOpenAIBatchProvider(upstreamUrl: string): BatchProvider {

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/pipeline.ts</path>
<type>file</type>
<content>
1955: 
1956:           // eslint-disable-next-line no-constant-condition
1957:           while (true) {
1958:             const recallBlock = findRecallToolUse(currentResp);
1959:             if (!recallBlock) break;
1960: 
1961:             recallDepth++;
1962:             const { result, input } = await executeRecall(
1963:               recallBlock,
1964:               recallContext.sessionState.projectPath,
1965:               recallContext.sessionState.sessionID,
1966:               getLLMClient(recallContext.config),
1967:             );
1968: 
1969:             const scope = input.scope ?? "all";
1970: 
1971:             // Store recall result for marker round-trip expansion
1972:             const storeKey = recallStoreKey(input.query, scope, input.id);
1973:             const position = ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/core/src/index.ts</path>
<type>file</type>
<content>
1: // @loreai/core — shared memory engine for Lore.
2: //
3: // This barrel re-exports every core module so hosts (the OpenCode plugin, the
4: // Pi extension, or any future adapter) can import from a single entry:
5: //
6: //   import { ltm, temporal, gradient, ... } from "@loreai/core"
7: //
8: // Modules that are intentionally not re-exported:
9: // - `db.ts` internals are exposed via specific functions (db(), ensureProject(), etc.)
10: // - No Plugin/Hooks surface — those live in host-specific packages.
11: 
12: export * as temporal from "./temporal";
13: export * as ltm from "./ltm";
14: export * as data from "./data";
15: export * as distillation from "./distillation";
16: export * as curator from "./curator";
17: export * as embedding from "./embedding";
18: export * as embeddingVendor from "./embedding-vendor";
19: ...

No files found

No files found

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/cli/import.ts</path>
<type>file</type>
<content>
230:   console.log("\n[lore] Starting gateway for LLM access...");
231: 
232:   // Import always runs locally — reading local agent history files.
233:   const startOpts: StartOptions = { quiet: true, local: true };
234:   const { config, owned, shutdown } = await startGateway(startOpts);
235:   const cfg = loreConfig();
236:   const defaultModel = cfg.model ?? {
237:     providerID: "anthropic",
238:     modelID: "claude-sonnet-4-6",
239:   };
240:   const llm = createGatewayLLMClient(
241:     { anthropic: config.upstreamAnthropic, openai: config.upstreamOpenAI },
242:     resolveAuth,
243:     defaultModel,
244:   );
245: 
246:   try {
247:     let totalCreated = 0;
248:     let totalUpdated = 0;
249:     let totalDeleted = 0;
250:     let _totalChunks = 0;
251:     let totalFailed = 0;
252: 
253:     for (const ...

Found 12 matches
/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/llm-adapter.ts:
  Line 8:  * UpstreamSnapshot (threaded via opts.protocol), with fallback to the

  Line 42: /** Tracks worker session IDs so temporal capture can skip them. */

  Line 389:  * @param getAuth       Callback to resolve auth credentials (per-session → global fallback)

  Line 404:         log.warn("no auth credentials available for worker call");

  Line 418:       // Also skip when an upstream override is active — the session routes

  Line 424:           log.warn(

  Line 425:             `worker protocol mismatch: ${target.protocol} target with non-Anthropic API key — skipping (model=${model.modelID}, worker=${opts?.workerID ?? "unknown"})`,

  Line 430:           log.warn(

  Line 431:             `worker protocol mismatch: ${target.protocol} target with Anthropic API key — skipping (model=${model.modelID}, worker=${opts?.workerID ?? ...

Found 67 matches
/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/pipeline.ts:
  Line 154:   isAuthStale,

  Line 383: /** Sessions that have already logged the cwd-fallback warning (dedup). */

  Line 503: // Model limits — fetched from models.dev, fallback for unknown

  Line 641:  * Start watching `.lore.md` (and the agents file as fallback) for changes.

  Line 681:   // Watch agents file (AGENTS.md etc.) as fallback

  Line 900:       providerID: "anthropic",

  Line 908:     const workerApiKey = config.workerApiKey;

  Line 911:       providerID?: string,

  Line 912:     ) => AuthCredential | null = workerApiKey

  Line 913:       ? () => ({ scheme: "api-key", value: workerApiKey })

  Line 922:     if (config.workerApiKey || config.workerUpstream) {

  Line 925:           `auth=${config.workerApiKey ? "dedicated key" : "session"}, ` +

  Line 934:       { dedicatedWorkerKey: !!workerApiKey },

  Line 937:     // ...

Found 24 matches
/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/translate/types.ts:
  Line 499:  * explicitly (extractAuth + authHeaders) to preserve the correct scheme.

  Line 524:   // Auth — handled separately by each builder (extractAuth + authHeaders)


/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/translate/openai.ts:
  Line 15: import { extractAuth } from "../auth";

  Line 488:   const cred = extractAuth(req.rawHeaders);


/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/translate/openai-responses.ts:
  Line 22: import { extractAuth } from "../auth";

  Line 274:   const cred = extractAuth(req.rawHeaders);


/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/translate/anthropic.ts:
  Line 16: import { extractAuth, ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/idle.ts</path>
<type>file</type>
<content>
125: 
126:   const timer = setInterval(() => {
127:     const now = Date.now();
128:     const timeoutMs = config.idleTimeoutSeconds * 1000;
129: 
130:     // --- Idle work (distillation, curation, etc.) ---
131:     for (const [sessionID, state] of sessions) {
132:       if (inProgress.has(sessionID)) continue;
133:       if (now - state.lastRequestTime < timeoutMs) continue;
134: 
135:       // Skip idle work when the agent is executing a tool — the session
136:       // is still active, not genuinely idle. Distillation/curation should
137:       // wait for the actual idle period after the tool-use turn completes.
138:       if (state.lastStopReason === "tool_use") continue;
139: 
140:       // Skip sessions with stale auth credentials — background LLM calls
141:       // (distillation, curation) would just 401, flooding ...

<path>/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/llm-adapter.ts</path>
<type>file</type>
<content>
399:   return {
400:     async prompt(system, user, opts) {
401:       const model = opts?.model ?? defaultModel;
402:       const cred = getAuth(opts?.sessionID, model.providerID);
403:       if (!cred) {
404:         log.warn("no auth credentials available for worker call");
405:         return null;
406:       }
407:       const upstreamOverride = opts?.upstreamUrl;
408:       const protocol = resolveWorkerProtocol(model.providerID, opts?.protocol);

(Showing lines 399-408 of 753. Use offset=409 to continue.)
</content>

Found 1 matches
/home/byk/.local/share/opencode/worktree/51d1015fd1f616acf9a5ffaad9331ec6b304586b/witty-wolf/packages/gateway/src/llm-adapter.ts:
  Line 401:       const model = opts?.model ?? defaultModel;