add ntfy
This commit is contained in:
parent
bad6ab1acc
commit
e0ef03a944
|
@ -0,0 +1,8 @@
|
||||||
|
import fetch from "node-fetch";
|
||||||
|
|
||||||
|
export async function ntfy(message: string) {
|
||||||
|
fetch("https://ntfy.sh/uhrv932r4e5w6zmi4-ld", {
|
||||||
|
method: "POST",
|
||||||
|
body: message,
|
||||||
|
}).catch(console.error);
|
||||||
|
}
|
|
@ -15,6 +15,7 @@ import { outsideProviders } from "../middleware/setup-passport";
|
||||||
import * as T from "../../../website/src/types/account-types";
|
import * as T from "../../../website/src/types/account-types";
|
||||||
import env from "../lib/env-vars";
|
import env from "../lib/env-vars";
|
||||||
import Stripe from "stripe";
|
import Stripe from "stripe";
|
||||||
|
import { ntfy } from "./ntfy";
|
||||||
|
|
||||||
const stripe = new Stripe(env.stripeSecretKey, {
|
const stripe = new Stripe(env.stripeSecretKey, {
|
||||||
apiVersion: "2022-08-01",
|
apiVersion: "2022-08-01",
|
||||||
|
@ -163,6 +164,7 @@ export async function createNewUser(
|
||||||
email: input.email || "",
|
email: input.email || "",
|
||||||
token: email.token,
|
token: email.token,
|
||||||
});
|
});
|
||||||
|
ntfy(`new LingDocs user ${input.name} - ${input.email}`);
|
||||||
const user = await insertLingdocsUser(newUser);
|
const user = await insertLingdocsUser(newUser);
|
||||||
return user;
|
return user;
|
||||||
}
|
}
|
||||||
|
|
|
@ -1,12 +1,13 @@
|
||||||
import express, { Response } from "express";
|
import express, { Response } from "express";
|
||||||
import * as T from "../../../website/src/types/account-types";
|
import * as T from "../../../website/src/types/account-types";
|
||||||
import { addFeedback } from "../lib/couch-db";
|
import { addFeedback } from "../lib/couch-db";
|
||||||
|
import { ntfy } from "../lib/ntfy";
|
||||||
// import env from "../lib/env-vars";
|
// import env from "../lib/env-vars";
|
||||||
|
|
||||||
// TODO: ADD PROPER ERROR HANDLING THAT WILL RETURN JSON ALWAYS
|
// TODO: ADD PROPER ERROR HANDLING THAT WILL RETURN JSON ALWAYS
|
||||||
|
|
||||||
function sendResponse(res: Response, payload: T.APIResponse) {
|
function sendResponse(res: Response, payload: T.APIResponse) {
|
||||||
return res.send(payload);
|
return res.send(payload);
|
||||||
}
|
}
|
||||||
|
|
||||||
const feedbackRouter = express.Router();
|
const feedbackRouter = express.Router();
|
||||||
|
@ -15,22 +16,25 @@ const feedbackRouter = express.Router();
|
||||||
* receives a piece of feedback
|
* receives a piece of feedback
|
||||||
*/
|
*/
|
||||||
feedbackRouter.put("/", (req, res, next) => {
|
feedbackRouter.put("/", (req, res, next) => {
|
||||||
const { anonymous, ...feedback } = req.body;
|
const { anonymous, ...feedback } = req.body;
|
||||||
const user = anonymous
|
const user = anonymous
|
||||||
? "anonymous"
|
? "anonymous"
|
||||||
: req.user
|
: req.user
|
||||||
? req.user.name
|
? req.user.name
|
||||||
: "not logged in";
|
: "not logged in";
|
||||||
addFeedback({
|
addFeedback({
|
||||||
user,
|
user,
|
||||||
feedback,
|
feedback,
|
||||||
}).then(() => {
|
})
|
||||||
res.send({ ok: true, message: "feedback received" });
|
.then(() => {
|
||||||
}).catch((e) => {
|
ntfy(JSON.stringify(feedback));
|
||||||
console.error("error receiving feedback");
|
res.send({ ok: true, message: "feedback received" });
|
||||||
console.error("feedback missed", feedback);
|
})
|
||||||
console.error(e);
|
.catch((e) => {
|
||||||
next("error receiving feedback");
|
console.error("error receiving feedback");
|
||||||
|
console.error("feedback missed", feedback);
|
||||||
|
console.error(e);
|
||||||
|
next("error receiving feedback");
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue