161sh/CatgirlIntelligenceAgency
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

(assistant) Make assistant client more robust to the service going down

Browse Source 
This is especially important for the non-essential functions, like website similarities...
This commit is contained in:
Viktor Lofgren 2024-01-13 18:29:30 +01:00
parent 4c62065e74
commit 5134044530
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
code/api/assistant-api/src/main/java/nu/marginalia/assistant/client/AssistantClient.java
View File

@ -65,7 +65,8 @@ public class AssistantClient extends AbstractDynamicClient {
public Observable<ArrayList<SimilarDomain>> similarDomains(Context ctx, int domainId, int count) {
try {
return super.get(ctx, 0, STR."/domain/\{domainId}/similar?count=\{count}", new TypeToken<ArrayList<SimilarDomain>>() {});
return super.get(ctx, 0, STR."/domain/\{domainId}/similar?count=\{count}", new TypeToken<ArrayList<SimilarDomain>>() {})
.onErrorResumeWith(Observable.just(new ArrayList<>()));
}
catch (RouteNotConfiguredException ex) {
return Observable.empty();
@ -74,7 +75,8 @@ public class AssistantClient extends AbstractDynamicClient {
public Observable<ArrayList<SimilarDomain>> linkedDomains(Context ctx, int domainId, int count) {
try {
return super.get(ctx, 0, STR."/domain/\{domainId}/linking?count=\{count}", new TypeToken<ArrayList<SimilarDomain>>() {});
return super.get(ctx, 0, STR."/domain/\{domainId}/linking?count=\{count}", new TypeToken<ArrayList<SimilarDomain>>() {})
.onErrorResumeWith(Observable.just(new ArrayList<>()));
}
catch (RouteNotConfiguredException ex) {
return Observable.empty();
@ -83,7 +85,8 @@ public class AssistantClient extends AbstractDynamicClient {
public Observable<DomainInformation> domainInformation(Context ctx, int domainId) {
try {
return super.get(ctx, 0, STR."/domain/\{domainId}/info", DomainInformation.class);
return super.get(ctx, 0, STR."/domain/\{domainId}/info", DomainInformation.class)
.onErrorResumeWith(Observable.just(new DomainInformation()));
}
catch (RouteNotConfiguredException ex) {
return Observable.empty();