increaseValidatorStake static method

Future<List<TransactionInstruction>> increaseValidatorStake({ required SolanaRPC connection, required SolAddress stakePoolAddress, required SolAddress validatorVote, required BigInt lamports, BigInt? ephemeralStakeSeed, })

Creates instructions required to increase validator stake.

Implementation

static Future<List<TransactionInstruction>> increaseValidatorStake({
  required SolanaRPC connection,
  required SolAddress stakePoolAddress,
  required SolAddress validatorVote,
  required BigInt lamports,
  BigInt? ephemeralStakeSeed,
}) async {
  final stakePool = await connection
      .request(SolanaRPCGetStakePoolAccount(address: stakePoolAddress));
  if (stakePool == null) {
    throw MessageException("Stake pool account does not found.");
  }
  final validatorList = await connection.request(
      SolanaRPCGetStakePoolValidatorListAccount(
          address: stakePool.validatorList.address));
  if (validatorList == null) {
    throw MessageException("Validator list account does not found.");
  }

  final validatorInfo = validatorList.validators.firstWhere(
    (v) => v.voteAccountAddress.address == validatorVote.address,
    orElse: () =>
        throw MessageException('Vote account not found in validator list'),
  );

  final withdrawAuthority =
      StakePoolProgramUtils.findWithdrawAuthorityProgramAddress(
    stakePoolAddress: stakePoolAddress,
  );
// bump up by one to avoid reuse
  final transientStakeSeed =
      validatorInfo.transientSeedSuffixStart + BigInt.one;

  final transientStake =
      StakePoolProgramUtils.findTransientStakeProgramAddress(
    voteAccountAddress: validatorInfo.voteAccountAddress,
    stakePoolAddress: stakePoolAddress,
    seed: transientStakeSeed,
  );

  final validatorStake = StakePoolProgramUtils.findStakeProgramAddress(
    voteAccountAddress: validatorInfo.voteAccountAddress,
    stakePoolAddress: stakePoolAddress,
  );

  final instructions = <TransactionInstruction>[];

  if (ephemeralStakeSeed != null) {
    final ephemeralStake =
        StakePoolProgramUtils.findEphemeralStakeProgramAddress(
      stakePoolAddress: stakePoolAddress,
      seed: ephemeralStakeSeed,
    );
    instructions.add(
      StakePoolProgram.increaseAdditionalValidatorStake(
          stakePool: stakePoolAddress,
          staker: stakePool.staker,
          validatorList: stakePool.validatorList,
          reserveStake: stakePool.reserveStake,
          withdrawAuthority: withdrawAuthority.address,
          transientStake: transientStake.address,
          validatorStake: validatorStake.address,
          validatorVote: validatorVote,
          ephemeralStake: ephemeralStake.address,
          layout: StakePoolIncreaseAdditionalValidatorStakeLayout(
              lamports: lamports,
              ephemeralStakeSeed: ephemeralStakeSeed,
              transientStakeSeed: transientStakeSeed)),
    );
  } else {
    instructions.add(
      StakePoolProgram.increaseValidatorStake(
        stakePool: stakePoolAddress,
        staker: stakePool.staker,
        validatorList: stakePool.validatorList,
        reserveStake: stakePool.reserveStake,
        withdrawAuthority: withdrawAuthority.address,
        transientStake: transientStake.address,
        validatorStake: validatorStake.address,
        validatorVote: validatorVote,
        layout: StakePoolIncreaseValidatorStakeLayout(
            lamports: lamports, transientStakeSeed: transientStakeSeed),
      ),
    );
  }

  return instructions;
}