Enable for Azure SQL

Author: ascott18

.gitignore

@@ -8,7 +8,7 @@
 *.user
 *.userosscache
 *.sln.docstates
-appsettings.localuser.json
+appsettings.localhost.json
 
 # User-specific files (MonoDevelop/Xamarin Studio)
 *.userprefs

demo/DemoServer/Program.cs

@@ -1,4 +1,4 @@
-using IntelliTect.SignalR.SqlServer;
+using IntelliTect.AspNetCore.SignalR.SqlServer;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Hosting;
@@ -21,7 +21,12 @@ public static IHostBuilder CreateHostBuilder(string[] args) =>
             Host.CreateDefaultBuilder(args)
                 .ConfigureWebHostDefaults(webBuilder =>
                 {
-                    webBuilder.UseStartup<Startup>();
+                    webBuilder.UseStartup<Startup>()
+                    .ConfigureAppConfiguration((builder, config) => config
+                        .AddJsonFile("appsettings.json", optional: false, reloadOnChange: true)
+                        .AddJsonFile("appsettings.localhost.json", optional: true, reloadOnChange: true)
+                        .AddEnvironmentVariables()
+                    );
                 });
     }
 }

demo/DemoServer/Startup.cs

@@ -1,4 +1,4 @@
-using IntelliTect.SignalR.SqlServer;
+using IntelliTect.AspNetCore.SignalR.SqlServer;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.AspNetCore.HttpsPolicy;
@@ -26,7 +26,7 @@ public void ConfigureServices(IServiceCollection services)
         {
             services.AddRazorPages();
             services.AddSignalR()
-                .AddSqlServer("Server=localhost;Database=SignalRTestDb;Trusted_Connection=True;MultipleActiveResultSets=True;");
+                .AddSqlServer(Configuration.GetConnectionString("Default"));
         }
 
         // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.

src/IntelliTect.AspNetCore.SignalR.SqlServer/Internal/SqlServer/ObservableDbOperation.cs

@@ -307,7 +307,7 @@ protected virtual void SqlDependency_OnChange(SqlNotificationEventArgs e, Action
                 {
                     _logger.LogError("{0}Unexpected SQL notification details: Type={1}, Source={2}, Info={3}", TracePrefix, e.Type, e.Source, e.Info);
 
-                    Faulted(new SqlMessageBusException(String.Format(CultureInfo.InvariantCulture, Resources.Error_UnexpectedSqlNotificationType, e.Type, e.Source, e.Info)));
+                    Faulted(new SqlMessageBusException($"Unexpected SQL notification Type={e.Type}, Source={e.Source}, Info={e.Info}"));
                 }
             }
             else if (e.Type == SqlNotificationType.Subscribe)
@@ -368,7 +368,14 @@ protected virtual bool StartSqlDependencyListener()
             catch (InvalidOperationException)
             {
                 Trace.TraceInformation("{0}SQL Service Broker is disabled, disabling query notifications", TracePrefix);
+                _notificationState = NotificationState.Disabled;
+                return false;
+            }
+            catch (NullReferenceException)
+            {
+                // Workaround for https://github.com/dotnet/SqlClient/issues/1264
 
+                Trace.TraceInformation("{0}SQL Service Broker is disabled, disabling query notifications", TracePrefix);
                 _notificationState = NotificationState.Disabled;
                 return false;
             }

src/IntelliTect.AspNetCore.SignalR.SqlServer/Internal/SqlServer/SqlInstaller.cs

@@ -1,7 +1,7 @@
 // Copyright (c) .NET Foundation. All rights reserved.
 // Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information.
 
-using IntelliTect.SignalR.SqlServer;
+using IntelliTect.AspNetCore.SignalR.SqlServer;
 using Microsoft.Extensions.Logging;
 using System;
 using System.Diagnostics;
@@ -29,10 +29,10 @@ public void Install()
         {
             _logger.LogInformation("Start installing SignalR SQL objects");
 
-            if (!IsSqlEditionSupported(_options.ConnectionString))
-            {
-                throw new PlatformNotSupportedException(Resources.Error_UnsupportedSqlEdition);
-            }
+            //if (!IsSqlEditionSupported(_options.ConnectionString))
+            //{
+            //    throw new PlatformNotSupportedException(Resources.Error_UnsupportedSqlEdition);
+            //}
 
             var script = GetType().Assembly.StringResource("install.sql");