123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029 |
- class UsersController < ApplicationController
- prepend_before_action :authentication_check, except: [:create, :password_reset_send, :password_reset_verify, :image]
- prepend_before_action :authentication_check_only, only: [:create]
-
-
-
-
-
-
-
-
-
- def index
- offset = 0
- per_page = 500
- if params[:page] && params[:per_page]
- offset = (params[:page].to_i - 1) * params[:per_page].to_i
- per_page = params[:per_page].to_i
- end
- if per_page > 500
- per_page = 500
- end
-
- users = if !current_user.permissions?(['admin.user', 'ticket.agent'])
- User.where(id: current_user.id).order(id: 'ASC').offset(offset).limit(per_page)
- else
- User.all.order(id: 'ASC').offset(offset).limit(per_page)
- end
- if params[:expand]
- list = []
- users.each { |user|
- list.push user.attributes_with_association_names
- }
- render json: list, status: :ok
- return
- end
- if params[:full]
- assets = {}
- item_ids = []
- users.each { |item|
- item_ids.push item.id
- assets = item.assets(assets)
- }
- render json: {
- record_ids: item_ids,
- assets: assets,
- }, status: :ok
- return
- end
- users_all = []
- users.each { |user|
- users_all.push User.lookup(id: user.id).attributes_with_association_ids
- }
- render json: users_all, status: :ok
- end
-
-
-
-
-
-
-
-
-
-
-
-
- def show
- user = User.find(params[:id])
- access!(user, 'read')
- if params[:expand]
- result = user.attributes_with_association_names
- elsif params[:full]
- result = {
- id: params[:id],
- assets: user.assets({}),
- }
- else
- result = user.attributes_with_association_ids
- result.delete('password')
- end
- render json: result
- end
-
-
-
-
-
-
-
-
-
- def create
- clean_params = User.association_name_to_id_convert(params)
- clean_params = User.param_cleanup(clean_params, true)
-
-
- count = User.all.count()
- admin_account_exists = true
- if count <= 2
- admin_account_exists = false
- end
-
- if !current_user
-
- if admin_account_exists && !Setting.get('user_create_account')
- raise Exceptions::UnprocessableEntity, 'Feature not enabled!'
- end
-
- if admin_account_exists && !params[:signup]
- raise Exceptions::UnprocessableEntity, 'Only signup with not authenticate user possible!'
- end
- user = User.new(clean_params)
- user.associations_from_param(params)
- user.updated_by_id = 1
- user.created_by_id = 1
-
- group_ids = []
- role_ids = []
- if count <= 2
- Role.where(name: %w(Admin Agent)).each { |role|
- role_ids.push role.id
- }
- Group.all().each { |group|
- group_ids.push group.id
- }
-
- else
- role_ids = Role.signup_role_ids
- end
- user.role_ids = role_ids
- user.group_ids = group_ids
-
-
- if admin_account_exists
- user.source = 'signup'
- end
-
- else
-
- permission_check_by_permission(params)
- user = User.new(clean_params)
- user.associations_from_param(params)
- end
-
- if !user.email.empty?
- exists = User.where(email: user.email.downcase).first
- raise Exceptions::UnprocessableEntity, 'User already exists!' if exists
- end
- user.save!
-
- if !admin_account_exists
- Setting.set('system_init_done', true)
-
- if !user.email.empty?
- Service::Image.organization_suggest(user.email)
- end
-
- Calendar.init_setup(request.remote_ip)
-
- begin
- TextModule.load(request.env['HTTP_ACCEPT_LANGUAGE'] || 'en-us')
- rescue => e
- logger.error "Unable to load text modules #{request.env['HTTP_ACCEPT_LANGUAGE'] || 'en-us'}: #{e.message}"
- end
- end
-
- if params[:invite] && current_user
- token = Token.create(action: 'PasswordReset', user_id: user.id)
- NotificationFactory::Mailer.notification(
- template: 'user_invite',
- user: user,
- objects: {
- token: token,
- user: user,
- current_user: current_user,
- }
- )
- end
-
- if params[:signup] && !current_user
- result = User.signup_new_token(user)
- NotificationFactory::Mailer.notification(
- template: 'signup',
- user: user,
- objects: result,
- )
- end
- if params[:expand]
- user = User.find(user.id).attributes_with_association_names
- render json: user, status: :created
- return
- end
- user_new = User.find(user.id).attributes_with_association_ids
- user_new.delete('password')
- render json: user_new, status: :created
- end
-
-
-
-
-
-
-
-
-
-
- def update
- permission_check_by_permission(params)
- user = User.find(params[:id])
- access!(user, 'change')
-
- permission_check_by_permission(params)
- user.with_lock do
- clean_params = User.association_name_to_id_convert(params)
- clean_params = User.param_cleanup(clean_params, true)
- user.update_attributes(clean_params)
-
- if current_user.permissions?('admin.user') && (params[:role_ids] || params[:roles])
- user.associations_from_param({ role_ids: params[:role_ids], roles: params[:roles] })
- end
-
- if current_user.permissions?('admin.user') && (params[:group_ids] || params[:groups])
- user.associations_from_param({ group_ids: params[:group_ids], groups: params[:groups] })
- end
-
- if current_user.permissions?(['admin.user', 'ticket.agent']) && (params[:organization_ids] || params[:organizations])
- user.associations_from_param({ organization_ids: params[:organization_ids], organizations: params[:organizations] })
- end
- if params[:expand]
- user = User.find(user.id).attributes_with_association_names
- render json: user, status: :ok
- return
- end
- end
-
- user_new = User.find(user.id).attributes_with_association_ids
- user_new.delete('password')
- render json: user_new, status: :ok
- end
-
-
-
-
-
-
-
-
-
- def destroy
- user = User.find(params[:id])
- access!(user, 'delete')
- model_references_check(User, params)
- model_destroy_render(User, params)
- end
-
-
-
-
-
-
-
-
-
- def me
- if params[:expand]
- user = current_user.attributes_with_association_names
- render json: user, status: :ok
- return
- end
- if params[:full]
- full = User.full(current_user.id)
- render json: full
- return
- end
- user = current_user.attributes_with_association_ids
- user.delete('password')
- render json: user
- end
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- def search
- if !current_user.permissions?(['ticket.agent', 'admin.user'])
- response_access_deny
- return
- end
-
- if params[:page] && params[:per_page]
- params[:limit] = params[:page].to_i * params[:per_page].to_i
- end
- if params[:limit] && params[:limit].to_i > 500
- params[:limit].to_i = 500
- end
- query_params = {
- query: params[:query],
- limit: params[:limit],
- current_user: current_user,
- }
- if params[:role_ids] && !params[:role_ids].empty?
- query_params[:role_ids] = params[:role_ids]
- end
-
- user_all = User.search(query_params)
-
- if params[:page] && params[:per_page]
- offset = (params[:page].to_i - 1) * params[:per_page].to_i
- user_all = user_all.slice(offset, params[:per_page].to_i) || []
- end
- if params[:expand]
- list = []
- user_all.each { |user|
- list.push user.attributes_with_association_names
- }
- render json: list, status: :ok
- return
- end
-
- if params[:label]
- users = []
- user_all.each { |user|
- realname = user.firstname.to_s + ' ' + user.lastname.to_s
- if user.email && user.email.to_s != ''
- realname = realname + ' <' + user.email.to_s + '>'
- end
- a = { id: user.id, label: realname, value: realname }
- users.push a
- }
-
- render json: users
- return
- end
- if params[:full]
- user_ids = []
- assets = {}
- user_all.each { |user|
- assets = user.assets(assets)
- user_ids.push user.id
- }
-
- render json: {
- assets: assets,
- user_ids: user_ids.uniq,
- }
- return
- end
- list = []
- user_all.each { |user|
- list.push user.attributes_with_association_ids
- }
- render json: list, status: :ok
- end
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- def recent
- if !current_user.permissions?('admin.user')
- response_access_deny
- return
- end
-
- user_all = if params[:role_ids] && !params[:role_ids].empty?
- User.joins(:roles).where( 'roles.id' => params[:role_ids] ).where('users.id != 1').order('users.created_at DESC').limit( params[:limit] || 20 )
- else
- User.where('id != 1').order('created_at DESC').limit( params[:limit] || 20 )
- end
-
- if !params[:full]
- users = []
- user_all.each { |user|
- realname = user.firstname.to_s + ' ' + user.lastname.to_s
- if user.email && user.email.to_s != ''
- realname = realname + ' <' + user.email.to_s + '>'
- end
- a = { id: user.id, label: realname, value: realname }
- users.push a
- }
-
- render json: users
- return
- end
- user_ids = []
- assets = {}
- user_all.each { |user|
- assets = user.assets(assets)
- user_ids.push user.id
- }
-
- render json: {
- assets: assets,
- user_ids: user_ids.uniq,
- }
- end
-
-
-
-
-
-
-
-
-
-
-
-
-
- def history
-
- if !current_user.permissions?(['admin.user', 'ticket.agent'])
- response_access_deny
- return
- end
-
- user = User.find(params[:id])
-
- history = user.history_get(true)
-
- render json: history
- end
- def email_verify
- raise Exceptions::UnprocessableEntity, 'No token!' if !params[:token]
- user = User.signup_verify_via_token(params[:token], current_user)
- raise Exceptions::UnprocessableEntity, 'Invalid token!' if !user
- render json: { message: 'ok', user_email: user.email }, status: :ok
- end
- def email_verify_send
- raise Exceptions::UnprocessableEntity, 'No email!' if !params[:email]
-
- user = User.find_by(email: params[:email].downcase)
- raise Exceptions::UnprocessableEntity, 'No such user!' if !user
-
-
-
-
- token = Token.create(action: 'Signup', user_id: user.id)
- result = User.signup_new_token(user)
- if result && result[:token]
- user = result[:user]
- NotificationFactory::Mailer.notification(
- template: 'signup',
- user: user,
- objects: result
- )
-
- if Setting.get('developer_mode') == true
- render json: { message: 'ok', token: result[:token].name }, status: :ok
- return
- end
-
- render json: { message: 'ok' }, status: :ok
- return
- end
-
- render json: { message: 'failed' }, status: :ok
- end
- def password_reset_send
-
- raise Exceptions::UnprocessableEntity, 'Feature not enabled!' if !Setting.get('user_lost_password')
- result = User.password_reset_new_token(params[:username])
- if result && result[:token]
-
- user = result[:user]
- NotificationFactory::Mailer.notification(
- template: 'password_reset',
- user: user,
- objects: result
- )
-
- if Setting.get('developer_mode') == true
- render json: { message: 'ok', token: result[:token].name }, status: :ok
- return
- end
-
- render json: { message: 'ok' }, status: :ok
- return
- end
-
- render json: { message: 'failed' }, status: :ok
- end
- def password_reset_verify
- if params[:password]
-
- result = password_policy(params[:password])
- if result != true
- render json: { message: 'failed', notice: result }, status: :ok
- return
- end
-
- user = User.password_reset_via_token(params[:token], params[:password])
-
- if user
- NotificationFactory::Mailer.notification(
- template: 'password_change',
- user: user,
- objects: {
- user: user,
- current_user: current_user,
- }
- )
- end
- else
- user = User.by_reset_token(params[:token])
- end
- if user
- render json: { message: 'ok', user_login: user.login }, status: :ok
- else
- render json: { message: 'failed' }, status: :ok
- end
- end
- def password_change
-
- if !params[:password_old]
- render json: { message: 'failed', notice: ['Current password needed!'] }, status: :ok
- return
- end
- user = User.authenticate(current_user.login, params[:password_old])
- if !user
- render json: { message: 'failed', notice: ['Current password is wrong!'] }, status: :ok
- return
- end
-
- if !params[:password_new]
- render json: { message: 'failed', notice: ['Please supply your new password!'] }, status: :ok
- return
- end
-
- result = password_policy(params[:password_new])
- if result != true
- render json: { message: 'failed', notice: result }, status: :ok
- return
- end
- user.update_attributes(password: params[:password_new])
- NotificationFactory::Mailer.notification(
- template: 'password_change',
- user: user,
- objects: {
- user: user,
- current_user: current_user,
- }
- )
- render json: { message: 'ok', user_login: user.login }, status: :ok
- end
- def preferences
- raise Exceptions::UnprocessableEntity, 'No current user!' if !current_user
- if params[:user]
- user = User.find(current_user.id)
- user.with_lock do
- params[:user].each { |key, value|
- user.preferences[key.to_sym] = value
- }
- user.save
- end
- end
- render json: { message: 'ok' }, status: :ok
- end
- def account_remove
- raise Exceptions::UnprocessableEntity, 'No current user!' if !current_user
-
- raise Exceptions::UnprocessableEntity, 'provider needed!' if !params[:provider]
- raise Exceptions::UnprocessableEntity, 'uid needed!' if !params[:uid]
-
- record = Authorization.where(
- user_id: current_user.id,
- provider: params[:provider],
- uid: params[:uid],
- )
- raise Exceptions::UnprocessableEntity, 'No record found!' if !record.first
- record.destroy_all
- render json: { message: 'ok' }, status: :ok
- end
- def image
-
- response.headers['Expires'] = 1.year.from_now.httpdate
- response.headers['Cache-Control'] = 'cache, store, max-age=31536000, must-revalidate'
- response.headers['Pragma'] = 'cache'
- file = Avatar.get_by_hash(params[:hash])
- if file
- send_data(
- file.content,
- filename: file.filename,
- type: file.preferences['Content-Type'] || file.preferences['Mime-Type'],
- disposition: 'inline'
- )
- return
- end
-
- image = 'R0lGODdhMAAwAOMAAMzMzJaWlr6+vqqqqqOjo8XFxbe3t7GxsZycnAAAAAAAAAAAAAAAAAAAAAAAAAAAACwAAAAAMAAwAAAEcxDISau9OOvNu/9gKI5kaZ5oqq5s675wLM90bd94ru98TwuAA+KQAQqJK8EAgBAgMEqmkzUgBIeSwWGZtR5XhSqAULACCoGCJGwlm1MGQrq9RqgB8fm4ZTUgDBIEcRR9fz6HiImKi4yNjo+QkZKTlJWWkBEAOw=='
- send_data(
- Base64.decode64(image),
- filename: 'image.gif',
- type: 'image/gif',
- disposition: 'inline'
- )
- end
- def avatar_new
- return if !valid_session_with_user
-
- file_full = StaticAssets.data_url_attributes(params[:avatar_full])
- file_resize = StaticAssets.data_url_attributes(params[:avatar_resize])
- avatar = Avatar.add(
- object: 'User',
- o_id: current_user.id,
- full: {
- content: file_full[:content],
- mime_type: file_full[:mime_type],
- },
- resize: {
- content: file_resize[:content],
- mime_type: file_resize[:mime_type],
- },
- source: 'upload ' + Time.zone.now.to_s,
- deletable: true,
- )
-
- user = User.find(current_user.id)
- user.update_attributes(image: avatar.store_hash)
- render json: { avatar: avatar }, status: :ok
- end
- def avatar_set_default
- return if !valid_session_with_user
-
- raise Exceptions::UnprocessableEntity, 'No id of avatar!' if !params[:id]
-
- avatar = Avatar.set_default('User', current_user.id, params[:id])
-
- user = User.find(current_user.id)
- user.update_attributes(image: avatar.store_hash)
- render json: {}, status: :ok
- end
- def avatar_destroy
- return if !valid_session_with_user
-
- raise Exceptions::UnprocessableEntity, 'No id of avatar!' if !params[:id]
-
- Avatar.remove_one('User', current_user.id, params[:id])
-
- avatar = Avatar.get_default('User', current_user.id)
- user = User.find(current_user.id)
- user.update_attributes(image: avatar.store_hash)
- render json: {}, status: :ok
- end
- def avatar_list
- return if !valid_session_with_user
-
- result = Avatar.list('User', current_user.id)
- render json: { avatars: result }, status: :ok
- end
- private
- def password_policy(password)
- if Setting.get('password_min_size').to_i > password.length
- return ["Can\'t update password, it must be at least %s characters long!", Setting.get('password_min_size')]
- end
- if Setting.get('password_need_digit').to_i == 1 && password !~ /\d/
- return ["Can't update password, it must contain at least 1 digit!"]
- end
- if Setting.get('password_min_2_lower_2_upper_characters').to_i == 1 && ( password !~ /[A-Z].*[A-Z]/ || password !~ /[a-z].*[a-z]/ )
- return ["Can't update password, it must contain at least 2 lowercase and 2 uppercase characters!"]
- end
- true
- end
- def permission_check_by_permission(params)
- return true if current_user.permissions?('admin.user')
- %i(role_ids roles).each do |key|
- next if !params[key]
- if current_user.permissions?('ticket.agent')
- params.delete(key)
- else
- logger.info "Role assignment is only allowed by admin! current_user_id: #{current_user.id} assigned to #{params[key].inspect}"
- raise Exceptions::NotAuthorized, 'This role assignment is only allowed by admin!'
- end
- end
- if current_user.permissions?('ticket.agent') && !params[:role_ids] && !params[:roles] && params[:id].blank?
- params[:role_ids] = Role.signup_role_ids
- end
- %i(group_ids groups).each do |key|
- next if !params[key]
- if current_user.permissions?('ticket.agent')
- params.delete(key)
- else
- logger.info "Group relation assignment is only allowed by admin! current_user_id: #{current_user.id} assigned to #{params[key].inspect}"
- raise Exceptions::NotAuthorized, 'Group relation is only allowed by admin!'
- end
- end
- return true if current_user.permissions?('ticket.agent')
- response_access_deny
- false
- end
- end
|