feat(stellar): support payments for issued assets and XLM

packages/payments-engine/dist/index.js

@@ -52,16 +52,17 @@ var StellarService = class {
   /**
    * Sends funds from the operational storage to a destination address
    */
-  async sendFunds(destinationAddress, amount) {
+  async sendFunds(destinationAddress, amount, assetCode, assetIssuer) {
     try {
       const sourceAccount = await this.server.loadAccount(this.sourceKeypair.publicKey());
+      const asset = assetCode && assetIssuer ? new StellarSdk.Asset(assetCode, assetIssuer) : StellarSdk.Asset.native();
       const transaction = new StellarSdk.TransactionBuilder(sourceAccount, {
         fee: StellarSdk.BASE_FEE,
         networkPassphrase: process.env.STELLAR_NETWORK_URL?.includes("public") ? StellarSdk.Networks.PUBLIC : StellarSdk.Networks.TESTNET
       }).addOperation(
         StellarSdk.Operation.payment({
           destination: destinationAddress,
-          asset: StellarSdk.Asset.native(),
+          asset,
           amount
         })
       ).setTimeout(30).build();

packages/payments-engine/dist/index.mjs

@@ -16,16 +16,17 @@ var StellarService = class {
   /**
    * Sends funds from the operational storage to a destination address
    */
-  async sendFunds(destinationAddress, amount) {
+  async sendFunds(destinationAddress, amount, assetCode, assetIssuer) {
     try {
       const sourceAccount = await this.server.loadAccount(this.sourceKeypair.publicKey());
+      const asset = assetCode && assetIssuer ? new StellarSdk.Asset(assetCode, assetIssuer) : StellarSdk.Asset.native();
       const transaction = new StellarSdk.TransactionBuilder(sourceAccount, {
         fee: StellarSdk.BASE_FEE,
         networkPassphrase: process.env.STELLAR_NETWORK_URL?.includes("public") ? StellarSdk.Networks.PUBLIC : StellarSdk.Networks.TESTNET
       }).addOperation(
         StellarSdk.Operation.payment({
           destination: destinationAddress,
-          asset: StellarSdk.Asset.native(),
+          asset,
           amount
         })
       ).setTimeout(30).build();

packages/payments-engine/src/index.ts

@@ -2,6 +2,8 @@ export interface PaymentIntentType {
   id: string;
   amount: number;
   currency: string;
+  assetCode?: string;
+  assetIssuer?: string;
   status: 'pending' | 'completed' | 'failed';
   createdAt: Date;
   updatedAt: Date;

packages/payments-engine/src/stellar.service.ts

@@ -24,9 +24,18 @@ export class StellarService {
   /**
    * Sends funds from the operational storage to a destination address
    */
-  async sendFunds(destinationAddress: string, amount: string): Promise<string> {
+  async sendFunds(
+    destinationAddress: string,
+    amount: string,
+    assetCode?: string,
+    assetIssuer?: string,
+  ): Promise<string> {
     try {
       const sourceAccount = await this.server.loadAccount(this.sourceKeypair.publicKey());
+      const asset =
+        assetCode && assetIssuer
+          ? new StellarSdk.Asset(assetCode, assetIssuer)
+          : StellarSdk.Asset.native();
 
       const transaction = new StellarSdk.TransactionBuilder(sourceAccount, {
         fee: StellarSdk.BASE_FEE,
@@ -37,7 +46,7 @@ export class StellarService {
         .addOperation(
           StellarSdk.Operation.payment({
             destination: destinationAddress,
-            asset: StellarSdk.Asset.native(),
+            asset,
             amount: amount,
           }),
         )