module main

import net
import net.jsonrpc

fn main() {
	addr := '127.0.0.1:42228'
	mut stream := net.dial_tcp(addr)!
	mut log_inter := jsonrpc.LoggingInterceptor{}
	mut inters := jsonrpc.Interceptors{
		event:            [log_inter.on_event]
		encoded_request:  [log_inter.on_encoded_request]
		request:          [log_inter.on_request]
		response:         [log_inter.on_response]
		encoded_response: [log_inter.on_encoded_response]
	}

	mut c := jsonrpc.new_client(jsonrpc.ClientConfig{
		stream:       stream
		interceptors: inters
	})

	println('TCP JSON-RPC client on ${addr}')

	d1 := c.request('kv.delete', {
		'key': 'foo'
	}, 'kv.delete')!
	println('RESULT: ${d1}')

	res := c.batch([
		jsonrpc.new_request('kv.create', {
			'key':   'foo'
			'value': 'bar'
		}, 'kv.create'),
		jsonrpc.new_request('kv.create', {
			'key':   'bar'
			'value': 'foo'
		}, 'kv.create'),
	])!
	println('RESULT: ${res}')

	c.notify('kv.create', {
		'key':   'bazz'
		'value': 'barr'
	})!
}