#include "InstallerMain.h"

#include "InstallerUtil.h"

#include "PerformInstall.h"

#include "CCriticalSection.h"

#define WMU_INSTALLER_DONE		WM_USER+2

#define PBAR_RANGE_HIGH			100

#define PBAR_RANGE_LOW			0

ICopyMethod *g_pCopyMethod = NULL;

HANDLE g_hCopyThread = NULL;

copy_thread_args_t g_thread_args = {NULL, NULL, NULL, false, false};

CCriticalSection g_update_window;

class TrackProgress : public ICopyProgress

{

public:

	void Initialize(HWND hTextBar, HWND hCurBar, HWND hTotalBar, size_t total_size)

	{

		m_hTextBar = hTextBar;

		m_hCurBar = hCurBar;

		m_hTotalBar = hTotalBar;

		m_TotalSize = total_size;

		m_TotalDone = 0;

		RedrawProgressBars(0.0, 0.0);

	}

	void Finished()

	{

		RedrawProgressBars(100.0, 100.0);

	}

public:

	void StartingNewFile(const TCHAR *filename)

	{

		TCHAR buffer[255];

		if (g_update_window.TryEnter())

		{

			UTIL_Format(buffer, sizeof(buffer) / sizeof(TCHAR), _T("Copying: %s"), filename);

			SendMessage(m_hTextBar, WM_SETTEXT, 0, (LPARAM)buffer);

			UpdateWindow(m_hTextBar);

			g_update_window.Leave();

		}

	}

	void UpdateProgress(size_t bytes, size_t total_bytes)

	{

		float fCur = (float)bytes / (float)total_bytes;

		float fTotal = ((float)m_TotalDone + (float)bytes) / (float)m_TotalSize;

		RedrawProgressBars(fCur, fTotal);

	}

	void FileDone(size_t total_size)

	{

		m_TotalDone += total_size;

		RedrawProgressBars(0.0, (float)m_TotalDone / (float)m_TotalSize);

	}

private:

	void RedrawProgressBar(HWND hBar, float fPerc)

	{

		/* Get a percentage point in the range */

		float fPointInRange = (float)(PBAR_RANGE_HIGH - PBAR_RANGE_LOW) * fPerc;

		int iPointInRange = (int)fPointInRange;

		/* Scale it */

		iPointInRange += PBAR_RANGE_LOW;

		if (g_update_window.TryEnter())

		{

			SendMessage(hBar,

				PBM_SETPOS,

				iPointInRange,

				0);

			g_update_window.Leave();

		}

	}

	void RedrawProgressBars(float fCurrent, float fTotal)

	{

		RedrawProgressBar(m_hCurBar, fCurrent);

		RedrawProgressBar(m_hTotalBar, fTotal);

	}

private:

	size_t m_TotalSize;

	size_t m_TotalDone;

	HWND m_hTextBar;

	HWND m_hCurBar;

	HWND m_hTotalBar;

} s_ProgressTracker;

void CancelPerformInstall()

{

	delete g_thread_args.pFileList;

	g_thread_args.pFileList = NULL;

}

void SetInstallMethod(ICopyMethod *pCopyMethod)

{

	g_pCopyMethod = pCopyMethod;

}

bool CopyStructureRecursively(ICopyMethod *pCopyMethod,

							  CFileList *pFileList,

							  const TCHAR *basepath,

							  const TCHAR *local_path,

							  TCHAR *errbuf,

							  size_t maxchars)

