Propagate code and reason from disconnect from server on client

Author: emilm

OCPP-J/src/main/java/eu/chargetime/ocpp/WebSocketReceiver.java

@@ -37,7 +37,7 @@ public WebSocketReceiver(WebSocketReceiverEvents handler) {
   @Override
   public void disconnect() {
     receiverEvents.close();
-    handler.disconnected();
+    handler.disconnected(0, "disconnect() method called");
   }
 
   void relay(String message) {

OCPP-J/src/main/java/eu/chargetime/ocpp/WebSocketTransmitter.java

@@ -105,7 +105,7 @@ public void onClose(int code, String reason, boolean remote) {
             logger.debug(
                 "On connection close (code: {}, reason: {}, remote: {})", code, reason, remote);
 
-            events.disconnected();
+            events.disconnected(code, reason);
           }
 
           @Override

ocpp-common/src/main/java/eu/chargetime/ocpp/Client.java

@@ -113,8 +113,8 @@ public void handleError(
           }
 
           @Override
-          public void handleConnectionClosed() {
-            if (events != null) events.connectionClosed();
+          public void handleConnectionClosed(int code, String reason) {
+            if (events != null) events.connectionClosed(code, reason);
           }
 
           @Override

ocpp-common/src/main/java/eu/chargetime/ocpp/ClientEvents.java

@@ -30,5 +30,5 @@ of this software and associated documentation files (the "Software"), to deal
 public interface ClientEvents {
   void connectionOpened();
 
-  void connectionClosed();
+  void connectionClosed(int code, String reason);
 }

ocpp-common/src/main/java/eu/chargetime/ocpp/Communicator.java

@@ -292,8 +292,8 @@ public void receivedMessage(Object input) {
     }
 
     @Override
-    public void disconnected() {
-      events.onDisconnected();
+    public void disconnected(int code, String reason) {
+      events.onDisconnected(code, reason);
     }
   }
 

ocpp-common/src/main/java/eu/chargetime/ocpp/CommunicatorEvents.java

@@ -66,8 +66,10 @@ public interface CommunicatorEvents {
    */
   void onError(String id, String errorCode, String errorDescription, Object payload);
 
-  /** The connection was disconnected. */
-  void onDisconnected();
+  /** The connection was disconnected.
+   * @param code
+   * @param reason*/
+  void onDisconnected(int code, String reason);
 
   /** A connection was established. */
   void onConnected();

ocpp-common/src/main/java/eu/chargetime/ocpp/RadioEvents.java

@@ -39,6 +39,8 @@ public interface RadioEvents {
    */
   void receivedMessage(Object message);
 
-  /** Disconnected from node. */
-  void disconnected();
+  /** Disconnected from node.
+   * @param code
+   * @param reason*/
+  void disconnected(int code, String reason);
 }

ocpp-common/src/main/java/eu/chargetime/ocpp/Server.java

@@ -143,7 +143,7 @@ public void handleError(
                   }
 
                   @Override
-                  public void handleConnectionClosed() {
+                  public void handleConnectionClosed(int code, String reason) {
                     Optional<UUID> sessionIdOptional = getSessionID(session);
                     if (sessionIdOptional.isPresent()) {
                       serverEvents.lostSession(sessionIdOptional.get());

ocpp-common/src/main/java/eu/chargetime/ocpp/Session.java

@@ -221,8 +221,8 @@ public void onError(String id, String errorCode, String errorDescription, Object
     }
 
     @Override
-    public void onDisconnected() {
-      events.handleConnectionClosed();
+    public void onDisconnected(int code, String reason) {
+      events.handleConnectionClosed(code, reason);
     }
 
     @Override

ocpp-common/src/main/java/eu/chargetime/ocpp/SessionEvents.java

@@ -59,8 +59,10 @@ public interface SessionEvents {
    */
   void handleError(String uniqueId, String errorCode, String errorDescription, Object payload);
 
-  /** Handle a closed connection. */
-  void handleConnectionClosed();
+  /** Handle a closed connection.
+   * @param code
+   * @param reason*/
+  void handleConnectionClosed(int code, String reason);
 
   /** Handle a opened connection. */
   void handleConnectionOpened();