wkc/no-twitter-bot-stats
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added documentation, info and debug logs, and moved mutation key check to a reusable function. #4

Merged
werewolfkid merged 1 commits from debug-resolver into main 2026-05-09 19:37:45 -04:00
Conversation 0 Commits 1 Files Changed 2
+156 -54
2 changed files with 156 additions and 54 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 56bc0b3334 - Show all commits
src/graphql/resolvers.ts
+155 -54
View File
@@ -4,13 +4,29 @@ import { BigIntResolver } from "graphql-scalars";
const envMutationKey = process.env.MUTATION_KEY || "";
const env = process.env.NODE_ENV || "development";
/**
* Check if a date provided is the current date.
* @param date the date to check.
* @returns boolean.
*/
const isDailyStatToday = (date: string): boolean => {
// Create a new date object and set the time to 00:00:00:00
const today = new Date().setHours(0, 0, 0, 0);
// Create a new date object using the argument date and set the time to 00:00:00:00
const dailyStatCreated = new Date(date).setHours(0, 0, 0, 0);
return today == dailyStatCreated;
console.info(
`[DEBUG]: today's date: ${new Date(today).toDateString()}; document creation date: ${new Date(dailyStatCreated).toDateString()}`
);
// return the logic check of the two dates.
return today === dailyStatCreated;
};
/**
* Fetches the latest DailyStats document form the database.
* @returns DailyStat object
*/
const getLatestDailyStat = async () => {
return await prisma.dailyStats.findFirst({
orderBy: {
@@ -19,6 +35,44 @@ const getLatestDailyStat = async () => {
});
};
/**
* Checks if a provided key is valid.
* @param providedKey @type {string} the key provided by the request.
* @returns boolean
*/
const mutationKeyCheck = (providedKey?: string): boolean => {
let flag = false;
if (envMutationKey.length === 0) {
console.info(
"[INFO] MUTATION KEY CHECK: FAILED - environment key not set."
);
return flag;
}
if (providedKey === undefined || providedKey.length === 0) {
console.info(
"[INFO] MUTATION KEY CHECK: FAILED - no mutation key provided."
);
return flag;
}
// If provided mutation key is invalid.
if (providedKey !== envMutationKey) {
console.info(
"[INFO] MUTATION KEY CHECK: FAILED - mutation key check has failed."
);
return flag;
}
// If provided key is valid
if (providedKey === envMutationKey) {
return true;
}
return flag;
};
// Prisma
export const resolvers = {
// scalars
@@ -40,7 +94,7 @@ export const resolvers = {
if (!startDate || !endDate) {
console.info(
"GET STATS RANGE: REFUSED - one or both dates not provided."
"[INFO] GET STATS RANGE: REFUSED - one or both dates not provided."
);
return null;
}
@@ -84,15 +138,9 @@ export const resolvers = {
// If env is not development check for the mutation key.
if (env !== "development") {
// If mutation key was not provided.
if (!mutationKey) {
console.info("INIT: REFUSED - no mutation key was provided.");
return null;
}
// If provided mutation key is invalid.
if (mutationKey !== envMutationKey) {
console.info("INIT: REFUSED - mutation key provided was incorrect.");
if (!mutationKeyCheck(mutationKey)) {
console.info("[INFO] INIT: REFUSED - mutation key check has failed.");
return null;
}
}
@@ -104,20 +152,20 @@ export const resolvers = {
// Check for daily stats document count.
if ((await prisma.dailyStats.count()) === 0) {
// Make a daily stats document.
console.info("INIT: created new document");
console.info("[INFO] INIT: created new document");
await prisma.dailyStats.create({ data: { createdAt: createdAtDate } });
newTablesCount++;
}
// Check for a total stats document.
if ((await prisma.totalStats.count()) === 0) {
// Make the total stats document.
console.info("INIT: created new document");
console.info("[INFO] INIT: created new document");
await prisma.totalStats.create({ data: { createdAt: createdAtDate } });
newTablesCount++;
}
console.info(
`INIT: ${newTablesCount} tables have been initialized with data.`
`[INFO] INIT: ${newTablesCount} tables have been initialized with data.`
);
return `${newTablesCount} tables have been initialized with data.`;
},
@@ -130,16 +178,10 @@ export const resolvers = {
// If env is not development check for the mutation key.
if (env !== "development") {
// If mutation key was not provided.
if (!mutationKey) {
console.info("CRONJOB: REFUSED - no mutation key was provided.");
return null;
}
// If provided mutation key is invalid.
if (mutationKey !== envMutationKey) {
if (!mutationKeyCheck(mutationKey)) {
console.info(
"CRONJOB: REFUSED - mutation key provided was incorrect."
"[INFO] CRONJOB: REFUSED - mutation key check has failed."
);
return null;
}
@@ -151,7 +193,9 @@ export const resolvers = {
if (latestDailyStats !== null) {
// Check if the latest document is for today.
if (isDailyStatToday(String(latestDailyStats.createdAt))) {
console.info("Cron job refused: latest document is current date.");
console.info(
"[INFO] Cron job refused: latest document is current date."
);
return null;
}
}
@@ -191,7 +235,7 @@ export const resolvers = {
});
// Update the total stats document with the new total.
console.info("CRONJOB: Creating new document.");
console.info("[INFO] CRONJOB: Creating new document.");
return await prisma.totalStats.update({
where: {
createdAt: totalStats?.createdAt
@@ -216,16 +260,10 @@ export const resolvers = {
// If env is not development check for the mutation key.
if (env !== "development") {
// If mutation key was not provided.
if (!mutationKey) {
console.info("ADD GROUP: REFUSED - no mutation key was provided.");
return null;
}
// If provided mutation key is invalid.
if (mutationKey !== envMutationKey) {
if (!mutationKeyCheck(mutationKey)) {
console.info(
"ADD GROUP: REFUSED - mutation key provided was incorrect."
"[INFO] ADD GROUP: REFUSED - mutation key check has failed."
);
return null;
}
@@ -244,7 +282,7 @@ export const resolvers = {
existingGroup.username !== groupUsername
) {
// Return the document after updating the details.
console.info("ADD GROUP: Updated group document.");
console.info("[INFO] ADD GROUP: Updated group document.");
return await prisma.groups.update({
where: {
telegramID: existingGroup.telegramID
@@ -258,7 +296,7 @@ export const resolvers = {
}
// Return document after creating one for the group.
console.info("ADD GROUP: Created new group document.");
console.info("[INFO] ADD GROUP: Created new group document.");
return await prisma.groups.create({
data: {
telegramID: groupIDInt,
@@ -275,25 +313,17 @@ export const resolvers = {
// If env is not development check for the mutation key.
if (env !== "development") {
// If mutation key was not provided.
if (!mutationKey) {
console.info(
"INCREMENT GROUP: REFUSED - no mutation key was provided."
);
return null;
}
// If provided mutation key is invalid.
if (mutationKey !== envMutationKey) {
if (!mutationKeyCheck(mutationKey)) {
console.info(
"INCREMENT GROUP: REFUSED - mutation key provided was incorrect."
"[INFO] INCREMENT GROUP: REFUSED - mutation key provided was incorrect."
);
return null;
}
}
// Return updated group document after incrementing it.
console.info("INCREMENT GROUP: Incremented group document.");
console.info("[INFO] INCREMENT GROUP: Incremented group document.");
return await prisma.groups.update({
where: { telegramID: BigInt(groupID) },
data: { linksDeleted: { increment: linksDeleted } }
@@ -313,16 +343,10 @@ export const resolvers = {
// If env is not development check for the mutation key.
if (env !== "development") {
// If mutation key was not provided.
if (!mutationKey) {
console.info("INCREMENT: REFUSED - no mutation key was provided.");
return null;
}
// If provided mutation key is invalid.
if (mutationKey !== envMutationKey) {
if (!mutationKeyCheck(mutationKey)) {
console.info(
"INCREMENT: REFUSED - mutation key provided was incorrect."
"[INFO] INCREMENT: REFUSED - mutation key check has failed."
);
return null;
}
@@ -336,7 +360,7 @@ export const resolvers = {
// Check if the latest document is for today.
if (!isDailyStatToday(String(latestDailyStats.createdAt))) {
// Create new daily stats document.
console.info("INCREMENT: Created new document.");
console.info("[INFO] INCREMENT: Created new document.");
const date = new Date().toISOString();
await prisma.dailyStats
.create({ data: { createdAt: date } })
@@ -350,7 +374,9 @@ export const resolvers = {
}
// Return latest daily stats after incrementing it.
console.info("INCREMENT: Incremented information on today's document.");
console.info(
"[INFO] INCREMENT: Incremented information on today's document."
);
return await prisma.dailyStats.update({
where: { createdAt: latestDailyStats.createdAt },
data: {
@@ -361,6 +387,81 @@ export const resolvers = {
});
}
}
// debug: async (
// _parent: unknown,
// data: { mutationKey?: string }
// // _ctx: unknown
// ) => {
// const { mutationKey } = data;
// // If env is not development check for the mutation key.
// if (env !== "development") {
// // If provided mutation key is invalid.
// if (!mutationKeyCheck(mutationKey)) {
// console.info(
// "[DEBUG] CRONJOB: REFUSED - mutation key check has failed."
// );
// return null;
// }
// }
// const latestDailyStats = await getLatestDailyStat();
// // If there is a daily stats documents.S
// if (latestDailyStats !== null) {
// // Check if the latest document is for today.
// if (isDailyStatToday(String(latestDailyStats.createdAt))) {
// console.info("[DEBUG]: latest document is current date.");
// return null;
// }
// }
// // Create new daily stats document.
// // const createdAtDate = new Date().toISOString();
// // await prisma.dailyStats.create({ data: { createdAt: createdAtDate } });
// // Get every daily stats documents.
// // const allStats = await prisma.dailyStats.findMany({});
// // Add all stats into one object.
// // const calculatedStats = allStats.reduce(
// // (acc, curr) => {
// // const links = (acc.linksDeleted += curr.linksDeleted);
// // const commands = (acc.commandResponses += curr.commandResponses);
// // const triggers = (acc.timesTriggered += curr.timesTriggered);
// // return {
// // linksDeleted: links,
// // commandResponses: commands,
// // timesTriggered: triggers
// // };
// // },
// // {
// // linksDeleted: 0,
// // commandResponses: 0,
// // timesTriggered: 0
// // }
// // );
// // Take the total stats document.
// const totalStats = await prisma.totalStats.findFirst({
// orderBy: {
// createdAt: "desc"
// }
// });
// // Update the total stats document with the new total.
// console.info("[DEBUG]: Creating new document.");
// // return await prisma.totalStats.update({
// // where: {
// // createdAt: totalStats?.createdAt
// // },
// // data: {
// // ...calculatedStats
// // }
// // });
// return totalStats;
// }
}
};
src/graphql/types.ts
+1
View File
@@ -14,6 +14,7 @@ const typeDefs = /* GraphQL */ `
type Mutation {
init(mutationKey: String): String!
cronJob(mutationKey: String): TotalStats
# debug(mutationKey: String): TotalStats
addGroup(
groupID: String!
groupName: String!