oceanprotocol/ocean.js
1
0
Fork 0
mirror of https://github.com/oceanprotocol/ocean.js.git synced 2024-11-26 20:39:05 +01:00
Code Releases Activity

small fixes

Browse Source
This commit is contained in:
alexcos20 2020-09-16 06:54:59 -07:00
parent 323e57e6f4
commit b07dc6daea
2 changed files with 16 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/metadatastore/OnChainMetaData.ts
View File

@ -34,6 +34,19 @@ export class OnChainMetadataStore {
) )
} }
/** Compress DDO using LZMA
*
*/
public async LZMACompressDDO(ddo: DDO): Promise<any> {
const data = DDO.serialize(ddo)
const lzma = new LZMA()
// see https://github.com/LZMA-JS/LZMA-JS/issues/44
lzma.disableEndMark = true
let compressed = lzma.compress(data, 9)
compressed = this.getHex(compressed)
return compressed
}
/** /**
* Publish a new DDO * Publish a new DDO
* @param {String} did * @param {String} did
@ -47,12 +60,7 @@ export class OnChainMetadataStore {
consumerAccount: string consumerAccount: string
): Promise<TransactionReceipt> { ): Promise<TransactionReceipt> {
let flags = 0 let flags = 0
const data = DDO.serialize(ddo) const compressed = this.LZMACompressDDO(ddo)
const lzma = new LZMA()
// see https://github.com/LZMA-JS/LZMA-JS/issues/44
lzma.disableEndMark = true
let compressed = lzma.compress(data, 9)
compressed = this.getHex(compressed)
flags = flags | 1 flags = flags | 1
return this.publishRaw(didZeroX(did), flags, compressed, consumerAccount) return this.publishRaw(didZeroX(did), flags, compressed, consumerAccount)
} }
@ -70,12 +78,7 @@ export class OnChainMetadataStore {
consumerAccount: string consumerAccount: string
): Promise<TransactionReceipt> { ): Promise<TransactionReceipt> {
let flags = 0 let flags = 0
const data = DDO.serialize(ddo) const compressed = this.LZMACompressDDO(ddo)
const lzma = new LZMA()
// see https://github.com/LZMA-JS/LZMA-JS/issues/44
lzma.disableEndMark = true
let compressed = lzma.compress(data, 9)
compressed = this.getHex(compressed)
flags = flags | 1 flags = flags | 1
return this.updateRaw(didZeroX(did), flags, compressed, consumerAccount) return this.updateRaw(didZeroX(did), flags, compressed, consumerAccount)
} }

2
src/ocean/Assets.ts
View File

@ -167,7 +167,7 @@ export class Assets extends Instantiable {
ddo, ddo,
publisher.getId() publisher.getId()
) )
this.logger.log('DDO stored') this.logger.log('DDO stored ' + ddo.id)
observer.next(CreateProgressStep.DdoStored) observer.next(CreateProgressStep.DdoStored)
if (storeTx) return ddo if (storeTx) return ddo
else return null else return null