auth_endpoint = https://api.siteniz.com/socketra/auth

POST /socketra/auth
Authorization: Bearer <kullanıcının token'ı>
Content-Type: application/json

{ "socket_id": "abc123", "channel_name": "private-conversation-9" }

# 200 → izin verilir   |   401/403 → reddedilir

Route::post('/socketra/auth', function (Request $request) {
    $user = auth()->user();                 // Bearer token'dan
    if (!$user) return response('Unauthorized', 401);

    $channel = $request->input('channel_name');   // private-conversation-9
    $id = (int) str_replace('private-conversation-', '', $channel);

    // Kullanıcı bu konuşmanın katılımcısı mı?
    if (!$user->conversations()->where('id', $id)->exists()) {
        return response('Forbidden', 403);
    }
    return response()->json(['ok' => true]);   // 200 = izin
});

# npm
npm install socket.io-client

# veya yarn
yarn add socket.io-client

import io from 'socket.io-client';

const PROJECT_ID = 42;
const userToken = await getMyApiToken();  // kendi giriş sisteminizden

export const socket = io(`https://socketra.net/project-${PROJECT_ID}`, {
  auth: { token: userToken },     // app_key YOK — sadece kullanıcı token'ı
  transports: ['websocket'],
  reconnection: true,
});

socket.on('connect', () => {
  // Konuşma kanalına katıl (auth_endpoint'te yetkilendirilir)
  socket.emit('subscribe', { channel: 'private-conversation-9' }, (res) => {
    if (res.ok) console.log('✅ Abone olundu', res.channel);
    else console.log('❌ Reddedildi:', res.error);
  });
});

// Backend'in bu kanala yayınladığı olay
socket.on('new-message', (data) => console.log('Yeni mesaj:', data));

// Diğer istemcilerin bu kanala gönderdiği mesajlar
socket.on('message-received', (payload) => console.log(payload.channel, payload.data));

socket.on('connect_error', (err) => console.log('Auth hatası:', err.message));

import React, { useEffect, useState, useRef } from 'react';
import { View, Text, TextInput, Button, FlatList } from 'react-native';
import io from 'socket.io-client';

export default function ChatScreen() {
  const [messages, setMessages] = useState([]);
  const [text, setText] = useState('');
  const socketRef = useRef(null);

  const CHANNEL = 'private-conversation-9';

  useEffect(() => {
    const socket = io('https://socketra.net/project-42', {
      auth: { token: '<kullanıcı-token>' },   // app_key değil
      transports: ['websocket'],
    });
    socketRef.current = socket;

    socket.on('connect', () => {
      socket.emit('subscribe', { channel: CHANNEL });   // odaya katıl
    });

    socket.on('message-received', (payload) => {
      if (payload.channel === CHANNEL)
        setMessages((prev) => [...prev, payload]);
    });

    return () => socket.disconnect();  // ekran kapanınca temizle
  }, []);

  const send = () => {
    if (!text.trim()) return;
    // Yalnızca bu kanaldakilere gider
    socketRef.current.emit('client-chat', { channel: CHANNEL, data: { text } });
    setText('');
  };

  return (
    <View style={{ flex: 1, padding: 16 }}>
      <FlatList
        data={messages}
        keyExtractor={(_, i) => String(i)}
        renderItem={({ item }) => <Text>{item.data?.text}</Text>}
      />
      <TextInput value={text} onChangeText={setText} placeholder="Mesaj…" />
      <Button title="Gönder" onPress={send} />
    </View>
  );
}

<!-- CDN -->
<script src="https://cdn.socket.io/4.8.1/socket.io.min.js"></script>

const socket = io('https://socketra.net/project-42', {
  auth: { token: '<kullanıcı-token>' },   // app_key değil
});

socket.on('connect', () => {
  socket.emit('subscribe', { channel: 'private-user-7' });
});

// Backend'in bu kanala yayınladığı olay
socket.on('notification', (data) => showToast(data.title, data.body));

// Mesaj gönder → yalnızca bu kanala abone olanlara gider
document.querySelector('#send').onclick = () => {
  socket.emit('message', { channel: 'private-user-7', data: { text: input.value } });
};

composer require predis/predis

REDIS_CLIENT=predis
REDIS_HOST=127.0.0.1
REDIS_PORT=6379
REDIS_PASSWORD=null

<?php

namespace App\Services;

use Illuminate\Support\Facades\Redis;

class Socketra
{
    /**
     * Bir projeye olay yayınlar.
     * @param int         $projectId  Proje ID'si
     * @param string      $event      Client'ın dinleyeceği olay adı
     * @param array       $data       Gönderilecek veri
     * @param string|null $channel    Hedef kanal (oda). null ise proje geneline yayılır.
     */
    public static function emit(int $projectId, string $event, array $data, ?string $channel = null): void
    {
        $redisChannel = "project_{$projectId}_events";
        $payload = json_encode([
            'event'   => $event,
            'data'    => $data,
            'channel' => $channel,   // örn: private-conversation-9
        ]);

        // ->client() alttaki phpredis/predis istemcisidir; önek eklemez.
        Redis::connection()->client()->publish($redisChannel, $payload);
    }
}

use App\Services\Socketra;

public function store(Request $request)
{
    $message = Message::create($request->validated());

    // Yalnızca ilgili konuşma kanalına "new-message" gönder
    Socketra::emit(42, 'new-message', [
        'id'   => $message->id,
        'text' => $message->text,
        'user' => $message->user->name,
    ], "private-conversation-{$message->conversation_id}");

    return response()->json($message, 201);
}

socket.on('new-message', (data) => {
  console.log(data.text, '—', data.user);
});

public function handle(MessageSent $event): void
{
    Socketra::emit(
        $event->message->project_id,
        'new-message',
        $event->message->toArray()
    );
}

npm install ioredis

const Redis = require('ioredis');

const pub = new Redis({
  host: '127.0.0.1',
  port: 6379,
  // password: process.env.REDIS_PASSWORD,
});

/**
 * Bir projeye olay yayınlar.
 * @param {string} [channel] Hedef kanal (oda). Boşsa proje geneline yayılır.
 */
function emit(projectId, event, data, channel = null) {
  const redisChannel = `project_${projectId}_events`;
  return pub.publish(redisChannel, JSON.stringify({ event, data, channel }));
}

module.exports = { emit };

const { emit } = require('./socketra');

app.post('/messages', async (req, res) => {
  const message = await db.messages.create(req.body);

  // Yalnızca ilgili konuşma kanalına gönder
  await emit(42, 'new-message', {
    id: message.id,
    text: message.text,
    user: message.userName,
  }, `private-conversation-${message.conversationId}`);

  res.status(201).json(message);
});

pub.publish(
  'system_database_alerts',
  JSON.stringify({ event: 'maintenance', data: { at: '02:00' } })
);
// Client: socket.on('system_database_alerts:maintenance', ...)