processing

package
v0.10.0-rc3 Latest Latest
Warning

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

 Go to latest Published: Jul 18, 2023 License: AGPL-3.0 Imports: 45 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetParseMentionFunc added in v0.2.2 

func GetParseMentionFunc(dbConn db.DB, federator federation.Federator) gtsmodel.ParseMentionFunc

Types

type Processor 

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

func NewProcessor 

func NewProcessor(
	tc typeutils.TypeConverter,
	federator federation.Federator,
	oauthServer oauth.Server,
	mediaManager *mm.Manager,
	state *state.State,
	emailSender email.Sender,
) *Processor

NewProcessor returns a new Processor.

func (*Processor) Account added in v0.8.0 

func (p *Processor) Account() *account.Processor

func (*Processor) Admin added in v0.8.0 

func (p *Processor) Admin() *admin.Processor

func (*Processor) AppCreate 

func (p *Processor) AppCreate(ctx context.Context, authed *oauth.Auth, form *apimodel.ApplicationCreateRequest) (*apimodel.Application, gtserror.WithCode)

func (*Processor) BlocksGet 

func (p *Processor) BlocksGet(ctx context.Context, authed *oauth.Auth, maxID string, sinceID string, limit int) (*apimodel.BlocksResponse, gtserror.WithCode)

func (*Processor) EnqueueClientAPI added in v0.8.0 

func (p *Processor) EnqueueClientAPI(ctx context.Context, msgs ...messages.FromClientAPI)

func (*Processor) EnqueueFederator added in v0.8.0 

func (p *Processor) EnqueueFederator(ctx context.Context, msgs ...messages.FromFederator)

func (*Processor) Fedi added in v0.8.0 

func (p *Processor) Fedi() *fedi.Processor

func (*Processor) FollowRequestAccept 

func (p *Processor) FollowRequestAccept(ctx context.Context, auth *oauth.Auth, accountID string) (*apimodel.Relationship, gtserror.WithCode)

func (*Processor) FollowRequestReject 

func (p *Processor) FollowRequestReject(ctx context.Context, auth *oauth.Auth, accountID string) (*apimodel.Relationship, gtserror.WithCode)

func (*Processor) FollowRequestsGet 

func (p *Processor) FollowRequestsGet(ctx context.Context, auth *oauth.Auth) ([]apimodel.Account, gtserror.WithCode)

func (*Processor) InstanceGetV1 added in v0.7.0 

func (p *Processor) InstanceGetV1(ctx context.Context) (*apimodel.InstanceV1, gtserror.WithCode)

func (*Processor) InstanceGetV2 added in v0.7.0 

func (p *Processor) InstanceGetV2(ctx context.Context) (*apimodel.InstanceV2, gtserror.WithCode)

func (*Processor) InstancePatch 

func (p *Processor) InstancePatch(ctx context.Context, form *apimodel.InstanceSettingsUpdateRequest) (*apimodel.InstanceV1, gtserror.WithCode)

func (*Processor) InstancePeersGet added in v0.3.7 

func (p *Processor) InstancePeersGet(ctx context.Context, includeSuspended bool, includeOpen bool, flat bool) (interface{}, gtserror.WithCode)

func (*Processor) List added in v0.10.0 

func (p *Processor) List() *list.Processor

func (*Processor) Media added in v0.8.0 

func (p *Processor) Media() *media.Processor

func (*Processor) OAuthHandleAuthorizeRequest added in v0.3.5 

func (p *Processor) OAuthHandleAuthorizeRequest(w http.ResponseWriter, r *http.Request) gtserror.WithCode

func (*Processor) OAuthHandleTokenRequest added in v0.3.5 

func (p *Processor) OAuthHandleTokenRequest(r *http.Request) (map[string]interface{}, gtserror.WithCode)

func (*Processor) OAuthValidateBearerToken added in v0.7.0 

func (p *Processor) OAuthValidateBearerToken(r *http.Request) (oauth2.TokenInfo, error)

func (*Processor) PreferencesGet added in v0.9.0 

func (p *Processor) PreferencesGet(ctx context.Context, accountID string) (*apimodel.Preferences, gtserror.WithCode)

func (*Processor) ProcessFromClientAPI 

func (p *Processor) ProcessFromClientAPI(ctx context.Context, clientMsg messages.FromClientAPI) error

func (*Processor) ProcessFromFederator 

func (p *Processor) ProcessFromFederator(ctx context.Context, federatorMsg messages.FromFederator) error

ProcessFromFederator reads the APActivityType and APObjectType of an incoming message from the federator, and directs the message into the appropriate side effect handler function, or simply does nothing if there's no handler function defined for the combination of Activity and Object.

func (*Processor) Report added in v0.8.0 

func (p *Processor) Report() *report.Processor

func (*Processor) Search added in v0.10.0 

func (p *Processor) Search() *search.Processor

func (*Processor) Status added in v0.8.0 

func (p *Processor) Status() *status.Processor

func (*Processor) Stream added in v0.8.0 

func (p *Processor) Stream() *stream.Processor

func (*Processor) Timeline added in v0.10.0 

func (p *Processor) Timeline() *timeline.Processor

func (*Processor) User added in v0.8.0 

func (p *Processor) User() *user.Processor

Source Files

View all Source files

Directories

Path Synopsis

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.