001/*- 002 * #%L 003 * HAPI FHIR Subscription Server 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.jpa.topic; 021 022import ca.uhn.fhir.jpa.searchparam.matcher.InMemoryMatchResult; 023import ca.uhn.fhir.jpa.subscription.model.ResourceModifiedMessage; 024import org.hl7.fhir.instance.model.api.IBaseResource; 025import org.hl7.fhir.r5.model.SubscriptionTopic; 026 027import java.util.List; 028 029public class SubscriptionTopicMatcher { 030 private final SubscriptionTopicSupport mySubscriptionTopicSupport; 031 private final SubscriptionTopic myTopic; 032 033 public SubscriptionTopicMatcher(SubscriptionTopicSupport theSubscriptionTopicSupport, SubscriptionTopic theTopic) { 034 mySubscriptionTopicSupport = theSubscriptionTopicSupport; 035 myTopic = theTopic; 036 } 037 038 public InMemoryMatchResult match(ResourceModifiedMessage theMsg) { 039 IBaseResource resource = theMsg.getPayload(mySubscriptionTopicSupport.getFhirContext()); 040 String resourceName = resource.fhirType(); 041 042 List<SubscriptionTopic.SubscriptionTopicResourceTriggerComponent> triggers = myTopic.getResourceTrigger(); 043 for (SubscriptionTopic.SubscriptionTopicResourceTriggerComponent next : triggers) { 044 if (resourceName.equals(next.getResource())) { 045 SubscriptionTriggerMatcher matcher = 046 new SubscriptionTriggerMatcher(mySubscriptionTopicSupport, theMsg, next); 047 InMemoryMatchResult result = matcher.match(); 048 if (result.matched()) { 049 // as soon as one trigger matches, we're done 050 return result; 051 } 052 } 053 } 054 return InMemoryMatchResult.noMatch(); 055 } 056}