Threema\Console\Command\ReceiveMessage

Complexity

Total Complexity

5

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	doRun()	0	45	4

<?php
/**
 * @author Threema GmbH
 * @copyright Copyright (c) 2015-2016 Threema GmbH
 */


namespace Threema\Console\Command;

use Threema\Console\Common;
use Threema\MsgApi\Connection;
use Threema\MsgApi\ConnectionSettings;
use Threema\MsgApi\Helpers\E2EHelper;
use Threema\MsgApi\PublicKeyStore;
use Threema\MsgApi\Tools\CryptTool;

class ReceiveMessage extends Base {
	const argOutputFolder = 'outputFolder';
	const argMessageId = 'messageId';

	/**
	 * @var PublicKeyStore
	 */
	private $publicKeyStore;

	/**
	 * @param PublicKeyStore $publicKeyStore
	 */
	public function __construct(PublicKeyStore $publicKeyStore) {
		parent::__construct('Decrypt a Message and download the Files',
			array(self::argThreemaId, self::argFrom, self::argSecret, self::argPrivateKey, self::argMessageId, self::argNonce),
			'Decrypt a box (must be provided on stdin) message and download (if the message is an image or file message) the file(s) to the given <'.self::argOutputFolder.'> folder',
			array(self::argOutputFolder));
		$this->publicKeyStore = $publicKeyStore;
	}

	protected function doRun() {
		$cryptTool = CryptTool::getInstance();

		$sendersThreemaId = $this->getArgumentThreemaId(self::argThreemaId);
		$id = $this->getArgumentThreemaId(self::argFrom);
		$secret = $this->getArgument(self::argSecret);
		$privateKey = $this->getArgumentPrivateKey(self::argPrivateKey);
		$nonce = $cryptTool->hex2bin($this->getArgument(self::argNonce));
		$messageId = $this->getArgument(self::argMessageId);
		$outputFolder = $this->getArgument(self::argOutputFolder);

		$box = $cryptTool->hex2bin($this->readStdIn());

		Common::required($box, $id, $secret, $privateKey, $nonce);

		$settings = new ConnectionSettings(
			$id,
			$secret
		);

		$connector = new Connection($settings, $this->publicKeyStore);
		$helper = new E2EHelper($privateKey, $connector);
		$message = $helper->receiveMessage(
			$sendersThreemaId,
			$messageId,
			$box,
			$nonce,
			$outputFolder
		);

		if(null === $message) {
			Common::e('invalid message');
			return;
		}

		if($message->isSuccess()) {
			Common::l($message->getMessageId().' - '.$message->getThreemaMessage());
			foreach($message->getFiles() as $fileName => $filePath) {
				Common::l('   received file '.$fileName.' in '.$filePath);
			}
		}
		else {
			Common::e('Error: '.implode("\n", $message->getErrors()));
		}
	}
}