chore: migrations and config from environment file

.env.example

@@ -0,0 +1,2 @@
+NODE_ENV=development|test|production
+DATABASE_DSN=postgres://user:[email protected]:5432/dbname

.sequelizerc

@@ -0,0 +1,7 @@
+const path = require('path');
+module.exports = {
+  'config': path.resolve('src', 'config', 'config.js'),
+  'models-path': path.resolve('src', 'config', 'models'),
+  'seeders-path': path.resolve('src', 'config', 'seeders'),
+  'migrations-path': path.resolve('src', 'config', 'migrations'),
+};

src/config/app.config.ts

@@ -0,0 +1,6 @@
+export default () => ({
+  pg: {
+    dsn: process.env.DATABASE_DSN,
+    dialect: process.env.DATABASE_DSN.split(':')[0],
+  },
+});

src/config/config.js

@@ -0,0 +1,16 @@
+module.exports = {
+  development: {
+    username: 'postgres',
+    password: '123456',
+    database: 'posterr_development',
+    host: '127.0.0.1',
+    dialect: 'postgres',
+  },
+  production: {
+    username: 'postgres',
+    password: '123456',
+    database: 'posterr',
+    host: '127.0.0.1',
+    dialect: 'postgres',
+  },
+};

src/config/migrations/20220724224210-create_users_table.js

@@ -0,0 +1,35 @@
+'use strict';
+
+module.exports = {
+  async up(queryInterface, Sequelize) {
+    /**
+     * Add altering commands here.
+     *
+     * Example:
+     * await queryInterface.createTable('users', { id: Sequelize.INTEGER });
+     */
+    return queryInterface.createTable('users', {
+      id: {
+        type: Sequelize.DataTypes.UUID,
+        primaryKey: true,
+        allowNull: false,
+      },
+      username: {
+        type: Sequelize.DataTypes.STRING(255),
+      },
+      created_at: {
+        type: Sequelize.DataTypes.DATE,
+      },
+    });
+  },
+
+  async down(queryInterface, Sequelize) {
+    /**
+     * Add reverting commands here.
+     *
+     * Example:
+     * await queryInterface.dropTable('users');
+     */
+    await queryInterface.dropTable('users');
+  },
+};

src/config/migrations/20220724225213-create_post_table.js

@@ -0,0 +1,63 @@
+'use strict';
+
+module.exports = {
+  async up(queryInterface, Sequelize) {
+    /**
+     * Add altering commands here.
+     *
+     * Example:
+     * await queryInterface.createTable('users', { id: Sequelize.INTEGER });
+     */
+    return queryInterface.createTable('posts', {
+      id: {
+        type: Sequelize.DataTypes.UUID,
+        primaryKey: true,
+        allowNull: false,
+      },
+      content: {
+        type: Sequelize.DataTypes.TEXT,
+      },
+      user_id: {
+        type: Sequelize.DataTypes.UUID,
+        allowNull: false,
+      },
+      created_at: {
+        type: Sequelize.DataTypes.DATE,
+      },
+      is_quote: {
+        type: Sequelize.DataTypes.BOOLEAN,
+        allowNull: false,
+      },
+      is_repost: {
+        type: Sequelize.DataTypes.BOOLEAN,
+        allowNull: false,
+      },
+      original_post_id: {
+        type: Sequelize.DataTypes.UUID,
+        allowNull: true,
+      },
+      original_post_content: {
+        type: Sequelize.DataTypes.TEXT,
+        allowNull: true,
+      },
+      original_post_user_id: {
+        type: Sequelize.DataTypes.UUID,
+        allowNull: true,
+      },
+      original_post_screen_name: {
+        type: Sequelize.DataTypes.STRING(255),
+        allowNull: true,
+      },
+    });
+  },
+
+  async down(queryInterface, Sequelize) {
+    /**
+     * Add reverting commands here.
+     *
+     * Example:
+     * await queryInterface.dropTable('users');
+     */
+    await queryInterface.dropTable('posts');
+  },
+};

src/config/migrations/20220725002723-create_user_fk_in_post_table.js

@@ -0,0 +1,32 @@
+'use strict';
+
+module.exports = {
+  async up(queryInterface, Sequelize) {
+    /**
+     * Add altering commands here.
+     *
+     * Example:
+     * await queryInterface.createTable('users', { id: Sequelize.INTEGER });
+     *
+     */
+    await queryInterface.addConstraint('posts', {
+      fields: ['user_id'],
+      type: 'foreign key',
+      name: 'fk_user_id_post',
+      references: {
+        table: 'users',
+        field: 'id',
+      },
+    });
+  },
+
+  async down(queryInterface, Sequelize) {
+    /**
+     * Add reverting commands here.
+     *
+     * Example:
+     * await queryInterface.dropTable('users');
+     */
+    await queryInterface.removeConstraint('posts', 'fk_user_id_post');
+  },
+};

src/config/migrations/20220725003427-create_unique_index_in_users_table.js

@@ -0,0 +1,27 @@
+'use strict';
+
+module.exports = {
+  async up(queryInterface, Sequelize) {
+    /**
+     * Add altering commands here.
+     *
+     * Example:
+     * await queryInterface.createTable('users', { id: Sequelize.INTEGER });
+     *
+     */
+    await queryInterface.addIndex('users', ['username'], {
+      name: 'idx_unique_username',
+      unique: true,
+    });
+  },
+
+  async down(queryInterface, Sequelize) {
+    /**
+     * Add reverting commands here.
+     *
+     * Example:
+     * await queryInterface.dropTable('users');
+     */
+    await queryInterface.removeIndex('users', 'idx_unique_username');
+  },
+};

