index.js

import { readFile } from 'fs/promises';
import transportLocalFile from "./src/doichain/test/transportLocalFile.js"
import createOrReadPeerId from './src/p2p/createOrReadPeerId.js'
import createNode from './src/p2p/createNode.js'
import peerDiscovery from './src/p2p/peerDiscovery.js'
import quiz from './src/p2p/quiz.js'
import { createOrReadSeed } from "./src/p2p/createOrReadSeed.js";
import { network } from 'doichainjs-lib';
import { createNewWallet } from "doichainjs-lib";
import { s } from "./src/p2p/sharedState.js";
import { createRequire } from "module";
import OrbitDb from 'orbit-db';
const require = createRequire(import.meta.url);
const ElectrumClient = require('@codewarriorr/electrum-client-js')
import 'dotenv/config'
const ORBIT_DB = process.env.ORBIT_DB
const IPFS = require('ipfs')
import bootstrapers from './src/p2p/peerIds/bootstrapers.js'


import * as ipfs from 'ipfs-core'
s.ipfs = await ipfs.create()

var peerIdConf
var id
var node
var firstPeer


const main = async () => {
  const settingsTable = JSON.parse(await readFile(new URL('./settings.json', import.meta.url)));

  s.options = settingsTable.options

  transportLocalFile(s.options.transportLocalFilePath);

  // Start Quiz
  console.info('Starting p2p Quiz')

  peerIdConf = process.env.PEER;

  id = await createOrReadPeerId(peerIdConf)

  s.node = await createNode(id)

  await peerDiscovery(s.node)

  s.id = id.toB58String()
  s.network = network.DOICHAIN_REGTEST

  global.DEFAULT_NETWORK = network.DOICHAIN_REGTEST

  let o_options

  // check if seed file is available

  s.addrType = "p2wpkh"

  switch (s.addrType) {
    case "p2pkh":
      s.purpose = "m/44"
      break;
    case "p2sh":
      s.purpose = "m/49"
      break;
    case "p2wpkh":
      s.purpose = "m/84"
      break;
  }

  s.coinType = global.DEFAULT_NETWORK.name == "mainnet" ? 0 : 1
  s.account = 0
  s.basePath = `${s.purpose}/${s.coinType}/${s.account}`

  global.client = new ElectrumClient("172.22.0.6", 50002, "ssl");
  try {
    await global.client.connect(
      "electrum-client-js", // optional client name
      "1.4.2" // optional protocol version
    )
  } catch (err) {
    console.error(err);
  }

  await createOrReadSeed(id)
  s.wallet = await createNewWallet(s.hdkey, s.purpose, s.coinType, o_options, s.addrType, s.id)

  if (ORBIT_DB !== "") {

    // Create OrbictDB
    s.orbitDb = await OrbitDb.createInstance(s.ipfs, { directory: './orbitdb1' })

    // Create docstore DB
    s.docstore = await s.orbitDb.open(ORBIT_DB);
    console.log("Successfully created docstore");

    await s.docstore.load()

    await s.docstore.events.on('replicated', () => console.log("Replicated Db"))

  }

  function getWinnerPeerId() {
    if (peerIdConf.includes('id-1')) {
      firstPeer = true
      quiz(firstPeer)
    } else {
      firstPeer = false
      quiz(firstPeer)
    }
  }

  getWinnerPeerId()
}

main()