Adam
591aa08da4
- True runs remember captured text per (tab path, node) with a token. Off runs whose widget hadn't received it use the remembered text and update the embedded metadata. IS_CHANGED includes the carried token, so prompts queued ahead pick it up - Scope pushed prompt updates to the tab the run was queued from, fixing captured text overwriting a same-id node in another open workflow - Nodes fetch missed text when a workflow loads or its tab is re-opened - In-memory only; tokens are compared by equality, so restarts are safe - Saver and Passthrough get hidden stash_tab/stash_token inputs (appended last, no socket or widget, not saved in widgets_values)
196 lines
8.7 KiB
Python
196 lines
8.7 KiB
Python
import comfy
|
|
from server import PromptServer
|
|
from aiohttp import web
|
|
import time
|
|
import hashlib
|
|
from comfy.model_management import InterruptProcessingException
|
|
from .data_utils import update_node_in_workflow, prompt_has_input
|
|
from . import stash_sync
|
|
|
|
class PromptStashPassthrough:
|
|
status_by_id = {} # Track pause status for each node instance
|
|
edited_text_by_id = {} # Store edited text during pause
|
|
|
|
@classmethod
|
|
def INPUT_TYPES(s):
|
|
return {
|
|
"required": {
|
|
},
|
|
"optional": {
|
|
"use_input_text": ("BOOLEAN", {"default": False, "label_on": "Use Input", "label_off": "Use Prompt"}),
|
|
"text": ("STRING", {"default": "", "forceInput": True, "tooltip": "Optional input text", "lazy": True}),
|
|
"prompt_text": ("STRING", {"multiline": True, "default": "", "placeholder": "Enter prompt text"}),
|
|
"pause_to_edit": ("BOOLEAN", {"default": False, "label_on": "Yes", "label_off": "No"}),
|
|
# Filled in by the frontend at queue time (hidden, no socket);
|
|
# used to carry input text forward to later runs. See stash_sync.py.
|
|
"stash_tab": ("STRING", {"default": "", "forceInput": True}),
|
|
"stash_token": ("STRING", {"default": "", "forceInput": True}),
|
|
},
|
|
"hidden": {
|
|
"unique_id": "UNIQUE_ID",
|
|
"extra_pnginfo": "EXTRA_PNGINFO",
|
|
"prompt": "PROMPT",
|
|
}
|
|
}
|
|
|
|
RETURN_TYPES = ("STRING",)
|
|
RETURN_NAMES = ("text",)
|
|
FUNCTION = "process"
|
|
CATEGORY = "utils"
|
|
|
|
|
|
@classmethod
|
|
def IS_CHANGED(cls, use_input_text=False, text="", prompt_text="", pause_to_edit=False, stash_tab="", stash_token="", unique_id=None, extra_pnginfo=None, prompt=None):
|
|
m = hashlib.sha256()
|
|
|
|
# Always include these parameters as they affect the output
|
|
m.update(str(use_input_text).encode())
|
|
m.update(str(prompt_text).encode())
|
|
m.update(str(unique_id).encode())
|
|
|
|
# Text carried forward from a True run (see stash_sync.py). IS_CHANGED
|
|
# runs when the prompt starts executing, so prompts queued ahead see it.
|
|
carried = stash_sync.carried_entry(stash_tab, unique_id, stash_token)
|
|
m.update(str(carried["token"] if carried else "").encode())
|
|
|
|
# Only include the text input if use_input_text is True
|
|
if use_input_text and text is not None:
|
|
m.update(str(text).encode())
|
|
|
|
return m.hexdigest()
|
|
|
|
def check_lazy_status(self, use_input_text=False, text="", prompt_text="", pause_to_edit=False, stash_tab="", stash_token="", unique_id=None, extra_pnginfo=None, prompt=None):
|
|
needed = []
|
|
if use_input_text:
|
|
if not prompt_has_input(prompt, unique_id, "text"):
|
|
raise ValueError(
|
|
f"Prompt Stash Passthrough (node {unique_id}): 'use_input_text' is on, but nothing "
|
|
"is connected to the 'text' input. Connect a text input or switch to 'Use Prompt'."
|
|
)
|
|
needed.append("text")
|
|
return needed
|
|
|
|
def process(self, use_input_text=False, text="", prompt_text="", pause_to_edit=False, stash_tab="", stash_token="", unique_id=None, extra_pnginfo=None, prompt=None):
|
|
from_input = bool(use_input_text and text is not None)
|
|
|
|
# Update the prompt text based on use_input_text toggle
|
|
output_text = prompt_text
|
|
if from_input:
|
|
output_text = text
|
|
# Remember it so later runs use it even if the frontend misses the
|
|
# push below, then tell the frontend (only the matching tab applies it).
|
|
token = stash_sync.store_text(stash_tab, unique_id, text)
|
|
stash_sync.push_update(unique_id, text, stash_tab, token)
|
|
else:
|
|
# Off run: if a True run produced text the frontend hadn't taken in
|
|
# when this prompt was queued, use that instead of the stale widget.
|
|
carried = stash_sync.carried_entry(stash_tab, unique_id, stash_token)
|
|
if carried:
|
|
from_input = True
|
|
output_text = carried["text"]
|
|
stash_sync.push_update(unique_id, output_text, stash_tab, carried["token"])
|
|
|
|
# Handle pausing if pause_to_edit is enabled
|
|
if pause_to_edit:
|
|
# Set status to paused and notify frontend
|
|
self.status_by_id[unique_id] = "paused"
|
|
PromptServer.instance.send_sync("prompt-stash-set-continue", {
|
|
"node_id": unique_id,
|
|
"show": True
|
|
})
|
|
|
|
# Track iterations for periodic sync
|
|
iteration_count = 0
|
|
sync_interval = 20 # Send sync every 20 iterations (2 seconds at 0.1s sleep)
|
|
|
|
# Wait in loop until continued
|
|
while self.status_by_id.get(unique_id) == "paused":
|
|
iteration_count += 1
|
|
|
|
# Resend sync signal every 20 iterations
|
|
if iteration_count % sync_interval == 0:
|
|
PromptServer.instance.send_sync("prompt-stash-set-continue", {
|
|
"node_id": unique_id,
|
|
"show": True
|
|
})
|
|
|
|
time.sleep(0.1)
|
|
|
|
# Get the edited text that was sent with the continue signal
|
|
if unique_id in self.edited_text_by_id:
|
|
output_text = self.edited_text_by_id[unique_id]
|
|
del self.edited_text_by_id[unique_id]
|
|
|
|
# Clean up status
|
|
if unique_id in self.status_by_id:
|
|
del self.status_by_id[unique_id]
|
|
|
|
# Keep the remembered text in step with the edit (same token, so a
|
|
# frontend that already has this token keeps using its widget).
|
|
stash_sync.replace_text(stash_tab, unique_id, output_text)
|
|
|
|
if from_input or pause_to_edit:
|
|
|
|
# Handle both list and dict formats of extra_pnginfo
|
|
workflow = None
|
|
if isinstance(extra_pnginfo, list) and len(extra_pnginfo) > 0:
|
|
workflow = extra_pnginfo[0].get("workflow")
|
|
elif isinstance(extra_pnginfo, dict):
|
|
workflow = extra_pnginfo.get("workflow")
|
|
|
|
if workflow:
|
|
|
|
def apply_stash_changes(node):
|
|
if "widgets_values" in node:
|
|
# Note: forceInput fields (like 'text') don't count in the widget_values indexing
|
|
use_input_text_index = 0 # First widget in optional inputs
|
|
prompt_text_index = 1 # Second widget (excluding forceInput)
|
|
pause_to_edit_index = 2 # Third widget
|
|
|
|
# Safety check, make sure there are at least 3 elements
|
|
if len(node["widgets_values"]) > pause_to_edit_index:
|
|
node["widgets_values"][use_input_text_index] = False # Force use_input_text to False
|
|
node["widgets_values"][prompt_text_index] = output_text # Update the prompt text
|
|
node["widgets_values"][pause_to_edit_index] = False # Force pause_to_edit to False
|
|
|
|
update_node_in_workflow(workflow, unique_id, apply_stash_changes)
|
|
|
|
|
|
if prompt and unique_id is not None:
|
|
node_id_str = str(unique_id)
|
|
if node_id_str in prompt:
|
|
prompt[node_id_str]['inputs']['use_input_text'] = False
|
|
prompt[node_id_str]['inputs']['prompt_text'] = output_text
|
|
|
|
return (output_text,)
|
|
|
|
# Add route for continue button
|
|
@PromptServer.instance.routes.post("/prompt_stash_passthrough/continue/{node_id}")
|
|
async def continue_node(request):
|
|
node_id = request.match_info["node_id"].strip()
|
|
data = await request.json()
|
|
edited_text = data.get("text", "")
|
|
|
|
if node_id in PromptStashPassthrough.status_by_id:
|
|
PromptStashPassthrough.edited_text_by_id[node_id] = edited_text
|
|
PromptStashPassthrough.status_by_id[node_id] = "continue"
|
|
return web.json_response({"status": "ok"})
|
|
|
|
@PromptServer.instance.routes.post("/prompt_stash_passthrough/clear_all")
|
|
async def clear_all_paused(request):
|
|
# Get all paused node IDs before clearing
|
|
paused_node_ids = list(PromptStashPassthrough.status_by_id.keys())
|
|
|
|
# Clear the backend state
|
|
PromptStashPassthrough.status_by_id.clear()
|
|
PromptStashPassthrough.edited_text_by_id.clear()
|
|
|
|
# Notify frontend to hide continue buttons for all paused nodes
|
|
for node_id in paused_node_ids:
|
|
PromptServer.instance.send_sync("prompt-stash-set-continue", {
|
|
"node_id": node_id,
|
|
"show": False
|
|
})
|
|
|
|
return web.json_response({"status": "ok"})
|