feat: Add OCPP 2.1 support (Phase B - Core foundation)

Initial implementation of OCPP 2.1 protocol support including:

**Types package (ocpp2.1/types/):**
- CustomDataType for vendor extensions (new in 2.1)
- Extended AuthorizationStatus, IdTokenType enums
- ChargingProfile types with new PriorityCharging, LocalGeneration, Dynamic
- MeterValue/SampledValue with 50+ Measurand values
- EnergyTransferMode enum (11 modes including BPT, DER, WPT)
- AuthorizeCertificateStatus enum (7 values)
- All validators registered with "21" suffix

**Provisioning package:**
- BootNotification, Reset (with ImmediateAndResume)
- GetBaseReport, GetReport, NotifyReport
- GetVariables, SetVariables
- SetNetworkProfile (with identity, basicAuthPassword fields)

**Authorization package:**
- Authorize (with certificate support, AllowedEnergyTransfer)
- ClearCache

**Availability package:**
- Heartbeat, StatusNotification, ChangeAvailability

**Data package:**
- DataTransfer

All types conform to OCPP 2.1 JSON schemas with correct:
- Field names and JSON tags
- MaxLength constraints
- Required/optional field handling
- Enum values

Closes #337

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: andig

ocpp2.1/authorization/authorization.go

@@ -0,0 +1,29 @@
+// Package authorization contains the authorization functional block for OCPP 2.1.
+// It contains different ways of authorizing a user, online and/or offline.
+package authorization
+
+import "github.com/lorenzodonini/ocpp-go/ocpp"
+
+// ProfileName is the name of the authorization functional block.
+const ProfileName = "authorization"
+
+// ChargingStationHandler contains callbacks for handling incoming CSMS requests.
+type ChargingStationHandler interface {
+	// OnClearCache handles a ClearCacheRequest from the CSMS.
+	OnClearCache(request *ClearCacheRequest) (response *ClearCacheResponse, err error)
+}
+
+// CSMSHandler contains callbacks for handling incoming Charging Station requests.
+type CSMSHandler interface {
+	// OnAuthorize handles an AuthorizeRequest from a Charging Station.
+	OnAuthorize(chargingStationID string, request *AuthorizeRequest) (response *AuthorizeResponse, err error)
+}
+
+// Profile returns the authorization profile with all features.
+func Profile() *ocpp.Profile {
+	return ocpp.NewProfile(
+		ProfileName,
+		AuthorizeFeature{},
+		ClearCacheFeature{},
+	)
+}

ocpp2.1/authorization/authorize.go

@@ -0,0 +1,60 @@
+package authorization
+
+import (
+	"reflect"
+
+	"github.com/lorenzodonini/ocpp-go/ocpp2.1/types"
+)
+
+// -------------------- Authorize (CS -> CSMS) --------------------
+
+const AuthorizeFeatureName = "Authorize"
+
+// AuthorizeRequest is the payload for an Authorize request from CS to CSMS.
+type AuthorizeRequest struct {
+	IdToken                     types.IdToken               `json:"idToken" validate:"required"`
+	Certificate                 string                      `json:"certificate,omitempty" validate:"omitempty,max=10000"`
+	ISO15118CertificateHashData []types.OCSPRequestDataType `json:"iso15118CertificateHashData,omitempty" validate:"omitempty,max=4,dive"`
+	CustomData                  *types.CustomDataType       `json:"customData,omitempty" validate:"omitempty"`
+}
+
+// AuthorizeResponse is the payload for an Authorize response from CSMS to CS.
+type AuthorizeResponse struct {
+	CertificateStatus     types.AuthorizeCertificateStatus `json:"certificateStatus,omitempty" validate:"omitempty,authorizeCertificateStatus21"`
+	IdTokenInfo           types.IdTokenInfo                `json:"idTokenInfo" validate:"required"`
+	AllowedEnergyTransfer []types.EnergyTransferMode       `json:"allowedEnergyTransfer,omitempty" validate:"omitempty,dive,energyTransferMode21"`
+	CustomData            *types.CustomDataType            `json:"customData,omitempty" validate:"omitempty"`
+}
+
+// AuthorizeFeature represents the Authorize feature.
+type AuthorizeFeature struct{}
+
+func (f AuthorizeFeature) GetFeatureName() string {
+	return AuthorizeFeatureName
+}
+
+func (f AuthorizeFeature) GetRequestType() reflect.Type {
+	return reflect.TypeOf(AuthorizeRequest{})
+}
+
+func (f AuthorizeFeature) GetResponseType() reflect.Type {
+	return reflect.TypeOf(AuthorizeResponse{})
+}
+
+func (r AuthorizeRequest) GetFeatureName() string {
+	return AuthorizeFeatureName
+}
+
+func (c AuthorizeResponse) GetFeatureName() string {
+	return AuthorizeFeatureName
+}
+
+// NewAuthorizeRequest creates a new AuthorizeRequest.
+func NewAuthorizeRequest(idToken string, tokenType types.IdTokenType) *AuthorizeRequest {
+	return &AuthorizeRequest{IdToken: types.IdToken{IdToken: idToken, Type: tokenType}}
+}
+
+// NewAuthorizeResponse creates a new AuthorizeResponse.
+func NewAuthorizeResponse(idTokenInfo types.IdTokenInfo) *AuthorizeResponse {
+	return &AuthorizeResponse{IdTokenInfo: idTokenInfo}
+}

