Skip to content

Commit 165b301

Browse files
Luch76Luch76
committed
Merge branch 'develop' into feature-2645/feedback-request-add-ability-to-request-feedback-from-external-source
# Conflicts: # server/src/main/java/com/objectcomputing/checkins/services/feedback_answer/FeedbackAnswerServices.java # server/src/main/java/com/objectcomputing/checkins/services/feedback_answer/FeedbackAnswerServicesImpl.java # server/src/main/java/com/objectcomputing/checkins/services/feedback_request/FeedbackRequestServices.java # server/src/main/java/com/objectcomputing/checkins/services/feedback_request/FeedbackRequestServicesImpl.java
2 parents 38a9104 + c7dd3a0 commit 165b301

File tree

16 files changed

+198
-217
lines changed

16 files changed

+198
-217
lines changed

‎server/build.gradle‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ plugins {
77
id "jacoco"
88
}
99

10-
version "0.8.7"
10+
version "0.8.8"
1111
group "com.objectcomputing.checkins"
1212

1313
repositories {

‎server/src/main/java/com/objectcomputing/checkins/services/feedback_answer/FeedbackAnswerServices.java‎

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package com.objectcomputing.checkins.services.feedback_answer;
22

3+
import com.objectcomputing.checkins.services.feedback_request.FeedbackRequest;
34
import io.micronaut.core.annotation.Nullable;
45

56
import java.util.List;
@@ -14,4 +15,6 @@ public interface FeedbackAnswerServices {
1415
FeedbackAnswer getById(UUID id);
1516

1617
List<FeedbackAnswer> findByValues(@Nullable UUID questionId, @Nullable UUID requestId, @Nullable UUID externalRecipientId);
17-
}
18+
19+
boolean getIsPermitted(FeedbackRequest feedbackRequest);
20+
}

‎server/src/main/java/com/objectcomputing/checkins/services/feedback_answer/question_and_answer/QuestionAndAnswerServicesImpl.java‎

