import us.monoid.web.Resty; //导入依赖的package包/类
/**
	 * @param url
	 * @return Returns the JSON 
	 */
	private String getJSON(String url){
		JSONResource res = null;
		JSONObject obj = null;
		Resty resty = new Resty();
		
		try {
			res = resty.json(url);
			obj = res.toObject();
			
		} catch (IOException | JSONException e) {
			// TODO: not my favorite way but does the trick
//			e.printStackTrace();
			return getJSON(url);
		}
		
		return obj.toString();
	}
 

import us.monoid.web.Resty; //导入依赖的package包/类
public Result getLatestBuildResults() {
    Result result = new Result();
    try {
        Resty resty = new Resty();
        resty.authenticate(url, login, pass.toCharArray());
        XMLResource resource = resty.xml(url + "/app/rest/builds/buildType:" + buildType + ",lookupLimit:1");
        Boolean hasNext = true;
        String testOccurrences = url + resource.get("//testOccurrences/@href").item(0).getNodeValue();
        while (hasNext) {
            XMLResource results = resty.xml(testOccurrences);
            NodeList nodeList = results.get("//testOccurrences/@nextHref");
            hasNext = (nodeList.getLength() > 0 && (testOccurrences = url + nodeList.item(0).getNodeValue()) != null);
            nodeList = results.get("//testOccurrence");
            if (nodeList != null) {
                for (int i = 0; i < nodeList.getLength(); i++) {
                    NamedNodeMap attributes = nodeList.item(i).getAttributes();
                    result.addResult(attributes.getNamedItem("name").getNodeValue(), attributes.getNamedItem("status").getNodeValue());
                }
            }
        }
    } catch (Exception e) {/**/}
    return result;
}
 

import us.monoid.web.Resty; //导入依赖的package包/类
@Override
public HttpResponse execute(final String url) {
    HttpURLConnection httpConnection = null;
    try {
        final Resty resty = new Resty();
        if (isProxySet()) {
            resty.setProxy(proxyHost, proxyPort);
        }
        final TextResource textResource = resty.text(url);
        httpConnection = textResource.http();

        return toHttpResponse(textResource, httpConnection);

    } catch (IOException ioEx) {
        throw new HipChatNotificationPluginException("Error opening connection to HipChat URL: [" + ioEx.getMessage() + "].", ioEx);

    } finally {
        if (httpConnection != null) {
            httpConnection.disconnect();
        }
    }
}
 

import us.monoid.web.Resty; //导入依赖的package包/类
/**
 * Same than above, but using resty. Way easier tbh.
 *
 * @param url The URL to get the object from.
 * @return The object as a parsed string.
 */
public static String wgetResty(String url) {
	try {
		return new Resty().identifyAsMozilla().text(url).toString();
	} catch (IOException e) {
		log.warn("Error Fetching Data from URL: " + url, e);
	}

	return null;
}
 

import us.monoid.web.Resty; //导入依赖的package包/类
public static URI getServer(String regionName) {
    try {
        return URI.create("ws://" + new Resty().text(requestURL, form(data("region", regionName))).toString());
    } catch (Exception e) {
        e.printStackTrace();
    }
    return null;
}
 

import us.monoid.web.Resty; //导入依赖的package包/类
/**
 * @param url
 * @return Returns the JSON as JSON Resource
 */
private JSONResource getJSON(String url) throws uQasarException{
	JSONResource res = null;
	Resty resty = new Resty();

	// Connection counter +1
	counter +=1;

	// Replaces spaces in URL with char %20
	url = url.replaceAll(" ", "%20");

	try {
		res = resty.json(url);

	} catch (IOException e) {

		// Check if the limit of trials has been reached
		if(counter<counterLimit){
			return getJSON(url);} else
				throw new uQasarException("Cubes Server is not availabe at this moument, error to connect with " +url);
	}

	// Reset the connection counter to 0
	counter = 0;

	return res;
}
 

import us.monoid.web.Resty; //导入依赖的package包/类
public String urlEncodeMap(Map<String,String> fields) {
    StringBuffer params = new StringBuffer();
    Iterator<String> keys = fields.keySet().iterator();
    while(keys.hasNext()) {
        String key = keys.next();
        String value = fields.get(key);
        if(params.length() > 0) {
            params.append("&");
        }
        params.append(key+"="+Resty.enc(value));
    }
    return params.toString();
}
 

