WIP

src/Microsoft.AspNetCore.SignalR.Client.TS/HttpClient.ts

@@ -3,15 +3,15 @@ class HttpClient {
         return this.xhr("GET", url);
     }
 
-    post(url: string): Promise<string> {
+    post(url: string, content: string): Promise<string> {
         return this.xhr("POST", url);
     }
 
-    private xhr(method: string, url: string): Promise<string> {
+    private xhr(method: string, url: string, content?: string): Promise<string> {
         return new Promise((resolve, reject) => {
             let xhr = new XMLHttpRequest();
             xhr.open(method, url, true);
-            xhr.send();
+            xhr.send(content);
             xhr.onload = () => {
                 if (xhr.status >= 200 && xhr.status < 300) {
                     resolve(xhr.response);

src/Microsoft.AspNetCore.SignalR.Client.TS/LongPollingTransport.ts

@@ -0,0 +1,56 @@
+class LongPollingTransport implements ITransport {
+
+    private receiveCallback: (data: string) => void;
+    private url: string;
+    private queryString: string;
+    private pollXhr: XMLHttpRequest;
+
+    // TODO: make the callback a named type
+    // TODO: string won't work for binary formats
+    constructor(receiveCallback: (data: string) => void) {
+         this.receiveCallback = receiveCallback;
+         this.pollXhr = new XMLHttpRequest();
+    }
+
+    connect(url: string, queryString: string): Promise<void> {
+
+        return Promise.resolve();
+    }
+
+    private poll(): void {
+        this.pollXhr.open("GET", , true);
+        this.pollXhr.send();
+        this.pollXhr.onload = () => {
+            if (this.pollXhr.status >= 200 && this.pollXhr.status < 300) {
+                this.receiveCallback(this.pollXhr.response);
+                this.poll();
+            }
+            else {
+                //TODO: handle error
+                /*
+                    {
+                        status: xhr.status,
+                        statusText: xhr.statusText
+                    };
+                }*/
+            };
+
+            this.pollXhr.onerror = () => {
+                /*
+                reject({
+                    status: xhr.status,
+                    statusText: xhr.statusText
+                });*/
+                //TODO: handle error
+            };
+        };
+    }
+
+    send(data: string): Promise<void> {
+        return new HttpClient().post(this.url + "/poll/send?" + this.queryString, data);
+    }
+
+    stop(): void {
+        this.pollXhr.abort();
+    }
+}