Add CRUD operations for participant

api/models/participantModel.js

@@ -0,0 +1,63 @@
+const db = require('../../data/db');
+
+module.exports = {
+	addParticipant,
+	getParticipantById,
+	updateParticipant,
+	deleteParticipant,
+	// getMeetingsByParticipantId,
+};
+
+function addParticipant(data) {
+	return db('participant')
+		.insert(data)
+		.returning([
+            'account_id',
+            'meeting_id',
+			'earliest_time',
+            'latest_time',
+            'quorum',
+            'mandatory',
+            'host',
+			'answered',
+			'timezone',
+		]);
+}
+
+function updateParticipant(data, account_id, meeting_id) {
+	return db('participant')
+		.where({ account_id, meeting_id })
+		.update(data)
+		.returning([
+            'account_id',
+            'meeting_id',
+			'earliest_time',
+            'latest_time',
+            'quorum',
+            'mandatory',
+            'host',
+			'answered',
+			'timezone',
+		]);
+}
+
+function deleteParticipant(id) {
+	return db('participant').where({ id }).del();
+}
+
+function getParticipantById(account_id, meeting_id) {
+	return db('participant')
+		.where({ account_id, meeting_id })
+		.first()
+		.select(
+            'account_id',
+            'meeting_id',
+			'earliest_time',
+            'latest_time',
+            'quorum',
+            'mandatory',
+            'host',
+			'answered',
+			'timezone',
+		);
+}

api/routes/participantRoute.js

@@ -0,0 +1,72 @@
+let express = require('express');
+let router = express.Router();
+
+let Participant = require('../models/participantModel');
+
+router.post('/', async (req, res) => {
+	const data = { ...req.body };
+
+	try {
+		const [participant] = await Participant.addParticipant(data);
+		res.status(201).json(participant);
+	} catch (error) {
+		res.status(500).json({
+			message: 'Failed to add new participant.',
+			error,
+		});
+	}
+});
+
+router.put('/:account_id-:meeting_id', async (req, res) => {
+	const data = { ...req.body };
+	const { account_id, meeting_id } = req.params;
+
+	try {
+		const participant = await Participant.updateParticipant(
+			data,
+			account_id,
+			meeting_id,
+		);
+		res.status(200).json(...participant);
+	} catch (error) {
+		res.status(500).json({
+			message: 'Failed to update participant.',
+			error,
+		});
+	}
+});
+
+router.delete('/:account_id-:meeting_id', async (req, res) => {
+	const { account_id, meeting_id } = req.params;
+
+	try {
+		const participant = await Participant.deleteParticipant(
+			account_id,
+			meeting_id,
+		);
+		res.status(200).json({
+			message: `Participant with id ${account_id}-${meeting_id} successfully deleted.`,
+		});
+	} catch (error) {
+		res.status(500).json({
+			message: 'Failed to delete participant.',
+			error,
+		});
+	}
+});
+
+router.get('/:account_id-:meeting_id', async (req, res) => {
+	const { account_id, meeting_id } = req.params;
+
+	try {
+		const participant = await Participant.getParticipantById(
+			account_id,
+			meeting_id,
+		);
+		res.status(200).json(participant);
+	} catch (error) {
+		res.status(500).json({ message: "Participant doesn't exist.", error });
+	}
+});
+
+module.exports = router;

api/server.js

@@ -5,6 +5,7 @@ require('dotenv').config();
 
 const accountsRoute = require('./routes/accountRoute');
 const meetingsRoute = require('./routes/meetingRoute');
+const participantsRoute = require('./routes/participantRoute');
 
 const server = express();
 
@@ -14,6 +15,7 @@ server.use(helmet());
 
 server.use('/api/accounts', accountsRoute);
 server.use('/api/meetings', meetingsRoute);
+server.use('/api/participants', participantsRoute);
 
 server.get('/', (req, res) =>
 	res

data/migrations/20200502193341_participant.js

@@ -1,18 +1,16 @@
 exports.up = (knex) => {
 	return knex.schema.createTable('participant', (table) => {
-		table.increments('id').primary();
+		table.integer('account_id').unsigned();
+		table.uuid('meeting_id').unsigned();
 		table
-			.integer('account_id')
+		.foreign('meeting_id')
-			.unsigned()
+		.references('meeting.id')
-			.notNullable()
+		.onDelete('cascade');
-			.references('account.id')
-			.onDelete('cascade');
 		table
-			.uuid('meeting_id')
+		.foreign('account_id')
-			.unsigned()
+		.references('account.id')
-			.notNullable()
+		.onDelete('cascade');
-			.references('meeting.id')
+		table.primary(['meeting_id','account_id']);
-			.onDelete('cascade');
 		table.time('earliest_time');
 		table.time('latest_time');
 		table.boolean('quorum');

data/migrations/20200502193443_availibility.js

@@ -1,11 +1,12 @@
 exports.up = (knex) => {
 	return knex.schema.createTable('availibility', (table) => {
 		table.increments('id').primary();
+		table.uuid('meeting_id').unsigned();
+		table.integer('account_id').unsigned();
 		table
-			.integer('participant_id')
+			.foreign(['account_id', 'meeting_id'])
-			.unsigned()
+			.references(['account_id', 'meeting_id'])
-			.notNullable()
+			.on('participant')
-			.references('participant.id')
 			.onDelete('cascade');
 		table
 			.integer('possible_date_id')