package org.hedgewars.hedgeroid;

import org.hedgewars.hedgeroid.Datastructures.GameConfig;

import org.hedgewars.hedgeroid.frontlib.Flib;

import org.hedgewars.hedgeroid.frontlib.Frontlib;

import org.hedgewars.hedgeroid.frontlib.Frontlib.BytesCallback;

import org.hedgewars.hedgeroid.frontlib.Frontlib.GameSetupPtr;

import org.hedgewars.hedgeroid.frontlib.Frontlib.GameconnPtr;

import org.hedgewars.hedgeroid.frontlib.Frontlib.IntCallback;

import org.hedgewars.hedgeroid.frontlib.Frontlib.StrBoolCallback;

import org.hedgewars.hedgeroid.frontlib.Frontlib.StrCallback;

import org.hedgewars.hedgeroid.frontlib.Frontlib.VoidCallback;

import org.hedgewars.hedgeroid.frontlib.NativeSizeT;

import org.hedgewars.hedgeroid.netplay.GameMessageListener;

import org.hedgewars.hedgeroid.netplay.Netplay;

import org.hedgewars.hedgeroid.util.TickHandler;

import android.os.Handler;

import android.os.HandlerThread;

import android.os.Looper;

import android.util.Log;

import com.sun.jna.Memory;

import com.sun.jna.Pointer;

public final class GameConnection {

	private static final Handler mainHandler = new Handler(Looper.getMainLooper());

	private final HandlerThread thread;

	private final Handler handler;

	private final Netplay netplay; // ==null if not a netgame

	private GameconnPtr conn;

	}

				}

	}

		final String playerName = netplay.getPlayerName();

		return result;

	}

		return result;

	}

		}

	// runs on the IPCThread

	private void shutdown() {

		tickHandler.stop();

		thread.quit();

		Flib.INSTANCE.flib_gameconn_destroy(conn);

		if(netplay != null) {

			mainHandler.post(new Runnable() {

				public void run() {

					netplay.unregisterGameMessageListener(gameMessageListener);

				}

			});

		}

	}

	// runs on the IPCThread

	private final StrBoolCallback chatCb = new StrBoolCallback() {

		public void callback(Pointer context, String message, boolean teamChat) {

			if(teamChat) {

				netplay.sendTeamChat(message);

			} else {

				netplay.sendChat(message);

			}

		}

	};

	// runs on the IPCThread

	private final VoidCallback connectCb = new VoidCallback() {

		public void callback(Pointer context) {

			Log.i("GameConnection", "Connected");

		}

	};

	// runs on the IPCThread

	private final IntCallback disconnectCb = new IntCallback() {

		public void callback(Pointer context, int reason) {

			if(netplay != null) {

				netplay.sendRoundFinished(reason==Frontlib.GAME_END_FINISHED);

			}

			shutdown();

		}

	};

	// runs on the IPCThread

	private final BytesCallback engineMessageCb = new BytesCallback() {

		public void callback(Pointer context, Pointer buffer, NativeSizeT size) {

			netplay.sendEngineMessage(buffer.getByteArray(0, size.intValue()));

		}

	};

	// runs on the IPCThread

	private final StrCallback errorMessageCb = new StrCallback() {

		public void callback(Pointer context, String message) {

			Log.e("GameConnection", message);

		}

	};

	// runs on any thread

	private final GameMessageListener gameMessageListener = new GameMessageListener() {

		public void onNetDisconnected() {

			handler.post(new Runnable() {

				public void run() {

				}

			});

		}

		public void onMessage(final int type, final String message) {

			handler.post(new Runnable() {

				public void run() {

					Flib.INSTANCE.flib_gameconn_send_textmsg(conn, type, message);

				}

			});

		}

		public void onEngineMessage(final byte[] em) {

			handler.post(new Runnable() {

				public void run() {

					Memory mem = new Memory(em.length);

					mem.write(0, em, 0, em.length);

					Flib.INSTANCE.flib_gameconn_send_enginemsg(conn, mem, NativeSizeT.valueOf(em.length));

				}

			});

		}

		public void onChatMessage(final String nick, final String message) {

			handler.post(new Runnable() {

				public void run() {

					Flib.INSTANCE.flib_gameconn_send_chatmsg(conn, nick, message);

				}

			});

		}

	};

}