pjandro/OmniRoute
1
0
Fork 0
mirror of https://github.com/diegosouzapw/OmniRoute.git synced 2026-08-08 08:12:20 +03:00
Code Issues Packages Projects Releases Wiki Activity

chore(ts): wave 4a — type 7 API routes (providers, cli-tools, oauth)

Browse Source 
Files typed:
- providers/[id]/route.ts (Request, params, Record, result spread)
- openclaw-settings/route.ts (Request, settings Record, error catches)
- cline-settings/route.ts (Request, globalState/secrets Record, error catches)
- droid-settings/route.ts (Request, settings Record, error catches)
- claude-settings/route.ts (Request, currentSettings Record, error catches)
- codex-settings/route.ts (Request, parsed/authData Record, TOML parser typed)
- oauth/[provider]/[action]/route.ts (Request, params, error catches)

TS errors: 419 → 347 (-72)
This commit is contained in:
diegosouzapw
2026-02-17 05:59:12 -03:00
parent f1319448ac
commit 3c79cd34eb
8 changed files with 54 additions and 51 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
.gitignore vendored
View File

@@ -85,3 +85,6 @@ blob-report/
cloud/
omnirouteCloud/
omnirouteSite/
# Security Analysis (standalone project with own git)
security-analysis/

12
src/app/api/cli-tools/claude-settings/route.ts
View File

