Skip to content

Commit a604db9

Browse files
authored
fix(ext): 修改 extension 作用域 (#3)
1 parent 4f40860 commit a604db9

File tree

2 files changed

+18
-8
lines changed

2 files changed

+18
-8
lines changed

nonebot_plugin_prometheus/__init__.py

+6-6
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,10 @@
1212

1313
from nonebot_plugin_prometheus import api as api
1414
from nonebot_plugin_prometheus.config import Config
15-
from nonebot_plugin_prometheus.extension import MessageCounterExtension
15+
from nonebot_plugin_prometheus.extension import (
16+
MessageSendCounter,
17+
MessageReceiveCounter,
18+
)
1619

1720
__plugin_meta__ = PluginMetadata(
1821
name="Prometheus 监控",
@@ -26,13 +29,10 @@
2629

2730
__all__ = [prometheus_client, Counter, Gauge, Histogram, Summary]
2831

29-
add_global_extension(MessageCounterExtension)
32+
add_global_extension(MessageSendCounter)
3033

3134
metrics = (
3235
Command("metrics", help_text="查询指标数据")
3336
.usage(__plugin_meta__.usage)
34-
.build(
35-
block=True,
36-
use_cmd_start=True,
37-
)
37+
.build(block=True, use_cmd_start=True, extensions=[MessageReceiveCounter()])
3838
)

nonebot_plugin_prometheus/extension.py

+12-2
Original file line numberDiff line numberDiff line change
@@ -8,21 +8,31 @@
88
)
99

1010

11-
class MessageCounterExtension(Extension):
11+
class MessageReceiveCounter(Extension):
1212
@property
1313
def priority(self) -> int:
1414
return 15
1515

1616
@property
1717
def id(self) -> str:
18-
return "MessageCounter"
18+
return "MessageReceiveCounter"
1919

2020
async def receive_wrapper(
2121
self, bot: Bot, event: Event, command: Alconna, receive: UniMessage
2222
) -> UniMessage:
2323
received_messages_counter.labels(bot.self_id, bot.adapter.get_name()).inc()
2424
return receive
2525

26+
27+
class MessageSendCounter(Extension):
28+
@property
29+
def priority(self) -> int:
30+
return 15
31+
32+
@property
33+
def id(self) -> str:
34+
return "MessageSendCounter"
35+
2636
async def send_wrapper(
2737
self, bot: Bot, event: Event, send: Union[str, Message, UniMessage]
2838
) -> Union[str, Message, UniMessage]:

0 commit comments

Comments
 (0)