diff --git a/src/MyWebLog.Data/RethinkDbData.fs b/src/MyWebLog.Data/RethinkDbData.fs index beefab9..c5d7d91 100644 --- a/src/MyWebLog.Data/RethinkDbData.fs +++ b/src/MyWebLog.Data/RethinkDbData.fs @@ -84,10 +84,6 @@ module private RethinkHelpers = /// Cast a strongly-typed list to an object list let objList<'T> (objects : 'T list) = objects |> List.map (fun it -> it :> obj) - - /// A simple type for the database version table - [] - type DbVersion = { Id : string } open System @@ -204,11 +200,32 @@ type RethinkDbData (conn : Net.IConnection, config : DataConfig, log : ILogger () + | Some v when v = "v2-rc1" -> do! migrateV2Rc1ToV2Rc2 () + | Some _ + | None -> + log.LogWarning $"Unknown database version; assuming {Utils.currentDbVersion}" + do! setDbVersion Utils.currentDbVersion + } + /// The connection for this instance member _.Conn = conn @@ -1138,6 +1155,14 @@ type RethinkDbData (conn : Net.IConnection, config : DataConfig, log : ILogger { + let! version = rethink<{| Id : string |} list> { withTable Table.DbVersion + limit 1 result; withRetryOnce conn } match List.tryHead version with | Some v when v.Id = "v2-rc2" -> () - // Future migrations will be checked here - | Some _ - | None -> - log.LogWarning $"Unknown database version; assuming {Utils.currentDbVersion}" - do! setDbVersion Utils.currentDbVersion + | it -> do! migrate (it |> Option.map (fun x -> x.Id)) } diff --git a/src/MyWebLog.Data/SQLiteData.fs b/src/MyWebLog.Data/SQLiteData.fs index 7b732c6..3b33874 100644 --- a/src/MyWebLog.Data/SQLiteData.fs +++ b/src/MyWebLog.Data/SQLiteData.fs @@ -228,13 +228,9 @@ type SQLiteData (conn : SqliteConnection, log : ILogger, ser : JsonS do! write cmd } - /// Log a migration step - let logMigrationStep migration message = - log.LogInformation $"Migrating %s{migration}: %s{message}" - /// Implement the changes between v2-rc1 and v2-rc2 let migrateV2Rc1ToV2Rc2 () = backgroundTask { - let logStep = logMigrationStep "v2-rc1 to v2-rc2" + let logStep = Utils.logMigrationStep log "v2-rc1 to v2-rc2" // Move meta items, podcast settings, and episode details to JSON-encoded text fields use cmd = conn.CreateCommand () logStep "Adding new columns" @@ -529,7 +525,7 @@ type SQLiteData (conn : SqliteConnection, log : ILogger, ser : JsonS DROP TABLE web_log_feed_podcast" do! write cmd - logStep "Setting database version" + logStep "Setting database version to v2-rc2" do! setDbVersion "v2-rc2" } diff --git a/src/MyWebLog.Data/Utils.fs b/src/MyWebLog.Data/Utils.fs index fcc3584..59ad5dc 100644 --- a/src/MyWebLog.Data/Utils.fs +++ b/src/MyWebLog.Data/Utils.fs @@ -50,3 +50,9 @@ let serialize<'T> ser (item : 'T) = /// Deserialize a JSON string let deserialize<'T> (ser : JsonSerializer) value = JsonConvert.DeserializeObject<'T> (value, Json.settings ser) + +open Microsoft.Extensions.Logging + +/// Log a migration step +let logMigrationStep<'T> (log : ILogger<'T>) migration message = + log.LogInformation $"Migrating %s{migration}: %s{message}" diff --git a/src/MyWebLog.Domain/SupportTypes.fs b/src/MyWebLog.Domain/SupportTypes.fs index 49bb09c..4753583 100644 --- a/src/MyWebLog.Domain/SupportTypes.fs +++ b/src/MyWebLog.Domain/SupportTypes.fs @@ -22,6 +22,7 @@ module Noda = /// The Unix epoch let epoch = Instant.FromUnixTimeSeconds 0L + /// Truncate an instant to remove fractional seconds let toSecondsPrecision (value : Instant) = Instant.FromUnixTimeSeconds (value.ToUnixTimeSeconds ()) @@ -29,6 +30,10 @@ module Noda = /// The current Instant, with fractional seconds truncated let now () = toSecondsPrecision (clock.GetCurrentInstant ()) + + /// Convert a date/time to an Instant with whole seconds + let fromDateTime (dt : DateTime) = + toSecondsPrecision (Instant.FromDateTimeUtc (DateTime (dt.Ticks, DateTimeKind.Utc))) /// A user's access level