88 lines
2.9 KiB
JavaScript
88 lines
2.9 KiB
JavaScript
module.exports = function(fetch) {
|
||
const config = require('../config');
|
||
this.initRedditApi = function() {
|
||
if(!config.use_reddit_oauth)
|
||
return null
|
||
|
||
let options = {
|
||
body: `grant_type=https://oauth.reddit.com/grants/installed_client&device_id=DO_NOT_TRACK_THIS_DEVICE&duration=permanent`,
|
||
headers: {
|
||
'Content-Type': 'application/x-www-form-urlencoded',
|
||
'Authorization': `Basic ${client_id_b64}`,
|
||
},
|
||
method: 'POST'
|
||
}
|
||
|
||
fetch('https://www.reddit.com/api/v1/access_token', options)
|
||
.then(result => {
|
||
if(result.status === 200) {
|
||
result.json()
|
||
.then(data => {
|
||
//console.log(data)
|
||
if(data.access_token) {
|
||
reddit_access_token = data.access_token
|
||
reddit_refresh_token = data.refresh_token
|
||
console.log(`Successfully obtained a reddit API key.`)
|
||
} else {
|
||
console.log(`Error while obtaining a reddit API key. Check that your reddit app ID is correct. Reddit could also be down.`, data)
|
||
}
|
||
})
|
||
} else {
|
||
console.error(`Something went wrong while trying to get an access token from reddit API. ${result.status} – ${result.statusText}`)
|
||
console.error(reddit_api_error_text)
|
||
return res.render('index', { json: null, http_status_code: result.status })
|
||
}
|
||
}).catch(error => {
|
||
console.log(`Error while obtaining a reddit API key.`, error)
|
||
})
|
||
|
||
setInterval(() => {
|
||
refreshRedditToken()
|
||
}, 1000 * 60 * 58) /* Refresh access token every ~1 hour. */
|
||
}
|
||
|
||
this.refreshRedditToken = function() {
|
||
let options = {
|
||
body: `grant_type=refresh_token&refresh_token=${reddit_refresh_token}`,
|
||
headers: {
|
||
'Content-Type': 'application/x-www-form-urlencoded',
|
||
'Authorization': `Basic ${client_id_b64}`,
|
||
},
|
||
method: 'POST'
|
||
}
|
||
fetch('https://www.reddit.com/api/v1/access_token', options)
|
||
.then(result => {
|
||
if(result.status === 200) {
|
||
result.json()
|
||
.then(data => {
|
||
//console.log(data)
|
||
if(data.access_token) {
|
||
reddit_access_token = data.access_token
|
||
console.log(`Successfully refreshed the reddit API key.`)
|
||
} else {
|
||
console.log(`Error while refreshing the reddit API key.`, data)
|
||
}
|
||
})
|
||
} else {
|
||
console.error(`Something went wrong while fetching data from reddit API. ${result.status} – ${result.statusText}`)
|
||
console.error(reddit_api_error_text)
|
||
return res.render('index', { json: null, http_status_code: result.status })
|
||
}
|
||
}).catch(error => {
|
||
console.log(`Error while refreshing the reddit API key.`, error)
|
||
})
|
||
}
|
||
this.redditApiGETHeaders = function() {
|
||
if(!config.use_reddit_oauth)
|
||
return { method: 'GET' }
|
||
|
||
return {
|
||
headers: {
|
||
Authorization: `Bearer ${reddit_access_token}`
|
||
},
|
||
method: 'GET'
|
||
}
|
||
}
|
||
initRedditApi()
|
||
}
|