test/supernode_client/main.go: Migrate to unixfs.AddFromReader

Using the procedure suggested in the changelog.
ipfs · May 1, 2015 · 159783f · 159783f
1 parent 2409fee
commit 159783f
Showing 1 changed file with 13 additions and 2 deletions.
diff --git a/test/supernode_client/main.go b/test/supernode_client/main.go
@@ -28,6 +28,7 @@ import (
  "github.com/ipfs/go-ipfs/repo"
  config "github.com/ipfs/go-ipfs/repo/config"
  fsrepo "github.com/ipfs/go-ipfs/repo/fsrepo"
+ unixfs "github.com/ipfs/go-ipfs/shell/unixfs"
  eventlog "github.com/ipfs/go-ipfs/thirdparty/eventlog"
  unit "github.com/ipfs/go-ipfs/thirdparty/unit"
  ds2 "github.com/ipfs/go-ipfs/util/datastore2"
@@ -151,10 +152,15 @@ func runFileAddingWorker(n *core.IpfsNode) error {
  log.Fatal(err)
  }
  }()
- k, err := coreunix.Add(n, piper)
+ fileNode, err := unixfs.AddFromReader(n, piper)
  if err != nil {
  log.Fatal(err)
  }
+ key, err := fileNode.Key()
+ if err != nil {
+ log.Fatal(err)
+ }
+ k := key.String()
  log.Println("added file", "seed", *seed, "#", i, "key", k, "size", unit.Information(sizeOfIthFile(i)))
  time.Sleep(1 * time.Second)
  }
@@ -185,10 +191,15 @@ func runFileCattingWorker(ctx context.Context, n *core.IpfsNode) error {
  log.Fatal(err)
  }
  // add to a dummy node to discover the key
- k, err := coreunix.Add(dummy, bytes.NewReader(buf.Bytes()))
+ fileNode, err := unixfs.AddFromReader(dummy, bytes.NewReader(buf.Bytes()))
+ if err != nil {
+ log.Fatal(err)
+ }
+ key, err := fileNode.Key()
  if err != nil {
  log.Fatal(err)
  }
+ k := key.String()
  e := elog.EventBegin(ctx, "cat", eventlog.LoggableF(func() map[string]interface{} {
  return map[string]interface{}{
  "key": k,