Method WriteDebugCacheSnapshot

dagql/cache_debug.go:1066–1586

nolint:gocyclo // intrinsically long state machine; refactoring would hurt clarity

(w io.Writer)

//nolint:gocyclo // intrinsically long state machine; refactoring would hurt clarity
func (c *Cache) WriteDebugCacheSnapshot(w io.Writer) error {
	sessionResults := c.debugSessionResultsSnapshot()
	c.callsMu.Lock()
	c.egraphMu.RLock()
	defer c.egraphMu.RUnlock()
	defer c.callsMu.Unlock()

	bw := bufio.NewWriterSize(w, 128<<10)

	writeValue := func(v any) error {
		bs, err := json.Marshal(v)
		if err != nil {
			return err
		}
		_, err = bw.Write(bs)
		return err
	}

	topFieldCount := 0
	writeField := func(name string) error {
		if topFieldCount > 0 {
			if _, err := bw.WriteString(","); err != nil {
				return err
			}
		}
		topFieldCount++
		if err := writeValue(name); err != nil {
			return err
		}
		_, err := bw.WriteString(":")
		return err
	}

	writeArrayField := func(name string, writeElems func(func(any) error) error) error {
		if err := writeField(name); err != nil {
			return err
		}
		if _, err := bw.WriteString("["); err != nil {
			return err
		}
		elemCount := 0
		if err := writeElems(func(v any) error {
			if elemCount > 0 {
				if _, err := bw.WriteString(","); err != nil {
					return err
				}
			}
			elemCount++
			return writeValue(v)
		}); err != nil {
			return err
		}
		_, err := bw.WriteString("]")
		return err
	}

	if _, err := bw.WriteString("{"); err != nil {
		return err