Skip to content

Commit 329bcc2

Browse files
committed
Fix service name
1 parent 405dba8 commit 329bcc2

1 file changed

Lines changed: 30 additions & 12 deletions

File tree

OpenFlow/src/Messages/Message.ts

Lines changed: 30 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -2186,6 +2186,15 @@ export class Message {
21862186
if (!NoderedUtil.IsNullUndefinded(resources.requests) && NoderedUtil.IsNullEmpty(resources.requests.memory)) delete resources.requests.memory;
21872187
if (!NoderedUtil.IsNullUndefinded(resources.requests) && NoderedUtil.IsNullEmpty(resources.requests.memory)) delete resources.requests.memory;
21882188

2189+
var saml_federation_metadata = Config.saml_federation_metadata;
2190+
if (api_ws_url == "wss://pc.openiap.io/") {
2191+
api_ws_url = "wss://demo.openiap.io/"
2192+
}
2193+
if (saml_federation_metadata == "https://pc.openiap.io/issue/FederationMetadata/2007-06/FederationMetadata.xml") {
2194+
saml_federation_metadata = "https://demo.openiap.io/issue/FederationMetadata/2007-06/FederationMetadata.xml"
2195+
}
2196+
var port = 3000;
2197+
21892198
const _deployment = {
21902199
metadata: { name: name, namespace: namespace, labels: { billed: hasbilling.toString(), userid: _id, app: name } },
21912200
spec: {
@@ -2199,10 +2208,10 @@ export class Message {
21992208
name: 'nodered',
22002209
image: nodered_image,
22012210
imagePullPolicy: "Always",
2202-
ports: [{ containerPort: Config.port }, { containerPort: 5859 }],
2211+
ports: [{ containerPort: port }, { containerPort: 5859 }],
22032212
resources: resources,
22042213
env: [
2205-
{ name: "saml_federation_metadata", value: Config.saml_federation_metadata },
2214+
{ name: "saml_federation_metadata", value: saml_federation_metadata },
22062215
{ name: "saml_issuer", value: Config.saml_issuer },
22072216
{ name: "saml_baseurl", value: saml_baseurl },
22082217
{ name: "nodered_id", value: name },
@@ -2212,7 +2221,7 @@ export class Message {
22122221
{ name: "api_ws_url", value: api_ws_url },
22132222
{ name: "domain", value: hostname },
22142223
{ name: "protocol", value: Config.protocol },
2215-
{ name: "port", value: Config.port.toString() },
2224+
{ name: "port", value: port.toString() },
22162225
{ name: "noderedusers", value: (name + "noderedusers") },
22172226
{ name: "noderedadmins", value: (name + "noderedadmins") },
22182227
{ name: "noderedapiusers", value: (name + "nodered api users") },
@@ -2293,18 +2302,23 @@ export class Message {
22932302
}
22942303
}
22952304

2305+
let servicename = name;
2306+
if (!/[a-z]([-a-z0-9]*[a-z0-9])?/.test(servicename)) {
2307+
servicename = "nr" + name + "svc";
2308+
}
2309+
22962310
Logger.instanse.debug("[" + tuser.username + "] GetService");
2297-
const service = await KubeUtil.instance().GetService(namespace, name);
2311+
const service = await KubeUtil.instance().GetService(namespace, servicename);
22982312
if (service == null) {
2299-
Logger.instanse.debug("[" + _tuser.username + "] Service " + name + " not found in " + namespace + " creating it");
2313+
Logger.instanse.debug("[" + _tuser.username + "] Service " + servicename + " not found in " + namespace + " creating it");
23002314
const _service = {
2301-
metadata: { name: name, namespace: namespace },
2315+
metadata: { name: servicename, namespace: namespace },
23022316
spec: {
23032317
type: "NodePort",
23042318
sessionAffinity: "ClientIP",
23052319
selector: { app: name },
23062320
ports: [
2307-
{ port: Config.port, name: "www" }
2321+
{ port: port, name: "www" }
23082322
]
23092323
}
23102324
}
@@ -2328,7 +2342,7 @@ export class Message {
23282342
paths: [{
23292343
path: "/",
23302344
backend: {
2331-
serviceName: name,
2345+
serviceName: servicename,
23322346
servicePort: "www"
23332347
}
23342348
}]
@@ -2344,9 +2358,9 @@ export class Message {
23442358
pathType: "Prefix",
23452359
backend: {
23462360
service: {
2347-
name: name,
2361+
name: servicename,
23482362
port: {
2349-
number: Config.port
2363+
number: port
23502364
}
23512365
}
23522366
}
@@ -2403,9 +2417,13 @@ export class Message {
24032417
} else {
24042418
Logger.instanse.warn("_DeleteNoderedInstance: Did not find deployment for " + name + " in namespace " + namespace);
24052419
}
2406-
const service = await KubeUtil.instance().GetService(namespace, name);
2420+
let servicename = name;
2421+
if (!/[a-z]([-a-z0-9]*[a-z0-9])?/.test(servicename)) {
2422+
servicename = "nr" + name + "svc";
2423+
}
2424+
const service = await KubeUtil.instance().GetService(namespace, servicename);
24072425
if (service != null) {
2408-
await KubeUtil.instance().CoreV1Api.deleteNamespacedService(name, namespace);
2426+
await KubeUtil.instance().CoreV1Api.deleteNamespacedService(servicename, namespace);
24092427
} else {
24102428
Logger.instanse.warn("_DeleteNoderedInstance: Did not find service for " + name + " in namespace " + namespace);
24112429
}

0 commit comments

Comments
 (0)