/* ScummVM - Graphic Adventure Engine
 *
 * ScummVM is the legal property of its developers, whose names
 * are too numerous to list here. Please refer to the COPYRIGHT
 * file distributed with this source distribution.
 *
 * 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., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
 *
 */

/*
 * This code is based on original Hugo Trilogy source code
 *
 * Copyright (c) 1989-1995 David P. Gray
 *
 */

// This module contains all the scheduling and timing stuff

#include "common/debug.h"
#include "common/system.h"
#include "common/textconsole.h"

#include "hugo/hugo.h"
#include "hugo/schedule.h"
#include "hugo/file.h"
#include "hugo/display.h"
#include "hugo/util.h"
#include "hugo/object.h"
#include "hugo/sound.h"
#include "hugo/parser.h"
#include "hugo/text.h"
#include "hugo/route.h"
#include "hugo/mouse.h"

namespace Hugo {

Scheduler::Scheduler(HugoEngine *vm) : _vm(vm) {
	_actListArr = nullptr;
	_curTick = 0;
	_oldTime = 0;
	_refreshTimeout = 0;
	_points = nullptr;
	_screenActs = nullptr;

	memset(_events, 0, sizeof(_events));
	_numBonuses = 0;
	_screenActsSize = 0;

	_actListArrSize = 0;
	_alNewscrIndex = 0;
	_freeEvent = nullptr;
	_headEvent = nullptr;
	_tailEvent = nullptr;
}

Scheduler::~Scheduler() {
}

void Scheduler::initCypher() {
	_cypher = getCypher();
}

/**
 * Initialize the timer event queue
 */
void Scheduler::initEventQueue() {
	debugC(1, kDebugSchedule, "initEventQueue");

	// Chain nextEvent from first to last
	for (int i = kMaxEvents; --i;)
		_events[i - 1]._nextEvent = &_events[i];
	_events[kMaxEvents - 1]._nextEvent = nullptr;

	// Chain prevEvent from last to first
	for (int i = 1; i < kMaxEvents; i++)
		_events[i]._prevEvent = &_events[i - 1];
	_events[0]._prevEvent = nullptr;

	_headEvent = _tailEvent = nullptr;              // Event list is empty
	_freeEvent = _events;                           // Free list is full
}

/**
 * Return a ptr to an event structure from the free list
 */
Event *Scheduler::getQueue() {
	debugC(4, kDebugSchedule, "getQueue");

	if (!_freeEvent)                                // Error: no more events available
		error("An error has occurred: %s", "getQueue");
	Event *resEvent = _freeEvent;
	_freeEvent = _freeEvent->_nextEvent;
	resEvent->_nextEvent = nullptr;
	return resEvent;
}

/**
 * Call Insert_action for each action in the list supplied
 */
void Scheduler::insertActionList(const uint16 actIndex) {
	debugC(1, kDebugSchedule, "insertActionList(%d)", actIndex);

	if (_actListArr[actIndex]) {
		for (int i = 0; _actListArr[actIndex][i]._a0._actType != ANULL; i++)
			insertAction(&_actListArr[actIndex][i]);
	}
}

/**
 * Return system time in ticks.  A tick is 1/TICKS_PER_SEC mS
 */
uint32 Scheduler::getWinTicks() const {
	debugC(5, kDebugSchedule, "getWinTicks()");

	return _vm->getGameStatus()._tick;
}

/**
 * Return system time in ticks.  A tick is 1/TICKS_PER_SEC mS
 * If update FALSE, simply return last known time
 * Note that this is real time unless a processing cycle takes longer than
 * a real tick, in which case the system tick is simply incremented
 */
uint32 Scheduler::getDosTicks(const bool updateFl) {
	debugC(5, kDebugSchedule, "getDosTicks(%s)", (updateFl) ? "TRUE" : "FALSE");

	uint32 t_now;                                   // Current wall time in ticks

	if (!updateFl)
		return(_curTick);

	if (_oldTime == 0)
		_oldTime = (uint32) floor((double) (g_system->getMillis() * _vm->getTPS() / 1000));
	// Calculate current wall time in ticks
	t_now = g_system->getMillis() * _vm->getTPS() / 1000;

	if ((t_now - _oldTime) > 0) {
		_oldTime = t_now;
		_curTick++;
	}
	return(_curTick);
}

/**
 * Add indecated bonus to score if not added already
 */
void Scheduler::processBonus(const int bonusIndex) {
	debugC(1, kDebugSchedule, "processBonus(%d)", bonusIndex);

	if (!_points[bonusIndex]._scoredFl) {
		_vm->adjustScore(_points[bonusIndex]._score);
		_points[bonusIndex]._scoredFl = true;
	}
}

/**
 * Transition to a new screen as follows:
 * 1. Clear out all non-global events from event list.
 * 2. Set the new screen (in the hero object and any carried objects)
 * 3. Read in the screen files for the new screen
 * 4. Schedule action list for new screen
 * 5. Initialize prompt line and status line
 */
void Scheduler::newScreen(const int screenIndex) {
	debugC(1, kDebugSchedule, "newScreen(%d)", screenIndex);

	// Make sure the background file exists!
	if (!_vm->isPacked()) {
		Common::String filename = Common::String(_vm->_text->getScreenNames(screenIndex));
		if (!Common::File::exists(_vm->_picDir + filename + ".PCX") &&
			!Common::File::exists(filename + ".ART")) {
				error("Unable to find background file for %s", filename.c_str());
			return;
		}
	}

	// 1. Clear out all local events
	Event *curEvent = _headEvent;                 // The earliest event
	Event *wrkEvent;                              // Event ptr
	while (curEvent) {                              // While mature events found
		wrkEvent = curEvent->_nextEvent;             // Save p (becomes undefined after Del)
		if (curEvent->_localActionFl)
			delQueue(curEvent);                     // Return event to free list
		curEvent = wrkEvent;
	}

	// 2. Set the new screen in the hero object and any being carried
	_vm->setNewScreen(screenIndex);

	// 3. Read in new screen files
	_vm->readScreenFiles(screenIndex);

	// 4. Schedule action list for this screen
	_vm->_scheduler->screenActions(screenIndex);

	// 5. Initialize prompt line and status line
	_vm->_screen->initNewScreenDisplay();
}

/**
 * Transition to a new screen as follows:
 * 1. Set the new screen (in the hero object and any carried objects)
 * 2. Read in the screen files for the new screen
 * 3. Initialize prompt line and status line
 */
void Scheduler::restoreScreen(const int screenIndex) {
	debugC(1, kDebugSchedule, "restoreScreen(%d)", screenIndex);

	// 1. Set the new screen in the hero object and any being carried
	_vm->setNewScreen(screenIndex);

	// 2. Read in new screen files
	_vm->readScreenFiles(screenIndex);

	// 3. Initialize prompt line and status line
	_vm->_screen->initNewScreenDisplay();
}

/**
 * Wait (if necessary) for next synchronizing tick
 * Slow machines won't make it by the end of tick, so will just plod on
 * at their own speed, not waiting here, but free running.
 * Note: DOS Versions only
 */
void Scheduler::waitForRefresh() {
	debugC(5, kDebugSchedule, "waitForRefresh()");

	uint32 t;

	if (_refreshTimeout == 0)
		_refreshTimeout = getDosTicks(true);

	while ((t = getDosTicks(true)) < _refreshTimeout)
		;
	_refreshTimeout = ++t;
}

/**
 * Read kALnewscr used by maze (Hugo 2)
 */
void Scheduler::loadAlNewscrIndex(Common::ReadStream &in) {
	debugC(6, kDebugSchedule, "loadAlNewscrIndex(&in)");

	for (int varnt = 0; varnt < _vm->_numVariant; varnt++) {
		int numElem = in.readUint16BE();
		if (varnt == _vm->_gameVariant)
			_alNewscrIndex = numElem;
	}
}

/**
 * Load Points from Hugo.dat
 */
void Scheduler::loadPoints(Common::SeekableReadStream &in) {
	debugC(6, kDebugSchedule, "loadPoints(&in)");

	for (int varnt = 0; varnt < _vm->_numVariant; varnt++) {
		uint16 numElem = in.readUint16BE();
		if (varnt == _vm->_gameVariant) {
			_numBonuses = numElem;
			_points = (Point *)malloc(sizeof(Point) * _numBonuses);
			for (int i = 0; i < _numBonuses; i++) {
				_points[i]._score = in.readByte();
				_points[i]._scoredFl = false;
			}
		} else {
			in.skip(numElem);
		}
	}
}

void Scheduler::readAct(Common::ReadStream &in, Act &curAct) {
	uint16 numSubAct;

	curAct._a0._actType = (Action) in.readByte();
	switch (curAct._a0._actType) {
	case ANULL:              // -1
		break;
	case ASCHEDULE:          // 0
		curAct._a0._timer = in.readSint16BE();
		curAct._a0._actIndex = in.readUint16BE();
		break;
	case START_OBJ:          // 1
		curAct._a1._timer = in.readSint16BE();
		curAct._a1._objIndex = in.readSint16BE();
		curAct._a1._cycleNumb = in.readSint16BE();
		curAct._a1._cycle = (Cycle) in.readByte();
		break;
	case INIT_OBJXY:         // 2
		curAct._a2._timer = in.readSint16BE();
		curAct._a2._objIndex = in.readSint16BE();
		curAct._a2._x = in.readSint16BE();
		curAct._a2._y = in.readSint16BE();
		break;
	case PROMPT:             // 3
		curAct._a3._timer = in.readSint16BE();
		curAct._a3._promptIndex = in.readSint16BE();
		numSubAct = in.readUint16BE();
		curAct._a3._responsePtr = (int *)malloc(sizeof(int) * numSubAct);
		for (int k = 0; k < numSubAct; k++)
			curAct._a3._responsePtr[k] = in.readSint16BE();
		curAct._a3._actPassIndex = in.readUint16BE();
		curAct._a3._actFailIndex = in.readUint16BE();
		curAct._a3._encodedFl = (in.readByte() == 1) ? true : false;
		break;
	case BKGD_COLOR:         // 4
		curAct._a4._timer = in.readSint16BE();
		curAct._a4._newBackgroundColor = in.readUint32BE();
		break;
	case INIT_OBJVXY:        // 5
		curAct._a5._timer = in.readSint16BE();
		curAct._a5._objIndex = in.readSint16BE();
		curAct._a5._vx = in.readSint16BE();
		curAct._a5._vy = in.readSint16BE();
		break;
	case INIT_CARRY:         // 6
		curAct._a6._timer = in.readSint16BE();
		curAct._a6._objIndex = in.readSint16BE();
		curAct._a6._carriedFl = (in.readByte() == 1) ? true : false;
		break;
	case INIT_HF_COORD:      // 7
		curAct._a7._timer = in.readSint16BE();
		curAct._a7._objIndex = in.readSint16BE();
		break;
	case NEW_SCREEN:         // 8
		curAct._a8._timer = in.readSint16BE();
		curAct._a8._screenIndex = in.readSint16BE();
		break;
	case INIT_OBJSTATE:      // 9
		curAct._a9._timer = in.readSint16BE();
		curAct._a9._objIndex = in.readSint16BE();
		curAct._a9._newState = in.readByte();
		break;
	case INIT_PATH:          // 10
		curAct._a10._timer = in.readSint16BE();
		curAct._a10._objIndex = in.readSint16BE();
		curAct._a10._newPathType = in.readSint16BE();
		curAct._a10._vxPath = in.readByte();
		curAct._a10._vyPath = in.readByte();
		break;
	case COND_R:             // 11
		curAct._a11._timer = in.readSint16BE();
		curAct._a11._objIndex = in.readSint16BE();
		curAct._a11._stateReq = in.readByte();
		curAct._a11._actPassIndex = in.readUint16BE();
		curAct._a11._actFailIndex = in.readUint16BE();
		break;
	case TEXT:               // 12
		curAct._a12._timer = in.readSint16BE();
		curAct._a12._stringIndex = in.readSint16BE();
		break;
	case SWAP_IMAGES:        // 13
		curAct._a13._timer = in.readSint16BE();
		curAct._a13._objIndex1 = in.readSint16BE();
		curAct._a13._objIndex2 = in.readSint16BE();
		break;
	case COND_SCR:           // 14
		curAct._a14._timer = in.readSint16BE();
		curAct._a14._objIndex = in.readSint16BE();
		curAct._a14._screenReq = in.readSint16BE();
		curAct._a14._actPassIndex = in.readUint16BE();
		curAct._a14._actFailIndex = in.readUint16BE();
		break;
	case AUTOPILOT:          // 15
		curAct._a15._timer = in.readSint16BE();
		curAct._a15._objIndex1 = in.readSint16BE();
		curAct._a15._objIndex2 = in.readSint16BE();
		curAct._a15._dx = in.readByte();
		curAct._a15._dy = in.readByte();
		break;
	case INIT_OBJ_SEQ:       // 16
		curAct._a16._timer = in.readSint16BE();
		curAct._a16._objIndex = in.readSint16BE();
		curAct._a16._seqIndex = in.readSint16BE();
		break;
	case SET_STATE_BITS:     // 17
		curAct._a17._timer = in.readSint16BE();
		curAct._a17._objIndex = in.readSint16BE();
		curAct._a17._stateMask = in.readSint16BE();
		break;
	case CLEAR_STATE_BITS:   // 18
		curAct._a18._timer = in.readSint16BE();
		curAct._a18._objIndex = in.readSint16BE();
		curAct._a18._stateMask = in.readSint16BE();
		break;
	case TEST_STATE_BITS:    // 19
		curAct._a19._timer = in.readSint16BE();
		curAct._a19._objIndex = in.readSint16BE();
		curAct._a19._stateMask = in.readSint16BE();
		curAct._a19._actPassIndex = in.readUint16BE();
		curAct._a19._actFailIndex = in.readUint16BE();
		break;
	case DEL_EVENTS:         // 20
		curAct._a20._timer = in.readSint16BE();
		curAct._a20._actTypeDel = (Action) in.readByte();
		break;
	case GAMEOVER:           // 21
		curAct._a21._timer = in.readSint16BE();
		break;
	case INIT_HH_COORD:      // 22
		curAct._a22._timer = in.readSint16BE();
		curAct._a22._objIndex = in.readSint16BE();
		break;
	case EXIT:               // 23
		curAct._a23._timer = in.readSint16BE();
		break;
	case BONUS:              // 24
		curAct._a24._timer = in.readSint16BE();
		curAct._a24._pointIndex = in.readSint16BE();
		break;
	case COND_BOX:           // 25
		curAct._a25._timer = in.readSint16BE();
		curAct._a25._objIndex = in.readSint16BE();
		curAct._a25._x1 = in.readSint16BE();
		curAct._a25._y1 = in.readSint16BE();
		curAct._a25._x2 = in.readSint16BE();
		curAct._a25._y2 = in.readSint16BE();
		curAct._a25._actPassIndex = in.readUint16BE();
		curAct._a25._actFailIndex = in.readUint16BE();
		break;
	case SOUND:              // 26
		curAct._a26._timer = in.readSint16BE();
		curAct._a26._soundIndex = in.readSint16BE();
		break;
	case ADD_SCORE:          // 27
		curAct._a27._timer = in.readSint16BE();
		curAct._a27._objIndex = in.readSint16BE();
		break;
	case SUB_SCORE:          // 28
		curAct._a28._timer = in.readSint16BE();
		curAct._a28._objIndex = in.readSint16BE();
		break;
	case COND_CARRY:         // 29
		curAct._a29._timer = in.readSint16BE();
		curAct._a29._objIndex = in.readSint16BE();
		curAct._a29._actPassIndex = in.readUint16BE();
		curAct._a29._actFailIndex = in.readUint16BE();
		break;
	case INIT_MAZE:          // 30
		curAct._a30._timer = in.readSint16BE();
		curAct._a30._mazeSize = in.readByte();
		curAct._a30._x1 = in.readSint16BE();
		curAct._a30._y1 = in.readSint16BE();
		curAct._a30._x2 = in.readSint16BE();
		curAct._a30._y2 = in.readSint16BE();
		curAct._a30._x3 = in.readSint16BE();
		curAct._a30._x4 = in.readSint16BE();
		curAct._a30._firstScreenIndex = in.readByte();
		break;
	case EXIT_MAZE:          // 31
		curAct._a31._timer = in.readSint16BE();
		break;
	case INIT_PRIORITY:      // 32
		curAct._a32._timer = in.readSint16BE();
		curAct._a32._objIndex = in.readSint16BE();
		curAct._a32._priority = in.readByte();
		break;
	case INIT_SCREEN:        // 33
		curAct._a33._timer = in.readSint16BE();
		curAct._a33._objIndex = in.readSint16BE();
		curAct._a33._screenIndex = in.readSint16BE();
		break;
	case AGSCHEDULE:         // 34
		curAct._a34._timer = in.readSint16BE();
		curAct._a34._actIndex = in.readUint16BE();
		break;
	case REMAPPAL:           // 35
		curAct._a35._timer = in.readSint16BE();
		curAct._a35._oldColorIndex = in.readSint16BE();
		curAct._a35._newColorIndex = in.readSint16BE();
		break;
	case COND_NOUN:          // 36
		curAct._a36._timer = in.readSint16BE();
		curAct._a36._nounIndex = in.readUint16BE();
		curAct._a36._actPassIndex = in.readUint16BE();
		curAct._a36._actFailIndex = in.readUint16BE();
		break;
	case SCREEN_STATE:       // 37
		curAct._a37._timer = in.readSint16BE();
		curAct._a37._screenIndex = in.readSint16BE();
		curAct._a37._newState = in.readByte();
		break;
	case INIT_LIPS:          // 38
		curAct._a38._timer = in.readSint16BE();
		curAct._a38._lipsObjIndex = in.readSint16BE();
		curAct._a38._objIndex = in.readSint16BE();
		curAct._a38._dxLips = in.readByte();
		curAct._a38._dyLips = in.readByte();
		break;
	case INIT_STORY_MODE:    // 39
		curAct._a39._timer = in.readSint16BE();
		curAct._a39._storyModeFl = (in.readByte() == 1);
		break;
	case WARN:               // 40
		curAct._a40._timer = in.readSint16BE();
		curAct._a40._stringIndex = in.readSint16BE();
		break;
	case COND_BONUS:         // 41
		curAct._a41._timer = in.readSint16BE();
		curAct._a41._bonusIndex = in.readSint16BE();
		curAct._a41._actPassIndex = in.readUint16BE();
		curAct._a41._actFailIndex = in.readUint16BE();
		break;
	case TEXT_TAKE:          // 42
		curAct._a42._timer = in.readSint16BE();
		curAct._a42._objIndex = in.readSint16BE();
		break;
	case YESNO:              // 43
		curAct._a43._timer = in.readSint16BE();
		curAct._a43._promptIndex = in.readSint16BE();
		curAct._a43._actYesIndex = in.readUint16BE();
		curAct._a43._actNoIndex = in.readUint16BE();
		break;
	case STOP_ROUTE:         // 44
		curAct._a44._timer = in.readSint16BE();
		break;
	case COND_ROUTE:         // 45
		curAct._a45._timer = in.readSint16BE();
		curAct._a45._routeIndex = in.readSint16BE();
		curAct._a45._actPassIndex = in.readUint16BE();
		curAct._a45._actFailIndex = in.readUint16BE();
		break;
	case INIT_JUMPEXIT:      // 46
		curAct._a46._timer = in.readSint16BE();
		curAct._a46._jumpExitFl = (in.readByte() == 1);
		break;
	case INIT_VIEW:          // 47
		curAct._a47._timer = in.readSint16BE();
		curAct._a47._objIndex = in.readSint16BE();
		curAct._a47._viewx = in.readSint16BE();
		curAct._a47._viewy = in.readSint16BE();
		curAct._a47._direction = in.readSint16BE();
		break;
	case INIT_OBJ_FRAME:     // 48
		curAct._a48._timer = in.readSint16BE();
		curAct._a48._objIndex = in.readSint16BE();
		curAct._a48._seqIndex = in.readSint16BE();
		curAct._a48._frameIndex = in.readSint16BE();
		break;
	case OLD_SONG:           //49
		curAct._a49._timer = in.readSint16BE();
		curAct._a49._songIndex = in.readUint16BE();
		break;
	default:
		error("Engine - Unknown action type encountered: %d", curAct._a0._actType);
	}
}

/**
 * Load actListArr from Hugo.dat
 */
void Scheduler::loadActListArr(Common::ReadStream &in) {
	debugC(6, kDebugSchedule, "loadActListArr(&in)");

	Act tmpAct;

	int numSubElem;
	for (int varnt = 0; varnt < _vm->_numVariant; varnt++) {
		int numElem = in.readUint16BE();
		if (varnt == _vm->_gameVariant) {
			_actListArrSize = numElem;
			_actListArr = (Act **)malloc(sizeof(Act *) * _actListArrSize);
		}

		for (int i = 0; i < numElem; i++) {
			numSubElem = in.readUint16BE();
			if (varnt == _vm->_gameVariant)
				_actListArr[i] = (Act *)malloc(sizeof(Act) * (numSubElem + 1));
			for (int j = 0; j < numSubElem; j++) {
				if (varnt == _vm->_gameVariant) {
					readAct(in, _actListArr[i][j]);
				} else {
					readAct(in, tmpAct);
					if (tmpAct._a0._actType == PROMPT)
						free(tmpAct._a3._responsePtr);
				}
			}

			if (varnt == _vm->_gameVariant)
				_actListArr[i][numSubElem]._a0._actType = ANULL;
		}
	}
}


/**
 * Read _screenActs
 */
void Scheduler::loadScreenAct(Common::SeekableReadStream &in) {
	for (int varnt = 0; varnt < _vm->_numVariant; varnt++) {
		uint16 numElem = in.readUint16BE();

		if (varnt == _vm->_gameVariant) {
			_screenActsSize = numElem;
			_screenActs = (uint16 **)malloc(sizeof(uint16 *) * numElem);
			for (int i = 0; i < numElem; i++) {
				uint16 numSubElem = in.readUint16BE();
				if (numSubElem == 0) {
					_screenActs[i] = nullptr;
				} else {
					_screenActs[i] = (uint16 *)malloc(sizeof(uint16) * numSubElem);
					for (int j = 0; j < numSubElem; j++)
						_screenActs[i][j] = in.readUint16BE();
				}
			}
		} else {
			for (int i = 0; i < numElem; i++) {
				uint16 numSubElem = in.readUint16BE();
				in.skip(numSubElem * sizeof(uint16));
			}
		}
	}
}

void Scheduler::freeScheduler() {
	debugC(6, kDebugSchedule, "freeActListArr()");

	free(_points);
	_points = nullptr;

	if (_screenActs) {
		for (int i = 0; i < _screenActsSize; i++)
			free(_screenActs[i]);
		free(_screenActs);
		_screenActs = nullptr;
		_screenActsSize = 0;
	}

	if (_actListArr) {
		for (int i = 0; i < _actListArrSize; i++) {
			for (int j = 0; _actListArr[i][j]._a0._actType != ANULL; j++) {
				if (_actListArr[i][j]._a0._actType == PROMPT)
					free(_actListArr[i][j]._a3._responsePtr);
			}
			free(_actListArr[i]);
		}
		free(_actListArr);
		_actListArr = nullptr;
		_actListArrSize = 0;
	}
}

/**
 * Add action lists for this screen to event queue
 */
void Scheduler::screenActions(const int screenNum) {
	debugC(1, kDebugEngine, "screenActions(%d)", screenNum);

	uint16 *screenAct = _screenActs[screenNum];
	if (screenAct) {
		for (int i = 0; screenAct[i]; i++)
			insertActionList(screenAct[i]);
	}
}

/**
 * Maze mode is enabled.  Check to see whether hero has crossed the maze
 * bounding box, if so, go to the next room
 */
void Scheduler::processMaze(const int x1, const int x2, const int y1, const int y2) {
	debugC(1, kDebugSchedule, "processMaze");

	if (x1 < _vm->_maze._x1) {
		// Exit west
		_actListArr[_alNewscrIndex][3]._a8._screenIndex = *_vm->_screenPtr - 1;
		_actListArr[_alNewscrIndex][0]._a2._x = _vm->_maze._x2 - kShiftSize - (x2 - x1);
		_actListArr[_alNewscrIndex][0]._a2._y = _vm->_hero->_y;
		_vm->_route->resetRoute();
		insertActionList(_alNewscrIndex);
	} else if (x2 > _vm->_maze._x2) {
		// Exit east
		_actListArr[_alNewscrIndex][3]._a8._screenIndex = *_vm->_screenPtr + 1;
		_actListArr[_alNewscrIndex][0]._a2._x = _vm->_maze._x1 + kShiftSize;
		_actListArr[_alNewscrIndex][0]._a2._y = _vm->_hero->_y;
		_vm->_route->resetRoute();
		insertActionList(_alNewscrIndex);
	} else if (y1 < _vm->_maze._y1 - kShiftSize) {
		// Exit north
		_actListArr[_alNewscrIndex][3]._a8._screenIndex = *_vm->_screenPtr - _vm->_maze._size;
		_actListArr[_alNewscrIndex][0]._a2._x = _vm->_maze._x3;
		_actListArr[_alNewscrIndex][0]._a2._y = _vm->_maze._y2 - kShiftSize - (y2 - y1);
		_vm->_route->resetRoute();
		insertActionList(_alNewscrIndex);
	} else if (y2 > _vm->_maze._y2 - kShiftSize / 2) {
		// Exit south
		_actListArr[_alNewscrIndex][3]._a8._screenIndex = *_vm->_screenPtr + _vm->_maze._size;
		_actListArr[_alNewscrIndex][0]._a2._x = _vm->_maze._x4;
		_actListArr[_alNewscrIndex][0]._a2._y = _vm->_maze._y1 + kShiftSize;
		_vm->_route->resetRoute();
		insertActionList(_alNewscrIndex);
	}
}

/**
 * Write the event queue to the file with handle f
 * Note that we convert all the event structure ptrs to indexes
 * using -1 for NULL.  We can't convert the action ptrs to indexes
 * so we save address of first dummy action ptr to compare on restore.
 */
void Scheduler::saveEvents(Common::WriteStream *f) {
	debugC(1, kDebugSchedule, "saveEvents()");

	f->writeUint32BE(getTicks());

	int16 freeIndex = (_freeEvent == nullptr) ? -1 : _freeEvent - _events;
	int16 headIndex = (_headEvent == nullptr) ? -1 : _headEvent - _events;
	int16 tailIndex = (_tailEvent == nullptr) ? -1 : _tailEvent - _events;

	f->writeSint16BE(freeIndex);
	f->writeSint16BE(headIndex);
	f->writeSint16BE(tailIndex);

	// Convert event ptrs to indexes
	for (int16 i = 0; i < kMaxEvents; i++) {
		Event *wrkEvent = &_events[i];

		// fix up action pointer (to do better)
		int16 index, subElem;
		findAction(wrkEvent->_action, &index, &subElem);
		f->writeSint16BE(index);
		f->writeSint16BE(subElem);
		f->writeByte((wrkEvent->_localActionFl) ? 1 : 0);
		f->writeUint32BE(wrkEvent->_time);
		f->writeSint16BE((wrkEvent->_prevEvent == nullptr) ? -1 : (wrkEvent->_prevEvent - _events));
		f->writeSint16BE((wrkEvent->_nextEvent == nullptr) ? -1 : (wrkEvent->_nextEvent - _events));
	}
}

/**
 * Restore the action data from file with handle f
 */

void Scheduler::restoreActions(Common::ReadStream *f) {
	for (int i = 0; i < _actListArrSize; i++) {
		uint16 numSubElem = f->readUint16BE();
		for (int j = 0; j < numSubElem; j++) {
			readAct(*f, _actListArr[i][j]);
		}
	}
}

int16 Scheduler::calcMaxPoints() const {
	int16 tmpScore = 0;
	for (int i = 0; i < _numBonuses; i++)
		tmpScore += _points[i]._score;
	return tmpScore;
}

/*
* Save the action data in the file with handle f
*/
void Scheduler::saveActions(Common::WriteStream *f) const {
	byte  subElemType;
	int16 nbrCpt;
	uint16 nbrSubElem;

	for (int i = 0; i < _actListArrSize; i++) {
		// write all the sub elems data
		for (nbrSubElem = 1; _actListArr[i][nbrSubElem - 1]._a0._actType != ANULL; nbrSubElem++)
			;

		f->writeUint16BE(nbrSubElem);
		for (int j = 0; j < nbrSubElem; j++) {
			subElemType = _actListArr[i][j]._a0._actType;
			f->writeByte(subElemType);
			switch (subElemType) {
			case ANULL:              // -1
				break;
			case ASCHEDULE:          // 0
				f->writeSint16BE(_actListArr[i][j]._a0._timer);
				f->writeUint16BE(_actListArr[i][j]._a0._actIndex);
				break;
			case START_OBJ:          // 1
				f->writeSint16BE(_actListArr[i][j]._a1._timer);
				f->writeSint16BE(_actListArr[i][j]._a1._objIndex);
				f->writeSint16BE(_actListArr[i][j]._a1._cycleNumb);
				f->writeByte(_actListArr[i][j]._a1._cycle);
				break;
			case INIT_OBJXY:         // 2
				f->writeSint16BE(_actListArr[i][j]._a2._timer);
				f->writeSint16BE(_actListArr[i][j]._a2._objIndex);
				f->writeSint16BE(_actListArr[i][j]._a2._x);
				f->writeSint16BE(_actListArr[i][j]._a2._y);
				break;
			case PROMPT:             // 3
				f->writeSint16BE(_actListArr[i][j]._a3._timer);
				f->writeSint16BE(_actListArr[i][j]._a3._promptIndex);
				for (nbrCpt = 0; _actListArr[i][j]._a3._responsePtr[nbrCpt] != -1; nbrCpt++)
					;
				nbrCpt++;
				f->writeUint16BE(nbrCpt);
				for (int k = 0; k < nbrCpt; k++)
					f->writeSint16BE(_actListArr[i][j]._a3._responsePtr[k]);
				f->writeUint16BE(_actListArr[i][j]._a3._actPassIndex);
				f->writeUint16BE(_actListArr[i][j]._a3._actFailIndex);
				f->writeByte((_actListArr[i][j]._a3._encodedFl) ? 1 : 0);
				break;
			case BKGD_COLOR:         // 4
				f->writeSint16BE(_actListArr[i][j]._a4._timer);
				f->writeUint32BE(_actListArr[i][j]._a4._newBackgroundColor);
				break;
			case INIT_OBJVXY:        // 5
				f->writeSint16BE(_actListArr[i][j]._a5._timer);
				f->writeSint16BE(_actListArr[i][j]._a5._objIndex);
				f->writeSint16BE(_actListArr[i][j]._a5._vx);
				f->writeSint16BE(_actListArr[i][j]._a5._vy);
				break;
			case INIT_CARRY:         // 6
				f->writeSint16BE(_actListArr[i][j]._a6._timer);
				f->writeSint16BE(_actListArr[i][j]._a6._objIndex);
				f->writeByte((_actListArr[i][j]._a6._carriedFl) ? 1 : 0);
				break;
			case INIT_HF_COORD:      // 7
				f->writeSint16BE(_actListArr[i][j]._a7._timer);
				f->writeSint16BE(_actListArr[i][j]._a7._objIndex);
				break;
			case NEW_SCREEN:         // 8
				f->writeSint16BE(_actListArr[i][j]._a8._timer);
				f->writeSint16BE(_actListArr[i][j]._a8._screenIndex);
				break;
			case INIT_OBJSTATE:      // 9
				f->writeSint16BE(_actListArr[i][j]._a9._timer);
				f->writeSint16BE(_actListArr[i][j]._a9._objIndex);
				f->writeByte(_actListArr[i][j]._a9._newState);
				break;
			case INIT_PATH:          // 10
				f->writeSint16BE(_actListArr[i][j]._a10._timer);
				f->writeSint16BE(_actListArr[i][j]._a10._objIndex);
				f->writeSint16BE(_actListArr[i][j]._a10._newPathType);
				f->writeByte(_actListArr[i][j]._a10._vxPath);
				f->writeByte(_actListArr[i][j]._a10._vyPath);
				break;
			case COND_R:             // 11
				f->writeSint16BE(_actListArr[i][j]._a11._timer);
				f->writeSint16BE(_actListArr[i][j]._a11._objIndex);
				f->writeByte(_actListArr[i][j]._a11._stateReq);
				f->writeUint16BE(_actListArr[i][j]._a11._actPassIndex);
				f->writeUint16BE(_actListArr[i][j]._a11._actFailIndex);
				break;
			case TEXT:               // 12
				f->writeSint16BE(_actListArr[i][j]._a12._timer);
				f->writeSint16BE(_actListArr[i][j]._a12._stringIndex);
				break;
			case SWAP_IMAGES:        // 13
				f->writeSint16BE(_actListArr[i][j]._a13._timer);
				f->writeSint16BE(_actListArr[i][j]._a13._objIndex1);
				f->writeSint16BE(_actListArr[i][j]._a13._objIndex2);
				break;
			case COND_SCR:           // 14
				f->writeSint16BE(_actListArr[i][j]._a14._timer);
				f->writeSint16BE(_actListArr[i][j]._a14._objIndex);
				f->writeSint16BE(_actListArr[i][j]._a14._screenReq);
				f->writeUint16BE(_actListArr[i][j]._a14._actPassIndex);
				f->writeUint16BE(_actListArr[i][j]._a14._actFailIndex);
				break;
			case AUTOPILOT:          // 15
				f->writeSint16BE(_actListArr[i][j]._a15._timer);
				f->writeSint16BE(_actListArr[i][j]._a15._objIndex1);
				f->writeSint16BE(_actListArr[i][j]._a15._objIndex2);
				f->writeByte(_actListArr[i][j]._a15._dx);
				f->writeByte(_actListArr[i][j]._a15._dy);
				break;
			case INIT_OBJ_SEQ:       // 16
				f->writeSint16BE(_actListArr[i][j]._a16._timer);
				f->writeSint16BE(_actListArr[i][j]._a16._objIndex);
				f->writeSint16BE(_actListArr[i][j]._a16._seqIndex);
				break;
			case SET_STATE_BITS:     // 17
				f->writeSint16BE(_actListArr[i][j]._a17._timer);
				f->writeSint16BE(_actListArr[i][j]._a17._objIndex);
				f->writeSint16BE(_actListArr[i][j]._a17._stateMask);
				break;
			case CLEAR_STATE_BITS:   // 18
				f->writeSint16BE(_actListArr[i][j]._a18._timer);
				f->writeSint16BE(_actListArr[i][j]._a18._objIndex);
				f->writeSint16BE(_actListArr[i][j]._a18._stateMask);
				break;
			case TEST_STATE_BITS:    // 19
				f->writeSint16BE(_actListArr[i][j]._a19._timer);
				f->writeSint16BE(_actListArr[i][j]._a19._objIndex);
				f->writeSint16BE(_actListArr[i][j]._a19._stateMask);
				f->writeUint16BE(_actListArr[i][j]._a19._actPassIndex);
				f->writeUint16BE(_actListArr[i][j]._a19._actFailIndex);
				break;
			case DEL_EVENTS:         // 20
				f->writeSint16BE(_actListArr[i][j]._a20._timer);
				f->writeByte(_actListArr[i][j]._a20._actTypeDel);
				break;
			case GAMEOVER:           // 21
				f->writeSint16BE(_actListArr[i][j]._a21._timer);
				break;
			case INIT_HH_COORD:      // 22
				f->writeSint16BE(_actListArr[i][j]._a22._timer);
				f->writeSint16BE(_actListArr[i][j]._a22._objIndex);
				break;
			case EXIT:               // 23
				f->writeSint16BE(_actListArr[i][j]._a23._timer);
				break;
			case BONUS:              // 24
				f->writeSint16BE(_actListArr[i][j]._a24._timer);
				f->writeSint16BE(_actListArr[i][j]._a24._pointIndex);
				break;
			case COND_BOX:           // 25
				f->writeSint16BE(_actListArr[i][j]._a25._timer);
				f->writeSint16BE(_actListArr[i][j]._a25._objIndex);
				f->writeSint16BE(_actListArr[i][j]._a25._x1);
				f->writeSint16BE(_actListArr[i][j]._a25._y1);
				f->writeSint16BE(_actListArr[i][j]._a25._x2);
				f->writeSint16BE(_actListArr[i][j]._a25._y2);
				f->writeUint16BE(_actListArr[i][j]._a25._actPassIndex);
				f->writeUint16BE(_actListArr[i][j]._a25._actFailIndex);
				break;
			case SOUND:              // 26
				f->writeSint16BE(_actListArr[i][j]._a26._timer);
				f->writeSint16BE(_actListArr[i][j]._a26._soundIndex);
				break;
			case ADD_SCORE:          // 27
				f->writeSint16BE(_actListArr[i][j]._a27._timer);
				f->writeSint16BE(_actListArr[i][j]._a27._objIndex);
				break;
			case SUB_SCORE:          // 28
				f->writeSint16BE(_actListArr[i][j]._a28._timer);
				f->writeSint16BE(_actListArr[i][j]._a28._objIndex);
				break;
			case COND_CARRY:         // 29
				f->writeSint16BE(_actListArr[i][j]._a29._timer);
				f->writeSint16BE(_actListArr[i][j]._a29._objIndex);
				f->writeUint16BE(_actListArr[i][j]._a29._actPassIndex);
				f->writeUint16BE(_actListArr[i][j]._a29._actFailIndex);
				break;
			case INIT_MAZE:          // 30
				f->writeSint16BE(_actListArr[i][j]._a30._timer);
				f->writeByte(_actListArr[i][j]._a30._mazeSize);
				f->writeSint16BE(_actListArr[i][j]._a30._x1);
				f->writeSint16BE(_actListArr[i][j]._a30._y1);
				f->writeSint16BE(_actListArr[i][j]._a30._x2);
				f->writeSint16BE(_actListArr[i][j]._a30._y2);
				f->writeSint16BE(_actListArr[i][j]._a30._x3);
				f->writeSint16BE(_actListArr[i][j]._a30._x4);
				f->writeByte(_actListArr[i][j]._a30._firstScreenIndex);
				break;
			case EXIT_MAZE:          // 31
				f->writeSint16BE(_actListArr[i][j]._a31._timer);
				break;
			case INIT_PRIORITY:      // 32
				f->writeSint16BE(_actListArr[i][j]._a32._timer);
				f->writeSint16BE(_actListArr[i][j]._a32._objIndex);
				f->writeByte(_actListArr[i][j]._a32._priority);
				break;
			case INIT_SCREEN:        // 33
				f->writeSint16BE(_actListArr[i][j]._a33._timer);
				f->writeSint16BE(_actListArr[i][j]._a33._objIndex);
				f->writeSint16BE(_actListArr[i][j]._a33._screenIndex);
				break;
			case AGSCHEDULE:         // 34
				f->writeSint16BE(_actListArr[i][j]._a34._timer);
				f->writeUint16BE(_actListArr[i][j]._a34._actIndex);
				break;
			case REMAPPAL:           // 35
				f->writeSint16BE(_actListArr[i][j]._a35._timer);
				f->writeSint16BE(_actListArr[i][j]._a35._oldColorIndex);
				f->writeSint16BE(_actListArr[i][j]._a35._newColorIndex);
				break;
			case COND_NOUN:          // 36
				f->writeSint16BE(_actListArr[i][j]._a36._timer);
				f->writeUint16BE(_actListArr[i][j]._a36._nounIndex);
				f->writeUint16BE(_actListArr[i][j]._a36._actPassIndex);
				f->writeUint16BE(_actListArr[i][j]._a36._actFailIndex);
				break;
			case SCREEN_STATE:       // 37
				f->writeSint16BE(_actListArr[i][j]._a37._timer);
				f->writeSint16BE(_actListArr[i][j]._a37._screenIndex);
				f->writeByte(_actListArr[i][j]._a37._newState);
				break;
			case INIT_LIPS:          // 38
				f->writeSint16BE(_actListArr[i][j]._a38._timer);
				f->writeSint16BE(_actListArr[i][j]._a38._lipsObjIndex);
				f->writeSint16BE(_actListArr[i][j]._a38._objIndex);
				f->writeByte(_actListArr[i][j]._a38._dxLips);
				f->writeByte(_actListArr[i][j]._a38._dyLips);
				break;
			case INIT_STORY_MODE:    // 39
				f->writeSint16BE(_actListArr[i][j]._a39._timer);
				f->writeByte((_actListArr[i][j]._a39._storyModeFl) ? 1 : 0);
				break;
			case WARN:               // 40
				f->writeSint16BE(_actListArr[i][j]._a40._timer);
				f->writeSint16BE(_actListArr[i][j]._a40._stringIndex);
				break;
			case COND_BONUS:         // 41
				f->writeSint16BE(_actListArr[i][j]._a41._timer);
				f->writeSint16BE(_actListArr[i][j]._a41._bonusIndex);
				f->writeUint16BE(_actListArr[i][j]._a41._actPassIndex);
				f->writeUint16BE(_actListArr[i][j]._a41._actFailIndex);
				break;
			case TEXT_TAKE:          // 42
				f->writeSint16BE(_actListArr[i][j]._a42._timer);
				f->writeSint16BE(_actListArr[i][j]._a42._objIndex);
				break;
			case YESNO:              // 43
				f->writeSint16BE(_actListArr[i][j]._a43._timer);
				f->writeSint16BE(_actListArr[i][j]._a43._promptIndex);
				f->writeUint16BE(_actListArr[i][j]._a43._actYesIndex);
				f->writeUint16BE(_actListArr[i][j]._a43._actNoIndex);
				break;
			case STOP_ROUTE:         // 44
				f->writeSint16BE(_actListArr[i][j]._a44._timer);
				break;
			case COND_ROUTE:         // 45
				f->writeSint16BE(_actListArr[i][j]._a45._timer);
				f->writeSint16BE(_actListArr[i][j]._a45._routeIndex);
				f->writeUint16BE(_actListArr[i][j]._a45._actPassIndex);
				f->writeUint16BE(_actListArr[i][j]._a45._actFailIndex);
				break;
			case INIT_JUMPEXIT:      // 46
				f->writeSint16BE(_actListArr[i][j]._a46._timer);
				f->writeByte((_actListArr[i][j]._a46._jumpExitFl) ? 1 : 0);
				break;
			case INIT_VIEW:          // 47
				f->writeSint16BE(_actListArr[i][j]._a47._timer);
				f->writeSint16BE(_actListArr[i][j]._a47._objIndex);
				f->writeSint16BE(_actListArr[i][j]._a47._viewx);
				f->writeSint16BE(_actListArr[i][j]._a47._viewy);
				f->writeSint16BE(_actListArr[i][j]._a47._direction);
				break;
			case INIT_OBJ_FRAME:     // 48
				f->writeSint16BE(_actListArr[i][j]._a48._timer);
				f->writeSint16BE(_actListArr[i][j]._a48._objIndex);
				f->writeSint16BE(_actListArr[i][j]._a48._seqIndex);
				f->writeSint16BE(_actListArr[i][j]._a48._frameIndex);
				break;
			case OLD_SONG:           // 49, Added by Strangerke for DOS versions
				f->writeSint16BE(_actListArr[i][j]._a49._timer);
				f->writeUint16BE(_actListArr[i][j]._a49._songIndex);
				break;
			default:
				error("Unknown action %d", subElemType);
			}
		}
	}
}

/*
* Find the index in the action list to be able to serialize the action to save game
*/
void Scheduler::findAction(const Act *action, int16 *index, int16 *subElem) {

	assert(index && subElem);
	if (!action) {
		*index = -1;
		*subElem = -1;
		return;
	}

	for (int i = 0; i < _actListArrSize; i++) {
		int j = 0;
		do {
			if (action == &_actListArr[i][j]) {
				*index = i;
				*subElem = j;
				return;
			}
			j++;
		} while (_actListArr[i][j-1]._a0._actType != ANULL);
	}
	// action not found ??
	assert(0);
}

void Scheduler::saveSchedulerData(Common::WriteStream *out) {
	savePoints(out);

	// Now save current time and all current events in event queue
	saveEvents(out);

	// Now save current actions
	saveActions(out);
}

void Scheduler::restoreSchedulerData(Common::ReadStream *in) {
	restorePoints(in);
	_vm->_object->restoreAllSeq();

	// Now restore time of the save and the event queue
	restoreEvents(in);

	// Now restore actions
	restoreActions(in);
}

/**
 * Restore the event list from file with handle f
 */
void Scheduler::restoreEvents(Common::ReadStream *f) {
	debugC(1, kDebugSchedule, "restoreEvents");

	uint32 saveTime = f->readUint32BE();              // time of save
	int16 freeIndex = f->readSint16BE();              // Free list index
	int16 headIndex = f->readSint16BE();              // Head of list index
	int16 tailIndex = f->readSint16BE();              // Tail of list index

	// Restore events indexes to pointers
	for (int i = 0; i < kMaxEvents; i++) {
		int16 index = f->readSint16BE();
		int16 subElem = f->readSint16BE();

		// fix up action pointer (to do better)
		if ((index == -1) && (subElem == -1))
			_events[i]._action = nullptr;
		else
			_events[i]._action = (Act *)&_actListArr[index][subElem];

		_events[i]._localActionFl = (f->readByte() == 1) ? true : false;
		_events[i]._time = f->readUint32BE();

		int16 prevIndex = f->readSint16BE();
		int16 nextIndex = f->readSint16BE();

		_events[i]._prevEvent = (prevIndex == -1) ? nullptr : &_events[prevIndex];
		_events[i]._nextEvent = (nextIndex == -1) ? nullptr : &_events[nextIndex];
	}
	_freeEvent = (freeIndex == -1) ? nullptr : &_events[freeIndex];
	_headEvent = (headIndex == -1) ? nullptr : &_events[headIndex];
	_tailEvent = (tailIndex == -1) ? nullptr : &_events[tailIndex];

	// Adjust times to fit our time
	uint32 curTime = getTicks();
	Event *wrkEvent = _headEvent;                     // The earliest event
	while (wrkEvent) {                                // While mature events found
		wrkEvent->_time = wrkEvent->_time - saveTime + curTime;
		wrkEvent = wrkEvent->_nextEvent;
	}
}

/**
 * Insert the action pointed to by p into the timer event queue
 * The queue goes from head (earliest) to tail (latest) timewise
 */
void Scheduler::insertAction(Act *action) {
	debugC(1, kDebugSchedule, "insertAction() - Action type A%d", action->_a0._actType);

	// First, get and initialize the event structure
	Event *curEvent = getQueue();
	curEvent->_action = action;
	switch (action->_a0._actType) {                   // Assign whether local or global
	case AGSCHEDULE:
		curEvent->_localActionFl = false;               // Lasts over a new screen
		break;
	// Workaround: When dying, switch to storyMode in order to block the keyboard.
	case GAMEOVER:
		_vm->getGameStatus()._storyModeFl = true;
		// fall through
	default:
		curEvent->_localActionFl = true;                // Rest are for current screen only
		break;
	}

	curEvent->_time = action->_a0._timer + getTicks(); // Convert rel to abs time

	// Now find the place to insert the event
	if (!_tailEvent) {                                // Empty queue
		_tailEvent = _headEvent = curEvent;
		curEvent->_nextEvent = curEvent->_prevEvent = nullptr;
	} else {
		Event *wrkEvent = _tailEvent;                   // Search from latest time back
		bool found = false;

		while (wrkEvent && !found) {
			if (wrkEvent->_time <= curEvent->_time) {     // Found if new event later
				found = true;
				if (wrkEvent == _tailEvent)                 // New latest in list
					_tailEvent = curEvent;
				else
					wrkEvent->_nextEvent->_prevEvent = curEvent;
				curEvent->_nextEvent = wrkEvent->_nextEvent;
				wrkEvent->_nextEvent = curEvent;
				curEvent->_prevEvent = wrkEvent;
			}
			wrkEvent = wrkEvent->_prevEvent;
		}

		if (!found) {                                   // Must be earliest in list
			_headEvent->_prevEvent = curEvent;            // So insert as new head
			curEvent->_nextEvent = _headEvent;
			curEvent->_prevEvent = nullptr;
			_headEvent = curEvent;
		}
	}
}

/**
 * This function performs the action in the event structure pointed to by p
 * It dequeues the event and returns it to the free list.  It returns a ptr
 * to the next action in the list, except special case of NEW_SCREEN
 */
Event *Scheduler::doAction(Event *curEvent) {
	debugC(1, kDebugSchedule, "doAction - Event action type : %d", curEvent->_action->_a0._actType);

	Status &gameStatus = _vm->getGameStatus();
	Act    *action = curEvent->_action;
	Object *obj1;
	int     dx, dy;
	switch (action->_a0._actType) {
	case ANULL:                                       // Big NOP from DEL_EVENTS
		break;
	case ASCHEDULE:                                   // act0: Schedule an action list
		insertActionList(action->_a0._actIndex);
		break;
	case START_OBJ:                                   // act1: Start an object cycling
		_vm->_object->_objects[action->_a1._objIndex]._cycleNumb = action->_a1._cycleNumb;
		_vm->_object->_objects[action->_a1._objIndex]._cycling = action->_a1._cycle;
		break;
	case INIT_OBJXY:                                  // act2: Initialize an object
		_vm->_object->_objects[action->_a2._objIndex]._x = action->_a2._x;          // Coordinates
		_vm->_object->_objects[action->_a2._objIndex]._y = action->_a2._y;
		break;
	case PROMPT:                                      // act3: Prompt user for key phrase
		promptAction(action);
		break;
	case BKGD_COLOR:                                  // act4: Set new background color
		_vm->_screen->setBackgroundColor(action->_a4._newBackgroundColor);
		break;
	case INIT_OBJVXY:                                 // act5: Initialize an object velocity
		_vm->_object->setVelocity(action->_a5._objIndex, action->_a5._vx, action->_a5._vy);
		break;
	case INIT_CARRY:                                  // act6: Initialize an object
		_vm->_object->setCarry(action->_a6._objIndex, action->_a6._carriedFl);  // carried status
		break;
	case INIT_HF_COORD:                               // act7: Initialize an object to hero's "feet" coords
		_vm->_object->_objects[action->_a7._objIndex]._x = _vm->_hero->_x - 1;
		_vm->_object->_objects[action->_a7._objIndex]._y = _vm->_hero->_y + _vm->_hero->_currImagePtr->_y2 - 1;
		_vm->_object->_objects[action->_a7._objIndex]._screenIndex = *_vm->_screenPtr;  // Don't forget screen!
		break;
	case NEW_SCREEN:                                  // act8: Start new screen
		newScreen(action->_a8._screenIndex);
		break;
	case INIT_OBJSTATE:                               // act9: Initialize an object state
		_vm->_object->_objects[action->_a9._objIndex]._state = action->_a9._newState;
		break;
	case INIT_PATH:                                   // act10: Initialize an object path and velocity
		_vm->_object->setPath(action->_a10._objIndex, (Path) action->_a10._newPathType, action->_a10._vxPath, action->_a10._vyPath);
		break;
	case COND_R:                                      // act11: action lists conditional on object state
		if (_vm->_object->_objects[action->_a11._objIndex]._state == action->_a11._stateReq)
			insertActionList(action->_a11._actPassIndex);
		else
			insertActionList(action->_a11._actFailIndex);
		break;
	case TEXT:                                        // act12: Text box (CF WARN)
		Utils::notifyBox(_vm->_file->fetchString(action->_a12._stringIndex));   // Fetch string from file
		break;
	case SWAP_IMAGES:                                 // act13: Swap 2 object images
		_vm->_object->swapImages(action->_a13._objIndex1, action->_a13._objIndex2);
		break;
	case COND_SCR:                                    // act14: Conditional on current screen
		if (_vm->_object->_objects[action->_a14._objIndex]._screenIndex == action->_a14._screenReq)
			insertActionList(action->_a14._actPassIndex);
		else
			insertActionList(action->_a14._actFailIndex);
		break;
	case AUTOPILOT:                                   // act15: Home in on a (stationary) object
		_vm->_object->homeIn(action->_a15._objIndex1, action->_a15._objIndex2, action->_a15._dx, action->_a15._dy);
		break;
	case INIT_OBJ_SEQ:                                // act16: Set sequence number to use
		// Note: Don't set a sequence at time 0 of a new screen, it causes
		// problems clearing the boundary bits of the object!  t>0 is safe
		_vm->_object->_objects[action->_a16._objIndex]._currImagePtr = _vm->_object->_objects[action->_a16._objIndex]._seqList[action->_a16._seqIndex]._seqPtr;
		break;
	case SET_STATE_BITS:                              // act17: OR mask with curr obj state
		_vm->_object->_objects[action->_a17._objIndex]._state |= action->_a17._stateMask;
		break;
	case CLEAR_STATE_BITS:                            // act18: AND ~mask with curr obj state
		_vm->_object->_objects[action->_a18._objIndex]._state &= ~action->_a18._stateMask;
		break;
	case TEST_STATE_BITS:                             // act19: If all bits set, do apass else afail
		if ((_vm->_object->_objects[action->_a19._objIndex]._state & action->_a19._stateMask) == action->_a19._stateMask)
			insertActionList(action->_a19._actPassIndex);
		else
			insertActionList(action->_a19._actFailIndex);
		break;
	case DEL_EVENTS:                                  // act20: Remove all events of this action type
		delEventType(action->_a20._actTypeDel);
		break;
	case GAMEOVER:                                    // act21: Game over!
		// NOTE: Must wait at least 1 tick before issuing this action if
		// any objects are to be made invisible!
		gameStatus._gameOverFl = true;
		break;
	case INIT_HH_COORD:                               // act22: Initialize an object to hero's actual coords
		_vm->_object->_objects[action->_a22._objIndex]._x = _vm->_hero->_x;
		_vm->_object->_objects[action->_a22._objIndex]._y = _vm->_hero->_y;
		_vm->_object->_objects[action->_a22._objIndex]._screenIndex = *_vm->_screenPtr;// Don't forget screen!
		break;
	case EXIT:                                        // act23: Exit game back to DOS
		_vm->endGame();
		break;
	case BONUS:                                       // act24: Get bonus score for action
		processBonus(action->_a24._pointIndex);
		break;
	case COND_BOX:                                    // act25: Conditional on bounding box
		obj1 = &_vm->_object->_objects[action->_a25._objIndex];
		dx = obj1->_x + obj1->_currImagePtr->_x1;
		dy = obj1->_y + obj1->_currImagePtr->_y2;
		if ((dx >= action->_a25._x1) && (dx <= action->_a25._x2) &&
		        (dy >= action->_a25._y1) && (dy <= action->_a25._y2))
			insertActionList(action->_a25._actPassIndex);
		else
			insertActionList(action->_a25._actFailIndex);
		break;
	case SOUND:                                       // act26: Play a sound (or tune)
		if (action->_a26._soundIndex < _vm->_tunesNbr)
			_vm->_sound->playMusic(action->_a26._soundIndex);
		else
			_vm->_sound->playSound(action->_a26._soundIndex, kSoundPriorityMedium);
		break;
	case ADD_SCORE:                                   // act27: Add object's value to score
		_vm->adjustScore(_vm->_object->_objects[action->_a27._objIndex]._objValue);
		break;
	case SUB_SCORE:                                   // act28: Subtract object's value from score
		_vm->adjustScore(-_vm->_object->_objects[action->_a28._objIndex]._objValue);
		break;
	case COND_CARRY:                                  // act29: Conditional on object being carried
		if (_vm->_object->isCarried(action->_a29._objIndex))
			insertActionList(action->_a29._actPassIndex);
		else
			insertActionList(action->_a29._actFailIndex);
		break;
	case INIT_MAZE:                                   // act30: Enable and init maze structure
		_vm->_maze._enabledFl = true;
		_vm->_maze._size = action->_a30._mazeSize;
		_vm->_maze._x1 = action->_a30._x1;
		_vm->_maze._y1 = action->_a30._y1;
		_vm->_maze._x2 = action->_a30._x2;
		_vm->_maze._y2 = action->_a30._y2;
		_vm->_maze._x3 = action->_a30._x3;
		_vm->_maze._x4 = action->_a30._x4;
		_vm->_maze._firstScreenIndex = action->_a30._firstScreenIndex;
		break;
	case EXIT_MAZE:                                   // act31: Disable maze mode
		_vm->_maze._enabledFl = false;
		break;
	case INIT_PRIORITY:
		_vm->_object->_objects[action->_a32._objIndex]._priority = action->_a32._priority;
		break;
	case INIT_SCREEN:
		_vm->_object->_objects[action->_a33._objIndex]._screenIndex = action->_a33._screenIndex;
		break;
	case AGSCHEDULE:                                  // act34: Schedule a (global) action list
		insertActionList(action->_a34._actIndex);
		break;
	case REMAPPAL:                                    // act35: Remap a palette color
		_vm->_screen->remapPal(action->_a35._oldColorIndex, action->_a35._newColorIndex);
		break;
	case COND_NOUN:                                   // act36: Conditional on noun mentioned
		if (_vm->_parser->isWordPresent(_vm->_text->getNounArray(action->_a36._nounIndex)))
			insertActionList(action->_a36._actPassIndex);
		else
			insertActionList(action->_a36._actFailIndex);
		break;
	case SCREEN_STATE:                                // act37: Set new screen state
		_vm->_screenStates[action->_a37._screenIndex] = action->_a37._newState;
		break;
	case INIT_LIPS:                                   // act38: Position lips on object
		_vm->_object->_objects[action->_a38._lipsObjIndex]._x = _vm->_object->_objects[action->_a38._objIndex]._x + action->_a38._dxLips;
		_vm->_object->_objects[action->_a38._lipsObjIndex]._y = _vm->_object->_objects[action->_a38._objIndex]._y + action->_a38._dyLips;
		_vm->_object->_objects[action->_a38._lipsObjIndex]._screenIndex = *_vm->_screenPtr; // Don't forget screen!
		_vm->_object->_objects[action->_a38._lipsObjIndex]._cycling = kCycleForward;
		break;
	case INIT_STORY_MODE:                             // act39: Init story_mode flag
		// This is similar to the QUIET path mode, except that it is
		// independant of it and it additionally disables the ">" prompt
		gameStatus._storyModeFl = action->_a39._storyModeFl;
		break;
	case WARN:                                        // act40: Text box (CF TEXT)
		Utils::notifyBox(_vm->_file->fetchString(action->_a40._stringIndex));
		break;
	case COND_BONUS:                                  // act41: Perform action if got bonus
		if (_points[action->_a41._bonusIndex]._scoredFl)
			insertActionList(action->_a41._actPassIndex);
		else
			insertActionList(action->_a41._actFailIndex);
		break;
	case TEXT_TAKE:                                   // act42: Text box with "take" message
		Utils::notifyBox(Common::String::format(TAKE_TEXT, _vm->_text->getNoun(_vm->_object->_objects[action->_a42._objIndex]._nounIndex, TAKE_NAME)));
		break;
	case YESNO:                                       // act43: Prompt user for Yes or No
		if (Utils::yesNoBox(_vm->_file->fetchString(action->_a43._promptIndex)))
			insertActionList(action->_a43._actYesIndex);
		else
			insertActionList(action->_a43._actNoIndex);
		break;
	case STOP_ROUTE:                                  // act44: Stop any route in progress
		_vm->_route->resetRoute();
		break;
	case COND_ROUTE:                                  // act45: Conditional on route in progress
		if (_vm->_route->getRouteIndex() >= action->_a45._routeIndex)
			insertActionList(action->_a45._actPassIndex);
		else
			insertActionList(action->_a45._actFailIndex);
		break;
	case INIT_JUMPEXIT:                               // act46: Init status.jumpexit flag
		// This is to allow left click on exit to get there immediately
		// For example the plane crash in Hugo2 where hero is invisible
		// Couldn't use INVISIBLE flag since conflicts with boat in Hugo1
		_vm->_mouse->setJumpExitFl(action->_a46._jumpExitFl);
		break;
	case INIT_VIEW:                                   // act47: Init object._viewx, viewy, dir
		_vm->_object->_objects[action->_a47._objIndex]._viewx = action->_a47._viewx;
		_vm->_object->_objects[action->_a47._objIndex]._viewy = action->_a47._viewy;
		_vm->_object->_objects[action->_a47._objIndex]._direction = action->_a47._direction;
		break;
	case INIT_OBJ_FRAME:                              // act48: Set seq,frame number to use
		// Note: Don't set a sequence at time 0 of a new screen, it causes
		// problems clearing the boundary bits of the object!  t>0 is safe
		_vm->_object->_objects[action->_a48._objIndex]._currImagePtr = _vm->_object->_objects[action->_a48._objIndex]._seqList[action->_a48._seqIndex]._seqPtr;
		for (dx = 0; dx < action->_a48._frameIndex; dx++)
			_vm->_object->_objects[action->_a48._objIndex]._currImagePtr = _vm->_object->_objects[action->_a48._objIndex]._currImagePtr->_nextSeqPtr;
		break;
	case OLD_SONG:
		// Replaces ACT26 for DOS games.
		_vm->_sound->_DOSSongPtr = _vm->_text->getTextData(action->_a49._songIndex);
		break;
	default:
		error("An error has occurred: %s", "doAction");
		break;
	}

	if (action->_a0._actType == NEW_SCREEN) {         // New_screen() deletes entire list
		return nullptr;                               // nextEvent = nullptr since list now empty
	} else {
		Event *wrkEvent = curEvent->_nextEvent;
		delQueue(curEvent);                             // Return event to free list
		return wrkEvent;                                // Return next event ptr
	}
}

/**
 * Delete an event structure (i.e. return it to the free list)
 * Historical note:  Originally event p was assumed to be at head of queue
 * (i.e. earliest) since all events were deleted in order when proceeding to
 * a new screen.  To delete an event from the middle of the queue, the action
 * was overwritten to be ANULL.  With the advent of GLOBAL events, delQueue
 * was modified to allow deletes anywhere in the list, and the DEL_EVENT
 * action was modified to perform the actual delete.
 */
void Scheduler::delQueue(Event *curEvent) {
	debugC(4, kDebugSchedule, "delQueue()");

	if (curEvent == _headEvent) {                     // If p was the head ptr
		_headEvent = curEvent->_nextEvent;              // then make new head_p
	} else {                                          // Unlink p
		curEvent->_prevEvent->_nextEvent = curEvent->_nextEvent;
		if (curEvent->_nextEvent)
			curEvent->_nextEvent->_prevEvent = curEvent->_prevEvent;
		else
			_tailEvent = curEvent->_prevEvent;
	}

	if (_headEvent)
		_headEvent->_prevEvent = nullptr;             // Mark end of list
	else
		_tailEvent = nullptr;                         // Empty queue

	curEvent->_nextEvent = _freeEvent;                // Return p to free list
	if (_freeEvent)                                   // Special case, if free list was empty
		_freeEvent->_prevEvent = curEvent;
	_freeEvent = curEvent;
}

/**
 * Delete all the active events of a given type
 */
void Scheduler::delEventType(const Action _actTypeDel) {
	// Note: actions are not deleted here, simply turned into NOPs!
	Event *wrkEvent = _headEvent;                     // The earliest event
	Event *saveEvent;

	while (wrkEvent) {                                // While events found in list
		saveEvent = wrkEvent->_nextEvent;
		if (wrkEvent->_action->_a20._actType == _actTypeDel)
			delQueue(wrkEvent);
		wrkEvent = saveEvent;
	}
}

/**
 * Save the points table
 */
void Scheduler::savePoints(Common::WriteStream *out) const {
	for (int i = 0; i < _numBonuses; i++) {
		out->writeByte(_points[i]._score);
		out->writeByte((_points[i]._scoredFl) ? 1 : 0);
	}
}

/**
 * Restore the points table
 */
void Scheduler::restorePoints(Common::ReadStream *in) {
	// Restore points table
	for (int i = 0; i < _numBonuses; i++) {
		_points[i]._score = in->readByte();
		_points[i]._scoredFl = (in->readByte() == 1);
	}
}

Scheduler_v1d::Scheduler_v1d(HugoEngine *vm) : Scheduler(vm) {
}

Scheduler_v1d::~Scheduler_v1d() {
}

const char *Scheduler_v1d::getCypher() const {
	return "Copyright (c) 1990, Gray Design Associates";
}

uint32 Scheduler_v1d::getTicks() {
	return getDosTicks(false);
}

/**
 * This is the scheduler which runs every tick.  It examines the event queue
 * for any events whose time has come.  It dequeues these events and performs
 * the action associated with the event, returning it to the free queue
 */
void Scheduler_v1d::runScheduler() {
	debugC(6, kDebugSchedule, "runScheduler");

	uint32 ticker = getTicks();                       // The time now, in ticks
	Event *curEvent = _headEvent;                     // The earliest event

	while (curEvent && (curEvent->_time <= ticker))   // While mature events found
		curEvent = doAction(curEvent);                  // Perform the action (returns nextEvent)
}

void Scheduler_v1d::promptAction(Act *action) {
	Common::String response;

	response = Utils::promptBox(_vm->_file->fetchString(action->_a3._promptIndex));

	response.toLowercase();

	char resp[256];
	Common::strlcpy(resp, response.c_str(), 256);

	if (action->_a3._encodedFl)
		decodeString(resp);

	if (strstr(resp, _vm->_file->fetchString(action->_a3._responsePtr[0])))
		insertActionList(action->_a3._actPassIndex);
	else
		insertActionList(action->_a3._actFailIndex);
}

/**
 * Decode a response to a prompt
 */
void Scheduler_v1d::decodeString(char *line) {
	debugC(1, kDebugSchedule, "decodeString(%s)", line);

	uint16 linelength = strlen(line);
	for (uint16 i = 0; i < linelength; i++) {
		line[i] = (line[i] + _cypher.c_str()[i % _cypher.size()]) % '~';
		if (line[i] < ' ')
			line[i] += ' ';
	}
}

Scheduler_v2d::Scheduler_v2d(HugoEngine *vm) : Scheduler_v1d(vm) {
}

Scheduler_v2d::~Scheduler_v2d() {
}

const char *Scheduler_v2d::getCypher() const {
	return "Copyright 1991, Gray Design Associates";
}

void Scheduler_v2d::promptAction(Act *action) {
	Common::String response;

	response = Utils::promptBox(_vm->_file->fetchString(action->_a3._promptIndex));
	response.toLowercase();

	debug(1, "doAction(act3), expecting answer %s", _vm->_file->fetchString(action->_a3._responsePtr[0]));

	bool  found = false;

	for (int dx = 0; !found && (action->_a3._responsePtr[dx] != -1); dx++) {
		const char *tmpStr = _vm->_file->fetchString(action->_a3._responsePtr[dx]);
		if (response.contains(tmpStr))
			found = true;
	}

	if (found)
		insertActionList(action->_a3._actPassIndex);
	else
		insertActionList(action->_a3._actFailIndex);
}

/**
 * Decode a string
 */
void Scheduler_v2d::decodeString(char *line) {
	debugC(1, kDebugSchedule, "decodeString(%s)", line);

	int16 lineLength = strlen(line);
	for (uint16 i = 0; i < lineLength; i++)
		line[i] -= _cypher.c_str()[i % _cypher.size()];

	debugC(1, kDebugSchedule, "result : %s", line);
}

Scheduler_v3d::Scheduler_v3d(HugoEngine *vm) : Scheduler_v2d(vm) {
}

Scheduler_v3d::~Scheduler_v3d() {
}

const char *Scheduler_v3d::getCypher() const {
	return "Copyright 1992, Gray Design Associates";
}

Scheduler_v1w::Scheduler_v1w(HugoEngine *vm) : Scheduler_v3d(vm) {
}

Scheduler_v1w::~Scheduler_v1w() {
}

uint32 Scheduler_v1w::getTicks() {
	return getWinTicks();
}

/**
 * This is the scheduler which runs every tick.  It examines the event queue
 * for any events whose time has come.  It dequeues these events and performs
 * the action associated with the event, returning it to the free queue
 */
void Scheduler_v1w::runScheduler() {
	debugC(6, kDebugSchedule, "runScheduler");

	uint32 ticker = getTicks();                       // The time now, in ticks
	Event *curEvent = _headEvent;                     // The earliest event

	while (curEvent && (curEvent->_time <= ticker))   // While mature events found
		curEvent = doAction(curEvent);                  // Perform the action (returns nextEvent)

	_vm->getGameStatus()._tick++;                     // Accessed elsewhere via getTicks()
}
} // End of namespace Hugo