fix: sql query fix + logging cleanup

ceramicnetwork · Jul 28, 2023 · 4fcd77c · 4fcd77c
1 parent beef7b4
commit 4fcd77c
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 4 deletions.
diff --git a/common/db/anchor.go b/common/db/anchor.go
@@ -39,7 +39,7 @@ func NewAnchorDb(logger models.Logger) *AnchorDatabase {
 }
 
 func (adb *AnchorDatabase) GetRequests(ctx context.Context, status models.RequestStatus, newerThan time.Time, olderThan time.Time, limit int) ([]*models.AnchorRequest, error) {
-	query := "SELECT REQ.id, REQ.cid, REQ.stream_id, REQ.origin, REQ.timestamp, REQ.created_at, META.metadata FROM request AS REQ LEFT JOIN metadata AS META USING (stream_id) WHERE status = $1 AND REQ.created_at > $2 AND created_at < $3 ORDER BY REQ.created_at LIMIT $4"
+	query := "SELECT REQ.id, REQ.cid, REQ.stream_id, REQ.origin, REQ.timestamp, REQ.created_at, META.metadata FROM request AS REQ LEFT JOIN metadata AS META USING (stream_id) WHERE status = $1 AND REQ.created_at > $2 AND REQ.created_at < $3 ORDER BY REQ.created_at LIMIT $4"
 	return adb.query(
 		ctx,
 		query,

diff --git a/services/batch.go b/services/batch.go
@@ -77,7 +77,10 @@ func (b BatchingService) batch(ctx context.Context, anchorReqs []*models.AnchorR
 	}
 	b.metricService.Count(ctx, models.MetricName_BatchCreated, 1)
 	b.metricService.Distribution(ctx, models.MetricName_BatchSize, batchSize)
-	b.logger.Infof("generated %v", anchorReqBatch)
+	b.logger.Debugw(
+		"batch generated",
+		"batch", anchorReqBatch,
+	)
 	return batchResults, nil
 }
 

diff --git a/services/poll.go b/services/poll.go
@@ -96,7 +96,11 @@ func (p RequestPoller) Run(ctx context.Context) {
 				// It's possible the checkpoint was updated even if a particular request in the batch failed to be
 				// queued.
 				if nextCheckpoint := p.sendRequestMessages(ctx, anchorReqMsgs); nextCheckpoint.After(startCheckpoint) {
-					p.logger.Debugf("old=%s, new=%s", startCheckpoint, nextCheckpoint)
+					p.logger.Debugw(
+						"checkpoints",
+						"start", startCheckpoint,
+						"next", nextCheckpoint,
+					)
 					if _, err = p.stateDb.UpdateCheckpoint(ctx, models.CheckpointType_RequestPoll, nextCheckpoint); err != nil {
 						p.logger.Errorf("error updating checkpoint %s: %v", nextCheckpoint, err)
 					} else {

diff --git a/services/worker.go b/services/worker.go
@@ -95,7 +95,7 @@ func (w WorkerService) createJobs(ctx context.Context) error {
 			}
 		}
 		w.logger.Debugw(
-			"counts",
+			"job counts",
 			"numJobsRequired", numJobsRequired,
 			"numExistingJobs", numExistingJobs,
 			"numJobsAllowed", numJobsAllowed,