Remove Buffer Usage

examples/asa.ts

@@ -49,7 +49,7 @@ async function main() {
   console.log(`Asset Params: ${JSON.stringify(assetInfo.params)}`);
   // example: ASSET_INFO
 
-  await new Promise((f) => setTimeout(f, 2000)); // sleep to ensure indexer is caught up
+  await new Promise((f) => setTimeout(f, 5000)); // sleep to ensure indexer is caught up
 
   // example: INDEXER_LOOKUP_ASSET
   const indexer = getLocalIndexerClient();

examples/codec.ts

@@ -3,7 +3,7 @@
 /* eslint-disable no-promise-executor-return */
 /* eslint-disable no-console */
 import algosdk from '../src';
-import { getLocalAlgodClient, getLocalAccounts } from './utils';
+import { getLocalAccounts, getLocalAlgodClient } from './utils';
 
 async function main() {
   const client = getLocalAlgodClient();

examples/lsig.ts

@@ -3,7 +3,7 @@
 /* eslint-disable no-promise-executor-return */
 /* eslint-disable no-console */
 import algosdk from '../src';
-import { getLocalAlgodClient, getLocalAccounts } from './utils';
+import { getLocalAccounts, getLocalAlgodClient } from './utils';
 
 async function main() {
   const client = getLocalAlgodClient();

src/bid.ts

@@ -1,4 +1,3 @@
-import { Buffer } from 'buffer';
 import * as address from './encoding/address';
 import * as encoding from './encoding/encoding';
 import * as nacl from './nacl/naclWrappers';
@@ -27,7 +26,7 @@ export type BidOptions = Omit<
  * */
 export default class Bid implements BidStorageStructure {
   name = 'Bid';
-  tag = Buffer.from([97, 66]); // "aB"
+  tag = Uint8Array.from([97, 66]); // "aB"
 
   bidderKey: Address;
   bidAmount: number;
@@ -67,23 +66,23 @@ export default class Bid implements BidStorageStructure {
   // eslint-disable-next-line camelcase
   get_obj_for_encoding() {
     return {
-      bidder: Buffer.from(this.bidderKey.publicKey),
+      bidder: this.bidderKey.publicKey,
       cur: this.bidAmount,
       price: this.maxPrice,
       id: this.bidID,
-      auc: Buffer.from(this.auctionKey.publicKey),
+      auc: this.auctionKey.publicKey,
       aid: this.auctionID,
     };
   }
 
   signBid(sk: Uint8Array) {
     const encodedMsg = encoding.encode(this.get_obj_for_encoding());
-    const toBeSigned = Buffer.from(utils.concatArrays(this.tag, encodedMsg));
+    const toBeSigned = utils.concatArrays(this.tag, encodedMsg);
     const sig = nacl.sign(toBeSigned, sk);
 
     // construct signed message
     const sBid = {
-      sig: Buffer.from(sig),
+      sig,
       bid: this.get_obj_for_encoding(),
     };
 

src/client/client.ts

@@ -1,4 +1,3 @@
-import { Buffer } from 'buffer';
 import * as utils from '../utils/utils';
 import {
   BaseHTTPClient,
@@ -151,10 +150,10 @@ export default class HTTPClient {
       return new Uint8Array(0); // empty Uint8Array
     }
     if (requestHeaders['content-type'] === 'application/json') {
-      return new Uint8Array(Buffer.from(JSON.stringify(data)));
+      return new TextEncoder().encode(JSON.stringify(data));
     }
     if (typeof data === 'string') {
-      return new Uint8Array(Buffer.from(data));
+      return new TextEncoder().encode(data);
     }
     if (data instanceof Uint8Array) {
       return data;
@@ -179,7 +178,7 @@ export default class HTTPClient {
     let text;
 
     if (format !== 'application/msgpack') {
-      text = (body && Buffer.from(body).toString()) || '';
+      text = (body && new TextDecoder().decode(body)) || '';
     }
 
     if (parseBody && format === 'application/json') {

src/client/kmd.ts

@@ -1,7 +1,11 @@
-import { Buffer } from 'buffer';
-import ServiceClient from './v2/serviceClient';
+import {
+  base64ToBytes,
+  bytesToBase64,
+  coerceToBytes,
+} from '../encoding/binarydata';
 import * as txn from '../transaction';
 import { CustomTokenHeader, KMDTokenHeader } from './urlTokenBaseHTTPClient';
+import ServiceClient from './v2/serviceClient';
 
 export default class Kmd extends ServiceClient {
   constructor(
@@ -50,7 +54,7 @@ export default class Kmd extends ServiceClient {
       wallet_name: walletName,
       wallet_driver_name: walletDriverName,
       wallet_password: walletPassword,
-      master_derivation_key: Buffer.from(walletMDK).toString('base64'),
+      master_derivation_key: bytesToBase64(walletMDK),
     };
     const res = await this.c.post('/v1/wallet', req);
     return res.body;
@@ -157,10 +161,7 @@ export default class Kmd extends ServiceClient {
     };
     const res = await this.c.post('/v1/master-key/export', req);
     return {
-      master_derivation_key: Buffer.from(
-        res.body.master_derivation_key,
-        'base64'
-      ),
+      master_derivation_key: base64ToBytes(res.body.master_derivation_key),
     };
   }
 
@@ -174,7 +175,7 @@ export default class Kmd extends ServiceClient {
   async importKey(walletHandle: string, secretKey: Uint8Array) {
     const req = {
       wallet_handle_token: walletHandle,
-      private_key: Buffer.from(secretKey).toString('base64'),
+      private_key: bytesToBase64(secretKey),
     };
     const res = await this.c.post('/v1/key/import', req);
     return res.body;
@@ -195,7 +196,7 @@ export default class Kmd extends ServiceClient {
       wallet_password: walletPassword,
     };
     const res = await this.c.post('/v1/key/export', req);
-    return { private_key: Buffer.from(res.body.private_key, 'base64') };
+    return { private_key: base64ToBytes(res.body.private_key) };
   }
 
   /**
@@ -266,12 +267,12 @@ export default class Kmd extends ServiceClient {
     const req = {
       wallet_handle_token: walletHandle,
       wallet_password: walletPassword,
-      transaction: Buffer.from(tx.toByte()).toString('base64'),
+      transaction: bytesToBase64(tx.toByte()),
     };
     const res = await this.c.post('/v1/transaction/sign', req);
 
     if (res.status === 200) {
-      return Buffer.from(res.body.signed_transaction, 'base64');
+      return base64ToBytes(res.body.signed_transaction);
     }
     return res.body;
   }
@@ -293,17 +294,18 @@ export default class Kmd extends ServiceClient {
     publicKey: Uint8Array | string
   ) {
     const tx = txn.instantiateTxnIfNeeded(transaction);
+    const pk = coerceToBytes(publicKey);
 
     const req = {
       wallet_handle_token: walletHandle,
       wallet_password: walletPassword,
-      transaction: Buffer.from(tx.toByte()).toString('base64'),
-      public_key: Buffer.from(publicKey).toString('base64'),
+      transaction: bytesToBase64(tx.toByte()),
+      public_key: bytesToBase64(pk),
     };
     const res = await this.c.post('/v1/transaction/sign', req);
 
     if (res.status === 200) {
-      return Buffer.from(res.body.signed_transaction, 'base64');
+      return base64ToBytes(res.body.signed_transaction);
     }
     return res.body;
   }
@@ -389,10 +391,11 @@ export default class Kmd extends ServiceClient {
     partial: string
   ) {
     const tx = txn.instantiateTxnIfNeeded(transaction);
+    const pubkey = coerceToBytes(pk);
     const req = {
       wallet_handle_token: walletHandle,
-      transaction: Buffer.from(tx.toByte()).toString('base64'),
-      public_key: Buffer.from(pk).toString('base64'),
+      transaction: bytesToBase64(tx.toByte()),
+      public_key: bytesToBase64(pubkey),
       partial_multisig: partial,
       wallet_password: pw,
     };

src/client/urlTokenBaseHTTPClient.ts

@@ -1,4 +1,3 @@
-import { Buffer } from 'buffer';
 import { fetch, Response, Headers } from 'cross-fetch';
 import {
   BaseHTTPClient,
@@ -118,7 +117,7 @@ export class URLTokenBaseHTTPClient implements BaseHTTPClient {
     try {
       body = new Uint8Array(await res.arrayBuffer());
       const decoded: Record<string, any> = JSON.parse(
-        Buffer.from(body).toString()
+        new TextDecoder().decode(body)
       );
       if (decoded.message) {
         bodyErrorMessage = decoded.message;

src/client/v2/algod/compile.ts

@@ -1,6 +1,6 @@
-import { Buffer } from 'buffer';
-import JSONRequest from '../jsonrequest';
+import { coerceToBytes } from '../../../encoding/binarydata';
 import HTTPClient from '../../client';
+import JSONRequest from '../jsonrequest';
 
 /**
  * Sets the default header (if not previously set)
@@ -42,7 +42,7 @@ export default class Compile extends JSONRequest {
     const txHeaders = setHeaders(headers);
     const res = await this.c.post(
       this.path(),
-      Buffer.from(this.source),
+      coerceToBytes(this.source),
       txHeaders,
       this.query
     );

src/client/v2/algod/disassemble.ts

@@ -1,6 +1,6 @@
-import { Buffer } from 'buffer';
-import JSONRequest from '../jsonrequest';
+import { coerceToBytes } from '../../../encoding/binarydata';
 import HTTPClient from '../../client';
+import JSONRequest from '../jsonrequest';
 
 /**
  * Sets the default header (if not previously set)
@@ -37,7 +37,7 @@ export default class Disassemble extends JSONRequest {
     const txHeaders = setHeaders(headers);
     const res = await this.c.post(
       this.path(),
-      Buffer.from(this.source),
+      coerceToBytes(this.source),
       txHeaders,
       this.query
     );

src/client/v2/algod/dryrun.ts

@@ -1,9 +1,8 @@
-import { Buffer } from 'buffer';
-import JSONRequest from '../jsonrequest';
-import HTTPClient from '../../client';
-import * as modelsv2 from './models/types';
 import * as encoding from '../../../encoding/encoding';
+import HTTPClient from '../../client';
+import JSONRequest from '../jsonrequest';
 import { setHeaders } from './compile';
+import * as modelsv2 from './models/types';
 
 export default class Dryrun extends JSONRequest {
   private blob: Uint8Array;
@@ -24,11 +23,7 @@ export default class Dryrun extends JSONRequest {
    */
   async do(headers = {}) {
     const txHeaders = setHeaders(headers);
-    const res = await this.c.post(
-      this.path(),
-      Buffer.from(this.blob),
-      txHeaders
-    );
+    const res = await this.c.post(this.path(), this.blob, txHeaders);
     return res.body;
   }
 }

src/client/v2/algod/getApplicationBoxByName.ts

@@ -1,7 +1,7 @@
-import { Buffer } from 'buffer';
-import JSONRequest from '../jsonrequest';
-import HTTPClient from '../../client';
+import { bytesToBase64 } from '../../../encoding/binarydata';
 import IntDecoding from '../../../types/intDecoding';
+import HTTPClient from '../../client';
+import JSONRequest from '../jsonrequest';
 import { Box } from './models/types';
 
 /**
@@ -32,7 +32,7 @@ export default class GetApplicationBoxByName extends JSONRequest<
     super(c, intDecoding);
     this.index = index;
     // Encode name in base64 format and append the encoding prefix.
-    const encodedName = Buffer.from(name).toString('base64');
+    const encodedName = bytesToBase64(name);
     this.query.name = encodeURI(`b64:${encodedName}`);
   }