From 58c1147e8352849ac70f526990bb46a054517387 Mon Sep 17 00:00:00 2001 From: Cory Dransfeldt Date: Wed, 8 May 2024 12:37:27 -0700 Subject: [PATCH] chore: post --- api/scrobble.js | 32 +- config/data/tag-aliases.js | 3 + .../partials/now/tracks-recent.liquid | 2 +- ...sted-scrobbling-implementation-preview.png | Bin 0 -> 33308 bytes ...ail-with-regex-filters-now-with-chatgpt.md | 2 +- ...y-self-hosted-scrobbling-implementation.md | 339 ++++++++++++++++++ 6 files changed, 372 insertions(+), 6 deletions(-) create mode 100644 src/assets/img/ogi/improving-my-self-hosted-scrobbling-implementation-preview.png create mode 100644 src/posts/2024/improving-my-self-hosted-scrobbling-implementation.md diff --git a/api/scrobble.js b/api/scrobble.js index c72dc5b1..b160c9c7 100644 --- a/api/scrobble.js +++ b/api/scrobble.js @@ -33,12 +33,10 @@ export default async (request) => { .single() if (albumError && albumError.code === 'PGRST116') { - const albumImageUrl = `https://coryd.dev/media/albums/${albumKey}.jpg` - const albumMBID = null const { error: insertAlbumError } = await supabase.from('albums').insert([ { - mbid: albumMBID, - image: albumImageUrl, + mbid: null, + image: `https://coryd.dev/media/albums/${albumKey}.jpg`, key: albumKey, name: album, tentative: true @@ -54,6 +52,32 @@ export default async (request) => { return new Response(JSON.stringify({ status: 'error', message: albumError.message }), { headers: { "Content-Type": "application/json" } }) } + const { data: artistData, error: artistError } = await supabase + .from('artists') + .select('*') + .eq('key', artistKey) + .single() + + if (artistError && artistError.code === 'PGRST116') { + const { error: insertArtistError } = await supabase.from('artists').insert([ + { + mbid: null, + image: `https://coryd.dev/media/artists/${artistKey}.jpg`, + key: albumKey, + name: album, + tentative: true + } + ]) + + if (insertArtistError) { + console.error('Error inserting artist into Supabase:', insertArtistError.message) + return new Response(JSON.stringify({ status: 'error', message: insertArtistError.message }), { headers: { "Content-Type": "application/json" } }) + } + } else if (artistError) { + console.error('Error querying artist from Supabase:', artistError.message) + return new Response(JSON.stringify({ status: 'error', message: artistError.message }), { headers: { "Content-Type": "application/json" } }) + } + const { error: listenError } = await supabase.from('listens').insert([ { artist_name: artist, diff --git a/config/data/tag-aliases.js b/config/data/tag-aliases.js index 796969ca..97cf298d 100644 --- a/config/data/tag-aliases.js +++ b/config/data/tag-aliases.js @@ -34,9 +34,11 @@ export default { macos: '#macOS #Apple', mastodon: '#Mastodon', music: '#Music', + musicbrainz: '#MusicBrainz', mystery: '#Mystery', netlify: '#Netlify', nonfiction: '#NonFiction', + plex: '#Plex', politics: '#Politics', privacy: '#Privacy', productivity: '#Productivity', @@ -49,6 +51,7 @@ export default { 'social media': '#SocialMedia', sports: '#Sports', spotify: '#Music', + supabase: '#Supabase', 'surveillance capitalism': '#SurveillanceCapitalism', 'tattoos': '#Tattoos', tech: '#Tech', diff --git a/src/_includes/partials/now/tracks-recent.liquid b/src/_includes/partials/now/tracks-recent.liquid index 0c51649e..49e1cac0 100644 --- a/src/_includes/partials/now/tracks-recent.liquid +++ b/src/_includes/partials/now/tracks-recent.liquid @@ -4,7 +4,7 @@ {% capture alt %}{{ item.title | escape }} by {{ item.artist }}{% endcapture %}
- {{ alt }} + {{ alt }}
{{ item.title }}
diff --git a/src/assets/img/ogi/improving-my-self-hosted-scrobbling-implementation-preview.png b/src/assets/img/ogi/improving-my-self-hosted-scrobbling-implementation-preview.png new file mode 100644 index 0000000000000000000000000000000000000000..1352ca5cbd55a465006083ee6492f1ae323efa33 GIT binary patch literal 33308 zcmeFZXIxX++BXcSh$0{&pdg@FP>O&^kt#Z%QWd30F9K2{y@UW(1cW#uy;>0Iolp~$ zl2NLmw?v6_LX1EHgoI~pz2}@W&bfc@`}KL>`Jf_@?47mOy2`&?(N~QwaqSk`&BDUM zb>;GJCM+!5%UD?00y)^hcZ|=&t-(LL?p(g<$HKzN2mN7XNy|9E!g849%5T~?f-@E; zI2#+UH)(x4f_iK{ANBmkS2M|EahlchS;0%MpPf9%ud~bMir(aG__?_YzWSM$j~fXd zfB3*ePf+BN_yt^3(bj_6j3QkN9`4blUP)VIbXL;fO|}b(;c#-QA|a$lp(o6xc(uy1 z*bFxi$;y7f{+GXU6w!)r5iIpWa?LE;_WbhKF;;=?+}nTsu3YnZ_uE|VVv!~6fBzB7 zwkwf4?rvlK+k4496|%fPx-+Nnzx=5A{62f_&*%Tk9lU-tm_ucqb^k9vl6$({Vz0{H zUv3%tZ~lvaJ`#8`|2(Cid*h#t_w$(kbC!MvrGLW1k4XPdc=#tg{AZT_Cp`QU9{!`u z`X@a6UmqUWq&W_8{H@}TylZyd<0_rSU-8#o0BQ{`|8Fnq?-lCTWU=A;`}?u7KV#u! z+sXF#=Hjqo6?-+$dGl?5|54=KW6k%P@BY$_{I~+gJdPbD@^#z^6YFw9l|?;j-c0)}i*YjjQl>DxnJj*6{c z-k21`q?FXp7x<4jCs%K6c{h-f1nj~nFGO29Y^fEyluJXpJlsq3{{{sVhq~u{>nnZ- z-ng`X!j}0x*?7}4KQ~D)Vv{H)!PxxP!UJ363~%E%Hz2Hc2btvCAXW$F9C+XsB%-xn zmtvpR)_PBWsZG#CfLn3(pyVU}Y{sH%Wdto5vzaUMd6n69J$s{HM|!1(qqksirmhFE z^cn*`7Tlw>@PE4*ZP;xe=K2h{kufin&9TJ5!;T2- zR&SK%S;n+7CUqr@C#^BHDACQ_KLe~2~A&G$=Rv#mQjhqFi3tUnk}6ZO;2>W zhi=gcgsk7I-|v=s9n`d7!?(q3-p2F#lKLcX^-c@k!)?Crz?EKVypm)xt|3EjY|NWu zROi+oPd%835LS4-gxO+7XGbij6AX+)aS5XxyT}b>baVvrpk))Q*>FcY$^T<%=8u%vVV({Y~H|XF@I;$BDPQrLOKi`LU%1E zn^b|X>R^$pPovb2c~y2Pxn(1$S4xB1q;T(cijCtHPF;9~C)k9qPmQq}=E*j#;6{Af zzSnk>Tk!^chz#EC0i)o-D)QoVkY&?@R7NJP|4~m7Qn!A}Zgp3ma@?nxnrb#y)W)RS#vYs9ieb(^@6w zDxJDeWe0Y7?B?brt&LBuJ!-7@S}L@O`J6N;t$Y%UB6{6?cn0qwyl;n0!n~#8TTadi zQdtXk2h&!)M~g9MJcjY>GgQvK$bIg&NJVzrU-PqNz|hazmU1x)P+Guyls28X_n6~~ zFY6#tY-{aCZd>9?Jz1e7X2`8PKa`w;|Mp1PV06oEz|=gGN_>)Piz0->=}JU-?6bP1 zgSwQpR}+3c8VN2Z;;aaFTDT+zYJx6O$p|u>PfLy5xO{@i&>)BOi1+AsCKdW-L*IIh z83X6P0y8uMmvXW90ug8~avS$v`?$LYf2j-ZnoU3uoS$TK3?p9k#iyIDnFCBR5}bVm zSYKy;`Y96Ft)!bqy;I}{-Opscyq|*8m(6_JB@#4VetCGXY5(_EVvO5# zg3^S4AJwy-gS&zDPW8(JKFJ*sL$+{ID`7mC7?+S_7r4Qfz1CWjemgHS(2`ErZn2vF z>6gmmcHBh(b~b11E}NY91qT);;c`j`4mOwdo-)U6E5jD*K@H`yW;AxnM8|-*{~Wi8 zW4q~$Yv$hKKI*t%&+nS};lhQQF>k9|N+z9+qaeb1L}+fT9!0AA;!=)2U0`GmKfv@E zott_dIPBl0I8@b=E1~{n7heyoiiV~&Z6h!DUpLNNV+3nDxtNm4tq6aY@HSEq6}QiR z0H*s(ZIz?Q{pZ4Oi77m*x9W_S++mSW___fims);S?#OkY ztt0u<3xX`I6Xlr2`|Uw^D=bB;nz}Wam&7_hnvh8nqk6w#f+c|6Li&O9lUWtL zE{Oj2kou(1Rh@W{R8|bXX-o6P`pou(O)HG)D;D-2Zzs6%>gwk3n{NyIc3*6qxeii- z8f7`bShFrzt^8P(pW?gQm&6eMRGK5Zt;E@e&-XY_FbpD1F(SY2;6ass=(yFfNV%K} zaJkx6RA3TW{q>oC4ejE*7luAT9yQ0r;zc4`J+tt1G;?D?BAnSBgjOiVFgFssJ&1A2 zq9epb?rFz5tIk6Uo6<=};Y49V%38>b5Aq@b!~hBE?EK;t0ip~e+_RqGmbrmFv6zV+ zsjIkErQ9@UI5IZugw!~pRE?xkQJALS2u{J%8EZ|$Qc~b`E8xIm`LtrkVk6WTD}5gS zEdh@d-@S)aZT`3lmRTXW-s-^x5HYB&1Zfb;wt-WaIN$~)=RO~-h%#l%DW7mMn=owA zXm`i2mG_dt=H_B$k7(@uo1J>GO?CCy#If^D4G~jPcBw0k86nfDd|Fl@OG_}Mla5oF z2x|v9rCM@TZKwl=zQA2pP?f@E7Gx9fYlm^W%bRO|V+l(kT=#m_L=XXiBNU<_k+TDU}CcL9qv6O&zKY+4n69hG8}4{;Ww( zPl33>pOTt8B=gmn<)E%j4-M!ZlHG1_{knqx#29)wywaR$LtWRAEPzNZ{zKBE`% z$*HFhN`1J2b?O)lbHxd<-0nV#*d}u_CTBfBS z1oYJ#tjGh$v_MH@itgcfQ=rbBUaO{gPFLYS5CWEMGKzcc2M*fnY~hm8H};(K1{vXs z@S|k5A`a_t5U-6l#+s<39=eg2h85nnb-oHmeG;~B+gIAgz)SmXleef}I#1?&}T^a53S@SwpEMgOcd<1QRbljgPV6Q`PjFmZI zv!iVJP{c-Gc6a>99%<}8?DfC4sdtlDJWd~d%qW;Fc+eBl?f0e%`^h=kM#+u%Emaiu z;70lOGfG(ma7aht3Z^56H8z6K%b93%g+nOOo=fW8AQj2WSd`^ZDSxA{deb7HD7|sk z<6DudhKKmx(9d^w;u5k}UY8foeeaOXW-@6Q6gCuuo{;37{GcEl?YyS)>|AdNvLdAbn8~;c|{)dnFNA>b!A^xAk z!ydUZfN=UxMoXN=ncsBguU_78_>*sFA8u9}^Gwh{S^*5zT`V2yP2VNriZ2{Rs6gd>yqx(PEgliCsp+s z-Q?4kF8__>)aQy}Z&<9*AG~5`)UsUUjC>4wE8aT-HgBm&dxYc(jDyHs7|o6mdP zP>giDp=eQNuN}JRB&JpjYUIL}uCL2`ecxxEttfxU z2=wK4p!K=kl?b?}$a8%=ELOF4`c-q5%|~#rOb_NPv3N9)YJ}&RJ1n~9Br@(?pq?AQ zm0;*DHg>X}rI0yepHa`^F%On$fNTzc5=*~aKu6hk`?H!cdfr)+pi6CQs#AQc)+{L# z%WJQQ`T5Qxg?E3xETmY~?BA=q*S`Gh_0qg3jYWqMjlLvn-zz&WE*(gDc^AS|D)-sj zL@-uI=pi5UZJ(K0I6N#5VJ_ZP4C?~R(lFp!%5KPArpHjmtalYH-d%;TVz{Va$J2vU zRTr=+EnE6oQmzerhA{Vf`ci}7+}7rdmSBiq80ZWtFmM1{Z|gh;5`tV5TM>b=6cjs- zjZ?;}1oo7(c&w%EDw_`~?6KwAZqXRhBoCry@dm_)O^0m(2)p8ssASL|R8oC@;GoMR z&7M0fB0!%YP=|zt5rwO@nE2DpLTDGT9uxDG=G#~WV74$wKvu~7vF-%dGtHLZ!}W#J zNy(sdMCl~GY<<2otiA@|zsvBYI#)}lI7Qux=U!NmAOl$dy!MI07k?K87)6i8gyW`h z$j9rWG(MUja_VX0Hhi|3Lv?ePScmV6UyUvT2?Y< z)bmI#LpDK%9kQ6s=P;?xHZKw1KaRK&5Hv$!uc~V#BrF9D9kk+_QOTxR9a(q!f+Ama z^pLIe4)|bYR-)+lr&0Zy(<4jQ5;!!o=;JeQ7&L;GNZ7Y`ZsaDKks7J$x+OUNy5Ci; zeA@W?pn$*x2TMl8zgOGs%ln6O0AvicbV+p<;I90qanP>LefrYBgZHSUmTP7a%Bld89q;L8C_OO(mTc^_9kn94nqWMsnMJM2 zt0wfN?X_<+d8HzX0Vm5-3^^Ihhn=6pFBKG)q-Cvly4E0RJ>k^KzE`5FZ`-{lMX@Pw zb;$B3yG;iHeEB&1+wkX#h^$AapW@gbE^BBv)p0MB+VVn$V{F%n@>i`9tV6v#qhEHyv z>9Aw^26kr795zZC1hBr#`9Iz(7`?%Z#R*FtX$l-3ZielkhQSgN2YvWvl16x`M3 z!z^i7viv&Zqbc-m!GBv(#1<_AmQMD9z{|0_lQ-@qUfXHmgI4bhvCe>V`O!f(;Ss2d ztL#?wz%8iGD8%~|7FFm?(RaPd2Is26uDNyJT0928?`P<>y1ZpSXu9GsuKh0KV42Oz zX>mk=e0HNhVAF4eJ)RGGxe7oedAL?x!aeZG>KTs&kC_4>l-IypHwR}0Kd>ltfL z53*9^WHc?f)U59G113=Y)osd=JL7CcYttI2Y^R`Dp3A0WsrL^G9!+k8H*y!)R*B=C zK%r6bVnLL4y}pa%vF?B-t*(bFY>zzgNHGrmB^Wg^Go)i z94OpAlglDyo1VLjTcSb<3-(99Y;#Objh^A7rrNHz+ln}{qTC<`>MAOmbCan5QYE7E zVbp{S`g!4Z&4XY10Mz!0Rx@cWVJk)s#;R3lm44rm`J<#uv*g-e;s(Or?G?K2IkeZ} z5MZ!sJojD$Y|h0ii2^Ved7H2TR`%(b zhJcN(qQq(z){;a|3X+uAqQtG`z*^K~jNUs2wyLmO$iI4RC%huG5GFi|xRBn^rQ)-M zdT`XJ)lcH}HDbNy`Sv~c^J^r<%A7tJpHe^6KlxSN-Db6%qpV&8q8P6Y~7U^fLBawd(XFpK!AguQtE8W8Wx z&CtQaSW=D;7pppYRr2AkOy{fj!9MCeb9-F}?4zvv)Ld|p^6eGwQadbiQ%y{*786W& z@AH-5DsRjsIK{EtNl6$}Wh>HlFbv}CU@RR)?>MAWsMb7BCBO!+gzfF@y7l;JElqPW zea3nLwJGD$K4qElb;w6L7Ur$5|K_C;6kbO=t~v=gFMWiAOREH01N_oWRp#Ee0_3Gg zQ<-L==>xnSZ#M?iU3?Am+I*+OL4tdtCxdsIyzh1Zq7Cc+@CZ7@Ry52hjUUVFo6I;8 zG$z07Je(SrTi(xaucLBRwKTdH)+_(kJ(3^3)3Dl50=%dC+x_;5c#ndrV6GLbG>hG3 zkK~0h!t|rueD)yZP!3EEYi6?*ImCY|U)9DeucRbu#hhqPWBgpY>pz#yV7rBUlh(bQ zVW&CF79CRwyDFb>#3kq}{)yv7k|e7cE!x3=5Fa^{D~oU=z(OZyuJ0-fH9kLS^~ZH% z4Mh>ZPI=PtARm*#)YRWO%N$FiOk(YiYpRecI!@0Gl!gbu5#e)R%d56byiZteKa@K+ zU+(7OoqE$18H>B(wRmM<%&F&o>h3aC8LCFKGot(~3Bz2##9#zV^x)NrmQS>ltmDp~ zpr#A?S159`nk`!KEASKVdw5GC!Y;=+3w@b-B)DHBU1TnnxZgg&Qo1Xi7ReE;ZkaHuGc+mmFBBl9!I;+s+@P0TvF^do^ z`*GsZ6WRHv9u!Tn^k-PQYa_d(U71SYSG0W$i$*tBLHDtx#&$=sN()^9l-fzTw}4WK z9sD{9ari5stqJ>`fOOKSoo|dX+g0Y+QyAXCe)M%5(Ng+ge3?Xdh~o)AEY+W_2tQ=f z$SqzKx119k{@&Cz(BO1)4A;6o36RoW7z{S#s^|J%Y>ssUgE}@QT+YJ>K4>Fza`;e3 zC%x;fEa?l_P^vO`{dkqh$AJu|?5=$2(u_G4srN6&7tmFz_WN1QP+cmzSQiH4-dh|( zx6EQx^hkF)aaasHJJhrkur2w(?lPCHwYP=Z9?T!K<+>&x*ifk6I#^W$=1UjiPB_WK z&gxuq4ByvUoIZ`Ldz&v^f~P^tG!d-W-segYPtKplXE>!H$UW$lTv=zBtc&yNQr+Gc z7fJVWeofAHG)Fb5Xqsvj%cEo}iY(k~##0uWocUk`xAQX)!iZau zac6Qk?!!wzAH?S144y6bXkpeerZ032zjA*1kmD`83?_Z9aBq8g_1VI*s(uxvtKHRW z?{jEDN6-FI&CwNFY9b(JLhsT9G}_09VXwb!jz0fQIJNLUuTs z-`r*grLH5&CAAads45DKK|M7mXy4{SF*SMuH+FP%(OpWPO({1O(qFuoNPlxm$+(LV z{zQsa?CC}>8jmW~hKmmH+P6hLA5TnmbfQ~#biIt`8yLT0IvzN8OkGnt-Y;_XfrPrl zV6YKmj7dsjvyGht$5cE36{4jztE`d|t4TLu%0Xr-pxr*RH{YKdt7dyjT zEc~YToI_P|)1q^t_p6mGbH(PEk(v87jGF0A_s6 z*C~Fv6epVAB&Y^0nc#6B?mjx*N7Hoomx4vCGGH^u1$R=~KFR5q>kE3uoL8gKDQPDa zSqD2sIRg}Lcai_6M;33Mw|yh1Z2*fsc!Y5;cHFs9pVbVbJQRDn{v=%)G_0SV15l&W zC`MFY9NY?pObeTa z<1@FUnh5n+dK8N~1eaU`&tX>u&(zjX|_87@?vyNw&BI8CTw?{4E1@11S zd6b+hte$J~wRUsUmX<9#!&lg^U+KmE&?z^k)c^fNKa132>(2gbRQyaKNNz3z?G@eD zv2qo(AV0g;zs06jGDL$s*D^fH$IsE|xlgBoSn5#lz_2Q)#t!&a?kZIIU=yJ1@-m?3 zQM8kL$*R?ofWix`OtWOyB)v^G{F5fP@f7DvNn}XBf*pN_Mcqh4-}=78N#m>ZhVe7Q zxMY@GmW5hkyzqwNp>&ElSDEij5d)tcwO-+Rdb>q=rcU<^AkWQ17Vf32W{&kKpo34w z9k01|(k8$%QqfWiu#3I(C9Hc5_W%-mXDbT9xR<^*-H4iclLa0a&X$8=bb{Ej2+pH7 zaiKs1ZTPWTTR0@CUF?hD63uSqrJ(c0ho)vXopI#0#Z2olx4g{u(*OiQNg`^Ij6Vt< zanun+&K`BL1`*8Jquja-)pq8O?jB+~9xtGO*^kDrAmmpmU9TnGiW;QE`FZmsj1=j^ zdb+5K8YOMEaz0@(k+)LD;ti|)It-`)@{1O|dnIgkZYh`LMb-Y=d{#5J^&x*tmPq5UOC?CUs_@5 zd~p6GTM?w;`-r+}Su#ZCYzy!B<|}vrlx&P{FFm@`vHbPx9;U^^>W& zI;)(88^G-NWxd9guh+2@t`v9YNa0)CD_Yns`ciG4ja}7z)6A3h-LBr(!R>y>Y_hfQ zhvtJ`bxj6uDtS5#*e!B-?zL>U@Nv#_NLu#~^=wx+2WK$|>_&ZSRr9_@Z-+O8XE_|f z^BcXx6GX}9xf+IgGD*i<wy!^p`iIz?|($j z6ct1J$&@@Fh2<}lWjT^tRHg^`?GsB%lrsmLI_p-PyKs+?#zj9b&{d@;vJ|?{f(I2H=-$@!=gzz%sh3+^M(T#Pc_e@ zN-d-x#y72mjzLli7>Hy`dBXOI7nX(^rxg)cK0A}CG!~DlZ~&+04A^Wt>{1T_r|dR{ zc`J{G$iJ2Ew_k0j=+DXGOq_h+(o0B8%3BeRu+GdwwGGs&Y9ZqcoUT~FtZMIk$>1t; zG_J`H^AHi{>H%F&XusTyBKiuqR^738*I^I{qMR&^5JK_71D0a*uUeO?S$YySLt%8Vs8+_xf6|E@I;-1Q)=Nzsm z>vllYoKIN1-y;X4c5ZIo{hFi0Abwp6-y=gBP#PHP>`IDdM6)w&=G05*j@qDe3GeW6 zIuTa#uo!fon5i5}+huR^n_4#C#QI%j%u??1TW5zRIqy2i7VR~RG$l~3ncp8AFNJXR z<)#my5$#h*OjufL*7A(x?_kNZBmz-nke0&YFAR?_(dK0K9A!@@d9E> z`V!T3y~-DwRM-u3v%|iBxDK>k(pnkDaQis%W=Wd?|K7#>xWzaeZU&!vP@eN_ybo&J zS3fuH2BTMPo~5wLQ^lp%U{$dUV4>U@&I-4)-{Y7{0Xr=+(cP*GuYq)?1~G+}#O4H( zmrxQnmSQSftUr0zvkvBHe0Y>8BZx%#?|5%SaLq3ciS-KxC9ES z6P+#LBcDe4B!?zd)E1Y^+J!u-2x?BRXtnO<`2pxBDL_rbHg8>6vFK%Xe(lwtS^!l+ zdr)-Bm&mDhvzh_ew`RxV)GTFuuoGn+(F4a{Z;ZqFu350DEkWma3AI^5K-+hof!{7jAX^7HK+afaa6rYQS6y3jTee9BU41n0*;Ls?`A0j)Lnq zJ@=_6Z!4Ngw$oITk}0t_9X(&;Z(6aw&z=OBqmhGp<>nn_>2Kq$kYzIQR(05Yl}o-6 zd~nRyB!9yIKa!-zg$!#o;9CHRH!V&x0pvu1_8iM(^s(rhNBcsGD4P4tJ3Fg!I}Z42 zxGThfHs$uTi!*mU+prw#?Gl@isYJxZB;39xpFL%vNNtK}f|aF!-TvpylCzx0mEy%{ zEK;Z@?W$UnsWQRq(K8yIH@M0+NC`JKUdo}cW>6qnQ3wi{y$yl7x%E@sBa=-Y=p7cH z$ekPZk$#Vx&05r{V_q{TP5-)27Z> zQ;ztjjNJqhxr#3rOPD@kr@B<69!42*l&NZT+l5+n)}CU7OQT|G->t`hNKR_Pb*_bJ zu+zdgY?3ebh_f3zEaT!=rSq~j&3XInZGi5xjs7^>bm9PJzda;qlsx@V+NP^^9)8K2 zXFyV6XxcH7zi@{yNo#9aOK^Q680{x`b^a`?nFdxJtmE>lA0*rghzTVk`&OusuOs%* zFd66}7s=E2vO!^>@{RyhsS*tD2N!Y!$PDzS%zO~Q!wS

UfS)-kqdgO6g`Q*Rh;1 z(u7-OSQ`$R@v#*Rp{dm)1SE^B((WZ`^OyvBO7UQ6R}?rA1MqsQMQw%j>e(Tu`wJ~R zT8-bMhAguB#~j^^-IQ*eHh4@l8Q|Gh{^WSc^x8;Ic+GdG7#>{(`Ifu}&L6Q@_GU?2 z)SGcZu3RZWsF9W$RJAPxtfBQjMaM5b_z6WcB7dW16t;9UVO{n++RMpohNU)sqxmrkCY5RiBVNg`uY z%_!6SaFMoM7w3daB?-1Y(3L)#WQ>P>Ju2oV%k}uCd3otYYumaN6?0(E&;#4M4{o)z zEjX+>-xp4aLl~^~tir;V)7ug{afB7k_*CvP$I7V`nXB$T-^CQH3OuXS>_EOJao5KT z`X^_{S73GPKRKSbw0M+H@gzbD-DjlcT>9n!VK~WKD=A^hvJ)3wCQH3I|6o)8zKqLK zD}UAGaDUTGmmI6vY5%3hBqw!>LmjPJagqPSc8e{o{im9kkky0=I=Cm?<`mY#{w%Py z1U)8h3an+4!}1vQG9o=kSx)WXFF)&B57*a;y>nR8pSE!dVIRknUN>ams%s$48|$Py zqbO*X*5>&cpf#lohwl(&zs9hR1Y9MYA1hRO^(9kY*aJ$dfYI@oADRc?4PB;vaR9({ z)gmWXAHgz3v5&@WUCXWO2#DX}{K!+E9BWJ(U6+6hfOH)7>6JGOJ~oB}6wh+B2Im4O zMmy#v5hw67j&2@}?eBvdb@jfOG-mS%+v{{W^0Z25t$!dfE)gj4LHidD*hNlzW9&}u zLmr`Ced1TgafYa_tQ;FYe0(%FcHJNSv@6qfN~snp`Xyv8LmHp#D|0BBd4e|81?oq6 zxB@K~p4Ub>)lHn#2)W8<-^Kh=CEgEm~|}sAuBqBm6;4-K zp{iUF?sp8)9XKzI%BT5TlJU-<3erKsvZLH`bA^@xA8Nb%x|&2RvFb)1pZ#k1a5T>a zAYZkmw_NHJmB8IJm>bSq`s)MzTMO<7!l0PVWt?C3Q!@x^*WTw`9;9P98oxms$AWfyZ{L6`XLSI20t`nOxOz$WnwRyuILWZ;%JAkOf!;IZ7e zk-{1rE5`%}TTo?+d;vO#%$cJ3sJ;}pYrCaE<0tf{O*&t)L*B{E95bRz6tWNS zZm2pNdbJ}{IFM#y=s0aUAfW9#N7ZK?ltYQln6wNQ5$NB-ILlsQcRVeq8rD1N@)Rn- zsYqnKP}Q{Y59iCApL}zS)FTbxzdBf(aoF+!i|PDXkg!*V8>w&t-4;MfJ<|%#U>ec%>h#|MwmouFHfDcu_^U#x(Cpe&KNADa2vsiKL@u zT#wj6zIN()Io{b+AXDONSx*X2uMD!3zBKMx*%bq~Q37|poPv9_nmeQTzSY6?WioX= zy%;2t&dt+aSy_O1I{Nse&5FxaP$;FETl=&%)1zfqHxSVfIrRPzLun5gPw*_Ti)>@Y zo4ST}t+EtW%3NA{&yy)&Wz~9yX(5^BQU0VV-su6LnyRLMx`gKZ0O*w67PXEu$qT+8 z>&#=iaJG-tY^GH~^S4#{-a`_e<%{;|UNx!T8NW66mU2~o*s$IO(y);@@vD^PA{N&z zCzzapyz_Edt*-Ylwe!GKdp=PVoU|c?_nT(VA&09-d-)_n7(il68^4Mtnd|flGauEJ zTBPyo-}E*2ks*}_0vgGl6?o^~1h3+|qk4Qm=e<0ua=P`*y8?Y>qQxrkrNTeH(_O6FPj1YmPlB z!3Z5>Id&k=ksW(7o`+%?moPj0>U7CIAsTP`32gaEHs1aQ{dwJhn!>dk^#or&egJ}PrAan+j!K= zG~fmF009T1?RQNtB;Z9~v?ydzo&-~qwC zkEcw1Hs>tjWWR~4h|D-$eIknvo6XoM67uzTQr8x-pjm;E@!Mk&?0hXog&;)be4_ou zu2Ep}f+{8B5~I-8=c*WjOWdHlnxm&b{Tw?`U>R`jH{&YUX;ClqCG%(8eri&xg-&J&ZDzBwCJns@D3?(ztv=zl?t_N1NxXfC{U$={Gr-7&2s4 zT&^8f?K{ui0Jf2euA%&ag<8>>of(Vb%}WxA7w#`@Ym; z3;tZn<(_81FV!CIY8QrC)1AOr1fZ|`^YuTpa_d6&ZEb9h*J<@wJ68}PQP_d!^P+iw zdhR-nw_WEdgUqn64V5RVs1zW0`1g_621((x`{15y2kF*L!1`zoBN}rAdOEj{YA{O}DJAnY|m;!`#sGrAP^Zc8@^xFq$#uQ+4 zPY=Aj{5((ncyW2VP&Lx4hR!bR*&D7AKzsYa+Eyw5&&ziKzqI|kdsUz#&4XlMB+$N* zVo9y0&yOw^z{4PzI1Ty#Q9FtsS{9%!bFF;F)~_L}cQw)w^z!q{Wuxwe&Pd*#(80?8 zQMUeDM%^of{0WMPQOlxot<{!06+C{ZU;AO7!DIkO>H!Lf+YQw6Uo6wbl(#>yC!5Ft zy`5rVccz&Ad79PK83XhCBWDjcPj<;i{pWB&%lqyu(JUU*TtMl%E#Dooihg;x5OA(^ z4+o^(gk-b-`t=;erJvkZ`rYHrX{C_=$WRK%W5f}_gUTg%qGn`7zUba_W;OOYx);ottHX+Cxw4sbR~!SBms{Gdu|kK=1KsPMbceGYy(T7 zWhU^=<}b=SCYqY%GtTw@E13Kkm|{tU^b0BKEil1_W0CITTl_J8Oxvxk7IKE-x(QZNr3;-ebiP>a!77J#(*PAHJ( zWC@(MPO;sGh>Y!C=Q~rh~eKCPs zbM5mA6p=NUT}orpkgGm!xE1k+4#^x>p17*NvPqwXB+r%rWN`h8HUm{z6{%*d25e_I zei_G?_3go^80OE|_Cp9>H4XXFnlt7h>u4XON7Q3zF^O7|6E0!j7MTtDr|Vvee9Z9c zJ~wxFr)bLBRR*1~g=QQ<^IaGROkjeh{}zZ??mKt$dQL6PKsAoI(pILoVXBAsttB#?k_iC>kc) zg@q@$3#T7z*5u~oeKx#95mRlmHM8g=6zgq9n(l`H< zt_O6#eH)LSUH3}13A||;Fko7V5=MI5kh$W6|ISGT0&&5n`1*M=i)h?}va7SW61)@YkTy)%GLG4!9m|1_zB<^+#vc5|r{* zn+PC%$_W1ks9>nQ#Sx?TN+o#%4{e+DD+jiFO9Dtt)v*fY=K3urJr>2MaCJjN>l2g? z7a6U~zDsp8MsAy5UJ?vyO(IuQd%{jY4&%fn;?s-V`JnH>DrZtxOCvPY#=HST#d`}6 z%Bzb=Ish;X!L*Mla8VBH!YVs}+4b2D{ws(6uv-Iu~>l{!z`DD%;(p*YKoX-TYz2J*+o(<4mjZEDD<3;kISrQ0X>B=%B>})%3 z+2;n0oA7}ZnM4lsT!qnrtnW+`AQT0bK!&CoynL&TsR7d2o)Lh5kN@B#osf6bsCB|h z%|h*0OPGJPkDm9q!?oY-x#HudKu4bJB_^JR4gzB4&RZ4$2ktY`mq}!T!=|Q|?g$j+ z-aSgu#~qtwl-Nr5L5d<*I*_sU;#oA5E?~eIoLG#oR_Rfo&v~V<@G>4aAE;;YhV3_i zGW`}kWCQHmECyqk4-lHwKTVYsl^`X85o zTtwpu*X}a$8*w=&lZxBfX-zMjq~USSS#{qOlP*y4-i=1SPIW+_T}j+pbk(vtv?XOr zi9s6?XPP1s;BiI(aj8#YLvv(LUSRoTtg+fp#k#Dh&Iyd_Y zdAgeoniG(j5lnFYcjk?}d-kDFq(YzK2w%aG7c7}b|Y_ro8(7?rgtWu z7x3#N7l8m@hgujzCuKzsT8*VV>{H9anRIbH_a!2~eHSLI=?0d*7`HVBI$vYN{Po!F zs^&HUrqm#~Oy{&Ihtr(%cImo<59*kokl|+=`YWoE&27w&NO#!-!DEcQ0t$I^c=18; zgho7P-Cn71trANWpyv?Odt9g;xaIxeMP1-Tz))OO;9qu9Z<_4Cg*4__3!9tJiV=9w z6o<1YSHl4S6QzG`=SK-EsD)Z>S|t{y#hq!EoEQYjCkq`xdzRdIj2>j=S*}B1Spboi z`Z}BDohH^%TOWZ}vy!}5iO;pGlbUa9A7->~Rpn{Os4?$ztG)$uhL9v)Aj%iV*rnYR zsPqJo;Uf}+|5eh&%!4yLz*g4ns7~=R-AJ$fe7>X!L`P9Ddgt>_t=d1xx*Qql4_6xq z3~#e6_%Cs$`ai`d$@Fi+@KdXtr^PMa3fWJ&!2CCK1Z|!((xI6}W`O^rCVN1p2Lh(! zA^a2YF%7K(l9YOr)&nnHgFxupxE>66=7t*~i$nd4<=Wl$B|4A$VVm;TB~d*$t#_2W zN3H_#x*U8ADlRK95uNhbCx!sc{s7X_n5f5M@&3|SV0#LFd8zD7(cBwASvzN!``4@} zL!xkaX(LciNJQ-_1BHi0h}o^qeZtP9Uur?SACp1CvZGlRfQp3D+C$tH27|W<^jHT$)-yk3HEs+fhc_xgl{69|~v!(#B0hNu8c`1A#!TB7(0vYdRFVEUe5eaB{ZnJ8oS zk}FKjR-y^eRjSJWx#g>-&Hr`vsgkov0H$%X#+0}5V|__~97Sdfuq=SG?eZ&6kPSzk zuv;{BywyAM{>E5l5dJ363rc-fJkku=dnziQyupbFX9A?gI`hmB2rNB&HpfhYh0GU< zz-9|q239M7-T!==xAR%IE5zk|U>!6L|DJ$$f*Ah_B85!3_bt-MbOmvI-;pPrnLE|0ptg7Yk{6R1pbQ)1yH3^Rco3 zh*03&e;F~7qv*+%lR77K_FVJF9Y-cK+JEUR5WZ$%$Nj_BH-ekTWO9ghLDy&u_ zzTpZTP+aA6p(Snmy7QlCp=j34(g%bF|kc05DQGd_mGAk zTsS+_qq&|Ypc*Q$dZ;?q7B~ac87GOfsdy=Ab)LvHh)i;wXkQI zHWfzv=+iQ|rf;`l5?GqqCSc`xtmg~3699ks)(C*%Rro&+DV+oCdanEhF!{`~a4kp{ zKGHF*6Uom2P6(k;cITCp^1-q9u1nQNn}sI)pw9ZIWg4o7iyb^zx(tSL=2!=zp+kqP z+~%yT-+A{Ep^~~X0&Vvq z#_Q6`b5LR+bB|y`Aaw@=!8$mb<@eXv$z`?eHl!}$DHCrT`9U`>O~%S*LFn`%*$&hd zi5}N?A1IL4UR)~gq<}Kd?rWg<$TN*kA`+9Lm%v=2{Qd$EAn6RyV5s-6 zfl@K%rdQqhH85n!LtfnE(w|xY*&z~xfz?>@nFCcBVsISlfff-Q|I3=k2&seKz!>V$ zYs7q7dE0XGR+K?2M;``tUGo&wCP3{A{UXC0B=SizdMTi^&>FS1*|XJ&*A3f?j9gR% zGyTM?PszAF!2avb{*e7(>dP9Tw{o0dW=dJXCQSCf!>_sQK;wcVmiR}P4}z-LlI%%~Ca)t6GH@(cZy2B2K5x%u$y26O@v-`Z0dD+ z4;LUncdfhWt(9Lu0&QH8O!K_D9botH&#_|qC$OiQ0rHWHgNn`H)iLEO#qN*!-z`8= zaW^3KDYWKJ8&CwdxiU;6fmTGsecF^(F=YaQAhwW-@Xr-E@4@`hJVt8*S;^W6u)_WU zO`UYc3c=@E2S(pmwE#mMTErHZL%9&i+Msw=gxm_REg3?ZCHlGU|1;fI znJ<5iZMs~?n95>a=(-PB`frku;swsa_WxZB+&*Kzb^hdd;9$zzkIxTnDdgC&NFTVP ztrmF9SWbH|a8USPJ#goBcKpswUcha*U-z9y9^bhz>prO2`D@0N1@SM&%osj zWl>cxmuAb~w)ncjeUBeMa1f*9&&T7-LHoSH8%L_18PC7DuPXiSW5ftJWYFqr)`Ebn z0NVqY=MMpQEN_lyb_MMfX6}Q>AoxrdAhG4xPSCl(@{^@zG=jE#BSkV)i7xPF5#Yf2 z9!aEp3dyWlQNZR(gPoeG0W)w1Hqz}8aBHULSs5EibfXlm#(;+FFx?GItD^@|K;mrl zoEk{MMfe~J^fV4k=%eR9feV7syfm7ZkZX_8yaWl2;ZZz%_g~Vz~fu!D8M~OE9ziXmG*P6yiEfT&e3rdD3 +A diagram of my Fastmail workflow ## Alias-specific rules diff --git a/src/posts/2024/improving-my-self-hosted-scrobbling-implementation.md b/src/posts/2024/improving-my-self-hosted-scrobbling-implementation.md new file mode 100644 index 00000000..e00a70f7 --- /dev/null +++ b/src/posts/2024/improving-my-self-hosted-scrobbling-implementation.md @@ -0,0 +1,339 @@ +--- +date: 2024-05-08T11:48-08:00 +title: Improving my self-hosted scrobbling implementation +description: I wrote (fairly) recently about implementing my own scrobbler using Plex webhooks, edge functions and blob storage. So far — so far — this has worked quite well. +tags: + - music + - plex + - tech + - supabase + - musicbrainz +--- +[I wrote (fairly) recently about implementing my own scrobbler using Plex webhooks, edge functions and blob storage.](https://coryd.dev/posts/2024/building-a-scrobbler-using-plex-webhooks-edge-functions-and-blob-storage/) So far — so far — this has worked quite well. + +In doing this, I was keeping listens as JSON blobs with Netlify, stored under keys for the week they belonged to. + +Artist and album metadata lived in similar blob structures. What I found, however, was that this — especially the metadata — quickly became unwieldy. Chalk this up to my inclination to force what I knew to work instead of picking a better tool. + +In the interest of making something I've enjoyed building and using more durable, I started looking at flexible database solutions. I poked around, asked some friends and landed on [Supabase](https://supabase.com): + +> Supabase is an open source Firebase alternative. +Start your project with a Postgres database, Authentication, instant APIs, Edge Functions, Realtime subscriptions, Storage, and Vector embeddings. + +Sounds good, right? (Very much so, learning curve aside.) + +I set up three tables: listens, albums and artists. + +I had data for each, structured as JSON. I wrote some ugly node scripts (I'll spare you the pain of seeing those here) that wrote these out to CSVs. + +I imported those CSVs into their respective tables, and worked my way to connections between the tables that look like this: + +A diagram of my scrobbling tables + +The connections between the tables allow me to query data specific to a given listen's artist or album — data is stored in a given table where it makes the most sense: artist `mbid`s with artists, `genre`s with artists and so forth. I can then retrieve that data, provided I have a valid listen, using Supabase's select syntax: `artists (mbid, image)` or `albums (mbid, image)`. + +Plex's webhooks send out a fair bit of data, but most of that data is Plex-specific. What I'm able to use from that payload is the art, album and track names. These are stored in the listens table with a timestamp derived when I receive a webhook payload containing a `media.scrobble` event. These webhooks are sent to a `scrobble` endpoint (read: edge function: + +```javascript +import { createClient } from '@supabase/supabase-js' +import { DateTime } from 'luxon' + +const SUPABASE_URL = Netlify.env.get('SUPABASE_URL') +const SUPABASE_KEY = Netlify.env.get('SUPABASE_KEY') +const supabase = createClient(SUPABASE_URL, SUPABASE_KEY) + +const sanitizeMediaString = (string) => string.normalize('NFD').replace(/[\u0300-\u036f\u2010—\.\?\(\)\[\]\{\}]/g, '').replace(/\.{3}/g, '') + +export default async (request) => { + const ACCOUNT_ID_PLEX = process.env.ACCOUNT_ID_PLEX + const params = new URL(request.url).searchParams + const id = params.get('id') + + if (!id) return new Response(JSON.stringify({ status: 'Bad request' }), { headers: { "Content-Type": "application/json" } }) + if (id !== ACCOUNT_ID_PLEX) return new Response(JSON.stringify({ status: 'Forbidden' }), { headers: { "Content-Type": "application/json" } }) + + const data = await request.formData() + const payload = JSON.parse(data.get('payload')) + + if (payload?.event === 'media.scrobble') { + const artist = payload['Metadata']['grandparentTitle'] + const album = payload['Metadata']['parentTitle'] + const track = payload['Metadata']['title'] + const listenedAt = Math.floor(DateTime.now().toSeconds()) + const artistKey = sanitizeMediaString(artist).replace(/\s+/g, '-').toLowerCase() + const albumKey = `${artistKey}-${sanitizeMediaString(album).replace(/\s+/g, '-').toLowerCase()}` + + const { data: albumData, error: albumError } = await supabase + .from('albums') + .select('*') + .eq('key', albumKey) + .single() + + if (albumError && albumError.code === 'PGRST116') { + const { error: insertAlbumError } = await supabase.from('albums').insert([ + { + mbid: null, + image: `https://coryd.dev/media/albums/${albumKey}.jpg`, + key: albumKey, + name: album, + tentative: true + } + ]) + + if (insertAlbumError) { + console.error('Error inserting album into Supabase:', insertAlbumError.message) + return new Response(JSON.stringify({ status: 'error', message: insertAlbumError.message }), { headers: { "Content-Type": "application/json" } }) + } + } else if (albumError) { + console.error('Error querying album from Supabase:', albumError.message) + return new Response(JSON.stringify({ status: 'error', message: albumError.message }), { headers: { "Content-Type": "application/json" } }) + } + + const { data: artistData, error: artistError } = await supabase + .from('artists') + .select('*') + .eq('key', artistKey) + .single() + + if (artistError && artistError.code === 'PGRST116') { + const { error: insertArtistError } = await supabase.from('artists').insert([ + { + mbid: null, + image: `https://coryd.dev/media/artists/${artistKey}.jpg`, + key: albumKey, + name: album, + tentative: true + } + ]) + + if (insertArtistError) { + console.error('Error inserting artist into Supabase:', insertArtistError.message) + return new Response(JSON.stringify({ status: 'error', message: insertArtistError.message }), { headers: { "Content-Type": "application/json" } }) + } + } else if (artistError) { + console.error('Error querying artist from Supabase:', artistError.message) + return new Response(JSON.stringify({ status: 'error', message: artistError.message }), { headers: { "Content-Type": "application/json" } }) + } + + const { error: listenError } = await supabase.from('listens').insert([ + { + artist_name: artist, + album_name: album, + track_name: track, + listened_at: listenedAt, + album_key: albumKey + } + ]) + + if (listenError) { + console.error('Error inserting data into Supabase:', listenError.message) + console.log('Track with the error:', { + artist_name: artist, + album_name: album, + track_name: track, + listened_at: listenedAt, + album_key: albumKey + }) + return new Response(JSON.stringify({ status: 'error', message: listenError.message }), { headers: { "Content-Type": "application/json" } }) + } + } + + return new Response(JSON.stringify({ status: 'success' }), { headers: { "Content-Type": "application/json" } }) +} + +export const config = { + path: '/api/scrobble', +} +``` + +Scary! (Not really). This does a whole host of things: +1. Creates a `supabase` SDK client with my database url and API key. +2. Defines a `sanitizeMediaString` helper that does its best to normalize media strings. +3. Restricts access to requests with my Plex account ID and rejects invalid requests. +4. It then retrieves the data we're interested in from the webhook payload. +5. Next, in the interest of being cautious, we look to see if our `albumKey` is in the albums table. If it's not, we add a record for the album with the `boolean` `tenative` value set to true. + 1. This allows me to quickly identify records that were added programmatically and tidy them up if need be. + 2. If we can't add a record for the album, we error out as we don't have an album to attribute the listen to. +6. Rinse and repeat for artists (tracks need artists!). +7. Finally, we record the listen — if there's an error we log out which track caused the error. + +Whew! On to the big scary (not!) presentation part: + +```javascript +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 fetchDataForPeriod = async (startPeriod, fields, table) => { + const PAGE_SIZE = 1000 + let rows = [] + let rangeStart = 0 + + while (true) { + const { data, error } = await supabase + .from(table) + .select(fields) + .order('listened_at', { ascending: false }) + .gte('listened_at', startPeriod.toSeconds()) + .range(rangeStart, rangeStart + PAGE_SIZE - 1) + + if (error) { + console.error(error) + break + } + + rows = rows.concat(data) + + if (data.length < PAGE_SIZE) break + rangeStart += PAGE_SIZE + } + + return rows +} + +const aggregateData = (data, groupByField, groupByType) => { + const aggregation = {} + data.forEach(item => { + const key = item[groupByField] + if (!aggregation[key]) { + if (groupByType === 'track') { + aggregation[key] = { + title: item[groupByField], + plays: 0, + mbid: item['albums']?.mbid || '', + url: item['albums']?.mbid ? `https://musicbrainz.org/release/${item['albums'].mbid}` : `https://musicbrainz.org/search?query=${encodeURIComponent(item['album_name'])}&type=release`, + image: item['albums']?.image || '', + timestamp: item['listened_at'], + type: groupByType + } + } else { + aggregation[key] = { + title: item[groupByField], + plays: 0, + mbid: item[groupByType]?.mbid || '', + url: item[groupByType]?.mbid ? `https://musicbrainz.org/${groupByType === 'albums' ? 'release' : 'artist'}/${item[groupByType].mbid}` : `https://musicbrainz.org/search?query=${encodeURIComponent(item[groupByField])}&type=${groupByType === 'albums' ? 'release' : 'artist'}`, + image: item[groupByType]?.image || '', + type: groupByType + } + } + if ( + groupByType === 'track' || + groupByType === 'albums' + ) aggregation[key]['artist'] = item['artist_name'] + } + aggregation[key].plays++ + }) + return Object.values(aggregation).sort((a, b) => b.plays - a.plays) +} + + +export default async function() { + const periods = { + week: DateTime.now().minus({ days: 7 }).startOf('day'), // Last week + month: DateTime.now().minus({ days: 30 }).startOf('day'), // Last 30 days + threeMonth: DateTime.now().minus({ months: 3 }).startOf('day'), // Last three months + year: DateTime.now().minus({ years: 1 }).startOf('day'), // Last 365 days + } + + const results = {} + const selectFields = ` + track_name, + artist_name, + album_name, + album_key, + listened_at, + artists (mbid, image), + albums (mbid, image) + ` + + for (const [period, startPeriod] of Object.entries(periods)) { + const periodData = await fetchDataForPeriod(startPeriod, selectFields, 'listens') + results[period] = { + artists: aggregateData(periodData, 'artist_name', 'artists'), + albums: aggregateData(periodData, 'album_name', 'albums'), + tracks: aggregateData(periodData, 'track_name', 'track') + } + } + + const recentData = await fetchDataForPeriod(DateTime.now().minus({ days: 7 }), selectFields, 'listens') + + results.recent = { + artists: aggregateData(recentData, 'artist_name', 'artists'), + albums: aggregateData(recentData, 'album_name', 'albums'), + tracks: aggregateData(recentData, 'track_name', 'track') + } + + results.nowPlaying = results.recent.tracks[0] + + return results +} +``` + +1. We set up another `supabase` SDK client with my database url and API key. +2. We author a method that will fetch data for different time periods (cleverly named `fetchDataForPeriod`). We pass in a start period, it pages through results from our `listens` table until we're out and filters out anything with a `listend_at` timestamp greater than or equal to our `startPeriod` in seconds. +3. This all yields data that we store in `periodData` — which is called within a for loop where we pull data for each of our time periods defined in `const periods = ...`. + 1. Within this loop we populate our `results` object. It has a key for each period we're concerned with populating and that key is populated with aggregated `artists`, `albums` and `tracks` data from our `aggregateData` function (clever naming again, right?). + 2. This `aggregateData` function takes our raw data, a field to group by that corresponds to the name of the pertinent column in Supabase and a type. + 1. If we're populating track objects, we define one shape, if we're dealing with albums or artists, we modify the shape a bit. + 2. If an object is either a track or an album, we add the artist name to the object. + 3. If an object has already been built, we increment the play count and go on our merry way. +4. I guess that's a lot — or a bit, I dunno. JSON to CSVs to tables, wire the tables together, write to the table, query things and present it. + +This also required that I update my `now-playing` endpoint/edge function that displays the last played track on my home page. The relevant section of that file is here: + +```javascript +import { createClient } from '@supabase/supabase-js'; + +const SUPABASE_URL = process.env.SUPABASE_URL +const SUPABASE_KEY = process.env.SUPABASE_KEY +const supabase = createClient(SUPABASE_URL, SUPABASE_KEY); + +... + +export default async () => { + const { data, error } = await supabase + .from('listens') + .select(` + track_name, + artist_name, + listened_at, + artists (mbid, genre) + `) + .order('listened_at', { ascending: false }) + .range(0, 1) + + const headers = { + "Content-Type": "application/json", + "Cache-Control": "public, s-maxage=360, stale-while-revalidate=1080", + }; + + if (error) { + console.error('Error fetching data:', error); + return new Response(JSON.stringify({ error: "Failed to fetch the latest track" }), { headers }); + } + + if (data.length === 0) { + return new Response(JSON.stringify({ message: "No recent tracks found" }), { headers }); + } + + const scrobbleData = data[0] + + return new Response(JSON.stringify({ + content: `${emojiMap( + scrobbleData.artists.genre, + scrobbleData.artist_name + )} ${scrobbleData.track_name} by ${ + scrobbleData.artist_name + }`, + }), { headers }); +}; +``` + +1. You guessed it! We set up a `supabase` SDK client. +2. We query our listens table and grab our `mbid` and `genre` via our foreign key connection to the artists table. +3. In much the same way as we did before, we pass the artist `genre` and `name` through our absurd `emojiMap` function and send back HTML to display. + +All of the music data used to present artist and album grids and track charts is now retrieved from Supabase on each build. It's much easier to add, modify or deal with artist and album metadata (and even update listen data if needed). \ No newline at end of file