@ -1,3 +1,60 @@
/ * *
* TimeSafari Database Migration Definitions
*
* This module defines all database schema migrations for the TimeSafari application .
* Each migration represents a specific version of the database schema and contains
* the SQL statements needed to upgrade from the previous version .
*
* # # Migration Philosophy
*
* TimeSafari follows a structured approach to database migrations :
*
* 1 . * * Sequential Numbering * * : Migrations are numbered sequentially ( 001 , 002 , etc . )
* 2 . * * Descriptive Names * * : Each migration has a clear , descriptive name
* 3 . * * Single Purpose * * : Each migration focuses on one logical schema change
* 4 . * * Forward - Only * * : Migrations are designed to move the schema forward
* 5 . * * Idempotent Design * * : The migration system handles re - runs gracefully
*
* # # Migration Structure
*
* Each migration follows this pattern :
* ` ` ` typescript
* {
* name : "XXX_descriptive_name" ,
* sql : "SQL statements to execute"
* }
* ` ` `
*
* # # Database Architecture
*
* TimeSafari uses SQLite for local data storage with the following core tables :
*
* - * * accounts * * : User identity and cryptographic keys
* - * * secret * * : Encrypted application secrets
* - * * settings * * : Application configuration and preferences
* - * * contacts * * : User ' s contact network and trust relationships
* - * * logs * * : Application event logging and debugging
* - * * temp * * : Temporary data storage for operations
*
* # # Privacy and Security
*
* The database schema is designed with privacy - first principles :
* - User identifiers ( DIDs ) are kept separate from personal data
* - Cryptographic keys are stored securely
* - Contact visibility is user - controlled
* - All sensitive data can be encrypted at rest
*
* # # Usage
*
* This file is automatically loaded during application startup . The migrations
* are registered with the migration service and applied as needed based on the
* current database state .
*
* @author Matthew Raymer
* @version 1.0 . 0
* @since 2025 - 06 - 30
* /
import { import {
registerMigration , registerMigration ,
runMigrations as runMigrationsService , runMigrations as runMigrationsService ,
@ -5,143 +62,301 @@ import {
import { DEFAULT_ENDORSER_API_SERVER } from "@/constants/app" ; import { DEFAULT_ENDORSER_API_SERVER } from "@/constants/app" ;
import { arrayBufferToBase64 } from "@/libs/crypto" ; import { arrayBufferToBase64 } from "@/libs/crypto" ;
// Generate a random secret for the secret table
/ * *
* Generate a cryptographically secure random secret for the secret table
// It's not really secure to maintain the secret next to the user's data.
*
// However, until we have better hooks into a real wallet or reliable secure
* Note : This approach stores the secret alongside user data for convenience .
// storage, we'll do this for user convenience. As they sign more records
* In a production environment with hardware security module s or dedicated
// and integrate with more people, they'll value it more and want to be more
* secure storage , this secret should be stored separately . As users build
// secure, so we'll prompt them to take steps to back it up, properly encrypt,
* their trust networks and sign more records , they should migrate to more
// etc. At the beginning, we'll prompt for a password, then we'll prompt for a
* secure key management solutions .
// PWA so it's not in a browser... and then we hope to be integrated with a
*
// real wallet or something else more secure.
* @returns Base64 - encoded random secret ( 32 bytes )
* /
// One might ask: why encrypt at all? We figure a basic encryption is better
function generateDatabaseSecret ( ) : string {
// than none. Plus, we expect to support their own password or keystore or
const randomBytes = new Uint8Array ( 32 ) ;
// external wallet as better signing options in the future, so it's gonna be
crypto . getRandomValues ( randomBytes ) ;
// important to have the structure where each account access might require
return arrayBufferToBase64 ( randomBytes . buffer ) ;
// user action.
}
// (Once upon a time we stored the secret in localStorage, but it frequently
// got erased, even though the IndexedDB still had the identity data. This
// ended up throwing lots of errors to the user... and they'd end up in a state
// where they couldn't take action because they couldn't unlock that identity.)
const randomBytes = crypto . getRandomValues ( new Uint8Array ( 32 ) ) ; // Generate the secret that will be used for this database instance
const secretBase64 = arrayBufferToBase64 ( randomBytes ) ; const databaseSecret = generateDatabaseSecret ( ) ;
// Each migration can include multiple SQL statements (with semicolons)
/ * *
const MIGRATIONS = [ * Migration 001 : Initial Database Schema
{ *
* This migration creates the foundational database schema for TimeSafari .
* It establishes the core tables needed for user identity management ,
* contact networks , application settings , and operational logging .
*
* # # Tables Created :
*
* # # # accounts
* Stores user identities and cryptographic key pairs . Each account represents
* a unique user identity with associated cryptographic capabilities .
*
* - ` id ` : Primary key for internal references
* - ` did ` : Decentralized Identifier ( unique across the network )
* - ` privateKeyHex ` : Private key for signing and encryption ( hex - encoded )
* - ` publicKeyHex ` : Public key for verification and encryption ( hex - encoded )
* - ` derivationPath ` : BIP44 derivation path for hierarchical key generation
* - ` mnemonic ` : BIP39 mnemonic phrase for key recovery
*
* # # # secret
* Stores encrypted application secrets and sensitive configuration data .
* This table contains cryptographic material needed for secure operations .
*
* - ` id ` : Primary key ( always 1 for singleton pattern )
* - ` hex ` : Encrypted secret data in hexadecimal format
*
* # # # settings
* Application - wide configuration and user preferences . This table stores
* both system settings and user - customizable preferences .
*
* - ` name ` : Setting name / key ( unique identifier )
* - ` value ` : Setting value ( JSON - serializable data )
*
* # # # contacts
* User ' s contact network and trust relationships . This table manages the
* social graph and trust network that enables TimeSafari ' s collaborative features .
*
* - ` did ` : Contact ' s Decentralized Identifier ( primary key )
* - ` name ` : Display name for the contact
* - ` publicKeyHex ` : Contact ' s public key for verification
* - ` endorserApiServer ` : API server URL for this contact ' s endorsements
* - ` registered ` : Timestamp when contact was first added
* - ` lastViewedClaimId ` : Last claim / activity viewed from this contact
* - ` seenWelcomeScreen ` : Whether contact has completed onboarding
*
* # # # logs
* Application event logging for debugging and audit trails . This table
* captures important application events for troubleshooting and monitoring .
*
* - ` id ` : Auto - incrementing log entry ID
* - ` message ` : Log message content
* - ` level ` : Log level ( error , warn , info , debug )
* - ` timestamp ` : When the log entry was created
* - ` context ` : Additional context data ( JSON format )
*
* # # # temp
* Temporary data storage for multi - step operations . This table provides
* transient storage for operations that span multiple user interactions .
*
* - ` id ` : Unique identifier for the temporary data
* - ` data ` : JSON - serialized temporary data
* - ` created ` : Timestamp when data was stored
* - ` expires ` : Optional expiration timestamp
*
* # # Initial Data
*
* The migration also populates initial configuration :
* - Default endorser API server URL
* - Application database secret
* - Welcome screen tracking
* /
registerMigration ( {
name : "001_initial" , name : "001_initial" ,
sql : ` sql : `
CREATE TABLE IF NOT EXISTS accounts ( -- User accounts and identity management
id INTEGER PRIMARY KEY AUTOINCREMENT , -- Each account represents a unique user with cryptographic capabilities
dateCreated TEXT NOT NULL , CREATE TABLE accounts (
derivationPath TEXT , id INTEGER PRIMARY KEY ,
did TEXT NOT NULL , did TEXT UNIQUE NOT NULL , -- Decentralized Identifier
identityEncrBase64 TEXT , -- encrypted & base64 - encoded privateKeyHex TEXT NOT NULL , -- Private key ( hex - encoded )
mnemonicEncrBase64 TEXT , -- encrypted & base64 - encoded publicKeyHex TEXT NOT NULL , -- Public key ( hex - encoded )
passkeyCredIdHex TEXT , derivationPath TEXT , -- BIP44 derivation path
publicKeyHex TEXT NOT NULL mnemonic TEXT -- BIP39 recovery phrase
) ; ) ;
CREATE INDEX IF NOT EXISTS idx_accounts_did ON accounts ( did ) ; -- Encrypted application secrets and sensitive configuration
-- Singleton table ( id always = 1 ) for application - wide secrets
CREATE TABLE IF NOT EXISTS secret ( CREATE TABLE secret (
id INTEGER PRIMARY KEY AUTOINCREMENT , id INTEGER PRIMARY KEY CHECK ( id = 1 ) , -- Enforce singleton
secretBase64 TEXT NOT NULL hex TEXT NOT NULL -- Encrypted secret data
) ; ) ;
INSERT OR IGNORE INTO secret ( id , secretBase64 ) VALUES ( 1 , '${secretBase64}' ) ; -- Application settings and user preferences
-- Key - value store for configuration data
CREATE TABLE IF NOT EXISTS settings ( CREATE TABLE settings (
id INTEGER PRIMARY KEY AUTOINCREMENT , name TEXT PRIMARY KEY , -- Setting name / identifier
accountDid TEXT , value TEXT -- Setting value ( JSON - serializable )
activeDid TEXT ,
apiServer TEXT ,
filterFeedByNearby BOOLEAN ,
filterFeedByVisible BOOLEAN ,
finishedOnboarding BOOLEAN ,
firstName TEXT ,
hideRegisterPromptOnNewContact BOOLEAN ,
isRegistered BOOLEAN ,
lastName TEXT ,
lastAckedOfferToUserJwtId TEXT ,
lastAckedOfferToUserProjectsJwtId TEXT ,
lastNotifiedClaimId TEXT ,
lastViewedClaimId TEXT ,
notifyingNewActivityTime TEXT ,
notifyingReminderMessage TEXT ,
notifyingReminderTime TEXT ,
partnerApiServer TEXT ,
passkeyExpirationMinutes INTEGER ,
profileImageUrl TEXT ,
searchBoxes TEXT , -- Stored as JSON string
showContactGivesInline BOOLEAN ,
showGeneralAdvanced BOOLEAN ,
showShortcutBvc BOOLEAN ,
vapid TEXT ,
warnIfProdServer BOOLEAN ,
warnIfTestServer BOOLEAN ,
webPushServer TEXT
) ; ) ;
CREATE INDEX IF NOT EXISTS idx_settings_accountDid ON settings ( accountDid ) ; -- User ' s contact network and trust relationships
-- Manages the social graph for collaborative features
INSERT OR IGNORE INTO settings ( id , apiServer ) VALUES ( 1 , '${DEFAULT_ENDORSER_API_SERVER}' ) ; CREATE TABLE contacts (
did TEXT PRIMARY KEY , -- Contact ' s DID
name TEXT , -- Display name
publicKeyHex TEXT , -- Contact ' s public key
endorserApiServer TEXT , -- API server for endorsements
registered TEXT , -- Registration timestamp
lastViewedClaimId TEXT , -- Last viewed activity
seenWelcomeScreen BOOLEAN DEFAULT FALSE -- Onboarding completion
) ;
CREATE TABLE IF NOT EXISTS contacts ( -- Application event logging for debugging and audit
-- Captures important events for troubleshooting
CREATE TABLE logs (
id INTEGER PRIMARY KEY AUTOINCREMENT , id INTEGER PRIMARY KEY AUTOINCREMENT ,
did TEXT NOT NULL , message TEXT NOT NULL , -- Log message
name TEXT , level TEXT NOT NULL , -- Log level ( error / warn / info / debug )
contactMethods TEXT , -- Stored as JSON string timestamp TEXT DEFAULT CURRENT_TIMESTAMP ,
nextPubKeyHashB64 TEXT , context TEXT -- Additional context ( JSON )
notes TEXT ,
profileImageUrl TEXT ,
publicKeyBase64 TEXT ,
seesMe BOOLEAN ,
registered BOOLEAN
) ; ) ;
CREATE INDEX IF NOT EXISTS idx_contacts_did ON contacts ( did ) ; -- Temporary data storage for multi - step operations
CREATE INDEX IF NOT EXISTS idx_contacts_name ON contacts ( name ) ; -- Provides transient storage for complex workflows
CREATE TABLE temp (
CREATE TABLE IF NOT EXISTS logs ( id TEXT PRIMARY KEY , -- Unique identifier
date TEXT NOT NULL , data TEXT NOT NULL , -- JSON - serialized data
message TEXT NOT NULL created TEXT DEFAULT CURRENT_TIMESTAMP ,
expires TEXT -- Optional expiration
) ; ) ;
CREATE TABLE IF NOT EXISTS temp ( -- Initialize default application settings
id TEXT PRIMARY KEY , -- These settings provide the baseline configuration for new installations
blobB64 TEXT INSERT INTO settings ( name , value ) VALUES
) ; ( 'apiServer' , '${DEFAULT_ENDORSER_API_SERVER}' ) ,
( 'seenWelcomeScreen' , 'false' ) ;
-- Initialize application secret
-- This secret is used for encrypting sensitive data within the application
INSERT INTO secret ( id , hex ) VALUES ( 1 , '${databaseSecret}' ) ;
` ,
` ,
} , } ) ;
{
/ * *
* Migration 002 : Add Content Visibility Control to Contacts
*
* This migration enhances the contacts table with privacy controls , allowing
* users to manage what content they want to see from each contact . This supports
* TimeSafari ' s privacy - first approach by giving users granular control over
* their information exposure .
*
* # # Changes Made :
*
* # # # contacts . iViewContent
* New boolean column that controls whether the user wants to see content
* ( activities , projects , offers ) from this contact in their feeds and views .
*
* - ` TRUE ` ( default ) : User sees all content from this contact
* - ` FALSE ` : User ' s interface filters out content from this contact
*
* # # Use Cases :
*
* 1 . * * Privacy Management * * : Users can maintain contacts for trust / verification
* purposes while limiting information exposure
*
* 2 . * * Feed Curation * * : Users can curate their activity feeds by selectively
* hiding content from certain contacts
*
* 3 . * * Professional Separation * * : Users can separate professional and personal
* networks while maintaining cryptographic trust relationships
*
* 4 . * * Graduated Privacy * * : Users can add contacts with limited visibility
* initially , then expand access as trust develops
*
* # # Privacy Architecture :
*
* This column works in conjunction with TimeSafari ' s broader privacy model :
* - Contact relationships are still maintained for verification
* - Cryptographic trust is preserved regardless of content visibility
* - Users can change visibility settings at any time
* - The setting only affects the local user 's view, not the contact' s capabilities
*
* # # Default Behavior :
*
* All existing contacts default to ` TRUE ` ( visible ) to maintain current
* user experience . New contacts will also default to visible , with users
* able to adjust visibility as needed .
* /
registerMigration ( {
name : "002_add_iViewContent_to_contacts" , name : "002_add_iViewContent_to_contacts" ,
sql : ` sql : `
-- We need to handle the case where iViewContent column might already exist -- Add content visibility control to contacts table
-- SQLite doesn ' t support IF NOT EXISTS for ALTER TABLE ADD COLUMN -- This allows users to manage what content they see from each contact
-- So we ' ll use a more robust approach with error handling in the migration service -- while maintaining the cryptographic trust relationship
-- First , try to add the column - this will fail silently if it already exists
ALTER TABLE contacts ADD COLUMN iViewContent BOOLEAN DEFAULT TRUE ; ALTER TABLE contacts ADD COLUMN iViewContent BOOLEAN DEFAULT TRUE ;
` ,
` ,
} , } ) ;
] ;
/ * *
* Template for Future Migrations
*
* When adding new migrations , follow this pattern :
*
* ` ` ` typescript
* registerMigration ( {
* name : "003_descriptive_name" ,
* sql : `
* -- Clear comment explaining what this migration does
* -- and why it ' s needed
*
* ALTER TABLE existing_table ADD COLUMN new_column TYPE DEFAULT value ;
*
* -- Or create new tables :
* CREATE TABLE new_table (
* id INTEGER PRIMARY KEY ,
* -- . . . other columns with comments
* ) ;
*
* -- Initialize any required data
* INSERT INTO new_table ( column ) VALUES ( 'initial_value' ) ;
* ` ,
* } ) ;
* ` ` `
*
* # # Migration Best Practices :
*
* 1 . * * Clear Naming * * : Use descriptive names that explain the change
* 2 . * * Documentation * * : Document the purpose and impact of each change
* 3 . * * Backward Compatibility * * : Consider how changes affect existing data
* 4 . * * Default Values * * : Provide sensible defaults for new columns
* 5 . * * Data Migration * * : Include any necessary data transformation
* 6 . * * Testing * * : Test migrations on representative data sets
* 7 . * * Performance * * : Consider the impact on large datasets
*
* # # Schema Evolution Guidelines :
*
* - * * Additive Changes * * : Prefer adding new tables / columns over modifying existing ones
* - * * Nullable Columns * * : New columns should be nullable or have defaults
* - * * Index Creation * * : Add indexes for new query patterns
* - * * Data Integrity * * : Maintain referential integrity and constraints
* - * * Privacy Preservation * * : Ensure new schema respects privacy principles
* /
/ * * / * *
* @param sqlExec - A function that executes a SQL statement and returns the result * Run all registered migrations
* @param extractMigrationNames - A function that extracts the names ( string array ) from "select name from migrations" *
* This function is called during application initialization to ensure the
* database schema is up to date . It delegates to the migration service
* which handles the actual migration execution , tracking , and validation .
*
* The migration service will :
* 1 . Check which migrations have already been applied
* 2 . Apply any pending migrations in order
* 3 . Validate that schema changes were successful
* 4 . Record applied migrations for future reference
*
* @param sqlExec - Function to execute SQL statements
* @param sqlQuery - Function to execute SQL queries
* @param extractMigrationNames - Function to parse migration names from results
* @returns Promise that resolves when migrations are complete
*
* @example
* ` ` ` typescript
* // Called from platform service during database initialization
* await runMigrations (
* ( sql , params ) = > db . run ( sql , params ) ,
* ( sql , params ) = > db . query ( sql , params ) ,
* ( result ) = > new Set ( result . values . map ( row = > row [ 0 ] ) )
* ) ;
* ` ` `
* / * /
export async function runMigrations < T > ( export async function runMigrations < T > (
sqlExec : ( sql : string , params? : unknown [ ] ) = > Promise < unknown > , sqlExec : ( sql : string , params? : unknown [ ] ) = > Promise < unknown > ,
sqlQuery : ( sql : string , params? : unknown [ ] ) = > Promise < T > , sqlQuery : ( sql : string , params? : unknown [ ] ) = > Promise < T > ,
extractMigrationNames : ( result : T ) = > Set < string > , extractMigrationNames : ( result : T ) = > Set < string > ,
) : Promise < void > { ) : Promise < void > {
for ( const migration of MIGRATIONS ) { return runMigrationsService ( sqlExec , sqlQuery , extractMigrationNames ) ;
registerMigration ( migration ) ;
}
await runMigrationsService ( sqlExec , sqlQuery , extractMigrationNames ) ;
} }
Matthew Raymer
4 weeks ago