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

XSPReplyApiError.<init>介绍

暂无

代码示例

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

/**
 * Realizes the action to pull an artifact
 *
 * @return The operation's result
 */
protected XSPReply doPullArtifact() {
  Artifact artifact = input.poll();
  if (artifact == null)
    return new XSPReplyApiError(ConnectionService.ERROR_EMPTY_QUEUE);
  return new XSPReplyResult<>(artifact);
}

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

@Override
  public XSPReply setPolicy(String actionId, String policyDefinition) {
    ASTNode definition = JSONLDLoader.parseJSON(Logging.get(), policyDefinition);
    if (definition == null)
      return new XSPReplyApiError(HttpApiService.ERROR_CONTENT_PARSING_FAILED);
    SecuredActionPolicy policy = SecuredActionPolicyBase.load(definition);
    if (policy == null)
      return new XSPReplyApiError(HttpApiService.ERROR_CONTENT_PARSING_FAILED, "Invalid policy definition");
    return setPolicy(actionId, policy);
  }
}

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

/**
 * @param reader      The reader to read from
 * @param resourceIRI The IRI for the resource to load
 * @param syntax      The expected syntax
 * @return The reply
 */
public XSPReply load(Reader reader, String resourceIRI, String syntax) {
  BufferedLogger bufferedLogger = new BufferedLogger();
  try {
    Collection<Quad> quads = load(bufferedLogger, reader, resourceIRI, syntax);
    if (quads == null || !bufferedLogger.getErrorMessages().isEmpty())
      return new XSPReplyApiError(HttpApiService.ERROR_CONTENT_PARSING_FAILED, bufferedLogger.getErrorsAsString());
    return new XSPReplyResultCollection<>(quads);
  } catch (TranslationException exception) {
    bufferedLogger.error(exception);
    return new XSPReplyApiError(HttpApiService.ERROR_CONTENT_PARSING_FAILED, bufferedLogger.getErrorsAsString());
  }
}

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

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

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

@Override
public XSPReply unassignRoleToGroup(String group, String role) {
  // check input data
  PlatformGroup groupObj = getGroup(group);
  if (groupObj == null)
    return new XSPReplyApiError(ERROR_INVALID_GROUP, group);
  PlatformRole roleObj = getRole(role);
  if (roleObj == null)
    return new XSPReplyApiError(ERROR_INVALID_ROLE, role);
  // check for current user with admin role
  SecurityService securityService = Register.getComponent(SecurityService.class);
  if (securityService == null)
    return XSPReplyServiceUnavailable.instance();
  XSPReply reply = securityService.getPolicy().checkAction(securityService, SecurityService.ACTION_UNASSIGN_ROLE_TO_GROUP);
  if (!reply.isSuccess())
    return reply;
  // execute
  Map<String, Node> parameters = new HashMap<>();
  parameters.put("entity", nodes.getIRINode(GROUPS + group));
  parameters.put("role", nodes.getIRINode(ROLES + role));
  reply = database.executeStoredProcedure(procedures.get("procedure-unassign-role"),
      new BaseStoredProcedureContext(Collections.<String>emptyList(), Collections.<String>emptyList(), parameters));
  if (!reply.isSuccess())
    return reply;
  return XSPReplySuccess.instance();
}

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

@Override
public XSPReply addAdminToGroup(String user, String group) {
  // check input data
  PlatformGroup groupObject = getGroup(group);
  if (groupObject == null)
    return new XSPReplyApiError(ERROR_INVALID_GROUP, group);
  PlatformUser newUser = getUser(user);
  if (newUser == null)
    return new XSPReplyApiError(ERROR_INVALID_USER, user);
  // check the current user is either the platform admin or the group admin
  SecurityService securityService = Register.getComponent(SecurityService.class);
  if (securityService == null)
    return XSPReplyServiceUnavailable.instance();
  XSPReply reply = securityService.getPolicy().checkAction(securityService, SecurityService.ACTION_ADD_ADMIN_TO_GROUP, groupObject);
  if (!reply.isSuccess())
    return reply;
  // execute
  Map<String, Node> parameters = new HashMap<>();
  parameters.put("group", nodes.getIRINode(GROUPS + group));
  parameters.put("admin", nodes.getIRINode(USERS + user));
  reply = database.executeStoredProcedure(procedures.get("procedure-add-admin"),
      new BaseStoredProcedureContext(Collections.<String>emptyList(), Collections.<String>emptyList(), parameters));
  if (!reply.isSuccess())
    return reply;
  return XSPReplySuccess.instance();
}

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

@Override
public XSPReply assignRoleToUser(String user, String role) {
  // check input data
  PlatformUser userObj = getUser(user);
  if (userObj == null)
    return new XSPReplyApiError(ERROR_INVALID_USER, user);
  PlatformRole roleObj = getRole(role);
  if (roleObj == null)
    return new XSPReplyApiError(ERROR_INVALID_ROLE, role);
  // check for current user with admin role
  SecurityService securityService = Register.getComponent(SecurityService.class);
  if (securityService == null)
    return XSPReplyServiceUnavailable.instance();
  XSPReply reply = securityService.getPolicy().checkAction(securityService, SecurityService.ACTION_ASSIGN_ROLE_TO_USER);
  if (!reply.isSuccess())
    return reply;
  // execute
  Map<String, Node> parameters = new HashMap<>();
  parameters.put("entity", nodes.getIRINode(USERS + user));
  parameters.put("role", nodes.getIRINode(ROLES + role));
  reply = database.executeStoredProcedure(procedures.get("procedure-assign-role"),
      new BaseStoredProcedureContext(Collections.<String>emptyList(), Collections.<String>emptyList(), parameters));
  if (!reply.isSuccess())
    return reply;
  return XSPReplySuccess.instance();
}

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

@Override
public XSPReply removeAdminFromGroup(String user, String group) {
  // check input data
  PlatformGroup groupObject = getGroup(group);
  if (groupObject == null)
    return new XSPReplyApiError(ERROR_INVALID_GROUP, group);
  PlatformUser newUser = getUser(user);
  if (newUser == null)
    return new XSPReplyApiError(ERROR_INVALID_USER, user);
  // check the current user is either the platform admin or the group admin
  SecurityService securityService = Register.getComponent(SecurityService.class);
  if (securityService == null)
    return XSPReplyServiceUnavailable.instance();
  XSPReply reply = securityService.getPolicy().checkAction(securityService, SecurityService.ACTION_REMOVE_ADMIN_FROM_GROUP, groupObject);
  if (!reply.isSuccess())
    return reply;
  // execute
  Map<String, Node> parameters = new HashMap<>();
  parameters.put("group", nodes.getIRINode(GROUPS + group));
  parameters.put("admin", nodes.getIRINode(USERS + user));
  reply = database.executeStoredProcedure(procedures.get("procedure-remove-admin"),
      new BaseStoredProcedureContext(Collections.<String>emptyList(), Collections.<String>emptyList(), parameters));
  if (!reply.isSuccess())
    return reply;
  return XSPReplySuccess.instance();
}

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

@Override
public XSPReply unassignRoleToUser(String user, String role) {
  // check input data
  PlatformUser userObj = getUser(user);
  if (userObj == null)
    return new XSPReplyApiError(ERROR_INVALID_USER, user);
  PlatformRole roleObj = getRole(role);
  if (roleObj == null)
    return new XSPReplyApiError(ERROR_INVALID_ROLE, role);
  // check for current user with admin role
  SecurityService securityService = Register.getComponent(SecurityService.class);
  if (securityService == null)
    return XSPReplyServiceUnavailable.instance();
  XSPReply reply = securityService.getPolicy().checkAction(securityService, SecurityService.ACTION_UNASSIGN_ROLE_TO_USER);
  if (!reply.isSuccess())
    return reply;
  // execute
  Map<String, Node> parameters = new HashMap<>();
  parameters.put("entity", nodes.getIRINode(USERS + user));
  parameters.put("role", nodes.getIRINode(ROLES + role));
  reply = database.executeStoredProcedure(procedures.get("procedure-unassign-role"),
      new BaseStoredProcedureContext(Collections.<String>emptyList(), Collections.<String>emptyList(), parameters));
  if (!reply.isSuccess())
    return reply;
  return XSPReplySuccess.instance();
}

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

