DDL operation

.env.test

@@ -0,0 +1,7 @@
+NODE_ENV=test
+JWT_SECRET=supersecretkey
+JWT_EXPIRES_IN=1h
+DB_USERNAME=postgres
+DB_PASSWORD=12345678
+DB_NAME=database_services_test
+DB_HOST=localhost

.github/workflows/test.yml

@@ -0,0 +1,51 @@
+name: Run Unit Tests
+
+on:
+  push:
+    branches: [ main ]
+  pull_request:
+
+jobs:
+  test:
+    runs-on: ubuntu-latest
+
+    services:
+      postgres:
+        image: postgres:13
+        env:
+          POSTGRES_USER: postgres
+          POSTGRES_PASSWORD: 12345678
+          POSTGRES_DB: database_services_test
+        ports:
+          - 5432:5432
+        options: >-
+          --health-cmd pg_isready
+          --health-interval 10s
+          --health-timeout 5s
+          --health-retries 5
+    env:
+      NODE_ENV: test
+      DB_USERNAME: postgres
+      DB_PASSWORD: 12345678
+      DB_NAME: database_services_test
+      DB_HOST: localhost
+      JWT_SECRET: supersecretkey
+      JWT_EXPIRES_IN: 1h
+
+    steps:
+      - name: Checkout code
+        uses: actions/checkout@v3
+
+      - name: Set up Node.js
+        uses: actions/setup-node@v3
+        with:
+          node-version: '20'
+
+      - name: Install dependencies
+        run: yarn install
+
+      - name: Run migrations
+        run: yarn migrate
+
+      - name: Run tests
+        run: yarn test

.sequelizerc

@@ -1,8 +1,9 @@
-const path = require('path');
+const path = require("path");
 require('dotenv').config();
