import struct
import msgpack

from ..utils import nbytes

BIG_BYTES_SHARD_SIZE = 2 ** 26


msgpack_opts = {
    ("max_%s_len" % x): 2 ** 31 - 1 for x in ["str", "bin", "array", "map", "ext"]
}
msgpack_opts["strict_map_key"] = False

try:
    msgpack.loads(msgpack.dumps(""), raw=False, **msgpack_opts)
    msgpack_opts["raw"] = False
except TypeError:
    # Backward compat with old msgpack (prior to 0.5.2)
    msgpack_opts["encoding"] = "utf-8"


def frame_split_size(frame, n=BIG_BYTES_SHARD_SIZE) -> list:
    """
    Split a frame into a list of frames of maximum size

    This helps us to avoid passing around very large bytestrings.

    Examples
    --------
    >>> frame_split_size([b'12345', b'678'], n=3)  # doctest: +SKIP
    [b'123', b'45', b'678']
    """
    if nbytes(frame) <= n:
        return [frame]

    if nbytes(frame) > n:
        if isinstance(frame, (bytes, bytearray)):
            frame = memoryview(frame)
        try:
            itemsize = frame.itemsize
        except AttributeError:
            itemsize = 1

        return [
            frame[i : i + n // itemsize]
            for i in range(0, nbytes(frame) // itemsize, n // itemsize)
        ]


def merge_frames(header, frames):
    """ Merge frames into original lengths

    Examples
    --------
    >>> merge_frames({'lengths': [3, 3]}, [b'123456'])
    [b'123', b'456']
    >>> merge_frames({'lengths': [6]}, [b'123', b'456'])
    [b'123456']
    """
    lengths = list(header["lengths"])
    frames = list(map(memoryview, frames))

    assert sum(lengths) == sum(map(nbytes, frames))

    if not all(len(f) == l for f, l in zip(frames, lengths)):
        frames = frames[::-1]
        lengths = lengths[::-1]

        out = []
        while lengths:
            l = lengths.pop()
            L = []
            while l:
                frame = frames.pop()
                if nbytes(frame) <= l:
                    L.append(frame)
                    l -= nbytes(frame)
                else:
                    L.append(frame[:l])
                    frames.append(frame[l:])
                    l = 0
            if len(L) == 1:  # no work necessary
                out.append(L[0])
            else:
                out.append(memoryview(bytearray().join(L)))
        frames = out

    frames = [memoryview(bytearray(f)) if f.readonly else f for f in frames]

    return frames


def pack_frames_prelude(frames):
    nframes = len(frames)
    nbytes_frames = map(nbytes, frames)
    return struct.pack(f"Q{nframes}Q", nframes, *nbytes_frames)


def pack_frames(frames):
    """ Pack frames into a byte-like object

    This prepends length information to the front of the bytes-like object

    See Also
    --------
    unpack_frames
    """
    data = [pack_frames_prelude(frames)]
    data.extend(frames)
    return b"".join(data)


def unpack_frames(b):
    """ Unpack bytes into a sequence of frames

    This assumes that length information is at the front of the bytestring,
    as performed by pack_frames

    See Also
    --------
    pack_frames
    """
    b = memoryview(b)

    fmt = "Q"
    fmt_size = struct.calcsize(fmt)

    (n_frames,) = struct.unpack_from(fmt, b)
    lengths = struct.unpack_from(f"{n_frames}{fmt}", b, fmt_size)

    frames = []
    start = fmt_size * (1 + n_frames)
    for length in lengths:
        end = start + length
        frame = b[start:end]
        frames.append(frame)
        start = end

    return frames

@@ -10,23 +10,8 @@
 ruct
-%0Aimport msgpack
 %0A%0Afr
@@ -214,222 +214,35 @@
 lse%0A
-%0Atry:%0A    msgpack.loads(msgpack.dumps(%22%22), raw=False, **msgpack_opts)%0A    msgpack_opts%5B%22raw%22%5D = False%0Aexcept TypeError:%0A    # Backward compat with old msgpack (prior to 0.5.2)%0A    msgpack_opts%5B%22encoding%22%5D = %22utf-8%22
+msgpack_opts%5B%22raw%22%5D = False
 %0A%0A%0Ad

Drop msgpack pre-0.5.2 compat code (#3977)