test_out_sentry.rb in ach-fluent-plugin-sentry-0.0.13

- old
+ new

@@ -62,49 +62,39 @@
     }
     d = create_driver(CONFIG)
     assert_equal 'https://user:password@app.getsentry.com/12345', d.instance.config['endpoint_url']
   end
 
-  def test_emit
-    stub_request(:post, "https://app.getsentry.com/api/12345/envelope/").
-      with(
-        body: "{\"event_id\":\"2aa1f0210fc04c89a8febda09d3e4a5f\",\"dsn\":\"https://user:password@app.getsentry.com/12345\",\"sdk\":{\"name\":\"sentry.ruby\",\"version\":\"4.6.5\"},\"sent_at\":\"2021-09-01T12:00:23Z\"}\n{\"type\":\"event\",\"content_type\":\"application/json\"}\n{\"event_id\":\"2aa1f0210fc04c89a8febda09d3e4a5f\",\"level\":\"warning\",\"timestamp\":\"2021-09-01T12:00:23\",\"environment\":\"default\",\"server_name\":\"reisei-workspace\",\"modules\":{\"rake\":\"13.0.6\",\"bundler\":\"2.2.26\",\"cool.io\":\"1.7.1\",\"http_parser.rb\":\"0.7.0\",\"msgpack\":\"1.4.2\",\"sigdump\":\"0.2.4\",\"serverengine\":\"2.2.4\",\"strptime\":\"0.2.5\",\"concurrent-ruby\":\"1.1.9\",\"tzinfo\":\"2.0.4\",\"tzinfo-data\":\"1.2021.1\",\"webrick\":\"1.7.0\",\"yajl-ruby\":\"1.4.1\",\"fluentd\":\"1.14.0\",\"faraday-em_http\":\"1.0.0\",\"faraday-em_synchrony\":\"1.0.0\",\"faraday-excon\":\"1.1.0\",\"faraday-httpclient\":\"1.0.1\",\"faraday-net_http\":\"1.0.1\",\"faraday-net_http_persistent\":\"1.2.0\",\"faraday-patron\":\"1.0.0\",\"faraday-rack\":\"1.0.0\",\"multipart-post\":\"2.1.1\",\"ruby2_keywords\":\"0.0.5\",\"faraday\":\"1.7.0\",\"sentry-ruby-core\":\"4.6.5\",\"sentry-ruby\":\"4.6.5\",\"ach-fluent-plugin-sentry\":\"0.0.9\",\"public_suffix\":\"4.0.6\",\"addressable\":\"2.8.0\",\"thor\":\"1.1.0\",\"appraisal\":\"2.4.1\",\"rexml\":\"3.2.5\",\"crack\":\"0.4.5\",\"hashdiff\":\"1.0.1\",\"power_assert\":\"2.0.1\",\"test-unit\":\"3.4.4\",\"webmock\":\"3.14.0\"},\"message\":\"error has occoured.\",\"user\":{},\"tags\":{\"tag\":\"app1_error\"},\"contexts\":{},\"extra\":{},\"fingerprint\":[],\"platform\":\"ruby\",\"sdk\":{\"name\":\"sentry.ruby\",\"version\":\"4.6.5\"}}\n",
-        headers: {
-  	      'Accept'=>'*/*',
-  	      'Accept-Encoding'=>'gzip;q=1.0,deflate;q=0.6,identity;q=0.3',
-  	      'Content-Encoding'=>'',
-  	      'Content-Type'=>'application/x-sentry-envelope',
-  	      'User-Agent'=>'sentry-ruby/4.6.5',
-  	      'X-Sentry-Auth'=>'Sentry sentry_version=7, sentry_client=sentry-ruby/4.6.5, sentry_timestamp=1630497623, sentry_key=user, sentry_secret=password'}).to_return(status: 200, body: "", headers: {})
-    #stub_post
-    d1 = create_driver(CONFIG, 'input.app1_error')
-    emit_level = 'warning'
-    emit_message = 'error has occoured.'
-    emit_extra = {'foo' => {'array' => [1,2,3]}, 'hash' => {'nest' => 'data'}}
-    d1.run do
-      d1.emit({
-        'level' => emit_level,
-        'message' => emit_message,
-        'something' => emit_extra
-      })
-    end
-    p @body
-    emits = d1.emits
-    timestamp = Time.now.utc.strftime('%Y-%m-%dT%H:%M:%S')
-    assert_equal 0, emits.length
+ # def test_emit
+ #   stub_post
+ #   d1 = create_driver(CONFIG, 'input.app1_error')
+ #   emit_level = 'warning'
+ #   emit_message = 'error has occoured.'
+ #   emit_extra = {'foo' => {'array' => [1,2,3]}, 'hash' => {'nest' => 'data'}}
+ #   d1.run do
+ #     d1.emit({
+ #       'level' => emit_level,
+ #       'message' => emit_message,
+ #       'something' => emit_extra
+ #     })
+ #   end
+ #   p @body
+ #   emits = d1.emits
+ #   timestamp = Time.now.utc.strftime('%Y-%m-%dT%H:%M:%S')
+ #   assert_equal 0, emits.length
     #assert_equal 'application/octet-stream', @content_type
-    assert_equal emit_message, @body['message']
-    assert_equal timestamp, @body['timestamp']
-    assert_equal emit_level, @body['level']
-    assert_equal 'fluentd', @body['logger']
-    assert_equal 'ruby', @body['platform']
-    assert_equal 'app1_error', @body['tags']['tag']
-    hostname = `#{d1.instance.config['hostname_command']}`.chomp
-    assert_equal hostname, @body['server_name']
-    extra_message = {'something' => emit_extra}
-    assert_equal extra_message, @body['extra']
-  end
+#    assert_equal emit_message, @body['message']
+#    assert_equal timestamp, @body['timestamp']
+#    assert_equal emit_level, @body['level']
+#    assert_equal 'fluentd', @body['logger']
+#    assert_equal 'ruby', @body['platform']
+#    assert_equal 'app1_error', @body['tags']['tag']
+#    hostname = `#{d1.instance.config['hostname_command']}`.chomp
+#    assert_equal hostname, @body['server_name']
+#    extra_message = {'something' => emit_extra}
+#    assert_equal extra_message, @body['extra']
+#  end
 
   def test_emit_mock
     stub_response
     emit_level = 'warning'
     emit_message = 'error has occoured.'
@@ -129,13 +119,14 @@
         'time_spent' => emit_time_spent,
         'culprit' => emit_culprit
       })
     end
     p @body
+    puts 'test', @body
     emits = d1.emits
     extra_message = {'something' => emit_extra}
     assert_equal 0, emits.length
-    #assert_equal 'application/octet-stream', @content_type
+    assert_equal 'application/x-sentry-envelope', @content_type
     assert_equal extra_message, @body['context']
     assert_equal emit_timestamp, @body['dateCreated']
     assert_equal emit_message, @body['message']
     assert_equal emit_level, Hash[ @body['tags'] ]['level']
     assert_equal emit_logger, Hash[ @body['tags'] ]['logger']