handlers

Documentation

Index

• Variables
• type BaseSessionHandler
  • func NewBaseSessionHandler(cfg engine.Config, rs resource.Resource, stateDb db.Db, userdataDb db.Db, ...) *BaseSessionHandler
  • func (f *BaseSessionHandler) GetConfig() engine.Config
  • func (f *BaseSessionHandler) GetEngine(cfg engine.Config, rs resource.Resource, pr *persist.Persister) engine.Engine
  • func (f *BaseSessionHandler) GetRequestParser() RequestParser
  • func (f *BaseSessionHandler) Output(rqs RequestSession) (RequestSession, error)
  • func (f *BaseSessionHandler) Process(rqs RequestSession) (RequestSession, error)
  • func (f *BaseSessionHandler) Reset(rqs RequestSession) (RequestSession, error)
  • func (f *BaseSessionHandler) Shutdown()
• type HandlerService
• type LocalHandlerService
  • func NewLocalHandlerService(ctx context.Context, fp string, debug bool, dbResource *resource.DbResource, ...) (*LocalHandlerService, error)
  • func (ls *LocalHandlerService) GetEngine() *engine.DefaultEngine
  • func (ls *LocalHandlerService) GetHandler(accountService remote.AccountServiceInterface) (*ussd.Handlers, error)
  • func (ls *LocalHandlerService) SetDataStore(db *db.Db)
  • func (ls *LocalHandlerService) SetPersister(Pe *persist.Persister)
• type RequestHandler
• type RequestParser
• type RequestSession

Variables

var (
	ErrInvalidRequest = errors.New("invalid request for context")
	ErrSessionMissing = errors.New("missing session")
	ErrInvalidInput   = errors.New("invalid input")
	ErrStorage        = errors.New("storage retrieval fail")
	ErrEngineType     = errors.New("incompatible engine")
	ErrEngineInit     = errors.New("engine init fail")
	ErrEngineExec     = errors.New("engine exec fail")
)

Types

type BaseSessionHandler

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

func NewBaseSessionHandler

func NewBaseSessionHandler(cfg engine.Config, rs resource.Resource, stateDb db.Db, userdataDb db.Db, rp RequestParser, hn *ussd.Handlers) *BaseSessionHandler

func (*BaseSessionHandler) GetConfig

func (f *BaseSessionHandler) GetConfig() engine.Config

func (*BaseSessionHandler) GetEngine

func (f *BaseSessionHandler) GetEngine(cfg engine.Config, rs resource.Resource, pr *persist.Persister) engine.Engine

func (*BaseSessionHandler) GetRequestParser

func (f *BaseSessionHandler) GetRequestParser() RequestParser

func (*BaseSessionHandler) Output

func (f *BaseSessionHandler) Output(rqs RequestSession) (RequestSession, error)

func (*BaseSessionHandler) Process

func (f *BaseSessionHandler) Process(rqs RequestSession) (RequestSession, error)

func (*BaseSessionHandler) Reset

func (f *BaseSessionHandler) Reset(rqs RequestSession) (RequestSession, error)

func (*BaseSessionHandler) Shutdown

func (f *BaseSessionHandler) Shutdown()

type HandlerService

type HandlerService interface {
	GetHandler() (*ussd.Handlers, error)
}

type LocalHandlerService

type LocalHandlerService struct {
	Parser        *asm.FlagParser
	DbRs          *resource.DbResource
	Pe            *persist.Persister
	UserdataStore *db.Db
	AdminStore    *utils.AdminStore
	Cfg           engine.Config
	Rs            resource.Resource
}

func NewLocalHandlerService

func NewLocalHandlerService(ctx context.Context, fp string, debug bool, dbResource *resource.DbResource, cfg engine.Config, rs resource.Resource) (*LocalHandlerService, error)

func (*LocalHandlerService) GetEngine

func (ls *LocalHandlerService) GetEngine() *engine.DefaultEngine

TODO: enable setting of sessionId on engine init time

func (*LocalHandlerService) GetHandler

func (ls *LocalHandlerService) GetHandler(accountService remote.AccountServiceInterface) (*ussd.Handlers, error)

func (*LocalHandlerService) SetDataStore

func (ls *LocalHandlerService) SetDataStore(db *db.Db)

func (*LocalHandlerService) SetPersister

func (ls *LocalHandlerService) SetPersister(Pe *persist.Persister)

type RequestHandler

type RequestHandler interface {
	GetConfig() engine.Config
	GetRequestParser() RequestParser
	GetEngine(cfg engine.Config, rs resource.Resource, pe *persist.Persister) engine.Engine
	Process(rs RequestSession) (RequestSession, error)
	Output(rs RequestSession) (RequestSession, error)
	Reset(rs RequestSession) (RequestSession, error)
	Shutdown()
}

type RequestParser

type RequestParser interface {
	GetSessionId(rq any) (string, error)
	GetInput(rq any) ([]byte, error)
}

TODO: seems like can remove this.

type RequestSession

type RequestSession struct {
	Ctx      context.Context
	Config   engine.Config
	Engine   engine.Engine
	Input    []byte
	Storage  *storage.Storage
	Writer   io.Writer
	Continue bool
}