processing

Documentation

Index

• func GetParseMentionFunc(state *state.State, federator *federation.Federator) gtsmodel.ParseMentionFunc
• type Processor
  • func NewProcessor(cleaner *cleaner.Cleaner, subscriptions *subscriptions.Subscriptions, ...) *Processor
  • func (p *Processor) Account() *account.Processor
  • func (p *Processor) Admin() *admin.Processor
  • func (p *Processor) AdvancedMigrations() *advancedmigrations.Processor
  • func (p *Processor) Application() *application.Processor
  • func (p *Processor) Conversations() *conversations.Processor
  • func (p *Processor) Fedi() *fedi.Processor
  • func (p *Processor) FiltersV1() *filtersv1.Processor
  • func (p *Processor) FiltersV2() *filtersv2.Processor
  • func (p *Processor) InstanceGetRules(ctx context.Context) ([]apimodel.InstanceRule, gtserror.WithCode)
  • func (p *Processor) InstanceGetV1(ctx context.Context) (*apimodel.InstanceV1, gtserror.WithCode)
  • func (p *Processor) InstanceGetV2(ctx context.Context) (*apimodel.InstanceV2, gtserror.WithCode)
  • func (p *Processor) InstancePatch(ctx context.Context, form *apimodel.InstanceSettingsUpdateRequest) (*apimodel.InstanceV1, gtserror.WithCode)
  • func (p *Processor) InstancePeersGet(ctx context.Context, includeSuspended bool, includeOpen bool, flat bool) (interface{}, gtserror.WithCode)
  • func (p *Processor) InteractionRequests() *interactionrequests.Processor
  • func (p *Processor) List() *list.Processor
  • func (p *Processor) Markers() *markers.Processor
  • func (p *Processor) Media() *media.Processor
  • func (p *Processor) OAuthHandleAuthorizeRequest(w http.ResponseWriter, r *http.Request) gtserror.WithCode
  • func (p *Processor) OAuthHandleTokenRequest(r *http.Request) (map[string]interface{}, gtserror.WithCode)
  • func (p *Processor) OAuthRevokeAccessToken(ctx context.Context, clientID string, clientSecret string, accessToken string) gtserror.WithCode
  • func (p *Processor) OAuthValidateBearerToken(r *http.Request) (oauth2.TokenInfo, error)
  • func (p *Processor) Polls() *polls.Processor
  • func (p *Processor) PreferencesGet(ctx context.Context, accountID string) (*apimodel.Preferences, gtserror.WithCode)
  • func (p *Processor) Push() *push.Processor
  • func (p *Processor) Report() *report.Processor
  • func (p *Processor) Search() *search.Processor
  • func (p *Processor) Status() *status.Processor
  • func (p *Processor) Stream() *stream.Processor
  • func (p *Processor) Tags() *tags.Processor
  • func (p *Processor) Timeline() *timeline.Processor
  • func (p *Processor) User() *user.Processor
  • func (p *Processor) Workers() *workers.Processor

Functions

func GetParseMentionFunc

func GetParseMentionFunc(state *state.State, federator *federation.Federator) gtsmodel.ParseMentionFunc

GetParseMentionFunc returns a new ParseMentionFunc using the provided state and federator. State is used for doing local database lookups; federator is used for remote account lookups (if necessary).

Types

type Processor

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

Processor groups together processing functions and sub processors for handling actions + events coming from either the client or federating APIs.

Many of the functions available through this struct or sub processors will trigger asynchronous processing via the workers contained in state.

func NewProcessor

func NewProcessor(
	cleaner *cleaner.Cleaner,
	subscriptions *subscriptions.Subscriptions,
	converter *typeutils.Converter,
	federator *federation.Federator,
	oauthServer oauth.Server,
	mediaManager *mm.Manager,
	state *state.State,
	emailSender email.Sender,
	webPushSender webpush.Sender,
	visFilter *visibility.Filter,
	intFilter *interaction.Filter,
) *Processor

NewProcessor returns a new Processor.

func (*Processor) Account

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

func (*Processor) Admin

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

func (*Processor) AdvancedMigrations

func (p *Processor) AdvancedMigrations() *advancedmigrations.Processor

func (*Processor) Application

func (p *Processor) Application() *application.Processor

func (*Processor) Conversations

func (p *Processor) Conversations() *conversations.Processor

func (*Processor) Fedi

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

func (*Processor) FiltersV1

func (p *Processor) FiltersV1() *filtersv1.Processor

func (*Processor) FiltersV2

func (p *Processor) FiltersV2() *filtersv2.Processor

func (*Processor) InstanceGetRules

func (p *Processor) InstanceGetRules(ctx context.Context) ([]apimodel.InstanceRule, gtserror.WithCode)

func (*Processor) InstanceGetV1

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

func (*Processor) InstanceGetV2

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

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

func (*Processor) InteractionRequests

func (p *Processor) InteractionRequests() *interactionrequests.Processor

func (*Processor) List

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

func (*Processor) Markers

func (p *Processor) Markers() *markers.Processor

func (*Processor) Media

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

func (*Processor) OAuthHandleAuthorizeRequest

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

func (*Processor) OAuthHandleTokenRequest

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

func (*Processor) OAuthRevokeAccessToken

func (p *Processor) OAuthRevokeAccessToken(
	ctx context.Context,
	clientID string,
	clientSecret string,
	accessToken string,
) gtserror.WithCode

func (*Processor) OAuthValidateBearerToken

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

func (*Processor) Polls

func (p *Processor) Polls() *polls.Processor

func (*Processor) PreferencesGet

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

func (*Processor) Push

func (p *Processor) Push() *push.Processor

func (*Processor) Report

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

func (*Processor) Search

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

func (*Processor) Status

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

func (*Processor) Stream

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

func (*Processor) Tags

func (p *Processor) Tags() *tags.Processor

func (*Processor) Timeline

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

func (*Processor) User

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

func (*Processor) Workers

func (p *Processor) Workers() *workers.Processor