upgrade failing counter to integer
This commit is contained in:
parent
5c4641c6ae
commit
26cca6a306
3 changed files with 85 additions and 2 deletions
|
@ -23,7 +23,7 @@ namespace BirdsiteLive.DAL.Postgres.DataAccessLayers
|
||||||
public class DbInitializerPostgresDal : PostgresBase, IDbInitializerDal
|
public class DbInitializerPostgresDal : PostgresBase, IDbInitializerDal
|
||||||
{
|
{
|
||||||
private readonly PostgresTools _tools;
|
private readonly PostgresTools _tools;
|
||||||
private readonly Version _currentVersion = new Version(2, 3);
|
private readonly Version _currentVersion = new Version(2, 4);
|
||||||
private const string DbVersionType = "db-version";
|
private const string DbVersionType = "db-version";
|
||||||
|
|
||||||
#region Ctor
|
#region Ctor
|
||||||
|
@ -134,7 +134,8 @@ namespace BirdsiteLive.DAL.Postgres.DataAccessLayers
|
||||||
new Tuple<Version, Version>(new Version(1,0), new Version(2,0)),
|
new Tuple<Version, Version>(new Version(1,0), new Version(2,0)),
|
||||||
new Tuple<Version, Version>(new Version(2,0), new Version(2,1)),
|
new Tuple<Version, Version>(new Version(2,0), new Version(2,1)),
|
||||||
new Tuple<Version, Version>(new Version(2,1), new Version(2,2)),
|
new Tuple<Version, Version>(new Version(2,1), new Version(2,2)),
|
||||||
new Tuple<Version, Version>(new Version(2,2), new Version(2,3))
|
new Tuple<Version, Version>(new Version(2,2), new Version(2,3)),
|
||||||
|
new Tuple<Version, Version>(new Version(2,3), new Version(2,4))
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -163,6 +164,14 @@ namespace BirdsiteLive.DAL.Postgres.DataAccessLayers
|
||||||
var addPostingError = $@"ALTER TABLE {_settings.FollowersTableName} ADD postingErrorCount SMALLINT";
|
var addPostingError = $@"ALTER TABLE {_settings.FollowersTableName} ADD postingErrorCount SMALLINT";
|
||||||
await _tools.ExecuteRequestAsync(addPostingError);
|
await _tools.ExecuteRequestAsync(addPostingError);
|
||||||
}
|
}
|
||||||
|
else if (from == new Version(2, 3) && to == new Version(2, 4))
|
||||||
|
{
|
||||||
|
var alterLastSync = $@"ALTER TABLE {_settings.TwitterUserTableName} ALTER COLUMN fetchingErrorCount TYPE INTEGER";
|
||||||
|
await _tools.ExecuteRequestAsync(alterLastSync);
|
||||||
|
|
||||||
|
var alterPostingError = $@"ALTER TABLE {_settings.FollowersTableName} ALTER COLUMN postingErrorCount TYPE INTEGER";
|
||||||
|
await _tools.ExecuteRequestAsync(alterPostingError);
|
||||||
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
throw new NotImplementedException();
|
throw new NotImplementedException();
|
||||||
|
|
|
@ -340,6 +340,48 @@ namespace BirdsiteLive.DAL.Postgres.Tests.DataAccessLayers
|
||||||
Assert.AreEqual(10, result.PostingErrorCount);
|
Assert.AreEqual(10, result.PostingErrorCount);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
[TestMethod]
|
||||||
|
public async Task CreateUpdateAndGetFollower_Integer()
|
||||||
|
{
|
||||||
|
var acct = "myhandle";
|
||||||
|
var host = "domain.ext";
|
||||||
|
var following = new[] { 12, 19, 23 };
|
||||||
|
var followingSync = new Dictionary<int, long>()
|
||||||
|
{
|
||||||
|
{12, 165L},
|
||||||
|
{19, 166L},
|
||||||
|
{23, 167L}
|
||||||
|
};
|
||||||
|
var inboxRoute = "/myhandle/inbox";
|
||||||
|
var sharedInboxRoute = "/inbox";
|
||||||
|
var actorId = $"https://{host}/{acct}";
|
||||||
|
|
||||||
|
var dal = new FollowersPostgresDal(_settings);
|
||||||
|
await dal.CreateFollowerAsync(acct, host, inboxRoute, sharedInboxRoute, actorId, following, followingSync);
|
||||||
|
var result = await dal.GetFollowerAsync(acct, host);
|
||||||
|
|
||||||
|
var updatedFollowing = new List<int> { 12, 19, 23, 24 };
|
||||||
|
var updatedFollowingSync = new Dictionary<int, long>(){
|
||||||
|
{12, 170L},
|
||||||
|
{19, 171L},
|
||||||
|
{23, 172L},
|
||||||
|
{24, 173L}
|
||||||
|
};
|
||||||
|
result.Followings = updatedFollowing.ToList();
|
||||||
|
result.FollowingsSyncStatus = updatedFollowingSync;
|
||||||
|
result.PostingErrorCount = 32768;
|
||||||
|
|
||||||
|
await dal.UpdateFollowerAsync(result);
|
||||||
|
result = await dal.GetFollowerAsync(acct, host);
|
||||||
|
|
||||||
|
Assert.AreEqual(updatedFollowing.Count, result.Followings.Count);
|
||||||
|
Assert.AreEqual(updatedFollowing[0], result.Followings[0]);
|
||||||
|
Assert.AreEqual(updatedFollowingSync.Count, result.FollowingsSyncStatus.Count);
|
||||||
|
Assert.AreEqual(updatedFollowingSync.First().Key, result.FollowingsSyncStatus.First().Key);
|
||||||
|
Assert.AreEqual(updatedFollowingSync.First().Value, result.FollowingsSyncStatus.First().Value);
|
||||||
|
Assert.AreEqual(32768, result.PostingErrorCount);
|
||||||
|
}
|
||||||
|
|
||||||
[TestMethod]
|
[TestMethod]
|
||||||
public async Task CreateUpdateAndGetFollower_Remove()
|
public async Task CreateUpdateAndGetFollower_Remove()
|
||||||
{
|
{
|
||||||
|
|
|
@ -130,6 +130,38 @@ namespace BirdsiteLive.DAL.Postgres.Tests.DataAccessLayers
|
||||||
Assert.IsTrue(Math.Abs((now.ToUniversalTime() - result.LastSync).Milliseconds) < 100);
|
Assert.IsTrue(Math.Abs((now.ToUniversalTime() - result.LastSync).Milliseconds) < 100);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
[TestMethod]
|
||||||
|
public async Task CreateUpdate3AndGetUser()
|
||||||
|
{
|
||||||
|
var acct = "myid";
|
||||||
|
var lastTweetId = 1548L;
|
||||||
|
|
||||||
|
var dal = new TwitterUserPostgresDal(_settings);
|
||||||
|
|
||||||
|
await dal.CreateTwitterUserAsync(acct, lastTweetId);
|
||||||
|
var result = await dal.GetTwitterUserAsync(acct);
|
||||||
|
|
||||||
|
|
||||||
|
var updatedLastTweetId = 1600L;
|
||||||
|
var updatedLastSyncId = 1550L;
|
||||||
|
var now = DateTime.Now;
|
||||||
|
var errors = 32768;
|
||||||
|
|
||||||
|
result.LastTweetPostedId = updatedLastTweetId;
|
||||||
|
result.LastTweetSynchronizedForAllFollowersId = updatedLastSyncId;
|
||||||
|
result.FetchingErrorCount = errors;
|
||||||
|
result.LastSync = now;
|
||||||
|
await dal.UpdateTwitterUserAsync(result);
|
||||||
|
|
||||||
|
result = await dal.GetTwitterUserAsync(acct);
|
||||||
|
|
||||||
|
Assert.AreEqual(acct, result.Acct);
|
||||||
|
Assert.AreEqual(updatedLastTweetId, result.LastTweetPostedId);
|
||||||
|
Assert.AreEqual(updatedLastSyncId, result.LastTweetSynchronizedForAllFollowersId);
|
||||||
|
Assert.AreEqual(errors, result.FetchingErrorCount);
|
||||||
|
Assert.IsTrue(Math.Abs((now.ToUniversalTime() - result.LastSync).Milliseconds) < 100);
|
||||||
|
}
|
||||||
|
|
||||||
[TestMethod]
|
[TestMethod]
|
||||||
[ExpectedException(typeof(ArgumentException))]
|
[ExpectedException(typeof(ArgumentException))]
|
||||||
public async Task Update_NoId()
|
public async Task Update_NoId()
|
||||||
|
|
Loading…
Add table
Reference in a new issue