require 'rails_helper' RSpec.describe Channel::Telegram do let(:telegram_channel) { create(:channel_telegram) } describe '#convert_markdown_to_telegram_html' do subject { telegram_channel.send(:convert_markdown_to_telegram_html, text) } context 'when text contains multiple newline characters' do let(:text) { "Line one\nLine two\n\nLine four" } it 'preserves multiple newline characters' do expect(subject).to eq("Line one\nLine two\n\nLine four") end end context 'when text contains broken markdown' do let(:text) { 'This is a **broken markdown with HTML tags.' } it 'does not break and properly converts to Telegram HTML format and escapes html tags' do expect(subject).to eq('This is a **broken markdown with <b>HTML</b> tags.') end end context 'when text contains markdown and HTML elements' do let(:text) { "Hello *world*! This is bold and this is italic.\nThis is a new line." } it 'converts markdown to Telegram HTML format and escapes other html' do expect(subject).to eq("Hello world! This is <b>bold</b> and this is <i>italic</i>.\nThis is a new line.") end end context 'when text contains unsupported HTML tags' do let(:text) { 'This is a test with unsupported tags.' } it 'removes unsupported HTML tags' do expect(subject).to eq('This is a <span>test</span> with unsupported tags.') end end context 'when text contains special characters' do let(:text) { 'Special characters: & < >' } it 'escapes special characters' do expect(subject).to eq('Special characters: & < >') end end context 'when text contains markdown links' do let(:text) { 'Check this [link](http://example.com) out!' } it 'converts markdown links to Telegram HTML format' do expect(subject).to eq('Check this link out!') end end end context 'when a valid message and empty attachments' do it 'send message' do message = create(:message, message_type: :outgoing, content: 'test', conversation: create(:conversation, inbox: telegram_channel.inbox, additional_attributes: { 'chat_id' => '123' })) stub_request(:post, "https://api.telegram.org/bot#{telegram_channel.bot_token}/sendMessage") .with( body: 'chat_id=123&text=test&reply_markup=&parse_mode=HTML&reply_to_message_id=' ) .to_return( status: 200, body: { result: { message_id: 'telegram_123' } }.to_json, headers: { 'Content-Type' => 'application/json' } ) expect(telegram_channel.send_message_on_telegram(message)).to eq('telegram_123') end it 'send message with markdown converted to telegram HTML' do message = create(:message, message_type: :outgoing, content: '**test** *test* ~test~', conversation: create(:conversation, inbox: telegram_channel.inbox, additional_attributes: { 'chat_id' => '123' })) stub_request(:post, "https://api.telegram.org/bot#{telegram_channel.bot_token}/sendMessage") .with( body: "chat_id=123&text=#{ ERB::Util.url_encode('test test ~test~') }&reply_markup=&parse_mode=HTML&reply_to_message_id=" ) .to_return( status: 200, body: { result: { message_id: 'telegram_123' } }.to_json, headers: { 'Content-Type' => 'application/json' } ) expect(telegram_channel.send_message_on_telegram(message)).to eq('telegram_123') end it 'send message with reply_markup' do message = create( :message, message_type: :outgoing, content: 'test', content_type: 'input_select', content_attributes: { 'items' => [{ 'title' => 'test', 'value' => 'test' }] }, conversation: create(:conversation, inbox: telegram_channel.inbox, additional_attributes: { 'chat_id' => '123' }) ) stub_request(:post, "https://api.telegram.org/bot#{telegram_channel.bot_token}/sendMessage") .with( body: 'chat_id=123&text=test' \ '&reply_markup=%7B%22one_time_keyboard%22%3Atrue%2C%22inline_keyboard%22%3A%5B%5B%7B%22text%22%3A%22test%22%2C%22' \ 'callback_data%22%3A%22test%22%7D%5D%5D%7D&parse_mode=HTML&reply_to_message_id=' ) .to_return( status: 200, body: { result: { message_id: 'telegram_123' } }.to_json, headers: { 'Content-Type' => 'application/json' } ) expect(telegram_channel.send_message_on_telegram(message)).to eq('telegram_123') end it 'sends message with business_connection_id' do additional_attributes = { 'chat_id' => '123', 'business_connection_id' => 'eooW3KF5WB5HxTD7T826' } message = create(:message, message_type: :outgoing, content: 'test', conversation: create(:conversation, inbox: telegram_channel.inbox, additional_attributes: additional_attributes)) stub_request(:post, "https://api.telegram.org/bot#{telegram_channel.bot_token}/sendMessage") .with( body: 'chat_id=123&text=test&reply_markup=&parse_mode=HTML&reply_to_message_id=&business_connection_id=eooW3KF5WB5HxTD7T826' ) .to_return( status: 200, body: { result: { message_id: 'telegram_123' } }.to_json, headers: { 'Content-Type' => 'application/json' } ) expect(telegram_channel.send_message_on_telegram(message)).to eq('telegram_123') end it 'send text message failed' do message = create(:message, message_type: :outgoing, content: 'test', conversation: create(:conversation, inbox: telegram_channel.inbox, additional_attributes: { 'chat_id' => '123' })) stub_request(:post, "https://api.telegram.org/bot#{telegram_channel.bot_token}/sendMessage") .with( body: 'chat_id=123&text=test&reply_markup=&parse_mode=HTML&reply_to_message_id=' ) .to_return( status: 403, headers: { 'Content-Type' => 'application/json' }, body: { ok: false, error_code: '403', description: 'Forbidden: bot was blocked by the user' }.to_json ) telegram_channel.send_message_on_telegram(message) expect(message.reload.status).to eq('failed') expect(message.reload.external_error).to eq('403, Forbidden: bot was blocked by the user') end end context 'when message contains attachments' do let(:message) do create(:message, message_type: :outgoing, content: nil, conversation: create(:conversation, inbox: telegram_channel.inbox, additional_attributes: { 'chat_id' => '123' })) end it 'calls send attachment service' do telegram_attachment_service = double attachment = message.attachments.new(account_id: message.account_id, file_type: :image) attachment.file.attach(io: Rails.root.join('spec/assets/avatar.png').open, filename: 'avatar.png', content_type: 'image/png') allow(Telegram::SendAttachmentsService).to receive(:new).with(message: message).and_return(telegram_attachment_service) allow(telegram_attachment_service).to receive(:perform).and_return('telegram_456') expect(telegram_channel.send_message_on_telegram(message)).to eq('telegram_456') end end end