lib/motion_vj.rb in motion_vj-0.1.0 vs lib/motion_vj.rb in motion_vj-0.2.0

- old
+ new

@@ -7,46 +7,46 @@ require 'listen' module MotionVj def self.get_dropbox_token(app_key, app_secret) token = MotionVj::Client.get_token(app_key, app_secret) - puts "Your Dropbox access token for this app is: #{token}" + puts "Your Dropbox access token for this app is: #{ token }" end - def self.start(token) - listener = Listen.to(ENV['VIDEOS_DIR'], only: /\.#{Regexp.escape ENV['VIDEO_EXTENTION']}$/) do |modified_filepaths, _, removed_filepaths| + def self.start(options) + listener = Listen.to(options[:videos_dir], only: /\.#{ Regexp.escape options[:videos_extension] }$/) do |modified_filepaths, _, removed_filepaths| # handle addded files unless modified_filepaths.empty? - client = MotionVj::Client.new(token) - motion_lsof = `lsof -c #{ENV['MOTION_CMD']}` + client = MotionVj::Client.new(options[:db_app_token], options[:db_videos_dir]) + motion_lsof = `lsof -c #{ options[:motion_cmd] }` modified_filepaths.each do |filepath| file_basename = File.basename filepath - if motion_lsof =~ /#{Regexp.escape file_basename}/ + if motion_lsof =~ /#{ Regexp.escape(file_basename) }/ Logger.error "Added file still in use." next end # if not being updated && not already uploaded if !client.file_exist?(file_basename) begin if client.upload(filepath) FileUtils.rm_f(filepath) - Logger.info "'#{file_basename}' was uploaded." + Logger.info "'#{ file_basename }' was uploaded." else - Logger.error "Could not upload '#{file_basename}'." + Logger.error "Could not upload '#{ file_basename }'." end rescue => e - Logger.error "Could not upload '#{file_basename}'." + Logger.error "Could not upload '#{ file_basename }'." end end end end # handle removed files removed_filepaths.each do |filepath| - Logger.info "'#{File.basename(filepath)}' deleted." + Logger.info "'#{ File.basename(filepath) }' deleted." end end listener.start end end