import us.monoid.web.Resty; //导入依赖的package包/类
public void login() throws IOException, LoginException {
    Resty r = new Resty();
    JSONResource authTickets = r.json(baseURL + "access/ticket",
            form("username=" + username + "@" + realm + "&password=" + password));
    try {
        authTicket = authTickets.get("data.ticket").toString();
        csrfPreventionToken = authTickets.get("data.CSRFPreventionToken").toString();
        authTicketIssuedTimestamp = new Date();
    } catch (Exception e) {
        throw new LoginException("Failed reading JSON response");
    }
}
 

import us.monoid.web.Resty; //导入依赖的package包/类
private Resty authedClient() throws IOException, LoginException {
    checkIfAuthTicketIsValid();
    Resty r = new Resty();
    r.withHeader("Cookie", "PVEAuthCookie=" + authTicket);
    r.withHeader("CSRFPreventionToken", csrfPreventionToken);
    return r;
}
 

import us.monoid.web.Resty; //导入依赖的package包/类
public String rollbackQemuMachineSnapshot(String node, Integer vmid, String snapshotName)
        throws IOException, LoginException, JSONException {
    Resty r = authedClient();
    String resource = "nodes/" + node + "/qemu/" + vmid.toString() + "/snapshot/" + snapshotName + "/rollback";
    JSONResource response = r.json(baseURL + resource, form(""));
    return response.toObject().getString("data");
}
 

import us.monoid.web.Resty; //导入依赖的package包/类
/**
 * Check the tear down.
 */
@Test
public void testTearDown() throws IOException {
	// insert mock to test object
	firespottingIT.popupPage = this.popupPage;

	// mock rest client
	firespottingIT.restClient = mock(Resty.class);

	// mock some objects for session key
	RemoteWebDriver remoteWebDriver = mock(RemoteWebDriver.class);
	SessionId sessionId = mock(SessionId.class);
	when(popupPage.getDriver()).thenReturn(remoteWebDriver);
	when(remoteWebDriver.getSessionId()).thenReturn(sessionId);
	when(sessionId.toString()).thenReturn("72345863");

	doReturn("sauceUsername").when(firespottingIT).getSystemVariable("SAUCE_USERNAME");
	doReturn("sauceKey").when(firespottingIT).getSystemVariable("SAUCE_ACCESS_KEY");
	doReturn("platform").when(firespottingIT).getSystemVariable("PLATFORM");
	doReturn("travisBuildNr").when(firespottingIT).getSystemVariable("TRAVIS_BUILD_NUMBER");

	// run test method
	firespottingIT.tearDown();

	// is the method called to tear down correctly?
	verify(popupPage, atLeastOnce()).tearDown();

	// verify rest client actions if environment variables are set
	// @TODO: add better verification! (no more anyStrings; check the values!)
	verify(firespottingIT.restClient, atLeastOnce()).authenticate(anyString(), anyString(), anyString().toCharArray());
	verify(firespottingIT.restClient, atLeastOnce()).withHeader("Content-Type", "application/json");
}
 

import us.monoid.web.Resty; //导入依赖的package包/类
public String getRawResponseSync(Query query) {
    try {
        if (mMockSlowResponse) {
            Thread.sleep(10000);
        }
        String start = String.format(LOCATION_ARG, query.lat0, query.lng0);
        String end = String.format(LOCATION_ARG, query.lat1, query.lng1);
        String args = String.format(ARGS, encode(start), encode(end));
        String url = BASE_URL + args;
        return new Resty().text(url).toString();
    } catch (Exception e) {
        e.printStackTrace();
        return null;
    }
}
 

import us.monoid.web.Resty; //导入依赖的package包/类
public String startQemuMachine(String node, Integer vmid) throws IOException, LoginException, JSONException {
    Resty r = authedClient();
    String resource = "nodes/" + node + "/qemu/" + vmid.toString() + "/status/start";
    JSONResource response = r.json(baseURL + resource, form(""));
    return response.toObject().getString("data");
}
 

import us.monoid.web.Resty; //导入依赖的package包/类
public String stopQemuMachine(String node, Integer vmid) throws IOException, LoginException, JSONException {
    Resty r = authedClient();
    String resource = "nodes/" + node + "/qemu/" + vmid.toString() + "/status/stop";
    JSONResource response = r.json(baseURL + resource, form(""));
    return response.toObject().getString("data");
}