text:
<?php

namespace Webmozart\Json\Tests;

use Symfony\Component\Filesystem\Filesystem;
use Webmozart\Json\JsonEncoder;

/**
 * @since  1.0
 *
 * @author Bernhard Schussek <bschussek@gmail.com>
 */
class JsonEncoderTest extends \PHPUnit_Framework_TestCase
{
    const BINARY_INPUT = "\xff\xf0";

    /**
     * @var JsonEncoder
     */
    private $encoder;

    private $fixturesDir;

    private $schemaFile;

    private $schemaObject;

    private $tempDir;

    private $tempFile;

    public function provideValues()
    {
        return array(
            array(0, '0'),
            array(1, '1'),
            array(1234, '1234'),
            array('a', '"a"'),
            array('b', '"b"'),
            array('a/b', '"a\/b"'),
            array(12.34, '12.34'),
            array(true, 'true'),
            array(false, 'false'),
            array(null, 'null'),
            array(array(1, 2, 3, 4), '[1,2,3,4]'),
            array(array('foo' => 'bar', 'baz' => 'bam'), '{"foo":"bar","baz":"bam"}'),
            array((object) array('foo' => 'bar', 'baz' => 'bam'), '{"foo":"bar","baz":"bam"}'),
        );
    }

    protected function setUp()
    {
        while (false === @mkdir($this->tempDir = sys_get_temp_dir().'/webmozart-JsonEncoderTest'.rand(10000, 99999), 0777, true)) {
        }

        $this->encoder = new JsonEncoder();
        $this->fixturesDir = __DIR__.'/Fixtures';
        $this->schemaFile = $this->fixturesDir.'/schema.json';
        $this->schemaObject = json_decode(file_get_contents($this->schemaFile));
        $this->tempFile = $this->tempDir.'/data.json';
    }

    protected function tearDown()
    {
        $filesystem = new Filesystem();

        // Ensure all files in the directory are writable before removing
        $filesystem->chmod($this->tempDir, 0755, 0000, true);
        $filesystem->remove($this->tempDir);
    }

    /**
     * @dataProvider provideValues
     */
    public function testEncode($value, $json)
    {
        $this->assertSame($json, $this->encoder->encode($value));
    }

    public function testEncodeWithSchemaFile()
    {
        $data = (object) array('name' => 'Bernhard');

        $this->assertSame('{"name":"Bernhard"}', $this->encoder->encode($data, $this->schemaFile));
    }

    public function testEncodeWithSchemaObject()
    {
        $data = (object) array('name' => 'Bernhard');

        $this->assertSame('{"name":"Bernhard"}', $this->encoder->encode($data, $this->schemaObject));
    }

    /**
     * @expectedException \Webmozart\Json\ValidationFailedException
     */
    public function testEncodeFailsIfValidationFailsWithSchemaFile()
    {
        $this->encoder->encode('foobar', $this->schemaFile);
    }

    /**
     * @expectedException \Webmozart\Json\ValidationFailedException
     */
    public function testEncodeFailsIfValidationFailsWithSchemaObject()
    {
        $this->encoder->encode('foobar', $this->schemaObject);
    }

    public function testEncodeUtf8()
    {
        $data = (object) array('name' => 'Bérnhard');

        $this->assertSame('{"name":"B\u00e9rnhard"}', $this->encoder->encode($data));
    }

    /**
     * JSON_ERROR_UTF8.
     *
     * @expectedException \Webmozart\Json\EncodingFailedException
     * @expectedExceptionCode 5
     */
    public function testEncodeFailsIfNonUtf8()
    {
        if (version_compare(PHP_VERSION, '5.5.0', '<')) {
            $this->markTestSkipped('PHP >= 5.5.0 only');

            return;
        }

        $this->encoder->encode(file_get_contents($this->fixturesDir.'/win-1258.json'));
    }

    /**
     * JSON_ERROR_UTF8.
     *
     * @expectedException \Webmozart\Json\EncodingFailedException
     * @expectedExceptionCode 5
     */
    public function testEncodeFailsForBinaryValue()
    {
        $this->encoder->encode(self::BINARY_INPUT);
    }

    public function testEncodeEmptyArrayKey()
    {
        $data = array('' => 'Bernhard');

        $this->assertSame('{"":"Bernhard"}', $this->encoder->encode($data));
    }

    public function testEncodeEmptyProperty()
    {
        if (version_compare(PHP_VERSION, '7.1.0', '<')) {
            $this->markTestSkipped('PHP >= 7.1.0 only');

            return;
        }

        $data = (object) array('' => 'Bernhard');

        $this->assertSame('{"":"Bernhard"}', $this->encoder->encode($data));
    }

    public function testEncodeMagicEmptyPropertyAfter71()
    {
        if (version_compare(PHP_VERSION, '7.1.0', '<')) {
            $this->markTestSkipped('PHP >= 7.1.0 only');

            return;
        }

        $data = (object) array('_empty_' => 'Bernhard');

        $this->assertSame('{"_empty_":"Bernhard"}', $this->encoder->encode($data));
    }

    public function testEncodeMagicEmptyPropertyBefore71()
    {
        if (version_compare(PHP_VERSION, '7.1.0', '>=')) {
            $this->markTestSkipped('PHP < 7.1.0 only');

            return;
        }

        $data = (object) array('a' => 'b', '_empty_' => 'Bernhard', 'c' => 'd');

        $this->assertSame('{"a":"b","":"Bernhard","c":"d"}', $this->encoder->encode($data));
    }

    public function testEncodeArrayAsArray()
    {
        $data = array('one', 'two');

        $this->encoder->setArrayEncoding(JsonEncoder::JSON_ARRAY);

        $this->assertSame('["one","two"]', $this->encoder->encode($data));
    }

    public function testEncodeArrayAsObject()
    {
        $data = array('one', 'two');

        $this->encoder->setArrayEncoding(JsonEncoder::JSON_OBJECT);

        $this->assertSame('{"0":"one","1":"two"}', $this->encoder->encode($data));
    }

    public function provideInvalidArrayEncoding()
    {
        return array(
            array(JsonEncoder::JSON_NUMBER),
            array(JsonEncoder::JSON_STRING),
            array(1234),
        );
    }

    /**
     * @dataProvider provideInvalidArrayEncoding
     * @expectedException \InvalidArgumentException
     */
    public function testFailIfInvalidArrayEncoding($invalidEncoding)
    {
        $this->encoder->setArrayEncoding($invalidEncoding);
    }

    public function testEncodeNumericAsString()
    {
        $data = '12345';

        $this->encoder->setNumericEncoding(JsonEncoder::JSON_STRING);

        $this->assertSame('"12345"', $this->encoder->encode($data));
    }

    public function testEncodeIntegerStringAsInteger()
    {
        $data = '12345';

        $this->encoder->setNumericEncoding(JsonEncoder::JSON_NUMBER);

        $this->assertSame('12345', $this->encoder->encode($data));
    }

    public function testEncodeIntegerFloatAsFloat()
    {
        $data = '123.45';

        $this->encoder->setNumericEncoding(JsonEncoder::JSON_NUMBER);

        $this->assertSame('123.45', $this->encoder->encode($data));
    }

    public function provideInvalidNumericEncoding()
    {
        return array(
            array(JsonEncoder::JSON_ARRAY),
            array(JsonEncoder::JSON_OBJECT),
            array(1234),
        );
    }

    /**
     * @dataProvider provideInvalidNumericEncoding
     * @expectedException \InvalidArgumentException
     */
    public function testFailIfInvalidNumericEncoding($invalidEncoding)
    {
        $this->encoder->setNumericEncoding($invalidEncoding);
    }

    public function testGtLtEscaoed()
    {
        $this->encoder->setEscapeGtLt(true);

        $this->assertSame('"\u003C\u003E"', $this->encoder->encode('<>'));
    }

    public function testGtLtNotEscaoed()
    {
        $this->encoder->setEscapeGtLt(false);

        $this->assertSame('"<>"', $this->encoder->encode('<>'));
    }

    public function testAmpersandEscaped()
    {
        $this->encoder->setEscapeAmpersand(true);

        $this->assertSame('"\u0026"', $this->encoder->encode('&'));
    }

    public function testAmpersandNotEscaped()
    {
        $this->encoder->setEscapeAmpersand(false);

        $this->assertSame('"&"', $this->encoder->encode('&'));
    }

    public function testSingleQuoteEscaped()
    {
        $this->encoder->setEscapeSingleQuote(true);

        $this->assertSame('"\u0027"', $this->encoder->encode("'"));
    }

    public function testSingleQuoteNotEscaped()
    {
        $this->encoder->setEscapeSingleQuote(false);

        $this->assertSame('"\'"', $this->encoder->encode("'"));
    }

    public function testDoubleQuoteEscaped()
    {
        $this->encoder->setEscapeDoubleQuote(true);

        $this->assertSame('"\u0022"', $this->encoder->encode('"'));
    }

    public function testDoubleQuoteNotEscaped()
    {
        $this->encoder->setEscapeDoubleQuote(false);

        $this->assertSame('"\""', $this->encoder->encode('"'));
    }

    public function testSlashEscaped()
    {
        $this->encoder->setEscapeSlash(true);

        $this->assertSame('"\\/"', $this->encoder->encode('/'));
    }

    public function testSlashNotEscaped()
    {
        $this->encoder->setEscapeSlash(false);

        $this->assertSame('"/"', $this->encoder->encode('/'));
    }

    public function testUnicodeEscaped()
    {
        $this->encoder->setEscapeUnicode(true);

        $this->assertSame('"\u00fc"', $this->encoder->encode('ü'));
    }

    public function testUnicodeNotEscaped()
    {
        if (version_compare(PHP_VERSION, '5.4.0', '<')) {
            $this->markTestSkipped('PHP >= 5.4.0 only');

            return;
        }

        $this->encoder->setEscapeUnicode(false);

        $this->assertSame('"ü"', $this->encoder->encode('ü'));
    }

    /**
     * JSON_ERROR_DEPTH.
     *
     * @expectedException \Webmozart\Json\EncodingFailedException
     * @expectedExceptionCode 1
     */
    public function testMaxDepth1Exceeded()
    {
        if (version_compare(PHP_VERSION, '5.5.0', '<')) {
            $this->markTestSkipped('PHP >= 5.5.0 only');

            return;
        }

        $this->encoder->setMaxDepth(1);

        $this->encoder->encode((object) array('name' => 'Bernhard'));
    }

    public function testMaxDepth1NotExceeded()
    {
        $this->encoder->setMaxDepth(1);

        $this->assertSame('"Bernhard"', $this->encoder->encode('Bernhard'));
    }

    /**
     * JSON_ERROR_DEPTH.
     *
     * @expectedException \Webmozart\Json\EncodingFailedException
     * @expectedExceptionCode 1
     */
    public function testMaxDepth2Exceeded()
    {
        if (version_compare(PHP_VERSION, '5.5.0', '<')) {
            $this->markTestSkipped('PHP >= 5.5.0 only');

            return;
        }

        $this->encoder->setMaxDepth(2);

        $this->encoder->encode((object) array('key' => (object) array('name' => 'Bernhard')));
    }

    public function testMaxDepth2NotExceeded()
    {
        $this->encoder->setMaxDepth(2);

        $this->assertSame('{"name":"Bernhard"}', $this->encoder->encode((object) array('name' => 'Bernhard')));
    }

    /**
     * @expectedException \InvalidArgumentException
     */
    public function testMaxDepthMustBeInteger()
    {
        $this->encoder->setMaxDepth('foo');
    }

    /**
     * @expectedException \InvalidArgumentException
     */
    public function testMaxDepthMustBeOneOrGreater()
    {
        $this->encoder->setMaxDepth(0);
    }

