yuka1984

[FunctionName("RegistOrder")]
public static async Task<HttpResponseMessage> RegistOrder(
    [HttpTrigger(AuthorizationLevel.Function, "post", Route = "order")]HttpRequestMessage request
    ,[OrchestrationClient]DurableOrchestrationClientBase client)
{
    var input = await request.Content.ReadAsStringAsync();
    var instanceId = await client.StartNewAsync("OrderRegistOrchestrator", int.Parse(input));
    return client.CreateCheckStatusResponse(request, instanceId);
}

yuka1984

[FunctionName("OrderRegistOrchestrator")]
public static async Task OrderRegistOrchestrator(
    [OrchestrationTrigger]DurableOrchestrationContext ctx)
{

    int orderNo = ctx.GetInput<int>();

    // Order情報をつけとって
    Order order = await ctx.CallActivityAsync<Order>("GetOrder", orderNo);

yuka1984

[FunctionName("GetOrder")]
public static async Task<Order> GetOrderActivity([ActivityTrigger]int input)
{
    var client = new HttpClient();
    var json = await client.GetStringAsync($"https://hogehoge.com/order/{input}");
    return JsonConvert.DeserializeObject<Order>(json);
}

[FunctionName("SendOrder")]
public static async Task SendOrderActivity([ActivityTrigger]Order input)

yuka1984

    public static class ConfigurationManagerRequired
    {
        static ConfigurationManagerRequired()
        {
            AppSettings = new AppSettingsRequired();
        }

        public static AppSettingsRequired AppSettings { get; }

yuka1984

        [FunctionName("OrderOrchestrator")]
        public static async Task Order([OrchestrationTrigger]DurableOrchestrationContextBase context)
        {
            var order = context.GetInput<OrderModel>();

            await context.CallActivityAsync("InsertToRepository" , order);

            while (true)
            {
                try

yuka1984

[FunctionName("HookRecieve")]
public static async Task<HttpResponseMessage> Run(
    [HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)]HttpRequestMessage req
    , [Table("KeySaveTable")] CloudTable table
    , [OrchestrationClient] DurableOrchestrationClient client
    , TraceWriter log)
{
    var json = await req.Content.ReadAsStringAsync();
    var result = JsonConvert.DeserializeObject<WebHookResult>(json);
    var query = new TableQuery<TableEntity>()

yuka1984

[FunctionName(nameof(SaveRequestKeyActivity))]
public static async Task SaveRequestKeyActivity(
    [ActivityTrigger] DurableActivityContext context,
    [Table("KeySaveTable")] CloudTable table
    )
{
    var key = context.GetInput<string>();
    var insertOperation = TableOperation.Insert(new TableEntity(key, context.InstanceId));
    await table.ExecuteAsync(insertOperation);
}

yuka1984

[FunctionName(nameof(HookApiRequestActivity))]
public static async Task<string> HookApiRequestActivity(
    [ActivityTrigger] int requestValue
    )
{
    var url = $"{ConfigurationManager.AppSettings["HookUrl"]}?Value={requestValue}";
    ServicePointManager.DefaultConnectionLimit = 100;
    using (var client = new HttpClient())
    {
        var result = await client.GetStringAsync(url);

yuka1984

[FunctionName(nameof(WebHookOrchestrator))]
public static async Task<ResultModel> WebHookOrchestrator(
    [OrchestrationTrigger]DurableOrchestrationContext context
    )
{
    var requestVaue = context.GetInput<int>();
    var hookKey = await context.CallActivityAsync<string>(nameof(HookApiRequestActivity), requestVaue);
    await context.CallActivityAsync(nameof(SaveRequestKeyActivity), hookKey);
    var result = await context.WaitForExternalEvent<ResultModel>(HookWaitEventName);
    return result;

yuka1984

public Task<IListener> CreateListenerAsync(ListenerFactoryContext context)
{
    _configuration.AddConfigExecutor(context.Descriptor.ShortName, context.Executor);
    return Task.FromResult((IListener) new InjectConfigurationTriggerListener());
}