Changeset View
Changeset View
Standalone View
Standalone View
src/it/reyboz/bustorino/backend/mato/MatoAPIFetcher.kt
| Show All 14 Lines | BusTO - Backend components | ||||
| You should have received a copy of the GNU General Public License | You should have received a copy of the GNU General Public License | ||||
| along with this program. If not, see <http://www.gnu.org/licenses/>. | along with this program. If not, see <http://www.gnu.org/licenses/>. | ||||
| */ | */ | ||||
| package it.reyboz.bustorino.backend.mato | package it.reyboz.bustorino.backend.mato | ||||
| import android.content.Context | import android.content.Context | ||||
| import android.util.Log | import android.util.Log | ||||
| import com.android.volley.toolbox.RequestFuture | import com.android.volley.toolbox.RequestFuture | ||||
| import it.reyboz.bustorino.BuildConfig | |||||
| import it.reyboz.bustorino.backend.* | import it.reyboz.bustorino.backend.* | ||||
| import org.json.JSONObject | import org.json.JSONObject | ||||
| import java.util.* | import java.util.* | ||||
| import java.util.concurrent.ExecutionException | |||||
| import java.util.concurrent.TimeUnit | import java.util.concurrent.TimeUnit | ||||
| import java.util.concurrent.atomic.AtomicReference | |||||
| import java.util.concurrent.TimeoutException | import java.util.concurrent.TimeoutException | ||||
| import java.util.concurrent.atomic.AtomicReference | |||||
| import java.util.concurrent.ExecutionException | |||||
| open class MatoAPIFetcher(val minNumPassaggi: Int) : ArrivalsFetcher { | open class MatoAPIFetcher(val minNumPassaggi: Int) : ArrivalsFetcher { | ||||
| var appContext: Context? = null | var appContext: Context? = null | ||||
| set(value) { | set(value) { | ||||
| field = value!!.applicationContext | field = value!!.applicationContext | ||||
| } | } | ||||
| constructor(): this(3) | constructor(): this(2) | ||||
| override fun ReadArrivalTimesAll(stopID: String?, res: AtomicReference<Fetcher.Result>?): Palina { | override fun ReadArrivalTimesAll(stopID: String?, res: AtomicReference<Fetcher.Result>?): Palina { | ||||
| stopID!! | stopID!! | ||||
| val future = RequestFuture.newFuture<Palina>() | |||||
| val now = Calendar.getInstance().time | val now = Calendar.getInstance().time | ||||
| var numMinutes = 30 | var numMinutes = 0 | ||||
| var palina = Palina(stopID) | var palina = Palina(stopID) | ||||
| var numPassaggi = 0 | var numPassaggi = 0 | ||||
| var trials = 0 | var trials = 0 | ||||
| val numDepartures = 4 | |||||
| while (numPassaggi < minNumPassaggi && trials < 4) { | while (numPassaggi < minNumPassaggi && trials < 4) { | ||||
| //numDepartures+=2 | |||||
| numMinutes += 15 | numMinutes += 20 | ||||
| val request = MapiArrivalRequest(stopID, now, numMinutes * 60, 10, res, future, future) | val future = RequestFuture.newFuture<Palina>() | ||||
| val request = MapiArrivalRequest(stopID, now, numMinutes * 60, numDepartures, res, future, future) | |||||
| if (appContext == null || res == null) { | if (appContext == null || res == null) { | ||||
| Log.e("BusTO:MatoAPIFetcher", "ERROR: Given null context or null result ref") | Log.e("BusTO:MatoAPIFetcher", "ERROR: Given null context or null result ref") | ||||
| return Palina(stopID) | return Palina(stopID) | ||||
| } | } | ||||
| val requestQueue = NetworkVolleyManager.getInstance(appContext).requestQueue | val requestQueue = NetworkVolleyManager.getInstance(appContext).requestQueue | ||||
| request.setTag(getVolleyReqTag(QueryType.ARRIVALS)) | request.setTag(getVolleyReqTag(QueryType.ARRIVALS)) | ||||
| requestQueue.add(request) | requestQueue.add(request) | ||||
| try { | try { | ||||
| val palinaResult = future.get(5, TimeUnit.SECONDS) | val palinaResult = future.get(5, TimeUnit.SECONDS) | ||||
| if (palinaResult!=null) { | if (palinaResult!=null) { | ||||
| if (BuildConfig.DEBUG) | |||||
| for (r in palinaResult.queryAllRoutes()){ | |||||
| Log.d(DEBUG_TAG, "route " + r.gtfsId + " has " + r.passaggi.size + " passaggi: "+ r.passaggiToString) | |||||
| } | |||||
| palina = palinaResult | palina = palinaResult | ||||
| numPassaggi = palina.totalNumberOfPassages | numPassaggi = palina.minNumberOfPassages | ||||
| } else{ | |||||
| Log.d(DEBUG_TAG, "Result palina is null") | |||||
| } | } | ||||
| } catch (e: InterruptedException) { | } catch (e: InterruptedException) { | ||||
| e.printStackTrace() | e.printStackTrace() | ||||
| res.set(Fetcher.Result.PARSER_ERROR) | res.set(Fetcher.Result.PARSER_ERROR) | ||||
| } catch (e: ExecutionException) { | } catch (e: ExecutionException) { | ||||
| e.printStackTrace() | e.printStackTrace() | ||||
| if (res.get() == Fetcher.Result.OK) | if (res.get() == Fetcher.Result.OK) | ||||
| res.set(Fetcher.Result.SERVER_ERROR) | res.set(Fetcher.Result.SERVER_ERROR) | ||||
| ▲ Show 20 Lines • Show All 94 Lines • ▼ Show 20 Lines | companion object{ | ||||
| palina.gtfsID = jsonStop.getString("gtfsId") | palina.gtfsID = jsonStop.getString("gtfsId") | ||||
| val routesStoppingJSON = jsonStop.getJSONArray("routes") | val routesStoppingJSON = jsonStop.getJSONArray("routes") | ||||
| val baseRoutes = mutableListOf<Route>() | val baseRoutes = mutableListOf<Route>() | ||||
| // get all the possible routes | // get all the possible routes | ||||
| for (i in 0 until routesStoppingJSON.length()){ | for (i in 0 until routesStoppingJSON.length()){ | ||||
| val routeBaseInfo = routesStoppingJSON.getJSONObject(i) | val routeBaseInfo = routesStoppingJSON.getJSONObject(i) | ||||
| val r = Route(routeBaseInfo.getString("shortName"), Route.Type.UNKNOWN,"") | val r = Route(routeBaseInfo.getString("shortName"), Route.Type.UNKNOWN,"") | ||||
| r.gtfsId = routeBaseInfo.getString("gtfsId").trim() | r.setGtfsId(routeBaseInfo.getString("gtfsId").trim()) | ||||
| baseRoutes.add(r) | baseRoutes.add(r) | ||||
| } | } | ||||
| if (jsonStop.has("desc")){ | if (jsonStop.has("desc")){ | ||||
| palina.location = jsonStop.getString("desc") | palina.location = jsonStop.getString("desc") | ||||
| } | } | ||||
| //there is also "zoneId" which is the zone of the stop (0-> city, etc) | //there is also "zoneId" which is the zone of the stop (0-> city, etc) | ||||
| if(jsonStop.has("stoptimesForPatterns")) { | if(jsonStop.has("stoptimesForPatterns")) { | ||||
| val routesStopTimes = jsonStop.getJSONArray("stoptimesForPatterns") | val routesStopTimes = jsonStop.getJSONArray("stoptimesForPatterns") | ||||
| for (i in 0 until routesStopTimes.length()) { | for (i in 0 until routesStopTimes.length()) { | ||||
| val patternJSON = routesStopTimes.getJSONObject(i) | val patternJSON = routesStopTimes.getJSONObject(i) | ||||
| val mRoute = parseRouteStoptimesJSON(patternJSON) | val mRoute = parseRouteStoptimesJSON(patternJSON) | ||||
| //Log.d("BusTO-MapiFetcher") | |||||
| //val directionId = patternJSON.getJSONObject("pattern").getInt("directionId") | //val directionId = patternJSON.getJSONObject("pattern").getInt("directionId") | ||||
| //TODO: use directionId | //TODO: use directionId | ||||
| palina.addRoute(mRoute) | palina.addRoute(mRoute) | ||||
| for (r in baseRoutes) { | for (r in baseRoutes) { | ||||
| if (palina.gtfsID != null && r.gtfsId.equals(palina.gtfsID)) { | if (mRoute.gtfsId != null && r.gtfsId.equals(mRoute.gtfsId)) { | ||||
| baseRoutes.remove(r) | baseRoutes.remove(r) | ||||
| break | break | ||||
| } | } | ||||
| } | } | ||||
| } | } | ||||
| } | } | ||||
| for (noArrivalRoute in baseRoutes){ | for (noArrivalRoute in baseRoutes){ | ||||
| palina.addRoute(noArrivalRoute) | palina.addRoute(noArrivalRoute) | ||||
| Show All 26 Lines | companion object{ | ||||
| "TRAM" -> routeType = Route.Type.TRAM | "TRAM" -> routeType = Route.Type.TRAM | ||||
| } | } | ||||
| val route = Route( | val route = Route( | ||||
| routeJSON.getString("shortName"), | routeJSON.getString("shortName"), | ||||
| patternJSON.getString("headsign"), | patternJSON.getString("headsign"), | ||||
| routeType, | routeType, | ||||
| passages, | passages, | ||||
| ) | ) | ||||
| route.gtfsId = gtfsId | route.setGtfsId(gtfsId) | ||||
| return route | return route | ||||
| } | } | ||||
| fun makeRequestParameters(requestName:String, variables: JSONObject, query: String): JSONObject{ | fun makeRequestParameters(requestName:String, variables: JSONObject, query: String): JSONObject{ | ||||
| val data = JSONObject() | val data = JSONObject() | ||||
| data.put("operationName", requestName) | data.put("operationName", requestName) | ||||
| data.put("variables", variables) | data.put("variables", variables) | ||||
| data.put("query", query) | data.put("query", query) | ||||
| return data | return data | ||||
| } | } | ||||
| } | } | ||||
| enum class QueryType { | enum class QueryType { | ||||
| ARRIVALS, ALL_STOPS | ARRIVALS, ALL_STOPS | ||||
| } | } | ||||
| } | } | ||||
| No newline at end of file | No newline at end of file | ||||
Public contents are in Creative Commons Attribution-ShareAlike 4.0 (CC-BY-SA) or GNU Free Documentation License (at your option) unless otherwise noted. · Contact / Register