マウスゼスチャに代表されるポインティングデバイスの軌道でなんらかのアクションをするというのが基本的な使い方になると思いますＺ の軌道を描いたらメニュー起動とか、VRゲームで手をトラッキングして星型を描いていたら魔法が発動するとかでしょうか？部屋にトラッキング装置を設置して部屋の証明や暖房の調整ができてもいいかもしれません

手書き認識ロジックの使い道

処理１．描き始めから描き終わりまでのXY座標（マウスの軌道）を全て記録処理２．三角形判定「処理１」で記録した座標配列を解析し三角形であるかの判定をします条件１．折返し（角）が３つ以上ある（任意に設定した最小角度以上であり、最大角度以下である事）条件２．３つの角全てが同一方向への回転である（全部右回り又は全部左回り）処理３．「処理２」の条件を全て満たしていたら三角形と断定し、３つの折返し部分を頂点とした三角形を描画する おおまかにこのような流れで三角形の判定を行っています

処理の流れ

手書き図形の認識（ゼスチャー認識）

マウスクリックで記録開始（描く間はずっと押しっぱなし）クリック時のX座標、Y座標を保存マウス移動が検出されたらX座標、Y座標を追加で保存していきますマウスボタンが離されたら記録終了とし図形判定処理を行います <pre><code>&nbsp;&nbsp;&nbsp;&nbsp;canvas.addEventListener("mousedown", function(event) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;prt("mousedown");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.operationReset();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.mouseTrackingX.push(event.offsetX);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.mouseTrackingY.push(event.offsetY);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.operationMousePress = true;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.operationMouseRelease = false;
&nbsp;&nbsp;&nbsp;&nbsp;});
&nbsp;&nbsp;&nbsp;&nbsp;canvas.addEventListener("mouseup", function(event) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;prt("mouseup");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.operationMousePress = false;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.operationMouseRelease = true;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.drawEnd();
&nbsp;&nbsp;&nbsp;&nbsp;});
&nbsp;&nbsp;&nbsp;&nbsp;canvas.addEventListener("mousemove", function(event) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if(me.operationMousePress === true) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.mouseTrackingX.push(event.offsetX);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.mouseTrackingY.push(event.offsetY);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var x = me.mouseTrackingX;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var y = me.mouseTrackingY;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var idxA = x.length - 2;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var idxB = x.length - 1;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var canvas = document.getElementById(me.constCanvasId);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var ctx = canvas.getContext('2d');
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ctx.beginPath();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ctx.strokeStyle = "rgb(0, 0, 0)";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ctx.moveTo(x[idxA], y[idxA]);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ctx.lineTo(x[idxB], y[idxB]);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ctx.stroke();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;});</code></pre>

手書き軌道の記録

例えば記録されたXY座標データが１００個だとしてその中から２０フレームだけを処理対象とする方法を取ります手ブレの酷い箇所を雑に取り除くためです、丁寧に手ブレ検出する方法もあるのかもしれませんが良いロジックを思いつかなかったので解析粒度を粗くすることで細かなブレを無視するというロジックにしました４個スキップして５個目だけ採用するという処理で配列を作り直し、中間データのブレ（があると決めつけた区間）を無視します記録したデータをそのまま解析すると瞬間的な手ブレ箇所を三角形だと誤認識してしまいますその際にスキップする個数は動的で、大きな三角形であれば粗く解析する（スキップ数多い）、小さな三角形であれば細かく解析する（スキップ数少ない）、として解析します<pre><code>&nbsp;&nbsp;&nbsp;&nbsp;var skipRate = parseInt(me.mouseTrackingX.length / self.constSensitivity);
&nbsp;&nbsp;&nbsp;&nbsp;var x = n1d.skipSampling(me.mouseTrackingX, skipRate);
&nbsp;&nbsp;&nbsp;&nbsp;var y = n1d.skipSampling(me.mouseTrackingY, skipRate);</code></pre>

解析前処理-スキップサンプリング

閉じない三角形を描かれた場合を考慮しXY座標記録の先頭のいくつかをXY座標の末尾に追加して図形を閉じた状態にします本処理を実施することで３個の角を描かれた場合でも２個の角だけの閉じていない三角形でも３個角を必要とする同じロジックで三角形判定が行なえます<pre><code>&nbsp;&nbsp;&nbsp;&nbsp;x = x.concat(x.slice(0, me.constRingBufferSize));
&nbsp;&nbsp;&nbsp;&nbsp;y = y.concat(y.slice(0, me.constRingBufferSize));</code></pre>

解析前処理-描画軌道を閉じる

