processors

Documentation

Index

• Constants
• func NewFSM(db model.RCSServerDatabase) *fsm.StateMachine
• type EventProcessor
  • func NewEventProcessor(cfg *config.Dendrite, idg *uid.UidGenerator, db model.RCSServerDatabase) *EventProcessor
  • func (p *EventProcessor) HandleCreate(ctx context.Context, ev *gomatrixserverlib.Event) ([]gomatrixserverlib.Event, error)
  • func (p *EventProcessor) HandleMembership(ctx context.Context, ev *gomatrixserverlib.Event) ([]gomatrixserverlib.Event, error)
• type RCSDelegate
  • func (d *RCSDelegate) HandleEvent(action, fromState, toState string, args []interface{}) error

Constants

const (
	ST_INIT   = "init"
	ST_INVITE = "invite"
	ST_JOIN   = "join"
	ST_LEAVE  = "leave"
)

const (
	OP_JOIN   = "join"
	OP_INVITE = "invite"
	OP_LEAVE  = "leave"
)

const (
	ACT_DEFAULT = "update database"
	ACT_IGNORE  = "ignore"
	ACT_JOIN    = "join"
	ACT_INVITE  = "invite"
)

Functions

func NewFSM

func NewFSM(db model.RCSServerDatabase) *fsm.StateMachine

Types

type EventProcessor

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

func NewEventProcessor

func NewEventProcessor(cfg *config.Dendrite, idg *uid.UidGenerator, db model.RCSServerDatabase) *EventProcessor

func (*EventProcessor) HandleCreate

func (p *EventProcessor) HandleCreate(
	ctx context.Context, ev *gomatrixserverlib.Event,
) ([]gomatrixserverlib.Event, error)

func (*EventProcessor) HandleMembership

func (p *EventProcessor) HandleMembership(
	ctx context.Context, ev *gomatrixserverlib.Event,
) ([]gomatrixserverlib.Event, error)

type RCSDelegate

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

func (*RCSDelegate) HandleEvent

func (d *RCSDelegate) HandleEvent(action, fromState, toState string, args []interface{}) error