diff options
Diffstat (limited to 'ebus-racket/inserter.rkt')
| -rwxr-xr-x | ebus-racket/inserter.rkt | 22 |
1 files changed, 15 insertions, 7 deletions
diff --git a/ebus-racket/inserter.rkt b/ebus-racket/inserter.rkt index a5a7ac8..cd05ad9 100755 --- a/ebus-racket/inserter.rkt +++ b/ebus-racket/inserter.rkt @@ -1,10 +1,11 @@ #! /usr/bin/env racket #lang racket/base (require racket/cmdline - racket/stream racket/tcp + racket/stream net/url "ebus/layer7.rkt" + "util/tcp-repl.rkt" "util/json.rkt") (define logger (make-logger 'ebus-inserter (current-logger))) @@ -12,7 +13,7 @@ (define connect-host? (make-parameter null)) (define connect-port? (make-parameter null)) (define insert? (make-parameter #f)) -(define baseurl? (make-parameter "http://localhost:8080/api")) +(define baseurl? (make-parameter "http://localhost:8000/sensor")) ;; Send field and value to database server (define (insert-field sensor-name datatype offset value) @@ -20,14 +21,19 @@ ((member datatype (list "bit" "byte" "data1b" "word" "bcd")) "int") ((member datatype (list "byteEnum")) "string"))) (set! value (cond ((string=? type "float") (real->decimal-string value)) - ((string=? type "int") (number->string value)) (else value))) - (put-pure-port - (string->url (format "~a/value/~a" (baseurl?) sensor-name)) - (string->bytes/utf-8 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-message logger 'debug (format "Successful insert: type=~a value=~a" + type value) #t)) + (else (log-message logger 'error (format "Error: type=~a value=~a ERROR:~a" + type value response) #t)))) (define (handle-packet packet) - (for ([field packet]) (log-message logger 'info (format "Field: ~a" field) #t) (when (insert?) @@ -48,6 +54,8 @@ [("-c" "--connect") host port "Connect to server <host> <port>" (connect-host? host) (connect-port? (string->number port))] + ["--tcp-repl" port "Open REPL on TCP <port>" + (tcp-repl-run (namespace-anchor->namespace repl-ns-anchor) (string->number port))] ["--insert" "Do Insert into Database" (insert? #t)] ["--baseurl" url "Database server http url" |