    public function testPrettyPrinting()
    {
        if (version_compare(PHP_VERSION, '5.4.0', '<')) {
            $this->markTestSkipped('PHP >= 5.4.0 only');

            return;
        }

        $this->encoder->setPrettyPrinting(true);

        $this->assertSame("{\n    \"name\": \"Bernhard\"\n}", $this->encoder->encode((object) array('name' => 'Bernhard')));
    }

    public function testNoPrettyPrinting()
    {
        $this->encoder->setPrettyPrinting(false);

        $this->assertSame('{"name":"Bernhard"}', $this->encoder->encode((object) array('name' => 'Bernhard')));
    }

    public function testTerminateWithLineFeed()
    {
        $this->encoder->setTerminateWithLineFeed(true);

        $this->assertSame('{"name":"Bernhard"}'."\n", $this->encoder->encode((object) array('name' => 'Bernhard')));
    }

    public function testDoNotTerminateWithLineFeed()
    {
        $this->encoder->setTerminateWithLineFeed(false);

        $this->assertSame('{"name":"Bernhard"}', $this->encoder->encode((object) array('name' => 'Bernhard')));
    }

    public function testEncodeFile()
    {
        $data = (object) array('name' => 'Bernhard');

        $this->encoder->encodeFile($data, $this->tempFile);

        $this->assertFileExists($this->tempFile);
        $this->assertSame('{"name":"Bernhard"}', file_get_contents($this->tempFile));
    }

    public function testEncodeFileCreatesMissingDirectories()
    {
        $data = (object) array('name' => 'Bernhard');

        $this->encoder->encodeFile($data, $this->tempDir.'/sub/data.json');

        $this->assertFileExists($this->tempDir.'/sub/data.json');
        $this->assertSame('{"name":"Bernhard"}', file_get_contents($this->tempDir.'/sub/data.json'));
    }

    public function testEncodeFileFailsIfNotWritable()
    {
        $data = (object) array('name' => 'Bernhard');

        touch($this->tempFile);
        chmod($this->tempFile, 0400);

        // Test that the file name is present in the output.
        $this->setExpectedException(
            '\Webmozart\Json\IOException',
            $this->tempFile
        );

        $this->encoder->encodeFile($data, $this->tempFile);
    }

    public function testEncodeFileFailsIfValidationFailsWithSchemaFile()
    {
        // Test that the file name is present in the output.
        $this->setExpectedException(
            '\Webmozart\Json\ValidationFailedException',
            $this->tempFile
        );

        $this->encoder->encodeFile('foobar', $this->tempFile, $this->schemaFile);
    }

    public function testEncodeFileFailsIfValidationFailsWithSchemaObject()
    {
        // Test that the file name is present in the output.
        $this->setExpectedException(
            '\Webmozart\Json\ValidationFailedException',
            $this->tempFile
        );

        $this->encoder->encodeFile('foobar', $this->tempFile, $this->schemaObject);
    }

    public function testEncodeFileFailsIfNonUtf8()
    {
        if (version_compare(PHP_VERSION, '5.5.0', '<')) {
            $this->markTestSkipped('PHP >= 5.5.0 only');

            return;
        }

        // Test that the file name is present in the output.
        $this->setExpectedException(
            '\Webmozart\Json\EncodingFailedException',
            $this->tempFile,
            5
        );

        $this->encoder->encodeFile(file_get_contents($this->fixturesDir.'/win-1258.json'),
            $this->tempFile);
    }
}


text:
#ifndef MBED_ADVERTISING_PARAMETERS_H__
#define MBED_ADVERTISING_PARAMETERS_H__

#include <algorithm>

#include "ble/common/BLETypes.h"
#include "ble/common/blecommon.h"
#include "ble/common/SafeEnum.h"

namespace ble {

/**
 * @addtogroup ble
 * @{
 * @addtogroup gap
 * @{
 */

/**
 * Parameters defining the advertising process.
 *
 * @par Legacy advertising:
 *
 * Advertising parameters for legacy advertising are a mainly defined by a pair
 * of values:
 *   - The Advertising mode modeled after advertising_type_t. It defines
 *     whether the device is connectable and scannable. You can set this value at
 *     construction time, update it with setType() and query it with getType().
 *   - Time interval between advertisement. You can set it at construction time,
 *     update it with setPrimaryInterval() and obtain it from getMinPrimaryInterval()
 *     and getMaxPrimaryInterval().
 *
 * In addition, it is possible to adjust other parameters:
 *   - You can select the advertising channels with setPrimaryChannels() and
 *   queried them with getChannel37(), getChannel38() and getChannel39().
 *   - You can set the address type used by the local device with setOwnAddressType()
 *   and query it by getOwnAddressType().
 *   - You can set the filter policy for scan and connection requests with
 *   setFilter() and query it with getFilter().
 *
 * For directed advertising, you can set the address of the target with the help
 * of setPeer() and query it with getPeerAddress() and getPeerAddressType().
 *
 * @par Extended advertising:
 *
 * To use extended advertising features, first disable legacy advertising
 * with setUseLegacyPDU().
 *
 * Extended advertising adds new features to BLE advertising:
 *   - Control the advertising power with setTxPower().
 *   - Include the Tx power in advertising packet with includeTxPowerInHeader().
 *   - Set a secondary phy_t channel with setPhy().
 *   - Enable scan requests notification to let the application be aware of any
 *   incoming scan requests with setScanRequestNotification().
 *   - Advertise anonymously with setAnonymousAdvertising()
 *
 * @par Fluent interface:
 *
 * This API is designed for usability. You can construct
 * it and pass it in place. To achieve this, the fluent interface pattern
 * is used. Every setter returns a reference to the object modified and can be
 * chained.
 *
 * @code
    void setAdvertisingParameters(ble::PalGap& gap) {
        using namespace ble;
        gap.setAdvertisingParameters(
            LEGACY_ADVERTISING_HANDLE,
            AdvertisingParameters()
                .setType(advertising_type_t::ADV_CONNECTABLE_UNDIRECTED)
                .setPrimaryInterval(millisecond_t(200), millisecond_t(500))
                .setOwnAddressType(own_address_type_t::RANDOM)
                .setUseLegacyPDU(false)
                .setPhy(phy_t::LE_1M, phy_t::LE_CODED)
        );
    }
 * @endcode
 *
 * @see ble::Gap::createAdvertisingSet(), ble::Gap::setAdvertisingParameters()
 */
class AdvertisingParameters {

    /**
     * Default minimum advertising interval.
     */
    static const uint32_t DEFAULT_ADVERTISING_INTERVAL_MIN = 0x400;

    /**
     * Default maximum advertising interval.
     */
    static const uint32_t DEFAULT_ADVERTISING_INTERVAL_MAX = 0x800;

    /**
     * Minimum Advertising interval for scannable and nonconnectable
     * undirected events in 625us units.
     *
     * @note Equal to 100ms.
     */
    static const uint32_t GAP_ADV_PARAMS_INTERVAL_MIN_NONCON = 0x00A0;

public:
    /**
     * Construct an instance of GapAdvertisingParams.
     *
     * @param[in] advType Type of advertising.
     * @param[in] minInterval, maxInterval Time interval between two advertisement.
     * A range is provided to the LE subsystem, so it can adjust the advertising
     * interval with other transmission happening on the BLE radio.
     * @param[in] useLegacyPDU If true legacy PDU shall be used for advertising.
     *
     * @note If CONNECTABLE_UNDIRECTED or CONNECTABLE_DIRECTED advertising is used
     * you must use legacy PDU.
     *
     * @note If values in input are out of range, they will be normalized.
     *
     * @note If type selected is incompatible with non legacy PDU, legacy PDU will be used.
     */
    AdvertisingParameters(
        advertising_type_t advType = advertising_type_t::CONNECTABLE_UNDIRECTED,
        adv_interval_t minInterval = adv_interval_t(DEFAULT_ADVERTISING_INTERVAL_MIN),
        adv_interval_t maxInterval = adv_interval_t(DEFAULT_ADVERTISING_INTERVAL_MAX),
        bool useLegacyPDU = true
    ) :
        _advType(advType),
        _minInterval(minInterval),
        _maxInterval(maxInterval),
        _peerAddressType(target_peer_address_type_t::PUBLIC),
        _ownAddressType(own_address_type_t::RANDOM),
        _policy(advertising_filter_policy_t::NO_FILTER),
        _primaryPhy(phy_t::LE_1M),
        _secondaryPhy(phy_t::LE_1M),
        _peerAddress(),
        _txPower(127),
        _maxSkip(0),
        _channel37(true),
        _channel38(true),
        _channel39(true),
        _anonymous(false),
        _notifyOnScan(false),
        _legacyPDU(useLegacyPDU),
        _includeHeaderTxPower(false)
    {
        normalize();
    }

    /**
     * Construct an instance of GapAdvertisingParams.
     *
     * @param[in] advType Type of advertising.
     * @param[in] useLegacyPDU If true legacy PDU shall be used for advertising.
     *
     * @note If CONNECTABLE_UNDIRECTED or CONNECTABLE_DIRECTED advertising is used
     * you must use legacy PDU.
     *
     * @note If type selected is incompatible with non legacy PDU, legacy PDU will be used.
     */
    AdvertisingParameters(
        advertising_type_t advType,
        bool useLegacyPDU
    ) :
        _advType(advType),
        _minInterval(adv_interval_t(DEFAULT_ADVERTISING_INTERVAL_MIN)),
        _maxInterval(adv_interval_t(DEFAULT_ADVERTISING_INTERVAL_MAX)),
        _peerAddressType(target_peer_address_type_t::PUBLIC),
        _ownAddressType(own_address_type_t::RANDOM),
        _policy(advertising_filter_policy_t::NO_FILTER),
        _primaryPhy(phy_t::LE_1M),
        _secondaryPhy(phy_t::LE_1M),
        _peerAddress(),
        _txPower(127),
        _maxSkip(0),
        _channel37(true),
        _channel38(true),
        _channel39(true),
        _anonymous(false),
        _notifyOnScan(false),
        _legacyPDU(useLegacyPDU),
        _includeHeaderTxPower(false)
    {
        normalize();
    }

public:
    /**
     * Update the advertising type and whether to use legacy PDU.
     *
     * @note If legacy PDU is not used then you cannot use
     * CONNECTABLE_UNDIRECTED nor CONNECTABLE_DIRECTED.
     *
     * @param[in] newAdvType The new advertising type.
     *
     * @param[in] legacy If true, legacy PDU will be used.
     *
     * @return reference to this object.
     */
    AdvertisingParameters &setType(advertising_type_t newAdvType, bool legacy)
    {
        if (newAdvType == advertising_type_t::CONNECTABLE_UNDIRECTED ||
            newAdvType == advertising_type_t::CONNECTABLE_DIRECTED) {
            /* these types can only be used with legacy PDUs */
            MBED_ASSERT(legacy);
        }
        _advType = newAdvType;
        _legacyPDU = legacy;
        return *this;
    }

    /**
     * Update the advertising type.
     *
     * @note If legacy PDU is not used then you cannot use
     * CONNECTABLE_UNDIRECTED nor CONNECTABLE_DIRECTED.
     *
     * @param[in] newAdvType The new advertising type.
     *
     * @return reference to this object.
     */
    AdvertisingParameters &setType(advertising_type_t newAdvType)
    {
        if (newAdvType == advertising_type_t::CONNECTABLE_UNDIRECTED ||
            newAdvType == advertising_type_t::CONNECTABLE_DIRECTED) {
            /* these types can only be used with legacy PDUs */
            MBED_ASSERT(_legacyPDU);
        }
        _advType = newAdvType;
        return *this;
    }

    /**
     * Return the advertising type.
     *
     * @return Advertising type.
     */
    advertising_type_t getType() const
    {
        return _advType;
    }

