ACA-PY Java Client Library

Convenience library based on okhttp and gson to interact with aries cloud agent python (aca-py) instances.

Use it in your project

<dependency>
   <groupId>network.idu.acapy</groupId>
   <artifactId>aries-client-python</artifactId>
   <version>0.10.0</version>
</dependency>

FAQ

Why don't you use swagger codegen?

For a long time aca-py's swagger.json was not really in sync with the code base. This has been hugely improved lately, so I started to generate model classes based on the stable releases found on dockerhub. There are still issues with complex structures, so one can not simply use the models 1:1, instead each one has to be checked manually before using it. This is tedious work and might take a while to complete. Also, the api is complex so that I found it useful to introduce helper methods directly in the model classes to make them more accessible.
Why is endpoint X, or field Y missing?

aca-py's api is changing rapidly with each release, and until most of the classes are using the generated models this can happen. So, if you are missing something create a PR with a fix or open an issue.

Version Compatibility

Client Version	ACA-PY Version
0.10.0	0.10.x
0.8.0	0.8.0
0.7.0	0.7.0
0.7.6	0.7.1, 0.7.2
>= 0.7.18	0.7.3
>= 0.7.25	0.7.4
>= 0.7.32	0.7.5

Implemented Endpoints

Method	Endpoint	Implemented
	action-menu
POST	/action-menu/{conn_id}/close	✅
POST	/action-menu/{conn_id}/fetch	✅
POST	/action-menu/{conn_id}/perform	✅
POST	/action-menu/{conn_id}/request	✅
POST	/action-menu/{conn_id}/send-menu	✅
	basicmessage
POST	/connections/{conn_id}/send-message	✅
	connection
GET	/connections	✅
POST	/connections/create-invitation	✅
POST	/connections/create-static	✅
POST	/connections/receive-invitation	✅
GET	/connections/{conn_id}}	✅
DELETE	/connections/{conn_id}	✅
POST	/connections/{conn_id}/accept-invitation	✅
POST	/connections/{conn_id}/accept-request	✅
GET	/connections/{conn_id}/endpoints	✅
POST	/connections/{conn_id}/establish-inbound/{ref_id}	✅
GET	/connections/{conn_id}/metadata	✅
POST	/connections/{conn_id}/metadata	✅
	credential-definition
POST	/credential-definitions	✅
GET	/credential-definitions/created	✅
GET	/credential-definitions/{cred_def_id}	✅
POST	/credential-definitions/{cred_def_id}/write_record	✅
	credentials
GET	/credentials/mime-types/{credential_id}	✅
GET	/credentials/revoked/{credential_id}	✅
GET	/credential/w3c/{credential_id}	✅
DELETE	/credential/w3c/{credential_id}	✅
GET	/credential/{credential_id}	✅
DELETE	/credential/{credential_id}	✅
GET	/credentials	✅
POST	/credentials/w3c	✅
	did-exchange
POST	/didexchange/create-request	✅
POST	/didexchange/receive-request	✅
POST	/didexchange/{conn_id}/accept-invitation	✅
POST	/didexchange/{conn_id}/accept-request	✅
POST	/didexchange/{conn_id}/reject	✅
	discover-features
GET	/discover-features/query	✅
GET	/discover-features/records	✅
	discover-features v2.0
GET	/discover-features-2.0/queries	✅
GET	/discover-features-2.0/records	✅
	endorse-transaction
POST	/transaction/{tran_id}/resend	✅
POST	/transactions	✅
POST	/transactions/create-request	✅
POST	/transactions/{conn_id}/set-endorser-info	✅
POST	/transactions/{conn_id}/set-endorser-role	✅
POST	/transactions/{tran_id}	✅
POST	/transactions/{tran_id}/cancel	✅
POST	/transactions/{tran_id}/endorse	✅
POST	/transactions/{tran_id}/refuse	✅
POST	/transactions/{tran_id}/write	✅
	introduction
POST	/connections/{conn_id}/start-introduction	✅
	issue-credential v1.0
