/* * Copyright 2013 - 2020 Anton Tananaev (anton@traccar.org) * * 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. */ package org.traccar.protocol; import io.netty.buffer.Unpooled; import io.netty.channel.Channel; import io.netty.handler.codec.http.FullHttpRequest; import io.netty.handler.codec.http.HttpResponseStatus; import io.netty.handler.codec.http.QueryStringDecoder; import org.traccar.BaseHttpProtocolDecoder; import org.traccar.Context; import org.traccar.DeviceSession; import org.traccar.Protocol; import org.traccar.database.CommandsManager; import org.traccar.helper.DateUtil; import org.traccar.model.CellTower; import org.traccar.model.Command; import org.traccar.model.Network; import org.traccar.model.Position; import org.traccar.model.WifiAccessPoint; import java.net.SocketAddress; import java.nio.charset.StandardCharsets; import java.text.DateFormat; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; import java.util.Map; public class OsmAndProtocolDecoder extends BaseHttpProtocolDecoder { public OsmAndProtocolDecoder(Protocol protocol) { super(protocol); } @Override protected Object decode(Channel channel, SocketAddress remoteAddress, Object msg) throws Exception { FullHttpRequest request = (FullHttpRequest) msg; QueryStringDecoder decoder = new QueryStringDecoder(request.uri()); Map<String, List<String>> params = decoder.parameters(); if (params.isEmpty()) { decoder = new QueryStringDecoder(request.content().toString(StandardCharsets.US_ASCII), false); params = decoder.parameters(); } Position position = new Position(getProtocolName()); position.setValid(true); Network network = new Network(); for (Map.Entry<String, List<String>> entry : params.entrySet()) { for (String value : entry.getValue()) { switch (entry.getKey()) { case "id": case "deviceid": DeviceSession deviceSession = getDeviceSession(channel, remoteAddress, value); if (deviceSession == null) { sendResponse(channel, HttpResponseStatus.BAD_REQUEST); return null; } position.setDeviceId(deviceSession.getDeviceId()); break; case "valid": position.setValid(Boolean.parseBoolean(value) || "1".equals(value)); break; case "timestamp": try { long timestamp = Long.parseLong(value); if (timestamp < Integer.MAX_VALUE) { timestamp *= 1000; } position.setTime(new Date(timestamp)); } catch (NumberFormatException error) { if (value.contains("T")) { position.setTime(DateUtil.parseDate(value)); } else { DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); position.setTime(dateFormat.parse(value)); } } break; case "lat": position.setLatitude(Double.parseDouble(value)); break; case "lon": position.setLongitude(Double.parseDouble(value)); break; case "location": String[] location = value.split(","); position.setLatitude(Double.parseDouble(location[0])); position.setLongitude(Double.parseDouble(location[1])); break; case "cell": String[] cell = value.split(","); if (cell.length > 4) { network.addCellTower(CellTower.from( Integer.parseInt(cell[0]), Integer.parseInt(cell[1]), Integer.parseInt(cell[2]), Integer.parseInt(cell[3]), Integer.parseInt(cell[4]))); } else { network.addCellTower(CellTower.from( Integer.parseInt(cell[0]), Integer.parseInt(cell[1]), Integer.parseInt(cell[2]), Integer.parseInt(cell[3]))); } break; case "wifi": String[] wifi = value.split(","); network.addWifiAccessPoint(WifiAccessPoint.from( wifi[0].replace('-', ':'), Integer.parseInt(wifi[1]))); break; case "speed": position.setSpeed(convertSpeed(Double.parseDouble(value), "kn")); break; case "bearing": case "heading": position.setCourse(Double.parseDouble(value)); break; case "altitude": position.setAltitude(Double.parseDouble(value)); break; case "accuracy": position.setAccuracy(Double.parseDouble(value)); break; case "hdop": position.set(Position.KEY_HDOP, Double.parseDouble(value)); break; case "batt": position.set(Position.KEY_BATTERY_LEVEL, Double.parseDouble(value)); break; case "driverUniqueId": position.set(Position.KEY_DRIVER_UNIQUE_ID, value); break; default: try { position.set(entry.getKey(), Double.parseDouble(value)); } catch (NumberFormatException e) { switch (value) { case "true": position.set(entry.getKey(), true); break; case "false": position.set(entry.getKey(), false); break; default: position.set(entry.getKey(), value); break; } } break; } } } if (position.getFixTime() == null) { position.setTime(new Date()); } if (network.getCellTowers() != null || network.getWifiAccessPoints() != null) { position.setNetwork(network); } if (position.getLatitude() == 0 && position.getLongitude() == 0) { getLastLocation(position, position.getDeviceTime()); } if (position.getDeviceId() != 0) { String response = null; CommandsManager commandsManager = Context.getCommandsManager(); if (commandsManager != null) { for (Command command : commandsManager.readQueuedCommands(position.getDeviceId(), 1)) { response = command.getString(Command.KEY_DATA); } } if (response != null) { sendResponse(channel, HttpResponseStatus.OK, Unpooled.copiedBuffer(response, StandardCharsets.UTF_8)); } else { sendResponse(channel, HttpResponseStatus.OK); } return position; } else { sendResponse(channel, HttpResponseStatus.BAD_REQUEST); return null; } } @Override protected void sendQueuedCommands(Channel channel, SocketAddress remoteAddress, long deviceId) { } }