src/config/migrations/20220725004430-create_indexes_in_posts_table.js

@@ -0,0 +1,33 @@
+'use strict';
+
+module.exports = {
+  async up(queryInterface, Sequelize) {
+    /**
+     * Add altering commands here.
+     *
+     * Example:
+     * await queryInterface.createTable('users', { id: Sequelize.INTEGER });
+     */
+    await queryInterface.addIndex('posts', ['user_id'], {
+      name: 'idx_user_id',
+    });
+    await queryInterface.addIndex('posts', ['created_at'], {
+      name: 'idx_created_at',
+    });
+    await queryInterface.addIndex('posts', ['user_id', 'created_at'], {
+      name: 'idx_user_posts',
+    });
+  },
+
+  async down(queryInterface, Sequelize) {
+    /**
+     * Add reverting commands here.
+     *
+     * Example:
+     * await queryInterface.dropTable('users');
+     */
+    await queryInterface.removeIndex('posts', 'idx_user_id');
+    await queryInterface.removeIndex('posts', 'idx_created_at');
+    await queryInterface.removeIndex('posts', 'idx_user_posts');
+  },
+};

src/config/migrations/20220725010419-create_fk_original_post_id_posts_table.js

@@ -0,0 +1,32 @@
+'use strict';
+
+module.exports = {
+  async up(queryInterface, Sequelize) {
+    /**
+     * Add altering commands here.
+     *
+     * Example:
+     * await queryInterface.createTable('users', { id: Sequelize.INTEGER });
+     *
+     */
+    await queryInterface.addConstraint('posts', {
+      fields: ['original_post_id'],
+      type: 'foreign key',
+      name: 'fk_original_post_id_post',
+      references: {
+        table: 'posts',
+        field: 'id',
+      },
+    });
+  },
+
+  async down(queryInterface, Sequelize) {
+    /**
+     * Add reverting commands here.
+     *
+     * Example:
+     * await queryInterface.dropTable('users');
+     */
+    await queryInterface.removeConstraint('posts', 'fk_original_post_id_post');
+  },
+};

src/config/models/index.ts

@@ -0,0 +1,2 @@
+export * from '#core/posts/infra/db/repository/sequelize/post-model';
+export * from '#core/users/infra/db/repository/sequelize/user-model';

src/config/seeders/20220725010659-created_base_users.js

@@ -0,0 +1,46 @@
+'use strict';
+const users = [
+  {
+    id: '4cfe67a9-defc-42b9-8410-cb5086bec2f5',
+    username: 'alucard',
+    created_at: new Date(),
+  },
+  {
+    id: 'b8903f77-5d16-4176-890f-f597594ff952',
+    username: 'anderson',
+    created_at: new Date(),
+  },
+  {
+    id: '75135a97-46be-405f-8948-0821290ca83e',
+    username: 'seras_victoria',
+    created_at: new Date(),
+  },
+];
+module.exports = {
+  async up(queryInterface, Sequelize) {
+    /**
+     * Add seed commands here.
+     *
+     * Example:
+     * await queryInterface.bulkInsert('People', [{
+     *   name: 'John Doe',
+     *   isBetaMember: false
+     * }], {});
+     */
+    await queryInterface.bulkInsert('users', users, {});
+  },
+
+  async down(queryInterface, Sequelize) {
+    /**
+     * Add commands to revert seed here.
+     *
+     * Example:
+     * await queryInterface.bulkDelete('People', null, {});
+     */
+    await queryInterface.bulkDelete(
+      'users',
+      users.map((u) => u.id),
+      {},
+    );
+  },
+};

src/database.module.ts

@@ -1,7 +1,15 @@
 import { Module } from '@nestjs/common';
 import { databaseProviders } from './database.providers';
+import { ConfigModule } from '@nestjs/config';
+import appConfig from './config/app.config';
 
 @Module({
+  imports: [
+    ConfigModule.forRoot({
+      load: [appConfig],
+      isGlobal: true,
+    }),
+  ],
   providers: [...databaseProviders],
   exports: [...databaseProviders],
 })

src/database.providers.ts

@@ -1,21 +1,18 @@
 import { Sequelize } from 'sequelize-typescript';
 import { PostModel } from '#core/posts';
 import { UserModel } from '#core/users';
+import { ConfigService } from '@nestjs/config';
 
 export const databaseProviders = [
   {
     provide: 'SEQUELIZE',
-    useFactory: async () => {
-      const sequelize = new Sequelize({
-        dialect: 'postgres',
-        host: 'localhost',
-        port: 5432,
-        username: 'postgres',
-        password: '123456',
-        database: 'posterr',
+    inject: [ConfigService],
+    useFactory: async (configService: ConfigService) => {
+      const sequelize = new Sequelize(configService.get('pg.dsn'), {
+        dialect: configService.get('pg.dialect'),
       });
       sequelize.addModels([PostModel, UserModel]);
-      await sequelize.sync();
+      // await sequelize.sync();
       return sequelize;
     },
   },