using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.ServiceModel.Description;
using System.ServiceModel.Dispatcher;
using System.ServiceModel;
using System.Windows.Forms;
using System.ServiceModel.Channels;

public static class CustomHeaderNames
{
    public const String CustomHeaderName = "UsernameToken";

    public const String UserName = "user";
    public const String PassName = "pass";

    public const String CustomHeaderNamespace = "http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-secext-1.0.xsd";

}

public class CustomHeader : MessageHeader
{
    private String _user, _pass;

    public String user
    {
        get
        {
            return (this._user);
        }
    }

    public String pass
    {
        get
        {
            return (this._pass);
        }
    }

    public CustomHeader(String user, String pass)
    {
        this._user = user;
        this._pass = pass;
    }

    public override string Name
    {
        get { return (CustomHeaderNames.CustomHeaderName); }
    }

    public override string Namespace
    {
        get { return (CustomHeaderNames.CustomHeaderNamespace); }
    }

    protected override void OnWriteHeaderContents(System.Xml.XmlDictionaryWriter writer, MessageVersion messageVersion)
    {
        // Write the content of the header directly using the XmlDictionaryWriter
        writer.WriteElementString(CustomHeaderNames.UserName, this.user);
        writer.WriteElementString(CustomHeaderNames.PassName, this.pass);
    }

    public static CustomHeader ReadHeader(System.Xml.XmlDictionaryReader reader)
    {
        // Read the header content (key) using the XmlDictionaryReader
        if (reader.ReadToDescendant(CustomHeaderNames.UserName, CustomHeaderNames.CustomHeaderNamespace))
        {
            String user = reader.ReadElementString("user");
            String pass = reader.ReadElementString("pass");
            return (new CustomHeader(user, pass));
        }
        else
        {
            return null;
        }
    }
}

public class MyMessageInspector : IClientMessageInspector
{
    //static string response;
    public void AfterReceiveReply(ref System.ServiceModel.Channels.Message reply, object correlationState)
    {
        try
        {
            //Console.WriteLine(reply.ToString());
            //MessageBox.Show(reply.ToString());
            string ret = reply.ToString().Substring(reply.ToString().IndexOf("<return "));
            ret = ret.Substring(ret.ToString().IndexOf(">") + 1);
            ret = ret.Substring(0, ret.ToString().IndexOf("</ret"));
            BS_SOAP_API.SOAPWorker.response = ret;
        }
        catch (Exception e) { BS_SOAP_API.SOAPWorker.response = e.Message; }
    }
    public static string CalculateMD5Hash(string input)
    {
        // step 1, calculate MD5 hash from input
        System.Security.Cryptography.MD5 md5 = System.Security.Cryptography.MD5.Create();
        byte[] inputBytes = System.Text.Encoding.ASCII.GetBytes(input);
        byte[] hash = md5.ComputeHash(inputBytes);

        // step 2, convert byte array to hex string
        StringBuilder sb = new StringBuilder();
        for (int i = 0; i < hash.Length; i++)
        {
            sb.Append(hash[i].ToString("X2"));
        }
        return sb.ToString();
    }
    public object BeforeSendRequest(ref System.ServiceModel.Channels.Message request, System.ServiceModel.IClientChannel channel)
    {


        string pass = BS_SOAP_API.SOAPWorker.Password;
        request.Headers.Add(new CustomHeader(BS_SOAP_API.SOAPWorker.Username, pass));
        //Console.WriteLine(request.ToString());
        return request;
    }
}

public class InspectorBehavior : IEndpointBehavior
{
    public void ApplyClientBehavior(ServiceEndpoint endpoint, ClientRuntime clientRuntime)
    { clientRuntime.MessageInspectors.Add(new MyMessageInspector()); }
    public void AddBindingParameters(ServiceEndpoint endpoint, System.ServiceModel.Channels.BindingParameterCollection bindingParameters) { }
    public void ApplyDispatchBehavior(ServiceEndpoint endpoint, EndpointDispatcher endpointDispatcher) { }
    public void Validate(ServiceEndpoint endpoint) { }
}

namespace BS_SOAP_API
{

