Spaces:
Running
on
L40S
Running
on
L40S
| /** | |
| * File: debug.js | |
| * Project: comfy_mtb | |
| * Author: Mel Massadian | |
| * | |
| * Copyright (c) 2023 Mel Massadian | |
| * | |
| */ | |
| // Reference the shared typedefs file | |
| /// <reference path="../types/typedefs.js" /> | |
| import { app } from '../../scripts/app.js' | |
| import * as shared from './comfy_shared.js' | |
| import { MtbWidgets } from './mtb_widgets.js' | |
| // TODO: respect inputs order... | |
| function escapeHtml(unsafe) { | |
| return unsafe | |
| .replace(/&/g, '&') | |
| .replace(/</g, '<') | |
| .replace(/>/g, '>') | |
| .replace(/"/g, '"') | |
| .replace(/'/g, ''') | |
| } | |
| app.registerExtension({ | |
| name: 'mtb.Debug', | |
| /** | |
| * @param {NodeType} nodeType | |
| * @param {NodeData} nodeData | |
| * @param {*} app | |
| */ | |
| async beforeRegisterNodeDef(nodeType, nodeData, app) { | |
| if (nodeData.name === 'Debug (mtb)') { | |
| const onNodeCreated = nodeType.prototype.onNodeCreated | |
| nodeType.prototype.onNodeCreated = function () { | |
| this.options = {} | |
| const r = onNodeCreated | |
| ? onNodeCreated.apply(this, arguments) | |
| : undefined | |
| this.addInput(`anything_1`, '*') | |
| return r | |
| } | |
| const onConnectionsChange = nodeType.prototype.onConnectionsChange | |
| /** | |
| * @param {OnConnectionsChangeParams} args | |
| */ | |
| nodeType.prototype.onConnectionsChange = function (...args) { | |
| const [_type, index, connected, link_info, ioSlot] = args | |
| const r = onConnectionsChange | |
| ? onConnectionsChange.apply(this, args) | |
| : undefined | |
| // TODO: remove all widgets on disconnect once computed | |
| shared.dynamic_connection(this, index, connected, 'anything_', '*', { | |
| link: link_info, | |
| ioSlot: ioSlot, | |
| }) | |
| //- infer type | |
| if (link_info) { | |
| // const fromNode = this.graph._nodes.find( | |
| // (otherNode) => otherNode.id === link_info.origin_id, | |
| // ) | |
| // const fromNode = app.graph.getNodeById(link_info.origin_id) | |
| const { from } = shared.nodesFromLink(this, link_info) | |
| if (!from || this.inputs.length === 0) return | |
| const type = from.outputs[link_info.origin_slot].type | |
| this.inputs[index].type = type | |
| // this.inputs[index].label = type.toLowerCase() | |
| } | |
| //- restore dynamic input | |
| if (!connected) { | |
| this.inputs[index].type = '*' | |
| this.inputs[index].label = `anything_${index + 1}` | |
| } | |
| return r | |
| } | |
| const onExecuted = nodeType.prototype.onExecuted | |
| nodeType.prototype.onExecuted = function (data) { | |
| onExecuted?.apply(this, arguments) | |
| const prefix = 'anything_' | |
| if (this.widgets) { | |
| for (let i = 0; i < this.widgets.length; i++) { | |
| if (this.widgets[i].name !== 'output_to_console') { | |
| this.widgets[i].onRemoved?.() | |
| } | |
| } | |
| this.widgets.length = 1 | |
| } | |
| let widgetI = 1 | |
| // console.log(message) | |
| if (data.text) { | |
| for (const txt of data.text) { | |
| const w = this.addCustomWidget( | |
| MtbWidgets.DEBUG_STRING(`${prefix}_${widgetI}`, escapeHtml(txt)), | |
| ) | |
| w.parent = this | |
| widgetI++ | |
| } | |
| } | |
| if (data.b64_images) { | |
| for (const img of data.b64_images) { | |
| const w = this.addCustomWidget( | |
| MtbWidgets.DEBUG_IMG(`${prefix}_${widgetI}`, img), | |
| ) | |
| w.parent = this | |
| widgetI++ | |
| } | |
| } | |
| // this.setSize(this.computeSize()) | |
| this.onRemoved = function () { | |
| // When removing this node we need to remove the input from the DOM | |
| for (let y in this.widgets) { | |
| if (this.widgets[y].canvas) { | |
| this.widgets[y].canvas.remove() | |
| } | |
| shared.cleanupNode(this) | |
| this.widgets[y].onRemoved?.() | |
| } | |
| } | |
| } | |
| } | |
| }, | |
| }) | |