Use balance from Geyser update to for real-time VM deposit flow

Author: Jeff Yanta

pkg/code/async/geyser/external_deposit.go

@@ -79,6 +79,14 @@ func maybeInitiateExternalDepositIntoVm(ctx context.Context, data code_data.Prov
 	if balance == 0 {
 		return nil
 	}
+	return initiateExternalDepositIntoVm(ctx, data, vmIndexerClient, userAuthority, balance)
+}
+
+func initiateExternalDepositIntoVm(ctx context.Context, data code_data.Provider, vmIndexerClient indexerpb.IndexerClient, userAuthority *common.Account, balance uint64) error {
+	vmDepositAccounts, err := userAuthority.GetVmDepositAccounts(common.CodeVmAccount, common.CoreMintAccount)
+	if err != nil {
+		return errors.Wrap(err, "error getting vm deposit ata")
+	}
 
 	memoryAccount, memoryIndex, err := getVirtualTimelockAccountLocationInMemory(ctx, vmIndexerClient, common.CodeVmAccount, userAuthority)
 	if err != nil {

pkg/code/async/geyser/handler.go

@@ -102,7 +102,7 @@ func (h *TokenProgramAccountHandler) Handle(ctx context.Context, update *geyserp
 		}
 
 		if unmarshalled.Amount > 0 {
-			err = maybeInitiateExternalDepositIntoVm(ctx, h.data, h.vmIndexerClient, userAuthorityAccount)
+			err = initiateExternalDepositIntoVm(ctx, h.data, h.vmIndexerClient, userAuthorityAccount, unmarshalled.Amount)
 			if err != nil {
 				return errors.Wrap(err, "error depositing into the vm")
 			}