Initial Commit

Author: redianmarku

.gitignore

@@ -0,0 +1,2 @@
+.env
+yarn.lock

config.js

@@ -0,0 +1,6 @@
+module.exports = {
+  consumer_key: "your_consumer_key",
+  consumer_secret: "your_consumer_secret",
+  access_token: "your_api_access_token",
+  access_token_secret: "your_api_access_token_secret",
+};

main.js

@@ -0,0 +1,62 @@
+const Twit = require("twit");
+const config = require("./config");
+
+// Instantiate Twit client with your Twitter API keys
+const T = new Twit(config);
+
+// Set the hashtag and message
+const hashtag = "your hashtag";
+const message = "write your message here...";
+
+// Function to scrape users, send messages, and repeat
+async function scrapeAndSend() {
+  try {
+    // Scrape tweets with the specified hashtag
+    const { data } = await T.get("search/tweets", {
+      q: `#${hashtag}`,
+      count: 20,
+    });
+
+    const users = data.statuses.map((tweet) => ({
+      id: tweet.user.id_str,
+    }));
+
+    // Send messages to the scraped users with a time delay
+    for (let i = 0; i < users.length; i++) {
+      const user = users[i];
+      try {
+        await T.post("direct_messages/events/new", {
+          event: {
+            type: "message_create",
+            message_create: {
+              target: { recipient_id: user.id },
+              message_data: { text: message },
+            },
+          },
+        });
+        console.log(`Message sent to user with ID ${user.id}`);
+
+        // Delay between sending messages
+        const delay = 1 * (60 * 1000); // Delay in milliseconds (e.g., 5000 = 5 seconds)
+        await sleep(delay);
+      } catch (err) {
+        console.error(`Error sending message to user with ID ${user.id}:`);
+      }
+    }
+
+    // Repeat the process after a delay
+    setTimeout(scrapeAndSend, 60000); // Delay in milliseconds (60 seconds = 60000 milliseconds)
+  } catch (err) {
+    console.error("Error retrieving tweets:", err);
+  }
+}
+
+// Utility function for delaying execution
+function sleep(ms) {
+  return new Promise((resolve) => {
+    setTimeout(resolve, ms);
+  });
+}
+
+// Start the process
+scrapeAndSend();