feat: restore artist charts

package.json

@@ -1,6 +1,6 @@
 {
   "name": "coryd.dev",
-  "version": "14.3.0",
+  "version": "14.4.0",
   "description": "The source for my personal site. Built using 11ty.",
   "type": "module",
   "scripts": {
@@ -37,7 +37,7 @@
     "@11ty/eleventy-plugin-rss": "^1.2.0",
     "@11ty/eleventy-plugin-syntaxhighlight": "^5.0.0",
     "@11tyrocks/eleventy-plugin-lightningcss": "^1.4.0",
-    "@aws-sdk/client-s3": "^3.574.0",
+    "@aws-sdk/client-s3": "^3.575.0",
     "@cdransf/eleventy-plugin-tabler-icons": "^1.3.0",
     "@supabase/supabase-js": "^2.43.1",
     "dotenv-flow": "^4.1.0",

src/_data/weeklyArtistChart.js

@@ -0,0 +1,111 @@
+import { createClient } from '@supabase/supabase-js';
+import { DateTime } from 'luxon'
+
+const SUPABASE_URL = process.env.SUPABASE_URL
+const SUPABASE_KEY = process.env.SUPABASE_KEY
+const supabase = createClient(SUPABASE_URL, SUPABASE_KEY)
+
+const aggregateData = (data) => {
+  const aggregation = {}
+  data.forEach(item => {
+    const key = item['artist_name']
+    if (!aggregation[key]) {
+      aggregation[key] = {
+        name: item['artist_name'],
+        genre: item['artists']['genre'],
+        mbid: item['artists']['mbid'],
+        plays: 0
+      }
+    }
+    aggregation[key].plays++
+  })
+  return Object.values(aggregation).sort((a, b) => b.plays - a.plays).slice(0, 8)
+}
+
+const formatData = (data) => {
+  let content = 'My top artists for the week: '
+  let description = '<p>My top artists for the last week:</p><ul>'
+  data.forEach((artist, index) => {
+    content += `${artist['name']} @ ${artist['plays']} play${parseInt(artist['plays']) > 1 ? 's' : ''}`
+    description+= `<li>${artist['name']} @ ${artist['plays']} • ${artist['genre']}</li>`
+    if (index !== data.length - 1) content += ', '
+  })
+  description += '</ul><br/><br/>'
+  return { content, description }
+}
+
+export default async function() {
+  try {
+    const now = DateTime.now()
+
+    if (now.weekday !== 1) return // only run on monday
+
+    const startOfWeek = now.minus({ days: now.weekday + 1 }).startOf('day')
+    const endOfWeek = now.minus({ days: now.weekday - 5 }).endOf('day')
+    const startOfWeekSeconds = startOfWeek.toSeconds()
+    const endOfWeekSeconds = endOfWeek.toSeconds()
+    const weekNumber = now.toFormat('kkkk-WW')
+
+    let { data: existingRecord } = await supabase
+      .from('weekly_charts')
+      .select('*')
+      .eq('week', weekNumber)
+      .single();
+
+    if (existingRecord) {
+      const formattedData = formatData(JSON.parse(existingRecord['data']))
+      return [{
+        title: formattedData['content'],
+        description: formattedData['description'],
+        url: `https://coryd.dev/now?ts=${existingRecord['week']}#artists`,
+        date: existingRecord['date']
+      }]
+    }
+
+    // Fetch the listens data for the past week
+    let { data: listens, error } = await supabase
+      .from('listens')
+      .select(`
+        listened_at,
+        track_name,
+        artist_name,
+        artists(mbid, genre)
+        `)
+      .gte('listened_at', startOfWeekSeconds)
+      .lte('listened_at', endOfWeekSeconds)
+
+    if (error) throw error
+
+    const aggregatedData = aggregateData(listens)
+    const artistNames = aggregatedData.map(artist => artist.name)
+    let { data: artistsData, error: artistsError } = await supabase
+      .from('artists')
+      .select('name_string, genre, mbid')
+      .in('name_string', artistNames)
+
+    if (artistsError) throw artistsError
+
+    const topArtists = aggregatedData.map(artist => {
+      return {
+        name: artist.name,
+        genre: artist?.genre || '',
+        plays: artist.plays,
+        mbid: artist?.mbid || ''
+      }
+    })
+
+    const { error: insertError } = await supabase
+      .from('weekly_charts')
+      .insert([{ week: weekNumber, date: now.toISODate(), data: JSON.stringify(topArtists) }])
+    if (insertError) throw insertError
+    const formattedData = formatData(topArtists)
+    return [{
+      title: formattedData['content'],
+      description: formattedData['description'],
+      url: `https://coryd.dev/now?ts=${weekNumber}#artists`,
+      date: now.toISODate()
+    }]
+  } catch (error) {
+    console.error('Error:', error.message)
+  }
+}

src/feeds/weekly-artist-chart.liquid

@@ -0,0 +1,13 @@
+---
+layout: null
+eleventyExcludeFromCollections: true
+permalink: /feeds/weekly-artist-chart
+---
+{% render "partials/feeds/rss.liquid"
+  permalink:"/feeds/weekly-artist-chart"
+  title:"Weekly artist chart • Cory Dransfeldt"
+  description:"The top 8 artists I've listened to this week."
+  data:weeklyArtistChart
+  updated:weeklyArtistChart[0].date
+  site:site
+%}