services

Documentation

Index

• type ActorService
  • func NewActorService(config *instance.FederationConfig, actorRep *models.ActorRepository, ...) *ActorService
  • func (a *ActorService) CreateActorFromRemoteAccount(ctx context.Context, accountIri string, localInstanceActor *models.Actor) (*models.Actor, error)
  • func (a *ActorService) GetLocalInstanceActor(ctx context.Context) (*models.Actor, error)
• type InstanceService
  • func NewInstanceService(config *instance.FederationConfig, instanceRepo *models.InstanceRepository) *InstanceService
• type StreamService
• type VideoService
  • func NewVideoService(config *instance.FederationConfig, actorService *ActorService, ...) *VideoService
  • func (s *VideoService) AddVideo(ctx context.Context, announceObject vocab.ActivityStreamsObjectProperty, ...) error
  • func (s *VideoService) DeleteVideo(ctx context.Context, deleteObject vocab.ActivityStreamsObjectProperty) error
  • func (s *VideoService) UpsertVideo(ctx context.Context, updateObject vocab.ActivityStreamsObjectProperty) error

Types

type ActorService

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

func NewActorService

func NewActorService(config *instance.FederationConfig, actorRep *models.ActorRepository, sender *outbox.Sender) *ActorService

func (*ActorService) CreateActorFromRemoteAccount

func (a *ActorService) CreateActorFromRemoteAccount(ctx context.Context, accountIri string, localInstanceActor *models.Actor) (*models.Actor, error)

func (*ActorService) GetLocalInstanceActor

func (a *ActorService) GetLocalInstanceActor(ctx context.Context) (*models.Actor, error)

type InstanceService

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

func NewInstanceService

func NewInstanceService(config *instance.FederationConfig, instanceRepo *models.InstanceRepository) *InstanceService

type StreamService

type StreamService interface {
	CreateStreamAccessByVideo(ctx context.Context, video *models.Video) error
	UpdateStreamAccessByVideo(ctx context.Context, video *models.Video) error
	DeleteStreamAccessByVideo(ctx context.Context, iri string) error
}

type VideoService

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

func NewVideoService

func NewVideoService(config *instance.FederationConfig, actorService *ActorService, videoRep *models.VideoRepository, streamService StreamService, instanceService *InstanceService) *VideoService

func (*VideoService) AddVideo

func (s *VideoService) AddVideo(ctx context.Context, announceObject vocab.ActivityStreamsObjectProperty, toFollowerIris []*url.URL) error

func (*VideoService) DeleteVideo

func (s *VideoService) DeleteVideo(ctx context.Context, deleteObject vocab.ActivityStreamsObjectProperty) error

func (*VideoService) UpsertVideo

func (s *VideoService) UpsertVideo(ctx context.Context, updateObject vocab.ActivityStreamsObjectProperty) error