updates

Author: michelle0927

components/microsoft_teams/microsoft_teams.app.mjs

@@ -286,7 +286,7 @@ export default {
     },
     async listChatMessages({ chatId }) {
       return this.makeRequest({
-        path: `/chats/${chatId}/messages`,
+        path: `/chats/${chatId}/messages?$orderby=createdDateTime%20desc`,
       });
     },
     async listShifts({ teamId }) {

components/microsoft_teams/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/microsoft_teams",
-  "version": "0.1.6",
+  "version": "0.1.7",
   "description": "Pipedream Microsoft Teams Components",
   "main": "microsoft_teams.app.mjs",
   "keywords": [

components/microsoft_teams/sources/common/base.mjs

@@ -13,27 +13,30 @@ export default {
     },
   },
   methods: {
-    _getLastCreated() {
-      return this.db.get("lastCreated");
+    _getLastDate() {
+      return this.db.get("lastDate");
     },
-    _setLastCreated(lastCreated) {
-      this.db.set("lastCreated", lastCreated);
+    _setLastDate(lastDate) {
+      this.db.set("lastDate", lastDate);
     },
-    isNew(resource, lastCreated) {
-      if (!resource.createdDateTime || !lastCreated) {
+    getTsField() {
+      return "createdDateTime";
+    },
+    isNew(resource, lastDate, tsField) {
+      if (!tsField || !resource[tsField] || !lastDate) {
         return true;
       }
-      return Date.parse(resource.createdDateTime) > lastCreated;
+      return Date.parse(resource[tsField]) > lastDate;
     },
-    async getNewPaginatedResources(fn, params, lastCreated) {
+    async getNewPaginatedResources(fn, params, lastDate, tsField, isSorted = false) {
       const resources = [];
       const paginator = this.paginate(fn, params);
 
       for await (const resource of paginator) {
-        const isNewResource = this.isNew(resource, lastCreated);
+        const isNewResource = this.isNew(resource, lastDate, tsField);
         if (isNewResource) {
           resources.push(resource);
-        } else {
+        } else if (isSorted) {
           break;
         }
       }
@@ -58,18 +61,19 @@ export default {
     },
   },
   async run() {
-    let lastCreated = Date.parse(this._getLastCreated());
+    let lastDate = this._getLastDate();
+    const tsField = this.getTsField();
 
-    const resources = await this.getResources(lastCreated);
+    const resources = await this.getResources(lastDate, tsField);
     for (const resource of resources) {
-      const { createdDateTime } = resource;
-      if (!lastCreated || (createdDateTime && Date.parse(createdDateTime) > lastCreated)) {
-        lastCreated = Date.parse(createdDateTime);
+      const date = resource[tsField];
+      if (!lastDate || (date && Date.parse(date) > lastDate)) {
+        lastDate = Date.parse(date);
       }
       const meta = this.generateMeta(resource);
       this.$emit(resource, meta);
     }
 
-    this._setLastCreated(lastCreated);
+    this._setLastDate(lastDate);
   },
 };

components/microsoft_teams/sources/new-channel-message/new-channel-message.mjs

@@ -4,8 +4,8 @@ export default {
   ...base,
   key: "microsoft_teams-new-channel-message",
   name: "New Channel Message",
-  description: "Emit new event when a new message is posted in a channel",
-  version: "0.0.11",
+  description: "Emit new event when a new message is posted in a channel. [See the documentation](https://learn.microsoft.com/en-us/graph/api/channel-list-messages?view=graph-rest-1.0&tabs=http)",
+  version: "0.0.12",
   type: "source",
   dedupe: "unique",
   props: {
@@ -28,14 +28,19 @@ export default {
   },
   methods: {
     ...base.methods,
-    async getResources(lastCreated) {
+    getTsField() {
+      return "lastModifiedDateTime";
+    },
+    async getResources(lastUpdated, tsField) {
       return this.getNewPaginatedResources(
         this.microsoftTeams.listChannelMessages,
         {
           teamId: this.team,
           channelId: this.channel,
         },
-        lastCreated,
+        lastUpdated,
+        tsField,
+        true, // Sorted by last modified date
       );
     },
     generateMeta(message) {

components/microsoft_teams/sources/new-channel/new-channel.mjs

@@ -4,8 +4,8 @@ export default {
   ...base,
   key: "microsoft_teams-new-channel",
   name: "New Channel",
-  description: "Emit new event when a new channel is created within a team",
-  version: "0.0.11",
+  description: "Emit new event when a new channel is created within a team. [See the documentation](https://learn.microsoft.com/en-us/graph/api/team-list-allchannels?view=graph-rest-1.0&tabs=http)",
+  version: "0.0.12",
   type: "source",
   dedupe: "unique",
   props: {
@@ -19,13 +19,14 @@ export default {
   },
   methods: {
     ...base.methods,
-    async getResources(lastCreated) {
+    async getResources(lastCreated, tsField) {
       return this.getNewPaginatedResources(
         this.microsoftTeams.listChannels,
         {
           teamId: this.team,
         },
         lastCreated,
+        tsField,
       );
     },
     generateMeta(channel) {

components/microsoft_teams/sources/new-chat-message/new-chat-message.mjs

@@ -4,8 +4,8 @@ export default {
   ...base,
   key: "microsoft_teams-new-chat-message",
   name: "New Chat Message",
-  description: "Emit new event when a new message is received in a chat",
-  version: "0.0.11",
+  description: "Emit new event when a new message is received in a chat. [See the documentation](https://learn.microsoft.com/en-us/graph/api/chat-list-messages?view=graph-rest-1.0&tabs=http)",
+  version: "0.0.12",
   type: "source",
   dedupe: "unique",
   props: {
@@ -19,13 +19,15 @@ export default {
   },
   methods: {
     ...base.methods,
-    async getResources(lastCreated) {
+    async getResources(lastCreated, tsField) {
       return this.getNewPaginatedResources(
         this.microsoftTeams.listChatMessages,
         {
           chatId: this.chat,
         },
         lastCreated,
+        tsField,
+        true, // Sorted by creation date
       );
     },
     generateMeta(message) {

components/microsoft_teams/sources/new-chat/new-chat.mjs

@@ -4,17 +4,18 @@ export default {
   ...base,
   key: "microsoft_teams-new-chat",
   name: "New Chat",
-  description: "Emit new event when a new chat is created",
-  version: "0.0.11",
+  description: "Emit new event when a new chat is created. [See the documentation](https://learn.microsoft.com/en-us/graph/api/chat-list?view=graph-rest-1.0&tabs=http)",
+  version: "0.0.12",
   type: "source",
   dedupe: "unique",
   methods: {
     ...base.methods,
-    async getResources(lastCreated) {
+    async getResources(lastCreated, tsField) {
       return this.getNewPaginatedResources(
         this.microsoftTeams.listChats,
         {},
         lastCreated,
+        tsField,
       );
     },
     generateMeta(chat) {

components/microsoft_teams/sources/new-team-member/new-team-member.mjs

@@ -4,8 +4,8 @@ export default {
   ...base,
   key: "microsoft_teams-new-team-member",
   name: "New Team Member",
-  description: "Emit new event when a new member is added to a team",
-  version: "0.0.11",
+  description: "Emit new event when a new member is added to a team. [See the documentation](https://learn.microsoft.com/en-us/graph/api/team-list-members?view=graph-rest-1.0&tabs=http)",
+  version: "0.0.12",
   type: "source",
   dedupe: "unique",
   props: {

components/microsoft_teams/sources/new-team/new-team.mjs

@@ -4,17 +4,18 @@ export default {
   ...base,
   key: "microsoft_teams-new-team",
   name: "New Team",
-  description: "Emit new event when a new team is joined by the authenticated user",
-  version: "0.0.11",
+  description: "Emit new event when a new team is joined by the authenticated user. [See the documentation](https://learn.microsoft.com/en-us/graph/api/user-list-joinedteams?view=graph-rest-1.0&tabs=http)",
+  version: "0.0.12",
   type: "source",
   dedupe: "unique",
   methods: {
     ...base.methods,
-    async getResources(lastCreated) {
+    async getResources(lastCreated, tsField) {
       return this.getNewPaginatedResources(
         this.microsoftTeams.listTeams,
         {},
         lastCreated,
+        tsField,
       );
     },
     generateMeta(team) {