POST	/issue-credential/create	✅
POST	/issue-credential/create-offer	✅
GET	/issue-credential/records	✅
GET	/issue-credential/records/{cred_ex_id}	✅
DELETE	/issue-credential/records/{cred_ex_id}	✅
POST	/issue-credential/records/{cred_ex_id}/issue	✅
POST	/issue-credential/records/{cred_ex_id}/problem-report	✅
POST	/issue-credential/records/{cred_ex_id}/send-offer	✅
POST	/issue-credential/records/{cred_ex_id}/send-request	✅
POST	/issue-credential/records/{cred_ex_id}/store	✅
POST	/issue-credential/send	✅
POST	/issue-credential/send-offer	✅
POST	/issue-credential/send-proposal	✅
	issue-credential v2.0
POST	/issue-credential-2.0/create	✅
POST	/issue-credential-2.0/create-offer	✅
GET	/issue-credential-2.0/records	✅
GET	/issue-credential-2.0/records/{cred_ex_id}	✅
DELETE	/issue-credential-2.0/records/{cred_ex_id}	✅
POST	/issue-credential-2.0/records/{cred_ex_id}/issue	✅
POST	/issue-credential-2.0/records/{cred_ex_id}/problem-report	✅
POST	/issue-credential-2.0/records/{cred_ex_id}/send-offer	✅
POST	/issue-credential-2.0/records/{cred_ex_id}/send-request	✅
POST	/issue-credential-2.0/records/{cred_ex_id}/store	✅
POST	/issue-credential-2.0/send	✅
POST	/issue-credential-2.0/send-offer	✅
POST	/issue-credential-2.0/send-proposal	✅
POST	/issue-credential-2.0/send-request	✅
	jsonld
POST	/jsonld/sign	✅
POST	/jsonld/verify	✅
	ledger
GET	/ledger/config	✅
GET	/ledger/did-endpoint	✅
GET	/ledger/did-verkey	✅
GET	/ledger/get-nym-role	✅
GET	/ledger/get-write-ledger	✅
GET	/ledger/get-write-ledgers	✅
POST	/ledger/register-nym	✅
PATCH	/ledger/rotate-public-did-keypair	✅
GET	/ledger/taa	✅
POST	/ledger/taa/accept	✅
POST	/ledger/{ledger_id}/set-write-ledger	✅
	mediation
GET	/mediation/default-mediator	✅
DELETE	/mediation/default-mediator	✅
GET	/mediation/keylists	✅
POST	/mediation/keylists/{mediation_id}/send-keylist-query	✅
POST	/mediation/keylists/{mediation_id}/send-keylist-update	✅
POST	/mediation/request/{conn_id}	✅
GET	/mediation/requests	✅
GET	/mediation/requests/{mediation_id}	✅
DELETE	/mediation/requests/{mediation_id}	✅
POST	/mediation/requests/{mediation_id}/deny	✅
POST	/mediation/requests/{mediation_id}/grant	✅
POST	/mediation/update-keylist/{conn_id}	✅
PUT	/mediation/{mediation_id}/default-mediator	✅
	multitenancy
POST	/multitenancy/wallet	✅
GET	/multitenancy/wallet/{wallet_id}	✅
PUT	/multitenancy/wallet/{wallet_id}	✅
POST	/multitenancy/wallet/{wallet_id}/remove	✅
POST	/multitenancy/wallet/{wallet_id}/token	✅
GET	/multitenancy/wallets	✅
	out-of-band
POST	/out-of-band/create-invitation	✅
POST	/out-of-band/receive-invitation	✅
	present-proof v1.0
POST	/present-proof/create-request	✅
GET	/present-proof/records	✅
GET	/present-proof/records/{pres_ex_id}	✅
DELETE	/present-proof/records/{pres_ex_id}	✅
GET	/present-proof/records/{pres_ex_id}/credentials	✅
POST	/present-proof/records/{pres_ex_id}/problem-report	✅
POST	/present-proof/records/{pres_ex_id}/send-presentation	✅
POST	/present-proof/records/{pres_ex_id}/send-request	✅
POST	/present-proof/records/{pres_ex_id}/verify-presentation	✅
POST	/present-proof/send-proposal	✅
POST	/present-proof/send-request	✅
	present-proof v2.0
