mirror of
https://github.com/Permissionless-Software-Foundation/psf-memo.git
synced 2026-09-21 16:52:01 -07:00
Chris Troutner
2e2db86263
Reply, topic message, add-poll-option, poll-vote, and create-poll now broadcast each protocol field as its own OP_RETURN script push instead of combining them into one push. The indexer requires three pushes for reply, topic message, and poll children, and accepts four for create-poll; the combined form was rejected or misparsed. hex.js builds the txid and text as separate pushes, and a new memo-multipush adapter teaches minimal-slp-wallet's single-push sendOpReturn to expand an array of fields into separate pushes. Acceptance step handlers assert the individual pushes, and unit/property tests cover the new shape. By coder.
129 lines
3.8 KiB
JavaScript
129 lines
3.8 KiB
JavaScript
/*
|
|
Unit tests for the Memo topic message behavior.
|
|
|
|
A topic message combines the topic name and message text, then broadcasts
|
|
it with the Memo topic-message prefix (0x6d0c). The combined topic + message
|
|
must not exceed 214 bytes.
|
|
*/
|
|
|
|
'use strict'
|
|
|
|
const test = require('node:test')
|
|
const assert = require('node:assert/strict')
|
|
const MemoTopicPost = require('../../src/services/memo-topic-post')
|
|
|
|
function makeWallet (address = 'bitcoincash:qqlrzp23w08434twmvr4fxw672whkjy0py26r63g3d') {
|
|
return {
|
|
walletInfo: { cashAddress: address },
|
|
broadcasts: [],
|
|
async getUtxos () {
|
|
return []
|
|
},
|
|
async sendOpReturn (msg, prefix) {
|
|
this.broadcasts.push({ msg, prefix })
|
|
return 'aa'.repeat(32)
|
|
}
|
|
}
|
|
}
|
|
|
|
test('post broadcasts topic name and message as separate pushes', async () => {
|
|
const wallet = makeWallet()
|
|
const memoTopicPost = new MemoTopicPost({ wallet, room: 'bitcoin' })
|
|
|
|
await memoTopicPost.post('hello bitcoin')
|
|
|
|
assert.equal(wallet.broadcasts.length, 1)
|
|
assert.equal(wallet.broadcasts[0].prefix, MemoTopicPost.MEMO_TOPIC_MESSAGE_PREFIX)
|
|
const pushes = wallet.broadcasts[0].msg
|
|
assert.ok(Array.isArray(pushes), 'expected separate pushes')
|
|
assert.equal(pushes.length, 2)
|
|
assert.equal(Buffer.from(pushes[0]).toString('utf8'), 'bitcoin')
|
|
assert.equal(Buffer.from(pushes[1]).toString('utf8'), 'hello bitcoin')
|
|
})
|
|
|
|
test('post reflects the new topic post on the injected feed', async () => {
|
|
const wallet = makeWallet()
|
|
const added = []
|
|
const feed = {
|
|
addPost (post) {
|
|
added.push(post)
|
|
}
|
|
}
|
|
const memoTopicPost = new MemoTopicPost({ wallet, room: 'cash', feed })
|
|
|
|
await memoTopicPost.post('hello cash')
|
|
|
|
assert.equal(added.length, 1)
|
|
assert.equal(added[0].text, 'hello cash')
|
|
assert.equal(added[0].room, 'cash')
|
|
assert.equal(added[0].address, wallet.walletInfo.cashAddress)
|
|
})
|
|
|
|
test('post rejects an empty message', async () => {
|
|
const wallet = makeWallet()
|
|
const memoTopicPost = new MemoTopicPost({ wallet, room: 'bitcoin' })
|
|
|
|
await assert.rejects(
|
|
() => memoTopicPost.post(''),
|
|
{ code: 'topic_post_validation', message: /must not be empty/ }
|
|
)
|
|
assert.equal(wallet.broadcasts.length, 0)
|
|
})
|
|
|
|
test('post rejects a message that exceeds the combined byte limit', async () => {
|
|
const wallet = makeWallet()
|
|
const memoTopicPost = new MemoTopicPost({ wallet, room: 'bitcoin' })
|
|
// "bitcoin" is 7 bytes; 214 - 7 = 207. Use 208 ASCII 'a' characters.
|
|
const message = 'a'.repeat(208)
|
|
|
|
await assert.rejects(
|
|
() => memoTopicPost.post(message),
|
|
{ code: 'topic_post_length', message: /too long/ }
|
|
)
|
|
assert.equal(wallet.broadcasts.length, 0)
|
|
})
|
|
|
|
test('post accepts a message at the combined byte limit', async () => {
|
|
const wallet = makeWallet()
|
|
const memoTopicPost = new MemoTopicPost({ wallet, room: 'bitcoin' })
|
|
const message = 'a'.repeat(207)
|
|
|
|
await memoTopicPost.post(message)
|
|
|
|
assert.equal(wallet.broadcasts.length, 1)
|
|
})
|
|
|
|
test('remainingBytes accounts for the topic name', () => {
|
|
const memoTopicPost = new MemoTopicPost({ room: 'bitcoin' })
|
|
|
|
assert.equal(memoTopicPost.remainingBytes(''), 207)
|
|
assert.equal(memoTopicPost.remainingBytes('hello'), 202)
|
|
})
|
|
|
|
test('remainingBytes counts UTF-8 bytes', () => {
|
|
const memoTopicPost = new MemoTopicPost({ room: 'bitcoin' })
|
|
|
|
// 'é' is 2 UTF-8 bytes.
|
|
assert.equal(memoTopicPost.remainingBytes('é'), 205)
|
|
})
|
|
|
|
test('post requires a wallet', async () => {
|
|
const memoTopicPost = new MemoTopicPost({ room: 'bitcoin' })
|
|
|
|
await assert.rejects(
|
|
() => memoTopicPost.post('hello'),
|
|
/requires a wallet/
|
|
)
|
|
})
|
|
|
|
test('post surfaces a broadcast failure', async () => {
|
|
const wallet = makeWallet()
|
|
wallet.sendOpReturn = async () => { throw new Error('broadcast failed') }
|
|
const memoTopicPost = new MemoTopicPost({ wallet, room: 'bitcoin' })
|
|
|
|
await assert.rejects(
|
|
() => memoTopicPost.post('hello'),
|
|
/broadcast failed/
|
|
)
|
|
})
|