From d846756a7f2f8370b02399641020963a90c4c0fc Mon Sep 17 00:00:00 2001 From: Nicolas Constant Date: Mon, 6 Jul 2020 00:55:56 -0400 Subject: [PATCH] added foolproofing --- .../DataAccessLayers/TwitterUserPostgresDal.cs | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/src/DataAccessLayers/BirdsiteLive.DAL.Postgres/DataAccessLayers/TwitterUserPostgresDal.cs b/src/DataAccessLayers/BirdsiteLive.DAL.Postgres/DataAccessLayers/TwitterUserPostgresDal.cs index e02c6be..eaa610b 100644 --- a/src/DataAccessLayers/BirdsiteLive.DAL.Postgres/DataAccessLayers/TwitterUserPostgresDal.cs +++ b/src/DataAccessLayers/BirdsiteLive.DAL.Postgres/DataAccessLayers/TwitterUserPostgresDal.cs @@ -22,13 +22,15 @@ namespace BirdsiteLive.DAL.Postgres.DataAccessLayers public async Task CreateTwitterUserAsync(string acct, long lastTweetPostedId) { + acct = acct.ToLowerInvariant(); + using (var dbConnection = Connection) { dbConnection.Open(); await dbConnection.ExecuteAsync( $"INSERT INTO {_settings.TwitterUserTableName} (acct,lastTweetPostedId,lastTweetSynchronizedForAllFollowersId) VALUES(@acct,@lastTweetPostedId,@lastTweetSynchronizedForAllFollowersId)", - new { acct = acct, lastTweetPostedId = lastTweetPostedId, lastTweetSynchronizedForAllFollowersId = lastTweetPostedId }); + new { acct, lastTweetPostedId, lastTweetSynchronizedForAllFollowersId = lastTweetPostedId }); } } @@ -36,6 +38,8 @@ namespace BirdsiteLive.DAL.Postgres.DataAccessLayers { var query = $"SELECT * FROM {_settings.TwitterUserTableName} WHERE acct = @acct"; + acct = acct.ToLowerInvariant(); + using (var dbConnection = Connection) { dbConnection.Open(); @@ -78,6 +82,8 @@ namespace BirdsiteLive.DAL.Postgres.DataAccessLayers { if (acct == default) throw new ArgumentException("acct"); + acct = acct.ToLowerInvariant(); + var query = $"DELETE FROM {_settings.TwitterUserTableName} WHERE acct = @acct"; using (var dbConnection = Connection)