445 lines
11 KiB
JavaScript
445 lines
11 KiB
JavaScript
var express = require('express');
|
|
var router = express.Router();
|
|
// var firebase = require('firebase');
|
|
var admin = require('firebase-admin');
|
|
//Database
|
|
var postgres = require("./../db-connect/db-connect");
|
|
|
|
|
|
// Initialize Firebase
|
|
// const config = {
|
|
// apiKey: "AIzaSyCuvwf78cmSDoZ2yS4XxHZhnjUn7yIHYfw",
|
|
// authDomain: "test-667ca.firebaseapp.com",
|
|
// databaseURL: "https://test-667ca.firebaseio.com",
|
|
// projectId: "test-667ca",
|
|
// storageBucket: "test-667ca.appspot.com",
|
|
// messagingSenderId: "221332577314"
|
|
// };
|
|
// firebase.initializeApp(config);
|
|
|
|
var serviceAccount = require('../login/firebaseAdminKey.json');
|
|
|
|
|
|
|
|
|
|
var firebaseAdmin = admin.initializeApp({
|
|
credential: admin.credential.cert(serviceAccount),
|
|
databaseURL: 'https://test-667ca.firebaseio.com'
|
|
});
|
|
|
|
function sendPush(msgtoken, title, text){
|
|
var message = {
|
|
data: {
|
|
title: title,
|
|
text: text
|
|
}
|
|
};
|
|
|
|
firebaseAdmin.messaging().sendToDevice(msgtoken, message)
|
|
.then(function(response) {
|
|
// See the MessagingDevicesResponse reference documentation for
|
|
// the contents of response.
|
|
console.log('Successfully sent message:', response);
|
|
})
|
|
.catch(function(error) {
|
|
console.log('Error sending message:', error);
|
|
});
|
|
|
|
}
|
|
|
|
//Push
|
|
router.get('/push/:msgtoken', function (req, res, next) {
|
|
sendPush(req.params.msgtoken, "Update", "Einkaufsliste wurde geändert")
|
|
res.status(200)
|
|
|
|
});
|
|
|
|
|
|
// Login und Dash
|
|
router.get('/', function(req, res, next) {
|
|
res.render('index');
|
|
});
|
|
|
|
|
|
router.get('/dash/:idtoken', function(req, res, next) {
|
|
// const msgtoken = req.params.msgtoken;
|
|
const token = req.params.idtoken;
|
|
var uid;
|
|
firebaseAdmin.auth().verifyIdToken(token)
|
|
.then(function(decodedToken) {
|
|
uid = decodedToken.uid;
|
|
// HIER WEITER MACHEN
|
|
// uid ist nur hier drinen verfügbar
|
|
|
|
|
|
}).catch(function(error) {
|
|
console.log(error)
|
|
});
|
|
|
|
|
|
|
|
|
|
res.render('dash');
|
|
});
|
|
|
|
|
|
// SmartShopper
|
|
|
|
//GET Own shoppinglists as JSON
|
|
|
|
router.get("/myshoppinglists",async function(req, res, next) {
|
|
var token = req.query.idtoken;
|
|
console.log("/myshoppinglists idtoken: ", token)
|
|
firebaseAdmin.auth().verifyIdToken(token)
|
|
.then(async function(decodedToken) {
|
|
uid = decodedToken.uid;
|
|
console.log("uid", uid)
|
|
try {
|
|
//Get user id: req.session.passport.user.profile.id
|
|
res.status(200).send(await postgres.getShoppinglistsAdmin(uid));
|
|
}
|
|
|
|
catch(err) {
|
|
res.status(400).send(await err);
|
|
}
|
|
|
|
}).catch(function(error) {
|
|
console.log(error)
|
|
});
|
|
|
|
|
|
});
|
|
|
|
//Test Funktion für Android, liefert die FirebaseAdmin Skd UID
|
|
// router.get("/androidUIDTest/:idtoken", function (req, res, next) {
|
|
// var token = req.params.idtoken;
|
|
// console.log("/sharedshoppinglists idtoken: ", token)
|
|
// var uid;
|
|
// firebaseAdmin.auth().verifyIdToken(token)
|
|
// .then(async function(decodedToken) {
|
|
// uid = decodedToken.uid;
|
|
// console.log("UID: ", uid);
|
|
// res.status(200).send(uid);
|
|
|
|
// }).catch( async function(error) {
|
|
// console.log(error)
|
|
// });
|
|
// })
|
|
|
|
//GET Shared shoppinglists as JSON
|
|
|
|
router.get("/sharedshoppinglists", async function(req, res, next) {
|
|
var token = req.query.idtoken;
|
|
console.log("/sharedshoppinglists idtoken: ", token)
|
|
var uid;
|
|
firebaseAdmin.auth().verifyIdToken(token)
|
|
.then(async function(decodedToken) {
|
|
uid = decodedToken.uid;
|
|
console.log("UID: ", uid);
|
|
try {
|
|
//Get user id: das da oben
|
|
res.status(200).send(await postgres.getShoppinglistsShared(uid));
|
|
}
|
|
|
|
catch(err) {
|
|
res.status(400).send(await err);
|
|
}
|
|
}).catch( async function(error) {
|
|
console.log(error)
|
|
});
|
|
|
|
|
|
});
|
|
|
|
//POST new shoppinglist
|
|
|
|
router.post("/shoppinglist", async function(req, res, next) {
|
|
console.log("/shoppinglist idtoken: ", req.body.idtoken)
|
|
var token = req.body.idtoken;
|
|
|
|
var uid;
|
|
firebaseAdmin.auth().verifyIdToken(token)
|
|
.then(async function(decodedToken) {
|
|
uid = decodedToken.uid;
|
|
console.log("UID: ", uid);
|
|
console.log("So andere sachen: ", req.body.name, req.body.description);
|
|
try {
|
|
|
|
res.status(200).send(await postgres.newShoppinglist(req.body.name, req.body.description, uid, req.body.color));
|
|
sendPush("enG4tJ6LyyU:APA91bEYjUEs7Sdzvu2ivgfqtpzlg42BZLlujDSRg0WLBvfZ_oD4V7cTx2o6MVr4oAdeHaK0wttPMQ85GMMOkgM7xvbHFcwXUG4MCr8JXX16S-OV2CS4ikQ286DOHPtBotbM7pqFTvIM", "Einkaufsliste " + req.body.name + " wurde erstellt!", req.body.description)
|
|
}
|
|
|
|
catch(err) {
|
|
res.status(400).send(await err);
|
|
}
|
|
}).catch(function(error) {
|
|
console.log(error)
|
|
});
|
|
});
|
|
//GET Shoppinglist detail
|
|
|
|
router.get("/shoppinglist_json/:sl_id", async (req, res) => {
|
|
var token = req.query.idtoken;
|
|
var uid;
|
|
firebaseAdmin.auth().verifyIdToken(token)
|
|
.then(async function(decodedToken) {
|
|
uid = decodedToken.uid;
|
|
console.log("UID: ", uid);
|
|
try {
|
|
res.status(200).send(await postgres.displayShoppinglist(req.params.sl_id));
|
|
}
|
|
|
|
catch(err) {
|
|
res.status(400).send(await err);
|
|
}
|
|
}).catch(function(error) {
|
|
console.log(error)
|
|
});
|
|
|
|
});
|
|
|
|
postgres.displayShoppinglist("4tezJYMK");
|
|
|
|
//DELETE Shoppinglist
|
|
|
|
router.delete("/shoppinglist", async (req, res) => {
|
|
try {
|
|
res.status(200).send(await postgres.deleteShoppinglist(req.body.sl_id));
|
|
sendPush("enG4tJ6LyyU:APA91bEYjUEs7Sdzvu2ivgfqtpzlg42BZLlujDSRg0WLBvfZ_oD4V7cTx2o6MVr4oAdeHaK0wttPMQ85GMMOkgM7xvbHFcwXUG4MCr8JXX16S-OV2CS4ikQ286DOHPtBotbM7pqFTvIM", "Die Einkaufsliste " + req.body.sl_id + " wurde gelöscht!", "Einkaufsliste wurde geändert")
|
|
}
|
|
|
|
catch(err) {
|
|
res.status(400).send(await err);
|
|
}
|
|
});
|
|
|
|
//Group erstellen
|
|
|
|
router.post("/group", async (req, res) => {
|
|
try {
|
|
res.status(200).send(await postgres.addGroup(req.body.sl_id, req.body.name, req.body.color, req.body.hidden));
|
|
}
|
|
|
|
catch(err) {
|
|
res.status(400).send(await err);
|
|
}
|
|
|
|
});
|
|
|
|
//Item erstellen
|
|
|
|
router.post("/item", async (req, res) => {
|
|
try {
|
|
res.status(200).send(await postgres.addItem(req.body.group_id, req.body.sl_id, req.body.name, req.body.count));
|
|
}
|
|
|
|
catch (err) {
|
|
res.status(400).send(await err);
|
|
}
|
|
});
|
|
|
|
router.get("/test1", (req, res) => {
|
|
res.render("test");
|
|
});
|
|
|
|
router.get("/userinfo_json", (req, res) => {
|
|
var token = req.query.idtoken;
|
|
|
|
console.log("/userinfo_json idtoken: ", token)
|
|
firebaseAdmin.auth().verifyIdToken(token)
|
|
.then(function(decodedToken) {
|
|
res.send(decodedToken);
|
|
}).catch(function(error) {
|
|
console.log(error)
|
|
});
|
|
});
|
|
|
|
//Rename Shoppinglist
|
|
router.put("/shoppinglist", async (req, res) => {
|
|
try {
|
|
res.status(200).send(await postgres.editShoppinglist(req.body.sl_id, req.body.name, req.body.description, req.body.color));
|
|
}
|
|
|
|
catch(err) {
|
|
res.status(400).send(await err);
|
|
}
|
|
});
|
|
|
|
//Rename Group
|
|
|
|
router.put("/group", async (req, res) => {
|
|
try {
|
|
res.status(200).send(await postgres.editGroup(req.body.sl_id, req.body.group_id, req.body.name, req.body.color, req.body.hidden));
|
|
}
|
|
|
|
catch(err) {
|
|
res.status(400).send(await err);
|
|
}
|
|
});
|
|
|
|
router.put("/item", async (req, res) => {
|
|
try {
|
|
res.status(200).send(await postgres.editItem(req.body.sl_id, req.body.group_id, req.body.item_id, req.body.name, req.body.count));
|
|
}
|
|
|
|
catch(err) {
|
|
res.status(400).send(await err);
|
|
}
|
|
});
|
|
|
|
router.delete("/group", async(req, res) => {
|
|
try {
|
|
res.status(200).send(await postgres.deleteGroup(req.body.group_id, req.body.sl_id));
|
|
}
|
|
|
|
catch(err) {
|
|
res.status(400).send(await err);
|
|
}
|
|
});
|
|
|
|
router.delete("/item", async(req, res) => {
|
|
try {
|
|
res.status(200).send(await postgres.deleteItem(req.body.item_id, req.body.group.id, req.body.sl_id));
|
|
}
|
|
|
|
catch(err) {
|
|
res.status(400).send(await err);
|
|
}
|
|
});
|
|
|
|
// Invite System
|
|
|
|
router.post("/invite", async (req, res) => {
|
|
try {
|
|
res.status(200).send(await postgres.createInvite(req.body.sl_id));
|
|
}
|
|
|
|
catch(err) {
|
|
res.status(400).send(await err);
|
|
}
|
|
});
|
|
|
|
router.post("/maninvite", async (req, res) => {
|
|
|
|
var token = req.query.idtoken;
|
|
var uid;
|
|
firebaseAdmin.auth().verifyIdToken(token)
|
|
.then(function(decodedToken) {
|
|
uid = decodedToken.uid;
|
|
console.log("UID: ", uid);
|
|
try {
|
|
res.status(200).send(postgres.manInvite(req.body.sl_id, uid));
|
|
}
|
|
catch(err) {
|
|
console.error(error);
|
|
}
|
|
}).catch(function(error) {
|
|
console.error(error)
|
|
});
|
|
});
|
|
|
|
router.get("/invite/:invitelink", async (req, res) => {
|
|
res.status(200).render("invitelogin", {invitelink: req.params.invitelink});
|
|
});
|
|
|
|
|
|
//Update User
|
|
|
|
router.post("/user", async function(req, res, next) {
|
|
console.log("/shoppinglist idtoken: ", req.body.idtoken)
|
|
var token = req.body.idtoken;
|
|
|
|
var uid;
|
|
firebaseAdmin.auth().verifyIdToken(token)
|
|
.then(async function(decodedToken) {
|
|
uid = decodedToken.uid;
|
|
try {
|
|
res.status(200).send(await postgres.updateUser(uid, req.body.message_id));
|
|
}
|
|
|
|
catch(err) {
|
|
res.status(400).send(await err);
|
|
}
|
|
}).catch(function(error) {
|
|
console.log(error)
|
|
});
|
|
});
|
|
|
|
//postgres.updateUser("testuser2", "einemessageid");
|
|
|
|
|
|
//postgres.moveDoneItems('dXMuv1J0f4O7RKn2bizGMTHUYkg1', '2IY2BwLP', 'aAnNNanas bjdbafBROtcHiPs');
|
|
|
|
router.post("/donepurchases", (req, res) => {
|
|
var token = req.query.idtoken;
|
|
var uid;
|
|
firebaseAdmin.auth().verifyIdToken(token)
|
|
.then(async function(decodedToken) {
|
|
uid = decodedToken.uid;
|
|
try {
|
|
console.log("test");
|
|
}
|
|
|
|
catch(err) {
|
|
console.error(error);
|
|
}
|
|
}).catch( async function(error) {
|
|
console.log(error)
|
|
});
|
|
|
|
});
|
|
|
|
|
|
//GET Done Purchases
|
|
router.get("/donepurchases", (req, res) => {
|
|
var token = req.query.idtoken;
|
|
var uid;
|
|
firebaseAdmin.auth().verifyIdToken(token)
|
|
.then(async function(decodedToken) {
|
|
uid = decodedToken.uid;
|
|
try {
|
|
res.status(200).send(await postgres.getDonePurchases(uid));
|
|
}
|
|
|
|
catch(err) {
|
|
res.status(400).send(await err);
|
|
}
|
|
}).catch( async function(error) {
|
|
console.log(error)
|
|
});
|
|
|
|
});
|
|
|
|
|
|
//OCR Scan
|
|
|
|
|
|
router.get("/scan/", async (req, res,) => {
|
|
res.render("ocrscan");
|
|
});
|
|
|
|
|
|
router.post("/dones", async function(req, res, next) {
|
|
console.log("/shoppinglist idtoken: ", req.body.idtoken)
|
|
var token = req.body.idtoken;
|
|
|
|
var uid;
|
|
firebaseAdmin.auth().verifyIdToken(token)
|
|
.then(async function(decodedToken) {
|
|
uid = decodedToken.uid;
|
|
console.log("UID: ", uid);
|
|
console.log("So andere sachen: ", req.body.name, req.body.description);
|
|
try {
|
|
|
|
res.status(200).send(await postgres.moveDoneItems(uid, req.body.sl_id, req.body.billcontent));
|
|
}
|
|
|
|
catch(err) {
|
|
res.status(400).send(await err);
|
|
}
|
|
}).catch(function(error) {
|
|
console.log(error)
|
|
});
|
|
});
|
|
module.exports = router;
|