chore: bump to 0.20.9, feat: compress, transfer (#16)

* pick pseudorandom

batch transfer

for mainnet

0.19.0

add airdrop.ts

add multi-trees, add transfer, compress

* clean transfer.ts

Author: SwenSchaeferjohann

package-lock.json

@@ -19,6 +19,8 @@
     "create-account-pulse": "ts-node src/internal/create-account-pulse.ts",
     "create-account-with-lamports-pulse": "ts-node src/internal/create-account-with-lamports-pulse.ts",
     "airdrop": "ts-node src/scripts/airdrop/airdrop.ts",
+    "transfer": "ts-node src/scripts/transfer.ts",
+    "compress": "ts-node src/scripts/compress.ts",
     "test": "npm run lamports && npm run token && npm run connection && npm run batch-compress && npm run mint-spl && npm run mint-spl-22 && npm run mint-spl-22-manual"
   },
   "repository": {
@@ -33,8 +35,8 @@
   },
   "homepage": "https://github.com/Lightprotocol/example-nodejs-client#readme",
   "dependencies": {
-    "@lightprotocol/compressed-token": "0.20.3",
-    "@lightprotocol/stateless.js": "0.20.3",
+    "@lightprotocol/compressed-token": "0.20.9",
+    "@lightprotocol/stateless.js": "0.20.9",
     "@solana/spl-token": "0.3.9",
     "@solana/spl-token-metadata": "^0.1.6",
     "@solana/web3.js": "^1.98.0",

package.json

@@ -25,6 +25,28 @@ export const LUT_DEVNET_AUTHORITY_KEYPAIR = process.env.LUT_DEVNET_AUTH_KEYPAIR
   : undefined;
 
 export const MINT_ADDRESS = new PublicKey(process.env.MINT_ADDRESS!);
+
+export const AUTHORITY_KEYPAIR = process.env.LUT_AUTHORITY_KEYPAIR
+  ? Keypair.fromSecretKey(
+      Uint8Array.from(JSON.parse(process.env.LUT_AUTHORITY_KEYPAIR))
+    )
+  : undefined;
+
+export const BOB_KEYPAIR = process.env.BOB_KEYPAIR
+  ? Keypair.fromSecretKey(Uint8Array.from(JSON.parse(process.env.BOB_KEYPAIR)))
+  : undefined;
+
+export const LUT_MAINNET_AUTHORITY_KEYPAIR = process.env.LUT_AUTHORITY_KEYPAIR
+  ? Keypair.fromSecretKey(
+      Uint8Array.from(JSON.parse(process.env.LUT_AUTHORITY_KEYPAIR))
+    )
+  : undefined;
+
+export const LUT_DEVNET_AUTHORITY_KEYPAIR = process.env.LUT_DEVNET_AUTH_KEYPAIR
+  ? Keypair.fromSecretKey(bs58.decode(process.env.LUT_DEVNET_AUTH_KEYPAIR))
+  : undefined;
+
+
 if (!RPC_ENDPOINT) throw new Error("Please set RPC_ENDPOINT in .env");
 if (!PAYER_KEYPAIR)
   throw new Error("Please set PAYER_KEYPAIR as bs58 string in .env");

src/constants.ts

@@ -9,6 +9,7 @@ import {
   dedupeSigner,
   pickRandomTreeAndQueue,
   Rpc,
+  sendAndConfirmTx,
 } from "@lightprotocol/stateless.js";
 import * as splToken from "@solana/spl-token";
 
@@ -131,6 +132,9 @@ import * as splToken from "@solana/spl-token";
     } else {
       console.log("Simulation successful", simulate);
     }
+    // Uncomment to send the transaction:
+    // const txId = await sendAndConfirmTx(connection, tx);
+    // console.log(`txId: ${txId}`);
   } catch (e) {
     console.error(`Batch compression failed:`, e);
   }

src/scripts/batch-compress.ts

