Bump version

.drone.yml

@@ -22,7 +22,7 @@ steps:
         from_secret: docs_deploy_key
       port: 22
       source: extollo_api_documentation.tar.gz
-      target: /var/nfs/general/static/sites/extollo
+      target: /var/nfs/storage/static/sites/extollo
     when:
       event: promote
       target: docs
@@ -38,7 +38,7 @@ steps:
         from_secret: docs_deploy_key
       port: 22
       script:
-        - cd /var/nfs/general/static/sites/extollo
+        - cd /var/nfs/storage/static/sites/extollo
         - rm -rf docs
         - tar xzf extollo_api_documentation.tar.gz
         - rm -rf extollo_api_documentation.tar.gz

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@extollo/lib",
-  "version": "0.5.2",
+  "version": "0.5.7",
   "description": "The framework library that lifts up your code.",
   "main": "lib/index.js",
   "types": "lib/index.d.ts",

src/cli/Directive.ts

@@ -172,6 +172,7 @@ export abstract class Directive extends AppClass {
             } catch (e: unknown) {
                 if ( e instanceof Error ) {
                     this.nativeOutput(e.message)
+                    this.error(e)
                 }
 
                 if ( e instanceof OptionValidationError ) {

src/cli/index.ts

@@ -11,3 +11,5 @@ export * from './directive/options/PositionalOption'
 export * from './directive/ShellDirective'
 export * from './directive/TemplateDirective'
 export * from './directive/UsageDirective'
+
+export * from './decorators'

src/http/response/api.ts

@@ -1,10 +1,10 @@
 /**
  * Base type for an API response format.
  */
-export interface APIResponse {
+export interface APIResponse<T> {
     success: boolean,
     message?: string,
-    data?: any,
+    data?: T,
     error?: {
         name: string,
         message: string,
@@ -17,7 +17,7 @@ export interface APIResponse {
  * @param {string} displayMessage
  * @return APIResponse
  */
-export function message(displayMessage: string): APIResponse {
+export function message(displayMessage: string): APIResponse<void> {
     return {
         success: true,
         message: displayMessage,
@@ -29,7 +29,7 @@ export function message(displayMessage: string): APIResponse {
  * @param record
  * @return APIResponse
  */
-export function one(record: unknown): APIResponse {
+export function one<T>(record: T): APIResponse<T> {
     return {
         success: true,
         data: record,
@@ -41,7 +41,7 @@ export function one(record: unknown): APIResponse {
  * @param {array} records
  * @return APIResponse
  */
-export function many(records: any[]): APIResponse {
+export function many<T>(records: T[]): APIResponse<{records: T[], total: number}> {
     return {
         success: true,
         data: {
@@ -56,7 +56,7 @@ export function many(records: any[]): APIResponse {
  * @return APIResponse
  * @param thrownError
  */
-export function error(thrownError: string | Error): APIResponse {
+export function error(thrownError: string | Error): APIResponse<void> {
     if ( typeof thrownError === 'string' ) {
         return {
             success: false,

src/migrations/2021-07-23T19:44:00.000Z_CreateSessionsTable.migration.ts

@@ -0,0 +1,39 @@
+import {Inject, Injectable} from '../di'
+import {ConstraintType, DatabaseService, FieldType, Migration, Schema} from '../orm'
+
+/**
+ * Migration that creates the sessions table used by the ORMSession backend.
+ */
+@Injectable()
+export default class CreateSessionsTableMigration extends Migration {
+    @Inject()
+    protected readonly db!: DatabaseService
+
+    async up(): Promise<void> {
+        const schema: Schema = this.db.get().schema()
+        const table = await schema.table('sessions')
+
+        table.primaryKey('session_uuid', FieldType.varchar)
+            .required()
+
+        table.column('session_data')
+            .type(FieldType.json)
+            .required()
+            .default('{}')
+
+        table.constraint('session_uuid_ck')
+            .type(ConstraintType.Check)
+            .expression('LENGTH(session_uuid) > 0')
+
+        await schema.commit(table)
+    }
+
+    async down(): Promise<void> {
+        const schema: Schema = this.db.get().schema()
+        const table = await schema.table('sessions')
+
+        table.dropIfExists()
+
+        await schema.commit(table)
+    }
+}

src/migrations/2021-07-24T10:31:00.000Z_CreateUsersTable.migration.ts

@@ -0,0 +1,47 @@
+import {Inject, Injectable} from '../di'
+import {DatabaseService, FieldType, Migration, Schema} from '../orm'
+
+/**
+ * Migration that creates the users table used by @extollo/lib.auth.
+ */
+@Injectable()
+export default class CreateUsersTableMigration extends Migration {
+    @Inject()
+    protected readonly db!: DatabaseService
+
+    async up(): Promise<void> {
+        const schema: Schema = this.db.get().schema()
+        const table = await schema.table('users')
+
+        table.primaryKey('user_id')
+            .required()
+
+        table.column('first_name')
+            .type(FieldType.varchar)
+            .nullable()
+
+        table.column('last_name')
+            .type(FieldType.varchar)
+            .nullable()
+
+        table.column('password_hash')
+            .type(FieldType.text)
+            .nullable()
+
+        table.column('username')
+            .type(FieldType.varchar)
+            .required()
+            .unique()
+
+        await schema.commit(table)
+    }
+
+    async down(): Promise<void> {
+        const schema: Schema = this.db.get().schema()
+        const table = await schema.table('users')
+
+        table.dropIfExists()
+
+        await schema.commit(table)
+    }
+}

src/orm/dialect/PostgreSQLDialect.ts

@@ -230,7 +230,7 @@ export class PostgreSQLDialect extends SQLDialect {
             const table: string = tableString.split('.').map(x => `"${x}"`)
                 .join('.')
             queryLines.push('INSERT INTO ' + (typeof source === 'string' ? table : `${table} AS "${source.alias}"`)
-                + (columns.length ? ` (${columns.join(', ')})` : ''))
+                + (columns.length ? ` (${columns.map(x => `"${x}"`).join(', ')})` : ''))
         }
 
         if ( Array.isArray(data) && !data.length ) {