diff --git a/wwwroot/core/base/baseTokenManager.js b/wwwroot/core/base/baseTokenManager.js index 8fc43f5..fd45575 100644 --- a/wwwroot/core/base/baseTokenManager.js +++ b/wwwroot/core/base/baseTokenManager.js @@ -44,4 +44,8 @@ export class BaseTokenManager { return this.usersToken.get(index); } + getAllUserData(){ + return this.usersToken.getAll(); + } + } \ No newline at end of file diff --git a/wwwroot/core/instagram/instagramPoller.js b/wwwroot/core/instagram/instagramPoller.js index 2d76718..a00a9dd 100644 --- a/wwwroot/core/instagram/instagramPoller.js +++ b/wwwroot/core/instagram/instagramPoller.js @@ -20,22 +20,21 @@ 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 mediaDetails = await Requester.doGetRequest(detailsUrl); - console.log(mediaDetails); - console.log({permalink : mediaDetails.permalink, userId : userData.userId}); + let mediaId = this.getMediaId(mediaData); + let detailsUrl = this.formatMediaDetailsUrl(mediaId, userData.token); - super.emit("newPost", {permalink : mediaDetails.permalink, userId : userData.userId}); + let mediaDetails = await Requester.doGetRequest(detailsUrl); + + 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) } }