Spaces:
Running
on
Zero
Running
on
Zero
File size: 12,397 Bytes
8f10d41 bbadfe5 e93696c bbadfe5 ed4d135 46ee887 3252bdf d93baed bbadfe5 8f10d41 fe2a1e9 8f10d41 1f11950 8f10d41 d93baed 8f10d41 1f11950 8f10d41 1f11950 8f10d41 ed4d135 8f10d41 d93baed 2368dfd d93baed 2368dfd 67771bf 428a530 d93baed 2368dfd 8f10d41 1c4b4f2 8f10d41 46ee887 8f10d41 1f11950 09731f9 46ee887 8f10d41 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 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 114 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 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 |
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 prompts.promps import prompt_for_create_system,prompt,get_prompt
from command.line_get_user_profile import get_user_profile
from command.n8n import post_data,post_data_line
import time
logger = logging.getLogger(__name__)
#router = APIRouter()
router = APIRouter()
#@router.get("/route/webhooks")
@router.post("/webhook")
async def webhook(request: Request):
DEBUG=0
#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')
n8nurl = os.getenv("n8nhook")
thread_name=""
#return
#url = github(token,foldername)
try:
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,get_prompt(text))
#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)
#########################################################################
### n8n WorkFlowStart
#########################################################################
line_signature = received_headers.get("x-line-signature")
#for debug
headers = {
"Content-Type": "application/json",
"X-Line-Signature": line_signature,
"Authorization": f"Bearer {os.getenv('ChannelAccessToken')}",
}
#/webhook-test/d2d0af6e-5c42-45b6-a923-3bd2d8520e3f
#post_data_line("https://kenken999-nodex-n8n.hf.space/webhook-test/d2d0af6e-5c42-45b6-a923-3bd2d8520e3d",body,headers)
post_data_line("https://kenken999-nodex-n8n.hf.space/webhook/d2d0af6e-5c42-45b6-a923-3bd2d8520e3d",body,headers)
#return
post_data(n8nurl,text,thread_name,headers)
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}の質問 についてチャットボットでよりよく対応するプランを日本語で作成して""")
######################################################################
if DEBUG==1:
proc = subprocess.Popen(
["make", "runbabyagi", thread_name],
stdin=subprocess.PIPE,
stdout=subprocess.PIPE,
stderr=subprocess.PIPE,
text=True,
)
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
|