Changeset 9 for profileconnection/src

Timestamp:

11/28/19 14:40:48 (5 years ago)

Author:

bart

Message:

Release 1.1.0

Location:

profileconnection/src/main/java/geniusweb/profileconnection

Files:

• FileProfileConnector.java (modified) (2 diffs)
• ProfileInterface.java (modified) (1 diff)
• WebsocketProfileConnector.java (modified) (3 diffs)

profileconnection/src/main/java/geniusweb/profileconnection/FileProfileConnector.java

@@ -10 +10 @@
 
 import geniusweb.profile.Profile;
+import tudelft.utilities.listener.DefaultListenable;
 
 /**
  * ProfileInterface based on a plain filesystem UTF8 file.
  */
-public class FileProfileConnector implements ProfileInterface {
+public class FileProfileConnector extends DefaultListenable<Profile>
+                implements ProfileInterface {
         private final static ObjectMapper jackson = new ObjectMapper();
         private final Profile profile;
@@ -25 +27 @@
         public FileProfileConnector(String filename) throws IOException {
                 Path path = new File(filename).toPath();
-                String serialized = new String(Files.readAllBytes(path), StandardCharsets.UTF_8);
+                String serialized = new String(Files.readAllBytes(path),
+                                StandardCharsets.UTF_8);
                 profile = jackson.readValue(serialized, Profile.class);
         }

profileconnection/src/main/java/geniusweb/profileconnection/ProfileInterface.java

@@ -2 +2 @@
 
 import geniusweb.profile.Profile;
+import tudelft.utilities.listener.Listenable;
 
 /**
  * A container holding a modifyable profile. This interface allows testing.
  */
-public interface ProfileInterface {
+public interface ProfileInterface extends Listenable<Profile> {
 
         /**

profileconnection/src/main/java/geniusweb/profileconnection/WebsocketProfileConnector.java

@@ -15 +15 @@
 
 import geniusweb.profile.Profile;
+import tudelft.utilities.listener.DefaultListenable;
 import tudelft.utilities.logging.Reporter;
 
@@ -21 +22 @@
  */
 @ClientEndpoint
-public class WebsocketProfileConnector implements ProfileInterface {
+public class WebsocketProfileConnector extends DefaultListenable<Profile>
+                implements ProfileInterface {
         private final static ObjectMapper jackson = new ObjectMapper();
         private static final int TIMEOUT_MS = 2000;
@@ -56 +58 @@
                 // this will be called every time the profile changes.
                 logger.log(Level.FINE, "Received profile: " + message);
-                this.profile = jackson.readValue(message, Profile.class);
+                profile = jackson.readValue(message, Profile.class);
+                notifyListeners(profile);
         }