Plume: Auto-Rebalance your Nest Vaults Daily

Created by

B3 Team

Root

Detect Vault Balances

Fetch Vault APYs

Calculate

If Needs Rebalance

About

Moves your pUSD between Nest vaults on Plume to chase higher APYs. Runs daily at 08:00 UTC. Won't rebalance unless one vault is paying at least 1% more than another. Each vault stays between 5% and 50% of your total. Choose which notification channel you want an update from (Slack, Telegram, etc.)

Quick Setup:

Import your Plume wallet or use your B3OS Treasury Wallet
Pick the Slack channel for rebalance notifications
Test and publish

Preview

Check All Fulfilled

Action

Code:function transform(input) { return { allFulfilled: input.every(i => i['check-withdrawal-action'].fulfilled) }; }

Input:foreach-check:iterations

Input Type:{"type":"array"}

Output Type:{"properties":{"allFulfilled":{"type":"boolean"}},"type":"object"}

calculate

Action

Balances:Detect Vault Balances:balances

Max Allocation Percent:0.5

Min Allocation Percent:0.05

Min Apy Differential:0.01

Min Rebalance Value Pusd:0.001

Vault Apys:Fetch Vault APYs:vaultApys

check-withdrawal-action

Action

Token:Item: tokenAddress

Vault:Item: vault

Wallet Address:Prop: walletAddress

Check Pending Status

Action

Params:{{$workflowId}}

Sql:SELECT pending FROM rebalance_flags WHERE id = 'nest-rebalance' AND workflow_id = $1

Check Timeout Status

Action

Params:{{$workflowId}}

Sql:SELECT pending FROM rebalance_flags WHERE id = 'nest-rebalance' AND workflow_id = $1

Clear Pending Flag

Action

Params:{{$workflowId}}

Sql:UPDATE rebalance_flags SET pending = 0 WHERE id = 'nest-rebalance' AND workflow_id = $1

Set Pending Flag

Action

Params:{{$workflowId}}

Sql:INSERT INTO rebalance_flags (id, workflow_id, pending) VALUES ('nest-rebalance', $1, 1) ON CONFLICT (id, workflow_id) DO UPDATE SET pending = EXCLUDED.pending

Wait 15 Minutes

Action

Delay Ms:900000 (15m)

Deposit {{$item.amountPusdRaw}}

Action

Amount Pusd Raw:Item: amountPusdRaw

Teller Address:Item: tellerAddress

Vault:Item: vault

Deposit {{$item.amountPusdRaw}}

Action

Amount Pusd Raw:Item: amountPusdRaw

Teller Address:Item: tellerAddress

Vault:Item: vault

Detect Vault Balances

Action

Wallet Address:Prop: walletAddress

Fetch Vault APYs

Action

Min Tvl:100000

Vault Filter:boring

foreach-check

Action

Array:calculate:withdrawals

foreach-deposit

Action

Array:calculate:deposits

foreach-deposit-direct

Action

Array:calculate:deposits

foreach-retry

Action

Array:calculate:retryArray

foreach-withdraw

Action

Array:calculate:withdrawals

Format Skip Message

Action

Code:function transform(input) { var a = input.addr || ''; var s = a.slice(0,6) + '...' + a.slice(-4); var walletLine = a ? 'Wallet: <a href="https://explorer.plume.org/address/' + a + '">' + s + '</a>' : 'Wallet: Not available'; var lines = ['Nest Vault Rebalance \u2014 No Action Needed', '', walletLine, '']; lines.push(input.summary || 'No rebalancing required.'); var balances = input.balances || []; var hasHoldings = false; for (var i = 0; i < balances.length; i++) { if (balances[i].symbol !== 'pUSD' && Number(balances[i].balanceRaw) > 0) { if (!hasHoldings) { lines.push(''); lines.push('Current Holdings'); hasHoldings = true; } lines.push(balances[i].symbol + ': ' + balances[i].balanceFormatted + ' ($' + (balances[i].valuePusd || '?') + ')'); } } return lines.join('\n'); }