ocpp2.1/authorization/clear_cache.go

@@ -0,0 +1,80 @@
+package authorization
+
+import (
+	"reflect"
+
+	"gopkg.in/go-playground/validator.v9"
+
+	"github.com/lorenzodonini/ocpp-go/ocpp2.1/types"
+)
+
+// -------------------- Clear Cache (CSMS -> CS) --------------------
+
+const ClearCacheFeatureName = "ClearCache"
+
+// ClearCacheStatus represents the status of a clear cache request.
+type ClearCacheStatus string
+
+const (
+	ClearCacheStatusAccepted ClearCacheStatus = "Accepted"
+	ClearCacheStatusRejected ClearCacheStatus = "Rejected"
+)
+
+func isValidClearCacheStatus(fl validator.FieldLevel) bool {
+	s := ClearCacheStatus(fl.Field().String())
+	switch s {
+	case ClearCacheStatusAccepted, ClearCacheStatusRejected:
+		return true
+	default:
+		return false
+	}
+}
+
+// ClearCacheRequest is the payload for a ClearCache request from CSMS to CS.
+type ClearCacheRequest struct {
+	CustomData *types.CustomDataType `json:"customData,omitempty" validate:"omitempty"`
+}
+
+// ClearCacheResponse is the payload for a ClearCache response from CS to CSMS.
+type ClearCacheResponse struct {
+	Status     ClearCacheStatus      `json:"status" validate:"required,clearCacheStatus21"`
+	StatusInfo *types.StatusInfo     `json:"statusInfo,omitempty" validate:"omitempty"`
+	CustomData *types.CustomDataType `json:"customData,omitempty" validate:"omitempty"`
+}
+
+// ClearCacheFeature represents the ClearCache feature.
+type ClearCacheFeature struct{}
+
+func (f ClearCacheFeature) GetFeatureName() string {
+	return ClearCacheFeatureName
+}
+
+func (f ClearCacheFeature) GetRequestType() reflect.Type {
+	return reflect.TypeOf(ClearCacheRequest{})
+}
+
+func (f ClearCacheFeature) GetResponseType() reflect.Type {
+	return reflect.TypeOf(ClearCacheResponse{})
+}
+
+func (r ClearCacheRequest) GetFeatureName() string {
+	return ClearCacheFeatureName
+}
+
+func (c ClearCacheResponse) GetFeatureName() string {
+	return ClearCacheFeatureName
+}
+
+// NewClearCacheRequest creates a new ClearCacheRequest.
+func NewClearCacheRequest() *ClearCacheRequest {
+	return &ClearCacheRequest{}
+}
+
+// NewClearCacheResponse creates a new ClearCacheResponse.
+func NewClearCacheResponse(status ClearCacheStatus) *ClearCacheResponse {
+	return &ClearCacheResponse{Status: status}
+}
+
+func init() {
+	_ = types.Validate.RegisterValidation("clearCacheStatus21", isValidClearCacheStatus)
+}

