🪠 Plumb through notify_charging_limit as a NOP

manager/handlers/ocpp201/notify_charging_limit.go

@@ -0,0 +1,25 @@
+// SPDX-License-Identifier: Apache-2.0
+
+package ocpp201
+
+import (
+	"context"
+	"github.com/thoughtworks/maeve-csms/manager/ocpp"
+	"github.com/thoughtworks/maeve-csms/manager/ocpp/ocpp201"
+	"go.opentelemetry.io/otel/attribute"
+	"go.opentelemetry.io/otel/trace"
+)
+
+type NotifyChargingLimitHandler struct{}
+
+func (h NotifyChargingLimitHandler) HandleCall(ctx context.Context, chargeStationId string, request ocpp.Request) (response ocpp.Response, err error) {
+	req := request.(*ocpp201.NotifyChargingLimitRequestJson)
+
+	span := trace.SpanFromContext(ctx)
+
+	span.SetAttributes(
+		attribute.String("notify_charging_limit.charging_limit_source", string(req.ChargingLimit.ChargingLimitSource)),
+		attribute.Int("notify_charging_limit.evse_id", req.EvseId))
+
+	return &ocpp201.NotifyChargingLimitResponseJson{}, nil
+}

manager/handlers/ocpp201/routing.go

@@ -101,6 +101,12 @@ func NewRouter(emitter transport.Emitter,
 				ResponseSchema: "ocpp201/NotifyReportResponse.json",
 				Handler:        NotifyReportHandler{},
 			},
+			"NotifyChargingLimit": {
+				NewRequest:     func() ocpp.Request { return new(ocpp201.NotifyChargingLimitRequestJson) },
+				RequestSchema:  "ocpp201/NotifyChargingLimitRequest.json",
+				ResponseSchema: "ocpp201/NotifyChargingLimitResponse.json",
+				Handler:        NotifyChargingLimitHandler{},
+			},
 			"StatusNotification": {
 				NewRequest:     func() ocpp.Request { return new(ocpp201.StatusNotificationRequestJson) },
 				RequestSchema:  "ocpp201/StatusNotificationRequest.json",

manager/ocpp/ocpp201/notify_charging_limit_request.go

@@ -0,0 +1,34 @@
+// SPDX-License-Identifier: Apache-2.0
+
+package ocpp201
+
+type NotifyChargingLimitRequestJson struct {
+	// CustomData corresponds to the JSON schema field "customData".
+	CustomData *CustomDataType `json:"customData,omitempty" yaml:"customData,omitempty" mapstructure:"customData,omitempty"`
+
+	// Number of the EVSE on which the limit has been applied.
+	EvseId int `json:"evseId,omitempty" yaml:"evseId,omitempty" mapstructure:"evseId,omitempty"`
+	// Number of the EVSE on which the limit has been applied.
+	ChargingLimit ChargingLimitType `json:"chargingLimit,omitempty" yaml:"chargingLimit,omitempty" mapstructure:"chargingLimit,omitempty"`
+
+	// ChargingSchedule corresponds to the JSON schema field "chargingSchedule".
+	ChargingSchedule []ChargingScheduleType `json:"chargingSchedule" yaml:"chargingSchedule" mapstructure:"chargingSchedule"`
+}
+
+func (*NotifyChargingLimitRequestJson) IsRequest() {}
+
+type ChargingLimitSourceEnumType string
+
+const ChargingLimitSourceEnumEMS ChargingLimitSourceEnumType = "EMS"
+const ChargingLimitSourceEnumOther ChargingLimitSourceEnumType = "Other"
+const ChargingLimitSourceEnumSO ChargingLimitSourceEnumType = "SO"
+const ChargingLimitSourceEnumCSO ChargingLimitSourceEnumType = "CSO"
+
+type ChargingLimitType struct {
+	// CustomData corresponds to the JSON schema field "customData".
+	CustomData *CustomDataType `json:"customData,omitempty" yaml:"customData,omitempty" mapstructure:"customData,omitempty"`
+
+    ChargingLimitSource BootReasonEnumType `json:"chargingLimitSource" yaml:"chargingLimitSource" mapstructure:"chargingLimitSource"`
+
+	IsGridCritical bool `json:"isGridCritical,omitempty" yaml:"isGridCritical,omitempty" mapstructure:"isGridCritical,omitempty"`
+}

manager/ocpp/ocpp201/notify_charging_limit_response.go

@@ -0,0 +1,11 @@
+// SPDX-License-Identifier: Apache-2.0
+
+package ocpp201
+
+type NotifyChargingLimitResponseJson struct {
+	// CustomData corresponds to the JSON schema field "customData".
+	CustomData *CustomDataType `json:"customData,omitempty" yaml:"customData,omitempty" mapstructure:"customData,omitempty"`
+}
+
+func (*NotifyChargingLimitResponseJson) IsResponse() {}
+