Development/auth

config/passportSetup.js

@@ -0,0 +1,106 @@
+const passport = require('passport');
+const OAuth2Strategy = require('passport-oauth').OAuth2Strategy;
+const request = require('request');
+const airtable = require('airtable');
+require('dotenv').config();
+
+const { API_KEY, TWITCH_CLIENT_ID, TWITCH_SECRET, CALLBACK_URL } = process.env;
+
+const base = new airtable({ apiKey: API_KEY }).base('appeqb1CAXVkBv8hN');
+
+OAuth2Strategy.prototype.userProfile = function(accessToken, done) {
+ var options = {
+ url: 'https://api.twitch.tv/helix/users',
+ method: 'GET',
+ headers: {
+ 'Client-ID': TWITCH_CLIENT_ID,
+ Accept: 'application/vnd.twitchtv.v5+json',
+ Authorization: 'Bearer ' + accessToken
+ }
+ };
+
+ request(options, function(error, response, body) {
+ if (response && response.statusCode == 200) {
+ done(null, JSON.parse(body));
+ } else {
+ done(JSON.parse(body));
+ }
+ });
+};
+
+passport.serializeUser(function(user, done) {
+ done(null, user.id);
+});
+
+passport.deserializeUser(function(id, done) {
+ base('users').find(id, function(err, record) {
+ if (err) {console.error(err); return;}
+ done(null, record);
+ })
+});
+
+passport.use(
+ 'twitch',
+ new OAuth2Strategy(
+ {
+ authorizationURL: 'https://id.twitch.tv/oauth2/authorize',
+ tokenURL: 'https://id.twitch.tv/oauth2/token',
+ clientID: TWITCH_CLIENT_ID,
+ clientSecret: TWITCH_SECRET,
+ callbackURL: CALLBACK_URL,
+ state: true
+ },
+ function(accessToken, refreshToken, profile, done) {
+ profile.accessToken = accessToken;
+ profile.refreshToken = refreshToken;
+
+ base('users')
+ .select({
+ view: 'Grid view',
+ filterByFormula: `{id} = ${profile.data[0].id}`
+ })
+ .eachPage(
+ function page(records, fetchNextPage) {
+ if (records.length != 0) {
+ base('users').update([
+ {
+ "id": records[0].id,
+ "fields": profile.data[0]
+ }
+ ], function(err, records) {
+ if (err) {
+ console.error(err);
+ return;
+ }
+ profile.id = records[0].id;
+ done(null, profile);
+ });
+ } else {
+ base('users').create(
+ [
+ {
+ fields: profile.data[0]
+ }
+ ],
+ function(err, records) {
+ if (err) {
+ console.error(err.message);
+ }
+ profile.id = records[0].id;
+ done(null, profile);
+ }
+ );
+ }
+ fetchNextPage();
+ },
+ function done(err) {
+ if (err) {
+ console.error(err);
+ return;
+ }
+ }
+ );
+ // done(null, profile);
+ }
+ )
+);

middleware/auth.js

@@ -0,0 +1,13 @@
+const passport = require('passport');
+
+module.exports = function (req, res, next) {
+ if (req.user != undefined) {
+ if(req.user.fields.display_name === req.params.channel) {
+ next();
+ } else {
+ res.status(401).send('Unauthorized access');
+ }
+ } else {
+ res.redirect('/');
+ }
+}

middleware/getLeaderboardSettings.js

@@ -6,55 +6,57 @@ const api_key = process.env.API_KEY;
 const base = new airtable({ apiKey: api_key }).base('appeqb1CAXVkBv8hN');
 
 module.exports = function(req, res, next) {
- var channel = req.query.channel || req.params.channel;
+ var channel = req.query.channel || req.params.channel;
+ channel = channel.toLowerCase();
+ res.locals.channel = channel;
 
- base('leaderboards')
- .select({
- view: 'Grid view',
- filterByFormula: `{channel} = "${channel}"`,
- maxRecords: 1
- })
- .firstPage(function(err, records) {
- if (err) {
- next(err);
- }
+ base('leaderboards')
+ .select({
+ view: 'Grid view',
+ filterByFormula: `{channel} = "${channel}"`,
+ maxRecords: 1
+ })
+ .firstPage(function(err, records) {
+ if (err) {
+ next(err);
+ }
 
- try {
- records.forEach(function(record) {
- req.leaderboardSettings = record.fields;
- req.leaderboardSettings.id = record.id;
- res.locals.leaderboardSettings = record.fields;
- res.locals.leaderboardSettings.id = record.id;
- });
+ try {
+ records.forEach(function(record) {
+ req.leaderboardSettings = record.fields;
+ req.leaderboardSettings.id = record.id;
+ res.locals.leaderboardSettings = record.fields;
+ res.locals.leaderboardSettings.id = record.id;
+ });
 
- if (records.length === 0) {
- base('leaderboards').create(
- [
- {
- fields: {
- channel: channel,
- theme: 'retro',
- 'background-opacity': 1
- }
- }
- ],
- function(err, records) {
- if (err) {
- next(err);
- }
- records.forEach(function(record) {
- req.leaderboardSettings = record.fields;
- req.leaderboardSettings.id = record.id;
- res.locals.leaderboardSettings = record.fields;
- res.locals.leaderboardSettings.id = record.id;
- });
- }
- );
- }
- } catch (e) {
- next(e);
- return;
- }
- next();
- });
+ if (records.length === 0) {
+ base('leaderboards').create(
+ [
+ {
+ fields: {
+ channel: channel,
+ theme: 'light',
+ 'background-opacity': 1
+ }
+ }
+ ],
+ function(err, records) {
+ if (err) {
+ next(err);
+ }
+ records.forEach(function(record) {
+ req.leaderboardSettings = record.fields;
+ req.leaderboardSettings.id = record.id;
+ res.locals.leaderboardSettings = record.fields;
+ res.locals.leaderboardSettings.id = record.id;
+ });
+ }
+ );
+ }
+ } catch (e) {
+ next(e);
+ return;
+ }
+ next();
+ });
 };

