handler

package
v0.0.0-...-aaedd79 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 1, 2026 License: MIT Imports: 37 Imported by: 0

Documentation

Index

Constants

View Source 
const GRPCErrorDomainGen = "gen.ai"
View Source 
const MCPSecretMaskedPlaceholder = "***"

Variables

This section is empty.

Functions

func GetUserFromContext 

func GetUserFromContext(ctx context.Context, authUseCase *usecase.AuthUseCase) (*domain.User, error)

func RequireAdmin 

func RequireAdmin(ctx context.Context, authUseCase *usecase.AuthUseCase) error

func StatusErrorWithReason 

func StatusErrorWithReason(code codes.Code, reason, userMessage string) error

func ToStatusError 

func ToStatusError(code codes.Code, err error) error

Types

type AuthHandler 

type AuthHandler struct {
	authpb.UnimplementedAuthServiceServer
	// contains filtered or unexported fields
}

func NewAuthHandler 

func NewAuthHandler(cfg *config.Config, authUseCase *usecase.AuthUseCase) *AuthHandler

func (*AuthHandler) ChangePassword 

func (a *AuthHandler) ChangePassword(ctx context.Context, req *authpb.ChangePasswordRequest) (*authpb.ChangePasswordResponse, error)

func (*AuthHandler) CheckVersion 

func (a *AuthHandler) CheckVersion(ctx context.Context, req *authpb.CheckVersionRequest) (*authpb.CheckVersionResponse, error)

func (*AuthHandler) Login 

func (a *AuthHandler) Login(ctx context.Context, req *authpb.LoginRequest) (*authpb.LoginResponse, error)

func (*AuthHandler) Logout 

func (a *AuthHandler) Logout(ctx context.Context, req *authpb.LogoutRequest) (*authpb.LogoutResponse, error)

func (*AuthHandler) RefreshToken 

func (a *AuthHandler) RefreshToken(ctx context.Context, req *authpb.RefreshTokenRequest) (*authpb.RefreshTokenResponse, error)

type ChatHandler 

type ChatHandler struct {
	chatpb.UnimplementedChatServiceServer
	// contains filtered or unexported fields
}

func NewChatHandler 

func NewChatHandler(cfg *config.Config, chatUseCase *usecase.ChatUseCase, authUseCase *usecase.AuthUseCase, documentIngest *usecase.DocumentIngestUseCase) *ChatHandler

func (*ChatHandler) CheckConnection 

func (c *ChatHandler) CheckConnection(ctx context.Context, req *commonpb.Empty) (*chatpb.ConnectionResponse, error)

func (*ChatHandler) ContinueAssistantResponse 

func (c *ChatHandler) ContinueAssistantResponse(req *chatpb.ContinueAssistantRequest, stream chatpb.ChatService_ContinueAssistantResponseServer) error

func (*ChatHandler) CreateSession 

func (c *ChatHandler) CreateSession(ctx context.Context, req *chatpb.CreateSessionRequest) (*chatpb.ChatSession, error)

func (*ChatHandler) DeleteSession 

func (c *ChatHandler) DeleteSession(ctx context.Context, req *chatpb.DeleteSessionRequest) (*commonpb.Empty, error)

func (*ChatHandler) DownloadVoskModel 

func (c *ChatHandler) DownloadVoskModel(req *chatpb.VoskModelDownloadRequest, stream chatpb.ChatService_DownloadVoskModelServer) error

func (*ChatHandler) EditUserMessageAndContinue 

func (c *ChatHandler) EditUserMessageAndContinue(req *chatpb.EditUserMessageAndContinueRequest, stream chatpb.ChatService_EditUserMessageAndContinueServer) error

func (*ChatHandler) GetAssistantMessageRegenerations 

func (c *ChatHandler) GetAssistantMessageRegenerations(ctx context.Context, req *chatpb.GetAssistantMessageRegenerationsRequest) (*chatpb.GetAssistantMessageRegenerationsResponse, error)

func (*ChatHandler) GetChatBootstrap 

func (c *ChatHandler) GetChatBootstrap(ctx context.Context, req *chatpb.GetChatBootstrapRequest) (*chatpb.GetChatBootstrapResponse, error)

func (*ChatHandler) GetIngestionStatus 

func (c *ChatHandler) GetIngestionStatus(ctx context.Context, req *chatpb.GetIngestionStatusRequest) (*chatpb.GetIngestionStatusResponse, error)

func (*ChatHandler) GetSelectedRunner 

func (c *ChatHandler) GetSelectedRunner(ctx context.Context, req *commonpb.Empty) (*chatpb.SelectedRunnerResponse, error)

func (*ChatHandler) GetSessionFile 

func (c *ChatHandler) GetSessionFile(ctx context.Context, req *chatpb.GetSessionFileRequest) (*chatpb.GetSessionFileResponse, error)

func (*ChatHandler) GetSessionMessages 

func (c *ChatHandler) GetSessionMessages(ctx context.Context, req *chatpb.GetSessionMessagesRequest) (*chatpb.GetSessionMessagesResponse, error)

