Add job to refresh rewards data daily (#58)

Layr-Labs · Jan 13, 2025 · 30d8cde · 30d8cde
2 parents 7e46d1b + 0a8ac71
commit 30d8cde
Show file tree

Hide file tree

Showing 4 changed files with 67 additions and 4 deletions.
diff --git a/eigenlayer-rewards-updater/templates/rewardsDataCron.yaml b/eigenlayer-rewards-updater/templates/rewardsDataCron.yaml
@@ -0,0 +1,49 @@
+{{- if eq .Values.rewardsDataJob.enabled true -}}
+---
+apiVersion: batch/v1
+kind: CronJob
+metadata:
+  name: {{ .Values.rewardsDataJob.name }}
+  namespace: {{ .Release.Namespace }}
+  labels:
+    tags.datadoghq.com/env: {{ .Values.environment }}
+    tags.datadoghq.com/version: {{ .Values.version }}
+    tags.datadoghq.com/service: "{{ .Values.rewardsDataJob.name }}"
+    admission.datadoghq.com/config.mode: "socket"
+    app: {{ .Values.rewardsDataJob.name }}
+spec:
+  schedule: "{{ .Values.rewardsDataJob.schedule }}"
+  jobTemplate:
+    spec:
+      template:
+        metadata:
+          labels:
+            tags.datadoghq.com/env: {{ .Values.environment }}
+            tags.datadoghq.com/version: {{ .Values.version }}
+            tags.datadoghq.com/service: "{{ .Values.rewardsDataJob.name }}"
+            admission.datadoghq.com/enabled: "true"
+        spec:
+          restartPolicy: Never
+          containers:
+            - name: rewards-data
+              image: {{ .Values.rewardsDataJob.image.repository }}:{{ .Values.rewardsDataJob.image.tag }}
+              imagePullPolicy: {{ .Values.rewardsDataJob.image.pullPolicy }}
+              args:
+                - -plaintext
+                - -d
+                - '{ "cutoff_date": "latest", "wait_for_complete": false }'
+                - {{ .Values.rewardsDataJob.sidecarUrl }}
+                - eigenlayer.sidecar.rewards.v1.Rewards/GenerateRewards
+              volumeMounts:
+                - name: config-volume
+                  mountPath: "/etc/eigenlayer-rewards-updater/"
+                  readOnly: true
+              env:
+                - name: DD_TRACE_SAMPLE_RATE
+                  value: "1.0"
+          volumes:
+            - name: config-volume
+              secret:
+                secretName: {{ .Values.rewardsDataJob.name }}-secret
+
+{{- end -}}
diff --git a/eigenlayer-rewards-updater/values-mainnetEthereum.yaml b/eigenlayer-rewards-updater/values-mainnetEthereum.yaml
@@ -4,22 +4,27 @@ cronJob:
   namespace: mainnet-ethereum
   enabled: false
   image:
-    tag: ffcfb90e5d3d23156acc7a33d7d8070a91a87bea
+    tag: v1.0.0-rc.3
 claimJob:
   namespace: testnet-holesky
   enabled: false
   image:
-    tag: ffcfb90e5d3d23156acc7a33d7d8070a91a87bea
+    tag: v1.0.0-rc.3
 verifyRootJob:
   enabled: true
   image:
-    tag: ffcfb90e5d3d23156acc7a33d7d8070a91a87bea
+    tag: v1.0.0-rc.3
   config: |
     debug: true
     
     environment: "mainnet"
     network: "ethereum"
     rpc_url: "https://ethereum-rpc.publicnode.com"
     proof_store_base_url: "https://eigenlabs-rewards-mainnet-ethereum.s3.amazonaws.com"
-    private_key: "..."
+    private_key: "c4d8ec6c8f3224aabc3335e088a168c75db6d5c284bedc01bdb550d7362a59d8"
     rewards_coordinator_address: "0x7750d328b314effa365a0402ccfd489b80b0adda"
+
+rewardsDataJob:
+  name: rewards-data
+  enabled: true
+  sidecarUrl: "sidecar.blocklake-mainnet-ethereum.svc.cluster.local:7100"
diff --git a/eigenlayer-rewards-updater/values.yaml b/eigenlayer-rewards-updater/values.yaml
@@ -58,3 +58,11 @@ verifyRootJob:
     private_key: ""
     proof_store_base_url: "https://eigenlabs-rewards-preprod-holesky.s3.amazonaws.com"
     rewards_coordinator_address: ""
+rewardsDataJob:
+  name: rewards-data
+  enabled: true
+  schedule: "0 6 * * *" # run daily at 6am UTC
+  image:
+    repository: docker pull fullstorydev/grpcurl
+    tag: latest
+  sidecarUrl: ""
diff --git a/pkg/updater/updater.go b/pkg/updater/updater.go
@@ -45,6 +45,7 @@ func (u *Updater) Update(ctx context.Context) (*UpdatedRoot, error) {
 	res, err := u.sidecarClient.Rewards.GenerateRewards(ctx, &v1.GenerateRewardsRequest{
 		RespondWithRewardsData: false,
 		WaitForComplete:        true,
+		CutoffDate:             "latest",
 	})
 	if err != nil {
 		return nil, fmt.Errorf("failed to generate rewards: %w", err)