quirons-broker - npm Package Compare versions

Comparing version 0.0.1-alpha.34 to 0.0.1-alpha.35

esocial/index.d.ts

@@ -0,1 +1,2 @@
+import * as t from 'io-ts';
 import { eSocial as evtCAT } from './schemas/evtCAT';
@@ -6,3 +7,10 @@ import { eSocial as evtMonit } from './schemas/evtMonit';
 import { eSocial as evtInfoEmpregador } from './schemas/evtInfoEmpregador';
-export { evtCAT, evtMonit, evtExpRisco, evtExclusao, evtInfoEmpregador };
+import { eSocial as EnvioLote } from './schemas/EnvioLoteEventos-v1_1_1';
+import { T_ideEmpregador } from './schemas/tipos';
+export { evtCAT, evtMonit, evtExpRisco, evtExclusao, evtInfoEmpregador, EnvioLote };
+export declare const IdeEmpregador: t.TypeC<{
+    tpInsc: t.UnionC<[t.LiteralC<1>, t.LiteralC<2>]>;
+    nrInsc: t.StringC;
+}>;
+export declare type IdeEmpregador = t.TypeOf<typeof T_ideEmpregador>;
 export declare type eSocialObject = evtCAT | evtMonit | evtExpRisco | evtExclusao | evtInfoEmpregador;
@@ -9,0 +17,0 @@ export declare type eSocialKey = Keys<eSocialObject>;

esocial/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.isProductionRestricted = exports.isProductionReady = exports.evtInfoEmpregador = exports.evtExclusao = exports.evtExpRisco = exports.evtMonit = exports.evtCAT = void 0;
+exports.isProductionRestricted = exports.isProductionReady = exports.IdeEmpregador = exports.EnvioLote = exports.evtInfoEmpregador = exports.evtExclusao = exports.evtExpRisco = exports.evtMonit = exports.evtCAT = void 0;
 const evtCAT_1 = require("./schemas/evtCAT");
@@ -14,2 +14,6 @@ Object.defineProperty(exports, "evtCAT", { enumerable: true, get: function () { return evtCAT_1.eSocial; } });
 Object.defineProperty(exports, "evtInfoEmpregador", { enumerable: true, get: function () { return evtInfoEmpregador_1.eSocial; } });
