/**
 * A Simple HTTP POST/GET Helper Class for Groovy 
 *
 * @author 		Tony Landis
 * @copyright 	2007 Tony Landis
 * @website 	http://www.tonylandis.com
 * @license 	BSD License (http://www.opensource.org/licenses/bsd-license.php)
 * @example 	groovy -l 4544 DEWDServer.groovy
 */
    

/**
 * Handle input from the DEWD Client
 * @example: mon:filename|fileid|posturl|authcode|authfield|fileidfield|contentfield 
 */
if(line.toLowerCase().startsWith("mon:")) { 
	
	// get the setup info
	def c = line.replace('mon:','').tokenize('|');
	 
	// start new thread to begin monitoring
	Thread.start{
		 
		def filename = 'c:\\tmp\\'+ c[0]
			  
		// check for dupe thread
		def killThread = new File(filename).exists();
   
   		// rename temp file
		if(new File(filename + '.xxx').exists()) {
			new File(filename + '.xxx').renameTo( new File(filename))
			new File(filename + '.xxx').delete()
		}
   			
		// exit thread?
		if(killThread==true) return null 
			
		def file = new File(filename)
		def lastMod = file.lastModified() 
			 
		while(true)  { 
			if(!file.exists()) { 
				return null
			} else {
				def curMod = file.lastModified();
				if(lastMod != curMod) 
				{
					lastMod = curMod 
   					println '\r\n\r\n--- --- ---\r\n\r\nSaving ' + filename + ' >>> ' + c[2] + "\r\n";
					 
   					def h = new GroovyHTTP(c[2]);  
					h.setParam(c[5], c[1]); // fileid
					h.setParam(c[4], c[3]); // auth
					h.setParam(c[6], new File(filename).getText()); // file content
					h.open()
					h.write()
					h.read()   
					def response = h.getContent() 
					h.close()  
					 
					// debug response
					println 'Server Response:  '+ response  
				}
				Thread.sleep(1000) 
			}  
		} 
	} 
} else {
	println 'Invalid Command: ' + line
}

class GroovyHTTP {
	public method='POST'
	public uri
	public host
	public path
	public port
	public params=null
	public socket=null
	public writer=null
	public reader=null
	public writedata
	public headers = []
	public content

	// set the url and create new URI object
	def GroovyHTTP(url) {
		uri = new URI(url)
		host = uri.getHost()
		path = uri.getRawPath() 
		port = uri.getPort() 
		def tpar = uri.getQuery()
		if(tpar != null && tpar != '') {
			tpar.tokenize('&').each{
				def pp = it.tokenize('=');
				this.setParam(pp[0],pp[1]);
			}
		} 
		if(port == null || port < 0) port = 80
		if(path == null || path.length() == 0) path = "/" 		
	}

	// sets the method (GET or POST)
	def setMethod(setmethod) {
		method = setmethod
	}

	// push params into this request
	def setParam(var,value) {
		if(params != null) 
			params += '&'
		else
			params=''
		params += var +'='+URLEncoder.encode(value) 
	}

	// clear params
	def clearParams() {
		params = null
	}

	// open a new socket
	def open() { 
		socket = new Socket(host, port)
	}

	// write data to the socket
	def write() { 
		def contentLen = 0
		if(params!=null) contentLen = params.length()	
		def writedata = '';
		
		if(this.method == 'GET')	 
			writedata += "GET " + path +'?'+ params + " HTTP/1.0\r\n"
		else
			writedata += "POST " + path + " HTTP/1.0\r\n"
		
		writedata +=
			"Host: " + host + "\r\n" + 
			"Content-Type: application/x-www-form-urlencoded\r\n" + 
			"Content-Length: " + contentLen + "\r\n\r\n" + 
			params + "\r\n"
			"Connection: close\r\n\r\n"   
			   
		writer = new PrintWriter(socket.getOutputStream(), true)
		writer.write(writedata)
		writer.flush() 
	}

	// read response from the server
	def read() { 
		reader = new DataInputStream(socket.getInputStream())
		def c = null
		while (null != ((c = reader.readLine()))) {   
			if(c=='') break 
			headers.add(c) 	 
		} 
	} 

	// get header value by name
	def getHeader(name) {
		def pattern = name + ': ' 
		def result
		headers.each{ 
			if(it ==~ /${pattern}.*/) { 
				result = it.replace(pattern,'').trim()
				return 2
			}   
		}
		return result
	}

	// get the response content
	def getContent() { 
		def row 
		content = ''
		while (null != ((row = reader.readLine()))) content += row + "\r\n"  
		return content = content.trim();
	}

	// close the socket
	def close() {
		reader.close() 
		writer.close()
		socket.close()
	}
}