From f748a01aab5cfd3ff993436ea2bf60054e2e4aed Mon Sep 17 00:00:00 2001
From: Eileen McNaughton <emcnaughton@wikimedia.org>
Date: Thu, 24 Nov 2022 16:43:09 +1300
Subject: [PATCH] Over-ride monitor page within the extension

This gives us a usable monitoring page for imports, without having to plan
out a solution that covers all potential use cases.

It should be a quick way to get this functionality operational
---
 ext/civiimport/civiimport.php                 | 28 ++++++++++++++++++-
 .../templates/CRM/Import/Monitor.tpl          | 15 ++++++++++
 2 files changed, 42 insertions(+), 1 deletion(-)
 create mode 100644 ext/civiimport/templates/CRM/Import/Monitor.tpl

diff --git a/ext/civiimport/civiimport.php b/ext/civiimport/civiimport.php
index fe0aa5c517e7..556e79e25dc9 100644
--- a/ext/civiimport/civiimport.php
+++ b/ext/civiimport/civiimport.php
@@ -1,5 +1,6 @@
 <?php
 
+use Civi\API\Exception\UnauthorizedException;
 use Civi\Api4\Mapping;
 use Civi\Api4\UserJob;
 use Civi\BAO\Import;
@@ -157,11 +158,36 @@ function _civiimport_civicrm_get_import_tables(): array {
  * @param string $templateFile
  *
  * @noinspection PhpUnusedParameterInspection
+ * @throws \CRM_Core_Exception
  */
-function civiimport_civicrm_alterTemplateFile($formName, $form, $type, &$templateFile) {
+function civiimport_civicrm_alterTemplateFile($formName, $form, $type, &$templateFile): void {
   if ($formName === 'CRM_Contribute_Import_Form_MapField') {
     $templateFile = 'CRM/Import/MapField.tpl';
   }
+  if ($formName === 'CRM_Queue_Page_Monitor') {
+    $jobName = CRM_Utils_Request::retrieveValue('name', 'String');
+    if (strpos($jobName, 'user_job_') === 0) {
+      try {
+        $userJobID = (int) str_replace('user_job_', '', $jobName);
+        $jobType = UserJob::get()->addWhere('id', '=', $userJobID)
+          ->execute()->first()['job_type'];
+        foreach (CRM_Core_BAO_UserJob::getTypes() as $userJobType) {
+          if ($userJobType['id'] === $jobType
+            && is_subclass_of($userJobType['class'], 'CRM_Import_Parser')
+          ) {
+
+            $templateFile = 'CRM/Import/Monitor.tpl';
+            Civi::resources()
+              ->addVars('civiimport', ['url' => CRM_Utils_System::url('civicrm/import/contact/summary', ['reset' => 1, 'user_job_id' => $userJobID])]);
+            break;
+          }
+        }
+      }
+      catch (UnauthorizedException $e) {
+        // We will not do anything here if not permissioned - leave it for the core page.
+      }
+    }
+  }
 }
 
 /**
diff --git a/ext/civiimport/templates/CRM/Import/Monitor.tpl b/ext/civiimport/templates/CRM/Import/Monitor.tpl
new file mode 100644
index 000000000000..d26134e448d6
--- /dev/null
+++ b/ext/civiimport/templates/CRM/Import/Monitor.tpl
@@ -0,0 +1,15 @@
+<div id='crm-import-progress'></div>
+{literal}
+  <script>
+    var target = '#crm-import-progress';
+    var url = CRM.vars.civiimport.url;
+    // Load the snippet into the container
+    CRM.loadPage(url, {
+      target: target,
+      block: false
+    })
+    window.setInterval(function() {
+      CRM.$(target).crmSnippet('refresh');
+    }, 1000);
+  </script>
+{/literal}