From: Christian Heller <c.heller@plomlompom.de>
Date: Sun, 24 Nov 2024 17:46:58 +0000 (+0100)
Subject: Create initial migration.
X-Git-Url: https://plomlompom.com/repos/%7B%7Bdb.prefix%7D%7D/static/%7B%7B%20web_path%20%7D%7D/%7B%7Bprefix%7D%7D/task?a=commitdiff_plain;h=635cb1db4731be1a002d7b9f53bd1115d16f03c7;p=ytplom

Create initial migration.
---

diff --git a/install.py b/install.py
index db188e8..991ef5f 100755
--- a/install.py
+++ b/install.py
@@ -3,14 +3,14 @@
 from shutil import copyfile
 from os import makedirs, scandir
 from os.path import basename, join as path_join
-from ytplom.misc import NAME_TEMPLATES_DIR, PATH_APP_DATA, PATH_TEMPLATES
+from ytplom.misc import PATH_APP_DATA, PATH_MIGRATIONS, PATH_TEMPLATES
 
-print(f'ensuring {PATH_APP_DATA}')
-makedirs(PATH_APP_DATA)
-print(f'ensuring {PATH_TEMPLATES}')
-makedirs(PATH_TEMPLATES)
-for e in scandir(NAME_TEMPLATES_DIR):
-    target_path = path_join(PATH_TEMPLATES, basename(e.path))
-    print(f'copying {e.path} to {target_path}')
-    copyfile(e.path, target_path)
-print(f'installation finished')
+for path in (PATH_APP_DATA, PATH_TEMPLATES, PATH_MIGRATIONS):
+    print(f'ensuring {path}')
+    makedirs(path)
+for path_dir in (PATH_MIGRATIONS, PATH_TEMPLATES):
+    for entry in scandir(basename(path_dir)):
+        target_path = path_join(path_dir, basename(entry.path))
+        print(f'copying {entry.path} to {target_path}')
+        copyfile(entry.path, target_path)
+print('installation finished')
diff --git a/migrations/init_0.sql b/migrations/init_0.sql
new file mode 100644
index 0000000..5b45769
--- /dev/null
+++ b/migrations/init_0.sql
@@ -0,0 +1,32 @@
+CREATE TABLE yt_queries (
+  id TEXT PRIMARY KEY,
+  text TEXT NOT NULL,
+  retrieved_at TEXT NOT NULL
+);
+CREATE TABLE yt_videos (
+  id TEXT PRIMARY KEY,
+  title TEXT NOT NULL,
+  description TEXT NOT NULL,
+  published_at TEXT NOT NULL,
+  duration TEXT NOT NULL,
+  definition TEXT NOT NULL
+);
+CREATE TABLE yt_query_results (
+  query_id TEXT NOT NULL,
+  video_id TEXT NOT NULL,
+  PRIMARY KEY (query_id, video_id),
+  FOREIGN KEY (query_id) REFERENCES yt_queries(id),
+  FOREIGN KEY (video_id) REFERENCES yt_videos(id)
+);
+CREATE TABLE quota_costs (
+  id TEXT PRIMARY KEY,
+  timestamp TEXT NOT NULL,
+  cost INT NOT NULL
+);
+CREATE TABLE files (
+  rel_path TEXT PRIMARY KEY,
+  yt_id TEXT NOT NULL DEFAULT "",
+  flags INTEGER NOT NULL DEFAULT 0,
+  FOREIGN KEY (yt_id) REFERENCES yt_videos(id)
+);
+
diff --git a/ytplom/misc.py b/ytplom/misc.py
index 9c893bd..9e46c82 100644
--- a/ytplom/misc.py
+++ b/ytplom/misc.py
@@ -57,8 +57,7 @@ PATH_TEMP = PathStr(path_join(PATH_CACHE, 'temp'))
 PATH_THUMBNAILS = PathStr(path_join(PATH_CACHE, 'thumbnails'))
 
 # template paths
-NAME_TEMPLATES_DIR = 'templates'
-PATH_TEMPLATES = PathStr(path_join(PATH_APP_DATA, NAME_TEMPLATES_DIR))
+PATH_TEMPLATES = PathStr(path_join(PATH_APP_DATA, 'templates'))
 NAME_TEMPLATE_QUERIES = PathStr('queries.tmpl')
 NAME_TEMPLATE_RESULTS = PathStr('results.tmpl')
 NAME_TEMPLATE_VIDEOS = PathStr('videos.tmpl')
@@ -83,47 +82,16 @@ QUOTA_COST_YOUTUBE_DETAILS = QuotaCost(1)
 # local expectations
 TIMESTAMP_FMT = '%Y-%m-%d %H:%M:%S.%f'
 LEGAL_EXTENSIONS = {'webm', 'mp4', 'mkv'}
+VIDEO_FLAGS: dict[FlagName, FlagsInt] = {
+  FlagName('delete'): FlagsInt(1 << 62)
+}
 
 # tables to create database with
 EXPECTED_DB_VERSION = 0
 SQL_DB_VERSION = SqlText('PRAGMA user_version')
-SCRIPT_INIT_DB = '''
-CREATE TABLE yt_queries (
-  id TEXT PRIMARY KEY,
-  text TEXT NOT NULL,
-  retrieved_at TEXT NOT NULL
-);
-CREATE TABLE yt_videos (
-  id TEXT PRIMARY KEY,
-  title TEXT NOT NULL,
-  description TEXT NOT NULL,
-  published_at TEXT NOT NULL,
-  duration TEXT NOT NULL,
-  definition TEXT NOT NULL
-);
-CREATE TABLE yt_query_results (
-  query_id TEXT NOT NULL,
-  video_id TEXT NOT NULL,
-  PRIMARY KEY (query_id, video_id),
-  FOREIGN KEY (query_id) REFERENCES yt_queries(id),
-  FOREIGN KEY (video_id) REFERENCES yt_videos(id)
-);
-CREATE TABLE quota_costs (
-  id TEXT PRIMARY KEY,
-  timestamp TEXT NOT NULL,
-  cost INT NOT NULL
-);
-CREATE TABLE files (
-  rel_path TEXT PRIMARY KEY,
-  yt_id TEXT NOT NULL DEFAULT "",
-  flags INTEGER NOT NULL DEFAULT 0,
-  FOREIGN KEY (yt_id) REFERENCES yt_videos(id)
-);
-'''
-
-VIDEO_FLAGS: dict[FlagName, FlagsInt] = {
-  FlagName('delete'): FlagsInt(1 << 62)
-}
+PATH_MIGRATIONS = PathStr(path_join(PATH_APP_DATA, 'migrations'))
+PATH_DB_SCHEMA = PathStr(path_join(PATH_MIGRATIONS,
+                                   f'init_{EXPECTED_DB_VERSION}.sql'))
 
 
 class NotFoundException(Exception):
@@ -160,7 +128,8 @@ class DatabaseConnection:
                         f'cannot find {path_db_dir} as directory to put DB '
                         'into, did you run install.py?')
             with sql_connect(self._path) as conn:
-                conn.executescript(SCRIPT_INIT_DB)
+                with open(PATH_DB_SCHEMA, 'r', encoding='utf8') as f:
+                    conn.executescript(f.read())
                 conn.execute(f'{SQL_DB_VERSION} = {EXPECTED_DB_VERSION}')
         with sql_connect(self._path) as conn:
             db_version = list(conn.execute(SQL_DB_VERSION))[0][0]