POST	/present-proof-2.0/create-request	✅
GET	/present-proof-2.0/records	✅
GET	/present-proof-2.0/records/{pres_ex_id}	✅
DELETE	/present-proof-2.0/records/{pres_ex_id}	✅
GET	/present-proof-2.0/records/{pres_ex_id}/credentials	✅
POST	/present-proof-2.0/records/{pres_ex_id}/problem-report	✅
POST	/present-proof-2.0/records/{pres_ex_id}/send-presentation	✅
POST	/present-proof-2.0/records/{pres_ex_id}/send-request	✅
POST	/present-proof-2.0/records/{pres_ex_id}/verify-presentation	✅
POST	/present-proof-2.0/send-proposal	✅
POST	/present-proof-2.0/send-request	✅
	resolver
GET	/resolver/resolve/{did}	✅
	revocation
GET	/revocation/active-registry/{cred_def_id}	✅
POST	/revocation/active-registry/{cred_def_id}/rotate	✅
POST	/revocation/clear-pending-revocations	✅
POST	/revocation/create-registry	✅
GET	/revocation/credential-record	✅
POST	/revocation/publish-revocations	✅
GET	/revocation/registries/created	✅
DELETE	/revocation/registry/delete-tails-file	✅
GET	/revocation/registry/{rev_reg_id}	✅
PATCH	/revocation/registry/{rev_reg_id}	✅
POST	/revocation/registry/{rev_reg_id}/definition	✅
POST	/revocation/registry/{rev_reg_id}/entry	✅
PUT	/revocation/registry/{rev_reg_id}/fix-revocation-entry-state	✅
GET	/revocation/registry/{rev_reg_id}/issued	✅
GET	/revocation/registry/{rev_reg_id}/issued/details	✅
GET	/revocation/registry/{rev_reg_id}/issued/indy_recs	✅
PATCH	/revocation/registry/{rev_reg_id}/set-state	✅
PUT	/revocation/registry/{rev_reg_id}/tails-file	✅
GET	/revocation/registry/{rev_reg_id}/tails-file	✅
POST	/revocation/revoke	✅
	schema
POST	/schemas	✅
GET	/schemas/created	✅
GET	/schemas/{schema_id}	✅
POST	/schemas/{schema_id}/write_record	✅
	settings
PUT	/settings	✅
GET	/settings	✅
	trustping
POST	/connections/{conn_id}/send-ping	✅
	wallet
GET	/wallet/did	✅
POST	/wallet/did/create	✅
PATCH	/wallet/did/local/rotate-keypair	✅
GET	/wallet/did/public	✅
POST	/wallet/did/public	✅
GET	/wallet/get-did-endpoint	✅
POST	/wallet/jwt/sign	✅
POST	/wallet/jwt/verify	✅
POST	/wallet/set-did-endpoint	✅
	server
GET	/plugins	✅
GET	/shutdown	✅
GET	/status	✅
GET	/status/config	✅
GET	/status/live	✅
GET	/status/ready	✅
POST	/status/reset	✅

Client Examples

Sending Requests: Create the aca-py Rest Client

The rest client is used to send requests against aca-py's admin rest endpoint.

Related aca-py config flags are: --admin <host> <port>, --admin-api-key <api-key>

The default assumes you are running against a single wallet. In case of multi tenancy with base and sub wallets the bearerToken needs to be set as well.

Example aca-py config flags:

--admin 0.0.0.0 8031
--admin-api-key secret

Example client builder:

AriesClient ac = AriesClient
        .builder()
        .url("http://localhost:8031") // optional - defaults to localhost:8031
        .apiKey("secret") // optional - admin api key if set
        .bearerToken("123.456.789") // optional - jwt token - only when running in multi tenant mode
        .build();

Receiving Events: Webhook and Websocket Handler Support

With aca-py you have three options on how to receive status changes:

Poll the rest API - this is not recommended
Register a webhook URL
Connect to aca-py's websocket

