handlers

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Feb 8, 2026 License: AGPL-3.0 Imports: 80 Imported by: 0

Documentation

Overview

Package handlers implements API handlers and supporting helpers for the API Lambda function.

Index

Constants

View Source 
const (
	ExportStatusCompleted = statusCompleted // Using common constant
	ExportStatusFailed    = "failed"
	ExportTypeArchive     = "archive"
	ExportTypeFollowers   = "followers"
	ExportTypeFollowing   = "following"
)

Export status constants

View Source 
const (
	ImportStatusFailed    = "failed"
	ImportStatusCancelled = "cancelled"
)

Import status constants

View Source 
const (
	// EnvProduction represents production environment name
	EnvProduction = "production"
	// EnvProd represents short production environment name
	EnvProd = "prod"
)
View Source 
const (
	MediaTypeImage   = "image"
	MediaTypeVideo   = "video"
	MediaTypeAudio   = "audio"
	MediaTypeGifv    = "gifv"
	MediaTypeUnknown = "unknown"
)

Media type constants

View Source 
const (
	MimeTypeImageGif  = "image/gif"
	MimeTypeImageJpeg = "image/jpeg"
	MimeTypeImagePng  = "image/png"
	MimeTypeImageWebp = "image/webp"
)

MIME type constants

View Source 
const (
	VisibilityPublic   = "public"
	VisibilityUnlisted = "unlisted"
	VisibilityPrivate  = "private"
	VisibilityDirect   = "direct"
)

Visibility constants

View Source 
const (
	StatusCreated = streaming.StatusCreated
	StatusDeleted = streaming.StatusDeleted
	UserStream    = streaming.UserStream
	PublicStream  = streaming.PublicStream
)

Import streaming constants

View Source 
const DefaultPaginationLimit = 20

DefaultPaginationLimit is the default limit for paginated responses

View Source 
const (
	// ErrInsufficientScope is returned when the OAuth token has insufficient scope
	ErrInsufficientScope = "insufficient scope"
)
View Source 
const MaxPaginationLimit = 80

MaxPaginationLimit is the maximum allowed limit for paginated responses

Variables

This section is empty.

Functions

func HealthCheckMiddleware 

func HealthCheckMiddleware(_ *zap.Logger) apptheory.Middleware

HealthCheckMiddleware adds health check information to request context

func IsProductionEnvironment 

func IsProductionEnvironment(cfg *config.Config) bool

IsProductionEnvironment checks if the current environment is production

func RegisterHealthRoutes 

func RegisterHealthRoutes(app *apptheory.App, storage core.RepositoryStorage, logger *zap.Logger)

RegisterHealthRoutes registers health check routes

func ValidateVAPIDKeysForProduction 

func ValidateVAPIDKeysForProduction(ctx context.Context, cfg *config.Config, repos core.RepositoryStorage, logger *zap.Logger) error

ValidateVAPIDKeysForProduction validates that VAPID keys are available in production

Types

type AIService 

type AIService interface {
	GetAnalysis(ctx context.Context, query *ai.GetAnalysisQuery) (*ai.GetAnalysisResult, error)
	GetStats(ctx context.Context, query *ai.GetStatsQuery) (*ai.GetStatsResult, error)
	QueueForAnalysis(ctx context.Context, cmd *ai.QueueAnalysisCommand) (*ai.QueueAnalysisResult, error)
}

AIService defines the subset of AI-related operations used by the Lift API

type AccountsService 

type AccountsService interface {
	CreateAuthorizationCode(ctx context.Context, cmd *accounts.CreateAuthorizationCodeCommand) (*accounts.CreateAuthorizationCodeResult, error)
	GetAccount(ctx context.Context, username string) (*storage.Account, error)
	GetAccountPins(ctx context.Context, query *accounts.GetAccountPinsQuery) (*accounts.AccountPinsResult, error)
	GetFamiliarFollowers(ctx context.Context, query *accounts.GetFamiliarFollowersQuery) (*accounts.FamiliarFollowersResult, error)
	GetInstanceStats(ctx context.Context, query *accounts.GetInstanceStatsQuery) (*accounts.GetInstanceStatsResult, error)
	GetMarkers(ctx context.Context, query *accounts.GetMarkersQuery) (*accounts.GetMarkersResult, error)
	GetOAuthApp(ctx context.Context, query *accounts.GetOAuthAppQuery) (*accounts.GetOAuthAppResult, error)
	GetPreferences(ctx context.Context, query *accounts.GetPreferencesQuery) (*accounts.PreferencesResult, error)
	GetUserAppConsent(ctx context.Context, query *accounts.GetUserAppConsentQuery) (*accounts.GetUserAppConsentResult, error)
	IsAccountPinned(ctx context.Context, userID, pinnedActorID string) (bool, error)
	LookupAccount(ctx context.Context, query *accounts.LookupAccountQuery) (*storage.Account, error)
	PinAccount(ctx context.Context, cmd *accounts.PinAccountCommand) (*accounts.RelationshipResult, error)
	RegisterAccount(ctx context.Context, cmd *accounts.RegisterAccountCommand) (*accounts.RegisterAccountResult, error)
	RemoveFollower(ctx context.Context, cmd *accounts.RemoveFollowerCommand) (*accounts.RelationshipResult, error)
	SaveMarker(ctx context.Context, cmd *accounts.SaveMarkerCommand) (*accounts.SaveMarkerResult, error)
	SetAccountNote(ctx context.Context, cmd *accounts.SetAccountNoteCommand) (*accounts.RelationshipResult, error)
	StoreOAuthState(ctx context.Context, cmd *accounts.StoreOAuthStateCommand) (*accounts.StoreOAuthStateResult, error)
	UnpinAccount(ctx context.Context, cmd *accounts.UnpinAccountCommand) (*accounts.RelationshipResult, error)
	UpdatePreferences(ctx context.Context, cmd *accounts.UpdatePreferencesCommand) (*accounts.PreferencesResult, error)
	UpdateProfile(ctx context.Context, cmd *accounts.UpdateProfileCommand) (*accounts.AccountResult, error)
}

AccountsService defines the subset of account-related operations used by the Lift API

type AdminStatusPagination 

type AdminStatusPagination struct {
	Limit  int
	Cursor string
}

AdminStatusPagination holds pagination parameters for admin status queries

type CheckResult 

type CheckResult struct {
	Status   HealthStatus  `json:"status"`
	Message  string        `json:"message,omitempty"`
	Duration time.Duration `json:"duration,omitempty"`
	Error    string        `json:"error,omitempty"`
	Details  interface{}   `json:"details,omitempty"`
}

CheckResult represents individual health check result

type ConversationsService 

type ConversationsService interface {
	DeleteConversation(ctx context.Context, cmd *conversations.DeleteConversationCommand) (*conversations.ConversationResult, error)
	ListConversations(ctx context.Context, query *conversations.ListConversationsQuery) (*conversations.Result, error)
	MarkConversationRead(ctx context.Context, cmd *conversations.MarkConversationReadCommand) (*conversations.ConversationResult, error)
}

ConversationsService defines the subset of conversation-related operations used by the Lift API

type CreateStatusRequest 

type CreateStatusRequest struct {
	Status        string   `json:"status"`
	Visibility    string   `json:"visibility"`
	InReplyToID   string   `json:"in_reply_to_id,omitempty"`
	Sensitive     bool     `json:"sensitive,omitempty"`
	SpoilerText   string   `json:"spoiler_text,omitempty"`
	Mentions      []string `json:"mentions,omitempty"`
	ToRecipients  []string `json:"to_recipients,omitempty"`  // Enhanced addressing
	CcRecipients  []string `json:"cc_recipients,omitempty"`  // Enhanced addressing
	BtoRecipients []string `json:"bto_recipients,omitempty"` // Enhanced addressing (hidden from others)
	BCCRecipients []string `json:"bcc_recipients,omitempty"` // Enhanced addressing (hidden from all)
}

CreateStatusRequest represents the enhanced request for creating a status with addressing fields

type DebugFederationDomainResponse 

type DebugFederationDomainResponse struct {
	Domain        string         `json:"domain"`
	LastContact   time.Time      `json:"last_contact,omitempty"`
	Status        string         `json:"status"`
	SharedInbox   string         `json:"shared_inbox,omitempty"`
	RecentErrors  []string       `json:"recent_errors,omitempty"`
	KnownActors   []string       `json:"known_actors"`
	ActivityCount int            `json:"activity_count"`
	InstanceInfo  map[string]any `json:"instance_info,omitempty"`
}

DebugFederationDomainResponse contains debug info for a specific domain

type DebugFederationResponse 

type DebugFederationResponse struct {
	ActivityID        string                 `json:"activity_id"`
	Type              string                 `json:"type"`
	Actor             string                 `json:"actor"`
	Created           time.Time              `json:"created"`
	Traces            []DebugFederationTrace `json:"traces"`
	ProcessingTime    string                 `json:"processing_time"`
	StorageLocations  map[string]string      `json:"storage_locations"`
	RelatedActivities []string               `json:"related_activities,omitempty"`
}

DebugFederationResponse contains the complete trace of an activity

type DebugFederationTrace 

type DebugFederationTrace struct {
	Timestamp   time.Time         `json:"timestamp"`
	Step        string            `json:"step"`
	Direction   string            `json:"direction"` // inbound/outbound
	Actor       string            `json:"actor,omitempty"`
	RemoteURL   string            `json:"remote_url,omitempty"`
	StatusCode  int               `json:"status_code,omitempty"`
	Headers     map[string]string `json:"headers,omitempty"`
	Body        json.RawMessage   `json:"body,omitempty"`
	Error       string            `json:"error,omitempty"`
	Duration    string            `json:"duration,omitempty"`
	StorageInfo map[string]any    `json:"storage_info,omitempty"`
}

DebugFederationTrace represents a single step in federation processing

type DebugObjectExplanation 

type DebugObjectExplanation struct {
	Object        any            `json:"object"`
	Storage       map[string]any `json:"storage"`
	Indexes       []string       `json:"indexes"`
	References    map[string]any `json:"references"`
	CostBreakdown map[string]any `json:"cost_breakdown"`
}

DebugObjectExplanation contains detailed object info including storage and cost

type DebugObjectResponse 

type DebugObjectResponse struct {
	ID            string         `json:"id"`
	Type          string         `json:"type"`
	Object        any            `json:"object"`
	Created       time.Time      `json:"created"`
	Actor         map[string]any `json:"actor,omitempty"`
	Relationships map[string]any `json:"relationships,omitempty"`
}

DebugObjectResponse contains detailed information about a stored object

type EmailFreeRecoveryHandler 

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

EmailFreeRecoveryHandler handles email-free account recovery

func NewEmailFreeRecoveryHandler 

func NewEmailFreeRecoveryHandler(authService *auth.AuthService) *EmailFreeRecoveryHandler

NewEmailFreeRecoveryHandler creates a new email-free recovery handler

func (*EmailFreeRecoveryHandler) HandleAddTrusteeLift 

func (h *EmailFreeRecoveryHandler) HandleAddTrusteeLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAddTrusteeLift adds a trusted contact for social recovery POST /auth/recovery/trustees/add

func (*EmailFreeRecoveryHandler) HandleConfirmSocialRecoveryLift 

func (h *EmailFreeRecoveryHandler) HandleConfirmSocialRecoveryLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleConfirmSocialRecoveryLift processes a trustee's confirmation POST /auth/recovery/social/confirm

func (*EmailFreeRecoveryHandler) HandleDeviceRecoveryLift 

func (h *EmailFreeRecoveryHandler) HandleDeviceRecoveryLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeviceRecoveryLift allows recovery via a trusted device POST /auth/recovery/device

func (*EmailFreeRecoveryHandler) HandleGenerateRecoveryCodesLift 

func (h *EmailFreeRecoveryHandler) HandleGenerateRecoveryCodesLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGenerateRecoveryCodesLift generates new recovery codes POST /auth/recovery/codes/generate

func (*EmailFreeRecoveryHandler) HandleGetRecoveryOptionsLift 

func (h *EmailFreeRecoveryHandler) HandleGetRecoveryOptionsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetRecoveryOptionsLift returns available recovery methods for an account GET /auth/recovery/options

func (*EmailFreeRecoveryHandler) HandleInitiateSocialRecoveryLift 

func (h *EmailFreeRecoveryHandler) HandleInitiateSocialRecoveryLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleInitiateSocialRecoveryLift starts the social recovery process POST /auth/recovery/social/initiate

func (*EmailFreeRecoveryHandler) HandleListTrusteesLift 

func (h *EmailFreeRecoveryHandler) HandleListTrusteesLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleListTrusteesLift lists all trustees for the authenticated user GET /auth/recovery/trustees

func (*EmailFreeRecoveryHandler) HandleRemoveTrusteeLift 

