media.py

Go to the documentation of this file.

import json
import socketserver
 
 
def find_free_port():
    with socketserver.TCPServer(("localhost", 0), None) as s:
        return s.server_address[1]
 
 
def create_call_query(peer_id, token, target_id):
    video_port = find_free_port()
    video_rtcp_port = find_free_port()
    audio_port = find_free_port()
    audio_rtcp_port = find_free_port()
 
    answer_query = (
        "{"
        '    "request_type":"MEDIA",'
        '    "command":"CALL",'
        '    "params":{'
        f'       "peer_id":"{peer_id}",'
        f'       "token":"{token}",'
        f'       "target_id":"{target_id}",'
        '        "constraints":{'
        '            "video_params":{'
        '                "band_width":1500,'
        '                "codec":"H264",'
        '                "payload_type":96,'  # ここで指定するpayload_typeはgStreamerで指定するものと一致させること。番号はRFCに沿っていれば何番でもよい
        '                "sampling_rate":90000'
        "            },"
        '            "audio_params":{'
        '                "band_width":1500,'
        '                "codec":"OPUS",'
        '                "payload_type":111,'  # ここで指定するpayload_typeはgStreamerで指定するものと一致させること。番号はRFCに沿っていれば何番でもよい
        '                "sampling_rate":48000'
        "            }"
        "        },"
        '        "redirect_params":{'
        '            "video":{'
        '               "ip_v4":"127.0.0.1",'
        f'               "port":{video_port}'
        "            },"
        '            "video_rtcp":{'
        '                "ip_v4":"127.0.0.1",'
        f'                "port":{video_rtcp_port}'
        "            },"
        '            "audio":{'
        '                "ip_v4":"127.0.0.1",'
        f'               "port":{audio_port}'
        "            },"
        '            "audio_rtcp":{'
        '                "ip_v4":"127.0.0.1",'
        f'               "port":{audio_rtcp_port}'
        "            }"
        "        }"
        "    }"
        "}"
    )
    return answer_query
 
 
def create_answer_query(media_connection_id):
    video_port = find_free_port()
    video_rtcp_port = find_free_port()
    audio_port = find_free_port()
    audio_rtcp_port = find_free_port()
 
    answer_query = (
        "{"
        '    "request_type":"MEDIA",'
        '    "command":"ANSWER",'
        '    "params":{'
        f'        "media_connection_id":"{media_connection_id}",'
        '        "answer_query":{'
        '            "constraints":{'
        '                "video_params":{'
        '                    "band_width":1500,'
        '                    "codec":"H264",'
        '                    "payload_type":96,'  # ここで指定するpayload_typeはgStreamerで指定するものと一致させること。番号はRFCに沿っていれば何番でもよい
        '                    "sampling_rate":90000'
        "                },"
        '                "audio_params":{'
        '                    "band_width":1500,'
        '                    "codec":"OPUS",'
        '                    "payload_type":111,'  # ここで指定するpayload_typeはgStreamerで指定するものと一致させること。番号はRFCに沿っていれば何番でもよい
        '                    "sampling_rate":48000'
        "                }"
        "            },"
        '            "redirect_params":{'
        '                "video":{'
        '                    "ip_v4":"127.0.0.1",'
        f'                    "port":{video_port}'
        "                },"
        '                "video_rtcp":{'
        '                    "ip_v4":"127.0.0.1",'
        f'                    "port":{video_rtcp_port}'
        "                },"
        '                "audio":{'
        '                    "ip_v4":"127.0.0.1",'
        f'                    "port":{audio_port}'
        "                },"
        '                "audio_rtcp":{'
        '                    "ip_v4":"127.0.0.1",'
        f'                    "port":{audio_rtcp_port}'
        "                }"
        "            }"
        "        }"
        "    }"
        "}"
    )
    return answer_query
 
 
def create_media_status_request(media_connection_id):
    return (
        "{"
        '    "request_type":"MEDIA",'
        '    "command":"STATUS",'
        '    "params":{'
        f'       "media_connection_id":"{media_connection_id}"'
        "    }"
        "}"
    )
 
 
def parse_media_info(object):
    return (
        # RTPの送信先IPアドレス
        object["ip_v4"],
        # RTPの送信先ポート
        object["port"],
        # RTCPの送信先IPアドレス
        object["ip_v4"],
        # RTCPの送信先ポート
        object["port"],
    )