{

	TCHAR file_path[MAX_PATH];

	const TCHAR *file;

	CFileList *pSubList;

	if (!pCopyMethod->SetCurrentFolder(local_path, errbuf, maxchars))

	{

		return false;

	}

	/* Copy files */

	while ((file = pFileList->PeekCurrentFile()) != NULL)

	{

		if (local_path == NULL)

		{

			UTIL_PathFormat(file_path,

				sizeof(file_path) / sizeof(TCHAR),

				_T("%s\\%s"),

				basepath,

				file);

		}

		else

		{

			UTIL_PathFormat(file_path,

				sizeof(file_path) / sizeof(TCHAR), 

				_T("%s\\%s\\%s"),

				basepath,

				local_path,

				file);

		}

		if (!pCopyMethod->SendFile(file_path, errbuf, maxchars))

		{

			return false;

		}

		pFileList->PopCurrentFile();

	}

	/* Now copy folders */

	while ((pSubList = pFileList->PeekCurrentFolder()) != NULL)

	{

		/* Try creating the folder */

		if (!pCopyMethod->CreateFolder(pSubList->GetFolderName(), errbuf, maxchars))

		{

			return false;

		}

		TCHAR new_local_path[MAX_PATH];

		if (local_path == NULL)

		{

			UTIL_PathFormat(new_local_path,

				sizeof(new_local_path) / sizeof(TCHAR),

				_T("%s"),

				pSubList->GetFolderName());

		}

		else

		{

			UTIL_PathFormat(new_local_path,

				sizeof(new_local_path) / sizeof(TCHAR),

				_T("%s\\%s"),

				local_path,

				pSubList->GetFolderName());

		}

		if (!CopyStructureRecursively(pCopyMethod,

				pSubList,

				basepath, 

				new_local_path, 

				errbuf, 

				maxchars))

		{

			return false;

		}

		pFileList->PopCurrentFolder();

		/* Set the current folder again for the next operation */

		if (!pCopyMethod->SetCurrentFolder(local_path, errbuf, maxchars))

		{

			return false;

		}

	}

	return true;

}

DWORD WINAPI T_CopyFiles(LPVOID arg)

{

	bool result = 

		CopyStructureRecursively(g_thread_args.pCopyMethod,

		g_thread_args.pFileList,

		g_thread_args.basepath,

		NULL,

		g_thread_args.error,

		sizeof(g_thread_args.error) / sizeof(TCHAR));

	PostMessage(g_thread_args.hWnd, WMU_INSTALLER_DONE, result ? TRUE : FALSE, 0);

	return 0;

}

bool StartFileCopy(HWND hWnd)

{

	g_thread_args.m_bWasCancelled = false;

	g_thread_args.hWnd = hWnd;

	if ((g_hCopyThread = CreateThread(NULL, 

		0, 

		T_CopyFiles, 

		NULL, 

		0,

		NULL))

		== NULL)

	{

		MessageBox(

			hWnd,

			_T("Could not initialize copy thread."),

			_T("SourceMod Installer"),

			MB_OK|MB_ICONERROR);

		return false;

	}

	return true;

}

void StopFileCopy()

{

	g_thread_args.m_bWasCancelled = true;

	g_pCopyMethod->CancelCurrentCopy();

	if (g_hCopyThread != NULL)

	{

		g_update_window.Enter();

		WaitForSingleObject(g_hCopyThread, INFINITE);

		g_update_window.Leave();

		CloseHandle(g_hCopyThread);

		g_hCopyThread = NULL;

	}

}

bool RequestCancelInstall(HWND hWnd)

{

	StopFileCopy();

	int val = MessageBox(

		hWnd,

		_T("Are you sure you want to cancel the install?"),

		_T("SourceMod Installer"),

		MB_YESNO|MB_ICONQUESTION);

	if (val == IDYES)

	{

		return true;

	}

	if (g_thread_args.pFileList == NULL)

	{

		return false;

	}

	/* Start the thread, note our return value is opposite */

	return !StartFileCopy(hWnd);

}

bool StartInstallProcess(HWND hWnd)