func (h *EmailFreeRecoveryHandler) HandleRemoveTrusteeLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleRemoveTrusteeLift removes a trustee DELETE /auth/recovery/trustees/{trustee_id}

func (*EmailFreeRecoveryHandler) HandleUseRecoveryCodeLift 

func (h *EmailFreeRecoveryHandler) HandleUseRecoveryCodeLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUseRecoveryCodeLift uses a recovery code to recover account POST /auth/recovery/codes/use

type EmojiService 

type EmojiService interface {
	CreateEmoji(ctx context.Context, cmd *emoji.CreateEmojiCommand) (*emoji.Result, error)
	DeleteEmoji(ctx context.Context, cmd *emoji.DeleteEmojiCommand) error
	ListEmojis(ctx context.Context, query *emoji.ListEmojisQuery) (*emoji.ListResult, error)
	UpdateEmoji(ctx context.Context, cmd *emoji.UpdateEmojiCommand) (*emoji.Result, error)
}

EmojiService defines the subset of emoji-related operations used by the Lift API

type FeaturedTag 

type FeaturedTag struct {
	ID            string    `json:"id"`
	Name          string    `json:"name"`
	URL           string    `json:"url"`
	StatusesCount int       `json:"statuses_count"`
	LastStatusAt  string    `json:"last_status_at"`
	CreatedAt     time.Time `json:"-"`
}

FeaturedTag represents a featured hashtag

type Handler 

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

Handler contains dependencies for API handlers.

func NewHandler 

func NewHandler(cfg *config.Config, repos core.RepositoryStorage, logger *zap.Logger, streamQueue streaming.StreamQueueService) *Handler

NewHandler creates a new handler with dependencies

func (*Handler) CreateUserWebSocketBudget 

func (h *Handler) CreateUserWebSocketBudget(ctx *apptheory.Context) (interface{}, error)

CreateUserWebSocketBudget creates or updates a budget for a user

func (*Handler) GetUserWebSocketBudget 

func (h *Handler) GetUserWebSocketBudget(ctx *apptheory.Context) (interface{}, error)

GetUserWebSocketBudget retrieves budget information for a user

func (*Handler) GetWebSocketCostAnalytics 

func (h *Handler) GetWebSocketCostAnalytics(ctx *apptheory.Context, req WebSocketCostAnalyticsRequest) (WebSocketCostSummaryResponse, error)

GetWebSocketCostAnalytics retrieves comprehensive WebSocket cost analytics

func (*Handler) HandleAccountLookupLift 

func (h *Handler) HandleAccountLookupLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAccountLookupLift looks up an account by username@domain

func (*Handler) HandleAccountSearchLift 

func (h *Handler) HandleAccountSearchLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAccountSearchLift handles GET /api/v1/accounts/search Search for accounts by username, display name, or domain

func (*Handler) HandleActivityPubFollowersLift 

func (h *Handler) HandleActivityPubFollowersLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleActivityPubFollowersLift handles ActivityPub followers collection endpoint

func (*Handler) HandleActivityPubFollowingLift 

func (h *Handler) HandleActivityPubFollowingLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleActivityPubFollowingLift handles ActivityPub following collection endpoint

func (*Handler) HandleAddAccountsToListLift 

func (h *Handler) HandleAddAccountsToListLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAddAccountsToListLift handles POST /api/v1/lists/:id/accounts

func (*Handler) HandleAddAnnouncementReactionLift 

func (h *Handler) HandleAddAnnouncementReactionLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAddAnnouncementReactionLift handles PUT /api/v1/announcements/:id/reactions/:name

func (*Handler) HandleAddFilterKeywordLift 

func (h *Handler) HandleAddFilterKeywordLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAddFilterKeywordLift handles POST /api/v2/filters/:filter_id/keywords

func (*Handler) HandleAddFilterStatusLift 

func (h *Handler) HandleAddFilterStatusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAddFilterStatusLift handles POST /api/v2/filters/:filter_id/statuses

func (*Handler) HandleAdminAccountActionLift 

func (h *Handler) HandleAdminAccountActionLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminAccountActionLift handles POST /api/v1/admin/accounts/:id/action

func (*Handler) HandleAdminApproveAccountLift 

func (h *Handler) HandleAdminApproveAccountLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminApproveAccountLift handles POST /api/v1/admin/accounts/:id/approve

func (*Handler) HandleAdminAssignReportLift 

func (h *Handler) HandleAdminAssignReportLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminAssignReportLift handles POST /api/v1/admin/reports/:id/assign_to_self

func (*Handler) HandleAdminCreateUserLift 

func (h *Handler) HandleAdminCreateUserLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminCreateUserLift handles the creation of a new user by an admin.

func (*Handler) HandleAdminDeleteStatusLift 

func (h *Handler) HandleAdminDeleteStatusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminDeleteStatusLift handles DELETE /api/v1/admin/statuses/:id

func (*Handler) HandleAdminDemoteModeratorLift 

func (h *Handler) HandleAdminDemoteModeratorLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminDemoteModeratorLift handles POST /api/v1/admin/moderation/reviewers/:id/demote

func (*Handler) HandleAdminEnableAccountLift 

func (h *Handler) HandleAdminEnableAccountLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminEnableAccountLift handles POST /api/v1/admin/accounts/:id/enable

func (*Handler) HandleAdminGetAccountLift 

func (h *Handler) HandleAdminGetAccountLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminGetAccountLift handles GET /api/v1/admin/accounts/:id

func (*Handler) HandleAdminGetAccountsLift 

func (h *Handler) HandleAdminGetAccountsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminGetAccountsLift handles GET /api/v1/admin/accounts

func (*Handler) HandleAdminGetAgentPolicyLift 

func (h *Handler) HandleAdminGetAgentPolicyLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminGetAgentPolicyLift handles GET /api/v1/admin/agents/policy.

func (*Handler) HandleAdminGetModerationEventsLift 

func (h *Handler) HandleAdminGetModerationEventsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminGetModerationEventsLift handles GET /api/v1/admin/moderation/events

func (*Handler) HandleAdminGetReportLift 

func (h *Handler) HandleAdminGetReportLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminGetReportLift handles GET /api/v1/admin/reports/:id

func (*Handler) HandleAdminGetReportsLift 

func (h *Handler) HandleAdminGetReportsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminGetReportsLift handles GET /api/v1/admin/reports

func (*Handler) HandleAdminGetReviewersLift 

func (h *Handler) HandleAdminGetReviewersLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminGetReviewersLift handles GET /api/v1/admin/moderation/reviewers

func (*Handler) HandleAdminGetStatusLift 

func (h *Handler) HandleAdminGetStatusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminGetStatusLift handles GET /api/v1/admin/statuses/:id

func (*Handler) HandleAdminGetStatusesLift 

func (h *Handler) HandleAdminGetStatusesLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminGetStatusesLift handles GET /api/v1/admin/statuses

func (*Handler) HandleAdminGetTrustGraphLift 

func (h *Handler) HandleAdminGetTrustGraphLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminGetTrustGraphLift handles GET /api/v1/admin/moderation/trust/graph

func (*Handler) HandleAdminMarkStatusSensitiveLift 

func (h *Handler) HandleAdminMarkStatusSensitiveLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminMarkStatusSensitiveLift handles POST /api/v1/admin/statuses/:id/sensitive

func (*Handler) HandleAdminModerationOverviewLift 

func (h *Handler) HandleAdminModerationOverviewLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminModerationOverviewLift handles GET /api/v1/admin/moderation/overview

func (*Handler) HandleAdminOverrideModerationEventLift 

func (h *Handler) HandleAdminOverrideModerationEventLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminOverrideModerationEventLift handles POST /api/v1/admin/moderation/events/:id/override

func (*Handler) HandleAdminPromoteModeratorLift 

func (h *Handler) HandleAdminPromoteModeratorLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminPromoteModeratorLift handles POST /api/v1/admin/moderation/reviewers/:id/promote

func (*Handler) HandleAdminRejectAccountLift 

func (h *Handler) HandleAdminRejectAccountLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminRejectAccountLift handles POST /api/v1/admin/accounts/:id/reject

func (*Handler) HandleAdminReopenReportLift 

func (h *Handler) HandleAdminReopenReportLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminReopenReportLift handles POST /api/v1/admin/reports/:id/reopen

func (*Handler) HandleAdminResolveReportLift 

func (h *Handler) HandleAdminResolveReportLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminResolveReportLift handles POST /api/v1/admin/reports/:id/resolve

func (*Handler) HandleAdminUnassignReportLift 

func (h *Handler) HandleAdminUnassignReportLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminUnassignReportLift handles POST /api/v1/admin/reports/:id/unassign

func (*Handler) HandleAdminUnmarkStatusSensitiveLift 

func (h *Handler) HandleAdminUnmarkStatusSensitiveLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminUnmarkStatusSensitiveLift handles POST /api/v1/admin/statuses/:id/unsensitive

func (*Handler) HandleAdminUnsensitiveAccountLift 

func (h *Handler) HandleAdminUnsensitiveAccountLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminUnsensitiveAccountLift handles POST /api/v1/admin/accounts/:id/unsensitive

func (*Handler) HandleAdminUnsilenceAccountLift 

func (h *Handler) HandleAdminUnsilenceAccountLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminUnsilenceAccountLift handles POST /api/v1/admin/accounts/:id/unsilence

func (*Handler) HandleAdminUnsuspendAccountLift 

func (h *Handler) HandleAdminUnsuspendAccountLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminUnsuspendAccountLift handles POST /api/v1/admin/accounts/:id/unsuspend

func (*Handler) HandleAdminUnverifyAgentLift 

func (h *Handler) HandleAdminUnverifyAgentLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminUnverifyAgentLift handles POST /api/v1/admin/agents/:username/unverify.

func (*Handler) HandleAdminUpdateAgentPolicyLift 

func (h *Handler) HandleAdminUpdateAgentPolicyLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminUpdateAgentPolicyLift handles PUT /api/v1/admin/agents/policy.

func (*Handler) HandleAdminUpdateTrustLift 

func (h *Handler) HandleAdminUpdateTrustLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminUpdateTrustLift handles PUT /api/v1/admin/moderation/trust/:from/:to

func (*Handler) HandleAdminVerifyAgentLift 

func (h *Handler) HandleAdminVerifyAgentLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAdminVerifyAgentLift handles POST /api/v1/admin/agents/:username/verify.

func (*Handler) HandleAgentAuthChallengeLift 

func (h *Handler) HandleAgentAuthChallengeLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAgentAuthChallengeLift issues a one-time challenge for self-sovereign token minting.

func (*Handler) HandleAgentAuthTokenLift 

func (h *Handler) HandleAgentAuthTokenLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAgentAuthTokenLift mints an OAuth token by verifying a signed challenge.

func (*Handler) HandleAgentMemorySearchLift 

func (h *Handler) HandleAgentMemorySearchLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAgentMemorySearchLift handles GET/POST /api/v1/agents/memory/search.

M4: timeline-as-memory retrieval for agent-scoped queries.

func (*Handler) HandleAgentRegisterChallengeLift 

func (h *Handler) HandleAgentRegisterChallengeLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAgentRegisterChallengeLift issues a one-time challenge for self-sovereign agent registration.

func (*Handler) HandleAgentRegisterLift 

func (h *Handler) HandleAgentRegisterLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAgentRegisterLift registers a self-sovereign agent by verifying a signed registration challenge and minting OAuth tokens for the new agent.

func (*Handler) HandleAgentRotateKeyChallengeLift 

func (h *Handler) HandleAgentRotateKeyChallengeLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAgentRotateKeyChallengeLift issues a one-time challenge for rotating a self-sovereign agent key.

func (*Handler) HandleAgentRotateKeyLift 

func (h *Handler) HandleAgentRotateKeyLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAgentRotateKeyLift rotates a self-sovereign agent key after verifying a signed challenge.

func (*Handler) HandleAppRegistrationLift 

func (h *Handler) HandleAppRegistrationLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAppRegistrationLift handles OAuth app registration requests

func (*Handler) HandleAppVerifyCredentialsLift 

func (h *Handler) HandleAppVerifyCredentialsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAppVerifyCredentialsLift verifies OAuth app credentials

func (*Handler) HandleAuthorizeFollowRequestLift 

func (h *Handler) HandleAuthorizeFollowRequestLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleAuthorizeFollowRequestLift handles POST /api/v1/follow_requests/:account_id/authorize Accepts a pending follow request

func (*Handler) HandleBeginWebAuthnLoginLift 

func (h *Handler) HandleBeginWebAuthnLoginLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleBeginWebAuthnLoginLift starts the WebAuthn login process POST /api/v1/auth/webauthn/login/begin

func (*Handler) HandleBeginWebAuthnRegistrationLift 

func (h *Handler) HandleBeginWebAuthnRegistrationLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleBeginWebAuthnRegistrationLift starts the WebAuthn registration process POST /api/v1/auth/webauthn/register/begin

func (*Handler) HandleBlockAccountFull 

