inbox

Documentation

Index

• func AddToQueue(req InboxRequest)
• func InitInboxWorkerPool(followRep *models.FollowRepository, videoService *services.VideoService, ...)
• func Verify(request *http.Request, resolver *remote.Resolver, forceHttps bool) (bool, error)
• type InboxRequest
• type Job

Functions

func AddToQueue

func AddToQueue(req InboxRequest)

AddToQueue will queue up an outbound http request.

func InitInboxWorkerPool

func InitInboxWorkerPool(
	followRep *models.FollowRepository,
	videoService *services.VideoService,
	resolver *remote.Resolver,
)

InitInboxWorkerPool starts n go routines that await ActivityPub jobs.

func Verify

func Verify(request *http.Request, resolver *remote.Resolver, forceHttps bool) (bool, error)

Verify will Verify the http signature of an inbound request as well as check it against the list of blocked domains. nolint: cyclop

Types

type InboxRequest

type InboxRequest struct {
	Request         *http.Request
	ForLocalAccount string
	Body            []byte
}

InboxRequest represents an inbound request to the ActivityPub inbox.

type Job

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

Job struct bundling the ActivityPub and the payload in one struct.