8 Commits

Author SHA1 Message Date
Aerex
00d0ea624f fix(tw): Reloaded tasks into object array for refresh
- chore(tw): Wrapped import function in try catch and logged error
2020-06-02 21:16:18 -05:00
Aerex
2f87752f6e fix: Used ArrayNodeDefinition to append taskwarrior config to main
config
2020-05-29 11:45:53 -05:00
Aerex
346e5c239b feat(tw): Added project_tag_suffix config to use tag for tw project 2020-05-28 11:54:21 -05:00
Aerex
9d78b4a8eb fix: Downgraded symfony/yaml to fix dep confilicts 2020-05-13 00:12:36 -05:00
Aerex
84ecfb5ad1 feat: Added missing symfony/yaml dep 2020-05-13 00:09:35 -05:00
Aerex
40b66fb38b feat: Converted vcalendar todo events to taskwarrior tasks 2020-05-12 23:56:22 -05:00
Aerex
45ea34da94 fix: Created config directory recursively 2020-05-05 00:04:31 -05:00
Aerex
56eb7e7571 fix: Used correct declaration for setRawConfigs
- chore: Added README
2020-05-04 23:39:00 -05:00
19 changed files with 368 additions and 123 deletions

1
.gitignore vendored
View File

@@ -1,3 +1,4 @@
vendor/ vendor/
main.uml main.uml
composer.lock composer.lock
.phpunit.result.cache

15
README.md Normal file
View File

@@ -0,0 +1,15 @@
# baikal-storage-plugin
## Install
```
composer require aerex/baikal-storage-plugin
```
## Configuration
Copy sample configuration to your baikal installation. Make sure that the folder is writable
## Usage
- Add the plugin to `Core/Frameworks/Baikal/Core/Server.php`
```
$this->server->addPlugin(new \Aerex\BaikalStorage\Plugin(<path-of-config-file>))
```

View File

