@@ -544,6 +544,7 @@ export class Message {
544544 { name : "saml_issuer" , value : Config . saml_issuer } ,
545545 { name : "nodered_id" , value : name } ,
546546 { name : "api_ws_url" , value : Config . api_ws_url } ,
547+ { name : "amqp_url" , value : Config . amqp_url } ,
547548 { name : "nodered_domain_schema" , value : hostname } ,
548549 { name : "protocol" , value : Config . protocol } ,
549550 { name : "port" , value : Config . port . toString ( ) } ,
@@ -635,14 +636,18 @@ export class Message {
635636 if ( service != null ) {
636637 await KubeUtil . instance ( ) . CoreV1Api . deleteNamespacedService ( name , namespace ) ;
637638 }
638- var list = await KubeUtil . instance ( ) . CoreV1Api . listNamespacedPod ( namespace ) ;
639- for ( var i = 0 ; i < list . body . items . length ; i ++ ) {
640- var item = list . body . items [ i ] ;
641- // if (item.metadata.labels.app === (name + "nodered") || item.metadata.labels.name === name) {
642- if ( item . metadata . labels . app === ( name + "nodered" ) ) {
643- await KubeUtil . instance ( ) . CoreV1Api . deleteNamespacedPod ( item . metadata . name , namespace ) ;
644- }
639+ var replicaset = await KubeUtil . instance ( ) . GetReplicaset ( namespace , "app" , ( name + "nodered" ) ) ;
640+ if ( replicaset !== null ) {
641+ KubeUtil . instance ( ) . AppsV1Api . deleteNamespacedReplicaSet ( replicaset . metadata . name , namespace ) ;
645642 }
643+ // var list = await KubeUtil.instance().CoreV1Api.listNamespacedPod(namespace);
644+ // for (var i = 0; i < list.body.items.length; i++) {
645+ // var item = list.body.items[i];
646+ // // if (item.metadata.labels.app === (name + "nodered") || item.metadata.labels.name === name) {
647+ // if (item.metadata.labels.app === (name + "nodered")) {
648+ // await KubeUtil.instance().CoreV1Api.deleteNamespacedPod(item.metadata.name, namespace);
649+ // }
650+ // }
646651 var ingress = await KubeUtil . instance ( ) . GetIngress ( namespace , "useringress" ) ;
647652 var updated = false ;
648653 for ( var i = ingress . spec . rules . length - 1 ; i >= 0 ; i -- ) {
0 commit comments