Skip to content

Commit 2193bec

Browse files
committed
add risk detector service
1 parent 2f6696f commit 2193bec

File tree

3 files changed

+449
-0
lines changed

3 files changed

+449
-0
lines changed
Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
package org.nameapi.client.services.riskdetector;
2+
3+
import com.google.common.base.Optional;
4+
import com.optimaize.command4j.ExecutionContext;
5+
import org.jetbrains.annotations.NotNull;
6+
import org.jetbrains.annotations.Nullable;
7+
import org.nameapi.client.services.NameApiBaseCommand;
8+
import org.nameapi.ontology5.input.entities.person.InputPerson;
9+
import org.nameapi.ontology5.services.riskdetector.RiskDetectorResult;
10+
11+
import java.util.concurrent.Callable;
12+
13+
public class DetectRisksCommand extends NameApiBaseCommand<RestPort, InputPerson, RiskDetectorResult> {
14+
15+
private static final String SERVICE_PATH = "/riskdetector/detect";
16+
17+
public DetectRisksCommand() {
18+
super(RestPort.class);
19+
}
20+
21+
@Nullable
22+
@Override
23+
public RiskDetectorResult call(@NotNull Optional<InputPerson> inputPersonOpt, @NotNull ExecutionContext context) throws Exception {
24+
return getPort(context).call(getApiKey(context), getContext(context), inputPersonOpt.get());
25+
}
26+
27+
@NotNull
28+
@Override
29+
protected Callable<RestPort> createPort(@NotNull final ExecutionContext context) {
30+
return new Callable<RestPort>() {
31+
@Override
32+
public RestPort call() throws Exception {
33+
return new RestPort(makeClient(context), SERVICE_PATH);
34+
}
35+
};
36+
}
37+
}
Lines changed: 38 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,38 @@
1+
package org.nameapi.client.services.riskdetector;
2+
3+
import com.optimaize.anythingworks.client.rest.http.HeaderParams;
4+
import com.optimaize.anythingworks.client.rest.http.QueryParams;
5+
import com.optimaize.anythingworks.client.rest.http.RestHttpClient;
6+
import com.optimaize.anythingworks.client.rest.http.RestHttpClientResponse;
7+
import com.optimaize.anythingworks.common.rest.TypeRef;
8+
import org.nameapi.client.services.RestServicePort;
9+
import org.nameapi.ontology5.input.context.Context;
10+
import org.nameapi.ontology5.input.entities.person.InputPerson;
11+
import org.nameapi.ontology5.services.InputWithPerson;
12+
import org.nameapi.ontology5.services.riskdetector.RiskDetectorResult;
13+
14+
/**
15+
*
16+
*/
17+
class RestPort extends RestServicePort {
18+
19+
private static final TypeRef returnType = new TypeRef<RiskDetectorResult>() {};
20+
21+
public RestPort(RestHttpClient restApiClient, String servicePath) {
22+
super(restApiClient, servicePath);
23+
}
24+
25+
public RiskDetectorResult call(String apiKey, Context context, InputPerson inputPerson) {
26+
QueryParams queryParams = QueryParams.create();
27+
queryParams.add("apiKey", apiKey);
28+
29+
RestHttpClientResponse<RiskDetectorResult> response = restApiClient.invokeBody(
30+
servicePath, "POST",
31+
queryParams, HeaderParams.none(),
32+
new InputWithPerson(context, inputPerson),
33+
returnType
34+
);
35+
return response.getResult().get();
36+
}
37+
38+
}

0 commit comments

Comments
 (0)