Spaces:
Running
on
Zero
Running
on
Zero
File size: 3,969 Bytes
f36e497 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 |
def inject(assembler, chain_definition, chain_items):
if not chain_items:
return
ksampler_name = chain_definition.get('ksampler_node', 'ksampler')
target_node_id = None
target_input_name = None
if ksampler_name in assembler.node_map:
ksampler_id = assembler.node_map[ksampler_name]
if 'positive' in assembler.workflow[ksampler_id]['inputs']:
target_node_id = ksampler_id
target_input_name = 'positive'
print(f"Conditioning injector targeting KSampler node '{ksampler_name}'.")
else:
print(f"Warning: KSampler node '{ksampler_name}' for Conditioning chain not found. Skipping.")
return
if not target_node_id:
print("Warning: Conditioning chain could not find a valid injection point (KSampler may be missing 'positive' input). Skipping.")
return
clip_source_str = chain_definition.get('clip_source')
if not clip_source_str:
print("Warning: 'clip_source' definition missing in the recipe for the Conditioning chain. Skipping.")
return
clip_node_name, clip_idx_str = clip_source_str.split(':')
if clip_node_name not in assembler.node_map:
print(f"Warning: CLIP source node '{clip_node_name}' for Conditioning chain not found. Skipping.")
return
clip_connection = [assembler.node_map[clip_node_name], int(clip_idx_str)]
original_positive_connection = assembler.workflow[target_node_id]['inputs'][target_input_name]
area_conditioning_outputs = []
for item_data in chain_items:
prompt = item_data.get('prompt', '')
if not prompt or not prompt.strip():
continue
text_encode_id = assembler._get_unique_id()
text_encode_node = assembler._get_node_template("CLIPTextEncode")
text_encode_node['inputs']['text'] = prompt
text_encode_node['inputs']['clip'] = clip_connection
assembler.workflow[text_encode_id] = text_encode_node
set_area_id = assembler._get_unique_id()
set_area_node = assembler._get_node_template("ConditioningSetArea")
set_area_node['inputs']['width'] = item_data.get('width', 1024)
set_area_node['inputs']['height'] = item_data.get('height', 1024)
set_area_node['inputs']['x'] = item_data.get('x', 0)
set_area_node['inputs']['y'] = item_data.get('y', 0)
set_area_node['inputs']['strength'] = item_data.get('strength', 1.0)
set_area_node['inputs']['conditioning'] = [text_encode_id, 0]
assembler.workflow[set_area_id] = set_area_node
area_conditioning_outputs.append([set_area_id, 0])
if not area_conditioning_outputs:
return
current_combined_conditioning = area_conditioning_outputs[0]
if len(area_conditioning_outputs) > 1:
for i in range(1, len(area_conditioning_outputs)):
combine_id = assembler._get_unique_id()
combine_node = assembler._get_node_template("ConditioningCombine")
combine_node['inputs']['conditioning_1'] = current_combined_conditioning
combine_node['inputs']['conditioning_2'] = area_conditioning_outputs[i]
assembler.workflow[combine_id] = combine_node
current_combined_conditioning = [combine_id, 0]
final_combine_id = assembler._get_unique_id()
final_combine_node = assembler._get_node_template("ConditioningCombine")
final_combine_node['inputs']['conditioning_1'] = original_positive_connection
final_combine_node['inputs']['conditioning_2'] = current_combined_conditioning
assembler.workflow[final_combine_id] = final_combine_node
assembler.workflow[target_node_id]['inputs'][target_input_name] = [final_combine_id, 0]
print(f"Conditioning injector applied. Redirected '{target_input_name}' input with {len(area_conditioning_outputs)} regional prompts.") |