websocket

type Client struct {
	// URL the client connects to
	URL string

	// ID sent by the client in the `Websocket-Id` header when connecting
	WebSocketID string

	// Feature that the websocket is specified for
	WebSocketAuthorizedFeature string

	NotifyExpired chan struct{}
	// contains filtered or unexported fields
}

type Config struct {
	ConnectAttemptWait time.Duration

	Dialer *ws.Dialer

	Log *log.Logger

	// Force use of unencrypted ws:// protocol instead of wss://
	NoWSS bool

	PingPeriod time.Duration

	PongWait time.Duration

	// Interval at which the websocket client should reset the connection
	ReconnectInterval time.Duration

	// Duration to wait before closing connection
	CloseDelayPeriod time.Duration

	WriteWait time.Duration

	EventHandler EventHandler
}

type DataElement struct {
	Data      interface{}
	Marshaled string
}

type ErrorElement struct {
	Error error
}

type EventAck struct {
	Type                  string `json:"type"` // always "event_ack"
	WebhookConversationID string `json:"webhook_conversation_id"`
	EventID               string `json:"event_id"` // ID of the event
}

type EventHandler interface {
	ProcessEvent(IncomingMessage)
}

type EventHandlerFunc func(IncomingMessage)

type IElement interface {
	Accept(v *Visitor) error
}

type IncomingMessage struct {
	*WebhookEvent
	*RequestLogEvent
}

type OutgoingMessage struct {
	*WebhookResponse
	*EventAck
}

type RequestLogEvent struct {
	EventPayload string `json:"event_payload"`

	// RequestLogID is the `resp_` id for the response event which is used as the request log event throughout the system.
	// This is different from the `EventPayload.RequestID` which is the `req_` id for the user's actual request, which they
	// can use to find their request in the dashboard.
	RequestLogID string `json:"request_log_id"`
	Type         string `json:"type"`
}

type StateElement struct {
	State state
	Data  []string
}

type Visitor struct {
	VisitError   func(ErrorElement) error
	VisitData    func(DataElement) error
	VisitStatus  func(StateElement) error
	VisitWarning func(WarningElement) error
}

type WarningElement struct {
	Warning string
}

type WebhookEndpoint struct {
	APIVersion *string `json:"api_version"`
}

type WebhookEvent struct {
	Endpoint              WebhookEndpoint   `json:"endpoint"`
	EventPayload          string            `json:"event_payload"`
	HTTPHeaders           map[string]string `json:"http_headers"`
	Type                  string            `json:"type"`
	WebhookConversationID string            `json:"webhook_conversation_id"`
	WebhookID             string            `json:"webhook_id"`
}

type WebhookResponse struct {
	ForwardURL            string            `json:"forward_url"`
	Status                int               `json:"status"`
	HTTPHeaders           map[string]string `json:"http_headers"`
	Body                  string            `json:"body"`
	Type                  string            `json:"type"`
	WebhookConversationID string            `json:"webhook_conversation_id"`
	WebhookID             string            `json:"webhook_id"`
}