websocket

type Attempt struct {
	Event string      `json:"type"`
	Body  AttemptBody `json:"body"`
}

type AttemptBody struct {
	Path         string         `json:"cli_path"`
	EventID      string         `json:"event_id"`
	AttemptId    string         `json:"attempt_id"`
	ConnectionId string         `json:"webhook_id"`
	Request      AttemptRequest `json:"request"`
}

type AttemptRequest struct {
	Method     string          `json:"method"`
	Timeout    int64           `json:"timeout"`
	DataString string          `json:"data_string"`
	Headers    json.RawMessage `json:"headers"`
}

type AttemptResponse struct {
	Event string              `json:"event"`
	Body  AttemptResponseBody `json:"body"`
}

type AttemptResponseBody struct {
	AttemptId string `json:"attempt_id"`
	CLIPath   string `json:"cli_path"`
	Status    int    `json:"status"`
	Data      string `json:"data"`
}

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

	CLIKey string

	TeamID string

	// ID sent by the client in the `Websocket-Id` header when connecting
	WebSocketID 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

	WriteWait time.Duration

	EventHandler EventHandler
}

type ConnectionMessage struct {
	Event string                `json:"event"`
	Body  ConnectionMessageBody `json:"body"`
}

type ConnectionMessageBody struct {
	SourceId      string   `json:"source_id"`
	ConnectionIds []string `json:"webhook_ids"`
}

type ErrorAttemptBody struct {
	AttemptId string `json:"attempt_id"`
	Error     bool   `json:"error"`
}

type ErrorAttemptResponse struct {
	Event string           `json:"event"`
	Body  ErrorAttemptBody `json:"body"`
}

type EventHandler interface {
	ProcessEvent(IncomingMessage)
}

type EventHandlerFunc func(IncomingMessage)

type IncomingMessage struct {
	*Attempt
}

type OutgoingMessage struct {
	*ErrorAttemptResponse
	*AttemptResponse
	*ConnectionMessage
}