test_capture

listener type	引数	どんな時に使う?
@app.message(pattern)	message, say	メッセージ投稿を扱う
@app.event(eventType,)	event, client	イベント全般を扱う(eventTypeを指定）
@app.event(‘message’)	body, say, logger	eventに’message’を指定すると@app.message()と同等。 subtypeを指定可能
@app.event(‘app_home_opened’)	client, event, logger	調査中
@app.action(callback_id \| block_id \| action_id)	body, client, ack	ack()を返す必要がある。
@app.action(‘approve_button’)	ack, say	調査中
@app.view(view_submission)	ack, body, client, view, logger	調査中
@app.shortcut(trigger_id)	shortcut, ack, client	global shortcutsとmessage shortcutsに対応しているらしい。調査中
@app.command(commandName)	command, ack, say	commandNameの正規表現で複数の@app.command()にマッチした場合、全てが実行される
@app.command(‘/ticket’)	ack, body, client	調査中（Using modals in Slack apps）
@app.options()	ack	調査中
@app.error()	error, body, logger	調査中


#!/usr/bin/env python3
# -*- coding: utf-8 -*-

# =======================================================
#  slack_boltでpythonからslackにキャプチャ画像を返信
#
#  test_capture_bot_concurrent.py
#  coded by Noboru Harada (noboru@ieee.org)
#
#  Changes:
#  2021/07/11: First version
#  2021/07/15: Added concurrent.future for multiple process
# =======================================================

#https://note.com/npaka/n/neb7147a2a9df
#https://rightcode.co.jp/blog/information-technology/python-asynchronous-program-multithread-does-not-work-approach

import concurrent.futures
import time
import re
import datetime
import sys
import os
import subprocess
import json
from collections import OrderedDict
import cv2
import logging
import os
from slack_sdk import WebClient
from slack_sdk.errors import SlackApiError
from slack_bolt import App
from slack_bolt.adapter.socket_mode import SocketModeHandler

global device_id

def check_camera_devices():
    ###############################################
    #  Check camera devices
    ###############################################

    # Get path for the swift script (supporse to be in the same location with this python script)
    script_path = os.path.dirname(os.path.abspath(__file__))
    script_path = "swift " + script_path + "/avfcam_list.swift"
    print(script_path)

    # Check camera devices with a swift script
    camera_devices = subprocess.check_output(script_path, shell=True)
    json_dict = json.loads(camera_devices, object_pairs_hook=OrderedDict)

    camera_devices = camera_devices.decode("utf-8")
    print(camera_devices)

    if json_dict.get('SPCameraDataType') == None:
        print("No camera device found")
        sys.exit()
     
    num_devices = len(json_dict['SPCameraDataType'])
    if num_devices == 0:
        print("No camera device found")
        sys.exit()

    val = 0
    if num_devices > 1:
        print("Select a camera devie:")
        for s in range(num_devices):
            name = json_dict['SPCameraDataType'][s].get("_name")
            print(" %d: %s" % (s, name))
        try:
            val = int(input())
        except ValueError:
            print("Wrong device id")
            val = 0

    if val > num_devices-1 or val < 0:
        print("Wrong device id")
        val = 0

    device_id = val
    device_name = json_dict['SPCameraDataType'][device_id].get("_name")
    print(" Use Camera device %d: %s" % (val, device_name))
    return device_id

###############################################
# init Socket Mode client settings
###############################################

client = WebClient(token=os.environ["SLACK_BOT_TOKEN"])

logging.basicConfig(level=logging.DEBUG)
logger = logging.getLogger(__name__)

app = App(token=os.environ["SLACK_BOT_TOKEN"])

###############################################
# event handler functions
###############################################
# show video image in thread
def show_image(device_id):
    cap = cv2.VideoCapture(device_id)
    cv2.namedWindow('Type [q] to quit capturing')
    #print("video_thread.start()")
    while True:
        # Capture frame-by-frame
        ret, frame1 = cap.read()

        # show the frame
        cv2.imshow('Type [q] to quit capturing', frame1)

        key = cv2.waitKey(1) & 0xFF
        if key == ord('q'):
            break
    cap.release()
    return device_id

# get time string
def get_time():
       return (datetime.datetime.now())

# respond mentions to this bot
@app.event("app_mention")
def handle_mention_events(body, say, logger):
    print("### BODY ### -----------------------------------")
    print(body)
    print("### SAY ### -----------------------------------")
    print(say)
    print("### LOGGER ### -----------------------------------")
    print(logger)
    print("### Send say ### -----------------------------------")
    say(f"In 'app_mention'\nこんにちは <@{body['event']['user']}> さん！")
    print("### end handler ### -----------------------------------")

# check if the text matches with "shot"/"SHOT"/"Shot"
@app.message(re.compile("([Ss][Hh][Oo][Tt])"))
def handle_messge(message, say):
    cap = cv2.VideoCapture(device_id)
    ret, frame = cap.read()
    filename = get_time().strftime('./Screen Shot %Y-%m-%d at %H.%M.%S.jpg')
    cv2.imwrite(filename,frame)
    cap.release()
    print(" Sent screen shot ***********************")
    try:
        # Call the files.upload method using the WebClient
        # Uploading files requires the 'files:write' scope
        result = client.files_upload(
            channels=message['channel'],
            initial_comment=filename,
            file=filename
        )
        logger.info(result)
        print(" Sent screen shot ***********************")

    except SlackApiError as e:
        logger.error("Error uploading file: {}".format(e))
    print("### MESSAGE ### -----------------------------------")
    print(message)
    print("### SAY ### -----------------------------------")
    print(say)
    print("### Send say ### -----------------------------------")
    say(f"In 'shot' こんにちは <@{message['user']}> さん！")
    print("### end handler ### -----------------------------------")

# check if the text matchs with "help"
@app.message("help")
def handle_help(message, say):
    print("### MESSAGE ### -----------------------------------")
    print(message)
    print("### SAY ### -----------------------------------")
    print(say)
    print("### Send say ### -----------------------------------")
    say(f"In 'help' こんにちは <@{message['user']}> さん！\nこれはhelpです。")
    print("### end handler ### -----------------------------------")

# deafault handler for 'message' event
@app.event("message")
def handle_messge_events(body, say, logger):
    print("### BODY ### -----------------------------------")
    print(body)
    print("### SAY ### -----------------------------------")
    print(say)
    print("### LOGGER ### -----------------------------------")
    print(logger)
    print("### Send say ### -----------------------------------")
    say(f"In 'message'\nこんにちは <@{body['event']['user']}> さん！")
    print("### end handler ### -----------------------------------")


if __name__ == "__main__":

    ##################
    # Working example
    ##################
    device_id = check_camera_devices()
    executor = concurrent.futures.ProcessPoolExecutor()
    future = executor.submit(show_image, device_id)
    print("===== SocketModelHandler =====")
    handler = SocketModeHandler(app, os.environ["SLACK_APP_TOKEN"])
    handler.start()
 
    # terminate resources
    cv2.destroyAllWindows()

定時にビデオキャプチャして画像を投稿するSlack botの作成(2021.7.11, 2021.7.15追記)

動作仕様

定時にslackにメッセージイベントを送信するには/remindを使う

Appの新規作成と設定

channelへのAppの追加

App-Level Tokensの生成

mentionのためのUser ID情報取得方法

Pythonの設定

Requirements

openvcを用いたビデオキャプチャ

Workspaceに常駐しイベントに反応するslack_bolt bot

使いたい必要なエッセンスだけに限定して書いた基本的なコードは下記のようになる。

boltが扱うイベントは以下のようになっているらしい（調査中）

slack_sdkを使ってSlack channelにファイルをアップロードする

【2021.7.15追記】concurrent.futuresでマルチプロセスを実現

参照

Slack appで定期的にタスクを実行する方法

Slack API　(Socket Mode API)

単にメッセージを送信するだけならこちらが簡単

opencvを用いたビデオキャプチャ

課題（boltとopenCVをマルチスレッド対応にできていない）

Back to Index

定時にビデオキャプチャして画像を投稿するSlack botの作成(2021.7.11, 2021.7.15追記)

動作仕様

定時にslackにメッセージイベントを送信するには/remindを使う

Appの新規作成と設定

channelへのAppの追加

App-Level Tokensの生成

mentionのためのUser ID情報取得方法

Pythonの設定

Requirements

openvcを用いたビデオキャプチャ

Workspaceに常駐しイベントに反応するslack_bolt bot

使いたい必要なエッセンスだけに限定して書いた基本的なコードは下記のようになる。

boltが扱うイベントは以下のようになっているらしい（調査中）

slack_sdkを使ってSlack channelにファイルをアップロードする

【2021.7.15追記】concurrent.futuresでマルチプロセスを実現

参照

Slack appで定期的にタスクを実行する方法

Slack API (Socket Mode API)

単にメッセージを送信するだけならこちらが簡単

opencvを用いたビデオキャプチャ

課題（boltとopenCVをマルチスレッド対応にできていない）

Back to Index

Slack API　(Socket Mode API)