Skip to content

Commit e691aa7

Browse files
update faulty proto def
1 parent 7e89ac4 commit e691aa7

File tree

3 files changed

+0
-121
lines changed

3 files changed

+0
-121
lines changed

packages/core/src/lib/metadata/rpc.ts

-38
This file was deleted.

packages/proto/src/lib/metadata.proto

-7
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,6 @@
11
syntax = "proto3";
22

33

4-
message MetadataRpc {
5-
string request_id = 1;
6-
optional WakuMetadataRequest request = 2;
7-
optional WakuMetadataResponse response = 3;
8-
}
9-
10-
114
message WakuMetadataRequest {
125
optional uint32 cluster_id = 1;
136
repeated uint32 shards = 2;

packages/proto/src/lib/metadata.ts

-76
Original file line numberDiff line numberDiff line change
@@ -8,82 +8,6 @@ import { encodeMessage, decodeMessage, message } from 'protons-runtime'
88
import type { Codec } from 'protons-runtime'
99
import type { Uint8ArrayList } from 'uint8arraylist'
1010

11-
export interface MetadataRpc {
12-
requestId: string
13-
request?: WakuMetadataRequest
14-
response?: WakuMetadataResponse
15-
}
16-
17-
export namespace MetadataRpc {
18-
let _codec: Codec<MetadataRpc>
19-
20-
export const codec = (): Codec<MetadataRpc> => {
21-
if (_codec == null) {
22-
_codec = message<MetadataRpc>((obj, w, opts = {}) => {
23-
if (opts.lengthDelimited !== false) {
24-
w.fork()
25-
}
26-
27-
if ((obj.requestId != null && obj.requestId !== '')) {
28-
w.uint32(10)
29-
w.string(obj.requestId)
30-
}
31-
32-
if (obj.request != null) {
33-
w.uint32(18)
34-
WakuMetadataRequest.codec().encode(obj.request, w)
35-
}
36-
37-
if (obj.response != null) {
38-
w.uint32(26)
39-
WakuMetadataResponse.codec().encode(obj.response, w)
40-
}
41-
42-
if (opts.lengthDelimited !== false) {
43-
w.ldelim()
44-
}
45-
}, (reader, length) => {
46-
const obj: any = {
47-
requestId: ''
48-
}
49-
50-
const end = length == null ? reader.len : reader.pos + length
51-
52-
while (reader.pos < end) {
53-
const tag = reader.uint32()
54-
55-
switch (tag >>> 3) {
56-
case 1:
57-
obj.requestId = reader.string()
58-
break
59-
case 2:
60-
obj.request = WakuMetadataRequest.codec().decode(reader, reader.uint32())
61-
break
62-
case 3:
63-
obj.response = WakuMetadataResponse.codec().decode(reader, reader.uint32())
64-
break
65-
default:
66-
reader.skipType(tag & 7)
67-
break
68-
}
69-
}
70-
71-
return obj
72-
})
73-
}
74-
75-
return _codec
76-
}
77-
78-
export const encode = (obj: Partial<MetadataRpc>): Uint8Array => {
79-
return encodeMessage(obj, MetadataRpc.codec())
80-
}
81-
82-
export const decode = (buf: Uint8Array | Uint8ArrayList): MetadataRpc => {
83-
return decodeMessage(buf, MetadataRpc.codec())
84-
}
85-
}
86-
8711
export interface WakuMetadataRequest {
8812
clusterId?: number
8913
shards: number[]

0 commit comments

Comments
 (0)