Rename web_mqtt to web_ocpp

- remove mqtt protocol specific state
- remove keepalive
- remove credit_flow logic
- bind client_id param from URL
- handle/parse/decode OCPP JSON message and log it

Author: razvanphp

.gitignore

@@ -1 +1,22 @@
 test/config_schema_SUITE_data/schema/
+.DS_Store
+.sw?
+.*.sw?
+*.beam
+/.erlang.mk/
+/cover/
+/deps/
+/doc/
+/ebin/
+/escript/
+/escript.lock
+/logs/
+/plugins/
+/plugins.lock
+/sbin/
+/sbin.lock
+
+/rabbitmq_web_ocpp.d
+
+/.bazelrc
+/bazel-*

CODE_OF_CONDUCT.md

@@ -1,10 +1,10 @@
-PROJECT = rabbitmq_web_mqtt
-PROJECT_DESCRIPTION = RabbitMQ MQTT-over-WebSockets adapter
-PROJECT_MOD = rabbit_web_mqtt_app
+PROJECT = rabbitmq_web_ocpp
+PROJECT_DESCRIPTION = RabbitMQ OCPP-J-to-AMQP adapter
+PROJECT_MOD = rabbit_web_ocpp_app
 
 define PROJECT_ENV
 [
-	    {tcp_config, [{port, 15675}]},
+	    {tcp_config, [{port, 19520}]},
 	    {ssl_config, []},
 	    {num_tcp_acceptors, 10},
 	    {num_ssl_acceptors, 10},
@@ -13,30 +13,22 @@ define PROJECT_ENV
 	  ]
 endef
 
-# We do not need QUIC as dependency of emqtt.
-BUILD_WITHOUT_QUIC=1
-export BUILD_WITHOUT_QUIC
-
 LOCAL_DEPS = ssl
-DEPS = rabbit cowboy rabbitmq_mqtt
-TEST_DEPS = emqtt rabbitmq_ct_helpers rabbitmq_ct_client_helpers rabbitmq_management rabbitmq_stomp rabbitmq_consistent_hash_exchange
+DEPS = rabbit cowboy
+TEST_DEPS = rabbitmq_ct_helpers rabbitmq_ct_client_helpers rabbitmq_management rabbitmq_stomp rabbitmq_consistent_hash_exchange
 
-PLT_APPS += rabbitmqctl elixir cowlib
+PLT_APPS += rabbitmq_cli elixir cowlib
 
 # FIXME: Add Ranch as a BUILD_DEPS to be sure the correct version is picked.
 # See rabbitmq-components.mk.
 BUILD_DEPS += ranch
 
-dep_emqtt = git https://github.com/emqx/emqtt.git 1.11.0
-
 DEP_EARLY_PLUGINS = rabbit_common/mk/rabbitmq-early-plugin.mk
 DEP_PLUGINS = rabbit_common/mk/rabbitmq-plugin.mk
 
-include ../../rabbitmq-components.mk
-include ../../erlang.mk
-
-# We are using mqtt_shared_SUITE from rabbitmq_mqtt.
-CT_OPTS += -pa ../rabbitmq_mqtt/test/
+# The monorepo structure of RabbitMQ does not work for OOT plugins.
+DEPS_DIR ?= $(abspath ../rabbitmq-server/deps)
+ERLANG_MK_TMP ?= $(abspath ./.erlang.mk)
 
-test-build::
-	$(verbose) $(MAKE) -C ../rabbitmq_mqtt test-dir
+include ../rabbitmq-server/rabbitmq-components.mk
+include ../rabbitmq-server/erlang.mk

CONTRIBUTING.md

@@ -1,20 +1,20 @@
-# RabbitMQ Web MQTT plugin
+# RabbitMQ Web OCPP plugin
 
-This plugin provides support for MQTT-over-WebSockets to RabbitMQ.
+This plugin provides is a thin translator layer for OCPP-over-WebSockets to RabbitMQ AMQP protocol. Both version `1.6J` and `2.x` should be supported as the base JSON format array was kept backwards compatible, even tho many of the action names and payload are changed.
 
 ## Installation
 
