fizzgate/fizz-gateway-node
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add some log to GrayReleasePlugin.java

Browse Source
This commit is contained in:
hongqiaowei
2022-07-29 16:49:11 +08:00
parent 43795a23ee
commit 89c85d1d7b
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
fizz-plugin/src/main/java/we/plugin/grayrelease/GrayReleasePlugin.java
View File

@@ -178,6 +178,10 @@ public class GrayReleasePlugin extends RequestBodyPlugin {
public Mono<Void> doFilter(ServerWebExchange exchange, Map<String, Object> config) { public Mono<Void> doFilter(ServerWebExchange exchange, Map<String, Object> config) {
String traceId = WebUtils.getTraceId(exchange); String traceId = WebUtils.getTraceId(exchange);
ThreadContext.put(Consts.TRACE_ID, traceId); ThreadContext.put(Consts.TRACE_ID, traceId);
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("gray release plugin config: {}", JacksonUtils.writeValueAsString(config));
}
String tc = (String) config.get(triggerCondition); String tc = (String) config.get(triggerCondition);
Object ognlRoot = request2ognlContext(exchange); Object ognlRoot = request2ognlContext(exchange);
Boolean conditionMatch = false; Boolean conditionMatch = false;
@@ -334,7 +338,7 @@ public class GrayReleasePlugin extends RequestBodyPlugin {
byte rt = ((Integer) pluginConfig.get(routeType)).byteValue(); byte rt = ((Integer) pluginConfig.get(routeType)).byteValue();
route.type = rt; route.type = rt;
Map<String, String> newRouteConfig = (Map<String, String>) pluginConfig.get(routeConfigMap); Map<String, String> newRouteConfig = (Map<String, String>) pluginConfig.get(routeConfigMap);
if (newRouteConfig == null) { if (newRouteConfig == null && rt != ApiConfig.Type.DIRECT_RESPONSE) {
newRouteConfig = routeConfig2map((String) pluginConfig.get(routeConfig)); newRouteConfig = routeConfig2map((String) pluginConfig.get(routeConfig));
pluginConfig.put(routeConfigMap, newRouteConfig); pluginConfig.put(routeConfigMap, newRouteConfig);
pluginConfig.remove(routeConfig); pluginConfig.remove(routeConfig);