aboutsummaryrefslogtreecommitdiff
path: root/central/src/main/java/moe/yuuta/dn42peering/asn/ASNServiceImpl.java
diff options
context:
space:
mode:
Diffstat (limited to 'central/src/main/java/moe/yuuta/dn42peering/asn/ASNServiceImpl.java')
-rw-r--r--central/src/main/java/moe/yuuta/dn42peering/asn/ASNServiceImpl.java17
1 files changed, 17 insertions, 0 deletions
diff --git a/central/src/main/java/moe/yuuta/dn42peering/asn/ASNServiceImpl.java b/central/src/main/java/moe/yuuta/dn42peering/asn/ASNServiceImpl.java
index 2fce4f1..81bd946 100644
--- a/central/src/main/java/moe/yuuta/dn42peering/asn/ASNServiceImpl.java
+++ b/central/src/main/java/moe/yuuta/dn42peering/asn/ASNServiceImpl.java
@@ -162,4 +162,21 @@ class ASNServiceImpl implements IASNService {
.onComplete(handler);
return this;
}
+
+ @Nonnull
+ @Override
+ public IASNService list(@Nonnull Handler<AsyncResult<List<ASN>>> handler) {
+ SqlTemplate
+ .forQuery(pool, "SELECT asn, activated " +
+ "FROM asn")
+ .mapTo(ASNRowMapper.INSTANCE)
+ .execute(null)
+ .compose(asns -> {
+ final List<ASN> asnList = new ArrayList<>();
+ for (ASN asn : asns) asnList.add(asn);
+ return Future.succeededFuture(asnList);
+ })
+ .onComplete(handler);
+ return this;
+ }
}