[FunctionName("ApproveFileUpload")] | |
public static async Task<IActionResult> Run( | |
[HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = "approve/{fileId}")] HttpRequest req, | |
[Table("metadata", "{fileId}", "{fileId}", Connection = "TableConnectionString")] FileMetadata fileMetadata, | |
[Table("metadata", Connection = "TableConnectionString")] CloudTable metadataTable, | |
[DurableClient] IDurableOrchestrationClient client, | |
ILogger log) | |
{ | |
var instanceId = fileMetadata.WorkflowId; | |
fileMetadata.ApprovedForAnalysis = true; | |
var replaceOperation = TableOperation.Replace(fileMetadata); | |
await metadataTable.ExecuteAsync(replaceOperation); | |
await client.RaiseEventAsync(instanceId, "UploadApproved", fileMetadata.ApprovedForAnalysis); | |
return new AcceptedResult(string.Empty, fileMetadata.RowKey); | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment