1
0
mirror of https://github.com/oceanprotocol/commons.git synced 2023-03-15 18:03:00 +01:00
commons/client/src/App.tsx

291 lines
8.2 KiB
TypeScript

import React, { Component } from 'react'
import Web3 from 'web3'
import { BrowserRouter as Router } from 'react-router-dom'
import { Logger } from '@oceanprotocol/squid'
import Header from './components/organisms/Header'
import Footer from './components/organisms/Footer'
import Spinner from './components/atoms/Spinner'
import { User } from './context/User'
import { provideOcean } from './ocean'
import Routes from './Routes'
import './styles/global.scss'
import styles from './App.module.scss'
import {
nodeHost,
nodePort,
nodeScheme,
faucetHost,
faucetPort,
faucetScheme
} from './config/config'
const POLL_ACCOUNTS = 1000 // every 1s
const POLL_NETWORK = POLL_ACCOUNTS * 60 // every 1 min
declare global {
interface Window {
web3: Web3
ethereum: any
}
}
interface AppState {
isLogged: boolean
isLoading: boolean
isWeb3: boolean
isNile: boolean
account: string
balance: {
eth: number
ocn: number
}
network: string
web3: Web3
ocean: any
startLogin: () => void
message: string
}
class App extends Component<{}, AppState> {
private accountsInterval: any
private networkInterval: any
public startLogin = (event?: any) => {
if (event) {
event.preventDefault()
}
this.startLoginProcess()
}
private requestFromFaucet = async () => {
if (this.state.account !== '') {
try {
const response = await fetch(
`${faucetScheme}://${faucetHost}:${faucetPort}/faucet`,
{
method: 'POST',
headers: {
Accept: 'application/json',
'Content-Type': 'application/json'
},
body: JSON.stringify({
address: this.state.account,
agent: 'commons'
})
}
)
return response.json()
} catch (error) {
Logger.log('requestFromFaucet', error)
}
} else {
// no account found
}
}
public state = {
isLogged: false,
isLoading: true,
isWeb3: false,
isNile: false,
balance: {
eth: 0,
ocn: 0
},
network: '',
web3: new Web3(
new Web3.providers.HttpProvider(
`${nodeScheme}://${nodeHost}:${nodePort}`
)
),
account: '',
ocean: {} as any,
startLogin: this.startLogin,
requestFromFaucet: this.requestFromFaucet,
message: 'Connecting to Ocean...'
}
public async componentDidMount() {
await this.bootstrap()
// this.initAccountsPoll()
// this.initNetworkPoll()
}
private bootstrap = async () => {
try {
if (window.web3) {
let web3provider = new Web3(window.web3.currentProvider)
this.setState({
isWeb3: true,
message: 'Setting up Web3...'
})
//
// Detecting network with window.web3
//
let isNile
await web3provider.eth.net.getId((err, netId) => {
if (err) return
isNile = netId === 8995
this.setState({ isNile, network: netId.toString() })
})
if (!isNile) {
web3provider = this.state.web3
}
//
// Provide the Ocean
//
this.setState({ message: 'Connecting to Ocean...' })
const { ocean } = await provideOcean(web3provider)
this.setState({ ocean, isLoading: false })
// Get accounts
const accounts = await ocean.accounts.list()
if (accounts.length > 0) {
const balance = await accounts[0].getBalance()
this.setState({
isLogged: true,
balance,
account: accounts[0].getId()
})
}
} else {
//
// No Web3 browser
//
const { ocean } = await provideOcean(this.state.web3)
this.setState({ isLoading: false })
const network = await ocean.keeper.getNetworkName()
const isNile = network === 'Nile'
this.setState({
isNile,
ocean,
network
})
}
} catch (e) {
// error in bootstrap process
// show error connecting to ocean
Logger.log('web3 error', e)
this.setState({ isLoading: false })
}
}
private initAccountsPoll() {
if (!this.accountsInterval) {
this.accountsInterval = setInterval(
this.fetchAccounts,
POLL_ACCOUNTS
)
}
}
private initNetworkPoll() {
if (!this.networkInterval) {
this.networkInterval = setInterval(this.fetchNetwork, POLL_NETWORK)
}
}
private fetchAccounts = async () => {
const { web3 } = window
const { ocean } = this.state
if (web3) {
const accounts = await ocean.accounts.list()
if (accounts.length > 0) {
const account = accounts[0].getId()
if (account !== this.state.account) {
const balance = await accounts[0].getBalance()
this.setState({ account, balance, isLogged: true })
}
} else {
this.state.isLogged !== false &&
this.setState({ isLogged: false, account: '' })
}
} else {
this.state.isWeb3 !== false &&
this.setState({
isWeb3: false,
isLogged: false
})
}
}
private fetchNetwork = async () => {
const { web3 } = window
const { ocean } = this.state
if (web3) {
const network = await ocean.keeper.getNetworkName()
const isNile = network === 'Nile'
network !== this.state.network && this.setState({ isNile, network })
}
}
private startLoginProcess = async () => {
try {
if (this.state.isWeb3 && window.ethereum) {
await window.ethereum.enable()
const accounts = await this.state.ocean.accounts.list()
if (accounts.length > 0) {
const balance = await accounts[0].getBalance()
this.setState({
isLogged: true,
balance,
account: accounts[0].getId()
})
} else {
// not unlocked
}
} else {
// no metamask/mist, show installation guide!
}
} catch (e) {
Logger.log('error logging', e)
// error in logging process
// show error
// rerun bootstrap process?
}
}
public render() {
return (
<div className={styles.app}>
<User.Provider value={this.state}>
<Router>
<>
<Header />
<main className={styles.main}>
{this.state.isLoading ? (
<div className={styles.loader}>
<Spinner message={this.state.message} />
</div>
) : (
<Routes />
)}
</main>
<Footer />
</>
</Router>
</User.Provider>
</div>
)
}
}
export default App