service

Documentation

Index

• type ActionExecutor
  • func NewActionExecutor(fbClient *fbmsg.Client) *ActionExecutor
  • func (ex *ActionExecutor) ExecuteAction(ctx context.Context, node *types.Node, state *ActionState) (_err error)
  • func (ex *ActionExecutor) ExecuteActions(nodes []*types.Node, state *ActionState)
• type ActionState
• type MessengerService
  • func NewMessengerService(query flowdef.QueryService, stateStore *store.FlowStateStore, ...) *MessengerService
  • func (s *MessengerService) ReceivedMessage(ctx context.Context, req *types.ReceivedMessageRequest) (*types.ReceivedMessageResponse, error)
  • func (s *MessengerService) ReceivedPostback(ctx context.Context, req *types.ReceivedPostbackRequest) (*types.ReceivedPostbackResponse, error)
• type OrderService
  • func NewOrderService(query flowdef.QueryService, stateStore *store.FlowStateStore, ...) *OrderService
  • func (s *OrderService) ReceivedCompletedOrder(ctx context.Context, req *types.ReceivedCompletedOrderRequest) (*types.ReceivedCompletedOrderResponse, error)

Types

type ActionExecutor

type ActionExecutor struct {
	FBClient *fbmsg.Client
}

func NewActionExecutor

func NewActionExecutor(fbClient *fbmsg.Client) *ActionExecutor

func (*ActionExecutor) ExecuteAction

func (ex *ActionExecutor) ExecuteAction(ctx context.Context, node *types.Node, state *ActionState) (_err error)

func (*ActionExecutor) ExecuteActions

func (ex *ActionExecutor) ExecuteActions(nodes []*types.Node, state *ActionState)

type ActionState

type ActionState struct {
	PageID dot.IntID
	PSID   dot.IntID
	Extra  map[string]string
}

type MessengerService

type MessengerService struct {
	FlowQuery  flowdef.QueryService
	StateStore *store.FlowStateStore
	ActionExec *ActionExecutor
}

func NewMessengerService

func NewMessengerService(
	query flowdef.QueryService,
	stateStore *store.FlowStateStore,
	actionExec *ActionExecutor,
) *MessengerService

func (*MessengerService) ReceivedMessage

func (s *MessengerService) ReceivedMessage(ctx context.Context, req *types.ReceivedMessageRequest) (*types.ReceivedMessageResponse, error)

func (*MessengerService) ReceivedPostback

func (s *MessengerService) ReceivedPostback(ctx context.Context, req *types.ReceivedPostbackRequest) (*types.ReceivedPostbackResponse, error)

type OrderService

type OrderService struct {
	FlowQuery  flowdef.QueryService
	StateStore *store.FlowStateStore
	ActionExec *ActionExecutor
}

func NewOrderService

func NewOrderService(
	query flowdef.QueryService,
	stateStore *store.FlowStateStore,
	actionExec *ActionExecutor,
) *OrderService

func (*OrderService) ReceivedCompletedOrder

func (s *OrderService) ReceivedCompletedOrder(ctx context.Context, req *types.ReceivedCompletedOrderRequest) (*types.ReceivedCompletedOrderResponse, error)