1717import com .google .gson .reflect .TypeToken ;
1818import io .kubernetes .client .openapi .JSON ;
1919import io .kubernetes .client .util .generic .dynamic .DynamicKubernetesObject ;
20+ import io .kubernetes .client .util .generic .dynamic .DynamicKubernetesTypeAdaptorFactory ;
2021import java .io .IOException ;
2122import org .junit .jupiter .api .Test ;
2223
@@ -26,13 +27,19 @@ class WatchDynamicObjectTest {
2627 @ Test
2728 void watchAddedEventShouldPreserveRawData () throws IOException {
2829 JSON json = new JSON ();
29- // Register the DynamicKubernetesTypeAdaptorFactory to properly handle DynamicKubernetesObject
30- json .setGson (json .getGson ().newBuilder ()
31- .registerTypeAdapterFactory (new io .kubernetes .client .util .generic .dynamic .DynamicKubernetesTypeAdaptorFactory ())
32- .create ());
30+ // Register the DynamicKubernetesTypeAdaptorFactory to properly handle
31+ // DynamicKubernetesObject
32+ json .setGson (
33+ json .getGson ()
34+ .newBuilder ()
35+ .registerTypeAdapterFactory (new DynamicKubernetesTypeAdaptorFactory ())
36+ .create ());
3337 Watch <DynamicKubernetesObject > watch =
3438 new Watch <>(
35- json , null , new TypeToken <Watch .Response <DynamicKubernetesObject >>() {}.getType (), null );
39+ json ,
40+ null ,
41+ new TypeToken <Watch .Response <DynamicKubernetesObject >>() {}.getType (),
42+ null );
3643
3744 String addedEvent = "{\" type\" :\" ADDED\" ,"
3845 + "\" object\" :{"
@@ -47,24 +54,31 @@ void watchAddedEventShouldPreserveRawData() throws IOException {
4754 assertThat (response .object ).isNotNull ();
4855 assertThat (response .object .getMetadata ()).isNotNull ();
4956 assertThat (response .object .getMetadata ().getName ()).isEqualTo ("test-pod" );
50-
57+
5158 // Check that raw data is preserved
5259 assertThat (response .object .getRaw ()).isNotNull ();
53- assertThat (response .object .getRaw ().size ()).isGreaterThan (2 ); // Should have more than just metadata
60+ // Should have more than just metadata
61+ assertThat (response .object .getRaw ().size ()).isGreaterThan (2 );
5462 assertThat (response .object .getRaw ().has ("spec" )).isTrue ();
5563 assertThat (response .object .getRaw ().get ("spec" )).isNotNull ();
5664 }
5765
5866 @ Test
5967 void watchModifiedEventShouldPreserveRawData () throws IOException {
6068 JSON json = new JSON ();
61- // Register the DynamicKubernetesTypeAdaptorFactory to properly handle DynamicKubernetesObject
62- json .setGson (json .getGson ().newBuilder ()
63- .registerTypeAdapterFactory (new io .kubernetes .client .util .generic .dynamic .DynamicKubernetesTypeAdaptorFactory ())
64- .create ());
69+ // Register the DynamicKubernetesTypeAdaptorFactory to properly handle
70+ // DynamicKubernetesObject
71+ json .setGson (
72+ json .getGson ()
73+ .newBuilder ()
74+ .registerTypeAdapterFactory (new DynamicKubernetesTypeAdaptorFactory ())
75+ .create ());
6576 Watch <DynamicKubernetesObject > watch =
6677 new Watch <>(
67- json , null , new TypeToken <Watch .Response <DynamicKubernetesObject >>() {}.getType (), null );
78+ json ,
79+ null ,
80+ new TypeToken <Watch .Response <DynamicKubernetesObject >>() {}.getType (),
81+ null );
6882
6983 String modifiedEvent = "{\" type\" :\" MODIFIED\" ,"
7084 + "\" object\" :{"
@@ -79,10 +93,11 @@ void watchModifiedEventShouldPreserveRawData() throws IOException {
7993 assertThat (response .object ).isNotNull ();
8094 assertThat (response .object .getMetadata ()).isNotNull ();
8195 assertThat (response .object .getMetadata ().getName ()).isEqualTo ("test-pod" );
82-
96+
8397 // Check that raw data is preserved
8498 assertThat (response .object .getRaw ()).isNotNull ();
85- assertThat (response .object .getRaw ().size ()).isGreaterThan (2 ); // Should have more than just metadata
99+ // Should have more than just metadata
100+ assertThat (response .object .getRaw ().size ()).isGreaterThan (2 );
86101 assertThat (response .object .getRaw ().has ("spec" )).isTrue ();
87102 assertThat (response .object .getRaw ().get ("spec" )).isNotNull ();
88103 }
0 commit comments