Method _transform

lib/auth/streamingV4/V4Transform.js:189–288

* This function will parse the chunk into metadata and data, * use the metadata to authenticate with vault and send the * data on to be stored if authentication passes * * @param {Buffer} chunk - chunk from request body * @param {string} encoding - Data encoding * @para

(chunk, encoding, callback)

     * @return {function} executes callback with err if applicable
     */
    _transform(chunk, encoding, callback) {
        // 'chunk' here is the node streaming chunk
        // transfer-encoding chunks should be of the format:
        // string(IntHexBase(chunk-size)) + ";chunk-signature=" +
        // signature + \r\n + chunk-data + \r\n
        // Last transfer-encoding chunk will have size 0 and no chunk-data.

        // if there was an error earlier, ignore the remaining data
        if (this.clientError) {
            return callback();
        }
        if (this.lastPieceDone) {
            const slice = chunk.slice(0, 10);
            this.log.trace('received chunk after end.' +
            'See first 10 bytes of chunk',
            { chunk: slice.toString() });
            return callback();
        }
        let unparsedChunk = chunk;
        let chunkLeftToEvaluate = true;
        return async.whilst(
            // test function
            () => chunkLeftToEvaluate,
            // async function
            done => {
                if (!this.haveMetadata) {
                    this.log.trace('do not have metadata so calling ' +
                    '_parseMetadata');
                    // need to parse our metadata
                    const parsedMetadataResults =
                        this._parseMetadata(unparsedChunk);
                    if (parsedMetadataResults.err) {
                        return done(parsedMetadataResults.err);
                    }
                    // if do not have full metadata get next chunk
                    if (!parsedMetadataResults.completeMetadata) {
                        chunkLeftToEvaluate = false;
                        return done();
                    }
                    // have metadata so reset unparsedChunk to remaining
                    // without metadata piece
                    unparsedChunk = parsedMetadataResults.unparsedChunk;
                }
                if (this.lastChunk) {
                    this.log.trace('authenticating final chunk with no data');
                    return this._authenticate(null, err => {
                        if (err) {
                            return done(err);
                        }
                        chunkLeftToEvaluate = false;
                        this.lastPieceDone = true;
                        return done();
                    });
                }
                if (unparsedChunk.length < this.seekingDataSize) {
                    // add chunk to currentData and get next chunk
                    unparsedChunk.copy(this.currentData, this.dataCursor);
                    this.dataCursor += unparsedChunk.length;