Merge pull request #643 from nhsconnect/develop

Minor mods
nhsconnect · Jun 24, 2024 · 6e3ccbf · 6e3ccbf
2 parents ce2aecd + 689b902
commit 6e3ccbf
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/database/functions/R__reporting.add_transient_data.sql b/database/functions/R__reporting.add_transient_data.sql
@@ -2,15 +2,15 @@ drop function if exists reporting.add_transient_data;
 
 create function reporting.add_transient_data
 (
-	_transient_id varchar(100),
-	_transient_data json,
-	_transient_report_id varchar(100),
-	_transient_report_name varchar(100)
+	_transient_id text,
+	_transient_data text,
+	_transient_report_id text,
+	_transient_report_name text
 )
 returns void
 as $$
 begin	
 	insert into reporting.transient(transient_id, transient_data, transient_report_id, transient_report_name, entry_date)
-	values (_transient_id, _transient_data, _transient_report_id, _transient_report_name, now());
+	values (_transient_id, _transient_data::json, _transient_report_id, _transient_report_name, now());
 end;
 $$ language plpgsql;
diff --git a/modules/api/src/Service/ReportingService.cs b/modules/api/src/Service/ReportingService.cs
@@ -104,10 +104,10 @@ private async Task CreateTransientData(string transientData, RouteReportRequest
         {
             var functionName = "reporting.add_transient_data";
             var parameters = new DynamicParameters();
-            parameters.Add("_transient_id", routeReportRequest.ObjectKeyJson);
-            parameters.Add("_transient_data", transientData);
-            parameters.Add("_transient_report_id", routeReportRequest.ReportId);
-            parameters.Add("_transient_report_name", routeReportRequest.ReportName);
+            parameters.Add("_transient_id", routeReportRequest.ObjectKeyJson, DbType.String, ParameterDirection.Input);
+            parameters.Add("_transient_data", transientData, DbType.String, ParameterDirection.Input);
+            parameters.Add("_transient_report_id", routeReportRequest.ReportId, DbType.String, ParameterDirection.Input);
+            parameters.Add("_transient_report_name", routeReportRequest.ReportName, DbType.String, ParameterDirection.Input);
             await _dataService.ExecuteQuery(functionName, parameters);
         }
     }