Solution for Assignment2.

solutions/Abhilasha/Assignment2/BuildAutomationTool.py

@@ -0,0 +1,162 @@
+# -*- coding: utf-8 -*-
+"""
+Created on Fri Dec  6 14:36:59 2019
+
+@author: Abhilasha
+"""
+
+import os
+import json
+import subprocess
+from pathlib import Path
+from os.path import relpath
+import time
+
+
+class ActionGraph():  
+
+    '''loads commands, dependencies and initialises the status for all the actions from all build.json files.'''
+
+    def __init__(self, root_dir):
+
+        self.root_dir = root_dir
+        self.all_action_status = {}
+        self.all_action_commands = {}
+        self.all_action_dependencies = {}
+
+    def create_action_map(self):
+
+        for filename in Path(self.root_dir).rglob('*.json'):
+            rel_location = relpath(filename,self.root_dir)
+            if len(str(rel_location).split(os.path.sep)) == 1:
+                rel_location = ''
+            else:
+                rel_location = str(rel_location).split(os.path.sep)[0]
+            with open(filename) as json_file:
+                all_data = json.load(json_file)
+                for data in all_data:
+                    if rel_location != '':
+                        action = rel_location+'/'+data['name']
+                    else:
+                        action = data['name']
+                    self.all_action_status[action] = 'not started'
+                    if 'command' in data:
+                        self.all_action_commands[action] = data['command']
+                    else:
+                        self.all_action_commands[action] = 'none'                
+                    if 'deps' in data:
+                        self.all_action_dependencies[action] = data['deps']
+                    else:
+                        self.all_action_dependencies[action] = 'none'
+
+
+    def get_command_to_be_executed(self, build, action):
+
+        if action not in self.all_action_status:
+            raise Exception('Command not recognized.')
+            return        
+        else:
+            Action_obj = Action(self.all_action_status, self.all_action_commands, self.all_action_dependencies)
+            Action_obj.get_dependencies(action)
+            Action_obj.update_dependencies_status(action)
+            Action_obj.execute_commands()
+            return 
+
+
+class Action():
+
+
+     def __init__(self, all_action_status, all_action_commands, all_action_dependencies):
+
+        self.all_action_status = all_action_status
+        self.all_action_commands = all_action_commands
+        self.all_action_dependencies = all_action_dependencies        
+        self.current_action_status = {}
+        self.current_action_commands = {}
+        self.current_action_dependencies = {}              
+        self.ongoing_subprocesses = []
+        self.action_name_for_ongoing_subprocess = []
+
+
+     def get_dependencies(self, action):
+
+        '''stores the status, commands, dependencies of the action to be executed and all its dependencies'''
+
+        self.current_action_status[action] = self.all_action_status[action]
+        self.current_action_commands[action] = self.all_action_commands[action]
+        self.current_action_dependencies[action] = self.all_action_dependencies[action]       
+        if self.all_action_dependencies[action] != 'none':       
+            for name in self.all_action_dependencies[action]:
+                self.get_dependencies(name)                    
+        return
+
+
+     def update_dependencies_status(self, action):
+
+         ''' updates the status of the actions- ready or processing or done '''
+
+         if self.current_action_dependencies[action] == 'none':
+             self.current_action_status[action] = 'ready'
+         else:             
+             total_no_of_dependencies = len(self.current_action_dependencies[action])
+             no_of_dependencies_done = 0;
+             for dep in self.current_action_dependencies[action]:                             
+                 if self.current_action_status[dep] == 'not started':
+                     self.update_dependencies_status(dep)
+                 if self.current_action_status[dep] == 'done':
+                     no_of_dependencies_done += 1      
+             if no_of_dependencies_done == total_no_of_dependencies:
+                 self.current_action_status[action] = 'ready'                  
+         return
+
+
+
+     def execute_commands(self):
+
+         for name in self.current_action_status:
+             if(self.current_action_status[name] == 'ready'):                 
+                 self.current_action_status[name] = 'processing'
+                 cwd = os.getcwd()
+                 if '/' in name:            
+                     loc = name[:name.rindex('/')]                     
+                 else:                     
+                     loc = ''   
+
+                 if self.current_action_commands[name] != 'none':
+                     if loc != '':
+                         os.chdir(cwd+os.path.sep+loc)
+                     command = str(self.current_action_commands[name])
+                     p = subprocess.Popen(command, shell=True)
+                     os.chdir(cwd)
+                     self.ongoing_subprocesses.append(p)
+                     self.action_name_for_ongoing_subprocess.append(name)
+
+                 else:                     
+                     self.current_action_status[name] = 'done'                     
+                     for name in self.current_action_status:
+                         if(self.current_action_status[name] == 'not_started'):
+                             self.update_dependencies_status(name)
+                     self.execute_commands()
+
+         while not len(self.ongoing_subprocesses) == 0:
+
+             any_subprocess_completed = False    
+             for p, action in zip(self.ongoing_subprocesses, self.action_name_for_ongoing_subprocess):
+                 if not(p.poll() is None):
+                     any_subprocess_completed = True
+                     break
+                 else:
+                     continue
+
+             if any_subprocess_completed == True:
+                 self.ongoing_subprocesses.remove(p)
+                 self.action_name_for_ongoing_subprocess.remove(action)
+                 self.current_action_status[action] = 'done'
+                 for name in self.current_action_status:
+                     if(self.current_action_status[name] == 'not started'):     
+                         self.update_dependencies_status(name)                             
+                 self.execute_commands() 
+             else:
+                 time.sleep(1)
+         return
+

