Class: Jets::Resource::ApiGateway::RestApi::Routes::Change::Base

Inherits:
Object
  • Object
show all
Extended by:
Memoist
Includes:
AwsServices
Defined in:
lib/jets/resource/api_gateway/rest_api/routes/change/base.rb

Direct Known Subclasses

MediaTypes, Page, Variable

Class Method Summary collapse

Instance Method Summary collapse

Methods included from AwsServices

#apigateway, #aws_lambda, #aws_options, #cfn, #dynamodb, #logs, #s3, #s3_resource, #sns, #sqs, #sts

Methods included from AwsServices::StackStatus

#lookup, #stack_exists?, #stack_in_progress?

Methods included from AwsServices::GlobalMemoist

included

Class Method Details

.changed? ⇒ Boolean

Returns:

  • (Boolean) 


6
7
8
 
# File 'lib/jets/resource/api_gateway/rest_api/routes/change/base.rb', line 6

def self.changed?
  new.changed?
end

Instance Method Details

#controller_action_from_api(function_arn) ⇒ Object

TODO: If this hits the Lambda Rate limit, then list_functions also contains the Lambda function description. So we can paginate through list_functions results and store description from there if needed. Dont think this will be needed though because controller_action_from_string gets called most of the time. Also, user might be able to request their Lambda limit to be increased.



95
96
97
98
99
100
 
# File 'lib/jets/resource/api_gateway/rest_api/routes/change/base.rb', line 95

def controller_action_from_api(function_arn)
  desc = lambda_function_description(function_arn)
  controller, action = desc.split('#')
  controller = controller.underscore.sub(/_controller$/,'')
  [controller, action]
end

#controller_action_from_string(function_arn) ⇒ Object 



102
103
104
105
106
107
108
109
 
# File 'lib/jets/resource/api_gateway/rest_api/routes/change/base.rb', line 102

def controller_action_from_string(function_arn)
  controller_action = function_arn.sub("#{Jets.project_namespace}-", '')
  md = controller_action.match(/(.*)_controller-(.*)/)
  controller = md[1]
  controller = controller.gsub('-','/')
  action = md[2]
  [controller, action]
end

#deployed_routes ⇒ Object

Build up deployed routes from the existing CloudFormation resources.



11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
 
# File 'lib/jets/resource/api_gateway/rest_api/routes/change/base.rb', line 11

def deployed_routes
  routes = []

  resources, position = [], true
  while position
    position = nil if position == true # start of loop
    resp = apigateway.get_resources(
      rest_api_id: rest_api_id,
      position: position,
      limit: 500, # default: 25 max: 500
    )
    resources += resp.items
    position = resp.position
  end

  resources.each do |resource|
    resource_methods = resource.resource_methods
    next if resource_methods.nil?

    resource_methods.each do |http_verb, resource_method|
      # puts "#{http_verb} #{resource.path} | resource.id #{resource.id}"
      # puts to(resource.id, http_verb)

      # Test changing config.cors and CloudFormation does an in-place update
      # on the resource. So no need to do bluegreen deployments for OPTIONS.
      next if http_verb == "OPTIONS"

      path = recreate_path(resource.path)
      method = http_verb.downcase.to_sym
      to = to(resource.id, http_verb)
      route = Jets::Router::Route.new(path: path, method: method, to: to)
      routes << route
    end
  end
  routes
end

#get_controller_action(function_arn) ⇒ Object 



82
83
84
85
86
87
88
 
# File 'lib/jets/resource/api_gateway/rest_api/routes/change/base.rb', line 82

def get_controller_action(function_arn)
  if function_arn.include?('_controller-')
    controller_action_from_string(function_arn)
  else
    controller_action_from_api(function_arn)
  end
end

#lambda_function_description(function_arn) ⇒ Object 



111
112
113
114
 
# File 'lib/jets/resource/api_gateway/rest_api/routes/change/base.rb', line 111

def lambda_function_description(function_arn)
  resp = aws_lambda.get_function(function_name: function_arn)
  resp.configuration.description # contains full info: PostsController#index
end

#method_uri(resource_id, http_method) ⇒ Object 



60
61
62
63
64
65
66
67
68
 
# File 'lib/jets/resource/api_gateway/rest_api/routes/change/base.rb', line 60

def method_uri(resource_id, http_method)
  # https://docs.aws.amazon.com/apigateway/latest/developerguide/limits.html
  resp = apigateway.get_method(
    rest_api_id: rest_api_id,
    resource_id: resource_id,
    http_method: http_method
  )
  resp.method_integration.uri
end

#new_routes ⇒ Object 



131
132
133
 
# File 'lib/jets/resource/api_gateway/rest_api/routes/change/base.rb', line 131

def new_routes
  Jets::Router.routes
end

#recreate_path(path) ⇒ Object 



49
50
51
52
53
 
# File 'lib/jets/resource/api_gateway/rest_api/routes/change/base.rb', line 49

def recreate_path(path)
  path = path.gsub(%r{^/},'')
  path = path.gsub(/{([^}]*)\+}/, '*\1')
  path.gsub(/{([^}]*)}/, ':\1')
end

#recreate_to(method_uri) ⇒ Object

Parses method uri and recreates a Route to argument. So:

"arn:aws:apigateway:us-west-2:lambda:path/2015-03-31/functions/arn:aws:lambda:us-west-2:112233445566:function:demo-test-posts_controller-new/invocations"

Returns:

posts#new



75
76
77
78
79
80
 
# File 'lib/jets/resource/api_gateway/rest_api/routes/change/base.rb', line 75

def recreate_to(method_uri)
  md = method_uri.match(/function:(.*)\//)
  function_arn = md[1] # IE: demo-dev-posts_controller-new
  controller, action = get_controller_action(function_arn)
  "#{controller}##{action}" # IE: posts#new
end

#rest_api_id ⇒ Object

Duplicated in rest_api/change_detection.rb, base_path/role.rb, rest_api/routes.rb



117
118
119
120
121
122
123
124
125
126
127
128
 
# File 'lib/jets/resource/api_gateway/rest_api/routes/change/base.rb', line 117

def rest_api_id
  stack_name = Jets::Naming.parent_stack_name
  return "RestApi" unless stack_exists?(stack_name)

  stack = cfn.describe_stacks(stack_name: stack_name).stacks.first

  api_gateway_stack_arn = lookup(stack[:outputs], "ApiGateway")

  # resources = cfn.describe_stack_resources(stack_name: api_gateway_stack_arn).stack_resources
  stack = cfn.describe_stacks(stack_name: api_gateway_stack_arn).stacks.first
  lookup(stack[:outputs], "RestApi") # rest_api_id
end

#to(resource_id, http_method) ⇒ Object 



55
56
57
58
 
# File 'lib/jets/resource/api_gateway/rest_api/routes/change/base.rb', line 55

def to(resource_id, http_method)
  uri = method_uri(resource_id, http_method)
  recreate_to(uri) unless uri.nil?
end