SuperMega/app/views_project.py

from flask import Flask, Blueprint, current_app, request, redirect, url_for, render_template, send_file, make_response, session, jsonify
from threading import Thread
import os
import logging
from typing import List, Tuple
from pygments import highlight
from pygments.lexers import CLexer, NasmLexer, DiffLexer, HexdumpLexer
from pygments.formatters import HtmlFormatter
import difflib
import subprocess
from ansi2html import Ansi2HTMLConverter

from observer import observer
from config import config
from model.settings import Settings
from model.defs import *
from supermega import start
from app.storage import storage, WebProject
from sender import scannerDetectsBytes
from phases.injector import verify_injected_exe
from phases.templater import get_template_names
from helper import run_process_checkret, run_exe
from model.project import prepare_project
from pe.superpe import SuperPe 
import pe.dllresolver


logger = logging.getLogger("ViewsProjects")

views_project = Blueprint('views_project', __name__)

conv = Ansi2HTMLConverter()
config.load()
thread_running = False


@views_project.route("/projects")
def projects_route():
    projects = storage.get_projects()
    return render_template('projects.html', projects=projects)


@views_project.route("/project/<name>")
def project(name):
    project = storage.get_project(name)
    if project == None:
        return redirect("/projects", code=302)
    
    exe_path = project.settings.inject_exe_out
    is_built = False
    if os.path.exists(exe_path):
        is_built = True

    exports = []
    is_64 = False
    is_dotnet = False
    code_sect_size = 0
    data_sect_size = 0
    data_sect_largest_gap_size = 0
    payload_len = 0
    unresolved_dlls = []
    has_remote = False
    has_rodata_section = False

    if config.get("avred_server") != "":
        has_remote = True

    # when we select a shellcode
    if project.settings.payload_path != "":
        payload_len = os.path.getsize(project.settings.payload_path)

    # when we selected an input file
    if project.settings.inject_exe_in != "" and os.path.exists(project.settings.inject_exe_in):
        superpe = SuperPe(project.settings.inject_exe_in)
        #if not superpe.is_64():
        #    # return 500
        #    return "Error: Binary {} is not 64bit".format(project.settings.inject_exe_in), 500

        is_64 = superpe.is_64()
        is_dotnet = superpe.is_dotnet()
        if superpe.is_dll():
            exports = superpe.get_exports_full()
        code_sect_size = superpe.get_code_section().Misc_VirtualSize
        rdata_section = superpe.get_section_by_name(".rdata")
        if rdata_section != None:
            data_sect_size = rdata_section.virt_size
        else:
            logger.warning("No .rdata section found in {}".format(project.settings.inject_exe_in))
        
        has_rodata_section = superpe.has_rodata_section()
        if has_rodata_section:
            superpe.get_rdata_rangemanager().find_largest_gap()
        unresolved_dlls = pe.dllresolver.unresolved_dlls(superpe)

    project_dir = os.path.dirname(os.getcwd() + "\\" + project.settings.main_dir)
    log_files = get_logfiles(project.settings.main_dir)
    exes = list_files_and_sizes(PATH_EXES, prepend=PATH_EXES)
    exes += list_files_and_sizes(PATH_EXES_MORE, prepend=PATH_EXES_MORE)
    shellcodes = list_files_and_sizes(PATH_SHELLCODES)

    carrier_names = get_template_names()
    carrier_invoke_styles = [(color.name, color.value) for color in CarrierInvokeStyle]
    payload_locations = [(color.name, color.value) for color in PayloadLocation]

    guardrail_styles = list_files(PATH_GUARDRAILS)
    antiemulation_styles = list_files(PATH_ANTIEMULATION)
    decoy_styles = list_files(PATH_DECOY)
    virtualprotect_styles = list_files(PATH_VIRTUALPROTECT)
    decoder_styles = list_files(PATH_DECODER)


    return render_template('project.html', 
        project_name = name,
        project=project, 
        is_built=is_built,
        project_dir=project_dir,
        
        exes=exes,
        shellcodes=shellcodes,
        carrier_names=carrier_names,
        decoder_styles=decoder_styles,
        carrier_invoke_styles=carrier_invoke_styles,
        payload_locations=payload_locations,
        exports=exports,

        log_files=log_files,
        is_64=is_64,
        is_dotnet=is_dotnet,
        code_sect_size=code_sect_size,
        data_sect_size=data_sect_size,
        data_sect_largest_gap_size=data_sect_largest_gap_size,
        payload_len=payload_len,
        unresolved_dlls=unresolved_dlls,
        has_rodata_section=has_rodata_section,

        has_remote=has_remote,
        fix_missing_iat=project.settings.fix_missing_iat,

        guardrailstyles = guardrail_styles,
        antiemulationstyles = antiemulation_styles,
        decoystyles = decoy_styles,
        virtualprotectstyles = virtualprotect_styles
    )


