Green Smiley.txtpb « rooms « daedalus « maps « data - lingo2-archipelago - Randomizer for LINGO 2 using Archipelago Multiworld

about summary refs log tree commit diff stats

path: root/data/maps/daedalus/rooms/Green Smiley.txtpb

blob: 18f067f88cabcb526c954f570b4fd4601ac09f74 (plain) (blame)

name: "Green Smiley"
panel_display_name: "Southwest Area"
panels {
  name: "SMILE"
  path: "Panels/Smiley Rooms/green"
  clue: "smile"
  answer: "green"
  symbols: QUESTION
}
paintings {
  name: "RELIC"
  path: "Components/Paintings/Group1/relic"
}

olor: #dd7700 } /* Name.Variable.Global */ .highlight .vi { color: #3333bb } /* Name.Variable.Instance */ .highlight .vm { color: #336699 } /* Name.Variable.Magic */ .highlight .il { color: #0000DD; font-weight: bold } /* Literal.Number.Integer.Long */

#include "database.h"

#include <include/uuid.h>

#include <stdexcept>

std::string database::create(std::mt19937& rng) {
  std::lock_guard state_guard(mutex_);

  std::string token = uuids::to_string(uuids::uuid_random_generator{rng}());
  requests_[token] = request{};

  return token;
}

void database::subscribe(const std::string& token,
                         subscribe_callback_type callback) {
  std::lock_guard state_guard(mutex_);

  if (!requests_.count(token)) {
    throw std::invalid_argument("Could not find request.");
  }

  request& req = requests_[token];
  size_t nextId = req.subscribers.size();
  req.subscribers.push_back(callback);
}

void database::post(const std::string& token, const std::string& msg) {
  std::lock_guard state_guard(mutex_);

  if (!requests_.count(token)) {
    throw std::invalid_argument("Could not find request.");
  }

  request& req = requests_.at(token);

  for (std::optional<subscribe_callback_type>& callback : req.subscribers) {
    if (callback) {
      try {
        (*callback)(msg);
      } catch (const std::exception& ex) {
        callback = std::nullopt;
      }
    }
  }
}

void database::setResult(const std::string& token, const std::string& result) {
  std::lock_guard state_guard(mutex_);

  if (!requests_.count(token)) {
    throw std::invalid_argument("Could not find request.");
  }

  request& req = requests_[token];
  req.result = result;
}

const std::string& database::getResult(const std::string& token) {
  std::lock_guard state_guard(mutex_);

  if (!requests_.count(token)) {
    throw std::invalid_argument("Could not find request.");
  }

  const request& req = requests_.at(token);
  return req.result;
}

void database::mark_done(const std::string& token) {
  std::lock_guard state_guard(mutex_);

  if (!requests_.count(token)) {
    throw std::invalid_argument("Could not find request.");
  }

  request& req = requests_[token];
  req.done = true;
}

bool database::is_done(const std::string& token) {
  std::lock_guard state_guard(mutex_);

  if (!requests_.count(token)) {
    throw std::invalid_argument("Could not find request.");
  }

  const request& req = requests_.at(token);
  return req.done;
}