Compare commits
24 Commits
Author | SHA1 | Date | |
---|---|---|---|
56f59bf640 | |||
268df991c4 | |||
b3d8dd1573 | |||
0fb36ea928 | |||
10148f7c50 | |||
274bf30973 | |||
e3ff1c3c4b | |||
446a9d1723 | |||
a749f91a8f | |||
8ea6db7b7f | |||
715ee43bcc | |||
c314b4e86f | |||
5824d34764 | |||
5eb9035dfe | |||
a49b1813fb | |||
e33ae24f17 | |||
2e13632fec | |||
9175af027b | |||
f9524a62d7 | |||
7889e04915 | |||
a81b9eced6 | |||
4aa06fe830 | |||
adeab3e7b7 | |||
5a356b66f6 |
@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "@api.global/typedrequest-interfaces",
|
||||
"version": "2.0.2",
|
||||
"version": "3.0.11",
|
||||
"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: '2.0.2',
|
||||
version: '3.0.11',
|
||||
description: 'interfaces for making typed requests'
|
||||
}
|
||||
|
63
ts/index.ts
63
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,56 @@ 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
|
||||
* binaryChunk: indicates a binary chunk of data
|
||||
* object: indicates a json object
|
||||
* end: indicates the end of a stream
|
||||
* feedback: indicates a feedback message
|
||||
*/
|
||||
mainPurpose: 'start' | 'binaryChunk' | 'object' | 'end' | 'feedback' | 'keepAlive';
|
||||
|
||||
/**
|
||||
* the data package
|
||||
*/
|
||||
chunkData?: any;
|
||||
|
||||
/**
|
||||
* feedback message
|
||||
*/
|
||||
feedback?: {
|
||||
message?: string;
|
||||
data?: any;
|
||||
sha265?: string;
|
||||
};
|
||||
|
||||
/**
|
||||
* keepAlive boolean
|
||||
*/
|
||||
keepAlive?: boolean;
|
||||
|
||||
/**
|
||||
* is there 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