+require("ts-node/register");
 
 module.exports = {
-  "config": path.resolve(__dirname, "src/config/sequelize.config.js"),
+  config: path.resolve(__dirname, "src/config/sequelize.config.js"),
   "models-path": path.resolve(__dirname, "src/models"),
   "seeders-path": path.resolve(__dirname, "src/seeders"),
   "migrations-path": path.resolve(__dirname, "src/migrations"),

eslint.config.mjs

@@ -1,22 +1,29 @@
 import js from "@eslint/js";
 import tseslint from "@typescript-eslint/eslint-plugin";
 import tsparser from "@typescript-eslint/parser";
+import prettier from "eslint-plugin-prettier"; 
 
 export default [
   js.configs.recommended,
   {
+    files: ["src/**/*.ts"],
+    ignores: ["dist/**", "node_modules/**"],
     languageOptions: {
       parser: tsparser,
     },
     plugins: {
       "@typescript-eslint": tseslint,
+      prettier,
     },
     rules: {
+      "prettier/prettier": "error", 
+      "@typescript-eslint/no-explicit-any": "off",
       "@typescript-eslint/no-var-requires": "off",
+      "no-undef": "off",
     },
   },
   {
-    files: ["src/migrations/*.js", "src/config/sequelize.config.js"],
+    files: ["src/config/sequelize.config.js"],
     languageOptions: {
       sourceType: "commonjs",
     },

jest.config.js

@@ -0,0 +1,9 @@
+require('dotenv').config({ path: '.env.test' });
+
+/** @type {import('ts-jest').JestConfigWithTsJest} **/
+module.exports = {
+  testEnvironment: "node",
+  transform: {
+    "^.+\.tsx?$": ["ts-jest",{}],
+  },
+};

package.json

@@ -7,11 +7,11 @@
     "dev": "nodemon --exec ts-node src/index.ts",
     "build": "tsc",
     "start": "node dist/index.js",
-    "migrate": "sequelize-cli db:migrate --config=src/config/sequelize.config.js",
+    "migrate": "sequelize-cli db:migrate --config src/config/sequelize.config.js",
     "seed": "sequelize-cli db:seed:all",
     "prepare": "husky install",
     "lint": "eslint src",
-    "test": "echo \"No test specified\" && exit 0"
+    "test": "jest"
   },
   "dependencies": {
     "@tsconfig/node16": "^16.1.3",
@@ -20,7 +20,7 @@
     "express": "^4.21.2",
     "jsonwebtoken": "8.5.1",
     "nanoid": "3",
-    "pg": "^8.13.1",
+    "pg": "^8.13.3",
     "pg-hstore": "^2.3.4",
     "sequelize": "^6.37.5",
     "uuid": "^11.0.5"
@@ -29,18 +29,21 @@
     "@eslint/js": "^9.20.0",
     "@types/bcryptjs": "^2.4.6",
     "@types/express": "^5.0.0",
+    "@types/jest": "^29.5.14",
     "@types/jsonwebtoken": "^9.0.8",
-    "@types/node": "^22.13.1",
+    "@types/node": "^22.13.2",
     "@types/sequelize": "^4.28.20",
     "eslint": "^9.20.1",
     "eslint-config-prettier": "^10.0.1",
     "eslint-plugin-prettier": "^5.2.3",
     "globals": "^15.14.0",
     "husky": "^9.1.7",
+    "jest": "^29.7.0",
     "lint-staged": "^15.4.3",
     "nodemon": "^3.1.9",
     "prettier": "^3.5.0",
     "sequelize-cli": "^6.6.2",
+    "ts-jest": "^29.2.6",
     "ts-node": "^10.9.2",
     "typescript": "^5.7.3",
     "typescript-eslint": "^8.24.0"

src/controllers/ddl-controller.ts

@@ -0,0 +1,23 @@
+import { Request, Response } from 'express';
+import { sequelize } from '../config/database';
+import { successResponse, errorResponse } from '../utils/response';
+import { Operations } from '../types/ddl';
+import { DDLExecutor } from '../operations/migrate';
+
+export const migrate = async (req: Request, res: Response) => {
+  const { operations }: { operations: Operations[] } = req.body;
+  if (!operations || !Array.isArray(operations))
+    return errorResponse(res, 'Invalid payload structure', 400);
+
+  const transaction = await sequelize.transaction();
+
+  try {
+    await DDLExecutor.execute(operations, transaction);
+
+    await transaction.commit();
+    return successResponse(res, {}, 'DDL operations completed successfully');
+  } catch (error: any) {
+    await transaction.rollback();
+    return errorResponse(res, error.message, 500);
+  }
+};

src/controllers/user-controller.ts

@@ -14,15 +14,15 @@ export const registerUser = async (req: Request, res: Response) => {
       return errorResponse(res, 'Name, email, and password are required', 400);
     }
 
-    const existingUser = await UserRepository.findByEmail(email);
+    const existingUser = await UserRepository.findOne({ email });
     if (existingUser) {
       return errorResponse(res, 'Email is already registered', 400);
     }
 
     const hashedPassword = await hashPassword(password);
     const apiKey = await generateApiKey();
 
-    const newUser = await UserRepository.createUser({
+    const newUser = await UserRepository.insert({
       name,
       email,
       password: hashedPassword,
@@ -44,7 +44,7 @@ export const loginUser = async (req: Request, res: Response) => {
   try {
     const { email, password } = req.body;
 
-    const user = await UserRepository.findByEmail(email);
+    const user = await UserRepository.findOne({ email });
     if (!user) {
       return errorResponse(res, 'Unauthorized', 401);
     }
@@ -79,7 +79,7 @@ export const getUserDetails = async (req: Request, res: Response) => {
     }
 
     const decoded: any = jwt.verify(token, ENV.JWT_SECRET);
-    const user = await UserRepository.findById(decoded.userId);
+    const user = await UserRepository.findOne({ id: decoded.userId });
 
     if (!user) {
       return errorResponse(res, 'Unauthorized', 401);

src/index.ts

@@ -2,6 +2,17 @@ import express, { Request, Response } from 'express';
 import dotenv from 'dotenv';
 import userRoutes from './routes/user-routes';
 import authRoutes from './routes/auth-routes';
+import ddlRoutes from './routes/ddl-routes';
+import { sequelize } from './config/database';
+
+sequelize
+  .sync({ force: true })
+  .then(async () => {
+    console.log('Database synchronized successfully.');
+  })
+  .catch((err) => {
+    console.error('Failed to synchronize database:', err);
+  });
 
 dotenv.config();
 
@@ -14,6 +25,7 @@ const apiRouter = express.Router();
 
 apiRouter.use('/auth', authRoutes);
 apiRouter.use('/users', userRoutes);
+apiRouter.use('/migrate', ddlRoutes);
 
 app.use('/api', apiRouter);
 

src/middlewares/auth-middleware.ts

@@ -18,6 +18,7 @@ export const authMiddleware = (
     (req as any).user = decoded;
     next();
   } catch (error) {
+    console.error('Error:', error);
     return errorResponse(res, 'Unauthorized', 401);
   }
 };

src/migrations/20250206065327-create-user.ts

@@ -0,0 +1,51 @@
+import { QueryInterface, DataTypes, Sequelize } from 'sequelize';
+
+/** @type {import('sequelize-cli').Migration} */
+export default {
+  async up(queryInterface: QueryInterface, sequelize: Sequelize) {
+    await queryInterface.sequelize.query(
+      'CREATE EXTENSION IF NOT EXISTS "uuid-ossp";',
+    );
+
+    await queryInterface.createTable('users', {
+      id: {
+        allowNull: false,
+        primaryKey: true,
+        type: DataTypes.UUID,
+        defaultValue: sequelize.literal('uuid_generate_v4()'),
+      },
+      name: {
+        type: DataTypes.STRING,
+        allowNull: false,
+      },
+      email: {
+        type: DataTypes.STRING,
+        allowNull: false,
+        unique: true,
+      },
+      password: {
+        type: DataTypes.STRING,
+        allowNull: false,
+      },
+      apikey: {
+        type: DataTypes.STRING,
+        allowNull: false,
+        unique: true,
+      },
+      created_at: {
+        allowNull: false,
+        type: DataTypes.DATE,
+        defaultValue: sequelize.literal('CURRENT_TIMESTAMP'),
+      },
+      updated_at: {
+        allowNull: false,
+        type: DataTypes.DATE,
+        defaultValue: sequelize.literal('CURRENT_TIMESTAMP'),
+      },
+    });
+  },
+
+  async down(queryInterface: QueryInterface) {
+    await queryInterface.dropTable('users');
+  },
+};

src/migrations/20250226042309-create-metadata-table.ts

@@ -0,0 +1,34 @@
+import { QueryInterface, DataTypes, Sequelize } from 'sequelize';
+
+/** @type {import('sequelize-cli').Migration} */
+export default {
+  async up(queryInterface: QueryInterface, sequelize: Sequelize) {
+    await queryInterface.createTable('metadata_table', {
+      id: {
+        primaryKey: true,
+        type: DataTypes.UUID,
+        defaultValue: sequelize.literal('uuid_generate_v4()'),
+        allowNull: false,
+      },
+      table_name: {
+        type: DataTypes.STRING,
+        unique: true,
+        allowNull: false,
+      },
+      created_at: {
+        type: DataTypes.DATE,
+        defaultValue: sequelize.literal('CURRENT_TIMESTAMP'),
+        allowNull: false,
+      },
+      updated_at: {
+        type: DataTypes.DATE,
+        defaultValue: sequelize.literal('CURRENT_TIMESTAMP'),
+        allowNull: false,
+      },
+    });
+  },
+
+  async down(queryInterface: QueryInterface) {
+    await queryInterface.dropTable('metadata_table');
+  },
+};