api

package
v0.0.0-...-32dd017 Latest Latest
Warning

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

 Go to latest Published: Apr 25, 2026 License: MIT Imports: 44 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AuthHandler 

type AuthHandler struct {
	// contains filtered or unexported fields
}

func NewAuthHandler 

func NewAuthHandler(l logger.Logger, conf *config.Config, tokenMgr *tokenmanager.Manager[TokenData]) *AuthHandler

func (*AuthHandler) GetCurrentUser 

func (h *AuthHandler) GetCurrentUser(ctx context.Context, _ *connect.Request[authv1.GetCurrentUserRequest]) (*connect.Response[authv1.GetCurrentUserResponse], error)

func (*AuthHandler) LoginWithTelegram 

func (h *AuthHandler) LoginWithTelegram(ctx context.Context, req *connect.Request[authv1.LoginWithTelegramRequest]) (*connect.Response[authv1.LoginWithTelegramResponse], error)

func (*AuthHandler) Logout 

func (h *AuthHandler) Logout(ctx context.Context, _ *connect.Request[authv1.LogoutRequest]) (*connect.Response[authv1.LogoutResponse], error)

type InboxHandler 

type InboxHandler struct {
	// contains filtered or unexported fields
}

func NewInboxHandler 

func NewInboxHandler(l logger.Logger, baseService *baseservices.BaseServices, st *store.Store) *InboxHandler

func (*InboxHandler) ConvertToNote 

func (h *InboxHandler) ConvertToNote(ctx context.Context, req *connect.Request[inboxv1.ConvertToNoteRequest]) (*connect.Response[inboxv1.ConvertToNoteResponse], error)

func (*InboxHandler) ConvertToTodo 

func (h *InboxHandler) ConvertToTodo(ctx context.Context, req *connect.Request[inboxv1.ConvertToTodoRequest]) (*connect.Response[inboxv1.ConvertToTodoResponse], error)

func (*InboxHandler) CreateInboxItem 

func (h *InboxHandler) CreateInboxItem(ctx context.Context, req *connect.Request[inboxv1.CreateInboxItemRequest]) (*connect.Response[inboxv1.CreateInboxItemResponse], error)

func (*InboxHandler) DeleteInboxItem 

func (h *InboxHandler) DeleteInboxItem(ctx context.Context, req *connect.Request[inboxv1.DeleteInboxItemRequest]) (*connect.Response[emptypb.Empty], error)

func (*InboxHandler) GetInboxItem 

func (h *InboxHandler) GetInboxItem(ctx context.Context, req *connect.Request[inboxv1.GetInboxItemRequest]) (*connect.Response[inboxv1.GetInboxItemResponse], error)

func (*InboxHandler) ListInboxItems 

func (h *InboxHandler) ListInboxItems(ctx context.Context, req *connect.Request[inboxv1.ListInboxItemsRequest]) (*connect.Response[inboxv1.ListInboxItemsResponse], error)

func (*InboxHandler) SubscribeInbox 

func (h *InboxHandler) SubscribeInbox(
	ctx context.Context,
	req *connect.Request[inboxv1.SubscribeInboxRequest],
	stream *connect.ServerStream[inboxv1.SubscribeInboxResponse],
) error

func (*InboxHandler) UpdateInboxItem 

func (h *InboxHandler) UpdateInboxItem(ctx context.Context, req *connect.Request[inboxv1.UpdateInboxItemRequest]) (*connect.Response[inboxv1.UpdateInboxItemResponse], error)

type NotesHandler 

type NotesHandler struct {
	// contains filtered or unexported fields
}

func NewNotesHandler 

func NewNotesHandler(l logger.Logger, baseService *baseservices.BaseServices, st *store.Store) *NotesHandler

func (*NotesHandler) CreateNote 

func (h *NotesHandler) CreateNote(ctx context.Context, req *connect.Request[notesv1.CreateNoteRequest]) (*connect.Response[notesv1.CreateNoteResponse], error)

func (*NotesHandler) DeleteNote 

func (h *NotesHandler) DeleteNote(ctx context.Context, req *connect.Request[notesv1.DeleteNoteRequest]) (*connect.Response[emptypb.Empty], error)

func (*NotesHandler) GetNote 

