/*
Popup Plus plugin for Miranda IM

Copyright	© 2002 Luca Santarelli,
			© 2004-2007 Victor Pavlychko
			© 2010 MPK
			© 2010 Merlin_de

This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.

===============================================================================

File name      : $HeadURL: http://svn.miranda.im/mainrepo/popup/trunk/src/popup_thread.cpp $
Revision       : $Revision: 1651 $
Last change on : $Date: 2010-07-15 20:31:06 +0300 (Чт, 15 июл 2010) $
Last change by : $Author: Merlin_de $

===============================================================================
*/

#include "headers.h"
#include <process.h>
//#include <list>

// globals
//static unsigned idPopupThread = 0;
static int gIdleRequests = 0;
static bool gTerminating = false;
static HANDLE hThreadMutex = NULL;
static HWND gHwndManager = 0;
static int gLockCount = 0;
static volatile int nPopups = 0;

//typedef std::list<PopupWnd2 *> PopupList;
typedef LIST<PopupWnd2> PopupList;
static PopupList popupList(3);

// forwards
enum
{ // message id's
	UTM_PT_FIRST = WM_USER+1607,
	UTM_STOP_THREAD,
	UTM_ADD_WINDOW,
	UTM_UPDATE_WINDOW,
	UTM_REMOVE_WINDOW,
	UTM_REQUEST_IDLE,
	UTM_LOCK_QUEUE,
	UTM_UNLOCK_QUEUE,
	UTM_REQUEST_REMOVE
};
static void __cdecl PopupThread(void *arg);

// interface
void LoadPopupThread()
{
	hThreadMutex = CreateMutex(NULL, FALSE, NULL);
	_beginthread(PopupThread, 0, NULL);
//	_beginthreadex(NULL, 0, PopupThread, NULL, 0, &idPopupThread);
}

void StopPopupThread()
{
	PostMessage(gHwndManager, UTM_STOP_THREAD, 0, 0);
}

void UnloadPopupThread()
{
// We won't waint for thread to exit, Miranda's thread unsind mechanism will do that for us.
	WaitForSingleObject(hThreadMutex, INFINITE);
	CloseHandle(hThreadMutex);
}

void PopupThreadLock()
{
	PostMessage(gHwndManager, UTM_LOCK_QUEUE, 0, 0);
}

void PopupThreadUnlock()
{
	PostMessage(gHwndManager, UTM_UNLOCK_QUEUE, 0, 0);
}

bool PopupThreadIsFull()
{
//	char buf[128];
//	wsprintf(buf, "%d, %d", nPopups, PopUpOptions.MaxPopups);
//	MessageBoxA(NULL, buf, "Popup Plus", MB_OK);
	return nPopups >= PopUpOptions.MaxPopups;
}

bool PopupThreadAddWindow(PopupWnd2 *wnd)
{
	PostMessage(gHwndManager, UTM_ADD_WINDOW, 0, (LPARAM)wnd);
	return true;
}

bool PopupThreadRemoveWindow(PopupWnd2 *wnd)
{
	PostMessage(gHwndManager, UTM_REMOVE_WINDOW, 0, (LPARAM)wnd);
	return true;
}

bool PopupThreadUpdateWindow(PopupWnd2 *wnd)
{
	PostMessage(gHwndManager, UTM_UPDATE_WINDOW, 0, (LPARAM)wnd);
	return true;
}

bool PopupThreadRequestRemoveWindow(PopupWnd2 *wnd)
{
	PostMessage(gHwndManager, UTM_REQUEST_REMOVE, 0, (LPARAM)wnd);
	return true;
}

