Kathy fixes (#862)

* Fix message print

* Fix kathy configs
pull/863/head
Mattie Conover 2 years ago committed by GitHub
parent e5548d2986
commit 1f624841f4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 8
      typescript/helloworld/src/app/app.ts
  2. 11
      typescript/infra/helm/helloworld-kathy/templates/stateful-set.yaml
  3. 1
      typescript/infra/helm/helloworld-kathy/values.yaml
  4. 3
      typescript/infra/scripts/helloworld/kathy.ts

@ -9,6 +9,7 @@ import {
MultiProvider,
Remotes,
} from '@abacus-network/sdk';
import { debug } from '@abacus-network/utils';
import { HelloWorldContracts } from './contracts';
@ -51,7 +52,12 @@ export class HelloWorldApp<
gasLimit,
value,
});
console.log(tx);
debug('Sending hello message', {
from,
to,
message,
tx,
});
return tx.wait(chainConnection.confirmations);
}

@ -7,6 +7,11 @@ metadata:
abacus/context: {{ .Values.abacus.context | quote }}
app.kubernetes.io/component: kathy
spec:
selector:
matchLabels:
app.kubernetes.io/component: kathy
replicas: 1
serviceName: helloworld-kathy
template:
metadata:
labels: *metadata_labels
@ -27,8 +32,8 @@ spec:
- name: CHAINS_TO_SKIP
value: {{ join "," .Values.chainsToSkip }}
- name: KATHY_FULL_CYCLE_TIME
value: {{ .Values.fullCycleTime }}
value: "{{ .Values.fullCycleTime }}"
- name: KATHY_MESSAGE_SEND_TIMEOUT
value: {{ .Values.messageSendTimeout }}
value: "{{ .Values.messageSendTimeout }}"
- name: KATHY_MESSAGE_RECEIPT_TIMEOUT
value: {{ .Values.messageReceiptTimeout }}
value: "{{ .Values.messageReceiptTimeout }}"

@ -3,6 +3,7 @@ image:
tag:
abacus:
runEnv: testnet2
context: abacus
# Only used for fetching secrets, so all chains should be included regardless of being skipped
chains: []
chainsToSkip: []

@ -49,7 +49,8 @@ metricsRegister.registerMetric(messageReceiptSeconds);
/** How long we should take to go through all the message pairings in milliseconds. 6hrs by default. */
const FULL_CYCLE_TIME =
parseInt(process.env['KATHY_FULL_CYCLE_TIME'] as string) || 1000 * 100;
parseInt(process.env['KATHY_FULL_CYCLE_TIME'] as string) ||
1000 * 60 * 60 * 6;
if (!Number.isSafeInteger(FULL_CYCLE_TIME) || FULL_CYCLE_TIME <= 0) {
error('Invalid cycle time provided');
process.exit(1);

Loading…
Cancel
Save