public
/
epg-grabber
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Update utils.js

This commit is contained in:
Aleksandr Statciuk 2022-05-03 19:18:45 +03:00
parent e7d2da5182
commit c462874b0c
1 changed files with 8 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
src/utils.js
View File

@ -3,7 +3,7 @@ const { padStart } = require('lodash')
const path = require('path') const path = require('path')
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 axiosCacheAdapter = require('axios-cache-adapter') const { setupCache } = require('axios-cache-interceptor')
const tough = require('tough-cookie') const tough = require('tough-cookie')
const convert = require('xml-js') const convert = require('xml-js')
const { merge } = require('lodash') const { merge } = require('lodash')
@ -41,13 +41,7 @@ utils.loadConfig = function (config) {
withCredentials: true, withCredentials: true,
jar: new tough.CookieJar(), jar: new tough.CookieJar(),
responseType: 'arraybuffer', responseType: 'arraybuffer',
cache: { cache: false
readHeaders: false,
exclude: {
query: false
},
maxAge: 0
}
} }
} }
@ -55,7 +49,7 @@ utils.loadConfig = function (config) {
} }
utils.createClient = function (config) { utils.createClient = function (config) {
const client = axiosCacheAdapter.setup() const client = setupCache(axios.create())
client.interceptors.request.use( client.interceptors.request.use(
function (request) { function (request) {
if (config.debug) { if (config.debug) {
@ -80,7 +74,7 @@ utils.createClient = function (config) {
{ {
headers: response.headers, headers: response.headers,
data, data,
fromCache: response.request.fromCache === true cached: response.cached
}, },
null, null,
2 2
@ -318,20 +312,12 @@ utils.getUTCDate = function (d = null) {
} }
utils.parseResponse = async (item, response, config) => { utils.parseResponse = async (item, response, config) => {
let buffer
let content
if (utils.isObject(response.data) || Array.isArray(response.data)) {
content = JSON.stringify(response.data)
buffer = Buffer.from(content, 'utf8')
} else {
content = response.data.toString()
buffer = response.data
}
const data = merge(item, config, { const data = merge(item, config, {
content, content: response.data.toString(),
buffer, buffer: response.data,
headers: response.headers, headers: response.headers,
request: response.request request: response.request,
cached: response.cached
}) })
if (!item.channel.logo && config.logo) { if (!item.channel.logo && config.logo) {