org.apache.http.client.fluent.Executor源码实例Demo

类org.apache.http.client.fluent.Executor源码实例Demo

下面列出了org.apache.http.client.fluent.Executor 类实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。

源代码1 项目: 07kit   文件: PriceLookup.java
public static List<PriceInfo> search(String term, int limit) {
	try {
		Request request = Request.Get(API_URL + "search?term=" + URLEncoder.encode(term, "UTF-8") + "&limit=" + limit);
		request.addHeader(AUTH_HEADER_KEY, "Bearer " + Session.get().getApiToken());

		HttpResponse response = Executor.newInstance(HttpUtil.getClient()).execute(request).returnResponse();
		if (response != null) {
			if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
				byte[] bytes = EntityUtils.toByteArray(response.getEntity());
				return GSON.fromJson(new String(bytes), PRICE_INFO_LIST_TYPE);
			}
		}
		return new ArrayList<>();
	} catch (IOException | CacheLoader.InvalidCacheLoadException e) {
		e.printStackTrace();
		return new ArrayList<>();
	}
}
 
源代码2 项目: redisson   文件: RedissonSessionManagerTest.java
@Test
public void testUpdate() throws Exception {
    // start the server at http://localhost:8080/myapp
    TomcatServer server = new TomcatServer("myapp", 8080, "src/test/");
    server.start();

    Executor executor = Executor.newInstance();
    
    write(executor, "test", "1");
    read(executor, "test", "1");
    write(executor, "test", "2");
    read(executor, "test", "2");
    
    Executor.closeIdleConnections();
    server.stop();
}
 
源代码3 项目: 07kit   文件: CompletedOfferRecorder.java
private void processQueue() {
	Request next = requestQueue.poll();
	while (next != null) {
		try {
			HttpResponse response = Executor.newInstance(HttpUtil.getClient()).execute(next).returnResponse();
			if (response != null) {
				if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
					logger.info("Processed request [" + next.toString() + "]");
				} else {
					logger.error("Error processing request queue got rsponse [" + response.toString() + "]");
				}
			}
		} catch (IOException e) {
			logger.error("Error processing request queue", e);
		}
		next = requestQueue.poll();
	}
}
 
源代码4 项目: 07kit   文件: ClanService.java
public static ClanInfo create(String loginName, String ingameName, String clanName, ClanRank.Status status, int world) {
    try {
        Request request = Request.Post(API_URL + "create");
        request.addHeader(AUTH_HEADER_KEY, "Bearer " + Session.get().getApiToken());
        request.bodyString(GSON.toJson(new CreateUpdateClanRequest(loginName, ingameName, clanName, status, world)),
                ContentType.APPLICATION_JSON);

        HttpResponse response = Executor.newInstance(HttpUtil.getClient()).execute(request).returnResponse();
        if (response != null) {
            if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
                byte[] bytes = EntityUtils.toByteArray(response.getEntity());
                return GSON.fromJson(new String(bytes), ClanInfo.class);
            } else if (response.getStatusLine().getStatusCode() == 302) {
                NotificationsUtil.showNotification("Clan", "That clan name is taken");
            } else {
                NotificationsUtil.showNotification("Clan", "Error creating clan");
            }
        }
        return null;
    } catch (IOException e) {
        logger.error("Error creating clan", e);
        return null;
    }
}
 
源代码5 项目: redisson   文件: RedissonSessionManagerTest.java
@Test
public void testUpdateTwoServers() throws Exception {
    TomcatServer server1 = new TomcatServer("myapp", 8080, "src/test/");
    server1.start();

    Executor executor = Executor.newInstance();
    BasicCookieStore cookieStore = new BasicCookieStore();
    executor.use(cookieStore);
    
    write(executor, "test", "1234");

    TomcatServer server2 = new TomcatServer("myapp", 8081, "src/test/");
    server2.start();

    read(8081, executor, "test", "1234");
    read(executor, "test", "1234");
    write(executor, "test", "324");
    read(8081, executor, "test", "324");
    
    Executor.closeIdleConnections();
    server1.stop();
    server2.stop();
}
 
