Skip to content
Snippets Groups Projects
Commit 35705c00 authored by Klaus Fischer's avatar Klaus Fischer
Browse files

Changed DemoSender to meet SchemaUri for Destination

parent 84c0dae8
No related branches found
No related tags found
2 merge requests!58Issue/release preparation,!42Issue/872 check submission data schema
......@@ -30,7 +30,7 @@ public static class SenderDemo {
var sendableSubmission = SendableSubmission.Builder()
.SetDestination(destinationId)
.SetServiceType(serviceIdentifier, "FIT Connect Demo")
.SetJsonData("{\"message\":\"Hello World\"}", new Uri("urn:ietf:rfc:3986"))
.SetJsonData("{\"message\":\"Hello World\"}", new Uri("https://git.fitko.de/fit-connect/sdk-dotnet/-/raw/issue/872-check-submission-data-schema/Examples/example.schema.json"))
.AddAttachments(
Attachment.FromPath("./Attachments/Test.pdf", "application/pdf",
description: "Test Attachment"),
......
......@@ -25,7 +25,9 @@ public static class SubscriberDemo {
await File.ReadAllTextAsync(privateKeySigning),
logger);
var submissionForPickups = await subscriber.GetAvailableSubmissionsAsync(Guid.Parse(config["FitConnect:Subscriber:DestinationId"]!));
var submissionForPickups =
await subscriber.GetAvailableSubmissionsAsync(
Guid.Parse(config["FitConnect:Subscriber:DestinationId"]!));
foreach (var submission in submissionForPickups) {
var outputDirectory = Directory.CreateDirectory(
......@@ -34,22 +36,25 @@ public static class SubscriberDemo {
outputDirectory.Create();
var receivedSubmission =
await subscriber.RequestSubmissionAsync(submission.SubmissionId);
logger.LogInformation("Fachdaten:\r\n\tMimeType: {mimeType}\r\n\t{Data}",
receivedSubmission.GetDataMimeType(), receivedSubmission.GetData());
// receivedSubmission.GetDataSchemaUri();
var metadata = receivedSubmission.Metadata;
var attachments = await receivedSubmission.GetAttachmentsAsync();
foreach (var attachment in attachments)
if (attachment.GetBytes().Length > 0) {
await File.WriteAllBytesAsync(
outputDirectory.FullName + "/" + (attachment.Filename ?? "temp.dat"),
attachment.GetBytes());
}
foreach (var attachment in attachments) {
if (attachment.GetBytes().Length == 0)
continue;
var content = attachment.GetBytes();
await File.WriteAllBytesAsync(
Path.Combine(outputDirectory.FullName, (attachment.Filename ?? "temp.dat")),
content);
}
await receivedSubmission
.AcceptSubmissionAsync();
......
......@@ -35,8 +35,9 @@ public static class JsonHelper {
}
var result = schema.Validate(metadataString).ToList();
logger?.LogError("Validation failed with {Errors}",
result.Aggregate("", (a, b) => a + "\n\t" + b));
if (result.Count > 0)
logger?.LogError("Validation failed with {Errors}",
result.Aggregate("", (a, b) => a + "\n\t" + b));
return new VerificationResult(result.Count == 0, result);
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment