increased responseMsToLive from 0 to 10s, to prevent infinite loops

This commit is contained in:
Art Lowel
2019-10-07 15:35:19 +02:00
parent 4836fd9ec8
commit 254b7d1633
9 changed files with 11 additions and 11 deletions

View File

@@ -45,7 +45,7 @@ export class AuthRequestService {
distinctUntilChanged(),
map((endpointURL: string) => new AuthPostRequest(this.requestService.generateRequestId(), endpointURL, body, options)),
map ((request: PostRequest) => {
request.responseMsToLive = 0;
request.responseMsToLive = 10 * 1000;
return request;
}),
tap((request: PostRequest) => this.requestService.configure(request)),
@@ -60,7 +60,7 @@ export class AuthRequestService {
distinctUntilChanged(),
map((endpointURL: string) => new AuthGetRequest(this.requestService.generateRequestId(), endpointURL, options)),
map ((request: GetRequest) => {
request.responseMsToLive = 0;
request.responseMsToLive = 10 * 1000;
return request;
}),
tap((request: GetRequest) => this.requestService.configure(request)),

View File

@@ -205,7 +205,7 @@ export abstract class DataService<T extends CacheableObject> {
first((href: string) => hasValue(href)))
.subscribe((href: string) => {
const request = new FindAllRequest(this.requestService.generateRequestId(), href, options);
request.responseMsToLive = 0;
request.responseMsToLive = 10 * 1000;
this.requestService.configure(request);
});

View File

@@ -22,7 +22,7 @@ import { TaskResponseParsingService } from '../tasks/task-response-parsing.servi
/* tslint:disable:max-classes-per-file */
export abstract class RestRequest {
public responseMsToLive = 0;
public responseMsToLive = 10 * 1000;
constructor(
public uuid: string,
public href: string,
@@ -392,7 +392,7 @@ export class TaskDeleteRequest extends DeleteRequest {
}
export class MyDSpaceRequest extends GetRequest {
public responseMsToLive = 0;
public responseMsToLive = 10 * 1000;
}
export class RequestError extends Error {

View File

@@ -60,7 +60,7 @@ describe('SubmissionRestService test suite', () => {
it('should configure a new SubmissionRequest', () => {
const expected = new SubmissionRequest(requestService.generateRequestId(), resourceHref);
// set cache time to zero
expected.responseMsToLive = 0;
expected.responseMsToLive = 10 * 1000;
scheduler.schedule(() => service.getDataById(resourceEndpoint, resourceScope).subscribe());
scheduler.flush();

View File

@@ -110,7 +110,7 @@ export class SubmissionRestService {
distinctUntilChanged(),
map((endpointURL: string) => new SubmissionRequest(requestId, endpointURL)),
map ((request: RestRequest) => {
request.responseMsToLive = 0;
request.responseMsToLive = 10 * 1000;
return request;
}),
tap((request: RestRequest) => this.requestService.configure(request)),

View File

@@ -20,7 +20,7 @@ import { DSOChangeAnalyzer } from '../data/dso-change-analyzer.service';
@Injectable()
export class WorkflowItemDataService extends DataService<WorkflowItem> {
protected linkPath = 'workflowitems';
protected responseMsToLive = 0;
protected responseMsToLive = 10 * 1000;
constructor(
protected comparator: DSOChangeAnalyzer<WorkflowItem>,

View File

@@ -20,7 +20,7 @@ import { WorkspaceItem } from './models/workspaceitem.model';
@Injectable()
export class WorkspaceitemDataService extends DataService<WorkspaceItem> {
protected linkPath = 'workspaceitems';
protected responseMsToLive = 0;
protected responseMsToLive = 10 * 1000;
constructor(
protected comparator: DSOChangeAnalyzer<WorkspaceItem>,

View File

@@ -22,7 +22,7 @@ import { ProcessTaskResponse } from './models/process-task-response';
@Injectable()
export class ClaimedTaskDataService extends TasksService<ClaimedTask> {
protected responseMsToLive = 0;
protected responseMsToLive = 10 * 1000;
/**
* The endpoint link name

View File

@@ -27,7 +27,7 @@ export class PoolTaskDataService extends TasksService<PoolTask> {
*/
protected linkPath = 'pooltasks';
protected responseMsToLive = 0;
protected responseMsToLive = 10 * 1000;
/**
* Initialize instance variables