LineSimulatorを利用してDurable FunctionsでロングランなLineBotをローカル環境交えて作ってみる

using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.Http;
using System.Text;
using System.Threading.Tasks;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.Azure.WebJobs.Host;
using Newtonsoft.Json;

namespace LineBot
{
	public static class Function1
	{
		[FunctionName("Function1")]
		public static async Task<HttpResponseMessage> Run([HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = null)]HttpRequestMessage req, TraceWriter log)
		{
			log.Info("Start");
			// リクエストJSONをパース
			var jsonContent = await req.Content.ReadAsStringAsync();
			var data = JsonConvert.DeserializeObject<Request>(jsonContent);
			string replyToken = null;
			string messageType = null;
			string message = null;
			
			//　本来はLineDeveloperCenterの値を設定
			string ChannelAccessToken = "dummyToken";
			
			// リクエストデータからデータを取得
			foreach (var item in data.Events)
			{
				// リプライデータ送付時の認証トークンを取得
				replyToken = item.ReplyToken;
				if (item.Message == null) continue;
				messageType = item.Message.type;
				message = item.Message.text;
			}
			string reqData = string.Empty;
			if (message.Contains("StatusQueryGetUri"))
			{
				var content = await GetStatusQueryAsync(message.Split(',').Last());
				StatusQueryResponse StatusQueryJson = null;
				if (content != null)
				{
					StatusQueryJson = JsonConvert.DeserializeObject<StatusQueryResponse>(content);
				}
				var replyMessage = ReplyMessages(replyToken, StatusQueryJson);
				reqData = JsonConvert.SerializeObject(replyMessage);
			}
			else
			{
				var DurableResponse = await RequestDurableFunctionsAsync();
				var DurableContent = RichButtonTemplate(DurableResponse);
				reqData = JsonConvert.SerializeObject(DurableContent);
			}
			
			// レスポンスの作成
			using (var client = new HttpClient())
			{
				// リクエストデータを作成
				HttpRequestMessage request =
				new HttpRequestMessage(HttpMethod.Post, "http://localhost:8080/v2/bot/message/reply")
				{
					Content = new StringContent(reqData, Encoding.UTF8, "application/json")
				};
				
				// 認証ヘッダーを追加
				client.DefaultRequestHeaders.Add("Authorization", $"Bearer {ChannelAccessToken}");
				
				// 非同期でPOST
				var res = await client.SendAsync(request);
				return req.CreateResponse(res.StatusCode);
			}
		}
		
		/// <summary>
		/// DurableFunctionsにリクエスト
		/// </summary>
		private static async Task<DurableAsyncHTTPAPIs> RequestDurableFunctionsAsync()
		{
			string eventName = string.Empty;
			string text = "キャンセル理由";
			
			// レスポンスの作成
			using (var client = new HttpClient())
			{
				// リクエストデータを作成
				HttpRequestMessage request =
				new HttpRequestMessage(HttpMethod.Post, "https://{独自に作成したドメインに書き直してください}/orchestrators/{独自に作成したFunction名に書き直してください}");
				
				// 非同期でPOST
				var res = await client.SendAsync(request);
				
				// レスポンスデータからHttpAsyncAPI用のURLを作成
				DurableAsyncHTTPAPIs  req = new DurableAsyncHTTPAPIs()
				{
					Id = "",
					StatusQueryGetUri = $"{res.Headers.Location.Scheme}://{res.Headers.Location.Host}/{res.Headers.Location.LocalPath}?{res.Headers.Location.Query}",
					SendEventPostUri = $"{res.Headers.Location.Scheme}://{res.Headers.Location.Host}/{res.Headers.Location.LocalPath}/raiseEvent/{eventName}?{res.Headers.Location.Query}",
					TerminatePostUri = $"{res.Headers.Location.Scheme}://{res.Headers.Location.Host}/{res.Headers.Location.LocalPath}/terminate?reason={text}&{res.Headers.Location.Query}"
				};
				return req;
			}
		}
		
		/// <summary>
		/// 処理状況を取得するHTTPAsyncAPI
		/// </summary>
		private static async Task<string> GetStatusQueryAsync(string uri)
		{
			// レスポンスの作成
			using (var client = new HttpClient())
			{
				// 非同期でPOST
				var response = await client.GetAsync(uri);
				return await response.Content.ReadAsStringAsync();
			}
		}
		
		/// <summary>
		/// ボタンテンプレートでリプライ情報の作成
		/// </summary>
		private static ResponseDuralbe RichButtonTemplate(DurableAsyncHTTPAPIs message)
		{
			var res = new ResponseDuralbe();
			var lineButtonMessage = new LineButtonMessage();
			var lineButton = new LineButtonMessageTemplate();
			var action = new LineButtonAction();
			res.replyToken = "dummyToken";
			res.messages = new List<LineButtonMessage>()
			{
				new LineButtonMessage()
				{
					altText = "処理を開始しました",
					template = new LineButtonMessageTemplate()
					{
						title = "Durable Functions Test",
						text = "処理開始！！",
						actions = new List<LineButtonAction>()
						{
							new LineButtonAction()
							{
								label="処理確認",
								data = String.Format("StatusQueryGetUri,{0}",message.StatusQueryGetUri)
							}
						}
					}
				}
			};
			return res;
		}
		
