| … | … | @@ -39,43 +39,45 @@ let follows = new Map() // discoveryKey -> { feed, publicKey, name } |
| 39 | 39 | async function loadState() { |
| 40 | 40 | if (store) return true // Already loaded |
| 41 | 41 | |
| 42 | | // Check if storage directory exists first |
| 43 | | const fs = await import('fs') |
| 44 | | const path = await import('path') |
| 45 | | const identityPath = path.join(STORAGE_PATH, 'cores') |
| 46 | | |
| 47 | | if (!fs.existsSync(identityPath)) { |
| 48 | | return null // Not initialized yet |
| 49 | | } |
| 50 | | |
| 51 | | store = new Corestore(STORAGE_PATH) |
| 52 | | await store.ready() |
| 42 | // Try to open Corestore - if it fails, storage doesn't exist yet |
| 43 | let identityCore |
| 44 | try { |
| 45 | store = new Corestore(STORAGE_PATH) |
| 46 | await store.ready() |
| 53 | 47 | |
| 54 | | // Load identity |
| 55 | | const identityCore = store.get({ name: 'identity' }) |
| 56 | | await identityCore.ready() |
| 48 | // Load identity |
| 49 | identityCore = store.get({ name: 'identity' }) |
| 50 | await identityCore.ready() |
| 57 | 51 | |
| 58 | | if (identityCore.length === 0) { |
| 59 | | await store.close() |
| 60 | | store = null |
| 61 | | return null // Not initialized |
| 62 | | } |
| 52 | if (identityCore.length === 0) { |
| 53 | await store.close() |
| 54 | store = null |
| 55 | return null // Not initialized |
| 56 | } |
| 63 | 57 | |
| 64 | | const identitySeed = await identityCore.get(0) |
| 65 | | identity = await IdentityKey.from({ seed: identitySeed }) |
| 58 | const identitySeed = await identityCore.get(0) |
| 59 | identity = await IdentityKey.from({ seed: identitySeed }) |
| 66 | 60 | |
| 67 | | // Load personal feed |
| 68 | | myFeed = store.get({ name: 'my-feed' }) |
| 69 | | await myFeed.ready() |
| 61 | // Load personal feed |
| 62 | myFeed = store.get({ name: 'my-feed' }) |
| 63 | await myFeed.ready() |
| 70 | 64 | |
| 71 | | // Load metadata |
| 72 | | metaBee = new Hyperbee(store.get({ name: 'metadata' }), { |
| 73 | | keyEncoding: 'utf-8', |
| 74 | | valueEncoding: 'json' |
| 75 | | }) |
| 76 | | await metaBee.ready() |
| 65 | // Load metadata |
| 66 | metaBee = new Hyperbee(store.get({ name: 'metadata' }), { |
| 67 | keyEncoding: 'utf-8', |
| 68 | valueEncoding: 'json' |
| 69 | }) |
| 70 | await metaBee.ready() |
| 77 | 71 | |
| 78 | | return true |
| 72 | return true |
| 73 | } catch (err) { |
| 74 | // Storage doesn't exist or is corrupted |
| 75 | if (store) { |
| 76 | try { await store.close() } catch {} |
| 77 | store = null |
| 78 | } |
| 79 | return null |
| 80 | } |
| 79 | 81 | } |
| 80 | 82 | |
| 81 | 83 | /** |