fluxengine/lib/fluxsink/aufluxsink.cc

#include "lib/core/globals.h"
#include "lib/config/flags.h"
#include "lib/data/fluxmap.h"
#include "lib/core/bytes.h"
#include "protocol.h"
#include "lib/fluxsink/fluxsink.h"
#include "lib/data/fluxmapreader.h"
#include "lib/fluxsink/fluxsink.pb.h"
#include "lib/config/proto.h"
#include <fstream>
#include <sys/stat.h>
#include <sys/types.h>

class AuFluxSink : public FluxSink
{
public:
    AuFluxSink(const AuFluxSinkProto& config): _config(config) {}

    ~AuFluxSink()
    {
        std::cerr << "Warning: do not play these files, or you will break your "
                     "speakers and/or ears!\n";
    }

public:
    void writeFlux(int track, int head, const Fluxmap& fluxmap) override
    {
        unsigned totalTicks = fluxmap.ticks() + 2;
        unsigned channels = _config.index_markers() ? 2 : 1;

        mkdir(_config.directory().c_str(), 0744);
        std::ofstream of(
            fmt::format(
                "{}/c{:02d}.h{:01d}.au", _config.directory(), track, head),
            std::ios::out | std::ios::binary);
        if (!of.is_open())
            error("cannot open output file");

        /* Write header */

        {
            Bytes header;
            header.resize(24);
            ByteWriter bw(header);

            bw.write_be32(0x2e736e64);
            bw.write_be32(24);
            bw.write_be32(totalTicks * channels);
            bw.write_be32(2); /* 8-bit PCM */
            bw.write_be32(TICK_FREQUENCY);
            bw.write_be32(channels); /* channels */

            of.write((const char*)header.cbegin(), header.size());
        }

        /* Write data */

        {
            Bytes data;
            data.resize(totalTicks * channels);
            memset(data.begin(), 0x80, data.size());

            FluxmapReader fmr(fluxmap);
            unsigned timestamp = 0;
            while (!fmr.eof())
            {
                unsigned ticks;
                int event;
                fmr.getNextEvent(event, ticks);
                if (fmr.eof())
                    break;
                timestamp += ticks;

                if (event & F_BIT_PULSE)
                    data[timestamp * channels + 0] = 0x7f;
                if (_config.index_markers() && (event & F_BIT_INDEX))
                    data[timestamp * channels + 1] = 0x7f;
            }

            of.write((const char*)data.cbegin(), data.size());
        }
    }

    operator std::string() const override
    {
        return fmt::format("au({})", _config.directory());
    }

private:
    const AuFluxSinkProto& _config;
};

std::unique_ptr<FluxSink> FluxSink::createAuFluxSink(
    const AuFluxSinkProto& config)
{
    return std::unique_ptr<FluxSink>(new AuFluxSink(config));
}