CodeExplorer
You are a developer and looking for Shopware projects?
Apply Now!
write example
public function getContextProviders(): array
{
return $this->connection->getContextProviders();
}
/** * @return string|null */
public function dump(Data $data)
{
if (!$this->connection->write($data) && $this->wrappedDumper) {
return $this->wrappedDumper->dump($data);
}
return null;
}
}
{
return $this->connection->getContextProviders();
}
/** * @return string|null */
public function dump(Data $data)
{
if (!$this->connection->write($data) && $this->wrappedDumper) {
return $this->wrappedDumper->dump($data);
}
return null;
}
}
return $this->output->getVerbosity() >= OutputInterface::VERBOSITY_DEBUG;
}
/** * Write a message to STDOUT without trailing newline * * @param string $message */
public function write($message)
{
$this->output->write($message);
}
/** * Write a message to STDOUT with trailing newline * * @param string $message */
public function writeln($message)
{
$this->output->write($message, true);
}
if (!\array_key_exists($matches[1], $areaToFile) || !\is_array($areaToFile[$matches[1]])) {
$areaToFile[$matches[1]] = [];
}
$areaToFile[$matches[1]][] = $filePath;
} else {
$areaToFile['unknown'][] = $filePath;
}
}
}
if ($input->getOption(self::OPTION_AREA)) {
$output->write(
$input->getOption(self::OPTION_SEPARATED)
? \implode($input->getOption(self::OPTION_DELIMITER) ?: '|', $areaToFile[$input->getOption(self::OPTION_AREA)])
: var_export($areaToFile[$input->getOption(self::OPTION_AREA)], true)
);
} else {
$output->write(
var_export($areaToFile, true)
);
}
return 0;
}
$areaToFile[$matches[1]] = [];
}
$areaToFile[$matches[1]][] = $filePath;
} else {
$areaToFile['unknown'][] = $filePath;
}
}
}
if ($input->getOption(self::OPTION_AREA)) {
$output->write(
$input->getOption(self::OPTION_SEPARATED)
? \implode($input->getOption(self::OPTION_DELIMITER) ?: '|', $areaToFile[$input->getOption(self::OPTION_AREA)])
: var_export($areaToFile[$input->getOption(self::OPTION_AREA)], true)
);
} else {
$output->write(
var_export($areaToFile, true)
);
}
return 0;
}
$cloner = $this->cloner;
$dumper = $this->dumper;
$connection = $this->connection;
VarDumper::setHandler(static function D$var, string $label = null) use ($cloner, $dumper, $connection) {
$data = $cloner->cloneVar($var);
if (null !== $label) {
$data = $data->withContext(['label' => $label]);
}
if (!$connection || !$connection->write($data)) {
$dumper->dump($data);
}
});
}
public static function getSubscribedEvents(): array
{
if (!class_exists(ConsoleEvents::class)) {
return [];
}
$this->setNode('values', new ConstantExpression($values->getAttribute('data'), $values->getTemplateLine()));
$this->setAttribute('capture', false);
}
}
}
public function compile(Compiler $compiler): void
{
$compiler->addDebugInfo($this);
if (\count($this->getNode('names')) > 1) {
$compiler->write('list(');
foreach ($this->getNode('names') as $idx => $node) {
if ($idx) {
$compiler->raw(', ');
}
$compiler->subcompile($node);
}
$compiler->raw(')');
} else {
if ($this->getAttribute('capture')) {
if ($compiler->getEnvironment()->isDebug()) {
$this->setAttribute('capture', false);
}
}
}
public function compile(Compiler $compiler): void
{
$compiler->addDebugInfo($this);
if (\count($this->getNode('names')) > 1) {
$compiler->write('list(');
foreach ($this->getNode('names') as $idx => $node) {
if ($idx) {
$compiler->raw(', ');
}
$compiler->subcompile($node);
}
$compiler->raw(')');
} else {
if ($this->getAttribute('capture')) {
if ($compiler->getEnvironment()->isDebug()) {
/** * Prints the list of HTML output generated during the test. */
protected function printHtmlOutput() {
if ($this->browserOutputFile) {
$contents = file_get_contents($this->browserOutputFile);
if ($contents) {
$this->writeNewLine();
$this->writeWithColor('bg-yellow, fg-black', 'HTML output was generated');
$this->write($contents);
}
// No need to keep the file around any more. unlink($this->browserOutputFile);
}
}
}
$criteria = new Criteria();
$criteria->addFilter(new EqualsFilter('mail_template_type.mailTemplates.id', null));
$mailTypeIds = $this->mailTemplateTypeRepository->search($criteria, $context->getContext())->getIds();
$payload = [];
foreach ($mailTypeIds as $mailTypeId) {
$payload[] = $this->createSimpleMailTemplate($context, $mailTypeId);
if (\count($payload) >= 10) {
$context->getConsole()->progressAdvance(\count($payload));
$this->write($payload, $context);
$payload = [];
}
}
if (!empty($payload)) {
$this->write($payload, $context);
}
$context->getConsole()->progressFinish();
}
$criteria->addFilter(new EqualsFilter('mail_template_type.mailTemplates.id', null));
$mailTypeIds = $this->mailTemplateTypeRepository->search($criteria, $context->getContext())->getIds();
$payload = [];
foreach ($mailTypeIds as $mailTypeId) {
$payload[] = $this->createSimpleMailTemplate($context, $mailTypeId);
if (\count($payload) >= 10) {
$context->getConsole()->progressAdvance(\count($payload));
$this->write($payload, $context);
$payload = [];
}
}
if (!empty($payload)) {
$this->write($payload, $context);
}
$context->getConsole()->progressFinish();
}
$path = getcwd() . '/' . $path;
}
return $path;
}
public function uninstall(InstalledRepositoryInterface $repo, PackageInterface $package)
{
$installPath = $this->getPackageBasePath($package);
$io = $this->io;
$outputStatus = function D) use ($io, $installPath) {
$io->write(sprintf('Deleting %s - %s', $installPath, !file_exists($installPath) ? '<comment>deleted</comment>' : '<error>not deleted</error>'));
};
$promise = parent::uninstall($repo, $package);
// Composer v2 might return a promise here if ($promise instanceof PromiseInterface) {
return $promise->then($outputStatus);
}
// If not, execute the code right away as parent::uninstall executed synchronously (composer v1, or v2 without async) $outputStatus();
}
return $path;
}
public function uninstall(InstalledRepositoryInterface $repo, PackageInterface $package)
{
$installPath = $this->getPackageBasePath($package);
$io = $this->io;
$outputStatus = function D) use ($io, $installPath) {
$io->write(sprintf('Deleting %s - %s', $installPath, !file_exists($installPath) ? '<comment>deleted</comment>' : '<error>not deleted</error>'));
};
$promise = parent::uninstall($repo, $package);
// Composer v2 might return a promise here if ($promise instanceof PromiseInterface) {
return $promise->then($outputStatus);
}
// If not, execute the code right away as parent::uninstall executed synchronously (composer v1, or v2 without async) $outputStatus();
->search(new Criteria([$ids->get('media')]), $context)
->first();
static::assertInstanceOf(MediaEntity::class, $media);
$fileSystem = $this->getContainer()->get('shopware.filesystem.private');
$urlGenerator = $this->getContainer()->get(UrlGeneratorInterface::class);
$path = $urlGenerator->getRelativeMediaUrl($media);
// simulate file $fileSystem->write($path, 'foo');
// ensure that file system knows the file static::assertTrue($fileSystem->has($path));
$context->addState(MediaDeletionSubscriber::SYNCHRONE_FILE_DELETE);
$this->getContainer()->get('media.repository')
->delete([['id' => $ids->get('media')]], $context);
// after deleting the entity, the file should be deleted too static::assertFalse($fileSystem->has($path));
}
->first();
static::assertInstanceOf(MediaEntity::class, $media);
$fileSystem = $this->getContainer()->get('shopware.filesystem.private');
$urlGenerator = $this->getContainer()->get(UrlGeneratorInterface::class);
$path = $urlGenerator->getRelativeMediaUrl($media);
// simulate file $fileSystem->write($path, 'foo');
// ensure that file system knows the file static::assertTrue($fileSystem->has($path));
$context->addState(MediaDeletionSubscriber::SYNCHRONE_FILE_DELETE);
$this->getContainer()->get('media.repository')
->delete([['id' => $ids->get('media')]], $context);
// after deleting the entity, the file should be deleted too static::assertFalse($fileSystem->has($path));
}
$remainingCount += $log['count'];
}
$deprecationsXML->setAttribute('remainingCount', $remainingCount);
$this->writeDocument($dom);
}
private function writeDocument(\DOMDocument $dom): void
{
$dom->formatOutput = true;
$this->write($dom->saveXML());
}
private function getRouteCollectionDocument(RouteCollection $routes): \DOMDocument
{
$dom = new \DOMDocument('1.0', 'UTF-8');
$dom->appendChild($routesXML = $dom->createElement('routes'));
foreach ($routes->all() as $name => $route) {
$routeXML = $this->getRouteDocument($route, $name);
$routesXML->appendChild($routesXML->ownerDocument->importNode($routeXML->childNodes->item(0), true));
}
}
$deprecationsXML->setAttribute('remainingCount', $remainingCount);
$this->writeDocument($dom);
}
private function writeDocument(\DOMDocument $dom): void
{
$dom->formatOutput = true;
$this->write($dom->saveXML());
}
private function getRouteCollectionDocument(RouteCollection $routes): \DOMDocument
{
$dom = new \DOMDocument('1.0', 'UTF-8');
$dom->appendChild($routesXML = $dom->createElement('routes'));
foreach ($routes->all() as $name => $route) {
$routeXML = $this->getRouteDocument($route, $name);
$routesXML->appendChild($routesXML->ownerDocument->importNode($routeXML->childNodes->item(0), true));
}
'utf32',
'utf-32' => 4,
// 7-8 bit charsets: (us-)?ascii, (iso|iec)-?8859-?[0-9]+, windows-?125[0-9], cp-?[0-9]+, ansi, macintosh, // koi-?7, koi-?8-?.+, mik, (cork|t1), v?iscii // and fallback default => 1,
};
}
if (\is_resource($input)) {
$blocks = 16372;
while (false !== $read = fread($input, $blocks)) {
$this->write($read);
}
} else {
$this->write($input);
}
}
public function read(int $length): ?string
{
if ($this->currentPos >= $this->charCount) {
return null;
}
'utf-32' => 4,
// 7-8 bit charsets: (us-)?ascii, (iso|iec)-?8859-?[0-9]+, windows-?125[0-9], cp-?[0-9]+, ansi, macintosh, // koi-?7, koi-?8-?.+, mik, (cork|t1), v?iscii // and fallback default => 1,
};
}
if (\is_resource($input)) {
$blocks = 16372;
while (false !== $read = fread($input, $blocks)) {
$this->write($read);
}
} else {
$this->write($input);
}
}
public function read(int $length): ?string
{
if ($this->currentPos >= $this->charCount) {
return null;
}
private static array $knownTypes = [
'production',
'development',
];
/** * {@inheritDoc} */
public function run(array $params)
{
if ($params === []) {
CLI::write(sprintf('Your environment is currently set as %s.', CLI::color($_SERVER['CI_ENVIRONMENT'] ?? ENVIRONMENT, 'green')));
CLI::newLine();
return;
}
$env = strtolower(array_shift($params));
if ($env === 'testing') {
CLI::error('The "testing" environment is reserved for PHPUnit testing.', 'light_gray', 'red');
CLI::error('You will not be able to run spark under a "testing" environment.', 'light_gray', 'red');
CLI::newLine();
'production',
'development',
];
/** * {@inheritDoc} */
public function run(array $params)
{
if ($params === []) {
CLI::write(sprintf('Your environment is currently set as %s.', CLI::color($_SERVER['CI_ENVIRONMENT'] ?? ENVIRONMENT, 'green')));
CLI::newLine();
return;
}
$env = strtolower(array_shift($params));
if ($env === 'testing') {
CLI::error('The "testing" environment is reserved for PHPUnit testing.', 'light_gray', 'red');
CLI::error('You will not be able to run spark under a "testing" environment.', 'light_gray', 'red');
CLI::newLine();
$this->installEntitySchema('file');
$this->installEntitySchema('menu_link_content');
$this->installEntitySchema('path_alias');
$this->installSchema('system', 'sequences');
// Place some sample config to test for in the export. $this->data = [
'foo' => $this->randomMachineName(),
'bar' => $this->randomMachineName(),
];
$storage = new DatabaseStorage(Database::getConnection(), 'config');
$storage->write('test_config', $this->data);
// Create user account with some potential syntax issues. // cspell:disable-next-line $account = User::create(['mail' => 'q\'uote$dollar@example.com', 'name' => '$dollar']);
$account->save();
// Create a path alias. $this->createPathAlias('/user/' . $account->id(), '/user/example');
// Create a cache table (this will create 'cache_discovery'). \Drupal::cache('discovery')->set('test', $this->data);
$this->installEntitySchema('menu_link_content');
$this->installEntitySchema('path_alias');
$this->installSchema('system', 'sequences');
// Place some sample config to test for in the export. $this->data = [
'foo' => $this->randomMachineName(),
'bar' => $this->randomMachineName(),
];
$storage = new DatabaseStorage(Database::getConnection(), 'config');
$storage->write('test_config', $this->data);
// Create user account with some potential syntax issues. // cspell:disable-next-line $account = User::create(['mail' => 'q\'uote$dollar@example.com', 'name' => '$dollar']);
$account->save();
// Create a path alias. $this->createPathAlias('/user/' . $account->id(), '/user/example');
// Create a cache table (this will create 'cache_discovery'). \Drupal::cache('discovery')->set('test', $this->data);
$translatorBag = new TranslatorBag();
$translatorBag->addCatalogue(new MessageCatalogue('en', [
'messages' => ['a' => 'trans_en_a'],
'validators' => ['post.num_comments' => '{count, plural, one {# comment} other {# comments}}'],
]));
$provider = self::createProvider((new MockHttpClient($responses))->withOptions([
'base_uri' => 'https://api.crowdin.com/api/v2/projects/1/',
'auth_bearer' => 'API_TOKEN',
]), $this->getLoader(), $this->getLogger(), $this->getDefaultLocale(), 'api.crowdin.com/api/v2/projects/1/');
$provider->write($translatorBag);
}
public function testWriteAddFileServerError()
{
$this->xliffFileDumper = new XliffFileDumper();
$expectedMessagesFileContent = <<<'XLIFF' <?xml version="1.0" encoding="utf-8"?> <xliff xmlns="urn:oasis:names:tc:xliff:document:1.2" version="1.2"> <file source-language="en" target-language="en" datatype="plaintext" original="file.ext"> <header> <tool tool-id="symfony" tool-name="Symfony"/> </header> <body> <trans-unit id="ypeBEso" resname="a"> <source>a</source> <target>trans_en_a</target> </trans-unit> </body> </file> </xliff>
$translatorBag->addCatalogue(new MessageCatalogue('en', [
'messages' => ['a' => 'trans_en_a'],
'validators' => ['post.num_comments' => '{count, plural, one {# comment} other {# comments}}'],
]));
$provider = self::createProvider((new MockHttpClient($responses))->withOptions([
'base_uri' => 'https://api.crowdin.com/api/v2/projects/1/',
'auth_bearer' => 'API_TOKEN',
]), $this->getLoader(), $this->getLogger(), $this->getDefaultLocale(), 'api.crowdin.com/api/v2/projects/1/');
$provider->write($translatorBag);
}
public function testWriteAddFileServerError()
{
$this->xliffFileDumper = new XliffFileDumper();
$expectedMessagesFileContent = <<<'XLIFF' <?xml version="1.0" encoding="utf-8"?> <xliff xmlns="urn:oasis:names:tc:xliff:document:1.2" version="1.2"> <file source-language="en" target-language="en" datatype="plaintext" original="file.ext"> <header> <tool tool-id="symfony" tool-name="Symfony"/> </header> <body> <trans-unit id="ypeBEso" resname="a"> <source>a</source> <target>trans_en_a</target> </trans-unit> </body> </file> </xliff>