pipeshandler

type Client struct {
	Conn    *websocket.Conn
	ID      string
	Session string
	End     time.Time
	Data    interface{}
	Mutex   *sync.Mutex
}

type Config struct {
	ExpectedConnections int64
	SessionDuration     time.Duration // How long a session should stay alive
	Secret              []byte        // JWT secret (for authorization)

	// Node handlers
	NodeDisconnectHandler func(node pipes.Node)

	// Client handlers
	ClientDisconnectHandler   func(client *Client)
	TokenValidateHandler      func(claims *ConnectionTokenClaims, attachments string) bool // Called before the websocket connection is accepted, returns if the client should be disconnected (true = disconnect)
	ClientConnectHandler      func(client *Client, attachments string) bool                // Called after websocket connection is established, returns if the client should be disconnected (true = disconnect)
	ClientEnterNetworkHandler func(client *Client, attachments string) bool                // Called after pipes adapter is registered, returns if the client should be disconnected (true = disconnect)

	// Codec middleware
	ClientEncodingMiddleware func(client *Client, instance *Instance, message []byte) ([]byte, error)
	DecodingMiddleware       func(client *Client, instance *Instance, message []byte) ([]byte, error)

	// Error handler
	ErrorHandler func(err error)
}

type ConnectionTokenClaims struct {
	Account        string `json:"acc"`             // Account id of the connecting client
	ExpiredUnixSec int64  `json:"e_u"`             // Expiration time in unix seconds
	Session        string `json:"ses"`             // Session id of the connecting client
	Node           string `json:"node"`            // Node id of the node the client is connecting to
	Extra          string `json:"extra,omitempty"` // Extra arguments for the connection

	jwt.RegisteredClaims
}

type Context struct {
	Client     *Client
	Action     string // The action to perform
	Locale     string // The locale of the client
	ResponseId string
	Data       []byte
	Node       *pipes.LocalNode
	Instance   *Instance
}

type Instance struct {
	Config Config
	// contains filtered or unexported fields
}

type Message[T any] struct {
	Action string `json:"action"`
	Data   T      `json:"data"`
}