This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a change to branch runtimer
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
from 001776c adjust logic
new 62b6c05 1.add embedded database 2.add default validateFilter
new b634ba9 1.add h2 db migration file directory
new 9d7b87e 1.add readme 2.modify ValidateFilter, add default filter
new d03c361 1.merge h2-migration and migration
The 4 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:
adapter/persistence/pom.xml | 5 +
.../adapter/persistence/DatasourceConfig.java | 110 +++++++++++++++++++++
.../adapter/persistence/PersistenceConfig.java | 2 -
.../MybatisEventTargetRunnerRepository.java | 5 +
.../main/resources/db/migration/V1__baseline.sql | 76 +++++++-------
.../main/resources/db/migration/V2__baseline.sql | 42 ++++----
.../migration/V3__change_target_transform_type.sql | 30 +++---
.../db/migration/V4__register_source_acs_mns.sql | 30 +++---
.../migration/V5__register_target_acs_dingtalk.sql | 30 +++---
.../V6__register_target_acs_eventbridge.sql | 30 +++---
...V7__update_event_connection_table_structure.sql | 35 +++----
.../db/migration/V8__update_unique_key.sql | 40 ++++----
.../rocketmq/impl/RocketMQEventDataRepository.java | 6 +-
.../eventbridge/enums/props/Constants.java | 24 +++--
.../ServiceProviderNotFoundException.java} | 27 ++---
docs/cn/RocketMQEventBridgeDatabaseUsage.md | 29 ++++++
docs/cn/RocketMQEventBridgeRuleValidation.md | 44 +++++++++
docs/cn/images/h2.png | Bin 0 -> 188366 bytes
infrastructure/pom.xml | 11 +++
.../infrastructure/validate/AuthValidation.java | 25 +++--
.../validate/DefaultAuthValidation.java | 47 +++++++++
.../validate/spi/ServiceLifecycle.java | 31 ++++++
.../validate/spi/ValidationServiceFactory.java | 47 +++++++++
.../validate/spi/ValidationServiceLoader.java | 91 +++++++++++++++++
.../validate/spi/annotation/SingletonSPI.java | 11 ++-
.../validate/spi/typed/TypedSPI.java | 28 ++++--
.../validate/spi/typed/TypedSPIRegistry.java | 79 +++++++++++++++
...ntbridge.infrastructure.validate.AuthValidation | 6 +-
.../eventbridge/config/H2ServerConfig.java | 31 +++---
.../rocketmq/eventbridge/filter/LoginFilter.java | 26 ++---
.../eventbridge/filter/ValidateFilter.java | 69 +++++++++++++
start/src/main/resources/application.properties | 10 +-
32 files changed, 841 insertions(+), 236 deletions(-)
create mode 100644
adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/DatasourceConfig.java
copy
adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/TransformRequest.java
=>
common/src/main/java/org/apache/rocketmq/eventbridge/enums/props/Constants.java
(67%)
copy
common/src/{test/java/org/apache/rocketmq/eventbridge/tools/transform/OriginalTransformTest.java
=>
main/java/org/apache/rocketmq/eventbridge/exception/ServiceProviderNotFoundException.java}
(60%)
create mode 100644 docs/cn/RocketMQEventBridgeDatabaseUsage.md
create mode 100644 docs/cn/RocketMQEventBridgeRuleValidation.md
create mode 100644 docs/cn/images/h2.png
copy
adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/network/NetworkServiceAPIImpl.java
=>
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/AuthValidation.java
(60%)
create mode 100644
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/DefaultAuthValidation.java
create mode 100644
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/ServiceLifecycle.java
create mode 100644
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/ValidationServiceFactory.java
create mode 100644
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/ValidationServiceLoader.java
copy
adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/annotations/WebLog.java
=>
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/annotation/SingletonSPI.java
(84%)
copy
common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/PatternType.java
=>
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/typed/TypedSPI.java
(65%)
create mode 100644
infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/typed/TypedSPIRegistry.java
copy
adapter/persistence/src/main/resources/db/migration/V3__change_target_transform_type.sql
=>
infrastructure/src/main/resources/META-INF/services/org.apache.rocketmq.eventbridge.infrastructure.validate.AuthValidation
(87%)
copy
common/src/main/java/org/apache/rocketmq/eventbridge/config/AppConfig.java =>
start/src/main/java/org/apache/rocketmq/eventbridge/config/H2ServerConfig.java
(52%)
create mode 100644
start/src/main/java/org/apache/rocketmq/eventbridge/filter/ValidateFilter.java
