rename package (#465)

This commit is contained in:
dxfeng10
2023-02-03 16:01:38 +08:00
committed by GitHub
parent f513623030
commit 470e31ccc8
366 changed files with 1520 additions and 1524 deletions

View File

@@ -24,7 +24,7 @@
<dependency>
<groupId>com.networknt</groupId>
<artifactId>json-schema-validator-i18n-support</artifactId>
<version>1.0.39_5</version>
<version>1.0.39_6</version>
<scope>provided</scope>
</dependency>

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we;
package com.fizzgate;
import org.springframework.context.ConfigurableApplicationContext;

View File

@@ -15,12 +15,12 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we;
package com.fizzgate;
import org.springframework.context.ConfigurableApplicationContext;
/**
* @deprecated and use {@link we.Fizz} instead
* @deprecated and use {@link com.fizzgate.Fizz} instead
*/
@Deprecated

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.apollo;
package com.fizzgate.apollo;
import com.ctrip.framework.apollo.Config;
import com.ctrip.framework.apollo.ConfigChangeListener;

View File

@@ -15,9 +15,15 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.beans.factory.config;
package com.fizzgate.beans.factory.config;
import com.fasterxml.jackson.core.type.TypeReference;
import com.fizzgate.config.FizzConfigConfiguration;
import com.fizzgate.config.RedisReactiveProperties;
import com.fizzgate.context.config.annotation.FizzRefreshScope;
import com.fizzgate.context.event.FizzRefreshEvent;
import com.fizzgate.util.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeansException;
@@ -37,11 +43,6 @@ import org.springframework.core.env.MutablePropertySources;
import org.springframework.data.redis.core.ReactiveStringRedisTemplate;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import we.config.FizzConfigConfiguration;
import we.config.RedisReactiveProperties;
import we.context.config.annotation.FizzRefreshScope;
import we.context.event.FizzRefreshEvent;
import we.util.*;
import java.util.*;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.beans.factory.config;
package com.fizzgate.beans.factory.config;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.config;
package com.fizzgate.config;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
@@ -32,8 +32,11 @@ import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSeriali
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import org.springframework.session.data.redis.config.annotation.SpringSessionRedisConnectionFactory;
import we.log.LogSendAppender;
import we.log.RedisLogSendServiceImpl;
import com.fizzgate.config.RedisReactiveConfig;
import com.fizzgate.config.RedisReactiveProperties;
import com.fizzgate.log.LogSendAppender;
import com.fizzgate.log.RedisLogSendServiceImpl;
import javax.annotation.Resource;

View File

@@ -15,13 +15,14 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.config;
package com.fizzgate.config;
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.stereotype.Component;
import we.context.config.annotation.FizzRefreshScope;
import com.fizzgate.context.config.annotation.FizzRefreshScope;
/**
* {@link AggregateRedisConfig} properties

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.config;
package com.fizzgate.config;
import com.ctrip.framework.apollo.spring.annotation.EnableApolloConfig;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.config;
package com.fizzgate.config;
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;

View File

@@ -15,13 +15,14 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.config;
package com.fizzgate.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import we.beans.factory.config.FizzBeanFactoryPostProcessor;
import we.context.event.FizzRefreshEventListener;
import we.context.scope.refresh.FizzRefreshScope;
import com.fizzgate.beans.factory.config.FizzBeanFactoryPostProcessor;
import com.fizzgate.context.event.FizzRefreshEventListener;
import com.fizzgate.context.scope.refresh.FizzRefreshScope;
import java.util.HashMap;
import java.util.Map;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.config;
package com.fizzgate.config;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -27,12 +27,14 @@ import org.springframework.core.env.ConfigurableEnvironment;
import org.springframework.data.redis.core.ReactiveStringRedisTemplate;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.util.CollectionUtils;
import we.stats.FlowStat;
import we.stats.ResourceTimeWindowStat;
import we.stats.TimeWindowStat;
import we.util.JacksonUtils;
import we.util.NetworkUtils;
import we.util.ResourceIdUtils;
import com.fizzgate.config.SchedConfig;
import com.fizzgate.stats.FlowStat;
import com.fizzgate.stats.ResourceTimeWindowStat;
import com.fizzgate.stats.TimeWindowStat;
import com.fizzgate.util.JacksonUtils;
import com.fizzgate.util.NetworkUtils;
import com.fizzgate.util.ResourceIdUtils;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;

View File

@@ -15,15 +15,17 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.config;
package com.fizzgate.config;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.core.ReactiveStringRedisTemplate;
import com.fizzgate.util.Consts;
import com.fizzgate.util.Result;
import reactor.core.publisher.Mono;
import we.util.Consts;
import we.util.Result;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;

View File

@@ -15,13 +15,14 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.config;
package com.fizzgate.config;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import we.stats.FlowStat;
import we.stats.circuitbreaker.CircuitBreakManager;
import com.fizzgate.stats.FlowStat;
import com.fizzgate.stats.circuitbreaker.CircuitBreakManager;
/**
* @author hongqiaowei

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.config;
package com.fizzgate.config;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -23,12 +23,14 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.core.ReactiveStringRedisTemplate;
import org.springframework.scheduling.annotation.Scheduled;
import we.stats.FlowStat;
import we.stats.ResourceTimeWindowStat;
import we.stats.TimeWindowStat;
import we.stats.ratelimit.ResourceRateLimitConfig;
import we.stats.ratelimit.ResourceRateLimitConfigService;
import we.util.*;
import com.fizzgate.config.SchedConfig;
import com.fizzgate.stats.FlowStat;
import com.fizzgate.stats.ResourceTimeWindowStat;
import com.fizzgate.stats.TimeWindowStat;
import com.fizzgate.stats.ratelimit.ResourceRateLimitConfig;
import com.fizzgate.stats.ratelimit.ResourceRateLimitConfigService;
import com.fizzgate.util.*;
import javax.annotation.Resource;
import java.math.BigDecimal;

View File

@@ -14,7 +14,7 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.config;
package com.fizzgate.config;
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;

View File

@@ -0,0 +1,2 @@
package com.fizzgate.config;

View File

@@ -15,11 +15,12 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.config;
package com.fizzgate.config;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import we.plugin.auth.*;
import com.fizzgate.plugin.auth.*;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;

View File

@@ -15,13 +15,15 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.config;
package com.fizzgate.config;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.reactive.function.client.WebClient;
import com.fizzgate.config.WebClientConfig;
/**
* @author hongqiaowei
*/

View File

@@ -14,22 +14,23 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.config;
package com.fizzgate.config;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.Scheduled;
import we.fizz.ConfigLoader;
import we.plugin.auth.ApiConfig2appsService;
import we.plugin.auth.ApiConfigService;
import we.plugin.auth.AppService;
import we.plugin.auth.GatewayGroupService;
import we.proxy.RpcInstanceService;
import we.service_registry.RegistryCenterService;
import we.stats.degrade.DegradeRuleService;
import we.stats.ratelimit.ResourceRateLimitConfigService;
import we.util.Result;
import com.fizzgate.fizz.ConfigLoader;
import com.fizzgate.plugin.auth.ApiConfig2appsService;
import com.fizzgate.plugin.auth.ApiConfigService;
import com.fizzgate.plugin.auth.AppService;
import com.fizzgate.plugin.auth.GatewayGroupService;
import com.fizzgate.proxy.RpcInstanceService;
import com.fizzgate.service_registry.RegistryCenterService;
import com.fizzgate.stats.degrade.DegradeRuleService;
import com.fizzgate.stats.ratelimit.ResourceRateLimitConfigService;
import com.fizzgate.util.Result;
import javax.annotation.Resource;

View File

@@ -14,7 +14,7 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.config;
package com.fizzgate.config;
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.config;
package com.fizzgate.config;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
@@ -24,10 +24,11 @@ import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.stereotype.Component;
import org.springframework.util.ObjectUtils;
import we.context.config.annotation.FizzRefreshScope;
import we.util.Consts;
import we.util.UUIDUtil;
import we.util.WebUtils;
import com.fizzgate.context.config.annotation.FizzRefreshScope;
import com.fizzgate.util.Consts;
import com.fizzgate.util.UUIDUtil;
import com.fizzgate.util.WebUtils;
import javax.annotation.PostConstruct;
import java.util.*;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.config;
package com.fizzgate.config;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.config;
package com.fizzgate.config;
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;

View File

@@ -15,11 +15,12 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.context.config.annotation;
package com.fizzgate.context.config.annotation;
import org.springframework.context.annotation.Scope;
import org.springframework.context.annotation.ScopedProxyMode;
import we.config.FizzConfigConfiguration;
import com.fizzgate.config.FizzConfigConfiguration;
import java.lang.annotation.*;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.context.event;
package com.fizzgate.context.event;
import org.springframework.context.ApplicationEvent;
import org.springframework.context.event.SmartApplicationListener;

View File

@@ -15,10 +15,11 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.context.event;
package com.fizzgate.context.event;
import org.springframework.context.ApplicationEvent;
import we.util.JacksonUtils;
import com.fizzgate.util.JacksonUtils;
/**
* @author hongqiaowei

View File

@@ -15,16 +15,17 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.context.event;
package com.fizzgate.context.event;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.context.event.ApplicationReadyEvent;
import org.springframework.context.ApplicationEvent;
import org.springframework.context.event.SmartApplicationListener;
import we.beans.factory.config.FizzBeanFactoryPostProcessor;
import we.context.scope.refresh.FizzRefreshScope;
import we.util.JacksonUtils;
import com.fizzgate.beans.factory.config.FizzBeanFactoryPostProcessor;
import com.fizzgate.context.scope.refresh.FizzRefreshScope;
import com.fizzgate.util.JacksonUtils;
import java.util.HashMap;
import java.util.Map;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.context.scope.refresh;
package com.fizzgate.context.scope.refresh;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.config.BeanDefinition;
@@ -28,7 +28,8 @@ import org.springframework.context.event.ContextRefreshedEvent;
import org.springframework.core.Ordered;
import org.springframework.jmx.export.annotation.ManagedOperation;
import org.springframework.jmx.export.annotation.ManagedResource;
import we.config.FizzConfigConfiguration;
import com.fizzgate.config.FizzConfigConfiguration;
/**
* @author hongqiaowei

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.context.scope.refresh;
package com.fizzgate.context.scope.refresh;
import org.springframework.context.ApplicationEvent;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.controller;
package com.fizzgate.controller;
import org.openjdk.jol.info.GraphLayout;
import org.springframework.beans.factory.annotation.Autowired;
@@ -23,20 +23,22 @@ import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.server.ServerWebExchange;
import com.fizzgate.global_resource.GlobalResourceService;
import com.fizzgate.plugin.auth.ApiConfig2appsService;
import com.fizzgate.plugin.auth.ApiConfigService;
import com.fizzgate.plugin.auth.AppService;
import com.fizzgate.plugin.auth.GatewayGroupService;
import com.fizzgate.stats.FlowStat;
import com.fizzgate.stats.ResourceStat;
import com.fizzgate.stats.circuitbreaker.CircuitBreakManager;
import com.fizzgate.stats.ratelimit.ResourceRateLimitConfig;
import com.fizzgate.stats.ratelimit.ResourceRateLimitConfigService;
import com.fizzgate.util.Consts;
import com.fizzgate.util.JacksonUtils;
import com.fizzgate.util.ResourceIdUtils;
import reactor.core.publisher.Mono;
import we.global_resource.GlobalResourceService;
import we.plugin.auth.ApiConfig2appsService;
import we.plugin.auth.ApiConfigService;
import we.plugin.auth.AppService;
import we.plugin.auth.GatewayGroupService;
import we.stats.FlowStat;
import we.stats.ResourceStat;
import we.stats.circuitbreaker.CircuitBreakManager;
import we.stats.ratelimit.ResourceRateLimitConfig;
import we.stats.ratelimit.ResourceRateLimitConfigService;
import we.util.Consts;
import we.util.JacksonUtils;
import we.util.ResourceIdUtils;
import javax.annotation.Resource;
import java.math.BigDecimal;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.controller;
package com.fizzgate.controller;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -26,13 +26,15 @@ import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.server.ServerWebExchange;
import com.fizzgate.proxy.CallbackReplayReq;
import com.fizzgate.proxy.CallbackService;
import com.fizzgate.util.Consts;
import com.fizzgate.util.JacksonUtils;
import com.fizzgate.util.Result;
import com.fizzgate.util.ThreadContext;
import reactor.core.publisher.Mono;
import we.proxy.CallbackReplayReq;
import we.proxy.CallbackService;
import we.util.Consts;
import we.util.JacksonUtils;
import we.util.Result;
import we.util.ThreadContext;
import javax.annotation.Resource;

View File

@@ -15,15 +15,17 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.controller;
package com.fizzgate.controller;
import org.apache.commons.io.FileUtils;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.server.ServerWebExchange;
import com.fizzgate.fizz.ConfigLoader;
import com.fizzgate.util.ScriptUtils;
import reactor.core.publisher.Mono;
import we.fizz.ConfigLoader;
import we.util.ScriptUtils;
import javax.annotation.Resource;
import java.io.File;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.controller;
package com.fizzgate.controller;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -27,15 +27,17 @@ import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.server.ServerWebExchange;
import com.fizzgate.stats.FlowStat;
import com.fizzgate.stats.ResourceTimeWindowStat;
import com.fizzgate.stats.TimeWindowStat;
import com.fizzgate.stats.ratelimit.ResourceRateLimitConfig;
import com.fizzgate.util.Consts;
import com.fizzgate.util.DateTimeUtils;
import com.fizzgate.util.JacksonUtils;
import com.fizzgate.util.ResourceIdUtils;
import reactor.core.publisher.Mono;
import we.stats.FlowStat;
import we.stats.ResourceTimeWindowStat;
import we.stats.TimeWindowStat;
import we.stats.ratelimit.ResourceRateLimitConfig;
import we.util.Consts;
import we.util.DateTimeUtils;
import we.util.JacksonUtils;
import we.util.ResourceIdUtils;
import java.math.BigDecimal;
import java.util.HashMap;

View File

@@ -15,15 +15,17 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.controller;
package com.fizzgate.controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.server.ServerWebExchange;
import com.fizzgate.util.Consts;
import com.fizzgate.util.DateTimeUtils;
import reactor.core.publisher.Mono;
import we.util.Consts;
import we.util.DateTimeUtils;
/**
* @author hongqiaowei

View File

@@ -15,8 +15,25 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.controller;
package com.fizzgate.controller;
import com.fizzgate.controller.req.BaseManagerConfigReq;
import com.fizzgate.controller.req.GetApiConfigDetailReq;
import com.fizzgate.controller.req.GetApiConfigReq;
import com.fizzgate.controller.req.GetConfigReq;
import com.fizzgate.controller.req.GetConfigStrReq;
import com.fizzgate.controller.resp.ApiConfigInfo;
import com.fizzgate.controller.resp.ConfigResp;
import com.fizzgate.controller.resp.ConfigStrResp;
import com.fizzgate.controller.resp.GetApiConfigDetailResp;
import com.fizzgate.controller.resp.GetApiConfigResp;
import com.fizzgate.fizz.ConfigLoader;
import com.fizzgate.plugin.PluginConfig;
import com.fizzgate.plugin.auth.ApiConfig;
import com.fizzgate.plugin.auth.ApiConfig2appsService;
import com.fizzgate.plugin.auth.ApiConfigService;
import com.fizzgate.plugin.auth.GatewayGroup;
import com.fizzgate.plugin.auth.GatewayGroupService;
import com.google.common.collect.Sets;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
@@ -28,23 +45,6 @@ import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Mono;
import we.controller.req.BaseManagerConfigReq;
import we.controller.req.GetApiConfigDetailReq;
import we.controller.req.GetApiConfigReq;
import we.controller.req.GetConfigReq;
import we.controller.req.GetConfigStrReq;
import we.controller.resp.ApiConfigInfo;
import we.controller.resp.ConfigResp;
import we.controller.resp.ConfigStrResp;
import we.controller.resp.GetApiConfigDetailResp;
import we.controller.resp.GetApiConfigResp;
import we.fizz.ConfigLoader;
import we.plugin.PluginConfig;
import we.plugin.auth.ApiConfig;
import we.plugin.auth.ApiConfig2appsService;
import we.plugin.auth.ApiConfigService;
import we.plugin.auth.GatewayGroup;
import we.plugin.auth.GatewayGroupService;
import javax.annotation.Resource;
import javax.validation.Valid;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.controller.req;
package com.fizzgate.controller.req;
import javax.validation.constraints.NotNull;
import java.io.Serializable;

View File

@@ -14,7 +14,7 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.controller.req;
package com.fizzgate.controller.req;
import lombok.Data;
import lombok.EqualsAndHashCode;

View File

@@ -14,7 +14,7 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.controller.req;
package com.fizzgate.controller.req;
import lombok.Data;
import lombok.EqualsAndHashCode;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.controller.req;
package com.fizzgate.controller.req;
import org.springframework.util.DigestUtils;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.controller.req;
package com.fizzgate.controller.req;
import org.springframework.util.DigestUtils;

View File

@@ -14,7 +14,7 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.controller.resp;
package com.fizzgate.controller.resp;
import lombok.Data;

View File

@@ -15,13 +15,13 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.controller.resp;
package com.fizzgate.controller.resp;
import java.io.Serializable;
import java.util.List;
import java.util.Objects;
import we.fizz.ConfigLoader;
import com.fizzgate.fizz.ConfigLoader;
/**
* 聚合配置响应实体类

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.controller.resp;
package com.fizzgate.controller.resp;
import java.io.Serializable;
import java.util.Objects;

View File

@@ -14,7 +14,7 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.controller.resp;
package com.fizzgate.controller.resp;
import lombok.Data;

View File

@@ -14,7 +14,7 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.controller.resp;
package com.fizzgate.controller.resp;
import lombok.Data;

View File

@@ -15,13 +15,13 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.dedicated_line;
import we.util.JacksonUtils;
package com.fizzgate.dedicated_line;
import java.util.Collections;
import java.util.List;
import com.fizzgate.util.JacksonUtils;
/**
* @author hongqiaowei
*/

View File

@@ -15,12 +15,13 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.dedicated_line;
package com.fizzgate.dedicated_line;
import cn.hutool.core.codec.Base64;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.fizzgate.util.JacksonUtils;
import org.springframework.util.CollectionUtils;
import we.util.JacksonUtils;
import java.util.*;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.dedicated_line;
package com.fizzgate.dedicated_line;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -30,11 +30,13 @@ import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.reactive.function.BodyExtractors;
import org.springframework.web.reactive.function.client.ClientResponse;
import org.springframework.web.server.ServerWebExchange;
import com.fizzgate.config.FizzMangerConfig;
import com.fizzgate.config.SystemConfig;
import com.fizzgate.proxy.FizzWebClient;
import com.fizzgate.util.*;
import reactor.core.publisher.Mono;
import we.config.FizzMangerConfig;
import we.config.SystemConfig;
import we.proxy.FizzWebClient;
import we.util.*;
import javax.annotation.Resource;
import java.time.LocalDateTime;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.dedicated_line;
package com.fizzgate.dedicated_line;
import cn.hutool.crypto.symmetric.SymmetricAlgorithm;
import org.slf4j.Logger;
@@ -39,11 +39,13 @@ import org.springframework.web.server.adapter.DefaultServerWebExchange;
import org.springframework.web.server.adapter.ForwardedHeaderTransformer;
import org.springframework.web.server.i18n.LocaleContextResolver;
import org.springframework.web.server.session.WebSessionManager;
import com.fizzgate.config.SystemConfig;
import com.fizzgate.proxy.FizzWebClient;
import com.fizzgate.util.*;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import we.config.SystemConfig;
import we.proxy.FizzWebClient;
import we.util.*;
import java.net.URI;
import java.util.Arrays;

View File

@@ -15,14 +15,15 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.dedicated_line;
package com.fizzgate.dedicated_line;
import cn.hutool.core.codec.Base64;
import we.util.JacksonUtils;
import java.util.Collections;
import java.util.List;
import com.fizzgate.util.JacksonUtils;
/**
* @author hongqiaowei
*/

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.dedicated_line;
package com.fizzgate.dedicated_line;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -23,12 +23,14 @@ import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.data.redis.core.ReactiveStringRedisTemplate;
import org.springframework.stereotype.Service;
import com.fizzgate.config.AggregateRedisConfig;
import com.fizzgate.config.SystemConfig;
import com.fizzgate.util.JacksonUtils;
import com.fizzgate.util.Result;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import we.config.AggregateRedisConfig;
import we.config.SystemConfig;
import we.util.JacksonUtils;
import we.util.Result;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.dedicated_line;
package com.fizzgate.dedicated_line;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -24,14 +24,16 @@ import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.data.redis.core.ReactiveStringRedisTemplate;
import org.springframework.http.HttpMethod;
import org.springframework.stereotype.Service;
import com.fizzgate.config.AggregateRedisConfig;
import com.fizzgate.config.SystemConfig;
import com.fizzgate.plugin.auth.ApiConfig;
import com.fizzgate.util.JacksonUtils;
import com.fizzgate.util.Result;
import com.fizzgate.util.UrlTransformUtils;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import we.config.AggregateRedisConfig;
import we.config.SystemConfig;
import we.plugin.auth.ApiConfig;
import we.util.JacksonUtils;
import we.util.Result;
import we.util.UrlTransformUtils;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;

View File

@@ -15,9 +15,14 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.dedicated_line;
package com.fizzgate.dedicated_line;
import com.alibaba.cloud.nacos.discovery.NacosDiscoveryAutoConfiguration;
import com.fizzgate.config.SystemConfig;
import com.fizzgate.service_registry.FizzServiceRegistration;
import com.fizzgate.service_registry.eureka.FizzEurekaHelper;
import com.fizzgate.service_registry.nacos.FizzNacosHelper;
import lombok.SneakyThrows;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -33,10 +38,6 @@ import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.ConfigurableEnvironment;
import org.springframework.core.env.MapPropertySource;
import org.springframework.core.env.PropertySource;
import we.config.SystemConfig;
import we.service_registry.FizzServiceRegistration;
import we.service_registry.eureka.FizzEurekaHelper;
import we.service_registry.nacos.FizzNacosHelper;
import javax.annotation.PreDestroy;
import java.util.Properties;

View File

@@ -15,10 +15,10 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.dedicated_line;
package com.fizzgate.dedicated_line;
import we.util.Consts;
import we.util.ThreadContext;
import com.fizzgate.util.Consts;
import com.fizzgate.util.ThreadContext;
/**
* @author hongqiaowei

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.dedicated_line;
package com.fizzgate.dedicated_line;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -30,7 +30,8 @@ import org.springframework.context.annotation.Configuration;
import org.springframework.http.server.reactive.HttpHandler;
import org.springframework.web.server.adapter.HttpWebHandlerAdapter;
import org.springframework.web.server.session.DefaultWebSessionManager;
import we.config.SystemConfig;
import com.fizzgate.config.SystemConfig;
import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.dedicated_line;
package com.fizzgate.dedicated_line;
import org.springframework.boot.web.reactive.context.ReactiveWebServerApplicationContext;
import org.springframework.boot.web.server.WebServer;

View File

@@ -15,11 +15,12 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.dedicated_line;
package com.fizzgate.dedicated_line;
import org.springframework.http.HttpMethod;
import we.plugin.auth.ApiConfig;
import we.util.JacksonUtils;
import com.fizzgate.plugin.auth.ApiConfig;
import com.fizzgate.util.JacksonUtils;
/**
* @author hongqiaowei

View File

@@ -15,9 +15,9 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.exception;
package com.fizzgate.exception;
import we.fizz.StepContext;
import com.fizzgate.fizz.StepContext;
/**
* @author Francis

View File

@@ -14,7 +14,7 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.exception;
package com.fizzgate.exception;
/**
*

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.exception;
package com.fizzgate.exception;
/**
* @author Francis

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.exception;
package com.fizzgate.exception;
/**
* @author Francis

View File

@@ -15,10 +15,23 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.filter;
package com.fizzgate.filter;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.fizzgate.config.SystemConfig;
import com.fizzgate.constants.CommonConstants;
import com.fizzgate.fizz.AggregateResource;
import com.fizzgate.fizz.AggregateResult;
import com.fizzgate.fizz.ConfigLoader;
import com.fizzgate.fizz.Pipeline;
import com.fizzgate.fizz.input.Input;
import com.fizzgate.plugin.auth.ApiConfig;
import com.fizzgate.util.Consts;
import com.fizzgate.util.MapUtil;
import com.fizzgate.util.NettyDataBufferUtils;
import com.fizzgate.util.WebUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.logging.log4j.ThreadContext;
import org.slf4j.Logger;
@@ -38,18 +51,6 @@ import org.springframework.web.server.WebFilterChain;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import reactor.core.scheduler.Schedulers;
import we.config.SystemConfig;
import we.constants.CommonConstants;
import we.fizz.AggregateResource;
import we.fizz.AggregateResult;
import we.fizz.ConfigLoader;
import we.fizz.Pipeline;
import we.fizz.input.Input;
import we.plugin.auth.ApiConfig;
import we.util.Consts;
import we.util.MapUtil;
import we.util.NettyDataBufferUtils;
import we.util.WebUtils;
import javax.annotation.Resource;
import java.nio.charset.StandardCharsets;

View File

@@ -14,13 +14,14 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.filter;
package com.fizzgate.filter;
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.stereotype.Component;
import we.context.config.annotation.FizzRefreshScope;
import com.fizzgate.context.config.annotation.FizzRefreshScope;
/**
* {@link AggregateFilter} properties

View File

@@ -15,9 +15,23 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.filter;
package com.fizzgate.filter;
import com.alibaba.fastjson.JSON;
import com.fizzgate.config.AggregateRedisConfig;
import com.fizzgate.plugin.auth.ApiConfig;
import com.fizzgate.plugin.auth.CallbackConfig;
import com.fizzgate.plugin.auth.GatewayGroupService;
import com.fizzgate.plugin.auth.Receiver;
import com.fizzgate.proxy.CallbackService;
import com.fizzgate.proxy.DiscoveryClientUriSelector;
import com.fizzgate.proxy.ServiceInstance;
import com.fizzgate.service_registry.RegistryCenterService;
import com.fizzgate.util.Consts;
import com.fizzgate.util.NettyDataBufferUtils;
import com.fizzgate.util.ThreadContext;
import com.fizzgate.util.WebUtils;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -34,19 +48,6 @@ import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import org.springframework.web.server.WebFilterChain;
import reactor.core.publisher.Mono;
import we.config.AggregateRedisConfig;
import we.plugin.auth.ApiConfig;
import we.plugin.auth.CallbackConfig;
import we.plugin.auth.GatewayGroupService;
import we.plugin.auth.Receiver;
import we.proxy.CallbackService;
import we.proxy.DiscoveryClientUriSelector;
import we.proxy.ServiceInstance;
import we.service_registry.RegistryCenterService;
import we.util.Consts;
import we.util.NettyDataBufferUtils;
import we.util.ThreadContext;
import we.util.WebUtils;
import javax.annotation.Resource;
import java.nio.charset.StandardCharsets;

View File

@@ -14,7 +14,7 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.filter;
package com.fizzgate.filter;
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.filter;
package com.fizzgate.filter;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Bean;
@@ -27,7 +27,7 @@ import org.springframework.web.cors.CorsConfiguration;
import org.springframework.web.cors.reactive.CorsWebFilter;
import org.springframework.web.cors.reactive.UrlBasedCorsConfigurationSource;
import we.config.SystemConfig;
import com.fizzgate.config.SystemConfig;
import javax.annotation.Resource;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.filter;
package com.fizzgate.filter;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
@@ -30,18 +30,20 @@ import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.web.server.ResponseStatusException;
import org.springframework.web.server.ServerWebExchange;
import org.springframework.web.server.WebExceptionHandler;
import com.fizzgate.Fizz;
import com.fizzgate.config.SystemConfig;
import com.fizzgate.exception.ExecuteScriptException;
import com.fizzgate.exception.RedirectException;
import com.fizzgate.exception.StopAndResponseException;
import com.fizzgate.fizz.exception.FizzRuntimeException;
import com.fizzgate.legacy.RespEntity;
import com.fizzgate.util.Consts;
import com.fizzgate.util.JacksonUtils;
import com.fizzgate.util.ThreadContext;
import com.fizzgate.util.WebUtils;
import reactor.core.publisher.Mono;
import we.Fizz;
import we.config.SystemConfig;
import we.exception.ExecuteScriptException;
import we.exception.RedirectException;
import we.exception.StopAndResponseException;
import we.fizz.exception.FizzRuntimeException;
import we.legacy.RespEntity;
import we.util.Consts;
import we.util.JacksonUtils;
import we.util.ThreadContext;
import we.util.WebUtils;
import java.net.URI;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.filter;
package com.fizzgate.filter;
import java.util.Map;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.filter;
package com.fizzgate.filter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -24,10 +24,12 @@ import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import org.springframework.web.server.WebFilter;
import org.springframework.web.server.WebFilterChain;
import reactor.core.publisher.Mono;
import we.util.Consts;
import we.util.ThreadContext;
import we.util.WebUtils;
import com.fizzgate.util.Consts;
import com.fizzgate.util.ThreadContext;
import com.fizzgate.util.WebUtils;
import reactor.core.publisher.Mono;
/**
* @author hongqiaowei

View File

@@ -15,13 +15,15 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.filter;
package com.fizzgate.filter;
import org.springframework.web.server.ServerWebExchange;
import org.springframework.web.server.WebFilter;
import org.springframework.web.server.WebFilterChain;
import com.fizzgate.util.WebUtils;
import reactor.core.publisher.Mono;
import we.util.WebUtils;
/**
* @author hongqiaowei

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.filter;
package com.fizzgate.filter;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
@@ -29,22 +29,24 @@ import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import org.springframework.web.server.WebFilterChain;
import com.fizzgate.config.SystemConfig;
import com.fizzgate.monitor.FizzMonitorService;
import com.fizzgate.plugin.auth.ApiConfigService;
import com.fizzgate.plugin.auth.AppService;
import com.fizzgate.stats.BlockType;
import com.fizzgate.stats.FlowStat;
import com.fizzgate.stats.IncrRequestResult;
import com.fizzgate.stats.ResourceConfig;
import com.fizzgate.stats.circuitbreaker.CircuitBreakManager;
import com.fizzgate.stats.circuitbreaker.CircuitBreaker;
import com.fizzgate.stats.degrade.DegradeRule;
import com.fizzgate.stats.ratelimit.ResourceRateLimitConfig;
import com.fizzgate.stats.ratelimit.ResourceRateLimitConfigService;
import com.fizzgate.util.*;
import reactor.core.publisher.Mono;
import reactor.core.publisher.SignalType;
import we.config.SystemConfig;
import we.monitor.FizzMonitorService;
import we.plugin.auth.ApiConfigService;
import we.plugin.auth.AppService;
import we.stats.BlockType;
import we.stats.FlowStat;
import we.stats.IncrRequestResult;
import we.stats.ResourceConfig;
import we.stats.circuitbreaker.CircuitBreakManager;
import we.stats.circuitbreaker.CircuitBreaker;
import we.stats.degrade.DegradeRule;
import we.stats.ratelimit.ResourceRateLimitConfig;
import we.stats.ratelimit.ResourceRateLimitConfigService;
import we.util.*;
import javax.annotation.Resource;
import java.util.ArrayList;

View File

@@ -14,7 +14,7 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.filter;
package com.fizzgate.filter;
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.filter;
package com.fizzgate.filter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -25,20 +25,22 @@ import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
import org.springframework.web.server.ServerWebExchange;
import org.springframework.web.server.WebFilterChain;
import com.fizzgate.plugin.FixedPluginFilter;
import com.fizzgate.plugin.FizzPluginFilterChain;
import com.fizzgate.plugin.PluginConfig;
import com.fizzgate.plugin.auth.ApiConfig;
import com.fizzgate.plugin.auth.AuthPluginFilter;
import com.fizzgate.plugin.auth.GatewayGroup;
import com.fizzgate.plugin.auth.GatewayGroupService;
import com.fizzgate.plugin.stat.StatPluginFilter;
import com.fizzgate.proxy.Route;
import com.fizzgate.util.ReactorUtils;
import com.fizzgate.util.Result;
import com.fizzgate.util.ThreadContext;
import com.fizzgate.util.WebUtils;
import reactor.core.publisher.Mono;
import we.plugin.FixedPluginFilter;
import we.plugin.FizzPluginFilterChain;
import we.plugin.PluginConfig;
import we.plugin.auth.ApiConfig;
import we.plugin.auth.AuthPluginFilter;
import we.plugin.auth.GatewayGroup;
import we.plugin.auth.GatewayGroupService;
import we.plugin.stat.StatPluginFilter;
import we.proxy.Route;
import we.util.ReactorUtils;
import we.util.Result;
import we.util.ThreadContext;
import we.util.WebUtils;
import javax.annotation.Resource;
import java.util.*;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.filter;
package com.fizzgate.filter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -32,15 +32,17 @@ import org.springframework.web.reactive.function.BodyExtractors;
import org.springframework.web.reactive.function.client.ClientResponse;
import org.springframework.web.server.ServerWebExchange;
import org.springframework.web.server.WebFilterChain;
import com.fizzgate.config.SystemConfig;
import com.fizzgate.plugin.auth.ApiConfig;
import com.fizzgate.proxy.FizzWebClient;
import com.fizzgate.proxy.Route;
import com.fizzgate.proxy.dubbo.ApacheDubboGenericService;
import com.fizzgate.proxy.dubbo.DubboInterfaceDeclaration;
import com.fizzgate.service_registry.RegistryCenterService;
import com.fizzgate.util.*;
import reactor.core.publisher.Mono;
import we.config.SystemConfig;
import we.plugin.auth.ApiConfig;
import we.proxy.FizzWebClient;
import we.proxy.Route;
import we.proxy.dubbo.ApacheDubboGenericService;
import we.proxy.dubbo.DubboInterfaceDeclaration;
import we.service_registry.RegistryCenterService;
import we.util.*;
import javax.annotation.Resource;
import java.nio.charset.StandardCharsets;

View File

@@ -14,9 +14,9 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz;
package com.fizzgate.fizz;
import we.fizz.input.Input;
import com.fizzgate.fizz.input.Input;
/**
*

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz;
package com.fizzgate.fizz;
import org.springframework.util.MultiValueMap;

View File

@@ -15,9 +15,16 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz;
package com.fizzgate.fizz;
import com.alibaba.fastjson.JSON;
import com.fizzgate.config.SystemConfig;
import com.fizzgate.fizz.input.Input;
import com.fizzgate.util.Consts;
import com.fizzgate.util.MapUtil;
import com.fizzgate.util.Utils;
import com.fizzgate.util.WebUtils;
import org.apache.logging.log4j.ThreadContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -30,12 +37,6 @@ import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import reactor.core.scheduler.Schedulers;
import we.config.SystemConfig;
import we.fizz.input.Input;
import we.util.Consts;
import we.util.MapUtil;
import we.util.Utils;
import we.util.WebUtils;
import javax.annotation.Resource;
import java.nio.charset.StandardCharsets;

View File

@@ -15,10 +15,18 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz;
package com.fizzgate.fizz;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.fizzgate.config.AppConfigProperties;
import com.fizzgate.fizz.input.ClientInputConfig;
import com.fizzgate.fizz.input.Input;
import com.fizzgate.fizz.input.InputFactory;
import com.fizzgate.fizz.input.InputType;
import com.fizzgate.util.Consts;
import com.fizzgate.util.ReactorUtils;
import org.apache.commons.io.FileUtils;
import org.apache.logging.log4j.ThreadContext;
import org.noear.snack.ONode;
@@ -32,13 +40,6 @@ import org.springframework.util.CollectionUtils;
import org.springframework.util.StringUtils;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import we.config.AppConfigProperties;
import we.fizz.input.ClientInputConfig;
import we.fizz.input.Input;
import we.fizz.input.InputFactory;
import we.fizz.input.InputType;
import we.util.Consts;
import we.util.ReactorUtils;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;
@@ -50,9 +51,9 @@ import java.nio.charset.StandardCharsets;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import static we.config.AggregateRedisConfig.AGGREGATE_REACTIVE_REDIS_TEMPLATE;
import static we.util.Consts.S.FORWARD_SLASH;
import static we.util.Consts.S.FORWARD_SLASH_STR;
import static com.fizzgate.config.AggregateRedisConfig.AGGREGATE_REACTIVE_REDIS_TEMPLATE;
import static com.fizzgate.util.Consts.S.FORWARD_SLASH;
import static com.fizzgate.util.Consts.S.FORWARD_SLASH_STR;
/**
*

View File

@@ -14,7 +14,7 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz;
package com.fizzgate.fizz;
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;

View File

@@ -15,9 +15,29 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz;
package com.fizzgate.fizz;
import com.alibaba.fastjson.JSON;
import com.fizzgate.constants.CommonConstants;
import com.fizzgate.exception.ExecuteScriptException;
import com.fizzgate.exception.RedirectException;
import com.fizzgate.exception.StopAndResponseException;
import com.fizzgate.fizz.component.ComponentExecutor;
import com.fizzgate.fizz.component.ComponentResult;
import com.fizzgate.fizz.component.IComponent;
import com.fizzgate.fizz.component.StepContextPosition;
import com.fizzgate.fizz.exception.FizzRuntimeException;
import com.fizzgate.fizz.field.FieldConfig;
import com.fizzgate.fizz.field.ValueTypeEnum;
import com.fizzgate.fizz.input.*;
import com.fizzgate.util.Consts;
import com.fizzgate.util.JacksonUtils;
import com.fizzgate.util.JsonSchemaUtils;
import com.fizzgate.util.MapUtil;
import com.fizzgate.xml.JsonToXml;
import com.fizzgate.xml.XmlToJson;
import com.fizzgate.xml.XmlToJson.Builder;
import org.apache.logging.log4j.ThreadContext;
import org.noear.snack.ONode;
import org.slf4j.Logger;
@@ -30,27 +50,8 @@ import org.springframework.util.CollectionUtils;
import org.springframework.util.StringUtils;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import we.constants.CommonConstants;
import we.exception.ExecuteScriptException;
import we.exception.RedirectException;
import we.exception.StopAndResponseException;
import we.fizz.component.ComponentExecutor;
import we.fizz.component.ComponentResult;
import we.fizz.component.IComponent;
import we.fizz.component.StepContextPosition;
import we.fizz.exception.FizzRuntimeException;
import we.fizz.field.FieldConfig;
import we.fizz.field.ValueTypeEnum;
import we.fizz.input.*;
import we.schema.util.I18nUtils;
import we.schema.util.PropertiesSupportUtils;
import we.util.Consts;
import we.util.JacksonUtils;
import we.util.JsonSchemaUtils;
import we.util.MapUtil;
import we.xml.JsonToXml;
import we.xml.XmlToJson;
import we.xml.XmlToJson.Builder;
import com.fizzgate.schema.util.I18nUtils;
import com.fizzgate.schema.util.PropertiesSupportUtils;
import javax.script.ScriptException;
import java.util.*;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz;
package com.fizzgate.fizz;
import java.lang.ref.SoftReference;
import java.util.ArrayList;
@@ -26,16 +26,17 @@ import java.util.Map;
import org.apache.commons.collections.CollectionUtils;
import org.springframework.context.ConfigurableApplicationContext;
import com.fizzgate.fizz.component.ComponentExecutor;
import com.fizzgate.fizz.component.ComponentResult;
import com.fizzgate.fizz.component.IComponent;
import com.fizzgate.fizz.component.StepContextPosition;
import com.fizzgate.fizz.input.Input;
import com.fizzgate.fizz.input.InputConfig;
import com.fizzgate.fizz.input.InputContext;
import com.fizzgate.fizz.input.InputFactory;
import com.fizzgate.fizz.input.InputType;
import reactor.core.publisher.Mono;
import we.fizz.component.ComponentExecutor;
import we.fizz.component.ComponentResult;
import we.fizz.component.IComponent;
import we.fizz.component.StepContextPosition;
import we.fizz.input.Input;
import we.fizz.input.InputConfig;
import we.fizz.input.InputContext;
import we.fizz.input.InputFactory;
import we.fizz.input.InputType;
/**
*

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz;
package com.fizzgate.fizz;
import java.util.ArrayList;
import java.util.HashMap;
@@ -27,8 +27,7 @@ import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.http.codec.multipart.FilePart;
import com.alibaba.fastjson.JSON;
import we.constants.CommonConstants;
import com.fizzgate.constants.CommonConstants;
/**
*

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz;
package com.fizzgate.fizz;
import java.util.HashMap;
import java.util.List;

View File

@@ -14,7 +14,7 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz.component;
package com.fizzgate.fizz.component;
import java.util.ArrayList;
import java.util.List;
@@ -24,11 +24,11 @@ import java.util.function.BiFunction;
import org.noear.snack.ONode;
import com.alibaba.fastjson.JSON;
import com.fizzgate.fizz.StepContext;
import com.fizzgate.fizz.component.circle.Circle;
import com.fizzgate.fizz.component.condition.Condition;
import reactor.core.publisher.Mono;
import we.fizz.StepContext;
import we.fizz.component.circle.Circle;
import we.fizz.component.condition.Condition;
/**
* Condition component

View File

@@ -1,4 +1,4 @@
package we.fizz.component;
package com.fizzgate.fizz.component;
public class ComponentResult {

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz.component;
package com.fizzgate.fizz.component;
/**
* Component Type

View File

@@ -14,7 +14,7 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz.component;
package com.fizzgate.fizz.component;
/**
* Component interface

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz.component;
package com.fizzgate.fizz.component;
/**
* Operator

View File

@@ -13,7 +13,7 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz.component;
package com.fizzgate.fizz.component;
import lombok.Data;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz.component.circle;
package com.fizzgate.fizz.component.circle;
import java.util.Collection;
import java.util.Collections;
@@ -24,19 +24,20 @@ import java.util.function.BiFunction;
import org.noear.snack.ONode;
import com.fizzgate.fizz.StepContext;
import com.fizzgate.fizz.component.ComponentExecutor;
import com.fizzgate.fizz.component.ComponentResult;
import com.fizzgate.fizz.component.ComponentTypeEnum;
import com.fizzgate.fizz.component.IComponent;
import com.fizzgate.fizz.component.StepContextPosition;
import com.fizzgate.fizz.component.condition.Condition;
import com.fizzgate.fizz.exception.FizzRuntimeException;
import com.fizzgate.fizz.field.ValueTypeEnum;
import com.fizzgate.fizz.input.PathMapping;
import lombok.Data;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import we.fizz.StepContext;
import we.fizz.component.ComponentExecutor;
import we.fizz.component.ComponentResult;
import we.fizz.component.ComponentTypeEnum;
import we.fizz.component.IComponent;
import we.fizz.component.StepContextPosition;
import we.fizz.component.condition.Condition;
import we.fizz.exception.FizzRuntimeException;
import we.fizz.field.ValueTypeEnum;
import we.fizz.input.PathMapping;
/**
* Circle component

View File

@@ -14,7 +14,7 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz.component.circle;
package com.fizzgate.fizz.component.circle;
import lombok.AllArgsConstructor;
import lombok.Data;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz.component.condition;
package com.fizzgate.fizz.component.condition;
import java.util.Collection;
import java.util.Map;
@@ -28,18 +28,18 @@ import org.springframework.util.CollectionUtils;
import org.springframework.util.ObjectUtils;
import com.alibaba.fastjson.JSON;
import com.fizzgate.fizz.component.ComponentTypeEnum;
import com.fizzgate.fizz.component.IComponent;
import com.fizzgate.fizz.component.OperatorEnum;
import com.fizzgate.fizz.exception.FizzRuntimeException;
import com.fizzgate.fizz.field.RefDataTypeEnum;
import com.fizzgate.fizz.field.ValueTypeEnum;
import com.fizzgate.fizz.input.PathMapping;
import com.fizzgate.fizz.input.extension.request.RequestInput;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import we.fizz.component.ComponentTypeEnum;
import we.fizz.component.IComponent;
import we.fizz.component.OperatorEnum;
import we.fizz.exception.FizzRuntimeException;
import we.fizz.field.RefDataTypeEnum;
import we.fizz.field.ValueTypeEnum;
import we.fizz.input.PathMapping;
import we.fizz.input.extension.request.RequestInput;
/**
* Condition component

View File

@@ -15,14 +15,15 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz.component.condition;
package com.fizzgate.fizz.component.condition;
import com.fizzgate.fizz.field.FixedDataTypeEnum;
import com.fizzgate.fizz.field.RefDataTypeEnum;
import com.fizzgate.fizz.field.ValueTypeEnum;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import we.fizz.field.FixedDataTypeEnum;
import we.fizz.field.RefDataTypeEnum;
import we.fizz.field.ValueTypeEnum;
/**
* Condition value

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz.exception;
package com.fizzgate.fizz.exception;
public class FizzException extends Exception {
public FizzException(Throwable exception) {

View File

@@ -15,9 +15,9 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz.exception;
package com.fizzgate.fizz.exception;
import we.fizz.StepContext;
import com.fizzgate.fizz.StepContext;
public class FizzRuntimeException extends RuntimeException {

View File

@@ -14,7 +14,7 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz.field;
package com.fizzgate.fizz.field;
import java.util.Map;

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz.field;
package com.fizzgate.fizz.field;
/**
* Data type of fixed value

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz.field;
package com.fizzgate.fizz.field;
/**
* Data type of reference value

View File

@@ -15,7 +15,7 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package we.fizz.field;
package com.fizzgate.fizz.field;
/**
* Value Type

Some files were not shown because too many files have changed in this diff Show More