From 3e3cd20757ab49765bf34dec32e11c45af1ffb2e Mon Sep 17 00:00:00 2001
From: yxd92326 <stephen.riggs@diamond.ac.uk>
Date: Tue, 31 Mar 2026 14:26:30 +0100
Subject: [PATCH] Send smartem results to murfey

---
 recipes/ispyb/em-spa-preprocess.json      | 11 +++++++++--
 src/cryoemservices/services/ctffind.py    |  3 ++-
 src/cryoemservices/services/motioncorr.py |  1 +
 3 files changed, 12 insertions(+), 3 deletions(-)

diff --git a/recipes/ispyb/em-spa-preprocess.json b/recipes/ispyb/em-spa-preprocess.json
index 155deafd..7c1b8fc8 100644
--- a/recipes/ispyb/em-spa-preprocess.json
+++ b/recipes/ispyb/em-spa-preprocess.json
@@ -18,9 +18,11 @@
       "icebreaker": 6,
       "images": 5,
       "ispyb_connector": 4,
-      "node_creator": 3
+      "node_creator": 3,
+      "smartem": 10
     },
     "parameters": {
+      "app_id": "{autoproc_program_id}",
       "do_icebreaker_jobs": "{do_icebreaker_jobs}",
       "dose_per_frame": "{fm_dose}",
       "eer_sampling": 1,
@@ -78,11 +80,15 @@
     "service": "IceBreaker"
   },
   "8": {
+    "parameters": {
+      "app_id": "{autoproc_program_id}"
+    },
     "output": {
       "cryolo": 9,
       "images": 5,
       "ispyb_connector": 4,
-      "node_creator": 3
+      "node_creator": 3,
+      "smartem": 10
     },
     "queue": "ctffind",
     "service": "CTFFind"
@@ -95,6 +101,7 @@
       "node_creator": 3
     },
     "parameters": {
+      "app_id": "{autoproc_program_id}",
       "particle_diameter": "{particle_diameter}",
       "cryolo_model_weights": "{cryolo_model_weights}",
       "retained_fraction": "0.7"
diff --git a/src/cryoemservices/services/ctffind.py b/src/cryoemservices/services/ctffind.py
index cf7dada6..9e426290 100644
--- a/src/cryoemservices/services/ctffind.py
+++ b/src/cryoemservices/services/ctffind.py
@@ -354,7 +354,8 @@ def ctf_find(self, rw, header: dict, message: dict):
                 rw.send_to(
                     "smartem",
                     {
-                        "ctf_max_resolution_estimate": self.estimated_resolution,
+                        "register": "spa.ctf_estimated",
+                        "ctf_max_resolution": self.estimated_resolution,
                         "ice_ring_density": ice_ring_density,
                         "app_id": ctf_params.app_id,
                         "mc_uuid": ctf_params.mc_uuid,
diff --git a/src/cryoemservices/services/motioncorr.py b/src/cryoemservices/services/motioncorr.py
index 5314648b..2a9daba5 100644
--- a/src/cryoemservices/services/motioncorr.py
+++ b/src/cryoemservices/services/motioncorr.py
@@ -737,6 +737,7 @@ def motion_correction(self, rw, header: dict, message: dict):
             rw.send_to(
                 "smartem",
                 {
+                    "register": "spa.motion_corrected",
                     "total_motion": total_motion,
                     "average_motion": average_motion_per_frame,
                     "app_id": mc_params.app_id,