func (*ChatHandler) GetSessionMessagesForAssistantMessageVersion 

func (c *ChatHandler) GetSessionMessagesForAssistantMessageVersion(ctx context.Context, req *chatpb.GetSessionMessagesForAssistantMessageVersionRequest) (*chatpb.GetSessionMessagesResponse, error)

func (*ChatHandler) GetSessionMessagesForUserMessageVersion 

func (c *ChatHandler) GetSessionMessagesForUserMessageVersion(ctx context.Context, req *chatpb.GetSessionMessagesForUserMessageVersionRequest) (*chatpb.GetSessionMessagesResponse, error)

func (*ChatHandler) GetSessionSettings 

func (c *ChatHandler) GetSessionSettings(ctx context.Context, req *chatpb.GetSessionSettingsRequest) (*chatpb.SessionSettings, error)

func (*ChatHandler) GetSessions 

func (c *ChatHandler) GetSessions(ctx context.Context, req *chatpb.GetSessionsRequest) (*chatpb.GetSessionsResponse, error)

func (*ChatHandler) GetUserMessageEdits 

func (c *ChatHandler) GetUserMessageEdits(ctx context.Context, req *chatpb.GetUserMessageEditsRequest) (*chatpb.GetUserMessageEditsResponse, error)

func (*ChatHandler) PutSessionFile 

func (c *ChatHandler) PutSessionFile(ctx context.Context, req *chatpb.PutSessionFileRequest) (*chatpb.PutSessionFileResponse, error)

func (*ChatHandler) RegenerateAssistantResponse 

func (c *ChatHandler) RegenerateAssistantResponse(req *chatpb.RegenerateAssistantRequest, stream chatpb.ChatService_RegenerateAssistantResponseServer) error

func (*ChatHandler) ResolveRunnableRunner 

func (c *ChatHandler) ResolveRunnableRunner(ctx context.Context, req *chatpb.ResolveRunnableRunnerRequest) (*chatpb.ResolveRunnableRunnerResponse, error)

func (*ChatHandler) SendMessage 

func (c *ChatHandler) SendMessage(req *chatpb.SendMessageRequest, stream chatpb.ChatService_SendMessageServer) error

func (*ChatHandler) SetSelectedRunner 

func (c *ChatHandler) SetSelectedRunner(ctx context.Context, req *chatpb.SetSelectedRunnerRequest) (*commonpb.Empty, error)

func (*ChatHandler) UpdateSessionSettings 

func (c *ChatHandler) UpdateSessionSettings(ctx context.Context, req *chatpb.UpdateSessionSettingsRequest) (*chatpb.SessionSettings, error)

func (*ChatHandler) UpdateSessionTitle 

func (c *ChatHandler) UpdateSessionTitle(ctx context.Context, req *chatpb.UpdateSessionTitleRequest) (*chatpb.ChatSession, error)

type EditorHandler 

type EditorHandler struct {
	editorpb.UnimplementedEditorServiceServer
	// contains filtered or unexported fields
}

func NewEditorHandler 

func NewEditorHandler(editorUseCase *usecase.EditorUseCase, authUseCase *usecase.AuthUseCase) *EditorHandler

func (*EditorHandler) SaveHistory 

func (e *EditorHandler) SaveHistory(ctx context.Context, req *editorpb.SaveHistoryRequest) (*commonpb.Empty, error)

func (*EditorHandler) Transform 

func (e *EditorHandler) Transform(ctx context.Context, req *editorpb.TransformRequest) (*editorpb.TransformResponse, error)

type RunnerHandler 

type RunnerHandler struct {
	runnerpb.UnimplementedRunnerServiceServer
	llmrunner.UnimplementedGRPCServer
	// contains filtered or unexported fields
}

func NewRunnerHandler 

func NewRunnerHandler(
	registry *llmrunner.Registry,
	pool *llmrunner.Pool,
	authUseCase *usecase.AuthUseCase,
	cfg *config.Config,
	runnerRepo repository.RunnerRepository,
	webSearchSettingsUC *usecase.WebSearchSettingsUseCase,
	mcpServersUC *usecase.MCPServersUseCase,
	mcpToolsListCache *mcpclient2.ToolsListCache,
) *RunnerHandler

func (*RunnerHandler) CreateMCPServer 

func (h *RunnerHandler) CreateMCPServer(ctx context.Context, req *runnerpb.CreateMCPServerRequest) (*runnerpb.MCPServer, error)

func (*RunnerHandler) CreateRunner 

func (h *RunnerHandler) CreateRunner(ctx context.Context, req *runnerpb.CreateRunnerRequest) (*commonpb.Empty, error)

func (*RunnerHandler) CreateUserMCPServer 

func (h *RunnerHandler) CreateUserMCPServer(ctx context.Context, req *runnerpb.CreateMCPServerRequest) (*runnerpb.MCPServer, error)

func (*RunnerHandler) DeleteMCPServer 

func (h *RunnerHandler) DeleteMCPServer(ctx context.Context, req *runnerpb.DeleteMCPServerRequest) (*commonpb.Empty, error)

func (*RunnerHandler) DeleteRunner 

func (h *RunnerHandler) DeleteRunner(ctx context.Context, req *runnerpb.DeleteRunnerRequest) (*commonpb.Empty, error)

func (*RunnerHandler) DeleteUserMCPServer 

func (h *RunnerHandler) DeleteUserMCPServer(ctx context.Context, req *runnerpb.DeleteMCPServerRequest) (*commonpb.Empty, error)

func (*RunnerHandler) GetRunnerModels 

func (h *RunnerHandler) GetRunnerModels(ctx context.Context, req *runnerpb.GetRunnerModelsRequest) (*runnerpb.GetRunnerModelsResponse, error)

func (*RunnerHandler) GetRunners 

func (h *RunnerHandler) GetRunners(ctx context.Context, _ *commonpb.Empty) (*runnerpb.GetRunnersResponse, error)

func (*RunnerHandler) GetRunnersStatus 

func (h *RunnerHandler) GetRunnersStatus(ctx context.Context, _ *commonpb.Empty) (*runnerpb.GetRunnersStatusResponse, error)

func (*RunnerHandler) GetUserRunners 

func (h *RunnerHandler) GetUserRunners(ctx context.Context, _ *commonpb.Empty) (*runnerpb.GetUserRunnersResponse, error)

func (*RunnerHandler) GetWebSearchAvailability 

func (h *RunnerHandler) GetWebSearchAvailability(ctx context.Context, _ *commonpb.Empty) (*runnerpb.WebSearchAvailabilityResponse, error)

func (*RunnerHandler) GetWebSearchSettings 

func (h *RunnerHandler) GetWebSearchSettings(ctx context.Context, _ *commonpb.Empty) (*runnerpb.WebSearchSettingsResponse, error)

func (*RunnerHandler) ListMCPServers 

func (h *RunnerHandler) ListMCPServers(ctx context.Context, _ *commonpb.Empty) (*runnerpb.ListMCPServersResponse, error)

func (*RunnerHandler) ListUserMCPServers 

func (h *RunnerHandler) ListUserMCPServers(ctx context.Context, _ *commonpb.Empty) (*runnerpb.ListMCPServersResponse, error)

func (*RunnerHandler) ProbeMCPServer 

func (h *RunnerHandler) ProbeMCPServer(ctx context.Context, req *runnerpb.GetMCPServerRequest) (*runnerpb.MCPProbeResult, error)

func (*RunnerHandler) ProbeUserMCPServer 

func (h *RunnerHandler) ProbeUserMCPServer(ctx context.Context, req *runnerpb.GetMCPServerRequest) (*runnerpb.MCPProbeResult, error)

func (*RunnerHandler) RunnerLoadModel 

func (h *RunnerHandler) RunnerLoadModel(ctx context.Context, req *runnerpb.RunnerLoadModelRequest) (*commonpb.Empty, error)

func (*RunnerHandler) RunnerResetMemory 

func (h *RunnerHandler) RunnerResetMemory(ctx context.Context, req *runnerpb.RunnerResetMemoryRequest) (*commonpb.Empty, error)

func (*RunnerHandler) RunnerUnloadModel 

func (h *RunnerHandler) RunnerUnloadModel(ctx context.Context, req *runnerpb.RunnerUnloadModelRequest) (*commonpb.Empty, error)

func (*RunnerHandler) UpdateMCPServer 

func (h *RunnerHandler) UpdateMCPServer(ctx context.Context, req *runnerpb.UpdateMCPServerRequest) (*runnerpb.MCPServer, error)

func (*RunnerHandler) UpdateRunner 

func (h *RunnerHandler) UpdateRunner(ctx context.Context, req *runnerpb.UpdateRunnerRequest) (*commonpb.Empty, error)

func (*RunnerHandler) UpdateUserMCPServer 

func (h *RunnerHandler) UpdateUserMCPServer(ctx context.Context, req *runnerpb.UpdateMCPServerRequest) (*runnerpb.MCPServer, error)

func (*RunnerHandler) UpdateWebSearchSettings 

func (h *RunnerHandler) UpdateWebSearchSettings(ctx context.Context, req *runnerpb.UpdateWebSearchSettingsRequest) (*runnerpb.WebSearchSettingsResponse, error)

type UserHandler 

type UserHandler struct {
	userpb.UnimplementedUserServiceServer
	// contains filtered or unexported fields
}

func NewUserHandler 

func NewUserHandler(userUseCase *usecase.UserUseCase, authUseCase *usecase.AuthUseCase) *UserHandler

func (*UserHandler) CreateUser 

func (u *UserHandler) CreateUser(ctx context.Context, req *userpb.CreateUserRequest) (*userpb.CreateUserResponse, error)

func (*UserHandler) EditUser 

func (u *UserHandler) EditUser(ctx context.Context, req *userpb.EditUserRequest) (*userpb.EditUserResponse, error)

func (*UserHandler) GetUsers 

func (u *UserHandler) GetUsers(ctx context.Context, req *userpb.GetUsersRequest) (*userpb.GetUsersResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.