Bump version to v0.8

db/00-version.sql

@@ -8,4 +8,4 @@ CREATE OR REPLACE FUNCTION get_version() RETURNS VARCHAR
 	AS $$SELECT major || '.' || minor FROM version $$
 	LANGUAGE SQL;
 
-INSERT INTO version (major,minor) VALUES (0,8);
+INSERT INTO version (major,minor) VALUES (0,7);

src/cronjobs/processBans.ts

@@ -9,8 +9,8 @@ export async function processBans(streamer: twitch.StreamerUserIdTokenPair) {
 		await dbconn.query("DELETE FROM bans");
 		var response = await twitch.streamerApiRequest(streamer,
 			`/moderation/banned?broadcaster_id=${streamer.userid}&first=100`);
-		log(LogLevel.DEBUG,"Ban API response:")
-		log(LogLevel.DEBUG,JSON.stringify(response,null,2));
+		//log(LogLevel.DEBUG,"Ban API response:")
+		//log(LogLevel.DEBUG,JSON.stringify(response,null,2));
 		while (true) {
 			var insertBanQuery = "INSERT INTO bans (userid) VALUES ";
 			var banRow = 0; // Used for $1, $2, etc. in parameterized query
@@ -37,8 +37,8 @@ export async function processBans(streamer: twitch.StreamerUserIdTokenPair) {
 				var oldFirstUserid = response.data[0].user_id;
 				response = await twitch.streamerApiRequest(streamer,
 					`/moderation/banned?broadcaster_id=${streamer.userid}&after=${response.pagination.cursor}&first=100`);
-				log(LogLevel.DEBUG,"Ban API response:");
-				log(LogLevel.DEBUG,JSON.stringify(response,null,2));
+				//log(LogLevel.DEBUG,"Ban API response:");
+				//log(LogLevel.DEBUG,JSON.stringify(response,null,2));
 				// Work around broken api endpoint giving a cursor referring to the
 				// current page, causing an infinite loop
 				if (oldFirstUserid == response.data[0].user_id) break;

src/cronjobs/processSubscriptions.ts

@@ -9,8 +9,8 @@ export async function processSubscriptions(streamer: twitch.StreamerUserIdTokenP
 		await dbconn.query("DELETE FROM subscriptions");
 		var response = await twitch.streamerApiRequest(streamer,
 			`/subscriptions?broadcaster_id=${streamer.userid}&first=100`);
-		log(LogLevel.DEBUG,"Subscriptions API response:")
-		log(LogLevel.DEBUG,JSON.stringify(response,null,2));
+		//log(LogLevel.DEBUG,"Subscriptions API response:")
+		//log(LogLevel.DEBUG,JSON.stringify(response,null,2));
 		while (true) {
 			var insertSubscriptionQuery = "INSERT INTO subscriptions (userid) VALUES ";
 			var subscriptionRow = 0; // Used for $1, $2, etc. in parameterized query
@@ -35,9 +35,9 @@ export async function processSubscriptions(streamer: twitch.StreamerUserIdTokenP
 				var oldFirstUserid = response.data[0].user_id;
 				response = await twitch.streamerApiRequest(streamer,
 					`/subscriptions?broadcaster_id=${streamer.userid}&after=${response.pagination.cursor}&first=100`);
-				log(LogLevel.DEBUG,"Subscription API response:");
-				log(LogLevel.DEBUG,JSON.stringify(response,null,2));
-				if (response.data.length === 0 || oldFirstUserid === response.data[0].user_id) break;
+				if (oldFirstUserid == response.data[0].user_id) break;
+				//log(LogLevel.DEBUG,"Subscription API response:");
+				//log(LogLevel.DEBUG,JSON.stringify(response,null,2));
 			} else {
 				break;
 			}
@@ -45,7 +45,6 @@ export async function processSubscriptions(streamer: twitch.StreamerUserIdTokenP
 		await dbconn.query("CALL update_scores()");
 		await dbconn.query('COMMIT');
 	} catch (e) {
-		log(LogLevel.ERROR,"cronjobs.processSubscriptions: Exception: " + e);
 		log(LogLevel.ERROR,"cronjobs.processSubscriptions: Exception thrown; rolling back");
 		await dbconn.query('ROLLBACK');
 		throw(e);

src/twitch.ts

@@ -53,7 +53,6 @@ export async function apiRequest(tokens: TokenPair, endpoint: string): Promise <
 	return fetch("https://api.twitch.tv/helix" + endpoint, { headers: headers })
 		.then(async (res: FetchResponse) => {
 			if (res.status == 200) {
-				log(LogLevel.DEBUG,"twitch.apiRequest: Request returned 200 for " + endpoint);
 				return res.json();
 			} else {
 				log(LogLevel.WARNING,"twitch.apiRequest: Failed API request (pre-refresh):");