web

Documentation

Index

• Constants
• Variables
• func StartWebUI(queueWsOutTokenTransactions chan *totra.TokenTransaction)
• type GasPriceMessage
• type Message
• type MessageHandler
• type MessagePayload
• type NewEventMessage
• type SendMessageMessage
• type WsClient
  • func NewClient(conn net.Conn, hub *WsHub) *WsClient
• type WsHub
  • func NewHub(queueWsOutTokenTransactions chan *totra.TokenTransaction) *WsHub

Constants

const (
	MsgNewSale  = "new_event"
	MsgGasPrice = "gas_price"

	MsgCommand = "cmd"
)

Variables

var (
	ErrEventNotSupported = errors.New("this event type is not supported")
)

* wsUpgrader is used to upgrade incomming HTTP requests into a persitent websocket connection

Functions

func StartWebUI

func StartWebUI(queueWsOutTokenTransactions chan *totra.TokenTransaction)

Types

type GasPriceMessage

type GasPriceMessage struct {
	Normal float64 `json:"normal"`
	Fast   float64 `json:"fast"`
}

payloads for message types

type Message

type Message struct {
	// Type is the message type sent
	Type string `json:"type"`
	// Payload is the data Based on the Type
	Payload any `json:"payload"`
}

Message is the Messages sent over the websocket Used to differ between different actions

type MessageHandler

type MessageHandler func(message Message, c *WsClient) error

MessageHandler is a function signature that is used to affect messages on the socket and triggered depending on the type

type MessagePayload

type MessagePayload json.RawMessage

type NewEventMessage

type NewEventMessage struct {
	Message string `json:"message"`
	From    string `json:"from"`
}

payloads for message types

type SendMessageMessage

type SendMessageMessage struct {
	Message string `json:"message"`
	From    string `json:"from"`
}

SendMessageMessage is the payload sent in the send_message message

type WsClient

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

func NewClient

func NewClient(conn net.Conn, hub *WsHub) *WsClient

NewClient is used to initialize a new Client with all required values initialized

type WsHub

type WsHub struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewHub

func NewHub(queueWsOutTokenTransactions chan *totra.TokenTransaction) *WsHub