solutions/Abhilasha/Assignment2/btest.py

@@ -0,0 +1,93 @@
+import unittest
+import os
+from os import path
+import tempfile
+import shutil
+import BuildAutomationTool as BAT
+
+class TestBuildAutomationTool(unittest.TestCase):
+
+    def setUp(self):
+
+        self.root = os.getcwd()
+        self.test_dir = tempfile.TemporaryDirectory()
+
+
+    def TearDown(self):
+
+        shutil.rmtree(self.test_dir)
+
+
+    def test_build_test_all(self):
+
+        with self.test_dir as tmpdirname:
+            new_root_dir = tmpdirname+os.path.sep+"code"
+            shutil.copytree(self.root+os.path.sep+"code", new_root_dir ) 
+            os.chdir(new_root_dir)
+            BAT_obj = BAT.ActionGraph(new_root_dir)
+            BAT_obj.create_action_map()
+            BAT_obj.get_command_to_be_executed('build', 'test_all')
+            self.assertEqual(path.exists('test.o'), True)
+            self.assertEqual(path.exists('test_sort_bubble.exe'), True)
+            self.assertEqual(path.exists('test_sort_quick.exe'), True)
+            self.assertEqual(path.exists('test_sort_merge.exe'), True)
+            os.chdir(os.path.join("algorithms"))
+            self.assertEqual(path.exists('sort_bubble.o'), True)
+            self.assertEqual(path.exists('sort_quick.o'), True)
+            self.assertEqual(path.exists('sort_merge.o'), True)
+            os.chdir(self.root)
+
+
+    def test_clean(self):
+
+        with self.test_dir as tmpdirname:
+            new_root_dir = tmpdirname+os.path.sep+"code"
+            shutil.copytree(self.root+os.path.sep+"code", new_root_dir )
+            os.chdir(new_root_dir)
+            BAT_obj = BAT.ActionGraph(new_root_dir)
+            BAT_obj.create_action_map()
+            BAT_obj.get_command_to_be_executed('build', 'clean')
+            self.assertEqual(path.exists('test.o'), False)
+            self.assertEqual(path.exists('test_sort_bubble.exe'), False)
+            self.assertEqual(path.exists('test_sort_quick.exe'), False)
+            self.assertEqual(path.exists('test_sort_merge.exe'), False)
+            os.chdir(os.path.join("algorithms"))
+            self.assertEqual(path.exists('sort_bubble.o'), False)
+            self.assertEqual(path.exists('sort_quick.o'), False)
+            self.assertEqual(path.exists('sort_merge.o'), False)  
+            os.chdir(self.root)
+
+
+    def test_sort_merge(self):
+
+        with self.test_dir as tmpdirname:
+            new_root_dir = tmpdirname+os.path.sep+"code"
+            shutil.copytree(self.root+os.path.sep+"code", new_root_dir )
+            os.chdir(new_root_dir)
+            BAT_obj = BAT.ActionGraph(new_root_dir)
+            BAT_obj.create_action_map()
+            BAT_obj.get_command_to_be_executed('build', 'test_sort_merge')       
+            self.assertEqual(path.exists('test.o'), True)
+            self.assertEqual(path.exists('test_sort_merge.exe'), True)
+            os.chdir(os.path.join("algorithms"))
+            self.assertEqual(path.exists('sort_merge.o'), True) 
+            os.chdir(self.root)
+
+
+    def test_invalid_key(self):
+
+        with self.test_dir as tmpdirname:
+            new_root_dir = tmpdirname+os.path.sep+"code"
+            shutil.copytree(self.root+os.path.sep+"code", new_root_dir ) 
+            os.chdir(new_root_dir)
+            BAT_obj = BAT.ActionGraph(new_root_dir)
+            BAT_obj.create_action_map()
+            with self.assertRaisesRegex(Exception, 'Command not recognized.'):
+                BAT_obj.get_command_to_be_executed('build', 'test_sort_selection')
+            os.chdir(self.root)
+
+
+if __name__ == '__main__':
+
+    unittest.main()
+

