@neo-one/node-core/transaction/ClaimTransaction.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const client_common_1 = require("@neo-one/client-common");
const errors_1 = require("../errors");
const utils_1 = require("../utils");
const common_1 = require("./common");
const Input_1 = require("./Input");
const TransactionBase_1 = require("./TransactionBase");
const TransactionType_1 = require("./TransactionType");
class ClaimTransaction extends TransactionBase_1.TransactionBase(client_common_1.ClaimTransactionModel) {
    constructor(add) {
        super(add);
        this.sizeExclusive = utils_1.utils.lazy(() => client_common_1.IOHelper.sizeOfUInt8 + client_common_1.IOHelper.sizeOfArray(this.claims, (claim) => claim.size));
        const getScriptHashesForVerifying = super.getScriptHashesForVerifying.bind(this);
        this.claimGetScriptHashesForVerifyingInternal = utils_1.utils.lazyAsync(async (options) => {
            const { getOutput } = options;
            const [hashesSet, hashes] = await Promise.all([
                getScriptHashesForVerifying(options),
                Promise.all(this.claims.map(async (claim) => {
                    const output = await getOutput(claim);
                    return client_common_1.common.uInt160ToHex(output.address);
                })),
            ]);
            return new Set([...hashesSet, ...hashes]);
        });
    }
    static deserializeWireBase(options) {
        const { reader } = options;
        const { type, version } = super.deserializeTransactionBaseStartWireBase(options);
        if (type !== TransactionType_1.TransactionType.Claim) {
            throw new client_common_1.InvalidFormatError(`Expected transaction type to be ${TransactionType_1.TransactionType.Claim}. Received: ${type}`);
        }
        const claims = reader.readArray(() => Input_1.Input.deserializeWireBase(options));
        const { attributes, inputs, outputs, scripts } = super.deserializeTransactionBaseEndWireBase(options);
        return new this({
            version,
            claims,
            attributes,
            inputs,
            outputs,
            scripts,
        });
    }
    async getNetworkFee(_context) {
        return utils_1.utils.ZERO;
    }
    async getClaimReferences({ getOutput }) {
        return Promise.all(this.claims.map(async (input) => getOutput(input)));
    }
    async getScriptHashesForVerifying(options) {
        return this.claimGetScriptHashesForVerifyingInternal(options);
    }
    async verify(options) {
        const [results] = await Promise.all([super.verify(options), this.verifyInternal(options)]);
        return results;
    }
    async serializeJSON(context) {
        const transactionBaseJSON = await super.serializeTransactionBaseJSON(context);
        return Object.assign(Object.assign({}, transactionBaseJSON), { type: 'ClaimTransaction', claims: this.claims.map((claim) => claim.serializeJSON(context)) });
    }
    async verifyInternal(options) {
        const { calculateClaimAmount, getOutput, utilityToken, memPool = [] } = options;
        if (common_1.hasDuplicateInputs(this.claims)) {
            throw new errors_1.VerifyError('Duplicate claims');
        }
        if (memPool.some((transaction) => transaction instanceof ClaimTransaction &&
            transaction.type === TransactionType_1.TransactionType.Claim &&
            common_1.hasIntersectingInputs(this.claims, transaction.claims))) {
            throw new errors_1.VerifyError('Duplicate claims in mempool');
        }
        const [results, claimAmount] = await Promise.all([
            this.getTransactionResults({ getOutput }),
            calculateClaimAmount(this.claims).catch((error) => {
                throw new errors_1.VerifyError(`Invalid claims: ${error.message}`);
            }),
        ]);
        const result = Object.entries(results).find(([assetHex, _value]) => client_common_1.common.uInt256Equal(client_common_1.common.hexToUInt256(assetHex), utilityToken.hash));
        if (result === undefined || result[1].gt(utils_1.utils.ZERO)) {
            throw new errors_1.VerifyError('Invalid claim value');
        }
        if (!claimAmount.eq(result[1].neg())) {
            throw new errors_1.VerifyError('Invalid claim value');
        }
    }
}
exports.ClaimTransaction = ClaimTransaction;

//# sourceMappingURL=ClaimTransaction.js.map