Function ParseMessageElements

message/message.go:144–437

(msg []*message.Elem)

}

func ParseMessageElements(msg []*message.Elem) []IMessageElement {
	var res []IMessageElement
	skipNext := false

	for _, elem := range msg {
		if skipNext {
			skipNext = false
			continue
		}
		if elem.SrcMsg != nil && len(elem.SrcMsg.OrigSeqs) != 0 {
			res = append(res, &ReplyElement{
				ReplySeq:  elem.SrcMsg.OrigSeqs[0],
				Time:      uint32(elem.SrcMsg.Time.Unwrap()),
				SenderUin: uint32(elem.SrcMsg.SenderUin),
				GroupUin:  uint32(elem.SrcMsg.ToUin.Unwrap()),
				Elements:  ParseMessageElements(elem.SrcMsg.Elems),
			})
		}

		if elem.Text != nil {
			if len(elem.Text.Attr6Buf) > 0 {
				att6 := binary.NewReader(elem.Text.Attr6Buf)
				att6.SkipBytes(7)
				target := att6.ReadU32()
				at := NewAt(target, elem.Text.Str.Unwrap())
				at.SubType = AtTypeGroupMember
				res = append(res, at)
			} else {
				res = append(res, NewText(func() string {
					if strings.Contains(elem.Text.Str.Unwrap(), "\r") && !strings.Contains(elem.Text.Str.Unwrap(), "\r\n") {
						return strings.ReplaceAll(elem.Text.Str.Unwrap(), "\r", "\r\n")
					}
					return elem.Text.Str.Unwrap()
				}()))
			}
		}

		if elem.Face != nil {
			if len(elem.Face.Old) > 0 {
				faceID := elem.Face.Index
				if faceID.IsSome() {
					res = append(res, &FaceElement{FaceID: uint32(faceID.Unwrap())})
				}
			} else if elem.CommonElem != nil && elem.CommonElem.PbElem != nil {
				if elem.CommonElem.ServiceType == 37 {
					qFace := message.QFaceExtra{}
					if err := proto.Unmarshal(elem.CommonElem.PbElem, &qFace); err == nil {
						if qFace.Qsid.IsSome() {
							res = append(res, &FaceElement{FaceID: uint32(qFace.Qsid.Unwrap()), isLargeFace: true})
						}
					}
				} else if elem.CommonElem.ServiceType == 33 {
					qFace := message.QSmallFaceExtra{}
					err := proto.Unmarshal(elem.CommonElem.PbElem, &qFace)
					if err == nil {
						res = append(res, &FaceElement{FaceID: qFace.FaceId, isLargeFace: false})
					}
				}