*/
private const VALID_STATUS_FLASHES = array(
'saved',
'error',
'forbidden',
'invalid_nonce',
'amazon_resync_queued',
'amazon_resync_none',
'amazon_resync_error',
'external_affiliate_imported',
'external_affiliate_import_none',
'external_affiliate_import_error',
'external_affiliate_notice_hidden',
);
/**
* Registry key under which the slice 8c-1
* {@see AdminMenuRegistrar} is bound.
*/
public const BINDING_ADMIN_MENU_REGISTRAR = 'affilun.admin.menu_registrar';
/**
* Registry key under which the slice 8c-2
* {@see SettingsPageRenderer} is bound.
*/
public const BINDING_SETTINGS_RENDERER = 'affilun.admin.settings_renderer';
/**
* Registry key under which the slice 8c-3
* {@see SaveSettingsHandler} is bound.
*/
public const BINDING_SAVE_SETTINGS_HANDLER = 'affilun.admin.save_settings_handler';
/**
* Registry key under which the slice 8c-2
* {@see SettingsFormParser} is bound.
*/
public const BINDING_SETTINGS_FORM_PARSER = 'affilun.admin.settings_form_parser';
/**
* Registry key under which the slice 8d
* {@see ProductsListPageRenderer} is bound.
*/
public const BINDING_PRODUCTS_LIST_PAGE_RENDERER = 'affilun.admin.products_list_page_renderer';
/**
* Saved-product CSV export action.
*/
private const CSV_EXPORT_ACTION = 'affilun_export_products_csv';
/**
* Saved-product CSV export nonce field.
*/
private const CSV_EXPORT_NONCE_FIELD = '_affilun_export_products_csv_nonce';
/**
* Saved-product CSV import action.
*/
private const CSV_IMPORT_ACTION = 'affilun_import_products_csv';
/**
* Saved-product CSV import nonce field.
*/
private const CSV_IMPORT_NONCE_FIELD = '_affilun_import_products_csv_nonce';
/**
* Registry key under which the slice 8d
* {@see ProductsListQueryParser} is bound.
*/
public const BINDING_PRODUCTS_LIST_QUERY_PARSER = 'affilun.admin.products_list_query_parser';
/**
* Registry key under which the Phase 11 slice 11f
* {@see DiagnosticsPageRenderer} is bound.
*/
public const BINDING_DIAGNOSTICS_PAGE_RENDERER = 'affilun.admin.diagnostics_page_renderer';
/**
* Registry key under which the Phase 11 slice 11f
* {@see LogsPageRenderer} is bound.
*/
public const BINDING_LOGS_PAGE_RENDERER = 'affilun.admin.logs_page_renderer';
/**
* Registry key under which the Phase 11 slice 11f
* {@see SyncJobsPageRenderer} is bound.
*/
public const BINDING_SYNC_JOBS_PAGE_RENDERER = 'affilun.admin.sync_jobs_page_renderer';
/**
* Registry key under which the Phase 4 migration / growth
* {@see MigrationPageRenderer} is bound.
*/
public const BINDING_MIGRATION_PAGE_RENDERER = 'affilun.admin.migration_page_renderer';
/**
* Registry key under which the Phase 3 click analytics
* {@see ClicksDashboardPageRenderer} is bound.
*/
public const BINDING_CLICKS_DASHBOARD_RENDERER = 'affilun.admin.clicks_dashboard_renderer';
/**
* Registry key under which the Phase 13 Cloud tools
* {@see CloudToolsPageRenderer} is bound.
*/
public const BINDING_CLOUD_TOOLS_RENDERER = 'affilun.admin.cloud_tools_renderer';
/**
* Registry key under which the Phase 2 KI-006 follow-up
* {@see AuditPageRenderer} is bound.
*/
public const BINDING_AUDIT_PAGE_RENDERER = 'affilun.admin.audit_page_renderer';
/**
* Registry key under which the strict-review fix #5 (KI-014)
* {@see AddNewProductPageRenderer} is bound.
*/
public const BINDING_ADD_NEW_PAGE_RENDERER = 'affilun.admin.add_new_page_renderer';
/**
* Slice 8c-1 admin-menu registrar override.
*/
private ?AdminMenuRegistrar $menuRegistrarOverride;
/**
* Slice 8c-2 settings-page renderer override.
*/
private ?SettingsPageRenderer $rendererOverride;
/**
* Slice 8c-3 save-settings handler override.
*/
private ?SaveSettingsHandler $saveHandlerOverride;
/**
* Slice 8d products-list-page renderer override.
*/
private ?ProductsListPageRenderer $productsListRendererOverride;
/**
* Slice 8d products-list-page query parser override.
*/
private ?ProductsListQueryParser $productsListQueryParserOverride;
/**
* Phase 11 slice 11f diagnostics-page renderer override.
*/
private ?DiagnosticsPageRenderer $diagnosticsRendererOverride;
/**
* Phase 11 slice 11f logs-page renderer override.
*/
private ?LogsPageRenderer $logsRendererOverride;
/**
* Phase 11 slice 11f sync-jobs-page renderer override.
*/
private ?SyncJobsPageRenderer $syncJobsRendererOverride;
/**
* Phase 4 migration / growth renderer override.
*/
private ?MigrationPageRenderer $migrationRendererOverride;
/**
* Phase 3 click analytics renderer override.
*/
private ?ClicksDashboardPageRenderer $clicksDashboardRendererOverride;
/**
* Phase 2 KI-006 follow-up audit-page renderer override.
*/
private ?AuditPageRenderer $auditRendererOverride;
/**
* Strict-review fix #5 (KI-014) Add New page renderer override.
*/
private ?AddNewProductPageRenderer $addNewRendererOverride;
/**
* Cached {@see AdminMenuRegistrar} bound into the registry.
*/
private ?AdminMenuRegistrar $resolvedMenuRegistrar = null;
/**
* Cached settings repository used by admin-post feature gates.
*/
private ?OptionStoreSettingsRepository $resolvedSettingsRepository = null;
/**
* Cached option store used by settings-page admin-post handlers.
*/
private ?OptionStore $resolvedOptionStore = null;
/**
* Cached {@see SettingsPageRenderer} bound into the registry.
*/
private ?SettingsPageRenderer $resolvedRenderer = null;
/**
* Cached importer for detected existing affiliate-link data.
*/
private ?ExternalAffiliateProductImportUseCase $resolvedExternalAffiliateImporter = null;
/**
* Cached {@see SaveSettingsHandler} bound into the registry.
*/
private ?SaveSettingsHandler $resolvedSaveHandler = null;
/**
* Cached {@see ProductsListPageRenderer} bound into the
* registry.
*/
private ?ProductsListPageRenderer $resolvedProductsListRenderer = null;
/**
* Cached {@see ProductsListQueryParser} bound into the
* registry.
*/
private ?ProductsListQueryParser $resolvedProductsListQueryParser = null;
/**
* Cached {@see DiagnosticsPageRenderer} bound into the registry.
*/
private ?DiagnosticsPageRenderer $resolvedDiagnosticsRenderer = null;
/**
* Cached {@see LogsPageRenderer} bound into the registry.
*/
private ?LogsPageRenderer $resolvedLogsRenderer = null;
/**
* Cached {@see SyncJobsPageRenderer} bound into the registry.
*/
private ?SyncJobsPageRenderer $resolvedSyncJobsRenderer = null;
/**
* Cached {@see MigrationPageRenderer} bound into the registry.
*/
private ?MigrationPageRenderer $resolvedMigrationRenderer = null;
/**
* Cached {@see ClicksDashboardPageRenderer} bound into the registry.
*/
private ?ClicksDashboardPageRenderer $resolvedClicksDashboardRenderer = null;
/**
* Cached {@see CloudToolsPageRenderer} bound into the registry.
*/
private ?CloudToolsPageRenderer $resolvedCloudToolsRenderer = null;
/**
* Cached Cloud AI post scan runner.
*/
private ?CloudAiPostScanRunner $resolvedCloudAiPostScanRunner = null;
/**
* Cached {@see AuditPageRenderer} bound into the registry.
*/
private ?AuditPageRenderer $resolvedAuditRenderer = null;
/**
* Cached {@see AddNewProductPageRenderer} bound into the
* registry (strict-review fix #5, KI-014). Captured by the
* page-render closure for the §7 Add New admin page.
*/
private ?AddNewProductPageRenderer $resolvedAddNewRenderer = null;
/**
* Cached product repository used by product admin-post handlers.
*/
private ?ProductRepository $resolvedProductRepository = null;
/**
* Cached product-meta repository used by product admin-post handlers.
*/
private ?ProductMetaRepository $resolvedProductMetaRepository = null;
/**
* Cached sync-job repository used by the Amazon bulk-resync
* admin-post handler.
*/
private ?SyncJobRepository $resolvedSyncJobRepository = null;
/**
* Cached {@see LogsListQueryParser} (built inline during
* register()) so the page-render closure for the Logs page can
* route `$_GET` through it without re-resolving.
*/
private ?LogsListQueryParser $resolvedLogsListQueryParser = null;
/**
* Cached {@see SyncJobsListQueryParser} (built inline during
* register()) so the page-render closure for the Sync Jobs page
* can route `$_GET` through it without re-resolving.
*/
private ?SyncJobsListQueryParser $resolvedSyncJobsListQueryParser = null;
/**
* Cached {@see AuditListQueryParser} (built inline during
* register()) so the page-render closure for the Audit page
* can route `$_GET` through it without re-resolving.
*/
private ?AuditListQueryParser $resolvedAuditListQueryParser = null;
/**
* Construct an admin service provider with optional
* overrides for each collaborator.
*
* Empty / no-arg construction is the production default;
* tests pass overrides one axis at a time so the provider
* graph can be exercised against synthetic collaborators
* without standing up the persistence stack.
*
* @param AdminMenuRegistrar|null $menuRegistrarOverride Slice 8c-1 admin-menu
* registrar override.
* @param SettingsPageRenderer|null $rendererOverride Slice 8c-2 page renderer override.
* @param SaveSettingsHandler|null $saveHandlerOverride Slice 8c-3 save handler override.
* @param ProductsListPageRenderer|null $productsListRendererOverride Slice 8d products-list
* renderer override.
* @param ProductsListQueryParser|null $productsListQueryParserOverride Slice 8d query parser
* override.
* @param DiagnosticsPageRenderer|null $diagnosticsRendererOverride Phase 11 11f diagnostics
* renderer override.
* @param LogsPageRenderer|null $logsRendererOverride Phase 11 11f logs renderer override.
* @param SyncJobsPageRenderer|null $syncJobsRendererOverride Phase 11 11f sync-jobs
* renderer override.
* @param AuditPageRenderer|null $auditRendererOverride Phase 2 KI-006 follow-up audit
* admin-page renderer override.
* @param AddNewProductPageRenderer|null $addNewRendererOverride Strict-review fix #5 (KI-014)
* Add New admin-page renderer override.
* @param ClicksDashboardPageRenderer|null $clicksDashboardRendererOverride Phase 3 click analytics
* renderer override.
* @param MigrationPageRenderer|null $migrationRendererOverride Phase 4 migration renderer
* override.
*/
public function __construct(
?AdminMenuRegistrar $menuRegistrarOverride = null,
?SettingsPageRenderer $rendererOverride = null,
?SaveSettingsHandler $saveHandlerOverride = null,
?ProductsListPageRenderer $productsListRendererOverride = null,
?ProductsListQueryParser $productsListQueryParserOverride = null,
?DiagnosticsPageRenderer $diagnosticsRendererOverride = null,
?LogsPageRenderer $logsRendererOverride = null,
?SyncJobsPageRenderer $syncJobsRendererOverride = null,
?AuditPageRenderer $auditRendererOverride = null,
?AddNewProductPageRenderer $addNewRendererOverride = null,
?ClicksDashboardPageRenderer $clicksDashboardRendererOverride = null,
?MigrationPageRenderer $migrationRendererOverride = null
) {
$this->menuRegistrarOverride = $menuRegistrarOverride;
$this->rendererOverride = $rendererOverride;
$this->saveHandlerOverride = $saveHandlerOverride;
$this->productsListRendererOverride = $productsListRendererOverride;
$this->productsListQueryParserOverride = $productsListQueryParserOverride;
$this->diagnosticsRendererOverride = $diagnosticsRendererOverride;
$this->logsRendererOverride = $logsRendererOverride;
$this->syncJobsRendererOverride = $syncJobsRendererOverride;
$this->auditRendererOverride = $auditRendererOverride;
$this->addNewRendererOverride = $addNewRendererOverride;
$this->clicksDashboardRendererOverride = $clicksDashboardRendererOverride;
$this->migrationRendererOverride = $migrationRendererOverride;
}
/**
* Bind the slice 8c-1 / 8c-2 / 8c-3 admin collaborators into
* the registry, then append the §13 Settings page
* {@see AdminPageDefinition} to the bound registrar.
*
* Resolution order:
*
* 1. Resolve {@see OptionStore} via
* {@see PersistenceServiceProvider::BINDING_OPTION_STORE}.
* Missing binding raises {@see LogicException}.
*
* 2. Build the §13 repository, the §13.10 save use case,
* and the §13 form parser.
*
* 3. Build (or accept the override of) the §13 page
* renderer and the §13.10 save handler.
*
* 4. Build (or accept the override of) the slice 8c-1
* admin-menu registrar.
*
* 5. Append the §13 Settings page definition to the
* registrar.
*
* 6. Bind all four under the `BINDING_*` keys and cache
* the registrar / renderer / save handler so the boot()
* action callbacks can capture them.
*
* @param ServiceProviderRegistry $registry Registry driving
* this bootstrap pass.
*
* @throws LogicException When the persistence provider has
* not registered before this one.
*/
public function register( ServiceProviderRegistry $registry ): void {
$optionStore = $this->resolveOptionStore( $registry );
$productRepository = $this->resolveProductRepository( $registry );
$productMetaRepository = $this->resolveProductMetaRepository( $registry );
$repository = new OptionStoreSettingsRepository( $optionStore );
$useCase = new SaveSettingsUseCase( $repository );
$parser = new SettingsFormParser();
$affiliateRoutingRepository = new OptionStoreAffiliateRoutingRepository( $optionStore );
$externalAffiliateImporter = new ExternalAffiliateProductImportUseCase(
$productRepository,
new SystemClock(),
self::buildExternalAffiliatePostRowsProvider()
);
$renderer = $this->rendererOverride ?? new SettingsPageRenderer(
$repository,
null,
$affiliateRoutingRepository,
$this->resolveOptionalProductCardViewModelFactory( $registry ),
$this->resolveOptionalProductCardRenderer( $registry ),
$externalAffiliateImporter,
$optionStore
);
$auditWriter = $this->resolveOptionalAuditEventWriter( $registry );
$saveHandler = $this->saveHandlerOverride ?? new SaveSettingsHandler(
$repository,
$useCase,
$parser,
null,
null,
null,
null,
$auditWriter,
null,
$affiliateRoutingRepository,
$this->resolveOptionalRenderCache( $registry )
);
$menuRegistrar = $this->menuRegistrarOverride ?? new AdminMenuRegistrar();
$listUseCase = $this->resolveListProductsUseCase( $registry, $productRepository );
$productTaxonomy = new ProductManualTaxonomy( $productMetaRepository );
$bulkProductsUseCase = new BulkUpdateProductsUseCase( $productRepository, $productTaxonomy );
$productCsvImportUseCase = new ProductCsvImportUseCase( $productRepository, $productTaxonomy );
$addNewRenderer = $this->addNewRendererOverride ?? new AddNewProductPageRenderer();
$productsListRenderer = $this->productsListRendererOverride
?? new ProductsListPageRenderer(
$listUseCase,
new ProductSummaryMapper(),
null,
$bulkProductsUseCase,
$productCsvImportUseCase,
$addNewRenderer,
$repository,
$productRepository,
productMetaRepository: $productMetaRepository,
amazonDiscountCardRenderer: $this->resolveOptionalAmazonDiscountCardRenderer( $registry )
);
$productsListQueryParser = $this->productsListQueryParserOverride
?? new ProductsListQueryParser();
$logRepository = $this->resolveLogRepository( $registry );
$syncJobRepository = $this->resolveSyncJobRepository( $registry );
$schemaVersionRepository = $this->resolveSchemaVersionRepository( $registry );
$logMasker = new LogMasker();
$listLogsUseCase = new ListLogsUseCase( $logRepository, $logMasker );
$getLogsSummaryUseCase = new GetLogsSummaryUseCase( $logRepository, $logMasker );
$listSyncJobsUseCase = new ListSyncJobsUseCase( $syncJobRepository );
// Phase 12 slice 12c: the providers map is resolved from the
// centralized ProviderRegistry binding published by
// ProviderServiceProvider. When the binding is missing —
// typically in tests that pre-seed the admin collaborators
// without standing up the provider service provider — the
// resolver falls back to an empty registry so the admin
// diagnostics page renders an empty `providers` branch
// rather than failing.
$providerRegistry = $this->resolveProviderRegistry( $registry );
$diagnosticsUseCase = new GetDiagnosticsUseCase(
$schemaVersionRepository,
$syncJobRepository,
$providerRegistry->all(),
null,
new SystemClock()
);
$diagnosticsRenderer = $this->diagnosticsRendererOverride
?? new DiagnosticsPageRenderer( $diagnosticsUseCase );
$logsRenderer = $this->logsRendererOverride
?? new LogsPageRenderer( $listLogsUseCase, $getLogsSummaryUseCase );
$syncJobsRenderer = $this->syncJobsRendererOverride
?? new SyncJobsPageRenderer( $listSyncJobsUseCase );
$clicksDashboardRenderer = $this->clicksDashboardRendererOverride
?? new ClicksDashboardPageRenderer(
$optionStore,
$this->resolveOptionalClickEventRepository( $registry ),
$productRepository
);
$migrationRenderer = $this->migrationRendererOverride
?? new MigrationPageRenderer( $optionStore );
$topAffiliateCandidates = $this->resolveOptionalTopAffiliateCandidateRepository( $registry );
$cloudToolsRenderer = new CloudToolsPageRenderer(
$repository,
productRepository: $productRepository,
productMetaRepository: $productMetaRepository,
topAffiliateCandidateRepository: $topAffiliateCandidates,
optionStore: $optionStore
);
$cloudAiPostScanRunner = new CloudAiPostScanRunner(
$repository,
$optionStore,
$providerRegistry,
new SaveProductUseCase( $productRepository, new SystemClock() )
);
$this->resolvedSettingsRepository = $repository;
$this->resolvedOptionStore = $optionStore;
$this->resolvedProductRepository = $productRepository;
$this->resolvedProductMetaRepository = $productMetaRepository;
$this->resolvedExternalAffiliateImporter = $externalAffiliateImporter;
$this->resolvedSyncJobRepository = $syncJobRepository;
$this->resolvedMenuRegistrar = $menuRegistrar;
$this->resolvedRenderer = $renderer;
$this->resolvedSaveHandler = $saveHandler;
$this->resolvedProductsListRenderer = $productsListRenderer;
$this->resolvedProductsListQueryParser = $productsListQueryParser;
$this->resolvedDiagnosticsRenderer = $diagnosticsRenderer;
$this->resolvedLogsRenderer = $logsRenderer;
$this->resolvedSyncJobsRenderer = $syncJobsRenderer;
$this->resolvedClicksDashboardRenderer = $clicksDashboardRenderer;
$this->resolvedMigrationRenderer = $migrationRenderer;
$this->resolvedCloudToolsRenderer = $cloudToolsRenderer;
$this->resolvedCloudAiPostScanRunner = $cloudAiPostScanRunner;
$this->resolvedLogsListQueryParser = new LogsListQueryParser();
$this->resolvedSyncJobsListQueryParser = new SyncJobsListQueryParser();
$this->resolvedAddNewRenderer = $addNewRenderer;
$currentSettings = $repository->load();
$menuRegistrar->add( $this->buildSettingsPageDefinition() );
$menuRegistrar->add( $this->buildProductsListPageDefinition() );
$menuRegistrar->add( $this->buildProductsListSubmenuOverrideDefinition() );
$menuRegistrar->add( $this->buildAddNewProductPageDefinition( true ) );
$menuRegistrar->add( $this->buildMigrationPageDefinition( true ) );
$menuRegistrar->add( $this->buildClicksDashboardPageDefinition() );
if ( $this->shouldShowCloudContractMenus( $currentSettings ) ) {
$menuRegistrar->add( $this->buildCloudToolsPageDefinition() );
}
$menuRegistrar->add( $this->buildDiagnosticsPageDefinition( true ) );
$menuRegistrar->add( $this->buildLogsPageDefinition( true ) );
$menuRegistrar->add( $this->buildSyncJobsPageDefinition( true ) );
$auditRenderer = $this->resolveAuditRenderer( $registry );
if ( $auditRenderer !== null ) {
$this->resolvedAuditRenderer = $auditRenderer;
$this->resolvedAuditListQueryParser = new AuditListQueryParser();
$menuRegistrar->add( $this->buildAuditPageDefinition( true ) );
}
$renderer->configureOperationTools(
$migrationRenderer,
$diagnosticsRenderer,
$logsRenderer,
$syncJobsRenderer,
$auditRenderer,
$this->resolvedLogsListQueryParser,
$this->resolvedSyncJobsListQueryParser,
$this->resolvedAuditListQueryParser
);
$registry->bind( self::BINDING_ADMIN_MENU_REGISTRAR, $menuRegistrar );
$registry->bind( self::BINDING_SETTINGS_RENDERER, $renderer );
$registry->bind( self::BINDING_SAVE_SETTINGS_HANDLER, $saveHandler );
$registry->bind( self::BINDING_SETTINGS_FORM_PARSER, $parser );
$registry->bind( self::BINDING_PRODUCTS_LIST_PAGE_RENDERER, $productsListRenderer );
$registry->bind( self::BINDING_PRODUCTS_LIST_QUERY_PARSER, $productsListQueryParser );
$registry->bind( self::BINDING_DIAGNOSTICS_PAGE_RENDERER, $diagnosticsRenderer );
$registry->bind( self::BINDING_LOGS_PAGE_RENDERER, $logsRenderer );
$registry->bind( self::BINDING_SYNC_JOBS_PAGE_RENDERER, $syncJobsRenderer );
$registry->bind( self::BINDING_CLICKS_DASHBOARD_RENDERER, $clicksDashboardRenderer );
$registry->bind( self::BINDING_MIGRATION_PAGE_RENDERER, $migrationRenderer );
$registry->bind( self::BINDING_CLOUD_TOOLS_RENDERER, $cloudToolsRenderer );
$registry->bind( self::BINDING_ADD_NEW_PAGE_RENDERER, $this->resolvedAddNewRenderer );
if ( $auditRenderer !== null ) {
$registry->bind( self::BINDING_AUDIT_PAGE_RENDERER, $auditRenderer );
}
}
/**
* Whether paid Cloud-only admin menu entries should be visible.
*
* @param PluginSettings $settings Current settings snapshot.
*/
private function shouldShowCloudContractMenus( PluginSettings $settings ): bool {
return $settings->cloud()->isConfigured();
}
/**
* Resolve optional click event repository.
*
* @param ServiceProviderRegistry $registry Registry.
*/
private function resolveOptionalClickEventRepository( ServiceProviderRegistry $registry ): ?ClickEventRepository {
$key = PersistenceServiceProvider::BINDING_CLICK_EVENT_REPOSITORY;
if ( ! $registry->has( $key ) ) {
return null;
}
$repository = $registry->get( $key );
return $repository instanceof ClickEventRepository ? $repository : null;
}
/**
* Resolve optional top affiliate candidate repository.
*
* @param ServiceProviderRegistry $registry Registry.
*/
private function resolveOptionalTopAffiliateCandidateRepository( ServiceProviderRegistry $registry ): ?TopAffiliateCandidateRepository {
$key = PersistenceServiceProvider::BINDING_TOP_AFFILIATE_CANDIDATE_REPOSITORY;
if ( ! $registry->has( $key ) ) {
return null;
}
$repository = $registry->get( $key );
return $repository instanceof TopAffiliateCandidateRepository ? $repository : null;
}
/**
* Resolve the optional Amazon discount shortcode configurator.
*/
private function resolveOptionalAmazonDiscountCardRenderer(
ServiceProviderRegistry $registry
): ?AmazonDiscountShortcodeCardRenderer {
$key = AmazonDiscountServiceProvider::BINDING_ADMIN_CARD_RENDERER;
if ( ! $registry->has( $key ) ) {
return null;
}
$renderer = $registry->get( $key );
return $renderer instanceof AmazonDiscountShortcodeCardRenderer ? $renderer : null;
}
/**
* Resolve the Phase 2 KI-006 follow-up {@see AuditPageRenderer}.
*
* Honours the constructor override first so tests that wire a
* synthetic renderer keep working without binding the
* persistence-layer audit-event repository. When no override
* is supplied, soft-resolves
* {@see PersistenceServiceProvider::BINDING_AUDIT_EVENT_REPOSITORY}
* via the same skip-on-missing pattern as
* {@see self::resolveOptionalAuditEventWriter()}; on miss
* returns null so the audit page wiring is skipped entirely.
*
* @param ServiceProviderRegistry $registry Bootstrap registry.
*/
private function resolveAuditRenderer(
ServiceProviderRegistry $registry
): ?AuditPageRenderer {
if ( $this->auditRendererOverride !== null ) {
return $this->auditRendererOverride;
}
$key = PersistenceServiceProvider::BINDING_AUDIT_EVENT_REPOSITORY;
if ( ! $registry->has( $key ) ) {
return null;
}
$auditEventRepo = $registry->get( $key );
if ( ! $auditEventRepo instanceof AuditEventRepository ) {
return null;
}
$listAuditEventsUseCase = new ListAuditEventsUseCase( $auditEventRepo );
$getAuditEventsSummaryUseCase = new GetAuditEventsSummaryUseCase( $auditEventRepo );
return new AuditPageRenderer( $listAuditEventsUseCase, $getAuditEventsSummaryUseCase );
}
/**
* Subscribe the `admin_menu` and
* `admin_post_affilun_save_settings` action callbacks.
*
* Both callbacks are public methods on this provider (rather
* than closures) so the {@see HookRegistrar}'s introspection
* surface carries stable, named callables that tests and
* diagnostics can identify without unwrapping a closure.
*
* @param HookRegistrar $hooks Shared hook registrar.
*/
public function boot( HookRegistrar $hooks ): void {
$hooks->addAction( 'admin_menu', array( $this, 'onAdminMenu' ) );
$hooks->addAction( 'admin_post_affilun_save_settings', array( $this, 'onSaveSettingsPost' ) );
$hooks->addAction( 'admin_post_affilun_delete_product', array( $this, 'onDeleteProductPost' ) );
$hooks->addAction( 'admin_post_affilun_bulk_products_action', array( $this, 'onBulkProductsActionPost' ) );
$hooks->addAction( 'admin_post_affilun_bulk_update_products', array( $this, 'onBulkUpdateProductsPost' ) );
$hooks->addAction( 'admin_post_affilun_create_article_draft', array( $this, 'onCreateArticleDraftPost' ) );
$hooks->addAction( 'admin_post_affilun_generate_article_draft', array( $this, 'onGenerateArticleDraftPost' ) );
$hooks->addAction( 'admin_post_' . CloudToolsPageRenderer::REVENUE_STATUS_ACTION, array( $this, 'onRevenueOpportunityStatusPost' ) );
$hooks->addAction( 'admin_post_' . CloudToolsPageRenderer::AI_SCAN_ACTION, array( $this, 'onCloudAiPostScanPost' ) );
$hooks->addAction( CloudAiPostScanRunner::CRON_HOOK, array( $this, 'onCloudAiPostScanCron' ) );
$hooks->addAction( 'init', array( $this, 'onCloudAiPostScanRecovery' ) );
$hooks->addAction( 'admin_post_' . self::CSV_EXPORT_ACTION, array( $this, 'onExportProductsCsvPost' ) );
$hooks->addAction( 'admin_post_' . self::CSV_IMPORT_ACTION, array( $this, 'onImportProductsCsvPost' ) );
$hooks->addAction( 'admin_post_affilun_resync_amazon_products', array( $this, 'onAmazonResyncPost' ) );
$hooks->addAction( 'admin_post_' . SettingsPageRenderer::EXTERNAL_AFFILIATE_IMPORT_ACTION, array( $this, 'onImportExternalAffiliateDataPost' ) );
$hooks->addAction( 'admin_post_' . SettingsPageRenderer::EXTERNAL_AFFILIATE_DISMISS_ACTION, array( $this, 'onDismissExternalAffiliateDataPost' ) );
$hooks->addAction( 'admin_notices', array( $this, 'onAdminNotices' ) );
$hooks->addAction( 'admin_enqueue_scripts', array( $this, 'onAdminEnqueueScripts' ) );
}
/**
* Render cross-page affilun admin notices.
*/
public function onAdminNotices(): void {
$this->renderArticleDraftProvenanceNotice();
$this->renderLinkHealthAdminNotice();
}
/**
* Keep fallback provenance visible when editing the saved draft.
*/
private function renderArticleDraftProvenanceNotice(): void {
$post = $GLOBALS['post'] ?? null;
if ( ! $post instanceof \WP_Post ) {
return;
}
if ( ! function_exists( 'get_current_screen' ) || get_current_screen()?->base !== 'post' ) {
return;
}
if ( ! function_exists( 'current_user_can' ) || ! current_user_can( 'edit_post', $post->ID ) ) {
return;
}
if ( ! function_exists( 'get_post_meta' ) || ! function_exists( 'esc_html' ) ) {
return;
}
$source = get_post_meta( $post->ID, '_affilun_article_draft_source', true );
$notice = is_string( $source ) ? ArticleDraftNotice::provenanceMessage( $source ) : null;
if ( $notice !== null ) {
echo '' . esc_html( $notice ) . '
'
. self::articleInlineMarkdownToHtml( $text )
. '
';
$paragraph = array();
};
$flushQuote = static function () use ( &$blocks, &$quote ): void {
if ( $quote === array() ) {
return;
}
$text = implode( ' ', $quote );
$blocks[] = ''
. self::articleInlineMarkdownToHtml( $text )
. '
';
$quote = array();
};
$flushList = static function () use ( &$blocks, &$listItems, &$listType ): void {
if ( $listItems === array() ) {
return;
}
$ordered = $listType === 'ordered';
$html = $ordered
? ''
: '';
foreach ( $listItems as $item ) {
$html .= '- ' . self::articleInlineMarkdownToHtml( $item ) . '
';
}
$html .= $ordered ? '
' : '';
$blocks[] = $html;
$listItems = array();
$listType = null;
};
$flushOpenBlocks = static function () use ( $flushParagraph, $flushList, $flushQuote ): void {
$flushParagraph();
$flushList();
$flushQuote();
};
foreach ( $lines as $line ) {
$line = trim( (string) $line );
if ( $line === '' ) {
$flushOpenBlocks();
continue;
}
if ( preg_match( '/\A(?:[-*_]\s*){3,}\z/u', $line ) === 1 ) {
$flushOpenBlocks();
$blocks[] = '
';
continue;
}
if ( preg_match( '/\A(#{1,6})\s+(.+?)(?:\s+#+)?\z/u', $line, $matches ) === 1 ) {
$flushOpenBlocks();
$level = strlen( (string) $matches[1] );
$level = min( 6, max( 2, $level ) );
$heading = trim( (string) $matches[2] );
$blocks[] = ''
. self::articleInlineMarkdownToHtml( $heading )
. '';
continue;
}
if ( preg_match( '/\A>\s?(.+)\z/u', $line, $matches ) === 1 ) {
$flushParagraph();
$flushList();
$quote[] = trim( (string) $matches[1] );
continue;
}
if ( preg_match( '/\A([-*+])\s+(.+)\z/u', $line, $matches ) === 1 ) {
$flushParagraph();
$flushQuote();
if ( $listType !== null && $listType !== 'unordered' ) {
$flushList();
}
$listType = 'unordered';
$listItems[] = trim( (string) $matches[2] );
continue;
}
if ( preg_match( '/\A\d+[.)]\s+(.+)\z/u', $line, $matches ) === 1 ) {
$flushParagraph();
$flushQuote();
if ( $listType !== null && $listType !== 'ordered' ) {
$flushList();
}
$listType = 'ordered';
$listItems[] = trim( (string) $matches[1] );
continue;
}
$flushList();
$flushQuote();
$paragraph[] = $line;
}
$flushOpenBlocks();
$blocks[] = '';
return implode( "\n\n", $blocks );
}
/**
* Convert a safe inline Markdown subset into HTML.
*
* @param string $text Inline Markdown text.
*/
private static function articleInlineMarkdownToHtml( string $text ): string {
$tokens = array();
$withCode = preg_replace_callback(
'/`([^`\r\n]+)`/u',
static function ( array $matches ) use ( &$tokens ): string {
return self::articleMarkdownToken(
$tokens,
'' . esc_html( (string) $matches[1] ) . ''
);
},
$text
);
if ( is_string( $withCode ) ) {
$text = $withCode;
}
$withLinks = preg_replace_callback(
'/\[([^\]\r\n]+)\]\((https?:\/\/[^\s)]+)\)/iu',
static function ( array $matches ) use ( &$tokens ): string {
$label = trim( (string) $matches[1] );
$url = trim( html_entity_decode( (string) $matches[2], ENT_QUOTES | ENT_HTML5, 'UTF-8' ) );
if ( $label === '' || ! self::articleMarkdownIsHttpUrl( $url ) ) {
return (string) $matches[0];
}
$href = self::articleEscUrl( $url );
if ( $href === '' ) {
return (string) $matches[0];
}
return self::articleMarkdownToken(
$tokens,
''
. esc_html( $label )
. ''
);
},
$text
);
if ( is_string( $withLinks ) ) {
$text = $withLinks;
}
$html = esc_html( $text );
$withStrong = preg_replace( '/\*\*([^*\r\n]+)\*\*/u', '$1', $html );
if ( is_string( $withStrong ) ) {
$html = $withStrong;
}
$withEmphasis = preg_replace( '/(?$1', $html );
if ( is_string( $withEmphasis ) ) {
$html = $withEmphasis;
}
return strtr( $html, $tokens );
}
/**
* Register an already-sanitized inline HTML token.
*
* @param array $tokens Token map by reference.
* @param string $html Sanitized HTML fragment.
*/
private static function articleMarkdownToken( array &$tokens, string $html ): string {
$index = count( $tokens );
$token = '%%AFLUN_ARTICLE_MD_TOKEN_'
. (string) $index . '_'
. substr( hash( 'sha256', $html . ':' . (string) $index ), 0, 12 )
. '%%';
$tokens[ $token ] = $html;
return $token;
}
/**
* Whether a Markdown link URL is a safe absolute http(s) URL.
*
* @param string $url Candidate URL.
*/
private static function articleMarkdownIsHttpUrl( string $url ): bool {
if ( preg_match( '/[\x00-\x1F\x7F\s]/u', $url ) === 1 ) {
return false;
}
$parts = function_exists( 'wp_parse_url' )
? wp_parse_url( $url )
: call_user_func( 'parse_url', $url );
if ( ! is_array( $parts ) ) {
return false;
}
$scheme = strtolower( is_string( $parts['scheme'] ?? null ) ? $parts['scheme'] : '' );
$host = is_string( $parts['host'] ?? null ) ? trim( $parts['host'] ) : '';
return $host !== '' && in_array( $scheme, array( 'http', 'https' ), true );
}
/**
* Escape an inline Markdown URL for href output.
*
* @param string $url Safe absolute http(s) URL.
*/
private static function articleEscUrl( string $url ): string {
if ( function_exists( 'esc_url' ) ) {
$escaped = esc_url( $url );
return is_string( $escaped ) ? $escaped : '';
}
return htmlspecialchars( $url, ENT_QUOTES | ENT_HTML5, 'UTF-8' );
}
/**
* Return sanitized POST data for admin request handlers.
*
* @return array
*/
private static function currentPostData(): array {
// phpcs:ignore WordPress.Security.NonceVerification.Missing -- Callers verify the action-specific nonce before mutating state.
$raw = $_POST;
return self::sanitizeRequestData( $raw );
}
/**
* Return sanitized GET data for read-only admin rendering.
*
* @return array
*/
private static function currentGetData(): array {
// phpcs:ignore WordPress.Security.NonceVerification.Recommended -- Read-only admin routing/filter input, sanitized before use.
$raw = $_GET;
return self::sanitizeRequestData( $raw );
}
/**
* Sanitize a GET/POST-like array recursively after unslashing.
*
* @param array $data Request data.
*
* @return array
*/
private static function sanitizeRequestData( array $data ): array {
$unslashed = function_exists( 'wp_unslash' ) ? wp_unslash( $data ) : $data;
if ( ! is_array( $unslashed ) ) {
return array();
}
$sanitized = array();
foreach ( $unslashed as $key => $value ) {
if ( ! is_string( $key ) ) {
continue;
}
$sanitized[ $key ] = self::sanitizeRequestValue( $key, $value );
}
return $sanitized;
}
/**
* Sanitize one request value using the most specific safe context available.
*
* @param string $key Request key.
* @param mixed $value Request value.
*
* @return mixed
*/
private static function sanitizeRequestValue( string $key, $value ) {
if ( is_array( $value ) ) {
$result = array();
foreach ( $value as $childKey => $childValue ) {
if ( is_string( $childKey ) ) {
$result[ $childKey ] = self::sanitizeRequestValue( $childKey, $childValue );
continue;
}
if ( is_int( $childKey ) ) {
$result[ $childKey ] = self::sanitizeRequestValue( $key, $childValue );
}
}
return $result;
}
if ( ! is_scalar( $value ) ) {
return '';
}
$string = (string) $value;
if ( str_contains( $key, 'csv' ) || str_contains( $key, 'body' ) || str_contains( $key, 'review_urls' ) ) {
if ( function_exists( 'sanitize_textarea_field' ) ) {
return (string) sanitize_textarea_field( $string );
}
$string = preg_replace( '/<[^>]*>/', '', $string ) ?? $string;
return trim( (string) preg_replace( '/[ \t]+/', ' ', $string ) );
}
return self::sanitizeTextField( $string );
}
/**
* Read a sanitize_key()-style token from request data.
*
* @param array $requestData Request data.
* @param string $key Request key.
*/
private static function requestKey( array $requestData, string $key ): string {
if ( ! array_key_exists( $key, $requestData ) || ! is_scalar( $requestData[ $key ] ) ) {
return '';
}
$value = (string) $requestData[ $key ];
return function_exists( 'sanitize_key' )
? (string) sanitize_key( $value )
: (string) preg_replace( '/[^a-z0-9_\-]/i', '', $value );
}
/**
* Extract a positive integer from POST-like data.
*
* @param array $postData POST payload.
* @param string $key Field key.
*/
private static function postInt( array $postData, string $key ): ?int {
if ( ! array_key_exists( $key, $postData ) || ! is_scalar( $postData[ $key ] ) ) {
return null;
}
$value = trim( (string) $postData[ $key ] );
if ( $value === '' || ! ctype_digit( $value ) ) {
return null;
}
$id = (int) $value;
return $id > 0 ? $id : null;
}
/**
* Extract positive integer list from POST-like data.
*
* @param array $postData POST payload.
* @param string $key Field key.
*
* @return list
*/
private static function postIntList( array $postData, string $key ): array {
if ( ! array_key_exists( $key, $postData ) || ! is_array( $postData[ $key ] ) ) {
return array();
}
$result = array();
foreach ( $postData[ $key ] as $value ) {
if ( ! is_scalar( $value ) ) {
continue;
}
$string = trim( (string) $value );
if ( $string !== '' && ctype_digit( $string ) && (int) $string > 0 ) {
$result[] = (int) $string;
}
}
return array_values( array_unique( $result ) );
}
/**
* Extract a sanitized single-line scalar string from POST-like data.
*
* @param array $postData POST payload.
* @param string $key Field key.
*/
private static function postString( array $postData, string $key ): string {
return self::sanitizeTextField( self::postRawString( $postData, $key ) );
}
/**
* Extract a sanitized multi-line scalar string from POST-like data.
*
* @param array $postData POST payload.
* @param string $key Field key.
*/
private static function postTextareaString( array $postData, string $key ): string {
$value = self::postRawString( $postData, $key );
if ( function_exists( 'sanitize_textarea_field' ) ) {
return (string) call_user_func( 'sanitize_textarea_field', $value );
}
$value = preg_replace( '/<[^>]*>/', '', $value ) ?? $value;
return trim( (string) preg_replace( '/[ \t]+/', ' ', $value ) );
}
/**
* Extract an unslashed scalar string from POST-like data.
*
* Use only for fields whose format is validated separately, such as
* base64-encoded CSV payloads.
*
* @param array $postData POST payload.
* @param string $key Field key.
*/
private static function postRawString( array $postData, string $key ): string {
if ( ! array_key_exists( $key, $postData ) || ! is_scalar( $postData[ $key ] ) ) {
return '';
}
return (string) $postData[ $key ];
}
/**
* Sanitize a single-line text field.
*
* @param string $value Raw value.
*/
private static function sanitizeTextField( string $value ): string {
if ( function_exists( 'sanitize_text_field' ) ) {
return (string) call_user_func( 'sanitize_text_field', $value );
}
$value = preg_replace( '/<[^>]*>/', '', $value ) ?? $value;
return trim( (string) preg_replace( '/\s+/', ' ', $value ) );
}
/**
* Clean revenue opportunity redirect provider.
*
* @param string $provider Raw provider.
*/
private static function cleanRevenueRedirectProvider( string $provider ): string {
$provider = preg_replace( '/[^a-z0-9_]/', '', strtolower( trim( $provider ) ) ) ?? '';
return $provider !== '' ? $provider : 'amazon';
}
/**
* Clean revenue opportunity redirect date.
*
* @param string $date Raw date.
*/
private static function cleanRevenueRedirectDate( string $date ): string {
$date = trim( $date );
return preg_match( '/\A\d{4}-\d{2}-\d{2}\z/', $date ) === 1 ? $date : gmdate( 'Y-m-d' );
}
/**
* Clean revenue opportunity redirect status filter.
*
* @param string $status Raw status.
*/
private static function cleanRevenueRedirectStatus( string $status ): string {
$status = strtolower( trim( $status ) );
return in_array( $status, array( 'all', 'new', 'seen', 'applied', 'dismissed' ), true ) ? $status : 'new';
}
/**
* Clean revenue opportunity redirect severity filter.
*
* @param string $severity Raw severity.
*/
private static function cleanRevenueRedirectSeverity( string $severity ): string {
$severity = strtolower( trim( $severity ) );
return in_array( $severity, array( 'all', 'high', 'medium', 'low' ), true ) ? $severity : 'all';
}
/**
* Clean revenue opportunity redirect type filter.
*
* @param string $type Raw opportunity type.
*/
private static function cleanRevenueRedirectType( string $type ): string {
$type = strtolower( trim( $type ) );
return in_array(
$type,
array(
'all',
'broken_link',
'out_of_stock',
'sale',
'provider_event',
'seasonal',
'unmonetized_keyword',
'high_click_stale_copy',
),
true
) ? $type : 'all';
}
/**
* Clean Cloud AI scan status filter.
*
* @param string $filter Raw filter.
*/
private static function cleanCloudAiScanFilter( string $filter ): string {
$filter = strtolower( trim( $filter ) );
return in_array( $filter, array( 'all', 'installed', 'missing', 'no_candidate' ), true ) ? $filter : 'missing';
}
/**
* Redirect back to the products list with a small status token.
*
* @param string $status Status token for the `affilun_status` query parameter.
*/
private function redirectProductsList( string $status ): void {
$this->redirectProductsListWithArgs( array( 'affilun_status' => $status ) );
}
/**
* Redirect back to the products list with query args.
*
* @param array $args Query args.
*/
private function redirectProductsListWithArgs( array $args ): void {
$url = self::resolveAdminPageUrl( 'affilun-products' );
if ( function_exists( 'add_query_arg' ) ) {
$url = (string) add_query_arg( $args, $url );
} else {
$url .= ( str_contains( $url, '?' ) ? '&' : '?' ) . http_build_query( $args );
}
if ( function_exists( 'wp_safe_redirect' ) ) {
call_user_func( 'wp_safe_redirect', $url );
exit;
}
}
/**
* Redirect back to the Cloud tools page with query args.
*
* @param array $args Query args.
*/
private function redirectCloudToolsWithArgs( array $args ): void {
$url = self::resolveAdminPageUrl( 'affilun-cloud-tools' );
if ( function_exists( 'add_query_arg' ) ) {
$url = (string) add_query_arg( $args, $url );
} else {
$url .= ( str_contains( $url, '?' ) ? '&' : '?' ) . http_build_query( $args );
}
if ( function_exists( 'wp_safe_redirect' ) ) {
call_user_func( 'wp_safe_redirect', $url );
exit;
}
}
/**
* Resolve an admin page URL.
*
* @param string $pageSlug Admin page slug.
*/
private static function resolveAdminPageUrl( string $pageSlug ): string {
$path = 'admin.php?page=' . rawurlencode( $pageSlug );
if ( function_exists( 'admin_url' ) ) {
return (string) admin_url( $path );
}
return 'http://example.test/wp-admin/' . $path;
}
/**
* Resolve the products page focused on saved products with link-health issues.
*/
private static function linkHealthProblemProductsUrl(): string {
$args = array(
'page' => 'affilun-products',
'affilun_link_health_filter' => 'problem',
);
$base = self::resolveAdminPageUrl( 'affilun-products' );
if ( function_exists( 'add_query_arg' ) ) {
return (string) add_query_arg( array( 'affilun_link_health_filter' => 'problem' ), $base );
}
return 'http://example.test/wp-admin/admin.php?' . http_build_query( $args );
}
/**
* Build the §13 Settings page {@see AdminPageDefinition}.
*
* The render closure re-checks the §3 `manage_options`
* capability via {@see AdminCapability::CAP_FALLBACK_MANAGE}
* (the slice 8c-2 renderer is admin-only-by-contract; this
* is the canonical capability seam for the page-render
* dispatch path) and forwards the whitelisted `affilun_status`
* query parameter to the cached renderer.
*/
private function buildSettingsPageDefinition(): AdminPageDefinition {
return new AdminPageDefinition(
'options-general.php',
'affilun 設定',
'affilun',
AdminCapability::CAP_FALLBACK_MANAGE,
'affilun-settings',
function (): void {
$this->renderSettingsPage();
},
'',
0,
null
);
}
/**
* Build the §6 Products list page {@see AdminPageDefinition}.
*
* Phase-8 minimum registers Products as a top-level admin
* menu (matching `specifications/admin-ui-spec.md` §2.1
* "[AFFILUN] under WordPress admin menu — Dashboard / Products /
* ..."); a future slice may consolidate Settings under the
* same top-level AFFILUN menu.
*
* The render closure re-checks the §3 editor-tier capability
* via {@see AdminCapability::CAP_VIEW_PRODUCTS} and forwards
* `$_GET` (already unslashed) to
* {@see ProductsListQueryParser::parse()} to construct a
* {@see ProductListQuery}, then dispatches to the cached
* {@see ProductsListPageRenderer}.
*/
private function buildProductsListPageDefinition(): AdminPageDefinition {
return new AdminPageDefinition(
'',
'affilun アフィリエイト管理',
'affilun',
AdminCapability::CAP_VIEW_PRODUCTS,
'affilun-products',
function (): void {
$this->renderProductsListPage();
},
'dashicons-cart',
30,
null
);
}
/**
* Override WordPress's auto-generated first submenu entry.
*
* `add_menu_page()` automatically duplicates the top-level
* entry as a first submenu using the menu_title (`Commerce
* Link Builder`). Registering an explicit `add_submenu_page()`
* with the same parent + menu slug as the top-level page
* replaces that auto-generated row with the supplied menu
* title (`商品一覧`), eliminating the visible duplicate while
* still routing to the same render closure.
*/
private function buildProductsListSubmenuOverrideDefinition(): AdminPageDefinition {
return new AdminPageDefinition(
'affilun-products',
'affilun アフィリエイト管理',
'アフィリエイト管理',
AdminCapability::CAP_VIEW_PRODUCTS,
'affilun-products',
// No-op render: the top-level definition above already
// registers the products-list render closure against the
// same `toplevel_page_affilun-products` action hook. Wiring
// the same closure here would make WordPress fire the
// render callback twice and emit duplicate page HTML.
static function (): void {},
'',
0,
null
);
}
/**
* Build the §7 Add New admin page {@see AdminPageDefinition}
* (strict-review fix #5, KI-014).
*
* Registered as a visible submenu under the existing top-level
* `affilun-products` AFFILUN menu so WordPress keeps the page routable
* from `admin.php?page=affilun-add-new` and the empty-state CTA does
* not trip core's "no access" guard. The editor-tier admin pages
* (Products list + Add New) live side-by-side, mirroring the
* WordPress core convention for `edit.php` + `post-new.php`.
* Capability gating uses the editor-tier
* {@see AdminCapability::CAP_VIEW_PRODUCTS} (`edit_posts`).
*
* @param bool $hidden Whether to register the page as hidden.
*/
private function buildAddNewProductPageDefinition( bool $hidden = false ): AdminPageDefinition {
return new AdminPageDefinition(
$hidden ? AdminPageDefinition::HIDDEN_PARENT_SLUG : 'affilun-products',
'affilun 商品を追加',
'商品を追加',
AdminCapability::CAP_VIEW_PRODUCTS,
'affilun-add-new',
function (): void {
$this->renderAddNewProductPage();
},
'',
0,
null
);
}
/**
* Build the Phase 4 migration / growth page {@see AdminPageDefinition}.
*
* @param bool $hidden Whether to register the page as hidden.
*/
private function buildMigrationPageDefinition( bool $hidden = false ): AdminPageDefinition {
return new AdminPageDefinition(
$hidden ? AdminPageDefinition::HIDDEN_PARENT_SLUG : 'affilun-products',
'affilun 移行 / スキャン',
'移行 / スキャン',
AdminCapability::CAP_VIEW_DIAGNOSTICS,
'affilun-migration',
function (): void {
$this->renderMigrationPage();
},
'',
0,
null
);
}
/**
* Build the Phase 3 click analytics page {@see AdminPageDefinition}.
*/
private function buildClicksDashboardPageDefinition(): AdminPageDefinition {
return new AdminPageDefinition(
'affilun-products',
'affilun クリック分析',
'クリック分析',
AdminCapability::CAP_VIEW_DIAGNOSTICS,
'affilun-clicks',
function (): void {
$this->renderClicksDashboardPage();
},
'',
0,
null
);
}
/**
* Build the Phase 13 Cloud tools page {@see AdminPageDefinition}.
*/
private function buildCloudToolsPageDefinition(): AdminPageDefinition {
return new AdminPageDefinition(
'affilun-products',
'affilun Cloudツール',
'Cloudツール',
AdminCapability::CAP_VIEW_DIAGNOSTICS,
'affilun-cloud-tools',
function (): void {
$this->renderCloudToolsPage();
},
'',
0,
null
);
}
/**
* Build the §13 Diagnostics admin page {@see AdminPageDefinition}.
*
* Registered as a submenu under the existing top-level
* `affilun-products` AFFILUN menu so all Phase-11 admin pages share one
* top-level entry. Capability gating uses
* {@see AdminCapability::CAP_FALLBACK_MANAGE} (`manage_options`).
*
* @param bool $hidden Whether to register the page as hidden.
*/
private function buildDiagnosticsPageDefinition( bool $hidden = false ): AdminPageDefinition {
return new AdminPageDefinition(
$hidden ? AdminPageDefinition::HIDDEN_PARENT_SLUG : 'affilun-products',
'affilun 診断情報',
'診断情報',
AdminCapability::CAP_VIEW_DIAGNOSTICS,
'affilun-diagnostics',
function (): void {
$this->renderDiagnosticsPage();
},
'',
0,
null
);
}
/**
* Build the §6 Logs admin page {@see AdminPageDefinition}.
*
* Registered as a submenu under `affilun-products`. Capability
* gating uses {@see AdminCapability::CAP_FALLBACK_MANAGE}
* (`manage_options`) since logs may surface admin-tier
* diagnostics context.
*
* @param bool $hidden Whether to register the page as hidden.
*/
private function buildLogsPageDefinition( bool $hidden = false ): AdminPageDefinition {
return new AdminPageDefinition(
$hidden ? AdminPageDefinition::HIDDEN_PARENT_SLUG : 'affilun-products',
'affilun ログ',
'ログ',
AdminCapability::CAP_VIEW_LOGS,
'affilun-logs',
function (): void {
$this->renderLogsPage();
},
'',
0,
null
);
}
/**
* Build the §6 Sync Jobs admin page {@see AdminPageDefinition}.
*
* Registered as a submenu under `affilun-products`. Capability
* gating uses {@see AdminCapability::CAP_FALLBACK_MANAGE}
* (`manage_options`).
*
* @param bool $hidden Whether to register the page as hidden.
*/
private function buildSyncJobsPageDefinition( bool $hidden = false ): AdminPageDefinition {
return new AdminPageDefinition(
$hidden ? AdminPageDefinition::HIDDEN_PARENT_SLUG : 'affilun-products',
'affilun 同期ジョブ',
'同期ジョブ',
AdminCapability::CAP_RUN_SYNC,
'affilun-sync-jobs',
function (): void {
$this->renderSyncJobsPage();
},
'',
0,
null
);
}
/**
* Build the §10 Audit Events admin page {@see AdminPageDefinition}.
*
* Registered as a submenu under `affilun-products`. Capability
* gating uses {@see AdminCapability::CAP_VIEW_DIAGNOSTICS}
* (with {@see AdminCapability::CAP_FALLBACK_MANAGE} as the
* OR-list fallback through {@see AdminCapability::PAGE_TOKEN_AUDIT}).
*
* @param bool $hidden Whether to register the page as hidden.
*/
private function buildAuditPageDefinition( bool $hidden = false ): AdminPageDefinition {
return new AdminPageDefinition(
$hidden ? AdminPageDefinition::HIDDEN_PARENT_SLUG : 'affilun-products',
'affilun 監査イベント',
'監査イベント',
AdminCapability::CAP_VIEW_DIAGNOSTICS,
'affilun-audit',
function (): void {
$this->renderAuditPage();
},
'',
0,
null
);
}
/**
* Page-render dispatch for the Phase 4 migration / growth page.
*/
private function renderMigrationPage(): void {
if ( ! $this->isAuthorizedForPage( AdminCapability::PAGE_TOKEN_MIGRATION ) ) {
if ( function_exists( 'wp_die' ) ) {
wp_die(
'Insufficient capabilities.',
'affilun',
array( 'response' => 403 )
);
}
return;
}
if ( $this->resolvedMigrationRenderer === null ) {
return;
}
$unslashedGet = self::currentGetData();
$unslashedPost = self::currentPostData();
$this->resolvedMigrationRenderer->render( array_merge( $unslashedGet, $unslashedPost ) );
}
/**
* Page-render dispatch for the Phase 3 click analytics page.
*/
private function renderClicksDashboardPage(): void {
if ( ! $this->isAuthorizedForPage( AdminCapability::PAGE_TOKEN_CLICKS ) ) {
if ( function_exists( 'wp_die' ) ) {
wp_die(
'Insufficient capabilities.',
'affilun',
array( 'response' => 403 )
);
}
return;
}
if ( $this->resolvedClicksDashboardRenderer === null ) {
return;
}
$this->resolvedClicksDashboardRenderer->render( self::currentGetData() );
}
/**
* Page-render dispatch for the Phase 13 Cloud tools page.
*/
private function renderCloudToolsPage(): void {
if ( ! $this->isAuthorizedForPage( AdminCapability::PAGE_TOKEN_DIAGNOSTICS ) ) {
if ( function_exists( 'wp_die' ) ) {
wp_die(
'Insufficient capabilities.',
'affilun',
array( 'response' => 403 )
);
}
return;
}
if ( $this->resolvedCloudToolsRenderer === null ) {
return;
}
$this->resolvedCloudToolsRenderer->render( self::currentGetData() );
}
/**
* Page-render dispatch for the §13 Diagnostics page.
*/
private function renderDiagnosticsPage(): void {
if ( ! $this->isAuthorizedForPage( AdminCapability::PAGE_TOKEN_DIAGNOSTICS ) ) {
if ( function_exists( 'wp_die' ) ) {
wp_die(
'Insufficient capabilities.',
'affilun',
array( 'response' => 403 )
);
}
return;
}
if ( $this->resolvedDiagnosticsRenderer === null ) {
return;
}
$this->resolvedDiagnosticsRenderer->render();
}
/**
* Page-render dispatch for the §6 Logs page.
*/
private function renderLogsPage(): void {
if ( ! $this->isAuthorizedForPage( AdminCapability::PAGE_TOKEN_LOGS ) ) {
if ( function_exists( 'wp_die' ) ) {
wp_die(
'Insufficient capabilities.',
'affilun',
array( 'response' => 403 )
);
}
return;
}
if (
$this->resolvedLogsRenderer === null
|| $this->resolvedLogsListQueryParser === null
) {
return;
}
$unslashed = self::currentGetData();
$query = $this->resolvedLogsListQueryParser->parse( $unslashed );
$this->resolvedLogsRenderer->render( $query );
}
/**
* Page-render dispatch for the §6 Sync Jobs page.
*/
private function renderSyncJobsPage(): void {
if ( ! $this->isAuthorizedForPage( AdminCapability::PAGE_TOKEN_SYNC_JOBS ) ) {
if ( function_exists( 'wp_die' ) ) {
wp_die(
'Insufficient capabilities.',
'affilun',
array( 'response' => 403 )
);
}
return;
}
if (
$this->resolvedSyncJobsRenderer === null
|| $this->resolvedSyncJobsListQueryParser === null
) {
return;
}
$unslashed = self::currentGetData();
$query = $this->resolvedSyncJobsListQueryParser->parse( $unslashed );
$this->resolvedSyncJobsRenderer->render( $query );
}
/**
* Page-render dispatch for the §10 Audit Events page.
*/
private function renderAuditPage(): void {
if ( ! $this->isAuthorizedForPage( AdminCapability::PAGE_TOKEN_AUDIT ) ) {
if ( function_exists( 'wp_die' ) ) {
wp_die(
'Insufficient capabilities.',
'affilun',
array( 'response' => 403 )
);
}
return;
}
if (
$this->resolvedAuditRenderer === null
|| $this->resolvedAuditListQueryParser === null
) {
return;
}
$unslashed = self::currentGetData();
$query = $this->resolvedAuditListQueryParser->parse( $unslashed );
$this->resolvedAuditRenderer->render( $query );
}
/**
* Page-render dispatch for the §6 Products list page.
*
* Re-checks the §3 editor-tier capability and routes the
* `$_GET` array (unslashed via `wp_unslash()` when available)
* through the cached {@see ProductsListQueryParser} so a
* tampered URL falls back to {@see ProductListQuery::defaults()}
* rather than reaching the renderer with a partially-validated
* query.
*/
private function renderProductsListPage(): void {
if (
! function_exists( 'current_user_can' )
|| ! current_user_can( AdminCapability::CAP_VIEW_PRODUCTS )
) {
if ( function_exists( 'wp_die' ) ) {
wp_die(
'Insufficient capabilities.',
'affilun',
array( 'response' => 403 )
);
}
return;
}
if (
$this->resolvedProductsListRenderer === null
|| $this->resolvedProductsListQueryParser === null
) {
return;
}
$unslashedGet = self::currentGetData();
$unslashedPost = self::currentPostData();
$requestData = array_merge( $unslashedGet, $unslashedPost );
$query = $this->resolvedProductsListQueryParser->parse( $unslashedGet );
$this->resolvedProductsListRenderer->render( $query, $requestData );
}
/**
* Page-render dispatch for the §7 Add New admin page
* (strict-review fix #5, KI-014).
*
* Re-checks the editor-tier capability via
* {@see AdminCapability::PAGE_TOKEN_PRODUCTS_NEW}'s OR-list
* (`edit_posts` primary; no fallback configured because the
* primary already maps to a built-in WordPress capability)
* and forwards the whitelisted `affilun_status` query parameter
* to the cached renderer. Unknown status values are dropped
* silently rather than echoed back into the page.
*/
private function renderAddNewProductPage(): void {
if ( ! $this->isAuthorizedForPage( AdminCapability::PAGE_TOKEN_PRODUCTS_NEW ) ) {
if ( function_exists( 'wp_die' ) ) {
wp_die(
'Insufficient capabilities.',
'affilun',
array( 'response' => 403 )
);
}
return;
}
if ( $this->resolvedAddNewRenderer === null ) {
return;
}
$getData = self::currentGetData();
$rawStatus = self::requestKey( $getData, 'affilun_status' );
$flash = in_array( $rawStatus, AddNewProductPageRenderer::VALID_STATUS_FLASHES, true ) ? $rawStatus : null;
$this->resolvedAddNewRenderer->render( $flash );
}
/**
* Page-render dispatch.
*
* Re-checks the §3 admin-tier capability and forwards the
* whitelisted `affilun_status` query parameter to the cached
* renderer. Unknown status values are dropped silently
* rather than echoed back into the page so a malicious
* `?affilun_status=...` value cannot reach the renderer.
*/
private function renderSettingsPage(): void {
if (
! function_exists( 'current_user_can' )
|| ! current_user_can( AdminCapability::CAP_FALLBACK_MANAGE )
) {
if ( function_exists( 'wp_die' ) ) {
wp_die(
'Insufficient capabilities.',
'affilun',
array( 'response' => 403 )
);
}
return;
}
if ( $this->resolvedRenderer === null ) {
return;
}
$getData = self::currentGetData();
$rawStatus = self::requestKey( $getData, 'affilun_status' );
$flash = in_array( $rawStatus, self::VALID_STATUS_FLASHES, true ) ? $rawStatus : null;
$this->resolvedRenderer->render( $flash, self::currentRequestParameters() );
}
/**
* Return request parameters for read-only operation tab rendering.
*
* @return array
*/
private static function currentRequestParameters(): array {
return array_merge( self::currentGetData(), self::currentPostData() );
}
/**
* Resolve {@see OptionStore} from the registry.
*
* @param ServiceProviderRegistry $registry Bootstrap registry.
*
* @throws LogicException When the binding is missing or the
* bound value is not an
* {@see OptionStore}.
*/
private function resolveOptionStore( ServiceProviderRegistry $registry ): OptionStore {
$key = PersistenceServiceProvider::BINDING_OPTION_STORE;
if ( ! $registry->has( $key ) ) {
$message = 'AdminServiceProvider requires PersistenceServiceProvider to register before it'
. ' (missing OptionStore binding).';
// phpcs:ignore WordPress.Security.EscapeOutput.ExceptionNotEscaped -- Developer-facing message, never rendered to HTML.
throw new LogicException( $message );
}
$optionStore = $registry->get( $key );
if ( ! $optionStore instanceof OptionStore ) {
$message = sprintf(
'AdminServiceProvider expected OptionStore under "%s"; got %s.',
$key,
is_object( $optionStore ) ? get_class( $optionStore ) : gettype( $optionStore )
);
// phpcs:ignore WordPress.Security.EscapeOutput.ExceptionNotEscaped -- Developer-facing message, never rendered to HTML.
throw new LogicException( $message );
}
return $optionStore;
}
/**
* Resolve {@see ProductRepository} from the registry.
*
* @param ServiceProviderRegistry $registry Bootstrap registry.
*
* @throws LogicException When the binding is missing or the
* bound value is not a
* {@see ProductRepository}.
*/
private function resolveProductRepository( ServiceProviderRegistry $registry ): ProductRepository {
$key = PersistenceServiceProvider::BINDING_PRODUCT_REPOSITORY;
if ( ! $registry->has( $key ) ) {
$message = 'AdminServiceProvider requires PersistenceServiceProvider to register before it'
. ' (missing ProductRepository binding).';
// phpcs:ignore WordPress.Security.EscapeOutput.ExceptionNotEscaped -- Developer-facing message, never rendered to HTML.
throw new LogicException( $message );
}
$repository = $registry->get( $key );
if ( ! $repository instanceof ProductRepository ) {
$message = sprintf(
'AdminServiceProvider expected ProductRepository under "%s"; got %s.',
$key,
is_object( $repository ) ? get_class( $repository ) : gettype( $repository )
);
// phpcs:ignore WordPress.Security.EscapeOutput.ExceptionNotEscaped -- Developer-facing message, never rendered to HTML.
throw new LogicException( $message );
}
return $repository;
}
/**
* Resolve {@see ProductMetaRepository} from the registry.
*
* @param ServiceProviderRegistry $registry Bootstrap registry.
*
* @throws LogicException When the binding is missing or invalid.
*/
private function resolveProductMetaRepository( ServiceProviderRegistry $registry ): ProductMetaRepository {
$key = PersistenceServiceProvider::BINDING_PRODUCT_META_REPOSITORY;
if ( ! $registry->has( $key ) ) {
$message = 'AdminServiceProvider requires PersistenceServiceProvider to register before it'
. ' (missing ProductMetaRepository binding).';
// phpcs:ignore WordPress.Security.EscapeOutput.ExceptionNotEscaped -- Developer-facing message, never rendered to HTML.
throw new LogicException( $message );
}
$repository = $registry->get( $key );
if ( ! $repository instanceof ProductMetaRepository ) {
$message = sprintf(
'AdminServiceProvider expected ProductMetaRepository under "%s"; got %s.',
$key,
is_object( $repository ) ? get_class( $repository ) : gettype( $repository )
);
// phpcs:ignore WordPress.Security.EscapeOutput.ExceptionNotEscaped -- Developer-facing message, never rendered to HTML.
throw new LogicException( $message );
}
return $repository;
}
/**
* Resolve the §8.2 {@see ListProductsUseCase} from the
* registry, falling back to a default-constructed instance
* wrapping the supplied repository when the
* {@see ProductsServiceProvider::BINDING_LIST_PRODUCTS_USE_CASE}
* binding is absent.
*
* Preferring the bound use case when present keeps the
* Phase-6 ProductsServiceProvider and the Phase-8 admin
* surface loosely coupled; the default-construction branch
* keeps the admin provider operable in test harnesses that
* exercise the admin graph without booting the REST stack.
*
* @param ServiceProviderRegistry $registry Bootstrap registry.
* @param ProductRepository $productRepository Repository for default construction.
*/
private function resolveListProductsUseCase(
ServiceProviderRegistry $registry,
ProductRepository $productRepository
): ListProductsUseCase {
$key = ProductsServiceProvider::BINDING_LIST_PRODUCTS_USE_CASE;
if ( $registry->has( $key ) ) {
$bound = $registry->get( $key );
if ( $bound instanceof ListProductsUseCase ) {
return $bound;
}
}
return new ListProductsUseCase( $productRepository );
}
/**
* Resolve {@see LogRepository} from the registry.
*
* @param ServiceProviderRegistry $registry Bootstrap registry.
*
* @throws LogicException When the binding is missing or the
* bound value is not a {@see LogRepository}.
*/
private function resolveLogRepository( ServiceProviderRegistry $registry ): LogRepository {
$key = PersistenceServiceProvider::BINDING_LOG_REPOSITORY;
if ( ! $registry->has( $key ) ) {
$message = 'AdminServiceProvider requires PersistenceServiceProvider to register before it'
. ' (missing LogRepository binding).';
// phpcs:ignore WordPress.Security.EscapeOutput.ExceptionNotEscaped -- Developer-facing message, never rendered to HTML.
throw new LogicException( $message );
}
$repo = $registry->get( $key );
if ( ! $repo instanceof LogRepository ) {
$message = sprintf(
'AdminServiceProvider expected LogRepository under "%s"; got %s.',
$key,
is_object( $repo ) ? get_class( $repo ) : gettype( $repo )
);
// phpcs:ignore WordPress.Security.EscapeOutput.ExceptionNotEscaped -- Developer-facing message, never rendered to HTML.
throw new LogicException( $message );
}
return $repo;
}
/**
* Resolve {@see SyncJobRepository} from the registry.
*
* @param ServiceProviderRegistry $registry Bootstrap registry.
*
* @throws LogicException When the binding is missing or the
* bound value is not a
* {@see SyncJobRepository}.
*/
private function resolveSyncJobRepository( ServiceProviderRegistry $registry ): SyncJobRepository {
$key = PersistenceServiceProvider::BINDING_SYNC_JOB_REPOSITORY;
if ( ! $registry->has( $key ) ) {
$message = 'AdminServiceProvider requires PersistenceServiceProvider to register before it'
. ' (missing SyncJobRepository binding).';
// phpcs:ignore WordPress.Security.EscapeOutput.ExceptionNotEscaped -- Developer-facing message, never rendered to HTML.
throw new LogicException( $message );
}
$repo = $registry->get( $key );
if ( ! $repo instanceof SyncJobRepository ) {
$message = sprintf(
'AdminServiceProvider expected SyncJobRepository under "%s"; got %s.',
$key,
is_object( $repo ) ? get_class( $repo ) : gettype( $repo )
);
// phpcs:ignore WordPress.Security.EscapeOutput.ExceptionNotEscaped -- Developer-facing message, never rendered to HTML.
throw new LogicException( $message );
}
return $repo;
}
/**
* Resolve {@see SchemaVersionRepository} from the registry.
*
* @param ServiceProviderRegistry $registry Bootstrap registry.
*
* @throws LogicException When the binding is missing or the
* bound value is not a
* {@see SchemaVersionRepository}.
*/
private function resolveSchemaVersionRepository(
ServiceProviderRegistry $registry
): SchemaVersionRepository {
$key = PersistenceServiceProvider::BINDING_SCHEMA_VERSION_REPOSITORY;
if ( ! $registry->has( $key ) ) {
$message = 'AdminServiceProvider requires PersistenceServiceProvider to register before it'
. ' (missing SchemaVersionRepository binding).';
// phpcs:ignore WordPress.Security.EscapeOutput.ExceptionNotEscaped -- Developer-facing message, never rendered to HTML.
throw new LogicException( $message );
}
$repo = $registry->get( $key );
if ( ! $repo instanceof SchemaVersionRepository ) {
$message = sprintf(
'AdminServiceProvider expected SchemaVersionRepository under "%s"; got %s.',
$key,
is_object( $repo ) ? get_class( $repo ) : gettype( $repo )
);
// phpcs:ignore WordPress.Security.EscapeOutput.ExceptionNotEscaped -- Developer-facing message, never rendered to HTML.
throw new LogicException( $message );
}
return $repo;
}
/**
* Resolve the {@see ProviderRegistry} from the registry.
*
* Phase 12 slice 12c centralizes the §12.1 providers map under
* {@see ProviderServiceProvider::BINDING_PROVIDER_REGISTRY}.
* When the binding is missing — typically in tests that
* pre-seed the admin collaborators without standing up the
* provider service provider — this method returns a fresh
* empty {@see ProviderRegistry} so the admin diagnostics page
* renders an empty `providers` branch rather than failing
* loudly.
*
* @param ServiceProviderRegistry $registry Bootstrap registry.
*
* @throws LogicException When the binding exists but is not a
* {@see ProviderRegistry}.
*/
private function resolveProviderRegistry( ServiceProviderRegistry $registry ): ProviderRegistry {
$key = ProviderServiceProvider::BINDING_PROVIDER_REGISTRY;
if ( ! $registry->has( $key ) ) {
return new ProviderRegistry( array() );
}
$value = $registry->get( $key );
if ( ! $value instanceof ProviderRegistry ) {
$message = sprintf(
'AdminServiceProvider expected ProviderRegistry under "%s"; got %s.',
$key,
is_object( $value ) ? get_class( $value ) : gettype( $value )
);
// phpcs:ignore WordPress.Security.EscapeOutput.ExceptionNotEscaped -- Developer-facing message, never rendered to HTML.
throw new LogicException( $message );
}
return $value;
}
/**
* Re-check page-render authorization through the §3.3
* {@see AdminCapability} OR-list (Phase 2 KI-008).
*
* Wraps `current_user_can()` in a closure compatible with
* {@see AdminCapability::isAuthorized()} so the dispatch
* path accepts either the dedicated `affilun_*` capability OR
* the `manage_options` fallback. When `current_user_can()`
* is unavailable (pure-unit test path without WordPress
* loaded), the probe denies, matching the legacy
* fail-closed behavior.
*
* @param string $pageToken Stable page token from
* {@see AdminCapability}.
*/
private function isAuthorizedForPage( string $pageToken ): bool {
$probe = static function ( string $cap ): bool {
return function_exists( 'current_user_can' )
&& (bool) current_user_can( $cap );
};
return AdminCapability::isAuthorized( $probe, $pageToken );
}
/**
* Soft-resolve the render cache so settings saves can invalidate
* cached card HTML.
*
* @param ServiceProviderRegistry $registry Bootstrap registry.
*/
private function resolveOptionalRenderCache( ServiceProviderRegistry $registry ): ?RenderCache {
$key = CacheServiceProvider::BINDING_RENDER_CACHE;
if ( ! $registry->has( $key ) ) {
return null;
}
$value = $registry->get( $key );
return $value instanceof RenderCache ? $value : null;
}
/**
* Soft-resolve the canonical ProductCardViewModelFactory for the
* Settings rendering preview.
*
* @param ServiceProviderRegistry $registry Bootstrap registry.
*/
private function resolveOptionalProductCardViewModelFactory(
ServiceProviderRegistry $registry
): ?ProductCardViewModelFactory {
$key = RenderServiceProvider::BINDING_PRODUCT_CARD_VIEW_MODEL_FACTORY;
if ( ! $registry->has( $key ) ) {
return null;
}
$value = $registry->get( $key );
return $value instanceof ProductCardViewModelFactory ? $value : null;
}
/**
* Soft-resolve the canonical ProductCardRenderer for the Settings
* rendering preview.
*
* @param ServiceProviderRegistry $registry Bootstrap registry.
*/
private function resolveOptionalProductCardRenderer(
ServiceProviderRegistry $registry
): ?ProductCardRenderer {
$key = RenderServiceProvider::BINDING_PRODUCT_CARD_RENDERER;
if ( ! $registry->has( $key ) ) {
return null;
}
$value = $registry->get( $key );
return $value instanceof ProductCardRenderer ? $value : null;
}
/**
* Soft-resolve the {@see AuditEventRepository} from the
* registry and wrap it in a {@see RepositoryAuditEventWriter}
* so the §13 admin Settings save can emit §10.1
* `configuration_change` audit rows.
*
* Returns null when the binding is missing or carries an
* unexpected value — pure-unit harnesses that don't bind the
* audit repository (the test seed `buildPreparedRegistry()`
* predates the audit-writer wiring) keep working without
* modification, and the {@see SaveSettingsHandler} stays
* silent on the audit channel rather than failing loudly.
*
* @param ServiceProviderRegistry $registry Bootstrap registry.
*/
private function resolveOptionalAuditEventWriter(
ServiceProviderRegistry $registry
): ?RepositoryAuditEventWriter {
$key = PersistenceServiceProvider::BINDING_AUDIT_EVENT_REPOSITORY;
if ( ! $registry->has( $key ) ) {
return null;
}
$events = $registry->get( $key );
if ( ! $events instanceof AuditEventRepository ) {
return null;
}
return new RepositoryAuditEventWriter( $events, new SystemClock() );
}
}