Skip to content

Commit

Permalink
put extractFollowerCount in common and change removeThreads (#296)
Browse files Browse the repository at this point in the history
  • Loading branch information
@HamdiBenK
HamdiBenK committed Jul 26, 2023
2 parents 74a7f7b + 57b0d01 commit d6b8007
Show file tree
Hide file tree
Showing 3 changed files with 112 additions and 134 deletions.
68 changes: 39 additions & 29 deletions controllers/profile.controller.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,8 @@ const {
configureTranslation,
readHTMLFileProfile,
} = require('../helpers/utils')

const {extractFollowerCount} = require('../helpers/common')
const {
verifyYoutube,
verifyFacebook,
Expand Down Expand Up @@ -1153,26 +1155,6 @@ module.exports.ProfilPrivacy = async (req, res) => {
}
}

let extractFollowerCount = str => {
const regex = /(\d+(\.\d+)?)([MK]?)\s*$/;

const match = str.match(regex);

if (match) {
let followerCount = parseFloat(match[1]);

if (match[3] === 'K') {
followerCount *= 1000;
} else if (match[3] === 'M') {
followerCount *= 1000000;
}

return parseInt(followerCount, 10);
}

return 0;
}

module.exports.addThreadsAccount = async (req,res) => {
try {
const instaAccount = await FbPage.findOne({UserId : req.user._id, instagram_username : {$exists : true}});
Expand Down Expand Up @@ -1205,15 +1187,43 @@ module.exports.addThreadsAccount = async (req,res) => {



module.exports.removeThreadsAccount = async (req,res) => {
const instaAccount = await FbPage.findOne({UserId : req.user._id, threads_id: req.params.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,threads_id: req.params.id }, {$unset: {threads_id:1, threads_picture:1,threads_followers:1}})
return makeResponseData(res, 200, 'deleted successfully')
} return makeResponseData(res, 200,'no_threads_found')

}
module.exports.removeThreadsAccount = async (req, res) => {
try {
// Find the instaAccount
const instaAccount = await FbPage.findOne({
UserId: req.user._id,
threads_id: req.params.id,
instagram_username: { $exists: true },
});

// Set the default response data message
let responseDataMessage = 'no_threads_found';

// Check if the instaAccount exists
if (!instaAccount) {
responseDataMessage = 'instagram_not_found';
} else if (instaAccount.threads_id) {
// Check if threads_id exists and update the FbPage document
await FbPage.updateOne(
{
UserId: req.user._id,
threads_id: req.params.id,
},
{ $unset: { threads_id: 1, threads_picture: 1, threads_followers: 1 } }
);
responseDataMessage = 'deleted successfully';
}

return makeResponseData(res, 200, responseDataMessage);
} catch (error) {
// Handle any errors that might occur during the process
return makeResponseError(
res,
500,
err.message ? err.message : err.error
);
}
};



Expand Down
20 changes: 20 additions & 0 deletions helpers/common.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -466,3 +466,23 @@ exports.BalanceUsersStats = async (condition) => {
}
}
}

exports.extractFollowerCount = str => {
const regex = /(\d+(\.\d+)?)([MK]?)\s*$/;

const match = str.match(regex);

if (match) {
let followerCount = parseFloat(match[1]);

if (match[3] === 'K') {
followerCount *= 1000;
} else if (match[3] === 'M') {
followerCount *= 1000000;
}

return parseInt(followerCount, 10);
}

return 0;
}
158 changes: 53 additions & 105 deletions manager/oracles.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@ const {
const puppeteer = require('puppeteer')
const { TronConstant } = require('../conf/const')
const { timeout } = require('../helpers/utils')
const {extractFollowerCount} = require('../helpers/common')
const { TikTokProfile } = require('../model')
const {
getWeb3Connection,
Expand Down Expand Up @@ -147,53 +148,55 @@ exports.verifyInsta = async function (userId, idPost) {



const fetchThreadData = async (res,idPost) => {
if (!isValidIdPost(idPost)) {
throw new Error('Invalid idPost');
}

const text = res.data.replace(/\s/g, '').replace(/\n/g, '');


const postID = text.match(/{"post_id":"(.*?)"}/)?.[1];
const lsdToken = fetchLSDToken(text)

// THIS FUNCTION WILL GIVE US IF ACCOUNT EXIST OR NO ( TO LINK SATT ACCOUNT TO THREAD ACCOUNT )
const headers = {
'Authority': 'www.threads.net',
'Accept': '*/*',
'Accept-Language': 'en-US,en;q=0.9',
'Cache-Control': 'no-cache',
'Content-Type': 'application/x-www-form-urlencoded',
'Origin': 'https://www.threads.net',
'Pragma': 'no-cache',
'Sec-Fetch-Site': 'same-origin',
'X-ASBD-ID': '129477',
'X-FB-LSD': lsdToken,
'X-IG-App-ID': '238260118697367',
};

const response = await axios.post("https://www.threads.net/api/graphql", {
'lsd': lsdToken,
'variables': JSON.stringify({
postID,
}),
'doc_id': '5587632691339264',
}, {
headers, transformRequest: [(data) => {
return Object.entries(data)
.map(([key, value]) => `${encodeURIComponent(key)}=${encodeURIComponent(value)}`)
.join('&');
}],
});
return response
}



exports.verifyThread = async (idPost, threads_id, instagram_username) => {
try {
console.log({idPost, threads_id, instagram_username})
const res = await axios.get(`https://www.threads.net/@${instagram_username}/post/${idPost}`);

if (!isValidIdPost(idPost)) {
throw new Error('Invalid idPost');
}

let text = res.data;
text = text.replace(/\s/g, '');
text = text.replace(/\n/g, '');

var postID = text.match(/{"post_id":"(.*?)"}/)?.[1];
//const lsdToken = text.match(/"LSD",\[\],{"token":"(\w+)"},\d+\]/)?.[1];
const lsdToken = await fetchLSDToken(text);
console.log({postID, lsdToken})
// THIS FUNCTION WILL GIVE US IF ACCOUNT EXIST OR NO ( TO LINK SATT ACCOUNT TO THREAD ACCOUNT )
const headers = {
'Authority': 'www.threads.net',
'Accept': '*/*',
'Accept-Language': 'en-US,en;q=0.9',
'Cache-Control': 'no-cache',
'Content-Type': 'application/x-www-form-urlencoded',
'Origin': 'https://www.threads.net',
'Pragma': 'no-cache',
'Sec-Fetch-Site': 'same-origin',
'X-ASBD-ID': '129477',
'X-FB-LSD': lsdToken,
'X-IG-App-ID': '238260118697367',
};

const response = await axios.post("https://www.threads.net/api/graphql", {
'lsd': lsdToken,
'variables': JSON.stringify({
postID,
}),
'doc_id': '5587632691339264',
}, {
headers, transformRequest: [(data) => {
return Object.entries(data)
.map(([key, value]) => `${encodeURIComponent(key)}=${encodeURIComponent(value)}`)
.join('&');
}],
});
const res = await axios.get(`https://www.threads.net/@${instagram_username}/post/${idPost}`);
const response = await fetchThreadData(res,idPost)

let owner =response.data.data.data.containing_thread.thread_items[0].post.user.pk
return threads_id === owner;
Expand Down Expand Up @@ -535,26 +538,6 @@ exports.tiktokAbos = async (userId, access_token = null) => {
}
}

let extractFollowerCount = str => {
const regex = /(\d+(\.\d+)?)([MK]?)\s*$/;

const match = str.match(regex);

if (match) {
let followerCount = parseFloat(match[1]);

if (match[3] === 'K') {
followerCount *= 1000;
} else if (match[3] === 'M') {
followerCount *= 1000000;
}

return parseInt(followerCount, 10);
}

return 0;
}

const threadsAbos = async (idPost,userName) => {
try {
var campaign_link = await CampaignLink.findOne({ idPost }).lean()
Expand All @@ -567,46 +550,9 @@ const threadsAbos = async (idPost,userName) => {
}

const threads = async idPost => {
const res = await axios.get(`https://www.threads.net/t/${idPost}`);
if (!isValidIdPost(idPost)) {
throw new Error('Invalid idPost');
}

let text = res.data;
text = text.replace(/\s/g, '');
text = text.replace(/\n/g, '');

const postID = text.match(/{"post_id":"(.*?)"}/)?.[1];
const lsdToken = await fetchLSDToken(text)

// THIS FUNCTION WILL GIVE US IF ACCOUNT EXIST OR NO ( TO LINK SATT ACCOUNT TO THREAD ACCOUNT )
const headers = {
'Authority': 'www.threads.net',
'Accept': '*/*',
'Accept-Language': 'en-US,en;q=0.9',
'Cache-Control': 'no-cache',
'Content-Type': 'application/x-www-form-urlencoded',
'Origin': 'https://www.threads.net',
'Pragma': 'no-cache',
'Sec-Fetch-Site': 'same-origin',
'X-ASBD-ID': '129477',
'X-FB-LSD': lsdToken,
'X-IG-App-ID': '238260118697367',
};

const response = await axios.post("https://www.threads.net/api/graphql", {
'lsd': lsdToken,
'variables': JSON.stringify({
postID,
}),
'doc_id': '5587632691339264',
}, {
headers, transformRequest: [(data) => {
return Object.entries(data)
.map(([key, value]) => `${encodeURIComponent(key)}=${encodeURIComponent(value)}`)
.join('&');
}],
});
const res = await axios.get(`https://www.threads.net/t/${idPost}`);
const response = await fetchThreadData(res,idPost);

let media_url;
response.data.data.data.containing_thread.thread_items[0].post?.image_versions2?.candidates.forEach((element) => {
if(element.height == 320 && element.__typename == "XDTImageCandidate") {
Expand Down Expand Up @@ -1186,6 +1132,9 @@ exports.answerOne = async (
var res = await tiktok(tiktokProfile, idPost)

break
case '7':
var res = await threads(idPost)
break
default:
var res = { likes: 0, shares: 0, views: 0, date: Date.now() }
break
Expand Down Expand Up @@ -1471,9 +1420,8 @@ function isValidIdPost(idPost) {
return typeof idPost === 'string' && idPost.trim().length > 0;
}

const fetchLSDToken = async (text) => {
return text.match(/"LSD",\[\],{"token":"(\w+)"},\d+\]/)?.[1];
}
const fetchLSDToken = text => text.match(/"LSD",\[\],{"token":"(\w+)"},\d+\]/)?.[1];




0 comments on commit d6b8007

Please sign in to comment.