From f29e139cbb7e4a4d539cba6e894ef4a6acd312d6 Mon Sep 17 00:00:00 2001
From: Evgeny Zinoviev <me@ch1p.io>
Date: Wed, 31 May 2023 09:22:00 +0300
Subject: WIP: big refactoring

---
 src/home/database/clickhouse.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'src/home/database/clickhouse.py')

diff --git a/src/home/database/clickhouse.py b/src/home/database/clickhouse.py
index ca81628..d0ec283 100644
--- a/src/home/database/clickhouse.py
+++ b/src/home/database/clickhouse.py
@@ -1,7 +1,7 @@
 import logging
 
 from zoneinfo import ZoneInfo
-from datetime import datetime, timedelta
+from datetime import datetime
 from clickhouse_driver import Client as ClickhouseClient
 from ..config import is_development_mode
 
-- 
cgit v1.2.3


From b0bf43e6a272d42a55158e657bd937cb82fc3d8d Mon Sep 17 00:00:00 2001
From: Evgeny Zinoviev <me@ch1p.io>
Date: Sat, 10 Jun 2023 23:02:34 +0300
Subject: move files, rename home package to homekit

---
 src/home/database/clickhouse.py | 39 ---------------------------------------
 1 file changed, 39 deletions(-)
 delete mode 100644 src/home/database/clickhouse.py

(limited to 'src/home/database/clickhouse.py')

diff --git a/src/home/database/clickhouse.py b/src/home/database/clickhouse.py
deleted file mode 100644
index d0ec283..0000000
--- a/src/home/database/clickhouse.py
+++ /dev/null
@@ -1,39 +0,0 @@
-import logging
-
-from zoneinfo import ZoneInfo
-from datetime import datetime
-from clickhouse_driver import Client as ClickhouseClient
-from ..config import is_development_mode
-
-_links = {}
-
-
-def get_clickhouse(db: str) -> ClickhouseClient:
-    if db not in _links:
-        _links[db] = ClickhouseClient.from_url(f'clickhouse://localhost/{db}')
-
-    return _links[db]
-
-
-class ClickhouseDatabase:
-    def __init__(self, db: str):
-        self.db = get_clickhouse(db)
-
-        self.server_timezone = self.db.execute('SELECT timezone()')[0][0]
-        self.logger = logging.getLogger(self.__class__.__name__)
-
-    def query(self, *args, **kwargs):
-        settings = {'use_client_time_zone': True}
-        kwargs['settings'] = settings
-
-        if 'no_tz_fix' not in kwargs and len(args) > 1 and isinstance(args[1], dict):
-            for k, v in args[1].items():
-                if isinstance(v, datetime):
-                    args[1][k] = v.astimezone(tz=ZoneInfo(self.server_timezone))
-
-        result = self.db.execute(*args, **kwargs)
-
-        if is_development_mode():
-            self.logger.debug(args[0] if len(args) == 1 else args[0] % args[1])
-
-        return result
-- 
cgit v1.2.3