mirror of
https://github.com/diegosouzapw/OmniRoute.git
synced 2026-08-21 06:32:16 +03:00
Compare commits
1 Commits
fix/10815-
...
fix/7346-m
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
b9b517281d |
@@ -1 +0,0 @@
|
||||
- fix(db): disambiguate `createProviderConnection()`'s OAuth email dedup by `providerSpecificData.profileArn` in addition to `username`, so adding a second Kiro/AWS profile with the same email creates a new connection instead of silently merging into the first (#10815)
|
||||
@@ -0,0 +1 @@
|
||||
- fix(cli): repair hollow externalized package dirs in the nested `<distDir>/node_modules` bundle location too, not just the top-level one, fixing macOS/Linux Electron `ERR_MODULE_NOT_FOUND` on Turbopack-externalized packages (#7346)
|
||||
@@ -628,12 +628,11 @@ function copyNativeAssetsAndExtraModules(projectRoot, resolvedOutDir) {
|
||||
* This keeps the fix narrowly scoped to packages the standalone already expects.
|
||||
*
|
||||
* @param {string} projectRoot
|
||||
* @param {string} resolvedOutDir
|
||||
* @param {string} bundleNodeModules
|
||||
* @returns {{repaired: number, packages: string[]}}
|
||||
*/
|
||||
function repairEmptyExternalPackageDirs(projectRoot, resolvedOutDir) {
|
||||
function repairEmptyExternalPackageDirs(projectRoot, bundleNodeModules) {
|
||||
const summary = { repaired: 0, packages: [] };
|
||||
const bundleNodeModules = path.join(resolvedOutDir, "node_modules");
|
||||
const sourceNodeModules = path.join(projectRoot, "node_modules");
|
||||
if (!fsSync.existsSync(bundleNodeModules) || !fsSync.existsSync(sourceNodeModules)) {
|
||||
return summary;
|
||||
@@ -899,12 +898,23 @@ export function assembleStandalone({
|
||||
// 6. Optionally copy native assets + extra modules (synchronous)
|
||||
if (copyNatives) {
|
||||
copyNativeAssetsAndExtraModules(projectRoot, resolvedOutDir);
|
||||
const emptyPkgRepair = repairEmptyExternalPackageDirs(projectRoot, resolvedOutDir);
|
||||
if (emptyPkgRepair.repaired > 0) {
|
||||
console.log(
|
||||
`[assembleStandalone] Repaired ${emptyPkgRepair.repaired} hollow external package dir(s): ` +
|
||||
emptyPkgRepair.packages.join(", ")
|
||||
);
|
||||
// Repair hollow externalized package dirs in BOTH locations Turbopack's standalone
|
||||
// tracer can populate: the top-level bundle node_modules, and — for projects with a
|
||||
// custom distDir (see next.config.mjs) — the nested <relDistDir>/node_modules mirrored
|
||||
// alongside the traced server chunks. materializeBundledSymlinks (step 7 below) already
|
||||
// treats these as two distinct targets; #9913 only covered the top-level one, which left
|
||||
// the nested location's hollow dirs unrepaired (#7346).
|
||||
for (const bundleNodeModules of [
|
||||
path.join(resolvedOutDir, "node_modules"),
|
||||
path.join(resolvedOutDir, relDistDir, "node_modules"),
|
||||
]) {
|
||||
const emptyPkgRepair = repairEmptyExternalPackageDirs(projectRoot, bundleNodeModules);
|
||||
if (emptyPkgRepair.repaired > 0) {
|
||||
console.log(
|
||||
`[assembleStandalone] Repaired ${emptyPkgRepair.repaired} hollow external package dir(s) in ` +
|
||||
`${path.relative(resolvedOutDir, bundleNodeModules) || "."}: ${emptyPkgRepair.packages.join(", ")}`
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
// #9166: dynamically imported LLMLingua packages are not reliably traced
|
||||
|
||||
@@ -26,11 +26,7 @@ import {
|
||||
isBcryptHash,
|
||||
verifyManagementPassword,
|
||||
} from "@/lib/auth/managementPassword";
|
||||
import {
|
||||
webSessionCredentialKey,
|
||||
parseProviderSpecificData,
|
||||
isMatchingOauthIdentity,
|
||||
} from "./webSessionDedup";
|
||||
import { webSessionCredentialKey, parseProviderSpecificData } from "./webSessionDedup";
|
||||
import { pickCodexConnectionForUser } from "@/lib/oauth/utils/codexConnectionSelection";
|
||||
import { reconcileCodexUsageHistory } from "./providers/usageIdentityReconciliation";
|
||||
|
||||
@@ -439,25 +435,30 @@ export async function createProviderConnection(data: JsonRecord) {
|
||||
}
|
||||
} else {
|
||||
// For other providers (or Codex without workspaceId), match on email —
|
||||
// disambiguated by providerSpecificData.username and/or
|
||||
// providerSpecificData.profileArn when present on both sides. Two
|
||||
// different IdPs (or two distinct Kiro/AWS profiles authenticated via
|
||||
// the same email-carrying IdP) can share the same email address;
|
||||
// matching on email alone would silently overwrite the other
|
||||
// account's connection on the second login. Only fall back to the
|
||||
// bare email-only match when neither side carries a username/profileArn
|
||||
// (legacy rows created before this disambiguation existed).
|
||||
// disambiguated by providerSpecificData.username when present on both
|
||||
// sides. Two different IdPs can share the same email address (e.g. a
|
||||
// Google account and a HuggingFace account); matching on email alone
|
||||
// would silently overwrite the other account's connection on the
|
||||
// second login. Only fall back to the bare email-only match when
|
||||
// neither side carries a username (legacy rows created before this
|
||||
// disambiguation existed).
|
||||
const incomingUsername = toStringOrNull(providerSpecificData.username);
|
||||
const incomingProfileArn = toStringOrNull(providerSpecificData.profileArn);
|
||||
const emailMatches = db
|
||||
.prepare(
|
||||
"SELECT * FROM provider_connections WHERE provider = ? AND auth_type = 'oauth' AND email = ?"
|
||||
)
|
||||
.all(data.provider, data.email) as JsonRecord[];
|
||||
existing =
|
||||
emailMatches.find((row) =>
|
||||
isMatchingOauthIdentity(row, incomingUsername, incomingProfileArn)
|
||||
) || null;
|
||||
emailMatches.find((row) => {
|
||||
const existingUsername = toStringOrNull(
|
||||
parseProviderSpecificData(row.provider_specific_data)?.username
|
||||
);
|
||||
if (incomingUsername && existingUsername) {
|
||||
return incomingUsername === existingUsername;
|
||||
}
|
||||
if (incomingUsername || existingUsername) return false;
|
||||
return true;
|
||||
}) || null;
|
||||
}
|
||||
} else if (data.authType === "apikey") {
|
||||
// Name-based upsert (existing behavior): same provider + same name → update.
|
||||
|
||||
@@ -55,43 +55,3 @@ export function parseProviderSpecificData(raw: unknown): Record<string, unknown>
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
/** Trimmed non-empty string, else null — local to avoid a cross-module import for one coercion. */
|
||||
function nonEmptyString(value: unknown): string | null {
|
||||
return typeof value === "string" && value.trim() ? value.trim() : null;
|
||||
}
|
||||
|
||||
/**
|
||||
* Two-sided disambiguator match: `true` when both sides agree, `false` when
|
||||
* both carry a value and it differs, `undefined` when the field can't decide
|
||||
* (at most one side carries it) — the caller then defers to other fields.
|
||||
*/
|
||||
function fieldMatch(incoming: string | null, existing: string | null): boolean | undefined {
|
||||
if (incoming && existing) return incoming === existing;
|
||||
if (incoming || existing) return false;
|
||||
return undefined;
|
||||
}
|
||||
|
||||
/**
|
||||
* Decide whether `row` (an existing `provider_connections` record) is the
|
||||
* same OAuth identity as an incoming connection carrying `incomingUsername`
|
||||
* and `incomingProfileArn` (#10815).
|
||||
*
|
||||
* Two independent disambiguators, either of which can prove "different
|
||||
* account": `providerSpecificData.username` (Raycast-style IdP dedup) and
|
||||
* `providerSpecificData.profileArn` (Kiro/AWS profile dedup — Kiro never
|
||||
* sets `username`). A field only rules a match IN/OUT when both the
|
||||
* incoming and existing record carry it; when neither carries either field
|
||||
* the legacy bare-email match still applies unchanged.
|
||||
*/
|
||||
export function isMatchingOauthIdentity(
|
||||
row: { provider_specific_data?: unknown },
|
||||
incomingUsername: string | null,
|
||||
incomingProfileArn: string | null
|
||||
): boolean {
|
||||
const existingPsd = parseProviderSpecificData(row.provider_specific_data);
|
||||
const usernameMatch = fieldMatch(incomingUsername, nonEmptyString(existingPsd?.username));
|
||||
const profileArnMatch = fieldMatch(incomingProfileArn, nonEmptyString(existingPsd?.profileArn));
|
||||
if (usernameMatch === false || profileArnMatch === false) return false;
|
||||
return true;
|
||||
}
|
||||
|
||||
@@ -0,0 +1,55 @@
|
||||
import { test } from "node:test";
|
||||
import assert from "node:assert/strict";
|
||||
import fs from "node:fs";
|
||||
import os from "node:os";
|
||||
import path from "node:path";
|
||||
|
||||
import { assembleStandalone } from "../../../scripts/build/assembleStandalone.mjs";
|
||||
|
||||
// #7346: on macOS (and Linux AppImage) Electron builds, Turbopack's standalone tracer can leave
|
||||
// a hollow (directory exists, contains zero files) externalized-package directory behind. #9913
|
||||
// added `repairEmptyExternalPackageDirs` to overlay the real source package on top of a hollow
|
||||
// bundle dir — but it only scans the TOP-LEVEL `<outDir>/node_modules`. This project builds with
|
||||
// a custom, non-default `distDir` (".build/next", see next.config.mjs), and Next's standalone
|
||||
// tracer also emits a SECOND, nested `node_modules` under `<outDir>/<relDistDir>/node_modules`
|
||||
// (the same location `materializeBundledSymlinks` already treats as a distinct target — see
|
||||
// assembleStandalone() step 7). A hollow externalized package dir landing in that nested
|
||||
// location is never repaired, which reproduces the exact ERR_MODULE_NOT_FOUND class reported on
|
||||
// #7346 even after #6794/#7353/#9913 all landed.
|
||||
test("assembleStandalone repairs a hollow externalized package dir in the nested <distDir> node_modules, not just the top-level one", () => {
|
||||
const tmp = fs.mkdtempSync(path.join(os.tmpdir(), "repair-nested-empty-pkg-"));
|
||||
const projectRoot = path.join(tmp, "project");
|
||||
const relDistDir = ".build/next";
|
||||
const distDir = path.join(projectRoot, relDistDir);
|
||||
const outDir = path.join(tmp, "dist");
|
||||
|
||||
// Real source package the repair should copy from.
|
||||
const sourcePkgDir = path.join(projectRoot, "node_modules", "some-nested-pkg");
|
||||
fs.mkdirSync(sourcePkgDir, { recursive: true });
|
||||
fs.writeFileSync(path.join(sourcePkgDir, "package.json"), '{"name":"some-nested-pkg"}');
|
||||
fs.writeFileSync(path.join(sourcePkgDir, "index.js"), "module.exports = {};");
|
||||
|
||||
// Fake standalone tree with a hollow externalized package dir under the NESTED
|
||||
// <relDistDir>/node_modules (directory exists but contains zero files — the exact
|
||||
// "hollow" shape repairEmptyExternalPackageDirs already repairs at the top level).
|
||||
const standaloneDir = path.join(distDir, "standalone");
|
||||
fs.mkdirSync(standaloneDir, { recursive: true });
|
||||
fs.writeFileSync(path.join(standaloneDir, "server.js"), "// server");
|
||||
const hollowNestedPkgDir = path.join(standaloneDir, relDistDir, "node_modules", "some-nested-pkg");
|
||||
fs.mkdirSync(hollowNestedPkgDir, { recursive: true });
|
||||
|
||||
assembleStandalone({
|
||||
distDir,
|
||||
outDir,
|
||||
projectRoot,
|
||||
copyNatives: true,
|
||||
});
|
||||
|
||||
const repairedIndexPath = path.join(outDir, relDistDir, "node_modules", "some-nested-pkg", "index.js");
|
||||
assert.ok(
|
||||
fs.existsSync(repairedIndexPath),
|
||||
"hollow nested externalized package dir must be repaired with the real source package (index.js present)"
|
||||
);
|
||||
|
||||
fs.rmSync(tmp, { recursive: true, force: true });
|
||||
});
|
||||
@@ -1,115 +0,0 @@
|
||||
import test from "node:test";
|
||||
import assert from "node:assert/strict";
|
||||
import fs from "node:fs";
|
||||
import os from "node:os";
|
||||
import path from "node:path";
|
||||
|
||||
const TEST_DATA_DIR = fs.mkdtempSync(path.join(os.tmpdir(), "omniroute-kiro-10815-"));
|
||||
process.env.DATA_DIR = TEST_DATA_DIR;
|
||||
|
||||
const core = await import("../../src/lib/db/core.ts");
|
||||
const providersDb = await import("../../src/lib/db/providers.ts");
|
||||
|
||||
test.after(async () => {
|
||||
core.resetDbInstance();
|
||||
fs.rmSync(TEST_DATA_DIR, { recursive: true, force: true });
|
||||
});
|
||||
|
||||
test("createProviderConnection keeps two Kiro oauth connections with the same email but different profileArn separate (#10815)", async () => {
|
||||
const first = await providersDb.createProviderConnection({
|
||||
provider: "kiro",
|
||||
authType: "oauth",
|
||||
email: "user@example.com",
|
||||
accessToken: "token-account-1",
|
||||
refreshToken: "refresh-account-1",
|
||||
providerSpecificData: {
|
||||
authMethod: "imported",
|
||||
provider: "Google",
|
||||
profileArn: "arn:aws:codewhisperer:us-east-1:111111111111:profile/AAAA",
|
||||
},
|
||||
});
|
||||
|
||||
const second = await providersDb.createProviderConnection({
|
||||
provider: "kiro",
|
||||
authType: "oauth",
|
||||
email: "user@example.com",
|
||||
accessToken: "token-account-2",
|
||||
refreshToken: "refresh-account-2",
|
||||
providerSpecificData: {
|
||||
authMethod: "imported",
|
||||
provider: "Google",
|
||||
profileArn: "arn:aws:codewhisperer:us-east-1:222222222222:profile/BBBB",
|
||||
},
|
||||
});
|
||||
|
||||
const kiroConnections = await providersDb.getProviderConnections({ provider: "kiro" });
|
||||
|
||||
assert.notEqual(
|
||||
second.id,
|
||||
first.id,
|
||||
"second Kiro connection should be a new row, not an update of the first"
|
||||
);
|
||||
assert.equal(
|
||||
kiroConnections.length,
|
||||
2,
|
||||
`expected 2 Kiro connections after adding a second account, got ${kiroConnections.length}`
|
||||
);
|
||||
});
|
||||
|
||||
test("createProviderConnection re-auth of the SAME Kiro profileArn still updates in place (#10815)", async () => {
|
||||
const first = await providersDb.createProviderConnection({
|
||||
provider: "kiro",
|
||||
authType: "oauth",
|
||||
email: "same-profile@example.com",
|
||||
accessToken: "token-a",
|
||||
refreshToken: "refresh-a",
|
||||
providerSpecificData: {
|
||||
authMethod: "imported",
|
||||
provider: "Google",
|
||||
profileArn: "arn:aws:codewhisperer:us-east-1:333333333333:profile/CCCC",
|
||||
},
|
||||
});
|
||||
|
||||
const reauth = await providersDb.createProviderConnection({
|
||||
provider: "kiro",
|
||||
authType: "oauth",
|
||||
email: "same-profile@example.com",
|
||||
accessToken: "token-a-refreshed",
|
||||
refreshToken: "refresh-a-refreshed",
|
||||
providerSpecificData: {
|
||||
authMethod: "imported",
|
||||
provider: "Google",
|
||||
profileArn: "arn:aws:codewhisperer:us-east-1:333333333333:profile/CCCC",
|
||||
},
|
||||
});
|
||||
|
||||
assert.equal(
|
||||
reauth.id,
|
||||
first.id,
|
||||
"re-auth of the same profileArn should update the existing row"
|
||||
);
|
||||
});
|
||||
|
||||
test("createProviderConnection keeps legacy email-only OAuth dedup for rows without profileArn/username (#10815)", async () => {
|
||||
const first = await providersDb.createProviderConnection({
|
||||
provider: "google",
|
||||
authType: "oauth",
|
||||
email: "legacy@example.com",
|
||||
accessToken: "legacy-token-1",
|
||||
refreshToken: "legacy-refresh-1",
|
||||
});
|
||||
|
||||
const second = await providersDb.createProviderConnection({
|
||||
provider: "google",
|
||||
authType: "oauth",
|
||||
email: "legacy@example.com",
|
||||
accessToken: "legacy-token-2",
|
||||
refreshToken: "legacy-refresh-2",
|
||||
});
|
||||
|
||||
assert.equal(
|
||||
second.id,
|
||||
first.id,
|
||||
"legacy rows without profileArn/username should still dedup by bare email match"
|
||||
);
|
||||
});
|
||||
Reference in New Issue
Block a user