server

Documentation

Index

• Constants
• func GetOptionalStringFromVars(name string, args url.Values, result_Out *string) bool
• func GetStringFromVars(name string, args url.Values, result_Out *string) error
• func HandleInputError(log *log.ColorLogger, w http.ResponseWriter, err error)
• func HandleInvalidMethod(log *log.ColorLogger, w http.ResponseWriter)
• func HandleResponse(log *log.ColorLogger, w http.ResponseWriter, response any, err error, ...)
• func RegisterQuerylessGet[ContextType IQuerylessCallContext[DataType], DataType any, ...](router *mux.Router, functionName string, ...)
• func RegisterQuerylessPost[ContextType IQuerylessCallContext[DataType], BodyType any, DataType any, ...](router *mux.Router, functionName string, ...)
• func RegisterSingleStagePost[ContextType ISingleStageCallContext[DataType], BodyType any, DataType any, ...](router *mux.Router, functionName string, ...)
• func RegisterSingleStageRoute[ContextType ISingleStageCallContext[DataType], DataType any, ...](router *mux.Router, functionName string, ...)
• func ValidateArg[ArgType any](name string, args url.Values, impl ArgValidator[ArgType], result_Out *ArgType) error
• func ValidateArgBatch[ArgType any](name string, args url.Values, batchLimit int, impl ArgValidator[ArgType], ...) error
• func ValidateOptionalArg[ArgType any](name string, args url.Values, impl ArgValidator[ArgType], result_Out *ArgType, ...) error
• type ApiManager
  • func NewApiServer(socketPath string, handlers []IHandler, route string) (*ApiManager, error)
  • func (m *ApiManager) Start(wg *sync.WaitGroup, socketOwnerUid uint32, socketOwnerGid uint32) error
  • func (m *ApiManager) Stop() error
• type ApiResponse
• type ArgValidator
• type IContextFactory
• type IHandler
• type IQuerylessCallContext
• type IQuerylessGetContextFactory
• type IQuerylessPostContextFactory
• type ISingleStageCallContext
• type ISingleStageGetContextFactory
• type ISingleStagePostContextFactory
• type SuccessData

Constants

const (
	ApiLogColor color.Attribute = color.FgHiBlue
)

Functions

func GetOptionalStringFromVars

func GetOptionalStringFromVars(name string, args url.Values, result_Out *string) bool

Gets an optional string argument from the provided vars list

func GetStringFromVars

func GetStringFromVars(name string, args url.Values, result_Out *string) error

Gets a string argument, ensuring that it exists in the provided vars list

func HandleInputError

func HandleInputError(log *log.ColorLogger, w http.ResponseWriter, err error)

Handles an error related to parsing the input parameters of a request

func HandleInvalidMethod

func HandleInvalidMethod(log *log.ColorLogger, w http.ResponseWriter)

Handle routes called with an invalid method

func HandleResponse

func HandleResponse(log *log.ColorLogger, w http.ResponseWriter, response any, err error, debug bool)

Handles a Node daemon response

func RegisterQuerylessGet

func RegisterQuerylessGet[ContextType IQuerylessCallContext[DataType], DataType any, ConfigType config.IModuleConfig](
	router *mux.Router,
	functionName string,
	factory IQuerylessGetContextFactory[ContextType, DataType],
	serviceProvider *services.ServiceProvider[ConfigType],
)

Registers a new route with the router, which will invoke the provided factory to create and execute the context for the route when it's called via GET; use this for typical general-purpose calls

func RegisterQuerylessPost

func RegisterQuerylessPost[ContextType IQuerylessCallContext[DataType], BodyType any, DataType any, ConfigType config.IModuleConfig](
	router *mux.Router,
	functionName string,
	factory IQuerylessPostContextFactory[ContextType, BodyType, DataType],
	serviceProvider *services.ServiceProvider[ConfigType],
)

Registers a new route with the router, which will invoke the provided factory to create and execute the context for the route when it's called via POST; use this for typical general-purpose calls

func RegisterSingleStagePost

func RegisterSingleStagePost[ContextType ISingleStageCallContext[DataType], BodyType any, DataType any, ConfigType config.IModuleConfig](
	router *mux.Router,
	functionName string,
	factory ISingleStagePostContextFactory[ContextType, BodyType, DataType],
	serviceProvider *services.ServiceProvider[ConfigType],
)

Registers a new route with the router, which will invoke the provided factory to create and execute the context for the route when it's called via POST; use this for typical general-purpose calls

func RegisterSingleStageRoute

