Use array as value type for job arguments column

Author: azygis

src/Hangfire.PostgreSql/PostgreSqlConnection.cs

@@ -125,7 +125,7 @@ public override string CreateExpiredJob(
         string jobId = connection.QuerySingle<long>(createJobSql,
           new {
             InvocationData = new JsonParameter(SerializationHelper.Serialize(invocationData)),
-            Arguments = new JsonParameter(invocationData.Arguments),
+            Arguments = new JsonParameter(invocationData.Arguments, JsonParameter.ValueType.Array),
             CreatedAt = createdAt,
             ExpireAt = createdAt.Add(expireIn),
           }).ToString(CultureInfo.InvariantCulture);

tests/Hangfire.PostgreSql.Tests/PostgreSqlConnectionFacts.cs

@@ -202,7 +202,7 @@ public void GetJobData_ReturnsResult_WhenJobExists()
           new {
             InvocationData = new JsonParameter(SerializationHelper.Serialize(InvocationData.SerializeJob(job))),
             StateName = "Succeeded",
-            Arguments = new JsonParameter("[\"\\\"Arguments\\\"\"]"),
+            Arguments = new JsonParameter("[\"\\\"Arguments\\\"\"]", JsonParameter.ValueType.Array),
           });
 
         JobData result = jobStorageConnection.GetJobData(jobId.ToString(CultureInfo.InvariantCulture));

tests/Hangfire.PostgreSql.Tests/PostgreSqlJobQueueFacts.cs

@@ -204,7 +204,7 @@ WITH i AS (
       // Arrange
       UseConnection((connection, storage) => {
         connection.Execute(arrangeSql,
-          new { InvocationData = new JsonParameter(""), Arguments = new JsonParameter(""), Queue = "default" });
+          new { InvocationData = new JsonParameter(""), Arguments = new JsonParameter("", JsonParameter.ValueType.Array), Queue = "default" });
         PostgreSqlJobQueue queue = CreateJobQueue(storage, useNativeDatabaseTransactions);
 
         // Act
@@ -298,8 +298,8 @@ WITH i AS (
       UseConnection((connection, storage) => {
         connection.Execute(arrangeSql,
           new[] {
-            new { Queue = "default", InvocationData = new JsonParameter(""), Arguments = new JsonParameter("") },
-            new { Queue = "default", InvocationData = new JsonParameter(""), Arguments = new JsonParameter("") },
+            new { Queue = "default", InvocationData = new JsonParameter(""), Arguments = new JsonParameter("", JsonParameter.ValueType.Array) },
+            new { Queue = "default", InvocationData = new JsonParameter(""), Arguments = new JsonParameter("", JsonParameter.ValueType.Array) },
           });
         PostgreSqlJobQueue queue = CreateJobQueue(storage, useNativeDatabaseTransactions);
 
@@ -345,7 +345,7 @@ WITH i AS (
         PostgreSqlJobQueue queue = CreateJobQueue(storage, useNativeDatabaseTransactions);
 
         connection.Execute(arrangeSql,
-          new { Queue = "critical", InvocationData = new JsonParameter(""), Arguments = new JsonParameter("") });
+          new { Queue = "critical", InvocationData = new JsonParameter(""), Arguments = new JsonParameter("", JsonParameter.ValueType.Array) });
 
         Assert.Throws<OperationCanceledException>(() => queue.Dequeue(_defaultQueues,
           CreateTimingOutCancellationToken()));
@@ -383,8 +383,8 @@ WITH i AS (
       UseConnection((connection, storage) => {
         connection.Execute(arrangeSql,
           new[] {
-            new { Queue = queueNames.First(), InvocationData = new JsonParameter("") , Arguments = new JsonParameter("") },
-            new { Queue = queueNames.Last(), InvocationData = new JsonParameter(""), Arguments = new JsonParameter("") },
+            new { Queue = queueNames.First(), InvocationData = new JsonParameter("") , Arguments = new JsonParameter("", JsonParameter.ValueType.Array) },
+            new { Queue = queueNames.Last(), InvocationData = new JsonParameter(""), Arguments = new JsonParameter("", JsonParameter.ValueType.Array) },
           });
 
         PostgreSqlJobQueue queue = CreateJobQueue(storage, useNativeDatabaseTransactions);

tests/Hangfire.PostgreSql.Tests/PostgreSqlMonitoringApiFacts.cs

@@ -37,7 +37,7 @@ public void GetJobs_MixedCasing_ReturnsJob()
         long jobId = connection.QuerySingle<long>(arrangeSql,
           new {
             InvocationData = new JsonParameter(SerializationHelper.Serialize(invocationData)),
-            Arguments = new JsonParameter(invocationData.Arguments),
+            Arguments = new JsonParameter(invocationData.Arguments, JsonParameter.ValueType.Array),
           });
 
         Mock<IState> state = new();