Function ParseMessage

notification/sender/notification_message.go:29–76

ParseMessage parses a notification message string into a Message structure.

(ctx context.Context, in io.Reader)

// ParseMessage parses a notification message string into a Message structure.
func ParseMessage(ctx context.Context, in io.Reader) (*Message, error) {
	var bodyLines []string

	// parse headers until we encounter "MarkdownBody:" or an empty line.
	sr := bufio.NewScanner(in)

	msg := &Message{
		Headers: map[string]string{},
	}

	for sr.Scan() {
		line := sr.Text()

		if line == "" {
			// no more headers after that
			break
		}

		if strings.HasPrefix(line, "Subject:") {
			msg.Subject = strings.TrimSpace(line[len("Subject:"):])
			continue
		}

		// parse headers
		const numParts = 2

		parts := strings.SplitN(line, ":", numParts)
		if len(parts) != numParts {
			log(ctx).Warnw("invalid header line in notification template", "line", line)
			continue
		}

		msg.Headers[strings.TrimSpace(parts[0])] = strings.TrimSpace(parts[1])
	}

	for sr.Scan() {
		line := sr.Text()
		bodyLines = append(bodyLines, line)
	}

	msg.Body = strings.Join(bodyLines, "\n")

	if len(bodyLines) == 0 {
		return nil, errors.New("no body found in message")
	}

	return msg, errors.Wrap(sr.Err(), "error reading message")
}

// ToString returns a string representation of the message.
func (m Message) ToString() string {