From 675e99335375bd8a56b451e266d2261ac219f03b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Ask=20Bj=C3=B8rn=20Hansen?= <ask@develooper.com>
Date: Sat, 20 Jan 2024 23:43:22 -0700
Subject: [PATCH] scorer: fix parsing leap column

---
 chdb/logscores.go | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git a/chdb/logscores.go b/chdb/logscores.go
index 7f0df15..71875a3 100644
--- a/chdb/logscores.go
+++ b/chdb/logscores.go
@@ -60,7 +60,10 @@ func (d *ClickHouse) Logscores(ctx context.Context, serverID, monitorID int, sin
 
 	log.DebugContext(ctx, "clickhouse query", "query", query, "args", args)
 
-	rows, err := d.Scores.Query(clickhouse.Context(ctx, clickhouse.WithSpan(span.SpanContext())),
+	rows, err := d.Scores.Query(
+		clickhouse.Context(
+			ctx, clickhouse.WithSpan(span.SpanContext()),
+		),
 		query, args...,
 	)
 	if err != nil {
@@ -74,6 +77,8 @@ func (d *ClickHouse) Logscores(ctx context.Context, serverID, monitorID int, sin
 
 		row := ntpdb.LogScore{}
 
+		var leap uint8
+
 		if err := rows.Scan(
 			&row.ID,
 			&row.MonitorID,
@@ -83,7 +88,7 @@ func (d *ClickHouse) Logscores(ctx context.Context, serverID, monitorID int, sin
 			&row.Step,
 			&row.Offset,
 			&row.Rtt,
-			&row.Attributes.Leap,
+			&leap,
 			&row.Attributes.Warning,
 			&row.Attributes.Error,
 		); err != nil {
@@ -91,6 +96,8 @@ func (d *ClickHouse) Logscores(ctx context.Context, serverID, monitorID int, sin
 			continue
 		}
 
+		row.Attributes.Leap = int8(leap)
+
 		rv = append(rv, row)
 
 	}