routers/webhook.py

import os
import sys
import subprocess
import logging
from fastapi import FastAPI, Request, HTTPException,APIRouter
import requests
import json
from datetime import datetime
import importlib
import pkgutil
from mysite.libs.utilities import validate_signature, no_process_file
#from mysite.database.database import ride,create_ride
from controllers.gra_04_database.rides import test_set_lide
from mysite.interpreter.prompt import prompt_genalate,test_prompt
from mysite.interpreter.google_chat import send_google_chat_card,send_google_chat_card_thread
#from mysite.interpreter.interpreter import chat_with_interpreter
from controllers.gra_02_openInterpreter.OpenInterpreter import chat_with_interpreter_no_stream
from mysite.appsheet.appsheet import get_senario
import asyncio
from promps import prompt_for_create_system,prompt,prompt2
logger = logging.getLogger(__name__)

#router = APIRouter()
router = APIRouter()
#@router.get("/route/webhooks")

@router.post("/webhook")
async def webhook(request: Request):
    #return
    #logger.info("[Start] ====== LINE webhook ======")
    body = await request.body()
    received_headers = dict(request.headers)
    body_str = body.decode("utf-8")
    logger.info("Received Body: %s", body_str)
    body_json = json.loads(body_str)
    events = body_json.get("events", [])

    webhook_url = os.getenv("chat_url")
    token = os.getenv("token")
    ChannelAccessToken = os.getenv('ChannelAccessToken')




    thread_name=""
    #return
    #url = github(token,foldername)
    try:
        DEBUG=0
        for event in events:
            if event["type"] == "message" and event["message"]["type"] == "text":
                user_id = event["source"]["userId"]
                text = event["message"]["text"]
                user_name,thmbnail = get_user_profile(user_id,ChannelAccessToken)

                logger.info("Received Headers: %s", user_name)
                logger.info("Received Headers: %s", thmbnail)

                #logger.info("------------------------------------------")
                first_line = text.split('\n')[0]
                #logger.info(f"User ID: {user_id}, Text: {text}")

                # 査定用のプロンプト
                promps,prompt_res = prompt_genalate("返信は日本語で答えて下さい "+text,prompt2)

                #test_set_lide(text,"a1")
                #no_process_file(text, "ai")
                #\r\m
                #########################################################################
                #user_name,thmbnail#
                title = f""" {user_name}様から下記の質問があります"""
                subtitle = f"""<b>ユーザーID</b> {user_id}\r\n <b>質問内容</b>\r\n {text}"""
                link_text = "\r\n<b>チャットボット設定用シート</b>\r\n シート用のアプリはチャットから\r\n @リファペディア\r\n と打ち込むと開きます"
                link_url = "https://docs.google.com/spreadsheets/d/13pqP-Ywo5eRlZBsYX2m3ChARG38EoIYOowFd3cWij1c/edit?gid=283940886#gid=283940886"
                #test_set_lide(subtitle, text)
                thread_name = send_google_chat_card(webhook_url, title, subtitle, link_text, link_url,thmbnail)
                from command.n8n import post_data
                import time
                n8nurl = os.getenv("n8nhook")
                post_data(n8nurl,text,thread_name)
                time.sleep(10)
                #########################################################################
                title = f""" プロンプト作成 {promps}"""
                subtitle = f"""userid {user_id}\r\n chatid {thread_name}\r\n{prompt_res}"""
                link_text = "データを確認する"
                link_url = "https://kenken999-php.hf.space/diamondprice_list.php"
                #test_set_lide(subtitle, text)
                if DEBUG==0:
                    thread_name = send_google_chat_card_thread(webhook_url, title, subtitle, link_text, link_url,thread_name)
                
                #thread_name = send_google_chat_card_thread(webhook_url, title, subtitle, link_text, link_url,thread_name)
                #return
                #test case
                #########################################################################
                first_line = text.split('\n')[0]
                #test_prompt
                res = test_prompt("返信は必ず日本語でして下さい \r\n"+prompt_res,text)
                if DEBUG==0:
                    thread_name = send_google_chat_card_thread(webhook_url, "プロンプトテスト "+first_line, str(res), link_text, link_url,thread_name)
                #thread_name = send_google_chat_card_thread(webhook_url, title, subtitle, link_text, link_url,thread_name)
                now = datetime.now()
                yyyymmddhis = now.strftime('%Y%m%d%H%M%S')

    
                ######################################################################### 
                ## excute create program
                res_no_process = no_process_file(prompt_for_create_system+res, "gpt_enginner"+ yyyymmddhis,thread_name)
                # execute open interpreter
                #########################################################################
                full_response,history = chat_with_interpreter_no_stream(prompt_for_create_system+"\r\n"+res)
                if DEBUG==1:
                    thread_name = send_google_chat_card_thread(webhook_url, f"自動設定開始 {res}", str(full_response), link_text, link_url,thread_name)
                #########################################################################
                #ダイヤ金額計算
                from babyagi.classesa.diamond import calculate
                title = f""" ダイヤ予測計算の実行 類似５件表示 {text} 
                id,price,carat, cut, color, clarity, depth, diamondprice.table, x, y, z 類似度"""
                res_calculate = calculate(text)
                subtitle = res_calculate
                link_text = "データを確認する"
                link_url = "https://kenken999-php.hf.space/diamondprice_list.php"
                #test_set_lide(subtitle, text)
                if DEBUG==0:
                    thread_name = send_google_chat_card_thread(webhook_url, title, subtitle, link_text, link_url,thread_name)
                #########################################################################
                from babyagi.babyagi import completion
                #import tempfile
                text = text.replace("\r\n","")
                # コマンドを構築
                command = f"""make runbabyagi "{text}に対して、より良いチャットボットでのQAプランデータ設定の提案を日本語で作成してください" {thread_name}"""

                with open('/home/user/app/babyagi/prompt.txt', 'w') as file:
                    file.write(f"""{text}の質問 についてチャットボットでよりよく対応するプランを日本語で作成して""")
                    
                #
                proc = subprocess.Popen(
                    ["make", "runbabyagi", thread_name],
                    stdin=subprocess.PIPE,
                    stdout=subprocess.PIPE,
                    stderr=subprocess.PIPE,
                    text=True,
                )
                #await asyncio.sleep(30) 
                """
                proc = subprocess.Popen(
                    command,
                    stdin=subprocess.PIPE,
                    stdout=subprocess.PIPE,
                    stderr=subprocess.PIPE,
                    text=True,   
                    shell=True
                )
                """


                #prompt_res_agi = completion("日本語で下記のプランを考えて "+res)
                #thread_name = send_google_chat_card_thread(webhook_url, title, prompt_res_agi, link_text, link_url,thread_name)
                #title = f""" タスク作成 再度考える {promps}"""
                #subtitle = prompt_res_agi
                #link_text = "データを確認する"
                #link_url = "https://kenken999-php.hf.space/diamondprice_list.php"
                #thread_name = send_google_chat_card_thread(webhook_url, title, prompt_res_agi, link_text, link_url,thread_name)

                #send_google_chat_card(webhook_url, title, subtitle, link_text, link_url)
                
                #return
                #return 
        #return                   
        """
        for event in events:
            if event["type"] == "message" and event["message"]["type"] == "text":
                user_id = event["source"]["userId"]
                text = event["message"]["text"]
                logger.info(event)
                logger.info(f"User ID: {user_id}, Text: {text}")
                now = datetime.now().strftime("%Y%m%d%H%M%S")
                title = text[:10]
                user_id_with_timestamp = title#f"{now}_{title}_{user_id}"
                no_process_file(text, user_id_with_timestamp)
                #db登録
                test_set_lide(text, user_id_with_timestamp)
        """
        logger.info("Received Headers: %s", received_headers)
        logger.info("Received Body: %s", body.decode("utf-8"))
        ###############################################################################
        #send to appsheet 
        get_senario("user_id",str(body))
        #apps script send
        headers = {
            "Content-Type": "application/json",
        }
        logger.info("Received Body: %s", "send data to appsheet ")
        #response = requests.post(os.getenv("WEBHOOK_URL"), headers=headers, data=body)
        # check signature
        line_signature = received_headers.get("x-line-signature")
        logger.info("Received Body: %s", "start send messages ")
        #headers = {
        #                "Content-Type": "application/json",
        #                "X-Line-Signature": line_signature,
        #                "Authorization": f"Bearer {os.getenv('ChannelAccessToken')}",
        #             }
        #r#esponse = requests.post(os.getenv("WEBHOOK_URL"), headers=headers, data=body)
        if not line_signature:
            raise HTTPException(status_code=400, detail="X-Line-Signature header is missing.")

        if not validate_signature(body.decode("utf-8"), line_signature, os.getenv("ChannelSecret")):
            raise HTTPException(status_code=400, detail="Invalid signature.")

        if not os.getenv("WEBHOOK_URL") or not os.getenv("WEBHOOK_URL").startswith("https://"):
            raise HTTPException(status_code=400, detail="Invalid webhook URL")

        headers = {
            "Content-Type": "application/json",
            "X-Line-Signature": line_signature,
            "Authorization": f"Bearer {os.getenv('ChannelAccessToken')}",
        }

        logger.info("Forwarding to URL: %s", os.getenv("WEBHOOK_URL"))
        logger.info("Forwarding Headers: %s", headers)
        logger.info("Forwarding Body: %s", body.decode("utf-8"))

        #response = requests.post(os.getenv("WEBHOOK_URL"), headers=headers, data=body)
        responses = requests.post(os.getenv("WEBHOOK_GAS"), headers=headers, data=body)
        logger.info("Response Code: %s", response.status_code)
        logger.info("Response Content: %s", response.text)
        logger.info("Response Headers: %s", response.headers)

        return {"status": "success", "response_content": response.text}#, response.status_code

    except Exception as e:
        error_file = os.path.basename(__file__)  # ファイル名を取得
        error_line = sys._getframe(1).f_lineno  # 行番号を取得
        print(f"Error occurred at file {error_file} on line {error_line}: {str(e)}")
        #エラー内容の分析
        promps,res = prompt_genalate(str(e))
        #test_set_lide(text,"a1")
        #no_process_file(text, "ai")
        custormer_supportpage = "\r\n カスタマーサポートはこちらから \r\n https://bpmboxesscom-46463613.hubspotpagebuilder.com/ja \r\n "
        title = f"""エラーが起こりました  -+errer file is {error_file}  error line is {error_line} {str(e)} 自動修復の開始 """
        subtitle = custormer_supportpage+res
        link_text = "test"
        link_url = "url"
        #test_set_lide(subtitle, text)
        logger.error(res)
        #send error to google chat
        send_google_chat_card_thread(webhook_url, title, subtitle, link_text, link_url,thread_name)            
        logger.error("Error: %s", str(e))
        #raise するとシステムとまるのでアンコメント
        #raise HTTPException(status_code=500, detail=str(e))
        return {"status": "success", "response_content": str(e)}#, response.status_code