fix unable to run function in other namespaces (#228)

serverless · Jan 11, 2021 · 14f490e · 14f490e
1 parent be5235c
commit 14f490e
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/lib/invoke.js b/lib/invoke.js
@@ -80,7 +80,7 @@ function invoke(func, data, funcsDesc, options) {
   const namespace = desc.namespace ||
         opts.namespace ||
         helpers.getDefaultNamespace(config);
-  const connectionOptions = helpers.getConnectionOptions(helpers.loadKubeConfig());
+  const connectionOptions = helpers.getConnectionOptions(helpers.loadKubeConfig(), { namespace });
   const core = new Api.Core(connectionOptions);
   const requestData = getData(data, {
     path: opts.path,

diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "serverless-kubeless",
-  "version": "0.11.0",
+  "version": "0.11.1",
   "description": "This plugin enables support for Kubeless within the [Serverless Framework](https://github.com/serverless).",
   "main": "index.js",
   "directories": {

diff --git a/test/kubelessInvoke.test.js b/test/kubelessInvoke.test.js
@@ -33,16 +33,16 @@ const serverless = require('./lib/serverless')({ service: { functions: { 'my-fun
 
 require('chai').use(chaiAsPromised);
 
-function nocksvc(url, funcs) {
+function nocksvc(url, funcs, namespace = 'default') {
   nock(url)
-    .get('/api/v1/namespaces/default/services')
+    .get(`/api/v1/namespaces/${namespace}/services`)
     .reply(200, {
       items: _.map(_.flatten([funcs]), f => ({
         metadata:
         {
           name: f,
           namespace: 'default',
-          selfLink: `/api/v1/namespaces/default/services/${f}`,
+          selfLink: `/api/v1/namespaces/${namespace}/services/${f}`,
           uid: '010a169d-618c-11e7-9939-080027abf356',
           resourceVersion: '248',
           creationTimestamp: '2017-07-05T14:12:39Z',
@@ -234,7 +234,7 @@ describe('KubelessInvoke', () => {
           statusMessage: 'OK',
         });
       });
-      nocksvc(kubeApiURL, func);
+      nocksvc(kubeApiURL, func, serverlessWithNS.service.provider.namespace);
       return kubelessInvoke.invokeFunction().then((res) => {
         expect(res).to.be.eql({
           statusCode: 200,
@@ -257,7 +257,7 @@ describe('KubelessInvoke', () => {
           statusMessage: 'OK',
         });
       });
-      nocksvc(kubeApiURL, func);
+      nocksvc(kubeApiURL, func, serverlessWithNS.service.functions[func].namespace);
       return kubelessInvoke.invokeFunction().then((res) => {
         expect(res).to.be.eql({
           statusCode: 200,