From: Zooko O'Whielacronx <zooko@zooko.com>
Date: Mon, 19 Nov 2007 21:07:28 +0000 (-0700)
Subject: remove tahoe_put-web2ish.py
X-Git-Url: https://git.rkrishnan.org/components/com_hotproperty/%22doc.html/something?a=commitdiff_plain;h=a50cea61bd376a5e37dcc7b7e72ef3a571e33983;p=tahoe-lafs%2Ftahoe-lafs.git

remove tahoe_put-web2ish.py
It isn't currently used, and I don't remember what part of its behavior was so much better than tahoe_put.py, and Brian has subsequently improved tahoe_put.py.
---

diff --git a/src/allmydata/scripts/tahoe_put-web2ish.py b/src/allmydata/scripts/tahoe_put-web2ish.py
deleted file mode 100644
index 6dceaee2..00000000
--- a/src/allmydata/scripts/tahoe_put-web2ish.py
+++ /dev/null
@@ -1,108 +0,0 @@
-#!/usr/bin/env python
-
-import re, sys, urllib
-
-from twisted.web2 import stream
-from twisted.web2.client.http import HTTPClientProtocol, ClientRequest
-from twisted.internet import defer, reactor, protocol
-
-SERVERURL_RE=re.compile("http://([^:]*)(:([1-9][0-9]*))?")
-
-def _put(serverurl, vdrive_fname, local_fname, verbosity):
-    """
-    @param verbosity: 0, 1, or 2, meaning quiet, verbose, or very verbose
-
-    @return: a Deferred which eventually fires with the exit code
-    """
-    mo = SERVERURL_RE.match(serverurl)
-    if not mo:
-        raise ValueError("serverurl is required to look like \"http://HOSTNAMEORADDR:PORT\"")
-    host = mo.group(1)
-    port = int(mo.group(3))
-
-    d = defer.Deferred()
-
-    url = "/vdrive/global/"
-    if vdrive_fname:
-        url += urllib.quote(vdrive_fname)
-
-    if local_fname is None or local_fname == "-":
-        infileobj = sys.stdin
-    else:
-        infileobj = open(local_fname, "rb")
-    instream = stream.FileStream(infileobj)
-
-    d2 = protocol.ClientCreator(reactor, HTTPClientProtocol).connectTCP(host, port)
-
-    def got_resp(resp):
-        # If this isn't a 200 or 201, then write out the response data and
-        # exit with resp.code as our exit value.
-        if resp.code not in (200, 201,):
-            def writeit(data):
-                sys.stdout.write(data)
-
-            def exit(dummy):
-                d.errback(resp.code)
-
-            return stream.readStream(resp.stream, writeit).addCallback(exit)
-
-        # If we are in quiet mode, then just exit with the resp.code.
-        if verbosity == 0:
-            d.callback(resp.code)
-            return
-
-        # Else, this is a successful request and we are not in quiet mode:
-        uribuffer = []
-        def gather_uri(data):
-            uribuffer.append(data)
-
-        def output_result(thingie):
-            uri = ''.join(uribuffer)
-            outbuf = []
-            if resp.code == 200:
-                outbuf.append("200 (OK); ")
-            elif resp.code == 201:
-                outbuf.append("201 (Created); ")
-
-            if verbosity == 2:
-                if resp.code == 200:
-                    outbuf.append("modified existing mapping of name %s to point to " % (vdrive_fname,))
-                elif resp.code == 201:
-                    outbuf.append("created new mapping of name %s to point to " % (vdrive_fname,))
-
-            outbuf.append("URI: %s" % (uri,))
-
-            sys.stdout.write(''.join(outbuf))
-            sys.stdout.write("\n")
-
-            d.callback(resp.code)
-
-        stream.readStream(resp.stream, gather_uri).addCallback(output_result)
-
-    def send_req(proto):
-        proto.submitRequest(ClientRequest('PUT', url, {}, instream)).addCallback(got_resp)
-
-    d2.addCallback(send_req)
-
-    return d
-
-def put(server, vdrive_fname, local_fname, verbosity):
-    """
-    This starts the reactor, does the PUT command, waits for the result, stops
-    the reactor, and returns the exit code.
-
-    @param verbosity: 0, 1, or 2, meaning quiet, verbose, or very verbose
-
-    @return: the exit code
-    """
-    d = _put(server, vdrive_fname, local_fname, verbosity)
-    exitcode = [ None ]
-    def exit(result):
-        exitcode[0] = result
-        reactor.stop()
-        return result
-
-    d.addCallbacks(exit, exit)
-    reactor.run()
-    return exitcode[0]
-