const all = require('it-all')
const IPFS = require('ipfs-http-client')
const ipfs = IPFS('http://localhost:5001')
function readFile(name) {
  return new Promise((resolve, reject) => {
    require('fs').readFile(name,{encoding: 'utf-8'},(err,data)=>{
        if(err) reject(err)
        resolve(data)
    })
  })
}
async function main () {
    const version = await ipfs.version()
    console.log('Version:', version.version)
    
    con = await readFile('./abc.txt')
    try{
        await (ipfs.files.write(
            path= '/hello.txt',
            content= Buffer.from(con),
            {create: true}
      ))}catch (err){throw err}
    console.log(`ipfs.files.write 文件buffer流到节点失败抛出错误`)
    var buff = await  all(ipfs.files.read('/hello.txt'))
    console.log(`ipfs.files.read 读取文件的数据流到本地后进行string化输出结果为:\n${buff.toString()}`)
    var stat = await (ipfs.files.stat('/hello.txt'))
    var abcCid = stat.cid.toString()
    var cidReader = await all(ipfs.files.read('/ipfs/'+abcCid))
    console.log(`ipfs.files.stat获取到文件的信息中的cid实例后将他通过cid地址拼接的方式实现另一种方式的数据读取:\n`,cidReader.toString())  
    try{
        await ipfs.files.mkdir(
            path = '/my/beautiful/images',
            {parents:true}
        )}catch(err){throw err}
    console.log(`ipfs.files.mkdir 新建一个文件夹失败会抛出错误`)
    var ls = await all(ipfs.files.ls('/'))
    console.log(`ipfas.files.ls 根目录的情况打印`,ls,`打印结束\n`)
}
// QmTQxi3W8cX37CGRe4NaN6rYLJ21WEU342uoHJ7cuGgmZa
main()