Added Conversation and Message Model, DAO and Repository

Author: Rishabh Garg

app/controllers/conversation.controller.ts

@@ -0,0 +1,26 @@
+import { NextFunction, Response, Request } from "express";
+import { ConversationRepository } from "../repositories/conversation.repository";
+
+export class ConversationController {
+ conversationRepository: ConversationRepository;
+ constructor() {
+ this.conversationRepository = new ConversationRepository();
+ }
+
+ getRecord = async (request: Request, response: Response, next: NextFunction) => {
+ await this.conversationRepository.getRecord();
+ response.send('Get Response');
+ }
+
+ createRecord = async (request: Request, response: Response, next: NextFunction) => {
+ response.json(request.body);
+ }
+
+ updateRecord = async (request: Request, response: Response, next: NextFunction) => {
+ response.json(request.body);
+ }
+
+ deleteRecord = async (request: Request, response: Response, next: NextFunction) => {
+ response.send(request.params.id + ' deleted successfully');
+ }
+}

app/controllers/user.controller.ts

@@ -9,7 +9,6 @@ export class UerController {
 
  getRecord = async (request: Request, response: Response, next: NextFunction) => {
  const users = await this.userRepository.retrieve({}, {}, {});
- console.log(users);
  response.send(users);
  }
 

app/models/conversation.model.ts

@@ -0,0 +1,10 @@
+
+import mongoose = require("mongoose");
+import { UserModel } from "./user.model";
+export interface ConversationModel extends mongoose.Document {
+ members?: UserModel[] | string[];
+ createdAt?: Date;
+ _id?: string;
+ isGroup?: boolean;
+ groupName?: string;
+}

app/models/message.model.ts

@@ -0,0 +1,12 @@
+
+import mongoose = require("mongoose");
+import { UserModel } from "./user.model";
+import { ConversationModel } from "./conversation.model";
+export interface MessageModel extends mongoose.Document {
+ sender?: UserModel | string;
+ messageText?: string;
+ createdAt?: Date;
+ conversationId?: ConversationModel | string;
+ members?: UserModel[] | string[];
+ _id?: string;
+}

app/repositories/conversation.repository.ts

@@ -0,0 +1,9 @@
+import { RepositoryBase } from "../config/base.repository";
+import { ConversationModel } from "../models/conversation.model";
+import { ConversationSchemaDO } from "../schemas/conversation.schema";
+
+export class ConversationRepository extends RepositoryBase<ConversationModel> {
+ constructor() {
+ super(ConversationSchemaDO);
+ }
+}

app/routes/conversation.route.ts

@@ -0,0 +1,29 @@
+
+import Mongoose = require("mongoose");
+import DataAccess = require("../config/mongo.connector");
+import { ConversationModel } from "../models/conversation.model";
+const mongooseConnection = DataAccess.mongooseConnection;
+
+class ConversationSchema {
+ static get schema() {
+ var schema = new Mongoose.Schema({
+ createdAt: {
+ type: Date,
+ default: Date.now
+ },
+ isGroup: {
+ type: Boolean,
+ default: false
+ },
+ groupName: {
+ type: String
+ },
+ members: [{
+ type: Mongoose.Schema.Types.ObjectId,
+ ref: 'Users'
+ }]
+ });
+ return schema;
+ }
+}
+export const ConversationSchemaDO = mongooseConnection.model<ConversationModel>("Conversations", ConversationSchema.schema);

app/schemas/conversation.schema.ts

@@ -0,0 +1,33 @@
+
+import Mongoose = require("mongoose");
+import DataAccess = require("../config/mongo.connector");
+import { MessageModel } from "../models/message.model";
+const mongooseConnection = DataAccess.mongooseConnection;
+
+class MessageSchema {
+ static get schema() {
+ var schema = new Mongoose.Schema({
+ createdAt: {
+ type: Date,
+ default: Date.now
+ },
+ conversationId: {
+ type: Mongoose.Schema.Types.ObjectId,
+ ref: 'Conversations'
+ },
+ messageText: {
+ type: String
+ },
+ members: [{
+ type: Mongoose.Schema.Types.ObjectId,
+ ref: 'Users'
+ }],
+ sender: {
+ type: Mongoose.Schema.Types.ObjectId,
+ ref: 'Users'
+ }
+ });
+ return schema;
+ }
+}
+export const MessageSchemaDO = mongooseConnection.model<MessageModel>("Messages", MessageSchema.schema);