improve logging, close input ports after usage

1 files changed, 17 insertions, 18 deletions

diff --git a/ebus-racket/inserter.rkt b/ebus-racket/inserter.rkt
index ab97ecf..d72d2ea 100755
--- a/ebus-racket/inserter.rkt
+++ b/ebus-racket/inserter.rkt
@@ -3,6 +3,7 @@
 (require racket/cmdline
 	 racket/tcp
 	 racket/stream
+	 racket/string
 	 net/url
 	 "ebus/layer7.rkt"
 	 "util/tcp-repl.rkt"
@@ -13,29 +14,27 @@
 (define connect-host? (make-parameter null))
 (define connect-port? (make-parameter null))
 (define insert? (make-parameter #f))
-(define baseurl? (make-parameter "http://localhost:8000/sensor"))
+(define baseurl? (make-parameter "http://localhost:8080/api/value"))
+
 
 ;; Send field and value to database server
-(define (insert-field sensor-name datatype offset value)
-  (define type (cond ((member datatype (list "data1c" "data2b" "data2c")) "float")
-		     ((member datatype (list "bit" "byte" "data1b" "word" "bcd")) "int")
-		     ((member datatype (list "byteEnum")) "string")))
-  (set! value (cond ((string=? type "float") (real->decimal-string value))
-		    (else value)))
-  (define response
-    (read-line (put-pure-port 
-		 (string->url (format "~a/~a" (baseurl?) sensor-name))
-		 (string->bytes/utf-8 (format "value=~a&type=~a" value type)))))
-  (define responseJson (string->jsexpr response))
-  (cond ((eq? (json-null) (hash-ref responseJson 'error))
-	      (log-inserter-debug "Successful insert: type=~a value=~a"
-						   type value))
-	(else (log-inserter-error "Error: type=~a value=~a ERROR:~a"
-						   type value response))))
+(define (insert-field sensor-name datatype value)
+  (define url (format "~a/~a" (baseurl?) sensor-name))
+  (define raw-value
+	(cond ((member datatype '(data1c data2b data2c)) (real->decimal-string value))
+          ((member datatype '(bit byte data1b word bcd)) (format "~s" value))
+	      ((member datatype '(byteEnum)) value)
+	      (else (error 'invalid-datatype))))
+  (define input-port (put-impure-port (string->url url) (string->bytes/utf-8 raw-value)))
+  (define server-response (read-line input-port))
+  (close-input-port input-port)
+  (cond ((string=? (list-ref (string-split server-response) 1) "200")
+		 (log-inserter-info "OK: ~a : ~a" url raw-value))
+		(else 
+		 (error "server-error" url raw-value server-response))))
 
 (define (handle-packet packet)
   (for ([field packet])
-       (log-inserter-info "Field: ~a" field)
        (when (insert?)
          (with-handlers ([exn:fail? (lambda (exn)
                                       (log-inserter-error "Failed to insert ~a: ~a" field exn))]