From 3ad84420bd882f983c2f9b605e7a68f5bdf95f5c Mon Sep 17 00:00:00 2001
From: cloudhead <cloudhead@radicle.xyz>
Date: Mon, 18 Nov 2024 12:27:07 +0100
Subject: [PATCH] cli: Implement `rad cob migrate`

Adds the new `migrate` sub-command to migrate the COB database.
Checks for version when opening the COBs database and suggests the
command on out of date version.

Also adds the 2nd migration to the COBs cache, which updates the patch
JSON schema.
---
 radicle-cli/examples/rad-cob-migrate.md       |  24 +++
 radicle-cli/src/commands/clone.rs             |   5 +-
 radicle-cli/src/commands/cob.rs               | 117 +++++++----
 radicle-cli/src/commands/inbox.rs             |   9 +-
 radicle-cli/src/commands/issue.rs             |   5 +-
 radicle-cli/src/commands/issue/cache.rs       |   4 +-
 radicle-cli/src/commands/patch.rs             |   4 +-
 radicle-cli/src/commands/patch/archive.rs     |   7 +-
 radicle-cli/src/commands/patch/assign.rs      |   3 +-
 radicle-cli/src/commands/patch/cache.rs       |   3 +-
 radicle-cli/src/commands/patch/checkout.rs    |   3 +-
 radicle-cli/src/commands/patch/comment.rs     |   4 +-
 radicle-cli/src/commands/patch/delete.rs      |   3 +-
 radicle-cli/src/commands/patch/diff.rs        |   4 +-
 radicle-cli/src/commands/patch/edit.rs        |   4 +-
 radicle-cli/src/commands/patch/label.rs       |   7 +-
 radicle-cli/src/commands/patch/list.rs        |   4 +-
 radicle-cli/src/commands/patch/ready.rs       |   7 +-
 radicle-cli/src/commands/patch/redact.rs      |   4 +-
 radicle-cli/src/commands/patch/resolve.rs     |   5 +-
 radicle-cli/src/commands/patch/review.rs      |   3 +-
 radicle-cli/src/commands/patch/show.rs        |   4 +-
 radicle-cli/src/commands/patch/update.rs      |   4 +-
 radicle-cli/src/commands/stats.rs             |   5 +-
 radicle-cli/src/terminal.rs                   |   1 +
 radicle-cli/src/terminal/cob.rs               | 113 ++++++++++
 radicle-cli/tests/commands.rs                 |  19 ++
 radicle-node/src/runtime.rs                   |  13 +-
 radicle-node/src/test/environment.rs          |   8 +-
 radicle-remote-helper/src/lib.rs              |  38 +++-
 radicle-remote-helper/src/list.rs             |   3 +-
 radicle-remote-helper/src/push.rs             |  18 +-
 radicle-tools/src/rad-merge.rs                |   3 +-
 radicle/src/cob/cache.rs                      | 195 ++++++++++++------
 radicle/src/cob/cache/migrations.rs           |   2 +
 radicle/src/cob/cache/migrations/2.rs         | 132 ++++++++++++
 .../cache/migrations/samples/patch.v1.json    | 179 ++++++++++++++++
 .../cache/migrations/samples/patch.v2.json    | 165 +++++++++++++++
 radicle/src/cob/issue/cache.rs                |   6 +-
 radicle/src/cob/patch.rs                      |   6 +-
 radicle/src/cob/patch/cache.rs                |   8 +-
 radicle/src/profile.rs                        |  67 +++---
 42 files changed, 1013 insertions(+), 205 deletions(-)
 create mode 100644 radicle-cli/examples/rad-cob-migrate.md
 create mode 100644 radicle-cli/src/terminal/cob.rs
 create mode 100644 radicle/src/cob/cache/migrations.rs
 create mode 100644 radicle/src/cob/cache/migrations/2.rs
 create mode 100644 radicle/src/cob/cache/migrations/samples/patch.v1.json
 create mode 100644 radicle/src/cob/cache/migrations/samples/patch.v2.json

diff --git a/radicle-cli/examples/rad-cob-migrate.md b/radicle-cli/examples/rad-cob-migrate.md
new file mode 100644
index 00000000..05c8adbe
--- /dev/null
+++ b/radicle-cli/examples/rad-cob-migrate.md
@@ -0,0 +1,24 @@
+``` (fail)
+$ rad patch list
+✗ Error: collaborative objects database is out of date
+✗ Hint: run `rad cob migrate` to update your database
+```
+
+``` (fail)
+$ rad issue list
+✗ Error: collaborative objects database is out of date
+✗ Hint: run `rad cob migrate` to update your database
+```
+
+```
+$ rad cob migrate
+✓ Migration [..]/[..] in progress.. (100%)
+✓ Migrated collaborative objects database successfully (version = [..])
+```
+
+```
+$ rad issue list
+Nothing to show.
+$ rad patch list
+Nothing to show.
+```
diff --git a/radicle-cli/src/commands/clone.rs b/radicle-cli/src/commands/clone.rs
index e9fa8eee..2284cb41 100644
--- a/radicle-cli/src/commands/clone.rs
+++ b/radicle-cli/src/commands/clone.rs
@@ -9,7 +9,6 @@ use radicle::issue::cache::Issues as _;
 use radicle::patch::cache::Patches as _;
 use thiserror::Error;
 
-use radicle::cob::migrate;
 use radicle::git::raw;
 use radicle::identity::doc;
 use radicle::identity::doc::{DocError, RepoId};
