1 files changed, 69 insertions, 0 deletions
diff --git a/lib/tapicero/replication.rb b/lib/tapicero/replication.rb
new file mode 100644
index 0000000..c8253a1
--- /dev/null
+++ b/lib/tapicero/replication.rb
@@ -0,0 +1,69 @@
+require 'couchrest'
+require 'json'
+
+module Tapicero
+  class Replication
+
+    LocalEndpoint = Struct.new(:name) do
+      def key; name; end
+      def url; name; end
+      def save_url; name; end
+    end
+
+    RemoteEndpoint = Struct.new(:remote, :credentials) do
+      def key;        domain; end
+      def url;       "http://#{creds}@#{domain}:#{port}/#{name}"; end
+      def save_url;  "http://...@#{domain}:#{port}/#{name}"; end
+      def domain;    remote[:internal_domain]; end
+      def port;      remote[:couch_port]; end
+      def name;      remote[:name]; end
+      def creds;     credentials[:username] + ':' + credentials[:password]; end
+    end
+
+    def initialize(source, target)
+      @source = endpoint_for(source)
+      @target = endpoint_for(target)
+    end
+
+    def run(options)
+      Tapicero.logger.debug "Replicating from #{source.save_url} to #{target.save_url}."
+      replication_db.save_doc replication_doc.merge(options)
+    end
+
+    def replication_doc
+      {
+        _id: "#{source.key}_to_#{target.key}"
+        source: source.url,
+        target: target.url,
+        user_ctx: {
+          name: replication_credentials[:username],
+          roles: [replication_credentials[:role]]
+        }
+      }
+    end
+
+    protected
+
+    def endpoint_for(hash_or_string)
+      hash_or_string.respond_to? :[] ?
+        RemoteEndpoint.new(hash_or_string, replication_credentials) :
+        LocalEndpoint.new(hash_or_string)
+    end
+
+    def replication_credentials
+      config.options[:replication].slice(:username, :password, :role)
+    end
+
+    def replication_db
+      @replication_db ||= couch.database('_replicator')
+    end
+
+    def couch
+      @couch ||= CouchRest.new(config.couch_host)
+    end
+
+    def config
+      Tapicero.config
+    end
+
+end