YQ Connector:Use docker-compose in integrational tests

1 files changed, 151 insertions, 0 deletions

diff --git a/contrib/python/python-libarchive/py2/libarchive/zip.py b/contrib/python/python-libarchive/py2/libarchive/zip.py
new file mode 100644
index 0000000000..539f6dbcc4
--- /dev/null
+++ b/contrib/python/python-libarchive/py2/libarchive/zip.py
@@ -0,0 +1,151 @@
+# Copyright (c) 2011, SmartFile <btimby@smartfile.com>
+# All rights reserved.
+#
+# Redistribution and use in source and binary forms, with or without
+# modification, are permitted provided that the following conditions are met:
+#     * Redistributions of source code must retain the above copyright
+#       notice, this list of conditions and the following disclaimer.
+#     * Redistributions in binary form must reproduce the above copyright
+#       notice, this list of conditions and the following disclaimer in the
+#       documentation and/or other materials provided with the distribution.
+#     * Neither the name of the organization nor the
+#       names of its contributors may be used to endorse or promote products
+#       derived from this software without specific prior written permission.
+#
+# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+# ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+# DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER BE LIABLE FOR ANY
+# DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+# (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+# LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+# ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+# SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+import os, time
+from libarchive import is_archive, Entry, SeekableArchive
+from zipfile import ZIP_STORED, ZIP_DEFLATED
+
+
+def is_zipfile(filename):
+    return is_archive(filename, formats=('zip', ))
+
+
+class ZipEntry(Entry):
+    def __init__(self, *args, **kwargs):
+        super(ZipEntry, self).__init__(*args, **kwargs)
+
+    def get_filename(self):
+        return self.pathname
+
+    def set_filename(self, value):
+        self.pathname = value
+
+    filename = property(get_filename, set_filename)
+
+    def get_file_size(self):
+        return self.size
+
+    def set_file_size(self, value):
+        assert isinstance(size, (int, long)), 'Please provide size as int or long.'
+        self.size = value
+
+    file_size = property(get_file_size, set_file_size)
+
+    def get_date_time(self):
+        return time.localtime(self.mtime)[0:6]
+
+    def set_date_time(self, value):
+        assert isinstance(value, tuple), 'mtime should be tuple (year, month, day, hour, minute, second).'
+        assert len(value) == 6, 'mtime should be tuple (year, month, day, hour, minute, second).'
+        self.mtime = time.mktime(value + (0, 0, 0))
+
+    date_time = property(get_date_time, set_date_time)
+
+    header_offset = Entry.header_position
+
+    def _get_missing(self):
+        raise NotImplemented()
+
+    def _set_missing(self, value):
+        raise NotImplemented()
+
+    compress_type = property(_get_missing, _set_missing)
+    comment = property(_get_missing, _set_missing)
+    extra = property(_get_missing, _set_missing)
+    create_system = property(_get_missing, _set_missing)
+    create_version = property(_get_missing, _set_missing)
+    extract_version = property(_get_missing, _set_missing)
+    reserved = property(_get_missing, _set_missing)
+    flag_bits = property(_get_missing, _set_missing)
+    volume = property(_get_missing, _set_missing)
+    internal_attr = property(_get_missing, _set_missing)
+    external_attr = property(_get_missing, _set_missing)
+    CRC = property(_get_missing, _set_missing)
+    compress_size = property(_get_missing, _set_missing)
+
+
+class ZipFile(SeekableArchive):
+    def __init__(self, f, mode='r', compression=ZIP_DEFLATED, allowZip64=False):
+        super(ZipFile, self).__init__(f, mode=mode, format='zip', entry_class=ZipEntry, encoding='CP437')
+        if mode == 'w' and compression == ZIP_STORED:
+            # Disable compression for writing.
+            _libarchive.archive_write_set_format_option(self.archive._a, "zip", "compression", "store")
+        self.compression = compression
+
+    getinfo     = SeekableArchive.getentry
+
+    def namelist(self):
+        return list(self.iterpaths)
+
+    def infolist(self):
+        return list(self)
+
+    def open(self, name, mode, pwd=None):
+        if pwd:
+            raise NotImplemented('Encryption not supported.')
+        if mode == 'r':
+            return self.readstream(name)
+        else:
+            return self.writestream(name)
+
+    def extract(self, name, path=None, pwd=None):
+        if pwd:
+            raise NotImplemented('Encryption not supported.')
+        if not path:
+            path = os.getcwd()
+        return self.readpath(name, os.path.join(path, name))
+
+    def extractall(self, path, names=None, pwd=None):
+        if pwd:
+            raise NotImplemented('Encryption not supported.')
+        if not names:
+            names = self.namelist()
+        if names:
+            for name in names:
+                self.extract(name, path)
+
+    def read(self, name, pwd=None):
+        if pwd:
+            raise NotImplemented('Encryption not supported.')
+        return self.read(name)
+
+    def writestr(self, member, data, compress_type=None):
+        if compress_type != self.compression:
+            raise Exception('Cannot change compression type for individual entries.')
+        return self.write(member, data)
+
+    def setpassword(self, pwd):
+        raise NotImplemented('Encryption not supported.')
+
+    def testzip(self):
+        raise NotImplemented()
+
+    def _get_missing(self):
+        raise NotImplemented()
+
+    def _set_missing(self, value):
+        raise NotImplemented()
+
+    comment = property(_get_missing, _set_missing)