org.xowl.infra.server.xsp.XSPReplyUtils类的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(14.6k)|赞(0)|评价(0)|浏览(89)

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

XSPReplyUtils介绍

暂无

代码示例

代码示例来源：origin: org.xowl.platform/xowl-service-connection

  1. /**
  2.  * Responds to the request to delete a previously spawned parametric connector
  3.  *
  4.  * @param connectorId The identifier of the connector to delete
  5.  * @return The response
  6.  */
  7. private HttpResponse onMessageDeleteConnector(String connectorId) {
  8.   XSPReply reply = delete(connectorId);
  9.   return XSPReplyUtils.toHttpResponse(reply, null);
  10. }

代码示例来源：origin: org.xowl.platform/xowl-satellite-base

  1. /**
  2.    * Updates the content of this job
  3.    *
  4.    * @param definition The JSON definition
  5.    * @param factory    The factory for the result
  6.    */
  7.   void update(ASTNode definition, XOWLFactory factory) {
  8.     for (ASTNode member : definition.getChildren()) {
  9.       String head = IOUtils.unescape(member.getChildren().get(0).getValue());
  10.       head = head.substring(1, head.length() - 1);
  11.       if ("status".equals(head)) {
  12.         String value = IOUtils.unescape(member.getChildren().get(1).getValue());
  13.         this.status = value.substring(1, value.length() - 1);
  14.       } else if ("timeScheduled".equals(head)) {
  15.         String value = IOUtils.unescape(member.getChildren().get(1).getValue());
  16.         this.timeScheduled = value.substring(1, value.length() - 1);
  17.       } else if ("timeRun".equals(head)) {
  18.         String value = IOUtils.unescape(member.getChildren().get(1).getValue());
  19.         this.timeRun = value.substring(1, value.length() - 1);
  20.       } else if ("timeCompleted".equals(head)) {
  21.         String value = IOUtils.unescape(member.getChildren().get(1).getValue());
  22.         this.timeCompleted = value.substring(1, value.length() - 1);
  23.       } else if ("result".equals(head)) {
  24.         ASTNode value = member.getChildren().get(1);
  25.         if (!value.getChildren().isEmpty())
  26.           result = XSPReplyUtils.parseJSONResult(value, factory);
  27.       }
  28.     }
  29.   }
  30. }

代码示例来源：origin: org.xowl.platform/xowl-service-connection

  1. @Override
  2. public HttpResponse handle(SecurityService securedService, HttpApiRequest request) {
  3.   return XSPReplyUtils.toHttpResponse(XSPReplyUnsupported.instance(), null);
  4. }

代码示例来源：origin: org.xowl.platform/xowl-satellite-base

  1. ASTNode value = member.getChildren().get(1);
  2. if (!value.getChildren().isEmpty())
  3.   result = XSPReplyUtils.parseJSONResult(value, factory);

代码示例来源：origin: org.xowl.platform/xowl-service-domain

  1. /**
  2.  * Responds to the request to delete a previously spawned parametric connector
  3.  *
  4.  * @param parameters The request parameters
  5.  * @return The response
  6.  */
  7. private HttpResponse onMessageDeleteConnector(Map<String, String[]> parameters) {
  8.   String[] ids = parameters.get("id");
  9.   if (ids == null || ids.length == 0)
  10.     return new HttpResponse(HttpURLConnection.HTTP_BAD_REQUEST, HttpConstants.MIME_TEXT_PLAIN, "Expected an id parameter");
  11.   XSPReply reply = delete(ids[0]);
  12.   return XSPReplyUtils.toHttpResponse(reply, null);
  13. }

代码示例来源：origin: org.xowl.platform/xowl-kernel-impl

  1. /**
  2.  * Responds to a request for the list of available metrics
  3.  *
  4.  * @param securityService The current security service
  5.  * @return The metrics
  6.  */
  7. private HttpResponse onMessageGetMetricList(SecurityService securityService) {
  8.   XSPReply reply = securityService.checkAction(ACTION_GET_METRICS);
  9.   if (!reply.isSuccess())
  10.     return XSPReplyUtils.toHttpResponse(reply, null);
  11.   // get all the metrics
  12.   boolean first = true;
  13.   StringBuilder builder = new StringBuilder("[");
  14.   for (Metric metric : getMetrics()) {
  15.     if (!first)
  16.       builder.append(", ");
  17.     first = false;
  18.     builder.append(metric.serializedJSON());
  19.   }
  20.   builder.append("]");
  21.   return new HttpResponse(HttpURLConnection.HTTP_OK, HttpConstants.MIME_JSON, builder.toString());
  22. }

