wip
This commit is contained in:
parent
d22a02fa9f
commit
26b30eddcc
|
@ -2,7 +2,7 @@ const { CurlGenerator } = require('curl-generator')
|
||||||
const axios = require('axios').default
|
const axios = require('axios').default
|
||||||
const axiosCookieJarSupport = require('axios-cookiejar-support').default
|
const axiosCookieJarSupport = require('axios-cookiejar-support').default
|
||||||
const { setupCache } = require('axios-cache-interceptor')
|
const { setupCache } = require('axios-cache-interceptor')
|
||||||
const { isObject, isPromise, getUTCDate } = require('./utils')
|
const { isObject, isPromise } = require('./utils')
|
||||||
|
|
||||||
axiosCookieJarSupport(axios)
|
axiosCookieJarSupport(axios)
|
||||||
|
|
||||||
|
@ -68,7 +68,6 @@ function create(config) {
|
||||||
}
|
}
|
||||||
|
|
||||||
async function buildRequest({ channel, date, config }) {
|
async function buildRequest({ channel, date, config }) {
|
||||||
date = typeof date === 'string' ? getUTCDate(date) : date
|
|
||||||
const CancelToken = axios.CancelToken
|
const CancelToken = axios.CancelToken
|
||||||
const source = CancelToken.source()
|
const source = CancelToken.source()
|
||||||
const request = { ...config.request }
|
const request = { ...config.request }
|
||||||
|
|
|
@ -1,9 +1,9 @@
|
||||||
const { merge } = require('lodash')
|
const { merge } = require('lodash')
|
||||||
const { create: createClient, buildRequest, parseResponse } = require('./client')
|
const { create: createClient, buildRequest, parseResponse } = require('./client')
|
||||||
const { parseChannels, parsePrograms } = require('./parser')
|
const { parseChannels, parsePrograms } = require('./parser')
|
||||||
|
const { sleep, isPromise, getUTCDate } = require('./utils')
|
||||||
const { generate: generateXMLTV } = require('./xmltv')
|
const { generate: generateXMLTV } = require('./xmltv')
|
||||||
const { load: loadConfig } = require('./config')
|
const { load: loadConfig } = require('./config')
|
||||||
const { sleep, isPromise } = require('./utils')
|
|
||||||
const Channel = require('./Channel')
|
const Channel = require('./Channel')
|
||||||
const Program = require('./Program')
|
const Program = require('./Program')
|
||||||
|
|
||||||
|
@ -29,6 +29,7 @@ class EPGGrabber {
|
||||||
async grab(channel, date, cb = () => {}) {
|
async grab(channel, date, cb = () => {}) {
|
||||||
await sleep(this.config.delay)
|
await sleep(this.config.delay)
|
||||||
|
|
||||||
|
date = typeof date === 'string' ? getUTCDate(date) : date
|
||||||
return buildRequest({ channel, date, config: this.config })
|
return buildRequest({ channel, date, config: this.config })
|
||||||
.then(this.client)
|
.then(this.client)
|
||||||
.then(parseResponse)
|
.then(parseResponse)
|
||||||
|
|
Loading…
Reference in New Issue