From 69ab8f905c1d442b9bafa6dfe96af5266e6e3def Mon Sep 17 00:00:00 2001
From: NunoSempere <nuno.sempere@protonmail.com>
Date: Thu, 28 Jul 2022 13:33:40 -0400
Subject: [PATCH] feat: wrange Insight Prediction API

---
 src/backend/platforms/insight.ts | 194 +++++++++++++++++--------------
 1 file changed, 104 insertions(+), 90 deletions(-)

diff --git a/src/backend/platforms/insight.ts b/src/backend/platforms/insight.ts
index 370aff5..ee5886b 100644
--- a/src/backend/platforms/insight.ts
+++ b/src/backend/platforms/insight.ts
@@ -1,117 +1,131 @@
 /* Imports */
 import axios from "axios";
 
-import { FetchedQuestion, Platform } from ".";
+import {FetchedQuestion, Platform} from ".";
 
 /* Definitions */
 const platformName = "insight";
 const marketsEnpoint = "https://insightprediction.com/api/markets";
-const getMarketEndpoint = (id: number) => `https://insightprediction.com/api/markets/${id}`
+const getMarketEndpoint = (id : number) => `https://insightprediction.com/api/markets/${id}`;
 
 /* Support functions */
 
-async function fetchQuestionStats(bearer: string, marketId: number){
-  const response = await axios({
-    url: getMarketEndpoint(marketId),
-    method: "GET",
-    headers: {
-      "Content-Type": "application/json",
-      "Accept": "application/json",
-      "Authorization": `Bearer ${bearer}`,
-    },
-  }).then((res) => res.data);
-  // console.log(response)
-  return response;
+async function fetchQuestionStats(bearer: string, marketId: number) {
+    const response = await axios({
+        url: getMarketEndpoint(marketId),
+        method: "GET",
+        headers: {
+            "Content-Type": "application/json",
+            Accept: "application/json",
+            Authorization: `Bearer ${bearer}`
+        }
+    }).then((res) => res.data);
+    // console.log(response)
+    return response;
 }
 
 async function fetchPage(bearer: string, pageNum: number) {
-  const response = await axios({
-    url: `${marketsEnpoint}?page=${pageNum}`,
-    method: "GET",
-    headers: {
-      "Content-Type": "application/json",
-      "Accept": "application/json",
-      "Authorization": `Bearer ${bearer}`,
-    },
-  }).then((res) => res.data);
-  // console.log(response)
-  return response;
+    const response = await axios({
+        url: `${marketsEnpoint}?page=${pageNum}`, // &orderBy=is_resolved&sortedBy=desc`,
+        method: "GET",
+        headers: {
+            "Content-Type": "application/json",
+            Accept: "application/json",
+            Authorization: `Bearer ${bearer}`
+        }
+    }).then((res) => res.data);
+    // console.log(response);
+    return response;
 }
 
-async function fetchData(bearer: string){
-  let pageNum = 1
-  let reachedEnd = false
-  let results = []
-  while(!reachedEnd){
-    let newPage = await fetchPage(bearer, pageNum)
-    let newPageData = newPage.data
-   
-    let marketsWithStats = newPageData.map(marketData => {
-      let marketStats = fetchQuestionStats(bearer, marketData.id)
-      return ({...marketStats, ...marketData})
-    })
+async function fetchData(bearer: string) {
+    let pageNum = 1;
+    let reachedEnd = false;
+    let results = [];
+    while (! reachedEnd) {
+        let newPage = await fetchPage(bearer, pageNum);
+        let newPageData = newPage.data;
+        let marketsFromPage = []
+        for (let market of newPageData) {
+            let response = await fetchQuestionStats(bearer, market.id);
+            let marketData = response.data
+            let marketAnswer = marketData.answer.data
+            delete marketData.answer
+            // These are the options and their prices.
+            let marketOptions = marketAnswer.map(answer => {
+                return({name: answer.title, probability: answer.latest_yes_price, type: "PROBABILITY"})
+            })
+            marketsFromPage.push({
+                ... marketData,
+                options: marketOptions
+            });
+        }
 
-    console.log(`Page = #${pageNum}`)
-    // console.log(newPageData)
-    console.log(marketsWithStats)
-    results.push(...marketsWithStats)
+        let finalObject = marketsFromPage
 
-    let newPagination = newPage.meta.pagination
-    if(newPagination.total_pages == pageNum  ){
-      reachedEnd = true
-    }else{
-      pageNum = pageNum + 1
+        console.log(`Page = #${pageNum}`);
+        // console.log(newPageData)
+        console.dir(finalObject, {depth: null});
+        results.push(... finalObject);
+
+        let newPagination = newPage.meta.pagination;
+        if (newPagination.total_pages == pageNum) {
+            reachedEnd = true;
+        } else {
+            pageNum = pageNum + 1;
+        }
     }
-  }
+    return results
 }
 
 async function processPredictions(predictions: any[]) {
-  let results = await predictions.map((prediction) => {
-    const id = `${platformName}-${prediction.id}`;
-    const probability = prediction.probability;
-    const options: FetchedQuestion["options"] = [
-      {
-        name: "Yes",
-        probability: probability,
-        type: "PROBABILITY",
-      },
-      {
-        name: "No",
-        probability: 1 - probability,
-        type: "PROBABILITY",
-      },
-    ];
-    const result: FetchedQuestion = {
-      id,
-      title: prediction.title,
-      url: "https://example.com",
-      description: prediction.description,
-      options,
-      qualityindicators: {
-        // other: prediction.otherx,
-        // indicators: prediction.indicatorx,
-      },
-    };
-    return result;
-  });
-  return results; //resultsProcessed
+    let results = await predictions.map((prediction) => {
+        const id = `${platformName}-${
+            prediction.id
+        }`;
+        const probability = prediction.probability;
+        const options: FetchedQuestion["options"] = [
+            {
+                name: "Yes",
+                probability: probability,
+                type: "PROBABILITY"
+            }, {
+                name: "No",
+                probability: 1 - probability,
+                type: "PROBABILITY"
+            },
+        ];
+        const result: FetchedQuestion = {
+            id,
+            title: prediction.title,
+            url: "https://example.com",
+            description: prediction.description,
+            options,
+            qualityindicators: {
+                // other: prediction.otherx,
+                // indicators: prediction.indicatorx,
+            }
+        };
+        return result;
+    });
+    return results; // resultsProcessed
 }
 
 /* Body */
 
 export const insight: Platform = {
-  name: platformName,
-  label: "Insight Prediction",
-  color: "#ff0000",
-  version: "v0",
-  async fetcher() {
-    let bearer = process.env.INSIGHT_BEARER;
-    // let data = await fetchData(bearer);
-    // console.log(data)
-    let results = [] // await processPredictions(data); // somehow needed
-    return results;
-  },
-  calculateStars(data) {
-    return 2;
-  },
+    name: platformName,
+    label: "Insight Prediction",
+    color: "#ff0000",
+    version: "v0",
+    async fetcher() {
+        let bearer = process.env.INSIGHT_BEARER;
+        let data = await fetchData(bearer);
+        // console.log(data);
+        let results = []; // await processPredictions(data); // somehow needed
+        return results;
+    },
+    calculateStars(data) {
+        return 2;
+    }
 };