package main

import "net/http"

//
//InWechatMsg  what we received currently from wechat
type InWechatMsg struct {
	header          CommonHeader
	body            interface{} //dynamic type
	req             *http.Request
	instantResponse chan string //instance reply channel
}

func (m *InWechatMsg) init() {
	m.instantResponse = make(chan string)
}

func (m *InWechatMsg) destroy() {
	close(m.instantResponse)
}

func (m *InWechatMsg) replyXML(xml string) {
	m.instantResponse <- xml
}

func (m *InWechatMsg) replyText(s string) {
	str, _ := BuildTextMsg(m.header.FromUserName, s)
	m.instantResponse <- str
}

func (m *InWechatMsg) transfer2KF() {
	str, _ := BuildKFTransferAnyOneMsg(m.header.FromUserName)
	m.replyXML(str)
}

func (m *InWechatMsg) transfer2SpecificKF(kf string) {
	str := buildKfForwardMsg(m.header.FromUserName, kf)
	m.replyXML(str)
}