Add abp.signalr-client

Author: acjh

aspnet-core/src/AbpCompanyName.AbpProjectName.Web.Mvc/AbpCompanyName.AbpProjectName.Web.Mvc.csproj

@@ -16,7 +16,7 @@
   </PropertyGroup>
 
   <PropertyGroup Condition=" '$(TargetFramework)' == 'netcoreapp2.0' ">
-    <DefineConstants>FEATURE_SIGNALR</DefineConstants>
+    <DefineConstants>FEATURE_SIGNALR;FEATURE_SIGNALR_ASPNETCORE</DefineConstants>
   </PropertyGroup>
 
   <ItemGroup>

aspnet-core/src/AbpCompanyName.AbpProjectName.Web.Mvc/Startup/Startup.cs

@@ -19,6 +19,10 @@
 using AbpCompanyName.AbpProjectName.Owin;
 #endif
 
+#if FEATURE_SIGNALR_ASPNETCORE
+using Abp.Web.SignalR.Hubs;
+#endif
+
 namespace AbpCompanyName.AbpProjectName.Web.Startup
 {
     public class Startup
@@ -42,6 +46,10 @@ public IServiceProvider ConfigureServices(IServiceCollection services)
 
             services.AddScoped<IWebResourceManager, WebResourceManager>();
 
+#if FEATURE_SIGNALR_ASPNETCORE
+            services.AddSignalR();
+#endif
+
             // Configure Abp and Dependency Injection
             return services.AddAbp<AbpProjectNameWebMvcModule>(
                 // Configure Log4Net logging
@@ -75,6 +83,13 @@ public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerF
             app.UseAppBuilder(ConfigureOwinServices);
 #endif
 
+#if FEATURE_SIGNALR_ASPNETCORE
+            app.UseSignalR(routes =>
+            {
+                routes.MapHub<AbpCommonHub>("/abpCommonHub");
+            });
+#endif
+
             app.UseMvc(routes =>
             {
                 routes.MapRoute(

aspnet-core/src/AbpCompanyName.AbpProjectName.Web.Mvc/wwwroot/lib/abp-web-resources/Abp/Framework/scripts/libs/abp.signalr-client.js

@@ -0,0 +1,95 @@
+var abp = abp || {};
+(function () {
+
+    // Check if SignalR is defined
+    if (!signalR) {
+        return;
+    }
+
+    // Create namespaces
+    abp.signalr = abp.signalr || {};
+    abp.signalr.hubs = abp.signalr.hubs || {};
+
+    // Configure the connection
+    function configureConnection(connection) {
+        // Set the common hub
+        abp.signalr.hubs.common = connection;
+
+        // Reconnect if hub disconnects
+        connection.onclose(function (e) {
+            if (e) {
+                abp.log.debug('Connection closed with error: ' + e);
+            }
+            else {
+                abp.log.debug('Disconnected');
+            }
+
+            if (!abp.signalr.autoConnect) {
+                return;
+            }
+
+            setTimeout(function () {
+                if ($.connection.hub.state === $.signalR.connectionState.disconnected) {
+                    $.connection.hub.start();
+                }
+            }, 5000);
+        });
+
+        // Register to get notifications
+        connection.on('getNotification', function (notification) {
+            abp.event.trigger('abp.notifications.received', notification);
+        });
+    }
+
+    // Connect to the server
+    abp.signalr.connect = function() {
+        // Start the connection.
+        startConnection('/abpCommonHub', configureConnection).then(function (connection) {
+            abp.log.debug('Connected to SignalR server!'); //TODO: Remove log
+            abp.event.trigger('abp.signalr.connected');
+            // Call the Register method on the hub.
+            connection.invoke('register').then(function () {
+                abp.log.debug('Registered to the SignalR server!'); //TODO: Remove log
+            });
+        })
+        .catch(error => {
+            abp.log.debug(error.message);
+        });
+    };
+
+    // Starts a connection with transport fallback - if the connection cannot be started using
+    // the webSockets transport the function will fallback to the serverSentEvents transport and
+    // if this does not work it will try longPolling. If the connection cannot be started using
+    // any of the available transports the function will return a rejected Promise.
+    function startConnection(url, configureConnection) {
+        return function start(transport) {
+            abp.log.debug(`Starting connection using ${signalR.TransportType[transport]} transport`)
+            var connection = new signalR.HubConnection(url, {transport: transport});
+            if (configureConnection && typeof configureConnection === 'function') {
+                configureConnection(connection);
+            }
+
+            return connection.start()
+                .then(function() {
+                    return connection;
+                })
+                .catch(function(error) {
+                    abp.log.debug(`Cannot start the connection use ${signalR.TransportType[transport]} transport. ${error.message}`);
+                    if (transport !== signalR.TransportType.LongPolling) {
+                        return start(transport + 1);
+                    }
+
+                    return Promise.reject(error);
+                });
+        }(signalR.TransportType.WebSockets);
+    }
+
+    if (abp.signalr.autoConnect === undefined) {
+        abp.signalr.autoConnect = true;
+    }
+
+    if (abp.signalr.autoConnect) {
+        abp.signalr.connect();
+    }
+
+})();