com.squareup.okhttp.mockwebserver.MockResponse.setHeader()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(12.8k)|赞(0)|评价(0)|浏览(100)

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

MockResponse.setHeader介绍

[英]Removes all headers named name, then adds a new header with the name and value.
[中]删除所有名为name的标题,然后添加一个包含名称和值的新标题。

代码示例

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

private MockResponse createContentResponse(String contentType, byte[] content) {
 MockResponse response = new MockResponse();
 response.setHeader("content-type", contentType);
 Buffer body = new Buffer();
 body.write(content);
 response.setBody(body);
 return response;
}

代码示例来源:origin: com.squareup.okhttp/mockwebserver

/** Creates a new mock response with an empty body. */
public MockResponse() {
 setHeader("Content-Length", 0);
}

代码示例来源:origin: com.squareup.okhttp/mockwebserver

/**
 * Attempts to perform a web socket upgrade on the connection. This will overwrite any previously
 * set status or body.
 */
public MockResponse withWebSocketUpgrade(WebSocketListener listener) {
 setStatus("HTTP/1.1 101 Switching Protocols");
 setHeader("Connection", "Upgrade");
 setHeader("Upgrade", "websocket");
 body = null;
 webSocketListener = listener;
 return this;
}

代码示例来源:origin: com.squareup.okhttp/mockwebserver

public MockResponse setBody(Buffer body) {
 setHeader("Content-Length", body.size());
 this.body = body.clone(); // Defensive copy.
 return this;
}

代码示例来源:origin: cdancy/jenkins-rest

public void testGetSystemInfo() throws Exception {
  MockWebServer server = mockWebServer();
  server.enqueue(
    new MockResponse().setHeader("X-Hudson", "1.395").setHeader("X-Jenkins", JenkinsApiMetadata.BUILD_VERSION)
      .setHeader("X-Jenkins-Session", "cc323b8d").setHeader("X-Hudson-CLI-Port", "50000")
      .setHeader("X-Jenkins-CLI-Port", "50000").setHeader("X-Jenkins-CLI2-Port", "50000")
      .setHeader("X-Instance-Identity", "fdsa").setHeader("X-SSH-Endpoint", "127.0.1.1:46126")
      .setHeader("Server", "Jetty(winstone-2.9)").setResponseCode(200));
  JenkinsApi jenkinsApi = api(server.getUrl("/"));
  SystemApi api = jenkinsApi.systemApi();
  try {
    final SystemInfo version = api.systemInfo();
    assertNotNull(version);
    assertTrue(version.jenkinsVersion().equalsIgnoreCase(JenkinsApiMetadata.BUILD_VERSION));
    assertSent(server, "HEAD", "/");
  } finally {
    jenkinsApi.close();
    server.shutdown();
  }
}

代码示例来源:origin: com.squareup.okhttp/mockwebserver

String key = request.getHeader("Sec-WebSocket-Key");
String acceptKey = Util.shaBase64(key + WebSocketProtocol.ACCEPT_MAGIC);
response.setHeader("Sec-WebSocket-Accept", acceptKey);

代码示例来源:origin: cdancy/jenkins-rest

public void testBuildJobWithParams() throws Exception {
  MockWebServer server = mockWebServer();
  server.enqueue(
    new MockResponse().setHeader("Location", "http://127.0.1.1:8080/queue/item/1/").setResponseCode(201));
  JenkinsApi jenkinsApi = api(server.getUrl("/"));
  JobsApi api = jenkinsApi.jobsApi();
  try {
    Map<String, List<String>> params = new HashMap<>();
    params.put("SomeKey", Lists.newArrayList("SomeVeryNewValue"));
    IntegerResponse output = api.buildWithParameters(null, "DevTest", params);
    assertNotNull(output);
    assertTrue(output.value() == 1);
    assertTrue(output.errors().size() == 0);
    assertSentAccept(server, "POST", "/job/DevTest/buildWithParameters", "application/unknown");
  } finally {
    jenkinsApi.close();
    server.shutdown();
  }
}

代码示例来源:origin: apache/jclouds

@Test
public void testPatchRedirect() throws Exception {
 MockWebServer redirectTarget = mockWebServer(new MockResponse().setBody("fooPATCHREDIRECT"));
 redirectTarget.useHttps(sslContext.getSocketFactory(), false);
 MockWebServer server = mockWebServer(new MockResponse().setResponseCode(302).setHeader("Location",
    redirectTarget.getUrl("/").toString()));
 PatchApi api = api(PatchApi.class, server.getUrl("/").toString());
 try {
   String result = api.patch("", "foo");
   assertEquals(result, "fooPATCHREDIRECT");
   assertEquals(server.getRequestCount(), 1);
   assertEquals(redirectTarget.getRequestCount(), 1);
   // Verify that the body was populated after the redirect
   RecordedRequest request = server.takeRequest();
   assertEquals(request.getMethod(), "PATCH");
   assertEquals(new String(request.getBody(), Charsets.UTF_8), "foo");
   request = redirectTarget.takeRequest();
   assertEquals(request.getMethod(), "PATCH");
   assertEquals(new String(request.getBody(), Charsets.UTF_8), "foo");
 } finally {
   closeQuietly(api);
   redirectTarget.shutdown();
   server.shutdown();
 }
}

