Allow to configure string codecs media type behavior

Fixes gh-150

Author: sdeleuze

autoconfigure-adapter/src/main/java/org/springframework/boot/autoconfigure/web/reactive/StringCodecInitializer.java

@@ -27,13 +27,16 @@
  */
 public class StringCodecInitializer extends AbstractCodecInitializer {
 
-	public StringCodecInitializer(boolean isClientCodec) {
+	private final boolean textPlainOnly;
+
+	public StringCodecInitializer(boolean isClientCodec, boolean textPlainOnly) {
 		super(isClientCodec);
+		this.textPlainOnly = textPlainOnly;
 	}
 
 	@Override
 	protected void register(GenericApplicationContext context, CodecConfigurer configurer) {
-		configurer.customCodecs().encoder(CharSequenceEncoder.textPlainOnly());
-		configurer.customCodecs().decoder(StringDecoder.textPlainOnly());
+		configurer.customCodecs().encoder(textPlainOnly ? CharSequenceEncoder.textPlainOnly() : CharSequenceEncoder.allMimeTypes());
+		configurer.customCodecs().decoder(textPlainOnly ? StringDecoder.textPlainOnly() : StringDecoder.allMimeTypes());
 	}
 }

jafu/src/main/java/org/springframework/fu/jafu/web/WebFluxClientDsl.java

@@ -79,7 +79,7 @@ public void initialize(GenericApplicationContext context) {
 		super.initialize(context);
 		this.dsl.accept(this);
 		if (!this.codecsConfigured) {
-			new StringCodecInitializer(true).initialize(context);
+			new StringCodecInitializer(true, false).initialize(context);
 			new ResourceCodecInitializer(true).initialize(context);
 		}
 		new ReactiveWebClientBuilderInitializer(baseUrl).initialize(context);
@@ -108,10 +108,19 @@ public void initialize(GenericApplicationContext context) {
 		}
 
 		/**
-		 * Enable {@link org.springframework.core.codec.CharSequenceEncoder} and {@link org.springframework.core.codec.StringDecoder}
+		 * Enable {@link org.springframework.core.codec.CharSequenceEncoder} and {@link org.springframework.core.codec.StringDecoder} for all media types
+		 * @see #string(boolean)
 		 */
 		public WebFluxClientCodecDsl string() {
-			new StringCodecInitializer(true).initialize(context);
+			new StringCodecInitializer(true, false).initialize(context);
+			return this;
+		}
+
+		/**
+		 * Enable {@link org.springframework.core.codec.CharSequenceEncoder} and {@link org.springframework.core.codec.StringDecoder}
+		 */
+		public WebFluxClientCodecDsl string(boolean textPlainOnly) {
+			new StringCodecInitializer(true, textPlainOnly).initialize(context);
 			return this;
 		}
 

jafu/src/main/java/org/springframework/fu/jafu/web/WebFluxServerDsl.java

@@ -154,7 +154,7 @@ public void initialize(GenericApplicationContext context) {
 		engine.setPort(port);
 
 		if (!codecsConfigured) {
-			new StringCodecInitializer(false).initialize(context);
+			new StringCodecInitializer(false, false).initialize(context);
 			new ResourceCodecInitializer(false).initialize(context);
 		}
 		if (context.containsBeanDefinition("webHandler")) {
@@ -187,10 +187,18 @@ public void initialize(GenericApplicationContext context) {
 		}
 
 		/**
-		 * Enable {@link org.springframework.core.codec.CharSequenceEncoder} and {@link org.springframework.core.codec.StringDecoder}
+		 * Enable {@link org.springframework.core.codec.CharSequenceEncoder} and {@link org.springframework.core.codec.StringDecoder} for all media types
 		 */
 		public WebFluxServerCodecDsl string() {
-			new StringCodecInitializer(false).initialize(context);
+			new StringCodecInitializer(false, false).initialize(context);
+			return this;
+		}
+
+		/**
+		 * Enable {@link org.springframework.core.codec.CharSequenceEncoder} and {@link org.springframework.core.codec.StringDecoder}
+		 */
+		public WebFluxServerCodecDsl string(boolean textPlainOnly) {
+			new StringCodecInitializer(false, textPlainOnly).initialize(context);
 			return this;
 		}
 

kofu/src/main/kotlin/org/springframework/fu/kofu/web/WebFluxClientDsl.kt

@@ -35,7 +35,7 @@ class WebFluxClientDsl(private val init: WebFluxClientDsl.() -> Unit) : Abstract
         super.initialize(context)
         init()
         if (!codecsConfigured) {
-            StringCodecInitializer(true).initialize(context)
+            StringCodecInitializer(true, false).initialize(context)
             ResourceCodecInitializer(true).initialize(context)
         }
         ReactiveWebClientBuilderInitializer(baseUrl).initialize(context)
@@ -59,8 +59,8 @@ class WebFluxClientDsl(private val init: WebFluxClientDsl.() -> Unit) : Abstract
         /**
          * Enable [org.springframework.core.codec.CharSequenceEncoder] and [org.springframework.core.codec.StringDecoder]
          */
-        fun string() {
-            StringCodecInitializer(true).initialize(context)
+        fun string(textPlainOnly: Boolean = false) {
+            StringCodecInitializer(true, textPlainOnly).initialize(context)
         }
 
         /**

kofu/src/main/kotlin/org/springframework/fu/kofu/web/WebFluxServerDsl.kt

@@ -73,7 +73,7 @@ open class WebFluxServerDsl(private val init: WebFluxServerDsl.() -> Unit): Abst
         }
         engine!!.setPort(port)
         if (!codecsConfigured) {
-            StringCodecInitializer(false).initialize(context)
+            StringCodecInitializer(false, false).initialize(context)
             ResourceCodecInitializer(false).initialize(context)
         }
         if (context.containsBeanDefinition("webHandler")) {
@@ -218,8 +218,8 @@ open class WebFluxServerDsl(private val init: WebFluxServerDsl.() -> Unit): Abst
         /**
          * Enable [org.springframework.core.codec.CharSequenceEncoder] and [org.springframework.core.codec.StringDecoder]
          */
-        fun string() {
-            StringCodecInitializer(false).initialize(context)
+        fun string(textPlainOnly: Boolean = false) {
+            StringCodecInitializer(false, textPlainOnly).initialize(context)
         }
 
         /**