1 files changed, 125 insertions, 0 deletions
diff --git a/sources/protocols/VSProtocol.java b/sources/protocols/VSProtocol.java
new file mode 100644
index 0000000..b66f034
--- /dev/null
+++ b/sources/protocols/VSProtocol.java
@@ -0,0 +1,125 @@
+package protocols;
+
+import prefs.VSPrefs;
+import events.VSEvent;
+import core.*;
+
+abstract public class VSProtocol extends VSPrefs implements VSEvent {
+    protected VSPrefs prefs;
+    private String protocolClassname;
+    private boolean isServer;
+    private boolean isClient;
+    protected VSProcess process;
+    private boolean currentContextIsServer;
+    private boolean lamportIncreased;
+
+    public VSProtocol() {
+    }
+
+    protected final void setProtocolClassname(String protocolClassname) {
+        if (protocolClassname.startsWith("class "))
+            protocolClassname = protocolClassname.substring(6);
+
+        this.protocolClassname = protocolClassname;
+    }
+
+    public final String getProtocolClassname() {
+        return protocolClassname;
+    }
+
+    public final String getProtocolName() {
+        return RegisteredProtocols.getProtocolName(protocolClassname);
+    }
+
+    public final VSProcess getProcess() {
+        return process;
+    }
+
+    protected void sendMessage(VSMessage message) {
+        process.setLamportTime(process.getLamportTime()+1);
+        message.setSendingProcess(process);
+        process.sendMessage(message);
+    }
+
+    private final boolean isIncorrectProtocol(VSMessage message) {
+        return !message.getProtocolClassname().equals(getProtocolClassname());
+    }
+
+    public final void onStart() {
+        if (isClient) {
+            onClientStart();
+            currentContextIsServer = false;
+        }
+    }
+
+    public final void onMessageRecv(VSMessage message) {
+        if (isIncorrectProtocol(message))
+            return;
+
+        if (isServer) {
+            currentContextIsServer = true;
+            onServerRecv(message);
+        }
+
+        if (isClient) {
+            currentContextIsServer = false;
+            onClientRecv(message);
+        }
+    }
+
+    public final void isServer(boolean isServer) {
+        this.isServer = isServer;
+    }
+
+    public final void isClient(boolean isClient) {
+        this.isClient = isClient;
+    }
+
+    public final void setVSPrefs(VSPrefs prefs) {
+        this.prefs = prefs;
+    }
+
+    public final void setProcess(VSProcess process) {
+        this.process = process;
+    }
+
+    public void reset() {
+        if (isServer) {
+            currentContextIsServer = true;
+            onServerReset();
+        }
+
+        if (isClient) {
+            currentContextIsServer = false;
+            onClientReset();
+        }
+    }
+
+    abstract protected void onClientStart();
+    abstract protected void onClientReset();
+    abstract protected void onClientRecv(VSMessage message);
+
+    abstract protected void onServerReset();
+    abstract protected void onServerRecv(VSMessage message);
+
+    protected void logg(String message) {
+        process.logg(toString() + "; " + message);
+    }
+
+    public boolean equals(VSProtocol protocol) {
+        return protocol.getID() == getID();
+    }
+
+    public String toString() {
+        String type = new String();
+
+        if (currentContextIsServer)
+            type += prefs.getString("lang.server");
+
+        else
+            type += prefs.getString("lang.client");
+
+        return prefs.getString("lang.protocol") + ": "
+               + RegisteredProtocols.getProtocolName(getProtocolClassname()) + " " + type;// + "; ID: " + getID();
+    }
+}