#244 - add a createLevelDatabase to allow customizing the Level used by BlockstoreLevel

[dcrousso]

this will also be passed down when creating a Dwn, MessageStoreLevel, and DataStoreLevel

[thehenrytsai]

Requested some minor changes but @mistermoe and @shamilovtim probably are best people to actually know if the abstraction is sufficient for them to instantiate a different level implementation.

[shamilovtim]

I am going to try my best to review but one difficulty I'm going to have is that I can't actually pull this due to the (unrelated to PR) presence of search-index

[mistermoe]

tried it out using memory-level, works! awesome.

import type { LevelDatabase, LevelDatabaseOptions } from '../src/store/create-level';

import { MemoryLevel } from 'memory-level';
import { MessageStoreLevel } from '../src/store/message-store-level.js';
import { DataStream, DidKeyResolver, Dwn, RecordsQuery, RecordsWrite } from '../src/index.js';


const messageStore = new MessageStoreLevel({
  createLevelDatabase<K, V>(_, options?: LevelDatabaseOptions<K, V>): LevelDatabase<K, V> {
    return new MemoryLevel(options);
  },
});

(async (): Promise<any> => {
  const { did, keyPair } = await DidKeyResolver.generate();
  const data = new TextEncoder().encode('data1');

  const record = await RecordsWrite.create({
    schema                      : 'test',
    data                        : data,
    dataFormat                  : 'application/json',
    authorizationSignatureInput : {
      privateJwk      : keyPair.privateJwk,
      protectedHeader : { alg: 'EdDSA', kid: DidKeyResolver.getKeyId(did) }
    }
  });

  console.log(record.toJSON());

  const dwn = await Dwn.create({ messageStore });

  let result = await dwn.processMessage(did, record.toJSON(), DataStream.fromBytes(data));
  console.log(result);

  const query = await RecordsQuery.create({
    filter: {
      schema: 'test'
    },
    authorizationSignatureInput: {
      privateJwk      : keyPair.privateJwk,
      protectedHeader : { alg: 'EdDSA', kid: DidKeyResolver.getKeyId(did) }
    }
  });

  result = await dwn.processMessage(did, query.toJSON());
  console.log(JSON.stringify(result, null, 2));
})();

i made the requested changes

[shamilovtim]

I was digging through here seeing if this fits the need for various level implementations and hit a blocker. Maybe I'm missing something but we didn't remove browser level or node level. You can see this when you take a look at the level repo it's directly importing:

It imports directly from level rather than using the require() API as a fallback in an if statement for an alternative implementation of Level. It then calls new Level(...).

Changes needed

• Provide a way to accept an alternative version of new Level()
• Change the import of level behind an if statement using require() if someone provides a different Level