@@ -19,7 +19,7 @@ const readSettings = async () => {
const settingsPath = getClaudeSettingsPath();
const content = await fs.readFile(settingsPath, "utf-8");
return JSON.parse(content);
} catch (error) {
} catch (error: any) {
if (error.code === "ENOENT") {
return null;
}
@@ -69,7 +69,7 @@ export async function GET() {
}
// POST - Backup old fields and write new settings
export async function POST(request) {
export async function POST(request: Request) {
try {
const writeGuard = ensureCliConfigWriteAllowed();
if (writeGuard) {
@@ -92,11 +92,11 @@ export async function POST(request) {
await createBackup("claude", settingsPath);
// Read current settings
let currentSettings = {};
let currentSettings: Record<string, any> = {};
try {
const content = await fs.readFile(settingsPath, "utf-8");
currentSettings = JSON.parse(content);
} catch (error) {
} catch (error: any) {
if (error.code !== "ENOENT") {
throw error;
}
@@ -152,11 +152,11 @@ export async function DELETE() {
const settingsPath = getClaudeSettingsPath();
// Read current settings
let currentSettings = {};
let currentSettings: Record<string, any> = {};
try {
const content = await fs.readFile(settingsPath, "utf-8");
currentSettings = JSON.parse(content);
} catch (error) {
} catch (error: any) {
if (error.code === "ENOENT") {
return NextResponse.json({
success: true,

18
src/app/api/cli-tools/cline-settings/route.ts
View File

@@ -16,7 +16,7 @@ const readGlobalState = async () => {
try {
const content = await fs.readFile(GLOBAL_STATE_PATH, "utf-8");
return JSON.parse(content);
} catch (error) {
} catch (error: any) {
if (error.code === "ENOENT") return null;
throw error;
}
@@ -27,14 +27,14 @@ const readSecrets = async () => {
try {
const content = await fs.readFile(SECRETS_PATH, "utf-8");
return JSON.parse(content);
} catch (error) {
} catch (error: any) {
if (error.code === "ENOENT") return {};
throw error;
}
};
// Check if OmniRoute is configured as OpenAI-compatible provider
const hasOmniRouteConfig = (globalState) => {
const hasOmniRouteConfig = (globalState: any) => {
if (!globalState) return false;
const isOpenAi =
globalState.actModeApiProvider === "openai" || globalState.planModeApiProvider === "openai";
@@ -96,7 +96,7 @@ export async function GET() {
}
// POST - Configure Cline to use OmniRoute as OpenAI-compatible provider
export async function POST(request) {
export async function POST(request: Request) {
try {
const writeGuard = ensureCliConfigWriteAllowed();
if (writeGuard) {
@@ -117,7 +117,7 @@ export async function POST(request) {
await createBackup("cline", SECRETS_PATH);
// Read existing globalState or create new
let globalState = {};
let globalState: Record<string, any> = {};
try {
const existing = await fs.readFile(GLOBAL_STATE_PATH, "utf-8");
globalState = JSON.parse(existing);
@@ -139,7 +139,7 @@ export async function POST(request) {
await fs.writeFile(GLOBAL_STATE_PATH, JSON.stringify(globalState, null, 2));
// Write API key to secrets
let secrets = {};
let secrets: Record<string, any> = {};
try {
const existing = await fs.readFile(SECRETS_PATH, "utf-8");
secrets = JSON.parse(existing);
@@ -175,11 +175,11 @@ export async function DELETE() {
await createBackup("cline", SECRETS_PATH);
// Read existing state
let globalState = {};
let globalState: Record<string, any> = {};
try {
const existing = await fs.readFile(GLOBAL_STATE_PATH, "utf-8");
globalState = JSON.parse(existing);
} catch (error) {
} catch (error: any) {
if (error.code === "ENOENT") {
return NextResponse.json({ success: true, message: "No settings file to reset" });
}
@@ -199,7 +199,7 @@ export async function DELETE() {
await fs.writeFile(GLOBAL_STATE_PATH, JSON.stringify(globalState, null, 2));
// Remove API key from secrets
let secrets = {};
let secrets: Record<string, any> = {};
try {
const existing = await fs.readFile(SECRETS_PATH, "utf-8");
secrets = JSON.parse(existing);

22
src/app/api/cli-tools/codex-settings/route.ts
View File

@@ -15,8 +15,8 @@ const getCodexAuthPath = () => getCliConfigPaths("codex").auth;
const getCodexDir = () => path.dirname(getCodexConfigPath());
// Parse TOML config to object (simple parser for codex config)
const parseToml = (content) => {
const result = { _root: {}, _sections: {} };
const parseToml = (content: string) => {
const result: Record<string, any> = { _root: {}, _sections: {} };
let currentSection = "_root";
content.split("\n").forEach((line) => {
@@ -55,8 +55,8 @@ const parseToml = (content) => {
};
// Convert parsed object back to TOML string
const toToml = (parsed) => {
let lines = [];
const toToml = (parsed: Record<string, any>) => {
let lines: string[] = [];
// Root level keys
Object.entries(parsed._root).forEach(([key, value]) => {
@@ -81,14 +81,14 @@ const readConfig = async () => {
const configPath = getCodexConfigPath();
const content = await fs.readFile(configPath, "utf-8");
return content;
} catch (error) {
} catch (error: any) {
if (error.code === "ENOENT") return null;
throw error;
}
};
// Check if config has OmniRoute settings
const hasOmniRouteConfig = (config) => {
const hasOmniRouteConfig = (config: string | null) => {
if (!config) return false;
return (
config.includes('model_provider = "omniroute"') ||
@@ -137,7 +137,7 @@ export async function GET() {
}
// POST - Update OmniRoute settings (merge with existing config)
export async function POST(request) {
export async function POST(request: Request) {
try {
const writeGuard = ensureCliConfigWriteAllowed();
if (writeGuard) {
@@ -164,7 +164,7 @@ export async function POST(request) {
await createMultiBackup("codex", [configPath, authPath]);
// Read and parse existing config
let parsed = { _root: {}, _sections: {} };
let parsed: Record<string, any> = { _root: {}, _sections: {} };
try {
const existingConfig = await fs.readFile(configPath, "utf-8");
parsed = parseToml(existingConfig);
@@ -190,7 +190,7 @@ export async function POST(request) {
await fs.writeFile(configPath, configContent);
// Update auth.json with OPENAI_API_KEY (Codex reads this first)
let authData = {};
let authData: Record<string, any> = {};
try {
const existingAuth = await fs.readFile(authPath, "utf-8");
authData = JSON.parse(existingAuth);
@@ -226,11 +226,11 @@ export async function DELETE() {
await createMultiBackup("codex", [configPath, getCodexAuthPath()]);
// Read and parse existing config
let parsed = { _root: {}, _sections: {} };
let parsed: Record<string, any> = { _root: {}, _sections: {} };
try {
const existingConfig = await fs.readFile(configPath, "utf-8");
parsed = parseToml(existingConfig);
} catch (error) {
} catch (error: any) {
if (error.code === "ENOENT") {
return NextResponse.json({
success: true,

12
src/app/api/cli-tools/droid-settings/route.ts
View File

@@ -19,14 +19,14 @@ const readSettings = async () => {
const settingsPath = getDroidSettingsPath();
const content = await fs.readFile(settingsPath, "utf-8");
return JSON.parse(content);
} catch (error) {
} catch (error: any) {
if (error.code === "ENOENT") return null;
throw error;
}
};
// Check if settings has OmniRoute customModels
const hasOmniRouteConfig = (settings) => {
const hasOmniRouteConfig = (settings: any) => {
if (!settings || !settings.customModels) return false;
return settings.customModels.some((m) => m.id === "custom:OmniRoute-0");
};
@@ -72,7 +72,7 @@ export async function GET() {
}
// POST - Update OmniRoute customModels (merge with existing settings)
export async function POST(request) {
export async function POST(request: Request) {
try {
const writeGuard = ensureCliConfigWriteAllowed();
if (writeGuard) {
@@ -95,7 +95,7 @@ export async function POST(request) {
await createBackup("droid", settingsPath);
// Read existing settings or create new
let settings = {};
let settings: Record<string, any> = {};
try {
const existingSettings = await fs.readFile(settingsPath, "utf-8");
settings = JSON.parse(existingSettings);
@@ -157,11 +157,11 @@ export async function DELETE() {
await createBackup("droid", settingsPath);
// Read existing settings
let settings = {};
let settings: Record<string, any> = {};
try {
const existingSettings = await fs.readFile(settingsPath, "utf-8");
settings = JSON.parse(existingSettings);
} catch (error) {
} catch (error: any) {
if (error.code === "ENOENT") {
return NextResponse.json({
success: true,

12
src/app/api/cli-tools/openclaw-settings/route.ts
View File

@@ -19,14 +19,14 @@ const readSettings = async () => {
const settingsPath = getOpenClawSettingsPath();
const content = await fs.readFile(settingsPath, "utf-8");
return JSON.parse(content);
} catch (error) {
} catch (error: any) {
if (error.code === "ENOENT") return null;
throw error;
}
};
// Check if settings has OmniRoute config
const hasOmniRouteConfig = (settings) => {
const hasOmniRouteConfig = (settings: any) => {
if (!settings || !settings.models || !settings.models.providers) return false;
return !!settings.models.providers["omniroute"];
};
@@ -72,7 +72,7 @@ export async function GET() {
}
// POST - Update OmniRoute settings (merge with existing settings)
export async function POST(request) {
export async function POST(request: Request) {
try {
const writeGuard = ensureCliConfigWriteAllowed();
if (writeGuard) {
@@ -95,7 +95,7 @@ export async function POST(request) {
await createBackup("openclaw", settingsPath);
// Read existing settings or create new
let settings = {};
let settings: Record<string, any> = {};
try {
const existingSettings = await fs.readFile(settingsPath, "utf-8");
settings = JSON.parse(existingSettings);
@@ -157,11 +157,11 @@ export async function DELETE() {
await createBackup("openclaw", settingsPath);
// Read existing settings
let settings = {};
let settings: Record<string, any> = {};
try {
const existingSettings = await fs.readFile(settingsPath, "utf-8");
settings = JSON.parse(existingSettings);
} catch (error) {
} catch (error: any) {
if (error.code === "ENOENT") {
return NextResponse.json({
success: true,

14
src/app/api/oauth/[provider]/[action]/route.ts
View File

@@ -23,7 +23,7 @@ if (!globalThis.__codexCallbackState) {
// GET /api/oauth/[provider]/authorize - Generate auth URL
// GET /api/oauth/[provider]/device-code - Request device code (for device_code flow)
export async function GET(request, { params }) {
export async function GET(request: Request, { params }: { params: Promise<{ provider: string; action: string }> }) {
try {
const { provider, action } = await params;
const { searchParams } = new URL(request.url);
@@ -68,7 +68,7 @@ export async function GET(request, { params }) {
return NextResponse.json({ error: "Unknown action" }, { status: 400 });
} catch (error) {
console.log("OAuth GET error:", error);
return NextResponse.json({ error: error.message }, { status: 500 });
return NextResponse.json({ error: (error as any).message }, { status: 500 });
}
}
@@ -76,7 +76,7 @@ export async function GET(request, { params }) {
* Start Codex callback server on port 1455
* Returns the auth URL and stores codeVerifier for later exchange
*/
async function handleStartCallbackServer(provider, searchParams) {
async function handleStartCallbackServer(provider: string, searchParams: URLSearchParams) {
if (provider !== "codex") {
return NextResponse.json(
{ error: "Callback server only supported for codex" },
@@ -135,13 +135,13 @@ async function handleStartCallbackServer(provider, searchParams) {
serverPort: port,
});
} catch (error) {
return NextResponse.json({ error: error.message }, { status: 500 });
return NextResponse.json({ error: (error as any).message }, { status: 500 });
}
}
// POST /api/oauth/[provider]/exchange - Exchange code for tokens and save
// POST /api/oauth/[provider]/poll - Poll for token (device_code flow)
export async function POST(request, { params }) {
export async function POST(request: Request, { params }: { params: Promise<{ provider: string; action: string }> }) {
try {
const { provider, action } = await params;
const body = await request.json();
@@ -320,7 +320,7 @@ export async function POST(request, { params }) {
displayName: connection.displayName,
},
});
} catch (exchangeErr) {
} catch (exchangeErr: any) {
return NextResponse.json({ success: false, error: exchangeErr.message }, { status: 500 });
}
}
@@ -328,7 +328,7 @@ export async function POST(request, { params }) {
return NextResponse.json({ error: "Unknown action" }, { status: 400 });
} catch (error) {
console.log("OAuth POST error:", error);
return NextResponse.json({ error: error.message }, { status: 500 });
return NextResponse.json({ error: (error as any).message }, { status: 500 });
}
}

12
src/app/api/providers/[id]/route.ts
View File

@@ -9,7 +9,7 @@ import { getConsistentMachineId } from "@/shared/utils/machineId";
import { syncToCloud } from "@/lib/cloudSync";
// GET /api/providers/[id] - Get single connection
export async function GET(request, { params }) {
export async function GET(request: Request, { params }: { params: Promise<{ id: string }> }) {
try {
const { id } = await params;
const connection = await getProviderConnectionById(id);
@@ -19,7 +19,7 @@ export async function GET(request, { params }) {
}
// Hide sensitive fields
const result = { ...connection };
const result: Record<string, any> = { ...connection };
delete result.apiKey;
delete result.accessToken;
delete result.refreshToken;
@@ -33,7 +33,7 @@ export async function GET(request, { params }) {
}
// PUT /api/providers/[id] - Update connection
export async function PUT(request, { params }) {
export async function PUT(request: Request, { params }: { params: Promise<{ id: string }> }) {
try {
const { id } = await params;
const body = await request.json();
@@ -60,7 +60,7 @@ export async function PUT(request, { params }) {
return NextResponse.json({ error: "Connection not found" }, { status: 404 });
}
const updateData = {};
const updateData: Record<string, any> = {};
if (name !== undefined) updateData.name = name;
if (priority !== undefined) updateData.priority = priority;
if (globalPriority !== undefined) updateData.globalPriority = globalPriority;
@@ -80,7 +80,7 @@ export async function PUT(request, { params }) {
const updated = await updateProviderConnection(id, updateData);
// Hide sensitive fields
const result = { ...updated };
const result: Record<string, any> = { ...updated };
delete result.apiKey;
delete result.accessToken;
delete result.refreshToken;
@@ -97,7 +97,7 @@ export async function PUT(request, { params }) {
}
// DELETE /api/providers/[id] - Delete connection
export async function DELETE(request, { params }) {
export async function DELETE(request: Request, { params }: { params: Promise<{ id: string }> }) {
try {
const { id } = await params;