123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317 |
- require 'test_helper'
- class SessionBasicTest < ActiveSupport::TestCase
- test 'b cache' do
- Sessions::CacheIn.set('last_run_test', true, { expires_in: 1.second })
- result = Sessions::CacheIn.get('last_run_test')
- assert_equal(true, result, 'check 1')
- # should not be expired
- result = Sessions::CacheIn.expired('last_run_test')
- assert_equal(false, result, 'check 1 - expired')
- # should be expired
- travel 2.seconds
- result = Sessions::CacheIn.expired('last_run_test')
- assert_equal(true, result, 'check 1 - expired')
- # renew expire
- result = Sessions::CacheIn.get('last_run_test', re_expire: true)
- assert_equal(true, result, 'check 1 - re_expire')
- # should not be expired
- result = Sessions::CacheIn.expired('last_run_test')
- assert_equal(false, result, 'check 1 - expired')
- # ignore expired
- travel 2.seconds
- result = Sessions::CacheIn.get('last_run_test', ignore_expire: true)
- assert_equal(true, result, 'check 1 - ignore_expire')
- # should be expired
- result = Sessions::CacheIn.expired('last_run_test')
- assert_equal(true, result, 'check 2')
- result = Sessions::CacheIn.get('last_run_test')
- assert_nil(result, 'check 2')
- # check delete cache
- Sessions::CacheIn.set('last_run_delete', true, { expires_in: 5.seconds })
- result = Sessions::CacheIn.get('last_run_delete')
- assert_equal(true, result, 'check 1')
- Sessions::CacheIn.delete('last_run_delete')
- result = Sessions::CacheIn.get('last_run_delete')
- assert_nil(result, 'check delete')
- travel_back
- end
- test 'c session create / update' do
- # create users
- roles = Role.where(name: %w[Agent])
- groups = Group.all
- agent1 = User.create_or_update(
- login: 'session-agent-1',
- firstname: 'Session',
- lastname: 'Agent 1',
- email: 'session-agent1@example.com',
- password: 'agentpw',
- active: true,
- roles: roles,
- groups: groups,
- updated_by_id: 1,
- created_by_id: 1,
- )
- # create sessions
- client_id1 = '123456789'
- Sessions.create(client_id1, {}, { type: 'websocket' })
- # check if session exists
- assert(Sessions.session_exists?(client_id1), 'check if session exists')
- # check session data
- data = Sessions.get(client_id1)
- assert(data[:meta], 'check if meta exists')
- assert(data[:user], 'check if user exists')
- assert_nil(data[:user]['id'], 'check if user id is correct')
- # recreate session
- Sessions.create(client_id1, agent1.attributes, { type: 'websocket' })
- # check if session exists
- assert(Sessions.session_exists?(client_id1), 'check if session exists')
- # check session data
- data = Sessions.get(client_id1)
- assert(data[:meta], 'check if meta exists')
- assert(data[:user], 'check if user exists')
- assert_equal(data[:user]['id'], agent1.id, 'check if user id is correct')
- # destroy session
- Sessions.destroy(client_id1)
- # check if session exists
- assert_not(Sessions.session_exists?(client_id1), 'check if session exists')
- end
- test 'c collections group' do
- require 'sessions/backend/collections/group.rb'
- # create users
- roles = Role.where(name: ['Agent'])
- groups = Group.all
- agent1 = User.create_or_update(
- login: 'session-collection-agent-1',
- firstname: 'Session',
- lastname: 'Agent 1',
- email: 'session-collection-agent1@example.com',
- password: 'agentpw',
- active: true,
- roles: roles,
- groups: groups,
- updated_by_id: 1,
- created_by_id: 1,
- )
- collection_client1 = Sessions::Backend::Collections::Group.new(agent1, {}, false, '123-1', 3)
- collection_client2 = Sessions::Backend::Collections::Group.new(agent1, {}, false, '234-2', 3)
- # get whole collections
- result1 = collection_client1.push
- assert(result1.present?, 'check collections')
- sleep 0.6
- result2 = collection_client2.push
- assert(result2.present?, 'check collections')
- assert_equal(result1, result2, 'check collections')
- # next check should be empty
- result1 = collection_client1.push
- assert_not(result1, 'check collections - recall')
- travel 1.second
- result2 = collection_client2.push
- assert_not(result2, 'check collections - recall')
- # change collection
- group = Group.first
- travel 4.seconds
- group.touch
- travel 4.seconds
- # get whole collections
- result1 = collection_client1.push
- assert(result1.present?, 'check collections - after touch')
- result2 = collection_client2.push
- assert(result2.present?, 'check collections - after touch')
- assert_equal(result1, result2, 'check collections')
- # check again after touch
- result1 = collection_client1.push
- assert_nil(result1, 'check collections - after touch - recall')
- result2 = collection_client2.push
- assert_nil(result2, 'check collections - after touch - recall')
- # change collection
- group = Group.create!(
- name: "SomeGroup::#{rand(999_999)}",
- active: true,
- created_by_id: 1,
- updated_by_id: 1,
- )
- travel 4.seconds
- # get whole collections
- result1 = collection_client1.push
- assert(result1.present?, 'check collections - after create')
- result2 = collection_client2.push
- assert(result2.present?, 'check collections - after create')
- assert_equal(result1, result2, 'check collections')
- # check again after create
- travel 4.seconds
- result1 = collection_client1.push
- assert_nil(result1, 'check collections - after create - recall')
- result2 = collection_client2.push
- assert_nil(result2, 'check collections - after create - recall')
- # change collection
- group.destroy
- travel 4.seconds
- # get whole collections
- result1 = collection_client1.push
- assert(result1.present?, 'check collections - after destroy')
- result2 = collection_client2.push
- assert(result2.present?, 'check collections - after destroy')
- assert_equal(result1, result2, 'check collections')
- # check again after destroy
- travel 4.seconds
- result1 = collection_client1.push
- assert_nil(result1, 'check collections - after destroy - recall')
- result2 = collection_client2.push
- assert_nil(result2, 'check collections - after destroy - recall')
- travel_back
- end
- test 'c activity stream' do
- # create users
- roles = Role.where(name: %w[Agent Admin])
- groups = Group.all
- agent1 = User.create_or_update(
- login: 'activity-stream-agent-1',
- firstname: 'Session',
- lastname: "activity stream #{rand(99_999)}",
- email: 'activity-stream-agent1@example.com',
- password: 'agentpw',
- active: true,
- roles: roles,
- groups: groups,
- updated_by_id: 1,
- created_by_id: 1,
- )
- # create min. on activity record
- random_name = "Random:#{rand(9_999_999_999)}"
- Group.create_or_update(
- name: random_name,
- updated_by_id: 1,
- created_by_id: 1,
- )
- as_client1 = Sessions::Backend::ActivityStream.new(agent1, {}, false, '123-1', 3)
- # get as stream
- result1 = as_client1.push
- assert(result1, 'check as agent1')
- travel 1.second
- # next check should be empty
- result1 = as_client1.push
- assert_not(result1, 'check as agent1 - recall')
- # next check should be empty
- travel 4.seconds
- result1 = as_client1.push
- assert_not(result1, 'check as agent1 - recall 2')
- agent1.update!(email: 'activity-stream-agent11@example.com')
- ticket = Ticket.create!(
- title: '12323',
- group_id: 1,
- priority_id: 1,
- state_id: 1,
- customer_id: 1,
- updated_by_id: 1,
- created_by_id: 1,
- )
- travel 4.seconds
- # get as stream
- result1 = as_client1.push
- assert( result1, 'check as agent1 - recall 3')
- travel_back
- end
- test 'c ticket_create' do
- # create users
- roles = Role.where(name: %w[Agent Admin])
- groups = Group.all
- agent1 = User.create_or_update(
- login: 'ticket_create-agent-1',
- firstname: 'Session',
- lastname: "ticket_create #{rand(99_999)}",
- email: 'ticket_create-agent1@example.com',
- password: 'agentpw',
- active: true,
- roles: roles,
- groups: groups,
- updated_by_id: 1,
- created_by_id: 1,
- )
- ticket_create_client1 = Sessions::Backend::TicketCreate.new(agent1, {}, false, '123-1', 3)
- # get as stream
- result1 = ticket_create_client1.push
- assert(result1, 'check ticket_create')
- travel 1.second
- # next check should be empty
- result1 = ticket_create_client1.push
- assert_not(result1, 'check ticket_create - recall')
- # next check should be empty
- travel 1.second
- result1 = ticket_create_client1.push
- assert_not(result1, 'check ticket_create - recall 2')
- Group.create!(
- name: "SomeTicketCreateGroup::#{rand(999_999)}",
- active: true,
- updated_by_id: 1,
- created_by_id: 1,
- )
- groups = Group.all
- agent1.groups = groups
- agent1.save!
- travel 4.seconds
- # get as stream
- result1 = ticket_create_client1.push
- assert(result1, 'check ticket_create - recall 3')
- travel_back
- end
- end
|