md2gmi/mdproc/preproc.go

package mdproc

import (
	"bytes"
	"regexp"

	"gitrepo.ru/neonxp/md2gmi/pipe"
)

// state function.
type stateFn func(*fsm, []byte) stateFn

// state machine.
type fsm struct {
	state stateFn

	i   int
	out chan pipe.StreamItem

	// combining multiple input lines
	multiLineBlockMode int
	blockBuffer        []byte
	sendBuffer         []byte
	// if we have a termination rule to abide, e.g. implied code fences
	pending []byte
}

func Preprocessor() pipe.Pipeline {
	return (&fsm{}).pipeline
}

func (m *fsm) pipeline(in chan pipe.StreamItem) chan pipe.StreamItem {
	m.out = make(chan pipe.StreamItem)

	go func() {
		for m.state = normal; m.state != nil; {
			b, ok := <-in
			if !ok {
				m.blockFlush()
				m.sync()
				close(m.out)
				m.state = nil

				continue
			}

			m.state = m.state(wrap(m, b.Payload()))
			m.sync()
		}
	}()

	return m.out
}

func wrap(m *fsm, data []byte) (*fsm, []byte) {
	var scount, ecount int
	if scount = countStart(data, "<!--"); scount > 0 {
		m.multiLineBlockMode += scount
	}

	if ecount = countEnd(data, "-->"); ecount > 0 {
		m.multiLineBlockMode -= ecount
	}

	// clip entire line if no control sequences present
	if (m.multiLineBlockMode > 0 && scount == 0 && ecount == 0) || m.multiLineBlockMode > 1 {
		data = data[:0]
		return m, data
	}

	// clip data past first occurrence
	if scount > 0 {
		data = data[:bytes.Index(data, []byte("<!--"))]
	}

	// clip data past last occurrence
	if ecount = countEnd(data, "-->"); ecount > 0 {
		data = data[bytes.LastIndex(data, []byte("-->"))+3:]
	}

	return m, data
}

func countStart(data []byte, pattern string) int {
	return bytes.Count(data, []byte(pattern))
}

func countEnd(data []byte, pattern string) int {
	return bytes.Count(data, []byte(pattern))
}

func (m *fsm) sync() {
	if len(m.sendBuffer) > 0 {
		m.sendBuffer = append(m.sendBuffer, '\n')
		m.out <- pipe.NewItem(m.i, m.sendBuffer)
		m.sendBuffer = m.sendBuffer[:0]
		m.i++
	}
}

func (m *fsm) softBlockFlush() {
	if m.multiLineBlockMode > 0 {
		return
	}

	m.blockFlush()
}

func (m *fsm) blockFlush() {
	// blockBuffer to sendbuffer
	m.sendBuffer = append(m.sendBuffer, m.blockBuffer...)
	m.blockBuffer = m.blockBuffer[:0]

	// pending to sendbuffer too
	if len(m.pending) > 0 {
		m.sendBuffer = append(m.sendBuffer, m.pending...)
		m.pending = m.pending[:0]
	}
}

func isTerminated(data []byte) bool {
	return len(data) > 0 && data[len(data)-1] != '.'
}

func triggerBreak(data []byte) bool {
	if len(data) == 0 || len(data) == 1 && data[0] == '\n' {
		return true
	}

	switch data[len(data)-1] {
	case '.':
		fallthrough
	case ';':
		fallthrough
	case ':':
		return true
	}

	return false
}

func handleList(data []byte) ([]byte, bool) {
	// match italic, bold
	nolist := regexp.MustCompile(`[\*_](.*)[\*_]`)
	nosub := nolist.FindSubmatch(data)
	// match lists
	list := regexp.MustCompile(`^([ \t]*[-*^]{1,1})[^*-]`)
	sub := list.FindSubmatch(data)
	// if lists, collapse to single level
	if len(sub) > 1 && len(nosub) <= 1 {
		return bytes.Replace(data, sub[1], []byte("-"), 1), true
	}

	return data, false
}

func hasFence(data []byte) bool {
	return bytes.Contains(data, []byte("```"))
}

func needsFence(data []byte) bool {
	return len(data) >= 4 && string(data[0:4]) == "    "
}

func normalText(m *fsm, data []byte) stateFn {
	if len(bytes.TrimSpace(data)) == 0 {
		return normal
	}

	if data, isList := handleList(data); isList {
		m.blockBuffer = append(m.blockBuffer, data...)
		m.softBlockFlush()

		return list
	}

	if hasFence(data) {
		m.blockBuffer = append(data, '\n')

		return fence
	}

	if needsFence(data) {
		m.blockBuffer = append(m.blockBuffer, []byte("```\n")...)
		m.blockBuffer = append(m.blockBuffer, append(data[4:], '\n')...)
		m.pending = []byte("```\n")

		return toFence
	}

	if isTerminated(data) {
		m.blockBuffer = append(m.blockBuffer, data...)
		m.blockBuffer = append(m.blockBuffer, ' ')

		return paragraph
	}

	m.blockBuffer = append(m.blockBuffer, append(data, '\n')...)
	m.softBlockFlush()

	return normal
}

func normal(m *fsm, data []byte) stateFn {
	return normalText(m, data)
}

func list(m *fsm, data []byte) stateFn {
	if data, isList := handleList(data); isList {
		data = append(data, '\n')
		m.blockBuffer = append(m.blockBuffer, data...)

		return list
	}

	m.softBlockFlush()

	return normalText(m, data)
}

func fence(m *fsm, data []byte) stateFn {
	m.blockBuffer = append(m.blockBuffer, append(data, '\n')...)
	// second fence returns to normal
	if hasFence(data) {
		m.softBlockFlush()

		return normal
	}

	return fence
}

func toFence(m *fsm, data []byte) stateFn {
	if needsFence(data) {
		data = append(data, '\n')
		m.blockBuffer = append(m.blockBuffer, data[4:]...)

		return toFence
	}

	m.softBlockFlush()

	return normalText(m, data)
}

func paragraph(m *fsm, data []byte) stateFn {
	if triggerBreak(data) {
		m.blockBuffer = append(m.blockBuffer, data...)
		m.blockBuffer = bytes.TrimSpace(m.blockBuffer)
		// TODO, remove double spaces inside paragraphs
		m.blockBuffer = append(m.blockBuffer, '\n')
		m.softBlockFlush()

		return normal
	}

	m.blockBuffer = append(m.blockBuffer, data...)
	m.blockBuffer = append(m.blockBuffer, []byte(" ")...)

	return paragraph
}