eml_rtmp_session

defmodule RtmpSession.Events do

  @type t :: RtmpSession.Events.PeerChunkSizeChanged.t |

    RtmpSession.Events.SelfChunkSizeChanged.t |

    RtmpSession.Events.ConnectionRequested.t |

    RtmpSession.Events.ReleaseStreamRequested.t |

    RtmpSession.Events.PublishStreamRequested.t |

    RtmpSession.Events.StreamMetaDataChanged.t |

    RtmpSession.Events.AudioVideoDataReceived.t |

    RtmpSession.Events.UnhandleableAmf0Command.t |

    RtmpSession.Events.PublishingFinished.t |

    RtmpSession.Events.PlayStreamRequested.t |

    RtmpSession.Events.PlayStreamFinished.t

  defmodule PeerChunkSizeChanged do
    @type t :: %__MODULE__{

      new_chunk_size: pos_integer()

    }

    defstruct new_chunk_size: nil
  end

  defmodule SelfChunkSizeChanged do
    @type t :: %__MODULE__{

      new_chunk_size: pos_integer()

    }

    defstruct new_chunk_size: nil
  end

  defmodule ConnectionRequested do
    @type t :: %__MODULE__{

      request_id: integer(),

      app_name: RtmpSession.app_name

    }

    defstruct request_id: nil,
              app_name: nil
  end

  defmodule ReleaseStreamRequested do
    @type t :: %__MODULE__{

      request_id: integer(),

      app_name: RtmpSession.app_name,

      stream_key: RtmpSession.stream_key

    }

    defstruct request_id: nil,
              app_name: nil,
              stream_key: nil
  end

  defmodule PublishStreamRequested do
    @type t :: %__MODULE__{

      request_id: integer(),

      app_name: RtmpSession.app_name,

      stream_key: RtmpSession.stream_key,

      stream_id: non_neg_integer

    }

    defstruct request_id: nil,
              app_name: nil,
              stream_key: nil,
              stream_id: nil
  end

  defmodule PublishingFinished do
    @type t :: %__MODULE__{

      app_name: RtmpSession.app_name,

      stream_key: RtmpSession.stream_key

    }

    defstruct app_name: nil,
              stream_key: nil
  end

  defmodule StreamMetaDataChanged do
    @type t :: %__MODULE__{

      app_name: RtmpSession.app_name,

      stream_key: RtmpSession.stream_key,

      meta_data: RtmpSession.StreamMetadata.t

    }

    defstruct app_name: nil,
              stream_key: nil,
              meta_data: nil
  end

  defmodule AudioVideoDataReceived do
    @type t :: %__MODULE__{

      app_name: RtmpSession.app_name,

      stream_key: RtmpSession.stream_key,

      data_type: :audio | :video,

      data: <<>>,

      timestamp: non_neg_integer,

      received_at_timestamp: pos_integer

    }

    defstruct app_name: nil,
              stream_key: nil,
              data_type: nil, 
              data: <<>>,
              timestamp: nil,
              received_at_timestamp: nil
  end

  defmodule UnhandleableAmf0Command do
    @type t :: %__MODULE__{

      command: %RtmpSession.Messages.Amf0Command{}

    }

    defstruct command: nil
  end

  defmodule PlayStreamRequested do
    @type video_type :: :live | :recorded | :any

    @type t :: %__MODULE__{

      request_id: integer,

      app_name: RtmpSession.app_name,

      stream_key: RtmpSession.stream_key,

      video_type: video_type,

      start_at: non_neg_integer,

      duration: integer,

      reset: boolean,

      stream_id: non_neg_integer

    }

    defstruct request_id: nil,
              app_name: nil,
              stream_key: nil,
              video_type: nil,
              start_at: nil,
              duration: nil,
              reset: nil,
              stream_id: nil
  end

  defmodule PlayStreamFinished do
    @type t :: %__MODULE__{

      app_name: RtmpSession.app_name,

      stream_key: RtmpSession.stream_key

    }

    defstruct app_name: nil,
              stream_key: nil
  end

end