middleware/getReferrals.js

@@ -5,58 +5,59 @@ const api_key = process.env.API_KEY;
 //Connect to Airtable
 const base = new airtable({ apiKey: api_key }).base('appeqb1CAXVkBv8hN');
 
-function isLower(character) {
- if (/[a-zA-Z]/) {
- character = character.toLowerCase();
- return character;
- }
-}
+// function isLower(character) {
+//  if (/[a-zA-Z]/) {
+//  character = character.toLowerCase();
+//  return character;
+//  }
+// }
 
 module.exports = function(req, res, next) {
- var referrals = [];
- var channel = req.query.channel || req.params.channel;
- var { referrer, since } = req.query;
-
- if(channel == undefined) {
- next();
- }
-
- channel = [...channel]
- .map(character => isLower(character))
- .toString()
- .split(',')
- .join('');
-
-
- var formula = `{channel} = "${channel}"`;
- if (referrer != undefined) {
- formula = formula + `, {referrer} = "${referrer}"`;
- }
-
- if (since != undefined) {
- formula = formula + `, IS_AFTER({timestamp}, "${since}")`;
- }
-
- base('referrals')
- .select({
- view: 'Grid view',
- filterByFormula: `AND(${formula})`
- })
- .eachPage(
- function page(records, fetchNextPage) {
- records.forEach(function(record) {
- referrals.push(record.fields);
- });
- fetchNextPage();
- },
- function done(err) {
- if (err) {
- next(err);
- }
- res.locals.referrals = referrals;
- req.referrals = referrals;
- req.type = 'referrals';
- next();
- }
- );
+ var referrals = [];
+ var channel = req.query.channel || req.params.channel;
+ var { referrer, since } = req.query;
+
+ if (channel == undefined) {
+ next();
+ }
+
+ channel = channel.toLowerCase();
+
+ // channel = [...channel]
+ // .map(character => isLower(character))
+ // .toString()
+ // .split(',')
+ // .join('');
+
+ var formula = `{channel} = "${channel}"`;
+ if (referrer != undefined) {
+ formula = formula + `, {referrer} = "${referrer}"`;
+ }
+
+ if (since != undefined) {
+ formula = formula + `, IS_AFTER({timestamp}, "${since}")`;
+ }
+
+ base('referrals')
+ .select({
+ view: 'Grid view',
+ filterByFormula: `AND(${formula})`
+ })
+ .eachPage(
+ function page(records, fetchNextPage) {
+ records.forEach(function(record) {
+ referrals.push(record.fields);
+ });
+ fetchNextPage();
+ },
+ function done(err) {
+ if (err) {
+ next(err);
+ }
+ res.locals.referrals = referrals;
+ req.referrals = referrals;
+ req.type = 'referrals';
+ next();
+ }
+ );
 };

middleware/middleware.js

@@ -0,0 +1,23 @@
+const excludeFavicon = require('./exludeFavicon');
+const processLeaderboard = require('./processLeaderboard');
+const setTheme = require('./setTheme');
+const resetLeaderboard = require('./resetLeaderboard');
+const getLeaderboardSettings = require('./getLeaderboardSettings');
+const getReferrals = require('./getReferrals');
+const useReferral = require('./useReferral');
+const requestIP = require('./requestIP');
+const buildJSON = require('./buildJSON');
+const auth = require('./auth');
+
+module.exports = {
+ auth,
+ excludeFavicon,
+ processLeaderboard,
+ setTheme,
+ resetLeaderboard,
+ getLeaderboardSettings,
+ getReferrals,
+ useReferral,
+ requestIP,
+ buildJSON
+};