Merge pull request #15 from raisedapp/develop

Version 0.2.1

Author: felixclase

src/main/Hangfire.Storage.SQLite/Entities/JobParameter.cs

@@ -20,5 +20,8 @@ public class JobParameter
 
         [MaxLength(DefaultValues.MaxLengthVarCharColumn)]
         public string Value { get; set; }
+
+        [Indexed(Name = "IX_JobParameter_ExpireAt", Order = 3, Unique = false)]
+        public DateTime ExpireAt { get; set; } = DateTime.MinValue;
     }
 }

src/main/Hangfire.Storage.SQLite/Entities/State.cs

@@ -24,5 +24,8 @@ public class State
 
         [MaxLength(DefaultValues.MaxLengthVarCharColumn)]
         public string Data { get; set; }
+
+        [Indexed(Name = "IX_State_ExpireAt", Order = 2, Unique = false)]
+        public DateTime ExpireAt { get; set; } = DateTime.MinValue;
     }
 }

src/main/Hangfire.Storage.SQLite/ExpirationManager.cs

@@ -34,6 +34,8 @@ public class ExpirationManager : IBackgroundProcess, IServerComponent
             DefaultValues.HangfireListTblName,
             DefaultValues.SetTblName,
             DefaultValues.HashTblName,
+            DefaultValues.StateTblName,
+            DefaultValues.JobParameterTblName
         };
 
         private static readonly ILog Logger = LogProvider.For<ExpirationManager>();

src/main/Hangfire.Storage.SQLite/Hangfire.Storage.SQLite.csproj

@@ -7,7 +7,7 @@
     <TargetFrameworks>netstandard2.0;net45</TargetFrameworks>
   </PropertyGroup>
   <PropertyGroup>
-    <Version>0.2.0</Version>
+    <Version>0.2.1</Version>
     <Authors>RaisedApp</Authors>
     <Company>RaisedApp</Company>
     <Copyright>Copyright © 2019 - Present</Copyright>
@@ -20,9 +20,9 @@
     <title>Hangfire Storage SQLite</title>    
     <Description>An Alternative SQLite Storage for Hangfire</Description>
     <PackageReleaseNotes>
-      0.2.0
-      - Distributed Lock In ExpirationManager
-      - ExpireAt In JobDetails Method
+      0.2.1
+      - Add AutoVacuum Options
+      - Add ExpireAt In JobParamter And State Models
     </PackageReleaseNotes>
   </PropertyGroup>
   <ItemGroup>

src/main/Hangfire.Storage.SQLite/HangfireDbContext.cs

@@ -1,4 +1,5 @@
-using Hangfire.Storage.SQLite.Entities;
+using Hangfire.Logging;
+using Hangfire.Storage.SQLite.Entities;
 using Newtonsoft.Json;
 using SQLite;
 using System;
@@ -12,7 +13,7 @@ namespace Hangfire.Storage.SQLite
     /// </summary>
     public class HangfireDbContext
     {
-        private readonly string _prefix;
+        private readonly ILog Logger = LogProvider.For<HangfireDbContext>();
 
         /// <summary>
         /// 
@@ -106,6 +107,15 @@ public void Init(SQLiteStorageOptions storageOptions)
             SetRepository = Database.Table<Set>();
             StateRepository = Database.Table<State>();
             DistributedLockRepository = Database.Table<DistributedLock>();
+
+            try
+            {
+                Database.Execute($"PRAGMA auto_vacuum = {(int) storageOptions.AutoVacuumSelected};");
+            }
+            catch (Exception ex)
+            {
+                Logger.Log(LogLevel.Error, () => $"Error set auto vacuum mode. Details: {ex.ToString()}");
+            }
         }
 
         public TableQuery<AggregatedCounter> AggregatedCounterRepository { get; private set; }

src/main/Hangfire.Storage.SQLite/SQLiteStorageOptions.cs

@@ -95,5 +95,17 @@ public TimeSpan DistributedLockLifetime
         /// Counters interval
         /// </summary>
         public TimeSpan CountersAggregateInterval { get; set; }
+
+        /// <summary>
+        /// Set AutoVacuum Mode In SQLite
+        /// </summary>
+        public AutoVacuum AutoVacuumSelected { get; set; } = AutoVacuum.NONE;
+
+        public enum AutoVacuum 
+        {
+            NONE = 0,
+            FULL = 1,
+            INCREMENTAL = 2
+        }
     }
 }

src/main/Hangfire.Storage.SQLite/SQLiteWriteOnlyTransaction.cs

@@ -168,11 +168,15 @@ public override void ExpireJob(string jobId, TimeSpan expireIn)
             {
                 var iJobId = int.Parse(jobId);
                 var job = _.HangfireJobRepository.FirstOrDefault(x => x.Id == iJobId);
-                
+
                 if (job != null) 
                 {
-                    job.ExpireAt = DateTime.UtcNow.Add(expireIn);
+                    var expireAt = DateTime.UtcNow.Add(expireIn);
+                    job.ExpireAt = expireAt;
+
                     _.Database.Update(job);
+                    _.Database.Execute($"UPDATE [{DefaultValues.StateTblName}] SET ExpireAt = {expireAt.Ticks} WHERE JobId = {jobId}");
+                    _.Database.Execute($"UPDATE [{DefaultValues.JobParameterTblName}] SET ExpireAt = {expireAt.Ticks} WHERE JobId = {jobId}");
                 }
             });   
         }

src/test/Hangfire.Storage.SQLite.Test/SQLiteDistributedLockFacts.cs

@@ -165,7 +165,7 @@ public void Ctor_WaitForLock_OnlySingleLockCanBeAcquired()
 
             manualResetEvent.Set();
 
-            threads.ForEach(t => Assert.True(t.Join(TimeSpan.FromSeconds(90)), "Thread is hanging unexpected"));
+            threads.ForEach(t => Assert.True(t.Join(TimeSpan.FromSeconds(120)), "Thread is hanging unexpected"));
 
             // All the threads should report success.
             Interlocked.MemoryBarrier();