Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Sign in / Register
Toggle navigation
M
Mirai
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Locked Files
Issues
0
Issues
0
List
Boards
Labels
Service Desk
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Security & Compliance
Security & Compliance
Dependency List
License Compliance
Packages
Packages
List
Container Registry
Analytics
Analytics
CI / CD
Code Review
Insights
Issues
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
MyCard
Mirai
Commits
e7725bdc
Commit
e7725bdc
authored
Oct 28, 2019
by
Him188
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Update DOCs
parent
c1351f48
Changes
2
Show whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
70 additions
and
11 deletions
+70
-11
mirai-core/src/commonMain/kotlin/net.mamoe.mirai/event/MessageSubscribers.kt
...onMain/kotlin/net.mamoe.mirai/event/MessageSubscribers.kt
+20
-2
mirai-demos/mirai-demo-1/src/main/java/demo/subscribe/SubscribeSamples.kt
...i-demo-1/src/main/java/demo/subscribe/SubscribeSamples.kt
+50
-9
No files found.
mirai-core/src/commonMain/kotlin/net.mamoe.mirai/event/MessageSubscribers.kt
View file @
e7725bdc
...
@@ -196,8 +196,26 @@ class MessageSubscribersBuilder<T : SenderAndMessage<*>>(
...
@@ -196,8 +196,26 @@ class MessageSubscribersBuilder<T : SenderAndMessage<*>>(
suspend
inline
fun
endsWith
(
start
:
String
,
noinline
listener
:
MessageListener
<
T
>)
=
suspend
inline
fun
endsWith
(
start
:
String
,
noinline
listener
:
MessageListener
<
T
>)
=
content
({
it
.
endsWith
(
start
)
},
listener
)
content
({
it
.
endsWith
(
start
)
},
listener
)
suspend
inline
fun
sentBy
(
id
:
UInt
,
noinline
listener
:
MessageListener
<
T
>)
=
content
({
sender
.
id
==
id
},
listener
)
/**
suspend
inline
fun
sentBy
(
id
:
Long
,
noinline
listener
:
MessageListener
<
T
>)
=
sentBy
(
id
.
toUInt
(),
listener
)
* 如果是这个人发的消息. 可以好友消息也可以是群消息
*/
suspend
inline
fun
sentBy
(
qqId
:
UInt
,
noinline
listener
:
MessageListener
<
T
>)
=
content
({
sender
.
id
==
qqId
},
listener
)
/**
* 如果是这个人发的消息. 可以好友消息也可以是群消息
*/
suspend
inline
fun
sentBy
(
qqId
:
Long
,
noinline
listener
:
MessageListener
<
T
>)
=
sentBy
(
qqId
.
toUInt
(),
listener
)
/**
* 如果是来自这个群的消息
*/
suspend
inline
fun
sentFrom
(
id
:
UInt
,
noinline
listener
:
MessageListener
<
T
>)
=
content
({
if
(
this
is
GroupSenderAndMessage
)
group
.
id
==
id
else
false
},
listener
)
/**
* 如果是来自这个群的消息
*/
suspend
inline
fun
sentFrom
(
id
:
Long
,
noinline
listener
:
MessageListener
<
T
>)
=
sentFrom
(
id
.
toUInt
(),
listener
)
suspend
inline
fun
<
reified
M
:
Message
>
has
(
noinline
listener
:
MessageListener
<
T
>)
=
suspend
inline
fun
<
reified
M
:
Message
>
has
(
noinline
listener
:
MessageListener
<
T
>)
=
handlerConsumer
{
if
(
message
.
any
<
M
>())
listener
(
this
)
}
handlerConsumer
{
if
(
message
.
any
<
M
>())
listener
(
this
)
}
...
...
mirai-demos/mirai-demo-1/src/main/java/demo/subscribe/SubscribeSamples.kt
View file @
e7725bdc
...
@@ -6,6 +6,7 @@ import kotlinx.coroutines.delay
...
@@ -6,6 +6,7 @@ import kotlinx.coroutines.delay
import
kotlinx.coroutines.withTimeoutOrNull
import
kotlinx.coroutines.withTimeoutOrNull
import
net.mamoe.mirai.Bot
import
net.mamoe.mirai.Bot
import
net.mamoe.mirai.BotAccount
import
net.mamoe.mirai.BotAccount
import
net.mamoe.mirai.contact.QQ
import
net.mamoe.mirai.event.*
import
net.mamoe.mirai.event.*
import
net.mamoe.mirai.event.events.FriendMessageEvent
import
net.mamoe.mirai.event.events.FriendMessageEvent
import
net.mamoe.mirai.login
import
net.mamoe.mirai.login
...
@@ -45,10 +46,27 @@ private fun readTestAccount(): BotAccount? {
...
@@ -45,10 +46,27 @@ private fun readTestAccount(): BotAccount? {
* @see MessageSubscribersBuilder
* @see MessageSubscribersBuilder
*/
*/
suspend
fun
Bot
.
messageDSL
()
{
suspend
fun
Bot
.
messageDSL
()
{
//监听所有 bot 的来自所有群和好友的消息
// 监听这个 bot 的来自所有群和好友的消息
subscribeMessages
{
this
.
subscribeMessages
{
// 当接收到消息 == "你好" 时就回复 "你好!"
"你好"
reply
"你好!"
"你好"
reply
"你好!"
// 当消息 == "查看 subject" 时, 执行 lambda 并回复 lambda 的返回值
case
(
"查看 subject"
)
{
if
(
subject
is
QQ
)
{
reply
(
"消息主体为 QQ, 你在跟发私聊消息"
)
}
else
{
reply
(
"消息主体为 Group, 你在群里发消息"
)
}
// 在回复的时候, 一般使用 subject 来作为回复对象.
// 因为当群消息时, subject 为这个群.
// 当好友消息时, subject 为这个好友.
// 所有在 SenderAndMessage(也就是此时的 this 指代的对象) 中实现的扩展方法, 如刚刚的 "reply", 都是以 subject 作为目标
}
// 当消息里面包含这个类型的消息时
has
<
Image
>
{
has
<
Image
>
{
// this: SenderAndMessage
// this: SenderAndMessage
// message: MessageChain
// message: MessageChain
...
@@ -61,30 +79,53 @@ suspend fun Bot.messageDSL() {
...
@@ -61,30 +79,53 @@ suspend fun Bot.messageDSL() {
this
.
group
.
sendMessage
(
"你在一个群里"
)
this
.
group
.
sendMessage
(
"你在一个群里"
)
}
}
reply
(
"图片, ID= ${message[Image].id}"
)
reply
(
"图片, ID= ${message[Image].id}"
)
//获取第一个 Image 类型的消息
reply
(
message
)
reply
(
message
)
}
}
"123"
reply
"你的消息里面包含 123"
"123"
containsReply
"你的消息里面包含 123"
// 当收到 "我的qq" 就执行 lambda 并回复 lambda 的返回值 String
"我的qq"
reply
{
sender
.
id
.
toString
()
}
"我的qq"
reply
{
sender
.
id
.
toString
()
}
// 如果是这个 QQ 号发送的消息(可以是好友消息也可以是群消息)
sentBy
(
1040400290
)
{
sentBy
(
1040400290
)
{
//reply("是你!")
}
}
// 当消息前缀为 "我是" 时
startsWith
(
"我是"
,
removePrefix
=
true
)
{
// it: 删除了消息前缀 "我是" 后的消息
// 如一条消息为 "我是张三", 则此时的 it 为 "张三".
reply
(
"你是$it"
)
}
// 当消息中包含 "复读" 时
contains
(
"复读"
)
{
contains
(
"复读"
)
{
reply
(
message
)
reply
(
message
)
}
}
// 自定义的 filter, filter 中 it 为转为 String 的消息.
// 也可以用任何能在处理时使用的变量, 如 subject, sender, message
content
({
it
.
length
==
3
})
{
reply
(
"你发送了长度为 3 的消息"
)
}
case
(
"上传好友图片"
)
{
case
(
"上传好友图片"
)
{
val
filename
=
it
.
toString
().
substringAfter
(
"上传好友图片"
)
val
filename
=
it
.
substringAfter
(
"上传好友图片"
)
File
(
"C:\\Users\\Him18\\Desktop\\$filename"
).
sendAsImageTo
(
1040400290
u
.
qq
()
)
File
(
"C:\\Users\\Him18\\Desktop\\$filename"
).
sendAsImageTo
(
subject
)
}
}
case
(
"上传群图片"
)
{
case
(
"上传群图片"
)
{
val
filename
=
it
.
toString
().
substringAfter
(
"上传好友图片"
)
val
filename
=
it
.
substringAfter
(
"上传好友图片"
)
File
(
"C:\\Users\\Him18\\Desktop\\$filename"
).
sendAsImageTo
(
920503456
u
.
group
()
)
File
(
"C:\\Users\\Him18\\Desktop\\$filename"
).
sendAsImageTo
(
subject
)
}
}
}
}
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment