fix: cannot like tweet (#48)

* fix: cannot add tweet

* refactor: add return typ for parTwitterClient.likeTweet

* style: lint fix

api/twitter-webhook-listener.ts

@@ -12,7 +12,6 @@ export default async (
   res: VercelResponse
 ): Promise<VercelResponse> => {
   const method = req.method?.toLowerCase();
-  console.log("method:", method)
   switch (method) {
     case "get": {
       try {

src/par-activity/cache.ts

@@ -1,3 +1,5 @@
+/* eslint @typescript-eslint/no-var-requires: "off" */
+
 import { createNodeRedisClient, WrappedNodeRedisClient } from "handy-redis";
 
 let cache: WrappedNodeRedisClient;

src/par-activity/handle-tweet-create.ts

@@ -37,7 +37,6 @@ export async function handleTweetCreate(
         any of the errors in one place and responds adequately. It also
         kills the whole process on any error, which is what's needed
          */
-        // eslint-disable @typescript-eslint/no-unused-vars
         const [count, engagement, selectionDate, _] = await Promise.all([
           await service.getEngagementCount(mention.cmdText as string),
           await service.getEngagementType(mention.cmdText as string),

src/par-activity/par-twitter-client.ts

@@ -1,5 +1,8 @@
 import Twitter from "twitter-lite";
 import { TwitterEndpoint, ITweet } from ".";
+import request from "request";
+import { promisify } from "util";
+const post = promisify(request.post);
 
 class ParTwitterClient {
   private v1: Twitter;
@@ -9,20 +12,20 @@ class ParTwitterClient {
    * Initialise the parameters for PAR account
    */
   constructor() {
-    const params = {
+    const oauth = {
       consumer_key: process.env.TWITTER_CONSUMER_KEY as string,
       consumer_secret: process.env.TWITTER_CONSUMER_SECRET as string,
       access_token_key: process.env.TWITTER_PAR_ACCESS_TOKEN as string,
       access_token_secret: process.env
         .TWITTER_PAR_ACCESS_TOKEN_SECRET as string,
     };
     this.v1 = new Twitter({
-      ...params,
+      ...oauth,
     });
     this.v2 = new Twitter({
       extension: false,
       version: "2",
-      ...params,
+      ...oauth,
     });
   }
 
@@ -46,25 +49,36 @@ class ParTwitterClient {
       return resp;
     } catch (error) {
       // TODO: handle error via sentry
-      console.error("parTwitterClient.replyMention", error);
+      console.error("parTwitterClient.replyMention", error, null, 2);
     }
   }
 
   /**
    * Like a tweet
    * @param {string} id - The id of the tweet to be liked
    */
-  async likeTweet(id: string) {
-    console.log(id);
+  async likeTweet(id: string): Promise<{ data: { liked: boolean } }> {
     try {
-      const resp = await this.v1.post(`favorites/create.json`, {
-        id
+      const resp = await post({
+        url: `https://api.twitter.com/2/users/${process.env.PICKATRANDOM_USERID}/likes`,
+        oauth: {
+          consumer_key: process.env.TWITTER_CONSUMER_KEY as string,
+          consumer_secret: process.env.TWITTER_CONSUMER_SECRET as string,
+          token: process.env.TWITTER_PAR_ACCESS_TOKEN as string,
+          token_secret: process.env.TWITTER_PAR_ACCESS_TOKEN_SECRET as string,
+        },
+        json: {
+          tweet_id: id,
+        },
       });
-      console.log(resp);
-      return resp;
+      return resp.body;
     } catch (error) {
-      // TODO: handle error via sentry
-      console.error("parTwitterClient.likeTweet", JSON.stringify(error));
+      console.error(
+        // TODO: handle with sentry
+        "parTwitterClient.likeTweet",
+        JSON.stringify(error, null, 2)
+      );
+      return error;
     }
   }
 }