transport

type Connection interface {
	// Disconnect drops the previously established connection to the broker.
	Disconnect(ctx context.Context) error
}

type Emitter interface {
	// Emit sends a message, destined for a specific charge station which is identified by its
	// chargeStationId using a specific ocppVersion, to the gateway.
	Emit(ctx context.Context, ocppVersion OcppVersion, chargeStationId string, message *Message) error
}

type EmitterFunc func(ctx context.Context, ocppVersion OcppVersion, chargeStationId string, message *Message) error

type Error struct {
	ErrorCode    ErrorCode
	WrappedError error
}

type ErrorCode string

type Listener interface {
	// Connect establishes a connection to the broker and subscribes to receive messages for
	// either a specific charge station or all charge stations (for a specific OcppVersion). The messages
	// are delivered to the provided MessageHandler.
	//
	// Returns either a Connection on success or an error.
	Connect(ctx context.Context, ocppVersion OcppVersion, chargeStationId *string, handler MessageHandler) (Connection, error)
}

type Message struct {
	MessageType      MessageType     `json:"type"`
	Action           string          `json:"action"`
	MessageId        string          `json:"id"`
	RequestPayload   json.RawMessage `json:"request,omitempty"`
	ResponsePayload  json.RawMessage `json:"response,omitempty"`
	ErrorCode        ErrorCode       `json:"error_code,omitempty"`
	ErrorDescription string          `json:"error_description,omitempty"`
	State            json.RawMessage `json:"state,omitempty"`
}

type MessageHandler interface {
	// Handle a Message produced by the broker. The message will be for a specific OcppVersion
	// and come from the charge station identified by the chargeStationId.
	Handle(ctx context.Context, chargeStationId string, message *Message)
}

type MessageHandlerFunc func(ctx context.Context, chargeStationId string, message *Message)

type MessageType int

type OcppVersion string

type Receiver interface {
	Connect(errCh chan error)
}