123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114 |
- class ChannelsSmsController < ApplicationController
- prepend_before_action -> { authentication_check && authorize! }, 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 show
- model_show_render(Channel, params)
- end
- def create
- model_create_render(Channel, channel_params)
- end
- def update
- model_update_render(Channel, channel_params)
- end
- def enable
- channel.update!(active: true)
- render json: channel
- end
- def disable
- channel.update!(active: false)
- render json: channel
- end
- def destroy
- channel.destroy!
- render json: {}
- 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 channel
- @channel ||= Channel.lookup(id: params[:id])
- end
- def test_options
- params.permit(:recipient, :message)
- end
- def channel_params
- raise 'Missing area params' if params[:area].blank?
- if ['Sms::Notification', 'Sms::Account'].exclude?(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
|