Michael Freno
7c684a42cc
- Consolidated duplicate UndoManagers to single instance - Fixed connection promise to only resolve on 'connected' status - Fixed WebSocketProvider import (WebsocketProvider) - Added proper doc.destroy() cleanup - Renamed isPresenceInitialized property to avoid conflict Co-Authored-By: Paperclip <noreply@paperclip.ing>
115 lines
3.0 KiB
TypeScript
115 lines
3.0 KiB
TypeScript
import {
|
|
bytesPerBlob,
|
|
bytesPerFieldElement,
|
|
fieldElementsPerBlob,
|
|
maxBytesPerTransaction,
|
|
} from '../../constants/blob.js'
|
|
import {
|
|
BlobSizeTooLargeError,
|
|
type BlobSizeTooLargeErrorType,
|
|
EmptyBlobError,
|
|
type EmptyBlobErrorType,
|
|
} from '../../errors/blob.js'
|
|
import type { ErrorType } from '../../errors/utils.js'
|
|
import type { ByteArray, Hex } from '../../types/misc.js'
|
|
import { type CreateCursorErrorType, createCursor } from '../cursor.js'
|
|
import { type SizeErrorType, size } from '../data/size.js'
|
|
import { type HexToBytesErrorType, hexToBytes } from '../encoding/toBytes.js'
|
|
import { type BytesToHexErrorType, bytesToHex } from '../encoding/toHex.js'
|
|
|
|
type To = 'hex' | 'bytes'
|
|
|
|
export type ToBlobsParameters<
|
|
data extends Hex | ByteArray = Hex | ByteArray,
|
|
to extends To | undefined = undefined,
|
|
> = {
|
|
/** Data to transform to a blob. */
|
|
data: data | Hex | ByteArray
|
|
/** Return type. */
|
|
to?: to | To | undefined
|
|
}
|
|
|
|
export type ToBlobsReturnType<to extends To> =
|
|
| (to extends 'bytes' ? readonly ByteArray[] : never)
|
|
| (to extends 'hex' ? readonly Hex[] : never)
|
|
|
|
export type ToBlobsErrorType =
|
|
| BlobSizeTooLargeErrorType
|
|
| BytesToHexErrorType
|
|
| CreateCursorErrorType
|
|
| EmptyBlobErrorType
|
|
| HexToBytesErrorType
|
|
| SizeErrorType
|
|
| ErrorType
|
|
|
|
/**
|
|
* Transforms arbitrary data to blobs.
|
|
*
|
|
* @example
|
|
* ```ts
|
|
* import { toBlobs, stringToHex } from 'viem'
|
|
*
|
|
* const blobs = toBlobs({ data: stringToHex('hello world') })
|
|
* ```
|
|
*/
|
|
export function toBlobs<
|
|
const data extends Hex | ByteArray,
|
|
to extends To =
|
|
| (data extends Hex ? 'hex' : never)
|
|
| (data extends ByteArray ? 'bytes' : never),
|
|
>(parameters: ToBlobsParameters<data, to>): ToBlobsReturnType<to> {
|
|
const to =
|
|
parameters.to ?? (typeof parameters.data === 'string' ? 'hex' : 'bytes')
|
|
const data = (
|
|
typeof parameters.data === 'string'
|
|
? hexToBytes(parameters.data)
|
|
: parameters.data
|
|
) as ByteArray
|
|
|
|
const size_ = size(data)
|
|
if (!size_) throw new EmptyBlobError()
|
|
if (size_ > maxBytesPerTransaction)
|
|
throw new BlobSizeTooLargeError({
|
|
maxSize: maxBytesPerTransaction,
|
|
size: size_,
|
|
})
|
|
|
|
const blobs = []
|
|
|
|
let active = true
|
|
let position = 0
|
|
while (active) {
|
|
const blob = createCursor(new Uint8Array(bytesPerBlob))
|
|
|
|
let size = 0
|
|
while (size < fieldElementsPerBlob) {
|
|
const bytes = data.slice(position, position + (bytesPerFieldElement - 1))
|
|
|
|
// Push a zero byte so the field element doesn't overflow the BLS modulus.
|
|
blob.pushByte(0x00)
|
|
|
|
// Push the current segment of data bytes.
|
|
blob.pushBytes(bytes)
|
|
|
|
// If we detect that the current segment of data bytes is less than 31 bytes,
|
|
// we can stop processing and push a terminator byte to indicate the end of the blob.
|
|
if (bytes.length < 31) {
|
|
blob.pushByte(0x80)
|
|
active = false
|
|
break
|
|
}
|
|
|
|
size++
|
|
position += 31
|
|
}
|
|
|
|
blobs.push(blob)
|
|
}
|
|
|
|
return (
|
|
to === 'bytes'
|
|
? blobs.map((x) => x.bytes)
|
|
: blobs.map((x) => bytesToHex(x.bytes))
|
|
) as any
|
|
}
|