代码示例来源：origin: org.xowl.platform/xowl-service-impact

  1. @Override
  2. public HttpResponse handle(SecurityService securityService, HttpApiRequest request) {
  3.   if (!HttpConstants.METHOD_POST.equals(request.getMethod()))
  4.     return new HttpResponse(HttpURLConnection.HTTP_BAD_METHOD, HttpConstants.MIME_TEXT_PLAIN, "Expected POST method");
  5.   byte[] content = request.getContent();
  6.   if (content == null || content.length == 0)
  7.     return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_FAILED_TO_READ_CONTENT), null);
  8.   BufferedLogger logger = new BufferedLogger();
  9.   ASTNode root = JSONLDLoader.parseJSON(logger, new String(content, IOUtils.CHARSET));
  10.   if (root == null)
  11.     return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_CONTENT_PARSING_FAILED, logger.getErrorsAsString()), null);
  12.   return XSPReplyUtils.toHttpResponse(perform(new XOWLImpactAnalysisSetup(root)), null);
  13. }

代码示例来源：origin: org.xowl.platform/xowl-kernel-impl

  1. @Override
  2. public HttpResponse handle(SecurityService securityService, HttpApiRequest request) {
  3.   XSPReply reply = securityService.checkAction(ACTION_GET_LOG);
  4.   if (!reply.isSuccess())
  5.     return XSPReplyUtils.toHttpResponse(reply, null);
  6.   if (!HttpConstants.METHOD_GET.equals(request.getMethod()))
  7.     return new HttpResponse(HttpURLConnection.HTTP_BAD_METHOD, HttpConstants.MIME_TEXT_PLAIN, "Expected GET method");
  8.   StringBuilder builder = new StringBuilder("[");
  9.   boolean first = true;
  10.   for (PlatformLogMessage message : buffer.getMessages()) {
  11.     if (!first)
  12.       builder.append(", ");
  13.     first = false;
  14.     builder.append(message.serializedJSON());
  15.   }
  16.   builder.append("]");
  17.   return new HttpResponse(HttpURLConnection.HTTP_OK, HttpConstants.MIME_JSON, builder.toString());
  18. }

代码示例来源：origin: org.xowl.platform/xowl-service-lts

  1. return XSPReplyUtils.toHttpResponse(retrieve(id), null);
  2.   if (quads[0].equals("metadata"))
  3.     return onMessageGetArtifactMetadata(id);
  4. String[] archetypes = parameters.get("archetype");
  5. if (lives != null && lives.length > 0)
  6.   return XSPReplyUtils.toHttpResponse(getLiveArtifacts(), null);
  7. else if (bases != null && bases.length > 0)
  8.   return XSPReplyUtils.toHttpResponse(getArtifactsForBase(bases[0]), null);
  9. else if (archetypes != null && archetypes.length > 0)
  10.   return XSPReplyUtils.toHttpResponse(getArtifactsForArchetype(archetypes[0]), null);
  11. else
  12.   return XSPReplyUtils.toHttpResponse(getAllArtifacts(), null);

代码示例来源：origin: org.xowl.platform/xowl-service-collaboration

  1. return XSPReplyUtils.toHttpResponse(registerOutput(specId, artifactId), null);
  2. case HttpConstants.METHOD_DELETE:
  3.   return XSPReplyUtils.toHttpResponse(unregisterOutput(specId, artifactId), null);

代码示例来源：origin: org.xowl.platform/xowl-service-collaboration

  1. return XSPReplyUtils.toHttpResponse(registerInput(specId, artifactId), null);
  2. case HttpConstants.METHOD_DELETE:
  3.   return XSPReplyUtils.toHttpResponse(unregisterInput(specId, artifactId), null);

代码示例来源：origin: org.xowl.platform/xowl-connector-semanticweb

  1. String contentType = request.getContentType();
  2. if (name == null)
  3.   return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_EXPECTED_QUERY_PARAMETERS, "'name'"), null);
  4. if (base == null)
  5.   return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_EXPECTED_QUERY_PARAMETERS, "'base'"), null);
  6. if (version == null)
  7.   return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_EXPECTED_QUERY_PARAMETERS, "'version'"), null);
  8. if (archetype == null)
  9.   return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_EXPECTED_QUERY_PARAMETERS, "'archetype'"), null);
  10. if (contentType == null || contentType.isEmpty())
  11.   return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_EXPECTED_HEADER_CONTENT_TYPE), null);
  12. int index = contentType.indexOf(";");
  13. if (index != -1)
  14. XSPReply reply = loader.load(new InputStreamReader(new ByteArrayInputStream(request.getContent())), resource, contentType);
  15. if (!reply.isSuccess())
  16.   return XSPReplyUtils.toHttpResponse(reply, null);

