search_controller_test.rb 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461
  1. # encoding: utf-8
  2. require 'test_helper'
  3. class SearchControllerTest < ActionDispatch::IntegrationTest
  4. setup do
  5. # clear cache
  6. Cache.clear
  7. # remove background jobs
  8. Delayed::Job.destroy_all
  9. # set current user
  10. UserInfo.current_user_id = 1
  11. # set accept header
  12. @headers = { 'ACCEPT' => 'application/json', 'CONTENT_TYPE' => 'application/json' }
  13. # create agent
  14. roles = Role.where(name: %w(Admin Agent))
  15. groups = Group.all
  16. @admin = User.create_or_update(
  17. login: 'search-admin',
  18. firstname: 'Search',
  19. lastname: 'Admin',
  20. email: 'search-admin@example.com',
  21. password: 'adminpw',
  22. active: true,
  23. roles: roles,
  24. groups: groups,
  25. )
  26. # create agent
  27. roles = Role.where(name: 'Agent')
  28. @agent = User.create_or_update(
  29. login: 'search-agent@example.com',
  30. firstname: 'Search 1234',
  31. lastname: 'Agent',
  32. email: 'search-agent@example.com',
  33. password: 'agentpw',
  34. active: true,
  35. roles: roles,
  36. groups: groups,
  37. )
  38. # create customer without org
  39. roles = Role.where(name: 'Customer')
  40. @customer_without_org = User.create_or_update(
  41. login: 'search-customer1@example.com',
  42. firstname: 'Search',
  43. lastname: 'Customer1',
  44. email: 'search-customer1@example.com',
  45. password: 'customer1pw',
  46. active: true,
  47. roles: roles,
  48. )
  49. # create orgs
  50. @organization = Organization.create_or_update(
  51. name: 'Rest Org',
  52. )
  53. @organization2 = Organization.create_or_update(
  54. name: 'Rest Org #2',
  55. )
  56. @organization3 = Organization.create_or_update(
  57. name: 'Rest Org #3',
  58. )
  59. # create customer with org
  60. @customer_with_org2 = User.create_or_update(
  61. login: 'search-customer2@example.com',
  62. firstname: 'Search',
  63. lastname: 'Customer2',
  64. email: 'search-customer2@example.com',
  65. password: 'customer2pw',
  66. active: true,
  67. roles: roles,
  68. organization_id: @organization.id,
  69. )
  70. @customer_with_org3 = User.create_or_update(
  71. login: 'search-customer3@example.com',
  72. firstname: 'Search',
  73. lastname: 'Customer3',
  74. email: 'search-customer3@example.com',
  75. password: 'customer3pw',
  76. active: true,
  77. roles: roles,
  78. organization_id: @organization.id,
  79. )
  80. Ticket.all.destroy_all
  81. @ticket1 = Ticket.create(
  82. title: 'test 1234-1',
  83. group: Group.lookup(name: 'Users'),
  84. customer_id: @customer_without_org.id,
  85. state: Ticket::State.lookup(name: 'new'),
  86. priority: Ticket::Priority.lookup(name: '2 normal'),
  87. updated_by_id: 1,
  88. created_by_id: 1,
  89. )
  90. @article1 = Ticket::Article.create(
  91. ticket_id: @ticket1.id,
  92. from: 'some_sender1@example.com',
  93. to: 'some_recipient1@example.com',
  94. subject: 'some subject1',
  95. message_id: 'some@id',
  96. body: 'some message1',
  97. internal: false,
  98. sender: Ticket::Article::Sender.where(name: 'Customer').first,
  99. type: Ticket::Article::Type.where(name: 'email').first,
  100. updated_by_id: 1,
  101. created_by_id: 1,
  102. )
  103. sleep 1
  104. @ticket2 = Ticket.create(
  105. title: 'test 1234-2',
  106. group: Group.lookup(name: 'Users'),
  107. customer_id: @customer_with_org2.id,
  108. state: Ticket::State.lookup(name: 'new'),
  109. priority: Ticket::Priority.lookup(name: '2 normal'),
  110. updated_by_id: 1,
  111. created_by_id: 1,
  112. )
  113. @article2 = Ticket::Article.create(
  114. ticket_id: @ticket2.id,
  115. from: 'some_sender2@example.com',
  116. to: 'some_recipient2@example.com',
  117. subject: 'some subject2',
  118. message_id: 'some@id',
  119. body: 'some message2',
  120. internal: false,
  121. sender: Ticket::Article::Sender.where(name: 'Customer').first,
  122. type: Ticket::Article::Type.where(name: 'email').first,
  123. updated_by_id: 1,
  124. created_by_id: 1,
  125. )
  126. sleep 1
  127. @ticket3 = Ticket.create(
  128. title: 'test 1234-2',
  129. group: Group.lookup(name: 'Users'),
  130. customer_id: @customer_with_org3.id,
  131. state: Ticket::State.lookup(name: 'new'),
  132. priority: Ticket::Priority.lookup(name: '2 normal'),
  133. updated_by_id: 1,
  134. created_by_id: 1,
  135. )
  136. @article3 = Ticket::Article.create(
  137. ticket_id: @ticket3.id,
  138. from: 'some_sender3@example.com',
  139. to: 'some_recipient3@example.com',
  140. subject: 'some subject3',
  141. message_id: 'some@id',
  142. body: 'some message3',
  143. internal: false,
  144. sender: Ticket::Article::Sender.where(name: 'Customer').first,
  145. type: Ticket::Article::Type.where(name: 'email').first,
  146. updated_by_id: 1,
  147. created_by_id: 1,
  148. )
  149. # configure es
  150. if ENV['ES_URL']
  151. #fail "ERROR: Need ES_URL - hint ES_URL='http://172.0.0.1:9200'"
  152. Setting.set('es_url', ENV['ES_URL'])
  153. # Setting.set('es_url', 'http://172.0.0.1:9200')
  154. # Setting.set('es_index', 'estest.local_zammad')
  155. # Setting.set('es_user', 'elasticsearch')
  156. # Setting.set('es_password', 'zammad')
  157. # set max attachment size in mb
  158. Setting.set('es_attachment_max_size_in_mb', 1)
  159. if ENV['ES_INDEX']
  160. #fail "ERROR: Need ES_INDEX - hint ES_INDEX='estest.local_zammad'"
  161. Setting.set('es_index', ENV['ES_INDEX'])
  162. end
  163. # drop/create indexes
  164. #Rake::Task["searchindex:drop"].execute
  165. #Rake::Task["searchindex:create"].execute
  166. system('rake searchindex:rebuild')
  167. # execute background jobs
  168. Scheduler.worker(true)
  169. sleep 6
  170. end
  171. end
  172. test 'settings index with nobody' do
  173. params = {
  174. query: 'test 1234',
  175. limit: 2,
  176. }
  177. post '/api/v1/search/ticket', params.to_json, @headers
  178. assert_response(401)
  179. result = JSON.parse(@response.body)
  180. assert_equal(result.class, Hash)
  181. assert_not(result.empty?)
  182. post '/api/v1/search/user', params.to_json, @headers
  183. assert_response(401)
  184. result = JSON.parse(@response.body)
  185. assert_equal(result.class, Hash)
  186. assert_not(result.empty?)
  187. post '/api/v1/search', params.to_json, @headers
  188. assert_response(401)
  189. result = JSON.parse(@response.body)
  190. assert_equal(result.class, Hash)
  191. assert_not(result.empty?)
  192. end
  193. test 'settings index with admin' do
  194. credentials = ActionController::HttpAuthentication::Basic.encode_credentials('search-admin@example.com', 'adminpw')
  195. params = {
  196. query: '1234*',
  197. limit: 1,
  198. }
  199. post '/api/v1/search', params.to_json, @headers.merge('Authorization' => credentials)
  200. assert_response(200)
  201. result = JSON.parse(@response.body)
  202. assert_equal(Hash, result.class)
  203. assert(result)
  204. assert_equal('Ticket', result['result'][0]['type'])
  205. assert_equal(@ticket3.id, result['result'][0]['id'])
  206. assert_equal('User', result['result'][1]['type'])
  207. assert_equal(@agent.id, result['result'][1]['id'])
  208. assert_not(result['result'][2])
  209. params = {
  210. query: '1234*',
  211. limit: 10,
  212. }
  213. post '/api/v1/search', params.to_json, @headers.merge('Authorization' => credentials)
  214. assert_response(200)
  215. result = JSON.parse(@response.body)
  216. assert_equal(Hash, result.class)
  217. assert(result)
  218. assert_equal('Ticket', result['result'][0]['type'])
  219. assert_equal(@ticket3.id, result['result'][0]['id'])
  220. assert_equal('Ticket', result['result'][1]['type'])
  221. assert_equal(@ticket2.id, result['result'][1]['id'])
  222. assert_equal('Ticket', result['result'][2]['type'])
  223. assert_equal(@ticket1.id, result['result'][2]['id'])
  224. assert_equal('User', result['result'][3]['type'])
  225. assert_equal(@agent.id, result['result'][3]['id'])
  226. assert_not(result['result'][4])
  227. params = {
  228. query: '1234*',
  229. limit: 10,
  230. }
  231. post '/api/v1/search/ticket', params.to_json, @headers.merge('Authorization' => credentials)
  232. assert_response(200)
  233. result = JSON.parse(@response.body)
  234. assert_equal(Hash, result.class)
  235. assert(result)
  236. assert_equal('Ticket', result['result'][0]['type'])
  237. assert_equal(@ticket3.id, result['result'][0]['id'])
  238. assert_equal('Ticket', result['result'][1]['type'])
  239. assert_equal(@ticket2.id, result['result'][1]['id'])
  240. assert_equal('Ticket', result['result'][2]['type'])
  241. assert_equal(@ticket1.id, result['result'][2]['id'])
  242. assert_not(result['result'][3])
  243. params = {
  244. query: '1234*',
  245. limit: 10,
  246. }
  247. post '/api/v1/search/user', params.to_json, @headers.merge('Authorization' => credentials)
  248. assert_response(200)
  249. result = JSON.parse(@response.body)
  250. assert_equal(Hash, result.class)
  251. assert_equal('User', result['result'][0]['type'])
  252. assert_equal(@agent.id, result['result'][0]['id'])
  253. assert_not(result['result'][1])
  254. end
  255. test 'settings index with agent' do
  256. credentials = ActionController::HttpAuthentication::Basic.encode_credentials('search-agent@example.com', 'agentpw')
  257. params = {
  258. query: '1234*',
  259. limit: 1,
  260. }
  261. post '/api/v1/search', params.to_json, @headers.merge('Authorization' => credentials)
  262. assert_response(200)
  263. result = JSON.parse(@response.body)
  264. assert_equal(Hash, result.class)
  265. assert(result)
  266. assert_equal('Ticket', result['result'][0]['type'])
  267. assert_equal(@ticket3.id, result['result'][0]['id'])
  268. assert_equal('User', result['result'][1]['type'])
  269. assert_equal(@agent.id, result['result'][1]['id'])
  270. assert_not(result['result'][2])
  271. params = {
  272. query: '1234*',
  273. limit: 10,
  274. }
  275. post '/api/v1/search', params.to_json, @headers.merge('Authorization' => credentials)
  276. assert_response(200)
  277. result = JSON.parse(@response.body)
  278. assert_equal(Hash, result.class)
  279. assert(result)
  280. assert_equal('Ticket', result['result'][0]['type'])
  281. assert_equal(@ticket3.id, result['result'][0]['id'])
  282. assert_equal('Ticket', result['result'][1]['type'])
  283. assert_equal(@ticket2.id, result['result'][1]['id'])
  284. assert_equal('Ticket', result['result'][2]['type'])
  285. assert_equal(@ticket1.id, result['result'][2]['id'])
  286. assert_equal('User', result['result'][3]['type'])
  287. assert_equal(@agent.id, result['result'][3]['id'])
  288. assert_not(result['result'][4])
  289. params = {
  290. query: '1234*',
  291. limit: 10,
  292. }
  293. post '/api/v1/search/ticket', params.to_json, @headers.merge('Authorization' => credentials)
  294. assert_response(200)
  295. result = JSON.parse(@response.body)
  296. assert_equal(Hash, result.class)
  297. assert(result)
  298. assert_equal('Ticket', result['result'][0]['type'])
  299. assert_equal(@ticket3.id, result['result'][0]['id'])
  300. assert_equal('Ticket', result['result'][1]['type'])
  301. assert_equal(@ticket2.id, result['result'][1]['id'])
  302. assert_equal('Ticket', result['result'][2]['type'])
  303. assert_equal(@ticket1.id, result['result'][2]['id'])
  304. assert_not(result['result'][3])
  305. params = {
  306. query: '1234*',
  307. limit: 10,
  308. }
  309. post '/api/v1/search/user', params.to_json, @headers.merge('Authorization' => credentials)
  310. assert_response(200)
  311. result = JSON.parse(@response.body)
  312. assert_equal(Hash, result.class)
  313. assert_equal('User', result['result'][0]['type'])
  314. assert_equal(@agent.id, result['result'][0]['id'])
  315. assert_not(result['result'][1])
  316. end
  317. test 'settings index with customer 1' do
  318. credentials = ActionController::HttpAuthentication::Basic.encode_credentials('search-customer1@example.com', 'customer1pw')
  319. params = {
  320. query: '1234*',
  321. limit: 10,
  322. }
  323. post '/api/v1/search', params.to_json, @headers.merge('Authorization' => credentials)
  324. assert_response(200)
  325. result = JSON.parse(@response.body)
  326. assert_equal(Hash, result.class)
  327. assert(result)
  328. assert_equal('Ticket', result['result'][0]['type'])
  329. assert_equal(@ticket1.id, result['result'][0]['id'])
  330. assert_not(result['result'][1])
  331. params = {
  332. query: '1234*',
  333. limit: 10,
  334. }
  335. post '/api/v1/search/ticket', params.to_json, @headers.merge('Authorization' => credentials)
  336. assert_response(200)
  337. result = JSON.parse(@response.body)
  338. assert_equal(Hash, result.class)
  339. assert(result)
  340. assert_equal('Ticket', result['result'][0]['type'])
  341. assert_equal(@ticket1.id, result['result'][0]['id'])
  342. assert_not(result['result'][1])
  343. params = {
  344. query: '1234*',
  345. limit: 10,
  346. }
  347. post '/api/v1/search/user', params.to_json, @headers.merge('Authorization' => credentials)
  348. assert_response(200)
  349. result = JSON.parse(@response.body)
  350. assert_equal(Hash, result.class)
  351. assert_not(result['result'][0])
  352. end
  353. test 'settings index with customer 2' do
  354. credentials = ActionController::HttpAuthentication::Basic.encode_credentials('search-customer2@example.com', 'customer2pw')
  355. params = {
  356. query: '1234*',
  357. limit: 10,
  358. }
  359. post '/api/v1/search', params.to_json, @headers.merge('Authorization' => credentials)
  360. assert_response(200)
  361. result = JSON.parse(@response.body)
  362. assert_equal(Hash, result.class)
  363. assert(result)
  364. assert_equal('Ticket', result['result'][0]['type'])
  365. assert_equal(@ticket3.id, result['result'][0]['id'])
  366. assert_equal('Ticket', result['result'][1]['type'])
  367. assert_equal(@ticket2.id, result['result'][1]['id'])
  368. assert_not(result['result'][2])
  369. params = {
  370. query: '1234*',
  371. limit: 10,
  372. }
  373. post '/api/v1/search/ticket', params.to_json, @headers.merge('Authorization' => credentials)
  374. assert_response(200)
  375. result = JSON.parse(@response.body)
  376. assert_equal(Hash, result.class)
  377. assert(result)
  378. assert_equal('Ticket', result['result'][0]['type'])
  379. assert_equal(@ticket3.id, result['result'][0]['id'])
  380. assert_equal('Ticket', result['result'][1]['type'])
  381. assert_equal(@ticket2.id, result['result'][1]['id'])
  382. assert_not(result['result'][2])
  383. params = {
  384. query: '1234*',
  385. limit: 10,
  386. }
  387. post '/api/v1/search/user', params.to_json, @headers.merge('Authorization' => credentials)
  388. assert_response(200)
  389. result = JSON.parse(@response.body)
  390. assert_equal(Hash, result.class)
  391. assert_not(result['result'][0])
  392. end
  393. end