func (h *NotesHandler) GetNote(ctx context.Context, req *connect.Request[notesv1.GetNoteRequest]) (*connect.Response[notesv1.GetNoteResponse], error)

func (*NotesHandler) ListNotes 

func (h *NotesHandler) ListNotes(ctx context.Context, req *connect.Request[notesv1.ListNotesRequest]) (*connect.Response[notesv1.ListNotesResponse], error)

func (*NotesHandler) SubscribeNotes 

func (h *NotesHandler) SubscribeNotes(
	ctx context.Context,
	req *connect.Request[notesv1.SubscribeNotesRequest],
	stream *connect.ServerStream[notesv1.SubscribeNotesResponse],
) error

func (*NotesHandler) UpdateNote 

func (h *NotesHandler) UpdateNote(ctx context.Context, req *connect.Request[notesv1.UpdateNoteRequest]) (*connect.Response[notesv1.UpdateNoteResponse], error)

type Server 

type Server struct {
	// contains filtered or unexported fields
}

func New 

func New(
	l logger.Logger,
	conf *config.Config,
	baseService *baseservices.BaseServices,
	st *store.Store,
	taskManager *tmanager.Manager,
	tokenMgr *tokenmanager.Manager[TokenData],
) *Server

func (*Server) Name 

func (s *Server) Name() string

Name returns the service name

func (*Server) Start 

func (s *Server) Start(ctx context.Context) error

Start starts the API server

func (*Server) Stop 

func (s *Server) Stop(ctx context.Context) error

Stop stops the API server

type TagsHandler 

type TagsHandler struct {
	// contains filtered or unexported fields
}

func NewTagsHandler 

func NewTagsHandler(l logger.Logger, baseService *baseservices.BaseServices, st *store.Store) *TagsHandler

func (*TagsHandler) CreateTag 

func (h *TagsHandler) CreateTag(ctx context.Context, req *connect.Request[tagsv1.CreateTagRequest]) (*connect.Response[tagsv1.CreateTagResponse], error)

func (*TagsHandler) DeleteTag 

func (h *TagsHandler) DeleteTag(ctx context.Context, req *connect.Request[tagsv1.DeleteTagRequest]) (*connect.Response[emptypb.Empty], error)

func (*TagsHandler) ListTags 

func (h *TagsHandler) ListTags(ctx context.Context, req *connect.Request[tagsv1.ListTagsRequest]) (*connect.Response[tagsv1.ListTagsResponse], error)

func (*TagsHandler) SubscribeTags 

func (h *TagsHandler) SubscribeTags(
	ctx context.Context,
	req *connect.Request[tagsv1.SubscribeTagsRequest],
	stream *connect.ServerStream[tagsv1.SubscribeTagsResponse],
) error

func (*TagsHandler) UpdateTag 

func (h *TagsHandler) UpdateTag(ctx context.Context, req *connect.Request[tagsv1.UpdateTagRequest]) (*connect.Response[tagsv1.UpdateTagResponse], error)

type TodosHandler 

type TodosHandler struct {
	// contains filtered or unexported fields
}

func NewTodosHandler 

func NewTodosHandler(l logger.Logger, baseService *baseservices.BaseServices, st *store.Store) *TodosHandler

func (*TodosHandler) CompleteTodo 

func (h *TodosHandler) CompleteTodo(ctx context.Context, req *connect.Request[todosv1.CompleteTodoRequest]) (*connect.Response[todosv1.CompleteTodoResponse], error)

func (*TodosHandler) CountTodos 

func (h *TodosHandler) CountTodos(ctx context.Context, req *connect.Request[todosv1.CountTodosRequest]) (*connect.Response[todosv1.CountTodosResponse], error)

func (*TodosHandler) CreateTodo 

func (h *TodosHandler) CreateTodo(ctx context.Context, req *connect.Request[todosv1.CreateTodoRequest]) (*connect.Response[todosv1.CreateTodoResponse], error)

func (*TodosHandler) DeleteTodo 

func (h *TodosHandler) DeleteTodo(ctx context.Context, req *connect.Request[todosv1.DeleteTodoRequest]) (*connect.Response[emptypb.Empty], error)

func (*TodosHandler) GetCalendarEntries 

func (h *TodosHandler) GetCalendarEntries(ctx context.Context, req *connect.Request[todosv1.GetCalendarEntriesRequest]) (*connect.Response[todosv1.GetCalendarEntriesResponse], error)

