Pr/UI language header - [deferred to v4.0.0-rc1] by rafacpti23 · Pull Request #2144 · diegosouzapw/OmniRoute

rafacpti23 · 2026-05-11T04:09:06Z

Summary

Describe the user-facing or operational change.

Related Issues

Closes #
Related to #

Validation

npm run lint
npm run test:unit
npm run test:coverage
Coverage is still >= 60% for statements, lines, functions, and branches
SonarQube PR analysis is green or any remaining issues are explicitly documented below

Tests Added Or Updated

List every changed or added automated test file.
If no production code changed, state that here.

Coverage Notes

If this PR changes src/, open-sse/, electron/, or bin/, explain which tests cover the change.
If coverage moved down in any touched file, explain why and what follow-up task will recover it.

Reviewer Notes

Call out any risky areas, migrations, feature flags, or manual validation that reviewers should know about.

⏳ Deferred to v4.0.0-rc1 — This PR will be integrated in the v4.0.0 release cycle due to its scope and architectural impact.

…bal routing/memory customizations)

…hen token missing

…hanges

…l discovery

…ing service

gemini-code-assist

Code Review

This pull request introduces a comprehensive SaaS layer named "Easy IA," featuring a new customer landing page, a dedicated client portal, and administrative tools for managing customers, plans, and billing. Key technical enhancements include the integration of Qdrant for semantic memory indexing, a new model cooldown management system, and expanded routing strategies such as global random routing. The deployment infrastructure is updated with new Docker Swarm configurations and refined production environment variables. Feedback focuses on ensuring database atomicity by wrapping multi-step operations (like customer creation and billing approval) in transactions and optimizing performance by moving schema enforcement out of hot paths.

gemini-code-assist · 2026-05-11T04:17:38Z

+export function activateSaasCustomerBilling(input: {
+  customerId: string;
+  planId?: string | null;
+  paymentId?: string | null;
+  paymentStatus?: string | null;
+  approvedAt?: string | null;
+}): SaasCustomer | null {
+  ensureSaasSchema();
+  const db = getDbInstance();
+  const customer = getSaasCustomerById(input.customerId, { includeUsage: false });
+  if (!customer) return null;
+  const now = input.approvedAt || new Date().toISOString();
+  const paidUntil = addMonths(new Date(now), 1).toISOString();
+  db.prepare(
+    `UPDATE saas_customers
+     SET status = 'active',
+         billing_status = 'active',
+         paid_until = ?,
+         plan_id = COALESCE(?, plan_id),
+         updated_at = ?
+     WHERE id = ?`
+  ).run(paidUntil, input.planId || null, now, input.customerId);
+  db.prepare(
+    "UPDATE saas_customer_api_keys SET is_active = 1, updated_at = ? WHERE customer_id = ?"
+  ).run(now, input.customerId);
+  db.prepare(
+    `UPDATE api_keys
+     SET is_active = 1
+     WHERE id IN (SELECT api_key_id FROM saas_customer_api_keys WHERE customer_id = ?)`
+  ).run(input.customerId);
+  clearApiKeyCaches();
+  backupDbFile("pre-write");
+  return getSaasCustomerById(input.customerId);
+}


The billing approval process (activating customer, ensuring API key, updating billing event) should be wrapped in a transaction to ensure atomicity.

const db = getDbInstance(); db.transaction(() => { db.prepare( `UPDATE saas_customers SET status = 'active', billing_status = 'active', paid_until = ?, plan_id = COALESCE(?, plan_id), updated_at = ? WHERE id = ?` ).run(paidUntil, input.planId || null, now, input.customerId); db.prepare( "UPDATE saas_customer_api_keys SET is_active = 1, updated_at = ? WHERE customer_id = ?" ).run(now, input.customerId); db.prepare( `UPDATE api_keys SET is_active = 1 WHERE id IN (SELECT api_key_id FROM saas_customer_api_keys WHERE customer_id = ?)` ).run(input.customerId); })();

gemini-code-assist · 2026-05-11T04:17:38Z

