Documentation
¶
Index ¶
- Constants
- Variables
- func SendError(c *fiber.Ctx, status int, err interface{}) error
- func SendErrorWithType(c *fiber.Ctx, status int, err interface{}, errorType models.ErrorType) error
- func SendSuccess(c *fiber.Ctx, status int, data interface{}) error
- type ActiveQuery
- type MetaResponse
- type QueryTracker
- func (qt *QueryTracker) AddQuery(userID models.UserID, sourceID models.SourceID, teamID models.TeamID, ...) string
- func (qt *QueryTracker) CancelQuery(queryID string, userID models.UserID) bool
- func (qt *QueryTracker) Cleanup()
- func (qt *QueryTracker) GetUserQueries(userID models.UserID) []*ActiveQuery
- func (qt *QueryTracker) RemoveQuery(queryID string)
- type Response
- type Server
- type ServerOptions
Constants ¶
const ( // OpenAIRequestTimeout is the maximum time to wait for OpenAI to respond OpenAIRequestTimeout = 15 * time.Second )
Added constant
Variables ¶
var ( // Note: Some errors might overlap with core definitions but are kept here // for mapping purposes within redirectToFrontend. ErrSessionNotFound = errors.New("session not found") ErrSessionExpired = errors.New("session expired") ErrUserNotFound = errors.New("user not found") ErrTeamNotFound = errors.New("team not found") ErrUserInactive = errors.New("user inactive") ErrOIDCProviderNotConfigured = errors.New("OIDC provider not configured") // This one might belong in auth/oidc.go ErrOIDCInvalidToken = errors.New("invalid OIDC token") ErrOIDCEmailNotVerified = errors.New("email not verified") )
Define Auth/OIDC specific errors used within handlers, especially for redirect mapping.
Functions ¶
func SendError ¶
SendError is a helper function to easily send a JSON error response with the given HTTP status code and error message. It uses the GeneralErrorType by default.
func SendErrorWithType ¶
SendErrorWithType is a helper function to easily send a JSON error response with the given HTTP status code, error message, and a specific application error type.
Types ¶
type ActiveQuery ¶ added in v0.4.0
type ActiveQuery struct {
ID string
UserID models.UserID
SourceID models.SourceID
TeamID models.TeamID
StartTime time.Time
SQL string
Cancel context.CancelFunc
}
ActiveQuery represents an active query with its context for cancellation
type MetaResponse ¶ added in v0.2.2
type MetaResponse struct {
Version string `json:"version"`
HTTPServerTimeout string `json:"http_server_timeout"`
}
MetaResponse represents the server metadata response
type QueryTracker ¶ added in v0.4.0
type QueryTracker struct {
// contains filtered or unexported fields
}
QueryTracker manages active queries for cancellation support
func (*QueryTracker) AddQuery ¶ added in v0.4.0
func (qt *QueryTracker) AddQuery(userID models.UserID, sourceID models.SourceID, teamID models.TeamID, sql string, cancel context.CancelFunc) string
AddQuery adds a new active query to the tracker
func (*QueryTracker) CancelQuery ¶ added in v0.4.0
func (qt *QueryTracker) CancelQuery(queryID string, userID models.UserID) bool
CancelQuery cancels a query if it exists and belongs to the user
func (*QueryTracker) Cleanup ¶ added in v0.4.0
func (qt *QueryTracker) Cleanup()
Cleanup removes queries that have been running for too long (over 1 hour)
func (*QueryTracker) GetUserQueries ¶ added in v0.4.0
func (qt *QueryTracker) GetUserQueries(userID models.UserID) []*ActiveQuery
GetUserQueries returns all active queries for a user
func (*QueryTracker) RemoveQuery ¶ added in v0.4.0
func (qt *QueryTracker) RemoveQuery(queryID string)
RemoveQuery removes a query from the tracker
type Response ¶
type Response struct {
Status string `json:"status"` // "success" or "error"
Data interface{} `json:"data,omitempty"`
Message string `json:"message,omitempty"`
ErrorType string `json:"error_type,omitempty"` // Application-specific error type code.
}
Response defines the standard JSON structure for API responses.
func NewErrorResponse ¶
NewErrorResponse creates a standard error response structure. It accepts various error types and maps them to a consistent JSON format.
func NewSuccessResponse ¶
func NewSuccessResponse(data interface{}) Response
NewSuccessResponse creates a standard success response structure.
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server represents the core HTTP server, encapsulating the Fiber app instance and necessary dependencies like database connections and configuration.
func New ¶
func New(opts ServerOptions) *Server
New creates, configures, and returns a new Server instance. It initializes the Fiber application, sets up middleware, injects dependencies, and registers all application routes.
type ServerOptions ¶
type ServerOptions struct {
Config *config.Config
SQLite *sqlite.DB
ClickHouse *clickhouse.Manager
OIDCProvider *auth.OIDCProvider // OIDC provider for authentication flows.
FS http.FileSystem // Filesystem for serving static assets (frontend).
Logger *slog.Logger
BuildInfo string
Version string
}
ServerOptions holds the dependencies required to create a new Server instance. This structure reflects the refactored approach using direct dependencies instead of services.
Source Files