Fix mark orphand commits (#85)

* fix mark orphand commits

Signed-off-by: Ayman <[email protected]>

* clean up

Signed-off-by: Ayman <[email protected]>

* clean up

Signed-off-by: Ayman <[email protected]>

* clean up

Signed-off-by: Ayman <[email protected]>

* code clean up

Signed-off-by: Ayman <[email protected]>

---------

Signed-off-by: Ayman <[email protected]>
Co-authored-by: Ayman <[email protected]>

Author: khalifapro

.circleci/config.yml

@@ -91,7 +91,7 @@ workflows:
             - build
           filters:
             branches:
-              only: main
+              only:  main
             tags:
               ignore: /.*/
       - approve_prod:

cmd/git/git.go

@@ -1801,6 +1801,11 @@ func (j *DSGit) GitEnrichItems(ctx *shared.Ctx, thrN int, items []interface{}, d
 						j.log.WithFields(logrus.Fields{"operation": "GitEnrichItems"}).Errorf("error hash data for commit %s, error %v", d.Payload, err)
 						continue
 					}
+					commitB, err := jsoniter.Marshal(d.Payload)
+					if err != nil {
+						return
+					}
+					commitStr := b64.StdEncoding.EncodeToString(commitB)
 					hashExist := isHashCreated(contentHash)
 					isCreated := isCommitCreated(d.Payload.ID)
 					if !hashExist && !isCreated {
@@ -1810,6 +1815,7 @@ func (j *DSGit) GitEnrichItems(ctx *shared.Ctx, thrN int, items []interface{}, d
 							Timestamp:      fmt.Sprintf("%v", tStamp),
 							EntityID:       d.Payload.ID,
 							SourceEntityID: d.Payload.SHA,
+							Content:        commitStr,
 							Hash:           contentHash,
 						})
 						createdCommits[d.Payload.ID] = true
@@ -1829,6 +1835,7 @@ func (j *DSGit) GitEnrichItems(ctx *shared.Ctx, thrN int, items []interface{}, d
 							Timestamp:      fmt.Sprintf("%v", tStamp),
 							EntityID:       d.Payload.ID,
 							SourceEntityID: d.Payload.SHA,
+							Content:        commitStr,
 							Hash:           contentHash,
 						})
 					}
@@ -2446,7 +2453,7 @@ func (j *DSGit) Sync(ctx *shared.Ctx) (err error) {
 		if err != nil {
 			return err
 		}
-		tm := time.Unix(i, 0)
+		tm := time.Unix(i, 0).UTC()
 		ctx.DateFrom = &tm
 	}
 	if ctx.DateFrom != nil {