Develop g7

back-end/src/auth/auth.controller.ts

@@ -78,4 +78,41 @@ export class AuthController {
 		await this.authService.checkAuth(userId);
 		return res.status(200).json({ status: 'ok' });
 	}
+
+	@Post('addEvent')
+	@UseGuards(JwtAuthGuard)
+	async addEvents(
+		@Jwt() userId: ObjectId,
+		@Body() body: { eventId: string },
+		@Res() res: Response,
+	) {
+		const id = new ObjectId(body.eventId);
+		await this.authService.addEvent(userId, id);
+		return res.status(200).json({ status: 'ok' });
+	}
+
+	@Post('removeEvent')
+	@UseGuards(JwtAuthGuard)
+	async removeEvents(
+		@Jwt() userId: ObjectId,
+		@Body() body: { eventId: string },
+		@Res() res: Response,
+	) {
+		const id = new ObjectId(body.eventId);
+		await this.authService.removeEvent(userId, id);
+		return res.status(200).json({ status: 'ok' });
+	}
+
+	// tryAddArticles
+	@Post('addArticle')
+	@UseGuards(JwtAuthGuard)
+	async addArticles(
+		@Jwt() userId: ObjectId,
+		@Body() body: { articleId: string },
+		@Res() res: Response,
+	) {
+		const id = new ObjectId(body.articleId);
+		await this.authService.addArticles(userId, id);
+		return res.status(200).json({ status: 'ok' });
+	}
 }

back-end/src/auth/auth.service.ts

@@ -165,4 +165,30 @@ export class AuthService {
 			);
 		return user;
 	}
+
+	// add events into user
+	async addEvent(userId: ObjectId, eventId: ObjectId) {
+		const user = await this.usersRepository.findOneAndUpdateUser(
+			{ _id: userId },
+			{ $push: { events: eventId } },
+		);
+		if (user.value === null) throw new ServiceError('BAD_REQUEST', 'Error 400');
+	}
+
+	// remove events from user
+	async removeEvent(userId: ObjectId, eventId: ObjectId) {
+		const user = await this.usersRepository.findOneAndUpdateUser(
+			{ _id: userId },
+			{ $pull: { events: eventId } },
+		);
+		if (user.value === null) throw new ServiceError('BAD_REQUEST', 'Error 400');
+	}
+
+	async addArticles(userId: ObjectId, articleId: ObjectId) {
+		const user = await this.usersRepository.findOneAndUpdateUser(
+			{ _id: userId },
+			{ $push: { myArticles: articleId } },
+		);
+		if (user.value === null) throw new ServiceError('BAD_REQUEST', 'Error 400');
+	}
 }

back-end/src/base/articles/articles.controller.ts

@@ -1,4 +1,4 @@
-import { Controller, Get, Res, UseFilters, Post, Req } from '@nestjs/common';
+import { Controller, Get, Res, UseFilters, Post, Req, Put } from '@nestjs/common';
 import { Response, Request } from 'express';
 
 import { ServiceErrorCatcher } from 'src/common/decorators/catch.decorator';
