| def inject(assembler, chain_definition, chain_items): | |
| if not chain_items: | |
| return | |
| guider_node_name = chain_definition.get('guider_node') | |
| guider_target_inputs = chain_definition.get('guider_target_inputs', []) | |
| start_connections_map = chain_definition.get('start_connections', {}) | |
| vae_node_name = chain_definition.get('vae_node', 'vae_loader') | |
| if guider_node_name and guider_node_name in assembler.node_map and guider_target_inputs: | |
| guider_id = assembler.node_map[guider_node_name] | |
| if vae_node_name not in assembler.node_map: | |
| print(f"Warning: VAE node '{vae_node_name}' not found for Guider chain. Skipping.") | |
| return | |
| vae_node_id = assembler.node_map[vae_node_name] | |
| print(f"ReferenceLatent injector targeting DualCFGGuider node '{guider_node_name}'.") | |
| current_connections = {} | |
| for target_input in guider_target_inputs: | |
| conn_str = start_connections_map.get(target_input) | |
| if not conn_str: | |
| print(f"Warning: No start connection defined for '{target_input}' in Guider chain. Skipping this input.") | |
| continue | |
| try: | |
| node_name, idx_str = conn_str.split(':') | |
| node_id = assembler.node_map[node_name] | |
| current_connections[target_input] = [node_id, int(idx_str)] | |
| except (ValueError, KeyError): | |
| print(f"Warning: Invalid start connection '{conn_str}' for '{target_input}'. Skipping.") | |
| encoded_latents = [] | |
| for i, img_filename in enumerate(chain_items): | |
| 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 | |
| scale_id = assembler._get_unique_id() | |
| scale_node = assembler._get_node_template("ImageScaleToTotalPixels") | |
| scale_node['inputs']['megapixels'] = 1.0 | |
| scale_node['inputs']['upscale_method'] = "lanczos" | |
| scale_node['inputs']['image'] = [load_id, 0] | |
| assembler.workflow[scale_id] = scale_node | |
| vae_encode_id = assembler._get_unique_id() | |
| vae_encode_node = assembler._get_node_template("VAEEncode") | |
| vae_encode_node['inputs']['pixels'] = [scale_id, 0] | |
| vae_encode_node['inputs']['vae'] = [vae_node_id, 0] | |
| assembler.workflow[vae_encode_id] = vae_encode_node | |
| encoded_latents.append([vae_encode_id, 0]) | |
| for target_input_name, start_connection in current_connections.items(): | |
| current_chain_head = start_connection | |
| for i, latent_conn in enumerate(encoded_latents): | |
| ref_latent_id = assembler._get_unique_id() | |
| ref_latent_node = assembler._get_node_template("ReferenceLatent") | |
| ref_latent_node['inputs']['conditioning'] = current_chain_head | |
| ref_latent_node['inputs']['latent'] = latent_conn | |
| ref_latent_node['_meta']['title'] = f"{target_input_name} RefLatent {i+1}" | |
| assembler.workflow[ref_latent_id] = ref_latent_node | |
| current_chain_head = [ref_latent_id, 0] | |
| assembler.workflow[guider_id]['inputs'][target_input_name] = current_chain_head | |
| print(f" - Input '{target_input_name}' of node '{guider_node_name}' re-routed through {len(chain_items)} reference images.") | |
| return | |
| flux_guidance_name = chain_definition.get('flux_guidance_node') | |
| ksampler_name = chain_definition.get('ksampler_node', 'ksampler') | |
| if ksampler_name not in assembler.node_map: | |
| print(f"Warning: KSampler node '{ksampler_name}' not found for ReferenceLatent chain. Skipping.") | |
| return | |
| if vae_node_name not in assembler.node_map: | |
| print(f"Warning: VAE loader node '{vae_node_name}' not found for ReferenceLatent chain. 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}' for positive chain.") | |
| 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}' for positive chain.") | |
| else: | |
| print(f"Warning: Could not find a valid positive injection point for ReferenceLatent chain. Skipping.") | |
| return | |
| current_pos_conditioning = assembler.workflow[pos_target_node_id]['inputs'][pos_target_input_name] | |
| neg_target_node_id = ksampler_id | |
| neg_target_input_name = 'negative' | |
| if 'negative' not in assembler.workflow[neg_target_node_id]['inputs']: | |
| print(f"Warning: KSampler node '{ksampler_name}' has no 'negative' input. Skipping negative ReferenceLatent chain.") | |
| neg_target_node_id = None | |
| current_neg_conditioning = None | |
| if neg_target_node_id: | |
| current_neg_conditioning = assembler.workflow[neg_target_node_id]['inputs'][neg_target_input_name] | |
| for i, img_filename in enumerate(chain_items): | |
| load_id = assembler._get_unique_id() | |
| load_node = assembler._get_node_template("LoadImage") | |
| load_node['inputs']['image'] = img_filename | |
| load_node['_meta']['title'] = f"Load Reference Image {i+1}" | |
| assembler.workflow[load_id] = load_node | |
| scale_id = assembler._get_unique_id() | |
| scale_node = assembler._get_node_template("ImageScaleToTotalPixels") | |
| scale_node['inputs']['megapixels'] = 1.0 | |
| scale_node['inputs']['upscale_method'] = "lanczos" | |
| scale_node['inputs']['image'] = [load_id, 0] | |
| scale_node['_meta']['title'] = f"Scale Reference {i+1}" | |
| assembler.workflow[scale_id] = scale_node | |
| vae_encode_id = assembler._get_unique_id() | |
| vae_encode_node = assembler._get_node_template("VAEEncode") | |
| vae_encode_node['inputs']['pixels'] = [scale_id, 0] | |
| vae_encode_node['inputs']['vae'] = [vae_node_id, 0] | |
| vae_encode_node['_meta']['title'] = f"VAE Encode Reference {i+1}" | |
| assembler.workflow[vae_encode_id] = vae_encode_node | |
| latent_conn = [vae_encode_id, 0] | |
| pos_ref_latent_id = assembler._get_unique_id() | |
| pos_ref_latent_node = assembler._get_node_template("ReferenceLatent") | |
| pos_ref_latent_node['inputs']['conditioning'] = current_pos_conditioning | |
| pos_ref_latent_node['inputs']['latent'] = latent_conn | |
| pos_ref_latent_node['_meta']['title'] = f"Positive ReferenceLatent {i+1}" | |
| assembler.workflow[pos_ref_latent_id] = pos_ref_latent_node | |
| current_pos_conditioning = [pos_ref_latent_id, 0] | |
| if neg_target_node_id: | |
| neg_ref_latent_id = assembler._get_unique_id() | |
| neg_ref_latent_node = assembler._get_node_template("ReferenceLatent") | |
| neg_ref_latent_node['inputs']['conditioning'] = current_neg_conditioning | |
| neg_ref_latent_node['inputs']['latent'] = latent_conn | |
| neg_ref_latent_node['_meta']['title'] = f"Negative ReferenceLatent {i+1}" | |
| assembler.workflow[neg_ref_latent_id] = neg_ref_latent_node | |
| current_neg_conditioning = [neg_ref_latent_id, 0] | |
| assembler.workflow[pos_target_node_id]['inputs'][pos_target_input_name] = current_pos_conditioning | |
| if neg_target_node_id: | |
| assembler.workflow[neg_target_node_id]['inputs'][neg_target_input_name] = current_neg_conditioning | |
| print(f"ReferenceLatent injector applied. Re-routed inputs through {len(chain_items)} reference images.") |