Push events only when POST method kicks in

[ljfreelancer88]

Sorry, I have a lot of questions regarding implementing Swoole, because their documentation is not that detailed enough for newbie. Anyway, Is it possible to push the events when there's a POST method only? See pseudo code below.

if request method is POST
  Push the updated/new event 
else
  Sleep momentarily or send a SSE comment to make the connection alive 

Thank you again. You are a big help.

[hhxsv5]

See Swoole\Http\Request->server.

if ($request->server['request_method'] === 'POST') {      
}

Indeed, English documentation is not detailed enough. Sometimes Google translates Chinese documentation as another way.

[ljfreelancer88]

Hi, I've tried the following code below but it seems not working. It doesn't push event when I use the Curl POST.

When I submit a Curl POST it returns SSE comment :no update instead of the "news" event. While in my SSE server, it opens the connection but it does not return the "news" event when I do Curl POST.

go(function() use ($request, $response) {
    (new SSESwoole($request, $response))->start(new Update(function () {
        if (isset($request->server['request_method']) && 
            $request->server['request_method'] === 'POST') {
                $time = date('Y-m-d H:i:s');
                $news = [['id' => $time, 'title' => 'title ' . $time, 'content' => 'content ' . $time]]; // Get news from database or service.
                return json_encode(['news' => $news]);
            }
            return false;
    }, 2), 'news');
});

[hhxsv5]

1.Start SSE Server php sse-swoole.php. 2.Run Curl Client curl -XPOST -N http://127.0.0.1:5200/.

[ljfreelancer88]

Ow! the variable $request inside if statement is undefined, that's why it's not working. Here is the minor changes on the code new Update(function() use ($request)). Now it's working! Thank you so much for your help. Appreciate it.

Here is the final code for reference.

go(function() use ($request, $response) {
    (new SSESwoole($request, $response))->start(new Update(function() use ($request) {
        if ($request->server['request_method'] === 'POST') {
                $time = date('Y-m-d H:i:s');
                $news = [['id' => $time, 'title' => 'title ' . $time, 'content' => 'content ' . $time]]; // Get news from database or service.
                return json_encode(['news' => $news]);
            }
            return false;
    }, 2), 'news');
});