diff --git a/package-lock.json b/package-lock.json index d034adecb..bb02fdb01 100644 --- a/package-lock.json +++ b/package-lock.json @@ -4798,6 +4798,7 @@ "node_modules/multi-core-indexer": { "version": "1.0.0-alpha.8", "resolved": "git+ssh://git@github.com/digidem/multi-core-indexer.git#d9327a99f0c62b28b1ff99dcd7173a7d5b3e1bcc", + "integrity": "sha512-LopPO+BMy1UXyyDOXbDsJ6eXApo97riXnRqjL1LYwQ7+Q9oZlPWpRmyVY42+eApSt8Ub7AEcUjbl5yIszpffKQ==", "license": "MIT", "dependencies": { "@types/node": "^18.16.19", diff --git a/package.json b/package.json index f0951ed00..70db1908f 100644 --- a/package.json +++ b/package.json @@ -129,7 +129,7 @@ "hyperswarm": "4.4.1", "magic-bytes.js": "^1.0.14", "map-obj": "^5.0.2", - "multi-core-indexer": "github:digidem/multi-core-indexer#feat/non-ready-cores", + "multi-core-indexer": "^1.0.0-alpha.9", "p-defer": "^4.0.0", "p-timeout": "^6.1.2", "patch-package": "^8.0.0", diff --git a/types/temp.d.ts b/types/temp.d.ts deleted file mode 100644 index 7dc653033..000000000 --- a/types/temp.d.ts +++ /dev/null @@ -1,106 +0,0 @@ -declare module 'multi-core-indexer' { - import { ReadableEvents } from 'streamx' - - type IndexStateCurrent = 'idle' | 'indexing' - interface IndexState { - current: IndexStateCurrent - remaining: number - entriesPerSecond: number - } - interface IndexStreamState { - remaining: number - drained: boolean - } - interface IndexEvents { - 'index-state': (state: IndexState) => void - indexing: () => void - idle: () => void - } - type IndexStreamEvents = ReadableEvents & { - drained: () => void - indexing: () => void - } - type ValueEncoding = 'binary' | 'utf-8' | 'json' - interface Entry { - index: number - key: Buffer - block: T extends 'binary' ? Buffer : T extends 'utf-8' ? string : JSONValue - } - type JSONValue = - | null - | string - | number - | boolean - | { - [x: string]: JSONValue - } - | Array - - export = MultiCoreIndexer - /** @typedef {string | ((name: string) => import('random-access-storage'))} StorageParam */ - /** @typedef {ValueEncoding} ValueEncoding */ - /** @typedef {IndexState} IndexState */ - /** @typedef {IndexEvents} IndexEvents */ - /** - * @template {ValueEncoding} [T='binary'] - * @typedef {Entry} Entry - */ - /** - * @template {ValueEncoding} [T='binary'] - * @extends {TypedEmitter} - */ - declare class MultiCoreIndexer< - T extends ValueEncoding = 'binary' - > extends TypedEmitter { - /** - * - * @param {StorageParam} storage - * @returns {(name: string) => import('random-access-storage')} - */ - static defaultStorage( - storage: StorageParam - ): (name: string) => import('random-access-storage') - /** - * - * @param {import('hypercore')[]} cores - * @param {object} opts - * @param {(entries: Entry[]) => Promise} opts.batch - * @param {StorageParam} opts.storage - * @param {number} [opts.maxBatch=100] - */ - constructor( - cores: import('hypercore')[], - { - batch, - maxBatch, - storage, - }: { - batch: (entries: Entry[]) => Promise - storage: StorageParam - maxBatch?: number | undefined - } - ) - /** - * @type {IndexState} - */ - get state(): IndexState - /** - * Add a core to be indexed - * @param {import('hypercore')} core - */ - addCore(core: import('hypercore')): void - /** - * Resolves when indexing state is 'idle' - */ - idle(): Promise - close(): Promise - #private - } - declare namespace MultiCoreIndexer { - export { StorageParam, ValueEncoding, IndexState, IndexEvents, Entry } - } - import { TypedEmitter } from 'tiny-typed-emitter' - type StorageParam = - | string - | ((name: string) => import('random-access-storage')) -}