Add instance_type and organization labels

fluent-plugin-wodby.gemspec

@@ -3,7 +3,7 @@ $LOAD_PATH.unshift(lib) unless $LOAD_PATH.include?(lib)
 
 Gem::Specification.new do |spec|
   spec.name    = "fluent-plugin-wodby"
-  spec.version = "0.1.8"
+  spec.version = "0.2.0"
   spec.authors = ["Robert Wunderer"]
   spec.email   = ["robert@ramsalt.com"]
 

lib/fluent/plugin/filter_wodby.rb

@@ -40,15 +40,22 @@ def filter(tag, time, record)
             record['wodby.instance_query'] = namespace
             instance = get_instance(namespace)
             app = get_app(instance['app_id'])
+            org = get_org(app['org_id'])
 
             @instance_map[namespace] = {
               'name' => "#{app['name']}.#{instance['name']}",
               'title' => "#{app['title']} - #{instance['title']}",
+              'type' => instance['type'],
+              'organization' => org['title'],
+              'organization_name' => org['name'],
             }
           end
 
           record['wodby.instance'] = @instance_map[namespace]['name']
           record['wodby.instance_title'] = @instance_map[namespace]['title']
+          record['wodby.instance_type'] = @instance_map[namespace]['type']
+          record['wodby.organization'] = @instance_map[namespace]['organization']
+          record['wodby.organization_name'] = @instance_map[namespace]['organization_name']
         else
           log.info "No namespace found"
           log.info record
@@ -86,6 +93,20 @@ def get_app(app_id)
 
         app
       end
+
+      def get_org(org_id)
+        begin
+          response = RestClient.get(
+            "https://api.wodby.com/api/v3/orgs/#{org_id}",
+            headers={'X-API-KEY': @api_key}
+          )
+          org = JSON.parse(response)
+        rescue RestClient::ExceptionWithResponse
+          org = {}
+        end
+
+        org
+      end
     end
   end
 end