artdanj-api/app/Tasks/HistorySongsTask.ts

import Logger from '@ioc:Adonis/Core/Logger'
import { getCurrentPlayingFromCache } from 'App/Utils/SongUtils'
import Song from 'App/Models/Song'

const MS = 10000
let taskId

async function LogSpotifyHistory(): Promise<void> {
  const current = await getCurrentPlayingFromCache()

  if (!current.is_playing) return

  if (current.progress && current.progress < 1000) return

  const last_entry = await Song.query().where('item_id', current.id!).orderBy('date', 'desc').first()

  if (last_entry && new Date().getTime() - last_entry.duration <= new Date(last_entry.date).getTime()) return

  if (last_entry && last_entry.item_name === current.name) return

  await Song.create({
    date: new Date(current.started_at!),
    duration: current.duration,
    item_name: current.name,
    item_type: current.type,
    item_id: current.id,
    author: current.author,
    device_name: current.device_name,
    device_type: current.device_type,
    image: current.image?.url,
  })
}

export async function Activate(): Promise<void> {
  Logger.info(`Starting task runner for tracking spotify listen history [${MS} ms]`)
  await LogSpotifyHistory()
  taskId = setInterval(LogSpotifyHistory, MS)
}

export function ShutDown(): void {
  clearInterval(taskId)
  Logger.info('Shutdown task runner for getting current developing state')
}