"""Atomic append of gzipped data.

The point is - if several gzip streams are concatenated,
they are read back as one whole stream.
"""

from __future__ import division, absolute_import, print_function

import gzip
from io import BytesIO

__all__ = ['gzip_append']

#
# gzip storage
#
def gzip_append(filename, data, level=6):
    """Append a block of data to file with safety checks."""

    # compress data
    buf = BytesIO()
    g = gzip.GzipFile(fileobj=buf, compresslevel=level, mode="w")
    g.write(data)
    g.close()
    zdata = buf.getvalue()

    # append, safely
    f = open(filename, "ab+", 0)
    f.seek(0, 2)
    pos = f.tell()
    try:
        f.write(zdata)
        f.close()
    except Exception as ex:
        # rollback on error
        f.seek(pos, 0)
        f.truncate()
        f.close()
        raise ex