DGF
/
dgf-prototype
6
0
Fork 0
Code Issues 7 Pull Requests Actions Packages Projects Releases Wiki Activity

minor refactor, add additional subdir for rollup
Gitea Actions Demo / Explore-Gitea-Actions (push) Failing after 29s Details

This commit is contained in:
Ladd Hoffman 2024-05-09 12:06:09 -05:00
parent f266f2c261
commit 72e16651fb
9 changed files with 19 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
backend/src/event-handlers/rollup/batch-items.js → backend/src/event-handlers/rollup/batch/batch-items.js
View File

@ -1,4 +1,4 @@
const { applicationData } = require('../../util/db');
const { applicationData } = require('../../../util/db');
let batchItems;

2
backend/src/event-handlers/rollup/batch-worker.js → backend/src/event-handlers/rollup/batch/batch-worker.js
View File

@ -1,4 +1,4 @@
const { rollup, wallet } = require('../../util/contracts');
const { rollup, wallet } = require('../../../util/contracts');
let batchWorker;
let batchStart;

4
backend/src/event-handlers/rollup/compute-author-weights.js → backend/src/event-handlers/rollup/batch/compute-author-weights.js
View File

@ -1,6 +1,6 @@
const Promise = require('bluebird');
const read = require('../../util/forum/read');
const { matrixPools } = require('../../util/db');
const read = require('../../../util/forum/read');
const { matrixPools } = require('../../../util/db');
const computeAuthorWeights = async (batchItems_) => {
const weights = {};

0
backend/src/event-handlers/rollup/compute-author-weights.test.js → backend/src/event-handlers/rollup/batch/compute-author-weights.test.js
View File

2
backend/src/event-handlers/rollup/fetch-batch-items-info.js → backend/src/event-handlers/rollup/batch/fetch-batch-items-info.js
View File

@ -1,4 +1,4 @@
const { rollup } = require('../../util/contracts');
const { rollup } = require('../../../util/contracts');
const fetchBatchItemsInfo = async () => {
// Read from Rollup.items

12
backend/src/event-handlers/rollup/submit-rollup.js → backend/src/event-handlers/rollup/batch/submit-rollup.js
View File

@ -1,13 +1,13 @@
const { v4: uuidv4 } = require('uuid');
const write = require('../../util/forum/write');
const addPostWithRetry = require('../../util/add-post-with-retry');
const callWithRetry = require('../../util/call-with-retry');
const write = require('../../../util/forum/write');
const addPostWithRetry = require('../../../util/add-post-with-retry');
const callWithRetry = require('../../../util/call-with-retry');
const { getBatchItems, clearBatchItems } = require('./batch-items');
const computeAuthorWeights = require('./compute-author-weights');
const { wallet, rollup } = require('../../util/contracts');
const { sendMatrixEvent } = require('../../matrix-bot');
const { stakeRollupAvailability } = require('./utils');
const { wallet, rollup } = require('../../../util/contracts');
const { sendMatrixEvent } = require('../../../matrix-bot');
const { stakeRollupAvailability } = require('../utils');
const fetchBatchItemsInfo = require('./fetch-batch-items-info');
const submitRollup = async () => {

6
backend/src/event-handlers/rollup/index.js
View File

@ -12,11 +12,11 @@ const {
stakeRollupAvailability, authorsMatch, validatePost,
} = require('./utils');
const computeMatrixPoolResult = require('./matrix-pools/compute-result');
const { initializeBatchItems, addBatchItem, clearBatchItems } = require('./batch-items');
const { getCurrentBatchWorker, initializeBatchWorker } = require('./batch-worker');
const { initializeBatchItems, addBatchItem, clearBatchItems } = require('./batch/batch-items');
const { getCurrentBatchWorker, initializeBatchWorker } = require('./batch/batch-worker');
const initiateMatrixPool = require('./matrix-pools/initiate');
const { initiateMatrixPools } = require('./matrix-pools/initiate-matrix-pools');
const computeAuthorWeights = require('./compute-author-weights');
const computeAuthorWeights = require('./batch/compute-author-weights');
const start = async () => {
console.log('registering validation pool decider for rollup');

6
backend/src/event-handlers/rollup/matrix-pools/evaluate.js
View File

@ -1,11 +1,11 @@
const { sendMatrixEvent } = require('../../../matrix-bot');
const { wallet } = require('../../../util/contracts');
const { matrixPools } = require('../../../util/db');
const { addBatchItem, getBatchItems } = require('../batch-items');
const { getCurrentBatchWorker, getBatchAge } = require('../batch-worker');
const { addBatchItem, getBatchItems } = require('../batch/batch-items');
const { getCurrentBatchWorker, getBatchAge } = require('../batch/batch-worker');
const computeMatrixPoolResult = require('./compute-result');
const { rollupInterval } = require('../config');
const submitRollup = require('../submit-rollup');
const submitRollup = require('../batch/submit-rollup');
const { stakeRollupAvailability } = require('../utils');
const evaluateMatrixPoolOutcome = async (postId) => {

4
backend/src/event-handlers/rollup/matrix-pools/initiate-matrix-pools.js
View File

@ -2,8 +2,8 @@ const Promise = require('bluebird');
const { matrixPools } = require('../../../util/db');
const read = require('../../../util/forum/read');
const initiateMatrixPool = require('./initiate');
const { addBatchItem, getBatchItems } = require('../batch-items');
const fetchBatchItemsInfo = require('../fetch-batch-items-info');
const { addBatchItem, getBatchItems } = require('../batch/batch-items');
const fetchBatchItemsInfo = require('../batch/fetch-batch-items-info');
const initiateMatrixPools = async () => {
const batchItemsInfo = await fetchBatchItemsInfo();