Working with new lib

Author: super3

index.js

@@ -1,15 +1,25 @@
-const fs = require("fs");
-var ndjson = require('ndjson');
+const redis = require('./redis.js');
+const ndjson = require('iterable-ndjson')
+const fs = require('fs')
+const source = fs.createReadStream('./users.json')
 
-fs.createReadStream('./users.json')
-  .pipe(ndjson.parse())
-  .on('data', function(obj) {
+async function import_users() {
+  let userIndex = 0;
+
+  for await (const obj of ndjson.parse(source)) {
     let user = obj.actor_login;
-    console.log("user: " + obj.actor_login);
-
-    substr = "";
-    for (var i = 0; i < user.length; i++) {
-        substr += user.charAt(i);
-        console.log(substr);
-    }
-  })
+    console.log(`user(${userIndex}): ${user}`);
+    await redis.set(`users:${userIndex}`, user);
+    userIndex++;
+  }
+
+  process.exit(0);
+};
+
+import_users();
+
+// substr = "";
+// for (var i = 0; i < user.length; i++) {
+//     substr += user.charAt(i);
+//     //console.log(substr);
+// }

package-lock.json

@@ -17,6 +17,8 @@
   },
   "homepage": "https://github.com/ovsoinc/gitbackup#readme",
   "dependencies": {
+    "ioredis": "^4.11.2",
+    "iterable-ndjson": "^1.1.0",
     "ndjson": "^1.5.0"
   }
 }

package.json

@@ -0,0 +1,3 @@
+const Redis = require('ioredis');
+
+module.exports = new Redis(process.env.REDIS_URL);