package admin import ( "strconv" "github.com/Wei-Shaw/sub2api/internal/handler/dto" "github.com/Wei-Shaw/sub2api/internal/pkg/response" "github.com/Wei-Shaw/sub2api/internal/service" "github.com/gin-gonic/gin" ) // AdminSetCaptureRequestsRequest 请求体:设置/清除 capture_requests type AdminSetCaptureRequestsRequest struct { Enabled bool `json:"enabled"` } // AdminAPIKeyHandler handles admin API key management type AdminAPIKeyHandler struct { adminService service.AdminService } // NewAdminAPIKeyHandler creates a new admin API key handler func NewAdminAPIKeyHandler(adminService service.AdminService) *AdminAPIKeyHandler { return &AdminAPIKeyHandler{ adminService: adminService, } } // AdminUpdateAPIKeyGroupRequest represents the request to update an API key's group type AdminUpdateAPIKeyGroupRequest struct { GroupID *int64 `json:"group_id"` // nil=不修改, 0=解绑, >0=绑定到目标分组 } // SetCaptureRequests 开启或关闭指定 API Key 的请求体捕获,并立即失效认证缓存。 // PUT /api/v1/admin/api-keys/:id/capture-requests func (h *AdminAPIKeyHandler) SetCaptureRequests(c *gin.Context) { keyID, err := strconv.ParseInt(c.Param("id"), 10, 64) if err != nil { response.BadRequest(c, "Invalid API key ID") return } var req AdminSetCaptureRequestsRequest if err := c.ShouldBindJSON(&req); err != nil { response.BadRequest(c, "Invalid request: "+err.Error()) return } apiKey, err := h.adminService.AdminSetCaptureRequests(c.Request.Context(), keyID, req.Enabled) if err != nil { response.ErrorFrom(c, err) return } response.Success(c, gin.H{ "id": apiKey.ID, "capture_requests": apiKey.CaptureRequests, }) } // UpdateGroup handles updating an API key's group binding // PUT /api/v1/admin/api-keys/:id func (h *AdminAPIKeyHandler) UpdateGroup(c *gin.Context) { keyID, err := strconv.ParseInt(c.Param("id"), 10, 64) if err != nil { response.BadRequest(c, "Invalid API key ID") return } var req AdminUpdateAPIKeyGroupRequest if err := c.ShouldBindJSON(&req); err != nil { response.BadRequest(c, "Invalid request: "+err.Error()) return } result, err := h.adminService.AdminUpdateAPIKeyGroupID(c.Request.Context(), keyID, req.GroupID) if err != nil { response.ErrorFrom(c, err) return } resp := struct { APIKey *dto.APIKey `json:"api_key"` AutoGrantedGroupAccess bool `json:"auto_granted_group_access"` GrantedGroupID *int64 `json:"granted_group_id,omitempty"` GrantedGroupName string `json:"granted_group_name,omitempty"` }{ APIKey: dto.APIKeyFromService(result.APIKey), AutoGrantedGroupAccess: result.AutoGrantedGroupAccess, GrantedGroupID: result.GrantedGroupID, GrantedGroupName: result.GrantedGroupName, } response.Success(c, resp) }