3 from cStringIO import StringIO
5 from allmydata.scripts.common_http import do_http, format_http_success, format_http_error
6 from allmydata.scripts.common import get_alias, DEFAULT_ALIAS, escape_path, \
8 from allmydata.util.encodingutil import quote_output
12 @param verbosity: 0, 1, or 2, meaning quiet, verbose, or very verbose
14 @return: a Deferred which eventually fires with the exit code
16 nodeurl = options['node-url']
17 aliases = options.aliases
18 from_file = options.from_file
19 to_file = options.to_file
20 mutable = options['mutable']
24 mutable_type = options['mutable-type']
30 stdout = options.stdout
31 stderr = options.stderr
33 if nodeurl[-1] != "/":
36 # several possibilities for the TO_FILE argument.
37 # <none> : unlinked upload
38 # foo : TAHOE_ALIAS/foo
39 # subdir/foo : TAHOE_ALIAS/subdir/foo
40 # /oops/subdir/foo : DISALLOWED
41 # ALIAS:foo : aliases[ALIAS]/foo
42 # ALIAS:subdir/foo : aliases[ALIAS]/subdir/foo
44 # ALIAS:/oops/subdir/foo : DISALLOWED
45 # DIRCAP:./foo : DIRCAP/foo
46 # DIRCAP:./subdir/foo : DIRCAP/subdir/foo
47 # MUTABLE-FILE-WRITECAP : filecap
49 # FIXME: don't hardcode cap format.
50 if to_file.startswith("URI:MDMF:") or to_file.startswith("URI:SSK:"):
51 url = nodeurl + "uri/%s" % urllib.quote(to_file)
54 rootcap, path = get_alias(aliases, to_file, DEFAULT_ALIAS)
55 except UnknownAliasError, e:
58 if path.startswith("/"):
59 suggestion = to_file.replace(u"/", u"", 1)
60 print >>stderr, "Error: The remote filename must not start with a slash"
61 print >>stderr, "Please try again, perhaps with %s" % quote_output(suggestion)
63 url = nodeurl + "uri/%s/" % urllib.quote(rootcap)
65 url += escape_path(path)
70 url += "?mutable=true"
73 url += "&mutable-type=%s" % mutable_type
76 infileobj = open(os.path.expanduser(from_file), "rb")
78 # do_http() can't use stdin directly: for one thing, we need a
79 # Content-Length field. So we currently must copy it.
81 print >>stderr, "waiting for file data on stdin.."
83 infileobj = StringIO(data)
85 resp = do_http("PUT", url, infileobj)
87 if resp.status in (200, 201,):
88 print >>stderr, format_http_success(resp)
89 print >>stdout, quote_output(resp.read(), quotemarks=False)
92 print >>stderr, format_http_error("Error", resp)