deps: update deps

Author: achingbrain

package.json

@@ -194,21 +194,20 @@
     "dep-check": "aegir dep-check"
   },
   "dependencies": {
-    "debug": "^4.1.1",
+    "@libp2p/logger": "^2.0.0",
     "err-code": "^3.0.1",
     "interface-datastore": "^6.0.2",
     "it-all": "^1.0.4",
     "it-drain": "^1.0.4",
     "it-filter": "^1.0.2",
     "it-map": "^1.0.5",
     "it-merge": "^1.0.1",
-    "it-pipe": "^1.1.0",
-    "it-pushable": "^1.4.2",
+    "it-pipe": "^2.0.3",
+    "it-pushable": "^3.0.0",
     "it-take": "^1.0.1",
     "uint8arrays": "^3.0.0"
   },
   "devDependencies": {
-    "@types/debug": "^4.1.5",
     "aegir": "^37.4.5",
     "interface-datastore-tests": "^2.0.3"
   }

src/tiered.js

@@ -1,10 +1,10 @@
 import { BaseDatastore } from './base.js'
 import * as Errors from './errors.js'
-import debug from 'debug'
-import pushable from 'it-pushable'
+import { logger } from '@libp2p/logger'
+import { pushable } from 'it-pushable'
 import drain from 'it-drain'
 
-const log = debug('datastore:core:tiered')
+const log = logger('datastore:core:tiered')
 
 /**
  * @typedef {import('interface-datastore').Datastore} Datastore
@@ -69,7 +69,7 @@ export class TieredDatastore extends BaseDatastore {
         const res = await store.get(key, options)
         if (res) return res
       } catch (err) {
-        log(err)
+        log.error(err)
       }
     }
     throw Errors.notFoundError()
@@ -109,7 +109,9 @@ export class TieredDatastore extends BaseDatastore {
   async * putMany (source, options = {}) {
     let error
     const pushables = this.stores.map(store => {
-      const source = pushable()
+      const source = pushable({
+        objectMode: true
+      })
 
       drain(store.putMany(source, options))
         .catch(err => {
@@ -143,7 +145,9 @@ export class TieredDatastore extends BaseDatastore {
   async * deleteMany (source, options = {}) {
     let error
     const pushables = this.stores.map(store => {
-      const source = pushable()
+      const source = pushable({
+        objectMode: true
+      })
 
       drain(store.deleteMany(source, options))
         .catch(err => {