Module: MosEisley

Defined in:
lib/slack.rb,
lib/logger.rb,
lib/handler.rb,
lib/s3po/s3po.rb,
lib/s3po/blockkit.rb,
lib/mos-eisley-lambda.rb

Defined Under Namespace

Modules: S3PO, SlackEvent, SlackWeb Classes: Handler

Class Method Summary collapse

Class Method Details

.apigw_event(event) ⇒ Object 



49
50
51
52
53
54
55
56
57
58
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
 
# File 'lib/mos-eisley-lambda.rb', line 49

def self.apigw_event(event)
  se = ME::SlackEvent.validate(event)
  unless se[:valid?]
    MosEisley.logger.warn("#{se[:msg]}")
    return {statusCode: 401}
  end
  resp = {statusCode: 200}
  ep = event['routeKey'].split[-1]
  MosEisley.logger.debug("Inbound Slack request to: #{ep}")
  case ep
  when '/actions'
    # Nothing to do, just pass to SQS
  when '/commands'
    ser = {}
    ack = ME::Handler.command_acks[se[:event][:command]]
    if ack
      ser[:response_type] = ack[:response_type]
      ser[:text] =
        if ack[:text]
          ack[:text]
        else
          text = sep[:text].empty? ? '' : " #{se[:event][:text]}"
          "Received: `#{se[:event][:command]}#{text}`"
        end
      # AWS sets status code and headers by passing JSON string
      resp = JSON.fast_generate(ser)
    end
  when '/events'
    # Respond to Slack challenge request
    if se[:event][:type] == 'url_verification'
      c = se[:event][:challenge]
      MosEisley.logger.info("Slack Events API challenge accepted: #{c}")
      return "{\"challenge\": \"#{c}\"}"
    end
  when '/menus'
    # ME::Handler.run(:menu, se)
    # TODO to be implemented
    return "{\"options\": []}"
  else
    MosEisley.logger.warn('Unknown request, ignored.')
    return {statusCode: 400}
  end
  m = {
    queue_url: ENV['MOSEISLEY_SQS_URL'],
    message_attributes: {
      'source' => {
        data_type: 'String',
        string_value: 'slack',
      },
      'destination' => {
        data_type: 'String',
        string_value: 'moseisley',
      },
      'endpoint' => {
        data_type: 'String',
        string_value: ep,
      },
    },
    message_body: "{\"payload\":#{se[:json]}}",
  }
  SQS.send_message(m)
  s = m[:message_body].length
  MosEisley.logger.debug("Sent message to SQS with body size #{s}.")
  return resp
end

.handlers ⇒ Object 



2
3
4
 
# File 'lib/handler.rb', line 2

def self.handlers
  MosEisley::Handler.handlers
end

.lambda_event(event) ⇒ Object 



13
14
15
16
17
18
19
20
21
22
23
24
25
 
# File 'lib/mos-eisley-lambda.rb', line 13

def self.lambda_event(event)
  abort unless preflightcheck
  # Inbound Slack event (via API GW)
  if event['routeKey']
    MosEisley.logger.info('API GW event')
    return apigw_event(event)
  end
  # Internal event (via SQS)
  if event.dig('Records',0,'eventSource') == 'aws:sqs'
    MosEisley.logger.info('SQS event')
    return sqs_event(event)
  end
end

.logger ⇒ Object 



8
9
10
 
# File 'lib/logger.rb', line 8

def self.logger
  @logger ||= Logger.new($stdout, formatter: proc { |s, d, n, m| "#{s} : #{m}\n" })
end

.logger=(logger) ⇒ Object 



4
5
6
 
# File 'lib/logger.rb', line 4

def self.logger=(logger)
  @logger = logger
end

.preflightcheck ⇒ Object 



27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
 
# File 'lib/mos-eisley-lambda.rb', line 27

def self.preflightcheck
  l = ENV['MOSEISLEY_LOG_LEVEL']
  if String === l && ['DEBUG', 'INFO', 'WARN', 'ERROR'].include?(l.upcase)
    MosEisley.logger.level = eval("Logger::#{l.upcase}")
  end
  env_required = [
    'MOSEISLEY_SQS_URL',
    'SLACK_SIGNING_SECRET',
    'SLACK_BOT_ACCESS_TOKEN',
  ]
  env_optional = [
    'MOSEISLEY_LOG_LEVEL',
  ]
  env_required.each do |e|
    if ENV[e].nil?
      MosEisley.logger.error("Missing environment variable: #{e}")
      return false
    end
  end
  return true
end

.sqs_event(event) ⇒ Object 



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
141
142
143
144
 
# File 'lib/mos-eisley-lambda.rb', line 115

def self.sqs_event(event)
  a = event.dig('Records',0,'messageAttributes')
  src = a.dig('source','stringValue')
  dst = a.dig('destination','stringValue')
  ep = a.dig('endpoint','stringValue')
  se = JSON.parse(event.dig('Records',0,'body'), {symbolize_names: true})
  se = se[:payload]
  MosEisley.logger.debug("Event src: #{src}, dst: #{dst}")
  if src == 'slack'
    # Inbound Slack event
    case ep
    when '/actions'
      ME::Handler.run(:action, se)
    when '/commands'
      ME::Handler.run(:command, se)
    when '/events'
      ME::Handler.run(:event, se)
    when '/menus'
      MosEisley.logger.warn('Menu request cannot be processed here.')
    else
      MosEisley.logger.warn("Unknown request: #{ep}")
    end
  elsif dst == 'slack'
    # An event to be sent to Slack
    MosEisley.logger.debug a.dig('api','stringValue')
  else
    MosEisley.logger.warn('Unknown event, ignored.')
  end
  return 0
end