Watch for new listenings

import {

  getState,

  setState,

} from "https://deno.land/x/windmill@v1.85.0/mod.ts";

/**

 * **IMPORTANT:** This does not return listenings on the first run.

 *

 * You can read more about the Listenings History API at

 * https://docs.funkwhale.audio/swagger/#/User%20activity/get_api_v1_history_listenings

 */

type Funkwhale = {

  baseUrl: string;

  token: string;

};

export async function main(

  auth: Funkwhale,

  query?: string,

  scope = "all",

  page_size = 10,

) {

  const previousState = await getState();

  const url = new URL("/api/v1/history/listenings", auth.baseUrl);

  const params = { query, scope, page_size };

  Object.entries(params).forEach(([key, value]) => {

    value && url.searchParams.append(key, encodeURIComponent(value));

  });

  const response = await fetch(url, {

    headers: {

      Authorization: `Bearer ${auth.token}`,

    },

  });

  const data = await response.json();

  data.results.reverse();

  const newListenings = [];

  let latestId;

  for (const listening of data.results) {

    if (latestId === undefined || listening.id > latestId) {

      latestId = listening.id;

    }

    if (

      previousState?.latestId !== undefined &&

      listening.id <= previousState.latestId

    ) {

      continue;

    }

    newListenings.push(listening);

  }

  if (latestId !== undefined) {

    await setState({

      latestId,

    });

  }

  return newListenings;

}