mirror of
https://git.sr.ht/~cadence/cloudtube
synced 2024-11-12 19:37:29 +00:00
57 lines
1.5 KiB
JavaScript
57 lines
1.5 KiB
JavaScript
|
const {redirect} = require("pinski/plugins")
|
||
|
const db = require("./utils/db")
|
||
|
const constants = require("./utils/constants")
|
||
|
const {getToken} = require("./utils/getuser")
|
||
|
const validate = require("./utils/validate")
|
||
|
const V = validate.V
|
||
|
const {fetchChannel} = require("./utils/youtube")
|
||
|
|
||
|
module.exports = [
|
||
|
{
|
||
|
route: `/formapi/(un|)subscribe/(${constants.regex.ucid})`, methods: ["POST"], upload: true, code: async ({req, fill, body}) => {
|
||
|
const add = !fill[0]
|
||
|
const ucid = fill[1]
|
||
|
|
||
|
return new V()
|
||
|
.with(validate.presetLoad({body}))
|
||
|
.with(validate.presetURLParamsBody())
|
||
|
.last(async state => {
|
||
|
const {params} = state
|
||
|
const responseHeaders = {}
|
||
|
const token = getToken(req, responseHeaders)
|
||
|
|
||
|
if (add) {
|
||
|
await fetchChannel(ucid)
|
||
|
db.prepare("INSERT OR IGNORE INTO Subscriptions (token, ucid) VALUES (?, ?)").run(token, ucid)
|
||
|
} else {
|
||
|
db.prepare("DELETE FROM Subscriptions WHERE token = ? AND ucid = ?").run(token, ucid)
|
||
|
}
|
||
|
|
||
|
if (params.has("referrer")) {
|
||
|
return {
|
||
|
statusCode: 303,
|
||
|
contentType: "application/json",
|
||
|
headers: Object.assign(responseHeaders, {
|
||
|
Location: params.get("referrer")
|
||
|
}),
|
||
|
content: {
|
||
|
status: "ok"
|
||
|
}
|
||
|
}
|
||
|
return redirect(params.get("referrer"), 303)
|
||
|
} else {
|
||
|
return {
|
||
|
statusCode: 200,
|
||
|
contentType: "application/json",
|
||
|
headers: responseHeaders,
|
||
|
content: {
|
||
|
status: "ok"
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
})
|
||
|
.go()
|
||
|
}
|
||
|
}
|
||
|
]
|