func (*TodosHandler) GetTodo 

func (h *TodosHandler) GetTodo(ctx context.Context, req *connect.Request[todosv1.GetTodoRequest]) (*connect.Response[todosv1.GetTodoResponse], error)

func (*TodosHandler) ListTodos 

func (h *TodosHandler) ListTodos(ctx context.Context, req *connect.Request[todosv1.ListTodosRequest]) (*connect.Response[todosv1.ListTodosResponse], error)

func (*TodosHandler) SubscribeTodos 

func (h *TodosHandler) SubscribeTodos(
	ctx context.Context,
	req *connect.Request[todosv1.SubscribeTodosRequest],
	stream *connect.ServerStream[todosv1.SubscribeTodosResponse],
) error

func (*TodosHandler) UpdateTodo 

func (h *TodosHandler) UpdateTodo(ctx context.Context, req *connect.Request[todosv1.UpdateTodoRequest]) (*connect.Response[todosv1.UpdateTodoResponse], error)

type TokenData 

type TokenData struct {
	TelegramID int64  `json:"telegram_id"`
	FirstName  string `json:"first_name"`
	LastName   string `json:"last_name"`
	Username   string `json:"username"`
	PhotoURL   string `json:"photo_url"`
}

TokenData stores additional data in the token.

type WorkspacesHandler 

type WorkspacesHandler struct {
	// contains filtered or unexported fields
}

func NewWorkspacesHandler 

func NewWorkspacesHandler(l logger.Logger, baseService *baseservices.BaseServices, st *store.Store) *WorkspacesHandler

func (*WorkspacesHandler) ArchiveWorkspace 

func (h *WorkspacesHandler) ArchiveWorkspace(ctx context.Context, req *connect.Request[workspacesv1.ArchiveWorkspaceRequest]) (*connect.Response[workspacesv1.ArchiveWorkspaceResponse], error)

func (*WorkspacesHandler) CreateWorkspace 

func (h *WorkspacesHandler) CreateWorkspace(ctx context.Context, req *connect.Request[workspacesv1.CreateWorkspaceRequest]) (*connect.Response[workspacesv1.CreateWorkspaceResponse], error)

func (*WorkspacesHandler) DeleteWorkspace 

func (h *WorkspacesHandler) DeleteWorkspace(ctx context.Context, req *connect.Request[workspacesv1.DeleteWorkspaceRequest]) (*connect.Response[emptypb.Empty], error)

func (*WorkspacesHandler) GetWorkspace 

func (h *WorkspacesHandler) GetWorkspace(ctx context.Context, req *connect.Request[workspacesv1.GetWorkspaceRequest]) (*connect.Response[workspacesv1.GetWorkspaceResponse], error)

func (*WorkspacesHandler) GetWorkspaceStats 

func (h *WorkspacesHandler) GetWorkspaceStats(ctx context.Context, req *connect.Request[workspacesv1.GetWorkspaceStatsRequest]) (*connect.Response[workspacesv1.GetWorkspaceStatsResponse], error)

func (*WorkspacesHandler) ListWorkspaces 

func (h *WorkspacesHandler) ListWorkspaces(ctx context.Context, req *connect.Request[workspacesv1.ListWorkspacesRequest]) (*connect.Response[workspacesv1.ListWorkspacesResponse], error)

func (*WorkspacesHandler) SubscribeWorkspaces 

func (h *WorkspacesHandler) SubscribeWorkspaces(
	ctx context.Context,
	req *connect.Request[workspacesv1.SubscribeWorkspacesRequest],
	stream *connect.ServerStream[workspacesv1.SubscribeWorkspacesResponse],
) error

func (*WorkspacesHandler) UnarchiveWorkspace 

func (h *WorkspacesHandler) UnarchiveWorkspace(ctx context.Context, req *connect.Request[workspacesv1.UnarchiveWorkspaceRequest]) (*connect.Response[workspacesv1.UnarchiveWorkspaceResponse], error)

func (*WorkspacesHandler) UpdateWorkspace 

func (h *WorkspacesHandler) UpdateWorkspace(ctx context.Context, req *connect.Request[workspacesv1.UpdateWorkspaceRequest]) (*connect.Response[workspacesv1.UpdateWorkspaceResponse], 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.