+export function createSaasCustomer(input: {
+  name: string;
+  email: string;
+  company?: string;
+  status?: SaasCustomerStatus;
+  planId?: string | null;
+  billingStatus?: SaasBillingStatus;
+  paidUntil?: string | null;
+  extraTokenCredits?: number;
+  notes?: string;
+  allowedModels?: string[];
+  allowedCombos?: string[];
+  passwordHash?: string | null;
+}): SaasCustomer {
+  ensureSaasSchema();
+  const db = getDbInstance();
+  const now = new Date().toISOString();
+  const id = randomUUID();
+  db.prepare(
+    `INSERT INTO saas_customers (
+      id, name, email, company, status, billing_status, paid_until, extra_token_credits,
+      plan_id, password_hash, billing_cycle_anchor, notes, created_at, updated_at
+    ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`
+  ).run(
+    id,
+    input.name,
+    input.email,
+    input.company || "",
+    input.status || "active",
+    input.billingStatus || "active",
+    input.paidUntil || null,
+    Math.max(0, Math.round(input.extraTokenCredits || 0)),
+    input.planId || null,
+    input.passwordHash || null,
+    now,
+    input.notes || "",
+    now,
+    now
+  );
+  setSaasCustomerPermissions(id, input.allowedModels || [], input.allowedCombos || []);
+  backupDbFile("pre-write");
+  return getSaasCustomerById(id) as SaasCustomer;
+}


The customer creation process (customer record, permissions) should be wrapped in a transaction to ensure atomicity.

const db = getDbInstance(); db.transaction(() => { db.prepare( `INSERT INTO saas_customers ( id, name, email, company, status, billing_status, paid_until, extra_token_credits, plan_id, password_hash, billing_cycle_anchor, notes, created_at, updated_at ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)` ).run( id, input.name, input.email, input.company || "", input.status || "active", input.billingStatus || "active", input.paidUntil || null, Math.max(0, Math.round(input.extraTokenCredits || 0)), input.planId || null, input.passwordHash || null, now, input.notes || "", now, now ); setSaasCustomerPermissions(id, input.allowedModels || [], input.allowedCombos || []); })();

gemini-code-assist · 2026-05-11T04:17:38Z

+export async function POST(request: Request) {
+  const authError = await requireManagementAuth(request);
+  if (authError) return authError;
+
+  try {
+    const rawBody = await request.json();
+    const validation = validateBody(customerSchema, rawBody);
+    if (isValidationFailure(validation)) {
+      return NextResponse.json(
+        {
+          error: summarizeValidationError(
+            validation.error,
+            "Revise os dados do cliente antes de salvar."
+          ),
+        },
+        { status: 400 }
+      );
+    }
+    const data = validation.data;
+
+    const customer = createSaasCustomer({
+      name: data.name,
+      email: data.email,
+      company: data.company || "",
+      status: data.status || "active",
+      billingStatus: data.billingStatus || "active",
+      paidUntil: data.paidUntil || null,
+      extraTokenCredits: data.extraTokenCredits || 0,
+      planId: data.planId || null,
+      passwordHash: data.password ? bcrypt.hashSync(data.password, 10) : null,
+      notes: data.notes || "",
+      allowedModels: data.allowedModels || [],
+      allowedCombos: data.allowedCombos || [],
+    });
+
+    const machineId = await getConsistentMachineId();
+    const keyName = data.apiKeyLabel || `${data.name} API Key`;
+    const apiKey = await createApiKey(keyName, machineId);
+    const keyIsActive =
+      data.status !== "blocked" &&
+      data.status !== "inactive" &&
+      (data.billingStatus || "active") === "active";
+    await updateApiKeyPermissions(apiKey.id, {
+      allowedModels: data.allowedModels || [],
+      noLog: false,
+      isActive: keyIsActive,
+    });
+    linkApiKeyToSaasCustomer({
+      customerId: customer.id,
+      apiKeyId: apiKey.id,
+      label: data.apiKeyLabel || "Principal",
+      isActive: keyIsActive,
+    });
+
+    return NextResponse.json(
+      { customer: getSaasCustomerById(customer.id), apiKey: apiKey.key },
+      { status: 201 }
+    );
+  } catch (error) {
+    return NextResponse.json({ error: friendlyCustomerAdminError(error) }, { status: 500 });
+  }
+}


