metaforecast/src/backend/platforms/smarkets.ts

import axios from "axios";

import { calculateStars } from "../utils/stars";
import { Platform } from "./";

/* Definitions */
const platformName = "smarkets";
let htmlEndPointEntrance = "https://api.smarkets.com/v3/events/";
let VERBOSE = false;
let empty = () => 0;

/* Support functions */

async function fetchEvents(url) {
  let response = await axios({
    url: htmlEndPointEntrance + url,
    method: "GET",
    headers: {
      "Content-Type": "text/html",
    },
  }).then((res) => res.data);
  VERBOSE ? console.log(response) : empty();
  return response;
}

async function fetchMarkets(eventid) {
  let response = await axios({
    url: `https://api.smarkets.com/v3/events/${eventid}/markets/`,
    method: "GET",
    headers: {
      "Content-Type": "text/json",
    },
  })
    .then((res) => res.data)
    .then((res) => res.markets);
  return response;
}

async function fetchContracts(marketid) {
  let response = await axios({
    url: `https://api.smarkets.com/v3/markets/${marketid}/contracts/`,
    method: "GET",
    headers: {
      "Content-Type": "text/html",
    },
  }).then((res) => res.data);
  VERBOSE ? console.log(response) : empty();
  return response;
}

async function fetchPrices(marketid) {
  let response = await axios({
    url: `https://api.smarkets.com/v3/markets/${marketid}/last_executed_prices/`,
    method: "GET",
    headers: {
      "Content-Type": "text/html",
    },
  }).then((res) => res.data);
  VERBOSE ? console.log(response) : empty();
  return response;
}

export const smarkets: Platform = {
  name: platformName,
  label: "Smarkets",
  color: "#6f5b41",
  async fetcher() {
    let htmlPath =
      "?state=new&state=upcoming&state=live&type_domain=politics&type_scope=single_event&with_new_type=true&sort=id&limit=50";

    let events = [];
    while (htmlPath) {
      let data = await fetchEvents(htmlPath);
      events.push(...data.events);
      htmlPath = data.pagination.next_page;
    }
    VERBOSE ? console.log(events) : empty();
    let markets = [];
    for (let event of events) {
      VERBOSE ? console.log(Date.now()) : empty();
      VERBOSE ? console.log(event.name) : empty();
      let eventMarkets = await fetchMarkets(event.id);
      eventMarkets = eventMarkets.map((market) => ({
        ...market,
        slug: event.full_slug,
      }));
      VERBOSE ? console.log("Markets fetched") : empty();
      VERBOSE ? console.log(event.id) : empty();
      VERBOSE ? console.log(eventMarkets) : empty();
      markets.push(...eventMarkets);
      //let lastPrices = await fetchPrices(market.id)
    }
    VERBOSE ? console.log(markets) : empty();

    let results = [];
    for (let market of markets) {
      VERBOSE ? console.log("================") : empty();
      VERBOSE ? console.log("Market: ", market) : empty();
      let id = `${platformName}-${market.id}`;
      let name = market.name;

      let contracts = await fetchContracts(market.id);
      VERBOSE ? console.log("Contracts: ", contracts) : empty();
      let prices = await fetchPrices(market.id);
      VERBOSE
        ? console.log("Prices: ", prices["last_executed_prices"][market.id])
        : empty();

      let optionsObj = {};
      for (let contract of contracts["contracts"]) {
        optionsObj[contract.id] = { name: contract.name };
      }
      for (let price of prices["last_executed_prices"][market.id]) {
        optionsObj[price.contract_id] = {
          ...optionsObj[price.contract_id],
          probability: price.last_executed_price
            ? Number(price.last_executed_price)
            : null,
          type: "PROBABILITY",
        };
      }
      let options: any[] = Object.values(optionsObj);
      // monkey patch the case where there are only two options and only one has traded.
      if (
        options.length == 2 &&
        options.map((option) => option.probability).includes(null)
      ) {
        let nonNullPrice =
          options[0].probability == null
            ? options[1].probability
            : options[0].probability;
        options = options.map((option) => {
          let probability = option.probability;
          return {
            ...option,
            probability: probability == null ? 100 - nonNullPrice : probability,
            // yes, 100, because prices are not yet normalized.
          };
        });
      }

      // Normalize normally
      let totalValue = options
        .map((element) => Number(element.probability))
        .reduce((a, b) => a + b, 0);

      options = options.map((element) => ({
        ...element,
        probability: Number(element.probability) / totalValue,
      }));
      VERBOSE ? console.log(options) : empty();

      /*
    if(contracts["contracts"].length == 2){
      isBinary = true
      percentage = ( Number(prices["last_executed_prices"][market.id][0].last_executed_price) + (100 - Number(prices["last_executed_prices"][market.id][1].last_executed_price)) ) / 2
      percentage = Math.round(percentage)+"%"
      let contractName = contracts["contracts"][0].name
      name = name+ (contractName=="Yes"?'':` (${contracts["contracts"][0].name})`)
    }
    */
      let result = {
        id: id,
        title: name,
        url: "https://smarkets.com/event/" + market.event_id + market.slug,
        platform: platformName,
        description: market.description,
        options: options,
        timestamp: new Date().toISOString(),
        qualityindicators: {
          stars: calculateStars(platformName, {}),
        },
      };
      VERBOSE ? console.log(result) : empty();
      results.push(result);
    }
    VERBOSE ? console.log(results) : empty();
    return results;
  },
};