Skip to content

Commit 2ca36e5

Browse files
remoteramiremoterami
committed
chore: remove superfluous clickhouse checks
1 parent 7c21cf5 commit 2ca36e5

File tree

5 files changed

+103
-103
lines changed

5 files changed

+103
-103
lines changed

‎backend/pkg/api/data_access/mobile.go‎

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -285,12 +285,12 @@ func (d *DataAccessService) GetValidatorDashboardMobileWidget(ctx context.Contex
285285
From(goqu.L(fmt.Sprintf(`%s AS r FINAL`, table))).
286286
With("validators", goqu.L("(SELECT dashboard_id, validator_index FROM users_val_dashboards_validators WHERE dashboard_id = ?)", dashboardId)).
287287
Select(
288-
goqu.L("COALESCE(SUM(r.attestations_reward)::decimal, 0) AS attestations_reward"),
289-
goqu.L("COALESCE(SUM(r.attestations_ideal_reward)::decimal, 0) AS attestations_ideal_reward"),
290-
goqu.L("COALESCE(SUM(r.blocks_proposed), 0) AS blocks_proposed"),
291-
goqu.L("COALESCE(SUM(r.blocks_scheduled), 0) AS blocks_scheduled"),
292-
goqu.L("COALESCE(SUM(r.sync_executed), 0) AS sync_executed"),
293-
goqu.L("COALESCE(SUM(r.sync_scheduled), 0) AS sync_scheduled")).
288+
goqu.L("SUM(r.attestations_reward) AS attestations_reward"),
289+
goqu.L("SUM(r.attestations_ideal_reward) AS attestations_ideal_reward"),
290+
goqu.L("SUM(r.blocks_proposed) AS blocks_proposed"),
291+
goqu.L("SUM(r.blocks_scheduled) AS blocks_scheduled"),
292+
goqu.L("SUM(r.sync_executed) AS sync_executed"),
293+
goqu.L("SUM(r.sync_scheduled) AS sync_scheduled")).
294294
InnerJoin(goqu.L("validators v"), goqu.On(goqu.L("r.validator_index = v.validator_index"))).
295295
Where(goqu.L("r.validator_index IN (SELECT validator_index FROM validators)"))
296296

