csms

type Config struct {
	// Versions offered, in order of preference (default 2.1, 2.0.1, 1.6).
	// Variant spellings of each (ocpp.Subprotocols) are accepted too.
	Versions []string
	// NoSubprotocol is the version assumed for a station that offers no
	// subprotocol; empty refuses such a station.
	NoSubprotocol string
	// Authenticate admits a station before the WebSocket upgrade: check the
	// basic authentication password (profiles 1 and 2; ocpp.BasicAuthPassword,
	// ocpp.PasswordOK) or r.TLS (profile 3; ocpp.ClientCertNames). A
	// non-nil error refuses the station with HTTP 401. Nil admits everyone.
	Authenticate func(r *http.Request, identity string) error
	// 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 of requests and answers
	// (for a station whose deviations the application handles itself).
	SkipValidation bool
	// OnInvalid, when set, decides about a station's request that fails
	// the schema check: return nil to hand it to the handler anyway (a
	// deviation the application tolerates; see ocpp.Deviations) or an
	// error to refuse it, normally verr. Unset, such requests are refused.
	OnInvalid func(st *Station, action string, payload json.RawMessage, verr *ocpp.RPCError) error
	// CheckSerial closes the connection of a 2.x station using a TLS client
	// certificate whose BootNotification serial number differs from the
	// certificate's common name (security profile 3).
	CheckSerial bool
	// OnConnect and OnDisconnect follow the registry.
	OnConnect    func(st *Station)
	OnDisconnect func(st *Station, err error)
	// AcceptOptions are passed to websocket.Accept (Subprotocols is set by
	// the Server); for example compression or origin checks.
	AcceptOptions websocket.AcceptOptions
}

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

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

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