openadr3.vtn.schema — energy.grid-coordination/clj-oa3-vtn 0.12.1

VTN-side entity coercion and notification payload construction.

Leverages clj-oa3's openadr3.entities for raw→coerced entity coercion. Provides additional helpers for building outbound notification payloads (the reverse direction: coerced/stored objects → wire-format notifications).

->event clj

->program clj

->subscription clj

coerce clj multimethod

Coerce a raw camelCase API map to a namespaced entity. Dispatches on :objectType ("PROGRAM", "EVENT", etc.).

coerce-stored clj

(coerce-stored stored-object)

Coerce a stored storage-canon object into a namespaced entity for VTN internal logic. Bridges from the VTN's ZDT/Duration shape to clj-oa3's string-bearing input form before delegating to entities/coerce.

coerce-stored-events clj

(coerce-stored-events events)

Coerce a sequence of stored event maps.

coerce-stored-programs clj

(coerce-stored-programs programs)

Coerce a sequence of stored program maps.

coerce-stored-subscriptions clj

(coerce-stored-subscriptions subscriptions)

Coerce a sequence of stored subscription maps.

Event clj

Notification clj

notification-payload clj

(notification-payload object-type operation object)

Build a wire-format notification map suitable for MQTT publishing.

Takes: object-type — string, e.g. "PROGRAM", "EVENT" operation — string, e.g. "CREATE", "UPDATE", "DELETE" object — the storage-canon entity (ZDT-bearing)

Returns a map matching the OpenADR notification schema: {:objectType "PROGRAM" :operation "CREATE" :object {... entity with ZDT/Duration fields ...}}

ZDTs and Durations are serialised to canonical UTC Z / ISO 8601 by the JSONWriter protocol extension when the payload is JSON-encoded for the wire.

NotificationPayload clj

Malli schema for an outbound notification (wire format, camelCase).

object-types clj

Valid OpenADR object types for notifications.

operations clj

Valid OpenADR notification operations.

Program clj

Subscription clj

validate-entity! clj

(validate-entity! entity)

Validate a stored entity against its storage-canon schema. Throws ex-info with :type :validation-error and Malli explanation on failure. Returns the entity unchanged on success.

validate-notification-payload clj

(validate-notification-payload payload)

Validate an outbound notification payload. Returns nil on success, Malli explanation on failure.

WireEvent clj

Malli schema for a stored event (storage canon, keyword keys, ZDT/Duration in time fields). GSI fields: programID (programID-index, programID-eventStart-index), intervalPeriod.start → eventStart (objectType-eventStart-index, programID-eventStart-index).

WireProgram clj

Malli schema for a stored program (storage canon, keyword keys, ZDT datetimes). GSI fields: programName (programName-index SK).

WireSubscription clj

Malli schema for a stored subscription (storage canon, keyword keys). GSI fields: clientName (query filter), programID (programID-index).