2 # ==================================================================================
3 # Copyright (c) 2022 Nokia
5 # Licensed under the Apache License, Version 2.0 (the "License");
6 # you may not use this file except in compliance with the License.
7 # You may obtain a copy of the License at
9 # http://www.apache.org/licenses/LICENSE-2.0
11 # Unless required by applicable law or agreed to in writing, software
12 # distributed under the License is distributed on an "AS IS" BASIS,
13 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 # See the License for the specific language governing permissions and
15 # limitations under the License.
16 # ==================================================================================
31 from time import gmtime, strftime
33 #sys.path.insert(0, '../ricxappframe/xapp-frame-py')
34 from ricxappframe.xapp_frame import RMRXapp, rmr
35 from ricxappframe.xapp_sdl import SDLWrapper
36 from ricxappframe.xapp_symptomdata import Symptomdata
38 # rmr init mode - when set to port 4561 then will wait for the rtmgr to connect
39 # otherwise will connect to rtmgr like set below
40 RMR_INIT_SVC = b"4560"
44 def signal_handler(sig, frame):
53 def RMR_init_xapp(initbind):
56 MRC = mrc = rmr.rmr_init(initbind, rmr.RMR_MAX_RCV_BYTES, 0x00)
57 while rmr.rmr_ready(mrc) == 0:
59 print('[%d]::RMR not yet ready')
60 rmr.rmr_set_stimeout(mrc, 1)
61 sbuf = rmr.rmr_alloc_msg(mrc, 500)
63 print('[%d]::RMR ready')
66 def read_file(filename):
68 with open(filename, 'r') as f:
73 except IOError as error:
76 def getSymptomData(symptomHndl, uriparams):
77 paramlist = urllib.parse.parse_qs(uriparams)
78 [x.upper() for x in paramlist]
82 if paramlist.get('fromTime'):
83 fromtime = getSeconds(paramlist.get('fromTime')[0])
84 if paramlist.get('toTime'):
85 totime = getSeconds(paramlist.get('toTime')[0])
86 zipfile = symptomHndl.collect("symptomdata"+'-%Y-%m-%d-%H-%M-%S.zip', ('examples/.*.py',), fromtime, totime)
88 (zipfile, size, data) = symptomHndl.read()
89 return (zipfile, size, data)
90 return (None, 0, None)
93 class RestHandler(http.server.BaseHTTPRequestHandler):
94 # responds to http request according to the process status
97 def _set_headers(self, status, length=0, ctype = 'application/json', attachment = None):
98 self.send_response(status)
99 self.send_header("Server-name", "XAPP REST SERVER 1.0")
100 self.send_header('Content-type', ctype)
102 self.send_header('Content-length', length)
103 if attachment != None:
104 self.send_header('Content-Disposition', "attachment; filename=" + attachment)
112 logging.debug("POST %s" % (self.path))
113 except (socket.error, IOError):
118 logging.debug("DELETE %s" % (self.path))
119 except (socket.error, IOError):
124 # default get handler
128 ctype = 'application/json'
130 if self.path == "/ric/v1/health/alive":
131 data = json.dumps({'status': 'alive'})
132 elif self.path == "/ric/v1/health/ready":
133 data = json.dumps({'status': 'ready'})
134 elif self.path.find("/ric/v1/symptomdata") >= 0:
135 (zipfile, size, data) = getSymptomData(symptomHndl, self.path[20:])
138 ctype = 'application/zip'
139 attachment = "symptomdata.zip"
141 logging.error("Symptom data does not exists")
142 self._set_headers(404, 0)
146 self._set_headers(200, length, ctype, attachment)
149 self.wfile.write(data.encode('utf-8'))
152 self.wfile.write(data)
154 logging.error("Unknown uri %s" % (self.path))
155 self._set_headers(404, 0)
156 except (socket.error, IOError):
159 class ThreadedHTTPServer(object):
160 handler = RestHandler
161 server_class = http.server.HTTPServer
162 def __init__(self, host, port):
163 self.server = self.server_class((host, port), self.handler)
164 self.server_thread = threading.Thread(target=self.server.serve_forever)
165 self.server_thread.daemon = True
168 self.server_thread.start()
171 self.server.socket.close()
172 self.server.server_close()
173 self.server.shutdown()
180 # init the default values
181 ADDRESS = "0.0.0.0" # bind to all interfaces
182 PORT = 8080 # web server listen port
184 parser = argparse.ArgumentParser()
185 parser.add_argument('-port', dest='port', help='HTTP server listen port, default 3000', required=False, type=int)
186 parser.add_argument('-address', dest='address', help='IP listen address, default all interfaces', required=False, type=str)
187 parser.add_argument('-xapp', dest='xapp', help='xapp name', required=True, type=str)
188 parser.add_argument('-service', dest='service', help='xapp service name (same as pod host name)', required=True, type=str)
189 args = parser.parse_args()
191 if args.port is not None:
193 if args.address is not None:
194 ADDRESS = args.address
196 # handle the RMR_SEED_RT and RMR_RTG_SVC which is different in mcxapp
198 os.environ["RMR_SRC_ID"] = args.service
199 os.environ["RMR_LOG_VLEVEL"] = '4'
200 os.environ["RMR_RTG_SVC"] = "4561"
201 rmrseed = os.environ.get('RMR_SEED_RT')
202 if rmrseed is not None:
203 data = read_file(rmrseed)
205 print("RMR seed file %s does not exists or is empty" % (rmrseed))
207 print("RMR_SEED_RT seed file not set in environment")
208 data = read_file('uta-rtg.rt')
210 os.environ['RMR_SEED_RT'] = "./uta-rtg.rt"
211 print("Setting the default RMR_SEED_RT=uta-rtg.rt - content:")
214 print("Try to export the RMR_SEED_RT file if your RMR is not getting ready")
216 symptomHndl = Symptomdata(args.service, args.xapp, "/tmp/", "http://service-ricplt-lwsd-http:8080/ric/v1/lwsd", 10)
218 # Start the threaded server, bind to address
219 server = ThreadedHTTPServer(ADDRESS, PORT)
222 mrc, sbuf = RMR_init_xapp(b"4560")
225 print("Waiting for a message, will timeout after 2000ms")
226 sbuf = rmr.rmr_torcv_msg(mrc, None, 2000)
227 summary = rmr.message_summary(sbuf)
228 if summary[rmr.RMR_MS_MSG_STATE] == 12:
229 print("Nothing received =(")
231 print("Message received!: {}".format(summary))
232 data = rmr.get_payload(sbuf)
233 rmr.rmr_free_msg(sbuf)
235 if __name__ == '__main__':
236 signal.signal(signal.SIGQUIT, signal_handler)
237 signal.signal(signal.SIGTERM, signal_handler)
238 signal.signal(signal.SIGINT, signal_handler)