Skip to content

Commit

Permalink
wip
Browse files Browse the repository at this point in the history
  • Loading branch information
joedixon committed Nov 23, 2023
1 parent b2e8705 commit 49f7378
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 4 deletions.
4 changes: 2 additions & 2 deletions src/Contracts/Connection.php
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ public function __construct(
protected ?string $origin
) {
$this->lastSeenAt = time();
$this->pusher = new PusherEvent;
// $this->pusher = new PusherEvent;
}

/**
Expand Down Expand Up @@ -73,7 +73,7 @@ public function ping(): void
{
$this->hasBeenPinged = true;

$this->pusher->ping($this);
// $this->pusher->ping($this);

// Output::info('Connection Pinged', $this->id());
}
Expand Down
9 changes: 7 additions & 2 deletions src/Pusher/Event.php
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,11 @@

class Event
{
public function __construct(protected ChannelManager $channels)
{
//
}

/**
* Handle a pusher event.
*/
Expand Down Expand Up @@ -45,7 +50,7 @@ public function acknowledge(Connection $connection): void
*/
public function subscribe(Connection $connection, string $channel, string $auth = null, string $data = null): void
{
$channel = app(ChannelManager::class)
$channel = $this->channels
->for($connection->app())
->find($channel);

Expand All @@ -59,7 +64,7 @@ public function subscribe(Connection $connection, string $channel, string $auth
*/
public function unsubscribe(Connection $connection, string $channel): void
{
$channel = app(ChannelManager::class)
$channel = $this->channels
->for($connection->app())
->find($channel)
->unsubscribe($connection);
Expand Down

0 comments on commit 49f7378

Please sign in to comment.