Skip to content

Commit d7add7e

Browse files
committed
make save return optional as well incase save is failed
1 parent e50a942 commit d7add7e

File tree

2 files changed

+13
-12
lines changed

2 files changed

+13
-12
lines changed

src/main/java/com/wego/httpcache/services/CachedResponseService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
import java.util.Optional;
55

66
public interface CachedResponseService {
7-
CachedResponse save(CachedResponse response, long ttl);
7+
Optional<CachedResponse> save(CachedResponse response, long ttl);
88

99
Optional<CachedResponse> findById(String id);
1010
}

src/main/java/com/wego/httpcache/services/impl/CachedResponseServiceImpl.java

Lines changed: 12 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -18,21 +18,22 @@ public class CachedResponseServiceImpl implements CachedResponseService {
1818

1919
@Inject private CachedResponseEntityToCachedResponse cachedResponseEntityToCachedResponse;
2020

21-
@Inject private CachedResponseToCachedResponseEntity responseToHttpReponseEntity;
21+
@Inject private CachedResponseToCachedResponseEntity cachedResponseToCachedResponseEntity;
2222

2323
@Override
24-
public CachedResponse save(CachedResponse cachedResponse, long ttl) {
25-
if (cachedResponse == null) {
26-
return null;
24+
public Optional<CachedResponse> save(CachedResponse cachedResponse, long ttl) {
25+
CachedResponse savedCachedResponse = null;
26+
27+
if (cachedResponse != null) {
28+
try {
29+
cachedResponseDao.save(cachedResponseToCachedResponseEntity.transform(cachedResponse), ttl);
30+
savedCachedResponse = cachedResponse;
31+
} catch (IOException e) {
32+
LOGGER.error("Error saving cachedResponse with id {}", cachedResponse.getId(), e);
33+
}
2734
}
2835

29-
try {
30-
cachedResponseDao.save(responseToHttpReponseEntity.transform(cachedResponse), ttl);
31-
} catch (IOException e) {
32-
LOGGER.error("Error saving cachedResponse with id {}", cachedResponse.getId(), e);
33-
}
34-
35-
return cachedResponse;
36+
return Optional.ofNullable(savedCachedResponse);
3637
}
3738

3839
@Override

0 commit comments

Comments
 (0)