# -*- coding: utf-8 -*- require 'nokogiri' require 'log4r/outputter/outputter' require "log4r/staticlogger" require 'active_support' require 'active_support/time' require 'active_support/core_ext' module Log4r class EvernoteOutputter < Outputter SANDBOX_HOST = 'sandbox.evernote.com' PRODUCTION_HOST = 'www.evernote.com' def initialize(_name, hash = {}) super(_name, hash) validate(hash) end # validation of evernote parameters def validate(hash) set_maxsize(hash) # for rolling set_shift_age(hash) # for roling env = hash[:env] || hash['env'] || 'sandbox' if env == 'sandbox' @env = "https://#{SANDBOX_HOST}/edam/user" elsif env == 'production' @env = "https://#{PRODUCTION_HOST}/edam/user" else raise ArgumentError, "Must specify from env 'sandbox' or 'production'" end @auth_token = hash[:auth_token] || hash['auth_token'] || "" raise ArgumentError, "Must specify from auth token" if @auth_token.empty? @evernote = MyEvernote.new(@env, @auth_token) notebook = hash[:notebook] || hash['notebook'] || "" raise ArgumentError, "Must specify from notebook" if notebook.empty? tags = @evernote.get_tags(hash[:tags] || hash['tags'] || []) stack = hash[:stack] || hash['stack'] @evernote = MyEvernote.new(@env, @auth_token) @notebook = @evernote.get_notebook(notebook, stack) @note = @evernote.get_note(@notebook) @tags = tags.map{|tag_obj| tag_obj.guid} end def canonical_log(logevent); super end def write(content) @content = content if note_size_requires_roll? || time_requires_roll? create_log else update_log end end private def create_log @note.clear @note.title = @name + " - " + Time.now.strftime("%Y-%m-%d %H:%M:%S") @note.tags = @tags @note.content = @content @note.create Logger.log_internal { "Create note: #{@note.guid}" } end def update_log @note.addContent(@content) @note.update Logger.log_internal { "Update note: #{@note.guid}" } end # more expensive, only for startup def note_size_requires_roll? @note.size == 0 || (@maxsize > 0 && @note.size >= @maxsize) end def time_requires_roll? !@endTime.nil? && Time.now.to_i >= @endTime end def set_maxsize(options) if options.has_key?(:maxsize) || options.has_key?('maxsize') maxsize = options[:maxsize] || options['maxsize'] multiplier = 1 if (maxsize =~ /\d+KB/) multiplier = 1024 elsif (maxsize =~ /\d+MB/) multiplier = 1024 * 1024 elsif (maxsize =~ /\d+GB/) multiplier = 1024 * 1024 * 1024 end _maxsize = maxsize.to_i * multiplier if _maxsize.class != Fixnum and _maxsize.class != Bignum raise TypeError, "Argument 'maxsize' must be an Fixnum", caller end if _maxsize == 0 raise TypeError, "Argument 'maxsize' must be > 0", caller end @maxsize = _maxsize else @maxsize = 0 end end def set_maxtime(options) if options.has_key?(:maxtime) || options.has_key?('maxtime') _maxtime = (options[:maxtime] or options['maxtime']).to_i if _maxtime.class != Fixnum raise TypeError, "Argument 'maxtime' must be an Fixnum", caller end if _maxtime == 0 raise TypeError, "Argument 'maxtime' must be > 0", caller end @maxtime = _maxtime @startTime = Time.now else @maxtime = 0 @startTime = 0 end end def set_shift_age(options) if options.has_key?(:shift_age) || options.has_key?('shift_age') _shift_age = (options[:shift_age] or options['shift_age']).to_i if _shift_age.class != Fixnum raise TypeError, "Argument 'shift_age' must be an Fixnum", caller end unless _shift_age.nil? unless [Log4ever::ShiftAge::DAILY, Log4ever::ShiftAge::WEEKLY, Log4ever::ShiftAge::MONTHLY].include? _shift_age raise TypeError, "Argument 'shift_age' must be > 0", caller end now = Time.now case _shift_age when Log4ever::ShiftAge::DAILY tomorrow = Time.local(now.tomorrow.year, now.tomorrow.month, now.tomorrow.day) @endTime = tomorrow.to_i when Log4ever::ShiftAge::WEEKLY next_week = Time.local(now.next_week.year, now.next_week.month, now.next_week.day) @endTime = next_week.to_i when Log4ever::ShiftAge::MONTHLY next_month = Time.local(now.next_month.year, now.next_month.month, now.next_month.day) @endTime = next_month.to_i else raise TypeError, "Argument 'shift_age' must be '1' or '2' or '3'", caller end end end end end end