feat: support UnixFSv1.5 metadata

package.json

@@ -55,7 +55,7 @@
     "explain-error": "^1.0.4",
     "form-data": "^3.0.0",
     "ipfs-block": "~0.8.1",
-    "ipfs-utils": "^0.4.0",
+    "ipfs-utils": "^0.5.0",
     "ipld-dag-cbor": "~0.15.0",
     "ipld-dag-pb": "^0.18.1",
     "ipld-raw": "^4.0.0",

src/add/form-data.browser.js

@@ -9,6 +9,16 @@ exports.toFormData = async input => {
   let i = 0
 
   for await (const file of files) {
+    const headers = {}
+
+    if (file.mtime) {
+      headers.mtime = file.mtime
+    }
+
+    if (file.mode) {
+      headers.mode = file.mode
+    }
+
     if (file.content) {
       // In the browser there's _currently_ no streaming upload, buffer up our
       // async iterator chunks and append a big Blob :(
@@ -18,9 +28,13 @@ exports.toFormData = async input => {
         bufs.push(chunk)
       }
 
-      formData.append(`file-${i}`, new Blob(bufs, { type: 'application/octet-stream' }), encodeURIComponent(file.path))
+      formData.append(`file-${i}`, new Blob(bufs, { type: 'application/octet-stream' }), encodeURIComponent(file.path), {
+        header: headers
+      })
     } else {
-      formData.append(`dir-${i}`, new Blob([], { type: 'application/x-directory' }), encodeURIComponent(file.path))
+      formData.append(`dir-${i}`, new Blob([], { type: 'application/x-directory' }), encodeURIComponent(file.path), {
+        header: headers
+      })
     }
 
     i++

src/add/form-data.js

@@ -12,6 +12,16 @@ exports.toFormData = async input => {
   let i = 0
 
   for await (const file of files) {
+    const headers = {}
+
+    if (file.mtime) {
+      headers.mtime = file.mtime
+    }
+
+    if (file.mode) {
+      headers.mode = file.mode.toString(8).padStart(4, '0')
+    }
+
     if (file.content) {
       // In Node.js, FormData can be passed a stream so no need to buffer
       formData.append(
@@ -26,13 +36,15 @@ exports.toFormData = async input => {
         {
           filepath: encodeURIComponent(file.path),
           contentType: 'application/octet-stream',
-          knownLength: file.content.length // Send Content-Length header if known
+          knownLength: file.content.length, // Send Content-Length header if known
+          header: headers
         }
       )
     } else {
       formData.append(`dir-${i}`, Buffer.alloc(0), {
         filepath: encodeURIComponent(file.path),
-        contentType: 'application/x-directory'
+        contentType: 'application/x-directory',
+        header: headers
       })
     }
 

src/add/index.js

@@ -50,6 +50,12 @@ module.exports = configure(({ ky }) => {
   }
 })
 
-function toCoreInterface ({ name, hash, size }) {
-  return { path: name, hash, size: parseInt(size) }
+function toCoreInterface ({ name, hash, size, mode, mtime }) {
+  return {
+    path: name,
+    hash,
+    size: parseInt(size),
+    mode: mode,
+    mtime: mtime
+  }
 }

src/files/chmod.js

@@ -0,0 +1,24 @@
+'use strict'
+
+const configure = require('../lib/configure')
+
+module.exports = configure(({ ky }) => {
+  return function chmod (path, mode, options) {
+    options = options || {}
+
+    const searchParams = new URLSearchParams(options.searchParams)
+    searchParams.append('arg', path)
+    searchParams.append('mode', mode)
+    if (options.format) searchParams.set('format', options.format)
+    if (options.flush != null) searchParams.set('flush', options.flush)
+    if (options.hashAlg) searchParams.set('hash', options.hashAlg)
+    if (options.parents != null) searchParams.set('parents', options.parents)
+
+    return ky.post('files/chmod', {
+      timeout: options.timeout,
+      signal: options.signal,
+      headers: options.headers,
+      searchParams
+    }).text()
+  }
+})

src/files/touch.js

@@ -0,0 +1,29 @@
+'use strict'
+
+const configure = require('../lib/configure')
+
+module.exports = configure(({ ky }) => {
+  return function touch (path, mtime, options) {
+    options = options || {}
+
+    if (isNaN(mtime)) {
+      options = mtime
+      mtime = null
+    }
+
+    const searchParams = new URLSearchParams(options.searchParams)
+    searchParams.append('arg', path)
+    if (mtime) searchParams.set('mtime', mtime)
+    if (options.format) searchParams.set('format', options.format)
+    if (options.flush != null) searchParams.set('flush', options.flush)
+    if (options.hashAlg) searchParams.set('hash', options.hashAlg)
+    if (options.parents != null) searchParams.set('parents', options.parents)
+
+    return ky.post('files/touch', {
+      timeout: options.timeout,
+      signal: options.signal,
+      headers: options.headers,
+      searchParams
+    }).text()
+  }
+})