feat: add leafwatch worker (#1765)

apps/web/src/lib/leafwatch.ts

@@ -1,8 +1,6 @@
 import axios from 'axios';
-import { DATADOG_TOKEN, IS_PRODUCTION, LEAFWATCH_HOST } from 'data/constants';
-import { v4 as uuid } from 'uuid';
+import { LEAFWATCH_WORKER_URL } from 'data/constants';
 
-const enabled = DATADOG_TOKEN && IS_PRODUCTION;
 const isBrowser = typeof window !== 'undefined';
 
 /**
@@ -14,21 +12,16 @@ export const Leafwatch = {
       localStorage.getItem('lenster.store') || JSON.stringify({ state: { profileId: null } })
     );
 
-    if (isBrowser && enabled) {
-      axios(LEAFWATCH_HOST, {
+    if (isBrowser) {
+      axios(LEAFWATCH_WORKER_URL, {
         method: 'POST',
-        params: {
-          'dd-api-key': DATADOG_TOKEN,
-          'dd-request-id': uuid()
-        },
         data: {
           event: name,
           metadata,
           profile: state.profileId,
           url: location.href,
           referrer: document.referrer,
-          userAgent: navigator.userAgent,
-          ddsource: 'leafwatch'
+          userAgent: navigator.userAgent
         }
       }).catch(() => {
         console.error('Error while sending analytics event to Leafwatch');

packages/data/constants.ts

@@ -21,10 +21,6 @@ export const LIT_PROTOCOL_ENVIRONMENT = getEnvConfig().litProtocolEnvironment;
 
 export const IS_MAINNET = API_URL === MAINNET_API_URL;
 
-// Leafwatch
-export const DATADOG_TOKEN = process.env.NEXT_PUBLIC_DATADOG_TOKEN ?? '';
-export const LEAFWATCH_HOST = 'https://http-intake.logs.datadoghq.com/api/v2/logs';
-
 // XMTP
 export const XMTP_ENV = IS_MAINNET ? 'production' : 'dev';
 export const XMTP_PREFIX = 'lens.dev/dm';
@@ -67,6 +63,7 @@ export const DEFAULT_OG = `${STATIC_IMAGES_URL}/og/logo.jpeg`;
 export const USER_CONTENT_URL = 'https://user-content.lenster.xyz';
 export const STS_TOKEN_URL = IS_PRODUCTION ? 'https://sts.lenster.xyz' : 'http://localhost:8082';
 export const METADATA_WORKER_URL = IS_PRODUCTION ? 'https://metadata.lenster.xyz' : 'http://localhost:8083';
+export const LEAFWATCH_WORKER_URL = IS_PRODUCTION ? 'https://leafwatch.lenster.xyz' : 'http://localhost:8084';
 
 // Web3
 export const ALCHEMY_KEY = 'HHfOFn8jsYguteTVvL0cz4g9aydrbjTV';

packages/leafwatch-worker/.dev.vars.example

@@ -0,0 +1 @@
+DATADOG_TOKEN=""

packages/leafwatch-worker/.eslintrc.js

@@ -0,0 +1,9 @@
+module.exports = {
+  root: true,
+  extends: ['weblint'],
+  rules: {
+    'import/no-anonymous-default-export': 'off',
+    'import/no-anonymous-default-export': 'off',
+    'no-use-before-define': 'off'
+  }
+};

packages/leafwatch-worker/package.json

@@ -0,0 +1,21 @@
+{
+  "name": "leafwatch-worker",
+  "version": "0.0.0",
+  "private": true,
+  "license": "GPL-3.0",
+  "scripts": {
+    "dev": "wrangler dev --port 8084 --local",
+    "worker:deploy": "wrangler publish",
+    "lint": "eslint . --ext .ts"
+  },
+  "devDependencies": {
+    "@cloudflare/workers-types": "^4.20230115.0",
+    "eslint-config-weblint": "*",
+    "tsconfig": "*",
+    "typescript": "^4.9.5",
+    "wrangler": "2.9.1"
+  },
+  "dependencies": {
+    "@cfworker/uuid": "^1.12.4"
+  }
+}

packages/leafwatch-worker/src/index.ts

@@ -0,0 +1,64 @@
+import { uuid } from '@cfworker/uuid';
+
+type EnvType = {
+  DATADOG_TOKEN: string;
+};
+
+export default {
+  async fetch(request: Request, env: EnvType) {
+    return await handleRequest(request, env);
+  }
+};
+
+const headers = {
+  'Access-Control-Allow-Origin': '*',
+  'Access-Control-Allow-Headers': 'Content-Type',
+  'Content-Type': 'application/json'
+};
+
+const handleRequest = async (request: Request, env: EnvType) => {
+  if (request.method !== 'POST') {
+    return new Response(JSON.stringify({ success: false, message: 'Only POST requests are supported' }), {
+      headers
+    });
+  }
+
+  if (request.headers.get('origin') !== 'https://lenster.xyz') {
+    return new Response(JSON.stringify({ success: false, message: 'Origin not allowed' }), { headers });
+  }
+
+  const payload = await request.json();
+
+  if (!payload) {
+    return new Response(JSON.stringify({ success: false, message: 'No body provided' }), { headers });
+  }
+
+  try {
+    const appenedPayload = {
+      ...payload,
+      ddsource: 'leafwatch',
+      ip: request.headers.get('cf-connecting-ip') || 'unknown'
+    };
+    const datadogRes = await fetch(
+      `https://http-intake.logs.datadoghq.com/api/v2/logs?dd-api-key=${
+        env.DATADOG_TOKEN
+      }&dd-request-id=${uuid()}`,
+      {
+        method: 'POST',
+        headers: { 'content-type': 'application/json' },
+        body: appenedPayload
+      }
+    );
+
+    return new Response(
+      JSON.stringify({
+        success: true,
+        payload: appenedPayload,
+        ddResponse: await datadogRes.json()
+      }),
+      { headers }
+    );
+  } catch {
+    return new Response(JSON.stringify({ success: false, message: 'Something went wrong!' }), { headers });
+  }
+};

packages/leafwatch-worker/tsconfig.json

@@ -0,0 +1,7 @@
+{
+  "extends": "tsconfig/base.json",
+  "compilerOptions": {
+    "baseUrl": ".",
+    "noEmit": true
+  }
+}

packages/leafwatch-worker/wrangler.toml

@@ -0,0 +1,11 @@
+name = "leafwatch-worker"
+main = "src/index.ts"
+compatibility_date = "2023-01-25"
+logpush = true
+routes = [
+	{ pattern = "leafwatch.lenster.xyz", custom_domain = true }
+]
+keep_vars = true
+
+[env.production.vars]
+DATADOG_TOKEN = ""

yarn.lock

@@ -1552,6 +1552,11 @@
     "@babel/helper-validator-identifier" "^7.19.1"
     to-fast-properties "^2.0.0"
 
+"@cfworker/uuid@^1.12.4":
+  version "1.12.4"
+  resolved "https://registry.yarnpkg.com/@cfworker/uuid/-/uuid-1.12.4.tgz#178a2126ce91bfd2fb58c1a14c991502bb69e8ef"
+  integrity sha512-aw4lxCT4NLbGqlTScWPtPrZrg4TO6HCZCnNUAeC4yTOvkXjJGdJP6S5NCY9vtP2FruLIC+vYCvUP98fHXtF7kg==
+
 "@cloudflare/kv-asset-handler@^0.2.0":
   version "0.2.0"
   resolved "https://registry.yarnpkg.com/@cloudflare/kv-asset-handler/-/kv-asset-handler-0.2.0.tgz#c9959bbd7a1c40bd7c674adae98aa8c8d0e5ca68"