async

func ListenGeneral ¶

func ListenGeneral(
	parentCtx context.Context,
	db *ent.Client,
	youTubeConfig *oauth2.Config,
	subscription *pubsub.Subscription,
	botTopic *pubsub.Topic,
	setChangeReason func(string),
) error

ListenGeneral polls a pubsub subscription for GeneralType messages.

func NewPubSubMembershipChangeHandler ¶

func NewPubSubMembershipChangeHandler(ctx context.Context, topic *pubsub.Topic) membership.ChangeHandler

func ProcessUserDelete ¶

func ProcessUserDelete(ctx context.Context, db *ent.Client, topic *pubsub.Topic, userID uint64, reason string) error

ProcessUserDelete revokes tokens and tells the bot to delete the user. The bot has to delete the user because it'll communicate the final role removals + user deletion, and at that point why have the async queue require another message?

func ProcessYouTubeDelete ¶

func ProcessYouTubeDelete(ctx context.Context, db *ent.Client, topic *pubsub.Topic, userID uint64) error

ProcessUserDelete revokes tokens and deletes all membership edges.

func ProcessYouTubeRegistration ¶

func ProcessYouTubeRegistration(ctx context.Context, db *ent.Client, youTubeConfig *oauth2.Config, userID uint64, setChangeReason func(string)) error

ProcessYouTubeRegistration really only checks memberships and triggers changes. One day it might do something else?

func PublishApplyMembershipMessage ¶

func PublishApplyMembershipMessage(ctx context.Context, topic *pubsub.Topic, message ApplyMembershipPSMessage) error

func PublishGeneralMessage ¶

func PublishGeneralMessage(ctx context.Context, topic *pubsub.Topic, message GeneralPSMessage) error