17
17
* under the License.
18
18
*/
19
19
20
- using System ;
21
20
using System . Linq ;
22
21
using System . Threading . Tasks ;
23
22
using Elastic . Elasticsearch . Xunit . XunitPlumbing ;
@@ -38,6 +37,7 @@ public class EqlSearchApiCoordinatedTests : CoordinatedIntegrationTestBase<TimeS
38
37
private const string StatusStep = nameof ( StatusStep ) ;
39
38
private const string GetStep = nameof ( GetStep ) ;
40
39
private const string WaitStep = nameof ( WaitStep ) ;
40
+ private const string DeleteStep = nameof ( DeleteStep ) ;
41
41
42
42
public EqlSearchApiCoordinatedTests ( TimeSeriesCluster cluster , EndpointUsage usage ) : base ( new CoordinatedUsage ( cluster , usage , testOnlyOne : true )
43
43
{
@@ -96,6 +96,17 @@ public EqlSearchApiCoordinatedTests(TimeSeriesCluster cluster, EndpointUsage usa
96
96
( v , c , r ) => c . Eql . GetAsync < Log > ( r ) ,
97
97
uniqueValueSelector : values => values . ExtendedValue < string > ( "id" )
98
98
)
99
+ } ,
100
+ { DeleteStep , u =>
101
+ u . Calls < EqlDeleteDescriptor , EqlDeleteRequest , IEqlDeleteRequest , EqlDeleteResponse > (
102
+ v => new EqlDeleteRequest ( v ) ,
103
+ ( v , d ) => d ,
104
+ ( v , c , f ) => c . Eql . Delete ( v , f ) ,
105
+ ( v , c , f ) => c . Eql . DeleteAsync ( v , f ) ,
106
+ ( v , c , r ) => c . Eql . Delete ( r ) ,
107
+ ( v , c , r ) => c . Eql . DeleteAsync ( r ) ,
108
+ uniqueValueSelector : values => values . ExtendedValue < string > ( "id" )
109
+ )
99
110
}
100
111
} ) { }
101
112
@@ -134,5 +145,11 @@ [I] public async Task EqlGetResponse() => await Assert<EqlGetResponse<Log>>(GetS
134
145
firstEvent . Id . Should ( ) . NotBeNullOrEmpty ( ) ;
135
146
firstEvent . Source . Event . Category . Should ( ) . BeOneOf ( Log . EventCategories ) ;
136
147
} ) ;
148
+
149
+ [ I ] public async Task EqlDeleteResponse ( ) => await Assert < EqlDeleteResponse > ( DeleteStep , r =>
150
+ {
151
+ r . ShouldBeValid ( ) ;
152
+ r . Acknowledged . Should ( ) . BeTrue ( ) ;
153
+ } ) ;
137
154
}
138
155
}
0 commit comments