feat: fund delegate

lerna.json

@@ -1,6 +1,8 @@
 {
-  "packages": ["packages/*"],
-  "version": "11.0.5",
+  "packages": [
+    "packages/*"
+  ],
+  "version": "11.1.0",
   "$schema": "node_modules/lerna/schemas/lerna-schema.json",
   "command": {
     "run": {

packages/common/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@streamflow/common",
-  "version": "11.0.5",
+  "version": "11.1.0",
   "description": "Common utilities and types used by streamflow packages.",
   "homepage": "https://github.com/streamflow-finance/js-sdk/",
   "type": "module",

packages/common/solana/types.ts

@@ -105,8 +105,11 @@ export class TransactionFailedError extends Error {
   }
 }
 
-export interface ITransactionResult {
+export interface IPrepareResult {
   ixs: TransactionInstruction[];
+}
+
+export interface ITransactionResult extends IPrepareResult {
   txId: string;
 }
 

packages/distributor/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@streamflow/distributor",
-  "version": "11.0.5",
+  "version": "11.1.0",
   "description": "JavaScript SDK to interact with Streamflow Airdrop protocol.",
   "homepage": "https://github.com/streamflow-finance/js-sdk/",
   "main": "./dist/cjs/index.cjs",

packages/eslint-config/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@streamflow/eslint-config",
-  "version": "11.0.5",
+  "version": "11.1.0",
   "description": "ESLint configuration for Streamflow protocol.",
   "homepage": "https://github.com/streamflow-finance/js-sdk/",
   "engines": {

packages/launchpad/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@streamflow/launchpad",
-  "version": "11.0.5",
+  "version": "11.1.0",
   "description": "JavaScript SDK to interact with Streamflow Launchpad protocol.",
   "homepage": "https://github.com/streamflow-finance/js-sdk/",
   "main": "./dist/cjs/index.cjs",

packages/staking/README.md

@@ -15,7 +15,7 @@ This protocol is the complex of several programs that ensure flexibility and acc
 
 aforementioned programs are:
 - Stake Pools Program
-- Reward Pools Program
+- Reward Pools Program (fixed and dynamic variants)
 - Fee Management Program (for streamflow usage, non-required and omitted from further docs)
 
 
@@ -338,6 +338,45 @@ Client also exposes methods to group staking/unstaking with reward pool actions.
 > [!Note]
 > Transactions can become quite large if you have many rewards pools, that can make it impossible to do all actions in 1 transaction - in this case please stick with `prepare` methods to build custom instructions and execute them with `execute`.
 
+### Auto-Unstake
+
+Stake pools can be configured with `autoUnstake: true` (via `createPoolV2`) to automatically unstake entries once their lock duration expires. 
+- When auto-unstake is enabled, a worker will unstake on the user's behalf after the lock period ends; 
+- if the stake entry has an associated reward entry from a fixed reward pool, the worker will also claim rewards during the auto-unstake process.
+
+This feature works well with `maxTotalStakeCumulative` — together they allow stake pool creators to have a predictable amount of tokens needed in the reward pool. Without auto-unstake, rewards continue to accumulate past unlock time, which can drain a reward pool unexpectedly.
+
+```typescript
+const { metadataId: stakePoolPda } = await client.createStakePool({
+    maxWeight: multiplier,
+    maxDuration,
+    minDuration,
+    mint: MINT_ADDRESS,
+    permissionless: false,
+    nonce: 0,
+    autoUnstake: true,
+    maxTotalStakeCumulative: new BN(1_000_000_000), // cap total stake
+}, extParams);
+```
+
+### Fund Delegate
+
+Fund Delegate allows configuring automated periodic top-ups of a dynamic reward pool. The delegate account holds tokens that a worker uses to fund the reward pool on a schedule. Users transfer tokens to the delegate's token account, and the worker funds the pool according to the configured schedule (start time, period, and expiry).
+
+```typescript
+const rewardPool = /* dynamic reward pool address */;
+
+// Create a fund delegate with a schedule
+const { tokenAccount } = await client.createFundDelegate({
+    rewardPool,
+    startTs: new BN(Math.floor(Date.now() / 1000)),  // start now
+    period: new BN(86400),                             // fund every 24 hours
+    expiryTs: new BN(Math.floor(Date.now() / 1000) + 86400 * 30), // expire in 30 days
+}, extParams);
+```
+
+After creating the delegate, transfer reward tokens to the `tokenAccount`, which is an ATA for the fund delegate PDA address. The worker will periodically fund the reward pool from these tokens according to the schedule.
+
 ### Set Token Metadata
 
 SolanaStakingClient also exposes original IDL of all programs, so you can use some additional instructions, that are not wrapped by the client. Currently there is no method to update Token Metadata of the Staking Mint that stakers get in return for their stake, but you can call the instructions from the original IDL like so:
@@ -372,10 +411,12 @@ Streamflow Staking protocol program IDs
 | Solana  |                                              |
 | ------- | -------------------------------------------- |
 | Staking Pools Mainnet   | STAKEvGqQTtzJZH6BWDcbpzXXn2BBerPAgQ3EGLN2GH  |
-| Reward Pools Mainnet   | RWRDdfRbi3339VgKxTAXg4cjyniF7cbhNbMxZWiSKmj  |
+| Reward Pools (fixed) Mainnet   | RWRDdfRbi3339VgKxTAXg4cjyniF7cbhNbMxZWiSKmj  |
+| Reward Pools (dynamic) Mainnet   | RWRDyfZa6Rk9UYi85yjYYfGmoUqffLqjo6vZdFawEez  |
 | ----   | ---  |
 | Staking Pools Devnet   | STAKEvGqQTtzJZH6BWDcbpzXXn2BBerPAgQ3EGLN2GH  |
-| Reward Pools Devnet   | RWRDdfRbi3339VgKxTAXg4cjyniF7cbhNbMxZWiSKmj  |
+| Reward Pools (fixed) Devnet   | RWRDdfRbi3339VgKxTAXg4cjyniF7cbhNbMxZWiSKmj  |
+| Reward Pools (dynamic) Devnet   | RWRDyfZa6Rk9UYi85yjYYfGmoUqffLqjo6vZdFawEez  |
 
 ### IDLs
 For further details you can consult with IDLs of protocols available at:

packages/staking/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@streamflow/staking",
-  "version": "11.0.5",
+  "version": "11.1.0",
   "description": "JavaScript SDK to interact with Streamflow Staking protocol.",
   "homepage": "https://github.com/streamflow-finance/js-sdk/",
   "main": "./dist/cjs/index.cjs",

packages/staking/solana/client.ts

@@ -46,6 +46,7 @@ import { type StakePool as StakePoolProgramType } from "./descriptor/stake_pool.
 import {
   deriveConfigPDA,
   deriveFeeValuePDA,
+  deriveFundDelegatePDA,
   deriveRewardPoolPDA,
   deriveRewardVaultPDA,
   deriveStakeEntryPDA,
@@ -55,6 +56,9 @@ import type {
   ClaimRewardPoolArgs,
   CloseRewardEntryArgs,
   CloseStakeEntryArgs,
+  CreateFundDelegateArgs,
+  CreateFundDelegatePrepareResult,
+  CreateFundDelegateResult,
   CreateRewardEntryArgs,
   CreateRewardPoolArgs,
   CreateStakePoolArgs,
@@ -315,10 +319,7 @@ export class SolanaStakingClient {
    * @param data - enriched stake params with an array of reward pools
    * @param extParams - parameter required for transaction execution
    */
-  async stakeAndCreateEntries(
-    data: StakeAndCreateEntriesArgs,
-    extParams: IInteractExt,
-  ): Promise<ITransactionResult> {
+  async stakeAndCreateEntries(data: StakeAndCreateEntriesArgs, extParams: IInteractExt): Promise<ITransactionResult> {
     const { ixs } = await this.prepareStakeAndCreateEntriesInstructions(data, extParams);
     const { signature } = await this.execute(ixs, extParams);
 
@@ -743,6 +744,41 @@ export class SolanaStakingClient {
     return { ixs: [instruction] };
   }
 
+  async createFundDelegate(data: CreateFundDelegateArgs, extParams: IInteractExt): Promise<CreateFundDelegateResult> {
+    const { ixs, tokenAccount } = await this.prepareCreateFundDelegateInstructions(data, extParams);
+    const { signature } = await this.execute(ixs, extParams);
+
+    return {
+      ixs,
+      txId: signature,
+      tokenAccount,
+    };
+  }
+
+  async prepareCreateFundDelegateInstructions(
+    { rewardPool, startTs, period, expiryTs, tokenProgramId = TOKEN_PROGRAM_ID }: CreateFundDelegateArgs,
+    extParams: IInteractExt,
+  ): Promise<CreateFundDelegatePrepareResult> {
+    const { rewardPoolDynamicProgram } = this.programs;
+    const authority = extParams.invoker.publicKey;
+    invariant(authority, "Undefined invoker publicKey");
+    const rewardPoolPk = pk(rewardPool);
+    const rewardPoolData = await rewardPoolDynamicProgram.account.rewardPool.fetch(rewardPoolPk);
+    const mint = rewardPoolData.mint;
+    const fundDelegate = deriveFundDelegatePDA(rewardPoolDynamicProgram.programId, rewardPoolPk);
+    const tokenAccount = getAssociatedTokenAddressSync(mint, fundDelegate, true, pk(tokenProgramId));
+
+    const instruction = await rewardPoolDynamicProgram.methods
+      .createFundDelegate(startTs, period, expiryTs)
+      .accounts({
+        rewardPool: rewardPoolPk,
+        tokenProgram: tokenProgramId,
+      })
+      .instruction();
+
+    return { ixs: [instruction], tokenAccount };
+  }
+
   async updateRewardPool(data: UpdateRewardPoolArgs, extParams: IInteractExt) {
     const { ixs } = await this.prepareUpdateRewardPoolInstructions(data, extParams);
     const { signature } = await this.execute(ixs, extParams);

packages/staking/solana/constants.ts

@@ -22,7 +22,9 @@ export const REWARD_VAULT_PREFIX = Buffer.from("reward-vault", "utf-8");
 export const REWARD_ENTRY_PREFIX = Buffer.from("reward-entry", "utf-8");
 export const CONFIG_PREFIX = Buffer.from("config", "utf-8");
 export const FEE_VALUE_PREFIX = Buffer.from("fee-value", "utf-8");
+export const FUND_DELEGATE_PREFIX = Buffer.from("fund-delegate", "utf-8");
 export const STREAMFLOW_TREASURY_PUBLIC_KEY = new PublicKey("5SEpbdjFK5FxwTvfsGMXVQTD2v4M2c5tyRTxhdsPkgDw");
+export const WORKER_PUBLIC_KEY = new PublicKey("wdrwhnCv4pzW8beKsbPa4S2UDZrXenjg16KJdKSpb5u");
 
 export const ANCHOR_DISCRIMINATOR_OFFSET = 8;
 export const STAKE_ENTRY_STAKE_POOL_OFFSET = ANCHOR_DISCRIMINATOR_OFFSET + 4;