feat: request anomaly detection (#135)

Co-authored-by: Snazzah <7025343+Snazzah@users.noreply.github.com>
Snazzah · Dec 4, 2023 · 8612128 · 8612128
1 parent 9c806ad
commit 8612128
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 1 deletion.
diff --git a/.vscode/settings.json b/.vscode/settings.json
@@ -1,5 +1,6 @@
 {
   "deepscan.enable": true,
   "mochaExplorer.files": "test/**/*.ts",
-  "mochaExplorer.require": "ts-node/register"
+  "mochaExplorer.require": "ts-node/register",
+  "editor.formatOnSave": false
 }
diff --git a/src/search/search.ts b/src/search/search.ts
@@ -162,6 +162,8 @@ export async function search(query: string, options?: SearchOptions, needleOptio
   const response = await needle('get', `https://links.duckduckgo.com/d.js?${queryString(queryObject)}`, needleOptions);
 
   if ((response.body as string).includes('DDG.deep.is506')) throw new Error('A server error occurred!');
+  if (response.body.toString().includes('DDG.deep.anomalyDetectionBlock'))
+    throw new Error('DDG detected an anomaly in the request, you are likely making requests too quickly.');
 
   const searchResults = JSON.parse(SEARCH_REGEX.exec(response.body)![1].replace(/\t/g, '    ')) as (CallbackSearchResult | CallbackNextSearch)[];
 

diff --git a/test/__util__/data/search/anomalyDetectionBlock.js b/test/__util__/data/search/anomalyDetectionBlock.js
diff --git a/test/search/search.ts b/test/search/search.ts
@@ -189,6 +189,16 @@ describe('search/search', () => {
       await expect(search('node', { vqd: SEARCH_QUERY_VQD })).to.eventually.be.rejectedWith(Error, 'A server error occurred!');
       scope.done();
     });
+
+    it('should throw on server anomalies', async () => {
+      const scope = makeSearchNock(DEFAULT_QUERY, 'anomalyDetectionBlock.js');
+
+      await expect(search('node', { vqd: SEARCH_QUERY_VQD })).to.eventually.be.rejectedWith(
+        Error,
+        'DDG detected an anomaly in the request, you are likely making requests too quickly.'
+      );
+      scope.done();
+    });
   });
 
   describe('autocomplete()', () => {