handle invalid idPost

SaTT-Wallet · Jul 17, 2023 · a00bbc0 · a00bbc0
2 parents 166f8d3 + dc34dbb
commit a00bbc0
Show file tree

Hide file tree

Showing 3 changed files with 105 additions and 6 deletions.
diff --git a/controllers/profile.controller.js b/controllers/profile.controller.js
@@ -1,6 +1,7 @@
 var rp = require('axios');
 const validator = require('validator')
 
+
 const {
     User,
     GoogleProfile,
@@ -885,11 +886,12 @@ module.exports.confrimChangeMail = async (req, res) => {
     }
 }
 
-module.exports.checkInsta = async (req, res) => {
+module.exports.checkThreads = async (req, res) => {
  try{
-   let instaAccount = await FbPage.exists({UserId : req.user._id, instagram_username : {$exists : true}});
-   return makeResponseData(res, 201, instaAccount)
-
+   let instaAccount = await FbPage.findOne({UserId : req.user._id, instagram_username : {$exists : true}});
+   if(!instaAccount) return makeResponseData(res, 200,'instagram_not_found')
+   if(instaAccount.threads_id) return makeResponseData(res, 200, 'threads_already_added')
+   return makeResponseData(res, 200, true)
  }catch (err) {
     return makeResponseError(
         res,
@@ -1137,3 +1139,92 @@ module.exports.ProfilPrivacy = async (req, res) => {
         )
     }
 }
+
+
+module.exports.addThreadsAccount = async (req,res) => {
+    try {
+        const instaAccount = await FbPage.findOne({UserId : req.user._id, instagram_username : {$exists : true}});
+        if(!instaAccount) return makeResponseData(res, 200,'instagram_not_found')
+        if(instaAccount.threads_id) return makeResponseData(res, 200,'threads_already_added')
+        const user = await axios.get(`https://www.threads.net/@${instaAccount.instagram_username}`);
+        let text = user.data.replace(/\s/g, '').replace(/\s/g, '');
+        const userID = text.match(/"user_id":"(\d+)"/)?.[1]
+        if(!userID) return makeResponseData(res, 200,'threads_not_found')
+        const lsdToken = await getLsdToken(text)
+        const currentUser = await fetchUserThreadData(lsdToken, userID);
+        if(currentUser) {
+            const userPicture = await axios.get(currentUser.profile_pic_url, { responseType: 'arraybuffer' })
+            const base64String = Buffer.from(userPicture.data, 'binary').toString('base64');
+            await FbPage.updateOne({
+                instagram_username: instaAccount.instagram_username,
+
+            }, {threads_id: currentUser.pk, threads_picture: base64String ? base64String : currentUser.profile_pic_url})
+            return makeResponseData(res, 200, 'threads_account_added', {username: instaAccount.instagram_username, picture: base64String ? base64String : currentUser.profile_pic_url, id: currentUser.pk})
+        } 
+        return makeResponseData(res, 200, 'error')
+    } catch(err) {
+        return makeResponseError(
+            res,
+            500,
+            err.message ? err.message : err.error
+        )
+    }
+}
+
+
+
+module.exports.removeThreadsAccount = async (req,res) => {
+    const instaAccount = await FbPage.findOne({UserId : req.user._id, instagram_username : {$exists : true}});
+    if(!instaAccount) return makeResponseData(res, 200,'instagram_not_found')
+    if(instaAccount.threads_id) {
+        await FbPage.updateOne({ UserId: req.user._id }, {$unset: {threads_id:1, threads_picture:1}})
+        return makeResponseData(res, 200, 'deleted successfully')
+    } return makeResponseData(res, 200,'no_threads_found')
+
+}
+
+
+
+
+
+
+
+
+
+const getLsdToken = async (text) => {
+    const lsdTokenMatch = text.match(/"LSD",\[\],{"token":"(\w+)"},\d+\]/)?.[1];
+    return lsdTokenMatch;
+};
+
+const fetchUserThreadData = async (token, userID) => {
+  const data = {
+    lsd: token,
+    variables: `{"userID": ${userID}}`,
+    doc_id: '23996318473300828',
+  };
+
+  const headers = {
+    'Content-Type': 'application/x-www-form-urlencoded',
+    'Cache-Control': 'no-cache',
+    'Pragma': 'no-cache',
+    'X-ASBD-ID': '129477',
+    'X-FB-LSD': token,
+    'X-IG-App-ID': '5587632691339264',
+  };
+
+  const response = await axios.post(
+    'https://www.threads.net/api/graphql',
+    data,
+    {
+      headers: headers,
+      transformRequest: [(data) => {
+        return Object.entries(data)
+          .map(([key, value]) => `${encodeURIComponent(key)}=${encodeURIComponent(value)}`)
+          .join('&');
+      }],
+    }
+    );
+
+    const user = response?.data?.data?.userData?.user
+    return user;
+}
diff --git a/model/fbPage.model.js b/model/fbPage.model.js
@@ -6,6 +6,7 @@ const fbPageSchema = mongoose.Schema(
         id: { type: String },
         instagram_id: { type: String },
         threads_id : String,
+        threads_picture : String,
         instagram_username: { type: String },
         name: { type: String },
         picture: { type: String },

diff --git a/routes/profile.routes.js b/routes/profile.routes.js
@@ -78,7 +78,9 @@ const {
     ShareByActivity,
     tiktokApiAbos,
     ProfilPrivacy,
-    checkInsta
+    checkThreads,
+    addThreadsAccount,
+    removeThreadsAccount
 } = require('../controllers/profile.controller')
 const {
     addFacebookChannel,
@@ -1394,6 +1396,11 @@ router.get('/linkedin/ShareByActivity/:activity', verifyAuth, ShareByActivityVal
 router.get('/Tiktok/ProfilPrivacy', verifyAuth, ProfilPrivacy)
 
 
-router.get('/check/insta',verifyAuth,checkInsta)
+router.get('/check/threads-account',verifyAuth,checkThreads)
+
+router.get('/add/threads-account', verifyAuth, addThreadsAccount)
+
+router.delete('/remove/threads-account', verifyAuth, removeThreadsAccount)
+
 
 module.exports = router