-#!/usr/bin/python\r
-# ------------------------------------------------\r
-# Copyright 2014 AT&T Intellectual Property\r
-# Licensed under the Apache License, Version 2.0 (the "License");\r
-# you may not use this file except in compliance with the License.\r
-# You may obtain a copy of the License at\r
-#\r
-# http://www.apache.org/licenses/LICENSE-2.0\r
-#\r
-# Unless required by applicable law or agreed to in writing, software\r
-# distributed under the License is distributed on an "AS IS" BASIS,\r
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
-# See the License for the specific language governing permissions and\r
-# limitations under the License.\r
-# -------------------------------------------\r
-\r
-# Implementation of GSHUB REST service\r
-# for announcement and discovery of gs instances, sources and sinks\r
-\r
-from BaseHTTPServer import BaseHTTPRequestHandler, HTTPServer\r
-import SocketServer\r
-import json\r
-import cgi\r
-import threading\r
-import getopt\r
-import sys\r
-import re\r
-import cgi\r
-import socket\r
-import json\r
-\r
-# lis of URLS for all the REST calls we will serve\r
-DISCOVER_INSTANCE_URL = '/v1/discover-instance'\r
-DISCOVER_INITINSTANCE_URL = '/v1/discover-initialized-instance'\r
-DISCOVER_SOURCE_URL = '/v1/discover-source'\r
-DISCOVER_SINK_URL = '/v1/discover-sink'\r
-DISCOVER_STARTPROCESSING_URL = '/v1/discover-start-processing'\r
-ANNOUNCE_INSTANCE_URL = '/v1/announce-instance'\r
-ANNOUNCE_INITINSTANCE_URL = '/v1/announce-initialized-instance'\r
-ANNOUNCE_SOURCE_URL = '/v1/announce-source'\r
-ANNOUNCE_SINK_URL = '/v1/announce-sink'\r
-ANNOUNCE_STARTPROCESSING_URL = '/v1/announce-start-processing'\r
-ANNOUNCE_STREAM_SUBSCRIPTION = '/v1/announce-stream-subscription'\r
-ANNOUNCE_FTA_INSTANCE = '/v1/announce-fta-instance'\r
-ANNOUNCE_METRICS = '/v1/log-metrics'\r
-\r
-# gs instance endpoints\r
-gs_instances = {}\r
-\r
-# initialized gs instances\r
-gs_init_instances = {}\r
-\r
-# instances for which processing started\r
-gs_startprocessing_instances = {}\r
-\r
-# source endpoints\r
-sources = {}\r
-\r
-# sink endpoints\r
-sinks = {}\r
-\r
-\r
-# exctract endpoint information from json data\r
-def extract_endpoint(data) :\r
- name = ''\r
- ip = ''\r
- port = 0\r
- \r
- try :\r
- doc = json.loads(str(data)) \r
- except :\r
- print ('Invalid json message ' + str(data))\r
- return []\r
- \r
- for key in doc.keys() :\r
- if key == 'name' :\r
- name = doc[key]\r
- elif key == 'ip' :\r
- ip = doc[key]\r
- # validate ip address \r
- try :\r
- socket.inet_pton(socket.AF_INET, ip)\r
- except :\r
- print ('Invalid IPV4 address ' + ip)\r
- ip = ''\r
- elif key == 'port' :\r
- # validate port number\r
- try :\r
- port = int(doc[key])\r
- except :\r
- print ('Invalid port number ' + doc[key])\r
- port = 0\r
- \r
- if name == '' or ip == '' or port == 0 :\r
- print ('Name, ip or port is missing from json message ' + str(doc))\r
- return []\r
- \r
-\r
- return [name, ip, port]\r
-\r
-\r
-# extract instance name from json data\r
-def extract_instance_name(data) :\r
- name = ''\r
- \r
- try :\r
- doc = json.loads(str(data)) \r
- except :\r
- print ('Invalid json message ' + str(data))\r
- return ''\r
- \r
- for key in doc.keys() :\r
- if key == 'name' :\r
- name = doc[key]\r
- \r
- if name == '' :\r
- print ('Name field is missing in json message ' + str(doc))\r
- elif (name in gs_instances) == False:\r
- print ('Attempt to announce the initialization or start of processing for unknown instance ' + name)\r
- name = ''\r
- \r
- return name\r
- \r
-# handler for HTTP requests. We will override do_POST and do_GET of BaseHTTPRequestHandler\r
-class Server(BaseHTTPRequestHandler) :\r
-\r
- def do_POST(self):\r
- if re.search(ANNOUNCE_INSTANCE_URL, self.path) != None: \r
- print self.path\r
- print self.headers\r
- if self.headers.getheader('content-type') == 'application/json' :\r
- # Find content length\r
- content_len = 0\r
- for i in range(len(self.headers.keys())):\r
- if self.headers.keys()[i] == 'content-length' :\r
- content_len = int (self.headers.values()[i])\r
- break\r
- if content_len != 0 :\r
- # extract endpoint information\r
- endpoint = extract_endpoint(self.rfile.read(content_len))\r
- if endpoint == [] :\r
- self.send_response(400)\r
- else :\r
- self.send_response(200)\r
- gs_instances[endpoint[0]] = [endpoint[1], endpoint[2]]\r
- else :\r
- self.send_response(400)\r
-\r
- else:\r
- self.send_response(400)\r
- self.end_headers() \r
- \r
- elif re.search(ANNOUNCE_INITINSTANCE_URL, self.path) != None:\r
- if self.headers.getheader('content-type') == 'application/json' :\r
- # Find content length\r
- content_len = 0\r
- for i in range(len(self.headers.keys())):\r
- if self.headers.keys()[i] == 'content-length' :\r
- content_len = int (self.headers.values()[i])\r
- break\r
- if content_len != 0 :\r
- # extract name of initialized gs instance \r
- name = extract_instance_name(self.rfile.read(content_len))\r
- if name == '' :\r
- self.send_response(400)\r
- else :\r
- self.send_response(200)\r
- gs_init_instances[name] = 1\r
- else :\r
- self.send_response(400)\r
-\r
- else:\r
- self.send_response(400)\r
- self.end_headers() \r
- \r
- elif re.search(ANNOUNCE_SOURCE_URL, self.path) != None:\r
- if self.headers.getheader('content-type') == 'application/json' :\r
- # Find content length\r
- content_len = 0\r
- for i in range(len(self.headers.keys())):\r
- if self.headers.keys()[i] == 'content-length' :\r
- content_len = int (self.headers.values()[i])\r
- break\r
- if content_len != 0 :\r
- # extract endpoint information \r
- endpoint = extract_endpoint(self.rfile.read(content_len))\r
- if endpoint == [] :\r
- self.send_response(400)\r
- else :\r
- self.send_response(200)\r
- sources[endpoint[0]] = [endpoint[1], endpoint[2]]\r
- else :\r
- self.send_response(400)\r
-\r
- else:\r
- self.send_response(400)\r
- self.end_headers()\r
- \r
- elif re.search(ANNOUNCE_SINK_URL, self.path) != None:\r
- if self.headers.getheader('content-type') == 'application/json' :\r
- # Find content length\r
- content_len = 0\r
- for i in range(len(self.headers.keys())):\r
- if self.headers.keys()[i] == 'content-length' :\r
- content_len = int (self.headers.values()[i])\r
- break\r
- if content_len != 0 :\r
- # extract endpoint information \r
- endpoint = extract_endpoint(self.rfile.read(content_len))\r
- if endpoint == [] :\r
- self.send_response(400)\r
- else :\r
- self.send_response(200)\r
- sinks[endpoint[0]] = [endpoint[1], endpoint[2]]\r
- else :\r
- self.send_response(400)\r
-\r
- else:\r
- self.send_response(400)\r
- self.end_headers() \r
- \r
- elif re.search(ANNOUNCE_STARTPROCESSING_URL, self.path) != None:\r
- if self.headers.getheader('content-type') == 'application/json' :\r
- # Find content length\r
- content_len = 0\r
- for i in range(len(self.headers.keys())):\r
- if self.headers.keys()[i] == 'content-length' :\r
- content_len = int (self.headers.values()[i])\r
- break\r
- if content_len != 0 :\r
- # extract name of initialized gs instance \r
- name = extract_instance_name(self.rfile.read(content_len))\r
- if name == '' :\r
- self.send_response(400)\r
- else :\r
- self.send_response(200)\r
- gs_startprocessing_instances[name] = 1\r
- else :\r
- self.send_response(400)\r
-\r
- else:\r
- self.send_response(400)\r
- self.end_headers()\r
- \r
- # we do not do any processing for ANNOUNCE_STREAM_SUBSCRIPTION, ANNOUNCE_FTA_INSTANCE and ANNOUNCE_METRICS in gshub simulator \r
- elif (re.search(ANNOUNCE_STREAM_SUBSCRIPTION, self.path) != None) or (re.search(ANNOUNCE_FTA_INSTANCE, self.path) != None) or (re.search(ANNOUNCE_METRICS, self.path) != None):\r
- if self.headers.getheader('content-type') == 'application/json' :\r
- # Find content length\r
- content_len = 0\r
- for i in range(len(self.headers.keys())):\r
- if self.headers.keys()[i] == 'content-length' :\r
- content_len = int (self.headers.values()[i])\r
- break\r
- if content_len != 0 : \r
- self.send_response(200)\r
- else :\r
- self.send_response(400)\r
-\r
- else:\r
- self.send_response(400)\r
- self.end_headers() \r
- \r
- else:\r
- self.send_response(404)\r
- self.end_headers()\r
- return\r
- \r
- def do_GET(self):\r
- if re.search(DISCOVER_INSTANCE_URL + '/*', self.path) != None:\r
- instance = self.path.split('/')[-1]\r
- # check if this instance is registered\r
- if instance in gs_instances :\r
- self.send_response(200)\r
- self.send_header('Content-Type', 'application/json')\r
- self.end_headers()\r
- self.wfile.write(bytes("{\"ip\" : \"" + gs_instances[instance][0] + "\", \"port\": " + str(gs_instances[instance][1]) + "}"))\r
- else:\r
- self.send_response(400)\r
- self.end_headers()\r
-\r
-\r
- elif re.search(DISCOVER_INITINSTANCE_URL + '/*', self.path) != None:\r
- instance = self.path.split('/')[-1]\r
- # check if this instance is initialized\r
- if instance in gs_init_instances :\r
- self.send_response(200)\r
- self.send_header('Content-Type', 'application/json')\r
- self.end_headers()\r
- self.wfile.write(bytes("{\"ip\" : \"" + gs_instances[instance][0] + "\", \"port\": " + str(gs_instances[instance][1]) + "}"))\r
- else:\r
- self.send_response(400)\r
- self.end_headers()\r
-\r
- elif re.search(DISCOVER_SOURCE_URL + '/*', self.path) != None:\r
- source = self.path.split('/')[-1]\r
- # check if it is a registered source\r
- if source in sources :\r
- self.send_response(200)\r
- self.send_header('Content-Type', 'application/json')\r
- self.end_headers()\r
- self.wfile.write(bytes("{\"ip\" : \"" + sources[source][0] + "\", \"port\": " + str(sources[source][1]) + "}"))\r
- else:\r
- self.send_response(400)\r
- self.end_headers()\r
- \r
- elif re.search(DISCOVER_SINK_URL + '/*', self.path) != None:\r
- sink = self.path.split('/')[-1]\r
- # check if it is a registered sink\r
- if sink in sinks :\r
- self.send_response(200)\r
- self.send_header('Content-Type', 'application/json')\r
- self.end_headers()\r
- self.wfile.write(bytes("{\"ip\" : \"" + sinks[sink][0] + "\", \"port\": " + str(sinks[sink][1]) + "}"))\r
- else:\r
- self.send_response(400)\r
- self.end_headers()\r
- \r
- elif re.search(DISCOVER_STARTPROCESSING_URL + '/*', self.path) != None:\r
- instance = self.path.split('/')[-1]\r
- # check if this instance is initialized\r
- if instance in gs_startprocessing_instances :\r
- self.send_response(200)\r
- self.send_header('Content-Type', 'application/json')\r
- self.end_headers()\r
- self.wfile.write(bytes("{}"))\r
- else:\r
- self.send_response(400)\r
- self.end_headers() \r
- else:\r
- self.send_response(404)\r
- self.end_headers()\r
- return\r
-\r
-\r
-# print usage instructions\r
-def usage():\r
- print ('./gshub.py [-p port]')\r
- \r
- \r
-\r
-def main():\r
- # process command-line arguments\r
- try:\r
- opts, args = getopt.getopt(sys.argv[1:], "hp:v", ["help", "port="])\r
- except getopt.GetoptError as err:\r
- # print help information and exit:\r
- print(str(err)) \r
- usage()\r
- sys.exit(2)\r
-\r
- port = 0\r
- for o, a in opts:\r
- if o in ("-h", "--help"):\r
- usage()\r
- sys.exit(0)\r
- elif o in ("-p", "--port"):\r
- port = int(a)\r
- else:\r
- print ('Unknown command-line option ' + o)\r
-\r
- # start HTTP server to serve REST calls\r
- server_address = ('127.0.0.1', port)\r
- httpd = HTTPServer(server_address, Server)\r
-\r
- # record HTTP server address in gshub.log\r
- f = open('gshub.log', 'w')\r
- f.write(str(httpd.server_address[0]) + ':' + str(httpd.server_address[1]) + '\n')\r
- f.close()\r
- \r
- print ('GSHUB Running on port ' + str(httpd.server_address[1]) + ' ...')\r
-\r
- httpd.serve_forever()\r
-\r
- \r
-if __name__ == "__main__":\r
- main()\r
+#!/usr/bin/python
+# ------------------------------------------------
+# Copyright 2014 AT&T Intellectual Property
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# -------------------------------------------
+
+# Implementation of GSHUB REST service
+# for announcement and discovery of gs instances, sources and sinks
+
+from BaseHTTPServer import BaseHTTPRequestHandler, HTTPServer
+import SocketServer
+import json
+import cgi
+import threading
+import getopt
+import sys
+import re
+import cgi
+import socket
+import json
+
+# lis of URLS for all the REST calls we will serve
+DISCOVER_INSTANCE_URL = '/v1/discover-instance'
+DISCOVER_INITINSTANCE_URL = '/v1/discover-initialized-instance'
+DISCOVER_SOURCE_URL = '/v1/discover-source'
+DISCOVER_SINK_URL = '/v1/discover-sink'
+DISCOVER_STARTPROCESSING_URL = '/v1/discover-start-processing'
+ANNOUNCE_INSTANCE_URL = '/v1/announce-instance'
+ANNOUNCE_INITINSTANCE_URL = '/v1/announce-initialized-instance'
+ANNOUNCE_SOURCE_URL = '/v1/announce-source'
+ANNOUNCE_SINK_URL = '/v1/announce-sink'
+ANNOUNCE_STARTPROCESSING_URL = '/v1/announce-start-processing'
+ANNOUNCE_STREAM_SUBSCRIPTION = '/v1/announce-stream-subscription'
+ANNOUNCE_FTA_INSTANCE = '/v1/announce-fta-instance'
+ANNOUNCE_METRICS = '/v1/log-metrics'
+
+# gs instance endpoints
+gs_instances = {}
+
+# initialized gs instances
+gs_init_instances = {}
+
+# instances for which processing started
+gs_startprocessing_instances = {}
+
+# source endpoints
+sources = {}
+
+# sink endpoints
+sinks = {}
+
+
+# exctract endpoint information from json data
+def extract_endpoint(data) :
+ name = ''
+ ip = ''
+ port = 0
+
+ try :
+ doc = json.loads(str(data))
+ except :
+ print ('Invalid json message ' + str(data))
+ return []
+
+ for key in doc.keys() :
+ if key == 'name' :
+ name = doc[key]
+ elif key == 'ip' :
+ ip = doc[key]
+ # validate ip address
+ try :
+ socket.inet_pton(socket.AF_INET, ip)
+ except :
+ print ('Invalid IPV4 address ' + ip)
+ ip = ''
+ elif key == 'port' :
+ # validate port number
+ try :
+ port = int(doc[key])
+ except :
+ print ('Invalid port number ' + doc[key])
+ port = 0
+
+ if name == '' or ip == '' or port == 0 :
+ print ('Name, ip or port is missing from json message ' + str(doc))
+ return []
+
+
+ return [name, ip, port]
+
+
+# extract instance name from json data
+def extract_instance_name(data) :
+ name = ''
+
+ try :
+ doc = json.loads(str(data))
+ except :
+ print ('Invalid json message ' + str(data))
+ return ''
+
+ for key in doc.keys() :
+ if key == 'name' :
+ name = doc[key]
+
+ if name == '' :
+ print ('Name field is missing in json message ' + str(doc))
+ elif (name in gs_instances) == False:
+ print ('Attempt to announce the initialization or start of processing for unknown instance ' + name)
+ name = ''
+
+ return name
+
+# handler for HTTP requests. We will override do_POST and do_GET of BaseHTTPRequestHandler
+class Server(BaseHTTPRequestHandler) :
+
+ def do_POST(self):
+ if re.search(ANNOUNCE_INSTANCE_URL, self.path) != None:
+ print self.path
+ print self.headers
+ if self.headers.getheader('content-type') == 'application/json' :
+ # Find content length
+ content_len = 0
+ for i in range(len(self.headers.keys())):
+ if self.headers.keys()[i] == 'content-length' :
+ content_len = int (self.headers.values()[i])
+ break
+ if content_len != 0 :
+ # extract endpoint information
+ endpoint = extract_endpoint(self.rfile.read(content_len))
+ if endpoint == [] :
+ self.send_response(400)
+ else :
+ self.send_response(200)
+ gs_instances[endpoint[0]] = [endpoint[1], endpoint[2]]
+ else :
+ self.send_response(400)
+
+ else:
+ self.send_response(400)
+ self.end_headers()
+
+ elif re.search(ANNOUNCE_INITINSTANCE_URL, self.path) != None:
+ if self.headers.getheader('content-type') == 'application/json' :
+ # Find content length
+ content_len = 0
+ for i in range(len(self.headers.keys())):
+ if self.headers.keys()[i] == 'content-length' :
+ content_len = int (self.headers.values()[i])
+ break
+ if content_len != 0 :
+ # extract name of initialized gs instance
+ name = extract_instance_name(self.rfile.read(content_len))
+ if name == '' :
+ self.send_response(400)
+ else :
+ self.send_response(200)
+ gs_init_instances[name] = 1
+ else :
+ self.send_response(400)
+
+ else:
+ self.send_response(400)
+ self.end_headers()
+
+ elif re.search(ANNOUNCE_SOURCE_URL, self.path) != None:
+ if self.headers.getheader('content-type') == 'application/json' :
+ # Find content length
+ content_len = 0
+ for i in range(len(self.headers.keys())):
+ if self.headers.keys()[i] == 'content-length' :
+ content_len = int (self.headers.values()[i])
+ break
+ if content_len != 0 :
+ # extract endpoint information
+ endpoint = extract_endpoint(self.rfile.read(content_len))
+ if endpoint == [] :
+ self.send_response(400)
+ else :
+ self.send_response(200)
+ sources[endpoint[0]] = [endpoint[1], endpoint[2]]
+ else :
+ self.send_response(400)
+
+ else:
+ self.send_response(400)
+ self.end_headers()
+
+ elif re.search(ANNOUNCE_SINK_URL, self.path) != None:
+ if self.headers.getheader('content-type') == 'application/json' :
+ # Find content length
+ content_len = 0
+ for i in range(len(self.headers.keys())):
+ if self.headers.keys()[i] == 'content-length' :
+ content_len = int (self.headers.values()[i])
+ break
+ if content_len != 0 :
+ # extract endpoint information
+ endpoint = extract_endpoint(self.rfile.read(content_len))
+ if endpoint == [] :
+ self.send_response(400)
+ else :
+ self.send_response(200)
+ sinks[endpoint[0]] = [endpoint[1], endpoint[2]]
+ else :
+ self.send_response(400)
+
+ else:
+ self.send_response(400)
+ self.end_headers()
+
+ elif re.search(ANNOUNCE_STARTPROCESSING_URL, self.path) != None:
+ if self.headers.getheader('content-type') == 'application/json' :
+ # Find content length
+ content_len = 0
+ for i in range(len(self.headers.keys())):
+ if self.headers.keys()[i] == 'content-length' :
+ content_len = int (self.headers.values()[i])
+ break
+ if content_len != 0 :
+ # extract name of initialized gs instance
+ name = extract_instance_name(self.rfile.read(content_len))
+ if name == '' :
+ self.send_response(400)
+ else :
+ self.send_response(200)
+ gs_startprocessing_instances[name] = 1
+ else :
+ self.send_response(400)
+
+ else:
+ self.send_response(400)
+ self.end_headers()
+
+ # we do not do any processing for ANNOUNCE_STREAM_SUBSCRIPTION, ANNOUNCE_FTA_INSTANCE and ANNOUNCE_METRICS in gshub simulator
+ elif (re.search(ANNOUNCE_STREAM_SUBSCRIPTION, self.path) != None) or (re.search(ANNOUNCE_FTA_INSTANCE, self.path) != None) or (re.search(ANNOUNCE_METRICS, self.path) != None):
+ if self.headers.getheader('content-type') == 'application/json' :
+ # Find content length
+ content_len = 0
+ for i in range(len(self.headers.keys())):
+ if self.headers.keys()[i] == 'content-length' :
+ content_len = int (self.headers.values()[i])
+ break
+ if content_len != 0 :
+ self.send_response(200)
+ else :
+ self.send_response(400)
+
+ else:
+ self.send_response(400)
+ self.end_headers()
+
+ else:
+ self.send_response(404)
+ self.end_headers()
+ return
+
+ def do_GET(self):
+ if re.search(DISCOVER_INSTANCE_URL + '/*', self.path) != None:
+ instance = self.path.split('/')[-1]
+ # check if this instance is registered
+ if instance in gs_instances :
+ self.send_response(200)
+ self.send_header('Content-Type', 'application/json')
+ self.end_headers()
+ self.wfile.write(bytes("{\"ip\" : \"" + gs_instances[instance][0] + "\", \"port\": " + str(gs_instances[instance][1]) + "}"))
+ else:
+ self.send_response(400)
+ self.end_headers()
+
+
+ elif re.search(DISCOVER_INITINSTANCE_URL + '/*', self.path) != None:
+ instance = self.path.split('/')[-1]
+ # check if this instance is initialized
+ if instance in gs_init_instances :
+ self.send_response(200)
+ self.send_header('Content-Type', 'application/json')
+ self.end_headers()
+ self.wfile.write(bytes("{\"ip\" : \"" + gs_instances[instance][0] + "\", \"port\": " + str(gs_instances[instance][1]) + "}"))
+ else:
+ self.send_response(400)
+ self.end_headers()
+
+ elif re.search(DISCOVER_SOURCE_URL + '/*', self.path) != None:
+ source = self.path.split('/')[-1]
+ # check if it is a registered source
+ if source in sources :
+ self.send_response(200)
+ self.send_header('Content-Type', 'application/json')
+ self.end_headers()
+ self.wfile.write(bytes("{\"ip\" : \"" + sources[source][0] + "\", \"port\": " + str(sources[source][1]) + "}"))
+ else:
+ self.send_response(400)
+ self.end_headers()
+
+ elif re.search(DISCOVER_SINK_URL + '/*', self.path) != None:
+ sink = self.path.split('/')[-1]
+ # check if it is a registered sink
+ if sink in sinks :
+ self.send_response(200)
+ self.send_header('Content-Type', 'application/json')
+ self.end_headers()
+ self.wfile.write(bytes("{\"ip\" : \"" + sinks[sink][0] + "\", \"port\": " + str(sinks[sink][1]) + "}"))
+ else:
+ self.send_response(400)
+ self.end_headers()
+
+ elif re.search(DISCOVER_STARTPROCESSING_URL + '/*', self.path) != None:
+ instance = self.path.split('/')[-1]
+ # check if this instance is initialized
+ if instance in gs_startprocessing_instances :
+ self.send_response(200)
+ self.send_header('Content-Type', 'application/json')
+ self.end_headers()
+ self.wfile.write(bytes("{}"))
+ else:
+ self.send_response(400)
+ self.end_headers()
+ else:
+ self.send_response(404)
+ self.end_headers()
+ return
+
+
+# print usage instructions
+def usage():
+ print ('./gshub.py [-p port]')
+
+
+
+def main():
+ # process command-line arguments
+ try:
+ opts, args = getopt.getopt(sys.argv[1:], "hp:v", ["help", "port="])
+ except getopt.GetoptError as err:
+ # print help information and exit:
+ print(str(err))
+ usage()
+ sys.exit(2)
+
+ port = 0
+ for o, a in opts:
+ if o in ("-h", "--help"):
+ usage()
+ sys.exit(0)
+ elif o in ("-p", "--port"):
+ port = int(a)
+ else:
+ print ('Unknown command-line option ' + o)
+
+ # start HTTP server to serve REST calls
+ server_address = ('127.0.0.1', port)
+ httpd = HTTPServer(server_address, Server)
+
+ # record HTTP server address in gshub.log
+ f = open('gshub.log', 'w')
+ f.write(str(httpd.server_address[0]) + ':' + str(httpd.server_address[1]) + '\n')
+ f.close()
+
+ print ('GSHUB Running on port ' + str(httpd.server_address[1]) + ' ...')
+
+ httpd.serve_forever()
+
+
+if __name__ == "__main__":
+ main()
Code Review / com / gs-lite.git / blobdiff