update acessToken (#174)

SaTT-Wallet · May 15, 2023 · 265a9fc · 265a9fc
2 parents e0cad3a + c990a1a
commit 265a9fc
Showing 1 changed file with 21 additions and 9 deletions.
diff --git a/manager/oracles.js b/manager/oracles.js
@@ -472,18 +472,29 @@ exports.tiktokAbos = async (userId, access_token = null) => {
                 { userId: +userId },
                 { accessToken: 1 }
             ).lean()
-        ).accessToken
+        ).accessToken   
 
     try {
-        function runCmd(cmd) {
-            var resp = child_process.execSync(cmd)
-            var result = resp.toString('UTF8')
-            return result
+
+         /*const runCmd = cmd => {
+            let resp = child_process.execSync(cmd)
+            return resp.toString('UTF8')
         }
         var cmd = `curl -L -X GET 'https://open.tiktokapis.com/v2/user/info/?fields=follower_count' \
         -H 'Authorization: Bearer ${accessToken}'`
-        var result = JSON.parse(runCmd(cmd))
-        return result?.data?.user?.follower_count ?? 0
+        var result = JSON.parse(runCmd(cmd))*/
+
+        const result = await axios.get('https://open.tiktokapis.com/v2/user/info', {
+            params: {
+              fields: 'follower_count',
+            },
+            headers: {
+              Authorization: `Bearer ${accessToken}`,
+            },
+          });
+
+
+        return result?.data?.data?.user?.follower_count ?? 0
     } catch (err) {
         console.error('tiktokAbos', err.message ? err.message : err.error)
     }
@@ -751,10 +762,11 @@ const tiktok = async (tiktokProfile, idPost) => {
         if (!tiktokProfile) return 'indisponible'
 
         let getUrl = `https://open-api.tiktok.com/oauth/refresh_token?client_key=${process.env.TIKTOK_KEY}&grant_type=refresh_token&refresh_token=${tiktokProfile.refreshToken}`
-        let resMedia = (await rp.get(getUrl)).data
+        let resMedia = await rp.get(getUrl)
+        resMedia?.data?.data?.access_token && await TikTokProfile.updateOne({_id:tiktokProfile._id},{accessToken : resMedia?.data?.data.access_token})
         let videoInfoResponse = await axios
             .post('https://open-api.tiktok.com/video/query/', {
-                access_token: resMedia?.data.access_token,
+                access_token: resMedia?.data?.data.access_token,
                 open_id: tiktokProfile.userTiktokId,
                 filters: {
                     video_ids: [idPost],