Notification: Twitch (automated)

Hi,

I have struggled with the Twitch Notifications myself; going through the OAUTH2 Twitch Developer documentation, I was able to figure it out! In an effort to make this available in an easy automated form, I have written a script that does the leg work for you.

Here are the features/How it works rundown:

The code will create a copy of your dotenv to (.env) and check it for TWITCH_CLIENT_ID, TWITCH_CLIENT_SECRET, and TWITCH_CHANNEL entried. If it finds the codes, it will proceed to direct you to the proper login site on https://id.twitch.tv with rights chat:edit and chat:read as required by streetmerchant (saving the session in ./user_data to make re-getting the token easy), automatically extract the code Query Parameter from either the redirect (new session) or the target (saved session - no login). The script then proceeds to obtain current mozilla certificate from https://curl.se/docs/caextract.html and sends the POST with the proper TWITCH AUTH parameters to automatically obtain TWITCH_ACCESS_TOKEN and TWITCH_REFRESH_TOKEN and either replace the token in the copied .env file, or append to it. Lastly, the script will display all your tokens and ask if you would like to copy the generated .env (based on your current dotenv file) over to a working dotenv file. If you answer with yes (y), the script will create a backup of dotenv (dotenv.bak) and copy over the new file to dotenv. This file will include all needed codes, as well as any parameters currently in your dotenv file.

Lastly, the script will suggest to run a npm run test:notification to test your notification.

NOTE: On rare occasions, the script will fail due to some random filesystem permission issue (either it cannot find dotenv and will quit with please populate parameters), or it fails during deletion of previous cacert.pem. If this happens, feel free to cancel the script and run again.

I hope that this will help some people to get Twitch notifications setup. Please feel free to 'optimize' the code (as I am certain, it will disgust some coders :)

The first steps are identical to Jef's approach. Creating an Application from https://dev.twitch.tv/console/apps with a redirect URL of http://localhost:

Must use unique name. Use https://www.uuidgenerator.net/ to get a UUID and append it to streetmerchant-.

From there, you should get the TWITCH_CLIENT_ID, TWITCH_CLIENT_SECRET, and TWITCH_CHANNEL (be careful, TWITCH_CLIENT_SECRET can only be seen one time when generated).

Add the three lines to your 'dotenv' file and save your file.

TWITCH_CLIENT_ID= TWITCH_CLIENT_SECRET= TWITCH_CHANNEL=<your twitch channel/username>

My script requires puppeteer, dotenv, readline, yesno, querystring, and node-libcurl (apologies, but this is my first NODE.js script ever), so please make sure you install the necessary dependencies

npm i puppeteer dotenv readline yesno querystring node-libcurl

Copy and paste the following code into Twitch_Auto.js (or any name of choosing):

