miru/app/js/rss.js

/* eslint-env browser */
/* global torrent4list */

import { settings } from './settings.js'
import { releasesCards } from './interface.js'
import { userBrowser, DOMPARSER } from './util.js'
import { client } from './main.js'
import halfmoon from 'halfmoon'
import { episodeRx } from './anime.js'

const exclusions = {
  edge: ['DTS'],
  chromium: ['DTS', 'AC3', 'HEVC', 'x265', 'H.265'],
  firefox: ['DTS', 'AC3', 'HEVC', 'x265', 'H.265', '.3gp', '.mkv']
}
if (!('audioTracks' in HTMLVideoElement.prototype)) {
  exclusions[userBrowser].push('mutli audio', 'dual audio')
}

export function getRSSContent (url) {
  return fetch(url).then(res => {
    return res.text().then(xmlTxt => {
      return DOMPARSER(xmlTxt, 'text/xml')
    })
  }).catch(error => {
    halfmoon.initStickyAlert({
      content: 'Failed fetching RSS!<br>' + error,
      title: 'Search Failed',
      alertType: 'alert-danger',
      fillType: ''
    })
    console.error(error)
  })
}

export async function nyaaRss (media, episode) {
  const frag = document.createDocumentFragment()
  const ep = (media.status === 'FINISHED' && settings.torrent9) ? `"01-${media.episodes}"|"01~${media.episodes}"|"Batch"|"Complete"|"+${episode}+"|"+${episode}v"` : `"+${episode}+"|"+${episode}v"`
  const url = new URL(`https://meowinjapanese.cf/?page=rss&c=1_2&f=${settings.torrent3 === true ? 2 : 0}&s=seeders&o=desc&q=(${[...new Set(Object.values(media.title).concat(media.synonyms).filter(name => name != null))].join(')|(').replace(/&/g, '%26')})${ep}"${settings.torrent1}"-(${exclusions[userBrowser].join('|')})`)

  const nodes = (await getRSSContent(url)).querySelectorAll('item *')
  if (!nodes.length) return frag
  const entries = []
  for (let index = Math.floor(nodes.length / 15); index--;) {
    const position = index * 15
    entries[index] = {
      title: nodes[position].textContent,
      seeders: nodes[position + 4].textContent,
      leechers: nodes[position + 5].textContent,
      downloads: nodes[position + 6].textContent,
      hash: nodes[position + 7].textContent,
      size: nodes[position + 10].textContent
    }
  }
  entries.sort((a, b) => b.seeders - a.seeders)
  const streamingEpisode = media?.streamingEpisodes.filter(episode => episodeRx.exec(episode.title) && Number(episodeRx.exec(episode.title)[1]) === Number(episode))[0]
  const fileMedia = {
    mediaTitle: media?.title.userPreferred,
    episodeNumber: Number(episode),
    episodeTitle: streamingEpisode ? episodeRx.exec(streamingEpisode.title)[2] : undefined,
    episodeThumbnail: streamingEpisode?.thumbnail,
    mediaCover: media?.coverImage.medium,
    name: 'Miru',
    media: media
  }
  if (settings.torrent2) {
    client.playTorrent(entries[0].hash, { media: fileMedia, episode: episode })
    halfmoon.hideModal('tsearch')
  }
  entries.forEach((entry, index) => {
    const template = document.createElement('tr')
    template.innerHTML += `
<th>${(index + 1)}</th>
<td>${entry.title}</td>
<td>${entry.size}</td>
<td>${entry.seeders}</td>
<td>${entry.leechers}</td>
<td>${entry.downloads}</td>
<td class="pointer">Play</td>`
    template.onclick = () => {
      client.playTorrent(entry.hash, { media: fileMedia, episode: episode })
      halfmoon.hideModal('tsearch')
    }
    frag.appendChild(template)
  })
  return frag
}

export async function releasesRSS (limit) {
  return releasesCards((await getRSSContent(getRSSurl())).querySelectorAll('item'), limit)
}

export function getRSSurl () {
  if (Object.values(torrent4list.options).filter(item => item.value === settings.torrent4)[0]) {
    return settings.torrent4 === 'Erai-raws' ? new URL(Object.values(torrent4list.options).filter(item => item.value === settings.torrent4)[0].innerHTML + settings.torrent1 + '-magnet') : new URL(Object.values(torrent4list.options).filter(item => item.value === settings.torrent4)[0].innerHTML + settings.torrent1)
  } else {
    return settings.torrent4 + settings.torrent1 // add custom RSS
  }
}