quantified.uncertainty/metaforecast
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: wrange Insight Prediction API

Browse Source
This commit is contained in:
NunoSempere 2022-07-28 13:33:40 -04:00
parent a751caf8fb
commit 69ab8f905c
1 changed files with 104 additions and 90 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

96
src/backend/platforms/insight.ts
View File

@ -1,24 +1,24 @@
/* 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){
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}`,
},
Accept: "application/json",
Authorization: `Bearer ${bearer}`
}
}).then((res) => res.data);
// console.log(response)
return response;
@ -26,59 +26,73 @@ async function fetchQuestionStats(bearer: string, marketId: number){
async function fetchPage(bearer: string, pageNum: number) {
const response = await axios({
url: `${marketsEnpoint}?page=${pageNum}`,
url: `${marketsEnpoint}?page=${pageNum}`, // &orderBy=is_resolved&sortedBy=desc`,
method: "GET",
headers: {
"Content-Type": "application/json",
"Accept": "application/json",
"Authorization": `Bearer ${bearer}`,
},
Accept: "application/json",
Authorization: `Bearer ${bearer}`
}
}).then((res) => res.data);
// console.log(response)
// 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}`)
let finalObject = marketsFromPage
console.log(`Page = #${pageNum}`);
// console.log(newPageData)
console.log(marketsWithStats)
results.push(...marketsWithStats)
console.dir(finalObject, {depth: null});
results.push(... finalObject);
let newPagination = newPage.meta.pagination
if(newPagination.total_pages == pageNum ){
reachedEnd = true
}else{
pageNum = pageNum + 1
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 id = `${platformName}-${
prediction.id
}`;
const probability = prediction.probability;
const options: FetchedQuestion["options"] = [
{
name: "Yes",
probability: probability,
type: "PROBABILITY",
},
{
type: "PROBABILITY"
}, {
name: "No",
probability: 1 - probability,
type: "PROBABILITY",
type: "PROBABILITY"
},
];
const result: FetchedQuestion = {
@ -90,11 +104,11 @@ async function processPredictions(predictions: any[]) {
qualityindicators: {
// other: prediction.otherx,
// indicators: prediction.indicatorx,
},
}
};
return result;
});
return results; //resultsProcessed
return results; // resultsProcessed
}
/* Body */
@ -106,12 +120,12 @@ export const insight: Platform = {
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
let data = await fetchData(bearer);
// console.log(data);
let results = []; // await processPredictions(data); // somehow needed
return results;
},
calculateStars(data) {
return 2;
},
}
};