mirror of
https://github.com/iptv-org/iptv.git
synced 2024-09-06 00:02:24 +02:00
53 lines
1.8 KiB
TypeScript
53 lines
1.8 KiB
TypeScript
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)
|
|
}
|
|
}
|