-This plugin ships with modern versions of RabbitMQ.
+This plugin works only with modern versions of RabbitMQ 4.x based on AMQP 1.0.
 Like all plugins, it [must be enabled](https://www.rabbitmq.com/plugins.html) before it can be used:
 
 ``` bash
 # this might require sudo
-rabbitmq-plugins enable rabbitmq_web_mqtt
+rabbitmq-plugins enable rabbitmq_web_ocpp
 ```
 
 ## Documentation
 
-Please refer to the [RabbitMQ Web MQTT guide](https://www.rabbitmq.com/web-mqtt.html).
+For all configuration options, please refer to the nearly identical plugin, [RabbitMQ Web MQTT guide](https://www.rabbitmq.com/web-mqtt.html).
 
 
 ## Building From Source

Makefile

@@ -0,0 +1,100 @@
+%% This Source Code Form is subject to the terms of the Mozilla Public
+%% License, v. 2.0. If a copy of the MPL was not distributed with this
+%% file, You can obtain one at https://mozilla.org/MPL/2.0/.
+%%
+%% Copyright (c) 2025 VAMPIRE BYTE SRL. All Rights Reserved.
+%%
+
+-type option(T) :: undefined | T.
+
+%% WebSocket Subprotocol Name Registry
+%% https://www.iana.org/assignments/websocket/websocket.xml
+-define(OCPP_SUPPORTED_PROTOCOLS, [<<"ocpp1.2">>, <<"ocpp1.5">>, <<"ocpp1.6">>, <<"ocpp2.0">>, <<"ocpp2.0.1">>, <<"ocpp2.1">>]).
+
+-define(OCPP_PROTO_V12, ocpp12).
+-define(OCPP_PROTO_V15, ocpp15).
+-define(OCPP_PROTO_V16, ocpp16).
+-define(OCPP_PROTO_V20, ocpp20).
+-define(OCPP_PROTO_V201, ocpp201).
+-define(OCPP_PROTO_V21, ocpp21).
+
+-type ocpp_protocol_version_atom() ::
+        ?OCPP_PROTO_V12
+        | ?OCPP_PROTO_V15
+        | ?OCPP_PROTO_V16
+        | ?OCPP_PROTO_V20
+        | ?OCPP_PROTO_V201
+        | ?OCPP_PROTO_V21.
+
+-define(OCPP_MESSAGE_TYPE_CALL, 2). % Request
+-define(OCPP_MESSAGE_TYPE_CALLRESULT, 3). % Response success
+-define(OCPP_MESSAGE_TYPE_CALLERROR, 4). % Response error
+-define(OCPP_MESSAGE_TYPE_CALLRESULTERROR, 5). % OCPP 2.1 only
+-define(OCPP_MESSAGE_TYPE_SEND, 6). % OCPP 2.1 only
+
+-define(ITEMS,
+        [pid,
+         protocol,
+         host,
+         port,
+         peer_host,
+         peer_port,
+         ssl,
+         ssl_protocol,
+         ssl_key_exchange,
+         ssl_cipher,
+         ssl_hash,
+         vhost,
+         user
+        ]).
+
+-define(INFO_ITEMS,
+        ?ITEMS ++
+        [
+         client_id,
+         conn_name,
+         user_property,
+         connection_state,
+         ssl_login_name,
+         recv_cnt,
+         recv_oct,
+         send_cnt,
+         send_oct,
+         send_pend,
+         clean_sess,
+         will_msg,
+         retainer_pid,
+         exchange,
+         prefetch,
+         messages_unconfirmed,
+         messages_unacknowledged
+        ]).
+
+%% Connection opened or closed.
+-define(EVENT_KEYS,
+        ?ITEMS ++
+        [name,
+         client_properties,
+         peer_cert_issuer,
+         peer_cert_subject,
+         peer_cert_validity,
+         auth_mechanism,
+         timeout,
+         frame_max,
+         channel_max,
+         connected_at,
+         node,
+         user_who_performed_action
+        ]).
+
+-define(SIMPLE_METRICS,
+        [pid,
+         recv_oct,
+         send_oct,
+         reductions]).
+-define(OTHER_METRICS,
+        [recv_cnt,
+         send_cnt,
+         send_pend,
+         garbage_collection,
+         state]).