Merge pull request #89 from synonymdev/core-data

Core data

Author: rbndg

declarations.d.ts

@@ -19,6 +19,7 @@ declare module 'hyperswarm' {
 
   class Server extends EventEmitter {
     listen: (keyPair: KeyPair) => Promise<void>;
+    close: () => Promise<void>;
     address: () => {
       publicKey: Uint8Array;
       host: string;
@@ -60,7 +61,7 @@ declare module 'hyperswarm' {
     status(topic: Uint8Array): Discovery | undefined;
     topics(): IterableIterator<Discovery>;
     listen(): Promise<undefined>;
-    destroy(): Promise<undefined>;
+    destroy(): Promise<void>;
     joinPeer(key: Uint8Array): undefined;
     leave(topic: Uint8Array): Promise<any>;
     join(
@@ -128,7 +129,7 @@ declare module 'corestore' {
       keyPair?: KeyPair,
       encryptionKey?: Uint8Array | undefined
     }>
-    _closing: null | Promise<any>;
+    closing: null | Promise<any>;
     _preready: (core: Hypercore) => Promise<void>
     storage: any;
 

examples/drives/watch/server.js

@@ -1,6 +1,6 @@
 import b4a from 'b4a';
 import logUpdate from 'log-update';
-import SDK from '@synonymdev/slashtags-sdk';
+import SDK, { SlashURL } from '@synonymdev/slashtags-sdk';
 import RAM from 'random-access-memory'
 
 console.log('Setting up slashtag...');
@@ -10,11 +10,17 @@ const sdk = new SDK({
 });
 
 const alice = sdk.slashtag('alice');
-const drive = alice.drivestore.get()
-await drive.ready()
-console.log('Serving feed...');
+await alice.ready()
+await alice.coreData.create('/trades-feed/latest-trade', b4a.from(''));
 
-setInterval(() => {
+const FILE_PATH = '/trades-feed/latest-trade'
+
+console.log(`Serving feed ${await alice.coreData.createURL(FILE_PATH)}\n`);
+
+await write()
+setInterval(write, 500);
+
+function write() {
   const trade = {
     amount: Math.random(),
     price: Math.ceil(60000 + Math.random() * 60000),
@@ -23,5 +29,5 @@ setInterval(() => {
   const tradeString = JSON.stringify(trade, null, 2);
   logUpdate('Latest trade:', tradeString);
 
-  drive.put('/feeds/bitfinex/latest-trade', b4a.from(tradeString));
-}, 500);
+  return alice.coreData.update(FILE_PATH, b4a.from(tradeString));
+}

examples/drives/watch/watcher.js

@@ -3,23 +3,17 @@ import logUpdate from 'log-update';
 import SDK from '@synonymdev/slashtags-sdk';
 import RAM from 'random-access-memory'
 
-const driveOpts = {
-  key: b4a.from(
-    '69b04ea6e3b62245048a8efe8c17c6affb91e07ea1e28c911c2acdfd4d851f5c',
-    'hex',
-  )
-};
+const url = `slash:pgar7jzdsatrkbrkt59eaf6gi973dad6w8te3rehfmg94ucfd7qy/trades-feed/latest-trade#driveKey=gcrnqop9u8h9yy7qqrmrm5ae47xdwoqya431crp1snz3m8h3mwpo&encryptionKey=n9ukimccktfppduqs3eenh8np1yt8ykn4px56h1wnqe8mianbrhy`;
 
 console.log('Setting up slashtag...');
-const sdk = new SDK({
-  storage: RAM,
-  primaryKey: b4a.from('b'.repeat(64), 'hex'),
-});
-const watcher = sdk.drive(driveOpts.key)
-await watcher.update()
+const sdk = new SDK({ storage: RAM });
+const slashtag = sdk.slashtag();
 
-watcher.core.on('append', async () => {
-  const trade = await watcher.get('/feeds/bitfinex/latest-trade')
-  const tradeString = b4a.toString(trade);
-  logUpdate('Latest trade:', tradeString);
-});
+slashtag.coreData.subscribe(
+  url,
+  (trade) => {
+    if (!trade) return
+    const tradeString = b4a.toString(trade);
+    logUpdate('Latest trade:', tradeString);
+  }
+)