源代码6 项目: gogs-webhook-plugin   文件: GogsConfigHandler.java
/**
 * Creates a web hook in Gogs with the passed json configuration string
 *
 * @param jsonCommand A json buffer with the creation command of the web hook
 * @param projectName the project (owned by the user) where the webHook should be created
 * @throws IOException something went wrong
 */
int createWebHook(String jsonCommand, String projectName) throws IOException {

    String gogsHooksConfigUrl = getGogsServer_apiUrl()
            + "repos/" + this.gogsServer_user
            + "/" + projectName + "/hooks";

    Executor executor = getExecutor();
    Request request = Request.Post(gogsHooksConfigUrl);

    if (gogsAccessToken != null) {
        request.addHeader("Authorization", "token " + gogsAccessToken);
    }

    String result = executor
            .execute(request.bodyString(jsonCommand, ContentType.APPLICATION_JSON))
            .returnContent().asString();
    JSONObject jsonObject = (JSONObject) JSONSerializer.toJSON( result );
    return jsonObject.getInt("id");
}
 
源代码7 项目: gogs-webhook-plugin   文件: GogsConfigHandler.java
/**
 * Get Access token of the user.
 *
 * @return an access token of the user
 */
public String getGogsAccessToken() {
    String resp;
    String sha1 = null;
    Executor executor = getExecutor();
    try {
        resp = executor.execute(
                Request.Get(this.getGogsUrl() + "/api/v1/users/" + this.gogsServer_user + "/tokens")
        ).returnContent().toString();
        JSONArray jsonArray = JSONArray.fromObject(resp);
        if (!jsonArray.isEmpty()) {
            sha1 = ((JSONObject) jsonArray.get(0)).getString("sha1");
        }
    } catch (IOException e) { }
    return sha1;
}
 
源代码8 项目: thorntail   文件: HttpsTest.java
@Test
@RunAsClient
public void hello() throws IOException, GeneralSecurityException {
    SSLContext sslContext = SSLContexts.custom()
            .loadTrustMaterial((TrustStrategy) (chain, authType) -> true)
            .build();
    try (CloseableHttpClient httpClient = HttpClients.custom()
            .setSSLContext(sslContext)
            .build()) {

        String response = Executor.newInstance(httpClient)
                .execute(Request.Get("https://localhost:8443/"))
                .returnContent().asString();
        assertThat(response).contains("Hello on port 8443, secure: true");
    }
}
 
源代码9 项目: substitution-schedule-parser   文件: BaseParser.java
BaseParser(SubstitutionScheduleData scheduleData, CookieProvider cookieProvider) {
    this.scheduleData = scheduleData;
    this.cookieProvider = cookieProvider;
    this.cookieStore = new BasicCookieStore();
    this.colorProvider = new ColorProvider(scheduleData);
    this.encodingDetector = new UniversalDetector(null);
    this.debuggingDataHandler = new NoOpDebuggingDataHandler();
    this.sardine = null;

    try {
        SSLConnectionSocketFactory sslsf = getSslConnectionSocketFactory(scheduleData);

        CloseableHttpClient httpclient = HttpClients.custom()
                .setSSLSocketFactory(sslsf)
                .setRedirectStrategy(new LaxRedirectStrategy())
                .setDefaultRequestConfig(RequestConfig.custom()
                        .setCookieSpec(CookieSpecs.STANDARD).build())
                .setUserAgent(
                        "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/74.0.3729.169 Safari/537.36")
                .build();
        this.executor = Executor.newInstance(httpclient).use(cookieStore);
    } catch (GeneralSecurityException | JSONException | IOException e) {
        throw new RuntimeException(e);
    }
}
 
源代码10 项目: redisson   文件: RedissonSessionManagerTest.java
@Test
public void testUpdateTwoServers() throws Exception {
    TomcatServer server1 = new TomcatServer("myapp", 8080, "src/test/");
    server1.start();

    Executor executor = Executor.newInstance();
    BasicCookieStore cookieStore = new BasicCookieStore();
    executor.use(cookieStore);
    
    write(executor, "test", "1234");

    TomcatServer server2 = new TomcatServer("myapp", 8081, "src/test/");
    server2.start();

    read(8081, executor, "test", "1234");
    read(executor, "test", "1234");
    write(executor, "test", "324");
    read(8081, executor, "test", "324");
    
    Executor.closeIdleConnections();
    server1.stop();
    server2.stop();
}
 
