Update Javascript samples w/ XDK

javascript/compliance/create_compliance_job.js → javascript/compliance/create_jobs.js

@@ -1,40 +1,23 @@
-const needle = require('needle');
+const { Client } = require('@xdevplatform/xdk');
 
 // The code below sets the bearer token from your environment variables
 // To set environment variables on macOS or Linux, run the export command below from the terminal:
 // export BEARER_TOKEN='YOUR-TOKEN'
 const token = process.env.BEARER_TOKEN;
-
-const endpointUrl = 'https://api.x.com/2/compliance/jobs'
+const client = new Client({ bearerToken: token });
 
 // For User Compliance Job, replace type value with users instead of tweets
 // Also replace the name value with your desired job name
 const data = {
-    "type": "tweets",
-    "name": 'my_batch_compliance_job'
-}
-
-async function makeRequest() {
-
-    const res = await needle.post(endpointUrl, {
-        json: data,
-        headers: {
-            "User-Agent": "v2BatchComplianceJS",
-            "authorization": `Bearer ${token}`
-        }
-    })
-
-    if (res.body) {
-        return res.body;
-    } else {
-        throw new Error('Unsuccessful request');
-    }
-}
+    type: "tweets",
+    name: 'my_batch_compliance_job'
+};
 
 (async () => {
     try {
         // Make request
-        const response = await makeRequest();
+        const response = await client.compliance.createJobs(data);
+
         console.dir(response, {
             depth: null
         });

javascript/compliance/download_compliance_results.js → javascript/compliance/download_results.js

@@ -1,14 +1,15 @@
-const needle = require('needle');
-
 // Replace with your job download_url
 downloadUrl = ''
 
 async function getRequest() {
+    const res = await fetch(downloadUrl, {
+        headers: {
+            'Accept-Encoding': 'gzip, deflate, br'
+        }
+    })
 
-    const res = await needle('get', downloadUrl, { compressed: true })
-
-    if (res.body) {
-        return res.body.toString('utf8');
+    if (res.ok) {
+        return await res.text();
     } else {
         throw new Error('Unsuccessful request');
     }
@@ -28,4 +29,4 @@ async function getRequest() {
         process.exit(-1);
     }
     process.exit();
-})();
+})();