activitypub

Documentation

Index

• Variables
• func GetInboxURL(actorURI string) (string, error)
• func Subscribe(consumer *Consumer, handler *Handler, logger *log.Logger) error
• type Consumer
  • func NewConsumer(log *log.Logger, pubsub *te.Client, handler *Handler) *Consumer
• type Handler
  • func ProvideHandler(config config.Config, store *store.Store[repository.ActivityHubRepository]) *Handler
  • func (h *Handler) CreateAccount(ctx context.Context, username string, name string, summary string) (acc models.Account, err error)
  • func (h *Handler) GetActor(ctx context.Context, actor string) (acc models.Account, err error)
  • func (h *Handler) GetFollowers(ctx context.Context, actorname string) (follower []models.Follower, err error)
  • func (h *Handler) ReceiveInboxActivity(ctx context.Context, activity externalmodel.Activity) error
  • func (h *Handler) SendPost(ctx context.Context, sendingActorID string, sendToURI string, content string) error
  • func (h *Handler) SendPostToFollowers(ctx context.Context, sendingActorID string, content string) error

Variables

var (
	ErrActorNotFound = errutil.NewError(errutil.TypeNotFound, "actor not found")
)

define errors

var (
	ErrUnsupportedActivityType = errutil.NewError(errutil.TypeBadRequest, "unsupported activity type")
)

var Module = fx.Options(
	repository.Module,
	fx.Provide(ProvideHandler),
	fx.Provide(NewConsumer),
	fx.Invoke(Subscribe),
)

Functions

func GetInboxURL

func GetInboxURL(actorURI string) (string, error)

func Subscribe

func Subscribe(consumer *Consumer, handler *Handler, logger *log.Logger) error

Types

type Consumer

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

func NewConsumer

func NewConsumer(log *log.Logger, pubsub *te.Client, handler *Handler) *Consumer

type Handler

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

func ProvideHandler

func ProvideHandler(config config.Config, store *store.Store[repository.ActivityHubRepository]) *Handler

func (*Handler) CreateAccount

func (h *Handler) CreateAccount(ctx context.Context, username string, name string, summary string) (acc models.Account, err error)

func (*Handler) GetActor

func (h *Handler) GetActor(ctx context.Context, actor string) (acc models.Account, err error)

func (*Handler) GetFollowers

func (h *Handler) GetFollowers(ctx context.Context, actorname string) (follower []models.Follower, err error)

func (*Handler) ReceiveInboxActivity

func (h *Handler) ReceiveInboxActivity(ctx context.Context, activity externalmodel.Activity) error

func (*Handler) SendPost

func (h *Handler) SendPost(ctx context.Context, sendingActorID string, sendToURI string, content string) error

func (*Handler) SendPostToFollowers

func (h *Handler) SendPostToFollowers(ctx context.Context, sendingActorID string, content string) error