Как связать объект Activerecord с подключением Em-Websocket?

Question

Я новичок в рубине. Я пытаюсь реализовать клиент чата, используя em-websocket. У меня есть следующий код:

  EventMachine::WebSocket.start(host: '0.0.0.0', port: 8080) do |websock|
    websock.onopen do
      puts 'New Connection Opened'
      cookies = CGI::Cookie::parse( websock.request["cookie"])
      person = Person.where(['token = ?', cookies["token"]]).first
      unless person       
        websock.close(code = nil, body = {Error: "Invalid Token"}.to_json)  unless person
        return
      end
      puts "#{person.name} authenticated!"
      person=person.attributes.merge(websock.attributes) # this doesn't work
      # Subscribe the new user to the GrindServer.realtime_channel with the callback function for the push action
      new_user = GrindServer.realtime_channel.subscribe { |msg| websock.send msg }
      GrindServer.online_people << person
      # Add the new user to the user list
      @users[websock.object_id] = new_user

      # Push the last messages to the user
      # message.all.each do |message|
        # websock.send message.to_json
      # end
      # puts GrindServer.realtime_channel.inspect
      # Broadcast the notification to all users
      onlinepeople = []
      GrindServer.online_people.each do |onli|
        onlinepeople << person
      end

      # Send last 10 messages to the newly connected user
      websock.send Message.where({ receiver_id: [0, person.id}).last(10).to_json

      GrindServer.realtime_channel.push ({
        'id' => 0,
        'sender_id' => 0,
        'messagetext' => "#{person.name} joined. <$<^<#<#{@users.length}>#>^>$> users in chat",
        'users' => onlinepeople,
        'metadata' => websock.request["query"]["id"],
        }.to_json)
    end
  ...# other event handlers
  end

В основном я пытаюсь сохранить список Person (объект ActiveRecord) и соответствующий ему объект WebSocket::Connection.

Код сервера

миграция

Обновление: даже если я не могу слиться. Я должен иметь возможность просто прикрепить записку к веб-сокету, что это принадлежит человеку по имени "х"?

Answer 1

Я решил это с помощью хеша.

  EventMachine::WebSocket.start(host: '0.0.0.0', port: 8080) do |websock|
    websock.onopen do
      puts 'New Connection Opened'
      cookies = CGI::Cookie::parse( websock.request["cookie"])
      person = Person.where(['token = ?', cookies["token"]]).first
      unless person       
        websock.close(code = nil, body = {Error: "Invalid Token"}.to_json)  unless person
        return
      end
      puts "#{person.name} authenticated!"
      # person=person.attributes.merge(websock.attributes)
      # Subscribe the new user to the GrindServer.realtime_channel with the callback function for the push action
      new_user = GrindServer.realtime_channel.subscribe { |msg| websock.send msg }
      GrindServer.online_people << {:ws_oid => websock.object_id,
                                    :websocket => websock, 
                                    :person_name => person.name,
                                    :person_trigram => person.trigram} # this solves it
      # Add the new user to the user list
      @users[websock.object_id] = new_user

      onlinepeople = []
      GrindServer.online_people.each do |onli|
        onlinepeople << onli.except(:websocket)
      end

      # Send last 10 messages to the newly connected user
      websock.send Message.where({ receiver_id: [0, person.id]}).last(10).to_json

      GrindServer.realtime_channel.push ({
        'id' => 0,
        'sender_id' => 0,
        'messagetext' => "#{person.name} joined. <$<^<#<#{@users.length}>#>^>$> users in chat",
        'users' => onlinepeople,
        'metadata' => person.trigram,
        }.to_json)
    end