|
1 |
| -const RAAM = require('../lib/raam') |
2 |
| -const prettify = require('../lib/helpers').prettify |
3 |
| -const RAAMReader = require('../lib/raamReader') |
4 |
| -const converter = require("@iota/converter") |
| 1 | +const RAAM = require('../lib/raam'); |
| 2 | +const prettify = require('../lib/helpers').prettify; |
| 3 | +const RAAMReader = require('../lib/raamReader'); |
| 4 | +const converter = require('@iota/converter'); |
5 | 5 | const iota = require('@iota/core').composeAPI({
|
6 |
| - provider: 'https://node.deviceproof.org' |
| 6 | + provider: 'https://node.deviceproof.org', |
7 | 7 | });
|
8 | 8 |
|
9 | 9 | (async () => {
|
10 |
| - try { |
11 |
| - const seed = generateSeed() |
12 |
| - console.log("Seed:", seed) |
13 |
| - const raam = await RAAM.fromSeed(seed, {amount: 4, iota, security: 2, channelPassword: "PASSWORD"}) |
14 |
| - console.log("Channel root:", converter.trytes(raam.channelRoot)) |
| 10 | + try { |
| 11 | + const seed = generateSeed(); |
| 12 | + console.log('Seed:', seed); |
| 13 | + const raam = await RAAM.fromSeed(seed, { |
| 14 | + amount: 4, iota, security: 2, channelPassword: 'PASSWORD', |
| 15 | + }); |
| 16 | + console.log('Channel root:', converter.trytes(raam.channelRoot)); |
15 | 17 |
|
16 |
| - console.log("Generated RAAM channel. Reading channel...") |
17 |
| - const {messages, errors} = await raam.syncChannel({ |
18 |
| - callback: (err, m) => { |
19 |
| - if (err) { |
20 |
| - console.error(err) |
21 |
| - } |
22 |
| - } |
23 |
| - }) |
24 |
| - errors.forEach(e => console.error(e)) |
25 |
| - console.log("Cursor:", raam.cursor) |
26 |
| - console.log("Messages:", messages) |
| 18 | + console.log('Generated RAAM channel. Reading channel...'); |
| 19 | + const { messages, errors } = await raam.syncChannel({ |
| 20 | + callback: (err, m) => { |
| 21 | + if (err) { |
| 22 | + console.error(err); |
| 23 | + } |
| 24 | + }, |
| 25 | + }); |
| 26 | + errors.forEach(e => console.error(e)); |
| 27 | + console.log('Cursor:', raam.cursor); |
| 28 | + console.log('Messages:', messages); |
27 | 29 |
|
28 |
| - console.log("Creating 2 messages...") |
29 |
| - const mt1 = raam.createMessageTransfers("HELLOIOTA") |
30 |
| - console.log("MessageTransfers 1:", { |
31 |
| - message: prettify(mt1.message), |
32 |
| - transfers: mt1.transfers |
33 |
| - }) |
34 |
| - const mt2 = raam.createMessageTransfers("", {index: 3}) |
| 30 | + console.log('Creating 2 messages...'); |
| 31 | + const mt1 = raam.createMessageTransfers('HELLOIOTA'); |
| 32 | + console.log('MessageTransfers 1:', { |
| 33 | + message: prettify(mt1.message), |
| 34 | + transfers: mt1.transfers, |
| 35 | + }); |
| 36 | + const mt2 = raam.createMessageTransfers('', { index: 3 }); |
35 | 37 |
|
36 |
| - let response = await raam.fetch({end: 3}) |
37 |
| - response.errors.forEach(e => console.error(e)) |
38 |
| - console.log("Published Messages:", response.messages) |
| 38 | + let response = await raam.fetch({ end: 3 }); |
| 39 | + response.errors.forEach(e => console.error(e)); |
| 40 | + console.log('Published Messages:', response.messages); |
39 | 41 |
|
40 |
| - console.log("Publishing created messages...") |
41 |
| - // if optional parameter message is passed, message is stored locally after publishing |
42 |
| - console.log("Bundle 1:", (await raam.publishMessageTransfers(mt1.transfers, {message: mt1.message}))[0].bundle) |
43 |
| - console.log("Bundle 2:", (await raam.publishMessageTransfers(mt2.transfers, {message: mt2.message}))[0].bundle) |
| 42 | + console.log('Publishing created messages...'); |
| 43 | + // if optional parameter message is passed, message is stored locally after publishing |
| 44 | + console.log('Bundle 1:', (await raam.publishMessageTransfers(mt1.transfers, { message: mt1.message }))[0].bundle); |
| 45 | + console.log('Bundle 2:', (await raam.publishMessageTransfers(mt2.transfers, { message: mt2.message }))[0].bundle); |
44 | 46 |
|
45 |
| - const reader = new RAAMReader(raam.channelRoot, {iota, channelPassword: "PASSWORD"}) |
46 |
| - response = await reader.fetch({end: 3}) |
47 |
| - response.errors.forEach(e => console.error(e)) |
48 |
| - console.log("Messages:", response.messages) |
49 |
| - } catch(e) { |
50 |
| - console.error(e) |
51 |
| - } |
52 |
| -})() |
| 47 | + const reader = new RAAMReader(raam.channelRoot, { iota, channelPassword: 'PASSWORD' }); |
| 48 | + response = await reader.fetch({ end: 3 }); |
| 49 | + response.errors.forEach(e => console.error(e)); |
| 50 | + console.log('Messages:', response.messages); |
| 51 | + } catch (e) { |
| 52 | + console.error(e); |
| 53 | + } |
| 54 | +})(); |
53 | 55 |
|
54 | 56 | function generateSeed(length = 81) {
|
55 |
| - const charset = "ABCDEFGHIJKLMNOPQRSTUVWXYZ9"; |
56 |
| - let retVal = [81]; |
57 |
| - for (let i = 0, n = charset.length; i < length; ++i) { |
58 |
| - retVal[i] = charset.charAt(Math.floor(Math.random() * n)); |
59 |
| - } |
60 |
| - let result = retVal.join("") |
61 |
| - return result; |
| 57 | + const charset = 'ABCDEFGHIJKLMNOPQRSTUVWXYZ9'; |
| 58 | + const retVal = [81]; |
| 59 | + for (let i = 0, n = charset.length; i < length; ++i) { |
| 60 | + retVal[i] = charset.charAt(Math.floor(Math.random() * n)); |
| 61 | + } |
| 62 | + const result = retVal.join(''); |
| 63 | + return result; |
62 | 64 | }
|
0 commit comments