Skip to content

Commit

Permalink
Remove unnecessary test because of change in behavior.
Browse files Browse the repository at this point in the history
  • Loading branch information
varunpuranik committed Feb 8, 2019
1 parent 0e3428c commit 735fb1a
Showing 1 changed file with 1 addition and 92 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1254,98 +1254,7 @@ public async Task EdgeAgentConnectionRefreshTest()
moduleClient.Verify(m => m.GetTwinAsync(), Times.Exactly(3));
}
}

[Fact]
[Unit]
public async Task EdgeAgentConnectionRefreshTest_NoRefresh()
{
// Arrange
var moduleDeserializerTypes = new Dictionary<string, Type>
{
{ DockerType, typeof(DockerDesiredModule) }
};

var edgeAgentDeserializerTypes = new Dictionary<string, Type>
{
{ DockerType, typeof(EdgeAgentDockerModule) }
};

var edgeHubDeserializerTypes = new Dictionary<string, Type>
{
{ DockerType, typeof(EdgeHubDockerModule) }
};

var runtimeInfoDeserializerTypes = new Dictionary<string, Type>
{
{ DockerType, typeof(DockerRuntimeInfo) }
};

var deserializerTypes = new Dictionary<Type, IDictionary<string, Type>>
{
[typeof(IModule)] = moduleDeserializerTypes,
[typeof(IEdgeAgentModule)] = edgeAgentDeserializerTypes,
[typeof(IEdgeHubModule)] = edgeHubDeserializerTypes,
[typeof(IRuntimeInfo)] = runtimeInfoDeserializerTypes,
};

ISerde<DeploymentConfig> serde = new TypeSpecificSerDe<DeploymentConfig>(deserializerTypes);

var runtimeInfo = new DockerRuntimeInfo("docker", new DockerRuntimeConfig("1.0", null));
var edgeAgentDockerModule = new EdgeAgentDockerModule("docker", new DockerConfig("image", string.Empty), null, null);
var edgeHubDockerModule = new EdgeHubDockerModule(
"docker",
ModuleStatus.Running,
RestartPolicy.Always,
new DockerConfig("image", string.Empty),
null,
null);
var deploymentConfig = new DeploymentConfig(
"1.0",
runtimeInfo,
new SystemModules(edgeAgentDockerModule, edgeHubDockerModule),
new Dictionary<string, IModule>());
long version = 1;
string deploymentConfigJson = serde.Serialize(deploymentConfig);
JObject deploymentConfigJobject = JObject.Parse(deploymentConfigJson);
deploymentConfigJobject.Add("$version", JToken.Parse($"{version}"));
var twinCollection = new TwinCollection(deploymentConfigJobject, new JObject());
var twin = new Twin(new TwinProperties { Desired = new TwinCollection(deploymentConfigJson) });

DesiredPropertyUpdateCallback desiredPropertyUpdateCallback = null;
var moduleClient = new Mock<IModuleClient>();
moduleClient.Setup(m => m.GetTwinAsync())
.ReturnsAsync(twin);
moduleClient.Setup(m => m.SetDesiredPropertyUpdateCallbackAsync(It.IsAny<DesiredPropertyUpdateCallback>()))
.Callback<DesiredPropertyUpdateCallback>(d => desiredPropertyUpdateCallback = d)
.Returns(Task.CompletedTask);

var moduleClientProvider = new Mock<IModuleClientProvider>();
Func<IModuleClient, Task> updateModuleClient = null;
moduleClientProvider.Setup(m => m.Create(It.IsAny<ConnectionStatusChangesHandler>(), It.IsAny<Func<IModuleClient, Task>>()))
.Callback<ConnectionStatusChangesHandler, Func<IModuleClient, Task>>((c, f) => updateModuleClient = f)
.ReturnsAsync(moduleClient.Object);

// Act
using (var edgeAgentConnection = new EdgeAgentConnection(moduleClientProvider.Object, serde, TimeSpan.FromSeconds(5)))
{
await Task.Delay(TimeSpan.FromSeconds(0.5));
Assert.NotNull(updateModuleClient);

await updateModuleClient(moduleClient.Object);
Assert.NotNull(desiredPropertyUpdateCallback);

await Task.Delay(TimeSpan.FromSeconds(3));
JObject patchConfigJobject = JObject.Parse(deploymentConfigJson);
patchConfigJobject.Add("$version", JToken.Parse($"{version + 1}"));
var patchTwinCollection = new TwinCollection(deploymentConfigJobject, new JObject());
await desiredPropertyUpdateCallback(patchTwinCollection, null);
await Task.Delay(TimeSpan.FromSeconds(4));

// Assert
moduleClient.Verify(m => m.GetTwinAsync(), Times.Once);
}
}


[Theory]
[Unit]
[InlineData("1.0", null)]
Expand Down

0 comments on commit 735fb1a

Please sign in to comment.