api

Documentation

Index

• Constants
• type Params
  • func PreprocessRequest(req *http.Request) (*Params, error)
• type QueryType
  • func QTypeFromString(strQType string) QueryType
• type RequestHandler
  • func NewRequestHandler(params *Params, messageBus core.MessageBus, nc core.NetworkCoordinator, ...) *RequestHandler
  • func (rh *RequestHandler) ProcessCreateMember() (map[string]interface{}, error)
  • func (rh *RequestHandler) ProcessDumpUsers(all bool) (map[string]interface{}, error)
  • func (rh *RequestHandler) ProcessGetBalance() (map[string]interface{}, error)
  • func (rh *RequestHandler) ProcessGetSeed() (map[string]interface{}, error)
  • func (rh *RequestHandler) ProcessIsAuthorized() (map[string]interface{}, error)
  • func (rh *RequestHandler) ProcessRegisterNode() (map[string]interface{}, error)
  • func (rh *RequestHandler) ProcessSendMoney() (map[string]interface{}, error)
• type Runner
  • func NewRunner(cfg *configuration.APIRunner) (*Runner, error)
  • func (ar *Runner) Start(c core.Components) error
  • func (ar *Runner) Stop() error

Constants

const (

	// HandlerError is error in handler
	HandlerError int = -1
	// HandlerError is bad formed request
	BadRequest int = -2
)

const (
	// REFERENCE is field for reference
	REFERENCE = "reference"
	// SEED is field to reference
	SEED = "seed"
)

Types

type Params

type Params struct {
	QueryType              string   `json:"query_type"`
	Name                   string   `json:"name"`
	Reference              string   `json:"reference"`
	From                   string   `json:"from"`
	To                     string   `json:"to"`
	Method                 string   `json:"method"`
	Requester              string   `json:"requester"`
	Target                 string   `json:"target"`
	QID                    string   `json:"qid"`
	Amount                 uint     `json:"amount"`
	PublicKey              string   `json:"public_key"`
	Roles                  []string `json:"roles"`
	NumberOfBootstrapNodes uint     `json:"bootstrap_nodes_num"`
	MajorityRule           uint     `json:"majority_rule"`
	Host                   string   `json:"host"`
}

Params contains supported query params

func PreprocessRequest

func PreprocessRequest(req *http.Request) (*Params, error)

PreprocessRequest extracts params from requests

type QueryType

type QueryType int

QueryType represents type of query

const (
	UNDEFINED QueryType = iota
	CreateMember
	DumpUserInfo
	GetBalance
	SendMoney
	DumpAllUsers
	RegisterNode
	IsAuth
	GetSeed
)

Supported query types

func QTypeFromString

func QTypeFromString(strQType string) QueryType

QTypeFromString converts string representation to enum

type RequestHandler

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

RequestHandler encapsulate processing of request

func NewRequestHandler

func NewRequestHandler(params *Params, messageBus core.MessageBus, nc core.NetworkCoordinator, rootDomainReference core.RecordRef, smanager *seedmanager.SeedManager) *RequestHandler

NewRequestHandler creates new query handler

func (*RequestHandler) ProcessCreateMember

func (rh *RequestHandler) ProcessCreateMember() (map[string]interface{}, error)

ProcessCreateMember processes CreateMember query type

func (*RequestHandler) ProcessDumpUsers

func (rh *RequestHandler) ProcessDumpUsers(all bool) (map[string]interface{}, error)

ProcessDumpUsers processes Dump users query type

func (*RequestHandler) ProcessGetBalance

func (rh *RequestHandler) ProcessGetBalance() (map[string]interface{}, error)

ProcessGetBalance processes get_balance query type

func (*RequestHandler) ProcessGetSeed

func (rh *RequestHandler) ProcessGetSeed() (map[string]interface{}, error)

ProcessGetSeed processes get seed request

func (*RequestHandler) ProcessIsAuthorized

func (rh *RequestHandler) ProcessIsAuthorized() (map[string]interface{}, error)

ProcessIsAuthorized processes is_auth query type

func (*RequestHandler) ProcessRegisterNode

func (rh *RequestHandler) ProcessRegisterNode() (map[string]interface{}, error)

ProcessRegisterNode process register node response

func (*RequestHandler) ProcessSendMoney

func (rh *RequestHandler) ProcessSendMoney() (map[string]interface{}, error)

ProcessSendMoney processes send_money query type

type Runner

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

Runner implements Component for API

func NewRunner

func NewRunner(cfg *configuration.APIRunner) (*Runner, error)

NewRunner is C-tor for API Runner

func (*Runner) Start

func (ar *Runner) Start(c core.Components) error

Start runs api server

func (*Runner) Stop

func (ar *Runner) Stop() error

Stop stops api server