Corrected context information processing in the background job.

Author: jgauffin

src/Server/Coderr.Server.ReportAnalyzer/AnalysisDbContext.cs

@@ -35,9 +35,17 @@ public IDbConnection Connection
         {
             get
             {
+                if (_unitOfWork is OurUnitOfWork ourUnitOfWork)
+                {
+                    return ourUnitOfWork.Transaction.Connection;
+                }
+                if (_unitOfWork != null && _con == null)
+                {
+                    throw new NotSupportedException("Got a unit of work but not a connection");
+                }
+
                 if (_con != null)
                     return _con;
-
                 _con = _connectionFactory();
                 return _con;
             }

src/Server/Coderr.Server.ReportAnalyzer/OurUnitOfWork.cs

@@ -36,6 +36,9 @@ public void Dispose()
 
         public void SaveChanges()
         {
+            if (Transaction == null)
+                return;
+
             Transaction.Commit();
             Transaction.Dispose();
             Transaction = null;

src/Server/Coderr.Server.SqlServer/Analysis/Jobs/InsertCollectionsJob.cs

@@ -43,10 +43,11 @@ public async Task ExecuteAsync()
                     break;
 
                 await DeleteImportedRows(collections);
+                await _importer.Execute();
                 _importer.Clear();
             }
 
-         //   _dbContext.SaveChanges();
+            _dbContext.SaveChanges();
         }
 
 

src/Server/Coderr.Server.SqlServer/Analysis/Jobs/RemoveOldCollectionDataJob.cs

@@ -70,6 +70,8 @@ public async Task ExecuteAsync()
                     }
                 }
             }
+
+            _analysisDbContext.SaveChanges();
         }
     }
 }

src/Server/Coderr.Server.Web.Tests/applicationhost.config

@@ -1,4 +1,10 @@
-<?xml version="1.0" encoding="UTF-8"?>
+
+
+
+
+
+
+<?xml version="1.0" encoding="UTF-8"?>
 <!--
 
     IIS configuration sections.
@@ -162,10 +168,10 @@
             </site>
             <site name="codeRR.Server.Web" id="2">
                 <application path="/" applicationPool="Clr4IntegratedAppPool">
-                    <virtualDirectory path="/" physicalPath="C:\src\1tcompany\codeRR.oss\codeRR.Server\src\Server\Coderr.Server.Web" />
+                    <virtualDirectory path="/" physicalPath="D:\src\1TCompany\codeRR\OSS\codeRR.Server\src\Server\Coderr.Server.Web" />
                 </application>
                 <application path="/coderr" applicationPool="Clr4IntegratedAppPool">
-                    <virtualDirectory path="/" physicalPath="C:\src\1tcompany\codeRR.oss\codeRR.Server\src\Server\Coderr.Server.Web" />
+                    <virtualDirectory path="/" physicalPath="D:\src\1TCompany\codeRR\OSS\codeRR.Server\src\Server\Coderr.Server.Web" />
                 </application>
                 <bindings>
                     <binding protocol="http" bindingInformation="*:50473:localhost" />

src/Server/Coderr.Server.Web/App_Start/CompositionRoot.cs

@@ -73,7 +73,7 @@ private IScopedTaskInvoker CreateTaskInvoker(IServiceLocator arg)
         private IAdoNetUnitOfWork CreateUnitOfWork(IServiceLocator arg)
         {
             var con = DbConnectionFactory.Open(true);
-            return new AdoNetUnitOfWork(con, true, IsolationLevel.RepeatableRead);
+            return new OurUnitOfWork(con, true);
         }
 
         private IDbConnection CreateConnection(IServiceLocator arg)

src/Server/Coderr.Server.Web/App_Start/Services/ServiceRunner.cs

@@ -133,7 +133,7 @@ private void BuildServices()
             _backgroundJobManager = new BackgroundJobManager(CompositionRoot.Container);
             _backgroundJobManager.JobFailed += OnJobFailed;
             _backgroundJobManager.StartInterval = TimeSpan.FromSeconds(Debugger.IsAttached ? 0 : 10);
-            _backgroundJobManager.ExecuteInterval = TimeSpan.FromMinutes(3);
+            _backgroundJobManager.ExecuteInterval = TimeSpan.FromSeconds(30);
 
             _backgroundJobManager.ScopeClosing += OnBackgroundJobScopeClosing;
         }

src/Server/Coderr.Server.Web/Infrastructure/TransactionalAttribute.cs

@@ -3,6 +3,7 @@
 using System.Linq;
 using System.Web;
 using System.Web.Mvc;
+using codeRR.Server.ReportAnalyzer;
 using Griffin.Data;
 
 namespace codeRR.Server.Web.Infrastructure
@@ -13,7 +14,7 @@ public override void OnActionExecuted(ActionExecutedContext filterContext)
         {
             if (filterContext.Exception == null && filterContext.Controller.ViewData.ModelState.IsValid)
             {
-                var uow = (AdoNetUnitOfWork) filterContext.HttpContext.GetService(typeof(IAdoNetUnitOfWork));
+                var uow = (OurUnitOfWork) filterContext.HttpContext.GetService(typeof(IAdoNetUnitOfWork));
                 uow.SaveChanges();
             }