fix: switch to protobuf.js

.eslintignore

@@ -0,0 +1 @@
+src/unixfs.proto.js

.gitignore

@@ -33,3 +33,6 @@ node_modules
 .node_repl_history
 
 dist
+
+package-lock.json
+yarn.lock

.travis.yml

@@ -3,12 +3,10 @@ language: node_js
 
 matrix:
   include:
-  - node_js: 4
-    env: CXX=g++-4.8
   - node_js: 6
     env:
       - CXX=g++-4.8
-  - node_js: stable
+  - node_js: 8
     env: CXX=g++-4.8
 
 # Make sure we have new NPM.

package.json

@@ -10,6 +10,7 @@
     "test": "aegir-test",
     "test:node": "aegir-test node",
     "test:browser": "aegir-test browser",
+    "build-proto": "pbjs --wrap commonjs --target static-module src/unixfs.proto > src/unixfs.proto.js",
     "build": "aegir-build",
     "lint": "aegir-lint",
     "release": "aegir-release",
@@ -43,7 +44,7 @@
     "safe-buffer": "^5.1.0"
   },
   "dependencies": {
-    "protocol-buffers": "^3.2.1"
+    "protobufjs": "^6.8.0"
   },
   "pre-commit": [
     "lint",
@@ -57,4 +58,4 @@
     "Pedro Teixeira <i@pgte.me>",
     "Richard Littauer <richard.littauer@gmail.com>"
   ]
-}
+}

src/index.js

@@ -1,7 +1,6 @@
 'use strict'
 
-const protobuf = require('protocol-buffers')
-const pb = protobuf(require('./unixfs.proto'))
+const pb = require('./unixfs.proto.js')
 // encode/decode
 const unixfsData = pb.Data
 // const unixfsMetadata = pb.MetaData // encode/decode
@@ -77,25 +76,30 @@ function Data (type, data) {
       fileSize = undefined
     }
 
-    return unixfsData.encode({
+    const msg = unixfsData.create({
       Type: type,
       Data: this.data,
       filesize: fileSize,
       blocksizes: this.blockSizes.length > 0 ? this.blockSizes : undefined,
       hashType: this.hashType,
       fanout: this.fanout
     })
+
+    return unixfsData.encode(msg).finish()
   }
 }
 
 // decode from protobuf https://github.com/ipfs/go-ipfs/blob/master/unixfs/format.go#L24
 Data.unmarshal = (marsheled) => {
   const decoded = unixfsData.decode(marsheled)
-  if (!decoded.Data) {
+  if (!decoded.Data || decoded.Data.length === 0) {
     decoded.Data = undefined
   }
+
   const obj = new Data(types[decoded.Type], decoded.Data)
-  obj.blockSizes = decoded.blocksizes
+  obj.blockSizes = (decoded.blocksizes || []).map((s) => {
+    return typeof s.toNumber === 'function' ? s.toNumber() : s
+  })
   return obj
 }
 

src/unixfs.proto

@@ -0,0 +1,22 @@
+message Data {
+  enum DataType {
+    Raw = 0;
+    Directory = 1;
+    File = 2;
+    Metadata = 3;
+    Symlink = 4;
+    HAMTShard = 5;
+  }
+
+  required DataType Type = 1;
+  optional bytes Data = 2;
+  optional uint64 filesize = 3;
+  repeated uint64 blocksizes = 4;
+
+  optional uint64 hashType = 5;
+  optional uint64 fanout = 6;
+}
+
+message Metadata {
+  required string MimeType = 1;
+}