[PATCH v1 16/22] tests/js/ring: Add JavaScript class wrapper example

[Ammar Faizi <ammarfaizi2@gnuweeb.org>]

Just an example writing a wrapper to simplify the SQ/CQ mechanism.

Signed-off-by: Ammar Faizi <ammarfaizi2@gnuweeb.org>
---
 tests/js/ring.js | 89 ++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 89 insertions(+)

diff --git a/tests/js/ring.js b/tests/js/ring.js
index 6752fe1..372c6e6 100644
--- a/tests/js/ring.js
+++ b/tests/js/ring.js
@@ -164,6 +164,94 @@ function test_simple_http_post_set_header()
 	assert(h.ch.read_ret() === ss.length);
 }
 
+class CHNet {
+	constructor(cr, url, method) {
+		this.ch = chnet.create_net();
+		this.ch.set_url(url);
+		this.ch.set_method(method);
+		this.cr = cr;
+	}
+
+	prep_read(read_size) {
+		let ring = this.cr.ring;
+		let sqe  = ring.get_sqe();
+		if (!sqe)
+			return false;
+		sqe.prep_read(this.ch, read_size);
+		sqe.set_user_data(this);
+		return true;
+	}
+
+	set_user_data(data) {
+		this.udata = data;
+	}
+
+	get_user_data() {
+		return this.udata;
+	}
+
+	set_header(key, val, overwrite = true) {
+		this.ch.set_request_header(key, val, overwrite);
+	}
+};
+
+class ChromiumNet {
+	constructor() {
+		this.ring = chnet.create_ring(4096);
+	}
+
+	create(url, method = "GET") {
+		return new CHNet(this, url, method);
+	}
+
+	for_each_cqe(cb = null) {
+		let ret = this.ring.for_each_cqe(function (cqe) {
+
+			if (cb)
+				cb(cqe);
+
+			let ch    = cqe.user_data;
+			let ret   = cqe.res;
+			let udata = ch.udata;
+
+			if (ret < 0 && ch.onerror)
+				ch.onerror(ch, ret, udata);
+			else
+				ch.onreadcomplete(ch, ret, udata);
+		});
+		this.ring.cq_advance(ret);
+		return ret;
+	}
+};
+
+function test_classes()
+{
+	const UA = "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/104.0.0.0 Safari/537.36";
+	const NR_REQ = 10;
+
+	let cr = new ChromiumNet;
+	let ch_arr = [];
+	let i, j, ch;
+
+	for (i = 0; i < NR_REQ; i++) {
+		ch = cr.create("http://127.0.0.1:8000/index.php?action=hello");
+		ch.set_header("User-Agent", UA);
+		ch.prep_read(4096);
+		ch.set_user_data(i);
+		ch.onerror = function (cr, ret, udata) {
+			console.log(`Req: ${udata} returned error: ${cr.ch.get_error()}`);
+		};
+		ch.onreadcomplete = function (cr, ret, udata) {
+			console.log(`Req: ${udata} returned ${ret} bytes: ${cr.ch.read_buf()}`);
+		};
+		ch_arr[i] = ch;
+	}
+
+	cr.ring.submit_sqe();
+	cr.ring.wait_cqe(1);
+	cr.for_each_cqe();
+}
+
 function main()
 {
 	test_nop();
@@ -171,6 +259,7 @@ function main()
 	test_simple_http();
 	test_simple_http_set_header();
 	test_simple_http_post_set_header();
+	test_classes();
 }
 
 main();
-- 
Ammar Faizi