|
17 | 17 | import org.slf4j.Logger;
|
18 | 18 | import org.slf4j.LoggerFactory;
|
19 | 19 |
|
| 20 | +import com.google.common.collect.Lists; |
20 | 21 | import com.redhat.labs.lodestar.config.JsonMarshaller;
|
21 | 22 | import com.redhat.labs.lodestar.exception.UnexpectedGitLabResponseException;
|
22 | 23 | import com.redhat.labs.lodestar.models.Engagement;
|
@@ -102,7 +103,7 @@ public Project createEngagement(Engagement engagement, String author, String aut
|
102 | 103 | List<File> repoFiles = new ArrayList<>();
|
103 | 104 | repoFiles.add(createEngagmentFile(engagement));
|
104 | 105 |
|
105 |
| - // create user reset file if required |
| 106 | + // create user reset file(s) if required |
106 | 107 | repoFiles.addAll(createUserManagementFiles(engagement));
|
107 | 108 |
|
108 | 109 | // create actions for multiple commit
|
@@ -259,38 +260,18 @@ private File createEngagmentFile(Engagement engagement) {
|
259 | 260 |
|
260 | 261 | private List<File> createUserManagementFiles(Engagement engagement) {
|
261 | 262 |
|
262 |
| - List<File> userResetFiles = new ArrayList<>(); |
263 |
| - |
264 | 263 | if (null == engagement.getEngagementUsers()) {
|
265 |
| - return userResetFiles; |
266 |
| - } |
267 |
| - |
268 |
| - // get all users that requested a reset |
269 |
| - List<EngagementUser> users = engagement.getEngagementUsers().stream().filter(user -> user.isReset()) |
270 |
| - .collect(Collectors.toList()); |
271 |
| - |
272 |
| - // create file for each reset request only if the file doesn't already exist |
273 |
| - for (EngagementUser user : users) { |
274 |
| - |
275 |
| - // create file name |
276 |
| - String fileName = getUserManagementFileName(user.getUuid()); |
277 |
| - |
278 |
| - // see if file exists |
279 |
| - Optional<File> userResetFile = fileService.getFileAllow404(engagement.getProjectId(), fileName); |
280 |
| - |
281 |
| - if (userResetFile.isEmpty()) { |
282 |
| - |
283 |
| - // create file |
284 |
| - String userAsJson = json.toJson(user); |
285 |
| - |
286 |
| - File resetFile = File.builder().content(userAsJson).filePath(fileName).build(); |
287 |
| - userResetFiles.add(resetFile); |
288 |
| - |
289 |
| - } |
290 |
| - |
| 264 | + return Lists.newArrayList(); |
291 | 265 | }
|
292 | 266 |
|
293 |
| - return userResetFiles; |
| 267 | + return engagement.getEngagementUsers().stream().filter(user -> user.isReset()) |
| 268 | + .filter(user -> fileService |
| 269 | + .getFileAllow404(engagement.getProjectId(), getUserManagementFileName(user.getUuid())) |
| 270 | + .isEmpty()) |
| 271 | + .map(user -> { |
| 272 | + return File.builder().content(json.toJson(user)).filePath(getUserManagementFileName(user.getUuid())) |
| 273 | + .build(); |
| 274 | + }).collect(Collectors.toList()); |
294 | 275 |
|
295 | 276 | }
|
296 | 277 |
|
|
0 commit comments