solutions/Abhilasha/Assignment2/code/algorithms/build.json

@@ -0,0 +1,18 @@
+[
+  {
+    "name": "clean",
+    "command": "rm -f *.o"
+  },
+  {
+    "name": "sort_bubble",
+    "command": "g++ -c sort_bubble.cpp"
+  },
+  {
+    "name": "sort_merge",
+    "command": "g++ -c sort_merge.cpp"
+  },
+  {
+    "name": "sort_quick",
+    "command": "g++ -c sort_quick.cpp"
+  }
+]

solutions/Abhilasha/Assignment2/code/algorithms/desktop.ini

@@ -0,0 +1,4 @@
+[ViewState]
+Mode=
+Vid=
+FolderType=Generic

solutions/Abhilasha/Assignment2/code/algorithms/sort_bubble.cpp

@@ -0,0 +1,6 @@
+#include <bits/stdc++.h>
+using namespace std;
+void sort_function(vector<int> &v)
+{
+    cout<<"sort bubble";
+}

solutions/Abhilasha/Assignment2/code/algorithms/sort_merge.cpp

@@ -0,0 +1,6 @@
+#include <bits/stdc++.h>
+using namespace std;
+void sort_function(vector<int> &v)
+{
+    cout<<"sort merge";
+}

solutions/Abhilasha/Assignment2/code/algorithms/sort_quick.cpp

@@ -0,0 +1,6 @@
+#include <bits/stdc++.h>
+using namespace std;
+void sort_function(vector<int> &v)
+{
+    cout<<"sort quick";
+}

solutions/Abhilasha/Assignment2/code/build.json

@@ -0,0 +1,30 @@
+[
+  {
+    "name": "clean",
+    "deps": ["algorithms/clean"],
+    "command": "rm -f test.o && rm -f test_*.exe"
+  },
+  {
+    "name": "test",
+    "command": "g++ -std=c++11 -c test.cpp"
+  },
+  {
+    "name": "test_sort_bubble",
+    "deps": ["test", "algorithms/sort_bubble"],
+    "command": "g++ test.o algorithms/sort_bubble.o -o test_sort_bubble.exe && ./test_sort_bubble.exe"
+  },
+  {
+    "name": "test_sort_merge",
+    "deps": ["test", "algorithms/sort_merge"],
+    "command": "g++ test.o algorithms/sort_merge.o -o test_sort_merge.exe && ./test_sort_merge.exe"
+  },
+  {
+    "name": "test_sort_quick",
+    "deps": ["test", "algorithms/sort_quick"],
+    "command": "g++ test.o algorithms/sort_quick.o -o test_sort_quick.exe && ./test_sort_quick.exe"
+  },
+  {
+    "name": "test_all",
+    "deps": ["test_sort_bubble", "test_sort_merge", "test_sort_quick"]
+  }
+]

solutions/Abhilasha/Assignment2/code/test.cpp

@@ -0,0 +1,8 @@
+#include <bits/stdc++.h>
+using namespace std;
+void sort_function(vector<int> &v);
+int main()
+{
+    vector<int> v;
+	sort_function(v);
+}