org.scribe.model.Response类的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(8.9k)|赞(0)|评价(0)|浏览(111)

本文整理了Java中org.scribe.model.Response类的一些代码示例,展示了Response类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Response类的具体详情如下:
包路径:org.scribe.model.Response
类名称:Response

Response介绍

[英]Represents an HTTP Response.
[中]表示HTTP响应。

代码示例

代码示例来源:origin: google/data-transfer-project

private <T> SmugMugResponse<T> makeRequest(
  String url, TypeReference<SmugMugResponse<T>> typeReference) throws IOException {
 // Note: there are no request params that need to go here, because smugmug fully specifies
 // which resource to get in the URL of a request, without using query params.
 String fullUrl;
 if (!url.contains("https://")) {
  fullUrl = BASE_URL + url;
 } else {
  fullUrl = url;
 }
 OAuthRequest request =
   new OAuthRequest(Verb.GET, fullUrl + "?_accept=application%2Fjson");
 oAuthService.signRequest(accessToken, request);
 final Response response = request.send();
 if (response.getCode() < 200 || response.getCode() >= 300) {
  throw new IOException(
    String.format("Error occurred in request for %s : %s", url, response.getMessage()));
 }
 String result = response.getBody();
 return mapper.readValue(result, typeReference);
}

代码示例来源:origin: google/data-transfer-project

public InputStream getImageAsStream(String urlStr) {
 OAuthRequest request = new OAuthRequest(Verb.GET, urlStr);
 oAuthService.signRequest(accessToken, request);
 final Response response = request.send();
 return response.getStream();
}

代码示例来源:origin: tumblr/jumblr

/**
 * Instantiate a new JumblrException given a bad response to wrap
 * @param response the response to wrap
 */
public JumblrException(Response response) {
  this.responseCode = response.getCode();
  String body = response.getBody();
  JsonParser parser = new JsonParser();
  try {
    final JsonElement element = parser.parse(body);
    if (element.isJsonObject()) {
      JsonObject object = element.getAsJsonObject();
      this.extractMessage(object);
      this.extractErrors(object);
    } else {
      this.message = body;
    }
  } catch (JsonParseException ex) {
    this.message = body;
  }
}

代码示例来源:origin: multidots/android-app-common-tasks

@Override
    protected Void doInBackground(String... params) {
      System.out.println("001 OauthEnd doInBackground-->" + params[0]);
      String url = params[0];
      if (url.contains("user_refused")) {
        setResult(RESULT_CANCELED);
        finish();
      } else {
        final Uri uri = Uri.parse(url);
        final String verifier = uri.getQueryParameter("oauth_verifier");
        final Verifier v = new Verifier(verifier);
        System.out.println("hp Verifier>>>> " + v.getValue());
        final Token accessToken = oas_linkedin.getAccessToken(requestToken,
            v);
        final OAuthRequest request = new OAuthRequest(Verb.GET,
            PROTECTED_RESOURCE_URL);
        oas_linkedin.signRequest(accessToken, request);
        Response response = request.send();

//                TODO JSON response in intent RESPONSE
        Intent intent = new Intent();
        intent.putExtra("RESPONSE", response.getBody());
        setResult(RESULT_OK, intent);
        finish();
      }
      return null;
    }
  }

代码示例来源:origin: hoverruan/weiboclient4j

public static <T> List<T> parseJsonObject(Response response, TypeReference<List<T>> type)
    throws WeiboClientException {
  if (response.isSuccessful()) {
    return parseJsonObject(response.getCode(), response.getBody(), type);
  } else {
    throw createException(response);
  }
}

代码示例来源:origin: de.esoco/esoco-oauth

/***************************************
 * {@inheritDoc}
 */
@Override
public int getCode()
{
  return rResponse.getCode();
}

代码示例来源:origin: tumblr/jumblr

public String getRedirectUrl(String path) {
  OAuthRequest request = this.constructGet(path, null);
  sign(request);
  boolean presetVal = HttpURLConnection.getFollowRedirects();
  HttpURLConnection.setFollowRedirects(false);
  Response response = request.send();
  HttpURLConnection.setFollowRedirects(presetVal);
  if (response.getCode() == 301 || response.getCode() == 302) {
    return response.getHeader("Location");
  } else {
    throw new JumblrException(response);
  }
}

代码示例来源:origin: org.scribe/scribe

Response(HttpURLConnection connection) throws IOException
{
 try
 {
  connection.connect();
  code = connection.getResponseCode();
  message = connection.getResponseMessage();
  headers = parseHeaders(connection);
  stream = isSuccessful() ? connection.getInputStream() : connection.getErrorStream();
 }
 catch (UnknownHostException e)
 {
  throw new OAuthException("The IP address of a host could not be determined.", e);
 }
}

代码示例来源:origin: org.scribe/scribe-up

Response doSend() throws IOException {
  this.connection.setRequestMethod(this.verb.name());
  if (this.connectTimeout != null) {
    this.connection.setConnectTimeout(this.connectTimeout.intValue());
  }
  if (this.readTimeout != null) {
    this.connection.setReadTimeout(this.readTimeout.intValue());
  }
  addHeaders(this.connection);
  if (this.verb.equals(Verb.PUT) || this.verb.equals(Verb.POST)) {
    addBody(this.connection, getByteBodyContents());
  }
  return new Response(this.connection);
}

代码示例来源:origin: tumblr/jumblr

