Back
Overview | Project
Gps service / src /

geolocation_manager.c

  1. #include <tizen.h>
  2. #include <stdio.h>
  3. #include <locations.h>
  4. #include <bundle.h>
  5. #include <message_port.h>
  6. #include <efl_extension.h>
  7. #include "$(appName).h"
  8. #include "geolocation_manager.h"
  9.  
  10. #define POSITION_UPDATE_INTERVAL 1
  11. #define SATELLITE_UPDATE_INTERVAL 5
  12. #define CHAR_BUFF_SIZE 20
  13. #define MAX_TIME_DIFF 15
  14. #define SEND_DATA_INTERVAL 5.0
  15.  
  16. #define MESSAGE_TYPE_POSITION_UPDATE "POSITION_UPDATE"
  17. #define MESSAGE_TYPE_SATELLITES_UPDATE "SATELLITES_UPDATE"
  18. #define MESSAGE_TYPE_CIRCLE_INIT "CIRCLE_INIT"
  19.  
  20. static struct
  21. {
  22. 	location_manager_h manager;
  23.  
  24. 	bool init_data_sent;
  25. } s_geolocation_data = {
  26. 	.manager = NULL,
  27.  
  28. 	.init_data_sent = false
  29. };
  30. static bool __send_message(bundle *b);
  31. static bool __send_position_coords(location_coords_s coords);
  32. static bool __send_satellites_count(int s_count);
  33. static void __position_updated_cb(double latitude, double longitude, double altitude, time_t timestamp, void *data);
  34. static void __satellite_updated_cb(int num_of_active, int num_of_inview, time_t timestamp, void *data);
  35. static Eina_Bool __init_data_send_cb(void *data);
  36. static Eina_Bool __init_data_send(void);
  37. static bool __init_data(location_coords_s *init_coords, int *satellites_count);
  38.  
  39.  
  40. bool
  41. geolocation_manager_init(void)
  42. {
  43. 	bool exists;
  44.  
  45. 	/* Create location manager handle */
  46. 	if (location_manager_create(LOCATIONS_METHOD_GPS, &s_geolocation_data.manager) != LOCATIONS_ERROR_NONE) {
  47. 		dlog_print(DLOG_ERROR, LOG_TAG, "Failed to create location manager");
  48. 		return false;
  49. 	}
  50.  
  51. 	/* Register callbacks for position and satellites data update */
  52. 	location_error_e pos_cb = location_manager_set_position_updated_cb(s_geolocation_data.manager, __position_updated_cb, POSITION_UPDATE_INTERVAL, NULL);
  53. 	location_error_e sat_cb = gps_status_set_satellite_updated_cb(s_geolocation_data.manager, __satellite_updated_cb, SATELLITE_UPDATE_INTERVAL, NULL);
  54.  
  55. 	if (pos_cb != LOCATIONS_ERROR_NONE) {
  56. 		dlog_print(DLOG_ERROR, LOG_TAG, "Failed to register callbacks for location manager");
  57. 		geolocation_manager_destroy_service();
  58. 		return false;
  59. 	}
  60.  
  61. 	if (sat_cb != LOCATIONS_ERROR_NONE)
  62. 		dlog_print(DLOG_WARN, LOG_TAG, "Failed to get satellites number. Probably you run this sample on the emulator.");
  63.  
  64. 	/* Check state of remote port from gps-consumer */
  65. 	if (message_port_check_remote_port(REMOTE_APP_ID, REMOTE_PORT, &exists) != MESSAGE_PORT_ERROR_NONE) {
  66. 		dlog_print(DLOG_ERROR, LOG_TAG, "Failed to check remote port");
  67. 		geolocation_manager_destroy_service();
  68. 		return false;
  69. 	}
  70.  
  71. 	if (!exists)
  72. 		dlog_print(DLOG_ERROR, LOG_TAG, "Remote port is not registered");
  73.  
  74. 	/* Start location service */
  75. 	location_manager_start(s_geolocation_data.manager);
  76.  
  77. 	/* Send initial data to gps-consumer port */
  78. 	 if (!__init_data_send()) {
  79. 		 dlog_print(DLOG_ERROR, LOG_TAG, "Failed to send init data - create timer to periodically try to send data");
  80. 		 ecore_timer_add(SEND_DATA_INTERVAL, __init_data_send_cb, NULL);
  81. 	 }
  82.  
  83. 	return true;
  84. }
  85.  
  86.  
  87. void
  88. geolocation_manager_stop_service(void)
  89. {
  90. 	location_manager_stop(s_geolocation_data.manager);
  91. }
  92.  
  93.  
  94. void
  95. geolocation_manager_destroy_service(void)
  96. {
  97. 	location_manager_unset_position_updated_cb(s_geolocation_data.manager);
  98. 	gps_status_unset_satellite_updated_cb(s_geolocation_data.manager);
  99. 	location_manager_stop(s_geolocation_data.manager);
  100. 	location_manager_destroy(s_geolocation_data.manager);
  101.  
  102.  
  103. 	s_geolocation_data.manager = NULL;
  104. }
  105.  
  106. static bool
  107. __send_message(bundle *b)
  108. {
  109. 	if (!b) {
  110. 		dlog_print(DLOG_ERROR, LOG_TAG, "Can not send message, the bundle is NULL");
  111. 		return false;
  112. 	}
  113.  
  114. 	/* Send message to specified remote port */
  115. 	int ret = message_port_send_message(REMOTE_APP_ID, REMOTE_PORT, b);
  116.  
  117. 	if (ret != MESSAGE_PORT_ERROR_NONE) {
  118. 		dlog_print(DLOG_ERROR, LOG_TAG, "Failed to send message: error %d", ret);
  119. 		return false;
  120. 	}
  121.  
  122. 	return true;
  123. }
  124.  
  125. static bool
  126. __send_position_coords(location_coords_s coords)
  127. {
  128. 	bundle *b = bundle_create();
  129. 	char latitude_str[CHAR_BUFF_SIZE], longitude_str[CHAR_BUFF_SIZE];
  130.  
  131. 	if (!b) {
  132. 		dlog_print(DLOG_ERROR, LOG_TAG, "Failed to create bundle, the coords will not be sent");
  133. 		return false;
  134. 	}
  135.  
  136. 	snprintf(latitude_str, CHAR_BUFF_SIZE, "%f", coords.latitude);
  137. 	snprintf(longitude_str, CHAR_BUFF_SIZE, "%f", coords.longitude);
  138.  
  139. 	bundle_add_str(b, "msg_type", MESSAGE_TYPE_POSITION_UPDATE);
  140. 	bundle_add_str(b, "latitude", latitude_str);
  141. 	bundle_add_str(b, "longitude", longitude_str);
  142.  
  143. 	bool ret = __send_message(b);
  144.  
  145. 	bundle_free(b);
  146.  
  147. 	return ret;
  148. }
  149.  
  150. static bool
  151. __send_satellites_count(int s_count)
  152. {
  153. 	bundle *b = bundle_create();
  154. 	char count_str[CHAR_BUFF_SIZE];
  155.  
  156. 	if (!b) {
  157. 		dlog_print(DLOG_ERROR, LOG_TAG, "Failed to create bundle, the satellites will not be sent");
  158. 		return false;
  159. 	}
  160.  
  161. 	snprintf(count_str, CHAR_BUFF_SIZE, "%d", s_count);
  162.  
  163. 	bundle_add_str(b, "msg_type", MESSAGE_TYPE_SATELLITES_UPDATE);
  164. 	bundle_add_str(b, "satellites_count", count_str);
  165.  
  166. 	bool ret = __send_message(b);
  167.  
  168. 	bundle_free(b);
  169.  
  170. 	return ret;
  171. }
  172.  
  173. static void
  174. __position_updated_cb(double latitude, double longitude, double altitude, time_t timestamp, void *data)
  175. {
  176. 	location_coords_s coords;
  177.  
  178. 	coords.latitude = latitude;
  179. 	coords.longitude = longitude;
  180.  
  181. 	time_t curr_timestamp;
  182.  
  183. 	/* Get current time to compare to the last position timestamp */
  184. 	time(&curr_timestamp);
  185.  
  186.  
  187. 	/* Send updated position only if init data has been sent and position update
  188. 	 * was registered less than MAX_TIME_DIFF seconds ago */
  189. 	if (s_geolocation_data.init_data_sent && curr_timestamp-timestamp < MAX_TIME_DIFF) {
  190.  
  191. 		/* Send position update via message port */
  192. 		if (__send_position_coords(coords)) {
  193. 			dlog_print(DLOG_INFO, LOG_TAG, "Position updated to %f, %f", latitude, longitude);
  194. 		} else {
  195. 			dlog_print(DLOG_ERROR, LOG_TAG, "Failed to send position update");
  196. 		}
  197. 	}
  198. }
  199.  
  200.  
  201. static void
  202. __satellite_updated_cb(int num_of_active, int num_of_inview, time_t timestamp, void *data)
  203. {
  204. 	/* Send update satellite count only if init data has been sent*/
  205. 	if (s_geolocation_data.init_data_sent) {
  206. 		/* Send satellite count update via message port */
  207. 		if (__send_satellites_count(num_of_inview)) {
  208. 			dlog_print(DLOG_INFO, LOG_TAG, "Satellite count updated: inview %d", num_of_inview);
  209. 		} else {
  210. 			dlog_print(DLOG_ERROR, LOG_TAG, "Failed to send satellite count update");
  211. 		}
  212. 	}
  213. }
  214.  
  215. static Eina_Bool
  216. __init_data_send_cb(void *data)
  217. {
  218. 	if (__init_data_send())
  219. 		return ECORE_CALLBACK_CANCEL;
  220.  
  221. 	return ECORE_CALLBACK_RENEW;
  222. }
  223.  
  224. static Eina_Bool
  225. __init_data_send(void)
  226. {
  227. 	location_coords_s init_coords;
  228. 	int satellites_count = 0;
  229.  
  230. 	/* Get initial position and satellites count */
  231. 	if (!__init_data(&init_coords, &satellites_count)) {
  232. 		dlog_print(DLOG_ERROR, LOG_TAG, "Failed to initialize geolocation data");
  233. 		return EINA_FALSE;
  234. 	}
  235.  
  236. 	/* Send initial data to consumer application */
  237. 	if (!__send_satellites_count(satellites_count) || !__send_position_coords(init_coords))
  238. 		return EINA_FALSE;
  239.  
  240. 	s_geolocation_data.init_data_sent = true;
  241.  
  242. 	return EINA_TRUE;
  243. }
  244.  
  245. static bool
  246. __init_data(location_coords_s *init_coords, int *satellites_count)
  247. {
  248. 	/* Additional variables have to be declared to ensure proper local_manager and gps_status functions execution */
  249. 	double altitude;
  250. 	time_t timestamp;
  251. 	time_t curr_timestamp;
  252. 	int num_of_active;
  253.  
  254. 	/* Get last location information*/
  255. 	if (location_manager_get_last_position(s_geolocation_data.manager, &altitude, &init_coords->latitude, &init_coords->longitude, &timestamp) != LOCATIONS_ERROR_NONE) {
  256. 		dlog_print(DLOG_ERROR, LOG_TAG, "Failed to get last location");
  257. 		return false;
  258. 	}
  259. 	dlog_print(DLOG_INFO, LOG_TAG, "Initial position: latitude %f, longitude %f", init_coords->latitude, init_coords->longitude);
  260.  
  261. 	/* Get current time and compare it to the last position timestamp */
  262. 	time(&curr_timestamp);
  263.  
  264. 	if (curr_timestamp-timestamp > MAX_TIME_DIFF) {
  265. 		dlog_print(DLOG_ERROR, LOG_TAG, "Last position updated over 15 seconds ago - no longer valid");
  266. 		return false;
  267. 	}
  268.  
  269. 	/* Get initial count of satellites in view */
  270. 	location_error_e ret = gps_status_get_satellite(s_geolocation_data.manager, &num_of_active, satellites_count, &timestamp);
  271. 	if (ret != LOCATIONS_ERROR_NONE) {
  272. 		dlog_print(DLOG_ERROR, LOG_TAG, "Failed to get satellite data [%d]", ret);
  273. 		/* Satellite data is not supported on Tizen Emulator - satellites count remains at 0 */
  274. 	}
  275. 	dlog_print(DLOG_INFO, LOG_TAG, "Initial satelite data: number of satellites inview: %d", *satellites_count);
  276.  
  277. 	return true;
  278. }