Nosial/socialbox-php
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

Added LogLib2 support

Browse source
This commit is contained in:
netkas 2025-01-22 13:18:55 -05:00
parent 5afe4429ed
commit a3456bdeed
7 changed files with 102 additions and 80 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
.idea/php.xml generated
View file

@ -17,6 +17,7 @@
</component> </component>
<component name="PhpIncludePathManager"> <component name="PhpIncludePathManager">
<include_path> <include_path>
<path value="/var/ncc/packages/net.nosial.loglib2=1.0.0" />
<path value="/var/ncc/packages/net.nosial.loglib=2.0.0" /> <path value="/var/ncc/packages/net.nosial.loglib=2.0.0" />
<path value="/var/ncc/packages/com.symfony.finder=2.0.7" /> <path value="/var/ncc/packages/com.symfony.finder=2.0.7" />
<path value="/var/ncc/packages/com.gregwar.captcha=v1.2.1" /> <path value="/var/ncc/packages/com.gregwar.captcha=v1.2.1" />

1
Dockerfile
View file

@ -45,6 +45,7 @@ RUN docker-php-ext-install -j$(nproc) \
curl \ curl \
opcache \ opcache \
zip \ zip \
sockets \
pcntl && \ pcntl && \
pecl install redis memcached && \ pecl install redis memcached && \
docker-php-ext-enable redis memcached docker-php-ext-enable redis memcached

7
docker-compose.test.yml
View file

@ -61,6 +61,10 @@ services:
# the instance name and the suffix being used to detect the TXT record # the instance name and the suffix being used to detect the TXT record
SB_INSTANCE_DNS_MOCK_COFFEE: ${SB_INSTANCE_DNS_MOCK_COFFEE:-"coffee.com v=socialbox;sb-rpc=http://coffee_socialbox:8085/;sb-key=sig:g59Cf8j1wmQmRg1MkveYbpdiZ-1-_hFU9eRRJmQAwmc;sb-exp=0"} SB_INSTANCE_DNS_MOCK_COFFEE: ${SB_INSTANCE_DNS_MOCK_COFFEE:-"coffee.com v=socialbox;sb-rpc=http://coffee_socialbox:8085/;sb-key=sig:g59Cf8j1wmQmRg1MkveYbpdiZ-1-_hFU9eRRJmQAwmc;sb-exp=0"}
SB_INSTANCE_DNS_MOCK_TEAPOT: ${SB_INSTANCE_DNS_MOCK_TEAPOT:-"teapot.com v=socialbox;sb-rpc=http://teapot_socialbox:8085/;sb-key=sig:MDXUuripAo_IAv-EZTEoFhpIdhsXxfMLNunSnQzxYiY;sb-exp=0"} SB_INSTANCE_DNS_MOCK_TEAPOT: ${SB_INSTANCE_DNS_MOCK_TEAPOT:-"teapot.com v=socialbox;sb-rpc=http://teapot_socialbox:8085/;sb-key=sig:MDXUuripAo_IAv-EZTEoFhpIdhsXxfMLNunSnQzxYiY;sb-exp=0"}
LOGLIB_UDP_ENABLED: true
LOGLIB_UDP_HOST: 10.0.0.109
LOGLIB_UDP_PORT: 5131
healthcheck: healthcheck:
test: ["CMD", "curl", "-f", "-H", "Request-Type: ping", "${SB_INSTANCE_RPC_ENDPOINT-http://coffee_socialbox:8085/}"] test: ["CMD", "curl", "-f", "-H", "Request-Type: ping", "${SB_INSTANCE_RPC_ENDPOINT-http://coffee_socialbox:8085/}"]
interval: 30s interval: 30s
@ -166,6 +170,9 @@ services:
# the instance name and the suffix being used to detect the TXT record # the instance name and the suffix being used to detect the TXT record
SB_INSTANCE_DNS_MOCK_COFFEE: ${SB_INSTANCE_DNS_MOCK_COFFEE:-"coffee.com v=socialbox;sb-rpc=http://coffee_socialbox:8085/;sb-key=sig:g59Cf8j1wmQmRg1MkveYbpdiZ-1-_hFU9eRRJmQAwmc;sb-exp=0"} SB_INSTANCE_DNS_MOCK_COFFEE: ${SB_INSTANCE_DNS_MOCK_COFFEE:-"coffee.com v=socialbox;sb-rpc=http://coffee_socialbox:8085/;sb-key=sig:g59Cf8j1wmQmRg1MkveYbpdiZ-1-_hFU9eRRJmQAwmc;sb-exp=0"}
SB_INSTANCE_DNS_MOCK_TEAPOT: ${SB_INSTANCE_DNS_MOCK_TEAPOT:-"teapot.com v=socialbox;sb-rpc=http://teapot_socialbox:8085/;sb-key=sig:MDXUuripAo_IAv-EZTEoFhpIdhsXxfMLNunSnQzxYiY;sb-exp=0"} SB_INSTANCE_DNS_MOCK_TEAPOT: ${SB_INSTANCE_DNS_MOCK_TEAPOT:-"teapot.com v=socialbox;sb-rpc=http://teapot_socialbox:8085/;sb-key=sig:MDXUuripAo_IAv-EZTEoFhpIdhsXxfMLNunSnQzxYiY;sb-exp=0"}
LOGLIB_UDP_ENABLED: true
LOGLIB_UDP_HOST: 10.0.0.109
LOGLIB_UDP_PORT: 5131
healthcheck: healthcheck:
test: ["CMD", "curl", "-f", "-H", "Request-Type: ping", "${SB_INSTANCE_RPC_ENDPOINT-http://teapot_socialbox:8085/}"] test: ["CMD", "curl", "-f", "-H", "Request-Type: ping", "${SB_INSTANCE_RPC_ENDPOINT-http://teapot_socialbox:8085/}"]
interval: 30s interval: 30s

