Bind synthetic publisher module to test-scoped validated feed source; retain real integrity validation

Author: merberg-ai

tests/test_publication_manual_handoff.py

@@ -182,7 +182,7 @@ def test_stale_automatic_selection_does_not_send_after_owner_handoff(self):
             self.existing(db)
             common.set_setting(db,"auto_enabled","1")
         with common.connect() as db:
-            self.assertIsNotNone(worker.load_record(RID))
+            self.assertIsNotNone(common.load_record(RID))
             self.assertEqual(db.execute("SELECT approval_sha256,post_id,draft_comment "
               "FROM publish_jobs WHERE run_id=?",(RID,)).fetchone(),
                 (self.record["approval_sha256"],PID,self.record["draft_comment"]))
@@ -197,6 +197,7 @@ def get_then_approve(method,path,*args,**kwargs):
             return {"post":{"id":PID}}
         with common.connect() as db, \
             patch.object(worker,"auto_candidates",return_value=0), \
+            patch.object(worker,"load_record",side_effect=common.load_record), \
             patch.object(worker,"allow_auto_candidate",return_value=True), \
             patch.object(worker,"checkpoint"), \
             patch.object(worker,"can_send",return_value=(True,"")), \
@@ -215,7 +216,7 @@ def test_existing_manual_publisher_path_claims_one_send(self):
             self.approve(db)
             common.queue_manual(db,RID)
         with common.connect() as db:
-            self.assertIsNotNone(worker.load_record(RID))
+            self.assertIsNotNone(common.load_record(RID))
             self.assertEqual(db.execute("SELECT approval_sha256,post_id,draft_comment "
               "FROM publish_jobs WHERE run_id=?",(RID,)).fetchone(),
                 (self.record["approval_sha256"],PID,self.record["draft_comment"]))
@@ -227,6 +228,7 @@ def stub(method,path,*args,**kwargs):
             return {"success":True,"comment":{"id":"11111111-2222-3333-4444-555555555555"}}
         with common.connect() as db, \
             patch.object(worker,"auto_candidates",return_value=0), \
+            patch.object(worker,"load_record",side_effect=common.load_record), \
             patch.object(worker,"checkpoint"), \
             patch.object(worker,"can_send",return_value=(True,"")), \
             patch.object(worker,"api",side_effect=stub), \