Slack: added im message send

1 files changed, 77 insertions, 2 deletions

diff --git a/protocols/Slack/src/slack_messages.cpp b/protocols/Slack/src/slack_messages.cpp
index f78ba3e9db..012e9451de 100644
--- a/protocols/Slack/src/slack_messages.cpp
+++ b/protocols/Slack/src/slack_messages.cpp
@@ -26,9 +26,84 @@ int CSlackProto::OnReceiveMessage(MCONTACT hContact, PROTORECVEVENT *pre)
 /* MESSAGE SENDING */
 
 // outcoming message flow
-int CSlackProto::OnSendMessage(MCONTACT hContact, int flags, const char *szMessage)
+void CSlackProto::OnMessageSent(JSONNode &root, void *arg)
 {
-	return 0;
+	SendMessageParam *param = (SendMessageParam*)arg;
+
+	if (!root)
+	{
+		ProtoBroadcastAck(param->hContact, ACKTYPE_MESSAGE, ACKRESULT_FAILED, (HANDLE)param->hMessage, (LPARAM)Translate("Unable to send message."));
+		return;
+	}
+
+	bool isOk = root["ok"].as_bool();
+	if (!isOk)
+	{
+		json_string error = root["error"].as_string();
+		debugLogA(__FUNCTION__": %s", error);
+		ProtoBroadcastAck(param->hContact, ACKTYPE_MESSAGE, ACKRESULT_FAILED, (HANDLE)param->hMessage, (LPARAM)error.c_str());
+		return;
+	}
+
+	ProtoBroadcastAck(param->hContact, ACKTYPE_MESSAGE, ACKRESULT_SUCCESS, (HANDLE)param->hMessage, 0);
+}
+
+void CSlackProto::OnImChannelOppened(JSONNode &root, void *arg)
+{
+	SendMessageParam *param = (SendMessageParam*)arg;
+
+	if (!root)
+	{
+		ProtoBroadcastAck(param->hContact, ACKTYPE_MESSAGE, ACKRESULT_FAILED, (HANDLE)param->hMessage, (LPARAM)Translate("Unable to open im channel."));
+		mir_free(param->message);
+		mir_free(param);
+		return;
+	}
+
+	bool isOk = root["ok"].as_bool();
+	if (!isOk)
+	{
+		json_string error = root["error"].as_string();
+		debugLogA(__FUNCTION__": %s", error);
+		ProtoBroadcastAck(param->hContact, ACKTYPE_MESSAGE, ACKRESULT_FAILED, (HANDLE)param->hMessage, (LPARAM)error.c_str());
+		mir_free(param->message);
+		mir_free(param);
+		return;
+	}
+
+	JSONNode channel = root["channel"].as_node();
+	json_string channelId = channel["id"].as_string();
+
+	ptrA token(getStringA("TokenSecret"));
+
+	char *message = param->message;
+	HttpRequest *request;
+	if (mir_strncmpi(message, "/me ", 4) == 0)
+	{
+		message += 4;
+		request = new SendActionRequest(token, channelId.c_str(), message);
+	}
+	else
+		request = new SendMessageRequest(token, channelId.c_str(), message);
+
+	SendRequest(request, &CSlackProto::OnMessageSent, param);
+}
+
+void CSlackProto::SendMessageThread(void *arg)
+{
+	Thread_SetName("SLACK: SendMessageThread");
+
+	SendMessageParam *param = (SendMessageParam*)arg;
+
+	ptrA token(getStringA("TokenSecret"));
+	ptrA user(getStringA(param->hContact, "UserId"));
+	SendRequest(new OpenImChannelRequest(token, user), &CSlackProto::OnImChannelOppened, param);
+}
+
+void CSlackProto::SendMessageAckThread(void *arg)
+{
+	Sleep(100);
+	ProtoBroadcastAck((MCONTACT)arg, ACKTYPE_MESSAGE, ACKRESULT_FAILED, (HANDLE)1, (LPARAM)Translate("You cannot send when you are offline"));
 }
 
 // message is received by the other side