Java 类io.vertx.core.json.DecodeException 实例源码

项目：okapi 文件：BeanTest.java

@Test
public void testDeploymentDescriptor1() {
  int fail = 0;
  final String docSampleDeployment = "{" + LS
    + "  \"srvcId\" : \"sample-module-1\"," + LS
    + "  \"descriptor\" : {" + LS
    + "    \"exec\" : "
    + "\"java -Dport=%p -jar ../okapi-test-module/target/okapi-test-module-fat.jar\"," + LS
    + "    \"env\" : [ {" + LS
    + "      \"name\" : \"helloGreeting\"," + LS
    + "      \"value\" : \"hej\"" + LS
    + "    } ]" + LS
    + "  }" + LS
    + "}";

  try {
    final DeploymentDescriptor md = Json.decodeValue(docSampleDeployment,
      DeploymentDescriptor.class);
    String pretty = Json.encodePrettily(md);
    assertEquals(docSampleDeployment, pretty);
  } catch (DecodeException ex) {
    ex.printStackTrace();
    fail = 400;
  }
  assertEquals(0, fail);
}

项目：vertx-zero 文件：JsonSaber.java

@Override
public Object from(final Class<?> paramType,
                   final String literal) {
    return Fn.get(() ->
                    Fn.getSemi(this.isValid(paramType), this.getLogger(),
                            () -> {
                                try {
                                    return this.getFun().apply(literal);
                                } catch (final DecodeException ex) {
                                    // Do not do anything
                                    // getLogger().jvm(ex);
                                    throw new _400ParameterFromStringException(this.getClass(), paramType, literal);
                                }
                            }, Fn::nil),
            paramType, literal);
}

项目：vertx-postgresql-starter 文件：RestApiUtil.java

public static <T> T decodeBodyToObject(RoutingContext routingContext, Class<T> clazz) {
  try {
    return Json.decodeValue(routingContext.getBodyAsString("UTF-8"), clazz);
  } catch (DecodeException exception) {
    routingContext.fail(exception);
    return null;
  }
}

项目：vertx-web-problem 文件：ExampleVerticle.java

@Override
public void start(Future<Void> startFuture) throws Exception {
    configureJsonMapper();
    Router router = Router.router(vertx);

    router.route().handler(BodyHandler.create());
    router.route().failureHandler(one.valuelogic.vertx.web.problem.reactivex.ProblemHandler.create());
    router.get("/test-get").handler(context -> context.response().end("ok"));
    router.get("/test-error").handler(context -> { throw new DecodeException("testing decode error"); });
    router.route().last().handler(one.valuelogic.vertx.web.problem.reactivex.NotFoundHandler.create());

    vertx.createHttpServer()
            .requestHandler(router::accept)
            .rxListen(HTTP_PORT)
            .subscribe(s -> startFuture.complete(), startFuture::fail);
}

项目：chili-core 文件：RequestMock.java

@Override
public void reply(Object message) {
    JsonObject data = new JsonObject();

    if (message instanceof JsonObject) {
        data = (JsonObject) message;
    } else if (message instanceof Buffer) {
        // normally buffers passed directly, for testing purposes
        // its wrapped in a json object.
        try {
            data = ((Buffer) message).toJsonObject();

            if (!data.containsKey(PROTOCOL_STATUS)) {
                data.put(PROTOCOL_STATUS, ACCEPTED);
            }
        } catch (DecodeException e) {
            data.put(ID_BUFFER, message.toString());
            data.put(PROTOCOL_STATUS, ACCEPTED);
        }
    }
    listener.handle(data, responseStatusFromJson(data));
}

项目：vertx-swagger 文件：BodyParameterExtractor.java

@Override
public Object extract(String name, Parameter parameter, RoutingContext context) {
    BodyParameter bodyParam = (BodyParameter) parameter;
    if ("".equals(context.getBodyAsString())) {
        if (bodyParam.getRequired())
            throw new IllegalArgumentException("Missing required parameter: " + name);
        else
            return null;
    }

    try {
        if(bodyParam.getSchema() instanceof ArrayModel) {
            return context.getBodyAsJsonArray();
        } else {
            return context.getBodyAsJson();
        }
    } catch (DecodeException e) {
        return context.getBodyAsString();  
    }
}

项目：okapi 文件：Auth.java

public void login(RoutingContext ctx) {
  final String json = ctx.getBodyAsString();
  if (json.length() == 0) {
    logger.debug("test-auth: accept OK in login");
    responseText(ctx, 202).end("Auth accept in /authn/login");
    return;
  }
  LoginParameters p;
  try {
    p = Json.decodeValue(json, LoginParameters.class);
  } catch (DecodeException ex) {
    responseText(ctx, 400).end("Error in decoding parameters: " + ex);
    return;
  }

  // Simple password validation: "peter" has a password "peter-password", etc.
  String u = p.getUsername();
  String correctpw = u + "-password";
  if (!p.getPassword().equals(correctpw)) {
    logger.warn("test-auth: Bad passwd for '" + u + "'. "
            + "Got '" + p.getPassword() + "' expected '" + correctpw + "'");
    responseText(ctx, 401).end("Wrong username or password");
    return;
  }
  String tok;
  tok = token(p.getTenant(), p.getUsername());
  logger.info("test-auth: Ok login for " + u + ": " + tok);
  responseJson(ctx, 200).putHeader(XOkapiHeaders.TOKEN, tok).end(json);
}