fixes and improvements after test-run 1

chaos_monkey/exploit/smbexec.py

@@ -37,6 +37,7 @@ class SmbExploiter(HostExploiter):
 
     def __init__(self):
         self._config = __import__('config').WormConfiguration
+        self._guid = __import__('config').GUID
 
     def is_os_supported(self, host):
         if host.os.get('type') in self._target_os_type:
@@ -103,6 +104,8 @@ class SmbExploiter(HostExploiter):
         else:
             cmdline = MONKEY_CMDLINE_DETACHED % {'monkey_path': remote_full_path}
 
+        cmdline += " -p " + self._guid
+
         if host.default_tunnel:
             cmdline += " -t " + host.default_tunnel
         if host.default_server:

chaos_monkey/exploit/sshexec.py

@@ -19,6 +19,7 @@ class SSHExploiter(HostExploiter):
 
     def __init__(self):
         self._config = __import__('config').WormConfiguration
+        self._guid = __import__('config').GUID
         self._update_timestamp = 0
 
     def log_transfer(self, transferred, total):
@@ -117,6 +118,7 @@ class SSHExploiter(HostExploiter):
 
         try:
             cmdline = "%s %s" % (self._config.dropper_target_path_linux, MONKEY_ARG)
+            cmdline += " -p " + self._guid
             if host.default_tunnel:
                 cmdline += " -t " + host.default_tunnel
             if host.default_server:

chaos_monkey/exploit/win_ms08_067.py

@@ -171,6 +171,7 @@ class Ms08_067_Exploiter(HostExploiter):
 
     def __init__(self):
         self._config = __import__('config').WormConfiguration
+        self._guid = __import__('config').GUID
 
     def is_os_supported(self, host):
         if host.os.get('type') in self._target_os_type and \
@@ -249,6 +250,8 @@ class Ms08_067_Exploiter(HostExploiter):
         else:
             cmdline = MONKEY_CMDLINE % {'monkey_path': remote_full_path}
 
+        cmdline += " -p " + self._guid
+
         if host.default_tunnel:
             cmdline += " -t " + host.default_tunnel
         if host.default_server:

chaos_monkey/exploit/wmiexec.py

@@ -15,6 +15,7 @@ class WmiExploiter(HostExploiter):
 
     def __init__(self):
         self._config = __import__('config').WormConfiguration
+        self._guid = __import__('config').GUID
 
     @WmiTools.dcom_wrap
     def exploit_host(self, host, depth=-1, src_path=None):

chaos_monkey/monkey.py

@@ -93,6 +93,7 @@ class ChaosMonkey(object):
 
         if 0 == WormConfiguration.depth:
             LOG.debug("Reached max depth, shutting down")
+            ControlClient.send_telemetry("trace", "Reached max depth, shutting down")
             return
         else:
             LOG.debug("Running with depth: %d" % WormConfiguration.depth)

chaos_monkey/monkey.spec

@@ -1,4 +1,5 @@
 # -*- mode: python -*-