/* package-visible for testing */ ResponseWrapper clear(Response response) {
  if (response.getCode() == 200 || response.getCode() == 201) {
    String json = response.getBody();
    try {
      Gson gson = new GsonBuilder().
          registerTypeAdapter(JsonElement.class, new JsonElementDeserializer()).
          create();
      ResponseWrapper wrapper = gson.fromJson(json, ResponseWrapper.class);
      if (wrapper == null) {
        throw new JumblrException(response);
      }
      wrapper.setClient(client);
      return wrapper;
    } catch (JsonSyntaxException ex) {
      throw new JumblrException(response);
    }
  } else {
    throw new JumblrException(response);
  }
}

代码示例来源:origin: multidots/android-app-common-tasks

@Override
    protected Void doInBackground(String... params) {
      System.out.println("001 OauthEnd doInBackground-->" + params[0]);
      String url = params[0];
      if (url.contains("user_refused")) {
        setResult(RESULT_CANCELED);
        finish();
      } else {
        final Uri uri = Uri.parse(url);
        final String verifier = uri.getQueryParameter("oauth_verifier");
        final Verifier v = new Verifier(verifier);
        System.out.println("hp Verifier>>>> " + v.getValue());
        final Token accessToken = oas_linkedin.getAccessToken(requestToken,
            v);
        final OAuthRequest request = new OAuthRequest(Verb.GET,
            PROTECTED_RESOURCE_URL);
        oas_linkedin.signRequest(accessToken, request);
        Response response = request.send();

//                TODO JSON response in intent RESPONSE
        Intent intent = new Intent();
        intent.putExtra("RESPONSE", response.getBody());
        setResult(RESULT_OK, intent);
        finish();
      }
      return null;
    }
  }

代码示例来源:origin: hoverruan/weiboclient4j

public static <T> T parseJsonObject(Response response, Class<T> clazz) throws WeiboClientException {
  if (response.isSuccessful()) {
    return parseJsonObject(response.getCode(), response.getBody(), clazz);
  } else {
    throw createException(response);
  }
}

代码示例来源:origin: org.scribe/scribe

public boolean isSuccessful()
{
 return getCode() >= 200 && getCode() < 400;
}

代码示例来源:origin: org.scribe/scribe

Response doSend(RequestTuner tuner) throws IOException
{
 connection.setRequestMethod(this.verb.name());
 if (connectTimeout != null) 
 {
  connection.setConnectTimeout(connectTimeout.intValue());
 }
 if (readTimeout != null)
 {
  connection.setReadTimeout(readTimeout.intValue());
 }
 addHeaders(connection);
 if (verb.equals(Verb.PUT) || verb.equals(Verb.POST))
 {
  addBody(connection, getByteBodyContents());
 }
 tuner.tune(this);
 return new Response(connection);
}

代码示例来源:origin: hburgmeier/jerseyoauth2

protected void throwClientException(Response response) throws ClientException
{
  int code = response.getCode();
  String body = response.getBody();
  throw new ClientException(Integer.toString(code)+" "+body);
}

代码示例来源:origin: bill1012/AdminEAP

@Override
public OAuthUser getOAuthUser(Token accessToken) {
  OAuthRequest request = new OAuthRequest(Verb.GET, PROTECTED_RESOURCE_URL);
  this.signRequest(accessToken, request);
  Response response = request.send();
  OAuthUser oAuthUser = new OAuthUser();
  oAuthUser.setoAuthType(getoAuthType());
  Object result = JSON.parse(response.getBody());
  oAuthUser.setoAuthId(JSONPath.eval(result, "$.id").toString());
  oAuthUser.setUserName(JSONPath.eval(result, "$.login").toString());
  return oAuthUser;
}

代码示例来源:origin: org.apache.camel/camel-yammer

private String send(Verb verb, String params) throws Exception {
  String url = apiUrl + ((params != null) ? params : "");
  
  OAuthRequest request = new OAuthRequest(verb, url);
  request.addQuerystringParameter(OAuthConstants.ACCESS_TOKEN, apiAccessToken);
  
  // For more details on the “Bearer” token refer to http://tools.ietf.org/html/draft-ietf-oauth-v2-bearer-23
  StringBuilder sb = new StringBuilder();
  sb.append("Bearer ");
  sb.append(apiAccessToken);
  request.addHeader("Authorization",  sb.toString());
  if (LOG.isDebugEnabled()) {
    LOG.debug("Yammer request url: {}", request.getCompleteUrl());
  }
  
  Response response = request.send();
  if (response.isSuccessful()) {                    
    return response.getBody();
  } else {
    throw new Exception(String.format("Failed to poll %s. Got response code %s and body: %s", getApiUrl(), response.getCode(), response.getBody()));
  }
}

代码示例来源:origin: google/data-transfer-project

if (response.getCode() < 200 || response.getCode() >= 300) {
 throw new IOException(
   String.format("Error occurred in request for %s : %s", fullUrl, response.getMessage()));
return mapper.readValue(response.getBody(), typeReference);

代码示例来源:origin: tumblr/jumblr

/* package-visible for testing */ Token clearXAuth(Response response) {
  if (response.getCode() == 200 || response.getCode() == 201) {
    return parseXAuthResponse(response);
  } else {
    throw new JumblrException(response);
  }
}

代码示例来源:origin: org.scribe/scribe

private String parseBodyContents()
{
 body = StreamUtils.getStreamContents(getStream());
 return body;
}

相关文章

微信公众号

最新文章

更多