cascade/ipfs-cluster
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

calling into dex importer

Browse Source 
License: MIT
Signed-off-by: Wyatt Daviau <wdaviau@cs.stanford.edu>
This commit is contained in:
Wyatt Daviau 2018-02-02 17:18:31 -05:00 committed by Hector Sanjuan
parent a77f0fb3ee
commit 20b81f9f3d
1 changed files with 20 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
api/rest/restapi.go
View File

@ -14,7 +14,6 @@ import (
"errors"
"fmt"
"io"
"mime"
"net"
"net/http"
@ -36,6 +35,7 @@ import (
peer "github.com/libp2p/go-libp2p-peer"
ma "github.com/multiformats/go-multiaddr"
manet "github.com/multiformats/go-multiaddr-net"
dex "github.com/zenground0/dex"
)
var logger = logging.Logger("restapi")
@ -517,29 +517,31 @@ func (api *API) addFileHandler(w http.ResponseWriter, r *http.Request) {
return
}
buf := make([]byte, 256)
for {
file, err := f.NextFile()
if err == io.EOF {
break
}
fmt.Printf("%s\n----------------\n", file.FileName())
if file.IsDirectory() {
continue
}
var n int
err := dex.ImportToPrint(f)
/*
buf := make([]byte, 256)
for {
n, err = file.Read(buf)
file, err := f.NextFile()
if err == io.EOF {
fmt.Printf("\n")
break
}
fmt.Printf("%s\n----------------\n", file.FileName())
if file.IsDirectory() {
continue
}
var n int
for {
n, err = file.Read(buf)
if err == io.EOF {
fmt.Printf("\n")
break
}
fmt.Printf(string(buf[:n]))
}
fmt.Printf(string(buf[:n]))
}
fmt.Printf(string(buf[:n]))
}
}*/
sendAcceptedResponse(w, nil)
sendAcceptedResponse(w, err)
}
func (api *API) peerListHandler(w http.ResponseWriter, r *http.Request) {