459 lines
14 KiB
TypeScript
459 lines
14 KiB
TypeScript
import { Router } from "express";
|
||
import { Request, Response } from "express";
|
||
import { storage } from "../storage";
|
||
import { forwardToSeleniumInsuranceEligibilityAgent } from "../services/seleniumInsuranceEligibilityClient";
|
||
import fs from "fs/promises";
|
||
import path from "path";
|
||
import PDFDocument from "pdfkit";
|
||
import { forwardToSeleniumInsuranceClaimStatusAgent } from "../services/seleniumInsuranceClaimStatusClient";
|
||
import fsSync from "fs";
|
||
import { emptyFolderContainingFile } from "../utils/emptyTempFolder";
|
||
import forwardToPatientDataExtractorService from "../services/patientDataExtractorService";
|
||
import { InsertPatient } from "../../../../packages/db/types/patient-types";
|
||
|
||
const router = Router();
|
||
|
||
/** Utility: naive name splitter */
|
||
function splitName(fullName?: string | null) {
|
||
if (!fullName) return { firstName: "", lastName: "" };
|
||
const parts = fullName.trim().split(/\s+/).filter(Boolean);
|
||
const firstName = parts.shift() ?? "";
|
||
const lastName = parts.join(" ") ?? "";
|
||
return { firstName, lastName };
|
||
}
|
||
|
||
/**
|
||
* Ensure patient exists for given insuranceId.
|
||
* If exists -> update first/last name when different.
|
||
* If not -> create using provided fields.
|
||
* Returns the patient object (the version read from DB after potential create/update).
|
||
*/
|
||
async function createOrUpdatePatientByInsuranceId(options: {
|
||
insuranceId: string;
|
||
firstName?: string | null;
|
||
lastName?: string | null;
|
||
dob?: string | Date | null;
|
||
userId: number;
|
||
}) {
|
||
const { insuranceId, firstName, lastName, dob, userId } = options;
|
||
if (!insuranceId) throw new Error("Missing insuranceId");
|
||
|
||
let patient = await storage.getPatientByInsuranceId(insuranceId);
|
||
|
||
// Normalize incoming names
|
||
const incomingFirst = firstName!.trim();
|
||
const incomingLast = lastName!.trim();
|
||
|
||
if (patient && patient.id) {
|
||
// update only if different
|
||
const updates: any = {};
|
||
if (
|
||
incomingFirst &&
|
||
String(patient.firstName ?? "").trim() !== incomingFirst
|
||
) {
|
||
updates.firstName = incomingFirst;
|
||
}
|
||
if (
|
||
incomingLast &&
|
||
String(patient.lastName ?? "").trim() !== incomingLast
|
||
) {
|
||
updates.lastName = incomingLast;
|
||
}
|
||
|
||
if (Object.keys(updates).length > 0) {
|
||
await storage.updatePatient(patient.id, updates);
|
||
}
|
||
return;
|
||
} else {
|
||
// If patient doesn't exist -> create
|
||
const createPayload: InsertPatient = {
|
||
firstName: incomingFirst,
|
||
lastName: incomingLast,
|
||
dateOfBirth: dob,
|
||
gender: "",
|
||
phone: "",
|
||
userId,
|
||
status: "inactive",
|
||
insuranceId,
|
||
};
|
||
|
||
await storage.createPatient(createPayload);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* /eligibility-check
|
||
* - run selenium
|
||
* - if pdf created -> call extractor -> get name
|
||
* - create or update patient (by memberId)
|
||
* - attach PDF to patient (create pdf group/file)
|
||
* - return { patient, pdfFileId, extractedName ... }
|
||
*/
|
||
router.post(
|
||
"/eligibility-check",
|
||
async (req: Request, res: Response): Promise<any> => {
|
||
if (!req.body.data) {
|
||
return res
|
||
.status(400)
|
||
.json({ error: "Missing Insurance Eligibility data for selenium" });
|
||
}
|
||
|
||
if (!req.user || !req.user.id) {
|
||
return res.status(401).json({ error: "Unauthorized: user info missing" });
|
||
}
|
||
|
||
let seleniumResult: any = undefined;
|
||
let createdPdfFileId: number | null = null;
|
||
let outputResult: any = {};
|
||
const extracted: any = {};
|
||
|
||
try {
|
||
const insuranceEligibilityData = JSON.parse(req.body.data);
|
||
|
||
const credentials = await storage.getInsuranceCredentialByUserAndSiteKey(
|
||
req.user.id,
|
||
insuranceEligibilityData.insuranceSiteKey
|
||
);
|
||
if (!credentials) {
|
||
return res.status(404).json({
|
||
error:
|
||
"No insurance credentials found for this provider, Kindly Update this at Settings Page.",
|
||
});
|
||
}
|
||
|
||
const enrichedData = {
|
||
...insuranceEligibilityData,
|
||
massdhpUsername: credentials.username,
|
||
massdhpPassword: credentials.password,
|
||
};
|
||
|
||
// 1) Run selenium agent
|
||
try {
|
||
seleniumResult =
|
||
await forwardToSeleniumInsuranceEligibilityAgent(enrichedData);
|
||
} catch (seleniumErr: any) {
|
||
return res.status(502).json({
|
||
error: "Selenium service failed",
|
||
detail: seleniumErr?.message ?? String(seleniumErr),
|
||
});
|
||
}
|
||
|
||
// 2) If selenium produced a pdf path, extract name
|
||
if (
|
||
seleniumResult?.pdf_path &&
|
||
seleniumResult.pdf_path.endsWith(".pdf")
|
||
) {
|
||
try {
|
||
const pdfPath = seleniumResult.pdf_path;
|
||
const pdfBuffer = await fs.readFile(pdfPath);
|
||
|
||
const extraction = await forwardToPatientDataExtractorService({
|
||
buffer: pdfBuffer,
|
||
originalname: path.basename(pdfPath),
|
||
mimetype: "application/pdf",
|
||
} as any);
|
||
|
||
if (extraction.name) {
|
||
const parts = splitName(extraction.name);
|
||
extracted.firstName = parts.firstName;
|
||
extracted.lastName = parts.lastName;
|
||
}
|
||
} catch (extractErr: any) {
|
||
return res.status(502).json({
|
||
error: "Patient data extraction failed",
|
||
detail: extractErr?.message ?? String(extractErr),
|
||
});
|
||
}
|
||
}
|
||
|
||
// Step-3) Create or update patient name using extracted info (prefer extractor -> request)
|
||
const insuranceId = String(
|
||
insuranceEligibilityData.memberId ?? ""
|
||
).trim();
|
||
if (!insuranceId) {
|
||
return res.status(400).json({ error: "Missing memberId" });
|
||
}
|
||
|
||
// prefer extractor names, else use request-sent names, else null
|
||
const preferFirst = extracted.firstName;
|
||
const preferLast = extracted.lastName;
|
||
|
||
try {
|
||
await createOrUpdatePatientByInsuranceId({
|
||
insuranceId,
|
||
firstName: preferFirst,
|
||
lastName: preferLast,
|
||
dob: insuranceEligibilityData.dateOfBirth,
|
||
userId: req.user.id,
|
||
});
|
||
} catch (patientOpErr: any) {
|
||
return res.status(500).json({
|
||
error: "Failed to create/update patient",
|
||
detail: patientOpErr?.message ?? String(patientOpErr),
|
||
});
|
||
}
|
||
|
||
// ✅ Step 4: Check result and update patient status
|
||
const patient = await storage.getPatientByInsuranceId(
|
||
insuranceEligibilityData.memberId
|
||
);
|
||
|
||
if (patient && patient.id !== undefined) {
|
||
const newStatus =
|
||
seleniumResult.eligibility === "Y" ? "active" : "inactive";
|
||
await storage.updatePatient(patient.id, { status: newStatus });
|
||
outputResult.patientUpdateStatus = `Patient status updated to ${newStatus}`;
|
||
|
||
// ✅ Step 5: Handle PDF Upload
|
||
if (
|
||
seleniumResult.pdf_path &&
|
||
seleniumResult.pdf_path.endsWith(".pdf")
|
||
) {
|
||
const pdfBuffer = await fs.readFile(seleniumResult.pdf_path);
|
||
|
||
const groupTitle = "Eligibility Status";
|
||
const groupTitleKey = "ELIGIBILITY_STATUS";
|
||
|
||
let group = await storage.findPdfGroupByPatientTitleKey(
|
||
patient.id,
|
||
groupTitleKey
|
||
);
|
||
|
||
// Step 5b: Create group if it doesn’t exist
|
||
if (!group) {
|
||
group = await storage.createPdfGroup(
|
||
patient.id,
|
||
groupTitle,
|
||
groupTitleKey
|
||
);
|
||
}
|
||
|
||
if (!group?.id) {
|
||
throw new Error("PDF group creation failed: missing group ID");
|
||
}
|
||
|
||
const created = await storage.createPdfFile(
|
||
group.id,
|
||
path.basename(seleniumResult.pdf_path),
|
||
pdfBuffer
|
||
);
|
||
|
||
// created could be { id, filename } or just id, adapt to your storage API.
|
||
if (created && typeof created === "object" && "id" in created) {
|
||
createdPdfFileId = Number(created.id);
|
||
}
|
||
|
||
outputResult.pdfUploadStatus = `PDF saved to group: ${group.title}`;
|
||
} else {
|
||
outputResult.pdfUploadStatus =
|
||
"No valid PDF path provided by Selenium, Couldn't upload pdf to server.";
|
||
}
|
||
} else {
|
||
outputResult.patientUpdateStatus =
|
||
"Patient not found or missing ID; no update performed";
|
||
}
|
||
|
||
res.json({
|
||
patientUpdateStatus: outputResult.patientUpdateStatus,
|
||
pdfUploadStatus: outputResult.pdfUploadStatus,
|
||
pdfFileId: createdPdfFileId,
|
||
});
|
||
} catch (err: any) {
|
||
console.error(err);
|
||
return res.status(500).json({
|
||
error: err.message || "Failed to forward to selenium agent",
|
||
});
|
||
} finally {
|
||
try {
|
||
if (seleniumResult && seleniumResult.pdf_path) {
|
||
await emptyFolderContainingFile(seleniumResult.pdf_path);
|
||
} else {
|
||
console.log(`[eligibility-check] no pdf_path available to cleanup`);
|
||
}
|
||
} catch (cleanupErr) {
|
||
console.error(
|
||
`[eligibility-check cleanup failed for ${seleniumResult?.pdf_path}`,
|
||
cleanupErr
|
||
);
|
||
}
|
||
}
|
||
}
|
||
);
|
||
|
||
router.post(
|
||
"/claim-status-check",
|
||
async (req: Request, res: Response): Promise<any> => {
|
||
if (!req.body.data) {
|
||
return res
|
||
.status(400)
|
||
.json({ error: "Missing Insurance Status data for selenium" });
|
||
}
|
||
|
||
if (!req.user || !req.user.id) {
|
||
return res.status(401).json({ error: "Unauthorized: user info missing" });
|
||
}
|
||
|
||
let result: any = undefined;
|
||
|
||
async function imageToPdfBuffer(imagePath: string): Promise<Buffer> {
|
||
return new Promise<Buffer>((resolve, reject) => {
|
||
try {
|
||
const doc = new PDFDocument({ autoFirstPage: false });
|
||
const chunks: Uint8Array[] = [];
|
||
|
||
// collect data chunks
|
||
doc.on("data", (chunk: any) => chunks.push(chunk));
|
||
doc.on("end", () => resolve(Buffer.concat(chunks)));
|
||
doc.on("error", (err: any) => reject(err));
|
||
|
||
const A4_WIDTH = 595.28; // points
|
||
const A4_HEIGHT = 841.89; // points
|
||
|
||
doc.addPage({ size: [A4_WIDTH, A4_HEIGHT] });
|
||
|
||
doc.image(imagePath, 0, 0, {
|
||
fit: [A4_WIDTH, A4_HEIGHT],
|
||
align: "center",
|
||
valign: "center",
|
||
});
|
||
|
||
doc.end();
|
||
} catch (err) {
|
||
reject(err);
|
||
}
|
||
});
|
||
}
|
||
try {
|
||
const insuranceClaimStatusData = JSON.parse(req.body.data);
|
||
|
||
const credentials = await storage.getInsuranceCredentialByUserAndSiteKey(
|
||
req.user.id,
|
||
insuranceClaimStatusData.insuranceSiteKey
|
||
);
|
||
if (!credentials) {
|
||
return res.status(404).json({
|
||
error:
|
||
"No insurance credentials found for this provider, Kindly Update this at Settings Page.",
|
||
});
|
||
}
|
||
|
||
const enrichedData = {
|
||
...insuranceClaimStatusData,
|
||
massdhpUsername: credentials.username,
|
||
massdhpPassword: credentials.password,
|
||
};
|
||
|
||
result = await forwardToSeleniumInsuranceClaimStatusAgent(enrichedData);
|
||
|
||
let createdPdfFileId: number | null = null;
|
||
|
||
// ✅ Step 1: Check result
|
||
const patient = await storage.getPatientByInsuranceId(
|
||
insuranceClaimStatusData.memberId
|
||
);
|
||
|
||
if (patient && patient.id !== undefined) {
|
||
let pdfBuffer: Buffer | null = null;
|
||
let generatedPdfPath: string | null = null;
|
||
|
||
if (
|
||
result.ss_path &&
|
||
(result.ss_path.endsWith(".png") ||
|
||
result.ss_path.endsWith(".jpg") ||
|
||
result.ss_path.endsWith(".jpeg"))
|
||
) {
|
||
try {
|
||
// Ensure file exists
|
||
if (!fsSync.existsSync(result.ss_path)) {
|
||
throw new Error(`Screenshot file not found: ${result.ss_path}`);
|
||
}
|
||
|
||
// Convert image to PDF buffer
|
||
pdfBuffer = await imageToPdfBuffer(result.ss_path);
|
||
|
||
// Optionally write generated PDF to temp path (so name is available for createPdfFile)
|
||
const pdfFileName = `claimStatus_${insuranceClaimStatusData.memberId}_${Date.now()}.pdf`;
|
||
generatedPdfPath = path.join(
|
||
path.dirname(result.ss_path),
|
||
pdfFileName
|
||
);
|
||
await fs.writeFile(generatedPdfPath, pdfBuffer);
|
||
} catch (err) {
|
||
console.error("Failed to convert screenshot to PDF:", err);
|
||
result.pdfUploadStatus = `Failed to convert screenshot to PDF: ${String(err)}`;
|
||
}
|
||
} else {
|
||
result.pdfUploadStatus =
|
||
"No valid PDF or screenshot path provided by Selenium; nothing to upload.";
|
||
}
|
||
|
||
if (pdfBuffer && generatedPdfPath) {
|
||
const groupTitle = "Claim Status";
|
||
const groupTitleKey = "CLAIM_STATUS";
|
||
|
||
let group = await storage.findPdfGroupByPatientTitleKey(
|
||
patient.id,
|
||
groupTitleKey
|
||
);
|
||
|
||
// Create group if missing
|
||
if (!group) {
|
||
group = await storage.createPdfGroup(
|
||
patient.id,
|
||
groupTitle,
|
||
groupTitleKey
|
||
);
|
||
}
|
||
|
||
if (!group?.id) {
|
||
throw new Error("PDF group creation failed: missing group ID");
|
||
}
|
||
|
||
// Use the basename for storage
|
||
const basename = path.basename(generatedPdfPath);
|
||
const created = await storage.createPdfFile(
|
||
group.id,
|
||
basename,
|
||
pdfBuffer
|
||
);
|
||
|
||
if (created && typeof created === "object" && "id" in created) {
|
||
createdPdfFileId = Number(created.id);
|
||
}
|
||
|
||
result.pdfUploadStatus = `PDF saved to group: ${group.title}`;
|
||
}
|
||
} else {
|
||
result.patientUpdateStatus =
|
||
"Patient not found or missing ID; no update performed";
|
||
}
|
||
|
||
res.json({
|
||
pdfUploadStatus: result.pdfUploadStatus,
|
||
pdfFileId: createdPdfFileId,
|
||
});
|
||
return;
|
||
} catch (err: any) {
|
||
console.error(err);
|
||
return res.status(500).json({
|
||
error: err.message || "Failed to forward to selenium agent",
|
||
});
|
||
} finally {
|
||
try {
|
||
if (result && result.ss_path) {
|
||
await emptyFolderContainingFile(result.ss_path);
|
||
} else {
|
||
console.log(`claim-status-check] no pdf_path available to cleanup`);
|
||
}
|
||
} catch (cleanupErr) {
|
||
console.error(
|
||
`[claim-status-check cleanup failed for ${result?.ss_path}`,
|
||
cleanupErr
|
||
);
|
||
}
|
||
}
|
||
}
|
||
);
|
||
|
||
export default router;
|