Posthog analytics Integration for iq.wiki backend

src/App/app.module.ts

@@ -66,6 +66,7 @@ import TagRepository from './Tag/tag.repository'
 import EventsService from './Wiki/events.service'
 import AppService from './app.service'
 import WikiController from './Wiki/controllers/wiki.controller'
+import { PosthogModule } from 'nestjs-posthog'
 
 // istanbul ignore next
 @Module({
@@ -93,6 +94,24 @@ import WikiController from './Wiki/controllers/wiki.controller'
         ],
       },
     }),
+    PosthogModule.forRootAsync({
+    imports: [ConfigModule],
+      inject: [ConfigService],
+      useFactory: (configService: ConfigService) => {
+        const apiKey = configService.get<string>('POSTHOG_API_KEY')
+        const host = configService.get<string>('POSTHOG_API_URL')
+        if (!apiKey ||!host) {
+          console.error('Posthog configuration is missing apiKey or host')
+        }
+        return {
+          apiKey: apiKey || '',
+          options: {
+            host,
+          },
+          mock: true,
+        }
+        },
+    }),
     SitemapModule,
     MailerModule,
     httpModule(20000),

src/Relayer/services/relayer.service.ts

@@ -12,6 +12,7 @@ import WikiAbi from '../utils/wiki.abi'
 import USER_ACTIVITY_LIMIT from '../../globalVars'
 import ActivityRepository from '../../App/Activities/activity.repository'
 import AppService from '../../App/app.service'
+import { PosthogService } from 'nestjs-posthog'
 
 @Injectable()
 class RelayerService {
@@ -24,6 +25,7 @@ class RelayerService {
     private configService: ConfigService,
     private httpService: HttpService,
     private activityRepository: ActivityRepository,
+    private posthogService: PosthogService,
   ) {
     this.signer = this.getRelayerInstance()
     this.wikiInstance = this.getWikiContractInstance(this.signer)
@@ -120,40 +122,62 @@ class RelayerService {
     }
 
     let result
-    if (this.appService.apiLevel() !== 'prod') {
-      const txConfig = {
-        gasPrice: ethers.utils.parseUnits('0.7', 'gwei'),
+    try {
+      if (this.appService.apiLevel() !== 'prod') {
+        const txConfig = {
+          gasPrice: ethers.utils.parseUnits('0.7', 'gwei'),
+        }
+        result = await this.wikiInstance.postBySig(
+          ipfs,
+          userAddr,
+          deadline,
+          v,
+          r,
+          s,
+          txConfig,
+        )
+      } else {
+        const gas = await this.getUpdatedGas()
+
+        const txConfig = this.appService.privateSigner()
+          ? {
+              gasPrice: ethers.utils.parseUnits(gas, 'gwei'),
+              gasLimit: 50000,
+            }
+          : {
+              gasLimit: 50000,
+            }
+
+        result = await this.wikiInstance.postBySig(
+          ipfs,
+          userAddr,
+          deadline,
+          v,
+          r,
+          s,
+          txConfig,
+        )
       }
-      result = await this.wikiInstance.postBySig(
-        ipfs,
-        userAddr,
-        deadline,
-        v,
-        r,
-        s,
-        txConfig,
-      )
-    } else {
-      const gas = await this.getUpdatedGas()
-
-      const txConfig = this.appService.privateSigner()
-        ? {
-            gasPrice: ethers.utils.parseUnits(gas, 'gwei'),
-            gasLimit: 50000,
-          }
-        : {
-            gasLimit: 50000,
-          }
-
-      result = await this.wikiInstance.postBySig(
-        ipfs,
-        userAddr,
-        deadline,
-        v,
-        r,
-        s,
-        txConfig,
-      )
+      this.posthogService.capture({
+        distinctId: userAddr,
+        event: 'Successful Transaction',
+        properties: {
+          ipfs,
+          userAddr,
+          result,
+        },
+      })
+    } catch (error) {
+      this.posthogService.capture({
+        distinctId: userAddr,
+        event: 'Failed Transaction',
+        properties: {
+          ipfs,
+          userAddr,
+          error,
+        },
+      })
+      throw error
     }
     return result
   }