protobuf definitions for hyper-real-time chat

maybe add batch event

Changed files
+919 -26
gen
+18 -1
README.md
··· 2 2 3 3 This repository defines the LRC protocol message schema using Protocol Buffers and provides generated code for both **TypeScript** and **Go**. 4 4 5 + 6 + ## Generation 7 + these may work idrk 8 + 9 + ### Typescript 10 + ``` 11 + npx protoc \ 12 + --ts_out gen/ts \ 13 + --proto_path . \ 14 + lrc.proto 15 + ``` 16 + 17 + ### Go 18 + ``` 19 + protoc --go_out=gen/go --go_opt=paths=source_relative lrc.proto 20 + ``` 21 + 5 22 ## Installation 6 23 7 24 ### TypeScript ··· 53 70 The LRC protocol does not inherently determine how Mute, Unmute, Kick, Ban and Unban should be implemented. ExternalID and Secret fields allow for some form of verification of identity, which can occur outside of the protocol. 54 71 55 72 ## License 56 - MIT 73 + MIT
+73 -24
gen/go/lrc.pb.go
··· 1067 1067 return 0 1068 1068 } 1069 1069 1070 + type BatchEvent struct { 1071 + state protoimpl.MessageState `protogen:"open.v1"` 1072 + Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` 1073 + unknownFields protoimpl.UnknownFields 1074 + sizeCache protoimpl.SizeCache 1075 + } 1076 + 1077 + func (x *BatchEvent) Reset() { 1078 + *x = BatchEvent{} 1079 + mi := &file_lrc_proto_msgTypes[16] 1080 + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1081 + ms.StoreMessageInfo(mi) 1082 + } 1083 + 1084 + func (x *BatchEvent) String() string { 1085 + return protoimpl.X.MessageStringOf(x) 1086 + } 1087 + 1088 + func (*BatchEvent) ProtoMessage() {} 1089 + 1090 + func (x *BatchEvent) ProtoReflect() protoreflect.Message { 1091 + mi := &file_lrc_proto_msgTypes[16] 1092 + if x != nil { 1093 + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 1094 + if ms.LoadMessageInfo() == nil { 1095 + ms.StoreMessageInfo(mi) 1096 + } 1097 + return ms 1098 + } 1099 + return mi.MessageOf(x) 1100 + } 1101 + 1102 + // Deprecated: Use BatchEvent.ProtoReflect.Descriptor instead. 1103 + func (*BatchEvent) Descriptor() ([]byte, []int) { 1104 + return file_lrc_proto_rawDescGZIP(), []int{16} 1105 + } 1106 + 1107 + func (x *BatchEvent) GetEvents() []*Event { 1108 + if x != nil { 1109 + return x.Events 1110 + } 1111 + return nil 1112 + } 1113 + 1070 1114 var File_lrc_proto protoreflect.FileDescriptor 1071 1115 1072 1116 const file_lrc_proto_rawDesc = "" + ··· 1163 1207 "\n" + 1164 1208 "privileges\x18\x01 \x01(\v2\f.lrc.v1.SudoR\n" + 1165 1209 "privileges\x12\x0e\n" + 1166 - "\x02id\x18\x02 \x01(\rR\x02idB3Z1github.com/rachel-mp4/lrcproto/gen/go/lrcpb;lrcpbb\x06proto3" 1210 + "\x02id\x18\x02 \x01(\rR\x02id\"3\n" + 1211 + "\n" + 1212 + "BatchEvent\x12%\n" + 1213 + "\x06events\x18\x01 \x03(\v2\r.lrc.v1.EventR\x06eventsB3Z1github.com/rachel-mp4/lrcproto/gen/go/lrcpb;lrcpbb\x06proto3" 1167 1214 1168 1215 var ( 1169 1216 file_lrc_proto_rawDescOnce sync.Once ··· 1177 1224 return file_lrc_proto_rawDescData 1178 1225 } 1179 1226 1180 - var file_lrc_proto_msgTypes = make([]protoimpl.MessageInfo, 16) 1227 + var file_lrc_proto_msgTypes = make([]protoimpl.MessageInfo, 17) 1181 1228 var file_lrc_proto_goTypes = []any{ 1182 - (*Event)(nil), // 0: lrc.v1.Event 1183 - (*Ping)(nil), // 1: lrc.v1.Ping 1184 - (*Pong)(nil), // 2: lrc.v1.Pong 1185 - (*Init)(nil), // 3: lrc.v1.Init 1186 - (*Pub)(nil), // 4: lrc.v1.Pub 1187 - (*Insert)(nil), // 5: lrc.v1.Insert 1188 - (*Delete)(nil), // 6: lrc.v1.Delete 1189 - (*Mute)(nil), // 7: lrc.v1.Mute 1190 - (*Unmute)(nil), // 8: lrc.v1.Unmute 1191 - (*Set)(nil), // 9: lrc.v1.Set 1192 - (*Get)(nil), // 10: lrc.v1.Get 1193 - (*Sudo)(nil), // 11: lrc.v1.Sudo 1194 - (*Kick)(nil), // 12: lrc.v1.Kick 1195 - (*Hug)(nil), // 13: lrc.v1.Hug 1196 - (*Ban)(nil), // 14: lrc.v1.Ban 1197 - (*Unban)(nil), // 15: lrc.v1.Unban 1229 + (*Event)(nil), // 0: lrc.v1.Event 1230 + (*Ping)(nil), // 1: lrc.v1.Ping 1231 + (*Pong)(nil), // 2: lrc.v1.Pong 1232 + (*Init)(nil), // 3: lrc.v1.Init 1233 + (*Pub)(nil), // 4: lrc.v1.Pub 1234 + (*Insert)(nil), // 5: lrc.v1.Insert 1235 + (*Delete)(nil), // 6: lrc.v1.Delete 1236 + (*Mute)(nil), // 7: lrc.v1.Mute 1237 + (*Unmute)(nil), // 8: lrc.v1.Unmute 1238 + (*Set)(nil), // 9: lrc.v1.Set 1239 + (*Get)(nil), // 10: lrc.v1.Get 1240 + (*Sudo)(nil), // 11: lrc.v1.Sudo 1241 + (*Kick)(nil), // 12: lrc.v1.Kick 1242 + (*Hug)(nil), // 13: lrc.v1.Hug 1243 + (*Ban)(nil), // 14: lrc.v1.Ban 1244 + (*Unban)(nil), // 15: lrc.v1.Unban 1245 + (*BatchEvent)(nil), // 16: lrc.v1.BatchEvent 1198 1246 } 1199 1247 var file_lrc_proto_depIdxs = []int32{ 1200 1248 1, // 0: lrc.v1.Event.ping:type_name -> lrc.v1.Ping ··· 1214 1262 11, // 14: lrc.v1.Kick.privileges:type_name -> lrc.v1.Sudo 1215 1263 11, // 15: lrc.v1.Ban.privileges:type_name -> lrc.v1.Sudo 1216 1264 11, // 16: lrc.v1.Unban.privileges:type_name -> lrc.v1.Sudo 1217 - 17, // [17:17] is the sub-list for method output_type 1218 - 17, // [17:17] is the sub-list for method input_type 1219 - 17, // [17:17] is the sub-list for extension type_name 1220 - 17, // [17:17] is the sub-list for extension extendee 1221 - 0, // [0:17] is the sub-list for field type_name 1265 + 0, // 17: lrc.v1.BatchEvent.events:type_name -> lrc.v1.Event 1266 + 18, // [18:18] is the sub-list for method output_type 1267 + 18, // [18:18] is the sub-list for method input_type 1268 + 18, // [18:18] is the sub-list for extension type_name 1269 + 18, // [18:18] is the sub-list for extension extendee 1270 + 0, // [0:18] is the sub-list for field type_name 1222 1271 } 1223 1272 1224 1273 func init() { file_lrc_proto_init() } ··· 1254 1303 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 1255 1304 RawDescriptor: unsafe.Slice(unsafe.StringData(file_lrc_proto_rawDesc), len(file_lrc_proto_rawDesc)), 1256 1305 NumEnums: 0, 1257 - NumMessages: 16, 1306 + NumMessages: 17, 1258 1307 NumExtensions: 0, 1259 1308 NumServices: 0, 1260 1309 },
+826 -1
gen/ts/lrc.ts
··· 1 - // @generated by protobuf-ts 2.10.0 with parameter long_type_string,optimize_code_size 1 + // @generated by protobuf-ts 2.10.0 2 2 // @generated from protobuf file "lrc.proto" (package "lrc.v1", syntax proto3) 3 3 // tslint:disable 4 + import type { BinaryWriteOptions } from "@protobuf-ts/runtime"; 5 + import type { IBinaryWriter } from "@protobuf-ts/runtime"; 6 + import { WireType } from "@protobuf-ts/runtime"; 7 + import type { BinaryReadOptions } from "@protobuf-ts/runtime"; 8 + import type { IBinaryReader } from "@protobuf-ts/runtime"; 9 + import { UnknownFieldHandler } from "@protobuf-ts/runtime"; 10 + import type { PartialMessage } from "@protobuf-ts/runtime"; 11 + import { reflectionMergePartial } from "@protobuf-ts/runtime"; 4 12 import { MessageType } from "@protobuf-ts/runtime"; 5 13 /** 6 14 * @generated from protobuf message lrc.v1.Event ··· 288 296 */ 289 297 id: number; 290 298 } 299 + /** 300 + * @generated from protobuf message lrc.v1.BatchEvent 301 + */ 302 + export interface BatchEvent { 303 + /** 304 + * @generated from protobuf field: repeated lrc.v1.Event events = 1; 305 + */ 306 + events: Event[]; 307 + } 291 308 // @generated message type with reflection information, may provide speed optimized methods 292 309 class Event$Type extends MessageType<Event> { 293 310 constructor() { ··· 308 325 { no: 14, name: "unban", kind: "message", oneof: "msg", T: () => Unban } 309 326 ]); 310 327 } 328 + create(value?: PartialMessage<Event>): Event { 329 + const message = globalThis.Object.create((this.messagePrototype!)); 330 + message.msg = { oneofKind: undefined }; 331 + if (value !== undefined) 332 + reflectionMergePartial<Event>(this, message, value); 333 + return message; 334 + } 335 + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Event): Event { 336 + let message = target ?? this.create(), end = reader.pos + length; 337 + while (reader.pos < end) { 338 + let [fieldNo, wireType] = reader.tag(); 339 + switch (fieldNo) { 340 + case /* lrc.v1.Ping ping */ 1: 341 + message.msg = { 342 + oneofKind: "ping", 343 + ping: Ping.internalBinaryRead(reader, reader.uint32(), options, (message.msg as any).ping) 344 + }; 345 + break; 346 + case /* lrc.v1.Pong pong */ 2: 347 + message.msg = { 348 + oneofKind: "pong", 349 + pong: Pong.internalBinaryRead(reader, reader.uint32(), options, (message.msg as any).pong) 350 + }; 351 + break; 352 + case /* lrc.v1.Init init */ 3: 353 + message.msg = { 354 + oneofKind: "init", 355 + init: Init.internalBinaryRead(reader, reader.uint32(), options, (message.msg as any).init) 356 + }; 357 + break; 358 + case /* lrc.v1.Pub pub */ 4: 359 + message.msg = { 360 + oneofKind: "pub", 361 + pub: Pub.internalBinaryRead(reader, reader.uint32(), options, (message.msg as any).pub) 362 + }; 363 + break; 364 + case /* lrc.v1.Insert insert */ 5: 365 + message.msg = { 366 + oneofKind: "insert", 367 + insert: Insert.internalBinaryRead(reader, reader.uint32(), options, (message.msg as any).insert) 368 + }; 369 + break; 370 + case /* lrc.v1.Delete delete */ 6: 371 + message.msg = { 372 + oneofKind: "delete", 373 + delete: Delete.internalBinaryRead(reader, reader.uint32(), options, (message.msg as any).delete) 374 + }; 375 + break; 376 + case /* lrc.v1.Mute mute */ 7: 377 + message.msg = { 378 + oneofKind: "mute", 379 + mute: Mute.internalBinaryRead(reader, reader.uint32(), options, (message.msg as any).mute) 380 + }; 381 + break; 382 + case /* lrc.v1.Unmute unmute */ 8: 383 + message.msg = { 384 + oneofKind: "unmute", 385 + unmute: Unmute.internalBinaryRead(reader, reader.uint32(), options, (message.msg as any).unmute) 386 + }; 387 + break; 388 + case /* lrc.v1.Set set */ 9: 389 + message.msg = { 390 + oneofKind: "set", 391 + set: Set.internalBinaryRead(reader, reader.uint32(), options, (message.msg as any).set) 392 + }; 393 + break; 394 + case /* lrc.v1.Get get */ 10: 395 + message.msg = { 396 + oneofKind: "get", 397 + get: Get.internalBinaryRead(reader, reader.uint32(), options, (message.msg as any).get) 398 + }; 399 + break; 400 + case /* lrc.v1.Kick kick */ 11: 401 + message.msg = { 402 + oneofKind: "kick", 403 + kick: Kick.internalBinaryRead(reader, reader.uint32(), options, (message.msg as any).kick) 404 + }; 405 + break; 406 + case /* lrc.v1.Hug hug */ 12: 407 + message.msg = { 408 + oneofKind: "hug", 409 + hug: Hug.internalBinaryRead(reader, reader.uint32(), options, (message.msg as any).hug) 410 + }; 411 + break; 412 + case /* lrc.v1.Ban ban */ 13: 413 + message.msg = { 414 + oneofKind: "ban", 415 + ban: Ban.internalBinaryRead(reader, reader.uint32(), options, (message.msg as any).ban) 416 + }; 417 + break; 418 + case /* lrc.v1.Unban unban */ 14: 419 + message.msg = { 420 + oneofKind: "unban", 421 + unban: Unban.internalBinaryRead(reader, reader.uint32(), options, (message.msg as any).unban) 422 + }; 423 + break; 424 + default: 425 + let u = options.readUnknownField; 426 + if (u === "throw") 427 + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); 428 + let d = reader.skip(wireType); 429 + if (u !== false) 430 + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); 431 + } 432 + } 433 + return message; 434 + } 435 + internalBinaryWrite(message: Event, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { 436 + /* lrc.v1.Ping ping = 1; */ 437 + if (message.msg.oneofKind === "ping") 438 + Ping.internalBinaryWrite(message.msg.ping, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); 439 + /* lrc.v1.Pong pong = 2; */ 440 + if (message.msg.oneofKind === "pong") 441 + Pong.internalBinaryWrite(message.msg.pong, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); 442 + /* lrc.v1.Init init = 3; */ 443 + if (message.msg.oneofKind === "init") 444 + Init.internalBinaryWrite(message.msg.init, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); 445 + /* lrc.v1.Pub pub = 4; */ 446 + if (message.msg.oneofKind === "pub") 447 + Pub.internalBinaryWrite(message.msg.pub, writer.tag(4, WireType.LengthDelimited).fork(), options).join(); 448 + /* lrc.v1.Insert insert = 5; */ 449 + if (message.msg.oneofKind === "insert") 450 + Insert.internalBinaryWrite(message.msg.insert, writer.tag(5, WireType.LengthDelimited).fork(), options).join(); 451 + /* lrc.v1.Delete delete = 6; */ 452 + if (message.msg.oneofKind === "delete") 453 + Delete.internalBinaryWrite(message.msg.delete, writer.tag(6, WireType.LengthDelimited).fork(), options).join(); 454 + /* lrc.v1.Mute mute = 7; */ 455 + if (message.msg.oneofKind === "mute") 456 + Mute.internalBinaryWrite(message.msg.mute, writer.tag(7, WireType.LengthDelimited).fork(), options).join(); 457 + /* lrc.v1.Unmute unmute = 8; */ 458 + if (message.msg.oneofKind === "unmute") 459 + Unmute.internalBinaryWrite(message.msg.unmute, writer.tag(8, WireType.LengthDelimited).fork(), options).join(); 460 + /* lrc.v1.Set set = 9; */ 461 + if (message.msg.oneofKind === "set") 462 + Set.internalBinaryWrite(message.msg.set, writer.tag(9, WireType.LengthDelimited).fork(), options).join(); 463 + /* lrc.v1.Get get = 10; */ 464 + if (message.msg.oneofKind === "get") 465 + Get.internalBinaryWrite(message.msg.get, writer.tag(10, WireType.LengthDelimited).fork(), options).join(); 466 + /* lrc.v1.Kick kick = 11; */ 467 + if (message.msg.oneofKind === "kick") 468 + Kick.internalBinaryWrite(message.msg.kick, writer.tag(11, WireType.LengthDelimited).fork(), options).join(); 469 + /* lrc.v1.Hug hug = 12; */ 470 + if (message.msg.oneofKind === "hug") 471 + Hug.internalBinaryWrite(message.msg.hug, writer.tag(12, WireType.LengthDelimited).fork(), options).join(); 472 + /* lrc.v1.Ban ban = 13; */ 473 + if (message.msg.oneofKind === "ban") 474 + Ban.internalBinaryWrite(message.msg.ban, writer.tag(13, WireType.LengthDelimited).fork(), options).join(); 475 + /* lrc.v1.Unban unban = 14; */ 476 + if (message.msg.oneofKind === "unban") 477 + Unban.internalBinaryWrite(message.msg.unban, writer.tag(14, WireType.LengthDelimited).fork(), options).join(); 478 + let u = options.writeUnknownFields; 479 + if (u !== false) 480 + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); 481 + return writer; 482 + } 311 483 } 312 484 /** 313 485 * @generated MessageType for protobuf message lrc.v1.Event ··· 318 490 constructor() { 319 491 super("lrc.v1.Ping", []); 320 492 } 493 + create(value?: PartialMessage<Ping>): Ping { 494 + const message = globalThis.Object.create((this.messagePrototype!)); 495 + if (value !== undefined) 496 + reflectionMergePartial<Ping>(this, message, value); 497 + return message; 498 + } 499 + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Ping): Ping { 500 + let message = target ?? this.create(), end = reader.pos + length; 501 + while (reader.pos < end) { 502 + let [fieldNo, wireType] = reader.tag(); 503 + switch (fieldNo) { 504 + default: 505 + let u = options.readUnknownField; 506 + if (u === "throw") 507 + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); 508 + let d = reader.skip(wireType); 509 + if (u !== false) 510 + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); 511 + } 512 + } 513 + return message; 514 + } 515 + internalBinaryWrite(message: Ping, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { 516 + let u = options.writeUnknownFields; 517 + if (u !== false) 518 + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); 519 + return writer; 520 + } 321 521 } 322 522 /** 323 523 * @generated MessageType for protobuf message lrc.v1.Ping ··· 328 528 constructor() { 329 529 super("lrc.v1.Pong", []); 330 530 } 531 + create(value?: PartialMessage<Pong>): Pong { 532 + const message = globalThis.Object.create((this.messagePrototype!)); 533 + if (value !== undefined) 534 + reflectionMergePartial<Pong>(this, message, value); 535 + return message; 536 + } 537 + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Pong): Pong { 538 + let message = target ?? this.create(), end = reader.pos + length; 539 + while (reader.pos < end) { 540 + let [fieldNo, wireType] = reader.tag(); 541 + switch (fieldNo) { 542 + default: 543 + let u = options.readUnknownField; 544 + if (u === "throw") 545 + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); 546 + let d = reader.skip(wireType); 547 + if (u !== false) 548 + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); 549 + } 550 + } 551 + return message; 552 + } 553 + internalBinaryWrite(message: Pong, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { 554 + let u = options.writeUnknownFields; 555 + if (u !== false) 556 + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); 557 + return writer; 558 + } 331 559 } 332 560 /** 333 561 * @generated MessageType for protobuf message lrc.v1.Pong ··· 345 573 { no: 6, name: "nonce", kind: "scalar", opt: true, T: 12 /*ScalarType.BYTES*/ } 346 574 ]); 347 575 } 576 + create(value?: PartialMessage<Init>): Init { 577 + const message = globalThis.Object.create((this.messagePrototype!)); 578 + if (value !== undefined) 579 + reflectionMergePartial<Init>(this, message, value); 580 + return message; 581 + } 582 + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Init): Init { 583 + let message = target ?? this.create(), end = reader.pos + length; 584 + while (reader.pos < end) { 585 + let [fieldNo, wireType] = reader.tag(); 586 + switch (fieldNo) { 587 + case /* optional uint32 id */ 1: 588 + message.id = reader.uint32(); 589 + break; 590 + case /* optional string nick */ 2: 591 + message.nick = reader.string(); 592 + break; 593 + case /* optional string externalID */ 3: 594 + message.externalID = reader.string(); 595 + break; 596 + case /* optional uint32 color */ 4: 597 + message.color = reader.uint32(); 598 + break; 599 + case /* optional bool echoed */ 5: 600 + message.echoed = reader.bool(); 601 + break; 602 + case /* optional bytes nonce */ 6: 603 + message.nonce = reader.bytes(); 604 + break; 605 + default: 606 + let u = options.readUnknownField; 607 + if (u === "throw") 608 + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); 609 + let d = reader.skip(wireType); 610 + if (u !== false) 611 + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); 612 + } 613 + } 614 + return message; 615 + } 616 + internalBinaryWrite(message: Init, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { 617 + /* optional uint32 id = 1; */ 618 + if (message.id !== undefined) 619 + writer.tag(1, WireType.Varint).uint32(message.id); 620 + /* optional string nick = 2; */ 621 + if (message.nick !== undefined) 622 + writer.tag(2, WireType.LengthDelimited).string(message.nick); 623 + /* optional string externalID = 3; */ 624 + if (message.externalID !== undefined) 625 + writer.tag(3, WireType.LengthDelimited).string(message.externalID); 626 + /* optional uint32 color = 4; */ 627 + if (message.color !== undefined) 628 + writer.tag(4, WireType.Varint).uint32(message.color); 629 + /* optional bool echoed = 5; */ 630 + if (message.echoed !== undefined) 631 + writer.tag(5, WireType.Varint).bool(message.echoed); 632 + /* optional bytes nonce = 6; */ 633 + if (message.nonce !== undefined) 634 + writer.tag(6, WireType.LengthDelimited).bytes(message.nonce); 635 + let u = options.writeUnknownFields; 636 + if (u !== false) 637 + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); 638 + return writer; 639 + } 348 640 } 349 641 /** 350 642 * @generated MessageType for protobuf message lrc.v1.Init ··· 357 649 { no: 1, name: "id", kind: "scalar", opt: true, T: 13 /*ScalarType.UINT32*/ } 358 650 ]); 359 651 } 652 + create(value?: PartialMessage<Pub>): Pub { 653 + const message = globalThis.Object.create((this.messagePrototype!)); 654 + if (value !== undefined) 655 + reflectionMergePartial<Pub>(this, message, value); 656 + return message; 657 + } 658 + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Pub): Pub { 659 + let message = target ?? this.create(), end = reader.pos + length; 660 + while (reader.pos < end) { 661 + let [fieldNo, wireType] = reader.tag(); 662 + switch (fieldNo) { 663 + case /* optional uint32 id */ 1: 664 + message.id = reader.uint32(); 665 + break; 666 + default: 667 + let u = options.readUnknownField; 668 + if (u === "throw") 669 + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); 670 + let d = reader.skip(wireType); 671 + if (u !== false) 672 + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); 673 + } 674 + } 675 + return message; 676 + } 677 + internalBinaryWrite(message: Pub, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { 678 + /* optional uint32 id = 1; */ 679 + if (message.id !== undefined) 680 + writer.tag(1, WireType.Varint).uint32(message.id); 681 + let u = options.writeUnknownFields; 682 + if (u !== false) 683 + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); 684 + return writer; 685 + } 360 686 } 361 687 /** 362 688 * @generated MessageType for protobuf message lrc.v1.Pub ··· 371 697 { no: 3, name: "utf16Index", kind: "scalar", T: 13 /*ScalarType.UINT32*/ } 372 698 ]); 373 699 } 700 + create(value?: PartialMessage<Insert>): Insert { 701 + const message = globalThis.Object.create((this.messagePrototype!)); 702 + message.body = ""; 703 + message.utf16Index = 0; 704 + if (value !== undefined) 705 + reflectionMergePartial<Insert>(this, message, value); 706 + return message; 707 + } 708 + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Insert): Insert { 709 + let message = target ?? this.create(), end = reader.pos + length; 710 + while (reader.pos < end) { 711 + let [fieldNo, wireType] = reader.tag(); 712 + switch (fieldNo) { 713 + case /* optional uint32 id */ 1: 714 + message.id = reader.uint32(); 715 + break; 716 + case /* string body */ 2: 717 + message.body = reader.string(); 718 + break; 719 + case /* uint32 utf16Index */ 3: 720 + message.utf16Index = reader.uint32(); 721 + break; 722 + default: 723 + let u = options.readUnknownField; 724 + if (u === "throw") 725 + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); 726 + let d = reader.skip(wireType); 727 + if (u !== false) 728 + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); 729 + } 730 + } 731 + return message; 732 + } 733 + internalBinaryWrite(message: Insert, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { 734 + /* optional uint32 id = 1; */ 735 + if (message.id !== undefined) 736 + writer.tag(1, WireType.Varint).uint32(message.id); 737 + /* string body = 2; */ 738 + if (message.body !== "") 739 + writer.tag(2, WireType.LengthDelimited).string(message.body); 740 + /* uint32 utf16Index = 3; */ 741 + if (message.utf16Index !== 0) 742 + writer.tag(3, WireType.Varint).uint32(message.utf16Index); 743 + let u = options.writeUnknownFields; 744 + if (u !== false) 745 + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); 746 + return writer; 747 + } 374 748 } 375 749 /** 376 750 * @generated MessageType for protobuf message lrc.v1.Insert ··· 385 759 { no: 3, name: "utf16End", kind: "scalar", T: 13 /*ScalarType.UINT32*/ } 386 760 ]); 387 761 } 762 + create(value?: PartialMessage<Delete>): Delete { 763 + const message = globalThis.Object.create((this.messagePrototype!)); 764 + message.utf16Start = 0; 765 + message.utf16End = 0; 766 + if (value !== undefined) 767 + reflectionMergePartial<Delete>(this, message, value); 768 + return message; 769 + } 770 + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Delete): Delete { 771 + let message = target ?? this.create(), end = reader.pos + length; 772 + while (reader.pos < end) { 773 + let [fieldNo, wireType] = reader.tag(); 774 + switch (fieldNo) { 775 + case /* optional uint32 id */ 1: 776 + message.id = reader.uint32(); 777 + break; 778 + case /* uint32 utf16Start */ 2: 779 + message.utf16Start = reader.uint32(); 780 + break; 781 + case /* uint32 utf16End */ 3: 782 + message.utf16End = reader.uint32(); 783 + break; 784 + default: 785 + let u = options.readUnknownField; 786 + if (u === "throw") 787 + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); 788 + let d = reader.skip(wireType); 789 + if (u !== false) 790 + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); 791 + } 792 + } 793 + return message; 794 + } 795 + internalBinaryWrite(message: Delete, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { 796 + /* optional uint32 id = 1; */ 797 + if (message.id !== undefined) 798 + writer.tag(1, WireType.Varint).uint32(message.id); 799 + /* uint32 utf16Start = 2; */ 800 + if (message.utf16Start !== 0) 801 + writer.tag(2, WireType.Varint).uint32(message.utf16Start); 802 + /* uint32 utf16End = 3; */ 803 + if (message.utf16End !== 0) 804 + writer.tag(3, WireType.Varint).uint32(message.utf16End); 805 + let u = options.writeUnknownFields; 806 + if (u !== false) 807 + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); 808 + return writer; 809 + } 388 810 } 389 811 /** 390 812 * @generated MessageType for protobuf message lrc.v1.Delete ··· 397 819 { no: 1, name: "id", kind: "scalar", T: 13 /*ScalarType.UINT32*/ } 398 820 ]); 399 821 } 822 + create(value?: PartialMessage<Mute>): Mute { 823 + const message = globalThis.Object.create((this.messagePrototype!)); 824 + message.id = 0; 825 + if (value !== undefined) 826 + reflectionMergePartial<Mute>(this, message, value); 827 + return message; 828 + } 829 + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Mute): Mute { 830 + let message = target ?? this.create(), end = reader.pos + length; 831 + while (reader.pos < end) { 832 + let [fieldNo, wireType] = reader.tag(); 833 + switch (fieldNo) { 834 + case /* uint32 id */ 1: 835 + message.id = reader.uint32(); 836 + break; 837 + default: 838 + let u = options.readUnknownField; 839 + if (u === "throw") 840 + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); 841 + let d = reader.skip(wireType); 842 + if (u !== false) 843 + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); 844 + } 845 + } 846 + return message; 847 + } 848 + internalBinaryWrite(message: Mute, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { 849 + /* uint32 id = 1; */ 850 + if (message.id !== 0) 851 + writer.tag(1, WireType.Varint).uint32(message.id); 852 + let u = options.writeUnknownFields; 853 + if (u !== false) 854 + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); 855 + return writer; 856 + } 400 857 } 401 858 /** 402 859 * @generated MessageType for protobuf message lrc.v1.Mute ··· 409 866 { no: 1, name: "id", kind: "scalar", T: 13 /*ScalarType.UINT32*/ } 410 867 ]); 411 868 } 869 + create(value?: PartialMessage<Unmute>): Unmute { 870 + const message = globalThis.Object.create((this.messagePrototype!)); 871 + message.id = 0; 872 + if (value !== undefined) 873 + reflectionMergePartial<Unmute>(this, message, value); 874 + return message; 875 + } 876 + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Unmute): Unmute { 877 + let message = target ?? this.create(), end = reader.pos + length; 878 + while (reader.pos < end) { 879 + let [fieldNo, wireType] = reader.tag(); 880 + switch (fieldNo) { 881 + case /* uint32 id */ 1: 882 + message.id = reader.uint32(); 883 + break; 884 + default: 885 + let u = options.readUnknownField; 886 + if (u === "throw") 887 + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); 888 + let d = reader.skip(wireType); 889 + if (u !== false) 890 + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); 891 + } 892 + } 893 + return message; 894 + } 895 + internalBinaryWrite(message: Unmute, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { 896 + /* uint32 id = 1; */ 897 + if (message.id !== 0) 898 + writer.tag(1, WireType.Varint).uint32(message.id); 899 + let u = options.writeUnknownFields; 900 + if (u !== false) 901 + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); 902 + return writer; 903 + } 412 904 } 413 905 /** 414 906 * @generated MessageType for protobuf message lrc.v1.Unmute ··· 423 915 { no: 3, name: "color", kind: "scalar", opt: true, T: 13 /*ScalarType.UINT32*/ } 424 916 ]); 425 917 } 918 + create(value?: PartialMessage<Set>): Set { 919 + const message = globalThis.Object.create((this.messagePrototype!)); 920 + if (value !== undefined) 921 + reflectionMergePartial<Set>(this, message, value); 922 + return message; 923 + } 924 + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Set): Set { 925 + let message = target ?? this.create(), end = reader.pos + length; 926 + while (reader.pos < end) { 927 + let [fieldNo, wireType] = reader.tag(); 928 + switch (fieldNo) { 929 + case /* optional string nick */ 1: 930 + message.nick = reader.string(); 931 + break; 932 + case /* optional string externalID */ 2: 933 + message.externalID = reader.string(); 934 + break; 935 + case /* optional uint32 color */ 3: 936 + message.color = reader.uint32(); 937 + break; 938 + default: 939 + let u = options.readUnknownField; 940 + if (u === "throw") 941 + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); 942 + let d = reader.skip(wireType); 943 + if (u !== false) 944 + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); 945 + } 946 + } 947 + return message; 948 + } 949 + internalBinaryWrite(message: Set, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { 950 + /* optional string nick = 1; */ 951 + if (message.nick !== undefined) 952 + writer.tag(1, WireType.LengthDelimited).string(message.nick); 953 + /* optional string externalID = 2; */ 954 + if (message.externalID !== undefined) 955 + writer.tag(2, WireType.LengthDelimited).string(message.externalID); 956 + /* optional uint32 color = 3; */ 957 + if (message.color !== undefined) 958 + writer.tag(3, WireType.Varint).uint32(message.color); 959 + let u = options.writeUnknownFields; 960 + if (u !== false) 961 + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); 962 + return writer; 963 + } 426 964 } 427 965 /** 428 966 * @generated MessageType for protobuf message lrc.v1.Set ··· 436 974 { no: 2, name: "connected", kind: "scalar", opt: true, T: 13 /*ScalarType.UINT32*/ } 437 975 ]); 438 976 } 977 + create(value?: PartialMessage<Get>): Get { 978 + const message = globalThis.Object.create((this.messagePrototype!)); 979 + if (value !== undefined) 980 + reflectionMergePartial<Get>(this, message, value); 981 + return message; 982 + } 983 + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Get): Get { 984 + let message = target ?? this.create(), end = reader.pos + length; 985 + while (reader.pos < end) { 986 + let [fieldNo, wireType] = reader.tag(); 987 + switch (fieldNo) { 988 + case /* optional string topic */ 1: 989 + message.topic = reader.string(); 990 + break; 991 + case /* optional uint32 connected */ 2: 992 + message.connected = reader.uint32(); 993 + break; 994 + default: 995 + let u = options.readUnknownField; 996 + if (u === "throw") 997 + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); 998 + let d = reader.skip(wireType); 999 + if (u !== false) 1000 + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); 1001 + } 1002 + } 1003 + return message; 1004 + } 1005 + internalBinaryWrite(message: Get, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { 1006 + /* optional string topic = 1; */ 1007 + if (message.topic !== undefined) 1008 + writer.tag(1, WireType.LengthDelimited).string(message.topic); 1009 + /* optional uint32 connected = 2; */ 1010 + if (message.connected !== undefined) 1011 + writer.tag(2, WireType.Varint).uint32(message.connected); 1012 + let u = options.writeUnknownFields; 1013 + if (u !== false) 1014 + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); 1015 + return writer; 1016 + } 439 1017 } 440 1018 /** 441 1019 * @generated MessageType for protobuf message lrc.v1.Get ··· 449 1027 { no: 2, name: "secret", kind: "scalar", T: 9 /*ScalarType.STRING*/ } 450 1028 ]); 451 1029 } 1030 + create(value?: PartialMessage<Sudo>): Sudo { 1031 + const message = globalThis.Object.create((this.messagePrototype!)); 1032 + message.externalID = ""; 1033 + message.secret = ""; 1034 + if (value !== undefined) 1035 + reflectionMergePartial<Sudo>(this, message, value); 1036 + return message; 1037 + } 1038 + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Sudo): Sudo { 1039 + let message = target ?? this.create(), end = reader.pos + length; 1040 + while (reader.pos < end) { 1041 + let [fieldNo, wireType] = reader.tag(); 1042 + switch (fieldNo) { 1043 + case /* string externalID */ 1: 1044 + message.externalID = reader.string(); 1045 + break; 1046 + case /* string secret */ 2: 1047 + message.secret = reader.string(); 1048 + break; 1049 + default: 1050 + let u = options.readUnknownField; 1051 + if (u === "throw") 1052 + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); 1053 + let d = reader.skip(wireType); 1054 + if (u !== false) 1055 + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); 1056 + } 1057 + } 1058 + return message; 1059 + } 1060 + internalBinaryWrite(message: Sudo, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { 1061 + /* string externalID = 1; */ 1062 + if (message.externalID !== "") 1063 + writer.tag(1, WireType.LengthDelimited).string(message.externalID); 1064 + /* string secret = 2; */ 1065 + if (message.secret !== "") 1066 + writer.tag(2, WireType.LengthDelimited).string(message.secret); 1067 + let u = options.writeUnknownFields; 1068 + if (u !== false) 1069 + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); 1070 + return writer; 1071 + } 452 1072 } 453 1073 /** 454 1074 * @generated MessageType for protobuf message lrc.v1.Sudo ··· 462 1082 { no: 2, name: "id", kind: "scalar", T: 13 /*ScalarType.UINT32*/ } 463 1083 ]); 464 1084 } 1085 + create(value?: PartialMessage<Kick>): Kick { 1086 + const message = globalThis.Object.create((this.messagePrototype!)); 1087 + message.id = 0; 1088 + if (value !== undefined) 1089 + reflectionMergePartial<Kick>(this, message, value); 1090 + return message; 1091 + } 1092 + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Kick): Kick { 1093 + let message = target ?? this.create(), end = reader.pos + length; 1094 + while (reader.pos < end) { 1095 + let [fieldNo, wireType] = reader.tag(); 1096 + switch (fieldNo) { 1097 + case /* lrc.v1.Sudo privileges */ 1: 1098 + message.privileges = Sudo.internalBinaryRead(reader, reader.uint32(), options, message.privileges); 1099 + break; 1100 + case /* uint32 id */ 2: 1101 + message.id = reader.uint32(); 1102 + break; 1103 + default: 1104 + let u = options.readUnknownField; 1105 + if (u === "throw") 1106 + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); 1107 + let d = reader.skip(wireType); 1108 + if (u !== false) 1109 + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); 1110 + } 1111 + } 1112 + return message; 1113 + } 1114 + internalBinaryWrite(message: Kick, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { 1115 + /* lrc.v1.Sudo privileges = 1; */ 1116 + if (message.privileges) 1117 + Sudo.internalBinaryWrite(message.privileges, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); 1118 + /* uint32 id = 2; */ 1119 + if (message.id !== 0) 1120 + writer.tag(2, WireType.Varint).uint32(message.id); 1121 + let u = options.writeUnknownFields; 1122 + if (u !== false) 1123 + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); 1124 + return writer; 1125 + } 465 1126 } 466 1127 /** 467 1128 * @generated MessageType for protobuf message lrc.v1.Kick ··· 474 1135 { no: 1, name: "id", kind: "scalar", T: 13 /*ScalarType.UINT32*/ } 475 1136 ]); 476 1137 } 1138 + create(value?: PartialMessage<Hug>): Hug { 1139 + const message = globalThis.Object.create((this.messagePrototype!)); 1140 + message.id = 0; 1141 + if (value !== undefined) 1142 + reflectionMergePartial<Hug>(this, message, value); 1143 + return message; 1144 + } 1145 + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Hug): Hug { 1146 + let message = target ?? this.create(), end = reader.pos + length; 1147 + while (reader.pos < end) { 1148 + let [fieldNo, wireType] = reader.tag(); 1149 + switch (fieldNo) { 1150 + case /* uint32 id */ 1: 1151 + message.id = reader.uint32(); 1152 + break; 1153 + default: 1154 + let u = options.readUnknownField; 1155 + if (u === "throw") 1156 + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); 1157 + let d = reader.skip(wireType); 1158 + if (u !== false) 1159 + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); 1160 + } 1161 + } 1162 + return message; 1163 + } 1164 + internalBinaryWrite(message: Hug, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { 1165 + /* uint32 id = 1; */ 1166 + if (message.id !== 0) 1167 + writer.tag(1, WireType.Varint).uint32(message.id); 1168 + let u = options.writeUnknownFields; 1169 + if (u !== false) 1170 + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); 1171 + return writer; 1172 + } 477 1173 } 478 1174 /** 479 1175 * @generated MessageType for protobuf message lrc.v1.Hug ··· 487 1183 { no: 2, name: "id", kind: "scalar", T: 13 /*ScalarType.UINT32*/ } 488 1184 ]); 489 1185 } 1186 + create(value?: PartialMessage<Ban>): Ban { 1187 + const message = globalThis.Object.create((this.messagePrototype!)); 1188 + message.id = 0; 1189 + if (value !== undefined) 1190 + reflectionMergePartial<Ban>(this, message, value); 1191 + return message; 1192 + } 1193 + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Ban): Ban { 1194 + let message = target ?? this.create(), end = reader.pos + length; 1195 + while (reader.pos < end) { 1196 + let [fieldNo, wireType] = reader.tag(); 1197 + switch (fieldNo) { 1198 + case /* lrc.v1.Sudo privileges */ 1: 1199 + message.privileges = Sudo.internalBinaryRead(reader, reader.uint32(), options, message.privileges); 1200 + break; 1201 + case /* uint32 id */ 2: 1202 + message.id = reader.uint32(); 1203 + break; 1204 + default: 1205 + let u = options.readUnknownField; 1206 + if (u === "throw") 1207 + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); 1208 + let d = reader.skip(wireType); 1209 + if (u !== false) 1210 + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); 1211 + } 1212 + } 1213 + return message; 1214 + } 1215 + internalBinaryWrite(message: Ban, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { 1216 + /* lrc.v1.Sudo privileges = 1; */ 1217 + if (message.privileges) 1218 + Sudo.internalBinaryWrite(message.privileges, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); 1219 + /* uint32 id = 2; */ 1220 + if (message.id !== 0) 1221 + writer.tag(2, WireType.Varint).uint32(message.id); 1222 + let u = options.writeUnknownFields; 1223 + if (u !== false) 1224 + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); 1225 + return writer; 1226 + } 490 1227 } 491 1228 /** 492 1229 * @generated MessageType for protobuf message lrc.v1.Ban ··· 500 1237 { no: 2, name: "id", kind: "scalar", T: 13 /*ScalarType.UINT32*/ } 501 1238 ]); 502 1239 } 1240 + create(value?: PartialMessage<Unban>): Unban { 1241 + const message = globalThis.Object.create((this.messagePrototype!)); 1242 + message.id = 0; 1243 + if (value !== undefined) 1244 + reflectionMergePartial<Unban>(this, message, value); 1245 + return message; 1246 + } 1247 + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Unban): Unban { 1248 + let message = target ?? this.create(), end = reader.pos + length; 1249 + while (reader.pos < end) { 1250 + let [fieldNo, wireType] = reader.tag(); 1251 + switch (fieldNo) { 1252 + case /* lrc.v1.Sudo privileges */ 1: 1253 + message.privileges = Sudo.internalBinaryRead(reader, reader.uint32(), options, message.privileges); 1254 + break; 1255 + case /* uint32 id */ 2: 1256 + message.id = reader.uint32(); 1257 + break; 1258 + default: 1259 + let u = options.readUnknownField; 1260 + if (u === "throw") 1261 + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); 1262 + let d = reader.skip(wireType); 1263 + if (u !== false) 1264 + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); 1265 + } 1266 + } 1267 + return message; 1268 + } 1269 + internalBinaryWrite(message: Unban, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { 1270 + /* lrc.v1.Sudo privileges = 1; */ 1271 + if (message.privileges) 1272 + Sudo.internalBinaryWrite(message.privileges, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); 1273 + /* uint32 id = 2; */ 1274 + if (message.id !== 0) 1275 + writer.tag(2, WireType.Varint).uint32(message.id); 1276 + let u = options.writeUnknownFields; 1277 + if (u !== false) 1278 + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); 1279 + return writer; 1280 + } 503 1281 } 504 1282 /** 505 1283 * @generated MessageType for protobuf message lrc.v1.Unban 506 1284 */ 507 1285 export const Unban = new Unban$Type(); 1286 + // @generated message type with reflection information, may provide speed optimized methods 1287 + class BatchEvent$Type extends MessageType<BatchEvent> { 1288 + constructor() { 1289 + super("lrc.v1.BatchEvent", [ 1290 + { no: 1, name: "events", kind: "message", repeat: 2 /*RepeatType.UNPACKED*/, T: () => Event } 1291 + ]); 1292 + } 1293 + create(value?: PartialMessage<BatchEvent>): BatchEvent { 1294 + const message = globalThis.Object.create((this.messagePrototype!)); 1295 + message.events = []; 1296 + if (value !== undefined) 1297 + reflectionMergePartial<BatchEvent>(this, message, value); 1298 + return message; 1299 + } 1300 + internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: BatchEvent): BatchEvent { 1301 + let message = target ?? this.create(), end = reader.pos + length; 1302 + while (reader.pos < end) { 1303 + let [fieldNo, wireType] = reader.tag(); 1304 + switch (fieldNo) { 1305 + case /* repeated lrc.v1.Event events */ 1: 1306 + message.events.push(Event.internalBinaryRead(reader, reader.uint32(), options)); 1307 + break; 1308 + default: 1309 + let u = options.readUnknownField; 1310 + if (u === "throw") 1311 + throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); 1312 + let d = reader.skip(wireType); 1313 + if (u !== false) 1314 + (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); 1315 + } 1316 + } 1317 + return message; 1318 + } 1319 + internalBinaryWrite(message: BatchEvent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { 1320 + /* repeated lrc.v1.Event events = 1; */ 1321 + for (let i = 0; i < message.events.length; i++) 1322 + Event.internalBinaryWrite(message.events[i], writer.tag(1, WireType.LengthDelimited).fork(), options).join(); 1323 + let u = options.writeUnknownFields; 1324 + if (u !== false) 1325 + (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); 1326 + return writer; 1327 + } 1328 + } 1329 + /** 1330 + * @generated MessageType for protobuf message lrc.v1.BatchEvent 1331 + */ 1332 + export const BatchEvent = new BatchEvent$Type();
+2
lrc.proto
··· 84 84 Sudo privileges = 1; 85 85 uint32 id = 2; 86 86 } 87 + 88 + message BatchEvent { repeated Event events = 1; }