def list_files_and_sizes(directory, prepend=""):
    # List all files in the directory and get their sizes
    files_and_sizes = []
    for filename in os.listdir(directory):
        filepath = os.path.join(directory, filename)
        if os.path.isfile(filepath):
            size = os.path.getsize(filepath)
            files_and_sizes.append({
                "filename": prepend + filename,
                "size": size,
            })
    return files_and_sizes


def list_files(directory, prepend="") -> List[str]:
    files = []
    for filename in os.listdir(directory):
        filepath = os.path.join(directory, filename)
        if os.path.isfile(filepath):
            filename = filename.replace(".c", "")
            files.append(filename)
    return files


@views_project.route("/project_add", methods=['POST', 'GET'])
def add_project():
    if request.method == 'POST':
        project_name = request.form['project_name']

        settings = Settings(project_name)
        comment = request.form['comment']

        # new project?
        if storage.get_project(project_name) == None:
            # Default values for web create
            settings.init_payload_injectable(
                FilePath("messagebox.bin"),
                FilePath("data/binary/exes/procexp64.exe"),
                ""
            )
            settings.decoder_style = "xor_2"
            settings.carrier_name = "alloc_rw_rx"
            settings.carrier_invoke_style = CarrierInvokeStyle.BackdoorCallInstr
            settings.payload_location = PayloadLocation.CODE
            settings.fix_missing_iat = True

            # add new project
            project = WebProject(project_name, settings)
            project.comment = comment
            storage.add_project(project)
        
        # update project
        else:
            settings.init_payload_injectable(
                request.form['shellcode'],
                request.form['exe'],
                request.form.get('dllfunc', "")
            )

            settings.fix_missing_iat = True if request.form.get('fix_missing_iat') != None else False
            settings.carrier_name = request.form['carrier_name']
            settings.plugin_antiemulation = request.form['antiemulation']
            settings.plugin_decoy = request.form['decoy']
            settings.plugin_guardrail = request.form['guardrail']
            carrier_invoke_style = request.form['carrier_invoke_style']
            settings.carrier_invoke_style = CarrierInvokeStyle[carrier_invoke_style]
            settings.decoder_style = request.form['decoder_style']
            payload_location = request.form['payload_location']
            settings.payload_location = PayloadLocation[payload_location]
            settings.plugin_guardrail_data = request.form.get('guardrail_data', settings.plugin_guardrail_data)
            settings.plugin_virtualprotect = request.form.get('virtualprotect')

            # overwrite project
            project = storage.get_project(project_name)
            project.settings = settings
            project.comment = comment
            storage.save_project(project)

        return redirect("/project/{}".format(project_name), code=302)
    
    else: # GET
        return render_template('project_add_get.html')


def supermega_thread(settings: Settings):
    global thread_running
    start(settings)
    thread_running = False


@views_project.route("/project/<project_name>/build", methods=['POST', 'GET'])
def build_project(project_name):
    global thread_running

    project = storage.get_project(project_name)

    #if project.settings.inject_exe_in.endswith(".dll"):
    #    if project.settings.dllfunc == "":
    #        logger.error("DLL injection requires a DLL function name")
    #        return redirect("/project/{}".format(project_name), code=302)

    project.settings.try_start_final_infected_exe = False
    prepare_project(project_name, project.settings)
    thread = Thread(target=supermega_thread, args=(project.settings, ))
    thread.start()
    thread_running = True

    return redirect("/project/{}/status".format(project_name), code=302)


