Function jsonDecompressTrace

lib/wire.go:237–490

jsonDecompressTrace decompresses with optional verbose debugging output

(compressed []byte, trace bool)

// jsonDecompressTrace decompresses with optional verbose debugging output
func jsonDecompressTrace(compressed []byte, trace bool) (normal []byte, err error) {
	if trace {
		fmt.Printf("\n  >>> Entering jsonDecompress with %d bytes\n", len(compressed))
		fmt.Printf("  First 16 bytes: % x\n", compressed[:min(len(compressed), 16)])
	}

	// Remove header byte
	if len(compressed) == 0 {
		err = fmt.Errorf("json decompression error: 0-length data")
		if trace {
			fmt.Printf("  ERROR: 0-length data\n")
		}
		return nil, err
	}

	compressionType := compressed[0]
	if trace {
		fmt.Printf("  Compression type: 0x%02x", compressionType)
		switch compressionType {
		case jc0:
			fmt.Printf(" (jc0 - no compression)\n")
		case jc1:
			fmt.Printf(" (jc1 - JSON string substitution only)\n")
		case jc2:
			fmt.Printf(" (jc2 - JSON string substitution + Snappy)\n")
		case jc3:
			fmt.Printf(" (jc3 - Custom subst table + JSON string substitution + Snappy)\n")
		default:
			fmt.Printf(" (UNKNOWN!)\n")
		}
	}

	compressed = compressed[1:]
	if trace {
		fmt.Printf("  After removing header: %d bytes\n", len(compressed))
	}

	// Dispatch based on compression type
	if compressionType == jc0 {
		normal = compressed
		if trace {
			fmt.Printf("  No decompression needed, returning %d bytes\n", len(normal))
			fmt.Printf("  <<< Exiting jsonDecompress\n")
		}

		// Debug
		if debugCompress {
			logDebug(context.Background(), "No decompression (%d)", len(normal))
		}
		return
	}

	if debugCompress {
		logDebug(context.Background(), " Removed header byte from %d to %d", len(compressed)+1, len(compressed))
	}

	sdecompressed := compressed
	if compressionType == jc1 {