geqinghu/Account_monitor
1
0
Fork 0
forked from rmorgado25/Account_monitor
Code Pull requests Activity
Account_monitor/Telegram/Telegram.mqh

1224 lines
75 KiB
MQL5
Raw Permalink Normal View History

convert
2025-05-30 14:38:50 +02:00
<EFBFBD><EFBFBD>//+------------------------------------------------------------------+
//| Telegram.mqh |
//| Copyright 2014, MetaQuotes Software Corp. |
//| http://www.mql5.com |
//+------------------------------------------------------------------+
#property copyright "Copyright 2014, MetaQuotes Software Corp."
#property link "http://www.mql5.com"
#property strict
//+------------------------------------------------------------------+
//| Include |
//+------------------------------------------------------------------+
#include <Arrays\List.mqh>
#include <Arrays\ArrayString.mqh>
#include "Common.mqh"
#include "Jason.mqh"
//+------------------------------------------------------------------+
//| Defines |
//+------------------------------------------------------------------+
#define TELEGRAM_BASE_URL "https://api.telegram.org"
#define WEB_TIMEOUT 5000
//+------------------------------------------------------------------+
//| ENUM_CHAT_ACTION |
//+------------------------------------------------------------------+
enum ENUM_CHAT_ACTION
{
ACTION_FIND_LOCATION, //picking location...
ACTION_RECORD_AUDIO, //recording audio...
ACTION_RECORD_VIDEO, //recording video...
ACTION_TYPING, //typing...
ACTION_UPLOAD_AUDIO, //sending audio...
ACTION_UPLOAD_DOCUMENT, //sending file...
ACTION_UPLOAD_PHOTO, //sending photo...
ACTION_UPLOAD_VIDEO //sending video...
};
//+------------------------------------------------------------------+
//| ChatActionToString |
//+------------------------------------------------------------------+
string ChatActionToString(const ENUM_CHAT_ACTION _action)
{
string result=EnumToString(_action);
result=StringSubstr(result,7);
StringToLower(result);
return(result);
}
//+------------------------------------------------------------------+
//| |
//+------------------------------------------------------------------+
class CCustomMessage : public CObject
{
public:
bool done;
long update_id;
long message_id;
//---
long from_id;
string from_first_name;
string from_last_name;
string from_username;
//---
long chat_id;
string chat_first_name;
string chat_last_name;
string chat_username;
string chat_type;
//---
datetime message_date;
string message_text;
CCustomMessage()
{
done=false;
update_id=0;
message_id=0;
from_id=0;
from_first_name=NULL;
from_last_name=NULL;
from_username=NULL;
chat_id=0;
chat_first_name=NULL;
chat_last_name=NULL;
chat_username=NULL;
chat_type=NULL;
message_date=0;
message_text=NULL;
from_id=0;
from_first_name=NULL;
from_last_name=NULL;
from_username=NULL;
chat_id=0;
chat_first_name=NULL;
chat_last_name=NULL;
chat_username=NULL;
chat_type=NULL;
message_date=0;
message_text=NULL;
}
};
//+------------------------------------------------------------------+
//| |
//+------------------------------------------------------------------+
class CCustomChat : public CObject
{
public:
long m_id;
CCustomMessage m_last;
CCustomMessage m_new_one;
int m_state;
datetime m_time;
};
//+------------------------------------------------------------------+
//| CCustomBot |
//+------------------------------------------------------------------+
class CCustomBot
{
private:
//+------------------------------------------------------------------+
void ArrayAdd(uchar &dest[],const uchar &src[])
{
int src_size=ArraySize(src);
if(src_size==0)
return;
int dest_size=ArraySize(dest);
ArrayResize(dest,dest_size+src_size,500);
ArrayCopy(dest,src,dest_size,0,src_size);
}
//+------------------------------------------------------------------+
void ArrayAdd(char &dest[],const string text)
{
int len=StringLen(text);
if(len>0)
{
uchar src[];
for(int i=0; i<len; i++)
{
ushort ch=StringGetCharacter(text,i);
uchar array[];
int total=ShortToUtf8(ch,array);
int size=ArraySize(src);
ArrayResize(src,size+total);
ArrayCopy(src,array,size,0,total);
}
ArrayAdd(dest,src);
}
}
//+------------------------------------------------------------------+
int SaveToFile(const string filename,
const char &text[])
{
ResetLastError();
int handle=FileOpen(filename,FILE_BIN|FILE_ANSI|FILE_WRITE);
if(handle==INVALID_HANDLE)
{
return(GetLastError());
}
FileWriteArray(handle,text);
FileClose(handle);
return(0);
}
//+------------------------------------------------------------------+
string UrlEncode(const string text)
{
string result=NULL;
int length=StringLen(text);
for(int i=0; i<length; i++)
{
ushort ch=StringGetCharacter(text,i);
if((ch>=48 && ch<=57) || // 0-9
(ch>=65 && ch<=90) || // A-Z
(ch>=97 && ch<=122) || // a-z
(ch=='!') || (ch=='\'') || (ch=='(') ||
(ch==')') || (ch=='*') || (ch=='-') ||
(ch=='.') || (ch=='_') || (ch=='~')
)
{
result+=ShortToString(ch);
}
else
{
if(ch==' ')
result+=ShortToString('+');
else
{
uchar array[];
int total=ShortToUtf8(ch,array);
for(int k=0; k<total; k++)
result+=StringFormat("%%%02X",array[k]);
}
}
}
return result;
}
protected:
CList m_chats;
private:
string m_token;
string m_name;
long m_update_id;
CArrayString m_users_filter;
bool m_first_remove;
//+------------------------------------------------------------------+
int PostRequest(string &out,
const string url,
const string params,
const int timeout=5000)
{
char data[];
int data_size=StringLen(params);
StringToCharArray(params,data,0,data_size);
uchar result[];
string result_headers;
//--- application/x-www-form-urlencoded
int res=WebRequest("POST",url,NULL,NULL,timeout,data,data_size,result,result_headers);
if(res==200)//OK
{
//--- delete BOM
int start_index=0;
int size=ArraySize(result);
for(int i=0; i<fmin(size,8); i++)
{
if(result[i]==0xef || result[i]==0xbb || result[i]==0xbf)
start_index=i+1;
else
break;
}
//---
out=CharArrayToString(result,start_index,WHOLE_ARRAY,CP_UTF8);
return(0);
}
else
{
if(res==-1)
{
return(_LastError);
}
else
{
//--- HTTP errors
if(res>=100 && res<=511)
{
out=CharArrayToString(result,0,WHOLE_ARRAY,CP_UTF8);
//Print(out);
return(ERR_HTTP_ERROR_FIRST+res);
}
return(res);
}
}
return(0);
}
//+------------------------------------------------------------------+
int ShortToUtf8(const ushort _ch,uchar &out[])
{
//---
if(_ch<0x80)
{
ArrayResize(out,1);
out[0]=(uchar)_ch;
return(1);
}
//---
if(_ch<0x800)
{
ArrayResize(out,2);
out[0] = (uchar)((_ch >> 6)|0xC0);
out[1] = (uchar)((_ch & 0x3F)|0x80);
return(2);
}
//---
if(_ch<0xFFFF)
{
if(_ch>=0xD800 && _ch<=0xDFFF)//Ill-formed
{
ArrayResize(out,1);
out[0]=' ';
return(1);
}
else if(_ch>=0xE000 && _ch<=0xF8FF)//Emoji
{
int ch=0x10000|_ch;
ArrayResize(out,4);
out[0] = (uchar)(0xF0 | (ch >> 18));
out[1] = (uchar)(0x80 | ((ch >> 12) & 0x3F));
out[2] = (uchar)(0x80 | ((ch >> 6) & 0x3F));
out[3] = (uchar)(0x80 | ((ch & 0x3F)));
return(4);
}
else
{
ArrayResize(out,3);
out[0] = (uchar)((_ch>>12)|0xE0);
out[1] = (uchar)(((_ch>>6)&0x3F)|0x80);
out[2] = (uchar)((_ch&0x3F)|0x80);
return(3);
}
}
ArrayResize(out,3);
out[0] = 0xEF;
out[1] = 0xBF;
out[2] = 0xBD;
return(3);
}
//+------------------------------------------------------------------+
string StringDecode(string text)
{
//--- replace \n
StringReplace(text,"\n",ShortToString(0x0A));
//--- replace \u0000
int haut=0;
int pos=StringFind(text,"\\u");
while(pos!=-1)
{
string strcode=StringSubstr(text,pos,6);
string strhex=StringSubstr(text,pos+2,4);
StringToUpper(strhex);
int total=StringLen(strhex);
int result=0;
for(int i=0,k=total-1; i<total; i++,k--)
{
int coef=(int)pow(2,4*k);
ushort ch=StringGetCharacter(strhex,i);
if(ch>='0' && ch<='9')
result+=(ch-'0')*coef;
if(ch>='A' && ch<='F')
result+=(ch-'A'+10)*coef;
}
if(haut!=0)
{
if(result>=0xDC00 && result<=0xDFFF)
{
int dec=((haut-0xD800)<<10)+(result-0xDC00);//+0x10000;
StringReplaceEx(text,pos,6,ShortToString((ushort)dec));
haut=0;
}
else
{
//--- error: Second byte out of range
haut=0;
}
}
else
{
if(result>=0xD800 && result<=0xDBFF)
{
haut=result;
StringReplaceEx(text,pos,6,"");
}
else
{
StringReplaceEx(text,pos,6,ShortToString((ushort)result));
}
}
pos=StringFind(text,"\\u",pos);
}
return(text);
}
//+------------------------------------------------------------------+
int StringReplaceEx(string &string_var,
const int start_pos,
const int length,
const string replacement)
{
string temp=(start_pos==0)?"":StringSubstr(string_var,0,start_pos);
temp+=replacement;
temp+=StringSubstr(string_var,start_pos+length);
string_var=temp;
return(StringLen(replacement));
}
//+------------------------------------------------------------------+
string BoolToString(const bool _value)
{
if(_value)return("true");
return("false");
}
protected:
//+------------------------------------------------------------------+
string StringTrim(string text)
{
#ifdef __MQL4__
text = StringTrimLeft(text);
text = StringTrimRight(text);
#endif
#ifdef __MQL5__
StringTrimLeft(text);
StringTrimRight(text);
#endif
return(text);
}
public:
//+------------------------------------------------------------------+
void CCustomBot()
{
m_token=NULL;
m_name=NULL;
m_update_id=0;
m_first_remove=true;
m_chats.Clear();
m_users_filter.Clear();
}
//+------------------------------------------------------------------+
int ChatsTotal()
{
return(m_chats.Total());
}
//+------------------------------------------------------------------+
int Token(const string _token)
{
string token=StringTrim(_token);
if(token=="")
return(ERR_TOKEN_ISEMPTY);
//---
m_token=token;
return(0);
}
//+------------------------------------------------------------------+
void UserNameFilter(const string username_list)
{
m_users_filter.Clear();
//--- parsing
string text=StringTrim(username_list);
if(text=="")
return;
//---
while(StringReplace(text," "," ")>0);
StringReplace(text,";"," ");
StringReplace(text,","," ");
//---
string array[];
int amount=StringSplit(text,' ',array);
for(int i=0; i<amount; i++)
{
string username=StringTrim(array[i]);
if(username!="")
{
//--- remove first @
if(StringGetCharacter(username,0)=='@')
username=StringSubstr(username,1);
m_users_filter.Add(username);
}
}
}
//+------------------------------------------------------------------+
string Name()
{
return(m_name);
}
//+------------------------------------------------------------------+
int GetMe()
{
if(m_token==NULL)
return(ERR_TOKEN_ISEMPTY);
//---
string out;
string url=StringFormat("%s/bot%s/getMe",TELEGRAM_BASE_URL,m_token);
string params="";
int res=PostRequest(out,url,params,WEB_TIMEOUT);
if(res==0)
{
CJAVal js(NULL,jtUNDEF);
//---
bool done=js.Deserialize(out);
if(!done)
return(ERR_JSON_PARSING);
//---
bool ok=js["ok"].ToBool();
if(!ok)
return(ERR_JSON_NOT_OK);
//---
if(m_name==NULL)
m_name=js["result"]["username"].ToStr();
}
//---
return(res);
}
//+------------------------------------------------------------------+
int GetUpdates()
{
if(m_token==NULL)
return(ERR_TOKEN_ISEMPTY);
string out;
string url=StringFormat("%s/bot%s/getUpdates",TELEGRAM_BASE_URL,m_token);
string params=StringFormat("offset=%d",m_update_id);
//---
int res=PostRequest(out,url,params,WEB_TIMEOUT);
//if(res==0)
{
//Print(out);
//--- parse result
CJAVal js(NULL,jtUNDEF);
bool done=js.Deserialize(out);
if(!done)
return(ERR_JSON_PARSING);
bool ok=js["ok"].ToBool();
if(!ok)
return(ERR_JSON_NOT_OK);
CCustomMessage msg;
int total=ArraySize(js["result"].m_e);
for(int i=0; i<total; i++)
{
CJAVal item=js["result"].m_e[i];
//---
msg.update_id=item["update_id"].ToInt();
//---
msg.message_id=item["message"]["message_id"].ToInt();
msg.message_date=(datetime)item["message"]["date"].ToInt();
//---
msg.message_text=item["message"]["text"].ToStr();
msg.message_text=StringDecode(msg.message_text);
//---
msg.from_id=item["message"]["from"]["id"].ToInt();
msg.from_first_name=item["message"]["from"]["first_name"].ToStr();
msg.from_first_name=StringDecode(msg.from_first_name);
msg.from_last_name=item["message"]["from"]["last_name"].ToStr();
msg.from_last_name=StringDecode(msg.from_last_name);
msg.from_username=item["message"]["from"]["username"].ToStr();
msg.from_username=StringDecode(msg.from_username);
//---
msg.chat_id=item["message"]["chat"]["id"].ToInt();
msg.chat_first_name=item["message"]["chat"]["first_name"].ToStr();
msg.chat_first_name=StringDecode(msg.chat_first_name);
msg.chat_last_name=item["message"]["chat"]["last_name"].ToStr();
msg.chat_last_name=StringDecode(msg.chat_last_name);
msg.chat_username=item["message"]["chat"]["username"].ToStr();
msg.chat_username=StringDecode(msg.chat_username);
msg.chat_type=item["message"]["chat"]["type"].ToStr();
m_update_id=msg.update_id+1;
if(m_first_remove)
continue;
//--- filter
if(m_users_filter.Total()==0 || (m_users_filter.Total()>0 && m_users_filter.SearchLinear(msg.from_username)>=0))
{
//--- find the chat
int index=-1;
for(int j=0; j<m_chats.Total(); j++)
{
CCustomChat *chat=m_chats.GetNodeAtIndex(j);
if(chat.m_id==msg.chat_id)
{
index=j;
break;
}
}
//--- add new one to the chat list
if(index==-1)
{
m_chats.Add(new CCustomChat);
CCustomChat *chat=m_chats.GetLastNode();
chat.m_id=msg.chat_id;
chat.m_time=TimeLocal();
chat.m_state=0;
chat.m_new_one.message_text=msg.message_text;
chat.m_new_one.done=false;
chat.m_new_one.from_id=msg.from_id;
chat.m_new_one.from_username=msg.from_username;
chat.m_new_one.from_first_name=msg.from_first_name;
chat.m_new_one.from_last_name=msg.from_last_name;
chat.m_new_one.chat_id=msg.chat_id;
chat.m_new_one.chat_username=msg.chat_username;
chat.m_new_one.chat_first_name=msg.chat_first_name;
chat.m_new_one.chat_last_name=msg.chat_last_name;
}
//--- update chat message
else
{
CCustomChat *chat=m_chats.GetNodeAtIndex(index);
chat.m_time=TimeLocal();
chat.m_new_one.message_text=msg.message_text;
chat.m_new_one.done=false;
chat.m_new_one.from_id=msg.from_id;
chat.m_new_one.from_username=msg.from_username;
chat.m_new_one.from_first_name=msg.from_first_name;
chat.m_new_one.from_last_name=msg.from_last_name;
chat.m_new_one.chat_id=msg.chat_id;
chat.m_new_one.chat_username=msg.chat_username;
chat.m_new_one.chat_first_name=msg.chat_first_name;
chat.m_new_one.chat_last_name=msg.chat_last_name;
}
}
}
m_first_remove=false;
}
//---
return(res);
}
//+------------------------------------------------------------------+
int SendChatAction(const long _chat_id,
const ENUM_CHAT_ACTION _action)
{
if(m_token==NULL)
return(ERR_TOKEN_ISEMPTY);
string out;
string url=StringFormat("%s/bot%s/sendChatAction",TELEGRAM_BASE_URL,m_token);
string params=StringFormat("chat_id=%lld&action=%s",_chat_id,ChatActionToString(_action));
int res=PostRequest(out,url,params,WEB_TIMEOUT);
return(res);
}
//+------------------------------------------------------------------+
int SendPhoto(const long _chat_id,
const string _photo_id,
const string _caption=NULL)
{
if(m_token==NULL)
return(ERR_TOKEN_ISEMPTY);
string out;
string url=StringFormat("%s/bot%s/sendPhoto",TELEGRAM_BASE_URL,m_token);
string params=StringFormat("chat_id=%lld&photo=%s",_chat_id,_photo_id);
if(_caption!=NULL)
params+="&caption="+UrlEncode(_caption);
int res=PostRequest(out,url,params,WEB_TIMEOUT);
if(res!=0)
{
//--- parse result
CJAVal js(NULL,jtUNDEF);
bool done=js.Deserialize(out);
if(!done)
return(ERR_JSON_PARSING);
//--- get error description
bool ok=js["ok"].ToBool();
long err_code=js["error_code"].ToInt();
string err_desc=js["description"].ToStr();
}
//--- done
return(res);
}
//+------------------------------------------------------------------+
int SendPhoto(string &_photo_id,
const string _channel_name,
const string _local_path,
const string _caption=NULL,
const bool _common_flag=false,
const int _timeout=10000)
{
if(m_token==NULL)
return(ERR_TOKEN_ISEMPTY);
string name=StringTrim(_channel_name);
if(StringGetCharacter(name,0)!='@')
name="@"+name;
if(m_token==NULL)
return(ERR_TOKEN_ISEMPTY);
ResetLastError();
//--- copy file to memory buffer
if(!FileIsExist(_local_path,_common_flag))
return(ERR_FILE_NOT_EXIST);
//---
int flags=FILE_READ|FILE_BIN|FILE_SHARE_WRITE|FILE_SHARE_READ;
if(_common_flag)
flags|=FILE_COMMON;
//---
int file=FileOpen(_local_path,flags);
if(file<0)
return(_LastError);
//---
int file_size=(int)FileSize(file);
uchar photo[];
ArrayResize(photo,file_size);
FileReadArray(file,photo,0,file_size);
FileClose(file);
//--- create boundary: (data -> base64 -> 1024 bytes -> md5)
uchar base64[];
uchar key[];
CryptEncode(CRYPT_BASE64,photo,key,base64);
//---
uchar temp[1024]= {0};
ArrayCopy(temp,base64,0,0,1024);
//---
uchar md5[];
CryptEncode(CRYPT_HASH_MD5,temp,key,md5);
//---
string hash=NULL;
int total=ArraySize(md5);
for(int i=0; i<total; i++)
hash+=StringFormat("%02X",md5[i]);
hash=StringSubstr(hash,0,16);
//--- WebRequest
uchar result[];
string result_headers;
string url=StringFormat("%s/bot%s/sendPhoto",TELEGRAM_BASE_URL,m_token);
//--- 1
uchar data[];
//--- add chart_id
ArrayAdd(data,"\r\n");
ArrayAdd(data,"--"+hash+"\r\n");
ArrayAdd(data,"Content-Disposition: form-data; name=\"chat_id\"\r\n");
ArrayAdd(data,"\r\n");
ArrayAdd(data,name);
ArrayAdd(data,"\r\n");
if(StringLen(_caption)>0)
{
ArrayAdd(data,"--"+hash+"\r\n");
ArrayAdd(data,"Content-Disposition: form-data; name=\"caption\"\r\n");
ArrayAdd(data,"\r\n");
ArrayAdd(data,_caption);
ArrayAdd(data,"\r\n");
}
ArrayAdd(data,"--"+hash+"\r\n");
ArrayAdd(data,"Content-Disposition: form-data; name=\"photo\"; filename=\"lampash.gif\"\r\n");
ArrayAdd(data,"\r\n");
ArrayAdd(data,photo);
ArrayAdd(data,"\r\n");
ArrayAdd(data,"--"+hash+"--\r\n");
// SaveToFile("debug.txt",data);
//---
string headers="Content-Type: multipart/form-data; boundary="+hash+"\r\n";
int res=WebRequest("POST",url,headers,_timeout,data,result,result_headers);
if(res==200)//OK
{
//--- delete BOM
int start_index=0;
int size=ArraySize(result);
for(int i=0; i<fmin(size,8); i++)
{
if(result[i]==0xef || result[i]==0xbb || result[i]==0xbf)
start_index=i+1;
else
break;
}
//---
string out=CharArrayToString(result,start_index,WHOLE_ARRAY,CP_UTF8);
//--- parse result
CJAVal js(NULL,jtUNDEF);
bool done=js.Deserialize(out);
if(!done)
return(ERR_JSON_PARSING);
//--- get error description
bool ok=js["ok"].ToBool();
if(!ok)
return(ERR_JSON_NOT_OK);
total=ArraySize(js["result"]["photo"].m_e);
for(int i=0; i<total; i++)
{
CJAVal image=js["result"]["photo"].m_e[i];
long image_size=image["file_size"].ToInt();
if(image_size<=file_size)
_photo_id=image["file_id"].ToStr();
}
return(0);
}
else
{
if(res==-1)
{
string out=CharArrayToString(result,0,WHOLE_ARRAY,CP_UTF8);
//Print(out);
return(_LastError);
}
else
{
if(res>=100 && res<=511)
{
string out=CharArrayToString(result,0,WHOLE_ARRAY,CP_UTF8);
//Print(out);
return(ERR_HTTP_ERROR_FIRST+res);
}
return(res);
}
}
//---
return(0);
}
//+------------------------------------------------------------------+
int SendPhoto(string &_photo_id,
const long _chat_id,
const string _local_path,
const string _caption=NULL,
const bool _common_flag=false,
const int _timeout=10000)
{
if(m_token==NULL)
return(ERR_TOKEN_ISEMPTY);
ResetLastError();
//--- copy file to memory buffer
if(!FileIsExist(_local_path,_common_flag))
return(ERR_FILE_NOT_EXIST);
//---
int flags=FILE_READ|FILE_BIN|FILE_SHARE_WRITE|FILE_SHARE_READ;
if(_common_flag)
flags|=FILE_COMMON;
//---
int file=FileOpen(_local_path,flags);
if(file<0)
return(_LastError);
//---
int file_size=(int)FileSize(file);
uchar photo[];
ArrayResize(photo,file_size);
FileReadArray(file,photo,0,file_size);
FileClose(file);
//--- create boundary: (data -> base64 -> 1024 bytes -> md5)
uchar base64[];
uchar key[];
CryptEncode(CRYPT_BASE64,photo,key,base64);
//---
uchar temp[1024]= {0};
ArrayCopy(temp,base64,0,0,1024);
//---
uchar md5[];
CryptEncode(CRYPT_HASH_MD5,temp,key,md5);
//---
string hash=NULL;
int total=ArraySize(md5);
for(int i=0; i<total; i++)
hash+=StringFormat("%02X",md5[i]);
hash=StringSubstr(hash,0,16);
//--- WebRequest
uchar result[];
string result_headers;
string url=StringFormat("%s/bot%s/sendPhoto",TELEGRAM_BASE_URL,m_token);
//--- 1
uchar data[];
//--- add chart_id
ArrayAdd(data,"\r\n");
ArrayAdd(data,"--"+hash+"\r\n");
ArrayAdd(data,"Content-Disposition: form-data; name=\"chat_id\"\r\n");
ArrayAdd(data,"\r\n");
ArrayAdd(data,IntegerToString(_chat_id));
ArrayAdd(data,"\r\n");
if(StringLen(_caption)>0)
{
ArrayAdd(data,"--"+hash+"\r\n");
ArrayAdd(data,"Content-Disposition: form-data; name=\"caption\"\r\n");
ArrayAdd(data,"\r\n");
ArrayAdd(data,_caption);
ArrayAdd(data,"\r\n");
}
ArrayAdd(data,"--"+hash+"\r\n");
ArrayAdd(data,"Content-Disposition: form-data; name=\"photo\"; filename=\"lampash.gif\"\r\n");
ArrayAdd(data,"\r\n");
ArrayAdd(data,photo);
ArrayAdd(data,"\r\n");
ArrayAdd(data,"--"+hash+"--\r\n");
// SaveToFile("debug.txt",data);
//---
string headers="Content-Type: multipart/form-data; boundary="+hash+"\r\n";
int res=WebRequest("POST",url,headers,_timeout,data,result,result_headers);
if(res==200)//OK
{
//--- delete BOM
int start_index=0;
int size=ArraySize(result);
for(int i=0; i<fmin(size,8); i++)
{
if(result[i]==0xef || result[i]==0xbb || result[i]==0xbf)
start_index=i+1;
else
break;
}
//---
string out=CharArrayToString(result,start_index,WHOLE_ARRAY,CP_UTF8);
//--- parse result
CJAVal js(NULL,jtUNDEF);
bool done=js.Deserialize(out);
if(!done)
return(ERR_JSON_PARSING);
//--- get error description
bool ok=js["ok"].ToBool();
if(!ok)
return(ERR_JSON_NOT_OK);
total=ArraySize(js["result"]["photo"].m_e);
for(int i=0; i<total; i++)
{
CJAVal image=js["result"]["photo"].m_e[i];
long image_size=image["file_size"].ToInt();
if(image_size<=file_size)
_photo_id=image["file_id"].ToStr();
}
return(0);
}
else
{
if(res==-1)
{
string out=CharArrayToString(result,0,WHOLE_ARRAY,CP_UTF8);
//Print(out);
return(_LastError);
}
else
{
if(res>=100 && res<=511)
{
string out=CharArrayToString(result,0,WHOLE_ARRAY,CP_UTF8);
//Print(out);
return(ERR_HTTP_ERROR_FIRST+res);
}
return(res);
}
}
//---
return(0);
}
//+------------------------------------------------------------------+
int SendDocument(string &_document_id,
const long _chat_id,
const string _local_path,
const string _caption=NULL,
const bool _common_flag=false,
const int _timeout=10000)
{
if(m_token==NULL)
return(ERR_TOKEN_ISEMPTY);
ResetLastError();
//--- copy file to memory buffer
if(!FileIsExist(_local_path,_common_flag))
return(ERR_FILE_NOT_EXIST);
//---
int flags=FILE_READ|FILE_BIN|FILE_SHARE_WRITE|FILE_SHARE_READ;
if(_common_flag)
flags|=FILE_COMMON;
//---
int file=FileOpen(_local_path,flags);
if(file<0)
return(_LastError);
//---
int file_size=(int)FileSize(file);
uchar document[];
ArrayResize(document,file_size);
FileReadArray(file,document,0,file_size);
FileClose(file);
//--- create boundary: (data -> base64 -> 1024 bytes -> md5)
uchar base64[];
uchar key[];
CryptEncode(CRYPT_BASE64,document,key,base64);
//---
uchar temp[1024]= {0};
ArrayCopy(temp,base64,0,0,1024);
//---
uchar md5[];
CryptEncode(CRYPT_HASH_MD5,temp,key,md5);
//---
string hash=NULL;
int total=ArraySize(md5);
for(int i=0; i<total; i++)
hash+=StringFormat("%02X",md5[i]);
hash=StringSubstr(hash,0,16);
//--- WebRequest
uchar result[];
string result_headers;
string url=StringFormat("%s/bot%s/sendDocument",TELEGRAM_BASE_URL,m_token);
//--- 1
uchar data[];
//--- add chart_id
ArrayAdd(data,"\r\n");
ArrayAdd(data,"--"+hash+"\r\n");
ArrayAdd(data,"Content-Disposition: form-data; name=\"chat_id\"\r\n");
ArrayAdd(data,"\r\n");
ArrayAdd(data,IntegerToString(_chat_id));
ArrayAdd(data,"\r\n");
if(StringLen(_caption)>0)
{
ArrayAdd(data,"--"+hash+"\r\n");
ArrayAdd(data,"Content-Disposition: form-data; name=\"caption\"\r\n");
ArrayAdd(data,"\r\n");
ArrayAdd(data,_caption);
ArrayAdd(data,"\r\n");
}
ArrayAdd(data,"--"+hash+"\r\n");
ArrayAdd(data,"Content-Disposition: form-data; name=\"document\"; filename=\""+_local_path+"\"\r\n");
ArrayAdd(data,"\r\n");
ArrayAdd(data,document);
ArrayAdd(data,"\r\n");
ArrayAdd(data,"--"+hash+"--\r\n");
// SaveToFile("debug.txt",data);
//---
string headers="Content-Type: multipart/form-data; boundary="+hash+"\r\n";
int res=WebRequest("POST",url,headers,_timeout,data,result,result_headers);
if(res==200)//OK
{
//--- delete BOM
int start_index=0;
int size=ArraySize(result);
for(int i=0; i<fmin(size,8); i++)
{
if(result[i]==0xef || result[i]==0xbb || result[i]==0xbf)
start_index=i+1;
else
break;
}
//---
string out=CharArrayToString(result,start_index,WHOLE_ARRAY,CP_UTF8);
//--- parse result
CJAVal js(NULL,jtUNDEF);
bool done=js.Deserialize(out);
if(!done)
return(ERR_JSON_PARSING);
//--- get error description
bool ok=js["ok"].ToBool();
if(!ok)
return(ERR_JSON_NOT_OK);
total=ArraySize(js["result"]["document"].m_e);
for(int i=0; i<total; i++)
{
CJAVal image=js["result"]["document"].m_e[i];
long image_size=image["file_size"].ToInt();
if(image_size<=file_size)
_document_id=image["file_id"].ToStr();
}
return(0);
}
else
{
if(res==-1)
{
string out=CharArrayToString(result,0,WHOLE_ARRAY,CP_UTF8);
//Print(out);
return(_LastError);
}
else
{
if(res>=100 && res<=511)
{
string out=CharArrayToString(result,0,WHOLE_ARRAY,CP_UTF8);
//Print(out);
return(ERR_HTTP_ERROR_FIRST+res);
}
return(res);
}
}
//---
return(0);
}
//+------------------------------------------------------------------+
virtual void ProcessMessages(void);
//+------------------------------------------------------------------+
int SendMessage(const long _chat_id,
const string _text,
const string _reply_markup=NULL,
const bool _as_HTML=false,
const bool _silently=false)
{
//--- check token
if(m_token==NULL)
return(ERR_TOKEN_ISEMPTY);
string out;
string url=StringFormat("%s/bot%s/sendMessage",TELEGRAM_BASE_URL,m_token);
string params=StringFormat("chat_id=%lld&text=%s",_chat_id,UrlEncode(_text));
if(_reply_markup!=NULL)
params+="&reply_markup="+_reply_markup;
if(_as_HTML)
params+="&parse_mode=HTML";
if(_silently)
params+="&disable_notification=true";
int res=PostRequest(out,url,params,WEB_TIMEOUT);
return(res);
}
//+------------------------------------------------------------------+
int SendMessage(const string _channel_name,
const string _text,
const bool _as_HTML=false,
const bool _silently=false)
{
//--- check token
if(m_token==NULL)
return(ERR_TOKEN_ISEMPTY);
string name=StringTrim(_channel_name);
if(StringGetCharacter(name,0)!='@')
name="@"+name;
string out;
string url=StringFormat("%s/bot%s/sendMessage",TELEGRAM_BASE_URL,m_token);
string params=StringFormat("chat_id=%s&text=%s",name,UrlEncode(_text));
if(_as_HTML)
params+="&parse_mode=HTML";
if(_silently)
params+="&disable_notification=true";
// Print(params);
int res=PostRequest(out,url,params,WEB_TIMEOUT);
return(res);
}
//+------------------------------------------------------------------+
string ReplyKeyboardMarkup(const string keyboard,
const bool resize,
const bool one_time)
{
string result=StringFormat("{\"keyboard\": %s, \"one_time_keyboard\": %s, \"resize_keyboard\": %s, \"selective\": false}",UrlEncode(keyboard),BoolToString(resize),BoolToString(one_time));
return(result);
}
//+------------------------------------------------------------------+
string ReplyKeyboardHide()
{
return("{\"hide_keyboard\": true}");
}
//+------------------------------------------------------------------+
string ForceReply()
{
return("{\"force_reply\": true}");
}
};
//+------------------------------------------------------------------+
Copy permalink