4
project.json
View file

@ -36,9 +36,9 @@
"source": "nosial/libs.config=latest@n64" "source": "nosial/libs.config=latest@n64"
}, },
{ {
"name": "net.nosial.loglib", "name": "net.nosial.loglib2",
"version": "latest", "version": "latest",
"source": "nosial/libs.log=latest@n64" "source": "nosial/loglib2=latest@github"
}, },
{ {
"name": "net.nosial.optslib", "name": "net.nosial.optslib",

113
src/Socialbox/Classes/CliCommands/InitializeCommand.php
View file

@ -3,18 +3,19 @@
namespace Socialbox\Classes\CliCommands; namespace Socialbox\Classes\CliCommands;
use Exception; use Exception;
use ncc\CLI\Main;
use ncc\ThirdParty\Symfony\Process\Exception\InvalidArgumentException; use ncc\ThirdParty\Symfony\Process\Exception\InvalidArgumentException;
use PDOException; use PDOException;
use Socialbox\Abstracts\CacheLayer; use Socialbox\Abstracts\CacheLayer;
use Socialbox\Classes\Configuration; use Socialbox\Classes\Configuration;
use Socialbox\Classes\Cryptography; use Socialbox\Classes\Cryptography;
use Socialbox\Classes\Database; use Socialbox\Classes\Database;
use Socialbox\Classes\DnsHelper;
use Socialbox\Classes\Logger; use Socialbox\Classes\Logger;
use Socialbox\Classes\Resources; use Socialbox\Classes\Resources;
use Socialbox\Enums\DatabaseObjects; use Socialbox\Enums\DatabaseObjects;
use Socialbox\Exceptions\CryptographyException; use Socialbox\Exceptions\CryptographyException;
use Socialbox\Interfaces\CliCommandInterface; use Socialbox\Interfaces\CliCommandInterface;
use Socialbox\Program;
use Socialbox\Socialbox; use Socialbox\Socialbox;
class InitializeCommand implements CliCommandInterface class InitializeCommand implements CliCommandInterface
@ -31,30 +32,30 @@
'instance.enabled', 'instance.domain', 'registration.*' 'instance.enabled', 'instance.domain', 'registration.*'
]; ];
Logger::getLogger()->error('Socialbox is disabled. Use --force to initialize the instance or set `instance.enabled` to True in the configuration'); Program::getLogger()->error('Socialbox is disabled. Use --force to initialize the instance or set `instance.enabled` to True in the configuration');
Logger::getLogger()->info('The reason you are required to do this is to allow you to configure the instance before enabling it'); Program::getLogger()->info('The reason you are required to do this is to allow you to configure the instance before enabling it');
Logger::getLogger()->info('The following configurations are required to be set before enabling the instance:'); Program::getLogger()->info('The following configurations are required to be set before enabling the instance:');
foreach($required_configurations as $config) foreach($required_configurations as $config)
{ {
Logger::getLogger()->info(sprintf(' - %s', $config)); Program::getLogger()->info(sprintf(' - %s', $config));
} }
Logger::getLogger()->info('instance.private_key & instance.public_key are automatically generated if not set'); Program::getLogger()->info('instance.private_key & instance.public_key are automatically generated if not set');
Logger::getLogger()->info('instance.domain is required to be set to the domain name of the instance'); Program::getLogger()->info('instance.domain is required to be set to the domain name of the instance');
Logger::getLogger()->info('instance.rpc_endpoint is required to be set to the publicly accessible http rpc endpoint of this server'); Program::getLogger()->info('instance.rpc_endpoint is required to be set to the publicly accessible http rpc endpoint of this server');
Logger::getLogger()->info('registration.* are required to be set to allow users to register to the instance'); Program::getLogger()->info('registration.* are required to be set to allow users to register to the instance');
Logger::getLogger()->info('You will be given a DNS TXT record to set for the public key after the initialization process'); Program::getLogger()->info('You will be given a DNS TXT record to set for the public key after the initialization process');
Logger::getLogger()->info('The configuration file can be edited using ConfigLib:'); Program::getLogger()->info('The configuration file can be edited using ConfigLib:');
Logger::getLogger()->info(' configlib --conf socialbox -e nano'); Program::getLogger()->info(' configlib --conf socialbox -e nano');
Logger::getLogger()->info('Or manually at:'); Program::getLogger()->info('Or manually at:');
Logger::getLogger()->info(sprintf(' %s', Configuration::getConfigurationLib()->getPath())); Program::getLogger()->info(sprintf(' %s', Configuration::getConfigurationLib()->getPath()));
if(getenv('SB_MODE') === 'automated') if(getenv('SB_MODE') === 'automated')
{ {
// Wait & Reload the configuration // Wait & Reload the configuration
while(!Configuration::getInstanceConfiguration()->isEnabled()) while(!Configuration::getInstanceConfiguration()->isEnabled())
{ {
Logger::getLogger()->info('Waiting for configuration, retrying in 5 seconds...'); Program::getLogger()->info('Waiting for configuration, retrying in 5 seconds...');
sleep(5); sleep(5);
Configuration::reload(); Configuration::reload();
} }
@ -71,32 +72,32 @@
// This is useful for CI/CD pipelines & Docker // This is useful for CI/CD pipelines & Docker
if(getenv('SB_MODE') === 'automated') if(getenv('SB_MODE') === 'automated')
{ {
Logger::getLogger()->info('Automated Setup Procedure is detected'); Program::getLogger()->info('Automated Setup Procedure is detected');
self::applyEnvironmentVariables(); self::applyEnvironmentVariables();
} }
if(Configuration::getInstanceConfiguration()->getDomain() === null) if(Configuration::getInstanceConfiguration()->getDomain() === null)
{ {
Logger::getLogger()->error('instance.domain is required but was not set'); Program::getLogger()->error('instance.domain is required but was not set');
return 1; return 1;
} }
if(Configuration::getInstanceConfiguration()->getRpcEndpoint() === null) if(Configuration::getInstanceConfiguration()->getRpcEndpoint() === null)
{ {
Logger::getLogger()->error('instance.rpc_endpoint is required but was not set'); Program::getLogger()->error('instance.rpc_endpoint is required but was not set');
return 1; return 1;
} }
Logger::getLogger()->info('Initializing Socialbox...'); Program::getLogger()->info('Initializing Socialbox...');
if(Configuration::getCacheConfiguration()->isEnabled()) if(Configuration::getCacheConfiguration()->isEnabled())
{ {
Logger::getLogger()->verbose('Clearing cache layer...'); Program::getLogger()->verbose('Clearing cache layer...');
CacheLayer::getInstance()->clear(); CacheLayer::getInstance()->clear();
} }
foreach(DatabaseObjects::casesOrdered() as $object) foreach(DatabaseObjects::casesOrdered() as $object)
{ {
Logger::getLogger()->verbose("Initializing database object {$object->value}"); Program::getLogger()->verbose("Initializing database object {$object->value}");
try try
{ {
@ -107,18 +108,18 @@
// Check if the error code is for "table already exists" // Check if the error code is for "table already exists"
if ($e->getCode() === '42S01') if ($e->getCode() === '42S01')
{ {
Logger::getLogger()->warning("Database object {$object->value} already exists, skipping..."); Program::getLogger()->warning("Database object {$object->value} already exists, skipping...");
continue; continue;
} }
else else
{ {
Logger::getLogger()->error("Failed to initialize database object {$object->value}: {$e->getMessage()}", $e); Program::getLogger()->error("Failed to initialize database object {$object->value}: {$e->getMessage()}", $e);
return 1; return 1;
} }
} }
catch(Exception $e) catch(Exception $e)
{ {
Logger::getLogger()->error("Failed to initialize database object {$object->value}: {$e->getMessage()}", $e); Program::getLogger()->error("Failed to initialize database object {$object->value}: {$e->getMessage()}", $e);
return 1; return 1;
} }
} }
@ -133,12 +134,12 @@
try try
{ {
Logger::getLogger()->info('Generating new key pair (expires ' . date('Y-m-d H:i:s', $expires) . ')...'); Program::getLogger()->info('Generating new key pair (expires ' . date('Y-m-d H:i:s', $expires) . ')...');
$signingKeyPair = Cryptography::generateSigningKeyPair(); $signingKeyPair = Cryptography::generateSigningKeyPair();
} }
catch (CryptographyException $e) catch (CryptographyException $e)
{ {
Logger::getLogger()->error('Failed to generate cryptography values', $e); Program::getLogger()->error('Failed to generate cryptography values', $e);
return 1; return 1;
} }
@ -153,7 +154,7 @@
Configuration::getCryptographyConfiguration()->getInternalEncryptionKeys() === null || Configuration::getCryptographyConfiguration()->getInternalEncryptionKeys() === null ||
count(Configuration::getCryptographyConfiguration()->getInternalEncryptionKeys()) < Configuration::getCryptographyConfiguration()->getEncryptionKeysCount()) count(Configuration::getCryptographyConfiguration()->getInternalEncryptionKeys()) < Configuration::getCryptographyConfiguration()->getEncryptionKeysCount())
{ {
Logger::getLogger()->info('Generating internal encryption keys...'); Program::getLogger()->info('Generating internal encryption keys...');
$encryptionKeys = Configuration::getCryptographyConfiguration()->getInternalEncryptionKeys() ?? []; $encryptionKeys = Configuration::getCryptographyConfiguration()->getInternalEncryptionKeys() ?? [];
while(count($encryptionKeys) < Configuration::getCryptographyConfiguration()->getEncryptionKeysCount()) while(count($encryptionKeys) < Configuration::getCryptographyConfiguration()->getEncryptionKeysCount())
{ {
@ -163,13 +164,13 @@
Configuration::getConfigurationLib()->set('cryptography.internal_encryption_keys', $encryptionKeys); Configuration::getConfigurationLib()->set('cryptography.internal_encryption_keys', $encryptionKeys);
} }
Logger::getLogger()->info('Updating configuration...'); Program::getLogger()->info('Updating configuration...');
Configuration::getConfigurationLib()->save(); Configuration::getConfigurationLib()->save();
Configuration::reload(); Configuration::reload();
Logger::getLogger()->info('Socialbox has been initialized successfully'); Program::getLogger()->info('Socialbox has been initialized successfully');
Logger::getLogger()->info(sprintf('Set the DNS TXT record for the domain %s to the following value:', Configuration::getInstanceConfiguration()->getDomain())); Program::getLogger()->info(sprintf('Set the DNS TXT record for the domain %s to the following value:', Configuration::getInstanceConfiguration()->getDomain()));
Logger::getLogger()->info(Socialbox::getDnsRecord()); Program::getLogger()->info(Socialbox::getDnsRecord());
return 0; return 0;
} }
@ -227,7 +228,7 @@
foreach($configurationMap as $env => $config) foreach($configurationMap as $env => $config)
{ {
$variable = getenv($env); $variable = getenv($env);
Logger::getLogger()->info(sprintf('Checking environment variable %s...', $env)); Program::getLogger()->info(sprintf('Checking environment variable %s...', $env));
switch($env) switch($env)
{ {
@ -245,91 +246,91 @@
if($variable !== false) if($variable !== false)
{ {
Configuration::getConfigurationLib()->set($config, $variable); Configuration::getConfigurationLib()->set($config, $variable);
Logger::getLogger()->info(sprintf('Set %s to %s', $config, $variable)); Program::getLogger()->info(sprintf('Set %s to %s', $config, $variable));
} }
break; break;
case 'SB_INSTANCE_DOMAIN': case 'SB_INSTANCE_DOMAIN':
if($variable === false && Configuration::getInstanceConfiguration()->getDomain() === null) if($variable === false && Configuration::getInstanceConfiguration()->getDomain() === null)
{ {
Logger::getLogger()->warning(sprintf('%s is not set, expected %s environment variable', $config, $env)); Program::getLogger()->warning(sprintf('%s is not set, expected %s environment variable', $config, $env));
} }
else else
{ {
Configuration::getConfigurationLib()->set($config, $variable); Configuration::getConfigurationLib()->set($config, $variable);
Logger::getLogger()->info(sprintf('Set %s to %s', $config, $variable)); Program::getLogger()->info(sprintf('Set %s to %s', $config, $variable));
} }
break; break;
case 'SB_DATABASE_HOST': case 'SB_DATABASE_HOST':
if($variable === false && Configuration::getDatabaseConfiguration()->getHost() === null) if($variable === false && Configuration::getDatabaseConfiguration()->getHost() === null)
{ {
Logger::getLogger()->warning(sprintf('%s is not set, expected %s environment variable', $config, $env)); Program::getLogger()->warning(sprintf('%s is not set, expected %s environment variable', $config, $env));
} }
else else
{ {
Configuration::getConfigurationLib()->set($config, $variable); Configuration::getConfigurationLib()->set($config, $variable);
Logger::getLogger()->info(sprintf('Set %s to %s', $config, $variable)); Program::getLogger()->info(sprintf('Set %s to %s', $config, $variable));
} }
break; break;
case 'SB_DATABASE_PORT': case 'SB_DATABASE_PORT':
if($variable === false && Configuration::getDatabaseConfiguration()->getPort() === null) if($variable === false && Configuration::getDatabaseConfiguration()->getPort() === null)
{ {
Logger::getLogger()->warning(sprintf('%s is not set, expected %s environment variable', $config, $env)); Program::getLogger()->warning(sprintf('%s is not set, expected %s environment variable', $config, $env));
} }
else else
{ {
Configuration::getConfigurationLib()->set($config, (int) $variable); Configuration::getConfigurationLib()->set($config, (int) $variable);
Logger::getLogger()->info(sprintf('Set %s to %s', $config, $variable)); Program::getLogger()->info(sprintf('Set %s to %s', $config, $variable));
} }
break; break;
case 'SB_DATABASE_USERNAME': case 'SB_DATABASE_USERNAME':
if($variable === false && Configuration::getDatabaseConfiguration()->getUsername() === null) if($variable === false && Configuration::getDatabaseConfiguration()->getUsername() === null)
{ {
Logger::getLogger()->warning(sprintf('%s is not set, expected %s environment variable', $config, $env)); Program::getLogger()->warning(sprintf('%s is not set, expected %s environment variable', $config, $env));
} }
else else
{ {
Configuration::getConfigurationLib()->set($config, $variable); Configuration::getConfigurationLib()->set($config, $variable);
Logger::getLogger()->info(sprintf('Set %s to %s', $config, $variable)); Program::getLogger()->info(sprintf('Set %s to %s', $config, $variable));
} }
break; break;
case 'SB_DATABASE_PASSWORD': case 'SB_DATABASE_PASSWORD':
if($variable === false && Configuration::getDatabaseConfiguration()->getPassword() === null) if($variable === false && Configuration::getDatabaseConfiguration()->getPassword() === null)
{ {
Logger::getLogger()->warning(sprintf('%s is not set, expected %s environment variable', $config, $env)); Program::getLogger()->warning(sprintf('%s is not set, expected %s environment variable', $config, $env));
} }
else else
{ {
Configuration::getConfigurationLib()->set($config, $variable); Configuration::getConfigurationLib()->set($config, $variable);
Logger::getLogger()->info(sprintf('Set %s to %s', $config, $variable)); Program::getLogger()->info(sprintf('Set %s to %s', $config, $variable));
} }
break; break;
case 'SB_DATABASE_NAME': case 'SB_DATABASE_NAME':
if($variable === false && Configuration::getDatabaseConfiguration()->getName() === null) if($variable === false && Configuration::getDatabaseConfiguration()->getName() === null)
{ {
Logger::getLogger()->warning(sprintf('%s is not set, expected %s environment variable', $config, $env)); Program::getLogger()->warning(sprintf('%s is not set, expected %s environment variable', $config, $env));
} }
else else
{ {
Configuration::getConfigurationLib()->set($config, $variable); Configuration::getConfigurationLib()->set($config, $variable);
Logger::getLogger()->info(sprintf('Set %s to %s', $config, $variable)); Program::getLogger()->info(sprintf('Set %s to %s', $config, $variable));
} }
break; break;
case 'SB_INSTANCE_RPC_ENDPOINT': case 'SB_INSTANCE_RPC_ENDPOINT':
if($variable === false && Configuration::getInstanceConfiguration()->getRpcEndpoint() === null) if($variable === false && Configuration::getInstanceConfiguration()->getRpcEndpoint() === null)
{ {
Logger::getLogger()->warning(sprintf('%s is not set, expected %s environment variable', $config, $env)); Program::getLogger()->warning(sprintf('%s is not set, expected %s environment variable', $config, $env));
} }
else else
{ {
Configuration::getConfigurationLib()->set($config, $variable); Configuration::getConfigurationLib()->set($config, $variable);
Logger::getLogger()->info(sprintf('Set %s to %s', $config, $variable)); Program::getLogger()->info(sprintf('Set %s to %s', $config, $variable));
} }
break; break;
@ -340,7 +341,7 @@
if($variable !== false) if($variable !== false)
{ {
Configuration::getConfigurationLib()->set($config, filter_var($variable, FILTER_VALIDATE_BOOLEAN)); Configuration::getConfigurationLib()->set($config, filter_var($variable, FILTER_VALIDATE_BOOLEAN));
Logger::getLogger()->info(sprintf('Set %s to %s', $config, $variable)); Program::getLogger()->info(sprintf('Set %s to %s', $config, $variable));
} }
break; break;
@ -350,12 +351,12 @@
if($variable !== false) if($variable !== false)
{ {
Configuration::getConfigurationLib()->set($config, (int) $variable); Configuration::getConfigurationLib()->set($config, (int) $variable);
Logger::getLogger()->info(sprintf('Set %s to %s', $config, $variable)); Program::getLogger()->info(sprintf('Set %s to %s', $config, $variable));
} }
break; break;
default: default:
Logger::getLogger()->warning("Environment variable $env is not supported"); Program::getLogger()->warning("Environment variable $env is not supported");
break; break;
} }
} }
@ -367,7 +368,7 @@
$mockServer = explode(' ', $mockServer); $mockServer = explode(' ', $mockServer);
if(count($mockServer) !== 2) if(count($mockServer) !== 2)
{ {
Logger::getLogger()->warning(sprintf('Invalid DNS Mock Server format: %s', implode(' ', $mockServer))); Program::getLogger()->warning(sprintf('Invalid DNS Mock Server format: %s', implode(' ', $mockServer)));
continue; continue;
} }
@ -375,30 +376,30 @@
$txt = $mockServer[1] ?? null; $txt = $mockServer[1] ?? null;
if($domain === null || $txt === null) if($domain === null || $txt === null)
{ {
Logger::getLogger()->warning(sprintf('Invalid DNS Mock Server format, domain or txt missing: %s', implode(' ', $mockServer))); Program::getLogger()->warning(sprintf('Invalid DNS Mock Server format, domain or txt missing: %s', implode(' ', $mockServer)));
continue; continue;
} }
try try
{ {
$mockServers[$domain] = $txt; $mockServers[$domain] = $txt;
Logger::getLogger()->info(sprintf('Added Mock Server %s: %s', $domain, $txt)); Program::getLogger()->info(sprintf('Added Mock Server %s: %s', $domain, $txt));
} }
catch(InvalidArgumentException $e) catch(InvalidArgumentException $e)
{ {
Logger::getLogger()->error(sprintf('Invalid TXT record format for %s', $domain), $e); Program::getLogger()->error(sprintf('Invalid TXT record format for %s', $domain), $e);
continue; continue;
} }
} }
if(count($mockServers) > 0) if(count($mockServers) > 0)
{ {
Logger::getLogger()->info('Setting Mock Servers...'); Program::getLogger()->info('Setting Mock Servers...');
Configuration::getConfigurationLib()->set('instance.dns_mocks', $mockServers); Configuration::getConfigurationLib()->set('instance.dns_mocks', $mockServers);
} }
// Apply changes & reload the configuration // Apply changes & reload the configuration
Logger::getLogger()->info('Updating configuration...'); Program::getLogger()->info('Updating configuration...');
Configuration::getConfigurationLib()->save(); // Save Configuration::getConfigurationLib()->save(); // Save
Configuration::reload(); // Reload Configuration::reload(); // Reload
} }