    /** Set the advertising intervals on the primary channels.
     *
     * @param[in] min, max Time interval between two advertisements.
     * A range is provided to the LE subsystem, so it can adjust the advertising
     * interval with other transmission happening on the BLE radio.
     *
     * @return reference to this object.
     */
    AdvertisingParameters &setPrimaryInterval(
        adv_interval_t min, adv_interval_t max
    )
    {
        _minInterval = min;
        _maxInterval = max;
        return *this;
    }

    /** Get the minimum advertising intervals on the primary channels.
     *
     * @return The lower bound of the primary interval selected.
     */
    adv_interval_t getMinPrimaryInterval() const
    {
        return _minInterval;
    }

    /** Get the maximum advertising intervals on the primary channels.
     *
     * @return The higher bound of the primary interval selected.
     */
    adv_interval_t getMaxPrimaryInterval() const
    {
        return _maxInterval;
    }

    /** Set which channels are to be used for primary advertising.
     *  At least must be used. If all are set to disabled, all channels will be used.
     *
     * @param channel37 Use channel 37.
     * @param channel38 Use channel 38.
     * @param channel39 Use channel 39.
     *
     * @return a reference to this object.
     */
    AdvertisingParameters &setPrimaryChannels(
        bool channel37, bool channel38, bool channel39
    )
    {
        if (!channel37 && !channel38 && !channel39) {
            channel37 = channel38 = channel39 = true;
        }
        _channel37 = channel37;
        _channel38 = channel38;
        _channel39 = channel39;
        return *this;
    }

    /** Check if channel 37 is used for primary advertising.
     *
     * @return True if channel used.
     */
    bool getChannel37() const
    {
        return _channel37;
    }

    /** Check if channel 38 is used for primary advertising.
     *
     * @return True if channel used.
     */
    bool getChannel38() const
    {
        return _channel38;
    }

    /** Check if channel 39 is used for primary advertising.
     *
     * @return True if channel used.
     */
    bool getChannel39() const
    {
        return _channel39;
    }

    /** Get what type of address is to be used as your own address during advertising.
     *
     * @return a reference to this object.
     */
    AdvertisingParameters &setOwnAddressType(own_address_type_t addressType)
    {
        _ownAddressType = addressType;
        return *this;
    }

    /** Get what type of address is to be used as your own address during advertising.
     *
     * @return Addres tpe used.
     */
    own_address_type_t getOwnAddressType() const
    {
        return _ownAddressType;
    }

    /** Set peer address and type used during directed advertising.
     *
     * @param address Peer's address bytes.
     * @param addressType Peer's address type.
     *
     * @return a reference to this object.
     */
    AdvertisingParameters &setPeer(
        const address_t &address,
        target_peer_address_type_t addressType
    )
    {
        _peerAddress = address;
        _peerAddressType = addressType;
        return *this;
    };

    /** Get the peer address used during directed advertising.
     *
     * @return Address of the peer targeted by directed advertising.
     */
    const address_t &getPeerAddress() const
    {
        return _peerAddress;
    };

    /** Get the peer address type used during directed advertising.
     *
     * @return The type of address of the peer targeted by directed advertising.
     */
    target_peer_address_type_t getPeerAddressType() const
    {
        return _peerAddressType;
    };

    /** Set the filter policy of whitelist use during advertising;
     *
     * @param mode Policy to use.
     *
     * @return A reference to this object.
     */
    AdvertisingParameters &setFilter(advertising_filter_policy_t mode)
    {
        _policy = mode;
        return *this;
    }

    /** Get the filter policy of whitelist use during advertising;
     *
     * @return Policy used.
     */
    advertising_filter_policy_t getFilter() const
    {
#if BLE_FEATURE_WHITELIST
        return _policy;
#else
        return advertising_filter_policy_t::NO_FILTER;
#endif // BLE_FEATURE_WHITELIST
    }

    /* Extended advertising parameters */

    /** Get PHYs used on primary and secondary advertising channels.
     *
     * @param primaryPhy Primary advertising channels PHY.
     * @param secondaryPhy Secondary advertising channels PHY.
     *
     * @return A reference to this.
     */
    AdvertisingParameters &setPhy(phy_t primaryPhy, phy_t secondaryPhy)
    {
        _primaryPhy = primaryPhy;
        _secondaryPhy = secondaryPhy;
        return *this;
    }

    /** Get PHY used for primary advertising.
     *
     * @return PHY used for primary advertising.
     */
    phy_t getPrimaryPhy() const
    {
        return _primaryPhy;
    }

    /** Get PHY used for secondary advertising.
     *
     * @return PHY used for secondary advertising.
     */
    phy_t getSecondaryPhy() const
    {
        return _secondaryPhy;
    }

    /** Set the advertising TX power.
     *
     * @param txPower Advertising TX power.
     *
     * @return A reference to this object.
     */
    AdvertisingParameters &setTxPower(advertising_power_t txPower)
    {
        _txPower = txPower;
        return *this;
    }

    /** Get the advertising TX power.
     *
     * @return Advertising TX power.
     */
    advertising_power_t getTxPower() const
    {
        return _txPower;
    }

    /** Set how many events can be skipped on the secondary channel.
     *
     * @param eventNumber Number of events that can be skipped.
     *
     * @return A reference to this object.
     */
    AdvertisingParameters &setSecondaryMaxSkip(uint8_t eventNumber)
    {
        _maxSkip = eventNumber;
        return *this;
    }

    /** Return how many events can be skipped on the secondary channel.
     *
     * @return How many events can be skipped on the secondary channel.
     */
    uint8_t getSecondaryMaxSkip() const
    {
        return _maxSkip;
    }

    /** Enabled or disable the callback that notifies the user about a scan request.
     *
     * @param enable Enable callback if true.
     *
     * @return A reference to this object.
     *
     * @see ::ble::Gap::EventHandler::onScanRequestReceived()
     */
    AdvertisingParameters &setScanRequestNotification(bool enable = true)
    {
        _notifyOnScan = enable;
        return *this;
    }

    /** Return of the callback for scan request is enabled.
     *
     * @return True if callback is enabled.
     */
    bool getScanRequestNotification() const
    {
        return _notifyOnScan;
    }

    /** Use legacy PDU during advertising.
     *
     * @param enable If true, legacy PDU will be used.
     *
     * @note If CONNECTABLE_UNDIRECTED or CONNECTABLE_DIRECTED advertising is used
     * you must use legacy PDU.
     *
     * @return A reference to this object.
     */
    AdvertisingParameters &setUseLegacyPDU(bool enable = true)
    {
        if (!enable) {
            /* these types can only be used with legacy PDUs */
            MBED_ASSERT((_advType != advertising_type_t::CONNECTABLE_UNDIRECTED) &&
                        (_advType != advertising_type_t::CONNECTABLE_DIRECTED));
        }

        _legacyPDU = enable;
        return *this;
    }

    /** Check if legacy PDU is used during advertising.
     *
     * @return True legacy PDU will be used.
     */
    bool getUseLegacyPDU() const
    {
        return _legacyPDU;
    }

    /** Set if TX power should be included in the header.
     *
     * @param enable If true, include the TX power in the header.
     *
     * @return A reference to this object.
     */
    AdvertisingParameters &includeTxPowerInHeader(bool enable = true)
    {
        _includeHeaderTxPower = enable;
        return *this;
    }

    /** Check if TX power should be included in the header.
     *
     * @return True if TX power is included in the header.
     */
    bool getTxPowerInHeader() const
    {
        return _includeHeaderTxPower;
    }

    /** Advertise without your own address.
     *
     * @param enable Advertising anonymous if true.
     *
     * @note You may not use anonymous advertising with periodic advertising on the same set.
     *
     * @return reference to this object.
     */
    AdvertisingParameters &setAnonymousAdvertising(bool enable)
    {
        _anonymous = enable;
        return *this;
    }

    /** Check if advertising is anonymous.
     *
     * @return True if advertising is anonymous.
     */
    bool getAnonymousAdvertising() const
    {
        return _anonymous;
    }

private:
    /**
     * Enforce limits on parameters.
     */
    void normalize()
    {
        /* Min interval is slightly larger than in other modes. */
        if (_advType == advertising_type_t::NON_CONNECTABLE_UNDIRECTED) {
            _minInterval = adv_interval_t(std::max(_minInterval.value(), GAP_ADV_PARAMS_INTERVAL_MIN_NONCON));
            _maxInterval = adv_interval_t(std::max(_maxInterval.value(), GAP_ADV_PARAMS_INTERVAL_MIN_NONCON));
        }
        if (_advType == advertising_type_t::CONNECTABLE_DIRECTED ||
            _advType == advertising_type_t::CONNECTABLE_UNDIRECTED) {
            _legacyPDU = true;
        }
    }

private:
    advertising_type_t _advType;
    /* The advertising interval in ADV duration units (in other words, 0.625ms). */
    adv_interval_t _minInterval;
    /* The advertising max interval in ADV duration units (in other words, 0.625ms) used in extended advertising. */
    adv_interval_t _maxInterval;

    target_peer_address_type_t _peerAddressType;
    own_address_type_t _ownAddressType;
    advertising_filter_policy_t _policy;
    phy_t _primaryPhy;
    phy_t _secondaryPhy;
    address_t _peerAddress;
    advertising_power_t _txPower;
    uint8_t _maxSkip;
    bool _channel37:1;
    bool _channel38:1;
    bool _channel39:1;
    bool _anonymous:1;
    bool _notifyOnScan:1;
    bool _legacyPDU:1;
    bool _includeHeaderTxPower:1;
};

/**
 * @}
 * @}
 */

} // namespace ble

#endif /* ifndef MBED_ADVERTISING_PARAMETERS_H__ */

redpajama_set_name: RedPajamaGithub


text:
from distutils.core import setup

setup(
    name='p4a-build',
    version='1.0.2',
    author='Mathieu Virbel',
    author_email='mat@kivy.org',
    scripts=['p4a-build'],
    description='Build tool for P4A Build Cloud',
    install_requires=['requests']
)


text:
// Copyright (c) 2009-2021 The Bitcoin Core developers
// Distributed under the MIT software license, see the accompanying
// file COPYING or http://www.opensource.org/licenses/mit-license.php.

#ifndef BITCOIN_PSBT_H
#define BITCOIN_PSBT_H

#include <node/transaction.h>
#include <policy/feerate.h>
#include <primitives/transaction.h>
#include <pubkey.h>
#include <script/keyorigin.h>
#include <script/sign.h>
#include <script/signingprovider.h>
#include <span.h>
#include <streams.h>

#include <optional>

// Magic bytes
static constexpr uint8_t PSBT_MAGIC_BYTES[5] = {'p', 's', 'b', 't', 0xff};

// Global types
static constexpr uint8_t PSBT_GLOBAL_UNSIGNED_TX = 0x00;
static constexpr uint8_t PSBT_GLOBAL_XPUB = 0x01;
static constexpr uint8_t PSBT_GLOBAL_VERSION = 0xFB;
static constexpr uint8_t PSBT_GLOBAL_PROPRIETARY = 0xFC;

