[ SQLITE ] housekeeping.

Author: soapdog

lib/server-process.js

@@ -131,7 +131,7 @@ module.exports = function (ssbConfig) {
     const database = new DatabaseSync(sqliteIndexPath);
 
     // create new file
-    serverlog("creating virtual table.");
+    serverlog("[SQLITE] creating virtual table.");
     database.exec(`
         CREATE VIRTUAL TABLE IF NOT EXISTS messages USING fts5(key, content, raw, timestamp);
       `);
@@ -202,7 +202,7 @@ module.exports = function (ssbConfig) {
       return;
     }
 
-    serverlog("SQLITE: Starting message indexing pull stream...");
+    serverlog("[SQLITE] Starting message indexing pull stream...");
     const insert = database.prepare(
       "INSERT OR REPLACE INTO messages (key, content, raw, timestamp) VALUES (?, ?, ?, ?)",
     );
@@ -240,28 +240,27 @@ module.exports = function (ssbConfig) {
           try {
             insert.run(m.key, m.content, m.raw, m.timestamp);
           } catch (e) {
-            serverlog("Problem inserting");
+            serverlog("[SQLITE] Problem inserting");
             serverlog(JSON.stringify(m, null, 2));
           }
 
           i++;
-          serverlog(`last timestamp ${lastIndexedTimestamp}`);
+          serverlog(`[SQLITE] insert. last timestamp ${lastIndexedTimestamp}`);
           lastIndexedTimestamp = m.timestamp;
         }
       }),
     );
   };
 
   loadOrCreateSqlite().then(({ database, controlData }) => {
-    serverlog("SQLITE: callback");
     let delayPullStream = false;
     let configuration = configurationForIdentity(ssbConfig.keys.id);
     if (configuration?.imported) {
       delayPullStream = true;
     }
     loadMessagesIntoSQLite({ database, controlData, delayPullStream });
   }).catch((e) => {
-    serverlog("SQLITE: ERROR");
+    serverlog("[SQLITE] ERROR");
     console.error(JSON.stringify(e));
   });
 };