* fix(ops): 修复运维监控系统的关键安全和稳定性问题
## 修复内容
### P0 严重问题
1. **DNS Rebinding防护** (ops_alert_service.go)
- 实现IP钉住机制防止验证后的DNS rebinding攻击
- 自定义Transport.DialContext强制只允许拨号到验证过的公网IP
- 扩展IP黑名单,包括云metadata地址(169.254.169.254)
- 添加完整的单元测试覆盖
2. **OpsAlertService生命周期管理** (wire.go)
- 在ProvideOpsMetricsCollector中添加opsAlertService.Start()调用
- 确保stopCtx正确初始化,避免nil指针问题
- 实现防御式启动,保证服务启动顺序
3. **数据库查询排序** (ops_repo.go)
- 在ListRecentSystemMetrics中添加显式ORDER BY updated_at DESC, id DESC
- 在GetLatestSystemMetric中添加排序保证
- 避免数据库返回顺序不确定导致告警误判
### P1 重要问题
4. **并发安全** (ops_metrics_collector.go)
- 为lastGCPauseTotal字段添加sync.Mutex保护
- 防止数据竞争
5. **Goroutine泄漏** (ops_error_logger.go)
- 实现worker pool模式限制并发goroutine数量
- 使用256容量缓冲队列和10个固定worker
- 非阻塞投递,队列满时丢弃任务
6. **生命周期控制** (ops_alert_service.go)
- 添加Start/Stop方法实现优雅关闭
- 使用context控制goroutine生命周期
- 实现WaitGroup等待后台任务完成
7. **Webhook URL验证** (ops_alert_service.go)
- 防止SSRF攻击:验证scheme、禁止内网IP
- DNS解析验证,拒绝解析到私有IP的域名
- 添加8个单元测试覆盖各种攻击场景
8. **资源泄漏** (ops_repo.go)
- 修复多处defer rows.Close()问题
- 简化冗余的defer func()包装
9. **HTTP超时控制** (ops_alert_service.go)
- 创建带10秒超时的http.Client
- 添加buildWebhookHTTPClient辅助函数
- 防止HTTP请求无限期挂起
10. **数据库查询优化** (ops_repo.go)
- 将GetWindowStats的4次独立查询合并为1次CTE查询
- 减少网络往返和表扫描次数
- 显著提升性能
11. **重试机制** (ops_alert_service.go)
- 实现邮件发送重试:最多3次,指数退避(1s/2s/4s)
- 添加webhook备用通道
- 实现完整的错误处理和日志记录
12. **魔法数字** (ops_repo.go, ops_metrics_collector.go)
- 提取硬编码数字为有意义的常量
- 提高代码可读性和可维护性
## 测试验证
- ✅ go test ./internal/service -tags opsalert_unit 通过
- ✅ 所有webhook验证测试通过
- ✅ 重试机制测试通过
## 影响范围
- 运维监控系统安全性显著提升
- 系统稳定性和性能优化
- 无破坏性变更,向后兼容
* feat(ops): 运维监控系统V2 - 完整实现
## 核心功能
- 运维监控仪表盘V2(实时监控、历史趋势、告警管理)
- WebSocket实时QPS/TPS监控(30s心跳,自动重连)
- 系统指标采集(CPU、内存、延迟、错误率等)
- 多维度统计分析(按provider、model、user等维度)
- 告警规则管理(阈值配置、通知渠道)
- 错误日志追踪(详细错误信息、堆栈跟踪)
## 数据库Schema (Migration 025)
### 扩展现有表
- ops_system_metrics: 新增RED指标、错误分类、延迟指标、资源指标、业务指标
- ops_alert_rules: 新增JSONB字段(dimension_filters, notify_channels, notify_config)
### 新增表
- ops_dimension_stats: 多维度统计数据
- ops_data_retention_config: 数据保留策略配置
### 新增视图和函数
- ops_latest_metrics: 最新1分钟窗口指标(已修复字段名和window过滤)
- ops_active_alerts: 当前活跃告警(已修复字段名和状态值)
- calculate_health_score: 健康分数计算函数
## 一致性修复(98/100分)
### P0级别(阻塞Migration)
- ✅ 修复ops_latest_metrics视图字段名(latency_p99→p99_latency_ms, cpu_usage→cpu_usage_percent)
- ✅ 修复ops_active_alerts视图字段名(metric→metric_type, triggered_at→fired_at, trigger_value→metric_value, threshold→threshold_value)
- ✅ 统一告警历史表名(删除ops_alert_history,使用ops_alert_events)
- ✅ 统一API参数限制(ListMetricsHistory和ListErrorLogs的limit改为5000)
### P1级别(功能完整性)
- ✅ 修复ops_latest_metrics视图未过滤window_minutes(添加WHERE m.window_minutes = 1)
- ✅ 修复数据回填UPDATE逻辑(QPS计算改为request_count/(window_minutes*60.0))
- ✅ 添加ops_alert_rules JSONB字段后端支持(Go结构体+序列化)
### P2级别(优化)
- ✅ 前端WebSocket自动重连(指数退避1s→2s→4s→8s→16s,最大5次)
- ✅ 后端WebSocket心跳检测(30s ping,60s pong超时)
## 技术实现
### 后端 (Go)
- Handler层: ops_handler.go(REST API), ops_ws_handler.go(WebSocket)
- Service层: ops_service.go(核心逻辑), ops_cache.go(缓存), ops_alerts.go(告警)
- Repository层: ops_repo.go(数据访问), ops.go(模型定义)
- 路由: admin.go(新增ops相关路由)
- 依赖注入: wire_gen.go(自动生成)
### 前端 (Vue3 + TypeScript)
- 组件: OpsDashboardV2.vue(仪表盘主组件)
- API: ops.ts(REST API + WebSocket封装)
- 路由: index.ts(新增/admin/ops路由)
- 国际化: en.ts, zh.ts(中英文支持)
## 测试验证
- ✅ 所有Go测试通过
- ✅ Migration可正常执行
- ✅ WebSocket连接稳定
- ✅ 前后端数据结构对齐
* refactor: 代码清理和测试优化
## 测试文件优化
- 简化integration test fixtures和断言
- 优化test helper函数
- 统一测试数据格式
## 代码清理
- 移除未使用的代码和注释
- 简化concurrency_cache实现
- 优化middleware错误处理
## 小修复
- 修复gateway_handler和openai_gateway_handler的小问题
- 统一代码风格和格式
变更统计: 27个文件,292行新增,322行删除(净减少30行)
* fix(ops): 运维监控系统安全加固和功能优化
## 安全增强
- feat(security): WebSocket日志脱敏机制,防止token/api_key泄露
- feat(security): X-Forwarded-Host白名单验证,防止CSRF绕过
- feat(security): Origin策略配置化,支持strict/permissive模式
- feat(auth): WebSocket认证支持query参数传递token
## 配置优化
- feat(config): 支持环境变量配置代理信任和Origin策略
- OPS_WS_TRUST_PROXY
- OPS_WS_TRUSTED_PROXIES
- OPS_WS_ORIGIN_POLICY
- fix(ops): 错误日志查询限流从5000降至500,优化内存使用
## 架构改进
- refactor(ops): 告警服务解耦,独立运行评估定时器
- refactor(ops): OpsDashboard统一版本,移除V2分离
## 测试和文档
- test(ops): 添加WebSocket安全验证单元测试(8个测试用例)
- test(ops): 添加告警服务集成测试
- docs(api): 更新API文档,标注限流变更
- docs: 添加CHANGELOG记录breaking changes
## 修复文件
Backend:
- backend/internal/server/middleware/logger.go
- backend/internal/handler/admin/ops_handler.go
- backend/internal/handler/admin/ops_ws_handler.go
- backend/internal/server/middleware/admin_auth.go
- backend/internal/service/ops_alert_service.go
- backend/internal/service/ops_metrics_collector.go
- backend/internal/service/wire.go
Frontend:
- frontend/src/views/admin/ops/OpsDashboard.vue
- frontend/src/router/index.ts
- frontend/src/api/admin/ops.ts
Tests:
- backend/internal/handler/admin/ops_ws_handler_test.go (新增)
- backend/internal/service/ops_alert_service_integration_test.go (新增)
Docs:
- CHANGELOG.md (新增)
- docs/API-运维监控中心2.0.md (更新)
* fix(migrations): 修复calculate_health_score函数类型匹配问题
在ops_latest_metrics视图中添加显式类型转换,确保参数类型与函数签名匹配
* fix(lint): 修复golangci-lint检查发现的所有问题
- 将Redis依赖从service层移到repository层
- 添加错误检查(WebSocket连接和读取超时)
- 运行gofmt格式化代码
- 添加nil指针检查
- 删除未使用的alertService字段
修复问题:
- depguard: 3个(service层不应直接import redis)
- errcheck: 3个(未检查错误返回值)
- gofmt: 2个(代码格式问题)
- staticcheck: 4个(nil指针解引用)
- unused: 1个(未使用字段)
代码统计:
- 修改文件:11个
- 删除代码:490行
- 新增代码:105行
- 净减少:385行
1161 lines
34 KiB
Go
1161 lines
34 KiB
Go
//go:build unit
|
|
|
|
package server_test
|
|
|
|
import (
|
|
"bytes"
|
|
"context"
|
|
"errors"
|
|
"io"
|
|
"math"
|
|
"net/http"
|
|
"net/http/httptest"
|
|
"sort"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/Wei-Shaw/sub2api/internal/config"
|
|
"github.com/Wei-Shaw/sub2api/internal/handler"
|
|
adminhandler "github.com/Wei-Shaw/sub2api/internal/handler/admin"
|
|
"github.com/Wei-Shaw/sub2api/internal/pkg/pagination"
|
|
"github.com/Wei-Shaw/sub2api/internal/pkg/usagestats"
|
|
"github.com/Wei-Shaw/sub2api/internal/server/middleware"
|
|
"github.com/Wei-Shaw/sub2api/internal/service"
|
|
|
|
"github.com/gin-gonic/gin"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
func TestAPIContracts(t *testing.T) {
|
|
gin.SetMode(gin.TestMode)
|
|
|
|
tests := []struct {
|
|
name string
|
|
setup func(t *testing.T, deps *contractDeps)
|
|
method string
|
|
path string
|
|
body string
|
|
headers map[string]string
|
|
wantStatus int
|
|
wantJSON string
|
|
}{
|
|
{
|
|
name: "GET /api/v1/auth/me",
|
|
method: http.MethodGet,
|
|
path: "/api/v1/auth/me",
|
|
wantStatus: http.StatusOK,
|
|
wantJSON: `{
|
|
"code": 0,
|
|
"message": "success",
|
|
"data": {
|
|
"id": 1,
|
|
"email": "alice@example.com",
|
|
"username": "alice",
|
|
"notes": "hello",
|
|
"role": "user",
|
|
"balance": 12.5,
|
|
"concurrency": 5,
|
|
"status": "active",
|
|
"allowed_groups": null,
|
|
"created_at": "2025-01-02T03:04:05Z",
|
|
"updated_at": "2025-01-02T03:04:05Z",
|
|
"run_mode": "standard"
|
|
}
|
|
}`,
|
|
},
|
|
{
|
|
name: "POST /api/v1/keys",
|
|
method: http.MethodPost,
|
|
path: "/api/v1/keys",
|
|
body: `{"name":"Key One","custom_key":"sk_custom_1234567890"}`,
|
|
headers: map[string]string{
|
|
"Content-Type": "application/json",
|
|
},
|
|
wantStatus: http.StatusOK,
|
|
wantJSON: `{
|
|
"code": 0,
|
|
"message": "success",
|
|
"data": {
|
|
"id": 100,
|
|
"user_id": 1,
|
|
"key": "sk_custom_1234567890",
|
|
"name": "Key One",
|
|
"group_id": null,
|
|
"status": "active",
|
|
"created_at": "2025-01-02T03:04:05Z",
|
|
"updated_at": "2025-01-02T03:04:05Z"
|
|
}
|
|
}`,
|
|
},
|
|
{
|
|
name: "GET /api/v1/keys (paginated)",
|
|
setup: func(t *testing.T, deps *contractDeps) {
|
|
t.Helper()
|
|
deps.apiKeyRepo.MustSeed(&service.APIKey{
|
|
ID: 100,
|
|
UserID: 1,
|
|
Key: "sk_custom_1234567890",
|
|
Name: "Key One",
|
|
Status: service.StatusActive,
|
|
CreatedAt: deps.now,
|
|
UpdatedAt: deps.now,
|
|
})
|
|
},
|
|
method: http.MethodGet,
|
|
path: "/api/v1/keys?page=1&page_size=10",
|
|
wantStatus: http.StatusOK,
|
|
wantJSON: `{
|
|
"code": 0,
|
|
"message": "success",
|
|
"data": {
|
|
"items": [
|
|
{
|
|
"id": 100,
|
|
"user_id": 1,
|
|
"key": "sk_custom_1234567890",
|
|
"name": "Key One",
|
|
"group_id": null,
|
|
"status": "active",
|
|
"created_at": "2025-01-02T03:04:05Z",
|
|
"updated_at": "2025-01-02T03:04:05Z"
|
|
}
|
|
],
|
|
"total": 1,
|
|
"page": 1,
|
|
"page_size": 10,
|
|
"pages": 1
|
|
}
|
|
}`,
|
|
},
|
|
{
|
|
name: "GET /api/v1/usage/stats",
|
|
setup: func(t *testing.T, deps *contractDeps) {
|
|
t.Helper()
|
|
deps.usageRepo.SetUserLogs(1, []service.UsageLog{
|
|
{
|
|
ID: 1,
|
|
UserID: 1,
|
|
APIKeyID: 100,
|
|
AccountID: 200,
|
|
Model: "claude-3",
|
|
InputTokens: 10,
|
|
OutputTokens: 20,
|
|
CacheCreationTokens: 1,
|
|
CacheReadTokens: 2,
|
|
TotalCost: 0.5,
|
|
ActualCost: 0.5,
|
|
DurationMs: ptr(100),
|
|
CreatedAt: deps.now,
|
|
},
|
|
{
|
|
ID: 2,
|
|
UserID: 1,
|
|
APIKeyID: 100,
|
|
AccountID: 200,
|
|
Model: "claude-3",
|
|
InputTokens: 5,
|
|
OutputTokens: 15,
|
|
TotalCost: 0.25,
|
|
ActualCost: 0.25,
|
|
DurationMs: ptr(300),
|
|
CreatedAt: deps.now,
|
|
},
|
|
})
|
|
},
|
|
method: http.MethodGet,
|
|
path: "/api/v1/usage/stats?start_date=2025-01-01&end_date=2025-01-02",
|
|
wantStatus: http.StatusOK,
|
|
wantJSON: `{
|
|
"code": 0,
|
|
"message": "success",
|
|
"data": {
|
|
"total_requests": 2,
|
|
"total_input_tokens": 15,
|
|
"total_output_tokens": 35,
|
|
"total_cache_tokens": 3,
|
|
"total_tokens": 53,
|
|
"total_cost": 0.75,
|
|
"total_actual_cost": 0.75,
|
|
"average_duration_ms": 200
|
|
}
|
|
}`,
|
|
},
|
|
{
|
|
name: "GET /api/v1/usage (paginated)",
|
|
setup: func(t *testing.T, deps *contractDeps) {
|
|
t.Helper()
|
|
deps.usageRepo.SetUserLogs(1, []service.UsageLog{
|
|
{
|
|
ID: 1,
|
|
UserID: 1,
|
|
APIKeyID: 100,
|
|
AccountID: 200,
|
|
RequestID: "req_123",
|
|
Model: "claude-3",
|
|
InputTokens: 10,
|
|
OutputTokens: 20,
|
|
CacheCreationTokens: 1,
|
|
CacheReadTokens: 2,
|
|
TotalCost: 0.5,
|
|
ActualCost: 0.5,
|
|
RateMultiplier: 1,
|
|
BillingType: service.BillingTypeBalance,
|
|
Stream: true,
|
|
DurationMs: ptr(100),
|
|
FirstTokenMs: ptr(50),
|
|
CreatedAt: deps.now,
|
|
},
|
|
})
|
|
},
|
|
method: http.MethodGet,
|
|
path: "/api/v1/usage?page=1&page_size=10",
|
|
wantStatus: http.StatusOK,
|
|
wantJSON: `{
|
|
"code": 0,
|
|
"message": "success",
|
|
"data": {
|
|
"items": [
|
|
{
|
|
"id": 1,
|
|
"user_id": 1,
|
|
"api_key_id": 100,
|
|
"account_id": 200,
|
|
"request_id": "req_123",
|
|
"model": "claude-3",
|
|
"group_id": null,
|
|
"subscription_id": null,
|
|
"input_tokens": 10,
|
|
"output_tokens": 20,
|
|
"cache_creation_tokens": 1,
|
|
"cache_read_tokens": 2,
|
|
"cache_creation_5m_tokens": 0,
|
|
"cache_creation_1h_tokens": 0,
|
|
"input_cost": 0,
|
|
"output_cost": 0,
|
|
"cache_creation_cost": 0,
|
|
"cache_read_cost": 0,
|
|
"total_cost": 0.5,
|
|
"actual_cost": 0.5,
|
|
"rate_multiplier": 1,
|
|
"billing_type": 0,
|
|
"stream": true,
|
|
"duration_ms": 100,
|
|
"first_token_ms": 50,
|
|
"created_at": "2025-01-02T03:04:05Z"
|
|
}
|
|
],
|
|
"total": 1,
|
|
"page": 1,
|
|
"page_size": 10,
|
|
"pages": 1
|
|
}
|
|
}`,
|
|
},
|
|
{
|
|
name: "GET /api/v1/admin/settings",
|
|
setup: func(t *testing.T, deps *contractDeps) {
|
|
t.Helper()
|
|
deps.settingRepo.SetAll(map[string]string{
|
|
service.SettingKeyRegistrationEnabled: "true",
|
|
service.SettingKeyEmailVerifyEnabled: "false",
|
|
|
|
service.SettingKeySMTPHost: "smtp.example.com",
|
|
service.SettingKeySMTPPort: "587",
|
|
service.SettingKeySMTPUsername: "user",
|
|
service.SettingKeySMTPPassword: "secret",
|
|
service.SettingKeySMTPFrom: "no-reply@example.com",
|
|
service.SettingKeySMTPFromName: "Sub2API",
|
|
service.SettingKeySMTPUseTLS: "true",
|
|
|
|
service.SettingKeyTurnstileEnabled: "true",
|
|
service.SettingKeyTurnstileSiteKey: "site-key",
|
|
service.SettingKeyTurnstileSecretKey: "secret-key",
|
|
|
|
service.SettingKeySiteName: "Sub2API",
|
|
service.SettingKeySiteLogo: "",
|
|
service.SettingKeySiteSubtitle: "Subtitle",
|
|
service.SettingKeyAPIBaseURL: "https://api.example.com",
|
|
service.SettingKeyContactInfo: "support",
|
|
service.SettingKeyDocURL: "https://docs.example.com",
|
|
|
|
service.SettingKeyDefaultConcurrency: "5",
|
|
service.SettingKeyDefaultBalance: "1.25",
|
|
})
|
|
},
|
|
method: http.MethodGet,
|
|
path: "/api/v1/admin/settings",
|
|
wantStatus: http.StatusOK,
|
|
wantJSON: `{
|
|
"code": 0,
|
|
"message": "success",
|
|
"data": {
|
|
"registration_enabled": true,
|
|
"email_verify_enabled": false,
|
|
"smtp_host": "smtp.example.com",
|
|
"smtp_port": 587,
|
|
"smtp_username": "user",
|
|
"smtp_password": "secret",
|
|
"smtp_from_email": "no-reply@example.com",
|
|
"smtp_from_name": "Sub2API",
|
|
"smtp_use_tls": true,
|
|
"turnstile_enabled": true,
|
|
"turnstile_site_key": "site-key",
|
|
"turnstile_secret_key": "secret-key",
|
|
"site_name": "Sub2API",
|
|
"site_logo": "",
|
|
"site_subtitle": "Subtitle",
|
|
"api_base_url": "https://api.example.com",
|
|
"contact_info": "support",
|
|
"doc_url": "https://docs.example.com",
|
|
"default_concurrency": 5,
|
|
"default_balance": 1.25
|
|
}
|
|
}`,
|
|
},
|
|
}
|
|
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
deps := newContractDeps(t)
|
|
if tt.setup != nil {
|
|
tt.setup(t, deps)
|
|
}
|
|
|
|
status, body := doRequest(t, deps.router, tt.method, tt.path, tt.body, tt.headers)
|
|
require.Equal(t, tt.wantStatus, status)
|
|
require.JSONEq(t, tt.wantJSON, body)
|
|
})
|
|
}
|
|
}
|
|
|
|
type contractDeps struct {
|
|
now time.Time
|
|
router http.Handler
|
|
apiKeyRepo *stubAPIKeyRepo
|
|
usageRepo *stubUsageLogRepo
|
|
settingRepo *stubSettingRepo
|
|
}
|
|
|
|
func newContractDeps(t *testing.T) *contractDeps {
|
|
t.Helper()
|
|
|
|
now := time.Date(2025, 1, 2, 3, 4, 5, 0, time.UTC)
|
|
|
|
userRepo := &stubUserRepo{
|
|
users: map[int64]*service.User{
|
|
1: {
|
|
ID: 1,
|
|
Email: "alice@example.com",
|
|
Username: "alice",
|
|
Notes: "hello",
|
|
Role: service.RoleUser,
|
|
Balance: 12.5,
|
|
Concurrency: 5,
|
|
Status: service.StatusActive,
|
|
AllowedGroups: nil,
|
|
CreatedAt: now,
|
|
UpdatedAt: now,
|
|
},
|
|
},
|
|
}
|
|
|
|
apiKeyRepo := newStubAPIKeyRepo(now)
|
|
apiKeyCache := stubAPIKeyCache{}
|
|
groupRepo := stubGroupRepo{}
|
|
userSubRepo := stubUserSubscriptionRepo{}
|
|
|
|
cfg := &config.Config{
|
|
Default: config.DefaultConfig{
|
|
APIKeyPrefix: "sk-",
|
|
},
|
|
RunMode: config.RunModeStandard,
|
|
}
|
|
|
|
userService := service.NewUserService(userRepo)
|
|
apiKeyService := service.NewAPIKeyService(apiKeyRepo, userRepo, groupRepo, userSubRepo, apiKeyCache, cfg)
|
|
|
|
usageRepo := newStubUsageLogRepo()
|
|
usageService := service.NewUsageService(usageRepo, userRepo)
|
|
|
|
settingRepo := newStubSettingRepo()
|
|
settingService := service.NewSettingService(settingRepo, cfg)
|
|
|
|
authHandler := handler.NewAuthHandler(cfg, nil, userService)
|
|
apiKeyHandler := handler.NewAPIKeyHandler(apiKeyService)
|
|
usageHandler := handler.NewUsageHandler(usageService, apiKeyService)
|
|
adminSettingHandler := adminhandler.NewSettingHandler(settingService, nil, nil)
|
|
|
|
jwtAuth := func(c *gin.Context) {
|
|
c.Set(string(middleware.ContextKeyUser), middleware.AuthSubject{
|
|
UserID: 1,
|
|
Concurrency: 5,
|
|
})
|
|
c.Set(string(middleware.ContextKeyUserRole), service.RoleUser)
|
|
c.Next()
|
|
}
|
|
adminAuth := func(c *gin.Context) {
|
|
c.Set(string(middleware.ContextKeyUser), middleware.AuthSubject{
|
|
UserID: 1,
|
|
Concurrency: 5,
|
|
})
|
|
c.Set(string(middleware.ContextKeyUserRole), service.RoleAdmin)
|
|
c.Next()
|
|
}
|
|
|
|
r := gin.New()
|
|
|
|
v1 := r.Group("/api/v1")
|
|
|
|
v1Auth := v1.Group("")
|
|
v1Auth.Use(jwtAuth)
|
|
v1Auth.GET("/auth/me", authHandler.GetCurrentUser)
|
|
|
|
v1Keys := v1.Group("")
|
|
v1Keys.Use(jwtAuth)
|
|
v1Keys.GET("/keys", apiKeyHandler.List)
|
|
v1Keys.POST("/keys", apiKeyHandler.Create)
|
|
|
|
v1Usage := v1.Group("")
|
|
v1Usage.Use(jwtAuth)
|
|
v1Usage.GET("/usage", usageHandler.List)
|
|
v1Usage.GET("/usage/stats", usageHandler.Stats)
|
|
|
|
v1Admin := v1.Group("/admin")
|
|
v1Admin.Use(adminAuth)
|
|
v1Admin.GET("/settings", adminSettingHandler.GetSettings)
|
|
|
|
return &contractDeps{
|
|
now: now,
|
|
router: r,
|
|
apiKeyRepo: apiKeyRepo,
|
|
usageRepo: usageRepo,
|
|
settingRepo: settingRepo,
|
|
}
|
|
}
|
|
|
|
func doRequest(t *testing.T, router http.Handler, method, path, body string, headers map[string]string) (int, string) {
|
|
t.Helper()
|
|
|
|
req := httptest.NewRequest(method, path, bytes.NewBufferString(body))
|
|
for k, v := range headers {
|
|
req.Header.Set(k, v)
|
|
}
|
|
|
|
w := httptest.NewRecorder()
|
|
router.ServeHTTP(w, req)
|
|
|
|
respBody, err := io.ReadAll(w.Result().Body)
|
|
require.NoError(t, err)
|
|
|
|
return w.Result().StatusCode, string(respBody)
|
|
}
|
|
|
|
func ptr[T any](v T) *T { return &v }
|
|
|
|
type stubUserRepo struct {
|
|
users map[int64]*service.User
|
|
}
|
|
|
|
func (r *stubUserRepo) Create(ctx context.Context, user *service.User) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUserRepo) GetByID(ctx context.Context, id int64) (*service.User, error) {
|
|
user, ok := r.users[id]
|
|
if !ok {
|
|
return nil, service.ErrUserNotFound
|
|
}
|
|
clone := *user
|
|
return &clone, nil
|
|
}
|
|
|
|
func (r *stubUserRepo) GetByEmail(ctx context.Context, email string) (*service.User, error) {
|
|
for _, user := range r.users {
|
|
if user.Email == email {
|
|
clone := *user
|
|
return &clone, nil
|
|
}
|
|
}
|
|
return nil, service.ErrUserNotFound
|
|
}
|
|
|
|
func (r *stubUserRepo) GetFirstAdmin(ctx context.Context) (*service.User, error) {
|
|
for _, user := range r.users {
|
|
if user.Role == service.RoleAdmin && user.Status == service.StatusActive {
|
|
clone := *user
|
|
return &clone, nil
|
|
}
|
|
}
|
|
return nil, service.ErrUserNotFound
|
|
}
|
|
|
|
func (r *stubUserRepo) Update(ctx context.Context, user *service.User) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUserRepo) Delete(ctx context.Context, id int64) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUserRepo) List(ctx context.Context, params pagination.PaginationParams) ([]service.User, *pagination.PaginationResult, error) {
|
|
return nil, nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUserRepo) ListWithFilters(ctx context.Context, params pagination.PaginationParams, filters service.UserListFilters) ([]service.User, *pagination.PaginationResult, error) {
|
|
return nil, nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUserRepo) UpdateBalance(ctx context.Context, id int64, amount float64) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUserRepo) DeductBalance(ctx context.Context, id int64, amount float64) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUserRepo) UpdateConcurrency(ctx context.Context, id int64, amount int) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUserRepo) ExistsByEmail(ctx context.Context, email string) (bool, error) {
|
|
return false, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUserRepo) RemoveGroupFromAllowedGroups(ctx context.Context, groupID int64) (int64, error) {
|
|
return 0, errors.New("not implemented")
|
|
}
|
|
|
|
type stubAPIKeyCache struct{}
|
|
|
|
func (stubAPIKeyCache) GetCreateAttemptCount(ctx context.Context, userID int64) (int, error) {
|
|
return 0, nil
|
|
}
|
|
|
|
func (stubAPIKeyCache) IncrementCreateAttemptCount(ctx context.Context, userID int64) error {
|
|
return nil
|
|
}
|
|
|
|
func (stubAPIKeyCache) DeleteCreateAttemptCount(ctx context.Context, userID int64) error {
|
|
return nil
|
|
}
|
|
|
|
func (stubAPIKeyCache) IncrementDailyUsage(ctx context.Context, apiKey string) error {
|
|
return nil
|
|
}
|
|
|
|
func (stubAPIKeyCache) SetDailyUsageExpiry(ctx context.Context, apiKey string, ttl time.Duration) error {
|
|
return nil
|
|
}
|
|
|
|
type stubGroupRepo struct{}
|
|
|
|
func (stubGroupRepo) Create(ctx context.Context, group *service.Group) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
|
|
func (stubGroupRepo) GetByID(ctx context.Context, id int64) (*service.Group, error) {
|
|
return nil, service.ErrGroupNotFound
|
|
}
|
|
|
|
func (stubGroupRepo) Update(ctx context.Context, group *service.Group) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
|
|
func (stubGroupRepo) Delete(ctx context.Context, id int64) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
|
|
func (stubGroupRepo) DeleteCascade(ctx context.Context, id int64) ([]int64, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (stubGroupRepo) List(ctx context.Context, params pagination.PaginationParams) ([]service.Group, *pagination.PaginationResult, error) {
|
|
return nil, nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (stubGroupRepo) ListWithFilters(ctx context.Context, params pagination.PaginationParams, platform, status string, isExclusive *bool) ([]service.Group, *pagination.PaginationResult, error) {
|
|
return nil, nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (stubGroupRepo) ListActive(ctx context.Context) ([]service.Group, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (stubGroupRepo) ListActiveByPlatform(ctx context.Context, platform string) ([]service.Group, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (stubGroupRepo) ExistsByName(ctx context.Context, name string) (bool, error) {
|
|
return false, errors.New("not implemented")
|
|
}
|
|
|
|
func (stubGroupRepo) GetAccountCount(ctx context.Context, groupID int64) (int64, error) {
|
|
return 0, errors.New("not implemented")
|
|
}
|
|
|
|
func (stubGroupRepo) DeleteAccountGroupsByGroupID(ctx context.Context, groupID int64) (int64, error) {
|
|
return 0, errors.New("not implemented")
|
|
}
|
|
|
|
type stubUserSubscriptionRepo struct{}
|
|
|
|
func (stubUserSubscriptionRepo) Create(ctx context.Context, sub *service.UserSubscription) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) GetByID(ctx context.Context, id int64) (*service.UserSubscription, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) GetByUserIDAndGroupID(ctx context.Context, userID, groupID int64) (*service.UserSubscription, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) GetActiveByUserIDAndGroupID(ctx context.Context, userID, groupID int64) (*service.UserSubscription, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) Update(ctx context.Context, sub *service.UserSubscription) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) Delete(ctx context.Context, id int64) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) ListByUserID(ctx context.Context, userID int64) ([]service.UserSubscription, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) ListActiveByUserID(ctx context.Context, userID int64) ([]service.UserSubscription, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) ListByGroupID(ctx context.Context, groupID int64, params pagination.PaginationParams) ([]service.UserSubscription, *pagination.PaginationResult, error) {
|
|
return nil, nil, errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) List(ctx context.Context, params pagination.PaginationParams, userID, groupID *int64, status string) ([]service.UserSubscription, *pagination.PaginationResult, error) {
|
|
return nil, nil, errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) ExistsByUserIDAndGroupID(ctx context.Context, userID, groupID int64) (bool, error) {
|
|
return false, errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) ExtendExpiry(ctx context.Context, subscriptionID int64, newExpiresAt time.Time) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) UpdateStatus(ctx context.Context, subscriptionID int64, status string) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) UpdateNotes(ctx context.Context, subscriptionID int64, notes string) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) ActivateWindows(ctx context.Context, id int64, start time.Time) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) ResetDailyUsage(ctx context.Context, id int64, newWindowStart time.Time) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) ResetWeeklyUsage(ctx context.Context, id int64, newWindowStart time.Time) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) ResetMonthlyUsage(ctx context.Context, id int64, newWindowStart time.Time) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) IncrementUsage(ctx context.Context, id int64, costUSD float64) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
func (stubUserSubscriptionRepo) BatchUpdateExpiredStatus(ctx context.Context) (int64, error) {
|
|
return 0, errors.New("not implemented")
|
|
}
|
|
|
|
type stubAPIKeyRepo struct {
|
|
now time.Time
|
|
|
|
nextID int64
|
|
byID map[int64]*service.APIKey
|
|
byKey map[string]*service.APIKey
|
|
}
|
|
|
|
func newStubAPIKeyRepo(now time.Time) *stubAPIKeyRepo {
|
|
return &stubAPIKeyRepo{
|
|
now: now,
|
|
nextID: 100,
|
|
byID: make(map[int64]*service.APIKey),
|
|
byKey: make(map[string]*service.APIKey),
|
|
}
|
|
}
|
|
|
|
func (r *stubAPIKeyRepo) MustSeed(key *service.APIKey) {
|
|
if key == nil {
|
|
return
|
|
}
|
|
clone := *key
|
|
r.byID[clone.ID] = &clone
|
|
r.byKey[clone.Key] = &clone
|
|
}
|
|
|
|
func (r *stubAPIKeyRepo) Create(ctx context.Context, key *service.APIKey) error {
|
|
if key == nil {
|
|
return errors.New("nil key")
|
|
}
|
|
if key.ID == 0 {
|
|
key.ID = r.nextID
|
|
r.nextID++
|
|
}
|
|
if key.CreatedAt.IsZero() {
|
|
key.CreatedAt = r.now
|
|
}
|
|
if key.UpdatedAt.IsZero() {
|
|
key.UpdatedAt = r.now
|
|
}
|
|
clone := *key
|
|
r.byID[clone.ID] = &clone
|
|
r.byKey[clone.Key] = &clone
|
|
return nil
|
|
}
|
|
|
|
func (r *stubAPIKeyRepo) GetByID(ctx context.Context, id int64) (*service.APIKey, error) {
|
|
key, ok := r.byID[id]
|
|
if !ok {
|
|
return nil, service.ErrAPIKeyNotFound
|
|
}
|
|
clone := *key
|
|
return &clone, nil
|
|
}
|
|
|
|
func (r *stubAPIKeyRepo) GetOwnerID(ctx context.Context, id int64) (int64, error) {
|
|
key, ok := r.byID[id]
|
|
if !ok {
|
|
return 0, service.ErrAPIKeyNotFound
|
|
}
|
|
return key.UserID, nil
|
|
}
|
|
|
|
func (r *stubAPIKeyRepo) GetByKey(ctx context.Context, key string) (*service.APIKey, error) {
|
|
found, ok := r.byKey[key]
|
|
if !ok {
|
|
return nil, service.ErrAPIKeyNotFound
|
|
}
|
|
clone := *found
|
|
return &clone, nil
|
|
}
|
|
|
|
func (r *stubAPIKeyRepo) Update(ctx context.Context, key *service.APIKey) error {
|
|
if key == nil {
|
|
return errors.New("nil key")
|
|
}
|
|
if _, ok := r.byID[key.ID]; !ok {
|
|
return service.ErrAPIKeyNotFound
|
|
}
|
|
if key.UpdatedAt.IsZero() {
|
|
key.UpdatedAt = r.now
|
|
}
|
|
clone := *key
|
|
r.byID[clone.ID] = &clone
|
|
r.byKey[clone.Key] = &clone
|
|
return nil
|
|
}
|
|
|
|
func (r *stubAPIKeyRepo) Delete(ctx context.Context, id int64) error {
|
|
key, ok := r.byID[id]
|
|
if !ok {
|
|
return service.ErrAPIKeyNotFound
|
|
}
|
|
delete(r.byID, id)
|
|
delete(r.byKey, key.Key)
|
|
return nil
|
|
}
|
|
|
|
func (r *stubAPIKeyRepo) ListByUserID(ctx context.Context, userID int64, params pagination.PaginationParams) ([]service.APIKey, *pagination.PaginationResult, error) {
|
|
ids := make([]int64, 0, len(r.byID))
|
|
for id := range r.byID {
|
|
if r.byID[id].UserID == userID {
|
|
ids = append(ids, id)
|
|
}
|
|
}
|
|
sort.Slice(ids, func(i, j int) bool { return ids[i] > ids[j] })
|
|
|
|
start := params.Offset()
|
|
if start > len(ids) {
|
|
start = len(ids)
|
|
}
|
|
end := start + params.Limit()
|
|
if end > len(ids) {
|
|
end = len(ids)
|
|
}
|
|
|
|
out := make([]service.APIKey, 0, end-start)
|
|
for _, id := range ids[start:end] {
|
|
clone := *r.byID[id]
|
|
out = append(out, clone)
|
|
}
|
|
|
|
total := int64(len(ids))
|
|
pageSize := params.Limit()
|
|
pages := int(math.Ceil(float64(total) / float64(pageSize)))
|
|
if pages < 1 {
|
|
pages = 1
|
|
}
|
|
return out, &pagination.PaginationResult{
|
|
Total: total,
|
|
Page: params.Page,
|
|
PageSize: pageSize,
|
|
Pages: pages,
|
|
}, nil
|
|
}
|
|
|
|
func (r *stubAPIKeyRepo) VerifyOwnership(ctx context.Context, userID int64, apiKeyIDs []int64) ([]int64, error) {
|
|
if len(apiKeyIDs) == 0 {
|
|
return []int64{}, nil
|
|
}
|
|
seen := make(map[int64]struct{}, len(apiKeyIDs))
|
|
out := make([]int64, 0, len(apiKeyIDs))
|
|
for _, id := range apiKeyIDs {
|
|
if _, ok := seen[id]; ok {
|
|
continue
|
|
}
|
|
seen[id] = struct{}{}
|
|
key, ok := r.byID[id]
|
|
if ok && key.UserID == userID {
|
|
out = append(out, id)
|
|
}
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (r *stubAPIKeyRepo) CountByUserID(ctx context.Context, userID int64) (int64, error) {
|
|
var count int64
|
|
for _, key := range r.byID {
|
|
if key.UserID == userID {
|
|
count++
|
|
}
|
|
}
|
|
return count, nil
|
|
}
|
|
|
|
func (r *stubAPIKeyRepo) ExistsByKey(ctx context.Context, key string) (bool, error) {
|
|
_, ok := r.byKey[key]
|
|
return ok, nil
|
|
}
|
|
|
|
func (r *stubAPIKeyRepo) ListByGroupID(ctx context.Context, groupID int64, params pagination.PaginationParams) ([]service.APIKey, *pagination.PaginationResult, error) {
|
|
return nil, nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubAPIKeyRepo) SearchAPIKeys(ctx context.Context, userID int64, keyword string, limit int) ([]service.APIKey, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubAPIKeyRepo) ClearGroupIDByGroupID(ctx context.Context, groupID int64) (int64, error) {
|
|
return 0, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubAPIKeyRepo) CountByGroupID(ctx context.Context, groupID int64) (int64, error) {
|
|
return 0, errors.New("not implemented")
|
|
}
|
|
|
|
type stubUsageLogRepo struct {
|
|
userLogs map[int64][]service.UsageLog
|
|
}
|
|
|
|
func newStubUsageLogRepo() *stubUsageLogRepo {
|
|
return &stubUsageLogRepo{userLogs: make(map[int64][]service.UsageLog)}
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) SetUserLogs(userID int64, logs []service.UsageLog) {
|
|
r.userLogs[userID] = logs
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) Create(ctx context.Context, log *service.UsageLog) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetByID(ctx context.Context, id int64) (*service.UsageLog, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) Delete(ctx context.Context, id int64) error {
|
|
return errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) ListByUser(ctx context.Context, userID int64, params pagination.PaginationParams) ([]service.UsageLog, *pagination.PaginationResult, error) {
|
|
logs := r.userLogs[userID]
|
|
total := int64(len(logs))
|
|
out := paginateLogs(logs, params)
|
|
return out, paginationResult(total, params), nil
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) ListByAPIKey(ctx context.Context, apiKeyID int64, params pagination.PaginationParams) ([]service.UsageLog, *pagination.PaginationResult, error) {
|
|
return nil, nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) ListByAccount(ctx context.Context, accountID int64, params pagination.PaginationParams) ([]service.UsageLog, *pagination.PaginationResult, error) {
|
|
return nil, nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) ListByUserAndTimeRange(ctx context.Context, userID int64, startTime, endTime time.Time) ([]service.UsageLog, *pagination.PaginationResult, error) {
|
|
logs := r.userLogs[userID]
|
|
return logs, paginationResult(int64(len(logs)), pagination.PaginationParams{Page: 1, PageSize: 100}), nil
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) ListByAPIKeyAndTimeRange(ctx context.Context, apiKeyID int64, startTime, endTime time.Time) ([]service.UsageLog, *pagination.PaginationResult, error) {
|
|
return nil, nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) ListByAccountAndTimeRange(ctx context.Context, accountID int64, startTime, endTime time.Time) ([]service.UsageLog, *pagination.PaginationResult, error) {
|
|
return nil, nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) ListByModelAndTimeRange(ctx context.Context, modelName string, startTime, endTime time.Time) ([]service.UsageLog, *pagination.PaginationResult, error) {
|
|
return nil, nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetAccountWindowStats(ctx context.Context, accountID int64, startTime time.Time) (*usagestats.AccountStats, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetAccountTodayStats(ctx context.Context, accountID int64) (*usagestats.AccountStats, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetDashboardStats(ctx context.Context) (*usagestats.DashboardStats, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetUsageTrendWithFilters(ctx context.Context, startTime, endTime time.Time, granularity string, userID, apiKeyID int64) ([]usagestats.TrendDataPoint, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetModelStatsWithFilters(ctx context.Context, startTime, endTime time.Time, userID, apiKeyID, accountID int64) ([]usagestats.ModelStat, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetAPIKeyUsageTrend(ctx context.Context, startTime, endTime time.Time, granularity string, limit int) ([]usagestats.APIKeyUsageTrendPoint, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetUserUsageTrend(ctx context.Context, startTime, endTime time.Time, granularity string, limit int) ([]usagestats.UserUsageTrendPoint, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetUserStatsAggregated(ctx context.Context, userID int64, startTime, endTime time.Time) (*usagestats.UsageStats, error) {
|
|
logs := r.userLogs[userID]
|
|
if len(logs) == 0 {
|
|
return &usagestats.UsageStats{}, nil
|
|
}
|
|
|
|
var totalRequests int64
|
|
var totalInputTokens int64
|
|
var totalOutputTokens int64
|
|
var totalCacheTokens int64
|
|
var totalCost float64
|
|
var totalActualCost float64
|
|
var totalDuration int64
|
|
var durationCount int64
|
|
|
|
for _, log := range logs {
|
|
totalRequests++
|
|
totalInputTokens += int64(log.InputTokens)
|
|
totalOutputTokens += int64(log.OutputTokens)
|
|
totalCacheTokens += int64(log.CacheCreationTokens + log.CacheReadTokens)
|
|
totalCost += log.TotalCost
|
|
totalActualCost += log.ActualCost
|
|
if log.DurationMs != nil {
|
|
totalDuration += int64(*log.DurationMs)
|
|
durationCount++
|
|
}
|
|
}
|
|
|
|
var avgDuration float64
|
|
if durationCount > 0 {
|
|
avgDuration = float64(totalDuration) / float64(durationCount)
|
|
}
|
|
|
|
return &usagestats.UsageStats{
|
|
TotalRequests: totalRequests,
|
|
TotalInputTokens: totalInputTokens,
|
|
TotalOutputTokens: totalOutputTokens,
|
|
TotalCacheTokens: totalCacheTokens,
|
|
TotalTokens: totalInputTokens + totalOutputTokens + totalCacheTokens,
|
|
TotalCost: totalCost,
|
|
TotalActualCost: totalActualCost,
|
|
AverageDurationMs: avgDuration,
|
|
}, nil
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetAPIKeyStatsAggregated(ctx context.Context, apiKeyID int64, startTime, endTime time.Time) (*usagestats.UsageStats, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetAccountStatsAggregated(ctx context.Context, accountID int64, startTime, endTime time.Time) (*usagestats.UsageStats, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetModelStatsAggregated(ctx context.Context, modelName string, startTime, endTime time.Time) (*usagestats.UsageStats, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetDailyStatsAggregated(ctx context.Context, userID int64, startTime, endTime time.Time) ([]map[string]any, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetBatchUserUsageStats(ctx context.Context, userIDs []int64) (map[int64]*usagestats.BatchUserUsageStats, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetBatchAPIKeyUsageStats(ctx context.Context, apiKeyIDs []int64) (map[int64]*usagestats.BatchAPIKeyUsageStats, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetUserDashboardStats(ctx context.Context, userID int64) (*usagestats.UserDashboardStats, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetUserUsageTrendByUserID(ctx context.Context, userID int64, startTime, endTime time.Time, granularity string) ([]usagestats.TrendDataPoint, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetUserModelStats(ctx context.Context, userID int64, startTime, endTime time.Time) ([]usagestats.ModelStat, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) ListWithFilters(ctx context.Context, params pagination.PaginationParams, filters usagestats.UsageLogFilters) ([]service.UsageLog, *pagination.PaginationResult, error) {
|
|
logs := r.userLogs[filters.UserID]
|
|
|
|
// Apply filters
|
|
var filtered []service.UsageLog
|
|
for _, log := range logs {
|
|
// Apply APIKeyID filter
|
|
if filters.APIKeyID > 0 && log.APIKeyID != filters.APIKeyID {
|
|
continue
|
|
}
|
|
// Apply Model filter
|
|
if filters.Model != "" && log.Model != filters.Model {
|
|
continue
|
|
}
|
|
// Apply Stream filter
|
|
if filters.Stream != nil && log.Stream != *filters.Stream {
|
|
continue
|
|
}
|
|
// Apply BillingType filter
|
|
if filters.BillingType != nil && log.BillingType != *filters.BillingType {
|
|
continue
|
|
}
|
|
// Apply time range filters
|
|
if filters.StartTime != nil && log.CreatedAt.Before(*filters.StartTime) {
|
|
continue
|
|
}
|
|
if filters.EndTime != nil && log.CreatedAt.After(*filters.EndTime) {
|
|
continue
|
|
}
|
|
filtered = append(filtered, log)
|
|
}
|
|
|
|
total := int64(len(filtered))
|
|
out := paginateLogs(filtered, params)
|
|
return out, paginationResult(total, params), nil
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetGlobalStats(ctx context.Context, startTime, endTime time.Time) (*usagestats.UsageStats, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
func (r *stubUsageLogRepo) GetAccountUsageStats(ctx context.Context, accountID int64, startTime, endTime time.Time) (*usagestats.AccountUsageStatsResponse, error) {
|
|
return nil, errors.New("not implemented")
|
|
}
|
|
|
|
type stubSettingRepo struct {
|
|
all map[string]string
|
|
}
|
|
|
|
func newStubSettingRepo() *stubSettingRepo {
|
|
return &stubSettingRepo{all: make(map[string]string)}
|
|
}
|
|
|
|
func (r *stubSettingRepo) SetAll(values map[string]string) {
|
|
r.all = make(map[string]string, len(values))
|
|
for k, v := range values {
|
|
r.all[k] = v
|
|
}
|
|
}
|
|
|
|
func (r *stubSettingRepo) Get(ctx context.Context, key string) (*service.Setting, error) {
|
|
value, ok := r.all[key]
|
|
if !ok {
|
|
return nil, service.ErrSettingNotFound
|
|
}
|
|
return &service.Setting{Key: key, Value: value}, nil
|
|
}
|
|
|
|
func (r *stubSettingRepo) GetValue(ctx context.Context, key string) (string, error) {
|
|
value, ok := r.all[key]
|
|
if !ok {
|
|
return "", service.ErrSettingNotFound
|
|
}
|
|
return value, nil
|
|
}
|
|
|
|
func (r *stubSettingRepo) Set(ctx context.Context, key, value string) error {
|
|
r.all[key] = value
|
|
return nil
|
|
}
|
|
|
|
func (r *stubSettingRepo) GetMultiple(ctx context.Context, keys []string) (map[string]string, error) {
|
|
out := make(map[string]string, len(keys))
|
|
for _, key := range keys {
|
|
out[key] = r.all[key]
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (r *stubSettingRepo) SetMultiple(ctx context.Context, settings map[string]string) error {
|
|
for k, v := range settings {
|
|
r.all[k] = v
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (r *stubSettingRepo) GetAll(ctx context.Context) (map[string]string, error) {
|
|
out := make(map[string]string, len(r.all))
|
|
for k, v := range r.all {
|
|
out[k] = v
|
|
}
|
|
return out, nil
|
|
}
|
|
|
|
func (r *stubSettingRepo) Delete(ctx context.Context, key string) error {
|
|
delete(r.all, key)
|
|
return nil
|
|
}
|
|
|
|
func paginateLogs(logs []service.UsageLog, params pagination.PaginationParams) []service.UsageLog {
|
|
start := params.Offset()
|
|
if start > len(logs) {
|
|
start = len(logs)
|
|
}
|
|
end := start + params.Limit()
|
|
if end > len(logs) {
|
|
end = len(logs)
|
|
}
|
|
out := make([]service.UsageLog, 0, end-start)
|
|
out = append(out, logs[start:end]...)
|
|
return out
|
|
}
|
|
|
|
func paginationResult(total int64, params pagination.PaginationParams) *pagination.PaginationResult {
|
|
pageSize := params.Limit()
|
|
pages := int(math.Ceil(float64(total) / float64(pageSize)))
|
|
if pages < 1 {
|
|
pages = 1
|
|
}
|
|
return &pagination.PaginationResult{
|
|
Total: total,
|
|
Page: params.Page,
|
|
PageSize: pageSize,
|
|
Pages: pages,
|
|
}
|
|
}
|
|
|
|
// Ensure compile-time interface compliance.
|
|
var (
|
|
_ service.UserRepository = (*stubUserRepo)(nil)
|
|
_ service.APIKeyRepository = (*stubAPIKeyRepo)(nil)
|
|
_ service.APIKeyCache = (*stubAPIKeyCache)(nil)
|
|
_ service.GroupRepository = (*stubGroupRepo)(nil)
|
|
_ service.UserSubscriptionRepository = (*stubUserSubscriptionRepo)(nil)
|
|
_ service.UsageLogRepository = (*stubUsageLogRepo)(nil)
|
|
_ service.SettingRepository = (*stubSettingRepo)(nil)
|
|
)
|