Load/save channels from/to database.

src/channel_manager.py

@@ -1,49 +1,30 @@
 #!/usr/bin/env python3
 
-import json
+from src.db import Database
-import os
+from sqlalchemy import Table, Column, Integer, String, Boolean, MetaData
-from os import path
+
+meta = MetaData()
+channel_table = Table(
+    'Channels',
+    meta,
+    Column('id', Integer, primary_key=True, autoincrement=True),
+    Column('channel', String, unique=True, nullable=False),
+    Column('autojoin', Boolean, default=True),
+)
+db = Database(channel_table, meta)
 
 
 class ChannelManager:
     def __init__(self):
-        self.channels = self._load_channels()
+        db.create_table(channel_table.name)
 
-    def _load_channels(self):
+        self.channels = db._load_channels()
-        os.makedirs('data', exist_ok=True)
-        if not path.exists('data/channels.json'):
-            with open('data/channels.json', 'w') as f:
-                json.dump([], f)
-            return []
-        try:
-            with open('data/channels.json', 'r') as f:
-                return json.load(f)
-        except json.JSONDecodeError as e:
-            print(f'Error decoding JSON: {e}')
-            return []
-        except Exception as e:
-            print(f'Error loading channels: {e}')
-            return []
 
     def save_channel(self, channel):
-        channel = channel.lstrip(':')
+        db._save_channel(channel)
-        if channel not in self.channels:
-            self.channels.append(channel)
-            self._write_channels()
 
     def remove_channel(self, channel):
-        channel = channel.lstrip(':')
+        db._remove_channel(channel)
-        if channel in self.channels:
-            self.channels.remove(channel)
-            self._write_channels()
-
-    def _write_channels(self):
-        os.makedirs('data', exist_ok=True)
-        try:
-            with open('data/channels.json', 'w') as f:
-                json.dump(self.channels, f)
-        except Exception as e:
-            print(f'Error saving channels: {e}')
 
     def get_channels(self):
         return self.channels

src/db.py

@@ -1,4 +1,4 @@
-from sqlalchemy import create_engine, Table, MetaData, inspect, update, select
+from sqlalchemy import create_engine, Table, MetaData, inspect, update, select, insert, delete
 from sqlalchemy_utils import database_exists, create_database
 
 
@@ -37,3 +37,31 @@ class Database:
                 return conn.execute(select(self.table).where(self.table.c.name == user)).fetchone()[index]
             else:
                 return -1
+
+    def _load_channels(self):
+        with self.engine.connect() as conn:
+            return conn.execute(select(self.table)).fetchall()
+
+    def _save_channel(self, channel: str):
+        with self.engine.connect() as conn:
+            stmt = select(self.table).where(self.table.c.channel == channel)
+            cnt = len(conn.execute(stmt).fetchall())
+
+            if cnt == 0:
+                conn.execute((
+                    insert(self.table).
+                    values({'channel': channel})
+                ))
+                conn.commit()
+
+    def _remove_channel(self, channel: str):
+        with self.engine.connect() as conn:
+            stmt = select(self.table).where(self.table.c.channel == channel)
+            cnt = len(conn.execute(stmt).fetchall())
+
+            if cnt == 1:
+                conn.execute((
+                    delete(self.table).
+                    where(self.table.c.channel == channel)
+                ))
+                conn.commit()