@Test(expected = ResourceNotFoundException.class) public void testCreateProcessorWhenFlowDoesNotExist() { final String flowId = "DOES-NOT-EXIST"; when(flowManager.getFlow(flowId)).thenReturn(Optional.empty()); processorService.create(flowId, "pgId", new VersionedProcessor()); }
@Override public FDProcessor create(final String flowId, final String processGroupId, final VersionedProcessor requestComponentConfig) { final FDFlow currentFlow = getFlowOrNotFound(flowId); validateRequestValues(requestComponentConfig); final String requestType = requestComponentConfig.getType(); final Bundle requestBundle = requestComponentConfig.getBundle(); final FDProcessor createdComponent = createExtensionComponent( currentFlow, processGroupId, requestType, requestComponentConfig, (em) -> em.createProcessor(requestType, requestBundle), VersionedProcessGroup::getProcessors, this::validate ); ComponentUtils.populateControllerServicePropertyDescriptors(currentFlow, processGroupId, createdComponent.getComponentDefinition()); return createdComponent; }
StandardFDProcessorService extends BaseExtensionComponentService<VersionedProcessor, ProcessorDefinition, FDProcessor> implements FDProcessorService { @Override public FDProcessor create(final String flowId, final String processGroupId, final VersionedProcessor requestComponentConfig) { final FDFlow currentFlow = getFlowOrNotFound(flowId); validateRequestValues(requestComponentConfig); final String requestType = requestComponentConfig.getType(); final Bundle requestBundle = requestComponentConfig.getBundle(); final FDProcessor createdComponent = createExtensionComponent( currentFlow, processGroupId, requestType, requestComponentConfig, (em) -> em.createProcessor(requestType, requestBundle), VersionedProcessGroup::getProcessors, this::validate ); ComponentUtils.populateControllerServicePropertyDescriptors(currentFlow, processGroupId, createdComponent.getComponentDefinition()); return createdComponent; } }
StandardFDProcessorService extends BaseExtensionComponentService<VersionedProcessor, ProcessorDefinition, FDProcessor> implements FDProcessorService { @Override public FDProcessor create(final String flowId, final String processGroupId, final VersionedProcessor requestComponentConfig) { final FDFlow currentFlow = getFlowOrNotFound(flowId); validateRequestValues(requestComponentConfig); final String requestType = requestComponentConfig.getType(); final Bundle requestBundle = requestComponentConfig.getBundle(); final FDProcessor createdComponent = createExtensionComponent( currentFlow, processGroupId, requestType, requestComponentConfig, (em) -> em.createProcessor(requestType, requestBundle), VersionedProcessGroup::getProcessors, this::validate ); ComponentUtils.populateControllerServicePropertyDescriptors(currentFlow, processGroupId, createdComponent.getComponentDefinition()); return createdComponent; } @Autowired  StandardFDProcessorService(final FDFlowManager flowManager, final FDExtensionManagers extensionManagers, final ValidationService validationService); }
StandardFDProcessorService extends BaseExtensionComponentService<VersionedProcessor, ProcessorDefinition, FDProcessor> implements FDProcessorService { @Override public FDProcessor create(final String flowId, final String processGroupId, final VersionedProcessor requestComponentConfig) { final FDFlow currentFlow = getFlowOrNotFound(flowId); validateRequestValues(requestComponentConfig); final String requestType = requestComponentConfig.getType(); final Bundle requestBundle = requestComponentConfig.getBundle(); final FDProcessor createdComponent = createExtensionComponent( currentFlow, processGroupId, requestType, requestComponentConfig, (em) -> em.createProcessor(requestType, requestBundle), VersionedProcessGroup::getProcessors, this::validate ); ComponentUtils.populateControllerServicePropertyDescriptors(currentFlow, processGroupId, createdComponent.getComponentDefinition()); return createdComponent; } @Autowired  StandardFDProcessorService(final FDFlowManager flowManager, final FDExtensionManagers extensionManagers, final ValidationService validationService); @Override FDComponentTypes getProcessorTypes(final String flowId); @Override FDPropertyDescriptor getPropertyDescriptor(final String flowId, final String processorId, final String propertyName); @Override FDProcessor create(final String flowId, final String processGroupId, final VersionedProcessor requestComponentConfig); @Override FDProcessor get(final String flowId, final String processorId); @Override FDProcessor update(final String flowId, final VersionedProcessor requestComponentConfig); @Override void delete(final String flowId, final String processorId); @Override ProcessorDefinition getComponentDefinition(final String agentClass, final VersionedProcessor componentConfig); }
StandardFDProcessorService extends BaseExtensionComponentService<VersionedProcessor, ProcessorDefinition, FDProcessor> implements FDProcessorService { @Override public FDProcessor create(final String flowId, final String processGroupId, final VersionedProcessor requestComponentConfig) { final FDFlow currentFlow = getFlowOrNotFound(flowId); validateRequestValues(requestComponentConfig); final String requestType = requestComponentConfig.getType(); final Bundle requestBundle = requestComponentConfig.getBundle(); final FDProcessor createdComponent = createExtensionComponent( currentFlow, processGroupId, requestType, requestComponentConfig, (em) -> em.createProcessor(requestType, requestBundle), VersionedProcessGroup::getProcessors, this::validate ); ComponentUtils.populateControllerServicePropertyDescriptors(currentFlow, processGroupId, createdComponent.getComponentDefinition()); return createdComponent; } @Autowired  StandardFDProcessorService(final FDFlowManager flowManager, final FDExtensionManagers extensionManagers, final ValidationService validationService); @Override FDComponentTypes getProcessorTypes(final String flowId); @Override FDPropertyDescriptor getPropertyDescriptor(final String flowId, final String processorId, final String propertyName); @Override FDProcessor create(final String flowId, final String processGroupId, final VersionedProcessor requestComponentConfig); @Override FDProcessor get(final String flowId, final String processorId); @Override FDProcessor update(final String flowId, final VersionedProcessor requestComponentConfig); @Override void delete(final String flowId, final String processorId); @Override ProcessorDefinition getComponentDefinition(final String agentClass, final VersionedProcessor componentConfig);  }