Rooba
/
perkeep
mirror of https://github.com/perkeep/perkeep.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Start of camput creating permanodes / claims.

This commit is contained in:
Brad Fitzpatrick 2011-03-12 13:10:56 -08:00
parent f70cc6d2e5
commit 6316a765fc
1 changed files with 38 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
clients/go/camput/camput.go
View File

@ -239,37 +239,60 @@ func handleResult(what string, pr *client.PutResult, err os.Error) {
func main() { func main() {
flag.Parse() flag.Parse()
if sumSet(flagFile, flagBlob, flagPermanode, flagInit, flagShare, flagRemove) != 1 { nOpts := sumSet(flagFile, flagBlob, flagPermanode, flagInit, flagShare, flagRemove)
// TODO: say which ones are conflicting if !(nOpts == 1 ||
(nOpts == 2 && *flagFile && *flagPermanode)) {
usage("Conflicting mode options.") usage("Conflicting mode options.")
} }
client := client.NewOrFail() cc := client.NewOrFail()
if !*flagVerbose { if !*flagVerbose {
client.SetLogger(nil) cc.SetLogger(nil)
} }
uploader := &Uploader{client} uploader := &Uploader{cc}
switch { switch {
case *flagInit: case *flagInit:
doInit() doInit()
return return
case *flagFile || *flagBlob:
var (
permaNode *client.PutResult
lastPut *client.PutResult
err os.Error
)
if n := flag.NArg(); *flagPermanode {
if n != 1 {
log.Fatalf("Options --permanode and --file can only be used together when there's exactly one argument")
}
permaNode, err = uploader.UploadNewPermanode()
if err != nil {
log.Fatalf("Error uploading permanode: %v", err)
}
}
for n := 0; n < flag.NArg(); n++ {
if *flagBlob {
lastPut, err = uploader.UploadFileBlob(flag.Arg(n))
handleResult("blob", lastPut, err)
} else {
lastPut, err = uploader.UploadFile(flag.Arg(n))
handleResult("file", lastPut, err)
}
}
if permaNode != nil {
// TODO: upload a signed "become" claim
// linking permaNode => lastPut
// TODO: add a --name and/or --tag flags to
// camput to then also issue some attribute
// modifications on the permanode as well.
}
case *flagPermanode: case *flagPermanode:
if flag.NArg() > 0 { if flag.NArg() > 0 {
log.Fatalf("--permanode doesn't take any additional arguments") log.Fatalf("--permanode doesn't take any additional arguments")
} }
pr, err := uploader.UploadNewPermanode() pr, err := uploader.UploadNewPermanode()
handleResult("permanode", pr, err) handleResult("permanode", pr, err)
case *flagFile || *flagBlob:
for n := 0; n < flag.NArg(); n++ {
if *flagBlob {
pr, err := uploader.UploadFileBlob(flag.Arg(n))
handleResult("blob", pr, err)
} else {
pr, err := uploader.UploadFile(flag.Arg(n))
handleResult("file", pr, err)
}
}
case *flagShare: case *flagShare:
if flag.NArg() != 1 { if flag.NArg() != 1 {
log.Fatalf("--share only supports one blobref") log.Fatalf("--share only supports one blobref")