chargepoint

type Backoff struct {
	Minimum     time.Duration // default 1 s
	RandomRange time.Duration // default 1 s
	RepeatTimes int           // default 5
}

type Client struct {
	// contains filtered or unexported fields
}

type Config struct {
	// URL is the central system's endpoint without the identity, e.g.
	// wss://csms.example/ocpp; the identity is appended as a path segment.
	URL string
	// ID is the charging station identity (1 to 48 characters).
	ID string
	// Versions offered, in order of preference (default 2.1, 2.0.1, 1.6).
	Versions []string
	// Password for HTTP basic authentication (security profiles 1 and 2).
	Password string
	// TLS for wss (profiles 2 and 3; a client certificate for 3).
	TLS *tls.Config
	// Header holds further upgrade request headers.
	Header http.Header
	// Timeout of our CALLs and of each handler (default 30 s).
	Timeout time.Duration
	// Ping is the WebSocket ping interval (0: none).
	Ping time.Duration
	// SkipValidation turns off the schema checks.
	SkipValidation bool
	// OnInvalid, when set, decides about a central system request that
	// fails the schema check: nil hands it to the handler anyway, an error
	// (normally verr) refuses it. Unset, such requests are refused.
	OnInvalid func(c *Client, action string, payload json.RawMessage, verr *ocpp.RPCError) error
	// Backoff between reconnection attempts in Run.
	Backoff Backoff
	// OnConnect runs, on its own goroutine, after every connection (send
	// BootNotification there); OnDisconnect after it ends.
	OnConnect    func(ctx context.Context, c *Client)
	OnDisconnect func(c *Client, err error)
	// OnResultError is told about a 2.1 CALLRESULTERROR the central system
	// sent about one of our answers.
	OnResultError func(id, code, desc string)
}

type Dialled struct {
	WS      *websocket.Conn
	Version string
}

type HandlerFunc func(ctx context.Context, c *Client, payload json.RawMessage) (any, error)