mirror of
https://github.com/tahoe-lafs/tahoe-lafs.git
synced 2025-01-23 12:59:55 +00:00
78 lines
2.1 KiB
Python
78 lines
2.1 KiB
Python
|
#!/usr/bin/env python
|
||
|
|
|
||
|
|
import re, socket, sys
|
||
|
|
|
||
|
|
NODEURL_RE=re.compile("http://([^:]*)(:([1-9][0-9]*))?")
|
||
|
|
|
||
|
|
def rm(nodeurl, vdrive, vdrive_pathname, verbosity):
|
||
|
|
"""
|
||
|
|
@param verbosity: 0, 1, or 2, meaning quiet, verbose, or very verbose
|
||
|
|
|
||
|
|
@return: a Deferred which eventually fires with the exit code
|
||
|
|
"""
|
||
|
|
mo = NODEURL_RE.match(nodeurl)
|
||
|
|
host = mo.group(1)
|
||
|
|
port = int(mo.group(3))
|
||
|
|
|
||
|
|
url = "/vdrive/" + vdrive + "/"
|
||
|
|
if vdrive_pathname:
|
||
|
|
url += vdrive_pathname
|
||
|
|
|
||
|
|
so = socket.socket()
|
||
|
|
so.connect((host, port,))
|
||
|
|
|
||
|
|
CHUNKSIZE=2**16
|
||
|
|
data = "DELETE %s HTTP/1.1\r\nConnection: close\r\nHostname: %s\r\n\r\n" % (url, host,)
|
||
|
|
sent = so.send(data)
|
||
|
|
|
||
|
|
respbuf = []
|
||
|
|
data = so.recv(CHUNKSIZE)
|
||
|
|
while data:
|
||
|
|
respbuf.append(data)
|
||
|
|
data = so.recv(CHUNKSIZE)
|
||
|
|
|
||
|
|
so.shutdown(socket.SHUT_WR)
|
||
|
|
|
||
|
|
data = so.recv(CHUNKSIZE)
|
||
|
|
while data:
|
||
|
|
respbuf.append(data)
|
||
|
|
data = so.recv(CHUNKSIZE)
|
||
|
|
|
||
|
|
respstr = ''.join(respbuf)
|
||
|
|
|
||
|
|
headerend = respstr.find('\r\n\r\n')
|
||
|
|
if headerend == -1:
|
||
|
|
headerend = len(respstr)
|
||
|
|
header = respstr[:headerend]
|
||
|
|
RESP_RE=re.compile("^HTTP/[0-9]\.[0-9] ([0-9]*) *([A-Za-z_ ]*)") # This regex is soooo ad hoc... --Zooko 2007-08-16
|
||
|
|
mo = RESP_RE.match(header)
|
||
|
|
if mo:
|
||
|
|
code = int(mo.group(1))
|
||
|
|
word = mo.group(2)
|
||
|
|
|
||
|
|
if code == 200:
|
||
|
|
print "%s %s" % (code, word,)
|
||
|
|
return 0
|
||
|
|
|
||
|
|
print respstr[headerend:]
|
||
|
|
return 1
|
||
|
|
|
||
|
|
def main():
|
||
|
|
import optparse, re
|
||
|
|
parser = optparse.OptionParser()
|
||
|
|
parser.add_option("-d", "--vdrive", dest="vdrive", default="global")
|
||
|
|
parser.add_option("-u", "--node-url", dest="nodeurl")
|
||
|
|
|
||
|
|
(options, args) = parser.parse_args()
|
||
|
|
|
||
|
|
NODEURL_RE=re.compile("http://([^:]*)(:([1-9][0-9]*))?")
|
||
|
|
if not isinstance(options.nodeurl, basestring) or not NODEURL_RE.match(options.nodeurl):
|
||
|
|
raise ValueError("--node-url is required to be a string and look like \"http://HOSTNAMEORADDR:PORT\", not: %r" % (options.nodeurl,))
|
||
|
|
|
||
|
|
vdrive_pathname = args[0]
|
||
|
|
|
||
|
|
return put(options.nodeurl, options.vdrive, vdrive_pathname, local_file)
|
||
|
|
|
||
|
|
if __name__ == '__main__':
|
||
|
|
main()
|