more functional commands

Author: spenceradolph

Payload_Type/sliverimplant/sliverimplant/SliverRequests/SliverAPI.py

@@ -9,13 +9,15 @@
 from mythic_container.LoggingBase import *
 from mythic_container.MythicGoRPC import *
 
+from sliver import InteractiveBeacon
+
 # TODO: make this better, if using identify all fields that will be used / handle emptying when exiting
 sliver_clients = {}
 
 async def create_sliver_interact(taskData: PTTaskMessageAllData):
     # check to see if its cached
     if (f"{taskData.Callback.ID}" in sliver_clients.keys()):
-        return sliver_clients[f"{taskData.Callback.ID}"]['interact']
+        return sliver_clients[f"{taskData.Callback.ID}"]['interact'], isinstance(sliver_clients[f"{taskData.Callback.ID}"]['interact'], InteractiveBeacon)
 
     extraInfoObj = json.loads(taskData.Callback.ExtraInfo)
     configfile = extraInfoObj['slivercfg_fileid']

Payload_Type/sliverimplant/sliverimplant/agent_functions/mv.py

@@ -4,13 +4,30 @@
 from mythic_container.MythicRPC import *
 from mythic_container.PayloadBuilder import *
 
+from sliver import sliver_pb2, client_pb2
+
 class MvArguments(TaskArguments):
     def __init__(self, command_line, **kwargs):
         super().__init__(command_line, **kwargs)
-        self.args = []
+        self.args = [
+            CommandParameter(
+                name="src",
+                cli_name="src",
+                display_name="src",
+                description="source file",
+                type=ParameterType.String,
+            ),
+            CommandParameter(
+                name="dst",
+                cli_name="dst",
+                display_name="dst",
+                description="destination file",
+                type=ParameterType.String,
+            ),
+        ]
 
     async def parse_arguments(self):
-        pass
+        self.load_args_from_json_string(self.command_line)
 
 
 class Mv(CommandBase):
@@ -40,7 +57,9 @@ async def create_go_tasking(self, taskData: MythicCommandBase.PTTaskMessageAllDa
         # TODO:  -h, --help           display help
         # TODO:  -t, --timeout int    command timeout in seconds (default: 60)
 
-        response = await mv(taskData)
+        src = taskData.args.get_arg('src')
+        dst = taskData.args.get_arg('dst')
+        response = await mv(taskData, src, dst)
 
         await SendMythicRPCResponseCreate(MythicRPCResponseCreateMessage(
             TaskID=taskData.Task.ID,
@@ -58,12 +77,13 @@ async def process_response(self, task: PTTaskMessageAllData, response: any) -> P
         resp = PTTaskProcessResponseMessageResponse(TaskID=task.Task.ID, Success=True)
         return resp
 
-async def mv(taskData: PTTaskMessageAllData):
-    # interact, isBeacon = await SliverAPI.create_sliver_interact(taskData)
+async def mv(taskData: PTTaskMessageAllData, src: str, dst: str):
+    interact, isBeacon = await SliverAPI.create_sliver_interact(taskData)
 
-    # ifconfig_results = await interact._stub()
+    # TODO: figure out how to await the task completing
+    mv_results = await interact._stub.Mv(interact._request(sliver_pb2.MvReq(Src=src, Dst=dst)))
 
     # if (isBeacon):
-    #     ifconfig_results = await ifconfig_results
+    #     mv_results = await mv_results
 
-    return "This command not yet implemented..."
+    return f"Tasked [*] {src} > {dst}"

Payload_Type/sliverimplant/sliverimplant/agent_functions/pwd.py

@@ -4,6 +4,8 @@
 from mythic_container.MythicRPC import *
 from mythic_container.PayloadBuilder import *
 
+from sliver import sliver_pb2
+
 class PwdArguments(TaskArguments):
     def __init__(self, command_line, **kwargs):
         super().__init__(command_line, **kwargs)
@@ -60,6 +62,8 @@ async def pwd(taskData: PTTaskMessageAllData):
 
     pwd_results = await interact.pwd()
 
+    # pwd_results = await interact._stub.Pwd(interact._request(sliver_pb2.PwdReq()))
+
     if (isBeacon):
         pwd_results = await pwd_results
 

Payload_Type/sliverimplant/sliverimplant/agent_functions/reconfig.py

@@ -4,13 +4,21 @@
 from mythic_container.MythicRPC import *
 from mythic_container.PayloadBuilder import *
 
+from sliver import sliver_pb2
+
 class ReconfigArguments(TaskArguments):
     def __init__(self, command_line, **kwargs):
         super().__init__(command_line, **kwargs)
-        self.args = []
+        self.args = [
+            CommandParameter(
+                name="beacon_interval",
+                description="beacon_interval in seconds",
+                type=ParameterType.Number,
+            ),
+        ]
 
     async def parse_arguments(self):
-        pass
+        self.load_args_from_json_string(self.command_line)
 
 
 class Reconfig(CommandBase):
@@ -32,13 +40,14 @@ async def create_go_tasking(self, taskData: MythicCommandBase.PTTaskMessageAllDa
 
         # Flags:
         # ======
-        # TODO:  -i, --beacon-interval    string    beacon callback interval
+        #        -i, --beacon-interval    string    beacon callback interval
         # TODO:  -j, --beacon-jitter      string    beacon callback jitter (random up to)
         # TODO:  -h, --help                         display help
         # TODO:  -r, --reconnect-interval string    reconnect interval for implant
         # TODO:  -t, --timeout            int       command timeout in seconds (default: 60)
 
-        response = await reconfig(taskData)
+        beacon_interval = taskData.args.get_arg('beacon_interval')
+        response = await reconfig(taskData, beacon_interval)
 
         await SendMythicRPCResponseCreate(MythicRPCResponseCreateMessage(
             TaskID=taskData.Task.ID,
@@ -56,12 +65,17 @@ async def process_response(self, task: PTTaskMessageAllData, response: any) -> P
         resp = PTTaskProcessResponseMessageResponse(TaskID=task.Task.ID, Success=True)
         return resp
 
-async def reconfig(taskData: PTTaskMessageAllData):
-    # interact, isBeacon = await SliverAPI.create_sliver_interact(taskData)
+async def reconfig(taskData: PTTaskMessageAllData, beacon_interval_seconds: int):
+    interact, isBeacon = await SliverAPI.create_sliver_interact(taskData)
+
+    if (not isBeacon):
+        return "Beacon only command!"
+    
+    beacon_interval = beacon_interval_seconds * 1000000000
 
-    # ifconfig_results = await interact._stub()
+    reconfig_results = await interact._stub.Reconfigure(interact._request(sliver_pb2.ReconfigureReq(BeaconInterval=beacon_interval)))
 
     # if (isBeacon):
     #     ifconfig_results = await ifconfig_results
 
-    return "This command not yet implemented..."
+    return "Tasked Reconfig!"

README.md

@@ -121,15 +121,15 @@ sudo ./mythic-cli install github https://github.com/MythicAgents/sliver
     - mkdir✅
     - msf👷
     - msf-inject👷
-    - mv👷
+    - mv✅
     - netstat✅
     - ping✅ (session only)
     - pivots👷 (session only)
     - portfwd👷
     - procdump👷
     - ps✅
     - pwd✅
-    - reconfig👷 (beacon only)
+    - reconfig✅ (beacon only)
     - rename (not applicable?)
     - rm✅
     - rportfwd👷