This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
from 7da727f Update .asf.yaml
new 587b8f0 style:code format.
new 0f0f15b style:code format.
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.asf.yaml | 8 +-
.github/workflows/license_checker.yaml | 2 +-
.licenserc.yaml | 2 +-
README.md | 55 +-
adapter/api/pom.xml | 3 +-
.../api/controller/ApiDestinationController.java | 21 +-
.../api/controller/ConnectionController.java | 258 +++++-----
.../adapter/api/controller/EventBusController.java | 5 +-
.../api/controller/EventDataController.java | 5 +-
.../api/controller/EventRuleController.java | 3 +-
.../api/controller/EventSourceController.java | 3 +-
.../api/controller/EventTargetController.java | 1 -
.../api/controller/EventTypeController.java | 5 +-
.../api/converter/CloudEventBatchedConverter.java | 89 ++--
.../api/converter/CloudEventBinaryConverter.java | 128 +++--
.../converter/CloudEventStructuredConverter.java | 99 ++--
.../adapter/api/converter/EventConverter.java | 8 +-
.../api/converter/EventConverterAdapter.java | 12 +-
.../api/converter/EventTargetConverter.java | 8 +-
.../api/converter/EventTargetDTOConverter.java | 7 -
.../adapter/api/converter/HttpEventConverter.java | 163 +++---
.../format/BatchedCloudEventDeserializer.java | 16 +-
.../format/BatchedCloudEventSerializer.java | 21 +-
.../api/converter/format/BatchedJsonFormat.java | 9 +-
.../eventbridge/adapter/api/dto/BaseRequest.java | 1 -
.../eventbridge/adapter/api/dto/BaseResponse.java | 5 +-
.../CreateApiDestinationRequest.java | 7 +-
.../CreateApiDestinationResponse.java | 1 -
.../DeleteApiDestinationRequest.java | 3 +-
.../apidestination/GetApiDestinationRequest.java | 3 +-
.../apidestination/GetApiDestinationResponse.java | 1 +
.../apidestination/ListApiDestinationsRequest.java | 5 +-
.../ListApiDestinationsResponse.java | 3 +-
.../UpdateApiDestinationRequest.java | 5 +-
.../adapter/api/dto/bus/CreateEventBusRequest.java | 4 +-
.../api/dto/bus/CreateEventBusResponse.java | 4 +-
.../adapter/api/dto/bus/DeleteEventBusRequest.java | 6 +-
.../api/dto/bus/DeleteEventBusResponse.java | 4 +-
.../adapter/api/dto/bus/EventBusDTO.java | 4 +-
.../adapter/api/dto/bus/GetEventBusRequest.java | 7 +-
.../adapter/api/dto/bus/GetEventBusResponse.java | 3 +-
.../adapter/api/dto/bus/ListEventBusesRequest.java | 4 +-
.../api/dto/bus/ListEventBusesResponse.java | 7 +-
.../dto/connection/CreateConnectionRequest.java | 7 +-
.../dto/connection/DeleteConnectionRequest.java | 3 +-
.../api/dto/connection/GetConnectionRequest.java | 3 +-
.../api/dto/connection/GetConnectionResponse.java | 3 +-
.../api/dto/connection/ListConnectionRequest.java | 5 +-
.../api/dto/connection/ListConnectionResponse.java | 3 +-
.../api/dto/connection/ListEnumsResponse.java | 3 +-
.../dto/connection/UpdateConnectionRequest.java | 3 +-
.../eventbridge/adapter/api/dto/data/EventDTO.java | 4 +-
.../adapter/api/dto/data/HttpEventData.java | 38 +-
.../adapter/api/dto/data/PutEventsRequest.java | 4 +-
.../adapter/api/dto/data/PutEventsResponse.java | 3 +-
.../adapter/api/dto/rule/CreateRuleRequest.java | 4 +-
.../adapter/api/dto/rule/CreateRuleResponse.java | 4 +-
.../adapter/api/dto/rule/DeleteRuleRequest.java | 4 +-
.../adapter/api/dto/rule/DisableRuleRequest.java | 4 +-
.../adapter/api/dto/rule/EnableRuleRequest.java | 4 +-
.../adapter/api/dto/rule/EventRuleDTO.java | 6 +-
.../adapter/api/dto/rule/GetRuleRequest.java | 4 +-
.../adapter/api/dto/rule/GetRuleResponse.java | 7 +-
.../adapter/api/dto/rule/ListRulesRequest.java | 4 +-
.../adapter/api/dto/rule/ListRulesResponse.java | 7 +-
.../adapter/api/dto/rule/UpdateRuleRequest.java | 4 +-
.../api/dto/source/CreateEventSourceRequest.java | 7 +-
.../api/dto/source/CreateEventSourceResponse.java | 4 +-
.../api/dto/source/DeleteEventSourceRequest.java | 4 +-
.../adapter/api/dto/source/EventSourceDTO.java | 7 +-
.../api/dto/source/GetEventSourceRequest.java | 4 +-
.../api/dto/source/GetEventSourceResponse.java | 7 +-
.../api/dto/source/ListEventSourcesRequest.java | 4 +-
.../api/dto/source/ListEventSourcesResponse.java | 7 +-
.../api/dto/source/UpdateEventSourceRequest.java | 7 +-
.../api/dto/source/UpdateEventSourceResponse.java | 3 +-
.../api/dto/target/CreateTargetsRequest.java | 7 +-
.../api/dto/target/CreateTargetsResponse.java | 3 +-
.../adapter/api/dto/target/DeadLetterQueueDTO.java | 9 +-
.../api/dto/target/DeleteTargetsRequest.java | 7 +-
.../api/dto/target/DeleteTargetsResponse.java | 3 +-
.../adapter/api/dto/target/EventTargetDTO.java | 7 +-
.../adapter/api/dto/target/ListTargetsRequest.java | 4 +-
.../api/dto/target/ListTargetsResponse.java | 7 +-
.../adapter/api/dto/target/RetryStrategyDTO.java | 4 +-
.../adapter/api/dto/target/RunOptionsDTO.java | 4 +-
.../api/dto/target/UpdateTargetsRequest.java | 7 +-
.../api/dto/target/UpdateTargetsResponse.java | 3 +-
.../adapter/api/dto/type/EventTypeDTO.java | 7 +-
.../api/dto/type/ListEventTypesRequest.java | 4 +-
.../api/dto/type/ListEventTypesResponse.java | 7 +-
.../adapter/api/handler/EventDataHandler.java | 99 ++--
.../adapter/api/handler/WebLogAspect.java | 2 +-
.../ApiDestinationDTOControllerTest.java | 15 +-
.../api/controller/ConnectionControllerTest.java | 33 +-
.../api/converter/EventConverterAdapterTest.java | 7 +-
.../api/converter/EventTargetConverterTest.java | 3 +-
.../api/converter/EventTargetDTOConverterTest.java | 2 -
.../adapter/api/handler/EventDataHandlerTest.java | 7 +-
adapter/persistence/pom.xml | 3 +-
.../mybatis/converter/ApiDestinationConverter.java | 3 +-
.../mybatis/dataobject/ApiDestinationDO.java | 42 +-
.../mybatis/mapper/EventApiDestinationMapper.java | 51 +-
.../MybatisApiDestinationRepository.java | 7 +-
.../bus/mybatis/mapper/EventBusMapper.java | 73 ++-
.../repository/MybatisEventBusRepository.java | 119 +++--
.../converter/EventSourceClassConverter.java | 93 ++--
.../converter/EventTargetClassConverter.java | 103 ++--
.../mybatis/dataobject/EventSourceClassDO.java | 5 +-
.../mybatis/dataobject/EventTargetClassDO.java | 5 +-
.../mybatis/mapper/EventSourceClassMapper.java | 8 +-
.../mybatis/mapper/EventTargetClassMapper.java | 9 +-
.../MybatisEventSourceClassRepository.java | 70 +--
.../MybatisEventTargetClassRepository.java | 70 +--
.../mybatis/converter/ConnectConverter.java | 7 +-
.../connect/mybatis/dataobject/ConnectionDO.java | 44 +-
.../mybatis/mapper/EventConnectionMapper.java | 39 +-
.../repository/MybatisConnectRepository.java | 9 +-
.../data/mybatis/dataobject/EventTopicDO.java | 5 +-
.../data/mybatis/mapper/EventTopicMapper.java | 50 +-
.../rocketmq/repository/BatchSendCallback.java | 48 --
.../rocketmq/repository/RocketMQMetaService.java | 4 +-
.../rule/mybatis/mapper/EventRuleMapper.java | 87 ++--
.../repository/MybatisEventRuleRepository.java | 129 +++--
.../mybatis/converter/EventSourceConverter.java | 8 +-
.../converter/EventSourceRunnerConverter.java | 12 +-
.../source/mybatis/dataobject/EventSourceDO.java | 5 +-
.../mybatis/dataobject/EventSourceRunnerDO.java | 5 +-
.../source/mybatis/mapper/EventSourceMapper.java | 91 ++--
.../mybatis/mapper/EventSourceRunnerMapper.java | 58 +--
.../repository/MybatisEventSourceRepository.java | 141 +++---
.../MybatisEventSourceRunnerRepository.java | 126 ++---
.../mybatis/converter/EventTargetConverter.java | 11 +-
.../converter/EventTargetRunnerConverter.java | 3 +-
.../target/mybatis/dataobject/EventTargetDO.java | 5 +-
.../mybatis/dataobject/EventTargetRunnerDO.java | 5 +-
.../target/mybatis/mapper/EventTargetMapper.java | 72 ++-
.../mybatis/mapper/EventTargetRunnerMapper.java | 75 ++-
.../repository/MybatisEventTargetRepository.java | 138 +++--
.../MybatisEventTargetRunnerRepository.java | 123 +++--
.../type/mybatis/mapper/EventTypeMapper.java | 85 ++--
.../repository/MybatisEventTypeRepository.java | 113 ++---
.../mybatis/EventApiDestinationMapper.xml | 562 +++++++++++----------
.../resources/mybatis/EventConnectionMapper.xml | 557 ++++++++++----------
adapter/pom.xml | 3 +-
adapter/rpc/pom.xml | 3 +-
.../adapter/rpc/impl/AppConfigAPIImpl.java | 3 +-
.../adapter/rpc/impl/HttpEventAPIImpl.java | 20 +-
.../adapter/rpc/impl/RocketMQEventDataAPIImpl.java | 14 +-
.../adapter/rpc/impl/SecretManagerAPIImpl.java | 6 +-
.../rpc/impl/connect/RocketMQConnectClient.java | 4 +-
.../RocketMQConnectSourceRunnerAPIImpl.java | 3 +-
.../RocketMQConnectTargetRunnerAPIImpl.java | 3 +-
.../rpc/impl/connect/RocketMQConverter.java | 9 +-
.../RocketMQConnectSourceRunnerContext.java | 4 +-
.../connect/dto/CreateSinkConnectorRequest.java | 3 +-
.../connect/dto/CreateSourceConnectorRequest.java | 4 +-
.../rpc/impl/connect/dto/TransformRequest.java | 4 +-
.../rpc/impl/network/NetworkServiceAPIImpl.java | 1 -
common/pom.xml | 3 +-
.../rocketmq/eventbridge/config/GlobalConfig.java | 6 +-
.../rocketmq/eventbridge/config/LocalConfig.java | 4 +-
.../eventbridge/event/EventBridgeEvent.java | 9 +-
.../exception/EventBridgeException.java | 1 -
.../rocketmq/eventbridge/tools/EventTool.java | 5 +-
.../rocketmq/eventbridge/tools/JsonUtil.java | 7 +-
.../apache/rocketmq/eventbridge/tools/NetUtil.java | 3 +-
.../rocketmq/eventbridge/tools/TokenUtil.java | 1 +
.../tools/pattern/ComplexConditionBuilders.java | 3 +-
.../pattern/InvalidEventPatternException.java | 4 +-
.../tools/pattern/NumericOperators.java | 3 +-
.../tools/pattern/PatternCondition.java | 8 +-
.../tools/pattern/PatternConditionBuilder.java | 12 +-
.../eventbridge/tools/pattern/PatternEntry.java | 4 +-
.../tools/pattern/PatternEvaluator.java | 13 +-
.../tools/pattern/PatternEvaluatorBuilder.java | 12 +-
.../tools/transform/ConstantTransform.java | 1 -
.../tools/transform/DeleteFieldTransform.java | 11 +-
.../eventbridge/tools/transform/Extract.java | 3 -
.../tools/transform/InsertFieldTransform.java | 14 +-
.../tools/transform/JsonPathExtract.java | 22 +-
.../tools/transform/JsonPathTransform.java | 4 +-
.../eventbridge/tools/transform/JsonPathUtil.java | 15 +-
.../eventbridge/tools/transform/JsonUtil.java | 13 +-
.../eventbridge/tools/transform/ObjectUtil.java | 4 +-
.../tools/transform/RegularExtract.java | 2 +-
.../tools/transform/StringSubstitutorTemplate.java | 15 +-
.../eventbridge/tools/transform/Template.java | 3 -
.../tools/transform/TemplateBuilder.java | 1 -
.../tools/transform/TemplateTransform.java | 4 +-
.../eventbridge/tools/transform/Transform.java | 9 +-
.../tools/transform/TransformBuilder.java | 6 -
.../tools/transform/TransformErrorCode.java | 6 +-
.../tools/transform/TransformValidator.java | 4 +-
.../tools/transform/UpdateFieldTransform.java | 16 +-
.../tools/pattern/PatternEvaluatorBuilderTest.java | 9 +-
.../tools/pattern/PatternEvaluatorTest.java | 3 +-
.../tools/transform/BaseTransformTest.java | 1 -
.../tools/transform/DeleteFieldTransformTest.java | 14 +-
.../tools/transform/InsertFieldTransformTest.java | 19 +-
.../tools/transform/JsonPathExtractTest.java | 1 -
.../tools/transform/OriginalTransformTest.java | 1 -
.../TemplateTransformFromJsonStringTest.java | 1 +
.../tools/transform/UpdateFieldTransformTest.java | 20 +-
domain/README-CN.md | 14 +-
domain/pom.xml | 3 +-
.../eventbridge/domain/cache/CacheManager.java | 57 +--
.../eventbridge/domain/cache/CacheName.java | 37 +-
.../domain/cache/GeneralKeyGenerator.java | 40 +-
.../domain/common/EventBridgeConstants.java | 3 +-
.../eventbridge/domain/common/enums/CacheEnum.java | 38 +-
.../domain/common/enums/EventRuleStatusEnum.java | 32 +-
.../domain/common/enums/NetworkTypeEnum.java | 1 +
.../common/exception/EventBridgeErrorCode.java | 10 +-
.../domain/model/AbstractResourceService.java | 3 +-
.../domain/model/AbstractRunnerService.java | 3 -
.../eventbridge/domain/model/Component.java | 5 +-
.../eventbridge/domain/model/PaginationResult.java | 4 +-
.../model/apidestination/ApiDestinationDTO.java | 41 +-
.../apidestination/ApiDestinationService.java | 10 +-
.../parameter/HttpApiParameters.java | 5 +-
.../eventbridge/domain/model/bus/EventBus.java | 5 +-
.../domain/model/bus/EventBusService.java | 181 ++++---
.../domain/model/classes/APIAttribute.java | 4 +-
.../domain/model/classes/EventSourceClass.java | 5 +-
.../model/classes/EventSourceClassService.java | 3 +-
.../domain/model/classes/EventTargetClass.java | 5 +-
.../model/classes/EventTargetClassService.java | 3 +-
.../domain/model/connection/ConnectionDTO.java | 5 +-
.../domain/model/connection/ConnectionService.java | 31 +-
.../connection/parameter/HeaderParameter.java | 2 +-
.../parameter/InvocationHttpParameters.java | 3 +-
.../connection/parameter/NetworkParameters.java | 3 +-
.../connection/parameter/OAuthHttpParameters.java | 3 +-
.../domain/model/data/PutEventsResponseEntry.java | 4 +-
.../eventbridge/domain/model/rule/EventRule.java | 5 +-
.../domain/model/rule/EventRuleDetail.java | 65 ++-
.../domain/model/rule/EventRuleService.java | 264 +++++-----
.../domain/model/run/DeadLetterQueue.java | 5 +-
.../domain/model/run/EventSourceRunner.java | 6 +-
.../domain/model/run/EventSourceRunnerService.java | 165 +++---
.../domain/model/run/EventTargetRunner.java | 6 +-
.../domain/model/run/EventTargetRunnerService.java | 276 +++++-----
.../domain/model/run/RetryStrategy.java | 4 +-
.../eventbridge/domain/model/run/RunOptions.java | 4 +-
.../model/source/ConnectEventSourceService.java | 5 +-
.../domain/model/source/EventSource.java | 5 +-
.../domain/model/source/EventSourceService.java | 247 +++++----
.../model/source/EventSourceServiceFactory.java | 115 +++--
.../eventbridge/domain/model/source/EventType.java | 6 +-
.../domain/model/source/EventTypeService.java | 123 +++--
.../model/source/HTTPEventSourceService.java | 65 ++-
.../domain/model/target/EventTarget.java | 5 +-
.../domain/model/target/EventTargetService.java | 353 +++++++------
.../repository/ApiDestinationRepository.java | 5 +-
.../domain/repository/ConnectionRepository.java | 5 +-
.../domain/repository/EventBusRepository.java | 1 -
.../domain/repository/EventDataRepository.java | 4 -
.../domain/repository/EventRuleRepository.java | 1 -
.../domain/repository/EventSourceRepository.java | 1 -
.../domain/repository/EventTargetRepository.java | 4 +-
.../repository/EventTargetRunnerRepository.java | 1 -
.../domain/repository/EventTypeRepository.java | 1 -
.../eventbridge/domain/rpc/AccountAPI.java | 3 -
.../eventbridge/domain/rpc/HttpEventAPI.java | 19 +-
.../eventbridge/domain/rpc/SecretManagerAPI.java | 5 +-
.../eventbridge/domain/rpc/SourceRunnerAPI.java | 7 +-
.../eventbridge/domain/rpc/TargetRunnerAPI.java | 1 -
.../domain/service/EventBusDomainService.java | 102 ++--
.../domain/service/EventRuleDomainService.java | 147 +++---
.../domain/model/EventBusServiceTest.java | 4 +-
.../domain/model/EventRuleServiceTest.java | 4 +-
.../domain/model/EventSourceClassServiceTest.java | 4 +-
.../model/EventSourceServiceFactoryTest.java | 3 +-
.../model/EventTargetRunnerClassServiceTest.java | 3 +-
.../service/ApiDestinationDTOServiceTest.java | 9 +-
.../domain/service/ConnectionServiceTest.java | 7 +-
pom.xml | 23 +-
start/README-CN.md | 14 +-
start/pom.xml | 3 +-
.../rocketmq/eventbridge/config/SwaggerConfig.java | 1 -
.../eventbridge/config/ValidatorConfiguration.java | 13 +-
.../rocketmq/eventbridge/filter/LoginFilter.java | 113 ++---
.../eventbridge/handler/ExceptionHandler.java | 10 +-
start/src/main/resources/logback-spring.xml | 8 +-
start/src/test/resources/application.properties | 1 -
style/copyright/Apache.xml | 5 +-
style/copyright/profiles_settings.xml | 4 +-
style/rmq_checkstyle.xml | 6 +-
style/rmq_codeStyle.xml | 249 +++++----
.../transform/eventbridge/CloudEventTransform.java | 4 +-
supports/connect-eventbridge-transform/pom.xml | 3 +-
.../eventbridge/ConnectRecordJsonPathExtract.java | 6 +-
.../eventbridge/EventBridgeTransform.java | 4 +-
.../eventbridge/EventBridgeTransformBuilder.java | 4 -
supports/connect-filter-transform/pom.xml | 3 +-
296 files changed, 3982 insertions(+), 4246 deletions(-)
delete mode 100644
adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/data/rocketmq/repository/BatchSendCallback.java
