server.py 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721
  1. #!/usr/bin/env python
  2. __copyright__ = 'Copyright 2005-2008, Janrain, Inc.'
  3. from BaseHTTPServer import HTTPServer, BaseHTTPRequestHandler
  4. from urlparse import urlparse
  5. import time
  6. import Cookie
  7. import cgi
  8. import cgitb
  9. import sys
  10. def quoteattr(s):
  11. qs = cgi.escape(s, 1)
  12. return '"%s"' % (qs,)
  13. try:
  14. import openid
  15. except ImportError:
  16. sys.stderr.write("""
  17. Failed to import the OpenID library. In order to use this example, you
  18. must either install the library (see INSTALL in the root of the
  19. distribution) or else add the library to python's import path (the
  20. PYTHONPATH environment variable).
  21. For more information, see the README in the root of the library
  22. distribution.""")
  23. sys.exit(1)
  24. from openid.extensions import sreg
  25. from openid.server import server
  26. from openid.store.filestore import FileOpenIDStore
  27. from openid.consumer import discover
  28. class OpenIDHTTPServer(HTTPServer):
  29. """
  30. http server that contains a reference to an OpenID Server and
  31. knows its base URL.
  32. """
  33. def __init__(self, *args, **kwargs):
  34. HTTPServer.__init__(self, *args, **kwargs)
  35. if self.server_port != 80:
  36. self.base_url = ('http://%s:%s/' %
  37. (self.server_name, self.server_port))
  38. else:
  39. self.base_url = 'http://%s/' % (self.server_name,)
  40. self.openid = None
  41. self.approved = {}
  42. self.lastCheckIDRequest = {}
  43. def setOpenIDServer(self, oidserver):
  44. self.openid = oidserver
  45. class ServerHandler(BaseHTTPRequestHandler):
  46. def __init__(self, *args, **kwargs):
  47. self.user = None
  48. BaseHTTPRequestHandler.__init__(self, *args, **kwargs)
  49. def do_GET(self):
  50. try:
  51. self.parsed_uri = urlparse(self.path)
  52. self.query = {}
  53. for k, v in cgi.parse_qsl(self.parsed_uri[4]):
  54. self.query[k] = v
  55. self.setUser()
  56. path = self.parsed_uri[2].lower()
  57. if path == '/':
  58. self.showMainPage()
  59. elif path == '/openidserver':
  60. self.serverEndPoint(self.query)
  61. elif path == '/login':
  62. self.showLoginPage('/', '/')
  63. elif path == '/loginsubmit':
  64. self.doLogin()
  65. elif path.startswith('/id/'):
  66. self.showIdPage(path)
  67. elif path.startswith('/yadis/'):
  68. self.showYadis(path[7:])
  69. elif path == '/serveryadis':
  70. self.showServerYadis()
  71. else:
  72. self.send_response(404)
  73. self.end_headers()
  74. except (KeyboardInterrupt, SystemExit):
  75. raise
  76. except:
  77. self.send_response(500)
  78. self.send_header('Content-type', 'text/html')
  79. self.end_headers()
  80. self.wfile.write(cgitb.html(sys.exc_info(), context=10))
  81. def do_POST(self):
  82. try:
  83. self.parsed_uri = urlparse(self.path)
  84. self.setUser()
  85. content_length = int(self.headers['Content-Length'])
  86. post_data = self.rfile.read(content_length)
  87. self.query = {}
  88. for k, v in cgi.parse_qsl(post_data):
  89. self.query[k] = v
  90. path = self.parsed_uri[2]
  91. if path == '/openidserver':
  92. self.serverEndPoint(self.query)
  93. elif path == '/allow':
  94. self.handleAllow(self.query)
  95. else:
  96. self.send_response(404)
  97. self.end_headers()
  98. except (KeyboardInterrupt, SystemExit):
  99. raise
  100. except:
  101. self.send_response(500)
  102. self.send_header('Content-type', 'text/html')
  103. self.end_headers()
  104. self.wfile.write(cgitb.html(sys.exc_info(), context=10))
  105. def handleAllow(self, query):
  106. # pretend this next bit is keying off the user's session or something,
  107. # right?
  108. request = self.server.lastCheckIDRequest.get(self.user)
  109. if 'yes' in query:
  110. if 'login_as' in query:
  111. self.user = self.query['login_as']
  112. if request.idSelect():
  113. identity = self.server.base_url + 'id/' + query['identifier']
  114. else:
  115. identity = request.identity
  116. trust_root = request.trust_root
  117. if self.query.get('remember', 'no') == 'yes':
  118. self.server.approved[(identity, trust_root)] = 'always'
  119. response = self.approved(request, identity)
  120. elif 'no' in query:
  121. response = request.answer(False)
  122. else:
  123. assert False, 'strange allow post. %r' % (query,)
  124. self.displayResponse(response)
  125. def setUser(self):
  126. cookies = self.headers.get('Cookie')
  127. if cookies:
  128. morsel = Cookie.BaseCookie(cookies).get('user')
  129. if morsel:
  130. self.user = morsel.value
  131. def isAuthorized(self, identity_url, trust_root):
  132. if self.user is None:
  133. return False
  134. if identity_url != self.server.base_url + 'id/' + self.user:
  135. return False
  136. key = (identity_url, trust_root)
  137. return self.server.approved.get(key) is not None
  138. def serverEndPoint(self, query):
  139. try:
  140. request = self.server.openid.decodeRequest(query)
  141. except server.ProtocolError, why:
  142. self.displayResponse(why)
  143. return
  144. if request is None:
  145. # Display text indicating that this is an endpoint.
  146. self.showAboutPage()
  147. return
  148. if request.mode in ["checkid_immediate", "checkid_setup"]:
  149. self.handleCheckIDRequest(request)
  150. else:
  151. response = self.server.openid.handleRequest(request)
  152. self.displayResponse(response)
  153. def addSRegResponse(self, request, response):
  154. sreg_req = sreg.SRegRequest.fromOpenIDRequest(request)
  155. # In a real application, this data would be user-specific,
  156. # and the user should be asked for permission to release
  157. # it.
  158. sreg_data = {
  159. 'nickname':self.user
  160. }
  161. sreg_resp = sreg.SRegResponse.extractResponse(sreg_req, sreg_data)
  162. response.addExtension(sreg_resp)
  163. def approved(self, request, identifier=None):
  164. response = request.answer(True, identity=identifier)
  165. self.addSRegResponse(request, response)
  166. return response
  167. def handleCheckIDRequest(self, request):
  168. is_authorized = self.isAuthorized(request.identity, request.trust_root)
  169. if is_authorized:
  170. response = self.approved(request)
  171. self.displayResponse(response)
  172. elif request.immediate:
  173. response = request.answer(False)
  174. self.displayResponse(response)
  175. else:
  176. self.server.lastCheckIDRequest[self.user] = request
  177. self.showDecidePage(request)
  178. def displayResponse(self, response):
  179. try:
  180. webresponse = self.server.openid.encodeResponse(response)
  181. except server.EncodingError, why:
  182. text = why.response.encodeToKVForm()
  183. self.showErrorPage('<pre>%s</pre>' % cgi.escape(text))
  184. return
  185. self.send_response(webresponse.code)
  186. for header, value in webresponse.headers.iteritems():
  187. self.send_header(header, value)
  188. self.writeUserHeader()
  189. self.end_headers()
  190. if webresponse.body:
  191. self.wfile.write(webresponse.body)
  192. def doLogin(self):
  193. if 'submit' in self.query:
  194. if 'user' in self.query:
  195. self.user = self.query['user']
  196. else:
  197. self.user = None
  198. self.redirect(self.query['success_to'])
  199. elif 'cancel' in self.query:
  200. self.redirect(self.query['fail_to'])
  201. else:
  202. assert 0, 'strange login %r' % (self.query,)
  203. def redirect(self, url):
  204. self.send_response(302)
  205. self.send_header('Location', url)
  206. self.writeUserHeader()
  207. self.end_headers()
  208. def writeUserHeader(self):
  209. if self.user is None:
  210. t1970 = time.gmtime(0)
  211. expires = time.strftime(
  212. 'Expires=%a, %d-%b-%y %H:%M:%S GMT', t1970)
  213. self.send_header('Set-Cookie', 'user=;%s' % expires)
  214. else:
  215. self.send_header('Set-Cookie', 'user=%s' % self.user)
  216. def showAboutPage(self):
  217. endpoint_url = self.server.base_url + 'openidserver'
  218. def link(url):
  219. url_attr = quoteattr(url)
  220. url_text = cgi.escape(url)
  221. return '<a href=%s><code>%s</code></a>' % (url_attr, url_text)
  222. def term(url, text):
  223. return '<dt>%s</dt><dd>%s</dd>' % (link(url), text)
  224. resources = [
  225. (self.server.base_url, "This example server's home page"),
  226. ('http://www.openidenabled.com/',
  227. 'An OpenID community Web site, home of this library'),
  228. ('http://www.openid.net/', 'the official OpenID Web site'),
  229. ]
  230. resource_markup = ''.join([term(url, text) for url, text in resources])
  231. self.showPage(200, 'This is an OpenID server', msg="""\
  232. <p>%s is an OpenID server endpoint.<p>
  233. <p>For more information about OpenID, see:</p>
  234. <dl>
  235. %s
  236. </dl>
  237. """ % (link(endpoint_url), resource_markup,))
  238. def showErrorPage(self, error_message):
  239. self.showPage(400, 'Error Processing Request', err='''\
  240. <p>%s</p>
  241. <!--
  242. This is a large comment. It exists to make this page larger.
  243. That is unfortunately necessary because of the "smart"
  244. handling of pages returned with an error code in IE.
  245. *************************************************************
  246. *************************************************************
  247. *************************************************************
  248. *************************************************************
  249. *************************************************************
  250. *************************************************************
  251. *************************************************************
  252. *************************************************************
  253. *************************************************************
  254. *************************************************************
  255. *************************************************************
  256. *************************************************************
  257. *************************************************************
  258. *************************************************************
  259. *************************************************************
  260. *************************************************************
  261. *************************************************************
  262. *************************************************************
  263. *************************************************************
  264. *************************************************************
  265. *************************************************************
  266. *************************************************************
  267. *************************************************************
  268. -->
  269. ''' % error_message)
  270. def showDecidePage(self, request):
  271. id_url_base = self.server.base_url+'id/'
  272. # XXX: This may break if there are any synonyms for id_url_base,
  273. # such as referring to it by IP address or a CNAME.
  274. assert (request.identity.startswith(id_url_base) or
  275. request.idSelect()), repr((request.identity, id_url_base))
  276. expected_user = request.identity[len(id_url_base):]
  277. if request.idSelect(): # We are being asked to select an ID
  278. msg = '''\
  279. <p>A site has asked for your identity. You may select an
  280. identifier by which you would like this site to know you.
  281. On a production site this would likely be a drop down list
  282. of pre-created accounts or have the facility to generate
  283. a random anonymous identifier.
  284. </p>
  285. '''
  286. fdata = {
  287. 'id_url_base': id_url_base,
  288. 'trust_root': request.trust_root,
  289. }
  290. form = '''\
  291. <form method="POST" action="/allow">
  292. <table>
  293. <tr><td>Identity:</td>
  294. <td>%(id_url_base)s<input type='text' name='identifier'></td></tr>
  295. <tr><td>Trust Root:</td><td>%(trust_root)s</td></tr>
  296. </table>
  297. <p>Allow this authentication to proceed?</p>
  298. <input type="checkbox" id="remember" name="remember" value="yes"
  299. /><label for="remember">Remember this
  300. decision</label><br />
  301. <input type="submit" name="yes" value="yes" />
  302. <input type="submit" name="no" value="no" />
  303. </form>
  304. '''%fdata
  305. elif expected_user == self.user:
  306. msg = '''\
  307. <p>A new site has asked to confirm your identity. If you
  308. approve, the site represented by the trust root below will
  309. be told that you control identity URL listed below. (If
  310. you are using a delegated identity, the site will take
  311. care of reversing the delegation on its own.)</p>'''
  312. fdata = {
  313. 'identity': request.identity,
  314. 'trust_root': request.trust_root,
  315. }
  316. form = '''\
  317. <table>
  318. <tr><td>Identity:</td><td>%(identity)s</td></tr>
  319. <tr><td>Trust Root:</td><td>%(trust_root)s</td></tr>
  320. </table>
  321. <p>Allow this authentication to proceed?</p>
  322. <form method="POST" action="/allow">
  323. <input type="checkbox" id="remember" name="remember" value="yes"
  324. /><label for="remember">Remember this
  325. decision</label><br />
  326. <input type="submit" name="yes" value="yes" />
  327. <input type="submit" name="no" value="no" />
  328. </form>''' % fdata
  329. else:
  330. mdata = {
  331. 'expected_user': expected_user,
  332. 'user': self.user,
  333. }
  334. msg = '''\
  335. <p>A site has asked for an identity belonging to
  336. %(expected_user)s, but you are logged in as %(user)s. To
  337. log in as %(expected_user)s and approve the login request,
  338. hit OK below. The "Remember this decision" checkbox
  339. applies only to the trust root decision.</p>''' % mdata
  340. fdata = {
  341. 'identity': request.identity,
  342. 'trust_root': request.trust_root,
  343. 'expected_user': expected_user,
  344. }
  345. form = '''\
  346. <table>
  347. <tr><td>Identity:</td><td>%(identity)s</td></tr>
  348. <tr><td>Trust Root:</td><td>%(trust_root)s</td></tr>
  349. </table>
  350. <p>Allow this authentication to proceed?</p>
  351. <form method="POST" action="/allow">
  352. <input type="checkbox" id="remember" name="remember" value="yes"
  353. /><label for="remember">Remember this
  354. decision</label><br />
  355. <input type="hidden" name="login_as" value="%(expected_user)s"/>
  356. <input type="submit" name="yes" value="yes" />
  357. <input type="submit" name="no" value="no" />
  358. </form>''' % fdata
  359. self.showPage(200, 'Approve OpenID request?', msg=msg, form=form)
  360. def showIdPage(self, path):
  361. link_tag = '<link rel="openid.server" href="%sopenidserver">' %\
  362. self.server.base_url
  363. yadis_loc_tag = '<meta http-equiv="x-xrds-location" content="%s">'%\
  364. (self.server.base_url+'yadis/'+path[4:])
  365. disco_tags = link_tag + yadis_loc_tag
  366. ident = self.server.base_url + path[1:]
  367. approved_trust_roots = []
  368. for (aident, trust_root) in self.server.approved.keys():
  369. if aident == ident:
  370. trs = '<li><tt>%s</tt></li>\n' % cgi.escape(trust_root)
  371. approved_trust_roots.append(trs)
  372. if approved_trust_roots:
  373. prepend = '<p>Approved trust roots:</p>\n<ul>\n'
  374. approved_trust_roots.insert(0, prepend)
  375. approved_trust_roots.append('</ul>\n')
  376. msg = ''.join(approved_trust_roots)
  377. else:
  378. msg = ''
  379. self.showPage(200, 'An Identity Page', head_extras=disco_tags, msg='''\
  380. <p>This is an identity page for %s.</p>
  381. %s
  382. ''' % (ident, msg))
  383. def showYadis(self, user):
  384. self.send_response(200)
  385. self.send_header('Content-type', 'application/xrds+xml')
  386. self.end_headers()
  387. endpoint_url = self.server.base_url + 'openidserver'
  388. user_url = self.server.base_url + 'id/' + user
  389. self.wfile.write("""\
  390. <?xml version="1.0" encoding="UTF-8"?>
  391. <xrds:XRDS
  392. xmlns:xrds="xri://$xrds"
  393. xmlns="xri://$xrd*($v*2.0)">
  394. <XRD>
  395. <Service priority="0">
  396. <Type>%s</Type>
  397. <Type>%s</Type>
  398. <URI>%s</URI>
  399. <LocalID>%s</LocalID>
  400. </Service>
  401. </XRD>
  402. </xrds:XRDS>
  403. """%(discover.OPENID_2_0_TYPE, discover.OPENID_1_0_TYPE,
  404. endpoint_url, user_url))
  405. def showServerYadis(self):
  406. self.send_response(200)
  407. self.send_header('Content-type', 'application/xrds+xml')
  408. self.end_headers()
  409. endpoint_url = self.server.base_url + 'openidserver'
  410. self.wfile.write("""\
  411. <?xml version="1.0" encoding="UTF-8"?>
  412. <xrds:XRDS
  413. xmlns:xrds="xri://$xrds"
  414. xmlns="xri://$xrd*($v*2.0)">
  415. <XRD>
  416. <Service priority="0">
  417. <Type>%s</Type>
  418. <URI>%s</URI>
  419. </Service>
  420. </XRD>
  421. </xrds:XRDS>
  422. """%(discover.OPENID_IDP_2_0_TYPE, endpoint_url,))
  423. def showMainPage(self):
  424. yadis_tag = '<meta http-equiv="x-xrds-location" content="%s">'%\
  425. (self.server.base_url + 'serveryadis')
  426. if self.user:
  427. openid_url = self.server.base_url + 'id/' + self.user
  428. user_message = """\
  429. <p>You are logged in as %s. Your OpenID identity URL is
  430. <tt><a href=%s>%s</a></tt>. Enter that URL at an OpenID
  431. consumer to test this server.</p>
  432. """ % (self.user, quoteattr(openid_url), openid_url)
  433. else:
  434. user_message = """\
  435. <p>This server uses a cookie to remember who you are in
  436. order to simulate a standard Web user experience. You are
  437. not <a href='/login'>logged in</a>.</p>"""
  438. self.showPage(200, 'Main Page', head_extras = yadis_tag, msg='''\
  439. <p>This is a simple OpenID server implemented using the <a
  440. href="http://openid.schtuff.com/">Python OpenID
  441. library</a>.</p>
  442. %s
  443. <p>To use this server with a consumer, the consumer must be
  444. able to fetch HTTP pages from this web server. If this
  445. computer is behind a firewall, you will not be able to use
  446. OpenID consumers outside of the firewall with it.</p>
  447. <p>The URL for this server is <a href=%s><tt>%s</tt></a>.</p>
  448. ''' % (user_message, quoteattr(self.server.base_url), self.server.base_url))
  449. def showLoginPage(self, success_to, fail_to):
  450. self.showPage(200, 'Login Page', form='''\
  451. <h2>Login</h2>
  452. <p>You may log in with any name. This server does not use
  453. passwords because it is just a sample of how to use the OpenID
  454. library.</p>
  455. <form method="GET" action="/loginsubmit">
  456. <input type="hidden" name="success_to" value="%s" />
  457. <input type="hidden" name="fail_to" value="%s" />
  458. <input type="text" name="user" value="" />
  459. <input type="submit" name="submit" value="Log In" />
  460. <input type="submit" name="cancel" value="Cancel" />
  461. </form>
  462. ''' % (success_to, fail_to))
  463. def showPage(self, response_code, title,
  464. head_extras='', msg=None, err=None, form=None):
  465. if self.user is None:
  466. user_link = '<a href="/login">not logged in</a>.'
  467. else:
  468. user_link = 'logged in as <a href="/id/%s">%s</a>.<br /><a href="/loginsubmit?submit=true&success_to=/login">Log out</a>' % \
  469. (self.user, self.user)
  470. body = ''
  471. if err is not None:
  472. body += '''\
  473. <div class="error">
  474. %s
  475. </div>
  476. ''' % err
  477. if msg is not None:
  478. body += '''\
  479. <div class="message">
  480. %s
  481. </div>
  482. ''' % msg
  483. if form is not None:
  484. body += '''\
  485. <div class="form">
  486. %s
  487. </div>
  488. ''' % form
  489. contents = {
  490. 'title': 'Python OpenID Server Example - ' + title,
  491. 'head_extras': head_extras,
  492. 'body': body,
  493. 'user_link': user_link,
  494. }
  495. self.send_response(response_code)
  496. self.writeUserHeader()
  497. self.send_header('Content-type', 'text/html')
  498. self.end_headers()
  499. self.wfile.write('''<html>
  500. <head>
  501. <title>%(title)s</title>
  502. %(head_extras)s
  503. </head>
  504. <style type="text/css">
  505. h1 a:link {
  506. color: black;
  507. text-decoration: none;
  508. }
  509. h1 a:visited {
  510. color: black;
  511. text-decoration: none;
  512. }
  513. h1 a:hover {
  514. text-decoration: underline;
  515. }
  516. body {
  517. font-family: verdana,sans-serif;
  518. width: 50em;
  519. margin: 1em;
  520. }
  521. div {
  522. padding: .5em;
  523. }
  524. table {
  525. margin: none;
  526. padding: none;
  527. }
  528. .banner {
  529. padding: none 1em 1em 1em;
  530. width: 100%%;
  531. }
  532. .leftbanner {
  533. text-align: left;
  534. }
  535. .rightbanner {
  536. text-align: right;
  537. font-size: smaller;
  538. }
  539. .error {
  540. border: 1px solid #ff0000;
  541. background: #ffaaaa;
  542. margin: .5em;
  543. }
  544. .message {
  545. border: 1px solid #2233ff;
  546. background: #eeeeff;
  547. margin: .5em;
  548. }
  549. .form {
  550. border: 1px solid #777777;
  551. background: #ddddcc;
  552. margin: .5em;
  553. margin-top: 1em;
  554. padding-bottom: 0em;
  555. }
  556. dd {
  557. margin-bottom: 0.5em;
  558. }
  559. </style>
  560. <body>
  561. <table class="banner">
  562. <tr>
  563. <td class="leftbanner">
  564. <h1><a href="/">Python OpenID Server Example</a></h1>
  565. </td>
  566. <td class="rightbanner">
  567. You are %(user_link)s
  568. </td>
  569. </tr>
  570. </table>
  571. %(body)s
  572. </body>
  573. </html>
  574. ''' % contents)
  575. def main(host, port, data_path):
  576. addr = (host, port)
  577. httpserver = OpenIDHTTPServer(addr, ServerHandler)
  578. # Instantiate OpenID consumer store and OpenID consumer. If you
  579. # were connecting to a database, you would create the database
  580. # connection and instantiate an appropriate store here.
  581. store = FileOpenIDStore(data_path)
  582. oidserver = server.Server(store, httpserver.base_url + 'openidserver')
  583. httpserver.setOpenIDServer(oidserver)
  584. print 'Server running at:'
  585. print httpserver.base_url
  586. httpserver.serve_forever()
  587. if __name__ == '__main__':
  588. host = 'localhost'
  589. data_path = 'sstore'
  590. port = 8000
  591. try:
  592. import optparse
  593. except ImportError:
  594. pass # Use defaults (for Python 2.2)
  595. else:
  596. parser = optparse.OptionParser('Usage:\n %prog [options]')
  597. parser.add_option(
  598. '-d', '--data-path', dest='data_path', default=data_path,
  599. help='Data directory for storing OpenID consumer state. '
  600. 'Defaults to "%default" in the current directory.')
  601. parser.add_option(
  602. '-p', '--port', dest='port', type='int', default=port,
  603. help='Port on which to listen for HTTP requests. '
  604. 'Defaults to port %default.')
  605. parser.add_option(
  606. '-s', '--host', dest='host', default=host,
  607. help='Host on which to listen for HTTP requests. '
  608. 'Also used for generating URLs. Defaults to %default.')
  609. options, args = parser.parse_args()
  610. if args:
  611. parser.error('Expected no arguments. Got %r' % args)
  612. host = options.host
  613. port = options.port
  614. data_path = options.data_path
  615. main(host, port, data_path)