Compare commits
4 Commits
Author | SHA1 | Date | |
---|---|---|---|
fe693e6383 | |||
6014e94ee0 | |||
88927fa6f8 | |||
e8133247f7 |
@ -26,6 +26,7 @@ mirror:
|
|||||||
snyk:
|
snyk:
|
||||||
stage: security
|
stage: security
|
||||||
script:
|
script:
|
||||||
|
- npmci npm prepare
|
||||||
- npmci command npm install -g snyk
|
- npmci command npm install -g snyk
|
||||||
- npmci command npm install --ignore-scripts
|
- npmci command npm install --ignore-scripts
|
||||||
- npmci command snyk test
|
- npmci command snyk test
|
||||||
@ -36,21 +37,11 @@ snyk:
|
|||||||
# ====================
|
# ====================
|
||||||
# test stage
|
# test stage
|
||||||
# ====================
|
# ====================
|
||||||
testLEGACY:
|
|
||||||
stage: test
|
|
||||||
script:
|
|
||||||
- npmci node install legacy
|
|
||||||
- npmci npm install
|
|
||||||
- npmci npm test
|
|
||||||
coverage: /\d+.?\d+?\%\s*coverage/
|
|
||||||
tags:
|
|
||||||
- docker
|
|
||||||
- notpriv
|
|
||||||
allow_failure: true
|
|
||||||
|
|
||||||
testLTS:
|
testLTS:
|
||||||
stage: test
|
stage: test
|
||||||
script:
|
script:
|
||||||
|
- npmci npm prepare
|
||||||
- npmci node install lts
|
- npmci node install lts
|
||||||
- npmci npm install
|
- npmci npm install
|
||||||
- npmci npm test
|
- npmci npm test
|
||||||
@ -62,6 +53,7 @@ testLTS:
|
|||||||
testSTABLE:
|
testSTABLE:
|
||||||
stage: test
|
stage: test
|
||||||
script:
|
script:
|
||||||
|
- npmci npm prepare
|
||||||
- npmci node install stable
|
- npmci node install stable
|
||||||
- npmci npm install
|
- npmci npm install
|
||||||
- npmci npm test
|
- npmci npm test
|
||||||
@ -118,6 +110,7 @@ pages:
|
|||||||
stage: metadata
|
stage: metadata
|
||||||
script:
|
script:
|
||||||
- npmci command npm install -g typedoc typescript
|
- npmci command npm install -g typedoc typescript
|
||||||
|
- npmci npm prepare
|
||||||
- npmci npm install
|
- npmci npm install
|
||||||
- npmci command typedoc --module "commonjs" --target "ES2016" --out public/ ts/
|
- npmci command typedoc --module "commonjs" --target "ES2016" --out public/ ts/
|
||||||
tags:
|
tags:
|
||||||
@ -130,13 +123,3 @@ pages:
|
|||||||
paths:
|
paths:
|
||||||
- public
|
- public
|
||||||
allow_failure: true
|
allow_failure: true
|
||||||
|
|
||||||
windowsCompatibility:
|
|
||||||
image: stefanscherer/node-windows:10-build-tools
|
|
||||||
stage: metadata
|
|
||||||
script:
|
|
||||||
- npm install & npm test
|
|
||||||
coverage: /\d+.?\d+?\%\s*coverage/
|
|
||||||
tags:
|
|
||||||
- windows
|
|
||||||
allow_failure: true
|
|
||||||
|
38
README.md
38
README.md
@ -1,25 +1,20 @@
|
|||||||
# smartrequest
|
# @pushrocks/smartrequest
|
||||||
|
|
||||||
dropin replacement for request
|
dropin replacement for request
|
||||||
|
|
||||||
## Availabililty
|
## Availabililty and Links
|
||||||
|
* [npmjs.org (npm package)](https://www.npmjs.com/package/@pushrocks/smartrequest)
|
||||||
[](https://www.npmjs.com/package/smartrequest)
|
* [gitlab.com (source)](https://gitlab.com/pushrocks/smartrequest)
|
||||||
[](https://GitLab.com/pushrocks/smartrequest)
|
* [github.com (source mirror)](https://github.com/pushrocks/smartrequest)
|
||||||
[](https://github.com/pushrocks/smartrequest)
|
* [docs (typedoc)](https://pushrocks.gitlab.io/smartrequest/)
|
||||||
[](https://pushrocks.gitlab.io/smartrequest/)
|
|
||||||
|
|
||||||
## Status for master
|
## Status for master
|
||||||
|
[](https://gitlab.com/pushrocks/smartrequest/commits/master)
|
||||||
[](https://GitLab.com/pushrocks/smartrequest/commits/master)
|
[](https://gitlab.com/pushrocks/smartrequest/commits/master)
|
||||||
[](https://GitLab.com/pushrocks/smartrequest/commits/master)
|
[](https://www.npmjs.com/package/@pushrocks/smartrequest)
|
||||||
[](https://www.npmjs.com/package/smartrequest)
|
[](https://snyk.io/test/npm/@pushrocks/smartrequest)
|
||||||
[](https://david-dm.org/pushrocks/smartrequest)
|
[](https://nodejs.org/dist/latest-v10.x/docs/api/)
|
||||||
[](https://www.bithound.io/github/pushrocks/smartrequest/master/dependencies/npm)
|
[](https://nodejs.org/dist/latest-v10.x/docs/api/)
|
||||||
[](https://www.bithound.io/github/pushrocks/smartrequest)
|
[](https://prettier.io/)
|
||||||
[](https://nodejs.org/dist/latest-v6.x/docs/api/)
|
|
||||||
[](https://nodejs.org/dist/latest-v6.x/docs/api/)
|
|
||||||
[](http://standardjs.com/)
|
|
||||||
|
|
||||||
## Usage
|
## Usage
|
||||||
|
|
||||||
@ -66,4 +61,9 @@ smartrequest.get('https://example.com/bigfile.mp4', optionsArg, true).then(res =
|
|||||||
})
|
})
|
||||||
```
|
```
|
||||||
|
|
||||||
[](https://push.rocks)
|
For further information read the linked docs at the top of this readme.
|
||||||
|
|
||||||
|
> MIT licensed | **©** [Lossless GmbH](https://lossless.gmbh)
|
||||||
|
| By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy.html)
|
||||||
|
|
||||||
|
[](https://maintainedby.lossless.com)
|
||||||
|
@ -3,9 +3,17 @@
|
|||||||
"coverageTreshold": 50
|
"coverageTreshold": 50
|
||||||
},
|
},
|
||||||
"npmci": {
|
"npmci": {
|
||||||
"npmGlobalTools": [
|
"npmGlobalTools": [],
|
||||||
"npmts"
|
|
||||||
],
|
|
||||||
"npmAccessLevel": "public"
|
"npmAccessLevel": "public"
|
||||||
|
},
|
||||||
|
"gitzone": {
|
||||||
|
"module": {
|
||||||
|
"githost": "gitlab.com",
|
||||||
|
"gitscope": "pushrocks",
|
||||||
|
"gitrepo": "smartrequest",
|
||||||
|
"shortDescription": "dropin replacement for request",
|
||||||
|
"npmPackagename": "@pushrocks/smartrequest",
|
||||||
|
"license": "MIT"
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
980
package-lock.json
generated
980
package-lock.json
generated
File diff suppressed because it is too large
Load Diff
16
package.json
16
package.json
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@pushrocks/smartrequest",
|
"name": "@pushrocks/smartrequest",
|
||||||
"version": "1.1.13",
|
"version": "1.1.15",
|
||||||
"private": false,
|
"private": false,
|
||||||
"description": "dropin replacement for request",
|
"description": "dropin replacement for request",
|
||||||
"main": "dist/index.js",
|
"main": "dist/index.js",
|
||||||
@ -23,15 +23,15 @@
|
|||||||
},
|
},
|
||||||
"homepage": "https://gitlab.com/pushrocks/smartrequest#README",
|
"homepage": "https://gitlab.com/pushrocks/smartrequest#README",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@pushrocks/smartpromise": "^2.0.5",
|
"@pushrocks/smartpromise": "^3.0.2",
|
||||||
"@types/form-data": "^2.2.1",
|
"@types/form-data": "^2.2.1",
|
||||||
"form-data": "^2.3.2"
|
"form-data": "^2.3.3"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@gitzone/tsbuild": "^2.0.22",
|
"@gitzone/tsbuild": "^2.1.8",
|
||||||
"@gitzone/tsrun": "^1.1.12",
|
"@gitzone/tsrun": "^1.2.5",
|
||||||
"@gitzone/tstest": "^1.0.15",
|
"@gitzone/tstest": "^1.0.20",
|
||||||
"@pushrocks/tapbundle": "^3.0.5",
|
"@pushrocks/tapbundle": "^3.0.9",
|
||||||
"@types/node": "^10.5.8"
|
"@types/node": "^11.13.6"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
15
test/test.ts
15
test/test.ts
@ -23,17 +23,18 @@ tap.test('should post a JSON document over http', async () => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
tap.skip.test('should deal with unix socks', async () => {
|
tap.skip.test('should deal with unix socks', async () => {
|
||||||
const socketResponse = await smartrequest.request('http://unix:/var/run/docker.sock:/containers/json', {
|
const socketResponse = await smartrequest.request(
|
||||||
|
'http://unix:/var/run/docker.sock:/containers/json',
|
||||||
|
{
|
||||||
headers: {
|
headers: {
|
||||||
"Content-Type": "application/json",
|
'Content-Type': 'application/json',
|
||||||
"Host": "docker.sock"
|
Host: 'docker.sock'
|
||||||
}
|
}
|
||||||
});
|
}
|
||||||
|
);
|
||||||
console.log(socketResponse.body);
|
console.log(socketResponse.body);
|
||||||
});
|
});
|
||||||
|
|
||||||
tap.skip.test('should correctly upload a file using formData', async () => {
|
tap.skip.test('should correctly upload a file using formData', async () => {});
|
||||||
|
|
||||||
})
|
|
||||||
|
|
||||||
tap.start();
|
tap.start();
|
||||||
|
@ -1,25 +1,20 @@
|
|||||||
import * as plugins from "./smartrequest.plugins";
|
import * as plugins from './smartrequest.plugins';
|
||||||
import * as interfaces from "./smartrequest.interfaces";
|
import * as interfaces from './smartrequest.interfaces';
|
||||||
import { request } from "./smartrequest.request";
|
import { request } from './smartrequest.request';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* the interfae for FormFieldData
|
* the interfae for FormFieldData
|
||||||
*/
|
*/
|
||||||
export interface IFormField {
|
export interface IFormField {
|
||||||
name: string;
|
name: string;
|
||||||
type: "string" | "filePath" | "Buffer";
|
type: 'string' | 'filePath' | 'Buffer';
|
||||||
payload: string;
|
payload: string;
|
||||||
}
|
}
|
||||||
|
|
||||||
const appendFormField = async (
|
const appendFormField = async (formDataArg: plugins.formData, formDataField: IFormField) => {
|
||||||
formDataArg: plugins.formData,
|
if (formDataField.type === 'filePath') {
|
||||||
formDataField: IFormField
|
let fileData = plugins.fs.readFileSync(plugins.path.join(process.cwd(), formDataField.payload));
|
||||||
) => {
|
formDataArg.append('file', fileData, {
|
||||||
if (formDataField.type === "filePath") {
|
|
||||||
let fileData = plugins.fs.readFileSync(
|
|
||||||
plugins.path.join(process.cwd(), formDataField.payload)
|
|
||||||
);
|
|
||||||
formDataArg.append("file", fileData, {
|
|
||||||
filename: 'upload.pdf',
|
filename: 'upload.pdf',
|
||||||
contentType: 'application/pdf'
|
contentType: 'application/pdf'
|
||||||
});
|
});
|
||||||
@ -38,7 +33,7 @@ export const postFormData = async (
|
|||||||
const requestOptions = Object.assign({}, optionsArg, {
|
const requestOptions = Object.assign({}, optionsArg, {
|
||||||
method: 'POST',
|
method: 'POST',
|
||||||
headers: {
|
headers: {
|
||||||
...(optionsArg.headers),
|
...optionsArg.headers,
|
||||||
...form.getHeaders()
|
...form.getHeaders()
|
||||||
},
|
},
|
||||||
requestBody: form
|
requestBody: form
|
||||||
|
@ -7,4 +7,4 @@ import * as url from 'url';
|
|||||||
|
|
||||||
import * as smartpromise from '@pushrocks/smartpromise';
|
import * as smartpromise from '@pushrocks/smartpromise';
|
||||||
|
|
||||||
export {formData, http, https, fs, path, url, smartpromise };
|
export { formData, http, https, fs, path, url, smartpromise };
|
||||||
|
@ -1,8 +1,8 @@
|
|||||||
import * as https from "https";
|
import * as https from 'https';
|
||||||
import * as plugins from "./smartrequest.plugins";
|
import * as plugins from './smartrequest.plugins';
|
||||||
import * as interfaces from "./smartrequest.interfaces";
|
import * as interfaces from './smartrequest.interfaces';
|
||||||
|
|
||||||
import { IncomingMessage } from "http";
|
import { IncomingMessage } from 'http';
|
||||||
|
|
||||||
export interface IExtendedIncomingMessage extends IncomingMessage {
|
export interface IExtendedIncomingMessage extends IncomingMessage {
|
||||||
body: any;
|
body: any;
|
||||||
@ -13,12 +13,12 @@ const buildUtf8Response = (
|
|||||||
): Promise<IExtendedIncomingMessage> => {
|
): Promise<IExtendedIncomingMessage> => {
|
||||||
let done = plugins.smartpromise.defer<IExtendedIncomingMessage>();
|
let done = plugins.smartpromise.defer<IExtendedIncomingMessage>();
|
||||||
// Continuously update stream with data
|
// Continuously update stream with data
|
||||||
let body = "";
|
let body = '';
|
||||||
incomingMessageArg.on("data", function(chunkArg) {
|
incomingMessageArg.on('data', function(chunkArg) {
|
||||||
body += chunkArg;
|
body += chunkArg;
|
||||||
});
|
});
|
||||||
|
|
||||||
incomingMessageArg.on("end", function() {
|
incomingMessageArg.on('end', function() {
|
||||||
try {
|
try {
|
||||||
(incomingMessageArg as IExtendedIncomingMessage).body = JSON.parse(body);
|
(incomingMessageArg as IExtendedIncomingMessage).body = JSON.parse(body);
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
@ -47,8 +47,8 @@ const parseSocketPathAndRoute = (stringToParseArg: string) => {
|
|||||||
return {
|
return {
|
||||||
socketPath: result[1],
|
socketPath: result[1],
|
||||||
path: result[2]
|
path: result[2]
|
||||||
}
|
};
|
||||||
}
|
};
|
||||||
|
|
||||||
export let request = async (
|
export let request = async (
|
||||||
domainArg: string,
|
domainArg: string,
|
||||||
@ -67,31 +67,30 @@ export let request = async (
|
|||||||
optionsArg.path = parsedUrl.path;
|
optionsArg.path = parsedUrl.path;
|
||||||
|
|
||||||
// determine if unixsock
|
// determine if unixsock
|
||||||
if(testForUnixSock(domainArg)) {
|
if (testForUnixSock(domainArg)) {
|
||||||
const detailedUnixPath = parseSocketPathAndRoute(optionsArg.path)
|
const detailedUnixPath = parseSocketPathAndRoute(optionsArg.path);
|
||||||
optionsArg.socketPath = detailedUnixPath.socketPath;
|
optionsArg.socketPath = detailedUnixPath.socketPath;
|
||||||
optionsArg.path = detailedUnixPath.path;
|
optionsArg.path = detailedUnixPath.path;
|
||||||
}
|
}
|
||||||
|
|
||||||
// lets determine the request module to use
|
// lets determine the request module to use
|
||||||
const requestModule = (() => {
|
const requestModule = (() => {
|
||||||
if (parsedUrl.protocol === "https:") {
|
if (parsedUrl.protocol === 'https:') {
|
||||||
return plugins.https;
|
return plugins.https;
|
||||||
} else if (parsedUrl.protocol === "http:") {
|
} else if (parsedUrl.protocol === 'http:') {
|
||||||
return plugins.http;
|
return plugins.http;
|
||||||
} else {
|
} else {
|
||||||
throw new Error(`unsupported protocol: ${parsedUrl.protocol}`);
|
throw new Error(`unsupported protocol: ${parsedUrl.protocol}`);
|
||||||
}
|
}
|
||||||
})() as typeof plugins.https;
|
})() as typeof plugins.https;
|
||||||
|
|
||||||
|
|
||||||
// lets perform the actual request
|
// lets perform the actual request
|
||||||
let request = requestModule.request(optionsArg);
|
let request = requestModule.request(optionsArg);
|
||||||
|
|
||||||
// lets write the requestBody
|
// lets write the requestBody
|
||||||
if (optionsArg.requestBody) {
|
if (optionsArg.requestBody) {
|
||||||
if (!(optionsArg.requestBody instanceof plugins.formData)) {
|
if (!(optionsArg.requestBody instanceof plugins.formData)) {
|
||||||
if(typeof optionsArg.requestBody !== "string") {
|
if (typeof optionsArg.requestBody !== 'string') {
|
||||||
optionsArg.requestBody = JSON.stringify(optionsArg.requestBody);
|
optionsArg.requestBody = JSON.stringify(optionsArg.requestBody);
|
||||||
}
|
}
|
||||||
request.write(optionsArg.requestBody);
|
request.write(optionsArg.requestBody);
|
||||||
@ -106,16 +105,16 @@ export let request = async (
|
|||||||
}
|
}
|
||||||
|
|
||||||
// lets handle an error
|
// lets handle an error
|
||||||
request.on("error", e => {
|
request.on('error', e => {
|
||||||
console.error(e);
|
console.error(e);
|
||||||
});
|
});
|
||||||
|
|
||||||
// lets handle the response
|
// lets handle the response
|
||||||
request.on("response", async response => {
|
request.on('response', async response => {
|
||||||
if (streamArg) {
|
if (streamArg) {
|
||||||
done.resolve(response);
|
done.resolve(response);
|
||||||
} else {
|
} else {
|
||||||
const builtResponse = await buildUtf8Response(response)
|
const builtResponse = await buildUtf8Response(response);
|
||||||
done.resolve(builtResponse);
|
done.resolve(builtResponse);
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
16
tslint.json
16
tslint.json
@ -1,3 +1,17 @@
|
|||||||
{
|
{
|
||||||
"extends": "tslint-config-standard"
|
"extends": ["tslint:latest", "tslint-config-prettier"],
|
||||||
|
"rules": {
|
||||||
|
"semicolon": [true, "always"],
|
||||||
|
"no-console": false,
|
||||||
|
"ordered-imports": false,
|
||||||
|
"object-literal-sort-keys": false,
|
||||||
|
"member-ordering": {
|
||||||
|
"options":{
|
||||||
|
"order": [
|
||||||
|
"static-method"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
},
|
||||||
|
"defaultSeverity": "warning"
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user