publish data in the git bucket (#37)

aultron · web-flow · commit 6b351250c7e4 · 2022-05-19T18:00:19.000+03:00
Signed-off-by: Ibrahim Mbaziira &lt;dev.code.ibra@gmail.com&gt;
diff --git a/cmd/git/git.go b/cmd/git/git.go
@@ -1752,7 +1752,7 @@ func (j *DSGit) GitEnrichItems(ctx *shared.Ctx, thrN int, items []interface{}, d
 				for _, d := range data {
 					formattedData = append(formattedData, d)
 				}
-				err = j.Publisher.PushEvents(CommitCreated, "insights", j.RepositorySource, "commits", os.Getenv("STAGE"), formattedData)
+				err = j.Publisher.PushEvents(CommitCreated, "insights", GitDataSource, "commits", os.Getenv("STAGE"), formattedData)
 				if err != nil {
 					shared.Printf("Error: %+v\n", err)
 					return

Original file line number	Diff line number	Diff line change
`@@ -1752,7 +1752,7 @@ func (j DSGit) GitEnrichItems(ctx shared.Ctx, thrN int, items []interface{}, d`
`1752`	`1752`	`for _, d := range data {`
`1753`	`1753`	`formattedData = append(formattedData, d)`
`1754`	`1754`	`}`
`1755`		`- err = j.Publisher.PushEvents(CommitCreated, "insights", j.RepositorySource, "commits", os.Getenv("STAGE"), formattedData)`
	`1755`	`+ err = j.Publisher.PushEvents(CommitCreated, "insights", GitDataSource, "commits", os.Getenv("STAGE"), formattedData)`
`1756`	`1756`	`if err != nil {`
`1757`	`1757`	`shared.Printf("Error: %+v\n", err)`
`1758`	`1758`	`return`