// Input types
static constexpr uint8_t PSBT_IN_NON_WITNESS_UTXO = 0x00;
static constexpr uint8_t PSBT_IN_WITNESS_UTXO = 0x01;
static constexpr uint8_t PSBT_IN_PARTIAL_SIG = 0x02;
static constexpr uint8_t PSBT_IN_SIGHASH = 0x03;
static constexpr uint8_t PSBT_IN_REDEEMSCRIPT = 0x04;
static constexpr uint8_t PSBT_IN_WITNESSSCRIPT = 0x05;
static constexpr uint8_t PSBT_IN_BIP32_DERIVATION = 0x06;
static constexpr uint8_t PSBT_IN_SCRIPTSIG = 0x07;
static constexpr uint8_t PSBT_IN_SCRIPTWITNESS = 0x08;
static constexpr uint8_t PSBT_IN_RIPEMD160 = 0x0A;
static constexpr uint8_t PSBT_IN_SHA256 = 0x0B;
static constexpr uint8_t PSBT_IN_HASH160 = 0x0C;
static constexpr uint8_t PSBT_IN_HASH256 = 0x0D;
static constexpr uint8_t PSBT_IN_TAP_KEY_SIG = 0x13;
static constexpr uint8_t PSBT_IN_TAP_SCRIPT_SIG = 0x14;
static constexpr uint8_t PSBT_IN_TAP_LEAF_SCRIPT = 0x15;
static constexpr uint8_t PSBT_IN_TAP_BIP32_DERIVATION = 0x16;
static constexpr uint8_t PSBT_IN_TAP_INTERNAL_KEY = 0x17;
static constexpr uint8_t PSBT_IN_TAP_MERKLE_ROOT = 0x18;
static constexpr uint8_t PSBT_IN_PROPRIETARY = 0xFC;

// Output types
static constexpr uint8_t PSBT_OUT_REDEEMSCRIPT = 0x00;
static constexpr uint8_t PSBT_OUT_WITNESSSCRIPT = 0x01;
static constexpr uint8_t PSBT_OUT_BIP32_DERIVATION = 0x02;
static constexpr uint8_t PSBT_OUT_TAP_INTERNAL_KEY = 0x05;
static constexpr uint8_t PSBT_OUT_TAP_TREE = 0x06;
static constexpr uint8_t PSBT_OUT_TAP_BIP32_DERIVATION = 0x07;
static constexpr uint8_t PSBT_OUT_PROPRIETARY = 0xFC;

// The separator is 0x00. Reading this in means that the unserializer can interpret it
// as a 0 length key which indicates that this is the separator. The separator has no value.
static constexpr uint8_t PSBT_SEPARATOR = 0x00;

// BIP 174 does not specify a maximum file size, but we set a limit anyway
// to prevent reading a stream indefinitely and running out of memory.
const std::streamsize MAX_FILE_SIZE_PSBT = 100000000; // 100 MB

// PSBT version number
static constexpr uint32_t PSBT_HIGHEST_VERSION = 0;

/** A structure for PSBT proprietary types */
struct PSBTProprietary
{
    uint64_t subtype;
    std::vector<unsigned char> identifier;
    std::vector<unsigned char> key;
    std::vector<unsigned char> value;

    bool operator<(const PSBTProprietary &b) const {
        return key < b.key;
    }
    bool operator==(const PSBTProprietary &b) const {
        return key == b.key;
    }
};

// Takes a stream and multiple arguments and serializes them as if first serialized into a vector and then into the stream
// The resulting output into the stream has the total serialized length of all of the objects followed by all objects concatenated with each other.
template<typename Stream, typename... X>
void SerializeToVector(Stream& s, const X&... args)
{
    WriteCompactSize(s, GetSerializeSizeMany(s.GetVersion(), args...));
    SerializeMany(s, args...);
}

// Takes a stream and multiple arguments and unserializes them first as a vector then each object individually in the order provided in the arguments
template<typename Stream, typename... X>
void UnserializeFromVector(Stream& s, X&... args)
{
    size_t expected_size = ReadCompactSize(s);
    size_t remaining_before = s.size();
    UnserializeMany(s, args...);
    size_t remaining_after = s.size();
    if (remaining_after + expected_size != remaining_before) {
        throw std::ios_base::failure("Size of value was not the stated size");
    }
}

// Deserialize bytes of given length from the stream as a KeyOriginInfo
template<typename Stream>
KeyOriginInfo DeserializeKeyOrigin(Stream& s, uint64_t length)
{
    // Read in key path
    if (length % 4 || length == 0) {
        throw std::ios_base::failure("Invalid length for HD key path");
    }

    KeyOriginInfo hd_keypath;
    s >> hd_keypath.fingerprint;
    for (unsigned int i = 4; i < length; i += sizeof(uint32_t)) {
        uint32_t index;
        s >> index;
        hd_keypath.path.push_back(index);
    }
    return hd_keypath;
}

// Deserialize a length prefixed KeyOriginInfo from a stream
template<typename Stream>
void DeserializeHDKeypath(Stream& s, KeyOriginInfo& hd_keypath)
{
    hd_keypath = DeserializeKeyOrigin(s, ReadCompactSize(s));
}

// Deserialize HD keypaths into a map
template<typename Stream>
void DeserializeHDKeypaths(Stream& s, const std::vector<unsigned char>& key, std::map<CPubKey, KeyOriginInfo>& hd_keypaths)
{
    // Make sure that the key is the size of pubkey + 1
    if (key.size() != CPubKey::SIZE + 1 && key.size() != CPubKey::COMPRESSED_SIZE + 1) {
        throw std::ios_base::failure("Size of key was not the expected size for the type BIP32 keypath");
    }
    // Read in the pubkey from key
    CPubKey pubkey(key.begin() + 1, key.end());
    if (!pubkey.IsFullyValid()) {
       throw std::ios_base::failure("Invalid pubkey");
    }
    if (hd_keypaths.count(pubkey) > 0) {
        throw std::ios_base::failure("Duplicate Key, pubkey derivation path already provided");
    }

    KeyOriginInfo keypath;
    DeserializeHDKeypath(s, keypath);

    // Add to map
    hd_keypaths.emplace(pubkey, std::move(keypath));
}

// Serialize a KeyOriginInfo to a stream
template<typename Stream>
void SerializeKeyOrigin(Stream& s, KeyOriginInfo hd_keypath)
{
    s << hd_keypath.fingerprint;
    for (const auto& path : hd_keypath.path) {
        s << path;
    }
}

// Serialize a length prefixed KeyOriginInfo to a stream
template<typename Stream>
void SerializeHDKeypath(Stream& s, KeyOriginInfo hd_keypath)
{
    WriteCompactSize(s, (hd_keypath.path.size() + 1) * sizeof(uint32_t));
    SerializeKeyOrigin(s, hd_keypath);
}

// Serialize HD keypaths to a stream from a map
template<typename Stream>
void SerializeHDKeypaths(Stream& s, const std::map<CPubKey, KeyOriginInfo>& hd_keypaths, CompactSizeWriter type)
{
    for (auto keypath_pair : hd_keypaths) {
        if (!keypath_pair.first.IsValid()) {
            throw std::ios_base::failure("Invalid CPubKey being serialized");
        }
        SerializeToVector(s, type, Span{keypath_pair.first});
        SerializeHDKeypath(s, keypath_pair.second);
    }
}

/** A structure for PSBTs which contain per-input information */
struct PSBTInput
{
    CTransactionRef non_witness_utxo;
    CTxOut witness_utxo;
    CScript redeem_script;
    CScript witness_script;
    CScript final_script_sig;
    CScriptWitness final_script_witness;
    std::map<CPubKey, KeyOriginInfo> hd_keypaths;
    std::map<CKeyID, SigPair> partial_sigs;
    std::map<uint160, std::vector<unsigned char>> ripemd160_preimages;
    std::map<uint256, std::vector<unsigned char>> sha256_preimages;
    std::map<uint160, std::vector<unsigned char>> hash160_preimages;
    std::map<uint256, std::vector<unsigned char>> hash256_preimages;

    // Taproot fields
    std::vector<unsigned char> m_tap_key_sig;
    std::map<std::pair<XOnlyPubKey, uint256>, std::vector<unsigned char>> m_tap_script_sigs;
    std::map<std::pair<CScript, int>, std::set<std::vector<unsigned char>, ShortestVectorFirstComparator>> m_tap_scripts;
    std::map<XOnlyPubKey, std::pair<std::set<uint256>, KeyOriginInfo>> m_tap_bip32_paths;
    XOnlyPubKey m_tap_internal_key;
    uint256 m_tap_merkle_root;

    std::map<std::vector<unsigned char>, std::vector<unsigned char>> unknown;
    std::set<PSBTProprietary> m_proprietary;
    std::optional<int> sighash_type;

    bool IsNull() const;
    void FillSignatureData(SignatureData& sigdata) const;
    void FromSignatureData(const SignatureData& sigdata);
    void Merge(const PSBTInput& input);
    PSBTInput() {}

    template <typename Stream>
    inline void Serialize(Stream& s) const {
        // Write the utxo
        if (non_witness_utxo) {
            SerializeToVector(s, CompactSizeWriter(PSBT_IN_NON_WITNESS_UTXO));
            OverrideStream<Stream> os(&s, s.GetType(), s.GetVersion() | SERIALIZE_TRANSACTION_NO_WITNESS);
            SerializeToVector(os, non_witness_utxo);
        }
        if (!witness_utxo.IsNull()) {
            SerializeToVector(s, CompactSizeWriter(PSBT_IN_WITNESS_UTXO));
            SerializeToVector(s, witness_utxo);
        }

        if (final_script_sig.empty() && final_script_witness.IsNull()) {
            // Write any partial signatures
            for (auto sig_pair : partial_sigs) {
                SerializeToVector(s, CompactSizeWriter(PSBT_IN_PARTIAL_SIG), Span{sig_pair.second.first});
                s << sig_pair.second.second;
            }

            // Write the sighash type
            if (sighash_type != std::nullopt) {
                SerializeToVector(s, CompactSizeWriter(PSBT_IN_SIGHASH));
                SerializeToVector(s, *sighash_type);
            }

            // Write the redeem script
            if (!redeem_script.empty()) {
                SerializeToVector(s, CompactSizeWriter(PSBT_IN_REDEEMSCRIPT));
                s << redeem_script;
            }

            // Write the witness script
            if (!witness_script.empty()) {
                SerializeToVector(s, CompactSizeWriter(PSBT_IN_WITNESSSCRIPT));
                s << witness_script;
            }

            // Write any hd keypaths
            SerializeHDKeypaths(s, hd_keypaths, CompactSizeWriter(PSBT_IN_BIP32_DERIVATION));

            // Write any ripemd160 preimage
            for (const auto& [hash, preimage] : ripemd160_preimages) {
                SerializeToVector(s, CompactSizeWriter(PSBT_IN_RIPEMD160), Span{hash});
                s << preimage;
            }

            // Write any sha256 preimage
            for (const auto& [hash, preimage] : sha256_preimages) {
                SerializeToVector(s, CompactSizeWriter(PSBT_IN_SHA256), Span{hash});
                s << preimage;
            }

            // Write any hash160 preimage
            for (const auto& [hash, preimage] : hash160_preimages) {
                SerializeToVector(s, CompactSizeWriter(PSBT_IN_HASH160), Span{hash});
                s << preimage;
            }

            // Write any hash256 preimage
            for (const auto& [hash, preimage] : hash256_preimages) {
                SerializeToVector(s, CompactSizeWriter(PSBT_IN_HASH256), Span{hash});
                s << preimage;
            }

            // Write taproot key sig
            if (!m_tap_key_sig.empty()) {
                SerializeToVector(s, PSBT_IN_TAP_KEY_SIG);
                s << m_tap_key_sig;
            }

            // Write taproot script sigs
            for (const auto& [pubkey_leaf, sig] : m_tap_script_sigs) {
                const auto& [xonly, leaf_hash] = pubkey_leaf;
                SerializeToVector(s, PSBT_IN_TAP_SCRIPT_SIG, xonly, leaf_hash);
                s << sig;
            }

            // Write taproot leaf scripts
            for (const auto& [leaf, control_blocks] : m_tap_scripts) {
                const auto& [script, leaf_ver] = leaf;
                for (const auto& control_block : control_blocks) {
                    SerializeToVector(s, PSBT_IN_TAP_LEAF_SCRIPT, Span{control_block});
                    std::vector<unsigned char> value_v(script.begin(), script.end());
                    value_v.push_back((uint8_t)leaf_ver);
                    s << value_v;
                }
            }

            // Write taproot bip32 keypaths
            for (const auto& [xonly, leaf_origin] : m_tap_bip32_paths) {
                const auto& [leaf_hashes, origin] = leaf_origin;
                SerializeToVector(s, PSBT_IN_TAP_BIP32_DERIVATION, xonly);
                std::vector<unsigned char> value;
                CVectorWriter s_value(s.GetType(), s.GetVersion(), value, 0);
                s_value << leaf_hashes;
                SerializeKeyOrigin(s_value, origin);
                s << value;
            }

            // Write taproot internal key
            if (!m_tap_internal_key.IsNull()) {
                SerializeToVector(s, PSBT_IN_TAP_INTERNAL_KEY);
                s << ToByteVector(m_tap_internal_key);
            }

            // Write taproot merkle root
            if (!m_tap_merkle_root.IsNull()) {
                SerializeToVector(s, PSBT_IN_TAP_MERKLE_ROOT);
                SerializeToVector(s, m_tap_merkle_root);
            }
        }

        // Write script sig
        if (!final_script_sig.empty()) {
            SerializeToVector(s, CompactSizeWriter(PSBT_IN_SCRIPTSIG));
            s << final_script_sig;
        }
        // write script witness
        if (!final_script_witness.IsNull()) {
            SerializeToVector(s, CompactSizeWriter(PSBT_IN_SCRIPTWITNESS));
            SerializeToVector(s, final_script_witness.stack);
        }

        // Write proprietary things
        for (const auto& entry : m_proprietary) {
            s << entry.key;
            s << entry.value;
        }

        // Write unknown things
        for (auto& entry : unknown) {
            s << entry.first;
            s << entry.second;
        }

        s << PSBT_SEPARATOR;
    }

