Support for 0.37 SDK #1008

Merged
tzarebczan merged 3 commits from 0.37-fixes into master 2019-05-27 00:34:22 +02:00
12 changed files with 95 additions and 92 deletions
Showing only changes of commit 1b069ba2a1 - Show all commits

View file

@ -188,8 +188,8 @@ inquirer
.post('http://localhost:5279', { .post('http://localhost:5279', {
method: 'channel_new', method: 'channel_new',
params: { params: {
channel_name: thumbnailChannelDefault, name: thumbnailChannelDefault,
amount: channelBid, bid: channelBid,
}, },
}) })
.then(response => { .then(response => {
@ -197,7 +197,6 @@ inquirer
if (response.data.error) { if (response.data.error) {
throw new Error(response.data.error.message); throw new Error(response.data.error.message);
} }
thumbnailChannel = thumbnailChannelDefault; thumbnailChannel = thumbnailChannelDefault;
thumbnailChannelId = response.data.result.claim_id; thumbnailChannelId = response.data.result.claim_id;
siteConfig['publishing']['thumbnailChannel'] = thumbnailChannel; siteConfig['publishing']['thumbnailChannel'] = thumbnailChannel;
@ -237,7 +236,9 @@ inquirer
'\nIt\'s a good idea to BACK UP YOUR MASTER PASSWORD \nin "/site/private/authConfig.json" so that you don\'t lose \ncontrol of your channel.' '\nIt\'s a good idea to BACK UP YOUR MASTER PASSWORD \nin "/site/private/authConfig.json" so that you don\'t lose \ncontrol of your channel.'
); );
console.log('\nNext step: run "npm run start" to build and start your server!'); console.log(
'\nNext step: run "npm run build" (or "npm run dev") to compiles, and "npm run start" to start your server!'
);
console.log( console.log(
'If you want to change any settings, you can edit the files in the "/site" folder.' 'If you want to change any settings, you can edit the files in the "/site" folder.'
); );

View file

@ -1,5 +1,5 @@
import {connect} from 'react-redux'; import { connect } from 'react-redux';
import {updateMetadata} from '../../actions/publish'; import { updateMetadata } from '../../actions/publish';
import View from './view'; import View from './view';
const mapStateToProps = ({ publish }) => { const mapStateToProps = ({ publish }) => {
@ -16,4 +16,7 @@ const mapDispatchToProps = dispatch => {
}; };
}; };
export default connect(mapStateToProps, mapDispatchToProps)(View); export default connect(
mapStateToProps,
mapDispatchToProps
)(View);

View file

@ -40,7 +40,7 @@ const initialState = {
description: '', description: '',
license: '', license: '',
licenseUrl: '', licenseUrl: '',
nsfw: false, tags: [],
}, },
isUpdate: false, isUpdate: false,
hasChanged: false, hasChanged: false,

View file

