Workingish version.

Author: jbussdieker

Rakefile

@@ -1 +1,4 @@
 require "bundler/gem_tasks"
+require 'rspec/core/rake_task'
+
+RSpec::Core::RakeTask.new(:spec)

lib/rsync.rb

@@ -1,5 +1,13 @@
 require "rsync/version"
+require "rsync/command"
+require "rsync/result"
 
 module Rsync
-  # Your code goes here...
+  def self.command(args = [], &block)
+    output = Command.new(args).run
+    exitcode = $?
+    result = Result.new(output, exitcode)
+    yield(result) if block_given?
+    result
+  end
 end

lib/rsync/change.rb

@@ -0,0 +1,146 @@
+module Rsync
+  class Change
+    include Enumerable
+
+    def initialize(raw)
+      @raw = raw
+    end
+
+    def each(&block)
+      @raw.split("\n").each do |line|
+        #if line =~ /^([<>ch.*][fdLDS][ .+\?cstTpoguax]{9}) (.*)$/
+        if line =~ /^([<>ch.\*].{10}) (.*)$/
+          detail = Detail.new(line)
+          yield(detail) if detail.changed?
+        end
+      end
+    end
+
+    class Detail
+      def initialize(raw)
+        @raw = raw
+      end
+
+      def filename
+        @raw[12..-1]
+      end
+
+      def changed?
+        if update_type == :message
+          return true
+        elsif update_type == :recv
+          return true
+        end
+        false
+      end
+
+      def summary
+        if update_type == :message
+          message
+        elsif update_type == :recv and @raw[2,9] == "+++++++++"
+          "creating"
+        elsif update_type == :recv
+          "updating"
+        else
+          changes = []
+          #[:checksum, :size, :timestamp, :permissions, :owner, :group, :acl].each do |prop|
+          [:checksum, :size, :permissions, :owner, :group, :acl].each do |prop|
+            changes << prop if send(prop) == :changed
+          end
+          changes.join(", ")
+        end
+      end
+
+      def message
+        @raw[1..10].strip
+      end
+
+      def raw_update_type
+        @raw[0]
+      end
+
+      def raw_file_type
+        @raw[1]
+      end
+
+      def attribute_prop(index)
+        case @raw[index]
+          when '.'
+            :no_change
+          when ' '
+            :identical
+          when '+'
+            :new
+          when '?'
+            :unknown
+          else
+            :changed
+        end
+      end
+
+      def checksum
+        attribute_prop(2)
+      end
+
+      def size
+        attribute_prop(3)
+      end
+
+      def timestamp
+        attribute_prop(4)
+      end
+
+      def permissions
+        attribute_prop(5)
+      end
+
+      def owner
+        attribute_prop(6)
+      end
+
+      def group
+        attribute_prop(7)
+      end
+
+      def acl
+        attribute_prop(9)
+      end
+
+      def ext_attr
+        attribute_prop(10)
+      end
+
+      def update_type
+        case raw_update_type
+          when '<'
+            :sent
+          when '>'
+            :recv
+          when 'c'
+            :change
+          when 'h'
+            :hard_link
+          when '.'
+            :no_update
+          when '*'
+            :message
+        end
+      end
+
+      def file_type
+        case raw_file_type
+          when 'f'
+            :file
+          when 'd'
+            :directory
+          when 'L'
+            :symlink
+          when 'D'
+            :device
+          when 'S'
+            :special
+        end
+      end
+    end
+  end
+end

lib/rsync/command.rb

@@ -0,0 +1,19 @@
+module Rsync
+  class Command
+    def initialize(args)
+      @args = args.join(" ")
+    end
+
+    def run
+      run_command("rsync --itemize-changes #{@args}")
+    end
+
+    def run_command(cmd, &block)
+      if block_given?
+        IO.popen("#{cmd} 2>&1", &block)
+      else
+        `#{cmd} 2>&1`
+      end
+    end
+  end
+end

lib/rsync/result.rb

