marketing-shibata50/9router
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(cursor): remove sql.js dependency from auto-import route (#368)

Browse source 
* fix(usage): track lifetime request total beyond history cap

* fix(ui): restore provider assets and model availability endpoint

* fix(cursor): remove sql.js dependency from auto-import route
This commit is contained in:
Andrew Peltekci 2026-03-22 19:17:42 -07:00 • committed by GitHub
parent 9fe4726f34
commit 3f852775c6
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 71 additions and 75 deletions
Download patch file Download diff file Expand all files Collapse all files

146
src/app/api/oauth/cursor/auto-import/route.js
View file

@ -1,5 +1,5 @@
import { NextResponse } from "next/server";
import { access, constants, readFile } from "fs/promises";
import { access, constants } from "fs/promises";
import { homedir } from "os";
import { join } from "path";
import { execFile } from "child_process";
@ -8,7 +8,11 @@ import { promisify } from "util";
const execFileAsync = promisify(execFile);
const ACCESS_TOKEN_KEYS = ["cursorAuth/accessToken", "cursorAuth/token"];
const MACHINE_ID_KEYS = ["storage.serviceMachineId", "storage.machineId", "telemetry.machineId"];
const MACHINE_ID_KEYS = [
"storage.serviceMachineId",
"storage.machineId",
"telemetry.machineId",
];
/** Get candidate db paths by platform */
function getCandidatePaths(platform) {
@ -16,19 +20,39 @@ function getCandidatePaths(platform) {
if (platform === "darwin") {
return [
join(home, "Library/Application Support/Cursor/User/globalStorage/state.vscdb"),
join(home, "Library/Application Support/Cursor - Insiders/User/globalStorage/state.vscdb"),
join(
home,
"Library/Application Support/Cursor/User/globalStorage/state.vscdb",
),
join(
home,
"Library/Application Support/Cursor - Insiders/User/globalStorage/state.vscdb",
),
];
}
if (platform === "win32") {
const appData = process.env.APPDATA || join(home, "AppData", "Roaming");
const localAppData = process.env.LOCALAPPDATA || join(home, "AppData", "Local");
const localAppData =
process.env.LOCALAPPDATA || join(home, "AppData", "Local");
return [
join(appData, "Cursor", "User", "globalStorage", "state.vscdb"),
join(appData, "Cursor - Insiders", "User", "globalStorage", "state.vscdb"),
join(
appData,
"Cursor - Insiders",
"User",
"globalStorage",
"state.vscdb",
),
join(localAppData, "Cursor", "User", "globalStorage", "state.vscdb"),
join(localAppData, "Programs", "Cursor", "User", "globalStorage", "state.vscdb"),
join(
localAppData,
"Programs",
"Cursor",
"User",
"globalStorage",
"state.vscdb",
),
];
}
@ -48,54 +72,9 @@ const normalize = (value) => {
}
};
/** Extract tokens using sql.js (pure JS, cross-platform) */
async function extractTokens(dbPath) {
const initSqlJs = (await import("sql.js")).default;
const SQL = await initSqlJs();
const db = new SQL.Database(await readFile(dbPath));
const queryAll = (sql, params = []) => {
const stmt = db.prepare(sql);
stmt.bind(params);
const rows = [];
while (stmt.step()) rows.push(stmt.getAsObject());
stmt.free();
return rows;
};
const desiredKeys = [...ACCESS_TOKEN_KEYS, ...MACHINE_ID_KEYS];
const placeholders = desiredKeys.map(() => "?").join(",");
const rows = queryAll(`SELECT key, value FROM itemTable WHERE key IN (${placeholders})`, desiredKeys);
const tokens = {};
for (const row of rows) {
if (ACCESS_TOKEN_KEYS.includes(row.key) && !tokens.accessToken) {
tokens.accessToken = normalize(row.value);
} else if (MACHINE_ID_KEYS.includes(row.key) && !tokens.machineId) {
tokens.machineId = normalize(row.value);
}
}
// Fuzzy fallback
if (!tokens.accessToken || !tokens.machineId) {
const fallbackRows = queryAll(
"SELECT key, value FROM itemTable WHERE key LIKE '%cursorAuth/%' OR key LIKE '%machineId%' OR key LIKE '%serviceMachineId%'"
);
for (const row of fallbackRows) {
const key = row.key || "";
const value = normalize(row.value);
if (!tokens.accessToken && key.toLowerCase().includes("accesstoken")) tokens.accessToken = value;
if (!tokens.machineId && key.toLowerCase().includes("machineid")) tokens.machineId = value;
}
}
db.close();
return tokens;
}
/**
* Extract tokens via sqlite3 CLI (fallback for Windows when native addon fails)
* Queries each key individually and parses output
* Extract tokens via sqlite3 CLI.
* Keeps the route build-safe by avoiding optional sql.js bundling.
*/
async function extractTokensViaCLI(dbPath) {
const normalize = (raw) => {
@ -109,7 +88,9 @@ async function extractTokensViaCLI(dbPath) {
};
const query = async (sql) => {
const { stdout } = await execFileAsync("sqlite3", [dbPath, sql], { timeout: 10000 });
const { stdout } = await execFileAsync("sqlite3", [dbPath, sql], {
timeout: 10000,
});
return stdout.trim();
};
@ -117,17 +98,31 @@ async function extractTokensViaCLI(dbPath) {
let accessToken = null;
for (const key of ACCESS_TOKEN_KEYS) {
try {
const raw = await query(`SELECT value FROM itemTable WHERE key='${key}' LIMIT 1`);
if (raw) { accessToken = normalize(raw); break; }
} catch { /* try next */ }
const raw = await query(
`SELECT value FROM itemTable WHERE key='${key}' LIMIT 1`,
);
if (raw) {
accessToken = normalize(raw);
break;
}
} catch {
/* try next */
}
}
let machineId = null;
for (const key of MACHINE_ID_KEYS) {
try {
const raw = await query(`SELECT value FROM itemTable WHERE key='${key}' LIMIT 1`);
if (raw) { machineId = normalize(raw); break; }
} catch { /* try next */ }
const raw = await query(
`SELECT value FROM itemTable WHERE key='${key}' LIMIT 1`,
);
if (raw) {
machineId = normalize(raw);
break;
}
} catch {
/* try next */
}
}
return { accessToken, machineId };
@ -136,7 +131,7 @@ async function extractTokensViaCLI(dbPath) {
/**
* GET /api/oauth/cursor/auto-import
* Auto-detect and extract Cursor tokens from local SQLite database.
* Strategy: better-sqlite3 (native, fast) → sqlite3 CLI (fallback) → windowsManual
* Strategy: sqlite3 CLI → manual fallback
*/
export async function GET() {
try {
@ -161,26 +156,27 @@ export async function GET() {
});
}
// Strategy 1: sql.js (pure JS WASM, cross-platform)
try {
const tokens = await extractTokens(dbPath);
if (tokens.accessToken && tokens.machineId) {
return NextResponse.json({ found: true, accessToken: tokens.accessToken, machineId: tokens.machineId });
}
} catch { /* fall through to sqlite3 CLI strategy */ }
// Strategy 2: sqlite3 CLI (works on Windows if sqlite3 is installed)
// Strategy 1: sqlite3 CLI
try {
const tokens = await extractTokensViaCLI(dbPath);
if (tokens.accessToken && tokens.machineId) {
return NextResponse.json({ found: true, accessToken: tokens.accessToken, machineId: tokens.machineId });
return NextResponse.json({
found: true,
accessToken: tokens.accessToken,
machineId: tokens.machineId,
});
}
} catch { /* sqlite3 CLI not available */ }
} catch {
// sqlite3 CLI not available
}
// Strategy 3: ask user to paste manually
// Strategy 2: ask user to paste manually
return NextResponse.json({ found: false, windowsManual: true, dbPath });
} catch (error) {
console.log("Cursor auto-import error:", error);
return NextResponse.json({ found: false, error: error.message }, { status: 500 });
return NextResponse.json(
{ found: false, error: error.message },
{ status: 500 },
);
}
}