Compare commits
No commits in common. "4609f183528b32806035986b47b589c46eece12a" and "2bb0e171d8bada09e40491680b82ab33a882e7eb" have entirely different histories.
4609f18352
...
2bb0e171d8
|
@ -735,7 +735,7 @@ class DataWrapper {
|
||||||
*/
|
*/
|
||||||
_putForCopy(cipherBundle, stream, part, dataStoreContext, destBackendInfo,
|
_putForCopy(cipherBundle, stream, part, dataStoreContext, destBackendInfo,
|
||||||
log, cb) {
|
log, cb) {
|
||||||
return this.put(cipherBundle, stream, part, dataStoreContext,
|
return this.put(cipherBundle, stream, part.size, dataStoreContext,
|
||||||
destBackendInfo, log, (error, partRetrievalInfo) => {
|
destBackendInfo, log, (error, partRetrievalInfo) => {
|
||||||
if (error) {
|
if (error) {
|
||||||
return cb(error);
|
return cb(error);
|
||||||
|
|
|
@ -46,8 +46,6 @@ class AzureClient {
|
||||||
try {
|
try {
|
||||||
this._client[azureMethod].apply(this._client, args);
|
this._client[azureMethod].apply(this._client, args);
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
console.log('ERROR IS', err);
|
|
||||||
console.log('ARGS WERE', args);
|
|
||||||
const error = errors.ServiceUnavailable;
|
const error = errors.ServiceUnavailable;
|
||||||
if (log) {
|
if (log) {
|
||||||
log.error('error thrown by Azure Storage Client Library',
|
log.error('error thrown by Azure Storage Client Library',
|
||||||
|
@ -157,7 +155,6 @@ class AzureClient {
|
||||||
return callback(null, azureKey);
|
return callback(null, azureKey);
|
||||||
}], log, callback);
|
}], log, callback);
|
||||||
}
|
}
|
||||||
console.log('PARAMS ARE', this._azureContainerName, azureKey, stream, size, options);
|
|
||||||
return this._errorWrapper('put', 'createBlockBlobFromStream',
|
return this._errorWrapper('put', 'createBlockBlobFromStream',
|
||||||
[this._azureContainerName, azureKey, stream, size, options,
|
[this._azureContainerName, azureKey, stream, size, options,
|
||||||
err => {
|
err => {
|
||||||
|
|
|
@ -148,8 +148,6 @@ const utils = {
|
||||||
});
|
});
|
||||||
},
|
},
|
||||||
translateAzureMetaHeaders(metaHeaders, tags) {
|
translateAzureMetaHeaders(metaHeaders, tags) {
|
||||||
console.log('TAGS ARE', tags);
|
|
||||||
console.log('meta headers are', metaHeaders);
|
|
||||||
const translatedMetaHeaders = {};
|
const translatedMetaHeaders = {};
|
||||||
if (tags) {
|
if (tags) {
|
||||||
// tags are passed as string of format 'key1=value1&key2=value2'
|
// tags are passed as string of format 'key1=value1&key2=value2'
|
||||||
|
@ -162,12 +160,10 @@ const utils = {
|
||||||
});
|
});
|
||||||
translatedMetaHeaders.tags = JSON.stringify(tagObj);
|
translatedMetaHeaders.tags = JSON.stringify(tagObj);
|
||||||
}
|
}
|
||||||
if (metaHeaders) {
|
Object.keys(metaHeaders).forEach(headerName => {
|
||||||
Object.keys(metaHeaders).forEach(headerName => {
|
const translated = headerName.substring(11).replace(/-/g, '_');
|
||||||
const translated = headerName.substring(11).replace(/-/g, '_');
|
translatedMetaHeaders[translated] = metaHeaders[headerName];
|
||||||
translatedMetaHeaders[translated] = metaHeaders[headerName];
|
});
|
||||||
});
|
|
||||||
}
|
|
||||||
return translatedMetaHeaders;
|
return translatedMetaHeaders;
|
||||||
},
|
},
|
||||||
/**
|
/**
|
||||||
|
|
Loading…
Reference in New Issue