@@ -1,12 +0,0 @@
|
||||
# we often want to refer to variables which
|
||||
# are defined in subsequent stage files. This
|
||||
# let's us use the {{var}} to represent fetch(:var)
|
||||
# in strings which are only evaluated at runtime.
|
||||
|
||||
def sub_strings(input_string)
|
||||
output_string = input_string
|
||||
input_string.scan(/{{(\w*)}}/).each do |var|
|
||||
output_string.gsub!("{{#{var[0]}}}", fetch(var[0].to_sym))
|
||||
end
|
||||
output_string
|
||||
end
|
||||
@@ -1,30 +0,0 @@
|
||||
namespace :apache do
|
||||
%w(start stop restart reload).each do |task_name|
|
||||
desc "#{task } Apache"
|
||||
task task_name do
|
||||
on roles(:app), in: :sequence, wait: 5 do
|
||||
sudo "/etc/init.d/apache2 #{task_name}"
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
desc "Enable site virual host"
|
||||
task "enable_virtual_host" do
|
||||
on roles(:app) do
|
||||
"cd /etc/apache2/sites-available/"
|
||||
sudo "a2ensite #{fetch(:server_name)}"
|
||||
end
|
||||
end
|
||||
|
||||
desc "Remove default Apache Virtual Host"
|
||||
task "remove_default_vhost" do
|
||||
on roles(:app) do
|
||||
if test("[ -f /etc/apache2/sites-enabled/000-default.conf ]")
|
||||
sudo "rm /etc/apache2/sites-enabled/000-default.conf"
|
||||
puts "removed default Apache Virtualhost"
|
||||
else
|
||||
puts "No default Apache Virtualhost to remove"
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
@@ -1,12 +0,0 @@
|
||||
namespace :cache do
|
||||
desc "clears the cache in the servers"
|
||||
task :clear do
|
||||
on roles(:app) do |role|
|
||||
within release_path do
|
||||
with rails_env: fetch(:rails_env) do
|
||||
execute :rake, "cache:clear"
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
@@ -1,14 +0,0 @@
|
||||
namespace :deploy do
|
||||
desc "checks whether the currently checkout out revision matches the
|
||||
remote one we're trying to deploy from"
|
||||
task :check_revision do
|
||||
branch = fetch(:branch)
|
||||
unless `git rev-parse HEAD` == `git rev-parse origin/#{branch}`
|
||||
puts "WARNING: HEAD is not the same as origin/#{branch}"
|
||||
puts "Run `git push` to sync changes or make sure you've"
|
||||
puts "checked out the branch: #{branch} as you can only deploy"
|
||||
puts "if you've got the target branch checked out"
|
||||
exit
|
||||
end
|
||||
end
|
||||
end
|
||||
@@ -1,17 +0,0 @@
|
||||
namespace :deploy do
|
||||
desc "compiles assets locally then rsyncs"
|
||||
task :compile_assets_locally do
|
||||
run_locally do
|
||||
execute "RAILS_ENV=#{fetch(:rails_env)} bundle exec rake assets:precompile"
|
||||
end
|
||||
on roles(:app) do |role|
|
||||
run_locally do
|
||||
execute"rsync -av --delete ./public/assets/ #{role.user}@#{role.hostname}:#{release_path}/public/assets/;"
|
||||
end
|
||||
"chmod -R 755 #{release_path}/public/assets/"
|
||||
end
|
||||
run_locally do
|
||||
execute "rm -rf ./public/assets"
|
||||
end
|
||||
end
|
||||
end
|
||||
@@ -1,14 +0,0 @@
|
||||
namespace :logs do
|
||||
task :tail, :file do |t, args|
|
||||
if args[:file]
|
||||
on roles(:app) do
|
||||
execute "tail -f #{shared_path}/log/#{args[:file]}.log"
|
||||
end
|
||||
else
|
||||
puts "please specify a logfile e.g: 'rake logs:tail[logfile]"
|
||||
puts "will tail 'shared_path/log/logfile.log'"
|
||||
puts "remember if you use zsh you'll need to format it as:"
|
||||
puts "rake 'logs:tail[logfile]' (single quotes)"
|
||||
end
|
||||
end
|
||||
end
|
||||
@@ -1,18 +0,0 @@
|
||||
namespace :deploy do
|
||||
desc "Runs test before deploying, can't deploy unless they pass"
|
||||
task :run_tests do
|
||||
test_log = "log/capistrano.test.log"
|
||||
tests = fetch(:tests)
|
||||
tests.each do |test|
|
||||
puts "--> Running tests: '#{test}', please wait ..."
|
||||
unless system "bundle exec rspec #{test} > #{test_log} 2>&1"
|
||||
puts "--> Tests: '#{test}' failed. Results in: #{test_log} and below:"
|
||||
system "cat #{test_log}"
|
||||
exit;
|
||||
end
|
||||
puts "--> '#{test}' passed"
|
||||
end
|
||||
puts "--> All tests passed"
|
||||
system "rm #{test_log}"
|
||||
end
|
||||
end
|
||||
@@ -1,27 +0,0 @@
|
||||
namespace :deploy do
|
||||
task :setup_config do
|
||||
on roles(:app) do
|
||||
# make the config dir
|
||||
execute :mkdir, "-p #{shared_path}/config"
|
||||
full_app_name = fetch(:full_app_name)
|
||||
|
||||
# config files to be uploaded to shared/config, see the
|
||||
# definition of smart_template for details of operation.
|
||||
# Essentially looks for #{filename}.erb in deploy/#{full_app_name}/
|
||||
# and if it isn't there, falls back to deploy/#{shared}. Generally
|
||||
# everything should be in deploy/shared with params which differ
|
||||
# set in the stage files
|
||||
config_files = fetch(:config_files)
|
||||
config_files.each do |file|
|
||||
smart_template file
|
||||
end
|
||||
|
||||
# symlink stuff which should be... symlinked
|
||||
symlinks = fetch(:symlinks)
|
||||
|
||||
symlinks.each do |symlink|
|
||||
sudo "ln -nfs #{shared_path}/config/#{symlink[:source]} #{sub_strings(symlink[:link])}"
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
@@ -1,12 +0,0 @@
|
||||
namespace :deploy do
|
||||
desc "rsyncs local config/secrets.yml file"
|
||||
task :upload_secrets do
|
||||
on roles(:app) do |role|
|
||||
run_locally do
|
||||
execute"rsync -av ./config/secrets.yml #{role.user}@#{role.hostname}:#{shared_path}/config/secrets.yml;"
|
||||
end
|
||||
"chmod -R 755 #{shared_path}/config/secrets.yml"
|
||||
execute "ln -nfs #{shared_path}/config/secrets.yml #{current_path}/config/secrets.yml"
|
||||
end
|
||||
end
|
||||
end
|
||||
@@ -1,32 +0,0 @@
|
||||
# will first try and copy the file:
|
||||
# config/deploy/#{full_app_name}/#{from}.erb
|
||||
# to:
|
||||
# shared/config/to
|
||||
# if the original source path doesn exist then it will
|
||||
# search in:
|
||||
# config/deploy/shared/#{from}.erb
|
||||
# this allows files which are common to all enviros to
|
||||
# come from a single source while allowing specific
|
||||
# ones to be over-ridden
|
||||
# if the target file name is the same as the source then
|
||||
# the second parameter can be left out
|
||||
def smart_template(from, to=nil)
|
||||
to ||= from
|
||||
full_to_path = "#{shared_path}/config/#{to}"
|
||||
if from_erb_path = template_file(from)
|
||||
from_erb = StringIO.new(ERB.new(File.read(from_erb_path)).result(binding))
|
||||
upload! from_erb, full_to_path
|
||||
info "copying: #{from_erb} to: #{full_to_path}"
|
||||
else
|
||||
error "error #{from} not found"
|
||||
end
|
||||
end
|
||||
|
||||
def template_file(name)
|
||||
if File.exist?((file = "config/deploy/#{fetch(:full_app_name)}/#{name}.erb"))
|
||||
return file
|
||||
elsif File.exist?((file = "config/deploy/shared/#{name}.erb"))
|
||||
return file
|
||||
end
|
||||
return nil
|
||||
end
|
||||
@@ -1,4 +1,4 @@
|
||||
class SpendingProposalsImporter
|
||||
class MigrateSpendingProposalsToInvestments
|
||||
|
||||
def import(sp)
|
||||
budget = Budget.last || Budget.create!(name: Date.today.year.to_s, currency_symbol: "€")
|
||||
@@ -1,6 +0,0 @@
|
||||
namespace :cache do
|
||||
desc "Clears memcached"
|
||||
task clear: :environment do
|
||||
Rails.cache.clear
|
||||
end
|
||||
end
|
||||
@@ -1,16 +0,0 @@
|
||||
namespace :comments do
|
||||
|
||||
desc "Recalculates all the comment counters for debates and proposals"
|
||||
task count: :environment do
|
||||
Debate.all.pluck(:id).each{ |id| Debate.reset_counters(id, :comments) }
|
||||
Proposal.all.pluck(:id).each{ |id| Proposal.reset_counters(id, :comments) }
|
||||
end
|
||||
|
||||
desc "Recalculates all the comment confidence scores (used for sorting comments)"
|
||||
task confidence_score: :environment do
|
||||
Comment.with_hidden.find_in_batches do |comments|
|
||||
comments.each(&:save)
|
||||
end
|
||||
end
|
||||
|
||||
end
|
||||
@@ -1,9 +0,0 @@
|
||||
namespace :debates do
|
||||
desc "Updates all debates by recalculating their hot_score"
|
||||
task touch: :environment do
|
||||
Debate.find_in_batches do |debates|
|
||||
debates.each(&:save)
|
||||
end
|
||||
end
|
||||
|
||||
end
|
||||
@@ -1,10 +0,0 @@
|
||||
namespace :proposals do
|
||||
|
||||
desc "Updates all proposals by recalculating their hot_score"
|
||||
task touch: :environment do
|
||||
Proposal.find_in_batches do |proposals|
|
||||
proposals.each(&:save)
|
||||
end
|
||||
end
|
||||
|
||||
end
|
||||
@@ -1,22 +0,0 @@
|
||||
namespace :spending_proposals do
|
||||
|
||||
desc "Sends an email to the authors of unfeasible spending proposals"
|
||||
task send_unfeasible_emails: :environment do
|
||||
SpendingProposal.find_each do |spending_proposal|
|
||||
if spending_proposal.unfeasible_email_pending?
|
||||
spending_proposal.send_unfeasible_email
|
||||
puts "email sent for proposal #{spending_proposal.title}"
|
||||
else
|
||||
puts "this proposal is feasible: #{spending_proposal.title}"
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
desc "Updates all spending proposals to recalculate their tsv and responsible_name columns"
|
||||
task touch: :environment do
|
||||
SpendingProposal.find_in_batches do |spending_proposal|
|
||||
spending_proposal.each(&:save)
|
||||
end
|
||||
end
|
||||
|
||||
end
|
||||
@@ -1,11 +0,0 @@
|
||||
namespace :tags do
|
||||
desc "Recalculates the debate and proposals counters"
|
||||
task custom_count: :environment do
|
||||
ActsAsTaggableOn::Tag.find_in_batches do |tasks|
|
||||
tasks.each do |task|
|
||||
task.recalculate_custom_counter_for('Debate')
|
||||
task.recalculate_custom_counter_for('Proposal')
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
@@ -1,87 +0,0 @@
|
||||
namespace :users do
|
||||
|
||||
desc "Recalculates all the failed census calls counters for users"
|
||||
task count_failed_census_calls: :environment do
|
||||
User.find_each{ |user| User.reset_counters(user.id, :failed_census_calls)}
|
||||
end
|
||||
|
||||
desc "Assigns official level to users with the officials' email domain"
|
||||
task check_for_official_emails: :environment do
|
||||
domain = Setting['email_domain_for_officials']
|
||||
|
||||
# We end the task if there is no email domain configured
|
||||
if !domain.blank?
|
||||
# We filter the mail addresses with SQL to speed up the process
|
||||
# The real check will be done by check_if_official_email, however.
|
||||
User.where('official_level = 0 and email like ?', "%#{domain}").find_each do |user|
|
||||
if user.has_official_email?
|
||||
user.add_official_position! (Setting['official_level_1_name']), 1
|
||||
puts "#{user.username} (#{user.email}) is now a level-1 official."
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
desc "Associates a geozone to each user who doesn't have it already but has validated his residence using the census API"
|
||||
task assign_geozones: :environment do
|
||||
User.residence_verified.where(geozone_id: nil).find_each do |u|
|
||||
begin
|
||||
response = CensusApi.new.call(u.document_type, u.document_number)
|
||||
if response.valid?
|
||||
u.geozone = Geozone.where(census_code: response.district_code).first
|
||||
u.save
|
||||
print "."
|
||||
else
|
||||
print "X"
|
||||
end
|
||||
rescue
|
||||
puts "Could not assign geozone for user: #{u.id}"
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
desc "Associates demographic information to users"
|
||||
task assign_demographic: :environment do
|
||||
User.residence_verified.where(gender: nil).find_each do |u|
|
||||
begin
|
||||
response = CensusApi.new.call(u.document_type, u.document_number)
|
||||
if response.valid?
|
||||
u.gender = response.gender
|
||||
u.date_of_birth = response.date_of_birth.to_datetime
|
||||
u.save
|
||||
print "."
|
||||
else
|
||||
print "X"
|
||||
end
|
||||
rescue
|
||||
puts "Could not assign gender/dob for user: #{u.id}"
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
desc "Makes duplicate username users change their username"
|
||||
task social_network_reset: :environment do
|
||||
duplicated_usernames = User.all.select(:username).group(:username).having('count(username) > 1').pluck(:username)
|
||||
|
||||
duplicated_usernames.each do |username|
|
||||
print "."
|
||||
user_ids = User.where(username: username).order(created_at: :asc).pluck(:id)
|
||||
user_ids_to_review = Identity.where(user_id: user_ids).pluck(:user_id)
|
||||
user_ids_to_review.shift if user_ids.size == user_ids_to_review.size
|
||||
user_ids_to_review.each { |id| User.find(id).update(registering_with_oauth: true) }
|
||||
end
|
||||
end
|
||||
|
||||
desc "Removes identities associated to erased users"
|
||||
task remove_erased_identities: :environment do
|
||||
Identity.joins(:user).where('users.erased_at IS NOT NULL').destroy_all
|
||||
end
|
||||
|
||||
desc "Update password changed at for existing users"
|
||||
task update_password_changed_at: :environment do
|
||||
User.all.each do |user|
|
||||
user.update(password_changed_at: user.created_at)
|
||||
end
|
||||
end
|
||||
|
||||
end
|
||||
Reference in New Issue
Block a user