add bench files

README.md

@@ -1,4 +1,4 @@
-# Lite RPC
+# Lite RPC For Solana Blockchain 
 
 Submitting a [transaction](https://docs.solana.com/terminology#transaction) to be executed on the solana blockchain,
 requires the client to identify the next few leaders based on the
@@ -16,7 +16,7 @@ commodity vms.
 
 1) Subscribe to new blocks using [blockSubscribe](https://docs.solana.com/developing/clients/jsonrpc-api#blocksubscribe---unstable-disabled-by-default)
 2) Subscribing to signatures with pool of rpc servers. (Under development)
-3) Listining to gossip protocol. (Future roadmap)
+3) Listening to gossip protocol. (Future roadmap)
 
 ## Executing
 

benches/bench_txs_send.ts

@@ -0,0 +1,103 @@
+import { Connection, Keypair, LAMPORTS_PER_SOL, PublicKey, TransactionSignature, Transaction } from '@solana/web3.js';
+import * as fs from 'fs';
+import * as splToken from "@solana/spl-token";
+import * as os from 'os';
+
+// number of users
+const tps: number = +process.argv[2];
+const forSeconds: number = +process.argv[3];
+// url
+const url = process.argv.length > 4 ? process.argv[4] : "http://localhost:8899";
+const skip_confirmations = process.argv.length > 5 ? process.argv[5] === "true" : false;
+import * as InFile from "./out.json";
+
+function sleep(ms: number) {
+    return new Promise(resolve => setTimeout(resolve, ms));
+}
+
+console.log("benching " + tps + " transactions per second on " + url + " for " + forSeconds + " seconds");
+
+function delay(ms: number) {
+    return new Promise(resolve => setTimeout(resolve, ms));
+}
+
+export async function main() {
+
+    const connection = new Connection(url, 'confirmed');
+    const authority = Keypair.fromSecretKey(
+        Uint8Array.from(
+            JSON.parse(
+                process.env.KEYPAIR ||
+                fs.readFileSync(os.homedir() + '/.config/solana/id.json', 'utf-8'),
+            ),
+        ),
+    );
+
+    const users = InFile.users.map(x => Keypair.fromSecretKey(Uint8Array.from(x.secretKey)));
+    const userAccounts = InFile.tokenAccounts.map(x => new PublicKey(x));
+    let signatures_to_unpack: TransactionSignature[][] = [];
+    let time_taken_to_send = [];
+
+    for (let i = 0; i < forSeconds; ++i) {
+        const start = performance.now();
+        let signatures: TransactionSignature[] = [];
+        const blockhash = (await connection.getLatestBlockhash()).blockhash;
+        for (let j = 0; j < tps; ++j) {
+            const toIndex = Math.floor(Math.random() * users.length);
+            let fromIndex = toIndex;
+            while (fromIndex === toIndex) {
+                fromIndex = Math.floor(Math.random() * users.length);
+            }
+            const userFrom = userAccounts[fromIndex];
+            const userTo = userAccounts[toIndex];
+            if (skip_confirmations === false) {
+                const transaction = new Transaction().add(
+                    splToken.createTransferInstruction(userFrom, userTo, users[fromIndex].publicKey, Math.ceil(Math.random() * 100))
+                );
+                transaction.recentBlockhash = blockhash;
+                transaction.feePayer = authority.publicKey;
+                const p = connection.sendTransaction(transaction, [authority, users[fromIndex]], { skipPreflight: true });
+                signatures.push(await p)
+            }
+        }
+        if (skip_confirmations === false) {
+            signatures_to_unpack.push(signatures)
+        }
+        const end = performance.now();
+        const diff = (end - start);
+        time_taken_to_send[i] = diff;
+        if (diff > 0 && diff < 1000) {
+            await sleep(1000 - diff)
+        }
+    }
+
+    console.log('finish sending transactions');
+    await delay(5000)
+    console.log('checking for confirmations');
+    if (skip_confirmations === false) {
+        const size = signatures_to_unpack.length
+        let successes: Uint32Array = new Uint32Array(size).fill(0);
+        let failures: Uint32Array = new Uint32Array(size).fill(0);
+        for (let i = 0; i < size; ++i) {
+            const signatures = signatures_to_unpack[i];
+            for (const signature of signatures) {
+                const confirmed = await connection.getSignatureStatus(signature);
+                if (confirmed != null && confirmed.value != null && confirmed.value.err == null) {
+                    successes[i]++;
+                } else {
+                    failures[i]++;
+                }
+            }
+
+        }
+        console.log("sucesses : " + successes)
+        console.log("failures : " + failures)
+        //console.log("time taken to send : " + time_taken_to_send)
+    }
+}
+
+main().then(x => {
+    console.log('finished sucessfully')
+}).catch(e => {
+    console.log('caught an error : ' + e)
+})