Support LogStream filters (#494)

* Support LogStream filters

* Updated test schemas

Author: jimmyjames

src/main/java/com/auth0/json/mgmt/logstreams/LogStream.java

@@ -2,6 +2,7 @@
 
 import com.fasterxml.jackson.annotation.*;
 
+import java.util.List;
 import java.util.Map;
 
 /**
@@ -22,6 +23,9 @@ public class LogStream {
     @JsonProperty("sink")
     private Map<String, Object> sink;
 
+    @JsonProperty("filters")
+    private List<LogStreamFilter> filters;
+
     /**
      * Creates a new LogStream instance and sets the type, which cannot be changed once set.
      *
@@ -119,4 +123,22 @@ public Map<String, Object> getSink() {
     public void setSink(Map<String, Object> sink) {
         this.sink = sink;
     }
+
+    /**
+     * @return the log stream filters
+     */
+    @JsonProperty("filters")
+    public List<LogStreamFilter> getFilters() {
+        return filters;
+    }
+
+    /**
+     * Set the log stream filters.
+     *
+     * @param filters the filters to set for the log stream.
+     */
+    @JsonProperty("filters")
+    public void setFilters(List<LogStreamFilter> filters) {
+        this.filters = filters;
+    }
 }

src/main/java/com/auth0/json/mgmt/logstreams/LogStreamFilter.java

@@ -0,0 +1,61 @@
+package com.auth0.json.mgmt.logstreams;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * Represents an Auth0 Log Stream Filter object. Related to the {@linkplain com.auth0.client.mgmt.LogStreamsEntity}
+ */
+@JsonIgnoreProperties(ignoreUnknown = true)
+@JsonInclude(JsonInclude.Include.NON_NULL)
+public class LogStreamFilter {
+
+    @JsonProperty("type")
+    private String type;
+    @JsonProperty("name")
+    private String name;
+
+    /**
+     * Create a new instance.
+     *
+     * @param type the log stream filter type.
+     * @param name the log stream filter name.
+     */
+    @JsonCreator
+    public LogStreamFilter(@JsonProperty("type") String type, @JsonProperty("name") String name) {
+        this.type = type;
+        this.name = name;
+    }
+
+    /**
+     * @return the log stream filter type.
+     */
+    @JsonProperty("type")
+    public String getType() {
+        return type;
+    }
+
+    /**
+     * Set the log stream filter type.
+     * @param type the log stream filter type.
+     */
+    @JsonProperty("type")
+    public void setType(String type) {
+        this.type = type;
+    }
+
+    /**
+     * @return the log stream filter name.
+     */
+    @JsonProperty("name")
+    public String getName() {
+        return name;
+    }
+
+    @JsonProperty("name")
+    public void setName(String name) {
+        this.name = name;
+    }
+}

src/test/java/com/auth0/client/mgmt/LogStreamsEntityTest.java

@@ -2,11 +2,13 @@
 
 import com.auth0.client.MockServer;
 import com.auth0.json.mgmt.logstreams.LogStream;
+import com.auth0.json.mgmt.logstreams.LogStreamFilter;
 import com.auth0.net.Request;
 import com.auth0.net.client.HttpMethod;
 import okhttp3.mockwebserver.RecordedRequest;
 import org.junit.Test;
 
+import java.util.Collections;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -39,6 +41,7 @@ public void shouldListLogStreams() throws Exception {
         assertThat(response, everyItem(hasProperty("type", is(notNullValue()))));
         assertThat(response, everyItem(hasProperty("status", is(notNullValue()))));
         assertThat(response, everyItem(hasProperty("sink", is(notNullValue()))));
+        assertThat(response, everyItem(hasProperty("filters", is(notNullValue()))));
     }
 
     @Test
@@ -72,11 +75,14 @@ public void shouldGetLogStream() throws Exception {
         assertThat(response, hasProperty("type", is(notNullValue())));
         assertThat(response, hasProperty("status", is(notNullValue())));
         assertThat(response, hasProperty("sink", is(notNullValue())));
+        assertThat(response, hasProperty("filters", is(notNullValue())));
     }
 
     @Test
     public void shouldCreateLogStream() throws Exception {
         LogStream logStream = getLogStream("log stream", "http");
+        LogStreamFilter filter = new LogStreamFilter("category", "auth.ancillary.success");
+        logStream.setFilters(Collections.singletonList(filter));
 
         Request<LogStream> request = api.logStreams().create(logStream);
         assertThat(request, is(notNullValue()));
@@ -90,17 +96,20 @@ public void shouldCreateLogStream() throws Exception {
         assertThat(recordedRequest, hasHeader("Authorization", "Bearer apiToken"));
 
         Map<String, Object> body = bodyFromRequest(recordedRequest);
-        assertThat(body.size(), is(3));
+        assertThat(body.size(), is(4));
         assertThat(body, hasEntry("name", "log stream"));
         assertThat(body, hasEntry("type", "http"));
         assertThat(body, hasEntry("sink", logStream.getSink()));
+        assertThat(body, hasKey("filters"));
+        assertThat(body.get("filters"), is(notNullValue()));
 
         assertThat(response, is(notNullValue()));
         assertThat(response, hasProperty("id", is(notNullValue())));
         assertThat(response, hasProperty("name", is(notNullValue())));
         assertThat(response, hasProperty("type", is(notNullValue())));
         assertThat(response, hasProperty("status", is(notNullValue())));
         assertThat(response, hasProperty("sink", is(notNullValue())));
+        assertThat(response, hasProperty("filters", is(notNullValue())));
 
     }
 

src/test/resources/mgmt/log_stream.json

@@ -9,5 +9,15 @@
     "httpContentType": "application/json",
     "httpAuthorization": "abc123",
     "httpEndpoint": "https//me.org"
-  }
+  },
+  "filters": [
+    {
+      "type": "category",
+      "name": "auth.ancillary.success"
+    },
+    {
+      "type": "category",
+      "name": "auth.ancillary.fail"
+    }
+  ]
 }

src/test/resources/mgmt/log_streams_list.json

@@ -9,7 +9,17 @@
       "httpContentType": "application/json",
       "httpAuthorization": "abc123",
       "httpEndpoint": "https//me.org"
-    }
+    },
+    "filters": [
+      {
+        "type": "category",
+        "name": "auth.ancillary.success"
+      },
+      {
+        "type": "category",
+        "name": "auth.ancillary.fail"
+      }
+    ]
   },
   {
     "id": "456",
@@ -21,6 +31,16 @@
       "datadogApiKey": "abc123",
       "httpAuthorization": "abc123",
       "httpEndpoint": "https//me.org"
-    }
+    },
+    "filters": [
+      {
+        "type": "category",
+        "name": "auth.ancillary.success"
+      },
+      {
+        "type": "category",
+        "name": "auth.ancillary.fail"
+      }
+    ]
   }
 ]