import pkg from 'threads-api';
import fs from 'fs';
const { ThreadsAPI } = pkg;

const threadsAPI = new ThreadsAPI({
  username: 'my_username',
  password: 'my_password',
  deviceID: 'android-2tjieqf5r9w00000'
});

const delay = ms => new Promise(resolve => setTimeout(resolve, ms));

const main = async () => {
  let cursor = null;
  let followers = [];

  const myID = await threadsAPI.getUserIDfromUsername('my_username');

  const { users: myFollowers, next_max_id } = await threadsAPI.getUserFollowers(myID);
  cursor = next_max_id;

  for (const follower of myFollowers.slice(0, 20)) {
    let followerCursor = null;
    let followerFollowers = [];
    do {
      const { users, next_max_id } = await threadsAPI.getUserFollowers(follower.user_id, followerCursor);
      followerFollowers = followerFollowers.concat(users.map(user => user.username));
      followerCursor = next_max_id;

      console.log(`Collected ${followerFollowers.length} followers. Waiting 10 seconds before the next followers request...`);
      await delay(10000);
    } while (followerCursor && followerFollowers.length < 500);

    followers = followers.concat(followerFollowers);
    console.log(`Finished collecting followers for ${follower.username}. Total followers collected: ${followers.length}. Waiting 10 seconds before the next user...`);
    await delay(10000);
  }

  fs.writeFileSync('followers.json', JSON.stringify(followers));
};

main().catch(console.error);