Contents

#!/usr/bin/env ruby -w
#
#  Copyright (c) 2007 Ritchie Young. All rights reserved.
#
# This file is part of RubySync.
# 
# RubySync is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License
# as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version.
# 
# RubySync is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied
# warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
# 
# You should have received a copy of the GNU General Public License along with RubySync; if not, write to the
# Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA


lib_path = File.dirname(__FILE__) + '/../lib'
$:.unshift lib_path unless $:.include?(lib_path) || $:.include?(File.expand_path(lib_path))

require 'ruby_sync'

module RubySync::Connectors::ActiveRecordEventHandler

  # Disable mirror updates for incoming events
  def update_mirror(path); end
  def delete_from_mirror(path); end

  # Process each RubySyncEvent and then delete it from the db.
  def each_change
    ::RubySyncEvent.find(:all).each do |rse|
      event = RubySync::Event.new(rse.event_type, self, rse.trackable_id, nil, to_payload(rse))
      yield event
      ::RubySyncEvent.delete rse
    end
  end

  # Create a hash suitable to use as rubysync event payload
  def to_payload ar_event
    ar_event.operations.map do |op|
      RubySync::Operation.new(op.operation.to_sym, op.field_name, op.values.map {|v| v.value})
    end
  end


  

end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
rubysync-0.1.0	lib/ruby_sync/connectors/active_record_event_handler.rb
rubysync-0.2.1	lib/ruby_sync/connectors/active_record_event_handler.rb
rubysync-0.0.4	lib/ruby_sync/connectors/active_record_event_handler.rb
rubysync-0.0.3	lib/ruby_sync/connectors/active_record_event_handler.rb
rubysync-0.0.5	lib/ruby_sync/connectors/active_record_event_handler.rb
rubysync-0.1.1	lib/ruby_sync/connectors/active_record_event_handler.rb