versions support for mongodb lifecycle feature

Change-Id: If0fec1afbcddb22aca011234186bbcce2d438a11

mongodb/lib/mongodb_service/job/mongodb_snapshot.rb

@@ -13,6 +13,8 @@ def execute
       filename = "#{snapshot_id}.tgz"
       dump_file_name = File.join(dump_path, filename)
 
+      setup_localdb
+      version = instance_version(name)
       result = dump_database(name, dump_file_name)
       raise "Failed to execute dump command to #{name}" unless result
 
@@ -23,7 +25,8 @@ def execute
         :size => dump_file_size,
         :files => [filename],
         :manifest => {
-          :version => 1
+          :version => 1,
+          :service_version => version
         }
       }
 
@@ -38,6 +41,7 @@ def execute
       dump_file_path = @snapshot_files[0]
       raise "Snapshot file #{dump_file_path} doesn't exist" unless File.exists?(dump_file_path)
 
+      setup_localdb
       result = restore_database(name, dump_file_path)
       raise "Failed execute import command to #{name}" unless result
 

mongodb/lib/mongodb_service/job/util.rb

@@ -26,15 +26,13 @@ def dump_database(service_id, file, opts={})
             return 1
           end
 
-          mongodump_path = @config['mongodump_path'] ? @config['mongodump_path'] : 'mongodump'
           tar_path = @config['tar_path'] ? @config['tar_path'] : 'tar'
           cmd_timeout = @config['timeout'].to_f
 
-          DataMapper.setup(:default, @config['local_db'])
-          DataMapper::auto_upgrade!
-
           tmp_dir = Dir.mktmpdir
           service = Node::ProvisionedService.get(service_id)
+          version = service.version || @config["default_version"]
+          mongodump_path = @config['mongodump_path'] ? @config['mongodump_path'][version.to_s] : 'mongodump'
 
           commands = [ "#{mongodump_path} -h 127.0.0.1:#{service.port} -u #{service.admin} -p #{service.adminpass} -o #{tmp_dir} ", \
                        "#{tar_path} czf #{file} -C #{tmp_dir} ." ]
@@ -56,6 +54,16 @@ def dump_database(service_id, file, opts={})
           nil
         end
 
+        def setup_localdb
+          DataMapper.setup(:default, @config['local_db'])
+          DataMapper::auto_upgrade!
+        end
+
+        def instance_version(service_id)
+          service = Node::ProvisionedService.get(service_id)
+          version = service.version || @config["default_version"]
+        end
+
         def restore_database(service_id, file)
           raise ArgumentError, "Missing options." unless service_id && file
           make_logger
@@ -65,12 +73,12 @@ def restore_database(service_id, file)
             return 1
           end
 
-          mongorestore_path = @config['mongorestore_path'] ? @config['mongorestore_path'] : 'mongorestore'
+          @logger.debug("Manifest in snapshot: #{@manifest}")
+          version = @manifest["service_version"] || @config['default_version']
+          mongorestore_path = @config['mongorestore_path'] ? @config['mongorestore_path'][version.to_s] : 'mongorestore'
           tar_path = @config['tar_path'] ? @config['tar_path'] : 'tar'
           cmd_timeout = @config['timeout'].to_f
 
-          DataMapper.setup(:default, @config['local_db'])
-          DataMapper::auto_upgrade!
 
           tmp_dir = Dir.mktmpdir