How to use header method in Sure

Best Python code snippet using sure_python

testCQCMessages.py

Source:testCQCMessages.py Github

copy

Full Screen

1#2# Copyright (c) 2018, Stephanie Wehner and Axel Dahlberg3# All rights reserved.4#5# Redistribution and use in source and binary forms, with or without6# modification, are permitted provided that the following conditions are met:7# 1. Redistributions of source code must retain the above copyright8# notice, this list of conditions and the following disclaimer.9# 2. Redistributions in binary form must reproduce the above copyright10# notice, this list of conditions and the following disclaimer in the11# documentation and/​or other materials provided with the distribution.12# 3. All advertising materials mentioning features or use of this software13# must display the following acknowledgement:14# This product includes software developed by Stephanie Wehner, QuTech.15# 4. Neither the name of the QuTech organization nor the16# names of its contributors may be used to endorse or promote products17# derived from this software without specific prior written permission.18#19# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDER ''AS IS'' AND ANY20# EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED21# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE22# DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER BE LIABLE FOR ANY23# DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES24# (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;25# LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND26# ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT27# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS28# SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.29import json30import unittest31import os32from SimulaQron.cqc.backend.cqcLogMessageHandler import CQCLogMessageHandler33from SimulaQron.cqc.pythonLib.cqc import CQCConnection, qubit, CQCUnsuppError, QubitNotActiveError34from SimulaQron.cqc.backend.cqcHeader import (35 CQCCmdHeader,36 CQC_CMD_SEND,37 CQC_CMD_EPR,38 CQC_CMD_CNOT,39 CQC_CMD_CPHASE,40 CQC_CMD_ROT_X,41 CQC_CMD_ROT_Y,42 CQC_CMD_ROT_Z,43 CQC_TP_COMMAND,44 CQC_TP_FACTORY,45 CQC_CMD_I,46 CQC_CMD_X,47 CQC_CMD_Y,48 CQC_CMD_Z,49 CQC_CMD_T,50 CQC_CMD_H,51 CQC_CMD_K,52 CQC_CMD_NEW,53 CQC_CMD_MEASURE,54 CQC_CMD_MEASURE_INPLACE,55 CQC_CMD_RESET,56 CQC_CMD_RECV,57 CQC_CMD_EPR_RECV,58 CQC_CMD_ALLOCATE,59 CQC_CMD_RELEASE,60 CQCCommunicationHeader,61 CQCXtraQubitHeader,62 CQCRotationHeader,63 CQCFactoryHeader,64 CQC_CMD_HDR_LENGTH,65)66def get_last_entries(amount):67 file = "{}/​logFile.json".format(CQCLogMessageHandler.dir_path)68 with open(file, "r") as outfile:69 logData = json.load(outfile)70 return logData[-amount:]71class CQCMessageTest(unittest.TestCase):72 # Only tests cqc_commands at the moment.73 # So no messages that are send back (notifications)74 @classmethod75 def setUpClass(cls):76 try:77 os.remove("{}/​logFile.json".format(CQCLogMessageHandler.dir_path))78 except OSError:79 pass80 @classmethod81 def tearDownClass(cls):82 try:83 os.remove("{}/​logFile.json".format(CQCLogMessageHandler.dir_path))84 except OSError:85 pass86 def testNewQubit(self):87 with CQCConnection("Alice", appID=1) as alice:88 qubit(alice, block=False, notify=False)89 lastEntry = get_last_entries(1)[0]90 cmd_header = lastEntry["cmd_header"]91 self.assertEqual(lastEntry["node_name"], "Alice")92 self.assertEqual(cmd_header["instruction"], CQC_CMD_NEW)93 self.assertEqual(cmd_header["block"], False)94 self.assertEqual(cmd_header["notify"], False)95 cqc_header = lastEntry["cqc_header"]96 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)97 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH)98 self.assertEqual(cqc_header["app_id"], 1)99 def testI(self):100 with CQCConnection("Alice", appID=1) as alice:101 q1 = qubit(alice)102 q1.I()103 lastEntry = get_last_entries(1)[0]104 self.assertEqual(lastEntry["node_name"], "Alice")105 cmd_header = lastEntry["cmd_header"]106 self.assertEqual(cmd_header["instruction"], CQC_CMD_I)107 self.assertEqual(cmd_header["block"], True)108 self.assertEqual(cmd_header["notify"], True)109 cqc_header = lastEntry["cqc_header"]110 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)111 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH)112 self.assertEqual(cqc_header["app_id"], 1)113 def testX(self):114 with CQCConnection("Alice", appID=1) as alice:115 q1 = qubit(alice)116 q1.X()117 lastEntry = get_last_entries(1)[0]118 self.assertEqual(lastEntry["node_name"], "Alice")119 cmd_header = lastEntry["cmd_header"]120 self.assertEqual(cmd_header["instruction"], CQC_CMD_X)121 self.assertEqual(cmd_header["block"], True)122 self.assertEqual(cmd_header["notify"], True)123 cqc_header = lastEntry["cqc_header"]124 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)125 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH)126 self.assertEqual(cqc_header["app_id"], 1)127 def testY(self):128 with CQCConnection("Alice", appID=1) as alice:129 q1 = qubit(alice)130 q1.Y()131 lastEntry = get_last_entries(1)[0]132 self.assertEqual(lastEntry["node_name"], "Alice")133 cmd_header = lastEntry["cmd_header"]134 self.assertEqual(cmd_header["instruction"], CQC_CMD_Y)135 self.assertEqual(cmd_header["block"], True)136 self.assertEqual(cmd_header["notify"], True)137 cqc_header = lastEntry["cqc_header"]138 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)139 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH)140 self.assertEqual(cqc_header["app_id"], 1)141 def testZ(self):142 with CQCConnection("Alice", appID=1) as alice:143 q1 = qubit(alice)144 q1.Z()145 lastEntry = get_last_entries(1)[0]146 self.assertEqual(lastEntry["node_name"], "Alice")147 cmd_header = lastEntry["cmd_header"]148 self.assertEqual(cmd_header["instruction"], CQC_CMD_Z)149 self.assertEqual(cmd_header["block"], True)150 self.assertEqual(cmd_header["notify"], True)151 cqc_header = lastEntry["cqc_header"]152 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)153 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH)154 self.assertEqual(cqc_header["app_id"], 1)155 def testH(self):156 with CQCConnection("Alice", appID=1) as alice:157 q1 = qubit(alice)158 q1.H()159 lastEntry = get_last_entries(1)[0]160 self.assertEqual(lastEntry["node_name"], "Alice")161 cmd_header = lastEntry["cmd_header"]162 self.assertEqual(cmd_header["instruction"], CQC_CMD_H)163 self.assertEqual(cmd_header["block"], True)164 self.assertEqual(cmd_header["notify"], True)165 cqc_header = lastEntry["cqc_header"]166 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)167 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH)168 self.assertEqual(cqc_header["app_id"], 1)169 def testT(self):170 with CQCConnection("Alice", appID=1) as alice:171 q1 = qubit(alice)172 q1.T()173 lastEntry = get_last_entries(1)[0]174 self.assertEqual(lastEntry["node_name"], "Alice")175 cmd_header = lastEntry["cmd_header"]176 self.assertEqual(cmd_header["instruction"], CQC_CMD_T)177 self.assertEqual(cmd_header["block"], True)178 self.assertEqual(cmd_header["notify"], True)179 cqc_header = lastEntry["cqc_header"]180 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)181 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH)182 self.assertEqual(cqc_header["app_id"], 1)183 def testK(self):184 with CQCConnection("Alice", appID=1) as alice:185 q1 = qubit(alice)186 q1.K()187 lastEntry = get_last_entries(1)[0]188 self.assertEqual(lastEntry["node_name"], "Alice")189 cmd_header = lastEntry["cmd_header"]190 self.assertEqual(cmd_header["instruction"], CQC_CMD_K)191 self.assertEqual(cmd_header["block"], True)192 self.assertEqual(cmd_header["notify"], True)193 cqc_header = lastEntry["cqc_header"]194 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)195 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH)196 self.assertEqual(cqc_header["app_id"], 1)197 def testRotX(self):198 with CQCConnection("Alice", appID=1) as alice:199 q1 = qubit(alice)200 q1.rot_X(200)201 lastEntry = get_last_entries(1)[0]202 self.assertEqual(lastEntry["node_name"], "Alice")203 cmd_header = lastEntry["cmd_header"]204 self.assertEqual(cmd_header["instruction"], CQC_CMD_ROT_X)205 self.assertEqual(cmd_header["block"], True)206 self.assertEqual(cmd_header["notify"], True)207 cqc_header = lastEntry["cqc_header"]208 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)209 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH + CQCRotationHeader.HDR_LENGTH)210 self.assertEqual(cqc_header["app_id"], 1)211 xtra_header = lastEntry["xtra_header"]212 self.assertEqual(xtra_header["step"], 200)213 def testRotY(self):214 with CQCConnection("Alice", appID=1) as alice:215 q1 = qubit(alice)216 q1.rot_Y(200)217 lastEntry = get_last_entries(1)[0]218 self.assertEqual(lastEntry["node_name"], "Alice")219 cmd_header = lastEntry["cmd_header"]220 self.assertEqual(cmd_header["instruction"], CQC_CMD_ROT_Y)221 self.assertEqual(cmd_header["block"], True)222 self.assertEqual(cmd_header["notify"], True)223 cqc_header = lastEntry["cqc_header"]224 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)225 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH + CQCRotationHeader.HDR_LENGTH)226 self.assertEqual(cqc_header["app_id"], 1)227 xtra_header = lastEntry["xtra_header"]228 self.assertEqual(xtra_header["step"], 200)229 def testRotZ(self):230 with CQCConnection("Alice", appID=1) as alice:231 q1 = qubit(alice)232 q1.rot_Z(200)233 lastEntry = get_last_entries(1)[0]234 self.assertEqual(lastEntry["node_name"], "Alice")235 cmd_header = lastEntry["cmd_header"]236 self.assertEqual(cmd_header["instruction"], CQC_CMD_ROT_Z)237 self.assertEqual(cmd_header["block"], True)238 self.assertEqual(cmd_header["notify"], True)239 cqc_header = lastEntry["cqc_header"]240 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)241 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH + CQCRotationHeader.HDR_LENGTH)242 self.assertEqual(cqc_header["app_id"], 1)243 xtra_header = lastEntry["xtra_header"]244 self.assertEqual(xtra_header["step"], 200)245 def testRotXFail(self):246 with CQCConnection("Alice", appID=1) as alice:247 q1 = qubit(alice)248 with self.assertRaises(ValueError):249 q1.rot_X(256)250 def testRotXFailNone(self):251 with CQCConnection("Alice", appID=1) as alice:252 q1 = qubit(alice)253 with self.assertRaises(ValueError):254 q1.rot_X(None)255 def testRotXFailNaN(self):256 with CQCConnection("Alice", appID=1) as alice:257 q1 = qubit(alice)258 with self.assertRaises(ValueError):259 q1.rot_X("four")260 def testRotXFailNegative(self):261 with CQCConnection("Alice", appID=1) as alice:262 q1 = qubit(alice)263 with self.assertRaises(ValueError):264 q1.rot_X(-1)265 def testRotXFailFloat(self):266 with CQCConnection("Alice", appID=1) as alice:267 q1 = qubit(alice)268 with self.assertRaises(ValueError):269 q1.rot_X(1.1)270 def testCNot(self):271 with CQCConnection("Alice", appID=1) as alice:272 q1 = qubit(alice)273 q2 = qubit(alice)274 q1.cnot(q2)275 lastEntry = get_last_entries(1)[0]276 self.assertEqual(lastEntry["node_name"], "Alice")277 cmd_header = lastEntry["cmd_header"]278 self.assertEqual(cmd_header["instruction"], CQC_CMD_CNOT)279 self.assertEqual(cmd_header["block"], True)280 self.assertEqual(cmd_header["notify"], True)281 cqc_header = lastEntry["cqc_header"]282 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)283 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH + CQCXtraQubitHeader.HDR_LENGTH)284 self.assertEqual(cqc_header["app_id"], 1)285 xtra_header = lastEntry["xtra_header"]286 self.assertEqual(xtra_header["qubit_id"], cmd_header["qubit_id"] + 1)287 def testCNotRemote(self):288 with CQCConnection("Alice", appID=1) as alice:289 # The appId in xtra_header['app_id'] is not 2 when testing.290 # In fact, doing this code in a real application result in an error as of 2018-03-12291 with CQCConnection("Bob", appID=2) as bob:292 q1 = qubit(alice)293 q2 = qubit(bob)294 with self.assertRaises(CQCUnsuppError):295 q1.cnot(q2)296 def testCPhase(self):297 with CQCConnection("Alice", appID=1) as alice:298 q1 = qubit(alice)299 q2 = qubit(alice)300 q1.cphase(q2)301 lastEntry = get_last_entries(1)[0]302 self.assertEqual(lastEntry["node_name"], "Alice")303 cmd_header = lastEntry["cmd_header"]304 self.assertEqual(cmd_header["instruction"], CQC_CMD_CPHASE)305 self.assertEqual(cmd_header["block"], True)306 self.assertEqual(cmd_header["notify"], True)307 cqc_header = lastEntry["cqc_header"]308 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)309 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH + CQCXtraQubitHeader.HDR_LENGTH)310 self.assertEqual(cqc_header["app_id"], 1)311 xtra_header = lastEntry["xtra_header"]312 self.assertEqual(xtra_header["qubit_id"], cmd_header["qubit_id"] + 1)313 def testSend(self):314 with CQCConnection("Alice", appID=1) as alice:315 q1 = qubit(alice)316 alice.sendQubit(q1, "Bob", remote_appID=2)317 lastEntry = get_last_entries(1)[0]318 self.assertEqual(lastEntry["node_name"], "Alice")319 cmd_header = lastEntry["cmd_header"]320 self.assertEqual(cmd_header["instruction"], CQC_CMD_SEND)321 self.assertEqual(cmd_header["block"], True)322 self.assertEqual(cmd_header["notify"], True)323 cqc_header = lastEntry["cqc_header"]324 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)325 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH + CQCCommunicationHeader.HDR_LENGTH)326 self.assertEqual(cqc_header["app_id"], 1)327 xtra_header = lastEntry["xtra_header"]328 self.assertEqual(xtra_header["remote_app_id"], 2)329 self.assertNotEqual(xtra_header["remote_node"], 0)330 self.assertNotEqual(xtra_header["remote_port"], 0)331 def testSendSelf(self):332 with CQCConnection("Alice", appID=1) as alice:333 # Should not work in a real application334 q1 = qubit(alice)335 alice.sendQubit(q1, "Alice", remote_appID=1)336 lastEntry = get_last_entries(1)[0]337 self.assertEqual(lastEntry["node_name"], "Alice")338 cmd_header = lastEntry["cmd_header"]339 self.assertEqual(cmd_header["instruction"], CQC_CMD_SEND)340 self.assertEqual(cmd_header["block"], True)341 self.assertEqual(cmd_header["notify"], True)342 cqc_header = lastEntry["cqc_header"]343 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)344 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH + CQCCommunicationHeader.HDR_LENGTH)345 self.assertEqual(cqc_header["app_id"], 1)346 xtra_header = lastEntry["xtra_header"]347 self.assertEqual(xtra_header["remote_app_id"], 1)348 self.assertNotEqual(xtra_header["remote_node"], 0)349 self.assertNotEqual(xtra_header["remote_port"], 0)350 def testRecv(self):351 with CQCConnection("Alice", appID=1) as alice:352 alice.recvQubit()353 lastEntry = get_last_entries(1)[0]354 self.assertEqual(lastEntry["node_name"], "Alice")355 cmd_header = lastEntry["cmd_header"]356 self.assertEqual(cmd_header["instruction"], CQC_CMD_RECV)357 self.assertEqual(cmd_header["block"], True)358 self.assertEqual(cmd_header["notify"], True)359 cqc_header = lastEntry["cqc_header"]360 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)361 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH)362 self.assertEqual(cqc_header["app_id"], 1)363 def testEPRSend(self):364 with CQCConnection("Alice", appID=1) as alice:365 alice.createEPR("Bob", remote_appID=2)366 entries = get_last_entries(5)367 cmd_header_epr = entries[0]["cmd_header"]368 self.assertEqual(entries[0]["node_name"], "Alice")369 self.assertEqual(cmd_header_epr["instruction"], CQC_CMD_EPR)370 self.assertEqual(cmd_header_epr["block"], True)371 self.assertEqual(cmd_header_epr["notify"], True)372 cqc_header_epr = entries[0]["cqc_header"]373 self.assertEqual(cqc_header_epr["type"], CQC_TP_COMMAND)374 for i in range(5):375 self.assertEqual(376 entries[i]["cqc_header"]["header_length"], CQC_CMD_HDR_LENGTH + CQCCommunicationHeader.HDR_LENGTH377 )378 self.assertEqual(cqc_header_epr["app_id"], 1)379 xtra_header_epr = entries[0]["xtra_header"]380 self.assertEqual(xtra_header_epr["remote_app_id"], 2)381 self.assertNotEqual(xtra_header_epr["remote_node"], 0)382 self.assertNotEqual(xtra_header_epr["remote_port"], 0)383 # Check if the qubits are created correctly384 # The protocol already knows what do to on EPR, so no new headers are made,385 # This means that the header of createEPR() is send into new(),386 # New headers have to be made for H() and CNOT() for the qubit ids,387 # but the instruction is not needed, defaults to 0388 self.assertEqual(entries[1]["cmd_header"]["instruction"], CQC_CMD_EPR)389 self.assertEqual(entries[3]["cmd_header"]["instruction"], 0)390 self.assertEqual(entries[4]["cmd_header"]["instruction"], 0)391 self.assertEqual(entries[4]["cmd_header"]["qubit_id"] + 1, entries[4]["xtra_header"]["qubit_id"])392 def testEPRRecv(self):393 with CQCConnection("Alice", appID=1) as alice:394 alice.recvEPR()395 lastEntry = get_last_entries(1)[0]396 self.assertEqual(lastEntry["node_name"], "Alice")397 cmd_header = lastEntry["cmd_header"]398 self.assertEqual(cmd_header["instruction"], CQC_CMD_EPR_RECV)399 self.assertEqual(cmd_header["block"], True)400 self.assertEqual(cmd_header["notify"], True)401 cqc_header = lastEntry["cqc_header"]402 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)403 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH)404 self.assertEqual(cqc_header["app_id"], 1)405 def testMeasure(self):406 with CQCConnection("Alice", appID=1) as alice:407 q1 = qubit(alice)408 m1 = q1.measure()409 # We've set that for this testing purposes, the measurement outcome is410 # always 2411 self.assertEqual(m1, 2)412 lastEntry = get_last_entries(1)[0]413 self.assertEqual(lastEntry["node_name"], "Alice")414 cmd_header = lastEntry["cmd_header"]415 self.assertEqual(cmd_header["instruction"], CQC_CMD_MEASURE)416 self.assertEqual(cmd_header["block"], True)417 self.assertEqual(cmd_header["notify"], False)418 cqc_header = lastEntry["cqc_header"]419 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)420 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH)421 self.assertEqual(cqc_header["app_id"], 1)422 self.assertFalse(q1._active)423 def testMeasureInplace(self):424 with CQCConnection("Alice", appID=1) as alice:425 q1 = qubit(alice)426 m1 = q1.measure(inplace=True)427 # We've set that for this testing purposes, the measurement outcome is428 # always 2429 self.assertEqual(m1, 2)430 lastEntry = get_last_entries(1)[0]431 self.assertEqual(lastEntry["node_name"], "Alice")432 cmd_header = lastEntry["cmd_header"]433 self.assertEqual(cmd_header["instruction"], CQC_CMD_MEASURE_INPLACE)434 self.assertEqual(cmd_header["block"], True)435 self.assertEqual(cmd_header["notify"], False)436 cqc_header = lastEntry["cqc_header"]437 self.assertEqual(cqc_header["type"], CQC_TP_COMMAND)438 self.assertEqual(cqc_header["header_length"], CQC_CMD_HDR_LENGTH)439 self.assertEqual(cqc_header["app_id"], 1)440 self.assertTrue(q1._active)441 def testFactoryZero(self):442 with CQCConnection("Alice", appID=1) as alice:443 q1 = qubit(alice)444 alice.set_pending(True)445 q1.X()446 alice.flush_factory(0, do_sequence=False)447 alice.set_pending(False)448 q1.measure(inplace=True)449 # Checking the factory and the measure, factory should not log any commands450 lastEntries = get_last_entries(2)451 factoryEntry = lastEntries[0]452 self.assertEqual(factoryEntry["node_name"], "Alice")453 factory_cqc_header = factoryEntry["cqc_header"]454 self.assertEqual(factory_cqc_header["type"], CQC_TP_FACTORY)455 expected_length = CQCFactoryHeader.HDR_LENGTH + CQC_CMD_HDR_LENGTH456 self.assertEqual(factory_cqc_header["header_length"], expected_length)457 self.assertEqual(factoryEntry["factory_iterations"], 0)458 measureEntry = lastEntries[1]459 self.assertEqual(measureEntry["node_name"], "Alice")460 self.assertEqual(measureEntry["cmd_header"]["instruction"], CQC_CMD_MEASURE_INPLACE)461 self.assertEqual(measureEntry["cmd_header"]["qubit_id"], q1._qID)462 q1.measure()463 def testFactoryOnce(self):464 with CQCConnection("Alice", appID=1) as alice:465 q1 = qubit(alice)466 alice.set_pending(True)467 q1.X()468 alice.flush_factory(1, do_sequence=False)469 alice.set_pending(False)470 q1.measure(inplace=True)471 # Doing a factory once is equal to doing a sequence, so the factory header is not send472 lastEntries = get_last_entries(2)473 xEntry = lastEntries[0]474 self.assertEqual(xEntry["node_name"], "Alice")475 x_cmd_cmd_header = xEntry["cmd_header"]476 self.assertEqual(x_cmd_cmd_header["instruction"], CQC_CMD_X)477 self.assertEqual(x_cmd_cmd_header["qubit_id"], q1._qID)478 # cqc header is the same as the first.479 measureEntry = lastEntries[1]480 self.assertEqual(measureEntry["node_name"], "Alice")481 self.assertEqual(measureEntry["cmd_header"]["instruction"], CQC_CMD_MEASURE_INPLACE)482 self.assertEqual(measureEntry["cmd_header"]["qubit_id"], q1._qID)483 def testFactoryN(self):484 with CQCConnection("Alice", appID=1) as alice:485 q1 = qubit(alice)486 alice.set_pending(True)487 q1.X()488 alice.flush_factory(10, do_sequence=False)489 alice.set_pending(False)490 q1.measure(inplace=True)491 # Checking the factory and the measure, factory should not log any commands492 lastEntries = get_last_entries(12)493 factoryEntry = lastEntries[0]494 self.assertEqual(factoryEntry["node_name"], "Alice")495 factory_cqc_header = factoryEntry["cqc_header"]496 self.assertEqual(factory_cqc_header["type"], CQC_TP_FACTORY)497 expected_length = CQCFactoryHeader.HDR_LENGTH + CQC_CMD_HDR_LENGTH498 self.assertEqual(factory_cqc_header["header_length"], expected_length)499 self.assertEqual(factoryEntry["factory_iterations"], 10)500 for i in range(1, 11):501 xEntry = lastEntries[i]502 x_cmd_cmd_header = xEntry["cmd_header"]503 self.assertEqual(x_cmd_cmd_header["instruction"], CQC_CMD_X)504 self.assertEqual(x_cmd_cmd_header["qubit_id"], q1._qID)505 # cqc header is the same as the first.506 measureEntry = lastEntries[11]507 self.assertEqual(measureEntry["cmd_header"]["instruction"], CQC_CMD_MEASURE_INPLACE)508 self.assertEqual(measureEntry["cmd_header"]["qubit_id"], q1._qID)509 def testFactoryCNOTFalse(self):510 with CQCConnection("Alice", appID=1) as alice:511 q1 = qubit(alice)512 qubit(alice)513 with self.assertRaises(CQCUnsuppError):514 alice.set_pending(True)515 q1.cnot(q1)516 alice.flush_factory(10, do_sequence=False)517 alice.set_pending(False)518 def testFactoryCNOT(self):519 with CQCConnection("Alice", appID=1) as alice:520 q1 = qubit(alice)521 q2 = qubit(alice)522 alice.set_pending(True)523 q1.cnot(q2)524 alice.flush_factory(10, do_sequence=False)525 alice.set_pending(False)526 entries = get_last_entries(11)527 factoryEntry = entries[0]528 self.assertEqual(factoryEntry["node_name"], "Alice")529 factory_cqc_header = factoryEntry["cqc_header"]530 self.assertEqual(factory_cqc_header["type"], CQC_TP_FACTORY)531 expected_length = CQCFactoryHeader.HDR_LENGTH + CQC_CMD_HDR_LENGTH + CQCXtraQubitHeader.HDR_LENGTH532 self.assertEqual(factory_cqc_header["header_length"], expected_length)533 self.assertEqual(factoryEntry["factory_iterations"], 10)534 for i in range(1, 11):535 xEntry = entries[i]536 x_cmd_cmd_header = xEntry["cmd_header"]537 self.assertEqual(x_cmd_cmd_header["instruction"], CQC_CMD_CNOT)538 self.assertEqual(x_cmd_cmd_header["qubit_id"], q1._qID)539 x = xEntry["xtra_header"]540 self.assertEqual(x["qubit_id"], q2._qID)541 def testFactoryCPHASE(self):542 with CQCConnection("Alice", appID=1) as alice:543 q1 = qubit(alice)544 q2 = qubit(alice)545 alice.set_pending(True)546 q1.cphase(q2)547 alice.flush_factory(10, do_sequence=False)548 alice.set_pending(False)549 entries = get_last_entries(11)550 factoryEntry = entries[0]551 self.assertEqual(factoryEntry["node_name"], "Alice")552 factory_cqc_header = factoryEntry["cqc_header"]553 self.assertEqual(factory_cqc_header["type"], CQC_TP_FACTORY)554 expected_length = CQCFactoryHeader.HDR_LENGTH + CQC_CMD_HDR_LENGTH + CQCXtraQubitHeader.HDR_LENGTH555 self.assertEqual(factory_cqc_header["header_length"], expected_length)556 self.assertEqual(factoryEntry["factory_iterations"], 10)557 for i in range(1, 11):558 xEntry = entries[i]559 x_cmd_cmd_header = xEntry["cmd_header"]560 self.assertEqual(x_cmd_cmd_header["instruction"], CQC_CMD_CPHASE)561 self.assertEqual(x_cmd_cmd_header["qubit_id"], q1._qID)562 x = xEntry["xtra_header"]563 self.assertEqual(x["qubit_id"], q2._qID)564 def testFactoryROTX(self):565 with CQCConnection("Alice", appID=1) as alice:566 q1 = qubit(alice)567 alice.set_pending(True)568 q1.rot_X(step=5)569 alice.flush_factory(10, do_sequence=False)570 alice.set_pending(False)571 q1.measure(inplace=True)572 # Checking the factory and the measure, factory should not log any commands573 lastEntries = get_last_entries(12)574 factoryEntry = lastEntries[0]575 self.assertEqual(factoryEntry["node_name"], "Alice")576 factory_cqc_header = factoryEntry["cqc_header"]577 self.assertEqual(factory_cqc_header["type"], CQC_TP_FACTORY)578 expected_length = CQCFactoryHeader.HDR_LENGTH + CQC_CMD_HDR_LENGTH + CQCRotationHeader.HDR_LENGTH579 self.assertEqual(factory_cqc_header["header_length"], expected_length)580 self.assertEqual(factoryEntry["factory_iterations"], 10)581 for i in range(1, 11):582 xEntry = lastEntries[i]583 x_cmd_cmd_header = xEntry["cmd_header"]584 self.assertEqual(x_cmd_cmd_header["instruction"], CQC_CMD_ROT_X)585 self.assertEqual(x_cmd_cmd_header["qubit_id"], q1._qID)586 xtra_header = xEntry["xtra_header"]587 self.assertEqual(xtra_header["step"], 5)588 # cqc header is the same as the first.589 measureEntry = lastEntries[11]590 self.assertEqual(measureEntry["cmd_header"]["instruction"], CQC_CMD_MEASURE_INPLACE)591 self.assertEqual(measureEntry["cmd_header"]["qubit_id"], q1._qID)592 def testFactoryNew(self):593 with CQCConnection("Alice", appID=1) as alice:594 # Should return a list of qubits with consecutive qubit ids595 alice.set_pending(True)596 qubit(alice)597 qubits = alice.flush_factory(10, do_sequence=False)598 # It is preferable to use the following however:599 # qubits = alice.allocate_qubits(10)600 alice.set_pending(False)601 # Checking the factory and the measure, factory should not log any commands602 lastEntries = get_last_entries(11)603 factoryEntry = lastEntries[0]604 self.assertEqual(factoryEntry["node_name"], "Alice")605 factory_cqc_header = factoryEntry["cqc_header"]606 self.assertEqual(factory_cqc_header["type"], CQC_TP_FACTORY)607 expected_length = CQCFactoryHeader.HDR_LENGTH + CQC_CMD_HDR_LENGTH608 self.assertEqual(factory_cqc_header["header_length"], expected_length)609 self.assertEqual(factoryEntry["factory_iterations"], 10)610 for i in range(1, 11):611 xEntry = lastEntries[i]612 x_cmd_cmd_header = xEntry["cmd_header"]613 self.assertEqual(x_cmd_cmd_header["instruction"], CQC_CMD_NEW)614 curID = qubits[0]._qID615 for q in qubits[1:]:616 self.assertEqual(q._qID, curID + 1)617 curID = q._qID618 def testFactoryMeasure(self):619 with CQCConnection("Alice", appID=1) as alice:620 # this one will go wrong in actual environment621 q1 = qubit(alice)622 alice.set_pending(True)623 q1.measure(inplace=False)624 # with self.assertRaises(QubitNotActiveError):625 measurements = alice.flush_factory(10, do_sequence=False)626 alice.set_pending(False)627 # All measurements should be equal to 2628 self.assertTrue(all(x == 2 for x in measurements))629 lastEntries = get_last_entries(11)630 factoryEntry = lastEntries[0]631 self.assertEqual(factoryEntry["node_name"], "Alice")632 factory_cqc_header = factoryEntry["cqc_header"]633 self.assertEqual(factory_cqc_header["type"], CQC_TP_FACTORY)634 expected_length = CQCFactoryHeader.HDR_LENGTH + CQC_CMD_HDR_LENGTH635 self.assertEqual(factory_cqc_header["header_length"], expected_length)636 self.assertEqual(factoryEntry["factory_iterations"], 10)637 for i in range(1, 11):638 xEntry = lastEntries[i]639 x_cmd_cmd_header = xEntry["cmd_header"]640 self.assertEqual(x_cmd_cmd_header["instruction"], CQC_CMD_MEASURE)641 self.assertEqual(x_cmd_cmd_header["qubit_id"], q1._qID)642 def testFactoryMeasureInplace(self):643 with CQCConnection("Alice", appID=1) as alice:644 # should give the same results as inplace = false645 q1 = qubit(alice)646 alice.set_pending(True)647 q1.measure(inplace=True)648 measurements = alice.flush_factory(10, do_sequence=False)649 alice.set_pending(False)650 # All measurements should be equal to 2651 self.assertTrue(all(x == 2 for x in measurements))652 lastEntries = get_last_entries(11)653 factoryEntry = lastEntries[0]654 self.assertEqual(factoryEntry["node_name"], "Alice")655 factory_cqc_header = factoryEntry["cqc_header"]656 self.assertEqual(factory_cqc_header["type"], CQC_TP_FACTORY)657 expected_length = CQCFactoryHeader.HDR_LENGTH + CQC_CMD_HDR_LENGTH658 self.assertEqual(factory_cqc_header["header_length"], expected_length)659 self.assertEqual(factoryEntry["factory_iterations"], 10)660 for i in range(1, 11):661 xEntry = lastEntries[i]662 x_cmd_cmd_header = xEntry["cmd_header"]663 self.assertEqual(x_cmd_cmd_header["instruction"], CQC_CMD_MEASURE_INPLACE)664 self.assertEqual(x_cmd_cmd_header["qubit_id"], q1._qID)665 def testFactoryReset(self):666 with CQCConnection("Alice", appID=1) as alice:667 q1 = qubit(alice)668 alice.set_pending(True)669 q1.reset()670 res = alice.flush_factory(10, do_sequence=False)671 alice.set_pending(False)672 self.assertListEqual(res, [])673 lastEntries = get_last_entries(11)674 factoryEntry = lastEntries[0]675 self.assertEqual(factoryEntry["node_name"], "Alice")676 factory_cqc_header = factoryEntry["cqc_header"]677 self.assertEqual(factory_cqc_header["type"], CQC_TP_FACTORY)678 expected_length = CQCFactoryHeader.HDR_LENGTH + CQC_CMD_HDR_LENGTH679 self.assertEqual(factory_cqc_header["header_length"], expected_length)680 self.assertEqual(factoryEntry["factory_iterations"], 10)681 for i in range(1, 11):682 xEntry = lastEntries[i]683 x_cmd_cmd_header = xEntry["cmd_header"]684 self.assertEqual(x_cmd_cmd_header["instruction"], CQC_CMD_RESET)685 self.assertEqual(x_cmd_cmd_header["qubit_id"], q1._qID)686 def testFactorySend(self):687 with CQCConnection("Alice", appID=1) as alice:688 q1 = qubit(alice)689 alice.set_pending(True)690 alice.sendQubit(q1, name="Bob", remote_appID=5)691 res = alice.flush_factory(10, do_sequence=False)692 alice.set_pending(False)693 self.assertListEqual(res, [])694 lastEntries = get_last_entries(11)695 factoryEntry = lastEntries[0]696 self.assertEqual(factoryEntry["node_name"], "Alice")697 factory_cqc_header = factoryEntry["cqc_header"]698 self.assertEqual(factory_cqc_header["type"], CQC_TP_FACTORY)699 expected_length = CQCFactoryHeader.HDR_LENGTH + CQC_CMD_HDR_LENGTH + CQCCommunicationHeader.HDR_LENGTH700 self.assertEqual(factory_cqc_header["header_length"], expected_length)701 self.assertEqual(factoryEntry["factory_iterations"], 10)702 for i in range(1, 11):703 xEntry = lastEntries[i]704 x_cmd_cmd_header = xEntry["cmd_header"]705 self.assertEqual(x_cmd_cmd_header["instruction"], CQC_CMD_SEND)706 self.assertEqual(x_cmd_cmd_header["qubit_id"], q1._qID)707 xtra_header = xEntry["xtra_header"]708 self.assertEqual(xtra_header["remote_app_id"], 5)709 self.assertGreater(xtra_header["remote_node"], 1)710 self.assertGreater(xtra_header["remote_port"], 1)711 def testFactoryRecv(self):712 with CQCConnection("Alice", appID=1) as alice:713 alice.set_pending(True)714 alice.recvQubit()715 qubits = alice.flush_factory(10, do_sequence=False)716 alice.set_pending(False)717 curID = qubits[0]._qID718 for q in qubits[1:]:719 self.assertEqual(q._qID, curID + 1)720 curID = q._qID721 lastEntries = get_last_entries(11)722 factoryEntry = lastEntries[0]723 self.assertEqual(factoryEntry["node_name"], "Alice")724 factory_cqc_header = factoryEntry["cqc_header"]725 self.assertEqual(factory_cqc_header["type"], CQC_TP_FACTORY)726 expected_length = CQCFactoryHeader.HDR_LENGTH + CQC_CMD_HDR_LENGTH727 self.assertEqual(factory_cqc_header["header_length"], expected_length)728 self.assertEqual(factoryEntry["factory_iterations"], 10)729 for i in range(1, 11):730 xEntry = lastEntries[i]731 x_cmd_cmd_header = xEntry["cmd_header"]732 self.assertEqual(x_cmd_cmd_header["instruction"], CQC_CMD_RECV)733 def testFactoryEPR(self):734 with CQCConnection("Alice", appID=1) as alice:735 alice.set_pending(True)736 alice.createEPR(name="Bob", remote_appID=5)737 qubits = alice.flush_factory(10, do_sequence=False)738 alice.set_pending(False)739 lastEntries = get_last_entries(51)740 factoryEntry = lastEntries[0]741 self.assertEqual(factoryEntry["node_name"], "Alice")742 factory_cqc_header = factoryEntry["cqc_header"]743 self.assertEqual(factory_cqc_header["type"], CQC_TP_FACTORY)744 expected_length = CQCFactoryHeader.HDR_LENGTH + CQC_CMD_HDR_LENGTH + CQCCommunicationHeader.HDR_LENGTH745 self.assertEqual(factory_cqc_header["header_length"], expected_length)746 self.assertEqual(factoryEntry["factory_iterations"], 10)747 # Check if the qubits are created correctly748 # The protocol already knows what do to on EPR, so no new headers are made,749 # This means that the header of createEPR() is send into new(),750 # New headers have to be made for H() and CNOT() for the qubit ids,751 # but the instruction is not needed, defaults to 0752 curID = [qubits[0]._qID]753 for q in qubits[1:]:754 self.assertEqual(q._qID, curID[-1] + 2)755 curID.append(q._qID)756 for i in range(10):757 xEntry = lastEntries[5 * i + 1]758 x_cmd_cmd_header = xEntry["cmd_header"]759 self.assertEqual(x_cmd_cmd_header["instruction"], CQC_CMD_EPR)760 xtra_header = xEntry["xtra_header"]761 self.assertEqual(xtra_header["remote_app_id"], 5)762 self.assertGreater(xtra_header["remote_node"], 0)763 self.assertGreater(xtra_header["remote_port"], 0)764 xEntry = lastEntries[5 * i + 2]765 x_cmd_cmd_header = xEntry["cmd_header"]766 self.assertEqual(x_cmd_cmd_header["instruction"], CQC_CMD_EPR)767 xEntry = lastEntries[5 * i + 3]768 x_cmd_cmd_header = xEntry["cmd_header"]769 self.assertEqual(x_cmd_cmd_header["instruction"], CQC_CMD_EPR)770 xEntry = lastEntries[5 * i + 4]771 x_cmd_cmd_header = xEntry["cmd_header"] # H Header772 self.assertEqual(x_cmd_cmd_header["instruction"], 0)773 id1 = x_cmd_cmd_header["qubit_id"]774 # Let's see the qubit id is in agreement with the received ones775 self.assertEqual(id1, curID[i])776 xEntry = lastEntries[5 * i + 5]777 x_cmd_cmd_header = xEntry["cmd_header"] # CNOT Header778 self.assertEqual(x_cmd_cmd_header["instruction"], 0)779 self.assertEqual(id1, x_cmd_cmd_header["qubit_id"])780 self.assertEqual(id1 + 1, xEntry["xtra_header"]["qubit_id"])781 def testFactoryEPR_RECV(self):782 with CQCConnection("Alice", appID=1) as alice:783 alice.set_pending(True)784 alice.recvEPR()785 qubits = alice.flush_factory(10, do_sequence=False)786 alice.set_pending(False)787 curID = qubits[0]._qID788 for q in qubits[1:]:789 self.assertEqual(q._qID, curID + 1)790 curID = q._qID791 lastEntries = get_last_entries(11)792 factoryEntry = lastEntries[0]793 self.assertEqual(factoryEntry["node_name"], "Alice")794 factory_cqc_header = factoryEntry["cqc_header"]795 self.assertEqual(factory_cqc_header["type"], CQC_TP_FACTORY)796 expected_length = CQCFactoryHeader.HDR_LENGTH + CQC_CMD_HDR_LENGTH797 self.assertEqual(factory_cqc_header["header_length"], expected_length)798 self.assertEqual(factoryEntry["factory_iterations"], 10)799 for i in range(1, 11):800 xEntry = lastEntries[i]801 x_cmd_cmd_header = xEntry["cmd_header"]802 self.assertEqual(x_cmd_cmd_header["instruction"], CQC_CMD_EPR_RECV)803 def testAllocate0(self):804 with CQCConnection("Alice", appID=1) as alice:805 qubits = alice.allocate_qubits(0)806 self.assertEqual(qubits, [])807 entry = get_last_entries(1)[0]808 self.assertEqual(entry["node_name"], "Alice")809 cqc_hdr = entry["cqc_header"]810 self.assertEqual(cqc_hdr["type"], CQC_TP_COMMAND)811 self.assertEqual(cqc_hdr["header_length"], CQCCmdHeader.HDR_LENGTH)812 cmd_hdr = entry["cmd_header"]813 self.assertEqual(cmd_hdr["instruction"], CQC_CMD_ALLOCATE)814 self.assertEqual(cmd_hdr["qubit_id"], 0)815 def testAllocate10(self):816 with CQCConnection("Alice", appID=1) as alice:817 qubits = alice.allocate_qubits(10)818 self.assertEqual(len(qubits), 10)819 curID = qubits[0]._qID820 for q in qubits[1:]:821 self.assertTrue(q._active)822 self.assertEqual(q._qID, curID + 1)823 curID = q._qID824 entry = get_last_entries(1)[0]825 self.assertEqual(entry["node_name"], "Alice")826 cqc_hdr = entry["cqc_header"]827 self.assertEqual(cqc_hdr["type"], CQC_TP_COMMAND)828 self.assertEqual(cqc_hdr["header_length"], CQCCmdHeader.HDR_LENGTH)829 cmd_hdr = entry["cmd_header"]830 self.assertEqual(cmd_hdr["instruction"], CQC_CMD_ALLOCATE)831 self.assertEqual(cmd_hdr["qubit_id"], 10)832 def testRelease(self):833 with CQCConnection("Alice", appID=1) as alice:834 qubits = alice.allocate_qubits(10)835 alice.release_qubits(qubits)836 for q in qubits:837 self.assertFalse(q._active)838 entries = get_last_entries(10)839 for i in range(10):840 entry = entries[i]841 self.assertEqual(entry["node_name"], "Alice")842 cqc_hdr = entry["cqc_header"]843 self.assertEqual(cqc_hdr["type"], CQC_TP_COMMAND)844 self.assertEqual(cqc_hdr["header_length"], 10 * CQCCmdHeader.HDR_LENGTH)845 cmd_hdr = entry["cmd_header"]846 self.assertEqual(cmd_hdr["instruction"], CQC_CMD_RELEASE)847 self.assertEqual(cmd_hdr["qubit_id"], qubits[i]._qID)848 def testReleaseWhenAlreadyReleased(self):849 with CQCConnection("Alice", appID=1) as alice:850 qubits = alice.allocate_qubits(10)851 qubits[0].measure()852 with self.assertRaises(QubitNotActiveError):853 alice.release_qubits(qubits)854 self.assertTrue(qubits[1]._active)855if __name__ == "__main__":...

