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

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

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

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

    public void Close() {
        //socket
    }

    public void Write(Command cmd) {
        MemoryStream stream = cmd.Convert();

        // while (stream.) {
        //     
        // }
    }
}
}