server.hpp

Go to the documentation of this file.

/*
 * Copyright 2020 Robert Bosch GmbH
 *
 * 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.
 *
 * SPDX-License-Identifier: Apache-2.0
 */
#pragma once
 
#include <memory>  // for unique_ptr<>
#include <string>  // for string
#include <vector>  // for vector<>
 
#include <cloe/cloe_fwd.hpp>         // for Handler
#include <fable/fable_fwd.hpp>       // for Json
#include <oatpp/network/Server.hpp>  // for Server
 
#include "oak/registrar.hpp"  // for StaticRegistrar, BufferRegistrar
 
namespace oak {
 
class GreedyHandler;
 
class Server {
 public:
  Server(const std::string& addr, int port);
  Server();
 
  ~Server();
 
  void set_threads(int n) { listen_threads_ = n; }
 
  void set_address(const std::string& addr) { listen_addr_ = addr; }
 
  const std::string& address() const { return listen_addr_; }
 
  void set_port(int port) { listen_port_ = port; }
 
  int port() const { return listen_port_; }
 
  bool is_listening() const { return listening_; }
 
  void listen();
 
  fable::Json endpoints_to_json(const std::vector<std::string>& endpoints) const;
 
  void stop();
 
  std::vector<std::string> endpoints() const;
 
 protected:
  friend StaticRegistrar;
  friend LockedRegistrar;
  friend BufferRegistrar;
 
  void add_handler(const std::string& key, cloe::Handler h);
 
 private:
  // Configuration
  std::string listen_addr_;
  int listen_port_;
  int listen_threads_;
 
  // State
  bool listening_;
  std::shared_ptr<oatpp::network::Server> server_;
  std::shared_ptr<GreedyHandler> handler_;
};
 
}  // namespace oak