[FunctionName("Fetching")]
public static async Task<List<string>> RunFetching([OrchestrationTrigger] IDurableOrchestrationContext ctx, ILogger log)
{
// Some Code
}
[FunctionName("Fetching_Secondary")]
public static async Task<string[]> Secondary([ActivityTrigger] string input, ILogger log)
{
// Some code that returns to "Fetching"
}
[FunctionName("Fetching_HttpStart")]
public static async Task<IActionResult> HttpStart([HttpTrigger(AuthorizationLevel.Anonymous, "post")] HttpRequestMessage req, [DurableClient] IDurableOrchestrationClient starter, Ilogger log)
{
string input = await req.Content.ReadAsStringAsync();
try
{
var inputData = JsonConvert.DeserializeObject<object>(input): // This has other types but I figure irrelevant for now
var instanceId = await starter.StartNewAsync("Fetching", null, inputData);
return new OkObjectResult(await starter.CreateCheckStatusResponse(req, instanceId).Content.ReadAsStringAsync());
} catch (Exception e)
{
log.LogDebug(e.Message);
}
}
[FunctionName("Fetching")]
public static async Task<List<string>> RunFetching([OrchestrationTrigger] IDurableOrchestrationContext ctx, ILogger log)
{
// Some Code
}
[FunctionName("Fetching_Secondary")]
public static async Task<string[]> Secondary([ActivityTrigger] string input, ILogger log)
{
// Some code that returns to "Fetching"
}
[FunctionName("Fetching_HttpStart")]
public static async Task<IActionResult> HttpStart([HttpTrigger(AuthorizationLevel.Anonymous, "post")] HttpRequestMessage req, [DurableClient] IDurableOrchestrationClient starter, Ilogger log)
{
string input = await req.Content.ReadAsStringAsync();
try
{
var inputData = JsonConvert.DeserializeObject<object>(input): // This has other types but I figure irrelevant for now
var instanceId = await starter.StartNewAsync("Fetching", null, inputData);
return new OkObjectResult(await starter.CreateCheckStatusResponse(req, instanceId).Content.ReadAsStringAsync());
} catch (Exception e)
{
log.LogDebug(e.Message);
}
}