Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

@reactive-js/http

Package Overview
Dependencies
Maintainers
1
Versions
10
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@reactive-js/http - npm Package Compare versions

Comparing version 0.0.41 to 0.0.42

build/types/lib/httpServer.d.ts

18

build/types/lib/http.d.ts

@@ -1,7 +0,11 @@

export { CacheDirective, HttpContentEncoding, HttpContentInfo, HttpDateTime, HttpHeaders, HttpMessage, HttpMethod, HttpPreferences, HttpRequest, HttpResponse, HttpServerRequest, HttpStatusCode, EntityTag, MediaType, URILike, } from "./internal/http/interfaces";
export { createHttpRequest, createRedirectHttpRequest, decodeHttpRequestContent, decodeHttpRequestWithCharset, disallowProtocolAndHostForwarding, encodeHttpRequestWithUtf8, encodeHttpClientRequestContent, httpRequestToUntypedHeaders, parseHttpRequestFromHeaders, toIOSourceHttpRequest, writeHttpRequestHeaders, } from "./internal/http/httpRequest";
export { checkIfNotModified, createHttpResponse, createHttpErrorResponse, decodeHttpResponseContent, decodeHttpResponseWithCharset, encodeHttpResponseWithUtf8, encodeHttpResponseContent, parseHttpResponseFromHeaders, toIOSourceHttpResponse, writeHttpResponseHeaders, } from "./internal/http/httpResponse";
export { HttpStandardHeader, HttpExtensionHeader, } from "./internal/http/httpHeaders";
export { parseHeaders } from "./internal/http/httpGrammar";
export { HttpServer, HttpRoutedRequest, createRoutingHttpServer, } from "./internal/http/httpServer";
export { HttpClientRequestStatusType, HttpClientRequestStatusStart, HttpClientRequestStatusProgress, HttpClientRequestStatusComplete, HttpClientRequestStatusHeadersReceived, HttpClientRequestStatus, HttpClientRequest, HttpClient, withDefaultBehaviors, } from "./internal/http/httpClient";
export { CacheDirective } from "./internal/cacheDirective";
export { HttpContentEncoding, HttpContentInfo, } from "./internal/httpContentInfo";
export { HttpDateTime } from "./internal/httpDateTime";
export { HttpHeaders } from "./internal/httpHeaders";
export { HttpMessage, URILike } from "./internal/httpMessage";
export { HttpPreferences } from "./internal/httpPreferences";
export { EntityTag } from "./internal/entityTag";
export { MediaType } from "./internal/mediaType";
export { HttpStandardHeader, HttpExtensionHeader, } from "./internal/httpHeaders";
export { HttpMethod, HttpRequest, createHttpRequest, createRedirectHttpRequest, decodeHttpRequestContent, decodeHttpRequestWithCharset, encodeHttpRequestWithUtf8, httpRequestToUntypedHeaders, toIOSourceHttpRequest, writeHttpRequestHeaders, } from "./internal/httpRequest";
export { HttpStatusCode, HttpResponse, checkIfNotModified, createHttpResponse, createHttpErrorResponse, decodeHttpResponseContent, decodeHttpResponseWithCharset, encodeHttpResponseWithUtf8, encodeHttpResponseContent, parseHttpResponseFromHeaders, toIOSourceHttpResponse, writeHttpResponseHeaders, } from "./internal/httpResponse";

@@ -8,3 +8,4 @@ /// <reference types="node" />

import { SchedulerLike } from "@reactive-js/core/lib/scheduler";
import { HttpResponse, HttpServerRequest, HttpServer } from "../../http";
import { HttpResponse } from "../../http";
import { HttpServerRequest, HttpServer } from "../../httpServer";
export declare type HttpRequestListenerOptions = {

@@ -11,0 +12,0 @@ readonly onError?: Function1<unknown, void | ObservableLike<unknown>>;

@@ -1,3 +0,2 @@

export { HttpClientOptions, createHttpClient, } from "./internal/node/httpClient";
export { HttpRequestListener, HttpRequestListenerOptions, createHttpRequestListener, } from "./internal/node/httpRequestListener";
export { createContentEncodingDecompressTransforms, createContentEncodingCompressTransforms, } from "./internal/node/httpContentEncoding";

@@ -1,7 +0,11 @@

export { CacheDirective, HttpContentEncoding, HttpContentInfo, HttpDateTime, HttpHeaders, HttpMessage, HttpMethod, HttpPreferences, HttpRequest, HttpResponse, HttpServerRequest, HttpStatusCode, EntityTag, MediaType, URILike, } from "./internal/http/interfaces";
export { createHttpRequest, createRedirectHttpRequest, decodeHttpRequestContent, decodeHttpRequestWithCharset, disallowProtocolAndHostForwarding, encodeHttpRequestWithUtf8, encodeHttpClientRequestContent, httpRequestToUntypedHeaders, parseHttpRequestFromHeaders, toIOSourceHttpRequest, writeHttpRequestHeaders, } from "./internal/http/httpRequest";
export { checkIfNotModified, createHttpResponse, createHttpErrorResponse, decodeHttpResponseContent, decodeHttpResponseWithCharset, encodeHttpResponseWithUtf8, encodeHttpResponseContent, parseHttpResponseFromHeaders, toIOSourceHttpResponse, writeHttpResponseHeaders, } from "./internal/http/httpResponse";
export { HttpStandardHeader, HttpExtensionHeader, } from "./internal/http/httpHeaders";
export { parseHeaders } from "./internal/http/httpGrammar";
export { HttpServer, HttpRoutedRequest, createRoutingHttpServer, } from "./internal/http/httpServer";
export { HttpClientRequestStatusType, HttpClientRequestStatusStart, HttpClientRequestStatusProgress, HttpClientRequestStatusComplete, HttpClientRequestStatusHeadersReceived, HttpClientRequestStatus, HttpClientRequest, HttpClient, withDefaultBehaviors, } from "./internal/http/httpClient";
export { CacheDirective } from "./internal/cacheDirective";
export { HttpContentEncoding, HttpContentInfo, } from "./internal/httpContentInfo";
export { HttpDateTime } from "./internal/httpDateTime";
export { HttpHeaders } from "./internal/httpHeaders";
export { HttpMessage, URILike } from "./internal/httpMessage";
export { HttpPreferences } from "./internal/httpPreferences";
export { EntityTag } from "./internal/entityTag";
export { MediaType } from "./internal/mediaType";
export { HttpStandardHeader, HttpExtensionHeader, } from "./internal/httpHeaders";
export { HttpMethod, HttpRequest, createHttpRequest, createRedirectHttpRequest, decodeHttpRequestContent, decodeHttpRequestWithCharset, encodeHttpRequestWithUtf8, httpRequestToUntypedHeaders, toIOSourceHttpRequest, writeHttpRequestHeaders, } from "./internal/httpRequest";
export { HttpStatusCode, HttpResponse, checkIfNotModified, createHttpResponse, createHttpErrorResponse, decodeHttpResponseContent, decodeHttpResponseWithCharset, encodeHttpResponseWithUtf8, encodeHttpResponseContent, parseHttpResponseFromHeaders, toIOSourceHttpResponse, writeHttpResponseHeaders, } from "./internal/httpResponse";
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var httpRequest_1 = require("./internal/http/httpRequest");
var httpRequest_1 = require("./internal/httpRequest");
exports.createHttpRequest = httpRequest_1.createHttpRequest;

@@ -8,10 +8,7 @@ exports.createRedirectHttpRequest = httpRequest_1.createRedirectHttpRequest;

exports.decodeHttpRequestWithCharset = httpRequest_1.decodeHttpRequestWithCharset;
exports.disallowProtocolAndHostForwarding = httpRequest_1.disallowProtocolAndHostForwarding;
exports.encodeHttpRequestWithUtf8 = httpRequest_1.encodeHttpRequestWithUtf8;
exports.encodeHttpClientRequestContent = httpRequest_1.encodeHttpClientRequestContent;
exports.httpRequestToUntypedHeaders = httpRequest_1.httpRequestToUntypedHeaders;
exports.parseHttpRequestFromHeaders = httpRequest_1.parseHttpRequestFromHeaders;
exports.toIOSourceHttpRequest = httpRequest_1.toIOSourceHttpRequest;
exports.writeHttpRequestHeaders = httpRequest_1.writeHttpRequestHeaders;
var httpResponse_1 = require("./internal/http/httpResponse");
var httpResponse_1 = require("./internal/httpResponse");
exports.checkIfNotModified = httpResponse_1.checkIfNotModified;

@@ -27,7 +24,1 @@ exports.createHttpResponse = httpResponse_1.createHttpResponse;

exports.writeHttpResponseHeaders = httpResponse_1.writeHttpResponseHeaders;
var httpGrammar_1 = require("./internal/http/httpGrammar");
exports.parseHeaders = httpGrammar_1.parseHeaders;
var httpServer_1 = require("./internal/http/httpServer");
exports.createRoutingHttpServer = httpServer_1.createRoutingHttpServer;
var httpClient_1 = require("./internal/http/httpClient");
exports.withDefaultBehaviors = httpClient_1.withDefaultBehaviors;

@@ -8,3 +8,4 @@ /// <reference types="node" />

import { SchedulerLike } from "@reactive-js/core/lib/scheduler";
import { HttpResponse, HttpServerRequest, HttpServer } from "../../http";
import { HttpResponse } from "../../http";
import { HttpServerRequest, HttpServer } from "../../httpServer";
export declare type HttpRequestListenerOptions = {

@@ -11,0 +12,0 @@ readonly onError?: Function1<unknown, void | ObservableLike<unknown>>;

@@ -9,2 +9,3 @@ "use strict";

const http_1 = require("../../http");
const httpServer_1 = require("../../httpServer");
const writeResponseMessage = (serverResponse) => (response) => {

@@ -35,3 +36,3 @@ serverResponse.statusCode = response.statusCode;

body: requestBody,
}, http_1.parseHttpRequestFromHeaders), observable_1.compute(), observable_1.await_(handler), observable_1.onNotify(writeResponseMessage(response.value)), observable_1.await_(writeResponseBody(responseBody)), observable_1.catchError(onError));
}, httpServer_1.parseHttpServerRequestFromHeaders), observable_1.compute(), observable_1.await_(handler), observable_1.onNotify(writeResponseMessage(response.value)), observable_1.await_(writeResponseBody(responseBody)), observable_1.catchError(onError));
};

@@ -38,0 +39,0 @@ return (req, resp) => {

@@ -1,3 +0,2 @@

export { HttpClientOptions, createHttpClient, } from "./internal/node/httpClient";
export { HttpRequestListener, HttpRequestListenerOptions, createHttpRequestListener, } from "./internal/node/httpRequestListener";
export { createContentEncodingDecompressTransforms, createContentEncodingCompressTransforms, } from "./internal/node/httpContentEncoding";
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var httpClient_1 = require("./internal/node/httpClient");
exports.createHttpClient = httpClient_1.createHttpClient;
var httpRequestListener_1 = require("./internal/node/httpRequestListener");

@@ -6,0 +4,0 @@ exports.createHttpRequestListener = httpRequestListener_1.createHttpRequestListener;

@@ -1,5 +0,2 @@

export { createHttpRequest, createRedirectHttpRequest, decodeHttpRequestContent, decodeHttpRequestWithCharset, disallowProtocolAndHostForwarding, encodeHttpRequestWithUtf8, encodeHttpClientRequestContent, httpRequestToUntypedHeaders, parseHttpRequestFromHeaders, toIOSourceHttpRequest, writeHttpRequestHeaders, } from "./internal/http/httpRequest.js";
export { checkIfNotModified, createHttpResponse, createHttpErrorResponse, decodeHttpResponseContent, decodeHttpResponseWithCharset, encodeHttpResponseWithUtf8, encodeHttpResponseContent, parseHttpResponseFromHeaders, toIOSourceHttpResponse, writeHttpResponseHeaders, } from "./internal/http/httpResponse.js";
export { parseHeaders } from "./internal/http/httpGrammar.js";
export { createRoutingHttpServer, } from "./internal/http/httpServer.js";
export { withDefaultBehaviors, } from "./internal/http/httpClient.js";
export { createHttpRequest, createRedirectHttpRequest, decodeHttpRequestContent, decodeHttpRequestWithCharset, encodeHttpRequestWithUtf8, httpRequestToUntypedHeaders, toIOSourceHttpRequest, writeHttpRequestHeaders, } from "./internal/httpRequest.js";
export { checkIfNotModified, createHttpResponse, createHttpErrorResponse, decodeHttpResponseContent, decodeHttpResponseWithCharset, encodeHttpResponseWithUtf8, encodeHttpResponseContent, parseHttpResponseFromHeaders, toIOSourceHttpResponse, writeHttpResponseHeaders, } from "./internal/httpResponse.js";

@@ -0,20 +1,26 @@

export { CacheDirective } from "./internal/cacheDirective.ts";
export {
CacheDirective,
HttpContentEncoding,
HttpContentInfo,
HttpDateTime,
HttpHeaders,
HttpMessage,
} from "./internal/httpContentInfo.ts";
export { HttpDateTime } from "./internal/httpDateTime.ts";
export { HttpHeaders } from "./internal/httpHeaders.ts";
export { HttpMessage, URILike } from "./internal/httpMessage.ts";
export { HttpPreferences } from "./internal/httpPreferences.ts";
export { EntityTag } from "./internal/entityTag.ts";
export { MediaType } from "./internal/mediaType.ts";
export {
HttpStandardHeader,
HttpExtensionHeader,
} from "./internal/httpHeaders.ts";
export {
HttpMethod,
HttpPreferences,
HttpRequest,
HttpResponse,
HttpServerRequest,
HttpStatusCode,
EntityTag,
MediaType,
URILike,
} from "./internal/http/interfaces.ts";
export {
createHttpRequest,

@@ -24,12 +30,11 @@ createRedirectHttpRequest,

decodeHttpRequestWithCharset,
disallowProtocolAndHostForwarding,
encodeHttpRequestWithUtf8,
encodeHttpClientRequestContent,
httpRequestToUntypedHeaders,
parseHttpRequestFromHeaders,
toIOSourceHttpRequest,
writeHttpRequestHeaders,
} from "./internal/http/httpRequest.ts";
} from "./internal/httpRequest.ts";
export {
HttpStatusCode,
HttpResponse,
checkIfNotModified,

@@ -45,27 +50,2 @@ createHttpResponse,

writeHttpResponseHeaders,
} from "./internal/http/httpResponse.ts";
export {
HttpStandardHeader,
HttpExtensionHeader,
} from "./internal/http/httpHeaders.ts";
export { parseHeaders } from "./internal/http/httpGrammar.ts";
export {
HttpServer,
HttpRoutedRequest,
createRoutingHttpServer,
} from "./internal/http/httpServer.ts";
export {
HttpClientRequestStatusType,
HttpClientRequestStatusStart,
HttpClientRequestStatusProgress,
HttpClientRequestStatusComplete,
HttpClientRequestStatusHeadersReceived,
HttpClientRequestStatus,
HttpClientRequest,
HttpClient,
withDefaultBehaviors,
} from "./internal/http/httpClient.ts";
} from "./internal/httpResponse.ts";
{
"name": "@reactive-js/http",
"version": "0.0.41",
"version": "0.0.42",
"keywords": [

@@ -39,3 +39,3 @@ "asynchronous",

"dependencies": {
"@reactive-js/core": "^0.0.41"
"@reactive-js/core": "^0.0.42"
},

@@ -76,3 +76,3 @@ "devDependencies": {

"mod-rm-node": "rm -rf ./mod/lib/node.* ./mod/lib/internal/node",
"mod-alias-reactive-js-core": "replace '@reactive-js/core/' '../../../core/mod/' ./mod/lib/* && replace '@reactive-js/core/' '../../../../core/mod/' ./mod/lib/internal/* && replace '@reactive-js/core/' '../../../../../core/mod/' ./mod/lib/internal/**/*",
"mod-alias-reactive-js-core": "replace '@reactive-js/core/' '../../../core/mod/' ./mod/lib/* && replace '@reactive-js/core/' '../../../../core/mod/' ./mod/lib/internal/*",
"docs": "node ../../scripts/docs.mjs",

@@ -95,3 +95,3 @@ "test": "jest",

},
"gitHead": "df7885624c8cebb5351cbec22ff65ec75d37266d"
"gitHead": "3007e8122b3754709adf20c5c6fbbf69a3ed4a68"
}

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc