from dotenv import load_dotenv
from slack_bolt import App
from slack_bolt.adapter.socket_mode import SocketModeHandler
import os


def environment(env_file_path: str = ".env") -> dict:
    load_dotenv()
    return {
        "SLACK_BOT_TOKEN": os.getenv("SLACK_BOT_TOKEN"),
        "SLACK_APP_TOKEN": os.getenv("SLACK_APP_TOKEN"),
    }


# 토큰 정보
token_infos: dict = environment()

# Install the slack app
app = App(token=token_infos["SLACK_BOT_TOKEN"])


# Add middleware / listeners here
@app.message("안녕")
def say_hello(message, say):
    user = message["user"]
    say(f"Hi there, <@{user}>")


if __name__ == "__main__":
    handler = SocketModeHandler(app, token_infos["SLACK_APP_TOKEN"])
    handler.start()

python main.py

# Add middleware / listeners here
@app.command("/문장제출")
def handle_submit_command(ack, body, client):
    print(body)

@app.command("/문장제출")
def handle_submit_modal(ack, body, client):
    ack()
    client.views_open(
        trigger_id=body["trigger_id"],
        view={
            "type": "modal",
            "callback_id": "submit_view",
            "title": {"type": "plain_text", "text": "제출하기"},
            "submit": {"type": "plain_text", "text": "제출"},
            "close": {"type": "plain_text", "text": "취소"},
            "blocks": [
                {
                    "type": "input",
                    "block_id": "title_block_id",
                    "label": {
                        "type": "plain_text",
                        "text": "책 제목",
                    },
                    "element": {
                        "type": "plain_text_input",
                        "action_id": "input_action_id",
                        "multiline": False,
                        "placeholder": {
                            "type": "plain_text",
                            "text": "책 제목을 입력해주세요",
                        },
                    },
                },
                {
                    "type": "input",
                    "block_id": "sentence_block_id",
                    "label": {
                        "type": "plain_text",
                        "text": "오늘의 문장",
                    },
                    "element": {
                        "type": "plain_text_input",
                        "action_id": "input_action_id",
                        "multiline": True,
                        "placeholder": {
                            "type": "plain_text",
                            "text": "기억에 남는 문장을 입력해주세요.",
                        },
                    },
                },
                {
                    "type": "input",
                    "block_id": "comment_block_id",
                    "label": {
                        "type": "plain_text",
                        "text": "생각 남기기",
                    },
                    "optional": True,
                    "element": {
                        "type": "plain_text_input",
                        "action_id": "input_action_id",
                        "multiline": True,
                        "placeholder": {
                            "type": "plain_text",
                            "text": "생각을 자유롭게 남겨주세요",
                        },
                    },
                },
            ],
        },
    )

@app.view("submit_view")
def handle_view_submit_events(ack, body, logger) -> None:
    print(body)
    ack()

@app.command("/문장제출")
def handle_submit_modal(ack, body, client):
    print(body)
    ack()

@app.command("/문장제출")
def handle_submit_modal(ack, body, client):
    ack()
    client.views_open(
        trigger_id=body["trigger_id"],
        view={
            "type": "modal",
            "callback_id": "submit_view",
            "private_metadata": body["channel_id"],
            ...

@app.view("submit_view")
def handle_view_submit_events(ack, body, logger) -> None:
    channel_id: str = body['view']["private_metadata"]

@app.view("submit_view")
def handle_view_submit_events(ack, body, logger) -> None:
    channel_id: str = body["view"]["private_metadata"]
    target_channel_id: str = "C07TTPD410D"
    
    # 채널 검증
    if channel_id != target_channel_id:
        # 검증 실패 시 에러 메시지 띄우기
        ack(
            response_action="errors",
            errors={"sentence_block_id": "#오늘의 문장 채널에서만 제출할 수 있습니다!"},
        )
        return None
    ack()

@app.view("submit_view")
def handle_view_submit_events(ack, body, logger) -> None:
    channel_id: str = body["view"]["private_metadata"]
    target_channel_id: str = "C07TTPD410D"

    # 채널 검증
    ...

    # 데이터 검증
    sentence :str = body['view']['state']['values']['sentence_block_id']['input_action_id']['value']
    if len(sentence) < 3:
        # 데이터 검증 실패로 인한 에러 메시지 띄우기
        ack(
            response_action="errors",
            errors={"sentence_block_id": "#오늘의 문장은 세 글자 이상 입력하여야 합니다!"},
        )
        return None
    ack()

@app.view("submit_view")
def handle_view_submit_events(ack, body, client) -> None:
    channel_id: str = body["view"]["private_metadata"]
    target_channel_id: str = "C07TTPD410D"

    # 채널 검증
    ...
    # 데이터 검증
    ...

    # 저장 데이터용 사전변수 정의
    data_dict: dict = dict()

    # 저장할 데이터
    # 멤버 이름: 한글 이름을 가져오려면 유저 정보를 따로 불러와야 함.
    # user 인자의 값으로는 body에 user.id 값을 가져와야 함.
    user_id = body['user']['id']
    user_info = client.users_info(user=user_id)
    user_name :str = user_info['user']['real_name']

    # 책 제목
    book_title :str = body['view']['state']['values']['title_block_id']['input_action_id']['value']

    # 오늘의 문장: 3글자 검증할 때 위에서 추출했으므로 pass

    # 생각 의견
    comment :str = body['view']['state']['values']['comment_block_id']['input_action_id']['value']

    # 생성일시(제출일시)
    from datetime import datetime
    created_at :str = datetime.now().strftime('%Y-%m-%d %H:%M:%S')

    # 데이터 삽입
    data_dict["user_id"] = user_id
    data_dict["userName"] = user_name
    data_dict["bookTitle"] = book_title
    data_dict["comment"] = comment
    data_dict["createdAt"] = created_at
    ack()    

def create_dir(dir_name: str) -> None:
    """폴더 생성 함수"""
    if not os.path.exists(dir_name):
        os.makedirs(dir_name)

def save_data_to_csv(dir_name: str, data: dict) -> None:
    """데이터를 CSV로 저장하는 함수"""
    file_name: str = os.path.join(dir_name, "contents.csv")
    with open(file_name, "a", newline="", encoding='utf-8') as csvfile:
        writer = csv.writer(csvfile=csvfile)

        if not os.path.getsize(file_name) > 0:
            writer.writerow(
                ["user_id", "user_name", "book_title", "sentence", "comment", "created_at"]
            )

        writer.writerow(
            [
                data["user_id"],
                data["user_name"],
                data["book_title"],
                data["sentence"],
                data["comment"],
                data["created_at"],
            ]
        )

@app.view("submit_view")
def handle_view_submit_events(ack, body, client) -> None:
    channel_id: str = body["view"]["private_metadata"]
    target_channel_id: str = "C07TTPD410D"

    # 채널 검증
    ...
    # 데이터 검증
    ...
    # 데이터 삽입
    ...

    # 데이터 저장용 폴더 생성
    dir_name: str = "data"
    create_dir(dir_name=dir_name)

    # 데이터 저장
    save_data_to_csv(dir_name=dir_name, data=data_dict)        
    ack()

@app.view("submit_view")
def handle_view_submit_events(ack, body, client) -> None:
    channel_id: str = body["view"]["private_metadata"]
    target_channel_id: str = "C07TTPD410D"

    # 채널 검증
    ...
    
    # 데이터 검증 
    ...

    # 데이터 삽입
    ...

    # 데이터 저장
    ...

    # 완료 메시지 가공 
    text :str = f">>> *<@{user_id}>님이 `{book_title}`에서 뽑은 오늘의 문장*\n\n'{sentence}'\n"
    
    if comment:
        text += f"\n✍️ {comment}\n"
    # 완료 메시지 전송: channel_id 변수의 경우 '채널 검증' 에서 이미 구했었음
    client.chat_postMessage(channel=channel_id, text=text)

    ack()

@app.command("/제출내역")
def handle_submission_history_command(ack, body, client) -> None:
    ack()

@app.command("/제출내역")
def handle_submission_history_command(ack, body, client) -> None:
    ack()
    # 사용자의 DM 채널 ID 가져오기
    response :dict = client.conversations_open(users=body['user_id'])
    dm_channel_id :str = response['channel']['id']

@app.command("/제출내역")
def handle_submission_history_command(ack, body, client) -> None:
    ack()
    # 사용자의 DM 채널 ID 가져오기
    user_id :str = body['user_id']
    response :dict = client.conversations_open(users=user_id)
    dm_channel_id :str = response['channel']['id']

    # 제출내역 파일이 없는 경우 제출내역이 없다고 메시지 전송하고 종료
    if not os.path.exists("data/contents.csv"):
        client.chat_postMessage(channel=dm_channel_id, text=f"제출내역이 없습니다.")
        return

    # 사용자의 제출내역만 필터링
    submission_list :list[dict] = []
    with open("data/contents.csv", 'r', encoding='utf-8') as csvfile:
        reader = csv.DictReader(csvfile)
        fieldnames = reader.fieldnames
        for row in reader:
            if row["user_id"] == user_id:
                submission_list.append(row)

    # 제출내역이 없다면 제출내역이 없다고 메시지 전송하고 종료
    if not submission_list:
        client.chat_postMessage(channel=dm_channel_id, text=f"제출내역이 없습니다.")
        return

@app.command("/제출내역")
def handle_submission_history_command(ack, body, client) -> None:
    ack()
    # 사용자의 DM 채널 ID 가져오기
    ...

    # 제출내역 파일이 없는 경우 제출내역이 없다고 메시지 전송하고 종료
    ...

    # 사용자의 제출내역만 필터링
    ...

    # 제출내역이 없다면 제출내역이 없다고 메시지 전송하고 종료
    ...

    # 사용자의 제출내역을 CSV 파일로 임시 저장 후 전송
    temp_dir :str = "data/temp"
    if not os.path.exists(temp_dir):
        os.mkdir(temp_dir)
    temp_file_path :str = os.path.join(temp_dir,f"{user_id}.csv")
    with open(temp_file_path, 'w', newline='', encoding='utf-8') as csvfile:
        writer = csv.DictWriter(csvfile, fieldnames)
        writer.writeheader()
        writer.writerows(submission_list)

@app.command("/제출내역")
def handle_submission_history_command(ack, body, client) -> None:
    ack()
    # 사용자의 DM 채널 ID 가져오기
    ...

    # 제출내역 파일이 없는 경우 제출내역이 없다고 메시지 전송하고 종료
    ...

    # 사용자의 제출내역만 필터링
    ...

    # 제출내역이 없다면 제출내역이 없다고 메시지 전송하고 종료
    ...

    # 사용자의 제출내역을 CSV 파일로 임시 저장 후 전송
    ...

    # 제출내역 파일 전송
    client.files_upload_v2(channel=dm_channel_id, file=temp_file_path, initial_comment = f"<*{user_id}> 님의 제출내역 입니다!")

@app.command("/제출내역")
def handle_submission_history_command(ack, body, client) -> None:
    ack()
    # 사용자의 DM 채널 ID 가져오기
    ...

    # 제출내역 파일이 없는 경우 제출내역이 없다고 메시지 전송하고 종료
    ...

    # 사용자의 제출내역만 필터링
    ...

    # 제출내역이 없다면 제출내역이 없다고 메시지 전송하고 종료
    ...

    # 사용자의 제출내역을 CSV 파일로 임시 저장 후 전송
    ...

    # 제출내역 파일 전송
    ...

    # 임시로 생성한 csv 파일 삭제
    os.remove(temp_file_path)

@app.command("/관리자")
def handle_admin_command(ack, body, client: WebClient) -> None:
    ack()

@app.command("/관리자")
def handle_admin_command(ack, body, client: WebClient) -> None:
    ack()

    # 관리자 검증: 관리자인지 확인 후 아니라면 메시지 전송 후 종료
    user_id: str = body["user_id"]
    user_infos: dict = client.users_info(user=user_id)
    is_admin: bool = user_infos["user"]["is_admin"]
    if is_admin is not True:
        # 메시지 전송: 자기자신에게만 보이는 메시지
        client.chat_postEphemeral(
            channel=body["channel_id"],
            user=user_id,
            text="관리자만 사용 가능한 명령어입니다.",
        )
        return

@app.command("/관리자")
def handle_admin_command(ack, body, client: WebClient) -> None:
    ack()

    # 관리자 검증: 관리자인지 확인 후 아니라면 메시지 전송 후 종료
    ...

    # 관리자용 메뉴 버튼 생성
    client.chat_postEphemeral(
        channel=body['channel_id'],
        user=user_id,
        text="관리자 메뉴를 선택해주세요.",
        blocks=[ 
            {
                "type": "actions",
                "elements": [
                    {
                        "type": "button",
                        "text": {
                            "type": "plain_text",
                            "text": "전체 제출내역 조회",
                            "emoji": True
                        },
                        "value": "admin_value_1",
                        "action_id": "fetch_all_submissions" # 액션 함수명으로 변경해줘야함.
                    }
                ]
            }

        ]
    )

@app.action("fetch_all_submissions")
def handle_some_action(ack, body, client: WebClient) -> None:
    ack()

@app.action("fetch_all_submissions")
def handle_some_action(ack, body, client: WebClient) -> None:
    ack()

    user_id :str = body['user']['id']

    # 관리자의 DM 채널 ID 가져오기
    response = client.conversations_open(users=user_id)
    dm_channel_id :str = response['channel']['id']

    # 전체 제출내역 불러와서 전송
    file_path :str = "data/contents.csv"
    if not os.path.exists(file_path):
        client.chat_postMessage(channel=dm_channel_id, text="제출내역이 없습니다")
        return
        
    client.files_upload_v2(
        channel=dm_channel_id,
        file=file_path,
        initial_comment="전체 제출내역 입니다."
    )

@app.command("/제출내역")
def handle_submission_history_command(ack, body, client) -> None:
    ack()
    print(type(client))

<class 'slack_sdk.web.client.WebClient'>

from slack_sdk import WebClient

@app.command("/제출내역")
def handle_submission_history_command(ack, body, client: WebClient) -> None:
    ack()