@@ -10,13 +10,45 @@ export class ArticlesController {
 	constructor(private readonly articlesService: ArticlesService) {}
 
 	@Get('')
-	index(@Res() res: Response) {
-		return res.status(201).json({ status: 'ok' });
+	getArticle(@Req() req: Request, @Res() res: Response) {
+		this.articlesService.getArticle().then((article) => {
+			return res.status(201).json(article);
+		});
 	}
 
 	@Post('/add')
-	addArticle(@Req() req: Request, @Res() res: Response) {
-		this.articlesService.addArticle(req.body).then((article) => {
+	async addArticle(@Req() req: Request, @Res() res: Response) {
+		const article = await this.articlesService.addArticle(req.body);
+		return res.status(201).json({ article, id: article.insertedId });
+	}
+
+	@Get('/:id')
+	getArticleById(@Req() req: Request, @Res() res: Response) {
+		this.articlesService.getArticleById(req.params.id).then((article) => {
+			return res.status(201).json(article);
+		});
+	}
+
+	// add participant to the array of participants in article in the database
+	@Put('/participant/:id')
+	addParticipant(@Req() req: Request, @Res() res: Response) {
+		this.articlesService.addParticipant(req.params.id, req.body).then((article) => {
+			return res.status(201).json(article);
+		});
+	}
+
+	// remove participant from the array of participants in article in the database
+	@Put('/removeParticipant/:id')
+	removeParticipant(@Req() req: Request, @Res() res: Response) {
+		this.articlesService.removeParticipant(req.params.id, req.body).then((article) => {
+			return res.status(201).json(article);
+		});
+	}
+
+	// add comment
+	@Put('/comment/:id')
+	addComment(@Req() req: Request, @Res() res: Response) {
+		this.articlesService.addComment(req.params.id, req.body).then((article) => {
 			return res.status(201).json(article);
 		});
 	}

back-end/src/base/articles/articles.repository.ts

@@ -1,16 +1,29 @@
 import { Inject, Injectable } from '@nestjs/common';
-import { Filter, UpdateFilter, FindOneAndUpdateOptions, Db } from 'mongodb';
+import { Filter, UpdateFilter, FindOneAndUpdateOptions, Db, ObjectId } from 'mongodb';
 
 import { Article } from 'src/base/articles/interfaces/articles.interface';
 
 @Injectable()
 export class ArticlesRepository {
 	constructor(@Inject('DATABASE_CONNECTION') private db: Db) {}
 
+	// Function to get the articles collection
 	get articles() {
 		return this.db.collection<Article>('articles');
 	}
 
+	// Function to get an article by its id
+	async getArticleById(id: ObjectId) {
+		id = new ObjectId(id);
+		return this.articles.findOne({ _id: id });
+	}
+
+	// Function to get all articles
+	async getAllArticles() {
+		return this.articles.find({}).toArray();
+	}
+
+	// Function to add an article
 	async createArticle(query: Article) {
 		return this.articles.insertOne(query);
 	}

back-end/src/base/articles/articles.service.ts

@@ -1,4 +1,5 @@
 import { forwardRef, Inject, Injectable } from '@nestjs/common';
+import { ObjectId } from 'mongodb';
 
 import { ArticlesRepository } from 'src/base/articles/articles.repository';
 import { UsersRepository } from 'src/base/users/users.repository';
@@ -12,9 +13,42 @@ export class ArticlesService {
 		private articlesRepository: ArticlesRepository,
 	) {}
 
+	// Function to add an article
 	async addArticle(queryArticle) {
 		return await this.articlesRepository.createArticle(queryArticle);
 	}
+
+	// Function to get all articles
+	async getArticle() {
+		return await this.articlesRepository.getAllArticles();
+	}
+
+	// Function to get an article by its id
+	async getArticleById(id) {
+		return await this.articlesRepository.getArticleById(id);
+	}
+
+	// add participant to the array of participants in article in the database
+	async addParticipant(id, queryParticipant) {
+		const update = { $push: { participants: queryParticipant } };
+
+		return await this.articlesRepository.updateOneArticle({ _id: new ObjectId(id) }, update);
+	}
+
+	// remove participant from the array of participants in article in the database
+	async removeParticipant(id, queryParticipant) {
+		const update = { $pull: { participants: queryParticipant } };
+
+		return await this.articlesRepository.updateOneArticle({ _id: new ObjectId(id) }, update);
+	}
+
+	// add comment
+	async addComment(id, queryComment) {
+		const update = { $push: { comments: queryComment } };
+
+		return await this.articlesRepository.updateOneArticle({ _id: new ObjectId(id) }, update);
+	}
+
 	// Business logic methods goes there...
 	// Define your own methods
 }

front-end/src/api/auth-req.ts

@@ -33,3 +33,15 @@ export const tryResetPassword = (password: string, resetToken: string) => {
 export const tryGetMe = async () => {
 	return http.get<Status<{ user: User }>>('/auth/me');
 };
+
+export const tryAddEvents = async (eventId: string) => {
+	return http.post<Status>('/auth/addEvent', { eventId });
+};
+
+export const tryRemoveEvents = async (eventId: string) => {
+	return http.post<Status>('/auth/removeEvent', { eventId });
+};
+
+export const tryAddArticles = async (articleId: string) => {
+	return http.post<Status>('/auth/addArticle', { articleId });
+};