    template <typename Stream>
    inline void Unserialize(Stream& s) {
        // Used for duplicate key detection
        std::set<std::vector<unsigned char>> key_lookup;

        // Read loop
        bool found_sep = false;
        while(!s.empty()) {
            // Read
            std::vector<unsigned char> key;
            s >> key;

            // the key is empty if that was actually a separator byte
            // This is a special case for key lengths 0 as those are not allowed (except for separator)
            if (key.empty()) {
                found_sep = true;
                break;
            }

            // Type is compact size uint at beginning of key
            SpanReader skey(s.GetType(), s.GetVersion(), key);
            uint64_t type = ReadCompactSize(skey);

            // Do stuff based on type
            switch(type) {
                case PSBT_IN_NON_WITNESS_UTXO:
                {
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, input non-witness utxo already provided");
                    } else if (key.size() != 1) {
                        throw std::ios_base::failure("Non-witness utxo key is more than one byte type");
                    }
                    // Set the stream to unserialize with witness since this is always a valid network transaction
                    OverrideStream<Stream> os(&s, s.GetType(), s.GetVersion() & ~SERIALIZE_TRANSACTION_NO_WITNESS);
                    UnserializeFromVector(os, non_witness_utxo);
                    break;
                }
                case PSBT_IN_WITNESS_UTXO:
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, input witness utxo already provided");
                    } else if (key.size() != 1) {
                        throw std::ios_base::failure("Witness utxo key is more than one byte type");
                    }
                    UnserializeFromVector(s, witness_utxo);
                    break;
                case PSBT_IN_PARTIAL_SIG:
                {
                    // Make sure that the key is the size of pubkey + 1
                    if (key.size() != CPubKey::SIZE + 1 && key.size() != CPubKey::COMPRESSED_SIZE + 1) {
                        throw std::ios_base::failure("Size of key was not the expected size for the type partial signature pubkey");
                    }
                    // Read in the pubkey from key
                    CPubKey pubkey(key.begin() + 1, key.end());
                    if (!pubkey.IsFullyValid()) {
                       throw std::ios_base::failure("Invalid pubkey");
                    }
                    if (partial_sigs.count(pubkey.GetID()) > 0) {
                        throw std::ios_base::failure("Duplicate Key, input partial signature for pubkey already provided");
                    }

                    // Read in the signature from value
                    std::vector<unsigned char> sig;
                    s >> sig;

                    // Add to list
                    partial_sigs.emplace(pubkey.GetID(), SigPair(pubkey, std::move(sig)));
                    break;
                }
                case PSBT_IN_SIGHASH:
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, input sighash type already provided");
                    } else if (key.size() != 1) {
                        throw std::ios_base::failure("Sighash type key is more than one byte type");
                    }
                    int sighash;
                    UnserializeFromVector(s, sighash);
                    sighash_type = sighash;
                    break;
                case PSBT_IN_REDEEMSCRIPT:
                {
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, input redeemScript already provided");
                    } else if (key.size() != 1) {
                        throw std::ios_base::failure("Input redeemScript key is more than one byte type");
                    }
                    s >> redeem_script;
                    break;
                }
                case PSBT_IN_WITNESSSCRIPT:
                {
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, input witnessScript already provided");
                    } else if (key.size() != 1) {
                        throw std::ios_base::failure("Input witnessScript key is more than one byte type");
                    }
                    s >> witness_script;
                    break;
                }
                case PSBT_IN_BIP32_DERIVATION:
                {
                    DeserializeHDKeypaths(s, key, hd_keypaths);
                    break;
                }
                case PSBT_IN_SCRIPTSIG:
                {
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, input final scriptSig already provided");
                    } else if (key.size() != 1) {
                        throw std::ios_base::failure("Final scriptSig key is more than one byte type");
                    }
                    s >> final_script_sig;
                    break;
                }
                case PSBT_IN_SCRIPTWITNESS:
                {
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, input final scriptWitness already provided");
                    } else if (key.size() != 1) {
                        throw std::ios_base::failure("Final scriptWitness key is more than one byte type");
                    }
                    UnserializeFromVector(s, final_script_witness.stack);
                    break;
                }
                case PSBT_IN_RIPEMD160:
                {
                    // Make sure that the key is the size of a ripemd160 hash + 1
                    if (key.size() != CRIPEMD160::OUTPUT_SIZE + 1) {
                        throw std::ios_base::failure("Size of key was not the expected size for the type ripemd160 preimage");
                    }
                    // Read in the hash from key
                    std::vector<unsigned char> hash_vec(key.begin() + 1, key.end());
                    uint160 hash(hash_vec);
                    if (ripemd160_preimages.count(hash) > 0) {
                        throw std::ios_base::failure("Duplicate Key, input ripemd160 preimage already provided");
                    }

                    // Read in the preimage from value
                    std::vector<unsigned char> preimage;
                    s >> preimage;

                    // Add to preimages list
                    ripemd160_preimages.emplace(hash, std::move(preimage));
                    break;
                }
                case PSBT_IN_SHA256:
                {
                    // Make sure that the key is the size of a sha256 hash + 1
                    if (key.size() != CSHA256::OUTPUT_SIZE + 1) {
                        throw std::ios_base::failure("Size of key was not the expected size for the type sha256 preimage");
                    }
                    // Read in the hash from key
                    std::vector<unsigned char> hash_vec(key.begin() + 1, key.end());
                    uint256 hash(hash_vec);
                    if (sha256_preimages.count(hash) > 0) {
                        throw std::ios_base::failure("Duplicate Key, input sha256 preimage already provided");
                    }

                    // Read in the preimage from value
                    std::vector<unsigned char> preimage;
                    s >> preimage;

                    // Add to preimages list
                    sha256_preimages.emplace(hash, std::move(preimage));
                    break;
                }
                case PSBT_IN_HASH160:
                {
                    // Make sure that the key is the size of a hash160 hash + 1
                    if (key.size() != CHash160::OUTPUT_SIZE + 1) {
                        throw std::ios_base::failure("Size of key was not the expected size for the type hash160 preimage");
                    }
                    // Read in the hash from key
                    std::vector<unsigned char> hash_vec(key.begin() + 1, key.end());
                    uint160 hash(hash_vec);
                    if (hash160_preimages.count(hash) > 0) {
                        throw std::ios_base::failure("Duplicate Key, input hash160 preimage already provided");
                    }

                    // Read in the preimage from value
                    std::vector<unsigned char> preimage;
                    s >> preimage;

                    // Add to preimages list
                    hash160_preimages.emplace(hash, std::move(preimage));
                    break;
                }
                case PSBT_IN_HASH256:
                {
                    // Make sure that the key is the size of a hash256 hash + 1
                    if (key.size() != CHash256::OUTPUT_SIZE + 1) {
                        throw std::ios_base::failure("Size of key was not the expected size for the type hash256 preimage");
                    }
                    // Read in the hash from key
                    std::vector<unsigned char> hash_vec(key.begin() + 1, key.end());
                    uint256 hash(hash_vec);
                    if (hash256_preimages.count(hash) > 0) {
                        throw std::ios_base::failure("Duplicate Key, input hash256 preimage already provided");
                    }

                    // Read in the preimage from value
                    std::vector<unsigned char> preimage;
                    s >> preimage;

                    // Add to preimages list
                    hash256_preimages.emplace(hash, std::move(preimage));
                    break;
                }
                case PSBT_IN_TAP_KEY_SIG:
                {
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, input Taproot key signature already provided");
                    } else if (key.size() != 1) {
                        throw std::ios_base::failure("Input Taproot key signature key is more than one byte type");
                    }
                    s >> m_tap_key_sig;
                    if (m_tap_key_sig.size() < 64) {
                        throw std::ios_base::failure("Input Taproot key path signature is shorter than 64 bytes");
                    } else if (m_tap_key_sig.size() > 65) {
                        throw std::ios_base::failure("Input Taproot key path signature is longer than 65 bytes");
                    }
                    break;
                }
                case PSBT_IN_TAP_SCRIPT_SIG:
                {
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, input Taproot script signature already provided");
                    } else if (key.size() != 65) {
                        throw std::ios_base::failure("Input Taproot script signature key is not 65 bytes");
                    }
                    SpanReader s_key(s.GetType(), s.GetVersion(), Span{key}.subspan(1));
                    XOnlyPubKey xonly;
                    uint256 hash;
                    s_key >> xonly;
                    s_key >> hash;
                    std::vector<unsigned char> sig;
                    s >> sig;
                    if (sig.size() < 64) {
                        throw std::ios_base::failure("Input Taproot script path signature is shorter than 64 bytes");
                    } else if (sig.size() > 65) {
                        throw std::ios_base::failure("Input Taproot script path signature is longer than 65 bytes");
                    }
                    m_tap_script_sigs.emplace(std::make_pair(xonly, hash), sig);
                    break;
                }
                case PSBT_IN_TAP_LEAF_SCRIPT:
                {
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, input Taproot leaf script already provided");
                    } else if (key.size() < 34) {
                        throw std::ios_base::failure("Taproot leaf script key is not at least 34 bytes");
                    } else if ((key.size() - 2) % 32 != 0) {
                        throw std::ios_base::failure("Input Taproot leaf script key's control block size is not valid");
                    }
                    std::vector<unsigned char> script_v;
                    s >> script_v;
                    if (script_v.empty()) {
                        throw std::ios_base::failure("Input Taproot leaf script must be at least 1 byte");
                    }
                    uint8_t leaf_ver = script_v.back();
                    script_v.pop_back();
                    const auto leaf_script = std::make_pair(CScript(script_v.begin(), script_v.end()), (int)leaf_ver);
                    m_tap_scripts[leaf_script].insert(std::vector<unsigned char>(key.begin() + 1, key.end()));
                    break;
                }
                case PSBT_IN_TAP_BIP32_DERIVATION:
                {
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, input Taproot BIP32 keypath already provided");
                    } else if (key.size() != 33) {
                        throw std::ios_base::failure("Input Taproot BIP32 keypath key is not at 33 bytes");
                    }
                    SpanReader s_key(s.GetType(), s.GetVersion(), Span{key}.subspan(1));
                    XOnlyPubKey xonly;
                    s_key >> xonly;
                    std::set<uint256> leaf_hashes;
                    uint64_t value_len = ReadCompactSize(s);
                    size_t before_hashes = s.size();
                    s >> leaf_hashes;
                    size_t after_hashes = s.size();
                    size_t hashes_len = before_hashes - after_hashes;
                    size_t origin_len = value_len - hashes_len;
                    m_tap_bip32_paths.emplace(xonly, std::make_pair(leaf_hashes, DeserializeKeyOrigin(s, origin_len)));
                    break;
                }
                case PSBT_IN_TAP_INTERNAL_KEY:
                {
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, input Taproot internal key already provided");
                    } else if (key.size() != 1) {
                        throw std::ios_base::failure("Input Taproot internal key key is more than one byte type");
                    }
                    UnserializeFromVector(s, m_tap_internal_key);
                    break;
                }
                case PSBT_IN_TAP_MERKLE_ROOT:
                {
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, input Taproot merkle root already provided");
                    } else if (key.size() != 1) {
                        throw std::ios_base::failure("Input Taproot merkle root key is more than one byte type");
                    }
                    UnserializeFromVector(s, m_tap_merkle_root);
                    break;
                }
                case PSBT_IN_PROPRIETARY:
                {
                    PSBTProprietary this_prop;
                    skey >> this_prop.identifier;
                    this_prop.subtype = ReadCompactSize(skey);
                    this_prop.key = key;

                    if (m_proprietary.count(this_prop) > 0) {
                        throw std::ios_base::failure("Duplicate Key, proprietary key already found");
                    }
                    s >> this_prop.value;
                    m_proprietary.insert(this_prop);
                    break;
                }
                // Unknown stuff
                default:
                    if (unknown.count(key) > 0) {
                        throw std::ios_base::failure("Duplicate Key, key for unknown value already provided");
                    }
                    // Read in the value
                    std::vector<unsigned char> val_bytes;
                    s >> val_bytes;
                    unknown.emplace(std::move(key), std::move(val_bytes));
                    break;
            }
        }

        if (!found_sep) {
            throw std::ios_base::failure("Separator is missing at the end of an input map");
        }
    }

    template <typename Stream>
    PSBTInput(deserialize_type, Stream& s) {
        Unserialize(s);
    }
};

