LumeWeb
/
kernel-ipfs
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

*switch to indexeddb blockstore and datastore

This commit is contained in:
Derrick Hammer 2023-03-30 18:56:26 -04:00
parent f0e6c5aa02
commit 053e988ea8
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
2 changed files with 14 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
package.json
View File

@ -28,10 +28,11 @@
"@lumeweb/kernel-swarm-client": "git+https://git.lumeweb.com/LumeWeb/kernel-swarm-client.git", "@lumeweb/kernel-swarm-client": "git+https://git.lumeweb.com/LumeWeb/kernel-swarm-client.git",
"@multiformats/mafmt": "^11.1.2", "@multiformats/mafmt": "^11.1.2",
"b4a": "^1.6.3", "b4a": "^1.6.3",
"blockstore-core": "^3.0.0", "blockstore-idb": "^1.1.0",
"buffer": "^6.0.3", "buffer": "^6.0.3",
"compact-encoding": "^2.11.0", "compact-encoding": "^2.11.0",
"datastore-core": "^8.0.4", "datastore-core": "^8.0.4",
"datastore-idb": "^2.1.0",
"helia": "^0.0.1", "helia": "^0.0.1",
"ipfs-http-client": "^60.0.0", "ipfs-http-client": "^60.0.0",
"ipfs-in-memory-repo": "^0.1.0", "ipfs-in-memory-repo": "^0.1.0",

17
src/index.ts
View File

@ -1,6 +1,4 @@
import { createLibp2p } from "libp2p"; import { createLibp2p } from "libp2p";
import { MemoryDatastore } from "datastore-core";
import { MemoryBlockstore } from "blockstore-core";
import { createHelia } from "helia"; import { createHelia } from "helia";
import { yamux } from "@chainsafe/libp2p-yamux"; import { yamux } from "@chainsafe/libp2p-yamux";
// @ts-ignore // @ts-ignore
@ -38,6 +36,8 @@ import { substr } from "runes2";
import { MultibaseDecoder } from "multiformats"; import { MultibaseDecoder } from "multiformats";
import { peerIdFromCID } from "@libp2p/peer-id"; import { peerIdFromCID } from "@libp2p/peer-id";
import { bootstrap } from "@libp2p/bootstrap"; import { bootstrap } from "@libp2p/bootstrap";
import { IDBBlockstore } from "blockstore-idb";
import { IDBDatastore } from "datastore-idb";
const basesByPrefix: { [prefix: string]: MultibaseDecoder<any> } = Object.keys( const basesByPrefix: { [prefix: string]: MultibaseDecoder<any> } = Object.keys(
bases bases
@ -113,10 +113,17 @@ async function handlePresentSeed() {
pubsub: gossipsub(), pubsub: gossipsub(),
}); });
// @ts-ignore const blockstore = new IDBBlockstore("ipfs_blocks");
const datastore = new IDBDatastore("ipfs_data");
await blockstore.open();
await datastore.open();
PeerManager.instance.ipfs = await createHelia({ PeerManager.instance.ipfs = await createHelia({
blockstore: new MemoryBlockstore(), // @ts-ignore
datastore: new MemoryDatastore(), blockstore,
// @ts-ignore
datastore,
libp2p, libp2p,
}); });