Set span kind to SERVER (#103)

lib/instrumentation.ex

@@ -83,7 +83,7 @@ defmodule OpentelemetryAbsinthe.Instrumentation do
     save_parent_ctx()
 
     span_name = span_name(nil, nil, config.span_name)
-    new_ctx = Tracer.start_span(span_name, %{attributes: attributes})
+    new_ctx = Tracer.start_span(span_name, %{kind: :server, attributes: attributes})
 
     Tracer.set_current_span(new_ctx)
   end

test/span_kind_test.exs

@@ -0,0 +1,11 @@
+defmodule OpentelemetryAbsintheTest.SpanKind do
+  use OpentelemetryAbsintheTest.Case
+
+  alias OpentelemetryAbsintheTest.Support.GraphQL.Queries
+  alias OpentelemetryAbsintheTest.Support.Query
+
+  test "span kind is server" do
+    OpentelemetryAbsinthe.Instrumentation.setup()
+    :server = Query.query_for_span_kind(Queries.invalid_query())
+  end
+end

test/support/query.ex

@@ -9,23 +9,29 @@ defmodule OpentelemetryAbsintheTest.Support.Query do
   @fields Record.extract(:span, from: "deps/opentelemetry/include/otel_span.hrl")
   Record.defrecordp(:span, @fields)
 
-  def query_for_attrs(query, opts \\ []) do
+  def query_for_span(query, opts \\ []) do
     :otel_simple_processor.set_exporter(:otel_exporter_pid, self())
 
     {:ok, data} = Absinthe.run(query, Schema, opts)
     Logger.debug("Absinthe query returned: #{inspect(data)}")
 
-    assert_receive {:span, span(attributes: {_, _, _, _, attributes})}, 5000
+    assert_receive {:span, span}, 5000
+    Logger.debug("Recieved span: #{inspect(span)}")
+    span
+  end
+
+  def query_for_attrs(query, opts \\ []) do
+    span(attributes: {_, _, _, _, attributes}) = query_for_span(query, opts)
     attributes
   end
 
   def query_for_span_name(query, opts \\ []) do
-    :otel_simple_processor.set_exporter(:otel_exporter_pid, self())
-
-    {:ok, data} = Absinthe.run(query, Schema, opts)
-    Logger.debug("Absinthe query returned: #{inspect(data)}")
-
-    assert_receive {:span, span(name: name)}, 5000
+    span(name: name) = query_for_span(query, opts)
     name
   end
+
+  def query_for_span_kind(query, opts \\ []) do
+    span(kind: kind) = query_for_span(query, opts)
+    kind
+  end
 end