fixes

pytorrent/services/automation_rules.py

@@ -370,7 +370,7 @@ def _enqueue_automation_job(profile: dict[str, Any], rule: dict[str, Any], actio
         if action_name == 'move':
             extra.update({'target_path': str(part_payload.get('path') or ''), 'move_data': bool(part_payload.get('move_data'))})
         if action_name == 'profile_transfer':
-            extra.update({'target_profile_id': int(part_payload.get('target_profile_id') or 0), 'target_path': str(part_payload.get('target_path') or ''), 'move_data': bool(part_payload.get('move_data')), 'post_action': str(part_payload.get('post_action') or 'none')})
+            extra.update({'target_profile_id': int(part_payload.get('target_profile_id') or 0), 'target_path': str(part_payload.get('target_path') or ''), 'move_data': bool(part_payload.get('move_data')), 'post_action': str(part_payload.get('post_action') or 'current')})
         if action_name == 'remove':
             extra.update({'remove_data': bool(part_payload.get('remove_data'))})
         effect_type = str(context_extra.get('effect_type') if context_extra else action_name)
@@ -435,9 +435,9 @@ def _automation_profile_transfer_payload(profile: dict[str, Any], eff: dict[str,
         move_data = bool(check.get('ok'))
         if not move_data:
             downgrade_reason = str(check.get('message') or check.get('error') or 'target path is not writable by source rTorrent user')
-    post_action = str(eff.get('post_action') or 'none').strip().lower()
-    if post_action not in {'none', 'start', 'stop', 'pause', 'check', 'recheck'}:
-        post_action = 'none'
+    post_action = str(eff.get('post_action') or 'current').strip().lower()
+    if post_action not in {'none', 'current', 'start', 'stop', 'pause', 'check', 'recheck'}:
+        post_action = 'current'
     label_mode = str(eff.get('label_mode') or 'none').strip().lower()
     if label_mode not in {'none', 'custom', 'moved_from', 'moved_to'}:
         label_mode = 'none'

pytorrent/services/download_planner.py

@@ -583,16 +583,10 @@ def start_scheduler(socketio=None) -> None:
     def loop():
         while True:
             try:
-                from .preferences import active_profile
                 from .websocket import emit_profile_event
-                from . import auth
                 profiles: list[dict]
-                if auth.enabled():
-                    with connect() as conn:
-                        profiles = conn.execute("SELECT * FROM rtorrent_profiles ORDER BY id").fetchall()
-                else:
-                    profile = active_profile()
-                    profiles = [profile] if profile else []
+                with connect() as conn:
+                    profiles = [dict(row) for row in conn.execute("SELECT * FROM rtorrent_profiles ORDER BY id").fetchall()]
                 for profile in profiles:
                     try:
                         result = enforce(profile, force=False)

pytorrent/services/rss.py

@@ -200,7 +200,10 @@ def start_scheduler(socketio=None) -> None:
                 with connect() as conn:
                     profiles = conn.execute("SELECT DISTINCT profile_id FROM rss_feeds WHERE enabled=1 AND profile_id IS NOT NULL").fetchall()
                 for row in profiles:
-                    profile = get_profile(int(row["profile_id"]))
+                    profile_id = int(row["profile_id"])
+                    with connect() as conn:
+                        owner = conn.execute("SELECT user_id FROM rtorrent_profiles WHERE id=?", (profile_id,)).fetchone()
+                    profile = get_profile(profile_id, int(owner["user_id"] if owner and owner.get("user_id") else default_user_id()))
                     if profile:
                         result = check(profile, only_due=True)
                         if socketio and result.get("queued"):

pytorrent/services/rtorrent/torrents.py

@@ -842,7 +842,7 @@ def transfer_profile(source_profile: dict, target_profile: dict, torrent_hashes:
     target_path = _remote_clean_path(payload.get("target_path") or payload.get("path") or "")
     move_data = bool(payload.get("move_data"))
     post_action = str(payload.get("post_action") or "none").strip().lower()
-    if post_action not in {"none", "start", "stop", "pause", "check", "recheck"}:
+    if post_action not in {"none", "current", "start", "stop", "pause", "check", "recheck"}:
         raise ValueError("Unsupported post-transfer action")
     label_mode = str(payload.get("label_mode") or "none").strip().lower()
     label_value = str(payload.get("label_value") or "").strip()
@@ -902,8 +902,8 @@ def transfer_profile(source_profile: dict, target_profile: dict, torrent_hashes:
             move_result = _move_profile_transfer_data(source_client, h, target_path)
             item.update(move_result)
             moved_to = str(move_result.get("moved_to") or "")
-        # Note: Explicit post-transfer actions override state restoration and keep command effects predictable.
-        start_on_target = bool(move_data and (was_state or was_active)) if post_action == "none" else post_action == "start"
+        # Note: The default keeps the torrent status from the source profile; explicit actions override it.
+        start_on_target = bool(was_state or was_active) if post_action in {"none", "current"} else post_action == "start"
         try:
             added = add_torrent_raw(target_profile, data, start_on_target, target_path, target_label)
             if not added.get("ok"):