		/// <summary>
		/// リプライメッセージの作成
		/// </summary>
		static Response ReplyMessages(string token, StatusQueryResponse contents)
		{
			Messages msg = new Messages();
			StringBuilder sb = new StringBuilder();
			if (contents==null)
			{
				sb.Append("未処理");
			}
			else
			{
				string StartTime = $"処理開始時間：{contents.createdTime}";
				if (contents.runtimeStatus == "Running")
				{
					sb.Append("処理中");
					sb.Append(Environment.NewLine);
					sb.Append(StartTime);
				}
				else if (contents.runtimeStatus == "Completed")
				{
					sb.Append("処理完了");
					sb.Append(Environment.NewLine);
					sb.Append(StartTime);
					sb.Append(Environment.NewLine);
					foreach (var item in contents.output)
					{
						sb.Append(item);
						sb.Append(Environment.NewLine);
					}
				}
				else if (contents.runtimeStatus == "Failed")
				{
					sb.Append("処理失敗");
					sb.Append(Environment.NewLine);
					sb.Append(StartTime);
				}
				else
				{
					sb.Append("不明");
					sb.Append(Environment.NewLine);
					sb.Append(StartTime);
				}
			}
			
			// リプライメッセージの作成
			var res = new Response()
			{
				replyToken = token,
				messages = new List<Messages>()
				{
					new Messages()
					{
						type ="text",
						text = sb.ToString().Replace(Environment.NewLine,"<br>")
					}
				}
			};
			return res;
		}
		
		//********************************************
		// Lineからのリクエストメッセージ用クラス
		//********************************************
		//　リクエスト
		public class Request
		{
			public List<Event> Events { get; set; }
		}
		
		//　イベント
		public class Event
		{
			public string ReplyToken { get; set; }
			public string Type { get; set; }
			public object Timestamp { get; set; }
			public Source Source { get; set; }
			public Message Message { get; set; }
		}
		
		// ソース
		public class Source
		{
			public string type { get; set; }
			public string userId { get; set; }
		}
		
		// リクエストメッセージ
		public class Message
		{
			public string id { get; set; }
			public string type { get; set; }
			public string text { get; set; }
		}

		//********************************************
		// Lineへのリプライメッセージ用クラス
		//********************************************
		// レスポンス
		public class Response
		{
			public string replyToken { get; set; }
			public List<Messages> messages { get; set; }
		}
		
		// レスポンスメッセージ
		public class Messages
		{
			public string type { get; set; }
			public string text { get; set; }
		}

		//********************************************
		// Lineへのボタンテンプレート用クラス
		//********************************************
		public class ResponseDuralbe
		{
			public string replyToken { get; set; }
			public List<LineButtonMessage> messages { get; set; }
		}
		
		// Line ボタン
		public class LineButtonMessage
		{
			public string type { get;  } = "template";
			public string altText { get; set; }
			public LineButtonMessageTemplate template { get; set; }
		}
		
		// Line ボタンテンプレート
		public class LineButtonMessageTemplate
		{
			public string type { get;  } = "buttons";
			public string thumbnailImageUrl { get; set; } = string.Empty;
			public string imageAspectRatio { get; set; } = string.Empty;
			public string imageSize { get; set; } = string.Empty;
			public string imageBackgroundColor { get; set; } = string.Empty;
			public string title { get; set; } = string.Empty;
			public string text { get; set; } = string.Empty;
			public List<LineButtonAction> actions { get; set; }
		}
		
		// Action ボタン
		public class LineButtonAction
		{
			public string type { get;  } = "postback";
			public string label { get; set; } = string.Empty;
			public string data { get; set; } = string.Empty;
			public string text { get; set; } = string.Empty;
		}
		
		//******************************************** 
		// AsyncHttpAPIs用クラス
		//********************************************
		public class DurableAsyncHTTPAPIs
		{
			public string Id { get; set; }
			public string StatusQueryGetUri { get; set; }
			public string SendEventPostUri { get; set; }
			public string TerminatePostUri { get; set; }
		}
		
		//********************************************
		// StatusQueryGetUriレスポンス用クラス
		//********************************************
		public class StatusQueryResponse
		{
			public string runtimeStatus { get; set; }
			public object input { get; set; }
			public List<string> output { get; set; }
			public DateTime createdTime { get; set; }
			public DateTime lastUpdatedTime { get; set; }
		}
	}
}