Vega Matter投屏集成

[offers.matter-casting]
vendor-id = <<App Specific VID granted by CSA, eg. 65521>>
product-id = <<App Specific PID granted by CSA, eg. 5678>>
vendor-name = "Your App Name"

schema-version = 1

[package]
title = "<应用标题>"
id = "com.amazondeveloper.media.sample"

# 账户登录的服务组件（无界面，没有 UI）

[components]

[[components.interactive]]
id = "com.amazondeveloper.media.sample.main"
runtime-module = "/com.amazon.kepler.keplerscript.runtime.loader_2@IKeplerScript_2_0"
launch-type = "singleton"
categories = ["com.amazon.category.main", "com.amazon.category.kepler.media"]

# Matter Casting 身份
[[components.service]]
id = "com.amazondeveloper.media.sample.interface.provider"
runtime-module = "/com.amazon.kepler.headless.runtime.loader_2@IKeplerScript_2_0"
launch-type = "singleton"

# 内容启动器集群 

[processes]

[[processes.group]]
component-ids = ["com.amazondeveloper.media.sample.main"]

[[processes.group]]
component-ids = ["com.amazondeveloper.media.sample.interface.provider"]

# 媒体控制集群 

# 账号登录集群 
[offers.matter-casting]
vendor-id = 65521
product-id = 5678
vendor-name = "Your app name"

[[offers.interaction]]
id = "com.amazondeveloper.media.sample.main"

[[offers.service]]
id = "com.amazondeveloper.media.sample.interface.provider"
required-privileges = ["com.amazon.multimedia.privilege.session.manage"]

[[offers.module]]
id = "/com.amazondeveloper.media.sample.module@ISomeUri1"
includes-messages = ["pkg://com.amazondeveloper.media.sample.main"]

# 将账户登录状态读取到服务组件 

[[message]]
uri = "pkg://com.amazondeveloper.media.sample.main"
sender-privileges = ["*"]
receiver-privileges = ["self"]

# 目标导航集群 

[[extras]]
key = "interface.provider"
component-id = "com.amazondeveloper.media.sample.main"

[extras.value.application]

# 这种格式故意在“media”后面添加了一个句点 (.)。
[[extras.value.application.interface]]
interface_name = "com.amazon.kepler.media.IContentLauncherServer"
attribute_options = ["partner-id"]
static-values = { partner-id = "<Your partner id>" }

# 媒体控制集群
[[extras.value.application.interface]]
interface_name = "com.amazon.kepler.media.IMediaPlaybackServer"
command_options = [
    "StartOver",
    "Previous",
    "Next",
    "SkipForward",
    "SkipBackward",
]
attribute_options = ["AudioAdvanceMuted"]
features = ["AdvancedSeek", "VariableSpeed", "AudioTracks", "TextTracks"]

# 账号登录集群
[[extras.value.application.interface]]
interface_name = "com.amazon.kepler.media.IAccountLoginServer"
attribute_options = ["Status"]
# 将账户登录状态读取到服务组件
override_attribute_component = { Status = "com.amazondeveloper.media.sample.interface.provider" }

# 目标导航集群
[[extras.value.application.interface]]
interface_name = "com.amazon.kepler.media.ITargetNavigator"

# --- Required Modules ---

[needs]

[[needs.module]]
id = "/com.amazon.kepler.media@IContentLauncher1"

[[needs.module]]
# 这种格式故意在“media”后面添加了一个句点 (.)。
id = "/com.amazon.kepler.media.@IAccountLogin1"

{ 
  "dependencies": { 
    //内容启动器   
    "@amazon-devices/kepler-media-content-launcher": "^2.0.0", 

    //媒体控件   
    "@amazon-devices/kepler-media-controls": "~1.0.0", 
    "@amazon-devices/kepler-media-types": "~1.0.0", 

    //账号登录  
    "@amazon-devices/kepler-media-account-login": "^1.1.0", 
    "@amazon-devices/headless-task-manager": "^1.1.0", 

    "@amazon-devices/vega-target-navigator-provider": "*" 
  } 
}

export class ContentLauncherHandler {

