mediabus-rtp-0.2.0.0: mediabus-demo-rtp-alaw-player/Main.hs

module Main where

import           System.Environment
import           Data.MediaBus.AsyncConduit
import           Conduit
import           Data.MediaBus
import           Data.MediaBus.Rtp

{- Send test data with:
#!/bin/bash

PORT=${1?port missing}
MY_IP=${2?host ip missing}
FNAME=${3:-28797-04.ogg}
FILE=$(realpath $(dirname ${0})/$FNAME)

gst-launch-1.0  uridecodebin uri=file://$FILE ! audioconvert ! audioresample !  audio/x-raw,format=S16LE,rate=8000,channels=1 ! alawenc ! rtppcmapay pt=8 mtu=172 min-ptime=10000000 max-ptime=200000000  ptime-multiple=5000000 ! udpsink host=$MY_IP port=$PORT
-}
maxFrames :: Int
maxFrames = 15000

main :: IO ()
main = do
    args <- getArgs
    case args of
        [] -> mainASync
        (_ : _) -> mainSync

mainASync :: IO ()
mainASync = runResourceT $
    withAsyncPolledSource 20
                          (rtpAlaw16kHzS16Source 10000 "127.0.01" 5)
                          (\(_, !src) -> runConduit (src .|
                                                         exitAfterC maxFrames .|
                                                         concealMissing blank .|
                                                         streamDebugPlaybackSink))

mainSync :: IO ()
mainSync = runConduitRes (rtpAlaw16kHzS16Source 10000 "127.0.01" 20 .|
                              exitAfterC maxFrames .|
                              streamDebugPlaybackSink)