const querystring = require('querystring'); const { curly } = require('node-libcurl'); global.__basedir = __dirname; global.code=''; global.foundatoken=false; global.foundrtoken=false; const urlp = require('url'); const path = require('path'); const tls = require('tls'); const http = require('http'); const fs = require('fs'); const puppeteer = require('puppeteer'); const yesno = require('yesno'); const url = 'http://curl.haxx.se/ca/cacert.pem'; const filePath = path.join(__basedir, 'cacert.pem'); const readline = require('readline'); function sleep(ms) { return new Promise((resolve) => { setTimeout(resolve, ms); }); }
async function processLineByLine() { const fileStream = fs.createReadStream(path.join(__basedir, '.env'));

const rl = readline.createInterface({ input: fileStream, crlfDelay: Infinity }); for await (const line of rl) { if(line.includes('TWITCH_ACCESS_TOKEN')){ fs.readFile(path.join(__basedir, '.env'), 'utf8', function(err, data) { let searchString1 = 'TWITCH_ACCESS_TOKEN'; let re1 = new RegExp('^.' + searchString1 + '.$', 'gm'); let formatted1 = data.replace(re1, 'TWITCH_ACCESS_TOKEN=' + access_token);

  fs.writeFile(path.join(__basedir, '.env'), formatted1, 'utf8', function(err) {
  	if (err) return console.log(err);
  	});
  });
foundatoken=true;	
  await sleep(1000);
}

if(line.includes('TWITCH_REFRESH_TOKEN')){ fs.readFile(path.join(__basedir, '.env'), 'utf8', function(err, data) { let searchString2 = 'TWITCH_REFRESH_TOKEN'; let re2 = new RegExp('^.' + searchString2 + '.$', 'gm'); let formatted2 = data.replace(re2, 'TWITCH_REFRESH_TOKEN=' + refresh_token);

  fs.writeFile(path.join(__basedir, '.env'), formatted2, 'utf8', function(err) {
  	if (err) return console.log(err);
  	});
  });
foundatoken=true;	
  await sleep(1000);
}

}

if (foundatoken==false){

  fs.appendFile(path.join(__basedir, '.env'), "\n" + 'TWITCH_ACCESS_TOKEN=' + access_token, function (err) {
  if (err) {
// append failed
  } else {
// done
  }
  })

} if (foundrtoken==false){ fs.appendFile(path.join(__basedir, '.env'), "\n" + 'TWITCH_REFRESH_TOKEN=' + refresh_token, function (err) { if (err) { // append failed } else { // done } }) } }

fs.copyFile('dotenv','.env', (err) => { if (err) throw err;}); require('dotenv').config(); const atoken = process.env.TWITCH_ACCESS_TOKEN; const rtoken = process.env.TWITCH_REFRESH_TOKEN; const cid = process.env.TWITCH_CLIENT_ID; const csec = process.env.TWITCH_CLIENT_SECRET; const chan = process.env.TWITCH_CHANNEL; console.log(__dirname + ' d ' + __basedir); if (( typeof cid !== 'undefined' && cid) || ( typeof csec !== 'undefined' && csec) || ( typeof chan !== 'undefined' && chan) ) {

console.log('--Parameters from dotenv--'); console.log('TWITCH_CLIENT_ID: ' + cid); console.log('TWITCH_CLIENT_SECRET: ' + csec); console.log('TWITCH_CHANNEL: ' + chan); console.log('--Getting Access Token and Refresh Token--');

const file = fs.createWriteStream(filePath); const request = http.get(url, (response) => {response.pipe(file);}); (async () => { const browser = await puppeteer.launch({ headless: false , userDataDir: "./user_data"}); const page = await browser.newPage(); await page.setDefaultNavigationTimeout(0); //Check for previous session try { await page.goto('https://id.twitch.tv/oauth2/authorize?response_type=code&client_id='+cid+'&redirect_uri=http://localhost&scope=chat:edit%20chat:read', {waitUntil: 'load', timeout: 0}); page.on('response', response => { const status = response.status() if ((status >= 300) && (status <= 399)) { if (response.headers()['location'].includes('localhost') == true){ let parsedUrl = urlp.parse(response.headers()['location']); const object = querystring.parse(parsedUrl.query); code = object['code']; console.log('CODE: ' + code);

} } }) await page.waitForNavigation(); await browser.close(); } catch (e) { console.log('Session previously saved in ./user_data... Using previous session. No login needed!'); const pages = await browser.pages(); var x = await browser.targets(); for(let i=0;i<x.length;i++) { var y = x[i].url(); if((x[i].type()==='page') && (y.includes('localhost')==true)) { let parsedUrl = urlp.parse(x[i].url()); const object = querystring.parse(parsedUrl.query); code = object['code']; console.log('CODE: ' + code); await browser.close(); } }

}

await sleep(2500); const certFilePath = path.join(__basedir, 'cacert.pem') const tlsData = tls.rootCertificates.join('\n') fs.access(certFilePath, (err) => { if (err) { console.log("The file does not exist, downloading..."); fs.writeFileSync(certFilePath, tlsData); } else { console.log("The file exists, deleting old cacert.pem"); fs.unlink(certFilePath, (err) => { if (err) { throw err; }

console.log("File is deleted.");

}); } });

await sleep(2500); fs.writeFileSync(certFilePath, tlsData); const { statusCode, data, headers } = await curly.post('https://id.twitch.tv/oauth2/token', {postFields: querystring.stringify({ client_id: cid,client_secret: csec, code: global.code, grant_type: 'authorization_code', redirect_uri: 'http://localhost'}), caInfo: certFilePath, }) global.access_token = data.access_token; global.refresh_token = data.refresh_token; processLineByLine(); await sleep(5000); console.log('--Parameters from dotenv--'); console.log('TWITCH_CLIENT_ID: ' + cid); console.log('TWITCH_CLIENT_SECRET: ' + csec); console.log('TWITCH_CHANNEL: ' + chan); console.log('--New Parameters obtained in script--'); console.log('TWITCH_ACCESS_TOKEN: ' + access_token); console.log('TWITCH_REFRESH_TOKEN: ' + refresh_token);

const ok = await yesno({ question: 'Do you want to update dotenv?' });

if (ok==true){ console.log('Creating dotenv.bak...'); fs.copyFile('dotenv','dotenv.bak', (err) => { if (err) throw err;}); console.log('Copying .env to dotenv'); fs.copyFile('.env','dotenv', (err) => { if (err) throw err;}); console.log('Done! exiting ...'); console.log('Test Twitch Notifications with: npm run test:notification'); process.exit(); }

})();

} else { console.log('Twitch API not configured'); console.log('Please register app at http://dev.twitch.tv'); console.log('And populate TWITCH_CLIENT_ID, TWITCH_CLIENT_SECRET, and TWITCH_CHANNEL in the dotenv file'); }

Run the code with node Twitch_Auto.js.