feat: add lens bulk collection trigger

Author: marian2js

libs/definitions/src/integration-definitions/lens/lens.definition.ts

@@ -8,6 +8,7 @@ import { GetDefaultProfileAction } from './actions/get-default-profile.action'
 import { GetPublicationAction } from './actions/get-publication.action'
 import { LikePostAction } from './actions/like-post.action'
 import { refreshLensAccessToken } from './lens.common'
+import { NewCollectionBulkTrigger } from './triggers/new-collection-bulk.trigger'
 import { NewCollectionTrigger } from './triggers/new-collection.trigger'
 import { NewFollowerBulkTrigger } from './triggers/new-follower-bulk.trigger'
 import { NewFollowerTrigger } from './triggers/new-follower.trigger'
@@ -22,6 +23,7 @@ export class LensDefinition extends SingleIntegrationDefinition {
 
   triggers = [
     new NewCollectionTrigger(),
+    new NewCollectionBulkTrigger(),
     new NewFollowerTrigger(),
     new NewFollowerBulkTrigger(),
     new NewMentionChainJetBotTrigger(),

libs/definitions/src/integration-definitions/lens/triggers/new-collection-bulk.trigger.ts

@@ -0,0 +1,71 @@
+import { RunResponse } from '@app/definitions/definition'
+import { OperationTrigger } from '@app/definitions/operation-trigger'
+import { OperationRunOptions } from 'apps/runner/src/services/operation-runner.service'
+import { JSONSchema7 } from 'json-schema'
+
+export class NewCollectionBulkTrigger extends OperationTrigger {
+  idKey = 'items[].address'
+  key = 'newCollectionBulk'
+  name = 'New Collection (Bulk)'
+  description = 'Triggers when someone collects one of your posts or comments'
+  version = '1.0.0'
+  skipAuth = true
+  unlisted = true
+
+  inputs: JSONSchema7 = {
+    required: ['publicationId'],
+    properties: {
+      publicationId: {
+        title: 'Publication ID',
+        type: 'string',
+        description:
+          'The ID of the post or comment to watch for collections. If empty, it will trigger on any collection.',
+      },
+    },
+  }
+  outputs: JSONSchema7 = {
+    properties: {
+      address: {
+        type: 'string',
+      },
+      defaultProfile: {
+        type: 'object',
+        properties: {
+          id: {
+            type: 'string',
+          },
+          handle: {
+            type: 'string',
+          },
+        },
+      },
+    },
+  }
+
+  async run({ inputs, fetchAll }: OperationRunOptions): Promise<RunResponse | null> {
+    const { publicationId } = inputs
+    const collections = fetchAll ? await this.fetchAll(publicationId) : await this.fetchLatest(publicationId)
+    return {
+      outputs: {
+        items: collections,
+      },
+    }
+  }
+
+  async fetchLatest(publicationId: string) {
+    const url = `https://api.apireum.com/v1/lens/posts/${publicationId}/collections?key=${process.env.APIREUM_API_KEY}`
+    const res = await fetch(url)
+    const data = await res.json()
+    return data.collections
+  }
+
+  async fetchAll(publicationId: string, cursor = '') {
+    const url = `https://api.apireum.com/v1/lens/posts/${publicationId}/collections?key=${process.env.APIREUM_API_KEY}&limit=50&cursor=${cursor}`
+    const res = await fetch(url)
+    const data = await res.json()
+    if (data.collections && data.collections.length >= 50) {
+      return [...data.collections, ...(await this.fetchAll(publicationId, data.cursor))]
+    }
+    return data.collections ? data.collections : []
+  }
+}