- @SuppressWarnings("synthetic-access")
- public void gotResult(HighLevelCallback<RequestListResult> highLevelCallback) {
- RequestListResult requestListResult;
- try {
- requestListResult = highLevelCallback.getResult();
- } catch (InterruptedException e) {
- logger.log(Level.SEVERE, "getResult() blocked and was interrupted");
- return;
- }
- for (RequestResult requestResult: requestListResult) {
- String identifier = requestResult.getIdentifier();
- logger.log(Level.FINER, "got identifier: " + identifier);
- Request request = identifierRequests.get(identifier);
- if (request == null) {
- request = new Request(node, identifier);
- }
- if (request.getType() == null) {
- if (requestResult instanceof GetRequestResult) {
- request.setType(Type.get);
- } else if (requestResult instanceof PutRequestResult) {
- request.setType(Type.put);
- } else if (requestResult instanceof PutDirRequestResult) {
- request.setType(Type.putDir);
- }
- }
- if (identifierRequests.containsKey(identifier)) {
- continue;
- }
- identifierRequests.put(requestResult.getIdentifier(), request);
- fireRequestAdded(request);
- }
- }
- });
- } catch (HighLevelException hle1) {
- throw new BackendException(hle1);
+ /**
+ * Wraps the requests of the FCP API into jSite requests.
+ *
+ * @param requests
+ * The requests to wrap
+ * @return The wrapped requests
+ */
+ private Collection<Request> wrapRequests(Collection<net.pterodactylus.fcp.highlevel.Request> requests) {
+ Collection<Request> wrappedRequests = new HashSet<Request>();
+ for (net.pterodactylus.fcp.highlevel.Request request : requests) {
+ Request wrappedRequest = new Request(request.getIdentifier());
+ wrappedRequest.setClientToken(request.getClientToken());
+ wrappedRequests.add(wrappedRequest);