API tools faq
paste
Guest User

Full JS code

a guest
Oct 6th, 2020
211
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
JavaScript 4.16 KB | None | 0 0
raw download clone embed print report
  1. "use strict"
  2.  
  3. const { Wallets, Gateway } = require("fabric-network")
  4. const fs = require("fs")
  5. const path = require("path")
  6. const net = require("net")
  7.  
  8. const blockProcessing = require("./blockProcessing.js")
  9.  
  10. const config = require("./config.json")
  11. const channelid = config.channelid
  12. const sdkUser = config.sdk_user
  13. const sdkAddress = config.sdk_address
  14. const sdkPort = config.sdk_port
  15. const healthPort = config.healthcheck_port
  16.  
  17. const configPath = path.resolve(__dirname, "nextblock.txt")
  18.  
  19. class BlockMap {
  20.     constructor() {
  21.         this.list = []
  22.     }
  23.     get(key) {
  24.         key = parseInt(key, 10).toString()
  25.         return this.list[`block${key}`]
  26.     }
  27.     set(key, value) {
  28.         this.list[`block${key}`] = value
  29.     }
  30.     remove(key) {
  31.         key = parseInt(key, 10).toString()
  32.         delete this.list[`block${key}`]
  33.     }
  34. }
  35.  
  36. let ProcessingMap = new BlockMap()
  37.  
  38. async function main() {
  39.     try {
  40.         const http = require('http');
  41.         /*const server = http.createServer((req, res)=>{
  42.             console.log(req.url, req.method, req. headers);
  43.             res.write('<html>');
  44.             res.write('<head><title>HLF Event Listener </title></head>');
  45.             res.write(' <body>HLF Event Listener Service is Up!</body>');
  46.             res.write('</html>');
  47.             res.end();
  48.         });
  49.         server.listen(healthPort);*/
  50.  
  51.         let nextBlock = 1
  52.         if (fs.existsSync(configPath)) {
  53.             nextBlock = fs.readFileSync(configPath, "utf8")
  54.         } else {
  55.             fs.writeFileSync(configPath, parseInt(nextBlock, 10))
  56.         }
  57.  
  58.         const walletPath = path.join(process.cwd(), "wallet")
  59.         const wallet = await Wallets.newFileSystemWallet(walletPath)
  60.         console.log(`Wallet path: ${walletPath}`)
  61.  
  62.         const userExists = await wallet.get(sdkUser)
  63.         if (!userExists) {
  64.             console.log(`An identity for the user "${sdkUser}" does not exist in the wallet`)
  65.             console.log("Run the enrollUser.js application before retrying")
  66.             return
  67.         }
  68.  
  69.         const ccpPath = path.resolve("connection-mtr.json")
  70.         const ccp = JSON.parse(fs.readFileSync(ccpPath, "utf8"))
  71.         const gateway = new Gateway()
  72.         await gateway.connect(ccp, { wallet, identity: sdkUser, discovery: { enabled: true, asLocalhost: false } })
  73.  
  74.         let network, listener
  75.         for (var i=0; i<channelid.length; i++) {
  76.             let cid = channelid[i]
  77.             console.log(`Adding listener for channel ${cid}`)
  78.             network = await gateway.getNetwork(cid)
  79.             console.log(`await gateway.getNetwork`)
  80.             listener = await network.addBlockListener(
  81.                 async (event) => {
  82.                     await ProcessingMap.set(event.blockData.header.number, event.blockData)
  83.                     console.log(`Added block ${event.blockData.header.number} to ProcessingMap`)
  84.                 },
  85.                 { startBlock: parseInt(nextBlock, 10) }
  86.             )
  87.             console.log(`await network.addBlockListener`)
  88.         };
  89.  
  90.         console.log(`Listening for block events, nextblock: ${nextBlock}`)
  91.         processPendingBlocks(ProcessingMap, channelid)
  92.     } catch (error) {
  93.         console.error(`Failed to evaluate transaction: ${error}`)
  94.         process.exit(1)
  95.     }
  96. }
  97.  
  98. async function processPendingBlocks(ProcessingMap, channelid) {
  99.     setTimeout(async () => {
  100.         let nextBlockNumber = fs.readFileSync(configPath, "utf8")
  101.         let processBlock
  102.  
  103.         do {
  104.             processBlock = ProcessingMap.get(nextBlockNumber)
  105.             if (processBlock == undefined) {
  106.                 break
  107.             }
  108.  
  109.             try {
  110.                 await blockProcessing.processBlockEvent(channelid, processBlock, sdkAddress, sdkPort)
  111.             } catch (error) {
  112.                 console.error(`Failed to process block: ${error}`)
  113.             }
  114.  
  115.             ProcessingMap.remove(nextBlockNumber)
  116.             fs.writeFileSync(configPath, parseInt(nextBlockNumber, 10) + 1)
  117.             nextBlockNumber = fs.readFileSync(configPath, "utf8")
  118.         } while (true)
  119.  
  120.         processPendingBlocks(ProcessingMap)
  121.     }, 250)
  122. }
  123.  
  124. main()
  125.  
Add Comment
Please, Sign In to add comment
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!