AIによるイベントストーミング図からのコード生成 / AI-powered code generation from Event Storming diagrams

Transcript

1. "*
   Y
   &4 "*ʹΑΔΠϕϯτετʔϛϯάਤ͔Βͷίʔυੜ੒ OST 
   ੒੉Ҹએ
3. 3 ։࠵ʂ ͓ΊͰͱ͏͍͟͝·͢ʂʂ
4. 4 ͱ͜ΖͰ
5. 5 ͜ͷ޿ࠂݟ·ͨ͠ʁ
6. 6 ͜ͷ޿ࠂݟ·ͨ͠ʁ ࣮͸$234 &4͕͜͜ʹજΜͰ͍ΔͷͰ͢ʂʂ
7. 7 9ͷ޿ࠂϚωʔδϟʔ ΠϕϯτιʔγϯάͬΆ͍
8. 8 9ͷ޿ࠂϚωʔδϟʔ $234
9. 9 ΍ͬͺ9ຽ͸$234 &4ͩΑͳʂʂ
10. ϓϩϙʔβϧ
11. Πϕϯτετʔϛϯά ਤͷ࣮૷ "*࣌୅ͷίʔσΟϯά "*ʹΑΔΠϕϯτετʔϛϯάਤ͔Βͷίʔυੜ੒
12. Πϕϯτετʔϛϯά ਤͷ࣮૷ "*࣌୅ͷίʔσΟϯά "*ʹΑΔΠϕϯτετʔϛϯάਤ͔Βͷίʔυੜ੒
13. ̏ͭͷϑΣʔζ l ϏοάϐΫνϟʔ l શମ૾Λ೺Ѳ͢Δ l ϏδωεϓϩηεϞσϦϯά l ղ૾౓Λ্͛Δ l ιϑτ΢ΣΞγεςϜϞσϦϯά l ࣮૷ʹ޲͚ͨઃܭΛ͢Δ
14. ϏοάϐΫνϟʔ
15. ϏδωεϓϩηεϞσϦϯά
16. ιϑτ΢ΣΞγεςϜϞσϦϯά
17.  ̍ɽΠϕϯτΛ෇ᝦʹॻ͖ग़͢ ̎ɽΠϕϯτΛฒͼସ͑Δ ̏ɽίϚϯυ΍ू໿ɾ֎෦γεςϜΛ௥Ճ͢Δ ̐ɽϙϦγʔΛ௥Ճ͢Δ ̑ɽશମͷ֬ೝͱσΟεΧογϣϯ ͬ͘͟ΓϏδωεϓϩηεϞσϦϯά·Ͱͷखॱ
18.  ϏϧσΟϯάϒϩοΫ
19. 19 ΞΫλʔ ίϚϯυʢޙड़ʣΛ ࣮ߦ͢Δओମ ΞΫλʔ͸ ίϚϯυͷ࣮ߦʹ ؔ͢Δ൑அ΋͢Δ
20. 20 ίϚϯυ ԿΒ͔ͷΞΫγϣϯΛ ࣮ߦ͢Δҙਤ΍ཁٻ
21. 21 ू໿ ίϚϯυΛॲཧ͢Δ ΦϒδΣΫτ
22. 22 Πϕϯτ Ϗδωε্Ͱൃੜͨ͠ ॏཁͳग़དྷࣄ΍ࣄ࣮
23. 23 ϦʔυϞσϧ σʔλͷಡΈऔΓʹ ࠷దԽ͞Εͨ σʔλߏ଄΍Ϗϡʔ
24. 24 ϙϦγʔ ࣗಈԽ͞Εͨ ൑அϩδοΫ ৚݅Λ͍ΕΔͷ͸ OSTྲྀ
25. 25 ϙϦγʔ ۭཝͷϙϦγʔ͸ ʮඞͣʯͷҙຯ ˞ϙϦγʔʹ໊લΛ͚ͭͯ΋ ͋·Γ໾ʹཱͨͳ͍ͷͰ ۭཝʹ͢Δͷ͸ OST ࣜ
26. 26 ֎෦γεςϜ ର৅γεςϜͷ ڥք֎ʹ͋ΔγεςϜ
27. 27 දهͷҙຯɿෳ਺ͷΠϕϯτ ݁Ռͷ෼ذ΍ ෳ਺ͷग़དྷࣄ͕ฒྻʹى͖Δ ͜ͱΛද͢
28. 28 • ෇ᝦ͸ಛఆͷ෇ᝦ͔Β͔͠ܨ͛ΒΕͳ͍ ϧʔϧ ࠨਤͷ໼ҹͷ ܨ͕ΓํҎ֎͸ /(
29. Πϕϯτετʔϛϯά ਤͷ࣮૷ "*࣌୅ͷίʔσΟϯά "*ʹΑΔΠϕϯτετʔϛϯάਤ͔Βͷίʔυੜ੒
30. 30 ΞΫλʔ ΞΫλʔͱίϚϯυ͸ ͍͍ͨͯ $6%
    ͷ "1*
    ͱͳΔ ʢ8FCͷ৔߹ʣ
31.  @Operation(summary = "Creating a new doc.") @PostMapping @ResponseStatus(HttpStatus.CREATED) public DocsPostResponse post(@Validated @RequestBody DocsPostRequest request) { var command = new DocCreate(new DocId(), request.body()); DocId docId = commandGateway.sendAndWait(command); return new DocsPostResponse(docId.value()); }
32.  public record DocCreate(DocId docId, String body) implements DocCommand { }
33. 33 ू໿ ίϚϯυΛॲཧ͢Δ ΦϒδΣΫτΛ ఆٛ͢Δ
34.  @Aggregate public class DocAggregate extends AbstractAggregate<Doc, DocId, DocEvent> { @Override protected DocId getAggregateRootId(Doc aggregate) { if (aggregate != null) { return aggregate.docId(); } else { return null; } } public DocAggregate() { } @CommandHandler public DocAggregate(DocCreate command) { var event = Doc.create(command.docId(), command.body()); apply(event); } @CommandHandler public void handle(DocUpdate command) { apply(it -> it.update(command.body())); } }
35.  public record Doc( DocId docId, String body ) implements EventDrivenAggregateRoot<DocEvent> { public static DocCreated create(DocId docId, String body) { return new DocCreated(docId, body); } public static Doc applyEvent(DocCreated event) { return new Doc(event.docId(), event.body()); } public DocUpdated update(String body) { return new DocUpdated(docId, body); } @Override public EventDrivenAggregateRoot<DocEvent> applyEvent(DocEvent event) { return switch (event) { case DocCreated docCreated -> new Doc(docCreated.docId(), docCreated.body()); case DocUpdated docUpdated -> new Doc(this.docId, docUpdated.body()); default -> throw new IllegalStateException("Unexpected value: " + event); }; } }
36. 36 Πϕϯτ ΠϕϯτΛ ΦϒδΣΫτͰ ఆٛ͢Δ
37.  public record DocCreated( DocId docId, String body ) implements DocEvent { }
38. 38 ϦʔυϞσϧ 8FCͰσʔλͱͯ͠ ༻ҙ͢ΔͳΒ (FUͷ8FC
    "1*ͱ σʔλऔಘॲཧ
39.  @GetMapping("{docsId}") public DocsGetResponse get(@PathVariable UUID docsId) throws ExecutionException, InterruptedException { var query = new GetDoc(docsId); var result = queryGateway.query(query, GetDocResult.class).get(); var docDataModel = result.docDataModel().orElseThrow(NotFoundException::new); return new DocsGetResponse(docsId, docDataModel.getBody(), docDataModel.getEffectiveCount()); }
40.  @Service public record DocQueryService(QueryGateway queryGateway, DocRepository repository) { @QueryHandler public GetDocResult handle(GetDoc query) { return new GetDocResult(repository.findById(query.docId().toString())); } }
41.  @Repository public interface DocRepository extends JpaRepository<DocDataModel, String> { }
42.  @Component public class DocProjection { private final DocRepository repository; public DocProjection(DocRepository repository) { this.repository = repository; } @EventHandler public void on(DocCreated event) { var doc = new DocDataModel(); doc.setDocId(event.docId().asString()); doc.setBody(event.body()); repository.save(doc); } @EventHandler public void on(DocUpdated event) { var doc = repository.findById(event.docId().asString()).orElseThrow(); doc.setBody(event.body()); repository.save(doc); } : }
43. 43 ϙϦγʔ ΠϕϯτϋϯυϥʔͰ ༻ҙ͞ΕΔ
44.  @EventHandler public void on(AlbumCreated event) { if (!event.photos.isEmpty()) { commandGateway.send(new AddPhotos(event.albumId, event.photos)) } }
45. 45 ֎෦γεςϜ ίϚϯυϋϯυϥʔ ʴ ෗ഊ๷ࢭ૚
46.  @CommandHandler public void handle(MakePayment command) { var result = paymentService.makePayment(command.accountId(), command.amount()); if (result.isSuccessful()) { eventGateway.publish( new PaymentSucceeded(command.paymentId(), result.getTransactionId())); } else { eventGateway.publish( new PaymentFailed(command.paymentId(), result.getFailureReason())); } }
47. Πϕϯτετʔϛϯά ਤͷ࣮૷ "*࣌୅ͷίʔσΟϯά "*ʹΑΔΠϕϯτετʔϛϯάਤ͔Βͷίʔυੜ੒
48. 48 "*࢖ͬͯͳౕ͍͍Δʁ
49. 49 ͍Ͷ͐Αͳ͊ʂʂʁ
50.  "*ͷಛੑʢ͍·͞Β͕ͩʜʜʣ
51. 51 ίϯςΩετ΢Οϯυ΢໰୊ $POUFYU
    3PU -PTU
    JO
    UIF
    .JEEMF ສτʔΫϯೖΔ ʺ ສτʔΫϯΛཧղ͢Δ
52. 52 l ܇࿅σʔλʹͳ͍৘ใΛٻΊΒΕͨͱ͖ l ࠷৽"1* l ࣾ಺ن໿ l ͍͋·͍ͳࢦࣔΛड͚ͨͱ͖ l ʮ͍͍ײ͡ʹͯ͠ʯ l จ຺͕ෆ଍͍ͯ͠Δͱ͖ l ෳ਺ͷղऍ͕Մೳͳ࣭໰ ϋϧγωʔγϣϯΛى͜͠΍͍͢ঢ়گ
53.  ͓હཱͯɿίϯςΩετ΢Οϯυ΢ฤ
54. 54 ߏ଄Խ͸͍͍ͧʂ ߏ଄Ͱऔࣺબ୒͕Ͱ͖Δ
55. 55 7FSUJDBM
    4MJDF ਫฏϨΠϠʔ͸ ෳ਺σΟϨΫτϦΛ ԣஅ͠΍͍͢ͷͰ ਨ௚ʹ෼ׂ͢Δͷ͕ ΑΓ(PPE
56.  ͓હཱͯɿϋϧγωʔγϣϯฤ
57. 57 ৘ใΛ౉͢ • ܇࿅σʔλʹͳ͍΋ͷΛҾ͖౉͢ #### 2.1. Set-Based Consistency Validationύλʔϯʹ͓͚ΔίϚϯυ෼཭ ू໿࡞੒લʹ֎෦σʔλʢϦϙδτϦ౳ʣΛࢀরͨ͠ݕূ͕ඞཁͳ৔߹ɺίϚϯυΛ2ͭʹ෼཭͢Δɿ **֎෦ެ։ίϚϯυʢRequest* Commandʣ**: - **໨త**: ΫϥΠΞϯτ͔ΒͷϦΫΤετΛड͚औΓɺݕূΛ࣮ࢪ - **໋໊نଇ**: `Request{໊ࢺ}Command` (ྫ: `RequestReservationSlotCommand`) - **Ξϊςʔγϣϯ**: `@RoutingKey` - Application ServiceʹϧʔςΟϯά - **ϋϯυϥʔ**: Application Serviceʢ`@Service` + `@CommandHandler`ʣͰॲཧ - **ྫ**: ```java public record RequestReservationSlotCommand( @RoutingKey String slotId, String facilityId // ... ͦͷଞͷϑΟʔϧυ ) {} ```
58. 58 બ୒ࢶΛ௵͢ ʮΠϕϯτΛ࡞ͬͯʯ͚ͩͩͱ ໋໊͸ 0SEFS$SFBUFE
    0SEFS$SFBUFE&WFOU
    $SFBUFE0SEFS Ͳ͜ʹஔ͘ʁ FWFOUT
    EPNBJOFWFOUT
    BQJ • ͍͋·͍ͳࢦࣔΛݻఆ͢Δ - **໋໊نଇ**: `{໊ࢺ}{ಈࢺաڈ෼ࢺ}Event` (ྫ: `FacilityRegisteredEvent`, `ReservationCancelledEvent`) - **ྫ**: ʮอҭࢪઃ͕ొ࿥͞Εͨʯ→ `FacilityRegisteredEvent` - **ύοέʔδ**: `com.example.eventsourcing.{context}.api.events`
59. 59 ϧʔϧΛఆٛ • จ຺͕ෆ଍͍ͯ͠Δͱ͜ΖΛϧʔϧͰΧόʔ ### 1. ΠϕϯτʢΦϨϯδ৭ͷ෇ᝦʣ - **ఆٛ**: γεςϜͰൃੜͨ͠ࣄ࣮ΛաڈܗͰදݱ - **࣮૷**: ֤Bounded Contextͷ`api/events`ύοέʔδʹrecordͱͯ͠ఆٛ - **഑ஔཧ༝**: ଞͷBounded Context΍ϚΠΫϩαʔϏε͔ΒࢀরՄೳͳެ։API ### σΟϨΫτϦߏ଄ ``` src/main/java/com/example/eventsourcing/ ├── {bounded-context}/ # ྫ: facility, parent │ ├── api/ │ │ └── events/ # ⭐ ެ։ΠϕϯτʢଞαʔϏε͔ΒࢀরՄೳʣ │ │ └── {Context}Events.java │ ├── adapter/ │ │ ├── inbound/ # Inbound Adaptersʢೖྗʣ
60.  ͕Μ͹Γ͗͢ͳ͍
61. 61 • ϓϩϯϓτ࡞Γ͸ूதͰ͸ͳ͘஝ੵ ◦ ׬ᘳͳϓϩϯϓτΛ࡞Ζ͏ͱ͠ͳ͍ ◦ ࢖͍ͳ͕ΒҭͯΔ • มߋͷλΠϛϯά͸ࢦࣔͷத ◦ ࢦࣔΛग़͢ ◦ ˠҙʹ͙ͦΘͳ͍ ◦ ˠमਖ਼Λ఻͑Δ ◦ ˠͦͷྲྀΕͰNEϑΝΠϧͷमਖ਼΋ࢦࣔ ϓϩϯϓτ͸࡞ΒͤΔ΋ͷ
62. "*ʹΑΔύϥμΠϜγϑτ ਤ͕ίʔυʹ ͳΔʂ @Service public class DocumentApplicationService { private final DocumentRepository documentRepository; public DocumentApplicationService(DocumentRepository documentRepository) { this.documentRepository = documentRepository; }
63.  ΍ͬͯΈΑ͏ʂ
65. 65 Profile nrs（成瀬 允宣） @nrslib プログラマ 趣味：カンファレンス講演 学生支援 小学校支援 写真