Add chainlit jp

.chainlit/translations/ja.json

@@ -0,0 +1,230 @@
+{
+    "components": {
+        "atoms": {
+            "buttons": {
+                "userButton": {
+                    "menu": {
+                        "settings": "設定",
+                        "settingsKey": "S",
+                        "APIKeys": "APIキー",
+                        "logout": "ログアウト"
+                    }
+                }
+            }
+        },
+        "molecules": {
+            "newChatButton": {
+                "newChat": "新しいチャット"
+            },
+            "tasklist": {
+                "TaskList": {
+                    "title": "\ud83d\uddd2\ufe0f タスクリスト",
+                    "loading": "読み込み中...",
+                    "error": "エラーが発生しました"
+                }
+            },
+            "attachments": {
+                "cancelUpload": "アップロードをキャンセル",
+                "removeAttachment": "添付ファイルを削除"
+            },
+            "newChatDialog": {
+                "createNewChat": "新しいチャットを作成しますか？",
+                "clearChat": "現在のメッセージをクリアして新しいチャットを開始します。",
+                "cancel": "キャンセル",
+                "confirm": "確認"
+            },
+            "settingsModal": {
+                "settings": "設定",
+                "expandMessages": "メッセージを展開する",
+                "hideChainOfThought": "思考の連鎖を隠す",
+                "darkMode": "ダークモード"
+            },
+            "detailsButton": {
+                "using": "処理中",
+                "used": ""
+            },
+            "auth": {
+                "authLogin": {
+                    "title": "アプリにアクセスするにはログインしてください。",
+                    "form": {
+                        "email": "メールアドレス",
+                        "password": "パスワード",
+                        "noAccount": "アカウントを持っていませんか？",
+                        "alreadyHaveAccount": "すでにアカウントをお持ちですか？",
+                        "signup": "サインアップ",
+                        "signin": "サインイン",
+                        "or": "または",
+                        "continue": "ログイン",
+                        "forgotPassword": "パスワードをお忘れですか？",
+                        "passwordMustContain": "パスワードには以下が含まれている必要があります：",
+                        "emailRequired": "メールアドレスは必須項目です",
+                        "passwordRequired": "パスワードは必須項目です"
+                    },
+                    "error": {
+                        "default": "サインインできません。",
+                        "signin": "異なるアカウントでサインインしてみてください。",
+                        "oauthsignin": "異なるアカウントでサインインしてみてください。",
+                        "redirect_uri_mismatch": "リダイレクトURIがOAuthアプリの設定と一致していません。",
+                        "oauthcallbackerror": "異なるアカウントでサインインしてみてください。",
+                        "oauthcreateaccount": "異なるアカウントでサインインしてみてください。",
+                        "emailcreateaccount": "異なるアカウントでサインインしてみてください。",
+                        "callback": "異なるアカウントでサインインしてみてください。",
+                        "oauthaccountnotlinked": "本人確認のため、元々使用していたアカウントでサインインしてください。",
+                        "emailsignin": "メールの送信に失敗しました。",
+                        "emailverify": "メールアドレスを確認してください。新しいメールが送信されました。",
+                        "credentialssignin": "サインインに失敗しました。提供した情報が正しいか確認してください。",
+                        "sessionrequired": "このページにアクセスするにはサインインしてください。"
+                    }
+                },
+                "authVerifyEmail": {
+                    "almostThere": "もう少しです！メールを送信しました：",
+                    "verifyEmailLink": "メール内のリンクをクリックしてサインアップを完了してください。",
+                    "didNotReceive": "メールが見つかりませんか？",
+                    "resendEmail": "メールを再送信",
+                    "goBack": "戻る",
+                    "emailSent": "メールが正常に送信されました。",
+                    "verifyEmail": "メールアドレスを確認してください"
+                },
+                "providerButton": {
+                    "continue": "{{provider}}で続行",
+                    "signup": "{{provider}}でサインアップ"
+                },
+                "authResetPassword": {
+                    "newPasswordRequired": "新しいパスワードは必須項目です",
+                    "passwordsMustMatch": "パスワードが一致しません",
+                    "confirmPasswordRequired": "確認用パスワードは必須項目です",
+                    "newPassword": "新しいパスワード",
+                    "confirmPassword": "確認用パスワード",
+                    "resetPassword": "パスワードをリセット"
+                },
+                "authForgotPassword": {
+                    "email": "メールアドレス",
+                    "emailRequired": "メールアドレスは必須項目です",
+                    "emailSent": "{{email}}宛にパスワードをリセットするための手順が記載されたメールを確認してください。",
+                    "enterEmail": "メールアドレスを入力してください。パスワードをリセットする手順をお送りします。",
+                    "resendEmail": "メールを再送信",
+                    "continue": "続行",
+                    "goBack": "戻る"
+                }
+            }
+        },
+        "organisms": {
+            "chat": {
+                "history": {
+                    "index": {
+                        "showHistory": "履歴を表示",
+                        "lastInputs": "最後の入力",
+                        "noInputs": "データがありません...",
+                        "loading": "読み込み中..."
+                    }
+                },
+                "inputBox": {
+                    "input": {
+                        "placeholder": "ここにメッセージを入力..."
+                    },
+                    "speechButton": {
+                        "start": "録音を開始",
+                        "stop": "録音を停止"
+                    },
+                    "SubmitButton": {
+                        "sendMessage": "メッセージを送信",
+                        "stopTask": "タスクを停止"
+                    },
+                    "UploadButton": {
+                        "attachFiles": "ファイルを添付"
+                    },
+                    "waterMark": {
+                        "text": "Built with"
+                    }
+                },
+                "Messages": {
+                    "index": {
+                        "running": "実行中",
+                        "executedSuccessfully": "正常に実行されました",
+                        "failed": "失敗",
+                        "feedbackUpdated": "フィードバックが更新されました",
+                        "updating": "更新中"
+                    }
+                },
+                "dropScreen": {
+                    "dropYourFilesHere": "ここにファイルをドロップしてください"
+                },
+                "index": {
+                    "failedToUpload": "アップロードに失敗しました",
+                    "cancelledUploadOf": "次のファイルのアップロードをキャンセルしました：",
+                    "couldNotReachServer": "サーバーに接続できませんでした",
+                    "continuingChat": "前回のチャットを続ける"
+                },
+                "settings": {
+                    "settingsPanel": "設定パネル",
+                    "reset": "リセット",
+                    "cancel": "キャンセル",
+                    "confirm": "確認"
+                }
+            },
+            "threadHistory": {
+                "sidebar": {
+                    "filters": {
+                        "FeedbackSelect": {
+                            "feedbackAll": "フィードバック：全て",
+                            "feedbackPositive": "フィードバック：ポジティブ",
+                            "feedbackNegative": "フィードバック：ネガティブ"
+                        },
+                        "SearchBar": {
+                            "search": "検索"
+                        }
+                    },
+                    "DeleteThreadButton": {
+                        "confirmMessage": "このスレッドとそのメッセージおよび要素を削除します。",
+                        "cancel": "キャンセル",
+                        "confirm": "確認",
+                        "deletingChat": "チャットを削除中",
+                        "chatDeleted": "チャットが削除されました"
+                    },
+                    "index": {
+                        "pastChats": "過去のチャット"
+                    },
+                    "ThreadList": {
+                        "empty": "空です...",
+                        "today": "今日",
+                        "yesterday": "昨日",
+                        "previous7days": "過去7日間",
+                        "previous30days": "過去30日間"
+                    },
+                    "TriggerButton": {
+                        "closeSidebar": "サイドバーを閉じる",
+                        "openSidebar": "サイドバーを開く"
+                    }
+                },
+                "Thread": {
+                    "backToChat": "チャットに戻る",
+                    "chatCreatedOn": "チャット作成日"
+                }
+            },
+            "header": {
+                "chat": "チャット",
+                "readme": "Readme"
+            }
+        }
+    },
+    "hooks": {
+        "useLLMProviders": {
+            "failedToFetchProviders": "プロバイダーの取得に失敗しました："
+        }
+    },
+    "pages": {
+        "Design": {},
+        "Env": {
+            "savedSuccessfully": "保存が成功しました",
+            "requiredApiKeys": "必要なAPIキー",
+            "requiredApiKeysInfo": "このアプリを使用するには、以下のAPIキーが必要です。キーはデバイスのローカルストレージに保存されます。"
+        },
+        "Page": {
+            "notPartOfProject": "このプロジェクトの一部ではありません。"
+        },
+        "ResumeButton": {
+            "resumeChat": "チャットを再開"
+        }
+    }
+}
+

