first commit

Author: cwilper

.gitignore

@@ -0,0 +1,6 @@
+*.gem
+*.swp
+.fixi
+.bundle
+Gemfile.lock
+pkg/*

Gemfile

@@ -0,0 +1,4 @@
+source "http://rubygems.org"
+
+# Specify your gem's dependencies in fixi.gemspec
+gemspec

Rakefile

@@ -0,0 +1 @@
+require "bundler/gem_tasks"

bin/fixi

@@ -0,0 +1,50 @@
+#!/usr/bin/env ruby
+
+require 'rubygems'
+require 'trollop'
+require 'fixi'
+
+name = ARGV.shift
+if name == "--help" || name == "-h" || name == "help"
+  name = ARGV.shift
+  if name.nil?
+    puts <<-EOS
+usage: fixi [--version] [--help] <command> [<options>] [path]
+
+All commands are scoped to the current directory or the given path, if specified.
+
+Commands:
+     add:   #{Fixi::Command::Add.synopsis}
+   check:   #{Fixi::Command::Check.synopsis}
+  commit:   #{Fixi::Command::Commit.synopsis}
+    info:   #{Fixi::Command::Info.synopsis}
+    init:   #{Fixi::Command::Init.synopsis}
+      ls:   #{Fixi::Command::Ls.synopsis}
+      rm:   #{Fixi::Command::Rm.synopsis}
+     sum:   #{Fixi::Command::Sum.synopsis}
+
+See 'fixi help <command>' for more information on a specific command.
+    EOS
+    exit 0
+  else
+    ARGV.insert(0, "--help")
+  end
+elsif name == "--version" || name == "-v"
+  puts "fixi version #{Fixi::VERSION}"
+  exit 0
+end
+
+command = Fixi::command name
+if command.nil?
+  puts "Error: No such command: #{name}"
+  exit 1
+end
+begin
+  command.execute ARGV
+rescue RuntimeError => msg
+  puts "Error: #{msg}"
+  exit 1
+#rescue => msg
+#  puts "Error: #{msg}"
+#  exit 1
+end

fixi.gemspec

@@ -0,0 +1,26 @@
+# -*- encoding: utf-8 -*-
+$:.push File.expand_path("../lib", __FILE__)
+require "fixi/version"
+
+Gem::Specification.new do |s|
+  s.name        = "fixi"
+  s.version     = Fixi::VERSION
+  s.authors     = ["Chris Wilper"]
+  s.email       = ["[email protected]"]
+  s.homepage    = ""
+  s.summary     = "A fixity tracker utility"
+  s.description = "Keeps an index of checksums and lets you update and verify them"
+
+  s.rubyforge_project = "fixi"
+
+  s.files         = `git ls-files`.split("\n")
+  s.test_files    = `git ls-files -- {test,spec,features}/*`.split("\n")
+  s.executables   = `git ls-files -- bin/*`.split("\n").map{ |f| File.basename(f) }
+  s.require_paths = ["lib"]
+
+  # specify any dependencies here; for example:
+  # s.add_development_dependency "rspec"
+  # s.add_runtime_dependency "rest-client"
+
+  s.add_runtime_dependency "trollop"
+end

lib/fixi.rb

@@ -0,0 +1,42 @@
+require "digest"
+require "fixi/version"
+require "fixi/patch/string_pack"
+require "fixi/command"
+
+module Fixi
+  # Get an instance of the command with the given name
+  def self.command(name)
+    return nil unless Command.const_defined? name.capitalize
+    Command.const_get(name.capitalize).new
+  end
+
+  # Validate the given comma-separated list of checksum algorithms
+  # and return and array of matching Digest implementations
+  def self.digests(checksums)
+    digests = []
+    checksums.split(",").each do |checksum|
+      begin
+        digests << Digest(checksum.upcase).new
+      rescue LoadError
+        raise "No such algorithm: #{checksum}"
+      end
+    end
+    digests
+  end
+
+  # Read the file once while computing any number of digests
+  def self.hexdigests(digests, file)
+    File.open(file, "rb") {|f|
+      buf = ""
+      while f.read(16384, buf)
+        digests.each {|digest| digest.update buf}
+      end
+    }
+    hds = []
+    digests.each {|digest|
+      hd = digest.hexdigest
+      hds << hd
+    }
+    hds
+  end
+end

lib/fixi/command.rb

@@ -0,0 +1,10 @@
+module Fixi::Command
+  def self.banner(name)
+    "fixi-#{name}: #{const_get(name.capitalize).synopsis}\n\n" +
+      "usage: fixi #{name} [<options>] [path]\n\n" +
+      "#{const_get(name.capitalize).details}\n\n" +
+      "Options:"
+  end
+end
+
+Dir.glob(File.dirname(__FILE__) + '/command/*') {|file| require file}

lib/fixi/command/add.rb

@@ -0,0 +1,33 @@
+require 'trollop'
+require 'fixi/index'
+
+class Fixi::Command::Add
+  def self.synopsis
+    "Add new files to the index"
+  end
+
+  def self.details
+    "This command is scoped to the current directory or the given path,
+      if specified.".pack
+  end
+
+  def execute args
+    opts = Trollop::options args do
+      banner Fixi::Command.banner "add"
+      opt :absolute, "Show absolute paths. By default, paths are reported
+        relative to the index root.".pack
+      opt :dry_run, "Don't do anything; just report what would be done"
+    end
+    path = File.expand_path(args[0] || ".")
+    index = Fixi::Index.new(path)
+
+    index.find(path) do |abspath|
+      relpath = index.relpath(abspath)
+      unless index.contains?(relpath)
+        puts "A #{opts[:absolute] ? abspath : relpath}"
+        index.add(relpath) unless opts[:dry_run]
+      end
+    end
+
+  end
+end

lib/fixi/command/check.rb

@@ -0,0 +1,66 @@
+require 'trollop'
+
+class Fixi::Command::Check
+  def self.synopsis
+    "Verify the fixity of files in the index"
+  end
+
+  def self.details
+    "This command is scoped to the current directory or the given path,
+      if specified.".pack
+  end
+
+  def execute args
+    opts = Trollop::options args do
+      banner Fixi::Command.banner "check"
+      opt :absolute, "Show absolute paths. By default, paths are reported
+        relative to the index root.".pack
+      opt :shallow, "Do shallow comparisons when determining which files have
+        changed. If specified, only file sizes and mtimes will be used. By 
+        default, checksums will also be computed and compared if necessary.".pack
+      opt :verbose, "For modified files, show which attribute changed.
+        By default, only the path is shown.".pack
+    end
+    path = File.expand_path(args[0] || ".")
+    index = Fixi::Index.new(path)
+   
+    index.each(args[0]) do |hash|
+      relpath = hash['relpath']
+      abspath = index.rootpath + '/' + relpath
+      if index.file_in_scope(relpath)
+        if File.exists?(abspath)
+          size = File.size(abspath)
+          mtime = File.mtime(abspath).to_i
+          if size != hash['size']
+            detail = opts[:verbose] ? "size=#{size} " : ""
+            puts "M #{detail}#{opts[:absolute] ? abspath : relpath}"
+          elsif File.mtime(abspath).to_i != hash['mtime']
+            detail = opts[:verbose] ? "mtime=#{Time.at(mtime).utc.iso8601} " : ""
+            puts "M #{detail}#{opts[:absolute] ? abspath : relpath}"
+          elsif not opts[:shallow]
+            hexdigests = Fixi::hexdigests(Fixi::digests(index.algorithms), abspath)
+            i = 0
+            index.algorithms.split(',').each do |algorithm|
+              if hexdigests[i] != hash[algorithm]
+                detail = opts[:verbose] ? "#{algorithm}=#{hexdigests[i]} " : ""
+                puts "M #{detail}#{opts[:absolute] ? abspath : relpath}"
+              end
+              i += 1
+            end
+          end
+        else
+          puts "D #{opts[:absolute] ? abspath : relpath}"
+        end
+      else
+        puts "X #{opts[:absolute] ? abspath : relpath}"
+      end
+    end
+
+    index.find(path) do |abspath|
+      relpath = index.relpath(abspath)
+      unless index.contains?(relpath)
+        puts "A #{opts[:absolute] ? abspath : relpath}"
+      end
+    end
+  end
+end

lib/fixi/command/commit.rb

@@ -0,0 +1,62 @@
+require 'trollop'
+require 'find'
+require 'fixi/index'
+
+class Fixi::Command::Commit
+  def self.synopsis
+    "Commit modified files to the index"
+  end
+
+  def self.details
+    "This command is scoped to the current directory or the given path,
+      if specified.".pack
+  end
+
+  def execute args
+    opts = Trollop::options args do
+      banner Fixi::Command.banner "commit"
+      opt :absolute, "Show absolute paths. By default, paths are reported
+        relative to the index root.".pack
+      opt :dry_run, "Don't do anything; just report what would be done"
+      opt :shallow, "Do shallow comparisons when determining which files have
+        changed. If specified, only file sizes and mtimes will be used. By 
+        default, checksums will also be computed and compared if necessary.".pack
+      opt :verbose, "For modified files, show which attribute changed.
+        By default, only the path is shown.".pack
+    end
+    path = File.expand_path(args[0] || ".")
+    index = Fixi::Index.new(path)
+
+    index.each(args[0]) do |hash|
+      relpath = hash['relpath']
+      abspath = index.rootpath + '/' + relpath
+      if index.file_in_scope(relpath) && File.exists?(abspath)
+        size = File.size(abspath)
+        mtime = File.mtime(abspath).to_i
+        if size != hash['size']
+          detail = opts[:verbose] ? "size=#{size} " : ""
+          puts "M #{detail}#{opts[:absolute] ? abspath : relpath}"
+          index.update(relpath) unless opts[:dry_run]
+        elsif mtime != hash['mtime']
+          detail = opts[:verbose] ? "mtime=#{Time.at(mtime).utc.iso8601} " : ""
+          puts "M #{detail}#{opts[:absolute] ? abspath : relpath}"
+          index.update(relpath) unless opts[:dry_run]
+        elsif not opts[:shallow]
+          hexdigests = Fixi::hexdigests(Fixi::digests(index.algorithms), abspath)
+          i = 0
+          need_update = false
+          index.algorithms.split(',').each do |algorithm|
+            if not(need_update) && (hexdigests[i] != hash[algorithm])
+              need_update = true
+              detail = opts[:verbose] ? "#{algorithm}=#{hexdigests[i]} " : ""
+              puts "M #{detail}#{opts[:absolute] ? abspath : relpath}"
+            end
+            hash[algorithm] = hexdigests[i]
+            i += 1
+          end
+          index.update(relpath, hash) if need_update && not(opts[:dry_run])
+        end
+      end
+    end
+  end
+end