ocppj

package
v0.1.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 18, 2026 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

Package ocppj implements OCPP-J (JSON over WebSocket) framing.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrConnClosed       = errors.New("ocpp: connection closed")
	ErrConnDropped      = errors.New("ocpp: connection dropped")
	ErrNotConnected     = errors.New("ocpp: not connected")
	ErrAlreadyConnected = errors.New("ocpp: already connected")

	ErrCallTimeout         = errors.New("ocpp: call timeout")
	ErrCallCancelled       = errors.New("ocpp: call cancelled")
	ErrQueueFull           = errors.New("ocpp: outbound queue full")
	ErrConcurrentCallLimit = errors.New("ocpp: concurrent call limit exceeded")

	ErrUnknownAction        = errors.New("ocpp: unknown action")
	ErrHandlerNotRegistered = errors.New("ocpp: handler not registered")
	ErrInvalidDirection     = errors.New("ocpp: invalid message direction")
	ErrDuplicateHandler     = errors.New("ocpp: handler already registered")

	ErrUnsupportedVersion = errors.New("ocpp: unsupported version")
	ErrVersionMismatch    = errors.New("ocpp: version mismatch on connection")
)

Functions

func EncodeCall 

func EncodeCall(msgID, action string, payload []byte) ([]byte, error)

EncodeCall builds a [2, msgID, action, payload] frame.

func EncodeCallError 

func EncodeCallError(msgID, code, desc string, details []byte) ([]byte, error)

EncodeCallError builds a [4, msgID, code, desc, details] frame.

func EncodeCallResult 

func EncodeCallResult(msgID string, payload []byte) ([]byte, error)

EncodeCallResult builds a [3, msgID, payload] frame.

func NewMsgID 

func NewMsgID() string

NewMsgID returns a unique, lexicographically sortable message ID.

Types

type CallError 

type CallError struct {
	Code        ErrorCode
	Description string
	Details     map[string]any
	// contains filtered or unexported fields
}

CallError is an OCPP-J error response (MessageType 4).

func NewCallError 

func NewCallError(code ErrorCode, desc string, details map[string]any) *CallError

NewCallError builds a CallError.

func WrapCallError 

func WrapCallError(code ErrorCode, cause error, details map[string]any) *CallError

WrapCallError builds a CallError wrapping an underlying cause.

func (*CallError) Error 

func (e *CallError) Error() string

func (*CallError) Unwrap 

func (e *CallError) Unwrap() error

func (*CallError) WireCode 

func (e *CallError) WireCode(v Version) string

WireCode returns the on-the-wire error code string, applying the OCPP 1.6 spec's misspelled OccurenceConstraintViolation code for 1.6 connections. //nolint:misspell // OCPP 1.6 spec wire spelling

type Direction 

type Direction int

Direction indicates which peer originates a given action. 

const (
	SentByCP   Direction = iota + 1 // Charge Point initiates (e.g. BootNotification)
	SentByCSMS                      // Central System initiates (e.g. ChangeConfiguration)
	SentByBoth                      // either peer may initiate (e.g. DataTransfer)
)

func (Direction) String 

func (d Direction) String() string

type ErrorCode 

type ErrorCode string

ErrorCode is an OCPP-J CallError code. 

const (
	ErrorCodeNotImplemented                ErrorCode = "NotImplemented"
	ErrorCodeNotSupported                  ErrorCode = "NotSupported"
	ErrorCodeInternalError                 ErrorCode = "InternalError"
	ErrorCodeProtocolError                 ErrorCode = "ProtocolError"
	ErrorCodeSecurityError                 ErrorCode = "SecurityError"
	ErrorCodeFormatViolation               ErrorCode = "FormatViolation"    // 2.x
	ErrorCodeFormationViolation            ErrorCode = "FormationViolation" // 1.6
	ErrorCodePropertyConstraintViolation   ErrorCode = "PropertyConstraintViolation"
	ErrorCodeOccurenceConstraintViolation  ErrorCode = "OccurenceConstraintViolation"  //nolint:misspell // OCPP 1.6 spec wire spelling
	ErrorCodeOccurrenceConstraintViolation ErrorCode = "OccurrenceConstraintViolation" // 2.x
	ErrorCodeTypeConstraintViolation       ErrorCode = "TypeConstraintViolation"
	ErrorCodeGenericError                  ErrorCode = "GenericError"
	ErrorCodeMessageTypeNotSupported       ErrorCode = "MessageTypeNotSupported" // 2.x
	ErrorCodeRPCFrameworkError             ErrorCode = "RpcFrameworkError"       // 2.x
)

type Frame 

type Frame struct {
	Type    MessageType
	MsgID   string
	Action  string // Call only
	Payload []byte // Call / CallResult: raw JSON object
	ErrCode string // CallError only
	ErrDesc string // CallError only
	ErrData []byte // CallError only: raw JSON object
}

Frame is a parsed OCPP-J message.

func Parse 

func Parse(raw []byte) (Frame, error)

Parse decodes a raw OCPP-J message into a Frame.

type Message 

type Message[Req, Resp any] struct {
	Action    string
	Direction Direction
}

Message binds an OCPP action to its request and response types at compile time. Generated code creates package-level Message values; user code passes them to On/Call so Req/Resp are inferred.

type MessageType 

type MessageType int

MessageType is the OCPP-J MessageTypeId (first array element). 

const (
	Call                 MessageType = 2
	CallResult           MessageType = 3
	MessageTypeCallError MessageType = 4
)

func (MessageType) String 

func (m MessageType) String() string

type ProtocolError 

type ProtocolError struct {
	Stage   string // "parse", "type", "shape"
	Raw     string
	Message string
}

ProtocolError indicates an OCPP-J frame that does not conform to the wire format.

func (*ProtocolError) Error 

func (e *ProtocolError) Error() string

type Version 

type Version string

Version identifies an OCPP protocol version. 

const (
	V16  Version = "1.6"
	V201 Version = "2.0.1"
	V21  Version = "2.1"
)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.