mtaylor

<bartr-list
  name="Vendor Rate Plans"
  [columns]="columns"
  (filterChange)="onFilterChange($event)">

  <div class="actions" fxFlexAlign="center" *featureToggle="'vendorRatePlanMgmtEnabled'">
    <button
      *ngIf="'create' | able: 'Vendor Rate Plan'"
      class="create"
      aria-label="Add Vendor Rate Plan"

mtaylor

        int fractional;
        if (split[1].length() > SIGNIF_DIGITS) {
            fractional = Integer.valueOf(split[1].substring(0, SIGNIF_DIGITS));
            // Always round up
            if (Long.valueOf(split[1].substring(SIGNIF_DIGITS)) != 0) {
                fractional ++;
            }
        } else {
            fractional = Integer.valueOf(split[1]);
            for (int i = split[1].length(); i < SIGNIF_DIGITS; i++) {

mtaylor

parity1_1   | 2019-09-20 15:15:34 UTC Imported #86409 0xa584…b201 (0 txs, 0.00 Mgas, 0 ms, 0.58 KiB)
parity3_1   | 2019-09-20 15:15:34 UTC Imported #86409 0xa584…b201 (0 txs, 0.00 Mgas, 0 ms, 0.58 KiB)
parity3_1   | 2019-09-20 15:15:35 UTC Imported #86410 0x7a76…8cc8 (0 txs, 0.00 Mgas, 0 ms, 0.58 KiB)
parity1_1   | 2019-09-20 15:15:35 UTC Imported #86410 0x7a76…8cc8 (0 txs, 0.00 Mgas, 0 ms, 0.58 KiB)
parity2_1   | 2019-09-20 15:15:35 UTC Imported #86410 0x7a76…8cc8 (0 txs, 0.00 Mgas, 0 ms, 0.58 KiB)
parity3_1   | 2019-09-20 15:15:45 UTC Imported #86411 0x9aca…463b (0 txs, 0.00 Mgas, 0 ms, 0.58 KiB)
parity2_1   | 2019-09-20 15:15:45 UTC Imported #86411 0x9aca…463b (0 txs, 0.00 Mgas, 0 ms, 0.58 KiB)
parity1_1   | 2019-09-20 15:15:45 UTC Imported #86411 0x9aca…463b (0 txs, 0.00 Mgas, 0 ms, 0.58 KiB)
parity2_1   | 2019-09-20 15:15:46 UTC Imported #86412 0x800e…9270 (0 txs, 0.00 Mgas, 0 ms, 0.58 KiB)
parity1_1   | 2019-09-20 15:15:46 UTC Imported #86412 0x800e…9270 (0 txs, 0.00 Mgas, 0 ms, 0.58 KiB)

mtaylor

api_B_1     |                  ^
api_B_1     | 
api_B_1     | TypeError: Cannot read property 'get' of undefined
api_B_1     |     at process.errorHandler (/usr/local/lib/node_modules/npm/lib/utils/error-handler.js:205:18)
api_B_1     |     at process.emit (events.js:189:13)
api_B_1     |     at process._fatalException (internal/bootstrap/node.js:496:27)
api_A_1     | Error: EACCES: permission denied, scandir '/home/node/api'
api_A_1     | (node:1) UnhandledPromiseRejectionWarning: TypeError: Cannot read property 'get' of undefined
api_A_1     |     at errorHandler (/usr/local/lib/node_modules/npm/lib/utils/error-handler.js:205:18)
api_A_1     |     at /usr/local/lib/node_modules/npm/bin/npm-cli.js:78:20

mtaylor

[mtaylor@mtaylor-dell-xps BartrProtocol]$ docker-compose logs api_A
Attaching to bartrprotocol_api_A_1
api_A_1     | 
api_A_1     | > @appliedblockchain/bartr-api@0.1.0 start:dev /home/node/api
api_A_1     | > nodemon --watch serverless.yml --exec sls offline start --runSchedulesOnInit "--host" "0.0.0.0" "--port" "3000" "--stage" "customer-local"
api_A_1     | 
api_A_1     | [nodemon] 1.19.0
api_A_1     | [nodemon] to restart at any time, enter `rs`
api_A_1     | [nodemon] watching: serverless.yml
api_A_1     | [nodemon] starting `sls offline start --runSchedulesOnInit --host 0.0.0.0 --port 3000 --stage customer-local`

mtaylor

[mtaylor@mtaylor-dell-xps BartrProtocol]$ npm test

> @appliedblockchain/bartr@0.1.0 test /home/mtaylor/dev/bartr/BartrProtocol
> cd e2e && npm test -s -- $@

 FAIL  ./multiple-cdrs-matched-flow.test.js (67.516s)
  ✕ the API for each party is reachable (17ms)
  ✕ the vendor and customer enter into an agreement (2ms)
  ✕ the same call details in 1 a batch of CDRs is received for each party (6ms)
  ✕ the vendor publishes some rates (2ms)

mtaylor

public interface Transformer {

   default void init(Map<String, String> properties) { }

   default Message transform(Message message) {
      return transform(new ServerMessageImpl(message)).getICoreMessage();
   }

   @Deprecated
   default ServerMessage transform(ServerMessage m) {

mtaylor

public interface Transformer {

   default void init(Map<String, String> properties) { }

   default Message transform(Message message) {
      return transform(new ServerMessageImpl(message)).getICoreMessage();
   }

   @Deprecated
   default ServerMessage transform(ServerMessage m) {

mtaylor

public interface Transformer {

   default void init(Map<String, String> properties) { }

   default Message transform(Message message) {
      ServerMessage m = null;
      if (transform(m) != null) {
         // convert message
         // transform(serverMessage)
      }

mtaylor

   @Override
   public UUID setup(Supplier<? extends UUID> nodeIdFactory) {
      synchronized (connection) {
         final UUID newNodeId = nodeIdFactory.get();
         //TODO make it plublic static to be read (at least)
         final int MAX_SETUP_ATTEMPTS = 10;
         for (int attempts = 0; attempts < MAX_SETUP_ATTEMPTS; attempts++) {
            final UUID nodeId = optimisticUpdateNodeId(newNodeId);
            if (nodeId != null) {
               return nodeId;