import struct, io
from dataclasses import dataclass
from grope import BlobIO, rope
from .struct3 import Struct3, u8, u16, u32, u64, char
from .rsrc import parse_pe_resources
from .rsrc import KnownResourceTypes
import uuid
from .version_info import parse_version_info

class _IMAGE_FILE_HEADER(Struct3):
    Machine: u16
    NumberOfSections: u16
    TimeDateStamp: u32
    PointerToSymbolTable: u32
    NumberOfSymbols: u32
    SizeOfOptionalHeader: u16
    Characteristics: u16

IMAGE_NT_OPTIONAL_HDR32_MAGIC = 0x10b
IMAGE_NT_OPTIONAL_HDR64_MAGIC = 0x20b

class _IMAGE_OPTIONAL_HEADER32(Struct3):
    MajorLinkerVersion: u8
    MinorLinkerVersion: u8
    SizeOfCode: u32
    SizeOfInitializedData: u32
    SizeOfUninitializedData: u32
    AddressOfEntryPoint: u32
    BaseOfCode: u32
    BaseOfData: u32
    ImageBase: u32
    SectionAlignment: u32
    FileAlignment: u32
    MajorOperatingSystemVersion: u16
    MinorOperatingSystemVersion: u16
    MajorImageVersion: u16
    MinorImageVersion: u16
    MajorSubsystemVersion: u16
    MinorSubsystemVersion: u16
    Reserved1: u32
    SizeOfImage: u32
    SizeOfHeaders: u32
    CheckSum: u32
    Subsystem: u16
    DllCharacteristics: u16
    SizeOfStackReserve: u32
    SizeOfStackCommit: u32
    SizeOfHeapReserve: u32
    SizeOfHeapCommit: u32
    LoaderFlags: u32
    NumberOfRvaAndSizes: u32

class _IMAGE_OPTIONAL_HEADER64(Struct3):
    MajorLinkerVersion: u8
    MinorLinkerVersion: u8
    SizeOfCode: u32
    SizeOfInitializedData: u32
    SizeOfUninitializedData: u32
    AddressOfEntryPoint: u32
    BaseOfCode: u32
    ImageBase: u64
    SectionAlignment: u32
    FileAlignment: u32
    MajorOperatingSystemVersion: u16
    MinorOperatingSystemVersion: u16
    MajorImageVersion: u16
    MinorImageVersion: u16
    MajorSubsystemVersion: u16
    MinorSubsystemVersion: u16
    Reserved1: u32
    SizeOfImage: u32
    SizeOfHeaders: u32
    CheckSum: u32
    Subsystem: u16
    DllCharacteristics: u16
    SizeOfStackReserve: u64
    SizeOfStackCommit: u64
    SizeOfHeapReserve: u64
    SizeOfHeapCommit: u64
    LoaderFlags: u32
    NumberOfRvaAndSizes: u32

class _IMAGE_DATA_DIRECTORY(Struct3):
    VirtualAddress: u32
    Size: u32

class _IMAGE_SECTION_HEADER(Struct3):
    Name: char[8]
    VirtualSize: u32
    VirtualAddress: u32
    SizeOfRawData: u32
    PointerToRawData: u32
    PointerToRelocations: u32
    PointerToLinenumbers: u32
    NumberOfRelocations: u16
    NumberOfLinenumbers: u16
    Characteristics: u32

class _IMAGE_DEBUG_DIRECTORY(Struct3):
    Characteristics: u32
    TimeDateStamp: u32
    MajorVersion: u16
    MinorVersion: u16
    Type: u32
    SizeOfData: u32
    AddressOfRawData: u32
    PointerToRawData: u32

class _IMAGE_DEBUG_CODEVIEW(Struct3):
    rsds: char[4]
    guid: char[16]
    age: u32

@dataclass
class PeIdent:
    image_name: str
    timestamp: int
    size_of_image: int

    @classmethod
    def from_pelink(cls, pelink: str):
        fname, tssize = pelink.split('/')
        ts = int(tssize[:8], 16)
        size = int(tssize[8:], 16)
        return cls(image_name=fname, timestamp=ts, size_of_image=size)

    @property
    def pelink(self):
        return f'{self.image_name}/{self.timestamp:08x}{self.size_of_image:x}'

    def __str__(self):
        return self.pelink
@dataclass
class CodeviewLink:
    guid: uuid.UUID
    age: int
    filename: str

    @classmethod
    def from_bxlink(cls, bxlink: str):
        fname, bxlink = bxlink.split('{', 1)
        guid, age = bxlink.split('}', 1)
        return cls(guid=uuid.UUID(guid), age=int(age, 10), filename=fname)

    @property
    def bxlink(self):
        return f'{self.filename}{{{self.guid}}}{self.age}'

    @property
    def short_filename(self):
        return self.filename.rsplit('\\', 1)[-1]

    def __str__(self):
        return self.bxlink

IMAGE_DEBUG_TYPE_CODEVIEW = 2

IMAGE_SCN_TYPE_REG                   = 0x00000000
IMAGE_SCN_TYPE_DSECT                 = 0x00000001
IMAGE_SCN_TYPE_NOLOAD                = 0x00000002
IMAGE_SCN_TYPE_GROUP                 = 0x00000004
IMAGE_SCN_TYPE_NO_PAD                = 0x00000008
IMAGE_SCN_TYPE_COPY                  = 0x00000010
IMAGE_SCN_CNT_CODE                   = 0x00000020
IMAGE_SCN_CNT_INITIALIZED_DATA       = 0x00000040
IMAGE_SCN_CNT_UNINITIALIZED_DATA     = 0x00000080
IMAGE_SCN_LNK_OTHER                  = 0x00000100
IMAGE_SCN_LNK_INFO                   = 0x00000200
IMAGE_SCN_TYPE_OVER                  = 0x00000400
IMAGE_SCN_LNK_REMOVE                 = 0x00000800
IMAGE_SCN_LNK_COMDAT                 = 0x00001000
IMAGE_SCN_NO_DEFER_SPEC_EXC          = 0x00004000
IMAGE_SCN_GPREL                      = 0x00008000
IMAGE_SCN_MEM_FARDATA                = 0x00008000
IMAGE_SCN_MEM_PURGEABLE              = 0x00020000
IMAGE_SCN_MEM_16BIT                  = 0x00020000
IMAGE_SCN_MEM_LOCKED                 = 0x00040000
IMAGE_SCN_MEM_PRELOAD                = 0x00080000
IMAGE_SCN_ALIGN_1BYTES               = 0x00100000
IMAGE_SCN_ALIGN_2BYTES               = 0x00200000
IMAGE_SCN_ALIGN_4BYTES               = 0x00300000
IMAGE_SCN_ALIGN_8BYTES               = 0x00400000
IMAGE_SCN_ALIGN_16BYTES              = 0x00500000
IMAGE_SCN_ALIGN_32BYTES              = 0x00600000
IMAGE_SCN_ALIGN_64BYTES              = 0x00700000
IMAGE_SCN_ALIGN_128BYTES             = 0x00800000
IMAGE_SCN_ALIGN_256BYTES             = 0x00900000
IMAGE_SCN_ALIGN_512BYTES             = 0x00A00000
IMAGE_SCN_ALIGN_1024BYTES            = 0x00B00000
IMAGE_SCN_ALIGN_2048BYTES            = 0x00C00000
IMAGE_SCN_ALIGN_4096BYTES            = 0x00D00000
IMAGE_SCN_ALIGN_8192BYTES            = 0x00E00000
IMAGE_SCN_ALIGN_MASK                 = 0x00F00000
IMAGE_SCN_LNK_NRELOC_OVFL            = 0x01000000
IMAGE_SCN_MEM_DISCARDABLE            = 0x02000000
IMAGE_SCN_MEM_NOT_CACHED             = 0x04000000
IMAGE_SCN_MEM_NOT_PAGED              = 0x08000000
IMAGE_SCN_MEM_SHARED                 = 0x10000000
IMAGE_SCN_MEM_EXECUTE                = 0x20000000
IMAGE_SCN_MEM_READ                   = 0x40000000
IMAGE_SCN_MEM_WRITE                  = 0x80000000


def _align(offs, alignment):
    return (offs + alignment - 1) // alignment * alignment

IMAGE_DIRECTORY_ENTRY_EXPORT = 0
IMAGE_DIRECTORY_ENTRY_IMPORT = 1
IMAGE_DIRECTORY_ENTRY_RESOURCE = 2
IMAGE_DIRECTORY_ENTRY_EXCEPTION = 3
IMAGE_DIRECTORY_ENTRY_SECURITY = 4
IMAGE_DIRECTORY_ENTRY_BASERELOC = 5
IMAGE_DIRECTORY_ENTRY_DEBUG = 6
IMAGE_DIRECTORY_ENTRY_ARCHITECTURE = 7
IMAGE_DIRECTORY_ENTRY_GLOBALPTR = 8
IMAGE_DIRECTORY_ENTRY_TLS = 9
IMAGE_DIRECTORY_ENTRY_LOAD_CONFIG = 10
IMAGE_DIRECTORY_ENTRY_BOUND_IMPORT = 11
IMAGE_DIRECTORY_ENTRY_IAT = 12
IMAGE_DIRECTORY_ENTRY_DELAY_IMPORT = 13
IMAGE_DIRECTORY_ENTRY_COM_DESCRIPTOR = 14

class _PeSection:
    def __init__(self, hdr, data):
        self.hdr = hdr
        self.data = data

