从jenkins获取ns列表

app/namespace.js

@@ -13,6 +13,17 @@ router.get('/', async (ctx) => {
   ctx.body = ctx.ok(data)
 })
 
+router.get('/get_namespace_for_jenkins', async (ctx) => {
+  const data = await ctx.cluster.namespace_get()
+  const ret = data.namespaces.map(item => item.name)
+  ctx.body = ret.filter((item) => {
+    if (!['default', 'kube-system'].includes(item)) {
+      return item
+    }
+    return null
+  }).join('\n')
+})
+
 
 router.get('/info', async (ctx) => {
   const data = await ctx.cluster.namespace_get()

app/service.js

@@ -32,7 +32,7 @@ router.get('/', async (ctx) => {
   ctx.body = ctx.ok(data)
 })
 
-router.post('/create', async (ctx) => {
+const createService = async (ctx) => {
   const {
     type, serviceName, namespace, image, system_name, domain, label,
   } = ctx.request.body
@@ -60,7 +60,12 @@ router.post('/create', async (ctx) => {
     await ingressCreate(namespace, serviceName, domain)
   }
   ctx.body = ctx.ok('创建成功')
+}
+
+router.post('/create', async (ctx) => {
+  await createService(ctx)
 })
+
 router.post('/details', async (ctx) => {
   const data = await ctx.cluster.service_get(ctx.request.body.serviceName, ctx.request.body.namespace)
   ctx.body = ctx.ok(data)
@@ -72,7 +77,15 @@ router.post('/delete', async (ctx) => {
 })
 
 router.post('/modifyImage', async (ctx) => {
-  await ctx.cluster.service_modifyImage(ctx.request.body.serviceName, ctx.request.body.image, ctx.request.body.namespace)
+  let list = await ctx.cluster.service_list(ctx.request.body.namespace)
+  list = list.services.map(item => item.serviceName)
+
+  if (list.includes(ctx.request.body.serviceName)) {
+    await ctx.cluster.service_modifyImage(ctx.request.body.serviceName, ctx.request.body.image, ctx.request.body.namespace)
+  } else {
+    await createService(ctx)
+  }
+
   ctx.body = ctx.ok('更新成功')
 })
 router.post('/instance', async (ctx) => {