🚝 👩‍👦‍👦 🙌🏽 कैसे मैंने कोटलिन के कोरटाइन के माध्यम से एक कस्टम ओखटप ब्रेकर बनाया 👯 👥 🍢

आइए समस्या के बयान से शुरू करते हैं।

हैडर में प्रत्येक अनुरोध में टोकन और यूजर आईडी भेजना आवश्यक है
हेडर से प्रत्येक उत्तर को एक नया टोकन और उपयोगकर्ता आईडी से खींचना आवश्यक है
प्राप्त डेटा को सहेजा जाना चाहिए।

सर्वर इंटरैक्शन के लिए लाइब्रेरी रेट्रोफिट है। मल्टीथ्रेडिंग के लिए कॉरआउट्स जिम्मेदार हैं।
कार्य मुश्किल नहीं है, आपको बस प्रत्येक अनुरोध के लिए ओक् ट्टप क्लाइंट ब्रेकर जोड़ने की आवश्यकता है। आधे घंटे और सब कुछ तैयार है, सब कुछ काम करता है, हर कोई खुश है। लेकिन मैं सोच रहा था, कि क्या ओक् ट्टप क्लाइंट के बिना ब्रेकर बनाना संभव है?

चलिए समस्याओं को हल करने की शुरुआत करते हैं। यदि हेडर जोड़ने में कोई समस्या नहीं है (आपको अनुरोध में @HeaderMap को जोड़ना होगा), तो प्रतिक्रिया में आने वाले हेडर कैसे प्राप्त करें? बहुत सरल है, हमें प्रतिक्रिया वर्ग में अपनी प्रतिक्रिया को लपेटने की आवश्यकता है, जिसमें हेडर () विधि है।

यहाँ क्वेरी इंटरफ़ेस था:

@FormUrlEncoded @POST("someurl/") suspend fun request1(@Field("idLast") idLastFeed: Long, @Field("autoview") autoView: Boolean, @HeaderMap headers: Map<String, String?>): Answer1 @FormUrlEncoded @POST("someurl/") suspend fun request2(@Field("ransom") ransom: Long, @HeaderMap headers: Map<String, String?>): Answer2

लेकिन यह बन गया है:

 @FormUrlEncoded @POST("someurl") suspend fun request1(@Field("idLast") idLastFeed: Long, @Field("autoview") autoView: Boolean, @HeaderMap headers: Map<String, String?>?): Response<Answer1> @FormUrlEncoded @POST("someurl") suspend fun request2(@Field("ransom") ransom: Long, @HeaderMap headers: Map<String, String?>?): Response<Answer2>

अब प्रत्येक अनुरोध के लिए आपको शीर्ष लेख पैरामीटर जोड़ने की आवश्यकता है। चलिए क्वेरी शेल के लिए एक अलग रेस्टक्लायंट क्लास बनाते हैं ताकि टोकन और आईडी प्रेजेंटर में लगातार शेयर्स से अलग न हों। यह इस प्रकार है:

 class RestClient(private val api: Api, private val prefs: SharedPreferences) { suspend fun request1(last: Long, autoView: Boolean): Answer1 { return api.request1(last, autoView, headers()) } suspend fun request2(id: Long): Answer2 { return api.request2(id, headers()) } private val TOKEN_KEY = "Token" private val ID_KEY = "ID" fun headers(): Map<String, String> { return mapOf( TOKEN_KEY to prefs.getString(Constants.Preferences.SP_TOKEN_KEY, ""), ID_KEY to prefs.getLong(Constants.Preferences.SP_ID, -1).toString() ) } }

यह देखा जा सकता है कि हम एक ही काम कर रहे हैं:

हमें अनुरोध के लिए कुछ पैरामीटर मिलते हैं।
अनुरोध करने के लिए शीर्ष लेख जोड़ें।
विधि को बुलाओ।
हेडर से हमें नए मूल्य मिलते हैं।
हम परिणाम वापस करते हैं।