def pe_checksum(blob):
    total_len = len(blob)

    r = 0
    while len(blob) >= 0x1000:
        words = struct.unpack('<2048H', bytes(blob[:0x1000]))
        r += sum(words)
        blob = blob[0x1000:]

    if len(blob) % 2 != 0:
        blob = rope(blob, b'\0')
    words = struct.unpack('<' + 'H'*(len(blob) // 2), bytes(blob))
    r += sum(words)

    while r > 0xffff:
        c = r
        r = 0
        while c:
            r += c & 0xffff
            c >>= 16

    return r + total_len

def _read(blob, fmt):
    size = struct.calcsize(fmt)
    return struct.unpack(fmt, bytes(blob[:size]))

def parse_rsds_blob(blob):
    if len(blob) < _IMAGE_DEBUG_CODEVIEW.size:
        return None

    cv = _IMAGE_DEBUG_CODEVIEW.unpack_from(blob)
    if cv.rsds != b'RSDS':
        return None

    fname = bytes(blob[_IMAGE_DEBUG_CODEVIEW.size:])
    fname, *_ = fname.split(b'\0', 1)
    return CodeviewLink(uuid.UUID(bytes_le=cv.guid), cv.age, fname.decode('utf-8'))

class _PeFile:
    def __init__(self, blob, verify_checksum=False):
        pe_offs, = _read(blob[0x3c:], '<H')

        fin = BlobIO(blob[pe_offs:])

        sig = fin.read(4)
        if sig != b'PE\0\0':
            raise RuntimeError('Not a PE file: PE signature is missing.')

        hdr = _IMAGE_FILE_HEADER.unpack_from_io(fin)
        opt_sig, = struct.unpack('<H', fin.read(2))
        if opt_sig == IMAGE_NT_OPTIONAL_HDR32_MAGIC:
            opt = _IMAGE_OPTIONAL_HEADER32.unpack_from_io(fin)
            opt.sig = opt_sig
        elif opt_sig == IMAGE_NT_OPTIONAL_HDR64_MAGIC:
            opt = _IMAGE_OPTIONAL_HEADER64.unpack_from_io(fin)
            opt.sig = opt_sig
        else:
            raise RuntimeError('Unknown optional header type.')

        self._checksum_offs = pe_offs + 4 + _IMAGE_FILE_HEADER.size + 4*16

        if verify_checksum:
            if opt.CheckSum == 0:
                self.checksum_correct = False
            else:
                real_checksum = pe_checksum(rope(blob[:self._checksum_offs], b'\0\0\0\0', blob[self._checksum_offs + 4:]))
                self.checksum_correct = real_checksum == opt.CheckSum

        if opt.FileAlignment == 0:
            raise RuntimeError('IMAGE_OPTIONAL_HEADER.FileAlignment must be nonzero')

        dds = [_IMAGE_DATA_DIRECTORY.unpack_from_io(fin) for dd_idx in range(opt.NumberOfRvaAndSizes)]

        def make_pe_section(idx, hdr):
            name = hdr.Name.rstrip(b'\0')

            if hdr.PointerToRawData % opt.FileAlignment != 0:
                raise RuntimeError('Section {}@{} is misaligned ({})'.format(name, idx, hdr.PointerToRawData))
            if hdr.SizeOfRawData % opt.FileAlignment != 0:
                raise RuntimeError('Size of section {}@{} is misaligned ({})'.format(name, idx, hdr.SizeOfRawData))

            if hdr.PointerToRawData == 0:
                data = None
            else:
                data = blob[hdr.PointerToRawData:hdr.PointerToRawData + hdr.SizeOfRawData]

            return _PeSection(hdr, data)

        sections = [make_pe_section(sec_idx, _IMAGE_SECTION_HEADER.unpack_from_io(fin)) for sec_idx in range(hdr.NumberOfSections)]

        present_secs = sorted((sec for sec in sections if sec.hdr.SizeOfRawData != 0), key=lambda sec: sec.hdr.PointerToRawData)
        if not present_secs:
            raise RuntimeError('no present sections')

        i = 1
        while i < len(present_secs):
            if present_secs[i-1].hdr.PointerToRawData + present_secs[i-1].hdr.SizeOfRawData != present_secs[i].hdr.PointerToRawData:
                raise RuntimeError('there are holes between sections')
            i += 1

        last_sec = present_secs[-1]
        end_of_image = last_sec.hdr.PointerToRawData + last_sec.hdr.SizeOfRawData

        self._blob = blob
        self._dos_stub = blob[:pe_offs]
        self._file_header = hdr
        self._opt_header = opt
        self._data_directories = dds
        self._sections = sections

        self._trailer = blob[end_of_image:]

        self._check_vm_overlaps()

    def _file_align(self, addr):
        return _align(addr, self._opt_header.FileAlignment)

    def _mem_align(self, addr):
        return _align(addr, self._opt_header.SectionAlignment)

    def _check_vm_overlaps(self):
        next_free_address = None
        for sec in self._sections:
            if sec.hdr.VirtualAddress % self._opt_header.SectionAlignment != 0:
                raise RuntimeError('sections are misaligned in memory')

            if next_free_address is not None and sec.hdr.VirtualAddress != next_free_address:
                raise RuntimeError('there are holes in the section map')

            next_free_address = self._mem_align(sec.hdr.VirtualAddress + sec.hdr.VirtualSize)

    @property
    def file_header(self):
        return self._file_header

    @property
    def optional_header(self):
        return self._opt_header

    def get_vm(self, start, stop):
        for sec in self._sections:
            if sec.hdr.VirtualAddress <= start and sec.hdr.VirtualAddress + sec.hdr.VirtualSize >= stop:
                sec_offs = start - sec.hdr.VirtualAddress
                init_size = min(sec.hdr.SizeOfRawData - sec_offs, stop - start)
                uninit_size = stop - start - init_size
                if len(sec.data) < sec_offs + init_size:
                    raise RuntimeError('PE file corrupt: missing section content')
                return rope(sec.data[sec_offs:sec_offs + init_size], b'\0'*uninit_size)

    def has_trailer(self):
        return bool(self._trailer)

    def remove_trailer(self):
        self.remove_signature()
        self._trailer = b''

    def has_signature(self):
        return len(self._data_directories) > IMAGE_DIRECTORY_ENTRY_SECURITY and self._data_directories[IMAGE_DIRECTORY_ENTRY_SECURITY].VirtualAddress != 0

    def remove_signature(self):
        if len(self._data_directories) < IMAGE_DIRECTORY_ENTRY_SECURITY:
            return

        dd = self._data_directories[IMAGE_DIRECTORY_ENTRY_SECURITY]
        if dd.Size == 0:
            return

        end_of_image = max(sec.hdr.PointerToRawData + sec.hdr.SizeOfRawData for sec in self._sections if sec.hdr.SizeOfRawData != 0)

        if dd.VirtualAddress + dd.Size != end_of_image + len(self._trailer):
            raise RuntimeError('signature is not at the end of the file')

        if dd.VirtualAddress < end_of_image:
            raise RuntimeError('signature is not contained in the pe trailer')

        self._trailer = self._trailer[:-dd.Size]
        dd.VirtualAddress = 0
        dd.Size = 0

    def has_directory(self, idx):
        if len(self._data_directories) < idx:
            return False

        dd = self._data_directories[idx]
        return dd.VirtualAddress != 0

    def find_directory(self, idx):
        if len(self._data_directories) < idx:
            return None

        dd = self._data_directories[idx]
        if dd.VirtualAddress == 0:
            return None

        return slice(dd.VirtualAddress, dd.VirtualAddress + dd.Size)

    def get_codeview_link(self):
        debug_dir = self.get_directory_contents(IMAGE_DIRECTORY_ENTRY_DEBUG)

        while debug_dir:
            dd = _IMAGE_DEBUG_DIRECTORY.unpack_from(debug_dir)
            debug_dir = debug_dir[_IMAGE_DEBUG_DIRECTORY.size:]

            if dd.Type == IMAGE_DEBUG_TYPE_CODEVIEW:
                dl = self._blob[dd.PointerToRawData:dd.PointerToRawData+dd.SizeOfData]

                cv = parse_rsds_blob(dl)
                if cv is not None:
                    return cv
        return None

    def get_directory_contents(self, idx):
        dd = self.find_directory(idx)
        if dd is None:
            return None

        return self.get_vm(dd.start, dd.stop)

    def parse_resources(self):
        vm_slice = self.find_directory(IMAGE_DIRECTORY_ENTRY_RESOURCE)
        if vm_slice is None:
            return None

        data = self.get_vm(vm_slice.start, vm_slice.stop)
        return parse_pe_resources(data, vm_slice.start)

    def _get_version_info_dict(self):
        res = self.parse_resources()
        if not res:
            return
        return res.get(KnownResourceTypes.RT_VERSION, {}).get(1, {})

    def get_version_info(self, langs=(0x0409, 0)):
        vis = self._get_version_info_dict()
        if not vis:
            return None

        for lngid in langs:
            vi = vis.get(lngid)
            if vi is not None:
                break
        else:
            lngid, vi = vis.popitem()

        return parse_version_info(vi)

    def get_file_version(self):
        vi = self.get_version_info()
        return vi.get_fixed_info().file_version_tuple if vi else None

    def get_product_version(self):
        vi = self.get_version_info()
        return vi.get_fixed_info().product_version_tuple if vi else None

    def _get_directory_section(self, dd_idx):
        if dd_idx >= len(self._data_directories):
            return None

        dd = self._data_directories[dd_idx]
        if dd.Size == 0:
            return None

        for sec_idx, sec in enumerate(self._sections):
            if sec.hdr.VirtualAddress == dd.VirtualAddress and sec.hdr.VirtualSize == dd.Size:
                return sec_idx

    def _find_vm_hole(self, secs, size):
        sorted_secs = sorted(secs, key=lambda sec: sec.hdr.VirtualAddress)
        i = 1
        while i < len(sorted_secs):
            start = self._mem_align(sorted_secs[i-1].hdr.VirtualAddress + sorted_secs[i-1].hdr.VirtualSize)
            stop = sorted_secs[i].hdr.VirtualAddress

            if stop - start >= size:
                return slice(start, self._mem_align(start + size))

            i += 1

        start = self._mem_align(sorted_secs[-1].hdr.VirtualAddress + sorted_secs[-1].hdr.VirtualSize)
        return slice(start, self._mem_align(start + size))

    def _resize_directory(self, idx, size):
        sec_idx = self._get_directory_section(idx)
        if sec_idx is None:
            raise RuntimeError('can\'t modify a directory that is not associated with a section')

        sec = self._sections[sec_idx]
        move_map = {}

        addr = self._mem_align(sec.hdr.VirtualAddress + size)
        for other_sec in self._sections[sec_idx + 1:]:
            move_map[other_sec] = addr
            addr = self._mem_align(addr + other_sec.hdr.VirtualSize)

        for dd in self._data_directories:
            if dd.VirtualAddress == 0:
                continue

            for osec, target_addr in move_map.items():
                if osec.hdr.VirtualAddress <= dd.VirtualAddress <= osec.hdr.VirtualAddress + osec.hdr.VirtualSize:
                    dd.VirtualAddress += target_addr - osec.hdr.VirtualAddress
                    break

        for osec, target_addr in move_map.items():
            osec.hdr.VirtualAddress = target_addr

        sec.hdr.VirtualSize = size

        dd = self._data_directories[idx]
        dd.Size = size

        return sec_idx, sec.hdr.VirtualAddress

    def is_dir_safely_resizable(self, idx):
        sec_idx = self._get_directory_section(idx)
        if sec_idx is None:
            return False

        return all((sec.hdr.Characteristics & IMAGE_SCN_MEM_DISCARDABLE) != 0 for sec in self._sections[sec_idx+1:])

    def resize_directory(self, idx, size):
        _, addr = self._resize_directory(idx, size)
        return addr

    def set_directory(self, idx, blob):
        sec_idx, _ = self._resize_directory(idx, len(blob))

        sec = self._sections[sec_idx]
        sec.data = blob

    def to_blob(self, update_checksum=False):
        self._opt_header.CheckSum = 0
        self._opt_header.SizeOfImage = max(self._mem_align(sec.hdr.VirtualAddress + sec.hdr.VirtualSize) for sec in self._sections)

        self._check_vm_overlaps()

        header_end = (len(self._dos_stub) + 4 + self._file_header.size + 2 + self._opt_header.size
            + len(self._data_directories) * _IMAGE_DATA_DIRECTORY.size + len(self._sections) * _IMAGE_SECTION_HEADER.size)
        section_offset = self._file_align(header_end)
        header_pad = section_offset - header_end

        for sec in self._sections:
            if sec.hdr.PointerToRawData == 0:
                continue
            sec.hdr.PointerToRawData = section_offset
            sec.hdr.SizeOfRawData = self._file_align(len(sec.data))
            section_offset = section_offset + sec.hdr.SizeOfRawData

        new_file = []

        new_file.append(self._dos_stub)
        new_file.append(b'PE\0\0')
        new_file.append(self._file_header.pack())
        new_file.append(struct.pack('<H', self._opt_header.sig))
        new_file.append(self._opt_header.pack())

        for dd in self._data_directories:
            new_file.append(dd.pack())

        for sec in self._sections:
            new_file.append(sec.hdr.pack())

        new_file.append(b'\0'*header_pad)
        for sec in self._sections:
            if sec.data is None:
                continue
            new_file.append(sec.data)
            with_pad = self._file_align(len(sec.data))
            pad = with_pad - len(sec.data)
            if pad:
                new_file.append(b'\0'*pad)

        new_file.append(self._trailer)

        out_blob = rope(*new_file)
        if update_checksum:
            new_checksum = pe_checksum(out_blob)
        else:
            new_checksum = 0

        return rope(out_blob[:self._checksum_offs], struct.pack('<I', new_checksum), out_blob[self._checksum_offs + 4:])

    def to_bytes(self, update_checksum=False):
        return bytes(self.to_blob(update_checksum=update_checksum))

def parse_pe(blob, verify_checksum=False):
    """Parse a PE file and return a PeFile object
    
    Expects either a bytes object or a grope.rope object consisting
    only of bytes objects (the latter is recommended).

    Set `verify_checksum=True` to add `checksum_correct` member to
    the returned object.
    """

    if isinstance(blob, bytes):
        blob = memoryview(blob)
    return _PeFile(blob, verify_checksum=verify_checksum)

622815c6eff37a23b49f47b4548fb9812d5af5f5
<mask token>


class _PeFile:

    def __init__(self, blob, verify_checksum=False):
        pe_offs, = _read(blob[60:], '<H')
        fin = BlobIO(blob[pe_offs:])
        sig = fin.read(4)
        if sig != b'PE\x00\x00':
            raise RuntimeError('Not a PE file: PE signature is missing.')
        hdr = _IMAGE_FILE_HEADER.unpack_from_io(fin)
        opt_sig, = struct.unpack('<H', fin.read(2))
        if opt_sig == IMAGE_NT_OPTIONAL_HDR32_MAGIC:
            opt = _IMAGE_OPTIONAL_HEADER32.unpack_from_io(fin)
            opt.sig = opt_sig
        elif opt_sig == IMAGE_NT_OPTIONAL_HDR64_MAGIC:
            opt = _IMAGE_OPTIONAL_HEADER64.unpack_from_io(fin)
            opt.sig = opt_sig
        else:
            raise RuntimeError('Unknown optional header type.')
        self._checksum_offs = pe_offs + 4 + _IMAGE_FILE_HEADER.size + 4 * 16
        if verify_checksum:
            if opt.CheckSum == 0:
                self.checksum_correct = False
            else:
                real_checksum = pe_checksum(rope(blob[:self._checksum_offs],
                    b'\x00\x00\x00\x00', blob[self._checksum_offs + 4:]))
                self.checksum_correct = real_checksum == opt.CheckSum
        if opt.FileAlignment == 0:
            raise RuntimeError(
                'IMAGE_OPTIONAL_HEADER.FileAlignment must be nonzero')
        dds = [_IMAGE_DATA_DIRECTORY.unpack_from_io(fin) for dd_idx in
            range(opt.NumberOfRvaAndSizes)]

        def make_pe_section(idx, hdr):
            name = hdr.Name.rstrip(b'\x00')
            if hdr.PointerToRawData % opt.FileAlignment != 0:
                raise RuntimeError('Section {}@{} is misaligned ({})'.
                    format(name, idx, hdr.PointerToRawData))
            if hdr.SizeOfRawData % opt.FileAlignment != 0:
                raise RuntimeError('Size of section {}@{} is misaligned ({})'
                    .format(name, idx, hdr.SizeOfRawData))
            if hdr.PointerToRawData == 0:
                data = None
            else:
                data = blob[hdr.PointerToRawData:hdr.PointerToRawData + hdr
                    .SizeOfRawData]
            return _PeSection(hdr, data)
        sections = [make_pe_section(sec_idx, _IMAGE_SECTION_HEADER.
            unpack_from_io(fin)) for sec_idx in range(hdr.NumberOfSections)]
        present_secs = sorted((sec for sec in sections if sec.hdr.
            SizeOfRawData != 0), key=lambda sec: sec.hdr.PointerToRawData)
        if not present_secs:
            raise RuntimeError('no present sections')
        i = 1
        while i < len(present_secs):
            if present_secs[i - 1].hdr.PointerToRawData + present_secs[i - 1
                ].hdr.SizeOfRawData != present_secs[i].hdr.PointerToRawData:
                raise RuntimeError('there are holes between sections')
            i += 1
        last_sec = present_secs[-1]
        end_of_image = (last_sec.hdr.PointerToRawData + last_sec.hdr.
            SizeOfRawData)
        self._blob = blob
        self._dos_stub = blob[:pe_offs]
        self._file_header = hdr
        self._opt_header = opt
        self._data_directories = dds
        self._sections = sections
        self._trailer = blob[end_of_image:]
        self._check_vm_overlaps()

    def _file_align(self, addr):
        return _align(addr, self._opt_header.FileAlignment)
    <mask token>
    <mask token>
    <mask token>

    @property
    def optional_header(self):
        return self._opt_header

    def get_vm(self, start, stop):
        for sec in self._sections:
            if (sec.hdr.VirtualAddress <= start and sec.hdr.VirtualAddress +
                sec.hdr.VirtualSize >= stop):
                sec_offs = start - sec.hdr.VirtualAddress
                init_size = min(sec.hdr.SizeOfRawData - sec_offs, stop - start)
                uninit_size = stop - start - init_size
                if len(sec.data) < sec_offs + init_size:
                    raise RuntimeError(
                        'PE file corrupt: missing section content')
                return rope(sec.data[sec_offs:sec_offs + init_size], 
                    b'\x00' * uninit_size)

    def has_trailer(self):
        return bool(self._trailer)

    def remove_trailer(self):
        self.remove_signature()
        self._trailer = b''
    <mask token>
    <mask token>

    def has_directory(self, idx):
        if len(self._data_directories) < idx:
            return False
        dd = self._data_directories[idx]
        return dd.VirtualAddress != 0

    def find_directory(self, idx):
        if len(self._data_directories) < idx:
            return None
        dd = self._data_directories[idx]
        if dd.VirtualAddress == 0:
            return None
        return slice(dd.VirtualAddress, dd.VirtualAddress + dd.Size)
    <mask token>

    def get_directory_contents(self, idx):
        dd = self.find_directory(idx)
        if dd is None:
            return None
        return self.get_vm(dd.start, dd.stop)
    <mask token>
    <mask token>
    <mask token>

    def get_file_version(self):
        vi = self.get_version_info()
        return vi.get_fixed_info().file_version_tuple if vi else None

    def get_product_version(self):
        vi = self.get_version_info()
        return vi.get_fixed_info().product_version_tuple if vi else None

    def _get_directory_section(self, dd_idx):
        if dd_idx >= len(self._data_directories):
            return None
        dd = self._data_directories[dd_idx]
        if dd.Size == 0:
            return None
        for sec_idx, sec in enumerate(self._sections):
            if (sec.hdr.VirtualAddress == dd.VirtualAddress and sec.hdr.
                VirtualSize == dd.Size):
                return sec_idx

    def _find_vm_hole(self, secs, size):
        sorted_secs = sorted(secs, key=lambda sec: sec.hdr.VirtualAddress)
        i = 1
        while i < len(sorted_secs):
            start = self._mem_align(sorted_secs[i - 1].hdr.VirtualAddress +
                sorted_secs[i - 1].hdr.VirtualSize)
            stop = sorted_secs[i].hdr.VirtualAddress
            if stop - start >= size:
                return slice(start, self._mem_align(start + size))
            i += 1
        start = self._mem_align(sorted_secs[-1].hdr.VirtualAddress +
            sorted_secs[-1].hdr.VirtualSize)
        return slice(start, self._mem_align(start + size))
    <mask token>
    <mask token>
    <mask token>
    <mask token>

    def to_blob(self, update_checksum=False):
        self._opt_header.CheckSum = 0
        self._opt_header.SizeOfImage = max(self._mem_align(sec.hdr.
            VirtualAddress + sec.hdr.VirtualSize) for sec in self._sections)
        self._check_vm_overlaps()
        header_end = len(self._dos_stub
            ) + 4 + self._file_header.size + 2 + self._opt_header.size + len(
            self._data_directories) * _IMAGE_DATA_DIRECTORY.size + len(self
            ._sections) * _IMAGE_SECTION_HEADER.size
        section_offset = self._file_align(header_end)
        header_pad = section_offset - header_end
        for sec in self._sections:
            if sec.hdr.PointerToRawData == 0:
                continue
            sec.hdr.PointerToRawData = section_offset
            sec.hdr.SizeOfRawData = self._file_align(len(sec.data))
            section_offset = section_offset + sec.hdr.SizeOfRawData
        new_file = []
        new_file.append(self._dos_stub)
        new_file.append(b'PE\x00\x00')
        new_file.append(self._file_header.pack())
        new_file.append(struct.pack('<H', self._opt_header.sig))
        new_file.append(self._opt_header.pack())
        for dd in self._data_directories:
            new_file.append(dd.pack())
        for sec in self._sections:
            new_file.append(sec.hdr.pack())
        new_file.append(b'\x00' * header_pad)
        for sec in self._sections:
            if sec.data is None:
                continue
            new_file.append(sec.data)
            with_pad = self._file_align(len(sec.data))
            pad = with_pad - len(sec.data)
            if pad:
                new_file.append(b'\x00' * pad)
        new_file.append(self._trailer)
        out_blob = rope(*new_file)
        if update_checksum:
            new_checksum = pe_checksum(out_blob)
        else:
            new_checksum = 0
        return rope(out_blob[:self._checksum_offs], struct.pack('<I',
            new_checksum), out_blob[self._checksum_offs + 4:])
    <mask token>


<mask token>

<mask token>


class _PeFile:

    def __init__(self, blob, verify_checksum=False):
        pe_offs, = _read(blob[60:], '<H')
        fin = BlobIO(blob[pe_offs:])
        sig = fin.read(4)
        if sig != b'PE\x00\x00':
            raise RuntimeError('Not a PE file: PE signature is missing.')
        hdr = _IMAGE_FILE_HEADER.unpack_from_io(fin)
        opt_sig, = struct.unpack('<H', fin.read(2))
        if opt_sig == IMAGE_NT_OPTIONAL_HDR32_MAGIC:
            opt = _IMAGE_OPTIONAL_HEADER32.unpack_from_io(fin)
            opt.sig = opt_sig
        elif opt_sig == IMAGE_NT_OPTIONAL_HDR64_MAGIC:
            opt = _IMAGE_OPTIONAL_HEADER64.unpack_from_io(fin)
            opt.sig = opt_sig
        else:
            raise RuntimeError('Unknown optional header type.')
        self._checksum_offs = pe_offs + 4 + _IMAGE_FILE_HEADER.size + 4 * 16
        if verify_checksum:
            if opt.CheckSum == 0:
                self.checksum_correct = False
            else:
                real_checksum = pe_checksum(rope(blob[:self._checksum_offs],
                    b'\x00\x00\x00\x00', blob[self._checksum_offs + 4:]))
                self.checksum_correct = real_checksum == opt.CheckSum
        if opt.FileAlignment == 0:
            raise RuntimeError(
                'IMAGE_OPTIONAL_HEADER.FileAlignment must be nonzero')
        dds = [_IMAGE_DATA_DIRECTORY.unpack_from_io(fin) for dd_idx in
            range(opt.NumberOfRvaAndSizes)]

        def make_pe_section(idx, hdr):
            name = hdr.Name.rstrip(b'\x00')
            if hdr.PointerToRawData % opt.FileAlignment != 0:
                raise RuntimeError('Section {}@{} is misaligned ({})'.
                    format(name, idx, hdr.PointerToRawData))
            if hdr.SizeOfRawData % opt.FileAlignment != 0:
                raise RuntimeError('Size of section {}@{} is misaligned ({})'
                    .format(name, idx, hdr.SizeOfRawData))
            if hdr.PointerToRawData == 0:
                data = None
            else:
                data = blob[hdr.PointerToRawData:hdr.PointerToRawData + hdr
                    .SizeOfRawData]
            return _PeSection(hdr, data)
        sections = [make_pe_section(sec_idx, _IMAGE_SECTION_HEADER.
            unpack_from_io(fin)) for sec_idx in range(hdr.NumberOfSections)]
        present_secs = sorted((sec for sec in sections if sec.hdr.
            SizeOfRawData != 0), key=lambda sec: sec.hdr.PointerToRawData)
        if not present_secs:
            raise RuntimeError('no present sections')
        i = 1
        while i < len(present_secs):
            if present_secs[i - 1].hdr.PointerToRawData + present_secs[i - 1
                ].hdr.SizeOfRawData != present_secs[i].hdr.PointerToRawData:
                raise RuntimeError('there are holes between sections')
            i += 1
        last_sec = present_secs[-1]
        end_of_image = (last_sec.hdr.PointerToRawData + last_sec.hdr.
            SizeOfRawData)
        self._blob = blob
        self._dos_stub = blob[:pe_offs]
        self._file_header = hdr
        self._opt_header = opt
        self._data_directories = dds
        self._sections = sections
        self._trailer = blob[end_of_image:]
        self._check_vm_overlaps()

    def _file_align(self, addr):
        return _align(addr, self._opt_header.FileAlignment)
    <mask token>

    def _check_vm_overlaps(self):
        next_free_address = None
        for sec in self._sections:
            if sec.hdr.VirtualAddress % self._opt_header.SectionAlignment != 0:
                raise RuntimeError('sections are misaligned in memory')
            if (next_free_address is not None and sec.hdr.VirtualAddress !=
                next_free_address):
                raise RuntimeError('there are holes in the section map')
            next_free_address = self._mem_align(sec.hdr.VirtualAddress +
                sec.hdr.VirtualSize)

    @property
    def file_header(self):
        return self._file_header

    @property
    def optional_header(self):
        return self._opt_header

    def get_vm(self, start, stop):
        for sec in self._sections:
            if (sec.hdr.VirtualAddress <= start and sec.hdr.VirtualAddress +
                sec.hdr.VirtualSize >= stop):
                sec_offs = start - sec.hdr.VirtualAddress
                init_size = min(sec.hdr.SizeOfRawData - sec_offs, stop - start)
                uninit_size = stop - start - init_size
                if len(sec.data) < sec_offs + init_size:
                    raise RuntimeError(
                        'PE file corrupt: missing section content')
                return rope(sec.data[sec_offs:sec_offs + init_size], 
                    b'\x00' * uninit_size)

    def has_trailer(self):
        return bool(self._trailer)

    def remove_trailer(self):
        self.remove_signature()
        self._trailer = b''
    <mask token>
    <mask token>

    def has_directory(self, idx):
        if len(self._data_directories) < idx:
            return False
        dd = self._data_directories[idx]
        return dd.VirtualAddress != 0

    def find_directory(self, idx):
        if len(self._data_directories) < idx:
            return None
        dd = self._data_directories[idx]
        if dd.VirtualAddress == 0:
            return None
        return slice(dd.VirtualAddress, dd.VirtualAddress + dd.Size)
    <mask token>

    def get_directory_contents(self, idx):
        dd = self.find_directory(idx)
        if dd is None:
            return None
        return self.get_vm(dd.start, dd.stop)
    <mask token>
    <mask token>

    def get_version_info(self, langs=(1033, 0)):
        vis = self._get_version_info_dict()
        if not vis:
            return None
        for lngid in langs:
            vi = vis.get(lngid)
            if vi is not None:
                break
        else:
            lngid, vi = vis.popitem()
        return parse_version_info(vi)

    def get_file_version(self):
        vi = self.get_version_info()
        return vi.get_fixed_info().file_version_tuple if vi else None

    def get_product_version(self):
        vi = self.get_version_info()
        return vi.get_fixed_info().product_version_tuple if vi else None

    def _get_directory_section(self, dd_idx):
        if dd_idx >= len(self._data_directories):
            return None
        dd = self._data_directories[dd_idx]
        if dd.Size == 0:
            return None
        for sec_idx, sec in enumerate(self._sections):
            if (sec.hdr.VirtualAddress == dd.VirtualAddress and sec.hdr.
                VirtualSize == dd.Size):
                return sec_idx

    def _find_vm_hole(self, secs, size):
        sorted_secs = sorted(secs, key=lambda sec: sec.hdr.VirtualAddress)
        i = 1
        while i < len(sorted_secs):
            start = self._mem_align(sorted_secs[i - 1].hdr.VirtualAddress +
                sorted_secs[i - 1].hdr.VirtualSize)
            stop = sorted_secs[i].hdr.VirtualAddress
            if stop - start >= size:
                return slice(start, self._mem_align(start + size))
            i += 1
        start = self._mem_align(sorted_secs[-1].hdr.VirtualAddress +
            sorted_secs[-1].hdr.VirtualSize)
        return slice(start, self._mem_align(start + size))
    <mask token>
    <mask token>
    <mask token>
    <mask token>

    def to_blob(self, update_checksum=False):
        self._opt_header.CheckSum = 0
        self._opt_header.SizeOfImage = max(self._mem_align(sec.hdr.
            VirtualAddress + sec.hdr.VirtualSize) for sec in self._sections)
        self._check_vm_overlaps()
        header_end = len(self._dos_stub
            ) + 4 + self._file_header.size + 2 + self._opt_header.size + len(
            self._data_directories) * _IMAGE_DATA_DIRECTORY.size + len(self
            ._sections) * _IMAGE_SECTION_HEADER.size
        section_offset = self._file_align(header_end)
        header_pad = section_offset - header_end
        for sec in self._sections:
            if sec.hdr.PointerToRawData == 0:
                continue
            sec.hdr.PointerToRawData = section_offset
            sec.hdr.SizeOfRawData = self._file_align(len(sec.data))
            section_offset = section_offset + sec.hdr.SizeOfRawData
        new_file = []
        new_file.append(self._dos_stub)
        new_file.append(b'PE\x00\x00')
        new_file.append(self._file_header.pack())
        new_file.append(struct.pack('<H', self._opt_header.sig))
        new_file.append(self._opt_header.pack())
        for dd in self._data_directories:
            new_file.append(dd.pack())
        for sec in self._sections:
            new_file.append(sec.hdr.pack())
        new_file.append(b'\x00' * header_pad)
        for sec in self._sections:
            if sec.data is None:
                continue
            new_file.append(sec.data)
            with_pad = self._file_align(len(sec.data))
            pad = with_pad - len(sec.data)
            if pad:
                new_file.append(b'\x00' * pad)
        new_file.append(self._trailer)
        out_blob = rope(*new_file)
        if update_checksum:
            new_checksum = pe_checksum(out_blob)
        else:
            new_checksum = 0
        return rope(out_blob[:self._checksum_offs], struct.pack('<I',
            new_checksum), out_blob[self._checksum_offs + 4:])
    <mask token>


<mask token>

<mask token>


@dataclass
class CodeviewLink:
    guid: uuid.UUID
    age: int
    filename: str
    <mask token>

    @property
    def bxlink(self):
        return f'{self.filename}{{{self.guid}}}{self.age}'
    <mask token>

    def __str__(self):
        return self.bxlink


<mask token>


class _PeSection:

    def __init__(self, hdr, data):
        self.hdr = hdr
        self.data = data


<mask token>


class _PeFile:

    def __init__(self, blob, verify_checksum=False):
        pe_offs, = _read(blob[60:], '<H')
        fin = BlobIO(blob[pe_offs:])
        sig = fin.read(4)
        if sig != b'PE\x00\x00':
            raise RuntimeError('Not a PE file: PE signature is missing.')
        hdr = _IMAGE_FILE_HEADER.unpack_from_io(fin)
        opt_sig, = struct.unpack('<H', fin.read(2))
        if opt_sig == IMAGE_NT_OPTIONAL_HDR32_MAGIC:
            opt = _IMAGE_OPTIONAL_HEADER32.unpack_from_io(fin)
            opt.sig = opt_sig
        elif opt_sig == IMAGE_NT_OPTIONAL_HDR64_MAGIC:
            opt = _IMAGE_OPTIONAL_HEADER64.unpack_from_io(fin)
            opt.sig = opt_sig
        else:
            raise RuntimeError('Unknown optional header type.')
        self._checksum_offs = pe_offs + 4 + _IMAGE_FILE_HEADER.size + 4 * 16
        if verify_checksum:
            if opt.CheckSum == 0:
                self.checksum_correct = False
            else:
                real_checksum = pe_checksum(rope(blob[:self._checksum_offs],
                    b'\x00\x00\x00\x00', blob[self._checksum_offs + 4:]))
                self.checksum_correct = real_checksum == opt.CheckSum
        if opt.FileAlignment == 0:
            raise RuntimeError(
                'IMAGE_OPTIONAL_HEADER.FileAlignment must be nonzero')
        dds = [_IMAGE_DATA_DIRECTORY.unpack_from_io(fin) for dd_idx in
            range(opt.NumberOfRvaAndSizes)]

        def make_pe_section(idx, hdr):
            name = hdr.Name.rstrip(b'\x00')
            if hdr.PointerToRawData % opt.FileAlignment != 0:
                raise RuntimeError('Section {}@{} is misaligned ({})'.
                    format(name, idx, hdr.PointerToRawData))
            if hdr.SizeOfRawData % opt.FileAlignment != 0:
                raise RuntimeError('Size of section {}@{} is misaligned ({})'
                    .format(name, idx, hdr.SizeOfRawData))
            if hdr.PointerToRawData == 0:
                data = None
            else:
                data = blob[hdr.PointerToRawData:hdr.PointerToRawData + hdr
                    .SizeOfRawData]
            return _PeSection(hdr, data)
        sections = [make_pe_section(sec_idx, _IMAGE_SECTION_HEADER.
            unpack_from_io(fin)) for sec_idx in range(hdr.NumberOfSections)]
        present_secs = sorted((sec for sec in sections if sec.hdr.
            SizeOfRawData != 0), key=lambda sec: sec.hdr.PointerToRawData)
        if not present_secs:
            raise RuntimeError('no present sections')
        i = 1
        while i < len(present_secs):
            if present_secs[i - 1].hdr.PointerToRawData + present_secs[i - 1
                ].hdr.SizeOfRawData != present_secs[i].hdr.PointerToRawData:
                raise RuntimeError('there are holes between sections')
            i += 1
        last_sec = present_secs[-1]
        end_of_image = (last_sec.hdr.PointerToRawData + last_sec.hdr.
            SizeOfRawData)
        self._blob = blob
        self._dos_stub = blob[:pe_offs]
        self._file_header = hdr
        self._opt_header = opt
        self._data_directories = dds
        self._sections = sections
        self._trailer = blob[end_of_image:]
        self._check_vm_overlaps()

    def _file_align(self, addr):
        return _align(addr, self._opt_header.FileAlignment)

    def _mem_align(self, addr):
        return _align(addr, self._opt_header.SectionAlignment)

    def _check_vm_overlaps(self):
        next_free_address = None
        for sec in self._sections:
            if sec.hdr.VirtualAddress % self._opt_header.SectionAlignment != 0:
                raise RuntimeError('sections are misaligned in memory')
            if (next_free_address is not None and sec.hdr.VirtualAddress !=
                next_free_address):
                raise RuntimeError('there are holes in the section map')
            next_free_address = self._mem_align(sec.hdr.VirtualAddress +
                sec.hdr.VirtualSize)

    @property
    def file_header(self):
        return self._file_header

    @property
    def optional_header(self):
        return self._opt_header

    def get_vm(self, start, stop):
        for sec in self._sections:
            if (sec.hdr.VirtualAddress <= start and sec.hdr.VirtualAddress +
                sec.hdr.VirtualSize >= stop):
                sec_offs = start - sec.hdr.VirtualAddress
                init_size = min(sec.hdr.SizeOfRawData - sec_offs, stop - start)
                uninit_size = stop - start - init_size
                if len(sec.data) < sec_offs + init_size:
                    raise RuntimeError(
                        'PE file corrupt: missing section content')
                return rope(sec.data[sec_offs:sec_offs + init_size], 
                    b'\x00' * uninit_size)

    def has_trailer(self):
        return bool(self._trailer)

    def remove_trailer(self):
        self.remove_signature()
        self._trailer = b''

    def has_signature(self):
        return len(self._data_directories
            ) > IMAGE_DIRECTORY_ENTRY_SECURITY and self._data_directories[
            IMAGE_DIRECTORY_ENTRY_SECURITY].VirtualAddress != 0

    def remove_signature(self):
        if len(self._data_directories) < IMAGE_DIRECTORY_ENTRY_SECURITY:
            return
        dd = self._data_directories[IMAGE_DIRECTORY_ENTRY_SECURITY]
        if dd.Size == 0:
            return
        end_of_image = max(sec.hdr.PointerToRawData + sec.hdr.SizeOfRawData for
            sec in self._sections if sec.hdr.SizeOfRawData != 0)
        if dd.VirtualAddress + dd.Size != end_of_image + len(self._trailer):
            raise RuntimeError('signature is not at the end of the file')
        if dd.VirtualAddress < end_of_image:
            raise RuntimeError('signature is not contained in the pe trailer')
        self._trailer = self._trailer[:-dd.Size]
        dd.VirtualAddress = 0
        dd.Size = 0

    def has_directory(self, idx):
        if len(self._data_directories) < idx:
            return False
        dd = self._data_directories[idx]
        return dd.VirtualAddress != 0

    def find_directory(self, idx):
        if len(self._data_directories) < idx:
            return None
        dd = self._data_directories[idx]
        if dd.VirtualAddress == 0:
            return None
        return slice(dd.VirtualAddress, dd.VirtualAddress + dd.Size)

    def get_codeview_link(self):
        debug_dir = self.get_directory_contents(IMAGE_DIRECTORY_ENTRY_DEBUG)
        while debug_dir:
            dd = _IMAGE_DEBUG_DIRECTORY.unpack_from(debug_dir)
            debug_dir = debug_dir[_IMAGE_DEBUG_DIRECTORY.size:]
            if dd.Type == IMAGE_DEBUG_TYPE_CODEVIEW:
                dl = self._blob[dd.PointerToRawData:dd.PointerToRawData +
                    dd.SizeOfData]
                cv = parse_rsds_blob(dl)
                if cv is not None:
                    return cv
        return None

    def get_directory_contents(self, idx):
        dd = self.find_directory(idx)
        if dd is None:
            return None
        return self.get_vm(dd.start, dd.stop)

    def parse_resources(self):
        vm_slice = self.find_directory(IMAGE_DIRECTORY_ENTRY_RESOURCE)
        if vm_slice is None:
            return None
        data = self.get_vm(vm_slice.start, vm_slice.stop)
        return parse_pe_resources(data, vm_slice.start)

    def _get_version_info_dict(self):
        res = self.parse_resources()
        if not res:
            return
        return res.get(KnownResourceTypes.RT_VERSION, {}).get(1, {})

    def get_version_info(self, langs=(1033, 0)):
        vis = self._get_version_info_dict()
        if not vis:
            return None
        for lngid in langs:
            vi = vis.get(lngid)
            if vi is not None:
                break
        else:
            lngid, vi = vis.popitem()
        return parse_version_info(vi)

    def get_file_version(self):
        vi = self.get_version_info()
        return vi.get_fixed_info().file_version_tuple if vi else None

    def get_product_version(self):
        vi = self.get_version_info()
        return vi.get_fixed_info().product_version_tuple if vi else None

    def _get_directory_section(self, dd_idx):
        if dd_idx >= len(self._data_directories):
            return None
        dd = self._data_directories[dd_idx]
        if dd.Size == 0:
            return None
        for sec_idx, sec in enumerate(self._sections):
            if (sec.hdr.VirtualAddress == dd.VirtualAddress and sec.hdr.
                VirtualSize == dd.Size):
                return sec_idx

    def _find_vm_hole(self, secs, size):
        sorted_secs = sorted(secs, key=lambda sec: sec.hdr.VirtualAddress)
        i = 1
        while i < len(sorted_secs):
            start = self._mem_align(sorted_secs[i - 1].hdr.VirtualAddress +
                sorted_secs[i - 1].hdr.VirtualSize)
            stop = sorted_secs[i].hdr.VirtualAddress
            if stop - start >= size:
                return slice(start, self._mem_align(start + size))
            i += 1
        start = self._mem_align(sorted_secs[-1].hdr.VirtualAddress +
            sorted_secs[-1].hdr.VirtualSize)
        return slice(start, self._mem_align(start + size))

    def _resize_directory(self, idx, size):
        sec_idx = self._get_directory_section(idx)
        if sec_idx is None:
            raise RuntimeError(
                "can't modify a directory that is not associated with a section"
                )
        sec = self._sections[sec_idx]
        move_map = {}
        addr = self._mem_align(sec.hdr.VirtualAddress + size)
        for other_sec in self._sections[sec_idx + 1:]:
            move_map[other_sec] = addr
            addr = self._mem_align(addr + other_sec.hdr.VirtualSize)
        for dd in self._data_directories:
            if dd.VirtualAddress == 0:
                continue
            for osec, target_addr in move_map.items():
                if (osec.hdr.VirtualAddress <= dd.VirtualAddress <= osec.
                    hdr.VirtualAddress + osec.hdr.VirtualSize):
                    dd.VirtualAddress += target_addr - osec.hdr.VirtualAddress
                    break
        for osec, target_addr in move_map.items():
            osec.hdr.VirtualAddress = target_addr
        sec.hdr.VirtualSize = size
        dd = self._data_directories[idx]
        dd.Size = size
        return sec_idx, sec.hdr.VirtualAddress

    def is_dir_safely_resizable(self, idx):
        sec_idx = self._get_directory_section(idx)
        if sec_idx is None:
            return False
        return all(sec.hdr.Characteristics & IMAGE_SCN_MEM_DISCARDABLE != 0 for
            sec in self._sections[sec_idx + 1:])

    def resize_directory(self, idx, size):
        _, addr = self._resize_directory(idx, size)
        return addr

    def set_directory(self, idx, blob):
        sec_idx, _ = self._resize_directory(idx, len(blob))
        sec = self._sections[sec_idx]
        sec.data = blob

    def to_blob(self, update_checksum=False):
        self._opt_header.CheckSum = 0
        self._opt_header.SizeOfImage = max(self._mem_align(sec.hdr.
            VirtualAddress + sec.hdr.VirtualSize) for sec in self._sections)
        self._check_vm_overlaps()
        header_end = len(self._dos_stub
            ) + 4 + self._file_header.size + 2 + self._opt_header.size + len(
            self._data_directories) * _IMAGE_DATA_DIRECTORY.size + len(self
            ._sections) * _IMAGE_SECTION_HEADER.size
        section_offset = self._file_align(header_end)
        header_pad = section_offset - header_end
        for sec in self._sections:
            if sec.hdr.PointerToRawData == 0:
                continue
            sec.hdr.PointerToRawData = section_offset
            sec.hdr.SizeOfRawData = self._file_align(len(sec.data))
            section_offset = section_offset + sec.hdr.SizeOfRawData
        new_file = []
        new_file.append(self._dos_stub)
        new_file.append(b'PE\x00\x00')
        new_file.append(self._file_header.pack())
        new_file.append(struct.pack('<H', self._opt_header.sig))
        new_file.append(self._opt_header.pack())
        for dd in self._data_directories:
            new_file.append(dd.pack())
        for sec in self._sections:
            new_file.append(sec.hdr.pack())
        new_file.append(b'\x00' * header_pad)
        for sec in self._sections:
            if sec.data is None:
                continue
            new_file.append(sec.data)
            with_pad = self._file_align(len(sec.data))
            pad = with_pad - len(sec.data)
            if pad:
                new_file.append(b'\x00' * pad)
        new_file.append(self._trailer)
        out_blob = rope(*new_file)
        if update_checksum:
            new_checksum = pe_checksum(out_blob)
        else:
            new_checksum = 0
        return rope(out_blob[:self._checksum_offs], struct.pack('<I',
            new_checksum), out_blob[self._checksum_offs + 4:])

    def to_bytes(self, update_checksum=False):
        return bytes(self.to_blob(update_checksum=update_checksum))


<mask token>

<mask token>


@dataclass
class PeIdent:
    image_name: str
    timestamp: int
    size_of_image: int

    @classmethod
    def from_pelink(cls, pelink: str):
        fname, tssize = pelink.split('/')
        ts = int(tssize[:8], 16)
        size = int(tssize[8:], 16)
        return cls(image_name=fname, timestamp=ts, size_of_image=size)

    @property
    def pelink(self):
        return f'{self.image_name}/{self.timestamp:08x}{self.size_of_image:x}'

    def __str__(self):
        return self.pelink


@dataclass
class CodeviewLink:
    guid: uuid.UUID
    age: int
    filename: str

    @classmethod
    def from_bxlink(cls, bxlink: str):
        fname, bxlink = bxlink.split('{', 1)
        guid, age = bxlink.split('}', 1)
        return cls(guid=uuid.UUID(guid), age=int(age, 10), filename=fname)

    @property
    def bxlink(self):
        return f'{self.filename}{{{self.guid}}}{self.age}'

    @property
    def short_filename(self):
        return self.filename.rsplit('\\', 1)[-1]

    def __str__(self):
        return self.bxlink


<mask token>


class _PeSection:

    def __init__(self, hdr, data):
        self.hdr = hdr
        self.data = data


<mask token>


class _PeFile:

    def __init__(self, blob, verify_checksum=False):
        pe_offs, = _read(blob[60:], '<H')
        fin = BlobIO(blob[pe_offs:])
        sig = fin.read(4)
        if sig != b'PE\x00\x00':
            raise RuntimeError('Not a PE file: PE signature is missing.')
        hdr = _IMAGE_FILE_HEADER.unpack_from_io(fin)
        opt_sig, = struct.unpack('<H', fin.read(2))
        if opt_sig == IMAGE_NT_OPTIONAL_HDR32_MAGIC:
            opt = _IMAGE_OPTIONAL_HEADER32.unpack_from_io(fin)
            opt.sig = opt_sig
        elif opt_sig == IMAGE_NT_OPTIONAL_HDR64_MAGIC:
            opt = _IMAGE_OPTIONAL_HEADER64.unpack_from_io(fin)
            opt.sig = opt_sig
        else:
            raise RuntimeError('Unknown optional header type.')
        self._checksum_offs = pe_offs + 4 + _IMAGE_FILE_HEADER.size + 4 * 16
        if verify_checksum:
            if opt.CheckSum == 0:
                self.checksum_correct = False
            else:
                real_checksum = pe_checksum(rope(blob[:self._checksum_offs],
                    b'\x00\x00\x00\x00', blob[self._checksum_offs + 4:]))
                self.checksum_correct = real_checksum == opt.CheckSum
        if opt.FileAlignment == 0:
            raise RuntimeError(
                'IMAGE_OPTIONAL_HEADER.FileAlignment must be nonzero')
        dds = [_IMAGE_DATA_DIRECTORY.unpack_from_io(fin) for dd_idx in
            range(opt.NumberOfRvaAndSizes)]

        def make_pe_section(idx, hdr):
            name = hdr.Name.rstrip(b'\x00')
            if hdr.PointerToRawData % opt.FileAlignment != 0:
                raise RuntimeError('Section {}@{} is misaligned ({})'.
                    format(name, idx, hdr.PointerToRawData))
            if hdr.SizeOfRawData % opt.FileAlignment != 0:
                raise RuntimeError('Size of section {}@{} is misaligned ({})'
                    .format(name, idx, hdr.SizeOfRawData))
            if hdr.PointerToRawData == 0:
                data = None
            else:
                data = blob[hdr.PointerToRawData:hdr.PointerToRawData + hdr
                    .SizeOfRawData]
            return _PeSection(hdr, data)
        sections = [make_pe_section(sec_idx, _IMAGE_SECTION_HEADER.
            unpack_from_io(fin)) for sec_idx in range(hdr.NumberOfSections)]
        present_secs = sorted((sec for sec in sections if sec.hdr.
            SizeOfRawData != 0), key=lambda sec: sec.hdr.PointerToRawData)
        if not present_secs:
            raise RuntimeError('no present sections')
        i = 1
        while i < len(present_secs):
            if present_secs[i - 1].hdr.PointerToRawData + present_secs[i - 1
                ].hdr.SizeOfRawData != present_secs[i].hdr.PointerToRawData:
                raise RuntimeError('there are holes between sections')
            i += 1
        last_sec = present_secs[-1]
        end_of_image = (last_sec.hdr.PointerToRawData + last_sec.hdr.
            SizeOfRawData)
        self._blob = blob
        self._dos_stub = blob[:pe_offs]
        self._file_header = hdr
        self._opt_header = opt
        self._data_directories = dds
        self._sections = sections
        self._trailer = blob[end_of_image:]
        self._check_vm_overlaps()

    def _file_align(self, addr):
        return _align(addr, self._opt_header.FileAlignment)

    def _mem_align(self, addr):
        return _align(addr, self._opt_header.SectionAlignment)

    def _check_vm_overlaps(self):
        next_free_address = None
        for sec in self._sections:
            if sec.hdr.VirtualAddress % self._opt_header.SectionAlignment != 0:
                raise RuntimeError('sections are misaligned in memory')
            if (next_free_address is not None and sec.hdr.VirtualAddress !=
                next_free_address):
                raise RuntimeError('there are holes in the section map')
            next_free_address = self._mem_align(sec.hdr.VirtualAddress +
                sec.hdr.VirtualSize)

    @property
    def file_header(self):
        return self._file_header

    @property
    def optional_header(self):
        return self._opt_header

    def get_vm(self, start, stop):
        for sec in self._sections:
            if (sec.hdr.VirtualAddress <= start and sec.hdr.VirtualAddress +
                sec.hdr.VirtualSize >= stop):
                sec_offs = start - sec.hdr.VirtualAddress
                init_size = min(sec.hdr.SizeOfRawData - sec_offs, stop - start)
                uninit_size = stop - start - init_size
                if len(sec.data) < sec_offs + init_size:
                    raise RuntimeError(
                        'PE file corrupt: missing section content')
                return rope(sec.data[sec_offs:sec_offs + init_size], 
                    b'\x00' * uninit_size)

    def has_trailer(self):
        return bool(self._trailer)

    def remove_trailer(self):
        self.remove_signature()
        self._trailer = b''

    def has_signature(self):
        return len(self._data_directories
            ) > IMAGE_DIRECTORY_ENTRY_SECURITY and self._data_directories[
            IMAGE_DIRECTORY_ENTRY_SECURITY].VirtualAddress != 0

    def remove_signature(self):
        if len(self._data_directories) < IMAGE_DIRECTORY_ENTRY_SECURITY:
            return
        dd = self._data_directories[IMAGE_DIRECTORY_ENTRY_SECURITY]
        if dd.Size == 0:
            return
        end_of_image = max(sec.hdr.PointerToRawData + sec.hdr.SizeOfRawData for
            sec in self._sections if sec.hdr.SizeOfRawData != 0)
        if dd.VirtualAddress + dd.Size != end_of_image + len(self._trailer):
            raise RuntimeError('signature is not at the end of the file')
        if dd.VirtualAddress < end_of_image:
            raise RuntimeError('signature is not contained in the pe trailer')
        self._trailer = self._trailer[:-dd.Size]
        dd.VirtualAddress = 0
        dd.Size = 0

    def has_directory(self, idx):
        if len(self._data_directories) < idx:
            return False
        dd = self._data_directories[idx]
        return dd.VirtualAddress != 0

    def find_directory(self, idx):
        if len(self._data_directories) < idx:
            return None
        dd = self._data_directories[idx]
        if dd.VirtualAddress == 0:
            return None
        return slice(dd.VirtualAddress, dd.VirtualAddress + dd.Size)

    def get_codeview_link(self):
        debug_dir = self.get_directory_contents(IMAGE_DIRECTORY_ENTRY_DEBUG)
        while debug_dir:
            dd = _IMAGE_DEBUG_DIRECTORY.unpack_from(debug_dir)
            debug_dir = debug_dir[_IMAGE_DEBUG_DIRECTORY.size:]
            if dd.Type == IMAGE_DEBUG_TYPE_CODEVIEW:
                dl = self._blob[dd.PointerToRawData:dd.PointerToRawData +
                    dd.SizeOfData]
                cv = parse_rsds_blob(dl)
                if cv is not None:
                    return cv
        return None

    def get_directory_contents(self, idx):
        dd = self.find_directory(idx)
        if dd is None:
            return None
        return self.get_vm(dd.start, dd.stop)

    def parse_resources(self):
        vm_slice = self.find_directory(IMAGE_DIRECTORY_ENTRY_RESOURCE)
        if vm_slice is None:
            return None
        data = self.get_vm(vm_slice.start, vm_slice.stop)
        return parse_pe_resources(data, vm_slice.start)

    def _get_version_info_dict(self):
        res = self.parse_resources()
        if not res:
            return
        return res.get(KnownResourceTypes.RT_VERSION, {}).get(1, {})

    def get_version_info(self, langs=(1033, 0)):
        vis = self._get_version_info_dict()
        if not vis:
            return None
        for lngid in langs:
            vi = vis.get(lngid)
            if vi is not None:
                break
        else:
            lngid, vi = vis.popitem()
        return parse_version_info(vi)

    def get_file_version(self):
        vi = self.get_version_info()
        return vi.get_fixed_info().file_version_tuple if vi else None

    def get_product_version(self):
        vi = self.get_version_info()
        return vi.get_fixed_info().product_version_tuple if vi else None

    def _get_directory_section(self, dd_idx):
        if dd_idx >= len(self._data_directories):
            return None
        dd = self._data_directories[dd_idx]
        if dd.Size == 0:
            return None
        for sec_idx, sec in enumerate(self._sections):
            if (sec.hdr.VirtualAddress == dd.VirtualAddress and sec.hdr.
                VirtualSize == dd.Size):
                return sec_idx

    def _find_vm_hole(self, secs, size):
        sorted_secs = sorted(secs, key=lambda sec: sec.hdr.VirtualAddress)
        i = 1
        while i < len(sorted_secs):
            start = self._mem_align(sorted_secs[i - 1].hdr.VirtualAddress +
                sorted_secs[i - 1].hdr.VirtualSize)
            stop = sorted_secs[i].hdr.VirtualAddress
            if stop - start >= size:
                return slice(start, self._mem_align(start + size))
            i += 1
        start = self._mem_align(sorted_secs[-1].hdr.VirtualAddress +
            sorted_secs[-1].hdr.VirtualSize)
        return slice(start, self._mem_align(start + size))

    def _resize_directory(self, idx, size):
        sec_idx = self._get_directory_section(idx)
        if sec_idx is None:
            raise RuntimeError(
                "can't modify a directory that is not associated with a section"
                )
        sec = self._sections[sec_idx]
        move_map = {}
        addr = self._mem_align(sec.hdr.VirtualAddress + size)
        for other_sec in self._sections[sec_idx + 1:]:
            move_map[other_sec] = addr
            addr = self._mem_align(addr + other_sec.hdr.VirtualSize)
        for dd in self._data_directories:
            if dd.VirtualAddress == 0:
                continue
            for osec, target_addr in move_map.items():
                if (osec.hdr.VirtualAddress <= dd.VirtualAddress <= osec.
                    hdr.VirtualAddress + osec.hdr.VirtualSize):
                    dd.VirtualAddress += target_addr - osec.hdr.VirtualAddress
                    break
        for osec, target_addr in move_map.items():
            osec.hdr.VirtualAddress = target_addr
        sec.hdr.VirtualSize = size
        dd = self._data_directories[idx]
        dd.Size = size
        return sec_idx, sec.hdr.VirtualAddress

    def is_dir_safely_resizable(self, idx):
        sec_idx = self._get_directory_section(idx)
        if sec_idx is None:
            return False
        return all(sec.hdr.Characteristics & IMAGE_SCN_MEM_DISCARDABLE != 0 for
            sec in self._sections[sec_idx + 1:])

    def resize_directory(self, idx, size):
        _, addr = self._resize_directory(idx, size)
        return addr

    def set_directory(self, idx, blob):
        sec_idx, _ = self._resize_directory(idx, len(blob))
        sec = self._sections[sec_idx]
        sec.data = blob

    def to_blob(self, update_checksum=False):
        self._opt_header.CheckSum = 0
        self._opt_header.SizeOfImage = max(self._mem_align(sec.hdr.
            VirtualAddress + sec.hdr.VirtualSize) for sec in self._sections)
        self._check_vm_overlaps()
        header_end = len(self._dos_stub
            ) + 4 + self._file_header.size + 2 + self._opt_header.size + len(
            self._data_directories) * _IMAGE_DATA_DIRECTORY.size + len(self
            ._sections) * _IMAGE_SECTION_HEADER.size
        section_offset = self._file_align(header_end)
        header_pad = section_offset - header_end
        for sec in self._sections:
            if sec.hdr.PointerToRawData == 0:
                continue
            sec.hdr.PointerToRawData = section_offset
            sec.hdr.SizeOfRawData = self._file_align(len(sec.data))
            section_offset = section_offset + sec.hdr.SizeOfRawData
        new_file = []
        new_file.append(self._dos_stub)
        new_file.append(b'PE\x00\x00')
        new_file.append(self._file_header.pack())
        new_file.append(struct.pack('<H', self._opt_header.sig))
        new_file.append(self._opt_header.pack())
        for dd in self._data_directories:
            new_file.append(dd.pack())
        for sec in self._sections:
            new_file.append(sec.hdr.pack())
        new_file.append(b'\x00' * header_pad)
        for sec in self._sections:
            if sec.data is None:
                continue
            new_file.append(sec.data)
            with_pad = self._file_align(len(sec.data))
            pad = with_pad - len(sec.data)
            if pad:
                new_file.append(b'\x00' * pad)
        new_file.append(self._trailer)
        out_blob = rope(*new_file)
        if update_checksum:
            new_checksum = pe_checksum(out_blob)
        else:
            new_checksum = 0
        return rope(out_blob[:self._checksum_offs], struct.pack('<I',
            new_checksum), out_blob[self._checksum_offs + 4:])

    def to_bytes(self, update_checksum=False):
        return bytes(self.to_blob(update_checksum=update_checksum))


<mask token>

import struct, io
from dataclasses import dataclass
from grope import BlobIO, rope
from .struct3 import Struct3, u8, u16, u32, u64, char
from .rsrc import parse_pe_resources
from .rsrc import KnownResourceTypes
import uuid
from .version_info import parse_version_info

class _IMAGE_FILE_HEADER(Struct3):
    Machine: u16
    NumberOfSections: u16
    TimeDateStamp: u32
    PointerToSymbolTable: u32
    NumberOfSymbols: u32
    SizeOfOptionalHeader: u16
    Characteristics: u16

IMAGE_NT_OPTIONAL_HDR32_MAGIC = 0x10b
IMAGE_NT_OPTIONAL_HDR64_MAGIC = 0x20b

class _IMAGE_OPTIONAL_HEADER32(Struct3):
    MajorLinkerVersion: u8
    MinorLinkerVersion: u8
    SizeOfCode: u32
    SizeOfInitializedData: u32
    SizeOfUninitializedData: u32
    AddressOfEntryPoint: u32
    BaseOfCode: u32
    BaseOfData: u32
    ImageBase: u32
    SectionAlignment: u32
    FileAlignment: u32
    MajorOperatingSystemVersion: u16
    MinorOperatingSystemVersion: u16
    MajorImageVersion: u16
    MinorImageVersion: u16
    MajorSubsystemVersion: u16
    MinorSubsystemVersion: u16
    Reserved1: u32
    SizeOfImage: u32
    SizeOfHeaders: u32
    CheckSum: u32
    Subsystem: u16
    DllCharacteristics: u16
    SizeOfStackReserve: u32
    SizeOfStackCommit: u32
    SizeOfHeapReserve: u32
    SizeOfHeapCommit: u32
    LoaderFlags: u32
    NumberOfRvaAndSizes: u32

class _IMAGE_OPTIONAL_HEADER64(Struct3):
    MajorLinkerVersion: u8
    MinorLinkerVersion: u8
    SizeOfCode: u32
    SizeOfInitializedData: u32
    SizeOfUninitializedData: u32
    AddressOfEntryPoint: u32
    BaseOfCode: u32
    ImageBase: u64
    SectionAlignment: u32
    FileAlignment: u32
    MajorOperatingSystemVersion: u16
    MinorOperatingSystemVersion: u16
    MajorImageVersion: u16
    MinorImageVersion: u16
    MajorSubsystemVersion: u16
    MinorSubsystemVersion: u16
    Reserved1: u32
    SizeOfImage: u32
    SizeOfHeaders: u32
    CheckSum: u32
    Subsystem: u16
    DllCharacteristics: u16
    SizeOfStackReserve: u64
    SizeOfStackCommit: u64
    SizeOfHeapReserve: u64
    SizeOfHeapCommit: u64
    LoaderFlags: u32
    NumberOfRvaAndSizes: u32

class _IMAGE_DATA_DIRECTORY(Struct3):
    VirtualAddress: u32
    Size: u32

class _IMAGE_SECTION_HEADER(Struct3):
    Name: char[8]
    VirtualSize: u32
    VirtualAddress: u32
    SizeOfRawData: u32
    PointerToRawData: u32
    PointerToRelocations: u32
    PointerToLinenumbers: u32
    NumberOfRelocations: u16
    NumberOfLinenumbers: u16
    Characteristics: u32

class _IMAGE_DEBUG_DIRECTORY(Struct3):
    Characteristics: u32
    TimeDateStamp: u32
    MajorVersion: u16
    MinorVersion: u16
    Type: u32
    SizeOfData: u32
    AddressOfRawData: u32
    PointerToRawData: u32

class _IMAGE_DEBUG_CODEVIEW(Struct3):
    rsds: char[4]
    guid: char[16]
    age: u32

@dataclass
class PeIdent:
    image_name: str
    timestamp: int
    size_of_image: int

    @classmethod
    def from_pelink(cls, pelink: str):
        fname, tssize = pelink.split('/')
        ts = int(tssize[:8], 16)
        size = int(tssize[8:], 16)
        return cls(image_name=fname, timestamp=ts, size_of_image=size)

    @property
    def pelink(self):
        return f'{self.image_name}/{self.timestamp:08x}{self.size_of_image:x}'

    def __str__(self):
        return self.pelink
@dataclass
class CodeviewLink:
    guid: uuid.UUID
    age: int
    filename: str

    @classmethod
    def from_bxlink(cls, bxlink: str):
        fname, bxlink = bxlink.split('{', 1)
        guid, age = bxlink.split('}', 1)
        return cls(guid=uuid.UUID(guid), age=int(age, 10), filename=fname)

    @property
    def bxlink(self):
        return f'{self.filename}{{{self.guid}}}{self.age}'

    @property
    def short_filename(self):
        return self.filename.rsplit('\\', 1)[-1]

    def __str__(self):
        return self.bxlink

IMAGE_DEBUG_TYPE_CODEVIEW = 2

IMAGE_SCN_TYPE_REG                   = 0x00000000
IMAGE_SCN_TYPE_DSECT                 = 0x00000001
IMAGE_SCN_TYPE_NOLOAD                = 0x00000002
IMAGE_SCN_TYPE_GROUP                 = 0x00000004
IMAGE_SCN_TYPE_NO_PAD                = 0x00000008
IMAGE_SCN_TYPE_COPY                  = 0x00000010
IMAGE_SCN_CNT_CODE                   = 0x00000020
IMAGE_SCN_CNT_INITIALIZED_DATA       = 0x00000040
IMAGE_SCN_CNT_UNINITIALIZED_DATA     = 0x00000080
IMAGE_SCN_LNK_OTHER                  = 0x00000100
IMAGE_SCN_LNK_INFO                   = 0x00000200
IMAGE_SCN_TYPE_OVER                  = 0x00000400
IMAGE_SCN_LNK_REMOVE                 = 0x00000800
IMAGE_SCN_LNK_COMDAT                 = 0x00001000
IMAGE_SCN_NO_DEFER_SPEC_EXC          = 0x00004000
IMAGE_SCN_GPREL                      = 0x00008000
IMAGE_SCN_MEM_FARDATA                = 0x00008000
IMAGE_SCN_MEM_PURGEABLE              = 0x00020000
IMAGE_SCN_MEM_16BIT                  = 0x00020000
IMAGE_SCN_MEM_LOCKED                 = 0x00040000
IMAGE_SCN_MEM_PRELOAD                = 0x00080000
IMAGE_SCN_ALIGN_1BYTES               = 0x00100000
IMAGE_SCN_ALIGN_2BYTES               = 0x00200000
IMAGE_SCN_ALIGN_4BYTES               = 0x00300000
IMAGE_SCN_ALIGN_8BYTES               = 0x00400000
IMAGE_SCN_ALIGN_16BYTES              = 0x00500000
IMAGE_SCN_ALIGN_32BYTES              = 0x00600000
IMAGE_SCN_ALIGN_64BYTES              = 0x00700000
IMAGE_SCN_ALIGN_128BYTES             = 0x00800000
IMAGE_SCN_ALIGN_256BYTES             = 0x00900000
IMAGE_SCN_ALIGN_512BYTES             = 0x00A00000
IMAGE_SCN_ALIGN_1024BYTES            = 0x00B00000
IMAGE_SCN_ALIGN_2048BYTES            = 0x00C00000
IMAGE_SCN_ALIGN_4096BYTES            = 0x00D00000
IMAGE_SCN_ALIGN_8192BYTES            = 0x00E00000
IMAGE_SCN_ALIGN_MASK                 = 0x00F00000
IMAGE_SCN_LNK_NRELOC_OVFL            = 0x01000000
IMAGE_SCN_MEM_DISCARDABLE            = 0x02000000
IMAGE_SCN_MEM_NOT_CACHED             = 0x04000000
IMAGE_SCN_MEM_NOT_PAGED              = 0x08000000
IMAGE_SCN_MEM_SHARED                 = 0x10000000
IMAGE_SCN_MEM_EXECUTE                = 0x20000000
IMAGE_SCN_MEM_READ                   = 0x40000000
IMAGE_SCN_MEM_WRITE                  = 0x80000000


def _align(offs, alignment):
    return (offs + alignment - 1) // alignment * alignment

IMAGE_DIRECTORY_ENTRY_EXPORT = 0
IMAGE_DIRECTORY_ENTRY_IMPORT = 1
IMAGE_DIRECTORY_ENTRY_RESOURCE = 2
IMAGE_DIRECTORY_ENTRY_EXCEPTION = 3
IMAGE_DIRECTORY_ENTRY_SECURITY = 4
IMAGE_DIRECTORY_ENTRY_BASERELOC = 5
IMAGE_DIRECTORY_ENTRY_DEBUG = 6
IMAGE_DIRECTORY_ENTRY_ARCHITECTURE = 7
IMAGE_DIRECTORY_ENTRY_GLOBALPTR = 8
IMAGE_DIRECTORY_ENTRY_TLS = 9
IMAGE_DIRECTORY_ENTRY_LOAD_CONFIG = 10
IMAGE_DIRECTORY_ENTRY_BOUND_IMPORT = 11
IMAGE_DIRECTORY_ENTRY_IAT = 12
IMAGE_DIRECTORY_ENTRY_DELAY_IMPORT = 13
IMAGE_DIRECTORY_ENTRY_COM_DESCRIPTOR = 14

class _PeSection:
    def __init__(self, hdr, data):
        self.hdr = hdr
        self.data = data

def pe_checksum(blob):
    total_len = len(blob)

    r = 0
    while len(blob) >= 0x1000:
        words = struct.unpack('<2048H', bytes(blob[:0x1000]))
        r += sum(words)
        blob = blob[0x1000:]

    if len(blob) % 2 != 0:
        blob = rope(blob, b'\0')
    words = struct.unpack('<' + 'H'*(len(blob) // 2), bytes(blob))
    r += sum(words)

    while r > 0xffff:
        c = r
        r = 0
        while c:
            r += c & 0xffff
            c >>= 16

    return r + total_len

def _read(blob, fmt):
    size = struct.calcsize(fmt)
    return struct.unpack(fmt, bytes(blob[:size]))

def parse_rsds_blob(blob):
    if len(blob) < _IMAGE_DEBUG_CODEVIEW.size:
        return None

    cv = _IMAGE_DEBUG_CODEVIEW.unpack_from(blob)
    if cv.rsds != b'RSDS':
        return None

    fname = bytes(blob[_IMAGE_DEBUG_CODEVIEW.size:])
    fname, *_ = fname.split(b'\0', 1)
    return CodeviewLink(uuid.UUID(bytes_le=cv.guid), cv.age, fname.decode('utf-8'))

class _PeFile:
    def __init__(self, blob, verify_checksum=False):
        pe_offs, = _read(blob[0x3c:], '<H')

        fin = BlobIO(blob[pe_offs:])

        sig = fin.read(4)
        if sig != b'PE\0\0':
            raise RuntimeError('Not a PE file: PE signature is missing.')

        hdr = _IMAGE_FILE_HEADER.unpack_from_io(fin)
        opt_sig, = struct.unpack('<H', fin.read(2))
        if opt_sig == IMAGE_NT_OPTIONAL_HDR32_MAGIC:
            opt = _IMAGE_OPTIONAL_HEADER32.unpack_from_io(fin)
            opt.sig = opt_sig
        elif opt_sig == IMAGE_NT_OPTIONAL_HDR64_MAGIC:
            opt = _IMAGE_OPTIONAL_HEADER64.unpack_from_io(fin)
            opt.sig = opt_sig
        else:
            raise RuntimeError('Unknown optional header type.')

        self._checksum_offs = pe_offs + 4 + _IMAGE_FILE_HEADER.size + 4*16

        if verify_checksum:
            if opt.CheckSum == 0:
                self.checksum_correct = False
            else:
                real_checksum = pe_checksum(rope(blob[:self._checksum_offs], b'\0\0\0\0', blob[self._checksum_offs + 4:]))
                self.checksum_correct = real_checksum == opt.CheckSum

        if opt.FileAlignment == 0:
            raise RuntimeError('IMAGE_OPTIONAL_HEADER.FileAlignment must be nonzero')

        dds = [_IMAGE_DATA_DIRECTORY.unpack_from_io(fin) for dd_idx in range(opt.NumberOfRvaAndSizes)]

        def make_pe_section(idx, hdr):
            name = hdr.Name.rstrip(b'\0')

            if hdr.PointerToRawData % opt.FileAlignment != 0:
                raise RuntimeError('Section {}@{} is misaligned ({})'.format(name, idx, hdr.PointerToRawData))
            if hdr.SizeOfRawData % opt.FileAlignment != 0:
                raise RuntimeError('Size of section {}@{} is misaligned ({})'.format(name, idx, hdr.SizeOfRawData))

            if hdr.PointerToRawData == 0:
                data = None
            else:
                data = blob[hdr.PointerToRawData:hdr.PointerToRawData + hdr.SizeOfRawData]

            return _PeSection(hdr, data)

        sections = [make_pe_section(sec_idx, _IMAGE_SECTION_HEADER.unpack_from_io(fin)) for sec_idx in range(hdr.NumberOfSections)]

        present_secs = sorted((sec for sec in sections if sec.hdr.SizeOfRawData != 0), key=lambda sec: sec.hdr.PointerToRawData)
        if not present_secs:
            raise RuntimeError('no present sections')

        i = 1
        while i < len(present_secs):
            if present_secs[i-1].hdr.PointerToRawData + present_secs[i-1].hdr.SizeOfRawData != present_secs[i].hdr.PointerToRawData:
                raise RuntimeError('there are holes between sections')
            i += 1

        last_sec = present_secs[-1]
        end_of_image = last_sec.hdr.PointerToRawData + last_sec.hdr.SizeOfRawData

        self._blob = blob
        self._dos_stub = blob[:pe_offs]
        self._file_header = hdr
        self._opt_header = opt
        self._data_directories = dds
        self._sections = sections

        self._trailer = blob[end_of_image:]

        self._check_vm_overlaps()

    def _file_align(self, addr):
        return _align(addr, self._opt_header.FileAlignment)

    def _mem_align(self, addr):
        return _align(addr, self._opt_header.SectionAlignment)

    def _check_vm_overlaps(self):
        next_free_address = None
        for sec in self._sections:
            if sec.hdr.VirtualAddress % self._opt_header.SectionAlignment != 0:
                raise RuntimeError('sections are misaligned in memory')

            if next_free_address is not None and sec.hdr.VirtualAddress != next_free_address:
                raise RuntimeError('there are holes in the section map')

            next_free_address = self._mem_align(sec.hdr.VirtualAddress + sec.hdr.VirtualSize)

    @property
    def file_header(self):
        return self._file_header

    @property
    def optional_header(self):
        return self._opt_header

    def get_vm(self, start, stop):
        for sec in self._sections:
            if sec.hdr.VirtualAddress <= start and sec.hdr.VirtualAddress + sec.hdr.VirtualSize >= stop:
                sec_offs = start - sec.hdr.VirtualAddress
                init_size = min(sec.hdr.SizeOfRawData - sec_offs, stop - start)
                uninit_size = stop - start - init_size
                if len(sec.data) < sec_offs + init_size:
                    raise RuntimeError('PE file corrupt: missing section content')
                return rope(sec.data[sec_offs:sec_offs + init_size], b'\0'*uninit_size)

    def has_trailer(self):
        return bool(self._trailer)

    def remove_trailer(self):
        self.remove_signature()
        self._trailer = b''

    def has_signature(self):
        return len(self._data_directories) > IMAGE_DIRECTORY_ENTRY_SECURITY and self._data_directories[IMAGE_DIRECTORY_ENTRY_SECURITY].VirtualAddress != 0

    def remove_signature(self):
        if len(self._data_directories) < IMAGE_DIRECTORY_ENTRY_SECURITY:
            return

        dd = self._data_directories[IMAGE_DIRECTORY_ENTRY_SECURITY]
        if dd.Size == 0:
            return

        end_of_image = max(sec.hdr.PointerToRawData + sec.hdr.SizeOfRawData for sec in self._sections if sec.hdr.SizeOfRawData != 0)

        if dd.VirtualAddress + dd.Size != end_of_image + len(self._trailer):
            raise RuntimeError('signature is not at the end of the file')

        if dd.VirtualAddress < end_of_image:
            raise RuntimeError('signature is not contained in the pe trailer')

        self._trailer = self._trailer[:-dd.Size]
        dd.VirtualAddress = 0
        dd.Size = 0

    def has_directory(self, idx):
        if len(self._data_directories) < idx:
            return False

        dd = self._data_directories[idx]
        return dd.VirtualAddress != 0

    def find_directory(self, idx):
        if len(self._data_directories) < idx:
            return None

        dd = self._data_directories[idx]
        if dd.VirtualAddress == 0:
            return None

        return slice(dd.VirtualAddress, dd.VirtualAddress + dd.Size)

    def get_codeview_link(self):
        debug_dir = self.get_directory_contents(IMAGE_DIRECTORY_ENTRY_DEBUG)

        while debug_dir:
            dd = _IMAGE_DEBUG_DIRECTORY.unpack_from(debug_dir)
            debug_dir = debug_dir[_IMAGE_DEBUG_DIRECTORY.size:]

            if dd.Type == IMAGE_DEBUG_TYPE_CODEVIEW:
                dl = self._blob[dd.PointerToRawData:dd.PointerToRawData+dd.SizeOfData]

                cv = parse_rsds_blob(dl)
                if cv is not None:
                    return cv
        return None

    def get_directory_contents(self, idx):
        dd = self.find_directory(idx)
        if dd is None:
            return None

        return self.get_vm(dd.start, dd.stop)

    def parse_resources(self):
        vm_slice = self.find_directory(IMAGE_DIRECTORY_ENTRY_RESOURCE)
        if vm_slice is None:
            return None

        data = self.get_vm(vm_slice.start, vm_slice.stop)
        return parse_pe_resources(data, vm_slice.start)

    def _get_version_info_dict(self):
        res = self.parse_resources()
        if not res:
            return
        return res.get(KnownResourceTypes.RT_VERSION, {}).get(1, {})

    def get_version_info(self, langs=(0x0409, 0)):
        vis = self._get_version_info_dict()
        if not vis:
            return None

        for lngid in langs:
            vi = vis.get(lngid)
            if vi is not None:
                break
        else:
            lngid, vi = vis.popitem()

        return parse_version_info(vi)

    def get_file_version(self):
        vi = self.get_version_info()
        return vi.get_fixed_info().file_version_tuple if vi else None

    def get_product_version(self):
        vi = self.get_version_info()
        return vi.get_fixed_info().product_version_tuple if vi else None

    def _get_directory_section(self, dd_idx):
        if dd_idx >= len(self._data_directories):
            return None

        dd = self._data_directories[dd_idx]
        if dd.Size == 0:
            return None

        for sec_idx, sec in enumerate(self._sections):
            if sec.hdr.VirtualAddress == dd.VirtualAddress and sec.hdr.VirtualSize == dd.Size:
                return sec_idx

    def _find_vm_hole(self, secs, size):
        sorted_secs = sorted(secs, key=lambda sec: sec.hdr.VirtualAddress)
        i = 1
        while i < len(sorted_secs):
            start = self._mem_align(sorted_secs[i-1].hdr.VirtualAddress + sorted_secs[i-1].hdr.VirtualSize)
            stop = sorted_secs[i].hdr.VirtualAddress

            if stop - start >= size:
                return slice(start, self._mem_align(start + size))

            i += 1

        start = self._mem_align(sorted_secs[-1].hdr.VirtualAddress + sorted_secs[-1].hdr.VirtualSize)
        return slice(start, self._mem_align(start + size))

    def _resize_directory(self, idx, size):
        sec_idx = self._get_directory_section(idx)
        if sec_idx is None:
            raise RuntimeError('can\'t modify a directory that is not associated with a section')

        sec = self._sections[sec_idx]
        move_map = {}

        addr = self._mem_align(sec.hdr.VirtualAddress + size)
        for other_sec in self._sections[sec_idx + 1:]:
            move_map[other_sec] = addr
            addr = self._mem_align(addr + other_sec.hdr.VirtualSize)

        for dd in self._data_directories:
            if dd.VirtualAddress == 0:
                continue

            for osec, target_addr in move_map.items():
                if osec.hdr.VirtualAddress <= dd.VirtualAddress <= osec.hdr.VirtualAddress + osec.hdr.VirtualSize:
                    dd.VirtualAddress += target_addr - osec.hdr.VirtualAddress
                    break

        for osec, target_addr in move_map.items():
            osec.hdr.VirtualAddress = target_addr

        sec.hdr.VirtualSize = size

        dd = self._data_directories[idx]
        dd.Size = size

        return sec_idx, sec.hdr.VirtualAddress

    def is_dir_safely_resizable(self, idx):
        sec_idx = self._get_directory_section(idx)
        if sec_idx is None:
            return False

        return all((sec.hdr.Characteristics & IMAGE_SCN_MEM_DISCARDABLE) != 0 for sec in self._sections[sec_idx+1:])

    def resize_directory(self, idx, size):
        _, addr = self._resize_directory(idx, size)
        return addr

    def set_directory(self, idx, blob):
        sec_idx, _ = self._resize_directory(idx, len(blob))

        sec = self._sections[sec_idx]
        sec.data = blob

    def to_blob(self, update_checksum=False):
        self._opt_header.CheckSum = 0
        self._opt_header.SizeOfImage = max(self._mem_align(sec.hdr.VirtualAddress + sec.hdr.VirtualSize) for sec in self._sections)

        self._check_vm_overlaps()

        header_end = (len(self._dos_stub) + 4 + self._file_header.size + 2 + self._opt_header.size
            + len(self._data_directories) * _IMAGE_DATA_DIRECTORY.size + len(self._sections) * _IMAGE_SECTION_HEADER.size)
        section_offset = self._file_align(header_end)
        header_pad = section_offset - header_end

        for sec in self._sections:
            if sec.hdr.PointerToRawData == 0:
                continue
            sec.hdr.PointerToRawData = section_offset
            sec.hdr.SizeOfRawData = self._file_align(len(sec.data))
            section_offset = section_offset + sec.hdr.SizeOfRawData

        new_file = []

        new_file.append(self._dos_stub)
        new_file.append(b'PE\0\0')
        new_file.append(self._file_header.pack())
        new_file.append(struct.pack('<H', self._opt_header.sig))
        new_file.append(self._opt_header.pack())

        for dd in self._data_directories:
            new_file.append(dd.pack())

        for sec in self._sections:
            new_file.append(sec.hdr.pack())

        new_file.append(b'\0'*header_pad)
        for sec in self._sections:
            if sec.data is None:
                continue
            new_file.append(sec.data)
            with_pad = self._file_align(len(sec.data))
            pad = with_pad - len(sec.data)
            if pad:
                new_file.append(b'\0'*pad)

        new_file.append(self._trailer)

        out_blob = rope(*new_file)
        if update_checksum:
            new_checksum = pe_checksum(out_blob)
        else:
            new_checksum = 0

        return rope(out_blob[:self._checksum_offs], struct.pack('<I', new_checksum), out_blob[self._checksum_offs + 4:])

    def to_bytes(self, update_checksum=False):
        return bytes(self.to_blob(update_checksum=update_checksum))

def parse_pe(blob, verify_checksum=False):
    """Parse a PE file and return a PeFile object
    
    Expects either a bytes object or a grope.rope object consisting
    only of bytes objects (the latter is recommended).

    Set `verify_checksum=True` to add `checksum_correct` member to
    the returned object.
    """

    if isinstance(blob, bytes):
        blob = memoryview(blob)
    return _PeFile(blob, verify_checksum=verify_checksum)
