[Indexer] Active Subscriber Counter: implement cached subscriber coun…

index.js

@@ -1,6 +1,7 @@
 const express = require('express');
 const cors = require('cors');
 const dotenv = require('dotenv');
+require('dotenv').config();
 dotenv.config();
 
 const { AppDatabase } = require('./src/db/appDatabase');
@@ -10,6 +11,7 @@ const { CreatorActionService } = require('./src/services/creatorActionService');
 const { CreatorAuditLogService } = require('./src/services/creatorAuditLogService');
 const { CreatorAuthService } = require('./src/services/creatorAuthService');
 const { SorobanSubscriptionVerifier } = require('./src/services/sorobanSubscriptionVerifier');
+const { SubscriptionService } = require('./src/services/subscriptionService');
 const VideoProcessingWorker = require('./src/services/videoProcessingWorker');
 const createVideoRoutes = require('./routes/video');
 const { buildAuditLogCsv } = require('./src/utils/export/auditLogCsv');
@@ -33,10 +35,17 @@ function createApp(dependencies = {}) {
   const subscriptionVerifier =
     dependencies.subscriptionVerifier || new SorobanSubscriptionVerifier(config);
   const tokenService = dependencies.tokenService || new CdnTokenService(config);
+  const subscriptionService =
+    dependencies.subscriptionService || new SubscriptionService({ database, auditLogService });
+
+  // expose the service on the express app so external routers can access it
+  app.set('subscriptionService', subscriptionService);
   const videoWorker = dependencies.videoWorker || new VideoProcessingWorker(config, database);
 
   app.use(cors());
   app.use(express.json());
+  // Subscription events webhook
+  app.use('/api/subscription', require('./routes/subscription'));
 
   app.use((req, res, next) => {
     req.config = config;
@@ -212,6 +221,18 @@ function createApp(dependencies = {}) {
     return res.status(200).json({ success: true, data: logs });
   });
 
+  // Get creator stats (including cached subscriber count)
+  app.get('/api/creator/:id/stats', (req, res) => {
+    try {
+      const creatorId = req.params.id;
+      const subscriberCount = database.getCreatorSubscriberCount(creatorId);
+
+      return res.status(200).json({ success: true, data: { creatorId, subscriberCount } });
+    } catch (error) {
+      return res.status(500).json({ success: false, error: error.message || 'Failed to fetch stats' });
+    }
+  });
+
   app.get('/api/creator/audit-log/export', requireCreatorAuth(creatorAuthService), (req, res) => {
     const format = String(req.query.format || '').toLowerCase();