Apply black, isort, autoflake

Test with autoflake

Author: danielebriggi

.flake8

@@ -1,6 +1,6 @@
 [flake8]
 # E203: it's a parse limit of flake8
-# W503: https://black.readthedocs.io/en/stable/guides/using_black_with_other_tools.html#w503
-ignore = E203, W503, E501,E701
+# W503,E501,E701: https://black.readthedocs.io/en/stable/guides/using_black_with_other_tools.html#w503
+ignore = E203, W503, E501, E701
 # align to black choice
 max-line-length = 88

src/setup.py

@@ -1,44 +1,44 @@
 import io
 import os
 
-from setuptools import setup, find_packages
+from setuptools import find_packages, setup
 
 
 def read_file(filename):
     base_path = os.path.abspath(os.path.dirname(__file__))
     full_path = os.path.join(base_path, filename)
     try:
-        with io.open(full_path, encoding='utf-8') as file:
+        with io.open(full_path, encoding="utf-8") as file:
             return file.read()
     except FileNotFoundError:
-        full_path = os.path.join(base_path, f'../{filename}')
-        with io.open(full_path, encoding='utf-8') as file:
+        full_path = os.path.join(base_path, f"../{filename}")
+        with io.open(full_path, encoding="utf-8") as file:
             return file.read()
 
 
 setup(
-    name='SqliteCloud',
-    version='0.0.75',
-    author='sqlitecloud.io',
-    description='A Python package for working with SQLite databases in the cloud.',
-    long_description=read_file('README-PYPI.md'),
-    long_description_content_type='text/markdown',
+    name="SqliteCloud",
+    version="0.0.75",
+    author="sqlitecloud.io",
+    description="A Python package for working with SQLite databases in the cloud.",
+    long_description=read_file("README-PYPI.md"),
+    long_description_content_type="text/markdown",
     url="https://github.com/sqlitecloud/python",
     packages=find_packages(),
     install_requires=[
-        'lz4 == 3.1.10',
+        "lz4 == 3.1.10",
     ],
     classifiers=[
-        'Development Status :: 3 - Alpha',
-        'Intended Audience :: Developers',
-        'License :: OSI Approved :: MIT License',
-        'Programming Language :: Python :: 3.6',
-        'Programming Language :: Python :: 3.7',
-        'Programming Language :: Python :: 3.8',
-        'Programming Language :: Python :: 3.9',
-        'Programming Language :: Python :: 3.10',
-        'Programming Language :: Python :: 3.11',
-        'Programming Language :: Python :: 3.12',
+        "Development Status :: 3 - Alpha",
+        "Intended Audience :: Developers",
+        "License :: OSI Approved :: MIT License",
+        "Programming Language :: Python :: 3.6",
+        "Programming Language :: Python :: 3.7",
+        "Programming Language :: Python :: 3.8",
+        "Programming Language :: Python :: 3.9",
+        "Programming Language :: Python :: 3.10",
+        "Programming Language :: Python :: 3.11",
+        "Programming Language :: Python :: 3.12",
     ],
-    license='MIT',
+    license="MIT",
 )

src/sqlitecloud/client.py

