rovenue/cache/

schema.rs

pub const MIGRATION_V1: &str = r#"
CREATE TABLE schema_meta (
    version INTEGER PRIMARY KEY
);

CREATE TABLE identity (
    id INTEGER PRIMARY KEY CHECK (id = 1),
    anon_id TEXT NOT NULL,
    known_user_id TEXT,
    created_at_ms INTEGER NOT NULL
);

CREATE TABLE entitlements (
    user_scope TEXT NOT NULL,
    entitlement_id TEXT NOT NULL,
    is_active INTEGER NOT NULL,
    product_id TEXT,
    expires_at_ms INTEGER,
    updated_at_ms INTEGER NOT NULL,
    PRIMARY KEY (user_scope, entitlement_id)
);

CREATE TABLE etag_cache (
    resource TEXT PRIMARY KEY,
    etag TEXT NOT NULL,
    updated_at_ms INTEGER NOT NULL
);

INSERT INTO schema_meta (version) VALUES (1);
"#;

pub const MIGRATION_V2: &str = r#"
ALTER TABLE entitlements ADD COLUMN store TEXT NOT NULL DEFAULT '';
ALTER TABLE entitlements ADD COLUMN product_identifier TEXT NOT NULL DEFAULT '';
ALTER TABLE entitlements ADD COLUMN expires_iso TEXT;

CREATE TABLE credit_balance (
    user_scope TEXT PRIMARY KEY,
    balance INTEGER NOT NULL,
    updated_at_ms INTEGER NOT NULL
);

UPDATE schema_meta SET version = 2;
"#;

pub const MIGRATION_V3: &str = r#"
CREATE TABLE app_account_tokens (
    scope TEXT PRIMARY KEY,
    token TEXT NOT NULL,
    created_at TEXT NOT NULL
);

CREATE TABLE session_events (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    kind TEXT NOT NULL,
    occurred_at TEXT NOT NULL,
    duration_ms INTEGER
);
CREATE INDEX idx_session_events_id ON session_events(id);

UPDATE schema_meta SET version = 3;
"#;

pub const MIGRATION_V4: &str = r#"
DROP TABLE IF EXISTS identity;

CREATE TABLE IF NOT EXISTS identity (
    id INTEGER PRIMARY KEY CHECK (id = 1),
    rovenue_id TEXT NOT NULL,
    app_user_id TEXT,
    synced INTEGER NOT NULL DEFAULT 1,
    created_at_ms INTEGER NOT NULL
);

UPDATE schema_meta SET version = 4;
"#;

pub const MIGRATION_V5: &str = r#"
CREATE TABLE offerings_cache (
    resource TEXT PRIMARY KEY,
    body TEXT NOT NULL,
    updated_at_ms INTEGER NOT NULL
);

UPDATE schema_meta SET version = 5;
"#;

pub const MIGRATION_V6: &str = "\
CREATE TABLE attribute_mutations (\
    id INTEGER PRIMARY KEY AUTOINCREMENT,\
    key TEXT NOT NULL,\
    value TEXT\
);\
CREATE INDEX idx_attribute_mutations_id ON attribute_mutations(id);\
UPDATE schema_meta SET version = 6;\
";

pub const MIGRATION_V7: &str = r#"
CREATE TABLE remote_config_cache (
    resource TEXT PRIMARY KEY,
    body TEXT NOT NULL,
    updated_at_ms INTEGER NOT NULL
);

UPDATE schema_meta SET version = 7;
"#;

pub const MIGRATION_V8: &str = r#"
CREATE TABLE virtual_currency_balance (
    user_scope    TEXT NOT NULL,
    code          TEXT NOT NULL,
    balance       INTEGER NOT NULL,
    updated_at_ms INTEGER NOT NULL,
    PRIMARY KEY (user_scope, code)
);

CREATE TABLE experiment_exposure (
    user_scope    TEXT NOT NULL,
    experiment_id TEXT NOT NULL,
    variant_id    TEXT NOT NULL,
    exposed_at_ms INTEGER NOT NULL,
    PRIMARY KEY (user_scope, experiment_id, variant_id)
);

UPDATE schema_meta SET version = 8;
"#;

pub const MIGRATION_V9: &str = r#"
CREATE TABLE funnel_install (
    id INTEGER PRIMARY KEY CHECK (id = 1),
    install_id TEXT NOT NULL,
    created_at_ms INTEGER NOT NULL
);

CREATE TABLE funnel_claim_state (
    install_id TEXT PRIMARY KEY,
    state TEXT NOT NULL,
    subscriber_id TEXT,
    claimed_at_ms INTEGER,
    created_at_ms INTEGER NOT NULL
);

UPDATE schema_meta SET version = 9;
"#;

pub const MIGRATION_V10: &str = r#"
CREATE TABLE placements_cache (
    resource TEXT PRIMARY KEY,
    body TEXT NOT NULL,
    updated_at_ms INTEGER NOT NULL
);

UPDATE schema_meta SET version = 10;
"#;

pub const MIGRATION_V11: &str = r#"
CREATE TABLE event_queue (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    envelope_json TEXT NOT NULL
);
CREATE INDEX idx_event_queue_id ON event_queue(id);

UPDATE schema_meta SET version = 11;
"#;

/// Repairs the chain after MIGRATION_V11 was edited in place (b35f9bcb5):
/// it first shipped creating `paywall_events`, and a store that reached v11
/// then never runs the renamed text, so it has no `event_queue` and drops
/// every funnel event. Idempotent on purpose — a store migrated after the
/// edit already has `event_queue` (with queued events to keep). The paywall
/// rail is gone and nothing drains `paywall_events`, so it is dropped.
/// Never edit a migration that has shipped; append one like this.
pub const MIGRATION_V12: &str = r#"
CREATE TABLE IF NOT EXISTS event_queue (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    envelope_json TEXT NOT NULL
);
CREATE INDEX IF NOT EXISTS idx_event_queue_id ON event_queue(id);
DROP TABLE IF EXISTS paywall_events;

UPDATE schema_meta SET version = 12;
"#;

/// Session events and attribute mutations carry the wire identity they were
/// recorded under, so each drains under its own subscriber and `log_out`
/// has nothing to discard (it used to clear both, losing whatever the 30 s
/// flush had not sent yet). Recreated rather than altered: rows buffered
/// before this carry no identity to post them under.
pub const MIGRATION_V13: &str = r#"
DROP TABLE IF EXISTS session_events;
CREATE TABLE session_events (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    rovenue_id TEXT NOT NULL,
    kind TEXT NOT NULL,
    occurred_at TEXT NOT NULL,
    duration_ms INTEGER
);
CREATE INDEX idx_session_events_id ON session_events(id);

DROP TABLE IF EXISTS attribute_mutations;
CREATE TABLE attribute_mutations (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    rovenue_id TEXT NOT NULL,
    key TEXT NOT NULL,
    value TEXT
);
CREATE INDEX idx_attribute_mutations_id ON attribute_mutations(id);

UPDATE schema_meta SET version = 13;
"#;

pub const MIGRATIONS: &[&str] = &[
    MIGRATION_V1,
    MIGRATION_V2,
    MIGRATION_V3,
    MIGRATION_V4,
    MIGRATION_V5,
    MIGRATION_V6,
    MIGRATION_V7,
    MIGRATION_V8,
    MIGRATION_V9,
    MIGRATION_V10,
    MIGRATION_V11,
    MIGRATION_V12,
    MIGRATION_V13,
];
pub const LATEST: u32 = 13;