Added additional language parameter.

Author: jakeminard

Optimizely.Graph.Source.Sdk/Optimizely.Graph.Source.Sdk.Sample/Program.cs

@@ -192,7 +192,7 @@
     }
 };
 
-await client.SaveContentAsync(generateId: (x) => $"{x.Name}_{x.Address.City}", exampleDataInstance1, exampleDataInstance2, exampleDataInstance3);
+await client.SaveContentAsync(generateId: (x) => $"{x.Name}_{x.Address.City}", "en", exampleDataInstance1, exampleDataInstance2, exampleDataInstance3);
 #endregion
 
 #region ExampleTypes

Optimizely.Graph.Source.Sdk/Optimizely.Graph.Source.Sdk.Tests/RepositoryTests/GraphSourceRepositoryTests.cs

@@ -206,7 +206,7 @@ public async Task SaveContentAsync_SerializesData_AndCallsGraphClient()
             mockRestClient.Setup(c => c.HandleResponse(response));
 
             // Act
-            await repository.SaveContentAsync(generateId: (x) => x.ToString(), exampleData);
+            await repository.SaveContentAsync(generateId: (x) => x.ToString(), "en", exampleData);
 
             // Assert
             mockRestClient.Verify(c => c.SendAsync(It.Is<HttpRequestMessage>(x => Compare(request, x))), Times.Once);
@@ -316,7 +316,7 @@ public async Task SaveContentAsync_WithMultipleTypes_ShouldGenerateJsonForConten
             mockRestClient.Setup(c => c.HandleResponse(response));
 
             // Act
-            await repository.SaveContentAsync<object>(generateId, locationStockholm, locationLondon, event1, event2, event3);
+            await repository.SaveContentAsync<object>(generateId, "en", locationStockholm, locationLondon, event1, event2, event3);
 
             // Assert
             Assert.AreEqual(expectedJsonString, jsonString);
@@ -353,7 +353,7 @@ public async Task CreateContent_ShouldContainTwoNewLines()
             };
 
             // Act
-            var createdContent = repository.CreateContent(generateId: (x) => x.ToString(), exampleData);
+            var createdContent = repository.CreateContent(generateId: (x) => x.ToString(), "en", exampleData);
             var result = createdContent.ReadAsStringAsync().Result;
 
             // Assert
@@ -387,7 +387,7 @@ public async Task CreateContent_ShouldProduceMinifiedContent()
             };
 
             // Act
-            var createdContent = repository.CreateContent(generateId: (x) => x.ToString(), exampleData);
+            var createdContent = repository.CreateContent(generateId: (x) => x.ToString(), "en", exampleData);
             var result = createdContent.ReadAsStringAsync().Result;
 
             // Assert

Optimizely.Graph.Source.Sdk/Optimizely.Graph.Source.Sdk/GraphSourceClient.cs

@@ -89,10 +89,10 @@ public async Task<string> SaveTypesAsync()
         /// <param name="generateId">Id associated with content.</param>
         /// <param name="data">Dynamic data being saved to Content Graph.</param>
         /// <returns></returns>
-        public async Task<string> SaveContentAsync<T>(Func<T, string> generateId, params T[] data)
+        public async Task<string> SaveContentAsync<T>(Func<T, string> generateId, string language, params T[] data)
             where T : class, new()
         {
-            return await repository.SaveContentAsync(generateId, data);
+            return await repository.SaveContentAsync(generateId, language, data);
         }
 
         /// <summary>

Optimizely.Graph.Source.Sdk/Optimizely.Graph.Source.Sdk/Repositories/GraphSourceRepository.cs

@@ -80,10 +80,10 @@ public async Task<string> SaveTypesAsync()
         }
 
         /// <inheritdoc/>
-        public async Task<string> SaveContentAsync<T>(Func<T, string> generateId, params T[] data)
+        public async Task<string> SaveContentAsync<T>(Func<T, string> generateId, string language, params T[] data)
             where T : class, new()
         {
-            var content = CreateContent(generateId, data);
+            var content = CreateContent(generateId, language, data);
 
             using (var requestMessage = new HttpRequestMessage(HttpMethod.Post, $"{DataUrl}?id={source}"))
             {
@@ -96,7 +96,7 @@ public async Task<string> SaveContentAsync<T>(Func<T, string> generateId, params
             return string.Empty;
         }
 
-        public StringContent CreateContent<T>(Func<T, string> generateId, params T[] data)
+        public StringContent CreateContent<T>(Func<T, string> generateId, string language, params T[] data)
         {
             var serializeOptions = new JsonSerializerOptions
             {
@@ -111,7 +111,6 @@ public StringContent CreateContent<T>(Func<T, string> generateId, params T[] dat
             foreach (var item in data)
             {
                 var id = generateId(item);
-                var language = "en";
 
                 itemJson += $"{{\"index\":{{\"_id\":\"{id}\",\"language_routing\":\"{language}\"}}}}";
                 itemJson += Environment.NewLine;

Optimizely.Graph.Source.Sdk/Optimizely.Graph.Source.Sdk/Repositories/IGraphSourceRepository.cs

@@ -40,7 +40,7 @@ public interface IGraphSourceRepository
         /// <param name="generateId">Id associated with content.</param>
         /// <param name="data">Dynamic data being saved to Content Graph.</param>
         /// <returns></returns>
-        Task<string> SaveContentAsync<T>(Func<T, string> generateId, params T[] data) where T : class, new();
+        Task<string> SaveContentAsync<T>(Func<T, string> generateId, string language, params T[] data) where T : class, new();
 
         /// <summary>
         /// Removes content previously stored by source.