slack-ops-test2-func: post text

lambda_function.py

import os
import json
import logging
from urllib import request, parse

token  = os.environ['TOKEN']
logger = logging.getLogger()
logger.setLevel(logging.INFO)

def lambda_handler(event, context):
  logger.info(str(event))
  if ('challenge' in event):
    return {
      "statusCode": 200,
      "body": json.dumps({'challenge': event['challenge']})
      }
  else: 
    process_event(event['event'])
    return { "statusCode": 200 }

def process_event(event):
  item     = event['item']
  channel  = item['channel']
  ts       = item['ts']
  reaction = event['reaction']
  logger.info('{}, {}, {}, {}'.format(item, channel, ts, reaction))

  text = retrieve_item_text(channel, ts)
  post_result(channel, ts, text)

def retrieve_item_text(channel, ts):
  url    = 'https://slack.com/api/channels.history'
  params = {
    'token':     token,
    'channel':   channel,
    'count':     1,
    'inclusive': True,
    'latest':    ts
  }
  requestUrl = '{}?{}'.format(url, parse.urlencode(params))
  req        = request.Request(requestUrl)

  with request.urlopen(req) as res:
    body = res.read().decode('utf-8')

  return json.loads(body)['messages'][0]['text']

def post_result(channel, thread_ts, text):
  url    = 'https://slack.com/api/chat.postMessage'
  params = {
    'token':     token,
    'channel':   channel,
    'text':      text,
    'thread_ts': thread_ts
  }
  requestUrl = '{}?{}'.format(url, parse.urlencode(params))
  req = request.Request(requestUrl)

  with request.urlopen(req) as response:
    response_body = response.read().decode("utf-8")
  logger.info(str(response_body))