Diversión con Asincronía

[UlisesGascon]

Notas

Nivel 1

prueba

llamadaAjax(urlAire, (err,dato) => {
	err ? console.warn(err) : console.log(dato);
})

llamadaAjax(url)
	.then(console.log)
	.catch(console.warn)

async function init(){
	try {
		const dato = await llamadaAjax(urlAire)
		console.log(dato)
	} catch(err) {
		console.warn(err)
	}
}

Librería

const urlAire = "http://airemad.com/api/v1/station"

function llamadaAjax(url, cb){
	const promesa = new Promise ((resolve, reject) => {
		fetch(url)
		    .then(request => request.text())
		    .then(text => {
		        resolve(JSON.parse(text));
		    })
		    .catch(error => {
		        reject(error);
		    });
	})

	if(cb && typeof(cb) === "function"){
		promesa
			.then(data => cb(false, data))
			.catch(cb)
	} else {
		return promesa
	}
	
}

Nivel 2

prueba

const servEstaciones = servicioHttp("http://airemad.com/api/v1/")

servEstaciones("station")
    .then(console.log)
    .catch(console.warn)

servEstS001("station/S001", (err, data) => {
   if(err) {
      console.warn(err)  
 } else {
     console.log(data)
}
})

código

function servicioHttp (baseUrl){

	//credetials, tokens, etc..

	return function(endpoint, cb) {

		const promesa = new Promise ((resolve, reject) => {
			fetch(${baseUrl + endpoint})
			    .then(request => request.text())
			    .then(text => {
			        resolve(JSON.parse(text));
			    })
			    .catch(error => {
			        reject(error);
			    });
		})

		if(cb && typeof(cb) === "function"){
			promesa
				.then(data => cb(false, data))
				.catch(cb)
		} else {
			return promesa
		}


	}
}

Nivel 3 🦄

reto

//HEADERS
servicioHttp("http://airemad.com/api/v1/")
	.headers({
      'Accept': 'application/json',
      'Content-Type': 'application/json'
    })
    .method("trace")
    //promesa o cb




// comportamiento para GET, POST, PUT, DELETE
servicioHttp("http://airemad.com/api/v1/")
	.get("station/123")
	.then(console.log)
	.catch(console.warn)

servicioHttp("http://airemad.com/api/v1/")
	.get("station/123", (err, data) => {
		if(err){
			console.warn(err)
		} else {
			console.log(data)
		}

	})


// comportamiento para GET, POST, PUT, DELETE
servicioHttp("http://airemad.com/api/v1/")
	.post("station", {id:123})
	.then(console.log)
	.catch(console.warn)

código

function $http (baseUrl){

	let headers = {}
	function wrapperAjax ({url, method, data}){
		const setup = {}
			setup.method = method;
			setup.headers = headers;
			if(data){
				setup.body = typeof(data) !== "string" ? JSON.stringify(data): data;
			}
		return fetch(`${baseUrl+ url}`, setup)
	}

	function fallbackStrategy (prom, cb) {
		if(cb && typeof(cb) === "function") {
			prom
				.then(response => response.json())
				.then(data => cb(false, data))
				.catch(cb)
		} else {
			return prom.then(response => response.json())
		}
	}

	return {
		headers(obj){
			const _self = this;
			this.headers = obj;
			return _self;
		},
		method(verb, url, data, cb){
			return fallbackStrategy(wrapperAjax({
				url, method:verb, data
			}), cb)
		},
		get(url, cb){
			return fallbackStrategy(wrapperAjax({
				url, method:"GET"
			}), cb)
		},
		post(url, data, cb){
			return fallbackStrategy(wrapperAjax({
				url, method:"POST", data
			}), cb)
		},
		put(url, data, cb){
			return fallbackStrategy(wrapperAjax({
				url, method:"PUT", data
			}), cb)
		},
		delete(url, cb){
			return fallbackStrategy(wrapperAjax({
				url, method:"DELETE"
			}), cb)
		}
	}
}

Test Final

$http("http://airemad.com/api/v1/")
	.get("station/S001")
	.then(console.log)
	.catch(console.warn)

[UlisesGascon]

Pendiente @Xexuline

• Probar el código y hacer que funcione
• headers necesita un refactor
• Soporte a XMLHttpRequest
• Test unitarios con 89% de C