Skip to content

Commit 40be7d0

Browse files
committed
ping upload api
1 parent 4dbc883 commit 40be7d0

3 files changed

Lines changed: 17 additions & 30 deletions

File tree

artcoded/src/main/java/tech/artcoded/websitev2/changelogs/CHANGE_LOG_03_GenerateThumbnailIfNotPresentChangeLog.java

Lines changed: 1 addition & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -36,20 +36,7 @@ public void run(MemZaGramRepository repository, IFileUploadService fileUploadSer
3636
String thumbnailId = fileUpload.getThumbnailId();
3737

3838
if (thumbnailId == null || thumbnailId.isBlank()) {
39-
try {
40-
log.info("ping...");
41-
var res = routesApi.pingWithHttpInfo();
42-
if (res.getStatusCode() == 200) {
43-
log.info("pong!");
44-
break;
45-
} else {
46-
log.info("no pong :(");
47-
Thread.sleep(1000);
48-
}
49-
} catch (Exception e) {
50-
log.error("could not reach file service", e);
51-
}
52-
}
39+
5340
var res = routesApi.makeThumbWithHttpInfo(fileUpload.getId());
5441
var data = res.getData();
5542

artcoded/src/main/java/tech/artcoded/websitev2/changelogs/CHANGE_LOG_56_AddThumbForEachUploadWhenApplicable.java

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -30,21 +30,6 @@ public void execute(MongoManagementService mongoManagementService, IFileUploadSe
3030
log.warn("make a dump first");
3131
log.info(mongoManagementService.dump(false).stream().collect(Collectors.joining("\n")));
3232
log.warn("dump generated. ping file service...");
33-
while (true) {
34-
try {
35-
log.info("ping...");
36-
var res = routesApi.pingWithHttpInfo();
37-
if (res.getStatusCode() == 200) {
38-
log.info("pong!");
39-
break;
40-
} else {
41-
log.info("no pong :(");
42-
Thread.sleep(1000);
43-
}
44-
} catch (Exception e) {
45-
log.error("could not reach file service", e);
46-
}
47-
}
4833
for (var upl : fileUploadService.findAll()) {
4934
if (Boolean.TRUE.equals(upl.getThumb()) || StringUtils.isNotBlank(upl.getThumbnailId())) {
5035
log.warn("skip {}", upl);

artcoded/src/main/java/tech/artcoded/websitev2/upload/api/ApiConfig.java

Lines changed: 16 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,8 +55,23 @@ public ApiClient getClient(@Value("${vendors.file-service.basePath}") String bas
5555
@Inject
5656
public UploadRoutesApi uploadRoutesApi(ApiClient apiClient) {
5757
var api = new UploadRoutesApi(apiClient);
58-
58+
while (true) {
59+
try {
60+
log.info("ping file service...");
61+
var res = api.pingWithHttpInfo();
62+
if (res.getStatusCode() == 200) {
63+
log.info("pong!");
64+
break;
65+
} else {
66+
log.info("no pong :( trying again in a sec");
67+
Thread.sleep(1000);
68+
}
69+
} catch (Exception e) {
70+
log.error("could not reach file service", e);
71+
}
72+
}
5973
return api;
74+
6075
}
6176

6277
@Bean

0 commit comments

Comments
 (0)