convert.php

#!/usr/bin/env php
<?php
include 'vendor/autoload.php';

use M3uParser\M3uParser;

$obj = new M3uParser();
$obj->addDefaultTags();

$files = glob('m3u/*.m3u');

$a = [];
foreach ($files as $file) {
    $data = $obj->parseFile($file);

    foreach ($data as $entry) {
        $suffix = '';
        $normalizedChannelName = normalizeChannelName($entry->getExtTags()[0]->getTitle());
        $normalizedChannelKey = normalizeChannelKey($normalizedChannelName);

        // check for duplicate channel names
        if (isset($a[$normalizedChannelKey])) {
            if ($a[$normalizedChannelKey]['path'] == $entry->getPath()) {
                echo "Skipping duplicate entry for '$normalizedChannelName'." . PHP_EOL;
                continue;
            }
            // distinguish them by URL hash
            $suffix = ' | ' . sha1($entry->getPath());
        }
        // check if URL is valid
        if (!validUrl($entry->getPath())) {
            echo "'$normalizedChannelName' does not have a valid URL; skipping." . PHP_EOL;
            continue;
        }
        // check if stream is playable
        if (!validStream($entry->getPath())) {
            echo "'$normalizedChannelName' does not have a valid stream; skipping." . PHP_EOL;
            continue;
        }
        if (strlen($suffix)) {
            $entry->getExtTags()[0]->setTitle($normalizedChannelName . $suffix);
            $entry->getExtTags()[0]->setAttribute('tvg-name', $normalizedChannelName . $suffix);
        }

        $a[$normalizedChannelKey . $suffix] = [
            'entry' => $entry->__toString(),
        ];
    }
}
ksort($a);
print_r($a);
writePlaylist($a);

function normalizeChannelKey($channelName)
{
    $channelName = preg_replace('/[^\w]/', '', $channelName);
    return strtolower($channelName);
}

function normalizeChannelName($channelName)
{
    $channelName = trim($channelName, ':');
    $channelName = trim($channelName);
    if (strlen($channelName) == 0) {
        $channelName = 'Unknown';
    }
    return $channelName;
}

function validUrl($url)
{

    if (filter_var($url, FILTER_VALIDATE_URL)) {
        $components = parse_url($url);

        // enable caching
        static $urlCache = [];
        $cacheKey = $components['scheme'] . $components['host'] . @$components['port'];
        if (isset($urlCache[$cacheKey])) {
            echo "Returning response for $url from cache." . PHP_EOL;
            return $urlCache[$cacheKey];
        }

        $live = pingPort($components['host'], $components['scheme'], @$components['port']);
        $urlCache[$cacheKey] = $live;
        if ($live) {
            return true;
        }
        echo "Url $url is not live." . PHP_EOL;
    }
    return false;
}

// vlc returns 0 even if a stream is broken, so we parse the output instead
function validStream($url)
{
    $context = stream_context_create([
        'http' => [
            'timeout' => 5,
        ],
    ]);

    $size = 1024;
    $section = file_get_contents($url, false, $context, 0, $size);
    return strlen($section) === $size;
}

function writePlaylist($array, $filename = 'output.m3u')
{
    if (!count($array)) {
        echo 'No channels available.' . PHP_EOL;
        return;
    }
    $fp = fopen($filename, 'w');
    fwrite($fp, "#EXTM3U\n");
    foreach ($array as $channel) {
        fwrite($fp, $channel['entry'] . "\n");
    }
    fclose($fp);
}

function pingPort($host, $proto, $port = null)
{
    if ($port === null) {
        switch ($proto) {
            case 'http':
                $port = 80;
                break;
            case 'https':
                $port = 443;
                break;
            case 'rtmp':
                $port = 1935;
                break;
            case 'rtsp':
                $port = 554;
                break;
            default:
                break;
        }
    }

    return (bool) fsockopen($host, $port, $errno, $errstr, 5);
}