Implemented new unfollowing logic

Author: KevinTrinh1227

config.example.json

@@ -0,0 +1,12 @@
+{
+  "initialStartup": {
+    "completed": false
+  },
+  "configValues": {
+    "maxTotalFollowing": 1000,
+    "minWaitTimeSeconds": 500,
+    "maxWaitTimeSeconds": 900,
+    "queueListMaxUsers": 1000,
+    "pendingFollowBackWaitTimeDays": 7
+  }
+}

package.json

@@ -2,12 +2,12 @@
   "name": "github-auto-followers-bot",
   "version": "1.0.0",
   "description": "https://github.com/KevinTrinh1227/Github-Auto-Followers-Bot",
-  "main": "src/main.js",
+  "main": "src/index.js",
   "src": {
-    "github-auto-followers-bot": "src/main.js"
+    "github-auto-followers-bot": "src/index.js"
   },
   "scripts": {
-    "start": "node src/main.js",
+    "start": "node src/index.js",
     "test": "echo \"Error: no test specified\" && exit 1"
   },
   "repository": {

src/main.js src/index.js

@@ -12,6 +12,7 @@ const {
   nextInUnfollowQueue,
   addUserToUnfollowQueue,
   removeUserFromFollowQueue,
+  moveExpiredUsersToUnfollowQueue,
 } = require("./queues");
 const { getTotalFollowing } = require("./followingList");
 const {
@@ -87,6 +88,7 @@ async function processQueue() {
         await unfollowUser(nextUnfollower);
       } else {
         console.log("No users to unfollow.");
+        await moveExpiredUsersToUnfollowQueue();
       }
 
       console.log("Waiting before the next cycle...\n\n\n");

src/queues.js

@@ -8,6 +8,7 @@ const pendingFollowBackPath = path.join(
   "../data/pending_follow_back.json"
 );
 const unfollowQueuePath = path.join(__dirname, "../data/unfollow_queue.json");
+const configPath = path.join(__dirname, "../config.json");
 
 // Function to remove users from follow_queue.json if they are present in the followedUsersSet
 async function cleanFollowQueue(followedUsersSet) {
@@ -62,6 +63,85 @@ async function nextInFollowQueue() {
   }
 }
 
+// Function to check if the user's follow back period has expired and move them to unfollow queue
+async function moveExpiredUsersToUnfollowQueue() {
+  try {
+    // Read and parse pending_follow_back.json
+    const pendingFollowBackData = await fs.readFile(
+      pendingFollowBackPath,
+      "utf8"
+    );
+    const pendingFollowBack = JSON.parse(pendingFollowBackData);
+
+    // Read and parse config.json
+    const configData = await fs.readFile(configPath, "utf8");
+    const config = JSON.parse(configData);
+    const pendingFollowBackWaitTimeDays =
+      config.configValues.pendingFollowBackWaitTimeDays;
+
+    // Read or initialize unfollow_queue.json
+    let unfollowQueue = {};
+    try {
+      const unfollowQueueData = await fs.readFile(unfollowQueuePath, "utf8");
+      unfollowQueue = JSON.parse(unfollowQueueData);
+    } catch (error) {
+      console.log("Unfollow queue file not found, starting a new one.");
+    }
+
+    // Get the current date
+    const currentDate = new Date();
+
+    // Loop through pending_follow_back.json and check expiration
+    for (const userId in pendingFollowBack) {
+      if (pendingFollowBack.hasOwnProperty(userId)) {
+        const user = pendingFollowBack[userId];
+
+        // Calculate the expiration date based on the followed_on date
+        const followedOnDate = new Date(user.followed_on);
+        const expirationDate = new Date(followedOnDate);
+        expirationDate.setDate(
+          followedOnDate.getDate() + pendingFollowBackWaitTimeDays
+        );
+
+        // Check if the user has exceeded the expiration date
+        if (currentDate > expirationDate) {
+          console.log(
+            `User ${user.login} exceeded the follow back period, moving to unfollow queue.`
+          );
+
+          // Add the user to the unfollow queue with a timestamp
+          unfollowQueue[user.id] = {
+            ...user,
+            added_to_queue_on: new Date().toISOString(), // Add a timestamp for when the user was added
+          };
+
+          // Remove the user from pending_follow_back.json
+          delete pendingFollowBack[userId];
+        }
+      }
+    }
+
+    // Write the updated unfollow_queue.json
+    await fs.writeFile(
+      unfollowQueuePath,
+      JSON.stringify(unfollowQueue, null, 4),
+      "utf8"
+    );
+    // Write the updated pending_follow_back.json
+    await fs.writeFile(
+      pendingFollowBackPath,
+      JSON.stringify(pendingFollowBack, null, 4),
+      "utf8"
+    );
+
+    console.log(
+      "Users successfully moved to the unfollow queue and pending follow back list updated."
+    );
+  } catch (error) {
+    console.error("Error moving expired users to unfollow queue:", error);
+  }
+}
+
 // Function to return the next user object from the unfollow queue
 async function nextInUnfollowQueue() {
   try {
@@ -196,6 +276,7 @@ module.exports = {
   removeUserFromFollowQueue,
   addUserToPendingFollowBack,
   cleanFollowQueue,
+  moveExpiredUsersToUnfollowQueue,
 };
 // Example usage
 // nextInQueue().then(follower => console.log("Next follower to process:", follower));