From 47b22f8f7ddc9db08fffa2d0d3ddf7e4b0dbf4f3 Mon Sep 17 00:00:00 2001
From: Daniel Bulant <danbulant@gmail.com>
Date: Thu, 20 May 2021 18:07:05 +0200
Subject: [PATCH] ratelimit

---
 src/pages/index.svelte | 22 ++++++++++++++++++----
 src/util/ratelimit.js  | 31 +++++++++++++++++++++++++++++++
 2 files changed, 49 insertions(+), 4 deletions(-)
 create mode 100644 src/util/ratelimit.js

diff --git a/src/pages/index.svelte b/src/pages/index.svelte
index a41e1af..599a589 100644
--- a/src/pages/index.svelte
+++ b/src/pages/index.svelte
@@ -1,15 +1,29 @@
 <script>
-	import request from "../util/request";
     import { params } from '@roxi/routify'
+	import request from "../util/request";
+    import ratelimit from "../util/ratelimit";
+    
 	var name = $params.search;
     $: {
         const url = new URL(window.location.toString());
         url.searchParams.set("search", name);
         history.replaceState(history.state, "", url.toString());
     }
-	var result = request("manga", "title=" + name + "&contentRating[]=safe&contentRating[]=suggestive");
-	$: result = request("manga", "title=" + name + "&contentRating[]=safe&contentRating[]=suggestive");
-	result.then(console.log);
+    /**
+     * Searches for results
+     * @param {string} title
+     * @returns {Promise<object>}
+     */
+    function search(title) {
+        var query = "";
+        if(title) query += "title=" + encodeURIComponent(name) + "&";
+        query += "contentRating[]=safe&contentRating[]=suggestive";
+        return request("manga", query);
+    }
+	var result = search(name);
+    result.then(console.log);
+	$: result = ratelimit(search, name);
+	$: result.then(console.log);
 </script>
 
 <main>
diff --git a/src/util/ratelimit.js b/src/util/ratelimit.js
new file mode 100644
index 0000000..1dfcbf2
--- /dev/null
+++ b/src/util/ratelimit.js
@@ -0,0 +1,31 @@
+const ratelimits = new Map();
+
+function callback(func) {
+    const params = ratelimits.get(func);
+    func(...params.params).then(params.result.resolve).catch(params.result.reject);
+    ratelimits.delete(func);
+}
+
+/**
+ * 
+ * @param {T} func 
+ * @param  {...Parameters<typeof T>} params 
+ * @template T
+ * @returns {Promise<ReturnType<T>>}
+ */
+function ratelimit(func, ...params) {
+    const data = ratelimits.get(func) || {
+        timeout: setTimeout(callback, 200, func),
+        params,
+        result: {}
+    };
+    if(!data.promise) data.promise = new Promise((resolve, reject) => {
+        data.result.resolve = resolve;
+        data.result.reject = reject;
+    });
+
+    ratelimits.set(func, data);
+    return data.promise;
+}
+
+export default ratelimit;
\ No newline at end of file