perf: fast-path all memory reads via direct SQL (312x grep, 8.7x e2e)

.github/workflows/ci.yml

@@ -22,8 +22,28 @@ jobs:
       - name: Install dependencies
         run: npm install
 
-      - name: Run CI checks
-        run: npm run ci
+      - name: Typecheck
+        run: npm run typecheck
+
+      - name: Run tests with coverage
+        run: npx vitest run --coverage --coverage.reporter=text --coverage.reporter=json-summary
+
+      - name: Coverage summary
+        if: always()
+        run: |
+          if [ -f coverage/coverage-summary.json ]; then
+            echo "### Test Coverage" >> $GITHUB_STEP_SUMMARY
+            node -e "
+              const c = require('./coverage/coverage-summary.json').total;
+              const fmt = (v) => v.pct.toFixed(1) + '%';
+              console.log('| Metric | Coverage |');
+              console.log('|--------|----------|');
+              console.log('| Statements | ' + fmt(c.statements) + ' |');
+              console.log('| Branches | ' + fmt(c.branches) + ' |');
+              console.log('| Functions | ' + fmt(c.functions) + ' |');
+              console.log('| Lines | ' + fmt(c.lines) + ' |');
+            " >> $GITHUB_STEP_SUMMARY
+          fi
 
       - name: Build bundles
         run: npm run build

.github/workflows/release.yml

@@ -95,10 +95,27 @@ jobs:
         env:
           GH_TOKEN: ${{ secrets.GITHUB_TOKEN }}
 
+      - name: Get merged PR description
+        if: steps.check.outputs.exists == 'false'
+        id: pr
+        run: |
+          # Find the most recent merged PR targeting main
+          PR_BODY=$(gh pr list --state merged --base main --limit 1 --json body,title -q '.[0].body // ""')
+          PR_TITLE=$(gh pr list --state merged --base main --limit 1 --json title -q '.[0].title // ""')
+          {
+            echo "body<<ENDOFBODY"
+            echo "$PR_BODY"
+            echo "ENDOFBODY"
+            echo "title=$PR_TITLE"
+          } >> "$GITHUB_OUTPUT"
+        env:
+          GH_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+
       - name: Create GitHub Release
         if: steps.check.outputs.exists == 'false'
         uses: softprops/action-gh-release@v2
         with:
           tag_name: ${{ steps.version.outputs.version }}
-          name: ${{ steps.version.outputs.version }}
-          generate_release_notes: true
+          name: "${{ steps.version.outputs.version }} — ${{ steps.pr.outputs.title }}"
+          body: ${{ steps.pr.outputs.body }}
+          generate_release_notes: false

.gitignore

@@ -9,3 +9,5 @@ coverage/
 bench/
 .claude/
 CLAUDE.md
+RESULTS-fast-path-all-commands.md
+PLAN-fast-path-all-commands.md

claude-code/bundle/capture.js

@@ -72,6 +72,20 @@ function sqlStr(value) {
 
 // dist/src/deeplake-api.js
 var log2 = (msg) => log("sdk", msg);
+var TRACE_SQL = process.env.DEEPLAKE_TRACE_SQL === "1" || process.env.DEEPLAKE_DEBUG === "1";
+var DEBUG_FILE_LOG = process.env.DEEPLAKE_DEBUG === "1";
+function summarizeSql(sql, maxLen = 220) {
+  const compact = sql.replace(/\s+/g, " ").trim();
+  return compact.length > maxLen ? `${compact.slice(0, maxLen)}...` : compact;
+}
+function traceSql(msg) {
+  if (!TRACE_SQL)
+    return;
+  process.stderr.write(`[deeplake-sql] ${msg}
+`);
+  if (DEBUG_FILE_LOG)
+    log2(msg);
+}
 var RETRYABLE_CODES = /* @__PURE__ */ new Set([429, 500, 502, 503, 504]);
 var MAX_RETRIES = 3;
 var BASE_DELAY_MS = 500;
@@ -119,9 +133,18 @@ var DeeplakeApi = class {
   }
   /** Execute SQL with retry on transient errors and bounded concurrency. */
   async query(sql) {
+    const startedAt = Date.now();
+    const summary = summarizeSql(sql);
+    traceSql(`query start: ${summary}`);
     await this._sem.acquire();
     try {
-      return await this._queryWithRetry(sql);
+      const rows = await this._queryWithRetry(sql);
+      traceSql(`query ok (${Date.now() - startedAt}ms, rows=${rows.length}): ${summary}`);
+      return rows;
+    } catch (e) {
+      const message = e instanceof Error ? e.message : String(e);
+      traceSql(`query fail (${Date.now() - startedAt}ms): ${summary} :: ${message}`);
+      throw e;
     } finally {
       this._sem.release();
     }

claude-code/bundle/commands/auth-login.js

@@ -256,6 +256,20 @@ function sqlStr(value) {
 
 // dist/src/deeplake-api.js
 var log2 = (msg) => log("sdk", msg);
+var TRACE_SQL = process.env.DEEPLAKE_TRACE_SQL === "1" || process.env.DEEPLAKE_DEBUG === "1";
+var DEBUG_FILE_LOG = process.env.DEEPLAKE_DEBUG === "1";
+function summarizeSql(sql, maxLen = 220) {
+  const compact = sql.replace(/\s+/g, " ").trim();
+  return compact.length > maxLen ? `${compact.slice(0, maxLen)}...` : compact;
+}
+function traceSql(msg) {
+  if (!TRACE_SQL)
+    return;
+  process.stderr.write(`[deeplake-sql] ${msg}
+`);
+  if (DEBUG_FILE_LOG)
+    log2(msg);
+}
 var RETRYABLE_CODES = /* @__PURE__ */ new Set([429, 500, 502, 503, 504]);
 var MAX_RETRIES = 3;
 var BASE_DELAY_MS = 500;
@@ -303,9 +317,18 @@ var DeeplakeApi = class {
   }
   /** Execute SQL with retry on transient errors and bounded concurrency. */
   async query(sql) {
+    const startedAt = Date.now();
+    const summary = summarizeSql(sql);
+    traceSql(`query start: ${summary}`);
     await this._sem.acquire();
     try {
-      return await this._queryWithRetry(sql);
+      const rows = await this._queryWithRetry(sql);
+      traceSql(`query ok (${Date.now() - startedAt}ms, rows=${rows.length}): ${summary}`);
+      return rows;
+    } catch (e) {
+      const message = e instanceof Error ? e.message : String(e);
+      traceSql(`query fail (${Date.now() - startedAt}ms): ${summary} :: ${message}`);
+      throw e;
     } finally {
       this._sem.release();
     }