tornado-packages/tornado-core
1
0
Fork 1
Code Pull Requests Activity

Compare commits

base: tornado-packages:49a5ba7a2d8c5f04dc43961f9bd16b782a6fce13
Branches Tags
tornado-packages:main
..
compare: tornado-packages:eff65cd13dc371bf0b7c5e4a863c6dc34247bd9c
Branches Tags
tornado-packages:main

1 Commits
49a5ba7a2d ... eff65cd13d

Author SHA1 Message Date
tornadocontrib
eff65cd13d
Add BaseMultiTornadoService 2024-11-18 07:27:31 +00:00
5 changed files with 21 additions and 48 deletions
Show Stats Expand all files Collapse all files

16
dist/index.js vendored
View File

@ -2484,16 +2484,10 @@ class BaseMultiTornadoService extends BaseEventsService {
events, events,
newEvents newEvents
}) { }) {
const instancesWithNewEvents = [ const instancesWithNewEvents = Object.keys(this.instances).filter(
...new Set( (i) => newEvents.find(({ instanceAddress, event }) => instanceAddress === i && event === "Deposit")
newEvents.filter(({ event }) => event === "Deposit").map(({ instanceAddress }) => instanceAddress) );
)
];
let tree; let tree;
const requiredTree = this.merkleTreeService?.Tornado?.target;
if (requiredTree && !instancesWithNewEvents.includes(requiredTree)) {
instancesWithNewEvents.push(requiredTree);
}
for (const instance of instancesWithNewEvents) { for (const instance of instancesWithNewEvents) {
const depositEvents = events.filter( const depositEvents = events.filter(
({ instanceAddress, event }) => instanceAddress === instance && event === "Deposit" ({ instanceAddress, event }) => instanceAddress === instance && event === "Deposit"
@ -2503,8 +2497,8 @@ class BaseMultiTornadoService extends BaseEventsService {
const errMsg = `Invalid deposit events for ${instance} wants ${depositEvents.length - 1} leafIndex have ${lastEvent.leafIndex}`; const errMsg = `Invalid deposit events for ${instance} wants ${depositEvents.length - 1} leafIndex have ${lastEvent.leafIndex}`;
throw new Error(errMsg); throw new Error(errMsg);
} }
if (requiredTree === instance && !this.optionalTree) { if (this.merkleTreeService?.Tornado?.target === instance && !this.optionalTree) {
tree = await this.merkleTreeService?.verifyTree(depositEvents); tree = await this.merkleTreeService.verifyTree(depositEvents);
} }
} }
return tree; return tree;

16
dist/index.mjs vendored
View File

@ -2462,16 +2462,10 @@ class BaseMultiTornadoService extends BaseEventsService {
events, events,
newEvents newEvents
}) { }) {
const instancesWithNewEvents = [ const instancesWithNewEvents = Object.keys(this.instances).filter(
...new Set( (i) => newEvents.find(({ instanceAddress, event }) => instanceAddress === i && event === "Deposit")
newEvents.filter(({ event }) => event === "Deposit").map(({ instanceAddress }) => instanceAddress) );
)
];
let tree; let tree;
const requiredTree = this.merkleTreeService?.Tornado?.target;
if (requiredTree && !instancesWithNewEvents.includes(requiredTree)) {
instancesWithNewEvents.push(requiredTree);
}
for (const instance of instancesWithNewEvents) { for (const instance of instancesWithNewEvents) {
const depositEvents = events.filter( const depositEvents = events.filter(
({ instanceAddress, event }) => instanceAddress === instance && event === "Deposit" ({ instanceAddress, event }) => instanceAddress === instance && event === "Deposit"
@ -2481,8 +2475,8 @@ class BaseMultiTornadoService extends BaseEventsService {
const errMsg = `Invalid deposit events for ${instance} wants ${depositEvents.length - 1} leafIndex have ${lastEvent.leafIndex}`; const errMsg = `Invalid deposit events for ${instance} wants ${depositEvents.length - 1} leafIndex have ${lastEvent.leafIndex}`;
throw new Error(errMsg); throw new Error(errMsg);
} }
if (requiredTree === instance && !this.optionalTree) { if (this.merkleTreeService?.Tornado?.target === instance && !this.optionalTree) {
tree = await this.merkleTreeService?.verifyTree(depositEvents); tree = await this.merkleTreeService.verifyTree(depositEvents);
} }
} }
return tree; return tree;

16
dist/tornado.umd.js vendored
View File

@ -90754,16 +90754,10 @@ class BaseMultiTornadoService extends BaseEventsService {
events, events,
newEvents newEvents
}) { }) {
const instancesWithNewEvents = [ const instancesWithNewEvents = Object.keys(this.instances).filter(
...new Set( (i) => newEvents.find(({ instanceAddress, event }) => instanceAddress === i && event === "Deposit")
newEvents.filter(({ event }) => event === "Deposit").map(({ instanceAddress }) => instanceAddress) );
)
];
let tree; let tree;
const requiredTree = this.merkleTreeService?.Tornado?.target;
if (requiredTree && !instancesWithNewEvents.includes(requiredTree)) {
instancesWithNewEvents.push(requiredTree);
}
for (const instance of instancesWithNewEvents) { for (const instance of instancesWithNewEvents) {
const depositEvents = events.filter( const depositEvents = events.filter(
({ instanceAddress, event }) => instanceAddress === instance && event === "Deposit" ({ instanceAddress, event }) => instanceAddress === instance && event === "Deposit"
@ -90773,8 +90767,8 @@ class BaseMultiTornadoService extends BaseEventsService {
const errMsg = `Invalid deposit events for ${instance} wants ${depositEvents.length - 1} leafIndex have ${lastEvent.leafIndex}`; const errMsg = `Invalid deposit events for ${instance} wants ${depositEvents.length - 1} leafIndex have ${lastEvent.leafIndex}`;
throw new Error(errMsg); throw new Error(errMsg);
} }
if (requiredTree === instance && !this.optionalTree) { if (this.merkleTreeService?.Tornado?.target === instance && !this.optionalTree) {
tree = await this.merkleTreeService?.verifyTree(depositEvents); tree = await this.merkleTreeService.verifyTree(depositEvents);
} }
} }
return tree; return tree;

2
dist/tornado.umd.min.js vendored
View File

File diff suppressed because one or more lines are too long

19
src/events/base.ts
View File

@ -566,21 +566,12 @@ export class BaseMultiTornadoService extends BaseEventsService<MultiDepositEvent
}: BaseEvents<MultiDepositEvents | MultiWithdrawalsEvents> & { }: BaseEvents<MultiDepositEvents | MultiWithdrawalsEvents> & {
newEvents: (MultiDepositEvents | MultiWithdrawalsEvents)[]; newEvents: (MultiDepositEvents | MultiWithdrawalsEvents)[];
}) { }) {
const instancesWithNewEvents = [ const instancesWithNewEvents = Object.keys(this.instances).filter((i) =>
...new Set( newEvents.find(({ instanceAddress, event }) => instanceAddress === i && event === 'Deposit'),
newEvents.filter(({ event }) => event === 'Deposit').map(({ instanceAddress }) => instanceAddress), );
),
];
let tree: S | undefined; let tree: S | undefined;
const requiredTree = this.merkleTreeService?.Tornado?.target as string | undefined;
// Audit and create deposit tree
if (requiredTree && !instancesWithNewEvents.includes(requiredTree)) {
instancesWithNewEvents.push(requiredTree);
}
for (const instance of instancesWithNewEvents) { for (const instance of instancesWithNewEvents) {
const depositEvents = events.filter( const depositEvents = events.filter(
({ instanceAddress, event }) => instanceAddress === instance && event === 'Deposit', ({ instanceAddress, event }) => instanceAddress === instance && event === 'Deposit',
@ -593,8 +584,8 @@ export class BaseMultiTornadoService extends BaseEventsService<MultiDepositEvent
throw new Error(errMsg); throw new Error(errMsg);
} }
if (requiredTree === instance && !this.optionalTree) { if (this.merkleTreeService?.Tornado?.target === instance && !this.optionalTree) {
tree = (await this.merkleTreeService?.verifyTree(depositEvents)) as S; tree = (await this.merkleTreeService.verifyTree(depositEvents)) as S;
} }
} }