Creativity.hpp

#pragma once
#include <eris/Good.hpp>
#include <eris/noncopyable.hpp>
#include "creativity/CreativitySettings.hpp"
#include "creativity/state/Storage.hpp"
#include <cstdint>
#include <mutex>
#include <string>
#include <utility>
#include <vector>

namespace creativity { class Book; }

namespace creativity {

class Creativity : private eris::noncopyable {
    public:
        Creativity() = default;

        std::shared_ptr<eris::Simulation> sim;

        eris::SharedMember<eris::Good> money;

        const CreativitySettings &parameters{set_};

        CreativitySettings& set();

        template <class T, typename... Args>
        void write(Args&&... args) {
            auto new_storage = state::Storage::create<T>(set_, std::forward<Args>(args)...);
            auto spair = storage();
            auto &old_storage = spair.first;
            if (old_storage) {
                for (const auto &state : *old_storage) {
                    new_storage->push_back(state);
                    // Don't let the old storage get ahead of the new storage (we don't want to
                    // pointlessly slam a bunch of things into memory).
                    new_storage->flush(false);
                }
            }

            spair.first = new_storage;
        }

        template <class T, typename... Args>
        void read(Args&&... args) {
            if (setup_sim_) throw std::logic_error("Creativity: attempt to read() after calling setup()");
            storage().first = state::Storage::create<T>(set_, std::forward<Args>(args)...);
            setup_read_ = true;
        }

        void checkParameters();

        void setup();

        void run();

        static double boundaryFromDensity(uint32_t readers, uint32_t dimensions, double density);

        static double densityFromBoundary(uint32_t readers, uint32_t dimensions, double boundary);

        double densityFromBoundary() const;

        bool piracy() const;

        bool policyActive() const;

        bool publicSharingActive() const;

        bool publicVotingActive() const;

        bool catchPiratesActive() const;

        double policyTaxes() const;

        static double policyTaxes(const CreativitySettings &s);

        double disposableIncome() const;

        double priorWeight() const;

        double meanInitialQuality() const;

        std::pair<std::vector<eris::SharedMember<Book>>&, std::unique_lock<std::mutex>> newBooks();

        std::pair<std::shared_ptr<state::Storage>&, std::unique_lock<std::mutex>> storage();

        template <typename Iter, typename = typename std::enable_if<std::is_arithmetic<
            typename std::iterator_traits<Iter>::value_type>::value>::type>
        static double evalPolynomial(double x, Iter it, Iter end) {
            double v = 0;
            double xi = 1;
            for (; it != end; ++it) {
                v += *it * xi;
                xi *= x;
                if (xi == 0) break;
            }
            return v;
        }

        template <typename Container, typename = typename std::enable_if<std::is_arithmetic<
            typename Container::value_type>::value>::type>
        static double evalPolynomial(double x, const Container &cont) {
            return evalPolynomial(x, cont.begin(), cont.end());
        }

        unsigned long market_books{0};

        double market_books_avg{0.0};

    protected:
        void createPiracyNetwork();

    private:
        // True if this is a live simulation.  Exclusive of setup_read_.
        bool setup_sim_{false};

        // True if this has loaded a previously simulation data file.  Exclusive of setup_sim_.
        bool setup_read_{false};

        // The actual, non-const settings (the public `.parameters` is a const reference to this)
        CreativitySettings set_;

        std::vector<eris::SharedMember<Book>> new_books_;

        std::list<unsigned int> mkt_books_;

        std::shared_ptr<state::Storage> storage_;

        // Mutex controlling .storage_ and new_books_ access
        std::mutex storage_mutex_, new_books_mutex_;
};

}