Add tests for storage encrypted file.

Also fix some bugs found by the tests.

Telegram/SourceFiles/platform/win/windows_dlls.cpp

@@ -7,6 +7,8 @@ https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL
 */
 #include "platform/win/windows_dlls.h"
 
+#include <QtCore/QSysInfo>
+
 namespace Platform {
 namespace Dlls {
 
@@ -69,10 +71,6 @@ void start() {
 	load(LibShell32, "SHChangeNotify", SHChangeNotify);
 	load(LibShell32, "SetCurrentProcessExplicitAppUserModelID", SetCurrentProcessExplicitAppUserModelID);
 
-	if (cBetaVersion() == 10020001 && SHChangeNotify) { // Temp - app icon was changed
-		SHChangeNotify(SHCNE_ASSOCCHANGED, SHCNF_IDLIST, nullptr, nullptr);
-	}
-
 	LibUxTheme = LoadLibrary(L"UXTHEME.DLL");
 	load(LibUxTheme, "SetWindowTheme", SetWindowTheme);
 

Telegram/SourceFiles/storage/storage_encrypted_file.cpp

@@ -28,12 +28,12 @@ File::Result File::open(
 		const QString &path,
 		Mode mode,
 		const EncryptionKey &key) {
+	close();
+
 	_data.setFileName(QFileInfo(path).absoluteFilePath());
 	const auto result = attemptOpen(mode, key);
 	if (result != Result::Success) {
-		_state = base::none;
+		close();
-		_data.close();
-		_lock.unlock();
 	}
 	return result;
 
@@ -198,4 +198,12 @@ size_type File::write(bytes::span bytes) {
 	return count;
 }
 
+void File::close() {
+	_lock.unlock();
+	_data.close();
+	_data.setFileName(QString());
+	_offset = 0;
+	_state = base::none;
+}
+
 } // namespace Storage

Telegram/SourceFiles/storage/storage_encrypted_file.h

@@ -10,6 +10,7 @@ https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL
 #include "storage/storage_file_lock.h"
 #include "storage/storage_encryption.h"
 #include "base/bytes.h"
+#include "base/optional.h"
 
 namespace Storage {
 
@@ -31,6 +32,8 @@ public:
 	size_type read(bytes::span bytes);
 	size_type write(bytes::span bytes);
 
+	void close();
+
 private:
 	enum class Format : uint32 {
 		Format_0,

Telegram/SourceFiles/storage/storage_encrypted_file_tests.cpp

@@ -0,0 +1,70 @@
+/*
+This file is part of Telegram Desktop,
+the official desktop application for the Telegram messaging service.
+
+For license and copyright information please follow this link:
+https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL
+*/
+#include "catch.hpp"
+
+#include "storage/storage_encrypted_file.h"
+
+const auto key = Storage::EncryptionKey(bytes::make_vector(
+	bytes::make_span("\
+abcdefgh01234567abcdefgh01234567abcdefgh01234567abcdefgh01234567\
+abcdefgh01234567abcdefgh01234567abcdefgh01234567abcdefgh01234567\
+abcdefgh01234567abcdefgh01234567abcdefgh01234567abcdefgh01234567\
+abcdefgh01234567abcdefgh01234567abcdefgh01234567abcdefgh01234567\
+").subspan(0, Storage::EncryptionKey::kSize)));
+
+TEST_CASE("simple encrypted file", "[storage_encrypted_file]") {
+	const auto name = QString("simple.test");
+	const auto test = bytes::make_span("testbytetestbyte").subspan(0, 16);
+
+	SECTION("writing file") {
+		Storage::File file;
+		const auto result = file.open(
+			name,
+			Storage::File::Mode::Write,
+			key);
+		REQUIRE(result == Storage::File::Result::Success);
+
+		auto data = bytes::make_vector(test);
+		const auto written = file.write(data);
+		REQUIRE(written == data.size());
+	}
+	SECTION("reading and writing file") {
+		Storage::File file;
+		const auto result = file.open(
+			name,
+			Storage::File::Mode::ReadAppend,
+			key);
+		REQUIRE(result == Storage::File::Result::Success);
+
+		auto data = bytes::vector(16);
+		const auto read = file.read(data);
+		REQUIRE(read == data.size());
+		REQUIRE(data == bytes::make_vector(test));
+
+		const auto written = file.write(data);
+		REQUIRE(written == data.size());
+	}
+	SECTION("reading file") {
+		Storage::File file;
+
+		const auto result = file.open(
+			name,
+			Storage::File::Mode::Read,
+			key);
+		REQUIRE(result == Storage::File::Result::Success);
+
+		auto data = bytes::vector(32);
+		const auto read = file.read(data);
+		REQUIRE(read == data.size());
+		REQUIRE(data == bytes::concatenate(test, test));
+	}
+}
+
+TEST_CASE("two process encrypted file", "[storage_encrypted_file]") {
+
+}

Telegram/SourceFiles/storage/storage_encryption.cpp

@@ -30,25 +30,47 @@ void CtrState::process(bytes::span data, index_type offset, Method method) {
 		_key.size() * CHAR_BIT,
 		&aes);
 
-	unsigned char ecountBuf[kBlockSize];
+	unsigned char ecountBuf[kBlockSize] = { 0 };
-	unsigned int blockNumber = offset / kBlockSize;
+	unsigned int offsetInBlock = 0;
+	const auto blockIndex = offset / kBlockSize;
+	auto iv = incrementedIv(blockIndex);
+
 	CRYPTO_ctr128_encrypt(
 		reinterpret_cast<const uchar*>(data.data()),
 		reinterpret_cast<uchar*>(data.data()),
 		data.size(),
 		&aes,
-		reinterpret_cast<unsigned char*>(_iv.data()),
+		reinterpret_cast<unsigned char*>(iv.data()),
 		ecountBuf,
-		&blockNumber,
+		&offsetInBlock,
 		(block128_f)method);
 }
 
+auto CtrState::incrementedIv(index_type blockIndex)
+-> bytes::array<kIvSize> {
+	Expects(blockIndex >= 0);
+
+	if (!blockIndex) {
+		return _iv;
+	}
+	auto result = _iv;
+	auto digits = kIvSize;
+	auto increment = uint64(blockIndex);
+	do {
+		--digits;
+		increment += static_cast<uint64>(result[digits]);
+		result[digits] = static_cast<bytes::type>(increment & 0xFFULL);
+		increment >>= 8;
+	} while (digits != 0 && increment != 0);
+	return result;
+}
+
 void CtrState::encrypt(bytes::span data, index_type offset) {
 	return process(data, offset, AES_encrypt);
 }
 
 void CtrState::decrypt(bytes::span data, index_type offset) {
-	return process(data, offset, AES_decrypt);
+	return process(data, offset, AES_encrypt);
 }
 
 EncryptionKey::EncryptionKey(bytes::vector &&data)

Telegram/SourceFiles/storage/storage_encryption.h

@@ -28,6 +28,8 @@ private:
 	template <typename Method>
 	void process(bytes::span data, index_type offset, Method method);
 
+	bytes::array<kIvSize> incrementedIv(index_type blockIndex);
+
 	static constexpr auto EcountSize = kBlockSize;
 
 	bytes::array<kKeySize> _key;

Telegram/SourceFiles/storage/storage_file_lock.h

@@ -7,6 +7,10 @@ https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL
 */
 #pragma once
 
+#include "core/basic_types.h"
+
+#include <QtCore/QFile>
+
 namespace Storage {
 
 class FileLock {

Telegram/SourceFiles/storage/storage_file_lock_posix.cpp

@@ -71,6 +71,9 @@ FileLock::Lock::Result FileLock::Lock::Acquire(const QFile &file) {
 	}
 }
 
+FileLock::Lock::Lock(int descriptor) : _descriptor(descriptor) {
+}
+
 FileLock::Lock::~Lock() {
 	struct flock unlock;
 	unlock.l_type = F_UNLCK;

Telegram/gyp/Telegram.gyp

@@ -61,6 +61,7 @@
       'telegram_win.gypi',
       'telegram_mac.gypi',
       'telegram_linux.gypi',
+	  'openssl.gypi',
       'qt.gypi',
       'qt_moc.gypi',
       'qt_rcc.gypi',

Telegram/gyp/lib_storage.gyp

@@ -13,6 +13,7 @@
     'type': 'static_library',
     'includes': [
       'common.gypi',
+	  'openssl.gypi',
       'qt.gypi',
       'telegram_win.gypi',
       'telegram_mac.gypi',

Telegram/gyp/openssl.gypi

@@ -0,0 +1,55 @@
+# This file is part of Telegram Desktop,
+# the official desktop application for the Telegram messaging service.
+#
+# For license and copyright information please follow this link:
+# https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL
+
+{
+  'conditions': [
+    [ 'build_win', {
+	  'libraries': [
+        '-llibeay32',
+        '-lssleay32',
+        '-lCrypt32',
+	  ],
+      'configurations': {
+        'Debug': {
+          'include_dirs': [
+            '<(libs_loc)/openssl/Debug/include',
+          ],
+          'library_dirs': [
+            '<(libs_loc)/openssl/Debug/lib',
+          ],
+        },
+        'Release': {
+          'include_dirs': [
+            '<(libs_loc)/openssl/Release/include',
+          ],
+          'library_dirs': [
+            '<(libs_loc)/openssl/Release/lib',
+          ],
+        },
+      },
+	}], [ 'build_macold', {
+      'xcode_settings': {
+        'OTHER_LDFLAGS': [
+          '<(libs_loc)/macold/openssl/libssl.a',
+          '<(libs_loc)/macold/openssl/libcrypto.a',
+        ],
+      },
+      'include_dirs': [
+        '<(libs_loc)/macold/openssl/include',
+      ],
+    }], [ 'build_mac', {
+      'xcode_settings': {
+        'OTHER_LDFLAGS': [
+          '<(libs_loc)/openssl/libssl.a',
+          '<(libs_loc)/openssl/libcrypto.a',
+        ],
+      },
+      'include_dirs': [
+        '<(libs_loc)/openssl/include',
+      ],
+    }],
+  ],
+}

Telegram/gyp/telegram_mac.gypi

@@ -55,14 +55,11 @@
         '/usr/local/macold/lib/libexif.a',
         '/usr/local/macold/lib/libc++.a',
         '/usr/local/macold/lib/libc++abi.a',
-        '<(libs_loc)/macold/openssl/libssl.a',
-        '<(libs_loc)/macold/openssl/libcrypto.a',
       ],
     },
     'include_dirs': [
       '/usr/local/macold',
       '/usr/local/macold/include/c++/v1',
-      '<(libs_loc)/macold/openssl/include',
       '<(libs_loc)/macold/libexif-0.6.20',
       '<(libs_loc)/macold/crashpad',
       '<(libs_loc)/macold/crashpad/third_party/mini_chromium/mini_chromium',
@@ -122,14 +119,11 @@
         '/usr/local/lib/libavutil.a',
         '/usr/local/lib/libswscale.a',
         '/usr/local/lib/libswresample.a',
-        '<(libs_loc)/openssl/libssl.a',
-        '<(libs_loc)/openssl/libcrypto.a',
       ],
     },
     'include_dirs': [
       '<(libs_loc)/crashpad',
       '<(libs_loc)/crashpad/third_party/mini_chromium/mini_chromium',
-      '<(libs_loc)/openssl/include'
     ],
     'configurations': {
       'Debug': {

Telegram/gyp/telegram_win.gypi

@@ -14,9 +14,6 @@
       '<(libs_loc)/ffmpeg',
     ],
     'libraries': [
-      '-llibeay32',
-      '-lssleay32',
-      '-lCrypt32',
       '-lzlibstat',
       '-lLzmaLib',
       '-lUxTheme',
@@ -41,11 +38,7 @@
     },
     'configurations': {
       'Debug': {
-        'include_dirs': [
-          '<(libs_loc)/openssl/Debug/include',
-        ],
         'library_dirs': [
-          '<(libs_loc)/openssl/Debug/lib',
           '<(libs_loc)/lzma/C/Util/LzmaLib/Debug',
           '<(libs_loc)/opus/win32/VS2015/Win32/Debug',
           '<(libs_loc)/openal-soft/build/Debug',
@@ -54,11 +47,7 @@
         ],
       },
       'Release': {
-        'include_dirs': [
-          '<(libs_loc)/openssl/Release/include',
-        ],
         'library_dirs': [
-          '<(libs_loc)/openssl/Release/lib',
           '<(libs_loc)/lzma/C/Util/LzmaLib/Release',
           '<(libs_loc)/opus/win32/VS2015/Win32/Release',
           '<(libs_loc)/openal-soft/build/Release',

Telegram/gyp/tests/tests.gyp

@@ -23,6 +23,7 @@
     ],
     'dependencies': [
       '<!@(<(list_tests_command))',
+      'tests_storage',
     ],
     'sources': [
       '<!@(<(list_tests_command) --sources)',
@@ -102,19 +103,39 @@
       '<(src_loc)/rpl/lifetime.h',
       '<(src_loc)/rpl/map.h',
       '<(src_loc)/rpl/mappers.h',
-	  '<(src_loc)/rpl/merge.h',
+      '<(src_loc)/rpl/merge.h',
       '<(src_loc)/rpl/never.h',
       '<(src_loc)/rpl/operators_tests.cpp',
       '<(src_loc)/rpl/producer.h',
       '<(src_loc)/rpl/producer_tests.cpp',
       '<(src_loc)/rpl/range.h',
       '<(src_loc)/rpl/rpl.h',
-	  '<(src_loc)/rpl/skip.h',
+      '<(src_loc)/rpl/skip.h',
       '<(src_loc)/rpl/take.h',
       '<(src_loc)/rpl/then.h',
       '<(src_loc)/rpl/type_erased.h',
       '<(src_loc)/rpl/variable.h',
       '<(src_loc)/rpl/variable_tests.cpp',
     ],
+  }, {
+    'target_name': 'tests_storage',
+    'includes': [
+      'common_test.gypi',
+      '../openssl.gypi',
+    ],
+    'dependencies': [
+      '../lib_storage.gyp:lib_storage',
+    ],
+    'sources': [
+      '<(src_loc)/storage/storage_encrypted_file_tests.cpp',
+      '<(src_loc)/platform/win/windows_dlls.cpp',
+      '<(src_loc)/platform/win/windows_dlls.h',
+    ],
+    'conditions': [[ 'not build_win', {
+	  'sources!': [
+        '<(src_loc)/platform/win/windows_dlls.cpp',
+        '<(src_loc)/platform/win/windows_dlls.h',
+	  ],
+	}]],
   }],
 }