func RegisterSingleStageRoute[ContextType ISingleStageCallContext[DataType], DataType any, ConfigType config.IModuleConfig](
	router *mux.Router,
	functionName string,
	factory ISingleStageGetContextFactory[ContextType, DataType],
	serviceProvider *services.ServiceProvider[ConfigType],
)

Registers a new route with the router, which will invoke the provided factory to create and execute the context for the route when it's called; use this for typical general-purpose calls

func ValidateArg

func ValidateArg[ArgType any](name string, args url.Values, impl ArgValidator[ArgType], result_Out *ArgType) error

Validates an argument, ensuring it exists and can be converted to the required type

func ValidateArgBatch

func ValidateArgBatch[ArgType any](name string, args url.Values, batchLimit int, impl ArgValidator[ArgType], result_Out *[]ArgType) error

Validates an argument representing a batch of inputs, ensuring it exists and the inputs can be converted to the required type

func ValidateOptionalArg

func ValidateOptionalArg[ArgType any](name string, args url.Values, impl ArgValidator[ArgType], result_Out *ArgType, exists_Out *bool) error

Validates an optional argument, converting to the required type if it exists

Types

type ApiManager

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

func NewApiServer

func NewApiServer(socketPath string, handlers []IHandler, route string) (*ApiManager, error)

func (*ApiManager) Start

func (m *ApiManager) Start(wg *sync.WaitGroup, socketOwnerUid uint32, socketOwnerGid uint32) error

Starts listening for incoming HTTP requests

func (*ApiManager) Stop

func (m *ApiManager) Stop() error

Stops the HTTP listener

type ApiResponse

type ApiResponse[Data any] struct {
	Data *Data `json:"data"`
}

type ArgValidator

type ArgValidator[ArgType any] func(string, string) (ArgType, error)

Function for validating an argument (wraps the old CLI validators)

type IContextFactory

type IContextFactory interface {
	RegisterRoute(router *mux.Router)
}

Context factories can implement this generally so they can register themselves with an HTTP router.

type IHandler

type IHandler interface {
	RegisterRoutes(router *mux.Router)
}

type IQuerylessCallContext

type IQuerylessCallContext[DataType any] interface {
	// Prepare the response data in whatever way the context needs to do
	//PrepareData(data *DataType, opts *bind.TransactOpts) error
	PrepareData(data *DataType, opts *bind.TransactOpts) error
}

Wrapper for callbacks used by call runners that simply run without following a structured pattern of querying the chain. This is the most general form of context and can be used by anything as it doesn't add any scaffolding. Structs implementing this will handle the caller-specific functionality.

type IQuerylessGetContextFactory

type IQuerylessGetContextFactory[ContextType IQuerylessCallContext[DataType], DataType any] interface {
	// Create the context for the route
	Create(args url.Values) (ContextType, error)
}

Interface for queryless call context factories that handle GET calls. These will be invoked during route handling to create the unique context for the route.

type IQuerylessPostContextFactory

type IQuerylessPostContextFactory[ContextType IQuerylessCallContext[DataType], BodyType any, DataType any] interface {
	// Create the context for the route
	Create(body BodyType) (ContextType, error)
}

Interface for queryless call context factories that handle POST requests. These will be invoked during route handling to create the unique context for the route

type ISingleStageCallContext

type ISingleStageCallContext[DataType any] interface {
	// Initialize the context with any bootstrapping, requirements checks, or bindings it needs to set up
	Initialize() error

	// Used to get any supplemental state required during initialization - anything in here will be fed into an hd.Query() multicall
	GetState(mc *batch.MultiCaller)

	// Prepare the response data in whatever way the context needs to do
	PrepareData(data *DataType, opts *bind.TransactOpts) error
}

Wrapper for callbacks used by call runners that follow a common single-stage pattern: Create bindings, query the chain, and then do whatever else they want. Structs implementing this will handle the caller-specific functionality.

type ISingleStageGetContextFactory

type ISingleStageGetContextFactory[ContextType ISingleStageCallContext[DataType], DataType any] interface {
	// Create the context for the route
	Create(args url.Values) (ContextType, error)
}

Interface for single-stage call context factories - these will be invoked during route handling to create the unique context for the route

type ISingleStagePostContextFactory

type ISingleStagePostContextFactory[ContextType ISingleStageCallContext[DataType], BodyType any, DataType any] interface {
	// Create the context for the route
	Create(body BodyType) (ContextType, error)
}

Interface for queryless call context factories that handle POST requests. These will be invoked during route handling to create the unique context for the route

type SuccessData

type SuccessData struct {
	Success bool `json:"success"`
}