Skip to content

Commit

Permalink
feat(api): load data feeds from config json file
Browse files Browse the repository at this point in the history
  • Loading branch information
Tommytrg committed Aug 10, 2021
1 parent 1cd65ad commit d12bd11
Show file tree
Hide file tree
Showing 3 changed files with 23 additions and 11 deletions.
2 changes: 1 addition & 1 deletion packages/api/src/dataFeeds.json
Original file line number Diff line number Diff line change
Expand Up @@ -71,4 +71,4 @@
"abi": "./abi/WitnetRequestBoardProxy.json"
}
}
]
]
26 changes: 17 additions & 9 deletions packages/api/src/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -35,18 +35,26 @@ async function main () {
})
}

function readDataFeeds(): Array<FeedInfo> {
const dataFeeds: Array<FeedInfoConfig> = JSON.parse(fs.readFileSync(path.join(__dirname, '/dataFeeds.json'), 'utf-8'))
function readDataFeeds (): Array<FeedInfo> {
const dataFeeds: Array<FeedInfoConfig> = JSON.parse(
fs.readFileSync(path.join(__dirname, '/dataFeeds.json'), 'utf-8')
)

return dataFeeds.map(dataFeed => ({
...dataFeed,
abi: JSON.parse(fs.readFileSync(path.join(__dirname, dataFeed.abi), 'utf-8')),
witnetRequestBoard: {
...dataFeed.witnetRequestBoard,
abi: JSON.parse(fs.readFileSync(path.join(__dirname, dataFeed.witnetRequestBoard.abi), 'utf-8'))
}
...dataFeed,
abi: JSON.parse(
fs.readFileSync(path.join(__dirname, dataFeed.abi), 'utf-8')
),
witnetRequestBoard: {
...dataFeed.witnetRequestBoard,
abi: JSON.parse(
fs.readFileSync(
path.join(__dirname, dataFeed.witnetRequestBoard.abi),
'utf-8'
)
)
}
))
}))
}

main()
6 changes: 5 additions & 1 deletion packages/api/src/repository/Feed.ts
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,11 @@ export class FeedRepository {
}

async getAll () {
return (await this.collection.find({ address: { $in: this.dataFeedsAddresses }}).toArray()).map(this.normalizeId)
return (
await this.collection
.find({ address: { $in: this.dataFeedsAddresses } })
.toArray()
).map(this.normalizeId)
}

async insert (feed: Omit<FeedDbObject, '_id'>) {
Expand Down

0 comments on commit d12bd11

Please sign in to comment.