/** A structure for PSBTs which contains per output information */
struct PSBTOutput
{
    CScript redeem_script;
    CScript witness_script;
    std::map<CPubKey, KeyOriginInfo> hd_keypaths;
    XOnlyPubKey m_tap_internal_key;
    std::optional<TaprootBuilder> m_tap_tree;
    std::map<XOnlyPubKey, std::pair<std::set<uint256>, KeyOriginInfo>> m_tap_bip32_paths;
    std::map<std::vector<unsigned char>, std::vector<unsigned char>> unknown;
    std::set<PSBTProprietary> m_proprietary;

    bool IsNull() const;
    void FillSignatureData(SignatureData& sigdata) const;
    void FromSignatureData(const SignatureData& sigdata);
    void Merge(const PSBTOutput& output);
    PSBTOutput() {}

    template <typename Stream>
    inline void Serialize(Stream& s) const {
        // Write the redeem script
        if (!redeem_script.empty()) {
            SerializeToVector(s, CompactSizeWriter(PSBT_OUT_REDEEMSCRIPT));
            s << redeem_script;
        }

        // Write the witness script
        if (!witness_script.empty()) {
            SerializeToVector(s, CompactSizeWriter(PSBT_OUT_WITNESSSCRIPT));
            s << witness_script;
        }

        // Write any hd keypaths
        SerializeHDKeypaths(s, hd_keypaths, CompactSizeWriter(PSBT_OUT_BIP32_DERIVATION));

        // Write proprietary things
        for (const auto& entry : m_proprietary) {
            s << entry.key;
            s << entry.value;
        }

        // Write taproot internal key
        if (!m_tap_internal_key.IsNull()) {
            SerializeToVector(s, PSBT_OUT_TAP_INTERNAL_KEY);
            s << ToByteVector(m_tap_internal_key);
        }

        // Write taproot tree
        if (m_tap_tree.has_value()) {
            SerializeToVector(s, PSBT_OUT_TAP_TREE);
            std::vector<unsigned char> value;
            CVectorWriter s_value(s.GetType(), s.GetVersion(), value, 0);
            const auto& tuples = m_tap_tree->GetTreeTuples();
            for (const auto& tuple : tuples) {
                uint8_t depth = std::get<0>(tuple);
                uint8_t leaf_ver = std::get<1>(tuple);
                CScript script = std::get<2>(tuple);
                s_value << depth;
                s_value << leaf_ver;
                s_value << script;
            }
            s << value;
        }

        // Write taproot bip32 keypaths
        for (const auto& [xonly, leaf] : m_tap_bip32_paths) {
            const auto& [leaf_hashes, origin] = leaf;
            SerializeToVector(s, PSBT_OUT_TAP_BIP32_DERIVATION, xonly);
            std::vector<unsigned char> value;
            CVectorWriter s_value(s.GetType(), s.GetVersion(), value, 0);
            s_value << leaf_hashes;
            SerializeKeyOrigin(s_value, origin);
            s << value;
        }

        // Write unknown things
        for (auto& entry : unknown) {
            s << entry.first;
            s << entry.second;
        }

        s << PSBT_SEPARATOR;
    }

    template <typename Stream>
    inline void Unserialize(Stream& s) {
        // Used for duplicate key detection
        std::set<std::vector<unsigned char>> key_lookup;

        // Read loop
        bool found_sep = false;
        while(!s.empty()) {
            // Read
            std::vector<unsigned char> key;
            s >> key;

            // the key is empty if that was actually a separator byte
            // This is a special case for key lengths 0 as those are not allowed (except for separator)
            if (key.empty()) {
                found_sep = true;
                break;
            }

            // Type is compact size uint at beginning of key
            SpanReader skey(s.GetType(), s.GetVersion(), key);
            uint64_t type = ReadCompactSize(skey);

            // Do stuff based on type
            switch(type) {
                case PSBT_OUT_REDEEMSCRIPT:
                {
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, output redeemScript already provided");
                    } else if (key.size() != 1) {
                        throw std::ios_base::failure("Output redeemScript key is more than one byte type");
                    }
                    s >> redeem_script;
                    break;
                }
                case PSBT_OUT_WITNESSSCRIPT:
                {
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, output witnessScript already provided");
                    } else if (key.size() != 1) {
                        throw std::ios_base::failure("Output witnessScript key is more than one byte type");
                    }
                    s >> witness_script;
                    break;
                }
                case PSBT_OUT_BIP32_DERIVATION:
                {
                    DeserializeHDKeypaths(s, key, hd_keypaths);
                    break;
                }
                case PSBT_OUT_TAP_INTERNAL_KEY:
                {
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, output Taproot internal key already provided");
                    } else if (key.size() != 1) {
                        throw std::ios_base::failure("Output Taproot internal key key is more than one byte type");
                    }
                    UnserializeFromVector(s, m_tap_internal_key);
                    break;
                }
                case PSBT_OUT_TAP_TREE:
                {
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, output Taproot tree already provided");
                    } else if (key.size() != 1) {
                        throw std::ios_base::failure("Output Taproot tree key is more than one byte type");
                    }
                    m_tap_tree.emplace();
                    std::vector<unsigned char> tree_v;
                    s >> tree_v;
                    SpanReader s_tree(s.GetType(), s.GetVersion(), tree_v);
                    while (!s_tree.empty()) {
                        uint8_t depth;
                        uint8_t leaf_ver;
                        CScript script;
                        s_tree >> depth;
                        s_tree >> leaf_ver;
                        s_tree >> script;
                        m_tap_tree->Add((int)depth, script, (int)leaf_ver, true /* track */);
                    }
                    if (!m_tap_tree->IsComplete()) {
                        throw std::ios_base::failure("Output Taproot tree is malformed");
                    }
                    break;
                }
                case PSBT_OUT_TAP_BIP32_DERIVATION:
                {
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, output Taproot BIP32 keypath already provided");
                    } else if (key.size() != 33) {
                        throw std::ios_base::failure("Output Taproot BIP32 keypath key is not at 33 bytes");
                    }
                    XOnlyPubKey xonly(uint256({key.begin() + 1, key.begin() + 33}));
                    std::set<uint256> leaf_hashes;
                    uint64_t value_len = ReadCompactSize(s);
                    size_t before_hashes = s.size();
                    s >> leaf_hashes;
                    size_t after_hashes = s.size();
                    size_t hashes_len = before_hashes - after_hashes;
                    size_t origin_len = value_len - hashes_len;
                    m_tap_bip32_paths.emplace(xonly, std::make_pair(leaf_hashes, DeserializeKeyOrigin(s, origin_len)));
                    break;
                }
                case PSBT_OUT_PROPRIETARY:
                {
                    PSBTProprietary this_prop;
                    skey >> this_prop.identifier;
                    this_prop.subtype = ReadCompactSize(skey);
                    this_prop.key = key;

                    if (m_proprietary.count(this_prop) > 0) {
                        throw std::ios_base::failure("Duplicate Key, proprietary key already found");
                    }
                    s >> this_prop.value;
                    m_proprietary.insert(this_prop);
                    break;
                }
                // Unknown stuff
                default: {
                    if (unknown.count(key) > 0) {
                        throw std::ios_base::failure("Duplicate Key, key for unknown value already provided");
                    }
                    // Read in the value
                    std::vector<unsigned char> val_bytes;
                    s >> val_bytes;
                    unknown.emplace(std::move(key), std::move(val_bytes));
                    break;
                }
            }
        }

        // Finalize m_tap_tree so that all of the computed things are computed
        if (m_tap_tree.has_value() && m_tap_tree->IsComplete() && m_tap_internal_key.IsFullyValid()) {
            m_tap_tree->Finalize(m_tap_internal_key);
        }

        if (!found_sep) {
            throw std::ios_base::failure("Separator is missing at the end of an output map");
        }
    }

    template <typename Stream>
    PSBTOutput(deserialize_type, Stream& s) {
        Unserialize(s);
    }
};

/** A version of CTransaction with the PSBT format*/
struct PartiallySignedTransaction
{
    std::optional<CMutableTransaction> tx;
    // We use a vector of CExtPubKey in the event that there happens to be the same KeyOriginInfos for different CExtPubKeys
    // Note that this map swaps the key and values from the serialization
    std::map<KeyOriginInfo, std::set<CExtPubKey>> m_xpubs;
    std::vector<PSBTInput> inputs;
    std::vector<PSBTOutput> outputs;
    std::map<std::vector<unsigned char>, std::vector<unsigned char>> unknown;
    std::optional<uint32_t> m_version;
    std::set<PSBTProprietary> m_proprietary;

    bool IsNull() const;
    uint32_t GetVersion() const;

    /** Merge psbt into this. The two psbts must have the same underlying CTransaction (i.e. the
      * same actual Bitcoin transaction.) Returns true if the merge succeeded, false otherwise. */
    [[nodiscard]] bool Merge(const PartiallySignedTransaction& psbt);
    bool AddInput(const CTxIn& txin, PSBTInput& psbtin);
    bool AddOutput(const CTxOut& txout, const PSBTOutput& psbtout);
    PartiallySignedTransaction() {}
    explicit PartiallySignedTransaction(const CMutableTransaction& tx);
    /**
     * Finds the UTXO for a given input index
     *
     * @param[out] utxo The UTXO of the input if found
     * @param[in] input_index Index of the input to retrieve the UTXO of
     * @return Whether the UTXO for the specified input was found
     */
    bool GetInputUTXO(CTxOut& utxo, int input_index) const;

