Skip to content

Commit

Permalink
signing service config parser.
Browse files Browse the repository at this point in the history
  • Loading branch information
jpe7s committed Dec 19, 2024
1 parent 730a997 commit 1c40151
Show file tree
Hide file tree
Showing 3 changed files with 85 additions and 1 deletion.
2 changes: 2 additions & 0 deletions kms_core/src/main/java/module-info.java
Original file line number Diff line number Diff line change
Expand Up @@ -9,4 +9,6 @@
provides software.sava.kms.core.signing.SigningServiceFactory with
software.sava.kms.core.signing.MemorySignerFactory,
software.sava.kms.core.signing.MemorySignerFromFilePointerFactory;

uses software.sava.kms.core.signing.SigningServiceFactory;
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,82 @@
package software.sava.kms.core.signing;

import software.sava.services.core.remote.call.Backoff;
import software.sava.services.core.remote.call.BackoffConfig;
import systems.comodal.jsoniter.FieldBufferPredicate;
import systems.comodal.jsoniter.JsonIterator;

import java.util.ServiceLoader;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import static systems.comodal.jsoniter.JsonIterator.fieldEquals;

public record SigningServiceConfig(Backoff backoff, SigningService signingService) {

public static SigningServiceConfig parseConfig(final ExecutorService executorService, final JsonIterator ji) {
final var parser = new Parser(executorService);
ji.testObject(parser);
return parser.createConfig(ji);
}

public static SigningServiceConfig parseConfig(final JsonIterator ji) {
return parseConfig(Executors.newVirtualThreadPerTaskExecutor(), ji);
}

private static final class Parser implements FieldBufferPredicate {

private final ExecutorService executorService;

private Backoff backoff;
private String factoryClass;
private SigningService signingService;
private int configMark = -1;

private Parser(final ExecutorService executorService) {
this.executorService = executorService;
}

SigningServiceConfig createConfig(final JsonIterator ji) {
if (backoff == null) {
backoff = Backoff.exponential(1, 32);
}
if (signingService == null) {
if (configMark < 0) {
throw new IllegalStateException("Must configure a signing service");
} else if (factoryClass == null) {
throw new IllegalStateException("Must configure a signing service factory class");
}
final int mark = ji.mark();
createService(executorService, ji);
ji.reset(mark);
}

return new SigningServiceConfig(backoff, signingService);
}

private void createService(final ExecutorService executorService, final JsonIterator ji) {
final var serviceFactory = ServiceLoader.load(SigningServiceFactory.class).stream()
.filter(service -> service.type().getName().equals(factoryClass))
.findFirst().orElseThrow().get();
signingService = serviceFactory.createService(executorService, ji);
}

@Override
public boolean test(final char[] buf, final int offset, final int len, final JsonIterator ji) {
if (fieldEquals("backoff", buf, offset, len)) {
backoff = BackoffConfig.parseConfig(ji).createHandler();
} else if (fieldEquals("factoryClass", buf, offset, len)) {
factoryClass = ji.readString();
} else if (fieldEquals("config", buf, offset, len)) {
if (factoryClass == null) {
configMark = ji.mark();
} else {
createService(executorService, ji);
}
} else {
ji.skip();
}
return true;
}
}
}
2 changes: 1 addition & 1 deletion settings.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ dependencyResolutionManagement {
}
versionCatalogs {
libs {
from("software.sava:solana-version-catalog:0.3.31")
from("software.sava:solana-version-catalog:0.4.1")
}
}
}

0 comments on commit 1c40151

Please sign in to comment.