Compare commits

...

2 Commits

Author SHA1 Message Date
03fa42e1b7 Fix empty media array bug 2026-03-26 14:33:38 +01:00
d205d96c3d Implement polling for all users 2026-03-26 13:50:01 +01:00
2 changed files with 16 additions and 11 deletions

View File

@@ -44,4 +44,8 @@ export class BaseTokenManager {
return this.usersToken.get(index);
}
getAllUserData(){
return this.usersToken.getAll();
}
}

View File

@@ -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;
}
}