bbgo_origin/pkg/bbgo/interact.go

94 lines
1.7 KiB
Go
Raw Normal View History

2022-01-11 18:54:13 +00:00
package bbgo
import (
"reflect"
"strconv"
2022-01-12 09:49:34 +00:00
"strings"
"text/scanner"
2022-01-11 18:54:13 +00:00
"gopkg.in/tucnak/telebot.v2"
)
// Interact implements the interaction between bot and message software.
type Interact struct {
Commands map[string]func()
}
func (i *Interact) HandleTelegramMessage(msg *telebot.Message) {
}
2022-01-12 09:49:34 +00:00
func parseCommand(src string) (args []string) {
2022-01-11 18:54:13 +00:00
var s scanner.Scanner
2022-01-12 09:49:34 +00:00
s.Init(strings.NewReader(src))
s.Filename = "command"
for tok := s.Scan(); tok != scanner.EOF; tok = s.Scan() {
text := s.TokenText()
if text[0] == '"' && text[len(text) - 1] == '"' {
text, _ = strconv.Unquote(text)
2022-01-11 18:54:13 +00:00
}
2022-01-12 09:49:34 +00:00
args = append(args,text)
2022-01-11 18:54:13 +00:00
}
2022-01-12 09:49:34 +00:00
return args
2022-01-11 18:54:13 +00:00
}
func parseFuncArgsAndCall(f interface{}, args []string) error {
fv := reflect.ValueOf(f)
ft := reflect.TypeOf(f)
var rArgs []reflect.Value
for i := 0; i < ft.NumIn(); i++ {
at := ft.In(i)
switch k := at.Kind(); k {
case reflect.String:
av := reflect.ValueOf(args[i])
rArgs = append(rArgs, av)
case reflect.Bool:
bv, err := strconv.ParseBool(args[i])
if err != nil {
return err
}
av := reflect.ValueOf(bv)
rArgs = append(rArgs, av)
case reflect.Int64:
nf, err := strconv.ParseInt(args[i], 10, 64)
if err != nil {
return err
}
av := reflect.ValueOf(nf)
rArgs = append(rArgs, av)
case reflect.Float64:
nf, err := strconv.ParseFloat(args[i], 64)
if err != nil {
return err
}
av := reflect.ValueOf(nf)
rArgs = append(rArgs, av)
}
}
out := fv.Call(rArgs)
if ft.NumOut() > 0 {
outType := ft.Out(0)
switch outType.Kind() {
case reflect.Interface:
o := out[0].Interface()
switch ov := o.(type) {
case error:
return ov
}
}
}
return nil
}