X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=Bouncer%2Fsrc%2Fb_xapp_main.cc;fp=Bouncer%2Fsrc%2Fb_xapp_main.cc;h=0000000000000000000000000000000000000000;hb=fbc7e3ad84fc7269233a2f0b5d416cb1c6f8a6ea;hp=0492e3983f8f730e8c4e769a270fad7dcbc54cd6;hpb=eb27c05c05b5042d115480c40cffa16e7d473d80;p=ric-app%2Fbouncer.git

diff --git a/Bouncer/src/b_xapp_main.cc b/Bouncer/src/b_xapp_main.cc
deleted file mode 100644
index 0492e39..0000000
--- a/Bouncer/src/b_xapp_main.cc
+++ /dev/null
@@ -1,184 +0,0 @@
-/*
-# ==================================================================================
-# Copyright (c) 2020 HCL Technologies Limited.
-#
-# 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.
-# ==================================================================================
-*/
-
-#include "xapp.hpp"
-#include <cpprest/http_listener.h>
-#include <cpprest/json.h>
-#include <cpprest/uri.h>
-using namespace web;
-using namespace web::http;
-using namespace web::http::experimental::listener;
-using namespace utility;
-std::vector<std::string>SubscriptionIds;
-#define TRACE(msg)            wcout << msg
-
-
-void display_json(
-   json::value const & jvalue)
-{
-        cout<<"\ndisplaying REST Notification\n";
-   wcout << jvalue.serialize().c_str() << endl;
-}
-
-
-void handle_request(http_request request)
-{
-auto answer = json::value::object();
-cout<<"\nPrinting POST request content\n";
-cout<<request.to_string()<<"\n";
-   request
-      .extract_json()
-      .then([&answer](pplx::task<json::value> task) {
-         try
-         {
-            answer = task.get();
-            display_json(answer);
-            }
-         catch (http_exception const & e)
-         {
-         cout<<"\ninside catch block";
-            wcout << e.what() << endl;
-         }
-
-      })
-      .wait();
-
-   request.reply(status_codes::OK, answer);
-}
-
-void handle_post(http_request request)
-{
-   TRACE("\nhandle POST\n");
-
-   handle_request(request);
-}
-
-void handle_put(http_request request)
-{
-   TRACE("\nhandle PUT\n");
-
-   handle_request(request);
-}
-
-void start_server()
-{
-        
-         utility::string_t port = U("8080");
-         utility::string_t address = U("http://0.0.0.0:");
-         address.append(port);
-   	 address.append(U("/ric/v1/subscriptions/response"));
-     	uri_builder uri(address);
-
-         auto addr = uri.to_uri().to_string();
-         http_listener listener(addr);
-   	//http_listener listener("http://localhost:8080/ric");
-   	cout<<"validated uri = "<<uri::validate(addr)<<"\n";
-         ucout << utility::string_t(U("Listening for REST Notification at: ")) << addr << std::endl;
-   	listener.support(methods::POST,[](http_request request) { handle_post(request);});
-   	listener.support(methods::PUT,[](http_request request){  handle_put(request);});
-   	try
-   	{
-      	listener
-         	.open()
-         	.then([&listener]() { })
-         	.wait();
-
-      	while (true);
-   	}
-   	catch (exception const & e)
-   	{
-      	wcout << e.what() << endl;
-   	}
-
-}
-
-void signalHandler( int signum ) {
-   cout << "Interrupt signal (" << signum << ") received.\n";
-   exit(signum);
-}
-
-int main(int argc, char *argv[]){
-
-	// Get the thread id
-	std::thread::id my_id = std::this_thread::get_id();
-	std::stringstream thread_id;
-	std::stringstream ss;
-
-	thread_id << my_id;
-
-	mdclog_write(MDCLOG_INFO, "Starting thread %s",  thread_id.str().c_str());
-
-	//get configuration
-	XappSettings config;
-	//change the priority depending upon application requirement
-	config.loadDefaultSettings();
-	config.loadEnvVarSettings();
-	config.loadCmdlineSettings(argc, argv);
-
-	//Register signal handler to stop
-	signal(SIGINT, signalHandler);
-	signal(SIGTERM, signalHandler);
-
-	//getting the listening port and xapp name info
-	std::string  port = config[XappSettings::SettingName::BOUNCER_PORT];
-	std::string  name = config[XappSettings::SettingName::XAPP_NAME];
-
-	//initialize rmr
-	std::unique_ptr<XappRmr> rmr = std::make_unique<XappRmr>(port);
-	rmr->xapp_rmr_init(true);
-
-
-	//Create Subscription Handler if Xapp deals with Subscription.
-	//std::unique_ptr<SubscriptionHandler> sub_handler = std::make_unique<SubscriptionHandler>();
-
-	SubscriptionHandler sub_handler;
-
-	//create Bouncer Xapp Instance.
-	std::unique_ptr<Xapp> b_xapp;
-	b_xapp = std::make_unique<Xapp>(std::ref(config),std::ref(*rmr));
-
-	mdclog_write(MDCLOG_INFO, "Created Bouncer Xapp Instance");
-	//Startup E2 subscription
-	std::thread t1(std::ref(start_server));
-	t1.detach();
-	b_xapp->startup(sub_handler);
-
-	sleep(10);
-
-
-	//start listener threads and register message handlers.
-	int num_threads = std::stoi(config[XappSettings::SettingName::THREADS]);
-	mdclog_write(MDCLOG_INFO, "Starting Listener Threads. Number of Workers = %d", num_threads);
-
-	std::unique_ptr<XappMsgHandler> mp_handler = std::make_unique<XappMsgHandler>(config[XappSettings::SettingName::XAPP_ID], sub_handler);
-
-	b_xapp->start_xapp_receiver(std::ref(*mp_handler));
-
-	sleep(20);//waiting for some time before sending delete.
-
-
-	b_xapp->shutdown();//will start the sending delete procedure.
- 	while(1){
-	 			sleep(1);
-	 		 }
-
-	return 0;
-}
-
-
-