    template <typename Stream>
    inline void Serialize(Stream& s) const {

        // magic bytes
        s << PSBT_MAGIC_BYTES;

        // unsigned tx flag
        SerializeToVector(s, CompactSizeWriter(PSBT_GLOBAL_UNSIGNED_TX));

        // Write serialized tx to a stream
        OverrideStream<Stream> os(&s, s.GetType(), s.GetVersion() | SERIALIZE_TRANSACTION_NO_WITNESS);
        SerializeToVector(os, *tx);

        // Write xpubs
        for (const auto& xpub_pair : m_xpubs) {
            for (const auto& xpub : xpub_pair.second) {
                unsigned char ser_xpub[BIP32_EXTKEY_WITH_VERSION_SIZE];
                xpub.EncodeWithVersion(ser_xpub);
                // Note that the serialization swaps the key and value
                // The xpub is the key (for uniqueness) while the path is the value
                SerializeToVector(s, PSBT_GLOBAL_XPUB, ser_xpub);
                SerializeHDKeypath(s, xpub_pair.first);
            }
        }

        // PSBT version
        if (GetVersion() > 0) {
            SerializeToVector(s, CompactSizeWriter(PSBT_GLOBAL_VERSION));
            SerializeToVector(s, *m_version);
        }

        // Write proprietary things
        for (const auto& entry : m_proprietary) {
            s << entry.key;
            s << entry.value;
        }

        // Write the unknown things
        for (auto& entry : unknown) {
            s << entry.first;
            s << entry.second;
        }

        // Separator
        s << PSBT_SEPARATOR;

        // Write inputs
        for (const PSBTInput& input : inputs) {
            s << input;
        }
        // Write outputs
        for (const PSBTOutput& output : outputs) {
            s << output;
        }
    }

    template <typename Stream>
    inline void Unserialize(Stream& s) {
        // Read the magic bytes
        uint8_t magic[5];
        s >> magic;
        if (!std::equal(magic, magic + 5, PSBT_MAGIC_BYTES)) {
            throw std::ios_base::failure("Invalid PSBT magic bytes");
        }

        // Used for duplicate key detection
        std::set<std::vector<unsigned char>> key_lookup;

        // Track the global xpubs we have already seen. Just for sanity checking
        std::set<CExtPubKey> global_xpubs;

        // Read global data
        bool found_sep = false;
        while(!s.empty()) {
            // Read
            std::vector<unsigned char> key;
            s >> key;

            // the key is empty if that was actually a separator byte
            // This is a special case for key lengths 0 as those are not allowed (except for separator)
            if (key.empty()) {
                found_sep = true;
                break;
            }

            // Type is compact size uint at beginning of key
            SpanReader skey(s.GetType(), s.GetVersion(), key);
            uint64_t type = ReadCompactSize(skey);

            // Do stuff based on type
            switch(type) {
                case PSBT_GLOBAL_UNSIGNED_TX:
                {
                    if (!key_lookup.emplace(key).second) {
                        throw std::ios_base::failure("Duplicate Key, unsigned tx already provided");
                    } else if (key.size() != 1) {
                        throw std::ios_base::failure("Global unsigned tx key is more than one byte type");
                    }
                    CMutableTransaction mtx;
                    // Set the stream to serialize with non-witness since this should always be non-witness
                    OverrideStream<Stream> os(&s, s.GetType(), s.GetVersion() | SERIALIZE_TRANSACTION_NO_WITNESS);
                    UnserializeFromVector(os, mtx);
                    tx = std::move(mtx);
                    // Make sure that all scriptSigs and scriptWitnesses are empty
                    for (const CTxIn& txin : tx->vin) {
                        if (!txin.scriptSig.empty() || !txin.scriptWitness.IsNull()) {
                            throw std::ios_base::failure("Unsigned tx does not have empty scriptSigs and scriptWitnesses.");
                        }
                    }
                    break;
                }
                case PSBT_GLOBAL_XPUB:
                {
                    if (key.size() != BIP32_EXTKEY_WITH_VERSION_SIZE + 1) {
                        throw std::ios_base::failure("Size of key was not the expected size for the type global xpub");
                    }
                    // Read in the xpub from key
                    CExtPubKey xpub;
                    xpub.DecodeWithVersion(&key.data()[1]);
                    if (!xpub.pubkey.IsFullyValid()) {
                       throw std::ios_base::failure("Invalid pubkey");
                    }
                    if (global_xpubs.count(xpub) > 0) {
                       throw std::ios_base::failure("Duplicate key, global xpub already provided");
                    }
                    global_xpubs.insert(xpub);
                    // Read in the keypath from stream
                    KeyOriginInfo keypath;
                    DeserializeHDKeypath(s, keypath);

                    // Note that we store these swapped to make searches faster.
                    // Serialization uses xpub -> keypath to enqure key uniqueness
                    if (m_xpubs.count(keypath) == 0) {
                        // Make a new set to put the xpub in
                        m_xpubs[keypath] = {xpub};
                    } else {
                        // Insert xpub into existing set
                        m_xpubs[keypath].insert(xpub);
                    }
                    break;
                }
                case PSBT_GLOBAL_VERSION:
                {
                    if (m_version) {
                        throw std::ios_base::failure("Duplicate Key, version already provided");
                    } else if (key.size() != 1) {
                        throw std::ios_base::failure("Global version key is more than one byte type");
                    }
                    uint32_t v;
                    UnserializeFromVector(s, v);
                    m_version = v;
                    if (*m_version > PSBT_HIGHEST_VERSION) {
                        throw std::ios_base::failure("Unsupported version number");
                    }
                    break;
                }
                case PSBT_GLOBAL_PROPRIETARY:
                {
                    PSBTProprietary this_prop;
                    skey >> this_prop.identifier;
                    this_prop.subtype = ReadCompactSize(skey);
                    this_prop.key = key;

                    if (m_proprietary.count(this_prop) > 0) {
                        throw std::ios_base::failure("Duplicate Key, proprietary key already found");
                    }
                    s >> this_prop.value;
                    m_proprietary.insert(this_prop);
                    break;
                }
                // Unknown stuff
                default: {
                    if (unknown.count(key) > 0) {
                        throw std::ios_base::failure("Duplicate Key, key for unknown value already provided");
                    }
                    // Read in the value
                    std::vector<unsigned char> val_bytes;
                    s >> val_bytes;
                    unknown.emplace(std::move(key), std::move(val_bytes));
                }
            }
        }

        if (!found_sep) {
            throw std::ios_base::failure("Separator is missing at the end of the global map");
        }

        // Make sure that we got an unsigned tx
        if (!tx) {
            throw std::ios_base::failure("No unsigned transcation was provided");
        }

        // Read input data
        unsigned int i = 0;
        while (!s.empty() && i < tx->vin.size()) {
            PSBTInput input;
            s >> input;
            inputs.push_back(input);

            // Make sure the non-witness utxo matches the outpoint
            if (input.non_witness_utxo && input.non_witness_utxo->GetHash() != tx->vin[i].prevout.hash) {
                throw std::ios_base::failure("Non-witness UTXO does not match outpoint hash");
            }
            ++i;
        }
        // Make sure that the number of inputs matches the number of inputs in the transaction
        if (inputs.size() != tx->vin.size()) {
            throw std::ios_base::failure("Inputs provided does not match the number of inputs in transaction.");
        }

        // Read output data
        i = 0;
        while (!s.empty() && i < tx->vout.size()) {
            PSBTOutput output;
            s >> output;
            outputs.push_back(output);
            ++i;
        }
        // Make sure that the number of outputs matches the number of outputs in the transaction
        if (outputs.size() != tx->vout.size()) {
            throw std::ios_base::failure("Outputs provided does not match the number of outputs in transaction.");
        }
    }

    template <typename Stream>
    PartiallySignedTransaction(deserialize_type, Stream& s) {
        Unserialize(s);
    }
};

enum class PSBTRole {
    CREATOR,
    UPDATER,
    SIGNER,
    FINALIZER,
    EXTRACTOR
};

std::string PSBTRoleName(PSBTRole role);

/** Compute a PrecomputedTransactionData object from a psbt. */
PrecomputedTransactionData PrecomputePSBTData(const PartiallySignedTransaction& psbt);

/** Checks whether a PSBTInput is already signed. */
bool PSBTInputSigned(const PSBTInput& input);

/** Signs a PSBTInput, verifying that all provided data matches what is being signed.
 *
 * txdata should be the output of PrecomputePSBTData (which can be shared across
 * multiple SignPSBTInput calls). If it is nullptr, a dummy signature will be created.
 **/
bool SignPSBTInput(const SigningProvider& provider, PartiallySignedTransaction& psbt, int index, const PrecomputedTransactionData* txdata, int sighash = SIGHASH_ALL, SignatureData* out_sigdata = nullptr, bool finalize = true);

/** Counts the unsigned inputs of a PSBT. */
size_t CountPSBTUnsignedInputs(const PartiallySignedTransaction& psbt);

/** Updates a PSBTOutput with information from provider.
 *
 * This fills in the redeem_script, witness_script, and hd_keypaths where possible.
 */
void UpdatePSBTOutput(const SigningProvider& provider, PartiallySignedTransaction& psbt, int index);

/**
 * Finalizes a PSBT if possible, combining partial signatures.
 *
 * @param[in,out] psbtx PartiallySignedTransaction to finalize
 * return True if the PSBT is now complete, false otherwise
 */
bool FinalizePSBT(PartiallySignedTransaction& psbtx);

/**
 * Finalizes a PSBT if possible, and extracts it to a CMutableTransaction if it could be finalized.
 *
 * @param[in]  psbtx PartiallySignedTransaction
 * @param[out] result CMutableTransaction representing the complete transaction, if successful
 * @return True if we successfully extracted the transaction, false otherwise
 */
bool FinalizeAndExtractPSBT(PartiallySignedTransaction& psbtx, CMutableTransaction& result);

/**
 * Combines PSBTs with the same underlying transaction, resulting in a single PSBT with all partial signatures from each input.
 *
 * @param[out] out   the combined PSBT, if successful
 * @param[in]  psbtxs the PSBTs to combine
 * @return error (OK if we successfully combined the transactions, other error if they were not compatible)
 */
[[nodiscard]] TransactionError CombinePSBTs(PartiallySignedTransaction& out, const std::vector<PartiallySignedTransaction>& psbtxs);

//! Decode a base64ed PSBT into a PartiallySignedTransaction
[[nodiscard]] bool DecodeBase64PSBT(PartiallySignedTransaction& decoded_psbt, const std::string& base64_psbt, std::string& error);
//! Decode a raw (binary blob) PSBT into a PartiallySignedTransaction
[[nodiscard]] bool DecodeRawPSBT(PartiallySignedTransaction& decoded_psbt, Span<const std::byte> raw_psbt, std::string& error);

#endif // BITCOIN_PSBT_H


text:
/**
 * Returns an array of zeros
 */
export function zeros(size: number): Float32Array {
  return new Float32Array(size);
}


text:
namespace dart {

const intptr_t kSkipCount = 4;

}  // namespace dart

#endif  // defined(HOST_ARCH_ARM64)


text:
#ifndef MockContentFilter_h
#define MockContentFilter_h

#include "MockContentFilterSettings.h"
#include "PlatformContentFilter.h"

namespace WebCore {

class MockContentFilter final : public PlatformContentFilter {
    friend std::unique_ptr<MockContentFilter> std::make_unique<MockContentFilter>();

public:
    static void ensureInstalled();
    static std::unique_ptr<MockContentFilter> create();

    void willSendRequest(ResourceRequest&, const ResourceResponse&) override;
    void responseReceived(const ResourceResponse&) override;
    void addData(const char* data, int length) override;
    void finishedAddingData() override;
    Ref<SharedBuffer> replacementData() const override;
    ContentFilterUnblockHandler unblockHandler() const override;
    String unblockRequestDeniedScript() const override;

private:
    static bool enabled();