{

	if (g_pCopyMethod->CheckForExistingInstall())

	{

		int val = MessageBox(

			hWnd, 

			_T("It looks like a previous SourceMod installation exists.  Do you want to upgrade?  Select \"Yes\" to upgrade and keep configuration files.  Select \"No\" to perform a full re-install."),

			_T("SourceMod Installer"), 

			MB_YESNO|MB_ICONQUESTION);

		if (val == 0 || val == IDYES)

		{

		}

		else

		{

		}

	}

#if 0

	TCHAR cur_path[MAX_PATH];

	if (_tgetcwd(cur_path, sizeof(cur_path)) == NULL)

	{

		MessageBox(

			hWnd,

			_T("Could not locate current directory!"),

			_T("SourceMod Installer"),

			MB_OK|MB_ICONERROR);

		return false;

	}

#endif

#if 0

	UTIL_PathFormat(source_path,

		sizeof(source_path) / sizeof(TCHAR),

		_T("%s\\files"),

		cur_path);

#else

	UTIL_PathFormat(g_thread_args.basepath,

		sizeof(g_thread_args.basepath) / sizeof(TCHAR),

		_T("C:\\real\\done\\base"));

#endif

	if (GetFileAttributes(g_thread_args.basepath) == INVALID_FILE_ATTRIBUTES)

	{

		MessageBox(

			hWnd,

			_T("Could not locate the source installation files!"),

			_T("SourceMod Installer"),

			MB_OK|MB_ICONERROR);

		return false;

	}

	delete g_thread_args.pFileList;

	g_thread_args.pFileList = CFileList::BuildFileList(_T(""), g_thread_args.basepath);

	s_ProgressTracker.Initialize(

		GetDlgItem(hWnd, IDC_PROGRESS_CURCOPY),

		GetDlgItem(hWnd, IDC_PROGRESS_CURRENT),

		GetDlgItem(hWnd, IDC_PROGRESS_TOTAL),

		(size_t)g_thread_args.pFileList->GetRecursiveSize());

	g_pCopyMethod->TrackProgress(&s_ProgressTracker);

	g_thread_args.pCopyMethod = g_pCopyMethod;

	return StartFileCopy(hWnd);

}

INT_PTR CALLBACK PerformInstallHandler(HWND hDlg, UINT message, WPARAM wParam, LPARAM lParam)

{

	switch (message)

	{

	case WM_INITDIALOG:

		{

			SetToGlobalPosition(hDlg);

			return (INT_PTR)TRUE;

		}

	case WM_COMMAND:

		{

			if (LOWORD(wParam) == ID_INSTALL_CANCEL

				|| LOWORD(wParam) == ID_CLOSE)

			{

				if (RequestCancelInstall(hDlg))

				{

					CancelPerformInstall();

					UpdateGlobalPosition(hDlg);

					EndDialog(hDlg, NULL);

				}

				return (INT_PTR)TRUE;

			}

			else if (LOWORD(wParam) == ID_INSTALL_START)

			{

				HWND hButton = GetDlgItem(hDlg, ID_INSTALL_START);

				EnableWindow(hButton, FALSE);

				StartInstallProcess(hDlg);

			}

			break;

		}

	case WMU_INSTALLER_DONE:

		{

			if (wParam == TRUE)

			{

				s_ProgressTracker.Finished();

				MessageBox(hDlg,

					_T("SourceMod was successfully installed!  Please visit http://www.sourcemod.net/ for documentation."),

					_T("SourceMod Installer"),

					MB_OK);

				CancelPerformInstall();

				UpdateGlobalPosition(hDlg);

				EndDialog(hDlg, NULL);

				return (INT_PTR)TRUE;

			}

			else if (!g_thread_args.m_bWasCancelled)

			{

				TCHAR buffer[500];

				UTIL_Format(buffer, 

					sizeof(buffer) / sizeof(TCHAR), 

					_T("Encountered error: %s"),

					g_thread_args.error);

				int res = MessageBox(hDlg,

					buffer,

					_T("SourceMod Installer"),

					MB_ICONERROR|MB_RETRYCANCEL);

				if (res == IDRETRY)

				{

					StartFileCopy(hDlg);

				}

				else

				{

					CancelPerformInstall();

					UpdateGlobalPosition(hDlg);

					EndDialog(hDlg, NULL);

					return (INT_PTR)TRUE;

				}

			}

			break;

		}

	}

	return (INT_PTR)FALSE;

}

void *DisplayPerformInstall(HWND hWnd)

{

	INT_PTR val;

	if ((val = DialogBox(

		g_hInstance, 

		MAKEINTRESOURCE(IDD_PERFORM_INSTALL),

		hWnd,

		PerformInstallHandler)) == -1)

	{

		return NULL;

	}

	return (void *)val;

}