Create check.js

scripts/commands/issue/check.js

@@ -0,0 +1,103 @@
+const { api } = require('../../core')
+const { Octokit } = require('@octokit/core')
+const { paginateRest } = require('@octokit/plugin-paginate-rest')
+const CustomOctokit = Octokit.plugin(paginateRest)
+const _ = require('lodash')
+
+const octokit = new CustomOctokit({
+  auth: process.env.GITHUB_TOKEN
+})
+
+const DATA_DIR = process.env.DATA_DIR || './tmp/data'
+const OWNER = 'iptv-org'
+const REPO = 'iptv'
+
+async function main() {
+  try {
+    await api.channels.load()
+    let channels = await api.channels.all()
+    channels = _.keyBy(channels, 'id')
+
+    await api.streams.load()
+    let streams = await api.streams.all()
+    streams = _.keyBy(streams, 'channel')
+
+    const channelRequests = await loadChannelRequests()
+    const buffer = {}
+    const report = channelRequests.map(r => {
+      let result = {
+        issueNumber: r.issue.number,
+        channelId: r.channel.id || undefined,
+        status: undefined
+      }
+
+      if (!r.channel || !r.channel.id) result.status = 'error'
+      else if (!channels[r.channel.id]) result.status = 'invalid_id'
+      else if (streams[r.channel.id]) result.status = 'fullfilled'
+      else if (buffer[r.channel.id] && !r.channel.url) result.status = 'duplicate'
+      else result.status = 'pending'
+
+      buffer[r.channel.id] = true
+
+      return result
+    })
+    console.table(report)
+  } catch (err) {
+    console.log(err.message)
+  }
+}
+
+main()
+
+async function loadChannelRequests() {
+  const issues = await fetchIssues('channel request')
+
+  return issues.map(parseIssue)
+}
+
+async function fetchIssues(labels) {
+  const issues = await octokit.paginate('GET /repos/{owner}/{repo}/issues', {
+    owner: OWNER,
+    repo: REPO,
+    per_page: 100,
+    labels,
+    direction: 'asc',
+    headers: {
+      'X-GitHub-Api-Version': '2022-11-28'
+    }
+  })
+
+  return issues
+}
+
+function parseIssue(issue) {
+  const buffer = {}
+  const channel = {}
+  const fields = {
+    'Channel ID (required)': 'id',
+    'Channel ID': 'id',
+    'Stream URL (optional)': 'url',
+    'Stream URL': 'url',
+    'Notes (optional)': 'notes',
+    Notes: 'notes'
+  }
+
+  const matches = issue.body.match(/### ([^\r\n]+)\s+([^\r\n]+)/g)
+
+  if (!matches) return { issue, channel: null }
+
+  matches.forEach(item => {
+    const [, fieldLabel, value] = item.match(/### ([^\r\n]+)\s+([^\r\n]+)/)
+    const field = fields[fieldLabel]
+
+    if (!field) return
+
+    buffer[field] = value === '_No response_' ? undefined : value.trim()
+  })
+
+  for (let field in buffer) {
+    channel[field] = buffer[field]
+  }
+
+  return { issue, channel }
+}