jake/jarv.is
jake/jarv.is
1
Fork 0
mirror of https://github.com/jakejarvis/jarv.is.git synced 2025-04-26 17:28:27 -04:00
Code Issues

only return { hits } from /api/hits

Browse Source
This commit is contained in:
Jake Jarvis 2022-06-09 10:58:42 -04:00
parent a2dc07a654
commit 31c1a070b1
Signed by: jake
GPG Key ID: 2B0C9CF251E69A39
1 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
pages/api/hits.ts
View File

@ -12,6 +12,13 @@ type PageStats = {
date?: string; date?: string;
}; };
type SiteStats = {
total: {
hits: number;
};
pages: PageStats[];
};
const handler = async (req: NextApiRequest, res: NextApiResponse) => { const handler = async (req: NextApiRequest, res: NextApiResponse) => {
try { try {
if (req.method !== "GET") { if (req.method !== "GET") {
@ -28,7 +35,7 @@ const handler = async (req: NextApiRequest, res: NextApiResponse) => {
if (slug) { if (slug) {
// increment this page's hits. retry 3 times in case of Fauna "contended transaction" error: // increment this page's hits. retry 3 times in case of Fauna "contended transaction" error:
// https://sentry.io/share/issue/9c60a58211954ed7a8dfbe289bd107b5/ // https://sentry.io/share/issue/9c60a58211954ed7a8dfbe289bd107b5/
const pageStats = await pRetry(() => incrementPageHits(slug, client), { const { hits } = await pRetry(() => incrementPageHits(slug, client), {
onFailedAttempt: (error) => { onFailedAttempt: (error) => {
console.warn(`Attempt ${error.attemptNumber} failed, trying again...`); console.warn(`Attempt ${error.attemptNumber} failed, trying again...`);
}, },
@ -40,7 +47,7 @@ const handler = async (req: NextApiRequest, res: NextApiResponse) => {
res.setHeader("Pragma", "no-cache"); res.setHeader("Pragma", "no-cache");
// return in JSON format // return in JSON format
return res.status(200).json(pageStats); return res.status(200).json({ hits });
} else { } else {
// return overall site stats if slug not specified // return overall site stats if slug not specified
const siteStats = await getSiteStats(client); const siteStats = await getSiteStats(client);
@ -63,7 +70,7 @@ const handler = async (req: NextApiRequest, res: NextApiResponse) => {
} }
}; };
const incrementPageHits = async (slug: string | string[], client: faunadb.Client) => { const incrementPageHits = async (slug: string | string[], client: faunadb.Client): Promise<PageStats> => {
const q = faunadb.query; const q = faunadb.query;
const result: { data: PageStats } = await client.query( const result: { data: PageStats } = await client.query(
q.Let( q.Let(
@ -97,18 +104,18 @@ const incrementPageHits = async (slug: string | string[], client: faunadb.Client
return result.data; return result.data;
}; };
const getSiteStats = async (client: faunadb.Client) => { const getSiteStats = async (client: faunadb.Client): Promise<SiteStats> => {
const notes = await getAllNotes(); const notes = await getAllNotes();
const q = faunadb.query; const q = faunadb.query;
const { data: pages }: { data: PageStats[] } = await client.query( const { data: pages }: { data: SiteStats["pages"] } = await client.query(
q.Map( q.Map(
q.Paginate(q.Documents(q.Collection("hits")), { size: 99 }), q.Paginate(q.Documents(q.Collection("hits")), { size: 99 }),
q.Lambda((x) => q.Select("data", q.Get(x))) q.Lambda((x) => q.Select("data", q.Get(x)))
) )
); );
const siteStats = { const siteStats: SiteStats = {
total: { hits: 0 }, total: { hits: 0 },
pages, pages,
}; };