Function formatEncodedJSONObject

pkg/util/json/encoded_format.go:119–188

(buf *bytes.Buffer, containerHeader uint32, b []byte)

}

func formatEncodedJSONObject(buf *bytes.Buffer, containerHeader uint32, b []byte) ([]byte, error) {
	length := int(containerHeader & containerHeaderLenMask)

	// There are `length` key JEntries and then `length` value JEntries in the
	// object.
	keyOff, valOff := uint32(0), uint32(0)
	keyEntB, valEntB := b, b
	// Skip past the key JEntries to find the first value JEntry, permitting
	// parallel iteration through the key JEntries, value JEntries, keys, and
	// values below.
	var err error
	for i := 0; i < length; i++ {
		// Decode (and ignore) key JEntry.
		var keyEnt jEntry
		valEntB, keyEnt, err = decodeJEntry(valEntB, valOff)
		if err != nil {
			return nil, err
		}
		if keyEnt.typCode != stringTag {
			return nil, errors.AssertionFailedf(
				"key encoded as non-string: %d", errors.Safe(keyEnt.typCode))
		}
		valOff += keyEnt.length
	}
	// Skip past the value JEntries to find the first key.
	valEntsSize := jEntrySize * length
	if len(valEntB) < valEntsSize {
		return nil, errors.AssertionFailedf("insufficient data to skip JSON object value JEntries")
	}
	keyB := valEntB[valEntsSize:]
	// Skip past the keys to find the first value.
	if len(keyB) < int(valOff) {
		return nil, errors.AssertionFailedf("insufficient data to skip JSON object keys")
	}
	valB := keyB[valOff:]

	// Iterate through the keys and values in parallel, formatting them.
	buf.WriteByte('{')
	for i := 0; i < length; i++ {
		if i != 0 {
			buf.WriteString(", ")
		}
		// Decode key JEntry i.
		var keyEnt jEntry
		keyEntB, keyEnt, err = decodeJEntry(keyEntB, keyOff)
		if err != nil {
			return nil, err
		}
		keyOff += keyEnt.length
		// Decode value JEntry i.
		var valEnt jEntry
		valEntB, valEnt, err = decodeJEntry(valEntB, valOff)
		if err != nil {
			return nil, err
		}
		valOff += valEnt.length
		// Decode and format key i.
		keyS := unsafeJSONString(keyB[:keyEnt.length])