Skip to content

Commit 750b078

Browse files
committed
add status in matchingService
1 parent a4ecf87 commit 750b078

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

peer-prep/src/matching-service/services/matchingService.js

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -36,14 +36,15 @@ async function findMatch(request) {
3636
checkCancel = setInterval(async() => {
3737
if (isCancelled.has(parseInt(request.id))) {
3838
clearInterval(checkCancel);
39-
resolve({ isMatched: false, collaboratorId: null, request: request });
39+
resolve({status: 'cancel', isMatched: false, collaboratorId: null, request: request });
4040

4141
} else {
4242
const checkMatchedPair = await getCurrentMatchedPair(request.id);
4343

4444
if (checkMatchedPair) {
4545
clearInterval(checkCancel);
4646
resolve({
47+
status: 'success',
4748
isMatched: true,
4849
collaboratorId: String(checkMatchedPair.id1) === String(request.id) ?
4950
parseInt(checkMatchedPair.id2) : parseInt(checkMatchedPair.id1),
@@ -66,10 +67,11 @@ async function findMatch(request) {
6667
if (!isMatched) {
6768
console.log(`Matched pair could not be found for ${request.id}`);
6869

69-
resolve({ isMatched: false, collaboratorId: null, request: request });
70+
resolve({status: 'error', isMatched: false, collaboratorId: null, request: request });
7071

7172
} else if (stored) {
7273
resolve({
74+
status: 'success',
7375
isMatched: true,
7476
collaboratorId: parseInt(collaboratorId),
7577
request: request
@@ -90,14 +92,15 @@ async function findMatch(request) {
9092
await addMatchedPair(matchedPair);
9193

9294
resolve({
95+
status: 'success',
9396
isMatched: true,
9497
collaboratorId: parseInt(collaboratorId),
9598
request: request
9699
});
97100
}
98101
} catch (error) {
99102
console.log('Error finding match: ', error);
100-
throw error;
103+
resolve({ status: 'error', message: error.message, isMatched: false, collaboratorId: null, request: request });
101104

102105
} finally {
103106
availabilityCache.delete(request.id);

0 commit comments

Comments
 (0)