SDMSubscriptionDocumentApi.cpp 7.28 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20
/*
 * Licensed to the OpenAirInterface (OAI) Software Alliance under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The OpenAirInterface Software Alliance licenses this file to You under
 * the OAI Public License, Version 1.1  (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.openairinterface.org/?page_id=698
 *
 * 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.
 *-------------------------------------------------------------------------------
 * For more information about the OpenAirInterface (OAI) Software Alliance:
 *      contact@openairinterface.org
 */
yangjian's avatar
yangjian committed
21
/**
yangjian's avatar
yangjian committed
22 23 24 25 26 27 28 29 30 31 32
 * Nudr_DataRepository API OpenAPI file
 * Unified Data Repository Service. © 2020, 3GPP Organizational Partners (ARIB,
 * ATIS, CCSA, ETSI, TSDSI, TTA, TTC). All rights reserved.
 *
 * The version of the OpenAPI document: 2.1.2
 *
 *
 * NOTE: This class is auto generated by OpenAPI Generator
 * (https://openapi-generator.tech). https://openapi-generator.tech Do not edit
 * the class manually.
 */
yangjian's avatar
yangjian committed
33 34

#include "SDMSubscriptionDocumentApi.h"
Tien-Thinh Nguyen's avatar
Tien-Thinh Nguyen committed
35

yangjian's avatar
yangjian committed
36
#include "Helpers.h"
37
#include "logger.hpp"
yangjian's avatar
yangjian committed
38

