fix:correct Slack Report using pingType=Report

solana-labs · Jan 20, 2022 · 63f70bd · 63f70bd
1 parent 065dbfe
commit 63f70bd
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git a/database.go b/database.go
@@ -10,7 +10,7 @@ type PingResult struct {
  TimeStamp int64 `gorm:"primaryKey;autoIncrement:false"`
  Cluster string `gorm:"primaryKey"`
  Hostname string
- PingType string `gorm:"NOT NULL"`
+ PingType string `gorm:"NOT NULL;primaryKey"`
  Submitted int `gorm:"NOT NULL"`
  Confirmed int `gorm:"NOT NULL"`
  Loss float64 `gorm:"NOT NULL"`

diff --git a/main.go b/main.go
@@ -81,6 +81,7 @@ func getLatest(c *gin.Context) {
  ret = GetLatestResult(Devnet)
  default:
  c.AbortWithStatus(http.StatusNotFound)
+ log.Println("StatusNotFound Error:", cluster)
  return
  }
  c.IndentedJSON(http.StatusOK, ret)

diff --git a/workers.go b/workers.go
@@ -111,7 +111,7 @@ func slackReportWorker(c Cluster) {
  lastReporUnixTime = time.Now().UTC().Unix() - int64(config.Slack.ReportTime)
  log.Println("reconstruct lastReport time=", lastReporUnixTime, "time now=", time.Now().UTC().Unix())
  }
- data := getAfter(c, DataPoint1Min, lastReporUnixTime)
+ data := getAfter(c, Report, lastReporUnixTime)
  if len(data) <= 0 { // No Data
  log.Println(c, " getAfter return empty")
  time.Sleep(30 * time.Second)