diff --git a/tools/omf/Makefile b/tools/omf/Makefile index d68fa5bbc4..4a65a197fd 100644 --- a/tools/omf/Makefile +++ b/tools/omf/Makefile @@ -1,7 +1,16 @@ CXXFLAGS = -g -I../../libs/pbd \ $(shell pkg-config --cflags sqlite3) \ $(shell pkg-config --cflags libxml-2.0) \ - $(shell pkg-config --cflags glibmm-2.4) + $(shell pkg-config --cflags glibmm-2.4) \ + $(shell pkg-config --cflags sndfile) -omftool: omftool.o - $(CXX) -o $@ omftool.o -L../../build/default/libs/pbd -lpbd $(shell pkg-config --libs sqlite3) $(shell pkg-config --libs libxml-2.0) \ No newline at end of file +LDFLAGS = -L../../build/default/libs/pbd -lpbd \ + $(shell pkg-config --libs sqlite3) \ + $(shell pkg-config --libs libxml-2.0) \ + $(shell pkg-config --libs sndfile) \ + +omftool: omftool.o loader.o + $(CXX) -o $@ omftool.o loader.o $(LDFLAGS) + +loader.o: loader.cc omftool.h +omftool.o: omftool.cc omftool.h diff --git a/tools/omf/loader.cc b/tools/omf/loader.cc new file mode 100644 index 0000000000..0442377357 --- /dev/null +++ b/tools/omf/loader.cc @@ -0,0 +1,649 @@ +/* Rewritten for Ardour by Paul Davis , Feb 2010 + but based on ... + */ + +/* REAPER OMF plug-in + Copyright (C) 2009 Hannes Breul + + Provides OMF import. + + Based on the m3u example included in the Reaper SDK, + Copyright (C) 2005-2008 Cockos Incorporated + + Original source available at: + http://www.reaper.fm/sdk/plugin/plugin.php#ext_dl + + This software is provided 'as-is', without any express or implied + warranty. In no event will the authors be held liable for any damages + arising from the use of this software. + + Permission is granted to anyone to use this software for any purpose, + including commercial applications, and to alter it and redistribute it + freely, subject to the following restrictions: + + 1. The origin of this software must not be misrepresented; you must not + claim that you wrote the original software. If you use this software + in a product, an acknowledgment in the product documentation would be + appreciated but is not required. + 2. Altered source versions must be plainly marked as such, and must not be + misrepresented as being the original software. + 3. This notice may not be removed or altered from any source distribution. +*/ + +#ifndef __STDC_FORMAT_MACROS +#define __STDC_FORMAT_MACROS /* PRI; C++ requires explicit requesting of these */ +#endif + +#include + +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + +#include "pbd/xml++.h" +#include "pbd/basename.h" +#include "omftool.h" + +using namespace std; +using namespace PBD; + +//#define DEBUG(fmt,...) fprintf (stderr, fmt, ## __VA_ARGS__) +#define DEBUG(fmt,...) +#define INFO(fmt,...) fprintf (stdout, fmt, ## __VA_ARGS__) + +#define MB_OK 0 +void +MessageBox (FILE* /*ignored*/, const char* msg, const char* title, int status) +{ + fprintf (stderr, msg); +} + +void +OMF::name_types () +{ + /* Add built-in types */ + sqlite3_exec(db, "INSERT INTO lookup VALUES (1, 'TOC property 1')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (2, 'TOC property 2')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (3, 'TOC property 3')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (4, 'TOC property 4')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (5, 'TOC property 5')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (6, 'TOC property 6')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (7, '(Type 7)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (8, '(Type 8)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (9, '(Type 9)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (10, '(Type 10)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (11, '(Type 11)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (12, '(Type 12)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (13, '(Type 13)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (14, '(Type 14)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (15, '(Type 15)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (16, '(Type 16)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (17, '(Type 17)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (18, '(Type 18)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (19, 'TOC Value')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (20, '(Type 20)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (21, 'String')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (22, '(Type 22)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (23, 'Type Name')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (24, 'Property Name')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (25, '(Type 25)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (26, '(Type 26)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (27, '(Type 27)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (28, '(Type 28)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (29, '(Type 29)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (30, '(Type 30)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (31, 'Referenced Object')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (32, 'Object')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (33, '(Type 33)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (34, '(Type 34)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (35, '(Type 35)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (36, '(Type 36)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (37, '(Type 37)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (38, '(Type 38)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (39, '(Type 39)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (40, '(Type 40)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (41, '(Type 41)')", 0, 0, 0); + sqlite3_exec(db, "INSERT INTO lookup VALUES (42, '(Type 42)')", 0, 0, 0); + + /* Assign type and property values to names */ + sqlite3_exec(db, "UPDATE data SET property = (SELECT name FROM lookup WHERE property = key), type = (SELECT name FROM lookup WHERE type = key)", 0, 0, 0); + sqlite3_exec(db, "DROP TABLE lookup", 0, 0, 0); +} + +int +OMF::load (const string& path) +{ + if ((file = fopen(path.c_str(), "rb")) == 0) { + MessageBox(NULL, "Cannot open file","OMF Error", MB_OK); + return -1; + } + + /* --------------- */ + char *fname = (char*) malloc (path.size()+5); + + strcpy(fname, path.c_str()); + strcat(fname, ".db3"); + //remove(fname); + if(sqlite3_open(":memory:", &db)) { + char error[512]; + sprintf(error, "Can't open database: %s", sqlite3_errmsg(db)); + MessageBox(NULL, error,"OMF Error", MB_OK); + sqlite3_close(db); + return -3; + } + sqlite3_exec(db, "BEGIN", 0, 0, 0); + sqlite3_exec(db, "CREATE TABLE data (object, property, type, value, offset, length)", 0, 0, 0); + sqlite3_exec(db, "CREATE TABLE lookup (key, name)", 0, 0, 0); + + uint8_t magic[8]; + fseek(file, -24, SEEK_END); + fread(magic, 8, 1, file); + if ((magic[0] != 0xa4) | (magic[1] != 0x43) | (magic[2] != 0x4d) | (magic[3] != 0xa5) | (magic[4] != 0x48) | (magic[5] != 0x64) | (magic[6] != 0x72) | (magic[7] != 0xd7)) { + MessageBox(NULL, "No valid OMF file.","OMF Error", MB_OK); + return -4; + } + + uint16_t bSize, version; + fseek(file, -12, SEEK_END); + fread(&version, 2, 1, file); + bigEndian = false; + if ((version == 1) | (version == 256)) { + MessageBox(NULL, "You tried to open an OMF1 file.\nOMF1 is not supported.","OMF Error", MB_OK); + return -2; + } else if (version == 512) { + bigEndian = true; + } else if (version != 2) { + MessageBox(NULL, "You tried to open a corrupted file.","OMF Error", MB_OK); + return -2; + } + + uint32_t tocStart, tocSize; + fseek(file, -14, SEEK_END); + fread(&bSize, 2, 1, file); + bSize = e16(bSize); + + fseek(file, -8, SEEK_END); + fread(&tocStart, 4, 1, file); + tocStart = e32(tocStart); + + fseek(file, -4, SEEK_END); + fread(&tocSize, 4, 1, file); + tocSize = e32(tocSize); + DEBUG ("block size: %d\n toc start: %d\n toc size: %d\n", bSize, tocStart, tocSize); + + + /* Calculate number of TOC blocks */ + uint32_t tocBlocks = tocSize / (bSize * 1024) + 1; + DEBUG ("toc blocks: %d\n", tocBlocks); + /* ------------------------------ */ + + time_t globalstart, starttime, endtime; + time(&globalstart); + starttime = globalstart; + INFO ("Parsing TOC... "); + + /* Go through TOC blocks */ + uint32_t j; + uint32_t currentObj = 0; + uint32_t currentProp = 0; + uint32_t currentType = 0; + char skip = 0; + //uint64_t len = 0; + for (j = 0; j < tocBlocks; j++) { + uint32_t currentBlock = tocStart + j * 1024 * bSize; // Start at beginning of current block + uint32_t currentPos; + for (currentPos = currentBlock; currentPos < currentBlock + 1024 * bSize; currentPos++) { + if (currentPos > tocStart + tocSize) break; // Exit at end of TOC + char cByte; // TOC control byte + fseek(file, currentPos, SEEK_SET); + fread(&cByte, 1, 1, file); + + /* New object */ + if (cByte == 1) { + fseek(file, currentPos + 1, SEEK_SET); + fread(¤tObj, 4, 1, file); + currentObj = e32(currentObj); + fseek(file, currentPos + 5, SEEK_SET); + fread(¤tProp, 4, 1, file); + currentProp = e32(currentProp); + fseek(file, currentPos + 9, SEEK_SET); + fread(¤tType, 4, 1, file); + currentType = e32(currentType); + DEBUG("---------------------\n"); + DEBUG(" object: 0x%x\n", currentObj); + DEBUG(" property: 0x%x\n", currentProp); + DEBUG(" type: 0x%x\n", currentType); + skip = 0; + currentPos += 12; // Skip the bytes that were just read + } + /* ---------- */ + + + /* New property */ + else if (cByte == 2) { + fseek(file, currentPos + 1, SEEK_SET); + fread(¤tProp, 4, 1, file); + currentProp = e32(currentProp); + fseek(file, currentPos + 5, SEEK_SET); + fread(¤tType, 4, 1, file); + currentType = e32(currentType); + DEBUG(" property: 0x%x\n", currentProp); + DEBUG(" type: 0x%x\n", currentType); + skip = 0; + currentPos += 8; + } + /* ------------ */ + + + /* New type */ + else if (cByte == 3) { + fseek(file, currentPos + 1, SEEK_SET); + fread(¤tType, 4, 1, file); + currentType = e32(currentType); + DEBUG(" type: 0x%x\n", currentType); + skip = 0; + currentPos += 4; + } + /* -------- */ + + + /* (unused) */ + else if (cByte == 4) { + currentPos += 4; + } + /* -------- */ + + + /* Reference to a value - 4/8 byte offset, 4/8 byte size */ + else if ((cByte == 5) | (cByte == 6) | (cByte == 7) | (cByte == 8)) { + if (!skip) { + uint32_t offset32 = 0; + uint32_t length32 = 0; + uint64_t dataOffset = 0; + uint64_t dataLength = 0; + if ((cByte == 5) | (cByte == 6)) { + fseek(file, currentPos + 1, SEEK_SET); + fread(&offset32, 4, 1, file); + fseek(file, currentPos + 5, SEEK_SET); + fread(&length32, 4, 1, file); + dataOffset = e32(offset32); + dataLength = e32(length32); + } else { + fseek(file, currentPos + 1, SEEK_SET); + fread(&dataOffset, 8, 1, file); + dataOffset = e64(dataOffset); + fseek(file, currentPos + 9, SEEK_SET); + fread(&dataLength, 8, 1, file); + dataLength = e64(dataLength); + } + DEBUG(" offset: %d\n", dataOffset); + DEBUG(" length: %d\n", dataLength); + + if (currentType == 21) { + char* string = (char*) malloc((uint32_t) dataLength); + fseek(file, dataOffset, SEEK_SET); + fread(string, dataLength, 1, file); + char* query = sqlite3_mprintf("INSERT INTO lookup VALUES(%d, '%s')",currentObj, string); + sqlite3_exec(db, query, 0, 0, 0); + sqlite3_free(query); + } else if (currentType == 32){ + uint32_t object = 0; + fseek(file, dataOffset, SEEK_SET); + fread(&object, 4, 1, file); + object = e32(object); + char* query = sqlite3_mprintf("INSERT INTO data VALUES(%d, %d, %d, %d, -1, -1)",currentObj, currentProp, currentType, object); + sqlite3_exec(db, query, 0, 0, 0); + sqlite3_free(query); + if (dataLength == 16) { + DEBUG(" offset: %lld\n", dataOffset + 8); + DEBUG(" length: %lld\n", dataLength); + fseek(file, dataOffset + 8, SEEK_SET); + fread(&object, 4, 1, file); + object = e32(object); + char* query2 = sqlite3_mprintf("INSERT INTO data VALUES(%d, %d, %d, %d, -1, -1)",currentObj, currentProp, currentType, object); + sqlite3_exec(db, query2, 0, 0, 0); + sqlite3_free(query2); + } + } else { + char* query = sqlite3_mprintf("INSERT INTO data VALUES(%d, %d, %d, '', %lld, %lld)",currentObj, currentProp, currentType, dataOffset, dataLength); + sqlite3_exec(db, query, 0, 0, 0); + sqlite3_free(query); + } + } + if ((cByte == 5) | (cByte == 6)) { + currentPos += 8; + } else { + currentPos += 16; + } + } + /* ----------------------------------------------------- */ + + + /* Zero byte value */ + else if (cByte == 9) { + if (!skip) { + char* query = sqlite3_mprintf("INSERT INTO data VALUES(%d, %d, %d, 'true', -1, -1)",currentObj, currentProp, currentType); + sqlite3_exec(db, query, 0, 0, 0); + sqlite3_free(query); + DEBUG(" value: true\n"); + } + } + /* --------------- */ + + + /* Immediate value */ + else if ((cByte == 10) | (cByte == 11) | (cByte == 12) | (cByte == 13) | (cByte == 14)) { + if (!skip) { + uint32_t data = 0; + fseek(file, currentPos + 1, SEEK_SET); + fread(&data, 4, 1, file); + data = e32(data); + char* query = sqlite3_mprintf("INSERT INTO data VALUES(%d, %d, %d, %d, -1, -1)",currentObj, currentProp, currentType, data); + sqlite3_exec(db, query, 0, 0, 0); + sqlite3_free(query); + DEBUG(" value: %d\n", data); + + } + currentPos += 4; + } + /* --------------- */ + + + /* Reference list */ + else if (cByte == 15) { + uint32_t data = 0; + fseek(file, currentPos + 1, SEEK_SET); + fread(&data, 4, 1, file); + data = e32(data); + char* query = sqlite3_mprintf("INSERT INTO data VALUES(%d, %d, %d, %d, -1, -1)",currentObj, currentProp, currentType, data); + sqlite3_exec(db, query, 0, 0, 0); + sqlite3_free(query); + DEBUG("reference: 0x%x\n", data); + skip = 1; + currentPos += 4; + } + /* -------------- */ + else { + break; + } + + } + } + /* --------------------- */ + time(&endtime); + INFO("done. (%ld seconds)\n", endtime - starttime); + starttime = endtime; + + INFO("Assigning type and property names... "); + name_types (); + time(&endtime); + INFO("done. (%ld seconds)\n", endtime - starttime); + starttime = endtime; + + bool isAvid = false; + + /* resolve ObjRefArrays */ + char **arrays; + int arrayCount; + int l; + INFO("Resolving ObjRefArrays "); + sqlite3_get_table(db, "SELECT * FROM data WHERE type LIKE 'omfi:ObjRefArray' AND value = ''", &arrays, &arrayCount, 0, 0); + INFO("(%d to be processed)... ", arrayCount); + sqlite3_exec(db,"DELETE FROM data WHERE type LIKE 'omfi:ObjRefArray' AND value = ''",0,0,0); + for (l = 6; l <= arrayCount * 6; l+=6) { + uint16_t counter; + uint32_t arrOffs = atoi(arrays[l+4]); + uint32_t arrLen = atoi(arrays[l+5]); + fseek(file, arrOffs, SEEK_SET); + fread(&counter, 2, 1, file); + counter = e16(counter); + if (arrLen = 4 * counter + 2) { + isAvid = true; + currentObj++; + DEBUG("currentObj: %d - references:", currentObj); + for (counter = 2; counter < arrLen; counter += 4) { + uint32_t temp; + fseek(file, arrOffs + counter, SEEK_SET); + fread(&temp, 4, 1, file); + temp = e32(temp); + DEBUG(" %d", temp); + sqlite3_exec(db, sqlite3_mprintf("INSERT INTO data VALUES (%d, 'Referenced Object', 'Object', %d, -1, -1)", currentObj, temp), 0, 0, 0); + } + DEBUG("\nData: %s | %s | %s | %d | -1 | -1\n", arrays[l], arrays[l+1], arrays[l+2], currentObj); + sqlite3_exec(db, sqlite3_mprintf("INSERT INTO data VALUES (%s, '%s', '%s', %d, -1, -1)", arrays[l], arrays[l+1], arrays[l+2], currentObj), 0, 0, 0); + } + } + sqlite3_free_table(arrays); + time(&endtime); + INFO("done. (%ld seconds)\n", endtime - starttime); + starttime = endtime; + /* -------------------- */ + + + //return -1; + /*char **refs; + int refCount; + int currentRef; + printf("Resolving ObjRefs...\n"); + sqlite3_get_table(db,"SELECT object, property, value FROM data WHERE type = 'omfi:ObjRef'", &refs, &refCount, 0, 0); + printf("temporary table created\n"); + for (currentRef = 3; currentRef <= refCount * 3; currentRef += 3) { + DEBUG("%d / %d\n", currentRef/3, refCount); + char **target; + int targetCount; + sqlite3_get_table(db, sqlite3_mprintf("SELECT value FROM data WHERE object = %s AND type = 'Object' LIMIT 1", refs[currentRef+2]), &target, &targetCount, 0, 0); + DEBUG("temporary table filled\n"); + if (targetCount > 0) { + //sqlite3_exec(db,sqlite3_mprintf("DELETE FROM data WHERE object = %s", refs[currentRef+2]),0,0,0); + DEBUG("unused reference deleted\n"); + sqlite3_exec(db,sqlite3_mprintf("UPDATE data SET value = %s WHERE object LIKE '%s' AND property LIKE '%s' LIMIT 1", target[1], refs[currentRef], refs[currentRef+1]),0,0,0); + printf("temporary data inserted\n"); + } + sqlite3_free_table(target); + } + sqlite3_free_table(refs); + printf("temporary table deleted\n"); */ + + if (!isAvid) { + INFO("Resolving ObjRefs "); + sqlite3_exec(db,"CREATE TABLE reference (object1, property1, value1)",0,0,0); + sqlite3_exec(db,"INSERT INTO reference SELECT object, property, value FROM data WHERE type LIKE 'omfi:ObjRef'",0,0,0); + sqlite3_exec(db,"CREATE TABLE objects (object2, value2)",0,0,0); + sqlite3_exec(db,"INSERT INTO objects SELECT object, value FROM data WHERE type LIKE 'Object'",0,0,0); + sqlite3_exec(db,"UPDATE reference SET value1 = (SELECT value2 FROM objects WHERE object2 = value1)",0,0,0); + //sqlite3_exec(db,"UPDATE data SET value = (SELECT value1 FROM references WHERE object1 = object) WHERE ",0,0,0); + char **refs; + int refCount; + int currentRef; + + sqlite3_get_table(db,"SELECT * FROM reference", &refs, &refCount, 0, 0); + INFO ("(%d to be processed)... ", refCount); + for (currentRef = 3; currentRef <= refCount * 3; currentRef += 3) { + DEBUG("%d / %d: object %s, property %s, value %s\n", currentRef/3, refCount, refs[currentRef], refs[currentRef+1], refs[currentRef+2]); + sqlite3_exec(db,sqlite3_mprintf("DELETE FROM data WHERE object = %s AND property = '%s'", refs[currentRef], refs[currentRef+1]),0,0,0); + sqlite3_exec(db,sqlite3_mprintf("INSERT INTO data VALUES (%s, '%s', 'omfi:ObjRef', %s, -1, -1)", refs[currentRef], refs[currentRef+1], refs[currentRef+2]),0,0,0); + } + sqlite3_free_table(refs); + } + DEBUG("temporary table deleted\n"); + + /*sqlite3_get_table(db,"SELECT object, property, value FROM data WHERE type LIKE 'omfi:ObjRef'", &refs, &refCount, 0, 0); + printf("%d\n", refCount); + for (currentRef = 3; currentRef <= refCount * 3; currentRef += 3) { + printf("%d / %d: object %s, property %s, value %s\n", currentRef/3, refCount, refs[currentRef], refs[currentRef+1], refs[currentRef+2]); + } + sqlite3_free_table(refs); + }*/ + + + /* resolve ObjRefs * + printf("Resolving ObjRefs...\n"); + sqlite3_exec(db,"CREATE TABLE temp (object, property, type, value, offset, length)",0,0,0); + printf("temporary table created\n"); + sqlite3_exec(db,"INSERT INTO temp SELECT d1.object, d1.property, d1.type, d2.value, d1.offset, d1.length FROM data d1, data d2 WHERE d1.type = 'omfi:ObjRef' AND d1.value = d2.object AND d2.type = 'Object'",0,0,0); + printf("temporary table filled\n"); + //sqlite3_exec(db,"DELETE FROM data WHERE object IN (SELECT value FROM data WHERE type LIKE 'omfi:ObjRef')",0,0,0); + sqlite3_exec(db,"DELETE FROM data WHERE object IN (SELECT object FROM temp) AND type = 'omfi:ObjRef'",0,0,0); + printf("unused referenced deleted\n"); + sqlite3_exec(db,"INSERT INTO data SELECT * FROM temp",0,0,0); + printf("temporary data inserted\n"); + sqlite3_exec(db,"DROP TABLE temp",0,0,0); + printf("temporary table deleted\n"); + * --------------- */ + + time(&endtime); + INFO("done. (%ld seconds)\n", endtime - starttime); + starttime = endtime; + + //return -1; + /* resolve UIDs */ + INFO("Resolving UIDs... "); + char **mobID; + int mobIDCount; + int currentID; + sqlite3_get_table(db,"SELECT object, property, offset FROM data WHERE type LIKE 'omfi:UID'", &mobID, &mobIDCount, 0, 0); + sqlite3_exec(db,"DELETE FROM data WHERE type LIKE 'omfi:UID'",0,0,0); + for (currentID = 3; currentID <= mobIDCount * 3; currentID += 3) { + uint32_t mobIDoffs = atoi(mobID[currentID+2]); + //sscanf(mobID[currentID+2], "%d", &mobIDoffs); + int mobBuffer[3]; + fseek(file, mobIDoffs, SEEK_SET); + fread(mobBuffer, 12, 1, file); + sqlite3_exec(db,sqlite3_mprintf("INSERT INTO data VALUES (%s, '%s', 'omfi:UID', '%d %d %d', -1, -1)", mobID[currentID], mobID[currentID + 1], mobBuffer[0], mobBuffer[1], mobBuffer[2]),0,0,0); + } + sqlite3_free_table(mobID); + /* ------------ */ + + time(&endtime); + INFO("done. (%ld seconds)\n", endtime - starttime); + starttime = endtime; + + //return -1; + + /* extract media data */ + printf("Extracting media data...\n"); + char **objects; + int objectsCount, k; + //sqlite3_exec(db,"CREATE TABLE names (UID, value)",0,0,0); + sqlite3_get_table(db, "SELECT object, offset, length FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE property = 'OMFI:HEAD:MediaData' LIMIT 1)) AND type = 'omfi:DataValue'", &objects, &objectsCount, 0, 0); + for (k = 3; k <= objectsCount * 3; k += 3) { + char **fileName; + int fileNameCount; + FILE *fd; + std::string full_path; + sqlite3_get_table(db, sqlite3_mprintf("SELECT offset, length FROM data WHERE object IN (SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:MDAT:MobID' LIMIT 1) AND property = 'OMFI:MOBJ:MobID' LIMIT 1) AND property = 'OMFI:MOBJ:Name' LIMIT 1", objects[k]), &fileName, &fileNameCount, 0, 0); + if (fileNameCount > 0) { + uint32_t fnOffs = atoi(fileName[2]); + uint32_t fnLen = atoi(fileName[3]); + if (get_offset_and_length (fileName[2], fileName[3], fnOffs, fnLen)) { + char *fnBuf = (char*) malloc(fnLen+1); + fseek(file, fnOffs, SEEK_SET); + fread(fnBuf, fnLen, 1, file); + fnBuf[fnLen] = '\0'; + + audiofile_path_vector.push_back (fnBuf); + full_path = Glib::build_filename (audiofile_path_vector); + audiofile_path_vector.pop_back (); + + fd = fopen(full_path.c_str(), "wb"); + + } else { + INFO ("Skip unnamed media file\n"); + continue; + } + } else { + audiofile_path_vector.push_back (objects[k]); + full_path = Glib::build_filename (audiofile_path_vector); + audiofile_path_vector.pop_back (); + fd = fopen(full_path.c_str(), "wb"); + INFO ("Direct file name used (%s)\n", full_path.c_str()); + } + + if(fd == NULL){ + char error[255]; + sprintf(error, "Can't create file [%s] (object %s)", full_path.c_str(), objects[k]); + MessageBox(NULL,error,"OMF Error", MB_OK); + sqlite3_exec(db, "COMMIT", 0, 0, 0); + sqlite3_close(db); + return 1; + } else { + INFO("Writing file %s (object %s): ", full_path.c_str(), objects[k]); + } + uint32_t foffset; + uint32_t flength; + + if (get_offset_and_length (objects[k+1], objects[k+2], foffset, flength)) { + int blockSize = 1024; + uint32_t currentBlock; + uint32_t written = 0; + char* buffer = (char*) malloc(blockSize); + fseek(file, foffset, SEEK_SET); + for (currentBlock = 0; currentBlock < flength / blockSize; currentBlock++) { + fread(buffer, blockSize, 1, file); + written += fwrite(buffer, 1, blockSize, fd); + } + fread(buffer, flength % blockSize, 1, file); + written += fwrite(buffer, 1, flength % blockSize, fd); + INFO("%d of %d bytes\n", written, flength); + fclose(fd); + + get_audio_info (full_path); + } + sqlite3_free_table(fileName); + } + sqlite3_free_table(objects); + /* ------------------ */ + + time(&endtime); + INFO("done. (%ld seconds)\n", endtime - starttime); + starttime = endtime; + + /* resolve ClassIDs */ + printf("Resolving ClassIDs "); + char **classID; + int classIDCount; + int currentClsID; + sqlite3_get_table(db,"SELECT object, property, value FROM data WHERE type = 'omfi:ClassID'", &classID, &classIDCount, 0, 0); + sqlite3_exec(db,"DELETE FROM data WHERE type = 'omfi:ClassID'",0,0,0); + INFO("(%d to be processed)... ", classIDCount); + for (currentClsID = 3; currentClsID <= classIDCount * 3; currentClsID += 3) { + //int clsID = (int) malloc(5); + int clsID = atoi(classID[currentClsID+2]); + clsID = e32(clsID); + //sscanf(classID[currentClsID+2], "%d", &clsID); + char clsString[5]; + strncpy(clsString, (char *) &clsID, 4); + clsString[4] = 0; + DEBUG("%d -> %s\n", clsID, clsString); + + sqlite3_exec(db,sqlite3_mprintf("INSERT INTO data VALUES (%s, '%s', 'omfi:ClassID', '%s', -1, -1)", classID[currentClsID], classID[currentClsID + 1], clsString),0,0,0); + } + sqlite3_free_table(classID); + /* ---------------- */ + + sqlite3_exec(db, "COMMIT", 0, 0, 0); + + time(&endtime); + INFO("done. (%ld seconds)\n", endtime - starttime); + starttime = endtime; + + /*time(&endtime); + printf("Took %ld seconds\n", endtime - starttime); + starttime = endtime;*/ + + + time(&endtime); + INFO("done. (%ld seconds)\n", endtime - starttime); + INFO("Overall time: %ld seconds\n", endtime - globalstart); + + return 0; + /* -------- */ +} diff --git a/tools/omf/omftool.cc b/tools/omf/omftool.cc index d502a9edea..fca1071ae0 100644 --- a/tools/omf/omftool.cc +++ b/tools/omf/omftool.cc @@ -45,32 +45,30 @@ #include #include #include - +#include #include #include "pbd/xml++.h" +#include "pbd/basename.h" #include "omftool.h" //#define DEBUG(fmt,...) fprintf (stderr, fmt, ## __VA_ARGS__) #define DEBUG(fmt,...) #define INFO(fmt,...) fprintf (stdout, fmt, ## __VA_ARGS__) -#define MB_OK 0 -void -MessageBox (FILE* /*ignored*/, const char* msg, const char* title, int status) -{ - fprintf (stderr, msg); -} - using namespace std; +using namespace PBD; OMF::OMF () { + char sbuf[256]; + bigEndian = false; id_counter = 0; session_name = "omfsession"; base_dir = "."; - sample_rate = 44100; + sample_rate = 0; + frame_rate = 0; version = 3000; db = 0; file = 0; @@ -80,9 +78,63 @@ OMF::OMF () routes = new XMLNode ("Routes"); regions = new XMLNode ("Regions"); playlists = new XMLNode ("Playlists"); - diskstreams = new XMLNode ("Diskstreams"); + diskstreams = new XMLNode ("DiskStreams"); locations = new XMLNode ("Locations"); options = new XMLNode ("Options"); + options = new XMLNode ("RouteGroups"); + + /* add master, default 2in/2out */ + + XMLNode* master = new_route_node (); + master->add_property ("name", "master"); + set_route_node_channels (master, 2, 2, false); + + XMLNode* tempo_map = new XMLNode ("TempoMap"); + XMLNode* tempo = new XMLNode ("Tempo"); + tempo->add_property ("start", "1|1|0"); + tempo->add_property ("beats-per-minute", "120.0"); + tempo->add_property ("note-type", "4.0"); + tempo->add_property ("movable", "no"); + tempo_map->add_child_nocopy (*tempo); + XMLNode* meter = new XMLNode ("Meter"); + meter->add_property ("start", "1|1|0"); + meter->add_property ("beats-per-bar", "4.0"); + meter->add_property ("note-type", "4.0"); + meter->add_property ("movable", "no"); + tempo_map->add_child_nocopy (*meter); + + XMLNode* click = new XMLNode ("Click"); + XMLNode* io = new XMLNode ("IO"); + click->add_child_nocopy (*io); + io->add_property ("name", "click"); + add_id (io); + io->add_property ("direction", "Output"); + io->add_property ("default-type", "audio"); + XMLNode* port = new XMLNode ("Port"); + io->add_child_nocopy (*port); + port->add_property ("type", "audio"); + port->add_property ("name", "click/audio_out 1"); + XMLNode* connection = new XMLNode ("Connection"); + connection->add_property ("other", "system:playback_1"); + port->add_child_nocopy (*connection); + + port = new XMLNode ("Port"); + io->add_child_nocopy (*port); + port->add_property ("type", "audio"); + port->add_property ("name", "click/audio_out 2"); + connection = new XMLNode ("Connection"); + connection->add_property ("other", "system:playback_2"); + port->add_child_nocopy (*connection); + + session->add_child_nocopy (*options); + session->add_child_nocopy (*sources); + session->add_child_nocopy (*regions); + session->add_child_nocopy (*playlists); + session->add_child_nocopy (*diskstreams); + session->add_child_nocopy (*routes); + session->add_child_nocopy (*locations); + session->add_child_nocopy (*tempo_map); + session->add_child_nocopy (*click); } OMF::~OMF () @@ -127,18 +179,78 @@ OMF::init () dir = Glib::build_filename (audiofile_path_vector); g_mkdir_with_parents (dir.c_str(), 0775); + /* and the rest */ + + + vector v; + v.push_back (base_dir); + v.push_back (session_name); + + vector d; + d.push_back ("analysis"); + d.push_back ("dead_sounds"); + d.push_back ("export"); + d.push_back ("peaks"); + + for (vector::iterator i = d.begin(); i != d.end(); ++i) { + v.push_back (*i); + dir = Glib::build_filename (v); + g_mkdir_with_parents (dir.c_str(), 0775); + v.pop_back (); + } + return 0; } +bool +OMF::get_audio_info (const std::string& path) +{ + SNDFILE *sf; + SF_INFO sf_info; + + sf_info.format = 0; // libsndfile says to clear this before sf_open(). + + if ((sf = sf_open ((char*) path.c_str(), SFM_READ, &sf_info)) == 0) { + char errbuf[256]; + cerr << "Cannot open source file " << path << sf_error_str (0, errbuf, sizeof (errbuf) - 1) << endl; + return false; + } + + if (known_sources.find (Glib::path_get_basename (path)) != known_sources.end()) { + /* already exists */ + return true; + } + + XMLNode* source = new_source_node(); + + known_sources.insert (pair + (Glib::path_get_basename (path), + new SourceInfo (sf_info.channels, + sf_info.samplerate, + sf_info.frames, + source))); + + source->add_property ("name", basename_nosuffix (path)); + cerr << "Source file " << basename_nosuffix (path) << " = " << sf_info.channels << '/' << sf_info.samplerate << '/' << sf_info.frames << endl; + sf_close (sf); + return true; +} + +void +OMF::add_id (XMLNode* node) +{ + char sbuf[64]; + id_counter++; + snprintf (sbuf, sizeof (sbuf), "%" PRId64, id_counter); + node->add_property ("id", sbuf); +} + XMLNode* OMF::new_playlist_node () { - char sbuf[256]; XMLNode* playlist = new XMLNode ("Playlist"); playlists->add_child_nocopy (*playlist); - id_counter++; - snprintf (sbuf, sizeof (sbuf), "%" PRId64, id_counter); - playlist->add_property ("id", sbuf); + add_id (playlist); playlist->add_property ("type", "audio"); playlist->add_property ("frozen", "no"); @@ -148,18 +260,157 @@ OMF::new_playlist_node () XMLNode* OMF::new_diskstream_node () { - char sbuf[256]; XMLNode* diskstream = new XMLNode ("AudioDiskstream"); diskstreams->add_child_nocopy (*diskstream); - id_counter++; - snprintf (sbuf, sizeof (sbuf), "%" PRId64, id_counter); - diskstream->add_property ("id", sbuf); + add_id (diskstream); diskstream->add_property ("flags", "Recordable"); diskstream->add_property ("speed", "1"); diskstream->add_property ("channels", "1"); return diskstream; } +void +OMF::set_region_sources (XMLNode* region, SourceInfo* sinfo) +{ + char buf[256]; + + region->add_property ("name", sinfo->node->property ("name")->value()); + + for (int i = 0; i < sinfo->channels; ++i) { + snprintf (buf, sizeof (buf), "source-%d", i); + region->add_property (buf, sinfo->node->property ("id")->value()); + } +} + +void +OMF::legalize_name (string& name) +{ + string::size_type pos; + string illegal_chars = ":"; + pos = 0; + + while ((pos = name.find_first_of (illegal_chars, pos)) != string::npos) { + name.replace (pos, 1, "_"); + pos += 1; + } +} + +void +OMF::set_route_node_channels (XMLNode* route, int in, int out, bool send_to_master) +{ + XMLNode* input_io; + XMLNode* output_io; + char sbuf[256]; + string name = route->property ("name")->value(); + + legalize_name (name); + + output_io = new XMLNode ("IO"); + route->add_child_nocopy (*output_io); + output_io->add_property ("name", name); + add_id (output_io); + output_io->add_property ("direction", "Output"); + output_io->add_property ("default-type", "audio"); + + input_io = new XMLNode ("IO"); + route->add_child_nocopy (*input_io); + input_io->add_property ("name", name); + add_id (input_io); + input_io->add_property ("direction", "Input"); + input_io->add_property ("default-type", "audio"); + + for (int i = 0; i < out; ++i) { + XMLNode* port = new XMLNode ("Port"); + output_io->add_child_nocopy (*port); + port->add_property ("type", "audio"); + + snprintf (sbuf, sizeof (sbuf), "%s/audio_out %d", name.c_str(), i+1); + + port->add_property ("name", sbuf); + XMLNode* connection = new XMLNode ("Connection"); + + if (send_to_master) { + if (i % 2) { + snprintf (sbuf, sizeof (sbuf), "master/audio_in 2"); + } else { + snprintf (sbuf, sizeof (sbuf), "master/audio_in 1"); + } + } else { + if (i % 2) { + snprintf (sbuf, sizeof (sbuf), "system:playback_2"); + } else { + snprintf (sbuf, sizeof (sbuf), "system:playback_1"); + } + } + + connection->add_property ("other", sbuf); + port->add_child_nocopy (*connection); + } + + for (int i = 0; i < in; ++i) { + XMLNode* port = new XMLNode ("Port"); + input_io->add_child_nocopy (*port); + port->add_property ("type", "audio"); + + snprintf (sbuf, sizeof (sbuf), "%s/audio_out %d", name.c_str(), i+1); + + port->add_property ("name", sbuf); + XMLNode* connection = new XMLNode ("Connection"); + + if (i % 2) { + snprintf (sbuf, sizeof (sbuf), "system:capture_2"); + } else { + snprintf (sbuf, sizeof (sbuf), "system:capture_1"); + } + + connection->add_property ("other", sbuf); + port->add_child_nocopy (*connection); + } + + /* add main out processor */ + + XMLNode* outs = new XMLNode ("Processor"); + route->add_child_nocopy (*outs); + add_id (outs); + outs->add_property ("name", name); + outs->add_property ("active", "yes"); + outs->add_property ("own-input", "yes"); + outs->add_property ("own-output", send_to_master ? "no" : "yes"); + outs->add_property ("output", name); + outs->add_property ("type", "main-outs"); + outs->add_property ("role", "Main"); + + /* Panner setup */ + + XMLNode* panner = new XMLNode ("Panner"); + outs->add_child_nocopy (*panner); + + panner->add_property ("linked", "no"); + panner->add_property ("link-direction", "SameDirection"); + panner->add_property ("bypassed", "no"); + + for (int i = 0; i < out; ++i) { + XMLNode* panout = new XMLNode ("Output"); + panner->add_child_nocopy (*panout); + panout->add_property ("x", "0"); + panout->add_property ("y", "0"); + } + + for (int i = 0; i < in; ++i) { + XMLNode* spanner = new XMLNode ("StreamPanner"); + panner->add_child_nocopy (*spanner); + spanner->add_property ("x", "0"); + spanner->add_property ("type", "Equal Power Stereo"); + spanner->add_property ("muted", "no"); + spanner->add_property ("mono", "no"); + + XMLNode* spc = new XMLNode ("Controllable"); + spanner->add_child_nocopy (*spc); + add_id (spc); + spc->add_property ("name", "panner"); + spc->add_property ("flags", ""); + } +} XMLNode* OMF::new_route_node () @@ -168,9 +419,7 @@ OMF::new_route_node () XMLNode* route = new XMLNode ("Route"); routes->add_child_nocopy (*route); - id_counter++; - snprintf (sbuf, sizeof (sbuf), "%" PRId64, id_counter); - route->add_property ("id", sbuf); + add_id (route); route->add_property ("default-type","audio"); route->add_property ("active","yes"); route->add_property ("phase-invert","no"); @@ -182,6 +431,50 @@ OMF::new_route_node () route->add_property ("soloed-by-others","0"); route->add_property ("mode","Normal"); + /* other boilerplate */ + + XMLNode* controllable = new XMLNode ("Controllable"); + route->add_child_nocopy (*controllable); + controllable->add_property ("name", "solo"); + add_id (controllable); + controllable->add_property ("flags", "Toggle"); + + XMLNode* mutemaster = new XMLNode ("MuteMaster"); + route->add_child_nocopy (*mutemaster); + mutemaster->add_property ("mute-point", ""); + + XMLNode* remotecontrol = new XMLNode ("RemoteControl"); + route->add_child_nocopy (*remotecontrol); + remotecontrol->add_property ("id", route->property ("id")->value()); + + XMLNode* amp = new XMLNode ("Processor"); + route->add_child_nocopy (*amp); + add_id (amp); + amp->add_property ("name", "Amp"); + amp->add_property ("active", "yes"); + amp->add_property ("type", "amp"); + amp->add_property ("gain", "1.0"); + + XMLNode* meter = new XMLNode ("Processor"); + route->add_child_nocopy (*meter); + add_id (meter); + meter->add_property ("name", "Meter"); + meter->add_property ("active", "yes"); + meter->add_property ("type", "meter"); + + XMLNode* extra = new XMLNode ("Extra"); + route->add_child_nocopy (*extra); + XMLNode* gui = new XMLNode ("GUI"); + extra->add_child_nocopy (*gui); + snprintf (sbuf, sizeof (sbuf), "%d:%d:%d", + random() % 65536, + random() % 65536, + random() % 65536); + gui->add_property ("color", sbuf); + gui->add_property ("shown-mixer", "yes"); + gui->add_property ("height", "62"); + gui->add_property ("shown-editor", "yes"); + return route; } @@ -208,17 +501,13 @@ OMF::new_region_node () region->add_property ("sync-position", "0"); region->add_property ("flags", "Opaque,DefaultFadeIn,DefaultFadeOut,FadeIn,FadeOut,External"); region->add_property ("scale-gain", "1"); - region->add_property ("source-0", "1"); - region->add_property ("master-source-0", "1"); region->add_property ("channels", "1"); gui_extra->add_property ("waveform-visible","yes"); gui_extra->add_property ("envelope-visible", "no"); gui_extra->add_property ("waveform-rectified", "no"); gui_extra->add_property ("waveform-logscaled","no"); - id_counter++; - snprintf (sbuf, sizeof (sbuf), "%" PRId64, id_counter); - region->add_property ("id", sbuf); + add_id (region); return region; } @@ -226,21 +515,18 @@ XMLNode* OMF::new_source_node () { XMLNode* source; - char sbuf[256]; - id_counter++; source = new XMLNode ("Source"); - snprintf (sbuf, sizeof (sbuf), "%" PRId64, id_counter); - source->add_property ("id", sbuf); + add_id (source); source->add_property ("type", "audio"); source->add_property ("flags", "CanRename"); - + sources->add_child_nocopy (*source); - + return source; } -XMLNode* +OMF::SourceInfo* OMF::get_known_source (const char* name) { string s (name); @@ -251,13 +537,6 @@ OMF::get_known_source (const char* name) return 0; } -void -OMF::add_source (const char* name, XMLNode* node) -{ - pair newpair (name, node); - known_sources.insert (newpair); -} - char * OMF::read_name (size_t offset, size_t len) { @@ -269,400 +548,391 @@ OMF::read_name (size_t offset, size_t len) } bool -OMF::get_offset_and_length (const char* offstr, const char* lenstr, uint32_t& offset, uint32_t len) +OMF::get_offset_and_length (const char* offstr, const char* lenstr, uint32_t& offset, uint32_t& len) { if (sscanf (offstr, "%d", &offset) == 0) { + cerr << "bad offset\n"; return false; } if (sscanf (lenstr, "%d", &len) == 0) { + cerr << "bad length\n"; return false; } if (((int32_t) offset) <= 0) { + cerr << "illegal offset\n"; return false; } if (((int32_t) len) <= 0) { + cerr << "illegal length\n"; return false; } return true; } -void +int OMF::create_xml () { XMLNode* region; XMLNode* playlist; XMLNode* diskstream; - XMLNode* source; + SourceInfo* sinfo; char sbuf[256]; - int64_t id_counter = 0; + int route_max_channels; + int major; + int minor; + int micro; + + major = version / 1000; + minor = version - (major * 1000); + micro = version - (major * 1000) - (minor * 100); - session->add_property ("version", "3.0.0"); - session->add_property ("name", "iNeedAName"); + snprintf (sbuf, sizeof (sbuf), "%d.%d.%d", major, minor, micro); - session->add_child_nocopy (*options); - session->add_child_nocopy (*sources); - session->add_child_nocopy (*regions); - session->add_child_nocopy (*playlists); - session->add_child_nocopy (*diskstreams); - session->add_child_nocopy (*routes); - session->add_child_nocopy (*locations); - - /* write RPP */ - printf("Writing project...\n"); + session->add_property ("version", sbuf); + session->add_property ("name", session_name); char **tracks; int numtracks; - //sqlite3_get_table(db, "SELECT d3.value FROM data d1, data d2, data d3 WHERE d1.property = 'OMFI:OOBJ:ObjClass' AND d1.value = 'CMOB' AND d2.object = d1.object AND d2.property = 'OMFI:MOBJ:Slots' AND d2.value = d3.object", &tracks, &numtracks, 0, 0); sqlite3_get_table(db, "SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT object FROM data WHERE property = 'OMFI:OOBJ:ObjClass' AND value = 'CMOB' LIMIT 1) AND property = 'OMFI:MOBJ:Slots')", &tracks, &numtracks, 0, 0); - int i; - for (i = 1; i <= numtracks; i++) { - printf("Processing track %d / %d...\n", i, numtracks); + + for (int i = 1; i <= numtracks; i++) { + int descCount; char **desc; - //sqlite3_get_table(db, sqlite3_mprintf("SELECT d2.value FROM data d1, data d2 WHERE d1.object LIKE '%s' AND d1.property LIKE 'OMFI:MSLT:Segment' AND d1.value LIKE d2.object AND d2.value LIKE 'SEQU' LIMIT 1", tracks[i]), &desc, &descCount, 0, 0); + sqlite3_get_table(db, sqlite3_mprintf("SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:MSLT:Segment' LIMIT 1) AND value = 'SEQU' LIMIT 1", tracks[i]), &desc, &descCount, 0, 0); sqlite3_free_table(desc); - if (descCount > 0) { + sinfo = 0; + route_max_channels = 0; - /* create a new route, which will mean that we need a new diskstream and playlist too - */ + INFO ("Processing track %d / %d...\n", i, numtracks); - XMLNode* route = new_route_node (); - XMLNode* playlist = new_playlist_node (); - XMLNode* diskstream = new_diskstream_node (); + if (descCount <= 0) { + continue; + } - /* route and playlist both need diskstream ID */ + /* create a new route, which will mean that we need a new diskstream and playlist too + */ - route->add_property ("diskstream-id", diskstream->property ("id")->value()); - playlist->add_property ("orig-diskstream-id", diskstream->property ("id")->value()); + XMLNode* route = new_route_node (); + XMLNode* playlist = new_playlist_node (); + XMLNode* diskstream = new_diskstream_node (); - DEBUG(" 0) { - uint32_t nOffs; - uint32_t nLen; - if (get_offset_and_length (name[2], name[3], nOffs, nLen)) { - char* nBuf = read_name (nOffs, nLen); - DEBUG("NAME \"%s\"\n", nBuf); - route->add_property ("name", nBuf); - playlist->add_property ("name", nBuf); - diskstream->add_property ("name", nBuf); - diskstream->add_property ("playlist", nBuf); - free (nBuf); - } else { - INFO ("Track %d has unreadable name\n", i); - snprintf (sbuf, sizeof (sbuf), "Track %d", i); - route->add_property ("name", sbuf); - playlist->add_property ("name", sbuf); - diskstream->add_property ("name", sbuf); - diskstream->add_property ("playlist", sbuf); - } + route->add_property ("diskstream-id", diskstream->property ("id")->value()); + playlist->add_property ("orig-diskstream-id", diskstream->property ("id")->value()); + + char **name; + int nameCount; + //sqlite3_get_table(db, sqlite3_mprintf("SELECT d2.offset, d2.length FROM data d1, data d2 WHERE d1.object LIKE '%s' AND d1.property LIKE 'OMFI:MSLT:TrackDesc' AND d2.object LIKE d1.value AND d2.property LIKE 'OMFI:TRKD:TrackName' LIMIT 1", tracks[i]), &name, &nameCount, 0, 0); + sqlite3_get_table(db, sqlite3_mprintf("SELECT offset, length FROM data WHERE object IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:MSLT:TrackDesc' LIMIT 1) AND property = 'OMFI:TRKD:TrackName' LIMIT 1", tracks[i]), &name, &nameCount, 0, 0); + if (nameCount > 0) { + uint32_t nOffs; + uint32_t nLen; + if (get_offset_and_length (name[2], name[3], nOffs, nLen)) { + char* nBuf = read_name (nOffs, nLen); + route->add_property ("name", nBuf); + playlist->add_property ("name", nBuf); + diskstream->add_property ("name", nBuf); + diskstream->add_property ("playlist", nBuf); + free (nBuf); } else { - INFO ("Track %d has no name\n", i); + INFO ("Track %d has unreadable name\n", i); snprintf (sbuf, sizeof (sbuf), "Track %d", i); route->add_property ("name", sbuf); playlist->add_property ("name", sbuf); diskstream->add_property ("name", sbuf); diskstream->add_property ("playlist", sbuf); } - sqlite3_free_table(name); - - char **rate; - int rateCount; - sqlite3_get_table(db, sqlite3_mprintf("SELECT offset FROM data WHERE object = %s AND property = 'OMFI:MSLT:EditRate' LIMIT 1", tracks[i]), &rate, &rateCount, 0, 0); - int num = 1, denom = 1; - if (rateCount > 0) { - uint32_t rOffs = atoi(rate[1]); - //sscanf(rate[1], "%d", &rOffs); - fseek(file, rOffs, SEEK_SET); - fread(&denom, 4, 1, file); - denom = e32(denom); - fread(&num, 4, 1, file); - num = e32(num); - } - double frameRate = (double) num / (double) denom; - sqlite3_free_table(rate); - - char **items; - int itemCount; - //sqlite3_get_table(db, sqlite3_mprintf("SELECT d3.value FROM data d1, data d2, data d3 WHERE d1.object LIKE '%s' AND d1.property LIKE 'OMFI:MSLT:Segment' AND d2.object LIKE d1.value AND d2.property LIKE 'OMFI:SEQU:Components' AND d3.object LIKE d2.value", tracks[i]), &items, &itemCount, 0, 0); - sqlite3_get_table(db, sqlite3_mprintf("SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:MSLT:Segment' LIMIT 1) AND property = 'OMFI:SEQU:Components' LIMIT 1)", tracks[i]), &items, &itemCount, 0, 0); - double position = 0.0; - int j; - double fadeTime = 0.0; - - for (j = 1; j <= itemCount; j++) { - //MessageBox(NULL, items[j],"Info",MB_OK); - printf(" item %d / %d\n", j, itemCount); - char **len; - int lenCount; - double length = 0.0; - int lenFrames = 0; - sqlite3_get_table(db, sqlite3_mprintf("SELECT value FROM data WHERE object = %s AND property = 'OMFI:CPNT:Length' LIMIT 1", items[j]), &len, &lenCount, 0, 0); - if (lenCount > 0) { - char **type; - int typeCount; - - sqlite3_get_table(db, sqlite3_mprintf("SELECT value FROM data WHERE object = %s AND property = 'OMFI:OOBJ:ObjClass' LIMIT 1", items[j]), &type, &typeCount, 0, 0); - if (typeCount > 0) { - lenFrames = atoi(len[1]); - //sscanf(len[1],"%d", &lenFrames); - length = lenFrames * frameRate; - - if (!strcmp(type[1], "TRAN")) { - position -= length; - char **effID; - int effIDCount; - //sqlite3_get_table(db, sqlite3_mprintf("SELECT d3.offset, d3.length FROM data d1, data d2, data d3 WHERE d1.object LIKE '%s' AND d1.property LIKE 'OMFI:TRAN:Effect' AND d2.object LIKE d1.value AND d2.property LIKE 'OMFI:EFFE:EffectKind' AND d3.object LIKE d2.value AND d3.property LIKE 'OMFI:EDEF:EffectID' LIMIT 1", items[j]), &effID, &effIDCount, 0, 0); - sqlite3_get_table(db, sqlite3_mprintf("SELECT offset, length FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:TRAN:Effect' LIMIT 1) AND property = 'OMFI:EFFE:EffectKind' LIMIT 1) AND property = 'OMFI:EDEF:EffectID' LIMIT 1", items[j]), &effID, &effIDCount, 0, 0); - if (effIDCount > 0) { - uint32_t eOffs; - uint32_t eLen; - if (get_offset_and_length (effID[2], effID[3], eOffs, eLen)) { - char* eBuf = read_name (eOffs, eLen); - if (!strcmp(eBuf, "omfi:effect:StereoAudioDissolve") | !strcmp(eBuf, "omfi:effect:SimpleMonoAudioDissolve")) { - fadeTime = length; - } - } - } - sqlite3_free_table(effID); - } else if (!strcmp(type[1], "FILL")) { - position += length; - - } else if (!strcmp(type[1], "NEST")) { - - char **itemName; - int itemNameCount; - sqlite3_get_table(db, sqlite3_mprintf("SELECT offset, length FROM data WHERE object IN (SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:NEST:Slots' LIMIT 1)) AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property = 'OMFI:MOBJ:MobID' LIMIT 1) AND property = 'OMFI:MOBJ:Name' LIMIT 1", items[j]), &itemName, &itemNameCount, 0, 0); - - XMLNode* region = new_region_node (); - playlist->add_child_nocopy (*region); - - region->add_property ("name", "iNeedAName"); - snprintf (sbuf, sizeof (sbuf), "%" PRId64, llrintf (position)); - region->add_property ("position", sbuf); - snprintf (sbuf, sizeof (sbuf), "%" PRId64, llrintf (length)); - region->add_property ("length", sbuf); - - DEBUG(" 0) { - int soffs = atoi(startTime[1]); - //sscanf(startTime[1],"%d", &soffs); - snprintf (sbuf, sizeof (sbuf), "%" PRId64, (int64_t) soffs); - region->add_property ("start", sbuf); - DEBUG("SOFFS %.14f\n", (double) soffs * frameRate); - } else { - region->add_property ("start", "0"); - } - - sqlite3_free_table(startTime); - - char **itemEffect; - int itemEffectCount; - //sqlite3_get_table(db, sqlite3_mprintf("select d7.offset from data d1, data d2, data d3, data d4, data d5, data d6, data d7 where d1.object like '%s' and d1.property like 'OMFI:NEST:Slots' and d2.object like d1.value and d3.object like d2.value and d3.property like 'OMFI:EFFE:EffectSlots' and d4.object like d3.value and d5.object like d4.value and d5.property like 'OMFI:ESLT:ArgValue' and d6.object like d4.value and d6.property like 'OMFI:ESLT:ArgID' and d6.value like '1' and d7.object like d5.value and d7.property like 'OMFI:CVAL:Value' LIMIT 2", items[j]), &itemEffect, &itemEffectCount, 0, 0); - sqlite3_get_table(db, sqlite3_mprintf("SELECT offset FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:NEST:Slots' LIMIT 1)) AND property = 'OMFI:EFFE:EffectSlots' LIMIT 1) LIMIT 2) AND property = 'OMFI:ESLT:ArgValue' LIMIT 2) AND property like 'OMFI:CVAL:Value' LIMIT 1", items[j]), &itemEffect, &itemEffectCount, 0, 0); - if (itemEffectCount > 0) { - int effNum = 1; - int effDenom = 1; - uint32_t effOffs = atoi(itemEffect[1]); - //sscanf(itemEffect[1], "%d", &effOffs); - fseek(file, effOffs, SEEK_SET); - fread(&effDenom, 4, 1, file); - fread(&effNum, 4, 1, file); - double vol = (double) effNum / (double) effDenom; - //ctx->AddLine("VOLPAN %.8f 0.000000 1.000000 -1.000000", vol); - DEBUG("VOLPAN %.8f 0.000000 1.000000 -1.000000\n", vol); - } - sqlite3_free_table(itemEffect); - - char **sourceFile; - int sourceFileCount; - //sqlite3_get_table(db, sqlite3_mprintf("SELECT d10.offset, d10.length FROM data d1, data d2, data d3, data d4, data d5, data d6, data d7, data d8, data d9, data d10 WHERE d1.object LIKE '%s' AND d1.property LIKE 'OMFI:NEST:Slots' AND d2.object LIKE d1.value AND d3.object LIKE d2.value AND d3.property LIKE 'OMFI:SCLP:SourceID' AND d4.value LIKE d3.value AND d4.property LIKE 'OMFI:MOBJ:MobID' AND d5.object LIKE d4.object AND d5.property LIKE 'OMFI:MOBJ:Slots' AND d6.object LIKE d5.value AND d7.object LIKE d6.value AND d7.property LIKE 'OMFI:MSLT:Segment' AND d8.object LIKE d7.value AND d8.property LIKE 'OMFI:SCLP:SourceID' AND d9.value LIKE d8.value AND d9.property LIKE 'OMFI:MOBJ:MobID' AND d10.object LIKE d9.object AND d10.property LIKE 'OMFI:MOBJ:Name' LIMIT 1", items[j]), &sourceFile, &sourceFileCount, 0, 0); - sqlite3_get_table(db, sqlite3_mprintf("SELECT offset, length FROM data WHERE object IN (SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:NEST:Slots' LIMIT 1) LIMIT 3) AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property = 'OMFI:MOBJ:MobID' LIMIT 1) AND property = 'OMFI:MOBJ:Slots' LIMIT 1) LIMIT 1) AND property = 'OMFI:MSLT:Segment' LIMIT 1) AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property = 'OMFI:MOBJ:MobID' LIMIT 1) AND property LIKE 'OMFI:MOBJ:Name' LIMIT 1", items[j]), &sourceFile, &sourceFileCount, 0, 0); - if (sourceFileCount > 0) { - if (itemNameCount > 0) { - uint32_t inOffs; - uint32_t inLen; - if (get_offset_and_length (itemName[2], itemName[3], inOffs, inLen)) { - char *inBuf = read_name (inOffs, inLen); - // ctx->AddLine("NAME \"%s\"", inBuf); - DEBUG("NAME \"%s\"\n", inBuf); - region->add_property ("name", inBuf); - free (inBuf); - } - } - uint32_t sfOffs; - uint32_t sfLen; - if (get_offset_and_length (sourceFile[2], sourceFile[3], sfOffs, sfLen)) { - char *sfBuf = read_name (sfOffs, sfLen); - - if ((source = get_known_source (sfBuf)) == 0) { - source = new_source_node (); - } - - region->add_property ("source-0", source->property ("id")->value()); - source->add_property ("name", sfBuf); - add_source (sfBuf, source); - - free (sfBuf); - } - } else { - char **fallbackFile; - int fallbackFileCount; - //sqlite3_get_table(db, sqlite3_mprintf("SELECT d9.object FROM data d1, data d2, data d3, data d4, data d5, data d6, data d7, data d8, data d9 WHERE d1.object LIKE '%s' AND d1.property LIKE 'OMFI:NEST:Slots' AND d2.object LIKE d1.value AND d3.object LIKE d2.value AND d3.property LIKE 'OMFI:SCLP:SourceID' AND d4.value LIKE d3.value AND d4.property LIKE 'OMFI:MOBJ:MobID' AND d5.object LIKE d4.object AND d5.property LIKE 'OMFI:MOBJ:Slots' AND d6.object LIKE d5.value AND d7.object LIKE d6.value AND d7.property LIKE 'OMFI:MSLT:Segment' AND d8.object LIKE d7.value AND d8.property LIKE 'OMFI:SCLP:SourceID' AND d9.value LIKE d8.value AND d9.property LIKE 'OMFI:MDAT:MobID' LIMIT 1", items[j]), &fallbackFile, &fallbackFileCount, 0, 0); - sqlite3_get_table(db, sqlite3_mprintf("SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:NEST:Slots' LIMIT 1) LIMIT 3) AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property = 'OMFI:MOBJ:MobID' LIMIT 1) AND property = 'OMFI:MOBJ:Slots' LIMIT 1) LIMIT 1) AND property = 'OMFI:MSLT:Segment' LIMIT 1) AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property = 'OMFI:MDAT:MobID' LIMIT 1", items[j]), &fallbackFile, &fallbackFileCount, 0, 0); - if (fallbackFileCount > 0) { - - if (itemNameCount > 0) { - uint32_t inOffs; - uint32_t inLen; - if (get_offset_and_length (itemName[2], itemName[3], inOffs, inLen)) { - char *inBuf = read_name (inOffs, inLen); - DEBUG("NAME \"%s\"\n", inBuf); - region->add_property ("name", inBuf); - free (inBuf); - } - } - - DEBUG("\n", fallbackFile[1]); - - if ((source = get_known_source (fallbackFile[1])) == 0) { - source = new_source_node (); - } - - region->add_property ("source-0", source->property ("id")->value()); - source->add_property ("name", fallbackFile[1]); - add_source (fallbackFile[1], source); - - } - sqlite3_free_table(fallbackFile); - } - - sqlite3_free_table(sourceFile); - sqlite3_free_table(itemName); - position += length; - - } else if (!strcmp(type[1], "SCLP")) { - - char **itemName; - int itemNameCount; - //sqlite3_get_table(db, sqlite3_mprintf("SELECT d5.offset, d5.length FROM data d3, data d4, data d5 WHERE d3.object LIKE '%s' AND d3.property LIKE 'OMFI:SCLP:SourceID' AND d4.value LIKE d3.value AND d5.object LIKE d4.object AND d5.property LIKE 'OMFI:MOBJ:Name' LIMIT 1", items[j]), &itemName, &itemNameCount, 0, 0); - sqlite3_get_table(db, sqlite3_mprintf("SELECT offset, length FROM data WHERE object IN (SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property = 'OMFI:MOBJ:MobID' LIMIT 1) AND property = 'OMFI:MOBJ:Name' LIMIT 1", items[j]), &itemName, &itemNameCount, 0, 0); - - XMLNode* region = new_region_node (); - playlist->add_child_nocopy (*region); - - region->add_property ("name", "iNeedAName"); - snprintf (sbuf, sizeof (sbuf), "%" PRId64, llrintf (position)); - region->add_property ("position", sbuf); - snprintf (sbuf, sizeof (sbuf), "%" PRId64, llrintf (length)); - region->add_property ("length", sbuf); - - DEBUG(" 0) { - int soffs = atoi(startTime[1]); - //sscanf(startTime[1],"%d", &soffs); - DEBUG("SOFFS %.14f\n", (double) soffs * frameRate); - snprintf (sbuf, sizeof (sbuf), "%" PRId64, (int64_t) soffs); - region->add_property ("start", sbuf); - } else { - region->add_property ("start", "0"); - } - sqlite3_free_table(startTime); - - char **sourceFile; - int sourceFileCount; - //sqlite3_get_table(db, sqlite3_mprintf("SELECT d10.offset, d10.length FROM data d3, data d4, data d5, data d6, data d7, data d8, data d9, data d10 WHERE d3.object LIKE '%s' AND d3.property LIKE 'OMFI:SCLP:SourceID' AND d4.value LIKE d3.value AND d4.property LIKE 'OMFI:MOBJ:MobID' AND d5.object LIKE d4.object AND d5.property LIKE 'OMFI:MOBJ:Slots' AND d6.object LIKE d5.value AND d7.object LIKE d6.value AND d7.property LIKE 'OMFI:MSLT:Segment' AND d8.object LIKE d7.value AND d8.property LIKE 'OMFI:SCLP:SourceID' AND d9.value LIKE d8.value AND d9.property LIKE 'OMFI:MOBJ:MobID' AND d10.object LIKE d9.object AND d10.property LIKE 'OMFI:MOBJ:Name' LIMIT 1", items[j]), &sourceFile, &sourceFileCount, 0, 0); - sqlite3_get_table(db, sqlite3_mprintf("SELECT offset, length FROM data WHERE object IN (SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property = 'OMFI:MOBJ:MobID' LIMIT 1) AND property = 'OMFI:MOBJ:Slots' LIMIT 1) LIMIT 1) AND property = 'OMFI:MSLT:Segment' LIMIT 1) AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property = 'OMFI:MOBJ:MobID' LIMIT 1) AND property LIKE 'OMFI:MOBJ:Name' LIMIT 1", items[j]), &sourceFile, &sourceFileCount, 0, 0); - - if (sourceFileCount > 0) { - if (itemNameCount > 0) { - uint32_t inOffs = atoi(itemName[2]); - uint32_t inLen = atoi(itemName[3]); - if (get_offset_and_length (itemName[2], itemName[3], inOffs, inLen)) { - char *inBuf = read_name (inOffs, inLen); - DEBUG("NAME \"%s\"\n", inBuf); - region->add_property ("name", inBuf); - free (inBuf); - } - } - uint32_t sfOffs = atoi(sourceFile[2]); - uint32_t sfLen = atoi(sourceFile[3]); - if (get_offset_and_length (sourceFile[2], sourceFile[3], sfOffs, sfLen)) { - char *sfBuf = read_name (sfOffs, sfLen); - - if ((source = get_known_source (sfBuf)) == 0) { - source = new_source_node (); - } - - region->add_property ("source-0", source->property ("id")->value()); - source->add_property ("name", sfBuf); - add_source (sfBuf, source); - - DEBUG("\n", sfBuf); - free (sfBuf); - } - } else { - char **fallbackFile; - int fallbackFileCount; - //sqlite3_get_table(db, sqlite3_mprintf("SELECT d9.object FROM data d3, data d4, data d5, data d6, data d7, data d8, data d9 WHERE d3.object LIKE '%s' AND d3.property LIKE 'OMFI:SCLP:SourceID' AND d4.value LIKE d3.value AND d4.property LIKE 'OMFI:MOBJ:MobID' AND d5.object LIKE d4.object AND d5.property LIKE 'OMFI:MOBJ:Slots' AND d6.object LIKE d5.value AND d7.object LIKE d6.value AND d7.property LIKE 'OMFI:MSLT:Segment' AND d8.object LIKE d7.value AND d8.property LIKE 'OMFI:SCLP:SourceID' AND d9.value LIKE d8.value AND d9.property LIKE 'OMFI:MDAT:MobID' LIMIT 1", items[j]), &fallbackFile, &fallbackFileCount, 0, 0); - sqlite3_get_table(db, sqlite3_mprintf("SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object IN (SELECT object FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property = 'OMFI:MOBJ:MobID' LIMIT 1) AND property = 'OMFI:MOBJ:Slots' LIMIT 1) LIMIT 1) AND property = 'OMFI:MSLT:Segment' LIMIT 1) AND property = 'OMFI:SCLP:SourceID' LIMIT 1)AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property LIKE 'OMFI:MDAT:MobID' LIMIT 1", items[j]), &fallbackFile, &fallbackFileCount, 0, 0); - if (fallbackFileCount > 0) { - if (itemNameCount > 0) { - uint32_t inOffs = atoi(itemName[2]); - uint32_t inLen = atoi(itemName[3]); - if (get_offset_and_length (itemName[2], itemName[3], inOffs, inLen)) { - char *inBuf = read_name (inOffs, inLen+1); - DEBUG("NAME \"%s\"\n", inBuf); - free (inBuf); - } - } - - DEBUG("\n", fallbackFile[1]); - - if ((source = get_known_source (fallbackFile[1])) == 0) { - source = new_source_node (); - } - - region->add_property ("source-0", source->property ("id")->value()); - source->add_property ("name", fallbackFile[1]); - add_source (fallbackFile[1], source); - } - sqlite3_free_table(fallbackFile); - } - - sqlite3_free_table(sourceFile); - sqlite3_free_table(itemName); - position += length; - } - - } - sqlite3_free_table(type); - } - sqlite3_free_table(len); - } - sqlite3_free_table(items); + } else { + INFO ("Track %d has no name\n", i); + snprintf (sbuf, sizeof (sbuf), "Track %d", i); + route->add_property ("name", sbuf); + playlist->add_property ("name", sbuf); + diskstream->add_property ("name", sbuf); + diskstream->add_property ("playlist", sbuf); } + sqlite3_free_table(name); + + char **rate; + int rateCount; + int num = 1, denom = 1; + + sqlite3_get_table(db, sqlite3_mprintf("SELECT offset FROM data WHERE object = %s AND property = 'OMFI:MSLT:EditRate' LIMIT 1", tracks[i]), &rate, &rateCount, 0, 0); + + if (rateCount > 0) { + uint32_t rOffs = atoi(rate[1]); + //sscanf(rate[1], "%d", &rOffs); + fseek(file, rOffs, SEEK_SET); + fread(&denom, 4, 1, file); + denom = e32(denom); + fread(&num, 4, 1, file); + num = e32(num); + if (frame_rate == 0) { + frame_rate = (double) num / (double) denom; + } + if (sample_rate == 0) { + sample_rate = denom; + } + } else { + INFO ("OMF file is missing frame rate information for track %d\n", i); + frame_rate = 0.04; // 25FPS + if (sample_rate == 0) { + sample_rate = 44100; + } + } + + sqlite3_free_table(rate); + + char **items; + int itemCount; + //sqlite3_get_table(db, sqlite3_mprintf("SELECT d3.value FROM data d1, data d2, data d3 WHERE d1.object LIKE '%s' AND d1.property LIKE 'OMFI:MSLT:Segment' AND d2.object LIKE d1.value AND d2.property LIKE 'OMFI:SEQU:Components' AND d3.object LIKE d2.value", tracks[i]), &items, &itemCount, 0, 0); + sqlite3_get_table(db, sqlite3_mprintf("SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:MSLT:Segment' LIMIT 1) AND property = 'OMFI:SEQU:Components' LIMIT 1)", tracks[i]), &items, &itemCount, 0, 0); + double position = 0.0; + int j; + double fadeTime = 0.0; + + for (j = 1; j <= itemCount; j++) { + + printf(" item %d / %d\n", j, itemCount); + + char **len; + int lenCount; + double length = 0.0; + int lenFrames = 0; + + region = 0; + + sqlite3_get_table(db, sqlite3_mprintf("SELECT value FROM data WHERE object = %s AND property = 'OMFI:CPNT:Length' LIMIT 1", items[j]), &len, &lenCount, 0, 0); + + if (lenCount <= 0) { + sqlite3_free_table(len); + continue; + } + + char **type; + int typeCount; + + sqlite3_get_table(db, sqlite3_mprintf("SELECT value FROM data WHERE object = %s AND property = 'OMFI:OOBJ:ObjClass' LIMIT 1", items[j]), &type, &typeCount, 0, 0); + + if (typeCount <= 0) { + sqlite3_free_table(type); + sqlite3_free_table(len); + continue; + } + + lenFrames = atoi(len[1]); + length = lenFrames * frame_rate; + + if (!strcmp(type[1], "TRAN")) { + + position -= length; + char **effID; + int effIDCount; + sqlite3_get_table(db, sqlite3_mprintf("SELECT offset, length FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:TRAN:Effect' LIMIT 1) AND property = 'OMFI:EFFE:EffectKind' LIMIT 1) AND property = 'OMFI:EDEF:EffectID' LIMIT 1", items[j]), &effID, &effIDCount, 0, 0); + if (effIDCount > 0) { + uint32_t eOffs; + uint32_t eLen; + if (get_offset_and_length (effID[2], effID[3], eOffs, eLen)) { + char* eBuf = read_name (eOffs, eLen); + if (!strcmp(eBuf, "omfi:effect:StereoAudioDissolve") | !strcmp(eBuf, "omfi:effect:SimpleMonoAudioDissolve")) { + fadeTime = length; + } + } + } + sqlite3_free_table(effID); + + } else if (!strcmp(type[1], "FILL")) { + + position += length; + + } else if (!strcmp(type[1], "NEST")) { + + char **itemName; + int itemNameCount; + int64_t start = 0; + + sqlite3_get_table(db, sqlite3_mprintf("SELECT offset, length FROM data WHERE object IN (SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:NEST:Slots' LIMIT 1)) AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property = 'OMFI:MOBJ:MobID' LIMIT 1) AND property = 'OMFI:MOBJ:Name' LIMIT 1", items[j]), &itemName, &itemNameCount, 0, 0); + + char **startTime; + int startTimeCount; + //sqlite3_get_table(db, sqlite3_mprintf("SELECT d3.value FROM data d1, data d2, data d3 WHERE d1.object LIKE '%s' AND d1.property LIKE 'OMFI:NEST:SLOTS' AND d2.object LIKE d1.value AND d3.object LIKE d2.value AND d3.property LIKE 'OMFI:SCLP:StartTime' LIMIT 1", items[j]), &startTime, &startTimeCount, 0, 0); + sqlite3_get_table(db, sqlite3_mprintf("SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:NEST:Slots' LIMIT 1)) AND property = 'OMFI:SCLP:StartTime' LIMIT 1", items[j]), &startTime, &startTimeCount, 0, 0); + if (startTimeCount > 0) { + start = atoi(startTime[1]); + } + + sqlite3_free_table(startTime); + + char **itemEffect; + int itemEffectCount; + //sqlite3_get_table(db, sqlite3_mprintf("select d7.offset from data d1, data d2, data d3, data d4, data d5, data d6, data d7 where d1.object like '%s' and d1.property like 'OMFI:NEST:Slots' and d2.object like d1.value and d3.object like d2.value and d3.property like 'OMFI:EFFE:EffectSlots' and d4.object like d3.value and d5.object like d4.value and d5.property like 'OMFI:ESLT:ArgValue' and d6.object like d4.value and d6.property like 'OMFI:ESLT:ArgID' and d6.value like '1' and d7.object like d5.value and d7.property like 'OMFI:CVAL:Value' LIMIT 2", items[j]), &itemEffect, &itemEffectCount, 0, 0); + sqlite3_get_table(db, sqlite3_mprintf("SELECT offset FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:NEST:Slots' LIMIT 1)) AND property = 'OMFI:EFFE:EffectSlots' LIMIT 1) LIMIT 2) AND property = 'OMFI:ESLT:ArgValue' LIMIT 2) AND property like 'OMFI:CVAL:Value' LIMIT 1", items[j]), &itemEffect, &itemEffectCount, 0, 0); + if (itemEffectCount > 0) { + int effNum = 1; + int effDenom = 1; + uint32_t effOffs = atoi(itemEffect[1]); + //sscanf(itemEffect[1], "%d", &effOffs); + fseek(file, effOffs, SEEK_SET); + fread(&effDenom, 4, 1, file); + fread(&effNum, 4, 1, file); + double vol = (double) effNum / (double) effDenom; + //ctx->AddLine("VOLPAN %.8f 0.000000 1.000000 -1.000000", vol); + DEBUG("VOLPAN %.8f 0.000000 1.000000 -1.000000\n", vol); + } + sqlite3_free_table(itemEffect); + + char **sourceFile; + int sourceFileCount; + //sqlite3_get_table(db, sqlite3_mprintf("SELECT d10.offset, d10.length FROM data d1, data d2, data d3, data d4, data d5, data d6, data d7, data d8, data d9, data d10 WHERE d1.object LIKE '%s' AND d1.property LIKE 'OMFI:NEST:Slots' AND d2.object LIKE d1.value AND d3.object LIKE d2.value AND d3.property LIKE 'OMFI:SCLP:SourceID' AND d4.value LIKE d3.value AND d4.property LIKE 'OMFI:MOBJ:MobID' AND d5.object LIKE d4.object AND d5.property LIKE 'OMFI:MOBJ:Slots' AND d6.object LIKE d5.value AND d7.object LIKE d6.value AND d7.property LIKE 'OMFI:MSLT:Segment' AND d8.object LIKE d7.value AND d8.property LIKE 'OMFI:SCLP:SourceID' AND d9.value LIKE d8.value AND d9.property LIKE 'OMFI:MOBJ:MobID' AND d10.object LIKE d9.object AND d10.property LIKE 'OMFI:MOBJ:Name' LIMIT 1", items[j]), &sourceFile, &sourceFileCount, 0, 0); + sqlite3_get_table(db, sqlite3_mprintf("SELECT offset, length FROM data WHERE object IN (SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:NEST:Slots' LIMIT 1) LIMIT 3) AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property = 'OMFI:MOBJ:MobID' LIMIT 1) AND property = 'OMFI:MOBJ:Slots' LIMIT 1) LIMIT 1) AND property = 'OMFI:MSLT:Segment' LIMIT 1) AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property = 'OMFI:MOBJ:MobID' LIMIT 1) AND property LIKE 'OMFI:MOBJ:Name' LIMIT 1", items[j]), &sourceFile, &sourceFileCount, 0, 0); + if (sourceFileCount > 0) { + uint32_t sfOffs; + uint32_t sfLen; + + if (get_offset_and_length (sourceFile[2], sourceFile[3], sfOffs, sfLen)) { + char *sfBuf = read_name (sfOffs, sfLen); + + if ((sinfo = get_known_source (sfBuf)) == 0) { + cerr << "Reference to unknown source [" << sfBuf << "]1" << endl; + return -1; + } + + free (sfBuf); + } else { + cerr << "offs/len illegal\n"; + } + } else { + char **fallbackFile; + int fallbackFileCount; + //sqlite3_get_table(db, sqlite3_mprintf("SELECT d9.object FROM data d1, data d2, data d3, data d4, data d5, data d6, data d7, data d8, data d9 WHERE d1.object LIKE '%s' AND d1.property LIKE 'OMFI:NEST:Slots' AND d2.object LIKE d1.value AND d3.object LIKE d2.value AND d3.property LIKE 'OMFI:SCLP:SourceID' AND d4.value LIKE d3.value AND d4.property LIKE 'OMFI:MOBJ:MobID' AND d5.object LIKE d4.object AND d5.property LIKE 'OMFI:MOBJ:Slots' AND d6.object LIKE d5.value AND d7.object LIKE d6.value AND d7.property LIKE 'OMFI:MSLT:Segment' AND d8.object LIKE d7.value AND d8.property LIKE 'OMFI:SCLP:SourceID' AND d9.value LIKE d8.value AND d9.property LIKE 'OMFI:MDAT:MobID' LIMIT 1", items[j]), &fallbackFile, &fallbackFileCount, 0, 0); + sqlite3_get_table(db, sqlite3_mprintf("SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:NEST:Slots' LIMIT 1) LIMIT 3) AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property = 'OMFI:MOBJ:MobID' LIMIT 1) AND property = 'OMFI:MOBJ:Slots' LIMIT 1) LIMIT 1) AND property = 'OMFI:MSLT:Segment' LIMIT 1) AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property = 'OMFI:MDAT:MobID' LIMIT 1", items[j]), &fallbackFile, &fallbackFileCount, 0, 0); + if (fallbackFileCount > 0) { + if ((sinfo = get_known_source (fallbackFile[1])) == 0) { + cerr << "Reference to unknown source [" << fallbackFile[1] << "]2" << endl; + return -1; + } + + } else { + cerr << "no fallback file\n"; + } + + sqlite3_free_table(fallbackFile); + } + + + if (sinfo) { + + region = new_region_node (); + playlist->add_child_nocopy (*region); + + snprintf (sbuf, sizeof (sbuf), "%" PRId64, llrintf (position * sample_rate)); + region->add_property ("position", sbuf); + snprintf (sbuf, sizeof (sbuf), "%" PRId64, llrintf (length * sample_rate)); + region->add_property ("length", sbuf); + snprintf (sbuf, sizeof (sbuf), "%" PRId64, llrintf (start * frame_rate * sample_rate)); + region->add_property ("start", sbuf); + set_region_sources (region, sinfo); + + route_max_channels = max (route_max_channels, sinfo->channels); + } + + sqlite3_free_table(sourceFile); + sqlite3_free_table(itemName); + position += length; + + } else if (!strcmp(type[1], "SCLP")) { + + char **itemName; + int itemNameCount; + int64_t start = 0; + //sqlite3_get_table(db, sqlite3_mprintf("SELECT d5.offset, d5.length FROM data d3, data d4, data d5 WHERE d3.object LIKE '%s' AND d3.property LIKE 'OMFI:SCLP:SourceID' AND d4.value LIKE d3.value AND d5.object LIKE d4.object AND d5.property LIKE 'OMFI:MOBJ:Name' LIMIT 1", items[j]), &itemName, &itemNameCount, 0, 0); + sqlite3_get_table(db, sqlite3_mprintf("SELECT offset, length FROM data WHERE object IN (SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property = 'OMFI:MOBJ:MobID' LIMIT 1) AND property = 'OMFI:MOBJ:Name' LIMIT 1", items[j]), &itemName, &itemNameCount, 0, 0); + + fadeTime = 0.0; + + char **startTime; + int startTimeCount; + //sqlite3_get_table(db, sqlite3_mprintf("SELECT d3.value FROM data d3 WHERE d3.object LIKE '%s' AND d3.property LIKE 'OMFI:SCLP:StartTime'", items[j]), &startTime, &startTimeCount, 0, 0); + sqlite3_get_table(db, sqlite3_mprintf("SELECT value FROM data WHERE object = %s AND property = 'OMFI:SCLP:StartTime' LIMIT 1", items[j]), &startTime, &startTimeCount, 0, 0); + if (startTimeCount > 0) { + start = atoi(startTime[1]); + } + sqlite3_free_table(startTime); + + char **sourceFile; + int sourceFileCount; + //sqlite3_get_table(db, sqlite3_mprintf("SELECT d10.offset, d10.length FROM data d3, data d4, data d5, data d6, data d7, data d8, data d9, data d10 WHERE d3.object LIKE '%s' AND d3.property LIKE 'OMFI:SCLP:SourceID' AND d4.value LIKE d3.value AND d4.property LIKE 'OMFI:MOBJ:MobID' AND d5.object LIKE d4.object AND d5.property LIKE 'OMFI:MOBJ:Slots' AND d6.object LIKE d5.value AND d7.object LIKE d6.value AND d7.property LIKE 'OMFI:MSLT:Segment' AND d8.object LIKE d7.value AND d8.property LIKE 'OMFI:SCLP:SourceID' AND d9.value LIKE d8.value AND d9.property LIKE 'OMFI:MOBJ:MobID' AND d10.object LIKE d9.object AND d10.property LIKE 'OMFI:MOBJ:Name' LIMIT 1", items[j]), &sourceFile, &sourceFileCount, 0, 0); + sqlite3_get_table(db, sqlite3_mprintf("SELECT offset, length FROM data WHERE object IN (SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property = 'OMFI:MOBJ:MobID' LIMIT 1) AND property = 'OMFI:MOBJ:Slots' LIMIT 1) LIMIT 1) AND property = 'OMFI:MSLT:Segment' LIMIT 1) AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property = 'OMFI:MOBJ:MobID' LIMIT 1) AND property LIKE 'OMFI:MOBJ:Name' LIMIT 1", items[j]), &sourceFile, &sourceFileCount, 0, 0); + + if (sourceFileCount > 0) { + uint32_t sfOffs; + uint32_t sfLen; + + if (get_offset_and_length (sourceFile[2], sourceFile[3], sfOffs, sfLen)) { + cerr << "get source file from " << sfOffs << " + " << sfLen << endl; + char *sfBuf = read_name (sfOffs, sfLen); + + if ((sinfo = get_known_source (sfBuf)) == 0) { + cerr << "Reference to unknown source [" << sfBuf << ']' << endl; + return -1; + } + + free (sfBuf); + } else { + cerr << "can't get off+len\n"; + } + } else { + char **fallbackFile; + int fallbackFileCount; + //sqlite3_get_table(db, sqlite3_mprintf("SELECT d9.object FROM data d3, data d4, data d5, data d6, data d7, data d8, data d9 WHERE d3.object LIKE '%s' AND d3.property LIKE 'OMFI:SCLP:SourceID' AND d4.value LIKE d3.value AND d4.property LIKE 'OMFI:MOBJ:MobID' AND d5.object LIKE d4.object AND d5.property LIKE 'OMFI:MOBJ:Slots' AND d6.object LIKE d5.value AND d7.object LIKE d6.value AND d7.property LIKE 'OMFI:MSLT:Segment' AND d8.object LIKE d7.value AND d8.property LIKE 'OMFI:SCLP:SourceID' AND d9.value LIKE d8.value AND d9.property LIKE 'OMFI:MDAT:MobID' LIMIT 1", items[j]), &fallbackFile, &fallbackFileCount, 0, 0); + sqlite3_get_table(db, sqlite3_mprintf("SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object IN (SELECT object FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property = 'OMFI:MOBJ:MobID' LIMIT 1) AND property = 'OMFI:MOBJ:Slots' LIMIT 1) LIMIT 1) AND property = 'OMFI:MSLT:Segment' LIMIT 1) AND property = 'OMFI:SCLP:SourceID' LIMIT 1)AND property = 'OMFI:SCLP:SourceID' LIMIT 1) AND property LIKE 'OMFI:MDAT:MobID' LIMIT 1", items[j]), &fallbackFile, &fallbackFileCount, 0, 0); + if (fallbackFileCount > 0) { + if ((sinfo = get_known_source (fallbackFile[1])) == 0) { + cerr << "Reference to unknown source [" << fallbackFile[1] << ']' << endl; + return -1; + } + + } + sqlite3_free_table(fallbackFile); + } + + if (sinfo) { + + region = new_region_node (); + playlist->add_child_nocopy (*region); + + snprintf (sbuf, sizeof (sbuf), "%" PRId64, llrintf (position * sample_rate)); + region->add_property ("position", sbuf); + snprintf (sbuf, sizeof (sbuf), "%" PRId64, llrintf (length * sample_rate)); + region->add_property ("length", sbuf); + snprintf (sbuf, sizeof (sbuf), "%" PRId64, llrintf (start * frame_rate * sample_rate)); + region->add_property ("start", sbuf); + set_region_sources (region, sinfo); + + route_max_channels = max (route_max_channels, sinfo->channels); + } + + sqlite3_free_table(sourceFile); + sqlite3_free_table(itemName); + position += length; + } + + sqlite3_free_table(type); + sqlite3_free_table(len); + } + + /* finalize route information */ + + cerr << "Set up track with " << route_max_channels << " channels" << endl; + set_route_node_channels (route, route_max_channels, route_max_channels, true); + sqlite3_free_table(items); } sqlite3_free_table(tracks); @@ -682,589 +952,10 @@ OMF::create_xml () v.push_back (session_name + ".ardour"); xml.write (Glib::build_filename(v).c_str()); -} - -void -OMF::name_types () -{ - /* Add built-in types */ - sqlite3_exec(db, "INSERT INTO lookup VALUES (1, 'TOC property 1')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (2, 'TOC property 2')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (3, 'TOC property 3')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (4, 'TOC property 4')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (5, 'TOC property 5')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (6, 'TOC property 6')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (7, '(Type 7)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (8, '(Type 8)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (9, '(Type 9)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (10, '(Type 10)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (11, '(Type 11)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (12, '(Type 12)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (13, '(Type 13)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (14, '(Type 14)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (15, '(Type 15)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (16, '(Type 16)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (17, '(Type 17)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (18, '(Type 18)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (19, 'TOC Value')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (20, '(Type 20)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (21, 'String')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (22, '(Type 22)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (23, 'Type Name')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (24, 'Property Name')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (25, '(Type 25)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (26, '(Type 26)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (27, '(Type 27)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (28, '(Type 28)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (29, '(Type 29)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (30, '(Type 30)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (31, 'Referenced Object')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (32, 'Object')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (33, '(Type 33)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (34, '(Type 34)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (35, '(Type 35)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (36, '(Type 36)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (37, '(Type 37)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (38, '(Type 38)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (39, '(Type 39)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (40, '(Type 40)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (41, '(Type 41)')", 0, 0, 0); - sqlite3_exec(db, "INSERT INTO lookup VALUES (42, '(Type 42)')", 0, 0, 0); - - /* Assign type and property values to names */ - sqlite3_exec(db, "UPDATE data SET property = (SELECT name FROM lookup WHERE property = key), type = (SELECT name FROM lookup WHERE type = key)", 0, 0, 0); - sqlite3_exec(db, "DROP TABLE lookup", 0, 0, 0); -} - -int -OMF::load (const string& path) -{ - if ((file = fopen(path.c_str(), "rb")) == 0) { - MessageBox(NULL, "Cannot open file","OMF Error", MB_OK); - return -1; - } - - /* --------------- */ - char *fname = (char*) malloc (path.size()+5); - - strcpy(fname, path.c_str()); - strcat(fname, ".db3"); - //remove(fname); - if(sqlite3_open(":memory:", &db)) { - char error[512]; - sprintf(error, "Can't open database: %s", sqlite3_errmsg(db)); - MessageBox(NULL, error,"OMF Error", MB_OK); - sqlite3_close(db); - return -3; - } - sqlite3_exec(db, "BEGIN", 0, 0, 0); - sqlite3_exec(db, "CREATE TABLE data (object, property, type, value, offset, length)", 0, 0, 0); - sqlite3_exec(db, "CREATE TABLE lookup (key, name)", 0, 0, 0); - - uint8_t magic[8]; - fseek(file, -24, SEEK_END); - fread(magic, 8, 1, file); - if ((magic[0] != 0xa4) | (magic[1] != 0x43) | (magic[2] != 0x4d) | (magic[3] != 0xa5) | (magic[4] != 0x48) | (magic[5] != 0x64) | (magic[6] != 0x72) | (magic[7] != 0xd7)) { - MessageBox(NULL, "No valid OMF file.","OMF Error", MB_OK); - return -4; - } - - uint16_t bSize, version; - fseek(file, -12, SEEK_END); - fread(&version, 2, 1, file); - bigEndian = false; - if ((version == 1) | (version == 256)) { - MessageBox(NULL, "You tried to open an OMF1 file.\nOMF1 is not supported.","OMF Error", MB_OK); - return -2; - } else if (version == 512) { - bigEndian = true; - } else if (version != 2) { - MessageBox(NULL, "You tried to open a corrupted file.","OMF Error", MB_OK); - return -2; - } - - uint32_t tocStart, tocSize; - fseek(file, -14, SEEK_END); - fread(&bSize, 2, 1, file); - bSize = e16(bSize); - - fseek(file, -8, SEEK_END); - fread(&tocStart, 4, 1, file); - tocStart = e32(tocStart); - - fseek(file, -4, SEEK_END); - fread(&tocSize, 4, 1, file); - tocSize = e32(tocSize); - DEBUG ("block size: %d\n toc start: %d\n toc size: %d\n", bSize, tocStart, tocSize); - - - /* Calculate number of TOC blocks */ - uint32_t tocBlocks = tocSize / (bSize * 1024) + 1; - DEBUG ("toc blocks: %d\n", tocBlocks); - /* ------------------------------ */ - - time_t globalstart, starttime, endtime; - time(&globalstart); - starttime = globalstart; - INFO ("Parsing TOC... "); - - /* Go through TOC blocks */ - uint32_t j; - uint32_t currentObj = 0; - uint32_t currentProp = 0; - uint32_t currentType = 0; - char skip = 0; - //uint64_t len = 0; - for (j = 0; j < tocBlocks; j++) { - uint32_t currentBlock = tocStart + j * 1024 * bSize; // Start at beginning of current block - uint32_t currentPos; - for (currentPos = currentBlock; currentPos < currentBlock + 1024 * bSize; currentPos++) { - if (currentPos > tocStart + tocSize) break; // Exit at end of TOC - char cByte; // TOC control byte - fseek(file, currentPos, SEEK_SET); - fread(&cByte, 1, 1, file); - - /* New object */ - if (cByte == 1) { - fseek(file, currentPos + 1, SEEK_SET); - fread(¤tObj, 4, 1, file); - currentObj = e32(currentObj); - fseek(file, currentPos + 5, SEEK_SET); - fread(¤tProp, 4, 1, file); - currentProp = e32(currentProp); - fseek(file, currentPos + 9, SEEK_SET); - fread(¤tType, 4, 1, file); - currentType = e32(currentType); - DEBUG("---------------------\n"); - DEBUG(" object: 0x%x\n", currentObj); - DEBUG(" property: 0x%x\n", currentProp); - DEBUG(" type: 0x%x\n", currentType); - skip = 0; - currentPos += 12; // Skip the bytes that were just read - } - /* ---------- */ - - - /* New property */ - else if (cByte == 2) { - fseek(file, currentPos + 1, SEEK_SET); - fread(¤tProp, 4, 1, file); - currentProp = e32(currentProp); - fseek(file, currentPos + 5, SEEK_SET); - fread(¤tType, 4, 1, file); - currentType = e32(currentType); - DEBUG(" property: 0x%x\n", currentProp); - DEBUG(" type: 0x%x\n", currentType); - skip = 0; - currentPos += 8; - } - /* ------------ */ - - - /* New type */ - else if (cByte == 3) { - fseek(file, currentPos + 1, SEEK_SET); - fread(¤tType, 4, 1, file); - currentType = e32(currentType); - DEBUG(" type: 0x%x\n", currentType); - skip = 0; - currentPos += 4; - } - /* -------- */ - - - /* (unused) */ - else if (cByte == 4) { - currentPos += 4; - } - /* -------- */ - - - /* Reference to a value - 4/8 byte offset, 4/8 byte size */ - else if ((cByte == 5) | (cByte == 6) | (cByte == 7) | (cByte == 8)) { - if (!skip) { - uint32_t offset32 = 0; - uint32_t length32 = 0; - uint64_t dataOffset = 0; - uint64_t dataLength = 0; - if ((cByte == 5) | (cByte == 6)) { - fseek(file, currentPos + 1, SEEK_SET); - fread(&offset32, 4, 1, file); - fseek(file, currentPos + 5, SEEK_SET); - fread(&length32, 4, 1, file); - dataOffset = e32(offset32); - dataLength = e32(length32); - } else { - fseek(file, currentPos + 1, SEEK_SET); - fread(&dataOffset, 8, 1, file); - dataOffset = e64(dataOffset); - fseek(file, currentPos + 9, SEEK_SET); - fread(&dataLength, 8, 1, file); - dataLength = e64(dataLength); - } - DEBUG(" offset: %d\n", dataOffset); - DEBUG(" length: %d\n", dataLength); - - if (currentType == 21) { - char* string = (char*) malloc((uint32_t) dataLength); - fseek(file, dataOffset, SEEK_SET); - fread(string, dataLength, 1, file); - char* query = sqlite3_mprintf("INSERT INTO lookup VALUES(%d, '%s')",currentObj, string); - sqlite3_exec(db, query, 0, 0, 0); - sqlite3_free(query); - } else if (currentType == 32){ - uint32_t object = 0; - fseek(file, dataOffset, SEEK_SET); - fread(&object, 4, 1, file); - object = e32(object); - char* query = sqlite3_mprintf("INSERT INTO data VALUES(%d, %d, %d, %d, -1, -1)",currentObj, currentProp, currentType, object); - sqlite3_exec(db, query, 0, 0, 0); - sqlite3_free(query); - if (dataLength == 16) { - DEBUG(" offset: %lld\n", dataOffset + 8); - DEBUG(" length: %lld\n", dataLength); - fseek(file, dataOffset + 8, SEEK_SET); - fread(&object, 4, 1, file); - object = e32(object); - char* query2 = sqlite3_mprintf("INSERT INTO data VALUES(%d, %d, %d, %d, -1, -1)",currentObj, currentProp, currentType, object); - sqlite3_exec(db, query2, 0, 0, 0); - sqlite3_free(query2); - } - } else { - char* query = sqlite3_mprintf("INSERT INTO data VALUES(%d, %d, %d, '', %lld, %lld)",currentObj, currentProp, currentType, dataOffset, dataLength); - sqlite3_exec(db, query, 0, 0, 0); - sqlite3_free(query); - } - } - if ((cByte == 5) | (cByte == 6)) { - currentPos += 8; - } else { - currentPos += 16; - } - } - /* ----------------------------------------------------- */ - - - /* Zero byte value */ - else if (cByte == 9) { - if (!skip) { - char* query = sqlite3_mprintf("INSERT INTO data VALUES(%d, %d, %d, 'true', -1, -1)",currentObj, currentProp, currentType); - sqlite3_exec(db, query, 0, 0, 0); - sqlite3_free(query); - DEBUG(" value: true\n"); - } - } - /* --------------- */ - - - /* Immediate value */ - else if ((cByte == 10) | (cByte == 11) | (cByte == 12) | (cByte == 13) | (cByte == 14)) { - if (!skip) { - uint32_t data = 0; - fseek(file, currentPos + 1, SEEK_SET); - fread(&data, 4, 1, file); - data = e32(data); - char* query = sqlite3_mprintf("INSERT INTO data VALUES(%d, %d, %d, %d, -1, -1)",currentObj, currentProp, currentType, data); - sqlite3_exec(db, query, 0, 0, 0); - sqlite3_free(query); - DEBUG(" value: %d\n", data); - - } - currentPos += 4; - } - /* --------------- */ - - - /* Reference list */ - else if (cByte == 15) { - uint32_t data = 0; - fseek(file, currentPos + 1, SEEK_SET); - fread(&data, 4, 1, file); - data = e32(data); - char* query = sqlite3_mprintf("INSERT INTO data VALUES(%d, %d, %d, %d, -1, -1)",currentObj, currentProp, currentType, data); - sqlite3_exec(db, query, 0, 0, 0); - sqlite3_free(query); - DEBUG("reference: 0x%x\n", data); - skip = 1; - currentPos += 4; - } - /* -------------- */ - else { - break; - } - - } - } - /* --------------------- */ - time(&endtime); - INFO("done. (%ld seconds)\n", endtime - starttime); - starttime = endtime; - - INFO("Assigning type and property names... "); - name_types (); - time(&endtime); - INFO("done. (%ld seconds)\n", endtime - starttime); - starttime = endtime; - - bool isAvid = false; - - /* resolve ObjRefArrays */ - char **arrays; - int arrayCount; - int l; - INFO("Resolving ObjRefArrays "); - sqlite3_get_table(db, "SELECT * FROM data WHERE type LIKE 'omfi:ObjRefArray' AND value = ''", &arrays, &arrayCount, 0, 0); - INFO("(%d to be processed)... ", arrayCount); - sqlite3_exec(db,"DELETE FROM data WHERE type LIKE 'omfi:ObjRefArray' AND value = ''",0,0,0); - for (l = 6; l <= arrayCount * 6; l+=6) { - uint16_t counter; - uint32_t arrOffs = atoi(arrays[l+4]); - uint32_t arrLen = atoi(arrays[l+5]); - fseek(file, arrOffs, SEEK_SET); - fread(&counter, 2, 1, file); - counter = e16(counter); - if (arrLen = 4 * counter + 2) { - isAvid = true; - currentObj++; - DEBUG("currentObj: %d - references:", currentObj); - for (counter = 2; counter < arrLen; counter += 4) { - uint32_t temp; - fseek(file, arrOffs + counter, SEEK_SET); - fread(&temp, 4, 1, file); - temp = e32(temp); - DEBUG(" %d", temp); - sqlite3_exec(db, sqlite3_mprintf("INSERT INTO data VALUES (%d, 'Referenced Object', 'Object', %d, -1, -1)", currentObj, temp), 0, 0, 0); - } - DEBUG("\nData: %s | %s | %s | %d | -1 | -1\n", arrays[l], arrays[l+1], arrays[l+2], currentObj); - sqlite3_exec(db, sqlite3_mprintf("INSERT INTO data VALUES (%s, '%s', '%s', %d, -1, -1)", arrays[l], arrays[l+1], arrays[l+2], currentObj), 0, 0, 0); - } - } - sqlite3_free_table(arrays); - time(&endtime); - INFO("done. (%ld seconds)\n", endtime - starttime); - starttime = endtime; - /* -------------------- */ - - - //return -1; - /*char **refs; - int refCount; - int currentRef; - printf("Resolving ObjRefs...\n"); - sqlite3_get_table(db,"SELECT object, property, value FROM data WHERE type = 'omfi:ObjRef'", &refs, &refCount, 0, 0); - printf("temporary table created\n"); - for (currentRef = 3; currentRef <= refCount * 3; currentRef += 3) { - DEBUG("%d / %d\n", currentRef/3, refCount); - char **target; - int targetCount; - sqlite3_get_table(db, sqlite3_mprintf("SELECT value FROM data WHERE object = %s AND type = 'Object' LIMIT 1", refs[currentRef+2]), &target, &targetCount, 0, 0); - DEBUG("temporary table filled\n"); - if (targetCount > 0) { - //sqlite3_exec(db,sqlite3_mprintf("DELETE FROM data WHERE object = %s", refs[currentRef+2]),0,0,0); - DEBUG("unused reference deleted\n"); - sqlite3_exec(db,sqlite3_mprintf("UPDATE data SET value = %s WHERE object LIKE '%s' AND property LIKE '%s' LIMIT 1", target[1], refs[currentRef], refs[currentRef+1]),0,0,0); - printf("temporary data inserted\n"); - } - sqlite3_free_table(target); - } - sqlite3_free_table(refs); - printf("temporary table deleted\n"); */ - - if (!isAvid) { - INFO("Resolving ObjRefs "); - sqlite3_exec(db,"CREATE TABLE reference (object1, property1, value1)",0,0,0); - sqlite3_exec(db,"INSERT INTO reference SELECT object, property, value FROM data WHERE type LIKE 'omfi:ObjRef'",0,0,0); - sqlite3_exec(db,"CREATE TABLE objects (object2, value2)",0,0,0); - sqlite3_exec(db,"INSERT INTO objects SELECT object, value FROM data WHERE type LIKE 'Object'",0,0,0); - sqlite3_exec(db,"UPDATE reference SET value1 = (SELECT value2 FROM objects WHERE object2 = value1)",0,0,0); - //sqlite3_exec(db,"UPDATE data SET value = (SELECT value1 FROM references WHERE object1 = object) WHERE ",0,0,0); - char **refs; - int refCount; - int currentRef; - - sqlite3_get_table(db,"SELECT * FROM reference", &refs, &refCount, 0, 0); - INFO ("(%d to be processed)... ", refCount); - for (currentRef = 3; currentRef <= refCount * 3; currentRef += 3) { - DEBUG("%d / %d: object %s, property %s, value %s\n", currentRef/3, refCount, refs[currentRef], refs[currentRef+1], refs[currentRef+2]); - sqlite3_exec(db,sqlite3_mprintf("DELETE FROM data WHERE object = %s AND property = '%s'", refs[currentRef], refs[currentRef+1]),0,0,0); - sqlite3_exec(db,sqlite3_mprintf("INSERT INTO data VALUES (%s, '%s', 'omfi:ObjRef', %s, -1, -1)", refs[currentRef], refs[currentRef+1], refs[currentRef+2]),0,0,0); - } - sqlite3_free_table(refs); - } - DEBUG("temporary table deleted\n"); - - /*sqlite3_get_table(db,"SELECT object, property, value FROM data WHERE type LIKE 'omfi:ObjRef'", &refs, &refCount, 0, 0); - printf("%d\n", refCount); - for (currentRef = 3; currentRef <= refCount * 3; currentRef += 3) { - printf("%d / %d: object %s, property %s, value %s\n", currentRef/3, refCount, refs[currentRef], refs[currentRef+1], refs[currentRef+2]); - } - sqlite3_free_table(refs); - }*/ - - - /* resolve ObjRefs * - printf("Resolving ObjRefs...\n"); - sqlite3_exec(db,"CREATE TABLE temp (object, property, type, value, offset, length)",0,0,0); - printf("temporary table created\n"); - sqlite3_exec(db,"INSERT INTO temp SELECT d1.object, d1.property, d1.type, d2.value, d1.offset, d1.length FROM data d1, data d2 WHERE d1.type = 'omfi:ObjRef' AND d1.value = d2.object AND d2.type = 'Object'",0,0,0); - printf("temporary table filled\n"); - //sqlite3_exec(db,"DELETE FROM data WHERE object IN (SELECT value FROM data WHERE type LIKE 'omfi:ObjRef')",0,0,0); - sqlite3_exec(db,"DELETE FROM data WHERE object IN (SELECT object FROM temp) AND type = 'omfi:ObjRef'",0,0,0); - printf("unused referenced deleted\n"); - sqlite3_exec(db,"INSERT INTO data SELECT * FROM temp",0,0,0); - printf("temporary data inserted\n"); - sqlite3_exec(db,"DROP TABLE temp",0,0,0); - printf("temporary table deleted\n"); - * --------------- */ - - time(&endtime); - INFO("done. (%ld seconds)\n", endtime - starttime); - starttime = endtime; - - //return -1; - /* resolve UIDs */ - INFO("Resolving UIDs... "); - char **mobID; - int mobIDCount; - int currentID; - sqlite3_get_table(db,"SELECT object, property, offset FROM data WHERE type LIKE 'omfi:UID'", &mobID, &mobIDCount, 0, 0); - sqlite3_exec(db,"DELETE FROM data WHERE type LIKE 'omfi:UID'",0,0,0); - for (currentID = 3; currentID <= mobIDCount * 3; currentID += 3) { - uint32_t mobIDoffs = atoi(mobID[currentID+2]); - //sscanf(mobID[currentID+2], "%d", &mobIDoffs); - int mobBuffer[3]; - fseek(file, mobIDoffs, SEEK_SET); - fread(mobBuffer, 12, 1, file); - sqlite3_exec(db,sqlite3_mprintf("INSERT INTO data VALUES (%s, '%s', 'omfi:UID', '%d %d %d', -1, -1)", mobID[currentID], mobID[currentID + 1], mobBuffer[0], mobBuffer[1], mobBuffer[2]),0,0,0); - } - sqlite3_free_table(mobID); - /* ------------ */ - - time(&endtime); - INFO("done. (%ld seconds)\n", endtime - starttime); - starttime = endtime; - - //return -1; - - /* extract media data */ - printf("Extracting media data...\n"); - char **objects; - int objectsCount, k; - //sqlite3_exec(db,"CREATE TABLE names (UID, value)",0,0,0); - sqlite3_get_table(db, "SELECT object, offset, length FROM data WHERE object IN (SELECT value FROM data WHERE object IN (SELECT value FROM data WHERE property = 'OMFI:HEAD:MediaData' LIMIT 1)) AND type = 'omfi:DataValue'", &objects, &objectsCount, 0, 0); - for (k = 3; k <= objectsCount * 3; k += 3) { - char **fileName; - int fileNameCount; - FILE *fd; - char *fnTemp; - sqlite3_get_table(db, sqlite3_mprintf("SELECT offset, length FROM data WHERE object IN (SELECT object FROM data WHERE value IN (SELECT value FROM data WHERE object = %s AND property = 'OMFI:MDAT:MobID' LIMIT 1) AND property = 'OMFI:MOBJ:MobID' LIMIT 1) AND property = 'OMFI:MOBJ:Name' LIMIT 1", objects[k]), &fileName, &fileNameCount, 0, 0); - if (fileNameCount > 0) { - uint32_t fnOffs = atoi(fileName[2]); - uint32_t fnLen = atoi(fileName[3]); - if (get_offset_and_length (fileName[2], fileName[3], fnOffs, fnLen)) { - char *fnBuf = (char*) malloc(fnLen+1); - fseek(file, fnOffs, SEEK_SET); - fread(fnBuf, fnLen, 1, file); - fnBuf[fnLen] = '\0'; - - audiofile_path_vector.push_back (fnBuf); - std::string full_path = Glib::build_filename (audiofile_path_vector); - audiofile_path_vector.pop_back (); - - fd = fopen(full_path.c_str(), "wb"); - - /* this is just the "name" */ - fnTemp = fnBuf; - } else { - INFO ("Skip unnamed media file\n"); - continue; - } - } else { - fnTemp = objects[k]; - fd = fopen(objects[k], "wb"); - } - if(fd == NULL){ - char error[255]; - sprintf(error, "Can't create file [%s] (object %s)", fnTemp, objects[k]); - MessageBox(NULL,error,"OMF Error", MB_OK); - sqlite3_exec(db, "COMMIT", 0, 0, 0); - sqlite3_close(db); - return 1; - } else { - INFO("Writing file %s (object %s): ", fnTemp, objects[k]); - XMLNode* source = new_source_node (); - source->add_property ("name", fnTemp); - add_source (fnTemp, source); - } - uint32_t foffset = atoi(objects[k+1]); - uint32_t flength = atoi(objects[k+2]); - uint32_t written = 0; - //sscanf(, "%d", &foffset); - //sscanf(objects[k+2], "%d", &flength); - //foffset = - int blockSize = 1024; - uint32_t currentBlock; - char* buffer = (char*) malloc(blockSize); - fseek(file, foffset, SEEK_SET); - for (currentBlock = 0; currentBlock < flength / blockSize; currentBlock++) { - fread(buffer, blockSize, 1, file); - written += fwrite(buffer, 1, blockSize, fd); - } - fread(buffer, flength % blockSize, 1, file); - written += fwrite(buffer, 1, flength % blockSize, fd); - INFO("%d of %d bytes\n", written, flength); - fclose(fd); - sqlite3_free_table(fileName); - } - sqlite3_free_table(objects); - /* ------------------ */ - - time(&endtime); - INFO("done. (%ld seconds)\n", endtime - starttime); - starttime = endtime; - - /* resolve ClassIDs */ - printf("Resolving ClassIDs "); - char **classID; - int classIDCount; - int currentClsID; - sqlite3_get_table(db,"SELECT object, property, value FROM data WHERE type = 'omfi:ClassID'", &classID, &classIDCount, 0, 0); - sqlite3_exec(db,"DELETE FROM data WHERE type = 'omfi:ClassID'",0,0,0); - INFO("(%d to be processed)... ", classIDCount); - for (currentClsID = 3; currentClsID <= classIDCount * 3; currentClsID += 3) { - //int clsID = (int) malloc(5); - int clsID = atoi(classID[currentClsID+2]); - clsID = e32(clsID); - //sscanf(classID[currentClsID+2], "%d", &clsID); - char clsString[5]; - strncpy(clsString, (char *) &clsID, 4); - clsString[4] = 0; - DEBUG("%d -> %s\n", clsID, clsString); - - sqlite3_exec(db,sqlite3_mprintf("INSERT INTO data VALUES (%s, '%s', 'omfi:ClassID', '%s', -1, -1)", classID[currentClsID], classID[currentClsID + 1], clsString),0,0,0); - } - sqlite3_free_table(classID); - /* ---------------- */ - - sqlite3_exec(db, "COMMIT", 0, 0, 0); - - time(&endtime); - INFO("done. (%ld seconds)\n", endtime - starttime); - starttime = endtime; - - /*time(&endtime); - printf("Took %ld seconds\n", endtime - starttime); - starttime = endtime;*/ - - - time(&endtime); - INFO("done. (%ld seconds)\n", endtime - starttime); - INFO("Overall time: %ld seconds\n", endtime - globalstart); - return 0; - /* -------- */ } + static void print_help (const char* execname) { @@ -1323,19 +1014,24 @@ main (int argc, char* argv[]) break; } } + + if (optind > argc) { + print_help (execname); + /*NOTREACHED*/ + } OMF omf; omf.set_version (version); omf.set_sample_rate (sample_rate); + if (session_name) { omf.set_session_name (session_name); + } else { + omf.set_session_name (basename_nosuffix (argv[optind])); } - cerr << "args done, file = " << argv[optind] << endl; - if (omf.init () == 0) { - cerr << "Attempting to load " << argv[optind] << endl; if (omf.load (argv[optind++]) == 0) { omf.create_xml (); diff --git a/tools/omf/omftool.h b/tools/omf/omftool.h index 1d93f47989..b6e291ca58 100644 --- a/tools/omf/omftool.h +++ b/tools/omf/omftool.h @@ -17,12 +17,22 @@ public: int init (); int load (const std::string&); - void create_xml (); + int create_xml (); void set_version (int); void set_session_name (const std::string&); void set_sample_rate (int); + struct SourceInfo { + int channels; + int sample_rate; + uint64_t length; + XMLNode* node; + + SourceInfo (int chn, int sr, uint64_t l, XMLNode* n) + : channels (chn), sample_rate (sr), length (l), node (n) {} + }; + private: bool bigEndian; int64_t id_counter; @@ -32,7 +42,8 @@ private: std::string base_dir; std::string session_name; std::vector audiofile_path_vector; - int sample_rate; + int sample_rate; /* audio samples per second */ + double frame_rate; /* time per video frame */ XMLNode* session; XMLNode* sources; XMLNode* routes; @@ -48,14 +59,18 @@ private: XMLNode* new_playlist_node (); XMLNode* new_diskstream_node (); - typedef std::map KnownSources; + typedef std::map KnownSources; KnownSources known_sources; - XMLNode* get_known_source (const char*); - void add_source (const char*, XMLNode*); + SourceInfo* get_known_source (const char*); char* read_name (size_t offset, size_t length); - bool get_offset_and_length (const char* offstr, const char* lenstr, uint32_t& offset, uint32_t len); + bool get_offset_and_length (const char* offstr, const char* lenstr, uint32_t& offset, uint32_t& len); void name_types (); + void add_id (XMLNode*); + void set_route_node_channels (XMLNode* route, int in, int out, bool send_to_master); + bool get_audio_info (const std::string& path); + void set_region_sources (XMLNode*, SourceInfo*); + void legalize_name (std::string&); uint16_t e16(uint16_t x) { @@ -64,7 +79,7 @@ private: | (x<<8); else return x; - } + } uint32_t e32(uint32_t x) {