golang

mongo_write_exception.go

we, ok := err.(mongo.WriteException)
if ok {
	if strings.Contains(we.WriteErrors.Error(), "E11000") {

		if strings.HasPrefix(event.Data.Conversation.Protocol, "20220322") {
			event.Data.Conversation.Protocol = replaceAtIndex(event.Data.Conversation.Protocol, '3', 8)
			fmt.Printf("\nnew protocol: %s", event.Data.Conversation.Protocol)

			err := handler(event)
			if err != nil {
				log.Printf("\nerror save new event message: %s", err.Error())
				return
			}
			_ = message.Ack()
		}

		return
	}
}