import { Request, Response } from 'express';
import * as captureLeadService from './captureLead.service';
import catchAsync from '@/shared/utils/catchAsync';
import responseCodes from '@/shared/utils/responseCode/responseCode';
import { pick } from '@/shared/utils';
import config from '@/shared/config/config';
import {
authenticateCompanyMetaAccount,
companyMetaAccountCallback,
} from '../meta/meta.platform';
const { CaptureLeadResponseCodes } = responseCodes;
export const createCaptureLead = catchAsync(
async (req: Request, res: Response) => {
const companyId = req.user.company.id;
const userId = req.user.id;
const payload = {
...req.body,
company: companyId,
};
const lead = await captureLeadService.createCaptureLead(payload, userId);
const responseData: any = { ...lead };
if (String(lead.platform) === 'custom_form') {
const webhookUrl =
lead.webhookUrl ||
`${config.backendUrl}/webhook/leads/${companyId}/${lead.id}`;
responseData.formEmbedHtml = `
`;
}
res.success(
responseData,
CaptureLeadResponseCodes.SUCCESS,
'Capture Lead Created Successfully',
);
},
);
export const updateCaptureLead = catchAsync(
async (req: Request, res: Response) => {
const { id } = pick(req.params, ['id']);
const data = await captureLeadService.updateCaptureLead(
id,
req.body,
req.user,
);
res.success(
data,
CaptureLeadResponseCodes.SUCCESS,
'Capture Lead Updated Successfully',
);
},
);
export const getCaptureLeadById = catchAsync(
async (req: Request, res: Response) => {
const { id } = pick(req.params, ['id']);
const lead = await captureLeadService.getCaptureLeadById(id);
res.success(
lead,
CaptureLeadResponseCodes.SUCCESS,
'Capture Lead Fetched Successfully',
);
},
);
export const getCaptureLead = catchAsync(
async (req: Request, res: Response) => {
const filter = pick(req.query, [
'search',
'platform',
'interestType',
'sourceId',
'projectId',
'isActive',
]);
const options = pick(req.query, [
'sortBy',
'limit',
'page',
'fields',
'populate',
'includeTimeStamps',
]);
const leads = await captureLeadService.queryCaptureLead(
{ ...filter, company: req.user.company.id },
options,
);
res.success(
leads,
CaptureLeadResponseCodes.SUCCESS,
'Capture Leads Fetched Successfully',
);
},
);
export const deleteCaptureLeadById = catchAsync(
async (req: Request, res: Response) => {
const { id } = pick(req.params, ['id']);
const data = await captureLeadService.deleteCaptureLead(id, req.user);
res.success(
data,
CaptureLeadResponseCodes.SUCCESS,
'Capture Lead Deleted Successfully',
);
},
);
export const authCompanyMetaAccount = catchAsync(
async (req: Request, res: Response) => {
const {
company: { id: companyId },
id: userId,
} = req.user;
const data = await authenticateCompanyMetaAccount(companyId, userId);
res.success(
data,
CaptureLeadResponseCodes.SUCCESS,
'Meta Account Authenticated Successfully',
);
},
);
export const authCompanyMetaAccountCallback = catchAsync(
async (req: Request, res: Response) => {
const { code, state } = pick(req.query, ['code', 'state']);
if (!state || typeof state !== 'string') {
console.error('OAuth state parameter missing or invalid.');
return;
}
let stateObject;
try {
const decodedStateUri = decodeURIComponent(state);
const buffer = Buffer.from(decodedStateUri, 'base64');
const stateJson = buffer.toString('utf8');
stateObject = JSON.parse(stateJson);
} catch (_error) {
throw new Error('Invalid state parameter format.');
}
const { userId, companyId } = stateObject;
const data = await companyMetaAccountCallback(companyId, userId, code);
// ensure we send proper content-type
res.setHeader('Content-Type', 'text/html; charset=utf-8');
return res.status(200).send(data);
},
);