zammad/test/unit/activity_stream_test.rb

# encoding: utf-8
require 'test_helper'

class ActivityStreamTest < ActiveSupport::TestCase
  admin_user = nil
  current_user = nil
  test 'aaa - setup' do
    roles = Role.where(name: %w(Admin Agent))
    group = Group.lookup(name: 'Users')
    admin_user = User.create_or_update(
      login: 'admin',
      firstname: 'Bob',
      lastname: 'Smith',
      email: 'bob@example.com',
      password: 'some_pass',
      active: true,
      roles: roles,
      group_ids: [group.id],
      updated_by_id: 1,
      created_by_id: 1
    )
    current_user = User.lookup(email: 'nicole.braun@zammad.org')
  end

  test 'ticket+user' do
    ticket = Ticket.create(
      group_id: Group.lookup(name: 'Users').id,
      customer_id: current_user.id,
      owner_id: User.lookup(login: '-').id,
      title: 'Unit Test 1 (äöüß)!',
      state_id: Ticket::State.lookup(name: 'new').id,
      priority_id: Ticket::Priority.lookup(name: '2 normal').id,
      updated_by_id: current_user.id,
      created_by_id: current_user.id,
    )
    travel 2.seconds

    article = Ticket::Article.create(
      ticket_id: ticket.id,
      updated_by_id: current_user.id,
      created_by_id: current_user.id,
      type_id: Ticket::Article::Type.lookup(name: 'phone').id,
      sender_id: Ticket::Article::Sender.lookup(name: 'Customer').id,
      from: 'Unit Test <unittest@example.com>',
      body: 'Unit Test 123',
      internal: false,
    )

    travel 100.seconds
    ticket.update_attributes(
      title: 'Unit Test 1 (äöüß) - update!',
      state_id: Ticket::State.lookup(name: 'open').id,
      priority_id: Ticket::Priority.lookup(name: '1 low').id,
    )
    updated_at = ticket.updated_at

    travel 1.second
    ticket.update_attributes(
      title: 'Unit Test 2 (äöüß) - update!',
      priority_id: Ticket::Priority.lookup(name: '2 normal').id,
    )

    # check activity_stream
    stream = admin_user.activity_stream(4)
    assert_equal(stream[0]['group_id'], ticket.group_id)
    assert_equal(stream[0]['o_id'], ticket.id)
    assert_equal(stream[0]['created_by_id'], current_user.id)
    assert_equal(stream[0]['created_at'].to_s, updated_at.to_s)
    assert_equal(stream[0]['object'], 'Ticket')
    assert_equal(stream[0]['type'], 'update')
    assert_equal(stream[1]['group_id'], ticket.group_id)
    assert_equal(stream[1]['o_id'], article.id)
    assert_equal(stream[1]['created_by_id'], current_user.id)
    assert_equal(stream[1]['created_at'].to_s, article.created_at.to_s)
    assert_equal(stream[1]['object'], 'Ticket::Article')
    assert_equal(stream[1]['type'], 'create')
    assert_equal(stream[2]['group_id'], ticket.group_id)
    assert_equal(stream[2]['o_id'], ticket.id)
    assert_equal(stream[2]['created_by_id'], current_user.id)
    assert_equal(stream[2]['created_at'].to_s, ticket.created_at.to_s)
    assert_equal(stream[2]['object'], 'Ticket')
    assert_equal(stream[2]['type'], 'create')
    assert_not(stream[3])

    stream = current_user.activity_stream(4)
    assert(stream.empty?)

    # cleanup
    ticket.destroy
    travel_back
  end

  test 'organization' do

    organization = Organization.create(
      name: 'some name',
      updated_by_id: current_user.id,
      created_by_id: current_user.id,
    )
    travel 100.seconds
    assert_equal(organization.class, Organization)

    organization.update_attributes(name: 'some name (äöüß)')
    updated_at = organization.updated_at

    travel 10.seconds
    organization.update_attributes(name: 'some name 2 (äöüß)')

    # check activity_stream
    stream = admin_user.activity_stream(3)
    assert_not(stream[0]['group_id'])
    assert_equal(stream[0]['o_id'], organization.id)
    assert_equal(stream[0]['created_by_id'], current_user.id)
    assert_equal(stream[0]['created_at'].to_s, updated_at.to_s)
    assert_equal(stream[0]['object'], 'Organization')
    assert_equal(stream[0]['type'], 'update')
    assert_not(stream[1]['group_id'])
    assert_equal(stream[1]['o_id'], organization.id)
    assert_equal(stream[1]['created_by_id'], current_user.id)
    assert_equal(stream[1]['created_at'].to_s, organization.created_at.to_s)
    assert_equal(stream[1]['object'], 'Organization')
    assert_equal(stream[1]['type'], 'create')
    assert_not(stream[2])

    stream = current_user.activity_stream(4)
    assert(stream.empty?)

    # cleanup
    organization.destroy
    travel_back
  end

  test 'user with update check false' do
    user = User.create(
      login: 'someemail@example.com',
      email: 'someemail@example.com',
      firstname: 'Bob Smith II',
      updated_by_id: current_user.id,
      created_by_id: current_user.id,
    )
    assert_equal(user.class, User)
    user.update_attributes(
      firstname: 'Bob U',
      lastname: 'Smith U',
    )

    # check activity_stream
    stream = admin_user.activity_stream(3)
    assert_not(stream[0]['group_id'])
    assert_equal(stream[0]['o_id'], user.id)
    assert_equal(stream[0]['created_by_id'], current_user.id)
    assert_equal(stream[0]['created_at'].to_s, user.created_at.to_s)
    assert_equal(stream[0]['object'], 'User')
    assert_equal(stream[0]['type'], 'create')
    assert_not(stream[1])

    stream = current_user.activity_stream(4)
    assert(stream.empty?)

    # cleanup
    user.destroy
    travel_back
  end

  test 'user with update check true' do

    user = User.create(
      login: 'someemail@example.com',
      email: 'someemail@example.com',
      firstname: 'Bob Smith II',
      updated_by_id: current_user.id,
      created_by_id: current_user.id,
    )
    travel 100.seconds
    assert_equal(user.class, User)

    user.update_attributes(
      firstname: 'Bob U',
      lastname: 'Smith U',
    )
    updated_at = user.updated_at

    travel 10.seconds
    user.update_attributes(
      firstname: 'Bob',
      lastname: 'Smith',
    )

    # check activity_stream
    stream = admin_user.activity_stream(3)
    assert_not(stream[0]['group_id'])
    assert_equal(stream[0]['o_id'], user.id)
    assert_equal(stream[0]['created_by_id'], current_user.id)
    assert_equal(stream[0]['created_at'].to_s, updated_at.to_s)
    assert_equal(stream[0]['object'], 'User')
    assert_equal(stream[0]['type'], 'update')
    assert_not(stream[1]['group_id'])
    assert_equal(stream[1]['o_id'], user.id)
    assert_equal(stream[1]['created_by_id'], current_user.id)
    assert_equal(stream[1]['created_at'].to_s, user.created_at.to_s)
    assert_equal(stream[1]['object'], 'User')
    assert_equal(stream[1]['type'], 'create')
    assert_not(stream[2])

    stream = current_user.activity_stream(4)
    assert(stream.empty?)

    # cleanup
    user.destroy
    travel_back
  end

end