Compare commits
39 Commits
Author | SHA1 | Date | |
---|---|---|---|
82edd4b457 | |||
dd23719646 | |||
53aece818a | |||
fba724741b | |||
854cc93644 | |||
ec7fa07855 | |||
b34e88123d | |||
b680ab8c23 | |||
f0547b33d3 | |||
20c5b115d8 | |||
c3801ecd53 | |||
51f03a45b6 | |||
ed8879a4c8 | |||
806970c701 | |||
9638f74440 | |||
b538c4fbdb | |||
1d3dc08e39 | |||
56f59bf640 | |||
268df991c4 | |||
b3d8dd1573 | |||
0fb36ea928 | |||
10148f7c50 | |||
274bf30973 | |||
e3ff1c3c4b | |||
446a9d1723 | |||
a749f91a8f | |||
8ea6db7b7f | |||
715ee43bcc | |||
c314b4e86f | |||
5824d34764 | |||
5eb9035dfe | |||
a49b1813fb | |||
e33ae24f17 | |||
2e13632fec | |||
9175af027b | |||
f9524a62d7 | |||
7889e04915 | |||
a81b9eced6 | |||
4aa06fe830 |
@ -2,17 +2,29 @@
|
||||
"gitzone": {
|
||||
"projectType": "npm",
|
||||
"module": {
|
||||
"githost": "gitlab.com",
|
||||
"githost": "code.foss.global",
|
||||
"gitscope": "api.global",
|
||||
"gitrepo": "typedrequest-interfaces",
|
||||
"description": "interfaces for making typed requests",
|
||||
"description": "A library providing interfaces for making typed HTTP requests.",
|
||||
"npmPackagename": "@api.global/typedrequest-interfaces",
|
||||
"license": "MIT",
|
||||
"projectDomain": "api.global"
|
||||
"projectDomain": "api.global",
|
||||
"keywords": [
|
||||
"HTTP",
|
||||
"requests",
|
||||
"interfaces",
|
||||
"TypeScript",
|
||||
"streaming",
|
||||
"API",
|
||||
"virtual streams"
|
||||
]
|
||||
}
|
||||
},
|
||||
"npmci": {
|
||||
"npmGlobalTools": [],
|
||||
"npmAccessLevel": "public"
|
||||
},
|
||||
"tsdoc": {
|
||||
"legal": "\n## License and Legal Information\n\nThis repository contains open-source code that is licensed under the MIT License. A copy of the MIT License can be found in the [license](license) file within this repository. \n\n**Please note:** The MIT License does not grant permission to use the trade names, trademarks, service marks, or product names of the project, except as required for reasonable and customary use in describing the origin of the work and reproducing the content of the NOTICE file.\n\n### Trademarks\n\nThis project is owned and maintained by Task Venture Capital GmbH. The names and logos associated with Task Venture Capital GmbH and any related products or services are trademarks of Task Venture Capital GmbH and are not included within the scope of the MIT license granted herein. Use of these trademarks must comply with Task Venture Capital GmbH's Trademark Guidelines, and any usage must be approved in writing by Task Venture Capital GmbH.\n\n### Company Information\n\nTask Venture Capital GmbH \nRegistered at District court Bremen HRB 35230 HB, Germany\n\nFor any legal inquiries or if you require further information, please contact us via email at hello@task.vc.\n\nBy using this repository, you acknowledge that you have read this section, agree to comply with its terms, and understand that the licensing of the code does not imply endorsement by Task Venture Capital GmbH of any derivative works.\n"
|
||||
}
|
||||
}
|
17
package.json
17
package.json
@ -1,8 +1,8 @@
|
||||
{
|
||||
"name": "@api.global/typedrequest-interfaces",
|
||||
"version": "3.0.0",
|
||||
"version": "3.0.19",
|
||||
"private": false,
|
||||
"description": "interfaces for making typed requests",
|
||||
"description": "A library providing interfaces for making typed HTTP requests.",
|
||||
"main": "dist_ts/index.js",
|
||||
"typings": "dist_ts/index.d.ts",
|
||||
"author": "Lossless GmbH",
|
||||
@ -17,8 +17,8 @@
|
||||
"@gitzone/tsbuild": "^2.1.66",
|
||||
"@gitzone/tsrun": "^1.2.44",
|
||||
"@gitzone/tstest": "^1.0.77",
|
||||
"@push.rocks/tapbundle": "^5.0.12",
|
||||
"@types/node": "^20.4.6"
|
||||
"@push.rocks/tapbundle": "^5.0.23",
|
||||
"@types/node": "^20.12.8"
|
||||
},
|
||||
"files": [
|
||||
"ts/**/*",
|
||||
@ -35,5 +35,14 @@
|
||||
"type": "module",
|
||||
"browserslist": [
|
||||
"last 1 chrome versions"
|
||||
],
|
||||
"keywords": [
|
||||
"HTTP",
|
||||
"requests",
|
||||
"interfaces",
|
||||
"TypeScript",
|
||||
"streaming",
|
||||
"API",
|
||||
"virtual streams"
|
||||
]
|
||||
}
|
||||
|
776
pnpm-lock.yaml
generated
776
pnpm-lock.yaml
generated
File diff suppressed because it is too large
Load Diff
1
readme.hints.md
Normal file
1
readme.hints.md
Normal file
@ -0,0 +1 @@
|
||||
|
164
readme.md
164
readme.md
@ -1,39 +1,151 @@
|
||||
# @api.global/typedrequest-interfaces
|
||||
|
||||
interfaces for making typed requests
|
||||
|
||||
## Availabililty and Links
|
||||
* [npmjs.org (npm package)](https://www.npmjs.com/package/@api.global/typedrequest-interfaces)
|
||||
* [gitlab.com (source)](https://gitlab.com/api.global/typedrequest-interfaces)
|
||||
* [github.com (source mirror)](https://github.com/api.global/typedrequest-interfaces)
|
||||
* [docs (typedoc)](https://api.global.gitlab.io/typedrequest-interfaces/)
|
||||
## Install
|
||||
|
||||
## Status for master
|
||||
To install `@api.global/typedrequest-interfaces`, you need to have Node.js installed on your system. You can then add this package to your project by running the following command in your terminal:
|
||||
|
||||
Status Category | Status Badge
|
||||
-- | --
|
||||
GitLab Pipelines | [](https://lossless.cloud)
|
||||
GitLab Pipline Test Coverage | [](https://lossless.cloud)
|
||||
npm | [](https://lossless.cloud)
|
||||
Snyk | [](https://lossless.cloud)
|
||||
TypeScript Support | [](https://lossless.cloud)
|
||||
node Support | [](https://nodejs.org/dist/latest-v10.x/docs/api/)
|
||||
Code Style | [](https://lossless.cloud)
|
||||
PackagePhobia (total standalone install weight) | [](https://lossless.cloud)
|
||||
PackagePhobia (package size on registry) | [](https://lossless.cloud)
|
||||
BundlePhobia (total size when bundled) | [](https://lossless.cloud)
|
||||
```bash
|
||||
npm install @api.global/typedrequest-interfaces --save
|
||||
```
|
||||
|
||||
This will add the package to your project's dependencies. Ensure you are in your project's directory or specify the path where your project is located.
|
||||
|
||||
## Usage
|
||||
|
||||
## Contribution
|
||||
To use the `@api.global/typedrequest-interfaces` package in your TypeScript project, follow the steps below. This package provides interfaces for making typed requests, which can help enforce a structured request and response pattern in your applications.
|
||||
|
||||
We are always happy for code contributions. If you are not the code contributing type that is ok. Still, maintaining Open Source repositories takes considerable time and thought. If you like the quality of what we do and our modules are useful to you we would appreciate a little monthly contribution: You can [contribute one time](https://lossless.link/contribute-onetime) or [contribute monthly](https://lossless.link/contribute). :)
|
||||
### Setting Up Your Project
|
||||
|
||||
## Contribution
|
||||
First, ensure your project is set up to use TypeScript and ESM (ECMAScript Modules). You will need a `tsconfig.json` file in your project root with at least the following settings:
|
||||
|
||||
We are always happy for code contributions. If you are not the code contributing type that is ok. Still, maintaining Open Source repositories takes considerable time and thought. If you like the quality of what we do and our modules are useful to you we would appreciate a little monthly contribution: You can [contribute one time](https://lossless.link/contribute-onetime) or [contribute monthly](https://lossless.link/contribute). :)
|
||||
```json
|
||||
{
|
||||
"compilerOptions": {
|
||||
"target": "ESNext",
|
||||
"module": "ESNext",
|
||||
"moduleResolution": "node",
|
||||
"outDir": "./dist",
|
||||
"declaration": true,
|
||||
"esModuleInterop": true,
|
||||
"experimentalDecorators": true,
|
||||
"forceConsistentCasingInFileNames": true
|
||||
},
|
||||
"include": ["src/**/*"]
|
||||
}
|
||||
```
|
||||
|
||||
For further information read the linked docs at the top of this readme.
|
||||
Adjust the settings according to your project requirements. This configuration supports modern JavaScript features and TypeScript.
|
||||
|
||||
## Legal
|
||||
> MIT licensed | **©** [Task Venture Capital GmbH](https://task.vc)
|
||||
| By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy)
|
||||
### Basic Implementation
|
||||
|
||||
To use the interfaces provided by the package, start by importing them into your TypeScript file. Below is an example demonstrating how to define a typed request using the interfaces:
|
||||
|
||||
```typescript
|
||||
import { ITypedRequest, ITypedEvent, ITag, IVirtualStream, IStreamRequest } from '@api.global/typedrequest-interfaces';
|
||||
|
||||
// Example: Defining a typed request
|
||||
interface MyCustomRequest extends ITypedRequest {
|
||||
method: 'MyCustomMethod';
|
||||
authInfo?: {
|
||||
jwt: string;
|
||||
};
|
||||
request: {
|
||||
someData: string;
|
||||
};
|
||||
response: {
|
||||
resultData: number;
|
||||
};
|
||||
}
|
||||
```
|
||||
|
||||
This snippet shows how to create a custom interface `MyCustomRequest` that implements the `ITypedRequest` interface from the package. You can specify the types for the request and response data to match your application's needs.
|
||||
|
||||
### Handling Typed Events
|
||||
|
||||
You can also define and use typed events similar to the following example:
|
||||
|
||||
```typescript
|
||||
// Example: Defining a typed event
|
||||
interface MyCustomEvent extends ITypedEvent<{ message: string }> {
|
||||
name: 'MyCustomEvent';
|
||||
uniqueEventId: 'Event123';
|
||||
payload: {
|
||||
message: 'Hello World';
|
||||
};
|
||||
}
|
||||
```
|
||||
|
||||
### Utilizing Tags
|
||||
|
||||
Tags can be useful for attaching metadata or categorization information to your requests or events. Implementing a tag looks like this:
|
||||
|
||||
```typescript
|
||||
// Example: Defining a tag
|
||||
interface UserActionTag extends ITag {
|
||||
name: 'UserAction';
|
||||
payload: {
|
||||
userId: number;
|
||||
action: string;
|
||||
};
|
||||
}
|
||||
```
|
||||
|
||||
### Virtual Streams
|
||||
|
||||
For more advanced use cases, like handling data streams, the `IVirtualStream` interface can be implemented as follows:
|
||||
|
||||
```typescript
|
||||
// Example: Implementing a virtual stream
|
||||
class MyStream implements IVirtualStream<Uint8Array> {
|
||||
side = 'requesting';
|
||||
streamId = 'myStream123';
|
||||
sendMethod = async (data: Uint8Array) => { /* Implementation here */ };
|
||||
// Implement other required methods...
|
||||
}
|
||||
```
|
||||
|
||||
### Working with Stream Requests
|
||||
|
||||
Stream requests allow for handling requests that involve streaming data. Here is how you can use the `IStreamRequest` interface:
|
||||
|
||||
```typescript
|
||||
// Example: Using an IStreamRequest
|
||||
const myStreamRequest: IStreamRequest = {
|
||||
method: '##VirtualStream##',
|
||||
request: {
|
||||
streamId: 'myStream123',
|
||||
cycleId: 'cycle456',
|
||||
cycle: 'request',
|
||||
mainPurpose: 'start'
|
||||
// More properties here...
|
||||
},
|
||||
response: {
|
||||
// Response structure here...
|
||||
}
|
||||
};
|
||||
```
|
||||
|
||||
This setup demonstrates creating a request for initializing a virtual stream. Other `mainPurpose` values like 'chunk', 'read', 'end', and 'feedback' can also be used depending on the interaction with the stream.
|
||||
|
||||
The examples shown demonstrate the versatility of the `@api.global/typedrequest-interfaces` package in structuring your application's request-response mechanisms, event handling, tagging, and stream management. By following TypeScript and ESM conventions, you can leverage these interfaces to architect robust, typed APIs and services.
|
||||
|
||||
## License and Legal Information
|
||||
|
||||
This repository contains open-source code that is licensed under the MIT License. A copy of the MIT License can be found in the [license](license) file within this repository.
|
||||
|
||||
**Please note:** The MIT License does not grant permission to use the trade names, trademarks, service marks, or product names of the project, except as required for reasonable and customary use in describing the origin of the work and reproducing the content of the NOTICE file.
|
||||
|
||||
### Trademarks
|
||||
|
||||
This project is owned and maintained by Task Venture Capital GmbH. The names and logos associated with Task Venture Capital GmbH and any related products or services are trademarks of Task Venture Capital GmbH and are not included within the scope of the MIT license granted herein. Use of these trademarks must comply with Task Venture Capital GmbH's Trademark Guidelines, and any usage must be approved in writing by Task Venture Capital GmbH.
|
||||
|
||||
### Company Information
|
||||
|
||||
Task Venture Capital GmbH
|
||||
Registered at District court Bremen HRB 35230 HB, Germany
|
||||
|
||||
For any legal inquiries or if you require further information, please contact us via email at hello@task.vc.
|
||||
|
||||
By using this repository, you acknowledge that you have read this section, agree to comply with its terms, and understand that the licensing of the code does not imply endorsement by Task Venture Capital GmbH of any derivative works.
|
||||
|
@ -3,6 +3,6 @@
|
||||
*/
|
||||
export const commitinfo = {
|
||||
name: '@api.global/typedrequest-interfaces',
|
||||
version: '3.0.0',
|
||||
description: 'interfaces for making typed requests'
|
||||
version: '3.0.19',
|
||||
description: 'A library providing interfaces for making typed HTTP requests.'
|
||||
}
|
||||
|
86
ts/index.ts
86
ts/index.ts
@ -11,6 +11,14 @@ export interface ITypedRequest {
|
||||
jwt: string;
|
||||
};
|
||||
|
||||
/**
|
||||
* localData tracks things within typedrequest.
|
||||
* needed for VirtualStreams
|
||||
*/
|
||||
localData?: {
|
||||
firstTypedrouter?: any;
|
||||
};
|
||||
|
||||
/**
|
||||
* server data that is added for dealing with the request server side. Will be omitted when sending the response
|
||||
*/
|
||||
@ -44,6 +52,8 @@ export interface ITypedRequest {
|
||||
|
||||
/**
|
||||
* a correlation id that
|
||||
* used for matching request and response
|
||||
* !important. Don't remove.
|
||||
*/
|
||||
correlation?: {
|
||||
id: string;
|
||||
@ -65,3 +75,79 @@ export interface ITag {
|
||||
}
|
||||
|
||||
export type implementsTag<T, U extends T> = {};
|
||||
|
||||
|
||||
// stream stuff
|
||||
export interface IVirtualStream<T = Uint8Array> {
|
||||
// Properties
|
||||
side: 'requesting' | 'responding';
|
||||
streamId: string;
|
||||
sendMethod: any;
|
||||
typedrouter: any;
|
||||
|
||||
// Methods
|
||||
handleStreamTr(streamTrArg: IStreamRequest): Promise<IStreamRequest>;
|
||||
cleanup(): Promise<void>;
|
||||
sendData(dataArg: T): Promise<void>;
|
||||
fetchData(): Promise<T>;
|
||||
readFromWebstream(readableStreamArg: ReadableStream<T>): Promise<void>;
|
||||
writeToWebstream(wwritableStreamArg: WritableStream<T>): Promise<void>; // Consider defining a more specific type for webStream if possible
|
||||
}
|
||||
|
||||
export interface IUnifiedStreamDataPackage {
|
||||
/**
|
||||
* the stream id, so Virtual Streams can talk to each other
|
||||
*/
|
||||
streamId: string;
|
||||
|
||||
/**
|
||||
* stream data is sent in cycles. This id is used to match the request and response
|
||||
*/
|
||||
cycleId: string;
|
||||
cycle: 'request' | 'response';
|
||||
|
||||
/**
|
||||
* the main purpose of the data package
|
||||
* start: indicates the start of a stream
|
||||
* chunk: indicates a binary chunk of data
|
||||
* read: indicates the introduction to send data
|
||||
* end: indicates the end of a stream
|
||||
* feedback: indicates a feedback message
|
||||
*/
|
||||
mainPurpose: 'start' | 'chunk' | 'read' | 'end' | 'feedback' | 'keepAlive';
|
||||
|
||||
/**
|
||||
* the data package
|
||||
*/
|
||||
chunkData?: any;
|
||||
|
||||
/**
|
||||
* feedback message
|
||||
*/
|
||||
feedback?: {
|
||||
message?: string;
|
||||
data?: any;
|
||||
sha265?: string;
|
||||
};
|
||||
|
||||
/**
|
||||
* keepAlive boolean
|
||||
*/
|
||||
keepAlive?: boolean;
|
||||
|
||||
/**
|
||||
* is backpressure detected on the readable side?
|
||||
*/
|
||||
backpressure?: boolean;
|
||||
|
||||
/**
|
||||
* does the writable side have more data scheduled to be sent?
|
||||
*/
|
||||
next?: boolean;
|
||||
}
|
||||
|
||||
export interface IStreamRequest extends implementsTR<ITypedRequest, IStreamRequest> {
|
||||
method: '##VirtualStream##';
|
||||
request: IUnifiedStreamDataPackage;
|
||||
response: IUnifiedStreamDataPackage;
|
||||
}
|
||||
|
@ -3,9 +3,12 @@
|
||||
"experimentalDecorators": true,
|
||||
"useDefineForClassFields": false,
|
||||
"target": "ES2022",
|
||||
"module": "ES2022",
|
||||
"moduleResolution": "nodenext",
|
||||
"module": "NodeNext",
|
||||
"moduleResolution": "NodeNext",
|
||||
"esModuleInterop": true,
|
||||
"verbatimModuleSyntax": true,
|
||||
}
|
||||
"verbatimModuleSyntax": true
|
||||
},
|
||||
"exclude": [
|
||||
"dist_*/**/*.d.ts"
|
||||
]
|
||||
}
|
||||
|
Reference in New Issue
Block a user