हम सभी अनुरोधों के लिए एक फ़ंक्शन क्यों नहीं बनाते हैं? ऐसा करने के लिए, प्रश्नों को संशोधित करें। @Field के व्यक्तिगत चर के बजाय, अब हम @FieldMap का उपयोग करेंगे। यह हमारे कार्य के लिए पहला पैरामीटर होगा - पर्च। दूसरा पैरामीटर हमारे पास स्वयं अनुरोध होगा। यहां मैंने कोटलिन डीएसएल का उपयोग किया (मैं वास्तव में चाहता था)। मैंने अनुरोध वर्ग बनाया, जिसमें मैंने अनुरोध को कॉल करने के लिए भेजने का कार्य किया।

यह क्वेरी इंटरफ़ेस जैसा दिखता है:

 @FormUrlEncoded @POST("someurl/") suspend fun feedListMap(@FieldMap map: HashMap<String, out Any>?, @HeaderMap headers: Map<String, String?>?): Response<Answer1> @FormUrlEncoded @POST("someurl/") suspend fun feedListMap(@FieldMap map: HashMap<String, out Any>?, @HeaderMap headers: Map<String, String?>?): Response<Answer2>

और यहाँ अनुरोध वर्ग है:

 class Request<T>( var fieldHashMap: java.util.HashMap<String, out Any> = hashMapOf(), var headersHashMap: Map<String, String?>? = mapOf(), var req: suspend (HashMap<String, out Any>?, Map<String, String?>?) -> Response<T>? = { _,_ -> null} ){ fun send(): Response<T>? { return runBlocking { try { req.invoke(fieldHashMap, headersHashMap) } catch (e: Exception) { throw Exception(e.message ?: " ") } catch (t: Throwable) { throw Exception(t.message ?: " ") } } } }

अब RestClient वर्ग इस तरह दिखता है:

 class RestClient(private val api: Api, private val prefs: SharedPreferences) { private val TOKEN_KEY = "Token" private val ID_KEY = "ID" fun headers(): Map<String, String> { return mapOf( TOKEN_KEY to prefs.getString(Constants.Preferences.SP_TOKEN_KEY, ""), ID_KEY to prefs.getLong(Constants.Preferences.SP_ID, -1).toString() ) } fun <T> buildRequest(request: Request<T>.() -> Unit): T? { val req = Request<T>() request(req) val res = req.send() val newToken = res?.headers()?.get(TOKEN_KEY) val newID = res?.headers()?.get(ID_KEY)?.toLong() if (newToken.notNull() && newID.notNull()) { prefs.edit() .putString(TOKEN_KEY, newToken) .putLong(ID_KEY, newID) .apply() } return res?.body() } fun fiedsMapForRequest1(last: Long, autoView: Boolean) = hashMapOf("idLast" to last, "autoview" to autoView) fun fiedsMapForRequest2(ransom: Long, autoView: Boolean) = hashMapOf("ransom" to ransom) }

और अंत में, यह है कि हम अपने अनुरोध को प्रस्तुतकर्ता में कैसे कहते हैं:

 try { val answer1 = restClient.buildRequest<Answer1> { fieldHashMap = restClient.fiedsMapForRequest1(1, false) headersHashMap = restClient.headers() req = api::request1 } val answer2 = restClient.buildRequest<Answer2> { fieldHashMap = restClient.fiedsMapForRequest2(1234) headersHashMap = restClient.headers() req = api::request2 } // do something with answer } catch (e: Exception) { viewState.showError(e.message.toString()) } finally { viewState.hideProgress() }

यहां मैंने कोटलिन की मदद से एक कस्टम ब्रेकर बनाया।

PS इस समस्या का समाधान बहुत ही रोमांचक था, लेकिन, दुर्भाग्य से, परियोजना एक Okhttp ब्रेकर का उपयोग करती है।

कैसे मैंने कोटलिन के कोरटाइन के माध्यम से एक कस्टम ओखटप ब्रेकर बनाया

More articles: