Function decodeHeader

cache/filesystem_cache.go:138–165

decodeHeader decodes header from raw byte stream. Data is encoded as follows: length(contentType)|contentType|length(contentEncoding)|contentEncoding|length(contentLength)|contentLength|cachedData

(reader io.Reader)

// decodeHeader decodes header from raw byte stream. Data is encoded as follows:
// length(contentType)|contentType|length(contentEncoding)|contentEncoding|length(contentLength)|contentLength|cachedData
func decodeHeader(reader io.Reader) (*ContentMetadata, error) {
	contentType, err := readHeader(reader)
	if err != nil {
		return nil, fmt.Errorf("cannot read Content-Type from provided reader: %w", err)
	}

	contentEncoding, err := readHeader(reader)
	if err != nil {
		return nil, fmt.Errorf("cannot read Content-Encoding from provided reader: %w", err)
	}

	contentLengthStr, err := readHeader(reader)
	if err != nil {
		return nil, fmt.Errorf("cannot read Content-Encoding from provided reader: %w", err)
	}

	contentLength, err := strconv.Atoi(contentLengthStr)
	if err != nil {
		log.Errorf("found corrupted content length %s", err)
		contentLength = 0
	}

	return &ContentMetadata{
		Length:   int64(contentLength),
		Type:     contentType,
		Encoding: contentEncoding,
	}, nil
}

func (f *fileSystemCache) Put(r io.Reader, contentMetadata ContentMetadata, key *Key) (time.Duration, error) {
	fp := key.filePath(f.dir)