feat: method for fetching latest commit from gittest server

go.mod

@@ -1,6 +1,6 @@
 module github.com/rudderlabs/rudder-go-kit
 
-go 1.22.5
+go 1.22.7
 
 replace github.com/gocql/gocql => github.com/scylladb/gocql v1.14.2
 

testhelper/gittest/gittest.go

@@ -21,9 +21,13 @@ import (
 
 type Server struct {
 	*httptest.Server
-	URL string
+	URL           string
+	rootPath      string
+	DefaultBranch string
 }
 
+const defaultBranch = "main"
+
 // NewHttpServer creates a new httptest.Server that serves a git repository from the given sourcePath.
 func NewHttpServer(t testing.TB, sourcePath string) *Server {
 	return newServer(t, sourcePath, false)
@@ -60,7 +64,7 @@ func newServer(t testing.TB, sourcePath string, secure bool) *Server {
 	require.NoError(t, err, "should be able to find git in PATH")
 	out, err = execCmd("git", "init", workingDir)
 	require.NoErrorf(t, err, "should be able to initialize git repository: %s", out)
-	out, err = execCmd("git", "-C", workingDir, "branch", "-m", "main")
+	out, err = execCmd("git", "-C", workingDir, "branch", "-m", defaultBranch)
 	require.NoErrorf(t, err, "should be able to rename the default branch to main: %s", out)
 	out, err = execCmd("git", "-C", workingDir, "add", ".")
 	require.NoErrorf(t, err, "should be able to add files to git repository: %s", out)
@@ -99,8 +103,10 @@ func newServer(t testing.TB, sourcePath string, secure bool) *Server {
 	serverURL.Host = net.JoinHostPort(getLocalIP(t), port)
 	url := serverURL.String() + "/" + org + "/" + repo
 	return &Server{
-		Server: s,
-		URL:    url,
+		Server:        s,
+		URL:           url,
+		rootPath:      gitRoot,
+		DefaultBranch: defaultBranch,
 	}
 }
 
@@ -109,6 +115,14 @@ func (s *Server) GetServerCA() []byte {
 	return getServerCA(s.Server)
 }
 
+func (s *Server) GetLatestCommitHash(t testing.TB, branch string) string {
+	cmd := exec.Command("git", "ls-remote", s.URL, fmt.Sprintf("refs/heads/%s", branch))
+	out, err := cmd.Output()
+	require.NoError(t, err, "should be able to run the ls-remote command")
+	commitHash := strings.Split(string(out), "\t")[0]
+	return commitHash
+}
+
 func getServerCA(server *httptest.Server) []byte {
 	return pem.EncodeToMemory(&pem.Block{Type: "CERTIFICATE", Bytes: server.TLS.Certificates[0].Certificate[0]})
 }

testhelper/gittest/gittest_test.go

@@ -5,6 +5,7 @@ import (
 	"os"
 	"os/exec"
 	"path/filepath"
+	"strings"
 	"testing"
 
 	"github.com/stretchr/testify/require"
@@ -57,6 +58,13 @@ func TestGitServer(t *testing.T) {
 
 		out, err = execCmd("git", "-C", tempDir, "push", "origin", "v1.0.0")
 		require.NoErrorf(t, err, "should be able to push the tag: %s", out)
+
+		out, err = execCmd("git", "-C", tempDir, "rev-parse", "HEAD")
+		require.NoError(t, err, "should be able to get the HEAD commit")
+		require.NotEmpty(t, out, "HEAD commit should not be empty")
+
+		latestCommit := s.GetLatestCommitHash(t, "develop")
+		require.Equal(t, strings.TrimSpace(out), latestCommit, "HEAD commit should match the latest commit")
 	})
 
 	t.Run("https", func(t *testing.T) {