Input:{"addr":"{{$props.walletAddress}}","balances":"{{detect-balance.result.balances}}","summary":"{{calculate.result.summary}}"}

Format Success Message

Action

Code:function transform(input) { var a = input.addr || ''; var s = a.slice(0,6) + '...' + a.slice(-4); var walletLine = a ? 'Wallet: <a href="https://explorer.plume.org/address/' + a + '">' + s + '</a>' : 'Wallet: Not available'; var lines = ['Nest Vault Rebalance Complete', '', walletLine, '']; var ws = input.withdrawals || []; if (ws.length > 0) { lines.push('Withdrawals'); for (var i = 0; i < ws.length; i++) { lines.push(ws[i].vault + ': ' + (ws[i].estimatedPusdValue || ws[i].amountFormatted || '?') + ' pUSD'); } lines.push(''); } var ds = input.deposits || []; if (ds.length > 0) { lines.push('Deposits'); for (var i = 0; i < ds.length; i++) { lines.push(ds[i].vault + ': ' + (ds[i].amountPusdFormatted || '?') + ' pUSD'); } lines.push(''); } lines.push('All withdrawals fulfilled and deposits executed.'); return lines.join('\n'); }

Input:{"addr":"{{$props.walletAddress}}","deposits":"{{calculate.result.deposits}}","withdrawals":"{{calculate.result.withdrawals}}"}

Format Timeout Message

Action

Input:{"addr":"{{$props.walletAddress}}"}

if-all-fulfilled

Action

Condition:{"$and":[{"{{all-fulfilled-check.result.output.allFulfilled}}":{"$eq":true}}]}

if-has-withdrawals

Action

Condition:{"$and":[{"{{calculate.result.hasWithdrawals}}":{"$eq":true}}]}

if-needs-rebalance

Action

Condition:{"$and":[{"{{calculate.result.needsRebalance}}":{"$eq":true}}]}

if-still-pending

Action

Condition:{"$and":[{"{{db-check-pending.result.rows[0].pending}}":{"$eq":1}}]}

if-timeout

Action

Condition:{"$and":[{"{{db-check-timeout.result.rows[0].pending}}":{"$eq":1}}]}

root

Action

Schedule:

Every day at 8 AM UTC

send-message_oy_eNK

Message configured

Alert Withdrawal Timeout

Message configured

send-skip

Message configured

Withdraw {{$item.amountRaw}}

Action

Amount Raw:Item: amountRaw

Token:Item: tokenAddress

Vault:Item: vault

Loading chat...

Preview

Check All Fulfilled

Action

Code:function transform(input) { return { allFulfilled: input.every(i => i['check-withdrawal-action'].fulfilled) }; }

Input:foreach-check:iterations

Input Type:{"type":"array"}

Output Type:{"properties":{"allFulfilled":{"type":"boolean"}},"type":"object"}

calculate

Action

Balances:Detect Vault Balances:balances

Max Allocation Percent:0.5

Min Allocation Percent:0.05

Min Apy Differential:0.01

Min Rebalance Value Pusd:0.001

Vault Apys:Fetch Vault APYs:vaultApys

check-withdrawal-action

Action

Token:Item: tokenAddress

Vault:Item: vault

Wallet Address:Prop: walletAddress

Check Pending Status

Action

Params:{{$workflowId}}

Sql:SELECT pending FROM rebalance_flags WHERE id = 'nest-rebalance' AND workflow_id = $1

Check Timeout Status

Action

Params:{{$workflowId}}

Sql:SELECT pending FROM rebalance_flags WHERE id = 'nest-rebalance' AND workflow_id = $1

Clear Pending Flag

Action

Params:{{$workflowId}}

Sql:UPDATE rebalance_flags SET pending = 0 WHERE id = 'nest-rebalance' AND workflow_id = $1

