Add support for vpcConnector and vpcConnectorEgressSettings

Author: pcboy

src/deploy/functions/release.js

@@ -217,6 +217,8 @@ module.exports = function(context, options, payload) {
                   timeout: functionInfo.timeout,
                   maxInstances: functionInfo.maxInstances,
                   environmentVariables: defaultEnvVariables,
+                  vpcConnector: functionInfo.vpcConnector,
+                  vpcConnectorEgressSettings: functionInfo.vpcConnectorEgressSettings,
                 })
                 .then((createRes) => {
                   if (_.has(functionTrigger, "httpsTrigger")) {
@@ -292,6 +294,8 @@ module.exports = function(context, options, payload) {
               timeout: functionInfo.timeout,
               runtime: runtime,
               maxInstances: functionInfo.maxInstances,
+              vpcConnector: functionInfo.vpcConnector,
+              vpcConnectorEgressSettings: functionInfo.vpcConnectorEgressSettings,
               environmentVariables: _.assign(
                 {},
                 existingFunction.environmentVariables,

src/gcp/cloudfunctions.js

@@ -65,13 +65,19 @@ function _createFunction(options) {
   const location = "projects/" + options.projectId + "/locations/" + options.region;
   const func = location + "/functions/" + options.functionName;
   const endpoint = "/" + API_VERSION + "/" + location + "/functions";
+
   const data = {
     sourceUploadUrl: options.sourceUploadUrl,
     name: func,
     entryPoint: options.entryPoint,
     labels: options.labels,
     runtime: options.runtime,
   };
+
+  if (options.vpcConnector) {
+    data.vpcConnector = options.vpcConnector;
+    data.vpcConnectorEgressSettings = options.vpcConnectorEgressSettings || "ALL_TRAFFIC";
+  }
   if (options.availableMemoryMb) {
     data.availableMemoryMb = options.availableMemoryMb;
   }
@@ -143,6 +149,7 @@ function _updateFunction(options) {
   const location = "projects/" + options.projectId + "/locations/" + options.region;
   const func = location + "/functions/" + options.functionName;
   const endpoint = "/" + API_VERSION + "/" + func;
+
   const data = _.assign(
     {
       sourceUploadUrl: options.sourceUploadUrl,
@@ -153,6 +160,13 @@ function _updateFunction(options) {
   );
   let masks = ["sourceUploadUrl", "name", "labels"];
 
+  if (options.vpcConnector) {
+    data.vpcConnector = options.vpcConnector;
+    data.vpcConnectorEgressSettings = options.vpcConnectorEgressSettings || "ALL_TRAFFIC";
+    masks.push("vpcConnector");
+    masks.push("vpcConnectorEgressSettings");
+  }
+
   if (options.runtime) {
     data.runtime = options.runtime;
     masks = _.concat(masks, "runtime");