    MockContentFilter() = default;
    void maybeDetermineStatus(MockContentFilterSettings::DecisionPoint);

    Vector<char> m_replacementData;
};

} // namespace WebCore

#endif // MockContentFilter_h


text:
using namespace RISE;
using namespace RISE::Implementation;

GlobalSpectralPhotonMap::GlobalSpectralPhotonMap(
	const unsigned int max_photons,
	const IPhotonTracer* tracer
	) :
  PhotonMapDirectionalHelper<SpectralPhoton>( max_photons, tracer ),
  nm_range( 1.0 )
{
}

GlobalSpectralPhotonMap::~GlobalSpectralPhotonMap()
{
}

// Computes the radiance estimate at a given surface position
void GlobalSpectralPhotonMap::RadianceEstimate(
		RISEPel&				rad,							// returned radiance
		const RayIntersectionGeometric&	ri,						// ray-surface intersection information
		const IBSDF&			brdf							// BRDF of the surface to estimate irradiance from
		) const
{
	rad = RISEPel( 0, 0, 0 );

	// locate the nearest photons
	PhotonDistListType heap;
	LocatePhotons( ri.ptIntersection, dGatherRadius, nMaxPhotonsOnGather, heap, 0, vphotons.size()-1 );

	if( heap.size() > nMinPhotonsOnGather )
	{
		XYZPel	sumPel( 0, 0, 0 );

		// They haven't been sorted yet, since the list isn't full
		if( heap.size() < nMaxPhotonsOnGather ) {
			std::make_heap( heap.begin(), heap.end() );
		}

		const Scalar farthest_away = (heap.size()<nMaxPhotonsOnGather ? dGatherRadius : heap[0].distance);
		const Scalar maxNDist = farthest_away * dEllipseRatio;

		// Sum irradiance from all photons
		PhotonDistListType::const_iterator i, e;

		for( i=heap.begin(), e=heap.end(); i!=e; i++ )
		{
			const SpectralPhoton& p = (*i).element;

			// The photon dir call and following if can be omitted (for speed)
			// if the scene does not have any thin surfaces
			const Vector3 vec = Vector3Ops::mkVector3( p.ptPosition, ri.ptIntersection );
			const Scalar pcos = Vector3Ops::Dot( vec, ri.vNormal );

			if( (pcos < maxNDist) && (pcos > -maxNDist) ) {
				const Vector3 vPhotonDir = PhotonDir(p.theta,p.phi);
				if( Vector3Ops::Dot(vPhotonDir,ri.vNormal) > 0 ) {
					// Compute XYZ valye from spectra
					XYZPel thisNM( 0, 0, 0 );
					if( ColorUtils::XYZFromNM( thisNM, p.nm ) ) {
						sumPel = sumPel + (thisNM * p.power * XYZPel(brdf.value( vPhotonDir, ri  )));
					}
				}
			}
		}

		rad = RISEPel( sumPel ) * (1.0/(PI*farthest_away));
	}
}

// Computes the radiance estimate at a given surface position for the given wavelength
void GlobalSpectralPhotonMap::RadianceEstimateNM(
			const Scalar			nm,								// wavelength for the estimate
			Scalar&					rad,							// returned radiance for the particular wavelength
			const RayIntersectionGeometric&	ri,						// ray-surface intersection information
			const IBSDF&			brdf							// BRDF of the surface to estimate irradiance from
			) const
{
	rad = 0;

	// locate the nearest photons
	PhotonDistListType heap;
	LocatePhotons( ri.ptIntersection, dGatherRadius, nMaxPhotonsOnGather, heap, 0, vphotons.size()-1 );

	if( heap.size() > nMinPhotonsOnGather )
	{
		// They haven't been sorted yet, since the list isn't full
		if( heap.size() < nMaxPhotonsOnGather ) {
			std::make_heap( heap.begin(), heap.end() );
		}

		const Scalar farthest_away = (heap.size()<nMaxPhotonsOnGather ? dGatherRadius : heap[0].distance);
		const Scalar maxNDist = farthest_away * dEllipseRatio;

		// Sum irradiance from all photons
		PhotonDistListType::const_iterator i, e;

		for( i=heap.begin(), e=heap.end(); i!=e; i++ )
		{
			const SpectralPhoton& p = (*i).element;

			// The photon dir call and following if can be omitted (for speed)
			// if the scene does not have any thin surfaces
			const Vector3 vec = Vector3Ops::mkVector3( p.ptPosition, ri.ptIntersection );
			const Scalar pcos = Vector3Ops::Dot( vec, ri.vNormal );

			if( (pcos < maxNDist) && (pcos > -maxNDist) ) {
				const Vector3 vPhotonDir = PhotonDir(p.theta,p.phi);
				if( Vector3Ops::Dot(vPhotonDir,ri.vNormal) > 0 ) {
					// Only take samples that are within the range we want
					if( fabs(p.nm-nm) <= nm_range ) {
						rad += p.power * brdf.valueNM(vPhotonDir, ri, nm);
					}
				}
			}
		}

		rad /= PI*farthest_away;
	}
}

bool GlobalSpectralPhotonMap::Store( const Scalar power, const Scalar nm, const Point3& pos, const Vector3& dir )
{
	if( vphotons.size() > nMaxPhotons ) {
		return false;
	}

	SpectralPhoton p;

	p.ptPosition = pos;
	p.power = power;
	p.nm = nm;

	int theta = int( acos( dir.z ) * (256.0 / PI) );
	theta = theta > 255 ? 255 : theta;
	p.theta = (unsigned char)(theta);

	int phi = int( atan2( dir.y, dir.x ) * (256.0/TWO_PI) );
	phi = phi > 255 ? 255 : phi;
	phi = phi < 0 ? phi+256 : phi;

	p.phi = (unsigned char)(phi);

	bbox.Include( p.ptPosition );
	vphotons.push_back( p );
	maxPower = r_max( maxPower, power );

	return true;
}

void GlobalSpectralPhotonMap::Serialize(
	IWriteBuffer&			buffer					///< [in] Buffer to serialize to
	) const
{
	buffer.ResizeForMore( sizeof( unsigned int ) * 4 + sizeof( Scalar ) * 3 );

	buffer.setUInt( nMaxPhotons );
	buffer.setUInt( nPrevScale );
	buffer.setDouble( dGatherRadius );
	buffer.setDouble( dEllipseRatio );
	buffer.setUInt( nMinPhotonsOnGather );
	buffer.setUInt( nMaxPhotonsOnGather );
	buffer.setDouble( maxPower );

	// Serialize the bounding box
	bbox.Serialize( buffer );

	// Serialize number of stored photons
	buffer.ResizeForMore( sizeof( unsigned int ) + sizeof( SpectralPhoton ) * vphotons.size() );
	buffer.setUInt( vphotons.size() );

	for( unsigned int i=0; i<vphotons.size(); i++ ) {
		const SpectralPhoton& p = vphotons[i];
		Point3Ops::Serialize( p.ptPosition, buffer );
		buffer.setUChar( p.plane );
		buffer.setDouble( p.power );
		buffer.setUChar( p.theta );
		buffer.setUChar( p.phi );
		buffer.setDouble( p.nm );
	}
}

void GlobalSpectralPhotonMap::Deserialize(
	IReadBuffer&			buffer					///< [in] Buffer to deserialize from
	)
{
	nMaxPhotons = buffer.getUInt();
	nPrevScale = buffer.getUInt();
	dGatherRadius = buffer.getDouble();
	dEllipseRatio = buffer.getDouble();
	nMinPhotonsOnGather = buffer.getUInt();
	nMaxPhotonsOnGather = buffer.getUInt();
	maxPower = buffer.getDouble();

	bbox.Deserialize( buffer );

	const unsigned int numphot = buffer.getUInt();
	vphotons.reserve( numphot );

	for( unsigned int i=0; i<numphot; i++ ) {
		SpectralPhoton p;
		Point3Ops::Deserialize( p.ptPosition, buffer );
		p.plane = buffer.getUChar();
		p.power = buffer.getDouble();
		p.theta = buffer.getUChar();
		p.phi = buffer.getUChar();
		p.nm = buffer.getDouble();
		vphotons.push_back( p );
	}
}


text:
#ifndef _ACOMPORTCONSTANTS_H_
#define _ACOMPORTCONSTANTS_H_

// Parity codes

#define acPARITY_NONE							 0	// No parity bits
#define acPARITY_ODD							 1	// Odd parity
#define acPARITY_EVEN							 2	// Even parity bits
#define acPARITY_MARK							 3	// Mark parity
#define acPARITY_SPACE							 4	// Space parity

// Stopbit codes

#define acSTOPBITS_1							 1	// 1 bit stop bit (default)
#define acSTOPBITS_2							 2	// 2 bit stop bit
#define acSTOPBITS_15							15	// 1.5 bit parity

// Error codes

#define acERR_SUCCESS							 0  // Success.
#define acERR_EVALUATIONEXPIRED					 1  // Evaluation period has expired
#define acERR_INVALIDLICENSE					 2	// Registration code is invalid.

#define acERR_GENERICERROR					   100	// Generic port Error
#define acERR_INVALIDPARAM					   101	// Invalid port parameter
#define acERR_INVALIDPORT					   102	// Invalid port. Most probably, port does not exist or is in use
#define acERR_PORTALREADYOPENED				   103	// Unable to perform operation because port it already opened
#define acERR_OPENPORTFAILED				   104	// Generic open port error
#define acERR_INITIALIZEPORTFAILED			   105	// Unable to initialize port
#define acERR_WRITEPORTFAILED				   106	// Unable to write to port
#define acERR_WRITEPORTDIRECTFAILED			   107	// Unable to write directly to port
#define acERR_READPORTFAILED				   108	// Unable to read from port
#define acERR_GETCOMSTATEFAILED				   109	// Unable to retrieve device information
#define acERR_SETCOMSTATEFAILED				   110	// Unable to change device settings
#define acERR_PURGECOMFAILED			       111	// Unable to purge the port
#define acERR_TIMEOUT						   112	// Port timeout

#endif	// _ACOMPORTCONSTANTS_H_


text:
"""
This module contains the methods for the ``openxc-dump`` command line program.

`main` is executed when ``openxc-dump`` is run, and all other callables in this
module are internal only.
"""

import argparse
import time
import logging
import sys

from openxc.formats.json import JsonFormatter
from .common import device_options, configure_logging, select_device

import functools
print = functools.partial(print, flush=True)

def receive(message, **kwargs):
    message['timestamp'] = time.time()
    print((JsonFormatter.serialize(message)))

def parse_options():
    parser = argparse.ArgumentParser(
            description="View a raw OpenXC data stream",
            parents=[device_options()])

    arguments = parser.parse_args()
    return arguments

def main():
    try:
        configure_logging(logging.DEBUG)
        arguments = parse_options()
        source_class, source_kwargs = select_device(arguments)
        source = source_class(callback=receive, **source_kwargs)
        source.start()
        # TODO test this, I'd prefer it to the sleep loop
        while(True):
            source.join(0.1)
    except KeyboardInterrupt:
        sys.exit(0)


text:
<!DOCTYPE html>

    <meta charset="UTF-8" />
    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
    <meta http-equiv="X-UA-Compatible" content="ie=edge" />
    <title>Code Editor</title>
    <link rel="stylesheet" href="./reset.css" />
    <link rel="stylesheet" href="./style.css" />

1 index.html

2 reset.css

3 script.js

4 style.css

      <button class="hide">-</button>

    <button class="show">+</button>


text:
""" Implementation of class Type. """

class Type:

    def __init__(self):
        self.width = 32
        self.isSigned = True
        self.isFloat = False