filip mertens
4 years ago
commit
9038920746
@ -0,0 +1,399 @@ |
||||
'use strict' |
||||
|
||||
import { |
||||
Plugin |
||||
} from '@remixproject/engine' |
||||
import git from 'isomorphic-git' |
||||
import IpfsHttpClient from 'ipfs-http-client' |
||||
import { |
||||
saveAs |
||||
} from 'file-saver' |
||||
|
||||
const JSZip = require('jszip') |
||||
const path = require('path') |
||||
const FormData = require('form-data') |
||||
const axios = require('axios') |
||||
|
||||
const profile = { |
||||
name: 'dGitProvider', |
||||
displayName: 'Decentralized git', |
||||
description: '', |
||||
icon: 'assets/img/fileManager.webp', |
||||
version: '0.0.1', |
||||
methods: ['init', 'status', 'log', 'commit', 'add', 'remove', 'rm', 'lsfiles', 'readblob', 'resolveref', 'branches', 'branch', 'checkout', 'currentbranch', 'push', 'pin', 'pull', 'pinList', 'unPin', 'setIpfsConfig', 'zip', 'setItem', 'getItem'], |
||||
kind: 'file-system' |
||||
} |
||||
class DGitProvider extends Plugin { |
||||
constructor () { |
||||
super(profile) |
||||
this.ipfsconfig = { |
||||
host: 'ipfs.komputing.org', |
||||
port: 443, |
||||
protocol: 'https', |
||||
ipfsurl: 'https://ipfsgw.komputing.org/ipfs/' |
||||
} |
||||
this.globalIPFSConfig = { |
||||
host: 'ipfs.io', |
||||
port: 443, |
||||
protocol: 'https', |
||||
ipfsurl: 'https://ipfs.io/ipfs/' |
||||
} |
||||
} |
||||
|
||||
async getGitConfig () { |
||||
const workspace = await this.call('filePanel', 'getCurrentWorkspace') |
||||
return { |
||||
fs: window.remixFileSystem, |
||||
dir: workspace.absolutePath |
||||
} |
||||
} |
||||
|
||||
async init () { |
||||
await git.init({ |
||||
...await this.getGitConfig(), |
||||
defaultBranch: 'main' |
||||
}) |
||||
} |
||||
|
||||
async status (cmd) { |
||||
const status = await git.statusMatrix({ |
||||
...await this.getGitConfig(), |
||||
...cmd |
||||
}) |
||||
return status |
||||
} |
||||
|
||||
async add (cmd) { |
||||
await git.add({ |
||||
...await this.getGitConfig(), |
||||
...cmd |
||||
}) |
||||
this.call('fileManager', 'refresh') |
||||
} |
||||
|
||||
async rm (cmd) { |
||||
await git.remove({ |
||||
...await this.getGitConfig(), |
||||
...cmd |
||||
}) |
||||
this.call('fileManager', 'refresh') |
||||
} |
||||
|
||||
async checkout (cmd) { |
||||
await git.checkout({ |
||||
...await this.getGitConfig(), |
||||
...cmd |
||||
}) |
||||
this.call('fileManager', 'refresh') |
||||
} |
||||
|
||||
async log (cmd) { |
||||
const status = await git.log({ |
||||
...await this.getGitConfig(), |
||||
...cmd |
||||
}) |
||||
return status |
||||
} |
||||
|
||||
async branch (cmd) { |
||||
const status = await git.branch({ |
||||
...await this.getGitConfig(), |
||||
...cmd |
||||
}) |
||||
this.call('fileManager', 'refresh') |
||||
return status |
||||
} |
||||
|
||||
async currentbranch () { |
||||
const name = await git.currentBranch({ |
||||
...await this.getGitConfig() |
||||
}) |
||||
return name |
||||
} |
||||
|
||||
async branches () { |
||||
const branches = await git.listBranches({ |
||||
...await this.getGitConfig() |
||||
}) |
||||
return branches |
||||
} |
||||
|
||||
async commit (cmd) { |
||||
await this.init() |
||||
try { |
||||
const sha = await git.commit({ |
||||
...await this.getGitConfig(), |
||||
...cmd |
||||
}) |
||||
return sha |
||||
} catch (e) {} |
||||
} |
||||
|
||||
async lsfiles (cmd) { |
||||
const filesInStaging = await git.listFiles({ |
||||
...await this.getGitConfig(), |
||||
...cmd |
||||
}) |
||||
return filesInStaging |
||||
} |
||||
|
||||
async resolveref (cmd) { |
||||
const oid = await git.resolveRef({ |
||||
...await this.getGitConfig(), |
||||
...cmd |
||||
}) |
||||
return oid |
||||
} |
||||
|
||||
async readblob (cmd) { |
||||
const readBlobResult = await git.readBlob({ |
||||
...await this.getGitConfig(), |
||||
...cmd |
||||
}) |
||||
return readBlobResult |
||||
} |
||||
|
||||
async setIpfsConfig (config) { |
||||
this.ipfsconfig = config |
||||
return new Promise((resolve, reject) => { |
||||
resolve(this.checkIpfsConfig()) |
||||
}) |
||||
} |
||||
|
||||
async checkIpfsConfig (config) { |
||||
this.ipfs = IpfsHttpClient(config || this.ipfsconfig) |
||||
try { |
||||
await this.ipfs.config.getAll() |
||||
return true |
||||
} catch (e) { |
||||
return false |
||||
} |
||||
} |
||||
|
||||
async push () { |
||||
if (!this.checkIpfsConfig()) return false |
||||
const workspace = await this.call('filePanel', 'getCurrentWorkspace') |
||||
const files = await this.getDirectory('/') |
||||
this.filesToSend = [] |
||||
for (const file of files) { |
||||
const c = window.remixFileSystem.readFileSync(`${workspace.absolutePath}/${file}`) |
||||
const ob = { |
||||
path: file, |
||||
content: c |
||||
} |
||||
this.filesToSend.push(ob) |
||||
} |
||||
const addOptions = { |
||||
wrapWithDirectory: true |
||||
} |
||||
const r = await this.ipfs.add(this.filesToSend, addOptions) |
||||
return r.cid.string |
||||
} |
||||
|
||||
async pin (pinataApiKey, pinataSecretApiKey) { |
||||
const workspace = await this.call('filePanel', 'getCurrentWorkspace') |
||||
const files = await this.getDirectory('/') |
||||
this.filesToSend = [] |
||||
|
||||
const data = new FormData() |
||||
files.forEach(async (file) => { |
||||
const c = window.remixFileSystem.readFileSync(`${workspace.absolutePath}/${file}`) |
||||
data.append('file', new Blob([c]), `base/${file}`) |
||||
}) |
||||
// get last commit data
|
||||
let ob |
||||
try { |
||||
const commits = await this.log({ ref: 'HEAD' }) |
||||
ob = { |
||||
ref: commits[0].oid, |
||||
message: commits[0].commit.message |
||||
} |
||||
} catch (e) { |
||||
ob = { |
||||
ref: 'no commits', |
||||
message: 'no commits' |
||||
} |
||||
} |
||||
const today = new Date() |
||||
const metadata = JSON.stringify({ |
||||
name: `remix - ${workspace.name} - ${today.toLocaleString()}`, |
||||
keyvalues: ob |
||||
}) |
||||
const pinataOptions = JSON.stringify({ |
||||
wrapWithDirectory: false |
||||
}) |
||||
data.append('pinataOptions', pinataOptions) |
||||
data.append('pinataMetadata', metadata) |
||||
const url = 'https://api.pinata.cloud/pinning/pinFileToIPFS' |
||||
try { |
||||
const result = await axios |
||||
.post(url, data, { |
||||
maxBodyLength: 'Infinity', |
||||
headers: { |
||||
'Content-Type': `multipart/form-data; boundary=${data._boundary}`, |
||||
pinata_api_key: pinataApiKey, |
||||
pinata_secret_api_key: pinataSecretApiKey |
||||
} |
||||
}) |
||||
return result.data.IpfsHash |
||||
} catch (error) { |
||||
throw new Error(error) |
||||
} |
||||
} |
||||
|
||||
async pinList (pinataApiKey, pinataSecretApiKey) { |
||||
const url = 'https://api.pinata.cloud/data/pinList?status=pinned' |
||||
try { |
||||
const result = await axios |
||||
.get(url, { |
||||
maxBodyLength: 'Infinity', |
||||
headers: { |
||||
pinata_api_key: pinataApiKey, |
||||
pinata_secret_api_key: pinataSecretApiKey |
||||
} |
||||
}) |
||||
return result.data |
||||
} catch (error) { |
||||
throw new Error(error) |
||||
} |
||||
} |
||||
|
||||
async unPin (pinataApiKey, pinataSecretApiKey, hashToUnpin) { |
||||
const url = `https://api.pinata.cloud/pinning/unpin/${hashToUnpin}` |
||||
try { |
||||
await axios |
||||
.delete(url, { |
||||
headers: { |
||||
pinata_api_key: pinataApiKey, |
||||
pinata_secret_api_key: pinataSecretApiKey |
||||
} |
||||
}) |
||||
return true |
||||
} catch (error) { |
||||
throw new Error(error) |
||||
} |
||||
}; |
||||
|
||||
async pull (cmd) { |
||||
const permission = await this.askUserPermission('pull', 'Import multiple files into your workspaces.') |
||||
console.log(this.ipfsconfig) |
||||
if (!permission) return false |
||||
const cid = cmd.cid |
||||
if (!cmd.local) { |
||||
this.ipfs = IpfsHttpClient(this.globalIPFSConfig) |
||||
} else { |
||||
if (!this.checkIpfsConfig()) return false |
||||
} |
||||
await this.call('filePanel', 'createWorkspace', `workspace_${Date.now()}`, false) |
||||
const workspace = await this.call('filePanel', 'getCurrentWorkspace') |
||||
for await (const file of this.ipfs.get(cid)) { |
||||
file.path = file.path.replace(cid, '') |
||||
if (!file.content) { |
||||
continue |
||||
} |
||||
const content = [] |
||||
for await (const chunk of file.content) { |
||||
content.push(chunk) |
||||
} |
||||
const dir = path.dirname(file.path) |
||||
try { |
||||
this.createDirectories(`${workspace.absolutePath}/${dir}`) |
||||
} catch (e) {} |
||||
try { |
||||
window.remixFileSystem.writeFileSync(`${workspace.absolutePath}/${file.path}`, Buffer.concat(content) || new Uint8Array()) |
||||
} catch (e) {} |
||||
} |
||||
this.call('fileManager', 'refresh') |
||||
} |
||||
|
||||
async getItem (name) { |
||||
if (typeof window !== 'undefined') { |
||||
return window.localStorage.getItem(name) |
||||
} |
||||
} |
||||
|
||||
async setItem (name, content) { |
||||
try { |
||||
if (typeof window !== 'undefined') { |
||||
window.localStorage.setItem(name, content) |
||||
} |
||||
} catch (exception) { |
||||
return false |
||||
} |
||||
return true |
||||
} |
||||
|
||||
async zip () { |
||||
const zip = new JSZip() |
||||
const workspace = await this.call('filePanel', 'getCurrentWorkspace') |
||||
const files = await this.getDirectory('/') |
||||
this.filesToSend = [] |
||||
for (const file of files) { |
||||
const c = window.remixFileSystem.readFileSync(`${workspace.absolutePath}/${file}`) |
||||
zip.file(file, c) |
||||
} |
||||
await zip.generateAsync({ |
||||
type: 'blob' |
||||
}) |
||||
.then(function (content) { |
||||
saveAs(content, `${workspace.name}.zip`) |
||||
}) |
||||
} |
||||
|
||||
async createDirectories (strdirectories) { |
||||
const ignore = ['.', '/.', ''] |
||||
if (ignore.indexOf(strdirectories) > -1) return false |
||||
const directories = strdirectories.split('/') |
||||
for (let i = 0; i < directories.length; i++) { |
||||
let previouspath = '' |
||||
if (i > 0) previouspath = '/' + directories.slice(0, i).join('/') |
||||
const finalPath = previouspath + '/' + directories[i] |
||||
try { |
||||
window.remixFileSystem.mkdirSync(finalPath) |
||||
} catch (e) {} |
||||
} |
||||
} |
||||
|
||||
async getDirectory (dir) { |
||||
let result = [] |
||||
const files = await this.call('fileManager', 'readdir', dir) |
||||
const fileArray = normalize(files) |
||||
for (const fi of fileArray) { |
||||
if (fi) { |
||||
const type = fi.data.isDirectory |
||||
if (type === true) { |
||||
result = [ |
||||
...result, |
||||
...(await this.getDirectory( |
||||
`${fi.filename}` |
||||
)) |
||||
] |
||||
} else { |
||||
result = [...result, fi.filename] |
||||
} |
||||
} |
||||
} |
||||
return result |
||||
} |
||||
} |
||||
|
||||
const normalize = (filesList) => { |
||||
const folders = [] |
||||
const files = [] |
||||
Object.keys(filesList || {}).forEach(key => { |
||||
if (filesList[key].isDirectory) { |
||||
folders.push({ |
||||
filename: key, |
||||
data: filesList[key] |
||||
}) |
||||
} else { |
||||
files.push({ |
||||
filename: key, |
||||
data: filesList[key] |
||||
}) |
||||
} |
||||
}) |
||||
return [...folders, ...files] |
||||
} |
||||
|
||||
module.exports = DGitProvider |
||||
@ -0,0 +1,71 @@ |
||||
import * as packageJson from '../../../../../package.json' |
||||
import { Plugin } from '@remixproject/engine' |
||||
import Web3 from 'web3' |
||||
const yo = require('yo-yo') |
||||
const modalDialogCustom = require('../ui/modal-dialog-custom') |
||||
|
||||
const profile = { |
||||
name: 'hardhat-provider', |
||||
displayName: 'Hardhat Provider', |
||||
kind: 'provider', |
||||
description: 'Hardhat provider', |
||||
methods: ['sendAsync'], |
||||
version: packageJson.version |
||||
} |
||||
|
||||
export default class HardhatProvider extends Plugin { |
||||
constructor (blockchain) { |
||||
super(profile) |
||||
this.provider = null |
||||
this.blockchain = blockchain |
||||
} |
||||
|
||||
onDeactivation () { |
||||
this.provider = null |
||||
} |
||||
|
||||
hardhatProviderDialogBody () { |
||||
return yo` |
||||
<div class=""> |
||||
Note: To run Hardhat network node on your system, go to hardhat project folder and run command: |
||||
<div class="border p-1">npx hardhat node</div> |
||||
<br> |
||||
For more info, visit: <a href="https://hardhat.org/getting-started/#connecting-a-wallet-or-dapp-to-hardhat-network" target="_blank">Hardhat Documentation</a> |
||||
<br><br> |
||||
Hardhat JSON-RPC Endpoint |
||||
</div> |
||||
` |
||||
} |
||||
|
||||
sendAsync (data) { |
||||
return new Promise((resolve, reject) => { |
||||
if (!this.provider) { |
||||
modalDialogCustom.prompt('Hardhat node request', this.hardhatProviderDialogBody(), 'http://127.0.0.1:8545', (target) => { |
||||
this.provider = new Web3.providers.HttpProvider(target) |
||||
this.sendAsyncInternal(data, resolve, reject) |
||||
}, () => { |
||||
this.sendAsyncInternal(data, resolve, reject) |
||||
}) |
||||
} else { |
||||
this.sendAsyncInternal(data, resolve, reject) |
||||
} |
||||
}) |
||||
} |
||||
|
||||
sendAsyncInternal (data, resolve, reject) { |
||||
if (this.provider) { |
||||
this.provider[this.provider.sendAsync ? 'sendAsync' : 'send'](data, (error, message) => { |
||||
if (error) { |
||||
this.provider = null |
||||
return reject(error) |
||||
} |
||||
resolve(message) |
||||
}) |
||||
} else { |
||||
const result = data.method === 'net_listening' ? 'canceled' : [] |
||||
resolve({ jsonrpc: '2.0', result: result, id: data.id }) |
||||
} |
||||
} |
||||
} |
||||
|
||||
module.exports = HardhatProvider |
||||
File diff suppressed because it is too large
Load Diff
Loading…
Reference in new issue