Skip to content

Commit

Permalink
Fix bug with rare case when certain statements fit into exactly one c…
Browse files Browse the repository at this point in the history
…all.
  • Loading branch information
roncli committed Apr 1, 2021
1 parent 445877d commit e0db8d6
Show file tree
Hide file tree
Showing 2 changed files with 14 additions and 3 deletions.
9 changes: 7 additions & 2 deletions src/database/challenge.js
Expand Up @@ -1685,7 +1685,8 @@ class ChallengeDb {
id: {type: Db.INT, value: challenge.id}
};

let sqlTerms = [];
let hasData = false,
sqlTerms = [];

for (const stat of damage) {
const index = damage.indexOf(stat);
Expand All @@ -1700,6 +1701,7 @@ class ChallengeDb {
params[`opponentPlayer${index}Id`] = {type: Db.INT, value: playerIds[stat.opponentDiscordId]};
params[`weapon${index}`] = {type: Db.VARCHAR(50), value: stat.weapon};
params[`damage${index}`] = {type: Db.FLOAT, value: stat.damage};
hasData = true;

if (Object.keys(params).length > 2000) {
await db.query(`${sql} ${sqlTerms.join(",")}`, params);
Expand All @@ -1710,10 +1712,13 @@ class ChallengeDb {
id: {type: Db.INT, value: challenge.id}
};
sqlTerms = [];
hasData = false;
}
}

await db.query(sql, params);
if (hasData) {
await db.query(sql, params);
}
}

// # ## ###
Expand Down
8 changes: 7 additions & 1 deletion src/database/team.js
Expand Up @@ -1663,6 +1663,8 @@ class TeamDb {
params[`rating${index}`] = {type: Db.FLOAT, value: rating};
}

let hasData = false;

for (const {challengeId, challengeRating, index} of Object.keys(challengeRatings).map((r, i) => ({challengeId: +r, challengeRating: challengeRatings[+r], index: i}))) {
sql = /* sql */`
${sql}
Expand All @@ -1678,15 +1680,19 @@ class TeamDb {
params[`challengedTeamRating${index}`] = {type: Db.FLOAT, value: challengeRating.challengedTeamRating};
params[`ratingChange${index}`] = {type: Db.FLOAT, value: challengeRating.change};
params[`challenge${index}Id`] = {type: Db.INT, value: challengeId};
hasData = true;

if (Object.keys(params).length > 2000) {
await db.query(sql, params);
sql = "";
params = {};
hasData = false;
}
}

await db.query(sql, params);
if (hasData) {
await db.query(sql, params);
}

await Cache.invalidate([`${settings.redisPrefix}:invalidate:challenge:closed`]);
}
Expand Down

0 comments on commit e0db8d6

Please sign in to comment.