@samitouri / QOSAMI-X402Tunnel / commits / ad3c4176

refactor: update CloneMessageVT and EqualMessageVT methods to use 'any' instead of 'proto.Message'

- Changed the return type of CloneMessageVT methods in various structs from proto.Message to any. - Updated the parameter type of EqualMessageVT methods to accept 'any' instead of 'proto.Message'. - This change enhances type flexibility and aligns with recent Go language updates.

cognitive committed Dec 30, 2025 at 00:58 UTC ad3c41762fc60c03f238e1791fd74c0605b41723
4 files changed +121 -796
portal/core/proto/rdsec/rdsec.pb.go
+32 -250
@@ -1,26 +1,12 @@
1 // Code generated by protoc-gen-go. DO NOT EDIT.
2 // versions:
3 -// protoc-gen-go v1.36.10
4 -// protoc v6.33.0
3 +// protoc-gen-go v1.36.11
4 +// protoc v3.21.12
5 // source: portal/core/proto/rdsec/rdsec.proto
6 +// Reflection-free version for TinyGo compatibility
7
8 package rdsec
9
9 -import (
10 - protoreflect "google.golang.org/protobuf/reflect/protoreflect"
11 - protoimpl "google.golang.org/protobuf/runtime/protoimpl"
12 - reflect "reflect"
13 - sync "sync"
14 - unsafe "unsafe"
15 -)
16 -
17 -const (
18 - // Verify that this generated code is sufficiently up-to-date.
19 - _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
20 - // Verify that runtime/protoimpl is sufficiently up-to-date.
21 - _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
22 -)
23 -
10 type ProtocolVersion int32
11
12 const (
@@ -44,63 +30,24 @@ func (x ProtocolVersion) Enum() *ProtocolVersion {
30 }
31
32 func (x ProtocolVersion) String() string {
47 - return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
48 -}
49 -
50 -func (ProtocolVersion) Descriptor() protoreflect.EnumDescriptor {
51 - return file_portal_core_proto_rdsec_rdsec_proto_enumTypes[0].Descriptor()
52 -}
53 -
54 -func (ProtocolVersion) Type() protoreflect.EnumType {
55 - return &file_portal_core_proto_rdsec_rdsec_proto_enumTypes[0]
56 -}
57 -
58 -func (x ProtocolVersion) Number() protoreflect.EnumNumber {
59 - return protoreflect.EnumNumber(x)
60 -}
61 -
62 -// Deprecated: Use ProtocolVersion.Descriptor instead.
63 -func (ProtocolVersion) EnumDescriptor() ([]byte, []int) {
64 - return file_portal_core_proto_rdsec_rdsec_proto_rawDescGZIP(), []int{0}
33 + s, ok := ProtocolVersion_name[int32(x)]
34 + if !ok {
35 + return "ProtocolVersion(" + string(rune('0'+x)) + ")"
36 + }
37 + return s
38 }
39
40 type Identity struct {
68 - state protoimpl.MessageState `protogen:"open.v1"`
69 - Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
70 - PublicKey []byte `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
71 - unknownFields protoimpl.UnknownFields
72 - sizeCache protoimpl.SizeCache
41 + Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
42 + PublicKey []byte `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
43 + unknownFields []byte
44 }
45
46 func (x *Identity) Reset() {
47 *x = Identity{}
77 - mi := &file_portal_core_proto_rdsec_rdsec_proto_msgTypes[0]
78 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
79 - ms.StoreMessageInfo(mi)
48 }
49
82 -func (x *Identity) String() string {
83 - return protoimpl.X.MessageStringOf(x)
84 -}
85 -
86 -func (*Identity) ProtoMessage() {}
87 -
88 -func (x *Identity) ProtoReflect() protoreflect.Message {
89 - mi := &file_portal_core_proto_rdsec_rdsec_proto_msgTypes[0]
90 - if x != nil {
91 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
92 - if ms.LoadMessageInfo() == nil {
93 - ms.StoreMessageInfo(mi)
94 - }
95 - return ms
96 - }
97 - return mi.MessageOf(x)
98 -}
99 -
100 -// Deprecated: Use Identity.ProtoReflect.Descriptor instead.
101 -func (*Identity) Descriptor() ([]byte, []int) {
102 - return file_portal_core_proto_rdsec_rdsec_proto_rawDescGZIP(), []int{0}
103 -}
50 +func (x *Identity) ProtoMessage() {} // Stub for vtproto compatibility
51
52 func (x *Identity) GetId() string {
53 if x != nil {
@@ -117,46 +64,20 @@ func (x *Identity) GetPublicKey() []byte {
64 }
65
66 type ClientInitPayload struct {
120 - state protoimpl.MessageState `protogen:"open.v1"`
121 - Version ProtocolVersion `protobuf:"varint,1,opt,name=version,proto3,enum=rdsec.ProtocolVersion" json:"version,omitempty"`
122 - Nonce []byte `protobuf:"bytes,2,opt,name=nonce,proto3" json:"nonce,omitempty"`
123 - Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
124 - Identity *Identity `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
125 - Alpn string `protobuf:"bytes,5,opt,name=alpn,proto3" json:"alpn,omitempty"`
126 - SessionPublicKey []byte `protobuf:"bytes,6,opt,name=session_public_key,json=sessionPublicKey,proto3" json:"session_public_key,omitempty"`
127 - unknownFields protoimpl.UnknownFields
128 - sizeCache protoimpl.SizeCache
67 + Version ProtocolVersion `protobuf:"varint,1,opt,name=version,proto3,enum=rdsec.ProtocolVersion" json:"version,omitempty"`
68 + Nonce []byte `protobuf:"bytes,2,opt,name=nonce,proto3" json:"nonce,omitempty"`
69 + Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
70 + Identity *Identity `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
71 + Alpn string `protobuf:"bytes,5,opt,name=alpn,proto3" json:"alpn,omitempty"`
72 + SessionPublicKey []byte `protobuf:"bytes,6,opt,name=session_public_key,json=sessionPublicKey,proto3" json:"session_public_key,omitempty"`
73 + unknownFields []byte
74 }
75
76 func (x *ClientInitPayload) Reset() {
77 *x = ClientInitPayload{}
133 - mi := &file_portal_core_proto_rdsec_rdsec_proto_msgTypes[1]
134 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
135 - ms.StoreMessageInfo(mi)
136 -}
137 -
138 -func (x *ClientInitPayload) String() string {
139 - return protoimpl.X.MessageStringOf(x)
140 -}
141 -
142 -func (*ClientInitPayload) ProtoMessage() {}
143 -
144 -func (x *ClientInitPayload) ProtoReflect() protoreflect.Message {
145 - mi := &file_portal_core_proto_rdsec_rdsec_proto_msgTypes[1]
146 - if x != nil {
147 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
148 - if ms.LoadMessageInfo() == nil {
149 - ms.StoreMessageInfo(mi)
150 - }
151 - return ms
152 - }
153 - return mi.MessageOf(x)
78 }
79
156 -// Deprecated: Use ClientInitPayload.ProtoReflect.Descriptor instead.
157 -func (*ClientInitPayload) Descriptor() ([]byte, []int) {
158 - return file_portal_core_proto_rdsec_rdsec_proto_rawDescGZIP(), []int{1}
159 -}
80 +func (x *ClientInitPayload) ProtoMessage() {} // Stub for vtproto compatibility
81
82 func (x *ClientInitPayload) GetVersion() ProtocolVersion {
83 if x != nil {
@@ -201,42 +122,16 @@ func (x *ClientInitPayload) GetSessionPublicKey() []byte {
122 }
123
124 type SignedPayload struct {
204 - state protoimpl.MessageState `protogen:"open.v1"`
205 - Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
206 - Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
207 - unknownFields protoimpl.UnknownFields
208 - sizeCache protoimpl.SizeCache
125 + Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
126 + Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
127 + unknownFields []byte
128 }
129
130 func (x *SignedPayload) Reset() {
131 *x = SignedPayload{}
213 - mi := &file_portal_core_proto_rdsec_rdsec_proto_msgTypes[2]
214 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
215 - ms.StoreMessageInfo(mi)
216 -}
217 -
218 -func (x *SignedPayload) String() string {
219 - return protoimpl.X.MessageStringOf(x)
132 }
133
222 -func (*SignedPayload) ProtoMessage() {}
223 -
224 -func (x *SignedPayload) ProtoReflect() protoreflect.Message {
225 - mi := &file_portal_core_proto_rdsec_rdsec_proto_msgTypes[2]
226 - if x != nil {
227 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
228 - if ms.LoadMessageInfo() == nil {
229 - ms.StoreMessageInfo(mi)
230 - }
231 - return ms
232 - }
233 - return mi.MessageOf(x)
234 -}
235 -
236 -// Deprecated: Use SignedPayload.ProtoReflect.Descriptor instead.
237 -func (*SignedPayload) Descriptor() ([]byte, []int) {
238 - return file_portal_core_proto_rdsec_rdsec_proto_rawDescGZIP(), []int{2}
239 -}
134 +func (x *SignedPayload) ProtoMessage() {} // Stub for vtproto compatibility
135
136 func (x *SignedPayload) GetData() []byte {
137 if x != nil {
@@ -253,46 +148,20 @@ func (x *SignedPayload) GetSignature() []byte {
148 }
149
150 type ServerInitPayload struct {
256 - state protoimpl.MessageState `protogen:"open.v1"`
257 - Version ProtocolVersion `protobuf:"varint,1,opt,name=version,proto3,enum=rdsec.ProtocolVersion" json:"version,omitempty"`
258 - Nonce []byte `protobuf:"bytes,2,opt,name=nonce,proto3" json:"nonce,omitempty"`
259 - Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
260 - Identity *Identity `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
261 - Alpn string `protobuf:"bytes,5,opt,name=alpn,proto3" json:"alpn,omitempty"`
262 - SessionPublicKey []byte `protobuf:"bytes,6,opt,name=session_public_key,json=sessionPublicKey,proto3" json:"session_public_key,omitempty"`
263 - unknownFields protoimpl.UnknownFields
264 - sizeCache protoimpl.SizeCache
151 + Version ProtocolVersion `protobuf:"varint,1,opt,name=version,proto3,enum=rdsec.ProtocolVersion" json:"version,omitempty"`
152 + Nonce []byte `protobuf:"bytes,2,opt,name=nonce,proto3" json:"nonce,omitempty"`
153 + Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
154 + Identity *Identity `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
155 + Alpn string `protobuf:"bytes,5,opt,name=alpn,proto3" json:"alpn,omitempty"`
156 + SessionPublicKey []byte `protobuf:"bytes,6,opt,name=session_public_key,json=sessionPublicKey,proto3" json:"session_public_key,omitempty"`
157 + unknownFields []byte
158 }
159
160 func (x *ServerInitPayload) Reset() {
161 *x = ServerInitPayload{}
269 - mi := &file_portal_core_proto_rdsec_rdsec_proto_msgTypes[3]
270 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
271 - ms.StoreMessageInfo(mi)
272 -}
273 -
274 -func (x *ServerInitPayload) String() string {
275 - return protoimpl.X.MessageStringOf(x)
162 }
163
278 -func (*ServerInitPayload) ProtoMessage() {}
279 -
280 -func (x *ServerInitPayload) ProtoReflect() protoreflect.Message {
281 - mi := &file_portal_core_proto_rdsec_rdsec_proto_msgTypes[3]
282 - if x != nil {
283 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
284 - if ms.LoadMessageInfo() == nil {
285 - ms.StoreMessageInfo(mi)
286 - }
287 - return ms
288 - }
289 - return mi.MessageOf(x)
290 -}
291 -
292 -// Deprecated: Use ServerInitPayload.ProtoReflect.Descriptor instead.
293 -func (*ServerInitPayload) Descriptor() ([]byte, []int) {
294 - return file_portal_core_proto_rdsec_rdsec_proto_rawDescGZIP(), []int{3}
295 -}
164 +func (x *ServerInitPayload) ProtoMessage() {} // Stub for vtproto compatibility
165
166 func (x *ServerInitPayload) GetVersion() ProtocolVersion {
167 if x != nil {
@@ -335,90 +204,3 @@ func (x *ServerInitPayload) GetSessionPublicKey() []byte {
204 }
205 return nil
206 }
338 -
339 -var File_portal_core_proto_rdsec_rdsec_proto protoreflect.FileDescriptor
340 -
341 -const file_portal_core_proto_rdsec_rdsec_proto_rawDesc = "" +
342 - "\n" +
343 - "#portal/core/proto/rdsec/rdsec.proto\x12\x05rdsec\"9\n" +
344 - "\bIdentity\x12\x0e\n" +
345 - "\x02id\x18\x01 \x01(\tR\x02id\x12\x1d\n" +
346 - "\n" +
347 - "public_key\x18\x02 \x01(\fR\tpublicKey\"\xe8\x01\n" +
348 - "\x11ClientInitPayload\x120\n" +
349 - "\aversion\x18\x01 \x01(\x0e2\x16.rdsec.ProtocolVersionR\aversion\x12\x14\n" +
350 - "\x05nonce\x18\x02 \x01(\fR\x05nonce\x12\x1c\n" +
351 - "\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\x12+\n" +
352 - "\bidentity\x18\x04 \x01(\v2\x0f.rdsec.IdentityR\bidentity\x12\x12\n" +
353 - "\x04alpn\x18\x05 \x01(\tR\x04alpn\x12,\n" +
354 - "\x12session_public_key\x18\x06 \x01(\fR\x10sessionPublicKey\"A\n" +
355 - "\rSignedPayload\x12\x12\n" +
356 - "\x04data\x18\x01 \x01(\fR\x04data\x12\x1c\n" +
357 - "\tsignature\x18\x02 \x01(\fR\tsignature\"\xe8\x01\n" +
358 - "\x11ServerInitPayload\x120\n" +
359 - "\aversion\x18\x01 \x01(\x0e2\x16.rdsec.ProtocolVersionR\aversion\x12\x14\n" +
360 - "\x05nonce\x18\x02 \x01(\fR\x05nonce\x12\x1c\n" +
361 - "\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\x12+\n" +
362 - "\bidentity\x18\x04 \x01(\v2\x0f.rdsec.IdentityR\bidentity\x12\x12\n" +
363 - "\x04alpn\x18\x05 \x01(\tR\x04alpn\x12,\n" +
364 - "\x12session_public_key\x18\x06 \x01(\fR\x10sessionPublicKey*)\n" +
365 - "\x0fProtocolVersion\x12\x16\n" +
366 - "\x12PROTOCOL_VERSION_1\x10\x00B1Z/gosuda.org/portal/portal/core/proto/rdsec;rdsecb\x06proto3"
367 -
368 -var (
369 - file_portal_core_proto_rdsec_rdsec_proto_rawDescOnce sync.Once
370 - file_portal_core_proto_rdsec_rdsec_proto_rawDescData []byte
371 -)
372 -
373 -func file_portal_core_proto_rdsec_rdsec_proto_rawDescGZIP() []byte {
374 - file_portal_core_proto_rdsec_rdsec_proto_rawDescOnce.Do(func() {
375 - file_portal_core_proto_rdsec_rdsec_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_portal_core_proto_rdsec_rdsec_proto_rawDesc), len(file_portal_core_proto_rdsec_rdsec_proto_rawDesc)))
376 - })
377 - return file_portal_core_proto_rdsec_rdsec_proto_rawDescData
378 -}
379 -
380 -var file_portal_core_proto_rdsec_rdsec_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
381 -var file_portal_core_proto_rdsec_rdsec_proto_msgTypes = make([]protoimpl.MessageInfo, 4)
382 -var file_portal_core_proto_rdsec_rdsec_proto_goTypes = []any{
383 - (ProtocolVersion)(0), // 0: rdsec.ProtocolVersion
384 - (*Identity)(nil), // 1: rdsec.Identity
385 - (*ClientInitPayload)(nil), // 2: rdsec.ClientInitPayload
386 - (*SignedPayload)(nil), // 3: rdsec.SignedPayload
387 - (*ServerInitPayload)(nil), // 4: rdsec.ServerInitPayload
388 -}
389 -var file_portal_core_proto_rdsec_rdsec_proto_depIdxs = []int32{
390 - 0, // 0: rdsec.ClientInitPayload.version:type_name -> rdsec.ProtocolVersion
391 - 1, // 1: rdsec.ClientInitPayload.identity:type_name -> rdsec.Identity
392 - 0, // 2: rdsec.ServerInitPayload.version:type_name -> rdsec.ProtocolVersion
393 - 1, // 3: rdsec.ServerInitPayload.identity:type_name -> rdsec.Identity
394 - 4, // [4:4] is the sub-list for method output_type
395 - 4, // [4:4] is the sub-list for method input_type
396 - 4, // [4:4] is the sub-list for extension type_name
397 - 4, // [4:4] is the sub-list for extension extendee
398 - 0, // [0:4] is the sub-list for field type_name
399 -}
400 -
401 -func init() { file_portal_core_proto_rdsec_rdsec_proto_init() }
402 -func file_portal_core_proto_rdsec_rdsec_proto_init() {
403 - if File_portal_core_proto_rdsec_rdsec_proto != nil {
404 - return
405 - }
406 - type x struct{}
407 - out := protoimpl.TypeBuilder{
408 - File: protoimpl.DescBuilder{
409 - GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
410 - RawDescriptor: unsafe.Slice(unsafe.StringData(file_portal_core_proto_rdsec_rdsec_proto_rawDesc), len(file_portal_core_proto_rdsec_rdsec_proto_rawDesc)),
411 - NumEnums: 1,
412 - NumMessages: 4,
413 - NumExtensions: 0,
414 - NumServices: 0,
415 - },
416 - GoTypes: file_portal_core_proto_rdsec_rdsec_proto_goTypes,
417 - DependencyIndexes: file_portal_core_proto_rdsec_rdsec_proto_depIdxs,
418 - EnumInfos: file_portal_core_proto_rdsec_rdsec_proto_enumTypes,
419 - MessageInfos: file_portal_core_proto_rdsec_rdsec_proto_msgTypes,
420 - }.Build()
421 - File_portal_core_proto_rdsec_rdsec_proto = out.File
422 - file_portal_core_proto_rdsec_rdsec_proto_goTypes = nil
423 - file_portal_core_proto_rdsec_rdsec_proto_depIdxs = nil
424 -}
portal/core/proto/rdsec/rdsec_vtproto.pb.go
+8 -9
@@ -7,7 +7,6 @@ package rdsec
7 import (
8 fmt "fmt"
9 protohelpers "github.com/planetscale/vtprotobuf/protohelpers"
10 - proto "google.golang.org/protobuf/proto"
10 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
11 io "io"
12 unsafe "unsafe"
@@ -38,7 +37,7 @@ func (m *Identity) CloneVT() *Identity {
37 return r
38 }
39
41 -func (m *Identity) CloneMessageVT() proto.Message {
40 +func (m *Identity) CloneMessageVT() any {
41 return m.CloneVT()
42 }
43
@@ -68,7 +67,7 @@ func (m *ClientInitPayload) CloneVT() *ClientInitPayload {
67 return r
68 }
69
71 -func (m *ClientInitPayload) CloneMessageVT() proto.Message {
70 +func (m *ClientInitPayload) CloneMessageVT() any {
71 return m.CloneVT()
72 }
73
@@ -94,7 +93,7 @@ func (m *SignedPayload) CloneVT() *SignedPayload {
93 return r
94 }
95
97 -func (m *SignedPayload) CloneMessageVT() proto.Message {
96 +func (m *SignedPayload) CloneMessageVT() any {
97 return m.CloneVT()
98 }
99
@@ -124,7 +123,7 @@ func (m *ServerInitPayload) CloneVT() *ServerInitPayload {
123 return r
124 }
125
127 -func (m *ServerInitPayload) CloneMessageVT() proto.Message {
126 +func (m *ServerInitPayload) CloneMessageVT() any {
127 return m.CloneVT()
128 }
129
@@ -143,7 +142,7 @@ func (this *Identity) EqualVT(that *Identity) bool {
142 return string(this.unknownFields) == string(that.unknownFields)
143 }
144
146 -func (this *Identity) EqualMessageVT(thatMsg proto.Message) bool {
145 +func (this *Identity) EqualMessageVT(thatMsg any) bool {
146 that, ok := thatMsg.(*Identity)
147 if !ok {
148 return false
@@ -177,7 +176,7 @@ func (this *ClientInitPayload) EqualVT(that *ClientInitPayload) bool {
176 return string(this.unknownFields) == string(that.unknownFields)
177 }
178
180 -func (this *ClientInitPayload) EqualMessageVT(thatMsg proto.Message) bool {
179 +func (this *ClientInitPayload) EqualMessageVT(thatMsg any) bool {
180 that, ok := thatMsg.(*ClientInitPayload)
181 if !ok {
182 return false
@@ -199,7 +198,7 @@ func (this *SignedPayload) EqualVT(that *SignedPayload) bool {
198 return string(this.unknownFields) == string(that.unknownFields)
199 }
200
202 -func (this *SignedPayload) EqualMessageVT(thatMsg proto.Message) bool {
201 +func (this *SignedPayload) EqualMessageVT(thatMsg any) bool {
202 that, ok := thatMsg.(*SignedPayload)
203 if !ok {
204 return false
@@ -233,7 +232,7 @@ func (this *ServerInitPayload) EqualVT(that *ServerInitPayload) bool {
232 return string(this.unknownFields) == string(that.unknownFields)
233 }
234
236 -func (this *ServerInitPayload) EqualMessageVT(thatMsg proto.Message) bool {
235 +func (this *ServerInitPayload) EqualMessageVT(thatMsg any) bool {
236 that, ok := thatMsg.(*ServerInitPayload)
237 if !ok {
238 return false
portal/core/proto/rdverb/rdverb.pb.go
+59 -514
@@ -1,25 +1,14 @@
1 // Code generated by protoc-gen-go. DO NOT EDIT.
2 // versions:
3 -// protoc-gen-go v1.36.10
4 -// protoc v6.33.0
3 +// protoc-gen-go v1.36.11
4 +// protoc v3.21.12
5 // source: portal/core/proto/rdverb/rdverb.proto
6 +// Reflection-free version for TinyGo compatibility
7
8 package rdverb
9
10 import (
10 - protoreflect "google.golang.org/protobuf/reflect/protoreflect"
11 - protoimpl "google.golang.org/protobuf/runtime/protoimpl"
11 rdsec "gosuda.org/portal/portal/core/proto/rdsec"
13 - reflect "reflect"
14 - sync "sync"
15 - unsafe "unsafe"
16 -)
17 -
18 -const (
19 - // Verify that this generated code is sufficiently up-to-date.
20 - _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
21 - // Verify that runtime/protoimpl is sufficiently up-to-date.
22 - _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
12 )
13
14 type PacketType int32
@@ -27,9 +16,9 @@ type PacketType int32
16 const (
17 PacketType_PACKET_TYPE_RELAY_INFO_REQUEST PacketType = 0
18 PacketType_PACKET_TYPE_RELAY_INFO_RESPONSE PacketType = 1
30 - PacketType_PACKET_TYPE_LEASE_UPDATE_REQUEST PacketType = 2 // Authenticated
19 + PacketType_PACKET_TYPE_LEASE_UPDATE_REQUEST PacketType = 2
20 PacketType_PACKET_TYPE_LEASE_UPDATE_RESPONSE PacketType = 3
32 - PacketType_PACKET_TYPE_LEASE_DELETE_REQUEST PacketType = 4 // Authenticated
21 + PacketType_PACKET_TYPE_LEASE_DELETE_REQUEST PacketType = 4
22 PacketType_PACKET_TYPE_LEASE_DELETE_RESPONSE PacketType = 5
23 PacketType_PACKET_TYPE_CONNECTION_REQUEST PacketType = 6
24 PacketType_PACKET_TYPE_CONNECTION_RESPONSE PacketType = 7
@@ -66,24 +55,11 @@ func (x PacketType) Enum() *PacketType {
55 }
56
57 func (x PacketType) String() string {
69 - return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
70 -}
71 -
72 -func (PacketType) Descriptor() protoreflect.EnumDescriptor {
73 - return file_portal_core_proto_rdverb_rdverb_proto_enumTypes[0].Descriptor()
74 -}
75 -
76 -func (PacketType) Type() protoreflect.EnumType {
77 - return &file_portal_core_proto_rdverb_rdverb_proto_enumTypes[0]
78 -}
79 -
80 -func (x PacketType) Number() protoreflect.EnumNumber {
81 - return protoreflect.EnumNumber(x)
82 -}
83 -
84 -// Deprecated: Use PacketType.Descriptor instead.
85 -func (PacketType) EnumDescriptor() ([]byte, []int) {
86 - return file_portal_core_proto_rdverb_rdverb_proto_rawDescGZIP(), []int{0}
58 + s, ok := PacketType_name[int32(x)]
59 + if !ok {
60 + return "PacketType(" + string(rune('0'+x)) + ")"
61 + }
62 + return s
63 }
64
65 type ResponseCode int32
@@ -127,63 +103,24 @@ func (x ResponseCode) Enum() *ResponseCode {
103 }
104
105 func (x ResponseCode) String() string {
130 - return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
131 -}
132 -
133 -func (ResponseCode) Descriptor() protoreflect.EnumDescriptor {
134 - return file_portal_core_proto_rdverb_rdverb_proto_enumTypes[1].Descriptor()
135 -}
136 -
137 -func (ResponseCode) Type() protoreflect.EnumType {
138 - return &file_portal_core_proto_rdverb_rdverb_proto_enumTypes[1]
139 -}
140 -
141 -func (x ResponseCode) Number() protoreflect.EnumNumber {
142 - return protoreflect.EnumNumber(x)
143 -}
144 -
145 -// Deprecated: Use ResponseCode.Descriptor instead.
146 -func (ResponseCode) EnumDescriptor() ([]byte, []int) {
147 - return file_portal_core_proto_rdverb_rdverb_proto_rawDescGZIP(), []int{1}
106 + s, ok := ResponseCode_name[int32(x)]
107 + if !ok {
108 + return "ResponseCode(" + string(rune('0'+x)) + ")"
109 + }
110 + return s
111 }
112
113 type Packet struct {
151 - state protoimpl.MessageState `protogen:"open.v1"`
152 - Type PacketType `protobuf:"varint,1,opt,name=type,proto3,enum=rdverb.PacketType" json:"type,omitempty"`
153 - Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
154 - unknownFields protoimpl.UnknownFields
155 - sizeCache protoimpl.SizeCache
114 + Type PacketType `protobuf:"varint,1,opt,name=type,proto3,enum=rdverb.PacketType" json:"type,omitempty"`
115 + Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
116 + unknownFields []byte
117 }
118
119 func (x *Packet) Reset() {
120 *x = Packet{}
160 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[0]
161 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
162 - ms.StoreMessageInfo(mi)
163 -}
164 -
165 -func (x *Packet) String() string {
166 - return protoimpl.X.MessageStringOf(x)
121 }
122
169 -func (*Packet) ProtoMessage() {}
170 -
171 -func (x *Packet) ProtoReflect() protoreflect.Message {
172 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[0]
173 - if x != nil {
174 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
175 - if ms.LoadMessageInfo() == nil {
176 - ms.StoreMessageInfo(mi)
177 - }
178 - return ms
179 - }
180 - return mi.MessageOf(x)
181 -}
182 -
183 -// Deprecated: Use Packet.ProtoReflect.Descriptor instead.
184 -func (*Packet) Descriptor() ([]byte, []int) {
185 - return file_portal_core_proto_rdverb_rdverb_proto_rawDescGZIP(), []int{0}
186 -}
123 +func (x *Packet) ProtoMessage() {} // Stub for vtproto compatibility
124
125 func (x *Packet) GetType() PacketType {
126 if x != nil {
@@ -200,43 +137,17 @@ func (x *Packet) GetPayload() []byte {
137 }
138
139 type RelayInfo struct {
203 - state protoimpl.MessageState `protogen:"open.v1"`
204 - Identity *rdsec.Identity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
205 - Address []string `protobuf:"bytes,2,rep,name=address,proto3" json:"address,omitempty"`
206 - Leases []*Lease `protobuf:"bytes,3,rep,name=leases,proto3" json:"leases,omitempty"`
207 - unknownFields protoimpl.UnknownFields
208 - sizeCache protoimpl.SizeCache
140 + Identity *rdsec.Identity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
141 + Address []string `protobuf:"bytes,2,rep,name=address,proto3" json:"address,omitempty"`
142 + Leases []*Lease `protobuf:"bytes,3,rep,name=leases,proto3" json:"leases,omitempty"`
143 + unknownFields []byte
144 }
145
146 func (x *RelayInfo) Reset() {
147 *x = RelayInfo{}
213 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[1]
214 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
215 - ms.StoreMessageInfo(mi)
148 }
149
218 -func (x *RelayInfo) String() string {
219 - return protoimpl.X.MessageStringOf(x)
220 -}
221 -
222 -func (*RelayInfo) ProtoMessage() {}
223 -
224 -func (x *RelayInfo) ProtoReflect() protoreflect.Message {
225 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[1]
226 - if x != nil {
227 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
228 - if ms.LoadMessageInfo() == nil {
229 - ms.StoreMessageInfo(mi)
230 - }
231 - return ms
232 - }
233 - return mi.MessageOf(x)
234 -}
235 -
236 -// Deprecated: Use RelayInfo.ProtoReflect.Descriptor instead.
237 -func (*RelayInfo) Descriptor() ([]byte, []int) {
238 - return file_portal_core_proto_rdverb_rdverb_proto_rawDescGZIP(), []int{1}
239 -}
150 +func (x *RelayInfo) ProtoMessage() {} // Stub for vtproto compatibility
151
152 func (x *RelayInfo) GetIdentity() *rdsec.Identity {
153 if x != nil {
@@ -260,77 +171,25 @@ func (x *RelayInfo) GetLeases() []*Lease {
171 }
172
173 type RelayInfoRequest struct {
263 - state protoimpl.MessageState `protogen:"open.v1"`
264 - unknownFields protoimpl.UnknownFields
265 - sizeCache protoimpl.SizeCache
174 + unknownFields []byte
175 }
176
177 func (x *RelayInfoRequest) Reset() {
178 *x = RelayInfoRequest{}
270 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[2]
271 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
272 - ms.StoreMessageInfo(mi)
179 }
180
275 -func (x *RelayInfoRequest) String() string {
276 - return protoimpl.X.MessageStringOf(x)
277 -}
278 -
279 -func (*RelayInfoRequest) ProtoMessage() {}
280 -
281 -func (x *RelayInfoRequest) ProtoReflect() protoreflect.Message {
282 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[2]
283 - if x != nil {
284 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
285 - if ms.LoadMessageInfo() == nil {
286 - ms.StoreMessageInfo(mi)
287 - }
288 - return ms
289 - }
290 - return mi.MessageOf(x)
291 -}
292 -
293 -// Deprecated: Use RelayInfoRequest.ProtoReflect.Descriptor instead.
294 -func (*RelayInfoRequest) Descriptor() ([]byte, []int) {
295 - return file_portal_core_proto_rdverb_rdverb_proto_rawDescGZIP(), []int{2}
296 -}
181 +func (x *RelayInfoRequest) ProtoMessage() {} // Stub for vtproto compatibility
182
183 type RelayInfoResponse struct {
299 - state protoimpl.MessageState `protogen:"open.v1"`
300 - RelayInfo *RelayInfo `protobuf:"bytes,1,opt,name=relay_info,json=relayInfo,proto3" json:"relay_info,omitempty"`
301 - unknownFields protoimpl.UnknownFields
302 - sizeCache protoimpl.SizeCache
184 + RelayInfo *RelayInfo `protobuf:"bytes,1,opt,name=relay_info,json=relayInfo,proto3" json:"relay_info,omitempty"`
185 + unknownFields []byte
186 }
187
188 func (x *RelayInfoResponse) Reset() {
189 *x = RelayInfoResponse{}
307 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[3]
308 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
309 - ms.StoreMessageInfo(mi)
310 -}
311 -
312 -func (x *RelayInfoResponse) String() string {
313 - return protoimpl.X.MessageStringOf(x)
314 -}
315 -
316 -func (*RelayInfoResponse) ProtoMessage() {}
317 -
318 -func (x *RelayInfoResponse) ProtoReflect() protoreflect.Message {
319 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[3]
320 - if x != nil {
321 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
322 - if ms.LoadMessageInfo() == nil {
323 - ms.StoreMessageInfo(mi)
324 - }
325 - return ms
326 - }
327 - return mi.MessageOf(x)
190 }
191
330 -// Deprecated: Use RelayInfoResponse.ProtoReflect.Descriptor instead.
331 -func (*RelayInfoResponse) Descriptor() ([]byte, []int) {
332 - return file_portal_core_proto_rdverb_rdverb_proto_rawDescGZIP(), []int{3}
333 -}
192 +func (x *RelayInfoResponse) ProtoMessage() {} // Stub for vtproto compatibility
193
194 func (x *RelayInfoResponse) GetRelayInfo() *RelayInfo {
195 if x != nil {
@@ -340,45 +199,19 @@ func (x *RelayInfoResponse) GetRelayInfo() *RelayInfo {
199 }
200
201 type Lease struct {
343 - state protoimpl.MessageState `protogen:"open.v1"`
344 - Identity *rdsec.Identity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
345 - Expires int64 `protobuf:"varint,2,opt,name=expires,proto3" json:"expires,omitempty"`
346 - Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
347 - Alpn []string `protobuf:"bytes,4,rep,name=alpn,proto3" json:"alpn,omitempty"`
348 - Metadata string `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
349 - unknownFields protoimpl.UnknownFields
350 - sizeCache protoimpl.SizeCache
202 + Identity *rdsec.Identity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
203 + Expires int64 `protobuf:"varint,2,opt,name=expires,proto3" json:"expires,omitempty"`
204 + Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
205 + Alpn []string `protobuf:"bytes,4,rep,name=alpn,proto3" json:"alpn,omitempty"`
206 + Metadata string `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
207 + unknownFields []byte
208 }
209
210 func (x *Lease) Reset() {
211 *x = Lease{}
355 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[4]
356 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
357 - ms.StoreMessageInfo(mi)
358 -}
359 -
360 -func (x *Lease) String() string {
361 - return protoimpl.X.MessageStringOf(x)
362 -}
363 -
364 -func (*Lease) ProtoMessage() {}
365 -
366 -func (x *Lease) ProtoReflect() protoreflect.Message {
367 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[4]
368 - if x != nil {
369 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
370 - if ms.LoadMessageInfo() == nil {
371 - ms.StoreMessageInfo(mi)
372 - }
373 - return ms
374 - }
375 - return mi.MessageOf(x)
212 }
213
378 -// Deprecated: Use Lease.ProtoReflect.Descriptor instead.
379 -func (*Lease) Descriptor() ([]byte, []int) {
380 - return file_portal_core_proto_rdverb_rdverb_proto_rawDescGZIP(), []int{4}
381 -}
214 +func (x *Lease) ProtoMessage() {} // Stub for vtproto compatibility
215
216 func (x *Lease) GetIdentity() *rdsec.Identity {
217 if x != nil {
@@ -416,43 +249,17 @@ func (x *Lease) GetMetadata() string {
249 }
250
251 type LeaseUpdateRequest struct {
419 - state protoimpl.MessageState `protogen:"open.v1"`
420 - Lease *Lease `protobuf:"bytes,1,opt,name=lease,proto3" json:"lease,omitempty"`
421 - Nonce []byte `protobuf:"bytes,2,opt,name=nonce,proto3" json:"nonce,omitempty"`
422 - Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
423 - unknownFields protoimpl.UnknownFields
424 - sizeCache protoimpl.SizeCache
252 + Lease *Lease `protobuf:"bytes,1,opt,name=lease,proto3" json:"lease,omitempty"`
253 + Nonce []byte `protobuf:"bytes,2,opt,name=nonce,proto3" json:"nonce,omitempty"`
254 + Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
255 + unknownFields []byte
256 }
257
258 func (x *LeaseUpdateRequest) Reset() {
259 *x = LeaseUpdateRequest{}
429 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[5]
430 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
431 - ms.StoreMessageInfo(mi)
432 -}
433 -
434 -func (x *LeaseUpdateRequest) String() string {
435 - return protoimpl.X.MessageStringOf(x)
260 }
261
438 -func (*LeaseUpdateRequest) ProtoMessage() {}
439 -
440 -func (x *LeaseUpdateRequest) ProtoReflect() protoreflect.Message {
441 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[5]
442 - if x != nil {
443 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
444 - if ms.LoadMessageInfo() == nil {
445 - ms.StoreMessageInfo(mi)
446 - }
447 - return ms
448 - }
449 - return mi.MessageOf(x)
450 -}
451 -
452 -// Deprecated: Use LeaseUpdateRequest.ProtoReflect.Descriptor instead.
453 -func (*LeaseUpdateRequest) Descriptor() ([]byte, []int) {
454 - return file_portal_core_proto_rdverb_rdverb_proto_rawDescGZIP(), []int{5}
455 -}
262 +func (x *LeaseUpdateRequest) ProtoMessage() {} // Stub for vtproto compatibility
263
264 func (x *LeaseUpdateRequest) GetLease() *Lease {
265 if x != nil {
@@ -476,41 +283,15 @@ func (x *LeaseUpdateRequest) GetTimestamp() int64 {
283 }
284
285 type LeaseUpdateResponse struct {
479 - state protoimpl.MessageState `protogen:"open.v1"`
480 - Code ResponseCode `protobuf:"varint,1,opt,name=code,proto3,enum=rdverb.ResponseCode" json:"code,omitempty"`
481 - unknownFields protoimpl.UnknownFields
482 - sizeCache protoimpl.SizeCache
286 + Code ResponseCode `protobuf:"varint,1,opt,name=code,proto3,enum=rdverb.ResponseCode" json:"code,omitempty"`
287 + unknownFields []byte
288 }
289
290 func (x *LeaseUpdateResponse) Reset() {
291 *x = LeaseUpdateResponse{}
487 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[6]
488 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
489 - ms.StoreMessageInfo(mi)
292 }
293
492 -func (x *LeaseUpdateResponse) String() string {
493 - return protoimpl.X.MessageStringOf(x)
494 -}
495 -
496 -func (*LeaseUpdateResponse) ProtoMessage() {}
497 -
498 -func (x *LeaseUpdateResponse) ProtoReflect() protoreflect.Message {
499 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[6]
500 - if x != nil {
501 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
502 - if ms.LoadMessageInfo() == nil {
503 - ms.StoreMessageInfo(mi)
504 - }
505 - return ms
506 - }
507 - return mi.MessageOf(x)
508 -}
509 -
510 -// Deprecated: Use LeaseUpdateResponse.ProtoReflect.Descriptor instead.
511 -func (*LeaseUpdateResponse) Descriptor() ([]byte, []int) {
512 - return file_portal_core_proto_rdverb_rdverb_proto_rawDescGZIP(), []int{6}
513 -}
294 +func (x *LeaseUpdateResponse) ProtoMessage() {} // Stub for vtproto compatibility
295
296 func (x *LeaseUpdateResponse) GetCode() ResponseCode {
297 if x != nil {
@@ -520,43 +301,17 @@ func (x *LeaseUpdateResponse) GetCode() ResponseCode {
301 }
302
303 type LeaseDeleteRequest struct {
523 - state protoimpl.MessageState `protogen:"open.v1"`
524 - Identity *rdsec.Identity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
525 - Nonce []byte `protobuf:"bytes,2,opt,name=nonce,proto3" json:"nonce,omitempty"`
526 - Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
527 - unknownFields protoimpl.UnknownFields
528 - sizeCache protoimpl.SizeCache
304 + Identity *rdsec.Identity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
305 + Nonce []byte `protobuf:"bytes,2,opt,name=nonce,proto3" json:"nonce,omitempty"`
306 + Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
307 + unknownFields []byte
308 }
309
310 func (x *LeaseDeleteRequest) Reset() {
311 *x = LeaseDeleteRequest{}
533 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[7]
534 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
535 - ms.StoreMessageInfo(mi)
536 -}
537 -
538 -func (x *LeaseDeleteRequest) String() string {
539 - return protoimpl.X.MessageStringOf(x)
540 -}
541 -
542 -func (*LeaseDeleteRequest) ProtoMessage() {}
543 -
544 -func (x *LeaseDeleteRequest) ProtoReflect() protoreflect.Message {
545 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[7]
546 - if x != nil {
547 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
548 - if ms.LoadMessageInfo() == nil {
549 - ms.StoreMessageInfo(mi)
550 - }
551 - return ms
552 - }
553 - return mi.MessageOf(x)
312 }
313
556 -// Deprecated: Use LeaseDeleteRequest.ProtoReflect.Descriptor instead.
557 -func (*LeaseDeleteRequest) Descriptor() ([]byte, []int) {
558 - return file_portal_core_proto_rdverb_rdverb_proto_rawDescGZIP(), []int{7}
559 -}
314 +func (x *LeaseDeleteRequest) ProtoMessage() {} // Stub for vtproto compatibility
315
316 func (x *LeaseDeleteRequest) GetIdentity() *rdsec.Identity {
317 if x != nil {
@@ -580,41 +335,15 @@ func (x *LeaseDeleteRequest) GetTimestamp() int64 {
335 }
336
337 type LeaseDeleteResponse struct {
583 - state protoimpl.MessageState `protogen:"open.v1"`
584 - Code ResponseCode `protobuf:"varint,1,opt,name=code,proto3,enum=rdverb.ResponseCode" json:"code,omitempty"`
585 - unknownFields protoimpl.UnknownFields
586 - sizeCache protoimpl.SizeCache
338 + Code ResponseCode `protobuf:"varint,1,opt,name=code,proto3,enum=rdverb.ResponseCode" json:"code,omitempty"`
339 + unknownFields []byte
340 }
341
342 func (x *LeaseDeleteResponse) Reset() {
343 *x = LeaseDeleteResponse{}
591 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[8]
592 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
593 - ms.StoreMessageInfo(mi)
594 -}
595 -
596 -func (x *LeaseDeleteResponse) String() string {
597 - return protoimpl.X.MessageStringOf(x)
344 }
345
600 -func (*LeaseDeleteResponse) ProtoMessage() {}
601 -
602 -func (x *LeaseDeleteResponse) ProtoReflect() protoreflect.Message {
603 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[8]
604 - if x != nil {
605 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
606 - if ms.LoadMessageInfo() == nil {
607 - ms.StoreMessageInfo(mi)
608 - }
609 - return ms
610 - }
611 - return mi.MessageOf(x)
612 -}
613 -
614 -// Deprecated: Use LeaseDeleteResponse.ProtoReflect.Descriptor instead.
615 -func (*LeaseDeleteResponse) Descriptor() ([]byte, []int) {
616 - return file_portal_core_proto_rdverb_rdverb_proto_rawDescGZIP(), []int{8}
617 -}
346 +func (x *LeaseDeleteResponse) ProtoMessage() {} // Stub for vtproto compatibility
347
348 func (x *LeaseDeleteResponse) GetCode() ResponseCode {
349 if x != nil {
@@ -624,42 +353,16 @@ func (x *LeaseDeleteResponse) GetCode() ResponseCode {
353 }
354
355 type ConnectionRequest struct {
627 - state protoimpl.MessageState `protogen:"open.v1"`
628 - LeaseId string `protobuf:"bytes,1,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
629 - ClientIdentity *rdsec.Identity `protobuf:"bytes,2,opt,name=client_identity,json=clientIdentity,proto3" json:"client_identity,omitempty"`
630 - unknownFields protoimpl.UnknownFields
631 - sizeCache protoimpl.SizeCache
356 + LeaseId string `protobuf:"bytes,1,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
357 + ClientIdentity *rdsec.Identity `protobuf:"bytes,2,opt,name=client_identity,json=clientIdentity,proto3" json:"client_identity,omitempty"`
358 + unknownFields []byte
359 }
360
361 func (x *ConnectionRequest) Reset() {
362 *x = ConnectionRequest{}
636 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[9]
637 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
638 - ms.StoreMessageInfo(mi)
639 -}
640 -
641 -func (x *ConnectionRequest) String() string {
642 - return protoimpl.X.MessageStringOf(x)
363 }
364
645 -func (*ConnectionRequest) ProtoMessage() {}
646 -
647 -func (x *ConnectionRequest) ProtoReflect() protoreflect.Message {
648 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[9]
649 - if x != nil {
650 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
651 - if ms.LoadMessageInfo() == nil {
652 - ms.StoreMessageInfo(mi)
653 - }
654 - return ms
655 - }
656 - return mi.MessageOf(x)
657 -}
658 -
659 -// Deprecated: Use ConnectionRequest.ProtoReflect.Descriptor instead.
660 -func (*ConnectionRequest) Descriptor() ([]byte, []int) {
661 - return file_portal_core_proto_rdverb_rdverb_proto_rawDescGZIP(), []int{9}
662 -}
365 +func (x *ConnectionRequest) ProtoMessage() {} // Stub for vtproto compatibility
366
367 func (x *ConnectionRequest) GetLeaseId() string {
368 if x != nil {
@@ -676,41 +379,15 @@ func (x *ConnectionRequest) GetClientIdentity() *rdsec.Identity {
379 }
380
381 type ConnectionResponse struct {
679 - state protoimpl.MessageState `protogen:"open.v1"`
680 - Code ResponseCode `protobuf:"varint,1,opt,name=code,proto3,enum=rdverb.ResponseCode" json:"code,omitempty"`
681 - unknownFields protoimpl.UnknownFields
682 - sizeCache protoimpl.SizeCache
382 + Code ResponseCode `protobuf:"varint,1,opt,name=code,proto3,enum=rdverb.ResponseCode" json:"code,omitempty"`
383 + unknownFields []byte
384 }
385
386 func (x *ConnectionResponse) Reset() {
387 *x = ConnectionResponse{}
687 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[10]
688 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
689 - ms.StoreMessageInfo(mi)
388 }
389
692 -func (x *ConnectionResponse) String() string {
693 - return protoimpl.X.MessageStringOf(x)
694 -}
695 -
696 -func (*ConnectionResponse) ProtoMessage() {}
697 -
698 -func (x *ConnectionResponse) ProtoReflect() protoreflect.Message {
699 - mi := &file_portal_core_proto_rdverb_rdverb_proto_msgTypes[10]
700 - if x != nil {
701 - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
702 - if ms.LoadMessageInfo() == nil {
703 - ms.StoreMessageInfo(mi)
704 - }
705 - return ms
706 - }
707 - return mi.MessageOf(x)
708 -}
709 -
710 -// Deprecated: Use ConnectionResponse.ProtoReflect.Descriptor instead.
711 -func (*ConnectionResponse) Descriptor() ([]byte, []int) {
712 - return file_portal_core_proto_rdverb_rdverb_proto_rawDescGZIP(), []int{10}
713 -}
390 +func (x *ConnectionResponse) ProtoMessage() {} // Stub for vtproto compatibility
391
392 func (x *ConnectionResponse) GetCode() ResponseCode {
393 if x != nil {
@@ -718,135 +395,3 @@ func (x *ConnectionResponse) GetCode() ResponseCode {
395 }
396 return ResponseCode_RESPONSE_CODE_UNKNOWN
397 }
721 -
722 -var File_portal_core_proto_rdverb_rdverb_proto protoreflect.FileDescriptor
723 -
724 -const file_portal_core_proto_rdverb_rdverb_proto_rawDesc = "" +
725 - "\n" +
726 - "%portal/core/proto/rdverb/rdverb.proto\x12\x06rdverb\x1a#portal/core/proto/rdsec/rdsec.proto\"J\n" +
727 - "\x06Packet\x12&\n" +
728 - "\x04type\x18\x01 \x01(\x0e2\x12.rdverb.PacketTypeR\x04type\x12\x18\n" +
729 - "\apayload\x18\x02 \x01(\fR\apayload\"y\n" +
730 - "\tRelayInfo\x12+\n" +
731 - "\bidentity\x18\x01 \x01(\v2\x0f.rdsec.IdentityR\bidentity\x12\x18\n" +
732 - "\aaddress\x18\x02 \x03(\tR\aaddress\x12%\n" +
733 - "\x06leases\x18\x03 \x03(\v2\r.rdverb.LeaseR\x06leases\"\x12\n" +
734 - "\x10RelayInfoRequest\"E\n" +
735 - "\x11RelayInfoResponse\x120\n" +
736 - "\n" +
737 - "relay_info\x18\x01 \x01(\v2\x11.rdverb.RelayInfoR\trelayInfo\"\x92\x01\n" +
738 - "\x05Lease\x12+\n" +
739 - "\bidentity\x18\x01 \x01(\v2\x0f.rdsec.IdentityR\bidentity\x12\x18\n" +
740 - "\aexpires\x18\x02 \x01(\x03R\aexpires\x12\x12\n" +
741 - "\x04name\x18\x03 \x01(\tR\x04name\x12\x12\n" +
742 - "\x04alpn\x18\x04 \x03(\tR\x04alpn\x12\x1a\n" +
743 - "\bmetadata\x18\x05 \x01(\tR\bmetadata\"m\n" +
744 - "\x12LeaseUpdateRequest\x12#\n" +
745 - "\x05lease\x18\x01 \x01(\v2\r.rdverb.LeaseR\x05lease\x12\x14\n" +
746 - "\x05nonce\x18\x02 \x01(\fR\x05nonce\x12\x1c\n" +
747 - "\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\"?\n" +
748 - "\x13LeaseUpdateResponse\x12(\n" +
749 - "\x04code\x18\x01 \x01(\x0e2\x14.rdverb.ResponseCodeR\x04code\"u\n" +
750 - "\x12LeaseDeleteRequest\x12+\n" +
751 - "\bidentity\x18\x01 \x01(\v2\x0f.rdsec.IdentityR\bidentity\x12\x14\n" +
752 - "\x05nonce\x18\x02 \x01(\fR\x05nonce\x12\x1c\n" +
753 - "\ttimestamp\x18\x03 \x01(\x03R\ttimestamp\"?\n" +
754 - "\x13LeaseDeleteResponse\x12(\n" +
755 - "\x04code\x18\x01 \x01(\x0e2\x14.rdverb.ResponseCodeR\x04code\"h\n" +
756 - "\x11ConnectionRequest\x12\x19\n" +
757 - "\blease_id\x18\x01 \x01(\tR\aleaseId\x128\n" +
758 - "\x0fclient_identity\x18\x02 \x01(\v2\x0f.rdsec.IdentityR\x0eclientIdentity\">\n" +
759 - "\x12ConnectionResponse\x12(\n" +
760 - "\x04code\x18\x01 \x01(\x0e2\x14.rdverb.ResponseCodeR\x04code*\xb8\x02\n" +
761 - "\n" +
762 - "PacketType\x12\"\n" +
763 - "\x1ePACKET_TYPE_RELAY_INFO_REQUEST\x10\x00\x12#\n" +
764 - "\x1fPACKET_TYPE_RELAY_INFO_RESPONSE\x10\x01\x12$\n" +
765 - " PACKET_TYPE_LEASE_UPDATE_REQUEST\x10\x02\x12%\n" +
766 - "!PACKET_TYPE_LEASE_UPDATE_RESPONSE\x10\x03\x12$\n" +
767 - " PACKET_TYPE_LEASE_DELETE_REQUEST\x10\x04\x12%\n" +
768 - "!PACKET_TYPE_LEASE_DELETE_RESPONSE\x10\x05\x12\"\n" +
769 - "\x1ePACKET_TYPE_CONNECTION_REQUEST\x10\x06\x12#\n" +
770 - "\x1fPACKET_TYPE_CONNECTION_RESPONSE\x10\a*\xe8\x01\n" +
771 - "\fResponseCode\x12\x19\n" +
772 - "\x15RESPONSE_CODE_UNKNOWN\x10\x00\x12\x1a\n" +
773 - "\x16RESPONSE_CODE_ACCEPTED\x10\x01\x12!\n" +
774 - "\x1dRESPONSE_CODE_INVALID_EXPIRES\x10\x02\x12\"\n" +
775 - "\x1eRESPONSE_CODE_INVALID_IDENTITY\x10\x03\x12\x1e\n" +
776 - "\x1aRESPONSE_CODE_INVALID_NAME\x10\x04\x12\x1e\n" +
777 - "\x1aRESPONSE_CODE_INVALID_ALPN\x10\x05\x12\x1a\n" +
778 - "\x16RESPONSE_CODE_REJECTED\x10\x06B3Z1gosuda.org/portal/portal/core/proto/rdverb;rdverbb\x06proto3"
779 -
780 -var (
781 - file_portal_core_proto_rdverb_rdverb_proto_rawDescOnce sync.Once
782 - file_portal_core_proto_rdverb_rdverb_proto_rawDescData []byte
783 -)
784 -
785 -func file_portal_core_proto_rdverb_rdverb_proto_rawDescGZIP() []byte {
786 - file_portal_core_proto_rdverb_rdverb_proto_rawDescOnce.Do(func() {
787 - file_portal_core_proto_rdverb_rdverb_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_portal_core_proto_rdverb_rdverb_proto_rawDesc), len(file_portal_core_proto_rdverb_rdverb_proto_rawDesc)))
788 - })
789 - return file_portal_core_proto_rdverb_rdverb_proto_rawDescData
790 -}
791 -
792 -var file_portal_core_proto_rdverb_rdverb_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
793 -var file_portal_core_proto_rdverb_rdverb_proto_msgTypes = make([]protoimpl.MessageInfo, 11)
794 -var file_portal_core_proto_rdverb_rdverb_proto_goTypes = []any{
795 - (PacketType)(0), // 0: rdverb.PacketType
796 - (ResponseCode)(0), // 1: rdverb.ResponseCode
797 - (*Packet)(nil), // 2: rdverb.Packet
798 - (*RelayInfo)(nil), // 3: rdverb.RelayInfo
799 - (*RelayInfoRequest)(nil), // 4: rdverb.RelayInfoRequest
800 - (*RelayInfoResponse)(nil), // 5: rdverb.RelayInfoResponse
801 - (*Lease)(nil), // 6: rdverb.Lease
802 - (*LeaseUpdateRequest)(nil), // 7: rdverb.LeaseUpdateRequest
803 - (*LeaseUpdateResponse)(nil), // 8: rdverb.LeaseUpdateResponse
804 - (*LeaseDeleteRequest)(nil), // 9: rdverb.LeaseDeleteRequest
805 - (*LeaseDeleteResponse)(nil), // 10: rdverb.LeaseDeleteResponse
806 - (*ConnectionRequest)(nil), // 11: rdverb.ConnectionRequest
807 - (*ConnectionResponse)(nil), // 12: rdverb.ConnectionResponse
808 - (*rdsec.Identity)(nil), // 13: rdsec.Identity
809 -}
810 -var file_portal_core_proto_rdverb_rdverb_proto_depIdxs = []int32{
811 - 0, // 0: rdverb.Packet.type:type_name -> rdverb.PacketType
812 - 13, // 1: rdverb.RelayInfo.identity:type_name -> rdsec.Identity
813 - 6, // 2: rdverb.RelayInfo.leases:type_name -> rdverb.Lease
814 - 3, // 3: rdverb.RelayInfoResponse.relay_info:type_name -> rdverb.RelayInfo
815 - 13, // 4: rdverb.Lease.identity:type_name -> rdsec.Identity
816 - 6, // 5: rdverb.LeaseUpdateRequest.lease:type_name -> rdverb.Lease
817 - 1, // 6: rdverb.LeaseUpdateResponse.code:type_name -> rdverb.ResponseCode
818 - 13, // 7: rdverb.LeaseDeleteRequest.identity:type_name -> rdsec.Identity
819 - 1, // 8: rdverb.LeaseDeleteResponse.code:type_name -> rdverb.ResponseCode
820 - 13, // 9: rdverb.ConnectionRequest.client_identity:type_name -> rdsec.Identity
821 - 1, // 10: rdverb.ConnectionResponse.code:type_name -> rdverb.ResponseCode
822 - 11, // [11:11] is the sub-list for method output_type
823 - 11, // [11:11] is the sub-list for method input_type
824 - 11, // [11:11] is the sub-list for extension type_name
825 - 11, // [11:11] is the sub-list for extension extendee
826 - 0, // [0:11] is the sub-list for field type_name
827 -}
828 -
829 -func init() { file_portal_core_proto_rdverb_rdverb_proto_init() }
830 -func file_portal_core_proto_rdverb_rdverb_proto_init() {
831 - if File_portal_core_proto_rdverb_rdverb_proto != nil {
832 - return
833 - }
834 - type x struct{}
835 - out := protoimpl.TypeBuilder{
836 - File: protoimpl.DescBuilder{
837 - GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
838 - RawDescriptor: unsafe.Slice(unsafe.StringData(file_portal_core_proto_rdverb_rdverb_proto_rawDesc), len(file_portal_core_proto_rdverb_rdverb_proto_rawDesc)),
839 - NumEnums: 2,
840 - NumMessages: 11,
841 - NumExtensions: 0,
842 - NumServices: 0,
843 - },
844 - GoTypes: file_portal_core_proto_rdverb_rdverb_proto_goTypes,
845 - DependencyIndexes: file_portal_core_proto_rdverb_rdverb_proto_depIdxs,
846 - EnumInfos: file_portal_core_proto_rdverb_rdverb_proto_enumTypes,
847 - MessageInfos: file_portal_core_proto_rdverb_rdverb_proto_msgTypes,
848 - }.Build()
849 - File_portal_core_proto_rdverb_rdverb_proto = out.File
850 - file_portal_core_proto_rdverb_rdverb_proto_goTypes = nil
851 - file_portal_core_proto_rdverb_rdverb_proto_depIdxs = nil
852 -}
portal/core/proto/rdverb/rdverb_vtproto.pb.go
+22 -23
@@ -7,7 +7,6 @@ package rdverb
7 import (
8 fmt "fmt"
9 protohelpers "github.com/planetscale/vtprotobuf/protohelpers"
10 - proto "google.golang.org/protobuf/proto"
10 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
11 rdsec "gosuda.org/portal/portal/core/proto/rdsec"
12 io "io"
@@ -39,7 +38,7 @@ func (m *Packet) CloneVT() *Packet {
38 return r
39 }
40
42 -func (m *Packet) CloneMessageVT() proto.Message {
41 +func (m *Packet) CloneMessageVT() any {
42 return m.CloneVT()
43 }
44
@@ -68,7 +67,7 @@ func (m *RelayInfo) CloneVT() *RelayInfo {
67 return r
68 }
69
71 -func (m *RelayInfo) CloneMessageVT() proto.Message {
70 +func (m *RelayInfo) CloneMessageVT() any {
71 return m.CloneVT()
72 }
73
@@ -84,7 +83,7 @@ func (m *RelayInfoRequest) CloneVT() *RelayInfoRequest {
83 return r
84 }
85
87 -func (m *RelayInfoRequest) CloneMessageVT() proto.Message {
86 +func (m *RelayInfoRequest) CloneMessageVT() any {
87 return m.CloneVT()
88 }
89
@@ -101,7 +100,7 @@ func (m *RelayInfoResponse) CloneVT() *RelayInfoResponse {
100 return r
101 }
102
104 -func (m *RelayInfoResponse) CloneMessageVT() proto.Message {
103 +func (m *RelayInfoResponse) CloneMessageVT() any {
104 return m.CloneVT()
105 }
106
@@ -126,7 +125,7 @@ func (m *Lease) CloneVT() *Lease {
125 return r
126 }
127
129 -func (m *Lease) CloneMessageVT() proto.Message {
128 +func (m *Lease) CloneMessageVT() any {
129 return m.CloneVT()
130 }
131
@@ -149,7 +148,7 @@ func (m *LeaseUpdateRequest) CloneVT() *LeaseUpdateRequest {
148 return r
149 }
150
152 -func (m *LeaseUpdateRequest) CloneMessageVT() proto.Message {
151 +func (m *LeaseUpdateRequest) CloneMessageVT() any {
152 return m.CloneVT()
153 }
154
@@ -166,7 +165,7 @@ func (m *LeaseUpdateResponse) CloneVT() *LeaseUpdateResponse {
165 return r
166 }
167
169 -func (m *LeaseUpdateResponse) CloneMessageVT() proto.Message {
168 +func (m *LeaseUpdateResponse) CloneMessageVT() any {
169 return m.CloneVT()
170 }
171
@@ -189,7 +188,7 @@ func (m *LeaseDeleteRequest) CloneVT() *LeaseDeleteRequest {
188 return r
189 }
190
192 -func (m *LeaseDeleteRequest) CloneMessageVT() proto.Message {
191 +func (m *LeaseDeleteRequest) CloneMessageVT() any {
192 return m.CloneVT()
193 }
194
@@ -206,7 +205,7 @@ func (m *LeaseDeleteResponse) CloneVT() *LeaseDeleteResponse {
205 return r
206 }
207
209 -func (m *LeaseDeleteResponse) CloneMessageVT() proto.Message {
208 +func (m *LeaseDeleteResponse) CloneMessageVT() any {
209 return m.CloneVT()
210 }
211
@@ -224,7 +223,7 @@ func (m *ConnectionRequest) CloneVT() *ConnectionRequest {
223 return r
224 }
225
227 -func (m *ConnectionRequest) CloneMessageVT() proto.Message {
226 +func (m *ConnectionRequest) CloneMessageVT() any {
227 return m.CloneVT()
228 }
229
@@ -241,7 +240,7 @@ func (m *ConnectionResponse) CloneVT() *ConnectionResponse {
240 return r
241 }
242
244 -func (m *ConnectionResponse) CloneMessageVT() proto.Message {
243 +func (m *ConnectionResponse) CloneMessageVT() any {
244 return m.CloneVT()
245 }
246
@@ -260,7 +259,7 @@ func (this *Packet) EqualVT(that *Packet) bool {
259 return string(this.unknownFields) == string(that.unknownFields)
260 }
261
263 -func (this *Packet) EqualMessageVT(thatMsg proto.Message) bool {
262 +func (this *Packet) EqualMessageVT(thatMsg any) bool {
263 that, ok := thatMsg.(*Packet)
264 if !ok {
265 return false
@@ -305,7 +304,7 @@ func (this *RelayInfo) EqualVT(that *RelayInfo) bool {
304 return string(this.unknownFields) == string(that.unknownFields)
305 }
306
308 -func (this *RelayInfo) EqualMessageVT(thatMsg proto.Message) bool {
307 +func (this *RelayInfo) EqualMessageVT(thatMsg any) bool {
308 that, ok := thatMsg.(*RelayInfo)
309 if !ok {
310 return false
@@ -321,7 +320,7 @@ func (this *RelayInfoRequest) EqualVT(that *RelayInfoRequest) bool {
320 return string(this.unknownFields) == string(that.unknownFields)
321 }
322
324 -func (this *RelayInfoRequest) EqualMessageVT(thatMsg proto.Message) bool {
323 +func (this *RelayInfoRequest) EqualMessageVT(thatMsg any) bool {
324 that, ok := thatMsg.(*RelayInfoRequest)
325 if !ok {
326 return false
@@ -340,7 +339,7 @@ func (this *RelayInfoResponse) EqualVT(that *RelayInfoResponse) bool {
339 return string(this.unknownFields) == string(that.unknownFields)
340 }
341
343 -func (this *RelayInfoResponse) EqualMessageVT(thatMsg proto.Message) bool {
342 +func (this *RelayInfoResponse) EqualMessageVT(thatMsg any) bool {
343 that, ok := thatMsg.(*RelayInfoResponse)
344 if !ok {
345 return false
@@ -377,7 +376,7 @@ func (this *Lease) EqualVT(that *Lease) bool {
376 return string(this.unknownFields) == string(that.unknownFields)
377 }
378
380 -func (this *Lease) EqualMessageVT(thatMsg proto.Message) bool {
379 +func (this *Lease) EqualMessageVT(thatMsg any) bool {
380 that, ok := thatMsg.(*Lease)
381 if !ok {
382 return false
@@ -402,7 +401,7 @@ func (this *LeaseUpdateRequest) EqualVT(that *LeaseUpdateRequest) bool {
401 return string(this.unknownFields) == string(that.unknownFields)
402 }
403
405 -func (this *LeaseUpdateRequest) EqualMessageVT(thatMsg proto.Message) bool {
404 +func (this *LeaseUpdateRequest) EqualMessageVT(thatMsg any) bool {
405 that, ok := thatMsg.(*LeaseUpdateRequest)
406 if !ok {
407 return false
@@ -421,7 +420,7 @@ func (this *LeaseUpdateResponse) EqualVT(that *LeaseUpdateResponse) bool {
420 return string(this.unknownFields) == string(that.unknownFields)
421 }
422
424 -func (this *LeaseUpdateResponse) EqualMessageVT(thatMsg proto.Message) bool {
423 +func (this *LeaseUpdateResponse) EqualMessageVT(thatMsg any) bool {
424 that, ok := thatMsg.(*LeaseUpdateResponse)
425 if !ok {
426 return false
@@ -446,7 +445,7 @@ func (this *LeaseDeleteRequest) EqualVT(that *LeaseDeleteRequest) bool {
445 return string(this.unknownFields) == string(that.unknownFields)
446 }
447
449 -func (this *LeaseDeleteRequest) EqualMessageVT(thatMsg proto.Message) bool {
448 +func (this *LeaseDeleteRequest) EqualMessageVT(thatMsg any) bool {
449 that, ok := thatMsg.(*LeaseDeleteRequest)
450 if !ok {
451 return false
@@ -465,7 +464,7 @@ func (this *LeaseDeleteResponse) EqualVT(that *LeaseDeleteResponse) bool {
464 return string(this.unknownFields) == string(that.unknownFields)
465 }
466
468 -func (this *LeaseDeleteResponse) EqualMessageVT(thatMsg proto.Message) bool {
467 +func (this *LeaseDeleteResponse) EqualMessageVT(thatMsg any) bool {
468 that, ok := thatMsg.(*LeaseDeleteResponse)
469 if !ok {
470 return false
@@ -487,7 +486,7 @@ func (this *ConnectionRequest) EqualVT(that *ConnectionRequest) bool {
486 return string(this.unknownFields) == string(that.unknownFields)
487 }
488
490 -func (this *ConnectionRequest) EqualMessageVT(thatMsg proto.Message) bool {
489 +func (this *ConnectionRequest) EqualMessageVT(thatMsg any) bool {
490 that, ok := thatMsg.(*ConnectionRequest)
491 if !ok {
492 return false
@@ -506,7 +505,7 @@ func (this *ConnectionResponse) EqualVT(that *ConnectionResponse) bool {
505 return string(this.unknownFields) == string(that.unknownFields)
506 }
507
509 -func (this *ConnectionResponse) EqualMessageVT(thatMsg proto.Message) bool {
508 +func (this *ConnectionResponse) EqualMessageVT(thatMsg any) bool {
509 that, ok := thatMsg.(*ConnectionResponse)
510 if !ok {
511 return false