func (h *Handler) HandleBlockAccountFull(ctx *apptheory.Context) (*apptheory.Response, error)

HandleBlockAccountFull blocks an account using Relationships service

func (*Handler) HandleBlockLift 

func (h *Handler) HandleBlockLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleBlockLift handles POST /api/v1/accounts/:id/block

func (*Handler) HandleBookmarkLift 

func (h *Handler) HandleBookmarkLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleBookmarkLift handles POST /api/v1/statuses/:id/bookmark

func (*Handler) HandleCancelImportLift 

func (h *Handler) HandleCancelImportLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCancelImportLift handles DELETE /api/v1/imports/:id

func (*Handler) HandleClearNotificationsLift 

func (h *Handler) HandleClearNotificationsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleClearNotificationsLift handles POST /api/v1/notifications/clear

func (*Handler) HandleCreateAdminDomainAllowLift 

func (h *Handler) HandleCreateAdminDomainAllowLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreateAdminDomainAllowLift handles POST /api/v1/admin/domain_allows

func (*Handler) HandleCreateAdminDomainBlockLift 

func (h *Handler) HandleCreateAdminDomainBlockLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreateAdminDomainBlockLift handles POST /api/v1/admin/domain_blocks

func (*Handler) HandleCreateAnnouncementLift 

func (h *Handler) HandleCreateAnnouncementLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreateAnnouncementLift handles POST /api/v1/admin/announcements

func (*Handler) HandleCreateChallengeLift 

func (h *Handler) HandleCreateChallengeLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreateChallengeLift handles POST /auth/wallet/challenge

func (*Handler) HandleCreateCustomEmojiLift 

func (h *Handler) HandleCreateCustomEmojiLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreateCustomEmojiLift handles POST /api/v1/admin/custom_emojis (admin only)

func (*Handler) HandleCreateDomainBlockLift 

func (h *Handler) HandleCreateDomainBlockLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreateDomainBlockLift handles POST /api/v1/domain_blocks

func (*Handler) HandleCreateEmailDomainBlockLift 

func (h *Handler) HandleCreateEmailDomainBlockLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreateEmailDomainBlockLift handles POST /api/v1/admin/email_domain_blocks

func (*Handler) HandleCreateExportLift 

func (h *Handler) HandleCreateExportLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreateExportLift handles POST /api/v1/exports

func (*Handler) HandleCreateFeaturedTagLift 

func (h *Handler) HandleCreateFeaturedTagLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreateFeaturedTagLift features a hashtag on the user's profile

func (*Handler) HandleCreateFilterLift 

func (h *Handler) HandleCreateFilterLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreateFilterLift handles POST /api/v2/filters

func (*Handler) HandleCreateImportLift 

func (h *Handler) HandleCreateImportLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreateImportLift handles POST /api/v1/imports

func (*Handler) HandleCreateListLift 

func (h *Handler) HandleCreateListLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreateListLift handles POST /api/v1/lists

func (*Handler) HandleCreateNoteLift 

func (h *Handler) HandleCreateNoteLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreateNoteLift handles POST /api/v1/notes

func (*Handler) HandleCreatePushSubscriptionLift 

func (h *Handler) HandleCreatePushSubscriptionLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreatePushSubscriptionLift handles POST /api/v1/push/subscription

func (*Handler) HandleCreateQuotePostLift 

func (h *Handler) HandleCreateQuotePostLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreateQuotePostLift handles POST /api/v1/statuses/:id/quote Creates a quote post of an existing status

func (*Handler) HandleCreateReportLift 

func (h *Handler) HandleCreateReportLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreateReportLift handles POST /api/v1/reports

func (*Handler) HandleCreateScheduledStatusLift 

func (h *Handler) HandleCreateScheduledStatusLift(ctx *apptheory.Context, statusReq *apimodels.CreateStatusRequest) (*apimodels.ScheduledStatus, *apptheory.Response, error)

HandleCreateScheduledStatusLift handles POST /api/v1/statuses (with scheduled_at)

func (*Handler) HandleCreateStatusFull 