源代码11 项目: redisson   文件: RedissonSessionManagerTest.java
@Test
public void testUpdate() throws Exception {
    // start the server at http://localhost:8080/myapp
    TomcatServer server = new TomcatServer("myapp", 8080, "src/test/");
    server.start();

    Executor executor = Executor.newInstance();
    
    write(executor, "test", "1");
    read(executor, "test", "1");
    write(executor, "test", "2");
    read(executor, "test", "2");
    
    Executor.closeIdleConnections();
    server.stop();
}
 
@Override
protected List<File> downloadArtifacts(CloseableHttpClient httpclient, JsonArray artifacts) {
    final List<File> files = new ArrayList<>();
    for (JsonElement ae : artifacts) {
        JsonObject artifact = ae.getAsJsonObject();
        if (!artifact.has("download"))
            continue;
        
        String name = jstring(artifact, "name");
        String url = jstring(artifact, "download");
       
        // Don't fail the submit if we fail to download the sab(s).
        try {
            File target = new File(name);
            StreamsRestUtils.getFile(Executor.newInstance(httpclient), getAuthorization(), url, target);
            files.add(target);
        } catch (IOException e) {
            TRACE.warning("Failed to download sab: " + name + " : " + e.getMessage());
        }
    }
    return files;
}
 
private void refreshAuth(Executor executor, JsonObject config) throws IOException {
    Request post = Request.Post(securityUrl)
            .addHeader("Authorization", RestUtils.createBasicAuth(userName, password))
            .addHeader("Accept", ContentType.APPLICATION_JSON.getMimeType())
            .bodyString(AUDIENCE_STREAMS, ContentType.APPLICATION_JSON);

    JsonObject resp = RestUtils.requestGsonResponse(executor, post);
    String token = jstring(resp, ACCESS_TOKEN);
    serviceAuth = token == null ? null : RestUtils.createBearerAuth(token);
    if (resp.has(EXPIRE_TIME)) {
        JsonElement je = resp.get(EXPIRE_TIME);
        // Response is in seconds since epoch, and docs say the min
        // for the service is 30s, so give a 10s of slack if we can
        expire = je.isJsonNull() ? 0 : Math.max(0, je.getAsLong() - 10) * MS;
    } else {
        // Short expiry (same as python)
        expire = System.currentTimeMillis() + 4 * 60 * MS;
    }

    // Update config
    config.addProperty(SERVICE_TOKEN, token);
    config.addProperty(SERVICE_TOKEN_EXPIRE, expire);
}
 
源代码14 项目: streamsx.topology   文件: StreamsRestUtils.java
static File getFile(Executor executor, String auth, String url, File file) throws IOException {
    return rawStreamingGet(executor, auth, url, new InputStreamConsumer<File>() {

        @Override
        public void consume(InputStream is) throws IOException {
            try {
                Files.copy(is, file.toPath(), StandardCopyOption.REPLACE_EXISTING);
            }
            catch(IOException ioe) {
                if (file.delete()) {
                    TRACE.fine("downloaded fragment " + file + " deleted");
                }
                throw ioe;
            }
        }

        @Override
        public File getResult() {
            return file;
        }
    });
}
 
源代码15 项目: redisson   文件: RedissonSessionManagerTest.java
public void testExpiration() throws Exception {
    TomcatServer server1 = new TomcatServer("myapp", 8080, "src/test/");
    server1.start();

    Executor executor = Executor.newInstance();
    BasicCookieStore cookieStore = new BasicCookieStore();
    executor.use(cookieStore);
    
    write(executor, "test", "1234");

    TomcatServer server2 = new TomcatServer("myapp", 8081, "src/test/");
    server2.start();

    Thread.sleep(30000);
    
    read(8081, executor, "test", "1234");

    Thread.sleep(40000);
    
    executor.use(cookieStore);
    read(executor, "test", "1234");
    
    Executor.closeIdleConnections();
    server1.stop();
    server2.stop();
}
 
