Есть ли в DAML SDK webhook, который может собирать данные о созданных транзакциях - PullRequest
Новая
       7

Есть ли в DAML SDK webhook, который может собирать данные о созданных транзакциях

0 голосов
/ 17 января 2019

API главной книги позволяет извлекать данные по требованию, но есть ли служба, которая выталкивает данные, такие как аналитика, когда появляются новые транзакции, относящиеся к порогу или критериям поиска, или просто агрегируются функции на основе данных транзакций.

1 Ответ

0 голосов
/ 17 января 2019

Ledger API позволяет выполнять потоковую передачу транзакций, созданных в бухгалтерской книге с использованием gRPC. Используя любой клиент, сгенерированный gRPC, вы можете реализовать фильтр, преобразование или агрегирование транзакций в вашем коде. Вот определение protobuf конечной точки службы, к которой нужно подключиться: 

service TransactionService {

    // Read the ledger's filtered transaction stream for a set of parties.
    rpc GetTransactions (GetTransactionsRequest) returns (stream GetTransactionsResponse);

}

Например, в Java подписка на поток транзакций будет выглядеть следующим образом: 

public class Main {

    private static void processTransaction(TransactionOuterClass.Transaction tx) {
        // process (filter, transform, aggregate) transaction
        System.out.printf("received transaction %s\n", tx.getTransactionId());
    }

    public static void main(String[] args) {

        // Create a GRPC channel
        ManagedChannel channel = ManagedChannelBuilder.forAddress("localhost", 7600).usePlaintext().build();

        // Get ledger identity
        LedgerIdentityServiceBlockingStub ledgerIdService = LedgerIdentityServiceGrpc.newBlockingStub(channel);
        GetLedgerIdentityResponse identityResponse = ledgerIdService.getLedgerIdentity(GetLedgerIdentityRequest.getDefaultInstance());
        String ledgerId = identityResponse.getLedgerId();

        // Subscribe observer to transaction stream
        String party = "Alice";
        TransactionServiceStub transactionService = TransactionServiceGrpc.newStub(channel);
        GetTransactionsRequest transactionsRequest = GetTransactionsRequest.newBuilder()
                .setLedgerId(ledgerId)
                .setBegin(LedgerOffset.newBuilder().setBoundary(LedgerOffset.LedgerBoundary.LEDGER_BEGIN))
                .setFilter(TransactionFilter.newBuilder().putFiltersByParty(party, Filters.getDefaultInstance()))
                .build();
        StreamObserver<GetTransactionsResponse> transactionObserver = new StreamObserver<GetTransactionsResponse>() {
            @Override
            public void onNext(GetTransactionsResponse value) {
                value.getTransactionsList().forEach(Main::processTransaction);
            }

            @Override
            public void onError(Throwable t) {
                System.err.printf("%s encountered an error while processing transactions!\n", party);
                t.printStackTrace();
            }

            @Override
            public void onCompleted() {
                System.out.printf("%s's transactions stream completed.\n", party);
            }
        };
        System.out.printf("%s starts reading transactions.\n", party);
        transactionService.getTransactions(transactionsRequest, transactionObserver);

        try {
            Thread.sleep(Long.MAX_VALUE);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

Обратите внимание, что используется необработанный код, сгенерированный GRPC. В SDK также доступны реактивные привязки, которые делают приведенное выше менее многословным.

...