summaryrefslogtreecommitdiff
path: root/StoneIsland/plugins/cordova-plugin-geolocation/src/ubuntu/geolocation.cpp
blob: c820cfef128878a5b55da9d3ad5b485d0ad6cfa2 (plain)
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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
/*
 *
 * Copyright 2013 Canonical Ltd.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 *
*/

#include <QUuid>

#include "geolocation.h"

Geolocation::Geolocation(Cordova *cordova): CPlugin(cordova),
                                            _geoPositionInfoSource(QGeoPositionInfoSource::createDefaultSource(this)) {
    if (_geoPositionInfoSource.data() != 0) {
        QObject::connect(_geoPositionInfoSource.data(), SIGNAL(positionUpdated(QGeoPositionInfo)), this, SLOT(positionUpdated(QGeoPositionInfo)));
        QObject::connect(_geoPositionInfoSource.data(), SIGNAL(updateTimeout()), this, SLOT(updateTimeout()));
    }
}

void Geolocation::addWatch(int scId, int ecId, const QString &id, bool enableHighAccuracy) {
    Q_UNUSED(enableHighAccuracy);

    assert(_id2sc.find(id) == _id2sc.end());

    if (!_geoPositionInfoSource.data()) {
        QVariantMap err;
        err.insert("code", POSITION_UNAVAILABLE);
        err.insert("message", "unavailable");

        this->cb(ecId, err);
        return;
    }

    _id2sc[id] = scId;
    _id2ec[id] = ecId;
}

void Geolocation::clearWatch(int scId, int ecId, const QString &id) {
    _id2sc.remove(id);
    _id2ec.remove(id);
}

void Geolocation::getLocation(int scId, int ecId, bool enableHighAccuracy, qint64 maximumAge) {
    Q_UNUSED(maximumAge);
    Q_UNUSED(enableHighAccuracy);

    if (!_geoPositionInfoSource.data()) {
        QVariantMap err;
        err.insert("code", POSITION_UNAVAILABLE);
        err.insert("message", "unavailable");

        this->cb(ecId, err);
        return;
    }

    _geoPositionInfoSource->requestUpdate();

    QString id = QString("_INTERNAL_") + QUuid::createUuid().toString();

    _id2sc[id] = scId;
    _id2ec[id] = ecId;
    _singleUpdate.insert(id);
}

void Geolocation::positionUpdated(const QGeoPositionInfo &update) {
    QGeoCoordinate coordinate = update.coordinate();

    QVariantMap p;

    p.insert("latitude", coordinate.latitude());
    p.insert("longitude", coordinate.longitude());
    p.insert("altitude", coordinate.altitude());

    if (update.hasAttribute(QGeoPositionInfo::VerticalAccuracy))
        p.insert("accuracy", update.attribute(QGeoPositionInfo::VerticalAccuracy));
    if (update.hasAttribute(QGeoPositionInfo::Direction))
        p.insert("heading", update.attribute(QGeoPositionInfo::Direction));
    if (update.hasAttribute(QGeoPositionInfo::GroundSpeed))
        p.insert("velocity", update.attribute(QGeoPositionInfo::GroundSpeed));
    if (update.hasAttribute(QGeoPositionInfo::HorizontalAccuracy))
        p.insert("altitudeAccuracy", update.attribute(QGeoPositionInfo::HorizontalAccuracy));
    p.insert("timestamp", update.timestamp().toMSecsSinceEpoch());

    for (const QString &id: _id2sc.keys()) {
        int scId = _id2sc[id];
        this->cb(scId, p);
        if (_singleUpdate.contains(id)) {
            _singleUpdate.remove(id);
            _id2sc.remove(id);
            _id2ec.remove(id);
        }
    }
}

void Geolocation::updateTimeout() {
    QVariantMap err;
    err.insert("code", TIMEOUT);
    err.insert("message", "timeout");

    for (int ecId: _id2ec) {
        this->cb(ecId, err);
    }

    _id2ec.clear();
    _id2sc.clear();
    _singleUpdate.clear();
}