aboutsummaryrefslogtreecommitdiff
path: root/central/src/main/java/moe/yuuta/dn42peering/asn/ASNHandler.java
diff options
context:
space:
mode:
Diffstat (limited to 'central/src/main/java/moe/yuuta/dn42peering/asn/ASNHandler.java')
-rw-r--r--central/src/main/java/moe/yuuta/dn42peering/asn/ASNHandler.java144
1 files changed, 3 insertions, 141 deletions
diff --git a/central/src/main/java/moe/yuuta/dn42peering/asn/ASNHandler.java b/central/src/main/java/moe/yuuta/dn42peering/asn/ASNHandler.java
index 7abc27e..0b88540 100644
--- a/central/src/main/java/moe/yuuta/dn42peering/asn/ASNHandler.java
+++ b/central/src/main/java/moe/yuuta/dn42peering/asn/ASNHandler.java
@@ -11,6 +11,7 @@ import io.vertx.ext.mail.MailConfig;
import io.vertx.ext.mail.MailMessage;
import io.vertx.ext.mail.MailResult;
import io.vertx.ext.web.Router;
+import io.vertx.ext.web.api.service.RouteToEBServiceHandler;
import io.vertx.ext.web.common.template.TemplateEngine;
import io.vertx.ext.web.handler.BodyHandler;
import io.vertx.ext.web.templ.freemarker.FreeMarkerTemplateEngine;
@@ -45,28 +46,10 @@ public class ASNHandler implements ISubRouter {
@Nonnull
@Override
public Router mount(@Nonnull Vertx vertx) {
- final IASNService asnService = IASNService.createProxy(vertx, IASNService.ADDRESS);
- final IWhoisService whoisService = IWhoisService.createProxy(vertx, IWhoisService.ADDRESS);
- // Preserve. We need to get email address out of it later.
- final JsonObject mailConfig = vertx.getOrCreateContext().config().getJsonObject("mail");
- final MailClient mailClient = MailClient.create(vertx, new MailConfig(mailConfig));
-
- final TemplateEngine engine = FreeMarkerTemplateEngine.create(vertx, "ftlh");
final Router router = Router.router(vertx);
router.get("/")
.produces("text/html")
- .handler(ctx -> {
- renderIndex(engine, null, null, res -> {
- if(res.succeeded()) {
- ctx.response()
- .putHeader(HttpHeaders.CONTENT_TYPE, "text/html")
- .end(res.result());
- } else {
- ctx.fail(res.cause());
- logger.error("Cannot render /asn.", res.cause());
- }
- });
- });
+ .handler(RouteToEBServiceHandler.build(vertx.eventBus(), IASNHttpService.ADDRESS, "index"));
final ObjectSchemaBuilder registerSchema = objectSchema()
.allowAdditionalProperties(false)
@@ -81,129 +64,8 @@ public class ASNHandler implements ISubRouter {
.body(Bodies.formUrlEncoded(registerSchema))
.predicate(RequestPredicate.BODY_REQUIRED)
.build())
- .handler(ctx -> {
- final JsonObject parameters = ctx.<RequestParameters>get(ValidationHandler.REQUEST_CONTEXT_KEY)
- .body().getJsonObject();
- final String upperASN = parameters.getString("asn").toUpperCase();
- // Start: Check if the ASN exists.
- Future.<Void>future(f -> asnService.exists(upperASN, true, true, ar -> {
- if(ar.succeeded()) {
- if(ar.result()) {
- f.fail(new FormException("This ASN exists in our records. Please login instead of registering."));
- } else {
- f.complete();
- }
- } else {
- f.fail(ar.cause());
- }
- }))
- // Lookup ASN
- .<WhoisObject>compose(exists ->
- Future.future(f -> whoisService.query(upperASN, f)))
- // Lookup emails
- .<List<String>>compose(asnLookup -> {
- if(asnLookup == null) {
- return Future.failedFuture(new FormException("The ASN is not found in the DN42 registry."));
- } else {
- return Future.future(f -> asnService.lookupEmails(asnLookup, ar -> {
- if(ar.succeeded()) {
- if(ar.result().isEmpty()) {
- f.fail(new FormException("The tech-c contact for this ASN does not have emails."));
- } else {
- f.complete(ar.result());
- }
- } else {
- f.fail(ar.cause());
- }
- }));
- }
- })
- // Generate random password and register.
- .<Pair<String /* Random password */, List<String> /* Emails */>>compose(emails -> Future.future(f -> {
- final String randomPassword = new RandomStringGenerator.Builder()
- .withinRange('a', 'z')
- .build()
- .generate(15);
- asnService.registerOrChangePassword(upperASN, randomPassword, ar -> {
- if(ar.succeeded()) {
- f.complete(new Pair<>(randomPassword, emails));
- } else {
- f.fail(ar.cause());
- }
- });
- }))
- // Send mails.
- .compose(pair -> CompositeFuture.any(Stream.of(pair.b)
- .map(mail -> new MailMessage()
- .setFrom(mailConfig.getString("from"))
- .setTo(mail)
- .setText(String.format("Hi %s! Welcome to dn42 peering! Your peering initial password is %s. Make sure to change it.",
- upperASN,
- pair.a))
- .setSubject("Peering initial password"))
- .map(message -> Future.<MailResult>future(f -> mailClient.sendMail(message, f)))
- .collect(Collectors.toList())))
- // Render HTML or report errors
- .onComplete(ar -> {
- if(ar.succeeded()) {
- // Get MailResult's out of the future.
- final List<MailResult> sendRes = ar.result().list();
- renderSuccess(engine, sendRes, res -> {
- if(res.succeeded()) {
- ctx.response()
- .putHeader(HttpHeaders.CONTENT_TYPE, "text/html")
- .end(res.result());
- } else {
- ctx.fail(res.cause());
- logger.error("Cannot render /asn (success).", res.cause());
- }
- });
- } else {
- if(ar.cause() instanceof HTTPException) {
- ctx.response().setStatusCode(((HTTPException) ar.cause()).code).end();
- } else if(ar.cause() instanceof FormException) {
- renderIndex(engine,
- Arrays.asList(((FormException) ar.cause()).errors.clone()),
- upperASN,
- res -> {
- if(res.succeeded()) {
- ctx.response()
- .putHeader(HttpHeaders.CONTENT_TYPE, "text/html")
- .end(res.result());
- } else {
- ctx.fail(res.cause());
- logger.error("Cannot render /asn (with errors).", res.cause());
- }
- });
- } else {
- logger.error(String.format("Cannot register ASN %s.", upperASN), ar.cause());
- ctx.fail(ar.cause());
- }
- }
- });
- });
+ .handler(RouteToEBServiceHandler.build(vertx.eventBus(), IASNHttpService.ADDRESS, "register"));
return router;
}
-
- private void renderIndex(@Nonnull TemplateEngine engine,
- @Nullable List<String> errors,
- @Nullable String asn,
- @Nonnull Handler<AsyncResult<Buffer>> handler) {
- final Map<String, Object> root = new HashMap<>();
- root.put("input_asn", asn == null ? "" : asn);
- root.put("errors", errors);
- engine.render(root, "asn/index.ftlh", handler);
- }
-
- private void renderSuccess(@Nonnull TemplateEngine engine,
- @Nonnull List<MailResult> sendRes,
- @Nonnull Handler<AsyncResult<Buffer>> handler) {
- final Map<String, Object> root = new HashMap<>();
- root.put("emails", sendRes.stream()
- .filter(Objects::nonNull) // Nulls mean failures.
- .flatMap(res -> res.getRecipients().stream())
- .collect(Collectors.toList()));
- engine.render(root, "asn/success.ftlh", handler);
- }
}
generated by cgit v1.2.3 (git 2.25.1) at 2024-06-03 03:37:25 +0000