This commit is contained in:
cdle
2021-10-11 18:27:10 +08:00
parent 39fca4e1ab
commit 6c6263bea8
3 changed files with 6 additions and 5 deletions
+2 -2
View File
@@ -81,8 +81,8 @@ func AddCommand(prefix string, cmds []Function) {
func handleMessage(sender Sender) {
defer sender.Finish()
key := fmt.Sprintf("u=%v&c=%v&i=%v", sender.GetUserID(), sender.GetChatID(), sender.GetImType())
fmt.Println(key, sender.GetContent())
fmt.Println(waits.Load(key))
// fmt.Println(key, sender.GetContent())
// fmt.Println(waits.Load(key))
if v, ok := waits.Load(key); ok {
c := v.(Carry)
+3 -2
View File
@@ -30,7 +30,7 @@ type Sender interface {
Finish()
Continue()
IsContinue() bool
Await(func(string, error) interface{}, ...interface{})
Await(Sender, func(string, error) interface{}, ...interface{})
}
type Edit int
@@ -134,6 +134,7 @@ func (sender *Faker) Finish() {
type BaseSender struct {
matches [][]string
goon bool
child Sender
}
func (sender *BaseSender) SetMatch(ss []string) {
@@ -222,7 +223,7 @@ type Carry struct {
Result chan interface{}
}
func (sender *BaseSender) Await(callback func(string, error) interface{}, params ...interface{}) {
func (_ *BaseSender) Await(sender Sender, callback func(string, error) interface{}, params ...interface{}) {
c := Carry{}
timeout := time.Second * 20
for _, param := range params {
+1 -1
View File
@@ -164,7 +164,7 @@ func initSys() {
old := b.Get(s.Get(1))
b.Set(s.Get(1), s.Get(2))
go func() {
s.Await(func(_ string, e error) interface{} {
s.Await(s, func(_ string, e error) interface{} {
if e != nil {
return nil
}