mirror of https://gitlab.com/ecentrics/concordia
12 changed files with 339 additions and 1254 deletions
|
Before Width: | Height: | Size: 112 KiB |
|
After Width: | Height: | Size: 10 KiB |
@ -1,23 +0,0 @@ |
|||||
import level from 'level'; |
|
||||
|
|
||||
/* Used in development only to store the identity.signatures.publicKey so developers don't have to |
|
||||
repeatedly sign theOrbitDB creation transaction in MetaMask when React development server reloads |
|
||||
the app */ |
|
||||
const concordiaDB = level('./concordia/identities'); |
|
||||
|
|
||||
async function storeIdentitySignaturePubKey(key, signaturePubKey) { |
|
||||
await concordiaDB.put(key, signaturePubKey); |
|
||||
} |
|
||||
|
|
||||
// If it exists, it returns the identity.signatures.publicKey for the given key (key is the
|
|
||||
// concatenation of identity.publicKey + identity.signatures.id)
|
|
||||
async function getIdentitySignaturePubKey(key) { |
|
||||
try { |
|
||||
return await concordiaDB.get(key); |
|
||||
} catch (err) { |
|
||||
if (err && err.notFound) return null; // Not found
|
|
||||
throw err; |
|
||||
} |
|
||||
} |
|
||||
|
|
||||
export { storeIdentitySignaturePubKey, getIdentitySignaturePubKey }; |
|
||||
@ -1,136 +0,0 @@ |
|||||
/* eslint-disable no-console */ |
|
||||
/* eslint-disable no-return-await */ |
|
||||
import IdentityProvider from 'orbit-db-identity-provider'; |
|
||||
import { getIdentitySignaturePubKey, storeIdentitySignaturePubKey } from './levelUtils'; |
|
||||
|
|
||||
const LOGGING_PREFIX = 'EthereumIdentityProvider: '; |
|
||||
|
|
||||
class EthereumIdentityProvider extends IdentityProvider { |
|
||||
constructor(options = {}) { |
|
||||
if (!EthereumIdentityProvider.web3) { |
|
||||
throw new Error(`${LOGGING_PREFIX}Couldn't create identity, because web3 wasn't set. ` |
|
||||
+ 'Please use setWeb3(web3) first!'); |
|
||||
} |
|
||||
|
|
||||
if (!EthereumIdentityProvider.contractAddress) { |
|
||||
throw new Error(`${LOGGING_PREFIX}Couldn't create identity, because contractAddress wasn't set. ` |
|
||||
+ 'Please use setContractAddress(contractAddress) first!'); |
|
||||
} |
|
||||
|
|
||||
super(options); |
|
||||
|
|
||||
// Orbit's Identity Id (user's Ethereum address) - Optional (will be grabbed later if omitted)
|
|
||||
const { id } = options; |
|
||||
if (id) { |
|
||||
const { userAddress, contractAddress } = EthereumIdentityProvider.splitId(id); |
|
||||
if (EthereumIdentityProvider.web3.utils.isAddress(userAddress) |
|
||||
&& EthereumIdentityProvider.contractAddress === contractAddress) { |
|
||||
this.id = id; |
|
||||
this.userAddress = userAddress; |
|
||||
} else throw new Error(`${LOGGING_PREFIX}Couldn't create identity, because an invalid id was supplied.`); |
|
||||
} |
|
||||
} |
|
||||
|
|
||||
static get type() { return 'ethereum'; } |
|
||||
|
|
||||
async getId() { |
|
||||
// Id wasn't in the constructor, grab it now
|
|
||||
if (!this.id) { |
|
||||
const accounts = await EthereumIdentityProvider.web3.eth.getAccounts(); |
|
||||
if (!accounts[0]) { |
|
||||
throw new Error(`${LOGGING_PREFIX}Couldn't create identity, because no web3 accounts were found (
|
|
||||
locked Metamask?).`);
|
|
||||
} |
|
||||
[this.userAddress] = accounts; |
|
||||
this.id = this.userAddress + EthereumIdentityProvider.contractAddress; |
|
||||
} |
|
||||
return this.id; |
|
||||
} |
|
||||
|
|
||||
async signIdentity(data) { |
|
||||
if (process.env.NODE_ENV === 'development') { // Don't sign repeatedly while in development
|
|
||||
console.debug(`${LOGGING_PREFIX}Attempting to find stored Orbit identity data...`); |
|
||||
const signaturePubKey = await getIdentitySignaturePubKey(data); |
|
||||
if (signaturePubKey) { |
|
||||
const identityInfo = { |
|
||||
userAddress: this.userAddress, |
|
||||
pubKeySignId: data, |
|
||||
signaturePubKey, |
|
||||
}; |
|
||||
if (await EthereumIdentityProvider.verifyIdentityInfo(identityInfo)) { |
|
||||
console.debug(`${LOGGING_PREFIX}Found and verified stored Orbit identity data!`); |
|
||||
return signaturePubKey; |
|
||||
} |
|
||||
console.debug(`${LOGGING_PREFIX}Stored Orbit identity data couldn't be verified.`); |
|
||||
} else console.debug(`${LOGGING_PREFIX}No stored Orbit identity data were found.`); |
|
||||
} |
|
||||
return await this.doSignIdentity(data); |
|
||||
} |
|
||||
|
|
||||
// eslint-disable-next-line consistent-return
|
|
||||
async doSignIdentity(data) { |
|
||||
try { |
|
||||
const signaturePubKey = await EthereumIdentityProvider.web3.eth.personal.sign(data, this.userAddress, ''); |
|
||||
if (process.env.NODE_ENV === 'development') { |
|
||||
storeIdentitySignaturePubKey(data, signaturePubKey) |
|
||||
.then(() => { |
|
||||
console.debug(`${LOGGING_PREFIX}Successfully stored current Orbit identity data.`); |
|
||||
}) |
|
||||
.catch(() => { |
|
||||
console.warn(`${LOGGING_PREFIX}Couldn't store current Orbit identity data...`); |
|
||||
}); |
|
||||
} |
|
||||
return signaturePubKey; // Password not required for MetaMask
|
|
||||
} catch (error) { |
|
||||
if (error.code && error.code === 4001) { |
|
||||
console.debug(`${LOGGING_PREFIX}User denied message signature.`); |
|
||||
return await this.doSignIdentity(data); |
|
||||
} |
|
||||
|
|
||||
console.error(`${LOGGING_PREFIX}Failed to sign data.`); |
|
||||
console.error(error); |
|
||||
} |
|
||||
} |
|
||||
|
|
||||
static async verifyIdentity(identity) { |
|
||||
const { userAddress } = EthereumIdentityProvider.splitId(identity.id); |
|
||||
|
|
||||
// Verify that identity was signed by the ID
|
|
||||
return new Promise((resolve) => { |
|
||||
resolve(EthereumIdentityProvider.web3.eth.accounts.recover(identity.publicKey + identity.signatures.id, |
|
||||
identity.signatures.publicKey) === userAddress); |
|
||||
}); |
|
||||
} |
|
||||
|
|
||||
static async verifyIdentityInfo(identityInfo) { |
|
||||
// Verify that identity was signed by the ID
|
|
||||
return new Promise((resolve) => { |
|
||||
resolve(EthereumIdentityProvider.web3.eth.accounts.recover(identityInfo.pubKeySignId, |
|
||||
identityInfo.signaturePubKey) === identityInfo.userAddress); |
|
||||
}); |
|
||||
} |
|
||||
|
|
||||
// Initialize by supplying a web3 object
|
|
||||
static setWeb3(web3) { |
|
||||
EthereumIdentityProvider.web3 = web3; |
|
||||
} |
|
||||
|
|
||||
// Initialize by supplying a contract's address (to be used as a point of reference)
|
|
||||
static setContractAddress(contractAddress) { |
|
||||
EthereumIdentityProvider.contractAddress = contractAddress; |
|
||||
} |
|
||||
|
|
||||
static splitId(id) { |
|
||||
const regex = /(0x.*)(0x.*)/g; |
|
||||
const match = regex.exec(id); |
|
||||
if (match && match.length === 3) { |
|
||||
return { userAddress: match[1], contractAddress: match[2] }; |
|
||||
} |
|
||||
throw new Error(`${LOGGING_PREFIX}Invalid id ${id}! Couldn't split it to userAddress, contractAddress.`); |
|
||||
} |
|
||||
} |
|
||||
|
|
||||
EthereumIdentityProvider.web3 = {}; |
|
||||
EthereumIdentityProvider.contractAddress = {}; |
|
||||
|
|
||||
export default EthereumIdentityProvider; |
|
||||
File diff suppressed because it is too large
Loading…
Reference in new issue