krill 0.16.0

Resource Public Key Infrastructure (RPKI) daemon
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73

//! Data migration for the publication server.

pub mod pre_0_10_0;
pub mod pre_0_13_0;
pub mod pre_0_14_0;


use log::info;
use rpki::ca::idexchange::MyHandle;
use crate::commons::KrillResult;
use crate::commons::eventsourcing::WalStore;
use crate::commons::storage::{Ident, KeyValueStore};
use crate::constants::PUBSERVER_CONTENT_NS;
use crate::config::Config;
use crate::server::pubd::content::RepositoryContent;
use self::pre_0_13_0::OldRepositoryContent;


/// Migrate v0.12.x RepositoryContent to the new 0.13.0+ format.
/// Apply any open WAL changes to the source first.
pub fn migrate_0_12_pubd_objects(config: &Config) -> KrillResult<bool> {
    let old_store: WalStore<OldRepositoryContent> = WalStore::create(
        &config.storage_uri, PUBSERVER_CONTENT_NS
    )?;
    let repo_content_handle = MyHandle::new("0".into());

    if old_store.has(&repo_content_handle)? {
        let old_repo_content =
            old_store.get_latest(&repo_content_handle)?.as_ref().clone();
        let repo_content: RepositoryContent =
            old_repo_content.try_into()?;
        let upgrade_store = KeyValueStore::create_upgrade_store(
            &config.storage_uri,
            PUBSERVER_CONTENT_NS,
        )?;
        upgrade_store.store(
            Some(const { Ident::make("0") }),
            const { Ident::make("snapshot.json") },
            &repo_content
        )?;
        Ok(true)
    } else {
        Ok(false)
    }
}

/// The format of the RepositoryContent did not change in 0.12, but
/// the location and way of storing it did. So, migrate if present.
pub fn migrate_pre_0_12_pubd_objects(config: &Config) -> KrillResult<()> {
    let old_store = KeyValueStore::create(
        &config.storage_uri, PUBSERVER_CONTENT_NS
    )?;
    if let Ok(Some(old_repo_content)) =
        old_store.get::<OldRepositoryContent>(
            None, const { Ident::make("0.json") }
        )
    {
        info!("Found pre 0.12.0 RC2 publication server data. Migrating..");
        let repo_content: RepositoryContent = old_repo_content.try_into()?;

        let upgrade_store = KeyValueStore::create_upgrade_store(
            &config.storage_uri, PUBSERVER_CONTENT_NS,
        )?;
        upgrade_store.store(
            Some(const { Ident::make("0") }),
            const { Ident::make("snapshot.json") },
            &repo_content
        )?;
    }

    Ok(())
}