IASaveRestore/saveState.js at main · CypherpunkArmory/IASaveRestore · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
(async function () {
    try {
        if (FS.analyzePath("REPLACE_PATH/1.sta").exists) {
            FS.unlink("REPLACE_PATH/1.sta");
        }
        var timeout = 0;
        while (!FS.analyzePath("REPLACE_PATH/1.sta").exists && timeout < 100) {
            await new Promise(r => setTimeout(r, 100));
            timeout++;
        }
        if (timeout == 100) {
            throw new Error('timeout');
        }
        var stateSize = -1;
        var newStateSize = 0;
        timeout = 0;
        while (newStateSize > stateSize && timeout < 100) {
            await new Promise(r => setTimeout(r, 100));
            stateSize = newStateSize;
            newStateSize = FS.stat("REPLACE_PATH/1.sta").size;
            timeout++;
        }
        if (timeout == 100) {
            throw new Error('timeout');
        }

        dbVersion = 1;

        var request = indexedDB.open("stateFiles", dbVersion),
            db,
            createObjectStore = function (dataBase) {
                try {
                    console.log("Creating objectStore");
                    dataBase.createObjectStore("states");
                } catch (error) {
                    MyAndroidClient.saveCallback("fail");
                }
            },

            getSaveState = function () {
                try {
                    var stateBytes = FS.readFile("REPLACE_PATH/1.sta");
                    console.log("Read state");
                    putSaveStateInDb(stateBytes);
                } catch (error) {
                    MyAndroidClient.saveCallback("fail");
                }
            },

            putSaveStateInDb = function (stateBytes) {
                try {
                    console.log("Putting state in IndexedDB");

                    var transaction = db.transaction(["states"], "readwrite");

                    var put = transaction.objectStore("states").put(stateBytes, "REPLACE_KEY");
                    MyAndroidClient.saveCallback("pass");
                } catch (error) {
                    MyAndroidClient.saveCallback("fail");
                }
            };

        request.onerror = function (event) {
            try {
                console.log("Error creating/accessing IndexedDB database");
            } catch (error) {
                MyAndroidClient.saveCallback("fail");
            }
        };

        request.onsuccess = function (event) {
            try {
                console.log("Success creating/accessing IndexedDB database");
                db = request.result;

                db.onerror = function (event) {
                    try {
                        console.log("Error creating/accessing IndexedDB database");
                    } catch (error) {
                        MyAndroidClient.saveCallback("fail");
                    }
                };

                if (db.setVersion) {
                    if (db.version != dbVersion) {
                        var setVersion = db.setVersion(dbVersion);
                        setVersion.onsuccess = function () {
                            try {
                                createObjectStore(db);
                                getSaveState();
                            } catch (error) {
                                MyAndroidClient.saveCallback("fail");
                            }
                        };
                    }
                    else {
                        getSaveState();
                    }
                }
                else {
                    getSaveState();
                }
            } catch (error) {
                MyAndroidClient.saveCallback("fail");
            }
        };

        request.onupgradeneeded = function (event) {
            try {
                createObjectStore(event.target.result);
            } catch (error) {
                MyAndroidClient.saveCallback("fail");
            }
        };
    } catch (error) {
        console.log("Failed in top");
        MyAndroidClient.saveCallback("fail");
    }
})();