func (h *Handler) HandleCreateStatusFull(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreateStatusFull creates a new status using the Notes service

func (*Handler) HandleCreateStatusLift 

func (h *Handler) HandleCreateStatusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreateStatusLift creates a new status using the Notes service

func (*Handler) HandleCreateVouchLift 

func (h *Handler) HandleCreateVouchLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleCreateVouchLift handles POST /api/v1/vouches

func (*Handler) HandleDebugFederationDomainLift 

func (h *Handler) HandleDebugFederationDomainLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDebugFederationDomainLift provides debug info for a specific federated domain

func (*Handler) HandleDebugFederationTraceLift 

func (h *Handler) HandleDebugFederationTraceLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDebugFederationTraceLift traces the processing of a specific activity

func (*Handler) HandleDebugObjectExplainLift 

func (h *Handler) HandleDebugObjectExplainLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDebugObjectExplainLift provides detailed explanation of object storage and cost

func (*Handler) HandleDebugObjectLift 

func (h *Handler) HandleDebugObjectLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDebugObjectLift provides detailed information about a stored object

func (*Handler) HandleDebugReplayLift 

func (h *Handler) HandleDebugReplayLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDebugReplayLift replays an activity for testing

func (*Handler) HandleDelegateAgentLift 

func (h *Handler) HandleDelegateAgentLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDelegateAgentLift handles POST /api/v1/agents/delegate.

M2: delegated OAuth agent creation.

func (*Handler) HandleDeleteAdminDomainAllowLift 

func (h *Handler) HandleDeleteAdminDomainAllowLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeleteAdminDomainAllowLift handles DELETE /api/v1/admin/domain_allows/:id

func (*Handler) HandleDeleteAdminDomainBlockLift 

func (h *Handler) HandleDeleteAdminDomainBlockLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeleteAdminDomainBlockLift handles DELETE /api/v1/admin/domain_blocks/:id

func (*Handler) HandleDeleteAgentLift 

func (h *Handler) HandleDeleteAgentLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeleteAgentLift handles DELETE /api/v1/agents/:username.

M2: deactivate agent (owner/admin only).

func (*Handler) HandleDeleteConversationLift 

func (h *Handler) HandleDeleteConversationLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeleteConversationLift removes a conversation from the user's list

func (*Handler) HandleDeleteCustomEmojiLift 

func (h *Handler) HandleDeleteCustomEmojiLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeleteCustomEmojiLift handles DELETE /api/v1/admin/custom_emojis/:shortcode (admin only)

func (*Handler) HandleDeleteDomainBlockLift 

func (h *Handler) HandleDeleteDomainBlockLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeleteDomainBlockLift handles DELETE /api/v1/domain_blocks

func (*Handler) HandleDeleteEmailDomainBlockLift 

func (h *Handler) HandleDeleteEmailDomainBlockLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeleteEmailDomainBlockLift handles DELETE /api/v1/admin/email_domain_blocks/:id

func (*Handler) HandleDeleteFeaturedTagLift 

func (h *Handler) HandleDeleteFeaturedTagLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeleteFeaturedTagLift removes a featured tag from the user's profile

func (*Handler) HandleDeleteFilterKeywordLift 

func (h *Handler) HandleDeleteFilterKeywordLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeleteFilterKeywordLift handles DELETE /api/v2/filters/:filter_id/keywords/:keyword_id

func (*Handler) HandleDeleteFilterLift 

func (h *Handler) HandleDeleteFilterLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeleteFilterLift handles DELETE /api/v2/filters/:id

func (*Handler) HandleDeleteFilterStatusLift 

func (h *Handler) HandleDeleteFilterStatusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeleteFilterStatusLift handles DELETE /api/v2/filters/:filter_id/statuses/:status_id

func (*Handler) HandleDeleteListLift 

func (h *Handler) HandleDeleteListLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeleteListLift handles DELETE /api/v1/lists/:id

func (*Handler) HandleDeletePushSubscriptionLift 

func (h *Handler) HandleDeletePushSubscriptionLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeletePushSubscriptionLift handles DELETE /api/v1/push/subscription

func (*Handler) HandleDeleteQuotePostLift 

func (h *Handler) HandleDeleteQuotePostLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeleteQuotePostLift handles DELETE /api/v1/statuses/:id/quote/:quote_id Deletes a quote post (removes the quote relationship)

func (*Handler) HandleDeleteScheduledStatusLift 

func (h *Handler) HandleDeleteScheduledStatusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeleteScheduledStatusLift handles DELETE /api/v1/scheduled_statuses/:id

func (*Handler) HandleDeleteStatusFull 

func (h *Handler) HandleDeleteStatusFull(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeleteStatusFull deletes a status using the Notes service

func (*Handler) HandleDeleteStatusLift 

func (h *Handler) HandleDeleteStatusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeleteStatusLift deletes a status using the Notes service

func (*Handler) HandleDeleteWebAuthnCredentialLift 

func (h *Handler) HandleDeleteWebAuthnCredentialLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDeleteWebAuthnCredentialLift removes a WebAuthn credential DELETE /api/v1/auth/webauthn/credentials/{credentialId}

func (*Handler) HandleDismissAnnouncementLift 

func (h *Handler) HandleDismissAnnouncementLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDismissAnnouncementLift handles POST /api/v1/announcements/:id/dismiss

func (*Handler) HandleDismissNotificationLift 

func (h *Handler) HandleDismissNotificationLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDismissNotificationLift handles POST /api/v1/notifications/:id/dismiss

func (*Handler) HandleDownloadExportLift 

func (h *Handler) HandleDownloadExportLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleDownloadExportLift handles GET /api/v1/exports/:id/download

func (*Handler) HandleEmbedPageLift 

func (h *Handler) HandleEmbedPageLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleEmbedPageLift handles GET /embed/:id using Lift framework

func (*Handler) HandleExportReputationLift 

func (h *Handler) HandleExportReputationLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleExportReputationLift handles POST /api/v1/reputation/export

func (*Handler) HandleFavoriteLift 

func (h *Handler) HandleFavoriteLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleFavoriteLift handles POST /api/v1/statuses/:id/favourite

func (*Handler) HandleFinishWebAuthnLoginLift 

func (h *Handler) HandleFinishWebAuthnLoginLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleFinishWebAuthnLoginLift completes the WebAuthn login process POST /api/v1/auth/webauthn/login/finish

func (*Handler) HandleFinishWebAuthnRegistrationLift 

func (h *Handler) HandleFinishWebAuthnRegistrationLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleFinishWebAuthnRegistrationLift completes the WebAuthn registration process POST /api/v1/auth/webauthn/register/finish

func (*Handler) HandleFollowAccountFull 

func (h *Handler) HandleFollowAccountFull(ctx *apptheory.Context) (*apptheory.Response, error)

HandleFollowAccountFull follows an account using Relationships service

func (*Handler) HandleFollowLift 

func (h *Handler) HandleFollowLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleFollowLift handles POST /api/v1/accounts/:id/follow

func (*Handler) HandleFollowTagLift 

func (h *Handler) HandleFollowTagLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleFollowTagLift follows a hashtag

func (*Handler) HandleGetAIAnalysisLift 

func (h *Handler) HandleGetAIAnalysisLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetAIAnalysisLift returns AI analysis for an object GET /api/v1/ai/analysis/:object_id

func (*Handler) HandleGetAIStatsLift 

func (h *Handler) HandleGetAIStatsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetAIStatsLift returns AI analysis statistics GET /api/v1/ai/stats

func (*Handler) HandleGetAISummaryLift 

func (h *Handler) HandleGetAISummaryLift(_ *apptheory.Context) (*apptheory.Response, error)

HandleGetAISummaryLift returns a summary of AI features and capabilities GET /api/v1/ai/capabilities

func (*Handler) HandleGetAccountFeaturedTagsLift 

func (h *Handler) HandleGetAccountFeaturedTagsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetAccountFeaturedTagsLift retrieves featured tags for a specific account

func (*Handler) HandleGetAccountFollowersFull 

func (h *Handler) HandleGetAccountFollowersFull(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetAccountFollowersFull retrieves followers for an account

func (*Handler) HandleGetAccountFollowersLift 

func (h *Handler) HandleGetAccountFollowersLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetAccountFollowersLift retrieves the list of accounts following the given account

func (*Handler) HandleGetAccountFollowingFull 

func (h *Handler) HandleGetAccountFollowingFull(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetAccountFollowingFull retrieves accounts that this account follows

func (*Handler) HandleGetAccountFollowingLift 

func (h *Handler) HandleGetAccountFollowingLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetAccountFollowingLift retrieves the list of accounts the given account is following

func (*Handler) HandleGetAccountFull 

func (h *Handler) HandleGetAccountFull(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetAccountFull retrieves account information by ID

func (*Handler) HandleGetAccountLift 

func (h *Handler) HandleGetAccountLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetAccountLift retrieves account information by ID (username or URL)

func (*Handler) HandleGetAccountStatusesFull 

func (h *Handler) HandleGetAccountStatusesFull(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetAccountStatusesFull retrieves statuses for an account using Notes service

func (*Handler) HandleGetAccountStatusesLift 

func (h *Handler) HandleGetAccountStatusesLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetAccountStatusesLift handles requests to get an account's statuses

func (*Handler) HandleGetAdminDomainAllowsLift 

func (h *Handler) HandleGetAdminDomainAllowsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetAdminDomainAllowsLift handles GET /api/v1/admin/domain_allows

func (*Handler) HandleGetAdminDomainBlockLift 

func (h *Handler) HandleGetAdminDomainBlockLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetAdminDomainBlockLift handles GET /api/v1/admin/domain_blocks/:id

func (*Handler) HandleGetAdminDomainBlocksLift 

func (h *Handler) HandleGetAdminDomainBlocksLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetAdminDomainBlocksLift handles GET /api/v1/admin/domain_blocks

func (*Handler) HandleGetAgentActivityLift 

func (h *Handler) HandleGetAgentActivityLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetAgentActivityLift handles GET /api/v1/agents/:username/activity.

M0: contract stub. Full implementation lands in M3.

func (*Handler) HandleGetAgentLift 

func (h *Handler) HandleGetAgentLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetAgentLift handles GET /api/v1/agents/:username.

M2: agent lookup.

func (*Handler) HandleGetAnnouncementsLift 

func (h *Handler) HandleGetAnnouncementsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetAnnouncementsLift handles GET /api/v1/announcements

func (*Handler) HandleGetBlocksLift 

func (h *Handler) HandleGetBlocksLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetBlocksLift handles GET /api/v1/blocks

func (*Handler) HandleGetBookmarksLift 

func (h *Handler) HandleGetBookmarksLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetBookmarksLift handles GET /api/v1/bookmarks

func (*Handler) HandleGetConsensusLift 

func (h *Handler) HandleGetConsensusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetConsensusLift handles GET /api/v1/moderation/consensus/:event_id

func (*Handler) HandleGetConversationsLift 

func (h *Handler) HandleGetConversationsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetConversationsLift retrieves all conversations for the authenticated user

func (*Handler) HandleGetCustomEmojisLift 

func (h *Handler) HandleGetCustomEmojisLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetCustomEmojisLift handles GET /api/v1/custom_emojis This endpoint is public and doesn't require authentication

func (*Handler) HandleGetDailyAggregatesLift 

func (h *Handler) HandleGetDailyAggregatesLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetDailyAggregatesLift returns daily aggregated metrics

func (*Handler) HandleGetDirectTimelineLift 

func (h *Handler) HandleGetDirectTimelineLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetDirectTimelineLift handles GET /api/v1/timelines/direct

func (*Handler) HandleGetDirectoryLift 

func (h *Handler) HandleGetDirectoryLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetDirectoryLift handles GET /api/v1/directory Returns profile directory of discoverable accounts

func (*Handler) HandleGetDomainBlocksLift 

func (h *Handler) HandleGetDomainBlocksLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetDomainBlocksLift handles GET /api/v1/domain_blocks

func (*Handler) HandleGetEmailDomainBlocksLift 

func (h *Handler) HandleGetEmailDomainBlocksLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetEmailDomainBlocksLift handles GET /api/v1/admin/email_domain_blocks

func (*Handler) HandleGetEndorsementsLift 

func (h *Handler) HandleGetEndorsementsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetEndorsementsLift handles GET /api/v1/endorsements Returns accounts that the user has endorsed (pinned to their profile)

func (*Handler) HandleGetExportStatusLift 

func (h *Handler) HandleGetExportStatusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetExportStatusLift handles GET /api/v1/exports/:id

func (*Handler) HandleGetFamiliarFollowersLift 

func (h *Handler) HandleGetFamiliarFollowersLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetFamiliarFollowersLift returns accounts that the requesting user follows and who also follow the given account

func (*Handler) HandleGetFavouritesLift 

func (h *Handler) HandleGetFavouritesLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetFavouritesLift handles GET /api/v1/favourites

func (*Handler) HandleGetFeaturedTagSuggestionsLift 

func (h *Handler) HandleGetFeaturedTagSuggestionsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetFeaturedTagSuggestionsLift suggests hashtags to feature based on usage

func (*Handler) HandleGetFeaturedTagsLift 

func (h *Handler) HandleGetFeaturedTagsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetFeaturedTagsLift retrieves the user's featured tags

func (*Handler) HandleGetFederationInstanceLift 

func (h *Handler) HandleGetFederationInstanceLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetFederationInstanceLift handles GET /api/v1/admin/federation/instance/:domain

func (*Handler) HandleGetFederationInstancesLift 

func (h *Handler) HandleGetFederationInstancesLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetFederationInstancesLift handles GET /api/v1/admin/federation/instances

func (*Handler) HandleGetFederationStatisticsLift 

func (h *Handler) HandleGetFederationStatisticsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetFederationStatisticsLift handles GET /api/v1/admin/federation/statistics

func (*Handler) HandleGetFilterKeywordsLift 

func (h *Handler) HandleGetFilterKeywordsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetFilterKeywordsLift handles GET /api/v2/filters/:filter_id/keywords

func (*Handler) HandleGetFilterLift 

func (h *Handler) HandleGetFilterLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetFilterLift handles GET /api/v2/filters/:id

func (*Handler) HandleGetFilterStatusesLift 

func (h *Handler) HandleGetFilterStatusesLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetFilterStatusesLift handles GET /api/v2/filters/:filter_id/statuses

func (*Handler) HandleGetFiltersLift 

func (h *Handler) HandleGetFiltersLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetFiltersLift handles GET /api/v2/filters

func (*Handler) HandleGetFollowRequestsLift 

func (h *Handler) HandleGetFollowRequestsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetFollowRequestsLift handles GET /api/v1/follow_requests Returns pending follow requests for locked accounts

func (*Handler) HandleGetFollowedTagsLift 

func (h *Handler) HandleGetFollowedTagsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetFollowedTagsLift retrieves the list of hashtags the user is following

func (*Handler) HandleGetGroupedNotificationsLift 

func (h *Handler) HandleGetGroupedNotificationsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetGroupedNotificationsLift handles GET /api/v2/notifications/grouped Returns notifications grouped by type and target with enhanced metadata

func (*Handler) HandleGetHomeTimelineLift 

func (h *Handler) HandleGetHomeTimelineLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetHomeTimelineLift returns the home timeline using the Notes service

func (*Handler) HandleGetImportStatusLift 

func (h *Handler) HandleGetImportStatusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetImportStatusLift handles GET /api/v1/imports/:id

func (*Handler) HandleGetInstanceActivityLift 

func (h *Handler) HandleGetInstanceActivityLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetInstanceActivityLift returns instance activity statistics

func (*Handler) HandleGetInstanceConfigurationLift 

func (h *Handler) HandleGetInstanceConfigurationLift(_ *apptheory.Context) (*apptheory.Response, error)

HandleGetInstanceConfigurationLift returns configuration details

func (*Handler) HandleGetInstanceCostsLift 

func (h *Handler) HandleGetInstanceCostsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetInstanceCostsLift returns cost analytics for the instance

func (*Handler) HandleGetInstanceDomainBlocksLift 

func (h *Handler) HandleGetInstanceDomainBlocksLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetInstanceDomainBlocksLift returns public domain blocks

func (*Handler) HandleGetInstanceMetricsLift 

func (h *Handler) HandleGetInstanceMetricsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetInstanceMetricsLift returns current instance metrics

func (*Handler) HandleGetInstancePeersLift 

func (h *Handler) HandleGetInstancePeersLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetInstancePeersLift returns connected domains (federation peers)

func (*Handler) HandleGetInstancePrivacyPolicyLift 

func (h *Handler) HandleGetInstancePrivacyPolicyLift(_ *apptheory.Context) (*apptheory.Response, error)

HandleGetInstancePrivacyPolicyLift returns the privacy policy

func (*Handler) HandleGetInstanceTermsOfServiceLift 

func (h *Handler) HandleGetInstanceTermsOfServiceLift(_ *apptheory.Context) (*apptheory.Response, error)

HandleGetInstanceTermsOfServiceLift returns the terms of service

func (*Handler) HandleGetInstanceV1Lift 

func (h *Handler) HandleGetInstanceV1Lift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetInstanceV1Lift returns instance information in v1 (legacy) format

func (*Handler) HandleGetInstanceV2Lift 

func (h *Handler) HandleGetInstanceV2Lift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetInstanceV2Lift returns instance information in v2 format

func (*Handler) HandleGetLinkTimelineLift 

func (h *Handler) HandleGetLinkTimelineLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetLinkTimelineLift handles GET /api/v1/timelines/link Returns timeline for a specific link

func (*Handler) HandleGetListAccountsLift 

func (h *Handler) HandleGetListAccountsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetListAccountsLift handles GET /api/v1/lists/:id/accounts

func (*Handler) HandleGetListLift 

func (h *Handler) HandleGetListLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetListLift handles GET /api/v1/lists/:id

func (*Handler) HandleGetListTimelineLift 

func (h *Handler) HandleGetListTimelineLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetListTimelineLift handles GET /api/v1/timelines/list/:list_id

func (*Handler) HandleGetListsLift 

func (h *Handler) HandleGetListsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetListsLift handles GET /api/v1/lists

func (*Handler) HandleGetMarkersLift 

func (h *Handler) HandleGetMarkersLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetMarkersLift handles GET /api/v1/markers Returns saved timeline positions

func (*Handler) HandleGetMediaLift 

func (h *Handler) HandleGetMediaLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetMediaLift handles GET /api/v1/media/:id (Lift version)

func (*Handler) HandleGetMutedAccountsLift 

func (h *Handler) HandleGetMutedAccountsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetMutedAccountsLift handles GET /api/v1/mutes

func (*Handler) HandleGetNotesLift 

func (h *Handler) HandleGetNotesLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetNotesLift handles GET /api/v1/notes/:object_id

func (*Handler) HandleGetNotificationLift 

func (h *Handler) HandleGetNotificationLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetNotificationLift handles GET /api/v1/notifications/:id

func (*Handler) HandleGetNotificationsLift 

func (h *Handler) HandleGetNotificationsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetNotificationsLift retrieves notifications for the authenticated user

func (*Handler) HandleGetPollLift 

func (h *Handler) HandleGetPollLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetPollLift retrieves a poll by ID

func (*Handler) HandleGetPredictiveAnalyticsLift 

func (h *Handler) HandleGetPredictiveAnalyticsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetPredictiveAnalyticsLift returns predictive analytics

func (*Handler) HandleGetPreferencesLift 

func (h *Handler) HandleGetPreferencesLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetPreferencesLift handles GET /api/v1/preferences Returns user preferences in Mastodon format

func (*Handler) HandleGetPublicTimelineLift 

func (h *Handler) HandleGetPublicTimelineLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetPublicTimelineLift returns the public timeline using the Notes service

func (*Handler) HandleGetPushSubscriptionLift 

func (h *Handler) HandleGetPushSubscriptionLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetPushSubscriptionLift handles GET /api/v1/push/subscription

func (*Handler) HandleGetQuotePermissionsLift 

func (h *Handler) HandleGetQuotePermissionsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetQuotePermissionsLift handles GET /api/v1/accounts/:id/quote_permissions Returns quote permissions for a user

func (*Handler) HandleGetQuotesOfStatusLift 

func (h *Handler) HandleGetQuotesOfStatusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetQuotesOfStatusLift handles GET /api/v1/statuses/:id/quotes Returns a list of quote posts for a given status

func (*Handler) HandleGetRelationshipsFull 

func (h *Handler) HandleGetRelationshipsFull(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetRelationshipsFull gets relationships with multiple accounts using Relationships service

func (*Handler) HandleGetRelationshipsLift 

func (h *Handler) HandleGetRelationshipsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetRelationshipsLift handles GET /api/v1/accounts/relationships It accepts multiple account IDs as query parameters: id[]=1&id[]=2

func (*Handler) HandleGetReputationKeysLift 

func (h *Handler) HandleGetReputationKeysLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetReputationKeysLift handles GET /.well-known/reputation-keys

func (*Handler) HandleGetReputationLift 

func (h *Handler) HandleGetReputationLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetReputationLift handles GET /api/v1/reputation/:actor_id

func (*Handler) HandleGetScheduledStatusLift 

func (h *Handler) HandleGetScheduledStatusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetScheduledStatusLift handles GET /api/v1/scheduled_statuses/:id

func (*Handler) HandleGetScheduledStatusesLift 

func (h *Handler) HandleGetScheduledStatusesLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetScheduledStatusesLift handles GET /api/v1/scheduled_statuses

func (*Handler) HandleGetSearchSuggestionsLift 

func (h *Handler) HandleGetSearchSuggestionsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetSearchSuggestionsLift handles GET /api/v1/accounts/search/suggestions Returns search suggestions for autocomplete

func (*Handler) HandleGetStatusContextLift 

func (h *Handler) HandleGetStatusContextLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetStatusContextLift retrieves the context (ancestors and descendants) of a status

func (*Handler) HandleGetStatusFavouritedByLift 

func (h *Handler) HandleGetStatusFavouritedByLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetStatusFavouritedByLift handles GET /api/v1/statuses/:id/favourited_by

func (*Handler) HandleGetStatusFull 

func (h *Handler) HandleGetStatusFull(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetStatusFull retrieves a status by ID using the Notes service

func (*Handler) HandleGetStatusHistoryLift 

func (h *Handler) HandleGetStatusHistoryLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetStatusHistoryLift handles GET /api/v1/statuses/:id/history

func (*Handler) HandleGetStatusLift 

func (h *Handler) HandleGetStatusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetStatusLift retrieves a status by ID using the Notes service

func (*Handler) HandleGetStatusRebloggedByLift 

func (h *Handler) HandleGetStatusRebloggedByLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetStatusRebloggedByLift handles GET /api/v1/statuses/:id/reblogged_by

func (*Handler) HandleGetStatusSourceLift 

func (h *Handler) HandleGetStatusSourceLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetStatusSourceLift handles GET /api/v1/statuses/:id/source

func (*Handler) HandleGetSuggestionsV1Lift 

func (h *Handler) HandleGetSuggestionsV1Lift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetSuggestionsV1Lift handles GET /api/v1/suggestions Returns follow suggestions (v1 format)

func (*Handler) HandleGetSuggestionsV2Lift 

func (h *Handler) HandleGetSuggestionsV2Lift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetSuggestionsV2Lift handles GET /api/v2/suggestions Returns follow suggestions (v2 format with sources)

func (*Handler) HandleGetTagLift 

func (h *Handler) HandleGetTagLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetTagLift retrieves information about a specific hashtag

func (*Handler) HandleGetTagTimelineLift 

func (h *Handler) HandleGetTagTimelineLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetTagTimelineLift handles GET /api/v1/timelines/tag/:hashtag

func (*Handler) HandleGetTranslationLanguagesLift 

func (h *Handler) HandleGetTranslationLanguagesLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetTranslationLanguagesLift handles GET /api/v1/instance/translation_languages

func (*Handler) HandleGetTrendingLinksLift 

func (h *Handler) HandleGetTrendingLinksLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetTrendingLinksLift handles GET /api/v1/trends/links Returns trending links

func (*Handler) HandleGetTrendingLinksV2Lift 

func (h *Handler) HandleGetTrendingLinksV2Lift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetTrendingLinksV2Lift handles GET /api/v2/trends/links Returns trending links with enhanced metadata

func (*Handler) HandleGetTrendingStatusesLift 

func (h *Handler) HandleGetTrendingStatusesLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetTrendingStatusesLift handles GET /api/v1/trends/statuses Returns trending statuses

func (*Handler) HandleGetTrendingStatusesV2Lift 

func (h *Handler) HandleGetTrendingStatusesV2Lift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetTrendingStatusesV2Lift handles GET /api/v2/trends/statuses Returns trending statuses with enhanced metrics

func (*Handler) HandleGetTrendingTagsLift 

func (h *Handler) HandleGetTrendingTagsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetTrendingTagsLift handles GET /api/v1/trends/tags Returns trending hashtags

func (*Handler) HandleGetTrendingTagsV2Lift 

func (h *Handler) HandleGetTrendingTagsV2Lift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetTrendingTagsV2Lift handles GET /api/v2/trends/tags Returns trending hashtags with enhanced metrics

func (*Handler) HandleGetTrendsLift 

func (h *Handler) HandleGetTrendsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetTrendsLift handles GET /api/v1/trends Returns general trends (mix of all types)

func (*Handler) HandleGetTrendsV2Lift 

func (h *Handler) HandleGetTrendsV2Lift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetTrendsV2Lift handles GET /api/v2/trends Returns general trends with enhanced metadata

func (*Handler) HandleGetTrustRelationshipsLift 

func (h *Handler) HandleGetTrustRelationshipsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetTrustRelationshipsLift handles GET /api/v1/moderation/trust

func (*Handler) HandleGetTrustScoreLift 

func (h *Handler) HandleGetTrustScoreLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetTrustScoreLift handles GET /api/v1/moderation/trust/:actor_id/score

func (*Handler) HandleGetUserNotesLift 

func (h *Handler) HandleGetUserNotesLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetUserNotesLift handles GET /api/v1/accounts/:id/notes

func (*Handler) HandleGetVouchesLift 

func (h *Handler) HandleGetVouchesLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetVouchesLift handles GET /api/v1/vouches/:actor_id

func (*Handler) HandleGetWalletsLift 

func (h *Handler) HandleGetWalletsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleGetWalletsLift handles GET /auth/wallet/list

func (*Handler) HandleImportReputationLift 

func (h *Handler) HandleImportReputationLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleImportReputationLift handles POST /api/v1/reputation/import

func (*Handler) HandleLinkWalletLift 

func (h *Handler) HandleLinkWalletLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleLinkWalletLift handles POST /auth/wallet/link

func (*Handler) HandleListAgentsLift 

func (h *Handler) HandleListAgentsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleListAgentsLift handles GET /api/v1/agents.

M2: agent directory.

func (*Handler) HandleListExportsLift 

func (h *Handler) HandleListExportsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleListExportsLift handles GET /api/v1/exports

func (*Handler) HandleListImportsLift 

func (h *Handler) HandleListImportsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleListImportsLift handles GET /api/v1/imports

func (*Handler) HandleListWebAuthnCredentialsLift 

func (h *Handler) HandleListWebAuthnCredentialsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleListWebAuthnCredentialsLift returns all WebAuthn credentials for the authenticated user GET /api/v1/auth/webauthn/credentials

func (*Handler) HandleLoginWalletLift 

func (h *Handler) HandleLoginWalletLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleLoginWalletLift handles POST /auth/wallet/login (for login)

func (*Handler) HandleMarkConversationReadLift 

func (h *Handler) HandleMarkConversationReadLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleMarkConversationReadLift marks a conversation as read

func (*Handler) HandleMarkGroupAsReadLift 

func (h *Handler) HandleMarkGroupAsReadLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleMarkGroupAsReadLift handles POST /api/v2/notifications/groups/:group_id/read Marks all notifications in a group as read

func (*Handler) HandleModerationFlagLift 

func (h *Handler) HandleModerationFlagLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleModerationFlagLift handles POST /api/v1/moderation/flag

func (*Handler) HandleModerationHistoryLift 

func (h *Handler) HandleModerationHistoryLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleModerationHistoryLift handles GET /api/v1/moderation/history/:object_id

func (*Handler) HandleModerationQueueLift 

func (h *Handler) HandleModerationQueueLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleModerationQueueLift handles GET /api/v1/moderation/queue

func (*Handler) HandleModerationReviewLift 

func (h *Handler) HandleModerationReviewLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleModerationReviewLift handles POST /api/v1/moderation/review

func (*Handler) HandleMuteAccountFull 

func (h *Handler) HandleMuteAccountFull(ctx *apptheory.Context) (*apptheory.Response, error)

HandleMuteAccountFull mutes an account using Relationships service

func (*Handler) HandleMuteAccountLift 

func (h *Handler) HandleMuteAccountLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleMuteAccountLift handles POST /api/v1/accounts/:id/mute

func (*Handler) HandleMuteConversationLift 

func (h *Handler) HandleMuteConversationLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleMuteConversationLift handles POST /api/v1/statuses/:id/mute

func (*Handler) HandleNodeInfoLift 

func (h *Handler) HandleNodeInfoLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleNodeInfoLift handles /nodeinfo/2.0 requests

func (*Handler) HandleNodeInfoWellKnownLift 

func (h *Handler) HandleNodeInfoWellKnownLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleNodeInfoWellKnownLift handles /.well-known/nodeinfo requests

func (*Handler) HandleOAuthAuthorizeLift 

func (h *Handler) HandleOAuthAuthorizeLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleOAuthAuthorizeLift handles the OAuth authorization endpoint using native Lift patterns GET /oauth/authorize

func (*Handler) HandleOAuthConsentLift 

func (h *Handler) HandleOAuthConsentLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleOAuthConsentLift handles the OAuth consent form submission using Lift patterns POST /oauth/consent

func (*Handler) HandleOAuthLoginLift 

func (h *Handler) HandleOAuthLoginLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleOAuthLoginLift handles redirecting users to login during OAuth flow GET /oauth/login

func (*Handler) HandleOAuthTokenLift 

func (h *Handler) HandleOAuthTokenLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleOAuthTokenLift handles the OAuth token endpoint using native Lift patterns POST /oauth/token

func (*Handler) HandleOEmbedLift 

func (h *Handler) HandleOEmbedLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleOEmbedLift handles GET /api/oembed using Lift framework

func (*Handler) HandlePinAccountLift 

func (h *Handler) HandlePinAccountLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandlePinAccountLift pins an account to the user's profile

func (*Handler) HandlePinStatusLift 

func (h *Handler) HandlePinStatusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandlePinStatusLift handles POST /api/v1/statuses/:id/pin

func (*Handler) HandleReblogLift 

func (h *Handler) HandleReblogLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleReblogLift handles POST /api/v1/statuses/:id/reblog

func (*Handler) HandleRegistrationLift 

func (h *Handler) HandleRegistrationLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleRegistrationLift handles user registration requests

func (*Handler) HandleRejectFollowRequestLift 

func (h *Handler) HandleRejectFollowRequestLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleRejectFollowRequestLift handles POST /api/v1/follow_requests/:account_id/reject Rejects a pending follow request

func (*Handler) HandleRemoveAccountsFromListLift 

func (h *Handler) HandleRemoveAccountsFromListLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleRemoveAccountsFromListLift handles DELETE /api/v1/lists/:id/accounts

func (*Handler) HandleRemoveAnnouncementReactionLift 

func (h *Handler) HandleRemoveAnnouncementReactionLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleRemoveAnnouncementReactionLift handles DELETE /api/v1/announcements/:id/reactions/:name

func (*Handler) HandleRemoveFromFollowersLift 

func (h *Handler) HandleRemoveFromFollowersLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleRemoveFromFollowersLift removes a follower from the current user's followers list

func (*Handler) HandleRemoveSuggestionLift 

func (h *Handler) HandleRemoveSuggestionLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleRemoveSuggestionLift handles DELETE /api/v1/suggestions/:account_id Removes an account from suggestions

func (*Handler) HandleRequestAIAnalysisLift 

func (h *Handler) HandleRequestAIAnalysisLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleRequestAIAnalysisLift triggers AI analysis for an object POST /api/v1/ai/analyze

func (*Handler) HandleRevokeVouchLift 

func (h *Handler) HandleRevokeVouchLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleRevokeVouchLift handles DELETE /api/v1/vouches/:vouch_id

func (*Handler) HandleSaveMarkersLift 

func (h *Handler) HandleSaveMarkersLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleSaveMarkersLift handles POST /api/v1/markers Saves timeline positions

func (*Handler) HandleSearchLift 

func (h *Handler) HandleSearchLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleSearchLift performs a search across accounts, statuses, and hashtags

func (*Handler) HandleSearchV2Lift 

func (h *Handler) HandleSearchV2Lift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleSearchV2Lift handles GET /api/v2/search requests - returns same format as v1

func (*Handler) HandleSetAccountNoteLift 

func (h *Handler) HandleSetAccountNoteLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleSetAccountNoteLift sets a private note on an account

func (*Handler) HandleSetupBootstrapChallengeLift 

func (h *Handler) HandleSetupBootstrapChallengeLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleSetupBootstrapChallengeLift handles POST /setup/bootstrap/challenge.

func (*Handler) HandleSetupBootstrapVerifyLift 

func (h *Handler) HandleSetupBootstrapVerifyLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleSetupBootstrapVerifyLift handles POST /setup/bootstrap/verify.

func (*Handler) HandleSetupCreateAdminLift 

func (h *Handler) HandleSetupCreateAdminLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleSetupCreateAdminLift handles POST /setup/admin.

func (*Handler) HandleSetupFinalizeLift 

func (h *Handler) HandleSetupFinalizeLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleSetupFinalizeLift handles POST /setup/finalize.

func (*Handler) HandleSetupStatusLift 

func (h *Handler) HandleSetupStatusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleSetupStatusLift handles GET /setup/status.

func (*Handler) HandleStatusSearchLift 

func (h *Handler) HandleStatusSearchLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleStatusSearchLift handles POST/GET /api/v1/search/statuses Search for statuses with privacy enforcement

func (*Handler) HandleSuspendAgentLift 

func (h *Handler) HandleSuspendAgentLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleSuspendAgentLift handles POST /api/v1/agents/:username/suspend.

M2: admin suspend.

func (*Handler) HandleTestFilterLift 

func (h *Handler) HandleTestFilterLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleTestFilterLift handles POST /api/v2/filters/test Tests filter rules against provided content

func (*Handler) HandleTranslateStatusLift 

func (h *Handler) HandleTranslateStatusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleTranslateStatusLift handles POST /api/v1/statuses/:id/translate

func (*Handler) HandleUnblockAccountFull 

func (h *Handler) HandleUnblockAccountFull(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUnblockAccountFull unblocks an account using Relationships service

func (*Handler) HandleUnblockLift 

func (h *Handler) HandleUnblockLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUnblockLift handles POST /api/v1/accounts/:id/unblock

func (*Handler) HandleUnbookmarkLift 

func (h *Handler) HandleUnbookmarkLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUnbookmarkLift handles POST /api/v1/statuses/:id/unbookmark

func (*Handler) HandleUndoUnifiedBoostLift 

func (h *Handler) HandleUndoUnifiedBoostLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUndoUnifiedBoostLift handles undoing both traditional boosts and quote boosts

func (*Handler) HandleUnfavoriteLift 

func (h *Handler) HandleUnfavoriteLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUnfavoriteLift handles POST /api/v1/statuses/:id/unfavourite

func (*Handler) HandleUnfollowAccountFull 

func (h *Handler) HandleUnfollowAccountFull(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUnfollowAccountFull unfollows an account using Relationships service

func (*Handler) HandleUnfollowLift 

func (h *Handler) HandleUnfollowLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUnfollowLift handles POST /api/v1/accounts/:id/unfollow

func (*Handler) HandleUnfollowTagLift 

func (h *Handler) HandleUnfollowTagLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUnfollowTagLift unfollows a hashtag

func (*Handler) HandleUnifiedBoostLift 

func (h *Handler) HandleUnifiedBoostLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUnifiedBoostLift handles both traditional boosts and quote boosts

func (*Handler) HandleUnlinkWalletLift 

func (h *Handler) HandleUnlinkWalletLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUnlinkWalletLift handles DELETE /auth/wallet/unlink/{address}

func (*Handler) HandleUnmuteAccountFull 

func (h *Handler) HandleUnmuteAccountFull(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUnmuteAccountFull unmutes an account using Relationships service

func (*Handler) HandleUnmuteAccountLift 

func (h *Handler) HandleUnmuteAccountLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUnmuteAccountLift handles POST /api/v1/accounts/:id/unmute

func (*Handler) HandleUnmuteConversationLift 

func (h *Handler) HandleUnmuteConversationLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUnmuteConversationLift handles POST /api/v1/statuses/:id/unmute

func (*Handler) HandleUnpinAccountLift 

func (h *Handler) HandleUnpinAccountLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUnpinAccountLift unpins an account from the user's profile

func (*Handler) HandleUnpinStatusLift 

func (h *Handler) HandleUnpinStatusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUnpinStatusLift handles POST /api/v1/statuses/:id/unpin

func (*Handler) HandleUnreblogLift 

func (h *Handler) HandleUnreblogLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUnreblogLift handles POST /api/v1/statuses/:id/unreblog

func (*Handler) HandleUpdateAdminDomainBlockLift 

func (h *Handler) HandleUpdateAdminDomainBlockLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUpdateAdminDomainBlockLift handles PUT /api/v1/admin/domain_blocks/:id

func (*Handler) HandleUpdateAgentLift 

func (h *Handler) HandleUpdateAgentLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUpdateAgentLift handles PATCH /api/v1/agents/:username.

M2: agent metadata update (owner/admin only).

func (*Handler) HandleUpdateCredentialsFull 

func (h *Handler) HandleUpdateCredentialsFull(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUpdateCredentialsFull updates the authenticated user's profile using Accounts service

func (*Handler) HandleUpdateCredentialsLift 

func (h *Handler) HandleUpdateCredentialsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUpdateCredentialsLift updates the current user's profile

func (*Handler) HandleUpdateCustomEmojiLift 

func (h *Handler) HandleUpdateCustomEmojiLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUpdateCustomEmojiLift handles PUT /api/v1/admin/custom_emojis/:shortcode (admin only)

func (*Handler) HandleUpdateFilterLift 

func (h *Handler) HandleUpdateFilterLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUpdateFilterLift handles PUT /api/v2/filters/:id

func (*Handler) HandleUpdateListLift 

func (h *Handler) HandleUpdateListLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUpdateListLift handles PUT /api/v1/lists/:id

func (*Handler) HandleUpdateMediaLift 

func (h *Handler) HandleUpdateMediaLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUpdateMediaLift handles PUT /api/v1/media/:id (Lift version)

func (*Handler) HandleUpdatePreferencesLift 

func (h *Handler) HandleUpdatePreferencesLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUpdatePreferencesLift handles PATCH /api/v1/preferences Updates user preferences and returns the updated preferences

func (*Handler) HandleUpdatePushSubscriptionLift 

func (h *Handler) HandleUpdatePushSubscriptionLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUpdatePushSubscriptionLift handles PUT /api/v1/push/subscription

func (*Handler) HandleUpdateQuotePermissionsLift 

func (h *Handler) HandleUpdateQuotePermissionsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUpdateQuotePermissionsLift handles PUT /api/v1/accounts/quote_permissions Updates quote permissions for the authenticated user

func (*Handler) HandleUpdateScheduledStatusLift 

func (h *Handler) HandleUpdateScheduledStatusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUpdateScheduledStatusLift handles PUT /api/v1/scheduled_statuses/:id

func (*Handler) HandleUpdateStatusLift 

func (h *Handler) HandleUpdateStatusLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUpdateStatusLift updates an existing status

func (*Handler) HandleUpdateTrustLift 

func (h *Handler) HandleUpdateTrustLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUpdateTrustLift handles PUT /api/v1/moderation/trust

func (*Handler) HandleUpdateWebAuthnCredentialNameLift 

func (h *Handler) HandleUpdateWebAuthnCredentialNameLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUpdateWebAuthnCredentialNameLift updates the display name of a WebAuthn credential PUT /api/v1/auth/webauthn/credentials/{credentialId}

func (*Handler) HandleUploadMediaLift 

func (h *Handler) HandleUploadMediaLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleUploadMediaLift handles POST /api/v1/media (Lift version)

func (*Handler) HandleVerifyCredentialsFull 

func (h *Handler) HandleVerifyCredentialsFull(ctx *apptheory.Context) (*apptheory.Response, error)

HandleVerifyCredentialsFull returns the authenticated user's account using Accounts service

func (*Handler) HandleVerifyCredentialsLift 

func (h *Handler) HandleVerifyCredentialsLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleVerifyCredentialsLift returns the current user's information

func (*Handler) HandleVerifyReputationLift 

func (h *Handler) HandleVerifyReputationLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleVerifyReputationLift handles POST /api/v1/reputation/verify

func (*Handler) HandleVerifySignatureLift 

func (h *Handler) HandleVerifySignatureLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleVerifySignatureLift handles POST /auth/wallet/verify (for registration)

func (*Handler) HandleVoteNoteLift 

func (h *Handler) HandleVoteNoteLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleVoteNoteLift handles POST /api/v1/notes/:id/vote

func (*Handler) HandleVoteOnPollLift 

func (h *Handler) HandleVoteOnPollLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleVoteOnPollLift submits a vote on a poll

func (*Handler) HandleWebFingerLift 

func (h *Handler) HandleWebFingerLift(ctx *apptheory.Context) (*apptheory.Response, error)

HandleWebFingerLift handles /.well-known/webfinger requests

type HealthCheckResponse 

type HealthCheckResponse struct {
	Status    HealthStatus           `json:"status"`
	Timestamp time.Time              `json:"timestamp"`
	Version   string                 `json:"version,omitempty"`
	BuildInfo map[string]string      `json:"build_info,omitempty"`
	Checks    map[string]CheckResult `json:"checks,omitempty"`
	Uptime    time.Duration          `json:"uptime,omitempty"`
}

HealthCheckResponse represents the health check response

type HealthChecker 

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

HealthChecker handles health check operations

func NewHealthChecker 

func NewHealthChecker(logger *zap.Logger, repos core.RepositoryStorage) *HealthChecker

NewHealthChecker creates a new health checker

func (*HealthChecker) HandleDetailedHealthCheck 

func (h *HealthChecker) HandleDetailedHealthCheck(c *apptheory.Context) (*apptheory.Response, error)

HandleDetailedHealthCheck handles GET /health/detailed - comprehensive health check

func (*HealthChecker) HandleLivenessCheck 

func (h *HealthChecker) HandleLivenessCheck(_ *apptheory.Context) (*apptheory.Response, error)

HandleLivenessCheck handles GET /health/live - basic liveness check

func (*HealthChecker) HandleReadinessCheck 

func (h *HealthChecker) HandleReadinessCheck(c *apptheory.Context) (*apptheory.Response, error)

HandleReadinessCheck handles GET /health/ready - full readiness check

type HealthStatus 

type HealthStatus string

HealthStatus represents the overall health status 

const (
	HealthStatusHealthy   HealthStatus = "healthy"
	HealthStatusDegraded  HealthStatus = "degraded"
	HealthStatusUnhealthy HealthStatus = "unhealthy"
)

HealthStatus values

type ListsService 

type ListsService interface {
	AddToList(ctx context.Context, cmd *lists.AddToListCommand) (*lists.MembershipResult, error)
	CreateList(ctx context.Context, cmd *lists.CreateListCommand) (*lists.ListResult, error)
	DeleteList(ctx context.Context, cmd *lists.DeleteListCommand) error
	GetList(ctx context.Context, query *lists.GetListQuery) (*storagemodels.List, error)
	GetListMembers(ctx context.Context, query *lists.GetListMembersQuery) (*lists.MembersResult, error)
	GetListTimeline(ctx context.Context, query *lists.GetListTimelineQuery) (*lists.TimelineResult, error)
	ListUserLists(ctx context.Context, query *lists.ListUserListsQuery) (*lists.Result, error)
	RemoveFromList(ctx context.Context, cmd *lists.RemoveFromListCommand) (*lists.MembershipResult, error)
	UpdateList(ctx context.Context, cmd *lists.UpdateListCommand) (*lists.ListResult, error)
}

ListsService defines the subset of list-related operations used by the Lift API

type MediaService 

type MediaService interface {
	GetMedia(ctx context.Context, query *media.GetMediaQuery) (*storagemodels.Media, error)
	UpdateMedia(ctx context.Context, cmd *media.UpdateMediaCommand) (*media.UpdateResult, error)
	UploadMedia(ctx context.Context, cmd *media.UploadMediaCommand) (*media.Result, error)
}

MediaService defines the subset of media-related operations used by the Lift API

type MediaUploadRequest 

type MediaUploadRequest struct {
	FileName    string
	MimeType    string
	FileData    []byte
	Description string
	Focus       string
	Sensitive   bool
	SpoilerText string
	MediaType   string
}

MediaUploadRequest holds parsed multipart media upload data

type MockRepositoryStorage 

type MockRepositoryStorage struct {
	mock.Mock
}

MockRepositoryStorage is a mock implementation of core.RepositoryStorage for testing This struct implements all repository accessor methods required by the core.RepositoryStorage interface Each method returns the result of m.Called() which can be mocked using testify/mock

func (*MockRepositoryStorage) AI 

func (m *MockRepositoryStorage) AI() *repositories.AIRepository

AI returns a mock AI repository for testing

func (*MockRepositoryStorage) Account 

func (m *MockRepositoryStorage) Account() *repositories.AccountRepository

Account returns a mock account repository for testing

func (*MockRepositoryStorage) Activity 

func (m *MockRepositoryStorage) Activity() interfaces.ActivityRepository

Activity returns a mock activity repository for testing (interface type for mockability).

func (*MockRepositoryStorage) Actor 

func (m *MockRepositoryStorage) Actor() interfaces.ActorRepository

Actor returns a mock actor repository for testing

func (*MockRepositoryStorage) Analytics 

func (m *MockRepositoryStorage) Analytics() *repositories.TrendingRepository

Analytics returns a mock analytics repository for testing

func (*MockRepositoryStorage) Announcement 

func (m *MockRepositoryStorage) Announcement() *repositories.AnnouncementRepository

Announcement returns a mock announcement repository for testing

func (*MockRepositoryStorage) Article 

func (m *MockRepositoryStorage) Article() interfaces.ArticleRepository

Article returns a mock article repository for testing

func (*MockRepositoryStorage) Audit 

func (m *MockRepositoryStorage) Audit() *repositories.AuditRepository

Audit returns a mock audit repository for testing

func (*MockRepositoryStorage) Bookmark 

func (m *MockRepositoryStorage) Bookmark() *repositories.BookmarkRepository

Bookmark returns a mock bookmark repository for testing

func (*MockRepositoryStorage) Category 

func (m *MockRepositoryStorage) Category() interfaces.CategoryRepository

Category returns a mock category repository for testing

func (*MockRepositoryStorage) CloudWatchMetrics 

func (m *MockRepositoryStorage) CloudWatchMetrics() *repositories.CloudWatchMetricsRepository

CloudWatchMetrics returns a mock CloudWatch metrics repository for testing

func (*MockRepositoryStorage) CommunityNote 

func (m *MockRepositoryStorage) CommunityNote() *repositories.CommunityNoteRepository

CommunityNote returns a mock community note repository for testing

func (*MockRepositoryStorage) Conversation 

func (m *MockRepositoryStorage) Conversation() *repositories.ConversationRepository

Conversation returns a mock conversation repository for testing

func (*MockRepositoryStorage) Cost 

func (m *MockRepositoryStorage) Cost() *repositories.TrackingRepository

Cost returns a mock cost repository for testing

func (*MockRepositoryStorage) DLQ 

func (m *MockRepositoryStorage) DLQ() *repositories.DLQRepository

DLQ returns a mock DLQ repository for testing

func (*MockRepositoryStorage) DNSCache 

func (m *MockRepositoryStorage) DNSCache() *repositories.DNSCacheRepository

DNSCache returns a mock DNS cache repository for testing

func (*MockRepositoryStorage) DomainBlock 

func (m *MockRepositoryStorage) DomainBlock() *repositories.DomainBlockRepository

DomainBlock returns a mock domainblock repository for testing

func (*MockRepositoryStorage) Draft 

func (m *MockRepositoryStorage) Draft() interfaces.DraftRepository

Draft returns a mock draft repository for testing

func (*MockRepositoryStorage) Emoji 

func (m *MockRepositoryStorage) Emoji() *repositories.EmojiRepository

Emoji returns a mock emoji repository for testing

func (*MockRepositoryStorage) Export 

func (m *MockRepositoryStorage) Export() *repositories.ExportRepository

Export returns a mock export repository for testing

func (*MockRepositoryStorage) FeaturedTag 

func (m *MockRepositoryStorage) FeaturedTag() *repositories.FeaturedTagRepository

FeaturedTag returns a mock featured tag repository for testing

func (*MockRepositoryStorage) Federation 

func (m *MockRepositoryStorage) Federation() *repositories.FederationRepository

Federation returns a mock federation repository for testing

func (*MockRepositoryStorage) Filter 

func (m *MockRepositoryStorage) Filter() *repositories.FilterRepository

Filter returns a mock filter repository for testing

func (*MockRepositoryStorage) GetDB 

func (m *MockRepositoryStorage) GetDB() dynamormCore.DB

GetDB returns a mock database connection for testing

func (*MockRepositoryStorage) GetLogger 

func (m *MockRepositoryStorage) GetLogger() *zap.Logger

GetLogger returns a mock logger for testing

func (*MockRepositoryStorage) GetTableName 

func (m *MockRepositoryStorage) GetTableName() string

GetTableName returns a mock table name for testing

func (*MockRepositoryStorage) Hashtag 

func (m *MockRepositoryStorage) Hashtag() *repositories.HashtagRepository

Hashtag returns a mock hashtag repository for testing

func (*MockRepositoryStorage) Import 

func (m *MockRepositoryStorage) Import() *repositories.ImportRepository

Import returns a mock import repository for testing

func (*MockRepositoryStorage) Instance 

func (m *MockRepositoryStorage) Instance() *repositories.InstanceRepository

Instance returns a mock instance repository for testing

func (*MockRepositoryStorage) Like 

func (m *MockRepositoryStorage) Like() *repositories.LikeRepository

Like returns a mock like repository for testing

func (*MockRepositoryStorage) List 

func (m *MockRepositoryStorage) List() *repositories.ListRepository

List returns a mock list repository for testing

func (*MockRepositoryStorage) Marker 

func (m *MockRepositoryStorage) Marker() *repositories.MarkerRepository

Marker returns a mock marker repository for testing

func (*MockRepositoryStorage) Media 

func (m *MockRepositoryStorage) Media() *repositories.MediaRepository

Media returns a mock media repository for testing

func (*MockRepositoryStorage) MediaAnalytics 

func (m *MockRepositoryStorage) MediaAnalytics() interfaces.MediaAnalyticsRepository

MediaAnalytics returns a mock media analytics repository for testing

func (*MockRepositoryStorage) MediaMetadata 

func (m *MockRepositoryStorage) MediaMetadata() *repositories.MediaMetadataRepository

MediaMetadata returns a mock media metadata repository for testing

func (*MockRepositoryStorage) MediaPopularity 

func (m *MockRepositoryStorage) MediaPopularity() interfaces.MediaPopularityRepository

MediaPopularity returns a mock media popularity repository for testing

func (*MockRepositoryStorage) MediaSession 

func (m *MockRepositoryStorage) MediaSession() interfaces.MediaSessionRepository

MediaSession returns a mock media session repository for testing

func (*MockRepositoryStorage) MetricRecord 

func (m *MockRepositoryStorage) MetricRecord() *repositories.MetricRecordRepository

MetricRecord returns a mock metric record repository for testing

func (*MockRepositoryStorage) Moderation 

func (m *MockRepositoryStorage) Moderation() interfaces.ModerationRepository

Moderation returns a mock moderation repository for testing

func (*MockRepositoryStorage) ModerationML 

func (m *MockRepositoryStorage) ModerationML() *repositories.ModerationMLRepository

ModerationML returns a mock ModerationML repository for testing

func (*MockRepositoryStorage) Notification 

func (m *MockRepositoryStorage) Notification() interfaces.NotificationRepository

Notification returns a mock notification repository for testing (interface type for mockability).

func (*MockRepositoryStorage) OAuth 

func (m *MockRepositoryStorage) OAuth() *repositories.OAuthRepository

OAuth returns a mock OAuth repository for testing

func (*MockRepositoryStorage) Object 

func (m *MockRepositoryStorage) Object() interfaces.ObjectRepository

Object returns a mock object repository for testing (interface type for mockability).

func (*MockRepositoryStorage) Poll 

func (m *MockRepositoryStorage) Poll() *repositories.PollRepository

Poll returns a mock poll repository for testing

func (*MockRepositoryStorage) Publication 

func (m *MockRepositoryStorage) Publication() interfaces.PublicationRepository

Publication returns a mock publication repository for testing

func (*MockRepositoryStorage) PublicationMember 

func (m *MockRepositoryStorage) PublicationMember() interfaces.PublicationMemberRepository

PublicationMember returns a mock publication member repository for testing

func (*MockRepositoryStorage) PushSubscription 

func (m *MockRepositoryStorage) PushSubscription() *repositories.PushSubscriptionRepository

PushSubscription returns a mock push subscription repository for testing

func (*MockRepositoryStorage) Quote 

func (m *MockRepositoryStorage) Quote() *repositories.QuoteRepository

Quote returns a mock quote repository for testing

func (*MockRepositoryStorage) RateLimit 

func (m *MockRepositoryStorage) RateLimit() *repositories.RateLimitRepository

RateLimit returns a mock ratelimit repository for testing

func (*MockRepositoryStorage) Recovery 

func (m *MockRepositoryStorage) Recovery() *repositories.RecoveryRepository

Recovery returns a mock recovery repository for testing

func (*MockRepositoryStorage) Relationship 

func (m *MockRepositoryStorage) Relationship() interfaces.ConcreteRelationshipRepository

Relationship returns a mock relationship repository for testing

func (*MockRepositoryStorage) Relay 

func (m *MockRepositoryStorage) Relay() *repositories.RelayRepository

Relay returns a mock relay repository for testing

func (*MockRepositoryStorage) Revision 

func (m *MockRepositoryStorage) Revision() interfaces.RevisionRepository

Revision returns a mock revision repository for testing

func (*MockRepositoryStorage) ScheduledStatus 

func (m *MockRepositoryStorage) ScheduledStatus() *repositories.ScheduledStatusRepository

ScheduledStatus returns a mock scheduled status repository for testing

func (*MockRepositoryStorage) Search 

func (m *MockRepositoryStorage) Search() *repositories.SearchRepository

Search returns a mock search repository for testing

func (*MockRepositoryStorage) Series 

func (m *MockRepositoryStorage) Series() interfaces.SeriesRepository

Series returns a mock series repository for testing

func (*MockRepositoryStorage) Severance 

func (m *MockRepositoryStorage) Severance() *repositories.SeveranceRepository

Severance returns a mock severance repository for testing

func (*MockRepositoryStorage) Social 

func (m *MockRepositoryStorage) Social() *repositories.SocialRepository

Social returns a mock social repository for testing

func (*MockRepositoryStorage) Status 

func (m *MockRepositoryStorage) Status() interfaces.StatusRepository

Status returns a mock status repository for testing

func (*MockRepositoryStorage) StreamingCloudWatch 

func (m *MockRepositoryStorage) StreamingCloudWatch() *repositories.StreamingCloudWatchRepository

StreamingCloudWatch returns a mock streaming CloudWatch repository for testing

func (*MockRepositoryStorage) StreamingConnection 

func (m *MockRepositoryStorage) StreamingConnection() interfaces.StreamingConnectionRepository

StreamingConnection returns a mock streaming connection repository for testing

func (*MockRepositoryStorage) Thread 

func (m *MockRepositoryStorage) Thread() *repositories.ThreadRepository

Thread returns a mock thread repository for testing

func (*MockRepositoryStorage) Timeline 

func (m *MockRepositoryStorage) Timeline() interfaces.TimelineRepository

Timeline returns a mock timeline repository for testing (interface type for mockability).

func (*MockRepositoryStorage) Trust 

func (m *MockRepositoryStorage) Trust() interfaces.TrustRepository

Trust returns a mock trust repository for testing

func (*MockRepositoryStorage) User 

func (m *MockRepositoryStorage) User() interfaces.UserRepository

User returns a mock user repository for testing

func (*MockRepositoryStorage) WebSocketCost 

func (m *MockRepositoryStorage) WebSocketCost() *repositories.WebSocketCostRepository

WebSocketCost returns a mock websocket cost repository for testing

type NotesService 

type NotesService interface {
	BookmarkNote(ctx context.Context, cmd *notes.BookmarkNoteCommand) (*notes.BookmarkResult, error)
	CountNotesByAuthor(ctx context.Context, authorID string) (int64, error)
	CountReplies(ctx context.Context, statusID string) (int, error)
	CreateNote(ctx context.Context, cmd *notes.CreateNoteCommand) (*notes.NoteResult, error)
	CreateCommunityNote(ctx context.Context, cmd *notes.CreateCommunityNoteCommand) (*notes.CreateCommunityNoteResult, error)
	CreateCommunityNoteVote(ctx context.Context, cmd *notes.CreateCommunityNoteVoteCommand) (*notes.CreateCommunityNoteVoteResult, error)
	DeleteNote(ctx context.Context, cmd *notes.DeleteNoteCommand) error
	GetBookmarks(ctx context.Context, query *notes.GetBookmarksQuery) (*notes.Result, error)
	GetBoostCount(ctx context.Context, statusID string) (int64, error)
	GetCommunityNote(ctx context.Context, query *notes.GetCommunityNoteQuery) (*notes.GetCommunityNoteResult, error)
	GetCommunityNotesByAuthor(ctx context.Context, query *notes.GetCommunityNotesByAuthorQuery) (*notes.GetCommunityNotesByAuthorResult, error)
	GetFavoritedNotes(ctx context.Context, query *notes.ListNotesQuery) (*notes.Result, error)
	GetLikeCount(ctx context.Context, statusID string) (int64, error)
	GetLikers(ctx context.Context, query *notes.GetLikersQuery) (*notes.UsersResult, error)
	GetNote(ctx context.Context, statusID string) (*storagemodels.Status, error)
	GetNoteWithViewer(ctx context.Context, query *notes.GetNoteQuery) (*storagemodels.Status, error)
	GetRebloggers(ctx context.Context, query *notes.GetRebloggersQuery) (*notes.UsersResult, error)
	GetSearchSuggestions(ctx context.Context, query *notes.GetSearchSuggestionsQuery) (*notes.GetSearchSuggestionsResult, error)
	GetUpdateHistory(ctx context.Context, query *notes.GetUpdateHistoryQuery) (*notes.GetUpdateHistoryResult, error)
	GetUserTimeline(ctx context.Context, actorID string, opts interfaces.PaginationOptions) (*notes.GetUserTimelineResult, error)
	GetVisibleCommunityNotes(ctx context.Context, query *notes.GetVisibleCommunityNotesQuery) (*notes.GetVisibleCommunityNotesResult, error)
	HasLiked(ctx context.Context, userID, statusID string) (bool, error)
	HasReblogged(ctx context.Context, userID, statusID string) (bool, error)
	IsBookmarked(ctx context.Context, userID, statusID string) (bool, error)
	LikeNote(ctx context.Context, cmd *notes.LikeNoteCommand) (*notes.LikeResult, error)
	ListNotes(ctx context.Context, query *notes.ListNotesQuery) (*notes.Result, error)
	ReblogNote(ctx context.Context, cmd *notes.ReblogNoteCommand) (*notes.LikeResult, error)
	UnlikeNote(ctx context.Context, cmd *notes.UnlikeNoteCommand) (*notes.LikeResult, error)
	UnbookmarkNote(ctx context.Context, cmd *notes.UnbookmarkNoteCommand) (*notes.BookmarkResult, error)
	UnreblogNote(ctx context.Context, cmd *notes.UnreblogNoteCommand) (*notes.LikeResult, error)
}

NotesService defines the subset of note-related operations used by the Lift API

type NotificationsService 

type NotificationsService interface {
	ClearNotifications(ctx context.Context, cmd *notifications.ClearCommand) (*notifications.ClearResult, error)
	CreateNotification(ctx context.Context, cmd *notifications.CreateNotificationCommand) (*notifications.NotificationResult, error)
	ListNotifications(ctx context.Context, query *notifications.ListNotificationsQuery) (*notifications.NotificationListResult, error)
	MarkAsRead(ctx context.Context, cmd *notifications.MarkAsReadCommand) (*notifications.NotificationResult, error)
}

NotificationsService defines the subset of notification-related operations used by the Lift API

type PaginationParams 

type PaginationParams struct {
	Limit   int
	MaxID   string
	MinID   string
	SinceID string
	Cursor  string
}

PaginationParams represents common pagination parameters

type PublicTimelineParams 

type PublicTimelineParams struct {
	Limit     int
	MaxID     string
	Local     bool
	Remote    bool
	OnlyMedia bool
}

PublicTimelineParams holds parameters for public timeline requests

type RelationshipsService 

type RelationshipsService interface {
	AcceptFollowRequest(ctx context.Context, cmd *relationships.AcceptFollowRequestCommand) (*relationships.RelationshipResult, error)
	AddDomainBlock(ctx context.Context, cmd *relationships.AddDomainBlockCommand) error
	Block(ctx context.Context, cmd *relationships.BlockCommand) (*relationships.RelationshipResult, error)
	CountFollowers(ctx context.Context, username string) (int64, error)
	CountFollowing(ctx context.Context, username string) (int64, error)
	Follow(ctx context.Context, cmd *relationships.FollowCommand) (*relationships.FollowResult, error)
	GetBlockedUsers(ctx context.Context, query *relationships.GetBlockedUsersQuery) (*relationships.BlockedUsersResult, error)
	GetDomainBlocks(ctx context.Context, query *relationships.GetDomainBlocksQuery) (*relationships.DomainBlocksResult, error)
	GetFollowers(ctx context.Context, username string, limit int, cursor string) ([]*storage.Account, string, error)
	GetFollowing(ctx context.Context, username string, limit int, cursor string) ([]*storage.Account, string, error)
	GetMutedUsers(ctx context.Context, query *relationships.GetMutedUsersQuery) (*relationships.MutedUsersResult, error)
	GetPendingFollowRequests(ctx context.Context, query *relationships.GetFollowRequestsQuery) (*relationships.FollowRequestsResult, error)
	GetRelationship(ctx context.Context, requesterID, targetID string) (*relationships.RelationshipData, error)
	GetRelationships(ctx context.Context, query *relationships.GetRelationshipsQuery) (*relationships.Result, error)
	IsMuted(ctx context.Context, muterID, mutedID string) (bool, error)
	Mute(ctx context.Context, cmd *relationships.MuteCommand) (*relationships.RelationshipResult, error)
	RejectFollowRequest(ctx context.Context, cmd *relationships.RejectFollowRequestCommand) (*relationships.RelationshipResult, error)
	RemoveDomainBlock(ctx context.Context, cmd *relationships.RemoveDomainBlockCommand) error
	Unblock(ctx context.Context, cmd *relationships.UnblockCommand) (*relationships.RelationshipResult, error)
	Unfollow(ctx context.Context, cmd *relationships.UnfollowCommand) (*relationships.RelationshipResult, error)
	Unmute(ctx context.Context, cmd *relationships.UnmuteCommand) (*relationships.RelationshipResult, error)
}

RelationshipsService defines the subset of relationship-related operations used by the Lift API

type ScheduledService 

type ScheduledService interface {
	CreateScheduledStatus(ctx context.Context, cmd *scheduled.CreateScheduledStatusCommand) (*scheduled.StatusResult, error)
	DeleteScheduledStatus(ctx context.Context, cmd *scheduled.DeleteScheduledStatusCommand) error
	GetScheduledMediaAttachments(ctx context.Context, scheduledStatusID string) ([]*storagemodels.Media, error)
	GetScheduledStatus(ctx context.Context, query *scheduled.GetScheduledStatusQuery) (*scheduled.StatusResult, error)
	ListScheduledStatuses(ctx context.Context, query *scheduled.ListScheduledStatusesQuery) (*scheduled.StatusListResult, error)
	UpdateScheduledStatus(ctx context.Context, cmd *scheduled.UpdateScheduledStatusCommand) (*scheduled.StatusResult, error)
}

ScheduledService defines the subset of scheduled status operations used by the Lift API

type SearchParams 

type SearchParams struct {
	Query     string
	Type      string
	AccountID string
	Limit     int
}

SearchParams holds search request parameters

type SearchService 

type SearchService interface {
	GetDirectory(ctx context.Context, query *search.DirectoryQuery) (*search.DirectoryResult, error)
	GetSuggestions(ctx context.Context, query *search.SuggestionsQuery) (*search.SuggestionsResult, error)
	RemoveSuggestion(ctx context.Context, cmd *search.RemoveSuggestionCommand) error
}

SearchService defines the subset of search-related operations used by the Lift API

type ServiceRegistry 

type ServiceRegistry interface {
	Accounts() AccountsService
	AI() AIService
	Conversations() ConversationsService
	Emoji() EmojiService
	Lists() ListsService
	Media() MediaService
	Notes() NotesService
	Notifications() NotificationsService
	Relationships() RelationshipsService
	Scheduled() ScheduledService
	Search() SearchService
}

ServiceRegistry is a thin abstraction over pkg/services.Registry to make cmd/api/handlers unit-testable without requiring DynamoDB/AWS/network side-effects.

type TagInfo 

type TagInfo struct {
	ID            string   `json:"id"`
	Name          string   `json:"name"`
	URL           string   `json:"url"`
	Following     bool     `json:"following"`
	History       []TagUse `json:"history"`
	TotalUses     int      `json:"total_uses"`
	TotalAccounts int      `json:"total_accounts"`
}

TagInfo represents detailed information about a hashtag

type TagTimelineParams 

type TagTimelineParams struct {
	Hashtag   string
	Limit     int
	MaxID     string
	Local     bool
	OnlyMedia bool
}

TagTimelineParams holds parameters for hashtag timeline requests

type TagTimelineUser 

type TagTimelineUser struct {
	Actor    *activitypub.Actor
	Username string
}

TagTimelineUser holds authenticated user information

type TagUse 

type TagUse struct {
	Day      string `json:"day"`
	Uses     string `json:"uses"`
	Accounts string `json:"accounts"`
}

TagUse represents hashtag usage statistics for a day

type TranslationLanguage 

type TranslationLanguage struct {
	Code string `json:"code"`
	Name string `json:"name"`
}

TranslationLanguage represents a supported translation language

type TranslationResult 

type TranslationResult struct {
	Content          string `json:"content"`
	SpoilerText      string `json:"spoiler_text,omitempty"`
	DetectedLanguage string `json:"detected_source_language"`
	Provider         string `json:"provider"`
}

TranslationResult represents the result of translating a status

type UpdateCredentialsFileData 

type UpdateCredentialsFileData struct {
	AvatarData        []byte
	AvatarContentType string
	HeaderData        []byte
	HeaderContentType string
}

UpdateCredentialsFileData holds file upload data from multipart form 

type WebFingerLink struct {
	Rel        string            `json:"rel"`
	Type       string            `json:"type,omitempty"`
	Href       string            `json:"href,omitempty"`
	Template   string            `json:"template,omitempty"`
	Titles     map[string]string `json:"titles,omitempty"`
	Properties map[string]any    `json:"properties,omitempty"`
}

WebFingerLink represents a link in a WebFinger response

type WebFingerResponse 

type WebFingerResponse struct {
	Subject string          `json:"subject"`
	Aliases []string        `json:"aliases,omitempty"`
	Links   []WebFingerLink `json:"links"`
	Props   map[string]any  `json:"properties,omitempty"`
}

WebFingerResponse represents a WebFinger response

type WebSocketCostAnalyticsRequest 

type WebSocketCostAnalyticsRequest struct {
	StartDate string `json:"start_date" validate:"required"`
	EndDate   string `json:"end_date" validate:"required"`
	Period    string `json:"period" validate:"oneof=hour day week month"`
	UserID    string `json:"user_id,omitempty"`
	Limit     int    `json:"limit,omitempty"`
}

WebSocketCostAnalyticsRequest represents requests for WebSocket cost analytics

type WebSocketCostDataPoint 

type WebSocketCostDataPoint struct {
	Timestamp        time.Time `json:"timestamp"`
	CostDollars      float64   `json:"cost_dollars"`
	Connections      int64     `json:"connections"`
	Messages         int64     `json:"messages"`
	UniqueUsers      int64     `json:"unique_users"`
	AverageLatencyMs float64   `json:"average_latency_ms"`
}

WebSocketCostDataPoint represents a single data point in cost trends

type WebSocketCostOperationSummary 

type WebSocketCostOperationSummary struct {
	OperationType    string    `json:"operation_type"`
	ConnectionID     string    `json:"connection_id"`
	UserID           string    `json:"user_id"`
	Username         string    `json:"username"`
	CostDollars      float64   `json:"cost_dollars"`
	ProcessingTimeMs int64     `json:"processing_time_ms"`
	MessageCount     int       `json:"message_count"`
	Timestamp        time.Time `json:"timestamp"`
}

WebSocketCostOperationSummary represents summary for high-cost operations

type WebSocketCostSummaryResponse 

type WebSocketCostSummaryResponse struct {
	Summary            *WebSocketOverallSummary                 `json:"summary"`
	TopUsers           []*repositories.WebSocketUserCostRanking `json:"top_users"`
	HighCostOperations []*WebSocketCostOperationSummary         `json:"high_cost_operations"`
	CostTrends         *WebSocketCostTrends                     `json:"cost_trends"`
	UserDetails        *repositories.WebSocketUserCostSummary   `json:"user_details,omitempty"`
	BudgetStatus       *repositories.BudgetStatus               `json:"budget_status,omitempty"`
}

WebSocketCostSummaryResponse represents WebSocket cost summary response

type WebSocketCostTrends 

type WebSocketCostTrends struct {
	Period        string                   `json:"period"`
	DataPoints    []WebSocketCostDataPoint `json:"data_points"`
	TrendAnalysis *WebSocketTrendAnalysis  `json:"trend_analysis"`
}

WebSocketCostTrends represents cost trends over time

type WebSocketOverallSummary 

type WebSocketOverallSummary struct {
	DateRange                string  `json:"date_range"`
	TotalCostDollars         float64 `json:"total_cost_dollars"`
	TotalConnections         int64   `json:"total_connections"`
	TotalMessages            int64   `json:"total_messages"`
	TotalConnectionHours     float64 `json:"total_connection_hours"`
	UniqueUsers              int64   `json:"unique_users"`
	AverageCostPerUser       float64 `json:"average_cost_per_user"`
	AverageCostPerConnection float64 `json:"average_cost_per_connection"`
	AverageCostPerMessage    float64 `json:"average_cost_per_message"`

	// Cost breakdown
	ConnectionCostPercent float64 `json:"connection_cost_percent"`
	MessageCostPercent    float64 `json:"message_cost_percent"`
	LambdaCostPercent     float64 `json:"lambda_cost_percent"`
	DynamoDBCostPercent   float64 `json:"dynamodb_cost_percent"`

	// Efficiency metrics
	MessagesPerConnection     float64 `json:"messages_per_connection"`
	AverageConnectionDuration float64 `json:"average_connection_duration"`
}

WebSocketOverallSummary represents overall WebSocket cost summary

type WebSocketTrendAnalysis 

type WebSocketTrendAnalysis struct {
	TrendDirection  string   `json:"trend_direction"` // increasing, decreasing, stable
	TrendPercentage float64  `json:"trend_percentage"`
	PeakHour        string   `json:"peak_hour,omitempty"`
	LowHour         string   `json:"low_hour,omitempty"`
	WeeklyPattern   string   `json:"weekly_pattern,omitempty"`
	GrowthRate      float64  `json:"growth_rate"`
	SeasonalFactors []string `json:"seasonal_factors,omitempty"`
}

WebSocketTrendAnalysis represents analysis of cost trends

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.