源代码16 项目: streamsx.topology   文件: StreamsBuildService.java
static BuildService of(Function<Executor,String> authenticator, JsonObject serviceDefinition,
        boolean verify) throws IOException {

    String buildServiceEndpoint = jstring(object(serviceDefinition, "connection_info"), "serviceBuildEndpoint");
    String buildServicePoolsEndpoint = jstring(object(serviceDefinition, "connection_info"), "serviceBuildPoolsEndpoint");
    // buildServicePoolsEndpoint is null when "connection_info" JSON element has no "serviceBuildPoolsEndpoint"
    if (authenticator instanceof StandaloneAuthenticator) {
        if (buildServiceEndpoint == null) {
            buildServiceEndpoint = Util.getenv(Util.STREAMS_BUILD_URL);
        }
        if (!buildServiceEndpoint.endsWith(STREAMS_BUILD_PATH)) {
            // URL was user-provided root of service, add the path
            URL url = new URL(buildServiceEndpoint);
            URL buildsUrl = new URL(url.getProtocol(), url.getHost(), url.getPort(), STREAMS_BUILD_PATH);
            buildServiceEndpoint = buildsUrl.toExternalForm();
        }
        return StreamsBuildService.of(authenticator, buildServiceEndpoint, verify);
    }
    return new StreamsBuildService(buildServiceEndpoint, buildServicePoolsEndpoint, authenticator, verify);
}
 
源代码17 项目: redisson   文件: RedissonSessionManagerTest.java
@Test
public void testUpdate() throws Exception {
    // start the server at http://localhost:8080/myapp
    TomcatServer server = new TomcatServer("myapp", 8080, "src/test/");
    server.start();

    Executor executor = Executor.newInstance();
    
    write(executor, "test", "1");
    read(executor, "test", "1");
    write(executor, "test", "2");
    read(executor, "test", "2");
    
    Executor.closeIdleConnections();
    server.stop();
}
 
源代码18 项目: redisson   文件: RedissonSessionManagerTest.java
@Test
public void testHttpSessionListener() throws Exception {
    TomcatServer server1 = new TomcatServer("myapp", 8080, "src/test/");
    server1.start();

    TomcatServer server2 = new TomcatServer("myapp", 8081, "src/test/");
    server2.start();

    Executor executor = Executor.newInstance();
    BasicCookieStore cookieStore = new BasicCookieStore();
    executor.use(cookieStore);

    TestHttpSessionListener.CREATED_INVOCATION_COUNTER = 0;
    TestHttpSessionListener.DESTROYED_INVOCATION_COUNTER = 0;

    write(executor, "test", "1234");

    TomcatServer server3 = new TomcatServer("myapp", 8082, "src/test/");
    server3.start();

    invalidate(executor);

    Thread.sleep(500);

    Assert.assertEquals(2, TestHttpSessionListener.CREATED_INVOCATION_COUNTER);
    Assert.assertEquals(3, TestHttpSessionListener.DESTROYED_INVOCATION_COUNTER);

    Executor.closeIdleConnections();
    server1.stop();
    server2.stop();
    server3.stop();
}
 
源代码19 项目: 07kit   文件: SocialService.java
public UserCharacter getCharacter(String hash) throws IOException {
    HttpResponse response = Executor.newInstance(HttpUtil.getClient()).execute(Request.Get(CHARACTERS_ENDPOINT + "?hash=" + hash)
            .addHeader("Authorization", "Bearer " + Session.get().getApiToken())
    ).returnResponse();
    if (response.getStatusLine().getStatusCode() == 200) {
        return gson.fromJson(EntityUtils.toString(response.getEntity()), UserCharacter.class);
    } else if (response.getStatusLine().getStatusCode() == 404) {
        return null;
    } else {
        throw new IllegalStateException(String.format("Couldn't retrieve character for hash %s: %d", hash, response.getStatusLine().getStatusCode()));
    }
}
 
