| 1 | (import (chicken format)
|
|---|
| 2 | zmq srfi-18)
|
|---|
| 3 |
|
|---|
| 4 | ;; server keypair
|
|---|
| 5 | (define-values (spk ssk)
|
|---|
| 6 | (curve-keypair))
|
|---|
| 7 |
|
|---|
| 8 | ;; client keypair
|
|---|
| 9 | (define-values (cpk csk)
|
|---|
| 10 | (curve-keypair))
|
|---|
| 11 |
|
|---|
| 12 | (define (spin-server)
|
|---|
| 13 | (thread-start!
|
|---|
| 14 | (lambda ()
|
|---|
| 15 | (let ((socket (make-socket 'rep)))
|
|---|
| 16 | (socket-option-set! socket 'curve/server 1)
|
|---|
| 17 | (socket-option-set! socket 'curve/secretkey ssk)
|
|---|
| 18 | (printf "Server socket setup!~n")
|
|---|
| 19 | (bind-socket socket "tcp://*:5050")
|
|---|
| 20 | (let ((msg (receive-message* socket)))
|
|---|
| 21 | (printf "Received ~a, responding.~n" msg)
|
|---|
| 22 | (send-message socket "pong!")
|
|---|
| 23 | (close-socket socket))))))
|
|---|
| 24 |
|
|---|
| 25 | (define (hit-server msg)
|
|---|
| 26 | (let ((socket (make-socket 'req)))
|
|---|
| 27 | (socket-option-set! socket 'curve/serverkey spk)
|
|---|
| 28 | (socket-option-set! socket 'curve/secretkey csk)
|
|---|
| 29 | (socket-option-set! socket 'curve/pubkey cpk)
|
|---|
| 30 | (connect-socket socket "tcp://192.168.0.7:5050")
|
|---|
| 31 | (send-message socket msg)
|
|---|
| 32 | (printf "Sent message, waiting for response...~n")
|
|---|
| 33 | (printf "Got response: ~a~n" (receive-message* socket))
|
|---|
| 34 | (close-socket socket)))
|
|---|