Set Pending Flag

Action

Params:{{$workflowId}}

Sql:INSERT INTO rebalance_flags (id, workflow_id, pending) VALUES ('nest-rebalance', $1, 1) ON CONFLICT (id, workflow_id) DO UPDATE SET pending = EXCLUDED.pending

Wait 15 Minutes

Action

Delay Ms:900000 (15m)

Deposit {{$item.amountPusdRaw}}

Action

Amount Pusd Raw:Item: amountPusdRaw

Teller Address:Item: tellerAddress

Vault:Item: vault

Deposit {{$item.amountPusdRaw}}

Action

Amount Pusd Raw:Item: amountPusdRaw

Teller Address:Item: tellerAddress

Vault:Item: vault

Detect Vault Balances

Action

Wallet Address:Prop: walletAddress

Fetch Vault APYs

Action

Min Tvl:100000

Vault Filter:boring

foreach-check

Action

Array:calculate:withdrawals

foreach-deposit

Action

Array:calculate:deposits

foreach-deposit-direct

Action

Array:calculate:deposits

foreach-retry

Action

Array:calculate:retryArray

foreach-withdraw

Action

Array:calculate:withdrawals

Format Skip Message

Action

Input:{"addr":"{{$props.walletAddress}}","balances":"{{detect-balance.result.balances}}","summary":"{{calculate.result.summary}}"}

Format Success Message

Action

Code:function transform(input) { var a = input.addr || ''; var s = a.slice(0,6) + '...' + a.slice(-4); var walletLine = a ? 'Wallet: <a href="https://explorer.plume.org/address/' + a + '">' + s + '</a>' : 'Wallet: Not available'; var lines = ['Nest Vault Rebalance Complete', '', walletLine, '']; var ws = input.withdrawals || []; if (ws.length > 0) { lines.push('Withdrawals'); for (var i = 0; i < ws.length; i++) { lines.push(ws[i].vault + ': ' + (ws[i].estimatedPusdValue || ws[i].amountFormatted || '?') + ' pUSD'); } lines.push(''); } var ds = input.deposits || []; if (ds.length > 0) { lines.push('Deposits'); for (var i = 0; i < ds.length; i++) { lines.push(ds[i].vault + ': ' + (ds[i].amountPusdFormatted || '?') + ' pUSD'); } lines.push(''); } lines.push('All withdrawals fulfilled and deposits executed.'); return lines.join('\n'); }

Input:{"addr":"{{$props.walletAddress}}","deposits":"{{calculate.result.deposits}}","withdrawals":"{{calculate.result.withdrawals}}"}

Format Timeout Message

Action

Input:{"addr":"{{$props.walletAddress}}"}

if-all-fulfilled

Action

Condition:{"$and":[{"{{all-fulfilled-check.result.output.allFulfilled}}":{"$eq":true}}]}

if-has-withdrawals

Action

Condition:{"$and":[{"{{calculate.result.hasWithdrawals}}":{"$eq":true}}]}

if-needs-rebalance

Action

Condition:{"$and":[{"{{calculate.result.needsRebalance}}":{"$eq":true}}]}

if-still-pending

Action

Condition:{"$and":[{"{{db-check-pending.result.rows[0].pending}}":{"$eq":1}}]}

if-timeout

Action

Condition:{"$and":[{"{{db-check-timeout.result.rows[0].pending}}":{"$eq":1}}]}

root

Action

Schedule:

Every day at 8 AM UTC

send-message_oy_eNK

Message configured

Alert Withdrawal Timeout

Message configured

send-skip

Message configured

Withdraw {{$item.amountRaw}}

Action

Amount Raw:Item: amountRaw

Token:Item: tokenAddress

Vault:Item: vault

Manage Account

Archive Workflow

Plume: Auto-Rebalance your Nest Vaults Daily

About

Preview

Plume: Auto-Rebalance your Nest Vaults Daily

About

Preview