From 67f726afb78bb29264ea5bf636ff817aad83d64e Mon Sep 17 00:00:00 2001 From: suyao Date: Mon, 1 Dec 2025 13:07:23 +0800 Subject: [PATCH] feat: implement API client with SWR integration for catalog management - Added a new Textarea component for user input. - Configured ESLint with custom rules and global ignores. - Developed a comprehensive API client with CRUD operations and error handling. - Defined catalog types and schemas using Zod for type safety. - Created utility functions for class name merging and validation. - Established Next.js configuration for API rewrites and static file headers. - Set up package.json with necessary dependencies and scripts. - Configured PostCSS for Tailwind CSS integration. - Added SVG assets for UI components. - Configured TypeScript with strict settings and module resolution. --- electron.vite.config.ts | 3 +- packages/catalog/PLANS.md | 6 +- packages/catalog/api/openapi.json | 627 ++++ packages/catalog/data/migration-report.json | 2 +- packages/catalog/package.json | 5 +- .../src/__tests__/fixtures/test-models.json | 2 +- .../__tests__/fixtures/test-overrides.json | 2 +- .../__tests__/fixtures/test-providers.json | 2 +- packages/catalog/src/utils/migration.ts | 49 +- packages/catalog/web/.gitignore | 41 + packages/catalog/web/README.md | 36 + .../[modelId]/providers/[providerId]/route.ts | 285 ++ .../app/api/catalog/models/[modelId]/route.ts | 113 + .../web/app/api/catalog/models/route.ts | 156 + .../catalog/providers/[providerId]/route.ts | 113 + .../web/app/api/catalog/providers/route.ts | 146 + .../web/app/api/catalog/stats/route.ts | 70 + packages/catalog/web/app/favicon.ico | Bin 0 -> 25931 bytes packages/catalog/web/app/globals.css | 26 + packages/catalog/web/app/layout.tsx | 31 + packages/catalog/web/app/page.tsx | 348 ++ packages/catalog/web/app/providers/page.tsx | 323 ++ packages/catalog/web/components.json | 20 + .../catalog/web/components/navigation.tsx | 32 + packages/catalog/web/components/ui/alert.tsx | 59 + packages/catalog/web/components/ui/badge.tsx | 29 + packages/catalog/web/components/ui/button.tsx | 52 + packages/catalog/web/components/ui/card.tsx | 59 + packages/catalog/web/components/ui/dialog.tsx | 107 + packages/catalog/web/components/ui/input.tsx | 25 + .../catalog/web/components/ui/pagination.tsx | 88 + .../catalog/web/components/ui/separator.tsx | 27 + packages/catalog/web/components/ui/table.tsx | 94 + .../catalog/web/components/ui/textarea.tsx | 23 + packages/catalog/web/eslint.config.mjs | 18 + packages/catalog/web/lib/api-client.ts | 299 ++ packages/catalog/web/lib/catalog-types.ts | 86 + packages/catalog/web/lib/utils.ts | 6 + packages/catalog/web/lib/validation.ts | 431 +++ packages/catalog/web/next.config.ts | 40 + packages/catalog/web/package.json | 32 + packages/catalog/web/postcss.config.mjs | 7 + packages/catalog/web/public/file.svg | 1 + packages/catalog/web/public/globe.svg | 1 + packages/catalog/web/public/next.svg | 1 + packages/catalog/web/public/vercel.svg | 1 + packages/catalog/web/public/window.svg | 1 + packages/catalog/web/tsconfig.json | 27 + tsconfig.web.json | 5 +- yarn.lock | 2809 ++++++++++++++++- 50 files changed, 6668 insertions(+), 98 deletions(-) create mode 100644 packages/catalog/api/openapi.json create mode 100644 packages/catalog/web/.gitignore create mode 100644 packages/catalog/web/README.md create mode 100644 packages/catalog/web/app/api/catalog/models/[modelId]/providers/[providerId]/route.ts create mode 100644 packages/catalog/web/app/api/catalog/models/[modelId]/route.ts create mode 100644 packages/catalog/web/app/api/catalog/models/route.ts create mode 100644 packages/catalog/web/app/api/catalog/providers/[providerId]/route.ts create mode 100644 packages/catalog/web/app/api/catalog/providers/route.ts create mode 100644 packages/catalog/web/app/api/catalog/stats/route.ts create mode 100644 packages/catalog/web/app/favicon.ico create mode 100644 packages/catalog/web/app/globals.css create mode 100644 packages/catalog/web/app/layout.tsx create mode 100644 packages/catalog/web/app/page.tsx create mode 100644 packages/catalog/web/app/providers/page.tsx create mode 100644 packages/catalog/web/components.json create mode 100644 packages/catalog/web/components/navigation.tsx create mode 100644 packages/catalog/web/components/ui/alert.tsx create mode 100644 packages/catalog/web/components/ui/badge.tsx create mode 100644 packages/catalog/web/components/ui/button.tsx create mode 100644 packages/catalog/web/components/ui/card.tsx create mode 100644 packages/catalog/web/components/ui/dialog.tsx create mode 100644 packages/catalog/web/components/ui/input.tsx create mode 100644 packages/catalog/web/components/ui/pagination.tsx create mode 100644 packages/catalog/web/components/ui/separator.tsx create mode 100644 packages/catalog/web/components/ui/table.tsx create mode 100644 packages/catalog/web/components/ui/textarea.tsx create mode 100644 packages/catalog/web/eslint.config.mjs create mode 100644 packages/catalog/web/lib/api-client.ts create mode 100644 packages/catalog/web/lib/catalog-types.ts create mode 100644 packages/catalog/web/lib/utils.ts create mode 100644 packages/catalog/web/lib/validation.ts create mode 100644 packages/catalog/web/next.config.ts create mode 100644 packages/catalog/web/package.json create mode 100644 packages/catalog/web/postcss.config.mjs create mode 100644 packages/catalog/web/public/file.svg create mode 100644 packages/catalog/web/public/globe.svg create mode 100644 packages/catalog/web/public/next.svg create mode 100644 packages/catalog/web/public/vercel.svg create mode 100644 packages/catalog/web/public/window.svg create mode 100644 packages/catalog/web/tsconfig.json diff --git a/electron.vite.config.ts b/electron.vite.config.ts index bbb8e2ecf8..aa5d27e76d 100644 --- a/electron.vite.config.ts +++ b/electron.vite.config.ts @@ -113,7 +113,8 @@ export default defineConfig({ '@cherrystudio/extension-table-plus': resolve('packages/extension-table-plus/src'), '@cherrystudio/ai-sdk-provider': resolve('packages/ai-sdk-provider/src'), '@cherrystudio/ui/icons': resolve('packages/ui/src/components/icons'), - '@cherrystudio/ui': resolve('packages/ui/src') + '@cherrystudio/ui': resolve('packages/ui/src'), + '@cherrystudio/catalog': resolve('packages/catalog/src') } }, optimizeDeps: { diff --git a/packages/catalog/PLANS.md b/packages/catalog/PLANS.md index 5980f0a186..197b907907 100644 --- a/packages/catalog/PLANS.md +++ b/packages/catalog/PLANS.md @@ -72,7 +72,7 @@ packages/catalog/ ```typescript // packages/catalog/src/schemas/model.schema.ts -import { z } from 'zod' +import * as z from 'zod' import { EndpointTypeSchema } from './provider.schema' // 模态类型 @@ -206,7 +206,7 @@ export type ModelConfig = z.infer ```typescript // packages/catalog/src/schemas/provider.schema.ts -import { z } from 'zod' +import * as z from 'zod' // 端点类型 export const EndpointTypeSchema = z.enum([ @@ -311,7 +311,7 @@ export type ProviderConfig = z.infer ```typescript // packages/catalog/src/schemas/override.schema.ts -import { z } from 'zod' +import * as z from 'zod' import { ModelCapabilityTypeSchema, ModelPricingSchema, ParameterSupportSchema } from './model.schema' export const ProviderModelOverrideSchema = z.object({ diff --git a/packages/catalog/api/openapi.json b/packages/catalog/api/openapi.json new file mode 100644 index 0000000000..01f0b34b6d --- /dev/null +++ b/packages/catalog/api/openapi.json @@ -0,0 +1,627 @@ +{ + "openapi": "3.0.3", + "info": { + "title": "Cherry Studio Catalog API", + "description": "REST API for managing AI models and providers catalog", + "version": "1.0.0", + "contact": { + "name": "Cherry Studio Team" + } + }, + "servers": [ + { + "url": "http://localhost:3000/api", + "description": "Development server" + } + ], + "paths": { + "/catalog/models": { + "get": { + "summary": "List models with pagination and filtering", + "parameters": [ + { + "name": "page", + "in": "query", + "schema": { + "type": "integer", + "minimum": 1, + "default": 1 + } + }, + { + "name": "limit", + "in": "query", + "schema": { + "type": "integer", + "minimum": 1, + "maximum": 100, + "default": 20 + } + }, + { + "name": "search", + "in": "query", + "schema": { + "type": "string" + } + }, + { + "name": "capabilities", + "in": "query", + "schema": { + "type": "array", + "items": { + "type": "string" + } + } + }, + { + "name": "providers", + "in": "query", + "schema": { + "type": "array", + "items": { + "type": "string" + } + } + } + ], + "responses": { + "200": { + "description": "Paginated list of models", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/PaginatedModels" + } + } + } + } + } + }, + "put": { + "summary": "Update models configuration", + "requestBody": { + "required": true, + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/ModelsConfig" + } + } + } + }, + "responses": { + "200": { + "description": "Models updated successfully" + } + } + } + }, + "/catalog/models/{modelId}": { + "get": { + "summary": "Get specific model details", + "parameters": [ + { + "name": "modelId", + "in": "path", + "required": true, + "schema": { + "type": "string" + } + } + ], + "responses": { + "200": { + "description": "Model details", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/Model" + } + } + } + } + } + }, + "put": { + "summary": "Update specific model", + "parameters": [ + { + "name": "modelId", + "in": "path", + "required": true, + "schema": { + "type": "string" + } + } + ], + "requestBody": { + "required": true, + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/Model" + } + } + } + }, + "responses": { + "200": { + "description": "Model updated successfully" + } + } + } + }, + "/catalog/providers": { + "get": { + "summary": "List providers with pagination and filtering", + "parameters": [ + { + "name": "page", + "in": "query", + "schema": { + "type": "integer", + "minimum": 1, + "default": 1 + } + }, + { + "name": "limit", + "in": "query", + "schema": { + "type": "integer", + "minimum": 1, + "maximum": 100, + "default": 20 + } + }, + { + "name": "search", + "in": "query", + "schema": { + "type": "string" + } + }, + { + "name": "authentication", + "in": "query", + "schema": { + "type": "array", + "items": { + "type": "string" + } + } + } + ], + "responses": { + "200": { + "description": "Paginated list of providers", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/PaginatedProviders" + } + } + } + } + } + }, + "put": { + "summary": "Update providers configuration", + "requestBody": { + "required": true, + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/ProvidersConfig" + } + } + } + }, + "responses": { + "200": { + "description": "Providers updated successfully" + } + } + } + }, + "/catalog/providers/{providerId}": { + "get": { + "summary": "Get specific provider details", + "parameters": [ + { + "name": "providerId", + "in": "path", + "required": true, + "schema": { + "type": "string" + } + } + ], + "responses": { + "200": { + "description": "Provider details", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/Provider" + } + } + } + } + } + } + }, + "/catalog/models/{modelId}/overrides": { + "get": { + "summary": "Get provider-specific overrides for a model", + "parameters": [ + { + "name": "modelId", + "in": "path", + "required": true, + "schema": { + "type": "string" + } + } + ], + "responses": { + "200": { + "description": "Provider overrides for the model", + "content": { + "application/json": { + "schema": { + "type": "object", + "additionalProperties": { + "$ref": "#/components/schemas/Model" + } + } + } + } + } + } + } + }, + "/catalog/models/{modelId}/providers/{providerId}": { + "get": { + "summary": "Get model configuration as seen by specific provider", + "parameters": [ + { + "name": "modelId", + "in": "path", + "required": true, + "schema": { + "type": "string" + } + }, + { + "name": "providerId", + "in": "path", + "required": true, + "schema": { + "type": "string" + } + } + ], + "responses": { + "200": { + "description": "Model configuration with provider-specific overrides applied", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/Model" + } + } + } + } + } + }, + "put": { + "summary": "Update model configuration for specific provider (auto-detects if override is needed)", + "parameters": [ + { + "name": "modelId", + "in": "path", + "required": true, + "schema": { + "type": "string" + } + }, + { + "name": "providerId", + "in": "path", + "required": true, + "schema": { + "type": "string" + } + } + ], + "requestBody": { + "required": true, + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/Model" + } + } + } + }, + "responses": { + "200": { + "description": "Model configuration updated (override created/updated if needed)", + "content": { + "application/json": { + "schema": { + "type": "object", + "properties": { + "updated": { + "type": "string", + "enum": ["base_model", "override", "both"] + }, + "model": { + "$ref": "#/components/schemas/Model" + } + } + } + } + } + } + } + } + }, + "/catalog/stats": { + "get": { + "summary": "Get catalog statistics", + "responses": { + "200": { + "description": "Catalog statistics", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/CatalogStats" + } + } + } + } + } + } + }, + "/catalog/validate": { + "post": { + "summary": "Validate catalog configuration", + "responses": { + "200": { + "description": "Validation results", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/ValidationResult" + } + } + } + } + } + } + } + }, + "components": { + "schemas": { + "Model": { + "type": "object", + "properties": { + "id": { "type": "string" }, + "name": { "type": "string" }, + "owned_by": { "type": "string" }, + "capabilities": { + "type": "array", + "items": { "type": "string" } + }, + "input_modalities": { + "type": "array", + "items": { "type": "string" } + }, + "output_modalities": { + "type": "array", + "items": { "type": "string" } + }, + "context_window": { "type": "integer" }, + "max_output_tokens": { "type": "integer" }, + "max_input_tokens": { "type": "integer" }, + "pricing": { + "$ref": "#/components/schemas/Pricing" + }, + "parameters": { + "$ref": "#/components/schemas/Parameters" + }, + "endpoint_types": { + "type": "array", + "items": { "type": "string" } + }, + "metadata": { "type": "object" } + } + }, + "Provider": { + "type": "object", + "properties": { + "id": { "type": "string" }, + "name": { "type": "string" }, + "description": { "type": "string" }, + "authentication": { "type": "string" }, + "pricing_model": { "type": "string" }, + "model_routing": { "type": "string" }, + "behaviors": { "type": "object" }, + "supported_endpoints": { + "type": "array", + "items": { "type": "string" } + }, + "api_compatibility": { "type": "object" }, + "special_config": { "type": "object" }, + "documentation": { "type": "string" }, + "website": { "type": "string" }, + "deprecated": { "type": "boolean" }, + "maintenance_mode": { "type": "boolean" }, + "config_version": { "type": "string" }, + "metadata": { "type": "object" } + } + }, + "Override": { + "type": "object", + "properties": { + "provider_id": { "type": "string" }, + "model_id": { "type": "string" }, + "disabled": { "type": "boolean" }, + "reason": { "type": "string" }, + "last_updated": { "type": "string" }, + "updated_by": { "type": "string" }, + "priority": { "type": "integer" }, + "limits": { + "type": "object", + "properties": { + "context_window": { "type": "integer" }, + "max_output_tokens": { "type": "integer" } + } + }, + "pricing": { + "$ref": "#/components/schemas/Pricing" + } + } + }, + "Pricing": { + "type": "object", + "properties": { + "input": { + "type": "object", + "properties": { + "per_million_tokens": { "type": "number" }, + "currency": { "type": "string" } + } + }, + "output": { + "type": "object", + "properties": { + "per_million_tokens": { "type": "number" }, + "currency": { "type": "string" } + } + } + } + }, + "Parameters": { + "type": "object", + "additionalProperties": true + }, + "PaginatedModels": { + "type": "object", + "properties": { + "data": { + "type": "array", + "items": { + "$ref": "#/components/schemas/Model" + } + }, + "pagination": { + "$ref": "#/components/schemas/Pagination" + } + } + }, + "PaginatedProviders": { + "type": "object", + "properties": { + "data": { + "type": "array", + "items": { + "$ref": "#/components/schemas/Provider" + } + }, + "pagination": { + "$ref": "#/components/schemas/Pagination" + } + } + }, + "PaginatedOverrides": { + "type": "object", + "properties": { + "data": { + "type": "array", + "items": { + "$ref": "#/components/schemas/Override" + } + }, + "pagination": { + "$ref": "#/components/schemas/Pagination" + } + } + }, + "Pagination": { + "type": "object", + "properties": { + "page": { "type": "integer" }, + "limit": { "type": "integer" }, + "total": { "type": "integer" }, + "totalPages": { "type": "integer" } + } + }, + "ModelsConfig": { + "type": "object", + "properties": { + "version": { "type": "string" }, + "models": { + "type": "array", + "items": { + "$ref": "#/components/schemas/Model" + } + } + } + }, + "ProvidersConfig": { + "type": "object", + "properties": { + "version": { "type": "string" }, + "providers": { + "type": "array", + "items": { + "$ref": "#/components/schemas/Provider" + } + } + } + }, + "OverridesConfig": { + "type": "object", + "properties": { + "version": { "type": "string" }, + "overrides": { + "type": "array", + "items": { + "$ref": "#/components/schemas/Override" + } + } + } + }, + "CatalogStats": { + "type": "object", + "properties": { + "total_models": { "type": "integer" }, + "total_providers": { "type": "integer" }, + "total_overrides": { "type": "integer" }, + "models_by_provider": { "type": "object" }, + "overrides_by_provider": { "type": "object" }, + "last_updated": { "type": "string" } + } + }, + "ValidationResult": { + "type": "object", + "properties": { + "valid": { "type": "boolean" }, + "errors": { + "type": "array", + "items": { "type": "string" } + }, + "warnings": { + "type": "array", + "items": { "type": "string" } + } + } + } + } + } +} diff --git a/packages/catalog/data/migration-report.json b/packages/catalog/data/migration-report.json index 30d927723e..6e5077a535 100644 --- a/packages/catalog/data/migration-report.json +++ b/packages/catalog/data/migration-report.json @@ -85,4 +85,4 @@ "models": "models.json", "overrides": "overrides.json" } -} \ No newline at end of file +} diff --git a/packages/catalog/package.json b/packages/catalog/package.json index 5f19ca77bf..9db429f286 100644 --- a/packages/catalog/package.json +++ b/packages/catalog/package.json @@ -47,5 +47,8 @@ }, "dependencies": { "json-schema": "^0.4.0" - } + }, + "workspaces": [ + "web" + ] } diff --git a/packages/catalog/src/__tests__/fixtures/test-models.json b/packages/catalog/src/__tests__/fixtures/test-models.json index d5eb6d61d0..16acedd17d 100644 --- a/packages/catalog/src/__tests__/fixtures/test-models.json +++ b/packages/catalog/src/__tests__/fixtures/test-models.json @@ -51,4 +51,4 @@ } } ] -} \ No newline at end of file +} diff --git a/packages/catalog/src/__tests__/fixtures/test-overrides.json b/packages/catalog/src/__tests__/fixtures/test-overrides.json index c097bfbaae..2b70fe9147 100644 --- a/packages/catalog/src/__tests__/fixtures/test-overrides.json +++ b/packages/catalog/src/__tests__/fixtures/test-overrides.json @@ -25,4 +25,4 @@ "priority": 100 } ] -} \ No newline at end of file +} diff --git a/packages/catalog/src/__tests__/fixtures/test-providers.json b/packages/catalog/src/__tests__/fixtures/test-providers.json index dcece2dbad..2779b37a95 100644 --- a/packages/catalog/src/__tests__/fixtures/test-providers.json +++ b/packages/catalog/src/__tests__/fixtures/test-providers.json @@ -50,4 +50,4 @@ } } ] -} \ No newline at end of file +} diff --git a/packages/catalog/src/utils/migration.ts b/packages/catalog/src/utils/migration.ts index 8a32ff3c35..a9576cb05a 100644 --- a/packages/catalog/src/utils/migration.ts +++ b/packages/catalog/src/utils/migration.ts @@ -74,9 +74,6 @@ interface ProviderConfig { name: string description?: string authentication: string - pricing_model: string - model_routing: string - behaviors: Record supported_endpoints: string[] api_compatibility?: Record special_config?: Record @@ -257,46 +254,11 @@ export class MigrationTool { for (const [providerId, providerData] of Object.entries(this.providerEndpointsData.providers)) { const supported_endpoints = this.privateConvertEndpointsToCapabilities(providerData.endpoints) - // Determine provider characteristics - const isDirectProvider = ['anthropic', 'openai', 'google'].includes(providerId) - const isCloudProvider = ['azure', 'aws', 'gcp'].some((cloud) => providerId.includes(cloud)) - const isProxyProvider = ['openrouter', 'litellm', 'together_ai'].includes(providerId) - - let pricing_model = 'PER_MODEL' - let model_routing = 'DIRECT' - - if (isProxyProvider) { - pricing_model = 'UNIFIED' - model_routing = 'INTELLIGENT' - } else if (isCloudProvider) { - pricing_model = 'PER_MODEL' - model_routing = 'DIRECT' - } - const provider: ProviderConfig = { id: providerId, name: providerData.display_name, description: `Provider: ${providerData.display_name}`, authentication: 'API_KEY', - pricing_model, - model_routing, - behaviors: { - supports_custom_models: providerData.endpoints.batches || false, - provides_model_mapping: isProxyProvider, - supports_model_versioning: true, - provides_fallback_routing: isProxyProvider, - has_auto_retry: isProxyProvider, - supports_health_check: isDirectProvider, - has_real_time_metrics: isDirectProvider || isProxyProvider, - provides_usage_analytics: isDirectProvider, - supports_webhook_events: false, - requires_api_key_validation: true, - supports_rate_limiting: isDirectProvider, - provides_usage_limits: isDirectProvider, - supports_streaming: providerData.endpoints.chat_completions || providerData.endpoints.messages, - supports_batch_processing: providerData.endpoints.batches || false, - supports_model_fine_tuning: providerId === 'openai' - }, supported_endpoints, api_compatibility: { supports_array_content: providerData.endpoints.chat_completions || false, @@ -313,12 +275,7 @@ export class MigrationTool { website: providerData.url, deprecated: false, maintenance_mode: false, - config_version: '1.0.0', - metadata: { - source: 'litellm-endpoints', - tags: [isDirectProvider ? 'official' : isProxyProvider ? 'proxy' : 'cloud'], - reliability: isDirectProvider ? 'high' : 'medium' - } + config_version: '1.0.0' } providers.push(provider) @@ -556,7 +513,9 @@ export class MigrationTool { console.log('\n✅ Migration completed successfully!') console.log(`📊 Migration Summary:`) - console.log(` Providers: ${providers.length} (${providersByType.direct} direct, ${providersByType.cloud} cloud, ${providersByType.proxy} proxy, ${providersByType.self_hosted} self-hosted)`) + console.log( + ` Providers: ${providers.length} (${providersByType.direct} direct, ${providersByType.cloud} cloud, ${providersByType.proxy} proxy, ${providersByType.self_hosted} self-hosted)` + ) console.log(` Base Models: ${models.length}`) console.log(` Overrides: ${overrides.length}`) console.log(`\n📁 Output Files:`) diff --git a/packages/catalog/web/.gitignore b/packages/catalog/web/.gitignore new file mode 100644 index 0000000000..5ef6a52078 --- /dev/null +++ b/packages/catalog/web/.gitignore @@ -0,0 +1,41 @@ +# See https://help.github.com/articles/ignoring-files/ for more about ignoring files. + +# dependencies +/node_modules +/.pnp +.pnp.* +.yarn/* +!.yarn/patches +!.yarn/plugins +!.yarn/releases +!.yarn/versions + +# testing +/coverage + +# next.js +/.next/ +/out/ + +# production +/build + +# misc +.DS_Store +*.pem + +# debug +npm-debug.log* +yarn-debug.log* +yarn-error.log* +.pnpm-debug.log* + +# env files (can opt-in for committing if needed) +.env* + +# vercel +.vercel + +# typescript +*.tsbuildinfo +next-env.d.ts diff --git a/packages/catalog/web/README.md b/packages/catalog/web/README.md new file mode 100644 index 0000000000..e215bc4ccf --- /dev/null +++ b/packages/catalog/web/README.md @@ -0,0 +1,36 @@ +This is a [Next.js](https://nextjs.org) project bootstrapped with [`create-next-app`](https://nextjs.org/docs/app/api-reference/cli/create-next-app). + +## Getting Started + +First, run the development server: + +```bash +npm run dev +# or +yarn dev +# or +pnpm dev +# or +bun dev +``` + +Open [http://localhost:3000](http://localhost:3000) with your browser to see the result. + +You can start editing the page by modifying `app/page.tsx`. The page auto-updates as you edit the file. + +This project uses [`next/font`](https://nextjs.org/docs/app/building-your-application/optimizing/fonts) to automatically optimize and load [Geist](https://vercel.com/font), a new font family for Vercel. + +## Learn More + +To learn more about Next.js, take a look at the following resources: + +- [Next.js Documentation](https://nextjs.org/docs) - learn about Next.js features and API. +- [Learn Next.js](https://nextjs.org/learn) - an interactive Next.js tutorial. + +You can check out [the Next.js GitHub repository](https://github.com/vercel/next.js) - your feedback and contributions are welcome! + +## Deploy on Vercel + +The easiest way to deploy your Next.js app is to use the [Vercel Platform](https://vercel.com/new?utm_medium=default-template&filter=next.js&utm_source=create-next-app&utm_campaign=create-next-app-readme) from the creators of Next.js. + +Check out our [Next.js deployment documentation](https://nextjs.org/docs/app/building-your-application/deploying) for more details. diff --git a/packages/catalog/web/app/api/catalog/models/[modelId]/providers/[providerId]/route.ts b/packages/catalog/web/app/api/catalog/models/[modelId]/providers/[providerId]/route.ts new file mode 100644 index 0000000000..b6660261de --- /dev/null +++ b/packages/catalog/web/app/api/catalog/models/[modelId]/providers/[providerId]/route.ts @@ -0,0 +1,285 @@ +import { promises as fs } from 'fs' +import type { NextRequest } from 'next/server' +import { NextResponse } from 'next/server' +import path from 'path' +import { z } from 'zod' + +import type { Model, ProviderModelOverride, OverridesDataFile } from '@/lib/catalog-types' +import { + ModelSchema, + ModelsDataFileSchema, + ProvidersDataFileSchema, + OverridesDataFileSchema +} from '@/lib/catalog-types' +import { safeParseWithValidation, validateString, ValidationError, createErrorResponse } from '@/lib/validation' + +const DATA_DIR = path.join(process.cwd(), '../data') + +// Type-safe helper function to apply overrides to base model +function applyOverrides(baseModel: Model, override: ProviderModelOverride | null): Model { + if (!override) return baseModel + + return { + ...baseModel, + ...(override.limits && { + context_window: override.limits.context_window ?? baseModel.context_window, + max_output_tokens: override.limits.max_output_tokens ?? baseModel.max_output_tokens + }), + ...(override.pricing && { pricing: override.pricing }) + } +} + +// Type-safe helper function to detect model modifications +function detectModifications( + baseModel: Model, + updatedModel: Partial +): { + pricing: Model['pricing'] | undefined + limits: + | { + context_window?: number + max_output_tokens?: number + } + | undefined +} | null { + const modifications: { + pricing: Model['pricing'] | undefined + limits: + | { + context_window?: number + max_output_tokens?: number + } + | undefined + } = { + pricing: undefined, + limits: undefined + } + + // Check for differences in pricing + if (JSON.stringify(baseModel.pricing) !== JSON.stringify(updatedModel.pricing)) { + modifications.pricing = updatedModel.pricing + } + + // Check for differences in limits + if ( + baseModel.context_window !== updatedModel.context_window || + baseModel.max_output_tokens !== updatedModel.max_output_tokens + ) { + modifications.limits = {} + if (baseModel.context_window !== updatedModel.context_window) { + modifications.limits.context_window = updatedModel.context_window + } + if (baseModel.max_output_tokens !== updatedModel.max_output_tokens) { + modifications.limits.max_output_tokens = updatedModel.max_output_tokens + } + } + + return modifications.pricing || modifications.limits ? modifications : null +} + +export async function GET(request: NextRequest, { params }: { params: { modelId: string; providerId: string } }) { + try { + const { modelId, providerId } = params + + // Validate parameters + const validModelId = validateString(modelId, 'modelId') + const validProviderId = validateString(providerId, 'providerId') + + // Read and validate all data files + const [modelsDataRaw, providersDataRaw, overridesDataRaw] = await Promise.all([ + fs.readFile(path.join(DATA_DIR, 'models.json'), 'utf-8'), + fs.readFile(path.join(DATA_DIR, 'providers.json'), 'utf-8'), + fs.readFile(path.join(DATA_DIR, 'overrides.json'), 'utf-8') + ]) + + const modelsData = await safeParseWithValidation( + modelsDataRaw, + ModelsDataFileSchema, + 'Invalid models data format in file' + ) + const providersData = await safeParseWithValidation( + providersDataRaw, + ProvidersDataFileSchema, + 'Invalid providers data format in file' + ) + const overridesData = await safeParseWithValidation( + overridesDataRaw, + OverridesDataFileSchema, + 'Invalid overrides data format in file' + ) + + // Find base model + const baseModel = modelsData.models.find((m) => m.id === validModelId) + if (!baseModel) { + return NextResponse.json(createErrorResponse('Model not found', 404), { status: 404 }) + } + + // Find provider override for this model + const override = overridesData.overrides.find( + (o) => o.model_id === validModelId && o.provider_id === validProviderId + ) + + // Apply override if exists + const finalModel = applyOverrides(baseModel, override || null) + + return NextResponse.json(ModelSchema.parse(finalModel)) + } catch (error) { + if (error instanceof ValidationError) { + console.error('Validation error:', error.message, error.details) + return NextResponse.json(createErrorResponse(error.message, 400, error.details), { status: 400 }) + } + + console.error('Error fetching provider model:', error) + return NextResponse.json( + createErrorResponse( + 'Failed to fetch model configuration', + 500, + error instanceof Error ? error.message : 'Unknown error' + ), + { status: 500 } + ) + } +} + +// Response schema for provider model updates +const ProviderModelUpdateResponseSchema = z.object({ + updated: z.enum(['base_model', 'override', 'override_updated', 'override_removed']), + model: ModelSchema +}) + +export async function PUT(request: NextRequest, { params }: { params: { modelId: string; providerId: string } }) { + try { + const { modelId, providerId } = params + + // Validate parameters + const validModelId = validateString(modelId, 'modelId') + const validProviderId = validateString(providerId, 'providerId') + + // Validate request body + const requestBody = await request.json() + const updatedModel = await safeParseWithValidation( + JSON.stringify(requestBody), + ModelSchema.partial(), + 'Invalid model data in request body' + ) + + // Read and validate current data + const [modelsDataRaw, providersDataRaw, overridesDataRaw] = await Promise.all([ + fs.readFile(path.join(DATA_DIR, 'models.json'), 'utf-8'), + fs.readFile(path.join(DATA_DIR, 'providers.json'), 'utf-8'), + fs.readFile(path.join(DATA_DIR, 'overrides.json'), 'utf-8') + ]) + + const modelsData = await safeParseWithValidation( + modelsDataRaw, + ModelsDataFileSchema, + 'Invalid models data format in file' + ) + const providersData = await safeParseWithValidation( + providersDataRaw, + ProvidersDataFileSchema, + 'Invalid providers data format in file' + ) + const overridesData = await safeParseWithValidation( + overridesDataRaw, + OverridesDataFileSchema, + 'Invalid overrides data format in file' + ) + + // Find base model and existing override + const baseModelIndex = modelsData.models.findIndex((m) => m.id === validModelId) + const existingOverrideIndex = overridesData.overrides.findIndex( + (o) => o.model_id === validModelId && o.provider_id === validProviderId + ) + + if (baseModelIndex === -1) { + return NextResponse.json(createErrorResponse('Base model not found', 404), { status: 404 }) + } + + const baseModel = modelsData.models[baseModelIndex] + + // Detect what needs to be overridden + const modifications = detectModifications(baseModel, updatedModel) + + let updated: 'base_model' | 'override' | 'override_updated' | 'override_removed' = 'base_model' + let overrideCreated = false + + if (modifications) { + // Create or update override + const override: ProviderModelOverride = { + provider_id: validProviderId, + model_id: validModelId, + disabled: false, + reason: 'Manual configuration update', + last_updated: new Date().toISOString().split('T')[0], + updated_by: 'web-interface', + priority: 100, + ...modifications + } + + const updatedOverrides = [...overridesData.overrides] + + if (existingOverrideIndex >= 0) { + updatedOverrides[existingOverrideIndex] = { + ...updatedOverrides[existingOverrideIndex], + ...override, + last_updated: new Date().toISOString().split('T')[0] + } + } else { + updatedOverrides.push(override) + overrideCreated = true + } + + const updatedOverridesData: OverridesDataFile = { + ...overridesData, + overrides: updatedOverrides + } + + updated = overrideCreated ? 'override' : 'override_updated' + + // Save changes to overrides file + await fs.writeFile(path.join(DATA_DIR, 'overrides.json'), JSON.stringify(updatedOverridesData, null, 2), 'utf-8') + } else if (existingOverrideIndex >= 0) { + // Remove override if no differences exist + const updatedOverrides = overridesData.overrides.filter((_, index) => index !== existingOverrideIndex) + + const updatedOverridesData: OverridesDataFile = { + ...overridesData, + overrides: updatedOverrides + } + + updated = 'override_removed' + + // Save changes to overrides file + await fs.writeFile(path.join(DATA_DIR, 'overrides.json'), JSON.stringify(updatedOverridesData, null, 2), 'utf-8') + } + + // Return the final model configuration + const finalOverride = overridesData.overrides.find( + (o) => o.model_id === validModelId && o.provider_id === validProviderId + ) + const finalModel = applyOverrides(baseModel, finalOverride || null) + + const response = ProviderModelUpdateResponseSchema.parse({ + updated, + model: finalModel + }) + + return NextResponse.json(response) + } catch (error) { + if (error instanceof ValidationError) { + console.error('Validation error:', error.message, error.details) + return NextResponse.json(createErrorResponse(error.message, 400, error.details), { status: 400 }) + } + + console.error('Error updating provider model:', error) + return NextResponse.json( + createErrorResponse( + 'Failed to update model configuration', + 500, + error instanceof Error ? error.message : 'Unknown error' + ), + { status: 500 } + ) + } +} diff --git a/packages/catalog/web/app/api/catalog/models/[modelId]/route.ts b/packages/catalog/web/app/api/catalog/models/[modelId]/route.ts new file mode 100644 index 0000000000..cec9b34032 --- /dev/null +++ b/packages/catalog/web/app/api/catalog/models/[modelId]/route.ts @@ -0,0 +1,113 @@ +import { promises as fs } from 'fs' +import type { NextRequest } from 'next/server' +import { NextResponse } from 'next/server' +import path from 'path' + +import type { ModelsDataFile } from '@/lib/catalog-types' +import { ModelSchema, ModelsDataFileSchema, ModelUpdateResponseSchema } from '@/lib/catalog-types' +import { createErrorResponse, safeParseWithValidation, ValidationError } from '@/lib/validation' + +const DATA_DIR = path.join(process.cwd(), '../data') + +export async function GET(request: NextRequest, { params }: { params: { modelId: string } }) { + try { + const { modelId } = params + + // Read and validate models data using Zod + const modelsDataPath = path.join(DATA_DIR, 'models.json') + const modelsDataRaw = await fs.readFile(modelsDataPath, 'utf-8') + const modelsData = await safeParseWithValidation( + modelsDataRaw, + ModelsDataFileSchema, + 'Invalid models data format in file' + ) + + // Find the model with type safety + const model = modelsData.models.find((m) => m.id === modelId) + if (!model) { + return NextResponse.json(createErrorResponse('Model not found', 404), { status: 404 }) + } + + return NextResponse.json(model) + } catch (error) { + if (error instanceof ValidationError) { + console.error('Validation error:', error.message, error.details) + return NextResponse.json(createErrorResponse(error.message, 400, error.details), { status: 400 }) + } + + console.error('Error fetching model:', error) + return NextResponse.json( + createErrorResponse('Failed to fetch model', 500, error instanceof Error ? error.message : 'Unknown error'), + { status: 500 } + ) + } +} + +export async function PUT(request: NextRequest, { params }: { params: { modelId: string } }) { + try { + const { modelId } = params + + // Read and validate request body using Zod + const requestBody = await request.json() + const updatedModel = await safeParseWithValidation( + JSON.stringify(requestBody), + ModelSchema, + 'Invalid model data in request body' + ) + + // Validate that the model ID matches + if (updatedModel.id !== modelId) { + return NextResponse.json(createErrorResponse('Model ID in request body must match URL parameter', 400), { + status: 400 + }) + } + + // Read current models data using Zod + const modelsDataPath = path.join(DATA_DIR, 'models.json') + const modelsDataRaw = await fs.readFile(modelsDataPath, 'utf-8') + const modelsData = await safeParseWithValidation( + modelsDataRaw, + ModelsDataFileSchema, + 'Invalid models data format in file' + ) + + // Find and update the model + const modelIndex = modelsData.models.findIndex((m) => m.id === modelId) + if (modelIndex === -1) { + return NextResponse.json(createErrorResponse('Model not found', 404), { status: 404 }) + } + + // Create updated models array (immutability) + const updatedModels = [ + ...modelsData.models.slice(0, modelIndex), + updatedModel, + ...modelsData.models.slice(modelIndex + 1) + ] + + const updatedModelsData: ModelsDataFile = { + ...modelsData, + models: updatedModels + } + + // Write back to file + await fs.writeFile(modelsDataPath, JSON.stringify(updatedModelsData, null, 2), 'utf-8') + + const response = ModelUpdateResponseSchema.parse({ + success: true, + model: updatedModel + }) + + return NextResponse.json(response) + } catch (error) { + if (error instanceof ValidationError) { + console.error('Validation error:', error.message, error.details) + return NextResponse.json(createErrorResponse(error.message, 400, error.details), { status: 400 }) + } + + console.error('Error updating model:', error) + return NextResponse.json( + createErrorResponse('Failed to update model', 500, error instanceof Error ? error.message : 'Unknown error'), + { status: 500 } + ) + } +} diff --git a/packages/catalog/web/app/api/catalog/models/route.ts b/packages/catalog/web/app/api/catalog/models/route.ts new file mode 100644 index 0000000000..8f88d4afa8 --- /dev/null +++ b/packages/catalog/web/app/api/catalog/models/route.ts @@ -0,0 +1,156 @@ +import { promises as fs } from 'fs' +import type { NextRequest } from 'next/server' +import { NextResponse } from 'next/server' +import path from 'path' + +import type { Model } from '@/lib/catalog-types' +import { + ModelSchema, + ModelsDataFileSchema +} from '@/lib/catalog-types' +import { + createErrorResponse, + safeParseWithValidation, + validatePaginatedResponse, + validateQueryParams, + ValidationError +} from '@/lib/validation' + +const DATA_DIR = path.join(process.cwd(), '../data') + +function filterModels( + models: readonly Model[], + search?: string, + capabilities?: string[], + providers?: string[] +): Model[] { + let filtered = [...models] + + if (search) { + const searchLower = search.toLowerCase() + filtered = filtered.filter( + (model) => + model.id.toLowerCase().includes(searchLower) || + model.name?.toLowerCase().includes(searchLower) || + model.owned_by?.toLowerCase().includes(searchLower) + ) + } + + if (capabilities && capabilities.length > 0) { + filtered = filtered.filter((model) => capabilities.some((cap) => model.capabilities.includes(cap))) + } + + if (providers && providers.length > 0) { + filtered = filtered.filter((model) => model.owned_by && providers.includes(model.owned_by)) + } + + return filtered +} + +function paginateItems( + items: readonly T[], + page: number, + limit: number +): { + items: T[] + pagination: { + page: number + limit: number + total: number + totalPages: number + hasNext: boolean + hasPrev: boolean + } +} { + const total = items.length + const totalPages = Math.ceil(total / limit) + const offset = (page - 1) * limit + const paginatedItems = items.slice(offset, offset + limit) + + return { + items: paginatedItems, + pagination: { + page, + limit, + total, + totalPages, + hasNext: page < totalPages, + hasPrev: page > 1 + } + } +} + +export async function GET(request: NextRequest) { + try { + const { searchParams } = new URL(request.url) + + // Validate query parameters using Zod + const validatedParams = validateQueryParams(searchParams) + + // Read and validate models data using Zod + const modelsDataPath = path.join(DATA_DIR, 'models.json') + const modelsDataRaw = await fs.readFile(modelsDataPath, 'utf-8') + const modelsData = await safeParseWithValidation( + modelsDataRaw, + ModelsDataFileSchema, + 'Invalid models data format in file' + ) + + // Filter models with type safety + const filteredModels = filterModels( + modelsData.models, + validatedParams.search, + validatedParams.capabilities, + validatedParams.providers + ) + + // Paginate results + const { items, pagination } = paginateItems(filteredModels, validatedParams.page, validatedParams.limit) + + // Create paginated response using Zod schema + const response = validatePaginatedResponse({ data: items, pagination }, ModelSchema) + + return NextResponse.json(response) + } catch (error) { + if (error instanceof ValidationError) { + console.error('Validation error:', error.message, error.details) + return NextResponse.json(createErrorResponse(error.message, 400, error.details), { status: 400 }) + } + + console.error('Error fetching models:', error) + return NextResponse.json( + createErrorResponse('Failed to fetch models', 500, error instanceof Error ? error.message : 'Unknown error'), + { status: 500 } + ) + } +} + +export async function PUT(request: NextRequest) { + try { + const body = await request.json() + + // Validate the data structure using Zod + const validatedData = await safeParseWithValidation( + JSON.stringify(body), + ModelsDataFileSchema, + 'Invalid models data format in request body' + ) + + // Write validated data back to file + const modelsDataPath = path.join(DATA_DIR, 'models.json') + await fs.writeFile(modelsDataPath, JSON.stringify(validatedData, null, 2), 'utf-8') + + return NextResponse.json({ success: true }) + } catch (error) { + if (error instanceof ValidationError) { + console.error('Validation error:', error.message, error.details) + return NextResponse.json(createErrorResponse(error.message, 400, error.details), { status: 400 }) + } + + console.error('Error updating models:', error) + return NextResponse.json( + createErrorResponse('Failed to update models', 500, error instanceof Error ? error.message : 'Unknown error'), + { status: 500 } + ) + } +} diff --git a/packages/catalog/web/app/api/catalog/providers/[providerId]/route.ts b/packages/catalog/web/app/api/catalog/providers/[providerId]/route.ts new file mode 100644 index 0000000000..1cc53797b4 --- /dev/null +++ b/packages/catalog/web/app/api/catalog/providers/[providerId]/route.ts @@ -0,0 +1,113 @@ +import { promises as fs } from 'fs' +import type { NextRequest } from 'next/server' +import { NextResponse } from 'next/server' +import path from 'path' + +import type { ProvidersDataFile } from '@/lib/catalog-types' +import { ProviderSchema, ProvidersDataFileSchema, ProviderUpdateResponseSchema } from '@/lib/catalog-types' +import { createErrorResponse, safeParseWithValidation, ValidationError } from '@/lib/validation' + +const DATA_DIR = path.join(process.cwd(), '../data') + +export async function GET(request: NextRequest, { params }: { params: { providerId: string } }) { + try { + const { providerId } = params + + // Read and validate providers data using Zod + const providersDataPath = path.join(DATA_DIR, 'providers.json') + const providersDataRaw = await fs.readFile(providersDataPath, 'utf-8') + const providersData = await safeParseWithValidation( + providersDataRaw, + ProvidersDataFileSchema, + 'Invalid providers data format in file' + ) + + // Find the provider with type safety + const provider = providersData.providers.find((p) => p.id === providerId) + if (!provider) { + return NextResponse.json(createErrorResponse('Provider not found', 404), { status: 404 }) + } + + return NextResponse.json(provider) + } catch (error) { + if (error instanceof ValidationError) { + console.error('Validation error:', error.message, error.details) + return NextResponse.json(createErrorResponse(error.message, 400, error.details), { status: 400 }) + } + + console.error('Error fetching provider:', error) + return NextResponse.json( + createErrorResponse('Failed to fetch provider', 500, error instanceof Error ? error.message : 'Unknown error'), + { status: 500 } + ) + } +} + +export async function PUT(request: NextRequest, { params }: { params: { providerId: string } }) { + try { + const { providerId } = params + + // Read and validate request body using Zod + const requestBody = await request.json() + const updatedProvider = await safeParseWithValidation( + JSON.stringify(requestBody), + ProviderSchema, + 'Invalid provider data in request body' + ) + + // Validate that the provider ID matches + if (updatedProvider.id !== providerId) { + return NextResponse.json(createErrorResponse('Provider ID in request body must match URL parameter', 400), { + status: 400 + }) + } + + // Read current providers data using Zod + const providersDataPath = path.join(DATA_DIR, 'providers.json') + const providersDataRaw = await fs.readFile(providersDataPath, 'utf-8') + const providersData = await safeParseWithValidation( + providersDataRaw, + ProvidersDataFileSchema, + 'Invalid providers data format in file' + ) + + // Find and update the provider + const providerIndex = providersData.providers.findIndex((p) => p.id === providerId) + if (providerIndex === -1) { + return NextResponse.json(createErrorResponse('Provider not found', 404), { status: 404 }) + } + + // Create updated providers array (immutability) + const updatedProviders = [ + ...providersData.providers.slice(0, providerIndex), + updatedProvider, + ...providersData.providers.slice(providerIndex + 1) + ] + + const updatedProvidersData: ProvidersDataFile = { + ...providersData, + providers: updatedProviders + } + + // Write back to file + await fs.writeFile(providersDataPath, JSON.stringify(updatedProvidersData, null, 2), 'utf-8') + + const response = ProviderUpdateResponseSchema.parse({ + success: true, + provider: updatedProvider + }) + + return NextResponse.json(response) + } catch (error) { + if (error instanceof ValidationError) { + console.error('Validation error:', error.message, error.details) + return NextResponse.json(createErrorResponse(error.message, 400, error.details), { status: 400 }) + } + + console.error('Error updating provider:', error) + return NextResponse.json( + createErrorResponse('Failed to update provider', 500, error instanceof Error ? error.message : 'Unknown error'), + { status: 500 } + ) + } +} diff --git a/packages/catalog/web/app/api/catalog/providers/route.ts b/packages/catalog/web/app/api/catalog/providers/route.ts new file mode 100644 index 0000000000..4b8ab08e7f --- /dev/null +++ b/packages/catalog/web/app/api/catalog/providers/route.ts @@ -0,0 +1,146 @@ +import { promises as fs } from 'fs' +import type { NextRequest } from 'next/server' +import { NextResponse } from 'next/server' +import path from 'path' + +import type { Provider } from '@/lib/catalog-types' +import { + ProviderSchema, + ProvidersDataFileSchema +} from '@/lib/catalog-types' +import { + createErrorResponse, + safeParseWithValidation, + validatePaginatedResponse, + validateQueryParams, + ValidationError +} from '@/lib/validation' + +const DATA_DIR = path.join(process.cwd(), '../data') + +function filterProviders(providers: readonly Provider[], search?: string, authentication?: string[]): Provider[] { + let filtered = [...providers] + + if (search) { + const searchLower = search.toLowerCase() + filtered = filtered.filter( + (provider) => + provider.id.toLowerCase().includes(searchLower) || + provider.name.toLowerCase().includes(searchLower) || + provider.description?.toLowerCase().includes(searchLower) + ) + } + + if (authentication && authentication.length > 0) { + filtered = filtered.filter((provider) => authentication.includes(provider.authentication)) + } + + return filtered +} + +function paginateItems( + items: readonly T[], + page: number, + limit: number +): { + items: T[] + pagination: { + page: number + limit: number + total: number + totalPages: number + hasNext: boolean + hasPrev: boolean + } +} { + const total = items.length + const totalPages = Math.ceil(total / limit) + const offset = (page - 1) * limit + const paginatedItems = items.slice(offset, offset + limit) + + return { + items: paginatedItems, + pagination: { + page, + limit, + total, + totalPages, + hasNext: page < totalPages, + hasPrev: page > 1 + } + } +} + +export async function GET(request: NextRequest) { + try { + const { searchParams } = new URL(request.url) + + // Validate query parameters using Zod + const validatedParams = validateQueryParams(searchParams) + + // Read and validate providers data using Zod + const providersDataPath = path.join(DATA_DIR, 'providers.json') + const providersDataRaw = await fs.readFile(providersDataPath, 'utf-8') + const providersData = await safeParseWithValidation( + providersDataRaw, + ProvidersDataFileSchema, + 'Invalid providers data format in file' + ) + + // Filter providers with type safety + const filteredProviders = filterProviders( + providersData.providers, + validatedParams.search, + validatedParams.authentication + ) + + // Paginate results + const { items, pagination } = paginateItems(filteredProviders, validatedParams.page, validatedParams.limit) + + // Create paginated response using Zod schema + const response = validatePaginatedResponse({ data: items, pagination }, ProviderSchema) + + return NextResponse.json(response) + } catch (error) { + if (error instanceof ValidationError) { + console.error('Validation error:', error.message, error.details) + return NextResponse.json(createErrorResponse(error.message, 400, error.details), { status: 400 }) + } + + console.error('Error fetching providers:', error) + return NextResponse.json( + createErrorResponse('Failed to fetch providers', 500, error instanceof Error ? error.message : 'Unknown error'), + { status: 500 } + ) + } +} + +export async function PUT(request: NextRequest) { + try { + const body = await request.json() + + // Validate the data structure using Zod + const validatedData = await safeParseWithValidation( + JSON.stringify(body), + ProvidersDataFileSchema, + 'Invalid providers data format in request body' + ) + + // Write validated data back to file + const providersDataPath = path.join(DATA_DIR, 'providers.json') + await fs.writeFile(providersDataPath, JSON.stringify(validatedData, null, 2), 'utf-8') + + return NextResponse.json({ success: true }) + } catch (error) { + if (error instanceof ValidationError) { + console.error('Validation error:', error.message, error.details) + return NextResponse.json(createErrorResponse(error.message, 400, error.details), { status: 400 }) + } + + console.error('Error updating providers:', error) + return NextResponse.json( + createErrorResponse('Failed to update providers', 500, error instanceof Error ? error.message : 'Unknown error'), + { status: 500 } + ) + } +} diff --git a/packages/catalog/web/app/api/catalog/stats/route.ts b/packages/catalog/web/app/api/catalog/stats/route.ts new file mode 100644 index 0000000000..af881a1bdd --- /dev/null +++ b/packages/catalog/web/app/api/catalog/stats/route.ts @@ -0,0 +1,70 @@ +import { promises as fs } from 'fs' +import { NextResponse } from 'next/server' +import path from 'path' +import { z } from 'zod' + +// Define schema for stats response +const StatsResponseSchema = z.object({ + total_models: z.number(), + total_providers: z.number(), + total_overrides: z.number(), + last_updated: z.string().optional(), + migration_status: z.enum(['completed', 'in_progress', 'failed']).optional() +}) + +const DATA_DIR = path.join(process.cwd(), '../data') + +// Define schema for migration report +const MigrationReportSchema = z.object({ + summary: z.object({ + total_base_models: z.number(), + total_providers: z.number(), + total_overrides: z.number() + }) +}) + +const ModelsDataSchema = z.object({ + version: z.string(), + models: z.array(z.any()) +}) + +export async function GET() { + try { + // Read migration report for stats with Zod validation + const reportData = await fs.readFile(path.join(DATA_DIR, 'migration-report.json'), 'utf-8') + const report = MigrationReportSchema.parse(JSON.parse(reportData)) + + // Read actual data for last updated timestamp with Zod validation + const modelsData = await fs.readFile(path.join(DATA_DIR, 'models.json'), 'utf-8') + const models = ModelsDataSchema.parse(JSON.parse(modelsData)) + + const stats = { + total_models: report.summary.total_base_models, + total_providers: report.summary.total_providers, + total_overrides: report.summary.total_overrides, + last_updated: new Date().toISOString(), + version: models.version + } + + // Validate response with Zod schema + const validatedStats = StatsResponseSchema.parse(stats) + + return NextResponse.json(validatedStats) + } catch (error) { + console.error('Error fetching stats:', error) + + // Try to provide a minimal fallback response + const fallbackStats = { + total_models: 0, + total_providers: 0, + total_overrides: 0 + } + + try { + const validatedFallback = StatsResponseSchema.parse(fallbackStats) + return NextResponse.json(validatedFallback) + } catch { + return NextResponse.json({ error: 'Failed to fetch stats' }, { status: 500 }) + } + } +} diff --git a/packages/catalog/web/app/favicon.ico b/packages/catalog/web/app/favicon.ico new file mode 100644 index 0000000000000000000000000000000000000000..718d6fea4835ec2d246af9800eddb7ffb276240c GIT binary patch literal 25931 zcmeHv30#a{`}aL_*G&7qml|y<+KVaDM2m#dVr!KsA!#An?kSQM(q<_dDNCpjEux83 zLb9Z^XxbDl(w>%i@8hT6>)&Gu{h#Oeyszu?xtw#Zb1mO{pgX9699l+Qppw7jXaYf~-84xW z)w4x8?=youko|}Vr~(D$UXIbiXABHh`p1?nn8Po~fxRJv}|0e(BPs|G`(TT%kKVJAdg5*Z|x0leQq0 zkdUBvb#>9F()jo|T~kx@OM8$9wzs~t2l;K=woNssA3l6|sx2r3+kdfVW@e^8e*E}v zA1y5{bRi+3Z`uD3{F7LgFJDdvm;nJilkzDku>BwXH(8ItVCXk*-lSJnR?-2UN%hJ){&rlvg`CDTj z)Bzo!3v7Ou#83zEDEFcKt(f1E0~=rqeEbTnMvWR#{+9pg%7G8y>u1OVRUSoox-ovF z2Ydma(;=YuBY(eI|04{hXzZD6_f(v~H;C~y5=DhAC{MMS>2fm~1H_t2$56pc$NH8( z5bH|<)71dV-_oCHIrzrT`2s-5w_+2CM0$95I6X8p^r!gHp+j_gd;9O<1~CEQQGS8) zS9Qh3#p&JM-G8rHekNmKVewU;pJRcTAog68KYo^dRo}(M>36U4Us zfgYWSiHZL3;lpWT=zNAW>Dh#mB!_@Lg%$ms8N-;aPqMn+C2HqZgz&9~Eu z4|Kp<`$q)Uw1R?y(~S>ePdonHxpV1#eSP1B;Ogo+-Pk}6#0GsZZ5!||ev2MGdh}_m z{DeR7?0-1^zVs&`AV6Vt;r3`I`OI_wgs*w=eO%_#7Kepl{B@xiyCANc(l zzIyd4y|c6PXWq9-|KM8(zIk8LPk(>a)zyFWjhT!$HJ$qX1vo@d25W<fvZQ2zUz5WRc(UnFMKHwe1| zWmlB1qdbiA(C0jmnV<}GfbKtmcu^2*P^O?MBLZKt|As~ge8&AAO~2K@zbXelK|4T<{|y4`raF{=72kC2Kn(L4YyenWgrPiv z@^mr$t{#X5VuIMeL!7Ab6_kG$&#&5p*Z{+?5U|TZ`B!7llpVmp@skYz&n^8QfPJzL z0G6K_OJM9x+Wu2gfN45phANGt{7=C>i34CV{Xqlx(fWpeAoj^N0Biu`w+MVcCUyU* zDZuzO0>4Z6fbu^T_arWW5n!E45vX8N=bxTVeFoep_G#VmNlQzAI_KTIc{6>c+04vr zx@W}zE5JNSU>!THJ{J=cqjz+4{L4A{Ob9$ZJ*S1?Ggg3klFp!+Y1@K+pK1DqI|_gq z5ZDXVpge8-cs!o|;K73#YXZ3AShj50wBvuq3NTOZ`M&qtjj#GOFfgExjg8Gn8>Vq5 z`85n+9|!iLCZF5$HJ$Iu($dm?8~-ofu}tEc+-pyke=3!im#6pk_Wo8IA|fJwD&~~F zc16osQ)EBo58U7XDuMexaPRjU@h8tXe%S{fA0NH3vGJFhuyyO!Uyl2^&EOpX{9As0 zWj+P>{@}jxH)8|r;2HdupP!vie{sJ28b&bo!8`D^x}TE$%zXNb^X1p@0PJ86`dZyj z%ce7*{^oo+6%&~I!8hQy-vQ7E)0t0ybH4l%KltWOo~8cO`T=157JqL(oq_rC%ea&4 z2NcTJe-HgFjNg-gZ$6!Y`SMHrlj}Etf7?r!zQTPPSv}{so2e>Fjs1{gzk~LGeesX%r(Lh6rbhSo_n)@@G-FTQy93;l#E)hgP@d_SGvyCp0~o(Y;Ee8{ zdVUDbHm5`2taPUOY^MAGOw*>=s7=Gst=D+p+2yON!0%Hk` zz5mAhyT4lS*T3LS^WSxUy86q&GnoHxzQ6vm8)VS}_zuqG?+3td68_x;etQAdu@sc6 zQJ&5|4(I?~3d-QOAODHpZ=hlSg(lBZ!JZWCtHHSj`0Wh93-Uk)_S%zsJ~aD>{`A0~ z9{AG(e|q3g5B%wYKRxiL2Y$8(4w6bzchKuloQW#e&S3n+P- z8!ds-%f;TJ1>)v)##>gd{PdS2Oc3VaR`fr=`O8QIO(6(N!A?pr5C#6fc~Ge@N%Vvu zaoAX2&(a6eWy_q&UwOhU)|P3J0Qc%OdhzW=F4D|pt0E4osw;%<%Dn58hAWD^XnZD= z>9~H(3bmLtxpF?a7su6J7M*x1By7YSUbxGi)Ot0P77`}P3{)&5Un{KD?`-e?r21!4vTTnN(4Y6Lin?UkSM z`MXCTC1@4A4~mvz%Rh2&EwY))LeoT=*`tMoqcEXI>TZU9WTP#l?uFv+@Dn~b(>xh2 z;>B?;Tz2SR&KVb>vGiBSB`@U7VIWFSo=LDSb9F{GF^DbmWAfpms8Sx9OX4CnBJca3 zlj9(x!dIjN?OG1X4l*imJNvRCk}F%!?SOfiOq5y^mZW)jFL@a|r-@d#f7 z2gmU8L3IZq0ynIws=}~m^#@&C%J6QFo~Mo4V`>v7MI-_!EBMMtb%_M&kvAaN)@ZVw z+`toz&WG#HkWDjnZE!6nk{e-oFdL^$YnbOCN}JC&{$#$O27@|Tn-skXr)2ml2~O!5 zX+gYoxhoc7qoU?C^3~&!U?kRFtnSEecWuH0B0OvLodgUAi}8p1 zrO6RSXHH}DMc$&|?D004DiOVMHV8kXCP@7NKB zgaZq^^O<7PoKEp72kby@W0Z!Y*Ay{&vfg#C&gG@YVR9g?FEocMUi1gSN$+V+ayF45{a zuDZDTN}mS|;BO%gEf}pjBfN2-gIrU#G5~cucA;dokXW89%>AyXJJI z9X4UlIWA|ZYHgbI z5?oFk@A=Ik7lrEQPDH!H+b`7_Y~aDb_qa=B2^Y&Ow41cU=4WDd40dp5(QS-WMN-=Y z9g;6_-JdNU;|6cPwf$ak*aJIcwL@1n$#l~zi{c{EW?T;DaW*E8DYq?Umtz{nJ&w-M zEMyTDrC&9K$d|kZe2#ws6)L=7K+{ zQw{XnV6UC$6-rW0emqm8wJoeZK)wJIcV?dST}Z;G0Arq{dVDu0&4kd%N!3F1*;*pW zR&qUiFzK=@44#QGw7k1`3t_d8&*kBV->O##t|tonFc2YWrL7_eqg+=+k;!F-`^b8> z#KWCE8%u4k@EprxqiV$VmmtiWxDLgnGu$Vs<8rppV5EajBXL4nyyZM$SWVm!wnCj-B!Wjqj5-5dNXukI2$$|Bu3Lrw}z65Lc=1G z^-#WuQOj$hwNGG?*CM_TO8Bg-1+qc>J7k5c51U8g?ZU5n?HYor;~JIjoWH-G>AoUP ztrWWLbRNqIjW#RT*WqZgPJXU7C)VaW5}MiijYbABmzoru6EmQ*N8cVK7a3|aOB#O& zBl8JY2WKfmj;h#Q!pN%9o@VNLv{OUL?rixHwOZuvX7{IJ{(EdPpuVFoQqIOa7giLVkBOKL@^smUA!tZ1CKRK}#SSM)iQHk)*R~?M!qkCruaS!#oIL1c z?J;U~&FfH#*98^G?i}pA{ z9Jg36t4=%6mhY(quYq*vSxptes9qy|7xSlH?G=S@>u>Ebe;|LVhs~@+06N<4CViBk zUiY$thvX;>Tby6z9Y1edAMQaiH zm^r3v#$Q#2T=X>bsY#D%s!bhs^M9PMAcHbCc0FMHV{u-dwlL;a1eJ63v5U*?Q_8JO zT#50!RD619#j_Uf))0ooADz~*9&lN!bBDRUgE>Vud-i5ck%vT=r^yD*^?Mp@Q^v+V zG#-?gKlr}Eeqifb{|So?HM&g91P8|av8hQoCmQXkd?7wIJwb z_^v8bbg`SAn{I*4bH$u(RZ6*xUhuA~hc=8czK8SHEKTzSxgbwi~9(OqJB&gwb^l4+m`k*Q;_?>Y-APi1{k zAHQ)P)G)f|AyjSgcCFps)Fh6Bca*Xznq36!pV6Az&m{O8$wGFD? zY&O*3*J0;_EqM#jh6^gMQKpXV?#1?>$ml1xvh8nSN>-?H=V;nJIwB07YX$e6vLxH( zqYwQ>qxwR(i4f)DLd)-$P>T-no_c!LsN@)8`e;W@)-Hj0>nJ-}Kla4-ZdPJzI&Mce zv)V_j;(3ERN3_@I$N<^|4Lf`B;8n+bX@bHbcZTopEmDI*Jfl)-pFDvo6svPRoo@(x z);_{lY<;);XzT`dBFpRmGrr}z5u1=pC^S-{ce6iXQlLGcItwJ^mZx{m$&DA_oEZ)B{_bYPq-HA zcH8WGoBG(aBU_j)vEy+_71T34@4dmSg!|M8Vf92Zj6WH7Q7t#OHQqWgFE3ARt+%!T z?oLovLVlnf?2c7pTc)~cc^($_8nyKwsN`RA-23ed3sdj(ys%pjjM+9JrctL;dy8a( z@en&CQmnV(()bu|Y%G1-4a(6x{aLytn$T-;(&{QIJB9vMox11U-1HpD@d(QkaJdEb zG{)+6Dos_L+O3NpWo^=gR?evp|CqEG?L&Ut#D*KLaRFOgOEK(Kq1@!EGcTfo+%A&I z=dLbB+d$u{sh?u)xP{PF8L%;YPPW53+@{>5W=Jt#wQpN;0_HYdw1{ksf_XhO4#2F= zyPx6Lx2<92L-;L5PD`zn6zwIH`Jk($?Qw({erA$^bC;q33hv!d!>%wRhj# zal^hk+WGNg;rJtb-EB(?czvOM=H7dl=vblBwAv>}%1@{}mnpUznfq1cE^sgsL0*4I zJ##!*B?=vI_OEVis5o+_IwMIRrpQyT_Sq~ZU%oY7c5JMIADzpD!Upz9h@iWg_>>~j zOLS;wp^i$-E?4<_cp?RiS%Rd?i;f*mOz=~(&3lo<=@(nR!_Rqiprh@weZlL!t#NCc zO!QTcInq|%#>OVgobj{~ixEUec`E25zJ~*DofsQdzIa@5^nOXj2T;8O`l--(QyU^$t?TGY^7#&FQ+2SS3B#qK*k3`ye?8jUYSajE5iBbJls75CCc(m3dk{t?- zopcER9{Z?TC)mk~gpi^kbbu>b-+a{m#8-y2^p$ka4n60w;Sc2}HMf<8JUvhCL0B&Btk)T`ctE$*qNW8L$`7!r^9T+>=<=2qaq-;ll2{`{Rg zc5a0ZUI$oG&j-qVOuKa=*v4aY#IsoM+1|c4Z)<}lEDvy;5huB@1RJPquU2U*U-;gu z=En2m+qjBzR#DEJDO`WU)hdd{Vj%^0V*KoyZ|5lzV87&g_j~NCjwv0uQVqXOb*QrQ zy|Qn`hxx(58c70$E;L(X0uZZ72M1!6oeg)(cdKO ze0gDaTz+ohR-#d)NbAH4x{I(21yjwvBQfmpLu$)|m{XolbgF!pmsqJ#D}(ylp6uC> z{bqtcI#hT#HW=wl7>p!38sKsJ`r8}lt-q%Keqy%u(xk=yiIJiUw6|5IvkS+#?JTBl z8H5(Q?l#wzazujH!8o>1xtn8#_w+397*_cy8!pQGP%K(Ga3pAjsaTbbXJlQF_+m+-UpUUent@xM zg%jqLUExj~o^vQ3Gl*>wh=_gOr2*|U64_iXb+-111aH}$TjeajM+I20xw(((>fej-@CIz4S1pi$(#}P7`4({6QS2CaQS4NPENDp>sAqD z$bH4KGzXGffkJ7R>V>)>tC)uax{UsN*dbeNC*v}#8Y#OWYwL4t$ePR?VTyIs!wea+ z5Urmc)X|^`MG~*dS6pGSbU+gPJoq*^a=_>$n4|P^w$sMBBy@f*Z^Jg6?n5?oId6f{ z$LW4M|4m502z0t7g<#Bx%X;9<=)smFolV&(V^(7Cv2-sxbxopQ!)*#ZRhTBpx1)Fc zNm1T%bONzv6@#|dz(w02AH8OXe>kQ#1FMCzO}2J_mST)+ExmBr9cva-@?;wnmWMOk z{3_~EX_xadgJGv&H@zK_8{(x84`}+c?oSBX*Ge3VdfTt&F}yCpFP?CpW+BE^cWY0^ zb&uBN!Ja3UzYHK-CTyA5=L zEMW{l3Usky#ly=7px648W31UNV@K)&Ub&zP1c7%)`{);I4b0Q<)B}3;NMG2JH=X$U zfIW4)4n9ZM`-yRj67I)YSLDK)qfUJ_ij}a#aZN~9EXrh8eZY2&=uY%2N0UFF7<~%M zsB8=erOWZ>Ct_#^tHZ|*q`H;A)5;ycw*IcmVxi8_0Xk}aJA^ath+E;xg!x+As(M#0=)3!NJR6H&9+zd#iP(m0PIW8$ z1Y^VX`>jm`W!=WpF*{ioM?C9`yOR>@0q=u7o>BP-eSHqCgMDj!2anwH?s%i2p+Q7D zzszIf5XJpE)IG4;d_(La-xenmF(tgAxK`Y4sQ}BSJEPs6N_U2vI{8=0C_F?@7<(G; zo$~G=8p+076G;`}>{MQ>t>7cm=zGtfbdDXm6||jUU|?X?CaE?(<6bKDYKeHlz}DA8 zXT={X=yp_R;HfJ9h%?eWvQ!dRgz&Su*JfNt!Wu>|XfU&68iRikRrHRW|ZxzRR^`eIGt zIeiDgVS>IeExKVRWW8-=A=yA`}`)ZkWBrZD`hpWIxBGkh&f#ijr449~m`j6{4jiJ*C!oVA8ZC?$1RM#K(_b zL9TW)kN*Y4%^-qPpMP7d4)o?Nk#>aoYHT(*g)qmRUb?**F@pnNiy6Fv9rEiUqD(^O zzyS?nBrX63BTRYduaG(0VVG2yJRe%o&rVrLjbxTaAFTd8s;<<@Qs>u(<193R8>}2_ zuwp{7;H2a*X7_jryzriZXMg?bTuegABb^87@SsKkr2)0Gyiax8KQWstw^v#ix45EVrcEhr>!NMhprl$InQMzjSFH54x5k9qHc`@9uKQzvL4ihcq{^B zPrVR=o_ic%Y>6&rMN)hTZsI7I<3&`#(nl+3y3ys9A~&^=4?PL&nd8)`OfG#n zwAMN$1&>K++c{^|7<4P=2y(B{jJsQ0a#U;HTo4ZmWZYvI{+s;Td{Yzem%0*k#)vjpB zia;J&>}ICate44SFYY3vEelqStQWFihx%^vQ@Do(sOy7yR2@WNv7Y9I^yL=nZr3mb zXKV5t@=?-Sk|b{XMhA7ZGB@2hqsx}4xwCW!in#C zI@}scZlr3-NFJ@NFaJlhyfcw{k^vvtGl`N9xSo**rDW4S}i zM9{fMPWo%4wYDG~BZ18BD+}h|GQKc-g^{++3MY>}W_uq7jGHx{mwE9fZiPCoxN$+7 zrODGGJrOkcPQUB(FD5aoS4g~7#6NR^ma7-!>mHuJfY5kTe6PpNNKC9GGRiu^L31uG z$7v`*JknQHsYB!Tm_W{a32TM099djW%5e+j0Ve_ct}IM>XLF1Ap+YvcrLV=|CKo6S zb+9Nl3_YdKP6%Cxy@6TxZ>;4&nTneadr z_ES90ydCev)LV!dN=#(*f}|ZORFdvkYBni^aLbUk>BajeWIOcmHP#8S)*2U~QKI%S zyrLmtPqb&TphJ;>yAxri#;{uyk`JJqODDw%(Z=2`1uc}br^V%>j!gS)D*q*f_-qf8&D;W1dJgQMlaH5er zN2U<%Smb7==vE}dDI8K7cKz!vs^73o9f>2sgiTzWcwY|BMYHH5%Vn7#kiw&eItCqa zIkR2~Q}>X=Ar8W|^Ms41Fm8o6IB2_j60eOeBB1Br!boW7JnoeX6Gs)?7rW0^5psc- zjS16yb>dFn>KPOF;imD}e!enuIniFzv}n$m2#gCCv4jM#ArwlzZ$7@9&XkFxZ4n!V zj3dyiwW4Ki2QG{@i>yuZXQizw_OkZI^-3otXC{!(lUpJF33gI60ak;Uqitp74|B6I zgg{b=Iz}WkhCGj1M=hu4#Aw173YxIVbISaoc z-nLZC*6Tgivd5V`K%GxhBsp@SUU60-rfc$=wb>zdJzXS&-5(NRRodFk;Kxk!S(O(a0e7oY=E( zAyS;Ow?6Q&XA+cnkCb{28_1N8H#?J!*$MmIwLq^*T_9-z^&UE@A(z9oGYtFy6EZef LrJugUA?W`A8`#=m literal 0 HcmV?d00001 diff --git a/packages/catalog/web/app/globals.css b/packages/catalog/web/app/globals.css new file mode 100644 index 0000000000..37d72f8a6a --- /dev/null +++ b/packages/catalog/web/app/globals.css @@ -0,0 +1,26 @@ +@import 'tailwindcss'; + +:root { + --background: #ffffff; + --foreground: #171717; +} + +@theme inline { + --color-background: var(--background); + --color-foreground: var(--foreground); + --font-sans: var(--font-geist-sans); + --font-mono: var(--font-geist-mono); +} + +@media (prefers-color-scheme: dark) { + :root { + --background: #0a0a0a; + --foreground: #ededed; + } +} + +body { + background: var(--background); + color: var(--foreground); + font-family: Arial, Helvetica, sans-serif; +} diff --git a/packages/catalog/web/app/layout.tsx b/packages/catalog/web/app/layout.tsx new file mode 100644 index 0000000000..4e0e0861b1 --- /dev/null +++ b/packages/catalog/web/app/layout.tsx @@ -0,0 +1,31 @@ +import './globals.css' + +import type { Metadata } from 'next' +import { Geist, Geist_Mono } from 'next/font/google' + +const geistSans = Geist({ + variable: '--font-geist-sans', + subsets: ['latin'] +}) + +const geistMono = Geist_Mono({ + variable: '--font-geist-mono', + subsets: ['latin'] +}) + +export const metadata: Metadata = { + title: 'Create Next App', + description: 'Generated by create next app' +} + +export default function RootLayout({ + children +}: Readonly<{ + children: React.ReactNode +}>) { + return ( + + {children} + + ) +} diff --git a/packages/catalog/web/app/page.tsx b/packages/catalog/web/app/page.tsx new file mode 100644 index 0000000000..07a741460e --- /dev/null +++ b/packages/catalog/web/app/page.tsx @@ -0,0 +1,348 @@ +'use client' + +import { useState } from 'react' + +import { Navigation } from '@/components/navigation' +import { Alert, AlertDescription } from '@/components/ui/alert' +import { Badge } from '@/components/ui/badge' +import { Button } from '@/components/ui/button' +import { Card, CardContent, CardDescription, CardHeader, CardTitle } from '@/components/ui/card' +import { + Dialog, + DialogContent, + DialogDescription, + DialogHeader, + DialogTitle, + DialogTrigger +} from '@/components/ui/dialog' +import { Input } from '@/components/ui/input' +import { Separator } from '@/components/ui/separator' +import { Table, TableBody, TableCell, TableHead, TableHeader, TableRow } from '@/components/ui/table' +import { Textarea } from '@/components/ui/textarea' +// Import SWR hooks and utilities +import { getErrorMessage, useDebounce, useModels, useUpdateModel } from '@/lib/api-client' +import type { CapabilityType, Model } from '@/lib/catalog-types' + +// Type-safe capabilities list +const CAPABILITIES: readonly CapabilityType[] = [ + 'FUNCTION_CALL', + 'REASONING', + 'IMAGE_RECOGNITION', + 'IMAGE_GENERATION', + 'AUDIO_RECOGNITION', + 'AUDIO_GENERATION', + 'EMBEDDING', + 'RERANK', + 'AUDIO_TRANSCRIPT', + 'VIDEO_RECOGNITION', + 'VIDEO_GENERATION', + 'STRUCTURED_OUTPUT', + 'FILE_INPUT', + 'WEB_SEARCH', + 'CODE_EXECUTION', + 'FILE_SEARCH', + 'COMPUTER_USE' +] as const + +// Simple Pagination Component +function SimplePagination({ + currentPage, + totalPages, + onPageChange +}: { + currentPage: number + totalPages: number + onPageChange: (page: number) => void +}) { + const pages = Array.from({ length: Math.min(5, totalPages) }, (_, i) => { + if (totalPages <= 5) return i + 1 + if (currentPage <= 3) return i + 1 + if (currentPage >= totalPages - 2) return totalPages - 4 + i + return currentPage - 2 + i + }) + + return ( +
+ + {pages.map((page) => ( + + ))} + +
+ ) +} + +export default function CatalogReview() { + // Form state + const [search, setSearch] = useState('') + const [selectedCapabilities, setSelectedCapabilities] = useState([]) + const [selectedProviders, setSelectedProviders] = useState([]) + const [currentPage, setCurrentPage] = useState(1) + const [editingModel, setEditingModel] = useState(null) + const [jsonContent, setJsonContent] = useState('') + + // Debounce search to avoid excessive API calls + const debouncedSearch = useDebounce(search, 300) + + // SWR hook for fetching models + const { + data: modelsData, + error, + isLoading + } = useModels({ + page: currentPage, + limit: 20, + search: debouncedSearch, + capabilities: selectedCapabilities.length > 0 ? selectedCapabilities : undefined, + providers: selectedProviders.length > 0 ? selectedProviders : undefined + }) + + // SWR mutation for updating models + const { trigger: updateModel, isMutating: isUpdating } = useUpdateModel() + + // Extract data from SWR response + const models = modelsData?.data || [] + const pagination = modelsData?.pagination || { + page: 1, + limit: 20, + total: 0, + totalPages: 0, + hasNext: false, + hasPrev: false + } + + const handleEdit = (model: Model) => { + setEditingModel(model) + setJsonContent(JSON.stringify(model, null, 2)) + } + + const handleSave = async () => { + if (!editingModel) return + + try { + // Validate JSON before sending + const updatedModel = JSON.parse(jsonContent) as unknown + + // Basic validation - the API will do thorough validation + if (!updatedModel || typeof updatedModel !== 'object') { + throw new Error('Invalid JSON format') + } + + // Use SWR mutation for optimistic update + await updateModel({ + id: editingModel.id, + data: updatedModel as Partial + }) + + // Close dialog and reset form + setEditingModel(null) + setJsonContent('') + } catch (error) { + console.error('Error saving model:', error) + // Error will be handled by SWR and displayed in UI + } + } + + // Type-safe function to extract unique providers + const getUniqueProviders = (): string[] => { + return [ + ...new Set(models.map((model) => model.owned_by).filter((provider): provider is string => Boolean(provider))) + ] + } + + return ( +
+
+
+

Catalog Review

+

Review and validate model configurations after migration

+
+ +
+ + + + Filters + Filter models to review specific configurations + + +
+ setSearch(e.target.value)} + className="max-w-sm" + /> +
+ +
+ +
+ {CAPABILITIES.map((capability) => ( + { + setSelectedCapabilities((prev) => + prev.includes(capability) ? prev.filter((c) => c !== capability) : [...prev, capability] + ) + }}> + {capability.replace('_', ' ')} + + ))} +
+
+ +
+ +
+ {getUniqueProviders().map((provider) => ( + { + setSelectedProviders((prev) => + prev.includes(provider) ? prev.filter((p) => p !== provider) : [...prev, provider] + ) + }}> + {provider} + + ))} +
+
+ + + + {/* Error Display */} + {error && ( + + {getErrorMessage(error)} + + )} + + + + Models ({pagination.total}) + Review migrated model configurations + + + {isLoading ? ( +
+
Loading models...
+
+ ) : ( + <> + + + + ID + Name + Provider + Capabilities + Context Window + Modalities + Actions + + + + {models.map((model) => ( + + {model.id} + {model.name || model.id} + + {model.owned_by} + + +
+ {model.capabilities.slice(0, 3).map((cap) => ( + + {cap.replace('_', ' ')} + + ))} + {model.capabilities.length > 3 && ( + + +{model.capabilities.length - 3} + + )} +
+ + {model.context_window.toLocaleString()} + +
+
In: {model.input_modalities?.join(', ')}
+
Out: {model.output_modalities?.join(', ')}
+
+ + + + + + + + + Edit Model Configuration + + Modify the JSON configuration for {model.name || model.id} + + +
+