From 46bc8087891d38d45b15f625dc18580793399cc6 Mon Sep 17 00:00:00 2001 From: jetsparrow Date: Thu, 22 Apr 2021 22:23:15 +0300 Subject: [PATCH] change heartattack Reported to Status, moved time calc to db --- JetHerald/Db.cs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/JetHerald/Db.cs b/JetHerald/Db.cs index 8a31d49..012e7e3 100644 --- a/JetHerald/Db.cs +++ b/JetHerald/Db.cs @@ -143,11 +143,11 @@ namespace JetHerald INSERT INTO heartbeat (TopicId, Heart, ExpiryTime) VALUES - (@topicId, @heart, @expiry) + (@topicId, @heart, CURRENT_TIMESTAMP() + INTERVAL @timeoutSeconds SECOND) 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> ProcessHeartAttacks() @@ -156,10 +156,10 @@ namespace JetHerald return await c.QueryAsync("CALL process_heartattacks();"); } - public async Task MarkHeartAttackReported(ulong id) + public async Task MarkHeartAttackReported(ulong id, byte status = 1) { 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}); }