1
1
/* eslint-disable import/export */
2
+ /* eslint-disable complexity */
2
3
/* eslint-disable @typescript-eslint/no-namespace */
4
+ /* eslint-disable @typescript-eslint/no-unnecessary-boolean-literal-compare */
5
+ /* eslint-disable @typescript-eslint/no-empty-interface */
3
6
4
7
import { encodeMessage , decodeMessage , message , enumeration } from 'protons-runtime'
5
- import type { Uint8ArrayList } from 'uint8arraylist'
6
8
import type { Codec } from 'protons-runtime'
9
+ import type { Uint8ArrayList } from 'uint8arraylist'
7
10
8
11
export interface Record {
9
12
key ?: Uint8Array
@@ -18,38 +21,38 @@ export namespace Record {
18
21
19
22
export const codec = ( ) : Codec < Record > => {
20
23
if ( _codec == null ) {
21
- _codec = message < Record > ( ( obj , writer , opts = { } ) => {
24
+ _codec = message < Record > ( ( obj , w , opts = { } ) => {
22
25
if ( opts . lengthDelimited !== false ) {
23
- writer . fork ( )
26
+ w . fork ( )
24
27
}
25
28
26
29
if ( obj . key != null ) {
27
- writer . uint32 ( 10 )
28
- writer . bytes ( obj . key )
30
+ w . uint32 ( 10 )
31
+ w . bytes ( obj . key )
29
32
}
30
33
31
34
if ( obj . value != null ) {
32
- writer . uint32 ( 18 )
33
- writer . bytes ( obj . value )
35
+ w . uint32 ( 18 )
36
+ w . bytes ( obj . value )
34
37
}
35
38
36
39
if ( obj . author != null ) {
37
- writer . uint32 ( 26 )
38
- writer . bytes ( obj . author )
40
+ w . uint32 ( 26 )
41
+ w . bytes ( obj . author )
39
42
}
40
43
41
44
if ( obj . signature != null ) {
42
- writer . uint32 ( 34 )
43
- writer . bytes ( obj . signature )
45
+ w . uint32 ( 34 )
46
+ w . bytes ( obj . signature )
44
47
}
45
48
46
49
if ( obj . timeReceived != null ) {
47
- writer . uint32 ( 42 )
48
- writer . string ( obj . timeReceived )
50
+ w . uint32 ( 42 )
51
+ w . string ( obj . timeReceived )
49
52
}
50
53
51
54
if ( opts . lengthDelimited !== false ) {
52
- writer . ldelim ( )
55
+ w . ldelim ( )
53
56
}
54
57
} , ( reader , length ) => {
55
58
const obj : any = { }
@@ -88,7 +91,7 @@ export namespace Record {
88
91
return _codec
89
92
}
90
93
91
- export const encode = ( obj : Record ) : Uint8Array => {
94
+ export const encode = ( obj : Partial < Record > ) : Uint8Array => {
92
95
return encodeMessage ( obj , Record . codec ( ) )
93
96
}
94
97
@@ -162,32 +165,30 @@ export namespace Message {
162
165
163
166
export const codec = ( ) : Codec < Peer > => {
164
167
if ( _codec == null ) {
165
- _codec = message < Peer > ( ( obj , writer , opts = { } ) => {
168
+ _codec = message < Peer > ( ( obj , w , opts = { } ) => {
166
169
if ( opts . lengthDelimited !== false ) {
167
- writer . fork ( )
170
+ w . fork ( )
168
171
}
169
172
170
173
if ( obj . id != null ) {
171
- writer . uint32 ( 10 )
172
- writer . bytes ( obj . id )
174
+ w . uint32 ( 10 )
175
+ w . bytes ( obj . id )
173
176
}
174
177
175
178
if ( obj . addrs != null ) {
176
179
for ( const value of obj . addrs ) {
177
- writer . uint32 ( 18 )
178
- writer . bytes ( value )
180
+ w . uint32 ( 18 )
181
+ w . bytes ( value )
179
182
}
180
- } else {
181
- throw new Error ( 'Protocol error: required field "addrs" was not found in object' )
182
183
}
183
184
184
185
if ( obj . connection != null ) {
185
- writer . uint32 ( 24 )
186
- Message . ConnectionType . codec ( ) . encode ( obj . connection , writer )
186
+ w . uint32 ( 24 )
187
+ Message . ConnectionType . codec ( ) . encode ( obj . connection , w )
187
188
}
188
189
189
190
if ( opts . lengthDelimited !== false ) {
190
- writer . ldelim ( )
191
+ w . ldelim ( )
191
192
}
192
193
} , ( reader , length ) => {
193
194
const obj : any = {
@@ -222,7 +223,7 @@ export namespace Message {
222
223
return _codec
223
224
}
224
225
225
- export const encode = ( obj : Peer ) : Uint8Array => {
226
+ export const encode = ( obj : Partial < Peer > ) : Uint8Array => {
226
227
return encodeMessage ( obj , Peer . codec ( ) )
227
228
}
228
229
@@ -235,51 +236,47 @@ export namespace Message {
235
236
236
237
export const codec = ( ) : Codec < Message > => {
237
238
if ( _codec == null ) {
238
- _codec = message < Message > ( ( obj , writer , opts = { } ) => {
239
+ _codec = message < Message > ( ( obj , w , opts = { } ) => {
239
240
if ( opts . lengthDelimited !== false ) {
240
- writer . fork ( )
241
+ w . fork ( )
241
242
}
242
243
243
244
if ( obj . type != null ) {
244
- writer . uint32 ( 8 )
245
- Message . MessageType . codec ( ) . encode ( obj . type , writer )
245
+ w . uint32 ( 8 )
246
+ Message . MessageType . codec ( ) . encode ( obj . type , w )
246
247
}
247
248
248
249
if ( obj . clusterLevelRaw != null ) {
249
- writer . uint32 ( 80 )
250
- writer . int32 ( obj . clusterLevelRaw )
250
+ w . uint32 ( 80 )
251
+ w . int32 ( obj . clusterLevelRaw )
251
252
}
252
253
253
254
if ( obj . key != null ) {
254
- writer . uint32 ( 18 )
255
- writer . bytes ( obj . key )
255
+ w . uint32 ( 18 )
256
+ w . bytes ( obj . key )
256
257
}
257
258
258
259
if ( obj . record != null ) {
259
- writer . uint32 ( 26 )
260
- writer . bytes ( obj . record )
260
+ w . uint32 ( 26 )
261
+ w . bytes ( obj . record )
261
262
}
262
263
263
264
if ( obj . closerPeers != null ) {
264
265
for ( const value of obj . closerPeers ) {
265
- writer . uint32 ( 66 )
266
- Message . Peer . codec ( ) . encode ( value , writer )
266
+ w . uint32 ( 66 )
267
+ Message . Peer . codec ( ) . encode ( value , w )
267
268
}
268
- } else {
269
- throw new Error ( 'Protocol error: required field "closerPeers" was not found in object' )
270
269
}
271
270
272
271
if ( obj . providerPeers != null ) {
273
272
for ( const value of obj . providerPeers ) {
274
- writer . uint32 ( 74 )
275
- Message . Peer . codec ( ) . encode ( value , writer )
273
+ w . uint32 ( 74 )
274
+ Message . Peer . codec ( ) . encode ( value , w )
276
275
}
277
- } else {
278
- throw new Error ( 'Protocol error: required field "providerPeers" was not found in object' )
279
276
}
280
277
281
278
if ( opts . lengthDelimited !== false ) {
282
- writer . ldelim ( )
279
+ w . ldelim ( )
283
280
}
284
281
} , ( reader , length ) => {
285
282
const obj : any = {
@@ -324,7 +321,7 @@ export namespace Message {
324
321
return _codec
325
322
}
326
323
327
- export const encode = ( obj : Message ) : Uint8Array => {
324
+ export const encode = ( obj : Partial < Message > ) : Uint8Array => {
328
325
return encodeMessage ( obj , Message . codec ( ) )
329
326
}
330
327
0 commit comments