XeonWars/ConnectionManager.cpp at master · proyectos-ce/XeonWars · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
//
// Created by Ignacio Mora on 4/5/17.
//

#include <cstdlib>
#include <iostream>
#include <zconf.h>
#include "ConnectionManager.h"


#include <mosquitto.h>
#include <cstring>


Game* ConnectionManager::mainGame;
ConnectionManager* ConnectionManager::instance;

void connect_callback(struct mosquitto *mosq, void *obj, int result)
{
    printf("connect callback, rc=%d\n", result);
}

void message_callback(struct mosquitto *mosq, void *obj, const struct mosquitto_message *message)
{

    string dir ((char*)message->payload);
    ConnectionManager::setPhoneDirection(dir);
}


void ConnectionManager::setPhoneDirection(string direction){
    ConnectionManager::mainGame->setPhoneDirection(direction);
}


ConnectionManager::ConnectionManager(Game *gamecito) {
    ConnectionManager::mainGame = gamecito;


    mosquitto_lib_init();

    char clientid[9] = "XeonWars";

    memset(clientid, 0, 24);
    snprintf(clientid, 23, "mysql_log_%d", getpid());
    mosq = mosquitto_new(clientid, true, 0);

    if(mosq) {
        mosquitto_connect_callback_set(mosq, connect_callback);
        mosquitto_message_callback_set(mosq, message_callback);

        mosquitto_connect(mosq, mqtt_host, mqtt_port, 60);

        mosquitto_subscribe(mosq, NULL, "/XeonDataFrom/Phone", 0);

        mosquitto_loop_start(mosq);
    }
}


ConnectionManager *ConnectionManager::createInstance(Game *gamecito) {
    instance = new ConnectionManager(gamecito);
    return instance;
}

ConnectionManager *ConnectionManager::getInstance() {
    return instance;
}

void ConnectionManager::send(string toSend) {
    char* cToSend = new char[toSend.length()+1];
    std::strcpy (cToSend, toSend.c_str());
    mosquitto_publish(mosq, NULL, "/XeonDataFrom/PC", toSend.length()+1, cToSend, 0, true);


}