package com.github.scribejava.core.utils;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.Reader;

import java.util.zip.GZIPInputStream;

/**

* Utils to deal with Streams.

*/

public abstract class StreamUtils {

/**

* Returns the stream contents as an UTF-8 encoded string

*

* @param is input stream

* @return string contents

*/

public static String getStreamContents(InputStream is) {

Preconditions.checkNotNull(is, "Cannot get String from a null object");

try {

final char[] buffer = new char[0x10000];

final StringBuilder out = new StringBuilder();

try (Reader in = new InputStreamReader(is, "UTF-8")) {

int read;

do {

read = in.read(buffer, 0, buffer.length);

if (read > 0) {

out.append(buffer, 0, read);

}

} while (read >= 0);

}

return out.toString();

} catch (IOException ioe) {

throw new IllegalStateException("Error while reading response body", ioe);

}

}

/**

* Return String content from a gzip stream

*

* @param is input stream

* @return string contents

*/

public static String getGzipStreamContents(InputStream is) {

Preconditions.checkNotNull(is, "Cannot get String from a null object");

try {

final GZIPInputStream gis = new GZIPInputStream(is);

return getStreamContents(gis);

} catch (IOException ioe) {

throw new IllegalStateException("Error while reading response body", ioe);

}

}

}