@views_project.route("/project/<project_name>/status")
def status_project(project_name):
    global thread_running
    if thread_running:
        return render_template('status_project.html', 
            project_name=project_name,
            logdata = "\n".join(observer.get_logs()))
    else:
        return redirect("/project/{}".format(project_name), code=302)


@views_project.route("/project/<project_name>/exec", methods=['POST', 'GET'])
def start_project(project_name):
    project = storage.get_project(project_name)
    if project == None:
        return redirect("/", code=302)

    remote = False
    remote_arg = request.args.get('remote')
    if remote_arg == "true":
        remote = True

    no_exec = False
    no_exec_arg = request.args.get('no_exec')
    if no_exec_arg == "true":
        no_exec = True

    logger.info("--[ Exec project: {} remote: {} no_exec: {}".format(project_name, remote, no_exec))

    if remote:
        logger.info("--[ Exec {} on server {}".format(project.settings.inject_exe_out, config.get("avred_server")))
        with open(project.settings.inject_exe_out, "rb") as f:
            data = f.read()
        filename = os.path.basename(project.settings.inject_exe_out)
        try:
            scannerDetectsBytes(data, 
                                filename, 
                                useBrotli=True, 
                                verify=project.settings.verify,
                                no_exec=no_exec)
        except Exception as e:
            logger.error(f'Error scanning: {e}')
            return jsonify({
				"exception": str(e)
			}), 500
    else:
        # Start/verify it at the end
        if project.settings.verify:
            logger.info("--[ Verify infected exe")
            exit_code = verify_injected_exe(project.settings.inject_exe_out)
        elif no_exec == False:
            run_exe(project.settings.inject_exe_out, dllfunc=project.settings.dllfunc, check=False)
        elif no_exec == True:
            dirname = os.path.dirname(os.path.abspath(project.settings.inject_exe_out))
            logger.info("--[ Open folder: {}".format(dirname))
            subprocess.run(['explorer', dirname])

    return redirect("/project/{}".format(project_name), code=302)


def get_logfiles(directory):
    log_files = []
    id = 0
    asm_a = ""  # for diff
    asm_b = ""
    for file in os.listdir(f"{directory}/"):
        if file.startswith("."):
            continue
        if not file.startswith("log-"):
            continue
        if file.endswith(".bin"):
            continue

        with open(os.path.join(f"{directory}/", file), "r") as f:
            data = f.read()
            if 'main_c' in file:
                data = highlight(data, CLexer(), HtmlFormatter(full=False))
            elif '_asm_' in file:
                # handle special cases
                if '_orig' in file:
                    asm_a = data
                if '_updated' in file:
                    asm_b = data
                data = highlight(data, NasmLexer(), HtmlFormatter(full=False))
            elif '.ascii' in file:
                data = conv.convert(data, full=False)
            elif '.txt' in file:
                continue # skip it 
            elif '.hex' in file:
                continue # skip it 
                #data = escape(data)
                #data = highlight(data, HexdumpLexer(), HtmlFormatter(full=False))
            elif '.log' in file:
                data = conv.convert(data, full=False)
            else:
                data = data

            entry = {
                "name": file,
                "id": str(id),
                "content": data,
            }
            log_files.append(entry)
            id += 1

            # more
            if asm_a != "" and asm_b != "":
                # do the diff from the content of the two files
                a = asm_a.splitlines()
                b = asm_b.splitlines()
                diff_generator = difflib.unified_diff(a, b, lineterm='')
                diff_string = '\n'.join(diff_generator)
                diff_l = highlight(diff_string, DiffLexer(), HtmlFormatter(full=False))
                entry = {
                    "name": "Summary: ASM Diff".format(),
                    "id": str(id),
                    "content": diff_l,
                }
                log_files.append(entry)
                id += 1
                #asm_a = ""
                asm_b = ""
    return log_files