39
namespace oai::udr::api {
yangjian's avatar
yangjian committed
40

41 42
using namespace oai::udr::helpers;
using namespace oai::udr::model;
yangjian's avatar
yangjian committed
43

yangjian's avatar
yangjian committed
44 45 46
SDMSubscriptionDocumentApi::SDMSubscriptionDocumentApi(
    std::shared_ptr<Pistache::Rest::Router> rtr) {
  router = rtr;
yangjian's avatar
yangjian committed
47 48
}

yangjian's avatar
yangjian committed
49
void SDMSubscriptionDocumentApi::init() { setupRoutes(); }
yangjian's avatar
yangjian committed
50 51

void SDMSubscriptionDocumentApi::setupRoutes() {
yangjian's avatar
yangjian committed
52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79
  using namespace Pistache::Rest;

  Routes::Patch(
      *router,
      base + "/subscription-data/:ueId/context-data/sdm-subscriptions/:subsId",
      Routes::bind(&SDMSubscriptionDocumentApi::modifysdm_subscription_handler,
                   this));
  Routes::Get(
      *router,
      base + "/subscription-data/:ueId/context-data/sdm-subscriptions/:subsId",
      Routes::bind(&SDMSubscriptionDocumentApi::querysdm_subscription_handler,
                   this));
  Routes::Delete(
      *router,
      base + "/subscription-data/:ueId/context-data/sdm-subscriptions/:subsId",
      Routes::bind(&SDMSubscriptionDocumentApi::removesdm_subscriptions_handler,
                   this));
  Routes::Put(
      *router,
      base + "/subscription-data/:ueId/context-data/sdm-subscriptions/:subsId",
      Routes::bind(&SDMSubscriptionDocumentApi::updatesdmsubscriptions_handler,
                   this));

  // Default handler, called when a route is not found
  router->addCustomHandler(
      Routes::bind(&SDMSubscriptionDocumentApi::
                       sdm_subscription_document_api_default_handler,
                   this));
yangjian's avatar
yangjian committed
80 81
}

yangjian's avatar
yangjian committed
82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100
void SDMSubscriptionDocumentApi::modifysdm_subscription_handler(
    const Pistache::Rest::Request &request,
    Pistache::Http::ResponseWriter response) {
  Logger::udr_server().info("SDMSubscription Method: PATCH!");

  // Getting the path params
  auto ueId = request.param(":ueId").as<std::string>();
  auto subsId = request.param(":subsId").as<std::string>();

  // Getting the body param
  std::vector<PatchItem> patchItem;

  // Getting the query params
  auto supportedFeaturesQuery = request.query().get("supported-features");
  Pistache::Optional<std::string> supportedFeatures;
  if (!supportedFeaturesQuery.isEmpty()) {
    std::string valueQuery_instance;
    if (fromStringValue(supportedFeaturesQuery.get(), valueQuery_instance)) {
      supportedFeatures = Pistache::Some(valueQuery_instance);
yangjian's avatar
yangjian committed
101
    }
yangjian's avatar
yangjian committed
102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119
  }

  try {
    nlohmann::json::parse(request.body()).get_to(patchItem);
    this->modifysdm_subscription(ueId, subsId, patchItem, supportedFeatures,
                                 response);
  } catch (nlohmann::detail::exception &e) {
    // send a 400 error
    response.send(Pistache::Http::Code::Bad_Request, e.what());
    return;
  } catch (Pistache::Http::HttpError &e) {
    response.send(static_cast<Pistache::Http::Code>(e.code()), e.what());
    return;
  } catch (std::exception &e) {
    // send a 500 error
    response.send(Pistache::Http::Code::Internal_Server_Error, e.what());
    return;
  }
yangjian's avatar
yangjian committed
120
}
yangjian's avatar
yangjian committed
121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143
void SDMSubscriptionDocumentApi::querysdm_subscription_handler(
    const Pistache::Rest::Request &request,
    Pistache::Http::ResponseWriter response) {
  Logger::udr_server().info("SDMSubscription Method: GET!");

  // Getting the path params
  auto ueId = request.param(":ueId").as<std::string>();
  auto subsId = request.param(":subsId").as<std::string>();

  try {
    this->querysdm_subscription(ueId, subsId, response);
  } catch (nlohmann::detail::exception &e) {
    // send a 400 error
    response.send(Pistache::Http::Code::Bad_Request, e.what());
    return;
  } catch (Pistache::Http::HttpError &e) {
    response.send(static_cast<Pistache::Http::Code>(e.code()), e.what());
    return;
  } catch (std::exception &e) {
    // send a 500 error
    response.send(Pistache::Http::Code::Internal_Server_Error, e.what());
    return;
  }
yangjian's avatar
yangjian committed
144
}
yangjian's avatar
yangjian committed
145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167
void SDMSubscriptionDocumentApi::removesdm_subscriptions_handler(
    const Pistache::Rest::Request &request,
    Pistache::Http::ResponseWriter response) {
  Logger::udr_server().info("SDMSubscription Method: DELETE!");

  // Getting the path params
  auto ueId = request.param(":ueId").as<std::string>();
  auto subsId = request.param(":subsId").as<std::string>();

  try {
    this->removesdm_subscriptions(ueId, subsId, response);
  } catch (nlohmann::detail::exception &e) {
    // send a 400 error
    response.send(Pistache::Http::Code::Bad_Request, e.what());
    return;
  } catch (Pistache::Http::HttpError &e) {
    response.send(static_cast<Pistache::Http::Code>(e.code()), e.what());
    return;
  } catch (std::exception &e) {
    // send a 500 error
    response.send(Pistache::Http::Code::Internal_Server_Error, e.what());
    return;
  }
yangjian's avatar
yangjian committed
168
}
yangjian's avatar
yangjian committed
169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196
void SDMSubscriptionDocumentApi::updatesdmsubscriptions_handler(
    const Pistache::Rest::Request &request,
    Pistache::Http::ResponseWriter response) {
  Logger::udr_server().info("SDMSubscription Method: PUT!");

  // Getting the path params
  auto ueId = request.param(":ueId").as<std::string>();
  auto subsId = request.param(":subsId").as<std::string>();

  // Getting the body param

  SdmSubscription sdmSubscription;

  try {
    nlohmann::json::parse(request.body()).get_to(sdmSubscription);
    this->updatesdmsubscriptions(ueId, subsId, sdmSubscription, response);
  } catch (nlohmann::detail::exception &e) {
    // send a 400 error
    response.send(Pistache::Http::Code::Bad_Request, e.what());
    return;
  } catch (Pistache::Http::HttpError &e) {
    response.send(static_cast<Pistache::Http::Code>(e.code()), e.what());
    return;
  } catch (std::exception &e) {
    // send a 500 error
    response.send(Pistache::Http::Code::Internal_Server_Error, e.what());
    return;
  }
yangjian's avatar
yangjian committed
197 198
}

yangjian's avatar
yangjian committed
199 200 201 202
void SDMSubscriptionDocumentApi::sdm_subscription_document_api_default_handler(
    const Pistache::Rest::Request &, Pistache::Http::ResponseWriter response) {
  response.send(Pistache::Http::Code::Not_Found,
                "The requested method does not exist");
yangjian's avatar
yangjian committed
203 204
}

Tien-Thinh Nguyen's avatar
Tien-Thinh Nguyen committed
205
}  // namespace oai::udr::api