Compare commits
24 Commits
Author | SHA1 | Date | |
---|---|---|---|
51f03a45b6 | |||
ed8879a4c8 | |||
806970c701 | |||
9638f74440 | |||
b538c4fbdb | |||
1d3dc08e39 | |||
56f59bf640 | |||
268df991c4 | |||
b3d8dd1573 | |||
0fb36ea928 | |||
10148f7c50 | |||
274bf30973 | |||
e3ff1c3c4b | |||
446a9d1723 | |||
a749f91a8f | |||
8ea6db7b7f | |||
715ee43bcc | |||
c314b4e86f | |||
5824d34764 | |||
5eb9035dfe | |||
a49b1813fb | |||
e33ae24f17 | |||
2e13632fec | |||
9175af027b |
@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "@api.global/typedrequest-interfaces",
|
||||
"version": "3.0.2",
|
||||
"version": "3.0.14",
|
||||
"private": false,
|
||||
"description": "interfaces for making typed requests",
|
||||
"main": "dist_ts/index.js",
|
||||
|
@ -3,6 +3,6 @@
|
||||
*/
|
||||
export const commitinfo = {
|
||||
name: '@api.global/typedrequest-interfaces',
|
||||
version: '3.0.2',
|
||||
version: '3.0.14',
|
||||
description: 'interfaces for making typed requests'
|
||||
}
|
||||
|
62
ts/index.ts
62
ts/index.ts
@ -16,8 +16,8 @@ export interface ITypedRequest {
|
||||
* needed for VirtualStreams
|
||||
*/
|
||||
localData?: {
|
||||
firstTypedrouter: any;
|
||||
}
|
||||
firstTypedrouter?: any;
|
||||
};
|
||||
|
||||
/**
|
||||
* server data that is added for dealing with the request server side. Will be omitted when sending the response
|
||||
@ -75,3 +75,61 @@ export interface ITag {
|
||||
}
|
||||
|
||||
export type implementsTag<T, U extends T> = {};
|
||||
|
||||
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