"use strict"; // I M P O R T S import got from "got"; import prism from "prismjs"; import raw from "choo/html/raw"; import stringifyObject from "stringify-object"; // U T I L S import messageSlack from "./slack"; import publishMeme from "./publish-meme"; import lbrytvAPI from "~helper/lbrytv-sdk"; import randomString from "./random-string"; import { send } from "~socket"; import uploadImage from "./upload-image"; const allowedQueryMethods = [ "support_create", "publish", "resolve" ]; const approvedContentIdsForTipping = [ "3db81c073f82fd1bb670c65f526faea3b8546720", "173412f5b1b7aa63a752e8832406aafd9f1ecb4e", "2a7f5db2678177435b1dee6c9e38e035ead450b6", "d81bac6d49b1f92e58c37a5f633a27a45b43405e", "b4668c0bd096317b44c40738c099b6618095e75f", "007789cc45cbb4255cf02ba77cbf84ca8e3d7561", "1ac47b8b3def40a25850dc726a09ce23d09e7009", "784b3c215a6f06b663fc1aa292bcb19f29c489bb", "758dd6497cdfc401ae1f25984738d024d47b50af", "8a7401b88d5ed0376d98f16808194d4dcb05b284" ]; const environment = process.env.NODE_ENV === "development" ? "development" : "production"; // P A C K A G E const loadLanguages = require("prismjs/components/"); loadLanguages(["json"]); // eslint-disable-line padding-line-between-statements // E X P O R T export default async(data, socket) => { const body = {}; let apiRequestMethod = ""; let dataDetails = ""; let explorerNotice = ""; if (data.example === 1 && (!data.claim || !data.method)) return; if (data.example === 2 && !data.data) return; if (data.example === 2) dataDetails = data.data; // file upload if (data.example === 3 && (!data.claim || !data.method)) return; const claimAddress = data.claim; const resolveMethod = data.method; if (allowedQueryMethods.indexOf(resolveMethod) < 0) { return send(socket, { details: "Unallowed resolve method for tutorial", message: "notification", type: "error" }); } body.authorization = process.env.LBRY_DAEMON_ACCESS_TOKEN; body.method = resolveMethod; switch(resolveMethod) { // T I P // E X A M P L E case "support_create": if (!approvedContentIdsForTipping.includes(claimAddress)) { return send(socket, { example: data.example, html: raw(`

Response

Tipping creators not in the whitelist for this example is not allowed.
`), message: "show result", selector: `#example${data.example}-result` }); } apiRequestMethod = "POST"; body.amount = "0.001"; // Hardcoded tip amount body.claim_id = claimAddress; body.tip = true; break; // P U B L I S H // E X A M P L E case "publish": apiRequestMethod = "PUT"; // Required for publishing body.author = "lbry.tech"; body.bid = "0.001"; // Hardcoded publish amount body.description = dataDetails.description; body.languages = [dataDetails.language]; body.license = dataDetails.license; body.name = dataDetails.name + "-" + randomString(10); body.title = dataDetails.title; body.tags = dataDetails.tags; // Gotta let the blockchain know what to save body.file_path = dataDetails.file_path; try { const imageUploadResponse = await uploadImage(body.file_path); body.file_path = imageUploadResponse.filename; // eslint-disable-line padding-line-between-statements try { const memePublishResponse = await publishMeme(body); switch(true) { case data.example === 2: case memePublishResponse.result: case memePublishResponse.result.outputs[0].address: explorerNotice = memePublishMessaging(memePublishResponse); break; default: break; } delete memePublishResponse.result.lbrytech_claim_name; const renderedCode = prism.highlight( stringifyObject(memePublishResponse, { indent: " ", singleQuotes: false }), prism.languages.json, "json" ); return send(socket, { example: data.example, html: raw(`

Response

${explorerNotice}
${renderedCode}
`), message: "show result", selector: `#example${data.example}-result` }); } catch(memePublishError) { send(socket, { details: "Meme publish failed", message: "notification", type: "error" }); if (process.env.NODE_ENV !== "development") { messageSlack({ message: "```" + JSON.parse(JSON.stringify(memePublishError.error)) + "```", pretext: "_Someone is going through the Playground after a response has been parsed_", title: `DAEMON ERROR | ${environment}` }); } return; } } catch(imageUploadError) { send(socket, { details: "Image upload failed", message: "notification", type: "error" }); if (process.env.NODE_ENV !== "development") { messageSlack({ message: "```" + imageUploadError.status + "```", pretext: "_Someone attempted to upload a meme to the web daemon and it failed_", title: `DAEMON ERROR | ${environment}` }); } return; } // R E S O L V E // E X A M P L E case "resolve": apiRequestMethod = "GET"; body.uri = claimAddress; try { let resolveResponse = await lbrytvAPI.resolve([claimAddress]); if (socket) { const renderedCode = prism.highlight( stringifyObject(resolveResponse, { indent: " ", singleQuotes: false }), prism.languages.json, "json" ); return send(socket, { example: data.example, html: raw(`

Response

${explorerNotice}
${renderedCode}
`), message: "show result", selector: `#example${data.example}-result` }); } } catch(error) { messageSlack({ message: "```" + error + "```", title: "DAEMON ERROR: resolve" }); } break; default: break; } // Q U E R Y // D A E M O N const queryOptions = { body: body, json: true, method: apiRequestMethod }; const queryUrl = process.env.NODE_ENV === "development" ? `http://localhost:5200/${resolveMethod}` : `https://${process.env.DAEMON_URL}/${resolveMethod}`; try { const response = await got(queryUrl, queryOptions); switch(true) { case data.example === 3: case response.body.result: case response.body.result.txid: explorerNotice = tipCompletionMessaging(response.body); break; default: break; } if (socket) { const renderedCode = prism.highlight( stringifyObject(response.body, { indent: " ", singleQuotes: false }), prism.languages.json, "json" ); return send(socket, { example: data.example, html: raw(`

Response

${explorerNotice}
${renderedCode}
`), message: "show result", selector: `#example${data.example}-result` }); } // console.log("——"); // console.log(response.body.result[Object.keys(response.body.result)[0]]); // console.log("——"); return response.body.result[Object.keys(response.body.result)[0]]; } catch(error) { console.error(error); messageSlack({ message: "```" + error + "```", pretext: "_Someone is going through the Playground and the daemon is not running_", title: `DAEMON ERROR | ${environment}` }); } }; // H E L P E R S function memePublishMessaging(source) { return `

Nicely done, you've published to lbry://${source.result.lbrytech_claim_name}.

To see Proof of Work (lol) that your meme is on the LBRY blockchain, check it out on our blockchain explorer! Please note that it may take a couple minutes for the transaction to be confirmed.

You can also check out your meme (once the transaction is confirmed) on LBRY or Spee.ch!


`; } function tipCompletionMessaging(source) { return `

If you want proof of the tip you just gave on behalf of LBRY, check it out on our blockchain explorer! Please note that it may take a couple minutes for the transaction to be confirmed.


`; }