nsq/nsqphp
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Refactor logging

Browse Source
This commit is contained in:
Konstantin Grachev
2021-09-18 22:47:06 +03:00
parent c8cd41777f
commit 97b3d8206c
4 changed files with 23 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/Connection.php
View File

@ -43,17 +43,9 @@ abstract class Connection
private LoggerInterface $logger,
) {
$this->stream = new NullStream();
$this->onConnectCallback = static function () use ($logger, $address) {
$logger->debug('Connected.', [
'class' => static::class,
'address' => $address,
]);
$this->onConnectCallback = static function () {
};
$this->onCloseCallback = static function () use ($logger, $address) {
$logger->debug('Disconnected.', [
'class' => static::class,
'address' => $address,
]);
$this->onCloseCallback = static function () {
};
}

21
src/Consumer.php
View File

@ -38,6 +38,15 @@ final class Consumer extends Connection
);
$this->onMessage = $onMessage;
$context = compact('address', 'topic', 'channel');
$this->onConnect(function () use ($context) {
$this->logger->debug('Consumer connected.', $context);
});
$this->onClose(function () use ($context) {
$this->logger->debug('Consumer disconnected.', $context);
});
$this->logger->debug('Consumer created.', $context);
}
public static function create(
@ -68,12 +77,6 @@ final class Consumer extends Connection
return call(function (): \Generator {
yield parent::connect();
$this->logger->debug('Consumer {topic}:{channel} connected to {host}', [
'topic' => $this->topic,
'channel' => $this->channel,
'host' => $this->address,
]);
$this->run();
});
}
@ -129,12 +132,6 @@ final class Consumer extends Connection
}
}
$this->logger->debug('Consumer disconnected.', [
'address' => $this->address,
'topic' => $this->topic,
'channel' => $this->channel,
]);
$this->close(false);
});
});

8
src/Lookup.php
View File

@ -144,8 +144,6 @@ final class Lookup
unset($consumers[$consumerKey]);
})->connect();
$this->logger->debug('Consumer created.', compact('address', 'topic', 'channel'));
$promise->onResolve(function (?\Throwable $e) use ($consumerKey, &$consumers) {
if (null !== $e) {
$this->logger->error($e->getMessage());
@ -163,13 +161,13 @@ final class Lookup
$this->watch($topic);
$this->logger->info('Subscribed', compact('topic', 'channel'));
$this->logger->info('Subscribed.', compact('topic', 'channel'));
}
public function unsubscribe(string $topic, string $channel): void
{
if (null === ($this->running[$topic][$channel] ?? null)) {
$this->logger->debug('Trying unsubscribe from non subscribed', compact('topic', 'channel'));
$this->logger->debug('Not subscribed.', compact('topic', 'channel'));
return;
}
@ -180,7 +178,7 @@ final class Lookup
unset($this->running[$topic]);
}
$this->logger->info('Unsubscribed', compact('topic', 'channel'));
$this->logger->info('Unsubscribed.', compact('topic', 'channel'));
}
private function watch(string $topic): void

13
src/Producer.php
View File

@ -24,6 +24,15 @@ final class Producer extends Connection
$this->clientConfig,
$this->logger,
);
$context = compact('address');
$this->onConnect(function () use ($context) {
$this->logger->debug('Producer connected.', $context);
});
$this->onClose(function () use ($context) {
$this->logger->debug('Producer disconnected.', $context);
});
$this->logger->debug('Producer created.', $context);
}
public static function create(
@ -48,10 +57,6 @@ final class Producer extends Connection
return call(function (): \Generator {
yield parent::connect();
$this->logger->debug('Producer connected to {host}', [
'host' => $this->address,
]);
$this->run();
});
}