Skip to content

Commit

Permalink
Added OpenTelemetry
Browse files Browse the repository at this point in the history
  • Loading branch information
A1240F3 committed Jul 5, 2023
1 parent d242804 commit cc0bb29
Show file tree
Hide file tree
Showing 2 changed files with 25 additions and 2 deletions.
5 changes: 3 additions & 2 deletions src/main/kotlin/net/phexpedition/user/UserApi.kt
Original file line number Diff line number Diff line change
Expand Up @@ -12,15 +12,16 @@ import jakarta.ws.rs.core.SecurityContext
@Path("/api/user")
@RequestScoped
@Produces(MediaType.APPLICATION_JSON)
class UserApi {
class UserApi(val userRepository: UserRepository) {

@Path("_me")
@GET
fun getSelf(@Context ctx: SecurityContext): Response {
println("---> getSelf")
val user = userFromSecurityContext(ctx)
println("---> user $user")
val ube = findByEMail("[email protected]")//user.email)
//val ube = findByEMail("[email protected]")//user.email)
val ube = userRepository.findUserByEmail("[email protected]")
println("---> ube $ube")
return Response.ok(ube).build()
}
Expand Down
22 changes: 22 additions & 0 deletions src/main/kotlin/net/phexpedition/user/UserRepository.kt
Original file line number Diff line number Diff line change
@@ -0,0 +1,22 @@
package net.phexpedition.user

import com.google.cloud.firestore.Firestore
import jakarta.enterprise.context.RequestScoped
import java.util.concurrent.TimeUnit

@RequestScoped
class UserRepository(val firestore: Firestore) {

fun findUserByEmail(email: String): User {
println("Finding user by eMail: $email")
val collection = firestore.collection("user")
val sn = collection.document(email).get().get(20, TimeUnit.SECONDS)
println("sn: ")
//val u = sn.toObject(User::class.java)
return User(
id = sn.get("id", String::class.java)!!,
email = sn.get("email", String::class.java)!!,
displayName = sn.get("displayName", String::class.java)!!
)
}
}

0 comments on commit cc0bb29

Please sign in to comment.