All files / src/validator handlePeriod.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
1x
1x
1x
 
1x
7x
1x
 
 
7x
 
7x
 
5x
5x
 
 
 
5x
2x
1x
 
2x
2x
2x
2x
3x
2x
 
 
 
const startNewPeriod = require('./periods/startNewPeriod');
const submitPeriod = require('./periods/submitPeriod');
const saveSubmission = require('../utils/saveSubmission');
 
module.exports = async (height, bridgeState) => {
  if (height % 32 === 0) {
    await startNewPeriod(height, bridgeState);
  }
 
  const { periodProposal } = bridgeState;
 
  if (!periodProposal) return;
 
  const submission = bridgeState.submissions[periodProposal.blocksRoot];
  const submissionInDatabase = await bridgeState.db.getPeriodDataByBlocksRoot(
    periodProposal.blocksRoot
  );
 
  if (submission || submissionInDatabase) {
    if (!submissionInDatabase) {
      await saveSubmission(periodProposal, submission, bridgeState.db);
    }
    const { blocksRoot, periodRoot } = submission || submissionInDatabase;
    delete bridgeState.submissions[blocksRoot];
    bridgeState.lastProcessedPeriodRoot = periodRoot;
    bridgeState.periodProposal = null;
  } else if (!periodProposal.txHash) {
    await submitPeriod(periodProposal, bridgeState);
  }
};