bool UpdatePopupPosition(PopupWnd2 *prev, PopupWnd2 *wnd)
{
	if (!wnd) return false;
	if (!PopUpOptions.ReorderPopUps && wnd->isPositioned()) return false;

	int POPUP_SPACING = PopUpOptions.spacing;

	POINT pos;
	SIZE prevSize = {0}, curSize = wnd->getSize();
	if (prev) prevSize = prev->getSize();

	RECT rc;
//	SystemParametersInfo(SPI_GETWORKAREA, 0, &rc, 0);

#if !defined(_UNICODE)
	//Win95 or NT don't have the support for multi monitor.
	if (!MyGetMonitorInfo) {
		SystemParametersInfo(SPI_GETWORKAREA,0,&rc,0);
	}
	//Windows 98/ME/2000/XP do have it.
	else
#endif
	if (GetSystemMetrics(SM_CMONITORS)==1) { //we have only one monitor (cant check it together with 1.if)
		SystemParametersInfo(SPI_GETWORKAREA,0,&rc,0);
	}
	else { //Multimonitor stuff (we have more then 1)
		HMONITOR hMonitor = NULL;
		HWND hWnd = NULL;
		MONITORINFOEX mnti; // = { 0 };

		if (PopUpOptions.Monitor == MN_MIRANDA)
			hWnd = (HWND)CallService(MS_CLUI_GETHWND,0,0);
		else // PopUpOptions.Monitor == MN_ACTIVE
			hWnd = GetForegroundWindow();

		mnti.cbSize = sizeof(MONITORINFOEX);

#if defined(_UNICODE)
		hMonitor = MonitorFromWindow(hWnd, MONITOR_DEFAULTTOPRIMARY);
		if (GetMonitorInfo(hMonitor, (LPMONITORINFO)&mnti) == TRUE) //It worked
#else
		hMonitor = MyMonitorFromWindow(hWnd, MONITOR_DEFAULTTOPRIMARY);
		if (MyGetMonitorInfo(hMonitor, (LPMONITORINFO)&mnti) == TRUE) //It worked
#endif
			CopyMemory(&rc, &(mnti.rcWork), sizeof(RECT));
		else
			SystemParametersInfo(SPI_GETWORKAREA,0,&rc,0);
	}

	rc.left += PopUpOptions.gapLeft - POPUP_SPACING;
	rc.right -= PopUpOptions.gapRight - POPUP_SPACING;
	rc.top += PopUpOptions.gapTop - POPUP_SPACING;
	rc.bottom -= PopUpOptions.gapBottom - POPUP_SPACING;
	if (PopUpOptions.Spreading == SPREADING_VERTICAL)
	{
		switch (PopUpOptions.Position)
		{
			case POS_UPPERLEFT:
				pos.x = rc.left + POPUP_SPACING;
				pos.y = (prev ? (prev->getPosition().y + prev->getSize().cy) : rc.top) + POPUP_SPACING;
				break;
			case POS_LOWERLEFT:
				pos.x = rc.left + POPUP_SPACING;
				pos.y = (prev ? prev->getPosition().y : rc.bottom) - wnd->getSize().cy - POPUP_SPACING;
				break;
			case POS_LOWERRIGHT:
				pos.x = rc.right - wnd->getSize().cx - POPUP_SPACING;
				pos.y = (prev ? prev->getPosition().y : rc.bottom) - wnd->getSize().cy - POPUP_SPACING;
				break;
			case POS_UPPERRIGHT:
				pos.x = rc.right - wnd->getSize().cx - POPUP_SPACING;
				pos.y = (prev ? (prev->getPosition().y + prev->getSize().cy) : rc.top) + POPUP_SPACING;
				break;
		}
	} else
	// if (PopUpOptions.Spreading == SPREADING_HORIZONTAL)
	{
		switch (PopUpOptions.Position)
		{
			case POS_UPPERLEFT:
				pos.x = (prev ? (prev->getPosition().x + prev->getSize().cx) : rc.left) + POPUP_SPACING;
				pos.y = rc.top + POPUP_SPACING;
				break;
			case POS_LOWERLEFT:
				pos.x = (prev ? (prev->getPosition().x + prev->getSize().cx) : rc.left) + POPUP_SPACING;
				pos.y = rc.bottom - wnd->getSize().cy - POPUP_SPACING;
				break;
			case POS_LOWERRIGHT:
				pos.x = (prev ? prev->getPosition().x : rc.right) - wnd->getSize().cx - POPUP_SPACING;
				pos.y = rc.bottom - wnd->getSize().cy - POPUP_SPACING;
				break;
			case POS_UPPERRIGHT:
				pos.x = (prev ? prev->getPosition().x : rc.right) - wnd->getSize().cx - POPUP_SPACING;
				pos.y = rc.top + POPUP_SPACING;
				break;
		}
	}
	wnd->setPosition(pos);
	return true;
}

void RepositionPopups()
{
	PopupWnd2 *prev = 0;
	if (PopUpOptions.ReorderPopUps)
	{
		for (int i = 0; i < popupList.getCount(); ++i)
		{
			UpdatePopupPosition(prev, popupList[i]);
			prev = popupList[i];
		}
	}
}

