add files

AESCipher.py

@@ -0,0 +1,54 @@
+# coding=utf-8
+"""
+@Author: Freshield
+@Contact: yangyufresh@163.com
+@File: AESCipher.py
+@Time: 2023-03-05 22:55
+@Last_update: 2023-03-05 22:55
+@Desc: None
+@==============================================@
+@      _____             _   _     _   _       @
+@     |   __|___ ___ ___| |_|_|___| |_| |      @
+@     |   __|  _| -_|_ -|   | | -_| | . |      @
+@     |__|  |_| |___|___|_|_|_|___|_|___|      @
+@                                    Freshield @
+@==============================================@
+"""
+from Crypto.Cipher import AES
+import base64
+
+# 加密函数
+def aes_encrypt(key, data):
+    # 将key转换成16、24、32位的字符串，不足的以空格补齐
+    key = key.ljust(32, ' ')
+    # 将data转换成16的倍数，不足的以空格补齐
+    data = data.ljust(16 * (len(data) // 16 + 1), ' ')
+    # 进行加密
+    cipher = AES.new(key.encode('utf-8'), AES.MODE_ECB)
+    encrypted_data = cipher.encrypt(data.encode('utf-8'))
+    # 将加密后的数据进行base64编码
+    encrypted_data = base64.b64encode(encrypted_data).decode('utf-8')
+    return encrypted_data
+
+# 解密函数
+def aes_decrypt(key, encrypted_data):
+    # 将key转换成16、24、32位的字符串，不足的以空格补齐
+    key = key.ljust(32, ' ')
+    # 对加密后的数据进行base64解码
+    encrypted_data = base64.b64decode(encrypted_data)
+    # 进行解密
+    cipher = AES.new(key.encode('utf-8'), AES.MODE_ECB)
+    decrypted_data = cipher.decrypt(encrypted_data).decode('utf-8')
+    # 去除解密后的数据中的空格
+    decrypted_data = decrypted_data.strip()
+    return decrypted_data
+
+
+# 测试
+if __name__ == '__main__':
+    key = '1234567890123456345345'
+    data = 'Hello, world!'
+    encrypted_data = aes_encrypt(key, data)
+    print('加密后的数据：', encrypted_data)
+    decrypted_data = aes_decrypt(key, encrypted_data)
+    print('解密后的数据：', decrypted_data)

MongdbClient.py

@@ -0,0 +1,95 @@
+# coding=utf-8
+"""
+@Author: Freshield
+@Contact: yangyufresh@163.com
+@File: MongdbClient.py
+@Time: 2023-03-03 20:25
+@Last_update: 2023-03-03 20:25
+@Desc: None
+@==============================================@
+@      _____             _   _     _   _       @
+@     |   __|___ ___ ___| |_|_|___| |_| |      @
+@     |   __|  _| -_|_ -|   | | -_| | . |      @
+@     |__|  |_| |___|___|_|_|_|___|_|___|      @
+@                                    Freshield @
+@==============================================@
+"""
+import pymongo
+from hashlib import sha256
+
+
+class MongodbClient(object):
+    """Mongodb客户端"""
+    def __init__(self):
+        self.myclient = pymongo.MongoClient("mongodb://localhost:27017/")
+        self.mydb = self.myclient["openai_bot"]
+        self.user_info = self.mydb['user_info']
+        self.user_history = self.mydb['user_history']
+
+    def insert_user(self, username, password):
+        """离线添加用户"""
+        username = sha256(username.encode('utf8')).hexdigest()
+        password = sha256(password.encode('utf8')).hexdigest()
+        mydict = {'username': username, 'password': password}
+        _ = self.user_info.insert_one(mydict)
+
+    def check_user_exist(self, username, password):
+        """检测用户是否存在"""
+        username = sha256(username.encode('utf8')).hexdigest()
+        password = sha256(password.encode('utf8')).hexdigest()
+        mydoc = self.user_info.find({'username': username, 'password': password}).limit(1)
+        res = [x for x in mydoc]
+
+        return len(res) >= 1
+
+    def update_user_access_token(self, username, access_token):
+        """更新数据库的access_token以便后续使用"""
+        username = sha256(username.encode('utf8')).hexdigest()
+        # 先看是否有这个用户
+        mydoc = self.user_history.find({'username': username}).limit(1)
+        res = [x for x in mydoc]
+        # 如果没有则直接创建
+        if len(res) < 1:
+            mydict = {
+                'username': username, 'access_token': access_token,
+                'role': '你是ChatGPT，OpenAI训练的大规模语言模型，简明的回答用户的问题。', 'history': []}
+            _ = self.user_history.insert_one(mydict)
+        # 如果有则更新
+        else:
+            self.user_history.update_one({'username': username}, {'$set': {'access_token': access_token}})
+
+    def get_user_chat_history(self, access_token):
+        """获取用户的聊天历史"""
+        mydoc = self.user_history.find({'access_token': access_token}).limit(1)
+        res = [x for x in mydoc]
+        history_str, history_list = '', []
+        role = '你是ChatGPT，OpenAI训练的大规模语言模型，简明的回答用户的问题。'
+        if len(res) >= 1:
+            # 遍历加到history中
+            history_list = res[0]['history']
+            role = res[0]['role']
+            for qus, ans in history_list[::-1]:
+                history_str += f'Q: {qus}\nA: {ans}\n'
+
+        return history_str, history_list, role
+
+    def update_user_chat_history(self, access_token, qus, ans):
+        """更新用户的聊天历史"""
+        mydoc = self.user_history.find({'access_token': access_token}).limit(1)
+        res = [x for x in mydoc]
+        if len(res) >= 1:
+            self.user_history.update_one({'access_token': access_token}, {'$push': {'history': (qus, ans)}})
+
+    def delete_user_chat_history(self, access_token):
+        """删除用户的聊天历史"""
+        mydoc = self.user_history.find({'access_token': access_token}).limit(1)
+        res = [x for x in mydoc]
+        if len(res) >= 1:
+            self.user_history.update_one({'access_token': access_token}, {'$set': {'history': []}})
+
+    def update_role(self, access_token, role):
+        """更新用户的聊天历史"""
+        mydoc = self.user_history.find({'access_token': access_token}).limit(1)
+        res = [x for x in mydoc]
+        if len(res) >= 1:
+            self.user_history.update_one({'access_token': access_token}, {'$set': {'role': role}})

OpenaiBot.py

@@ -0,0 +1,60 @@
+# coding=utf-8
+"""
+@Author: Freshield
+@Contact: yangyufresh@163.com
+@File: OpenaiBot.py
+@Time: 2023-03-03 17:47
+@Last_update: 2023-03-03 17:47
+@Desc: None
+@==============================================@
+@      _____             _   _     _   _       @
+@     |   __|___ ___ ___| |_|_|___| |_| |      @
+@     |   __|  _| -_|_ -|   | | -_| | . |      @
+@     |__|  |_| |___|___|_|_|_|___|_|___|      @
+@                                    Freshield @
+@==============================================@
+"""
+import os
+import openai
+
+
+class OpenaiBot(object):
+    """调用openai的机器人"""
+    def __init__(self, temperature=0.5):
+        openai.api_key = os.environ.get('OPENAI_API_KEY')
+        self.model_engine = "gpt-3.5-turbo"
+        self.temperature = temperature
+
+    def set_api_key(self, api_key):
+        """设定api key"""
+        openai.api_key = api_key
+
+    def construct_message(self, role, new_msg, history_list, keep_history=3):
+        """
+        构造message，这里history_list是一个list，每个元素是一个tuple
+        """
+        msg_list = [{"role": "system", "content": role}]
+        history_list = history_list[-keep_history:]
+        for user, assistant in history_list:
+            msg_list.append({"role": "user", "content": user})
+            msg_list.append({"role": "assistant", "content": assistant})
+        msg_list.append({"role": "user", "content": new_msg})
+
+        return msg_list
+
+    def get_response(self, role, new_msg, history_list, keep_history=3):
+        """
+        通过openai获取回复
+        """
+        msg_list = self.construct_message(role, new_msg, history_list, keep_history)
+        response = openai.ChatCompletion.create(
+            model=self.model_engine, messages=msg_list,
+            temperature=self.temperature
+        )
+        content = response['choices'][0]['message']['content']
+
+        return content
+
+
+if __name__ == '__main__':
+    openai_bot = OpenaiBot()

README.md

@@ -1,13 +1,13 @@
----
-title: ChatGPT Gradio
-emoji: 😻
-colorFrom: gray
-colorTo: purple
-sdk: gradio
-sdk_version: 3.20.1
-app_file: app.py
-pinned: false
-license: apache-2.0
----
-
-Check out the configuration reference at https://huggingface.co/docs/hub/spaces-config-reference
+# ChatGPT-gradio
+# 简介
+
+> 这是一个可以简单的把ChatGPT的API应用的前端网页，通过gradio进行构建。同时给出了简单的无需数据库的版本和加入数据库的两个不同的版本。
+
+ 
+基于ChatGPT的[API](https://github.com/openai/openai-python) 接口进行调用。
+
+app的版本是已经直接部署到huggingface space的版本，没有任何的状态存储所以不需要数据库的支持。
+
+而server版本是使用gradio结合mongodb的实现方式，加入了对于gradio的access token的识别bing获取，对于想要使用gradio构建自己的应用的朋友有一定的参考价值。需要注意的是这里需要通过offline部分的代码提前加入用户。
+
+有任何问题欢迎来骚扰，vx: freshield

app.py

@@ -0,0 +1,76 @@
+# coding=utf-8
+"""
+@Author: Freshield
+@Contact: yangyufresh@163.com
+@File: server_simple.py
+@Time: 2023-03-09 22:39
+@Last_update: 2023-03-09 22:39
+@Desc: None
+@==============================================@
+@      _____             _   _     _   _       @
+@     |   __|___ ___ ___| |_|_|___| |_| |      @
+@     |   __|  _| -_|_ -|   | | -_| | . |      @
+@     |__|  |_| |___|___|_|_|_|___|_|___|      @
+@                                    Freshield @
+@==============================================@
+"""
+import gradio as gr
+from lib.OpenaiBot import OpenaiBot
+
+openai_bot = OpenaiBot()
+
+
+def ask_chatGPT(openai_key, role, new_msg, state, request: gr.Request):
+    """向chatGPT提问"""
+    res_content = '对不起，服务器出错了，请稍后再试。'
+    res = [(new_msg, res_content)]
+    try:
+        openai_bot.set_api_key(openai_key)
+        res_content = openai_bot.get_response(role, new_msg, state)
+        res = [(new_msg, res_content)]
+    except Exception as e:
+        print(e)
+    finally:
+        state += res
+        res = state
+
+    return res, state
+
+
+def clean_question(question):
+    """清除问题"""
+    return ''
+
+
+if __name__ == '__main__':
+    with gr.Blocks(title="尝试chatGPT对话", css="#maxheight {max-height: 390px} ") as demo:
+        state = gr.State([])
+        with gr.Column(variant='panel'):
+            # title
+            with gr.Row():
+                gr.Markdown("## 尝试chatGPT对话")
+            with gr.Row():
+                # left part
+                with gr.Column():
+                    openai_key = gr.Textbox(
+                        label='openai_key', placeholder='输入你openai的api key', type='password')
+                    role_b = gr.Textbox(
+                        label='请输入你设定的chatGPT的角色', lines=2,
+                        value='你是ChatGPT，OpenAI训练的大规模语言模型，简明的回答用户的问题。')
+                    question_b = gr.Textbox(
+                        label='请输入你想要问的问题',
+                        placeholder='输入你想提问的内容...',
+                        lines=3
+                    )
+                    with gr.Row():
+                        greet_btn = gr.Button('提交', variant="primary")
+                # right part
+                with gr.Column():
+                    answer_b = gr.Chatbot(
+                        label='chatGPT的问答', value=[(None, '请在这里提问')], elem_id='maxheight')
+
+        greet_btn.click(fn=ask_chatGPT, inputs=[openai_key, role_b, question_b, state], outputs=[answer_b, state])
+        greet_btn.click(fn=clean_question, inputs=[question_b], outputs=[question_b])
+
+    demo.launch(server_name='0.0.0.0', server_port=8080)
+    demo.close()

lib/AESCipher.py

@@ -0,0 +1,54 @@
+# coding=utf-8
+"""
+@Author: Freshield
+@Contact: yangyufresh@163.com
+@File: AESCipher.py
+@Time: 2023-03-05 22:55
+@Last_update: 2023-03-05 22:55
+@Desc: None
+@==============================================@
+@      _____             _   _     _   _       @
+@     |   __|___ ___ ___| |_|_|___| |_| |      @
+@     |   __|  _| -_|_ -|   | | -_| | . |      @
+@     |__|  |_| |___|___|_|_|_|___|_|___|      @
+@                                    Freshield @
+@==============================================@
+"""
+from Crypto.Cipher import AES
+import base64
+
+# 加密函数
+def aes_encrypt(key, data):
+    # 将key转换成16、24、32位的字符串，不足的以空格补齐
+    key = key.ljust(32, ' ')
+    # 将data转换成16的倍数，不足的以空格补齐
+    data = data.ljust(16 * (len(data) // 16 + 1), ' ')
+    # 进行加密
+    cipher = AES.new(key.encode('utf-8'), AES.MODE_ECB)
+    encrypted_data = cipher.encrypt(data.encode('utf-8'))
+    # 将加密后的数据进行base64编码
+    encrypted_data = base64.b64encode(encrypted_data).decode('utf-8')
+    return encrypted_data
+
+# 解密函数
+def aes_decrypt(key, encrypted_data):
+    # 将key转换成16、24、32位的字符串，不足的以空格补齐
+    key = key.ljust(32, ' ')
+    # 对加密后的数据进行base64解码
+    encrypted_data = base64.b64decode(encrypted_data)
+    # 进行解密
+    cipher = AES.new(key.encode('utf-8'), AES.MODE_ECB)
+    decrypted_data = cipher.decrypt(encrypted_data).decode('utf-8')
+    # 去除解密后的数据中的空格
+    decrypted_data = decrypted_data.strip()
+    return decrypted_data
+
+
+# 测试
+if __name__ == '__main__':
+    key = '1234567890123456345345'
+    data = 'Hello, world!'
+    encrypted_data = aes_encrypt(key, data)
+    print('加密后的数据：', encrypted_data)
+    decrypted_data = aes_decrypt(key, encrypted_data)
+    print('解密后的数据：', decrypted_data)

lib/MongdbClient.py

@@ -0,0 +1,95 @@
+# coding=utf-8
+"""
+@Author: Freshield
+@Contact: yangyufresh@163.com
+@File: MongdbClient.py
+@Time: 2023-03-03 20:25
+@Last_update: 2023-03-03 20:25
+@Desc: None
+@==============================================@
+@      _____             _   _     _   _       @
+@     |   __|___ ___ ___| |_|_|___| |_| |      @
+@     |   __|  _| -_|_ -|   | | -_| | . |      @
+@     |__|  |_| |___|___|_|_|_|___|_|___|      @
+@                                    Freshield @
+@==============================================@
+"""
+import pymongo
+from hashlib import sha256
+
+
+class MongodbClient(object):
+    """Mongodb客户端"""
+    def __init__(self):
+        self.myclient = pymongo.MongoClient("mongodb://localhost:27017/")
+        self.mydb = self.myclient["openai_bot"]
+        self.user_info = self.mydb['user_info']
+        self.user_history = self.mydb['user_history']
+
+    def insert_user(self, username, password):
+        """离线添加用户"""
+        username = sha256(username.encode('utf8')).hexdigest()
+        password = sha256(password.encode('utf8')).hexdigest()
+        mydict = {'username': username, 'password': password}
+        _ = self.user_info.insert_one(mydict)
+
+    def check_user_exist(self, username, password):
+        """检测用户是否存在"""
+        username = sha256(username.encode('utf8')).hexdigest()
+        password = sha256(password.encode('utf8')).hexdigest()
+        mydoc = self.user_info.find({'username': username, 'password': password}).limit(1)
+        res = [x for x in mydoc]
+
+        return len(res) >= 1
+
+    def update_user_access_token(self, username, access_token):
+        """更新数据库的access_token以便后续使用"""
+        username = sha256(username.encode('utf8')).hexdigest()
+        # 先看是否有这个用户
+        mydoc = self.user_history.find({'username': username}).limit(1)
+        res = [x for x in mydoc]
+        # 如果没有则直接创建
+        if len(res) < 1:
+            mydict = {
+                'username': username, 'access_token': access_token,
+                'role': '你是ChatGPT，OpenAI训练的大规模语言模型，简明的回答用户的问题。', 'history': []}
+            _ = self.user_history.insert_one(mydict)
+        # 如果有则更新
+        else:
+            self.user_history.update_one({'username': username}, {'$set': {'access_token': access_token}})
+
+    def get_user_chat_history(self, access_token):
+        """获取用户的聊天历史"""
+        mydoc = self.user_history.find({'access_token': access_token}).limit(1)
+        res = [x for x in mydoc]
+        history_str, history_list = '', []
+        role = '你是ChatGPT，OpenAI训练的大规模语言模型，简明的回答用户的问题。'
+        if len(res) >= 1:
+            # 遍历加到history中
+            history_list = res[0]['history']
+            role = res[0]['role']
+            for qus, ans in history_list[::-1]:
+                history_str += f'Q: {qus}\nA: {ans}\n'
+
+        return history_str, history_list, role
+
+    def update_user_chat_history(self, access_token, qus, ans):
+        """更新用户的聊天历史"""
+        mydoc = self.user_history.find({'access_token': access_token}).limit(1)
+        res = [x for x in mydoc]
+        if len(res) >= 1:
+            self.user_history.update_one({'access_token': access_token}, {'$push': {'history': (qus, ans)}})
+
+    def delete_user_chat_history(self, access_token):
+        """删除用户的聊天历史"""
+        mydoc = self.user_history.find({'access_token': access_token}).limit(1)
+        res = [x for x in mydoc]
+        if len(res) >= 1:
+            self.user_history.update_one({'access_token': access_token}, {'$set': {'history': []}})
+
+    def update_role(self, access_token, role):
+        """更新用户的聊天历史"""
+        mydoc = self.user_history.find({'access_token': access_token}).limit(1)
+        res = [x for x in mydoc]
+        if len(res) >= 1:
+            self.user_history.update_one({'access_token': access_token}, {'$set': {'role': role}})

lib/OpenaiBot.py

@@ -0,0 +1,60 @@
+# coding=utf-8
+"""
+@Author: Freshield
+@Contact: yangyufresh@163.com
+@File: OpenaiBot.py
+@Time: 2023-03-03 17:47
+@Last_update: 2023-03-03 17:47
+@Desc: None
+@==============================================@
+@      _____             _   _     _   _       @
+@     |   __|___ ___ ___| |_|_|___| |_| |      @
+@     |   __|  _| -_|_ -|   | | -_| | . |      @
+@     |__|  |_| |___|___|_|_|_|___|_|___|      @
+@                                    Freshield @
+@==============================================@
+"""
+import os
+import openai
+
+
+class OpenaiBot(object):
+    """调用openai的机器人"""
+    def __init__(self, temperature=0.5):
+        openai.api_key = os.environ.get('OPENAI_API_KEY')
+        self.model_engine = "gpt-3.5-turbo"
+        self.temperature = temperature
+
+    def set_api_key(self, api_key):
+        """设定api key"""
+        openai.api_key = api_key
+
+    def construct_message(self, role, new_msg, history_list, keep_history=3):
+        """
+        构造message，这里history_list是一个list，每个元素是一个tuple
+        """
+        msg_list = [{"role": "system", "content": role}]
+        history_list = history_list[-keep_history:]
+        for user, assistant in history_list:
+            msg_list.append({"role": "user", "content": user})
+            msg_list.append({"role": "assistant", "content": assistant})
+        msg_list.append({"role": "user", "content": new_msg})
+
+        return msg_list
+
+    def get_response(self, role, new_msg, history_list, keep_history=3):
+        """
+        通过openai获取回复
+        """
+        msg_list = self.construct_message(role, new_msg, history_list, keep_history)
+        response = openai.ChatCompletion.create(
+            model=self.model_engine, messages=msg_list,
+            temperature=self.temperature
+        )
+        content = response['choices'][0]['message']['content']
+
+        return content
+
+
+if __name__ == '__main__':
+    openai_bot = OpenaiBot()

offline/insert_user.py

@@ -0,0 +1,24 @@
+# coding=utf-8
+"""
+@Author: Freshield
+@Contact: yangyufresh@163.com
+@File: insert_user.py
+@Time: 2023-03-09 22:35
+@Last_update: 2023-03-09 22:35
+@Desc: None
+@==============================================@
+@      _____             _   _     _   _       @
+@     |   __|___ ___ ___| |_|_|___| |_| |      @
+@     |   __|  _| -_|_ -|   | | -_| | . |      @
+@     |__|  |_| |___|___|_|_|_|___|_|___|      @
+@                                    Freshield @
+@==============================================@
+"""
+from lib.MongdbClient import MongodbClient
+
+
+if __name__ == '__main__':
+    # 离线添加用户
+    mongo_client = MongodbClient()
+    username, password = '', ''
+    mongo_client.insert_user(username, password)

server.py

@@ -0,0 +1,126 @@
+# coding=utf-8
+"""
+@Author: Freshield
+@Contact: yangyufresh@163.com
+@File: b2_try_gradio.py
+@Time: 2023-03-03 16:06
+@Last_update: 2023-03-03 16:06
+@Desc: None
+@==============================================@
+@      _____             _   _     _   _       @
+@     |   __|___ ___ ___| |_|_|___| |_| |      @
+@     |   __|  _| -_|_ -|   | | -_| | . |      @
+@     |__|  |_| |___|___|_|_|_|___|_|___|      @
+@                                    Freshield @
+@==============================================@
+"""
+import gradio as gr
+from lib.OpenaiBot import OpenaiBot
+from lib.MongdbClient import MongodbClient
+
+openai_bot = OpenaiBot()
+mongo_client = MongodbClient()
+
+
+def check_auth(username, passowrd):
+    return mongo_client.check_user_exist(username, passowrd)
+
+
+def ask_chatGPT(role, new_msg, state, request: gr.Request):
+    """向chatGPT提问"""
+    # 获取access_token
+    access_token = request.request.cookies['access-token-unsecure']
+    res_content = '对不起，服务器出错了，请稍后再试。'
+    res = [(new_msg, res_content)]
+    try:
+        res_content = openai_bot.get_response(role, new_msg, state)
+        res = [(new_msg, res_content)]
+    except Exception as e:
+        print(e)
+    finally:
+        state += res
+        res = state
+
+    # 更新history
+    mongo_client.update_user_chat_history(access_token, new_msg, res_content)
+    history, _, _ = mongo_client.get_user_chat_history(access_token)
+
+    return res, state, history
+
+
+def clean_question(question):
+    """清除问题"""
+    return ''
+
+
+def clean_history(history, request: gr.Request):
+    """清除历史记录"""
+    access_token = request.request.cookies['access-token-unsecure']
+    mongo_client.delete_user_chat_history(access_token)
+    history, _, _ = mongo_client.get_user_chat_history(access_token)
+
+    return history
+
+
+def update_role(role, request: gr.Request):
+    """更新角色"""
+    access_token = request.request.cookies['access-token-unsecure']
+    mongo_client.update_role(access_token, role)
+
+    return role
+
+
+if __name__ == '__main__':
+    with gr.Blocks(title="尝试chatGPT对话", css="#maxheight {max-height: 390px} ") as demo:
+        state = gr.State([])
+        with gr.Column(variant='panel'):
+            # title
+            with gr.Row():
+                gr.Markdown("## 尝试chatGPT对话")
+            with gr.Row():
+                # left part
+                with gr.Column():
+                    role_b = gr.Textbox(
+                        label='请输入你设定的chatGPT的角色', lines=2,
+                        value='你是ChatGPT，OpenAI训练的大规模语言模型，简明的回答用户的问题。')
+                    question_b = gr.Textbox(
+                        label='请输入你想要问的问题',
+                        placeholder='输入你想提问的内容...',
+                        lines=3
+                    )
+                    with gr.Row():
+                        role_btn = gr.Button('更新角色')
+                        greet_btn = gr.Button('提交', variant="primary")
+                    with gr.Row():
+                        clean_history_btn = gr.Button('清除历史记录')
+                # right part
+                with gr.Column():
+                    answer_b = gr.Chatbot(
+                        label='chatGPT的问答', value=[(None, '请在这里提问')], elem_id='maxheight')
+            with gr.Row():
+                history_b = gr.TextArea(
+                    label='历史记录', interactive=False)
+
+        role_btn.click(fn=update_role, inputs=[role_b], outputs=[role_b])
+        greet_btn.click(fn=ask_chatGPT, inputs=[role_b, question_b, state], outputs=[answer_b, state, history_b])
+        greet_btn.click(fn=clean_question, inputs=[question_b], outputs=[question_b])
+        clean_history_btn.click(fn=clean_history, inputs=[history_b], outputs=[history_b])
+
+        def demo_load(request: gr.Request):
+            """第一次进入demo时候运行的"""
+            # 更新用户的access_token
+            token_dict = demo.server_app.tokens
+            access_token = request.request.cookies['access-token-unsecure']
+            username = token_dict[access_token]
+            mongo_client.update_user_access_token(username, access_token)
+
+            # 获取用户的历史记录
+            history_str, history_list, role = mongo_client.get_user_chat_history(access_token)
+
+            return history_str, history_list[-10:], role, history_list[-10:]
+
+        demo.load(demo_load, None, [history_b, state, role_b, answer_b])
+
+    demo.launch(
+        auth=check_auth, auth_message='请输入给定的用户名和密码', server_name='0.0.0.0', server_port=8081)
+    demo.close()