mirror of
https://github.com/MCCTeam/Minecraft-Console-Client
synced 2025-10-14 21:22:49 +00:00
VkMessagercs: New Methods and VK API version update (#1319)
* New Methods and VK API version update * Update VkMessager.cs * Update VkMessager.cs * Fix code indenting Co-authored-by: ORelio <ORelio@users.noreply.github.com>
This commit is contained in:
Рома Данилов
GitHub
parent
28f47cc532
commit
2eba2149b7
1 changed files with 390 additions and 343 deletions
|
|
@ -35,362 +35,409 @@ MCC.LoadBot(new VkMessager(vkToken, chatId, botCommunityId));
|
||||||
/// </summary>
|
/// </summary>
|
||||||
internal class VkLongPoolClient
|
internal class VkLongPoolClient
|
||||||
{
|
{
|
||||||
/* VK Client*/
|
/* VK Client*/
|
||||||
public VkLongPoolClient(string token, string botCommunityId, Action<string, string, string, string, string, string> onMessageReceivedCallback, IWebProxy webProxy = null)
|
public VkLongPoolClient(string token, string botCommunityId, Action<string, string, string, string, string, string> onMessageReceivedCallback, IWebProxy webProxy = null)
|
||||||
{
|
{
|
||||||
Token = token;
|
Token = token;
|
||||||
BotCommunityId = botCommunityId;
|
BotCommunityId = botCommunityId;
|
||||||
OnMessageReceivedCallback = onMessageReceivedCallback;
|
OnMessageReceivedCallback = onMessageReceivedCallback;
|
||||||
ReceiverWebClient = new WebClient() { Proxy = webProxy, Encoding = Encoding.UTF8 };
|
ReceiverWebClient = new WebClient() { Proxy = webProxy, Encoding = Encoding.UTF8 };
|
||||||
SenderWebClient = new WebClient() { Proxy = webProxy, Encoding = Encoding.UTF8 };
|
SenderWebClient = new WebClient() { Proxy = webProxy, Encoding = Encoding.UTF8 };
|
||||||
|
|
||||||
Init();
|
Init();
|
||||||
StartLongPoolAsync();
|
StartLongPoolAsync();
|
||||||
}
|
}
|
||||||
private WebClient ReceiverWebClient { get; set; }
|
|
||||||
private WebClient SenderWebClient { get; set; }
|
|
||||||
private string Token { get; set; }
|
|
||||||
private int LastTs { get; set; }
|
|
||||||
private string Server { get; set; }
|
|
||||||
private string Key { get; set; }
|
|
||||||
private Action<string, string, string, string, string, string> OnMessageReceivedCallback { get; set; }
|
|
||||||
private string BotCommunityId { get; set; }
|
|
||||||
private Random rnd = new Random();
|
|
||||||
|
|
||||||
/* Utils */
|
private WebClient ReceiverWebClient { get; set; }
|
||||||
public string Utils_GetShortLink(string url)
|
private WebClient SenderWebClient { get; set; }
|
||||||
{
|
private string Token { get; set; }
|
||||||
if (Uri.IsWellFormedUriString(url, UriKind.Absolute))
|
private int LastTs { get; set; }
|
||||||
{
|
private string Server { get; set; }
|
||||||
string json = CallVkMethod("utils.getShortLink", "url=" + url);
|
private string Key { get; set; }
|
||||||
var j = JsonConvert.DeserializeObject(json) as JObject;
|
private Action<string, string, string, string, string, string> OnMessageReceivedCallback { get; set; }
|
||||||
var link = j["response"]["short_url"].ToString();
|
private string BotCommunityId { get; set; }
|
||||||
if (link == "") return Utils_GetShortLink(url);
|
private Random rnd = new Random();
|
||||||
else return link;
|
|
||||||
}
|
|
||||||
else return "Invalid link format";
|
|
||||||
}
|
|
||||||
/* Docs */
|
|
||||||
public string Docs_GetMessagesUploadServer(string peer_id, string type, string file)
|
|
||||||
{
|
|
||||||
string string1 = CallVkMethod("docs.getMessagesUploadServer", "peer_id=" + peer_id + "&type=" + type);
|
|
||||||
if (string1 != "")
|
|
||||||
{
|
|
||||||
string uploadurl = Regex.Match(string1, "\"upload_url\":\"(.*)\"").Groups[1].Value.Replace(@"\/", "/");
|
|
||||||
return uploadurl;
|
|
||||||
}
|
|
||||||
else return Docs_GetMessagesUploadServer(peer_id, type, file);
|
|
||||||
}
|
|
||||||
public string Docs_Upload(string url, string file)
|
|
||||||
{
|
|
||||||
var c = new WebClient();
|
|
||||||
var r2 = Encoding.UTF8.GetString(c.UploadFile(url, "POST", file));
|
|
||||||
if (r2 != "") return r2;
|
|
||||||
else return Docs_Upload(url, file);
|
|
||||||
}
|
|
||||||
public string Docs_Save(string file, string title)
|
|
||||||
{
|
|
||||||
var j2 = JsonConvert.DeserializeObject(file) as JObject;
|
|
||||||
string json = CallVkMethod("docs.save", "&file=" + j2["file"].ToString() + "&title=" + title);
|
|
||||||
if (json != "")
|
|
||||||
return json;
|
|
||||||
else return Docs_Save(file, title);
|
|
||||||
}
|
|
||||||
public string Docs_Get_Send_Attachment(string file)
|
|
||||||
{
|
|
||||||
var j3 = JsonConvert.DeserializeObject(file) as JObject;
|
|
||||||
var at = "doc" + j3["response"]["doc"]["owner_id"].ToString() + "_" + j3["response"]["doc"]["id"].ToString();
|
|
||||||
return at;
|
|
||||||
}
|
|
||||||
/* Groups */
|
|
||||||
public void Groups_Online(bool enable = true)
|
|
||||||
{
|
|
||||||
if (enable)
|
|
||||||
string json = CallVkMethod("groups.enableOnline", "group_id=" + BotCommunityId);
|
|
||||||
if (json == "")
|
|
||||||
Groups_Online(enable);
|
|
||||||
else
|
|
||||||
string json = CallVkMethod("groups.disableOnline", "group_id=" + BotCommunityId);
|
|
||||||
if (json == "")
|
|
||||||
Groups_Online(enable);
|
|
||||||
}
|
|
||||||
public string Groups_GetById_GetName(string group_id)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
string js = CallVkMethod("groups.getById", "group_id=" + group_id);
|
|
||||||
if (js != "")
|
|
||||||
{
|
|
||||||
var j3 = JsonConvert.DeserializeObject(js) as JObject;
|
|
||||||
string name = j3["response"][0]["name"].ToString();
|
|
||||||
return name;
|
|
||||||
}
|
|
||||||
else return Groups_GetById_GetName(group_id);
|
|
||||||
} catch { return ""; }
|
|
||||||
}
|
|
||||||
/* Users */
|
|
||||||
public string Users_Get_FirstName(string user_id)
|
|
||||||
{
|
|
||||||
string js = CallVkMethod("users.get", "user_ids=" + user_id);
|
|
||||||
if (js != "")
|
|
||||||
{
|
|
||||||
var j3 = JsonConvert.DeserializeObject(js) as JObject;
|
|
||||||
string name = j3["response"][0]["first_name"].ToString();
|
|
||||||
return name;
|
|
||||||
}
|
|
||||||
else return Users_Get_FirstName(user_id);
|
|
||||||
}
|
|
||||||
/* Messages */
|
|
||||||
public void Messages_Kick_Group(string chat_id, string user_id)
|
|
||||||
{
|
|
||||||
if (user_id != BotCommunityId)
|
|
||||||
{
|
|
||||||
string json = CallVkMethod("messages.removeChatUser", "chat_id=" + chat_id + "&member_id=" + "-" + user_id);
|
|
||||||
if (json == "")
|
|
||||||
Messages_Kick_Group(chat_id, user_id);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
public void Messages_Kick_User(string chat_id, string user_id)
|
|
||||||
{
|
|
||||||
string json = CallVkMethod("messages.removeChatUser", "chat_id=" + chat_id + "&user_id=" + user_id + "&member_id=" + user_id);
|
|
||||||
if (json == "")
|
|
||||||
Messages_Kick_User(chat_id, user_id);
|
|
||||||
}
|
|
||||||
public void Messages_SetActivity(string chatId, string type = "typing")
|
|
||||||
{
|
|
||||||
string id3 = chatId;
|
|
||||||
id3 = id3.Substring(1);
|
|
||||||
int ind = Convert.ToInt32(id3);
|
|
||||||
CallVkMethod("messages.setActivity", "user_id=" + BotCommunityId + "&peer_id=" + chatId + "&group_id=" + "&type=" + type + "&group_id=" + BotCommunityId);
|
|
||||||
CallVkMethod("messages.setActivity", "user_id=" + BotCommunityId + "&peer_id=" + ind + "&type=" + type + "&group_id=" + BotCommunityId);
|
|
||||||
}
|
|
||||||
public string Messages_GetInviteLink(string chatId, bool reset)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
string json = CallVkMethod("messages.getInviteLink", "peer_id=" + chatId + "&group_id=" + BotCommunityId);
|
|
||||||
if (json != "")
|
|
||||||
{
|
|
||||||
var j = JsonConvert.DeserializeObject(json) as JObject;
|
|
||||||
var link = j["response"]["link"].ToString();
|
|
||||||
if (link == "")
|
|
||||||
return Messages_GetInviteLink(chatId, reset);
|
|
||||||
else return link;
|
|
||||||
}
|
|
||||||
else return Messages_GetInviteLink(chatId, reset);
|
|
||||||
} catch { return Messages_GetInviteLink(chatId, reset); }
|
|
||||||
}
|
|
||||||
/* Messages Send */
|
|
||||||
public void Messages_Send_Text(string chatId, string text)
|
|
||||||
{
|
|
||||||
string reply = CallVkMethod("messages.send", "peer_id=" + chatId + "&random_id=" + rnd.Next() + "&message=" + text);
|
|
||||||
if (reply == "")
|
|
||||||
Messages_Send_Text(chatId, text);
|
|
||||||
}
|
|
||||||
public void Messages_Send_Keyboard(string chatId, Keyboard keyboard)
|
|
||||||
{
|
|
||||||
string kb = keyboard.GetKeyboard();
|
|
||||||
string reply = CallVkMethod("messages.send", "peer_id=" + chatId + "&random_id=" + rnd.Next() + "&keyboard=" + kb);
|
|
||||||
if (reply == "")
|
|
||||||
Messages_Send_Keyboard(chatId, keyboard);
|
|
||||||
}
|
|
||||||
public void Messages_Send_TextAndKeyboard(string chatId, string text, Keyboard keyboard)
|
|
||||||
{
|
|
||||||
string kb = keyboard.GetKeyboard();
|
|
||||||
string reply = CallVkMethod("messages.send", "peer_id=" + chatId + "&random_id=" + rnd.Next() + "&message=" + text + "&keyboard=" + kb);
|
|
||||||
if (reply == "")
|
|
||||||
Messages_Send_TextAndKeyboard(chatId, text, keyboard);
|
|
||||||
}
|
|
||||||
public void Messages_Send_Sticker(string chatId, int sticker_id)
|
|
||||||
{
|
|
||||||
string reply = CallVkMethod("messages.send", "peer_id=" + chatId + "&random_id=" + rnd.Next() + "&sticker_id=" + sticker_id);
|
|
||||||
if (reply == "")
|
|
||||||
Messages_Send_Sticker(chatId, sticker_id);
|
|
||||||
}
|
|
||||||
public void Messages_Send_TextAndDocument(string chatId, string text, string file, string title)
|
|
||||||
{
|
|
||||||
string u2 = Docs_GetMessagesUploadServer(chatId, "doc", file);
|
|
||||||
string r2 = Docs_Upload(u2, file);
|
|
||||||
string r3 = Docs_Save(r2, title);
|
|
||||||
string at = Docs_Get_Send_Attachment(r3);
|
|
||||||
string reply = CallVkMethod("messages.send", "peer_id=" + chatId + "&random_id=" + rnd.Next() + "&message=" + text + "&attachment=" + at);
|
|
||||||
if (reply == "")
|
|
||||||
Messages_Send_TextAndDocument(chatId, text, file, title);
|
|
||||||
}
|
|
||||||
public void Messages_Send_Custom(string chatId, string custom)
|
|
||||||
{
|
|
||||||
string reply = CallVkMethod("messages.send", "peer_id=" + chatId + "&random_id=" + rnd.Next() + custom);
|
|
||||||
if (reply == "")
|
|
||||||
Messages_Send_Custom(chatId, custom);
|
|
||||||
}
|
|
||||||
/* Messages GetConversationMembers*/
|
|
||||||
public int Messages_GetConversationMembers_GetCount(string chatId)
|
|
||||||
{
|
|
||||||
var json = CallVkMethod("messages.getConversationMembers", "peer_id=" + chatId + "&group_id=" + BotCommunityId);
|
|
||||||
if (json != "")
|
|
||||||
{
|
|
||||||
var j = JsonConvert.DeserializeObject(json) as JObject;
|
|
||||||
int u2 = int.Parse(j["response"]["count"].ToString());
|
|
||||||
return u2;
|
|
||||||
}
|
|
||||||
else return Messages_GetConversationMembers_GetCount(chatId);
|
|
||||||
}
|
|
||||||
public string Messages_GetConversationMembers_GetProfiles(string chatId)
|
|
||||||
{
|
|
||||||
var json = CallVkMethod("messages.getConversationMembers", "peer_id=" + chatId + "&group_id=" + BotCommunityId);
|
|
||||||
if (json != "")
|
|
||||||
{
|
|
||||||
string ids = "";
|
|
||||||
JObject json1 = JObject.Parse(json);
|
|
||||||
IList<JToken> results = json1["response"]["profiles"].Children().ToList();
|
|
||||||
foreach (JToken result in results)
|
|
||||||
{
|
|
||||||
string id = result["id"].ToString();
|
|
||||||
if (!id.Contains("-"))
|
|
||||||
ids += id + ", ";
|
|
||||||
}
|
|
||||||
return ids;
|
|
||||||
}
|
|
||||||
else return Messages_GetConversationMembers_GetProfiles(chatId);
|
|
||||||
}
|
|
||||||
public string Messages_GetConversationMembers_GetItems_member_id(string chatId)
|
|
||||||
{
|
|
||||||
var json = CallVkMethod("messages.getConversationMembers", "peer_id=" + chatId + "&group_id=" + BotCommunityId);
|
|
||||||
if (json != "")
|
|
||||||
{
|
|
||||||
string ids = "";
|
|
||||||
JObject json1 = JObject.Parse(json);
|
|
||||||
IList<JToken> results = json1["response"]["items"].Children().ToList();
|
|
||||||
foreach (JToken result in results)
|
|
||||||
{
|
|
||||||
string id = result["member_id"].ToString();
|
|
||||||
if (!id.Contains("-"))
|
|
||||||
ids += id + ", ";
|
|
||||||
}
|
|
||||||
return ids;
|
|
||||||
}
|
|
||||||
else return Messages_GetConversationMembers_GetItems_member_id(chatId);
|
|
||||||
}
|
|
||||||
|
|
||||||
public class Keyboard
|
/* Utils */
|
||||||
{
|
public string Utils_GetShortLink(string url)
|
||||||
public bool one_time = false;
|
{
|
||||||
public List<List<object>> buttons = new List<List<object>>();
|
if (Uri.IsWellFormedUriString(url, UriKind.Absolute))
|
||||||
public bool inline = false;
|
|
||||||
public Keyboard(bool one_time2, bool line = false)
|
|
||||||
{
|
|
||||||
if (line == true && one_time2 == true)
|
|
||||||
one_time2 = false;
|
|
||||||
|
|
||||||
one_time = one_time2;
|
|
||||||
inline = line;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void AddButton(string label, string payload, string color)
|
|
||||||
{
|
|
||||||
Buttons button = new Buttons(label, payload, color);
|
|
||||||
buttons.Add(new List<object>() { button });
|
|
||||||
}
|
|
||||||
public string GetKeyboard()
|
|
||||||
{
|
{
|
||||||
return JsonConvert.SerializeObject(this, Formatting.Indented); ;
|
string json = CallVkMethod("utils.getShortLink", "url=" + url);
|
||||||
|
var j = JsonConvert.DeserializeObject(json) as JObject;
|
||||||
|
var link = j["response"]["short_url"].ToString();
|
||||||
|
if (link == "")
|
||||||
|
return Utils_GetShortLink(url);
|
||||||
|
else
|
||||||
|
return link;
|
||||||
}
|
}
|
||||||
public class Buttons
|
else
|
||||||
{
|
return "Invalid link format";
|
||||||
public Action action;
|
}
|
||||||
public string color;
|
|
||||||
public Buttons(string labe11, string payload1, string color2)
|
|
||||||
{
|
|
||||||
action = new Action(labe11, payload1);
|
|
||||||
color = color2;
|
|
||||||
}
|
|
||||||
|
|
||||||
public class Action
|
/* Docs */
|
||||||
{
|
public string Docs_GetMessagesUploadServer(string peer_id, string type, string file)
|
||||||
public string type;
|
{
|
||||||
public string payload;
|
string string1 = CallVkMethod("docs.getMessagesUploadServer", "peer_id=" + peer_id + "&type=" + type);
|
||||||
public string label;
|
if (string1 != "")
|
||||||
public Action(string label3, string payload3)
|
{
|
||||||
{
|
string uploadurl = Regex.Match(string1, "\"upload_url\":\"(.*)\"").Groups[1].Value.Replace(@"\/", "/");
|
||||||
type = "text";
|
return uploadurl;
|
||||||
payload = "{\"button\": \"" + payload3 + "\"}";
|
}
|
||||||
label = label3;
|
else
|
||||||
}
|
return Docs_GetMessagesUploadServer(peer_id, type, file);
|
||||||
}
|
}
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/* LoongPool */
|
|
||||||
private void Init()
|
|
||||||
{
|
|
||||||
var jsonResult = CallVkMethod("groups.getLongPollServer", "group_id=" + BotCommunityId);
|
|
||||||
var data = Json.ParseJson(jsonResult);
|
|
||||||
|
|
||||||
Key = data.Properties["response"].Properties["key"].StringValue;
|
public string Docs_Upload(string url, string file)
|
||||||
Server = data.Properties["response"].Properties["server"].StringValue;
|
{
|
||||||
LastTs = Convert.ToInt32(data.Properties["response"].Properties["ts"].StringValue);
|
var c = new WebClient();
|
||||||
}
|
var r2 = Encoding.UTF8.GetString(c.UploadFile(url, "POST", file));
|
||||||
private void StartLongPoolAsync()
|
if (r2 != "") return r2;
|
||||||
{
|
else return Docs_Upload(url, file);
|
||||||
Task.Factory.StartNew(() =>
|
}
|
||||||
{
|
|
||||||
while (true)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
string baseUrl = String.Format("{0}?act=a_check&version=2&wait=25&key={1}&ts=", Server, Key);
|
|
||||||
var data = ReceiverWebClient.DownloadString(baseUrl + LastTs);
|
|
||||||
var messages = ProcessResponse(data);
|
|
||||||
|
|
||||||
foreach (var message in messages)
|
public string Docs_Save(string file, string title)
|
||||||
{
|
{
|
||||||
OnMessageReceivedCallback(message.Item1, message.Item2, message.Item3, message.Item4, message.Item5, message.Item6);
|
var j2 = JsonConvert.DeserializeObject(file) as JObject;
|
||||||
}
|
if (j2 != null)
|
||||||
|
{
|
||||||
|
string json = CallVkMethod("docs.save", "&file=" + j2["file"].ToString() + "&title=" + title);
|
||||||
|
if (json != "")
|
||||||
|
return json;
|
||||||
|
else return "";
|
||||||
|
}
|
||||||
|
else return "";
|
||||||
|
}
|
||||||
|
|
||||||
}
|
public string Docs_Get_Send_Attachment(string file)
|
||||||
catch { }
|
{
|
||||||
}
|
var j3 = JsonConvert.DeserializeObject(file) as JObject;
|
||||||
});
|
var at = "doc" + j3["response"]["doc"]["owner_id"].ToString() + "_" + j3["response"]["doc"]["id"].ToString();
|
||||||
}
|
return at;
|
||||||
|
}
|
||||||
|
|
||||||
private IEnumerable<Tuple<string, string, string, string, string, string>> ProcessResponse(string jsonData)
|
/* Groups */
|
||||||
{
|
public void Groups_Online(bool enable = true)
|
||||||
var j = JsonConvert.DeserializeObject(jsonData) as JObject;
|
{
|
||||||
var data = Json.ParseJson(jsonData);
|
if (enable)
|
||||||
if (data.Properties.ContainsKey("failed"))
|
CallVkMethod("groups.enableOnline", "group_id=" + BotCommunityId);
|
||||||
{
|
else
|
||||||
Init();
|
CallVkMethod("groups.disableOnline", "group_id=" + BotCommunityId);
|
||||||
}
|
}
|
||||||
LastTs = Convert.ToInt32(data.Properties["ts"].StringValue);
|
|
||||||
var updates = data.Properties["updates"].DataArray;
|
|
||||||
List<Tuple<string, string, string, string, string, string>> messages = new List<Tuple<string, string, string, string, string, string>>();
|
|
||||||
foreach (var str in updates)
|
|
||||||
{
|
|
||||||
if (str.Properties["type"].StringValue != "message_new") continue;
|
|
||||||
|
|
||||||
var msgData = str.Properties["object"].Properties;
|
public string Groups_GetById_GetName(string group_id)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
string js = CallVkMethod("groups.getById", "group_id=" + group_id);
|
||||||
|
if (js != "")
|
||||||
|
{
|
||||||
|
var j3 = JsonConvert.DeserializeObject(js) as JObject;
|
||||||
|
string name = j3["response"][0]["name"].ToString();
|
||||||
|
return name;
|
||||||
|
}
|
||||||
|
else return "";
|
||||||
|
}
|
||||||
|
catch { return ""; }
|
||||||
|
}
|
||||||
|
|
||||||
var id = msgData["from_id"].StringValue;
|
/* Messages */
|
||||||
var userId = msgData["from_id"].StringValue;
|
public void Messages_Kick_Group(string chat_id, string user_id)
|
||||||
var peer_id = msgData["peer_id"].StringValue;
|
{
|
||||||
string event_id = "";
|
if (user_id != BotCommunityId)
|
||||||
var msgText = msgData["text"].StringValue;
|
{
|
||||||
var conversation_message_id = msgData["conversation_message_id"].StringValue;
|
string json = CallVkMethod("messages.removeChatUser", "chat_id=" + chat_id + "&member_id=" + "-" + user_id);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
messages.Add(new Tuple<string, string, string, string, string, string>(userId, peer_id, msgText, conversation_message_id, id, event_id));
|
public void Messages_Kick_User(string chat_id, string user_id)
|
||||||
}
|
{
|
||||||
|
string json = CallVkMethod("messages.removeChatUser", "chat_id=" + chat_id + "&user_id=" + user_id + "&member_id=" + user_id);
|
||||||
|
}
|
||||||
|
|
||||||
return messages;
|
public void Messages_SetActivity(string chatId, string type = "typing")
|
||||||
}
|
{
|
||||||
|
string id3 = chatId;
|
||||||
|
id3 = id3.Substring(1);
|
||||||
|
int ind = Convert.ToInt32(id3);
|
||||||
|
CallVkMethod("messages.setActivity", "user_id=" + BotCommunityId + "&peer_id=" + chatId + "&group_id=" + "&type=" + type + "&group_id=" + BotCommunityId);
|
||||||
|
CallVkMethod("messages.setActivity", "user_id=" + BotCommunityId + "&peer_id=" + ind + "&type=" + type + "&group_id=" + BotCommunityId);
|
||||||
|
}
|
||||||
|
|
||||||
public string CallVkMethod(string methodName, string data)
|
public string Messages_GetInviteLink(string chatId, bool reset)
|
||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
var url = String.Format("https://api.vk.com/method/{0}?v=5.122&access_token={1}&{2}", methodName, Token, data);
|
string json = CallVkMethod("messages.getInviteLink", "peer_id=" + chatId + "&group_id=" + BotCommunityId);
|
||||||
var jsonResult = SenderWebClient.DownloadString(url);
|
if (json != "")
|
||||||
return jsonResult;
|
{
|
||||||
}
|
var j = JsonConvert.DeserializeObject(json) as JObject;
|
||||||
catch { return String.Empty; }
|
var link = j["response"]["link"].ToString();
|
||||||
}
|
return link;
|
||||||
|
}
|
||||||
|
return "";
|
||||||
|
}
|
||||||
|
catch { return ""; }
|
||||||
|
}
|
||||||
|
|
||||||
|
/* Users */
|
||||||
|
public string Users_Get_First_Name(string user_id, string name_case = "nom")
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
string json = CallVkMethod("users.get", "user_ids=" + user_id + "&name_case=" + name_case);
|
||||||
|
if (json != "")
|
||||||
|
{
|
||||||
|
var firstname = Regex.Match(json, "{\"first_name\":\"(.*)\",\"id\":(.*)").Groups[1].Value;
|
||||||
|
return firstname;
|
||||||
|
}
|
||||||
|
return "";
|
||||||
|
}
|
||||||
|
catch { return ""; }
|
||||||
|
}
|
||||||
|
|
||||||
|
public string Users_Get_Last_Name(string user_id)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
string json = CallVkMethod("users.get", "user_ids=" + user_id);
|
||||||
|
if (json != "")
|
||||||
|
{
|
||||||
|
var firstname = Regex.Match(json, "\"id\":(.*),\"last_name\":\"(.*)\",\"can_access_closed\":(.*)").Groups[2].Value;
|
||||||
|
return firstname;
|
||||||
|
}
|
||||||
|
return "";
|
||||||
|
}
|
||||||
|
catch { return ""; }
|
||||||
|
}
|
||||||
|
|
||||||
|
/* Messages Send */
|
||||||
|
public void Messages_Send_Text(string chatId, string text, int disable_mentions = 0)
|
||||||
|
{
|
||||||
|
string reply = CallVkMethod("messages.send", "peer_id=" + chatId + "&random_id=" + rnd.Next() + "&message=" + text + "&disable_mentions=" + disable_mentions);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void Messages_Send_Keyboard(string chatId, Keyboard keyboard)
|
||||||
|
{
|
||||||
|
string kb = keyboard.GetKeyboard();
|
||||||
|
string reply = CallVkMethod("messages.send", "peer_id=" + chatId + "&random_id=" + rnd.Next() + "&keyboard=" + kb);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void Messages_Send_TextAndKeyboard(string chatId, string text, Keyboard keyboard)
|
||||||
|
{
|
||||||
|
string kb = keyboard.GetKeyboard();
|
||||||
|
string reply = CallVkMethod("messages.send", "peer_id=" + chatId + "&random_id=" + rnd.Next() + "&message=" + text + "&keyboard=" + kb);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void Messages_Send_Sticker(string chatId, int sticker_id)
|
||||||
|
{
|
||||||
|
string reply = CallVkMethod("messages.send", "peer_id=" + chatId + "&random_id=" + rnd.Next() + "&sticker_id=" + sticker_id);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void Messages_Send_TextAndDocument(string chatId, string text, string file, string title)
|
||||||
|
{
|
||||||
|
string u2 = Docs_GetMessagesUploadServer(chatId, "doc", file);
|
||||||
|
string r2 = Docs_Upload(u2, file);
|
||||||
|
string r3 = Docs_Save(r2, title);
|
||||||
|
string at = Docs_Get_Send_Attachment(r3);
|
||||||
|
string reply = CallVkMethod("messages.send", "peer_id=" + chatId + "&random_id=" + rnd.Next() + "&message=" + text + "&attachment=" + at);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void Messages_Send_Custom(string chatId, string custom)
|
||||||
|
{
|
||||||
|
string reply = CallVkMethod("messages.send", "peer_id=" + chatId + "&random_id=" + rnd.Next() + custom);
|
||||||
|
}
|
||||||
|
|
||||||
|
/* Messages GetConversationMembers*/
|
||||||
|
public int Messages_GetConversationMembers_GetCount(string chatId)
|
||||||
|
{
|
||||||
|
var json = CallVkMethod("messages.getConversationMembers", "peer_id=" + chatId + "&group_id=" + BotCommunityId);
|
||||||
|
if (json != "")
|
||||||
|
{
|
||||||
|
var j = JsonConvert.DeserializeObject(json) as JObject;
|
||||||
|
int u2 = int.Parse(j["response"]["count"].ToString());
|
||||||
|
return u2;
|
||||||
|
}
|
||||||
|
else return -1;
|
||||||
|
}
|
||||||
|
|
||||||
|
public string Messages_GetConversationMembers_GetProfiles(string chatId)
|
||||||
|
{
|
||||||
|
var json = CallVkMethod("messages.getConversationMembers", "peer_id=" + chatId + "&group_id=" + BotCommunityId);
|
||||||
|
if (json != "")
|
||||||
|
{
|
||||||
|
string ids = "";
|
||||||
|
JObject json1 = JObject.Parse(json);
|
||||||
|
IList<JToken> results = json1["response"]["profiles"].Children().ToList();
|
||||||
|
foreach (JToken result in results)
|
||||||
|
{
|
||||||
|
string id = result["id"].ToString();
|
||||||
|
if (!id.Contains("-"))
|
||||||
|
ids += id + ", ";
|
||||||
|
}
|
||||||
|
return ids;
|
||||||
|
}
|
||||||
|
return "";
|
||||||
|
}
|
||||||
|
|
||||||
|
public string Messages_GetConversationMembers_GetItems_member_id(string chatId)
|
||||||
|
{
|
||||||
|
var json = CallVkMethod("messages.getConversationMembers", "peer_id=" + chatId + "&group_id=" + BotCommunityId);
|
||||||
|
if (json != "")
|
||||||
|
{
|
||||||
|
string ids = "";
|
||||||
|
JObject json1 = JObject.Parse(json);
|
||||||
|
IList<JToken> results = json1["response"]["items"].Children().ToList();
|
||||||
|
foreach (JToken result in results)
|
||||||
|
{
|
||||||
|
string id = result["member_id"].ToString();
|
||||||
|
if (!id.Contains("-"))
|
||||||
|
ids += id + ", ";
|
||||||
|
}
|
||||||
|
return ids;
|
||||||
|
}
|
||||||
|
return "";
|
||||||
|
}
|
||||||
|
|
||||||
|
public class Keyboard
|
||||||
|
{
|
||||||
|
public enum Color
|
||||||
|
{
|
||||||
|
Negative,
|
||||||
|
Positive,
|
||||||
|
Primary,
|
||||||
|
Secondary
|
||||||
|
}
|
||||||
|
|
||||||
|
public bool one_time = false;
|
||||||
|
public List<List<object>> buttons = new List<List<object>>();
|
||||||
|
public bool inline = false;
|
||||||
|
|
||||||
|
public Keyboard(bool one_time2, bool line = false)
|
||||||
|
{
|
||||||
|
if (line == true && one_time2 == true)
|
||||||
|
one_time2 = false;
|
||||||
|
one_time = one_time2;
|
||||||
|
inline = line;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void AddButton(string label, string payload, Color color)
|
||||||
|
{
|
||||||
|
string color2 = "";
|
||||||
|
if (color == Color.Negative)
|
||||||
|
color2 = "Negative";
|
||||||
|
else if (color == Color.Positive)
|
||||||
|
color2 = "Positive";
|
||||||
|
else if (color == Color.Primary)
|
||||||
|
color2 = "Primary";
|
||||||
|
else
|
||||||
|
color2 = "Secondary";
|
||||||
|
Buttons button = new Buttons(label, payload, color2);
|
||||||
|
buttons.Add(new List<object>() { button });
|
||||||
|
}
|
||||||
|
|
||||||
|
public string GetKeyboard()
|
||||||
|
{
|
||||||
|
return JsonConvert.SerializeObject(this, Formatting.Indented); ;
|
||||||
|
}
|
||||||
|
|
||||||
|
public class Buttons
|
||||||
|
{
|
||||||
|
public Action action;
|
||||||
|
public string color;
|
||||||
|
public Buttons(string labe11, string payload1, string color2)
|
||||||
|
{
|
||||||
|
action = new Action(labe11, payload1);
|
||||||
|
color = color2;
|
||||||
|
}
|
||||||
|
|
||||||
|
public class Action
|
||||||
|
{
|
||||||
|
public string type;
|
||||||
|
public string payload;
|
||||||
|
public string label;
|
||||||
|
public Action(string label3, string payload3)
|
||||||
|
{
|
||||||
|
type = "text";
|
||||||
|
payload = "{\"button\": \"" + payload3 + "\"}";
|
||||||
|
label = label3;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/* LoongPool */
|
||||||
|
private void Init()
|
||||||
|
{
|
||||||
|
var jsonResult = CallVkMethod("groups.getLongPollServer", "group_id=" + BotCommunityId);
|
||||||
|
var data = Json.ParseJson(jsonResult);
|
||||||
|
|
||||||
|
Key = data.Properties["response"].Properties["key"].StringValue;
|
||||||
|
Server = data.Properties["response"].Properties["server"].StringValue;
|
||||||
|
LastTs = Convert.ToInt32(data.Properties["response"].Properties["ts"].StringValue);
|
||||||
|
}
|
||||||
|
|
||||||
|
private void StartLongPoolAsync()
|
||||||
|
{
|
||||||
|
Task.Factory.StartNew(() =>
|
||||||
|
{
|
||||||
|
while (true)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
string baseUrl = String.Format("{0}?act=a_check&version=2&wait=25&key={1}&ts=", Server, Key);
|
||||||
|
var data = ReceiverWebClient.DownloadString(baseUrl + LastTs);
|
||||||
|
var messages = ProcessResponse(data);
|
||||||
|
|
||||||
|
foreach (var message in messages)
|
||||||
|
{
|
||||||
|
OnMessageReceivedCallback(message.Item1, message.Item2, message.Item3, message.Item4, message.Item5, message.Item6);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
catch { }
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
private IEnumerable<Tuple<string, string, string, string, string, string>> ProcessResponse(string jsonData)
|
||||||
|
{
|
||||||
|
var j = JsonConvert.DeserializeObject(jsonData) as JObject;
|
||||||
|
var data = Json.ParseJson(jsonData);
|
||||||
|
if (data.Properties.ContainsKey("failed"))
|
||||||
|
{
|
||||||
|
Init();
|
||||||
|
}
|
||||||
|
LastTs = Convert.ToInt32(data.Properties["ts"].StringValue);
|
||||||
|
var updates = data.Properties["updates"].DataArray;
|
||||||
|
List<Tuple<string, string, string, string, string, string>> messages = new List<Tuple<string, string, string, string, string, string>>();
|
||||||
|
foreach (var str in updates)
|
||||||
|
{
|
||||||
|
if (str.Properties["type"].StringValue != "message_new") continue;
|
||||||
|
|
||||||
|
var msgData = str.Properties["object"].Properties;
|
||||||
|
|
||||||
|
var id = msgData["from_id"].StringValue;
|
||||||
|
var userId = msgData["from_id"].StringValue;
|
||||||
|
var peer_id = msgData["peer_id"].StringValue;
|
||||||
|
string event_id = "";
|
||||||
|
var msgText = msgData["text"].StringValue;
|
||||||
|
var conversation_message_id = msgData["conversation_message_id"].StringValue;
|
||||||
|
|
||||||
|
messages.Add(new Tuple<string, string, string, string, string, string>(userId, peer_id, msgText, conversation_message_id, id, event_id));
|
||||||
|
}
|
||||||
|
|
||||||
|
return messages;
|
||||||
|
}
|
||||||
|
|
||||||
|
public string CallVkMethod(string methodName, string data)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
var url = String.Format("https://api.vk.com/method/{0}?v=5.124&access_token={1}&{2}", methodName, Token, data);
|
||||||
|
var jsonResult = SenderWebClient.DownloadString(url);
|
||||||
|
|
||||||
|
return jsonResult;
|
||||||
|
}
|
||||||
|
catch { return String.Empty; }
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue