package com.cn.test.chapter2.websocket;

import java.io.IOException;
import java.util.Date;
import java.util.concurrent.ConcurrentLinkedQueue;

import org.codehaus.jettison.json.JSONArray;
import org.eclipse.jetty.websocket.WebSocket;

/**
 * @author Mathieu Carbou (mathieu.carbou@gmail.com)
 */
class Endpoint implements WebSocket.OnTextMessage  {

	protected Connection _connection;
	
	private Endpoints endpoints;
	
	private static int clientCounter = 0;
    private int clientId = clientCounter++;
	
	public Endpoint(Endpoints endpoints) {
		this.setEndpoints(endpoints);
	}
	
	@Override
	public void onClose(int code, String message) {
		this.endpoints.remove(this);
	}

	@Override
	public void onOpen(Connection connection) {
		_connection = connection;
		try {
			this._connection.sendMessage(new JSONArray().put("ClientID = " + clientId).toString());
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
        endpoints.offer(this);
	}
	
	/**
	 * 发送信息
	 * @param data
	 */
	public void sendMessage(Endpoint fromEndpoint, String data){
		try {
			if(this._connection != null && this._connection.isOpen()){
				if(fromEndpoint.clientId == 0){
					this._connection.sendMessage(new JSONArray().put("FROM[系统广播]  : " + data).toString());
				}else{
					this._connection.sendMessage(new JSONArray().put("FROM " + fromEndpoint.clientId + " : " + data).toString());
				}
			}else{
				this._connection.disconnect();
				endpoints.remove(this);
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			this._connection.disconnect();
		}
	}

	@Override
	public void onMessage(final String data) {
		this.endpoints.broadcast(this,data);
	}

	public Endpoints getEndpoints() {
		return endpoints;
	}

	public void setEndpoints(Endpoints endpoints) {
		this.endpoints = endpoints;
	}
	
	


}