daan/geekbot
1
0
Fork 0
Code Issues 2 Pull requests Projects Releases Packages Wiki Activity

Start counting messages in postgres

Browse source
This commit is contained in:
runebaas 2018-08-29 23:01:10 +02:00
parent 449e1e0adc
commit 6a163366ea
No known key found for this signature in database
GPG key ID: 2677AF508D0300D6
1 changed files with 18 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

35
Geekbot.net/Handlers.cs
View file

@ -105,23 +105,24 @@ namespace Geekbot.net
var channel = (SocketGuildChannel) message.Channel;
// var rowId = await _messageCounterDatabaseContext.Database.ExecuteSqlCommandAsync(
// "UPDATE \"Messages\" SET \"MessageCount\" = \"MessageCount\" + 1 WHERE \"GuildId\" = {0} AND \"UserId\" = {1}",
// channel.Guild.Id.AsLong(),
// message.Author.Id.AsLong()
// );
//
// if (rowId == 0)
// {
// _messageCounterDatabaseContext.Messages.Add(new MessagesModel
// {
// UserId = message.Author.Id.AsLong(),
// GuildId = channel.Guild.Id.AsLong(),
// MessageCount = 1
// });
// _messageCounterDatabaseContext.SaveChanges();
// }
// just testing, redis will remain the source of truth for now
var rowId = await _messageCounterDatabaseContext.Database.ExecuteSqlCommandAsync(
"UPDATE \"Messages\" SET \"MessageCount\" = \"MessageCount\" + 1 WHERE \"GuildId\" = {0} AND \"UserId\" = {1}",
channel.Guild.Id.AsLong(),
message.Author.Id.AsLong()
);
if (rowId == 0)
{
_messageCounterDatabaseContext.Messages.Add(new MessagesModel
{
UserId = message.Author.Id.AsLong(),
GuildId = channel.Guild.Id.AsLong(),
MessageCount = 1
});
_messageCounterDatabaseContext.SaveChanges();
}
await _redis.Db.HashIncrementAsync($"{channel.Guild.Id}:Messages", message.Author.Id.ToString());
await _redis.Db.HashIncrementAsync($"{channel.Guild.Id}:Messages", 0.ToString());