CWP\Search\Solr\CwpSolrConfigStore

Complexity

Total Complexity

6

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	2
A	uploadFile()	0	3	1
A	uploadString()	0	9	1
A	instanceDir()	0	3	2

<?php

namespace CWP\Search\Solr;

use SilverStripe\FullTextSearch\Solr\Solr;
use SilverStripe\FullTextSearch\Solr\Stores\SolrConfigStore;

/**
 * Class CwpSolrConfigStore
 *
 * Uploads configuration to Solr via the PHP proxy CWP uses to filter requests
 */
class CwpSolrConfigStore implements SolrConfigStore
{
    /**
     * @var string
     */
    protected $remote = '';

    /**
     * @var string
     */
    protected $url = '';

    /**
     * @param array $config
     */
    public function __construct($config)
    {
        $options = Solr::solr_options();

        $this->url = implode('', [
            'http://',
            isset($config['auth']) ? $config['auth'] . '@' : '',
            $options['host'] . ':' . $options['port'],
            $config['path']
        ]);
        $this->remote = $config['remotepath'];
    }

    /**
     * @param string $index
     * @param string $file
     * @return void
     */
    public function uploadFile($index, $file)
    {
        $this->uploadString($index, basename($file), file_get_contents($file));
    }

    /**
     *
     * @param string $index
     * @param string $filename
     * @param string $string
     * @return void
     */
    public function uploadString($index, $filename, $string)
    {
        $targetDir = "{$this->url}/config/$index";

        file_get_contents($targetDir . '/' . $filename, false, stream_context_create([
            'http' => [
                'method' => 'POST',
                'header' => 'Content-type: application/octet-stream',
                'content' => (string) $string
            ]
        ]));
    }

    /**
     * @param string $index
     * @return string
     */
    public function instanceDir($index)
    {
        return $this->remote ? "{$this->remote}/$index" : $index;
    }
}