@@ -484,12 +484,12 @@ func (d *DataAccessService) getIndividualEfficiencies(ctx context.Context, indic
484484
From(goqu.L(fmt.Sprintf(`%s AS r FINAL`, table))).
485485
Select(
486486
goqu.L("r.validator_index"),
487-
goqu.L("COALESCE(r.attestations_reward::decimal, 0) AS attestations_reward"),
488-
goqu.L("COALESCE(r.attestations_ideal_reward::decimal, 0) AS attestations_ideal_reward"),
489-
goqu.L("COALESCE(r.blocks_proposed, 0) AS blocks_proposed"),
490-
goqu.L("COALESCE(r.blocks_scheduled, 0) AS blocks_scheduled"),
491-
goqu.L("COALESCE(r.sync_executed, 0) AS sync_executed"),
492-
goqu.L("COALESCE(r.sync_scheduled, 0) AS sync_scheduled"),
487+
goqu.L("r.attestations_reward AS attestations_reward"),
488+
goqu.L("r.attestations_ideal_reward AS attestations_ideal_reward"),
489+
goqu.L("r.blocks_proposed AS blocks_proposed"),
490+
goqu.L("r.blocks_scheduled AS blocks_scheduled"),
491+
goqu.L("r.sync_executed AS sync_executed"),
492+
goqu.L("r.sync_scheduled AS sync_scheduled"),
493493
).Where(goqu.L("r.validator_index IN ?", indices))
494494

495495
var queryResult []struct {

‎backend/pkg/api/data_access/vdb_management.go‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -470,12 +470,12 @@ func (d *DataAccessService) GetValidatorDashboardOverview(ctx context.Context, d
470470
From(goqu.L(fmt.Sprintf(`%s AS r FINAL`, table))).
471471
With("validators", goqu.L("(SELECT dashboard_id, validator_index FROM users_val_dashboards_validators WHERE dashboard_id = ?)", dashboardId.Id)).
472472
Select(
473-
goqu.L("COALESCE(SUM(r.attestations_reward)::decimal, 0) AS attestations_reward"),
474-
goqu.L("COALESCE(SUM(r.attestations_ideal_reward)::decimal, 0) AS attestations_ideal_reward"),
475-
goqu.L("COALESCE(SUM(r.blocks_proposed), 0) AS blocks_proposed"),
476-
goqu.L("COALESCE(SUM(r.blocks_scheduled), 0) AS blocks_scheduled"),
477-
goqu.L("COALESCE(SUM(r.sync_executed), 0) AS sync_executed"),
478-
goqu.L("COALESCE(SUM(r.sync_scheduled), 0) AS sync_scheduled"))
473+
goqu.L("SUM(r.attestations_reward) AS attestations_reward"),
474+
goqu.L("SUM(r.attestations_ideal_reward) AS attestations_ideal_reward"),
475+
goqu.L("SUM(r.blocks_proposed) AS blocks_proposed"),
476+
goqu.L("SUM(r.blocks_scheduled) AS blocks_scheduled"),
477+
goqu.L("SUM(r.sync_executed) AS sync_executed"),
478+
goqu.L("SUM(r.sync_scheduled) AS sync_scheduled"))
479479

480480
if len(dashboardId.Validators) == 0 {
481481
ds = ds.

‎backend/pkg/api/data_access/vdb_rewards.go‎

Lines changed: 48 additions & 48 deletions
Original file line numberDiff line numberDiff line change
@@ -89,15 +89,15 @@ func (d *DataAccessService) GetValidatorDashboardRewards(ctx context.Context, da
8989
With("validators", goqu.L("(SELECT validator_index as validator_index, group_id FROM users_val_dashboards_validators WHERE dashboard_id = ?)", dashboardId.Id)).
9090
Select(
9191
goqu.L("e.epoch"),
92-
goqu.L(`SUM(COALESCE(e.attestations_reward, 0) + COALESCE(e.blocks_cl_reward, 0) + COALESCE(e.sync_reward, 0)) AS cl_rewards`),
93-
goqu.L("SUM(COALESCE(e.attestations_scheduled, 0)) AS attestations_scheduled"),
94-
goqu.L("SUM(COALESCE(e.attestations_observed, 0)) AS attestations_observed"),
95-
goqu.L("SUM(COALESCE(e.blocks_scheduled, 0)) AS blocks_scheduled"),
96-
goqu.L("SUM(COALESCE(e.blocks_proposed, 0)) AS blocks_proposed"),
97-
goqu.L("SUM(COALESCE(e.sync_scheduled, 0)) AS sync_scheduled"),
98-
goqu.L("SUM(COALESCE(e.sync_executed, 0)) AS sync_executed"),
92+
goqu.L(`SUM(e.attestations_reward + e.blocks_cl_reward + e.sync_reward) AS cl_rewards`),
93+
goqu.L("SUM(e.attestations_scheduled) AS attestations_scheduled"),
94+
goqu.L("SUM(e.attestations_observed) AS attestations_observed"),
95+
goqu.L("SUM(e.blocks_scheduled) AS blocks_scheduled"),
96+
goqu.L("SUM(e.blocks_proposed) AS blocks_proposed"),
97+
goqu.L("SUM(e.sync_scheduled) AS sync_scheduled"),
98+
goqu.L("SUM(e.sync_executed) AS sync_executed"),
9999
goqu.L("SUM(CASE WHEN e.slashed THEN 1 ELSE 0 END) AS slashed_in_epoch"),
100-
goqu.L("SUM(COALESCE(e.blocks_slashing_count, 0)) AS slashed_amount")).
100+
goqu.L("SUM(e.blocks_slashing_count) AS slashed_amount")).
101101
Where(goqu.L("e.epoch_timestamp >= fromUnixTimestamp(?)", utils.EpochToTime(startEpoch).Unix()))
102102

103103
elDs := goqu.Dialect("postgres").
@@ -536,26 +536,26 @@ func (d *DataAccessService) GetValidatorDashboardGroupRewards(ctx context.Contex
536536
From(goqu.L("validator_dashboard_data_epoch e")).
537537
With("validators", goqu.L("(SELECT validator_index as validator_index, group_id FROM users_val_dashboards_validators WHERE dashboard_id = ?)", dashboardId.Id)).
538538
Select(
539-
goqu.L("COALESCE(e.attestations_source_reward, 0) AS attestations_source_reward"),
540-
goqu.L("COALESCE(e.attestations_target_reward, 0) AS attestations_target_reward"),
541-
goqu.L("COALESCE(e.attestations_head_reward, 0) AS attestations_head_reward"),
542-
goqu.L("COALESCE(e.attestations_inactivity_reward, 0) AS attestations_inactivity_reward"),
543-
goqu.L("COALESCE(e.attestations_inclusion_reward, 0) AS attestations_inclusion_reward"),
544-
goqu.L("COALESCE(e.attestations_scheduled, 0) AS attestations_scheduled"),
545-
goqu.L("COALESCE(e.attestations_head_executed, 0) AS attestations_head_executed"),
546-
goqu.L("COALESCE(e.attestations_source_executed, 0) AS attestations_source_executed"),
547-
goqu.L("COALESCE(e.attestations_target_executed, 0) AS attestations_target_executed"),
548-
goqu.L("COALESCE(e.blocks_scheduled, 0) AS blocks_scheduled"),
549-
goqu.L("COALESCE(e.blocks_proposed, 0) AS blocks_proposed"),
550-
goqu.L("COALESCE(e.blocks_cl_reward, 0) AS blocks_cl_reward"),
551-
goqu.L("COALESCE(e.sync_scheduled, 0) AS sync_scheduled"),
552-
goqu.L("COALESCE(e.sync_executed, 0) AS sync_executed"),
553-
goqu.L("COALESCE(e.sync_reward, 0) AS sync_reward"),
539+
goqu.L("e.attestations_source_reward"),
540+
goqu.L("e.attestations_target_reward"),
541+
goqu.L("e.attestations_head_reward"),
542+
goqu.L("e.attestations_inactivity_reward"),
543+
goqu.L("e.attestations_inclusion_reward"),
544+
goqu.L("e.attestations_scheduled"),
545+
goqu.L("e.attestations_head_executed"),
546+
goqu.L("e.attestations_source_executed"),
547+
goqu.L("e.attestations_target_executed"),
548+
goqu.L("e.blocks_scheduled"),
549+
goqu.L("e.blocks_proposed"),
550+
goqu.L("e.blocks_cl_reward"),
551+
goqu.L("e.sync_scheduled"),
552+
goqu.L("e.sync_executed"),
553+
goqu.L("e.sync_reward"),
554554
goqu.L("(CASE WHEN e.slashed THEN 1 ELSE 0 END) AS slashed_in_epoch"),
555-
goqu.L("COALESCE(e.blocks_slashing_count, 0) AS slashed_amount"),
556-
goqu.L("COALESCE(e.blocks_cl_slasher_reward, 0) AS slasher_reward"),
557-
goqu.L("COALESCE(e.blocks_cl_attestations_reward, 0) AS blocks_cl_attestations_reward"),
558-
goqu.L("COALESCE(e.blocks_cl_sync_aggregate_reward, 0) AS blocks_cl_sync_aggregate_reward")).
555+
goqu.L("e.blocks_slashing_count AS slashed_amount"),
556+
goqu.L("e.blocks_cl_slasher_reward AS slasher_reward"),
557+
goqu.L("e.blocks_cl_attestations_reward"),
558+
goqu.L("e.blocks_cl_sync_aggregate_reward")).
559559
Where(goqu.L("e.epoch_timestamp = fromUnixTimestamp(?)", utils.EpochToTime(epoch).Unix()))
560560

561561
elDs := goqu.Dialect("postgres").
@@ -751,7 +751,7 @@ func (d *DataAccessService) GetValidatorDashboardRewardsChart(ctx context.Contex
751751
// CL
752752
rewardsDs := goqu.Dialect("postgres").
753753
Select(
754-
goqu.L(`SUM(COALESCE(e.attestations_reward, 0) + COALESCE(e.blocks_cl_reward, 0) + COALESCE(e.sync_reward, 0)) AS cl_rewards`),
754+
goqu.L(`SUM(e.attestations_reward + e.blocks_cl_reward + e.sync_reward) AS cl_rewards`),
755755
timeColumn.As("timestamp"),
756756
).
757757
From(dataTable).
@@ -1034,31 +1034,31 @@ func (d *DataAccessService) GetValidatorDashboardDuties(ctx context.Context, das
10341034
rewardsDs := goqu.Dialect("postgres").
10351035
Select(
10361036
goqu.L("e.validator_index"),
1037-
goqu.L("COALESCE(e.attestations_scheduled, 0) AS attestations_scheduled"),
1038-
goqu.L("COALESCE(e.attestations_source_executed, 0) AS attestations_source_executed"),
1039-
goqu.L("COALESCE(e.attestations_source_reward, 0) AS attestations_source_reward"),
1040-
goqu.L("COALESCE(e.attestations_target_executed, 0) AS attestations_target_executed"),
1041-
goqu.L("COALESCE(e.attestations_target_reward, 0) AS attestations_target_reward"),
1042-
goqu.L("COALESCE(e.attestations_head_executed, 0) AS attestations_head_executed"),
1043-
goqu.L("COALESCE(e.attestations_head_reward, 0) AS attestations_head_reward"),
1044-
goqu.L("COALESCE(e.sync_scheduled, 0) AS sync_scheduled"),
1045-
goqu.L("COALESCE(e.sync_executed, 0) AS sync_executed"),
1046-
goqu.L("COALESCE(e.sync_reward, 0) AS sync_reward"),
1037+
goqu.L("e.attestations_scheduled"),
1038+
goqu.L("e.attestations_source_executed"),
1039+
goqu.L("e.attestations_source_reward"),
1040+
goqu.L("e.attestations_target_executed"),
1041+
goqu.L("e.attestations_target_reward"),
1042+
goqu.L("e.attestations_head_executed"),
1043+
goqu.L("e.attestations_head_reward"),
1044+
goqu.L("e.sync_scheduled"),
1045+
goqu.L("e.sync_executed"),
1046+
goqu.L("e.sync_reward"),
10471047
goqu.L("e.slashed AS slashed_in_epoch"),
1048-
goqu.L("COALESCE(e.blocks_slashing_count, 0) AS slashed_amount"),
1049-
goqu.L("COALESCE(e.blocks_cl_slasher_reward, 0) AS slasher_reward"),
1050-
goqu.L("COALESCE(e.blocks_scheduled, 0) AS blocks_scheduled"),
1051-
goqu.L("COALESCE(e.blocks_proposed, 0) AS blocks_proposed"),
1052-
goqu.L("COALESCE(e.blocks_cl_attestations_reward, 0) AS blocks_cl_attestations_reward"),
1053-
goqu.L("COALESCE(e.blocks_cl_sync_aggregate_reward, 0) AS blocks_cl_sync_aggregate_reward")).
1048+
goqu.L("e.blocks_slashing_count AS slashed_amount"),
1049+
goqu.L("e.blocks_cl_slasher_reward AS slasher_reward"),
1050+
goqu.L("e.blocks_scheduled"),
1051+
goqu.L("e.blocks_proposed"),
1052+
goqu.L("e.blocks_cl_attestations_reward"),
1053+
goqu.L("e.blocks_cl_sync_aggregate_reward")).
10541054
From(goqu.L("validator_dashboard_data_epoch e")).
10551055
Where(goqu.L("e.epoch_timestamp = fromUnixTimestamp(?)", utils.EpochToTime(epoch).Unix())).
10561056
Where(goqu.L(`
1057-
(COALESCE(e.attestations_scheduled, 0) +
1058-
COALESCE(e.sync_scheduled,0) +
1059-
COALESCE(e.blocks_scheduled,0) +
1057+
(e.attestations_scheduled +
1058+
e.sync_scheduled +
1059+
e.blocks_scheduled +
10601060
CASE WHEN e.slashed THEN 1 ELSE 0 END +
1061-
COALESCE(e.blocks_slashing_count, 0)) > 0`))
1061+
e.blocks_slashing_count) > 0`))
10621062

10631063
elDs := goqu.Dialect("postgres").
10641064
Select(

‎backend/pkg/api/data_access/vdb_summary.go‎

Lines changed: 31 additions & 31 deletions
Original file line numberDiff line numberDiff line change
@@ -120,22 +120,22 @@ func (d *DataAccessService) GetValidatorDashboardSummary(ctx context.Context, da
120120
goqu.L("ARRAY_AGG(r.validator_index) AS validator_indices"),
121121
goqu.L(`
122122
(
123-
SUM(COALESCE(finalizeAggregation(r.balance_end), 0)) +
124-
SUM(COALESCE(r.withdrawals_amount, 0)) -
125-
SUM(COALESCE(r.deposits_amount, 0)) -
126-
SUM(COALESCE(finalizeAggregation(r.balance_start), 0))
123+
SUM(finalizeAggregation(r.balance_end)) +
124+
SUM(r.withdrawals_amount) -
125+
SUM(r.deposits_amount) -
126+
SUM(finalizeAggregation(r.balance_start))
127127
) AS cl_rewards
128128
`),
129-
goqu.L("COALESCE(SUM(r.attestations_reward)::decimal, 0) AS attestations_reward"),
130-
goqu.L("COALESCE(SUM(r.attestations_ideal_reward)::decimal, 0) AS attestations_ideal_reward"),
131-
goqu.L("COALESCE(SUM(r.attestations_observed), 0) AS attestations_observed"),
132-
goqu.L("COALESCE(SUM(r.attestations_scheduled), 0) AS attestations_scheduled"),
133-
goqu.L("COALESCE(SUM(r.blocks_proposed), 0) AS blocks_proposed"),
134-
goqu.L("COALESCE(SUM(r.blocks_scheduled), 0) AS blocks_scheduled"),
135-
goqu.L("COALESCE(SUM(r.sync_executed), 0) AS sync_executed"),
136-
goqu.L("COALESCE(SUM(r.sync_scheduled), 0) AS sync_scheduled"),
137-
goqu.L("COALESCE(MIN(r.epoch_start), 0) AS min_epoch_start"),
138-
goqu.L("COALESCE(MAX(r.epoch_end), 0) AS max_epoch_end")).
129+
goqu.L("SUM(r.attestations_reward) AS attestations_reward"),
130+
goqu.L("SUM(r.attestations_ideal_reward) AS attestations_ideal_reward"),
131+
goqu.L("SUM(r.attestations_observed) AS attestations_observed"),
132+
goqu.L("SUM(r.attestations_scheduled) AS attestations_scheduled"),
133+
goqu.L("SUM(r.blocks_proposed) AS blocks_proposed"),
134+
goqu.L("SUM(r.blocks_scheduled) AS blocks_scheduled"),
135+
goqu.L("SUM(r.sync_executed) AS sync_executed"),
136+
goqu.L("SUM(r.sync_scheduled) AS sync_scheduled"),
137+
goqu.L("MIN(r.epoch_start) AS min_epoch_start"),
138+
goqu.L("MAX(r.epoch_end) AS max_epoch_end")).
139139
GroupBy(goqu.L("result_group_id"))
140140

141141
if len(validators) > 0 {
@@ -866,10 +866,10 @@ func (d *DataAccessService) internal_getElClAPR(ctx context.Context, dashboardId
866866
goqu.L("COUNT(*) AS validator_count"),
867867
goqu.L(`
868868
(
869-
SUM(COALESCE(finalizeAggregation(r.balance_end), 0)) +
870-
SUM(COALESCE(r.withdrawals_amount, 0)) -
871-
SUM(COALESCE(r.deposits_amount, 0)) -
872-
SUM(COALESCE(finalizeAggregation(r.balance_start), 0))
869+
SUM(finalizeAggregation(r.balance_end)) +
870+
SUM(r.withdrawals_amount) -
871+
SUM(r.deposits_amount) -
872+
SUM(finalizeAggregation(r.balance_start))
873873
) AS reward
874874
`))
875875
if len(dashboardId.Validators) > 0 {
@@ -1039,12 +1039,12 @@ func (d *DataAccessService) GetValidatorDashboardSummaryChart(ctx context.Contex
10391039
SELECT
10401040
%[2]s as ts,
10411041
0 AS group_id,
1042-
COALESCE(SUM(d.attestations_reward), 0) AS attestations_reward,
1043-
COALESCE(SUM(d.attestations_ideal_reward), 0) AS attestations_ideal_reward,
1044-
COALESCE(SUM(d.blocks_proposed), 0) AS blocks_proposed,
1045-
COALESCE(SUM(d.blocks_scheduled), 0) AS blocks_scheduled,
1046-
COALESCE(SUM(d.sync_executed), 0) AS sync_executed,
1047-
COALESCE(SUM(d.sync_scheduled), 0) AS sync_scheduled
1042+
SUM(d.attestations_reward) AS attestations_reward,
1043+
SUM(d.attestations_ideal_reward) AS attestations_ideal_reward,
1044+
SUM(d.blocks_proposed) AS blocks_proposed,
1045+
SUM(d.blocks_scheduled) AS blocks_scheduled,
1046+
SUM(d.sync_executed) AS sync_executed,
1047+
SUM(d.sync_scheduled) AS sync_scheduled
10481048
FROM %[1]s d
10491049
WHERE %[2]s >= fromUnixTimestamp($1) AND %[2]s <= fromUnixTimestamp($2) AND validator_index IN ($3)
10501050
GROUP BY %[2]s;
@@ -1061,12 +1061,12 @@ func (d *DataAccessService) GetValidatorDashboardSummaryChart(ctx context.Contex
10611061
SELECT
10621062
%[2]s as ts,
10631063
v.group_id,
1064-
COALESCE(SUM(d.attestations_reward), 0) AS attestations_reward,
1065-
COALESCE(SUM(d.attestations_ideal_reward), 0) AS attestations_ideal_reward,
1066-
COALESCE(SUM(d.blocks_proposed), 0) AS blocks_proposed,
1067-
COALESCE(SUM(d.blocks_scheduled), 0) AS blocks_scheduled,
1068-
COALESCE(SUM(d.sync_executed), 0) AS sync_executed,
1069-
COALESCE(SUM(d.sync_scheduled), 0) AS sync_scheduled
1064+
SUM(d.attestations_reward) AS attestations_reward,
1065+
SUM(d.attestations_ideal_reward) AS attestations_ideal_reward,
1066+
SUM(d.blocks_proposed) AS blocks_proposed,
1067+
SUM(d.blocks_scheduled) AS blocks_scheduled,
1068+
SUM(d.sync_executed) AS sync_executed,
1069+
SUM(d.sync_scheduled) AS sync_scheduled
10701070
FROM %[1]s d
10711071
INNER JOIN validators v ON d.validator_index = v.validator_index
10721072
WHERE %[2]s >= fromUnixTimestamp($1) AND %[2]s <= fromUnixTimestamp($2) AND validator_index in (select validator_index from validators)
@@ -1474,7 +1474,7 @@ func (d *DataAccessService) GetValidatorDashboardSlashingsSummaryValidators(ctx
14741474
goqu.L("r.epoch_end"),
14751475
goqu.L("r.validator_index"),
14761476
goqu.L("r.slashed"),
1477-
goqu.L("COALESCE(r.blocks_slashing_count, 0) AS slashed_amount")).
1477+
goqu.L("r.blocks_slashing_count AS slashed_amount")).
14781478
Where(goqu.L("(r.slashed OR r.blocks_slashing_count > 0)"))
14791479

14801480
// handle the case when we have a list of validators

‎backend/pkg/api/services/service_average_network_efficiency.go‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -62,12 +62,12 @@ func (s *Services) updateEfficiencyData() error {
6262
ds := goqu.Dialect("postgres").
6363
From(goqu.L(fmt.Sprintf(`%s AS r FINAL`, tableName))).
6464
Select(
65-
goqu.L("COALESCE(SUM(r.attestations_reward)::decimal, 0) AS attestations_reward"),
66-
goqu.L("COALESCE(SUM(r.attestations_ideal_reward)::decimal, 0) AS attestations_ideal_reward"),
67-
goqu.L("COALESCE(SUM(r.blocks_proposed), 0) AS blocks_proposed"),
68-
goqu.L("COALESCE(SUM(r.blocks_scheduled), 0) AS blocks_scheduled"),
69-
goqu.L("COALESCE(SUM(r.sync_executed), 0) AS sync_executed"),
70-
goqu.L("COALESCE(SUM(r.sync_scheduled), 0) AS sync_scheduled"))
65+
goqu.L("SUM(r.attestations_reward) AS attestations_reward"),
66+
goqu.L("SUM(r.attestations_ideal_reward) AS attestations_ideal_reward"),
67+
goqu.L("SUM(r.blocks_proposed) AS blocks_proposed"),
68+
goqu.L("SUM(r.blocks_scheduled) AS blocks_scheduled"),
69+
goqu.L("SUM(r.sync_executed) AS sync_executed"),
70+
goqu.L("SUM(r.sync_scheduled) AS sync_scheduled"))
7171

7272
query, args, err := ds.Prepared(true).ToSQL()
7373
if err != nil {

0 commit comments

Comments
 (0)