Feat: Segment validation

packages/p2p-media-loader-core/src/p2p/peer-protocol.ts

@@ -5,7 +5,10 @@ import { Settings } from "../types";
 
 export type PeerSettings = Pick<
   Settings,
-  "p2pNotReceivingBytesTimeoutMs" | "webRtcMaxMessageSize" | "p2pErrorRetries"
+  | "p2pNotReceivingBytesTimeoutMs"
+  | "webRtcMaxMessageSize"
+  | "p2pErrorRetries"
+  | "validateP2Psegment"
 >;
 
 export class PeerProtocol {

packages/p2p-media-loader-core/src/p2p/peer.ts

@@ -45,6 +45,7 @@ export class Peer {
     this.id = Peer.getPeerIdFromConnection(connection);
     this.peerProtocol = new PeerProtocol(connection, settings, {
       onSegmentChunkReceived: this.onSegmentChunkReceived,
+      // eslint-disable-next-line @typescript-eslint/no-misused-promises
       onCommandReceived: this.onCommandReceived,
     });
 
@@ -62,7 +63,7 @@ export class Peer {
     if (this.httpLoadingSegments.has(externalId)) return "http-loading";
   }
 
-  private onCommandReceived = (command: Command.PeerCommand) => {
+  private onCommandReceived = async (command: Command.PeerCommand) => {
     switch (command.c) {
       case PeerCommandType.SegmentsAnnouncement:
         this.loadedSegments = new Set(command.l);
@@ -106,9 +107,15 @@ export class Peer {
           return;
         }
 
-        const isWrongBytes = request.loadedBytes !== request.totalBytes;
+        let isValid = true;
+        if (this.settings.validateP2Psegment) {
+          isValid = await this.settings.validateP2Psegment(
+            request.segment.url,
+            request.segment.byteRange,
+          );
+        }
 
-        if (isWrongBytes) {
+        if (!isValid) {
           request.clearLoadedBytes();
           this.cancelSegmentDownloading("peer-response-bytes-mismatch");
           this.destroy();

packages/p2p-media-loader-core/src/types.d.ts

@@ -53,6 +53,7 @@ export type Settings = {
   httpNotReceivingBytesTimeoutMs: number;
   httpErrorRetries: number;
   p2pErrorRetries: number;
+  validateP2Psegment?: (url: string, byteRange?: ByteRange) => Promise<boolean>;
 };
 
 export type CoreEventHandlers = {