v0.5.2

src/access_log.cr

@@ -1,3 +1,4 @@
+require "log"
 require "file_utils"
 require "json"
 require "socket"
@@ -9,7 +10,9 @@ require "./models/access_log"
 require "./models/crawler"
 require "./swd"
 
-VERSION = "0.5.1"
+VERSION = "0.5.2"
+
+Log.setup_from_env
 
 # Default socket location
 socket = "/tmp/access_log.socket"
@@ -82,7 +85,7 @@ OptionParser.parse do |p|
 end
 
 # Parameterize values according to database URI
-if database.starts_with? "postgresql://"
+if database.starts_with?("postgresql://") || database.starts_with?("postgres://")
   params = fields.map_with_index do |_, i|
     "$#{i + 1}"
   end
@@ -187,7 +190,8 @@ db = DB.open database do |db|
               (swd ? s.try(&.total_co2) : nil)
 
     # Ignore parsing errors
-    rescue JSON::ParseException
+    rescue e : JSON::ParseException
+      Log.warn &.emit("Parse exception", error: e.message)
     rescue IO::Error
       server.close
       FileUtils.rm(socket) if File.exists? socket