趣味で自分用のアプリケーションの実装であれば、前回の実装で十分というよりオーバースペックくらいだと思います。しかし、実際の業務システムであれば、異常系も考慮しなければいけません。処理の途中で異常終了するケースを考えてみます。<pre><code> 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) // ①
 val users = userRepsitory.getByIds(organizerId :: participantIds)
 publisher.publish(event) // ②</code></pre> <code>reserve</code>メソッド全体にDBトランザクションが張られているとします。つまり、<code>reserve</code>メソッドのどこかの処理で異常終了した場合はロールバックします。<ul><li>①で落ちた場合<ul><li>DBはロールバックします。ミーティング作成通知（及び通知予約）も送られていないため、処理全体としてなかったことと同じであり、整合性は保たれています。</li></ul></li><li>②で落ちた場合<ul><li>ミーティング作成通知（及び通知予約）の途中で落ちるため、何人かにはミーティングが作成された（もしくは開始・終了した）旨の通知が届くことでしょう。しかしDBはロールバックするため、実際にはミーティングは作成されておらず、整合性が保たれなくなってしまいます。</li></ul></li></ul>この問題を回避するためにはどうしたらいいでしょうか。

問題点

ミーティング作成と、作成後の通知が同じトランザクション内で処理してしまっていることが問題と言えます。なのでトランザクションを切り離したいです。つまり、通知処理はあくまでミーティング作成のコミットが成功してから走るようにしたいです。また、後続のトランザクションが失敗した場合、後続のみ再実行できるようにしたいので、同じアプリケーションサービス内で複数トランザクションを実行するのではなく、<code>reserve</code>メソッド内ではあくまでミーティング作成のトランザクションのみに責任を持ち、通知は別プロセスで（何らかの方法で）行うようにします。 通知は別プロセスで行うとして、ミーティングが作成されたという事実を知る必要があります。ドメインイベントを生成するようにしたので、それ自体をミーティングオブジェクトと同じDBに保存してしまいましょう。そうすれば同じDBトランザクションで整合性を担保できます。

対応方針

ミーティングオブジェクトをDBに保存することを決めたので、テーブル設計を考えます。各イベントごとにテーブルを用意してもいいのですが、コストがかかるためすべてのイベントを同じテーブルに保存する方向で考えます。以下のようなカラム構成でどうでしょうか。<ul><li><code>id</code> (string): イベントID(UUID)</li><li><code>type</code> (string): イベント種別（例："MeetingCreated", "MeetingDeleted"）</li><li><code>occuredOn</code> (datetime): イベント発生日時</li><li><code>details</code> (json): イベント詳細（例：{"meetingId": 1, "organizerId": 1, ...}）</li><li><code>processed_at</code> (datetime): イベント処理完了日時</li><li><code>created_at</code> (timestamp): 作成日時</li><li><code>updated_at</code> (timestamp): 更新日時</li></ul>イベントを一意に指定するIDがあったほうが何かと便利だと思うので、<code>id</code>を付与しました。イベント種別は<code>type</code>で識別します。またイベントごとに異なるカラムについては<code>details</code>で吸収できるようにしました。別プロセスでイベントを処理する際にすでに処理済みなのかを知る必要があるため、<code>processed_at</code>を付与しました。 次に実装です。

テーブル設計

