diff --git a/src/Command/ListenSubscritptionCommand.php b/src/Command/ListenSubscritptionCommand.php deleted file mode 100644 index 4043af4..0000000 --- a/src/Command/ListenSubscritptionCommand.php +++ /dev/null @@ -1,89 +0,0 @@ - 'charles', - 'remoteAddr' => 'rawsfsda' - ]; - $key = "!ChangeThisMercureHubJWTSecretKey!"; - $payload = [ - 'mercure' => [ - 'publish' => ['*'], - 'subscribe' => ['*'], - 'payload' => $tab - ], - ]; - - $jwt = JWT::encode($payload, $key, 'HS256'); - try{ - $response = $this->httpClient->request('GET', $_ENV['MERCURE_URL'] . '/subscriptions', [ - 'headers' => [ - 'Authorization' => 'Bearer ' . $jwt, - 'Content-Type' => 'application/ld+json', - ] - ]); - $data = json_decode($response->getContent(), true); - $subscriptions = $this->getSubscription($data); - $encodedSubscriptions = json_encode($subscriptions, JSON_PRETTY_PRINT); - $section = $output->section(); - $section2 = $output->section(); - $section->writeln('Active Subscriptions:'); - $section2->writeln($encodedSubscriptions); - return Command::SUCCESS; - }catch (\Throwable $e){ - $output->writeln('Error fetching subscriptions: ' . $e->getMessage() . ''); - return Command::FAILURE; - } - } - - private function getSubscription(array $data): array { - $subscriptions = []; - foreach ($data['subscriptions'] as $sub) { - if ($sub['active']) { - $subscriptions[] = [ - 'topic' => $sub['topic'], - 'user' => $sub['payload']['user'] ?? null, - 'remoteAddr' => $sub['payload']['remoteAddr'] ?? null, - ]; - } - } - return $subscriptions; - } - - private function getUserFromSubscription(array $subscription): ?string { - $parts = parse_url($subscription['topic']); - $userIdentifier = null; - if (isset($parts['query'])) { - parse_str($parts['query'], $query); - if (isset($query['userId'])) { - $userIdentifier = $query['userId']; - } - } - return $userIdentifier; - } - - private function addSubscriptionToDb(array $subscription): void { -// try{ -// -// } - } - -} \ No newline at end of file