feat: some user operations added

Author: =

src/main/kotlin/com/example/service/DatabaseModule.kt

@@ -22,6 +22,7 @@ object DatabaseModule {
         }
     }
 
-    suspend fun <T> dbQuery(block: suspend () -> T): T =
+    suspend fun <T> dbQuery(block: suspend () -> T): Result<T> = runCatching {
         newSuspendedTransaction(Dispatchers.IO) { block() }
+    }
 }

src/main/kotlin/com/example/service/UserService.kt

@@ -5,10 +5,12 @@ import com.example.dto.UserLoginDto
 import com.example.dto.UserRegisterDto
 import com.example.dto.UserUpdateLocationDto
 import kotlinx.coroutines.flow.Flow
+import java.util.UUID
 
 interface UserService {
     suspend fun login(userLoginDto: UserLoginDto): Result<String>
     suspend fun register(userRegisterDto: UserRegisterDto): Result<Boolean>
-    fun getProfile(userId: Int): Flow<UserDto>
+    suspend fun getProfileFlow(userId: Int): Result<Flow<UserDto>>
+    suspend fun getProfile(userId: UUID): Result<UserDto>
     suspend fun updateUserLocation(userId: Int, userUpdateLocationDto: UserUpdateLocationDto): Result<Boolean>
-}
+}

src/main/kotlin/com/example/service/impl/UserServiceImpl.kt

@@ -8,28 +8,58 @@ import com.example.service.DatabaseModule.dbQuery
 import com.example.service.UserService
 import com.example.table.Users
 import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.asFlow
+import org.jetbrains.exposed.sql.ResultRow
 import org.jetbrains.exposed.sql.and
+import org.jetbrains.exposed.sql.insert
 import org.jetbrains.exposed.sql.select
+import java.util.UUID
 
-class UserServiceImpl: UserService {
+class UserServiceImpl : UserService {
     override suspend fun login(userLoginDto: UserLoginDto): Result<String> = dbQuery {
         val loginStatement = Users.select {
             Users.email eq userLoginDto.email and (Users.password eq userLoginDto.password)
         }
         val user = loginStatement.singleOrNull()
         if (user != null) {
-            Result.success("Login successful")
+            user[Users.userId].toString()
         } else {
-            Result.failure(Exception("Invalid email or password"))
+            throw Exception("Invalid email or password")
         }
     }
 
-    override suspend fun register(userRegisterDto: UserRegisterDto): Result<Boolean> {
-        TODO("Not yet implemented")
+    override suspend fun register(userRegisterDto: UserRegisterDto): Result<Boolean> = dbQuery {
+        val registerStatement = Users.select { Users.email eq userRegisterDto.email }
+        val user = registerStatement.singleOrNull()
+        if (user != null) {
+            throw Exception("Email already exists")
+        } else {
+            Users.insert {
+                it[fullName] = userRegisterDto.fullName
+                it[email] = userRegisterDto.email
+                it[password] = userRegisterDto.password
+            }
+            true
+        }
     }
 
-    override fun getProfile(userId: Int): Flow<UserDto> {
-        TODO("Not yet implemented")
+    override suspend fun getProfileFlow(userId: Int): Result<Flow<UserDto>> = dbQuery {
+        val user = Users.select { Users.id eq userId }
+        if (user.empty()) {
+            throw Exception("User not found")
+        } else {
+            val userFlow = user.map(::resultRowToUserDto).asFlow()
+            userFlow
+        }
+    }
+
+    override suspend fun getProfile(userId: UUID): Result<UserDto> = dbQuery {
+        val user = Users.select { Users.userId eq userId }
+        if (user.empty()) {
+            throw Exception("User not found")
+        } else {
+            resultRowToUserDto(user.single())
+        }
     }
 
     override suspend fun updateUserLocation(
@@ -38,6 +68,20 @@ class UserServiceImpl: UserService {
     ): Result<Boolean> {
         TODO("Not yet implemented")
     }
+
+    private fun resultRowToUserDto(row: ResultRow): UserDto = UserDto(
+        id = row[Users.id],
+        userId = row[Users.userId].toString(),
+        fullName = row[Users.fullName],
+        email = row[Users.email],
+        password = row[Users.password],
+        phoneNumber = row[Users.phoneNumber],
+        occupation = row[Users.occupation],
+        employer = row[Users.employer],
+        country = row[Users.country],
+        latitude = row[Users.latitude],
+        longitude = row[Users.longitude]
+    )
 }
 
 val userService: UserService = UserServiceImpl()