@Override
public XSPReply renameUser(String identifier, String name) {
  // check authorization
  SecurityService securityService = Register.getComponent(SecurityService.class);
  if (securityService == null)
    return XSPReplyServiceUnavailable.instance();
  PlatformUser userObject = getUser(identifier);
  if (userObject == null)
    return new XSPReplyApiError(ERROR_INVALID_USER, identifier);
  XSPReply reply = securityService.getPolicy().checkAction(securityService, SecurityService.ACTION_RENAME_USER, userObject);
  if (!reply.isSuccess())
    return reply;
  synchronized (cacheUsers) {
    Map<String, Node> parameters = new HashMap<>();
    parameters.put("entity", nodes.getIRINode(USERS + identifier));
    parameters.put("newName", nodes.getLiteralNode(name, Vocabulary.xsdString, null));
    reply = database.executeStoredProcedure(procedures.get("procedure-rename-entity"),
        new BaseStoredProcedureContext(Collections.<String>emptyList(), Collections.<String>emptyList(), parameters));
    if (!reply.isSuccess())
      return reply;
    cacheUsers.remove(identifier);
    return XSPReplySuccess.instance();
  }
}

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

@Override
public XSPReply renameGroup(String identifier, String name) {
  // check authorization
  SecurityService securityService = Register.getComponent(SecurityService.class);
  if (securityService == null)
    return XSPReplyServiceUnavailable.instance();
  PlatformGroup groupObject = getGroup(identifier);
  if (groupObject == null)
    return new XSPReplyApiError(ERROR_INVALID_GROUP, identifier);
  XSPReply reply = securityService.getPolicy().checkAction(securityService, SecurityService.ACTION_RENAME_GROUP, groupObject);
  if (!reply.isSuccess())
    return reply;
  synchronized (cacheGroups) {
    // rename the entity
    Map<String, Node> parameters = new HashMap<>();
    parameters.put("entity", nodes.getIRINode(GROUPS + identifier));
    parameters.put("newName", nodes.getLiteralNode(name, Vocabulary.xsdString, null));
    reply = database.executeStoredProcedure(procedures.get("procedure-rename-entity"),
        new BaseStoredProcedureContext(Collections.<String>emptyList(), Collections.<String>emptyList(), parameters));
    if (!reply.isSuccess())
      return reply;
    cacheGroups.remove(identifier);
    return XSPReplySuccess.instance();
  }
}

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

@Override
public XSPReply renameRole(String identifier, String name) {
  // check authorization
  SecurityService securityService = Register.getComponent(SecurityService.class);
  if (securityService == null)
    return XSPReplyServiceUnavailable.instance();
  PlatformRole roleObject = getRole(identifier);
  if (roleObject == null)
    return new XSPReplyApiError(ERROR_INVALID_ROLE, identifier);
  XSPReply reply = securityService.getPolicy().checkAction(securityService, SecurityService.ACTION_RENAME_ROLE, roleObject);
  if (!reply.isSuccess())
    return reply;
  synchronized (cacheRoles) {
    // rename the entity
    Map<String, Node> parameters = new HashMap<>();
    parameters.put("entity", nodes.getIRINode(ROLES + identifier));
    parameters.put("newName", nodes.getLiteralNode(name, Vocabulary.xsdString, null));
    reply = database.executeStoredProcedure(procedures.get("procedure-rename-entity"),
        new BaseStoredProcedureContext(Collections.<String>emptyList(), Collections.<String>emptyList(), parameters));
    if (!reply.isSuccess())
      return reply;
    cacheRoles.remove(identifier);
    return XSPReplySuccess.instance();
  }
}

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

@Override
public XSPReply createRole(String identifier, String name) {
  // check authorization
  SecurityService securityService = Register.getComponent(SecurityService.class);
  if (securityService == null)
    return XSPReplyServiceUnavailable.instance();
  XSPReply reply = securityService.getPolicy().checkAction(securityService, SecurityService.ACTION_CREATE_ROLE);
  if (!reply.isSuccess())
    return reply;
  // check identifier format
  if (!identifier.matches("[_a-zA-Z0-9]+"))
    return new XSPReplyApiError(ERROR_INVALID_IDENTIFIER, "[_a-zA-Z0-9]+");
  // create the group data
  Map<String, Node> parameters = new HashMap<>();
  parameters.put("role", nodes.getIRINode(ROLES + identifier));
  parameters.put("name", nodes.getLiteralNode(name, Vocabulary.xsdString, null));
  reply = database.executeStoredProcedure(procedures.get("procedure-create-role"),
      new BaseStoredProcedureContext(Collections.<String>emptyList(), Collections.<String>emptyList(), parameters));
  if (!reply.isSuccess())
    return reply;
  PlatformRoleBase role = getRole(identifier, name);
  EventService eventService = Register.getComponent(EventService.class);
  if (eventService != null)
    eventService.onEvent(new PlatformRoleCreatedEvent(role, securityService));
  return new XSPReplyResult<>(role);
}

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

