From bbb673b6402e47a108cb42ff9afeb00473a5982f Mon Sep 17 00:00:00 2001
From: Cam <yulinfeng000@gmail.com>
Date: Wed, 9 Mar 2022 10:12:23 +0800
Subject: [PATCH] update README,add new example: with_fastapi and add project
 dependence in setup.py

---
 README.md       | 54 ++++++++++++++++++++++++++++++++++++++++++++++++-
 setup.py        |  3 ++-
 with_fastapi.py | 40 ++++++++++++++++++++++++++++++++++++
 3 files changed, 95 insertions(+), 2 deletions(-)
 create mode 100644 with_fastapi.py

diff --git a/README.md b/README.md
index 47c8fb8..5b84259 100644
--- a/README.md
+++ b/README.md
@@ -109,6 +109,53 @@ while True:
    print(msg)
 ```
 
+## 与 fastapi (其他asyncio生态框架) 配合使用
+
+```python
+from fastapi import FastAPI
+from blive import BLiver,Events
+from blive.msg import DanMuMsg
+
+app = FastAPI()
+
+BLIVER_POOL = {}
+
+
+# 定义弹幕事件handler
+async def handler(ctx):
+   danmu = DanMuMsg(ctx.body)
+   print(
+      f'\n{danmu.sender.name} ({danmu.sender.medal.medal_name}:{danmu.sender.medal.medal_level}): "{danmu.content}"\n'
+   )
+
+def create_bliver(roomid):
+    b = BLiver(roomid)
+    b.register_handler(Events.DANMU_MSG,handler)
+    return b
+
+
+@app.get("/create")
+async def create_new_bliver(roomid:int):
+    room = BLIVER_POOL.get(roomid,None)
+    if not room:
+        b = create_bliver(roomid)
+        BLIVER_POOL[roomid] = b.run_as_task() # 启动监听
+    return {"msg":"创建一个新直播间弹幕监听成功"}
+
+
+@app.get("/del")
+async def rm_bliver(roomid:int):
+    room = BLIVER_POOL.get(roomid,None)
+    if room:
+        room.cancel()
+    return {"msg":"移除直播间弹幕监听成功"}
+
+
+@app.get("/show")
+async def show():
+    return list(BLIVER_POOL.keys())
+```
+
 ## 项目简介
 
 - blive 文件夹为框架代码
@@ -119,7 +166,12 @@ while True:
 
   - msg.py 为消息操作类代码
 
-- app.py , multi_room.py 为2个简单示例，分别是以框架运行和同时监听多个直播间的实现
+- app.py
+   以框架形式运行例子
+- multi_room.py
+   同时监听多个直播间的实现
+- with_fastapi.py
+   与fastapi 配合使用的例子
 
 ## TODO
 
diff --git a/setup.py b/setup.py
index 5c334e4..c7c3027 100644
--- a/setup.py
+++ b/setup.py
@@ -5,7 +5,7 @@ with open("./README.md", "r") as f:
 
 setuptools.setup(
     name="blive",
-    version="0.0.4",
+    version="0.0.5",
     author="cam",
     author_email="yulinfeng000@gmail.com",
     long_description=description,
@@ -16,4 +16,5 @@ setuptools.setup(
         "Programming Language :: Python :: 3",
         "License :: OSI Approved :: MIT License",
     ],
+    install_requires=["aiohttp","loguru","requests","APScheduler","brotli"]
 )
diff --git a/with_fastapi.py b/with_fastapi.py
new file mode 100644
index 0000000..e4c3287
--- /dev/null
+++ b/with_fastapi.py
@@ -0,0 +1,40 @@
+from fastapi import FastAPI
+from blive import BLiver,Events
+from blive.msg import DanMuMsg
+
+app = FastAPI()
+
+BLIVER_POOL = {}
+
+def create_bliver(roomid):
+    # 定义弹幕事件handler
+    async def listen(ctx):
+        danmu = DanMuMsg(ctx.body)
+        print(
+            f'\n{danmu.sender.name} ({danmu.sender.medal.medal_name}:{danmu.sender.medal.medal_level}): "{danmu.content}"\n'
+        )
+    b = BLiver(roomid)
+    b.register_handler(Events.DANMU_MSG,listen)
+    return b
+
+
+@app.get("/create")
+async def create_new_bliver(roomid:int):
+    room = BLIVER_POOL.get(roomid,None)
+    if not room:
+        b = create_bliver(roomid)
+        BLIVER_POOL[roomid] = b.run_as_task()
+    return {"msg":"创建一个新直播间弹幕监听成功"}
+
+
+@app.get("/del")
+async def rm_bliver(roomid:int):
+    room = BLIVER_POOL.get(roomid,None)
+    if room:
+        room.cancel()
+    return {"msg":"移除直播间弹幕监听成功"}
+
+
+@app.get("/show")
+async def show():
+    return list(BLIVER_POOL.keys())