ocpp2.1/availability/availability.go

@@ -0,0 +1,32 @@
+// Package availability contains the availability functional block for OCPP 2.1.
+// It contains features for notifying the CSMS of availability and status changes.
+package availability
+
+import "github.com/lorenzodonini/ocpp-go/ocpp"
+
+// ProfileName is the name of the availability functional block.
+const ProfileName = "availability"
+
+// ChargingStationHandler contains callbacks for handling incoming CSMS requests.
+type ChargingStationHandler interface {
+	// OnChangeAvailability handles a ChangeAvailabilityRequest from the CSMS.
+	OnChangeAvailability(request *ChangeAvailabilityRequest) (response *ChangeAvailabilityResponse, err error)
+}
+
+// CSMSHandler contains callbacks for handling incoming Charging Station requests.
+type CSMSHandler interface {
+	// OnHeartbeat handles a HeartbeatRequest from a Charging Station.
+	OnHeartbeat(chargingStationID string, request *HeartbeatRequest) (response *HeartbeatResponse, err error)
+	// OnStatusNotification handles a StatusNotificationRequest from a Charging Station.
+	OnStatusNotification(chargingStationID string, request *StatusNotificationRequest) (response *StatusNotificationResponse, err error)
+}
+
+// Profile returns the availability profile with all features.
+func Profile() *ocpp.Profile {
+	return ocpp.NewProfile(
+		ProfileName,
+		ChangeAvailabilityFeature{},
+		HeartbeatFeature{},
+		StatusNotificationFeature{},
+	)
+}

ocpp2.1/availability/change_availability.go

@@ -0,0 +1,102 @@
+package availability
+
+import (
+	"reflect"
+
+	"gopkg.in/go-playground/validator.v9"
+
+	"github.com/lorenzodonini/ocpp-go/ocpp2.1/types"
+)
+
+// -------------------- Change Availability (CSMS -> CS) --------------------
+
+const ChangeAvailabilityFeatureName = "ChangeAvailability"
+
+// OperationalStatus represents the requested operational status.
+type OperationalStatus string
+
+const (
+	OperationalStatusInoperative OperationalStatus = "Inoperative"
+	OperationalStatusOperative   OperationalStatus = "Operative"
+)
+
+func isValidOperationalStatus(fl validator.FieldLevel) bool {
+	s := OperationalStatus(fl.Field().String())
+	switch s {
+	case OperationalStatusInoperative, OperationalStatusOperative:
+		return true
+	default:
+		return false
+	}
+}
+
+// ChangeAvailabilityStatus represents the response status.
+type ChangeAvailabilityStatus string
+
+const (
+	ChangeAvailabilityStatusAccepted  ChangeAvailabilityStatus = "Accepted"
+	ChangeAvailabilityStatusRejected  ChangeAvailabilityStatus = "Rejected"
+	ChangeAvailabilityStatusScheduled ChangeAvailabilityStatus = "Scheduled"
+)
+
+func isValidChangeAvailabilityStatus(fl validator.FieldLevel) bool {
+	s := ChangeAvailabilityStatus(fl.Field().String())
+	switch s {
+	case ChangeAvailabilityStatusAccepted, ChangeAvailabilityStatusRejected, ChangeAvailabilityStatusScheduled:
+		return true
+	default:
+		return false
+	}
+}
+
+// ChangeAvailabilityRequest is the payload for a ChangeAvailability request from CSMS to CS.
+type ChangeAvailabilityRequest struct {
+	OperationalStatus OperationalStatus     `json:"operationalStatus" validate:"required,operationalStatus21"`
+	EVSE              *types.EVSE           `json:"evse,omitempty" validate:"omitempty"`
+	CustomData        *types.CustomDataType `json:"customData,omitempty" validate:"omitempty"`
+}
+
+// ChangeAvailabilityResponse is the payload for a ChangeAvailability response from CS to CSMS.
+type ChangeAvailabilityResponse struct {
+	Status     ChangeAvailabilityStatus `json:"status" validate:"required,changeAvailabilityStatus21"`
+	StatusInfo *types.StatusInfo        `json:"statusInfo,omitempty" validate:"omitempty"`
+	CustomData *types.CustomDataType    `json:"customData,omitempty" validate:"omitempty"`
+}
+
+// ChangeAvailabilityFeature represents the ChangeAvailability feature.
+type ChangeAvailabilityFeature struct{}
+
+func (f ChangeAvailabilityFeature) GetFeatureName() string {
+	return ChangeAvailabilityFeatureName
+}
+
+func (f ChangeAvailabilityFeature) GetRequestType() reflect.Type {
+	return reflect.TypeOf(ChangeAvailabilityRequest{})
+}
+
+func (f ChangeAvailabilityFeature) GetResponseType() reflect.Type {
+	return reflect.TypeOf(ChangeAvailabilityResponse{})
+}
+
+func (r ChangeAvailabilityRequest) GetFeatureName() string {
+	return ChangeAvailabilityFeatureName
+}
+
+func (c ChangeAvailabilityResponse) GetFeatureName() string {
+	return ChangeAvailabilityFeatureName
+}
+
+// NewChangeAvailabilityRequest creates a new ChangeAvailabilityRequest.
+func NewChangeAvailabilityRequest(operationalStatus OperationalStatus) *ChangeAvailabilityRequest {
+	return &ChangeAvailabilityRequest{OperationalStatus: operationalStatus}
+}
+
+// NewChangeAvailabilityResponse creates a new ChangeAvailabilityResponse.
+func NewChangeAvailabilityResponse(status ChangeAvailabilityStatus) *ChangeAvailabilityResponse {
+	return &ChangeAvailabilityResponse{Status: status}
+}
+
+func init() {
+	_ = types.Validate.RegisterValidation("operationalStatus21", isValidOperationalStatus)
+	_ = types.Validate.RegisterValidation("changeAvailabilityStatus21", isValidChangeAvailabilityStatus)
+}

