waku-org/js-waku
1
0
Fork 0
mirror of https://github.com/waku-org/js-waku.git synced 2025-02-27 03:20:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

commit new proto buf gen

Browse Source
This commit is contained in:
danisharora099 2024-01-30 19:52:03 +05:30
parent 8fa2d1b236
commit b41fb70576
No known key found for this signature in database
GPG Key ID: FBD2BF500037F135
8 changed files with 366 additions and 213 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

104
packages/proto/src/lib/filter.ts
View File

@ -4,8 +4,8 @@
/* eslint-disable @typescript-eslint/no-unnecessary-boolean-literal-compare */ /* eslint-disable @typescript-eslint/no-unnecessary-boolean-literal-compare */
/* eslint-disable @typescript-eslint/no-empty-interface */ /* eslint-disable @typescript-eslint/no-empty-interface */
import { encodeMessage, decodeMessage, message } from 'protons-runtime' import { type Codec, decodeMessage, encodeMessage, message } from 'protons-runtime'
import type { Codec } from 'protons-runtime' import { alloc as uint8ArrayAlloc } from 'uint8arrays/alloc'
import type { Uint8ArrayList } from 'uint8arraylist' import type { Uint8ArrayList } from 'uint8arraylist'
export interface FilterRequest { export interface FilterRequest {
@ -48,14 +48,16 @@ export namespace FilterRequest {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.contentTopic = reader.string() obj.contentTopic = reader.string()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -115,20 +117,24 @@ export namespace FilterRequest {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.subscribe = reader.bool() obj.subscribe = reader.bool()
break break
case 2: }
case 2: {
obj.topic = reader.string() obj.topic = reader.string()
break break
case 3: }
case 3: {
obj.contentFilters.push(FilterRequest.ContentFilter.codec().decode(reader, reader.uint32())) obj.contentFilters.push(FilterRequest.ContentFilter.codec().decode(reader, reader.uint32()))
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -181,14 +187,16 @@ export namespace MessagePush {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.messages.push(WakuMessage.codec().decode(reader, reader.uint32())) obj.messages.push(WakuMessage.codec().decode(reader, reader.uint32()))
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -251,20 +259,24 @@ export namespace FilterRpc {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.requestId = reader.string() obj.requestId = reader.string()
break break
case 2: }
case 2: {
obj.request = FilterRequest.codec().decode(reader, reader.uint32()) obj.request = FilterRequest.codec().decode(reader, reader.uint32())
break break
case 3: }
case 3: {
obj.push = MessagePush.codec().decode(reader, reader.uint32()) obj.push = MessagePush.codec().decode(reader, reader.uint32())
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -342,13 +354,13 @@ export namespace RateLimitProof {
} }
}, (reader, length) => { }, (reader, length) => {
const obj: any = { const obj: any = {
proof: new Uint8Array(0), proof: uint8ArrayAlloc(0),
merkleRoot: new Uint8Array(0), merkleRoot: uint8ArrayAlloc(0),
epoch: new Uint8Array(0), epoch: uint8ArrayAlloc(0),
shareX: new Uint8Array(0), shareX: uint8ArrayAlloc(0),
shareY: new Uint8Array(0), shareY: uint8ArrayAlloc(0),
nullifier: new Uint8Array(0), nullifier: uint8ArrayAlloc(0),
rlnIdentifier: new Uint8Array(0) rlnIdentifier: uint8ArrayAlloc(0)
} }
const end = length == null ? reader.len : reader.pos + length const end = length == null ? reader.len : reader.pos + length
@ -357,32 +369,40 @@ export namespace RateLimitProof {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.proof = reader.bytes() obj.proof = reader.bytes()
break break
case 2: }
case 2: {
obj.merkleRoot = reader.bytes() obj.merkleRoot = reader.bytes()
break break
case 3: }
case 3: {
obj.epoch = reader.bytes() obj.epoch = reader.bytes()
break break
case 4: }
case 4: {
obj.shareX = reader.bytes() obj.shareX = reader.bytes()
break break
case 5: }
case 5: {
obj.shareY = reader.bytes() obj.shareY = reader.bytes()
break break
case 6: }
case 6: {
obj.nullifier = reader.bytes() obj.nullifier = reader.bytes()
break break
case 7: }
case 7: {
obj.rlnIdentifier = reader.bytes() obj.rlnIdentifier = reader.bytes()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -460,7 +480,7 @@ export namespace WakuMessage {
} }
}, (reader, length) => { }, (reader, length) => {
const obj: any = { const obj: any = {
payload: new Uint8Array(0), payload: uint8ArrayAlloc(0),
contentTopic: '' contentTopic: ''
} }
@ -470,32 +490,40 @@ export namespace WakuMessage {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.payload = reader.bytes() obj.payload = reader.bytes()
break break
case 2: }
case 2: {
obj.contentTopic = reader.string() obj.contentTopic = reader.string()
break break
case 3: }
case 3: {
obj.version = reader.uint32() obj.version = reader.uint32()
break break
case 10: }
case 10: {
obj.timestamp = reader.sint64() obj.timestamp = reader.sint64()
break break
case 11: }
case 11: {
obj.meta = reader.bytes() obj.meta = reader.bytes()
break break
case 21: }
case 21: {
obj.rateLimitProof = RateLimitProof.codec().decode(reader, reader.uint32()) obj.rateLimitProof = RateLimitProof.codec().decode(reader, reader.uint32())
break break
case 31: }
case 31: {
obj.ephemeral = reader.bool() obj.ephemeral = reader.bool()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })

104
packages/proto/src/lib/filter_v2.ts
View File

@ -4,8 +4,8 @@
/* eslint-disable @typescript-eslint/no-unnecessary-boolean-literal-compare */ /* eslint-disable @typescript-eslint/no-unnecessary-boolean-literal-compare */
/* eslint-disable @typescript-eslint/no-empty-interface */ /* eslint-disable @typescript-eslint/no-empty-interface */
import { enumeration, encodeMessage, decodeMessage, message } from 'protons-runtime' import { type Codec, decodeMessage, encodeMessage, enumeration, message } from 'protons-runtime'
import type { Codec } from 'protons-runtime' import { alloc as uint8ArrayAlloc } from 'uint8arrays/alloc'
import type { Uint8ArrayList } from 'uint8arraylist' import type { Uint8ArrayList } from 'uint8arraylist'
export interface FilterSubscribeRequest { export interface FilterSubscribeRequest {
@ -83,23 +83,28 @@ export namespace FilterSubscribeRequest {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.requestId = reader.string() obj.requestId = reader.string()
break break
case 2: }
case 2: {
obj.filterSubscribeType = FilterSubscribeRequest.FilterSubscribeType.codec().decode(reader) obj.filterSubscribeType = FilterSubscribeRequest.FilterSubscribeType.codec().decode(reader)
break break
case 10: }
case 10: {
obj.pubsubTopic = reader.string() obj.pubsubTopic = reader.string()
break break
case 11: }
case 11: {
obj.contentTopics.push(reader.string()) obj.contentTopics.push(reader.string())
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -163,20 +168,24 @@ export namespace FilterSubscribeResponse {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.requestId = reader.string() obj.requestId = reader.string()
break break
case 10: }
case 10: {
obj.statusCode = reader.uint32() obj.statusCode = reader.uint32()
break break
case 11: }
case 11: {
obj.statusDesc = reader.string() obj.statusDesc = reader.string()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -231,17 +240,20 @@ export namespace MessagePush {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.wakuMessage = WakuMessage.codec().decode(reader, reader.uint32()) obj.wakuMessage = WakuMessage.codec().decode(reader, reader.uint32())
break break
case 2: }
case 2: {
obj.pubsubTopic = reader.string() obj.pubsubTopic = reader.string()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -319,13 +331,13 @@ export namespace RateLimitProof {
} }
}, (reader, length) => { }, (reader, length) => {
const obj: any = { const obj: any = {
proof: new Uint8Array(0), proof: uint8ArrayAlloc(0),
merkleRoot: new Uint8Array(0), merkleRoot: uint8ArrayAlloc(0),
epoch: new Uint8Array(0), epoch: uint8ArrayAlloc(0),
shareX: new Uint8Array(0), shareX: uint8ArrayAlloc(0),
shareY: new Uint8Array(0), shareY: uint8ArrayAlloc(0),
nullifier: new Uint8Array(0), nullifier: uint8ArrayAlloc(0),
rlnIdentifier: new Uint8Array(0) rlnIdentifier: uint8ArrayAlloc(0)
} }
const end = length == null ? reader.len : reader.pos + length const end = length == null ? reader.len : reader.pos + length
@ -334,32 +346,40 @@ export namespace RateLimitProof {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.proof = reader.bytes() obj.proof = reader.bytes()
break break
case 2: }
case 2: {
obj.merkleRoot = reader.bytes() obj.merkleRoot = reader.bytes()
break break
case 3: }
case 3: {
obj.epoch = reader.bytes() obj.epoch = reader.bytes()
break break
case 4: }
case 4: {
obj.shareX = reader.bytes() obj.shareX = reader.bytes()
break break
case 5: }
case 5: {
obj.shareY = reader.bytes() obj.shareY = reader.bytes()
break break
case 6: }
case 6: {
obj.nullifier = reader.bytes() obj.nullifier = reader.bytes()
break break
case 7: }
case 7: {
obj.rlnIdentifier = reader.bytes() obj.rlnIdentifier = reader.bytes()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -437,7 +457,7 @@ export namespace WakuMessage {
} }
}, (reader, length) => { }, (reader, length) => {
const obj: any = { const obj: any = {
payload: new Uint8Array(0), payload: uint8ArrayAlloc(0),
contentTopic: '' contentTopic: ''
} }
@ -447,32 +467,40 @@ export namespace WakuMessage {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.payload = reader.bytes() obj.payload = reader.bytes()
break break
case 2: }
case 2: {
obj.contentTopic = reader.string() obj.contentTopic = reader.string()
break break
case 3: }
case 3: {
obj.version = reader.uint32() obj.version = reader.uint32()
break break
case 10: }
case 10: {
obj.timestamp = reader.sint64() obj.timestamp = reader.sint64()
break break
case 11: }
case 11: {
obj.meta = reader.bytes() obj.meta = reader.bytes()
break break
case 21: }
case 21: {
obj.rateLimitProof = RateLimitProof.codec().decode(reader, reader.uint32()) obj.rateLimitProof = RateLimitProof.codec().decode(reader, reader.uint32())
break break
case 31: }
case 31: {
obj.ephemeral = reader.bool() obj.ephemeral = reader.bool()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })

98
packages/proto/src/lib/light_push.ts
View File

@ -4,8 +4,8 @@
/* eslint-disable @typescript-eslint/no-unnecessary-boolean-literal-compare */ /* eslint-disable @typescript-eslint/no-unnecessary-boolean-literal-compare */
/* eslint-disable @typescript-eslint/no-empty-interface */ /* eslint-disable @typescript-eslint/no-empty-interface */
import { encodeMessage, decodeMessage, message } from 'protons-runtime' import { type Codec, decodeMessage, encodeMessage, message } from 'protons-runtime'
import type { Codec } from 'protons-runtime' import { alloc as uint8ArrayAlloc } from 'uint8arrays/alloc'
import type { Uint8ArrayList } from 'uint8arraylist' import type { Uint8ArrayList } from 'uint8arraylist'
export interface PushRequest { export interface PushRequest {
@ -47,17 +47,20 @@ export namespace PushRequest {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.pubsubTopic = reader.string() obj.pubsubTopic = reader.string()
break break
case 2: }
case 2: {
obj.message = WakuMessage.codec().decode(reader, reader.uint32()) obj.message = WakuMessage.codec().decode(reader, reader.uint32())
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -114,17 +117,20 @@ export namespace PushResponse {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.isSuccess = reader.bool() obj.isSuccess = reader.bool()
break break
case 2: }
case 2: {
obj.info = reader.string() obj.info = reader.string()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -187,20 +193,24 @@ export namespace PushRpc {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.requestId = reader.string() obj.requestId = reader.string()
break break
case 2: }
case 2: {
obj.request = PushRequest.codec().decode(reader, reader.uint32()) obj.request = PushRequest.codec().decode(reader, reader.uint32())
break break
case 3: }
case 3: {
obj.response = PushResponse.codec().decode(reader, reader.uint32()) obj.response = PushResponse.codec().decode(reader, reader.uint32())
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -278,13 +288,13 @@ export namespace RateLimitProof {
} }
}, (reader, length) => { }, (reader, length) => {
const obj: any = { const obj: any = {
proof: new Uint8Array(0), proof: uint8ArrayAlloc(0),
merkleRoot: new Uint8Array(0), merkleRoot: uint8ArrayAlloc(0),
epoch: new Uint8Array(0), epoch: uint8ArrayAlloc(0),
shareX: new Uint8Array(0), shareX: uint8ArrayAlloc(0),
shareY: new Uint8Array(0), shareY: uint8ArrayAlloc(0),
nullifier: new Uint8Array(0), nullifier: uint8ArrayAlloc(0),
rlnIdentifier: new Uint8Array(0) rlnIdentifier: uint8ArrayAlloc(0)
} }
const end = length == null ? reader.len : reader.pos + length const end = length == null ? reader.len : reader.pos + length
@ -293,32 +303,40 @@ export namespace RateLimitProof {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.proof = reader.bytes() obj.proof = reader.bytes()
break break
case 2: }
case 2: {
obj.merkleRoot = reader.bytes() obj.merkleRoot = reader.bytes()
break break
case 3: }
case 3: {
obj.epoch = reader.bytes() obj.epoch = reader.bytes()
break break
case 4: }
case 4: {
obj.shareX = reader.bytes() obj.shareX = reader.bytes()
break break
case 5: }
case 5: {
obj.shareY = reader.bytes() obj.shareY = reader.bytes()
break break
case 6: }
case 6: {
obj.nullifier = reader.bytes() obj.nullifier = reader.bytes()
break break
case 7: }
case 7: {
obj.rlnIdentifier = reader.bytes() obj.rlnIdentifier = reader.bytes()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -396,7 +414,7 @@ export namespace WakuMessage {
} }
}, (reader, length) => { }, (reader, length) => {
const obj: any = { const obj: any = {
payload: new Uint8Array(0), payload: uint8ArrayAlloc(0),
contentTopic: '' contentTopic: ''
} }
@ -406,32 +424,40 @@ export namespace WakuMessage {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.payload = reader.bytes() obj.payload = reader.bytes()
break break
case 2: }
case 2: {
obj.contentTopic = reader.string() obj.contentTopic = reader.string()
break break
case 3: }
case 3: {
obj.version = reader.uint32() obj.version = reader.uint32()
break break
case 10: }
case 10: {
obj.timestamp = reader.sint64() obj.timestamp = reader.sint64()
break break
case 11: }
case 11: {
obj.meta = reader.bytes() obj.meta = reader.bytes()
break break
case 21: }
case 21: {
obj.rateLimitProof = RateLimitProof.codec().decode(reader, reader.uint32()) obj.rateLimitProof = RateLimitProof.codec().decode(reader, reader.uint32())
break break
case 31: }
case 31: {
obj.ephemeral = reader.bool() obj.ephemeral = reader.bool()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })

68
packages/proto/src/lib/message.ts
View File

@ -4,8 +4,8 @@
/* eslint-disable @typescript-eslint/no-unnecessary-boolean-literal-compare */ /* eslint-disable @typescript-eslint/no-unnecessary-boolean-literal-compare */
/* eslint-disable @typescript-eslint/no-empty-interface */ /* eslint-disable @typescript-eslint/no-empty-interface */
import { encodeMessage, decodeMessage, message } from 'protons-runtime' import { type Codec, decodeMessage, encodeMessage, message } from 'protons-runtime'
import type { Codec } from 'protons-runtime' import { alloc as uint8ArrayAlloc } from 'uint8arrays/alloc'
import type { Uint8ArrayList } from 'uint8arraylist' import type { Uint8ArrayList } from 'uint8arraylist'
export interface RateLimitProof { export interface RateLimitProof {
@ -68,13 +68,13 @@ export namespace RateLimitProof {
} }
}, (reader, length) => { }, (reader, length) => {
const obj: any = { const obj: any = {
proof: new Uint8Array(0), proof: uint8ArrayAlloc(0),
merkleRoot: new Uint8Array(0), merkleRoot: uint8ArrayAlloc(0),
epoch: new Uint8Array(0), epoch: uint8ArrayAlloc(0),
shareX: new Uint8Array(0), shareX: uint8ArrayAlloc(0),
shareY: new Uint8Array(0), shareY: uint8ArrayAlloc(0),
nullifier: new Uint8Array(0), nullifier: uint8ArrayAlloc(0),
rlnIdentifier: new Uint8Array(0) rlnIdentifier: uint8ArrayAlloc(0)
} }
const end = length == null ? reader.len : reader.pos + length const end = length == null ? reader.len : reader.pos + length
@ -83,32 +83,40 @@ export namespace RateLimitProof {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.proof = reader.bytes() obj.proof = reader.bytes()
break break
case 2: }
case 2: {
obj.merkleRoot = reader.bytes() obj.merkleRoot = reader.bytes()
break break
case 3: }
case 3: {
obj.epoch = reader.bytes() obj.epoch = reader.bytes()
break break
case 4: }
case 4: {
obj.shareX = reader.bytes() obj.shareX = reader.bytes()
break break
case 5: }
case 5: {
obj.shareY = reader.bytes() obj.shareY = reader.bytes()
break break
case 6: }
case 6: {
obj.nullifier = reader.bytes() obj.nullifier = reader.bytes()
break break
case 7: }
case 7: {
obj.rlnIdentifier = reader.bytes() obj.rlnIdentifier = reader.bytes()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -186,7 +194,7 @@ export namespace WakuMessage {
} }
}, (reader, length) => { }, (reader, length) => {
const obj: any = { const obj: any = {
payload: new Uint8Array(0), payload: uint8ArrayAlloc(0),
contentTopic: '' contentTopic: ''
} }
@ -196,32 +204,40 @@ export namespace WakuMessage {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.payload = reader.bytes() obj.payload = reader.bytes()
break break
case 2: }
case 2: {
obj.contentTopic = reader.string() obj.contentTopic = reader.string()
break break
case 3: }
case 3: {
obj.version = reader.uint32() obj.version = reader.uint32()
break break
case 10: }
case 10: {
obj.timestamp = reader.sint64() obj.timestamp = reader.sint64()
break break
case 11: }
case 11: {
obj.meta = reader.bytes() obj.meta = reader.bytes()
break break
case 21: }
case 21: {
obj.rateLimitProof = RateLimitProof.codec().decode(reader, reader.uint32()) obj.rateLimitProof = RateLimitProof.codec().decode(reader, reader.uint32())
break break
case 31: }
case 31: {
obj.ephemeral = reader.bool() obj.ephemeral = reader.bool()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })

21
packages/proto/src/lib/metadata.ts
View File

@ -4,8 +4,7 @@
/* eslint-disable @typescript-eslint/no-unnecessary-boolean-literal-compare */ /* eslint-disable @typescript-eslint/no-unnecessary-boolean-literal-compare */
/* eslint-disable @typescript-eslint/no-empty-interface */ /* eslint-disable @typescript-eslint/no-empty-interface */
import { encodeMessage, decodeMessage, message } from 'protons-runtime' import { type Codec, decodeMessage, encodeMessage, message } from 'protons-runtime'
import type { Codec } from 'protons-runtime'
import type { Uint8ArrayList } from 'uint8arraylist' import type { Uint8ArrayList } from 'uint8arraylist'
export interface WakuMetadataRequest { export interface WakuMetadataRequest {
@ -49,17 +48,20 @@ export namespace WakuMetadataRequest {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.clusterId = reader.uint32() obj.clusterId = reader.uint32()
break break
case 2: }
case 2: {
obj.shards.push(reader.uint32()) obj.shards.push(reader.uint32())
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -118,17 +120,20 @@ export namespace WakuMetadataResponse {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.clusterId = reader.uint32() obj.clusterId = reader.uint32()
break break
case 2: }
case 2: {
obj.shards.push(reader.uint32()) obj.shards.push(reader.uint32())
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })

30
packages/proto/src/lib/peer_exchange.ts
View File

@ -4,8 +4,7 @@
/* eslint-disable @typescript-eslint/no-unnecessary-boolean-literal-compare */ /* eslint-disable @typescript-eslint/no-unnecessary-boolean-literal-compare */
/* eslint-disable @typescript-eslint/no-empty-interface */ /* eslint-disable @typescript-eslint/no-empty-interface */
import { encodeMessage, decodeMessage, message } from 'protons-runtime' import { type Codec, decodeMessage, encodeMessage, message } from 'protons-runtime'
import type { Codec } from 'protons-runtime'
import type { Uint8ArrayList } from 'uint8arraylist' import type { Uint8ArrayList } from 'uint8arraylist'
export interface PeerInfo { export interface PeerInfo {
@ -39,14 +38,16 @@ export namespace PeerInfo {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.enr = reader.bytes() obj.enr = reader.bytes()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -95,14 +96,16 @@ export namespace PeerExchangeQuery {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.numPeers = reader.uint64() obj.numPeers = reader.uint64()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -155,14 +158,16 @@ export namespace PeerExchangeResponse {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.peerInfos.push(PeerInfo.codec().decode(reader, reader.uint32())) obj.peerInfos.push(PeerInfo.codec().decode(reader, reader.uint32()))
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -217,17 +222,20 @@ export namespace PeerExchangeRPC {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.query = PeerExchangeQuery.codec().decode(reader, reader.uint32()) obj.query = PeerExchangeQuery.codec().decode(reader, reader.uint32())
break break
case 2: }
case 2: {
obj.response = PeerExchangeResponse.codec().decode(reader, reader.uint32()) obj.response = PeerExchangeResponse.codec().decode(reader, reader.uint32())
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })

145
packages/proto/src/lib/store.ts
View File

@ -4,8 +4,8 @@
/* eslint-disable @typescript-eslint/no-unnecessary-boolean-literal-compare */ /* eslint-disable @typescript-eslint/no-unnecessary-boolean-literal-compare */
/* eslint-disable @typescript-eslint/no-empty-interface */ /* eslint-disable @typescript-eslint/no-empty-interface */
import { encodeMessage, decodeMessage, message, enumeration } from 'protons-runtime' import { type Codec, decodeMessage, encodeMessage, enumeration, message } from 'protons-runtime'
import type { Codec } from 'protons-runtime' import { alloc as uint8ArrayAlloc } from 'uint8arrays/alloc'
import type { Uint8ArrayList } from 'uint8arraylist' import type { Uint8ArrayList } from 'uint8arraylist'
export interface Index { export interface Index {
@ -50,7 +50,7 @@ export namespace Index {
} }
}, (reader, length) => { }, (reader, length) => {
const obj: any = { const obj: any = {
digest: new Uint8Array(0), digest: uint8ArrayAlloc(0),
receiverTime: 0n, receiverTime: 0n,
senderTime: 0n, senderTime: 0n,
pubsubTopic: '' pubsubTopic: ''
@ -62,23 +62,28 @@ export namespace Index {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.digest = reader.bytes() obj.digest = reader.bytes()
break break
case 2: }
case 2: {
obj.receiverTime = reader.sint64() obj.receiverTime = reader.sint64()
break break
case 3: }
case 3: {
obj.senderTime = reader.sint64() obj.senderTime = reader.sint64()
break break
case 4: }
case 4: {
obj.pubsubTopic = reader.string() obj.pubsubTopic = reader.string()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -155,20 +160,24 @@ export namespace PagingInfo {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.pageSize = reader.uint64() obj.pageSize = reader.uint64()
break break
case 2: }
case 2: {
obj.cursor = Index.codec().decode(reader, reader.uint32()) obj.cursor = Index.codec().decode(reader, reader.uint32())
break break
case 3: }
case 3: {
obj.direction = PagingInfo.Direction.codec().decode(reader) obj.direction = PagingInfo.Direction.codec().decode(reader)
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -219,14 +228,16 @@ export namespace ContentFilter {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.contentTopic = reader.string() obj.contentTopic = reader.string()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -303,26 +314,32 @@ export namespace HistoryQuery {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 2: case 2: {
obj.pubsubTopic = reader.string() obj.pubsubTopic = reader.string()
break break
case 3: }
case 3: {
obj.contentFilters.push(ContentFilter.codec().decode(reader, reader.uint32())) obj.contentFilters.push(ContentFilter.codec().decode(reader, reader.uint32()))
break break
case 4: }
case 4: {
obj.pagingInfo = PagingInfo.codec().decode(reader, reader.uint32()) obj.pagingInfo = PagingInfo.codec().decode(reader, reader.uint32())
break break
case 5: }
case 5: {
obj.startTime = reader.sint64() obj.startTime = reader.sint64()
break break
case 6: }
case 6: {
obj.endTime = reader.sint64() obj.endTime = reader.sint64()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -404,20 +421,24 @@ export namespace HistoryResponse {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 2: case 2: {
obj.messages.push(WakuMessage.codec().decode(reader, reader.uint32())) obj.messages.push(WakuMessage.codec().decode(reader, reader.uint32()))
break break
case 3: }
case 3: {
obj.pagingInfo = PagingInfo.codec().decode(reader, reader.uint32()) obj.pagingInfo = PagingInfo.codec().decode(reader, reader.uint32())
break break
case 4: }
case 4: {
obj.error = HistoryResponse.HistoryError.codec().decode(reader) obj.error = HistoryResponse.HistoryError.codec().decode(reader)
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -480,20 +501,24 @@ export namespace HistoryRpc {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.requestId = reader.string() obj.requestId = reader.string()
break break
case 2: }
case 2: {
obj.query = HistoryQuery.codec().decode(reader, reader.uint32()) obj.query = HistoryQuery.codec().decode(reader, reader.uint32())
break break
case 3: }
case 3: {
obj.response = HistoryResponse.codec().decode(reader, reader.uint32()) obj.response = HistoryResponse.codec().decode(reader, reader.uint32())
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -571,13 +596,13 @@ export namespace RateLimitProof {
} }
}, (reader, length) => { }, (reader, length) => {
const obj: any = { const obj: any = {
proof: new Uint8Array(0), proof: uint8ArrayAlloc(0),
merkleRoot: new Uint8Array(0), merkleRoot: uint8ArrayAlloc(0),
epoch: new Uint8Array(0), epoch: uint8ArrayAlloc(0),
shareX: new Uint8Array(0), shareX: uint8ArrayAlloc(0),
shareY: new Uint8Array(0), shareY: uint8ArrayAlloc(0),
nullifier: new Uint8Array(0), nullifier: uint8ArrayAlloc(0),
rlnIdentifier: new Uint8Array(0) rlnIdentifier: uint8ArrayAlloc(0)
} }
const end = length == null ? reader.len : reader.pos + length const end = length == null ? reader.len : reader.pos + length
@ -586,32 +611,40 @@ export namespace RateLimitProof {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.proof = reader.bytes() obj.proof = reader.bytes()
break break
case 2: }
case 2: {
obj.merkleRoot = reader.bytes() obj.merkleRoot = reader.bytes()
break break
case 3: }
case 3: {
obj.epoch = reader.bytes() obj.epoch = reader.bytes()
break break
case 4: }
case 4: {
obj.shareX = reader.bytes() obj.shareX = reader.bytes()
break break
case 5: }
case 5: {
obj.shareY = reader.bytes() obj.shareY = reader.bytes()
break break
case 6: }
case 6: {
obj.nullifier = reader.bytes() obj.nullifier = reader.bytes()
break break
case 7: }
case 7: {
obj.rlnIdentifier = reader.bytes() obj.rlnIdentifier = reader.bytes()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })
@ -689,7 +722,7 @@ export namespace WakuMessage {
} }
}, (reader, length) => { }, (reader, length) => {
const obj: any = { const obj: any = {
payload: new Uint8Array(0), payload: uint8ArrayAlloc(0),
contentTopic: '' contentTopic: ''
} }
@ -699,32 +732,40 @@ export namespace WakuMessage {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 1: case 1: {
obj.payload = reader.bytes() obj.payload = reader.bytes()
break break
case 2: }
case 2: {
obj.contentTopic = reader.string() obj.contentTopic = reader.string()
break break
case 3: }
case 3: {
obj.version = reader.uint32() obj.version = reader.uint32()
break break
case 10: }
case 10: {
obj.timestamp = reader.sint64() obj.timestamp = reader.sint64()
break break
case 11: }
case 11: {
obj.meta = reader.bytes() obj.meta = reader.bytes()
break break
case 21: }
case 21: {
obj.rateLimitProof = RateLimitProof.codec().decode(reader, reader.uint32()) obj.rateLimitProof = RateLimitProof.codec().decode(reader, reader.uint32())
break break
case 31: }
case 31: {
obj.ephemeral = reader.bool() obj.ephemeral = reader.bool()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })

9
packages/proto/src/lib/topic_only_message.ts
View File

@ -4,8 +4,7 @@
/* eslint-disable @typescript-eslint/no-unnecessary-boolean-literal-compare */ /* eslint-disable @typescript-eslint/no-unnecessary-boolean-literal-compare */
/* eslint-disable @typescript-eslint/no-empty-interface */ /* eslint-disable @typescript-eslint/no-empty-interface */
import { encodeMessage, decodeMessage, message } from 'protons-runtime' import { type Codec, decodeMessage, encodeMessage, message } from 'protons-runtime'
import type { Codec } from 'protons-runtime'
import type { Uint8ArrayList } from 'uint8arraylist' import type { Uint8ArrayList } from 'uint8arraylist'
export interface TopicOnlyMessage { export interface TopicOnlyMessage {
@ -41,14 +40,16 @@ export namespace TopicOnlyMessage {
const tag = reader.uint32() const tag = reader.uint32()
switch (tag >>> 3) { switch (tag >>> 3) {
case 2: case 2: {
obj.contentTopic = reader.string() obj.contentTopic = reader.string()
break break
default: }
default: {
reader.skipType(tag & 7) reader.skipType(tag & 7)
break break
} }
} }
}
return obj return obj
}) })