AstralTransRocketries/ClassiCube
1
0
Fork 0
mirror of https://github.com/ClassiCube/ClassiCube.git synced 2025-09-13 17:47:12 -04:00
Code Issues Packages Projects Releases Wiki Activity

add function for saving node to IndexedDB directly (doesn't work properly yet)

Browse Source
This commit is contained in:
UnknownShadow200 2021-06-07 21:08:07 +10:00
parent d690981fc2
commit 7bf24f4016
2 changed files with 47 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/Platform_Web.c
View File

@ -189,12 +189,9 @@ cc_result File_Write(cc_file file, const void* data, cc_uint32 count, cc_uint32*
}
extern int interop_FileClose(int fd);
extern void interop_SyncFS(void);
cc_result File_Close(cc_file file) {
/* returned result is negative for error */
int res = -interop_FileClose(file);
interop_SyncFS();
return res;
return -interop_FileClose(file);
}
extern int interop_FileSeek(int fd, int offset, int whence);
@ -258,6 +255,9 @@ void Platform_LoadSysFonts(void) { }
/*########################################################################################################################*
*---------------------------------------------------------Socket----------------------------------------------------------*
*#########################################################################################################################*/
extern void interop_InitSockets(void);
int Socket_ValidAddress(const cc_string* address) { return true; }
extern int interop_SocketGetPending(int sock);
cc_result Socket_Available(cc_socket s, int* available) {
int res = interop_SocketGetPending(s);
@ -281,7 +281,6 @@ cc_result Socket_GetError(cc_socket s, cc_result* result) {
*result = 0; return -res;
}
}
int Socket_ValidAddress(const cc_string* address) { return true; }
extern int interop_SocketCreate(void);
extern int interop_SocketConnect(int sock, const char* addr, int port);
@ -428,7 +427,6 @@ EMSCRIPTEN_KEEPALIVE void Platform_LogError(const char* msg) {
}
extern void interop_InitModule(void);
extern void interop_InitSockets(void);
extern void interop_GetIndexedDBError(char* buffer);
void Platform_Init(void) {

45
src/interop_web.js
View File

@ -129,12 +129,48 @@ mergeInto(LibraryManager.library, {
interop_GetIndexedDBError: function(buffer) {
if (window.cc_idbErr) stringToUTF8(window.cc_idbErr, buffer, 64);
},
interop_SyncFS: function() {
FS.syncfs(false, function(err) {
interop_SaveNode: function (path) {
var callback = function(err) {
if (!err) return;
console.log(err);
ccall('Platform_LogError', 'void', ['string'], ['&cError saving files to IndexedDB:']);
ccall('Platform_LogError', 'void', ['string'], ['&cError saving ' + path]);
ccall('Platform_LogError', 'void', ['string'], [' &c' + err]);
};
var stat, node, entry;
try {
var lookup = FS.lookupPath(path);
node = lookup.node;
stat = FS.stat(path);
} catch (err) {
return callback(err);
}
if (FS.isDir(stat.mode)) {
entry = { timestamp: stat.mtime, mode: stat.mode };
} else {
// Performance consideration: storing a normal JavaScript array to a IndexedDB is much slower than storing a typed array.
// Therefore always convert the file contents to a typed array first before writing the data to IndexedDB.
node.contents = MEMFS.getFileDataAsTypedArray(node);
entry = { timestamp: stat.mtime, mode: stat.mode, contents: node.contents };
}
IDBFS.getDB('/classicube', function(err, db) {
if (err) return callback(err);
var transaction = db.transaction([IDBFS.DB_STORE_NAME], 'readwrite');
var store = transaction.objectStore(IDBFS.DB_STORE_NAME);
transaction.onerror = function(e) {
callback(this.error);
e.preventDefault();
};
var req = store.put(entry, node.path);
req.onsuccess = function() { callback(null); };
req.onerror = function(e) {
callback(this.error);
e.preventDefault();
};
});
},
interop_DirectorySetWorking: function (raw) {
@ -151,6 +187,7 @@ mergeInto(LibraryManager.library, {
var path = UTF8ToString(raw);
try {
FS.mkdir(path, mode, 0);
interop_SaveNode(path);
return 0;
} catch (e) {
if (typeof FS === 'undefined' || !(e instanceof FS.ErrnoError)) abort(e);
@ -232,6 +269,8 @@ mergeInto(LibraryManager.library, {
try {
var stream = FS.getStream(fd);
FS.close(stream);
// save writable files to IndexedDB
if (stream.isWrite.get()) interop_SaveNode(stream.path);
return 0;
} catch (e) {
if (typeof FS === 'undefined' || !(e instanceof FS.ErrnoError)) abort(e);