feat(add on event): add on event

Author: Littleor

example/basic-dapp/index.js

@@ -361,15 +361,18 @@ async function walletInitialized() {
   }
 
   provider.on('accountsChanged', (accounts) => {
-    console.log('accountsChcanged, accounts = ', accounts)
+    console.log('accountsChanged, accounts = ', accounts)
     if (!accounts.length) return unAuthed()
     authed(accounts[0])
   })
 
   provider.on('chainChanged', (chainId) => {
+    console.log('chainChanged called', chainId)
     getElement('chainId').innerHTML = chainId
     provider.request({ method: 'cfx_netVersion' }).then((networkId) => {
-      getElement('networkId').innerHTML = networkId
+      setTimeout(() => {
+        getElement('networkId').innerHTML = networkId
+      }, 800)
     })
   })
 

src/config.ts

@@ -2,5 +2,5 @@
  * @author Littleor <me@littleor.cn>
  * @since 2022/2/12
  */
-export const BASE_URL = 'http://192.168.31.149:10086/#/'
+export const BASE_URL = 'https://app.anyweb.cc/#/'
 export const API_BASE_URL = 'https://api.anyweb.cc'

src/provider.ts

@@ -8,10 +8,16 @@ import {
   IProvider,
   IRequestArguments,
 } from './interface/provider'
-import { ConsoleLike, IAuthResult } from './utils/types'
+import {
+  IAuthResult,
+  IProviderConnectInfo,
+  IProviderRpcError,
+} from './utils/interface'
 import { callIframe, readCache, setCache } from './utils/common'
 import config from '../package.json'
 import { AddressType, getAddressType } from './utils/address'
+import { IProviderMessage } from './utils/interface'
+import { ConsoleLike } from './utils/types'
 
 /**
  * AnyWeb Provider
@@ -27,6 +33,15 @@ export class Provider implements IProvider {
   address: string[] = []
   networkId = -1
   chainId = -1
+  url = ''
+  events: {
+    onConnect?: (connectInfo: IProviderConnectInfo) => void
+    onDisconnect?: (error: IProviderRpcError) => void
+    onChainChanged?: (chainId: string) => void
+    onAccountsChanged?: (accounts: string[]) => void
+    onMessage?: (message: IProviderMessage) => void
+    onNetworkChanged?: (networkId: string) => void
+  } = {}
 
   constructor({ logger, appId }: BaseProviderOptions) {
     if (!logger) {
@@ -139,6 +154,12 @@ export class Provider implements IProvider {
           authType: 'account',
         })) as IAuthResult
         setCache(result, this)
+        this.events.onAccountsChanged &&
+          this.events.onAccountsChanged(result.address)
+        this.events.onChainChanged &&
+          this.events.onChainChanged(String(result.chainId))
+        this.events.onNetworkChanged &&
+          this.events.onNetworkChanged(String(result.networkId))
         return this.address
       case 'cfx_sendTransaction':
         const paramsObj = params
@@ -187,5 +208,27 @@ export class Provider implements IProvider {
       type,
       listener,
     })
+    switch (type) {
+      case 'connect':
+        this.events.onConnect = listener
+        break
+      case 'disconnect':
+        this.events.onDisconnect = listener
+        break
+      case 'chainChanged':
+        this.events.onChainChanged = listener
+        break
+      case 'accountsChanged':
+        this.events.onAccountsChanged = listener
+        break
+      case 'message':
+        this.events.onMessage = listener
+        break
+      case 'networkChanged':
+        this.events.onNetworkChanged = listener
+        break
+      default:
+        break
+    }
   }
 }

src/utils/common.ts

@@ -5,7 +5,7 @@
 import * as forge from 'node-forge'
 import axios from 'axios'
 import { API_BASE_URL, BASE_URL } from '../config'
-import { IAuthResult } from './types'
+import { IAuthResult } from './interface'
 import { Provider } from '../provider'
 
 /**
@@ -125,6 +125,7 @@ export const readCache = (provider: Provider) => {
       provider.address = result.address
       provider.networkId = result.networkId
       provider.chainId = result.chainId
+      provider.url = result.url
     }
   } catch (e) {
     provider.logger.error(e)
@@ -137,11 +138,12 @@ export const setCache = (data: IAuthResult, provider: Provider) => {
       'anyweb_info',
       JSON.stringify({
         ...data,
-        expires: 10 * 60 * 1000 + new Date().getTime(),
+        expires: 1 * 60 * 1000 + new Date().getTime(),
       })
     )
   provider.address = data.address
   provider.networkId = data.networkId
   provider.chainId = data.chainId
+  provider.url = data.url
   return data
 }

src/utils/interface.ts

@@ -0,0 +1,26 @@
+/**
+ * @author Littleor <me@littleor.cn>
+ * @since 2022/2/18
+ */
+
+export interface IAuthResult {
+  chainId: number
+  networkId: number
+  address: string[]
+  url: string
+}
+
+export interface IProviderRpcError extends Error {
+  message: string
+  code: number
+  data?: unknown
+}
+
+export interface IProviderConnectInfo {
+  readonly chainId: string
+}
+
+export interface IProviderMessage {
+  readonly type: string
+  readonly data: unknown
+}

src/utils/types.ts

@@ -6,9 +6,3 @@ export type ConsoleLike = Pick<
   Console,
   'log' | 'warn' | 'error' | 'debug' | 'info' | 'trace'
 >
-
-export interface IAuthResult {
-  chainId: number
-  networkId: number
-  address: string[]
-}