REminiscence/resource.cpp

1302 lines
32 KiB
C++

/*
* REminiscence - Flashback interpreter
* Copyright (C) 2005-2015 Gregory Montoir (cyx@users.sourceforge.net)
*/
#include "file.h"
#include "fs.h"
#include "resource.h"
#include "unpack.h"
#include "util.h"
Resource::Resource(FileSystem *fs, ResourceType ver, Language lang) {
memset(this, 0, sizeof(Resource));
_fs = fs;
_type = ver;
_lang = lang;
_isDemo = false;
_aba = 0;
_readUint16 = (_type == kResourceTypeDOS) ? READ_LE_UINT16 : READ_BE_UINT16;
_readUint32 = (_type == kResourceTypeDOS) ? READ_LE_UINT32 : READ_BE_UINT32;
_scratchBuffer = (uint8_t *)malloc(320 * 224 + 1024);
if (!_scratchBuffer) {
error("Unable to allocate temporary memory buffer");
}
static const int kBankDataSize = 0x7000;
_bankData = (uint8_t *)malloc(kBankDataSize);
if (!_bankData) {
error("Unable to allocate bank data buffer");
}
_bankDataTail = _bankData + kBankDataSize;
clearBankData();
}
Resource::~Resource() {
clearLevelRes();
free(_fnt);
free(_icn); _icn = 0;
_icnLen = 0;
free(_tab);
free(_spc);
free(_spr1);
free(_scratchBuffer);
free(_cmd);
free(_pol);
free(_cine_off);
free(_cine_txt);
for (int i = 0; i < _numSfx; ++i) {
free(_sfxList[i].data);
}
free(_sfxList);
free(_bankData);
delete _aba;
}
void Resource::init() {
switch (_type) {
case kResourceTypeAmiga:
_isDemo = _fs->exists("demo.lev");
break;
case kResourceTypeDOS:
if (_fs->exists(ResourceAba::FILENAME)) {
_aba = new ResourceAba(_fs);
_aba->readEntries();
_isDemo = true;
}
break;
}
}
void Resource::fini() {
}
void Resource::clearLevelRes() {
free(_tbn); _tbn = 0;
free(_mbk); _mbk = 0;
free(_pal); _pal = 0;
free(_map); _map = 0;
free(_lev); _lev = 0;
_levNum = -1;
free(_sgd); _sgd = 0;
free(_bnq); _bnq = 0;
free(_ani); _ani = 0;
free_OBJ();
}
void Resource::load_DEM(const char *filename) {
free(_dem); _dem = 0;
_demLen = 0;
File f;
if (f.open(filename, "rb", _fs)) {
_demLen = f.size();
_dem = (uint8_t *)malloc(_demLen);
if (_dem) {
f.read(_dem, _demLen);
}
}
}
void Resource::load_FIB(const char *fileName) {
debug(DBG_RES, "Resource::load_FIB('%s')", fileName);
static const uint8_t fibonacciTable[] = {
0xDE, 0xEB, 0xF3, 0xF8, 0xFB, 0xFD, 0xFE, 0xFF,
0x00, 0x01, 0x02, 0x03, 0x05, 0x08, 0x0D, 0x15
};
snprintf(_entryName, sizeof(_entryName), "%s.FIB", fileName);
File f;
if (f.open(_entryName, "rb", _fs)) {
_numSfx = f.readUint16LE();
_sfxList = (SoundFx *)malloc(_numSfx * sizeof(SoundFx));
if (!_sfxList) {
error("Unable to allocate SoundFx table");
}
int i;
for (i = 0; i < _numSfx; ++i) {
SoundFx *sfx = &_sfxList[i];
sfx->offset = f.readUint32LE();
sfx->len = f.readUint16LE();
sfx->data = 0;
}
for (i = 0; i < _numSfx; ++i) {
SoundFx *sfx = &_sfxList[i];
if (sfx->len == 0) {
continue;
}
f.seek(sfx->offset);
uint8_t *data = (uint8_t *)malloc(sfx->len * 2);
if (!data) {
error("Unable to allocate SoundFx data buffer");
}
sfx->data = data;
uint8_t c = f.readByte();
*data++ = c;
*data++ = c;
uint16_t sz = sfx->len - 1;
while (sz--) {
uint8_t d = f.readByte();
c += fibonacciTable[d >> 4];
*data++ = c;
c += fibonacciTable[d & 15];
*data++ = c;
}
sfx->len *= 2;
}
if (f.ioErr()) {
error("I/O error when reading '%s'", _entryName);
}
} else {
error("Cannot open '%s'", _entryName);
}
}
void Resource::load_SPL_demo() {
_numSfx = NUM_SFXS;
_sfxList = (SoundFx *)calloc(_numSfx, sizeof(SoundFx));
if (!_sfxList) {
return;
}
for (int i = 0; _splNames[i] && i < NUM_SFXS; ++i) {
File f;
if (f.open(_splNames[i], "rb", _fs)) {
SoundFx *sfx = &_sfxList[i];
const int size = f.size();
sfx->data = (uint8_t *)malloc(size);
if (sfx->data) {
f.read(sfx->data, size);
sfx->offset = 0;
sfx->len = size;
}
}
}
}
void Resource::load_MAP_menu(const char *fileName, uint8_t *dstPtr) {
debug(DBG_RES, "Resource::load_MAP_menu('%s')", fileName);
static const int kMenuMapSize = 0x3800 * 4;
snprintf(_entryName, sizeof(_entryName), "%s.MAP", fileName);
File f;
if (f.open(_entryName, "rb", _fs)) {
if (f.read(dstPtr, kMenuMapSize) != kMenuMapSize) {
error("Failed to read '%s'", _entryName);
}
if (f.ioErr()) {
error("I/O error when reading '%s'", _entryName);
}
return;
} else if (_aba) {
uint32_t size = 0;
uint8_t *dat = _aba->loadEntry(_entryName, &size);
if (dat) {
if (size != kMenuMapSize) {
error("Unexpected size %d for '%s'", size, _entryName);
}
memcpy(dstPtr, dat, size);
free(dat);
return;
}
}
error("Cannot load '%s'", _entryName);
}
void Resource::load_PAL_menu(const char *fileName, uint8_t *dstPtr) {
debug(DBG_RES, "Resource::load_PAL_menu('%s')", fileName);
static const int kMenuPalSize = 768;
snprintf(_entryName, sizeof(_entryName), "%s.PAL", fileName);
File f;
if (f.open(_entryName, "rb", _fs)) {
if (f.read(dstPtr, kMenuPalSize) != kMenuPalSize) {
error("Failed to read '%s'", _entryName);
}
if (f.ioErr()) {
error("I/O error when reading '%s'", _entryName);
}
return;
} else if (_aba) {
uint32_t size = 0;
uint8_t *dat = _aba->loadEntry(_entryName, &size);
if (dat) {
if (size != kMenuPalSize) {
error("Unexpected size %d for '%s'", size, _entryName);
}
memcpy(dstPtr, dat, size);
free(dat);
return;
}
}
error("Cannot load '%s'", _entryName);
}
void Resource::load_CMP_menu(const char *fileName, uint8_t *dstPtr) {
File f;
if (f.open(fileName, "rb", _fs)) {
const uint32_t size = f.readUint32BE();
uint8_t *tmp = (uint8_t *)malloc(size);
if (!tmp) {
error("Failed to allocate CMP temporary buffer");
}
f.read(tmp, size);
if (!delphine_unpack(dstPtr, tmp, size)) {
error("Bad CRC for %s", fileName);
}
free(tmp);
return;
}
error("Cannot load '%s'", fileName);
}
void Resource::load_SPR_OFF(const char *fileName, uint8_t *sprData) {
debug(DBG_RES, "Resource::load_SPR_OFF('%s')", fileName);
snprintf(_entryName, sizeof(_entryName), "%s.OFF", fileName);
uint8_t *offData = 0;
File f;
if (f.open(_entryName, "rb", _fs)) {
const int len = f.size();
offData = (uint8_t *)malloc(len);
if (!offData) {
error("Unable to allocate sprite offsets");
}
f.read(offData, len);
if (f.ioErr()) {
error("I/O error when reading '%s'", _entryName);
}
} else if (_aba) {
offData = _aba->loadEntry(_entryName);
}
if (offData) {
const uint8_t *p = offData;
uint16_t pos;
while ((pos = READ_LE_UINT16(p)) != 0xFFFF) {
assert(pos < NUM_SPRITES);
uint32_t off = READ_LE_UINT32(p + 2);
if (off == 0xFFFFFFFF) {
_sprData[pos] = 0;
} else {
_sprData[pos] = sprData + off;
}
p += 6;
}
free(offData);
return;
}
error("Cannot load '%s'", _entryName);
}
static const char *getCineName(Language lang, ResourceType type) {
switch (lang) {
case LANG_FR:
if (type == kResourceTypeAmiga) {
return "FR";
}
return "FR_";
case LANG_DE:
return "GER";
case LANG_SP:
return "SPA";
case LANG_IT:
return "ITA";
case LANG_EN:
default:
return "ENG";
}
}
void Resource::load_CINE() {
const char *prefix = getCineName(_lang, _type);
debug(DBG_RES, "Resource::load_CINE('%s')", prefix);
if (_type == kResourceTypeAmiga) {
if (_isDemo) {
// file not present in demo data files
return;
}
if (_cine_txt == 0) {
snprintf(_entryName, sizeof(_entryName), "%sCINE.TXT", prefix);
File f;
if (f.open(_entryName, "rb", _fs)) {
const int len = f.size();
_cine_txt = (uint8_t *)malloc(len + 1);
if (!_cine_txt) {
error("Unable to allocate cinematics text data");
}
f.read(_cine_txt, len);
if (f.ioErr()) {
error("I/O error when reading '%s'", _entryName);
}
_cine_txt[len] = 0;
uint8_t *p = _cine_txt;
for (int i = 0; i < NUM_CUTSCENE_TEXTS; ++i) {
_cineStrings[i] = p;
uint8_t *sep = (uint8_t *)memchr(p, '\n', &_cine_txt[len] - p);
if (!sep) {
break;
}
p = sep + 1;
}
}
if (!_cine_txt) {
error("Cannot load '%s'", _entryName);
}
}
return;
}
if (_cine_off == 0) {
snprintf(_entryName, sizeof(_entryName), "%sCINE.BIN", prefix);
File f;
if (f.open(_entryName, "rb", _fs)) {
int len = f.size();
_cine_off = (uint8_t *)malloc(len);
if (!_cine_off) {
error("Unable to allocate cinematics offsets");
}
f.read(_cine_off, len);
if (f.ioErr()) {
error("I/O error when reading '%s'", _entryName);
}
} else if (_aba) {
_cine_off = _aba->loadEntry(_entryName);
}
if (!_cine_off) {
error("Cannot load '%s'", _entryName);
}
}
if (_cine_txt == 0) {
snprintf(_entryName, sizeof(_entryName), "%sCINE.TXT", prefix);
File f;
if (f.open(_entryName, "rb", _fs)) {
int len = f.size();
_cine_txt = (uint8_t *)malloc(len);
if (!_cine_txt) {
error("Unable to allocate cinematics text data");
}
f.read(_cine_txt, len);
if (f.ioErr()) {
error("I/O error when reading '%s'", _entryName);
}
} else if (_aba) {
_cine_txt = _aba->loadEntry(_entryName);
}
if (!_cine_txt) {
error("Cannot load '%s'", _entryName);
}
}
}
void Resource::load_TEXT() {
_stringsTable = 0;
switch (_lang) {
case LANG_FR:
_stringsTable = LocaleData::_stringsTableFR;
break;
case LANG_EN:
_stringsTable = LocaleData::_stringsTableEN;
break;
case LANG_DE:
_stringsTable = LocaleData::_stringsTableDE;
break;
case LANG_SP:
_stringsTable = LocaleData::_stringsTableSP;
break;
case LANG_IT:
_stringsTable = LocaleData::_stringsTableIT;
break;
case LANG_JP:
_stringsTable = LocaleData::_stringsTableJP;
break;
}
// Load menu strings
_textsTable = 0;
switch (_lang) {
case LANG_FR:
_textsTable = LocaleData::_textsTableFR;
break;
case LANG_EN:
_textsTable = LocaleData::_textsTableEN;
break;
case LANG_DE:
_textsTable = LocaleData::_textsTableDE;
break;
case LANG_SP:
_textsTable = LocaleData::_textsTableSP;
break;
case LANG_IT:
_textsTable = LocaleData::_textsTableIT;
break;
case LANG_JP:
_textsTable = LocaleData::_textsTableEN;
break;
}
}
void Resource::free_TEXT() {
_stringsTable = 0;
_textsTable = 0;
}
static const char *getTextBin(Language lang, ResourceType type) {
// FB PC-CD version has language specific files
// .TBN is used as fallback if open fails
switch (lang) {
case LANG_FR:
return "TBF";
case LANG_DE:
return "TBG";
case LANG_SP:
return "TBS";
case LANG_IT:
return "TBI";
case LANG_EN:
default:
return "TBN";
}
}
void Resource::load(const char *objName, int objType, const char *ext) {
debug(DBG_RES, "Resource::load('%s', %d)", objName, objType);
LoadStub loadStub = 0;
switch (objType) {
case OT_MBK:
snprintf(_entryName, sizeof(_entryName), "%s.MBK", objName);
loadStub = &Resource::load_MBK;
break;
case OT_PGE:
snprintf(_entryName, sizeof(_entryName), "%s.PGE", objName);
loadStub = &Resource::load_PGE;
break;
case OT_PAL:
snprintf(_entryName, sizeof(_entryName), "%s.PAL", objName);
loadStub = &Resource::load_PAL;
break;
case OT_CT:
snprintf(_entryName, sizeof(_entryName), "%s.CT", objName);
loadStub = &Resource::load_CT;
break;
case OT_MAP:
snprintf(_entryName, sizeof(_entryName), "%s.MAP", objName);
loadStub = &Resource::load_MAP;
break;
case OT_SPC:
snprintf(_entryName, sizeof(_entryName), "%s.SPC", objName);
loadStub = &Resource::load_SPC;
break;
case OT_RP:
snprintf(_entryName, sizeof(_entryName), "%s.RP", objName);
loadStub = &Resource::load_RP;
break;
case OT_RPC:
snprintf(_entryName, sizeof(_entryName), "%s.RPC", objName);
loadStub = &Resource::load_RP;
break;
case OT_SPR:
snprintf(_entryName, sizeof(_entryName), "%s.SPR", objName);
loadStub = &Resource::load_SPR;
break;
case OT_SPRM:
snprintf(_entryName, sizeof(_entryName), "%s.SPR", objName);
loadStub = &Resource::load_SPRM;
break;
case OT_ICN:
snprintf(_entryName, sizeof(_entryName), "%s.ICN", objName);
loadStub = &Resource::load_ICN;
break;
case OT_FNT:
snprintf(_entryName, sizeof(_entryName), "%s.FNT", objName);
loadStub = &Resource::load_FNT;
break;
case OT_OBJ:
snprintf(_entryName, sizeof(_entryName), "%s.OBJ", objName);
loadStub = &Resource::load_OBJ;
break;
case OT_ANI:
snprintf(_entryName, sizeof(_entryName), "%s.ANI", objName);
loadStub = &Resource::load_ANI;
break;
case OT_TBN:
snprintf(_entryName, sizeof(_entryName), "%s.%s", objName, getTextBin(_lang, _type));
if (!_fs->exists(_entryName)) {
snprintf(_entryName, sizeof(_entryName), "%s.TBN", objName);
}
loadStub = &Resource::load_TBN;
break;
case OT_CMD:
snprintf(_entryName, sizeof(_entryName), "%s.CMD", objName);
loadStub = &Resource::load_CMD;
break;
case OT_POL:
snprintf(_entryName, sizeof(_entryName), "%s.POL", objName);
loadStub = &Resource::load_POL;
break;
case OT_CMP:
snprintf(_entryName, sizeof(_entryName), "%s.CMP", objName);
loadStub = &Resource::load_CMP;
break;
case OT_OBC:
snprintf(_entryName, sizeof(_entryName), "%s.OBC", objName);
loadStub = &Resource::load_OBC;
break;
case OT_SPL:
snprintf(_entryName, sizeof(_entryName), "%s.SPL", objName);
loadStub = &Resource::load_SPL;
break;
case OT_LEV:
snprintf(_entryName, sizeof(_entryName), "%s.LEV", objName);
loadStub = &Resource::load_LEV;
break;
case OT_SGD:
snprintf(_entryName, sizeof(_entryName), "%s.SGD", objName);
loadStub = &Resource::load_SGD;
break;
case OT_BNQ:
snprintf(_entryName, sizeof(_entryName), "%s.BNQ", objName);
loadStub = &Resource::load_BNQ;
break;
case OT_SPM:
snprintf(_entryName, sizeof(_entryName), "%s.SPM", objName);
loadStub = &Resource::load_SPM;
break;
default:
error("Unimplemented Resource::load() type %d", objType);
break;
}
if (ext) {
snprintf(_entryName, sizeof(_entryName), "%s.%s", objName, ext);
}
File f;
if (f.open(_entryName, "rb", _fs)) {
assert(loadStub);
(this->*loadStub)(&f);
if (f.ioErr()) {
error("I/O error when reading '%s'", _entryName);
}
} else {
if (_aba) {
uint32_t size;
uint8_t *dat = _aba->loadEntry(_entryName, &size);
if (dat) {
switch (objType) {
case OT_MBK:
_mbk = dat;
break;
case OT_PGE:
decodePGE(dat, size);
break;
case OT_PAL:
_pal = dat;
break;
case OT_CT:
if (!delphine_unpack((uint8_t *)_ctData, dat, size)) {
error("Bad CRC for '%s'", _entryName);
}
free(dat);
break;
case OT_SPC:
_spc = dat;
_numSpc = READ_BE_UINT16(_spc) / 2;
break;
case OT_RP:
if (size != 0x4A) {
error("Unexpected size %d for '%s'", size, _entryName);
}
memcpy(_rp, dat, size);
free(dat);
break;
case OT_ICN:
_icn = dat;
break;
case OT_FNT:
_fnt = dat;
break;
case OT_OBJ:
_numObjectNodes = READ_LE_UINT16(dat);
assert(_numObjectNodes == 230);
decodeOBJ(dat + 2, size - 2);
break;
case OT_ANI:
_ani = dat;
break;
case OT_TBN:
_tbn = dat;
break;
case OT_CMD:
_cmd = dat;
break;
case OT_POL:
_pol = dat;
break;
case OT_BNQ:
_bnq = dat;
break;
default:
error("Cannot load '%s' type %d", _entryName, objType);
}
return;
}
}
error("Cannot open '%s'", _entryName);
}
}
void Resource::load_CT(File *pf) {
debug(DBG_RES, "Resource::load_CT()");
int len = pf->size();
uint8_t *tmp = (uint8_t *)malloc(len);
if (!tmp) {
error("Unable to allocate CT buffer");
} else {
pf->read(tmp, len);
if (!delphine_unpack((uint8_t *)_ctData, tmp, len)) {
error("Bad CRC for collision data");
}
free(tmp);
}
}
void Resource::load_FNT(File *f) {
debug(DBG_RES, "Resource::load_FNT()");
int len = f->size();
_fnt = (uint8_t *)malloc(len);
if (!_fnt) {
error("Unable to allocate FNT buffer");
} else {
f->read(_fnt, len);
}
}
void Resource::load_MBK(File *f) {
debug(DBG_RES, "Resource::load_MBK()");
int len = f->size();
_mbk = (uint8_t *)malloc(len);
if (!_mbk) {
error("Unable to allocate MBK buffer");
} else {
f->read(_mbk, len);
}
}
void Resource::load_ICN(File *f) {
debug(DBG_RES, "Resource::load_ICN()");
int len = f->size();
if (_icnLen == 0) {
_icn = (uint8_t *)malloc(len);
} else {
_icn = (uint8_t *)realloc(_icn, _icnLen + len);
}
if (!_icn) {
error("Unable to allocate ICN buffer");
} else {
f->read(_icn + _icnLen, len);
}
_icnLen += len;
}
void Resource::load_SPR(File *f) {
debug(DBG_RES, "Resource::load_SPR()");
int len = f->size() - 12;
_spr1 = (uint8_t *)malloc(len);
if (!_spr1) {
error("Unable to allocate SPR1 buffer");
} else {
f->seek(12);
f->read(_spr1, len);
}
}
void Resource::load_SPRM(File *f) {
debug(DBG_RES, "Resource::load_SPRM()");
const uint32_t len = f->size() - 12;
assert(len <= sizeof(_sprm));
f->seek(12);
f->read(_sprm, len);
}
void Resource::load_RP(File *f) {
debug(DBG_RES, "Resource::load_RP()");
f->read(_rp, 0x4A);
}
void Resource::load_SPC(File *f) {
debug(DBG_RES, "Resource::load_SPC()");
int len = f->size();
_spc = (uint8_t *)malloc(len);
if (!_spc) {
error("Unable to allocate SPC buffer");
} else {
f->read(_spc, len);
_numSpc = READ_BE_UINT16(_spc) / 2;
}
}
void Resource::load_PAL(File *f) {
debug(DBG_RES, "Resource::load_PAL()");
int len = f->size();
_pal = (uint8_t *)malloc(len);
if (!_pal) {
error("Unable to allocate PAL buffer");
} else {
f->read(_pal, len);
}
}
void Resource::load_MAP(File *f) {
debug(DBG_RES, "Resource::load_MAP()");
int len = f->size();
_map = (uint8_t *)malloc(len);
if (!_map) {
error("Unable to allocate MAP buffer");
} else {
f->read(_map, len);
}
}
void Resource::load_OBJ(File *f) {
debug(DBG_RES, "Resource::load_OBJ()");
if (_type == kResourceTypeAmiga) { // demo has uncompressed objects data
const int size = f->size();
uint8_t *buf = (uint8_t *)malloc(size);
if (!buf) {
error("Unable to allocate OBJ buffer");
} else {
f->read(buf, size);
decodeOBJ(buf, size);
}
return;
}
_numObjectNodes = f->readUint16LE();
assert(_numObjectNodes < 255);
uint32_t offsets[256];
for (int i = 0; i < _numObjectNodes; ++i) {
offsets[i] = f->readUint32LE();
}
offsets[_numObjectNodes] = f->size() - 2;
int numObjectsCount = 0;
uint16_t objectsCount[256];
for (int i = 0; i < _numObjectNodes; ++i) {
int diff = offsets[i + 1] - offsets[i];
if (diff != 0) {
objectsCount[numObjectsCount] = (diff - 2) / 0x12;
debug(DBG_RES, "i=%d objectsCount[numObjectsCount]=%d", i, objectsCount[numObjectsCount]);
++numObjectsCount;
}
}
uint32_t prevOffset = 0;
ObjectNode *prevNode = 0;
int iObj = 0;
for (int i = 0; i < _numObjectNodes; ++i) {
if (prevOffset != offsets[i]) {
ObjectNode *on = (ObjectNode *)malloc(sizeof(ObjectNode));
if (!on) {
error("Unable to allocate ObjectNode num=%d", i);
}
f->seek(offsets[i] + 2);
on->last_obj_number = f->readUint16LE();
on->num_objects = objectsCount[iObj];
debug(DBG_RES, "last=%d num=%d", on->last_obj_number, on->num_objects);
on->objects = (Object *)malloc(sizeof(Object) * on->num_objects);
for (int j = 0; j < on->num_objects; ++j) {
Object *obj = &on->objects[j];
obj->type = f->readUint16LE();
obj->dx = f->readByte();
obj->dy = f->readByte();
obj->init_obj_type = f->readUint16LE();
obj->opcode2 = f->readByte();
obj->opcode1 = f->readByte();
obj->flags = f->readByte();
obj->opcode3 = f->readByte();
obj->init_obj_number = f->readUint16LE();
obj->opcode_arg1 = f->readUint16LE();
obj->opcode_arg2 = f->readUint16LE();
obj->opcode_arg3 = f->readUint16LE();
debug(DBG_RES, "obj_node=%d obj=%d op1=0x%X op2=0x%X op3=0x%X", i, j, obj->opcode2, obj->opcode1, obj->opcode3);
}
++iObj;
prevOffset = offsets[i];
prevNode = on;
}
_objectNodesMap[i] = prevNode;
}
}
void Resource::free_OBJ() {
debug(DBG_RES, "Resource::free_OBJ()");
ObjectNode *prevNode = 0;
for (int i = 0; i < _numObjectNodes; ++i) {
if (_objectNodesMap[i] != prevNode) {
ObjectNode *curNode = _objectNodesMap[i];
free(curNode->objects);
free(curNode);
prevNode = curNode;
}
_objectNodesMap[i] = 0;
}
}
void Resource::load_OBC(File *f) {
const int packedSize = f->readUint32BE();
uint8_t *packedData = (uint8_t *)malloc(packedSize);
if (!packedData) {
error("Unable to allocate OBC temporary buffer 1");
}
f->seek(packedSize);
const int unpackedSize = f->readUint32BE();
uint8_t *tmp = (uint8_t *)malloc(unpackedSize);
if (!tmp) {
error("Unable to allocate OBC temporary buffer 2");
}
f->seek(4);
f->read(packedData, packedSize);
if (!delphine_unpack(tmp, packedData, packedSize)) {
error("Bad CRC for compressed object data");
}
free(packedData);
decodeOBJ(tmp, unpackedSize);
free(tmp);
}
void Resource::decodeOBJ(const uint8_t *tmp, int size) {
uint32_t offsets[256];
int tmpOffset = 0;
_numObjectNodes = 230;
for (int i = 0; i < _numObjectNodes; ++i) {
offsets[i] = _readUint32(tmp + tmpOffset); tmpOffset += 4;
}
offsets[_numObjectNodes] = size;
int numObjectsCount = 0;
uint16_t objectsCount[256];
for (int i = 0; i < _numObjectNodes; ++i) {
int diff = offsets[i + 1] - offsets[i];
if (diff != 0) {
objectsCount[numObjectsCount] = (diff - 2) / 0x12;
++numObjectsCount;
}
}
uint32_t prevOffset = 0;
ObjectNode *prevNode = 0;
int iObj = 0;
for (int i = 0; i < _numObjectNodes; ++i) {
if (prevOffset != offsets[i]) {
ObjectNode *on = (ObjectNode *)malloc(sizeof(ObjectNode));
if (!on) {
error("Unable to allocate ObjectNode num=%d", i);
}
const uint8_t *objData = tmp + offsets[i];
on->last_obj_number = _readUint16(objData); objData += 2;
on->num_objects = objectsCount[iObj];
on->objects = (Object *)malloc(sizeof(Object) * on->num_objects);
for (int j = 0; j < on->num_objects; ++j) {
Object *obj = &on->objects[j];
obj->type = _readUint16(objData); objData += 2;
obj->dx = *objData++;
obj->dy = *objData++;
obj->init_obj_type = _readUint16(objData); objData += 2;
obj->opcode2 = *objData++;
obj->opcode1 = *objData++;
obj->flags = *objData++;
obj->opcode3 = *objData++;
obj->init_obj_number = _readUint16(objData); objData += 2;
obj->opcode_arg1 = _readUint16(objData); objData += 2;
obj->opcode_arg2 = _readUint16(objData); objData += 2;
obj->opcode_arg3 = _readUint16(objData); objData += 2;
debug(DBG_RES, "obj_node=%d obj=%d op1=0x%X op2=0x%X op3=0x%X", i, j, obj->opcode2, obj->opcode1, obj->opcode3);
}
++iObj;
prevOffset = offsets[i];
prevNode = on;
}
_objectNodesMap[i] = prevNode;
}
}
void Resource::load_PGE(File *f) {
debug(DBG_RES, "Resource::load_PGE()");
if (_type == kResourceTypeAmiga) {
const int size = f->size();
uint8_t *tmp = (uint8_t *)malloc(size);
if (!tmp) {
error("Unable to allocate PGE temporary buffer");
}
f->read(tmp, size);
decodePGE(tmp, size);
free(tmp);
return;
}
_pgeNum = f->readUint16LE();
memset(_pgeInit, 0, sizeof(_pgeInit));
debug(DBG_RES, "_pgeNum=%d", _pgeNum);
assert(_pgeNum <= ARRAYSIZE(_pgeInit));
for (uint16_t i = 0; i < _pgeNum; ++i) {
InitPGE *pge = &_pgeInit[i];
pge->type = f->readUint16LE();
pge->pos_x = f->readUint16LE();
pge->pos_y = f->readUint16LE();
pge->obj_node_number = f->readUint16LE();
pge->life = f->readUint16LE();
for (int lc = 0; lc < 4; ++lc) {
pge->counter_values[lc] = f->readUint16LE();
}
pge->object_type = f->readByte();
pge->init_room = f->readByte();
pge->room_location = f->readByte();
pge->init_flags = f->readByte();
pge->colliding_icon_num = f->readByte();
pge->icon_num = f->readByte();
pge->object_id = f->readByte();
pge->skill = f->readByte();
pge->mirror_x = f->readByte();
pge->flags = f->readByte();
pge->unk1C = f->readByte();
f->readByte();
pge->text_num = f->readUint16LE();
}
}
void Resource::decodePGE(const uint8_t *p, int size) {
_pgeNum = _readUint16(p); p += 2;
memset(_pgeInit, 0, sizeof(_pgeInit));
debug(DBG_RES, "len=%d _pgeNum=%d", size, _pgeNum);
assert(_pgeNum <= ARRAYSIZE(_pgeInit));
for (uint16_t i = 0; i < _pgeNum; ++i) {
InitPGE *pge = &_pgeInit[i];
pge->type = _readUint16(p); p += 2;
pge->pos_x = _readUint16(p); p += 2;
pge->pos_y = _readUint16(p); p += 2;
pge->obj_node_number = _readUint16(p); p += 2;
pge->life = _readUint16(p); p += 2;
for (int lc = 0; lc < 4; ++lc) {
pge->counter_values[lc] = _readUint16(p); p += 2;
}
pge->object_type = *p++;
pge->init_room = *p++;
pge->room_location = *p++;
pge->init_flags = *p++;
pge->colliding_icon_num = *p++;
pge->icon_num = *p++;
pge->object_id = *p++;
pge->skill = *p++;
pge->mirror_x = *p++;
pge->flags = *p++;
pge->unk1C = *p++;
++p;
pge->text_num = _readUint16(p); p += 2;
}
}
void Resource::load_ANI(File *f) {
debug(DBG_RES, "Resource::load_ANI()");
const int size = f->size();
_ani = (uint8_t *)malloc(size);
if (!_ani) {
error("Unable to allocate ANI buffer");
} else {
f->read(_ani, size);
}
}
void Resource::load_TBN(File *f) {
debug(DBG_RES, "Resource::load_TBN()");
int len = f->size();
_tbn = (uint8_t *)malloc(len);
if (!_tbn) {
error("Unable to allocate TBN buffer");
} else {
f->read(_tbn, len);
}
}
void Resource::load_CMD(File *pf) {
debug(DBG_RES, "Resource::load_CMD()");
free(_cmd);
int len = pf->size();
_cmd = (uint8_t *)malloc(len);
if (!_cmd) {
error("Unable to allocate CMD buffer");
} else {
pf->read(_cmd, len);
}
}
void Resource::load_POL(File *pf) {
debug(DBG_RES, "Resource::load_POL()");
free(_pol);
int len = pf->size();
_pol = (uint8_t *)malloc(len);
if (!_pol) {
error("Unable to allocate POL buffer");
} else {
pf->read(_pol, len);
}
}
void Resource::load_CMP(File *pf) {
free(_pol);
free(_cmd);
int len = pf->size();
uint8_t *tmp = (uint8_t *)malloc(len);
if (!tmp) {
error("Unable to allocate CMP buffer");
}
pf->read(tmp, len);
struct {
int offset, packedSize, size;
} data[2];
int offset = 0;
for (int i = 0; i < 2; ++i) {
int packedSize = READ_BE_UINT32(tmp + offset); offset += 4;
assert((packedSize & 1) == 0);
if (packedSize < 0) {
data[i].size = packedSize = -packedSize;
} else {
data[i].size = READ_BE_UINT32(tmp + offset + packedSize - 4);
}
data[i].offset = offset;
data[i].packedSize = packedSize;
offset += packedSize;
}
_pol = (uint8_t *)malloc(data[0].size);
if (!_pol) {
error("Unable to allocate POL buffer");
}
if (data[0].packedSize == data[0].size) {
memcpy(_pol, tmp + data[0].offset, data[0].packedSize);
} else if (!delphine_unpack(_pol, tmp + data[0].offset, data[0].packedSize)) {
error("Bad CRC for cutscene polygon data");
}
_cmd = (uint8_t *)malloc(data[1].size);
if (!_cmd) {
error("Unable to allocate CMD buffer");
}
if (data[1].packedSize == data[1].size) {
memcpy(_cmd, tmp + data[1].offset, data[1].packedSize);
} else if (!delphine_unpack(_cmd, tmp + data[1].offset, data[1].packedSize)) {
error("Bad CRC for cutscene command data");
}
free(tmp);
}
void Resource::load_VCE(int num, int segment, uint8_t **buf, uint32_t *bufSize) {
*buf = 0;
int offset = _voicesOffsetsTable[num];
if (offset != 0xFFFF) {
const uint16_t *p = _voicesOffsetsTable + offset / 2;
offset = (*p++) * 2048;
int count = *p++;
if (segment < count) {
File f;
if (f.open("VOICE.VCE", "rb", _fs)) {
int voiceSize = p[segment] * 2048 / 5;
uint8_t *voiceBuf = (uint8_t *)malloc(voiceSize);
if (voiceBuf) {
uint8_t *dst = voiceBuf;
offset += 0x2000;
for (int s = 0; s < count; ++s) {
int len = p[s] * 2048;
for (int i = 0; i < len / (0x2000 + 2048); ++i) {
if (s == segment) {
f.seek(offset);
int n = 2048;
while (n--) {
int v = f.readByte();
if (v & 0x80) {
v = -(v & 0x7F);
}
*dst++ = (uint8_t)(v & 0xFF);
}
}
offset += 0x2000 + 2048;
}
if (s == segment) {
break;
}
}
*buf = voiceBuf;
*bufSize = voiceSize;
}
}
}
}
}
void Resource::load_SPL(File *f) {
for (int i = 0; i < _numSfx; ++i) {
free(_sfxList[i].data);
}
free(_sfxList);
_numSfx = NUM_SFXS;
_sfxList = (SoundFx *)calloc(_numSfx, sizeof(SoundFx));
if (!_sfxList) {
error("Unable to allocate SoundFx table");
}
int offset = 0;
for (int i = 0; i < _numSfx; ++i) {
const int size = f->readUint16BE(); offset += 2;
if ((size & 0x8000) != 0) {
continue;
}
debug(DBG_RES, "sfx=%d size=%d", i, size);
assert(size != 0 && (size & 1) == 0);
if (i != 64) {
_sfxList[i].offset = offset;
_sfxList[i].len = size;
_sfxList[i].data = (uint8_t *)malloc(size);
assert(_sfxList[i].data);
f->read(_sfxList[i].data, size);
} else {
f->seek(offset + size);
}
offset += size;
}
}
void Resource::load_LEV(File *f) {
const int len = f->size();
_lev = (uint8_t *)malloc(len);
if (!_lev) {
error("Unable to allocate LEV buffer");
} else {
f->read(_lev, len);
}
}
void Resource::load_SGD(File *f) {
const int len = f->size();
if (_type == kResourceTypeDOS) {
_sgd = (uint8_t *)malloc(len);
if (!_sgd) {
error("Unable to allocate SGD buffer");
} else {
f->read(_sgd, len);
// first byte == number of entries, clear to fix up 32 bits offset
_sgd[0] = 0;
}
return;
}
f->seek(len - 4);
int size = f->readUint32BE();
f->seek(0);
uint8_t *tmp = (uint8_t *)malloc(len);
if (!tmp) {
error("Unable to allocate SGD temporary buffer");
}
f->read(tmp, len);
_sgd = (uint8_t *)malloc(size);
if (!_sgd) {
error("Unable to allocate SGD buffer");
}
if (!delphine_unpack(_sgd, tmp, len)) {
error("Bad CRC for SGD data");
}
free(tmp);
}
void Resource::load_BNQ(File *f) {
const int len = f->size();
_bnq = (uint8_t *)malloc(len);
if (!_bnq) {
error("Unable to allocate BNQ buffer");
} else {
f->read(_bnq, len);
}
}
void Resource::load_SPM(File *f) {
static const int kPersoDatSize = 178647;
const int len = f->size();
f->seek(len - 4);
const uint32_t size = f->readUint32BE();
f->seek(0);
uint8_t *tmp = (uint8_t *)malloc(len);
if (!tmp) {
error("Unable to allocate SPM temporary buffer");
}
f->read(tmp, len);
if (size == kPersoDatSize) {
_spr1 = (uint8_t *)malloc(size);
if (!_spr1) {
error("Unable to allocate SPR1 buffer");
}
if (!delphine_unpack(_spr1, tmp, len)) {
error("Bad CRC for SPM data");
}
} else {
assert(size <= sizeof(_sprm));
if (!delphine_unpack(_sprm, tmp, len)) {
error("Bad CRC for SPM data");
}
}
for (int i = 0; i < NUM_SPRITES; ++i) {
const uint32_t offset = _spmOffsetsTable[i];
if (offset >= kPersoDatSize) {
_sprData[i] = _sprm + offset - kPersoDatSize;
} else {
_sprData[i] = _spr1 + offset;
}
}
free(tmp);
}
void Resource::clearBankData() {
_bankBuffersCount = 0;
_bankDataHead = _bankData;
}
int Resource::getBankDataSize(uint16_t num) {
int len = READ_BE_UINT16(_mbk + num * 6 + 4);
switch (_type) {
case kResourceTypeAmiga:
if (len & 0x8000) {
len = -(int16_t)len;
}
break;
case kResourceTypeDOS:
if (len & 0x8000) {
if (_mbk == _bnq) { // demo .bnq use signed int
len = -(int16_t)len;
break;
}
len &= 0x7FFF;
}
break;
}
return len * 32;
}
uint8_t *Resource::findBankData(uint16_t num) {
for (int i = 0; i < _bankBuffersCount; ++i) {
if (_bankBuffers[i].entryNum == num) {
return _bankBuffers[i].ptr;
}
}
return 0;
}
uint8_t *Resource::loadBankData(uint16_t num) {
const uint8_t *ptr = _mbk + num * 6;
int dataOffset = READ_BE_UINT32(ptr);
if (_type == kResourceTypeDOS) {
// first byte of the data buffer corresponds
// to the total count of entries
dataOffset &= 0xFFFF;
}
const int size = getBankDataSize(num);
const int avail = _bankDataTail - _bankDataHead;
if (avail < size) {
clearBankData();
}
assert(_bankDataHead + size <= _bankDataTail);
assert(_bankBuffersCount < (int)ARRAYSIZE(_bankBuffers));
_bankBuffers[_bankBuffersCount].entryNum = num;
_bankBuffers[_bankBuffersCount].ptr = _bankDataHead;
const uint8_t *data = _mbk + dataOffset;
if (READ_BE_UINT16(ptr + 4) & 0x8000) {
memcpy(_bankDataHead, data, size);
} else {
assert(dataOffset > 4);
assert(size == (int)READ_BE_UINT32(data - 4));
if (!delphine_unpack(_bankDataHead, data, 0)) {
error("Bad CRC for bank data %d", num);
}
}
uint8_t *bankData = _bankDataHead;
_bankDataHead += size;
return bankData;
}