Yhozen/steemsites

import { notify } from 'react-notify-toast'

function createSite (e, { author, wif, permlink, files, pageName, body })  {
    const title = pageName
    const jsonMetadata = {
      app: 'steemsites'
    }
    const authorLC = author.toLowerCase()
    const permlinkLC = permlink.toLowerCase()
    const data = {jsonMetadata, body, title, wif, author: authorLC, files}
    shouldUpdate(authorLC, permlinkLC, data)
    e.preventDefault()
}


export default createSite

async function shouldUpdate (author, permlink, data) {
    try {
        const { steem } =  await import('./steem')
        const { peerweb } =  await import('./peerweb')
        const magnetLink = await peerweb.getMagnet(data.files, `${author}/${permlink}`)
        data.jsonMetadata["magnetLink"] = magnetLink
        data.jsonMetadata = JSON.stringify(data.jsonMetadata)
        const content = await getContent(author, permlink, steem)
        if (content) {
            const upPermlink =`update-${permlink}-${Date.now()}` 
            await comment( author, permlink, upPermlink, data, steem )
            notify.show('Updated', 'success')
        } else {
           await comment( '', 'steemsites',  permlink, data, steem )
           notify.show('Site added', 'success')
        }
    } catch (err) {
        notify.show(`Couldn't add: ${err}`, 'error')
        console.error(err)
    }
}

function getContent (author, permlink, steem) {
    return new Promise((resolve,reject) => {
        steem.api.getContent(author, permlink, (err, response) => {
            if (err) return reject(err) // eslint-disable-next-line
            if (response.id == 0) return resolve(false)
            resolve(response)
        })
    })
}
function comment ( namespace, permlink, upPermlink, data, steem) {
    const { title, body, jsonMetadata, wif, author } = data
    return new Promise((resolve,reject) => {
        steem.broadcast.comment(wif, namespace, permlink, author, upPermlink, title, body, jsonMetadata, (err, response) => {
            if (err) return reject(err)
            resolve(response)
        })
    })
}