Update the formatting for SQL files, add changes to the channel repository

app/src/domain/entity.ts

@@ -2,11 +2,11 @@ export type EntityId = number|string;
 
 export class Entity<T> {
   protected readonly id: EntityId;
-  protected model: T;
+  protected _model: T;
 
   public constructor(id: EntityId, model: T) {
     this.id = id;
-    this.model = model;
+    this._model = model;
   }
 
   public getId(): EntityId {
@@ -14,6 +14,10 @@ export class Entity<T> {
   }
 
   public getModel(): T {
-    return this.model;
+    return this._model;
+  }
+
+  public get model(): T {
+    return this.getModel();
   }
 }

app/src/domain/repository/channel-repository.ts

@@ -0,0 +1,39 @@
+import { type EntityId, Entity } from '@slovo/domain/entity';
+import { BaseRepository } from '@slovo/domain/repository';
+import { type Channel } from '@slovo/models/channel';
+
+export class ChannelRepository extends BaseRepository<Channel> {
+  public async get(id: EntityId): Promise<Entity<Channel>> {
+    const conn = await this.pool.getConnection();
+    const query = `SELECT * FROM Channels WHERE id = ?`;
+    const rows = await conn.query(query, [ id ]);
+
+    if (!rows.length) {
+      throw Error("Unable to find Channel.");
+    }
+
+    return new Entity(id, { 
+      name: rows[0].name,
+      description: rows[0].description,
+      link: new URL(rows[0].link),
+      language: rows[0].language,
+      copyright: rows[0].copyright,
+      explicit: rows[0].explicit as boolean,
+      category: rows[0].category,
+    } as Channel);
+  }
+
+  public async save(channel: Entity<Channel>): Promise<Entity<Channel>> {
+
+    return channel;
+  }
+
+  public async update(channel: Entity<Channel>): Promise<Entity<Channel>> {
+
+    return channel;
+  }
+
+  public async delete(channel: Entity<Channel>): Promise<boolean> {
+    return true;
+  }
+}

app/src/domain/repository/user-repository.ts

@@ -68,9 +68,9 @@ export class UserRepository extends BaseRepository<User> {
     
     const query = `UPDATE user SET name = ?, email = ?, password = ? WHERE id = ?`;
     const results = await conn.query(query, [
-      user.getModel().name,
-      user.getModel().email,
-      user.getModel().password,
+      user.model.name,
+      user.model.email,
+      user.model.password,
       user.getId()
     ]);
 
@@ -82,9 +82,8 @@ export class UserRepository extends BaseRepository<User> {
     return user;
   }
 
+  /// Don't delete users
   public async delete(user: Entity<User>): Promise<boolean> {
-    const conn: PoolConnection = await this.pool.getConnection();
-
-    await conn.release();
+    return true;
   }
 }

sql/04-episodes.sql

@@ -2,8 +2,8 @@ CREATE TABLE episodes (
     id          INT(11) UNSIGNED NOT NULL AUTO_INCREMENT,
     title       VARCHAR(255) NOT NULL,
     link        VARCHAR(255) NOT NULL,
-    duration VARCHAR(127) NOT NULL,
-    length INT(11) UNSIGNED NOT NULL,
+    duration    VARCHAR(127) NOT NULL COMMENT "HH:MM:SS representation",
+    length      INT(11) UNSIGNED NOT NULL COMMENT "Length in seconds",
     description TEXT NOT NULL,
 
     explicit BOOLEAN NOT NULL DEFAULT true,