Lines changed: 2 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ public QuestionAndAnswerServicesImpl(FeedbackAnswerServices feedbackAnswerServic
4242
@Override
4343
public List<Tuple> getAllQuestionsAndAnswers(UUID requestId) {
4444
FeedbackRequest feedbackRequest = feedbackRequestServices.getById(requestId);
45-
if (!getIsPermitted(feedbackRequest)) {
45+
if (!feedbackAnswerServices.getIsPermitted(feedbackRequest)) {
4646
throw new PermissionException(NOT_AUTHORIZED_MSG);
4747
}
4848
List<TemplateQuestion> templateQuestions = templateQuestionServices.findByFields(feedbackRequest.getTemplateId());
@@ -77,7 +77,7 @@ public Tuple getQuestionAndAnswer(@Nullable UUID requestId, @Nullable UUID quest
7777
TemplateQuestion question = new TemplateQuestion();
7878
FeedbackRequest feedbackRequest = feedbackRequestServices.getById(requestId);
7979

80-
if (!getIsPermitted(feedbackRequest)) {
80+
if (!feedbackAnswerServices.getIsPermitted(feedbackRequest)) {
8181
throw new PermissionException(NOT_AUTHORIZED_MSG);
8282
}
8383

@@ -101,18 +101,4 @@ public Tuple getQuestionAndAnswer(@Nullable UUID requestId, @Nullable UUID quest
101101
}
102102
return new Tuple(question, returnedAnswer);
103103
}
104-
105-
public boolean getIsPermitted(FeedbackRequest feedbackRequest) {
106-
final boolean isAdmin = currentUserServices.isAdmin();
107-
final UUID requestCreatorId = feedbackRequest.getCreatorId();
108-
UUID requesteeId = feedbackRequest.getRequesteeId();
109-
MemberProfile requestee = memberProfileServices.getById(requesteeId);
110-
final UUID currentUserId = currentUserServices.getCurrentUser().getId();
111-
final UUID recipientId = feedbackRequest.getRecipientId();
112-
boolean isRequesteesSupervisor = requesteeId != null ? memberProfileServices.getSupervisorsForId(requesteeId).stream().anyMatch(profile -> currentUserId.equals(profile.getId())) : false;
113-
final UUID requesteePDL = requestee.getPdlId();
114-
115-
return isAdmin || currentUserId.equals(requesteePDL) || isRequesteesSupervisor || requestCreatorId.equals(currentUserId) || recipientId.equals(currentUserId);
116-
}
117-
118104
}

‎server/src/main/java/com/objectcomputing/checkins/services/feedback_request/FeedbackRequestServices.java‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,4 +14,6 @@ public interface FeedbackRequestServices {
1414
FeedbackRequest getById(UUID id);
1515

1616
List<FeedbackRequest> findByValues(UUID creatorId, UUID requesteeId, UUID recipientId, LocalDate oldestDate, UUID reviewPeriodId, UUID templateId, UUID externalRecipientId, List<UUID> requesteeIds);
17+
18+
boolean selfRevieweeIsCurrentUserReviewee(FeedbackRequest request, UUID currentUserId);
1719
}

‎server/src/main/java/com/objectcomputing/checkins/services/feedback_request/FeedbackRequestServicesImpl.java‎

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -418,6 +418,23 @@ private boolean isSupervisor(UUID requesteeId, UUID currentUserId) {
418418
&& memberProfileServices.getSupervisorsForId(requesteeId).stream().anyMatch(profile -> currentUserId.equals(profile.getId()));
419419
}
420420

421+
public boolean selfRevieweeIsCurrentUserReviewee(FeedbackRequest request,
422+
UUID currentUserId) {
423+
// If we are looking at a self-review request, see if there is a review
424+
// request in the same review period that is assigned to the current
425+
// user and the requestee is the same as the self-review request. If
426+
// so, this user is allowed to see the self-review request.
427+
if (request.getRecipientId().equals(request.getRequesteeId())) {
428+
List<FeedbackRequest> other = feedbackReqRepository.findByValues(
429+
null, request.getRecipientId().toString(),
430+
currentUserId.toString(), null,
431+
Util.nullSafeUUIDToString(request.getReviewPeriodId()),
432+
null);
433+
return (other.size() == 1);
434+
}
435+
return false;
436+
}
437+
421438
private boolean createIsPermitted(UUID requesteeId) {
422439
final boolean isAdmin = currentUserServices.isAdmin();
423440
final UUID currentUserId = currentUserServices.getCurrentUser().getId();

‎server/src/main/java/com/objectcomputing/checkins/services/memberprofile/MemberProfileServices.java‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,8 @@
99
public interface MemberProfileServices {
1010
MemberProfile getById(UUID id);
1111

12+
MemberProfile findByWorkEmail(@NotNull String workEmail);
13+
1214
Set<MemberProfile> findByValues(String firstName, String lastName, String title,
1315
UUID pdlId, String workEmail, UUID supervisorId, Boolean terminated);
1416

‎server/src/main/java/com/objectcomputing/checkins/services/memberprofile/MemberProfileServicesImpl.java‎

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
import com.objectcomputing.checkins.services.role.RoleServices;
1414
import com.objectcomputing.checkins.services.team.member.TeamMemberServices;
1515
import io.micronaut.cache.annotation.CacheConfig;
16+
import io.micronaut.cache.annotation.CacheInvalidate;
1617
import io.micronaut.cache.annotation.Cacheable;
1718
import io.micronaut.core.annotation.Nullable;
1819
import jakarta.inject.Named;
@@ -55,6 +56,7 @@ public MemberProfileServicesImpl(MemberProfileRepository memberProfileRepository
5556
}
5657

5758
@Override
59+
@Cacheable
5860
public MemberProfile getById(@NotNull UUID id) {
5961
Optional<MemberProfile> optional = memberProfileRepository.findById(id);
6062
if (optional.isEmpty()) {
@@ -67,6 +69,14 @@ public MemberProfile getById(@NotNull UUID id) {
6769
return memberProfile;
6870
}
6971

72+
@Cacheable
73+
@Override
74+
public MemberProfile findByWorkEmail(@NotNull String workEmail) {
75+
return memberProfileRepository.findByWorkEmail(workEmail).orElseThrow(() ->
76+
new NotFoundException("Member not found")
77+
);
78+
}
79+
7080
@Override
7181
public Set<MemberProfile> findByValues(@Nullable String firstName,
7282
@Nullable String lastName,
@@ -86,6 +96,7 @@ public Set<MemberProfile> findByValues(@Nullable String firstName,
8696
}
8797

8898
@Override
99+
@CacheInvalidate(cacheNames = {"member-cache"})
89100
public MemberProfile saveProfile(MemberProfile memberProfile) {
90101
MemberProfile emailProfile = memberProfileRepository.findByWorkEmail(memberProfile.getWorkEmail()).orElse(null);
91102

@@ -152,6 +163,7 @@ public void emailAssignment(MemberProfile member, boolean isPDL) {
152163
}
153164

154165
@Override
166+
@CacheInvalidate(cacheNames = {"member-cache"})
155167
public boolean deleteProfile(@NotNull UUID id) {
156168
if (!currentUserServices.isAdmin()) {
157169
throw new PermissionException("Requires admin privileges");
@@ -183,6 +195,7 @@ public boolean deleteProfile(@NotNull UUID id) {
183195
}
184196

185197
@Override
198+
@Cacheable(parameters = {"firstName", "lastName"})
186199
public MemberProfile findByName(@NotNull String firstName, @NotNull String lastName) {
187200
List<MemberProfile> searchResult = memberProfileRepository.search(firstName, null, lastName,
188201
null, null, null, null, null, null);
@@ -222,6 +235,7 @@ public List<MemberProfile> getSubordinatesForId(UUID id) {
222235
}
223236

224237
@Override
238+
@CacheInvalidate(cacheNames = {"member-cache"})
225239
public MemberProfile updateProfile(MemberProfile memberProfile) {
226240
return memberProfileRepository.update(memberProfile);
227241
}

‎server/src/main/java/com/objectcomputing/checkins/services/reports/CSVProcessor.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
package com.objectcomputing.checkins.services.reports;
22

3-
import com.objectcomputing.checkins.services.memberprofile.MemberProfileRepository;
43
import com.objectcomputing.checkins.exceptions.BadArgException;
54

5+
import com.objectcomputing.checkins.services.memberprofile.MemberProfileServices;
66
import org.apache.commons.csv.CSVFormat;
77
import org.apache.commons.csv.CSVParser;
88

@@ -18,7 +18,7 @@
1818

1919
abstract class CSVProcessor {
2020

21-
public void load(MemberProfileRepository memberProfileRepository,
21+
public void load(MemberProfileServices memberProfileServices,
2222
ByteBuffer dataSource) throws IOException,
2323
BadArgException {
2424
ByteArrayInputStream stream = new ByteArrayInputStream(dataSource.array());
@@ -30,10 +30,10 @@ public void load(MemberProfileRepository memberProfileRepository,
3030
.setNullString("")
3131
.build()
3232
.parse(input);
33-
loadImpl(memberProfileRepository, csvParser);
33+
loadImpl(memberProfileServices, csvParser);
3434
}
3535

36-
protected abstract void loadImpl(MemberProfileRepository memberProfileRepository, CSVParser csvParser) throws BadArgException;
36+
protected abstract void loadImpl(MemberProfileServices memberProfileServices, CSVParser csvParser) throws BadArgException;
3737

3838
protected LocalDate parseDate(String date) {
3939
List<String> formatStrings = List.of("yyyy", "M/d/yyyy");

‎server/src/main/java/com/objectcomputing/checkins/services/reports/CompensationHistory.java‎

Lines changed: 31 additions & 35 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,10 @@
11
package com.objectcomputing.checkins.services.reports;
22

3+
import com.objectcomputing.checkins.exceptions.NotFoundException;
34
import com.objectcomputing.checkins.services.memberprofile.MemberProfile;
4-
import com.objectcomputing.checkins.services.memberprofile.MemberProfileRepository;
55
import com.objectcomputing.checkins.exceptions.BadArgException;
66

7+
import com.objectcomputing.checkins.services.memberprofile.MemberProfileServices;
78
import io.micronaut.core.annotation.Introspected;
89
import org.apache.commons.csv.CSVParser;
910
import org.apache.commons.csv.CSVRecord;
@@ -12,10 +13,7 @@
1213
import org.slf4j.LoggerFactory;
1314

1415
import java.time.LocalDate;
15-
import java.util.ArrayList;
16-
import java.util.List;
17-
import java.util.UUID;
18-
import java.util.Optional;
16+
import java.util.*;
1917

2018
public class CompensationHistory extends CSVProcessor {
2119

@@ -32,41 +30,39 @@ public record Compensation(
3230
private final List<Compensation> history = new ArrayList<>();
3331

3432
@Override
35-
protected void loadImpl(MemberProfileRepository memberProfileRepository,
33+
protected void loadImpl(MemberProfileServices memberProfileServices,
3634
CSVParser csvParser) throws BadArgException {
37-
history.clear();
38-
for (CSVRecord csvRecord : csvParser) {
39-
try {
40-
String emailAddress = csvRecord.get("emailAddress");
41-
Optional<MemberProfile> memberProfile =
42-
memberProfileRepository.findByWorkEmail(emailAddress);
43-
if (memberProfile.isPresent()) {
44-
String startDate = csvRecord.get("startDate");
45-
LocalDate date = parseDate(startDate);
46-
if (date == null) {
47-
LOG.error("Unable to parse date: {}", startDate);
48-
} else {
49-
String value = csvRecord.get("compensation");
50-
Compensation comp = new Compensation(
51-
memberProfile.get().getId(),
52-
date,
53-
value == null ? null : value.replaceAll("[^\\d\\.,]", ""),
54-
csvRecord.get("totalComp")
55-
);
56-
history.add(comp);
35+
history.clear();
36+
for (CSVRecord csvRecord : csvParser) {
37+
String emailAddress = null;
38+
try {
39+
emailAddress = csvRecord.get("emailAddress");
40+
MemberProfile memberProfile = memberProfileServices.findByWorkEmail(emailAddress);
41+
String startDate = csvRecord.get("startDate");
42+
LocalDate date = parseDate(startDate);
43+
if (date == null) {
44+
LOG.error("Unable to parse date: {}", startDate);
45+
} else {
46+
String value = csvRecord.get("compensation");
47+
Compensation comp = new Compensation(
48+
memberProfile.getId(),
49+
date,
50+
value == null ? null : value.replaceAll("[^\\d\\.,]", ""),
51+
csvRecord.get("totalComp")
52+
);
53+
history.add(comp);
54+
}
55+
} catch (NotFoundException nfe) {
56+
LOG.error("Unable to find a profile for {}", emailAddress);
57+
} catch (IllegalArgumentException ex) {
58+
throw new BadArgException("Unable to parse the compensation history");
5759
}
58-
} else {
59-
LOG.error("Unable to find a profile for {}", emailAddress);
60-
}
61-
} catch(IllegalArgumentException ex) {
62-
throw new BadArgException("Unable to parse the compensation history");
6360
}
64-
}
6561
}
6662

6763
public List<Compensation> getHistory(UUID memberId) {
68-
return history.stream()
69-
.filter(entry -> entry.memberId().equals(memberId))
70-
.toList();
64+
return history.stream()
65+
.filter(entry -> entry.memberId().equals(memberId))
66+
.toList();
7167
}
7268
}

0 commit comments

Comments
 (0)