代码示例来源：origin: org.xowl.platform/xowl-kernel-impl

  1. /**
  2.  * Responds to a request for the policy resource
  3.  *
  4.  * @param request The web API request to handle
  5.  * @return The HTTP response
  6.  */
  7. private HttpResponse handleRequestPolicy(HttpApiRequest request) {
  8.   if (request.getUri().equals(apiUri + "/policy")) {
  9.     if (!HttpConstants.METHOD_GET.equals(request.getMethod()))
  10.       return new HttpResponse(HttpURLConnection.HTTP_BAD_METHOD, HttpConstants.MIME_TEXT_PLAIN, "Expected GET method");
  11.     return XSPReplyUtils.toHttpResponse(getPolicy().getConfiguration(), null);
  12.   }
  13.   if (request.getUri().startsWith(apiUri + "/policy/actions/")) {
  14.     String rest = request.getUri().substring(apiUri.length() + "/policy/actions/".length());
  15.     String actionId = URIUtils.decodeComponent(rest);
  16.     if (actionId.isEmpty())
  17.       return new HttpResponse(HttpURLConnection.HTTP_NOT_FOUND);
  18.     if (!HttpConstants.METHOD_PUT.equals(request.getMethod()))
  19.       return new HttpResponse(HttpURLConnection.HTTP_BAD_METHOD, HttpConstants.MIME_TEXT_PLAIN, "Expected PUT method");
  20.     String definition = new String(request.getContent(), IOUtils.CHARSET);
  21.     return XSPReplyUtils.toHttpResponse(getPolicy().setPolicy(actionId, definition), null);
  22.   }
  23.   return new HttpResponse(HttpURLConnection.HTTP_NOT_FOUND);
  24. }

代码示例来源：origin: org.xowl.platform/xowl-service-collaboration

  1. return XSPReplyUtils.toHttpResponse(delete(neighbourId), null);
  2.   if (!HttpConstants.METHOD_GET.equals(request.getMethod()))
  3.     return new HttpResponse(HttpURLConnection.HTTP_BAD_METHOD, HttpConstants.MIME_TEXT_PLAIN, "Expected GET method");
  4.   return XSPReplyUtils.toHttpResponse(getNeighbourManifest(neighbourId), null);
  5.   if (!HttpConstants.METHOD_POST.equals(request.getMethod()))
  6.     return new HttpResponse(HttpURLConnection.HTTP_BAD_METHOD, HttpConstants.MIME_TEXT_PLAIN, "Expected POST method");
  7.   return XSPReplyUtils.toHttpResponse(archive(neighbourId), null);
  8.   return XSPReplyUtils.toHttpResponse(restart(neighbourId), null);
  9. rest = rest.substring("manifest/inputs/".length(), rest.length() - "/artifacts".length());
  10. String specId = URIUtils.decodeComponent(rest);
  11. return XSPReplyUtils.toHttpResponse(getNeighbourInputsFor(neighbourId, specId), null);
  12. return XSPReplyUtils.toHttpResponse(getNeighbourOutputsFor(neighbourId, specId), null);

代码示例来源：origin: org.xowl.platform/xowl-service-collaboration

  1. String content = new String(request.getContent(), IOUtils.CHARSET);
  2. if (content.isEmpty())
  3.   return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_FAILED_TO_READ_CONTENT), null);
  4. BufferedLogger logger = new BufferedLogger();
  5. ASTNode root = JSONLDLoader.parseJSON(logger, content);
  6. if (root == null)
  7.   return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_CONTENT_PARSING_FAILED, logger.getErrorsAsString()), null);
  8. CollaborationSpecification specification = new CollaborationSpecification(root);
  9. JobExecutionService executionService = Register.getComponent(JobExecutionService.class);
  10. if (executionService == null)
  11.   return XSPReplyUtils.toHttpResponse(XSPReplyServiceUnavailable.instance(), null);
  12. return XSPReplyUtils.toHttpResponse(executionService.schedule(new CollaborationSpawnJob(specification)), null);

代码示例来源：origin: org.xowl.platform/xowl-service-connection

  1. String descriptorId = request.getParameter("descriptor");
  2. if (descriptorId == null)
  3.   return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_EXPECTED_QUERY_PARAMETERS, "'descriptor'"), null);
  4. String content = new String(request.getContent(), IOUtils.CHARSET);
  5. if (content.isEmpty())
  6.   return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_FAILED_TO_READ_CONTENT), null);
  7.   return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_CONTENT_PARSING_FAILED, logger.getErrorsAsString()), null);
  8.   return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_PARAMETER_RANGE, "'descriptor' is not the identifier of a recognized connector descriptor"), null);
  9. ConnectorServiceData specification = new ConnectorServiceData(descriptor, root);
  10. if (!specification.getIdentifier().equals(connectorId))
  11.   return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_PARAMETER_RANGE, "'identifier' is not the same as URI parameter"), null);
  12. XSPReply reply = spawn(descriptor, specification);
  13. if (!reply.isSuccess())
  14.   return XSPReplyUtils.toHttpResponse(reply, null);
  15. return new HttpResponse(HttpURLConnection.HTTP_OK, HttpConstants.MIME_JSON, ((XSPReplyResult<ConnectorService>) reply).getData().serializedJSON());

