109 lines
2.9 KiB
JavaScript
109 lines
2.9 KiB
JavaScript
const express = require("express");
|
|
const path = require("path");
|
|
const router = express.Router();
|
|
const mongoose = require("mongoose");
|
|
mongoose.connect("mongodb://localhost:27017/vinlottis", {
|
|
useNewUrlParser: true
|
|
});
|
|
|
|
const sub = require(path.join(__dirname + "/../api/subscriptions"));
|
|
const mustBeAuthenticated = require(path.join(
|
|
__dirname + "/../middleware/mustBeAuthenticated"
|
|
));
|
|
|
|
const _wineFunctions = require(path.join(__dirname + "/../api/wine"));
|
|
const _personFunctions = require(path.join(__dirname + "/../api/person"));
|
|
const Subscription = require(path.join(__dirname + "/../schemas/Subscription"));
|
|
const Purchase = require(path.join(__dirname + "/../schemas/Purchase"));
|
|
const PreLotteryWine = require(path.join(
|
|
__dirname + "/../schemas/PreLotteryWine"
|
|
));
|
|
|
|
router.use((req, res, next) => {
|
|
next();
|
|
});
|
|
|
|
router.route("/log/wines").post(mustBeAuthenticated, async (req, res) => {
|
|
const wines = req.body;
|
|
for (let i = 0; i < wines.length; i++) {
|
|
let wine = wines[i];
|
|
let newWonWine = new PreLotteryWine({
|
|
name: wine.name,
|
|
vivinoLink: wine.vivinoLink,
|
|
rating: wine.rating,
|
|
image: wine.image,
|
|
price: wine.price,
|
|
country: wine.country,
|
|
id: wine.id
|
|
});
|
|
await newWonWine.save();
|
|
}
|
|
|
|
let subs = await Subscription.find();
|
|
for (let i = 0; i < subs.length; i++) {
|
|
let subscription = subs[i]; //get subscription from your databse here.
|
|
const message = JSON.stringify({
|
|
message: "Dagens vin er lagt til, se den på lottis.vin/dagens!",
|
|
title: "Ny vin!",
|
|
link: "/#/dagens"
|
|
});
|
|
sub.sendNotification(subscription, message);
|
|
}
|
|
|
|
res.send(true);
|
|
});
|
|
|
|
router.route("/log/schema").get(mustBeAuthenticated, async (req, res) => {
|
|
let schema = { ...PreLotteryWine.schema.obj };
|
|
let nulledSchema = Object.keys(schema).reduce((accumulator, current) => {
|
|
accumulator[current] = "";
|
|
return accumulator;
|
|
}, {});
|
|
|
|
res.send(nulledSchema);
|
|
});
|
|
|
|
router.route("/log").post(mustBeAuthenticated, async (req, res) => {
|
|
await PreLotteryWine.deleteMany();
|
|
|
|
const purchaseBody = req.body.purchase;
|
|
const winnersBody = req.body.winners;
|
|
|
|
const date = purchaseBody.date;
|
|
const blue = purchaseBody.blue;
|
|
const red = purchaseBody.red;
|
|
const yellow = purchaseBody.yellow;
|
|
const green = purchaseBody.green;
|
|
|
|
const bought = purchaseBody.bought;
|
|
const stolen = purchaseBody.stolen;
|
|
|
|
const winesThisDate = [];
|
|
|
|
for (let i = 0; i < winnersBody.length; i++) {
|
|
let currentWinner = winnersBody[i];
|
|
|
|
let wonWine = await _wineFunctions.findSaveWine(currentWinner);
|
|
winesThisDate.push(wonWine);
|
|
|
|
await _personFunctions.findSavePerson(currentWinner, wonWine);
|
|
}
|
|
|
|
let purchase = new Purchase({
|
|
date: date,
|
|
blue: blue,
|
|
yellow: yellow,
|
|
red: red,
|
|
green: green,
|
|
wines: winesThisDate,
|
|
bought: bought,
|
|
stolen: stolen
|
|
});
|
|
|
|
await purchase.save();
|
|
|
|
res.send(true);
|
|
});
|
|
|
|
module.exports = router;
|