Webhook

Related aca-py config flag: --webhook-url <url#api_key>

Single Tenant Controller Example

If running a single wallet and not in multi tenant mode.

Example aca-py config flag: --webhook-url http://localhost:8080/webhook

@Controller
public class WebhookController {

   private EventHandler handler = new EventHandler.DefaultEventHandler();

   @Post("/webhook/topic/{topic}")
   public void handleWebhookEvent(
           @PathVariable String topic,
           @Body String payload) {
      handler.handleEvent(topic, payload);
   }
}

Multi Tenant Example

If running in multi tenant mode.

Example aca-py config flags:

--webhook-url http://localhost:8080/webhook
--multitenant
--jwt-secret 1234
--multitenant-admin

Example multi tenant webhook controller

@Controller
public class WebhookController {

   private EventHandler handler = new TenantAwareEventHandler.DefaultTenantAwareEventHandler();

   @Post("/webhook/topic/{topic}")
   public void handleWebhookEvent(
           @PathVariable String topic,
           @Body String payload,
           HttpRequest request) {
      String walletId = request.getHeaders().get("x-wallet-id");
      handler.handleEvent(walletId, topic, payload);
   }
}

Websocket

If the admin api is enabled aca-py also supports a websocket endpoint under ws(s)://<host>:<admin-port>/ws

Example aca-py config flag: --admin 0.0.0.0 8031

To connect with the websocket you can use the AriesWebSocketClient like:

@Factory
public class AriesSocketFactory {

   @Value("${acapy.ws.url}")
   private String url;
   @Value("${acapy.admin.apiKey}")
   private String apiKey;
   
   @Singleton
   @Bean(preDestroy = "closeWebsocket")
   public AriesWebSocketClient ariesWebSocketClient() {
      return AriesWebSocketClient
              .builder()
              .url(url) // optional - defaults to ws://localhost:8031/ws
              .apiKey(apiKey) // optional - admin api key if set
              .handler(new EventHandler.DefaultEventHandler()) // optional - your handler implementation
              // .bearerToken(bearer) // optional - jwt token - only when running in multi tenant mode
              .build();
   }
}

Writing Custom Event Handlers

To add your own event handler implementation to use in webhooks or in the websocket client, you can either extend or instantiate one of the following classes:

EventHandler
TenantAwareEventHandler
ReactiveEventHandler

All classes take care of type conversion so that you can immediately start implementing your business logic.

Basic EventHandler

@Singleton
public class MyHandler extends EventHandler {
    @Override
    public void handleProof(PresentationExchangeRecord proof) {
        if (proof.roleIsVerifierAndVerified()) {    // received a validated proof
            MyCredential myCredential = proof.from(MyCredential.class);
            // If the presentation is based on multiple credentials this can be done multiple times
            // given that the POJO is annotated with @AttributeGroup e.g.
            MyOtherCredential otherCredential = proof.from(MyOtherCredential.class);
        }
    }
}

Reactive Event Handler

As the websocket client already implements the EventHandler interface you can directly use it like:

AriesWebSocketClient ws = AriesWebSocketClient.builder().build();

// do some stuff, create a connection, or receive invitation

// blocking wait 
ConnectionRecord active = ws.connection()
    .filter(ConnectionRecord::stateIsActive)
    .blockFirst(Duration.ofSeconds(5));
// none blocking
ws.connection()
    .filter(ConnectionRecord::stateIsActive)
    .subscribe(System.out::println);

A Word on Credential POJO's

The library assumes credentials are flat Pojo's like:

@Data @NoArgsConstructor @Builder
@AttributeGroupName("referent") // the referent that should be matched in the proof request
public final class MyCredential {
   private String street;

   @AttributeName("e-mail")
   private String email;       // schema attribute name is e-mail

   @AttributeName(excluded = true)
   private String comment;     // internal field
}

How fields are serialised/deserialized can be changed by using the @AttributeName or @AttributeGroupName annotations.

Create a connection

