65 lines
No EOL
2 KiB
JavaScript
65 lines
No EOL
2 KiB
JavaScript
var fs = require('fs');
|
|
var lbryApi = require('../helpers/lbryApi.js');
|
|
var config = require('config');
|
|
|
|
var walledAddress = config.get('WalletConfig.lbryAddress');
|
|
|
|
function handlePublishError(error) {
|
|
if (error.code === "ECONNREFUSED"){
|
|
return "Connection refused. The daemon may not be running.";
|
|
} else if (error.response.data.error) {
|
|
return error.response.data.error;
|
|
} else {
|
|
return error;
|
|
};
|
|
}
|
|
|
|
function createPublishParams(name, filepath, license, nsfw) {
|
|
var publishParams = {
|
|
"name": name,
|
|
"file_path": filepath,
|
|
"bid": 0.01,
|
|
"metadata": {
|
|
"description": name + " published via spee.ch",
|
|
"title": name,
|
|
"author": "spee.ch",
|
|
"language": "en",
|
|
"license": license,
|
|
"nsfw": (nsfw.toLowerCase() === "true")
|
|
},
|
|
"claim_address": walledAddress,
|
|
"change_address": walledAddress //requires daemon 0.12.2rc1 or above
|
|
};
|
|
return publishParams;
|
|
}
|
|
|
|
function deleteTemporaryFile(filepath) {
|
|
fs.unlink(filepath, function(err) {
|
|
if (err) throw err;
|
|
console.log('successfully deleted ' + filepath);
|
|
});
|
|
}
|
|
|
|
module.exports = {
|
|
publish: function(name, filepath, license, nsfw, socket, visitor) {
|
|
// update the client
|
|
socket.emit("publish-status", "Your image is being published (this might take a second)...");
|
|
visitor.event("Publish Route", "Publish Request", filepath).send();
|
|
// create the publish object
|
|
var publishParams = createPublishParams(name, filepath, license, nsfw);
|
|
// get a promise to publish
|
|
lbryApi.publishClaim(publishParams)
|
|
.then(function(data){
|
|
visitor.event("Publish Route", "Publish Success", filepath).send();
|
|
console.log("publish promise success. Tx info:", data)
|
|
socket.emit("publish-complete", {name: name, result: data.result});
|
|
deleteTemporaryFile(filepath);
|
|
})
|
|
.catch(function(error){
|
|
visitor.event("Publish Route", "Publish Failure", filepath).send();
|
|
console.log("error:", error);
|
|
socket.emit("publish-failure", handlePublishError(error));
|
|
deleteTemporaryFile(filepath);
|
|
});
|
|
}
|
|
} |