fix(logging): PPT-1368 - logging to use placeos-log-backend (#271)

src/config.cr

@@ -10,10 +10,10 @@ abstract class PlaceOS::Driver; end
 class PlaceOS::Driver::Protocol; end
 
 # Application code
+require "./placeos-core"
 require "./logging"
 require "./constants"
 
-require "./placeos-core"
 require "./api/*"
 
 # Require telemetry after application code

src/constants.cr

@@ -13,6 +13,8 @@ module PlaceOS::Core
 
   REDIS_URL = ENV["REDIS_URL"]? || "redis://localhost:6379"
 
+  Log = ::Log.for(self)
+
   # seconds before a node is considered offline
   # should not be divisible by 3
   CLUSTER_NODE_TTL = (ENV["CLUSTER_NODE_TTL"]? || "20").to_i

src/logging.cr

@@ -4,7 +4,6 @@ require "./constants"
 
 module PlaceOS::Core::Logging
   ::Log.progname = APP_NAME
-
   # Configure logging
   log_backend = PlaceOS::LogBackend.log_backend
   log_level = Core.production? ? ::Log::Severity::Info : ::Log::Severity::Debug

src/placeos-core.cr

@@ -7,38 +7,10 @@ require "./placeos-core/*"
 require "./constants"
 
 module PlaceOS::Core
-  Log           = ::Log.for(self)
-  LOG_STDOUT    = ActionController.default_backend
-  LOGSTASH_HOST = ENV["LOGSTASH_HOST"]?
-  LOGSTASH_PORT = ENV["LOGSTASH_PORT"]?
-
   # Minimize the number of connections being made to redis
   REDIS_LOCK   = Driver::RedisStorage.redis_lock
   REDIS_CLIENT = Driver::RedisStorage.shared_redis_client
 
-  def self.log_backend
-    if !(logstash_host = LOGSTASH_HOST.presence).nil?
-      logstash_port = LOGSTASH_PORT.try(&.to_i?) || abort("LOGSTASH_PORT is either malformed or not present in environment")
-
-      # Logstash UDP Input
-      logstash = UDPSocket.new
-      logstash.connect logstash_host, logstash_port
-      logstash.sync = false
-
-      # debug at the broadcast backend level, however this will be filtered
-      # by the bindings
-      backend = ::Log::BroadcastBackend.new
-      backend.append(LOG_STDOUT, :trace)
-      backend.append(ActionController.default_backend(
-        io: logstash,
-        formatter: ActionController.json_formatter
-      ), :trace)
-      backend
-    else
-      LOG_STDOUT
-    end
-  end
-
   def self.start_managers
     resource_manager = ResourceManager.instance
     module_manager = ModuleManager.instance