웹 수익 창출로의 여정 - 3일차

npm init -y
npm i -S ilp-protocol-stream ilp-plugin @interledger/connection-tag-utils
mkdir src
touch src/index.js

// src/index.js
const { randomBytes } = require("crypto");
const { createServer, createConnection } = require("ilp-protocol-stream");
const { encode, decode } = require("@interledger/connection-tag-utils");
const createPlugin = require("ilp-plugin");

// Used for encoding and decoding connectionTag
const SECRET_KEY = randomBytes(32);

async function createStreamServer() {
  const server = await createServer({ plugin: createPlugin() });
  server.on("connection", (connection) => {
    // connectionTag contains encrypted data, in this case about the user account
    const { account } = JSON.parse(
      decode(SECRET_KEY, connection.connectionTag)
    );
    connection.on("stream", (stream) => {
      stream.setReceiveMax(10000);
      stream.on("money", (amount) => {
        console.log(`Received payment from ${account} for: ${amount}`);
      });
    });
  });

  return server;
}

async function sendMoney({ amount, destinationAccount, sharedSecret }) {
  const connection = await createConnection({
    plugin: createPlugin(),
    destinationAccount,
    sharedSecret,
  });

  const stream = connection.createStream();
  await stream.sendTotal(amount);
  await connection.end();
}

async function run() {
  const server = await createStreamServer();

  // Encode the user account here so we can use when we receive money
  const data = encode(SECRET_KEY, JSON.stringify({ account: "userAccountId" }));

  const { destinationAccount, sharedSecret } = server.generateAddressAndSecret(
    data
  );

  const amount = 10000;
  await sendMoney({ amount, destinationAccount, sharedSecret });
  await server.close();
}

run().catch((err) => console.log(err));

npx nodemon src/index.js

Received payment from userAccountId for: 10000

가능한 다음 단계