Merge pull request #7 from mocyuto/fix-worker-record

Fix for some unnessesary records

.github/workflows/test.yaml

@@ -1,14 +1,13 @@
 name: Test
 on:
-  - push
   - pull_request
 jobs:
   build:
     runs-on: ${{ matrix.os }}
     strategy:
       fail-fast: false
       matrix:
-        ruby: ["2.5", "2.6", "2.7", "3.0"]
+        ruby: ["2.6", "2.7", "3.0", "3.1"]
         os:
           - ubuntu-latest
           - windows-latest

README.md

@@ -25,7 +25,7 @@ If `tag` is specified as bufferd chunk key, it send as tag for sentry.
 
 ### record keys
 
-- `message`: message body for sentry as events.
+- `message` (required): message body for sentry as events.
 - `level`: log level for sentry as events.
 
 

lib/fluent/plugin/out_raven.rb

@@ -25,7 +25,7 @@ class RavenOutput < Output
     helpers :inject
 
     config_param :dsn, :string, default: nil
-    config_param :environment, :string, default: nil
+    config_param :environment, :string, default: 'development'
     config_param :logger_level, :string, default: 'info'
     config_param :default_level, :string, default: 'error'
 
@@ -47,12 +47,15 @@ def start
 
     def write(chunk)
       tag = chunk.metadata.tag
-      chunk.each do |_time, record|
+      chunk
+        .each do |_time, record|
+        next if record['message'].nil?
+
         Sentry.capture_message record['message'],
                                level: record['level'] || @default_level,
                                tags: {
                                  logger: 'fluent-sentry-logger',
-                                 worker: record['worker'],
+                                 worker: record['worker'] || Socket.gethostname,
                                  tag: tag
                                }
       end