1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586 |
- class ChannelsSmsController < ApplicationChannelController
- PERMISSION = 'admin.channel_sms'.freeze
- AREA = ['Sms::Notification'.freeze, 'Sms::Account'.freeze].freeze
- prepend_before_action -> { authentication_check(permission: self.class::PERMISSION) }, except: [:webhook]
- skip_before_action :verify_csrf_token, only: [:webhook]
- def index
- assets = {}
- render json: {
- account_channel_ids: channels_data('Sms::Account', assets),
- notification_channel_ids: channels_data('Sms::Notification', assets),
- config: channels_config,
- assets: assets
- }
- end
- def test
- raise 'Missing parameter options.adapter' if params[:options][:adapter].blank?
- driver = Channel.driver_class(params[:options][:adapter])
- resp = driver.new.send(params[:options], test_options)
- render json: { success: resp }
- rescue => e
- render json: { error: e.inspect, error_human: e.message }
- end
- def webhook
- raise Exceptions::UnprocessableEntity, 'token param missing' if params['token'].blank?
- channel = nil
- Channel.where(active: true, area: 'Sms::Account').each do |local_channel|
- next if local_channel.options[:webhook_token] != params['token']
- channel = local_channel
- end
- if !channel
- render(
- json: { message: 'channel not found' },
- status: :not_found
- )
- return
- end
- conten_type, content = channel.process(params.permit!.to_h)
- send_data content, type: conten_type
- end
- private
- def test_options
- params.permit(:recipient, :message)
- end
- def channel_params
- raise 'Missing area params' if params[:area].blank?
- if !self.class::AREA.include?(params[:area])
- raise "Invalid area '#{params[:area]}'!"
- end
- raise 'Missing options params' if params[:options].blank?
- raise 'Missing options.adapter params' if params[:options][:adapter].blank?
- params
- end
- def channels_config
- list = []
- Dir.glob(Rails.root.join('app', 'models', 'channel', 'driver', 'sms', '*.rb')).each do |path|
- filename = File.basename(path)
- require_dependency "channel/driver/sms/#{filename.sub('.rb', '')}"
- list.push Channel.driver_class("sms/#{filename}").definition
- end
- list
- end
- def channels_data(area, assets)
- channel_ids = []
- Channel.where(area: area).each do |channel|
- assets = channel.assets(assets)
- channel_ids.push(channel.id)
- end
- channel_ids
- end
- end
|