代码示例来源:origin: cdancy/jenkins-rest

public void testBuildJobWithEmptyParamsMap() throws Exception {
  MockWebServer server = mockWebServer();
  server.enqueue(
    new MockResponse().setHeader("Location", "http://127.0.1.1:8080/queue/item/1/").setResponseCode(201));
  JenkinsApi jenkinsApi = api(server.getUrl("/"));
  JobsApi api = jenkinsApi.jobsApi();
  try {
    IntegerResponse output = api.buildWithParameters(null, "DevTest", new HashMap<>());
    assertNotNull(output);
    assertTrue(output.value() == 1);
    assertTrue(output.errors().size() == 0);
    assertSentAccept(server, "POST", "/job/DevTest/buildWithParameters", "application/unknown");
  } finally {
    jenkinsApi.close();
    server.shutdown();
  }
}

代码示例来源:origin: apache/jclouds

@Test
public void testGetStringRedirect() throws Exception {
 MockWebServer redirectTarget = mockWebServer(new MockResponse().setBody(XML2));
 redirectTarget.useHttps(sslContext.getSocketFactory(), false);
 MockWebServer server = mockWebServer(new MockResponse().setResponseCode(302).setHeader("Location",
    redirectTarget.getUrl("/").toString()));
 IntegrationTestClient client = client(server.getUrl("/").toString());
 try {
   String result = client.download("redirect");
   assertEquals(result, XML2);
   assertEquals(server.getRequestCount(), 1);
   assertEquals(redirectTarget.getRequestCount(), 1);
 } finally {
   closeQuietly(client);
   redirectTarget.shutdown();
   server.shutdown();
 }
}

代码示例来源:origin: apache/jclouds

@Test
public void testPostRedirect() throws Exception {
 MockWebServer redirectTarget = mockWebServer(new MockResponse().setBody("fooPOSTREDIRECT"));
 redirectTarget.useHttps(sslContext.getSocketFactory(), false);
 MockWebServer server = mockWebServer(new MockResponse().setResponseCode(302).setHeader("Location",
    redirectTarget.getUrl("/").toString()));
 IntegrationTestClient client = client(server.getUrl("/").toString());
 try {
   String result = client.post("redirect", "foo");
   assertEquals(result, "fooPOSTREDIRECT");
   assertEquals(server.getRequestCount(), 1);
   assertEquals(redirectTarget.getRequestCount(), 1);
   // Verify that the body was populated after the redirect
   RecordedRequest request = server.takeRequest();
   assertEquals(new String(request.getBody(), Charsets.UTF_8), "foo");
   request = redirectTarget.takeRequest();
   assertEquals(new String(request.getBody(), Charsets.UTF_8), "foo");
 } finally {
   closeQuietly(client);
   redirectTarget.shutdown();
   server.shutdown();
 }
}

代码示例来源:origin: apache/jclouds

@Test
public void testPutRedirect() throws Exception {
 MockWebServer redirectTarget = mockWebServer(new MockResponse().setBody("fooPUTREDIRECT"));
 redirectTarget.useHttps(sslContext.getSocketFactory(), false);
 MockWebServer server = mockWebServer(new MockResponse().setResponseCode(302).setHeader("Location",
    redirectTarget.getUrl("/").toString()));
 IntegrationTestClient client = client(server.getUrl("/").toString());
 try {
   String result = client.upload("redirect", "foo");
   assertEquals(result, "fooPUTREDIRECT");
   assertEquals(server.getRequestCount(), 1);
   assertEquals(redirectTarget.getRequestCount(), 1);
   // Verify that the body was populated after the redirect
   RecordedRequest request = server.takeRequest();
   assertEquals(new String(request.getBody(), Charsets.UTF_8), "foo");
   request = redirectTarget.takeRequest();
   assertEquals(new String(request.getBody(), Charsets.UTF_8), "foo");
 } finally {
   closeQuietly(client);
   redirectTarget.shutdown();
   server.shutdown();
 }
}

代码示例来源:origin: apache/jclouds

@Test
public void testBothProtocolsSucceedIfSSLAndHTTPConfigured() throws Exception {
 MockWebServer redirectTarget = mockWebServer(new MockResponse());
 MockWebServer server = mockWebServer(new MockResponse().setResponseCode(302).setHeader("Location",
    redirectTarget.getUrl("/").toString()));
 server.useHttps(sslContext.getSocketFactory(), false);
 Module httpConfigModule = new ConnectionSpecModule(ConnectionSpec.CLEARTEXT, ConnectionSpec.MODERN_TLS);
 PatchApi api = api(PatchApi.class, server.getUrl("/").toString(), httpConfigModule);
 try {
   api.patchNothing("");
   assertEquals(server.getRequestCount(), 1);
   assertEquals(redirectTarget.getRequestCount(), 1);
 } finally {
   closeQuietly(api);
   server.shutdown();
   redirectTarget.shutdown();
 }
}

