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
	// 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

	WriteWait time.Duration

	EventHandler EventHandler
}

type EventHandler interface {
	ProcessEvent(IncomingMessage)
}

type EventHandlerFunc func(IncomingMessage)

type IncomingMessage struct {
	*WebhookEvent
	*RequestLogEvent
}

type OutgoingMessage struct {
	*WebhookResponse
}

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 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"`
}