源代码20 项目: 07kit   文件: SocialService.java
public UserCharacter createCharacter(String name, String hash) throws IOException {
    HttpResponse response = Executor.newInstance(HttpUtil.getClient()).execute(Request.Post(CHARACTERS_ENDPOINT)
            .addHeader("Authorization", "Bearer " + Session.get().getApiToken())
            .bodyString(gson.toJson(new UserCharacter(name, hash)), ContentType.APPLICATION_JSON)
    ).returnResponse();
    if (response.getStatusLine().getStatusCode() == 200) {
        return gson.fromJson(EntityUtils.toString(response.getEntity()), UserCharacter.class);
    } else {
        throw new IllegalStateException(String.format("Couldn't create character for hash %s: %d", hash, response.getStatusLine().getStatusCode()));
    }
}
 
源代码21 项目: 07kit   文件: SocialService.java
public UserCharacter updateCharacter(UserCharacter character) throws IOException {
    HttpResponse response = Executor.newInstance(HttpUtil.getClient()).execute(Request.Put(String.format(CHARACTER_ENDPOINT, character.id))
            .addHeader("Authorization", "Bearer " + Session.get().getApiToken())
            .bodyString(gson.toJson(character), ContentType.APPLICATION_JSON)
    ).returnResponse();
    if (response.getStatusLine().getStatusCode() == 200) {
        return gson.fromJson(EntityUtils.toString(response.getEntity()), UserCharacter.class);
    } else {
        throw new IllegalStateException(String.format("Couldn't update character for id %d: %d", character.id, response.getStatusLine().getStatusCode()));
    }
}
 
源代码22 项目: 07kit   文件: SocialService.java
public void uploadScreenshotEvent(EventForm eventForm, ScreenshotForm form, Consumer<Boolean> callback) {
    HttpEntity entity = MultipartEntityBuilder
            .create()
            .addTextBody("name", form.name)
            .addTextBody("description", form.description)
            .addTextBody("locationX", String.valueOf(form.locationX))
            .addTextBody("locationY", String.valueOf(form.locationY))
            .addTextBody("created", String.valueOf(form.created.getTime()))
            .addBinaryBody("file", form.file, ContentType.create("image/png"), form.file.getName())
            .build();


    new Thread(socialThreadGroup, () -> {
        try {
            HttpResponse response = Executor.newInstance(HttpUtil.getClient()).execute(Request.Post(String.format(CHARACTER_SCREENSHOT_ENDPOINT, Session.get().getCharacter().id))
                    .addHeader("Authorization", "Bearer " + Session.get().getApiToken())
                    .body(entity)).returnResponse();
            if (response.getStatusLine().getStatusCode() == 200) {
                Map responseBody = gson.fromJson(EntityUtils.toString(response.getEntity()), Map.class);
                eventForm.screenshotId = ((Number) responseBody.get("id")).longValue();
                createEvent(eventForm, callback);
            } else {
                callback.accept(false);
            }
        } catch (Exception e) {
            callback.accept(false);
            e.printStackTrace();
        }
    }, String.format("screenshot-upload-%s", form.file.getName())).start();
}
 
源代码23 项目: 07kit   文件: LoginController.java
public void login(String email, String password, boolean rememberMe) {
    try {
        SwingWorker worker = new SwingWorker() {
            @Override
            protected Object doInBackground() throws Exception {
                HttpResponse response = Executor.newInstance(HttpUtil.getClient()).execute(Request.Post(API_URL + "/token")
                        .bodyString(JacksonUtil.serialize(new CreateTokenRequest(email, password)), ContentType.APPLICATION_JSON)).returnResponse();
                if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
                    UserToken tokenResponse = JacksonUtil.deserialize(
                            EntityUtils.toString(response.getEntity()),
                            UserToken.class);
                    if (loadAccount(tokenResponse.getUuid(), rememberMe, email)) {
                        logger.info("Logged in.");
                        return null;
                    }
                }
                logger.error("Invalid login, response: [" + response.toString() + "]");
                getComponent().getStatusLbl().setText("Status: Invalid login");
                return null;
            }
        };
        worker.execute();
    } catch (Exception e) {
        logger.error("Oops.", e);
        getComponent().getStatusLbl().setText("Status: Error logging in");
    }
}
 