@@ -29,7 +29,8 @@ def __init__(
         """Initializes a new instance of the class with connection information.
 
         Args:
-            cloud_account (SqliteCloudAccount): The account information for the SQlite Cloud database.
+            cloud_account (SqliteCloudAccount): The account information for the
+                SQlite Cloud database.
             connection_str (str): The connection string for the SQlite Cloud database.
                 Eg: sqlitecloud://user:pass@host.com:port/dbname?timeout=10&apikey=abcd123
 
@@ -49,7 +50,8 @@ def open_connection(self) -> SQCloudConnect:
         """Opens a connection to the SQCloud server.
 
         Returns:
-            SQCloudConnect: An instance of the SQCloudConnect class representing the connection to the SQCloud server.
+            SQCloudConnect: An instance of the SQCloudConnect class representing
+                the connection to the SQCloud server.
 
         Raises:
             SQCloudException: If an error occurs while opening the connection.
@@ -75,9 +77,7 @@ def is_connected(self, conn: SQCloudConnect) -> bool:
         """
         return self._driver.is_connected(conn)
 
-    def exec_query(
-        self, query: str, conn: SQCloudConnect
-    ) -> SqliteCloudResultSet:
+    def exec_query(self, query: str, conn: SQCloudConnect) -> SqliteCloudResultSet:
         """Executes a SQL query on the SQLite Cloud database.
 
         Args:

src/sqlitecloud/download.py

@@ -1,5 +1,5 @@
-from io import BufferedWriter
 import logging
+from io import BufferedWriter
 
 from sqlitecloud.driver import Driver
 from sqlitecloud.types import SQCloudConnect

src/sqlitecloud/driver.py

@@ -1,10 +1,13 @@
-from io import BufferedReader, BufferedWriter
 import logging
 import select
+import socket
 import ssl
 import threading
+from io import BufferedReader, BufferedWriter
 from typing import Callable, Optional, Union
+
 import lz4.block
+
 from sqlitecloud.resultset import SQCloudResult, SqliteCloudResultSet
 from sqlitecloud.types import (
     SQCLOUD_CMD,
@@ -19,7 +22,6 @@
     SQCloudRowsetSignature,
     SQCloudValue,
 )
-import socket
 
 
 class Driver:
@@ -131,7 +133,7 @@ def _internal_connect(
         try:
             sock.connect((hostname, port))
         except Exception as e:
-            errmsg = f"An error occurred while initializing the socket."
+            errmsg = "An error occurred while initializing the socket."
             raise SQCloudException(errmsg) from e
 
         return sock

src/sqlitecloud/pubsub.py

@@ -1,6 +1,5 @@
-import socket
-from sqlite3 import connect
 from typing import Callable, Optional
+
 from sqlitecloud.driver import Driver
 from sqlitecloud.resultset import SqliteCloudResultSet
 from sqlitecloud.types import SQCLOUD_PUBSUB_SUBJECT, SQCloudConnect

src/sqlitecloud/types.py

@@ -1,9 +1,7 @@
+import types
 from asyncio import AbstractEventLoop
 from enum import Enum
-from threading import Thread
-import types
 from typing import Callable, Optional
-from enum import Enum
 
 
 class SQCLOUD_DEFAULT(Enum):

src/sqlitecloud/upload.py

@@ -1,9 +1,11 @@
-from io import BufferedReader
+import logging
 import os
+from io import BufferedReader
 from typing import Optional
+
 from sqlitecloud.driver import Driver
 from sqlitecloud.types import SQCloudConnect
-import logging
+
 
 def xCallback(fd: BufferedReader, blen: int, ntot: int, nprogress: int) -> bytes:
     """
@@ -45,11 +47,11 @@ def upload_db(
         SQCloudException: If an error occurs while uploading the database.
 
     """
-    
+
     # Create a driver object
     driver = Driver()
 
-    with open(filename, 'rb') as fd:
+    with open(filename, "rb") as fd:
         dbsize = os.path.getsize(filename)
 
         driver.upload_database(

src/tests/conftest.py

@@ -1,14 +1,17 @@
 import os
+
 import pytest
 from dotenv import load_dotenv
 
 from sqlitecloud.client import SqliteCloudClient
 from sqlitecloud.types import SQCloudConnect, SqliteCloudAccount
 
+
 @pytest.fixture(autouse=True)
 def load_env_vars():
     load_dotenv(".env")
 
+
 @pytest.fixture()
 def sqlitecloud_connection():
     account = SqliteCloudAccount()
@@ -26,4 +29,4 @@ def sqlitecloud_connection():
 
     yield (connection, client)
 
-    client.disconnect(connection)
+    client.disconnect(connection)

src/tests/integration/test_client.py

@@ -1,11 +1,9 @@
 import json
-from multiprocessing import connection
 import os
-import sqlite3
-import tempfile
 import time
 
 import pytest
+
 from sqlitecloud.client import SqliteCloudClient
 from sqlitecloud.types import (
     SQCLOUD_ERRCODE,
@@ -90,10 +88,10 @@ def test_is_connected(self):
         client = SqliteCloudClient(cloud_account=account)
 
         conn = client.open_connection()
-        assert client.is_connected(conn) == True
+        assert client.is_connected(conn)
 
         client.disconnect(conn)
-        assert client.is_connected(conn) == False
+        assert not client.is_connected(conn)
 
     def test_disconnect(self):
         account = SqliteCloudAccount()
@@ -104,10 +102,10 @@ def test_disconnect(self):
         client = SqliteCloudClient(cloud_account=account)
 
         conn = client.open_connection()
-        assert client.is_connected(conn) == True
+        assert client.is_connected(conn)
 
         client.disconnect(conn)
-        assert client.is_connected(conn) == False
+        assert not client.is_connected(conn)
         assert conn.socket is None
         assert conn.pubsub_socket is None
 
@@ -119,7 +117,7 @@ def test_select(self, sqlitecloud_connection):
 
         result = client.exec_query("SELECT 'Hello'", connection)
 
-        assert False == result.is_result
+        assert not result.is_result
         assert 1 == result.nrows
         assert 1 == result.ncols
         assert "Hello" == result.get_value(0, 0)
@@ -239,7 +237,7 @@ def test_json(self, sqlitecloud_connection):
         connection, client = sqlitecloud_connection
         result = client.exec_query("TEST JSON", connection)
 
-        assert SQCLOUD_RESULT_TYPE.RESULT_JSON == result.tag 
+        assert SQCLOUD_RESULT_TYPE.RESULT_JSON == result.tag
         assert {
             "msg-from": {"class": "soldier", "name": "Wixilav"},
             "msg-to": {"class": "supreme-commander", "name": "[Redacted]"},
@@ -293,7 +291,7 @@ def test_array(self, sqlitecloud_connection):
         result = client.exec_query("TEST ARRAY", connection)
 
         result_array = result.get_result()
-        
+
         assert SQCLOUD_RESULT_TYPE.RESULT_ARRAY == result.tag
         assert isinstance(result_array, list)
         assert len(result_array) == 5
@@ -332,7 +330,6 @@ def test_max_rows_option(self):
         # just expect everything is ok
         assert rowset.nrows > 100
 
-
     def test_max_rowset_option_to_fail_when_rowset_is_bigger(self):
         account = SqliteCloudAccount()
         account.hostname = os.getenv("SQLITE_HOST")
@@ -352,7 +349,6 @@ def test_max_rowset_option_to_fail_when_rowset_is_bigger(self):
         assert SQCLOUD_ERRCODE.INTERNAL.value == e.value.errcode
         assert "RowSet too big to be sent (limit set to 1024 bytes)." == e.value.errmsg
 
-
     def test_max_rowset_option_to_succeed_when_rowset_is_lighter(self):
         account = SqliteCloudAccount()
         account.hostname = os.getenv("SQLITE_HOST")
@@ -439,7 +435,7 @@ def test_query_timeout(self):
                     LIMIT 10000000
                 )
                 SELECT i FROM r WHERE i = 1;""",
-                connection
+                connection,
             )
 
         client.disconnect(connection)
@@ -645,7 +641,8 @@ def test_compression_multiple_columns(self):
 
         # min compression size for rowset set by default to 20400 bytes
         rowset = client.exec_query(
-            "SELECT * from albums inner join albums a2 on albums.AlbumId = a2.AlbumId", connection
+            "SELECT * from albums inner join albums a2 on albums.AlbumId = a2.AlbumId",
+            connection,
         )
 
         client.disconnect(connection)