4 files changed, 38 insertions, 0 deletions
diff --git a/gn3/auth/__init__.py b/gn3/auth/__init__.py
new file mode 100644
index 0000000..699d9e2
--- /dev/null
+++ b/gn3/auth/__init__.py
@@ -0,0 +1,3 @@
+"""Top-Level `Auth` module"""
+from . import authorisation
+from . import authentication
diff --git a/gn3/auth/authentication/__init__.py b/gn3/auth/authentication/__init__.py
new file mode 100644
index 0000000..8ad4cfd
--- /dev/null
+++ b/gn3/auth/authentication/__init__.py
@@ -0,0 +1 @@
+"""The authentication module"""
diff --git a/gn3/auth/authorisation/__init__.py b/gn3/auth/authorisation/__init__.py
new file mode 100644
index 0000000..cc370e2
--- /dev/null
+++ b/gn3/auth/authorisation/__init__.py
@@ -0,0 +1 @@
+"""The authorisation module."""
diff --git a/gn3/migrations.py b/gn3/migrations.py
new file mode 100644
index 0000000..7f8d694
--- /dev/null
+++ b/gn3/migrations.py
@@ -0,0 +1,33 @@
+"""Run the migrations in the app, rather than with yoyo CLI."""
+from pathlib import Path
+from typing import Union
+
+from yoyo.backends import DatabaseBackend
+from yoyo import read_migrations
+from yoyo.migrations import Migration, MigrationList
+
+class MigrationNotFound(Exception):
+    """Raised if a migration is not found at the given path."""
+    def __init__(self, migration_path: Path):
+        """Initialise the exception."""
+        super().__init__(f"Could not find migration '{migration_path}'")
+
+def apply_migrations(backend: DatabaseBackend, migrations: MigrationList):
+    "Apply the provided migrations."
+    with backend.lock():
+        backend.apply_migrations(backend.to_apply(migrations))
+
+def rollback_migrations(backend: DatabaseBackend, migrations: MigrationList):
+    "Rollback the provided migrations."
+    with backend.lock():
+        backend.rollback_migrations(backend.to_rollback(migrations))
+
+def get_migration(migration_path: Union[Path, str]) -> Migration:
+    """Retrieve a migration at thi given `migration_path`."""
+    migration_path = Path(migration_path)
+    if migration_path.exists():
+        for migration in read_migrations(str(migration_path.parent)):
+            if Path(migration.path) == migration_path:
+                return migration
+
+    raise MigrationNotFound(migration_path)