ac.connectionsReceiveInvitation(
        ReceiveInvitationRequest.builder()
            .did(did)
            .label(label)
            .build(), 
        ConnectionReceiveInvitationFilter
            .builder()
            .alias("alias")
            .build())    
.ifPresent(connection -> {
    log.debug("{}", connection.getConnectionId());
});

Issue a Credential

MyCredential myCredential = MyCredential
        .builder()
        .email("[email protected]")
        .build();
ac.issueCredentialSend(
        new V1CredentialProposalRequest(connectionId, credentialdefinitionId, myCredential));

Present Proof Request

PresentProofRequest proofRequest = PresentProofRequestHelper.buildForEachAttribute(
    connectionId,
    MyCredential.class,
    ProofRestrictions.builder()
        .credentialDefinitionId(credentialDefinitionId)
        .build());
ac.presentProofSendRequest(proofRequest);

Build Connectionless Proof Request

Connectionless proofs are more a thing of mobile wallets, because mostly they involve something that is presented to a human like a barcode, but the java client supports this by providing models and builders.

A flow has the usually following steps:

The user is presented with a QRCode that contains an invitation URL like: https://myhost.com/url/1234
The server side HTTP handler of this URL responds with an HTTP.FOUND response that has the proof request encoded in the m parameter
The mobile wallet tries to match a stored credential, and then responds with a proof presentation if possible
The server side WebhookHandler waits for the proof and then triggers further actions

@Get("/url/{requestId}")
public HttpResponse<Object> connectionLessProof(@QueryValue String requestId) {
    boolean matchingRequest = false; // TODO manage request states
    String proofRequestBase64 = ""; // TODO on how to build this see the example below
    if (matchingRequest) {
        return HttpResponse
                .status(HttpStatus.FOUND)
                .header("location", deploymentUri + "?m=" + proofRequestBase64;
    }
    return HttpResponse.notFound();
}

Proof Request Builder Example

ProofRequestPresentationBuilder builder = new ProofRequestPresentationBuilder(ariesClient);

PresentProofRequest presentProofRequest = PresentProofRequestHelper.buildForEachAttribute(
        connectionId,
        List.of("name", "email"),
        ProofRestrictions
            .builder()
            .schemaId("WgWxqztrNooG92RXvxSTWv:2:schema_name:1.0")
            .build());

Optional<String> base64 = builder.buildRequest(presentProofRequest);

Name		Name	Last commit message	Last commit date
Latest commit History 410 Commits
.github		.github
src		src
swagger		swagger
.gitignore		.gitignore
LICENSE		LICENSE
MAINTAINERS.md		MAINTAINERS.md
NOTICE		NOTICE
README.md		README.md
license-header.txt		license-header.txt
licenses.xml		licenses.xml
pom.xml		pom.xml

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Licenses found

Repository files navigation

ACA-PY Java Client Library

Use it in your project

FAQ

Version Compatibility

Implemented Endpoints

Client Examples

Sending Requests: Create the aca-py Rest Client

Receiving Events: Webhook and Websocket Handler Support

Webhook

Single Tenant Controller Example

Multi Tenant Example

Websocket

Writing Custom Event Handlers

Basic EventHandler

Reactive Event Handler

A Word on Credential POJO's

Create a connection

Issue a Credential

Present Proof Request

Build Connectionless Proof Request

About

Licenses found

Releases

Packages

Contributors 8

Languages

License

Licenses found

hyperledger-labs/acapy-java-client

Folders and files

Latest commit

History

Repository files navigation

ACA-PY Java Client Library

Use it in your project

FAQ

Version Compatibility

Implemented Endpoints

Client Examples

Sending Requests: Create the aca-py Rest Client

Receiving Events: Webhook and Websocket Handler Support

Webhook

Single Tenant Controller Example

Multi Tenant Example

Websocket

Writing Custom Event Handlers

Basic EventHandler

Reactive Event Handler

A Word on Credential POJO's

Create a connection

Issue a Credential

Present Proof Request

Build Connectionless Proof Request

About

Topics

Resources

License

Licenses found

Stars

Watchers

Forks

Releases

Packages 0

Contributors 8

Languages

Packages