mirror of
https://github.com/Adaptix-Framework/AdaptixC2
synced 2026-06-08 10:20:39 +00:00
Ralf
686 lines
23 KiB
C++
686 lines
23 KiB
C++
#include <UI/Widgets/AdaptixWidget.h>
|
|
|
|
bool AdaptixWidget::isValidSyncPacket(QJsonObject jsonObj)
|
|
{
|
|
if ( !jsonObj.contains("type") || !jsonObj["type"].isDouble() )
|
|
return false;
|
|
|
|
int spType = jsonObj["type"].toDouble();
|
|
|
|
if( spType == TYPE_SYNC_START ) {
|
|
if ( !jsonObj.contains("count") || !jsonObj["count"].isDouble() ) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
if( spType == TYPE_SYNC_FINISH ) {
|
|
return true;
|
|
}
|
|
|
|
if(spType == SP_TYPE_EVENT) {
|
|
if ( !jsonObj.contains("event_type") || !jsonObj["event_type"].isDouble() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("date") || !jsonObj["date"].isDouble() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("message") || !jsonObj["message"].isString() ) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
if( spType == TYPE_LISTENER_REG ) {
|
|
if ( !jsonObj.contains("fn") || !jsonObj["fn"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("ui") || !jsonObj["ui"].isString() ) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
if( spType == TYPE_LISTENER_START || spType == TYPE_LISTENER_EDIT ) {
|
|
if ( !jsonObj.contains("l_name") || !jsonObj["l_name"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("l_type") || !jsonObj["l_type"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("l_bind_host") || !jsonObj["l_bind_host"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("l_bind_port") || !jsonObj["l_bind_port"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("l_agent_host") || !jsonObj["l_agent_host"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("l_agent_port") || !jsonObj["l_agent_port"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("l_status") || !jsonObj["l_status"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("l_data") || !jsonObj["l_data"].isString() ) {
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
if( spType == TYPE_LISTENER_STOP ) {
|
|
if ( !jsonObj.contains("l_name") || !jsonObj["l_name"].isString() ) {
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
if( spType == TYPE_AGENT_REG ) {
|
|
if ( !jsonObj.contains("agent") || !jsonObj["agent"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("listener") || !jsonObj["listener"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("ui") || !jsonObj["ui"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("cmd") || !jsonObj["cmd"].isString() ) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
if( spType == TYPE_AGENT_NEW ) {
|
|
if ( !jsonObj.contains("a_id") || !jsonObj["a_id"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_name") || !jsonObj["a_name"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_listener") || !jsonObj["a_listener"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_async") || !jsonObj["a_async"].isBool() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_external_ip") || !jsonObj["a_external_ip"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_internal_ip") || !jsonObj["a_internal_ip"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_gmt_offset") || !jsonObj["a_gmt_offset"].isDouble() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_sleep") || !jsonObj["a_sleep"].isDouble() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_jitter") || !jsonObj["a_jitter"].isDouble() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_pid") || !jsonObj["a_pid"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_tid") || !jsonObj["a_tid"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_arch") || !jsonObj["a_arch"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_elevated") || !jsonObj["a_elevated"].isBool() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_process") || !jsonObj["a_process"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_os") || !jsonObj["a_os"].isDouble() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_os_desc") || !jsonObj["a_os_desc"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_domain") || !jsonObj["a_domain"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_computer") || !jsonObj["a_computer"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_username") || !jsonObj["a_username"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_tags") || !jsonObj["a_tags"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_last_tick") || !jsonObj["a_last_tick"].isDouble() ) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
if( spType == TYPE_AGENT_TICK ) {
|
|
if (!jsonObj.contains("a_id") || !jsonObj["a_id"].isArray()) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
if( spType == TYPE_AGENT_CONSOLE_OUT)
|
|
{
|
|
if (!jsonObj.contains("time") || !jsonObj["time"].isDouble()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("a_id") || !jsonObj["a_id"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("a_text") || !jsonObj["a_text"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("a_message") || !jsonObj["a_message"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("a_msg_type") || !jsonObj["a_msg_type"].isDouble()) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
if( spType == TYPE_AGENT_UPDATE ) {
|
|
if ( !jsonObj.contains("a_id") || !jsonObj["a_id"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_sleep") || !jsonObj["a_sleep"].isDouble() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_jitter") || !jsonObj["a_jitter"].isDouble() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_elevated") || !jsonObj["a_elevated"].isBool() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_username") || !jsonObj["a_username"].isString() ) {
|
|
return false;
|
|
}
|
|
if ( !jsonObj.contains("a_tags") || !jsonObj["a_tags"].isString() ) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
if( spType == TYPE_AGENT_TASK_CREATE ) {
|
|
if (!jsonObj.contains("a_id") || !jsonObj["a_id"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("a_task_id") || !jsonObj["a_task_id"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("a_task_type") || !jsonObj["a_task_type"].isDouble()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("a_start_time") || !jsonObj["a_start_time"].isDouble()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("a_cmdline") || !jsonObj["a_cmdline"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("a_user") || !jsonObj["a_user"].isString()) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
if( spType == TYPE_AGENT_TASK_UPDATE ) {
|
|
if (!jsonObj.contains("a_id") || !jsonObj["a_id"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("a_task_id") || !jsonObj["a_task_id"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("a_task_type") || !jsonObj["a_task_type"].isDouble()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("a_finish_time") || !jsonObj["a_finish_time"].isDouble()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("a_msg_type") || !jsonObj["a_msg_type"].isDouble()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("a_message") || !jsonObj["a_message"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("a_text") || !jsonObj["a_text"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("a_completed") || !jsonObj["a_completed"].isBool()) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
if( spType == TYPE_AGENT_TASK_REMOVE ) {
|
|
if (!jsonObj.contains("a_task_id") || !jsonObj["a_task_id"].isString()) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
if( spType == TYPE_AGENT_REMOVE ) {
|
|
if (!jsonObj.contains("a_id") || !jsonObj["a_id"].isString()) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
if( spType == TYPE_DOWNLOAD_CREATE ) {
|
|
if (!jsonObj.contains("d_agent_id") || !jsonObj["d_agent_id"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("d_file_id") || !jsonObj["d_file_id"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("d_agent_name") || !jsonObj["d_agent_name"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("d_computer") || !jsonObj["d_computer"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("d_file") || !jsonObj["d_file"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("d_size") || !jsonObj["d_size"].isDouble()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("d_date") || !jsonObj["d_date"].isDouble()) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
if( spType == TYPE_DOWNLOAD_UPDATE ) {
|
|
if (!jsonObj.contains("d_file_id") || !jsonObj["d_file_id"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("d_recv_size") || !jsonObj["d_recv_size"].isDouble()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("d_state") || !jsonObj["d_state"].isDouble()) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
if( spType == TYPE_DOWNLOAD_DELETE ) {
|
|
if (!jsonObj.contains("d_file_id") || !jsonObj["d_file_id"].isString()) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
if( spType == TYPE_BROWSER_DISKS ) {
|
|
if (!jsonObj.contains("b_agent_id") || !jsonObj["b_agent_id"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("b_time") || !jsonObj["b_time"].isDouble()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("b_msg_type") || !jsonObj["b_msg_type"].isDouble()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("b_message") || !jsonObj["b_message"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("b_data") || !jsonObj["b_data"].isString()) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
if( spType == TYPE_BROWSER_FILES ) {
|
|
if (!jsonObj.contains("b_agent_id") || !jsonObj["b_agent_id"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("b_time") || !jsonObj["b_time"].isDouble()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("b_msg_type") || !jsonObj["b_msg_type"].isDouble()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("b_message") || !jsonObj["b_message"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("b_path") || !jsonObj["b_path"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("b_data") || !jsonObj["b_data"].isString()) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
if( spType == TYPE_BROWSER_STATUS ) {
|
|
if (!jsonObj.contains("b_agent_id") || !jsonObj["b_agent_id"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("b_time") || !jsonObj["b_time"].isDouble()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("b_msg_type") || !jsonObj["b_msg_type"].isDouble()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("b_message") || !jsonObj["b_message"].isString()) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
if( spType == TYPE_BROWSER_PROCESS ) {
|
|
if (!jsonObj.contains("b_agent_id") || !jsonObj["b_agent_id"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("b_time") || !jsonObj["b_time"].isDouble()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("b_msg_type") || !jsonObj["b_msg_type"].isDouble()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("b_message") || !jsonObj["b_message"].isString()) {
|
|
return false;
|
|
}
|
|
if (!jsonObj.contains("b_data") || !jsonObj["b_data"].isString()) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
void AdaptixWidget::processSyncPacket(QJsonObject jsonObj)
|
|
{
|
|
int spType = jsonObj["type"].toDouble();
|
|
if( this->sync && dialogSyncPacket != nullptr ) {
|
|
dialogSyncPacket->receivedLogs++;
|
|
dialogSyncPacket->upgrade();
|
|
}
|
|
|
|
if( spType == TYPE_SYNC_START )
|
|
{
|
|
int count = jsonObj["count"].toDouble();
|
|
dialogSyncPacket->init(count);
|
|
this->sync = true;
|
|
this->setEnabled(false);
|
|
return;
|
|
}
|
|
if( spType == TYPE_SYNC_FINISH )
|
|
{
|
|
if (dialogSyncPacket != nullptr ) {
|
|
dialogSyncPacket->finish();
|
|
this->sync = false;
|
|
this->setEnabled(true);
|
|
|
|
emit this->SyncedSignal();
|
|
}
|
|
return;
|
|
}
|
|
|
|
|
|
if( spType == TYPE_LISTENER_START )
|
|
{
|
|
ListenerData newListener = {0};
|
|
newListener.ListenerName = jsonObj["l_name"].toString();
|
|
newListener.ListenerType = jsonObj["l_type"].toString();
|
|
newListener.BindHost = jsonObj["l_bind_host"].toString();
|
|
newListener.BindPort = jsonObj["l_bind_port"].toString();
|
|
newListener.AgentPort = jsonObj["l_agent_port"].toString();
|
|
newListener.AgentHost = jsonObj["l_agent_host"].toString();
|
|
newListener.Status = jsonObj["l_status"].toString();
|
|
newListener.Data = jsonObj["l_data"].toString();
|
|
|
|
ListenersTab->AddListenerItem(newListener);
|
|
return;
|
|
}
|
|
if( spType == TYPE_LISTENER_EDIT )
|
|
{
|
|
ListenerData newListener = {0};
|
|
newListener.ListenerName = jsonObj["l_name"].toString();
|
|
newListener.ListenerType = jsonObj["l_type"].toString();
|
|
newListener.BindHost = jsonObj["l_bind_host"].toString();
|
|
newListener.BindPort = jsonObj["l_bind_port"].toString();
|
|
newListener.AgentPort = jsonObj["l_agent_port"].toString();
|
|
newListener.AgentHost = jsonObj["l_agent_host"].toString();
|
|
newListener.Status = jsonObj["l_status"].toString();
|
|
newListener.Data = jsonObj["l_data"].toString();
|
|
|
|
ListenersTab->EditListenerItem(newListener);
|
|
return;
|
|
}
|
|
if( spType == TYPE_LISTENER_STOP )
|
|
{
|
|
QString listenerName = jsonObj["l_name"].toString();
|
|
|
|
ListenersTab->RemoveListenerItem(listenerName);
|
|
return;
|
|
}
|
|
|
|
|
|
if( spType == TYPE_AGENT_NEW )
|
|
{
|
|
QString agentName = jsonObj["a_name"].toString();
|
|
|
|
Agent* newAgent = new Agent(jsonObj, RegisterAgentsCmd[agentName], this);
|
|
|
|
SessionsTablePage->AddAgentItem( newAgent );
|
|
return;
|
|
}
|
|
if( spType == TYPE_AGENT_UPDATE )
|
|
{
|
|
QString agentId = jsonObj["a_id"].toString();
|
|
|
|
if(Agents.contains(agentId)) {
|
|
Agent* agent = Agents[agentId];
|
|
agent->Update(jsonObj);
|
|
}
|
|
}
|
|
if( spType == TYPE_AGENT_TICK )
|
|
{
|
|
QJsonArray agentIDs = jsonObj["a_id"].toArray();
|
|
for (QJsonValue idValue : agentIDs) {
|
|
QString id = idValue.toString();
|
|
if (Agents.contains(id))
|
|
Agents[id]->data.LastTick = QDateTime::currentSecsSinceEpoch();
|
|
}
|
|
|
|
return;
|
|
}
|
|
if( spType == TYPE_AGENT_CONSOLE_OUT )
|
|
{
|
|
qint64 time = static_cast<qint64>(jsonObj["time"].toDouble());
|
|
QString agentId = jsonObj["a_id"].toString();
|
|
QString text = jsonObj["a_text"].toString();
|
|
QString message = jsonObj["a_message"].toString();
|
|
int msgType = jsonObj["a_msg_type"].toDouble();
|
|
|
|
if (Agents.contains(agentId))
|
|
Agents[agentId]->Console->ConsoleOutputMessage(time, "", msgType, message, text, false );
|
|
|
|
return;
|
|
}
|
|
if( spType == TYPE_AGENT_REMOVE )
|
|
{
|
|
QString agentId = jsonObj["a_id"].toString();
|
|
|
|
SessionsTablePage->RemoveAgentItem(agentId);
|
|
}
|
|
|
|
|
|
|
|
if( spType == TYPE_AGENT_TASK_CREATE )
|
|
{
|
|
TaskData taskData = { 0 };
|
|
taskData.AgentId = jsonObj["a_id"].toString();
|
|
taskData.TaskId = jsonObj["a_task_id"].toString();
|
|
taskData.TaskType = jsonObj["a_task_type"].toDouble();
|
|
taskData.StartTime = jsonObj["a_start_time"].toDouble();
|
|
taskData.CommandLine = jsonObj["a_cmdline"].toString();
|
|
taskData.Client = jsonObj["a_user"].toString();
|
|
|
|
if (Agents.contains(taskData.AgentId))
|
|
Agents[taskData.AgentId]->Console->ConsoleOutputPrompt( taskData.StartTime, taskData.TaskId, taskData.Client, taskData.CommandLine);
|
|
|
|
TasksTab->AddTaskItem(taskData);
|
|
|
|
return;
|
|
}
|
|
if( spType == TYPE_AGENT_TASK_UPDATE )
|
|
{
|
|
TaskData taskData = { 0 };
|
|
taskData.AgentId = jsonObj["a_id"].toString();
|
|
taskData.TaskId = jsonObj["a_task_id"].toString();
|
|
taskData.TaskType = jsonObj["a_task_type"].toDouble();
|
|
taskData.FinishTime = jsonObj["a_finish_time"].toDouble();
|
|
taskData.MessageType = jsonObj["a_msg_type"].toDouble();
|
|
taskData.Message = jsonObj["a_message"].toString();
|
|
taskData.Output = jsonObj["a_text"].toString();
|
|
taskData.Completed = jsonObj["a_completed"].toBool();
|
|
|
|
if (Agents.contains(taskData.AgentId))
|
|
Agents[taskData.AgentId]->Console->ConsoleOutputMessage( taskData.FinishTime, taskData.TaskId, taskData.MessageType, taskData.Message, taskData.Output , taskData.Completed );
|
|
|
|
TasksTab->EditTaskItem(taskData);
|
|
|
|
return;
|
|
}
|
|
if( spType == TYPE_AGENT_TASK_REMOVE )
|
|
{
|
|
QString TaskId = jsonObj["a_task_id"].toString();
|
|
TasksTab->RemoveTaskItem(TaskId);
|
|
return;
|
|
}
|
|
|
|
|
|
|
|
if( spType == TYPE_DOWNLOAD_CREATE )
|
|
{
|
|
DownloadData newDownload = {0};
|
|
newDownload.AgentId = jsonObj["d_agent_id"].toString();
|
|
newDownload.FileId = jsonObj["d_file_id"].toString();
|
|
newDownload.AgentName = jsonObj["d_agent_name"].toString();
|
|
newDownload.Computer = jsonObj["d_computer"].toString();
|
|
newDownload.Filename = jsonObj["d_file"].toString();
|
|
newDownload.TotalSize = jsonObj["d_size"].toDouble();
|
|
newDownload.Date = UnixTimestampGlobalToStringLocal(static_cast<qint64>(jsonObj["d_date"].toDouble()));
|
|
newDownload.RecvSize = 0;
|
|
newDownload.State = DOWNLOAD_STATE_RUNNING;
|
|
|
|
DownloadsTab->AddDownloadItem(newDownload);
|
|
|
|
return;
|
|
}
|
|
if( spType == TYPE_DOWNLOAD_UPDATE )
|
|
{
|
|
QString fileId = jsonObj["d_file_id"].toString();
|
|
int recvSize = jsonObj["d_recv_size"].toDouble();
|
|
int state = jsonObj["d_state"].toDouble();
|
|
|
|
DownloadsTab->EditDownloadItem(fileId, recvSize, state);
|
|
|
|
return;
|
|
}
|
|
if( spType == TYPE_DOWNLOAD_DELETE )
|
|
{
|
|
QString fileId = jsonObj["d_file_id"].toString();
|
|
|
|
DownloadsTab->RemoveDownloadItem(fileId);
|
|
|
|
return;
|
|
}
|
|
|
|
|
|
|
|
if( spType == TYPE_BROWSER_DISKS )
|
|
{
|
|
QString agentId = jsonObj["b_agent_id"].toString();
|
|
qint64 time = jsonObj["b_time"].toDouble();
|
|
int msgType = jsonObj["b_msg_type"].toDouble();
|
|
QString message = jsonObj["b_message"].toString();
|
|
QString data = jsonObj["b_data"].toString();
|
|
|
|
if (Agents.contains(agentId))
|
|
Agents[agentId]->FileBrowser->SetDisks(time, msgType, message, data);
|
|
|
|
return;
|
|
}
|
|
if( spType == TYPE_BROWSER_FILES )
|
|
{
|
|
QString agentId = jsonObj["b_agent_id"].toString();
|
|
qint64 time = jsonObj["b_time"].toDouble();
|
|
int msgType = jsonObj["b_msg_type"].toDouble();
|
|
QString message = jsonObj["b_message"].toString();
|
|
QString path = jsonObj["b_path"].toString();
|
|
QString data = jsonObj["b_data"].toString();
|
|
|
|
if (Agents.contains(agentId))
|
|
Agents[agentId]->FileBrowser->AddFiles(time, msgType, message, path, data);
|
|
|
|
return;
|
|
}
|
|
if( spType == TYPE_BROWSER_PROCESS )
|
|
{
|
|
QString agentId = jsonObj["b_agent_id"].toString();
|
|
qint64 time = jsonObj["b_time"].toDouble();
|
|
int msgType = jsonObj["b_msg_type"].toDouble();
|
|
QString message = jsonObj["b_message"].toString();
|
|
QString data = jsonObj["b_data"].toString();
|
|
|
|
if (Agents.contains(agentId)) {
|
|
Agents[agentId]->ProcessBrowser->SetStatus(time, msgType, message);
|
|
Agents[agentId]->ProcessBrowser->SetProcess(msgType, data);
|
|
}
|
|
|
|
return;
|
|
}
|
|
if( spType == TYPE_BROWSER_STATUS )
|
|
{
|
|
QString agentId = jsonObj["b_agent_id"].toString();
|
|
qint64 time = jsonObj["b_time"].toDouble();
|
|
int msgType = jsonObj["b_msg_type"].toDouble();
|
|
QString message = jsonObj["b_message"].toString();
|
|
|
|
if (Agents.contains(agentId))
|
|
Agents[agentId]->FileBrowser->SetStatus( time, msgType, message );
|
|
|
|
return;
|
|
}
|
|
|
|
|
|
if(spType == SP_TYPE_EVENT)
|
|
{
|
|
int type = jsonObj["event_type"].toDouble();
|
|
qint64 time = jsonObj["date"].toDouble();
|
|
QString message = jsonObj["message"].toString();
|
|
|
|
LogsTab->AddLogs(type, time, message);
|
|
}
|
|
|
|
|
|
if( spType == TYPE_LISTENER_REG )
|
|
{
|
|
QString fn = jsonObj["fn"].toString();
|
|
QString ui = jsonObj["ui"].toString();
|
|
|
|
auto widgetBuilder = new WidgetBuilder(ui.toLocal8Bit() );
|
|
if(widgetBuilder->GetError().isEmpty())
|
|
RegisterListenersUI[fn] = widgetBuilder;
|
|
|
|
return;
|
|
}
|
|
if( spType == TYPE_AGENT_REG )
|
|
{
|
|
QString agentName = jsonObj["agent"].toString();
|
|
QString listenerName = jsonObj["listener"].toString();
|
|
QString ui = jsonObj["ui"].toString();
|
|
QString cmd = jsonObj["cmd"].toString();
|
|
|
|
auto widgetBuilder = new WidgetBuilder(ui.toLocal8Bit() );
|
|
if(widgetBuilder->GetError().isEmpty())
|
|
RegisterAgentsUI[agentName] = widgetBuilder;
|
|
|
|
auto commander = new Commander();
|
|
bool result = true;
|
|
QString msg = ValidCommandsFile(cmd.toLocal8Bit(), &result);
|
|
if ( result )
|
|
commander->AddRegCommands(cmd.toLocal8Bit());
|
|
|
|
RegisterAgentsCmd[agentName] = commander;
|
|
LinkListenerAgent[listenerName].push_back(agentName);
|
|
return;
|
|
}
|
|
}
|