changeset 160:729dc894e61c

Add post support to HTTP client
author Mike Pavone <pavone@retrodev.com>
date Sat, 10 Aug 2013 18:26:14 -0700
parents d81de309a51f
children fc8eecad71e6
files modules/http.tp
diffstat 1 files changed, 34 insertions(+), 26 deletions(-) [+]
line wrap: on
line diff
--- a/modules/http.tp	Sat Aug 10 15:51:31 2013 -0700
+++ b/modules/http.tp	Sat Aug 10 18:26:14 2013 -0700
@@ -73,38 +73,46 @@
 			}
 		}
 	}
+	_handleResponse <- :sock {
+		resp <- ""
+		waiting <- true
+		headerText <- ""
+		rest <- ""
+		status <- ""
+		while: { waiting } do: {
+			data <- sock recv 4096
+			resp <- resp . data
+			pos <- resp find: "\r\n\r\n" else: { -1 }
+			if: pos >= 0 {
+				waiting <- false
+				statusEnd <- resp find: "\r\n" else: { 0 }
+				statusStart <- (resp find: " " else: { 0 }) + 1
+				status <- resp from: statusStart withLength: (statusEnd - statusStart)
+				headerText <- resp from: statusEnd + 2 withLength: pos - (statusEnd + 2)
+				rest <- resp from: pos + 4
+			}
+		}
+		headers <- (headerText splitOn: "\r\n") fold: (dict linear) with: :acc curLine{
+			//TODO: support multiple headers with the same name
+			part <- curLine partitionOn: ":"
+			acc set: (trim: (part before)) (trim: (part after))
+		}
+
+		response: headers status sock rest
+	}
 	#{
 		client:usingPort <- :address :port{
 			#{
 				get <- :path {
 					sock <- socket connectTo: address onPort: port
 					sock send: "GET " . path . " HTTP/1.1\r\nHost: " . address . "\r\n\r\n"
-					resp <- ""
-					waiting <- true
-					headerText <- ""
-					rest <- ""
-					status <- ""
-					while: { waiting } do: {
-						data <- sock recv 4096
-						resp <- resp . data
-						pos <- resp find: "\r\n\r\n" else: { -1 }
-						if: pos >= 0 {
-							waiting <- false
-							statusEnd <- resp find: "\r\n" else: { 0 }
-							statusStart <- (resp find: " " else: { 0 }) + 1
-							status <- resp from: statusStart withLength: (statusEnd - statusStart)
-							headerText <- resp from: statusEnd + 2 withLength: pos - (statusEnd + 2)
-							rest <- resp from: pos + 4
-						}
-					}
-					headers <- (headerText splitOn: "\r\n") fold: (dict linear) with: :acc curLine{
-						//TODO: support multiple headers with the same name
-						part <- curLine partitionOn: ":"
-						acc set: (trim: (part before)) (trim: (part after))
-					}
-
-
-					response: headers status sock rest
+					_handleResponse: sock
+				}
+				post:toPath:withType <- :body :path :type {
+					sock <- socket connectTo: address onPort: port
+					sock send: "POST " . path . " HTTP/1.1\r\nHost: " . address . "\r\nContent-Type: " . type . "\r\nContent-Length: " . (string: (body byte_length)) . "\r\n\r\n"
+					sock send: body
+					_handleResponse: sock
 				}
 			}
 		}