137 lines
3.4 KiB
JavaScript
Executable File
137 lines
3.4 KiB
JavaScript
Executable File
// Declare a route
|
|
module.exports = function (fastify, opts, done) {
|
|
|
|
const pb = opts.pb;
|
|
|
|
fastify.post('/upvote', async (request, reply) => {
|
|
const data = request.body;
|
|
|
|
const postId = data?.postId;
|
|
const userId = data?.userId;
|
|
|
|
let output = 'failure';
|
|
|
|
|
|
try {
|
|
|
|
|
|
let doesUserExist = await pb.collection("alreadyVoted").getList(1, 50, {
|
|
filter: `user="${userId}"` && `post="${postId}"`,
|
|
})
|
|
|
|
doesUserExist = doesUserExist?.items?.find(item => item?.user === userId && item?.post === postId);
|
|
|
|
const votedId = doesUserExist?.id;
|
|
let currentVote = doesUserExist?.type;
|
|
|
|
//console.log('currentVote: ', currentVote)
|
|
|
|
|
|
const opPost = await pb.collection('posts').getOne(postId)
|
|
|
|
//If user has no history with this post create it
|
|
if( !currentVote || votedId === 'undefined')
|
|
{
|
|
|
|
let formDataAlreadyVoted = new FormData();
|
|
formDataAlreadyVoted.append('post', postId);
|
|
formDataAlreadyVoted.append('user', userId);
|
|
formDataAlreadyVoted.append('type', 'upvote');
|
|
await pb.collection('alreadyVoted').create(formDataAlreadyVoted);
|
|
|
|
//create new record for notifications collections
|
|
if (userId !== opPost.user)
|
|
{
|
|
let formDataNotifications = new FormData();
|
|
formDataNotifications.append('opUser', opPost.user);
|
|
formDataNotifications.append('user', userId)
|
|
formDataNotifications.append('post', postId);
|
|
formDataNotifications.append('notifyType', 'vote');
|
|
|
|
await pb.collection('notifications').create(formDataNotifications);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (currentVote === 'downvote')
|
|
{
|
|
console.log('downvote')
|
|
await pb.collection("posts").update(postId, {
|
|
"upvote+": 1,
|
|
});
|
|
|
|
await pb.collection("posts").update(postId, {
|
|
"downvote-": 1,
|
|
});
|
|
|
|
|
|
await pb.collection("alreadyVoted").update(votedId, {
|
|
"type": 'upvote',
|
|
});
|
|
|
|
//Reward: Find user of post and add +1 karma points
|
|
let opPost = await pb.collection('posts').getOne(postId)
|
|
await pb.collection("users").update(opPost.user, {
|
|
"karma+": 2,
|
|
})
|
|
|
|
|
|
|
|
}
|
|
else if (currentVote === 'neutral' || !currentVote)
|
|
{
|
|
|
|
//Reward: User of post gets +1 karma points
|
|
await pb.collection("users").update(opPost.user, {
|
|
"karma+": 1,
|
|
})
|
|
|
|
await pb.collection("posts").update(postId, {
|
|
"upvote+": 1,
|
|
});
|
|
|
|
|
|
await pb.collection("alreadyVoted").update(votedId, {
|
|
"type": 'upvote',
|
|
});
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
else
|
|
{
|
|
|
|
await pb.collection("posts").update(postId, {
|
|
"upvote-": 1,
|
|
});
|
|
|
|
|
|
await pb.collection("alreadyVoted").update(votedId, {
|
|
"type": 'neutral',
|
|
});
|
|
|
|
//Reset Reward: Find user of post and subtract -1 karma points
|
|
await pb.collection("users").update(opPost.user, {
|
|
"karma-": 1,
|
|
})
|
|
|
|
|
|
}
|
|
|
|
}
|
|
catch(e) {
|
|
console.log(e)
|
|
}
|
|
|
|
|
|
reply.send({ items: output })
|
|
|
|
});
|
|
|
|
done();
|
|
}; |