  // --- Matter 0x00 LaunchContent（可选，需要CS功能）及
  // 0x01 LaunchURL（可选，需要UP功能）---
  //通过相同的handleLaunchContent接口支持内容启动。
  //因此，无论使用哪条命令（LaunchURL或LaunchContent），手机都可以 
  //发送，内容应用程序将以相同的方式处理。
  // 重要 — 响应规范：
  //   提供商必须解析返回的Promise <ILauncherResponse>。Matter Casting
  // 服务强制执行25秒的命令超时，因此提供商 
  //   应在20秒内返回ILauncherResponse，以便
  // 用于传输和处理开销。如果未
  // 在25秒内收到回复，手机应用程序将收到超时错误。
  async handleLaunchContent(
    contentSearch: IContentSearch,
    autoPlay: boolean,
    _optionalFields: ILaunchContentOptionalFields,
  ): Promise<ILauncherResponse> {

    if (autoPlay) {
      console.log('Content Launcher: autoPlay=true, starting playback');
    } else {
      console.log('Content Launcher: autoPlay=false, showing search results');
    }

    //返回SUCCESS — Matter Casting服务将其转译为 
    //状态为SUCCESS的Matter LauncherResponse (0x02) 
    return this.factory
      .makeLauncherResponseBuilder()
      .contentLauncherStatus(ContentLauncherStatusType.SUCCESS)
      .optionalData('Launch handled successfully')
      .build();

    // 其他状态选项：
    //   ContentLauncherStatusType.AUTH_FAILED      — 用户未获授权
    //   ContentLauncherStatusType.URL_NOT_AVAILABLE — 未找到内容/其他错误
  }
}

export class MediaControlHandlerAsync implements IMediaControlHandlerAsync {

  // --- Matter 0x00 Play (mandatory) ---
  async handlePlay(_sessionId?: IMediaSessionId): Promise<void> {
    this.state.playbackStatus = PlaybackStatus.PLAYING;
    this.state.playbackSpeed = 1.0;
    this.pushState();
  }

  // --- Matter 0x01 Pause (mandatory) ---
  async handlePause(
    _sessionId?: IMediaSessionId,
    _context?: ICommandContext,
  ): Promise<void> {
    this.state.playbackStatus = PlaybackStatus.PAUSED;
    this.pushState();
  }

  // --- Matter 0x02 Stop (mandatory) ---
  async handleStop(_sessionId?: IMediaSessionId): Promise<void> {
    this.state.playbackStatus = PlaybackStatus.NOT_PLAYING;
    this.state.currentPosition = { seconds: 0, nanoseconds: 0 };
    this.pushState();
  }

  // --- Matter 0x03 StartOver (Optional) ---
  async handleStartOver(_sessionId?: IMediaSessionId): Promise<void> {
    this.state.playbackStatus = PlaybackStatus.PLAYING;
    this.state.currentPosition = { seconds: 0, nanoseconds: 0 };
    this.state.playbackPosition.position = { seconds: 0, nanoseconds: 0 };
    this.pushState();
  }

  // --- Matter 0x04 Previous (optional) ---
  async handlePrevious(): Promise<void> {
    // 跳到上一曲目的业务逻辑 
  }

  // --- Matter 0x05 Next (optional) ---
  async handleNext(_sessionId?: IMediaSessionId): Promise<void> {
    // 跳到下一曲目的业务逻辑 
  }

  // --- Matter 0x06 Rewind（可选，需用到变速功能）---
  async handleRewind(_sessionId?: IMediaSessionId): Promise<void> {
    this.state.playbackStatus = PlaybackStatus.PLAYING;
    if (this.state.playbackSpeed > -5.0) {
      this.state.playbackSpeed =
        this.state.playbackSpeed <= -1.0
          ? this.state.playbackSpeed - 1.0
          : -1.0;
    }
    this.pushState();
  }

  // --- Matter 0x07 FastForward (optional, requires VariableSpeed feature) ---
  async handleFastForward(_sessionId?: IMediaSessionId): Promise<void> {
    this.state.playbackStatus = PlaybackStatus.PLAYING;
    if (this.state.playbackSpeed < 5.0) {
      this.state.playbackSpeed =
        this.state.playbackSpeed >= 1.0
          ? this.state.playbackSpeed + 1.0
          : 1.0;
    }
    this.pushState();
  }

  // --- Matter 0x08 SkipForward (optional) ---
  async handleSkipForward(
    delta: ITimeValue,
    _sessionId?: IMediaSessionId,
  ): Promise<void> {
    this.state.currentPosition = {
      seconds: this.state.currentPosition.seconds + delta.seconds,
      nanoseconds: this.state.currentPosition.nanoseconds + delta.nanoseconds,
    };
    this.state.playbackPosition.position = this.state.currentPosition;
    this.pushState();
  }

  // --- Matter 0x09 SkipBackward (optional) ---
  async handleSkipBackward(
    delta: ITimeValue,
    _sessionId?: IMediaSessionId,
  ): Promise<void> {
    this.state.currentPosition = {
      seconds: Math.max(0, this.state.currentPosition.seconds - delta.seconds),
      nanoseconds: 0,
    };
    this.state.playbackPosition.position = this.state.currentPosition;
    this.pushState();
  }

