Miroirs/fedipage
1
0
Fork 0
mirror of https://git.qoto.org/fedipage/fedipage.git synced 2024-11-17 07:48:21 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

Making an attempt to fix a bug where status create notifications occasionally resend themselves

Browse source
This commit is contained in:
Jeffrey Phillips Freeman 2023-10-13 20:25:59 -04:00
parent 3412316da2
commit aa2860c132
No known key found for this signature in database
GPG key ID: AD914585C9406B6A
1 changed files with 15 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
api/activitypub/sendNote.ts
View file

@ -36,18 +36,18 @@ export default async function (req: VercelRequest, res: VercelResponse) {
const configRef = configCollection.doc("config"); const configRef = configCollection.doc("config");
const config = await configRef.get(); const config = await configRef.get();
if (config.exists == false) { const configData = config.data();
let sentIds = [];
if ( (!config.exists) || (configData == undefined) ) {
// Config doesn't exist, make something // Config doesn't exist, make something
configRef.set({ configRef.set({
"sentIds": [], "sentIds": [],
"lastEpoch": "" "lastEpoch": ""
}); });
} } else {
if( configData.sentIds.length > 0 ) {
const configData = config.data(); sentIds.push(...configData.sentIds);
let sentIds = []; }
if (configData != undefined) {
sentIds.push(...configData.sentIds);
let lastEpoch = configData.lastEpoch; let lastEpoch = configData.lastEpoch;
let currentEpoch = new Date().getTime(); let currentEpoch = new Date().getTime();
let elapsed = currentEpoch - lastEpoch; let elapsed = currentEpoch - lastEpoch;
@ -56,6 +56,11 @@ export default async function (req: VercelRequest, res: VercelResponse) {
console.log("Function called too often, doing nothing"); console.log("Function called too often, doing nothing");
res.status(401).end("Function is rate limited, please wait") res.status(401).end("Function is rate limited, please wait")
return; return;
} else {
configRef.set({
"sentIds": sentIds,
"lastEpoch": new Date().getTime()
});
} }
} }
@ -87,7 +92,9 @@ export default async function (req: VercelRequest, res: VercelResponse) {
if (item.id != undefined && !sentIds.includes(item.id)) { if (item.id != undefined && !sentIds.includes(item.id)) {
if (item.object != undefined) { if (item.object != undefined) {
// We might not need this. // We might not need this.
item.object.published = (new Date()).toISOString(); if( (!item.object.published) || (item.object.published == undefined)) {
item.object.published = (new Date()).toISOString();
}
} }
console.log(`Sending to ${actorInbox}`); console.log(`Sending to ${actorInbox}`);