Conversation selector

channelName.json

@@ -1 +1 @@
-[{"id":"C02G2SXKX","name":"general"},{"id":"C03RAK46BEC","name":"web3-da0"},{"id":"C046EJH4P2B","name":"da0-global-comms"},{"id":"C046T7HT05U","name":"da0-hack-and-show"},{"id":"C046ZFGTWQK","name":"da0-shoutout"},{"id":"C047A5734FK","name":"da0-arm0ry"},{"id":"C049L7M5X9S","name":"da0-learning"},{"id":"C04FRRV17GF","name":"da0-coordinate"},{"id":"C04UZ3JNH9A","name":"da0-desci"},{"id":"C051REPUTSS","name":"da0-dml"},{"id":"C051U8RSTHV","name":"da0-g0v-ars-electronica"},{"id":"C0525SELHFY","name":"da0-zkp"}]
+[{"id":"C02G2SXKX","name":"general"},{"id":"C0385B90D","name":"jothon"},{"id":"CGU1SLHNH","name":"rand0m"},{"id":"C03RAK46BEC","name":"web3-da0"},{"id":"C046EJH4P2B","name":"da0-global-comms"},{"id":"C046T7HT05U","name":"da0-hack-and-show"},{"id":"C046ZFGTWQK","name":"da0-shoutout"},{"id":"C047A5734FK","name":"da0-arm0ry"},{"id":"C049L7M5X9S","name":"da0-learning"},{"id":"C04FRRV17GF","name":"da0-coordinate"},{"id":"C04UZ3JNH9A","name":"da0-desci"},{"id":"C051REPUTSS","name":"da0-dml"},{"id":"C051U8RSTHV","name":"da0-g0v-ars-electronica"},{"id":"C0525SELHFY","name":"da0-zkp"},{"id":"C059A63M16J","name":"da0-shoutout-test"},{"id":"C05DXC8CNGP","name":"thaubing-esg"}]

src/selectConversation.js

@@ -24,6 +24,7 @@ const app = new App({
   signingSecret: process.env.SLACK_SIGNING_SECRET,
 });
 
+
 // All the room in the world for your code
 // Require the Node Slack SDK package (github.com/slackapi/node-slack-sdk)
 const { WebClient, LogLevel } = require("@slack/web-api");
@@ -48,7 +49,7 @@ var emojiFilter = [];
 
 const retrieveingTime = new Date();
 const retrieveingTimeStamp = retrieveingTime.getTime()/1000;
-const retrieveingTimeStampStartDay = retrieveingTimeStamp - 7776000;
+const retrieveingTimeStampStartDay = retrieveingTimeStamp - 604800;
 
 // conversation selected was record by ts in this array
 // let tsSelected = [];

src/transfer.js

@@ -0,0 +1,69 @@
+const redis = require('redis');
+var Promise = require('bluebird'); // add this
+require('dotenv').config();
+
+// 建立連接至來源及目標資料庫
+const sourceClient = redis.createClient({
+    host: 'localhost', 
+    port: 6379
+});
+
+const targetClient = redis.createClient({ 
+    url: process.env.REDISCLOUD_URL
+});
+
+// promisify redis client
+Promise.promisifyAll(sourceClient);
+
+sourceClient.on('connect', function() {
+    console.log('connected to sourceClient');
+});
+
+sourceClient.connect();
+
+// promisify redis client
+Promise.promisifyAll(targetClient);
+
+targetClient.on('connect', function() {
+    console.log('connected to targetClient');
+});
+
+targetClient.connect();
+
+let cursor = '0';
+
+function scanAndCopyKeys() {
+  sourceClient.scan(cursor, 'MATCH', '*', 'COUNT', '100', function(err, reply) {
+    if (err) throw err;
+    console.log("done");
+
+    // reply is an array where reply[0] is the new cursor and reply[1] is the array of keys
+    cursor = reply[0];
+    const keys = reply[1];
+
+    keys.forEach(key => {
+      sourceClient.dump(key, (err, value) => {
+        if (err) throw err;
+
+        targetClient.del(key, (err, delResult) => {
+          if (err) throw err;
+
+          targetClient.restore(key, 0, value, (err, restoreResult) => {
+            if (err) throw err;
+          });
+        });
+      });
+    });
+
+    // if cursor == '0', it means the scan is complete
+    if (cursor !== '0') {
+      scanAndCopyKeys();
+    } else {
+      // You may want to close the connection here.
+      console.log('Finished!');
+    }
+  });
+}
+
+scanAndCopyKeys();
+