Raindrop.io - New Tag Added to Bookmark (#19863)

michelle0927 · web-flow · commit a2b40fa92d68 · 2026-01-28T13:06:18.000-05:00
* new-tag-added-to-bookmark source

* versions
diff --git a/components/raindrop/actions/create-collection/create-collection.mjs b/components/raindrop/actions/create-collection/create-collection.mjs
@@ -4,7 +4,7 @@ export default {
   key: "raindrop-create-collection",
   name: "Create New Collection",
   description: "Creates an additional collection. [See the docs here](https://developer.raindrop.io/v1/collections/methods#create-collection)",
-  version: "0.0.5",
+  version: "0.0.6",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/raindrop/actions/delete-bookmark/delete-bookmark.mjs b/components/raindrop/actions/delete-bookmark/delete-bookmark.mjs
@@ -4,7 +4,7 @@ export default {
   key: "raindrop-delete-bookmark",
   name: "Delete Bookmark",
   description: "Delete a bookmark. [See the docs here](https://developer.raindrop.io/v1/raindrops/single#remove-raindrop)",
-  version: "0.0.5",
+  version: "0.0.6",
   annotations: {
     destructiveHint: true,
     openWorldHint: true,
diff --git a/components/raindrop/actions/delete-collection/delete-collection.mjs b/components/raindrop/actions/delete-collection/delete-collection.mjs
@@ -4,7 +4,7 @@ export default {
   key: "raindrop-delete-collection",
   name: "Delete Collection",
   description: "Delete a collection. [See the docs here](https://developer.raindrop.io/v1/collections/methods#remove-collection)",
-  version: "0.0.5",
+  version: "0.0.6",
   annotations: {
     destructiveHint: true,
     openWorldHint: true,
diff --git a/components/raindrop/actions/get-bookmark/get-bookmark.mjs b/components/raindrop/actions/get-bookmark/get-bookmark.mjs
@@ -4,7 +4,7 @@ export default {
   key: "raindrop-get-bookmark",
   name: "Get Bookmark",
   description: "Retrieve bookmark detailed information by given ID. [See the docs here](https://developer.raindrop.io/v1/raindrops/single#get-raindrop)",
-  version: "0.0.5",
+  version: "0.0.6",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/raindrop/actions/get-collection/get-collection.mjs b/components/raindrop/actions/get-collection/get-collection.mjs
@@ -4,7 +4,7 @@ export default {
   key: "raindrop-get-collection",
   name: "Get Collection",
   description: "Get collection. [See the docs here](https://developer.raindrop.io/v1/collections/methods#get-collection)",
-  version: "0.0.5",
+  version: "0.0.6",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/raindrop/actions/list-collections/list-collections.mjs b/components/raindrop/actions/list-collections/list-collections.mjs
@@ -4,7 +4,7 @@ export default {
   key: "raindrop-list-collections",
   name: "Retrieve All Collections",
   description: "Retrieves all collections. [See the docs here](https://developer.raindrop.io/v1/collections/methods#get-root-collections)",
-  version: "0.0.5",
+  version: "0.0.6",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/raindrop/actions/parse-bookmark-file/parse-bookmark-file.mjs b/components/raindrop/actions/parse-bookmark-file/parse-bookmark-file.mjs
@@ -6,7 +6,7 @@ export default {
   key: "raindrop-parse-bookmark-file",
   name: "Parse HTML Bookmark File",
   description: "Convert an HTML bookmark file to JSON. Supports Nestcape, Pocket and Instapaper file formats. [See the documentation](https://developer.raindrop.io/v1/import#parse-html-import-file)",
-  version: "1.0.2",
+  version: "1.0.3",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/raindrop/actions/retrieve-bookmarks/retrieve-bookmarks.mjs b/components/raindrop/actions/retrieve-bookmarks/retrieve-bookmarks.mjs
@@ -5,7 +5,7 @@ export default {
   key: "raindrop-retrieve-bookmarks",
   name: "Retrieve Bookmarks from Collection",
   description: "Retrieves all bookmarks from the specified collection. [See docs](https://developer.raindrop.io/v1/raindrops/multiple)",
-  version: "0.2.3",
+  version: "0.2.4",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/raindrop/actions/save/save.mjs b/components/raindrop/actions/save/save.mjs
@@ -4,7 +4,7 @@ export default {
   key: "raindrop-save",
   name: "Save to Raindrop Collection",
   description: "Receive a link and save it into a specified collection. [See docs](https://developer.raindrop.io/v1/raindrops/single)",
-  version: "1.2.3",
+  version: "1.2.4",
   annotations: {
     destructiveHint: false,
     openWorldHint: true,
diff --git a/components/raindrop/actions/update-bookmark/update-bookmark.mjs b/components/raindrop/actions/update-bookmark/update-bookmark.mjs
@@ -4,7 +4,7 @@ export default {
   key: "raindrop-update-bookmark",
   name: "Update Bookmark",
   description: "Update an existing bookmark. [See the docs here](https://developer.raindrop.io/v1/raindrops/single#update-raindrop)",
-  version: "0.0.5",
+  version: "0.0.6",
   annotations: {
     destructiveHint: true,
     openWorldHint: true,
diff --git a/components/raindrop/actions/update-collection/update-collection.mjs b/components/raindrop/actions/update-collection/update-collection.mjs
@@ -4,7 +4,7 @@ export default {
   key: "raindrop-update-collection",
   name: "Update Collection",
   description: "Update an existing collection. [See the docs here](https://developer.raindrop.io/v1/collections/methods#update-collection)",
-  version: "0.0.5",
+  version: "0.0.6",
   annotations: {
     destructiveHint: true,
     openWorldHint: true,
diff --git a/components/raindrop/package.json b/components/raindrop/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/raindrop",
-  "version": "0.4.2",
+  "version": "0.5.0",
   "description": "Pipedream Raindrop.io Components",
   "main": "raindrop.app.mjs",
   "keywords": [
diff --git a/components/raindrop/raindrop.app.mjs b/components/raindrop/raindrop.app.mjs
@@ -55,6 +55,15 @@ export default {
         };
       },
     },
+    tags: {
+      type: "string[]",
+      label: "Tags",
+      description: "Emit events when the specified tags are added to a bookmark",
+      async options({ collectionId }) {
+        const { items } = await this.getTags(this, collectionId);
+        return items?.map(({ _id: id }) => id) || [];
+      },
+    },
     expanded: {
       type: "boolean",
       label: "Expanded",
@@ -162,6 +171,11 @@ export default {
         params,
       });
     },
+    async getTags($, collectionId) {
+      return this._makeRequest($, {
+        path: `/tags/${collectionId}`,
+      });
+    },
     async postBookmark($, bookmarkData) {
       return this._makeRequest($, {
         method: "POST",
diff --git a/components/raindrop/sources/common/base-polling.mjs b/components/raindrop/sources/common/base-polling.mjs
@@ -0,0 +1,21 @@
+import raindrop from "../../raindrop.app.mjs";
+import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";
+
+export default {
+  props: {
+    raindrop,
+    db: "$.service.db",
+    timer: {
+      type: "$.interface.timer",
+      default: {
+        intervalSeconds: DEFAULT_POLLING_SOURCE_TIMER_INTERVAL,
+      },
+    },
+    collectionId: {
+      propDefinition: [
+        raindrop,
+        "collectionId",
+      ],
+    },
+  },
+};
diff --git a/components/raindrop/sources/new-bookmark/new-bookmark.mjs b/components/raindrop/sources/new-bookmark/new-bookmark.mjs
@@ -1,30 +1,14 @@
-import raindrop from "../../raindrop.app.mjs";
+import common from "../common/base-polling.mjs";
 import constants from "../../common/constants.mjs";
-import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";
 
 export default {
+  ...common,
   key: "raindrop-new-bookmark",
   name: "New Bookmark",
   description: "Emit new event when a bookmark is added",
   type: "source",
-  version: "0.0.6",
+  version: "0.0.7",
   dedupe: "unique",
-  props: {
-    raindrop,
-    db: "$.service.db",
-    timer: {
-      type: "$.interface.timer",
-      default: {
-        intervalSeconds: DEFAULT_POLLING_SOURCE_TIMER_INTERVAL,
-      },
-    },
-    collectionId: {
-      propDefinition: [
-        raindrop,
-        "collectionId",
-      ],
-    },
-  },
   methods: {
     _getPage() {
       return this.db.get("page") ?? 0;
diff --git a/components/raindrop/sources/new-tag-added-to-bookmark/new-tag-added-to-bookmark.mjs b/components/raindrop/sources/new-tag-added-to-bookmark/new-tag-added-to-bookmark.mjs
@@ -0,0 +1,108 @@
+import common from "../common/base-polling.mjs";
+import constants from "../../common/constants.mjs";
+
+export default {
+  ...common,
+  key: "raindrop-new-tag-added-to-bookmark",
+  name: "New Tag Added to Bookmark",
+  description: "Emit new event when a tag is added to a bookmark",
+  version: "0.0.1",
+  dedupe: "unique",
+  type: "source",
+  props: {
+    ...common.props,
+    tags: {
+      propDefinition: [
+        common.props.raindrop,
+        "tags",
+        (c) => ({
+          collectionId: c.collectionId,
+        }),
+      ],
+    },
+  },
+  hooks: {
+    async deploy() {
+      let maxLastUpdated = 0;
+      const previousTagAssignments = {};
+      this.tags.forEach((tag) => {
+        previousTagAssignments[tag] = {};
+      });
+      for await (const bookmark of this.getRecentlyUpdatedBookmarks(maxLastUpdated)) {
+        this.tags.forEach((tag) => {
+          if (bookmark.tags.includes(tag)) {
+            previousTagAssignments[tag][bookmark._id] = true;
+          }
+        });
+        maxLastUpdated = Math.max(maxLastUpdated, Date.parse(bookmark.lastUpdate));
+      }
+      this._setPreviousTagAssignments(previousTagAssignments);
+      this._setLastUpdated(maxLastUpdated);
+    },
+  },
+  methods: {
+    _getLastUpdated() {
+      return this.db.get("lastUpdated");
+    },
+    _setLastUpdated(lastUpdated) {
+      this.db.set("lastUpdated", lastUpdated);
+    },
+    _getPreviousTagAssignments() {
+      return this.db.get("previousTagAssignments");
+    },
+    _setPreviousTagAssignments(previousTagAssignments) {
+      this.db.set("previousTagAssignments", previousTagAssignments);
+    },
+    getSearchQuery(tags) {
+      return `${tags.map((s) => `#"${s}"`).join(" ")} match:OR`;
+    },
+    async *getRecentlyUpdatedBookmarks(lastUpdated) {
+      const params = {
+        page: 0,
+        perpage: constants.DEFAULT_PER_PAGE,
+        search: this.getSearchQuery(this.tags),
+      };
+      while (true) {
+        const { items } = await this.raindrop.getRaindrops(this, this.collectionId, params);
+        for (const bookmark of items) {
+          if (Date.parse(bookmark.lastUpdate) > lastUpdated) {
+            yield bookmark;
+          }
+        }
+        if (items.length < constants.DEFAULT_PER_PAGE) break;
+        params.page++;
+      }
+    },
+    generateMeta(bookmark, tag) {
+      const ts = Date.parse(bookmark.lastUpdate);
+      return {
+        id: `${bookmark._id}-${tag}-${ts}`,
+        summary: `Tag "${tag}" added to bookmark ${bookmark._id}`,
+        ts,
+      };
+    },
+  },
+  async run() {
+    const lastUpdated = this._getLastUpdated();
+    let maxLastUpdated = lastUpdated;
+    const previousTagAssignments = this._getPreviousTagAssignments();
+
+    for await (const bookmark of this.getRecentlyUpdatedBookmarks(lastUpdated)) {
+      this.tags.forEach((tag) => {
+        if (bookmark.tags.includes(tag)) {
+          if (!previousTagAssignments[tag][bookmark._id]) {
+            this.$emit(bookmark, this.generateMeta(bookmark, tag));
+            previousTagAssignments[tag][bookmark._id] = true;
+          }
+        } else {
+          if (previousTagAssignments[tag][bookmark._id]) {
+            delete previousTagAssignments[tag][bookmark._id];
+          }
+        }
+      });
+      this._setPreviousTagAssignments(previousTagAssignments);
+      maxLastUpdated = Math.max(maxLastUpdated, Date.parse(bookmark.lastUpdate));
+    }
+    this._setLastUpdated(maxLastUpdated);
+  },
+};
