initial implementation of DSL

Author: anthonycorletti

lib/ferry/configuration.rb

@@ -1 +1,142 @@
-configuration.rb
+require_relative 'configuration/filter'
+require_relative 'configuration/question'
+require_relative 'configuration/server'
+require_relative 'configuration/servers'
+
+module Ferry
+ class Configuration
+
+ def initialize(config = nil)
+ @config ||= config
+ end
+
+ def self.env
+ @env ||= new
+ end
+
+ def self.reset!
+ @env = new
+ end
+
+ def ask(key, default=nil, options={})
+ question = Question.new(key, default, options)
+ set(key, question)
+ end
+
+ def set(key, value)
+ config[key] = value
+ end
+
+ def set_if_empty(key, value)
+ config[key] = value unless config.has_key? key
+ end
+
+ def delete(key)
+ config.delete(key)
+ end
+
+ def fetch(key, default=nil, &block)
+ value = fetch_for(key, default, &block)
+ while callable_without_parameters?(value)
+ value = set(key, value.call)
+ end
+ return value
+ end
+
+ def keys
+ config.keys
+ end
+
+ def role(name, hosts, options={})
+ if name == :all
+ raise ArgumentError.new("#{name} reserved name for role. Please choose another name")
+ end
+
+ servers.add_role(name, hosts, options)
+ end
+
+ def server(name, properties={})
+ servers.add_host(name, properties)
+ end
+
+ def roles_for(names)
+ servers.roles_for(names)
+ end
+
+ def role_properties_for(names, &block)
+ servers.role_properties_for(names, &block)
+ end
+
+ def primary(role)
+ servers.fetch_primary(role)
+ end
+
+ def backend
+ @backend ||= SSHKit
+ end
+
+ attr_writer :backend
+
+ def configure_backend
+ backend.configure do |sshkit|
+ sshkit.format = fetch(:format)
+ sshkit.output_verbosity = fetch(:log_level)
+ sshkit.default_env = fetch(:default_env)
+ sshkit.backend = fetch(:sshkit_backend, SSHKit::Backend::Netssh)
+ sshkit.backend.configure do |backend|
+ backend.pty = fetch(:pty)
+ backend.connection_timeout = fetch(:connection_timeout)
+ backend.ssh_options = (backend.ssh_options || {}).merge(fetch(:ssh_options,{}))
+ end
+ end
+ end
+
+ def timestamp
+ @timestamp ||= Time.now.utc
+ end
+
+ def setup_filters
+ @filters = cmdline_filters.clone
+ @filters << Filter.new(:role, ENV['ROLES']) if ENV['ROLES']
+ @filters << Filter.new(:host, ENV['HOSTS']) if ENV['HOSTS']
+ fh = fetch_for(:filter,{}) || {}
+ @filters << Filter.new(:host, fh[:host]) if fh[:host]
+ @filters << Filter.new(:role, fh[:role]) if fh[:role]
+ end
+
+ def add_cmdline_filter(type, values)
+ cmdline_filters << Filter.new(type, values)
+ end
+
+ def filter list
+ setup_filters if @filters.nil?
+ @filters.reduce(list) { |l,f| f.filter l }
+ end
+
+ private
+
+ def cmdline_filters
+ @cmdline_filters ||= []
+ end
+
+ def servers
+ @servers ||= Servers.new
+ end
+
+ def config
+ @config ||= Hash.new
+ end
+
+ def fetch_for(key, default, &block)
+ if block_given?
+ config.fetch(key, &block)
+ else
+ config.fetch(key, default)
+ end
+ end
+
+ def callable_without_parameters?(x)
+ x.respond_to?(:call) && ( !x.respond_to?(:arity) || x.arity == 0)
+ end
+ end
+end

lib/ferry/defaults.rb

@@ -0,0 +1,3 @@
+# options for user to set in the deploy.rb
+# still not sure what we can put here ...
+# see deploy_ferry.rb.erb for ideas

