Compare commits

..

No commits in common. "8a191bb694b3ed1ca8d2afda6f88e283ea65eef3" and "a78918da6179ebe423e523dd88d41276417ff150" have entirely different histories.

15 changed files with 70468 additions and 9259 deletions

2
.gitignore vendored
View File

@ -31,7 +31,7 @@ yarn-error.log*
# yarn vs npm conflict # yarn vs npm conflict
package-lock.json ## use yarn.lock instead package-lock.json ## use yarn.lock instead
# yarn.lock yarn.lock
# Local Netlify folder # Local Netlify folder
.netlify .netlify

View File

@ -91,16 +91,3 @@ Overall, the services which we use are:
- Commits follow [conventional commits](https://www.conventionalcommits.org/en/v1.0.0/#summary) - Commits follow [conventional commits](https://www.conventionalcommits.org/en/v1.0.0/#summary)
- For elicit and metaculus, this library currently filters out questions with <10 predictions. - For elicit and metaculus, this library currently filters out questions with <10 predictions.
- The database is updated once a day, at 3:00 AM UTC, with the command `ts-node -T src/backend/flow/doEverythingForScheduler.ts`. The frontpage is updated after that, at 6:00 AM UTC with the command `ts-node -T src/backend/index.ts frontpage`. It's possible that either of these two operations makes the webpage briefly go down.
## To do
- [x] Update Metaculus and Manifold Markets fetchers
- [ ] Upgrade to [React 18](https://reactjs.org/blog/2022/03/08/react-18-upgrade-guide.html). This will require dealing with the workaround we used for [this issue](https://github.com/vercel/next.js/issues/36019#issuecomment-1103266481)
- [ ] Add markets from [Insight Prediction](https://insightprediction.com/).
- [ ] Add database of resolutions
- [ ] Allow users to embed predictions in the EA Forum/LessWrong (in progress)
- [ ] Find a long-term mantainer for this project
- [ ] Allow users to record their own predictions
- [ ] Release snapshots (I think @niplav is working on this)
- [ ] ...

70279
package-lock.json generated Normal file

File diff suppressed because it is too large Load Diff

View File

@ -7,7 +7,8 @@
"url": "git+https://github.com/QURIresearch/metaforecast.git" "url": "git+https://github.com/QURIresearch/metaforecast.git"
}, },
"keywords": [ "keywords": [
"forecasts", "predictions" "forecasts",
"predictions"
], ],
"author": "Nuño Sempere", "author": "Nuño Sempere",
"license": "MIT", "license": "MIT",
@ -26,96 +27,92 @@
"dbshell": ". .env && psql $DIGITALOCEAN_POSTGRES" "dbshell": ". .env && psql $DIGITALOCEAN_POSTGRES"
}, },
"dependencies": { "dependencies": {
"@floating-ui/react-dom": "^0.7.2", "@floating-ui/react-dom": "^0.7.0",
"@graphql-yoga/node": "^2.13.13", "@graphql-yoga/node": "^2.1.0",
"@pothos/core": "^3.22.8", "@pothos/core": "^3.5.1",
"@pothos/plugin-prisma": "^3.35.6", "@pothos/plugin-prisma": "^3.4.0",
"@pothos/plugin-relay": "^3.28.6", "@pothos/plugin-relay": "^3.10.0",
"@prisma/client": "^3.15.2", "@prisma/client": "^3.11.1",
"@quri/squiggle-lang": "^0.2.12", "@quri/squiggle-lang": "^0.2.11",
"@tailwindcss/forms": "^0.4.1", "@tailwindcss/forms": "^0.4.0",
"@tailwindcss/typography": "^0.5.7", "@tailwindcss/typography": "^0.5.1",
"@types/chroma-js": "^2.1.4", "@types/chroma-js": "^2.1.3",
"@types/dom-to-image": "^2.6.4", "@types/dom-to-image": "^2.6.4",
"@types/google-spreadsheet": "^3.3.0", "@types/google-spreadsheet": "^3.2.1",
"@types/jsdom": "^16.2.15", "@types/jsdom": "^16.2.14",
"@types/nprogress": "^0.2.0", "@types/nprogress": "^0.2.0",
"@types/react": "^17.0.50", "@types/react": "^17.0.39",
"@types/react-copy-to-clipboard": "^5.0.4", "@types/react-copy-to-clipboard": "^5.0.2",
"@types/textversionjs": "^1.1.1", "@types/textversionjs": "^1.1.1",
"@types/tunnel": "^0.0.3", "@types/tunnel": "^0.0.3",
"airtable": "^0.11.5", "airtable": "^0.11.1",
"ajv": "^8.11.0", "ajv": "^8.11.0",
"algoliasearch": "^4.14.2", "algoliasearch": "^4.10.3",
"autoprefixer": "10.4.5", "autoprefixer": "^10.1.0",
"axios": "^0.25.0", "axios": "^0.25.0",
"chroma-js": "^2.4.2", "chroma-js": "^2.4.2",
"critters": "^0.0.16", "critters": "^0.0.16",
"date-fns": "^2.29.3", "date-fns": "^2.28.0",
"dom-to-image": "^2.6.0", "dom-to-image": "^2.6.0",
"dotenv": "^16.0.3", "dotenv": "^16.0.0",
"fetch": "^1.1.0", "fetch": "^1.1.0",
"fs": "^0.0.1-security", "fs": "^0.0.1-security",
"fuse.js": "^6.6.2", "fuse.js": "^6.4.6",
"google-spreadsheet": "^3.3.0", "google-spreadsheet": "^3.1.15",
"graphql": "^16.6.0", "graphql": "^16.3.0",
"graphql-request": "^4.3.0", "graphql-request": "^4.0.0",
"html-to-image": "^1.10.8", "html-to-image": "^1.7.0",
"https": "^1.0.0", "https": "^1.0.0",
"isomorphic-fetch": "^3.0.0", "isomorphic-fetch": "^3.0.0",
"jsdom": "^19.0.0", "jsdom": "^19.0.0",
"json2csv": "^5.0.7", "json2csv": "^5.0.5",
"multiselect-react-dropdown": "^2.0.25", "multiselect-react-dropdown": "^2.0.17",
"next": "^12.3.1", "next": "12",
"next-plausible": "^3.6.3", "next-plausible": "^3.1.6",
"next-urql": "^3.3.3", "next-urql": "^3.3.2",
"nprogress": "^0.2.0", "nprogress": "^0.2.0",
"open": "^7.4.2", "open": "^7.3.1",
"papaparse": "^5.3.2", "papaparse": "^5.3.0",
"pg": "^8.8.0", "pg": "^8.7.3",
"postcss": "^8.4.18", "postcss": "^8.2.1",
"postcss-flexbugs-fixes": "^5.0.2", "postcss-flexbugs-fixes": "^5.0.2",
"postcss-preset-env": "^7.8.2", "postcss-preset-env": "^7.3.2",
"prisma": "^3.15.2", "prisma": "^3.11.1",
"query-string": "^7.1.1", "query-string": "^7.1.1",
"re-resizable": "^6.9.9", "re-resizable": "^6.9.9",
"react": "^17.0.2", "react": "^17.0.2",
"react-component-export-image": "^1.0.6", "react-component-export-image": "^1.0.6",
"react-compound-slider": "^3.4.0", "react-compound-slider": "^3.3.1",
"react-copy-to-clipboard": "^5.1.0", "react-copy-to-clipboard": "^5.0.3",
"react-dom": "^17.0.2", "react-dom": "^17.0.2",
"react-dropdown": "^1.11.0", "react-dropdown": "^1.9.2",
"react-hook-form": "^7.38.0", "react-hook-form": "^7.27.0",
"react-icons": "^4.6.0", "react-icons": "^4.2.0",
"react-is": "^18.2.0", "react-is": "^18.0.0",
"react-markdown": "^8.0.3", "react-markdown": "^8.0.0",
"react-safe": "^1.3.0", "react-safe": "^1.3.0",
"react-select": "^5.5.4", "react-select": "^5.2.2",
"remark-gfm": "^3.0.1", "remark-gfm": "^3.0.1",
"tabletojson": "^2.0.7", "tabletojson": "^2.0.4",
"tailwindcss": "^3.2.0", "tailwindcss": "^3.0.22",
"textversionjs": "^1.1.3", "textversionjs": "^1.1.3",
"ts-node": "^10.9.1", "ts-node": "^10.7.0",
"tunnel": "^0.0.6", "tunnel": "^0.0.6",
"urql": "^2.2.3", "urql": "^2.2.0",
"urql-custom-scalars-exchange": "^0.1.6", "urql-custom-scalars-exchange": "^0.1.5",
"victory": "^36.6.8" "victory": "^36.3.2"
},
"resolutions": {
"@types/react": "<18.0.0"
}, },
"devDependencies": { "devDependencies": {
"@graphql-codegen/cli": "^2.13.7", "@graphql-codegen/cli": "^2.6.2",
"@graphql-codegen/introspection": "^2.2.1", "@graphql-codegen/introspection": "^2.1.1",
"@graphql-codegen/near-operation-file-preset": "^2.4.3", "@graphql-codegen/near-operation-file-preset": "^2.2.9",
"@graphql-codegen/schema-ast": "^2.5.1", "@graphql-codegen/schema-ast": "^2.4.1",
"@graphql-codegen/typed-document-node": "^2.3.5", "@graphql-codegen/typed-document-node": "^2.2.8",
"@graphql-codegen/typescript": "^2.7.5", "@graphql-codegen/typescript": "^2.4.8",
"@graphql-codegen/typescript-operations": "^2.5.5", "@graphql-codegen/typescript-operations": "^2.3.5",
"@svgr/cli": "^6.5.0", "@netlify/plugin-nextjs": "^4.2.4",
"@svgr/cli": "^6.2.1",
"@types/pg": "^8.6.5", "@types/pg": "^8.6.5",
"eslint": "^8.25.0", "netlify-cli": "^9.13.6"
"eslint-config-next": "^12.3.1",
"typescript": "4.8.4"
} }
} }