@Override
public XSPReply cancel(Job job) {
  SecurityService securityService = Register.getComponent(SecurityService.class);
  if (securityService == null)
    return XSPReplyServiceUnavailable.instance();
  XSPReply reply = securityService.checkAction(ACTION_CANCEL, job);
  if (!reply.isSuccess())
    return reply;
  boolean success = executorPool.remove(job);
  if (success) {
    // the job was queued and prevented from running
    job.onTerminated(true);
    return XSPReplySuccess.instance();
  }
  switch (job.getStatus()) {
    case Unscheduled:
    case Scheduled:
      job.onTerminated(true);
      return XSPReplySuccess.instance();
    case Running:
      return job.cancel();
    case Completed:
      return new XSPReplyApiError(ERROR_ALREADY_COMPLETED);
    case Cancelled:
      return new XSPReplyApiError(ERROR_ALREADY_CANCELLED);
    default:
      return new XSPReplyApiError(ERROR_INVALID_JOB_STATE, job.getStatus().toString());
  }
}

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

/**
 * Responds to a request for the login resource
 *
 * @param request The web API request to handle
 * @return The HTTP response
 */
private HttpResponse handleRequestLogin(HttpApiRequest request) {
  if (!HttpConstants.METHOD_POST.equals(request.getMethod()))
    return new HttpResponse(HttpURLConnection.HTTP_BAD_METHOD, HttpConstants.MIME_TEXT_PLAIN, "Expected POST method");
  String login = request.getParameter("login");
  if (login == null)
    return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_EXPECTED_QUERY_PARAMETERS, "'login'"), null);
  String password = new String(request.getContent(), IOUtils.CHARSET);
  XSPReply reply = login(request.getClient(), login, password);
  if (!reply.isSuccess())
    return XSPReplyUtils.toHttpResponse(reply, null);
  String token = ((XSPReplyResult<String>) reply).getData();
  HttpResponse response = new HttpResponse(HttpURLConnection.HTTP_OK, HttpConstants.MIME_JSON, getCurrentUser().serializedJSON());
  response.addHeader(HttpConstants.HEADER_SET_COOKIE, AUTH_TOKEN + "=" + token +
      "; Max-Age=" + Long.toString(securityTokenTTL) +
      "; Path=" + PlatformHttp.getUriPrefixApi() +
      "; Secure" +
      "; HttpOnly");
  return response;
}

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

/**
   * Responds to the request to push an artifact to a connector
   * When successful, this action creates the appropriate job and returns it.
   *
   * @param connectorId The identifier of the connector to delete
   * @param request     The request to handle
   * @return The response
   */
  private HttpResponse onMessagePushToConnector(String connectorId, HttpApiRequest request) {
    String artifact = request.getParameter("artifact");
    if (artifact == null)
      return XSPReplyUtils.toHttpResponse(new XSPReplyApiError(ERROR_EXPECTED_QUERY_PARAMETERS, "'artifact'"), null);

    JobExecutionService executor = Register.getComponent(JobExecutionService.class);
    if (executor == null)
      return XSPReplyUtils.toHttpResponse(XSPReplyServiceUnavailable.instance(), null);
    Job job = new PushArtifactJob(connectorId, artifact);
    executor.schedule(job);
    return new HttpResponse(HttpURLConnection.HTTP_OK, HttpConstants.MIME_JSON, job.serializedJSON());
  }
}

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

@Override
public XSPReply changeUserKey(String identifier, String oldKey, String newKey) {
  // check authorization
  SecurityService securityService = Register.getComponent(SecurityService.class);
  if (securityService == null)
    return XSPReplyServiceUnavailable.instance();
  PlatformUser platformUser = authenticate(identifier, oldKey);
  if (platformUser == null)
    return new XSPReplyApiError(ERROR_INVALID_USER, identifier);
  XSPReply reply = securityService.getPolicy().checkAction(securityService, SecurityService.ACTION_UPDATE_USER_KEY, platformUser);
  if (!reply.isSuccess())
    return reply;
  // execute
  reply = server.getUser(identifier);
  if (!reply.isSuccess())
    return reply;
  XOWLUser xowlUser = ((XSPReplyResult<XOWLUser>) reply).getData();
  return xowlUser.updatePassword(newKey);
}

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