lib/ferry/deploy.rb

@@ -1 +1,3 @@
-deploy.rb
+require 'ferry/framework'
+
+load File.expand_path("../tasks/deploy.rake", __FILE__)

lib/ferry/dotfile.rb

@@ -1 +1,2 @@
-dotfile.rb
+dotfile = Pathname.new(File.join(Dir.home, '.ferryfile'))
+load dotfile if dotfile.file?

lib/ferry/dsl.rb

@@ -1 +1,64 @@
-dsl.rb
+require 'etc'
+require 'ferry/dsl/task_enhancements'
+require 'ferry/dsl/paths'
+require 'ferry/dsl/stages'
+require 'ferry/dsl/env'
+require 'ferry/configuration/filter'
+
+module Ferry
+ module DSL
+ include TaskEnhancements
+ include Env
+ include Paths
+ include Stages
+
+ def invoke(task, *args)
+ Rake::Task[task].invoke(*args)
+ end
+
+ def t(key, options={})
+ I18n.t(key, options.merge(scope: :ferry))
+ end
+
+ def scm
+ fetch(:scm)
+ end
+
+ def sudo(*args)
+ execute :sudo, *args
+ end
+
+ def revision_log_message
+ fetch(:revision_log_message,
+ t(:revision_log_message,
+ branch: fetch(:branch),
+ user: local_user,
+ sha: fetch(:current_revision),
+ release: fetch(:release_timestamp))
+ )
+ end
+
+ def rollback_log_message
+ t(:rollback_log_message, user: local_user, release: fetch(:rollback_timestamp))
+ end
+
+ def local_user
+ fetch(:local_user)
+ end
+
+ def lock(locked_version)
+ VersionValidator.new(locked_version).verify
+ end
+
+ def on(hosts, options={}, &block)
+ subset_copy = Marshal.dump(Configuration.env.filter(hosts))
+ SSHKit::Coordinator.new(Marshal.load(subset_copy)).each(options, &block)
+ end
+
+ def run_locally(&block)
+ SSHKit::Backend::Local.new(&block).run
+ end
+
+ end
+end
+self.extend Ferry::DSL

lib/ferry/dsl/env.rb

@@ -1 +1,81 @@
-env.rb
+module Ferry
+ module DSL
+ module Env
+
+ def configure_backend
+ env.configure_backend
+ end
+
+ def fetch(key, default=nil, &block)
+ env.fetch(key, default, &block)
+ end
+
+ def any?(key)
+ value = fetch(key)
+ if value && value.respond_to?(:any?)
+ value.any?
+ else
+ !fetch(key).nil?
+ end
+ end
+
+ def set(key, value)
+ env.set(key, value)
+ end
+
+ def set_if_empty(key, value)
+ env.set_if_empty(key, value)
+ end
+
+ def delete(key)
+ env.delete(key)
+ end
+
+ def ask(key, value, options={})
+ env.ask(key, value, options)
+ end
+
+ def role(name, servers, options={})
+ env.role(name, servers, options)
+ end
+
+ def server(name, properties={})
+ env.server(name, properties)
+ end
+
+ def roles(*names)
+ env.roles_for(names.flatten)
+ end
+
+ def role_properties(*names, &block)
+ env.role_properties_for(names, &block)
+ end
+
+ def release_roles(*names)
+ if names.last.is_a? Hash
+ names.last.merge!({ :exclude => :no_release })
+ else
+ names << { exclude: :no_release }
+ end
+ roles(*names)
+ end
+
+ def primary(role)
+ env.primary(role)
+ end
+
+ def env
+ Configuration.env
+ end
+
+ def release_timestamp
+ env.timestamp.strftime("%Y%m%d%H%M%S")
+ end
+
+ def asset_timestamp
+ env.timestamp.strftime("%Y%m%d%H%M.%S")
+ end
+
+ end
+ end
+end