games/Factorio-FBSR
1
0
Fork 0
mirror of https://github.com/demodude4u/Factorio-FBSR.git synced 2024-11-24 08:12:21 +02:00
Code Issues Releases Activity

Resolved #96

Browse Source
This commit is contained in:
Weston Rye (Demod) 2017-07-04 23:55:14 -04:00
parent b504d5ef39
commit c812d8056f
2 changed files with 20 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
FactorioBlueprintStringRenderer/src/com/demod/fbsr/app/BlueprintBotRedditService.java
View File

@ -115,14 +115,16 @@ public class BlueprintBotRedditService extends AbstractScheduledService {
if (CACHE_FILE.exists()) {
try (FileInputStream fis = new FileInputStream(CACHE_FILE)) {
return Utils.readJsonFromStream(fis);
} catch (Exception e) {
// No worries if anything went wrong with the file.
}
} else {
JSONObject cache = new JSONObject();
cache.put("lastProcessedSubmissionMillis", 0L);
cache.put("lastProcessedCommentMillis", 0L);
cache.put("lastProcessedMessageMillis", 0L);
return cache;
}
JSONObject cache = new JSONObject();
cache.put("lastProcessedSubmissionMillis", 0L);
cache.put("lastProcessedCommentMillis", 0L);
cache.put("lastProcessedMessageMillis", 0L);
return cache;
}
private String getPermaLink(Comment comment) {
@ -425,6 +427,11 @@ public class BlueprintBotRedditService extends AbstractScheduledService {
@Override
protected void runOneIteration() throws Exception {
Optional<WatchdogService> watchdogOpt = ServiceFinder.findService(WatchdogService.class);
watchdogOpt.ifPresent(watchdog -> {
watchdog.notifyKnown("Reddit Bot");
});
try {
JSONObject cacheJson = getOrCreateCache();
boolean cacheUpdated = false;
@ -440,7 +447,7 @@ public class BlueprintBotRedditService extends AbstractScheduledService {
saveCache(cacheJson);
}
ServiceFinder.findService(WatchdogService.class).ifPresent(watchdog -> {
watchdogOpt.ifPresent(watchdog -> {
watchdog.notifyActive("Reddit Bot");
});
} catch (NetworkException e) {

6
FactorioBlueprintStringRenderer/src/com/demod/fbsr/app/WatchdogService.java
View File

@ -29,6 +29,12 @@ public class WatchdogService extends AbstractScheduledService {
}
}
public synchronized void notifyKnown(String label) {
if (known.add(label)) {
active.add(label);
}
}
@Override
protected synchronized void runOneIteration() throws Exception {
for (String label : known) {