improved wiki script

This commit is contained in:
tycrek 2021-08-09 11:12:15 -07:00
parent fefb07af6d
commit e7842e453f
No known key found for this signature in database
GPG Key ID: 25D74F3943625263
1 changed files with 36 additions and 49 deletions

View File

@ -4,88 +4,75 @@ const fetch = require('node-fetch'); // Make calls to Reddit from Node.js
const qs = require('qs'); // Properly build a query for node-fetch POST const qs = require('qs'); // Properly build a query for node-fetch POST
const moment = require('moment'); // Time-related functions const moment = require('moment'); // Time-related functions
//#region constants
// REDDIT_: For authentication with Reddit API. Oauth MUST be used. ID and Secret come from a "script" app type. // REDDIT_: For authentication with Reddit API. Oauth MUST be used. ID and Secret come from a "script" app type.
const REDDIT_USER = process.env.REDDIT_USER || 'username'; const REDDIT_USER = process.env.REDDIT_USER || 'username';
const REDDIT_PASS = process.env.REDDIT_PASS || 'password'; const REDDIT_PASS = process.env.REDDIT_PASS || 'password';
const REDDIT_CLIENT_ID = process.env.REDDIT_CLIENT_ID || 'clientid'; const REDDIT_CLIENT_ID = process.env.REDDIT_CLIENT_ID || 'clientid';
const REDDIT_CLIENT_SECRET = process.env.REDDIT_CLIENT_SECRET || 'clientsecret'; const REDDIT_CLIENT_SECRET = process.env.REDDIT_CLIENT_SECRET || 'clientsecret';
// Initial basic authorization for getting the Oauth token
const BASIC_AUTH = `Basic ${Buffer.from(REDDIT_CLIENT_ID + ':' + REDDIT_CLIENT_SECRET).toString('base64')}`;
// WIKI_: For the Reddit Wiki // WIKI_: For the Reddit Wiki
const WIKI_SUBREDDIT = 'privacy'; const WIKI_SUBREDDIT = 'privacy';
const WIKI_PAGE = 'de-google'; const WIKI_PAGE = 'de-google';
const WIKI_REASON = 'Automated edit from GitHub repo: https://github.com/tycrek/degoogle'; const WIKI_REASON = 'Automated edit from GitHub repo: https://github.com/tycrek/degoogle';
// Helps POST data be submitted properly // Endpoints for each of our fetches to Reddit
const CONTENT_TYPE = 'application/x-www-form-urlencoded'; const ENDPOINTS = {
updateWiki();
/**
* Update the Reddit wiki
*/
function updateWiki() {
// Endpoints for each of our fetches to Reddit
let endpoints = {
revisions: `https://old.reddit.com/r/${WIKI_SUBREDDIT}/wiki/revisions/${WIKI_PAGE}.json`, revisions: `https://old.reddit.com/r/${WIKI_SUBREDDIT}/wiki/revisions/${WIKI_PAGE}.json`,
token: 'https://www.reddit.com/api/v1/access_token', token: 'https://www.reddit.com/api/v1/access_token',
edit: `https://oauth.reddit.com/r/${WIKI_SUBREDDIT}/api/wiki/edit` edit: `https://oauth.reddit.com/r/${WIKI_SUBREDDIT}/api/wiki/edit`
}; };
// Initial basic authorization for getting the Oauth token // Helps POST data be submitted properly
let basicAuth = `Basic ${Buffer.from(REDDIT_CLIENT_ID + ':' + REDDIT_CLIENT_SECRET).toString('base64')}`; const CONTENT_TYPE = 'application/x-www-form-urlencoded';
//#endregion
let lastId, token; // Update the wiki
Promise.all([getLastRevision(), getToken()])
getLastRevision(endpoints.revisions) .then(([lastId, token]) => putWiki(lastId, token))
.then((mLastId) => lastId = mLastId)
.then(() => getToken(endpoints.token, basicAuth))
.then((mToken) => token = mToken)
.then(() => putWiki(endpoints.edit, lastId, token))
.catch((err) => (console.error(err), process.exit(1))); .catch((err) => (console.error(err), process.exit(1)));
}
//#region functions
/** /**
* Get the last revision ID on the Wiki. Required otherwise editing the wiki fails * Get the last revision ID on the Wiki. Required otherwise editing the wiki fails
* @param {String} endpoint Endpoint of where to get the ID's
*/ */
function getLastRevision(endpoint) { function getLastRevision() {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) =>
fetch(endpoint) fetch(ENDPOINTS.revisions)
.then((response) => response.json()) .then((response) => response.json())
.then((json) => json.data.children[0].id) // children[0] is the most recent edit .then((json) => json.data.children[0].id) // children[0] is the most recent edit
.then((lastId) => resolve(lastId)) .then(resolve)
.catch((err) => reject(err)); .catch(reject));
});
} }
/** /**
* Gets an Oauth token used to edit the Wiki * Gets an Oauth token used to edit the Wiki
* @param {String} endpoint Endpoint of where to get the token
* @param {String} auth Initial authorization data to get the better Oauth data
*/ */
function getToken(endpoint, auth) { function getToken() {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) =>
fetch(endpoint, { fetch(ENDPOINTS.token, {
method: 'POST', method: 'POST',
headers: { 'Authorization': auth, 'Content-Type': CONTENT_TYPE }, headers: { 'Authorization': BASIC_AUTH, 'Content-Type': CONTENT_TYPE },
body: qs.stringify({ grant_type: 'password', username: REDDIT_USER, password: REDDIT_PASS }) body: qs.stringify({ grant_type: 'password', username: REDDIT_USER, password: REDDIT_PASS })
}) })
.then((response) => response.json()) .then((response) => response.json())
.then((json) => json.access_token) .then(({ access_token }) => resolve(access_token))
.then((token) => resolve(token)) .catch(reject));
.catch((err) => reject(err));
});
} }
/** /**
* Post the contents from the README into the wiki * Post the contents from the README into the wiki
* @param {String} endpoint Endpoint for editing the wiki
* @param {String} lastId Revision ID for the Wiki * @param {String} lastId Revision ID for the Wiki
* @param {String} token Oauth token for authenticating with the Reddit API * @param {String} token Oauth token for authenticating with the Reddit API
*/ */
function putWiki(endpoint, lastId, token) { function putWiki(lastId, token) {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) =>
fetch(endpoint, { fetch(ENDPOINTS.edit, {
method: 'POST', method: 'POST',
headers: { 'Authorization': `bearer ${token}`, 'Content-Type': CONTENT_TYPE }, headers: { 'Authorization': `bearer ${token}`, 'Content-Type': CONTENT_TYPE },
body: qs.stringify({ body: qs.stringify({
@ -97,11 +84,10 @@ function putWiki(endpoint, lastId, token) {
}) })
.then((response) => response.json()) .then((response) => response.json())
.then((json) => { .then((json) => {
if (Object.keys(json).length == 0) resolve(); if (Object.keys(json).length === 0) resolve();
else throw Error(json); else throw Error(json);
}) })
.catch((err) => reject(err)); .catch(reject));
});
} }
/** /**
@ -117,4 +103,5 @@ function fixContent(content) {
content = content.replace(/-informational\?style=flat-square\)/g, '**'); content = content.replace(/-informational\?style=flat-square\)/g, '**');
return content; return content;
} } // * If this is highlighted weirdly, it's because of the 'updated timestamp' regex, don't worry about it
//#endregion