186526/unpkg
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Use GAE trace agent

Browse Source
This commit is contained in:
Michael Jackson
2019-08-02 17:07:17 -07:00
parent 3289881a21
commit 1c850c8662
6 changed files with 392 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
modules/server.js
View File

@ -1,3 +1,7 @@
if (process.env.GAE_ENV === 'standard') {
require('@google-cloud/trace-agent').start();
}
import createServer from './createServer.js';
const server = createServer();

2
modules/utils/debug.js
View File

@ -1,2 +0,0 @@
const debug = process.env.DEBUG ? console.log.bind(console) : () => {};
export default debug;

5
modules/utils/logging.js Normal file
View File

@ -0,0 +1,5 @@
function noop() {}
export const debug = process.env.DEBUG ? console.log.bind(console) : noop;
export const info = console.log.bind(console);
export const error = console.error.bind(console);

31
modules/utils/npm.js
View File

@ -3,8 +3,8 @@ import https from 'https';
import gunzip from 'gunzip-maybe';
import LRUCache from 'lru-cache';
import debug from './debug.js';
import bufferStream from './bufferStream.js';
import * as log from './logging.js';
const npmRegistryURL =
process.env.NPM_REGISTRY_URL || 'https://registry.npmjs.org';
@ -45,7 +45,7 @@ async function fetchPackageInfo(packageName) {
const name = encodePackageName(packageName);
const infoURL = `${npmRegistryURL}/${name}`;
debug('Fetching package info for %s from %s', packageName, infoURL);
log.debug('Fetching package info for %s from %s', packageName, infoURL);
const { hostname, pathname } = url.parse(infoURL);
const options = {
@ -63,16 +63,13 @@ async function fetchPackageInfo(packageName) {
return bufferStream(res).then(JSON.parse);
}
if (res.statusCode === 404) {
return null;
}
const content = (await bufferStream(res)).toString('utf-8');
const data = await bufferStream(res);
const content = data.toString('utf-8');
log.error('Failed to fetch info for %s', packageName);
log.error('Status: %s', res.statusCode);
log.error('Content: %s', content);
throw new Error(
`Failed to fetch info for ${packageName}\nstatus: ${res.statusCode}\ndata: ${content}`
);
return null;
}
async function fetchVersionsAndTags(packageName) {
@ -168,7 +165,7 @@ export async function getPackage(packageName, version) {
: packageName;
const tarballURL = `${npmRegistryURL}/${packageName}/-/${tarballName}-${version}.tgz`;
debug('Fetching package for %s from %s', packageName, tarballURL);
log.debug('Fetching package for %s from %s', packageName, tarballURL);
const { hostname, pathname } = url.parse(tarballURL);
const options = {
@ -185,11 +182,11 @@ export async function getPackage(packageName, version) {
return stream;
}
const data = await bufferStream(res);
const spec = `${packageName}@${version}`;
const content = data.toString('utf-8');
const content = (await bufferStream(res)).toString('utf-8');
throw new Error(
`Failed to fetch tarball for ${spec}\nstatus: ${res.statusCode}\ndata: ${content}`
);
log.error('Failed to fetch tarball for %s@%s', packageName, version);
log.error('Status: %s', res.statusCode);
log.error('Content: %s', content);
return null;
}