3847eb2036
This repo had no version control prior to this commit. The import is a
straight snapshot of the working tree at 2026-05-03; the deployed
binary on fihelvop01 was being rebuilt from this source via `make
build` + scp into place, with no upstream review path.
The snapshot already includes one in-flight fix made on 2026-05-03 to
internal/service/persona.go:GetSelfModel — the handler queried
`source` and `strength` columns plus an `is_active = true` filter on
persona.persona_commitments, none of which exist on that table (its
shape is session-bound commitments with `status`, `commitment_meta`,
etc.). The query returned a 500 every time SynapseHub bootstrapped a
persona's self-model, dropping the IdentityConstraints / Commitments /
ConscienceStandards layer from the assembled prompt. The patched
query reads existing columns only (commitment_text, commitment_type),
filters on `status='active'`, and synthesises Source="learned" /
Strength=1.0 to keep the SelfModel response shape stable for callers.
Verified live: `GET /api/v1/personas/70f7cfd9-.../self-model` now
returns 200 with `{identityConstraints:[],commitments:[],
conscienceStandards:[]}` instead of 500.
Future changes go through PRs against this repo — no more bin-only
deploys.
Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
101 lines
2.8 KiB
Go
101 lines
2.8 KiB
Go
package handler
|
|
|
|
import (
|
|
"github.com/gofiber/fiber/v2"
|
|
|
|
"github.com/gosec/gsc-ops-api/internal/middleware"
|
|
"github.com/gosec/gsc-ops-api/internal/service"
|
|
"github.com/gosec/gsc-ops-api/pkg/types"
|
|
)
|
|
|
|
// PGPHandler handles PGP key endpoints
|
|
type PGPHandler struct {
|
|
svc *service.PGPService
|
|
}
|
|
|
|
// NewPGPHandler creates a new PGP handler
|
|
func NewPGPHandler(svc *service.PGPService) *PGPHandler {
|
|
return &PGPHandler{svc: svc}
|
|
}
|
|
|
|
// Search handles GET /api/v1/pgp/keys
|
|
func (h *PGPHandler) Search(c *fiber.Ctx) error {
|
|
reqID := middleware.GetRequestID(c)
|
|
query := c.Query("search")
|
|
if query == "" {
|
|
query = c.Query("q")
|
|
}
|
|
|
|
if query == "" {
|
|
apiErr := types.NewValidation("search or q query parameter is required")
|
|
return c.Status(apiErr.Status).JSON(types.NewErrorResponse(apiErr, reqID))
|
|
}
|
|
|
|
keys, err := h.svc.SearchKeys(query)
|
|
if err != nil {
|
|
apiErr := types.NewInternal(err.Error())
|
|
return c.Status(apiErr.Status).JSON(types.NewErrorResponse(apiErr, reqID))
|
|
}
|
|
|
|
return c.JSON(types.NewDataResponse(keys, reqID))
|
|
}
|
|
|
|
// Get handles GET /api/v1/pgp/keys/:keyId
|
|
func (h *PGPHandler) Get(c *fiber.Ctx) error {
|
|
reqID := middleware.GetRequestID(c)
|
|
keyID := c.Params("keyId")
|
|
|
|
key, err := h.svc.GetKey(keyID)
|
|
if err != nil {
|
|
apiErr := types.NewInternal(err.Error())
|
|
return c.Status(apiErr.Status).JSON(types.NewErrorResponse(apiErr, reqID))
|
|
}
|
|
if key == nil {
|
|
apiErr := types.NewNotFound("PGP key not found: " + keyID)
|
|
return c.Status(apiErr.Status).JSON(types.NewErrorResponse(apiErr, reqID))
|
|
}
|
|
|
|
return c.JSON(types.NewDataResponse(key, reqID))
|
|
}
|
|
|
|
// Upload handles POST /api/v1/pgp/keys
|
|
func (h *PGPHandler) Upload(c *fiber.Ctx) error {
|
|
reqID := middleware.GetRequestID(c)
|
|
|
|
var req types.PGPKeyUpload
|
|
if err := c.BodyParser(&req); err != nil {
|
|
apiErr := types.NewBadRequest("Invalid request body: " + err.Error())
|
|
return c.Status(apiErr.Status).JSON(types.NewErrorResponse(apiErr, reqID))
|
|
}
|
|
|
|
if req.KeyText == "" {
|
|
apiErr := types.NewValidation("keyText is required")
|
|
return c.Status(apiErr.Status).JSON(types.NewErrorResponse(apiErr, reqID))
|
|
}
|
|
|
|
if err := h.svc.UploadKey(req.KeyText); err != nil {
|
|
apiErr := types.NewInternal(err.Error())
|
|
return c.Status(apiErr.Status).JSON(types.NewErrorResponse(apiErr, reqID))
|
|
}
|
|
|
|
return c.Status(fiber.StatusCreated).JSON(types.NewDataResponse(fiber.Map{
|
|
"uploaded": true,
|
|
}, reqID))
|
|
}
|
|
|
|
// Delete handles DELETE /api/v1/pgp/keys/:keyId
|
|
func (h *PGPHandler) Delete(c *fiber.Ctx) error {
|
|
reqID := middleware.GetRequestID(c)
|
|
keyID := c.Params("keyId")
|
|
|
|
if err := h.svc.DeleteKey(keyID); err != nil {
|
|
apiErr := types.NewInternal(err.Error())
|
|
return c.Status(apiErr.Status).JSON(types.NewErrorResponse(apiErr, reqID))
|
|
}
|
|
|
|
return c.JSON(types.NewDataResponse(fiber.Map{
|
|
"keyId": keyID,
|
|
"deleted": true,
|
|
}, reqID))
|
|
}
|