using System;
using System.Collections.Generic;
using System.Text;
using Sprache;
using System.IO;

public class ZundokoGenerator {
  Random _random = new Random();
  public IEnumerator<string> RandomZunDoko() {
    for (;;) {
      yield return _random.Next(0, 2) == 0 ? "ズン" : "ドコ";
    }
  }
}

public static class KiyoshiParser {
  public static readonly Parser<string> zun =
    from txt in Parse.String("ズン").Text()
    select txt;
  public static readonly Parser<string> doko =
    from txt in Parse.String("ドコ").Text()
    select txt;
  public static readonly Parser<string> zzzd =
    from z0 in zun
    from z1 in zun
    from z2 in zun
    from z3 in zun
    from dk in doko
    select "キヨシ";
}

class Program {
  static void Main() {
    var zdg = new ZundokoGenerator().RandomZunDoko();
    var sb = new StringBuilder();
    int count = 0;
    for (;;) {
      sb.Clear();
      for (int i = 0; i < 5; ++i) {
        zdg.MoveNext();
        sb.Append(zdg.Current);
      }
      ++count;
      try {
        var kys = KiyoshiParser.zzzd.Parse(sb.ToString());
        Console.WriteLine(sb.ToString() + kys);
        Console.WriteLine(count + "回ズンドコしました");
        break;
      }
      catch (Sprache.ParseException) {
        Console.WriteLine(sb.ToString());
      }
    }
  }
}

public class HostIOWindow : EditorWindow {
  [MenuItem("Window/HostIO")]
  static void Open() {
    var win = (HostIOWindow)EditorWindow.GetWindow(typeof(HostIOWindow));
    win.Show();
  }
  static HostIOWindow _instance = null;
  HttpListener _listener;
  Task<HttpListenerContext> _task;
  IPAddress _local;
  byte[] _ip;
  //
  void Awake() {
    if (!HttpListener.IsSupported) {
      throw new NotSupportedException("not supported");
    }
  }
  void Update() {
    if (_task == null) {
      _task = _listener.GetContextAsync();
    } else {
      if (_task.IsCompleted) {
        var ctxt = _task.Result;
        try {
          RequestHandler(ctxt);
        }
        catch (WebException e) {
          ErrorHandler(ctxt, e);
        }
        finally {
          _task.Dispose();
          _task = null;
        }
      } else
        if (_task.IsCanceled) {
          _task.Dispose();
          _task = null;
        } else
          if (_task.IsFaulted) {
            _task.Dispose();
            _task = null;
          }
    }
    Repaint();
  }
  // サーバ起動
  void StartWebServer() {
    StopWebServer();
    _task = null;
    _ip = HostIOUtil.DetectLocalAddress();
    _listener = new HttpListener();
    _listener.Prefixes.Add("http://localhost:4649/");
    var url = string.Format("http://{0}.{1}.{2}.{3}:4649/", _ip[0], _ip[1], _ip[2], _ip[3]);
    _listener.Prefixes.Add(url);
    _listener.Start();
    Debug.Log("START WEB SERVER => " + url);
  }
  // リクエストハンドラ
  void RequestHandler(HttpListenerContext ctxt) {
    var req = ctxt.Request;
    var res = ctxt.Response;
    var pathelem = req.RawUrl.Split('/').ToList();
    pathelem.RemoveAll((e) => string.IsNullOrEmpty(e));
    if (pathelem.Count > 0) {
      switch (pathelem[0]) {
      case "assets":
        if (pathelem.Count == 1) {
          RequestHandler_file(ctxt, "/");
        } else {
          var pathname = "/" + Path.Combine(pathelem.GetRange(1, pathelem.Count - 1).ToArray());
          pathname = pathname.Replace('\\', '/');
          RequestHandler_file(ctxt, pathname);
        }
        break;
      case "ping":
        RequestHandler_ping(ctxt);
        break;
      default:
        throw new WebException("unknown API");
      }
    } else {
      throw new WebException("unknown API");
    }
  }
}

public class HostIO : MonoBehaviour {
  static HostIO _instance = null;
  static byte _pinCode = 0;
  static StringBuilder _addressBase = new StringBuilder(1024);
  static int _addressBaseRewindLength;
  static bool _connect;
  static byte[] _ip;
  static readonly string _saveKey = "HostIO";
  static readonly string _savePINCodeKey = _saveKey + "_PINCode";
  static float _wait = 1.0f;


  public static HostIO Instance {
    get { return _instance; }
  }
  public static byte PINCode {
    get { return _pinCode; }
    set {
      _pinCode = value;
      _addressBase.Clear();
      _addressBase.Append(string.Format("http://{0}.{1}.{2}.{3}", _ip[0], _ip[1], _ip[2], value));
      _addressBase.Append(":3751");
      _addressBaseRewindLength = _addressBase.Length;
      Debug.Log("SERVER: " + _addressBase.ToString());
      _wait = 0.0f;
    }
  }
  public static bool IsConnected {
    get { return _connect; }
  }
  void Awake() {
#if UNITY_EDITOR
    // UnityEditor上で起動した場合は不要なので死ぬ
    _ip = null;
    Destroy(this);
#else
    // みんな大好きシングルトン
    if (_instance != null) {
      Destroy(this);
    } else {
      _connect = false;
      _instance = this;
      DontDestroyOnLoad(gameObject);
      _ip = HostIOUtil.DetectLocalAddress();
      PINCode = (byte)PlayerPrefs.GetInt(_savePINCodeKey, 0);
    }
#endif
  }
  void OnDestroy() {
    if (_instance == this) {
      PlayerPrefs.SetInt(_savePINCodeKey, (int)PINCode);
      PlayerPrefs.Save();
      _connect = false;
      _instance = null;
    }
  }
  void Start() {
    StartCoroutine(ConnectServer());
  }
  // 定期的にHTTPサーバにPingしてサーバが生きているかどうかチェックする
  IEnumerator ConnectServer() {
    while (true) {
      if (PINCode != 0) {
        using (var webreq = UnityWebRequest.Get(MakeAPIUrl("/ping"))) {
            yield return webreq.SendWebRequest();
            if (webreq.isNetworkError || webreq.isHttpError) {
              _connect = false;
            } else {
              _connect = true;
            }
        }
      } else {
        _connect = false;
      }
      yield return new WaitForSecondsRealtime(1.0f);
    }
  }
  // 同期的にファイルを読む
  public static byte[] LoadFile(string path) {
    using (var webreq = UnityWebRequest.Get(MakeAPIUrl("/assets" + path))) {
      var async = webreq.SendWebRequest();
      while (!async.isDone) {
        Thread.Sleep(1);
      }
      var req = async.webRequest;
      if (req.isNetworkError || req.isHttpError) {
        return null;
      }
      return req.downloadHandler.data;
    }
  }
  // 非同期的にファイルを読む
  public static UnityWebRequestAsyncOperation LoadFileAsync(string path) {
    using (var webreq = UnityWebRequest.Get(MakeAPIUrl("/assets" + path))) {
      return webreq.SendWebRequest();
    }
  }
}