| 1 |
1674
|
aaronmk
|
#!/usr/bin/env python
|
| 2 |
|
|
# A DiGIR client
|
| 3 |
|
|
|
| 4 |
1678
|
aaronmk
|
import os
|
| 5 |
1674
|
aaronmk
|
import os.path
|
| 6 |
|
|
import sys
|
| 7 |
|
|
import urllib
|
| 8 |
|
|
import urllib2
|
| 9 |
|
|
|
| 10 |
|
|
sys.path.append(os.path.dirname(__file__)+"/../lib")
|
| 11 |
|
|
|
| 12 |
1678
|
aaronmk
|
import dates
|
| 13 |
1674
|
aaronmk
|
import opts
|
| 14 |
|
|
import streams
|
| 15 |
|
|
import util
|
| 16 |
|
|
|
| 17 |
|
|
# Config
|
| 18 |
|
|
timeout = 20 # sec
|
| 19 |
1679
|
aaronmk
|
default_schema = 'http://digir.net/schema/conceptual/darwin/full/2003/1.0/darwin2full.xsd'
|
| 20 |
1674
|
aaronmk
|
|
| 21 |
|
|
request_xml_template = '''\
|
| 22 |
|
|
<?xml version="1.0" encoding="UTF-8"?>
|
| 23 |
|
|
<request
|
| 24 |
|
|
xmlns="http://digir.net/schema/protocol/2003/1.0"
|
| 25 |
|
|
xmlns:xsd="http://www.w3.org/2001/XMLSchema"
|
| 26 |
|
|
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
| 27 |
|
|
xmlns:digir="http://digir.net/schema/protocol/2003/1.0"
|
| 28 |
|
|
xmlns:darwin="http://digir.net/schema/conceptual/darwin/2003/1.0"
|
| 29 |
|
|
xmlns:dwc="http://digir.net/schema/conceptual/darwin/2003/1.0"
|
| 30 |
|
|
xsi:schemaLocation="http://digir.net/schema/protocol/2003/1.0
|
| 31 |
|
|
http://digir.sourceforge.net/schema/protocol/2003/1.0/digir.xsd
|
| 32 |
|
|
http://digir.net/schema/conceptual/darwin/2003/1.0
|
| 33 |
|
|
http://digir.sourceforge.net/schema/conceptual/darwin/2003/1.0/darwin2.xsd">
|
| 34 |
|
|
<header>
|
| 35 |
|
|
<version>1.0</version>
|
| 36 |
1678
|
aaronmk
|
<sendTime>[time]</sendTime>
|
| 37 |
|
|
<source>[source]</source>
|
| 38 |
1674
|
aaronmk
|
<destination resource="[resource]">[url]</destination>
|
| 39 |
|
|
<type>search</type>
|
| 40 |
|
|
</header>
|
| 41 |
|
|
<search>
|
| 42 |
|
|
<filter>
|
| 43 |
1675
|
aaronmk
|
<equals>
|
| 44 |
1678
|
aaronmk
|
<darwin:Kingdom>plantae</darwin:Kingdom>
|
| 45 |
1675
|
aaronmk
|
</equals>
|
| 46 |
1674
|
aaronmk
|
</filter>
|
| 47 |
|
|
<records limit="[count]" start="[start]">
|
| 48 |
1679
|
aaronmk
|
<structure schemaLocation="[schema]"/>
|
| 49 |
1674
|
aaronmk
|
</records>
|
| 50 |
|
|
<count>true</count>
|
| 51 |
|
|
</search>
|
| 52 |
|
|
</request>
|
| 53 |
|
|
'''
|
| 54 |
|
|
|
| 55 |
|
|
def main():
|
| 56 |
|
|
env_names = []
|
| 57 |
|
|
def usage_err():
|
| 58 |
|
|
raise SystemExit('Usage: '+opts.env_usage(env_names, True)+' '
|
| 59 |
|
|
+sys.argv[0]+' 2>>log')
|
| 60 |
|
|
|
| 61 |
|
|
# Get config from env vars
|
| 62 |
|
|
url = opts.get_env_var('url', None, env_names)
|
| 63 |
|
|
resource = opts.get_env_var('resource', None, env_names)
|
| 64 |
1679
|
aaronmk
|
schema = opts.get_env_var('schema', default_schema, env_names)
|
| 65 |
1674
|
aaronmk
|
start = util.cast(int, opts.get_env_var('start', 0, env_names))
|
| 66 |
|
|
count = util.cast(int, opts.get_env_var('n', 1, env_names))
|
| 67 |
1678
|
aaronmk
|
debug = opts.env_flag('debug', False, env_names)
|
| 68 |
1674
|
aaronmk
|
if url == None or resource == None: usage_err()
|
| 69 |
|
|
|
| 70 |
1678
|
aaronmk
|
def clear_line(): sys.stderr.write('\n')
|
| 71 |
|
|
log_indent = 0
|
| 72 |
|
|
def log(msg, line_ending='\n'):
|
| 73 |
|
|
sys.stderr.write((' '*log_indent)+msg+line_ending)
|
| 74 |
1674
|
aaronmk
|
|
| 75 |
1678
|
aaronmk
|
self_dir = os.path.dirname(__file__)
|
| 76 |
|
|
source = os.popen(self_dir+"/local_ip").read().strip()
|
| 77 |
|
|
this_request_xml_template = (request_xml_template
|
| 78 |
|
|
.replace('[source]', source)
|
| 79 |
|
|
.replace('[url]', url)
|
| 80 |
|
|
.replace('[resource]', resource)
|
| 81 |
1679
|
aaronmk
|
.replace('[schema]', schema)
|
| 82 |
1678
|
aaronmk
|
.replace('[count]', str(count))
|
| 83 |
|
|
)
|
| 84 |
|
|
|
| 85 |
|
|
time = dates.strftime('%Y-%m-%d %H:%M:%S %Z', dates.now())
|
| 86 |
|
|
request_xml = (this_request_xml_template
|
| 87 |
|
|
.replace('[start]', str(start))
|
| 88 |
|
|
.replace('[time]', time)
|
| 89 |
|
|
)
|
| 90 |
|
|
if debug: sys.stderr.write(request_xml)
|
| 91 |
1674
|
aaronmk
|
this_url = url+'?'+urllib.urlencode({'request': request_xml})
|
| 92 |
|
|
stream = streams.StreamIter(streams.TimeoutInputStream(
|
| 93 |
|
|
urllib2.urlopen(this_url), timeout))
|
| 94 |
|
|
|
| 95 |
|
|
try:
|
| 96 |
|
|
# Copy lines
|
| 97 |
|
|
for line in stream:
|
| 98 |
|
|
sys.stdout.write(line)
|
| 99 |
|
|
finally: # still run if break is called
|
| 100 |
|
|
stream.close()
|
| 101 |
|
|
|
| 102 |
|
|
main()
|
