<?php

return [
    'default' => env('MQTT_CONNECTION', 'default'),

    'connections' => [
        'default' => [
            'host' => env('MQTT_HOST', '127.0.0.1'),
            'port' => (int) env('MQTT_PORT', 1883),
            'username' => env('MQTT_USERNAME', null),
            'password' => env('MQTT_PASSWORD', null),
            'client_id_prefix' => env('MQTT_CLIENT_ID_PREFIX', 'mqtt'),
            'client_id' => env('MQTT_CLIENT_ID', null),
            
            // 日志配置
            'logging' => [
                'enabled' => env('MQTT_LOGGING_ENABLED', false),
                'channel' => env('MQTT_LOGGING_CHANNEL', 'mqtt'),
            ],
            
            // Repository 配置
            'repository' => [
                'class' => env('MQTT_REPOSITORY_CLASS', null),
            ],
            
            // 连接设置
            'connection_settings' => [
                'use_blocking_socket' => env('MQTT_USE_BLOCKING_SOCKET', false),
                'connect_timeout' => (int) env('MQTT_CONNECT_TIMEOUT', 60),
                'socket_timeout' => (int) env('MQTT_SOCKET_TIMEOUT', 5),
                'resend_timeout' => (int) env('MQTT_RESEND_TIMEOUT', 10),
                'reconnect_automatically' => env('MQTT_RECONNECT_AUTOMATICALLY', false),
                'max_reconnect_attempts' => (int) env('MQTT_MAX_RECONNECT_ATTEMPTS', 3),
                'delay_between_reconnect_attempts' => (int) env('MQTT_DELAY_BETWEEN_RECONNECT_ATTEMPTS', 0),
                'keep_alive_interval' => (int) env('MQTT_KEEP_ALIVE_INTERVAL', 10),

                'last_will' => [
                    'topic' => env('MQTT_LAST_WILL_TOPIC', null),
                    'message' => env('MQTT_LAST_WILL_MESSAGE', null),
                    'quality_of_service' => (int) env('MQTT_LAST_WILL_QOS', 0),
                    'retain' => env('MQTT_RETAIN_LAST_WILL', false),
                ],

                'tls' => [
                    'use_tls' => env('MQTT_USE_TLS', false),
                    'verify_peer' => env('MQTT_TLS_VERIFY_PEER', true),
                    'verify_peer_name' => env('MQTT_TLS_VERIFY_PEER_NAME', true),
                    'self_signed_allowed' => env('MQTT_TLS_SELF_SIGNED_ALLOWED', false),
                    'certificate_authority_file' => env('MQTT_TLS_CA_FILE', null),
                    'certificate_authority_path' => env('MQTT_TLS_CA_PATH', null),
                    'client_certificate_file' => env('MQTT_TLS_CLIENT_CERT_FILE', null),
                    'client_certificate_key_file' => env('MQTT_TLS_CLIENT_KEY_FILE', null),
                    'client_certificate_key_passphrase' => env('MQTT_TLS_CLIENT_KEY_PASSPHRASE', null),
                    'alpn' => env('MQTT_TLS_ALPN', null),
                ],
            ],
        ],
    ],
];

use EasyMqtt\Factory;

$config = [
    'default' => 'mqtt',
    'connections' => [
        'mqtt' => [
            'host' => 'localhost',
            'port' => 1883,
        ],
    ],
];

$factory = new Factory($config);
$mqtt = $factory->make();

// 发布消息
$factory->publish('test/topic', 'Hello MQTT!');

// 订阅主题
$factory->subscribe('test/topic', function ($message) {
    echo "收到消息: " . $message . "\n";
});

use EasyMqtt\Factory;

// 使用配置
$factory = app(Factory::class);

// 发布消息
$factory->publish('sensors/temperature', '25.5');

// 订阅主题
$factory->subscribe('sensors/+', function ($message) {
    echo "传感器数据: " . $message . "\n";
});

$data = [
    'temperature' => 25.5,
    'humidity' => 60,
    'timestamp' => time(),
];

$factory->publish('sensors/data', $data);

use EasyMqtt\Message;

// 创建消息对象
$message = Message::make([
    'device_id' => 'sensor_001',
    'temperature' => 25.5,
    'humidity' => 60,
], 'sensors/data');

// 使用 Fluent API
$message->useConnection('production')
        ->toTopic('sensors/temperature')
        ->send();

// 或者一步到位
$message->publishTo('sensors/data', 'production', 1, true);

// 订阅消息处理
$factory->subscribe('sensors/+', function ($topic, Message $message) {
    // 检查是否为 JSON 消息
    if ($message->isJson()) {
        // 使用点号语法访问嵌套数据
        $deviceId = $message->get('device.id');
        $temperature = $message->get('data.temperature');
        
        // 检查键是否存在
        if ($message->has('alerts')) {
            $alerts = $message->get('alerts');
        }
        
        // 获取所有数据
        $allData = $message->all();
    } else {
        // 处理普通字符串消息
        echo "收到消息: " . $message->raw() . "\n";
    }
});

$config = [
    'default' => 'mqtt_auth',
    'connections' => [
        'mqtt_auth' => [
            'host' => 'localhost',
            'port' => 1883,
            'username' => 'your_username',
            'password' => 'your_password',
        ],
    ],
];

$factory = new Factory($config);

use EasyMqtt\Support\ClientIdGenerator;

// 生成默认格式的客户端 ID (mqtt_xxxxxxxxxx)
$clientId = ClientIdGenerator::generate();

// 生成自定义前缀的客户端 ID
$clientId = ClientIdGenerator::generate('sensor');

// 验证客户端 ID 格式
if (ClientIdGenerator::isValid($clientId)) {
    echo "客户端 ID 格式正确: " . $clientId . "\n";
}

// 启用信号处理器，支持优雅停止
$factory->subscribe(
    'sensors/+', 
    function ($topic, Message $message) {
        echo "收到传感器数据: " . $message->raw() . "\n";
    },
    'default',  // 连接名称
    0,          // QoS 级别
    true        // 启用信号处理器
);