Full Screen

Full Screen

personal.js

Source:personal.js Github

copy

Full Screen

1 /​/​ start header2 function getScrollAmountForStickyHeader() {3 return void 0 !== qodeGlobalVars.vars.page_scroll_amount_for_sticky && "" !== qodeGlobalVars.vars.page_scroll_amount_for_sticky ? amount = qodeGlobalVars.vars.page_scroll_amount_for_sticky : $(".carousel.full_screen").length ? amount = $(".carousel").height() : amount = scroll_amount_for_sticky, amount4 }5 6 function qodeBrowserDetection() {7 var e = /​Chrome/​.test(navigator.userAgent) && /​Google Inc/​.test(navigator.vendor),8 t = /​Safari/​.test(navigator.userAgent) && /​Apple Computer/​.test(navigator.vendor),9 o = navigator.userAgent.toLowerCase().indexOf("firefox") > -1,10 n = window.navigator.userAgent.indexOf("MSIE ");11 e && qode_body.addClass("qode-chrome"), t && qode_body.addClass("qode-safari"), o && qode_body.addClass("qode-firefox"), (n > 0 || navigator.userAgent.match(/​Trident.*rv\:11\./​)) && qode_body.addClass("qode-ms-explorer"), /​Edge\/​\d./​i.test(navigator.userAgent) && qode_body.addClass("qode-edge")12 }13 14 function headerSize(e) {15 "use strict";16 /​/​if ($("header.page_header").hasClass("scroll_top") && $("header.page_header").hasClass("has_top") && ($("header.page_header").hasClass("fixed") || $("header.page_header").hasClass("fixed_hiding")) && (e >= 0 && e <= 34 ? ($("header.page_header").css("top", -e), $("header.page_header").css("margin-top", 0), $(".header_top").show()) : e > 34 && ($("header.page_header").css("top", "-34px"), $("header.page_header").css("margin-top", 34), $(".header_top").hide())), sticky_amount = getScrollAmountForStickyHeader(), $("header").hasClass("regular") && (header_height - logo_height >= 10 ? $(".q_logo a").height(logo_height) : $(".q_logo a").height(header_height - 10), $(".q_logo a img").css("height", "100%")), $("header.page_header").hasClass("fixed") && ($top_header_height = $("header.page_header").hasClass("scroll_top") ? 34 : 0, header_height - e + $top_header_height >= min_header_height_scroll && e >= $top_header_height ? ($("header.page_header").removeClass("scrolled"), $("header:not(.centered_logo.centered_logo_animate) nav.main_menu > ul > li > a").css("line-height", header_height - e + $top_header_height + "px"), $("header:not(.centered_logo.centered_logo_animate) .side_menu_button").css("height", header_height - e + $top_header_height + "px"), $("header:not(.centered_logo.centered_logo_animate) .shopping_cart_inner").css("height", header_height - e + $top_header_height + "px"), $("header:not(.centered_logo.centered_logo_animate) .header_bottom .qode-login-register-widget.qode-user-logged-in .qode-logged-in-user").css("height", header_height - e + $top_header_height + "px"), $("header:not(.centered_logo.centered_logo_animate) .logo_wrapper").css("height", header_height - e + $top_header_height + "px"), header_height - logo_height > 0 ? $("header:not(.centered_logo.centered_logo_animate) .q_logo a").css("height", logo_height + "px") : $("header:not(.centered_logo.centered_logo_animate) .q_logo a").css("height", header_height - e + $top_header_height - 10 + "px")) : e < $top_header_height ? ($("header.page_header").removeClass("scrolled"), $("header:not(.centered_logo.centered_logo_animate) nav.main_menu > ul > li > a").css("line-height", header_height + "px"), $("header:not(.centered_logo.centered_logo_animate) .side_menu_button").css("height", header_height + "px"), $("header:not(.centered_logo.centered_logo_animate) .shopping_cart_inner").css("height", header_height + "px"), $("header:not(.centered_logo.centered_logo_animate) .header_bottom .qode-login-register-widget.qode-user-logged-in .qode-logged-in-user").css("height", header_height + "px"), $("header:not(.centered_logo.centered_logo_animate) .logo_wrapper").css("height", header_height + "px"), header_height - logo_height > 0 ? $("header:not(.centered_logo.centered_logo_animate) .q_logo a").css("height", logo_height + "px") : $("header:not(.centered_logo.centered_logo_animate) .q_logo a").css("height", header_height - 10 + "px")) : header_height - e + $top_header_height < min_header_height_scroll && ($("header.page_header").addClass("scrolled"), $("header:not(.centered_logo.centered_logo_animate) nav.main_menu > ul > li > a").css("line-height", min_header_height_scroll + "px"), $("header:not(.centered_logo.centered_logo_animate) .side_menu_button").css("height", min_header_height_scroll + "px"), $("header:not(.centered_logo.centered_logo_animate) .shopping_cart_inner").css("height", min_header_height_scroll + "px"), $("header:not(.centered_logo.centered_logo_animate) .header_bottom .qode-login-register-widget.qode-user-logged-in .qode-logged-in-user").css("height", min_header_height_scroll + "px"), $("header:not(.centered_logo.centered_logo_animate) .logo_wrapper").css("height", min_header_height_scroll + "px"), min_header_height_scroll - logo_height > 0 ? $("header:not(.centered_logo.centered_logo_animate) .q_logo a").css("height", logo_height + "px") : $("header:not(.centered_logo.centered_logo_animate) .q_logo a").css("height", min_header_height_scroll - 10 + "px")), $("header.page_header").hasClass("centered_logo") && $("header.page_header").hasClass("centered_logo_animate") ? header_height - e + $top_header_height < logo_height && header_height - e + $top_header_height >= min_header_height_scroll && logo_height > min_header_height_scroll - 10 && e >= $top_header_height ? $(".q_logo a").height(header_height - e + $top_header_height - 10) : header_height - e + $top_header_height < logo_height && header_height - e + $top_header_height >= min_header_height_scroll && logo_height > min_header_height_scroll - 10 && e < $top_header_height ? $(".q_logo a").height(header_height - 10) : header_height - e + $top_header_height < logo_height && header_height - e + $top_header_height < min_header_height_scroll && logo_height > min_header_height_scroll - 10 ? $(".q_logo a").height(min_header_height_scroll - 10) : header_height - e + $top_header_height < logo_height && header_height - e + $top_header_height < min_header_height_scroll && logo_height < min_header_height_scroll - 10 ? $(".q_logo a").height(logo_height) : (e + $top_header_height === 0 && header_height, $(".q_logo a").height(logo_height)) : $("header.page_header").hasClass("centered_logo") ? ($(".q_logo a").height(logo_height), $(".q_logo img").height("auto")) : $(".q_logo img").height("100%"), setLeftPostionedMenuPadding()), $("header.page_header").hasClass("fixed_hiding") && (e < scroll_amount_for_fixed_hiding ? $("header.page_header").removeClass("scrolled") : $("header.page_header").addClass("scrolled"), $(".q_logo a").height(logo_height /​ 2), $(".q_logo img").height("100%")), $("header.page_header").hasClass("stick") || $("header.page_header").hasClass("stick_with_left_right_menu")) {17 if ($("header.page_header").hasClass("scroll_top") && $("header.page_header").hasClass("has_top") && ($("header.page_header").hasClass("fixed") || $("header.page_header").hasClass("fixed_hiding")) && (e >= 0 && e <= 34 ? ($("header.page_header").css("top", -e),18 $("header.page_header").css("margin-top", 0),19 $(".header_top").show()) : e > 34 && ($("header.page_header").css("top", "-34px"),20 $("header.page_header").css("margin-top", 34),21 $(".header_top").hide())),22 sticky_amount = getScrollAmountForStickyHeader(),23 $("header").hasClass("regular") && (header_height - logo_height >= 10 ? $(".q_logo a").height(logo_height) : $(".q_logo a").height(header_height - 10),24 $(".q_logo a img").css("height", "100%")),25 $("header.page_header").hasClass("fixed") && ($top_header_height = $("header.page_header").hasClass("scroll_top") ? 34 : 0,26 header_height - e + $top_header_height >= min_header_height_scroll && e >= $top_header_height ? ($("header.page_header").removeClass("scrolled"),27 $("header:not(.centered_logo.centered_logo_animate) nav.main_menu > ul > li > a").css("line-height", header_height - e + $top_header_height + "px"),28 $("header:not(.centered_logo.centered_logo_animate) .side_menu_button").css("height", header_height - e + $top_header_height + "px"),29 $("header:not(.centered_logo.centered_logo_animate) .shopping_cart_inner").css("height", header_height - e + $top_header_height + "px"),30 $("header:not(.centered_logo.centered_logo_animate) .header_bottom .qode-login-register-widget.qode-user-logged-in .qode-logged-in-user").css("height", header_height - e + $top_header_height + "px"),31 $("header:not(.centered_logo.centered_logo_animate) .logo_wrapper").css("height", header_height - e + $top_header_height + "px"), header_height - logo_height > 0 ? $("header:not(.centered_logo.centered_logo_animate) .q_logo a").css("height", logo_height + "px") : $("header:not(.centered_logo.centered_logo_animate) .q_logo a").css("height", header_height - e + $top_header_height - 10 + "px")) : e < $top_header_height ? ($("header.page_header").removeClass("scrolled"),32 $("header:not(.centered_logo.centered_logo_animate) nav.main_menu > ul > li > a").css("line-height", header_height + "px"),33 $("header:not(.centered_logo.centered_logo_animate) .side_menu_button").css("height", header_height + "px"),34 $("header:not(.centered_logo.centered_logo_animate) .shopping_cart_inner").css("height", header_height + "px"),35 $("header:not(.centered_logo.centered_logo_animate) .header_bottom .qode-login-register-widget.qode-user-logged-in .qode-logged-in-user").css("height", header_height + "px"),36 $("header:not(.centered_logo.centered_logo_animate) .logo_wrapper").css("height", header_height + "px"),37 header_height - logo_height > 0 ? $("header:not(.centered_logo.centered_logo_animate) .q_logo a").css("height", logo_height + "px") : $("header:not(.centered_logo.centered_logo_animate) .q_logo a").css("height", header_height - 10 + "px")) : header_height - e + $top_header_height < min_header_height_scroll && ($("header.page_header").addClass("scrolled"),38 $("header:not(.centered_logo.centered_logo_animate) nav.main_menu > ul > li > a").css("line-height", min_header_height_scroll + "px"),39 $("header:not(.centered_logo.centered_logo_animate) .side_menu_button").css("height", min_header_height_scroll + "px"),40 $("header:not(.centered_logo.centered_logo_animate) .shopping_cart_inner").css("height", min_header_height_scroll + "px"),41 $("header:not(.centered_logo.centered_logo_animate) .header_bottom .qode-login-register-widget.qode-user-logged-in .qode-logged-in-user").css("height", min_header_height_scroll + "px"),42 $("header:not(.centered_logo.centered_logo_animate) .logo_wrapper").css("height", min_header_height_scroll + "px"), min_header_height_scroll - logo_height > 0 ? $("header:not(.centered_logo.centered_logo_animate) .q_logo a").css("height", logo_height + "px") : $("header:not(.centered_logo.centered_logo_animate) .q_logo a").css("height", min_header_height_scroll - 10 + "px")),43 $("header.page_header").hasClass("centered_logo") && $("header.page_header").hasClass("centered_logo_animate") ? header_height - e + $top_header_height < logo_height && header_height - e + $top_header_height >= min_header_height_scroll && logo_height > min_header_height_scroll - 10 && e >= $top_header_height ? $(".q_logo a").height(header_height - e + $top_header_height - 10) : header_height - e + $top_header_height < logo_height && header_height - e + $top_header_height >= min_header_height_scroll && logo_height > min_header_height_scroll - 10 && e < $top_header_height ? $(".q_logo a").height(header_height - 10) : header_height - e + $top_header_height < logo_height && header_height - e + $top_header_height < min_header_height_scroll && logo_height > min_header_height_scroll - 10 ? $(".q_logo a").height(min_header_height_scroll - 10) : header_height - e + $top_header_height < logo_height && header_height - e + $top_header_height < min_header_height_scroll && logo_height < min_header_height_scroll - 10 ? $(".q_logo a").height(logo_height) : (e + $top_header_height === 0 && header_height,44 $(".q_logo a").height(logo_height)) : $("header.page_header").hasClass("centered_logo") ? ($(".q_logo a").height(logo_height),45 $(".q_logo img").height("auto")) : $(".q_logo img").height("100%"),46 setLeftPostionedMenuPadding()),47 $("header.page_header").hasClass("fixed_hiding") && (e < scroll_amount_for_fixed_hiding ? $("header.page_header").removeClass("scrolled") : $("header.page_header").addClass("scrolled"),48 $(".q_logo a").height(logo_height /​ 2),49 $(".q_logo img").height("100%")),50 $("header.page_header").hasClass("stick") || $("header.page_header").hasClass("stick_with_left_right_menu")) { 51 if (e > sticky_amount) {52 if (!$("header.page_header").hasClass("sticky")) {53 $top_header_height = $("header.page_header").hasClass("has_top") ? 34 : 0;54 var t = $("header.page_header").hasClass("centered_logo") ? $("header.page_header").height() : header_height + $top_header_height;55 $("header.page_header").hasClass("menu_bottom") && (t = header_height + 60), $("header.page_header").addClass("sticky"), $(".content").css("padding-top", t), window.clearTimeout(sticky_animate), sticky_animate = window.setTimeout(function() {56 $("header.page_header").addClass("sticky_animate")57 }, 100), min_header_height_sticky - logo_height >= 10 ? $(".q_logo a").height(logo_height) : $(".q_logo a").height(min_header_height_sticky - 10), $("header.page_header").hasClass("menu_bottom") && initDropDownMenu()58 }59 min_header_height_sticky - logo_height >= 10 ? $(".q_logo a").height(logo_height) : $(".q_logo a").height(min_header_height_sticky - 10)60 } else $("header.page_header").hasClass("sticky") && ($("header").removeClass("sticky_animate"), $("header").removeClass("sticky"), $(".content").css("padding-top", "0px"), $("header.page_header").hasClass("menu_bottom") && initDropDownMenu()), setMargingsForLeftAndRightMenu(), $("header.page_header").hasClass("centered_logo") ? ($(".q_logo a").height(logo_height), $(".q_logo img").height("auto")) : header_height - logo_height >= 10 ? $(".q_logo a").height(logo_height) : $(".q_logo a").height(header_height - 10), $(".q_logo a img").css("height", "100%");61 setLeftPostionedMenuPadding()62 }63 }64 65 function qodeMobileHeaderBehavior() {66 if ($("header").hasClass("sticky_mobile")) {67 var e = $(".page_header"),68 t = (e.find(".mobile_menu_button"), e.outerHeight()),69 o = $("#wpadminbar").length ? $("#wpadminbar").height() : 0,70 n = t,71 i = $scroll,72 a = function() {73 if (e.find(".header_inner").css("padding-top", 0), $window_width < 1e3) {74 var a = $scroll;75 a > n ? (e.addClass("qode-animate-mobile-header"), $(".content").css("padding-top", t)) : (e.removeClass("qode-animate-mobile-header"), $(".content").css("padding-top", 0)), a > i && a >= n || a <= n ? (e.removeClass("mobile-header-appear"), e.find(".header_inner").css("padding-top", 0)) : (e.addClass("mobile-header-appear"), e.find(".header_inner").css("padding-top", o)), i = $scroll76 }77 };78 qode_window.on("scroll resize", function() {79 a()80 })81 }82 }83 84 function setMargingsForLeftAndRightMenu() {85 "use strict";86 if ($("header.page_header").hasClass("stick_with_left_right_menu") && !$("header.page_header").hasClass("left_right_margin_set")) {87 var e = $(".q_logo a img").width() /​ 2;88 0 == $scroll && 0 != e && $("header.page_header").addClass("left_right_margin_set"), $(".logo_wrapper").width(2 * e), $("nav.main_menu.left_side > ul > li:last-child").css("margin-right", e), $("nav.main_menu.right_side > ul > li:first-child").css("margin-left", e), $(".rtl nav.main_menu.left_side > ul > li:first-child").css("margin-right", e), $(".rtl nav.main_menu.left_side > ul > li:last-child").css("margin-right", 0), $(".rtl nav.main_menu.right_side > ul > li:last-child").css("margin-left", e), $(".rtl nav.main_menu.right_side > ul > li:first-child").css("margin-left", 0)89 }90 }91 92 function setLeftPostionedMenuPadding() {93 "use strict";94 var e = $("header:not(.centered_logo) nav.main_menu");95 if (e.length && e.hasClass("left")) {96 var t = $(".q_logo a img").filter(function() {97 return "1" == $(this).css("opacity")98 });99 e.css("left", t.width())100 }101 }102 103 function logoSizeOnSmallScreens() {104 "use strict";105 80 < logo_height ? $(".q_logo a").height(80) : $(".q_logo a").height(logo_height), $(".q_logo a img").css("height", "100%"), $("header.page_header").removeClass("sticky_animate sticky"), $(".content").css("padding-top", "0px")106 }107 108 function contentMinHeight() {109 "use strict";110 if ($("header .header_bottom").length || $("header .bottom_header").length) {111 if ($("header .header_bottom").length) var e = $("header .header_bottom").css("background-color");112 if ($("header .bottom_header").length) var e = $("header .bottom_header").css("background-color");113 var t = e.substring(e.indexOf("(") + 1, e.lastIndexOf(")")).split(/​,\s*/​)[3],114 o = void 0 != t || $("header.page_header").hasClass("transparent") ? 0 : $("header.page_header").height();115 $("body .content").css("min-height", $window_height - o - $("footer:not(.uncover)").height())116 }117 }118 function contentMinHeightWithPaspartu() {119 "use strict";120 if ($(".paspartu_enabled").length) {121 var e, t = 0,122 o = $window_width * paspartu_width,123 n = $("footer").height();124 if ($(".disable_footer").length && (n = 0), $(".vertical_menu_enabled").length ? $(".paspartu_top").length && $(".paspartu_middle_inner").length && (t += o) : $(".paspartu_top").length && (t += o), !$(".paspartu_bottom").length && $(".disable_bottom_paspartu").length || (t += o), $(".vertical_menu_enabled").length) e = $window_height - t - n;125 else {126 if ($("header .header_bottom").length) var i = $("header .header_bottom").css("background-color");127 if ($("header .bottom_header").length) var i = $("header .bottom_header").css("background-color");128 if (void 0 !== i) var a = i.substring(i.indexOf("(") + 1, i.lastIndexOf(")")).split(/​,\s*/​)[3];129 var r = void 0 != a || $("header.page_header").hasClass("transparent") ? 0 : $("header.page_header").height();130 e = $window_height - r - t - n131 }132 $(".content").length && $(".content").css("min-height", e)133 }134 }135 function checkTitleToShowOrHide() {136 if ($(".title_outer.animate_title_area").length) {137 var e = $(".title_outer").data("height");138 $scroll > $(".title").height() && $(".title_outer").css({139 height: e,140 opacity: "1",141 overflow: "visible"142 })143 }144 }145 function contentMenuPosition() {146 "use strict";147 if ($("nav.content_menu").length) {148 if (content_menu_position > sticky_amount) var e = min_header_height_sticky;149 else var e = 0;150 content_menu_position - e - content_menu_top_add - $scroll <= 0 && ($("header").hasClass("stick") || $("header").hasClass("stick_with_left_right_menu")) ? (content_menu_position < sticky_amount ? $scroll > sticky_amount ? $("nav.content_menu").css({151 position: "fixed",152 top: min_header_height_sticky + content_menu_top_add153 }).addClass("fixed") : $("nav.content_menu").css({154 position: "fixed",155 top: 0,156 transition: "none"157 }).addClass("fixed") : $("nav.content_menu").css({158 position: "fixed",159 top: min_header_height_sticky + content_menu_top_add160 }).addClass("fixed"), $("header.sticky").addClass("no_shadow"), $(".content > .content_inner > .container > .container_inner").css("margin-top", content_line_height), $(".content > .content_inner > .full_width").css("margin-top", content_line_height)) : content_menu_position - content_menu_top - content_menu_top_add - $scroll <= 0 && !$("header").hasClass("stick") ? ($("nav.content_menu").css({161 position: "fixed",162 top: content_menu_top + content_menu_top_add163 }).addClass("fixed"), $(".content > .content_inner > .container > .container_inner").css("margin-top", content_line_height), $(".content > .content_inner > .full_width").css("margin-top", content_line_height)) : ($("nav.content_menu").css({164 position: "relative",165 top: "0px"166 }).removeClass("fixed"), $("header.sticky").removeClass("no_shadow"), $(".content > .content_inner > .container > .container_inner").css("margin-top", "0px"), $(".content > .content_inner > .full_width").css("margin-top", "0px")), $(".content .in_content_menu").waypoint(function(e) {167 var t = $(this),168 o = t.data("q_id");169 $("nav.content_menu.fixed li a").each(function() {170 $(this).attr("href") === o ? $(this).parent().addClass("active") : $(this).parent().removeClass("active")171 })172 }, {173 offset: "150"174 })175 }176 }177 function initMobileMenu() {178 "use strict";179 $(".mobile_menu_button > span").on("tap click", function(e) {180 e.preventDefault(), $(".mobile_menu > ul").is(":visible") ? $(".mobile_menu > ul").slideUp(200) : $(".mobile_menu > ul").slideDown(200)181 }), initInsideMobileMenu()182 }183 184 function initInsideMobileMenu() {185 "use strict";186 $(".mobile_menu > ul > li.has_sub > span.mobile_arrow, .mobile_menu > ul > li.has_sub > h3, .mobile_menu > ul > li.has_sub > a[href*='#']").on("tap click", function(e) {187 e.preventDefault(), $(this).closest("li.has_sub").find("> ul.sub_menu").is(":visible") ? ($(this).closest("li.has_sub").find("> ul.sub_menu").slideUp(200), $(this).closest("li.has_sub").removeClass("open_sub")) : ($(this).closest("li.has_sub").addClass("open_sub"), $(this).closest("li.has_sub").find("> ul.sub_menu").slideDown(200))188 }), $(".mobile_menu > ul > li.has_sub > ul.sub_menu > li.has_sub > span.mobile_arrow, .mobile_menu > ul > li.has_sub > ul.sub_menu > li.has_sub > h3, .mobile_menu > ul > li.has_sub > ul.sub_menu > li.has_sub > a[href*='#']").on("tap click", function(e) {189 e.preventDefault(), $(this).parent().find("ul.sub_menu").is(":visible") ? ($(this).parent().find("ul.sub_menu").slideUp(200), $(this).parent().removeClass("open_sub")) : ($(this).parent().addClass("open_sub"), $(this).parent().find("ul.sub_menu").slideDown(200))190 }), $(".mobile_menu ul li > a, .q_logo a").on("click", function() {191 "http:/​/​#" !== $(this).attr("href") && "#" !== $(this).attr("href") && $(".mobile_menu > ul").slideUp()192 })193 }194 /​/​var $ = jQuery.noConflict();195window.qode = {}, qode.modules = {};196var common = {};197qode.modules.common = common;198var $scroll = 0,199 qode_body = $("body"),200 qode_document = $("document"),201 qode_window = $(window),202 $window_width = $(window).width();203qode.windowWidth = $window_width;204var $window_height = $(window).height();205qode.windowHeight = $window_height;206var logo_height, menu_dropdown_height_set = !1,207 sticky_amount = 0,208 qode_grid_width = 1100,209 content_menu_position, content_menu_top, content_menu_top_add = 0,210 src, next_image, prev_image, $top_header_height, min_w = 1500,211 video_width_original = 1280,212 video_height_original = 720,213 vid_ratio = 1280 /​ 720,214 skrollr_slider, paspartu_width;215if (void 0 === paspartu_width_init) var paspartu_width_init = .02;216var min_header_height_fixed_hidden = 50;217var scroll_amount_for_sticky = 85;218var scroll_amount_for_fixed_hiding = 200;219var qodeGlobalVars = {"vars":{"page_scroll_amount_for_sticky":""}};220/​/​common.getLoadMoreData = getLoadMoreData, common.setLoadMoreAjaxData = setLoadMoreAjaxData, common.qodeOwlSlider = qodeOwlSlider, qode.animationEnd = animationEventEnd(), qode.transitionEnd = transitionEventEnd(), 221$(document).ready(function() {222 "use strict";223 if ($("header").hasClass("regular") && (content_menu_top = 0), $("header").hasClass("fixed_top_header") && (content_menu_top = header_height), $("header").hasClass("fixed") && (content_menu_top = min_header_height_scroll), $("header").hasClass("fixed_hiding") && (content_menu_top = min_header_height_fixed_hidden + 40), ($("header").hasClass("stick") || $("header").hasClass("stick_with_left_right_menu")) && (content_menu_top = 0), !$("header.page_header").hasClass("scroll_top") && $("header.page_header").hasClass("has_top") && $("header.page_header").hasClass("fixed") && (content_menu_top_add = 34), $("body").hasClass("vertical_menu_enabled")) {224 content_menu_top = 0, content_menu_top_add = 0225 }226 paspartu_width = $window_width < 1024 ? .02 : paspartu_width_init, contentMinHeight(), contentMinHeightWithPaspartu(),227 initMobileMenu()228 /​/​qodeGridWidth(), setDropDownMenuPosition(), initDropDownMenu(), initVerticalMenu(), initVerticalMobileMenu(), initQodeSlider(), initSideMenu(), initPopupMenu(), initMessageHeight(), initToCounter(), initCounter(), $(".vertical_split_slider").length || initCountdown(), initProgressBars(), initListAnimation(), initPieChart(), initPieChartWithIcon(), initServiceAnimation(), initParallaxTitle(), initSideAreaScroll(), initVerticalAreaMenuScroll(), loadMore(), prettyPhoto(), initFlexSlider(), fitVideo(), fitAudio(), initAccordion(), initAccordionContentLink(), qodeInitAccordions(), initMessages(), initProgressBarsIcon(), initMoreFacts(), placeholderReplace(), backButtonShowHide(), backToTop(), initSteps(), showGoogleMap(), initProgressBarsVertical(), initElementsAnimation(), updateShoppingCart(), initHashClick(), initIconWithTextAnimation(), initVideoBackground(), initCheckSafariBrowser(), initSearchButton(), initCoverBoxes(), createContentMenu(), contentMenuScrollTo(), createSelectContentMenu(), initButtonHover(), initEnlargeButton(), initSocialIconHover(), initPageTitleAnimation(), initIconShortcodeHover(), qodeIcon().init(), initIconWithTextHover(), parallaxLayers(), initHorizontalMarquee(), qodeHorizontalMarqueeLoop(), initTextMarquee(), initExpandingImages(), qodeLazyImages(), initItemShowcase(), qodeCTASection().init(), qodeInitInteractiveIconShowcase(), qodeInitSendContactForm(), qodeWorkflow(), qodeCustomFontTypeOut(), qodeMobileHeaderBehavior(), initElementsHolderResponsiveStyle(), 229 $(".widget #searchform").mousedown(function() {230 $(this).addClass("form_focus")231 }).focusout(function() {232 $(this).removeClass("form_focus")233 }), $scroll = $(window).scrollTop(), checkTitleToShowOrHide()234 /​/​, checkVerticalMenuTransparency(), 235 $(window).width() > 1e3 ? headerSize($scroll) : logoSizeOnSmallScreens()236 , $(window).width() > 768 && contentMenuPosition()237 /​/​, contentMenuCheckLastSection(), $("header:not(.stick_with_left_right_menu) .q_logo a").css("visibility", "visible"), initFullScreenTemplate(), showHideVerticalMenu(), initMasonryGallery(), initLoadNextPostOnBottom(), initBlogMasonryGallery(), initBlogGallery(), qodeV2Button().init(), qodeCardsSlider().init(), qodeCardsGallery(), qodeInitEllipticalSlider(), qodeInitPricingCalculator(), qodeSlidingImageHolder(), qodeOwlSlider(), qodeScrollingImage()238}), $(window).on("load", function() {239 "use strict";240 /​/​ qodeBrowserDetection(), $(".touchevents .main_menu li:has(div.second)").doubleTapToGo(), setLeftPostionedMenuPadding(), initSmallImageBlogHeight(), setDropDownMenuPosition(), initDropDownMenu(), initPortfolio(), initPortfolioZIndex(), initPortfolioSingleInfo(), initTestimonials(), initTestimonialsCarousel(), initVideoBackgroundSize(), initBlog(), initBlogMasonryFullWidth(), initQBlog(), initPortfolioJustifiedGallery(), initPortfolioMasonry(), initPortfolioMasonryFilter(), initTabs(), qodeInitAdvancedTabs(), qodeInitAdvancedTabsIcons(), countClientsPerRow(), animatedTextIconHeight(), countAnimatedTextIconPerRow(), initTitleAreaAnimation(), setContentBottomMargin(), footerWidth(), $("nav.content_menu").length > 0 && (content_menu_position = $("nav.content_menu").offset().top, contentMenuPosition()), contentMenuCheckLastSection(), initQodeCarousel(), initPortfolioSlider(), initBlogSlider(), qodeInitBlogCarouselTitled(), initPreviewSlider(), initInDeviceSlider(), initTabsActiveBorder(), setActiveTabBorder(), initImageHover(), $("header.stick_with_left_right_menu .q_logo a").css("visibility", "visible"), setMargingsForLeftAndRightMenu(), initImageGallerySliderNoSpace(), initVerticalSplitSlider(), initParallax(), initQodeElementAnimationSkrollr(), qodeBlogCompundMasonryGallery().init(), qodeInitStickyWidget(), qodeBlogHeadlines(), qodeCardsSlider().load(), initContentSlider(), qodePageTransitionEffect(), qodeContactPageAcceptance(), setTimeout(function() {241 /​/​ checkAnchorOnScroll(), qodeBlogGalleryAnimation(), checkAnchorOnLoad(), checkHeaderStyleOnScroll(), $(".no-touchevents .carousel").length && skrollr_slider.refresh()242 /​/​ }, 700), qodePanelArea(), initDropDownAfterWPMLReplaceMenu()243}), $(window).scroll(function() {244 "use strict";245 $scroll = $(window).scrollTop(), $(window).width() > 1e3 && headerSize($scroll)246 , $(window).width() > 768 && contentMenuPosition()247 /​/​, contentMenuCheckLastSection(), checkVerticalMenuTransparency(), qodeLazyImages(), $(".touchevents .drop_down > ul > li").mouseleave(), $(".touchevents .drop_down > ul > li").blur()248}), $(window).resize(function() {249 "use strict";250 $(window).width() > 1e3 ? headerSize($scroll) : logoSizeOnSmallScreens()251 /​/​$window_width = $(window).width(), $window_height = $(window).height(), paspartu_width = $window_width < 1024 ? .02 : paspartu_width_init, $(window).width() > 1e3 ? headerSize($scroll) : logoSizeOnSmallScreens(), initMessageHeight(), qodeNumberOfTestimonialsItemsResize(), fitAudio(), initSmallImageBlogHeight(), initBlog(), initBlogMasonryFullWidth(), initQBlog(), animatedTextIconHeight(), countAnimatedTextIconPerRow(), initVideoBackgroundSize(), countClientsPerRow(), setContentBottomMargin(), footerWidth(), calculateHeights(), $(".vertical_split_slider").height($window_height), initMasonryGallery(), initPortfolioMasonry(), contentMinHeight(), contentMinHeightWithPaspartu(), qodeInitStickyWidget()252});253 /​/​ end header254 /​* function bridgeQodeAjaxSubmitCommentForm() {255 "use strict";256 var options = {257 success: function() {258 $("#commentform textarea").val("");259 $("#commentform .success p").text("Comment has been sent!");260 }261 };262 $('#commentform').submit(function() {263 $(this).find('input[type="submit"]').next('.success').remove();264 $(this).find('input[type="submit"]').after('<div class="success"><p></​p></​div>');265 $(this).ajaxSubmit(options);266 return false;267 });268 }269 var header_height = 100;270 var min_header_height_scroll = 57;271 var min_header_height_fixed_hidden = 50;272 var min_header_height_sticky = 60;273 var scroll_amount_for_sticky = 85;274 var content_line_height = 60;275 var header_bottom_border_weight = 1;276 var scroll_amount_for_fixed_hiding = 200;277 var paspartu_width_init = 0.02;278 var add_for_admin_bar = jQuery('body').hasClass('admin-bar') ? 32 : 0;279 min_header_height_fixed_hidden = 50;280 paspartu_width_init = 0.02;281 var logo_height = 130;282 var logo_width = 280;283 logo_height = 138;284 logo_width = 478;285 header_top_height = 0;286 var loading_text;287 loading_text = 'Loading new posts...';288 var finished_text;289 finished_text = 'No more posts';290 var piechartcolor;291 piechartcolor = "#1abc9c";292 piechartcolor = "#000000";293 var geocoder;294 var map;295 296 function initialize() {297 "use strict";298 var mapStyles = [{299 stylers: [{300 hue: "#324156"301 }, {302 saturation: "-60"303 }, {304 lightness: "-20"305 }, {306 gamma: 1.51307 }]308 }];309 var qodeMapType = new google.maps.StyledMapType(mapStyles, {310 name: "Qode Map"311 });312 geocoder = new google.maps.Geocoder();313 var latlng = new google.maps.LatLng(-34.397, 150.644);314 var myOptions = {315 zoom: 12,316 scrollwheel: false,317 center: latlng,318 zoomControl: true,319 zoomControlOptions: {320 style: google.maps.ZoomControlStyle.SMALL,321 position: google.maps.ControlPosition.RIGHT_CENTER322 },323 scaleControl: false,324 scaleControlOptions: {325 position: google.maps.ControlPosition.LEFT_CENTER326 },327 streetViewControl: false,328 streetViewControlOptions: {329 position: google.maps.ControlPosition.LEFT_CENTER330 },331 panControl: false,332 panControlOptions: {333 position: google.maps.ControlPosition.LEFT_CENTER334 },335 mapTypeControl: false,336 mapTypeControlOptions: {337 mapTypeIds: [google.maps.MapTypeId.ROADMAP, 'qode_style'],338 style: google.maps.MapTypeControlStyle.HORIZONTAL_BAR,339 position: google.maps.ControlPosition.LEFT_CENTER340 },341 mapTypeId: 'qode_style'342 };343 map = new google.maps.Map(document.getElementById("map_canvas"), myOptions);344 map.mapTypes.set('qode_style', qodeMapType);345 }346 347 function codeAddress(data) {348 "use strict";349 if (data === '')350 return;351 var contentString = '<div id="content">' +352 '<div id="siteNotice">' +353 '</​div>' +354 '<div id="bodyContent">' +355 '<p>' + data + '</​p>' +356 '</​div>' +357 '</​div>';358 var infowindow = new google.maps.InfoWindow({359 content: contentString360 });361 geocoder.geocode({362 'address': data363 }, function(results, status) {364 if (status === google.maps.GeocoderStatus.OK) {365 map.setCenter(results[0].geometry.location);366 var marker = new google.maps.Marker({367 map: map,368 position: results[0].geometry.location,369 icon: 'https:/​/​bridge358.qodeinteractive.com/​wp-content/​themes/​bridge/​img/​pin.png',370 title: data['store_title']371 });372 google.maps.event.addListener(marker, 'click', function() {373 infowindow.open(map, marker);374 });375 }376 });377 }378 var $ = jQuery.noConflict();379 $(document).ready(function() {380 "use strict";381 showContactMap();382 });383 384 function showContactMap() {385 "use strict";386 if ($("#map_canvas").length > 0) {387 initialize();388 codeAddress("");389 codeAddress("");390 codeAddress("");391 codeAddress("");392 codeAddress("");393 }394 }395 var no_ajax_pages = [];396 var qode_root = 'https:/​/​bridge358.qodeinteractive.com/​';397 var theme_root = 'https:/​/​bridge358.qodeinteractive.com/​wp-content/​themes/​bridge/​';398 var header_style_admin = "";399 if (typeof no_ajax_obj !== 'undefined') {400 no_ajax_pages = no_ajax_obj.no_ajax_pages;...

Full Screen

Full Screen

base.py

Source:base.py Github

copy

Full Screen

...144 f" but expected {encode_hex(parent.hash)}"145 )146 vm = self.get_vm(child)147 try:148 vm.validate_header(child, parent)149 except ValidationError as exc:150 raise ValidationError(151 f"{child} is not a valid child of {parent}: {exc}"152 ) from exc153 if index in indices_to_check_seal:154 vm.validate_seal(child)155 def validate_chain_extension(self, headers: Tuple[BlockHeaderAPI, ...]) -> None:156 for index, header in enumerate(headers):157 vm = self.get_vm(header)158 # pass in any parents that are not already in the database159 parents = headers[:index]160 vm.validate_seal_extension(header, parents)161class Chain(BaseChain):162 logger = logging.getLogger("eth.chain.chain.Chain")163 gas_estimator: StaticMethod[Callable[[StateAPI, SignedTransactionAPI], int]] = None164 chaindb_class: Type[ChainDatabaseAPI] = ChainDB165 consensus_context_class: Type[ConsensusContextAPI] = ConsensusContext166 def __init__(self, base_db: AtomicDatabaseAPI) -> None:167 if not self.vm_configuration:168 raise ValueError(169 "The Chain class cannot be instantiated with an empty `vm_configuration`"170 )171 else:172 validate_vm_configuration(self.vm_configuration)173 self.chaindb = self.get_chaindb_class()(base_db)174 self.consensus_context = self.consensus_context_class(self.chaindb.db)175 self.headerdb = HeaderDB(base_db)176 if self.gas_estimator is None:177 self.gas_estimator = get_gas_estimator()178 #179 # Helpers180 #181 @classmethod182 def get_chaindb_class(cls) -> Type[ChainDatabaseAPI]:183 if cls.chaindb_class is None:184 raise AttributeError("`chaindb_class` not set")185 return cls.chaindb_class186 #187 # Chain API188 #189 @classmethod190 def from_genesis(cls,191 base_db: AtomicDatabaseAPI,192 genesis_params: Dict[str, HeaderParams],193 genesis_state: AccountState = None) -> 'BaseChain':194 genesis_vm_class = cls.get_vm_class_for_block_number(BlockNumber(0))195 pre_genesis_header = BlockHeader(difficulty=0, block_number=-1, gas_limit=0)196 chain_context = ChainContext(cls.chain_id)197 state = genesis_vm_class.build_state(base_db, pre_genesis_header, chain_context)198 if genesis_state is None:199 genesis_state = {}200 # mutation201 apply_state_dict(state, genesis_state)202 state.persist()203 if 'state_root' not in genesis_params:204 # If the genesis state_root was not specified, use the value205 # computed from the initialized state database.206 genesis_params = assoc(genesis_params, 'state_root', state.state_root)207 elif genesis_params['state_root'] != state.state_root:208 # If the genesis state_root was specified, validate that it matches209 # the computed state from the initialized state database.210 raise ValidationError(211 "The provided genesis state root does not match the computed "212 f"genesis state root. Got {state.state_root!r}. "213 f"Expected {genesis_params['state_root']!r}"214 )215 genesis_header = genesis_vm_class.create_genesis_header(**genesis_params)216 return cls.from_genesis_header(base_db, genesis_header)217 @classmethod218 def from_genesis_header(cls,219 base_db: AtomicDatabaseAPI,220 genesis_header: BlockHeaderAPI) -> 'BaseChain':221 chaindb = cls.get_chaindb_class()(base_db)222 chaindb.persist_header(genesis_header)223 return cls(base_db)224 #225 # VM API226 #227 def get_vm(self, at_header: BlockHeaderAPI = None) -> VirtualMachineAPI:228 header = self.ensure_header(at_header)229 vm_class = self.get_vm_class_for_block_number(header.block_number)230 chain_context = ChainContext(self.chain_id)231 return vm_class(232 header=header,233 chaindb=self.chaindb,234 chain_context=chain_context,235 consensus_context=self.consensus_context236 )237 #238 # Header API239 #240 def create_header_from_parent(self,241 parent_header: BlockHeaderAPI,242 **header_params: HeaderParams) -> BlockHeaderAPI:243 return self.get_vm_class_for_block_number(244 block_number=BlockNumber(parent_header.block_number + 1),245 ).create_header_from_parent(parent_header, **header_params)246 def get_block_header_by_hash(self, block_hash: Hash32) -> BlockHeaderAPI:247 validate_word(block_hash, title="Block Hash")248 return self.chaindb.get_block_header_by_hash(block_hash)249 def get_canonical_block_header_by_number(self, block_number: BlockNumber) -> BlockHeaderAPI:250 return self.chaindb.get_canonical_block_header_by_number(block_number)251 def get_canonical_head(self) -> BlockHeaderAPI:252 return self.chaindb.get_canonical_head()253 def get_score(self, block_hash: Hash32) -> int:254 return self.headerdb.get_score(block_hash)255 def ensure_header(self, header: BlockHeaderAPI = None) -> BlockHeaderAPI:256 """257 Return ``header`` if it is not ``None``, otherwise return the header258 of the canonical head.259 """260 if header is None:261 head = self.get_canonical_head()262 return self.create_header_from_parent(head)263 else:264 return header265 #266 # Block API267 #268 def get_ancestors(self, limit: int, header: BlockHeaderAPI) -> Tuple[BlockAPI, ...]:269 ancestor_count = min(header.block_number, limit)270 # We construct a temporary block object271 vm_class = self.get_vm_class_for_block_number(header.block_number)272 block_class = vm_class.get_block_class()273 block = block_class(header=header, uncles=[], transactions=[])274 ancestor_generator = iterate(compose(275 self.get_block_by_hash,276 operator.attrgetter('parent_hash'),277 operator.attrgetter('header'),278 ), block)279 # we peel off the first element from the iterator which will be the280 # temporary block object we constructed.281 next(ancestor_generator)282 return tuple(take(ancestor_count, ancestor_generator))283 def get_block(self) -> BlockAPI:284 return self.get_vm().get_block()285 def get_block_by_hash(self, block_hash: Hash32) -> BlockAPI:286 validate_word(block_hash, title="Block Hash")287 block_header = self.get_block_header_by_hash(block_hash)288 return self.get_block_by_header(block_header)289 def get_block_by_header(self, block_header: BlockHeaderAPI) -> BlockAPI:290 vm = self.get_vm(block_header)291 return vm.get_block()292 def get_canonical_block_by_number(self, block_number: BlockNumber) -> BlockAPI:293 validate_uint256(block_number, title="Block Number")294 return self.get_block_by_hash(self.chaindb.get_canonical_block_hash(block_number))295 def get_canonical_block_hash(self, block_number: BlockNumber) -> Hash32:296 return self.chaindb.get_canonical_block_hash(block_number)297 def build_block_with_transactions(298 self,299 transactions: Sequence[SignedTransactionAPI],300 parent_header: BlockHeaderAPI = None301 ) -> Tuple[BlockAPI, Tuple[ReceiptAPI, ...], Tuple[ComputationAPI, ...]]:302 base_header = self.ensure_header(parent_header)303 vm = self.get_vm(base_header)304 new_header, receipts, computations = vm.apply_all_transactions(transactions, base_header)305 new_block = vm.set_block_transactions(vm.get_block(), new_header, transactions, receipts)306 return new_block, receipts, computations307 #308 # Transaction API309 #310 def get_canonical_transaction_index(self, transaction_hash: Hash32) -> Tuple[BlockNumber, int]:311 return self.chaindb.get_transaction_index(transaction_hash)312 def get_canonical_transaction(self, transaction_hash: Hash32) -> SignedTransactionAPI:313 (block_num, index) = self.chaindb.get_transaction_index(transaction_hash)314 transaction = self.get_canonical_transaction_by_index(block_num, index)315 if transaction.hash == transaction_hash:316 return transaction317 else:318 raise TransactionNotFound(319 f"Found transaction {encode_hex(transaction.hash)} "320 f"instead of {encode_hex(transaction_hash)} in block {block_num} at {index}"321 )322 def get_canonical_transaction_by_index(self,323 block_number: BlockNumber,324 index: int) -> SignedTransactionAPI:325 VM_class = self.get_vm_class_for_block_number(block_number)326 return self.chaindb.get_transaction_by_index(327 block_number,328 index,329 VM_class.get_transaction_builder(),330 )331 def create_transaction(self, *args: Any, **kwargs: Any) -> SignedTransactionAPI:332 return self.get_vm().create_transaction(*args, **kwargs)333 def create_unsigned_transaction(self,334 *,335 nonce: int,336 gas_price: int,337 gas: int,338 to: Address,339 value: int,340 data: bytes) -> UnsignedTransactionAPI:341 return self.get_vm().create_unsigned_transaction(342 nonce=nonce,343 gas_price=gas_price,344 gas=gas,345 to=to,346 value=value,347 data=data,348 )349 def get_transaction_receipt(self, transaction_hash: Hash32) -> ReceiptAPI:350 transaction_block_number, transaction_index = self.chaindb.get_transaction_index(351 transaction_hash,352 )353 return self.get_transaction_receipt_by_index(transaction_block_number, transaction_index)354 def get_transaction_receipt_by_index(self,355 block_number: BlockNumber,356 index: int) -> ReceiptAPI:357 vm = self.get_vm_class_for_block_number(block_number)358 receipt = self.chaindb.get_receipt_by_index(359 block_number,360 index,361 vm.get_receipt_builder(),362 )363 return receipt364 #365 # Execution API366 #367 def get_transaction_result(368 self,369 transaction: SignedTransactionAPI,370 at_header: BlockHeaderAPI) -> bytes:371 with self.get_vm(at_header).in_costless_state() as state:372 computation = state.costless_execute_transaction(transaction)373 computation.raise_if_error()374 return computation.output375 def estimate_gas(376 self,377 transaction: SignedTransactionAPI,378 at_header: BlockHeaderAPI = None) -> int:379 if at_header is None:380 at_header = self.get_canonical_head()381 with self.get_vm(at_header).in_costless_state() as state:382 return self.gas_estimator(state, transaction)383 def import_block(self,384 block: BlockAPI,385 perform_validation: bool = True386 ) -> BlockImportResult:387 try:388 parent_header = self.get_block_header_by_hash(block.header.parent_hash)389 except HeaderNotFound:390 raise ValidationError(391 f"Attempt to import block #{block.number}. "392 f"Cannot import block {block.hash!r} before importing "393 f"its parent block at {block.header.parent_hash!r}"394 )395 base_header_for_import = self.create_header_from_parent(parent_header)396 # Make a copy of the empty header, adding in the expected amount of gas used. This397 # allows for richer logging in the VM.398 annotated_header = base_header_for_import.copy(gas_used=block.header.gas_used)399 block_result = self.get_vm(annotated_header).import_block(block)400 imported_block = block_result.block401 # Validate the imported block.402 if perform_validation:403 try:404 validate_imported_block_unchanged(imported_block, block)405 except ValidationError:406 self.logger.warning("Proposed %s doesn't follow EVM rules, rejecting...", block)407 raise408 persist_result = self.persist_block(imported_block, perform_validation)409 return BlockImportResult(*persist_result, block_result.meta_witness)410 def persist_block(411 self,412 block: BlockAPI,413 perform_validation: bool = True) -> BlockPersistResult:414 if perform_validation:415 self.validate_block(block)416 (417 new_canonical_hashes,418 old_canonical_hashes,419 ) = self.chaindb.persist_block(block)420 self.logger.debug(421 'Persisted block: number %s | hash %s',422 block.number,423 encode_hex(block.hash),424 )425 new_canonical_blocks = tuple(426 self.get_block_by_hash(header_hash)427 for header_hash428 in new_canonical_hashes429 )430 old_canonical_blocks = tuple(431 self.get_block_by_hash(header_hash)432 for header_hash433 in old_canonical_hashes434 )435 return BlockPersistResult(436 imported_block=block,437 new_canonical_blocks=new_canonical_blocks,438 old_canonical_blocks=old_canonical_blocks,439 )440 #441 # Validation API442 #443 def validate_receipt(self, receipt: ReceiptAPI, at_header: BlockHeaderAPI) -> None:444 VM_class = self.get_vm_class(at_header)445 VM_class.validate_receipt(receipt)446 def validate_block(self, block: BlockAPI) -> None:447 if block.is_genesis:448 raise ValidationError("Cannot validate genesis block this way")449 vm = self.get_vm(block.header)450 parent_header = self.get_block_header_by_hash(block.header.parent_hash)451 vm.validate_header(block.header, parent_header)452 vm.validate_seal(block.header)453 vm.validate_seal_extension(block.header, ())454 self.validate_uncles(block)455 def validate_seal(self, header: BlockHeaderAPI) -> None:456 vm = self.get_vm(header)457 vm.validate_seal(header)458 def validate_uncles(self, block: BlockAPI) -> None:459 has_uncles = len(block.uncles) > 0460 should_have_uncles = block.header.uncles_hash != EMPTY_UNCLE_HASH461 if not has_uncles and not should_have_uncles:462 # optimization to avoid loading ancestors from DB, since the block has no uncles463 return464 elif has_uncles and not should_have_uncles:465 raise ValidationError("Block has uncles but header suggests uncles should be empty")466 elif should_have_uncles and not has_uncles:467 raise ValidationError("Header suggests block should have uncles but block has none")468 # Check for duplicates469 uncle_groups = groupby(operator.attrgetter('hash'), block.uncles)470 duplicate_uncles = tuple(sorted(471 hash for hash, twins in uncle_groups.items() if len(twins) > 1472 ))473 if duplicate_uncles:474 raise ValidationError(475 "Block contains duplicate uncles:\n"476 f" - {' - '.join(duplicate_uncles)}"477 )478 recent_ancestors = tuple(479 ancestor480 for ancestor481 in self.get_ancestors(MAX_UNCLE_DEPTH + 1, header=block.header)482 )483 recent_ancestor_hashes = {ancestor.hash for ancestor in recent_ancestors}484 recent_uncle_hashes = _extract_uncle_hashes(recent_ancestors)485 for uncle in block.uncles:486 if uncle.hash == block.hash:487 raise ValidationError("Uncle has same hash as block")488 # ensure the uncle has not already been included.489 if uncle.hash in recent_uncle_hashes:490 raise ValidationError(491 f"Duplicate uncle: {encode_hex(uncle.hash)}"492 )493 # ensure that the uncle is not one of the canonical chain blocks.494 if uncle.hash in recent_ancestor_hashes:495 raise ValidationError(496 f"Uncle {encode_hex(uncle.hash)} cannot be an ancestor "497 f"of {encode_hex(block.hash)}"498 )499 # ensure that the uncle was built off of one of the canonical chain500 # blocks.501 if uncle.parent_hash not in recent_ancestor_hashes or (502 uncle.parent_hash == block.header.parent_hash):503 raise ValidationError(504 f"Uncle's parent {encode_hex(uncle.parent_hash)} "505 f"is not an ancestor of {encode_hex(block.hash)}"506 )507 # Now perform VM level validation of the uncle508 self.validate_seal(uncle)509 try:510 uncle_parent = self.get_block_header_by_hash(uncle.parent_hash)511 except HeaderNotFound:512 raise ValidationError(513 f"Uncle ancestor not found: {uncle.parent_hash!r}"514 )515 uncle_vm_class = self.get_vm_class_for_block_number(uncle.block_number)516 uncle_vm_class.validate_uncle(block, uncle, uncle_parent)517@to_set518def _extract_uncle_hashes(blocks: Iterable[BlockAPI]) -> Iterable[Hash32]:519 for block in blocks:520 for uncle in block.uncles:521 yield uncle.hash522class MiningChain(Chain, MiningChainAPI):523 header: BlockHeaderAPI = None524 def __init__(self, base_db: AtomicDatabaseAPI, header: BlockHeaderAPI = None) -> None:525 super().__init__(base_db)526 self.header = self.ensure_header(header)527 def apply_transaction(self,528 transaction: SignedTransactionAPI529 ) -> Tuple[BlockAPI, ReceiptAPI, ComputationAPI]:530 vm = self.get_vm(self.header)531 base_block = vm.get_block()532 receipt, computation = vm.apply_transaction(base_block.header, transaction)533 header_with_receipt = vm.add_receipt_to_header(base_block.header, receipt)534 # since we are building the block locally, we have to persist all the incremental state535 vm.state.persist()536 new_header: BlockHeaderAPI = header_with_receipt.copy(state_root=vm.state.state_root)537 transactions = base_block.transactions + (transaction, )538 receipts = base_block.get_receipts(self.chaindb) + (receipt, )539 new_block = vm.set_block_transactions(base_block, new_header, transactions, receipts)540 self.header = new_block.header541 return new_block, receipt, computation542 def import_block(self,543 block: BlockAPI,544 perform_validation: bool = True545 ) -> BlockImportResult:546 result = super().import_block(547 block, perform_validation)548 self.header = self.ensure_header()549 return result550 def set_header_timestamp(self, timestamp: int) -> None:551 self.header = self.header.copy(timestamp=timestamp)552 @staticmethod553 def _custom_header(base_header: BlockHeaderAPI, **kwargs: Any) -> BlockHeaderAPI:554 header_fields = {'coinbase'}555 header_params = {k: v for k, v in kwargs.items() if k in header_fields}556 return base_header.copy(**header_params)557 def mine_all(558 self,559 transactions: Sequence[SignedTransactionAPI],560 *args: Any,561 parent_header: BlockHeaderAPI = None,562 **kwargs: Any,563 ) -> Tuple[BlockImportResult, Tuple[ReceiptAPI, ...], Tuple[ComputationAPI, ...]]:564 if parent_header is None:565 base_header = self.header566 else:567 base_header = self.create_header_from_parent(parent_header)568 custom_header = self._custom_header(base_header, **kwargs)569 vm = self.get_vm(custom_header)570 new_header, receipts, computations = vm.apply_all_transactions(transactions, base_header)571 filled_block = vm.set_block_transactions(vm.get_block(), new_header, transactions, receipts)572 block_result = vm.mine_block(filled_block, *args, **kwargs)573 imported_block = block_result.block574 block_persist_result = self.persist_block(imported_block)575 block_import_result = BlockImportResult(*block_persist_result, block_result.meta_witness)576 self.header = self.create_header_from_parent(imported_block.header)577 return (block_import_result, receipts, computations)578 def mine_block(self, *args: Any, **kwargs: Any) -> BlockAPI:579 """580 Mine whatever transactions have been incrementally applied so far.581 """582 return self.mine_block_extended(*args, **kwargs).block583 def mine_block_extended(self, *args: Any, **kwargs: Any) -> BlockAndMetaWitness:584 custom_header = self._custom_header(self.header, **kwargs)585 vm = self.get_vm(custom_header)586 current_block = vm.get_block()587 mine_result = vm.mine_block(current_block, *args, **kwargs)588 mined_block = mine_result.block589 self.validate_block(mined_block)590 self.chaindb.persist_block(mined_block)591 self.header = self.create_header_from_parent(mined_block.header)592 return mine_result593 def get_vm(self, at_header: BlockHeaderAPI = None) -> VirtualMachineAPI:594 if at_header is None:595 at_header = self.header...

Full Screen

Full Screen

cqcLogMessageHandler.py

Source:cqcLogMessageHandler.py Github

copy

Full Screen

...69 def parse_data(cls, header, cmd, xtra, comment, node_name):70 subdata = {}71 subdata["node_name"] = node_name72 subdata["comment"] = comment73 subdata["cqc_header"] = cls.parse_header(header)74 subdata["cmd_header"] = cls.parse_cmd(cmd)75 if xtra:76 subdata["xtra_header"] = cls.parse_xtra(xtra)77 cls.logData.append(subdata)78 with open(cls.file, "w") as outfile:79 json.dump(cls.logData, outfile)80 @classmethod81 def parse_handle_data(cls, header, data, comment, node_name):82 cmd_l = CQC_CMD_HDR_LENGTH83 xtra_l = CQC_CMD_XTRA_LENGTH84 subdata = {}85 subdata["node_name"] = node_name86 subdata["comment"] = comment87 subdata["cqc_header"] = cls.parse_header(header)88 if len(data) >= cmd_l:89 subdata["cmd_header"] = cls.parse_cmd(CQCCmdHeader(data[:cmd_l]))90 if len(data) >= cmd_l + xtra_l:91 subdata["xtra_header"] = cls.parse_xtra(CQCXtraHeader(data[cmd_l: cmd_l + xtra_l]))92 cls.logData.append(subdata)93 with open(cls.file, "w") as outfile:94 json.dump(cls.logData, outfile)95 @classmethod96 def parse_handle_factory(cls, header, data, comment, node_name):97 subdata = {}98 subdata["node_name"] = node_name99 subdata["comment"] = comment100 subdata["cqc_header"] = cls.parse_header(header)101 fact_hdr = CQCFactoryHeader(data[: CQCFactoryHeader.HDR_LENGTH])102 subdata["factory_iterations"] = fact_hdr.num_iter103 subdata["notify"] = fact_hdr.notify104 cls.logData.append(subdata)105 with open(cls.file, "w") as outfile:106 json.dump(cls.logData, outfile)107 @classmethod108 def parse_header(cls, header):109 header_data = {}110 header_data["type"] = header.tp111 header_data["app_id"] = header.app_id112 header_data["header_length"] = header.length113 header_data["is_set"] = header.is_set114 return header_data115 @classmethod116 def parse_cmd(cls, cmd):117 cmd_data = {}118 cmd_data["notify"] = cmd.notify119 cmd_data["block"] = cmd.block120 cmd_data["action"] = cmd.action121 cmd_data["is_set"] = cmd.is_set122 cmd_data["qubit_id"] = cmd.qubit_id...

Full Screen

Full Screen

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.

LambdaTest Learning Hubs:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run Sure automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

... View sample repo... View DocumentationSign up Free
›
_

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

...
Sign up with GoogleSign up with Email
Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful