Class: RollbackAll

Inherits:
Object
  • Object
show all
Defined in:
lib/rollbackall.rb

Overview

Uses project dependency map and configuration to process a DataPlatform Service’s code repository level framework upgrade and service deployments

Constant Summary collapse

VERSION_MAP_FILE = 
'versionmap.json'
MANIFEST_FILE =

todo: remove the up one level path

'manifest.json'

Instance Method Summary collapse

Constructor Details

#initialize(repo_url, branch, manifest_path = MANIFEST_FILE) ⇒ RollbackAll

repo_url is where the last known version map and manifest are checked-in



15
16
17
18
19
20
21
22
 
# File 'lib/rollbackall.rb', line 15

def initialize repo_url, branch, manifest_path = MANIFEST_FILE

  @repo_url = repo_url
  @branch = branch
  @manifest_path = manifest_path

  @manifest = JSON.parse File.read(@manifest_path) if File.exist? @manifest_path
end

Instance Method Details

#Do(input_validator, is_local_run = false) ⇒ Object

Raises:

  • (StandardError) 


59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
 
# File 'lib/rollbackall.rb', line 59

def Do input_validator, is_local_run=false

  puts "\n"
  puts GlobalConstants::UPGRADE_PROGRESS + 'Rollback All has begun..'

  # retrieve version map and upgrade manifest
  puts GlobalConstants::UPGRADE_PROGRESS + 'Retrieving artifacts...'
  retrieve_artifacts

  return false if @remote_version_map.nil? || @manifest.nil?

  puts GlobalConstants::UPGRADE_PROGRESS + 'Ensuring version map exists...'
  version_exists


  # validate manifest
  puts GlobalConstants::UPGRADE_PROGRESS + 'Validating manifest...'
  validation_errors = []
  input_validator.validate_manifest(@manifest) do |error|
    validation_errors << error if !error.nil?
  end
  raise StandardError, validation_error_message(validation_errors) if validation_errors.length > 0

  nuget_targets = []

  # TODO: This validation could probably go in an input validator specifically for rollback
  rollback_config = @manifest['is_rollback'].IsRollback
  rollback = !rollback_config.nil? and rollback_config.downcase == 'y'
  if !rollback
    puts 'IsRollback not set in manifest, aborting rollback.'
    return false
  end
  upgrader = Upgrade.new versions_to_update, rollback

  # if changes exist, cycle through dependency tree and kick off upgrades
  puts GlobalConstants::UPGRADE_PROGRESS + 'Navigating projects...'
  dep_tree = DependencyTree.new(@manifest['projects'])
  dep_tree.traverse do |node|

    if node.metadata.should_upgrade
      puts "#{GlobalConstants::UPGRADE_PROGRESS} Processing project #{node.project_name}..."

      # validate project node
      puts GlobalConstants::UPGRADE_PROGRESS + 'Validating project node...'
      input_validator.validate_project_node(node) do |error|
        validation_errors << error if !error.nil?
      end
      raise StandardError, validation_error_message(validation_errors) if validation_errors.length > 0

      # the upgrade
      puts "#{GlobalConstants::UPGRADE_PROGRESS} Rolling back project #{node.project_name}..."
      upgrade_status = upgrader.Do node, nuget_targets, is_local_run

      # save node name to use for status update
      node_name = node._node_name

      # project status set in json
      if upgrade_status
        puts "#{GlobalConstants::UPGRADE_PROGRESS} Rollback of #{node.project_name} succeeded"
        @manifest['projects'][node_name]['metadata']['status'] = GlobalConstants::SUCCESS
        Dir.chdir GlobalConstants::PARENTDIR
      else
        # either cycle was unterrupted, a step in upgrade failed or full cycle successfully completed
        # save the version map and manifest
        puts "#{GlobalConstants::UPGRADE_PROGRESS} Rollback of #{node.project_name} failed"
        @manifest['projects'][node_name]['metadata']['status'] = GlobalConstants::FAILED
        # no more processing after failure
        return false
      end

    else
      puts "#{GlobalConstants::UPGRADE_PROGRESS} Skipping Rollback for project #{node.project_name}..."
    end
  end

  # upgrade completed successfully, set rollback to 'n' state, update status as unprocessed and save version map and manifest, push
  @manifest['is_rollback'] = 'n'
  reset_status_unprocessed


  true
end

#manifest ⇒ Object 



24
25
26
 
# File 'lib/rollbackall.rb', line 24

def manifest
  @manifest
end

#reset_status_unprocessed ⇒ Object 



147
148
149
150
151
152
153
154
 
# File 'lib/rollbackall.rb', line 147

def reset_status_unprocessed
  @manifest['projects'].each { |proj|
    proj.each { |item|
      item['metadata']['status'] = GlobalConstants::UNPROCESSED if item.class.to_s != 'String'
    }
  }
  @manifest
end

#retrieve_artifacts ⇒ Object 



32
33
34
35
36
37
38
39
40
41
 
# File 'lib/rollbackall.rb', line 32

def retrieve_artifacts

  return if !GithubApi.CheckoutRepoAfresh @repo_url, @branch

  # JSON files converted to hash
  @remote_version_map = JSON.parse File.read(VERSION_MAP_FILE) if File.exist? VERSION_MAP_FILE
  @manifest = JSON.parse File.read(@manifest_path) if File.exist? @manifest_path

  Dir.chdir GlobalConstants::PARENTDIR
end

#save(version_manifest) ⇒ Object 



142
143
144
 
# File 'lib/rollbackall.rb', line 142

def save version_manifest

end

#validation_error_message(validation_errors) ⇒ Object 



156
157
158
 
# File 'lib/rollbackall.rb', line 156

def validation_error_message validation_errors
  "One or more validation errors have occurred: #{validation_errors.join(' ')}"
end

#version_exists ⇒ Object 



43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
 
# File 'lib/rollbackall.rb', line 43

def version_exists

  # create version map afresh to compare
  vm = VersionMap.new
  version_repo_url = @manifest['version_source']['repo_url']
  versions = vm.version_map version_repo_url, @manifest['version_source']['branch']

  # If remote version doesn't exist, save it
  if @remote_version_map.nil?
    File.write VERSIONMAPFILE, versions.to_json
    GithubApi.PushBranch @repo_url, @branch

    return hash
  end
end

#version_map ⇒ Object 



28
29
30
 
# File 'lib/rollbackall.rb', line 28

def version_map
  @remote_version_map
end