@Override
public XSPReply resetUserKey(String identifier, String newKey) {
  // check authorization
  SecurityService securityService = Register.getComponent(SecurityService.class);
  if (securityService == null)
    return XSPReplyServiceUnavailable.instance();
  PlatformUser platformUser = getUser(identifier);
  if (platformUser == null)
    return new XSPReplyApiError(ERROR_INVALID_USER, identifier);
  XSPReply reply = securityService.getPolicy().checkAction(securityService, SecurityService.ACTION_RESET_USER_KEY, platformUser);
  if (!reply.isSuccess())
    return reply;
  // execute
  reply = server.getUser(identifier);
  if (!reply.isSuccess())
    return reply;
  XOWLUser xowlUser = ((XSPReplyResult<XOWLUser>) reply).getData();
  return xowlUser.updatePassword(newKey);
}

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

@Override
public XSPReply deleteRule(ConsistencyRule rule) {
  StorageService storageService = Register.getComponent(StorageService.class);
  if (storageService == null)
    return XSPReplyServiceUnavailable.instance();
  TripleStore live = storageService.getLiveStore();
  XSPReply reply = live.removeRule(rule);
  if (!reply.isSuccess())
    return reply;
  reply = live.sparql("DELETE WHERE { GRAPH <" +
      TextUtils.escapeAbsoluteURIW3C(IRI_RULE_METADATA) +
      "> { <" +
      TextUtils.escapeAbsoluteURIW3C(rule.getIdentifier()) +
      "> ?p ?o } }", null, null);
  if (!reply.isSuccess())
    return reply;
  Result sparqlResult = ((XSPReplyResult<Result>) reply).getData();
  if (sparqlResult.isFailure())
    return new XSPReplyApiError(ArtifactStorageService.ERROR_STORAGE_FAILED, ((ResultFailure) sparqlResult).getMessage());
  EventService eventService = Register.getComponent(EventService.class);
  if (eventService != null)
    eventService.onEvent(new ConsistencyRuleDeletedEvent(rule, this));
  return XSPReplySuccess.instance();
}

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

@Override
public XSPReply addRule(ConsistencyRule rule) {
  StorageService storageService = Register.getComponent(StorageService.class);
  if (storageService == null)
    return XSPReplyServiceUnavailable.instance();
  TripleStore live = storageService.getLiveStore();
  XSPReply reply = live.addRule(rule.getDefinition(), rule.isActive());
  if (!reply.isSuccess())
    return reply;
  reply = live.sparql("INSERT DATA { GRAPH <" + TextUtils.escapeAbsoluteURIW3C(IRI_RULE_METADATA) + "> {" +
      "<" + TextUtils.escapeAbsoluteURIW3C(rule.getIdentifier()) + "> <" + TextUtils.escapeAbsoluteURIW3C(Vocabulary.rdfType) + "> <" + TextUtils.escapeAbsoluteURIW3C(IRI_RULE) + "> ." +
      "<" + TextUtils.escapeAbsoluteURIW3C(rule.getIdentifier()) + "> <" + TextUtils.escapeAbsoluteURIW3C(KernelSchema.NAME) + "> \"" + TextUtils.escapeStringW3C(rule.getName()) + "\" ." +
      "<" + TextUtils.escapeAbsoluteURIW3C(rule.getIdentifier()) + "> <" + TextUtils.escapeAbsoluteURIW3C(IRI_DEFINITION) + "> \"" + TextUtils.escapeStringW3C(rule.getDefinition()) + "\" ." +
      "} }", null, null);
  if (!reply.isSuccess())
    return reply;
  Result sparqlResult = ((XSPReplyResult<Result>) reply).getData();
  if (sparqlResult.isFailure())
    return new XSPReplyApiError(ArtifactStorageService.ERROR_STORAGE_FAILED, ((ResultFailure) sparqlResult).getMessage());
  EventService eventService = Register.getComponent(EventService.class);
  if (eventService != null)
    eventService.onEvent(new ConsistencyRuleCreatedEvent(rule, this));
  return new XSPReplyResult<>(rule);
}