[\s]*
[\s]*<\/div>,[\s]*]/;
+const newActions = `
+ const actions = [
+
+
+
,
+ ];
+ if (params.row.status !== 'submitted') {
+ actions.push(
+
}
+ label="Submit"
+ onClick={async () => {
+ const conf = window.confirm('Submit this draft?');
+ if (conf) {
+ try {
+ await axios.put('/appeal_drafts/' + params.row.id + '/submit');
+ window.location.reload();
+ } catch (e) {
+ alert('Error submitting: ' + (e.response?.data?.message || e.message));
+ }
+ }
+ }}
+ showInMenu
+ />
+ );
+ }
+ return actions;
+`;
+
+content = content.replace(actionsRegex, newActions);
+fs.writeFileSync(filePath, content);
+console.log('Fixed configureAppeal_draftsCols.tsx');
diff --git a/patch_appeal_drafts.js b/patch_appeal_drafts.js
new file mode 100644
index 0000000..89a9c2b
--- /dev/null
+++ b/patch_appeal_drafts.js
@@ -0,0 +1,109 @@
+const fs = require('fs');
+
+let code = fs.readFileSync('backend/src/services/appeal_drafts.js', 'utf8');
+
+if (!code.includes("const Logger = require('./logger');")) {
+ code = code.replace("const config = require('../config');", "const config = require('../config');\nconst Logger = require('./logger');\n");
+}
+
+const createLogic = `
+ static async create(data, currentUser) {
+ const transaction = await db.sequelize.transaction();
+ try {
+ if (data.caseId) {
+ // Find max version
+ const maxVersionDraft = await db.appeal_drafts.findOne({
+ where: { caseId: data.caseId },
+ order: [['version', 'DESC']],
+ transaction
+ });
+ data.version = maxVersionDraft ? maxVersionDraft.version + 1 : 1;
+ data.status = 'draft';
+ }
+
+ const newDraft = await Appeal_draftsDBApi.create(data, { currentUser, transaction });
+ await transaction.commit();
+
+ if (newDraft.caseId) {
+ await Logger.log({
+ organizationId: newDraft.organizationId,
+ caseId: newDraft.caseId,
+ actorUserId: currentUser.id,
+ actionType: 'appeal_draft_created',
+ message: 'Appeal draft v' + newDraft.version + ' created'
+ });
+ }
+ return newDraft;
+ } catch (error) {
+ await transaction.rollback();
+ throw error;
+ }
+ }
+`;
+
+const updateLogic = `
+ static async update(data, id, currentUser) {
+ const transaction = await db.sequelize.transaction();
+ try {
+ let draft = await Appeal_draftsDBApi.findBy({id}, {transaction});
+ if (!draft) throw new ValidationError('appeal_draftsNotFound');
+ if (draft.status === 'submitted') {
+ throw new ValidationError('draftIsReadOnly', 'Submitted drafts are read-only');
+ }
+
+ const isSubmitting = data.status === 'submitted' && draft.status !== 'submitted';
+
+ if (isSubmitting) {
+ // Only one draft can be submitted per case
+ const existingSubmitted = await db.appeal_drafts.findOne({
+ where: { caseId: draft.caseId, status: 'submitted' },
+ transaction
+ });
+ if (existingSubmitted) {
+ // Can choose to throw error or just un-submit the other. Instructions: "only one draft can be in submitted status per case at a time"
+ // Let's un-submit the other one or throw error. Throwing error is safer.
+ throw new ValidationError('alreadySubmitted', 'Another draft is already submitted for this case');
+ }
+ data.submitted_at = new Date();
+ data.submittedByUserId = currentUser.id;
+ }
+
+ const updatedDraft = await Appeal_draftsDBApi.update(id, data, { currentUser, transaction });
+
+ if (isSubmitting && draft.caseId) {
+ // Update case status to submitted
+ await db.cases.update({ status: 'submitted' }, { where: { id: draft.caseId }, transaction });
+ }
+
+ await transaction.commit();
+
+ if (isSubmitting && draft.caseId) {
+ await Logger.log({
+ organizationId: draft.organizationId,
+ caseId: draft.caseId,
+ actorUserId: currentUser.id,
+ actionType: 'appeal_submitted',
+ message: 'Appeal draft v' + draft.version + ' was submitted'
+ });
+ } else if (draft.caseId) {
+ await Logger.log({
+ organizationId: draft.organizationId,
+ caseId: draft.caseId,
+ actorUserId: currentUser.id,
+ actionType: 'appeal_draft_updated',
+ message: 'Appeal draft v' + draft.version + ' was updated'
+ });
+ }
+
+ return updatedDraft;
+ } catch (error) {
+ await transaction.rollback();
+ throw error;
+ }
+ }
+`;
+
+code = code.replace(/static async create\([\s\S]*?catch \(error\) \{[\s\S]*?throw error;\n \}\n \};/m, createLogic);
+code = code.replace(/static async update\([\s\S]*?catch \(error\) \{[\s\S]*?throw error;\n \}\n \};/m, updateLogic);
+
+fs.writeFileSync('backend/src/services/appeal_drafts.js', code);
diff --git a/patch_appeal_submit.js b/patch_appeal_submit.js
new file mode 100644
index 0000000..22066d5
--- /dev/null
+++ b/patch_appeal_submit.js
@@ -0,0 +1,33 @@
+const fs = require('fs');
+const path = require('path');
+
+const serviceFile = path.join(__dirname, 'backend/src/services/appeal_drafts.js');
+let service = fs.readFileSync(serviceFile, 'utf8');
+
+const newMethod = `
+ static async submit(id, currentUser) {
+ return await this.update({ status: 'submitted' }, id, currentUser);
+ }
+`;
+
+service = service.replace(/}\s*module.exports = Appeal_draftsService;/, newMethod + '\n}\nmodule.exports = Appeal_draftsService;');
+fs.writeFileSync(serviceFile, service);
+
+const routesFile = path.join(__dirname, 'backend/src/routes/appeal_drafts.js');
+let routes = fs.readFileSync(routesFile, 'utf8');
+
+const newRoute = `
+router.put('/:id/submit', wrapAsync(async (req, res) => {
+ const payload = await Appeal_draftsService.submit(
+ req.params.id,
+ req.currentUser,
+ );
+ res.status(200).send(payload);
+}));
+
+router.use('/', require('../helpers').commonErrorHandler);
+`;
+
+routes = routes.replace("router.use('/', require('../helpers').commonErrorHandler);", newRoute);
+fs.writeFileSync(routesFile, routes);
+console.log('Patched Appeal Drafts submit action');
diff --git a/patch_cases_actions.js b/patch_cases_actions.js
new file mode 100644
index 0000000..07ca3c1
--- /dev/null
+++ b/patch_cases_actions.js
@@ -0,0 +1,116 @@
+const fs = require('fs');
+const path = require('path');
+
+const routesFile = path.join(__dirname, 'backend/src/routes/cases.js');
+let routes = fs.readFileSync(routesFile, 'utf8');
+
+const newRoutes = `
+router.put('/:id/assign-owner', wrapAsync(async (req, res) => {
+ const payload = await CasesService.assignOwner(
+ req.body.data,
+ req.params.id,
+ req.currentUser,
+ );
+ res.status(200).send(payload);
+}));
+
+router.put('/:id/change-status', wrapAsync(async (req, res) => {
+ const payload = await CasesService.changeStatus(
+ req.body.data,
+ req.params.id,
+ req.currentUser,
+ );
+ res.status(200).send(payload);
+}));
+
+router.put('/:id/reopen', wrapAsync(async (req, res) => {
+ const payload = await CasesService.reopen(
+ req.body.data,
+ req.params.id,
+ req.currentUser,
+ );
+ res.status(200).send(payload);
+}));
+
+router.put('/:id/mark-won', wrapAsync(async (req, res) => {
+ const payload = await CasesService.markWon(
+ req.body.data,
+ req.params.id,
+ req.currentUser,
+ );
+ res.status(200).send(payload);
+}));
+
+router.put('/:id/mark-lost', wrapAsync(async (req, res) => {
+ const payload = await CasesService.markLost(
+ req.body.data,
+ req.params.id,
+ req.currentUser,
+ );
+ res.status(200).send(payload);
+}));
+
+router.use('/', require('../helpers').commonErrorHandler);
+`;
+
+routes = routes.replace(/router\.use\('/', require('../helpers').commonErrorHandler);/, newRoutes);
+fs.writeFileSync(routesFile, routes);
+
+const serviceFile = path.join(__dirname, 'backend/src/services/cases.js');
+let service = fs.readFileSync(serviceFile, 'utf8');
+
+const newMethods = `
+ static async assignOwner(data, id, currentUser) {
+ const record = await CasesDBApi.findBy(id, { currentUser });
+ if (!record) throw new ValidationError('Case not found');
+
+ const updated = await CasesDBApi.update(id, { assignedToUserId: data.assignedToUserId }, { currentUser });
+ await Logger.log(currentUser.organizationId, id, currentUser.id, 'owner_changed', 'Owner assigned to ' + data.assignedToUserId, { assignedToUserId: data.assignedToUserId });
+ return updated;
+ }
+
+ static async changeStatus(data, id, currentUser) {
+ const record = await CasesDBApi.findBy(id, { currentUser });
+ if (!record) throw new ValidationError('Case not found');
+
+ // We reuse the update logic which has validation
+ return await this.update({ status: data.status }, id, currentUser);
+ }
+
+ static async reopen(data, id, currentUser) {
+ const record = await CasesDBApi.findBy(id, { currentUser });
+ if (!record) throw new ValidationError('Case not found');
+
+ if (!data.reopenReason) throw new ValidationError('reopenReasonRequired');
+
+ const updated = await CasesDBApi.update(id, { status: data.status || 'intake' }, { currentUser });
+ await Logger.log(currentUser.organizationId, id, currentUser.id, 'status_changed', 'Case reopened: ' + data.reopenReason, { reopenReason: data.reopenReason, status: data.status || 'intake' });
+ return updated;
+ }
+
+ static async markWon(data, id, currentUser) {
+ const record = await CasesDBApi.findBy(id, { currentUser });
+ if (!record) throw new ValidationError('Case not found');
+
+ if (!data.resolutionReason) throw new ValidationError('resolutionReasonRequired');
+
+ const updated = await CasesDBApi.update(id, { status: 'won' }, { currentUser });
+ await Logger.log(currentUser.organizationId, id, currentUser.id, 'status_changed', 'Case marked won: ' + data.resolutionReason, { resolutionReason: data.resolutionReason, status: 'won' });
+ return updated;
+ }
+
+ static async markLost(data, id, currentUser) {
+ const record = await CasesDBApi.findBy(id, { currentUser });
+ if (!record) throw new ValidationError('Case not found');
+
+ if (!data.resolutionReason) throw new ValidationError('resolutionReasonRequired');
+
+ const updated = await CasesDBApi.update(id, { status: 'lost' }, { currentUser });
+ await Logger.log(currentUser.organizationId, id, currentUser.id, 'status_changed', 'Case marked lost: ' + data.resolutionReason, { resolutionReason: data.resolutionReason, status: 'lost' });
+ return updated;
+ }
+}
+`;
+
+service = service.replace(/}\nmodule.exports = CasesService;/, newMethods + '\nmodule.exports = CasesService;');
+console.log('Patched Cases Routes and Services');
diff --git a/patch_cases_routes_actions.js b/patch_cases_routes_actions.js
new file mode 100644
index 0000000..1bcdc86
--- /dev/null
+++ b/patch_cases_routes_actions.js
@@ -0,0 +1,58 @@
+const fs = require('fs');
+const path = require('path');
+
+const routesFile = path.join(__dirname, 'backend/src/routes/cases.js');
+let routes = fs.readFileSync(routesFile, 'utf8');
+
+const newRoutes = `
+router.put('/:id/assign-owner', wrapAsync(async (req, res) => {
+ const payload = await CasesService.assignOwner(
+ req.body.data,
+ req.params.id,
+ req.currentUser,
+ );
+ res.status(200).send(payload);
+}));
+
+router.put('/:id/change-status', wrapAsync(async (req, res) => {
+ const payload = await CasesService.changeStatus(
+ req.body.data,
+ req.params.id,
+ req.currentUser,
+ );
+ res.status(200).send(payload);
+}));
+
+router.put('/:id/reopen', wrapAsync(async (req, res) => {
+ const payload = await CasesService.reopen(
+ req.body.data,
+ req.params.id,
+ req.currentUser,
+ );
+ res.status(200).send(payload);
+}));
+
+router.put('/:id/mark-won', wrapAsync(async (req, res) => {
+ const payload = await CasesService.markWon(
+ req.body.data,
+ req.params.id,
+ req.currentUser,
+ );
+ res.status(200).send(payload);
+}));
+
+router.put('/:id/mark-lost', wrapAsync(async (req, res) => {
+ const payload = await CasesService.markLost(
+ req.body.data,
+ req.params.id,
+ req.currentUser,
+ );
+ res.status(200).send(payload);
+}));
+
+router.use('/', require('../helpers').commonErrorHandler);
+`;
+
+routes = routes.replace(/router\.use\('\/', require\('\.\.\/helpers'\)\.commonErrorHandler\);/, newRoutes);
+fs.writeFileSync(routesFile, routes);
+console.log('Patched Cases routes');
diff --git a/patch_cases_service.js b/patch_cases_service.js
new file mode 100644
index 0000000..7e9f904
--- /dev/null
+++ b/patch_cases_service.js
@@ -0,0 +1,102 @@
+const fs = require('fs');
+
+let casesSvc = fs.readFileSync('backend/src/services/cases.js', 'utf8');
+
+// Add Logger import
+if (!casesSvc.includes("const Logger = require('./logger');")) {
+ casesSvc = casesSvc.replace("const config = require('../config');", "const config = require('../config');\nconst Logger = require('./logger');\n");
+}
+
+// Patch create
+if (casesSvc.includes('await CasesDBApi.create(')) {
+ casesSvc = casesSvc.replace(
+ 'await CasesDBApi.create(',
+ 'const newCase = await CasesDBApi.create('
+ );
+ casesSvc = casesSvc.replace(
+ 'await transaction.commit();',
+ `await transaction.commit();\n await Logger.log({\n organizationId: newCase.organizationId,\n caseId: newCase.id,\n actorUserId: currentUser.id,\n actionType: 'case_created',\n message: 'Case was created',\n metadata: { case_number: newCase.case_number }\n });`
+ );
+}
+
+// Patch update
+const updateCode = `
+ let cases = await CasesDBApi\.findBy\({id}, {transaction});
+ if (!cases) { throw new ValidationError('casesNotFound'); }
+
+ const oldStatus = cases.status;
+ const newStatus = data.status || cases.status;
+
+ if (data.status && data.status !== oldStatus) {
+ const allowedTransitions = {
+ 'intake': ['triage'],
+ 'triage': ['evidence_needed', 'appeal_ready'],
+ 'evidence_needed': ['appeal_ready'],
+ 'appeal_ready': ['submitted'],
+ 'submitted': ['pending_payer'],
+ 'pending_payer': ['won', 'lost']
+ };
+
+ const isReopening = (['won', 'lost'].includes(oldStatus)) && !['won', 'lost'].includes(newStatus);
+
+ if (isReopening) {
+ if (!data.reopenReason) {
+ throw new ValidationError('reopenReasonRequired', 'A reason is required to reopen a case');
+ }
+ } else if (allowedTransitions[oldStatus] && !allowedTransitions[oldStatus].includes(newStatus)) {
+ // reject invalid transition
+ throw new ValidationError('invalidStatusTransition', 'Cannot transition case status from ' + oldStatus + ' to ' + newStatus);
+ }
+ }
+
+ const updatedCases = await CasesDBApi.update(id, data, { currentUser, transaction });
+ await transaction.commit();
+
+ // Logging
+ if (data.status && data.status !== oldStatus) {
+ await Logger.log({
+ organizationId: cases.organizationId,
+ caseId: id,
+ actorUserId: currentUser.id,
+ actionType: 'status_changed',
+ message: 'Status changed from ' + oldStatus + ' to ' + newStatus,
+ metadata: { oldStatus, newStatus, reopenReason: data.reopenReason }
+ });
+ }
+ if (data.owner_userId && data.owner_userId !== cases.owner_userId) {
+ await Logger.log({
+ organizationId: cases.organizationId,
+ caseId: id,
+ actorUserId: currentUser.id,
+ actionType: 'owner_changed',
+ message: 'Case owner was changed',
+ metadata: { oldOwner: cases.owner_userId, newOwner: data.owner_userId }
+ });
+ }
+ if (data.due_at && new Date(data.due_at).getTime() !== new Date(cases.due_at).getTime()) {
+ await Logger.log({
+ organizationId: cases.organizationId,
+ caseId: id,
+ actorUserId: currentUser.id,
+ actionType: 'due_date_changed',
+ message: 'Case due date was changed',
+ metadata: { oldDueDate: cases.due_at, newDueDate: data.due_at }
+ });
+ }
+ if (!data.status && !data.owner_userId && !data.due_at) {
+ await Logger.log({
+ organizationId: cases.organizationId,
+ caseId: id,
+ actorUserId: currentUser.id,
+ actionType: 'case_updated',
+ message: 'Case details were updated',
+ metadata: { updatedFields: Object.keys(data) }
+ });
+ }
+
+ return updatedCases;
+`;
+
+casesSvc = casesSvc.replace(/let cases = await CasesDBApi\.findBy\([\s\S]*?return updatedCases;/m, updateCode);
+
+fs.writeFileSync('backend/src/services/cases.js', casesSvc);
\ No newline at end of file
diff --git a/patch_cases_service_actions.js b/patch_cases_service_actions.js
new file mode 100644
index 0000000..24cad37
--- /dev/null
+++ b/patch_cases_service_actions.js
@@ -0,0 +1,41 @@
+const fs = require('fs');
+const path = require('path');
+
+const serviceFile = path.join(__dirname, 'backend/src/services/cases.js');
+let service = fs.readFileSync(serviceFile, 'utf8');
+
+const newMethods = `
+ static async assignOwner(data, id, currentUser) {
+ if (!data.assignedToUserId) throw new ValidationError('assignedToUserIdRequired');
+ return await this.update({ owner_userId: data.assignedToUserId }, id, currentUser);
+ }
+
+ static async changeStatus(data, id, currentUser) {
+ if (!data.status) throw new ValidationError('statusRequired');
+ return await this.update({ status: data.status }, id, currentUser);
+ }
+
+ static async reopen(data, id, currentUser) {
+ if (!data.reopenReason) throw new ValidationError('reopenReasonRequired', 'A reason is required to reopen a case');
+ return await this.update({ status: data.status || 'intake', reopenReason: data.reopenReason }, id, currentUser);
+ }
+
+ static async markWon(data, id, currentUser) {
+ if (!data.resolutionReason) throw new ValidationError('resolutionReasonRequired', 'A reason is required to mark as won');
+ // We can also set outcome to won here
+ return await this.update({ status: 'won', outcome: 'won', resolutionReason: data.resolutionReason }, id, currentUser);
+ }
+
+ static async markLost(data, id, currentUser) {
+ if (!data.resolutionReason) throw new ValidationError('resolutionReasonRequired', 'A reason is required to mark as lost');
+ // We can also set outcome to lost here
+ return await this.update({ status: 'lost', outcome: 'lost', resolutionReason: data.resolutionReason }, id, currentUser);
+ }
+`;
+
+service = service.replace(/}\nmodule\.exports = CasesService;/, newMethods + '\n}\nmodule.exports = CasesService;');
+// Wait, the update method should also log the resolutionReason.
+service = service.replace(/metadata: \{ oldStatus, newStatus, reopenReason: data\.reopenReason \}/, 'metadata: { oldStatus, newStatus, reopenReason: data.reopenReason, resolutionReason: data.resolutionReason }');
+
+fs.writeFileSync(serviceFile, service);
+console.log('Patched CasesService');
diff --git a/patch_cases_view.js b/patch_cases_view.js
new file mode 100644
index 0000000..0588988
--- /dev/null
+++ b/patch_cases_view.js
@@ -0,0 +1,46 @@
+const fs = require('fs');
+
+let view = fs.readFileSync('frontend/src/pages/cases/cases-view.tsx', 'utf8');
+
+if (!view.includes('updateCase')) {
+ view = view.replace("import { fetch as fetchCase } from '../../stores/cases/casesSlice';", "import { fetch as fetchCase, update as updateCase } from '../../stores/cases/casesSlice';");
+}
+
+const commandArea = `
+ {activeTab === 'overview' && (
+
+ Command Actions
+
+
+
+
+
+
+
+
+ {
+ const reason = prompt("Enter reason (optional)");
+ dispatch(updateCase({ id, data: { status: 'won', reopenReason: reason }})).then(() => dispatch(fetchCase({id})));
+ }}
+ />
+ {
+ const reason = prompt("Enter reason (optional)");
+ dispatch(updateCase({ id, data: { status: 'lost', reopenReason: reason }})).then(() => dispatch(fetchCase({id})));
+ }}
+ />
+
+
+ )
+`;
+
+if (!view.includes('Command Actions')) {
+ view = view.replace('{activeTab === \'overview\' && (', commandArea + '\n {activeTab === \'overview\' && (');
+}
+
+fs.writeFileSync('frontend/src/pages/cases/cases-view.tsx', view);
\ No newline at end of file
diff --git a/patch_cases_view_modals.js b/patch_cases_view_modals.js
new file mode 100644
index 0000000..6b92401
--- /dev/null
+++ b/patch_cases_view_modals.js
@@ -0,0 +1,102 @@
+const fs = require('fs');
+const path = require('path');
+
+const filePath = path.join(__dirname, 'frontend/src/pages/cases/cases-view.tsx');
+let content = fs.readFileSync(filePath, 'utf8');
+
+const imports = `
+import CardBoxModal from "../../components/CardBoxModal";
+import FormField from "../../components/FormField";
+import { Field, Form, Formik } from "formik";
+import axios from "axios";
+`;
+
+content = content.replace("import BaseButton from \"../../components/BaseButton\";", "import BaseButton from \"../../components/BaseButton\";" + imports);
+
+const stateAndHandlers = `
+ const [modalAction, setModalAction] = useState(null);
+ const [actionLoading, setActionLoading] = useState(false);
+
+ const handleActionSubmit = async (values) => {
+ setActionLoading(true);
+ try {
+ if (modalAction === 'markWon') {
+ await axios.put(\"/cases/\${id}/mark-won\", { data: { resolutionReason: values.reason } });
+ } else if (modalAction === 'markLost') {
+ await axios.put(\"/cases/\${id}/mark-lost\", { data: { resolutionReason: values.reason } });
+ } else if (modalAction === 'reopen') {
+ await axios.put(\"/cases/\${id}/reopen\", { data: { reopenReason: values.reason } });
+ } else if (modalAction === 'changeStatus') {
+ await axios.put(\"/cases/\${id}/change-status\", { data: { status: values.status } });
+ }
+ dispatch(fetchCase({ id }));
+ setModalAction(null);
+ } catch (e) {
+ console.error(e);
+ alert('Action failed: ' + (e.response?.data?.message || e.message));
+ } finally {
+ setActionLoading(false);
+ }
+ };
+`;
+
+content = content.replace(/const { id } = router.query;/, stateAndHandlers + '\n const { id } = router.query;');
+
+const newButtons = `
+
setModalAction('changeStatus')} />
+
+
+
+
+ setModalAction('markWon')} />
+ setModalAction('markLost')} />
+{['won', 'lost'].includes(cases.status) && setModalAction('reopen')} />}
+`;
+
+content = content.replace(//, newButtons);
+
+const modals = `
+ setModalAction(null)}
+ onConfirm={() => {
+ const form = document.getElementById('action-form');
+ if (form) form.dispatchEvent(new Event('submit', { cancelable: true, bubbles: true }));
+ }}
+ >
+
+
+
+
+`;
+
+content = content.replace(//, "\n" + modals);
+
+fs.writeFileSync(filePath, content);
+console.log('Patched CasesView');
diff --git a/patch_models.js b/patch_models.js
new file mode 100644
index 0000000..84ecec2
--- /dev/null
+++ b/patch_models.js
@@ -0,0 +1,44 @@
+const fs = require('fs');
+
+// Patch activity_logs.js
+let activityLogs = fs.readFileSync('backend/src/db/models/activity_logs.js', 'utf8');
+if (!activityLogs.includes('actionType')) {
+ activityLogs = activityLogs.replace(
+ 'message: {',
+ 'actionType: { type: DataTypes.STRING },\n metadata: { type: DataTypes.JSONB },\n\n message: {'
+ );
+ fs.writeFileSync('backend/src/db/models/activity_logs.js', activityLogs);
+}
+
+// Patch appeal_drafts.js
+let appealDrafts = fs.readFileSync('backend/src/db/models/appeal_drafts.js', 'utf8');
+if (!appealDrafts.includes('version: {')) {
+ appealDrafts = appealDrafts.replace(
+ 'title: {',
+ 'version: { type: DataTypes.INTEGER, defaultValue: 1 },\n summary: { type: DataTypes.TEXT },\n body: { type: DataTypes.TEXT },\n evidenceChecklist: { type: DataTypes.JSONB },\n\n title: {'
+ );
+ // Add belongsTo for submittedByUserId
+ appealDrafts = appealDrafts.replace(
+ 'db.appeal_drafts.belongsTo(db.users, {',
+ 'db.appeal_drafts.belongsTo(db.users, {\n as: \"submittedByUser\",\n foreignKey: {\n name: \"submittedByUserId\",\n },\n constraints: false,\n });\n\n db.appeal_drafts.belongsTo(db.users, {'
+ );
+ // Unescape literal backslashes so it's actual newlines
+ appealDrafts = appealDrafts.replace(/\\n/g, '\n');
+
+ // change status to STRING
+ appealDrafts = appealDrafts.replace(
+ /status: {\s*type: DataTypes\.ENUM,[\s\S]*?],/,
+ 'status: {\n type: DataTypes.STRING,'
+ );
+ fs.writeFileSync('backend/src/db/models/appeal_drafts.js', appealDrafts);
+}
+
+// Patch cases.js for status type change
+let cases = fs.readFileSync('backend/src/db/models/cases.js', 'utf8');
+if (cases.includes('type: DataTypes.ENUM,')) {
+ cases = cases.replace(
+ /status: {\s*type: DataTypes\.ENUM,[\s\S]*?],/,
+ 'status: {\n type: DataTypes.STRING,'
+ );
+ fs.writeFileSync('backend/src/db/models/cases.js', cases);
+}
\ No newline at end of file
diff --git a/patch_new_forms.js b/patch_new_forms.js
new file mode 100644
index 0000000..baad7b2
--- /dev/null
+++ b/patch_new_forms.js
@@ -0,0 +1,22 @@
+const fs = require('fs');
+
+const entities = ['tasks', 'documents', 'appeal_drafts', 'notes', 'activity_logs'];
+
+for (const e of entities) {
+ const file = `frontend/src/pages/${e}/${e}-new.tsx`;
+ if (!fs.existsSync(file)) continue;
+ let content = fs.readFileSync(file, 'utf8');
+
+ content = content.replace(
+ new RegExp(`await router\.push\('/${e}/${e}-list'\)`),
+ `await router.push(router.query.caseId ? `/cases/cases-view?id=${router.query.caseId}` : '/${e}/${e}-list')`
+ );
+
+ content = content.replace(
+ /initialValues={[^]*?}[\s\S]*?onSubmit=/,
+ `initialValues={{ ...(typeof dateRangeStart !== 'undefined' && dateRangeStart && dateRangeEnd ? { ...initialValues, due_at: moment(dateRangeStart).format('YYYY-MM-DDTHH:mm'), completed_at: moment(dateRangeEnd).format('YYYY-MM-DDTHH:mm') } : initialValues), case: router.query.caseId || '' }}
+ onSubmit=`
+ );
+
+ fs.writeFileSync(file, content);
+}
diff --git a/patch_other_services.js b/patch_other_services.js
new file mode 100644
index 0000000..7a8f1fc
--- /dev/null
+++ b/patch_other_services.js
@@ -0,0 +1,47 @@
+const fs = require('fs');
+
+function patchService(serviceName, entityName, createAction, updateAction) {
+ let code = fs.readFileSync(`backend/src/services/${serviceName}.js`, 'utf8');
+
+ // Add Logger import
+ if (!code.includes("const Logger = require('./logger');")) {
+ code = code.replace("const config = require('../config');", "const config = require('../config');\nconst Logger = require('./logger');\n");
+ }
+
+ // Patch create
+ let createMatch = new RegExp(`await ${entityName}DBApi.create([\s\S]*?);`);
+ if (code.includes(`await ${entityName}DBApi.create(`)) {
+ code = code.replace(`await ${entityName}DBApi.create(`, `const newEntity = await ${entityName}DBApi.create(`);
+ let commitIndex = code.indexOf('await transaction.commit();');
+ if (commitIndex > -1 && !code.includes(`actionType: '${createAction}'`)) {
+ code = code.replace(
+ 'await transaction.commit();',
+ `await transaction.commit();\n if (newEntity.caseId) { await Logger.log({ organizationId: newEntity.organizationId, caseId: newEntity.caseId, actorUserId: currentUser.id, actionType: '${createAction}', message: '${createAction.replace('_', ' ')}' }); }`
+ );
+ }
+ }
+
+ // Patch update
+ let updateMatch = new RegExp(`const updated${entityName} = await ${entityName}DBApi.update([\s\S]*?);`);
+ if (code.includes(`const updated${entityName} = await ${entityName}DBApi.update(`) && !code.includes(`actionType: '${updateAction}'`)) {
+ code = code.replace(
+ 'await transaction.commit();\n return updated',
+ `await transaction.commit();
+ let dbEntity = await ${entityName}DBApi.findBy({id});
+ if (dbEntity && dbEntity.caseId) {
+ let act = '${updateAction}';
+ if (data.status === 'completed' && dbEntity.status !== 'completed') act = '${entityName.toLowerCase()}_completed';
+ await Logger.log({ organizationId: dbEntity.organizationId, caseId: dbEntity.caseId, actorUserId: currentUser.id, actionType: act, message: act.replace('_', ' ') });
+ }
+ return updated`
+ );
+ }
+
+ fs.writeFileSync(`backend/src/services/${serviceName}.js`, code);
+}
+
+patchService('tasks', 'Tasks', 'task_created', 'task_updated');
+patchService('notes', 'Notes', 'note_added', 'note_updated');
+patchService('documents', 'Documents', 'document_uploaded', 'document_updated');
+
+// Special logic for appeal_drafts: creating a new draft increments version, only one draft can be in submitted status per case.