    public class SOAPWorker
    {
        public static string Username;
        public static string Password;
        public static string response;
        public static APIService.EDokApiPortTypeClient call;
        static System.ServiceModel.BasicHttpBinding binding = new System.ServiceModel.BasicHttpBinding();
        public static string CalculateMD5Hash(string input)
        {
            // step 1, calculate MD5 hash from input
            System.Security.Cryptography.MD5 md5 = System.Security.Cryptography.MD5.Create();
            byte[] inputBytes = System.Text.Encoding.ASCII.GetBytes(input);
            byte[] hash = md5.ComputeHash(inputBytes);

            // step 2, convert byte array to hex string
            StringBuilder sb = new StringBuilder();
            for (int i = 0; i < hash.Length; i++)
            {
                sb.Append(hash[i].ToString("X2"));
            }
            return sb.ToString();
        }
        public static Boolean init(string address, string username, string password)
        {
            address += "eDokumentyApi.php";
            try
            {
                Username = username;
                Password = password;
                call = new APIService.EDokApiPortTypeClient(
                    (System.ServiceModel.Channels.Binding)binding,
                    new EndpointAddress(new Uri(address), 
                          EndpointIdentity.CreateDnsIdentity("eDokumentyAPI")));
                call.Endpoint.Behaviors.Add(new InspectorBehavior());
                call.Open();
                if (call.State == System.ServiceModel.CommunicationState.Opened) return true; else return false;
            }
            catch (Exception e)
            {
                MessageBox.Show("Wystąpił błąd podczas inicjalizacji połączenia");
                e.GetType();
                return false;
                //throw e;
            }
        }

        public static int CreateDocument(Dictionary<string, string> data)
        {
            string json = Newtonsoft.Json.JsonConvert.SerializeObject(data);

            try
            {
                SOAPWorker.call.createDocument(
                    new BS_SOAP_API.APIService.createDocumentRequest((object)json)
                );
                return int.Parse(response.Replace("\"", ""));
            }
            catch (Exception e) { e.GetType(); return -1; }
        }

        public static int SearchContacts(Dictionary<string, string> data)
        {
            string json = Newtonsoft.Json.JsonConvert.SerializeObject(data);
            SOAPWorker.call.searchContacts(
                new BS_SOAP_API.APIService.searchContactsRequest((object)json)
            );
            try
            {
                
                //Console.WriteLine(response);
                return Newtonsoft.Json.JsonConvert.DeserializeObject<int[]>(response)[0];
                //return int.Parse(response);
            }
            catch (Exception e) { e.GetType(); return -1; }
        }

        public static Dictionary<string, string> getUserAccount(string name)
        {
            Dictionary<string, string> data = new Dictionary<string, string>();
            data["usrnam"] = name;
            string json = Newtonsoft.Json.JsonConvert.SerializeObject(data);
            SOAPWorker.call.getUserAccount(
                new BS_SOAP_API.APIService.getUserAccountRequest((object)json)
            );
            try
            {
                return Newtonsoft.Json.JsonConvert.DeserializeObject<Dictionary<string, string>>(response);
            }
            catch (Exception e) { e.GetType(); return null; }
        }


        public static Dictionary<string, string> GetContactData(int id)
        {
            //string json = Newtonsoft.Json.JsonConvert.SerializeObject(data);
            SOAPWorker.call.getContact(
                new BS_SOAP_API.APIService.getContactRequest((object)id)
            );
            try
            {
                
                //Console.WriteLine(response);
                return Newtonsoft.Json.JsonConvert.DeserializeObject<Dictionary<string, string>>(response);
               // return int.Parse(response);
            }
            catch (Exception e) { e.GetType(); return null; }
        }

        public static int GetTypeOfDocumentData(string name)
        {
            Dictionary<string, string> data = new Dictionary<string, string>();
            data["dctptp"] = name;
            string json = Newtonsoft.Json.JsonConvert.SerializeObject(data);

            try
            {
                SOAPWorker.call.getDocumentTypeData(
                    new BS_SOAP_API.APIService.getDocumentTypeDataRequest((object)json)
                );
                Dictionary<object, object> resp = 
                    Newtonsoft.Json.JsonConvert.DeserializeObject<Dictionary<object, object>>(response.Trim(new char[]{'[',']'}));
                return int.Parse((string)resp["dctpid"]);
            }
            catch (Exception e) { e.GetType(); return -1; }
        }

    }

}