代码示例来源:origin: cdancy/jenkins-rest

public void testBuildJob() throws Exception {
  MockWebServer server = mockWebServer();
  server.enqueue(
    new MockResponse().setHeader("Location", "http://127.0.1.1:8080/queue/item/1/").setResponseCode(201));
  JenkinsApi jenkinsApi = api(server.getUrl("/"));
  JobsApi api = jenkinsApi.jobsApi();
  try {
    IntegerResponse output = api.build(null,"DevTest");
    assertNotNull(output);
    assertTrue(output.value() == 1);
    assertTrue(output.errors().size() == 0);
    assertSentAccept(server, "POST", "/job/DevTest/build", "application/unknown");
  } finally {
    jenkinsApi.close();
    server.shutdown();
  }
}

代码示例来源:origin: cdancy/jenkins-rest

public void testBuildJobWithNullParamsMap() throws Exception {
  MockWebServer server = mockWebServer();
  server.enqueue(
    new MockResponse().setHeader("Location", "http://127.0.1.1:8080/queue/item/1/").setResponseCode(201));
  JenkinsApi jenkinsApi = api(server.getUrl("/"));
  JobsApi api = jenkinsApi.jobsApi();
  try {
    IntegerResponse output = api.buildWithParameters(null, "DevTest", null);
    assertNotNull(output);
    assertTrue(output.value() == 1);
    assertTrue(output.errors().size() == 0);
    assertSentAccept(server, "POST", "/job/DevTest/buildWithParameters", "application/unknown");
  } finally {
    jenkinsApi.close();
    server.shutdown();
  }
}

代码示例来源:origin: appnexus/mobile-sdk-android

@Test
public void test2CookiesReset() {
  server.enqueue(new MockResponse().setResponseCode(200).setHeader("Set-Cookie", TestResponsesUT.UUID_COOKIE_RESET).setBody(TestResponsesUT.banner()));
  requestManager.execute();
  Robolectric.flushBackgroundThreadScheduler();
  Robolectric.flushForegroundThreadScheduler();
  String wvcookie = WebviewUtil.getCookie();
  System.out.println(wvcookie);
  assertEquals(getUUId2(wvcookie), getUUId2(TestResponsesUT.UUID_COOKIE_RESET));
}

代码示例来源:origin: cdancy/jenkins-rest

public void testCreateJobAlreadyExists() throws Exception {
  MockWebServer server = mockWebServer();
  String configXML = payloadFromResource("/freestyle-project.xml");
  server.enqueue(new MockResponse().setHeader("X-Error", "A job already exists with the name ?DevTest?")
    .setResponseCode(400));
  JenkinsApi jenkinsApi = api(server.getUrl("/"));
  JobsApi api = jenkinsApi.jobsApi();
  try {
    RequestStatus success = api.create(null, "DevTest", configXML);
    assertNotNull(success);
    assertFalse(success.value());
    assertFalse(success.errors().isEmpty());
    assertSentWithXMLFormDataAccept(server, "POST", "/createItem?name=DevTest", configXML, MediaType.WILDCARD);
  } finally {
    jenkinsApi.close();
    server.shutdown();
  }
}

代码示例来源:origin: cdancy/jenkins-rest

public void testGetProgressiveText() throws Exception {
  MockWebServer server = mockWebServer();
  String body = payloadFromResource("/progressive-text.txt");
  server.enqueue(new MockResponse().setHeader("X-Text-Size", "123").setBody(body).setResponseCode(200));
  JenkinsApi jenkinsApi = api(server.getUrl("/"));
  JobsApi api = jenkinsApi.jobsApi();
  try {
    ProgressiveText output = api.progressiveText(null,"DevTest", 0);
    assertNotNull(output);
    assertTrue(output.size() == 123);
    assertFalse(output.hasMoreData());
    assertSentAcceptText(server, "GET", "/job/DevTest/lastBuild/logText/progressiveText?start=0");
  } finally {
    jenkinsApi.close();
    server.shutdown();
  }
}

代码示例来源:origin: appnexus/mobile-sdk-android

@Test
public void test1CookiesSync() {
  server.enqueue(new MockResponse().setResponseCode(200).setHeader("Set-Cookie", TestResponsesUT.UUID_COOKIE_1).setBody(TestResponsesUT.banner()));
  requestManager.execute();
  Robolectric.flushBackgroundThreadScheduler();
  Robolectric.flushForegroundThreadScheduler();
  String wvcookie = WebviewUtil.getCookie();
  //Asserts the Cookie stored in the device is the same as that of the one we sent back in the response.
  assertEquals(getUUId2(wvcookie), getUUId2(TestResponsesUT.UUID_COOKIE_1));
}

相关文章