app_chainlit-2nd.py

@@ -0,0 +1,15 @@
+from dotenv import load_dotenv
+load_dotenv()
+import chainlit as cl
+
+from langchain_openai import ChatOpenAI
+
+# We will set streaming=True so that we can stream tokens
+model = ChatOpenAI(temperature=0, streaming=True)
+
+from langchain_core.messages import HumanMessage
+
+@cl.on_message
+async def run_convo(message: cl.Message):
+    response = model.invoke([HumanMessage(content=message.content)])
+    await cl.Message(content=response.content).send()

app_chainlit-3rd.py

@@ -0,0 +1,39 @@
+from langchain_openai import ChatOpenAI
+from langchain.prompts import ChatPromptTemplate
+from langchain.schema import StrOutputParser
+from langchain.schema.runnable import Runnable
+from langchain.schema.runnable.config import RunnableConfig
+from typing import cast
+
+import chainlit as cl
+
+
+@cl.on_chat_start
+async def on_chat_start():
+    model = ChatOpenAI(streaming=True)
+    prompt = ChatPromptTemplate.from_messages(
+        [
+            (
+                "system",
+                "You're a very knowledgeable historian who provides accurate and eloquent answers to historical questions.",
+            ),
+            ("human", "{question}"),
+        ]
+    )
+    runnable = prompt | model | StrOutputParser()
+    cl.user_session.set("runnable", runnable)
+
+
+@cl.on_message
+async def on_message(message: cl.Message):
+    runnable = cast(Runnable, cl.user_session.get("runnable"))  # type: Runnable
+
+    msg = cl.Message(content="")
+
+    async for chunk in runnable.astream(
+        {"question": message.content},
+        config=RunnableConfig(callbacks=[cl.LangchainCallbackHandler()]),
+    ):
+        await msg.stream_token(chunk)
+
+    await msg.send()