@ -9,11 +9,22 @@ import { selectShowState, selectAsset } from '../selectors/show';
import { validateChannelSelection, validateNoPublishErrors } from '../utils/validate'; import { validateChannelSelection, validateNoPublishErrors } from '../utils/validate';
import { createPublishMetadata, createPublishFormData, createThumbnailUrl } from '../utils/publish'; import { createPublishMetadata, createPublishFormData, createThumbnailUrl } from '../utils/publish';
import { makePublishRequestChannel } from '../channels/publish'; import { makePublishRequestChannel } from '../channels/publish';
// yep
function * publishFile (action) { function* publishFile(action) {
const { history } = action.data; const { history } = action.data;
const publishState = yield select(selectPublishState); const publishState = yield select(selectPublishState);
const { publishInChannel, selectedChannel, file, claim, metadata, thumbnailChannel, thumbnailChannelId, thumbnail, isUpdate, error: publishToolErrors } = publishState; const {
publishInChannel,
selectedChannel,
file,
claim,
metadata,
thumbnailChannel,
thumbnailChannelId,
thumbnail,
isUpdate,
error: publishToolErrors,
} = publishState;
const { loggedInChannel } = yield select(selectChannelState); const { loggedInChannel } = yield select(selectChannelState);
const { host } = yield select(selectSiteState); const { host } = yield select(selectSiteState);
@ -39,7 +50,7 @@ function * publishFile (action) {
// create metadata // create metadata
publishMetadata = createPublishMetadata( publishMetadata = createPublishMetadata(
isUpdate ? asset.name : claim, isUpdate ? asset.name : claim,
isUpdate ? {type: asset.claimData.contentType} : file, isUpdate ? { type: asset.claimData.contentType } : file,
metadata, metadata,
publishInChannel, publishInChannel,
selectedChannel selectedChannel
@ -49,7 +60,12 @@ function * publishFile (action) {
} }
if (thumbnail) { if (thumbnail) {
// add thumbnail to publish metadata // add thumbnail to publish metadata
publishMetadata['thumbnail'] = createThumbnailUrl(thumbnailChannel, thumbnailChannelId, claim, host); publishMetadata['thumbnail'] = createThumbnailUrl(
thumbnailChannel,
thumbnailChannelId,
claim,
host
);
} }
// create form data for main publish // create form data for main publish
publishFormData = createPublishFormData(file, thumbnail, publishMetadata); publishFormData = createPublishFormData(file, thumbnail, publishMetadata);
@ -57,7 +73,7 @@ function * publishFile (action) {
publishChannel = yield call(makePublishRequestChannel, publishFormData, isUpdate); publishChannel = yield call(makePublishRequestChannel, publishFormData, isUpdate);
while (true) { while (true) {
const {loadStart, progress, load, success, error: publishError} = yield take(publishChannel); const { loadStart, progress, load, success, error: publishError } = yield take(publishChannel);
if (publishError) { if (publishError) {
return yield put(updatePublishStatus(publishStates.FAILED, publishError.message)); return yield put(updatePublishStatus(publishStates.FAILED, publishError.message));
} }
@ -67,7 +83,7 @@ function * publishFile (action) {
yield put({ yield put({
type: 'ASSET_UPDATE_CLAIMDATA', type: 'ASSET_UPDATE_CLAIMDATA',
data: { data: {
id : `a#${success.data.name}#${success.data.claimId}`, id: `a#${success.data.name}#${success.data.claimId}`,
claimData: success.data.claimData, claimData: success.data.claimData,
}, },
}); });
@ -91,6 +107,6 @@ function * publishFile (action) {
} }
} }
export function * watchPublishStart () { export function* watchPublishStart() {
yield takeLatest(actions.PUBLISH_START, publishFile); yield takeLatest(actions.PUBLISH_START, publishFile);
}; }

View file

@ -5,6 +5,7 @@ export const createPublishMetadata = (
publishInChannel, publishInChannel,
selectedChannel selectedChannel
) => { ) => {
// this metadata stuff needs to be removed...
let metadata = { let metadata = {
name: claim, name: claim,
title, title,

26
package-lock.json generated
View file

@ -2617,7 +2617,6 @@
"resolved": "http://registry.npmjs.org/bl/-/bl-1.2.2.tgz", "resolved": "http://registry.npmjs.org/bl/-/bl-1.2.2.tgz",
"integrity": "sha512-e8tQYnZodmebYDWGH7KMRvtzKXaJHx3BbilrgZCfvyLUYdKpK1t5PSPmpkny/SgiTSCnjfLW7v5rlONXVFkQEA==", "integrity": "sha512-e8tQYnZodmebYDWGH7KMRvtzKXaJHx3BbilrgZCfvyLUYdKpK1t5PSPmpkny/SgiTSCnjfLW7v5rlONXVFkQEA==",
"dev": true, "dev": true,
"optional": true,
"requires": { "requires": {
"readable-stream": "^2.3.5", "readable-stream": "^2.3.5",
"safe-buffer": "^5.1.1" "safe-buffer": "^5.1.1"
@ -3959,7 +3958,6 @@
"resolved": "https://registry.npmjs.org/decompress-tar/-/decompress-tar-4.1.1.tgz", "resolved": "https://registry.npmjs.org/decompress-tar/-/decompress-tar-4.1.1.tgz",
"integrity": "sha512-JdJMaCrGpB5fESVyxwpCx4Jdj2AagLmv3y58Qy4GE6HMVjWz1FeVQk1Ct4Kye7PftcdOo/7U7UKzYBJgqnGeUQ==", "integrity": "sha512-JdJMaCrGpB5fESVyxwpCx4Jdj2AagLmv3y58Qy4GE6HMVjWz1FeVQk1Ct4Kye7PftcdOo/7U7UKzYBJgqnGeUQ==",
"dev": true, "dev": true,
"optional": true,
"requires": { "requires": {
"file-type": "^5.2.0", "file-type": "^5.2.0",
"is-stream": "^1.1.0", "is-stream": "^1.1.0",
@ -3994,7 +3992,6 @@
"resolved": "https://registry.npmjs.org/decompress-targz/-/decompress-targz-4.1.1.tgz", "resolved": "https://registry.npmjs.org/decompress-targz/-/decompress-targz-4.1.1.tgz",
"integrity": "sha512-4z81Znfr6chWnRDNfFNqLwPvm4db3WuZkqV+UgXQzSngG3CEKdBkw5jrv3axjjL96glyiiKjsxJG3X6WBZwX3w==", "integrity": "sha512-4z81Znfr6chWnRDNfFNqLwPvm4db3WuZkqV+UgXQzSngG3CEKdBkw5jrv3axjjL96glyiiKjsxJG3X6WBZwX3w==",
"dev": true, "dev": true,
"optional": true,
"requires": { "requires": {
"decompress-tar": "^4.1.1", "decompress-tar": "^4.1.1",
"file-type": "^5.2.0", "file-type": "^5.2.0",
@ -5385,8 +5382,7 @@
"version": "5.2.0", "version": "5.2.0",
"resolved": "https://registry.npmjs.org/file-type/-/file-type-5.2.0.tgz", "resolved": "https://registry.npmjs.org/file-type/-/file-type-5.2.0.tgz",
"integrity": "sha1-LdvqfHP/42No365J3DOMBYwritY=", "integrity": "sha1-LdvqfHP/42No365J3DOMBYwritY=",
"dev": true, "dev": true
"optional": true
}, },
"fill-range": { "fill-range": {
"version": "4.0.0", "version": "4.0.0",
@ -5584,8 +5580,7 @@
"version": "1.0.0", "version": "1.0.0",
"resolved": "https://registry.npmjs.org/fs-constants/-/fs-constants-1.0.0.tgz", "resolved": "https://registry.npmjs.org/fs-constants/-/fs-constants-1.0.0.tgz",
"integrity": "sha512-y6OAwoSIf7FyjMIv94u+b5rdheZEjzR63GTyZJm5qh4Bi+2YgwLCcI/fPFZkL5PSixOt6ZNKm+w+Hfp/Bciwow==", "integrity": "sha512-y6OAwoSIf7FyjMIv94u+b5rdheZEjzR63GTyZJm5qh4Bi+2YgwLCcI/fPFZkL5PSixOt6ZNKm+w+Hfp/Bciwow==",
"dev": true, "dev": true
"optional": true
}, },
"fs-extra": { "fs-extra": {
"version": "5.0.0", "version": "5.0.0",
@ -5641,8 +5636,7 @@
"ansi-regex": { "ansi-regex": {
"version": "2.1.1", "version": "2.1.1",
"bundled": true, "bundled": true,
"dev": true, "dev": true
"optional": true
}, },
"aproba": { "aproba": {
"version": "1.2.0", "version": "1.2.0",
@ -6057,8 +6051,7 @@
"safe-buffer": { "safe-buffer": {
"version": "5.1.1", "version": "5.1.1",
"bundled": true, "bundled": true,
"dev": true, "dev": true
"optional": true
}, },
"safer-buffer": { "safer-buffer": {
"version": "2.1.2", "version": "2.1.2",
@ -6114,7 +6107,6 @@
"version": "3.0.1", "version": "3.0.1",
"bundled": true, "bundled": true,
"dev": true, "dev": true,
"optional": true,
"requires": { "requires": {
"ansi-regex": "^2.0.0" "ansi-regex": "^2.0.0"
} }
@ -6158,14 +6150,12 @@
"wrappy": { "wrappy": {
"version": "1.0.2", "version": "1.0.2",
"bundled": true, "bundled": true,
"dev": true, "dev": true
"optional": true
}, },
"yallist": { "yallist": {
"version": "3.0.2", "version": "3.0.2",
"bundled": true, "bundled": true,
"dev": true, "dev": true
"optional": true
} }
} }
}, },
@ -15171,7 +15161,6 @@
"resolved": "https://registry.npmjs.org/tar-stream/-/tar-stream-1.6.2.tgz", "resolved": "https://registry.npmjs.org/tar-stream/-/tar-stream-1.6.2.tgz",
"integrity": "sha512-rzS0heiNf8Xn7/mpdSVVSMAWAoy9bfb1WOTYC78Z0UQKeKa/CWS8FOq0lKGNa8DWKAn9gxjCvMLYc5PGXYlK2A==", "integrity": "sha512-rzS0heiNf8Xn7/mpdSVVSMAWAoy9bfb1WOTYC78Z0UQKeKa/CWS8FOq0lKGNa8DWKAn9gxjCvMLYc5PGXYlK2A==",
"dev": true, "dev": true,
"optional": true,
"requires": { "requires": {
"bl": "^1.0.0", "bl": "^1.0.0",
"buffer-alloc": "^1.2.0", "buffer-alloc": "^1.2.0",
@ -15434,8 +15423,7 @@
"version": "1.1.1", "version": "1.1.1",
"resolved": "https://registry.npmjs.org/to-buffer/-/to-buffer-1.1.1.tgz", "resolved": "https://registry.npmjs.org/to-buffer/-/to-buffer-1.1.1.tgz",
"integrity": "sha512-lx9B5iv7msuFYE3dytT+KE5tap+rNYw+K4jVkb9R/asAb+pbBSM17jtunHplhBe6RRJdZx3Pn2Jph24O32mOVg==", "integrity": "sha512-lx9B5iv7msuFYE3dytT+KE5tap+rNYw+K4jVkb9R/asAb+pbBSM17jtunHplhBe6RRJdZx3Pn2Jph24O32mOVg==",
"dev": true, "dev": true
"optional": true
}, },
"to-fast-properties": { "to-fast-properties": {
"version": "2.0.0", "version": "2.0.0",

View file

@ -33,24 +33,24 @@ const createPublishParams = (
name, name,
file_path: filePath, file_path: filePath,
bid: publishing.fileClaimBidAmount, bid: publishing.fileClaimBidAmount,
metadata: {
description, description,
title, title,
author: details.title, author: details.title,
language: 'en', languages: ['en'],
license, license,
licenseUrl, license_url: licenseUrl,
nsfw, tags: [],
},
claim_address: publishing.primaryClaimAddress, claim_address: publishing.primaryClaimAddress,
}; };
// add thumbnail to channel if video // add thumbnail to channel if video
if (thumbnail) { if (thumbnail) {
publishParams['metadata']['thumbnail'] = thumbnail; publishParams['thumbnail_url'] = thumbnail;
}
if (nsfw) {
publishParams.tags.push = 'mature';
} }
// add channel details if publishing to a channel // add channel details if publishing to a channel
if (channelName && channelClaimId) { if (channelClaimId) {
publishParams['channel_name'] = channelName;
publishParams['channel_id'] = channelClaimId; publishParams['channel_id'] = channelClaimId;
} }
// log params // log params

View file

@ -11,15 +11,12 @@ const createThumbnailPublishParams = (thumbnailFilePath, claimName, license, lic
name: `${claimName}-thumb`, name: `${claimName}-thumb`,
file_path: thumbnailFilePath, file_path: thumbnailFilePath,
bid: publishing.fileClaimBidAmount, bid: publishing.fileClaimBidAmount,
metadata: {
title: `${claimName} thumbnail`, title: `${claimName} thumbnail`,
description: `a thumbnail for ${claimName}`, description: `a thumbnail for ${claimName}`,
author: details.title, author: details.title,
language: 'en', languages: ['en'],
license, license,
licenseUrl, license_url: licenseUrl,
nsfw,
},
claim_address: publishing.primaryClaimAddress, claim_address: publishing.primaryClaimAddress,
channel_name: publishing.thumbnailChannel, channel_name: publishing.thumbnailChannel,
channel_id: publishing.thumbnailChannelId, channel_id: publishing.thumbnailChannelId,

View file

@ -16,7 +16,7 @@ const publish = async (publishParams, fileName, fileType) => {
try { try {
publishResults = await publishClaim(publishParams); publishResults = await publishClaim(publishParams);
logger.verbose(`Successfully published ${publishParams.name} ${fileName}`, publishResults); logger.verbose(`Successfully published ${publishParams.name} ${fileName}`, publishResults);
const outpoint = `${publishResults.output.txid}:${publishResults.output.nout}`; const outpoint = `${publishResults.outputs[0].txid}:${publishResults.outputs[0].nout}`;
// get the channel information // get the channel information
if (publishParams.channel_name) { if (publishParams.channel_name) {
logger.debug(`this claim was published in channel: ${publishParams.channel_name}`); logger.debug(`this claim was published in channel: ${publishParams.channel_name}`);

View file

@ -138,7 +138,7 @@ const claimUpdate = ({ body, files, headers, ip, originalUrl, user, tor }, res)
nsfw: claimRecord.nsfw, nsfw: claimRecord.nsfw,
license: claimRecord.license, license: claimRecord.license,
licenseUrl: claimRecord.license_url, licenseUrl: claimRecord.license_url,
language: 'en', languages: ['en'],
author: details.title, author: details.title,
}, },
updateMetadata({ title, description, nsfw, license, licenseUrl }) updateMetadata({ title, description, nsfw, license, licenseUrl })

View file

@ -172,10 +172,10 @@ module.exports = {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
axios axios
.post(lbrynetUri, { .post(lbrynetUri, {
method: 'channel_new', method: 'channel_create',
params: { params: {
channel_name: name, name: name,
amount: publishing.channelClaimBidAmount, bid: publishing.channelClaimBidAmount,
}, },
}) })
.then(response => { .then(response => {

View file

@ -1,26 +1,23 @@
const db = require('../index.js'); const db = require('../index.js');
const createClaimRecordDataAfterPublish = (certificateId, channelName, fileName, fileType, publishParams, publishResults) => { const createClaimRecordDataAfterPublish = (
certificateId,
channelName,
fileName,
fileType,
publishParams,
publishResults
) => {
const { const {
name, name,
metadata: { metadata: { title, description, thumbnail, nsfw },
title,
description,
thumbnail,
nsfw,
},
claim_address: address, claim_address: address,
bid: amount, bid: amount,
} = publishParams; } = publishParams;
const { const { claim_id: claimId, txid, nout } = publishResults;
claim_id: claimId,
txid,
nout,
} = publishResults;
return db.Claim.getCurrentHeight() return db.Claim.getCurrentHeight().then(height => {
.then(height => {
return { return {
name, name,
claimId, claimId,
@ -28,7 +25,7 @@ const createClaimRecordDataAfterPublish = (certificateId, channelName, fileName,
description, description,
address, address,
thumbnail, thumbnail,
outpoint : `${txid}:${nout}`, outpoint: `${txid}:${nout}`,
height, height,
contentType: fileType, contentType: fileType,
nsfw, nsfw,