new changes

Hadiqaa · Oct 4, 2023 · 3848c1a · 3848c1a
1 parent 6e89ed0
commit 3848c1a
Show file tree

Hide file tree

Showing 32 changed files with 821 additions and 1 deletion.
diff --git a/.env.example b/.env.example
@@ -0,0 +1,9 @@
+# .env
+
+NODE_ENV=
+DB_HOST=
+DB_DIALECT=
+DB_USER=
+DB_PASSWORD=
+DB_PORT=
+DB_MIGRATIONS_PATH=
diff --git a/.gitignore b/.gitignore
@@ -1 +1,3 @@
-node_modules 
+node_modules 
+.env
+package-lock.json
diff --git a/config/config.json b/config/config.json
@@ -0,0 +1,26 @@
+{
+    "development": {
+      "host": "localhost",
+      "dialect": "postgres",
+      "user":"hadiqasumbalarshad",
+      "password" :"11223344",
+      "port":"5432",
+      "migrationsPath": "./migrations"
+
+    },
+    "test": {
+      "host": "localhost",
+      "dialect": "postgres",
+      "user":"hadiqasumbalarshad",
+      "password" :"11223344",
+      "port":"5432"
+    },
+    "production": {
+      "host": "localhost",
+      "dialect": "postgres",
+      "user":"hadiqasumbalarshad",
+      "password" :"11223344",
+      "port":"5432"
+    }
+  }
+
diff --git a/controllers/attachment.controller.ts b/controllers/attachment.controller.ts
@@ -0,0 +1,35 @@
+import { Request, Response } from 'express';
+// import AttachmentService from '../services/attachment.service';
+
+// Function to create a new attachment
+const createAttachment = async (req: Request, res: Response) => {
+  try {
+    const { fileUrl, fileName, messageId, creatorId } = req.body;
+    const attachment = await AttachmentService.createAttachment(
+      fileUrl,
+      fileName,
+      messageId,
+      creatorId
+    );
+
+    res.status(201).json(attachment);
+  } catch (error) {
+    res.status(500).json({ error: error.message });
+  }
+};
+
+// Function to get attachments by message ID
+const getAttachmentsByMessageId = async (req: Request, res: Response) => {
+  try {
+    const { message_id } = req.params;
+    const attachments = await AttachmentService.getAttachmentsByMessageId(
+      message_id
+    );
+
+    res.status(200).json(attachments);
+  } catch (error) {
+    res.status(500).json({ error: error.message });
+  }
+};
+
+export { createAttachment, getAttachmentsByMessageId };
diff --git a/controllers/auth.controller.ts b/controllers/auth.controller.ts
diff --git a/controllers/group.controller.ts b/controllers/group.controller.ts
diff --git a/controllers/grouppmembers.controller.ts b/controllers/grouppmembers.controller.ts
diff --git a/controllers/index.js b/controllers/index.js
diff --git a/controllers/message.controller.ts b/controllers/message.controller.ts
diff --git a/controllers/user.controller.ts b/controllers/user.controller.ts
diff --git a/migrations/20231003065958-User.ts b/migrations/20231003065958-User.ts
@@ -0,0 +1,40 @@
+'use strict';
+import { QueryInterface, DataTypes, Sequelize } from 'sequelize';
+
+/** @type {import('sequelize-cli').Migration} */
+module.exports = {
+  async up (queryInterface: QueryInterface, sequelize: Sequelize) {
+    await queryInterface.createTable('Users', {
+      id: {
+        allowNull: false,
+        autoIncrement: true,
+        primaryKey: true,
+        type: DataTypes.INTEGER
+      },
+      userName: {
+        type: DataTypes.STRING
+      },
+      fullName: {
+        type: DataTypes.STRING
+      },
+      email: {
+        type: DataTypes.STRING
+      },
+      password: {
+        type: DataTypes.STRING
+      },
+      createdAt: {
+        allowNull: false,
+        type: DataTypes.DATE
+      },
+      updatedAt: {
+        allowNull: false,
+        type: DataTypes.DATE
+      }
+    });
+  },
+
+  async down (queryInterface: QueryInterface, sequelize: Sequelize) {
+    await queryInterface.dropTable('Users');
+  }
+};
diff --git a/migrations/20231003075540-Message.ts b/migrations/20231003075540-Message.ts
@@ -0,0 +1,44 @@
+'use strict';
+
+import { QueryInterface, DataTypes, Sequelize } from 'sequelize';
+/** @type {import('sequelize-cli').Migration} */
+module.exports = {
+  async up (queryInterface: QueryInterface, sequelize: Sequelize) {
+    await queryInterface.createTable('Messages', {
+      id: {
+        allowNull: false,
+        autoIncrement: true,
+        primaryKey: true,
+        type: DataTypes.INTEGER
+      },
+      text: {
+        type: DataTypes.STRING,
+        allowNull: false
+      },
+      sender_id : {
+        type: DataTypes.INTEGER.UNSIGNED ,
+        allowNull: false,
+      },
+      group_id : {
+        type: DataTypes.INTEGER.UNSIGNED ,
+        allowNull: false,
+      },
+      reciever_id : {
+        type: DataTypes.INTEGER.UNSIGNED ,
+        allowNull: false,
+      },
+      createdAt: {
+        allowNull: false,
+        type: DataTypes.DATE
+      },
+      updatedAt: {
+        allowNull: false,
+        type: DataTypes.DATE
+      }
+  });
+},
+
+  async down (queryInterface: QueryInterface, sequelize: Sequelize) {
+    await queryInterface.dropTable('Messages');
+  }
+};
diff --git a/migrations/20231003075550-Group.ts b/migrations/20231003075550-Group.ts
@@ -0,0 +1,36 @@
+'use strict';
+
+import { QueryInterface, DataTypes, Sequelize } from 'sequelize';
+/** @type {import('sequelize-cli').Migration} */
+module.exports = {
+  async up (queryInterface: QueryInterface, sequelize: Sequelize) {
+    await queryInterface.createTable('Groups', {
+      id: {
+        allowNull: false,
+        autoIncrement: true,
+        primaryKey: true,
+        type: DataTypes.INTEGER
+      },
+      group_name: {
+        allowNull: false,
+        type: DataTypes.STRING
+      },
+      creator_id : {
+        type: DataTypes.INTEGER.UNSIGNED ,
+        allowNull: false,
+      },
+      createdAt: {
+        allowNull: false,
+        type: DataTypes.DATE
+      },
+      updatedAt: {
+        allowNull: false,
+        type: DataTypes.DATE
+      }
+    });
+  },
+
+  async down (queryInterface: QueryInterface, sequelize: Sequelize) {
+    await queryInterface.dropTable('Groups');
+  }
+};
diff --git a/migrations/20231003075602-Groupmember.ts b/migrations/20231003075602-Groupmember.ts
@@ -0,0 +1,37 @@
+'use strict';
+
+import { QueryInterface, DataTypes, Sequelize } from 'sequelize';
+/** @type {import('sequelize-cli').Migration} */
+module.exports = {
+  async up (queryInterface: QueryInterface, sequelize: Sequelize) {
+    await queryInterface.createTable('Group_participants', {
+      id: {
+        allowNull: false,
+        autoIncrement: true,
+        primaryKey: true,
+        type: DataTypes.INTEGER
+      },
+      group_id : {
+        type: DataTypes.INTEGER.UNSIGNED ,
+        allowNull: false,
+      },
+
+      user_id : {
+        type: DataTypes.INTEGER.UNSIGNED ,
+        allowNull: false,
+      },
+      createdAt: {
+        allowNull: false,
+        type: DataTypes.DATE
+      },
+      updatedAt: {
+        allowNull: false,
+        type: DataTypes.DATE
+      }
+    });
+  },
+
+  async down (queryInterface: QueryInterface, sequelize: Sequelize) {
+    await queryInterface.dropTable('Groups');
+  }
+};
diff --git a/migrations/20231003075627-Attachment.ts b/migrations/20231003075627-Attachment.ts
@@ -0,0 +1,43 @@
+'use strict';
+
+import { QueryInterface, DataTypes, Sequelize } from 'sequelize';
+/** @type {import('sequelize-cli').Migration} */
+module.exports = {
+  async up (queryInterface: QueryInterface, sequelize: Sequelize) {
+      await queryInterface.createTable('Attachments', {
+        id: {
+          allowNull: false,
+          autoIncrement: true,
+          primaryKey: true,
+          type: DataTypes.INTEGER
+        },
+        file_Url: {
+          allowNull: false,
+          type: DataTypes.STRING
+        },
+        file_Name: {
+          type: DataTypes.STRING
+        },
+        creator_id : {
+          type: DataTypes.INTEGER.UNSIGNED ,
+          allowNull: false,
+        },
+        message_id : {
+          type: DataTypes.INTEGER.UNSIGNED ,
+          allowNull: false,
+        },
+        createdAt: {
+          allowNull: false,
+          type: DataTypes.DATE
+        },
+        updatedAt: {
+          allowNull: false,
+          type: DataTypes.DATE
+        }
+      });
+  },
+
+  async down (queryInterface: QueryInterface, sequelize: Sequelize) {
+    await queryInterface.dropTable('Attachments');
+  }
+};
diff --git a/models/index.ts b/models/index.ts
@@ -0,0 +1,43 @@
+import fs from 'fs';
+import path from 'path';
+import { Sequelize, DataTypes, Model } from 'sequelize';
+
+const basename = path.basename(__filename);
+const env = process.env.NODE_ENV || 'development';
+const config = require(path.join(__dirname, '..', 'config', 'config.json'))[env];
+const db: Record<string, Model> = {}; // Define the type for the `db` object
+
+let sequelize: Sequelize;
+
+// if (config.use_env_variable) {
+//   sequelize = new Sequelize(process.env[config.use_env_variable]!, config);
+// } else {
+//   sequelize = new Sequelize(config.database!, config.username!, config.password!, config);
+// }
+
+fs
+  .readdirSync(__dirname)
+  .filter(file => {
+    return (
+      file.indexOf('.') !== 0 &&
+      file !== basename &&
+      file.slice(-3) === '.ts' &&
+      file.indexOf('.test.ts') === -1
+    );
+  })
+  .forEach(file => {
+    const model = require(path.join(__dirname, file)).default(sequelize, DataTypes);
+    db[model.name] = model;
+  });
+
+Object.keys(db).forEach((model : any) => {
+  if (model.associate) {
+    model.associate!(db);
+  }
+});
+
+
+export { sequelize, DataTypes };
+
+export default db;
+