ci: updating build to support ws url

This commit is contained in:
Chubby Granny Chaser
2025-05-09 20:53:21 +01:00
parent 6c44cc0cc4
commit 18815a027f
2 changed files with 302 additions and 180 deletions

View File

@@ -4,3 +4,4 @@ out
.gitignore .gitignore
migration.stub migration.stub
hydra-python-rpc/ hydra-python-rpc/
src/generated/

View File

@@ -47,19 +47,22 @@ export interface Envelope {
/** /**
* @generated from protobuf oneof: payload * @generated from protobuf oneof: payload
*/ */
payload: { payload:
| {
oneofKind: "friendRequest"; oneofKind: "friendRequest";
/** /**
* @generated from protobuf field: FriendRequest friend_request = 1; * @generated from protobuf field: FriendRequest friend_request = 1;
*/ */
friendRequest: FriendRequest; friendRequest: FriendRequest;
} | { }
| {
oneofKind: "updateGamePlaytime"; oneofKind: "updateGamePlaytime";
/** /**
* @generated from protobuf field: UpdateGamePlaytime update_game_playtime = 2; * @generated from protobuf field: UpdateGamePlaytime update_game_playtime = 2;
*/ */
updateGamePlaytime: UpdateGamePlaytime; updateGamePlaytime: UpdateGamePlaytime;
} | { }
| {
oneofKind: undefined; oneofKind: undefined;
}; };
} }
@@ -67,21 +70,38 @@ export interface Envelope {
class FriendRequest$Type extends MessageType<FriendRequest> { class FriendRequest$Type extends MessageType<FriendRequest> {
constructor() { constructor() {
super("FriendRequest", [ super("FriendRequest", [
{ no: 1, name: "friend_request_count", kind: "scalar", T: 5 /*ScalarType.INT32*/ }, {
{ no: 2, name: "sender_id", kind: "scalar", opt: true, T: 9 /*ScalarType.STRING*/ } no: 1,
name: "friend_request_count",
kind: "scalar",
T: 5 /*ScalarType.INT32*/,
},
{
no: 2,
name: "sender_id",
kind: "scalar",
opt: true,
T: 9 /*ScalarType.STRING*/,
},
]); ]);
} }
create(value?: PartialMessage<FriendRequest>): FriendRequest { create(value?: PartialMessage<FriendRequest>): FriendRequest {
const message = globalThis.Object.create((this.messagePrototype!)); const message = globalThis.Object.create(this.messagePrototype!);
message.friendRequestCount = 0; message.friendRequestCount = 0;
if (value !== undefined) if (value !== undefined)
reflectionMergePartial<FriendRequest>(this, message, value); reflectionMergePartial<FriendRequest>(this, message, value);
return message; return message;
} }
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: FriendRequest): FriendRequest { internalBinaryRead(
let message = target ?? this.create(), end = reader.pos + length; reader: IBinaryReader,
length: number,
options: BinaryReadOptions,
target?: FriendRequest
): FriendRequest {
const message = target ?? this.create(),
end = reader.pos + length;
while (reader.pos < end) { while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag(); const [fieldNo, wireType] = reader.tag();
switch (fieldNo) { switch (fieldNo) {
case /* int32 friend_request_count */ 1: case /* int32 friend_request_count */ 1:
message.friendRequestCount = reader.int32(); message.friendRequestCount = reader.int32();
@@ -90,26 +110,42 @@ class FriendRequest$Type extends MessageType<FriendRequest> {
message.senderId = reader.string(); message.senderId = reader.string();
break; break;
default: default:
let u = options.readUnknownField; const u = options.readUnknownField;
if (u === "throw") if (u === "throw")
throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); throw new globalThis.Error(
let d = reader.skip(wireType); `Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`
);
const d = reader.skip(wireType);
if (u !== false) if (u !== false)
(u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); (u === true ? UnknownFieldHandler.onRead : u)(
this.typeName,
message,
fieldNo,
wireType,
d
);
} }
} }
return message; return message;
} }
internalBinaryWrite(message: FriendRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { internalBinaryWrite(
message: FriendRequest,
writer: IBinaryWriter,
options: BinaryWriteOptions
): IBinaryWriter {
/* int32 friend_request_count = 1; */ /* int32 friend_request_count = 1; */
if (message.friendRequestCount !== 0) if (message.friendRequestCount !== 0)
writer.tag(1, WireType.Varint).int32(message.friendRequestCount); writer.tag(1, WireType.Varint).int32(message.friendRequestCount);
/* optional string sender_id = 2; */ /* optional string sender_id = 2; */
if (message.senderId !== undefined) if (message.senderId !== undefined)
writer.tag(2, WireType.LengthDelimited).string(message.senderId); writer.tag(2, WireType.LengthDelimited).string(message.senderId);
let u = options.writeUnknownFields; const u = options.writeUnknownFields;
if (u !== false) if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); (u == true ? UnknownFieldHandler.onWrite : u)(
this.typeName,
message,
writer
);
return writer; return writer;
} }
} }
@@ -121,13 +157,24 @@ export const FriendRequest = new FriendRequest$Type();
class UpdateGamePlaytime$Type extends MessageType<UpdateGamePlaytime> { class UpdateGamePlaytime$Type extends MessageType<UpdateGamePlaytime> {
constructor() { constructor() {
super("UpdateGamePlaytime", [ super("UpdateGamePlaytime", [
{ no: 1, name: "playtime_delta_in_seconds", kind: "scalar", T: 3 /*ScalarType.INT64*/, L: 0 /*LongType.BIGINT*/ }, {
{ no: 2, name: "last_time_played", kind: "scalar", T: 9 /*ScalarType.STRING*/ }, no: 1,
{ no: 3, name: "game_id", kind: "scalar", T: 9 /*ScalarType.STRING*/ } name: "playtime_delta_in_seconds",
kind: "scalar",
T: 3 /*ScalarType.INT64*/,
L: 0 /*LongType.BIGINT*/,
},
{
no: 2,
name: "last_time_played",
kind: "scalar",
T: 9 /*ScalarType.STRING*/,
},
{ no: 3, name: "game_id", kind: "scalar", T: 9 /*ScalarType.STRING*/ },
]); ]);
} }
create(value?: PartialMessage<UpdateGamePlaytime>): UpdateGamePlaytime { create(value?: PartialMessage<UpdateGamePlaytime>): UpdateGamePlaytime {
const message = globalThis.Object.create((this.messagePrototype!)); const message = globalThis.Object.create(this.messagePrototype!);
message.playtimeDeltaInSeconds = 0n; message.playtimeDeltaInSeconds = 0n;
message.lastTimePlayed = ""; message.lastTimePlayed = "";
message.gameId = ""; message.gameId = "";
@@ -135,10 +182,16 @@ class UpdateGamePlaytime$Type extends MessageType<UpdateGamePlaytime> {
reflectionMergePartial<UpdateGamePlaytime>(this, message, value); reflectionMergePartial<UpdateGamePlaytime>(this, message, value);
return message; return message;
} }
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: UpdateGamePlaytime): UpdateGamePlaytime { internalBinaryRead(
let message = target ?? this.create(), end = reader.pos + length; reader: IBinaryReader,
length: number,
options: BinaryReadOptions,
target?: UpdateGamePlaytime
): UpdateGamePlaytime {
const message = target ?? this.create(),
end = reader.pos + length;
while (reader.pos < end) { while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag(); const [fieldNo, wireType] = reader.tag();
switch (fieldNo) { switch (fieldNo) {
case /* int64 playtime_delta_in_seconds */ 1: case /* int64 playtime_delta_in_seconds */ 1:
message.playtimeDeltaInSeconds = reader.int64().toBigInt(); message.playtimeDeltaInSeconds = reader.int64().toBigInt();
@@ -150,17 +203,29 @@ class UpdateGamePlaytime$Type extends MessageType<UpdateGamePlaytime> {
message.gameId = reader.string(); message.gameId = reader.string();
break; break;
default: default:
let u = options.readUnknownField; const u = options.readUnknownField;
if (u === "throw") if (u === "throw")
throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); throw new globalThis.Error(
let d = reader.skip(wireType); `Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`
);
const d = reader.skip(wireType);
if (u !== false) if (u !== false)
(u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); (u === true ? UnknownFieldHandler.onRead : u)(
this.typeName,
message,
fieldNo,
wireType,
d
);
} }
} }
return message; return message;
} }
internalBinaryWrite(message: UpdateGamePlaytime, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { internalBinaryWrite(
message: UpdateGamePlaytime,
writer: IBinaryWriter,
options: BinaryWriteOptions
): IBinaryWriter {
/* int64 playtime_delta_in_seconds = 1; */ /* int64 playtime_delta_in_seconds = 1; */
if (message.playtimeDeltaInSeconds !== 0n) if (message.playtimeDeltaInSeconds !== 0n)
writer.tag(1, WireType.Varint).int64(message.playtimeDeltaInSeconds); writer.tag(1, WireType.Varint).int64(message.playtimeDeltaInSeconds);
@@ -170,9 +235,13 @@ class UpdateGamePlaytime$Type extends MessageType<UpdateGamePlaytime> {
/* string game_id = 3; */ /* string game_id = 3; */
if (message.gameId !== "") if (message.gameId !== "")
writer.tag(3, WireType.LengthDelimited).string(message.gameId); writer.tag(3, WireType.LengthDelimited).string(message.gameId);
let u = options.writeUnknownFields; const u = options.writeUnknownFields;
if (u !== false) if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); (u == true ? UnknownFieldHandler.onWrite : u)(
this.typeName,
message,
writer
);
return writer; return writer;
} }
} }
@@ -184,55 +253,107 @@ export const UpdateGamePlaytime = new UpdateGamePlaytime$Type();
class Envelope$Type extends MessageType<Envelope> { class Envelope$Type extends MessageType<Envelope> {
constructor() { constructor() {
super("Envelope", [ super("Envelope", [
{ no: 1, name: "friend_request", kind: "message", oneof: "payload", T: () => FriendRequest }, {
{ no: 2, name: "update_game_playtime", kind: "message", oneof: "payload", T: () => UpdateGamePlaytime } no: 1,
name: "friend_request",
kind: "message",
oneof: "payload",
T: () => FriendRequest,
},
{
no: 2,
name: "update_game_playtime",
kind: "message",
oneof: "payload",
T: () => UpdateGamePlaytime,
},
]); ]);
} }
create(value?: PartialMessage<Envelope>): Envelope { create(value?: PartialMessage<Envelope>): Envelope {
const message = globalThis.Object.create((this.messagePrototype!)); const message = globalThis.Object.create(this.messagePrototype!);
message.payload = { oneofKind: undefined }; message.payload = { oneofKind: undefined };
if (value !== undefined) if (value !== undefined)
reflectionMergePartial<Envelope>(this, message, value); reflectionMergePartial<Envelope>(this, message, value);
return message; return message;
} }
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Envelope): Envelope { internalBinaryRead(
let message = target ?? this.create(), end = reader.pos + length; reader: IBinaryReader,
length: number,
options: BinaryReadOptions,
target?: Envelope
): Envelope {
const message = target ?? this.create(),
end = reader.pos + length;
while (reader.pos < end) { while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag(); const [fieldNo, wireType] = reader.tag();
switch (fieldNo) { switch (fieldNo) {
case /* FriendRequest friend_request */ 1: case /* FriendRequest friend_request */ 1:
message.payload = { message.payload = {
oneofKind: "friendRequest", oneofKind: "friendRequest",
friendRequest: FriendRequest.internalBinaryRead(reader, reader.uint32(), options, (message.payload as any).friendRequest) friendRequest: FriendRequest.internalBinaryRead(
reader,
reader.uint32(),
options,
(message.payload as any).friendRequest
),
}; };
break; break;
case /* UpdateGamePlaytime update_game_playtime */ 2: case /* UpdateGamePlaytime update_game_playtime */ 2:
message.payload = { message.payload = {
oneofKind: "updateGamePlaytime", oneofKind: "updateGamePlaytime",
updateGamePlaytime: UpdateGamePlaytime.internalBinaryRead(reader, reader.uint32(), options, (message.payload as any).updateGamePlaytime) updateGamePlaytime: UpdateGamePlaytime.internalBinaryRead(
reader,
reader.uint32(),
options,
(message.payload as any).updateGamePlaytime
),
}; };
break; break;
default: default:
let u = options.readUnknownField; const u = options.readUnknownField;
if (u === "throw") if (u === "throw")
throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`); throw new globalThis.Error(
let d = reader.skip(wireType); `Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`
);
const d = reader.skip(wireType);
if (u !== false) if (u !== false)
(u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); (u === true ? UnknownFieldHandler.onRead : u)(
this.typeName,
message,
fieldNo,
wireType,
d
);
} }
} }
return message; return message;
} }
internalBinaryWrite(message: Envelope, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { internalBinaryWrite(
message: Envelope,
writer: IBinaryWriter,
options: BinaryWriteOptions
): IBinaryWriter {
/* FriendRequest friend_request = 1; */ /* FriendRequest friend_request = 1; */
if (message.payload.oneofKind === "friendRequest") if (message.payload.oneofKind === "friendRequest")
FriendRequest.internalBinaryWrite(message.payload.friendRequest, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); FriendRequest.internalBinaryWrite(
message.payload.friendRequest,
writer.tag(1, WireType.LengthDelimited).fork(),
options
).join();
/* UpdateGamePlaytime update_game_playtime = 2; */ /* UpdateGamePlaytime update_game_playtime = 2; */
if (message.payload.oneofKind === "updateGamePlaytime") if (message.payload.oneofKind === "updateGamePlaytime")
UpdateGamePlaytime.internalBinaryWrite(message.payload.updateGamePlaytime, writer.tag(2, WireType.LengthDelimited).fork(), options).join(); UpdateGamePlaytime.internalBinaryWrite(
let u = options.writeUnknownFields; message.payload.updateGamePlaytime,
writer.tag(2, WireType.LengthDelimited).fork(),
options
).join();
const u = options.writeUnknownFields;
if (u !== false) if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); (u == true ? UnknownFieldHandler.onWrite : u)(
this.typeName,
message,
writer
);
return writer; return writer;
} }
} }