using System;
using System.Collections.Concurrent;
using System.IO;
using System.Net;
using System.Net.Sockets;
using Christie_net.codegear;
using Christie_net.datagear.command;

namespace Christie_net.daemon {
public class Connection {
    public Socket socket;
    public string name;
    public CodeGearManager cgm;
    public BlockingCollection<Command> sendQueue = new BlockingCollection<Command>();
    public bool sendManager = true;
    private object syncObject = new object();
    
    public Connection(Socket socket, CodeGearManager cgm) {
        this.socket = socket;
        this.cgm = cgm;
    }

    public void SendCommand(Command cmd) {
        sendQueue.TryAdd(cmd);
    }

    /// <summary>
    /// socketが接続しているhostnameとそのport番号を返す
    /// </summary>
    /// <returns></returns>
    public string GetInfoString() {
        IPEndPoint endPoint = (IPEndPoint) socket.RemoteEndPoint;
        IPAddress ipAddress = endPoint.Address;
        IPHostEntry hostEntry = Dns.GetHostEntry(ipAddress);
        // Dns.GetHostEntry(((IPEndPoint) socket.RemoteEndPoint).Address.ToString()).HostName + ":" +((IPEndPoint) socket.RemoteEndPoint).Port;
        return hostEntry.HostName + ":" + endPoint.Port;
       
    }

    /// <summary>
    /// socketを閉じる
    /// </summary>
    public void Close() {
        socket.Shutdown(SocketShutdown.Both);
        socket.Close();
    }

    /// <summary>
    /// commandの実装に従ってbyte配列に変換し接続先に書き込む
    /// </summary>
    /// <param name="cmd"></param>
    public void Write(Command cmd) {
        MemoryStream stream = cmd.Convert();
        byte[] buffer = stream.ToArray();

        try {
            while (stream.Length > 0) {
                socket.Send(buffer);
            }
        } catch (Exception e) {
            Console.WriteLine(e.StackTrace); 
        }
    }
}
}