iptv/scripts/core/issueLoader.ts

import { Collection } from '@freearhey/core'
import { restEndpointMethods } from '@octokit/plugin-rest-endpoint-methods'
import { paginateRest } from '@octokit/plugin-paginate-rest'
import { Octokit } from '@octokit/core'
import { IssueParser } from './'
import { TESTING, OWNER, REPO } from '../constants'

const CustomOctokit = Octokit.plugin(paginateRest, restEndpointMethods)
const octokit = new CustomOctokit()

export class IssueLoader {
  async load({ labels }: { labels: string[] | string }) {
    labels = Array.isArray(labels) ? labels.join(',') : labels
    let issues: object[] = []
    if (TESTING) {
      switch (labels) {
        case 'streams:add':
          issues = require('../../tests/__data__/input/issues/streams_add.js')
          break
        case 'streams:edit':
          issues = require('../../tests/__data__/input/issues/streams_edit.js')
          break
        case 'broken stream':
          issues = require('../../tests/__data__/input/issues/broken_stream.js')
          break
        case 'streams:add,approved':
          issues = require('../../tests/__data__/input/issues/streams_add_approved.js')
          break
        case 'streams:edit,approved':
          issues = require('../../tests/__data__/input/issues/streams_edit_approved.js')
          break
        case 'streams:remove,approved':
          issues = require('../../tests/__data__/input/issues/streams_remove_approved.js')
          break
      }
    } else {
      issues = await octokit.paginate(octokit.rest.issues.listForRepo, {
        owner: OWNER,
        repo: REPO,
        per_page: 100,
        labels,
        headers: {
          'X-GitHub-Api-Version': '2022-11-28'
        }
      })
    }

    const parser = new IssueParser()

    return new Collection(issues).map(parser.parse)
  }
}