Skip to content

Commit 4d8f844

Browse files
authored
Merge pull request #177 from hack-a-chain-software/circulating-coins
fix: circulating coins file read
2 parents e089273 + 5d31e42 commit 4d8f844

File tree

5 files changed

+12
-5
lines changed

5 files changed

+12
-5
lines changed

Dockerfile

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@ RUN yarn install --frozen-lockfile
1212
COPY --from=builder /app/dist ./dist
1313
COPY --from=builder /app/src/config/global-bundle.pem ./dist/config/global-bundle.pem
1414
COPY --from=builder /app/src/kadena-server/config/schema.graphql ./dist/kadena-server/config/schema.graphql
15+
COPY --from=builder /app/src/circulating-coins/ ./dist/circulating-coins/
1516
EXPOSE 3001
1617

1718
CMD ["node", "dist/index.js", "--graphql"]

csvs/miner_rewards.csv renamed to indexer/src/circulating-coins/miner_rewards.csv

File renamed without changes.

csvs/token_payments.csv renamed to indexer/src/circulating-coins/token_payments.csv

File renamed without changes.

indexer/src/kadena-server/repository/infra/repository/network-db-repository.ts

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,8 @@ export default class NetworkDbRepository implements NetworkRepository {
5050

5151
const { rows } = await rootPgPool.query(creationTimeQuery);
5252

53-
const latestCreationTime = parseInt(rows[0].creationTime, 10);
53+
const firstRow = rows?.[0]?.creationTime;
54+
const latestCreationTime = parseInt(firstRow, 10);
5455

5556
return latestCreationTime;
5657
}

indexer/src/kadena-server/utils/coin-circulation.ts

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
import Papa from "papaparse";
22
import fs from "fs";
3+
import path from "path";
34

45
type RewardRow = [number, number];
56

@@ -92,17 +93,21 @@ async function getCsvContent(filePath: string): Promise<string> {
9293
}
9394

9495
async function getMinerRewards(cutHeight: number) {
95-
const csvContent = await getCsvContent(
96-
`${__dirname}/../../../../csvs/miner_rewards.csv`,
96+
const filePath = path.resolve(
97+
__dirname,
98+
"../../circulating-coins/miner_rewards.csv",
9799
);
100+
const csvContent = await getCsvContent(filePath);
98101
const reward = calculateReward(csvContent, cutHeight);
99102
return reward;
100103
}
101104

102105
async function getTokenPayments(latestCreationTime: number) {
103-
const csvContent = await getCsvContent(
104-
`${__dirname}/../../../../csvs/token_payments.csv`,
106+
const filePath = path.resolve(
107+
__dirname,
108+
"../../circulating-coins/token_payments.csv",
105109
);
110+
const csvContent = await getCsvContent(filePath);
106111
const tokenPayments = calculateTokenPayments(csvContent, latestCreationTime);
107112
return tokenPayments;
108113
}

0 commit comments

Comments
 (0)