X-Git-Url: https://git.giacomolli.uk/onechat/blobdiff_plain/80e348724041a694002fc38f57e8868b9b9a2be9..c76d3832afce8da932860294d27bd167bf8a928c:/view.go?ds=sidebyside diff --git a/view.go b/view.go index 1b3ed6a..4a6e567 100644 --- a/view.go +++ b/view.go @@ -97,6 +97,105 @@ func (v *View) Append(tree ViewNodeReader) (bool, error) { return v.fit(tree) } +// load keeps the node of line when it is built, and tells if it is. +func (v *View) load(tree ViewNodeReader, line NodeKey) (bool, error) { + node, built, err := tree.Node(line.level, line.index) + if err != nil || !built { + return false, err + } + + v.nodes[line] = node + + return true, nil +} + +// fit merges the most due pairs while a batch runs, and tells if a merge +// changed the view. +func (v *View) fit(tree ViewNodeReader) (bool, error) { + size := v.Size() + if size > v.high { + v.merging = true + } + + merged := false + for v.merging && size > v.low { + best, err := v.mostDue(tree) + if err != nil || best < 0 { + return merged, err + } + + left, right := v.lines[best], v.lines[best+1] + parent := NodeKey{left.level + 1, left.index / 2} + _, err = v.load(tree, parent) + if err != nil { + return merged, err + } + + size += v.lineSize(parent) - v.lineSize(left) - v.lineSize(right) + delete(v.nodes, left) + delete(v.nodes, right) + + v.lines[best] = parent + v.lines = append(v.lines[:best+1], v.lines[best+2:]...) + merged = true + } + + v.merging = false + + return merged, nil +} + +// Size returns the sum of the line sizes. +func (v *View) Size() int { + size := 0 + for _, line := range v.lines { + size += v.lineSize(line) + } + + return size +} + +// mostDue returns the position of the left line of the most due sibling pair +// whose parent is built, or -1 when there is no such pair. +func (v *View) mostDue(tree ViewNodeReader) (int, error) { + best := -1 + bestDue := 0.0 + for n := 0; n+1 < len(v.lines); n++ { + left, right := v.lines[n], v.lines[n+1] + if left.index%2 != 0 || right.level != left.level || right.index != left.index+1 { + continue + } + + last := nodeEnd(right.level, right.index) - 1 + due := math.Ldexp(float64(v.end-last), -left.level) + if best >= 0 && due <= bestDue { + continue + } + + built, err := tree.Built(left.level+1, left.index/2) + if err != nil { + return -1, fmt.Errorf("check parent node: %w", err) + } + + if built { + best = n + bestDue = due + } + } + + return best, nil +} + +// lineSize returns the size of a view line. +func (v *View) lineSize(line NodeKey) int { + node, built := v.nodes[line] + if !built { + return len(viewPending) + } + + return node.Size +} + // Coarsen takes each merge of other, a view of the same messages, and then // merges in one batch until the size is at most low. Each line of the result is // the coarser of the two lines that start at its first message. Dyadic ranges @@ -191,76 +290,6 @@ func (v *View) LinesWithout(skip map[int]bool) []string { return lines } -// Context returns the lines of the view before message end as the model reads -// them. It stops at the first line that is not built, so a compaction never -// sees a pending mark or a part of a message. -func (v *View) Context(end int) string { - var text strings.Builder - - text.WriteString("\n") - - for _, line := range v.lines { - _, built := v.nodes[line] - if !built || nodeEnd(line.level, line.index) > end { - break - } - - v.renderLine(&text, line) - } - - text.WriteString("") - - return text.String() -} - -// load keeps the node of line when it is built, and tells if it is. -func (v *View) load(tree ViewNodeReader, line NodeKey) (bool, error) { - node, built, err := tree.Node(line.level, line.index) - if err != nil || !built { - return false, err - } - - v.nodes[line] = node - - return true, nil -} - -// fit merges the most due pairs while a batch runs, and tells if a merge -// changed the view. -func (v *View) fit(tree ViewNodeReader) (bool, error) { - size := v.Size() - if size > v.high { - v.merging = true - } - - merged := false - for v.merging && size > v.low { - best, err := v.mostDue(tree) - if err != nil || best < 0 { - return merged, err - } - - left, right := v.lines[best], v.lines[best+1] - parent := NodeKey{left.level + 1, left.index / 2} - _, err = v.load(tree, parent) - if err != nil { - return merged, err - } - - size += v.lineSize(parent) - v.lineSize(left) - v.lineSize(right) - delete(v.nodes, left) - delete(v.nodes, right) - - v.lines[best] = parent - v.lines = append(v.lines[:best+1], v.lines[best+2:]...) - merged = true - } - - v.merging = false - - return merged, nil -} - // renderLine writes one view line, "id+n|text", and a newline. func (v *View) renderLine(text *strings.Builder, line NodeKey) { body := viewPending @@ -277,55 +306,26 @@ func (v *View) renderLine(text *strings.Builder, line NodeKey) { text.WriteByte('\n') } -// Size returns the sum of the line sizes. -func (v *View) Size() int { - size := 0 - for _, line := range v.lines { - size += v.lineSize(line) - } - - return size -} - -// mostDue returns the position of the left line of the most due sibling pair -// whose parent is built, or -1 when there is no such pair. -func (v *View) mostDue(tree ViewNodeReader) (int, error) { - best := -1 - bestDue := 0.0 - for n := 0; n+1 < len(v.lines); n++ { - left, right := v.lines[n], v.lines[n+1] - if left.index%2 != 0 || right.level != left.level || right.index != left.index+1 { - continue - } +// Context returns the lines of the view before message end as the model reads +// them. It stops at the first line that is not built, so a compaction never +// sees a pending mark or a part of a message. +func (v *View) Context(end int) string { + var text strings.Builder - last := nodeEnd(right.level, right.index) - 1 - due := math.Ldexp(float64(v.end-last), -left.level) - if best >= 0 && due <= bestDue { - continue - } + text.WriteString("\n") - built, err := tree.Built(left.level+1, left.index/2) - if err != nil { - return -1, fmt.Errorf("check parent node: %w", err) + for _, line := range v.lines { + _, built := v.nodes[line] + if !built || nodeEnd(line.level, line.index) > end { + break } - if built { - best = n - bestDue = due - } + v.renderLine(&text, line) } - return best, nil -} - -// lineSize returns the size of a view line. -func (v *View) lineSize(line NodeKey) int { - node, built := v.nodes[line] - if !built { - return len(viewPending) - } + text.WriteString("") - return node.Size + return text.String() } // restoreView returns the view of state with the limits high and low. Each line