@@ -23,11 +23,9 @@ import { RoleName } from "~/utils/roleUtils";
2323import type { User } from "./user" ;
2424
2525export const insertEvent = async ( event : Omit < typeof gataEvent . $inferInsert , "createdBy" > & { createdBy : string } ) => {
26- return await db . transaction ( async ( tx ) => {
27- const [ { eventId } ] = await tx . insert ( gataEvent ) . values ( event ) . returning ( { eventId : gataEvent . id } ) ;
28- await tx . insert ( eventOrganizer ) . values ( { userId : event . createdBy , eventId } ) ;
29- return eventId ;
30- } ) ;
26+ const [ { eventId } ] = await db . insert ( gataEvent ) . values ( event ) . returning ( { eventId : gataEvent . id } ) ;
27+ await db . insert ( eventOrganizer ) . values ( { userId : event . createdBy , eventId } ) ;
28+ return eventId ;
3129} ;
3230
3331export const getUpCommingEvents = async ( loggedInUserId : string ) => {
@@ -142,11 +140,9 @@ type InsertPollVote = {
142140} ;
143141
144142export const insertPollVote = async ( { userId, pollId, options } : InsertPollVote ) => {
145- await db . transaction ( async ( tx ) => {
146- await tx . delete ( pollVote ) . where ( and ( eq ( pollVote . userId , userId ) , eq ( pollVote . pollId , pollId ) ) ) ;
147- if ( ! options . length ) return ;
148- await tx . insert ( pollVote ) . values ( options . map ( ( pollOptionId ) => ( { pollId, pollOptionId, userId } ) ) ) ;
149- } ) ;
143+ await db . delete ( pollVote ) . where ( and ( eq ( pollVote . userId , userId ) , eq ( pollVote . pollId , pollId ) ) ) ;
144+ if ( ! options . length ) return ;
145+ await db . insert ( pollVote ) . values ( options . map ( ( pollOptionId ) => ( { pollId, pollOptionId, userId } ) ) ) ;
150146} ;
151147
152148export const updatePoll = async ( pollId : number , values : Partial < typeof poll . $inferInsert > ) => {
@@ -158,29 +154,23 @@ export const deletePoll = async (pollId: number) => {
158154} ;
159155
160156export const insertNewPoll = async ( eventId : number , pollValues : typeof poll . $inferInsert , options : string [ ] ) => {
161- await db . transaction ( async ( tx ) => {
162- const [ { pollId } ] = await tx . insert ( poll ) . values ( pollValues ) . returning ( { pollId : poll . id } ) ;
163- await tx . insert ( eventPolls ) . values ( { pollId, eventId } ) ;
164- await tx . insert ( pollOption ) . values ( options . map ( ( textOption ) => ( { textOption, pollId } ) ) ) ;
165- } ) ;
157+ const [ { pollId } ] = await db . insert ( poll ) . values ( pollValues ) . returning ( { pollId : poll . id } ) ;
158+ await db . insert ( eventPolls ) . values ( { pollId, eventId } ) ;
159+ await db . insert ( pollOption ) . values ( options . map ( ( textOption ) => ( { textOption, pollId } ) ) ) ;
166160} ;
167161
168162export const insertPollOptions = async ( pollId : number , options : string [ ] ) => {
169163 await db . insert ( pollOption ) . values ( options . map ( ( textOption ) => ( { textOption, pollId } ) ) ) ;
170164} ;
171165
172166export const updateOrganizers = async ( eventId : number , organizers : string [ ] ) => {
173- await db . transaction ( async ( tx ) => {
174- await tx . delete ( eventOrganizer ) . where ( eq ( eventOrganizer . eventId , eventId ) ) ;
175- await tx . insert ( eventOrganizer ) . values ( organizers . map ( ( userId ) => ( { userId, eventId } ) ) ) ;
176- } ) ;
167+ await db . delete ( eventOrganizer ) . where ( eq ( eventOrganizer . eventId , eventId ) ) ;
168+ await db . insert ( eventOrganizer ) . values ( organizers . map ( ( userId ) => ( { userId, eventId } ) ) ) ;
177169} ;
178170
179171export const insertCloudinaryImage = async ( eventId : number , values : typeof cloudinaryImage . $inferInsert ) => {
180- return await db . transaction ( async ( tx ) => {
181- await tx . insert ( cloudinaryImage ) . values ( values ) ;
182- await tx . insert ( eventCloudinaryImages ) . values ( { eventId, cloudId : values . cloudId } ) ;
183- } ) ;
172+ await db . insert ( cloudinaryImage ) . values ( values ) ;
173+ await db . insert ( eventCloudinaryImages ) . values ( { eventId, cloudId : values . cloudId } ) ;
184174} ;
185175
186176export const getEventCloudinaryImages = async ( eventId : number ) => {
@@ -265,25 +255,18 @@ export const getEventMessages = async (eventId: number) => {
265255} ;
266256
267257export const insertEventMessage = async ( eventId : number , userId : string , message : string ) => {
268- return await db . transaction ( async ( tx ) => {
269- const [ { messageId } ] = await tx
270- . insert ( messages )
271- . values ( { userId, message } )
272- . returning ( { messageId : messages . id } ) ;
273- await tx . insert ( eventMessages ) . values ( { messageId, eventId } ) ;
274- return messageId ;
275- } ) ;
258+ const [ { messageId } ] = await db . insert ( messages ) . values ( { userId, message } ) . returning ( { messageId : messages . id } ) ;
259+ await db . insert ( eventMessages ) . values ( { messageId, eventId } ) ;
260+ return messageId ;
276261} ;
277262
278263export const insertEventMessageReply = async ( userId : string , messageId : number , reply : string ) => {
279- return await db . transaction ( async ( tx ) => {
280- const [ { replyId } ] = await tx
281- . insert ( messages )
282- . values ( { userId, message : reply } )
283- . returning ( { replyId : messages . id } ) ;
284- await tx . insert ( messageReplies ) . values ( { messageId, replyId } ) ;
285- return replyId ;
286- } ) ;
264+ const [ { replyId } ] = await db
265+ . insert ( messages )
266+ . values ( { userId, message : reply } )
267+ . returning ( { replyId : messages . id } ) ;
268+ await db . insert ( messageReplies ) . values ( { messageId, replyId } ) ;
269+ return replyId ;
287270} ;
288271
289272export const insertMessageLike = async ( userId : string , messageId : number , type : string ) => {
0 commit comments