crystal

cr1.cr

def isLoggedIn(context, repo)
  sessionId = context.session.string?("userId")
  if sessionId
    user = repo.findUserByUserId(sessionId)
    case user
    when DB::Success

      groupId = user.value["activeChannel"].as_h.fetch("groupId", "")
      channelId = user.value["activeChannel"].as_h.fetch("channelId", "")

      puts "logged on in groupId: #{groupId} and channelId: #{channelId}"

      CurrentUser.new(user.value["name"].to_s, user.value["email"].to_s,
                      ActiveChannel.new(groupId.to_s, channelId.to_s),
                      sessionId)
    else
      false
    end
  else
    false
  end
end

cr2.cr

def isLoggedIn(context, repo)
  sessionId = context.session.string?("userId")
  return false unless sessionId

  user = repo.findUserByUserId(sessionId)
  return false unless user.is_a? DB::Success
  
  groupId = user.value["activeChannel"].as_h.fetch("groupId", "")
  channelId = user.value["activeChannel"].as_h.fetch("channelId", "")

  puts "logged on in groupId: #{groupId} and channelId: #{channelId}"

  CurrentUser.new(user.value["name"].to_s, user.value["email"].to_s,
                  ActiveChannel.new(groupId.to_s, channelId.to_s),
                  sessionId)
end

sc.scala

def isLoggedIn(context, repo)
  for {
    sessionId  = context.session.string?("userId")
    user      <= repo.findUserByUserId(sessionId)
    groupId   = user.value["activeChannel"].as_h.fetch("groupId", "")
    channelId = user.value["activeChannel"].as_h.fetch("channelId", "")
    yield {
      puts "logged on in groupId: #{groupId} and channelId: #{channelId}"
      CurrentUser.new(user.value["name"].to_s, user.value["email"].to_s,
                            ActiveChannel.new(groupId.to_s, channelId.to_s),
                            sessionId)
    }
  }