chtwrs/chirpnest
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

test

Browse Source
This commit is contained in:
shoopea 2020-10-17 16:13:19 +02:00
parent 291bea074a
commit f878f9aab9
3 changed files with 39 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
def.go
View File

@ -416,6 +416,18 @@ type ChatWarsMessageShopMainReq struct {
Link string `json:"link"`
}
type ChatWarsMessageGListAck struct {
Msg *ChatWarsMessage `json:"msg"`
}
type ChatWarsMessageGDefListAck struct {
Msg *ChatWarsMessage `json:"msg"`
}
type ChatWarsMessageGAtkListAck struct {
Msg *ChatWarsMessage `json:"msg"`
}
type ChatWarsMessageShopMainAck struct {
Msg *ChatWarsMessage `json:"msg"`
Name string `json:"name"`

18
msg.go
View File

@ -467,6 +467,24 @@ func parseSubTypeMessageShopMainAck(m *ChatWarsMessage, r *regexp.Regexp) (*Chat
return &cwm, nil
}
func parseSubTypeMessageGListAck(m *ChatWarsMessage, r *regexp.Regexp) (*ChatWarsMessageGListAck, error) {
cwm := ChatWarsMessageGListAck{}
cwm.Msg = m
return &cwm, nil
}
func parseSubTypeMessageGDefListAck(m *ChatWarsMessage, r *regexp.Regexp) (*ChatWarsMessageGDefListAck, error) {
cwm := ChatWarsMessageGDefListAck{}
cwm.Msg = m
return &cwm, nil
}
func parseSubTypeMessageGAtkListAck(m *ChatWarsMessage, r *regexp.Regexp) (*ChatWarsMessageGAtkListAck, error) {
cwm := ChatWarsMessageGAtkListAck{}
cwm.Msg = m
return &cwm, nil
}
func parseSubTypeMessageMeAck(m *ChatWarsMessage, r *regexp.Regexp) (*ChatWarsMessageMeAck, error) {
var (
i int64

15
workers.go
View File

@ -559,6 +559,15 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) {
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_shop_main_ack`]")
err = insertMsgShopMainAck(cwm)
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : insertMsgShopMainAck")
case cacheObjSubType[`msg_g_list_req`]:
case cacheObjSubType[`msg_g_list_ack`]:
_, err := parseSubTypeMessageGListAck(m, rule.re)
case cacheObjSubType[`msg_g_atklist_req`]:
case cacheObjSubType[`msg_g_atklist_ack`]:
_, err := parseSubTypeMessageGAtkListAck(m, rule.re)
case cacheObjSubType[`msg_g_deflist_req`]:
case cacheObjSubType[`msg_g_deflist_ack`]:
_, err := parseSubTypeMessageGDefListAck(m, rule.re)
case cacheObjSubType[`msg_bot_user_config`]:
botUserConfig(m)
case cacheObjSubType[`msg_bot_user_config_pillage_on`]:
@ -590,12 +599,6 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) {
botVaultValOth(m)
case cacheObjSubType[`msg_refresh_cmd`]:
botRefreshMsg(m, rule.re)
case cacheObjSubType[`msg_g_list_req`]:
case cacheObjSubType[`msg_g_list_ack`]:
case cacheObjSubType[`msg_g_atklist_req`]:
case cacheObjSubType[`msg_g_atklist_ack`]:
case cacheObjSubType[`msg_g_deflist_req`]:
case cacheObjSubType[`msg_g_deflist_ack`]:
default:
//log.Printf("SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Unknwon message type in rule %d : %d (%d)\n%s\n", msgParsingRules[i].ID, msgParsingRules[i].MsgTypeID64, objId, m.Text)
}