6ba8898ea3ed5b395f885c086d6648c1921bcc90
[core.git] / framework / main / classes / streams / crypto / class_OpenSslStream.php
1 <?php
2 // Own namespace
3 namespace CoreFramework\Stream\Crypto;
4
5 // Import framework stuff
6 use CoreFramework\Crypto\RandomNumber\RandomNumberGenerator;
7
8 /**
9  * An OpenSSL-based encryption stream
10  *
11  * @author              Roland Haeder <webmaster@shipsimu.org>
12  * @version             0.0.0
13  * @copyright   Copyright (c) 2007, 2008 Roland Haeder, 2009 - 2017 Core Developer Team
14  * @license             GNU GPL 3.0 or any newer version
15  * @link                http://www.shipsimu.org
16  *
17  * This program is free software: you can redistribute it and/or modify
18  * it under the terms of the GNU General Public License as published by
19  * the Free Software Foundation, either version 3 of the License, or
20  * (at your option) any later version.
21  *
22  * This program is distributed in the hope that it will be useful,
23  * but WITHOUT ANY WARRANTY; without even the implied warranty of
24  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
25  * GNU General Public License for more details.
26  *
27  * You should have received a copy of the GNU General Public License
28  * along with this program. If not, see <http://www.gnu.org/licenses/>.
29  */
30 class OpenSslStream extends BaseStream implements EncryptableStream {
31         /**
32          * Protected constructor
33          *
34          * @return      void
35          */
36         protected function __construct () {
37                 // Call parent constructor
38                 parent::__construct(__CLASS__);
39         }
40
41         /**
42          * Creates an instance of this node class
43          *
44          * @param       $rngInstance            An RNG instance
45          * @return      $streamInstance         An instance of this node class
46          */
47         public static final function createOpenSslStream (RandomNumberGenerator $rngInstance) {
48                 // Get a new instance
49                 $streamInstance = new OpenSslStream();
50
51                 // Set the RNG instance
52                 $streamInstance->setRngInstance($rngInstance);
53
54                 // Return the instance
55                 return $streamInstance;
56         }
57
58         /**
59          * Encrypt the string with fixed salt
60          *
61          * @param       $str            The unencrypted string
62          * @param       $key            Optional key, if none provided, a random key will be generated
63          * @return      $encrypted      Encrypted string
64          */
65         public function encryptStream ($str, $key = NULL) {
66                 // @TODO unfinished
67                 return $str;
68
69                 // Debug message
70                 //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('[' . __METHOD__ . ':' . __LINE__ . ']: key[' . gettype($key) . ']=' . $key);
71
72                 // Init crypto module
73                 $iv_size = mcrypt_get_iv_size(MCRYPT_RIJNDAEL_256, MCRYPT_MODE_ECB);
74                 $iv = mcrypt_create_iv($iv_size, MCRYPT_RAND);
75
76                 // Generate key, if none provided
77                 if (is_null($key)) {
78                         // None provided
79                         $key = $this->getRngInstance()->generateKey();
80                 } // END - if
81
82                 // Add some "payload" to the string
83                 switch ($this->getRngInstance()->randomNumber(0, 8)) {
84                         case 0:
85                                 $payloadString = crc32($this->getRngInstance()->randomString(10)) . EncryptableStream::DATA_PAYLOAD_SEPARATOR . base64_encode($str) . EncryptableStream::DATA_PAYLOAD_SEPARATOR . crc32($this->getRngInstance()->randomString(20));
86                                 break;
87
88                         case 1:
89                                 $payloadString = crc32($this->getRngInstance()->randomString(10)) . EncryptableStream::DATA_PAYLOAD_SEPARATOR . base64_encode($str) . EncryptableStream::DATA_PAYLOAD_SEPARATOR . md5($this->getRngInstance()->randomString(20));
90                                 break;
91
92                         case 2:
93                                 $payloadString = crc32($this->getRngInstance()->randomString(10)) . EncryptableStream::DATA_PAYLOAD_SEPARATOR . base64_encode($str) . EncryptableStream::DATA_PAYLOAD_SEPARATOR . sha1($this->getRngInstance()->randomString(20));
94                                 break;
95
96                         case 3:
97                                 $payloadString = md5($this->getRngInstance()->randomString(10)) . EncryptableStream::DATA_PAYLOAD_SEPARATOR . base64_encode($str) . EncryptableStream::DATA_PAYLOAD_SEPARATOR . crc32($this->getRngInstance()->randomString(20));
98                                 break;
99
100                         case 4:
101                                 $payloadString = md5($this->getRngInstance()->randomString(10)) . EncryptableStream::DATA_PAYLOAD_SEPARATOR . base64_encode($str) . EncryptableStream::DATA_PAYLOAD_SEPARATOR . md5($this->getRngInstance()->randomString(20));
102                                 break;
103
104                         case 5:
105                                 $payloadString = md5($this->getRngInstance()->randomString(10)) . EncryptableStream::DATA_PAYLOAD_SEPARATOR . base64_encode($str) . EncryptableStream::DATA_PAYLOAD_SEPARATOR . sha1($this->getRngInstance()->randomString(20));
106                                 break;
107
108                         case 6:
109                                 $payloadString = sha1($this->getRngInstance()->randomString(10)) . EncryptableStream::DATA_PAYLOAD_SEPARATOR . base64_encode($str) . EncryptableStream::DATA_PAYLOAD_SEPARATOR . crc32($this->getRngInstance()->randomString(20));
110                                 break;
111
112                         case 7:
113                                 $payloadString = sha1($this->getRngInstance()->randomString(10)) . EncryptableStream::DATA_PAYLOAD_SEPARATOR . base64_encode($str) . EncryptableStream::DATA_PAYLOAD_SEPARATOR . md5($this->getRngInstance()->randomString(20));
114                                 break;
115
116                         case 8:
117                                 $payloadString = sha1($this->getRngInstance()->randomString(10)) . EncryptableStream::DATA_PAYLOAD_SEPARATOR . base64_encode($str) . EncryptableStream::DATA_PAYLOAD_SEPARATOR . sha1($this->getRngInstance()->randomString(20));
118                                 break;
119                 }
120
121                 // Encrypt the string
122                 $encrypted = mcrypt_encrypt(MCRYPT_RIJNDAEL_256, $key, $payloadString, MCRYPT_MODE_ECB, $iv);
123
124                 // Return the string
125                 return $encrypted;
126         }
127
128         /**
129          * Decrypt the string with fixed salt
130          *
131          * @param       $encrypted      Encrypted string
132          * @param       $key            Optional key, if none provided, a random key will be generated
133          * @return      $str            The unencrypted string
134          */
135         public function decryptStream ($encrypted, $key = NULL) {
136                 // @TODO unfinished
137                 return $encrypted;
138
139                 // Init crypto module
140                 $iv_size = mcrypt_get_iv_size(MCRYPT_RIJNDAEL_256, MCRYPT_MODE_ECB);
141                 $iv = mcrypt_create_iv($iv_size, MCRYPT_RAND);
142
143                 // Shall we use a default key or custom?
144                 if (is_null($key)) {
145                         // Generate (default) key
146                         $key = $this->getRngInstance()->generateKey();
147                 } // END - if
148
149                 // Decrypt the string
150                 $payloadString = mcrypt_decrypt(MCRYPT_RIJNDAEL_256, $key, $encrypted, MCRYPT_MODE_ECB, $iv);
151
152                 // Get the real string out
153                 $strArray = explode(EncryptableStream::DATA_PAYLOAD_SEPARATOR, $payloadString);
154
155                 // Does the element count match?
156                 assert(count($strArray) == 3);
157
158                 // Decode the string
159                 $str = base64_decode($strArray[1]);
160
161                 // Trim trailing nulls away
162                 $str = rtrim($str, "\0");
163
164                 // Return the string
165                 return $str;
166         }
167
168         /**
169          * Streams the data and maybe does something to it
170          *
171          * @param       $data   The data (string mostly) to "stream"
172          * @return      $data   The data (string mostly) to "stream"
173          * @throws      UnsupportedOperationException   If this method is called (which is a mistake)
174          */
175         public function streamData ($data) {
176                 self::createDebugInstance(__CLASS__, __LINE__)->debugOutput('Unhandled ' . strlen($data) . ' bytes in this stream.');
177                 throw new UnsupportedOperationException(array($this, __FUNCTION__), self::EXCEPTION_UNSPPORTED_OPERATION);
178         }
179
180 }