The customer creation process (customer record, API key, permissions) should be wrapped in a transaction to ensure atomicity.

const db = getDbInstance(); db.transaction(() => { // ... customer creation ... })();

gemini-code-assist · 2026-05-11T04:17:38Z

+export async function POST(request: Request) {
+  try {
+    const rawBody = await request.json();
+    const validation = validateBody(checkoutSchema, rawBody);
+    if (isValidationFailure(validation)) {
+      return NextResponse.json(
+        {
+          error: summarizeValidationError(
+            validation.error,
+            "Revise os dados do checkout e tente novamente."
+          ),
+        },
+        { status: 400 }
+      );
+    }
+
+    const body = validation.data;
+    let customer = body.customerId ? getSaasCustomerById(body.customerId) : null;
+
+    if (!customer) {
+      if (!body.email || !body.name) {
+        return NextResponse.json(
+          { error: "Nome e email sao obrigatorios para iniciar a assinatura." },
+          { status: 400 }
+        );
+      }
+      customer = getSaasCustomerByEmail(body.email, { includeUsage: false });
+      if (!customer) {
+        customer = createSaasCustomer({
+          name: body.name,
+          email: body.email,
+          company: body.company || "",
+          status: "inactive",
+          billingStatus: "past_due",
+          paidUntil: null,
+          planId: body.planId || null,
+          allowedModels: [],
+          allowedCombos: [],
+        });
+      } else {
+        customer = updateSaasCustomer(customer.id, {
+          name: body.name,
+          company: body.company || customer.company,
+          planId: body.planId === undefined ? customer.planId : body.planId,
+        });
+      }
+      if (!customer) {
+        return NextResponse.json(
+          { error: "Nao foi possivel preparar o cadastro." },
+          { status: 500 }
+        );
+      }
+      if (body.password) {
+        setSaasCustomerPassword(customer.id, body.password);
+      }
+    }
+
+    if (body.password) {
+      setSaasCustomerPassword(customer.id, body.password);
+    }
+
+    const plan =
+      body.planId && body.planId !== null
+        ? listSaasPlans().find((item) => item.id === body.planId)
+        : customer.planId
+          ? listSaasPlans().find((item) => item.id === customer?.planId)
+          : null;
+
+    const tokenCredits = Math.max(0, body.tokenCredits || 0);
+    const amountCents =
+      body.kind === "credit_purchase"
+        ? Math.max(100, Math.round(tokenCredits / 1000))
+        : Math.max(0, plan?.priceMonthlyCents || customer.priceMonthlyCents || 0);
+
+    if (body.kind !== "credit_purchase" && !plan) {
+      return NextResponse.json(
+        { error: friendlyCheckoutStartError("Plano nao encontrado para pagamento.") },
+        { status: 404 }
+      );
+    }
+
+    if (amountCents <= 0 && body.kind !== "credit_purchase") {
+      const activated = updateSaasCustomer(customer.id, {
+        status: "active",
+        billingStatus: "active",
+        paidUntil: new Date(Date.now() + 30 * 24 * 60 * 60 * 1000).toISOString(),
+        planId: plan?.id || customer.planId,
+      });
+      return NextResponse.json({
+        checkoutUrl: null,
+        customer: activated,
+        freeActivation: true,
+      });
+    }
+
+    if (!isMercadoPagoConfigured()) {
+      return NextResponse.json(
+        {
+          error: friendlyCheckoutStartError(
+            "Mercado Pago ainda nao foi configurado neste ambiente. Defina MERCADO_PAGO_ACCESS_TOKEN para liberar o checkout."
+          ),
+        },
+        { status: 400 }
+      );
+    }
+
+    const event = createSaasBillingEvent({
+      customerId: customer.id,
+      planId: plan?.id || customer.planId,
+      kind: body.kind,
+      amountCents,
+      tokenCredits,
+      metadataJson: JSON.stringify({
+        customerId: customer.id,
+        planId: plan?.id || customer.planId || null,
+        tokenCredits,
+      }),
+    });
+
+    const sitePublicUrl = getSitePublicUrl(request);
+    const apiPublicUrl = getApiPublicUrl(request);
+    const preference = await createMercadoPagoPreference({
+      items: [
+        buildCheckoutItem(body.kind, plan?.name || "Recarga de tokens", amountCents, tokenCredits),
+      ],
+      payer: {
+        name: customer.name,
+        email: customer.email,
+      },
+      external_reference: event.externalReference,
+      notification_url: `${apiPublicUrl}/api/saas/checkout/webhook`,
+      back_urls: {
+        success: `${sitePublicUrl}/portal?checkout=success`,
+        failure: `${sitePublicUrl}/portal?checkout=failure`,
+        pending: `${sitePublicUrl}/portal?checkout=pending`,
+      },
+      auto_return: "approved",
+      metadata: {
+        customerId: customer.id,
+        planId: plan?.id || customer.planId || null,
+        billingEventId: event.id,
+        kind: body.kind,
+        tokenCredits,
+      },
+    });
+
+    updateSaasBillingEvent(event.id, {
+      checkoutUrl: preference.init_point || preference.sandbox_init_point || null,
+      preferenceId: preference.id || null,
+      metadataJson: JSON.stringify(preference),
+    });
+
+    return NextResponse.json({
+      checkoutUrl: preference.init_point || preference.sandbox_init_point || null,
+      preferenceId: preference.id || null,
+      publicKey: getMercadoPagoPublicKey() || null,
+      customerId: customer.id,
+      billingEventId: event.id,
+    });
+  } catch (error) {
+    const message = error instanceof Error ? error.message : String(error);
+    return NextResponse.json({ error: friendlyCheckoutStartError(message) }, { status: 500 });
+  }
+}


The customer creation and billing event creation should be wrapped in a transaction to ensure atomicity.

const db = getDbInstance(); db.transaction(() => { // ... customer creation and billing event creation ... })();

gemini-code-assist · 2026-05-11T04:17:38Z

+export async function POST(request: Request) {
+  try {
+    if (!isMercadoPagoConfigured()) {
+      return NextResponse.json({ ok: true, skipped: "not_configured" });
+    }
+
+    const payload = await request.json().catch(() => ({}));
+    const paymentId =
+      payload?.data?.id || payload?.id || payload?.resource?.split("/").pop() || null;
+    if (!paymentId) {
+      return NextResponse.json({ ok: true, skipped: "missing_payment_id" });
+    }
+
+    const payment = await getMercadoPagoPayment(String(paymentId));
+    const event =
+      getSaasBillingEventByPaymentId(String(payment.id || paymentId)) ||
+      (payment?.external_reference
+        ? getSaasBillingEventByExternalReference(String(payment.external_reference))
+        : null);
+
+    if (!event) {
+      return NextResponse.json({ ok: true, skipped: "billing_event_not_found" });
+    }
+
+    const status = String(payment.status || "").toLowerCase();
+    if (status === "approved") {
+      await applyBillingApproval(event, payment);
+    } else {
+      const normalizedStatus =
+        status === "rejected"
+          ? "rejected"
+          : status === "cancelled"
+            ? "cancelled"
+            : status === "expired"
+              ? "expired"
+              : "pending";
+      updateSaasBillingEvent(event.id, {
+        status: normalizedStatus,
+        paymentId: String(payment.id || paymentId),
+        metadataJson: JSON.stringify(payment || {}),
+      });
+    }
+
+    return NextResponse.json({ ok: true });
+  } catch (error) {
+    return NextResponse.json(
+      { ok: false, error: error instanceof Error ? error.message : String(error) },
+      { status: 200 }
+    );
+  }
+}


The billing approval process (activating customer, ensuring API key, updating billing event) should be wrapped in a transaction to ensure atomicity.

const db = getDbInstance(); db.transaction(() => { // ... billing approval ... })();

gemini-code-assist · 2026-05-11T04:17:38Z

+export async function PATCH(request: Request, { params }: { params: Promise<{ id: string }> }) {
+  const authError = await requireManagementAuth(request);
+  if (authError) return authError;
+
+  try {
+    const { id } = await params;
+    const rawBody = await request.json();
+    const validation = validateBody(updateCustomerSchema, rawBody);
+    if (isValidationFailure(validation)) {
+      return NextResponse.json(
+        {
+          error: summarizeValidationError(
+            validation.error,
+            "Revise os dados do cliente antes de salvar."
+          ),
+        },
+        { status: 400 }
+      );
+    }
+    const customer = updateSaasCustomer(id, {
+      ...validation.data,
+      passwordHash: validation.data.password
+        ? bcrypt.hashSync(validation.data.password, 10)
+        : undefined,
+    });
+    if (!customer) {
+      return NextResponse.json(
+        { error: friendlyCustomerAdminError("Customer not found") },
+        { status: 404 }
+      );
+    }
+    return NextResponse.json({ customer });
+  } catch (error) {
+    return NextResponse.json({ error: friendlyCustomerAdminError(error) }, { status: 500 });
+  }
+}


The customer update process (customer record, permissions) should be wrapped in a transaction to ensure atomicity.

const db = getDbInstance(); db.transaction(() => { // ... customer update ... })();

gemini-code-assist · 2026-05-11T04:17:38Z

    | "requestCountsFailed"
  >
 ): BatchRecord {
+  ensureBatchesSchema();


ensureBatchesSchema is called at the beginning of every database function. This causes redundant schema checks on every call. Consider calling it once during application initialization.

gemini-code-assist · 2026-05-11T04:17:38Z

+  };
+}
+
+export function ensureSaasSchema(): void {


ensureSaasSchema is called at the beginning of every database function. This causes redundant schema checks on every call. Consider calling it once during application initialization.

diegosouzapw · 2026-05-11T13:04:31Z

Hey @rafacpti23, thanks for this contribution! 🚀

We really appreciate the work you've put into these features — the SaaS module, Qdrant integration, model cooldowns, and resilience improvements are all excellent additions.

However, given the scope of the changes (~28K+ lines, 100 files), this PR is better suited for the next major release cycle. We don't want to rush such a large feature set into v3.8.0 where it could introduce regressions.

Plan: This PR will be deferred to v4.0.0-rc1, where we'll have a dedicated integration window for these features. We'll keep this PR open and track it for the v4.0.0 milestone.

In the meantime, the model cooldown feature (PR #2146) has been extracted as a focused PR and will be integrated into v3.8.0 separately.

Thanks again for the amazing work! 🙌

diegosouzapw · 2026-05-12T00:54:48Z

Thank you for this contribution! After review, this PR has been deferred to the v4.0.0-rc1 milestone as it introduces architectural changes that are better suited for the next major release. We'll revisit it there. We appreciate your work and will keep this open.

diegosouzapw · 2026-05-20T15:51:40Z

Thank you @rafacpti23! The UI language header PR is deferred to v4.0.0-rc1 together with the related resilience UI work in #2145. Both will be merged with full credit in that release cycle. Thanks for your patience!

rafacpti23 and others added 28 commits April 20, 2026 15:20

Prepare Easy IA SaaS and GHCR deployment

e964298

Enable GHCR publishing from prod branch

4741ab4

Harden Docker npm install against network resets

e7a2e1c

Build Docker image for amd64 only

70fbd9c

Merge upstream OmniRoute updates

af5f96d

Fix production dashboard routing

dfdb80d

Include OpenAPI spec in Docker context

5b7fb02

Add Easy IA customer site

6200e9f

Fix Easy IA site Docker build

02c8d35

Add site public directory for Docker build

d370efe

Update README.md

ff3ef42

Add Easy IA landing, portal, and SaaS billing flow

8f15598

Merge OmniRoute v3.7.0 into customized Easy IA build

c343b1d

Restore model availability compatibility shim for CI build

3aecc17

Merge OmniRoute v3.7.1 into customized Easy IA build

470c0e5

Merge upstream v3.7.9 into customized Easy IA fork (preserve SaaS/glo…

3649f09

…bal routing/memory customizations)

fix: batches table self-heal, sidebar labels, and aurora visual theme

ed6286f

fix(prod-ci): publish fork image tags from repo owner and skip Snyk w…

1551313

…hen token missing

chore(prod): trigger docker publish and vps deploy

a778bce

fix(docker): include workspace manifest before npm ci

ebf719b

merge: sync upstream main into prod while preserving custom Easy IA c…

500f360

…hanges

fix(lockfile): regenerate package-lock for workspace consistency

1ca89a0

feat(qdrant): auto-load embedding models in settings UI

03f5ba6

feat(qdrant): support dynamic embedding providers and OpenRouter mode…

696f903

…l discovery

fix(i18n): add missing pt-BR webhooks translations

449c954

fix(pr-review): qdrant vector-name handling, i18n, timeout and embedd…

1e7787a

…ing service

feat(resilience): expose model cooldown list with manual re-enable

9e39621

feat(ui): pt-BR default locale, language flags, and themed top header

79b4bf3

rafacpti23 requested a review from diegosouzapw as a code owner May 11, 2026 04:09

gemini-code-assist Bot reviewed May 11, 2026

View reviewed changes

diegosouzapw changed the base branch from main to release/v3.8.0 May 11, 2026 12:58

diegosouzapw changed the title ~~Pr/UI language header~~ Pr/UI language header - [deferred to v4.0.0-rc1] May 11, 2026

diegosouzapw mentioned this pull request May 20, 2026

Feat/resilience UI i18n model cooldown - [deferred to v4.0.0-rc1] #2145

Open

5 tasks

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Pr/UI language header - [deferred to v4.0.0-rc1]#2144

Pr/UI language header - [deferred to v4.0.0-rc1]#2144
rafacpti23 wants to merge 28 commits into
diegosouzapw:release/v3.8.0from
rafacpti23:pr/ui-language-header

rafacpti23 commented May 11, 2026 •

edited by diegosouzapw

Loading

Uh oh!

gemini-code-assist Bot left a comment

Uh oh!

gemini-code-assist Bot May 11, 2026

Uh oh!

gemini-code-assist Bot May 11, 2026

Uh oh!

gemini-code-assist Bot May 11, 2026

Uh oh!

gemini-code-assist Bot May 11, 2026

Uh oh!

gemini-code-assist Bot May 11, 2026

Uh oh!

gemini-code-assist Bot May 11, 2026

Uh oh!

gemini-code-assist Bot May 11, 2026

Uh oh!

gemini-code-assist Bot May 11, 2026

Uh oh!

diegosouzapw commented May 11, 2026

Uh oh!

diegosouzapw commented May 12, 2026

Uh oh!

diegosouzapw commented May 20, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

2 participants

Conversation

rafacpti23 commented May 11, 2026 • edited by diegosouzapw Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Summary

Related Issues

Validation

Tests Added Or Updated

Coverage Notes

Reviewer Notes

Uh oh!

gemini-code-assist Bot left a comment

Choose a reason for hiding this comment

Code Review

Uh oh!

gemini-code-assist Bot May 11, 2026

Choose a reason for hiding this comment

Uh oh!

gemini-code-assist Bot May 11, 2026

Choose a reason for hiding this comment

Uh oh!

gemini-code-assist Bot May 11, 2026

Choose a reason for hiding this comment

Uh oh!

gemini-code-assist Bot May 11, 2026

Choose a reason for hiding this comment

Uh oh!

gemini-code-assist Bot May 11, 2026

Choose a reason for hiding this comment

Uh oh!

gemini-code-assist Bot May 11, 2026

Choose a reason for hiding this comment

Uh oh!

gemini-code-assist Bot May 11, 2026

Choose a reason for hiding this comment

Uh oh!

gemini-code-assist Bot May 11, 2026

Choose a reason for hiding this comment

Uh oh!

diegosouzapw commented May 11, 2026

Uh oh!

diegosouzapw commented May 12, 2026

Uh oh!

diegosouzapw commented May 20, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

2 participants

rafacpti23 commented May 11, 2026 •

edited by diegosouzapw

Loading