added possible openRound to py library
This commit is contained in:
parent
b5da4ecb52
commit
6307acb27d
|
@ -63,6 +63,8 @@ class AggregatorSaveResultParams:
|
||||||
"""List of parsed oracles"""
|
"""List of parsed oracles"""
|
||||||
oracles: list[Any]
|
oracles: list[Any]
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
# Parameters for creating and setting a history buffer
|
# Parameters for creating and setting a history buffer
|
||||||
@dataclass
|
@dataclass
|
||||||
class AggregatorSetHistoryBufferParams:
|
class AggregatorSetHistoryBufferParams:
|
||||||
|
@ -558,6 +560,49 @@ class AggregatorAccount:
|
||||||
]
|
]
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
|
|
||||||
|
# TODO: Verify this function
|
||||||
|
async def open_round(self, params: AggregatorOpenRoundParams):
|
||||||
|
program = self.program
|
||||||
|
authority = params.authority or self.keypair
|
||||||
|
state_account, state_bump = ProgramStateAccount.from_seed(program)
|
||||||
|
mint = await state_account.get_token_mint()
|
||||||
|
queue = await params.oracle_queue_account.load_data()
|
||||||
|
lease_account, lease_bump = LeaseAccount.from_seed(
|
||||||
|
self.program,
|
||||||
|
queue_account,
|
||||||
|
self
|
||||||
|
)
|
||||||
|
lease = await lease_account.load_data()
|
||||||
|
permission_account, permission_bump = PermissionAccount.from_seed(
|
||||||
|
self.program,
|
||||||
|
queue.authority,
|
||||||
|
params.oracle_queue_account.public_key,
|
||||||
|
self.public_key
|
||||||
|
)
|
||||||
|
await program.rpc["aggregator_open_round"](
|
||||||
|
{
|
||||||
|
"state_bump": state_bump,
|
||||||
|
"lease_bump": lease_bump,
|
||||||
|
"permission_bump": permission_bump,
|
||||||
|
},
|
||||||
|
ctx=anchorpy.Context(
|
||||||
|
accounts={
|
||||||
|
"aggregator": self.public_key,
|
||||||
|
"lease": self.public_key,
|
||||||
|
"oracle_queue": self.public_key,
|
||||||
|
"queue_authority": queue.authority,
|
||||||
|
"permission": permission_account.public_key,
|
||||||
|
"escrow": lease.escrow,
|
||||||
|
"program_state": state_account.public_key,
|
||||||
|
"payout_wallet": params.payout_wallet,
|
||||||
|
"token_program": TOKEN_PROGRAM_ID,
|
||||||
|
"data_buffer": queue.data_buffer,
|
||||||
|
"mint": mint.public_key,
|
||||||
|
},
|
||||||
|
signers=[self.keypair]
|
||||||
|
)
|
||||||
|
)
|
||||||
|
|
||||||
"""
|
"""
|
||||||
RPC to add a new job to an aggregtor to be performed on feed updates.
|
RPC to add a new job to an aggregtor to be performed on feed updates.
|
||||||
|
|
Loading…
Reference in New Issue