add pipeline classes

src/pipelines/basePipeline.ts

@@ -0,0 +1,4 @@
+export default abstract class Pipeline {
+  public abstract loadRemoteAsset(uri: string): void;
+  public abstract loadLocalAsset(asset: string | ArrayBuffer): void;
+}

src/pipelines/mse/dash/dashPipeline.ts

@@ -0,0 +1,11 @@
+import Pipeline from '@/pipelines/basePipeline.ts';
+
+export default class DashPipeline extends Pipeline {
+  public loadLocalAsset(asset: string | ArrayBuffer): void {
+    //TODO
+  }
+
+  public loadRemoteAsset(uri: string): void {
+    //TODO
+  }
+}

src/pipelines/mse/hls/hlsPipeline.ts

@@ -0,0 +1,11 @@
+import Pipeline from '@/pipelines/basePipeline.ts';
+
+export default class HlsPipeline extends Pipeline {
+  public loadLocalAsset(asset: string | ArrayBuffer): void {
+    //TODO
+  }
+
+  public loadRemoteAsset(uri: string): void {
+    //TODO
+  }
+}

src/pipelines/mse/streamingPipeline.ts

@@ -0,0 +1,7 @@
+import Pipeline from '@/pipelines/basePipeline.ts';
+
+export default abstract class MsePipeLine extends Pipeline {
+  public abstract loadLocalAsset(asset: string | ArrayBuffer): void;
+
+  public abstract loadRemoteAsset(uri: string): void;
+}

src/pipelines/native/nativePipeline.ts

@@ -0,0 +1,11 @@
+import Pipeline from '@/pipelines/basePipeline.ts';
+
+export default class NativePipeline extends Pipeline {
+  public loadLocalAsset(asset: string | ArrayBuffer): void {
+    //TODO
+  }
+
+  public loadRemoteAsset(uri: string): void {
+    //TODO
+  }
+}

src/player/errors.ts

@@ -0,0 +1,20 @@
+export enum ErrorCategory {
+  Pipeline,
+}
+
+export enum ErrorCode {
+  // pipeline
+  NoSupportedPipelines,
+}
+
+export default abstract class PlayerError {
+  public abstract readonly category: ErrorCategory;
+  public abstract readonly code: ErrorCode;
+  public abstract readonly critical: boolean;
+}
+
+export class NoSupportedPipelinesError extends PlayerError {
+  public readonly category = ErrorCategory.Pipeline;
+  public readonly code = ErrorCode.NoSupportedPipelines;
+  public readonly critical = true;
+}

src/player/events.ts

@@ -1,6 +1,9 @@
+import PlayerError from '@/player/errors.ts';
+
 export const Events = {
   EnterPictureInPictureMode: 'EnterPictureInPictureMode',
   LeavePictureInPictureMode: 'LeavePictureInPictureMode',
+  Error: 'Error',
 } as const;
 
 abstract class PlayerEvent {
@@ -15,7 +18,18 @@ export class LeavePictureInPictureModeEvent extends PlayerEvent {
   public readonly type = Events.LeavePictureInPictureMode;
 }
 
+export class ErrorEvent extends PlayerEvent {
+  public readonly type = Events.Error;
+  public readonly error: PlayerError;
+
+  public constructor(error: PlayerError) {
+    super();
+    this.error = error;
+  }
+}
+
 export interface EventToTypeMap {
   [Events.EnterPictureInPictureMode]: EnterPictureInPictureModeEvent;
   [Events.LeavePictureInPictureMode]: LeavePictureInPictureModeEvent;
+  [Events.Error]: ErrorEvent;
 }

src/player/player.ts

@@ -4,8 +4,11 @@ import Logger from '../utils/logger.ts';
 import { getDefaultPlayerConfiguration } from './configuration.ts';
 import EventEmitter from '../utils/eventEmitter.ts';
 
-import { Events, EnterPictureInPictureModeEvent, LeavePictureInPictureModeEvent } from './events.ts';
+import { Events, EnterPictureInPictureModeEvent, LeavePictureInPictureModeEvent, ErrorEvent } from './events.ts';
 import type { EventToTypeMap } from './events.ts';
+import Pipeline from '@/pipelines/basePipeline.ts';
+import NativePipeline from '@/pipelines/native/nativePipeline.ts';
+import { NoSupportedPipelinesError } from '@/player/errors.ts';
 
 enum PlaybackState {
   Playing = 'Playing',
@@ -36,8 +39,14 @@ interface PlayerVideoTrack {}
 interface PlayerStats {}
 
 export default class Player {
+  private static readonly pipelinesMap: Map<string, Pipeline> = new Map();
+
   public static readonly Events = Events;
 
+  public static registerPipeline(mimeType: string, pipeline: Pipeline) {
+    Player.pipelinesMap.set(mimeType, pipeline);
+  }
+
   private videoElement: HTMLVideoElement | null = null;
   private pictureInPictureWindow: PictureInPictureWindow | null = null;
   private configuration: PlayerConfiguration = getDefaultPlayerConfiguration();
@@ -388,13 +397,35 @@ export default class Player {
     // TODO
   }
 
+  private load(mimeType: string, pipelineHandler: (pipeline: Pipeline) => void): void {
+    const pipeline = Player.pipelinesMap.get(mimeType);
+
+    if (pipeline) {
+      return pipelineHandler(pipeline);
+    }
+
+    if (this.videoElement?.canPlayType(mimeType)) {
+      return pipelineHandler(new NativePipeline());
+    }
+
+    this.logger.warn('no supported pipelines found for ', mimeType);
+
+    this.eventEmitter.emit(Events.Error, new ErrorEvent(new NoSupportedPipelinesError()));
+  }
+
   public loadRemoteAsset(uri: string, mimeType: string): void {
-    this.logger.info(uri, mimeType);
-    // TODO
+    if (this.videoElement === null) {
+      return this.warnAttempt('loadRemoteAsset');
+    }
+
+    return this.load(mimeType, (pipeline) => pipeline.loadRemoteAsset(uri));
   }
 
   public loadLocalAsset(asset: string | ArrayBuffer, mimeType: string): void {
-    this.logger.info(asset, mimeType);
-    // TODO
+    if (this.videoElement === null) {
+      return this.warnAttempt('loadLocalAsset');
+    }
+
+    return this.load(mimeType, (pipeline) => pipeline.loadLocalAsset(asset));
   }
 }