Skip to content

Commit 8471797

Browse files
add live tests
1 parent f5337b6 commit 8471797

2 files changed

Lines changed: 67 additions & 0 deletions

File tree

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
// Copyright (c) Microsoft Corporation. All rights reserved.
2+
// Licensed under the MIT License.
3+
// Code generated by Microsoft (R) AutoRest Code Generator.
4+
5+
package com.azure.ai.metricsadvisor;
6+
7+
import com.azure.core.http.rest.RequestOptions;
8+
import com.azure.core.http.rest.Response;
9+
import com.azure.core.test.annotation.DoNotRecord;
10+
import com.azure.core.util.BinaryData;
11+
import org.junit.jupiter.api.Assertions;
12+
import org.junit.jupiter.api.Test;
13+
14+
public final class CreateANewDataFeedTests extends MetricsAdvisorClientTestBase {
15+
@Test
16+
@DoNotRecord(skipInPlayback = true)
17+
public void testCreateANewDataFeedTests() {
18+
BinaryData body =
19+
BinaryData.fromString(
20+
"{\"allUpIdentification\":\"__SUM__\",\"authenticationType\":\"Basic\",\"dataFeedDescription\":\"This is a sample data feed.\",\"dataFeedName\":\"Sample - cost/revenue - city/category\",\"dataSourceParameter\":{\"connectionString\":\"Server=PlaceholderSqlServer,1433;Initial Catalog=PlaceholderDatabase;User ID=PlaceholderUserName;Password=PlaceholderPassword;\",\"query\":\"select * from your_table where timestamp = @StartTime\"},\"dataSourceType\":\"SqlServer\",\"dataStartFrom\":\"2020-01-01T00:00:00.000Z\",\"dimension\":[{\"dimensionDisplayName\":\"category\",\"dimensionName\":\"category\"},{\"dimensionDisplayName\":\"city\",\"dimensionName\":\"city\"}],\"fillMissingPointType\":\"SmartFilling\",\"granularityName\":\"Daily\",\"maxConcurrency\":5,\"metrics\":[{\"metricDisplayName\":\"cost\",\"metricName\":\"cost\"},{\"metricDisplayName\":\"revenue\",\"metricName\":\"revenue\"}],\"minRetryIntervalInSeconds\":3600,\"needRollup\":\"NeedRollup\",\"rollUpMethod\":\"Sum\",\"startOffsetInSeconds\":86400,\"stopRetryAfterInSeconds\":604800,\"timestampColumn\":\"timestamp\",\"viewMode\":\"Private\"}");
21+
RequestOptions requestOptions = new RequestOptions();
22+
Response<Void> response = metricsAdvisorClient.createDataFeedWithResponse(body, requestOptions);
23+
Assertions.assertEquals(201, response.getStatusCode());
24+
Assertions.assertEquals("", response.getHeaders().get("Location").getValue());
25+
}
26+
}
Lines changed: 41 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,41 @@
1+
// Copyright (c) Microsoft Corporation. All rights reserved.
2+
// Licensed under the MIT License.
3+
// Code generated by Microsoft (R) AutoRest Code Generator.
4+
5+
package com.azure.ai.metricsadvisor;
6+
7+
import com.azure.core.credential.AccessToken;
8+
import com.azure.core.http.HttpClient;
9+
import com.azure.core.http.policy.HttpLogDetailLevel;
10+
import com.azure.core.http.policy.HttpLogOptions;
11+
import com.azure.core.test.TestBase;
12+
import com.azure.core.test.TestMode;
13+
import com.azure.core.util.Configuration;
14+
import com.azure.identity.DefaultAzureCredentialBuilder;
15+
import java.time.OffsetDateTime;
16+
import reactor.core.publisher.Mono;
17+
18+
class MetricsAdvisorClientTestBase extends TestBase {
19+
protected MetricsAdvisorClient metricsAdvisorClient;
20+
21+
@Override
22+
protected void beforeTest() {
23+
MetricsAdvisorClientBuilder metricsAdvisorClientbuilder =
24+
new MetricsAdvisorClientBuilder()
25+
.endpoint(Configuration.getGlobalConfiguration().get("ENDPOINT", "https://metricsadvisor-weidxu.cognitiveservices.azure.com/"))
26+
.httpClient(HttpClient.createDefault())
27+
.httpLogOptions(new HttpLogOptions().setLogLevel(HttpLogDetailLevel.BASIC));
28+
if (getTestMode() == TestMode.PLAYBACK) {
29+
metricsAdvisorClientbuilder
30+
.httpClient(interceptorManager.getPlaybackClient())
31+
.credential(request -> Mono.just(new AccessToken("this_is_a_token", OffsetDateTime.MAX)));
32+
} else if (getTestMode() == TestMode.RECORD) {
33+
metricsAdvisorClientbuilder
34+
.addPolicy(interceptorManager.getRecordPolicy())
35+
.credential(new DefaultAzureCredentialBuilder().build());
36+
} else if (getTestMode() == TestMode.LIVE) {
37+
metricsAdvisorClientbuilder.credential(new DefaultAzureCredentialBuilder().build());
38+
}
39+
metricsAdvisorClient = metricsAdvisorClientbuilder.buildClient();
40+
}
41+
}

0 commit comments

Comments
 (0)