configs & networks

Author: apocas

lib/compose.js

@@ -1,6 +1,5 @@
 const yaml = require('js-yaml');
 const fs = require('fs');
-const { nextTick } = require('process');
 
 class Compose {
   constructor(dockerode) {
@@ -19,6 +18,8 @@ class Compose {
       console.log(self.recipe);
       output.secrets = await self.loadSecrets();
       output.volumes = await self.loadVolumes();
+      output.configs = await self.loadConfigs();
+      output.networks = await self.loadNetworks();
       return output;
     } catch (e) {
       throw e;
@@ -27,13 +28,13 @@ class Compose {
 
   async loadSecrets() {
     var secrets = [];
-    var secretNames = Object.keys(this.recipe.secrets);
+    var secretNames = Object.keys(this.recipe.secrets || []);
     for (var secretName of secretNames) {
       var secret = this.recipe.secrets[secretName];
       if (secret.external === true) continue;
       var opts = {
-        "Name": this.projectName + '_' + secretName,
-        "Data": fs.readFileSync(secret.file, 'utf8')
+        'Name': this.projectName + '_' + secretName,
+        'Data': fs.readFileSync(secret.file, 'utf8')
       };
       if (secret.name !== undefined) {
         opts.Name = secretName;
@@ -47,15 +48,37 @@ class Compose {
     return secrets;
   }
 
+  async loadConfigs() {
+    var configs = [];
+    var configNames = Object.keys(this.recipe.configs || []);
+    for (var configName of configNames) {
+      var config = this.recipe.configs[configName];
+      if (config.external === true) continue;
+      var opts = {
+        'Name': this.projectName + '_' + configName,
+        'Data': fs.readFileSync(config.file, 'utf8')
+      };
+      if (config.name !== undefined) {
+        opts.Name = configName;
+      }
+      try {
+        configs.push(await this.docker.createConfig(opts));
+      } catch (err) {
+        throw err;
+      }
+    }
+    return configs;
+  }
+
   async loadVolumes() {
     var volumes = [];
-    var volumeNames = Object.keys(this.recipe.volumes);
+    var volumeNames = Object.keys(this.recipe.volumes || []);
     for (var volumeName of volumeNames) {
       var volume = this.recipe.volumes[volumeName];
       if (volume.external === true) continue;
       var opts = {
-        "Name": this.projectName + '_' + volumeName,
-        "Driver": volume.driver,
+        'Name': this.projectName + '_' + volumeName,
+        'Driver': volume.driver,
         'DriverOpts': volume.driver_opts,
         'Labels': volume.labels
       };
@@ -70,6 +93,47 @@ class Compose {
     }
     return volumes;
   }
+
+  async loadNetworks() {
+    var networks = [];
+    var networkNames = Object.keys(this.recipe.networks || []);
+    for (var networkName of networkNames) {
+      var network = this.recipe.networks[networkName];
+      if (network.external === true) continue;
+      var opts = {
+        'Name': this.projectName + '_' + networkName,
+        'Driver': network.driver,
+        'DriverOpts': network.driver_opts,
+        'Labels': network.labels,
+        'Attachable': network.attachable,
+        'EnableIPv6': network.enable_ipv6,
+        'Internal': network.internal
+      };
+      if (network.name !== undefined) {
+        opts.Name = networkName;
+      }
+      if (network.ipam !== undefined) {
+        opts.IPAM = {
+          'Driver': network.ipam.driver,
+          'Options': network.ipam.options
+        }
+        if (network.ipam.config !== undefined) {
+          opts.IPAM['Config'] = {
+            'Subnet': network.ipam.config.subnet,
+            'IPRange': network.ipam.config.ip_range,
+            'Gateway': network.ipam.config.gateway,
+            'AuxAddress': network.ipam.config.aux_addresses
+          }
+        }
+      }
+      try {
+        networks.push(await this.docker.createNetwork(opts));
+      } catch (err) {
+        throw err;
+      }
+    }
+    return networks;
+  }
 }
 
 module.exports = Compose;