69432: Immediate patch

This commit is contained in:
Kristof De Langhe
2020-03-11 12:38:32 +01:00
parent 004297fcfa
commit 1f1846c487

View File

@@ -44,7 +44,7 @@ import {
FindByIDRequest, FindByIDRequest,
FindListOptions, FindListOptions,
FindListRequest, FindListRequest,
GetRequest GetRequest, PatchRequest
} from './request.models'; } from './request.models';
import { RequestEntry } from './request.reducer'; import { RequestEntry } from './request.reducer';
import { RequestService } from './request.service'; import { RequestService } from './request.service';
@@ -337,6 +337,32 @@ export abstract class DataService<T extends CacheableObject> {
this.objectCache.addPatch(href, operations); this.objectCache.addPatch(href, operations);
} }
/**
* Send out an immediate patch request, instead of adding to the object cache first
* This is useful in cases where you need the returned response and an object cache update is not needed
* @param dso The dso to send the patch to
* @param operations The patch operations
*/
immediatePatch(dso: T, operations: Operation[]): Observable<RestResponse> {
const requestId = this.requestService.generateRequestId();
const hrefObs = this.halService.getEndpoint(this.linkPath).pipe(
map((endpoint: string) => this.getIDHref(endpoint, dso.uuid)));
hrefObs.pipe(
find((href: string) => hasValue(href)),
map((href: string) => {
const request = new PatchRequest(requestId, href, operations);
this.requestService.configure(request);
})
).subscribe();
return this.requestService.getByUUID(requestId).pipe(
find((request: RequestEntry) => request.completed),
map((request: RequestEntry) => request.response)
);
}
/** /**
* Add a new patch to the object cache * Add a new patch to the object cache
* The patch is derived from the differences between the given object and its version in the object cache * The patch is derived from the differences between the given object and its version in the object cache