@@ -19,16 +19,17 @@
"php": ">=5.5", "php": ">=5.5",
"sabre/dav" : "~4.0.2", "sabre/dav" : "~4.0.2",
"sabre/vobject": "^4.0", "sabre/vobject": "^4.0",
"easycorp/easy-log-handler": "^1.0",
"nesbot/carbon": "^2.0.0", "nesbot/carbon": "^2.0.0",
"laminas/laminas-validator": "^2.13", "laminas/laminas-validator": "^2.13",
"laminas/laminas-stdlib": "^3.2", "laminas/laminas-stdlib": "^3.2",
"psr/container": "^1.0", "psr/container": "^1.0",
"symfony/config": "3.4", "symfony/config": "3.4",
"symfony/process": "^3.4" "symfony/process": "^3.4",
"monolog/monolog": "^2.0",
"symfony/yaml": "~3.0|~4.0"
}, },
"require-dev": { "require-dev": {
"phpunit/phpunit": "^7.4" "phpunit/phpunit": "^8.5.3"
}, },
"authors": [ "authors": [
{ {

7
config.yaml Executable file
View File

@@ -0,0 +1,7 @@
logger:
file: /home/aerex/baikal-storage-plugin.log
level: 'DEBUG'
taskwarrior:
taskdata: /home/aerex/.task
taskrc: /home/aerex/.taskrc
project_tag_suffix: project_

View File

@@ -11,7 +11,7 @@ class ConfigBuilder implements ConfigurationInterface {
private $configs = []; private $configs = [];
private $configFile; private $configFile;
public function __construct($configFile = '~/.config/baikal') { public function __construct($configFile) {
$this->configFile = $configFile; $this->configFile = $configFile;
$this->processor = new Processor(); $this->processor = new Processor();
} }
@@ -21,9 +21,23 @@ class ConfigBuilder implements ConfigurationInterface {
} }
public function getConfigTreeBuilder() { public function getConfigTreeBuilder() {
$treeBuilder = new TreeBuilder('configs'); $treeBuilder = new TreeBuilder();
$rootNode = $treeBuilder->getRootNode(); $rootNode = $treeBuilder->root('configs');
$ref = $rootNode->children(); $ref = $rootNode->children()
->arrayNode('logger')
->canBeEnabled()
->children()
->scalarNode('file')->end()
->scalarNode('level')
->defaultValue('ERROR')
->validate()
->IfNotInArray(['DEBUG', 'INFO', 'NOTICE', 'WARNING', 'ERROR', 'CRITICAL', 'ALERT', 'EMERGENCY'])
->thenInvalid('Invalid log level %s')
->end()
->end()
->end()
->end();
foreach ($this->configs as $config) { foreach ($this->configs as $config) {
$ref = $ref->append($config->get()); $ref = $ref->append($config->get());
} }
@@ -32,11 +46,7 @@ class ConfigBuilder implements ConfigurationInterface {
} }
public function readContent() { public function readContent() {
if (!is_dir($this->configFile)) { return file_get_contents($this->configFile);
mkdir($this->configFile);
}
$contents = sprintf('%s/storage.yml', $this->configFile);
return file_get_contents($contents);
} }
public function loadYaml() { public function loadYaml() {

View File

@@ -2,16 +2,24 @@
namespace Aerex\BaikalStorage\Configs; namespace Aerex\BaikalStorage\Configs;
use Symfony\Component\Config\Definition\Builder\TreeBuilder; use Symfony\Component\Config\Definition\Builder\ArrayNodeDefinition;
class TaskwarriorConfig { class TaskwarriorConfig {
public function get() { public function get() {
$treeBuilder = new TreeBuilder('taskwarrior'); $node = new ArrayNodeDefinition('taskwarrior');
$node = $treeBuilder->getRootNode(); $node->canBeEnabled()
$node->children() ->children()
->scalarNode('data_dir') ->scalarNode('taskdata')
->defaultValue('~/.task') ->defaultValue('~/.task')
->end(); ->end()
->scalarNode('taskrc')
->defaultValue('~/.taskrc')
->end()
->scalarNode('project_tag_suffix')
->defaultValue('project_')
->end()
->end();
return $node; return $node;
} }
} }

View File

@@ -18,20 +18,20 @@ class Console extends AbstractConsole {
} }
} }
public function execute($cmd, $args, $input = null) { public function execute($cmd, $args, $input = null, $envs = []) {
$stdin[] = $cmd; $stdin[] = $cmd;
$stdin[] = array_merge($stdin, $this->defaultArgs, $args); $stdin = array_merge($stdin, $this->defaultArgs, $args);
if (isset($input)) { if (isset($input)) {
$stdin[] = $this->convertToString($input); $input = $this->convertToString($input);
$process = new Process($stdin);
} }
$process = new Process(implode(' ', $stdin), $input, $envs);
$process->inheritEnvironmentVariables();
try { try {
$process->mustRun(); $process->mustRun();
return $process->getOutput(); return $process->getOutput();
} catch (ProcessFailedException $error) { } catch (ProcessFailedException $error) {
echo $error->getMessage();
throw $error; throw $error;
} }
} }

63
lib/Logger.php Normal file
View File

@@ -0,0 +1,63 @@
<?php
namespace Aerex\BaikalStorage;
use Monolog\Logger as Monolog;
use Monolog\Handler\StreamHandler;
class Logger {
private $configs = ['enabled' => false];
function __construct($configs, $tag) {
if (isset($configs['logger'])) {
$this->configs = $configs['logger'];
}
if ($this->configs['enabled']) {
$this->logger = new Monolog($tag);
$logLevel = Monolog::getLevels()[$this->configs['level']];
$this->logger->pushHandler(new StreamHandler($this->configs['file'], $logLevel));
}
}
public function debug($message) {
if ($this->configs['enabled']) {
$this->logger->debug($message);
}
}
public function info($message) {
if ($this->configs['enabled']) {
$this->logger->info($message);
}
}
public function notice($message) {
if ($this->configs['enabled']) {
$this->logger->notice($message);
}
}
public function error($message) {
if ($this->configs['enabled']) {
$this->logger->error($message);
}
}
public function critical($message) {
if ($this->configs['enabled']) {
$this->logger->critical($message);
}
}
public function alert($message) {
if ($this->configs['enabled']) {
$this->logger->alert($message);
}
}
public function emergency($message) {
if ($this->configs['enabled']) {
$this->logger->emergency($message);
}
}
}

View File

@@ -31,11 +31,6 @@ class Plugin extends ServerPlugin {
*/ */
protected $storageManager; protected $storageManager;
/**
* @var ConfigBuilder
*/
protected $config;
/** /**
* Creates the Taskwarrior plugin * Creates the Taskwarrior plugin
@@ -43,14 +38,16 @@ class Plugin extends ServerPlugin {
* @param CalendarProcessor $TWCalManager * @param CalendarProcessor $TWCalManager
* *
*/ */
function __construct($config = null){ function __construct($configFile){
if (isset($config)) { $configs = $this->buildConfigurations($configFile);
$this->config = $config; $this->storageManager = new StorageManager($configs);
} else { $this->initializeStorages($configs);
$this->config = new ConfigBuilder(); }
}
$this->storageManager = new StorageManager($this->config); public function buildConfigurations($configFile) {
$this->addStorages(); $this->config = new ConfigBuilder($configFile);
$this->config->add(new TaskwarriorConfig());
return $this->config->loadYaml();
} }
/** /**
@@ -58,10 +55,9 @@ class Plugin extends ServerPlugin {
* *
*/ */
public function addStorages() { public function initializeStorages($configs) {
$taskwarrior = new Taskwarrior(new Console(['rc.verbose=nothing', 'rc.hooks=off']), new TaskwarriorConfig()); $taskwarrior = new Taskwarrior(new Console(['rc.verbose=nothing', 'rc.hooks=off']), $configs);
$this->storageManager->addStorage(Taskwarrior::NAME, $taskwarrior); $this->storageManager->addStorage(Taskwarrior::NAME, $taskwarrior);
$this->storageManager->init();
} }
/** /**

View File

@@ -3,7 +3,6 @@
namespace Aerex\BaikalStorage; namespace Aerex\BaikalStorage;
use Sabre\VObject\Component\VCalendar as Calendar; use Sabre\VObject\Component\VCalendar as Calendar;
use Aerex\BaikalStorage\Configs\ConfigBuilder;
class StorageManager { class StorageManager {
@@ -15,13 +14,12 @@ class StorageManager {
/** /**
* @var Config * @var array()
*/ */
private $configBuilder;
private $configs; private $configs;
public function __construct($configBuilder){ public function __construct($configs){
$this->configBuilder = $configBuilder; $this->configs = $configs;
} }
public function getStorages() { public function getStorages() {
@@ -33,14 +31,9 @@ class StorageManager {
} }
public function addStorage($name, $storage) { public function addStorage($name, $storage) {
$this->configBuilder->add($storage->getConfig());
$this->storages[$name] = $storage; $this->storages[$name] = $storage;
} }
public function init() {
$this->configs = $this->configBuilder->loadYaml();
}
public function import(Calendar $calendar) { public function import(Calendar $calendar) {
if (!isset($this->configs)) { if (!isset($this->configs)) {
throw new \Exception('StorageManger was not initialize or configs are not defined'); throw new \Exception('StorageManger was not initialize or configs are not defined');
@@ -50,7 +43,6 @@ class StorageManager {
if (!isset($storage)){ if (!isset($storage)){
throw new \Exception(); throw new \Exception();
} }
$storage->setRawConfigs($this->configs[$key]);
$storage->save($calendar); $storage->save($calendar);
} }
} }

View File

@@ -8,5 +8,4 @@ interface IStorage {
public function save(Calendar $c); public function save(Calendar $c);
public function refresh(); public function refresh();
public function getConfig(); public function getConfig();
public function setRawConfigs();
} }

View File

@@ -3,87 +3,149 @@
namespace Aerex\BaikalStorage\Storages; namespace Aerex\BaikalStorage\Storages;
use Sabre\VObject\Component\VCalendar as Calendar; use Sabre\VObject\Component\VCalendar as Calendar;
use Aerex\BaikalStorage\Logger;
use Carbon\Carbon; use Carbon\Carbon;
class Taskwarrior implements IStorage { class Taskwarrior implements IStorage {
private const DATA_FILES = ['pending.data', 'completed.data', 'undo.data'];
private $rawConfigs;
public const NAME = 'taskwarrior'; public const NAME = 'taskwarrior';
private $tasks = []; private $tasks = [];
public function __construct($console, $config) { private $configs;
private $logger;
public function __construct($console, $configs) {
$this->console = $console; $this->console = $console;
$this->config = $config; $this->configs = $configs['taskwarrior'];
$this->logger = new Logger($configs, 'Taskwarrior');
} }
public function getConfig() { public function getConfig() {
return $this->config; return $this->config;
} }
public function setRawConfigs($rawConfigs) {
$this->rawConfigs = $rawConfigs;
}
public function refresh() { public function refresh() {
$dataDir = $this->rawConfigs['data_dir']; $output = $this->console->execute('task', ['sync'], null,
$fp = fopen(sprintf('%s/taskwarrior-baikal-storage.lock', $dataDir), 'a'); ['TASKRC' => $this->configs['taskrc'],'TASKDATA' => $this->configs['taskdata']]);
$tasks = json_decode($this->console->execute('task', ['export'], null,
if (!$fp || !flock($fp, LOCK_EX | LOCK_NB, $eWouldBlock) || $eWouldBlock) { ['TASKRC' => $this->configs['taskrc'], 'TASKDATA' => $this->configs['taskdata']]), true);
fputs(STDERR, 'Could not get lock');
}
$mtime = 0;
$tasksUpdated = false;
foreach (Taskwarrior::DATA_FILES as $dataFile) {
$fmtime = filemtime(sprintf('%s/%s', $this->config['data_dir'], $dataFile));
if ($fmtime > $mtime) {
$mtime = $fmtime;
$tasksUpdated = true;
}
}
if ($tasksUpdated) {
$tasks = $this->console->execute('task', ['export']);
foreach ($tasks as $task) { foreach ($tasks as $task) {
$this->tasks[$task['uuid']] = $task; if (isset($task['uid'])) {
$this->tasks[$task['uid']] = $task;
}
} }
} $this->logger->info($output);
fclose($fp);
unlink(sprintf('%s/taskwarrior-baikal-storage.lock', $dataDir));
} }
public function vObjectToTask($vtodo) { public function vObjectToTask($vtodo) {
if ($this->tasks['uid'] == $vtodo->UID) { if (isset($this->tasks[(string)$vtodo->UID])) {
$task = $this->tasks['uid']; $task = $this->tasks[(string)$vtodo->UID];
} else { } else {
$task = []; $task = [];
$task['uid'] = $vtodo->UID; $task['uid'] = (string)$vtodo->UID;
} }
if (isset($vtodo->SUMMARY)){
if (!isset($vtodo->DESCRIPTION) && isset($vtodo->SUMMARY)){ $task['description'] = (string)$vtodo->SUMMARY;
$task['description'] = $vtodo->SUMMARY; } else if(isset($vtodo->DESCRIPTION)) {
} else { $task['description'] = (string)$vtodo->DESCRIPTION;
$task['description'] = $vtodo->DESCRIPTION;
} }
if (isset($vtodo->DTSTAMP)){ if (isset($vtodo->DTSTAMP)){
$task['entry'] = new Carbon($vtodo->DTSTAMP->getDateTime()->format(\DateTime::W3C)); $task['entry'] = new Carbon($vtodo->DTSTAMP->getDateTime()->format(\DateTime::W3C));
} }
if (isset($vtodo->DTSTART)) {
$task['start'] = new Carbon($vtodo->DTSTART->getDateTime()->format(\DateTime::W3C));
}
if (isset($vtodo->DTEND)){
$task['end'] = new Carbon($vtodo->DTEND->getDateTime()->format(\DateTime::W3C));
}
if (isset($vtodo->{'LAST-MODIFIED'})) {
$task['modified'] = new Carbon($vtodo->{'LAST-MODIFIED'}->getDateTime()->format(\DateTime::W3C));
}
if (isset($vtodo->PRIORITY)) {
$priority = $vtodo->PRIORITY->getJsonValue();
if ($priority < 5) {
$task['priority'] = 'H';
} else if ($priority === 5) {
$task['priority'] = 'M';
} else if ($priority > 5 && $priority < 10) {
$task['priority'] = 'L';
}
}
if (isset($vtodo->DUE)){ if (isset($vtodo->DUE)){
$task['due'] = new Carbon($vtodo->DUE->getDateTime()->format(\DateTime::W3C)); $task['due'] = new Carbon($vtodo->DUE->getDateTime()->format(\DateTime::W3C));
} }
return $task; if (isset($vtodo->RRULE)) {
$rules = $vtodo->RRULE->getParts();
if (isset($rules['FREQ'])) {
$task['recu'] = $rules['FREQ'];
}
if (isset($rules['UNTIL'])) {
$task['until'] = $rules['UNTIL'];
}
}
if (isset($vtodo->STATUS)) {
switch((string)$vtodo->STATUS) {
case 'NEEDS-ACTION':
$task['status'] = 'pending';
break;
case 'COMPLETED':
$task['status'] = 'completed';
if (!isset($task['end'])) {
$task['end'] = new Carbon($vtodo->DTSTAMP->getDateTime()->format(\DateTime::W3C));
}
break;
case 'CANCELED':
$task['status'] = 'deleted';
if (!isset($task['end'])) {
$task['end'] = new Carbon($vtodo->DTSTAMP->getDateTime()->format(\DateTime::W3C));
}
break;
}
}
if (isset($vtodo->CATEGORIES)) {
$task['tags'] = [];
foreach ($vtodo->CATEGORIES as $category) {
if (isset($this->configs['project_tag_suffix'])) {
$projTagSuffixRegExp = sprintf('/^%s/', $this->configs['project_tag_suffix']);
if (preg_match($projTagSuffixRegExp, $category)) {
$task['project'] = preg_replace($projTagSuffixRegExp, '', $category);
continue;
}
}
$task['tags'] = $category;
}
}
return $task;
} }
public function save(Calendar $c) { public function save(Calendar $c) {
if (!isset($c->VTODO)){ try {
throw new \Exception('Calendar event does not contain VTODO'); if (!isset($c->VTODO)){
throw new \Exception('Calendar event does not contain VTODO');
}
$this->logger->info(json_encode($c->jsonSerialize()));
$this->refresh();
$task = $this->vObjectToTask($c->VTODO);
$this->logger->info(json_encode($task));
$this->logger->info(
sprintf('Executing TASKRC = %s TASKDATA = %s task import %s', $this->configs['taskrc'], $this->configs['taskdata'], json_encode($task))
);
$output = $this->console->execute('task', ['import'], $task,
['TASKRC' => $this->configs['taskrc'],'TASKDATA' => $this->configs['taskdata']]);
$this->logger->info($output);
} catch (\Exception $e) {
$this->logger->error($e->getTraceAsString());
throw $e;
} }
$this->refresh(); }
$task = $this->vObjectToTask($c->VTODO);
$this->console->execute('task', ['import'], $task);
}
} }

View File

@@ -9,7 +9,7 @@
<testsuite name="Baikal Storage Plug Tests"> <testsuite name="Baikal Storage Plug Tests">
<directory>./lib/tests</directory> <directory>./lib/tests/</directory>
</testsuite> </testsuite>
<filter> <filter>

View File

@@ -0,0 +1,50 @@
<?php
namespace Aerex\BaikalStorage;
use PHPUnit\Framework\TestCase;
use Aerex\BaikalStorage\Configs\ConfigBuilder;
use Aerex\BaikalStorage\Configs\TaskwarriorConfig;
class ConfigTest extends TestCase {
/**
* @var \PHPUnit_Framework_MockObject_MockObject
* */
public $mockConfigBuilder;
public function testLoggerConfigs() {
$configs = new ConfigBuilder(__DIR__ . '/Fixtures/LoggerConfig.yaml');
$contents = $configs->loadYaml();
$this->assertEquals(sizeof($contents), 1);
$this->assertArrayHasKey('logger', $contents, 'config missing logger property');
$this->assertArrayHasKey('file', $contents['logger'], 'config missing logger.file property');
$this->assertEquals($contents['logger']['file'], '/home/user/logger.yaml');
$this->assertArrayHasKey('level', $contents['logger'], 'config missing logger.level property');
$this->assertEquals($contents['logger']['level'], 'ERROR', 'ERROR is not set as default logger level');
$this->assertArrayHasKey('enabled', $contents['logger'], 'config missing logger.enabled property');
$this->assertTrue($contents['logger']['enabled']);
}
public function testTaskwarriorConfig() {
$configs = new ConfigBuilder(__DIR__ . '/Fixtures/TaskwarriorConfig.yaml');
$configs->add(new TaskwarriorConfig());
$contents = $configs->loadYaml();
$this->assertEquals(sizeof($contents), 2);
$this->assertArrayHasKey('logger', $contents, 'config missing logger property');
$this->assertArrayHasKey('file', $contents['logger'], 'config missing logger.file property');
$this->assertArrayHasKey('level', $contents['logger'], 'config missing logger.level property');
$this->assertArrayHasKey('enabled', $contents['logger'], 'config missing logger.enabled property');
$this->assertArrayHasKey('taskwarrior', $contents, 'config missing taskwarrior property');
$this->assertArrayHasKey('taskrc', $contents['taskwarrior'], 'config missing taskwarrior.taskrc property');
$this->assertEquals($contents['taskwarrior']['taskrc'], '/home/aerex/.taskrc');
$this->assertArrayHasKey('taskdata', $contents['taskwarrior'], 'config missing taskwarrior.taskdata property');
$this->assertEquals($contents['taskwarrior']['taskdata'], '/home/aerex/.task');
$this->assertArrayHasKey('project_tag_suffix', $contents['taskwarrior'], 'config missing taskwarrior.taskdata property');
$this->assertEquals($contents['taskwarrior']['project_tag_suffix'], 'project_');
}
}

View File

@@ -0,0 +1,2 @@
logger:
file: /home/user/logger.yaml

View File

@@ -0,0 +1,7 @@
logger:
file: /home/aerex/baikal-storage-plugin.log
level: DEBUG
taskwarrior:
taskdata: /home/aerex/.task
taskrc: /home/aerex/.taskrc
project_tag_suffix: project_

View File

@@ -1,2 +0,0 @@
taskwarrior:
data_dir: '~/task'

View File

@@ -5,7 +5,6 @@ namespace Aerex\BaikalStorage;
use PHPUnit\Framework\TestCase; use PHPUnit\Framework\TestCase;
use Aerex\BaikalStorage\AbstractConsole; use Aerex\BaikalStorage\AbstractConsole;
use Aerex\BaikalStorage\Configs\ConfigBuilder; use Aerex\BaikalStorage\Configs\ConfigBuilder;
use Aerex\BaikalStorage\Configs\TaskwarriorConfig;
use Aerex\BaikalStorage\Storages\Taskwarrior; use Aerex\BaikalStorage\Storages\Taskwarrior;
use Aerex\BaikalStorage\Storages\IStorage; use Aerex\BaikalStorage\Storages\IStorage;
use Sabre\VObject\Component\VCalendar as Calendar; use Sabre\VObject\Component\VCalendar as Calendar;
@@ -21,50 +20,35 @@ class StorageManagerTest extends TestCase {
public $mockConfigBuilder; public $mockConfigBuilder;
function setUp() { protected function setUp(): void {
$this->mockConfigBuilder = $this->getMockBuilder(ConfigBuilder::class) $this->mockConfigBuilder = $this->getMockBuilder(ConfigBuilder::class)
->setMethods(['readContent']) ->setMethods(['readContent'])
->setConstructorArgs(['']) ->setConstructorArgs([''])
->getMock(); ->getMock();
$this->mockConsole = $this->createMock(AbstractConsole::class); $this->mockConsole = $this->createMock(AbstractConsole::class);
$this->mockStorage = $this->createMock(IStorage::class); $this->mockStorage = $this->createMock(Taskwarrior::class);
} }
public function testAddTaskwarriorStorage() { public function testAddTaskwarriorStorage() {
$this->mockConfigBuilder->expects($this->once()) $configs = ['taskwarrior' => ['taskrc' => '', 'taskdata' => '']];
->method('readContent') $tw = new Taskwarrior($this->mockConsole, $configs);
->willReturn(file_get_contents(__DIR__ . '/Fixtures/taskwarrior_config.yml'));
$tw = new Taskwarrior($this->mockConsole, new TaskwarriorConfig());
$manager = new StorageManager($this->mockConfigBuilder); $manager = new StorageManager($this->mockConfigBuilder);
$manager->addStorage(Taskwarrior::NAME, $tw); $manager->addStorage(Taskwarrior::NAME, $tw);
$storages = $manager->getStorages(); $storages = $manager->getStorages();
$manager->init();
$configs = $manager->getConfigs(); $configs = $manager->getConfigs();
$this->assertEquals(sizeof(array_keys($storages)), 1, 'Taskwarrior storage was not added'); $this->assertEquals(sizeof(array_keys($storages)), 1, 'Taskwarrior storage was not added');
$this->assertEquals(sizeof(array_keys($configs)), 1, 'Taskwarrior config was not loaded');
$this->assertArrayHasKey('taskwarrior', $storages, 'Storages should have taskwarrior'); $this->assertArrayHasKey('taskwarrior', $storages, 'Storages should have taskwarrior');
$this->assertArrayHasKey('taskwarrior', $configs, 'Configs should have taskwarrior');
} }
public function testTaskwarriorImport() { public function testTaskwarriorImport() {
$cal = new Calendar(); $cal = new Calendar();
$this->mockConfigBuilder->expects($this->once())
->method('readContent')
->willReturn(file_get_contents(__DIR__ . '/Fixtures/taskwarrior_config.yml'));
$this->mockStorage->expects($this->once()) $this->mockStorage->expects($this->once())
->method('save') ->method('save')
->with($this->equalTo($cal)); ->with($this->equalTo($cal));
$this->mockStorage->expects($this->once())
->method('setRawConfigs')
->with($this->equalTo(['data_dir' => '~/.task']));
$this->mockStorage->expects($this->once())
->method('getConfig')
->willReturn(new TaskwarriorConfig());
$manager = new StorageManager($this->mockConfigBuilder); $configs = ['taskwarrior' => ['taskrc' => '', 'taskdata' => '']];
$manager = new StorageManager($configs);
$manager->addStorage(Taskwarrior::NAME, $this->mockStorage); $manager->addStorage(Taskwarrior::NAME, $this->mockStorage);
$manager->init();
$manager->import($cal); $manager->import($cal);
} }

View File

@@ -0,0 +1,50 @@
<?php
namespace Aerex\BaikalStorage;
use PHPUnit\Framework\TestCase;
use Aerex\BaikalStorage\AbstractConsole;
use Sabre\VObject\Component\VCalendar as Calendar;
use Aerex\BaikalStorage\Storages\Taskwarrior;
class TaskwarriorTest extends TestCase {
/**
* @var \PHPUnit_Framework_MockObject_MockObject
* */
private $mockConsole;
protected function setUp(): void {
$this->mockConsole = $this->createMock(AbstractConsole::class);
}
public function testVObjectToTask() {
$configs = ['taskwarrior' => ['taskrc' => '', 'taskdata' => ''], 'logger' => ['file' => '', 'level'=> 'DEBUG', 'enabled' => true]];
$this->taskwarrior = new Taskwarrior($this->mockConsole, $configs);
$vcalendar = new Calendar([
'VTODO' => [
'SUMMARY' => 'Finish project',
'DTSTAMP' => new \DateTime('2020-07-04 10:00:00'),
'DTSTART' => new \DateTime('2020-07-04 12:00:00'),
'DTEND' => new \DateTime('2020-07-05 01:00:00'),
'DUE' => new \DateTime('2020-07-05 03:00:00'),
'LAST_MODIFIED' => new \DateTime('2020-07-04 13:00:00'),
'PRIORITY' => 5,
'RRULE' => 'FREQ=MONTHLY'
]
]);
$task = $this->taskwarrior->vObjectToTask($vcalendar->VTODO);
$this->assertArrayHasKey('uid', $task, 'task should have a uid');
$this->assertEquals((string)$vcalendar->VTODO->UID, $task['uid']);
$this->assertArrayHasKey('description', $task, 'task should have description');
$this->assertEquals((string)$vcalendar->VTODO->SUMMARY, $task['description']);
$this->assertArrayHasKey('due', $task, 'task should have due');
$this->assertEquals($vcalendar->VTODO->DUE->getDateTime(), $task['due']);
$this->assertArrayHasKey('entry', $task, 'task should have an entry');
$this->assertEquals($vcalendar->VTODO->DTSTAMP->getDateTime(), $task['entry']);
$this->assertArrayHasKey('start', $task, 'task should have start');
$this->assertEquals($vcalendar->VTODO->DTSTART->getDateTime(), $task['start']);
}
}