v0.4.15

added PushC2OneToMany Functionality

Author: its-a-feature

mythic_container/__init__.py

@@ -1,9 +1,9 @@
 from .rabbitmq import rabbitmqConnectionClass
 from .mythic_service import start_and_run_forever, test_command
 
-containerVersion = "v1.1.8"
+containerVersion = "v1.1.9"
 
-PyPi_version = "0.4.14"
+PyPi_version = "0.4.15"
 
 RabbitmqConnection = rabbitmqConnectionClass()
 

mythic_container/grpc/pushC2GRPC_pb2.py

@@ -5,25 +5,31 @@ from typing import ClassVar as _ClassVar, Optional as _Optional
 DESCRIPTOR: _descriptor.FileDescriptor
 
 class PushC2MessageFromAgent(_message.Message):
-    __slots__ = ["Base64Message", "C2ProfileName", "Message", "RemoteIP", "TaskingSize"]
+    __slots__ = ["AgentDisconnected", "Base64Message", "C2ProfileName", "Message", "OuterUUID", "RemoteIP", "TrackingID"]
+    AGENTDISCONNECTED_FIELD_NUMBER: _ClassVar[int]
+    AgentDisconnected: bool
     BASE64MESSAGE_FIELD_NUMBER: _ClassVar[int]
     Base64Message: bytes
     C2PROFILENAME_FIELD_NUMBER: _ClassVar[int]
     C2ProfileName: str
     MESSAGE_FIELD_NUMBER: _ClassVar[int]
     Message: bytes
+    OUTERUUID_FIELD_NUMBER: _ClassVar[int]
+    OuterUUID: str
     REMOTEIP_FIELD_NUMBER: _ClassVar[int]
     RemoteIP: str
-    TASKINGSIZE_FIELD_NUMBER: _ClassVar[int]
-    TaskingSize: int
-    def __init__(self, C2ProfileName: _Optional[str] = ..., RemoteIP: _Optional[str] = ..., TaskingSize: _Optional[int] = ..., Message: _Optional[bytes] = ..., Base64Message: _Optional[bytes] = ...) -> None: ...
+    TRACKINGID_FIELD_NUMBER: _ClassVar[int]
+    TrackingID: str
+    def __init__(self, C2ProfileName: _Optional[str] = ..., RemoteIP: _Optional[str] = ..., Message: _Optional[bytes] = ..., OuterUUID: _Optional[str] = ..., Base64Message: _Optional[bytes] = ..., TrackingID: _Optional[str] = ..., AgentDisconnected: bool = ...) -> None: ...
 
 class PushC2MessageFromMythic(_message.Message):
-    __slots__ = ["Error", "Message", "Success"]
+    __slots__ = ["Error", "Message", "Success", "TrackingID"]
     ERROR_FIELD_NUMBER: _ClassVar[int]
     Error: str
     MESSAGE_FIELD_NUMBER: _ClassVar[int]
     Message: bytes
     SUCCESS_FIELD_NUMBER: _ClassVar[int]
     Success: bool
-    def __init__(self, Success: bool = ..., Error: _Optional[str] = ..., Message: _Optional[bytes] = ...) -> None: ...
+    TRACKINGID_FIELD_NUMBER: _ClassVar[int]
+    TrackingID: str
+    def __init__(self, Success: bool = ..., Error: _Optional[str] = ..., Message: _Optional[bytes] = ..., TrackingID: _Optional[str] = ...) -> None: ...

mythic_container/grpc/pushC2GRPC_pb2.pyi

@@ -2,7 +2,7 @@
 """Client and server classes corresponding to protobuf-defined services."""
 import grpc
 
-import pushC2GRPC_pb2 as pushC2GRPC__pb2
+import mythic_container.grpc.pushC2GRPC_pb2 as pushC2GRPC__pb2
 
 
 class PushC2Stub(object):
@@ -19,6 +19,11 @@ def __init__(self, channel):
                 request_serializer=pushC2GRPC__pb2.PushC2MessageFromAgent.SerializeToString,
                 response_deserializer=pushC2GRPC__pb2.PushC2MessageFromMythic.FromString,
                 )
+        self.StartPushC2StreamingOneToMany = channel.stream_stream(
+                '/pushC2Services.PushC2/StartPushC2StreamingOneToMany',
+                request_serializer=pushC2GRPC__pb2.PushC2MessageFromAgent.SerializeToString,
+                response_deserializer=pushC2GRPC__pb2.PushC2MessageFromMythic.FromString,
+                )
 
 
 class PushC2Servicer(object):
@@ -31,6 +36,12 @@ def StartPushC2Streaming(self, request_iterator, context):
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
+    def StartPushC2StreamingOneToMany(self, request_iterator, context):
+        """Missing associated documentation comment in .proto file."""
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
 
 def add_PushC2Servicer_to_server(servicer, server):
     rpc_method_handlers = {
@@ -39,6 +50,11 @@ def add_PushC2Servicer_to_server(servicer, server):
                     request_deserializer=pushC2GRPC__pb2.PushC2MessageFromAgent.FromString,
                     response_serializer=pushC2GRPC__pb2.PushC2MessageFromMythic.SerializeToString,
             ),
+            'StartPushC2StreamingOneToMany': grpc.stream_stream_rpc_method_handler(
+                    servicer.StartPushC2StreamingOneToMany,
+                    request_deserializer=pushC2GRPC__pb2.PushC2MessageFromAgent.FromString,
+                    response_serializer=pushC2GRPC__pb2.PushC2MessageFromMythic.SerializeToString,
+            ),
     }
     generic_handler = grpc.method_handlers_generic_handler(
             'pushC2Services.PushC2', rpc_method_handlers)
@@ -65,3 +81,20 @@ def StartPushC2Streaming(request_iterator,
             pushC2GRPC__pb2.PushC2MessageFromMythic.FromString,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def StartPushC2StreamingOneToMany(request_iterator,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.stream_stream(request_iterator, target, '/pushC2Services.PushC2/StartPushC2StreamingOneToMany',
+            pushC2GRPC__pb2.PushC2MessageFromAgent.SerializeToString,
+            pushC2GRPC__pb2.PushC2MessageFromMythic.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

mythic_container/grpc/pushC2GRPC_pb2_grpc.py

@@ -10,7 +10,7 @@
 # This call to setup() does all the work
 setup(
     name="mythic_container",
-    version="0.4.14",
+    version="0.4.15",
     description="Functionality for Mythic Services",
     long_description=README,
     long_description_content_type="text/markdown",