svc_impls

Documentation

Index

• Variables
• type FederationServiceImpl
  • func NewFederationServiceImpl(httpClient *http.Client, telemetry *unitel.Telemetry, log logr.Logger) *FederationServiceImpl
  • func (i *FederationServiceImpl) DiscoverInstance(ctx context.Context, baseURL string) (*versia.InstanceMetadata, error)
  • func (i *FederationServiceImpl) DiscoverUser(ctx context.Context, baseURL, username string) (*webfinger.User, error)
  • func (i *FederationServiceImpl) GetUser(ctx context.Context, uri *versiautils.URL) (*versia.User, error)
  • func (i *FederationServiceImpl) SendToInbox(ctx context.Context, author *entity.User, user *entity.User, object any) ([]byte, error)
• type FollowServiceImpl
  • func NewFollowServiceImpl(federationService service.FederationService, repositories repository.Manager, ...) *FollowServiceImpl
  • func (i FollowServiceImpl) GetFollow(ctx context.Context, id uuid.UUID) (*entity.Follow, error)
  • func (i FollowServiceImpl) ImportVersiaFollow(ctx context.Context, lFollow *versia.Follow) (*entity.Follow, error)
  • func (i FollowServiceImpl) NewFollow(ctx context.Context, follower, followee *entity.User) (*entity.Follow, error)
• type InboxServiceImpl
  • func NewInboxService(federationService service.FederationService, repositories repository.Manager, ...) *InboxServiceImpl
  • func (i InboxServiceImpl) Handle(ctx context.Context, obj any, userId uuid.UUID) error
  • func (i InboxServiceImpl) WithRepositories(repositories repository.Manager) service.InboxService
• type InstanceMetadataServiceImpl
  • func NewInstanceMetadataServiceImpl(federationService service.FederationService, repositories repository.Manager, ...) *InstanceMetadataServiceImpl
  • func (i InstanceMetadataServiceImpl) Ours(ctx context.Context) (*entity.InstanceMetadata, error)
• type NoteServiceImpl
  • func NewNoteServiceImpl(federationService service.FederationService, taskService service.TaskService, ...) *NoteServiceImpl
  • func (i NoteServiceImpl) CreateNote(ctx context.Context, req api_schema.CreateNoteRequest) (*entity.Note, error)
  • func (i NoteServiceImpl) GetNote(ctx context.Context, id uuid.UUID) (*entity.Note, error)
  • func (i NoteServiceImpl) ImportVersiaNote(ctx context.Context, lNote *versia.Note) (*entity.Note, error)
• type RequestSignerImpl
  • func NewRequestSignerImpl(telemetry *unitel.Telemetry, log logr.Logger) *RequestSignerImpl
  • func (i *RequestSignerImpl) SignAndSend(c *fiber.Ctx, signer versiacrypto.Signer, body any) error
• type ResponseError
  • func (e *ResponseError) Error() string
• type TaskServiceImpl
  • func NewTaskServiceImpl(client *taskqueue.Client, telemetry *unitel.Telemetry, log logr.Logger) *TaskServiceImpl
  • func (i TaskServiceImpl) ScheduleTask(ctx context.Context, type_ string, data any) error
• type UserServiceImpl
  • func NewUserServiceImpl(repositories repository.Manager, federationService service.FederationService, ...) *UserServiceImpl
  • func (i UserServiceImpl) GetLocalUserByID(ctx context.Context, id uuid.UUID) (*entity.User, error)
  • func (i UserServiceImpl) GetWebfingerForUser(ctx context.Context, userID string) (*webfinger.User, error)
  • func (i UserServiceImpl) NewUser(ctx context.Context, username, password string) (*entity.User, error)
  • func (i UserServiceImpl) Search(ctx context.Context, req api_schema.SearchUserRequest) (u *entity.User, err error)
  • func (i UserServiceImpl) WithRepositories(repositories repository.Manager) service.UserService

Variables

var (
	ErrSignatureValidationFailed = errors.New("signature validation failed")
)

Types

type FederationServiceImpl

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

func NewFederationServiceImpl

func NewFederationServiceImpl(httpClient *http.Client, telemetry *unitel.Telemetry, log logr.Logger) *FederationServiceImpl

func (*FederationServiceImpl) DiscoverInstance

func (i *FederationServiceImpl) DiscoverInstance(ctx context.Context, baseURL string) (*versia.InstanceMetadata, error)

func (*FederationServiceImpl) DiscoverUser

func (i *FederationServiceImpl) DiscoverUser(ctx context.Context, baseURL, username string) (*webfinger.User, error)

func (*FederationServiceImpl) GetUser