37
src/Socialbox/Classes/Logger.php
View file

@ -1,30 +1,23 @@
<?php <?php
namespace Socialbox\Classes; namespace Socialbox\Classes;
use LogLib\Log;
class Logger class Logger
{
private static ?\LogLib\Logger $logger = null;
/**
* @return \LogLib\Logger
*/
public static function getLogger(): \LogLib\Logger
{ {
if(self::$logger === null) private static ?\LogLib2\Logger $logger = null;
/**
* @return \LogLib2\Logger
*/
public static function getLogger(): \LogLib2\Logger
{ {
self::$logger = new \LogLib\Logger("net.nosial.socialbox"); if(self::$logger === null)
self::$logger->setConsoleLoggingEnabled(Configuration::getLoggingConfiguration()->isConsoleLoggingEnabled()); {
self::$logger->setConsoleLoggingLevel(Configuration::getLoggingConfiguration()->getConsoleLoggingLevel()); self::$logger = new \LogLib2\Logger(Configuration::getInstanceConfiguration()->getName());
self::$logger->setFileLoggingEnabled(Configuration::getLoggingConfiguration()->isFileLoggingEnabled()); \LogLib2\Logger::registerHandlers();
self::$logger->setFileLoggingLevel(Configuration::getLoggingConfiguration()->getFileLoggingLevel()); }
Log::registerExceptionHandler(); return self::$logger;
Log::register(self::$logger);
} }
}
return self::$logger;
}
}

19
src/Socialbox/Program.php
View file

@ -3,10 +3,13 @@
namespace Socialbox; namespace Socialbox;
use OptsLib\Parse; use OptsLib\Parse;
use Socialbox\Classes\Logger;
use Socialbox\Enums\CliCommands; use Socialbox\Enums\CliCommands;
class Program class Program
{ {
private static ?\LogLib2\Logger $logger;
/** /**
* Socialbox main entry point * Socialbox main entry point
* *
@ -73,4 +76,20 @@
return 0; return 0;
} }
/**
* Retrieves the logger instance for the Socialbox program.
*
* @return \LogLib2\Logger Returns the logger instance.
*/
public static function getLogger(): \LogLib2\Logger
{
if(self::$logger === null)
{
self::$logger = new \LogLib2\Logger('net.nosial.socialbox');
\LogLib2\Logger::registerHandlers();
}
return self::$logger;
}
} }