Changeset 18 for simplerunner/src/main/java/geniusweb

Timestamp:

06/11/20 16:34:40 (4 years ago)

Author:

bart

Message:

Update to version 1.41

File:

• simplerunner/src/main/java/geniusweb/simplerunner/NegoRunner.java (modified) (6 diffs)

simplerunner/src/main/java/geniusweb/simplerunner/NegoRunner.java

@@ -7 +7 @@
 import java.util.logging.Level;
 
+import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 
@@ -13 +14 @@
 import geniusweb.protocol.NegoProtocol;
 import geniusweb.protocol.NegoSettings;
+import geniusweb.protocol.NegoState;
 import geniusweb.protocol.partyconnection.ProtocolToPartyConnFactory;
-import tudelft.utilities.logging.ReportToLogger;
 import tudelft.utilities.logging.Reporter;
 
@@ -27 +28 @@
         private final NegoProtocol protocol;
         private final ProtocolToPartyConnFactory connectionfactory;
-        private final Reporter log;
+        protected final Reporter log;
         private final static ObjectMapper jackson = new ObjectMapper();
 
@@ -55 +56 @@
 
         protected void stop() {
-                if (protocol.getState().getError() != null) {
-                        log.log(Level.WARNING, "protocol terminated abnormally",
-                                        protocol.getState().getError());
-                } else {
-                        log.log(Level.INFO,
-                                        "protocol ended normally: " + protocol.getState());
+                Level level = protocol.getState().getError() == null ? Level.INFO
+                                : Level.WARNING;
+                logFinal(level, protocol.getState());
+        }
+
+        /**
+         * Separate so that we can intercept this when mocking, as this will crash
+         * on mocks
+         * 
+         * @param level
+         * @param state
+         */
+        protected void logFinal(Level level, NegoState state) {
+                try {
+                        log.log(level, "protocol ended normally: "
+                                        + jackson.writeValueAsString(protocol.getState()));
+                } catch (JsonProcessingException e) {
+                        e.printStackTrace();
                 }
         }
@@ -75 +88 @@
 
                 NegoRunner runner = new NegoRunner(settings,
-                                new ClassPathConnectionFactory(),
-                                new ReportToLogger("sessionrunner"));
+                                new ClassPathConnectionFactory(), new StdOutReporter());
                 runner.run();
         }
@@ -90 +102 @@
         }
 }
+
+class StdOutReporter implements Reporter {
+
+        @Override
+        public void log(Level arg0, String arg1) {
+                System.out.println(arg0 + ":" + arg1);
+        }
+
+        @Override
+        public void log(Level arg0, String arg1, Throwable arg2) {
+                System.out.println(arg0 + ">" + arg1);
+        }
+
+}