Allow skipping version check on versioned docs

Author: ejsmith

src/Foundatio.Repositories.Elasticsearch/Repositories/ElasticRepositoryBase.cs

@@ -204,7 +204,7 @@ await Run.WithRetriesAsync(async () => {
                 if (id.Routing != null)
                     indexParameters.Routing = id.Routing;
 
-                if (HasVersion) {
+                if (HasVersion && !options.ShouldSkipVersionCheck()) {
                     indexParameters.IfSequenceNumber = response.SequenceNumber;
                     indexParameters.IfPrimaryTerm = response.PrimaryTerm;
                 }
@@ -1097,7 +1097,7 @@ private async Task IndexDocumentsAsync(IReadOnlyCollection<T> documents, bool is
 
                 i.Index(ElasticIndex.GetIndex(document));
 
-                if (HasVersion && !isCreateOperation) {
+                if (HasVersion && !isCreateOperation && !options.ShouldSkipVersionCheck()) {
                     var elasticVersion = ((IVersioned)document).GetElasticVersion();
                     i.IfPrimaryTerm(elasticVersion.PrimaryTerm);
                     i.IfSequenceNumber(elasticVersion.SequenceNumber);
@@ -1134,7 +1134,7 @@ private async Task IndexDocumentsAsync(IReadOnlyCollection<T> documents, bool is
                 //baseOperation.Routing = GetParentIdFunc != null ? GetParentIdFunc(d) : d.Id;
                 baseOperation.Index = ElasticIndex.GetIndex(d);
 
-                if (HasVersion && !isCreateOperation) {
+                if (HasVersion && !isCreateOperation && !options.ShouldSkipVersionCheck()) {
                     var elasticVersion = ((IVersioned)d).GetElasticVersion();
                     indexOperation.IfSequenceNumber = elasticVersion.SequenceNumber;
                     indexOperation.IfPrimaryTerm = elasticVersion.PrimaryTerm;

src/Foundatio.Repositories/Options/VersionOptions.cs

@@ -0,0 +1,23 @@
+using Foundatio.Repositories.Options;
+
+namespace Foundatio.Repositories {
+    public static class SetVersionsOptionsExtensions {
+        internal const string SkipVersionCheckKey = "@SkipVersionCheck";
+
+        public static T VersionCheck<T>(this T options, bool shouldCheckVersion) where T : ICommandOptions {
+            return options.BuildOption(SkipVersionCheckKey, shouldCheckVersion);
+        }
+
+        public static T SkipVersionCheck<T>(this T options) where T : ICommandOptions {
+            return options.VersionCheck(true);
+        }
+    }
+}
+
+namespace Foundatio.Repositories.Options {
+    public static class ReadVersionOptionsExtensions {
+        public static bool ShouldSkipVersionCheck(this ICommandOptions options) {
+            return options.SafeGetOption(SetVersionsOptionsExtensions.SkipVersionCheckKey, false);
+        }
+    }
+}

tests/Foundatio.Repositories.Elasticsearch.Tests/VersionedTests.cs

@@ -41,6 +41,20 @@ public async Task AddAsync() {
         Assert.Equal(employee, employee2);
     }
 
+    [Fact]
+    public async Task CanSaveNonExistingAsync() {
+        var employee = EmployeeGenerator.Default;
+        Assert.Null(employee.Version);
+        employee.Id = ObjectId.GenerateNewId().ToString();
+
+        employee = await _employeeRepository.SaveAsync(employee, o => o.SkipVersionCheck());
+        Assert.NotNull(employee?.Id);
+        Assert.Equal("1:0", employee.Version);
+
+        var employee2 = await _employeeRepository.GetByIdAsync(employee.Id);
+        Assert.Equal(employee, employee2);
+    }
+
     [Fact]
     public async Task AddAndIgnoreHighVersionAsync() {
         var employee = EmployeeGenerator.Generate();