websocket

type HttpServerHandler interface {
	ListenAndServe() error
	Shutdown(ctx context.Context) error
}

type PayloadConverter interface {
	ExtractWsMessage(payload []byte) (*data.WsMessage, error)
	ConstructPayload(wsMessage *data.WsMessage) ([]byte, error)
	IsInterfaceNil() bool
}

type PayloadHandler interface {
	ProcessPayload(payload []byte, topic string) error
	Close() error
	IsInterfaceNil() bool
}

type WSConClient interface {
	io.Closer
	OpenConnection(url string) error
	WriteMessage(messageType int, data []byte) error
	ReadMessage() (int, []byte, error)
	GetID() string
	IsInterfaceNil() bool
}