源代码24 项目: redisson   文件: RedissonSessionManagerTest.java
@Test
public void testRecreate() throws Exception {
    // start the server at http://localhost:8080/myapp
    TomcatServer server = new TomcatServer("myapp", 8080, "src/test/");
    server.start();

    Executor executor = Executor.newInstance();
    
    write(executor, "test", "1");
    recreate(executor, "test", "2");
    read(executor, "test", "2");
    
    Executor.closeIdleConnections();
    server.stop();
}
 
源代码25 项目: 07kit   文件: ClanService.java
public static ClanInfo join(String loginName, String ingameName, String clanName, long clanId, boolean useId, ClanRank.Status status, int world) {
    try {
        Request request = Request.Post(API_URL + "rank/update/" + (useId ? "id" : "name"));
        request.addHeader(AUTH_HEADER_KEY, "Bearer " + Session.get().getApiToken());
        request.bodyString(GSON.toJson(new GetOrJoinClanRequest(
                clanId,
                loginName,
                ingameName,
                clanName,
                status,
                world
        )), ContentType.APPLICATION_JSON);
        HttpResponse response = Executor.newInstance(HttpUtil.getClient()).execute(request).returnResponse();

        if (response != null) {
            if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
                byte[] bytes = EntityUtils.toByteArray(response.getEntity());
                return GSON.fromJson(new String(bytes), ClanInfo.class);
            } else if (response.getStatusLine().getStatusCode() == HttpStatus.SC_FAILED_DEPENDENCY) {
                NotificationsUtil.showNotification("Clan", "You have not yet been accepted into this clan");
            } else if (response.getStatusLine().getStatusCode() == HttpStatus.SC_NOT_FOUND) {
                NotificationsUtil.showNotification("Clan", "Unable to find clan");
            } else if (response.getStatusLine().getStatusCode() == HttpStatus.SC_FORBIDDEN) {
                NotificationsUtil.showNotification("Clan", "You have been banned from this clan");
            } else if (response.getStatusLine().getStatusCode() == HttpStatus.SC_EXPECTATION_FAILED) {
                NotificationsUtil.showNotification("Clan", "You have been denied access into this clan");
            } else {
                NotificationsUtil.showNotification("Clan", "Error joining clan");
            }
        }
        return null;
    } catch (IOException e) {
        logger.error("Error joining clan", e);
        return null;
    }
}
 
源代码26 项目: 07kit   文件: ClanService.java
public static ClanInfo updateRank(String loginName, String ingameName, ClanInfo clan, ClanRank.Status status, int world) {
    try {
        Request request = Request.Post(API_URL + "rank/update/id");
        request.addHeader(AUTH_HEADER_KEY, "Bearer " + Session.get().getApiToken());
        request.bodyString(GSON.toJson(new GetOrJoinClanRequest(
                clan.getClanId(),
                loginName,
                ingameName,
                clan.getName(),
                status,
                world
        )), ContentType.APPLICATION_JSON);
        HttpResponse response = Executor.newInstance(HttpUtil.getClient()).execute(request).returnResponse();

        if (response != null) {
            if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
                byte[] bytes = EntityUtils.toByteArray(response.getEntity());
                return GSON.fromJson(new String(bytes), ClanInfo.class);
            } else if (response.getStatusLine().getStatusCode() == HttpStatus.SC_FAILED_DEPENDENCY) {
                NotificationsUtil.showNotification("Clan", "You have not yet been accepted into this clan");
            } else if (response.getStatusLine().getStatusCode() == HttpStatus.SC_NOT_FOUND) {
                NotificationsUtil.showNotification("Clan", "Unable to find clan");
            } else if (response.getStatusLine().getStatusCode() == HttpStatus.SC_FORBIDDEN) {
                NotificationsUtil.showNotification("Clan", "You have been banned from this clan");
            } else {
                NotificationsUtil.showNotification("Clan", "Error updating clan");
            }
        }
        return null;
    } catch (IOException e) {
        logger.error("Error updating clan rank", e);
        return null;
    }
}
 
