|
|
|
|
@ -8,13 +8,15 @@ const |
|
|
|
|
|
|
|
|
|
module.exports = { |
|
|
|
|
getProfile(username, callback){ |
|
|
|
|
request(`${insta}/${username}`,(err, res, body) => { |
|
|
|
|
const link = `${insta}/${username}`; |
|
|
|
|
request(link,(err, res, body) => { |
|
|
|
|
if(res.statusCode === 404) |
|
|
|
|
throw new Error('Instagram user not found'); |
|
|
|
|
body += `<script>document.querySelector('html').innerHTML = JSON.stringify(_sharedData.entry_data.ProfilePage[0].graphql.user)</script>`; |
|
|
|
|
let u; |
|
|
|
|
try { |
|
|
|
|
const user = JSON.parse(parse(body).body.textContent); |
|
|
|
|
callback({ |
|
|
|
|
u = { |
|
|
|
|
id: user['id'], |
|
|
|
|
name: user['full_name'], |
|
|
|
|
pic: user['profile_pic_url_hd'], |
|
|
|
|
@ -26,36 +28,82 @@ module.exports = { |
|
|
|
|
following: user['edge_follow']['count'], |
|
|
|
|
posts: user['edge_owner_to_timeline_media']['count'], |
|
|
|
|
lastPosts: user['edge_owner_to_timeline_media']['edges'] |
|
|
|
|
.map(post => post['node']['shortcode']) |
|
|
|
|
}); |
|
|
|
|
.map(post => post['node']['shortcode']), |
|
|
|
|
link |
|
|
|
|
}; |
|
|
|
|
} catch(e){ throw new Error('Instagram parsing error'); } |
|
|
|
|
callback(u); |
|
|
|
|
}); |
|
|
|
|
}, |
|
|
|
|
getHashtag(hashtag, callback){ |
|
|
|
|
const link = `${insta}/explore/tags/${hashtag}/`; |
|
|
|
|
request(link, (err, res, body) => { |
|
|
|
|
if(res.statusCode === 404) |
|
|
|
|
throw new Error('Instagram hashtag not found'); |
|
|
|
|
body += `<script>document.querySelector('html').innerHTML = JSON.stringify(_sharedData.entry_data.TagPage[0].graphql.hashtag)</script>`; |
|
|
|
|
let h; |
|
|
|
|
try { |
|
|
|
|
const hashtag = JSON.parse(parse(body).body.textContent); |
|
|
|
|
h = { |
|
|
|
|
id: hashtag['id'], |
|
|
|
|
pic: hashtag['profile_pic_url'], |
|
|
|
|
posts: hashtag['edge_hashtag_to_media']['count'], |
|
|
|
|
featuredPosts: hashtag['edge_hashtag_to_top_posts']['edges'] |
|
|
|
|
.map(post => post['node']['shortcode']), |
|
|
|
|
lastPosts: hashtag['edge_hashtag_to_media']['edges'] |
|
|
|
|
.map(post => post['node']['shortcode']), |
|
|
|
|
link |
|
|
|
|
} |
|
|
|
|
} catch(e){ throw new Error('Instagram parsing error'); } |
|
|
|
|
callback(h); |
|
|
|
|
}); |
|
|
|
|
}, |
|
|
|
|
getPost(shortcode, callback){ |
|
|
|
|
request(`${insta}/p/${shortcode}`, (err, res, body) => { |
|
|
|
|
const link = `${insta}/p/${shortcode}`; |
|
|
|
|
request(link, (err, res, body) => { |
|
|
|
|
if(res.statusCode === 404) |
|
|
|
|
throw new Error('Instagram post not found'); |
|
|
|
|
body += `<script>document.querySelector('html').innerHTML = JSON.stringify(_sharedData.entry_data.PostPage[0].graphql.shortcode_media)</script>`; |
|
|
|
|
let p = null; |
|
|
|
|
let p; |
|
|
|
|
try { |
|
|
|
|
const post = JSON.parse(parse(body).body.textContent); |
|
|
|
|
const |
|
|
|
|
post = JSON.parse(parse(body).body.textContent), |
|
|
|
|
caption = post['edge_media_to_caption']['edges'].length > 0 |
|
|
|
|
? post['edge_media_to_caption']['edges'][0]['node']['text'] : null, |
|
|
|
|
username = post['owner']['username'], |
|
|
|
|
hashtagsRegex = /(?<=[\s>])#(\d*[A-Za-z_]+\d*)\b(?!;)/g, |
|
|
|
|
usernamesRegex = /@([A-Za-z0-9_](?:(?:[A-Za-z0-9_]|(?:\\.(?!\\.))){0,28}(?:[A-Za-z0-9_]))?)/g; |
|
|
|
|
p = { |
|
|
|
|
id: post['id'], |
|
|
|
|
timestamp: post['taken_at_timestamp'], |
|
|
|
|
likes: post['edge_media_preview_like']['count'], |
|
|
|
|
comments: post['comments_disabled'] ? -1 : post['edge_media_to_comment']['count'], |
|
|
|
|
caption: post['edge_media_to_caption']['edges'].length > 0 ? post['edge_media_to_caption']['edges'][0]['node']['text'] : null, |
|
|
|
|
comments: post['comments_disabled'] ? null : post['edge_media_to_comment']['edges'] |
|
|
|
|
.map(c => ({ |
|
|
|
|
user: c['node']['owner']['username'], |
|
|
|
|
content: c['node']['text'], |
|
|
|
|
timestamp: c['node']['created_at'], |
|
|
|
|
hashtags: c['node']['text'].match(hashtagsRegex), |
|
|
|
|
mentions: c['node']['text'].match(usernamesRegex), |
|
|
|
|
likes: c['node']['edge_liked_by']['count'] |
|
|
|
|
})), |
|
|
|
|
caption, |
|
|
|
|
hashtags: caption ? caption.match(hashtagsRegex) : null, |
|
|
|
|
mentions: caption ? caption.match(usernamesRegex) : null, |
|
|
|
|
tagged: post['edge_media_to_tagged_user']['edges'] |
|
|
|
|
.map(u => u['node']['user']['username']), |
|
|
|
|
location: post['location'] ? { |
|
|
|
|
name: post['location']['name'], |
|
|
|
|
city: JSON.parse(post['location']['address_json'])['city_name'] |
|
|
|
|
} : null, |
|
|
|
|
author: { |
|
|
|
|
id: post['owner']['id'], |
|
|
|
|
username: post['owner']['username'], |
|
|
|
|
username, |
|
|
|
|
name: post['owner']['full_name'], |
|
|
|
|
pic: post['owner']['profile_pic_url'], |
|
|
|
|
verified: post['owner']['is_verified'] |
|
|
|
|
} |
|
|
|
|
verified: post['owner']['is_verified'], |
|
|
|
|
link: `${insta}/${username}` |
|
|
|
|
}, |
|
|
|
|
link |
|
|
|
|
}; |
|
|
|
|
switch(post['__typename']){ |
|
|
|
|
case 'GraphImage': |
|
|
|
|
@ -79,5 +127,62 @@ module.exports = { |
|
|
|
|
} catch(e){ throw new Error('Instagram parsing error'); } |
|
|
|
|
callback(p); |
|
|
|
|
}); |
|
|
|
|
}, |
|
|
|
|
subscribeUserPosts(username, onPosts, options){ |
|
|
|
|
const interval = options['interval'] || 30; |
|
|
|
|
let lastPost = options['lastPost'] || null; |
|
|
|
|
const checkNewPosts = () => { |
|
|
|
|
module.exports.getProfile(username, profile => { |
|
|
|
|
const _lastPost = profile.lastPosts[0]; |
|
|
|
|
if(_lastPost !== lastPost){ |
|
|
|
|
lastPost = _lastPost; |
|
|
|
|
if(!_lastPost){ |
|
|
|
|
onPosts(lastPost); |
|
|
|
|
setTimeout(checkNewPosts, interval); |
|
|
|
|
} |
|
|
|
|
else { |
|
|
|
|
const posts = []; |
|
|
|
|
for(let i = 0; i < profile.lastPosts.indexOf(lastPost); i++){ |
|
|
|
|
posts.push(profile.lastPosts[i]); |
|
|
|
|
} |
|
|
|
|
onPosts(posts); |
|
|
|
|
setTimeout(checkNewPosts, interval); |
|
|
|
|
} |
|
|
|
|
lastPost = _lastPost; |
|
|
|
|
} |
|
|
|
|
else { |
|
|
|
|
setTimeout(checkNewPosts, interval); |
|
|
|
|
} |
|
|
|
|
}); |
|
|
|
|
}; |
|
|
|
|
checkNewPosts(); |
|
|
|
|
}, |
|
|
|
|
subscribeHashtagPosts(hashtag, onPosts, options){ |
|
|
|
|
const interval = options['interval'] || 30; |
|
|
|
|
let lastPost = options['lastPost'] || null; |
|
|
|
|
const checkNewPosts = () => { |
|
|
|
|
module.exports.getHashtag(hashtag, hashtag => { |
|
|
|
|
const _lastPost = hashtag.lastPosts[0]; |
|
|
|
|
if(_lastPost !== lastPost){ |
|
|
|
|
if(!_lastPost){ |
|
|
|
|
onPosts(lastPost); |
|
|
|
|
setTimeout(checkNewPosts, interval); |
|
|
|
|
} |
|
|
|
|
else { |
|
|
|
|
const posts = []; |
|
|
|
|
for(let i = 0; i < hashtag.lastPosts.indexOf(lastPost); i++){ |
|
|
|
|
posts.push(hashtag.lastPosts[i]); |
|
|
|
|
} |
|
|
|
|
onPosts(posts); |
|
|
|
|
setTimeout(checkNewPosts, interval); |
|
|
|
|
} |
|
|
|
|
lastPost = _lastPost; |
|
|
|
|
} |
|
|
|
|
else { |
|
|
|
|
setTimeout(checkNewPosts, interval); |
|
|
|
|
} |
|
|
|
|
}); |
|
|
|
|
}; |
|
|
|
|
checkNewPosts(); |
|
|
|
|
} |
|
|
|
|
}; |
|
|
|
|
|
