-
Notifications
You must be signed in to change notification settings - Fork 38
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat(components): expose the placeholder service to be ready to be us…
…ed without rule-engine
- Loading branch information
Showing
17 changed files
with
356 additions
and
240 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
171 changes: 5 additions & 166 deletions
171
packages/@o3r/components/src/rules-engine/placeholder.action-handler.ts
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,183 +1,22 @@ | ||
| import { Injectable, Injector, OnDestroy, Optional } from '@angular/core'; | ||
| import { select, Store } from '@ngrx/store'; | ||
| import { Injectable } from '@angular/core'; | ||
| import type { RulesEngineActionHandler } from '@o3r/core'; | ||
| import { | ||
| deletePlaceholderTemplateEntity, | ||
| PlaceholderRequestReply, | ||
| PlaceholderTemplateStore, | ||
| selectPlaceholderRequestEntities, | ||
| selectPlaceholderTemplateEntities, | ||
| setPlaceholderRequestEntityFromUrl, | ||
| setPlaceholderTemplateEntity, | ||
| updatePlaceholderRequestEntity | ||
| } from '@o3r/components'; | ||
| import { DynamicContentService } from '@o3r/dynamic-content'; | ||
| import { LocalizationService } from '@o3r/localization'; | ||
| import { LoggerService } from '@o3r/logger'; | ||
| import { combineLatest, distinctUntilChanged, firstValueFrom, map, of, startWith, Subject, Subscription, withLatestFrom } from 'rxjs'; | ||
| import { ActionUpdatePlaceholderBlock, RULES_ENGINE_PLACEHOLDER_UPDATE_ACTION_TYPE } from './placeholder.interfaces'; | ||
| import { PlaceholderService } from '@o3r/components'; | ||
|
|
||
| /** | ||
| * Service to handle async PlaceholderTemplate actions | ||
| */ | ||
| @Injectable() | ||
| export class PlaceholderRulesEngineActionHandler implements OnDestroy, RulesEngineActionHandler<ActionUpdatePlaceholderBlock> { | ||
|
|
||
| protected subscription = new Subscription(); | ||
|
|
||
| protected placeholdersActions$: Subject<{ placeholderId: string; templateUrl: string; priority: number }[]> = new Subject(); | ||
| export class PlaceholderRulesEngineActionHandler implements RulesEngineActionHandler<ActionUpdatePlaceholderBlock>{ | ||
|
|
||
| /** @inheritdoc */ | ||
| public readonly supportingActions = [RULES_ENGINE_PLACEHOLDER_UPDATE_ACTION_TYPE] as const; | ||
|
|
||
| constructor( | ||
| store: Store<PlaceholderTemplateStore>, | ||
| private readonly logger: LoggerService, | ||
| private readonly injector: Injector, | ||
| @Optional() translateService?: LocalizationService | ||
| ) { | ||
| const lang$ = translateService ? translateService.getTranslateService().onLangChange.pipe( | ||
| map(({ lang }) => lang), | ||
| startWith(translateService.getCurrentLanguage()), | ||
| distinctUntilChanged() | ||
| ) : of(null); | ||
|
|
||
| const filteredActions$ = combineLatest([ | ||
| lang$, | ||
| this.placeholdersActions$.pipe( | ||
| distinctUntilChanged((prev, next) => JSON.stringify(prev) === JSON.stringify(next)) | ||
| ) | ||
| ]).pipe( | ||
| withLatestFrom( | ||
| combineLatest([store.pipe(select(selectPlaceholderTemplateEntities)), store.pipe(select(selectPlaceholderRequestEntities))]) | ||
| ), | ||
| map(([langAndTemplatesUrls, storedPlaceholdersAndRequests]) => { | ||
| const [lang, placeholderActions] = langAndTemplatesUrls; | ||
| const storedPlaceholders = storedPlaceholdersAndRequests[0] || {}; | ||
| const storedPlaceholderRequests = storedPlaceholdersAndRequests[1] || {}; | ||
| const placeholderNewRequests: { rawUrl: string; resolvedUrl: string }[] = []; | ||
| // Stores all raw Urls used from the current engine execution | ||
| const usedUrls: Record<string, boolean> = {}; | ||
| // Get all Urls that needs to be resolved from current rules engine output | ||
| const placeholdersTemplates = placeholderActions.reduce((acc, placeholderAction) => { | ||
| const placeholdersTemplateUrl = { | ||
| rawUrl: placeholderAction.templateUrl, | ||
| priority: placeholderAction.priority | ||
| }; | ||
| if (acc[placeholderAction.placeholderId]) { | ||
| acc[placeholderAction.placeholderId].push(placeholdersTemplateUrl); | ||
| } else { | ||
| acc[placeholderAction.placeholderId] = [placeholdersTemplateUrl]; | ||
| } | ||
| const resolvedUrl = this.resolveUrlWithLang(placeholderAction.templateUrl, lang); | ||
| // Filters duplicates and resolved urls that are already in the store | ||
| if (!usedUrls[placeholderAction.templateUrl] && (!storedPlaceholderRequests[placeholderAction.templateUrl] | ||
| || storedPlaceholderRequests[placeholderAction.templateUrl]!.resolvedUrl !== resolvedUrl)) { | ||
| placeholderNewRequests.push({ | ||
| rawUrl: placeholderAction.templateUrl, | ||
| resolvedUrl: this.resolveUrlWithLang(placeholderAction.templateUrl, lang) | ||
| }); | ||
| } | ||
| usedUrls[placeholderAction.templateUrl] = true; | ||
| return acc; | ||
| }, {} as { [key: string]: { rawUrl: string; priority: number }[] }); | ||
| // Urls not used anymore and not already disabled | ||
| const placeholderRequestsToDisable: string[] = []; | ||
| // Urls used that were disabled | ||
| const placeholderRequestsToEnable: string[] = []; | ||
| Object.keys(storedPlaceholderRequests).forEach((storedPlaceholderRequestRawUrl) => { | ||
| const usedFromEngineIteration = usedUrls[storedPlaceholderRequestRawUrl]; | ||
| const usedFromStore = (storedPlaceholderRequests && storedPlaceholderRequests[storedPlaceholderRequestRawUrl]) ? storedPlaceholderRequests[storedPlaceholderRequestRawUrl]!.used : false; | ||
| if (!usedFromEngineIteration && usedFromStore) { | ||
| placeholderRequestsToDisable.push(storedPlaceholderRequestRawUrl); | ||
| } else if (usedFromEngineIteration && !usedFromStore) { | ||
| placeholderRequestsToEnable.push(storedPlaceholderRequestRawUrl); | ||
| } | ||
| }); | ||
| // Placeholder that are no longer filled by the current engine execution output will be cleared | ||
| const placeholdersTemplatesToBeCleanedUp = Object.keys(storedPlaceholders) | ||
| .filter(placeholderId => !placeholdersTemplates[placeholderId]); | ||
|
|
||
| const placeholdersTemplatesToBeSet = Object.keys(placeholdersTemplates).reduce((changedPlaceholderTemplates, placeholderTemplateId) => { | ||
| // Caching if the placeholder template already exists with the same urls | ||
| if (!storedPlaceholders[placeholderTemplateId] || | ||
| !(JSON.stringify(storedPlaceholders[placeholderTemplateId]!.urlsWithPriority) === JSON.stringify(placeholdersTemplates[placeholderTemplateId]))) { | ||
| changedPlaceholderTemplates.push({ | ||
| id: placeholderTemplateId, | ||
| urlsWithPriority: placeholdersTemplates[placeholderTemplateId] | ||
| }); | ||
| } | ||
| return changedPlaceholderTemplates; | ||
| }, [] as { id: string; urlsWithPriority: { rawUrl: string; priority: number }[] }[]); | ||
| return { | ||
| placeholdersTemplatesToBeCleanedUp, | ||
| placeholderRequestsToDisable, | ||
| placeholderRequestsToEnable, | ||
| placeholdersTemplatesToBeSet, | ||
| placeholderNewRequests | ||
| }; | ||
| }) | ||
| ); | ||
| this.subscription.add(filteredActions$.subscribe((placeholdersUpdates) => { | ||
| placeholdersUpdates.placeholdersTemplatesToBeCleanedUp.forEach(placeholderId => | ||
| store.dispatch(deletePlaceholderTemplateEntity({ | ||
| id: placeholderId | ||
| })) | ||
| ); | ||
| placeholdersUpdates.placeholdersTemplatesToBeSet.forEach(placeholdersTemplateToBeSet => { | ||
| store.dispatch(setPlaceholderTemplateEntity({ entity: placeholdersTemplateToBeSet })); | ||
| }); | ||
| placeholdersUpdates.placeholderRequestsToDisable.forEach(placeholderRequestToDisable => { | ||
| store.dispatch(updatePlaceholderRequestEntity({ entity: { id: placeholderRequestToDisable, used: false } })); | ||
| }); | ||
| placeholdersUpdates.placeholderRequestsToEnable.forEach(placeholderRequestToEnable => { | ||
| store.dispatch(updatePlaceholderRequestEntity({ entity: { id: placeholderRequestToEnable, used: true } })); | ||
| }); | ||
| placeholdersUpdates.placeholderNewRequests.forEach(placeholderNewRequest => { | ||
| store.dispatch(setPlaceholderRequestEntityFromUrl({ | ||
| resolvedUrl: placeholderNewRequest.resolvedUrl, | ||
| id: placeholderNewRequest.rawUrl, | ||
| call: this.retrieveTemplate(placeholderNewRequest.resolvedUrl) | ||
| })); | ||
| }); | ||
| })); | ||
| } | ||
|
|
||
| /** | ||
| * Localize the url, replacing the language marker | ||
| * @param url | ||
| * @param language | ||
| */ | ||
| protected resolveUrlWithLang(url: string, language: string | null): string { | ||
| if (!language && url.includes('[LANGUAGE]')) { | ||
| this.logger.warn(`Missing language when trying to resolve ${url}`); | ||
| } | ||
| return language ? url.replace(/\[LANGUAGE]/g, language) : url; | ||
| } | ||
|
|
||
| /** | ||
| * Retrieve template as json from a given url | ||
| * @param url | ||
| */ | ||
| protected async retrieveTemplate(url: string): Promise<PlaceholderRequestReply> { | ||
| const resolvedUrl$ = this.injector.get(DynamicContentService, null, { optional: true })?.getContentPathStream(url) || of(url); | ||
| const fullUrl = await firstValueFrom(resolvedUrl$); | ||
| return fetch(fullUrl).then((response) => response.json()); | ||
| constructor(private readonly placeholderService: PlaceholderService) { | ||
| } | ||
|
|
||
| /** @inheritdoc */ | ||
| public executeActions(actions: ActionUpdatePlaceholderBlock[]) { | ||
| const templates = actions.map((action) => ({ | ||
| placeholderId: action.placeholderId, | ||
| templateUrl: action.value, | ||
| priority: action.priority || 0 | ||
| })); | ||
|
|
||
| this.placeholdersActions$.next(templates); | ||
| } | ||
|
|
||
| /** @inheritdoc */ | ||
| public ngOnDestroy(): void { | ||
| this.subscription.unsubscribe(); | ||
| this.placeholderService.updatePlaceholderTemplateUrls(actions); | ||
| } | ||
| } |
7 changes: 2 additions & 5 deletions
7
packages/@o3r/components/src/rules-engine/placeholder.interfaces.ts
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,14 +1,11 @@ | ||
| import type { RulesEngineAction } from '@o3r/core'; | ||
| import type { PlaceholderUrlUpdate } from '@o3r/components'; | ||
|
|
||
| /** ActionUpdatePlaceholderBlock */ | ||
| export const RULES_ENGINE_PLACEHOLDER_UPDATE_ACTION_TYPE = 'UPDATE_PLACEHOLDER'; | ||
|
|
||
| /** | ||
| * Content of action that updates a placeholder | ||
| */ | ||
| export interface ActionUpdatePlaceholderBlock extends RulesEngineAction { | ||
| actionType: typeof RULES_ENGINE_PLACEHOLDER_UPDATE_ACTION_TYPE; | ||
| placeholderId: string; | ||
| value: string; | ||
| priority?: number; | ||
| export interface ActionUpdatePlaceholderBlock extends RulesEngineAction<typeof RULES_ENGINE_PLACEHOLDER_UPDATE_ACTION_TYPE, string>, PlaceholderUrlUpdate { | ||
| } |
Oops, something went wrong.