#   Copyright (c) 2010, Diaspora Inc.  This file is
#   licensed under the Affero General Public License version 3 or later.  See
#   the COPYRIGHT file.

require 'spec_helper'
require File.join(Rails.root, 'lib/diaspora/web_socket')
describe Diaspora::WebSocket do
  before do
    @mock_redis = mock()
    Diaspora::WebSocket.stub(:redis).and_return @mock_redis
  end
  describe '.next' do
   it 'pops the data from redis' do
     @mock_redis.should_receive(:rpop).with(:websocket)
     Diaspora::WebSocket.next
   end
  end
  describe '.queue_to_user' do
    it 'push the data into redis' do
      @mock_redis.should_receive(:lpush).with(:websocket, {:uid => "me", :data => "Socket!"}.to_json)
      Diaspora::WebSocket.queue_to_user("me", "Socket!")
    end
  end
end

describe Diaspora::Socketable do
  before do
    @user = make_user
    @aspect = @user.aspects.create(:name => "losers")
    @post = @user.build_post(:status_message, :message => "hey", :to => @aspect.id)
    @post.save
  end

  it 'sockets to a user' do
    Diaspora::WebSocket.should_receive(:queue_to_user)
    @post.socket_to_uid(@user.id, :aspect_ids => @aspect.id)
  end
end