
001/*- 002 * #%L 003 * HAPI FHIR JPA Server 004 * %% 005 * Copyright (C) 2014 - 2025 Smile CDR, Inc. 006 * %% 007 * Licensed under the Apache License, Version 2.0 (the "License"); 008 * you may not use this file except in compliance with the License. 009 * You may obtain a copy of the License at 010 * 011 * http://www.apache.org/licenses/LICENSE-2.0 012 * 013 * Unless required by applicable law or agreed to in writing, software 014 * distributed under the License is distributed on an "AS IS" BASIS, 015 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 016 * See the License for the specific language governing permissions and 017 * limitations under the License. 018 * #L% 019 */ 020package ca.uhn.fhir.jpa.search.builder; 021 022import ca.uhn.fhir.interceptor.api.HookParams; 023import ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster; 024import ca.uhn.fhir.interceptor.api.Pointcut; 025import ca.uhn.fhir.interceptor.model.RequestPartitionId; 026import ca.uhn.fhir.jpa.searchparam.SearchParameterMap; 027import ca.uhn.fhir.rest.api.server.RequestDetails; 028import ca.uhn.fhir.rest.server.servlet.ServletRequestDetails; 029import ca.uhn.fhir.rest.server.util.CompositeInterceptorBroadcaster; 030import ca.uhn.fhir.rest.server.util.ICachedSearchDetails; 031 032/** 033 * facade over raw hook interface 034 */ 035public class StorageInterceptorHooksFacade { 036 private final IInterceptorBroadcaster myInterceptorBroadcaster; 037 038 public StorageInterceptorHooksFacade(IInterceptorBroadcaster theInterceptorBroadcaster) { 039 myInterceptorBroadcaster = theInterceptorBroadcaster; 040 } 041 042 /** 043 * Interceptor call: STORAGE_PRESEARCH_PARTITION_SELECTED 044 */ 045 public void callStoragePresearchPartitionSelected( 046 RequestDetails theRequestDetails, SearchParameterMap theParams, ICachedSearchDetails theSearch) { 047 IInterceptorBroadcaster compositeBroadcaster = 048 CompositeInterceptorBroadcaster.newCompositeBroadcaster(myInterceptorBroadcaster, theRequestDetails); 049 050 compositeBroadcaster.ifHasCallHooks(Pointcut.STORAGE_PRESEARCH_PARTITION_SELECTED, () -> new HookParams() 051 .add(ICachedSearchDetails.class, theSearch) 052 .add(RequestDetails.class, theRequestDetails) 053 .addIfMatchesType(ServletRequestDetails.class, theRequestDetails) 054 .add(SearchParameterMap.class, theParams)); 055 } 056 057 /** 058 * Interceptor call: STORAGE_PRESEARCH_REGISTERED 059 */ 060 public void callStoragePresearchRegistered( 061 RequestDetails theRequestDetails, 062 SearchParameterMap theParams, 063 ICachedSearchDetails theSearch, 064 RequestPartitionId theRequestPartitionId) { 065 IInterceptorBroadcaster compositeBroadcaster = 066 CompositeInterceptorBroadcaster.newCompositeBroadcaster(myInterceptorBroadcaster, theRequestDetails); 067 if (compositeBroadcaster.hasHooks(Pointcut.STORAGE_PRESEARCH_REGISTERED)) { 068 HookParams params = new HookParams() 069 .add(ICachedSearchDetails.class, theSearch) 070 .add(RequestDetails.class, theRequestDetails) 071 .addIfMatchesType(ServletRequestDetails.class, theRequestDetails) 072 .add(SearchParameterMap.class, theParams) 073 .add(RequestPartitionId.class, theRequestPartitionId); 074 compositeBroadcaster.callHooks(Pointcut.STORAGE_PRESEARCH_REGISTERED, params); 075 } 076 } 077}