openreplay/sourcemap-uploader/lib/uploadSourcemaps.js

73 lines
2 KiB
JavaScript

const https = require('https');
const getUploadURLs = (api_key, project_key, js_file_urls) =>
new Promise((resolve, reject) => {
if (js_file_urls.length === 0) {
resolve([]);
}
const pathPrefix = (global.SERVER.pathname + "/").replace(/\/+/g, '/');
const req = https.request(
{
method: 'PUT',
hostname: global.SERVER.host,
path: pathPrefix + `${project_key}/sourcemaps/`,
headers: { Authorization: api_key, 'Content-Type': 'application/json' },
},
res => {
if (res.statusCode === 403) {
reject("Authorisation rejected. Please, check your API_KEY and/or PROJECT_KEY.")
return
} else if (res.statusCode !== 200) {
reject("Server Error. Please, contact OpenReplay support.");
return;
}
let data = '';
res.on('data', s => (data += s));
res.on('end', () => resolve(JSON.parse(data).data));
},
);
req.on('error', reject);
req.write(JSON.stringify({ URL: js_file_urls }));
req.end();
});
const uploadSourcemap = (upload_url, body) =>
new Promise((resolve, reject) => {
body = Buffer.from(JSON.stringify(body));
const req = https.request(
upload_url,
{
method: 'PUT',
headers: {
'Content-Length': body.length,
'Content-Type': 'application/json',
},
},
res => {
if (res.statusCode !== 200) {
reject("Unable to upload. Please, contact OpenReplay support.");
return;
}
resolve();
//res.on('end', resolve);
},
);
req.on('error', reject);
req.write(body);
req.end();
});
module.exports = (api_key, project_key, sourcemaps) =>
getUploadURLs(
api_key,
project_key,
sourcemaps.map(({ js_file_url }) => js_file_url),
).then(upload_urls =>
Promise.all(
upload_urls.map((upload_url, i) =>
uploadSourcemap(upload_url, sourcemaps[i].body)
.then(() => sourcemaps[i].js_file_url)
),
),
);