update tasks

Author: sevenreup

src/app/(dashboard)/patients/[id]/actions.ts

@@ -1,13 +1,17 @@
 "use server";
 
-import { pushResourceBundle } from "@/lib/fhir/bundle";
+import { BinaryPatchData, pushResourceBundle } from "@/lib/fhir/bundle";
 import { fetchCarePlan } from "./fetch";
-import { CarePlanData, CarePlanDataActivity } from "../../../../lib/models/types";
+import {
+  CarePlanData,
+  CarePlanDataActivity,
+} from "../../../../lib/models/types";
 import { fhirR4 } from "@smile-cdr/fhirts";
 import { mapCarePlanToTask } from "@/lib/fhir/tasks";
+import { createJsonPatchUpdate } from "@/lib/utils";
 
 export const fixTasks = async (formData: FormData) => {
-  const resourcesToUpdate: fhirR4.Resource[] = [];
+  const resourcesToUpdate: (fhirR4.Resource | BinaryPatchData)[] = [];
   const data = JSON.parse(formData.getAll("data")[0] as string) as {
     careplan: CarePlanData;
     items: CarePlanDataActivity[];
@@ -26,6 +30,7 @@ export const fixTasks = async (formData: FormData) => {
       const task = creatNewTask(data.careplan, activity);
       resourcesToUpdate.push(task);
     } else {
+
       if (!activity.isTaskAndCarePlanSameStatus && activity.taskReference) {
         activity.taskStatus = mapCarePlanToTask(
           activity.carePlanActivityStatus
@@ -53,6 +58,18 @@ export const fixTasks = async (formData: FormData) => {
       activity.detail.status = mapCarePlan.get(taskId)
         ?.carePlanActivityStatus as any;
       carePlan.activity![index] = activity;
+      const taskUpdateBundle = {
+        path: `Task/${taskId}`,
+        isBinary: true,
+        data: createJsonPatchUpdate([
+          {
+            op: "replace",
+            path: "/status",
+            value: mapCarePlan.get(taskId)?.taskStatus,
+          },
+        ]),
+      };
+      resourcesToUpdate.push(taskUpdateBundle);
     }
   }
   if (mapCarePlan.size > 0) {

src/app/(dashboard)/patients/[id]/components/careplanContainer.tsx

@@ -149,19 +149,19 @@ export const CarePlanContainer = ({ data, action }: Props) => {
                     <div className="badge badge-accent">Scheduled Task</div>
                   )}
                 </div>
-              </summary>
-              <div className="collapse-content">
-                <div className="flex flex-col p-2">
-                  <div className="flex flex-row gap-2">
-                    <span className="badge badge-secondary">
-                      CarePlan Status: {activity.carePlanActivityStatus}
-                    </span>
-                    <span className="badge badge-secondary">
-                      Task Status: {activity.taskStatus}
-                    </span>
+                <div className="">
+                  <div className="flex flex-col p-2">
+                    <div className="flex flex-row gap-2">
+                      <span className="badge badge-neutral p-2">
+                        CarePlan Status: {activity.carePlanActivityStatus}
+                      </span>
+                      <span className="badge badge-primary p-2">
+                        Task Status: {activity.taskStatus}
+                      </span>
+                    </div>
                   </div>
                 </div>
-              </div>
+              </summary>
             </details>
           );
         })}

src/lib/fhir/bundle.ts

@@ -3,17 +3,32 @@ import { fhirServer } from "../api/axios";
 import { AxiosError } from "axios";
 import { IBundle } from "@smile-cdr/fhirts/dist/FHIR-R4/interfaces/IBundle";
 
-export const pushResourceBundle = async (resources: fhirR4.Resource[]) => {
+export type BinaryPatchData = {
+  data: fhirR4.Binary;
+  path: string;
+  isBinary: boolean;
+};
+
+export const pushResourceBundle = async (
+  resources: (fhirR4.Resource | BinaryPatchData)[]
+) => {
   try {
     const bundle = new fhirR4.Bundle();
     bundle.type = "transaction";
     const entrries: fhirR4.BundleEntry[] = [];
     for (const resource of resources) {
       const entry = new fhirR4.BundleEntry();
-      entry.resource = resource;
-      entry.request = new fhirR4.BundleRequest();
-      entry.request.method = "PUT";
-      entry.request.url = `${resource.resourceType}/${resource.id}`;
+      if ("isBinary" in resource) {
+        entry.resource = resource.data;
+        entry.request = new fhirR4.BundleRequest();
+        entry.request.method = "PATCH";
+        entry.request.url = resource.path;
+      } else {
+        entry.resource = resource;
+        entry.request = new fhirR4.BundleRequest();
+        entry.request.method = "PUT";
+        entry.request.url = `${resource.resourceType}/${resource.id}`;
+      }
       entrries.push(entry);
     }
 
@@ -48,7 +63,7 @@ export const fetchBundle = async (
     };
   });
   console.log(JSON.stringify(bundle));
-  
+
   const response = await fhirServer.post("/", bundle);
   return response.data;
 };

src/lib/utils.ts

@@ -1,6 +1,7 @@
 import { type ClassValue, clsx } from "clsx";
 import { twMerge } from "tailwind-merge";
 import { addDays, subMinutes, startOfDay } from "date-fns";
+import { fhirR4 } from "@smile-cdr/fhirts";
 
 export function cn(...inputs: ClassValue[]) {
   return twMerge(clsx(inputs));
@@ -44,3 +45,11 @@ export const paramGenerator = (
     .join("&")}`;
 };
 
+export const createJsonPatchUpdate = (data: any) => {
+  const binary = new fhirR4.Binary();
+  binary.contentType = "application/json-patch+json";
+  binary.resourceType = "Binary";
+  binary.data = Buffer.from(JSON.stringify(data)).toString("base64");
+  return binary;
+};
+