remove fastify endpoint

This commit is contained in:
MuslemRahimi 2024-11-05 18:12:26 +01:00
parent 94912cde3e
commit 0668735a35
3 changed files with 0 additions and 61 deletions

View File

@ -76,8 +76,6 @@ fastify.register(require("./feedback/server"), { pb });
fastify.register(require("./create-watchlist/server"), { pb }); fastify.register(require("./create-watchlist/server"), { pb });
fastify.register(require("./delete-watchlist/server"), { pb }); fastify.register(require("./delete-watchlist/server"), { pb });
fastify.register(require("./edit-name-watchlist/server"), { pb }); fastify.register(require("./edit-name-watchlist/server"), { pb });
fastify.register(require("./get-notifications/server"), { pb });
fastify.register(require("./update-notifications/server"), { pb });
fastify.register(require("./create-strategy/server"), { pb }); fastify.register(require("./create-strategy/server"), { pb });
fastify.register(require("./delete-strategy/server"), { pb }); fastify.register(require("./delete-strategy/server"), { pb });
fastify.register(require("./all-strategies/server"), { pb }); fastify.register(require("./all-strategies/server"), { pb });

View File

@ -1,30 +0,0 @@
// Declare a route
module.exports = function (fastify, opts, done) {
const pb = opts.pb;
fastify.post('/get-notifications', async (request, reply) => {
const data = request.body;
const userId = data?.userId;
let output;
try {
output = await pb.collection("notifications").getFullList({
filter: `opUser="${userId}" && readed = false`,
expand: 'user,post,comment',
sort: '-created'
});
}
catch(e) {
//console.log(e)
output = []
}
reply.send({ items: output })
});
done();
};

View File

@ -1,29 +0,0 @@
// Declare a route
module.exports = function (fastify, opts, done) {
const pb = opts.pb;
fastify.post('/update-notifications', async (request, reply) => {
const data = request.body;
const notificationList = data?.unreadList;
let output;
try {
const itemsToUpdate = notificationList?.filter(item => !item.readed);
// Perform updates in parallel
await Promise.all(itemsToUpdate.map(item =>
pb.collection("notifications").update(item, { readed: 'true' })
));
output = 'success'
}
catch(e) {
output = 'failure';
}
reply.send({ items: output })
});
done();
};