@@ -0,0 +1,112 @@
+import * as web3 from "@solana/web3.js";
+import { Keypair, PublicKey } from "@solana/web3.js";
+import { CompressedTokenProgram } from "@lightprotocol/compressed-token";
+import {
+  bn,
+  buildAndSignTx,
+  calculateComputeUnitPrice,
+  createRpc,
+  dedupeSigner,
+  pickRandomTreeAndQueue,
+  Rpc,
+  sendAndConfirmTx,
+} from "@lightprotocol/stateless.js";
+import * as splToken from "@solana/spl-token";
+import dotenv from "dotenv";
+import bs58 from "bs58";
+dotenv.config();
+
+const RPC_ENDPOINT = process.env.RPC_ENDPOINT;
+const MINT_ADDRESS = new PublicKey(process.env.MINT_ADDRESS!);
+const PAYER_KEYPAIR = Keypair.fromSecretKey(
+  bs58.decode(process.env.PAYER_KEYPAIR!)
+);
+
+(async () => {
+  try {
+    const connection: Rpc = createRpc(RPC_ENDPOINT);
+    const mintAddress = MINT_ADDRESS;
+    const payer = PAYER_KEYPAIR;
+
+    const activeStateTrees = await connection.getCachedActiveStateTreeInfo();
+
+    /// Pick a new tree for each transaction!
+    const { tree } = pickRandomTreeAndQueue(activeStateTrees);
+
+    // Create an SPL token account for the sender.
+    // The sender will send tokens from this account to the recipients as compressed tokens.
+    const sourceTokenAccount = await splToken.getOrCreateAssociatedTokenAccount(
+      connection,
+      payer,
+      mintAddress,
+      payer.publicKey
+    );
+
+    // Airdrop to example recipients addresses
+    // 1 recipient = 120_000 CU
+    // 5 recipients = 170_000 CU
+    const airDropAddresses = [
+      "GMPWaPPrCeZPse5kwSR3WUrqYAPrVZBSVwymqh7auNW7",
+    ].map((address) => new web3.PublicKey(address));
+
+    const amount = bn(111); // each recipient will receive 111 tokens
+    const instructions: web3.TransactionInstruction[] = [];
+
+    instructions.push(
+      web3.ComputeBudgetProgram.setComputeUnitLimit({ units: 120_000 }),
+      web3.ComputeBudgetProgram.setComputeUnitPrice({
+        // ideally replace this with a dynamic priority_fee based on network conditions.
+        microLamports: calculateComputeUnitPrice(20_000, 120_000),
+      })
+    );
+
+    const compressInstruction = await CompressedTokenProgram.compress({
+      payer: payer.publicKey,
+      owner: payer.publicKey,
+      source: sourceTokenAccount.address, // here, the owner of this account is also the payer.
+      toAddress: airDropAddresses,
+      amount: airDropAddresses.map(() => amount),
+      mint: mintAddress,
+      outputStateTree: tree,
+    });
+    instructions.push(compressInstruction);
+
+    // Use zk-compression LUT for your network
+    // https://www.zkcompression.com/developers/protocol-addresses-and-urls#lookup-tables
+    const lookupTableAddress = new web3.PublicKey(
+      // "9NYFyEqPkyXUhkerbGHXUXkvb4qpzeEdHuGpgbgpH1NJ" // mainnet
+      "qAJZMgnQJ8G6vA3WRcjD9Jan1wtKkaCFWLWskxJrR5V" // devnet
+    );
+
+    // Get the lookup table account state
+    const lookupTableAccount = (
+      await connection.getAddressLookupTable(lookupTableAddress)
+    ).value!;
+
+    // Sign the transaction with the payer and owner keypair
+    const owner = payer;
+    const additionalSigners = dedupeSigner(payer, [owner]);
+
+    const { blockhash } = await connection.getLatestBlockhash();
+
+    const tx = buildAndSignTx(
+      instructions,
+      payer,
+      blockhash,
+      additionalSigners,
+      [lookupTableAccount]
+    );
+
+    const simulate = await connection.simulateTransaction(tx);
+    if (simulate.value.err) {
+      console.error("Simulation failed", simulate);
+    } else {
+      console.log("Simulation successful", simulate);
+    }
+    // Uncomment to send the transaction.
+    // const txId = await sendAndConfirmTx(connection, tx);
+    // console.log(`txId: ${txId}`);
+  } catch (e) {
+    console.error(`Compression failed:`, e);
+  }
+})();

src/scripts/compress.ts

@@ -37,12 +37,13 @@ const connection: Rpc = createRpc(RPC_ENDPOINT, RPC_ENDPOINT);
 
   console.log(`ATA: ${ata.address}`);
 
-  await mintToSpl(
+  const mintTxId = await mintToSpl(
     connection,
     payer,
     mint,
     ata.address,
     payer.publicKey,
     BigInt("240000050")
   );
+  console.log(`mint-spl success! txId: ${mintTxId}`);
 })();