代码示例来源：origin: org.xowl.platform/xowl-service-collaboration

  1. String content = new String(request.getContent(), IOUtils.CHARSET);
  2.     if (content.isEmpty())
  3.       return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_FAILED_TO_READ_CONTENT), null);
  4.     BufferedLogger logger = new BufferedLogger();
  5.     ASTNode root = JSONLDLoader.parseJSON(logger, content);
  6.     if (root == null)
  7.       return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_CONTENT_PARSING_FAILED, logger.getErrorsAsString()), null);
  8.     ArtifactSpecification specification = new ArtifactSpecification(root);
  9.     return XSPReplyUtils.toHttpResponse(addInputSpecification(specification), null);
  10. if (!HttpConstants.METHOD_DELETE.equals(request.getMethod()))
  11.   return new HttpResponse(HttpURLConnection.HTTP_BAD_METHOD, HttpConstants.MIME_TEXT_PLAIN, "Expected DELETE method");
  12. return XSPReplyUtils.toHttpResponse(removeInputSpecification(specId), null);

代码示例来源：origin: org.xowl.platform/xowl-service-collaboration

  1. String content = new String(request.getContent(), IOUtils.CHARSET);
  2.     if (content.isEmpty())
  3.       return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_FAILED_TO_READ_CONTENT), null);
  4.     BufferedLogger logger = new BufferedLogger();
  5.     ASTNode root = JSONLDLoader.parseJSON(logger, content);
  6.     if (root == null)
  7.       return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_CONTENT_PARSING_FAILED, logger.getErrorsAsString()), null);
  8.     ArtifactSpecification specification = new ArtifactSpecification(root);
  9.     return XSPReplyUtils.toHttpResponse(addOutputSpecification(specification), null);
  10. if (!HttpConstants.METHOD_DELETE.equals(request.getMethod()))
  11.   return new HttpResponse(HttpURLConnection.HTTP_BAD_METHOD, HttpConstants.MIME_TEXT_PLAIN, "Expected DELETE method");
  12. return XSPReplyUtils.toHttpResponse(removeOutputSpecification(specId), null);

代码示例来源：origin: org.xowl.platform/xowl-service-collaboration

  1. String content = new String(request.getContent(), IOUtils.CHARSET);
  2.       if (content.isEmpty())
  3.         return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_FAILED_TO_READ_CONTENT), null);
  4.       BufferedLogger logger = new BufferedLogger();
  5.       ASTNode root = JSONLDLoader.parseJSON(logger, content);
  6.       if (root == null)
  7.         return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_CONTENT_PARSING_FAILED, logger.getErrorsAsString()), null);
  8.       PlatformRoleBase role = new PlatformRoleBase(root);
  9.       return XSPReplyUtils.toHttpResponse(createRole(role.getIdentifier(), role.getName()), null);
  10. switch (request.getMethod()) {
  11.   case HttpConstants.METHOD_DELETE:
  12.     return XSPReplyUtils.toHttpResponse(removeRole(roleId), null);
  13.   case HttpConstants.METHOD_PUT:
  14.     return XSPReplyUtils.toHttpResponse(addRole(roleId), null);

代码示例来源：origin: org.xowl.platform/xowl-service-collaboration

  1. if (!HttpConstants.METHOD_POST.equals(request.getMethod()))
  2.     return new HttpResponse(HttpURLConnection.HTTP_BAD_METHOD, HttpConstants.MIME_TEXT_PLAIN, "Expected POST method");
  3.   return XSPReplyUtils.toHttpResponse(archive(), null);
  4. } else if (request.getUri().equals(apiUri + "/delete")) {
  5.   if (!HttpConstants.METHOD_POST.equals(request.getMethod()))
  6.     return new HttpResponse(HttpURLConnection.HTTP_BAD_METHOD, HttpConstants.MIME_TEXT_PLAIN, "Expected POST method");
  7.   return XSPReplyUtils.toHttpResponse(delete(), null);
  8. } else if (request.getUri().startsWith(apiUri + "/manifest")) {
  9.   return handleManifest(request);

内容来源于网络，如有侵权，请联系作者删除！

XSPReplyUtils

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    XSPReplyUtils类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com