前処理でデータを整えたら三角形判定処理を実行しますプログラム中の trackingIsTriangle という関数になりますXY座標配列から３点の座標を取得処理１．「折返し」と認識できる箇所を３箇所以上検出する　　処理１－１．３点の成す角度を取得　　処理１－２．「処理１－１」の角度が任意の角度範囲であれば「折返し」として保存、そうでなければ保存しない　　　　処理１－２－１．回転方向を取得し保存処理２．以下の条件を全て満たしていたら「三角形成立」と、３点座標の構造体を返却、そうでない場合は「三角形不成立」取れただけの「折返し」座標の構造体を返却　　条件１．「処理１」の結果、３箇所以上の「折返し」が発見されている　　条件２．全ての「折返し」で回転方向が同一である <h3 id="hfb4b7ccd8d">角度の算出</h3>以下の資料を参考にした■3点の座標から角度と回転方向を求める方法を解説！プログラムで自動化！<a href="https://youta-blog.com/angle-and-rotation-direction/" target="_blank" rel="noopener noreferrer">https://youta-blog.com/angle-and-rotation-direction/</a> ■３点の座標から簡単に角度と回転方向を求める．<a href="https://www5d.biglobe.ne.jp/~noocyte/Programming/Geometry/RotationDirection.html#GetAngleOnly" target="_blank" rel="noopener noreferrer">https://www5d.biglobe.ne.jp/~noocyte/Programming/Geometry/RotationDirection.html#GetAngleOnly</a> 点A → 点B → 点C の順番で描画された場合に３点の成す角度（Bの角度）を求めます２つのベクトル →BA、→BC とし内積を取り、公式に当てはめて cosθ を求めます求めた cosθ を arccos 関数で ラジアンに変換します詳細は参考資料としたサイトを御覧ください（手抜き） <pre><code>function angleOf3Points(a, b, c) {
&nbsp;&nbsp;var vBA = [a.x - b.x, a.y - b.y];
&nbsp;&nbsp;var vBC = [c.x - b.x, c.y - b.y];
&nbsp;&nbsp;var dot = n2d.dot(vBA, vBC);
&nbsp;&nbsp;var normBA = Math.sqrt(Math.pow(vBA[0], 2) + Math.pow(vBA[1], 2));
&nbsp;&nbsp;var normBC = Math.sqrt(Math.pow(vBC[0], 2) + Math.pow(vBC[1], 2));
&nbsp;&nbsp;var cosTheta = dot / (normBA * normBC);
&nbsp;&nbsp;return Math.acos(cosTheta);
}</code></pre> <h3 id="hbed541ce77">回転方向の算出（描画方向の特定）</h3> 以下の資料を参考にした■3点の回転方向を調べる<a href="https://qiita.com/tydesign/items/d41ac74b5effd87141b8" target="_blank" rel="noopener noreferrer">https://qiita.com/tydesign/items/d41ac74b5effd87141b8</a> 点A → 点B → 点C の順番で描画された場合に描画方向を特定し、その描画順が三角形を右回りで描こうとしているのか、左回りで描こうとしているのかを特定します点A → 点B → 点C の描画を「点A を中心に 点B から 点C へと回転変形した」と考えます→AB と →AC の傾きを比較して →AC のほうが大きく傾いているのであれば左回り、そうでなければ右回りとします詳細は参考資料としたサイトを御覧ください（手抜き） <pre><code>&nbsp;&nbsp;// 折返しと認識する「最小角度」「最大角度」を設定する
&nbsp;&nbsp;// 折返しが３個以上ある場合は検査処理を実行
&nbsp;&nbsp;// 発見した折返しの最初の３個について検査処理を実行
&nbsp;&nbsp;// ３箇所全てが同じ方向への回転だった場合は三角形だとする
&nbsp;&nbsp;var dataRotate = [];
&nbsp;&nbsp;var dataRad = [];
&nbsp;&nbsp;var dataX = []
&nbsp;&nbsp;var dataY = [];
&nbsp;&nbsp;var count = 0;
&nbsp;&nbsp;for(var i = 0; i &lt; size - 2; i += 1) {
&nbsp;&nbsp;&nbsp;&nbsp;var A = {x: x[i + 0], y: y[i + 0]};
&nbsp;&nbsp;&nbsp;&nbsp;var B = {x: x[i + 1], y: y[i + 1]};
&nbsp;&nbsp;&nbsp;&nbsp;var C = {x: x[i + 2], y: y[i + 2]};
&nbsp;&nbsp;&nbsp;&nbsp;var rad = angleOf3Points(A, B, C);
&nbsp;&nbsp;&nbsp;&nbsp;if(rad &gt; minRad &amp;&amp; rad &lt; maxRad) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var rotate = rotateDirectionOf3Points(A, B, C);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;dataRotate.push(rotate);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;dataRad.push(rad);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;dataX.push(B.x);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;dataY.push(B.y);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;count += 1;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if(count &gt;= 3) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;break;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;//prt("dataRotate", dataRotate);
&nbsp;&nbsp;//prt("dataRad", dataRad);
&nbsp;&nbsp;//prt("dataX", dataX);
&nbsp;&nbsp;//prt("dataY", dataY);
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;// 折返しとみなせる物が３箇所あり、３箇所の回転方向が同一であるなら三角形の描画とする
&nbsp;&nbsp;if(count &gt;= 3 &amp;&amp; n1d.allEqual(dataRotate, dataRotate[0])) {
&nbsp;&nbsp;&nbsp;&nbsp;return {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ok: true,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;size: dataX.length,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;x: dataX,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;y: dataY,
&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;} else {
&nbsp;&nbsp;&nbsp;&nbsp;return {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ok: false,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;size: dataX.length,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;x: dataX,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;y: dataY,
&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;}</code></pre>

三角形判定処理

三角形の検出が終わったら特に特殊なロジックはありません返却された三角形のパラメータに従い三角形を描画します 処理解説は以上です

描画処理

詳細な処理の流れ

サンプリングの粒度変更ロジックはまだ改善の余地があります、現状は「描いた長さに比例して粒度調整」ですが点と点の間の距離を見て区間別に粒度調整するのが望ましいと思います、点ABCの→ABは高速に描き、→BCはゆっくり描かれていたとしますその際に→ABは細かい粒度で判定して問題なく、→BCは荒い粒度でブレを軽減させる処置が必要になりますこれは実際にある問題で三角形を描く際にそれぞれの辺を描く時の自分の手の動きを注意して観察すると分かります、素早くなめらかに描ける辺とブレやすく描くのが遅い辺があるはずです、人間の手の動きではXY軸全てに精密動作はできないはずです、人それぞれ癖があります

改善点１－サンプリングの改善

今回のロジックは書き順に完全に依存しています、そもそもがゼスチャーの延長なので大きな問題ではないのですが。ただし図形を認識させるという点で考えた場合に書き順を無視して輪郭や線の検出に特化したほうが効率が良い、精度が高い場合も考えられます目的によっては根本的なロジック変更を考えたほうが良さそうです

改善点２－書き順に依存しない図形認識の採用

三角形は１つの角度と２辺が決まれば三角形を決定することが可能です、長方形は直角部分と２辺が決まれば四角形全体を決定可能です、このように理論的に可能な条件と人間に「三角形を描いてください」と指示した場合には大きな差があります、エンジニア寄りの人間は「１つの角度と２辺が決まれば三角形を決定できるのだからそれだけ描けば認識するんでしょ？」と思う可能性が高いです人種や用途によって個人の認識差がありロジックが大幅に異なる事もありますので、自動認識ソフトを作成する時は誰向けになにを目的とした物を作るのかを考える必要があります、具体的には試験する際にエンジニアだけで終わらせずに非エンジニアにも触らせたりすればそれで良い話だとは思います

図形認識の考え方

改善点など

<pre><code>&lt;html lang="ja"&gt;
&lt;head&gt;
&nbsp;&nbsp;&lt;meta charset="utf-8"&gt;
&lt;/head&gt;
&lt;body&gt;
&nbsp;&nbsp;&lt;div id="draw_area"&gt;
&nbsp;&nbsp;&nbsp;&nbsp;&lt;canvas id="draw_area_canvas" width="800" height="600" style="background-color: #bbbbbb;"&gt;&lt;/canvas&gt;
&nbsp;&nbsp;&lt;/div&gt;
&nbsp;&nbsp;&lt;div id="config_area"&gt;
&nbsp;&nbsp;&nbsp;&nbsp;&lt;input type="text" id="config_area_ring_buffer_size"&gt; データの最初と最後を繋げる配列の数&lt;br&gt;
&nbsp;&nbsp;&nbsp;&nbsp;&lt;input type="text" id="config_area_minimum_radian"&gt; 最小角度係数（π／n） の n に使用されます&lt;br&gt;
&nbsp;&nbsp;&nbsp;&nbsp;&lt;input type="text" id="config_area_maximum_radian"&gt; 最大角度係数（π／n） の n に使用されます&lt;br&gt;
&nbsp;&nbsp;&nbsp;&nbsp;&lt;input type="text" id="config_area_sensitivity"&gt; 座標サンプリング係数、大きいと荒く、小さいと細かく座標を検査するようになります&lt;br&gt;
&nbsp;&nbsp;&nbsp;&nbsp;&lt;button type="button" id="config_area_reset_button"&gt;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Reset
&nbsp;&nbsp;&nbsp;&nbsp;&lt;/button&gt;
&nbsp;&nbsp;&nbsp;&nbsp;&lt;br&gt;
&nbsp;&nbsp;&lt;/div&gt;
&nbsp;&nbsp;&lt;div id="log_area"&gt;
&nbsp;&nbsp;&nbsp;&nbsp;&lt;textarea id="log_arrea_view" style="width: 200px; height: 600px; background-color: #DDDDDD;"&gt;
&nbsp;&nbsp;&nbsp;&nbsp;&lt;/textarea&gt;
&nbsp;&nbsp;&lt;/div&gt;

&nbsp;&nbsp;&lt;script type="text/javascript"&gt;

function prt() {
&nbsp;&nbsp;console.log.apply(null, arguments);
}

function Number1D() {
&nbsp;&nbsp;var self = this;
&nbsp;&nbsp;self.allEqual = function(x, n) {
&nbsp;&nbsp;&nbsp;&nbsp;for(var i = 0; i &lt; x.length; i += 1) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if(x[i] != n) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return false;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;return true;
&nbsp;&nbsp;}
&nbsp;&nbsp;self.skipSampling = function(x, n) {
&nbsp;&nbsp;&nbsp;&nbsp;var y = [];
&nbsp;&nbsp;&nbsp;&nbsp;for(var i = 0; i &lt; x.length; i += 1) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if(i % n == 0) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;y.push(x[i]);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;return y;
&nbsp;&nbsp;}
}
var n1d = new Number1D();

function Number2D() {
&nbsp;&nbsp;var self = this;
&nbsp;&nbsp;self.dot = function(a, b) {
&nbsp;&nbsp;&nbsp;&nbsp;var dot = 0;
&nbsp;&nbsp;&nbsp;&nbsp;for(var i = 0; i &lt; 2; i += 1) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;dot += a[i] * b[i];
&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;return dot;
&nbsp;&nbsp;}
}
var n2d = new Number2D();

////////////////////////////////////////
// 点A→B→Cの順番に描画した場合にその描画が右回りか左回りかの判定
// 右回り = 0
// 左回り = 1
////////////////////////////////////////
function rotateDirectionOf3Points(a, b, c) {
&nbsp;&nbsp;var dy1 = b.y - a.y;
&nbsp;&nbsp;var dx1 = b.x - a.x;
&nbsp;&nbsp;var dy2 = c.y - a.y;
&nbsp;&nbsp;var dx2 = c.x - a.x;
&nbsp;&nbsp;//var leftN = dy1 / dx1;
&nbsp;&nbsp;//var rightN = dy2 / dx2;
&nbsp;&nbsp;var leftN = dx2 * dy1;
&nbsp;&nbsp;var rightN = dx1 * dy2;
&nbsp;&nbsp;if(leftN &lt; rightN) {
&nbsp;&nbsp;&nbsp;&nbsp;return 0;
&nbsp;&nbsp;} else {
&nbsp;&nbsp;&nbsp;&nbsp;return 1;
&nbsp;&nbsp;}
}

function angleOf3Points(a, b, c) {
&nbsp;&nbsp;var vBA = [a.x - b.x, a.y - b.y];
&nbsp;&nbsp;var vBC = [c.x - b.x, c.y - b.y];
&nbsp;&nbsp;var dot = n2d.dot(vBA, vBC);
&nbsp;&nbsp;var normBA = Math.sqrt(Math.pow(vBA[0], 2) + Math.pow(vBA[1], 2));
&nbsp;&nbsp;var normBC = Math.sqrt(Math.pow(vBC[0], 2) + Math.pow(vBC[1], 2));
&nbsp;&nbsp;var cosTheta = dot / (normBA * normBC);
&nbsp;&nbsp;return Math.acos(cosTheta);
}

function trackingIsTriangle(size, minRad, maxRad, x, y) {
&nbsp;&nbsp;// 折返しと認識する「最小角度」「最大角度」を設定する
&nbsp;&nbsp;// 折返しが３個以上ある場合は検査処理を実行
&nbsp;&nbsp;// 発見した折返しの最初の３個について検査処理を実行
&nbsp;&nbsp;// ３箇所全てが同じ方向への回転だった場合は三角形だとする
&nbsp;&nbsp;var dataRotate = [];
&nbsp;&nbsp;var dataRad = [];
&nbsp;&nbsp;var dataX = []
&nbsp;&nbsp;var dataY = [];
&nbsp;&nbsp;var count = 0;
&nbsp;&nbsp;for(var i = 0; i &lt; size - 2; i += 1) {
&nbsp;&nbsp;&nbsp;&nbsp;var A = {x: x[i + 0], y: y[i + 0]};
&nbsp;&nbsp;&nbsp;&nbsp;var B = {x: x[i + 1], y: y[i + 1]};
&nbsp;&nbsp;&nbsp;&nbsp;var C = {x: x[i + 2], y: y[i + 2]};
&nbsp;&nbsp;&nbsp;&nbsp;var rad = angleOf3Points(A, B, C);
&nbsp;&nbsp;&nbsp;&nbsp;if(rad &gt; minRad &amp;&amp; rad &lt; maxRad) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var rotate = rotateDirectionOf3Points(A, B, C);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;dataRotate.push(rotate);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;dataRad.push(rad);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;dataX.push(B.x);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;dataY.push(B.y);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;count += 1;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if(count &gt;= 3) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;break;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;//prt("dataRotate", dataRotate);
&nbsp;&nbsp;//prt("dataRad", dataRad);
&nbsp;&nbsp;//prt("dataX", dataX);
&nbsp;&nbsp;//prt("dataY", dataY);
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;// 折返しとみなせる物が３箇所あり、３箇所の回転方向が同一であるなら三角形の描画とする
&nbsp;&nbsp;if(count &gt;= 3 &amp;&amp; n1d.allEqual(dataRotate, dataRotate[0])) {
&nbsp;&nbsp;&nbsp;&nbsp;return {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ok: true,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;size: dataX.length,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;x: dataX,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;y: dataY,
&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;} else {
&nbsp;&nbsp;&nbsp;&nbsp;return {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ok: false,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;size: dataX.length,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;x: dataX,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;y: dataY,
&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;}
}

////////////////////////////////////////
// 手書き図形補正機能クラス
////////////////////////////////////////
function HandWriteFigureCorrection() {
&nbsp;&nbsp;var self = this;
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;////////////////////////////////////////
&nbsp;&nbsp;// 定数
&nbsp;&nbsp;////////////////////////////////////////
&nbsp;&nbsp;self.constCanvasId = "draw_area_canvas";
&nbsp;&nbsp;self.constViewLogId = "log_arrea_view";
&nbsp;&nbsp;self.constConfigRingBufferSizeId = "config_area_ring_buffer_size";
&nbsp;&nbsp;self.constConfigMinimumRadianCoeffId = "config_area_minimum_radian";
&nbsp;&nbsp;self.constConfigMaximumRadianCoeffId = "config_area_maximum_radian";
&nbsp;&nbsp;self.constConfigSensitivityId = "config_area_sensitivity";
&nbsp;&nbsp;self.constConfigResetButtonId = "config_area_reset_button";
&nbsp;&nbsp;self.constRingBufferSize = 5;
&nbsp;&nbsp;self.constMinimumRadianCoeff = 9.0;
&nbsp;&nbsp;self.constMaximumRadianCoeff = 1.5;
&nbsp;&nbsp;self.constSensitivity = 22;
&nbsp;&nbsp;self.configRingBufferSize = self.constRingBufferSize;
&nbsp;&nbsp;self.configMinimumRadianCoeff = self.constMinimumRadianCoeff;
&nbsp;&nbsp;self.configMaximumRadianCoeff = self.constMaximumRadianCoeff;
&nbsp;&nbsp;self.configSensitivity = self.constSensitivity;
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;////////////////////////////////////////
&nbsp;&nbsp;// フラグ
&nbsp;&nbsp;////////////////////////////////////////
&nbsp;&nbsp;self.operationMousePress = false;
&nbsp;&nbsp;self.operationMouseRelease = false;
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;////////////////////////////////////////
&nbsp;&nbsp;// その他変数
&nbsp;&nbsp;////////////////////////////////////////
&nbsp;&nbsp;self.mouseTrackingX = [];
&nbsp;&nbsp;self.mouseTrackingY = [];
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;////////////////////////////////////////
&nbsp;&nbsp;// イベント設定
&nbsp;&nbsp;////////////////////////////////////////
&nbsp;&nbsp;self.setupEvents = function() {
&nbsp;&nbsp;&nbsp;&nbsp;var me = this;
&nbsp;&nbsp;&nbsp;&nbsp;var canvas = document.getElementById(me.constCanvasId);
&nbsp;&nbsp;&nbsp;&nbsp;canvas.addEventListener("mousedown", function(event) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;prt("mousedown");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.operationReset();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.mouseTrackingX.push(event.offsetX);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.mouseTrackingY.push(event.offsetY);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.operationMousePress = true;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.operationMouseRelease = false;
&nbsp;&nbsp;&nbsp;&nbsp;});
&nbsp;&nbsp;&nbsp;&nbsp;canvas.addEventListener("mouseup", function(event) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;prt("mouseup");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.operationMousePress = false;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.operationMouseRelease = true;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.drawEnd();
&nbsp;&nbsp;&nbsp;&nbsp;});
&nbsp;&nbsp;&nbsp;&nbsp;canvas.addEventListener("mousemove", function(event) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if(me.operationMousePress === true) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.mouseTrackingX.push(event.offsetX);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.mouseTrackingY.push(event.offsetY);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var x = me.mouseTrackingX;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var y = me.mouseTrackingY;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var idxA = x.length - 2;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var idxB = x.length - 1;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var canvas = document.getElementById(me.constCanvasId);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var ctx = canvas.getContext('2d');
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ctx.beginPath();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ctx.strokeStyle = "rgb(0, 0, 0)";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ctx.moveTo(x[idxA], y[idxA]);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ctx.lineTo(x[idxB], y[idxB]);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ctx.stroke();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;});
&nbsp;&nbsp;&nbsp;&nbsp;document.getElementById(me.constConfigResetButtonId).addEventListener("click", function(event) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.initConfigInputs();
&nbsp;&nbsp;&nbsp;&nbsp;});
&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;self.operationReset = function() {
&nbsp;&nbsp;&nbsp;&nbsp;var me = this;
&nbsp;&nbsp;&nbsp;&nbsp;var canvas = document.getElementById(me.constCanvasId);
&nbsp;&nbsp;&nbsp;&nbsp;var ctx = canvas.getContext('2d');
&nbsp;&nbsp;&nbsp;&nbsp;ctx.fillStyle = "rgb(187, 187, 187)";
&nbsp;&nbsp;&nbsp;&nbsp;ctx.fillRect(0, 0, canvas.width, canvas.height);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;me.operationMousePress = false;
&nbsp;&nbsp;&nbsp;&nbsp;me.operationMouseRelease = false;
&nbsp;&nbsp;&nbsp;&nbsp;me.mouseTrackingX = [];
&nbsp;&nbsp;&nbsp;&nbsp;me.mouseTrackingY = [];
&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;self.updateConfigItem = function(id, configName, configType) {
&nbsp;&nbsp;&nbsp;&nbsp;var me = this;
&nbsp;&nbsp;&nbsp;&nbsp;var elm = document.getElementById(id);
&nbsp;&nbsp;&nbsp;&nbsp;if(configType == "int") {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me[configName] = parseInt(elm.value);
&nbsp;&nbsp;&nbsp;&nbsp;} else if(configType == "float") {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me[configName] = parseFloat(elm.value);
&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;}
&nbsp;&nbsp;self.updateConfig = function() {
&nbsp;&nbsp;&nbsp;&nbsp;var me = this;
&nbsp;&nbsp;&nbsp;&nbsp;var canvas = document.getElementById(me.constConfigRingBufferSizeId);
&nbsp;&nbsp;&nbsp;&nbsp;me.updateConfigItem(me.constConfigRingBufferSizeId, "configRingBufferSize", "int");
&nbsp;&nbsp;&nbsp;&nbsp;me.updateConfigItem(me.constConfigMinimumRadianCoeffId, "configMinimumRadianCoeff", "float");
&nbsp;&nbsp;&nbsp;&nbsp;me.updateConfigItem(me.constConfigMaximumRadianCoeffId, "configMaximumRadianCoeff", "float");
&nbsp;&nbsp;&nbsp;&nbsp;me.updateConfigItem(me.constConfigSensitivityId, "configSensitivity", "int");
&nbsp;&nbsp;}
&nbsp;&nbsp;self.initConfigInputs = function() {
&nbsp;&nbsp;&nbsp;&nbsp;var me = this;
&nbsp;&nbsp;&nbsp;&nbsp;document.getElementById(me.constConfigRingBufferSizeId).value = String(me.constRingBufferSize);
&nbsp;&nbsp;&nbsp;&nbsp;document.getElementById(me.constConfigMinimumRadianCoeffId).value = String(me.constMinimumRadianCoeff);
&nbsp;&nbsp;&nbsp;&nbsp;document.getElementById(me.constConfigMaximumRadianCoeffId).value = String(me.constMaximumRadianCoeff);
&nbsp;&nbsp;&nbsp;&nbsp;document.getElementById(me.constConfigSensitivityId).value = String(me.constSensitivity);
&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;self.test1 = function() {
&nbsp;&nbsp;&nbsp;&nbsp;var me = this;
&nbsp;&nbsp;&nbsp;&nbsp;var x = me.mouseTrackingX;
&nbsp;&nbsp;&nbsp;&nbsp;var y = me.mouseTrackingY;
&nbsp;&nbsp;&nbsp;&nbsp;var size = x.length;
&nbsp;&nbsp;&nbsp;&nbsp;var idxA = 0;
&nbsp;&nbsp;&nbsp;&nbsp;var idxB = parseInt(size / 2);
&nbsp;&nbsp;&nbsp;&nbsp;var idxC = size - 1;
&nbsp;&nbsp;&nbsp;&nbsp;var canvas = document.getElementById(me.constCanvasId);
&nbsp;&nbsp;&nbsp;&nbsp;var ctx = canvas.getContext('2d');
&nbsp;&nbsp;&nbsp;&nbsp;ctx.beginPath();
&nbsp;&nbsp;&nbsp;&nbsp;ctx.strokeStyle = "rgb(255, 0, 0)";
&nbsp;&nbsp;&nbsp;&nbsp;ctx.moveTo(x[idxA], y[idxA]);
&nbsp;&nbsp;&nbsp;&nbsp;ctx.lineTo(x[idxB], y[idxB]);
&nbsp;&nbsp;&nbsp;&nbsp;ctx.lineTo(x[idxC], y[idxC]);
&nbsp;&nbsp;&nbsp;&nbsp;ctx.stroke();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;var plotX = [x[idxA], x[idxB], x[idxC]];
&nbsp;&nbsp;&nbsp;&nbsp;var plotY = [y[idxA], y[idxB], y[idxC]];
&nbsp;&nbsp;&nbsp;&nbsp;ctx.font = "16px serif";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;ctx.fillStyle = "rgb(0, 0, 0)";
&nbsp;&nbsp;&nbsp;&nbsp;ctx.fillText("A(" + String(plotX[0]) + ", " + String(plotY[0]) + ")", plotX[0], plotY[0]);
&nbsp;&nbsp;&nbsp;&nbsp;ctx.fillText("B(" + String(plotX[1]) + ", " + String(plotY[1]) + ")", plotX[1], plotY[1]);
&nbsp;&nbsp;&nbsp;&nbsp;ctx.fillText("C(" + String(plotX[2]) + ", " + String(plotY[2]) + ")", plotX[2], plotY[2]);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;var rotate = rotateDirectionOf3Points({x: plotX[0], y: plotY[0]}, {x: plotX[1], y: plotY[1]}, {x: plotX[2], y: plotY[2]});
&nbsp;&nbsp;&nbsp;&nbsp;var rad = angleOf3Points({x: plotX[0], y: plotY[0]}, {x: plotX[1], y: plotY[1]}, {x: plotX[2], y: plotY[2]});
&nbsp;&nbsp;&nbsp;&nbsp;var degree = rad * (180 / Math.PI);
&nbsp;&nbsp;&nbsp;&nbsp;var lines = ["rad: " + String(rad), "degree: " + String(degree), "rotate: " + String(rotate)];
&nbsp;&nbsp;&nbsp;&nbsp;for(var i = 0; i &lt; plotX.length; i += 1) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var txt = "X=" + String(plotX[i]) + ", Y=" + String(plotY[i]);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;lines.push(txt);
&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;var logView = document.getElementById(me.constViewLogId);
&nbsp;&nbsp;&nbsp;&nbsp;var logText = lines.join("\n");
&nbsp;&nbsp;&nbsp;&nbsp;logView.value = lines.join("\n");
&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;////////////////////////////////////////
&nbsp;&nbsp;// 描画終了処理
&nbsp;&nbsp;////////////////////////////////////////
&nbsp;&nbsp;self.drawEnd = function() {
&nbsp;&nbsp;&nbsp;&nbsp;var me = this;
&nbsp;&nbsp;&nbsp;&nbsp;me.updateConfig();
&nbsp;&nbsp;&nbsp;&nbsp;prt("configRingBufferSize", me.configRingBufferSize);
&nbsp;&nbsp;&nbsp;&nbsp;prt("configMinimumRadianCoeff", me.configMinimumRadianCoeff);
&nbsp;&nbsp;&nbsp;&nbsp;prt("configMaximumRadianCoeff", me.configMaximumRadianCoeff);
&nbsp;&nbsp;&nbsp;&nbsp;prt("configSensitivity", me.configSensitivity);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;prt(me.mouseTrackingX);
&nbsp;&nbsp;&nbsp;&nbsp;prt(me.mouseTrackingY);
&nbsp;&nbsp;&nbsp;&nbsp;var skipRate = parseInt(me.mouseTrackingX.length / self.constSensitivity);
&nbsp;&nbsp;&nbsp;&nbsp;prt("skipRate", skipRate);
&nbsp;&nbsp;&nbsp;&nbsp;var x = n1d.skipSampling(me.mouseTrackingX, skipRate);
&nbsp;&nbsp;&nbsp;&nbsp;var y = n1d.skipSampling(me.mouseTrackingY, skipRate);
&nbsp;&nbsp;&nbsp;&nbsp;x = x.concat(x.slice(0, me.constRingBufferSize));
&nbsp;&nbsp;&nbsp;&nbsp;y = y.concat(y.slice(0, me.constRingBufferSize));
&nbsp;&nbsp;&nbsp;&nbsp;var res = trackingIsTriangle(
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;x.length,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Math.PI / me.constMinimumRadianCoeff,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Math.PI / me.constMaximumRadianCoeff,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;x,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;y);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;if(0) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;me.test1();
&nbsp;&nbsp;&nbsp;&nbsp;} else {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var logView = document.getElementById(me.constViewLogId);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var lines = ["三角形: " + String(res.ok ? "true": "false")];
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;for(var i = 0; i &lt; res.size; i += 1) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;lines.push("座標 " + String(i + 1) + ": " + String(res.x[i]) + ", " + String(res.y[i]));
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var logText = lines.join("\n");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logView.value = lines.join("\n");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if(res.ok === true) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var canvas = document.getElementById(me.constCanvasId);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;var ctx = canvas.getContext('2d');
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ctx.beginPath();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ctx.strokeStyle = "rgb(255, 0, 255)";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ctx.moveTo(res.x[0], res.y[0]);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ctx.lineTo(res.x[1], res.y[1]);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ctx.lineTo(res.x[2], res.y[2]);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ctx.lineTo(res.x[0], res.y[0]);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ctx.stroke();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;self.start = function() {
&nbsp;&nbsp;&nbsp;&nbsp;var me = this;
&nbsp;&nbsp;&nbsp;&nbsp;me.initConfigInputs();
&nbsp;&nbsp;&nbsp;&nbsp;me.setupEvents();
&nbsp;&nbsp;}
}

window.addEventListener('load', function(){
&nbsp;&nbsp;var x = new HandWriteFigureCorrection();
&nbsp;&nbsp;x.start();
});
&nbsp;&nbsp;&lt;/script&gt;

&lt;/body&gt;
&lt;/html&gt;</code></pre>

HTML+JavaScript（適当なWEBサーバに設置して試験してください）

ソースコード

アプリケーションの中で発生するイベントは、ドメインオブジェクトに対する何らかのアクションに起因すると考えられるため、イベント自体はアクションに紐付けたいです。現状はというと、アプリケーションサービス内でアクションの「直後に」発生する形になっています。<pre><code> val meeting = // アクション(ミーティングを作成する)
 Meeting(
 organizerId,
 participantIds,
 startAt,
 endAt,
 title,
 detail
 )
 meetingRepository.save(meeting)
 val users = userRepsitory.getByIds(organizerId :: participantIds)
 publisher.publish(
 MeetingCreated(meeting.id, users, title, detail, startAt, endAt) // イベント発生(ミーティングが作成された)
 )</code></pre> 上記の場合、<code>Meeting</code>のインスタンス生成時にイベントが生成されるようにしたいです。しかし、ここで鬼門なのは、<code>MeetingCreated</code>は<code>users</code>を受け取る必要があるということです。逆にそれ以外のパラメータに関しては、<code>Meeting</code>インスタンス化の引数で受け取るため問題ないです。どうしたらいいでしょうか？ 以下に思いつく限り対応案を書き出してみます。<ol><li><code>userRepository.getByIds</code>を先に実行してからインスタンス化の引数として渡す</li><li>インスタンス化処理の中で<code>userRepository.getByIds</code>を実行する</li><li>そもそも<code>MeetingCreated</code>が<code>users</code>を受け取るのをやめる。その代わり通知処理で必要になるため各<code>Observer</code>内で<code>userRepository.getByIds</code>を実行する</li><li>そもそも<code>Observer</code>がメールアドレスを必要としない形にする</li></ol>1は手頃ですが、インスタンス化に関係のないものをパラメータに追加したくないです。2はドメイン層をクリーンな状態にしておきたいので却下です。インスタンス化の引数にrepositoryを渡さないのであればテストが極端に難しくなります。3はうまくやればいい感じの実装になりそうな気がします。4については考えがあるので後で説明することになると思います。というわけで一旦3の方針で実装してみます。

方針検討

<pre><code>@@ -58,6 +58,7 @@ trait UserRepository:
&nbsp;class MeetingId(val value: Int) extends AnyVal
&nbsp;
&nbsp;class Meeting(
+&nbsp; &nbsp; val id: MeetingId,
&nbsp; &nbsp; &nbsp;val organizerId: UserId,
&nbsp; &nbsp; &nbsp;val participantIds: List[UserId],
&nbsp; &nbsp; &nbsp;val startAt: LocalDateTime,
@@ -65,19 +66,44 @@ class Meeting(
&nbsp; &nbsp; &nbsp;val title: String,
&nbsp; &nbsp; &nbsp;val detail: String
&nbsp;):
-&nbsp; val id = MeetingId(1)
+&nbsp; def delete: MeetingDeleted =
+&nbsp; &nbsp; MeetingDeleted(id, organizerId, participantIds)
+
+object Meeting:
+&nbsp; def create(
+&nbsp; &nbsp; &nbsp; organizerId: UserId,
+&nbsp; &nbsp; &nbsp; participantIds: List[UserId],
+&nbsp; &nbsp; &nbsp; startAt: LocalDateTime,
+&nbsp; &nbsp; &nbsp; endAt: LocalDateTime,
+&nbsp; &nbsp; &nbsp; title: String,
+&nbsp; &nbsp; &nbsp; detail: String
+&nbsp; ): (Meeting, MeetingCreated) =
+&nbsp; &nbsp; val id = MeetingId(1)
+&nbsp; &nbsp; val meeting =
+&nbsp; &nbsp; &nbsp; Meeting(id, organizerId, participantIds, startAt, endAt, title, detail)
+&nbsp; &nbsp; val event = MeetingCreated(
+&nbsp; &nbsp; &nbsp; id,
+&nbsp; &nbsp; &nbsp; organizerId,
+&nbsp; &nbsp; &nbsp; participantIds,
+&nbsp; &nbsp; &nbsp; title,
+&nbsp; &nbsp; &nbsp; detail,
+&nbsp; &nbsp; &nbsp; startAt,
+&nbsp; &nbsp; &nbsp; endAt
+&nbsp; &nbsp; )
+&nbsp; &nbsp; (meeting, event)
&nbsp;
&nbsp;trait MeetingRepository:
&nbsp; &nbsp;def save(meeting: Meeting): Unit
&nbsp; &nbsp;def get(meetingId: MeetingId): Meeting
-&nbsp; def delete(meetingId: MeetingId): Unit
+&nbsp; def delete(meetingId: MeetingId, event: MeetingDeleted): Unit
&nbsp;
&nbsp;trait DomainEvent:
&nbsp; &nbsp;val occuredOn = LocalDateTime.now()
&nbsp;
&nbsp;class MeetingCreated(
&nbsp; &nbsp; &nbsp;val meetingId: MeetingId,
-&nbsp; &nbsp; val users: List[User],
+&nbsp; &nbsp; val organizerId: UserId,
+&nbsp; &nbsp; val participantIds: List[UserId],
&nbsp; &nbsp; &nbsp;val title: String,
&nbsp; &nbsp; &nbsp;val detail: String,
&nbsp; &nbsp; &nbsp;val startAt: LocalDateTime,
@@ -86,7 +112,8 @@ class MeetingCreated(
&nbsp;
&nbsp;class MeetingDeleted(
&nbsp; &nbsp; &nbsp;val meetingId: MeetingId,
-&nbsp; &nbsp; val users: List[User]
+&nbsp; &nbsp; val organizerId: UserId,
+&nbsp; &nbsp; val participantIds: List[UserId]
&nbsp;) extends DomainEvent
&nbsp;
&nbsp;trait DomainEventObserver:
@@ -97,22 +124,32 @@ class DomainEventPublisher(obs: DomainEventObserver*):
&nbsp; &nbsp; &nbsp;obs.foreach(_.respondTo(event))
&nbsp;
&nbsp;// インフラストラクチャ層
-class EmailSender extends DomainEventObserver:
+class EmailSender(
+&nbsp; &nbsp; userRepsitory: UserRepository
+) extends DomainEventObserver:
&nbsp; &nbsp;override def respondTo[T &lt;: DomainEvent](event: T): Unit =
&nbsp; &nbsp; &nbsp;event match
&nbsp; &nbsp; &nbsp; &nbsp;case e: MeetingCreated =&gt;
-&nbsp; &nbsp; &nbsp; &nbsp; e.users.foreach(u =&gt; send(u.email, e.title, e.detail))
+&nbsp; &nbsp; &nbsp; &nbsp; val users =
+&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; userRepsitory.getByIds(e.organizerId :: e.participantIds)
+&nbsp; &nbsp; &nbsp; &nbsp; users.foreach(u =&gt; send(u.email, e.title, e.detail))
&nbsp; &nbsp; &nbsp; &nbsp;case e: MeetingDeleted =&gt;
-&nbsp; &nbsp; &nbsp; &nbsp; e.users.foreach(u =&gt; send(u.email, "ミーティング削除のお知らせ", "ミーティングが削除されました"))
+&nbsp; &nbsp; &nbsp; &nbsp; val users =
+&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; userRepsitory.getByIds(e.organizerId :: e.participantIds)
+&nbsp; &nbsp; &nbsp; &nbsp; users.foreach(u =&gt; send(u.email, "ミーティング削除のお知らせ", "ミーティングが削除されました"))
&nbsp;
&nbsp; &nbsp;def send(to: Email, subject: String, body: String): Unit =
&nbsp; &nbsp; &nbsp;println(s"email send to $to")
&nbsp;
-class EmailReserver extends DomainEventObserver:
+class EmailReserver(
+&nbsp; &nbsp; userRepsitory: UserRepository
+) extends DomainEventObserver:
&nbsp; &nbsp;override def respondTo[T &lt;: DomainEvent](event: T): Unit =
&nbsp; &nbsp; &nbsp;event match
&nbsp; &nbsp; &nbsp; &nbsp;case e: MeetingCreated =&gt;
-&nbsp; &nbsp; &nbsp; &nbsp; e.users.foreach(u =&gt; {
+&nbsp; &nbsp; &nbsp; &nbsp; val users =
+&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; userRepsitory.getByIds(e.organizerId :: e.participantIds)
+&nbsp; &nbsp; &nbsp; &nbsp; users.foreach(u =&gt; {
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;reserve(u.email, e.title, e.detail, e.startAt)
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;reserve(u.email, e.title, e.detail, e.endAt)
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;})
@@ -130,7 +167,10 @@ class MeetingService(
&nbsp; &nbsp; &nbsp;meetingRepository: MeetingRepository,
&nbsp; &nbsp; &nbsp;userRepsitory: UserRepository
&nbsp;):
-&nbsp; private val publisher = DomainEventPublisher(EmailSender(), EmailReserver())
+&nbsp; private val publisher = DomainEventPublisher(
+&nbsp; &nbsp; EmailSender(userRepsitory),
+&nbsp; &nbsp; EmailReserver(userRepsitory)
+&nbsp; )
&nbsp;
&nbsp; &nbsp;def reserve(
&nbsp; &nbsp; &nbsp; &nbsp;organizerId: UserId,
@@ -140,8 +180,8 @@ class MeetingService(
&nbsp; &nbsp; &nbsp; &nbsp;title: String,
&nbsp; &nbsp; &nbsp; &nbsp;detail: String
&nbsp; &nbsp;): Unit =
-&nbsp; &nbsp; val meeting =
-&nbsp; &nbsp; &nbsp; Meeting(
+&nbsp; &nbsp; val (meeting, event) =
+&nbsp; &nbsp; &nbsp; Meeting.create(
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;organizerId,
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;participantIds,
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;startAt,
@@ -151,9 +191,7 @@ class MeetingService(
&nbsp; &nbsp; &nbsp; &nbsp;)
&nbsp; &nbsp; &nbsp;meetingRepository.save(meeting)
&nbsp; &nbsp; &nbsp;val users = userRepsitory.getByIds(organizerId :: participantIds)
-&nbsp; &nbsp; publisher.publish(
-&nbsp; &nbsp; &nbsp; MeetingCreated(meeting.id, users, title, detail, startAt, endAt)
-&nbsp; &nbsp; )
+&nbsp; &nbsp; publisher.publish(event)
&nbsp;
&nbsp; &nbsp;def reserveWithFollowed(
&nbsp; &nbsp; &nbsp; &nbsp;organizerId: UserId,
@@ -164,8 +202,8 @@ class MeetingService(
&nbsp; &nbsp;): Unit =
&nbsp; &nbsp; &nbsp;val organizer = userRepsitory.get(organizerId)
&nbsp; &nbsp; &nbsp;val followers = organizer.followed
-&nbsp; &nbsp; val meeting =
-&nbsp; &nbsp; &nbsp; Meeting(
+&nbsp; &nbsp; val (meeting, event) =
+&nbsp; &nbsp; &nbsp; Meeting.create(
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;organizerId,
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;followers.map(_.id),
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;startAt,
@@ -175,13 +213,12 @@ class MeetingService(
&nbsp; &nbsp; &nbsp; &nbsp;)
&nbsp; &nbsp; &nbsp;meetingRepository.save(meeting)
- &nbsp; &nbsp;val users = userRepsitory.getByIds(organizerId :: followers.map(_.id))
-&nbsp; &nbsp; publisher.publish(
-&nbsp; &nbsp; &nbsp; MeetingCreated(meeting.id, users, title, detail, startAt, endAt)
-&nbsp; &nbsp; )
+&nbsp; &nbsp; publisher.publish(event)
&nbsp;
&nbsp; &nbsp;def remove(meetingId: MeetingId): Unit =
&nbsp; &nbsp; &nbsp;val meeting = meetingRepository.get(meetingId)
-&nbsp; &nbsp; meetingRepository.delete(meetingId)
+&nbsp; &nbsp; val event = meeting.delete
+&nbsp; &nbsp; meetingRepository.delete(meetingId, event)
- &nbsp; &nbsp;val users =
- &nbsp; &nbsp; &nbsp;userRepsitory.getByIds(meeting.organizerId :: meeting.participantIds)
-&nbsp; &nbsp; publisher.publish(MeetingDeleted(meeting.id, users))
+&nbsp; &nbsp; publisher.publish(event)</code></pre> <code>Meeting</code>のコンストラクタの中でイベントも生成するのは違和感があったため、コンパニオンオブジェクトのメソッド呼び出しにしました。ドメインオブジェクト潔癖症なので副作用を持ち込まないようタプルでイベントも返すようにしています。<code>users</code>の代わりに<code>Meeting</code>オブジェクト自体が持っている<code>organizerId</code>と<code>participantIds</code>をイベントの属性に含めるようにしました。後は<code>Observer</code>が<code>UserRepository</code>を持って<code>users</code>にマッピングするようにしています。 この実装には少々問題点がありまして、それは、イベントの生成自体は約束されるのですが、イベントを発行するのを忘れていたとしてもエラーにならないということです。Golangであれば未使用変数があればエラーになるのですが、Scalaも取り入れてくれませんかね。とはいえ普通の人であればまあ気づくと思うので、これはこれで良しとしましょう。あともう一つ、ミーティングの削除に関してはドメイン側に削除イベント生成メソッドを実装してもそもそも呼び出す必然性がなかったため、<code>meetingRepository.delete()</code>の引数にイベントを追加しました。（本来全く必要ないのですが・・・。この辺もっといい実装があれば教えてほしいです。）

Observer内でRepositoryにアクセスする実装

さて、一応ドメインイベントをドメインオブジェクトが生成するようにする実装は一通り完了したのですが、個人的に気に食わないポイントが一つあります。<pre><code> override def respondTo[T &lt;: DomainEvent](event: T): Unit =
 event match
 case e: MeetingCreated =&gt;
 val users =
 userRepsitory.getByIds(e.organizerId :: e.participantIds)
 users.foreach(u =&gt; send(u.email, e.title, e.detail))
 case e: MeetingDeleted =&gt;
 val users =
 userRepsitory.getByIds(e.organizerId :: e.participantIds)
 users.foreach(u =&gt; send(u.email, "ミーティング削除のお知らせ", "ミーティングが削除されました"))</code></pre> このあたりです。なんというか全然インフラ層っぽくないです。もともとインフラ層とは技術的な込み入ったコードを書く場所だったはずです。なのにこれは、「ミーティングが作成されたら、主催者と参加者全員に対してメールを送信する(etc)」と読めて、ゴリゴリに業務ロジックっぽい感じがします。では、これはどこに実装すればいいでしょうか、ドメイン知識というよりアプリケーションに対する要求って感じな気がするので、一旦アプリケーションサービスに実装します。<pre><code>@@ -124,25 +124,40 @@ class DomainEventPublisher(obs: DomainEventObserver*):
&nbsp; &nbsp; &nbsp;obs.foreach(_.respondTo(event))
&nbsp;
&nbsp;// インフラストラクチャ層
-class EmailSender(
-&nbsp; &nbsp; userRepsitory: UserRepository
+class EmailSender:
+&nbsp; def send(to: Email, subject: String, body: String): Unit =
+&nbsp; &nbsp; println(s"email send to $to")
+
+class EmailReserver:
+&nbsp; def reserve(
+&nbsp; &nbsp; &nbsp; to: Email,
+&nbsp; &nbsp; &nbsp; subject: String,
+&nbsp; &nbsp; &nbsp; body: String,
+&nbsp; &nbsp; &nbsp; when: LocalDateTime
+&nbsp; ): Unit =
+&nbsp; &nbsp; println(s"email reserved sending to $to when $when")
+
+// アプリケーション層
+class EmailSendService(
+&nbsp; &nbsp; userRepsitory: UserRepository,
+&nbsp; &nbsp; sender: EmailSender
&nbsp;) extends DomainEventObserver:
&nbsp; &nbsp;override def respondTo[T &lt;: DomainEvent](event: T): Unit =
&nbsp; &nbsp; &nbsp;event match
&nbsp; &nbsp; &nbsp; &nbsp;case e: MeetingCreated =&gt;
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;val users =
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;userRepsitory.getByIds(e.organizerId :: e.participantIds)
-&nbsp; &nbsp; &nbsp; &nbsp; users.foreach(u =&gt; send(u.email, e.title, e.detail))
+&nbsp; &nbsp; &nbsp; &nbsp; users.foreach(u =&gt; sender.send(u.email, e.title, e.detail))
&nbsp; &nbsp; &nbsp; &nbsp;case e: MeetingDeleted =&gt;
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;val users =
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;userRepsitory.getByIds(e.organizerId :: e.participantIds)
-&nbsp; &nbsp; &nbsp; &nbsp; users.foreach(u =&gt; send(u.email, "ミーティング削除のお知らせ", "ミーティングが削除されました"))
+&nbsp; &nbsp; &nbsp; &nbsp; users.foreach(u =&gt;
+&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; sender.send(u.email, "ミーティング削除のお知らせ", "ミーティングが削除されました")
+&nbsp; &nbsp; &nbsp; &nbsp; )
&nbsp;
-&nbsp; def send(to: Email, subject: String, body: String): Unit =
-&nbsp; &nbsp; println(s"email send to $to")
-
-class EmailReserver(
-&nbsp; &nbsp; userRepsitory: UserRepository
+class EmailReserveService(
+&nbsp; &nbsp; userRepsitory: UserRepository,
+&nbsp; &nbsp; reserver: EmailReserver
&nbsp;) extends DomainEventObserver:
&nbsp; &nbsp;override def respondTo[T &lt;: DomainEvent](event: T): Unit =
&nbsp; &nbsp; &nbsp;event match
@@ -150,26 +165,17 @@ class EmailReserver(
 &nbsp; &nbsp; &nbsp; &nbsp;val users =
 &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;userRepsitory.getByIds(e.organizerId :: e.participantIds)
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;users.foreach(u =&gt; {
-&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; reserve(u.email, e.title, e.detail, e.startAt)
-&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; reserve(u.email, e.title, e.detail, e.endAt)
+&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; reserver.reserve(u.email, e.title, e.detail, e.startAt)
+&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; reserver.reserve(u.email, e.title, e.detail, e.endAt)
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;})
&nbsp;
-&nbsp; def reserve(
-&nbsp; &nbsp; &nbsp; to: Email,
-&nbsp; &nbsp; &nbsp; subject: String,
-&nbsp; &nbsp; &nbsp; body: String,
-&nbsp; &nbsp; &nbsp; when: LocalDateTime
-&nbsp; ): Unit =
-&nbsp; &nbsp; println(s"email reserved sending to $to when $when")
-
-// アプリケーション層
&nbsp;class MeetingService(
&nbsp; &nbsp; &nbsp;meetingRepository: MeetingRepository,
&nbsp; &nbsp; &nbsp;userRepsitory: UserRepository
&nbsp;):
&nbsp; &nbsp;private val publisher = DomainEventPublisher(
-&nbsp; &nbsp; EmailSender(userRepsitory),
-&nbsp; &nbsp; EmailReserver(userRepsitory)
+&nbsp; &nbsp; EmailSendService(userRepsitory, EmailSender()),
+&nbsp; &nbsp; EmailReserveService(userRepsitory, EmailReserver())
&nbsp; &nbsp;)
&nbsp;
&nbsp; &nbsp;def reserve(</code></pre> すっきりしました。責任範囲がちゃんと分離できた気がします。依存関係に関してはアプリケーションサービスがインフラを参照してしまっていますが、些細な問題なので今日のところはここまでにしておきます。

インフラ層からアプリケーションロジックを分離する

今回はドメインイベントの発行主体をドメインオブジェクトにする修正と、インフラ層からアプリケーションロジックを切り離すリファクタを行いました。 現時点でのコード全容を添付しておきます。<pre><code>// ドメイン層
class UserId(val value: Int) extends AnyVal
class Email(val value: String) extends AnyVal

class User(val id: UserId, val email: Email):
 def followed: List[User] =
 List(
 User(UserId(1), Email("hoge1@example.com")),
 User(UserId(2), Email("hoge2@example.com"))
 )

trait UserRepository:
 def get(id: UserId) =
 User(id, Email("hoge@example.com"))

 def getByIds(ids: List[UserId]) =
 ids.map(User(_, Email("hoge@example.com")))

class MeetingId(val value: Int) extends AnyVal

class Meeting(
 val id: MeetingId,
 val organizerId: UserId,
 val participantIds: List[UserId],
 val startAt: LocalDateTime,
 val endAt: LocalDateTime,
 val title: String,
 val detail: String
):
 def delete: MeetingDeleted =
 MeetingDeleted(id, organizerId, participantIds)

object Meeting:
 def create(
 organizerId: UserId,
 participantIds: List[UserId],
 startAt: LocalDateTime,
 endAt: LocalDateTime,
 title: String,
 detail: String
 ): (Meeting, MeetingCreated) =
 val id = MeetingId(1)
 val meeting =
 Meeting(id, organizerId, participantIds, startAt, endAt, title, detail)
 val event = MeetingCreated(
 id,
 organizerId,
 participantIds,
 title,
 detail,
 startAt,
 endAt
 )
 (meeting, event)

trait MeetingRepository:
 def save(meeting: Meeting): Unit
 def get(meetingId: MeetingId): Meeting
 def delete(meetingId: MeetingId, event: MeetingDeleted): Unit

trait DomainEvent:
 val occuredOn = LocalDateTime.now()

class MeetingCreated(
 val meetingId: MeetingId,
 val organizerId: UserId,
 val participantIds: List[UserId],
 val title: String,
 val detail: String,
 val startAt: LocalDateTime,
 val endAt: LocalDateTime
) extends DomainEvent

class MeetingDeleted(
 val meetingId: MeetingId,
 val organizerId: UserId,
 val participantIds: List[UserId]
) extends DomainEvent

trait DomainEventObserver:
 def respondTo[T &lt;: DomainEvent](event: T): Unit

class DomainEventPublisher(obs: DomainEventObserver*):
 def publish[T &lt;: DomainEvent](event: T): Unit =
 obs.foreach(_.respondTo(event))

// インフラストラクチャ層
class EmailSender:
 def send(to: Email, subject: String, body: String): Unit =
 println(s"email send to $to")

class EmailReserver:
 def reserve(
 to: Email,
 subject: String,
 body: String,
 when: LocalDateTime
 ): Unit =
 println(s"email reserved sending to $to when $when")

// アプリケーション層
class EmailSendService(
 userRepsitory: UserRepository,
 sender: EmailSender
) extends DomainEventObserver:
 override def respondTo[T &lt;: DomainEvent](event: T): Unit =
 event match
 case e: MeetingCreated =&gt;
 val users =
 userRepsitory.getByIds(e.organizerId :: e.participantIds)
 users.foreach(u =&gt; sender.send(u.email, e.title, e.detail))
 case e: MeetingDeleted =&gt;
 val users =
 userRepsitory.getByIds(e.organizerId :: e.participantIds)
 users.foreach(u =&gt;
 sender.send(u.email, "ミーティング削除のお知らせ", "ミーティングが削除されました")
 )

class EmailReserveService(
 userRepsitory: UserRepository,
 reserver: EmailReserver
) extends DomainEventObserver:
 override def respondTo[T &lt;: DomainEvent](event: T): Unit =
 event match
 case e: MeetingCreated =&gt;
 val users =
 userRepsitory.getByIds(e.organizerId :: e.participantIds)
 users.foreach(u =&gt; {
 reserver.reserve(u.email, e.title, e.detail, e.startAt)
 reserver.reserve(u.email, e.title, e.detail, e.endAt)
 })

class MeetingService(
 meetingRepository: MeetingRepository,
 userRepsitory: UserRepository
):
 private val publisher = DomainEventPublisher(
 EmailSendService(userRepsitory, EmailSender()),
 EmailReserveService(userRepsitory, EmailReserver())
 )

 def reserve(
 organizerId: UserId,
 participantIds: List[UserId],
 startAt: LocalDateTime,
 endAt: LocalDateTime,
 title: String,
 detail: String
 ): Unit =
 val (meeting, event) =
 Meeting.create(
 organizerId,
 participantIds,
 startAt,
 endAt,
 title,
 detail
 )
 meetingRepository.save(meeting)
 publisher.publish(event)

 def reserveWithFollowed(
 organizerId: UserId,
 startAt: LocalDateTime,
 endAt: LocalDateTime,
 title: String,
 detail: String
 ): Unit =
 val organizer = userRepsitory.get(organizerId)
 val followers = organizer.followed
 val (meeting, event) =
 Meeting.create(
 organizerId,
 followers.map(_.id),
 startAt,
 endAt,
 title,
 detail
 )
 meetingRepository.save(meeting)
 publisher.publish(event)

 def remove(meetingId: MeetingId): Unit =
 val meeting = meetingRepository.get(meetingId)
 val event = meeting.delete
 meetingRepository.delete(meetingId, event)
 publisher.publish(event)</code></pre>

まとめ

イベントをドメインに移したい

Scalaの型について（応用編その３）

まず最初に前回のおさらいとして前回の実装の一部を再掲します。<pre><code>// サービス層
class MeetingService(
 meetingRepository: MeetingRepository,
 userRepsitory: UserRepository
):
 def reserve(
 organizerId: UserId,
 participantIds: List[UserId],
 startAt: LocalDateTime,
 endAt: LocalDateTime,
 title: String,
 detail: String
 ): Unit =
 val meeting =
 Meeting(organizerId, participantIds, startAt, endAt, title, detail)
 meetingRepository.save(meeting)

 def notify(user: User) =
 EmailSender().send(user.email, title, detail)
 EmailReserver().reserve(user.email, title, detail, startAt)
 EmailReserver().reserve(user.email, title, detail, endAt)

 val users = userRepsitory.getByIds(organizerId :: participantIds)
 users.foreach(notify)</code></pre> 現時点では特に問題のあるコードのようには思えません。では、（少々こじつけ感がありますが）以下のような仕様を追加します。<ul><li>このシステムには別のユーザをフォローする機能も他にある</li><li>主催者は参加者を選んでミーティングを作成することの他に、参加者を自分で直接選ばずミーティングを作成することもできる<ul><li>その場合、参加者は自分をフォローしているユーザに設定される</li></ul></li></ul> 雑に実装するとこんな感じでしょうか。<pre><code>-class User(val id: UserId, val email: Email)
+class User(val id: UserId, val email: Email):
+&nbsp; def followed: List[User] =
+&nbsp; &nbsp; List(
+&nbsp; &nbsp; &nbsp; User(UserId(1), Email("hoge1@example.com")),
+&nbsp; &nbsp; &nbsp; User(UserId(2), Email("hoge2@example.com"))
+&nbsp; &nbsp; )
&nbsp;
&nbsp;trait UserRepository:
+&nbsp; def get(id: UserId) =
+&nbsp; &nbsp; User(id, Email("hoge@example.com"))
+
&nbsp; &nbsp;def getByIds(ids: List[UserId]) =
&nbsp; &nbsp; &nbsp;ids.map(User(_, Email("hoge@example.com")))
&nbsp;
@@ -97,3 +105,24 @@ class MeetingService(
&nbsp;
&nbsp; &nbsp; &nbsp;val users = userRepsitory.getByIds(organizerId :: participantIds)
&nbsp; &nbsp; &nbsp;users.foreach(notify)
+
+&nbsp; def reserveWithFollowed(
+&nbsp; &nbsp; &nbsp; organizerId: UserId,
+&nbsp; &nbsp; &nbsp; startAt: LocalDateTime,
+&nbsp; &nbsp; &nbsp; endAt: LocalDateTime,
+&nbsp; &nbsp; &nbsp; title: String,
+&nbsp; &nbsp; &nbsp; detail: String
+&nbsp; ): Unit =
+&nbsp; &nbsp; val organizer = userRepsitory.get(organizerId)
+&nbsp; &nbsp; val followers = organizer.followed
+&nbsp; &nbsp; val meeting =
+&nbsp; &nbsp; &nbsp; Meeting(organizerId, followers.map(_.id), startAt, endAt, title, detail)
+&nbsp; &nbsp; meetingRepository.save(meeting)
+
+&nbsp; &nbsp; def notify(user: User) =
+&nbsp; &nbsp; &nbsp; EmailSender().send(user.email, title, detail)
+&nbsp; &nbsp; &nbsp; EmailReserver().reserve(user.email, title, detail, startAt)
+&nbsp; &nbsp; &nbsp; EmailReserver().reserve(user.email, title, detail, endAt)
+
+&nbsp; &nbsp; val users = userRepsitory.getByIds(organizerId :: followers.map(_.id))
+&nbsp; &nbsp; users.foreach(notify)</code></pre> こうなってくると、流石にリファクタしたくなってきます。とりあえず一旦通知関連の処理を内部メソッドに切り出しましょう。<pre><code>@@ -98,13 +98,14 @@ class MeetingService(
&nbsp; &nbsp; &nbsp; &nbsp;Meeting(organizerId, participantIds, startAt, endAt, title, detail)
&nbsp; &nbsp; &nbsp;meetingRepository.save(meeting)
&nbsp;
-&nbsp; &nbsp; def notify(user: User) =
-&nbsp; &nbsp; &nbsp; EmailSender().send(user.email, title, detail)
-&nbsp; &nbsp; &nbsp; EmailReserver().reserve(user.email, title, detail, startAt)
-&nbsp; &nbsp; &nbsp; EmailReserver().reserve(user.email, title, detail, endAt)
-
-&nbsp; &nbsp; val users = userRepsitory.getByIds(organizerId :: participantIds)
-&nbsp; &nbsp; users.foreach(notify)
+&nbsp; &nbsp; notifyMeetingCreated(
+&nbsp; &nbsp; &nbsp; organizerId,
+&nbsp; &nbsp; &nbsp; participantIds,
+&nbsp; &nbsp; &nbsp; title,
+&nbsp; &nbsp; &nbsp; detail,
+&nbsp; &nbsp; &nbsp; startAt,
+&nbsp; &nbsp; &nbsp; endAt
+&nbsp; &nbsp; )
&nbsp;
&nbsp; &nbsp;def reserveWithFollowed(
&nbsp; &nbsp; &nbsp; &nbsp;organizerId: UserId,
@@ -119,10 +120,27 @@ class MeetingService(
&nbsp; &nbsp; &nbsp; &nbsp;Meeting(organizerId, followers.map(_.id), startAt, endAt, title, detail)
&nbsp; &nbsp; &nbsp;meetingRepository.save(meeting)
&nbsp;
+&nbsp; &nbsp; notifyMeetingCreated(
+&nbsp; &nbsp; &nbsp; organizerId,
+&nbsp; &nbsp; &nbsp; followers.map(_.id),
+&nbsp; &nbsp; &nbsp; title,
+&nbsp; &nbsp; &nbsp; detail,
+&nbsp; &nbsp; &nbsp; startAt,
+&nbsp; &nbsp; &nbsp; endAt
+&nbsp; &nbsp; )
+
+&nbsp; private def notifyMeetingCreated(
+&nbsp; &nbsp; &nbsp; organizerId: UserId,
+&nbsp; &nbsp; &nbsp; participantIds: List[UserId],
+&nbsp; &nbsp; &nbsp; title: String,
+&nbsp; &nbsp; &nbsp; detail: String,
+&nbsp; &nbsp; &nbsp; startAt: LocalDateTime,
+&nbsp; &nbsp; &nbsp; endAt: LocalDateTime
+&nbsp; ): Unit =
&nbsp; &nbsp; &nbsp;def notify(user: User) =
&nbsp; &nbsp; &nbsp; &nbsp;EmailSender().send(user.email, title, detail)
&nbsp; &nbsp; &nbsp; &nbsp;EmailReserver().reserve(user.email, title, detail, startAt)
&nbsp; &nbsp; &nbsp; &nbsp;EmailReserver().reserve(user.email, title, detail, endAt)
&nbsp;
-&nbsp; &nbsp; val users = userRepsitory.getByIds(organizerId :: followers.map(_.id))
+&nbsp; &nbsp; val users = userRepsitory.getByIds(organizerId :: participantIds)
&nbsp; &nbsp; &nbsp;users.foreach(notify)</code></pre> 多少はスッキリしました。内部メソッドが大量の引数を受け取っているのが気持ち悪いですが、一旦目を瞑ります。

複数箇所で発生するイベント

更に要件が追加され、ミーティング情報を削除した際にも主催者と参加者全員に対してメール通知をすることになったとします。実装してみます。<pre><code>@@ -55,17 +55,22 @@ trait UserRepository:
&nbsp; &nbsp;def getByIds(ids: List[UserId]) =
&nbsp; &nbsp; &nbsp;ids.map(User(_, Email("hoge@example.com")))
&nbsp;
+class MeetingId(val value: Int) extends AnyVal
+
&nbsp;class Meeting(
-&nbsp; &nbsp; organizerId: UserId,
-&nbsp; &nbsp; participantIds: List[UserId],
-&nbsp; &nbsp; startAt: LocalDateTime,
-&nbsp; &nbsp; endAt: LocalDateTime,
-&nbsp; &nbsp; title: String,
-&nbsp; &nbsp; detail: String
+&nbsp; &nbsp; val id: Option[MeetingId],
+&nbsp; &nbsp; val organizerId: UserId,
+&nbsp; &nbsp; val participantIds: List[UserId],
+&nbsp; &nbsp; val startAt: LocalDateTime,
+&nbsp; &nbsp; val endAt: LocalDateTime,
+&nbsp; &nbsp; val title: String,
+&nbsp; &nbsp; val detail: String
&nbsp;)
&nbsp;
&nbsp;trait MeetingRepository:
&nbsp; &nbsp;def save(meeting: Meeting): Unit
+&nbsp; def get(meetingId: MeetingId): Meeting
+&nbsp; def delete(meetingId: MeetingId): Unit
&nbsp;
&nbsp;// インフラストラクチャ層
&nbsp;class EmailSender:
@@ -95,7 +100,7 @@ class MeetingService(
&nbsp; &nbsp; &nbsp; &nbsp;detail: String
&nbsp; &nbsp;): Unit =
&nbsp; &nbsp; &nbsp;val meeting =
-&nbsp; &nbsp; &nbsp; Meeting(organizerId, participantIds, startAt, endAt, title, detail)
+&nbsp; &nbsp; &nbsp; Meeting(None, organizerId, participantIds, startAt, endAt, title, detail)
&nbsp; &nbsp; &nbsp;meetingRepository.save(meeting)
&nbsp;
&nbsp; &nbsp; &nbsp;notifyMeetingCreated(
@@ -117,7 +122,15 @@ class MeetingService(
&nbsp; &nbsp; &nbsp;val organizer = userRepsitory.get(organizerId)
&nbsp; &nbsp; &nbsp;val followers = organizer.followed
&nbsp; &nbsp; &nbsp;val meeting =
-&nbsp; &nbsp; &nbsp; Meeting(organizerId, followers.map(_.id), startAt, endAt, title, detail)
+&nbsp; &nbsp; &nbsp; Meeting(
+&nbsp; &nbsp; &nbsp; &nbsp; None,
+&nbsp; &nbsp; &nbsp; &nbsp; organizerId,
+&nbsp; &nbsp; &nbsp; &nbsp; followers.map(_.id),
+&nbsp; &nbsp; &nbsp; &nbsp; startAt,
+&nbsp; &nbsp; &nbsp; &nbsp; endAt,
+&nbsp; &nbsp; &nbsp; &nbsp; title,
+&nbsp; &nbsp; &nbsp; &nbsp; detail
+&nbsp; &nbsp; &nbsp; )
&nbsp; &nbsp; &nbsp;meetingRepository.save(meeting)
&nbsp;
&nbsp; &nbsp; &nbsp;notifyMeetingCreated(
@@ -144,3 +157,14 @@ class MeetingService(
&nbsp;
&nbsp; &nbsp; &nbsp;val users = userRepsitory.getByIds(organizerId :: participantIds)
&nbsp; &nbsp; &nbsp;users.foreach(notify)
+
+&nbsp; def remove(meetingId: MeetingId): Unit =
+&nbsp; &nbsp; val meeting = meetingRepository.get(meetingId)
+&nbsp; &nbsp; meetingRepository.delete(meetingId)
+
+&nbsp; &nbsp; def notify(user: User) =
+&nbsp; &nbsp; &nbsp; EmailSender().send(user.email, "ミーティング削除のお知らせ", "ミーティングが削除されました")
+
+&nbsp; &nbsp; val userIds = meeting.organizerId :: meeting.participantIds
+&nbsp; &nbsp; val users = userRepsitory.getByIds(userIds)
+&nbsp; &nbsp; users.foreach(notify)</code></pre> また個別の通知ロジックが出てきました。今回はコードの重複を予想し、先に内部メソッドに切り出しておきましょう。<pre><code>@@ -162,9 +162,15 @@ class MeetingService(
&nbsp; &nbsp; &nbsp;val meeting = meetingRepository.get(meetingId)
&nbsp; &nbsp; &nbsp;meetingRepository.delete(meetingId)
&nbsp;
+&nbsp; &nbsp; notifyMeetingDeleted(meeting.organizerId, meeting.participantIds)
+
+&nbsp; private def notifyMeetingDeleted(
+&nbsp; &nbsp; &nbsp; organizerId: UserId,
+&nbsp; &nbsp; &nbsp; participantIds: List[UserId]
+&nbsp; ): Unit =
&nbsp; &nbsp; &nbsp;def notify(user: User) =
&nbsp; &nbsp; &nbsp; &nbsp;EmailSender().send(user.email, "ミーティング削除のお知らせ", "ミーティングが削除されました")
&nbsp;
-&nbsp; &nbsp; val userIds = meeting.organizerId :: meeting.participantIds
+&nbsp; &nbsp; val userIds = organizerId :: participantIds
&nbsp; &nbsp; &nbsp;val users = userRepsitory.getByIds(userIds)
&nbsp; &nbsp; &nbsp;users.foreach(notify)</code></pre>

別のイベント

現状の実装の何が問題でしょうか。例えば、以下のような仕様変更があったとします。<ul><li>メール通知の他にプッシュ通知も追加してほしい</li><li>メール通知の際にHTMLかプレーンテキストかを選択できるようにしたい</li></ul>いずれの場合も複数箇所を修正する必要があります。今はミーティングサービスだけしか見ていませんが、他のサービスを考えると更に多くの箇所を修正しなくてはなりません。影響範囲の特定・修正に時間がかかりますし、リグレッションにも注意しなければなりません。 行き当りばったりのリファクタではなく、根本的な設計を考え直してみます。<ul><li>「ミーティングが作成された」「ミーティングが削除された」のような「イベント」が存在する</li><li>メール送信者、メール予約者など、イベントの「観測者」が存在する</li><li>イベントは任意の場所から発行される。観測者はイベントが発行されるとそのイベントの種類に応じて反応する</li></ul>この設計でリファクタし直してみましょう。

問題点と対応方針

<pre><code>@@ -58,26 +58,65 @@ trait UserRepository:
&nbsp;class MeetingId(val value: Int) extends AnyVal
&nbsp;
&nbsp;class Meeting(
-&nbsp; &nbsp; val id: Option[MeetingId],
&nbsp; &nbsp; &nbsp;val organizerId: UserId,
&nbsp; &nbsp; &nbsp;val participantIds: List[UserId],
&nbsp; &nbsp; &nbsp;val startAt: LocalDateTime,
&nbsp; &nbsp; &nbsp;val endAt: LocalDateTime,
&nbsp; &nbsp; &nbsp;val title: String,
&nbsp; &nbsp; &nbsp;val detail: String
-)
+):
+&nbsp; val id = MeetingId(1)
&nbsp;
&nbsp;trait MeetingRepository:
&nbsp; &nbsp;def save(meeting: Meeting): Unit
&nbsp; &nbsp;def get(meetingId: MeetingId): Meeting
&nbsp; &nbsp;def delete(meetingId: MeetingId): Unit
&nbsp;
+trait DomainEvent:
+&nbsp; val occuredOn = LocalDateTime.now()
+
+class MeetingCreated(
+&nbsp; &nbsp; val meetingId: MeetingId,
+&nbsp; &nbsp; val users: List[User],
+&nbsp; &nbsp; val title: String,
+&nbsp; &nbsp; val detail: String,
+&nbsp; &nbsp; val startAt: LocalDateTime,
+&nbsp; &nbsp; val endAt: LocalDateTime
+) extends DomainEvent
+
+class MeetingDeleted(
+&nbsp; &nbsp; val meetingId: MeetingId,
+&nbsp; &nbsp; val users: List[User]
+) extends DomainEvent
+
+trait DomainEventObserver:
+&nbsp; def respondTo[T &lt;: DomainEvent](event: T): Unit
+
+class DomainEventPublisher(obs: DomainEventObserver*):
+&nbsp; def publish[T &lt;: DomainEvent](event: T): Unit =
+&nbsp; &nbsp; obs.foreach(_.respondTo(event))
+
&nbsp;// インフラストラクチャ層
-class EmailSender:
+class EmailSender extends DomainEventObserver:
+&nbsp; override def respondTo[T &lt;: DomainEvent](event: T): Unit =
+&nbsp; &nbsp; event match
+&nbsp; &nbsp; &nbsp; case e: MeetingCreated =&gt;
+&nbsp; &nbsp; &nbsp; &nbsp; e.users.foreach(u =&gt; send(u.email, e.title, e.detail))
+&nbsp; &nbsp; &nbsp; case e: MeetingDeleted =&gt;
+&nbsp; &nbsp; &nbsp; &nbsp; e.users.foreach(u =&gt; send(u.email, "ミーティング削除のお知らせ", "ミーティングが削除されました"))
+
&nbsp; &nbsp;def send(to: Email, subject: String, body: String): Unit =
&nbsp; &nbsp; &nbsp;println(s"email send to $to")
&nbsp;
-class EmailReserver:
+class EmailReserver extends DomainEventObserver:
+&nbsp; override def respondTo[T &lt;: DomainEvent](event: T): Unit =
+&nbsp; &nbsp; event match
+&nbsp; &nbsp; &nbsp; case e: MeetingCreated =&gt;
+&nbsp; &nbsp; &nbsp; &nbsp; e.users.foreach(u =&gt; {
+&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; reserve(u.email, e.title, e.detail, e.startAt)
+&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; reserve(u.email, e.title, e.detail, e.endAt)
+&nbsp; &nbsp; &nbsp; &nbsp; })
+
&nbsp; &nbsp;def reserve(
&nbsp; &nbsp; &nbsp; &nbsp;to: Email,
&nbsp; &nbsp; &nbsp; &nbsp;subject: String,
@@ -91,6 +130,8 @@ class MeetingService(
&nbsp; &nbsp; &nbsp;meetingRepository: MeetingRepository,
&nbsp; &nbsp; &nbsp;userRepsitory: UserRepository
&nbsp;):
+&nbsp; private val publisher = DomainEventPublisher(EmailSender(), EmailReserver())
+
&nbsp; &nbsp;def reserve(
&nbsp; &nbsp; &nbsp; &nbsp;organizerId: UserId,
&nbsp; &nbsp; &nbsp; &nbsp;participantIds: List[UserId],
@@ -100,16 +141,18 @@ class MeetingService(
&nbsp; &nbsp; &nbsp; &nbsp;detail: String
&nbsp; &nbsp;): Unit =
&nbsp; &nbsp; &nbsp;val meeting =
-&nbsp; &nbsp; &nbsp; Meeting(None, organizerId, participantIds, startAt, endAt, title, detail)
+&nbsp; &nbsp; &nbsp; Meeting(
+&nbsp; &nbsp; &nbsp; &nbsp; organizerId,
+&nbsp; &nbsp; &nbsp; &nbsp; participantIds,
+&nbsp; &nbsp; &nbsp; &nbsp; startAt,
+&nbsp; &nbsp; &nbsp; &nbsp; endAt,
+&nbsp; &nbsp; &nbsp; &nbsp; title,
+&nbsp; &nbsp; &nbsp; &nbsp; detail
+&nbsp; &nbsp; &nbsp; )
&nbsp; &nbsp; &nbsp;meetingRepository.save(meeting)
-
-&nbsp; &nbsp; notifyMeetingCreated(
-&nbsp; &nbsp; &nbsp; organizerId,
-&nbsp; &nbsp; &nbsp; participantIds,
-&nbsp; &nbsp; &nbsp; title,
-&nbsp; &nbsp; &nbsp; detail,
-&nbsp; &nbsp; &nbsp; startAt,
-&nbsp; &nbsp; &nbsp; endAt
+&nbsp; &nbsp; val users = userRepsitory.getByIds(organizerId :: participantIds)
+&nbsp; &nbsp; publisher.publish(
+&nbsp; &nbsp; &nbsp; MeetingCreated(meeting.id, users, title, detail, startAt, endAt)
&nbsp; &nbsp; &nbsp;)
&nbsp;
&nbsp; &nbsp;def reserveWithFollowed(
@@ -123,7 +166,6 @@ class MeetingService(
&nbsp; &nbsp; &nbsp;val followers = organizer.followed
&nbsp; &nbsp; &nbsp;val meeting =
&nbsp; &nbsp; &nbsp; &nbsp;Meeting(
-&nbsp; &nbsp; &nbsp; &nbsp; None,
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;organizerId,
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;followers.map(_.id),
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;startAt,
@@ -132,45 +174,14 @@ class MeetingService(
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;detail
&nbsp; &nbsp; &nbsp; &nbsp;)
&nbsp; &nbsp; &nbsp;meetingRepository.save(meeting)
-
-&nbsp; &nbsp; notifyMeetingCreated(
-&nbsp; &nbsp; &nbsp; organizerId,
-&nbsp; &nbsp; &nbsp; followers.map(_.id),
-&nbsp; &nbsp; &nbsp; title,
-&nbsp; &nbsp; &nbsp; detail,
-&nbsp; &nbsp; &nbsp; startAt,
-&nbsp; &nbsp; &nbsp; endAt
+&nbsp; &nbsp; val users = userRepsitory.getByIds(organizerId :: followers.map(_.id))
+&nbsp; &nbsp; publisher.publish(
+&nbsp; &nbsp; &nbsp; MeetingCreated(meeting.id, users, title, detail, startAt, endAt)
&nbsp; &nbsp; &nbsp;)
&nbsp;
-&nbsp; private def notifyMeetingCreated(
-&nbsp; &nbsp; &nbsp; organizerId: UserId,
-&nbsp; &nbsp; &nbsp; participantIds: List[UserId],
-&nbsp; &nbsp; &nbsp; title: String,
-&nbsp; &nbsp; &nbsp; detail: String,
-&nbsp; &nbsp; &nbsp; startAt: LocalDateTime,
-&nbsp; &nbsp; &nbsp; endAt: LocalDateTime
-&nbsp; ): Unit =
-&nbsp; &nbsp; def notify(user: User) =
-&nbsp; &nbsp; &nbsp; EmailSender().send(user.email, title, detail)
-&nbsp; &nbsp; &nbsp; EmailReserver().reserve(user.email, title, detail, startAt)
-&nbsp; &nbsp; &nbsp; EmailReserver().reserve(user.email, title, detail, endAt)
-
-&nbsp; &nbsp; val users = userRepsitory.getByIds(organizerId :: participantIds)
-&nbsp; &nbsp; users.foreach(notify)
-
&nbsp; &nbsp;def remove(meetingId: MeetingId): Unit =
&nbsp; &nbsp; &nbsp;val meeting = meetingRepository.get(meetingId)
&nbsp; &nbsp; &nbsp;meetingRepository.delete(meetingId)
-
-&nbsp; &nbsp; notifyMeetingDeleted(meeting.organizerId, meeting.participantIds)
-
-&nbsp; private def notifyMeetingDeleted(
-&nbsp; &nbsp; &nbsp; organizerId: UserId,
-&nbsp; &nbsp; &nbsp; participantIds: List[UserId]
-&nbsp; ): Unit =
-&nbsp; &nbsp; def notify(user: User) =
-&nbsp; &nbsp; &nbsp; EmailSender().send(user.email, "ミーティング削除のお知らせ", "ミーティングが削除されました")
-
-&nbsp; &nbsp; val userIds = organizerId :: participantIds
-&nbsp; &nbsp; val users = userRepsitory.getByIds(userIds)
-&nbsp; &nbsp; users.foreach(notify)
+&nbsp; &nbsp; val users =
+&nbsp; &nbsp; &nbsp; userRepsitory.getByIds(meeting.organizerId :: meeting.participantIds)
+&nbsp; &nbsp; publisher.publish(MeetingDeleted(meeting.id, users))</code></pre> アプリケーションサービスの実装がすっきりし、通知に関するロジックはそれぞれの観測者のイベントごとの実装に収まりました。（なお、実装はデザインパターンのObserverパターンを使用しているつもりです。）まだまだ改善の余地はありそうですが、長くなってきたので今回はここまでとします。 そういえば、ようやく出てきましたね、<pre><code>+&nbsp; def respondTo[T &lt;: DomainEvent](event: T): Unit</code></pre> 上限境界です。Pub/Subの実装に気を取られてこのブログの趣旨を忘れてしまっていました(笑)

リファクタリング

今回は、イベントの発火に関するロジックをまとめるために、Observerパターンを使用してリファクタしました。現時点でのコードの全容を貼っておきます。<pre><code>// ドメイン層
class UserId(val value: Int) extends AnyVal
class Email(val value: String) extends AnyVal

class User(val id: UserId, val email: Email):
 def followed: List[User] =
 List(
 User(UserId(1), Email("hoge1@example.com")),
 User(UserId(2), Email("hoge2@example.com"))
 )

trait UserRepository:
 def get(id: UserId) =
 User(id, Email("hoge@example.com"))

 def getByIds(ids: List[UserId]) =
 ids.map(User(_, Email("hoge@example.com")))

class MeetingId(val value: Int) extends AnyVal

class Meeting(
 val organizerId: UserId,
 val participantIds: List[UserId],
 val startAt: LocalDateTime,
 val endAt: LocalDateTime,
 val title: String,
 val detail: String
):
 val id = MeetingId(1)

trait MeetingRepository:
 def save(meeting: Meeting): Unit
 def get(meetingId: MeetingId): Meeting
 def delete(meetingId: MeetingId): Unit

trait DomainEvent:
 val occuredOn = LocalDateTime.now()

class MeetingCreated(
 val meetingId: MeetingId,
 val users: List[User],
 val title: String,
 val detail: String,
 val startAt: LocalDateTime,
 val endAt: LocalDateTime
) extends DomainEvent

class MeetingDeleted(
 val meetingId: MeetingId,
 val users: List[User]
) extends DomainEvent

trait DomainEventObserver:
 def respondTo[T &lt;: DomainEvent](event: T): Unit

class DomainEventPublisher(obs: DomainEventObserver*):
 def publish[T &lt;: DomainEvent](event: T): Unit =
 obs.foreach(_.respondTo(event))

// インフラストラクチャ層
class EmailSender extends DomainEventObserver:
 override def respondTo[T &lt;: DomainEvent](event: T): Unit =
 event match
 case e: MeetingCreated =&gt;
 e.users.foreach(u =&gt; send(u.email, e.title, e.detail))
 case e: MeetingDeleted =&gt;
 e.users.foreach(u =&gt; send(u.email, "ミーティング削除のお知らせ", "ミーティングが削除されました"))

 def send(to: Email, subject: String, body: String): Unit =
 println(s"email send to $to")

class EmailReserver extends DomainEventObserver:
 override def respondTo[T &lt;: DomainEvent](event: T): Unit =
 event match
 case e: MeetingCreated =&gt;
 e.users.foreach(u =&gt; {
 reserve(u.email, e.title, e.detail, e.startAt)
 reserve(u.email, e.title, e.detail, e.endAt)
 })

 def reserve(
 to: Email,
 subject: String,
 body: String,
 when: LocalDateTime
 ): Unit =
 println(s"email reserved sending to $to when $when")

// アプリケーション層
class MeetingService(
 meetingRepository: MeetingRepository,
 userRepsitory: UserRepository
):
 private val publisher = DomainEventPublisher(EmailSender(), EmailReserver())

 def reserve(
 organizerId: UserId,
 participantIds: List[UserId],
 startAt: LocalDateTime,
 endAt: LocalDateTime,
 title: String,
 detail: String
 ): Unit =
 val meeting =
 Meeting(
 organizerId,
 participantIds,
 startAt,
 endAt,
 title,
 detail
 )
 meetingRepository.save(meeting)
 val users = userRepsitory.getByIds(organizerId :: participantIds)
 publisher.publish(
 MeetingCreated(meeting.id, users, title, detail, startAt, endAt)
 )

 def reserveWithFollowed(
 organizerId: UserId,
 startAt: LocalDateTime,
 endAt: LocalDateTime,
 title: String,
 detail: String
 ): Unit =
 val organizer = userRepsitory.get(organizerId)
 val followers = organizer.followed
 val meeting =
 Meeting(
 organizerId,
 followers.map(_.id),
 startAt,
 endAt,
 title,
 detail
 )
 meetingRepository.save(meeting)
 val users = userRepsitory.getByIds(organizerId :: followers.map(_.id))
 publisher.publish(
 MeetingCreated(meeting.id, users, title, detail, startAt, endAt)
 )

 def remove(meetingId: MeetingId): Unit =
 val meeting = meetingRepository.get(meetingId)
 meetingRepository.delete(meetingId)
 val users =
 userRepsitory.getByIds(meeting.organizerId :: meeting.participantIds)
 publisher.publish(MeetingDeleted(meeting.id, users))</code></pre>

ドメインイベントの導入

Scalaの型について（応用編その２）

例として、ミーティング予約サービスを考えます。このサービスは、ユーザからのミーティング予約リクエストを受けて、ミーティング情報を保存し、後から参照できるようにします。また、ミーティングを予約したユーザ（主催者）と、参加者全員に対して、メールを送信します。メールの送信タイミングは予約したタイミングと、ミーティング開始10分前、ミーティング終了10分前とします。 まずは適当に雑なコードを書いてみます。<pre><code>// ドメイン層
class UserId(val value: Int) extends AnyVal
class Email(val value: String) extends AnyVal

class User(val id: UserId, val email: Email)

trait UserRepository:
 def getByIds(ids: List[UserId]) =
 ids.map(User(_, Email("hoge@example.com")))

class Meeting(
 organizerId: UserId,
 participantIds: List[UserId],
 startAt: LocalDateTime,
 endAt: LocalDateTime,
 title: String,
 detail: String
)

trait MeetingRepository:
 def save(meeting: Meeting): Unit

// インフラストラクチャ層
class EmailSender:
 def send(to: Email, subject: String, detail: String): Unit =
 println(s"email send to $to")

class EmailReserver:
 def reserve(
 to: Email,
 subject: String,
 detail: String,
 when: LocalDateTime
 ): Unit =
 println(s"email reserved sending to $to when $when")

// サービス層
class MeetingService(
 meetingRepository: MeetingRepository,
 userRepsitory: UserRepository
):
 def reserve(
 organizerId: UserId,
 participantIds: List[UserId],
 startAt: LocalDateTime,
 endAt: LocalDateTime,
 title: String,
 detail: String
 ): Unit =
 val meeting =
 Meeting(organizerId, participantIds, startAt, endAt, title, detail)
 meetingRepository.save(meeting)

 def notify(user: User) =
 EmailSender().send(user.email, title, detail)
 EmailReserver().reserve(user.email, title, detail, startAt)
 EmailReserver().reserve(user.email, title, detail, endAt)

 val users = userRepsitory.getByIds(organizerId :: participantIds)
 users.foreach(notify)</code></pre> 面倒なのでファイル構成とかは考えてません。あと実際の処理も面倒なので全部printです。それと、メール送信の予約は実際には開始終了時間の10分前と言いましたが、本質と関係ない仕様なので一旦無視しています。

初回実装

今回は応用編の初回ということで、例として扱うドメインの要件と最初の実装を行いました。次回から少しずつリファクタリングしていこうと思います。

ミーティング予約サービス

Scalaの型について（応用編その１）

下限境界自体はそんなに難しくないのですが、どんな例を示すかで悩みました。というのも、ネットに出回っている他の記事を眺めていても、大体がListのようなデータ構造を定義しているだけで、「だったら普通にListを使えば良くない？下限境界なんて実際使うことなんてある？」という疑問に答えることができないと思ったためです。色々考えた結果、前回の例で使用したZooクラスを拡張するのが良さそうだと判断しました。 前回のZooクラスで、インスタンス化した後に<code>append</code>メソッドで別の動物を追加できるようにしたいとします。ただし、現状<code>animals</code>はListなので、後から要素を追加することはできません。そこで同じオブジェクトに要素を追加するのではなく、要素が追加された新しいオブジェクトを生成するようにします。 <pre><code>@main def main() =
 val zoo = Zoo(List(Dog(), Cat()))
 zoo.sound()
 val dogZoo = Zoo(List(Dog(), Dog()))
 dogZoo.sound()
 dogZoo.animals.foreach(_.run())
 val animalZoo = dogZoo.append(Cat()) // コンパイルエラー

class Zoo[T &lt;: Animal](val animals: List[T]):
 def sound(): Unit =
 animals.foreach(_.cry())

 def append(animal: T) =
 Zoo(animal :: animals)

class Animal:
 def cry(): Unit =
 println("crying")

class Dog extends Animal:
 override def cry(): Unit =
 println("bow wow!")

 def run(): Unit =
 println("running!")

class Cat extends Animal:
 override def cry(): Unit =
 println("meow")

 def walk(): Unit =
 println("walking")</code></pre> 上記のmain関数は6行目でコンパイルエラーを発生します。これは、<code>dogZoo</code>の型が3行目で<code>Zoo[Dog]</code>に固定されてしまっているためです。appendの引数の型パラメータがTになっており、<code>dogZoo</code>の場合はTがDogになるためです。しかし、Catを入れた場合は<code>Zoo[Animal]</code>を生成してほしいです。このような場合に、下限境界を用いることで、Zooに柔軟性を持たせることができます。下限境界は、<code>[T &gt;: U]</code>と指定します（Uが下限）<pre><code>@main def main() =
 val zoo = Zoo(List(Dog(), Cat()))
 zoo.sound()
 val dogZoo = Zoo(List(Dog(), Dog()))
 dogZoo.sound()
 dogZoo.animals.foreach(_.run())
 val animalZoo = dogZoo.append(Cat())

class Zoo[T &lt;: Animal](val animals: List[T]):
 def sound(): Unit =
 animals.foreach(_.cry())

 def append[U &gt;: T &lt;: Animal](animal: U) =
 Zoo(animal :: animals)</code></pre> 上記のバージョンではコンパイルエラーは起こらず、期待通り<code>animalZoo</code>の型は<code>Zoo[Animal]</code>になります。（なお、下限境界の設定のみではUはZooの型パラメータが満たすべき上限境界を満たしていないためZooのインスタンス化のところでコンパイルエラーになります。そのため下限境界だけでなく上限境界も同時に設定しています。） Zooの属性<code>animals</code>の型をAnimalのサブクラスに限定しながら、後から別のAnimalを追加した際にも型の柔軟性が保たれるような実装になりました。

下限境界

Scalaの型についてまとめてみた（その４）

型パラメータは基本的にどんな型が入ってくるかわからないというか、どんな型でも対応できる柔軟性を持たせるのが目的でした。しかし、場合によっては型にある程度制約を持たせたい場合があります。<code>[T &lt;: Type]</code>という型パラメータの指定をすると、TはTypeのサブ型であるという制約が課されます。例を示します。<pre><code>@main def main() =
 val zoo = Zoo(List(Dog(), Cat()))
 zoo.sound()
 val dogZoo = Zoo(List(Dog(), Dog()))
 dogZoo.sound()
 dogZoo.animals.foreach(_.run())

class Zoo[T &lt;: Animal](val animals: List[T]):
 def sound(): Unit =
 animals.foreach(_.cry())

class Animal:
 def cry(): Unit =
 println("crying")

class Dog extends Animal:
 override def cry(): Unit =
 println("bow wow!")

 def run(): Unit =
 println("running!")

class Cat extends Animal:
 override def cry(): Unit =
 println("meow")

 def walk(): Unit =
 println("walking")</code></pre> 上記で、<code>Zoo[T &lt;: Animal]</code>と定義されているので、Zooの型パラメータはAnimalもしくはそのサブ型であることが要求されます。このように定義することで、メソッド定義内でAnimal型のメソッド<code>cry()</code>を使用することができます。main関数の1行目の定数は、Zoo[Animal]型です。一方、3行目の定数はZoo[Dog]型です。個人的にはここがポイントだと思っていて、あくまでも型パラメータの型が可変になることで、5行目ではDog型のメソッドである<code>run()</code>を呼び出すことが可能になっています。<pre><code>class Zoo(val animals: List[Animal]):
 def sound(): Unit =
 animals.foreach(_.cry())</code></pre> 上記のように定義すると、上の<code>dogZoo.animals</code>は<code>List[Animal]</code>になってしまうため、<code>run()</code>を呼び出すことができなくなってしまいます。いわばDog型であるという情報を失ってしまうことになります。 上限境界を用いることで、型安全性と柔軟性を兼ね備えた実装が可能になることがわかりました。

上限境界

Scalaの型についてまとめてみた（その３）

前回の最後で、反変とは共変の逆であるという話をしました。反変の型アノテーションは、<code>Hoge[-T]</code>と定義します。UがTの子である場合、Hoge[U]はHoge[T]の「親」になります。物凄く不自然な感じがしますね。具体例を使って考えてみます。<pre><code>@main def main() =
 val animal = Animal()
 val dog = Dog()

 val fn1: Dog =&gt; Unit = listen
 fn1(dog) #=&gt; "listening to...\nbow wow!"

 val fn2: Animal =&gt; Unit = chase // コンパイルエラー
 fn2(animal)

def listen(a: Animal): Unit =
 println("listening to...")
 a.cry()

def chase(d: Dog): Unit =
 println("chasing!")
 d.run()

class Animal:
 def cry(): Unit =
 println("crying")

class Dog extends Animal:
 override def cry(): Unit =
 println("bow wow!")

 def run(): Unit =
 println("running!")</code></pre> Scalaでは関数型の引数のパラメータが反変として定義されています。そのため上記のmain関数の4行目は成功しますが、7行目はコンパイルエラーを発生します。listenは引数にAnimalを要求していますが、fn1として実際に実行されるときに渡されているのはDogです。Dog is AnimalなのでAnimalとしての要求にはもちろん応えられます。逆に、chaseは引数にDogを要求していますが、fn2として実際に渡されているのはAnimalです。そのためもし7行目でコンパイルエラーが発生しないなら、Animalに対してrunメソッドを呼び出そうとして実行エラーになっていたことでしょう。 ここで関数の型について考えてみると、fn1はDog =&gt; Unit型でしたが、代入されているのはlistenつまりAnimal =&gt; Unit型です。抽象化するとFn[Dog]がFn[Animal]と互換性がある、つまり親子関係でいうとFn[Dog]はFn[Animal]の親ということになり、型パラメータと親子関係が逆転していることがわかります。 一見不自然に見える反変ですが、場合によっては自然な定義となることもあることがわかりました。

反変

型アノテーションその２

Scalaの型についてまとめてみた（その２）

例として以下のコードを見てください。<pre><code>val animals = List[Animal](Dog(), Cat())
animals.foreach(_.cry())

abstract class Animal():
 def cry(): Unit

class Dog extends Animal():
 override def cry(): Unit =
 println("bow wow!")

class Cat extends Animal():
 override def cry(): Unit =
 println("meow")</code></pre> ※List[Animal]は型推論してくれるため本来は指定しなくても大丈夫です。このコードを見せられてもなんの違和感も感じないと思いますが、Listの各要素の型はAnimalなのに、DogやCatを入れても問題ないのはなぜでしょうか？それは、Listの型が共変の型パラメータになっているためです。共変の型パラメータは<code>class Hoge[+T]()</code>と定義され、UがTのサブ型である場合、Hoge[U]もHoge[T]のサブ型と判断されます。これにより、たとえ厳密に同じ型でなくても、Listの要素として追加できるようになり柔軟性が増します。 注意点として、共変を安全に定義できるのはイミュータブルなオブジェクトのみです。まず、配列は参照型なので以下のような挙動になるのはおわかりかと思います<pre><code>val ary = Array(1)
val ary2 = ary
ary2(0) = 2
println(ary(0)) #=&gt; 2</code></pre> 次に、以下のコードを見てください。<pre><code>@main def main() =
 val dogs = Array(Dog())
 val animals: Array[Animal] = dogs // コンパイルエラー
 animals(0) = Cat()
 dogs(0).run()
 
abstract class Animal:
 def cry(): Unit
 
class Dog extends Animal:
 override def cry(): Unit =
 println("bow wow!")
 
 def run(): Unit =
 println("running!")
 
class Cat extends Animal:
 override def cry(): Unit =
 println("meow")
 
 def walk(): Unit =
 println("walking")</code></pre> 実際にはmain関数の2行目でコンパイルエラーが起きますが、仮にArrayのパラメータが共変だったとすると以下のような不具合が発生します<ul><li>2行目でanimalsはArray[Animal]と定義されているので、dogsを入れることができます</li><li>同様に3行目でanimalsにCatを入れることも可能です</li><li>2行目でanimalsとdogsは同じオブジェクトを参照しているため、dogs(0)にはCatが入っています</li><li>4行目でdogs(0).run()を実行しようとしますが、dogs(0)の実態はCatなので、runメソッドが実装されておらず実行エラーになります</li></ul> ScalaではArrayは実際には共変ではなく非変として定義されています。非変の場合は厳密に同じ型でなければ互換性がないと判断されます。 他にも反変がありますがこちらは共変と全く逆で、UがTのサブ型である場合、Hoge[T]がHoge[U]のサブ型と判断されます。こちらは直感に反しますが、そのような定義に実用性はあるのでしょうか？ ・・・というわけで、次回に続きます

共変・非変について

変位指定アノテーションその１

Scalaの型についてまとめてみた（その１）

Entのスキーマファイルを元に生成したER図のリンクは以下のコマンドで作成できます。<pre><code>$ go run -mod=mod ariga.io/entviz ./path/to/ent/schema</code></pre> <img src="https://images.microcms-assets.io/assets/b30d7661c2694503832399a83cea2137/23a1dab6624c4261b481810da2825a45/image.png" alt="">

TL;DR

go mod init で確認用プロジェクトを初期化します。<pre><code>$ go mod init github.com/rotemtam/ent-blog-example</code></pre> 新しいプロジェクトが作成されたことを確認します。<pre><code>go: creating new go.mod: module github.com/rotemtam/ent-blog-example</code></pre>

1. go mod initで確認用プロジェクトを初期化する

Entを使用してアプリケーション・データ・モデルを作成するため、go get を使って取得しましょう。 <pre><code>$ go get -u entgo.io/ent@master</code></pre>

2. アプリケーション・データ・モデルを作成する

Ent CLI を使用して、このチュートリアルで扱う2種類のエンティティ（UserとPost）のモデルを初期化します。 <pre><code>$ go run -mod=mod entgo.io/ent/cmd/ent new User Post</code></pre>

3. Ent CLI を使用して２種類のエンティティのモデルを初期化する

./ent/schema 配下にあるpost.go と user.go にそれぞれ以下を追記します。 user.go<pre><code>// Fields of the User.&nbsp;&nbsp;
func (User) Fields() []ent.Field {&nbsp;&nbsp;
&nbsp;&nbsp;return []ent.Field{&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;field.String("name"),&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;field.String("email").
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Unique(),&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;field.Time("created_at").
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Default(time.Now),&nbsp;&nbsp;
&nbsp;&nbsp;}&nbsp;&nbsp;
}&nbsp;&nbsp;
&nbsp;&nbsp;
// Edges of the User.&nbsp;&nbsp;
func (User) Edges() []ent.Edge {&nbsp;&nbsp;
&nbsp;&nbsp;return []ent.Edge{&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;edge.To("posts", Post.Type),&nbsp;&nbsp;
&nbsp;&nbsp;}&nbsp;&nbsp;
}</code></pre> post.go<pre><code>// Fields of the Post. 
func (Post) Fields() []ent.Field { 
 return []ent.Field{ 
 field.String("title"), 
 field.Text("body"), 
 field.Time("created_at").
 Default(time.Now), 
 } 
} 
 
// Edges of the Post.
func (Post) Edges() []ent.Edge { 
 return []ent.Edge{ 
 edge.From("author", User.Type). 
 Unique(). 
 Ref("posts"), 
 } 
}</code></pre>

4. 生成されたschemaファイルに設定を追記する

以下のコマンドを実行し、ER図のリンクを生成してブラウザで確認します。<pre><code>$ go run -mod=mod ariga.io/entviz ./ent/schema</code></pre> 以下のようなページが開ければ完了です。<img src="https://images.microcms-assets.io/assets/b30d7661c2694503832399a83cea2137/c355cb8ee1b640ea973aa5f88f22d166/image.png" alt="">

5. コマンドを実行してER図のリンクを生成する

実際に使ってみた

schemaファイルさえ書いていればコマンド一つでER図が生成できるので非常に便利な機能でした。Entはコンスタントにこういった便利な機能のアップデートが行われているので、これからも定期的にリリースノートをチェックして追っていきたいと思います。

Go言語のフレームワークentにER図生成ツールが導入されたので使ってみた

こんな感じでホバーで型定義が確認できるところがいいですね。<img src="https://images.microcms-assets.io/assets/b30d7661c2694503832399a83cea2137/ce10752003984656b09e5d543258de21/%E3%82%B9%E3%82%AF%E3%83%AA%E3%83%BC%E3%83%B3%E3%82%B7%E3%83%A7%E3%83%83%E3%83%88%202024-01-04%2018.57.49.png" alt="">

type

次にinterface<img src="https://images.microcms-assets.io/assets/b30d7661c2694503832399a83cea2137/d4ed6b36ffdb4b4f9992d7f904359734/%E3%82%B9%E3%82%AF%E3%83%AA%E3%83%BC%E3%83%B3%E3%82%B7%E3%83%A7%E3%83%83%E3%83%88%202024-01-04%2018.57.28.png" alt="">こっちはホバーしても確認はできません。 ただし、interfaceは継承することができます。 継承(extends)<img src="https://images.microcms-assets.io/assets/b30d7661c2694503832399a83cea2137/cbea8ed2132d44c19529fbb68922f0f5/%E3%82%B9%E3%82%AF%E3%83%AA%E3%83%BC%E3%83%B3%E3%82%B7%E3%83%A7%E3%83%83%E3%83%88%202024-01-04%2019.03.03.png" alt="">typeでは型の継承はできないです。<img src="https://images.microcms-assets.io/assets/b30d7661c2694503832399a83cea2137/22aed711d8b24e0193836c2f071adf6d/%E3%82%B9%E3%82%AF%E3%83%AA%E3%83%BC%E3%83%B3%E3%82%B7%E3%83%A7%E3%83%83%E3%83%88%202024-01-04%2019.14.53.png" alt="">

interface

<img src="https://images.microcms-assets.io/assets/b30d7661c2694503832399a83cea2137/3e7f34b67601449482dc74dfb4a60c4a/%E3%82%B9%E3%82%AF%E3%83%AA%E3%83%BC%E3%83%B3%E3%82%B7%E3%83%A7%E3%83%83%E3%83%88%202024-01-04%2019.09.53.png" alt="">labelを取り除いた型定義になりました。こちらはinterface→typeでの定義が可能です。

Omit

<pre><code>interface Hoge {
 className?: string;
 label: string;
 onClick?: () =&gt; void;
};

// 複数指定するときは|を使用
type Huga = Pick&lt;Hoge, "label" | "className"&gt;;</code></pre>結果<img src="https://images.microcms-assets.io/assets/b30d7661c2694503832399a83cea2137/b13533ee1e344288bb51581f4d0fc708/%E3%82%B9%E3%82%AF%E3%83%AA%E3%83%BC%E3%83%B3%E3%82%B7%E3%83%A7%E3%83%83%E3%83%88%202024-01-04%2019.24.34.png" alt="">

Pick

<img src="https://images.microcms-assets.io/assets/b30d7661c2694503832399a83cea2137/d51c0105ab9f4642a17f14b8d0bade29/%E3%82%B9%E3%82%AF%E3%83%AA%E3%83%BC%E3%83%B3%E3%82%B7%E3%83%A7%E3%83%83%E3%83%88%202024-01-04%2019.20.34.png" alt="">stringかnumberか判断してくれます。

型宣言の条件分岐

?がついている型は宣言が任意ですが、指定がない場合の初期値を設定することができます。<pre><code>interface Hoge {
 className?: string;
};</code></pre>宣言<pre><code>Page.defaultProps = {
 className: null,
};</code></pre>

defaultProps

おまけ

typeScriptが使われる現場がかなり多いと思いますので不要な型宣言を増やさないように実装していきたいですね。

typeScriptのtypeとinterfaceの違い

公式<a href="https://github.com/pmndrs/zustand" target="_blank" rel="noopener noreferrer">https://github.com/pmndrs/zustand</a> 軽量なグローバル管理ライブラリです。Reduxを使用するとめんどくさいので業務でも個人開発でも使用してます。<pre><code>import { create } from 'zustand'

const useBearStore = create((set) =&gt; ({
 bears: 0,
 increasePopulation: () =&gt; set((state) =&gt; ({ bears: state.bears + 1 })),
 removeAllBears: () =&gt; set({ bears: 0 }),
}))</code></pre> <pre><code>function BearCounter() {
 const bears = useBearStore((state) =&gt; state.bears)
 return &lt;h1&gt;{bears} around here ...&lt;/h1&gt;
}

function Controls() {
 const increasePopulation = useBearStore((state) =&gt; state.increasePopulation)
 return &lt;button onClick={increasePopulation}&gt;one up&lt;/button&gt;
}</code></pre>

zustand

公式<a href="https://storybook.js.org/" target="_blank" rel="noopener noreferrer">https://storybook.js.org/</a> コンポーネントごとに単体テストが簡単にできるようになります。個々にstorybookのファイルを作成しないといけないので業務ではリソース次第で採用するといいと思います。 こんな感じのページが生成されます。<img src="https://images.microcms-assets.io/assets/b30d7661c2694503832399a83cea2137/39f5d58dc5504b50ae02649bf20f3281/mdx-example.png" alt="">

Storybook

classに直接書いていくとどうしても可読性が下がってしまうので必要な時に使用するといいと思います。(tailwindには@applyというオプションもあるのですが、ホバーでスタイル確認できないので 簡単なのですぐ使えると思います。<pre><code>import { tw } from "tw-tag";

// ()で囲むとホバー時にスタイルが確認できる。
const error_message = tw(`text-red-600 text-sm mb-2`);

&lt;p className={`${error_message} mx-auto`} style={{ whiteSpace: "pre-wrap" }}&gt;
	{errorMessage}
&lt;/p&gt;</code></pre>

tw-tag

いかがでしたでしょうか？ 他にも便利なライブラリがたくさんありますので、探してみるのもいいかもしれませんね。

【React】使ってみていい感じだったライブラリ

暗号化<img src="https://images.microcms-assets.io/assets/b30d7661c2694503832399a83cea2137/38a3e35a0c8d4d679607204542419512/%E3%82%B9%E3%82%AF%E3%83%AA%E3%83%BC%E3%83%B3%E3%82%B7%E3%83%A7%E3%83%83%E3%83%88%202024-01-04%2016.15.54.png" alt="">結果<img src="https://images.microcms-assets.io/assets/b30d7661c2694503832399a83cea2137/3fdc245d6ba84317961702a32887d948/%E3%82%B9%E3%82%AF%E3%83%AA%E3%83%BC%E3%83%B3%E3%82%B7%E3%83%A7%E3%83%83%E3%83%88%202024-01-04%2016.17.37.png" alt="">Wklv lv d whvw phvvdjh iru wkh Fdhvdu flskhu.これが暗号ですね。 これをリフレクターというもので復号化してみます。 リフレクター<img src="https://images.microcms-assets.io/assets/b30d7661c2694503832399a83cea2137/d4ce4402851047248d03eb70dc3584c7/%E3%82%B9%E3%82%AF%E3%83%AA%E3%83%BC%E3%83%B3%E3%82%B7%E3%83%A7%E3%83%83%E3%83%88%202024-01-04%2016.21.28.png" alt="">結果<img src="https://images.microcms-assets.io/assets/b30d7661c2694503832399a83cea2137/60d90a5a726748a2abdf38d560dc6327/%E3%82%B9%E3%82%AF%E3%83%AA%E3%83%BC%E3%83%B3%E3%82%B7%E3%83%A7%E3%83%83%E3%83%88%202024-01-04%2016.22.06.png" alt=""> ただ反転してるだけなんですけどね

実装

ネットが普及してる今のご時世ではセキュリティ対策はエンジニアにとっても大事なものとなってますね。 イミテーションゲームという映画ではこれより遥かに複雑なエニグマという暗号が使われてたり(初めてコンピュータで暗号を復号化されたのもエニグマだったような.... 興味のある方は暗号の歴史から追うのも面白いかと思います！

BuildersIO produced by YOKU