イベント作成と通知が別プロセスということになったので、まずはイベント作成の方の実装からしてみます。<pre><code>@@ -100,6 +100,10 @@ trait MeetingRepository:
&nbsp;trait DomainEvent:
&nbsp; &nbsp;val occuredOn = LocalDateTime.now()
&nbsp;
+trait DomainEventRepository:
+&nbsp; def save[T &lt;: DomainEvent](event: T): Unit =
+&nbsp; &nbsp; println(event)
+
&nbsp;class MeetingCreated(
&nbsp; &nbsp; &nbsp;val meetingId: MeetingId,
&nbsp; &nbsp; &nbsp;val organizerId: UserId,
@@ -171,13 +175,9 @@ class EmailReserveService(
&nbsp;
&nbsp;class MeetingService(
&nbsp; &nbsp; &nbsp;meetingRepository: MeetingRepository,
-&nbsp; &nbsp; userRepsitory: UserRepository
+&nbsp; &nbsp; userRepsitory: UserRepository,
+&nbsp; &nbsp; eventRepository: DomainEventRepository
&nbsp;):
-&nbsp; private val publisher = DomainEventPublisher(
-&nbsp; &nbsp; EmailSendService(userRepsitory, EmailSender()),
-&nbsp; &nbsp; EmailReserveService(userRepsitory, EmailReserver())
-&nbsp; )
-
&nbsp; &nbsp;def reserve(
&nbsp; &nbsp; &nbsp; &nbsp;organizerId: UserId,
&nbsp; &nbsp; &nbsp; &nbsp;participantIds: List[UserId],
@@ -196,8 +196,7 @@ class MeetingService(
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;detail
&nbsp; &nbsp; &nbsp; &nbsp;)
&nbsp; &nbsp; &nbsp;meetingRepository.save(meeting)
-&nbsp; &nbsp; publisher.publish(event)
+&nbsp; &nbsp; eventRepository.save(event)
&nbsp;
&nbsp; &nbsp;def reserveWithFollowed(
&nbsp; &nbsp; &nbsp; &nbsp;organizerId: UserId,
@@ -218,13 +217,10 @@ class MeetingService(
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;detail
&nbsp; &nbsp; &nbsp; &nbsp;)
&nbsp; &nbsp; &nbsp;meetingRepository.save(meeting)
-&nbsp; &nbsp; publisher.publish(event)
+&nbsp; &nbsp; eventRepository.save(event)
&nbsp;
&nbsp; &nbsp;def remove(meetingId: MeetingId): Unit =
&nbsp; &nbsp; &nbsp;val meeting = meetingRepository.get(meetingId)
&nbsp; &nbsp; &nbsp;val event = meeting.delete
&nbsp; &nbsp; &nbsp;meetingRepository.delete(meetingId, event)
-&nbsp; &nbsp; publisher.publish(event)
+&nbsp; &nbsp; eventRepository.save(event)</code></pre> <code>publisher.publish</code>の代わりに<code>eventRepository.save</code>を呼ぶようになっただけです。簡単ですね。 では続いて、通知処理です。<pre><code>@@ -99,11 +99,28 @@ trait MeetingRepository:
&nbsp;
&nbsp;trait DomainEvent:
&nbsp; &nbsp;val occuredOn = LocalDateTime.now()
+&nbsp; var processedAt: Option[LocalDateTime] = None
+
+&nbsp; def processCompleted(): Unit =
+&nbsp; &nbsp; processedAt = Some(LocalDateTime.now())
&nbsp;
&nbsp;trait DomainEventRepository:
&nbsp; &nbsp;def save[T &lt;: DomainEvent](event: T): Unit =
&nbsp; &nbsp; &nbsp;println(event)
&nbsp;
+&nbsp; def getUnprocessed: List[DomainEvent] =
+&nbsp; &nbsp; List(
+&nbsp; &nbsp; &nbsp; MeetingCreated(
+&nbsp; &nbsp; &nbsp; &nbsp; MeetingId(1),
+&nbsp; &nbsp; &nbsp; &nbsp; UserId(1),
+&nbsp; &nbsp; &nbsp; &nbsp; List(UserId(2), UserId(3)),
+&nbsp; &nbsp; &nbsp; &nbsp; title = "ミーティング1",
+&nbsp; &nbsp; &nbsp; &nbsp; detail = "全員集合",
+&nbsp; &nbsp; &nbsp; &nbsp; startAt = LocalDateTime.now(),
+&nbsp; &nbsp; &nbsp; &nbsp; endAt = LocalDateTime.now()
+&nbsp; &nbsp; &nbsp; )
+&nbsp; &nbsp; )
+
&nbsp;class MeetingCreated(
&nbsp; &nbsp; &nbsp;val meetingId: MeetingId,
&nbsp; &nbsp; &nbsp;val organizerId: UserId,
@@ -173,6 +190,24 @@ class EmailReserveService(
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;reserver.reserve(u.email, e.title, e.detail, e.endAt)
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp;})
&nbsp;
+class EventProcessService(
+&nbsp; &nbsp; eventRepository: DomainEventRepository,
+&nbsp; &nbsp; userRepsitory: UserRepository
+):
+&nbsp; val publisher = DomainEventPublisher(
+&nbsp; &nbsp; EmailSendService(userRepsitory, EmailSender()),
+&nbsp; &nbsp; EmailReserveService(userRepsitory, EmailReserver())
+&nbsp; )
+
+&nbsp; def process(): Unit =
+&nbsp; &nbsp; val events = eventRepository.getUnprocessed
+&nbsp; &nbsp; events.foreach(processEvent)
+
+&nbsp; private def processEvent(event: DomainEvent): Unit =
+&nbsp; &nbsp; publisher.publish(event)
+&nbsp; &nbsp; event.processCompleted()
+&nbsp; &nbsp; eventRepository.save(event)
+
&nbsp;class MeetingService(
&nbsp; &nbsp; &nbsp;meetingRepository: MeetingRepository,
&nbsp; &nbsp; &nbsp;userRepsitory: UserRepository,</code></pre> 未処理のイベントリストを取得し、それぞれのイベントについて<code>publish</code>し、完了時間を記録してからDBに保存します。各イベント発生時の処理と別プロセスで行うという大幅な仕様変更ですが、実装的にはそれほど大きく変わっていません。（別プロセスの具体的な方法については未実装ですが・・・）

実装修正

ところで、今の実装でも、イベントの処理途中で落ちた場合のことを考えると、通知などは行われますが完了時間の記録は行われないため、同じイベントが再度発行されてしまいます。これはDBトランザクションでない以上、どうしようもないと思います。ただし、テーブル設計でイベントIDを付与しているため、同じイベントが発行されてもリモートのサブスクライバ側で処理済みの場合は破棄することが可能です。イベント発行の際の冪等性は留意が必要なテーマだと思います。

重複排除

今回は、異常系について考慮する中で、イベントの保存と発行を別プロセスで行うという仕様変更を行いました。なお、「何らかの方法で」別プロセスで行うと言いましたが、それを実現する具体的な技術論については自分がまだ勉強不足のため、別の機会に譲ろうと思います。あと、実はまだ一度も実行していないので、そろそろちゃんと動かしてみようと思います。それについても次回以降に回したいと思います。 ひたすらリファクタを繰り返してきましたが、今回でかなり理想的な形に近づいたと思います。現時点でのコード全容を貼っておきます。<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()
 var processedAt: Option[LocalDateTime] = None

 def processCompleted(): Unit =
 processedAt = Some(LocalDateTime.now())

trait DomainEventRepository:
 def save[T &lt;: DomainEvent](event: T): Unit =
 println(event)

 def getUnprocessed: List[DomainEvent] =
 List(
 MeetingCreated(
 MeetingId(1),
 UserId(1),
 List(UserId(2), UserId(3)),
 title = "ミーティング1",
 detail = "全員集合",
 startAt = LocalDateTime.now(),
 endAt = 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 EventProcessService(
 eventRepository: DomainEventRepository,
 userRepsitory: UserRepository
):
 val publisher = DomainEventPublisher(
 EmailSendService(userRepsitory, EmailSender()),
 EmailReserveService(userRepsitory, EmailReserver())
 )

 def process(): Unit =
 val events = eventRepository.getUnprocessed
 events.foreach(processEvent)

 private def processEvent(event: DomainEvent): Unit =
 publisher.publish(event)
 event.processCompleted()
 eventRepository.save(event)

class MeetingService(
 meetingRepository: MeetingRepository,
 userRepsitory: UserRepository,
 eventRepository: DomainEventRepository
):
 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)
 eventRepository.save(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)
 eventRepository.save(event)

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

まとめ

異常系を考える

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

アプリケーションの中で発生するイベントは、ドメインオブジェクトに対する何らかのアクションに起因すると考えられるため、イベント自体はアクションに紐付けたいです。現状はというと、アプリケーションサービス内でアクションの「直後に」発生する形になっています。<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]のサブ型と判断されます。こちらは直感に反しますが、そのような定義に実用性はあるのでしょうか？ ・・・というわけで、次回に続きます

BuildersIO produced by YOKU

#Scala の記事一覧

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

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

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

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

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

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

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

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

【AWS】boto3でDynamoDBを操作するときによく使うメソッド

Auth0環境を構築して自作のAPIと連携してみた

単体テストのベストプラクティス