adding exec

Signed-off-by: Vanessa Sochat <[email protected]>

Author: vsoch

scompose/client/exec.py

@@ -0,0 +1,37 @@
+'''
+
+Copyright (C) 2019 Vanessa Sochat.
+
+This program is free software: you can redistribute it and/or modify it
+under the terms of the GNU Affero General Public License as published by
+the Free Software Foundation, either version 3 of the License, or (at your
+option) any later version.
+
+This program is distributed in the hope that it will be useful, but WITHOUT
+ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+FITNESS FOR A PARTICULAR PURPOSE.  See the GNU Affero General Public
+License for more details.
+
+You should have received a copy of the GNU Affero General Public License
+along with this program.  If not, see <https://www.gnu.org/licenses/>.
+
+'''
+
+from scompose.project import Project
+import logging
+import json
+import sys
+import os
+
+
+log = logging.getLogger(__name__)
+
+def main(args, parser, extra):
+    '''execute a command to an instance.
+    '''
+    # Initialize the project
+    project = Project(filename=args.file,
+                      name=args.project_name,
+                      env_file=args.env_file)
+
+    project.execute(args.name[0], extra)

scompose/project/project.py

@@ -195,6 +195,10 @@ def create_hosts(self, name, depends_on):
 
     def shell(self, name):
         '''if an instance exists, shell into it.
+
+           Parameters
+           ==========
+           name: the name of the instance to shell into
         '''
         if self.instances:
             if name in self.instances:
@@ -203,6 +207,25 @@ def shell(self, name):
                     self.client.shell(instance.instance.get_uri(), sudo=self.sudo)
 
 
+    def execute(self, name, commands):
+        '''if an instance exists, execute a command to it.
+
+           Parameters
+           ==========
+           name: the name of the instance to exec to
+           commands: a list of commands to issue
+        '''
+        if self.instances:
+            if name in self.instances:
+                instance = self.instances[name]
+                if instance.exists():
+                    for line in self.client.execute(instance.instance.get_uri(), 
+                                                    command=commands,
+                                                    stream=True,
+                                                    sudo=self.sudo):
+                        print(line, end='')
+
+
     def logs(self, names, tail=0):
         '''logs will print logs to the screen.
         '''
@@ -275,19 +298,24 @@ def _create(self, names, command="create", writable_tmpfs=False):
 
             for instance in self.iter_instances(names):
 
+                # Flag to indicated create
+                do_create = True
+
                 # Ensure created, skip over if not
                 for depends_on in instance.params.get('depends_on', []):
                     if depends_on not in created:
                         count += 1
-                        continue
+                        do_create = False
+
+                if do_create:
 
-                # Create a hosts file for the instance based on depends
-                self.create_hosts(instance.name, created)
+                    # Create a hosts file for the instance based on depends
+                    self.create_hosts(instance.name, created)
 
-                # If we get here, execute command and add to list
-                getattr(instance, command)(self.working_dir, writable_tmpfs)
-                created.append(instance.name)
-                names.remove(instance.name) 
+                    # If we get here, execute command and add to list
+                    getattr(instance, command)(self.working_dir, writable_tmpfs)
+                    created.append(instance.name)
+                    names.remove(instance.name) 
 
                 # Possibly circular dependencies 
                 if count >= 100: