revisions

Author: andrii-codefresh

event_reporter/reporter/application_event_reporter.go

@@ -274,7 +274,7 @@ func (s *applicationEventReporter) resolveApplicationVersions(ctx context.Contex
 
 		var applicationVersions *apiclient.ApplicationVersions
 		if s.useSourcesServer {
-			appVers := s.sourcesServerClient.GetAppVersion(a)
+			appVers := s.sourcesServerClient.GetAppVersion(a, syncResultRevisions)
 			applicationVersions = utils.SourcesAppVersionsToRepo(appVers, logCtx)
 		} else {
 			applicationVersions = syncManifests.GetApplicationVersions()
@@ -293,7 +293,8 @@ func (s *applicationEventReporter) resolveApplicationVersions(ctx context.Contex
 
 	var applicationVersions *apiclient.ApplicationVersions
 	if s.useSourcesServer {
-		appVers := s.sourcesServerClient.GetAppVersion(a)
+		syncResultRevisions := &([]string{*syncResultRevision})
+		appVers := s.sourcesServerClient.GetAppVersion(a, syncResultRevisions)
 		applicationVersions = utils.SourcesAppVersionsToRepo(appVers, logCtx)
 	} else {
 		applicationVersions = syncManifests.GetApplicationVersions()

pkg/sources_server_client/client.go

@@ -12,6 +12,11 @@ import (
 	"github.com/argoproj/argo-cd/v2/pkg/apis/application/v1alpha1"
 )
 
+type VersionPayload struct {
+	app       *v1alpha1.Application
+	revisions *[]string
+}
+
 type DependenciesMap struct {
 	Lock         string `json:"helm/Chart.lock"`
 	Deps         string `json:"helm/dependencies"`
@@ -32,7 +37,7 @@ type sourceServerClient struct {
 }
 
 type SourceServerClientInteface interface {
-	GetAppVersion(app *v1alpha1.Application) *AppVersionResult
+	GetAppVersion(app *v1alpha1.Application, revisions *[]string) *AppVersionResult
 }
 
 func (c *sourceServerClient) sendRequest(method, url string, payload interface{}) ([]byte, error) {
@@ -72,8 +77,8 @@ func (c *sourceServerClient) sendRequest(method, url string, payload interface{}
 	return body, nil
 }
 
-func (c *sourceServerClient) GetAppVersion(app *v1alpha1.Application) *AppVersionResult {
-	appVersionResult, err := c.sendRequest("POST", "/getAppVersion", app)
+func (c *sourceServerClient) GetAppVersion(app *v1alpha1.Application, revisions *[]string) *AppVersionResult {
+	appVersionResult, err := c.sendRequest("POST", "/getAppVersion", VersionPayload{app: app, revisions: revisions})
 	if err != nil {
 		log.Errorf("error getting app version: %v", err)
 		return nil