dobin-avred/avred.py

#!/usr/bin/python3

import argparse
import pickle
import os
import logging
from filehelper import *
from copy import deepcopy
import pprint
import signal


from config import config
from model.model_base import Outcome, ScanSpeed, ScanInfo

from model.model_verification import Appraisal, VerifyStatus
from filehelper import FileType
from scanner import ScannerRest, ScannerYara, hashCache
from scanning import scanIsHash

from plugins.plain.plugin_plain import PluginPlain
from plugins.dotnet.plugin_dotnet import PluginDotNet
from plugins.pe.plugin_pe import PluginPe
from plugins.office.plugin_office import PluginOffice
from model.plugin_model import Plugin
from verifier import verify
from reducer import Reducer


def handler(signum, frame):
    print("Ctrl-c was pressed, quitting.", end="\r\n", flush=True)
    print("If it doesnt quit, press ctrl-c rapidly...", end="\r\n", flush=True)
    exit(1)
signal.signal(signal.SIGINT, handler)


def main():
    parser = argparse.ArgumentParser()
    parser.add_argument("-f", "--file", help="File to scan")
    parser.add_argument("-u", "--uploads", help="Scan app/uploads/*", default=False, action='store_true')
    parser.add_argument('-s', "--server", help="Avred Server to use from config.json (default \"amsi\")", default="amsi")
    parser.add_argument("-e", "--scanspeed", help="1, 2, 3", default=2, type=int)
    #parser.add_argument("--logtofile", help="Log everything to <file>.log", default=False, action='store_true')
    parser.add_argument("-C", "--Config", help="Print config location and content", default=False, action='store_true')
    # debug
    parser.add_argument("--checkonly", help="Debug: Only check if AV detects the file as malicious", default=False, action='store_true')
    parser.add_argument("--reinfo", help="Debug: Re-do the file info", default=False, action='store_true')
    parser.add_argument("--rescan", help="Debug: Re-do the scanning for matches", default=False, action='store_true')
    parser.add_argument("--reverify", help="Debug: Re-do the verification", default=False, action='store_true')
    parser.add_argument("--reaugment", help="Debug: Re-do the augmentation", default=False, action='store_true')
    parser.add_argument("--reoutflank", help="Debug: Re-do the Outflanking", default=False, action='store_true')
    args = parser.parse_args()

    # Load config
    config.load()
    if args.Config:
        print("Config path: " + config.getConfigPath())
        pprint.pprint(config.getConfig())
        return
    
    if not os.path.exists(args.file):
        print("File {} does not exist. Aborting".format(args.file))
        return

    # do the scan
    setupLogging(args.file)
    logging.info("Using file: {}".format(args.file))
    if args.checkonly:
        checkFile(args.file, args.server)
    else:
        handleFile(args.file, args, args.server)


def setupLogging(filename):
    # Setup logging
    # log_format = '[%(levelname)-8s][%(asctime)s][%(filename)s:%(lineno)3d] %(funcName)s() :: %(message)s'
    logging.root.handlers = []

    log_format = '[%(levelname)-8s][%(asctime)s] %(funcName)s() :: %(message)s'
    handlers = [
        logging.StreamHandler(),
        logging.FileHandler(filename + ".log")
    ]
    logging.basicConfig(
        level=logging.INFO,
        format=log_format,
        handlers=handlers,
    )


def scanUploads(args, scanner):
    root_folder = os.path.dirname(__file__)
    upload_folder = os.path.join(root_folder, 'app', 'upload')
    files = os.listdir(upload_folder)

    for filename in files:
        if not filename.endswith('.outcome') and not filename.endswith('.log') and not filename.endswith('.gitkeep'):
            #handleFile(filename, args, scanner)
            filepath = os.path.join(upload_folder, filename)
            setupLogging(filepath)
            handleFile(filepath, args, scanner)


