Jetsparrow/jetherald
1
0
Fork 0
mirror of https://github.com/Jetsparrow/jetherald.git synced 2026-01-20 23:56:08 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

change heartattack Reported to Status, moved time calc to db

Browse Source
This commit is contained in:
jetsparrow 2021-04-22 22:23:15 +03:00
parent b423b8358d
commit 46bc808789
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
JetHerald/Db.cs
View File

@ -143,11 +143,11 @@ namespace JetHerald
INSERT INTO heartbeat INSERT INTO heartbeat
(TopicId, Heart, ExpiryTime) (TopicId, Heart, ExpiryTime)
VALUES VALUES
(@topicId, @heart, @expiry) (@topicId, @heart, CURRENT_TIMESTAMP() + INTERVAL @timeoutSeconds SECOND)
ON DUPLICATE KEY UPDATE ON DUPLICATE KEY UPDATE
ExpiryTime = @expiry; ExpiryTime = CURRENT_TIMESTAMP() + INTERVAL @timeoutSeconds SECOND;
", ",
new { topicId, heart, expiry = DateTime.UtcNow.AddSeconds(timeoutSeconds)}); new { topicId, heart, @timeoutSeconds});
} }
public async Task<IEnumerable<HeartAttack>> ProcessHeartAttacks() public async Task<IEnumerable<HeartAttack>> ProcessHeartAttacks()
@ -156,10 +156,10 @@ namespace JetHerald
return await c.QueryAsync<HeartAttack>("CALL process_heartattacks();"); return await c.QueryAsync<HeartAttack>("CALL process_heartattacks();");
} }
public async Task MarkHeartAttackReported(ulong id) public async Task MarkHeartAttackReported(ulong id, byte status = 1)
{ {
using var c = GetConnection(); using var c = GetConnection();
await c.ExecuteAsync("UPDATE heartattack SET Reported = 1 WHERE HeartattackId = @id", new {id}); await c.ExecuteAsync("UPDATE heartattack SET Status = @status WHERE HeartattackId = @id", new {id, status});
} }