analytics

src/server/workers/plausibleAnalyticsUtils.ts

@@ -0,0 +1,104 @@
+const PLAUSIBLE_API_KEY = process.env.PLAUSIBLE_API_KEY!; // Replace with your Plausible API key
+const PLAUSIBLE_SITE_ID = 'localhost'; // Replace with your registered site ID with Plausible
+const PLAUSIBLE_BASE_URL = 'https://plausible.apps.twoducks.dev/api'; //  This is a self-hosted Plausible instance. Replace with your own, or the cloud-based Plausible base URL (e.g. https://plausible.io/api)
+
+const headers = {
+  'Content-Type': 'application/json',
+  Authorization: `Bearer ${PLAUSIBLE_API_KEY}`,
+};
+
+type PageViewsResult = {
+  results: {
+    [key: string]: {
+      value: number;
+    };
+  };
+};
+
+type PageViewSourcesResult = {
+  results: [
+    {
+      source: string;
+      visitors: number;
+    }
+  ];
+};
+
+export async function getDailyPageViews() {
+  const totalViews = await getTotalPageViews();
+  const prevDayViewsChangePercent = await getPrevDayViewsChangePercent();
+
+  return {
+    totalViews,
+    prevDayViewsChangePercent,
+  };
+}
+
+async function getTotalPageViews() {
+  const response = await fetch(
+    `${PLAUSIBLE_BASE_URL}/v1/stats/aggregate?site_id=${PLAUSIBLE_SITE_ID}&metrics=pageviews`,
+    {
+      method: 'GET',
+      headers: headers,
+    }
+  );
+  if (!response.ok) {
+    throw new Error(`HTTP error! Status: ${response.status}`);
+  }
+  const json = (await response.json()) as PageViewsResult;
+
+  return json.results.pageviews.value;
+}
+
+async function getPrevDayViewsChangePercent() {
+  // Calculate today, yesterday, and the day before yesterday's dates
+  const today = new Date();
+  const yesterday = new Date(today.setDate(today.getDate() - 1)).toISOString().split('T')[0];
+  const dayBeforeYesterday = new Date(new Date().setDate(new Date().getDate() - 2)).toISOString().split('T')[0];
+
+  // Fetch page views for yesterday and the day before yesterday
+  const pageViewsYesterday = await getPageviewsForDate(yesterday);
+  const pageViewsDayBeforeYesterday = await getPageviewsForDate(dayBeforeYesterday);
+
+  console.table({
+    pageViewsYesterday,
+    pageViewsDayBeforeYesterday,
+    typeY: typeof pageViewsYesterday,
+    typeDBY: typeof pageViewsDayBeforeYesterday,
+  });
+
+  let change = 0;
+  if (pageViewsYesterday === 0 || pageViewsDayBeforeYesterday === 0) {
+    console.log('Page views are zero, so no percentage change');
+    return '0';
+  } else {
+    change = ((pageViewsYesterday - pageViewsDayBeforeYesterday) / pageViewsDayBeforeYesterday) * 100;
+  }
+  return change.toFixed(2);
+}
+
+async function getPageviewsForDate(date: string) {
+  const url = `${PLAUSIBLE_BASE_URL}/v1/stats/aggregate?site_id=${PLAUSIBLE_SITE_ID}&period=day&date=${date}&metrics=pageviews`;
+  const response = await fetch(url, {
+    method: 'GET',
+    headers: headers,
+  });
+  if (!response.ok) {
+    throw new Error(`HTTP error! Status: ${response.status}`);
+  }
+  const data = (await response.json()) as PageViewsResult;
+  return data.results.pageviews.value;
+}
+
+export async function getSources() {
+  const url = `${PLAUSIBLE_BASE_URL}/v1/stats/breakdown?site_id=${PLAUSIBLE_SITE_ID}&property=visit:source&metrics=visitors`;
+  const response = await fetch(url, {
+    method: 'GET',
+    headers: headers,
+  });
+  if (!response.ok) {
+    throw new Error(`HTTP error! Status: ${response.status}`);
+  }
+  const data = (await response.json()) as PageViewSourcesResult;
+  return data.results;
+}