+const EnvioLoteEventos_v1_1_1_1 = require("./schemas/EnvioLoteEventos-v1_1_1");
+Object.defineProperty(exports, "EnvioLote", { enumerable: true, get: function () { return EnvioLoteEventos_v1_1_1_1.eSocial; } });
+const tipos_1 = require("./schemas/tipos");
+exports.IdeEmpregador = tipos_1.T_ideEmpregador;
 function isProductionReady(obj) {
@@ -16,0 +20,0 @@ return obj.ideEvento.tpAmb === 1;

index.d.ts

@@ -925,3 +925,3 @@ import * as t from 'io-ts';
 }>]>, t.UnionC<[t.TypeC<{
-    kind: t.LiteralC<"postMessage">;
+    kind: t.LiteralC<"sendTAF">;
     identification: t.TypeC<{
@@ -931,3 +931,4 @@ userId: t.StringC;
     }>;
-    content: t.TypeC<{
+    content: t.UnionC<[t.TypeC<{
+        verb: t.LiteralC<"post">;
         ticketCode: t.StringC;
@@ -951,10 +952,4 @@ lote: t.ArrayC<t.IntersectionC<[t.TypeC<{
         }>]>>;
-    }>;
-}>, t.TypeC<{
-    kind: t.LiteralC<"getMessage">;
-    identification: t.TypeC<{
-        userId: t.StringC;
-        branchId: t.StringC;
-    }>;
-    content: t.TypeC<{
+    }>, t.TypeC<{
+        verb: t.LiteralC<"get">;
         ticketCode: t.StringC;
@@ -967,16 +962,10 @@ registryKey: t.StringC;
         lotQuantity: t.NumberC;
-    }>;
-}>, t.TypeC<{
-    kind: t.LiteralC<"deleteMessage">;
-    identification: t.TypeC<{
-        userId: t.StringC;
-        branchId: t.StringC;
-    }>;
-    content: t.TypeC<{
+    }>, t.TypeC<{
+        verb: t.LiteralC<"delete">;
         deleteTicket: t.ArrayC<t.TypeC<{
             ticketCode: t.StringC;
         }>>;
-    }>;
-}>, t.TypeC<{
-    kind: t.LiteralC<"postResponseMessage">;
+    }>]>;
+}>, t.UnionC<[t.TypeC<{
+    kind: t.LiteralC<"responseTAF">;
     identification: t.TypeC<{
@@ -986,3 +975,4 @@ userId: t.StringC;
     }>;
-    content: t.PartialC<{
+    content: t.UnionC<[t.UnionC<[t.TypeC<{
+        verb: t.LiteralC<"post">;
         ticketCode: t.StringC;
@@ -1001,10 +991,4 @@ registryKey: t.ArrayC<t.IntersectionC<[t.TypeC<{
         keyAmount: t.NumberC;
-    }>;
-}>, t.TypeC<{
-    kind: t.LiteralC<"getResponseMessage">;
-    identification: t.TypeC<{
-        userId: t.StringC;
-        branchId: t.StringC;
-    }>;
-    content: t.TypeC<{
+    }>, t.TypeC<{
+        verb: t.LiteralC<"get">;
         type: t.StringC;
@@ -1035,82 +1019,10 @@ code: t.StringC;
         maxRecNo: t.NumberC;
-    }>;
-}>, t.TypeC<{
-    kind: t.LiteralC<"deleteResponseMessage">;
-    identification: t.TypeC<{
-        userId: t.StringC;
-        branchId: t.StringC;
-    }>;
-    content: t.TypeC<{
+    }>, t.TypeC<{
+        verb: t.LiteralC<"delete">;
         sucess: t.BooleanC;
-    }>;
+    }>]>, t.NullC]>;
 }>, t.TypeC<{
-    kind: t.LiteralC<"send">;
-    identification: t.TypeC<{
-        userId: t.StringC;
-        branchId: t.StringC;
-    }>;
-    content: t.UnionC<[t.TypeC<{
-        kind: t.LiteralC<"postMessage">;
-        verb: t.KeyofC<{
-            get: null;
-            post: null;
-            put: null;
-            delete: null;
-        }>;
-        data: t.TypeC<{
-            ticketCode: t.StringC;
-            lote: t.ArrayC<t.IntersectionC<[t.TypeC<{
-                sourceBranch: t.StringC;
-                messageType: t.UnionC<[t.LiteralC<"1">, t.LiteralC<"2">]>;
-                messageSequential: t.StringC;
-                registryType: t.UnionC<[t.LiteralC<"S-2210">, t.LiteralC<"S-2220">, t.LiteralC<"S-2240">, t.LiteralC<"S-3000">]>;
-                registryKey: t.StringC;
-                integrationMessage: t.StringC;
-            }>, t.PartialC<{
-                integrationDate: t.StringC;
-                integrationTime: t.StringC;
-                registryPriority: t.StringC;
-                integrationQueue: t.UnionC<[t.LiteralC<"1">, t.LiteralC<"2">]>;
-                erpowner: t.StringC;
-                registryPredecessor: t.StringC;
-                transferBranch: t.StringC;
-                complement: t.StringC;
-            }>]>>;
-        }>;
-    }>, t.TypeC<{
-        kind: t.LiteralC<"getMessage">;
-        verb: t.KeyofC<{
-            get: null;
-            post: null;
-            put: null;
-            delete: null;
-        }>;
-        data: t.TypeC<{
-            ticketCode: t.StringC;
-            registryKey: t.StringC;
-            startRecNo: t.NumberC;
-            searchMode: t.UnionC<[t.LiteralC<"1">, t.LiteralC<"2">]>;
-            sourceBranch: t.StringC;
-            queryElements: t.UnionC<[t.LiteralC<"0">, t.LiteralC<"1">]>;
-            lotQuantity: t.NumberC;
-        }>;
-    }>, t.TypeC<{
-        kind: t.LiteralC<"deleteMessage">;
-        verb: t.KeyofC<{
-            get: null;
-            post: null;
-            put: null;
-            delete: null;
-        }>;
-        data: t.TypeC<{
-            deleteTicket: t.ArrayC<t.TypeC<{
-                ticketCode: t.StringC;
-            }>>;
-        }>;
-    }>]>;
-}>, t.IntersectionC<[t.TypeC<{
-    kind: t.LiteralC<"senderResponse">;
-}>, t.PartialC<{
+    kind: t.LiteralC<"responseTAF">;
     errorMessage: t.StringC;
 }>]>]>]>;
 export declare type Message = t.TypeOf<typeof Message>;

package.json

 {
   "name": "quirons-broker",
-  "version": "0.0.1-alpha.34",
-  "description": "A small library to expose the broker ttalk types",
+  "version": "0.0.1-alpha.35",
+  "description": "A small library to expose the broker types",
   "main": "index.ts",
@@ -22,5 +22,5 @@ "typings": "index.d.ts",
     "fp-ts": "2.6.1",
-    "io-ts": "2.2.2",
+    "io-ts": "2.2.16",
     "typescript": "3.9.2"
   }
 }

taf/index.d.ts

 import * as t from 'io-ts';
 export { PostMessage, GetMessage, DeleteMessage, PostResponseMessage, GetResponseMessage, DeleteResponseMessage } from './message';
 export declare const SenderMessageContent: t.UnionC<[t.TypeC<{
-    kind: t.LiteralC<"postMessage">;
-    verb: t.KeyofC<{
-        get: null;
-        post: null;
-        put: null;
-        delete: null;
+    verb: t.LiteralC<"post">;
+    ticketCode: t.StringC;
+    lote: t.ArrayC<t.IntersectionC<[t.TypeC<{
+        sourceBranch: t.StringC;
+        messageType: t.UnionC<[t.LiteralC<"1">, t.LiteralC<"2">]>;
+        messageSequential: t.StringC;
+        registryType: t.UnionC<[t.LiteralC<"S-2210">, t.LiteralC<"S-2220">, t.LiteralC<"S-2240">, t.LiteralC<"S-3000">]>;
+        registryKey: t.StringC;
+        integrationMessage: t.StringC;
+    }>, t.PartialC<{
+        integrationDate: t.StringC;
+        integrationTime: t.StringC;
+        registryPriority: t.StringC;
+        integrationQueue: t.UnionC<[t.LiteralC<"1">, t.LiteralC<"2">]>;
+        erpowner: t.StringC;
+        registryPredecessor: t.StringC;
+        transferBranch: t.StringC;
+        complement: t.StringC;
+    }>]>>;
+}>, t.TypeC<{
+    verb: t.LiteralC<"get">;
+    ticketCode: t.StringC;
+    registryKey: t.StringC;
+    startRecNo: t.NumberC;
+    searchMode: t.UnionC<[t.LiteralC<"1">, t.LiteralC<"2">]>;
+    sourceBranch: t.StringC;
+    queryElements: t.UnionC<[t.LiteralC<"0">, t.LiteralC<"1">]>;
+    lotQuantity: t.NumberC;
+}>, t.TypeC<{
+    verb: t.LiteralC<"delete">;
+    deleteTicket: t.ArrayC<t.TypeC<{
+        ticketCode: t.StringC;
+    }>>;
+}>]>;
+export declare type SenderMessageContent = t.TypeOf<typeof SenderMessageContent>;
+export declare const SenderMessage: t.TypeC<{
+    kind: t.LiteralC<"sendTAF">;
+    identification: t.TypeC<{
+        userId: t.StringC;
+        branchId: t.StringC;
     }>;
-    data: t.TypeC<{
+    content: t.UnionC<[t.TypeC<{
+        verb: t.LiteralC<"post">;
         ticketCode: t.StringC;
@@ -30,12 +65,4 @@ lote: t.ArrayC<t.IntersectionC<[t.TypeC<{
         }>]>>;
-    }>;
-}>, t.TypeC<{
-    kind: t.LiteralC<"getMessage">;
-    verb: t.KeyofC<{
-        get: null;
-        post: null;
-        put: null;
-        delete: null;
-    }>;
-    data: t.TypeC<{
+    }>, t.TypeC<{
+        verb: t.LiteralC<"get">;
         ticketCode: t.StringC;
@@ -48,20 +75,12 @@ registryKey: t.StringC;
         lotQuantity: t.NumberC;
-    }>;
-}>, t.TypeC<{
-    kind: t.LiteralC<"deleteMessage">;
-    verb: t.KeyofC<{
-        get: null;
-        post: null;
-        put: null;
-        delete: null;
-    }>;
-    data: t.TypeC<{
+    }>, t.TypeC<{
+        verb: t.LiteralC<"delete">;
         deleteTicket: t.ArrayC<t.TypeC<{
             ticketCode: t.StringC;
         }>>;
-    }>;
-}>]>;
-export declare type SenderMessageContent = t.TypeOf<typeof SenderMessageContent>;
-export declare const SenderMessage: t.TypeC<{
-    kind: t.LiteralC<"send">;
+    }>]>;
+}>;
+export declare type SenderMessage = t.TypeOf<typeof SenderMessage>;
+export declare const SenderResponseMessage: t.UnionC<[t.TypeC<{
+    kind: t.LiteralC<"responseTAF">;
     identification: t.TypeC<{
@@ -71,66 +90,50 @@ userId: t.StringC;
     }>;
-    content: t.UnionC<[t.TypeC<{
-        kind: t.LiteralC<"postMessage">;
-        verb: t.KeyofC<{
-            get: null;
-            post: null;
-            put: null;
-            delete: null;
-        }>;
-        data: t.TypeC<{
-            ticketCode: t.StringC;
-            lote: t.ArrayC<t.IntersectionC<[t.TypeC<{
-                sourceBranch: t.StringC;
-                messageType: t.UnionC<[t.LiteralC<"1">, t.LiteralC<"2">]>;
-                messageSequential: t.StringC;
-                registryType: t.UnionC<[t.LiteralC<"S-2210">, t.LiteralC<"S-2220">, t.LiteralC<"S-2240">, t.LiteralC<"S-3000">]>;
-                registryKey: t.StringC;
-                integrationMessage: t.StringC;
-            }>, t.PartialC<{
-                integrationDate: t.StringC;
-                integrationTime: t.StringC;
-                registryPriority: t.StringC;
-                integrationQueue: t.UnionC<[t.LiteralC<"1">, t.LiteralC<"2">]>;
-                erpowner: t.StringC;
-                registryPredecessor: t.StringC;
-                transferBranch: t.StringC;
-                complement: t.StringC;
-            }>]>>;
-        }>;
+    content: t.UnionC<[t.UnionC<[t.TypeC<{
+        verb: t.LiteralC<"post">;
+        ticketCode: t.StringC;
+        registryKey: t.ArrayC<t.IntersectionC<[t.TypeC<{
+            key: t.StringC;
+            success: t.BooleanC;
+        }>, t.PartialC<{
+            error: t.ArrayC<t.TypeC<{
+                coderr: t.StringC;
+                description: t.StringC;
+            }>>;
+        }>]>>;
+        coderr: t.NumberC;
+        description: t.StringC;
+        keyAmount: t.NumberC;
     }>, t.TypeC<{
-        kind: t.LiteralC<"getMessage">;
-        verb: t.KeyofC<{
-            get: null;
-            post: null;
-            put: null;
-            delete: null;
-        }>;
-        data: t.TypeC<{
+        verb: t.LiteralC<"get">;
+        type: t.StringC;
+        code: t.StringC;
+        items: t.ArrayC<t.IntersectionC<[t.TypeC<{
+            success: t.BooleanC;
+            proccessed: t.BooleanC;
+            description: t.StringC;
+        }>, t.PartialC<{
+            registryKey: t.StringC;
             ticketCode: t.StringC;
-            registryKey: t.StringC;
-            startRecNo: t.NumberC;
-            searchMode: t.UnionC<[t.LiteralC<"1">, t.LiteralC<"2">]>;
-            sourceBranch: t.StringC;
-            queryElements: t.UnionC<[t.LiteralC<"0">, t.LiteralC<"1">]>;
-            lotQuantity: t.NumberC;
-        }>;
+            errorCode: t.StringC;
+            errorDescription: t.StringC;
+            errorDetail: t.StringC;
+            statusCode: t.StringC;
+            statusDescription: t.StringC;
+            active: t.BooleanC;
+            receiptNumber: t.StringC;
+            registryPriority: t.StringC;
+            integrationQueue: t.StringC;
+            streamingErrors: t.ArrayC<t.PartialC<{
+                streamingErrorCode: t.StringC;
+                streamingErrorDetail: t.StringC;
+            }>>;
+        }>]>>;
+        lastRecNo: t.NumberC;
+        maxRecNo: t.NumberC;
     }>, t.TypeC<{
-        kind: t.LiteralC<"deleteMessage">;
-        verb: t.KeyofC<{
-            get: null;
-            post: null;
-            put: null;
-            delete: null;
-        }>;
-        data: t.TypeC<{
-            deleteTicket: t.ArrayC<t.TypeC<{
-                ticketCode: t.StringC;
-            }>>;
-        }>;
-    }>]>;
-}>;
-export declare type SenderMessage = t.TypeOf<typeof SenderMessage>;
-export declare const SenderResponseMessage: t.IntersectionC<[t.TypeC<{
-    kind: t.LiteralC<"senderResponse">;
-}>, t.PartialC<{
+        verb: t.LiteralC<"delete">;
+        sucess: t.BooleanC;
+    }>]>, t.NullC]>;
+}>, t.TypeC<{
+    kind: t.LiteralC<"responseTAF">;
     errorMessage: t.StringC;
@@ -140,3 +143,3 @@ }>]>;
 export declare const Message: t.UnionC<[t.TypeC<{
-    kind: t.LiteralC<"postMessage">;
+    kind: t.LiteralC<"sendTAF">;
     identification: t.TypeC<{
@@ -146,3 +149,4 @@ userId: t.StringC;
     }>;
-    content: t.TypeC<{
+    content: t.UnionC<[t.TypeC<{
+        verb: t.LiteralC<"post">;
         ticketCode: t.StringC;
@@ -166,10 +170,4 @@ lote: t.ArrayC<t.IntersectionC<[t.TypeC<{
         }>]>>;
-    }>;
-}>, t.TypeC<{
-    kind: t.LiteralC<"getMessage">;
-    identification: t.TypeC<{
-        userId: t.StringC;
-        branchId: t.StringC;
-    }>;
-    content: t.TypeC<{
+    }>, t.TypeC<{
+        verb: t.LiteralC<"get">;
         ticketCode: t.StringC;
@@ -182,16 +180,10 @@ registryKey: t.StringC;
         lotQuantity: t.NumberC;
-    }>;
-}>, t.TypeC<{
-    kind: t.LiteralC<"deleteMessage">;
-    identification: t.TypeC<{
-        userId: t.StringC;
-        branchId: t.StringC;
-    }>;
-    content: t.TypeC<{
+    }>, t.TypeC<{
+        verb: t.LiteralC<"delete">;
         deleteTicket: t.ArrayC<t.TypeC<{
             ticketCode: t.StringC;
         }>>;
-    }>;
-}>, t.TypeC<{
-    kind: t.LiteralC<"postResponseMessage">;
+    }>]>;
+}>, t.UnionC<[t.TypeC<{
+    kind: t.LiteralC<"responseTAF">;
     identification: t.TypeC<{
@@ -201,3 +193,4 @@ userId: t.StringC;
     }>;
-    content: t.PartialC<{
+    content: t.UnionC<[t.UnionC<[t.TypeC<{
+        verb: t.LiteralC<"post">;
         ticketCode: t.StringC;
@@ -216,10 +209,4 @@ registryKey: t.ArrayC<t.IntersectionC<[t.TypeC<{
         keyAmount: t.NumberC;
-    }>;
-}>, t.TypeC<{
-    kind: t.LiteralC<"getResponseMessage">;
-    identification: t.TypeC<{
-        userId: t.StringC;
-        branchId: t.StringC;
-    }>;
-    content: t.TypeC<{
+    }>, t.TypeC<{
+        verb: t.LiteralC<"get">;
         type: t.StringC;
@@ -250,82 +237,10 @@ code: t.StringC;
         maxRecNo: t.NumberC;
-    }>;
-}>, t.TypeC<{
-    kind: t.LiteralC<"deleteResponseMessage">;
-    identification: t.TypeC<{
-        userId: t.StringC;
-        branchId: t.StringC;
-    }>;
-    content: t.TypeC<{
+    }>, t.TypeC<{
+        verb: t.LiteralC<"delete">;
         sucess: t.BooleanC;
-    }>;
+    }>]>, t.NullC]>;
 }>, t.TypeC<{
-    kind: t.LiteralC<"send">;
-    identification: t.TypeC<{
-        userId: t.StringC;
-        branchId: t.StringC;
-    }>;
-    content: t.UnionC<[t.TypeC<{
-        kind: t.LiteralC<"postMessage">;
-        verb: t.KeyofC<{
-            get: null;
-            post: null;
-            put: null;
-            delete: null;
-        }>;
-        data: t.TypeC<{
-            ticketCode: t.StringC;
-            lote: t.ArrayC<t.IntersectionC<[t.TypeC<{
-                sourceBranch: t.StringC;
-                messageType: t.UnionC<[t.LiteralC<"1">, t.LiteralC<"2">]>;
-                messageSequential: t.StringC;
-                registryType: t.UnionC<[t.LiteralC<"S-2210">, t.LiteralC<"S-2220">, t.LiteralC<"S-2240">, t.LiteralC<"S-3000">]>;
-                registryKey: t.StringC;
-                integrationMessage: t.StringC;
-            }>, t.PartialC<{
-                integrationDate: t.StringC;
-                integrationTime: t.StringC;
-                registryPriority: t.StringC;
-                integrationQueue: t.UnionC<[t.LiteralC<"1">, t.LiteralC<"2">]>;
-                erpowner: t.StringC;
-                registryPredecessor: t.StringC;
-                transferBranch: t.StringC;
-                complement: t.StringC;
-            }>]>>;
-        }>;
-    }>, t.TypeC<{
-        kind: t.LiteralC<"getMessage">;
-        verb: t.KeyofC<{
-            get: null;
-            post: null;
-            put: null;
-            delete: null;
-        }>;
-        data: t.TypeC<{
-            ticketCode: t.StringC;
-            registryKey: t.StringC;
-            startRecNo: t.NumberC;
-            searchMode: t.UnionC<[t.LiteralC<"1">, t.LiteralC<"2">]>;
-            sourceBranch: t.StringC;
-            queryElements: t.UnionC<[t.LiteralC<"0">, t.LiteralC<"1">]>;
-            lotQuantity: t.NumberC;
-        }>;
-    }>, t.TypeC<{
-        kind: t.LiteralC<"deleteMessage">;
-        verb: t.KeyofC<{
-            get: null;
-            post: null;
-            put: null;
-            delete: null;
-        }>;
-        data: t.TypeC<{
-            deleteTicket: t.ArrayC<t.TypeC<{
-                ticketCode: t.StringC;
-            }>>;
-        }>;
-    }>]>;
-}>, t.IntersectionC<[t.TypeC<{
-    kind: t.LiteralC<"senderResponse">;
-}>, t.PartialC<{
+    kind: t.LiteralC<"responseTAF">;
     errorMessage: t.StringC;
 }>]>]>;
 export declare type Message = t.TypeOf<typeof Message>;

taf/index.js

@@ -24,26 +24,28 @@ "use strict";
 const t = __importStar(require("io-ts"));
-var message_1 = require("./message");
-Object.defineProperty(exports, "PostMessage", { enumerable: true, get: function () { return message_1.PostMessage; } });
-Object.defineProperty(exports, "GetMessage", { enumerable: true, get: function () { return message_1.GetMessage; } });
-Object.defineProperty(exports, "DeleteMessage", { enumerable: true, get: function () { return message_1.DeleteMessage; } });
-Object.defineProperty(exports, "PostResponseMessage", { enumerable: true, get: function () { return message_1.PostResponseMessage; } });
-Object.defineProperty(exports, "GetResponseMessage", { enumerable: true, get: function () { return message_1.GetResponseMessage; } });
-Object.defineProperty(exports, "DeleteResponseMessage", { enumerable: true, get: function () { return message_1.DeleteResponseMessage; } });
-const message_2 = require("./message");
+const message_1 = require("./message");
 const constructors_1 = require("../constructors");
+const custom_types_1 = require("../custom-types");
+var message_2 = require("./message");
+Object.defineProperty(exports, "PostMessage", { enumerable: true, get: function () { return message_2.PostMessage; } });
+Object.defineProperty(exports, "GetMessage", { enumerable: true, get: function () { return message_2.GetMessage; } });
+Object.defineProperty(exports, "DeleteMessage", { enumerable: true, get: function () { return message_2.DeleteMessage; } });
+Object.defineProperty(exports, "PostResponseMessage", { enumerable: true, get: function () { return message_2.PostResponseMessage; } });
+Object.defineProperty(exports, "GetResponseMessage", { enumerable: true, get: function () { return message_2.GetResponseMessage; } });
+Object.defineProperty(exports, "DeleteResponseMessage", { enumerable: true, get: function () { return message_2.DeleteResponseMessage; } });
 exports.SenderMessageContent = t.union([
-    constructors_1.senderMessage('postMessage', message_2.PostMessage),
-    constructors_1.senderMessage('getMessage', message_2.GetMessage),
-    constructors_1.senderMessage('deleteMessage', message_2.DeleteMessage),
+    message_1.PostMessage,
+    message_1.GetMessage,
+    message_1.DeleteMessage
 ]);
-exports.SenderMessage = t.type({
-    kind: t.literal('send'),
-    identification: constructors_1.Identification,
-    content: exports.SenderMessageContent
-});
-exports.SenderResponseMessage = t.intersection([
+exports.SenderMessage = constructors_1.userMessage('sendTAF', exports.SenderMessageContent);
+exports.SenderResponseMessage = t.union([
+    // This should match the tag below
+    constructors_1.userMessage('responseTAF', custom_types_1.nullable(t.union([
+        message_1.PostResponseMessage,
+        message_1.GetResponseMessage,
+        message_1.DeleteResponseMessage
+    ]))),
     t.type({
-        kind: t.literal('senderResponse')
-    }),
-    t.partial({
+        // This should match the tag above
+        kind: t.literal('responseTAF'),
         errorMessage: t.string
@@ -53,10 +55,4 @@ })
 exports.Message = t.union([
-    constructors_1.userMessage('postMessage', message_2.PostMessage),
-    constructors_1.userMessage('getMessage', message_2.GetMessage),
-    constructors_1.userMessage('deleteMessage', message_2.DeleteMessage),
-    constructors_1.userMessage('postResponseMessage', message_2.PostResponseMessage),
-    constructors_1.userMessage('getResponseMessage', message_2.GetResponseMessage),
-    constructors_1.userMessage('deleteResponseMessage', message_2.DeleteResponseMessage),
     exports.SenderMessage,
     exports.SenderResponseMessage
 ]);

taf/message.d.ts

@@ -6,2 +6,3 @@ import * as t from 'io-ts';
 export declare const PostMessage: t.TypeC<{
+    verb: t.LiteralC<"post">;
     ticketCode: t.StringC;
@@ -26,3 +27,5 @@ lote: t.ArrayC<t.IntersectionC<[t.TypeC<{
 }>;
-export declare const PostResponseMessage: t.PartialC<{
+export declare type PostMessage = t.TypeOf<typeof PostMessage>;
+export declare const PostResponseMessage: t.TypeC<{
+    verb: t.LiteralC<"post">;
     ticketCode: t.StringC;
@@ -42,3 +45,5 @@ registryKey: t.ArrayC<t.IntersectionC<[t.TypeC<{
 }>;
+export declare type PostResponseMessage = t.TypeOf<typeof PostResponseMessage>;
 export declare const GetMessage: t.TypeC<{
+    verb: t.LiteralC<"get">;
     ticketCode: t.StringC;
@@ -52,3 +57,5 @@ registryKey: t.StringC;
 }>;
+export declare type GetMessage = t.TypeOf<typeof GetMessage>;
 export declare const GetResponseMessage: t.TypeC<{
+    verb: t.LiteralC<"get">;
     type: t.StringC;
@@ -80,3 +87,5 @@ code: t.StringC;
 }>;
+export declare type GetResponseMessage = t.TypeOf<typeof GetResponseMessage>;
 export declare const DeleteMessage: t.TypeC<{
+    verb: t.LiteralC<"delete">;
     deleteTicket: t.ArrayC<t.TypeC<{
@@ -86,10 +95,7 @@ ticketCode: t.StringC;
 }>;
+export declare type DeleteMessage = t.TypeOf<typeof DeleteMessage>;
 export declare const DeleteResponseMessage: t.TypeC<{
+    verb: t.LiteralC<"delete">;
     sucess: t.BooleanC;
 }>;
-export declare type PostMessage = t.TypeOf<typeof PostMessage>;
-export declare type PostResponseMessage = t.TypeOf<typeof PostResponseMessage>;
-export declare type GetMessage = t.TypeOf<typeof GetMessage>;
-export declare type GetResponseMessage = t.TypeOf<typeof GetResponseMessage>;
-export declare type DeleteMessage = t.TypeOf<typeof DeleteMessage>;
 export declare type DeleteResponseMessage = t.TypeOf<typeof DeleteResponseMessage>;

taf/message.js

@@ -28,2 +28,4 @@ "use strict";
 exports.PostMessage = t.type({
+    verb: t.literal('post'),
+    // Atributo raiz
     ticketCode: t.string,
@@ -44,3 +46,4 @@ lote: t.array(t.intersection([
             integrationMessage: t.string,
-        }), t.partial({
+        }),
+        t.partial({
             // Data da Integração.
@@ -65,18 +68,20 @@ integrationDate: t.string,
 });
-exports.PostResponseMessage = t.partial({
-    //Atributo raiz
+exports.PostResponseMessage = t.type({
+    verb: t.literal('post'),
+    // Atributo raiz
     ticketCode: t.string,
-    //Array contendo os TAFKEY requisitados.
+    // Array contendo os TAFKEY requisitados.
     registryKey: t.array(t.intersection([
         t.type({
-            //Código do TAFKEY
+            // Código do TAFKEY
             key: t.string,
-            //Informa se o TAFKEY foi integrado ou não.
+            // Informa se o TAFKEY foi integrado ou não.
             success: t.boolean
-        }), t.partial({
-            //Array contendo os erros que impediram a integração do registro. Atributo gerado somente quando success for igual a false.
+        }),
+        t.partial({
+            // Array contendo os erros que impediram a integração do registro. Atributo gerado somente quando success for igual a false.
             error: t.array(t.type({
-                //Código do erro que impossibilitou a integração.
+                // Código do erro que impossibilitou a integração.
                 coderr: t.string,
-                //Descrição do erro que impossibilitou a integração. 
+                // Descrição do erro que impossibilitou a integração. 
                 description: t.string
@@ -86,10 +91,11 @@ }))
     ])),
-    //Código de erro que impediu a integração do lote
+    // Código de erro que impediu a integração do lote
     coderr: t.number,
-    //Descrição do erro que impossibilitou a integração do lote. 
+    // Descrição do erro que impossibilitou a integração do lote. 
     description: t.string,
-    //Número de registros enviados no POST.
+    // Número de registros enviados no POST.
     keyAmount: t.number
 });
 exports.GetMessage = t.type({
+    verb: t.literal('get'),
     // Código do TAFTICKET, Obrigatório caso registryKey não seja informado.
@@ -107,6 +113,7 @@ ticketCode: t.string,
     queryElements: t.union([t.literal('0'), t.literal('1')]),
-    //Limita a quantidade de registros a serem retornados na requisição. O tamanho da mensagem não poderá ultrapassar 850Kb, caso isto aconteça será realizado um retorno contendo os registros que já foram incrementados na resposta.
+    // Limita a quantidade de registros a serem retornados na requisição. O tamanho da mensagem não poderá ultrapassar 850Kb, caso isto aconteça será realizado um retorno contendo os registros que já foram incrementados na resposta.
     lotQuantity: t.number
 });
 exports.GetResponseMessage = t.type({
+    verb: t.literal('get'),
     // Determina o agrupamento do retorno que pode ser por ticketCode (TAFTICKET) ou registryKey (TAFKEY), o agrupamento depende dos parâmetros enviados no request, quando o registryKey é informado e o ticketCode omitido, o  retorno será por registryKey caso contrário por ticketCode.
@@ -164,2 +171,3 @@ type: t.string,
 exports.DeleteMessage = t.type({
+    verb: t.literal('delete'),
     deleteTicket: t.array(t.type({
@@ -170,3 +178,4 @@ ticketCode: t.string
 exports.DeleteResponseMessage = t.type({
+    verb: t.literal('delete'),
     sucess: t.boolean
 });

No alert changes

Improved metrics

Number of package files

96

increased by2.13%

Worsened metrics

Total package byte prevSize

485568

decreased by-0.19%

Lines of code

11068

decreased by-0.54%

No dependency changes