fix(lib): fix put binary shard

Author: 0x77dev

packages/lib/src/shard.ts

@@ -4,23 +4,29 @@ import { UnknownShardKindError } from './errors'
 import { EventEmitter } from 'events'
 import { Stack } from './stack'
 import { InvalidShardPathError } from '.'
+import all from 'it-all'
 
 export enum ShardKind {
   // eslint-disable-next-line no-unused-vars
   Binary = 'binary',
   // eslint-disable-next-line no-unused-vars
-  Object = 'object'
+  Object = 'object',
 }
 
 export class Shard<TData = Buffer | Record<string, any>> {
   private events = new EventEmitter()
 
-  private constructor(public stack: Stack, public cid: CID, public kind: ShardKind, public data: TData) { }
+  private constructor(
+    public stack: Stack,
+    public cid: CID,
+    public kind: ShardKind,
+    public data: TData
+  ) {}
 
   public async put(data: TData): Promise<void> {
     switch (this.kind) {
       case ShardKind.Binary:
-        this.cid = await this.stack.ipfs.block.put(new Uint8Array(data as unknown as Buffer))
+        this.cid = (await this.stack.ipfs.add(data as any as Uint8Array)).cid
         break
       case ShardKind.Object:
         this.cid = await this.stack.ipfs.dag.put(data)
@@ -36,7 +42,11 @@ export class Shard<TData = Buffer | Record<string, any>> {
     this.events.on(event, listener)
   }
 
-  public static async new<TData = unknown>(stack: Stack, kind: ShardKind, data: TData): Promise<Shard<TData>> {
+  public static async new<TData = unknown>(
+    stack: Stack,
+    kind: ShardKind,
+    data: TData
+  ): Promise<Shard<TData>> {
     const cid: CID = await stack.ipfs.dag.put({ empty: true })
 
     const shard = new Shard<TData>(stack, cid, kind, data)
@@ -45,12 +55,16 @@ export class Shard<TData = Buffer | Record<string, any>> {
     return shard
   }
 
-  public static async create<TData = Buffer | Record<string, any>>(stack: Stack, cid: CID, kind: ShardKind): Promise<Shard<TData>> {
+  public static async create<TData = Buffer | Record<string, any>>(
+    stack: Stack,
+    cid: CID,
+    kind: ShardKind
+  ): Promise<Shard<TData>> {
     let data
 
     switch (kind) {
       case ShardKind.Binary:
-        data = Buffer.from(await stack.ipfs.block.get(cid))
+        data = Buffer.from(await all(stack.ipfs.cat(cid)))
         break
       case ShardKind.Object:
         data = (await stack.ipfs.dag.get(cid)).value
@@ -62,7 +76,10 @@ export class Shard<TData = Buffer | Record<string, any>> {
     return new Shard(stack, cid, kind, data)
   }
 
-  public static from<TData = Buffer | Record<string, any>>(stack: Stack, path: string): Promise<Shard<TData>> {
+  public static from<TData = Buffer | Record<string, any>>(
+    stack: Stack,
+    path: string
+  ): Promise<Shard<TData>> {
     // eslint-disable-next-line no-unused-vars
     const [_, shard, cid, kind] = path.split('/')