def handleFile(filename, args, serverName):
    file = None
    analyzerOptions = {
        "scanSpeed": ScanSpeed.Normal,
    }
    plugin: Plugin = None
    outcome: Outcome = None

    filenameOutcome = filename + ".outcome"
    logging.info("Handle file: " + filename)

    fileScannerType = getFileScannerTypeFor(filename)
    logging.info("Using parser for file type {}".format(fileScannerType.name))
    if fileScannerType is FileType.PLAIN:
        plugin = PluginPlain()
        file = plugin.makeFile(filename)
    elif fileScannerType is FileType.OFFICE:
        plugin = PluginOffice()
        file = plugin.makeFile(filename)
    elif fileScannerType is FileType.EXE:
        plugin = PluginPe()
        file = plugin.makeFile(filename)
    elif fileScannerType is FileType.DOTNET:
        plugin = PluginDotNet()
        file = plugin.makeFile(filename)
    else:
        logging.error("Unknown filetype, aborting")
        exit(1)

    # scanner is the connection to the AV-oracle
    scanner = None
    # load existing outcome
    if os.path.exists(filenameOutcome):
        with open(filenameOutcome, 'rb') as handle:
            outcome = pickle.load(handle)

        logging.warning("Using scanner as defined in outcome: {}".format(
            outcome.scanInfo.scannerName))
        scanner = getScannerObj(outcome.scanInfo.scannerName)
        if scanner is None:
            return

        if args.reinfo:
            fileInfo = getFileInfo(file)
            outcome.fileInfo = fileInfo
            outcome.sections = file.getSections()
            outcome.regions = file.regionsBag.sections
            outcome.saveToFile(file.filepath)
    else:
        logging.info("Using scanner from command line: {}".format(
            serverName))
        scanner = getScannerObj(serverName)
        if scanner is None:
            return

        fileInfo = getFileInfo(file)
        outcome = Outcome.nullOutcome(fileInfo)
        outcome.sections = file.getSections()
        outcome.regions = file.regionsBag.sections


    hashCache.load()
    # scan
    if not outcome.isScanned or args.rescan:
        scanner.checkOnlineOrExit()

        # unmodified file detected?
        outcome.isScanned = True  # we do the scan now
        if not scanIsDetected(file, scanner):
            outcome.isDetected = False
            outcome.appraisal = Appraisal.Undetected
            outcome.scanInfo = ScanInfo(scanner.scanner_name, analyzerOptions['scanSpeed'])
            logging.info("isDetected: {}".format(outcome.isDetected))
            outcome.saveToFile(file.filepath)
            hashCache.save()
            return
        outcome.isDetected = True

        # quick check hash
        if scanIsHash(file, scanner):
            outcome.appraisal = Appraisal.Hash
            outcome.scanInfo = ScanInfo(scanner.scanner_name, analyzerOptions['scanSpeed'])
            logging.info("Appraisal: {}".format(outcome.appraisal))
            outcome.saveToFile(file.filepath)
            hashCache.save()
            return
        
        logging.info(f"QuickCheck: {file.filename} is detected by {scanner.scanner_name} and not hash based")
        
        # ready to go
        isDetected = True  # we now know that the file is being detected
        filePlay = deepcopy(file)  # leave original unmodified, apply matches for iterative scanning here
        iteration = 0
        reducer = Reducer(filePlay, scanner, iteration, ScanSpeed(args.scanspeed))
        MAX_ITERATIONS = 6
        while isDetected:
            if iteration > MAX_ITERATIONS:
                logging.error("{} iterations deep and still no end.. bailing out".format(MAX_ITERATIONS))
                return

            # get matches
            logging.info("Scanning for matches...")
            matches, scanInfo = plugin.analyzeFile(filePlay, scanner, reducer, analyzerOptions)
            outcome.matches += matches
            logging.info("Result: {} matches".format(len(matches)))
            outcome.scanInfo = scanInfo
            outcome.saveToFile(filePlay.filepath)

            # apply matches and verify if it is not detected
            # TODO: will overwrite previously identified matches too, not just new ones
            filePlay.Data().hideMatches(outcome.matches)
            # try to identify matches until it is not detected anymore
            if scanIsDetected(filePlay, scanner):
                logging.info("Still detected on iteration {}, apply {} matches and do again".format(
                    iteration, len(matches)
                ))
                iteration += 1
                # not really necessary to create a new reducer
                # but it is tho (reset scan chunk size and similar)
                # but take-over previous matchIdx so we have unique incremental match ids
                reducer = Reducer(filePlay, scanner, iteration, ScanSpeed(args.scanspeed), matchIdx=reducer.matchIdx)
            else:
               break

        # sections of file now have the "detected" attribute set. re-add to the outcome with this info
        outcome.sections = filePlay.getSections()

    hashCache.save()
    #if not outcome.isMinimized:
    #    scanner.checkOnlineOrExit()
    #    timeStart = time.time()
    #    matches = minimizeMatches(file, outcome.matches, scanner)
    #    outcome.scanInfo.scanDuration += round(time.time() - timeStart)
    #
    #    logging.info("Previous matches: {}   After Minimizing: {}".format(
    #        len(outcome.matches), len(matches)
    #    ))
    #    outcome.matches = matches
    #    outcome.isMinimized = True

    if not outcome.isVerified or args.reverify:
        scanner.checkOnlineOrExit()
        outcome = verifyFile(outcome, file, scanner)
        outcome.saveToFile(file.filepath)

    if not outcome.isAugmented or args.reaugment:
        outcome = augmentFile(outcome, file, plugin.augmentFile)
        outcome.saveToFile(file.filepath)

    if not outcome.isOutflanked or args.reoutflank:
        outcome = outflankFile(plugin.outflankFile, outcome, file, scanner)
        outcome.saveToFile(file.filepath)

    hashCache.save()

    # output for cmdline users
    #print("Result:")
    #print(outcome)


