11import type { PrismaClient } from "@prisma/client" ;
2+ import type { Prisma } from "@prisma/client" ;
23import {
34 type GroupChatId ,
45 type GroupChatName ,
@@ -18,28 +19,30 @@ class GroupChatDao {
1819 administratorId : UserAccountId ,
1920 createdAt : Date ,
2021 ) {
21- return await this . prismaClient . $transaction ( async ( _prismaClient ) => {
22- await _prismaClient . groupChats . create ( {
23- data : {
24- id : aggregateId . asString ( ) ,
25- disabled : false ,
26- name : name . asString ( ) ,
27- ownerId : administratorId . asString ( ) ,
28- createdAt : createdAt ,
29- updatedAt : createdAt ,
30- } ,
31- } ) ;
32- await _prismaClient . members . create ( {
33- data : {
34- id : MemberId . generate ( ) . asString ( ) ,
35- groupChatId : aggregateId . asString ( ) ,
36- userAccountId : administratorId . asString ( ) ,
37- role : "administrator" ,
38- createdAt : createdAt ,
39- updatedAt : createdAt ,
40- } ,
41- } ) ;
42- } ) ;
22+ return await this . prismaClient . $transaction (
23+ async ( _prismaClient : Prisma . TransactionClient ) => {
24+ await _prismaClient . groupChats . create ( {
25+ data : {
26+ id : aggregateId . asString ( ) ,
27+ disabled : false ,
28+ name : name . asString ( ) ,
29+ ownerId : administratorId . asString ( ) ,
30+ createdAt : createdAt ,
31+ updatedAt : createdAt ,
32+ } ,
33+ } ) ;
34+ await _prismaClient . members . create ( {
35+ data : {
36+ id : MemberId . generate ( ) . asString ( ) ,
37+ groupChatId : aggregateId . asString ( ) ,
38+ userAccountId : administratorId . asString ( ) ,
39+ role : "administrator" ,
40+ createdAt : createdAt ,
41+ updatedAt : createdAt ,
42+ } ,
43+ } ) ;
44+ } ,
45+ ) ;
4346 }
4447
4548 async deleteGroupChat ( aggregateId : GroupChatId , createdAt : Date ) {
0 commit comments