69432: Remove immediatePatch and replace usage with patch

This commit is contained in:
Kristof De Langhe
2020-03-12 16:24:47 +01:00
parent 20f8f913cf
commit c1bd6938a7
4 changed files with 10 additions and 44 deletions

View File

@@ -1455,9 +1455,9 @@
"profile.security.form.label.passwordrepeat": "Retype to confirm", "profile.security.form.label.passwordrepeat": "Retype to confirm",
"profile.security.form.notifications.success.content": "Successfully changed password.", "profile.security.form.notifications.success.content": "Your changes to the password were saved.",
"profile.security.form.notifications.success.title": "Password changed", "profile.security.form.notifications.success.title": "Password saved",
"profile.security.form.notifications.error.title": "Error changing passwords", "profile.security.form.notifications.error.title": "Error changing passwords",

View File

@@ -104,9 +104,8 @@ export class ServerSyncBufferEffects {
map((entry: ObjectCacheEntry) => { map((entry: ObjectCacheEntry) => {
if (isNotEmpty(entry.patches)) { if (isNotEmpty(entry.patches)) {
const flatPatch: Operation[] = [].concat(...entry.patches.map((patch) => patch.operations)); const flatPatch: Operation[] = [].concat(...entry.patches.map((patch) => patch.operations));
const objectPatch = flatPatch.filter((op: Operation) => op.path.startsWith('/metadata')); if (isNotEmpty(flatPatch)) {
if (isNotEmpty(objectPatch)) { this.requestService.configure(new PatchRequest(this.requestService.generateRequestId(), href, flatPatch));
this.requestService.configure(new PatchRequest(this.requestService.generateRequestId(), href, objectPatch));
} }
} }
return new ApplyPatchObjectCacheAction(href); return new ApplyPatchObjectCacheAction(href);

View File

@@ -44,7 +44,7 @@ import {
FindByIDRequest, FindByIDRequest,
FindListOptions, FindListOptions,
FindListRequest, FindListRequest,
GetRequest, PatchRequest GetRequest
} 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,32 +337,6 @@ 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

View File

@@ -116,18 +116,11 @@ export class ProfilePageSecurityFormComponent implements OnInit {
} }
if (passEntered) { if (passEntered) {
const operation = Object.assign({ op: 'replace', path: '/password', value: pass }); const operation = Object.assign({ op: 'replace', path: '/password', value: pass });
this.epersonService.immediatePatch(this.user, [operation]).subscribe((response: RestResponse) => { this.epersonService.patch(this.user.self, [operation]);
if (response.isSuccessful) {
this.notificationsService.success( this.notificationsService.success(
this.translate.instant(this.NOTIFICATIONS_PREFIX + 'success.title'), this.translate.instant(this.NOTIFICATIONS_PREFIX + 'success.title'),
this.translate.instant(this.NOTIFICATIONS_PREFIX + 'success.content') this.translate.instant(this.NOTIFICATIONS_PREFIX + 'success.content')
); );
} else {
this.notificationsService.error(
this.translate.instant(this.NOTIFICATIONS_PREFIX + 'error.title'), (response as ErrorResponse).errorMessage
);
}
});
} }
return passEntered; return passEntered;