ocpp2.1/availability/heartbeat.go

@@ -0,0 +1,55 @@
+package availability
+
+import (
+	"reflect"
+
+	"github.com/lorenzodonini/ocpp-go/ocpp2.1/types"
+)
+
+// -------------------- Heartbeat (CS -> CSMS) --------------------
+
+const HeartbeatFeatureName = "Heartbeat"
+
+// HeartbeatRequest is the payload for a Heartbeat request from CS to CSMS.
+type HeartbeatRequest struct {
+	CustomData *types.CustomDataType `json:"customData,omitempty" validate:"omitempty"`
+}
+
+// HeartbeatResponse is the payload for a Heartbeat response from CSMS to CS.
+type HeartbeatResponse struct {
+	CurrentTime types.DateTime        `json:"currentTime" validate:"required"`
+	CustomData  *types.CustomDataType `json:"customData,omitempty" validate:"omitempty"`
+}
+
+// HeartbeatFeature represents the Heartbeat feature.
+type HeartbeatFeature struct{}
+
+func (f HeartbeatFeature) GetFeatureName() string {
+	return HeartbeatFeatureName
+}
+
+func (f HeartbeatFeature) GetRequestType() reflect.Type {
+	return reflect.TypeOf(HeartbeatRequest{})
+}
+
+func (f HeartbeatFeature) GetResponseType() reflect.Type {
+	return reflect.TypeOf(HeartbeatResponse{})
+}
+
+func (r HeartbeatRequest) GetFeatureName() string {
+	return HeartbeatFeatureName
+}
+
+func (c HeartbeatResponse) GetFeatureName() string {
+	return HeartbeatFeatureName
+}
+
+// NewHeartbeatRequest creates a new HeartbeatRequest.
+func NewHeartbeatRequest() *HeartbeatRequest {
+	return &HeartbeatRequest{}
+}
+
+// NewHeartbeatResponse creates a new HeartbeatResponse.
+func NewHeartbeatResponse(currentTime types.DateTime) *HeartbeatResponse {
+	return &HeartbeatResponse{CurrentTime: currentTime}
+}