|
|
|
|
@@ -20,22 +20,22 @@ export class InstagramPoller extends BasePoller {
|
|
|
|
|
|
|
|
|
|
async pollOnce(){
|
|
|
|
|
try{
|
|
|
|
|
let userData = this.tokenManager .getUserData(0);
|
|
|
|
|
let postListUrl = this.formatPostListUrl(userData.userId, userData.token);
|
|
|
|
|
for (const userData of this.tokenManager.getAllUserData()) {
|
|
|
|
|
let postListUrl= this.formatPostListUrl(userData.userId, userData.token);
|
|
|
|
|
|
|
|
|
|
let mediaData = await Requester.doGetRequest(postListUrl);
|
|
|
|
|
console.log(mediaData);
|
|
|
|
|
let mediaId = this.getMediaId(mediaData);
|
|
|
|
|
let detailsUrl = this.formatMediaDetailsUrl(mediaId, userData.token);
|
|
|
|
|
let mediaData = await Requester.doGetRequest(postListUrl);
|
|
|
|
|
let mediaId = this.getMediaId(mediaData);
|
|
|
|
|
if(mediaId == null) continue;
|
|
|
|
|
|
|
|
|
|
let mediaDetails = await Requester.doGetRequest(detailsUrl);
|
|
|
|
|
console.log(mediaDetails);
|
|
|
|
|
console.log({permalink : mediaDetails.permalink, userId : userData.userId});
|
|
|
|
|
let detailsUrl = this.formatMediaDetailsUrl(mediaId, userData.token);
|
|
|
|
|
|
|
|
|
|
super.emit("newPost", {permalink : mediaDetails.permalink, userId : userData.userId});
|
|
|
|
|
let mediaDetails = await Requester.doGetRequest(detailsUrl);
|
|
|
|
|
console.log(mediaDetails);
|
|
|
|
|
super.emit("newPost", {permalink : mediaDetails.permalink, userId : userData.userId});
|
|
|
|
|
}
|
|
|
|
|
} catch(err) {
|
|
|
|
|
console.error(err);
|
|
|
|
|
await Logger.error(`Unbale to fetch instagram content for`, err)
|
|
|
|
|
await Logger.error(`Unable to fetch instagram content for`, err)
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@@ -48,6 +48,7 @@ export class InstagramPoller extends BasePoller {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
getMediaId(mediaData){
|
|
|
|
|
if(mediaData.data.length === 0) return null;
|
|
|
|
|
return mediaData.data[0].id;
|
|
|
|
|
}
|
|
|
|
|
}
|