1 files changed, 94 insertions, 0 deletions
diff --git a/src/jaegertracing/opentelemetry-cpp/examples/http/server.cc b/src/jaegertracing/opentelemetry-cpp/examples/http/server.cc
new file mode 100644
index 000000000..46772dc05
--- /dev/null
+++ b/src/jaegertracing/opentelemetry-cpp/examples/http/server.cc
@@ -0,0 +1,94 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+#include "server.h"
+#include "opentelemetry/trace/context.h"
+#include "opentelemetry/trace/experimental_semantic_conventions.h"
+#include "tracer_common.h"
+
+#include <iostream>
+#include <thread>
+
+namespace
+{
+
+using namespace opentelemetry::trace;
+namespace context = opentelemetry::context;
+
+uint16_t server_port              = 8800;
+constexpr const char *server_name = "localhost";
+
+class RequestHandler : public HTTP_SERVER_NS::HttpRequestCallback
+{
+public:
+  virtual int onHttpRequest(HTTP_SERVER_NS::HttpRequest const &request,
+                            HTTP_SERVER_NS::HttpResponse &response) override
+  {
+    StartSpanOptions options;
+    options.kind          = SpanKind::kServer;  // server
+    std::string span_name = request.uri;
+
+    // extract context from http header
+    const HttpTextMapCarrier<std::map<std::string, std::string>> carrier(
+        (std::map<std::string, std::string> &)request.headers);
+    auto prop        = context::propagation::GlobalTextMapPropagator::GetGlobalPropagator();
+    auto current_ctx = context::RuntimeContext::GetCurrent();
+    auto new_context = prop->Extract(carrier, current_ctx);
+    options.parent   = GetSpan(new_context)->GetContext();
+
+    // start span with parent context extracted from http header
+    auto span = get_tracer("http-server")
+                    ->StartSpan(span_name,
+                                {{OTEL_GET_TRACE_ATTR(AttrHttpServerName), server_name},
+                                 {OTEL_GET_TRACE_ATTR(AttrNetHostPort), server_port},
+                                 {OTEL_GET_TRACE_ATTR(AttrHttpMethod), request.method},
+                                 {OTEL_GET_TRACE_ATTR(AttrHttpScheme), "http"},
+                                 {OTEL_GET_TRACE_ATTR(AttrHttpRequestContentLength),
+                                  static_cast<uint64_t>(request.content.length())},
+                                 {OTEL_GET_TRACE_ATTR(AttrHttpClientIp), request.client}},
+                                options);
+
+    auto scope = get_tracer("http_server")->WithActiveSpan(span);
+
+    for (auto &kv : request.headers)
+    {
+      span->SetAttribute("http.header." + std::string(kv.first.data()), kv.second);
+    }
+    if (request.uri == "/helloworld")
+    {
+      span->AddEvent("Processing request");
+      response.headers[HTTP_SERVER_NS::CONTENT_TYPE] = HTTP_SERVER_NS::CONTENT_TYPE_TEXT;
+      span->End();
+      return 200;
+    }
+    span->End();
+    return 404;
+  }
+};
+}  // namespace
+
+int main(int argc, char *argv[])
+{
+  initTracer();
+
+  // The port the validation service listens to can be specified via the command line.
+  if (argc > 1)
+  {
+    server_port = atoi(argv[1]);
+  }
+
+  HttpServer http_server(server_name, server_port);
+  RequestHandler req_handler;
+  http_server.AddHandler("/helloworld", &req_handler);
+  auto root_span = get_tracer("http_server")->StartSpan(__func__);
+  Scope scope(root_span);
+  http_server.Start();
+  std::cout << "Server is running..Press ctrl-c to exit...\n";
+  while (1)
+  {
+    std::this_thread::sleep_for(std::chrono::seconds(100));
+  }
+  http_server.Stop();
+  root_span->End();
+  return 0;
+}