1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039 |
- # Copyright (C) 2012-2025 Zammad Foundation, https://zammad-foundation.org/
- class UsersController < ApplicationController
- include ChecksUserAttributesByCurrentUserPermission
- include CanPaginate
- prepend_before_action -> { authorize! }, only: %i[import_example import_start search history unlock]
- prepend_before_action :authentication_check, except: %i[create password_reset_send password_reset_verify image email_verify email_verify_send admin_password_auth_send admin_password_auth_verify]
- prepend_before_action :authentication_check_only, only: %i[create]
- # @path [GET] /users
- #
- # @summary Returns a list of User records.
- # @notes The requester has to be in the role 'Admin' or 'Agent' to
- # get a list of all Users. If the requester is in the
- # role 'Customer' only just the own User record will be returned.
- #
- # @response_message 200 [Array<User>] List of matching User records.
- # @response_message 403 Forbidden / Invalid session.
- def index
- users = policy_scope(User).reorder(id: :asc).offset(pagination.offset).limit(pagination.limit)
- if response_expand?
- list = users.map(&:attributes_with_association_names)
- render json: list, status: :ok
- return
- end
- if response_full?
- assets = {}
- item_ids = []
- users.each do |item|
- item_ids.push item.id
- assets = item.assets(assets)
- end
- render json: {
- record_ids: item_ids,
- assets: assets,
- }, status: :ok
- return
- end
- users_all = users.map do |user|
- User.lookup(id: user.id).attributes_with_association_ids
- end
- render json: users_all, status: :ok
- end
- # @path [GET] /users/{id}
- #
- # @summary Returns the User record with the requested identifier.
- # @notes The requester has to be in the role 'Admin' or 'Agent' to
- # access all User records. If the requester is in the
- # role 'Customer' just the own User record is accessable.
- #
- # @parameter id(required) [Integer] The identifier matching the requested User.
- # @parameter full [Bool] If set a Asset structure with all connected Assets gets returned.
- #
- # @response_message 200 [User] User record matching the requested identifier.
- # @response_message 403 Forbidden / Invalid session.
- def show
- user = User.find(params[:id])
- authorize!(user)
- if response_expand?
- result = user.attributes_with_association_names
- result.delete('password')
- render json: result
- return
- end
- if response_full?
- result = {
- id: user.id,
- assets: user.assets({}),
- }
- render json: result
- return
- end
- result = user.attributes_with_association_ids
- result.delete('password')
- render json: result
- end
- # @path [POST] /users
- #
- # @summary processes requests as CRUD-like record creation, admin creation or user signup depending on circumstances
- # @see #create_internal #create_admin #create_signup
- def create
- if current_user
- create_internal
- elsif params[:signup]
- create_signup
- else
- create_admin
- end
- end
- # @path [PUT] /users/{id}
- #
- # @summary Updates the User record matching the identifier with the provided attribute values.
- # @notes TODO.
- #
- # @parameter id(required) [Integer] The identifier matching the requested User record.
- # @parameter User(required,body) [User] The attribute value structure needed to update a User record.
- #
- # @response_message 200 [User] Updated User record.
- # @response_message 403 Forbidden / Invalid session.
- def update
- user = User.find(params[:id])
- authorize!(user)
- # permission check
- check_attributes_by_current_user_permission(params)
- user.with_lock do
- clean_params = User.association_name_to_id_convert(params)
- clean_params = User.param_cleanup(clean_params, true)
- clean_params[:screen] = 'edit'
- # presence and permissions were checked via `check_attributes_by_current_user_permission`
- privileged_attributes = params.slice(:role_ids, :roles, :group_ids, :groups, :organization_ids, :organizations)
- if privileged_attributes.present?
- user.associations_from_param(privileged_attributes)
- end
- user.update!(clean_params)
- end
- if response_expand?
- user = user.reload.attributes_with_association_names
- user.delete('password')
- render json: user, status: :ok
- return
- end
- if response_full?
- result = {
- id: user.id,
- assets: user.assets({}),
- }
- render json: result, status: :ok
- return
- end
- user = user.reload.attributes_with_association_ids
- user.delete('password')
- render json: user, status: :ok
- end
- # @path [DELETE] /users/{id}
- #
- # @summary Deletes the User record matching the given identifier.
- # @notes The requester has to be in the role 'Admin' to be able to delete a User record.
- #
- # @parameter id(required) [User] The identifier matching the requested User record.
- #
- # @response_message 200 User successfully deleted.
- # @response_message 403 Forbidden / Invalid session.
- def destroy
- user = User.find(params[:id])
- authorize!(user)
- model_references_check(User, params)
- model_destroy_render(User, params)
- end
- # @path [GET] /users/me
- #
- # @summary Returns the User record of current user.
- # @notes The requester needs to have a valid authentication.
- #
- # @parameter full [Bool] If set a Asset structure with all connected Assets gets returned.
- #
- # @response_message 200 [User] User record matching the requested identifier.
- # @response_message 403 Forbidden / Invalid session.
- def me
- if response_expand?
- user = current_user.attributes_with_association_names
- user.delete('password')
- render json: user, status: :ok
- return
- end
- if response_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
- # @path [GET] /users/search
- #
- # @tag Search
- # @tag User
- #
- # @summary Searches the User matching the given expression(s).
- # @notes TODO: It's possible to use the SOLR search syntax.
- # The requester has to be in the role 'Admin' or 'Agent' to
- # be able to search for User records.
- #
- # @parameter query [String] The search query.
- # @parameter limit [Integer] The limit of search results.
- # @parameter ids(multi) [Array<Integer>] A list of User IDs which should be returned
- # @parameter role_ids(multi) [Array<Integer>] A list of Role identifiers to which the Users have to be allocated to.
- # @parameter group_ids(multi) [Hash<String=>Integer,Array<Integer>>] A list of Group identifiers to which the Users have to be allocated to.
- # @parameter permissions(multi) [Array<String>] A list of Permission identifiers to which the Users have to be allocated to.
- # @parameter full [Boolean] Defines if the result should be
- # true: { user_ids => [1,2,...], assets => {...} }
- # or false: [{:id => user.id, :label => "firstname lastname <email>", :value => "firstname lastname <email>"},...].
- #
- # @response_message 200 [Array<User>] A list of User records matching the search term.
- # @response_message 403 Forbidden / Invalid session.
- def search
- query = params[:query]
- if query.respond_to?(:permit!)
- query.permit!.to_h
- end
- query = params[:query] || params[:term]
- if query.respond_to?(:permit!)
- query = query.permit!.to_h
- end
- query_params = {
- query: query,
- limit: pagination.limit,
- offset: pagination.offset,
- sort_by: params[:sort_by],
- order_by: params[:order_by],
- current_user: current_user,
- }
- %i[ids role_ids group_ids permissions].each do |key|
- next if params[key].blank?
- query_params[key] = params[key]
- end
- # do query
- user_all = User.search(query_params)
- if response_expand?
- list = user_all.map(&:attributes_with_association_names)
- render json: list, status: :ok
- return
- end
- # build result list
- if params[:label] || params[:term]
- users = []
- user_all.each do |user|
- realname = user.fullname
- # improve realname, if possible
- if user.email.present? && realname != user.email
- begin
- realname = Channel::EmailBuild.recipient_line(realname, user.email)
- rescue Mail::Field::IncompleteParseError
- # mute if parsing of recipient_line was not successful / #5166
- end
- end
- a = if params[:term]
- { id: user.id, label: realname, value: user.email, inactive: !user.active }
- else
- { id: user.id, label: realname, value: realname }
- end
- users.push a
- end
- # return result
- render json: users
- return
- end
- if response_full?
- user_ids = []
- assets = {}
- user_all.each do |user|
- assets = user.assets(assets)
- user_ids.push user.id
- end
- # return result
- render json: {
- assets: assets,
- user_ids: user_ids.uniq,
- }
- return
- end
- list = user_all.map(&:attributes_with_association_ids)
- render json: list, status: :ok
- end
- # @path [GET] /users/history/{id}
- #
- # @tag History
- # @tag User
- #
- # @summary Returns the History records of a User record matching the given identifier.
- # @notes The requester has to be in the role 'Admin' or 'Agent' to
- # get the History records of a User record.
- #
- # @parameter id(required) [Integer] The identifier matching the requested User record.
- #
- # @response_message 200 [History] The History records of the requested User record.
- # @response_message 403 Forbidden / Invalid session.
- def history
- # get user data
- user = User.find(params[:id])
- # get history of user
- render json: user.history_get(true)
- end
- # @path [PUT] /users/unlock/{id}
- #
- # @summary Unlocks the User record matching the identifier.
- # @notes The requester have 'admin.user' permissions to be able to unlock a user.
- #
- # @parameter id(required) [Integer] The identifier matching the requested User record.
- #
- # @response_message 200 Unlocked User record.
- # @response_message 403 Forbidden / Invalid session.
- def unlock
- user = User.find(params[:id])
- user.with_lock do
- user.update!(login_failed: 0)
- end
- render json: { message: 'ok' }, status: :ok
- end
- =begin
- Resource:
- POST /api/v1/users/email_verify
- Payload:
- {
- "token": "SoMeToKeN",
- }
- Response:
- {
- :message => 'ok'
- }
- Test:
- curl http://localhost/api/v1/users/email_verify -v -u #{login}:#{password} -H "Content-Type: application/json" -X POST -d '{"token": "SoMeToKeN"}'
- =end
- def email_verify
- raise Exceptions::UnprocessableEntity, __('No token!') if !params[:token]
- verify = Service::User::SignupVerify.new(token: params[:token], current_user: current_user)
- begin
- user = verify.execute
- rescue Service::CheckFeatureEnabled::FeatureDisabledError, Service::User::SignupVerify::InvalidTokenError => e
- raise Exceptions::UnprocessableEntity, e.message
- end
- current_user_set(user) if user
- msg = user ? { message: 'ok', user_email: user.email } : { message: 'failed' }
- render json: msg, status: :ok
- end
- =begin
- Resource:
- POST /api/v1/users/email_verify_send
- Payload:
- {
- "email": "some_email@example.com"
- }
- Response:
- {
- :message => 'ok'
- }
- Test:
- curl http://localhost/api/v1/users/email_verify_send -v -u #{login}:#{password} -H "Content-Type: application/json" -X POST -d '{"email": "some_email@example.com"}'
- =end
- def email_verify_send
- raise Exceptions::UnprocessableEntity, __('No email!') if !params[:email]
- signup = Service::User::Deprecated::Signup.new(user_data: { email: params[:email] }, resend: true)
- begin
- signup.execute
- rescue Service::CheckFeatureEnabled::FeatureDisabledError => e
- raise Exceptions::UnprocessableEntity, e.message
- rescue Service::User::Signup::TokenGenerationError
- render json: { message: 'failed' }, status: :ok
- end
- # Result is always positive to avoid leaking of existing user accounts.
- render json: { message: 'ok' }, status: :ok
- end
- =begin
- Resource:
- POST /api/v1/users/admin_login
- Payload:
- {
- "username": "some user name"
- }
- Response:
- {
- :message => 'ok'
- }
- Test:
- curl http://localhost/api/v1/users/admin_login -v -u #{login}:#{password} -H "Content-Type: application/json" -X POST -d '{"username": "some_username"}'
- =end
- def admin_password_auth_send
- raise Exceptions::UnprocessableEntity, 'username param needed!' if params[:username].blank?
- send = Service::Auth::Deprecated::SendAdminToken.new(login: params[:username])
- begin
- send.execute
- rescue Service::CheckFeatureEnabled::FeatureDisabledError => e
- raise Exceptions::UnprocessableEntity, e.message
- rescue Service::Auth::Deprecated::SendAdminToken::TokenError, Service::Auth::Deprecated::SendAdminToken::EmailError
- render json: { message: 'failed' }, status: :ok
- return
- end
- render json: { message: 'ok' }, status: :ok
- end
- def admin_password_auth_verify
- raise Exceptions::UnprocessableEntity, 'token param needed!' if params[:token].blank?
- verify = Service::Auth::VerifyAdminToken.new(token: params[:token])
- user = begin
- verify.execute
- rescue => e
- raise Exceptions::UnprocessableEntity, e.message
- end
- msg = user ? { message: 'ok', user_login: user.login } : { message: 'failed' }
- render json: msg, status: :ok
- end
- =begin
- Resource:
- POST /api/v1/users/password_reset
- Payload:
- {
- "username": "some user name"
- }
- Response:
- {
- :message => 'ok'
- }
- Test:
- curl http://localhost/api/v1/users/password_reset -v -u #{login}:#{password} -H "Content-Type: application/json" -X POST -d '{"username": "some_username"}'
- =end
- def password_reset_send
- raise Exceptions::UnprocessableEntity, 'username param needed!' if params[:username].blank?
- send = Service::User::PasswordReset::Deprecated::Send.new(username: params[:username])
- begin
- send.execute
- rescue Service::CheckFeatureEnabled::FeatureDisabledError => e
- raise Exceptions::UnprocessableEntity, e.message
- rescue Service::User::PasswordReset::Send::EmailError
- render json: { message: 'failed' }, status: :ok
- return
- end
- # Result is always positive to avoid leaking of existing user accounts.
- render json: { message: 'ok' }, status: :ok
- end
- =begin
- Resource:
- POST /api/v1/users/password_reset_verify
- Payload:
- {
- "token": "SoMeToKeN",
- "password": "new_pw"
- }
- Response:
- {
- :message => 'ok'
- }
- Test:
- curl http://localhost/api/v1/users/password_reset_verify -v -u #{login}:#{password} -H "Content-Type: application/json" -X POST -d '{"token": "SoMeToKeN", "password": "new_pw"}'
- =end
- def password_reset_verify
- raise Exceptions::UnprocessableEntity, 'token param needed!' if params[:token].blank?
- # If no password is given, verify token only.
- if params[:password].blank?
- verify = Service::User::PasswordReset::Verify.new(token: params[:token])
- begin
- user = verify.execute
- rescue Service::CheckFeatureEnabled::FeatureDisabledError => e
- raise Exceptions::UnprocessableEntity, e.message
- rescue Service::User::PasswordReset::Verify::InvalidTokenError
- render json: { message: 'failed' }, status: :ok
- return
- end
- render json: { message: 'ok', user_login: user.login }, status: :ok
- return
- end
- update = Service::User::PasswordReset::Update.new(token: params[:token], password: params[:password])
- begin
- user = update.execute
- rescue Service::CheckFeatureEnabled::FeatureDisabledError => e
- raise Exceptions::UnprocessableEntity, e.message
- rescue Service::User::PasswordReset::Update::InvalidTokenError, Service::User::PasswordReset::Update::EmailError
- render json: { message: 'failed' }, status: :ok
- return
- rescue PasswordPolicy::Error => e
- render json: { message: 'failed', notice: e.metadata }, status: :ok
- return
- end
- render json: { message: 'ok', user_login: user.login }, status: :ok
- end
- =begin
- Resource:
- POST /api/v1/users/password_change
- Payload:
- {
- "password_old": "old_pw",
- "password_new": "new_pw"
- }
- Response:
- {
- :message => 'ok'
- }
- Test:
- curl http://localhost/api/v1/users/password_change -v -u #{login}:#{password} -H "Content-Type: application/json" -X POST -d '{"password_old": "old_pw", "password_new": "new_pw"}'
- =end
- def password_change
- # check old password
- if !params[:password_old] || !PasswordPolicy::MaxLength.valid?(params[:password_old])
- render json: { message: 'failed', notice: [__('Please provide your current password.')] }, status: :unprocessable_entity
- return
- end
- # set new password
- if !params[:password_new]
- render json: { message: 'failed', notice: [__('Please provide your new password.')] }, status: :unprocessable_entity
- return
- end
- begin
- Service::User::ChangePassword.new(
- user: current_user,
- current_password: params[:password_old],
- new_password: params[:password_new]
- ).execute
- rescue PasswordPolicy::Error => e
- render json: { message: 'failed', notice: e.metadata }, status: :unprocessable_entity
- return
- rescue PasswordHash::Error
- render json: { message: 'failed', notice: [__('The current password you provided is incorrect.')] }, status: :unprocessable_entity
- return
- end
- render json: { message: 'ok', user_login: current_user.login }, status: :ok
- end
- def password_check
- raise Exceptions::UnprocessableEntity, __("The required parameter 'password' is missing.") if params[:password].blank?
- password_check = Service::User::PasswordCheck.new(user: current_user, password: params[:password])
- render json: { success: password_check.execute }, status: :ok
- end
- =begin
- Resource:
- PUT /api/v1/users/preferences
- Payload:
- {
- "language": "de",
- "notification": true
- }
- Response:
- {
- :message => 'ok'
- }
- Test:
- curl http://localhost/api/v1/users/preferences -v -u #{login}:#{password} -H "Content-Type: application/json" -X PUT -d '{"language": "de", "notifications": true}'
- =end
- def preferences
- preferences_params = params.except(:controller, :action)
- if preferences_params.present?
- user = User.find(current_user.id)
- user.with_lock do
- preferences_params.permit!.to_h.each do |key, value|
- user.preferences[key.to_sym] = value
- end
- user.save!
- end
- end
- render json: { message: 'ok' }, status: :ok
- end
- =begin
- Resource:
- POST /api/v1/users/preferences_reset
- Response:
- {
- :message => 'ok'
- }
- Test:
- curl http://localhost/api/v1/users/preferences_reset -v -u #{login}:#{password} -H "Content-Type: application/json" -X POST'
- =end
- def preferences_notifications_reset
- User.reset_notifications_preferences!(current_user)
- render json: { message: 'ok' }, status: :ok
- end
- =begin
- Resource:
- PUT /api/v1/users/out_of_office
- Payload:
- {
- "out_of_office": true,
- "out_of_office_start_at": true,
- "out_of_office_end_at": true,
- "out_of_office_replacement_id": 123,
- "out_of_office_text": 'honeymoon'
- }
- Response:
- {
- :message => 'ok'
- }
- Test:
- curl http://localhost/api/v1/users/out_of_office -v -u #{login}:#{password} -H "Content-Type: application/json" -X PUT -d '{"out_of_office": true, "out_of_office_replacement_id": 123}'
- =end
- def out_of_office
- user = User.find(current_user.id)
- Service::User::OutOfOffice
- .new(user,
- enabled: params[:out_of_office],
- start_at: params[:out_of_office_start_at],
- end_at: params[:out_of_office_end_at],
- replacement: User.find_by(id: params[:out_of_office_replacement_id]),
- text: params[:out_of_office_text])
- .execute
- render json: { message: 'ok' }, status: :ok
- end
- =begin
- Resource:
- DELETE /api/v1/users/account
- Payload:
- {
- "provider": "twitter",
- "uid": 581482342942
- }
- Response:
- {
- :message => 'ok'
- }
- Test:
- curl http://localhost/api/v1/users/account -v -u #{login}:#{password} -H "Content-Type: application/json" -X PUT -d '{"provider": "twitter", "uid": 581482342942}'
- =end
- def account_remove
- # provider + uid to remove
- raise Exceptions::UnprocessableEntity, 'provider needed!' if !params[:provider]
- raise Exceptions::UnprocessableEntity, 'uid needed!' if !params[:uid]
- Service::User::RemoveLinkedAccount.new(provider: params[:provider], uid: params[:uid], current_user:).execute
- render json: { message: 'ok' }, status: :ok
- end
- =begin
- Resource:
- GET /api/v1/users/image/8d6cca1c6bdc226cf2ba131e264ca2c7
- Response:
- <IMAGE>
- Test:
- curl http://localhost/api/v1/users/image/8d6cca1c6bdc226cf2ba131e264ca2c7 -v -u #{login}:#{password}
- =end
- def image
- # Cache images in the browser.
- expires_in(1.year.from_now, must_revalidate: true)
- file = Avatar.get_by_hash(params[:hash])
- if file
- file_content_type = file.preferences['Content-Type'] || file.preferences['Mime-Type']
- return serve_default_image if ActiveStorage.content_types_allowed_inline.exclude?(file_content_type)
- send_data(
- file.content,
- filename: file.filename,
- type: file_content_type,
- disposition: 'inline'
- )
- return
- end
- serve_default_image
- end
- =begin
- Resource:
- POST /api/v1/users/avatar
- Payload:
- {
- "avatar_full": "base64 url",
- }
- Response:
- {
- message: 'ok'
- }
- Test:
- curl http://localhost/api/v1/users/avatar -v -u #{login}:#{password} -H "Content-Type: application/json" -X POST -d '{"avatar": "base64 url"}'
- =end
- def avatar_new
- service = Service::Avatar::ImageValidate.new
- file_full = service.execute(image_data: params[:avatar_full])
- if file_full[:error].present?
- render json: { error: file_full[:message] }, status: :unprocessable_entity
- return
- end
- file_resize = service.execute(image_data: params[:avatar_resize])
- if file_resize[:error].present?
- render json: { error: file_resize[:message] }, status: :unprocessable_entity
- return
- end
- render json: { avatar: Service::Avatar::Add.new(current_user: current_user).execute(full_image: file_full, resize_image: file_resize) }, status: :ok
- end
- def avatar_set_default
- # get & validate image
- raise Exceptions::UnprocessableEntity, __("The required parameter 'id' is missing.") if !params[:id]
- # set as default
- avatar = Avatar.set_default('User', current_user.id, params[:id])
- # update user link
- user = User.find(current_user.id)
- user.update!(image: avatar.store_hash)
- render json: {}, status: :ok
- end
- def avatar_destroy
- # get & validate image
- raise Exceptions::UnprocessableEntity, __("The required parameter 'id' is missing.") if !params[:id]
- # remove avatar
- Avatar.remove_one('User', current_user.id, params[:id])
- # update user link
- if (avatar = Avatar.get_default('User', current_user.id))
- user = User.find(current_user.id)
- user.update!(image: avatar.store_hash)
- end
- render json: {}, status: :ok
- end
- def avatar_list
- # list of avatars
- result = Avatar.list('User', current_user.id)
- render json: { avatars: result }, status: :ok
- end
- # @path [GET] /users/import_example
- #
- # @summary Download of example CSV file.
- # @notes The requester have 'admin.user' permissions to be able to download it.
- # @example curl -u #{login}:#{password} http://localhost:3000/api/v1/users/import_example
- #
- # @response_message 200 File download.
- # @response_message 403 Forbidden / Invalid session.
- def import_example
- send_data(
- User.csv_example,
- filename: 'user-example.csv',
- type: 'text/csv',
- disposition: 'attachment'
- )
- end
- # @path [POST] /users/import
- #
- # @summary Starts import.
- # @notes The requester have 'admin.text_module' permissions to be create a new import.
- # @example curl -u #{login}:#{password} -F 'file=@/path/to/file/users.csv' 'https://your.zammad/api/v1/users/import?try=true'
- # @example curl -u #{login}:#{password} -F 'file=@/path/to/file/users.csv' 'https://your.zammad/api/v1/users/import'
- #
- # @response_message 201 Import started.
- # @response_message 403 Forbidden / Invalid session.
- def import_start
- string = params[:data]
- if string.blank? && params[:file].present?
- string = params[:file].read.force_encoding('utf-8')
- end
- raise Exceptions::UnprocessableEntity, __('No source data submitted!') if string.blank?
- result = User.csv_import(
- string: string,
- parse_params: {
- col_sep: params[:col_sep] || ',',
- },
- try: params[:try],
- delete: params[:delete],
- )
- render json: result, status: :ok
- end
- def two_factor_enabled_authentication_methods
- user = User.find(params[:id])
- render json: { methods: user.two_factor_enabled_authentication_methods }, status: :ok
- end
- private
- def password_login?
- return true if Setting.get('user_show_password_login')
- return true if Setting.where('name LIKE ? AND frontend = true', "#{SqlHelper.quote_like('auth_')}%")
- .map { |provider| provider.state_current['value'] }
- .all?(false)
- false
- end
- def clean_user_params
- User.param_cleanup(User.association_name_to_id_convert(params), true).merge(screen: 'create')
- end
- # @summary Creates a User record with the provided attribute values.
- # @notes For creating a user via agent interface
- #
- # @parameter User(required,body) [User] The attribute value structure needed to create a User record.
- #
- # @response_message 200 [User] Created User record.
- # @response_message 403 Forbidden / Invalid session.
- def create_internal
- # permission check
- check_attributes_by_current_user_permission(params)
- user = User.new(clean_user_params)
- user.associations_from_param(params)
- user.save!
- if params[:invite].present?
- 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 response_expand?
- user = user.reload.attributes_with_association_names
- user.delete('password')
- render json: user, status: :created
- return
- end
- if response_full?
- result = {
- id: user.id,
- assets: user.assets({}),
- }
- render json: result, status: :created
- return
- end
- user = user.reload.attributes_with_association_ids
- user.delete('password')
- render json: user, status: :created
- end
- # @summary Creates a User record with the provided attribute values.
- # @notes For creating a user via public signup form
- #
- # @parameter User(required,body) [User] The attribute value structure needed to create a User record.
- #
- # @response_message 200 [User] Created User record.
- # @response_message 403 Forbidden / Invalid session.
- def create_signup
- # check signup option only after admin account is created
- if !params[:signup]
- raise Exceptions::UnprocessableEntity, __("The required parameter 'signup' is missing.")
- end
- # only allow fixed fields
- # TODO: https://github.com/zammad/zammad/issues/3295
- new_params = clean_user_params.slice(:firstname, :lastname, :email, :password)
- # check if user already exists
- if new_params[:email].blank?
- raise Exceptions::UnprocessableEntity, __("The required attribute 'email' is missing.")
- end
- signup = Service::User::Deprecated::Signup.new(user_data: new_params)
- begin
- signup.execute
- rescue PasswordPolicy::Error => e
- render json: { message: 'failed', notice: e.metadata }, status: :unprocessable_entity
- return
- rescue Service::CheckFeatureEnabled::FeatureDisabledError => e
- raise Exceptions::UnprocessableEntity, e.message
- end
- render json: { message: 'ok' }, status: :created
- end
- # @summary Creates a User record with the provided attribute values.
- # @notes For creating an administrator account when setting up the system
- #
- # @parameter User(required,body) [User] The attribute value structure needed to create a User record.
- #
- # @response_message 200 [User] Created User record.
- # @response_message 403 Forbidden / Invalid session.
- def create_admin
- Service::User::AddFirstAdmin.new.execute(
- user_data: clean_user_params.slice(:firstname, :lastname, :email, :password),
- request: request,
- )
- render json: { message: 'ok' }, status: :created
- rescue PasswordPolicy::Error => e
- render json: { message: 'failed', notice: e.metadata }, status: :unprocessable_entity
- rescue Exceptions::MissingAttribute, Service::System::CheckSetup::SystemSetupError => e
- raise Exceptions::UnprocessableEntity, e.message
- end
- def serve_default_image
- image = 'R0lGODdhMAAwAOMAAMzMzJaWlr6+vqqqqqOjo8XFxbe3t7GxsZycnAAAAAAAAAAAAAAAAAAAAAAAAAAAACwAAAAAMAAwAAAEcxDISau9OOvNu/9gKI5kaZ5oqq5s675wLM90bd94ru98TwuAA+KQAQqJK8EAgBAgMEqmkzUgBIeSwWGZtR5XhSqAULACCoGCJGwlm1MGQrq9RqgB8fm4ZTUgDBIEcRR9fz6HiImKi4yNjo+QkZKTlJWWkBEAOw=='
- send_data(
- Base64.decode64(image),
- filename: 'image.gif',
- type: 'image/gif',
- disposition: 'inline'
- )
- end
- end
|