Class CoreManager

Hierarchy

  • TypedEmitter
    • CoreManager

Constructors

constructor

Accessors

creatorCore deviceId namespaces

Methods

[kCoreManagerReplicate] addCore close deleteOthersData getCoreByDiscoveryKey getCoreByKey getCores getWriterCore ready

Constructors

constructor

  • new CoreManager(options): CoreManager

  • Parameters

    • options: {
          autoDownload: undefined | boolean;
          db: BetterSQLite3Database<Record<string, never>>;
          encryptionKeys: undefined | Partial<Record<
              | "blob"
              | "auth"
              | "config"
              | "data"
              | "blobIndex", Buffer>>;
          keyManager: KeyManager;
          logger: undefined | Logger;
          projectKey: Buffer;
          projectSecretKey: undefined | Buffer;
          storage: HypercoreStorage;
      }
      • autoDownload: undefined | boolean

        Immediately start downloading cores - should only be set to false for tests

      • db: BetterSQLite3Database<Record<string, never>>

        Drizzle better-sqlite3 database instance

      • encryptionKeys: undefined | Partial<Record<
            | "blob"
            | "auth"
            | "config"
            | "data"
            | "blobIndex", Buffer>>

        Encryption keys for each namespace

      • keyManager: KeyManager

        mapeo/crypto KeyManager instance

      • logger: undefined | Logger
      • projectKey: Buffer

        32-byte public key of the project creator core

      • projectSecretKey: undefined | Buffer

        32-byte secret key of the project creator core

      • storage: HypercoreStorage

        Folder to store all hypercore data

    Returns CoreManager

Accessors

creatorCore

deviceId

  • get deviceId(): string

  • Returns string

Staticnamespaces

  • get namespaces(): readonly ["auth", "config", "data", "blobIndex", "blob"]

  • Returns readonly ["auth", "config", "data", "blobIndex", "blob"]

Methods

[kCoreManagerReplicate]

  • [kCoreManagerReplicate](stream): ReplicationStream

  • ONLY FOR TESTING Replicate all cores in core manager

    NB: Remote peers need to be manually added when unit testing core manager without the Sync API

    Parameters

    • stream: any

    Returns ReplicationStream

addCore

  • addCore(key, namespace): CoreRecord

  • Add a core to the manager (will be persisted across restarts)

    Parameters

    • key: Buffer

      32-byte public key of core to add

    • namespace:
          | "blob"
          | "auth"
          | "config"
          | "data"
          | "blobIndex"

    Returns CoreRecord

close

  • close(): Promise<void>

  • Close all open cores and end any replication streams TODO: gracefully close replication streams

    Returns Promise<void>

deleteOthersData

  • deleteOthersData(namespace): Promise<void>

  • Parameters

    • namespace:
          | "blob"
          | "config"
          | "data"
          | "blobIndex"

    Returns Promise<void>

getCoreByDiscoveryKey

  • getCoreByDiscoveryKey(discoveryKey): undefined | CoreRecord

  • Get a core by its discovery key

    Parameters

    • discoveryKey: Buffer

    Returns undefined | CoreRecord

getCoreByKey

  • getCoreByKey(key): undefined | Core

  • Get a core by its public key

    Parameters

    • key: Buffer

    Returns undefined | Core

getCores

  • getCores(namespace): CoreRecord[]

  • Get an array of all cores in the given namespace

    Parameters

    • namespace:
          | "blob"
          | "auth"
          | "config"
          | "data"
          | "blobIndex"

    Returns CoreRecord[]

getWriterCore

  • getWriterCore(namespace): CoreRecord

  • Get the writer core for the given namespace

    Parameters

    • namespace:
          | "blob"
          | "auth"
          | "config"
          | "data"
          | "blobIndex"

    Returns CoreRecord

ready

  • ready(): Promise<void>

  • Resolves when all cores have finished loading

    Returns Promise<void>

Settings

Member Visibility

On This Page

Constructors
Accessors
Methods