You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
devdocs/lib/docs/subscribers/doc_subscriber.rb

57 lines
1.5 KiB

module Docs
class DocSubscriber < Subscriber
self.namespace = 'doc'
def index(event)
before, after = parse_payload(event)
log "Entries:"
log_diff before['entries'], after['entries'], 'name'
log "Types:"
log_diff before['types'], after['types'], 'name'
end
def db(event)
before, after = parse_payload(event)
log "Files:"
log_diff before.keys, after.keys
end
def info(event)
log event.payload[:msg]
end
def error(event)
exception = event.payload[:exception]
log "ERROR:"
puts " #{event.payload[:url]}"
puts " #{exception.class}: #{exception.message.gsub("\n", "\n ")}"
puts exception.backtrace.select { |line| line.start_with?(Docs.root_path) }.join("\n ").prepend("\n ")
puts "\n"
end
private
def parse_payload(event)
[JSON.parse(event.payload[:before]), JSON.parse(event.payload[:after])]
end
def log_diff(before, after, prop = nil)
before ||= []
after ||= []
if prop
before = before.map { |obj| obj[prop] }
after = after.map { |obj| obj[prop] }
end
created, updated, deleted = (after - before), (before & after), (before - after)
log " Updated: #{updated.length}"
log " Created: #{created.length}"
created.each { |str| log " + #{str}" }
log " Deleted: #{deleted.length}"
deleted.each { |str| log " - #{str}" }
end
end
end