updated

Author: saleheenkhan

routes/employer-comped-member.js

@@ -0,0 +1,32 @@
+import express from 'express';
+import { enqueueMemberCreation } from '../services/ghostService.js';
+
+const router = express.Router();
+
+router.post('/create-employer-comped-member', async (req, res) => {
+  const { name, email, productId } = req.body;
+
+  if (!name || !email || !productId) {
+    return res.status(400).json({ error: 'Missing required fields' });
+  }
+
+  try {
+    await enqueueMemberCreation({
+      type: 'emcomp',
+      data: { email, name, productId }
+    });
+    
+    res.status(202).json({
+      success: true,
+      message: 'EMComp member creation queued successfully'
+    });
+  } catch (err) {
+    console.error('Error queuing emcomp member:', err);
+    res.status(500).json({ 
+      error: 'Failed to queue emcomp member creation',
+      details: err.message
+    });
+  }
+});
+
+export default router;

server.js

@@ -6,6 +6,7 @@ import checkoutRoutes from './routes/checkout.js';
 import webhookRoutes from './routes/stripe-webhook.js';
 import freeMemberRoutes from './routes/free-member.js';
 import compMemberRoutes from './routes/comped-member.js';
+import employerMemberRoutes from './routes/employer-comped-member.js';
 import noLoginMemberRoutes from './routes/no-login-member.js';
 import './workers/memberWorker.js';
 import { connection } from './config/queue.js';
@@ -30,6 +31,12 @@ app.use('/start-checkout', bodyParser.json());
 app.use('/create-free-member', bodyParser.json());
 app.use(freeMemberRoutes);
 
+
+// EMComped Members
+app.use('/create-employer-comped-member', bodyParser.json());
+app.use(employerMemberRoutes);
+
+
 // Comped Members
 app.use('/create-comped-member', bodyParser.json());
 app.use(compMemberRoutes);

services/ghostService.js

@@ -76,6 +76,37 @@ export async function createCompGhostMember({ email, name, productId }) {
 }
 
 
+export async function createEmCompGhostMember({ email, name, productId }) {
+  try {
+    logger.info(`Creating EMcomp member: ${email.substring(0, 3)}...@...`, { productId });
+    const subscriptionData = {
+      id: "",
+      tier: { id: productId, active: true, expiry_at: null },
+      plan: { id: "", nickname: "Complimentary", currency: "EUR", amount: 0 },
+      status: "active",
+      price: { id: "", price_id: "", nickname: "Complimentary", amount: 0, type: "recurring", currency: "EUR", tier: { id: "", tier_id: productId } },
+      offer: null
+    };
+
+    const result = await api.members.add({
+      email,
+      name,
+      tiers: [{ id: productId, expiry_at: null }],
+      subscriptions: [subscriptionData],
+    });
+    logger.info(`EMComp member created for ${email.substring(0, 3)}...@...`, { productId });
+    return result;
+  } catch (err) {
+    logger.error(`Failed to create comp member ${email.substring(0, 3)}...@...`, {
+      error: err.message,
+      stack: err.stack,
+      productId
+    });
+    throw new Error(`Ghost API error: ${err.message}`);
+  }
+}
+
+
 
 export async function createNoLoginGhostMember({ email, name, note }) {
   try {

workers/memberWorker.js

@@ -3,7 +3,7 @@
 import { Worker } from 'bullmq';
 import { connection } from '../config/queue.js';
 // Make sure to import the new function
-import { createGhostMember, createFreeGhostMember, createCompGhostMember, createNoLoginGhostMember } from '../services/ghostService.js';
+import { createGhostMember, createFreeGhostMember, createCompGhostMember, createNoLoginGhostMember, createEmCompGhostMember } from '../services/ghostService.js';
 import logger from '../config/logger.js';
 import env from '../config/env.js';
 
@@ -25,6 +25,9 @@ const worker = new Worker('member-creation', async (job) => {
       case 'free':
         result = await createFreeGhostMember(data);
         break;
+      case 'emcomp':
+        result = await createEmCompGhostMember(data);
+        break;
       case 'comp':
         result = await createCompGhostMember(data);
         break;