Implemented Set Charging Profile API

manager/api/API.md

@@ -271,6 +271,49 @@ This operation does not require authentication
 This operation does not require authentication
 </aside>
 
+## setChargingProfile
+
+<a id="opIdsetChargingProfile"></a>
+
+`POST /cs/{csId}/setchargingprofile`
+
+> Body parameter
+
+```json
+{
+  "<ChargingProfileType>"
+}
+```
+
+<h3 id="setChargingProfile-parameters">Parameters</h3>
+
+|Name|In|Type|Required|Description|
+|---|---|---|---|---|
+|csId|path|string|true|The charge station identifier|
+|body|body|[ChargineProfileType](#schemaChargingProfileType)|true|none|
+
+> Example responses
+
+> default Response
+
+```json
+{
+  "status": "string",
+  "error": "string"
+}
+```
+
+<h3 id="setChargingProfile-responses">Responses</h3>
+
+|Status|Meaning|Description|Schema|
+|---|---|---|---|
+|200|[OK](https://tools.ietf.org/html/rfc7231#section-6.3.1)|OK|None|
+|default|Default|Unexpected error|[Status](#schemastatus)|
+
+<aside class="success">
+This operation does not require authentication
+</aside>
+
 ## setToken
 
 <a id="opIdsetToken"></a>
@@ -838,6 +881,46 @@ Trigger a charge station action
 |trigger|SignChargingStationCertificate|
 |trigger|SignCombinedCertificate|
 
+<h2 id="ChargingProfileType">ChargingProfileType</h2>
+<!-- backwards compatibility -->
+<a id="schemaChargingProfileType"></a>
+<a id="schema_ChargingProfileType"></a>
+<a id="tocSChargingProfileType"></a>
+<a id="tocsChargingProfileType"></a>
+
+```json
+
+{
+  "id": int,
+  "stackLevel": int,
+  "chargingProfilePurpose": "ChargingProfilePurposeEnumType",
+  "chargingProfileKind": "ChargingProfileKindEnumType",
+  "recurrencyKind": "RecurrencyKindEnumType",
+  "validFrom": "dateTime",
+  "validTo": "dateTime",
+  "transactionId": "identifierString[0..36]",
+  "chargingSchedule": "ChargingScheduleType"
+}
+
+```
+
+Send charging profile to charging station
+
+### Properties ###
+<small><em>See OCPP 2.0.1 Specification for ChargingProfileType</em></small>
+
+|Name|Type|Required|Restrictions|Description|
+|---|---|---|---|---|
+|id|int|true|none|none|
+|stackLevel|int|true|none|none|
+|chargingProfilePurpose|ChargingProfilePurposeEnumType|true|none|none|
+|chargingProfileKind|ChargingProfileKindEnumType|true|none|none|
+|recurrencyKind|RecurrencyKindEnumType|false|none|none|
+|validFrom|dateTime|false|none|none|
+|validTo|dateTime|false|none|none|
+|transactionId|identifierString[0..36]|false|none|none|
+|chargingSchedule|ChargingScheduleType|true|none|none|
+
 <h2 id="tocS_Token">Token</h2>
 <!-- backwards compatibility -->
 <a id="schematoken"></a>

manager/api/render.go

@@ -2,7 +2,9 @@
 
 package api
 
-import "net/http"
+import (
+	"net/http"
+)
 
 func (c ChargeStationAuth) Bind(r *http.Request) error {
 	return nil
@@ -24,6 +26,10 @@ func (c ChargeStationTrigger) Bind(r *http.Request) error {
 	return nil
 }
 
+func (c ChargingProfileType) Bind(r *http.Request) error {
+	return nil
+}
+
 func (t Token) Bind(r *http.Request) error {
 	return nil
 }

manager/api/server.go

@@ -3,16 +3,21 @@
 package api
 
 import (
+	"context"
 	"fmt"
-	handlers "github.com/thoughtworks/maeve-csms/manager/handlers/ocpp201"
-	"github.com/thoughtworks/maeve-csms/manager/ocpi"
 	"net/http"
 	"time"
 
+	"github.com/thoughtworks/maeve-csms/manager/config"
+	handlers "github.com/thoughtworks/maeve-csms/manager/handlers/ocpp201"
+	"github.com/thoughtworks/maeve-csms/manager/ocpi"
+
 	"github.com/getkin/kin-openapi/openapi3"
 	"github.com/go-chi/render"
 	"github.com/thoughtworks/maeve-csms/manager/ocpp"
+	"github.com/thoughtworks/maeve-csms/manager/ocpp/ocpp201"
 	"github.com/thoughtworks/maeve-csms/manager/store"
+	"golang.org/x/exp/slog"
 	"k8s.io/utils/clock"
 )
 
@@ -149,6 +154,7 @@ func (s *Server) LookupChargeStationAuth(w http.ResponseWriter, r *http.Request,
 }
 
 func (s *Server) TriggerChargeStation(w http.ResponseWriter, r *http.Request, csId string) {
+	slog.Info("[TEST] in TriggerChargeStation!")
 	req := new(ChargeStationTrigger)
 	if err := render.Bind(r, req); err != nil {
 		_ = render.Render(w, r, ErrInvalidRequest(err))
@@ -167,6 +173,32 @@ func (s *Server) TriggerChargeStation(w http.ResponseWriter, r *http.Request, cs
 	w.WriteHeader(http.StatusCreated)
 }
 
+func (s *Server) SetChargingProfile(w http.ResponseWriter, r *http.Request, csId string) {
+	slog.Info("[TEST] In server.go, SetChargingProfile()")
+	req := new(ChargingProfileType)
+
+	if err := render.Bind(r, req); err != nil {
+		_ = render.Render(w, r, ErrInvalidRequest(err))
+		return
+	}
+
+	slog.Info("[TEST] req:", req)
+
+	// Get the transport.Emitter so that we can send messages
+	cfg := config.DefaultConfig
+	settings, _ := config.Configure(context.Background(), &cfg)
+
+	// Define the call maker
+	v201CallMaker := handlers.NewCallMaker(settings.MsgEmitter)
+
+	request := ocpp201.SetChargingProfileRequestJson{EvseId: 0, ChargingProfile: ocpp201.ChargingProfileType(*req)}
+
+	// Send the call
+	v201CallMaker.Send(context.Background(), csId, &request)
+
+	w.WriteHeader(http.StatusCreated)
+}
+
 func (s *Server) SetToken(w http.ResponseWriter, r *http.Request) {
 	req := new(Token)
 	if err := render.Bind(r, req); err != nil {

manager/handlers/call_maker.go

@@ -5,12 +5,12 @@ package handlers
 import (
 	"context"
 	"encoding/json"
-	"fmt"
+	"reflect"
+
 	"github.com/google/uuid"
 	"github.com/thoughtworks/maeve-csms/manager/ocpp"
 	"github.com/thoughtworks/maeve-csms/manager/transport"
 	"golang.org/x/exp/slog"
-	"reflect"
 )
 
 // OcppCallMaker is an implementation of the CallMaker interface for a specific set of OCPP messages.
@@ -20,10 +20,17 @@ type OcppCallMaker struct {
 	Actions     map[reflect.Type]string // the OCPP Action associated with a specific ocpp.Request object
 }
 
+type SetChargingProfileRequestJsonFix struct {
+	evseId          int
+	chargingProfile interface{}
+}
+
 func (b OcppCallMaker) Send(ctx context.Context, chargeStationId string, request ocpp.Request) error {
 	action, ok := b.Actions[reflect.TypeOf(request)]
+	slog.Info("[TEST] we are in Send() in call_maker.go", "action", action)
 	if !ok {
-		return fmt.Errorf("unknown request type: %T", request)
+		slog.Error("unknown request type", request)
+		return nil
 	}
 
 	requestBytes, err := json.Marshal(request)

manager/handlers/ocpp201/request_start_transaction_result.go

@@ -4,6 +4,7 @@ package ocpp201
 
 import (
 	"context"
+
 	"github.com/thoughtworks/maeve-csms/manager/ocpp"
 	types "github.com/thoughtworks/maeve-csms/manager/ocpp/ocpp201"
 	"go.opentelemetry.io/otel/attribute"

manager/handlers/ocpp201/routing.go

@@ -3,16 +3,17 @@
 package ocpp201
 
 import (
+	"io/fs"
+	"reflect"
+	"time"
+
 	"github.com/thoughtworks/maeve-csms/manager/handlers"
 	"github.com/thoughtworks/maeve-csms/manager/ocpp"
 	"github.com/thoughtworks/maeve-csms/manager/ocpp/ocpp201"
 	"github.com/thoughtworks/maeve-csms/manager/services"
 	"github.com/thoughtworks/maeve-csms/manager/store"
 	"github.com/thoughtworks/maeve-csms/manager/transport"
-	"io/fs"
 	"k8s.io/utils/clock"
-	"reflect"
-	"time"
 )
 
 func NewRouter(emitter transport.Emitter,
@@ -306,6 +307,7 @@ func NewCallMaker(e transport.Emitter) *handlers.OcppCallMaker {
 			reflect.TypeOf(&ocpp201.SetVariablesRequestJson{}):               "SetVariables",
 			reflect.TypeOf(&ocpp201.TriggerMessageRequestJson{}):             "TriggerMessage",
 			reflect.TypeOf(&ocpp201.UnlockConnectorRequestJson{}):            "UnlockConnector",
+			reflect.TypeOf(&ocpp201.SetChargingProfileRequestJson{}):         "SetChargingProfile",
 		},
 	}
 }

manager/handlers/ocpp201/set_charging_profile_result.go

@@ -0,0 +1,22 @@
+// SPDX-License-Identifier: Apache-2.0
+
+package ocpp201
+
+import (
+	"context"
+
+	"github.com/thoughtworks/maeve-csms/manager/ocpp"
+	types "github.com/thoughtworks/maeve-csms/manager/ocpp/ocpp201"
+	"golang.org/x/exp/slog"
+)
+
+type SetChargingProfileResultHandler struct{}
+
+func (h SetChargingProfileResultHandler) HandleCallResult(ctx context.Context, chargeStationId string, request ocpp.Request, response ocpp.Response, state any) error {
+	req := request.(*types.SetChargingProfileRequestJson)
+	resp := response.(*types.SetChargingProfileResponseJson)
+
+	slog.Info("[TEST] in scp_result.go, got response:", resp, "[TEST] From request:", req)
+
+	return nil
+}

manager/handlers/ocpp201/trigger_message_result.go

@@ -4,6 +4,7 @@ package ocpp201
 
 import (
 	"context"
+
 	"github.com/thoughtworks/maeve-csms/manager/ocpp"
 	"github.com/thoughtworks/maeve-csms/manager/ocpp/ocpp201"
 	"github.com/thoughtworks/maeve-csms/manager/store"