81 lines
2.8 KiB
JavaScript
81 lines
2.8 KiB
JavaScript
|
module.exports = function(fetch) {
|
|||
|
|
this.initRedditApi = function() {
|
|||
|
|
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() {
|
|||
|
|
return {
|
|||
|
|
headers: {
|
|||
|
|
Authorization: `Bearer ${reddit_access_token}`
|
|||
|
|
},
|
|||
|
|
method: 'GET'
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
initRedditApi()
|
|||
|
|
}
|