Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -74,11 +74,12 @@ async void ReauthenticateConnections(object sender, ElapsedEventArgs elapsedEven
Option<IClientCredentials> clientCredentials = await this.credentialsCache.Get(identity);
bool result = await clientCredentials
.Map(
async c =>
c =>
{
bool authRes = await this.authenticator.ReauthenticateAsync(c);
Events.ClientCredentialsResult(identity, authRes);
return authRes;
Console.WriteLine("Returning false for all clients.");
// bool authRes = await this.authenticator.ReauthenticateAsync(c);
// Events.ClientCredentialsResult(identity, authRes);
return Task.FromResult(false);
})
.GetOrElse(
() =>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -522,9 +522,18 @@ public async Task<DirectMethodResponse> InvokeMethodAsync(DirectMethodRequest re
return await taskCompletion.Task;
}

public Task OnDesiredPropertyUpdates(IMessage twinUpdates) => this.underlyingProxy.OnDesiredPropertyUpdates(twinUpdates);
public Task OnDesiredPropertyUpdates(IMessage twinUpdates)
{
Console.WriteLine("OnDesiredPropertyUpdates StackTrace: '{0}'", Environment.StackTrace);
return this.underlyingProxy.OnDesiredPropertyUpdates(twinUpdates);
}

public Task SendTwinUpdate(IMessage twin) => this.underlyingProxy.SendTwinUpdate(twin);
public Task SendTwinUpdate(IMessage twin)
{
// print stack trace here
Console.WriteLine("SendTwinUpdate StackTrace: '{0}'", Environment.StackTrace);
return this.underlyingProxy.SendTwinUpdate(twin);
}

public Task CloseAsync(Exception ex) => this.underlyingProxy.CloseAsync(ex);

Expand Down