wip

Author: lukepolo

src/matches/match-relay/match-relay.service.ts

@@ -72,7 +72,6 @@ export class MatchRelayService {
   ) {
     const broadcast = this.broadcasts[matchId];
     if (!broadcast) {
-      this.logger.error(`Broadcast not found for matchId ${matchId}`);
       this.relayError(
         response,
         404,
@@ -102,7 +101,6 @@ export class MatchRelayService {
 
     const broadcast = this.broadcasts[matchId];
     if (!broadcast) {
-      this.logger.error(`Broadcast not found for matchId ${matchId}`);
       this.relayError(
         response,
         404,
@@ -198,7 +196,6 @@ export class MatchRelayService {
     fragmentIndex: number,
   ): void {
     if (!this.broadcasts[matchId]) {
-      this.logger.log(`Creating new match broadcast for matchId ${matchId}`);
       this.broadcasts[matchId] = [];
     }
 
@@ -250,7 +247,7 @@ export class MatchRelayService {
         })
         .catch((error: Error) => {
           this.logger.error(
-            `Cannot gzip ${totalBuffer.length} bytes: ${error}`,
+            `cannot gzip: ${error}`,
           );
           broadcast[fragmentIndex][field].gipped = false;
           broadcast[fragmentIndex][field].data = totalBuffer;

src/matches/match-relay/types/fragment.types.ts

@@ -0,0 +1,36 @@
+export type StartFieldData = {
+  data?: Buffer;
+  gipped?: boolean;
+  signup_fragment?: number;
+  tick?: number;
+  tps?: number;
+  map?: string;
+  keyframe_interval?: number;
+  protocol?: number;
+  [key: string]: any;
+};
+
+export type FullFieldData = {
+  data?: Buffer;
+  gipped?: boolean;
+  tick?: number;
+  [key: string]: any;
+};
+
+export type DeltaFieldData = {
+  data?: Buffer;
+  gipped?: boolean;
+  timestamp?: number;
+  endtick?: number;
+  [key: string]: any;
+};
+
+export type Fragment = {
+  start?: StartFieldData;
+  full?: FullFieldData;
+  delta?: DeltaFieldData;
+  [key: string]: any;
+};
+
+export type Broadcast = Fragment[];
+