@@ -0,0 +1,65 @@
+require 'rsync/change'
+
+module Rsync
+  class Result
+    def initialize(raw, exitcode)
+      @raw = raw
+      @exitcode = exitcode
+    end
+
+    def success?
+      @exitcode.to_i == 0
+    end
+
+    def error
+      case @exitcode.exitstatus
+        when 0 
+          "Success"
+        when 1
+          "Syntax or usage error"
+        when 2
+          "Protocol incompatibility"
+        when 3
+          "Errors selecting input/output files, dirs"
+        when 4
+          "Requested action not supported: an attempt was made to manipulate 64-bit files on a platform that can not support them; or an option was specified that is supported by the client and not by the server."
+        when 5
+          "Error starting client-server protocol"
+        when 6
+          "Daemon unable to append to log-file"
+        when 10
+          "Error in socket I/O"
+        when 11
+          "Error in file I/O"
+        when 12
+          "Error in rsync protocol data stream"
+        when 13
+          "Errors with program diagnostics"
+        when 14
+          "Error in IPC code"
+        when 20
+          "Received SIGUSR1 or SIGINT"
+        when 21
+          "Some error returned by waitpid()"
+        when 22
+          "Error allocating core memory buffers"
+        when 23
+          "Partial transfer due to error"
+        when 24
+          "Partial transfer due to vanished source files"
+        when 25
+          "The --max-delete limit stopped deletions"
+        when 30
+          "Timeout in data send/receive"
+        when 35
+          "Timeout waiting for daemon connection"
+        else
+          "Unknown Error"
+      end
+    end
+
+    def changes
+      Change.new(@raw)
+    end
+  end
+end

rsync.gemspec

@@ -8,9 +8,8 @@ Gem::Specification.new do |spec|
   spec.version       = Rsync::VERSION
   spec.authors       = ["Joshua Bussdieker"]
   spec.email         = ["[email protected]"]
-  spec.description   = %q{TODO: Write a gem description}
-  spec.summary       = %q{TODO: Write a gem summary}
-  spec.homepage      = ""
+  spec.summary       = %q{Ruby/Rsync is a Ruby library that can syncronize files between remote hosts by wrapping a call to the rsync binary.}
+  spec.homepage      = "http://github.com/jbussdieker/ruby-rsync"
   spec.license       = "MIT"
 
   spec.files         = `git ls-files`.split($/)
@@ -20,4 +19,5 @@ Gem::Specification.new do |spec|
 
   spec.add_development_dependency "bundler", "~> 1.3"
   spec.add_development_dependency "rake"
+  spec.add_development_dependency "rspec"
 end

spec/rsync/change_spec.rb

@@ -0,0 +1,42 @@
+require 'rsync/change'
+
+describe Rsync::Change do
+  it "should handle example" do
+    Rsync::Change.new(".f          blah2.txt")
+  end
+end
+
+describe Rsync::Change::Detail do
+  it "should handle filename" do
+    Rsync::Change::Detail.new("            filename").filename.should eql("filename")
+  end
+
+  it "should handle message type" do
+    Rsync::Change::Detail.new("*deleting  ").message.should eql("deleting")
+  end
+
+  it "should handle update types" do
+    Rsync::Change::Detail.new("<          ").update_type.should eql(:sent)
+    Rsync::Change::Detail.new(">          ").update_type.should eql(:recv)
+    Rsync::Change::Detail.new("c          ").update_type.should eql(:change)
+    Rsync::Change::Detail.new("h          ").update_type.should eql(:hard_link)
+    Rsync::Change::Detail.new(".          ").update_type.should eql(:no_update)
+    Rsync::Change::Detail.new("*          ").update_type.should eql(:message)
+  end
+
+  it "should handle file types" do
+    Rsync::Change::Detail.new(" f         ").file_type.should eql(:file)
+    Rsync::Change::Detail.new(" d         ").file_type.should eql(:directory)
+    Rsync::Change::Detail.new(" L         ").file_type.should eql(:symlink)
+    Rsync::Change::Detail.new(" D         ").file_type.should eql(:device)
+    Rsync::Change::Detail.new(" S         ").file_type.should eql(:special)
+  end
+
+  it "should handle checksum info" do
+    Rsync::Change::Detail.new("  c        ").checksum.should eql(:changed)
+    Rsync::Change::Detail.new("  .        ").checksum.should eql(:no_change)
+    Rsync::Change::Detail.new("           ").checksum.should eql(:identical)
+    Rsync::Change::Detail.new("  +        ").checksum.should eql(:new)
+    Rsync::Change::Detail.new("  ?        ").checksum.should eql(:unknown)
+  end
+end