001/*- 002 * #%L 003 * HAPI FHIR JPA Server - Batch2 Task Processor 004 * %% 005 * Copyright (C) 2014 - 2024 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.batch2.jobs.parameters; 021 022import ca.uhn.fhir.interceptor.model.RequestPartitionId; 023import ca.uhn.fhir.jpa.partition.IRequestPartitionHelperSvc; 024import ca.uhn.fhir.jpa.searchparam.MatchUrlService; 025import ca.uhn.fhir.jpa.searchparam.ResourceSearch; 026import ca.uhn.fhir.rest.api.server.RequestDetails; 027 028public class UrlPartitioner { 029 private final MatchUrlService myMatchUrlService; 030 private final IRequestPartitionHelperSvc myRequestPartitionHelperSvc; 031 032 public UrlPartitioner(MatchUrlService theMatchUrlService, IRequestPartitionHelperSvc theRequestPartitionHelperSvc) { 033 myMatchUrlService = theMatchUrlService; 034 myRequestPartitionHelperSvc = theRequestPartitionHelperSvc; 035 } 036 037 public PartitionedUrl partitionUrl(String theUrl, RequestDetails theRequestDetails) { 038 ResourceSearch resourceSearch = myMatchUrlService.getResourceSearch(theUrl); 039 RequestPartitionId requestPartitionId = 040 myRequestPartitionHelperSvc.determineReadPartitionForRequestForSearchType( 041 theRequestDetails, resourceSearch.getResourceName(), resourceSearch.getSearchParameterMap()); 042 PartitionedUrl retval = new PartitionedUrl(); 043 retval.setUrl(theUrl); 044 retval.setRequestPartitionId(requestPartitionId); 045 return retval; 046 } 047}