8
src/Global.d.ts vendored
View File

@ -1,8 +0,0 @@
// Workaround related to: https://github.com/vercel/next.js/issues/29788
// https://github.com/vercel/next.js/issues/29788#issuecomment-1000595524
declare type StaticImageData = {
src: string;
height: number;
width: number;
placeholder?: string;
};

View File

@ -1,218 +1,15 @@
/* Imports */ /* Imports */
import {or} from "ajv/dist/compile/codegen";
import axios from "axios"; import axios from "axios";
import {FetchedQuestion, Platform} from "."; import {FetchedQuestion, Platform} from ".";
import {QuestionOption} from "../../common/types";
import toMarkdown from "../utils/toMarkdown";
import { average } from "../../utils";
/* Definitions */ /* Definitions */
const platformName = "insight"; const platformName = "insight";
const marketsEnpoint = "https://insightprediction.com/api/markets?orderBy=is_resolved&sortedBy=asc"; 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}`;
const SPORTS_CATEGORIES = [
'World Cup',
'MLB',
'Futures',
'Sports',
'EPL',
'Golf',
'NHL',
'College Football'
]
/* Support functions */ /* Support functions */
// Stubs
const excludeMarketFromTitle = (title : any) => {
if (!!title) {
return title.includes(" vs ") || title.includes(" Over: ") || title.includes("NFL") || title.includes("Will there be a first time winner") || title.includes("Premier League")
} else {
return true
}
}
const hasActiveYesNoOrderBook = (orderbook : any) => {
if (!!orderbook) {
let yes = !!orderbook.yes && !!orderbook.yes.buy && Array.isArray(orderbook.yes.buy) && orderbook.yes.buy.length != 0 && !!orderbook.yes.buy[0].price && !!orderbook.yes.sell && Array.isArray(orderbook.yes.sell) && orderbook.yes.sell.length != 0 && !!orderbook.yes.sell[0].price
let no = !!orderbook.no && !!orderbook.no.buy && Array.isArray(orderbook.no.buy) && orderbook.no.buy.length != 0 && !!orderbook.no.buy[0].price && !!orderbook.no.sell && Array.isArray(orderbook.no.sell) && orderbook.no.sell.length != 0 && !!orderbook.no.sell[0].price
return yes && no
} else {
return false
}
}
const isBinaryQuestion = (data : any) => Array.isArray(data) && data.length == 1
const geomMean = (a : number, b : number) => Math.sqrt(a * b)
const processRelativeUrls = (a : string) => a.replaceAll("] (/", "](http://insightprediction.com/").replaceAll("](/", "](http://insightprediction.com/")
const processDescriptionText = (text : any) => {
if (typeof text === 'string') {
return processRelativeUrls(toMarkdown(text))
} else {
return ""
}
}
const getOrderbookPrize = (orderbook : any) => {
let yes_min_cents = orderbook.yes.buy[0].price
let yes_max_cents = orderbook.yes.sell[0].price
let yes_min = Number(yes_min_cents.slice(0, -1))
let yes_max = Number(yes_max_cents.slice(0, -1))
let yes_price_orderbook = geomMean(yes_min, yes_max)
return yes_price_orderbook
}
const getAnswerProbability = (answer : any) => {
let orderbook = answer.orderbook
let latest_yes_price = answer.latest_yes_price
if (!! orderbook && hasActiveYesNoOrderBook(orderbook)) {
let yes_price_orderbook = getOrderbookPrize(orderbook)
let yes_probability = (latest_yes_price ? geomMean(latest_yes_price, yes_price_orderbook) : yes_price_orderbook) / 100
return yes_probability
} else if (!! latest_yes_price) {
return latest_yes_price / 100
} else {
return -1
}
}
// Fetching
async function fetchPage(bearer: string, pageNum: number) {
let pageUrl = `${marketsEnpoint}&page=${pageNum}`
const response = await axios({
url: pageUrl, // &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 fetchMarket(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;
}
const processMarket = (market : any) => {
let options: FetchedQuestion["options"] = []
if (!!market && !!market.answer && !!market.answer.data) {
let data = market.answer.data
if (isBinaryQuestion(data)) { // Binary questions
let answer = data[0]
let probability = getAnswerProbability(answer)
if (probability != -1) {
options = [
{
name: "Yes",
probability: probability,
type: "PROBABILITY"
}, {
name: "No",
probability: 1 - probability,
type: "PROBABILITY"
},
];
}
} else { // non binary question
for (let answer of data) {
let probability = getAnswerProbability(answer)
if (probability != -1) {
let newOption: QuestionOption = ({
name: String(answer.title),
probability: probability,
type: "PROBABILITY"
});
options.push(newOption)
}
}
}
if (!! options && Array.isArray(options) && options.length > 0) {
const id = `${platformName}-${
market.id
}`
const result: FetchedQuestion = {
id: id,
title: market.title,
url: market.url,
description: processDescriptionText(market.rules),
options,
qualityindicators: market.coin_id == "USD" ? (
{volume: market.volume}
) : ({})
};
return result;
}
}
return null
}
async function fetchAllMarkets(bearer: string) {
let pageNum = 1
let markets = []
let categories = []
let isEnd = false
while (! isEnd) {
if(pageNum % 20 == 0){
console.log(`Fetching page #${pageNum}`) // : ${pageUrl}
}
let page = await fetchPage(bearer, pageNum)
// console.log(JSON.stringify(page, null, 2))
let data = page.data
if (!! data && Array.isArray(data) && data.length > 0) {
let lastMarket = data[data.length - 1]
let isLastMarketResolved = lastMarket.is_resolved
if (isLastMarketResolved == true) {
isEnd = true
}
let newMarkets = data.filter(market => !market.is_resolved && !market.is_expired && ! excludeMarketFromTitle(market.title))
for (let initMarketData of newMarkets) {
let fullMarketDataResponse = await fetchMarket(bearer, initMarketData.id)
let fullMarketData = fullMarketDataResponse.data
let processedMarketData = processMarket(fullMarketData)
if (processedMarketData != null && ! SPORTS_CATEGORIES.includes(fullMarketData.category)) {
console.log(`- Adding: ${
fullMarketData.title
}`)
console.group()
console.log(fullMarketData)
console.log(JSON.stringify(processedMarketData, null, 2))
console.groupEnd()
markets.push(processedMarketData)
}
let category = fullMarketData.category
categories.push(category)
}
} else {
isEnd = true
} pageNum = pageNum + 1
}
console.log(markets)
console.log(categories)
return markets
}
/* /*
async function fetchQuestionStats(bearer : string, marketId : number) { async function fetchQuestionStats(bearer : string, marketId : number) {
const response = await axios({ const response = await axios({
@ -228,7 +25,19 @@ async function fetchQuestionStats(bearer : string, marketId : number) {
return response; return response;
} }
async function fetchPage(bearer : string, pageNum : number) {
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) { async function fetchData(bearer : string) {
let pageNum = 1; let pageNum = 1;
@ -303,6 +112,7 @@ async function processPredictions(predictions : any[]) {
return results; // resultsProcessed return results; // resultsProcessed
} }
*/ */
/* Body */ /* Body */
export const insight: Platform = { export const insight: Platform = {
name: platformName, name: platformName,
@ -311,29 +121,12 @@ export const insight: Platform = {
version: "v1", version: "v1",
async fetcher() { async fetcher() {
let bearer = process.env.INSIGHT_BEARER; let bearer = process.env.INSIGHT_BEARER;
if (!! bearer) { // let data = await fetchData(bearer);
let data = await fetchAllMarkets(bearer); // console.log(data);
return data let results: FetchedQuestion[] = []; // await processPredictions(data); // somehow needed
} else { return results;
throw Error("No INSIGHT_BEARER available in environment")
}
// let results: FetchedQuestion[] = []; // await processPredictions(data); // somehow needed
// return results;
}, },
calculateStars(data) { calculateStars(data) {
let nuno = () => { return 2;
if((data.qualityindicators.volume || 0) > 10000){
return 4
} else if((data.qualityindicators.volume || 0) > 1000){
return 3
} else{
return 2
}
}
let eli = () => null;
let misha = () => null;
let starsDecimal = average([nuno()]); //, eli(data), misha(data)])
let starsInteger = Math.round(starsDecimal);
return starsInteger;
} }
}; };

View File

@ -6,12 +6,12 @@ import { FetchedQuestion, Platform } from "./";
/* Definitions */ /* Definitions */
const platformName = "manifold"; const platformName = "manifold";
const ENDPOINT = "https://manifold.markets/api/v0/markets"; const endpoint = "https://manifold.markets/api/v0/markets";
// See https://manifoldmarkets.notion.site/Manifold-Markets-API-5e7d0aef4dcf452bb04b319e178fabc5 // See https://manifoldmarkets.notion.site/Manifold-Markets-API-5e7d0aef4dcf452bb04b319e178fabc5
/* Support functions */ /* Support functions */
async function fetchPage(endpoint: string) { async function fetchData() {
let response = await axios({ let response = await axios({
url: endpoint, url: endpoint,
method: "GET", method: "GET",
@ -23,31 +23,6 @@ async function fetchPage(endpoint: string) {
return response; return response;
} }
async function fetchAllData(){
let endpoint = ENDPOINT
let end = false
let allData = []
let counter = 1
while(!end){
console.log(`Query #${counter}: ${endpoint}`)
let newData = await fetchPage(endpoint)
if(Array.isArray(newData)){
allData.push(...newData)
let hasReachedEnd = (newData.length == 0) || (newData[newData.length -1] == undefined) || (newData[newData.length -1].id == undefined)
if(!hasReachedEnd){
let lastId = newData[newData.length -1].id
endpoint = `${ENDPOINT}?before=${lastId}`
}else{
end = true
}
}else{
end = true
}
counter = counter +1
}
return allData
}
function showStatistics(results: FetchedQuestion[]) { function showStatistics(results: FetchedQuestion[]) {
console.log(`Num unresolved markets: ${results.length}`); console.log(`Num unresolved markets: ${results.length}`);
let sum = (arr: number[]) => arr.reduce((tally, a) => tally + a, 0); let sum = (arr: number[]) => arr.reduce((tally, a) => tally + a, 0);
@ -88,7 +63,7 @@ function processPredictions(predictions: any[]): FetchedQuestion[] {
id: id, id: id,
title: prediction.question, title: prediction.question,
url: prediction.url, url: prediction.url,
description: prediction.description || "", description: prediction.description,
options, options,
qualityindicators: { qualityindicators: {
createdTime: prediction.createdTime, createdTime: prediction.createdTime,
@ -115,7 +90,7 @@ export const manifold: Platform = {
color: "#793466", color: "#793466",
version: "v1", version: "v1",
async fetcher() { async fetcher() {
let data = await fetchAllData(); let data = await fetchData();
let results = processPredictions(data); // somehow needed let results = processPredictions(data); // somehow needed
showStatistics(results); showStatistics(results);
return results; return results;

View File

@ -64,7 +64,6 @@ const predictableProps = {
additionalProperties: true, additionalProperties: true,
}, },
}, },
nullable: true,
additionalProperties: true, additionalProperties: true,
}, },
} as const; } as const;
@ -212,17 +211,15 @@ const fetchAndValidate = async <T = unknown>(
url: string, url: string,
validator: ValidateFunction<T> validator: ValidateFunction<T>
): Promise<T> => { ): Promise<T> => {
// console.log(url); console.log(url);
const data = await fetchWithRetries<object>(url); const data = await fetchWithRetries<object>(url);
if (validator(data)) { if (validator(data)) {
return data; return data;
}else{
console.log(data)
throw new Error(
`Response validation for url ${url} failed: ` +
JSON.stringify(validator.errors, null, 4)
);
} }
throw new Error(
`Response validation for url ${url} failed: ` +
JSON.stringify(validator.errors)
);
}; };
export async function fetchApiQuestions( export async function fetchApiQuestions(

View File

@ -1,27 +1,28 @@
import Error from "next/error"; import { FetchedQuestion, Platform } from "..";
import {FetchedQuestion, Platform} from ".."; import { average } from "../../../utils";
import {average} from "../../../utils"; import { sleep } from "../../utils/sleep";
import {sleep} from "../../utils/sleep";
import { import {
ApiCommon, ApiCommon,
ApiMultipleQuestions, ApiMultipleQuestions,
ApiPredictable, ApiPredictable,
ApiQuestion, ApiQuestion,
fetchApiQuestions, fetchApiQuestions,
fetchSingleApiQuestion fetchSingleApiQuestion,
} from "./api"; } from "./api";
const platformName = "metaculus"; const platformName = "metaculus";
const now = new Date().toISOString(); const now = new Date().toISOString();
const SLEEP_TIME = 1000; const SLEEP_TIME = 1000;
async function apiQuestionToFetchedQuestions(apiQuestion: ApiQuestion): Promise<FetchedQuestion[]> { async function apiQuestionToFetchedQuestions(
apiQuestion: ApiQuestion
): Promise<FetchedQuestion[]> {
// one item can expand: // one item can expand:
// - to 0 questions if we don't want it; // - to 0 questions if we don't want it;
// - to 1 question if it's a simple forecast // - to 1 question if it's a simple forecast
// - to multiple questions if it's a group (see https://github.com/quantified-uncertainty/metaforecast/pull/84 for details) // - to multiple questions if it's a group (see https://github.com/quantified-uncertainty/metaforecast/pull/84 for details)
const skip = (q : ApiPredictable) : boolean => { const skip = (q: ApiPredictable): boolean => {
if (q.publish_time > now || now > q.resolve_time) { if (q.publish_time > now || now > q.resolve_time) {
return true; return true;
} }
@ -31,119 +32,89 @@ async function apiQuestionToFetchedQuestions(apiQuestion: ApiQuestion): Promise<
return false; return false;
}; };
const buildFetchedQuestion = (q : ApiPredictable & ApiCommon) : Omit < FetchedQuestion, const buildFetchedQuestion = (
"url" | "description" | "title" > => { q: ApiPredictable & ApiCommon
const isBinary = q.possibilities.type === "binary"; ): Omit<FetchedQuestion, "url" | "description" | "title"> => {
let options: FetchedQuestion["options"] = []; const isBinary = q.possibilities.type === "binary";
if (isBinary) { let options: FetchedQuestion["options"] = [];
const probability = q.community_prediction?.full.q2; if (isBinary) {
if (probability !== undefined) { const probability = q.community_prediction.full.q2;
options = [ if (probability !== undefined) {
{ options = [
name: "Yes", {
probability: probability, name: "Yes",
type: "PROBABILITY" probability: probability,
}, { type: "PROBABILITY",
name: "No", },
probability: 1 - probability, {
type: "PROBABILITY" name: "No",
}, probability: 1 - probability,
]; type: "PROBABILITY",
} },
];
} }
return { }
id: `${platformName}-${ return {
q.id id: `${platformName}-${q.id}`,
}`, options,
options, qualityindicators: {
qualityindicators: { numforecasts: q.number_of_predictions,
numforecasts: q.number_of_predictions },
extra: {
resolution_data: {
publish_time: apiQuestion.publish_time,
resolution: apiQuestion.resolution,
close_time: apiQuestion.close_time,
resolve_time: apiQuestion.resolve_time,
}, },
extra: { },
resolution_data: {
publish_time: apiQuestion.publish_time,
resolution: apiQuestion.resolution,
close_time: apiQuestion.close_time,
resolve_time: apiQuestion.resolve_time
}
}
};
}; };
};
if (apiQuestion.type === "group") { if (apiQuestion.type === "group") {
await sleep(SLEEP_TIME); await sleep(SLEEP_TIME);
let apiQuestionDetailsTemp const apiQuestionDetails = await fetchSingleApiQuestion(apiQuestion.id);
try{
apiQuestionDetailsTemp = await fetchSingleApiQuestion(apiQuestion.id);
}catch(error){
console.log(error)
return []
}
const apiQuestionDetails = apiQuestionDetailsTemp
if (apiQuestionDetails.type !== "group") { if (apiQuestionDetails.type !== "group") {
console.log("Error: expected `group` type") throw new Error("Expected `group` type"); // shouldn't happen, this is mostly for typescript
return [] //throw new Error("Expected `group` type"); // shouldn't happen, this is mostly for typescript
}else{
try{
let result = (apiQuestionDetails.sub_questions || []).filter((q) => ! skip(q)).map((sq) => {
const tmp = buildFetchedQuestion(sq);
return {
... tmp,
title: `${
apiQuestion.title
} (${
sq.title
})`,
description: apiQuestionDetails.description || "",
url: `https://www.metaculus.com${
apiQuestion.page_url
}?sub-question=${
sq.id
}`
};
});
return result
}catch(error){
console.log(error)
return []
}
} }
return (apiQuestionDetails.sub_questions || [])
.filter((q) => !skip(q))
.map((sq) => {
const tmp = buildFetchedQuestion(sq);
return {
...tmp,
title: `${apiQuestion.title} (${sq.title})`,
description: apiQuestionDetails.description || "",
url: `https://www.metaculus.com${apiQuestion.page_url}?sub-question=${sq.id}`,
};
});
} else if (apiQuestion.type === "forecast") { } else if (apiQuestion.type === "forecast") {
if (apiQuestion.group) { if (apiQuestion.group) {
return []; // sub-question, should be handled on the group level return []; // sub-question, should be handled on the group level
} }
if (skip(apiQuestion)) { if (skip(apiQuestion)) {
console.log(`- [Skipping]: ${
apiQuestion.title
}`)
/*console.log(`Close time: ${
apiQuestion.close_time
}, resolve time: ${
apiQuestion.resolve_time
}`)*/
return []; return [];
} }
await sleep(SLEEP_TIME); await sleep(SLEEP_TIME);
try{ const apiQuestionDetails = await fetchSingleApiQuestion(apiQuestion.id);
const apiQuestionDetails = await fetchSingleApiQuestion(apiQuestion.id); const tmp = buildFetchedQuestion(apiQuestion);
const tmp = buildFetchedQuestion(apiQuestion); return [
return [{ {
... tmp, ...tmp,
title: apiQuestion.title, title: apiQuestion.title,
description: apiQuestionDetails.description || "", description: apiQuestionDetails.description || "",
url: "https://www.metaculus.com" + apiQuestion.page_url url: "https://www.metaculus.com" + apiQuestion.page_url,
},]; },
}catch(error){ ];
console.log(error)
return []
}
} else { } else {
if (apiQuestion.type !== "claim") { // should never happen, since `discriminator` in JTD schema causes a strict runtime check if (apiQuestion.type !== "claim") {
console.log(`Unknown metaculus question type: ${ // should never happen, since `discriminator` in JTD schema causes a strict runtime check
(apiQuestion as any).type console.log(
}, skipping`); `Unknown metaculus question type: ${
(apiQuestion as any).type
}, skipping`
);
} }
return []; return [];
} }
@ -154,25 +125,19 @@ export const metaculus: Platform<"id" | "debug"> = {
label: "Metaculus", label: "Metaculus",
color: "#006669", color: "#006669",
version: "v2", version: "v2",
fetcherArgs: [ fetcherArgs: ["id", "debug"],
"id", "debug"
],
async fetcher(opts) { async fetcher(opts) {
let allQuestions: FetchedQuestion[] = []; let allQuestions: FetchedQuestion[] = [];
if (opts.args ?. id) { if (opts.args?.id) {
try{ const id = Number(opts.args.id);
console.log("Using optional id arg.") const apiQuestion = await fetchSingleApiQuestion(id);
const id = Number(opts.args.id); const questions = await apiQuestionToFetchedQuestions(apiQuestion);
const apiQuestion = await fetchSingleApiQuestion(id); console.log(questions);
const questions = await apiQuestionToFetchedQuestions(apiQuestion); return {
console.log(questions); questions,
return {questions, partial: true}; partial: true,
};
}catch(error){
console.log(error)
return {questions: [], partial: true};
}
} }
let next: string | null = "https://www.metaculus.com/api2/questions/"; let next: string | null = "https://www.metaculus.com/api2/questions/";
@ -183,17 +148,14 @@ export const metaculus: Platform<"id" | "debug"> = {
await sleep(SLEEP_TIME); await sleep(SLEEP_TIME);
const apiQuestions: ApiMultipleQuestions = await fetchApiQuestions(next); const apiQuestions: ApiMultipleQuestions = await fetchApiQuestions(next);
const results = apiQuestions.results; const results = apiQuestions.results;
// console.log(results)
let j = false; let j = false;
for (const result of results) { for (const result of results) {
const questions = await apiQuestionToFetchedQuestions(result); const questions = await apiQuestionToFetchedQuestions(result);
// console.log(questions)
for (const question of questions) { for (const question of questions) {
console.log(`- ${ console.log(`- ${question.title}`);
question.title if ((!j && i % 20 === 0) || opts.args?.debug) {
}`);
if ((! j && i % 20 === 0) || opts.args ?. debug) {
console.log(question); console.log(question);
j = true; j = true;
} }
@ -205,16 +167,20 @@ export const metaculus: Platform<"id" | "debug"> = {
i += 1; i += 1;
} }
return {questions: allQuestions, partial: false}; return {
questions: allQuestions,
partial: false,
};
}, },
calculateStars(data) { calculateStars(data) {
const {numforecasts} = data.qualityindicators; const { numforecasts } = data.qualityindicators;
const nuno = () => (numforecasts || 0) > 300 ? 4 : (numforecasts || 0) > 100 ? 3 : 2; const nuno = () =>
(numforecasts || 0) > 300 ? 4 : (numforecasts || 0) > 100 ? 3 : 2;
const eli = () => 3; const eli = () => 3;
const misha = () => 3; const misha = () => 3;
const starsDecimal = average([nuno(), eli(), misha()]); const starsDecimal = average([nuno(), eli(), misha()]);
const starsInteger = Math.round(starsDecimal); const starsInteger = Math.round(starsDecimal);
return starsInteger; return starsInteger;
} },
}; };

View File

@ -17,14 +17,12 @@ Router.events.on("routeChangeStart", (as, { shallow }) => {
Router.events.on("routeChangeComplete", () => NProgress.done()); Router.events.on("routeChangeComplete", () => NProgress.done());
Router.events.on("routeChangeError", () => NProgress.done()); Router.events.on("routeChangeError", () => NProgress.done());
function MyApp({ Component, pageProps }: AppProps) { function MyApp({ Component, pageProps }: AppProps) {
return ( return (
<PlausibleProvider domain="metaforecast.org"> <PlausibleProvider domain="metaforecast.org">
<Component {...pageProps} /> <Component {...pageProps} />
</PlausibleProvider> </PlausibleProvider>
); );
// Workaround in package.json for: https://github.com/vercel/next.js/issues/36019#issuecomment-1103266481
} }
export default withUrqlClient((ssr) => getUrqlClientOptions(ssr), { export default withUrqlClient((ssr) => getUrqlClientOptions(ssr), {

View File

@ -11,7 +11,7 @@ export const Spinner: React.FC = () => (
cy="12" cy="12"
r="10" r="10"
stroke="currentColor" stroke="currentColor"
strokeWidth="4" stroke-width="4"
></circle> ></circle>
<path <path
className="opacity-75" className="opacity-75"

View File

@ -74,7 +74,7 @@ const getCurrencySymbolIfNeeded = ({
"openInterest", "openInterest",
"liquidity", "liquidity",
]; ];
let dollarPlatforms = ["predictit", "kalshi", "polymarket", "insight"]; let dollarPlatforms = ["predictit", "kalshi", "polymarket"];
if (indicatorsWhichNeedCurrencySymbol.includes(indicator)) { if (indicatorsWhichNeedCurrencySymbol.includes(indicator)) {
if (dollarPlatforms.includes(platform)) { if (dollarPlatforms.includes(platform)) {
return "$"; return "$";
@ -172,7 +172,6 @@ export const QuestionFooter: React.FC<Props> = ({
> >
{question.platform.label {question.platform.label
.replace("Good Judgment Open", "GJOpen") .replace("Good Judgment Open", "GJOpen")
.replace("Insight Prediction", "Insight")
.replace(/ /g, "\u00a0")} .replace(/ /g, "\u00a0")}
</div> </div>
<div <div

View File

@ -97,7 +97,7 @@ export default async function searchWithAlgolia({
url: "https://metaforecast.org", url: "https://metaforecast.org",
platform: "metaforecast", platform: "metaforecast",
platformLabel: "metaforecast", platformLabel: "metaforecast",
description: "Maybe try a broader query, e.g., reduce the number of 'stars' by clicking in 'Advanced options'?", description: "Maybe try a broader query?",
options: [ options: [
{ {
name: "Yes", name: "Yes",
@ -166,7 +166,7 @@ export default async function searchWithAlgolia({
url: "https://metaforecast.org", url: "https://metaforecast.org",
platform: "metaforecast", platform: "metaforecast",
platformLabel: "metaforecast", platformLabel: "metaforecast",
description: "Maybe try a broader query? Maybe try a broader query, e.g., reduce the number of 'stars' by clicking in 'Advanced options'? That said, we could be wrong.", description: "Maybe try a broader query? That said, we could be wrong.",
options: [ options: [
{ {
name: "Yes", name: "Yes",

8774
yarn.lock

File diff suppressed because it is too large Load Diff