/**

 * Copyright (c) 2015-2016, FastDev 刘强 (fastdev@163.com).

 *

 * Licensed under the Apache License, Version 2.0 (the "License");

 * you may not use this file except in compliance with the License.

 * You may obtain a copy of the License at

 *

 * http://www.apache.org/licenses/LICENSE-2.0

 *

 * Unless required by applicable law or agreed to in writing, software

 * distributed under the License is distributed on an "AS IS" BASIS,

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

 * See the License for the specific language governing permissions and

 * limitations under the License.

 */

using OF.DistributeService.Core.Attribute;
using OF.DistributeService.Core.Client;
using OF.DistributeService.Core.Common;
using OF.DistributeService.Core.Entity;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
using ZooKeeperNet;

namespace TestOpenRestClient
{
 static class Program
 {
 /// <summary>
 /// 应用程序的主入口点。
 /// </summary>
 [STAThread]
 static void Main()
 {
 Application.EnableVisualStyles();
 Application.SetCompatibleTextRenderingDefault(false);
 Application.ThreadException += Application_ThreadException;
 AppDomain.CurrentDomain.UnhandledException += CurrentDomain_UnhandledException;
 AppDomain.CurrentDomain.DomainUnload += CurrentDomain_DomainUnload;
 Application.ApplicationExit += Application_ApplicationExit;
 Application.Run(new ClientDemo());
 }

 private static void TestSafeCall()
 {
 MockSafeCall(3, -2);
 MockSafeCall(3, -1);
 MockSafeCall(3, 0);
 MockSafeCall(3, 1);
 MockSafeCall(3, 2);
 MockSafeCall(3, 3);
 MockSafeCall(3, 4);
 MockSafeCall(3, 5);
 }

 private static void MockSafeCall(int maxLoop, int maxThrowI)
 {
 
 int indexI = 0;
 bool isTrue = Util.SafeLoopUtilTrue((loopI) =>
 {
 MockException(indexI++, maxThrowI);
 return 5 == indexI;
 }, maxLoop, 10);
 System.Diagnostics.Debug.WriteLine("MockSafeCall " + isTrue + ",LoopI:" + indexI + ":(" + maxLoop + "," + maxThrowI + ")");
 
 System.Diagnostics.Debug.WriteLine("\n\n");
 }

 private static void TestRetry()
 {
 MockTestRetry(3, -2);
 MockTestRetry(3, -1);
 MockTestRetry(3, 0);
 MockTestRetry(3, 1);
 MockTestRetry(3, 2);
 MockTestRetry(3, 3);
 MockTestRetry(3, 4);
 MockTestRetry(3, 5);
 }

 private static void MockTestRetry(int maxLoop, int maxThrowI)
 {
 try
 {
 int indexI = 0;
 int resultI = Util.MaxRetryCall(() =>
 {
 MockException(indexI++, maxThrowI);
 return indexI;
 }, maxLoop, 10);
 System.Diagnostics.Debug.WriteLine("MockTestRetry Result:" + resultI + ":(" + maxLoop + "," + maxThrowI + ")");
 }
 catch (Exception ex)
 {
 Util.LogException("MockTestRetry", ex);
 System.Diagnostics.Debug.WriteLine("MockTestRetry Exception:"+ maxLoop + "," + maxThrowI);
 }
 System.Diagnostics.Debug.WriteLine("\n\n");
 }

 private static void MockException(int index, int maxThrowI)
 {
 if (index <= maxThrowI)
 {
 throw new Exception();
 }
 }
 public static void InitAppServices()
 {
 ClientToAppConfig estTestApp = new ClientToAppConfig
 {
 ServiceAppName = "DonetOFDistributeServiceTest",
 ServiceList = OFDistributeServiceAttribute.GetClientToAppConfigList(typeof(TestOpenRestClient.Api.ISOService).Assembly)
 };
 ClientToAppManager.Init(new List<OF.DistributeService.Core.Entity.ClientToAppConfig> { 
 estTestApp
 });
 }

 public static void Dispose()
 {
 var instance = ClientToAppManager.Get();
 if (instance != null)
 {
 instance.Dispose();
 }
 }

 static void Application_ApplicationExit(object sender, EventArgs e)
 {
 Dispose();
 Util.LogInfo("ClientDemo Application_ApplicationExit" + e.ToString());
 }

 static void CurrentDomain_DomainUnload(object sender, EventArgs e)
 {
 Dispose();
 Util.LogInfo("ClientDemo CurrentDomain_DomainUnload:" + e.ToString());
 }

 static void CurrentDomain_UnhandledException(object sender, UnhandledExceptionEventArgs e)
 {
 Dispose();
 Util.LogException("ClientDemo CurrentDomain_UnhandledException:", e.ExceptionObject as Exception);
 }


 static void Application_ThreadException(object sender, System.Threading.ThreadExceptionEventArgs e)
 {
 Dispose();
 Util.LogException("ClientDemo Application_ThreadException:", e.Exception as Exception);
 }
 }

 public class Wather : IWatcher
 {
 public void Process(WatchedEvent @event)
 {
 System.Diagnostics.Debug.WriteLine(@event.Path + "," + @event.State + "," + @event.Type);
 }
 }
}