Fixes 5034: update latest snapshot after uploading content (#902)

Fixes 5034: trigger update-latest-snapshot after uploading content
content-services · Nov 22, 2024 · 7a63415 · 7a63415
1 parent d8a6297
commit 7a63415
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/pkg/handler/repositories.go b/pkg/handler/repositories.go
@@ -881,6 +881,7 @@ func (rh *RepositoryHandler) enqueueAddUploadsEvent(c echo.Context, response api
 		if err := rh.DaoRegistry.RepositoryConfig.UpdateLastSnapshotTask(c.Request().Context(), taskID.String(), response.OrgID, response.RepositoryUUID); err != nil {
 			logger.Error().Err(err).Msgf("error UpdatingLastSnapshotTask task for AddUploads")
 		}
+		rh.enqueueUpdateLatestSnapshotEvent(c, response.OrgID, taskID, response)
 	}
 
 	return taskID.String()

diff --git a/pkg/handler/repositories_test.go b/pkg/handler/repositories_test.go
@@ -176,6 +176,15 @@ func mockTaskClientEnqueueAddUploads(repoSuite *ReposSuite, repo api.RepositoryR
 		repo.OrgID,
 		repo.RepositoryUUID,
 	).Return(nil)
+	repo.LastSnapshotTaskUUID = "00000000-0000-0000-0000-000000000000"
+	repoSuite.tcMock.On("Enqueue", queue.Task{
+		Typename:     config.UpdateLatestSnapshotTask,
+		Payload:      tasks.UpdateLatestSnapshotPayload{RepositoryConfigUUID: repo.UUID},
+		Dependencies: []uuid.UUID{dao.UuidifyString(repo.LastSnapshotTaskUUID)},
+		ObjectUUID:   &repo.RepositoryUUID,
+		ObjectType:   utils.Ptr(config.ObjectTypeRepository),
+		OrgId:        repo.OrgID,
+	}).Return(nil, nil)
 }
 
 func mockSnapshotDeleteEvent(tcMock *client.MockTaskClient, repoConfigUUID string) {