Initial dev commit.

Changes
=======
* Basic query functionality is available for both sync and async APIs
* Rough handling of timeouts and cancellation is available (but more
  work needs to be done)
* Error handling is incomplete
* Linting is not in place (and will require changes)
* Typing is not in place (and will require changes)
* Test suite is minimal

Author: thejcfactor

.gitignore

@@ -0,0 +1,182 @@
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*$py.class
+
+# C extensions
+*.so
+
+# Distribution / packaging
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+share/python-wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+MANIFEST
+
+# PyInstaller
+#  Usually these files are written by a python script from a template
+#  before PyInstaller builds the exe, so as to inject date/other infos into it.
+*.manifest
+*.spec
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.nox/
+.coverage
+.coverage.*
+.cache
+nosetests.xml
+coverage.xml
+*.cover
+*.py,cover
+.hypothesis/
+.pytest_cache/
+cover/
+
+# Translations
+*.mo
+*.pot
+
+# Django stuff:
+*.log
+local_settings.py
+db.sqlite3
+db.sqlite3-journal
+
+# Flask stuff:
+instance/
+.webassets-cache
+
+# Scrapy stuff:
+.scrapy
+
+# Sphinx documentation
+docs/_build/
+
+# PyBuilder
+.pybuilder/
+target/
+
+# Jupyter Notebook
+.ipynb_checkpoints
+
+# IPython
+profile_default/
+ipython_config.py
+
+# pyenv
+#   For a library or package, you might want to ignore these files since the code is
+#   intended to run in multiple environments; otherwise, check them in:
+# .python-version
+
+# pipenv
+#   According to pypa/pipenv#598, it is recommended to include Pipfile.lock in version control.
+#   However, in case of collaboration, if having platform-specific dependencies or dependencies
+#   having no cross-platform support, pipenv may install dependencies that don't work, or not
+#   install all needed dependencies.
+#Pipfile.lock
+
+# poetry
+#   Similar to Pipfile.lock, it is generally recommended to include poetry.lock in version control.
+#   This is especially recommended for binary packages to ensure reproducibility, and is more
+#   commonly ignored for libraries.
+#   https://python-poetry.org/docs/basic-usage/#commit-your-poetrylock-file-to-version-control
+#poetry.lock
+
+# pdm
+#   Similar to Pipfile.lock, it is generally recommended to include pdm.lock in version control.
+#pdm.lock
+#   pdm stores project-wide configurations in .pdm.toml, but it is recommended to not include it
+#   in version control.
+#   https://pdm.fming.dev/#use-with-ide
+.pdm.toml
+
+# PEP 582; used by e.g. github.com/David-OConnor/pyflow and github.com/pdm-project/pdm
+__pypackages__/
+
+# Celery stuff
+celerybeat-schedule
+celerybeat.pid
+
+# SageMath parsed files
+*.sage.py
+
+# Environments
+.env
+.venv
+env/
+venv/
+ENV/
+env.bak/
+venv.bak/
+
+# Spyder project settings
+.spyderproject
+.spyproject
+
+# Rope project settings
+.ropeproject
+
+# mkdocs documentation
+/site
+
+# mypy
+.mypy_cache/
+.dmypy.json
+dmypy.json
+
+# Pyre type checker
+.pyre/
+
+# pytype static type analyzer
+.pytype/
+
+# Cython debug symbols
+cython_debug/
+
+# PyCharm
+#  JetBrains specific template is maintained in a separate JetBrains.gitignore that can
+#  be found at https://github.com/github/gitignore/blob/main/Global/JetBrains.gitignore
+#  and can be added to the global gitignore or merged into this file.  For a more nuclear
+#  option (not recommended) you can uncomment the following to ignore the entire idea folder.
+.idea/
+
+# Distribution / packaging
+build/
+couchbase_columnar/_version.py
+couchbase_columnar/*.so
+couchbase_columnar/*.dylib*.*
+couchbase_columnar/*.dll
+couchbase_columnar/*.pyd
+deps/couchbase-cxx-cache/
+
+# Sphinx
+docs/_build/
+
+# VS Code
+.vscode/
+
+# tests
+tests/test_logs/
+CouchbaseMock*.jar
+gocaves*
+.pytest_cache/
+test_scripts/

LICENSE

@@ -0,0 +1,91 @@
+#  Copyright 2016-2024. Couchbase, Inc.
+#  All Rights Reserved.
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+
+import asyncio
+import selectors
+from asyncio import AbstractEventLoop
+from typing import Optional
+
+from couchbase_analytics.common import JSONType as JSONType  # noqa: F401
+
+
+class _LoopValidator:
+    """
+    **INTERNAL**
+    """
+
+    REQUIRED_METHODS = {'add_reader', 'remove_reader',
+                        'add_writer', 'remove_writer'}
+
+    @staticmethod
+    def _get_working_loop() -> AbstractEventLoop:
+        """
+        **INTERNAL**
+        """
+        evloop = asyncio.get_event_loop()
+        gen_new_loop = not _LoopValidator._is_valid_loop(evloop)
+        if gen_new_loop:
+            evloop.close()
+            selector = selectors.SelectSelector()
+            new_loop = asyncio.SelectorEventLoop(selector)
+            asyncio.set_event_loop(new_loop)
+            return new_loop
+
+        return evloop
+
+    @staticmethod
+    def _is_valid_loop(evloop: Optional[AbstractEventLoop] = None) -> bool:
+        """
+        **INTERNAL**
+        """
+        if not evloop:
+            return False
+        for meth in _LoopValidator.REQUIRED_METHODS:
+            abs_meth, actual_meth = (
+                getattr(asyncio.AbstractEventLoop, meth), getattr(evloop.__class__, meth))
+            if abs_meth == actual_meth:
+                return False
+        return True
+
+    @staticmethod
+    def get_event_loop(evloop: Optional[AbstractEventLoop] = None) -> AbstractEventLoop:
+        """
+        **INTERNAL**
+        """
+        if evloop and _LoopValidator._is_valid_loop(evloop):
+            return evloop
+        return _LoopValidator._get_working_loop()
+
+    @staticmethod
+    def close_loop() -> None:
+        """
+        **INTERNAL**
+        """
+        evloop = asyncio.get_event_loop()
+        evloop.close()
+
+
+def get_event_loop(evloop: Optional[AbstractEventLoop] = None) -> AbstractEventLoop:
+    """
+    Get an event loop compatible with acouchbase_analytics.
+    Some Event loops, such as ProactorEventLoop (the default asyncio event
+    loop for Python 3.8 on Windows) are not compatible with acouchbase_analytics as
+    they don't implement all members in the abstract base class.
+
+    :param evloop: preferred event loop
+    :return: The preferred event loop, if compatible, otherwise, a compatible
+    alternative event loop.
+    """
+    return _LoopValidator.get_event_loop(evloop)