Osmosis MCP Server

"use strict"; Object.defineProperty(exports, "__esModule", { value: true }); exports.encodeBech32Pubkey = exports.encodeAminoPubkey = exports.decodeBech32Pubkey = exports.decodeAminoPubkey = exports.encodeEd25519Pubkey = exports.encodeSecp256k1Pubkey = void 0; const encoding_1 = require("@cosmjs/encoding"); const math_1 = require("@cosmjs/math"); const utils_1 = require("@cosmjs/utils"); const pubkeys_1 = require("./pubkeys"); /** * Takes a Secp256k1 public key as raw bytes and returns the Amino JSON * representation of it (the type/value wrapper object). */ function encodeSecp256k1Pubkey(pubkey) { if (pubkey.length !== 33 || (pubkey[0] !== 0x02 && pubkey[0] !== 0x03)) { throw new Error("Public key must be compressed secp256k1, i.e. 33 bytes starting with 0x02 or 0x03"); } return { type: pubkeys_1.pubkeyType.secp256k1, value: (0, encoding_1.toBase64)(pubkey), }; } exports.encodeSecp256k1Pubkey = encodeSecp256k1Pubkey; /** * Takes an Edd25519 public key as raw bytes and returns the Amino JSON * representation of it (the type/value wrapper object). */ function encodeEd25519Pubkey(pubkey) { if (pubkey.length !== 32) { throw new Error("Ed25519 public key must be 32 bytes long"); } return { type: pubkeys_1.pubkeyType.ed25519, value: (0, encoding_1.toBase64)(pubkey), }; } exports.encodeEd25519Pubkey = encodeEd25519Pubkey; // As discussed in https://github.com/binance-chain/javascript-sdk/issues/163 // Prefixes listed here: https://github.com/tendermint/tendermint/blob/d419fffe18531317c28c29a292ad7d253f6cafdf/docs/spec/blockchain/encoding.md#public-key-cryptography // Last bytes is varint-encoded length prefix const pubkeyAminoPrefixSecp256k1 = (0, encoding_1.fromHex)("eb5ae987" + "21" /* fixed length */); const pubkeyAminoPrefixEd25519 = (0, encoding_1.fromHex)("1624de64" + "20" /* fixed length */); const pubkeyAminoPrefixSr25519 = (0, encoding_1.fromHex)("0dfb1005" + "20" /* fixed length */); /** See https://github.com/tendermint/tendermint/commit/38b401657e4ad7a7eeb3c30a3cbf512037df3740 */ const pubkeyAminoPrefixMultisigThreshold = (0, encoding_1.fromHex)("22c1f7e2" /* variable length not included */); /** * Decodes a pubkey in the Amino binary format to a type/value object. */ function decodeAminoPubkey(data) { if ((0, utils_1.arrayContentStartsWith)(data, pubkeyAminoPrefixSecp256k1)) { const rest = data.slice(pubkeyAminoPrefixSecp256k1.length); if (rest.length !== 33) { throw new Error("Invalid rest data length. Expected 33 bytes (compressed secp256k1 pubkey)."); } return { type: pubkeys_1.pubkeyType.secp256k1, value: (0, encoding_1.toBase64)(rest), }; } else if ((0, utils_1.arrayContentStartsWith)(data, pubkeyAminoPrefixEd25519)) { const rest = data.slice(pubkeyAminoPrefixEd25519.length); if (rest.length !== 32) { throw new Error("Invalid rest data length. Expected 32 bytes (Ed25519 pubkey)."); } return { type: pubkeys_1.pubkeyType.ed25519, value: (0, encoding_1.toBase64)(rest), }; } else if ((0, utils_1.arrayContentStartsWith)(data, pubkeyAminoPrefixSr25519)) { const rest = data.slice(pubkeyAminoPrefixSr25519.length); if (rest.length !== 32) { throw new Error("Invalid rest data length. Expected 32 bytes (Sr25519 pubkey)."); } return { type: pubkeys_1.pubkeyType.sr25519, value: (0, encoding_1.toBase64)(rest), }; } else if ((0, utils_1.arrayContentStartsWith)(data, pubkeyAminoPrefixMultisigThreshold)) { // eslint-disable-next-line @typescript-eslint/no-use-before-define return decodeMultisigPubkey(data); } else { throw new Error("Unsupported public key type. Amino data starts with: " + (0, encoding_1.toHex)(data.slice(0, 5))); } } exports.decodeAminoPubkey = decodeAminoPubkey; /** * Decodes a bech32 pubkey to Amino binary, which is then decoded to a type/value object. * The bech32 prefix is ignored and discareded. * * @param bechEncoded the bech32 encoded pubkey */ function decodeBech32Pubkey(bechEncoded) { const { data } = (0, encoding_1.fromBech32)(bechEncoded); return decodeAminoPubkey(data); } exports.decodeBech32Pubkey = decodeBech32Pubkey; /** * Uvarint decoder for Amino. * @see https://github.com/tendermint/go-amino/blob/8e779b71f40d175/decoder.go#L64-76 * @returns varint as number, and bytes count occupied by varaint */ function decodeUvarint(reader) { if (reader.length < 1) { throw new Error("Can't decode varint. EOF"); } if (reader[0] > 127) { throw new Error("Decoding numbers > 127 is not supported here. Please tell those lazy CosmJS maintainers to port the binary.Varint implementation from the Go standard library and write some tests."); } return [reader[0], 1]; } /** * Decodes a multisig pubkey to type object. * Pubkey structure [ prefix + const + threshold + loop:(const + pubkeyLength + pubkey ) ] * [ 4b + 1b + varint + loop:(1b + varint + pubkeyLength bytes) ] * @param data encoded pubkey */ function decodeMultisigPubkey(data) { const reader = Array.from(data); // remove multisig amino prefix; const prefixFromReader = reader.splice(0, pubkeyAminoPrefixMultisigThreshold.length); if (!(0, utils_1.arrayContentStartsWith)(prefixFromReader, pubkeyAminoPrefixMultisigThreshold)) { throw new Error("Invalid multisig prefix."); } // remove 0x08 threshold prefix; if (reader.shift() != 0x08) { throw new Error("Invalid multisig data. Expecting 0x08 prefix before threshold."); } // read threshold const [threshold, thresholdBytesLength] = decodeUvarint(reader); reader.splice(0, thresholdBytesLength); // read participants pubkeys const pubkeys = []; while (reader.length > 0) { // remove 0x12 threshold prefix; if (reader.shift() != 0x12) { throw new Error("Invalid multisig data. Expecting 0x12 prefix before participant pubkey length."); } // read pubkey length const [pubkeyLength, pubkeyLengthBytesSize] = decodeUvarint(reader); reader.splice(0, pubkeyLengthBytesSize); // verify that we can read pubkey if (reader.length < pubkeyLength) { throw new Error("Invalid multisig data length."); } // read and decode participant pubkey const encodedPubkey = reader.splice(0, pubkeyLength); const pubkey = decodeAminoPubkey(Uint8Array.from(encodedPubkey)); pubkeys.push(pubkey); } return { type: pubkeys_1.pubkeyType.multisigThreshold, value: { threshold: threshold.toString(), pubkeys: pubkeys, }, }; } /** * Uvarint encoder for Amino. This is the same encoding as `binary.PutUvarint` from the Go * standard library. * * @see https://github.com/tendermint/go-amino/blob/8e779b71f40d175/encoder.go#L77-L85 */ function encodeUvarint(value) { const checked = math_1.Uint53.fromString(value.toString()).toNumber(); if (checked > 127) { throw new Error("Encoding numbers > 127 is not supported here. Please tell those lazy CosmJS maintainers to port the binary.PutUvarint implementation from the Go standard library and write some tests."); } return [checked]; } /** * Encodes a public key to binary Amino. */ function encodeAminoPubkey(pubkey) { if ((0, pubkeys_1.isMultisigThresholdPubkey)(pubkey)) { const out = Array.from(pubkeyAminoPrefixMultisigThreshold); out.push(0x08); // TODO: What is this? out.push(...encodeUvarint(pubkey.value.threshold)); for (const pubkeyData of pubkey.value.pubkeys.map((p) => encodeAminoPubkey(p))) { out.push(0x12); // TODO: What is this? out.push(...encodeUvarint(pubkeyData.length)); out.push(...pubkeyData); } return new Uint8Array(out); } else if ((0, pubkeys_1.isEd25519Pubkey)(pubkey)) { return new Uint8Array([...pubkeyAminoPrefixEd25519, ...(0, encoding_1.fromBase64)(pubkey.value)]); } else if ((0, pubkeys_1.isSecp256k1Pubkey)(pubkey)) { return new Uint8Array([...pubkeyAminoPrefixSecp256k1, ...(0, encoding_1.fromBase64)(pubkey.value)]); } else { throw new Error("Unsupported pubkey type"); } } exports.encodeAminoPubkey = encodeAminoPubkey; /** * Encodes a public key to binary Amino and then to bech32. * * @param pubkey the public key to encode * @param prefix the bech32 prefix (human readable part) */ function encodeBech32Pubkey(pubkey, prefix) { return (0, encoding_1.toBech32)(prefix, encodeAminoPubkey(pubkey)); } exports.encodeBech32Pubkey = encodeBech32Pubkey; //# sourceMappingURL=encoding.js.map