  // --- Matter 0x0B Seek（可选，需要 AdvancedSeek 功能）---
  async handleSeek(
    position: ITimeValue,
    _sessionId?: IMediaSessionId,
  ): Promise<void> {
    this.state.currentPosition = position;
    this.state.playbackPosition.position = position;
    this.pushState();
  }

  // --- Matter 0x0C ActivateAudioTrack（可选，需要 AudioTracks 功能）---
  async handleSetAudioTrack(
    audioTrack: ITrack,
    _sessionId?: IMediaSessionId,
  ): Promise<void> {
    // 激活所选音轨的业务逻辑。
  }

  //---Matter 0x0D ActivateTextTrack（可选，需要 TextTracks 功能）---
  async handleEnableTextTrack(
    textTrack: ITrack,
    _sessionId?: IMediaSessionId,
  ): Promise<void> {
    // 启用所选文字轨道的业务逻辑 
  }

  // --- Matter 0x0E DeactivateTextTrack（可选，需要 TextTracks 功能）---
  async handleDisableTextTrack(
    _sessionId?: IMediaSessionId,
  ): Promise<void> {
    // 禁用活动文字轨道的业务逻辑。
  }
}

export class AccountLoginWrapper {

  createAccountLoginHandler(): IAccountLoginHandlerAsync {
    return {

      // --- Matter 0x00 GetSetupPIN ---
      // 内容应用程序为给定账户生成设置 PIN。
      handleGetSetupPin: async (accountId: string): Promise<string> => {
        console.log(`[KCP] handleGetSetupPin, accountId=${accountId}`);
        const setupPin = '12345678';
        return setupPin;
      },

      // --- Matter 0x02 Login ---
      // 内容应用程序验证PIN并将用户登录。
      handleLogin: async (accountId: string, pin: string): Promise<void> => {
        console.log(`[KCP] handleLogin, accountId=${accountId}`);
        await AccountLoginWrapper.saveLoginStatus(true);
        const status = accountLoginServerComponent
          .makeStatusBuilder()
          .status(StatusType.SIGNED_IN)
          .build();
        this.accountLoginServer?.updateStatus(status);
      },

      // --- Matter 0x03 Logout ---
      // 播放器发送此消息以结束用户的会话。
      handleLogout: async (): Promise<void> => {
        console.log('[KCP] handleLogout');
        await AccountLoginWrapper.saveLoginStatus(false);
        const status = accountLoginServerComponent
          .makeStatusBuilder()
          .status(StatusType.SIGNED_OUT)
          .build();
        this.accountLoginServer?.updateStatus(status);
      },
    };
  }
}

const server: IMediaControlServerAsync =
  MediaControlServerComponentAsync.getOrMakeServer();

// 任何播放状态更改后，重建并推送会话状态。
const mediaPlayerState = new MediaPlayerState(); // from your MediaPlayerState class

//示例：用户按下播放键。
mediaPlayerState.playbackStatus = PlaybackStatus.PLAYING;
mediaPlayerState.playbackSpeed = 1.0;
server.updateMediaSessionStates([mediaPlayerState.getServerState()]);

//示例：用户想要定位至 5 分钟处。
mediaPlayerState.currentPosition = { seconds: 300, nanoseconds: 0 };
mediaPlayerState.playbackPosition.position = { seconds: 300, nanoseconds: 0 };
server.updateMediaSessionStates([mediaPlayerState.getServerState()]);

// 示例：用户按下暂停键。
mediaPlayerState.playbackStatus = PlaybackStatus.PAUSED;
server.updateMediaSessionStates([mediaPlayerState.getServerState()]);

// 示例：内容发生更改（例如已开始下一集或内容启动器启动了
// 一部新电影）。
mediaPlayerState.mediaId = {
  contentId: 'episode-002',
  catalogName: 'my-catalog-v1',
};
mediaPlayerState.playbackStatus = PlaybackStatus.PLAYING;
mediaPlayerState.currentPosition = { seconds: 0, nanoseconds: 0 };
mediaPlayerState.playbackPosition.position = { seconds: 0, nanoseconds: 0 };
server.updateMediaSessionStates([mediaPlayerState.getServerState()]);

const server: IAccountLoginServerAsync =
  new AccountLoginServerComponent().getOrMakeServer();

// 示例：用户登录。
const signedInStatus = new AccountLoginServerComponent()
  .makeStatusBuilder()
  .status(StatusType.SIGNED_IN)
  .build();
server.updateStatus(signedInStatus);

// 示例：用户注销。
const signedOutStatus = new AccountLoginServerComponent()
  .makeStatusBuilder()
  .status(StatusType.SIGNED_OUT)
  .build();
server.updateStatus(signedOutStatus);