Class: Rockette::Commands::Deploy

Inherits:
Rockette::Command show all
Includes:
TextHelper
Defined in:
lib/rockette/commands/deploy.rb

Overview

Push export file and import into APEX

Instance Method Summary collapse

Methods included from TextHelper

#bail, #check_input, #file_not_found, #no_rockette_dir, #padder

Methods inherited from Rockette::Command

#command, #cursor, #editor, #exec_exist?, #generator, #pager, #platform, #prompt, #screen, #which

Constructor Details

#initialize(options) ⇒ Deploy

Returns a new instance of Deploy.



11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
# File 'lib/rockette/commands/deploy.rb', line 11

def initialize(options)
  super()
  @options = options
  @filey = @options[:file]
  if @options[:secret]
    secret_id = @options[:secret]
    signer = OCI::Auth::Signers::InstancePrincipalsSecurityTokenSigner.new
    identity_client = OCI::Identity::IdentityClient.new(config: OCI::Config.new, signer: signer)
    secret_client = OCI::Secrets::SecretsClient.new(config: OCI::Config.new, signer: signer)
    secret_response = secret_client.get_secret_bundle(secret_id).data.secret_bundle_content.content
    @conf = Psych.load(Base64.decode64(secret_response))
  else
    @conf = Psych.load(File.read(CONF))
  end
  @body = @conf["token_body"]
  @hdrs = @conf["token_hdrs"]
  @hdrs["Authorization"] = @conf["web_creds"][@options[:cred]] if @options[:cred]
  @token = get_token
  @hdrs["Authorization"] = "Bearer " + @token
end

Instance Method Details

#check_version(filey) ⇒ Object 



32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
 
# File 'lib/rockette/commands/deploy.rb', line 32

def check_version(filey)
  app_url = "#{@options[:url]}deploy/apps/#{@options[:app_id]}"
  response = Rester.new(url: app_url, headers: @hdrs).rest_try
  bail unless response
  abort padder("App ID: #{@options[:app_id]}, not found. Received: #{response.code}") unless response.code == 200
  deployed_version = JSON.parse(response.body)["version"]
  fh = File.open(filey, 'r')
  export_version = ''
  fh.each_line do |line|
    if line.match(/,p_flow_version=>'/)
      export_version = line.match(/^,p_flow_version=>'(.*?)'$/)[1]
    end
  end
  return deployed_version == export_version
end

#deployer ⇒ Object 



61
62
63
64
65
66
67
68
69
70
71
72
73
 
# File 'lib/rockette/commands/deploy.rb', line 61

def deployer
  push_url = "#{@options[:url]}deploy/app/#{@options[:app_id]}/"
  filey = file_finder
  file_not_found if filey.is_a?(Array)
  if @options[:app_id] != '0' then
    abort padder("Error. Versions are identical, unable to deploy export") if check_version(filey)
  end
  @hdrs["Content-Type"] = "application/sql"
  response = Rester.new(headers: @hdrs, meth: "Post", params: File.open(filey), url: push_url).rest_try
  bail unless response
  abort padder("Error. Got back response code: #{response.code}") unless (200..201).include? response.code
  response
end

#execute(input: $stdin, output: $stdout) ⇒ Object 



75
76
77
78
79
80
81
82
 
# File 'lib/rockette/commands/deploy.rb', line 75

def execute(input: $stdin, output: $stdout)
  check_input(input)
  filey = file_finder
  file_not_found if filey.is_a?(Array)
  output.puts padder("Attempting to deploy export file #{@filey}...")
  deployer
  output.puts padder("Deployed #{@filey} to target APEX instance: #{@options[:url]}")
end

#file_finder ⇒ Object 



48
49
50
51
52
53
 
# File 'lib/rockette/commands/deploy.rb', line 48

def file_finder
  [EXPORT_DIR, "/usr/app", "/usr/local/app"].each do |f|
    next unless File.exist?(File.join(f, @filey))
    break File.join(f, @filey) if File.exist?(File.join(f, @filey)) # Take 1st match
  end
end

#get_token ⇒ Object 



55
56
57
58
59
 
# File 'lib/rockette/commands/deploy.rb', line 55

def get_token
  token_url = "#{@options[:url]}oauth/token"
  response = Rester.new(headers: @hdrs, meth: "Post", params: @body, url: token_url).rest_try
  return JSON.parse(response.body)["access_token"]
end