def scanIsDetected(file: BaseFile, scanner):
    detected = scanner.scannerDetectsBytes(file.DataAsBytes(), file.filename)
    return detected


def verifyFile(outcome, file, scanner):
    # verify our analysis
    logging.info("Perform verification of matches")
    verification = verify(file, outcome.matches, scanner)
    outcome.verification = verification
    outcome.isVerified = True

    if len(outcome.matches) == 0:
        return outcome

    allCount = len(verification.matchConclusions.verifyStatus)
    robustCount = verification.matchConclusions.getCount(VerifyStatus.ROBUST)
    dominantCount = verification.matchConclusions.getCount(VerifyStatus.DOMINANT)
    irrelevantCount = verification.matchConclusions.getCount(VerifyStatus.IRRELEVANT)

    if robustCount == allCount:
        outcome.appraisal = Appraisal.Robust
    elif dominantCount == 1:
        outcome.appraisal = Appraisal.One
    elif dominantCount > 1:
        outcome.appraisal = Appraisal.Fragile

    return outcome


def augmentFile(outcome, file, augmenter):
    logging.info("Perform augmentation of matches")
    fileStructure = augmenter(file, outcome.matches)
    outcome.fileStructure = fileStructure
    outcome.isAugmented = True
    return outcome


def outflankFile(outflank, outcome: Outcome, file, scanner):
    logging.info("Attempt to outflank the file")
    outflankPatches = outflank(file, outcome.matches, outcome.verification.matchConclusions, scanner)

    #for p in outflankPatches:
    #    print("patch: " + str(p))

    outcome.outflankPatches = outflankPatches
    outcome.isOutflanked = True
    return outcome


# Check if file gets detected by the scanner
def checkFile(filepath, serverName):
    scanner = getScannerObj(serverName)
    if scanner is None:
        return

    data = None
    with open(filepath, 'rb') as file:
        data = file.read()
    print("Sending file to server")
    detected = scanner.scannerDetectsBytes(data, os.path.basename(filepath))
    if detected:
        print(f"File is detected")
    else:
        print(f"File is not detected")


def printMatches(matches):
    for match in matches:
        print("Match: " + str(match))


def getScannerObj(serverName):
    # Server load and alive check
    if serverName not in config.get("server"):
        logging.error(f"Could not find server with name '{serverName}' in config.json")
        exit(1)
    url = config.get("server")[serverName]
    if url.startswith("http"):
        scanner = ScannerRest(url, serverName)
    elif url.startswith("yara"):
        scanner = ScannerYara(url.replace("yara://", ""), serverName)
    else:
        logging.error("Not a valid URL, should start with http or yara: " + url)
        return None
    
    return scanner


if __name__ == "__main__":
    main()