app_chainlit.py

@@ -1,15 +1,103 @@
-from dotenv import load_dotenv
-load_dotenv()
+from typing import Literal
+from langchain_core.tools import tool
+from langchain_openai import ChatOpenAI
+from langgraph.prebuilt import ToolNode
+from langchain.schema.runnable.config import RunnableConfig
+from langchain_core.messages import HumanMessage
+
 import chainlit as cl
 
-from langchain_openai import ChatOpenAI
+@tool
+def get_weather(city: Literal["nyc", "sf"]):
+    """Use this to get weather information."""
+    if city == "nyc":
+        return "It might be cloudy in nyc"
+    elif city == "sf":
+        return "It's always sunny in sf"
+    else:
+        raise AssertionError("Unknown city")
 
-# We will set streaming=True so that we can stream tokens
-model = ChatOpenAI(temperature=0, streaming=True)
 
-from langchain_core.messages import HumanMessage
+tools = [get_weather]
+model = ChatOpenAI(model_name="gpt-3.5-turbo", temperature=0)
+final_model = ChatOpenAI(model_name="gpt-3.5-turbo", temperature=0)
+
+model = model.bind_tools(tools)
+# NOTE: this is where we're adding a tag that we'll can use later to filter the model stream events to only the model called in the final node.
+# This is not necessary if you call a single LLM but might be important in case you call multiple models within the node and want to filter events
+# from only one of them.
+final_model = final_model.with_config(tags=["final_node"])
+tool_node = ToolNode(tools=tools)
+
+from typing import Annotated
+from typing_extensions import TypedDict
+
+from langgraph.graph import END, StateGraph, START
+from langgraph.graph.message import MessagesState
+from langchain_core.messages import BaseMessage, SystemMessage, HumanMessage
+
+
+def should_continue(state: MessagesState) -> Literal["tools", "final"]:
+    messages = state["messages"]
+    last_message = messages[-1]
+    # If the LLM makes a tool call, then we route to the "tools" node
+    if last_message.tool_calls:
+        return "tools"
+    # Otherwise, we stop (reply to the user)
+    return "final"
+
+
+def call_model(state: MessagesState):
+    messages = state["messages"]
+    response = model.invoke(messages)
+    # We return a list, because this will get added to the existing list
+    return {"messages": [response]}
+
+
+def call_final_model(state: MessagesState):
+    messages = state["messages"]
+    last_ai_message = messages[-1]
+    response = final_model.invoke(
+        [
+            SystemMessage("Rewrite this in the voice of Al Roker"),
+            HumanMessage(last_ai_message.content),
+        ]
+    )
+    # overwrite the last AI message from the agent
+    response.id = last_ai_message.id
+    return {"messages": [response]}
+
+
+builder = StateGraph(MessagesState)
+
+builder.add_node("agent", call_model)
+builder.add_node("tools", tool_node)
+# add a separate final node
+builder.add_node("final", call_final_model)
+
+builder.add_edge(START, "agent")
+builder.add_conditional_edges(
+    "agent",
+    should_continue,
+)
+
+builder.add_edge("tools", "agent")
+builder.add_edge("final", END)
+
+graph = builder.compile()
 
 @cl.on_message
-async def run_convo(message: cl.Message):
-    response = model.invoke([HumanMessage(content=message.content)])
-    await cl.Message(content=response.content).send()
+async def on_message(msg: cl.Message):
+    config = {"configurable": {"thread_id": cl.context.session.id}}
+    cb = cl.LangchainCallbackHandler()
+    final_answer = cl.Message(content="")
+    
+    for msg, metadata in graph.stream({"messages": [HumanMessage(content=msg.content)]}, stream_mode="messages", config=RunnableConfig(callbacks=[cb], **config)):
+        if (
+            msg.content
+            and not isinstance(msg, HumanMessage)
+            and metadata["langgraph_node"] == "final"
+        ):
+            await final_answer.stream_token(msg.content)
+
+    await final_answer.send()