diff --git a/apps/backoffice-v2/package.json b/apps/backoffice-v2/package.json
index a3498efd02..9e3a4a03db 100644
--- a/apps/backoffice-v2/package.json
+++ b/apps/backoffice-v2/package.json
@@ -98,7 +98,7 @@
     "i18next-http-backend": "^2.1.1",
     "leaflet": "^1.9.4",
     "libphonenumber-js": "^1.10.49",
-    "lucide-react": "^0.239.0",
+    "lucide-react": "^0.445.0",
     "match-sorter": "^6.3.1",
     "msw": "^1.0.0",
     "posthog-js": "^1.154.2",
diff --git a/apps/backoffice-v2/public/locales/en/toast.json b/apps/backoffice-v2/public/locales/en/toast.json
index 5809b1b785..bce138fba5 100644
--- a/apps/backoffice-v2/public/locales/en/toast.json
+++ b/apps/backoffice-v2/public/locales/en/toast.json
@@ -81,6 +81,10 @@
   "pdf_certificate": {
     "error": "Failed to open PDF certificate."
   },
+  "document_ocr": {
+    "success": "OCR performed successfully.",
+    "error": "Failed to perform OCR on the document."
+  },
   "business_report_creation": {
     "success": "Merchant check created successfully.",
     "error": "Error occurred while creating a merchant check.",
diff --git a/apps/backoffice-v2/src/common/components/molecules/ImageOCR/ImageOCR.tsx b/apps/backoffice-v2/src/common/components/molecules/ImageOCR/ImageOCR.tsx
new file mode 100644
index 0000000000..f4e6259e44
--- /dev/null
+++ b/apps/backoffice-v2/src/common/components/molecules/ImageOCR/ImageOCR.tsx
@@ -0,0 +1,35 @@
+import { ctw } from '@/common/utils/ctw/ctw';
+import { ComponentProps, FunctionComponent } from 'react';
+import { Loader2, ScanTextIcon } from 'lucide-react';
+
+export interface IImageOCR extends ComponentProps<'button'> {
+  onOcrPressed?: () => void;
+  isOcrDisabled: boolean;
+  isLoadingOCR?: boolean;
+}
+
+export const ImageOCR: FunctionComponent<IImageOCR> = ({
+  isOcrDisabled,
+  onOcrPressed,
+  className,
+  isLoadingOCR,
+  ...props
+}) => (
+  <button
+    {...props}
+    type="button"
+    className={ctw(
+      'btn btn-circle btn-ghost btn-sm bg-base-300/70 text-[0.688rem] focus:outline-primary disabled:bg-base-300/70',
+      isLoadingOCR,
+      className,
+    )}
+    onClick={() => onOcrPressed?.()}
+    disabled={isOcrDisabled || isLoadingOCR}
+  >
+    {isLoadingOCR ? (
+      <Loader2 className="animate-spin stroke-foreground" />
+    ) : (
+      <ScanTextIcon className={'p-0.5'} />
+    )}
+  </button>
+);
diff --git a/apps/backoffice-v2/src/domains/customer/fetchers.ts b/apps/backoffice-v2/src/domains/customer/fetchers.ts
index ae20cbd752..94587404af 100644
--- a/apps/backoffice-v2/src/domains/customer/fetchers.ts
+++ b/apps/backoffice-v2/src/domains/customer/fetchers.ts
@@ -27,6 +27,7 @@ const CustomerSchema = z.object({
       createBusinessReportBatch: z
         .object({ enabled: z.boolean().default(false), options: createBusinessReportOptions })
         .optional(),
+      isDocumentOcrEnabled: z.boolean().default(false).optional(),
     })
     .nullable(),
   config: z
diff --git a/apps/backoffice-v2/src/domains/entities/hooks/mutations/useDocumentOcr/useDocumentOcr.ts b/apps/backoffice-v2/src/domains/entities/hooks/mutations/useDocumentOcr/useDocumentOcr.ts
new file mode 100644
index 0000000000..21b8f389ca
--- /dev/null
+++ b/apps/backoffice-v2/src/domains/entities/hooks/mutations/useDocumentOcr/useDocumentOcr.ts
@@ -0,0 +1,30 @@
+import { useMutation, useQueryClient } from '@tanstack/react-query';
+import { fetchWorkflowDocumentOCRResult } from '@/domains/workflows/fetchers';
+import { toast } from 'sonner';
+import { t } from 'i18next';
+import { workflowsQueryKeys } from '@/domains/workflows/query-keys';
+import { useFilterId } from '@/common/hooks/useFilterId/useFilterId';
+
+export const useDocumentOcr = ({ workflowId }: { workflowId: string }) => {
+  const filterId = useFilterId();
+  const workflowById = workflowsQueryKeys.byId({ workflowId, filterId });
+  const queryClient = useQueryClient();
+
+  return useMutation({
+    mutationFn: ({ documentId }: { documentId: string }) => {
+      return fetchWorkflowDocumentOCRResult({
+        workflowRuntimeId: workflowId,
+        documentId,
+      });
+    },
+    onSuccess: (data, variables) => {
+      void queryClient.invalidateQueries(workflowsQueryKeys._def);
+      toast.success(t('toast:document_ocr.success'));
+    },
+    onError: (error, variables) => {
+      console.error('OCR error:', error, 'for document:', variables.documentId);
+      void queryClient.invalidateQueries(workflowsQueryKeys._def);
+      toast.error(t('toast:document_ocr.error'));
+    },
+  });
+};
diff --git a/apps/backoffice-v2/src/domains/workflows/fetchers.ts b/apps/backoffice-v2/src/domains/workflows/fetchers.ts
index 47cd387770..663359a8ab 100644
--- a/apps/backoffice-v2/src/domains/workflows/fetchers.ts
+++ b/apps/backoffice-v2/src/domains/workflows/fetchers.ts
@@ -298,3 +298,21 @@ export const createWorkflowRequest = async ({
 
   return handleZodError(error, workflow);
 };
+
+export const fetchWorkflowDocumentOCRResult = async ({
+  workflowRuntimeId,
+  documentId,
+}: {
+  workflowRuntimeId: string;
+  documentId: string;
+}) => {
+  const [workflow, error] = await apiClient({
+    method: Method.GET,
+    url: `${getOriginUrl(
+      env.VITE_API_URL,
+    )}/api/v1/internal/workflows/${workflowRuntimeId}/documents/${documentId}/run-ocr`,
+    schema: z.any(),
+  });
+
+  return handleZodError(error, workflow);
+};
diff --git a/apps/backoffice-v2/src/lib/blocks/components/CallToActionLegacy/hooks/useCallToActionLegacyLogic/useCallToActionLegacyLogic.tsx b/apps/backoffice-v2/src/lib/blocks/components/CallToActionLegacy/hooks/useCallToActionLegacyLogic/useCallToActionLegacyLogic.tsx
index 1677b129f8..dd7b4718b5 100644
--- a/apps/backoffice-v2/src/lib/blocks/components/CallToActionLegacy/hooks/useCallToActionLegacyLogic/useCallToActionLegacyLogic.tsx
+++ b/apps/backoffice-v2/src/lib/blocks/components/CallToActionLegacy/hooks/useCallToActionLegacyLogic/useCallToActionLegacyLogic.tsx
@@ -1,4 +1,3 @@
-import { CommonWorkflowEvent } from '@ballerine/common';
 import { ComponentProps, FunctionComponent, useCallback, useEffect, useState } from 'react';
 import { toast } from 'sonner';
 import { useApproveTaskByIdMutation } from '../../../../../../domains/entities/hooks/mutations/useApproveTaskByIdMutation/useApproveTaskByIdMutation';
diff --git a/apps/backoffice-v2/src/lib/blocks/components/Details/Details.tsx b/apps/backoffice-v2/src/lib/blocks/components/Details/Details.tsx
index 77b7a34163..6f85036c0f 100644
--- a/apps/backoffice-v2/src/lib/blocks/components/Details/Details.tsx
+++ b/apps/backoffice-v2/src/lib/blocks/components/Details/Details.tsx
@@ -13,6 +13,7 @@ export const Details: FunctionComponent<ExtractCellProps<'details'>> = ({
   workflowId,
   documents = [],
   onSubmit,
+  isSaveDisabled,
   props,
 }) => {
   if (!value.data?.length) {
@@ -38,6 +39,7 @@ export const Details: FunctionComponent<ExtractCellProps<'details'>> = ({
         documents={documents}
         title={value?.title}
         data={sortedData}
+        isSaveDisabled={isSaveDisabled}
         contextUpdateMethod={contextUpdateMethod}
         onSubmit={onSubmit}
       />
diff --git a/apps/backoffice-v2/src/lib/blocks/components/EditableDetails/EditableDetails.tsx b/apps/backoffice-v2/src/lib/blocks/components/EditableDetails/EditableDetails.tsx
index b967d6b1ea..85199220a6 100644
--- a/apps/backoffice-v2/src/lib/blocks/components/EditableDetails/EditableDetails.tsx
+++ b/apps/backoffice-v2/src/lib/blocks/components/EditableDetails/EditableDetails.tsx
@@ -103,6 +103,7 @@ export const EditableDetails: FunctionComponent<IEditableDetails> = ({
   documents,
   title,
   workflowId,
+  isSaveDisabled,
   contextUpdateMethod = 'base',
   onSubmit: onSubmitCallback,
 }) => {
@@ -427,7 +428,11 @@ export const EditableDetails: FunctionComponent<IEditableDetails> = ({
         </div>
         <div className={`flex justify-end`}>
           {data?.some(({ isEditable }) => isEditable) && (
-            <Button type="submit" className={`ms-auto mt-3`}>
+            <Button
+              type="submit"
+              className={`ms-auto mt-3 aria-disabled:pointer-events-none aria-disabled:opacity-50`}
+              aria-disabled={isSaveDisabled}
+            >
               Save
             </Button>
           )}
diff --git a/apps/backoffice-v2/src/lib/blocks/components/EditableDetails/interfaces.ts b/apps/backoffice-v2/src/lib/blocks/components/EditableDetails/interfaces.ts
index c1c2cc0d23..4da7f1351a 100644
--- a/apps/backoffice-v2/src/lib/blocks/components/EditableDetails/interfaces.ts
+++ b/apps/backoffice-v2/src/lib/blocks/components/EditableDetails/interfaces.ts
@@ -25,6 +25,7 @@ export interface IEditableDetails {
   documents: IEditableDetailsDocument[];
   title: string;
   workflowId: string;
+  isSaveDisabled?: boolean;
   contextUpdateMethod?: 'base' | 'director';
   onSubmit?: (document: AnyObject) => void;
 }
diff --git a/apps/backoffice-v2/src/lib/blocks/components/MultiDocuments/MultiDocuments.tsx b/apps/backoffice-v2/src/lib/blocks/components/MultiDocuments/MultiDocuments.tsx
index 167ee82ca7..c053fff65a 100644
--- a/apps/backoffice-v2/src/lib/blocks/components/MultiDocuments/MultiDocuments.tsx
+++ b/apps/backoffice-v2/src/lib/blocks/components/MultiDocuments/MultiDocuments.tsx
@@ -7,7 +7,13 @@ export const MultiDocuments: FunctionComponent<IMultiDocumentsProps> = ({ value
 
   return (
     <div className={`m-2 rounded p-1`}>
-      <Case.Documents documents={documents} isLoading={value?.isLoading} />
+      <Case.Documents
+        documents={documents}
+        isDocumentEditable={value?.isDocumentEditable}
+        isLoading={value?.isLoading}
+        onOcrPressed={value?.onOcrPressed}
+        isLoadingOCR={value?.isLoadingOCR}
+      />
     </div>
   );
 };
diff --git a/apps/backoffice-v2/src/lib/blocks/components/MultiDocuments/interfaces.ts b/apps/backoffice-v2/src/lib/blocks/components/MultiDocuments/interfaces.ts
index fe92eb3c6e..2e3bbc0132 100644
--- a/apps/backoffice-v2/src/lib/blocks/components/MultiDocuments/interfaces.ts
+++ b/apps/backoffice-v2/src/lib/blocks/components/MultiDocuments/interfaces.ts
@@ -1,6 +1,9 @@
 export interface IMultiDocumentsProps {
   value: {
     isLoading: boolean;
+    onOcrPressed: () => void;
+    isLoadingOCR: boolean;
+    isDocumentEditable: boolean;
     data: Array<{
       imageUrl: string;
       title: string;
diff --git a/apps/backoffice-v2/src/lib/blocks/create-blocks-typed/types.ts b/apps/backoffice-v2/src/lib/blocks/create-blocks-typed/types.ts
index 28075eb23b..a94904702d 100644
--- a/apps/backoffice-v2/src/lib/blocks/create-blocks-typed/types.ts
+++ b/apps/backoffice-v2/src/lib/blocks/create-blocks-typed/types.ts
@@ -115,6 +115,7 @@ export type TDetailsCell = {
   hideSeparator?: boolean;
   documents?: IEditableDetailsDocument[];
   contextUpdateMethod?: 'base' | 'director';
+  isSaveDisabled?: boolean;
   value: {
     id: string;
     title: string;
diff --git a/apps/backoffice-v2/src/lib/blocks/hooks/useDocumentBlocks/useDocumentBlocks.tsx b/apps/backoffice-v2/src/lib/blocks/hooks/useDocumentBlocks/useDocumentBlocks.tsx
index dcc7d9eaa4..8af41a490d 100644
--- a/apps/backoffice-v2/src/lib/blocks/hooks/useDocumentBlocks/useDocumentBlocks.tsx
+++ b/apps/backoffice-v2/src/lib/blocks/hooks/useDocumentBlocks/useDocumentBlocks.tsx
@@ -1,7 +1,7 @@
 import { MotionButton } from '@/common/components/molecules/MotionButton/MotionButton';
 import { checkIsBusiness } from '@/common/utils/check-is-business/check-is-business';
 import { ctw } from '@/common/utils/ctw/ctw';
-import { CommonWorkflowStates, StateTag, valueOrNA } from '@ballerine/common';
+import { CommonWorkflowStates, isObject, StateTag, valueOrNA } from '@ballerine/common';
 import { useApproveTaskByIdMutation } from '@/domains/entities/hooks/mutations/useApproveTaskByIdMutation/useApproveTaskByIdMutation';
 import { useRejectTaskByIdMutation } from '@/domains/entities/hooks/mutations/useRejectTaskByIdMutation/useRejectTaskByIdMutation';
 import { useRemoveDecisionTaskByIdMutation } from '@/domains/entities/hooks/mutations/useRemoveDecisionTaskByIdMutation/useRemoveDecisionTaskByIdMutation';
@@ -29,6 +29,7 @@ import { X } from 'lucide-react';
 import * as React from 'react';
 import { FunctionComponent, useCallback, useMemo } from 'react';
 import { toTitleCase } from 'string-ts';
+import { useDocumentOcr } from '@/domains/entities/hooks/mutations/useDocumentOcr/useDocumentOcr';
 
 export const useDocumentBlocks = ({
   workflow,
@@ -79,6 +80,14 @@ export const useDocumentBlocks = ({
 
   const { mutate: mutateApproveTaskById, isLoading: isLoadingApproveTaskById } =
     useApproveTaskByIdMutation(workflow?.id);
+  const {
+    mutate: mutateOCRDocument,
+    isLoading: isLoadingOCRDocument,
+    data: ocrResult,
+  } = useDocumentOcr({
+    workflowId: workflow?.id,
+  });
+
   const { isLoading: isLoadingRejectTaskById } = useRejectTaskByIdMutation(workflow?.id);
 
   const { comment, onClearComment, onCommentChange } = useCommentInputLogic();
@@ -358,6 +367,25 @@ export const useDocumentBlocks = ({
           })
           .cellAt(0, 0);
 
+        const documentEntries = Object.entries(
+          {
+            ...additionalProperties,
+            ...propertiesSchema?.properties,
+          } ?? {},
+        ).map(([title, formattedValue]) => {
+          if (isObject(formattedValue)) {
+            return [
+              title,
+              {
+                ...formattedValue,
+                value: formattedValue.value || ocrResult?.parsedData?.[title],
+              },
+            ];
+          }
+
+          return [title, formattedValue];
+        });
+
         const detailsCell = createBlocksTyped()
           .addBlock()
           .addCell({
@@ -370,12 +398,7 @@ export const useDocumentBlocks = ({
                 value: {
                   id,
                   title: `${category} - ${docType}`,
-                  data: Object.entries(
-                    {
-                      ...additionalProperties,
-                      ...propertiesSchema?.properties,
-                    } ?? {},
-                  )?.map(
+                  data: documentEntries?.map(
                     ([
                       title,
                       {
@@ -441,6 +464,7 @@ export const useDocumentBlocks = ({
                   },
                 },
                 workflowId: workflow?.id,
+                isSaveDisabled: isLoadingOCRDocument,
                 documents: workflow?.context?.documents,
               })
               .addCell(decisionCell)
@@ -455,6 +479,9 @@ export const useDocumentBlocks = ({
             type: 'multiDocuments',
             value: {
               isLoading: storageFilesQueryResult?.some(({ isLoading }) => isLoading),
+              onOcrPressed: () => mutateOCRDocument({ documentId: id }),
+              isDocumentEditable: caseState.writeEnabled,
+              isLoadingOCR: isLoadingOCRDocument,
               data:
                 documents?.[docIndex]?.pages?.map(
                   ({ type, fileName, metadata, ballerineFileId }, pageIndex) => ({
diff --git a/apps/backoffice-v2/src/pages/Entity/components/Case/Case.Documents.Toolbar.tsx b/apps/backoffice-v2/src/pages/Entity/components/Case/Case.Documents.Toolbar.tsx
index d2dc82764c..fed645e15e 100644
--- a/apps/backoffice-v2/src/pages/Entity/components/Case/Case.Documents.Toolbar.tsx
+++ b/apps/backoffice-v2/src/pages/Entity/components/Case/Case.Documents.Toolbar.tsx
@@ -5,6 +5,7 @@ import { ImageViewer } from '@/common/components/organisms/ImageViewer/ImageView
 import { ctw } from '@/common/utils/ctw/ctw';
 import { isPdf } from '@/common/utils/is-pdf/is-pdf';
 import { useDocumentsToolbarLogic } from '@/pages/Entity/components/Case/hooks/useDocumentsToolbarLogic/useDocumentsToolbarLogic';
+import { ImageOCR } from '@/common/components/molecules/ImageOCR/ImageOCR';
 
 export const DocumentsToolbar: FunctionComponent<{
   image: { id: string; imageUrl: string; fileType: string; fileName: string };
@@ -13,6 +14,9 @@ export const DocumentsToolbar: FunctionComponent<{
   onRotateDocument: () => void;
   onOpenDocumentInNewTab: (id: string) => void;
   shouldDownload: boolean;
+  onOcrPressed?: () => void;
+  isOCREnabled: boolean;
+  isLoadingOCR: boolean;
   fileToDownloadBase64: string;
 }> = ({
   image,
@@ -20,7 +24,10 @@ export const DocumentsToolbar: FunctionComponent<{
   hideOpenExternalButton,
   onRotateDocument,
   onOpenDocumentInNewTab,
+  onOcrPressed,
   shouldDownload,
+  isLoadingOCR,
+  isOCREnabled,
   fileToDownloadBase64,
 }) => {
   const { onOpenInNewTabClick } = useDocumentsToolbarLogic({
@@ -31,6 +38,11 @@ export const DocumentsToolbar: FunctionComponent<{
 
   return (
     <div className={`absolute z-50 flex space-x-2 bottom-right-6`}>
+      <ImageOCR
+        isOcrDisabled={!isOCREnabled}
+        onOcrPressed={onOcrPressed}
+        isLoadingOCR={isLoadingOCR}
+      />
       {!hideOpenExternalButton && !isLoading && image?.id && (
         <button
           type={`button`}
diff --git a/apps/backoffice-v2/src/pages/Entity/components/Case/Case.Documents.tsx b/apps/backoffice-v2/src/pages/Entity/components/Case/Case.Documents.tsx
index 60b07a8b73..3c271251f9 100644
--- a/apps/backoffice-v2/src/pages/Entity/components/Case/Case.Documents.tsx
+++ b/apps/backoffice-v2/src/pages/Entity/components/Case/Case.Documents.tsx
@@ -7,7 +7,7 @@ import { ImageViewer } from '@/common/components/organisms/ImageViewer/ImageView
 import { ctw } from '@/common/utils/ctw/ctw';
 import { keyFactory } from '@/common/utils/key-factory/key-factory';
 import { DocumentsToolbar } from '@/pages/Entity/components/Case/Case.Documents.Toolbar';
-import { useDocuments } from './hooks/useDocuments/useDocuments';
+import { useDocumentsLogic } from './hooks/useDocuments/useDocumentsLogic';
 import { IDocumentsProps } from './interfaces';
 
 /**
@@ -24,7 +24,10 @@ import { IDocumentsProps } from './interfaces';
  */
 export const Documents: FunctionComponent<IDocumentsProps> = ({
   documents,
+  onOcrPressed,
   isLoading,
+  isDocumentEditable,
+  isLoadingOCR,
   hideOpenExternalButton,
 }) => {
   const {
@@ -32,11 +35,9 @@ export const Documents: FunctionComponent<IDocumentsProps> = ({
     onCrop,
     onCancelCrop,
     isCropping,
-    onOcr,
     selectedImageRef,
     initialImage,
     skeletons,
-    isLoadingOCR,
     selectedImage,
     onSelectImage,
     documentRotation,
@@ -45,8 +46,9 @@ export const Documents: FunctionComponent<IDocumentsProps> = ({
     onTransformed,
     isRotatedOrTransformed,
     shouldDownload,
+    isOCREnabled,
     fileToDownloadBase64,
-  } = useDocuments(documents);
+  } = useDocumentsLogic(documents);
 
   return (
     <ImageViewer selectedImage={selectedImage} onSelectImage={onSelectImage}>
@@ -88,8 +90,10 @@ export const Documents: FunctionComponent<IDocumentsProps> = ({
             onOpenDocumentInNewTab={onOpenDocumentInNewTab}
             // isRotatedOrTransformed={isRotatedOrTransformed}
             shouldDownload={shouldDownload}
+            isOCREnabled={!!isDocumentEditable && isOCREnabled}
+            onOcrPressed={onOcrPressed}
+            isLoadingOCR={!!isLoadingOCR}
             // isCropping={isCropping}
-            // isLoadingOCR={isLoadingOCR}
             // onCancelCrop={onCancelCrop}
             fileToDownloadBase64={fileToDownloadBase64}
           />
diff --git a/apps/backoffice-v2/src/pages/Entity/components/Case/hooks/useDocuments/useDocuments.tsx b/apps/backoffice-v2/src/pages/Entity/components/Case/hooks/useDocuments/useDocumentsLogic.tsx
similarity index 67%
rename from apps/backoffice-v2/src/pages/Entity/components/Case/hooks/useDocuments/useDocuments.tsx
rename to apps/backoffice-v2/src/pages/Entity/components/Case/hooks/useDocuments/useDocumentsLogic.tsx
index 92a91facff..0321747971 100644
--- a/apps/backoffice-v2/src/pages/Entity/components/Case/hooks/useDocuments/useDocuments.tsx
+++ b/apps/backoffice-v2/src/pages/Entity/components/Case/hooks/useDocuments/useDocumentsLogic.tsx
@@ -1,69 +1,23 @@
-import { t } from 'i18next';
-import { toast } from 'sonner';
 import { ComponentProps, useCallback, useRef, useState } from 'react';
 
 import { IDocumentsProps } from '../../interfaces';
 import { TransformWrapper } from 'react-zoom-pan-pinch';
 import { useCrop } from '@/common/hooks/useCrop/useCrop';
 import { DOWNLOAD_ONLY_MIME_TYPES } from '@/common/constants';
-import { useToggle } from '@/common/hooks/useToggle/useToggle';
 import { useFilterId } from '@/common/hooks/useFilterId/useFilterId';
 import { useTesseract } from '@/common/hooks/useTesseract/useTesseract';
 import { createArrayOfNumbers } from '@/common/utils/create-array-of-numbers/create-array-of-numbers';
 import { useStorageFileByIdQuery } from '@/domains/storage/hooks/queries/useStorageFileByIdQuery/useStorageFileByIdQuery';
-import { copyToClipboard } from '@/common/utils/copy-to-clipboard/copy-to-clipboard';
+import { useCustomerQuery } from '@/domains/customer/hook/queries/useCustomerQuery/useCustomerQuery';
 
-export const useDocuments = (documents: IDocumentsProps['documents']) => {
+export const useDocumentsLogic = (documents: IDocumentsProps['documents']) => {
   const initialImage = documents?.[0];
-  const {
-    crop,
-    isCropping,
-    onCrop,
-    cropImage,
-    toggleOnIsCropping,
-    toggleOffIsCropping,
-    onCancelCrop,
-  } = useCrop();
-  const [isLoadingOCR, , toggleOnIsLoadingOCR, toggleOffIsLoadingOCR] = useToggle(false);
+  const { data: customer } = useCustomerQuery();
+  const { crop, isCropping, onCrop, onCancelCrop } = useCrop();
   const selectedImageRef = useRef<HTMLImageElement>();
   const recognize = useTesseract();
   const filterId = useFilterId();
-  const onOcr = useCallback(async () => {
-    if (!isCropping) {
-      toggleOnIsCropping();
-
-      return;
-    }
-
-    toggleOnIsLoadingOCR();
 
-    try {
-      const croppedBase64 = await cropImage(selectedImageRef.current);
-      const result = await recognize(croppedBase64);
-      const text = result?.data?.text;
-
-      if (!text) {
-        throw new Error('No document OCR text found');
-      }
-
-      await copyToClipboard(text)();
-    } catch (err) {
-      console.error(err);
-
-      toast.error(t('toast:ocr_document_error'));
-    }
-
-    toggleOffIsLoadingOCR();
-    toggleOffIsCropping();
-  }, [
-    isCropping,
-    toggleOnIsLoadingOCR,
-    toggleOffIsLoadingOCR,
-    toggleOffIsCropping,
-    toggleOnIsCropping,
-    cropImage,
-    recognize,
-  ]);
   const skeletons = createArrayOfNumbers(4);
   const [selectedImage, setSelectedImage] = useState<{
     imageUrl: string;
@@ -114,11 +68,10 @@ export const useDocuments = (documents: IDocumentsProps['documents']) => {
     onCrop,
     onCancelCrop,
     isCropping,
-    onOcr,
+    isOCREnabled: !!customer?.features?.isDocumentOcrEnabled,
     selectedImageRef,
     initialImage,
     skeletons,
-    isLoadingOCR,
     selectedImage,
     onSelectImage,
     documentRotation,
diff --git a/apps/backoffice-v2/src/pages/Entity/components/Case/interfaces.ts b/apps/backoffice-v2/src/pages/Entity/components/Case/interfaces.ts
index c89aba044d..1ac14e0be9 100644
--- a/apps/backoffice-v2/src/pages/Entity/components/Case/interfaces.ts
+++ b/apps/backoffice-v2/src/pages/Entity/components/Case/interfaces.ts
@@ -48,7 +48,10 @@ export interface IDocumentsProps {
     fileName: string;
     title: string;
   }>;
+  onOcrPressed: () => void;
   isLoading?: boolean;
+  isLoadingOCR?: boolean;
+  isDocumentEditable?: boolean;
   hideOpenExternalButton?: boolean;
 }
 
diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml
index 2cd38ae123..202a67347e 100644
--- a/pnpm-lock.yaml
+++ b/pnpm-lock.yaml
@@ -211,8 +211,8 @@ importers:
         specifier: ^1.10.49
         version: 1.10.49
       lucide-react:
-        specifier: ^0.239.0
-        version: 0.239.0(react@18.2.0)
+        specifier: ^0.445.0
+        version: 0.445.0(react@18.2.0)
       match-sorter:
         specifier: ^6.3.1
         version: 6.3.1
@@ -29096,10 +29096,10 @@ packages:
       react: 18.2.0
     dev: false
 
-  /lucide-react@0.239.0(react@18.2.0):
-    resolution: {integrity: sha512-kMDFooh1QXW1xizangvXzj/M4OzH5Hpa8hplSaMcaOOuyjLwugjaqYCgZWXI66BUPLGVA/FomIhaWqbUurrXPg==}
+  /lucide-react@0.445.0(react@18.2.0):
+    resolution: {integrity: sha512-YrLf3aAHvmd4dZ8ot+mMdNFrFpJD7YRwQ2pUcBhgqbmxtrMP4xDzIorcj+8y+6kpuXBF4JB0NOCTUWIYetJjgA==}
     peerDependencies:
-      react: ^16.5.1 || ^17.0.0 || ^18.0.0
+      react: ^16.5.1 || ^17.0.0 || ^18.0.0 || ^19.0.0-rc
     dependencies:
       react: 18.2.0
     dev: false
diff --git a/services/workflows-service/src/business/business.service.ts b/services/workflows-service/src/business/business.service.ts
index e0ce4d94e9..7689f4b919 100644
--- a/services/workflows-service/src/business/business.service.ts
+++ b/services/workflows-service/src/business/business.service.ts
@@ -4,7 +4,7 @@ import {
   TCompanyInformation,
 } from '@/business/types/business-information';
 import { AppLoggerService } from '@/common/app-logger/app-logger.service';
-import { TCustomerWithDefinitionsFeatures } from '@/customer/types';
+import { TFeaturesWithFeatures } from '@/customer/types';
 import { env } from '@/env';
 import type { PrismaTransaction, TProjectIds } from '@/types';
 import { HttpService } from '@nestjs/axios';
@@ -31,7 +31,7 @@ export class BusinessService {
     return (await this.repository.findMany(args, projectIds)) as Array<
       Business & {
         metadata?: {
-          featureConfig?: TCustomerWithDefinitionsFeatures['features'];
+          featureConfig?: TFeaturesWithFeatures;
           lastOngoingAuditReportInvokedAt?: number;
         };
       }
diff --git a/services/workflows-service/src/common/utils/unified-api-client/unified-api-client.ts b/services/workflows-service/src/common/utils/unified-api-client/unified-api-client.ts
index 5338887f02..f3e3885462 100644
--- a/services/workflows-service/src/common/utils/unified-api-client/unified-api-client.ts
+++ b/services/workflows-service/src/common/utils/unified-api-client/unified-api-client.ts
@@ -2,6 +2,7 @@ import axios, { AxiosInstance } from 'axios';
 import { env } from '@/env';
 import { Logger } from '@nestjs/common';
 import { BusinessReportType } from '@prisma/client';
+import { TSchema } from '@sinclair/typebox';
 
 export type TReportRequest = Array<{
   websiteUrl: string;
@@ -14,6 +15,17 @@ export type TReportRequest = Array<{
   businessReportId?: string;
   withQualityControl?: boolean;
 }>;
+export type TOcrImages = Array<
+  | {
+      remote: {
+        imageUri: string;
+        mimeType: string;
+      };
+    }
+  | {
+      base64: string;
+    }
+>;
 
 export class UnifiedApiClient {
   private readonly axiosInstance: AxiosInstance;
@@ -74,4 +86,34 @@ export class UnifiedApiClient {
       throw error;
     }
   }
+
+  async runOcr({ images, schema }: { images: TOcrImages; schema: TSchema }) {
+    return await this.axiosInstance.post('/v1/smart-ocr', {
+      images,
+      schema,
+    });
+  }
+
+  async runDocumentOcr({
+    images,
+    supportedCountries,
+    overrideSchemas,
+  }: {
+    images: TOcrImages;
+    supportedCountries: string[];
+    overrideSchemas: {
+      overrideSchemas: Array<{
+        countryCode: string;
+        documentType: string;
+        documentCategory: string;
+        schema: TSchema;
+      }>;
+    };
+  }) {
+    return await this.axiosInstance.post('/v1/document/smart-ocr', {
+      images,
+      supportedCountries,
+      overrideSchemas,
+    });
+  }
 }
diff --git a/services/workflows-service/src/customer/types.ts b/services/workflows-service/src/customer/types.ts
index fdaececb46..036bc35e69 100644
--- a/services/workflows-service/src/customer/types.ts
+++ b/services/workflows-service/src/customer/types.ts
@@ -27,6 +27,8 @@ export type TOngoingAuditReportDefinitionConfig = {
   proxyViaCountry: string;
 };
 
+export type TFeaturesWithFeatures = Record<string, TCustomerFeatures>;
+
 export const CUSTOMER_FEATURES = {
   [FEATURE_LIST.ONGOING_MERCHANT_REPORT_T1]: {
     name: 'ONGOING_MERCHANT_REPORT_T1',
@@ -50,8 +52,8 @@ export const CUSTOMER_FEATURES = {
       proxyViaCountry: 'GB',
     },
   },
-} satisfies Record<string, TCustomerFeatures>;
+} satisfies TFeaturesWithFeatures;
 
 export type TCustomerWithDefinitionsFeatures = Customer & {
-  features?: Record<string, TCustomerFeatures> | null;
+  features?: TFeaturesWithFeatures | Record<string, boolean> | null;
 };
diff --git a/services/workflows-service/src/storage/storage.controller.internal.ts b/services/workflows-service/src/storage/storage.controller.internal.ts
index c7e5218ac9..a5591cfd1e 100644
--- a/services/workflows-service/src/storage/storage.controller.internal.ts
+++ b/services/workflows-service/src/storage/storage.controller.internal.ts
@@ -8,24 +8,12 @@ import type { Response } from 'express';
 import { StorageService } from './storage.service';
 import * as errors from '../errors';
 import { fileFilter } from './file-filter';
-import {
-  createPresignedUrlWithClient,
-  downloadFileFromS3,
-  manageFileByProvider,
-} from '@/storage/get-file-storage-manager';
-import { AwsS3FileConfig } from '@/providers/file/file-provider/aws-s3-file.config';
-import path from 'path';
-import os from 'os';
-import { File } from '@prisma/client';
-import { z } from 'zod';
-import { HttpFileService } from '@/providers/file/file-provider/http-file.service';
+import { manageFileByProvider } from '@/storage/get-file-storage-manager';
 import { ProjectIds } from '@/common/decorators/project-ids.decorator';
 import type { TProjectId, TProjectIds } from '@/types';
 import { CurrentProject } from '@/common/decorators/current-project.decorator';
-import { isBase64 } from '@/common/utils/is-base64/is-base64';
 import { AppLoggerService } from '@/common/app-logger/app-logger.service';
 import { HttpService } from '@nestjs/axios';
-import mime from 'mime';
 import { getFileMetadata } from '@/common/get-file-metadata/get-file-metadata';
 
 // Temporarily identical to StorageControllerExternal
@@ -114,67 +102,18 @@ export class StorageControllerInternal {
     @Res() res: Response,
     @Query('format') format: string,
   ) {
-    // currently ignoring user id due to no user info
-    const persistedFile = await this.service.getFileById({ id }, projectIds, {});
-
-    if (!persistedFile) {
-      throw new errors.NotFoundException('file not found');
-    }
-
-    const mimeType =
-      persistedFile.mimeType ||
-      mime.getType(persistedFile.fileName || persistedFile.uri || '') ||
-      undefined;
-
-    if (persistedFile.fileNameInBucket && format === 'signed-url') {
-      const signedUrl = await createPresignedUrlWithClient({
-        bucketName: AwsS3FileConfig.getBucketName(process.env) as string,
-        fileNameInBucket: persistedFile.fileNameInBucket,
-        mimeType,
-      });
+    const { mimeType, signedUrl, filePath } = await this.service.fetchFileContent({
+      id,
+      projectIds,
+      format,
+    });
 
+    if (signedUrl) {
       return res.json({ signedUrl, mimeType });
     }
 
     res.set('Content-Type', mimeType || 'application/octet-stream');
 
-    if (persistedFile.fileNameInBucket) {
-      const localFilePath = await downloadFileFromS3(
-        AwsS3FileConfig.getBucketName(process.env) as string,
-        persistedFile.fileNameInBucket,
-      );
-
-      return res.sendFile(localFilePath, { root: '/' });
-    }
-
-    if (!isBase64(persistedFile.uri) && this._isUri(persistedFile)) {
-      const downloadFilePath = await this.__downloadFileFromRemote(persistedFile);
-
-      return res.sendFile(this.__getAbsoluteFilePAth(downloadFilePath));
-    }
-
-    return res.sendFile(this.__getAbsoluteFilePAth(persistedFile.fileNameOnDisk));
-  }
-
-  private __getAbsoluteFilePAth(filePath: string) {
-    if (!path.isAbsolute(filePath)) return filePath;
-
-    const rootDir = path.parse(os.homedir()).root;
-
-    return path.join(rootDir, filePath);
-  }
-
-  private async __downloadFileFromRemote(persistedFile: File) {
-    const localeFilePath = `${os.tmpdir()}/${persistedFile.id}`;
-    const downloadedFilePath = await new HttpFileService({
-      client: this.httpService,
-      logger: this.logger,
-    }).download(persistedFile.uri, localeFilePath);
-
-    return downloadedFilePath;
-  }
-
-  _isUri(persistedFile: File) {
-    return z.string().url().safeParse(persistedFile.uri).success;
+    return res.sendFile(filePath!);
   }
 }
diff --git a/services/workflows-service/src/storage/storage.service.ts b/services/workflows-service/src/storage/storage.service.ts
index 0adf888b77..627c81f3e6 100644
--- a/services/workflows-service/src/storage/storage.service.ts
+++ b/services/workflows-service/src/storage/storage.service.ts
@@ -1,12 +1,31 @@
 import { Injectable } from '@nestjs/common';
 import { FileRepository } from './storage.repository';
 import { IFileIds } from './types';
-import { Prisma } from '@prisma/client';
+import { File, Prisma } from '@prisma/client';
 import type { TProjectId, TProjectIds } from '@/types';
+import * as errors from '@/errors';
+import mime from 'mime';
+import {
+  createPresignedUrlWithClient,
+  downloadFileFromS3,
+} from '@/storage/get-file-storage-manager';
+import { AwsS3FileConfig } from '@/providers/file/file-provider/aws-s3-file.config';
+import { isBase64 } from '@/common/utils/is-base64/is-base64';
+import path from 'path';
+import os from 'os';
+import { HttpFileService } from '@/providers/file/file-provider/http-file.service';
+import { z } from 'zod';
+import { HttpService } from '@nestjs/axios';
+import { AppLoggerService } from '@/common/app-logger/app-logger.service';
+import { readFileSync } from 'fs';
 
 @Injectable()
 export class StorageService {
-  constructor(protected readonly fileRepository: FileRepository) {}
+  constructor(
+    protected readonly fileRepository: FileRepository,
+    protected readonly httpService: HttpService,
+    protected readonly logger: AppLoggerService,
+  ) {}
 
   async createFileLink({
     uri,
@@ -44,4 +63,88 @@ export class StorageService {
   async getFileById({ id }: IFileIds, projectIds: TProjectIds, args?: Prisma.FileFindFirstArgs) {
     return await this.fileRepository.findById({ id }, args || {}, projectIds);
   }
+
+  async fetchFileContent({
+    id,
+    projectIds,
+    format,
+  }: {
+    id: string;
+    projectIds: TProjectIds;
+    format?: string;
+  }) {
+    const persistedFile = await this.getFileById({ id }, projectIds, {});
+
+    if (!persistedFile) {
+      throw new errors.NotFoundException('file not found');
+    }
+
+    let mimeType =
+      persistedFile.mimeType ||
+      mime.getType(persistedFile.fileName || persistedFile.uri || '') ||
+      'image/jpeg';
+
+    if (persistedFile.fileNameInBucket && format === 'signed-url') {
+      const signedUrl = await createPresignedUrlWithClient({
+        bucketName: AwsS3FileConfig.getBucketName(process.env) as string,
+        fileNameInBucket: persistedFile.fileNameInBucket,
+        mimeType,
+      });
+
+      return { signedUrl, mimeType };
+    }
+
+    mimeType ||= 'application/octet-stream';
+
+    if (persistedFile.fileNameInBucket) {
+      const localFilePath = await downloadFileFromS3(
+        AwsS3FileConfig.getBucketName(process.env) as string,
+        persistedFile.fileNameInBucket,
+      );
+
+      return { filePath: path.resolve('/', localFilePath), mimeType };
+    }
+
+    if (!isBase64(persistedFile.uri) && this._isUri(persistedFile)) {
+      const downloadFilePath = await this.__downloadFileFromRemote(persistedFile);
+
+      const filePath = this.__getAbsoluteFilePAth(downloadFilePath);
+
+      return { filePath: filePath, mimeType };
+    }
+
+    const filePath = this.__getAbsoluteFilePAth(persistedFile.fileNameOnDisk);
+
+    return { filePath: filePath, mimeType };
+  }
+
+  private __getAbsoluteFilePAth(filePath: string) {
+    if (!path.isAbsolute(filePath)) return filePath;
+
+    const rootDir = path.parse(os.homedir()).root;
+
+    return path.join(rootDir, filePath);
+  }
+
+  private async __downloadFileFromRemote(persistedFile: File) {
+    const localeFilePath = `${os.tmpdir()}/${persistedFile.id}`;
+    const downloadedFilePath = await new HttpFileService({
+      client: this.httpService,
+      logger: this.logger,
+    }).download(persistedFile.uri, localeFilePath);
+
+    return downloadedFilePath;
+  }
+
+  _isUri(persistedFile: File) {
+    return z.string().url().safeParse(persistedFile.uri).success;
+  }
+
+  fileToBase64(filepath: string): string {
+    const fileBuffer = readFileSync(filepath);
+
+    const base64String = fileBuffer.toString('base64');
+
+    return base64String;
+  }
 }
diff --git a/services/workflows-service/src/workflow/cron/ongoing-monitoring.cron.intg.test.ts b/services/workflows-service/src/workflow/cron/ongoing-monitoring.cron.intg.test.ts
index a400a6de7f..48855c4043 100644
--- a/services/workflows-service/src/workflow/cron/ongoing-monitoring.cron.intg.test.ts
+++ b/services/workflows-service/src/workflow/cron/ongoing-monitoring.cron.intg.test.ts
@@ -7,8 +7,8 @@ import { BusinessService } from '@/business/business.service';
 import { Business, Project } from '@prisma/client';
 import {
   FEATURE_LIST,
-  TCustomerFeatures,
   TCustomerWithDefinitionsFeatures,
+  TFeaturesWithFeatures,
   TOngoingAuditReportDefinitionConfig,
 } from '@/customer/types';
 import { BusinessReportService } from '@/business-report/business-report.service';
@@ -49,7 +49,6 @@ describe('OngoingMonitoringCron', () => {
       jest.spyOn(prismaService, 'acquireLock').mockResolvedValue(true);
       jest.spyOn(customerService, 'list').mockResolvedValue(mockCustomers());
       jest.spyOn(businessService, 'list').mockResolvedValue(mockBusinesses());
-      // Mock additional service methods as needed
 
       await service.handleCron();
 
@@ -232,7 +231,7 @@ describe('OngoingMonitoringCron', () => {
                 proxyViaCountry: 'US',
               } as TOngoingAuditReportDefinitionConfig,
             },
-          } as Record<string, TCustomerFeatures>,
+          } as TFeaturesWithFeatures,
         },
       },
       {
@@ -255,7 +254,7 @@ describe('OngoingMonitoringCron', () => {
                 proxyViaCountry: 'GB',
               } as TOngoingAuditReportDefinitionConfig,
             },
-          } as Record<string, TCustomerFeatures>,
+          } as TFeaturesWithFeatures,
         },
       },
       {
@@ -274,13 +273,13 @@ describe('OngoingMonitoringCron', () => {
                 proxyViaCountry: 'CA',
               } as TOngoingAuditReportDefinitionConfig,
             },
-          } as Record<string, TCustomerFeatures>,
+          } as TFeaturesWithFeatures,
         },
       },
     ] as unknown as Array<
       Business & {
         metadata?: {
-          featureConfig?: TCustomerWithDefinitionsFeatures['features'];
+          featureConfig?: TFeaturesWithFeatures;
           lastOngoingAuditReportInvokedAt?: number;
         };
       }
diff --git a/services/workflows-service/src/workflow/cron/ongoing-monitoring.cron.ts b/services/workflows-service/src/workflow/cron/ongoing-monitoring.cron.ts
index 7930f7c9fe..8047a42372 100644
--- a/services/workflows-service/src/workflow/cron/ongoing-monitoring.cron.ts
+++ b/services/workflows-service/src/workflow/cron/ongoing-monitoring.cron.ts
@@ -20,6 +20,7 @@ import { Injectable } from '@nestjs/common';
 import { Cron, CronExpression } from '@nestjs/schedule';
 import { Business, Project } from '@prisma/client';
 import get from 'lodash/get';
+import { isBoolean } from 'lodash';
 
 @Injectable()
 export class OngoingMonitoringCron {
@@ -141,6 +142,7 @@ export class OngoingMonitoringCron {
           customer.features &&
           Object.entries(customer.features).find(([featureName, featureConfig]) => {
             return (
+              !isBoolean(featureConfig) &&
               featureName === this.processFeatureName &&
               featureConfig.enabled &&
               featureConfig.options.active
@@ -171,13 +173,12 @@ export class OngoingMonitoringCron {
     return await Promise.all(customersWithDefinitionsPromise);
   }
 
-  private extractDefinitionConfig(
-    featureConfig: Record<string, TCustomerFeatures> | null | undefined,
-  ) {
+  private extractDefinitionConfig(featureConfig: TCustomerWithDefinitionsFeatures['features']) {
     if (!featureConfig) return null;
 
     return Object.entries(featureConfig).find(([featureName, featureConfig]) => {
       return (
+        !isBoolean(featureConfig) &&
         featureName === this.processFeatureName &&
         featureConfig.enabled &&
         featureConfig.options.active
diff --git a/services/workflows-service/src/workflow/workflow.controller.internal.ts b/services/workflows-service/src/workflow/workflow.controller.internal.ts
index ccddb26dc4..e6863c473d 100644
--- a/services/workflows-service/src/workflow/workflow.controller.internal.ts
+++ b/services/workflows-service/src/workflow/workflow.controller.internal.ts
@@ -338,6 +338,24 @@ export class WorkflowControllerInternal {
     }
   }
 
+  @common.Get(':id/documents/:documentId/run-ocr')
+  @swagger.ApiOkResponse({ type: WorkflowDefinitionModel })
+  @swagger.ApiNotFoundResponse({ type: errors.NotFoundException })
+  @swagger.ApiForbiddenResponse({ type: errors.ForbiddenException })
+  @UseGuards(WorkflowAssigneeGuard)
+  async runDocumentOcr(
+    @common.Param() params: DocumentUpdateParamsInput,
+    @CurrentProject() currentProjectId: TProjectId,
+  ) {
+    const ocrResult = await this.service.runOCROnDocument({
+      workflowRuntimeId: params?.id,
+      documentId: params?.documentId,
+      projectId: currentProjectId,
+    });
+
+    return ocrResult;
+  }
+
   // @nestAccessControl.UseRoles({
   //   resource: 'Workflow',
   //   action: 'delete',
diff --git a/services/workflows-service/src/workflow/workflow.service.ts b/services/workflows-service/src/workflow/workflow.service.ts
index f5a12c855d..ef0fc6103a 100644
--- a/services/workflows-service/src/workflow/workflow.service.ts
+++ b/services/workflows-service/src/workflow/workflow.service.ts
@@ -88,7 +88,7 @@ import {
   WorkflowRuntimeData,
   WorkflowRuntimeDataStatus,
 } from '@prisma/client';
-import { Static } from '@sinclair/typebox';
+import { Static, TSchema } from '@sinclair/typebox';
 import { plainToClass } from 'class-transformer';
 import dayjs from 'dayjs';
 import { isEqual, merge } from 'lodash';
@@ -108,6 +108,8 @@ import { addPropertiesSchemaToDocument } from './utils/add-properties-schema-to-
 import { entitiesUpdate } from './utils/entities-update';
 import { WorkflowEventEmitterService } from './workflow-event-emitter.service';
 import { WorkflowRuntimeDataRepository } from './workflow-runtime-data.repository';
+import { StorageService } from '@/storage/storage.service';
+import { TOcrImages, UnifiedApiClient } from '@/common/utils/unified-api-client/unified-api-client';
 import { AwsSecretsManager } from '@/secrets-manager/aws-secrets-manager';
 import { InMemorySecretsManager } from '@/secrets-manager/in-memory-secrets-manager';
 
@@ -150,6 +152,7 @@ export class WorkflowService {
     private readonly ruleEngineService: RuleEngineService,
     private readonly sentry: SentryService,
     private readonly secretsManagerFactory: SecretsManagerFactory,
+    private readonly storageService: StorageService,
   ) {}
 
   async createWorkflowDefinition(data: WorkflowDefinitionCreateDto) {
@@ -2542,4 +2545,106 @@ export class WorkflowService {
       data: args,
     });
   }
+
+  async findDocumentById({
+    workflowId,
+    projectId,
+    documentId,
+    transaction,
+  }: {
+    workflowId: string;
+    projectId: string;
+    documentId: string;
+    transaction: PrismaTransaction | PrismaClient;
+  }) {
+    const runtimeData = await this.workflowRuntimeDataRepository.findByIdAndLock(
+      workflowId,
+      {},
+      [projectId],
+      transaction,
+    );
+    const workflowDef = await this.workflowDefinitionRepository.findById(
+      runtimeData.workflowDefinitionId,
+      {},
+      [projectId],
+      transaction,
+    );
+    const document = runtimeData?.context?.documents?.find(
+      (document: DefaultContextSchema['documents'][number]) => document.id === documentId,
+    );
+
+    return addPropertiesSchemaToDocument(document, workflowDef.documentsSchema);
+  }
+
+  async runOCROnDocument({
+    workflowRuntimeId,
+    projectId,
+    documentId,
+  }: {
+    workflowRuntimeId: string;
+    projectId: string;
+    documentId: string;
+  }) {
+    const ocrResult = await this.prismaService.$transaction(
+      async transaction => {
+        const customer = await this.customerService.getByProjectId(projectId);
+
+        if (customer.features?.['isDocumentOcrEnabled'] === true) {
+          throw new BadRequestException('Document OCR is not enabled for this customer');
+        }
+
+        const document = await this.findDocumentById({
+          workflowId: workflowRuntimeId,
+          projectId,
+          documentId,
+          transaction,
+        });
+
+        if (!('pages' in document)) {
+          throw new BadRequestException('Cannot run document OCR on document without pages');
+        }
+
+        const documentFetchPagesContentPromise = document.pages.map(async page => {
+          const ballerineFileId = page.ballerineFileId;
+
+          if (!ballerineFileId) {
+            throw new BadRequestException('Cannot run document OCR on document without pages');
+          }
+
+          const { signedUrl, mimeType, filePath } = await this.storageService.fetchFileContent({
+            id: ballerineFileId,
+            format: 'signed-url',
+            projectIds: [projectId],
+          });
+
+          if (signedUrl) {
+            return {
+              remote: {
+                imageUri: signedUrl,
+                mimeType,
+              },
+            };
+          }
+
+          const base64String = this.storageService.fileToBase64(filePath!);
+
+          return { base64: `data:${mimeType};base64,${base64String}` };
+        });
+
+        const images = (await Promise.all(documentFetchPagesContentPromise)) satisfies TOcrImages;
+
+        return (
+          await new UnifiedApiClient().runOcr({
+            images,
+            schema: document.propertiesSchema as unknown as TSchema,
+          })
+        )?.data;
+      },
+      {
+        timeout: 180_000,
+      },
+    );
+
+    return ocrResult;
+  }
 }
diff --git a/services/workflows-service/src/workflow/workflow.service.unit.test.ts b/services/workflows-service/src/workflow/workflow.service.unit.test.ts
index 53ab279fc5..17b19e3914 100644
--- a/services/workflows-service/src/workflow/workflow.service.unit.test.ts
+++ b/services/workflows-service/src/workflow/workflow.service.unit.test.ts
@@ -207,6 +207,7 @@ describe('WorkflowService', () => {
       ruleEngineService,
       {} as any,
       {} as any,
+      {} as any,
     );
   });