+import os
 import platform
 a = Analysis(['main.py'],
              pathex=['.'],
@@ -12,7 +13,7 @@ if platform.system().find("Windows")>= 0:
 pyz = PYZ(a.pure)
 exe = EXE(pyz,
           a.scripts,
-          a.binaries,
+          a.binaries + [('msvcr100.dll', os.environ['WINDIR'] + '\system32\msvcr100.dll', 'BINARY')],
           a.zipfiles,
           a.datas,
           name='monkey.exe',

chaos_monkey/readme.txt

@@ -5,8 +5,11 @@ Windows:
 	https://www.python.org/download/releases/2.7
 2. install pywin32-219.win32-py2.7.exe
 	http://sourceforge.net/projects/pywin32/files/pywin32/Build%20219/
-3. install VCForPython27.msi
+3. a. install VCForPython27.msi
 	http://www.microsoft.com/en-us/download/details.aspx?id=44266
+   b. if not installed, install Microsoft Visual C++ 2010 SP1 Redistributable Package
+    32bit: http://www.microsoft.com/en-us/download/details.aspx?id=8328
+    64bit: http://www.microsoft.com/en-us/download/details.aspx?id=13523
 4. Download & Run get-pip.py
 	https://bootstrap.pypa.io/get-pip.py
 5. Run:

monkey_island/cc/admin/ui/js/monkeys-admin.js

@@ -309,18 +309,17 @@ function createTunnels() {
 }
 
 function createScanned() {
-    var genTime = temelGenerationDate; // save the initial value as it's going to be changed in each json call
+    // Gets all the scans performed by monkeys
-    // For each existing monkey, gets all the scans performed by it
     // For each non exploited machine, adds a new node and connects it as a scanned node.
-    for (var i = 0; i < monkeys.length; i++) {
+
-        var monkey = monkeys[i];
-        // Get scans for each monkey
     // Reading the JSON file containing the monkeys' informations
-        $.getJSON(jsonFileTelemetry +'?timestamp='+ genTime + "&monkey_guid=" + monkey.guid+"&telem_type=scan", function(json) {
+    $.getJSON(jsonFileTelemetry +'?timestamp='+ temelGenerationDate + "&telem_type=scan", function(json) {
         temelGenerationDate = json.timestamp;
         var scans = json.objects;
         for (var i = 0; i < scans.length; i++) {
             var scan = scans[i];
+            var monkey = getMonkeyByGuid(scan.monkey_guid);
+
             //Check if we already exploited this machine from another PoV, if so no point in scanning.
             if (null != getMonkeyByIP(scan.data.machine.ip_addr)) {
                 //if so, make sure we don't already have such a node
@@ -329,6 +328,7 @@ function createScanned() {
                 });
                 continue;
             }
+
             //And check if we've already added this scanned machine
             var machineNode = getScannedByIP(scan.data.machine.ip_addr)
             if (null == machineNode) {
@@ -347,7 +347,6 @@ function createScanned() {
             updateCounters();
         }
     });
-    }
 }
 
 /**
@@ -414,7 +413,6 @@ function prepareSearchEngine() {
     });
 }
 
-
 /**
  * Manage the key presses events
  */
@@ -441,7 +439,6 @@ function onDoubleClick(properties) {
     onSelect(properties);
 }
 
-
 /**
  * Manage the event when an object is selected
  */
@@ -482,7 +479,6 @@ function onNodeSelect(nodeId) {
     }
 
     $("#selectionInfo").html(htmlContent);
-
     $('#monkey-config').show()
     $('#btnConfigLoad, #btnConfigUpdate').show();
 
@@ -496,7 +492,7 @@ function onNodeSelect(nodeId) {
     }
     $('#monkey-enabled').show();
 
-    $.getJSON('/api/telemetry/' + monkey.guid, function(json) {
+    $.getJSON('/api/telemetry?monkey_guid=' + monkey.guid, function(json) {
         telemTable.clear();
         var telemetries = json.objects;
 
@@ -666,6 +662,29 @@ function selectNode(hostname, zoom) {
 }
 
 
+function resetDB() {
+    if (confirm('Are you sure you want to empty the database?')) {
+        $.ajax({
+            headers : {
+                'Accept' : 'application/json',
+            },
+            url : '/api?action=reset',
+            type : 'GET',
+            success : function(response, textStatus, jqXhr) {
+                console.log("DB was successfully reset!");
+                location.reload();
+            },
+            error : function(jqXHR, textStatus, errorThrown) {
+                // log the error to the console
+                console.log("The following error occured: " + textStatus, errorThrown);
+            },
+            complete : function() {
+                console.log("Trying to reset DB...");
+            }
+        });
+    }
+}
+
 /**
  * Get a monkey from its id
  */

monkey_island/cc/main.py

@@ -26,7 +26,7 @@ MONKEY_DOWNLOADS = [
     {
         'type': 'windows',
         'machine': 'x86',
-        'filename': 'monkey-linux-32.exe',
+        'filename': 'monkey-windows-32.exe',
     },
     {
         'type': 'windows',
@@ -202,7 +202,7 @@ class MonkeyDownload(restful.Resource):
     def post(self):
         host_json = json.loads(request.data)
         host_os = host_json.get('os')
-        if os:
+        if host_os:
             result = None
             for download in MONKEY_DOWNLOADS:
                 if host_os.get('type') == download.get('type') and \