feat: add mew config param isP2PUploadDisabled

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

@@ -36,6 +36,7 @@ export class Core<TStream extends Stream = Stream> {
 
   /** Default configuration for stream settings. */
   static readonly DEFAULT_STREAM_CONFIG: StreamConfig = {
+    isP2PUploadDisabled: false,
     isP2PDisabled: false,
     simultaneousHttpDownloads: 2,
     simultaneousP2PDownloads: 3,
@@ -162,6 +163,9 @@ export class Core<TStream extends Stream = Stream> {
     if (this.secondaryStreamConfig.isP2PDisabled) {
       this.destroyStreamLoader("secondary");
     }
+
+    this.mainStreamLoader?.sendBroadcastAnnouncement();
+    this.secondaryStreamLoader?.sendBroadcastAnnouncement();
   }
 
   /**

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

@@ -583,6 +583,10 @@ export class HybridLoader {
     this.levelChangedTimestamp = performance.now();
   }
 
+  sendBroadcastAnnouncement() {
+    this.p2pLoaders.currentLoader.broadcastAnnouncement();
+  }
+
   updatePlayback(position: number, rate: number) {
     const isRateChanged = this.playback.rate !== rate;
     const isPositionChanged = this.playback.position !== position;

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

@@ -114,12 +114,16 @@ export class P2PLoader {
   }
 
   private onPeerConnected = (peer: Peer) => {
+    if (this.config.isP2PUploadDisabled) return;
+
     const { httpLoading, loaded } = this.getSegmentsAnnouncement();
     peer.sendSegmentsAnnouncementCommand(loaded, httpLoading);
   };
 
   broadcastAnnouncement = () => {
-    if (this.isAnnounceMicrotaskCreated) return;
+    if (this.isAnnounceMicrotaskCreated || this.config.isP2PUploadDisabled) {
+      return;
+    }
 
     this.isAnnounceMicrotaskCreated = true;
     queueMicrotask(() => {
@@ -142,6 +146,10 @@ export class P2PLoader {
       segmentExternalId,
     );
     if (!segment) return;
+    if (this.config.isP2PUploadDisabled) {
+      peer.sendSegmentAbsentCommand(segmentExternalId, requestId);
+      return;
+    }
 
     const swarmId = this.config.swarmId ?? this.streamManifestUrl;
     const streamSwarmId = StreamUtils.getStreamSwarmId(swarmId, this.stream);

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

@@ -80,7 +80,8 @@ export type DynamicStreamProperties =
   | "p2pErrorRetries"
   | "validateP2PSegment"
   | "httpRequestSetup"
-  | "isP2PDisabled";
+  | "isP2PDisabled"
+  | "isP2PUploadDisabled";
 
 /**
  * Represents a dynamically modifiable configuration, allowing updates to selected CoreConfig properties at runtime.
@@ -186,6 +187,16 @@ export type CoreConfig = Partial<StreamConfig> &
 
 /** Configuration options for the Core functionality, including network and processing parameters. */
 export type StreamConfig = {
+  /**
+   * Indicates if Peer-to-Peer (P2P) upload is disabled for the stream.
+   * If `true`, the stream only downloads segments without uploading to peers.
+   *
+   * @default
+   * ```typescript
+   * isP2PUploadDisabled: false
+   * ```
+   */
+  isP2PUploadDisabled: boolean;
   /**
    * Indicates whether Peer-to-Peer (P2P) functionality is disabled for the stream.
    * If set to true, P2P functionality is disabled for the stream.
@@ -387,7 +398,11 @@ export type StreamConfig = {
    * validateP2PSegment: undefined
    * ```
    */
-  validateP2PSegment?: (url: string, byteRange: ByteRange | undefined, data: ArrayBuffer) => Promise<boolean>;
+  validateP2PSegment?: (
+    url: string,
+    byteRange: ByteRange | undefined,
+    data: ArrayBuffer,
+  ) => Promise<boolean>;
 
   /**
    * Optional function to customize the setup of HTTP requests for segment downloads.