From f39303495a46a6d096e96c050a31b8315bbc7585 Mon Sep 17 00:00:00 2001
From: Bill Rich <bill.rich@gmail.com>
Date: Tue, 25 Jul 2023 11:31:01 -0700
Subject: [PATCH] Add commitsScanned metrics (#1533)

* Add commitsScanned metrics

* Just keep commit count
---
 pkg/sources/git/git.go | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/pkg/sources/git/git.go b/pkg/sources/git/git.go
index 41e6a937687f..b8d03a6dd29c 100644
--- a/pkg/sources/git/git.go
+++ b/pkg/sources/git/git.go
@@ -51,9 +51,14 @@ type Git struct {
 	jobID              int64
 	sourceMetadataFunc func(file, email, commit, timestamp, repository string, line int64) *source_metadatapb.MetaData
 	verify             bool
+	metrics            metrics
 	concurrency        *semaphore.Weighted
 }
 
+type metrics struct {
+	commitsScanned int
+}
+
 func NewGit(sourceType sourcespb.SourceType, jobID, sourceID int64, sourceName string, verify bool, concurrency int,
 	sourceMetadataFunc func(file, email, commit, timestamp, repository string, line int64) *source_metadatapb.MetaData,
 ) *Git {
@@ -339,6 +344,10 @@ func CloneRepoUsingSSH(ctx context.Context, gitUrl string, args ...string) (stri
 	return CloneRepo(ctx, userInfo, gitUrl, args...)
 }
 
+func (s *Git) CommitsScanned() int {
+	return s.metrics.commitsScanned
+}
+
 func (s *Git) ScanCommits(ctx context.Context, repo *git.Repository, path string, scanOptions *ScanOptions, chunksChan chan *sources.Chunk) error {
 	if err := GitCmdCheck(); err != nil {
 		return err
@@ -371,6 +380,7 @@ func (s *Git) ScanCommits(ctx context.Context, repo *git.Repository, path string
 			break
 		}
 		depth++
+		s.metrics.commitsScanned++
 		logger.V(5).Info("scanning commit", "commit", commit.Hash)
 		for _, diff := range commit.Diffs {
 			if !scanOptions.Filter.Pass(diff.PathB) {