static LRESULT CALLBACK PopupThreadManagerWndProc(HWND hwnd, UINT message, WPARAM wParam, LPARAM lParam)
{
	PopupWnd2 *wnd = NULL;
	if (message == UTM_ADD_WINDOW ||
		message == UTM_UPDATE_WINDOW ||
		message == UTM_REMOVE_WINDOW ||
		message == UTM_REQUEST_REMOVE)
	{
		if (!(wnd = (PopupWnd2 *)lParam))
			return 0;
	}
	switch (message)
	{
		case UTM_STOP_THREAD:
		{
			gTerminating = true;
			if (DBGetContactSettingByte(NULL, MODULNAME, "FastExit", 0))
				for (int i = 0; i < popupList.getCount(); ++i)
					PUDeletePopUp(popupList[i]->getHwnd());
			PostQuitMessage(0);
			break;
		}
		case UTM_ADD_WINDOW:
		{
			if (gTerminating) break;
			UpdatePopupPosition(popupList.getCount() ? popupList[popupList.getCount()-1] : 0, wnd);
			popupList.insert(wnd);
			++nPopups;
			wnd->callMethodAsync(&PopupWnd2::m_show, 0);
			break;
		}
		case UTM_UPDATE_WINDOW:
		{
			RepositionPopups();
			break;
		}
		case UTM_REQUEST_REMOVE:
		{
			if ((PopUpOptions.LeaveHovered && gLockCount) || (wnd && wnd->isLocked()))
			{
				wnd->updateTimer();
			} else
			{
				PostMessage(wnd->getHwnd(), WM_CLOSE, 0, 0);
			}
			break;
		}
		case UTM_REMOVE_WINDOW:
		{
			// popupList.remove(ptr) would be nicer, but it requires sortFunc :(
			for (int i = 0; i < popupList.getCount(); ++i)
				if (popupList[i] == wnd)
				{
					popupList.remove(i);
					RepositionPopups();
					--nPopups;
					delete wnd;
					break;
				}
			break;
		}
		case UTM_LOCK_QUEUE:
		{
			++gLockCount;
			break;
		}
		case UTM_UNLOCK_QUEUE:
		{
			if (--gLockCount < 0)
				gLockCount = 0;
			break;
		}
	}
	return DefWindowProc(hwnd, message, wParam, lParam);
}

// thread func
static void __cdecl PopupThread(void *arg)
{
	// grab the mutex
	if (WaitForSingleObject(hThreadMutex, INFINITE) != WAIT_OBJECT_0)
	{ // other thread is already running
		_endthread();
		return;
	}

	// Increment Miranda thread counter
	CallService(MS_SYSTEM_THREAD_PUSH, 0, 0);

	// Create manager window
	DWORD err;
	WNDCLASSEX wcl;
	wcl.cbSize = sizeof(wcl);
	wcl.lpfnWndProc = PopupThreadManagerWndProc;
	wcl.style = 0;
	wcl.cbClsExtra = 0;
	wcl.cbWndExtra = 0;
	wcl.hInstance = hInst;
	wcl.hIcon = NULL;
	wcl.hCursor = LoadCursor(NULL, IDC_ARROW);
	wcl.hbrBackground = (HBRUSH)GetStockObject(LTGRAY_BRUSH);
	wcl.lpszMenuName = NULL;
	wcl.lpszClassName = _T("PopupThreadManagerWnd");
	wcl.hIconSm = (HICON)LoadImage(hInst, MAKEINTRESOURCE(IDI_POPUP), IMAGE_ICON, GetSystemMetrics(SM_CXSMICON), GetSystemMetrics(SM_CYSMICON), LR_DEFAULTCOLOR); 
	g_wndClass.cPopupThreadManagerWnd = RegisterClassEx(&wcl);
	err = GetLastError();
	if (!g_wndClass.cPopupThreadManagerWnd) {
		TCHAR msg[1024];
		wsprintf(msg, TranslateT("Failed to register %s class."),wcl.lpszClassName);
		MSGERROR(msg);
	}

	gHwndManager = CreateWindow(_T("PopupThreadManagerWnd"), NULL, 0, CW_USEDEFAULT, CW_USEDEFAULT, CW_USEDEFAULT, CW_USEDEFAULT, HWND_DESKTOP, NULL, hInst, NULL);
	SetWindowPos(gHwndManager, 0, 0, 0, 0, 0, SWP_NOZORDER|SWP_NOMOVE|SWP_NOSIZE|SWP_NOACTIVATE|SWP_DEFERERASE|SWP_NOSENDCHANGING|SWP_HIDEWINDOW);

	MSG msg;
	while (GetMessage(&msg, NULL, 0, 0))
	{
		TranslateMessage(&msg);
		DispatchMessage(&msg);
	}

	ReleaseMutex(hThreadMutex);

	// Decrement Miranda thread counter
	CallService(MS_SYSTEM_THREAD_POP, 0, 0);

	// Ok, now we can kill this thread
	_endthread();

	return;
}