@@ -183,8 +182,8 @@ pub fn run(options: Options, ctx: impl term::Context) -> anyhow::Result<()> {
     info.push([term::format::bold(proj.name()).into()]);
     info.push([term::format::italic(proj.description()).into()]);
 
-    let issues = profile.issues(&repo, migrate::ignore)?.counts()?;
-    let patches = profile.patches(&repo, migrate::ignore)?.counts()?;
+    let issues = term::cob::issues(&profile, &repo)?.counts()?;
+    let patches = term::cob::patches(&profile, &repo)?.counts()?;
 
     info.push([term::Line::spaced([
         term::format::tertiary(issues.open).into(),
diff --git a/radicle-cli/src/commands/cob.rs b/radicle-cli/src/commands/cob.rs
index 02c4bc74..2f4f2aab 100644
--- a/radicle-cli/src/commands/cob.rs
+++ b/radicle-cli/src/commands/cob.rs
@@ -5,7 +5,6 @@ use anyhow::anyhow;
 use chrono::prelude::*;
 use nonempty::NonEmpty;
 use radicle::cob;
-use radicle::cob::migrate;
 use radicle::cob::Op;
 use radicle::identity::Identity;
 use radicle::issue::cache::Issues;
@@ -27,14 +26,16 @@ pub const HELP: Help = Help {
 Usage
 
     rad cob <command> [<option>...]
-    rad cob list  --repo <rid> --type <typename>
-    rad cob log   --repo <rid> --type <typename> --object <oid> [<option>...]
-    rad cob show  --repo <rid> --type <typename> --object <oid> [<option>...]
+    rad cob list --repo <rid> --type <typename>
+    rad cob log --repo <rid> --type <typename> --object <oid> [<option>...]
+    rad cob show --repo <rid> --type <typename> --object <oid> [<option>...]
+    rad cob migrate [<option>...]
 
 Commands
 
     list                       List all COBs of a given type (--object is not needed)
     log                        Print a log of all raw operations on a COB
+    migrate                    Migrate the COB database to the latest version
 
 Log options
 
@@ -54,13 +55,26 @@ Other options
 enum OperationName {
     List,
     Log,
+    Migrate,
     Show,
 }
 
 enum Operation {
-    List,
-    Log(Rev),
-    Show(Rev),
+    List {
+        repo: RepoId,
+        type_name: cob::TypeName,
+    },
+    Log {
+        repo: RepoId,
+        rev: Rev,
+        type_name: cob::TypeName,
+    },
+    Migrate,
+    Show {
+        repo: RepoId,
+        rev: Rev,
+        type_name: cob::TypeName,
+    },
 }
 
 enum Format {
@@ -69,9 +83,7 @@ enum Format {
 }
 
 pub struct Options {
-    rid: RepoId,
     op: Operation,
-    type_name: cob::TypeName,
     format: Format,
 }
 
@@ -91,6 +103,7 @@ impl Args for Options {
                 Value(val) if op.is_none() => match val.to_string_lossy().as_ref() {
                     "list" => op = Some(OperationName::List),
                     "log" => op = Some(OperationName::Log),
+                    "migrate" => op = Some(OperationName::Migrate),
                     "show" => op = Some(OperationName::Show),
                     unknown => anyhow::bail!("unknown operation '{unknown}'"),
                 },
@@ -129,24 +142,35 @@ impl Args for Options {
                 _ => return Err(anyhow::anyhow!(arg.unexpected())),
             }
         }
+        let repo = rid.ok_or_else(|| anyhow!("a repository id must be specified with `--repo`"));
+        let type_name =
+            type_name.ok_or_else(|| anyhow!("an object type must be specified with `--type`"));
 
         Ok((
             Options {
                 op: {
                     match op.ok_or_else(|| anyhow!("a command must be specified"))? {
-                        OperationName::List => Operation::List,
-                        OperationName::Log => Operation::Log(oid.ok_or_else(|| {
-                            anyhow!("an object id must be specified with `--object`")
-                        })?),
-                        OperationName::Show => Operation::Show(oid.ok_or_else(|| {
-                            anyhow!("an object id must be specified with `--object`")
-                        })?),
+                        OperationName::List => Operation::List {
+                            repo: repo?,
+                            type_name: type_name?,
+                        },
+                        OperationName::Log => Operation::Log {
+                            repo: repo?,
+                            rev: oid.ok_or_else(|| {
+                                anyhow!("an object id must be specified with `--object`")
+                            })?,
+                            type_name: type_name?,
+                        },
+                        OperationName::Migrate => Operation::Migrate,
+                        OperationName::Show => Operation::Show {
+                            repo: repo?,
+                            rev: oid.ok_or_else(|| {
+                                anyhow!("an object id must be specified with `--object`")
+                            })?,
+                            type_name: type_name?,
+                        },
                     }
                 },
-                rid: rid
-                    .ok_or_else(|| anyhow!("a repository id must be specified with `--repo`"))?,
-                type_name: type_name
-                    .ok_or_else(|| anyhow!("an object type must be specified with `--type`"))?,
                 format: format.unwrap_or(Format::Pretty),
             },
             vec![],
@@ -157,18 +181,23 @@ impl Args for Options {
 pub fn run(options: Options, ctx: impl term::Context) -> anyhow::Result<()> {
     let profile = ctx.profile()?;
     let storage = &profile.storage;
-    let repo = storage.repository(options.rid)?;
 
     match options.op {
-        Operation::List => {
-            let cobs = list::<NonEmpty<cob::Entry>, _>(&repo, &options.type_name)?;
+        Operation::List { repo, type_name } => {
+            let repo = storage.repository(repo)?;
+            let cobs = list::<NonEmpty<cob::Entry>, _>(&repo, &type_name)?;
             for cob in cobs {
                 println!("{}", cob.id);
             }
         }
-        Operation::Log(oid) => {
+        Operation::Log {
+            repo,
+            rev: oid,
+            type_name,
+        } => {
+            let repo = storage.repository(repo)?;
             let oid = oid.resolve(&repo.backend)?;
-            let ops = cob::store::ops(&oid, &options.type_name, &repo)?;
+            let ops = cob::store::ops(&oid, &type_name, &repo)?;
 
             for op in ops.into_iter().rev() {
                 match options.format {
@@ -177,28 +206,44 @@ pub fn run(options: Options, ctx: impl term::Context) -> anyhow::Result<()> {
                 }
             }
         }
-        Operation::Show(oid) => {
+        Operation::Migrate => {
+            let mut db = profile.cobs_db_mut()?;
+            if db.check_version().is_ok() {
+                term::success!("Collaborative objects database is already up to date");
+            } else {
+                let version = db.migrate(term::cob::migrate::spinner())?;
+                term::success!(
+                    "Migrated collaborative objects database successfully (version={version})"
+                );
+            }
+        }
+        Operation::Show {
+            repo,
+            rev: oid,
+            type_name,
+        } => {
+            let repo = storage.repository(repo)?;
             let oid = &oid.resolve(&repo.backend)?;
 
-            if options.type_name == cob::patch::TYPENAME.clone() {
-                let patches = profile.patches(&repo, migrate::ignore)?;
+            if type_name == cob::patch::TYPENAME.clone() {
+                let patches = term::cob::patches(&profile, &repo)?;
                 let Some(patch) = patches.get(oid)? else {
-                    anyhow::bail!(cob::store::Error::NotFound(options.type_name, *oid))
+                    anyhow::bail!(cob::store::Error::NotFound(type_name, *oid))
                 };
                 serde_json::to_writer_pretty(std::io::stdout(), &patch)?
-            } else if options.type_name == cob::issue::TYPENAME.clone() {
-                let issues = profile.issues(&repo, migrate::ignore)?;
+            } else if type_name == cob::issue::TYPENAME.clone() {
+                let issues = term::cob::issues(&profile, &repo)?;
                 let Some(issue) = issues.get(oid)? else {
-                    anyhow::bail!(cob::store::Error::NotFound(options.type_name, *oid))
+                    anyhow::bail!(cob::store::Error::NotFound(type_name, *oid))
                 };
                 serde_json::to_writer_pretty(std::io::stdout(), &issue)?
-            } else if options.type_name == cob::identity::TYPENAME.clone() {
-                let Some(cob) = cob::get::<Identity, _>(&repo, &options.type_name, oid)? else {
-                    anyhow::bail!(cob::store::Error::NotFound(options.type_name, *oid))
+            } else if type_name == cob::identity::TYPENAME.clone() {
+                let Some(cob) = cob::get::<Identity, _>(&repo, &type_name, oid)? else {
+                    anyhow::bail!(cob::store::Error::NotFound(type_name, *oid))
                 };
                 serde_json::to_writer_pretty(std::io::stdout(), &cob.object)?
             } else {
-                anyhow::bail!("the type name '{}' is unknown", options.type_name);
+                anyhow::bail!("the type name '{type_name}' is unknown");
             }
             println!();
         }
diff --git a/radicle-cli/src/commands/inbox.rs b/radicle-cli/src/commands/inbox.rs
index 9a7e0f2a..8edfcb60 100644
--- a/radicle-cli/src/commands/inbox.rs
+++ b/radicle-cli/src/commands/inbox.rs
@@ -6,7 +6,6 @@ use anyhow::anyhow;
 
 use git_ref_format::Qualified;
 use localtime::LocalTime;
-use radicle::cob::migrate;
 use radicle::cob::TypedId;
 use radicle::identity::Identity;
 use radicle::issue::cache::Issues as _;
@@ -272,8 +271,8 @@ where
     let (_, head) = repo.head()?;
     let doc = repo.identity_doc()?;
     let proj = doc.project()?;
-    let issues = profile.issues(&repo, migrate::ignore)?;
-    let patches = profile.patches(&repo, migrate::ignore)?;
+    let issues = term::cob::issues(profile, &repo)?;
+    let patches = term::cob::patches(profile, &repo)?;
 
     let mut notifs = notifs.by_repo(&rid, sort_by.field)?.collect::<Vec<_>>();
     if !sort_by.reverse {
@@ -536,7 +535,7 @@ fn show(
 
     match n.kind {
         NotificationKind::Cob { typed_id } if typed_id.is_issue() => {
-            let issues = profile.issues(&repo, migrate::ignore)?;
+            let issues = term::cob::issues(profile, &repo)?;
             let issue = issues.get(&typed_id.id)?.unwrap();
 
             term::issue::show(
@@ -547,7 +546,7 @@ fn show(
             )?;
         }
         NotificationKind::Cob { typed_id } if typed_id.is_patch() => {
-            let patches = profile.patches(&repo, migrate::ignore)?;
+            let patches = term::cob::patches(profile, &repo)?;
             let patch = patches.get(&typed_id.id)?.unwrap();
 
             term::patch::show(&patch, &typed_id.id, false, &repo, None, profile)?;
diff --git a/radicle-cli/src/commands/issue.rs b/radicle-cli/src/commands/issue.rs
index 8e6b3a4d..07376e30 100644
--- a/radicle-cli/src/commands/issue.rs
+++ b/radicle-cli/src/commands/issue.rs
@@ -9,7 +9,7 @@ use anyhow::{anyhow, Context as _};
 
 use radicle::cob::common::{Label, Reaction};
 use radicle::cob::issue::{CloseReason, State};
-use radicle::cob::{issue, migrate, thread};
+use radicle::cob::{issue, thread};
 use radicle::crypto::Signer;
 use radicle::issue::cache::Issues as _;
 use radicle::prelude::{Did, RepoId};
@@ -459,8 +459,7 @@ pub fn run(options: Options, ctx: impl term::Context) -> anyhow::Result<()> {
                 | Operation::Edit { .. }
                 | Operation::Comment { .. }
         );
-
-    let mut issues = profile.issues_mut(&repo, migrate::ignore)?;
+    let mut issues = term::cob::issues_mut(&profile, &repo)?;
 
     match options.op {
         Operation::Edit {
diff --git a/radicle-cli/src/commands/issue/cache.rs b/radicle-cli/src/commands/issue/cache.rs
index 54bcb6d0..8993dc2e 100644
--- a/radicle-cli/src/commands/issue/cache.rs
+++ b/radicle-cli/src/commands/issue/cache.rs
@@ -1,6 +1,5 @@
 use std::ops::ControlFlow;
 
-use radicle::cob::migrate;
 use radicle::issue::IssueId;
 use radicle::storage::git::Repository;
 use radicle::storage::ReadStorage as _;
@@ -38,9 +37,8 @@ pub fn run(mode: CacheMode, profile: &Profile) -> anyhow::Result<()> {
 }
 
 fn cache(id: Option<IssueId>, repository: &Repository, profile: &Profile) -> anyhow::Result<()> {
-    let mut issues = profile.issues_mut(repository, migrate::ignore)?;
+    let mut issues = term::cob::issues_mut(profile, repository)?;
 
-    // FIXME: Should this change?
     match id {
         Some(id) => {
             issues.write(&id)?;
diff --git a/radicle-cli/src/commands/patch.rs b/radicle-cli/src/commands/patch.rs
index 35437741..c2bfc9c3 100644
--- a/radicle-cli/src/commands/patch.rs
+++ b/radicle-cli/src/commands/patch.rs
@@ -37,7 +37,7 @@ use std::ffi::OsString;
 use anyhow::anyhow;
 
 use radicle::cob::patch::PatchId;
-use radicle::cob::{migrate, patch, Label};
+use radicle::cob::{patch, Label};
 use radicle::git::RefString;
 use radicle::patch::cache::Patches as _;
 use radicle::storage::git::transport;
@@ -928,7 +928,7 @@ pub fn run(options: Options, ctx: impl term::Context) -> anyhow::Result<()> {
             label::run(&patch_id, add, delete, &profile, &repository)?;
         }
         Operation::Set { patch_id, remote } => {
-            let patches = profile.patches(&repository, migrate::ignore)?;
+            let patches = term::cob::patches(&profile, &repository)?;
             let patch_id = patch_id.resolve(&repository.backend)?;
             let patch = patches
                 .get(&patch_id)?
diff --git a/radicle-cli/src/commands/patch/archive.rs b/radicle-cli/src/commands/patch/archive.rs
index 7283bfec..6e256e63 100644
--- a/radicle-cli/src/commands/patch/archive.rs
+++ b/radicle-cli/src/commands/patch/archive.rs
@@ -1,9 +1,8 @@
-use super::*;
-
-use radicle::cob::migrate;
 use radicle::prelude::*;
 use radicle::storage::git::Repository;
 
+use super::*;
+
 pub fn run(
     patch_id: &PatchId,
     undo: bool,
@@ -11,7 +10,7 @@ pub fn run(
     repository: &Repository,
 ) -> anyhow::Result<()> {
     let signer = term::signer(profile)?;
-    let mut patches = profile.patches_mut(repository, migrate::ignore)?;
+    let mut patches = term::cob::patches_mut(profile, repository)?;
     let Ok(mut patch) = patches.get_mut(patch_id) else {
         anyhow::bail!("Patch `{patch_id}` not found");
     };
diff --git a/radicle-cli/src/commands/patch/assign.rs b/radicle-cli/src/commands/patch/assign.rs
index 15776ea0..af8d3bcc 100644
--- a/radicle-cli/src/commands/patch/assign.rs
+++ b/radicle-cli/src/commands/patch/assign.rs
@@ -2,7 +2,6 @@ use std::collections::BTreeSet;
 
 use super::*;
 
-use radicle::cob::migrate;
 use radicle::prelude::Did;
 use radicle::storage::git::Repository;
 
@@ -16,7 +15,7 @@ pub fn run(
     repository: &Repository,
 ) -> anyhow::Result<()> {
     let signer = term::signer(profile)?;
-    let mut patches = profile.patches_mut(repository, migrate::ignore)?;
+    let mut patches = term::cob::patches_mut(profile, repository)?;
     let Ok(mut patch) = patches.get_mut(patch_id) else {
         anyhow::bail!("Patch `{patch_id}` not found");
     };
diff --git a/radicle-cli/src/commands/patch/cache.rs b/radicle-cli/src/commands/patch/cache.rs
index c4cf90be..b04f5a00 100644
--- a/radicle-cli/src/commands/patch/cache.rs
+++ b/radicle-cli/src/commands/patch/cache.rs
@@ -1,6 +1,5 @@
 use std::ops::ControlFlow;
 
-use radicle::cob::migrate;
 use radicle::patch::PatchId;
 use radicle::storage::git::Repository;
 use radicle::storage::ReadStorage as _;
@@ -38,7 +37,7 @@ pub fn run(mode: CacheMode, profile: &Profile) -> anyhow::Result<()> {
 }
 
 fn cache(id: Option<PatchId>, repository: &Repository, profile: &Profile) -> anyhow::Result<()> {
-    let mut patches = profile.patches_mut(repository, migrate::ignore)?;
+    let mut patches = term::cob::patches_mut(profile, repository)?;
 
     match id {
         Some(id) => {
diff --git a/radicle-cli/src/commands/patch/checkout.rs b/radicle-cli/src/commands/patch/checkout.rs
index 11224574..03c35a5f 100644
--- a/radicle-cli/src/commands/patch/checkout.rs
+++ b/radicle-cli/src/commands/patch/checkout.rs
@@ -1,7 +1,6 @@
 use anyhow::anyhow;
 
 use git_ref_format::Qualified;
-use radicle::cob::migrate;
 use radicle::cob::patch;
 use radicle::cob::patch::RevisionId;
 use radicle::git::RefString;
@@ -39,7 +38,7 @@ pub fn run(
     profile: &Profile,
     opts: Options,
 ) -> anyhow::Result<()> {
-    let patches = profile.patches(stored, migrate::ignore)?;
+    let patches = term::cob::patches(profile, stored)?;
     let patch = patches
         .get(patch_id)?
         .ok_or_else(|| anyhow!("Patch `{patch_id}` not found"))?;
diff --git a/radicle-cli/src/commands/patch/comment.rs b/radicle-cli/src/commands/patch/comment.rs
index 0837df69..d37f7ce4 100644
--- a/radicle-cli/src/commands/patch/comment.rs
+++ b/radicle-cli/src/commands/patch/comment.rs
@@ -1,8 +1,8 @@
 use super::*;
 
 use radicle::cob;
+use radicle::cob::patch;
 use radicle::cob::thread::CommentId;
-use radicle::cob::{migrate, patch};
 use radicle::patch::ByRevision;
 use radicle::prelude::*;
 use radicle::storage::git::Repository;
@@ -20,7 +20,7 @@ pub fn run(
     profile: &Profile,
 ) -> anyhow::Result<()> {
     let signer = term::signer(profile)?;
-    let mut patches = profile.patches_mut(repo, migrate::ignore)?;
+    let mut patches = term::cob::patches_mut(profile, repo)?;
 
     let revision_id = revision_id.resolve::<cob::EntryId>(&repo.backend)?;
     let ByRevision {
diff --git a/radicle-cli/src/commands/patch/delete.rs b/radicle-cli/src/commands/patch/delete.rs
index ecce8006..c1044065 100644
--- a/radicle-cli/src/commands/patch/delete.rs
+++ b/radicle-cli/src/commands/patch/delete.rs
@@ -1,4 +1,3 @@
-use radicle::cob::migrate;
 use radicle::prelude::*;
 use radicle::storage::git::Repository;
 
@@ -6,7 +5,7 @@ use super::*;
 
 pub fn run(patch_id: &PatchId, profile: &Profile, repository: &Repository) -> anyhow::Result<()> {
     let signer = &term::signer(profile)?;
-    let mut patches = profile.patches_mut(repository, migrate::ignore)?;
+    let mut patches = term::cob::patches_mut(profile, repository)?;
     patches.remove(patch_id, signer)?;
 
     Ok(())
diff --git a/radicle-cli/src/commands/patch/diff.rs b/radicle-cli/src/commands/patch/diff.rs
index dc730c6e..19b278fd 100644
--- a/radicle-cli/src/commands/patch/diff.rs
+++ b/radicle-cli/src/commands/patch/diff.rs
@@ -1,6 +1,6 @@
 use std::process;
 
-use radicle::cob::{migrate, patch};
+use radicle::cob::patch;
 use radicle::storage::git::Repository;
 
 use super::*;
@@ -11,7 +11,7 @@ pub fn run(
     stored: &Repository,
     profile: &Profile,
 ) -> anyhow::Result<()> {
-    let patches = profile.patches(stored, migrate::ignore)?;
+    let patches = term::cob::patches(profile, stored)?;
     let Some(patch) = patches.get(patch_id)? else {
         anyhow::bail!("Patch `{patch_id}` not found");
     };
diff --git a/radicle-cli/src/commands/patch/edit.rs b/radicle-cli/src/commands/patch/edit.rs
index db041442..8050b811 100644
--- a/radicle-cli/src/commands/patch/edit.rs
+++ b/radicle-cli/src/commands/patch/edit.rs
@@ -1,7 +1,7 @@
 use super::*;
 
 use radicle::cob;
-use radicle::cob::{migrate, patch};
+use radicle::cob::patch;
 use radicle::crypto;
 use radicle::prelude::*;
 use radicle::storage::git::Repository;
@@ -16,7 +16,7 @@ pub fn run(
     repository: &Repository,
 ) -> anyhow::Result<()> {
     let signer = term::signer(profile)?;
-    let mut patches = profile.patches_mut(repository, migrate::ignore)?;
+    let mut patches = term::cob::patches_mut(profile, repository)?;
     let Ok(patch) = patches.get_mut(patch_id) else {
         anyhow::bail!("Patch `{patch_id}` not found");
     };
diff --git a/radicle-cli/src/commands/patch/label.rs b/radicle-cli/src/commands/patch/label.rs
index f98a11da..d2aa7bb1 100644
--- a/radicle-cli/src/commands/patch/label.rs
+++ b/radicle-cli/src/commands/patch/label.rs
@@ -1,8 +1,7 @@
-use super::*;
-
-use radicle::cob::migrate;
 use radicle::storage::git::Repository;
 
+use super::*;
+
 use crate::terminal as term;
 
 pub fn run(
@@ -13,7 +12,7 @@ pub fn run(
     repository: &Repository,
 ) -> anyhow::Result<()> {
     let signer = term::signer(profile)?;
-    let mut patches = profile.patches_mut(repository, migrate::ignore)?;
+    let mut patches = term::cob::patches_mut(profile, repository)?;
     let Ok(mut patch) = patches.get_mut(patch_id) else {
         anyhow::bail!("Patch `{patch_id}` not found");
     };
diff --git a/radicle-cli/src/commands/patch/list.rs b/radicle-cli/src/commands/patch/list.rs
index 249c51e1..ed016b09 100644
--- a/radicle-cli/src/commands/patch/list.rs
+++ b/radicle-cli/src/commands/patch/list.rs
@@ -1,7 +1,7 @@
 use std::collections::{BTreeMap, BTreeSet};
 
+use radicle::cob::patch;
 use radicle::cob::patch::{Patch, PatchId};
-use radicle::cob::{migrate, patch};
 use radicle::patch::cache::Patches as _;
 use radicle::prelude::*;
 use radicle::profile::Profile;
@@ -21,7 +21,7 @@ pub fn run(
     repository: &Repository,
     profile: &Profile,
 ) -> anyhow::Result<()> {
-    let patches = profile.patches(repository, migrate::ignore)?;
+    let patches = term::cob::patches(profile, repository)?;
 
     let mut all = Vec::new();
     let iter = match filter {
diff --git a/radicle-cli/src/commands/patch/ready.rs b/radicle-cli/src/commands/patch/ready.rs
index bdf69995..d40d74f2 100644
--- a/radicle-cli/src/commands/patch/ready.rs
+++ b/radicle-cli/src/commands/patch/ready.rs
@@ -1,9 +1,8 @@
-use super::*;
-
-use radicle::cob::migrate;
 use radicle::prelude::*;
 use radicle::storage::git::Repository;
 
+use super::*;
+
 pub fn run(
     patch_id: &PatchId,
     undo: bool,
@@ -11,7 +10,7 @@ pub fn run(
     repository: &Repository,
 ) -> anyhow::Result<bool> {
     let signer = term::signer(profile)?;
-    let mut patches = profile.patches_mut(repository, migrate::ignore)?;
+    let mut patches = term::cob::patches_mut(profile, repository)?;
     let Ok(mut patch) = patches.get_mut(patch_id) else {
         anyhow::bail!("Patch `{patch_id}` not found");
     };
diff --git a/radicle-cli/src/commands/patch/redact.rs b/radicle-cli/src/commands/patch/redact.rs
index 1a966103..f66ff18d 100644
--- a/radicle-cli/src/commands/patch/redact.rs
+++ b/radicle-cli/src/commands/patch/redact.rs
@@ -1,4 +1,4 @@
-use radicle::cob::{migrate, patch};
+use radicle::cob::patch;
 use radicle::git::Oid;
 use radicle::prelude::*;
 use radicle::storage::git::Repository;
@@ -13,7 +13,7 @@ pub fn run(
     repository: &Repository,
 ) -> anyhow::Result<()> {
     let signer = &term::signer(profile)?;
-    let mut patches = profile.patches_mut(repository, migrate::ignore)?;
+    let mut patches = term::cob::patches_mut(profile, repository)?;
 
     let revision_id = revision_id.resolve::<Oid>(&repository.backend)?;
     let patch::ByRevision {
diff --git a/radicle-cli/src/commands/patch/resolve.rs b/radicle-cli/src/commands/patch/resolve.rs
index c96a2c09..e7b87f9a 100644
--- a/radicle-cli/src/commands/patch/resolve.rs
+++ b/radicle-cli/src/commands/patch/resolve.rs
@@ -1,5 +1,4 @@
 use anyhow::anyhow;
-use radicle::cob::migrate;
 use radicle::cob::thread::CommentId;
 use radicle::patch::{self, PatchId};
 use radicle::patch::{cache::Patches as _, ReviewId};
@@ -16,7 +15,7 @@ pub fn resolve(
     profile: &Profile,
 ) -> anyhow::Result<()> {
     let signer = term::signer(profile)?;
-    let mut patches = profile.patches_mut(repo, migrate::ignore)?;
+    let mut patches = term::cob::patches_mut(profile, repo)?;
     let patch = patches
         .get(&patch_id)?
         .ok_or_else(|| anyhow!("Patch `{patch_id}` not found"))?;
@@ -33,7 +32,7 @@ pub fn unresolve(
     profile: &Profile,
 ) -> anyhow::Result<()> {
     let signer = term::signer(profile)?;
-    let mut patches = profile.patches_mut(repo, migrate::ignore)?;
+    let mut patches = term::cob::patches_mut(profile, repo)?;
     let patch = patches
         .get(&patch_id)?
         .ok_or_else(|| anyhow!("Patch `{patch_id}` not found"))?;
diff --git a/radicle-cli/src/commands/patch/review.rs b/radicle-cli/src/commands/patch/review.rs
index ae706f1c..08dcbd22 100644
--- a/radicle-cli/src/commands/patch/review.rs
+++ b/radicle-cli/src/commands/patch/review.rs
@@ -3,7 +3,6 @@ mod builder;
 
 use anyhow::{anyhow, Context};
 
-use radicle::cob::migrate;
 use radicle::cob::patch::{PatchId, RevisionId, Verdict};
 use radicle::git;
 use radicle::prelude::*;
@@ -62,7 +61,7 @@ pub fn run(
         "couldn't load repository {} from local state",
         repository.id
     ))?;
-    let mut patches = profile.patches_mut(repository, migrate::ignore)?;
+    let mut patches = term::cob::patches_mut(profile, repository)?;
     let mut patch = patches
         .get_mut(&patch_id)
         .context(format!("couldn't find patch {patch_id} locally"))?;
diff --git a/radicle-cli/src/commands/patch/show.rs b/radicle-cli/src/commands/patch/show.rs
index 436556af..15dd98cd 100644
--- a/radicle-cli/src/commands/patch/show.rs
+++ b/radicle-cli/src/commands/patch/show.rs
@@ -1,6 +1,6 @@
 use std::process;
 
-use radicle::cob::{migrate, patch};
+use radicle::cob::patch;
 use radicle::git;
 use radicle::storage::git::Repository;
 
@@ -32,7 +32,7 @@ pub fn run(
     stored: &Repository,
     workdir: Option<&git::raw::Repository>,
 ) -> anyhow::Result<()> {
-    let patches = profile.patches(stored, migrate::ignore)?;
+    let patches = term::cob::patches(profile, stored)?;
     let Some(patch) = patches.get(patch_id).map_err(|e| Error::WithHint {
         err: e.into(),
         hint: "reset the cache with `rad patch cache` and try again",
diff --git a/radicle-cli/src/commands/patch/update.rs b/radicle-cli/src/commands/patch/update.rs
index 6778e854..b2cc6f7e 100644
--- a/radicle-cli/src/commands/patch/update.rs
+++ b/radicle-cli/src/commands/patch/update.rs
@@ -1,4 +1,4 @@
-use radicle::cob::{migrate, patch};
+use radicle::cob::patch;
 use radicle::git;
 use radicle::prelude::*;
 use radicle::storage::git::Repository;
@@ -19,7 +19,7 @@ pub fn run(
     let head_branch = try_branch(workdir.head()?)?;
 
     let (_, target_oid) = get_merge_target(repository, &head_branch)?;
-    let mut patches = profile.patches_mut(repository, migrate::ignore)?;
+    let mut patches = term::cob::patches_mut(profile, repository)?;
     let Ok(mut patch) = patches.get_mut(&patch_id) else {
         anyhow::bail!("Patch `{patch_id}` not found");
     };
diff --git a/radicle-cli/src/commands/stats.rs b/radicle-cli/src/commands/stats.rs
index 11099a53..8e6efc17 100644
--- a/radicle-cli/src/commands/stats.rs
+++ b/radicle-cli/src/commands/stats.rs
@@ -3,7 +3,6 @@ use std::path::Path;
 
 use localtime::LocalDuration;
 use localtime::LocalTime;
-use radicle::cob::migrate;
 use radicle::git;
 use radicle::issue::cache::Issues as _;
 use radicle::node::address;
@@ -96,8 +95,8 @@ pub fn run(_options: Options, ctx: impl term::Context) -> anyhow::Result<()> {
 
     for repo in storage.repositories()? {
         let repo = storage.repository(repo.rid)?;
-        let issues = profile.issues(&repo, migrate::ignore)?.counts()?;
-        let patches = profile.patches(&repo, migrate::ignore)?.counts()?;
+        let issues = term::cob::issues(&profile, &repo)?.counts()?;
+        let patches = term::cob::patches(&profile, &repo)?.counts()?;
 
         stats.local.issues += issues.total();
         stats.local.patches += patches.total();
diff --git a/radicle-cli/src/terminal.rs b/radicle-cli/src/terminal.rs
index 45f2edbc..23573ad1 100644
--- a/radicle-cli/src/terminal.rs
+++ b/radicle-cli/src/terminal.rs
@@ -4,6 +4,7 @@ pub mod format;
 pub mod io;
 pub mod job;
 pub use io::signer;
+pub mod cob;
 pub mod comment;
 pub mod highlight;
 pub mod issue;
diff --git a/radicle-cli/src/terminal/cob.rs b/radicle-cli/src/terminal/cob.rs
new file mode 100644
index 00000000..ba628757
--- /dev/null
+++ b/radicle-cli/src/terminal/cob.rs
@@ -0,0 +1,113 @@
+use radicle::{
+    cob::{
+        self,
+        cache::{MigrateCallback, MigrateProgress},
+    },
+    profile,
+    storage::ReadRepository,
+    Profile,
+};
+use radicle_term as term;
+
+use crate::terminal;
+
+/// Hint to migrate COB database.
+pub const MIGRATION_HINT: &str = "run `rad cob migrate` to update your database";
+
+/// COB migration progress spinner.
+pub struct MigrateSpinner {
+    spinner: Option<term::Spinner>,
+}
+
+impl Default for MigrateSpinner {
+    /// Create a new [`MigrateSpinner`].
+    fn default() -> Self {
+        Self { spinner: None }
+    }
+}
+
+impl MigrateCallback for MigrateSpinner {
+    fn progress(&mut self, progress: MigrateProgress) {
+        self.spinner
+            .get_or_insert_with(|| term::spinner("Migration in progress.."))
+            .message(format!(
+                "Migration {}/{} in progress.. ({}%)",
+                progress.migration.current(),
+                progress.migration.total(),
+                progress.rows.percentage()
+            ));
+
+        if progress.is_done() {
+            if let Some(spinner) = self.spinner.take() {
+                spinner.finish()
+            }
+        }
+    }
+}
+
+/// Migrate functions.
+pub mod migrate {
+    use super::MigrateSpinner;
+
+    /// Display migration progress via a spinner.
+    pub fn spinner() -> MigrateSpinner {
+        MigrateSpinner::default()
+    }
+}
+
+/// Return a read-only handle for the patches cache.
+pub fn patches<'a, R>(
+    profile: &Profile,
+    repository: &'a R,
+) -> Result<cob::patch::Cache<cob::patch::Patches<'a, R>, cob::cache::StoreReader>, anyhow::Error>
+where
+    R: ReadRepository + cob::Store,
+{
+    profile.patches(repository).map_err(with_hint)
+}
+
+/// Return a read-write handle for the patches cache.
+pub fn patches_mut<'a, R>(
+    profile: &Profile,
+    repository: &'a R,
+) -> Result<cob::patch::Cache<cob::patch::Patches<'a, R>, cob::cache::StoreWriter>, anyhow::Error>
+where
+    R: ReadRepository + cob::Store,
+{
+    profile.patches_mut(repository).map_err(with_hint)
+}
+
+/// Return a read-only handle for the issues cache.
+pub fn issues<'a, R>(
+    profile: &Profile,
+    repository: &'a R,
+) -> Result<cob::issue::Cache<cob::issue::Issues<'a, R>, cob::cache::StoreReader>, anyhow::Error>
+where
+    R: ReadRepository + cob::Store,
+{
+    profile.issues(repository).map_err(with_hint)
+}
+
+/// Return a read-write handle for the issues cache.
+pub fn issues_mut<'a, R>(
+    profile: &Profile,
+    repository: &'a R,
+) -> Result<cob::issue::Cache<cob::issue::Issues<'a, R>, cob::cache::StoreWriter>, anyhow::Error>
+where
+    R: ReadRepository + cob::Store,
+{
+    profile.issues_mut(repository).map_err(with_hint)
+}
+
+/// Adds a hint to the COB out-of-date database error.
+fn with_hint(e: profile::Error) -> anyhow::Error {
+    match e {
+        profile::Error::CobsCache(cob::cache::Error::OutOfDate) => {
+            anyhow::Error::from(terminal::args::Error::WithHint {
+                err: e.into(),
+                hint: MIGRATION_HINT,
+            })
+        }
+        e => anyhow::Error::from(e),
+    }
+}
diff --git a/radicle-cli/tests/commands.rs b/radicle-cli/tests/commands.rs
index d2cfad7d..d0520b68 100644
--- a/radicle-cli/tests/commands.rs
+++ b/radicle-cli/tests/commands.rs
@@ -186,6 +186,25 @@ fn rad_cob_show() {
     test("examples/rad-cob-show.md", &working, Some(home), []).unwrap();
 }
 
+#[test]
+fn rad_cob_migrate() {
+    let mut environment = Environment::new();
+    let profile = environment.profile(config::profile("alice"));
+    let home = &profile.home;
+    let working = environment.tmp().join("working");
+
+    home.cobs_db_mut()
+        .unwrap()
+        .raw_query(|conn| conn.execute("PRAGMA user_version = 0"))
+        .unwrap();
+
+    // Setup a test repository.
+    fixtures::repository(&working);
+
+    test("examples/rad-init.md", &working, Some(home), []).unwrap();
+    test("examples/rad-cob-migrate.md", &working, Some(home), []).unwrap();
+}
+
 #[test]
 fn rad_init() {
     let mut environment = Environment::new();
diff --git a/radicle-node/src/runtime.rs b/radicle-node/src/runtime.rs
index 0210198b..0abfcc13 100644
--- a/radicle-node/src/runtime.rs
+++ b/radicle-node/src/runtime.rs
@@ -8,6 +8,7 @@ use std::{fs, io, net};
 use crossbeam_channel as chan;
 use cyphernet::Ecdh;
 use netservices::resource::NetAccept;
+use radicle::cob::migrate;
 use radicle_fetch::FetchLimit;
 use radicle_signals::Signal;
 use reactor::poller::popol;
@@ -141,7 +142,17 @@ impl Runtime {
         let policies = home.policies_mut()?;
         let policies = policy::Config::new(policy, policies);
         let notifications = home.notifications_mut()?;
-        let cobs_cache = cob::cache::Store::open(home.cobs().join(cob::cache::COBS_DB_FILE))?;
+        let mut cobs_cache = cob::cache::Store::open(home.cobs().join(cob::cache::COBS_DB_FILE))?;
+
+        match cobs_cache.check_version() {
+            Ok(()) => {}
+            Err(cob::cache::Error::OutOfDate) => {
+                log::info!(target: "node", "Migrating COBs cache..");
+                let version = cobs_cache.migrate(migrate::log)?;
+                log::info!(target: "node", "Migration of COBs cache complete (version={version})..");
+            }
+            Err(e) => return Err(e.into()),
+        }
 
         log::info!(target: "node", "Default seeding policy set to '{}'", &policy);
         log::info!(target: "node", "Initializing service ({:?})..", network);
diff --git a/radicle-node/src/test/environment.rs b/radicle-node/src/test/environment.rs
index fd3ab43f..4fc6fb52 100644
--- a/radicle-node/src/test/environment.rs
+++ b/radicle-node/src/test/environment.rs
@@ -10,8 +10,7 @@ use std::{
 use crossbeam_channel as chan;
 
 use localtime::LocalTime;
-use radicle::cob::cache::COBS_DB_FILE;
-use radicle::cob::issue;
+use radicle::cob::{issue, migrate};
 use radicle::crypto::ssh::{keystore::MemorySigner, Keystore};
 use radicle::crypto::test::signer::MockSigner;
 use radicle::crypto::{KeyPair, Seed, Signer};
@@ -111,7 +110,6 @@ impl Environment {
         let keystore = Keystore::new(&home.keys());
         let keypair = KeyPair::from_seed(Seed::from([!(self.users as u8); 32]));
         let policies_db = home.node().join(POLICIES_DB_FILE);
-        let cobs_db = home.cobs().join(COBS_DB_FILE);
         let now = LocalTime::now();
 
         config.write(&home.config()).unwrap();
@@ -126,8 +124,10 @@ impl Environment {
         .unwrap();
         let public_key = keypair.pk.into();
 
+        let mut db = home.cobs_db_mut().unwrap();
+        db.migrate(migrate::ignore).unwrap();
+
         policy::Store::open(policies_db).unwrap();
-        cob::cache::Store::open(cobs_db).unwrap();
         home.database_mut()
             .unwrap()
             .init(
diff --git a/radicle-remote-helper/src/lib.rs b/radicle-remote-helper/src/lib.rs
index 63b864e6..6c2d60a2 100644
--- a/radicle-remote-helper/src/lib.rs
+++ b/radicle-remote-helper/src/lib.rs
@@ -11,12 +11,13 @@ use std::path::PathBuf;
 use std::str::FromStr;
 use std::{env, fmt, io};
 
-use radicle_cli::git::Rev;
 use thiserror::Error;
 
-use radicle::git;
 use radicle::storage::git::transport::local::{Url, UrlError};
 use radicle::storage::{ReadRepository, WriteStorage};
+use radicle::{cob, profile};
+use radicle::{git, storage, Profile};
+use radicle_cli::git::Rev;
 use radicle_cli::terminal as cli;
 
 #[derive(Debug, Error)]
@@ -259,3 +260,36 @@ pub(crate) fn hint(s: impl fmt::Display) {
 pub(crate) fn warn(s: impl fmt::Display) {
     eprintln!("{}", cli::format::hint(format!("warn: {s}")));
 }
+
+/// Get the patch store.
+pub(crate) fn patches<'a, R: ReadRepository + cob::Store>(
+    profile: &Profile,
+    repo: &'a R,
+) -> Result<cob::patch::Cache<cob::patch::Patches<'a, R>, cob::cache::StoreReader>, list::Error> {
+    match profile.patches(repo) {
+        Ok(patches) => Ok(patches),
+        Err(err @ profile::Error::CobsCache(cob::cache::Error::OutOfDate)) => {
+            hint(cli::cob::MIGRATION_HINT);
+            Err(err.into())
+        }
+        Err(err) => Err(err.into()),
+    }
+}
+
+/// Get the mutable patch store.
+pub(crate) fn patches_mut<'a>(
+    profile: &Profile,
+    repo: &'a storage::git::Repository,
+) -> Result<
+    cob::patch::Cache<cob::patch::Patches<'a, storage::git::Repository>, cob::cache::StoreWriter>,
+    push::Error,
+> {
+    match profile.patches_mut(repo) {
+        Ok(patches) => Ok(patches),
+        Err(err @ profile::Error::CobsCache(cob::cache::Error::OutOfDate)) => {
+            hint(cli::cob::MIGRATION_HINT);
+            Err(err.into())
+        }
+        Err(err) => Err(err.into()),
+    }
+}
diff --git a/radicle-remote-helper/src/list.rs b/radicle-remote-helper/src/list.rs
index 0228d918..e4713089 100644
--- a/radicle-remote-helper/src/list.rs
+++ b/radicle-remote-helper/src/list.rs
@@ -3,7 +3,6 @@ use radicle::profile;
 use thiserror::Error;
 
 use radicle::cob;
-use radicle::cob::migrate;
 use radicle::git;
 use radicle::storage::git::transport::local::Url;
 use radicle::storage::ReadRepository;
@@ -88,7 +87,7 @@ fn patch_refs<R: ReadRepository + cob::Store + 'static>(
     profile: &Profile,
     stored: &R,
 ) -> Result<(), Error> {
-    let patches = profile.patches(stored, migrate::ignore)?;
+    let patches = crate::patches(profile, stored)?;
     for patch in patches.list()? {
         let Ok((id, patch)) = patch else {
             // Ignore patches that fail to decode.
diff --git a/radicle-remote-helper/src/push.rs b/radicle-remote-helper/src/push.rs
index a584c0ea..32e98318 100644
--- a/radicle-remote-helper/src/push.rs
+++ b/radicle-remote-helper/src/push.rs
@@ -9,8 +9,8 @@ use thiserror::Error;
 
 use radicle::cob;
 use radicle::cob::object::ParseObjectId;
+use radicle::cob::patch;
 use radicle::cob::patch::cache::Patches as _;
-use radicle::cob::{migrate, patch};
 use radicle::crypto::Signer;
 use radicle::explorer::ExplorerResource;
 use radicle::git::canonical;
@@ -219,6 +219,7 @@ pub fn run(
             }
             Command::Push(git::Refspec { src, dst, force }) => {
                 let working = git::raw::Repository::open(working)?;
+                let patches = crate::patches_mut(profile, stored)?;
 
                 if dst == &*rad::PATCHES_REFNAME {
                     patch_open(
@@ -227,7 +228,7 @@ pub fn run(
                         &nid,
                         &working,
                         stored,
-                        profile.patches_mut(stored, migrate::ignore)?,
+                        patches,
                         &signer,
                         profile,
                         opts.clone(),
@@ -247,7 +248,7 @@ pub fn run(
                             &nid,
                             &working,
                             stored,
-                            profile.patches_mut(stored, migrate::ignore)?,
+                            patches,
                             &signer,
                             opts.clone(),
                         )
@@ -323,16 +324,7 @@ pub fn run(
                                 Err(e) => return Err(e.into()),
                             };
                         }
-                        push(
-                            src,
-                            &dst,
-                            *force,
-                            &nid,
-                            &working,
-                            stored,
-                            profile.patches_mut(stored, migrate::ignore)?,
-                            &signer,
-                        )
+                        push(src, &dst, *force, &nid, &working, stored, patches, &signer)
                     }
                 }
             }
diff --git a/radicle-tools/src/rad-merge.rs b/radicle-tools/src/rad-merge.rs
index 143b9666..c909adee 100644
--- a/radicle-tools/src/rad-merge.rs
+++ b/radicle-tools/src/rad-merge.rs
@@ -2,7 +2,6 @@ use std::collections::HashSet;
 use std::env;
 
 use anyhow::{anyhow, bail};
-use radicle::cob::migrate;
 use radicle::cob::patch::{PatchId, RevisionId};
 use radicle::git::Oid;
 use radicle::storage::ReadStorage;
@@ -27,7 +26,7 @@ fn main() -> anyhow::Result<()> {
     let profile = radicle::Profile::load()?;
     let (working, rid) = radicle::rad::cwd()?;
     let stored = profile.storage.repository(rid)?;
-    let mut patches = profile.patches_mut(&stored, migrate::ignore)?;
+    let mut patches = profile.patches_mut(&stored)?;
     let mut patch = patches.get_mut(&pid)?;
 
     if patch.is_merged() {
diff --git a/radicle/src/cob/cache.rs b/radicle/src/cob/cache.rs
index 16cb239c..1a506c66 100644
--- a/radicle/src/cob/cache.rs
+++ b/radicle/src/cob/cache.rs
@@ -1,3 +1,5 @@
+mod migrations;
+
 use std::collections::HashMap;
 use std::convert::Infallible;
 use std::fmt;
@@ -23,34 +25,51 @@ const DB_WRITE_TIMEOUT: time::Duration = time::Duration::from_secs(6);
 
 /// Database migrations.
 /// The first migration is the creation of the initial tables.
-const MIGRATIONS: &[Migration] = &[Migration::Sql(include_str!("cache/migrations/1.sql"))];
+const MIGRATIONS: &[Migration] = &[
+    Migration::Sql(include_str!("cache/migrations/1.sql")),
+    Migration::Native(migrations::_2::run),
+];
 
 /// Function signature for native migrations.
-type MigrateFn = fn(&sql::Connection, Progress, &dyn MigrateCallback) -> Result<usize, Error>;
+type MigrateFn = fn(&sql::Connection, &Progress, &mut dyn MigrateCallback) -> Result<usize, Error>;
 
 /// A database migration.
 enum Migration {
     /// Migration written in SQL.
     Sql(&'static str),
     /// Migration function written in Rust.
-    #[allow(dead_code)]
     Native(MigrateFn),
 }
 
+/// Progress of a database migration.
+#[derive(Debug)]
+pub struct MigrateProgress<'a> {
+    /// Progress in the list of migrations.
+    pub migration: &'a Progress,
+    /// Progress within each individual migration.
+    pub rows: &'a Progress,
+}
+
+impl<'a> MigrateProgress<'a> {
+    /// If we're done with the migration.
+    pub fn is_done(&self) -> bool {
+        self.migration.current() == self.migration.total()
+            && self.rows.current() == self.rows.total()
+    }
+}
+
 /// Something that can process migration progress.
 pub trait MigrateCallback {
     /// A migration has progressed.
-    /// The first [`Progress`] parameter refers to the progress within the list of migrations.
-    /// The second [`Progress`] parameter refers to the progress within the current migration.
-    fn progress(&mut self, migration: Progress, item: Progress) -> Result<bool, Error>;
+    fn progress(&mut self, progress: MigrateProgress<'_>);
 }
 
 impl<F> MigrateCallback for F
 where
-    F: Fn(Progress, Progress) -> Result<bool, Error>,
+    F: Fn(MigrateProgress),
 {
-    fn progress(&mut self, migration: Progress, item: Progress) -> Result<bool, Error> {
-        (self)(migration, item)
+    fn progress(&mut self, progress: MigrateProgress) {
+        (self)(progress)
     }
 }
 
@@ -59,21 +78,18 @@ pub mod migrate {
     use super::*;
 
     /// Log progress via installed logger at "info" level.
-    pub fn log(migration: Progress, item: Progress) -> Result<bool, Error> {
-        log::info!(
+    pub fn log(progress: MigrateProgress<'_>) {
+        log::trace!(
             target: "db",
             "Migration {}/{} in progress.. ({}%)",
-            migration.current() + 1,
-            migration.total(),
-            item.percentage()
+            progress.migration.current(),
+            progress.migration.total(),
+            progress.rows.percentage()
         );
-        Ok(true)
     }
 
     /// Ignore progress, just migrate.
-    pub fn ignore(_migration: Progress, _item: Progress) -> Result<bool, Error> {
-        Ok(true)
-    }
+    pub fn ignore(_progress: MigrateProgress<'_>) {}
 }
 
 #[derive(Error, Debug)]
@@ -81,9 +97,18 @@ pub enum Error {
     /// An Internal error.
     #[error("internal error: {0}")]
     Internal(#[from] sql::Error),
+    /// Malformed JSON schema, eg. missing fields or wrong field types.
+    #[error("malformed JSON schema")]
+    MalformedJsonSchema,
+    /// Malformed JSON data, ie. not valid JSON.
+    #[error("malformed JSON data: {0}")]
+    MalformedJson(serde_json::Error),
     /// No rows returned in query result.
     #[error("no rows returned")]
     NoRows,
+    /// Schema is out of date, migrations need to be run.
+    #[error("collaborative objects database is out of date")]
+    OutOfDate,
 }
 
 /// Read and write to the store.
@@ -148,7 +173,6 @@ impl Store<Write> {
     pub fn open<P: AsRef<Path>>(path: P) -> Result<Self, Error> {
         let mut db = sql::Connection::open_thread_safe(path)?;
         db.set_busy_timeout(DB_WRITE_TIMEOUT.as_millis() as usize)?;
-        migrate(&db, migrate::ignore)?;
 
         Ok(Self {
             db: Arc::new(db),
@@ -159,7 +183,6 @@ impl Store<Write> {
     /// Create a new in-memory database.
     pub fn memory() -> Result<Self, Error> {
         let db = Arc::new(sql::Connection::open_thread_safe(":memory:")?);
-        migrate(&db, migrate::ignore)?;
 
         Ok(Self {
             db,
@@ -167,6 +190,11 @@ impl Store<Write> {
         })
     }
 
+    /// Builder method that migrates the database.
+    pub fn with_migrations<M: MigrateCallback>(mut self, callback: M) -> Result<Self, Error> {
+        self.migrate(callback).map(|_| self)
+    }
+
     /// Turn this handle into a read-only handle.
     pub fn read_only(self) -> Store<Read> {
         Store {
@@ -183,6 +211,47 @@ impl Store<Write> {
     {
         transaction(&self.db, query)
     }
+
+    /// Migrate this database to the latest version.
+    /// Returns the verison migrated to.
+    pub fn migrate<M: MigrateCallback>(&mut self, callback: M) -> Result<usize, Error> {
+        self.migrate_to(MIGRATIONS.len(), callback)
+    }
+
+    /// Migrate this database to the given target version.
+    /// Returns the verison migrated to.
+    pub fn migrate_to<M: MigrateCallback>(
+        &mut self,
+        target: usize,
+        mut callback: M,
+    ) -> Result<usize, Error> {
+        let db = &self.db;
+        let mut version = version(db)?;
+        let total = MIGRATIONS.len();
+
+        for (i, migration) in MIGRATIONS.iter().enumerate().take(target).skip(version) {
+            let current = i + 1;
+
+            transaction(db, |db| {
+                match migration {
+                    Migration::Sql(query) => {
+                        db.execute(query)?;
+                        callback.progress(MigrateProgress {
+                            migration: &Progress { total, current },
+                            rows: &Progress::done(1),
+                        });
+                    }
+                    Migration::Native(migrate) => {
+                        migrate(db, &Progress { total, current }, &mut callback)?;
+                    }
+                }
+                version = bump(db)?;
+
+                Ok::<_, Error>(())
+            })?;
+        }
+        Ok(version)
+    }
 }
 
 impl<T> Store<T> {
@@ -190,6 +259,14 @@ impl<T> Store<T> {
     pub fn version(&self) -> Result<usize, Error> {
         version(&self.db)
     }
+
+    /// Check if the database version is out of date, ie. we need to migrate.
+    pub fn check_version(&self) -> Result<(), Error> {
+        if version(&self.db)? < MIGRATIONS.len() {
+            return Err(Error::OutOfDate);
+        }
+        Ok(())
+    }
 }
 
 /// Get the `user_version` value from the database header.
@@ -214,39 +291,6 @@ fn bump(db: &sql::Connection) -> Result<usize, Error> {
     Ok(new as usize)
 }
 
-/// Migrate the database to the latest schema.
-fn migrate<M>(db: &sql::Connection, mut callback: M) -> Result<usize, Error>
-where
-    M: MigrateCallback,
-{
-    let mut version = version(db)?;
-    let total = MIGRATIONS.len();
-
-    for (i, migration) in MIGRATIONS.iter().enumerate() {
-        if i < version {
-            continue;
-        }
-        transaction(db, |db| {
-            match migration {
-                Migration::Sql(query) => {
-                    db.execute(query)?;
-                    callback.progress(
-                        Progress { total, current: i },
-                        Progress::done(db.change_count()),
-                    )?;
-                }
-                Migration::Native(migrate) => {
-                    migrate(db, Progress { total, current: i }, &callback)?;
-                }
-            }
-            version = bump(db)?;
-
-            Ok::<_, Error>(())
-        })?;
-    }
-    Ok(version)
-}
-
 /// Update a COB object in the cache.
 pub trait Update<T> {
     /// The output type, if any, for a successful update.
@@ -351,6 +395,7 @@ impl<T> Remove<T> for NoCache {
 ///
 /// See [`crate::cob::issue::Cache::write_all`] and
 /// [`crate::cob::patch::Cache::write_all`].
+#[derive(Debug)]
 pub struct Progress {
     current: usize,
     total: usize,
@@ -386,11 +431,45 @@ impl Progress {
     }
 
     /// Return the percentage of the progress made.
-    ///
-    /// # Panics
-    ///
-    /// If the `total` provided is `0`.
     pub fn percentage(&self) -> f32 {
-        (self.current as f32 / self.total as f32) * 100.0
+        if self.total == 0 {
+            100.
+        } else {
+            (self.current as f32 / self.total as f32) * 100.0
+        }
+    }
+}
+
+#[cfg(test)]
+#[allow(clippy::unwrap_used)]
+mod tests {
+    use super::*;
+    use crate::assert_matches;
+
+    #[test]
+    fn test_check_version() {
+        let mut db = StoreWriter::memory().unwrap();
+        assert_matches!(db.check_version(), Err(Error::OutOfDate));
+
+        db.migrate(migrate::ignore).unwrap();
+        assert_matches!(db.check_version(), Ok(()));
+    }
+
+    #[test]
+    fn test_migrate_to() {
+        let mut db = StoreWriter::memory().unwrap();
+        assert_eq!(db.version().unwrap(), 0);
+
+        assert_eq!(db.migrate_to(1, migrate::ignore).unwrap(), 1); // 0 -> 1
+        assert_eq!(db.version().unwrap(), 1);
+
+        assert_eq!(db.migrate_to(2, migrate::ignore).unwrap(), 2); // 1 -> 2
+        assert_eq!(db.version().unwrap(), 2);
+
+        assert_eq!(db.migrate_to(1, migrate::ignore).unwrap(), 2); // No-op.
+        assert_eq!(db.version().unwrap(), 2);
+
+        assert_eq!(db.migrate_to(99, migrate::ignore).unwrap(), 2); // No-op.
+        assert_eq!(db.version().unwrap(), 2);
     }
 }
diff --git a/radicle/src/cob/cache/migrations.rs b/radicle/src/cob/cache/migrations.rs
new file mode 100644
index 00000000..417f9b09
--- /dev/null
+++ b/radicle/src/cob/cache/migrations.rs
@@ -0,0 +1,2 @@
+#[path = "migrations/2.rs"]
+pub mod _2;
diff --git a/radicle/src/cob/cache/migrations/2.rs b/radicle/src/cob/cache/migrations/2.rs
new file mode 100644
index 00000000..e6393cbe
--- /dev/null
+++ b/radicle/src/cob/cache/migrations/2.rs
@@ -0,0 +1,132 @@
+//! Migration to update the patch `reviews` JSON representation.
+use crate::cob::cache::*;
+use serde_json as json;
+
+/// Run migration.
+pub fn run(
+    db: &sql::Connection,
+    migration: &Progress,
+    callback: &mut dyn MigrateCallback,
+) -> Result<usize, Error> {
+    // Select patches with reviews.
+    let rows = db
+        .prepare("SELECT id, patch FROM patches WHERE json_extract(patch, '$.reviews') != '{}'")?
+        .into_iter()
+        .collect::<Vec<_>>();
+    // Query to update a patch to the new schema.
+    let mut update = db.prepare(
+        "UPDATE patches
+         SET patch = ?1
+         WHERE id = ?2",
+    )?;
+    let mut progress = Progress::new(rows.len());
+    callback.progress(MigrateProgress {
+        migration,
+        rows: &progress,
+    });
+
+    for row in rows {
+        let row = row?;
+        let id = row.read::<&str, _>("id");
+        let mut patch = json::from_str::<json::Value>(row.read::<&str, _>("patch"))
+            .map_err(Error::MalformedJson)?;
+        let patch = patch.as_object_mut().ok_or(Error::MalformedJsonSchema)?;
+        let revisions = patch["revisions"]
+            .as_object_mut()
+            .ok_or(Error::MalformedJsonSchema)?;
+        let mut transformed = false;
+
+        for (_, r) in revisions.iter_mut() {
+            let Some(revision) = r.as_object_mut() else {
+                // Redacted revision (`null`).
+                continue;
+            };
+            let reviews = revision
+                .get_mut("reviews")
+                .ok_or(Error::MalformedJsonSchema)?
+                .as_object_mut()
+                .ok_or(Error::MalformedJsonSchema)?;
+
+            for (_, review) in reviews.iter_mut() {
+                if let Some(list) = review.as_array_mut() {
+                    if let Some(last) = list.pop() {
+                        *review = last;
+                        transformed = true;
+                    }
+                }
+            }
+        }
+
+        if transformed {
+            let obj = json::to_string(&patch).map_err(Error::MalformedJson)?;
+
+            update.reset()?;
+            update.bind((1, obj.as_str()))?;
+            update.bind((2, id))?;
+            update.next()?;
+            progress.inc();
+
+            callback.progress(MigrateProgress {
+                migration,
+                rows: &progress,
+            });
+        }
+    }
+    Ok(progress.current())
+}
+
+#[allow(clippy::unwrap_used)]
+#[cfg(test)]
+mod tests {
+    use crate::cob::cache::*;
+
+    // Before the migration.
+    const PATCH_V1: &str = include_str!("samples/patch.v1.json");
+    // After the migration.
+    const PATCH_V2: &str = include_str!("samples/patch.v2.json");
+
+    #[test]
+    fn test_migration_2() {
+        let mut db = StoreWriter::memory().unwrap();
+        db.migrate_to(1, migrate::ignore).unwrap();
+        db.raw_query(|conn| {
+            let mut stmt = conn.prepare(
+                "INSERT INTO patches (id, repo, patch)
+                 VALUES (?1, ?2, ?3)",
+            )?;
+            stmt.bind((1, "016a91d2029ee71b9aee8d927664caf1b7885346"))?;
+            stmt.bind((2, "rad:z4V1sjrXqjvFdnCUbxPFqd5p4DtH5"))?;
+            stmt.bind((3, PATCH_V1))?;
+            stmt.next()?;
+
+            Ok::<_, sql::Error>(())
+        })
+        .unwrap();
+
+        assert_eq!(db.migrate_to(2, migrate::ignore).unwrap(), 2);
+
+        let row = db
+            .raw_query(|conn| {
+                Ok::<_, sql::Error>(
+                    conn.prepare("SELECT patch FROM patches LIMIT 1")?
+                        .into_iter()
+                        .next()
+                        .unwrap()
+                        .unwrap(),
+                )
+            })
+            .unwrap();
+
+        let patch = row.read::<&str, _>("patch");
+        let actual: serde_json::Value = serde_json::from_str(patch).unwrap();
+        let expected: serde_json::Value = serde_json::from_str(PATCH_V2).unwrap();
+
+        assert_eq!(actual, expected);
+    }
+
+    #[test]
+    fn test_patch_json_deserialization() {
+        serde_json::from_str::<crate::cob::patch::Patch>(PATCH_V1).unwrap_err();
+        serde_json::from_str::<crate::cob::patch::Patch>(PATCH_V2).unwrap();
+    }
+}
diff --git a/radicle/src/cob/cache/migrations/samples/patch.v1.json b/radicle/src/cob/cache/migrations/samples/patch.v1.json
new file mode 100644
index 00000000..1e51b00f
--- /dev/null
+++ b/radicle/src/cob/cache/migrations/samples/patch.v1.json
@@ -0,0 +1,179 @@
+{
+  "title": "Remove loading indicator from Share button",
+  "author": {
+    "id": "did:key:z6MkkfM3tPXNPrPevKr3uSiQtHPuwnNhu2yUVjgd2jXVsVz5"
+  },
+  "state": {
+    "status": "merged",
+    "revision": "7bdb1c8a273ace2a0be4b93e9b1b525dc1696e68",
+    "commit": "f6a77bec9401c35b1baa19d356405a9d77ed8e0d"
+  },
+  "target": "delegates",
+  "labels": [],
+  "merges": {},
+  "revisions": {
+    "016a91d2029ee71b9aee8d927664caf1b7885346": {
+      "id": "016a91d2029ee71b9aee8d927664caf1b7885346",
+      "author": { "id": "did:key:z6MkkfM3tPXNPrPevKr3uSiQtHPuwnNhu2yUVjgd2jXVsVz5" },
+      "description": [
+        {
+          "author": "z6MkkfM3tPXNPrPevKr3uSiQtHPuwnNhu2yUVjgd2jXVsVz5",
+          "timestamp": 1710884599000,
+          "body": "",
+          "embeds": []
+        }
+      ],
+      "base": "daba9fca8281405134d64036bde300f2181f73fe",
+      "oid": "c24c942261647993fcb0d34224f5c98b0f30266f",
+      "discussion": {
+        "comments": {},
+        "timeline": []
+      },
+      "reviews": {},
+      "timestamp": 1710884599000,
+      "resolves": [],
+      "reactions": []
+    },
+    "4a98168bfe6e16934b922e7d5df3cf68c7e7d085": {
+      "id": "4a98168bfe6e16934b922e7d5df3cf68c7e7d085",
+      "author": { "id": "did:key:z6MkkfM3tPXNPrPevKr3uSiQtHPuwnNhu2yUVjgd2jXVsVz5" },
+      "description": [
+        {
+          "author": "z6MkkfM3tPXNPrPevKr3uSiQtHPuwnNhu2yUVjgd2jXVsVz5",
+          "timestamp": 1710939751000,
+          "body": "Instead of disabeling the Share button, adds a min-width param",
+          "embeds": []
+        }
+      ],
+      "base": "9c65ee97e8f97a2ae130c36b6bbc1071cc31fd93",
+      "oid": "5dd21bdb51a6a37dc5957d81f63058344ec6b8e5",
+      "discussion": {
+        "comments": {},
+        "timeline": []
+      },
+      "reviews": {
+        "z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx": [
+          {
+            "id": "0076749b04e878ca4387bb60cd80a281af2285bb",
+            "author": { "id": "did:key:z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx" },
+            "verdict": "accept",
+            "summary": null,
+            "comments": {
+              "comments": {},
+              "timeline": []
+            },
+            "labels": [],
+            "timestamp": 1710941558000
+          },
+          {
+            "id": "89d45fb371eb2622ba88188d474347cc526d80bb",
+            "author": { "id": "did:key:z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx" },
+            "verdict": "accept",
+            "summary": null,
+            "comments": {
+              "comments": {},
+              "timeline": []
+            },
+            "labels": [],
+            "timestamp": 1710947885000
+          }
+        ]
+      },
+      "timestamp": 1710939751000,
+      "resolves": [],
+      "reactions": []
+    },
+    "6a71b034d661994d188abac920b41e7f9c57d85d": {
+      "id": "6a71b034d661994d188abac920b41e7f9c57d85d",
+      "author": { "id": "did:key:z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx" },
+      "description": [
+        {
+          "author": "z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx",
+          "timestamp": 1710940872000,
+          "body": "Rebase.",
+          "embeds": []
+        }
+      ],
+      "base": "cddf8b40fc352eb84885e5adeed65b3abb0639fc",
+      "oid": "239bc7e5c786ac65d8456164a97bab2419da441a",
+      "discussion": {
+        "comments": {},
+        "timeline": []
+      },
+      "reviews": {},
+      "timestamp": 1710940872000,
+      "resolves": [],
+      "reactions": []
+    },
+    "7bdb1c8a273ace2a0be4b93e9b1b525dc1696e68": {
+      "id": "7bdb1c8a273ace2a0be4b93e9b1b525dc1696e68",
+      "author": { "id": "did:key:z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx" },
+      "description": [
+        {
+          "author": "z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx",
+          "timestamp": 1710947911000,
+          "body": "Rebase.",
+          "embeds": []
+        }
+      ],
+      "base": "fe7cd1b4e52d15c27f89e23d98e8ccad9c3a8bff",
+      "oid": "f6a77bec9401c35b1baa19d356405a9d77ed8e0d",
+      "discussion": {
+        "comments": {},
+        "timeline": []
+      },
+      "reviews": {},
+      "timestamp": 1710947911000,
+      "resolves": [],
+      "reactions": []
+    },
+    "eee18b0bb43e8673c3b32f3e151556906b1214f6": {
+      "id": "eee18b0bb43e8673c3b32f3e151556906b1214f6",
+      "author": {
+        "id": "did:key:z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx"
+      },
+      "description": [
+        {
+          "author": "z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx",
+          "timestamp": 1710941119000,
+          "body": "Rebase.",
+          "embeds": []
+        }
+      ],
+      "base": "cddf8b40fc352eb84885e5adeed65b3abb0639fc",
+      "oid": "a9bdc6b43df080adb8086427b363590aea17bf82",
+      "discussion": {
+        "comments": {},
+        "timeline": []
+      },
+      "reviews": {},
+      "timestamp": 1710941119000,
+      "resolves": [],
+      "reactions": []
+    }
+  },
+  "assignees": [],
+  "timeline": [
+    "016a91d2029ee71b9aee8d927664caf1b7885346",
+    "4a98168bfe6e16934b922e7d5df3cf68c7e7d085",
+    "6a71b034d661994d188abac920b41e7f9c57d85d",
+    "eee18b0bb43e8673c3b32f3e151556906b1214f6",
+    "0076749b04e878ca4387bb60cd80a281af2285bb",
+    "e5b200b71a7f413db5697d0e1f9ce267a2095a45",
+    "27c4e9b9e3837adf417eb816bcea8521b563a030",
+    "89d45fb371eb2622ba88188d474347cc526d80bb",
+    "7bdb1c8a273ace2a0be4b93e9b1b525dc1696e68",
+    "c7d8213bab37f40c8cb6668a98ce7292f6d05bf3",
+    "081559bfae2f729486f50d93600d1dac0f996d81"
+  ],
+  "reviews": {
+    "0076749b04e878ca4387bb60cd80a281af2285bb": [
+      "4a98168bfe6e16934b922e7d5df3cf68c7e7d085",
+      "z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx"
+    ],
+    "89d45fb371eb2622ba88188d474347cc526d80bb": [
+      "4a98168bfe6e16934b922e7d5df3cf68c7e7d085",
+      "z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx"
+    ]
+  }
+}
diff --git a/radicle/src/cob/cache/migrations/samples/patch.v2.json b/radicle/src/cob/cache/migrations/samples/patch.v2.json
new file mode 100644
index 00000000..4318b888
--- /dev/null
+++ b/radicle/src/cob/cache/migrations/samples/patch.v2.json
@@ -0,0 +1,165 @@
+{
+  "title": "Remove loading indicator from Share button",
+  "author": {
+    "id": "did:key:z6MkkfM3tPXNPrPevKr3uSiQtHPuwnNhu2yUVjgd2jXVsVz5"
+  },
+  "state": {
+    "status": "merged",
+    "revision": "7bdb1c8a273ace2a0be4b93e9b1b525dc1696e68",
+    "commit": "f6a77bec9401c35b1baa19d356405a9d77ed8e0d"
+  },
+  "target": "delegates",
+  "labels": [],
+  "merges": {},
+  "revisions": {
+    "016a91d2029ee71b9aee8d927664caf1b7885346": {
+      "id": "016a91d2029ee71b9aee8d927664caf1b7885346",
+      "author": { "id": "did:key:z6MkkfM3tPXNPrPevKr3uSiQtHPuwnNhu2yUVjgd2jXVsVz5" },
+      "description": [
+        {
+          "author": "z6MkkfM3tPXNPrPevKr3uSiQtHPuwnNhu2yUVjgd2jXVsVz5",
+          "timestamp": 1710884599000,
+          "body": "",
+          "embeds": []
+        }
+      ],
+      "base": "daba9fca8281405134d64036bde300f2181f73fe",
+      "oid": "c24c942261647993fcb0d34224f5c98b0f30266f",
+      "discussion": {
+        "comments": {},
+        "timeline": []
+      },
+      "reviews": {},
+      "timestamp": 1710884599000,
+      "resolves": [],
+      "reactions": []
+    },
+    "4a98168bfe6e16934b922e7d5df3cf68c7e7d085": {
+      "id": "4a98168bfe6e16934b922e7d5df3cf68c7e7d085",
+      "author": { "id": "did:key:z6MkkfM3tPXNPrPevKr3uSiQtHPuwnNhu2yUVjgd2jXVsVz5" },
+      "description": [
+        {
+          "author": "z6MkkfM3tPXNPrPevKr3uSiQtHPuwnNhu2yUVjgd2jXVsVz5",
+          "timestamp": 1710939751000,
+          "body": "Instead of disabeling the Share button, adds a min-width param",
+          "embeds": []
+        }
+      ],
+      "base": "9c65ee97e8f97a2ae130c36b6bbc1071cc31fd93",
+      "oid": "5dd21bdb51a6a37dc5957d81f63058344ec6b8e5",
+      "discussion": {
+        "comments": {},
+        "timeline": []
+      },
+      "reviews": {
+        "z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx": {
+          "id": "89d45fb371eb2622ba88188d474347cc526d80bb",
+          "author": { "id": "did:key:z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx" },
+          "verdict": "accept",
+          "summary": null,
+          "comments": {
+            "comments": {},
+            "timeline": []
+          },
+          "labels": [],
+          "timestamp": 1710947885000
+        }
+      },
+      "timestamp": 1710939751000,
+      "resolves": [],
+      "reactions": []
+    },
+    "6a71b034d661994d188abac920b41e7f9c57d85d": {
+      "id": "6a71b034d661994d188abac920b41e7f9c57d85d",
+      "author": { "id": "did:key:z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx" },
+      "description": [
+        {
+          "author": "z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx",
+          "timestamp": 1710940872000,
+          "body": "Rebase.",
+          "embeds": []
+        }
+      ],
+      "base": "cddf8b40fc352eb84885e5adeed65b3abb0639fc",
+      "oid": "239bc7e5c786ac65d8456164a97bab2419da441a",
+      "discussion": {
+        "comments": {},
+        "timeline": []
+      },
+      "reviews": {},
+      "timestamp": 1710940872000,
+      "resolves": [],
+      "reactions": []
+    },
+    "7bdb1c8a273ace2a0be4b93e9b1b525dc1696e68": {
+      "id": "7bdb1c8a273ace2a0be4b93e9b1b525dc1696e68",
+      "author": { "id": "did:key:z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx" },
+      "description": [
+        {
+          "author": "z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx",
+          "timestamp": 1710947911000,
+          "body": "Rebase.",
+          "embeds": []
+        }
+      ],
+      "base": "fe7cd1b4e52d15c27f89e23d98e8ccad9c3a8bff",
+      "oid": "f6a77bec9401c35b1baa19d356405a9d77ed8e0d",
+      "discussion": {
+        "comments": {},
+        "timeline": []
+      },
+      "reviews": {},
+      "timestamp": 1710947911000,
+      "resolves": [],
+      "reactions": []
+    },
+    "eee18b0bb43e8673c3b32f3e151556906b1214f6": {
+      "id": "eee18b0bb43e8673c3b32f3e151556906b1214f6",
+      "author": {
+        "id": "did:key:z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx"
+      },
+      "description": [
+        {
+          "author": "z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx",
+          "timestamp": 1710941119000,
+          "body": "Rebase.",
+          "embeds": []
+        }
+      ],
+      "base": "cddf8b40fc352eb84885e5adeed65b3abb0639fc",
+      "oid": "a9bdc6b43df080adb8086427b363590aea17bf82",
+      "discussion": {
+        "comments": {},
+        "timeline": []
+      },
+      "reviews": {},
+      "timestamp": 1710941119000,
+      "resolves": [],
+      "reactions": []
+    }
+  },
+  "assignees": [],
+  "timeline": [
+    "016a91d2029ee71b9aee8d927664caf1b7885346",
+    "4a98168bfe6e16934b922e7d5df3cf68c7e7d085",
+    "6a71b034d661994d188abac920b41e7f9c57d85d",
+    "eee18b0bb43e8673c3b32f3e151556906b1214f6",
+    "0076749b04e878ca4387bb60cd80a281af2285bb",
+    "e5b200b71a7f413db5697d0e1f9ce267a2095a45",
+    "27c4e9b9e3837adf417eb816bcea8521b563a030",
+    "89d45fb371eb2622ba88188d474347cc526d80bb",
+    "7bdb1c8a273ace2a0be4b93e9b1b525dc1696e68",
+    "c7d8213bab37f40c8cb6668a98ce7292f6d05bf3",
+    "081559bfae2f729486f50d93600d1dac0f996d81"
+  ],
+  "reviews": {
+    "0076749b04e878ca4387bb60cd80a281af2285bb": [
+      "4a98168bfe6e16934b922e7d5df3cf68c7e7d085",
+      "z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx"
+    ],
+    "89d45fb371eb2622ba88188d474347cc526d80bb": [
+      "4a98168bfe6e16934b922e7d5df3cf68c7e7d085",
+      "z6MkwPUeUS2fJMfc2HZN1RQTQcTTuhw4HhPySB8JeUg2mVvx"
+    ]
+  }
+}
diff --git a/radicle/src/cob/issue/cache.rs b/radicle/src/cob/issue/cache.rs
index 26788697..be93060a 100644
--- a/radicle/src/cob/issue/cache.rs
+++ b/radicle/src/cob/issue/cache.rs
@@ -534,6 +534,7 @@ mod tests {
     use radicle_cob::ObjectId;
 
     use crate::cob::cache::{Store, Update, Write};
+    use crate::cob::migrate;
     use crate::cob::thread::Thread;
     use crate::issue::{CloseReason, Issue, IssueCounts, IssueId, State};
     use crate::test::arbitrary;
@@ -542,7 +543,10 @@ mod tests {
     use super::{Cache, Issues};
 
     fn memory(store: MockRepository) -> Cache<MockRepository, Store<Write>> {
-        let cache = Store::<Write>::memory().unwrap();
+        let cache = Store::<Write>::memory()
+            .unwrap()
+            .with_migrations(migrate::ignore)
+            .unwrap();
         Cache { store, cache }
     }
 
diff --git a/radicle/src/cob/patch.rs b/radicle/src/cob/patch.rs
index d546054d..00a67664 100644
--- a/radicle/src/cob/patch.rs
+++ b/radicle/src/cob/patch.rs
@@ -2739,6 +2739,8 @@ mod test {
     use crate::test::arbitrary::gen;
     use crate::test::storage::MockRepository;
 
+    use cob::migrate;
+
     #[test]
     fn test_json_serialization() {
         let edit = Action::Label {
@@ -3352,8 +3354,10 @@ mod test {
         let branch = checkout.branch_with([("README", b"Hello World!")]);
         let mut patches = {
             let path = alice.tmp.path().join("cobs.db");
-            let db = cob::cache::Store::open(path).unwrap();
+            let mut db = cob::cache::Store::open(path).unwrap();
             let store = cob::patch::Patches::open(&*alice.repo).unwrap();
+
+            db.migrate(migrate::ignore).unwrap();
             cob::patch::Cache::open(store, db)
         };
         let mut patch = patches
diff --git a/radicle/src/cob/patch/cache.rs b/radicle/src/cob/patch/cache.rs
index 109951fa..16c89f6b 100644
--- a/radicle/src/cob/patch/cache.rs
+++ b/radicle/src/cob/patch/cache.rs
@@ -362,7 +362,7 @@ impl Update<Patch> for StoreWriter {
             "INSERT INTO patches (id, repo, patch)
              VALUES (?1, ?2, ?3)
              ON CONFLICT DO UPDATE
-             SET patch =  (?3)",
+             SET patch = (?3)",
         )?;
 
         stmt.bind((1, sql::Value::String(id.to_string())))?;
@@ -705,6 +705,7 @@ mod tests {
     use radicle_cob::ObjectId;
 
     use crate::cob::cache::{Store, Update, Write};
+    use crate::cob::migrate;
     use crate::cob::thread::{Comment, Thread};
     use crate::cob::Author;
     use crate::patch::{
@@ -718,7 +719,10 @@ mod tests {
     use super::{Cache, Patches};
 
     fn memory(store: MockRepository) -> Cache<MockRepository, Store<Write>> {
-        let cache = Store::<Write>::memory().unwrap();
+        let cache = Store::<Write>::memory()
+            .unwrap()
+            .with_migrations(migrate::ignore)
+            .unwrap();
         Cache { store, cache }
     }
 
diff --git a/radicle/src/profile.rs b/radicle/src/profile.rs
index cb7fd430..54cd8c47 100644
--- a/radicle/src/profile.rs
+++ b/radicle/src/profile.rs
@@ -20,6 +20,7 @@ use std::{fs, io};
 use localtime::LocalTime;
 use thiserror::Error;
 
+use crate::cob::migrate;
 use crate::crypto::ssh::agent::Agent;
 use crate::crypto::ssh::{keystore, Keystore, Passphrase};
 use crate::crypto::{PublicKey, Signer};
@@ -229,6 +230,10 @@ impl Profile {
                 config.node.external_addresses.iter(),
             )?;
 
+        // Migrate COBs cache.
+        let mut cobs = home.cobs_db_mut()?;
+        cobs.migrate(migrate::ignore)?;
+
         transport::local::register(storage.clone());
 
         Ok(Profile {
@@ -561,71 +566,83 @@ impl Home {
         self.database_mut()
     }
 
-    /// Return a read-only handle for the issues cache.
-    pub fn issues<'a, R, M>(
-        &self,
-        repository: &'a R,
-        _migrate: M,
-    ) -> Result<cob::issue::Cache<cob::issue::Issues<'a, R>, cob::cache::StoreReader>, Error>
-    where
-        M: cob::MigrateCallback,
-        R: ReadRepository + cob::Store,
-    {
+    /// Get read access to the COBs cache.
+    pub fn cobs_db(&self) -> Result<cob::cache::StoreReader, Error> {
         let path = self.cobs().join(cob::cache::COBS_DB_FILE);
         let db = cob::cache::Store::reader(path)?;
+
+        Ok(db)
+    }
+
+    /// Get write access to the COBs cache.
+    pub fn cobs_db_mut(&self) -> Result<cob::cache::StoreWriter, Error> {
+        let path = self.cobs().join(cob::cache::COBS_DB_FILE);
+        let db = cob::cache::Store::open(path)?;
+
+        Ok(db)
+    }
+
+    /// Return a read-only handle for the issues cache.
+    pub fn issues<'a, R>(
+        &self,
+        repository: &'a R,
+    ) -> Result<cob::issue::Cache<cob::issue::Issues<'a, R>, cob::cache::StoreReader>, Error>
+    where
+        R: ReadRepository + cob::Store,
+    {
+        let db = self.cobs_db()?;
         let store = cob::issue::Issues::open(repository)?;
 
+        db.check_version()?;
+
         Ok(cob::issue::Cache::reader(store, db))
     }
 
     /// Return a read-write handle for the issues cache.
-    pub fn issues_mut<'a, R, M>(
+    pub fn issues_mut<'a, R>(
         &self,
         repository: &'a R,
-        _migrate: M,
     ) -> Result<cob::issue::Cache<cob::issue::Issues<'a, R>, cob::cache::StoreWriter>, Error>
     where
-        M: cob::MigrateCallback,
         R: ReadRepository + cob::Store,
     {
-        let path = self.cobs().join(cob::cache::COBS_DB_FILE);
-        let db = cob::cache::Store::open(path)?;
+        let db = self.cobs_db_mut()?;
         let store = cob::issue::Issues::open(repository)?;
 
+        db.check_version()?;
+
         Ok(cob::issue::Cache::open(store, db))
     }
 
     /// Return a read-only handle for the patches cache.
-    pub fn patches<'a, R, M>(
+    pub fn patches<'a, R>(
         &self,
         repository: &'a R,
-        _migrate: M,
     ) -> Result<cob::patch::Cache<cob::patch::Patches<'a, R>, cob::cache::StoreReader>, Error>
     where
-        M: cob::MigrateCallback,
         R: ReadRepository + cob::Store,
     {
-        let path = self.cobs().join(cob::cache::COBS_DB_FILE);
-        let db = cob::cache::Store::reader(path)?;
+        let db = self.cobs_db()?;
         let store = cob::patch::Patches::open(repository)?;
 
+        db.check_version()?;
+
         Ok(cob::patch::Cache::reader(store, db))
     }
 
     /// Return a read-write handle for the patches cache.
-    pub fn patches_mut<'a, R, M>(
+    pub fn patches_mut<'a, R>(
         &self,
         repository: &'a R,
-        _migrate: M,
     ) -> Result<cob::patch::Cache<cob::patch::Patches<'a, R>, cob::cache::StoreWriter>, Error>
     where
-        M: cob::MigrateCallback,
         R: ReadRepository + cob::Store,
     {
-        let path = self.cobs().join(cob::cache::COBS_DB_FILE);
-        let db = cob::cache::Store::open(path)?;
+        let db = self.cobs_db_mut()?;
         let store = cob::patch::Patches::open(repository)?;
 
+        db.check_version()?;
+
         Ok(cob::patch::Cache::open(store, db))
     }
 }