New lens group ID search for creators

Author: ptrumpis

src/endpoints/explorer/search.js

@@ -3,6 +3,7 @@ import { Config } from '../../utils/config.js';
 import * as Cache from '../../utils/cache.js';
 import * as Util from '../../utils/helper.js';
 import * as Web from '../../utils/web.js';
+import * as Creator from '../../utils/creator.js';
 
 const useRelay = Config.app.relay.server;
 const useWebSource = Config.app.flag.enable_web_source;
@@ -20,6 +21,16 @@ router.post('/', async function (req, res, next) {
         return res.json({ "lenses": [] });
     }
 
+    if (Util.isGroupId(searchTerm)) {
+        const groupLenses = await Creator.getLensGroup(searchTerm);
+        if (Array.isArray(groupLenses) && groupLenses.length) {
+            for (const lens of groupLenses) {
+                Cache.Search.set(lens.lens_id, lens);
+            }
+            return res.json({ "lenses": groupLenses });
+        }
+    }
+
     let searchResults = await Util.advancedSearch(searchTerm);
     if (searchResults && searchResults.length) {
         searchResults = Util.modifyResponseURLs(searchResults);

src/utils/creator.js

@@ -0,0 +1,45 @@
+import { BridgeError, CameraKitClient, DataMessage, ErrorMessage } from "@ptrumpis/snap-camerakit-bridge";
+import * as dotenv from 'dotenv';
+
+dotenv.config();
+
+const bridgeAddr = process.env.BRIDGE_ADDR;
+const apiToken = process.env.BRIDGE_API_TOKEN;
+let isInitialized = false;
+
+const client = (bridgeAddr) ? new CameraKitClient(bridgeAddr) : null;
+
+async function getLensGroup(groupId) {
+    try {
+        if (!client) {
+            throw new Error('You need to edit your .env file and set BRIDGE_ADDR');
+        }
+
+        if (!apiToken) {
+            throw new Error('You need to edit your .env file and set BRIDGE_API_TOKEN');
+        }
+
+        let message = null;
+        if (!isInitialized) {
+            message = await client.init(apiToken);
+            if (message instanceof ErrorMessage) {
+                throw BridgeError.fromJSON(message.error)
+            } else if (message instanceof DataMessage) {
+                isInitialized = (message.data) ? true : false;
+            }
+        }
+
+        message = await client.getLensGroup(groupId);
+        if (message instanceof ErrorMessage) {
+            throw BridgeError.fromJSON(message.error)
+        } else if (message instanceof DataMessage) {
+            return message.data;
+        }
+    } catch (e) {
+        console.error(`[Error] Failed to get lens group: ${e.message}`);
+    }
+
+    return [];
+}
+
+export { getLensGroup };

src/utils/helper.js

@@ -182,6 +182,11 @@ function isLensId(str) {
     return id.test(str);
 }
 
+function isGroupId(str) {
+    var regex = /^[a-f0-9]{8}-[a-f0-9]{4}-[a-f0-9]{4}-[a-f0-9]{4}-[a-f0-9]{12}$/i;
+    return regex.test(str);
+  }
+
 function isUrl(url) {
     try {
         new URL(url);
@@ -205,4 +210,4 @@ function sleep(ms) {
     });
 }
 
-export { advancedSearch, relayRequest, getUnlockFromRelay, mirrorSearchResults, downloadLens, downloadUnlock, mergeLensesUnique, parseLensUuid, parseLensUuidFromShareUrl, isLensUuid, isLensId, isUrl, modifyResponseURLs, sleep };
+export { advancedSearch, relayRequest, getUnlockFromRelay, mirrorSearchResults, downloadLens, downloadUnlock, mergeLensesUnique, parseLensUuid, parseLensUuidFromShareUrl, isLensUuid, isLensId, isGroupId, isUrl, modifyResponseURLs, sleep };