源代码27 项目: zest-writer   文件: GithubHttp.java
public static Content loadManifest(String folder, String owner, String repo) throws IOException {
    String projecUrl = "https://api.github.com/repos/"+owner+"/"+repo;
    String title = null;
    log.debug("Tentative de connexion à l'url : "+projecUrl);
    String githubUser = System.getProperty("zw.github_user");
    String githubToken = System.getProperty("zw.github_token");

    Executor executor;
    if(githubUser != null && !"".equals(githubUser) && githubToken != null && !"".equals(githubToken)) {
        executor = Executor
                .newInstance()
                .auth(new HttpHost("api.github.com"), githubUser, githubToken);
    } else {
        executor = Executor.newInstance();
    }

    String json = executor.execute(Request.Get(projecUrl)).returnContent().asString();
    ObjectMapper mapper = new ObjectMapper();
    Map map = mapper.readValue(json, Map.class);
    if(map.containsKey("description")) {
        title = (String) map.get("description");
    }
    Content current = new Content("container", toSlug(title), title, Constant.DEFAULT_INTRODUCTION_FILENAME, Constant.DEFAULT_CONCLUSION_FILENAME, new ArrayList<>(), 2, "CC-BY", title, "TUTORIAL");
    // read all directory
    current.getChildren ().addAll (loadDirectory (folder.length () + File.separator.length (), new File(folder)));
    current.setBasePath (folder);
    generateMetadataAttributes(current.getFilePath());
    return current;
}
 
源代码28 项目: gogs-webhook-plugin   文件: GogsConfigHandler.java
/**
 * Creates an empty repository (under the configured user).
 * It is created as a public repository, un-initialized.
 *
 * @param projectName the project name (repository) to create
 * @throws IOException Something went wrong (example: the repo already exists)
 */
void createEmptyRepo(String projectName) throws IOException {

    Executor executor = getExecutor();
    String gogsHooksConfigUrl = getGogsServer_apiUrl() + "user/repos";
    Request request = Request.Post(gogsHooksConfigUrl);

    if (this.gogsAccessToken != null) {
        request.addHeader("Authorization", "token " + this.gogsAccessToken);
    }

    int result = executor
            .execute(request
                    .bodyForm(Form.form()
                                  .add("name", projectName)
                                  .add("description", "API generated repository")
                                  .add("private", "true")
                                  .add("auto_init", "false")
                                  .build()
                    )
            )
            .returnResponse().getStatusLine().getStatusCode();


    if (result != 201) {
        throw new IOException("Repository creation call did not return the expected value (returned " + result + ")");
    }
}
 
源代码29 项目: gogs-webhook-plugin   文件: GogsConfigHandler.java
void removeRepo(String projectName) throws IOException {
    Executor executor = getExecutor();
    String gogsHookConfigUrl = getGogsServer_apiUrl() + "repos/" + this.gogsServer_user + "/" + projectName;
    Request request = Request.Delete(gogsHookConfigUrl);

    if (this.gogsAccessToken != null) {
        request.addHeader("Authorization", "token " + this.gogsAccessToken);
    }

    int result = executor.execute(request).returnResponse().getStatusLine().getStatusCode();
    if (result != 204) {
        throw new IOException("Repository deletion call did not return the expected value (returned " +  result + ")");
    }
}
 
源代码30 项目: redisson   文件: RedissonSessionManagerTest.java
@Test
public void testWriteReadRemove() throws Exception {
    // start the server at http://localhost:8080/myapp
    TomcatServer server = new TomcatServer("myapp", 8080, "src/test/");
    server.start();

    Executor executor = Executor.newInstance();
    
    write(executor, "test", "1234");
    read(executor, "test", "1234");
    remove(executor, "test", "null");
    
    Executor.closeIdleConnections();
    server.stop();
}
 
源代码评论
动弹
沙发等你来抢
 类所在包
 类方法
 同包方法