Initial commit

1 files changed, 395 insertions, 0 deletions

diff --git a/NET/worlds/console/VoiceChat.java b/NET/worlds/console/VoiceChat.java
new file mode 100644
index 0000000..bf52f71
--- /dev/null
+++ b/NET/worlds/console/VoiceChat.java
@@ -0,0 +1,395 @@
+package NET.worlds.console;
+
+import NET.worlds.core.IniFile;
+import NET.worlds.network.URL;
+import NET.worlds.scape.CDAudio;
+import NET.worlds.scape.Pilot;
+import NET.worlds.scape.WavSoundPlayer;
+import java.io.File;
+import java.io.IOException;
+import java.net.InetAddress;
+import java.text.MessageFormat;
+
+public class VoiceChat implements DialogReceiver {
+   private static final String SPEAKFREELY = "sfmain.exe";
+   private static final int INITIAL_STATE = 0;
+   private static final int BEGINNING_CONNECTION = 1;
+   private static final int REQUESTING_CONNECTION = 2;
+   private static final int ATTEMPTING_CONNECTION = 3;
+   private static final int SUCCESSFULLY_CONNECTED = 4;
+   private static final int CONNECTION_FAILED_RESETTING = 5;
+   private static final int CLOSING_CONNECTION = 6;
+   private static final int CONNECTION_CLOSED_RESETTING = 7;
+   private static final String[] _stateStrs = new String[]{
+      "Initial State",
+      "Beginning Connection",
+      "Attempting Connection",
+      "Successfully Connected",
+      "Resetting (Connection Failed)",
+      "Closing Connection",
+      "Resetting (Connection Closed)"
+   };
+   private int _state = 0;
+   private String _error = "";
+   private static boolean _selfWhisper = false;
+   public static String VCdebugCommand = "&|+debug>VCcommand=";
+   public static String VCdebugCommandReset = "&|+debug>VCcommandReset=";
+   private static String _extraCommand = "";
+   private static GammaPhoneMonitor chatMonitor = null;
+   private String _who = null;
+   public static UpdateableDialog voiceChatDialog;
+   private static UpdateableDialog voiceChatQueryDialog;
+   private static String voiceChatQueryIP;
+   private static String voiceChatQueryWho;
+   public static boolean voiceChatEnabled = IniFile.gamma().getIniInt("VoiceChat", voiceChatAvailable() ? 1 : 0) != 0;
+   private static boolean voiceChatExeChecked = false;
+   private static boolean voiceChatExists = false;
+   private int _gammaphoneWindow = 0;
+   DefaultConsole _console = null;
+   VCTimerThread _vtimer = null;
+   private static final String voiceChatQuery = "&|+voicechat?";
+   private static final String voiceChatAccept = "&|+voicechat>accept";
+   private static final String voiceChatReject = "&|+voicechat>reject";
+   private static final String voiceChatBusy = "&|+voicechat>busy";
+   private static final String voiceChatNotVIP = "&|+voicechat>notvip";
+   private static final String voiceChatDisabled = "&|+voicechat>disabled";
+
+   public int getState() {
+      return this._state;
+   }
+
+   public String getStateString() {
+      return _stateStrs[this._state];
+   }
+
+   public String getLastError() {
+      return this._error;
+   }
+
+   public static void activateSelfWhisper() {
+      _selfWhisper = true;
+      Console.println(Console.message("Selfwhisper-on"));
+   }
+
+   public static void deactivateSelfWhisper() {
+      _selfWhisper = false;
+      Console.println(Console.message("Selfwhisper-off"));
+   }
+
+   public static void setExtra(String text) {
+      int start = text.indexOf(34) + 1;
+      int end = text.lastIndexOf(34);
+      _extraCommand = text.substring(start, end);
+      Object[] arguments = new Object[]{new String(_extraCommand)};
+      Console.println(MessageFormat.format(Console.message("Add-VoiceChat"), arguments));
+   }
+
+   public static void resetExtra() {
+      _extraCommand = "";
+      Console.println(Console.message("VoiceChat-reset"));
+   }
+
+   public String who() {
+      return this._who;
+   }
+
+   public static void setVoiceChatEnabled(boolean f) {
+      if (!voiceChatAvailable()) {
+         f = false;
+      }
+
+      voiceChatEnabled = f;
+      IniFile.gamma().setIniInt("VoiceChat", f ? 1 : 0);
+   }
+
+   public static boolean voiceChatAvailable() {
+      if (voiceChatExeChecked) {
+         return voiceChatExists;
+      } else {
+         URL vcexe = URL.make("home:sfmain.exe");
+         String fname = vcexe.unalias();
+         File f = new File(fname);
+         voiceChatExists = f.exists();
+         voiceChatExeChecked = true;
+         return voiceChatExists;
+      }
+   }
+
+   public void registerProcess(int id) {
+      this._gammaphoneWindow = id;
+   }
+
+   public void beginChat(String friendName, DefaultConsole console) {
+      this._state = 1;
+      this._console = console;
+      if (!console.getVIP()) {
+         this.resetConnection(Console.message("must-be-VIP"));
+      } else {
+         String ip = null;
+
+         try {
+            InetAddress localAddr = console.getServerNew().getLocalAddress();
+            ip = localAddr != null ? localAddr.toString() : null;
+            ip = ip.substring(ip.indexOf(47) + 1);
+         } catch (SecurityException var7) {
+            this.resetConnection(Console.message("sec-violation"));
+         }
+
+         if (ip == null) {
+            this.resetConnection(Console.message("cant-determine-IP"));
+         } else {
+            if (voiceChatDialog != null) {
+               if (friendName.equals(this._who)) {
+                  Object[] arguments = new Object[]{new String(this._who)};
+                  Console.println(MessageFormat.format(Console.message("already-VoiceChat"), arguments));
+                  return;
+               }
+
+               this.resetConnection(Console.message("chat-ended"));
+            }
+
+            if (voiceChatQueryDialog != null && voiceChatQueryWho.equals(friendName)) {
+               Object[] arguments = new Object[]{new String(friendName)};
+               Console.println(MessageFormat.format(Console.message("already-calling"), arguments));
+               return;
+            }
+
+            while (ConnectionRecord.checkList(this._who)) {
+               Object[] arguments = new Object[]{new String(this._who)};
+               Console.println(MessageFormat.format(Console.message("wait-a-few"), arguments));
+
+               try {
+                  Thread.sleep(2000L);
+               } catch (InterruptedException var6) {
+               }
+            }
+
+            if (this.initiateVoiceChat(friendName, null)) {
+               Object[] arguments = new Object[]{new String(friendName), new String(ip)};
+               Console.println(MessageFormat.format(Console.message("Asking-to-call"), arguments));
+               this._state = 2;
+               this.sendWhisper(friendName, "&|+voicechat?" + ip);
+               this._vtimer = new VCTimerThread(this, 30000L);
+               this._vtimer.start();
+            }
+         }
+      }
+   }
+
+   private static native void terminateVC(int var0);
+
+   private boolean initiateVoiceChat(String friendName, String ip) {
+      this._who = friendName;
+      int hWnd = Window.getHWnd();
+      String startString = URL.make(
+            "home:sfmain.exe" + (ip == null ? " -a " : " -c " + ip) + " -g " + hWnd + " -p " + Window.getGammaProcessID() + " " + _extraCommand + " "
+         )
+         .unalias();
+      WavSoundPlayer.pauseSystem();
+      CDAudio.get().setEnabled(false);
+      if (tryToRun(startString)) {
+         Object[] arguments = new Object[]{new String(this._who)};
+         voiceChatDialog = new UpdateableDialog(
+            Console.getFrame(),
+            this,
+            Console.message("Voice-connect"),
+            null,
+            Console.message("Terminate"),
+            MessageFormat.format(Console.message("end-VoiceChat"), arguments),
+            false
+         );
+         if (chatMonitor == null) {
+            chatMonitor = new GammaPhoneMonitor(this);
+            chatMonitor.start();
+         }
+
+         return true;
+      } else {
+         WavSoundPlayer.resumeSystem();
+         CDAudio.get().setEnabled(true);
+         Object[] arguments = new Object[]{new String(this._who), new String(startString)};
+         voiceChatDialog = new UpdateableDialog(
+            Console.getFrame(),
+            this,
+            Console.message("Voice-Chat-199"),
+            null,
+            Console.message("Continue"),
+            MessageFormat.format(Console.message("Unable-to-chat"), arguments),
+            false
+         );
+         return false;
+      }
+   }
+
+   public void inform(int msgid, String msg) {
+      if (msgid >= 900) {
+         if (voiceChatDialog == null) {
+            return;
+         }
+
+         voiceChatDialog.setTitle(Console.message("VoiceChat-Connected"));
+         this._state = 4;
+      } else {
+         this.resetConnection(msg);
+      }
+   }
+
+   public boolean handleChatRequest(String user, String text, DefaultConsole console) {
+      Object[] arguments = new Object[]{new String(user)};
+      if (!console.getVIP()) {
+         Console.println(MessageFormat.format(Console.message("reject-chat"), arguments));
+         this.sendWhisper(user, "&|+voicechat>notvip");
+      } else if (!voiceChatEnabled) {
+         Console.println(MessageFormat.format(Console.message("chat-disabled"), arguments));
+         this.sendWhisper(user, "&|+voicechat>disabled");
+      } else if (voiceChatQueryDialog != null) {
+         this.sendWhisper(user, "&|+voicechat>busy");
+      } else {
+         voiceChatQueryIP = text.substring("&|+voicechat?".length());
+         voiceChatQueryWho = user;
+         voiceChatQueryDialog = new UpdateableDialog(
+            Console.getFrame(),
+            this,
+            Console.message("Accept-voice"),
+            Console.message("Reject"),
+            Console.message("Accept"),
+            MessageFormat.format(Console.message("do-you-voice"), arguments),
+            false
+         );
+      }
+
+      return true;
+   }
+
+   public boolean handleChatWhisper(String user, String whisper, DefaultConsole console) {
+      Object[] arguments = new Object[]{new String(user)};
+      if (whisper.startsWith("&|+voicechat?")) {
+         this.handleChatRequest(user, whisper, console);
+         return true;
+      } else {
+         if (whisper.startsWith("&|+voicechat>accept")) {
+            if (this._state != 2) {
+               this.sendWhisper(user, "&|+voicechat>reject");
+               return false;
+            }
+
+            Console.println(MessageFormat.format(Console.message("chat-accepted"), arguments));
+            synchronized (this._vtimer) {
+               this._vtimer._vc = null;
+            }
+
+            this._vtimer = null;
+            this._state = 3;
+            this._vtimer = new VCTimerThread(this, 15000L);
+            this._vtimer.start();
+         } else if (whisper.startsWith("&|+voicechat>notvip")) {
+            if (voiceChatDialog != null && this._who.equals(user)) {
+               this.resetConnection(MessageFormat.format(Console.message("cannot-voice"), arguments));
+            }
+         } else if (whisper.startsWith("&|+voicechat>disabled")) {
+            if (voiceChatDialog != null && this._who.equals(user)) {
+               this.resetConnection(MessageFormat.format(Console.message("user-voice-dis"), arguments));
+            }
+         } else if (whisper.startsWith("&|+voicechat>busy")) {
+            if (voiceChatDialog != null && this._who.equals(user)) {
+               this.resetConnection(MessageFormat.format(Console.message("receiving-Voice"), arguments));
+            }
+         } else if (whisper.startsWith("&|+voicechat>reject")) {
+            if (voiceChatDialog != null && this._who.equals(user)) {
+               this.resetConnection(MessageFormat.format(Console.message("Voice-terminated"), arguments));
+            }
+
+            if (voiceChatQueryDialog != null && voiceChatQueryWho != null && voiceChatQueryWho.equals(user)) {
+               voiceChatQueryDialog.closeIt(false);
+               voiceChatQueryWho = null;
+               this.resetConnection(MessageFormat.format(Console.message("Voice-terminated"), arguments));
+            }
+         }
+
+         return false;
+      }
+   }
+
+   public static boolean tryToRun(String s) {
+      try {
+         Runtime.getRuntime().exec(s);
+         return true;
+      } catch (IOException var2) {
+         return false;
+      }
+   }
+
+   public void checkConnected() {
+      if (this.getState() == 2) {
+         this.resetConnection(Console.message("never-answered"));
+         this.sendWhisper(this.who(), "&|+voicechat>reject");
+      } else {
+         if (this.getState() != 4) {
+            this.resetConnection(Console.message("VoiceChat-failed"));
+         }
+      }
+   }
+
+   public void resetConnection(String err) {
+      this._error = err;
+      if (err != null) {
+         this._state = 5;
+         Console.println(this._error);
+      }
+
+      if (voiceChatDialog != null) {
+         voiceChatDialog.closeIt(true);
+      }
+   }
+
+   public void terminate() {
+      if (this._vtimer != null) {
+         synchronized (this._vtimer) {
+            this._vtimer._vc = null;
+         }
+
+         this._vtimer = null;
+      }
+
+      CDAudio.get().setEnabled(true);
+      ConnectionRecord.getList().addElement(new ConnectionRecord(this.who()));
+      this._state = 0;
+   }
+
+   public void release() {
+      if (chatMonitor != null) {
+         chatMonitor.stop();
+         chatMonitor = null;
+      }
+   }
+
+   @Override
+   public synchronized void dialogDone(Object who, boolean confirmed) {
+      if (who == voiceChatQueryDialog) {
+         voiceChatQueryDialog = null;
+         if (confirmed) {
+            this.sendWhisper(voiceChatQueryWho, "&|+voicechat>accept");
+            this.initiateVoiceChat(voiceChatQueryWho, voiceChatQueryIP);
+         } else if (voiceChatQueryWho != null) {
+            this.sendWhisper(voiceChatQueryWho, "&|+voicechat>reject");
+         }
+      } else if (who == voiceChatDialog) {
+         this._state = 6;
+         String stopString = URL.make("home:sfmain.exe -q").unalias();
+         tryToRun(stopString);
+         voiceChatDialog = null;
+         this.sendWhisper(this._who, "&|+voicechat>reject");
+         this.terminate();
+      } else {
+         String stopString = URL.make("home:sfmain.exe -q").unalias();
+         tryToRun(stopString);
+      }
+   }
+
+   private void sendWhisper(String destination, String text) {
+      Pilot.sendText(destination, text);
+      if (_selfWhisper) {
+         this.handleChatWhisper(destination, text, this._console);
+      }
+   }
+}