elm/core/Native/HTTP.js

55 lines
1.7 KiB
JavaScript

function nativeHTTP(elm) {
"use strict";
var toElmString = Elm.JavaScript.castJSStringToString;
var toJSString = Elm.JavaScript.castStringToJSString;
function registerReq(queue,responses) { return function(req) {
if (req.url !== "") { sendReq(queue,responses,req); }
};
}
function updateQueue(queue,responses) {
if (queue.length > 0) {
Dispatcher.notify(responses.id, queue[0].value);
if (queue[0].value.ctor !== Waiting) {
queue.shift();
setTimeout(function() { updateQueue(queue,responses); }, 0);
}
}
}
function setHeader(pair) {
request.setRequestHeader(toJSString(pair._0), toJSString(pair._1));
}
function sendReq(queue,responses,req) {
var response = { value: Elm.HTTP.Waiting };
queue.push(response);
var request = null;
if (window.ActiveXObject) { request = new ActiveXObject("Microsoft.XMLHTTP"); }
if (window.XMLHttpRequest) { request = new XMLHttpRequest(); }
request.onreadystatechange = function(e) {
if (request.readyState === 4) {
response.value = (request.status === 200
? Success(toElmString(request.responseText))
: Failure(request.status)(toElmString(request.statusText)));
setTimeout(function() { updateQueue(queue,responses); }, 0);
}
};
request.open(toJSString(req.verb), toJSString(req.url), true);
Elm.List.map(setHeader)(req.headers);
request.send(toJSString(req.body));
return null;
}
function send(requests) {
var responses = Elm.Signal.constant(Elm.HTTP.Waiting);
var sender = Elm.Signal.lift(registerReq([],responses))(requests);
function f(x) { return function(y) { return x; } }
return Elm.Signal.lift2(f)(responses)(sender);
}
elm.Native.HTTP = {send:send};
}