nodered_nodes.ts

import * as RED from "node-red";
import { Red } from "node-red";
import { NoderedUtil } from "@openiap/openflow-api";

export interface Iget_pods {
    name: string;
    targetid: string;
}
export class get_pods {
    public node: Red = null;
    public name: string;
    constructor(public config: Iget_pods) {
        RED.nodes.createNode(this, config);
        this.node = this;
        this.node.status({});
        this.name = config.name;
        this.node.on("input", this.oninput);
        this.node.on("close", this.onclose);
    }
    async oninput(msg: any) {
        try {
            this.node.status({});
            const targetid = (!NoderedUtil.IsNullUndefinded(msg.targetid) ? msg.targetid : this.config.targetid);
            let priority: number = 1;
            if (!NoderedUtil.IsNullEmpty(msg.priority)) { priority = msg.priority; }
            this.node.status({ fill: "blue", shape: "dot", text: "Getting pods" });

            const result = await NoderedUtil.GetNoderedInstance({ _id: targetid, jwt: msg.jwt, priority });
            msg.payload = result;
            this.node.send(msg);
            this.node.status({});
        } catch (error) {
            NoderedUtil.HandleError(this, error, msg);
        }
    }
    onclose() {
    }
}