diff --git a/msg.go b/msg.go index 2abb9a4..6cd54b1 100644 --- a/msg.go +++ b/msg.go @@ -18,7 +18,7 @@ func getMsgParsingRule(m *ChatWarsMessage) (*MessageParsingRule, error) { if i == len(msgParsingRules) { return nil, errors.New("Can't find message type in rules.") } else { - return msgParsingRules[i], nil + return &msgParsingRules[i], nil } } diff --git a/workers.go b/workers.go index c88fd3e..b89f3f4 100644 --- a/workers.go +++ b/workers.go @@ -359,7 +359,6 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) { case objSubTypeMessageBuyReq: case objSubTypeMessageSellReq: case objSubTypeMessageOrderbookReq: - case objSubTypeMessageOrderbookAck: case objSubTypeMessageWithdrawReq: case objSubTypeMessageWithdrawCode: case objSubTypeMessageWithdrawRcv: @@ -457,7 +456,7 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) { } } case objSubTypeMessageTimeAck: - _, err := fromChatWarsDate(r.ReplaceAllString(m.Text, "${Day}") + " " + r.ReplaceAllString(m.Text, "${Month}") + " " + r.ReplaceAllString(m.Text, "${Year}") + " " + r.ReplaceAllString(m.Text, "${Hour}") + ":" + r.ReplaceAllString(m.Text, "${Minute}")) + _, err := fromChatWarsDate(rule.re.ReplaceAllString(m.Text, "${Day}") + " " + rule.re.ReplaceAllString(m.Text, "${Month}") + " " + rule.re.ReplaceAllString(m.Text, "${Year}") + " " + rule.re.ReplaceAllString(m.Text, "${Hour}") + ":" + rule.re.ReplaceAllString(m.Text, "${Minute}")) logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : fromChatWarsDate") case objSubTypeMessageOrderbookAck: cwm, err := parseSubTypeMessageOrderbookAck(m, rule.re)