Spaces:
Running on Zero
Running on Zero
| def inject(assembler, chain_definition, chain_items): | |
| if not chain_items: | |
| return | |
| ksampler_name = chain_definition.get('ksampler_node', 'ksampler') | |
| flux_guidance_name = chain_definition.get('flux_guidance_node') | |
| vae_node_name = chain_definition.get('vae_node', 'vae_loader') | |
| if ksampler_name not in assembler.node_map: | |
| print(f"Warning: [ReferenceLatent] KSampler node '{ksampler_name}' not found. Skipping.") | |
| return | |
| if vae_node_name not in assembler.node_map: | |
| print(f"Warning: [ReferenceLatent] VAE loader node '{vae_node_name}' not found. Skipping.") | |
| return | |
| ksampler_id = assembler.node_map[ksampler_name] | |
| vae_node_id = assembler.node_map[vae_node_name] | |
| pos_target_node_id = None | |
| pos_target_input_name = None | |
| if flux_guidance_name and flux_guidance_name in assembler.node_map: | |
| flux_guidance_id = assembler.node_map[flux_guidance_name] | |
| if 'conditioning' in assembler.workflow[flux_guidance_id]['inputs']: | |
| pos_target_node_id = flux_guidance_id | |
| pos_target_input_name = 'conditioning' | |
| print(f"ReferenceLatent injector targeting FluxGuidance node '{flux_guidance_name}'.") | |
| if not pos_target_node_id: | |
| if 'positive' in assembler.workflow[ksampler_id]['inputs']: | |
| pos_target_node_id = ksampler_id | |
| pos_target_input_name = 'positive' | |
| print(f"ReferenceLatent injector targeting KSampler node '{ksampler_name}'.") | |
| else: | |
| print(f"Warning: [ReferenceLatent] Could not find a valid positive injection point. Skipping.") | |
| return | |
| current_pos_conditioning = assembler.workflow[pos_target_node_id]['inputs'][pos_target_input_name] | |
| for i, img_filename in enumerate(chain_items): | |
| if not img_filename or not isinstance(img_filename, str): | |
| continue | |
| load_id = assembler._get_unique_id() | |
| load_node = assembler._get_node_template("LoadImage") | |
| load_node['inputs']['image'] = img_filename | |
| assembler.workflow[load_id] = load_node | |
| vae_encode_id = assembler._get_unique_id() | |
| vae_encode_node = assembler._get_node_template("VAEEncode") | |
| vae_encode_node['inputs']['pixels'] = [load_id, 0] | |
| vae_encode_node['inputs']['vae'] = [vae_node_id, 0] | |
| assembler.workflow[vae_encode_id] = vae_encode_node | |
| latent_conn = [vae_encode_id, 0] | |
| ref_latent_id = assembler._get_unique_id() | |
| ref_latent_node = assembler._get_node_template("ReferenceLatent") | |
| ref_latent_node['inputs']['conditioning'] = current_pos_conditioning | |
| ref_latent_node['inputs']['latent'] = latent_conn | |
| assembler.workflow[ref_latent_id] = ref_latent_node | |
| current_pos_conditioning = [ref_latent_id, 0] | |
| assembler.workflow[pos_target_node_id]['inputs'][pos_target_input_name] = current_pos_conditioning | |
| print(f"ReferenceLatent injector applied. Re-routed inputs through {len(chain_items)} reference image(s).") |