func (i *FederationServiceImpl) GetUser(ctx context.Context, uri *versiautils.URL) (*versia.User, error)

func (*FederationServiceImpl) SendToInbox

func (i *FederationServiceImpl) SendToInbox(ctx context.Context, author *entity.User, user *entity.User, object any) ([]byte, error)

type FollowServiceImpl

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

func NewFollowServiceImpl

func NewFollowServiceImpl(federationService service.FederationService, repositories repository.Manager, telemetry *unitel.Telemetry, log logr.Logger) *FollowServiceImpl

func (FollowServiceImpl) GetFollow

func (i FollowServiceImpl) GetFollow(ctx context.Context, id uuid.UUID) (*entity.Follow, error)

func (FollowServiceImpl) ImportVersiaFollow

func (i FollowServiceImpl) ImportVersiaFollow(ctx context.Context, lFollow *versia.Follow) (*entity.Follow, error)

func (FollowServiceImpl) NewFollow

func (i FollowServiceImpl) NewFollow(ctx context.Context, follower, followee *entity.User) (*entity.Follow, error)

type InboxServiceImpl

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

func NewInboxService

func NewInboxService(federationService service.FederationService, repositories repository.Manager, telemetry *unitel.Telemetry, log logr.Logger) *InboxServiceImpl

func (InboxServiceImpl) Handle

func (i InboxServiceImpl) Handle(ctx context.Context, obj any, userId uuid.UUID) error

func (InboxServiceImpl) WithRepositories

func (i InboxServiceImpl) WithRepositories(repositories repository.Manager) service.InboxService

type InstanceMetadataServiceImpl

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

func NewInstanceMetadataServiceImpl

func NewInstanceMetadataServiceImpl(federationService service.FederationService, repositories repository.Manager, telemetry *unitel.Telemetry, log logr.Logger) *InstanceMetadataServiceImpl

func (InstanceMetadataServiceImpl) Ours

func (i InstanceMetadataServiceImpl) Ours(ctx context.Context) (*entity.InstanceMetadata, error)

type NoteServiceImpl

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

func NewNoteServiceImpl

func NewNoteServiceImpl(federationService service.FederationService, taskService service.TaskService, repositories repository.Manager, telemetry *unitel.Telemetry, log logr.Logger) *NoteServiceImpl

func (NoteServiceImpl) CreateNote

func (i NoteServiceImpl) CreateNote(ctx context.Context, req api_schema.CreateNoteRequest) (*entity.Note, error)

func (NoteServiceImpl) GetNote

func (i NoteServiceImpl) GetNote(ctx context.Context, id uuid.UUID) (*entity.Note, error)

func (NoteServiceImpl) ImportVersiaNote

func (i NoteServiceImpl) ImportVersiaNote(ctx context.Context, lNote *versia.Note) (*entity.Note, error)

type RequestSignerImpl

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

func NewRequestSignerImpl

func NewRequestSignerImpl(telemetry *unitel.Telemetry, log logr.Logger) *RequestSignerImpl

func (*RequestSignerImpl) SignAndSend

func (i *RequestSignerImpl) SignAndSend(c *fiber.Ctx, signer versiacrypto.Signer, body any) error

type ResponseError

type ResponseError struct {
	StatusCode int
	URL        *url.URL
}

func (*ResponseError) Error

func (e *ResponseError) Error() string

type TaskServiceImpl

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

func NewTaskServiceImpl

func NewTaskServiceImpl(client *taskqueue.Client, telemetry *unitel.Telemetry, log logr.Logger) *TaskServiceImpl

func (TaskServiceImpl) ScheduleTask

func (i TaskServiceImpl) ScheduleTask(ctx context.Context, type_ string, data any) error

type UserServiceImpl

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

func NewUserServiceImpl

func NewUserServiceImpl(repositories repository.Manager, federationService service.FederationService, telemetry *unitel.Telemetry, log logr.Logger) *UserServiceImpl

func (UserServiceImpl) GetLocalUserByID

func (i UserServiceImpl) GetLocalUserByID(ctx context.Context, id uuid.UUID) (*entity.User, error)

func (UserServiceImpl) GetWebfingerForUser

func (i UserServiceImpl) GetWebfingerForUser(ctx context.Context, userID string) (*webfinger.User, error)

func (UserServiceImpl) NewUser

func (i UserServiceImpl) NewUser(ctx context.Context, username, password string) (*entity.User, error)

func (UserServiceImpl) Search

func (i UserServiceImpl) Search(ctx context.Context, req api_schema.SearchUserRequest) (u *entity.User, err error)

func (UserServiceImpl) WithRepositories

func (i UserServiceImpl) WithRepositories(repositories repository.Manager) service.UserService