# -*- coding: utf-8 -*- import requests import base64 from __future__ import annotations import base64, binascii, hashlib, json, lzma, os, random, re, socket, struct, tempfile, threading, time from urllib.parse import quote, urlencode, urlparse, parse_qs from http.server import BaseHTTPRequestHandler, ThreadingHTTPServer import requests import sys sys.path.append('..') from base.spider import Spider from collections.abc import Mapping from typing import Any _CACHE = {} _PF_SET = set() def _cache(key, ttl, load): now = time.time() hit = _CACHE.get(key) if hit and now - hit[0] < ttl: return hit[1] value = load() _CACHE[key] = (now, value) return value HOST = 'https://api5-normal-sinfonlineb.fqnovel.com' UA = 'com.kylin.read/73532 (Linux; U; Android 16; zh_CN; PLK110; Build/; Cronet/TTNetVersion)' MEDIA_UA = UA EP = 'mc-episode-v1:' PROXY_TYPE = 'mc_cenc' APP_VERSION_CODE = '73532' APP_VERSION_NAME = '7.3.5.32' APP_UA = UA EPISODE_PREFIX = EP VIDEO_URL = HOST + '/novel/player/multi_video_model/v1/' try: from cryptography.hazmat.primitives import hashes from cryptography.hazmat.primitives.ciphers import Cipher, algorithms, modes except ImportError: hashes = None Cipher = algorithms = modes = None try: from Crypto.Cipher import AES as CryptoAES except ImportError: CryptoAES = None # 敏感词古风替换：只保留短剧标题/简介中高频出现的；冷门词不会命中，删了不影响安全 CLASSICAL_MAP = { '成人':'风月','色情':'风月','情色':'春宫','淫':'风月','黄色':'春宫', '偷拍':'窥帘','强奸':'强占','萝莉':'豆蔻','幼女':'玉蕊','少女':'碧玉', '暴力':'杀伐','恐怖':'幽冥', '国产':'华夏','日韩':'东瀛','欧美':'西洋','港台':'香江', } # 未成年人相关词：标题或简介命中即整片屏蔽 MINOR_WORDS = ('豆蔻','玉蕊','碧玉','稚子','未成年','萝莉','幼女','少女','童') SORTED_CLASSICAL_KEYS = sorted(CLASSICAL_MAP, key=len, reverse=True) def _clean(text): value = str(text or '') for key in SORTED_CLASSICAL_KEYS: value = value.replace(key, CLASSICAL_MAP[key]) lower = value.lower() return '' if any(word.lower() in lower for word in MINOR_WORDS) else value def _minor(text): lower = str(text or '').lower() return any(word.lower() in lower for word in MINOR_WORDS) def _vod(x): x = x or {} sid = str(x.get('series_id') or '') raw_name = str(x.get('series_title') or x.get('title') or '') raw_intro = str(x.get('series_intro') or x.get('video_desc') or '') if not sid or not raw_name or _minor(raw_name + raw_intro): return None name, intro = _clean(raw_name), _clean(raw_intro) if not name: return None pic = str(x.get('series_cover') or x.get('cover') or '') cnt = x.get('episode_cnt') or 0 return {'vod_id': sid, 'vod_name': name, 'vod_pic': pic, 'vod_remarks': ('全%s集' % cnt) if cnt else '', 'vod_content': intro} def _items(rows): out=[]; seen=set() def walk(x): if isinstance(x, dict): if x.get('series_id') and (x.get('series_title') or x.get('title')): v=_vod(x); key=str(x.get('series_id')) if v and key not in seen: seen.add(key); out.append(v) for y in x.values(): walk(y) elif isinstance(x, list): for y in x: walk(y) walk(rows); return out class Spider(Spider): def __init__(self): self._cfg = {} self.relay = NativeRelay() def init(self, extend=''): config = {} if isinstance(extend, dict): config = extend elif isinstance(extend, str) and extend.strip(): try: value = json.loads(extend) if isinstance(value, dict): config = value except ValueError: pass self._cfg = config self.relay = NativeRelay(config) try: self._ensure_stream() except Exception: pass return None def _ensure_stream(self): return _stream_ensure(getattr(self, '_cfg', {}) or {}) def getName(self): return '红果原生漫剧' def isVideoFormat(self, url): return False def manualVideoCheck(self): return False def destroy(self): return None def homeContent(self, filter): def load(): panel = self.relay.panel().get('data') or {} dims = [] for row in panel.get('selector_rows') or []: dims.append((str(row.get('type') or ''), row.get('items') or [])) # 只保留 genre 作为一级分类；theme/role/epoch 降为筛选条件 prefix_map = {'genre': 'g_'} classes = [] for typ, items in dims: prefix = prefix_map.get(typ) if not prefix: continue for item in items: name = _clean(item.get('show_name')) value = str(item.get('selector_item_id') or '') if name and value: classes.append({'type_id': prefix + value, 'type_name': name}) filters = [] for typ, items in dims: # genre 已作为一级分类；sort/gender 等不作为筛选行 if typ in ('genre', 'sort', 'gender', 'creation_status', 'online_time'): continue key = typ values = [{'n': '全部', 'v': ''}] for item in items: name = _clean(item.get('show_name')) value = str(item.get('selector_item_id') or '') if name and value: values.append({'n': name, 'v': value}) row_name = _clean(next((r.get('row_name') for r in panel.get('selector_rows') or [] if str(r.get('type') or '') == key), '')) if key and row_name and len(values) > 1: filters.append({'key': key, 'name': row_name.replace('全部', ''), 'value': values}) return classes, filters classes, filters = _cache('hg_panel', 3600, load) classes = classes or [{'type_id': 'g_comic_series', 'type_name': '漫剧'}] fmap = {c['type_id']: filters for c in classes} return {'class': classes, 'filters': fmap, 'filterable': 1 if filters else 0} def homeVideoContent(self): return {'list': []} def categoryContent(self, tid, pg, filter, extend): try: page = max(1, int(pg)) except (TypeError, ValueError): page = 1 selected = {} if tid: tid = str(tid) # 一级分类只有 g_ 前缀（genre）；theme/role/epoch 走筛选 if tid.startswith('g_'): selected['genre'] = [tid[2:]] if not selected: selected['genre'] = ['comic_series'] if isinstance(extend, dict): for name in ('category_dim_art_style', 'category_dim_theme', 'category_dim_role', 'category_dim_epoch', 'sort', 'gender', 'creation_status', 'online_time'): value = extend.get(name) if value in (None, '', 'all'): continue selected[name] = [str(x) for x in (value if isinstance(value, (list, tuple)) else [value]) if str(x).strip()] rows, has_more = self.relay.feed(page, selected) if has_more: nxt = page + 1 cache_key = ('hg_feed', json.dumps(selected, ensure_ascii=False, sort_keys=True), nxt) if not _CACHE.get(cache_key) and cache_key not in _PF_SET: _PF_SET.add(cache_key) def _prefetch(): try: self.relay.feed(nxt, selected) finally: _PF_SET.discard(cache_key) threading.Thread(target=_prefetch, daemon=True).start() return {'page': page, 'pagecount': page + (1 if has_more else 0), 'limit': len(rows), 'total': len(rows), 'list': _items(rows)} def searchContent(self, key, quick=False, pg='1'): word = str(key or '').strip() try: page = max(1, int(pg)) except (TypeError, ValueError): page = 1 if not word: return {'page': page, 'pagecount': 1, 'limit': 0, 'total': 0, 'list': []} try: rows = self.relay.search_web(word, page) except Exception: rows = [] items = _items(rows) return {'page': page, 'pagecount': page, 'limit': len(items), 'total': len(items), 'list': items} def detailContent(self, ids): sid = str(ids[0] if isinstance(ids, (list, tuple)) else ids) d = self.relay.detail(sid) payload = d.get('data') if isinstance(d.get('data'), dict) else d vd = payload.get('video_data') or payload.get('video_detail') or payload if not isinstance(vd, dict): return {'list': []} raw_name = str(vd.get('series_title') or '') raw_intro = str(vd.get('series_intro') or '') if _minor(raw_name + raw_intro): return {'list': []} name, intro = _clean(raw_name), _clean(raw_intro) if not name: return {'list': []} eps = [] for i, item in enumerate(vd.get('video_list') or [], 1): vid = str(item.get('vid') or '') if vid: eps.append('第%d集$%s%s' % (i, EP, vid)) return {'list': [{'vod_id': sid, 'vod_name': name, 'vod_pic': str(vd.get('series_cover') or ''), 'vod_year': '', 'vod_area': '', 'vod_director': '', 'vod_actor': '', 'vod_content': intro, 'vod_remarks': _clean(str(vd.get('episode_right_text') or '')), 'vod_play_from': '红果漫剧', 'vod_play_url': '#'.join(eps)}]} def playerContent(self, flag, id, vipFlags=None): vid = str(id).replace(EP, '') try: base = self._ensure_stream() if base: return {'parse': 0, 'jx': 0, 'playUrl': '', 'url': base + '/play?' + urlencode({'vid': vid}), 'header': {'User-Agent': UA, 'Referer': 'https://novel.snssdk.com/'}} except Exception: pass return {'parse': 0, 'jx': 0, 'playUrl': '', 'url': self._proxy_base() + 'type=' + PROXY_TYPE + '&vid=' + quote(vid, safe=''), 'header': {'User-Agent': UA, 'Referer': 'https://novel.snssdk.com/'}} def localProxy(self, param): q = json.loads(param) if isinstance(param, str) else (param or {}) if not isinstance(q, dict): q = {} typ = q.get('type') or '' if isinstance(typ, (list, tuple)): typ = typ[0] if typ else '' if str(typ) not in ('', PROXY_TYPE): return [404, 'text/plain', b'not found'] vid = q.get('vid') or q.get('id') or '' if isinstance(vid, (list, tuple)): vid = vid[0] if vid else '' if not str(vid).strip(): return [400, 'text/plain', b'missing vid'] return self.relay.proxy(str(vid).strip()) def _proxy_base(self): try: base = str(self.getProxyUrl() or '').strip() if base: return base.rstrip('&?') + ('&' if '?' in base else '?') except Exception: pass return '' # 原生媒体解密实现 def _aes(key: bytes, iv: bytes, data: bytes, mode: str) -> bytes: if Cipher is not None and algorithms is not None: m = modes.CTR(iv) if mode == "ctr" else modes.CBC(iv) d = Cipher(algorithms.AES(key), m).decryptor() return d.update(data) + d.finalize() if CryptoAES is not None: if mode == "ctr": return CryptoAES.new(key, CryptoAES.MODE_CTR, nonce=b"", initial_value=iv).decrypt(data) return CryptoAES.new(key, CryptoAES.MODE_CBC, iv).decrypt(data) raise HongguoPluginError("缺少 AES 依赖(cryptography/pycryptodome)") class HongguoPluginError(RuntimeError): pass def _text(value: Any) -> str: return str(value or "").strip() def _first(*values: Any) -> str: for value in values: if isinstance(value, (list, tuple)): result = _first(*value) elif isinstance(value, Mapping): result = _first( value.get("url"), value.get("uri"), value.get("src"), value.get("download_url"), value.get("main_url"), value.get("backup_url"), value.get("backup_url_1"), value.get("play_addr"), value.get("url_list"), ) else: result = _text(value) if result: return result return "" def _json_response(response: requests.Response) -> Any: response.raise_for_status() try: return response.json() except ValueError as exc: raise HongguoPluginError("上游响应不是 JSON") from exc def _media_url(item: Mapping[str, Any]) -> str: return _first( item.get("main_url"), item.get("backup_url"), item.get("backup_url_1"), item.get("play_addr"), item.get("url"), ) def _spade_value(item: Mapping[str, Any]) -> str: encrypt_info = item.get("encrypt_info") if not isinstance(encrypt_info, Mapping): encrypt_info = {} return _first(item.get("spade_a"), encrypt_info.get("spade_a")) def derive_content_key(spade_b64: str) -> bytes: raw = _b64(spade_b64) if len(raw) < 3: raise HongguoPluginError("spade_a 太短") v8 = len(raw) - (raw[0] ^ raw[1] ^ raw[2]) + 47 if v8 <= 0 or 1 + v8 > len(raw): v8 = len(raw) - 1 if v8 < 33: raise HongguoPluginError("spade_a 长度异常") value = bytearray(raw[1 : 1 + v8]) va, vb = 85, 246 for index in range(v8): previous = va if index & 1 else vb if index & 1: va = value[index] else: vb = value[index] value[index] = (-21 - index.bit_count() + (previous ^ value[index])) & 0xFF try: return binascii.unhexlify(bytes(value[1:33]).decode("ascii")) except (ValueError, binascii.Error) as exc: raise HongguoPluginError("spade_a 密钥材料无效") from exc def _find_box(data: memoryview, fourcc: bytes, start: int) -> tuple[int, int]: for index in range(max(4, start), len(data) - 4): if data[index : index + 4] != fourcc: continue size = struct.unpack(">I", data[index - 4 : index])[0] if size == 1 and index + 12 <= len(data): size = struct.unpack(">Q", data[index + 4 : index + 12])[0] if 8 <= size <= 5_000_000 and index - 4 + size <= len(data): return index - 4, size return -1, 0 def _box_body(data: memoryview, fourcc: bytes, start: int) -> memoryview | None: offset, size = _find_box(data, fourcc, start) return data[offset + 8 : offset + size] if offset >= 0 else None def _parse_track( moov: memoryview, track_offset: int, ) -> tuple[list[int], list[int], list[int], list[int], int, int] | None: if track_offset < 0: return None stbl_offset, _ = _find_box(moov, b"stbl", track_offset + 8) if stbl_offset < 0: return None stsz = _box_body(moov, b"stsz", stbl_offset) stco = _box_body(moov, b"stco", stbl_offset) co64 = _box_body(moov, b"co64", stbl_offset) stsc = _box_body(moov, b"stsc", stbl_offset) saiz = _box_body(moov, b"saiz", stbl_offset) saio = _box_body(moov, b"saio", stbl_offset) if any(value is None for value in (stsz, stsc, saiz, saio)) or ( stco is None and co64 is None ): return None assert stsz is not None and stsc is not None assert saiz is not None and saio is not None default_size = struct.unpack(">I", stsz[4:8])[0] sample_count = struct.unpack(">I", stsz[8:12])[0] sizes = ( [default_size] * sample_count if default_size else [ struct.unpack(">I", stsz[12 + index * 4 : 16 + index * 4])[0] for index in range(sample_count) ] ) chunk_table = stco if stco is not None else co64 assert chunk_table is not None chunk_count = struct.unpack(">I", chunk_table[4:8])[0] chunk_width = 4 if stco is not None else 8 offsets = [ int.from_bytes( chunk_table[ 8 + index * chunk_width : 8 + (index + 1) * chunk_width ], "big", ) for index in range(chunk_count) ] entry_count = struct.unpack(">I", stsc[4:8])[0] entries = [ ( struct.unpack(">I", stsc[8 + index * 12 : 12 + index * 12])[0], struct.unpack(">I", stsc[12 + index * 12 : 16 + index * 12])[0], ) for index in range(entry_count) ] chunk_samples = [0] * chunk_count for index, (first_chunk, samples_per_chunk) in enumerate(entries): end = entries[index + 1][0] - 1 if index + 1 < len(entries) else chunk_count for chunk in range(first_chunk - 1, min(end, chunk_count)): chunk_samples[chunk] = samples_per_chunk saiz_flags = int.from_bytes(saiz[1:4], "big") saiz_cursor = 12 if saiz_flags & 1 else 4 if len(saiz) < saiz_cursor + 5: return None default_aux_size = saiz[saiz_cursor] aux_count = struct.unpack(">I", saiz[saiz_cursor + 1 : saiz_cursor + 5])[0] aux_sizes = ( [default_aux_size] * aux_count if default_aux_size else [ int(saiz[saiz_cursor + 5 + index]) for index in range(aux_count) if saiz_cursor + 5 + index < len(saiz) ] ) if len(aux_sizes) != aux_count: return None saio_flags = int.from_bytes(saio[1:4], "big") saio_cursor = 12 if saio_flags & 1 else 4 offset_width = 8 if saio[0] == 1 else 4 if len(saio) < saio_cursor + 4 + offset_width: return None entry_count = int.from_bytes(saio[saio_cursor : saio_cursor + 4], "big") if entry_count < 1: return None aux_offset = int.from_bytes( saio[saio_cursor + 4 : saio_cursor + 4 + offset_width], "big", ) return sizes, offsets, chunk_samples, aux_sizes, aux_offset, sample_count def _replace_fourcc(data: bytearray, old: bytes, new: bytes) -> None: position = 0 while True: position = data.find(old, position) if position < 0: return data[position : position + len(old)] = new position += len(new) def _replace_sinf(data: bytearray) -> None: position = 0 while True: position = data.find(b"sinf", position) if position < 0: return if position >= 4: size = struct.unpack(">I", data[position - 4 : position])[0] end = position - 4 + size if 8 <= size < 50_000 and end <= len(data): data[position : position + 4] = b"free" data[position + 4 : end] = b"\x00" * max(0, end - position - 4) position = end continue position += 4 def decrypt_mp4_cenc(data: bytes, content_key: bytes) -> bytes: if len(content_key) != 16: raise HongguoPluginError("CENC 密钥长度错误") result = bytearray(data) if len(result) < 16: raise HongguoPluginError("MP4 数据过短") moov_start, moov_size = _find_box(memoryview(result), b"moov", 0) if moov_start < 0 or moov_size < 8: raise HongguoPluginError("MP4 moov 越界") moov = memoryview(result)[moov_start : moov_start + moov_size] tracks: list[int] = [] track_search = 0 while True: track, track_size = _find_box(moov, b"trak", track_search) if track < 0: break tracks.append(track) track_search = track + max(track_size, 8) decrypted_samples = 0 for track in tracks: parsed = _parse_track(moov, track) if parsed is None: continue sizes, offsets, chunk_counts, aux_sizes, aux_offset, sample_count = parsed aux_size = sum(max(size, 8) for size in aux_sizes) if not sample_count or aux_offset < 0 or aux_offset + aux_size > len(result): continue aux = result[aux_offset : aux_offset + aux_size] sample_index = 0 aux_index = 0 for chunk_index, chunk_offset in enumerate(offsets): current = chunk_offset for _ in range(chunk_counts[chunk_index]): if sample_index >= sample_count or sample_index >= len(sizes): break size = sizes[sample_index] if current + size > len(result): raise HongguoPluginError("MP4 样本越界") if sample_index >= len(aux_sizes): raise HongguoPluginError("MP4 辅助信息数量不足") entry_size = max(aux_sizes[sample_index], 8) iv = bytes(aux[aux_index : aux_index + min(entry_size, 8)]).ljust( 8, b"\0" ) + b"\0" * 8 result[current : current + size] = _aes( content_key, iv, bytes(result[current : current + size]), "ctr" ) current += size sample_index += 1 aux_index += entry_size decrypted_samples += 1 if not decrypted_samples: raise HongguoPluginError("MP4 没有可解密的 CENC 样本") _replace_fourcc(result, b"encv", b"hvc1") _replace_fourcc(result, b"enca", b"mp4a") _replace_sinf(result) return bytes(result) def _b64(value: str) -> bytes: text = _text(value) text += "=" * (-len(text) % 4) try: return base64.b64decode(text) except (ValueError, binascii.Error): return base64.urlsafe_b64decode(text) def _branch_one_bytes() -> bytes: if not hasattr(_branch_one_bytes, "value"): _branch_one_bytes.value = lzma.decompress(base64.b85decode(_BRANCH_ONE_B85)) return _branch_one_bytes.value _BRANCH_ONE_B85 = ( '{Wp48S^xk9=GL@E0stWa761SMbT8$j;R-wN{#^houf7QIIVU7uEXt3ca?@+^++8<`vdWaS1a!^(@3piHN^UDea^utz&m68PwK)la*43U*mNYT~Az3vWRR9M@u9%`>|`oTuVAm{6Xbi7iUoW)6rJ_BOyLIpL' 'xODyDEOHDUy)Hr^$hEEodD$hbGrZQIEu8`Tb_H;~Z>VMWKW5~p-hONtZJoi*u&tO=m69!Z>V7E`+W`F%rB6Z`>9J*SJ%Azqgna;j' 'pyLxZi;ycJaM~j_>t{HhAIxC^4(?8&VcUx=ux(qrgcIAXU5Yosc?z1$(' 'FqfP|)2$ve(&}uw;(uxdO>E6dMMn^`79eTmC_B=qkOB^y=1A8sQij#h5;4}+#ILn~##Qh5V8-%l`Cgcy0u7DR!N$07Q0#BWZ9icP-W3P^XQYY)|Xa<5v$^`p|naVLW^*4x>oTf$}?2%{6bD};l{wp' 'UXx&>{O(!V18p93xBW_5+H#yeu03vRjESLXD$A9{yVQwj)I(NohO>ORrTjPEA{?DAU0dxSX!K7471{McHXwNi-H;o*fS{' 'A^u%?y|GH!Rj#yLuLt`!ot{jYLYX|a)tAG>|ahQ' '(CvT4r8nG+e1c=US5#<;4qieQKmF}v#Lir5E|do?DhNZDSa32d|8J@+jja&PG#}{s>QAtW@PV$U?q=(1XE9c#V$_wg+bp&V&B)eE' 'w|E7%&@=fW46%KQT|hx-6(^7@;GSAuQiVAKWj{$=NiFaV|-^t;>U+e*p}pUxsGg' 'R<;C@A<@#B?1bIdg$yI+yA6AxY23cPa12A79#Fv)!=h0N+GRs0Kg078`}Jx76kkmF2?7`fU$Lt8m3@5>LUp7)McaOF3%leJQMA(V' 'z#j;PC$N!2YwiDp$FdZE3B6)aNBYUa(TNaoy8X~=byBHab^*nv9%*}Rf54ca_b0AXoR_G3a@6Q#ZFpU^6?~3S9&n|oyDT=y+-aSh' 'n_@mxq0;KkI{N4=aOj0w-G;T1{5|jUk~rpYu}~n&xeXONR{x@w=wxoIjOh3^cwp6#*_zNzKwGmt%gS9r?F8cMjKT$lB|br+51yB2' '=wZV7fy7D{`(29#`6Q#QIa%hm)is>KD_ry#_H*-F*|Z?%Qv8Wrj@X=do{p=*x3Fz@7wS7@0b~~-n@Ufde^yLqtQCm?0O`Da6nn-j' 'r9Pog2fjAFwYIJkyQ%q6436nF9t#Lsz;}b$hp5{_)$_DwZec8D&xJpU4!-(s}b112NIK72XtvrrGX22}y~3_iro{&MnhETA+DaK?Xi(' 'Q0J_&dFeJ5#7fK#kt7e^e@c1D7iOsd7Y$~wsRTJ#qi|^(h#yWd2}FIU8B9IG^z&-907)*(j!(qXjiLbP^#}@|w33k4F~`7m' 'K~fLbR%d?z%hl(M*M#B6)+ez&D3$JDYg5AF2vDMPEE2G;dt-P!gtE!qaJ41%TjxghS@IBUwUEIbBB|AJ4?hq}BLavJ+^|F^sE80o' 'uLA?B96n!Yic+9jWQ6baLx|+P0BjCKJP6CmKDt5GssWs1oekHG4ifxLAKG`*ebaE=-5kobMB}Pz;R0REqN-x}q3%W$B*jB?E{A%B' '2MhzK1%uoumz1tpa`{9cjKqgYo(@1|z(N)PeGvIibln>rkSAlt;@TjZ46mVE-PxOR1;;0DloppysYZle6G|A!P|?bB1T7wCbzf01t(nEUGrFWjeMlraZ}~O%Xn~3S`Ij?3XhZJj44r^n=^V1+N&4lbxGo' '0!x)@u1Oh2G558Kzoz_xRv^@R+Sg`Cz7G*HrruF#dZW2&@Gr5H7wXs&LAz?4wE7`UwBTRkeMY-w&~x' 'xYPt=bzf(89ffpeR@daZBH>+i&9AQXz8Ag>QY~)CA!cmHgHPV`CM4&WXiAA=p%;HSE^I8hyHb@HbJlKm9(B<&rvxIdWJ!Ra`W' 'hBT1d#{e#>cz9y9sU9Z>FD5Whu?djyd$z^Ls@m~rs_#3A*V$?hFlmO6p0uz~8wP--L+&#T9-XiXKJ4AQ%8r0jK1b6h*9Wi$-*5_l' 'O#gg!K%y%um(KnRmO)=2JlcF+X}hP7Gn{v@AW+9!+?D4&s3dzwJ?<}0CzFsHw)I`q@f#x}7%g)SCviR=d%M!Rmu0E64)p8)od~J;' '`uAVx3hx(ZmT&ZB5FN_#N-S9Eo!g%GuzQb%boa1Ar5RHkT*|?FDT530rxbxdzA|UYb0wSBm%7Qn@nee@gz=>xU=<{_-qSfw5uiL;' 'Mw2t@X*I@v5gyeO;Azw^vnq!jZLCTY%Y{$jEnTUhmlE>vWa&xR^daeIgtPS9t@UxM+5D(jQtQ_K#m>{iU' 'O?L(Lsk3<&K&Ums!V4(!0{&6z@!u^0I%2ikvMuCv?M%o^RU4iL9Ul=Tq`Qq@Y|gl{oFV~Pg{3!t#0?>Pb^@f|3o+DkcL3`=U&&99' 'n1ipU;k(6$Nz26d3+X9kD2Xa;);f=qm`iT8!@&Qu*cJ5i_@Hd;W4ON2#^@~rt|oiREpd1zc0fLvL#d((Kta6BI3vAn-V@xZV6?gw' 'BF+>*#3Zvm$iZ0&*L4xFf>P65Fs@w&+C#wM^s41lRJlT>3OUK+H|^M(l{gmrAm#*VIo*I{)6)`Nzr6!nmw#7l;a=;Tn6ly2vS7=!' '4~fE_r9)9&$7RnSmaUHleEM)gsGR)UePI2Z;ewO0?U{4Hj^NSpP?ZKTS1ny~#up6i*JvMIBxfjm6!LI8GWXS)_4~GP0Tc`k@RHlb' '?H*yz0Ro+%R`J|{HtsE%xxbx|k*{5o_xZfD-4bteruCah1ep@1vlv6^uCy1}`{fpW42@`+Mu;V?l$yPujd?<|dg(yXnEsC)#1?($' 'zKI!)WJ{_o-+z`%>g@GCWa}v981h|wyGx=%oNo$4GCZGs6t-$my{R~~VT)-|t0xOmFH*mG*~zgs#tB&P;ZmopQC~^2%k>{0dIwfZ|8hkc56tni&2PBSpf)>hw3C=z-?+kQb#d26(o17askq>W4Pr};0!JE#@sxOF9my2)h<;cb' 'qT6pG$%k6+f=FhWam9}cQRXZN5wlU$%U1vcZ{jIriu^h(0M*xQrm~b4xv+A)2*h{|*OUZHRs|f|)GEKa&*g~)W2TtT@sp!Yi~Jp6' 'wj$ze7Qh-nn-d7f*4;;Fh?D`p1icS86F*iA9ztj-WD$>79%gsB#1FbG{_>5LsYa?X69@8s3xd{bEr`6YU0#ux0)++' '_%@p1W~Su8mIu&SDyjn!G5Qr|8K|Nb9}JFJojQ+6p^;w+uT6lnyKtZS=3elR)`hl>nFV_s<6^h;+(3*4)YFb;uPh2sE(;xkw=o({' 'rYtN4S@zdyB7&z_aWQZ;0%0E*48M`@aATEdR@V13+j;5YhV?niH+U<3IVS)kl|v>n;TU6E(jG84m^*Zt2HF%yZ60921r25wAoevU' 'fmk@6FhGsIlMK1CsV8Jm4?>-}sW4nU_xov}%a{Q;0GBl>+%-!r4`9mrOw6!D_zy3Kwa6^~rCkp^A1C1|-Jv*l9M=p(toY6>j|X}F' '&J*W-E$Lo`K*NdO**eB~TiY`XMSO' 'jw!2tgE@FcbNS9HRi#}gs*>CRWVgjZ+WHLslM%L{zLlX8k>UAErfG>z6II2{1c-NL1G~)I^m>#6?6%=NdcxVnD#ni3uWui)jx9C4=W~kLY|Oe*bewS|N8*!A|#x($!+mR' '&gaDU{A&eA&TJ~XwQ`Fl%NrdX4IS10ui2`WfEQ~bHe>|0ky9r;QeKb->WHB`kP(B+bZ-ZV!rzOtPOZt8Tzpn97eQ+wLh9Tl!))xz{-b2}kkE)X' 'EJG1G3IPJPD;I6su@*;N(}z!o7+h>cAl{jEcZ2lfCJ3Ne0NKDBGgit}LYoOSmsl1ef0PEllmj*@Js#r6w08Lh9+bSeom$_*!' '5|r6Y4Dx}JPapC_RA{VAT|+ZpKEEoA@4)`4S6pmCKGSZTTrRNRB@V7-ucDbG4nM^oJlA)h97s`h>~c&iC{2ig!d1#Ms|2EpI4VS+bD+GS(^tdl5+xK6nJ(&b5xU~owi2wxtJwuQfZM9MOwx0S&Y' '0M|tBN1P+_SY#BSCCwPqU4kW7U(8c0F&W4nF1xcA91f)B#zz{gL3*#w7izhnq>*o-vc{mLA5QT^YFI*ri12A+GoT(*4sD|;Di3L;' 'ddvAmG-l-X;ZAVo5xfgM2m#Lip2TfW%kJ?d*tAJDuo;B0EcW}mr$d+~fQI<{!iGQe0|xatE}eU4w=svBpHR9nV9L4ct5-EG*Q2vOh7|QvY@fsu-mx4=)2$W&H%Bv*6Pkqo!X)sGUjZ*w?($clu1BKNR!cvm&l_A4!QaMjH<)|8' 'n~62K-9(7nUGvuX);0QFvfsj__uhI8O;kdfTFkgOHe@qOnFRSEJtXUJpu+LXnR*N4v`Q83l2{m1pvspU*&UREpagCvg(lKkm+jlKin}pFVycXE6L%w(vH&1}baI9hBwpzi>IO4667L%@%{_50Sj9%@XzeAAOqip=#fq?ykn4q)2(|F|?HnUV5;G%>lG*m}Au;xPFQ4(+j;)-1SD^9BtFjE^O?z}w' 'uU|!m6Hy#z2M>UblgTLeaF%`8f16wkT>fnKbEb?e@em~s>XttyK' ')TceKHQ-~Tnz{k+grpi-x2T;K=yM_^%S`iDEe!1{lj%g!G~tdPIc}F1V7n8}8Nk*~w27SR70RK(##!BZ^@G6-XQEb9t|3(uBG74aC&5gMh<}|_L8@RrOvt1qn^KyK5@*eAErDMMa|H4mlpeX~;P@EIw^#%8$Fs3W*5yK!O*hzqcb-^@pHmxbYO?i7' '&%4x!c>e_}-F%GGS6Z3v%bqA9' '4&dC6(7GuQAaO7{=>r%0nX@Q*tc%Q^bME5x!^o=9e2DXGmRdV?tK*Ze`U*vd^Cc)i6G=%2lu6SA329j44pM323>Q}aW6O}TIN}PJ' '(Y^EKmiAHwt}ZeXj;B$)P;W3qGjf*z6K>R6{s4ufaa%$47e&d32a{7%7`^=aljldOIo_7_`9PMfV' '<86~9RK11O2Dr2@VfeqJ)icEr(oVh{jrh*o6W7ZNCf8jo-ka?*2>c9zWz4|pJ^$coH__5~}=' 'Mj)2(s#paw69f{;*cw2J!qurM{7Qwa!$noN5)PTcp)EoZhP@)Myju?zy}cv6x0d0J+gd~7-ByisLI|O>X~HCtJRO%=b97P3M=iYoR9501E+f|zhkdjB-ml5ulYLJmy$;X})JU$+3' 'zyNT=s|&ZPb^&RRoPE7Wytzt^5i^-iyOFQO{2n1MjAr68i#lYjQNZ>4=eooL+zpM&E4Jkv6N6AKqDj9hEF2H3f)Ehqph' 'I$`&19~xp|KthQK>8t|DOAF0Fq&AUnTMuf6Q`n`VsVE(_4L~E!cl}FQDg=W+@HIkucI9Q2%PY>X`q)7P!lf>fPm4&yX5&a%bZKEy' 'm}FRrxHg!l1$y9ySs$ukj&~twB;p_?hAabQ`}9Mgt9Y23OF3A&X_>oGiGXT>tUe>LAG~6d7{>2=VA?$j2svmjI9LncaGVXPfjK{J9fDKJ}7Z+(7%Sy;Z?g;K' '7rYq|cO>Ma^A(!fsLpc`Ov($85(=_aJTcHz>vfvj)8LIb_vkeqBjdiddaQl$Cgs@;xAk@-%pjZ7;VnIFoD7wecc47PjS4z81ELs8~#u1ku8y@4?1EzR}~D^1Xc-^Z2{`=hMlANbzs{o6#@S2T!_-b^~V`zxQ4kKB^mHF*;r*' '6Y@H<d&y(Wf(Y&q8zyyKBlvy}_Y&I{%!f#$Dgrs}F>QGh*hn2}#WNst6!Q?wz%p0W6njR>>cz6a+No<0vS!G=N!4Y^o+q-*U' 'yD$@p!i|$I@`{X;v1fX|k5z*J{TaL8RKb)T!vpi_gd$?mOSdG)%3qc4ix46SfP;eZM#Ii((=+We!%sKq3UCXmEEi`{eY;(`rmdqV' '9;(y1{6niqWj$+zPeg4?MY__EReO|KGj2}I%NObBmiEKx{CB!o=SIv4ZU2KJOMhs^ZQqbs7obl9^|8){XqaNp+(039&^000Sa^h&' '24%u1SGd{X;_&jh|1^|z3t%L-=xP*V!u%w_`$IegUxv>39@ku+aJiCq1DyW6ayl{SLUVR268{cZ7$oh(Yh~pAabC9C3`>B^8i3jw' 'cgyaT1*d%;V&x2?QGZSpJyN+@7O?W_)zWXN34Eoez%c<|^4mu<_KPoCRvjokm69iJ4ACJ``8J)wK6{|9dL=2{C6~&fSHc!~4x&mH' '_m^imaD|EzFcow!V^y|CI~T6}1`sCH{ZqL`LG|rvl7UeLtOOY@id@bc${0dnFCBGw(}}p5kA*qB*?g^Av553SNeW~CO`9#pr~P~q' '%2(z1>q&+-X%*JJebW#_MD4N8WZk!u)-rsr(5H2#)1>;iC;@*8I^B<*_|q=T2tOtpm+K=Fe3%P2`ymsz;GR59Gb&>srW' 'k#lwi!x3Q1M?^Q_enuOH=X*9c}(leKhA-qQ;462_!#*' 'Pe?r;M_4Nwfd6-`X_Fb!6PT-;zt-+O=^Jz`-JR1V@B4I>eR+ho00s6eD;9FgSLqH1wV%@F^$gs>b_zxfvulv|;zIweZ5Vbbca$B6' 's@#B6JERzQvsUQ5FOrX6>Ta#RVTbm@km0(utG&Ke1hcv4&zdr8=7AX+Cb8!iUv`?$Cq*}DTOxb>yY`v7Cd1^lBF*GQTHc8cuX*^|dmbpr#7tt6J$t`2' 'h)c&z03gs}>eWqo9~BsDzYw8VZ6t&9oB-kd;m}c>Izd7vAu#xnYZTO{a)*YzAsX^Qw(@XZj})i?G07nV$&I;u' '%-}gIAIQPL7P;M2&tpL#^K}aqG%oNFJ061=`7vO4x-ZAbJcX|RkE@67);I>}p(7-Ot61m>5`pjRH#8yI+EnmtUM@g1|3oI-8o7kQ' 'XFxJ3X{~ep;*5O>;?GCGNf3Ik+hbD|lDo}<_L0>GCo1cOkABa4L!<eU' 'DiRZy@DdfK8_H;A2RBmyBu5ZmFRm|Kh^9CX2Dc?c6B)~b(4p0LX-x-@DseT}jD`^fcOOR9jVk-wZE`NTC?z!~Skzxz2-410{ur4^P17CZsM5cApJR_U{*36Rh0h1qlg3`kuxmj1&4b_-W|F?OQDMg~ISMnec^>kZuYed)n)eYCT;B;t?v6o&>CS{dIJm' 'h+srIc=rKUx*PB&ReQB1P*m=|g>X^-8n@c_m4^3iHpF~BR2j1EI74nv+CT=J`mNSK0i?*esv~zHAWK1x+Z%Yz5%)Oas!b@;O^G+P' 'Scz$&p&^ff`xXeMo?%gXzQkm3#=HuMGK?FzmL!C?%B#M|2k{G&_vC)4OZVM28#w-UaR0hi;XXd01qr7u-w6jPmXxv^G6699cdq_xA7mS@3B-o8AmW1LfQ1--jU}%nDEQnRap1LS{?U~c4DpUHhY0S6' 'A25$sj&A}-vlo!^Aj7uuHfJo4AF9&@aQcBJGxwBs1gSWVx_uERU~L*5S%AWc0x{~y*^HAe`tvS8B{lhL!;4_w)`h|Gd}2C3lNnXv' 'D%j)-sc+g0Yqn=4?L9(NP}4E9ad&rw1)lI%AV*+j7sEtnt4A5pN*{C(Jf&<7xN1};$2>_POQ;>Il&(22NkLQ`Bou-_`OI(4!JWTL' 'RXZircVC}Jyq>2M4z=*F(Jj?T{Zv>@X{h!2aAqI`O+zniuZIe{-amNawhrOslk5blTTIXyeg)+>r|=?Qr<-t!EHSMqlhJI4%Nkm3hZ_Y-<|;Im_2<>Q?cf3YCTp}' 'xD9UFPR6GR*P6ZhzS25DiP4&TSD7Ce$--6qbV_n?RF?+>$8I2x5+}Wy!@D3%z@X%J!!nS-qms$q)YOrjaNG@3F2JeI' 'B11G89c#!QRdEil3SS2Dcnx1iDNx4pwR7xdP$NK)7b!FPocY>_k@q|ua8R;6)J3Qk0h+YL_iRENH_!Lu9RP3h3_ksx^LPNmXlY!{' '7y`-skrRe=0^nqUEM%ZKm{T+YFg+{ama`H$UfOu|Wo}{~Q`BSA6bB`&x3baJSvimiBd(B5ZRC?ntIf;FDi^~|FS~vN;b7}SAjEQE' 'NTqu30xy1@Wo%8r|4vgb{Yrd0;iN5E6jIh5Rqv4W^h#gT-7@MKFZ93v`_3A;JN=uCYZaY$MbH~=2QSWKOa(W-8el4Rrqrw}0UqvW' 'P{g0e+C5|+DNKFUJcasKKjYAptG%7uRTSR<4>lHQWJAhTvl%mRf9J|F2jA1VCT' 'gN{3cA?R97Pqm#W3xbIEg_2nC;2x1T=Vnp5tTwP{Ju9N9BufCnfhrWLxnbVa>Nbg9{u4TMXk;+SDrjnN^zdI7K@#L(GW}r' '1$=l=ni>jyarNmc<82Z4`)X3yy%w^5i0Y*JfayxJ_Qa-04?vh6Fk8s&`+ej56KkW=49@=^@F07CsUMw7*jhgv%4+P~bl*CSz{!U>' '0tv0M2!hDjcBkR`HCnm|M4_Zd35d!3Jl}iy}c@|KWWRIr=Ay^i6q}#uB|s`G+6{D7!;GO>PnRIcm8C2lJ%' 'g-Qxx`=^w8HU%ynm-43nYiihePYn9HOx^R;5HPrpPdt^;t*iC0Of7gK}Chl1FPoEOA`_^' 'm17c>k;23UIcHHbN9-H*(*c5_<;4{9T#v6(WzF3$t;' 'EYj9-3GTeJBGZiFNKfZ5l*&M>sm0VdpN' 'ME!|1EI0i7DC!}j!F=O0{r#|e;TmN9x9#V+$?D?@8kBrC7+}JyX^5r$l(6F_olq+fQsDS`-zif_4dt3f)C5IDd)a9lO|(VGa#SQD6ufB>rh;QXVk#)HCD>Bs=K#9oL`T(odYss>huj7K4c1I' 'y*S~@u!&`zXR-(oQ+u7y{IB+?57IlVH^Qpk*l7x1?*jwq2@A{)T~eLshb|zTAx>`{)%2h~vcMAj&+PCLt~!4zq7UDMO3ZwxhfGB@' 'uWYsiL7L8yuzEOYXQt?ICri|!tliMAM+#h@$cAQ#foiQnkY?e-cVsf$aJ>5{r4R(9-Fko?JK&q6ghJ{5f+M(2fQefYLGM^' 'T~Umh53Lk870J46*~Ox!KPnxp`iD#S33?+Kd|fdDS8d4&TD4gepnv>~(u@UL>;eZG!iMVaUqBy@YFr+BNOa3HhMq)E' '-18&ss>uppRbGFzP^Mpiu=4+^?@;m+KYjDRFo{za}^k{aQ>YyGPAK9M43FD((nusW0IT*+ly}1$@8pI+c%49aac^b+PHy0vf4s;zYuri`)+HO7=O($SHgGK3dRS!R_' '%tVlLnUq<~?=(hz;QUB1uYz-PLxKWg2M7b(%hVJ7$NV8KhCqc;KFuEdcZcHS^%5v6TF~?Mu6IMhHgd9(KjXk=NecW=DOiM3LX6^#%xSC?oJM;`w-lm-8DNY)2jd*QOv;_C3oxj2VQYx$4u9HyCMt*02' '>TbVw^KT>+txMSW?gE38;peu{7aJ_#Q%Yp$rngee1j#KQm|po#ODOzV7`HwTx>NJ;z5hg_zSvdevUyE20npPlTB&@&hk^WNw;Qe5' '9?rlvL%>R=UeauPL_M2r!3r`F6|@5&=Gu>tPE$PPeJ=-ClQm6vYTeRpRm)aX`JLg+H#}d@`Dq(U|J-fo5Lme&^`s)t=@V`o_maG&Zq|AJW@T;h~R>*pEQJ&!{#3HRzo#v' 'Q85b|&tv;Rj`J#XLXktDIwu`Fvu(>LYz|eSD(*r9X>q{0Qmny<`$-B&K!owrcmk&`P`DTd()hw;9KPkXSn}lU@+72T*+c9X!p!D=' '$K*OP!Tq}sEX&>);@WJW3uLVyn^jj0GUq(q>++wMq7wGo1gSc5Nk6TpVG<9)^HcKJ@j)q`BCx3XqFFHGj>TThkZd0*!EYiPI?K+n' '^rE;EHs}@#vcp7^SOvg(YD93MwOC3jSB;(x*NRlv{hZ{5&_bsiBgNkFK8i=E-gf+Z(K$POGN5XS;%%&fAZA4J}r6bGEb6JF8OBL<11D=ql-*c0LTwkH(ZLaU%+KkthH!!Lp`96' '#in#0g;9i?%;TtAR9#r0I{8rj)(5EMizbJN)7~u~uMZ^-L2i?IVB3E|jp1F;)aS#nvGCrysvlwdad9&#wZoPW;99cjSie{SuwaOJ_XgZw`6ze^wDH(y^9itJ)CtrOIjX9L{yN2H2kV%ip^uyh22' 'vu;BwHd$IZ-rBx^yj=t{?jXCwe-??jLwBgB*b%db9Y@}*SBj7EkRQDLR@!#mD-6sY@7^iVIW;@dl8?vS3FM@%O??6{27M%m@@L{q' 'bJ|-yyxxY5>y{ETUoKIG34YGX_w7}E=tAk&XI<`T(DJ=vEX8SbX@r<6q4+Dw+%H)v9w+lj-{MzzKZ4fu|J%>^wo;3@KKBlmYN=!n' 'R^G$2EPlIA2wlQU!5)NYp&hm;-pM}VJ$pj^nzg5fYnWxSxD*%zgZ~iHfX*{}-7U&o46emBoDj$b@*7`qi9q%WV3*+6qalokfCVdX' '#+;==oWs6^e)Nv2atQuTi#@>N%pL%GJLQc' '`JevS0ax!p1P9{~B|h?cLL`=GZ@)OUaL<(V^|Xfnx_>uUv<%F0#rBCV`93{2r-o&h>3i8GUjqH;I+>(+U3_5R{^}+60Na*X`#OfQ' '?=|&|Q}~MxI3z@Y228_}eSbC>I{fnsfzaK@qnZHBa|xD-3Ms26qF' ')qD=~o2rYW7^%FwH(Aw`GMUFqMAIQ78>4ITjp=^q?Y7-DZ!vd2UHeW4twMP2!x7EP{`i*Gb=VtdncHYhU(S%x4vA)gWO9cJ>ev_@q^s$@HuelOqzx^%2oc|<7ftbi&#?l#L`H3*1' 'AmSV3(ov@c+bG@TE8J$gKTUdKMIyL7A!Z{&w;xBRH9YsAdm7<{z_--GVD+Hh7+GvUj!UY3A!<%b' 'pW?3UV(64!EP%Yls1FjvudIFch8XVZgLtr0%q~rTvP4kPv)fdAz(dq3OHLuYPmip({U$-D4y|(d{UbKzbc(jT+2Q&jO%3(}l`u|f' 'f_-c-`b&Fnnwxo~`jTetvI)s6Onu|bxIp?N>o~S^5`aL3%Mf`YAf%KTD9;V1{EO0)x!;D-Q1kT>!s1W)P=n@Nz?`iU@pYozO' 'VpN_br9K_$!Pp?$9&_+l_B;n@rJ(S-%-obrSw{1Fwz_!ujwm(4Rpi9rDwUlz{~cy0-v`_X0il0rImnuoBj0lCNeTFXt%s^&#i|HB' '!@6v7N+G|~#1riQr0u!@_W%#i7J1IjkRb03f5w%O*!G%0yD9lR$>Y+7;Y7Us~8p;i#>=rQMMb;z_+*MT8HU{V_A)Qi~18YC1+>}OW6c3x+>6+7_YpazZ-K$NxsJjxeLZ~`&$zxE{!' 'A^Ie=5~$RtO6G;P6l5Yc3%Unf7~3%0%yUxJ2xEL_^JX!pN|<0|C!gh{HMijCoCr-$W@kc' 'B+TtbV5PST0NmdLIS' '2JmUE?0V{l1k{**-iJG2gsj~g@+y2+0PvLpYAlHD);P94gSDuV(hIYC8IxhGI)%1Qe{mjP)4mHGC7U)F$nxy>)39taxgoD&DXz$q' 'Pb;76%2-ufniA5KYZX2rR&U|X_aRC&SR#fF-+k}c(rH0e;5W0}cPIref*yb}$9yP81_jHWq4A7&tOg@A4}66o>2B?BcyD44JgQNY' '+#<@RF=sHtBm!&&8y0b}Qj4LNY?k*`-?Pp$8g39{S$-{i{mp~h6A0lRYq1HkvZ-gaDA;M^GVuHGuu<($c*&}I3hok&01*7;tq6mp' 'EOVB#Crf*BK^DQj^AV7bQHHLYNN+vc_f)w!d' 'CioL*WE~eU+5%7LAH0a2;*sz|Y1DshF{sqDneAZI9CX?=nEwXQe>yHBD2Qp0Ghb*@0?#B0%&tCE' 'UErk2-Jt|*$f}k8l-W(kD4eyQnV|-0s(oDmBz2UIi?%V6Au)ROf!?F4Pu7?6qfyDvslVqiDUF}(Q>u|;Z6h6{7ejTh#$-XLg}5!IIiDP>)6pD6fruQPWy?R2>lvnK<3!;d)o_z?;`A3defn5W0?QT!^Eg#3o*?' 'h*7bB2!FXn#e^51^xzfCr}EbgIo*+qT`#AWEmm1VvQ(^8{?qyLaZL53e)-wl_#fGC0e=>L3aot4lP7u@C>ZQ2dPT#Bb=B*!*{29i!*_hm=(i>UILY)3m(Y=n*lw8-LJW' '@EP8kQKnNMBXo`OJkan>WAzT?kQf}r2N6H%CxiwA5khi$S)r(Uq7m@#WtEYf9^dFj78!-=nw6uw!Yl619#A@CPUb#q00d(*FkhXb' 'N3dAvhvhl6%^QdFe>M*cpi_h9Jr>BGI&R&06Py?HUbm@X4(SHRN6At!XK@m0+k_8;(Uifw$uZ|Ew%k_i`_Q~07o3D+C4v={T)W(I' '-TFS++nEkJ!dzrI%_$K=' 'j!48gUC6<5#6NCF4gM`3;Zl#(BuL)dUb6{@SnpXEqYXwJI0qs_lcP$2=%hfln%P4SU=no%QTpM`EivFGgHiYAD?70xS#(q%Jv%!0' 'xVg;%7Ot_bq5P4IDq-12K@rql$TJ7Y{jctn5+N$^<@%vs^!rn9Ukb$^v}I8w>n<(Y+X#khf$dx<`D+(=yeAg|Jg_EOkf4nXuC{#3{+aVY4m#UY0rH*aXkE)Bxpo?jPCni=p@3?' 'Y=Z1g%Gh5#FLMe`f9a*b`9dG&2MTf6lwdXS(P4`1sT+Gf^v2k4tGFL2Fwsu;+Nwy~Z~ugtt^Q8Hv)4^nSpLa02aqKmx7FQh`Ilkl2aQ9QD~t`!oQGL7B4RCM)7)FCwiu-F(~3Wk5>K?v#?i' 'PhG3`5Pq>9lz-Q!R$|2UA-8Osr@y(^0gld*bGa1e)-#GTO=sC_FxYWrb!CrdgTxAfId36?$wkqB*nNChJRIc_$P8*!edLw?NB#m_' 'IOj9vccR(-q4#lD@gFhW*N_e44jL1z>4U>}#_0epu=tbIme!p><0%H{W3zh=3_JO-NYLtM|Kg^hL+kZ5A(O!9!&3)s{z}mWCj0w*' 'X*6EJB1##K_3BZ(qJMV*t_?ies?qcaVQCN4grm!KxpP0Mz~9Ja=RnHwWp83l%^&>epGNRVKl&EGhQ5T%;W9#h@Td@Irmx4xYg4cb' 'o3<)AgQVV-NerpM1ITi4BkcP13}xrm)vHFXmfh!!0*qto`#oH7kmrjI(48{SeW9@&9NUYf+rRf{@8+BvKvjXYl)7m9E}1qz^DB`%' '<$awn^^-bvNx$kieD3hj1b$FJUnhUK0iLk}I0?T2FMhFDB5nsH3g98?Q{`u|Rw=1Hlgqz`f6<|Hgo@#8KUw>+cJv_YsM;tz1nPIZ)`M}`F=)G+i*p7#5L&0Mne$APjX9$2!dTdJMCxN7c?@^Ry;3Pv9r~Ag1*gV8*Y4j' 'x!(qmMI-N`y%WS)G8G@xGpy-Z;7{r{iQ`fqy}sm1z2gMy^4j+GI>IN}clTxp?BNc)N77w#@z2lK+U(O}_A*75Zpq80tV`id2wW{}' ';nT{5_HMwb=|3sNQ_-ZvW0^kh`lM6Mv%I8zm=M3oJ)(*NxN+9tSb9xnGh!kbSf5TybGnlsQ$VCrm+$KjSE{+OBM9@EmjqrMUx}>+' '-8c=@sZ{F%0eSJHn_lX-0w)wWnIOkYYo5(~+?dWQ$XaMFe15G4CSPj4}nDKlN1^672=LN@o@;5HM?gD05x|XM*f7`CzG)-E>Ap|&MzLZ8-fli' 'K`y-TgLip(HQlv7meBuimanXZlcp{K+hUsTOqJA_w;<;SRGZ}*TTR3N=rGV9TR2^ds<+61jUk#A%GJ8dg5KVR3J><2f1x2>%hM8J' 'K2z$a^u8I0M(nQU-$MzFzMymW=c8pPB|2EaDbE87Xh>R5Ry@toauWkT9d`49kxd-mR<&gkO^Gtj}R!Q' 'FEK|U3xFlqoSEjcGO8>^;;YqZqr-#PVo9*%gC3a?C51Rm-aCVe;shaTv8`=%RHysx2B%2>c_}FubRjAA+4HuNIzwN;+36@+DxQ&7y^ID|tP|ECKnIb)(**9cac`EpQvpm}wvg5?~' 'G^O_Da@}gO8Iz2C?{Q}02C3COVAmlm+6cdN8I2sw_*xc}K{ZBc)DYlCi6Bm??QPvsOT(=@VX0|r1cF}>Up-eboNAe#G0%%UNN' '{j=FI9~I+j7;EBBXCN}KKOSqH(V$ZjG-c=n4g&5I9GS3~?!3d_$qd<`W`T>RpC>0M$zsDDo$ajL9KV;$e)%>1Fqn1LCRKqPtS>`n{sn`3PhX' 'mQCme6?r{%<}O?y%+v?Fmg$=aQr&iNZQ^IV^rdr{nYEAxJBJlh&=syagaFqR$ws<6!@D$bD@-0F?f%<' '!+~4!ZvIeAH%!b{@;~>!%KOF=z2~T4{AL)iQ|@z%;G+buZ=+Va^kZ?-s?~8PxxaS!?Rah{dvpI2T8UM' 'Mxnlxx(xdoo{+kF{MiSl9ltA|JOJ_N-ocb?lsI-MuM$@+vGN-jP01CY?!dUaTL8B007-GbYvbG@v8?w7e1YSlD5DUw#V+g_Yt|5{' '(hTyL)S$|)N^W{=pu*lVI=$OgQFs0|EGWqpaHP&LhdgM#1n$Q_vR)4GPog05BIh?^Cl9HcQu6PyX^EGvd0|USKQGugpaW7f@r3Uc' '?$%(6x9G+8F*8$8E5vaR1<>#f3G^n|0W?nfqUxK9sq%z~0bG>*EJ5jNB!yz}_c3_&6a6FD{D4P(c;50agU;tT7S`z9^oM)Fps(3-oL;6mu8?kTkyQH!;8|ZG?d}1Cy' '*&_rjdHQ6&aF2v=S<6@SZ8+;MJq~C>AHD1n)opmIyR`040!+!g^HVx;s&GV(O86#EI^u&5=j7dZ>+2aET@E!vDiCv;LXM)EuKq2#' 'Ilf`1!FD{%uYv$QRE)Z&M`?K8_4vCeL2$8~DEgm8!Gkl~-d@BXn<0cg`Y*Jw!E&+Mg^1Q3fTUNV;43~s_|2d*y{9B!{sK$Ic7t8b' 'ErEKcWG{%fFmmH;6OJlxe8^VhMwt|kwD3)H)O-G`PLI=b4firw*@|fy2@x8;1A&Bdx9aa8C|~FS-s)IGou*x+izxC>LRZwsR6M1=' '^RqN5+j}|T6Any!0P{>~lTFiH(r1Y9AMAaJaIEoMo' 'Br{?Ht&8m3DxEwk_t2Kq;ADR;tvqEn8{*aG`qm#wwp{&=$|o%e?PSlP8>yz~J2GoU>-uUAfJbUKk%zIfgHFR^J9ld*aER6poVO9XSjmJc3Hk2ZZUH$)ujeo@O~L5KA+|lv>7Ioa`EHzWEQd}?PkBpcqJ;}2ikhvxDfHzS>uT^6UFxuPaEFh)vMGhl_C&LngPoy' 'S&J~2eFT$>j}A-g5g#z|mJ?sv(z_(KXMH>9SX?|YQMNjAGa3?7stnPIj1+GoAf^H5$h|3R2ZJ4v`mcy0~mzC|3$*z9OLqU@${V@*_c0o(j8Qb#AV`fShD^rc1CjyBTiKM#nIlS2ERo1~Xv7HJ6%+=B#<&Md{X&sjJ=5lAXUd@_juCQW_OB' 'a4nZNSbO*AL?R8YCVUI<%ZNQ*g)Lt6vH?DM_+M+u;qN3$Og*ftsicv4Z_AI#qI?!Mc=gd' '_=s8)7`jE)&`(9yeN6dOuw~nmD1Z2NcrXlFAn6nFT(5ED)Ym!)1}yg5kR;~ZOC8k4feN1CxbkK$2ROd}=_ag`O0Q4--c37|3g8VX' 'n32v$?z9RxYtz`pqa@ar4GdFz!HUnD>vw+Fwi)&+a;C?2R#Ox}ozdO@GQ+G^L|r>MsAjNozsGbAu0w)#nUa;i%&1q7WV5sihap58' '=lHwZt2p^gVacaFos1w?7O<@HP_-F?6B*@eOz2~{q*X&vRUn;-ss?4w1%lMQ?!bqRin7^U6v=Mpv`fFYm1;68a*Q4G6oqn+`LC~C' 'ETaJazDD1OwjNE0NfM&Qf2c;Q(^1}wBwx()L&4lS?YvZav5cQ&?GyRZh7N+lEL' '`;-qr-m3Na=AbpNRwBKE_y_E(UhnqP-t>H!ql6cz?kGpXo^f_1l*@rG7wK>l-N6FfY1v237Qv5-Iu{#|Ew1VaGi+YIn&N+yqPb=3' '86}=3#P2lxdJ9lJ3HPNDm!AVwOB-gzjPT{mA)82d--w*9m^wxyVGxq70tF8cX2bhe9`_Qzh9g~pOcgUh>4|8TdpAg=Tr7x8PbD0F' 'hF61ZdYK@F>5(R1' 'QB1Q0ssk-ZMh%bK*GJ}QhFTY3C;!JEMR6*P-W0=D!5?XGROPSWk*DZGti*dfFCj%%MVVBTD}E^$1Z9s@q&FUJJ(|75?P@t6-5hda' '2a4Vbbj4o+WCHbnaiD)D^fj%UHjh9YwEZPrp|W$?4$X|w(ew)iD~HwhNFqSv$L6W^nM`KUL>YRvIJVpHPfoSey$a5uh0RNqktmkQ' 'QvTV+?fGU?dG0Z}S>$bH@VIpanZ?@ojRc~-7f~*5g3!#P*G`I$yu8-Rdh=E8TZ+4`IpNrJ@1xc1ktX8_t7bj5e4U=SjL@{&Zm^_W' '#6-R#=#eWqAPuDMS;1u>Ed{nI+66w|R3dh()~Pbv$Ux;Z)GRIN=_>kaRf5c;(m-z-V;5F{l1Jdio>qsLC#;B}t~guxIW3DbtuhU?' 'T+jR3S(UdT!rM!VLgBH~9$vKdX^3lz@&OC>muxa`KS`heFrEBe+&Cch!B(wSi`bcA08q0-RjC6p`TuM)eiU=2%dTDo{s?lXFK?hjl1sF|sp}hiK`A)f^aBl+?il>sJ8`KwyxHJE' 'Vx!T>V)Y!em{NWlB)nfQ4C^&dbjGD&FEBJa*XYH$WQXH(1u<%*vDO&Wr{6{Pv0wbk8Bwzbn)JP~nk7Nyir@z~lMX%cX<(Wc*v9i(' 'k(=K>SZZ>QbEK7Oj^;}vD3RG$MKiQ8qV2^=3o?RBvGVw^g+^6P1^HZtWGVR)=LTGbu?UU#v;3y_hV|M6pH?%ZUn5tXpb^UXxz4Fs' '5vE`_?xX#ln^B5l;)KS>Q%Z{Sh-VzRBPLyj%rtCbu<;F=->IzMwx)!DW5eG4$+ckhNsTD&0|e1*1-*awdyMwIt1J32j<@Xq@h~)P' ';P2MqabP3pw^R(hOL3@-*EI=3*VUo}w((}b3a*=g@u!P*iWI_P!6hc5=x2O@VQ' 'zG}m^S})!w*|%O7Bd;KNYyTow9US?L!M>7rq3O{D&uE|PD01XtQ{r}0yYc>7P;{UC4_ychk$Y_OD>=Xr)iuZ#AyBqH`}Yu|3|Z3r' 'j$xJiR-RNV^xXKXHz&X5ED1k|K>aZEqPrl<070gqyr@6V(ll9cIfsSI-|uRqeNAL;dPc{fg&1lT=B>|FJvW=|`bJfitY)_80D`BH' '3ghX@fAXXtV{x4hUW&N(uPq%oazy=7Ays{f#&@zq5%=f>K5Jhj_|!' ';+&ay!%z}d*A~u`JnMi8&&}$bf`BG)5r(<7#d}j|uF8pFqgA$p%1m@uVG|y#^I2k`${3{(Wj%;Ou3WCO;Vo-435GXi;J}O?;7BMNI>XdSoLCp=5_`;iayadJ@<4EE8HDGq0j4&cbe1UXo' 'ft&a^1iuClwDeg_n;3`W`Q@BWWS)y@%O`Bixdb6{IUo&UK)hv41-M>sqv7k5=x@4BJc^)KHTDXj0BX8ok2W`mh8ut4`Jc7)H%QjV' 'pF?1qBW3tP#bYI=J^vzqB@)Svf#-clnw#K_2TQ>(C1uXBYZ#T3BXUy-lDL~^&-n_WaKY+QghVsS$Wg+GlfS(h236bpZR{CtwPijw' 'abx?UN?T%Ysnj{*bUsdri;q?{jX*Dgx5QPOA$4ow|Dt}7ig;bqjIGSvJL1Sje7BLK$$4n`(~H+UL*-ih#3um+uWem21|I#a3XdJ2' '8CM;SD>YRn2RZYtzDW+`yP;{i;(64xQ2{3K32DB}l=A' 'm6>iRj;)rAt~ptjtB;K0%w!Ynq%MFP6YJVPeL|z#1e8ayRhVs$ACE)I)@6qa*?u?B=KD+j7wl!v`Ww-r9Eq%4@4d=Jf5y!*-jYWS' '(;rH7>DZXoQf6EH7=8j<9Tb=1JpxKrI7nqPlpN2lDnvasHZ@YIYVn!`YCW{A2HC!Sci01+kJ$M$6=XAPW+nZqaha<3>^%>lT$kekUHrmrxd#O`cD?JgNBKtrl' 'of!0SvlPOAfMUEsCEx5d4sMx-oQDOfKIP2!A#sL?C?11iB)3R^9d47M`_P*p5<2tw)qB%0co(Ny_ZwatA!9W~23uVsM~qIIY&6~A' 'QtMR1-GYs)&hmb=@_#~YY}~Lk$%MHLU3b_MLoIpAEI$*WEh4TIacq;e=6J>Cm`HiEd;fz~&-{>O?lg!)u#SuTobm{7U_Lu86Hcc1' 'Nfs17ZJPeWzSp4h5R$z*<%3p%IaYpV5$=lL0FX_fXdm6lUzPl`8f}9dz`JaCEC~*Q%wF_0U8=u|8R6)F!vk|YRE3buzXxXqI{5YF' 'h)K@gSWL=bR=-{p3*Q1o=*wv@FggYo1_}B-e(yB;GfnpwWKFEN5H65t2CiKyrL5ViNd((~rn0Be+9*LtYhq5eyEADG3mItMPVN;^' 'kCfja9ub6};jVo_2DRw@06jd|2jT73m(OU^R%Xut+FYObec`vUZaxP8{nv>&l#o^vI@)Wog&P*xPo_D#cD{hU|5kLbnbCH}O-=NdEKQMBcX%ULmyL~gTgPP3`D9FbA_;>8&xhYj-XFcQ8iZ6%OP>!vHMa0z-$`70cmU<^6o92+M9' '+!HzUZ%`O^Pp&nG>qn0pKL1eW>XdN#4vlktqSc|+a0VAn;FpJn?0kqt`<((4w4-|92ArB==_Mf_$`%ubD>o@|0?~pesO50|Mk2s`h*ivWoxD^JE33&4^~YSuIF&(%HqeDC=(>Y^HhnIw^Gh>D{r^6^mA|e(?)!30GcIl2Q|Dk^v2SGGr>GHO!I!4Me)fa(@2*>+^zitS$ec6$?`>@`+B' 's+q*v*h`(MblCnuHB9Eo6$r~WSs=0WWyEu4RJVu7U)s)-2b3cQ@v4;R9$=qIktvF59A~3Zt^cWtgPJJ?Eg(%>dlTfZLka(rhej$;' 'i>fu&giuj^BbMVGBLJ!fHkmm{N9M>sM(JBw*!`F#Lv$K+A{Jam)9t1D5_E_d4B~1?ZwrE=e@}FtT7M<-vmRh4eyv5)ypXY!dyTSs' 'HQ611@xcT9H5#bX6>vIep=BrEiSRcqVsrW86raE(bLPu?P{-xRl11U?XjmoKQJM|@aNs8G{5K`MhD6V(BeoHA)b`K78n@p9#xjR8' 'LuEM`tnn>SEjCK^$xwG+-0Vx#8e)KZ@OHEZVe=m`4~Y4~m3t{~r@n)2%ofUi`dm5lF=w(Ws8MnmX-pDcmuUXl4l)8PX@AXb50QK>' '7h?8fEzEd{;cUMgjI9jA`H|i4j&#kk{9DRzf&iMAZvs(r5$}D!vN#$>XLIJw(y4t8{92bm28N6fa$R=u3xZq;P4pf;;Ibqgik%6e' 'HC-QaLrCO@aL8XoUqMmGjQI#GUUwwe?;_!vh6N|05Oci8U9g(pp?IS#o_x{h^#ZdA%!aap&jTSbG`XkY' 'vy+6i$;PgDl2kvSWBeyzsw6jBKME&A)oF@QoitSwHHeH+EJd$?JgxxNU~r}Fdcqe&uKAJhHdl2``;bz$;6HGMR$LyEvd+Vy#xU}7zD+te;Pe@ro-cWvoHER0Fl;njlH+bCWGs4g4Pe|omtz3CUhd^UzL' 'K=HKrsf$`55nc-i%%Kf1w0ww{HhVPWi#CG*!0LSX(Dq$uB?D_~' 'B#M4i0ftxcNJDv4ZWJVo@z^Q>T|Oof*ZT%6!Dm~#lDm^i8iU1tAhK0h^~A9u^DI+gXBv_-#Z;M0qMx0hO4=d{9c#rPJvO%#jM4gM' 'mHsN*d8$bK`S6T%OqZT_!Rzu~{RTm_iNaSzZ*Vx3K@xk$X}o+4zZc_zR`b7A(`=$_EhVG5@;@)%aH@dGpzmM(5K+MMN>U{Hn^50a' '>Y_7?Za=s%N{n0|CuFEZz45#LK_>=dj%0' '#(8lEh?i+AVfPIVu20p;#>q)Gc(sj=$TwX5zUQIGlJci6~uewzgx3je0xXvSCw5~1#mctoUZ`3N>&m9?8Ty0&+$' 'UL&ei4F>zI%ceT+7eO|wl|uqYaF6PCo1E*xswYpCsH(k2=CCMOGQ4~<4dFV6W!{XDirnh$n(M1P-X)p{@i^Rw;OFQ_yHJkUQkGH-' 'yGjhD&HojK^ZW@WlnrfZt-pp;6w+JF)#R}rHuW^tZ@yZX@1`;C$JJyfkQ9T>2?>g_#aJzxj4T' 'H8UhjK2`W~SIh=rrQJ#1iBmzB07@O)^H=hCx}+O`yMvi0fEULpuxye?Yuf=ZM&9Sd0epP)qKQ(IF&oiq{RE0I;xaYprAuJa' 'wp=a;zWE$I(CEjHmiyZcL&`K)CWeQfQ>%ZTsAR(cflBe$1qf=>Q^pVdBo@BOKRG-TlQznN9Jh8#yR|H%I`=mj{_{-gn9$os^bNwC' 'Q->5_^XzwW8p>i|jbV)_352F6{S2ADY$MZ@myhs_*L@t6Y11@S;B2kAPs0k`zy?PTqu|X2!61zc?z~%kd-yb;g' 'e5~hUmB1VF&+wO4Zef?PMWSA5F#({`CSLY*?ZsoHDpf91-Y$~c4?wWemU*GLg$|qfrsw?U7sXU!3GZ2V8&BgH+OcR^F(ec-`#aD5' 'p%&Uft4}I=_D3R)gVIm?W!^{*FS_J{Xw~jF$c1&2B;v7PQ<#5JJ4hr(iJ})ww&tUI|P6' '7v)^v6^ipk53T_wcX6pdhyfpk?ROmxuX>$fceX47E?Mff9D)5x^s&N7w-1UOOBDH}DiZ-^$+R;ra%FLa-n_x&Tl$Rne&aRge`L8t}l2f6XCy1{a!YYcS`ad-KQ' 'ZL$$Yv32a&2^^lUufA3Jw02heAi}U-9f8U{B+nb`Bx{{P@{$G6I-(P9I54njWf*' '5NCDW)B7AAu=W?_&UTW6Hq;LwSI;v))PYSqTD7$cC1q*vlse((i6j9S-DUJe(gD9PW&($0em*uj0;Y#l|D`gyoVlStFv*Bugw||C' '9K)6Y#sEPwy@;OOFzyUDTSzC8p9^9=f_o9ncgO$kV>?M`E&#rtA_tfMVO+HhW*&$Syig' 'yn6GU-pQKFF0YH%l!m1*FAc6ypqu+`iGX$4a936uw6#GgHd);=-XkP`W`{$oFQ9>}2pYQWdH-I-N9i~W_WV{%4vEFl-UvdH94mBO' 'KYGVk2}8pFxmWE6T7E+l04E?Bf2lsblxCf$Z*-5(F9VnNh+T{b<+EVnY)X8P+-6nkmT=^g-15?3k{2R;?q}yv3' 'MwOr0G{vHV_dG6E{*NY@%_@oPB~s}0cYv#WZLWPGz#JT6*r;tWtv5kwh-*tWB;x6EA~uM{AOTbsZ2oCqm!N&}8(D@j?2w)nQQ)BP' 'rX7$nEk}SLwWd;W4cok=DRb{BM@lqbr`' 'EXq}%Cv#S$3b?p2H$u6<4D4wg5RWHNQ50?rl5e`y`91w=cZ7BU48+mZ;@M&K*A*{rZnb~`{N9sWs0D;|tf#6@`~|d7Y=?{I-d0ln' '0a&%o7j>MbNj)I4G8P$(i7F4mA95OS+T3<(!Dr5{yv8Y0=W(`$eo}J!RVHaAzpIBhzSpZ8zEcBJsZP(@_zX895S2(UH6AK)MtI7j' 'uFLqthkTz|B&eA{txq@qP)~_tH6b(a$t2_y@WWn#MsCD$3iTBc>fVYQjb=jwJ<-qR|woz9LUYjVxfusP07rZPKXZdg2KWFzft)Dp#vZpW2' 'j*3aM{Hyz3kN~uDO$MG+QJL*`COyRr7E(}`2!9-JOceu&tg-FrniY2{9C~{P|6Nn%Z}DW^ylBN#8zsGo-8x^-3aMTL5l)l)**HL(' 'FLS$Yll_eH(?I?w6y(h7sqo&@dRln2yz-Ci6D{7cFVNESd-<8^-PY=b;Ve@2Pj%DPn*(PjKx_IsD!x^9Yz*?J' 'goAs;w?3petUc^yTb_!oO~{5)ND(1iIm#UJTOJwQZBJBy+aEZ(dwT?$PKZ-*0C8cT>W9F@M-V%j{|u}kU|%!-+IXkUI#xzJuElZ7' '`hEE@KQNU+yh|b61@k9my>4JgtG;Kv)CdKHcig{Co`j}wV&1>mt3J' 'M?}Ka2cruN8%@oJwKZocb{r)*JFO0i4+$_Fq-&)Ty#vfG36Yk#2bCg9n*y6CJbu_<)g3-0Ild11ZK^+1O*(uOKjTmDg=J_@l`Ah6' '9x@1>(`&D&@S100&f~zig01{miL}bfDCeu_!x5mQQHY7hhVf(VhW?$Fus6>vtpX;cx1mKTx}H@hDP{RVar06SF-+;UC+@%Z-tafHU&o5=1=2*jB2{446UMqAQsr_^)-Qx' ')y|9mFu<7xiQgB(*Mm6B0*>yVFFAry7}Yy|LN4+)=qiiVSt;BVJ@Hm1g}7+a`d=h?<_@fQo~{dXfjGqy7~@#JYE?fWgmvs+1UAu6' 'u=B($WsPctS2Spwuc*S{LL#T7ZIMk)1KS}>^_%I?j4OpK!ihBmVxFOLGKi}j;|XkrHY$c!wO1$BpZMvRnj4+6C3^shUyk?N*8' '=z}ur!sKCQE22r@risB^?9h!c7duwKIpo$kmuc}NO)J8hne7aV3RGaqUAJJKjvMLJpaQm@rGsw@McI^7s@Pw+9gD`9C>N?e`_s+e' 'kM4+dE)gDABx?vssHLSXj2O-5$iGG1NDmsVe-c6EA_POwm3!gKe' '+xa<{E8SlR-f299*8?(nMun2oIjzOCF0d-#i2xo812Oy)5-`YZq>#QutTTbUF>jwEcw59Ab=rpm*-DL_H`Xrshi3ARY7r_>=X@tL3mJB{Mub`_6)Lw6l' 'jp~gu2^9rlE!y=Z0aK3f3{Ha_`SmXT2|eEwd72Rz<`Hr9^fBd~_JJp}CobTZYxbajESga-#!E$J7#N5cNqgt~D#V~iR5VqR6Purx' 'GKBrOO=%{$8$?LZ#1H7RMoU&Vq)_pv9M+0;V<elbC_}hrhxEzUO&ivz4Wr?f+5uVH;r&DdePhp06i!qn1A6%R5KrI' 'eJf{C6geGsY+kQPrVG;4?>o)fH!N${Pw|}v09KmATQO_wD;Vpv3WDSa#A1~p0}~!dU;*jBVg$feDv;;UH@42#7=7FTY$b!Exs!i+' 'PdOt;k%EU|TrE_kizVj=fZ-G)KJ3BWg=T5$EtWkIY~QBJJ;0xDwDEx5I6>poyxVg@Hk6$Tx(5Rh%x+sTnyO`fFT?89+((M!9xjWm' '1o(MLAYm{d!W%p{p+t3g?gFg;0o>+a(XjQ3;Dz}1edl!o9hu)2436tmPzzf2*%^3a7ujr8=bHBX_@-DcpZS_BYDaWG_YAGWXP' 'HDTE{8FMCz1p}MHj$b+wkUvztnyM7Mwsx7(H9Cy5_vZ)}m|E?>S%#t(S*~ZW#nIVC!F>ONMZHFw?)+C?h>_DMX`hPsOi2!{Qr0?Gl8d^_j$Xs(L9~&nN(zD>^NZz`>d0*ChU|l5JHHGxRtu=PNgt^pO>-%I' '^(+_0^LXaS!cnJ=(M3>~yiIFa=Y8Ci2x{dljWG|^sdNsn&qH*A?p}0CAFahmC2>nDj~$`cys~a8H0O0EIcqII@>QLjw40C4CU(6g' 'ieILwM(9RyANj?&X8w!nW(FRNus89N_|r!@)W@D=6CW~K3usE8*+t^fVUHgId2{%UuEM_?1=-WS9!iEPXan)2Qp35{V(J;^#SfbK' '7iJFc&ponTpggf7fj!3Yj2OxCT=4rq5)<4rn1x+-1fZ^&gu4B1pzWjUvEF4+xH6MO_$o@EJ?DVlPJ-;uOw_Z=RQBjjwg`ey;%71u' 'YX+hII(c7T?ADu(qz!T>5ED%HUu4GhJ_Wl>`C&3vg75^YEZaS}5rYu=MSAIFiw*9`lc_%&1~ut1El$P+gnprc0~llsmGbAF6rF^m' 'e{H+Kp~R!XAxGwxc`BWFg+ew77SN&~U=!`im3Dv&M^371)GAv5v*r{IX=JezaS!*mEL&WL2u2LxYA?dG6*}z(qQh@XNaPnep0j%#' 'ItF_{he{Qp1oED*zID}X&l&10X*;mLP%5H4J~P3ay484Q54!~z7V8sFy(m|f_p$%jO^!Hh32Wt2*~fNzKTyNw5yII^j7{O63w4nJ' 'm$LT6kL5)VvjCaM<;e`x@7J3;*c5t1kIoYuB_dBBRg8%#pF}~&M6hxEHs?Bo4h~xs>pBnhYP)GZmrE~(CHdCAjx@YD2ZLYy3R?6V`nyrPGwxZ@S|$tOm-zuMFs55MJWYwFuENwV(%^v*){)3r$1TC' 'w^w4q5VEp>OnaM}d{sw1>rer8EVGk@$Ke!@GgL{G-ao1yrKpu^Z@QL&n-!ae&??YQbk>5>W4Q|k{XDlDoU3u' 'Y~VP~zoZv4>Km{@FPqr}AsqgL$cg}PtXe$oy8@K2S>{K}k^aTIW&Gyze@Jn=%3QQmpsp~CGKAf#;x4!`NT<~eRkpke' 'c>;qOw5L{#qD{fOcj*x*&$KRSw;2dIjR?T(l2Pk^s2x&YR2QQ_LR#wMPai!kOio=aeY3I^Y$LB(NqHB`BVvq?f04a^g->+e^1YOk2nm_II6JQ7Z9q@+<4+^w*ee_iuvC2iS2hQO' 'ahAw_!RenH;#fRTI35Z({y7#ofa$j=J`Awnx&xD$+j3DXR^lja<9f<9zJ!TOyXim%2!ChiyhDp6ALzIrig8d%bXP6~@K+0n5*EpT' 'mL*F?ZlM(O$}d#M#g$K|6Q`n+mUuPfPDg4*=`t#)tnuI+O(m3NB@SQjhWUl1af|y^Gsp+0q|Qt9dFtyb41T%(u?_%afWqD2vY%ea' 't;IFlJ5in3C5$=*OFMMjz{9RZ4>lQ=H1CgIX3DTC$c8gGRHqvy+dZnrqNfE#2;ut978$!}uatmU68YEG(+MdEN3-?LF2&=iV-!##jZITzt4GQ_MvLh~f' 'h&`Vf_U=A|r{O%gA{^3SzP&DpA3y4URBq_9@c8|z004A?z_^snHnG1Yp@dHp#^gNiC-aKa)i*uGe#cML?D)p$I;%O=UP!@P(uUvr@n#WMvZCJDbFw77bq_<&bU1+>sEpz!Jk?!Giq9;2Jsr1vi_pgDSbg%kKOOYy51OiJNpJ1&I' 'qpO>8r}ZfWhnKZwEsXW@c`#={^du9eCh0stM~I?v0eOKtD@q7ITUE=SeRtM3yAK}}!p?Zb>Wdsl$Nht_8n9SqhGtn=B(ev=Jc$9W' 'S-6&OgVGlEaSHuF?!Qv^deT&HlH-UScqFC;^1`V%424I_znjcT$nDijrCX2NoMNiN9!#nYzg%#aCl}43<+74-`ilow@au&JuWZGF' '0h<`=7>1QH({_@CbojC&=>rd1@NO4WKrEXO>zxCzj1J9I>Fxl?L-k(wE%rk*=PZY5oac%_OX}XWu9C!U>14wFHy}})ka0L8w?`>7' 'Qn-({As;$yWK1hlgL9t&o3cr7s+EHA-C_XiZ+={PO33xQ|Npw1g18aQNXlN43*9EI^Eq5Bx{&o%ebQ?t!8WndF~S3D@>en=5tp2C5ffB2VZcTuZc==4Ss' 'dvLs!8W-)WJgZaG^YoI#aootxsHQb5lj4Q~gaVy#j2*E|IYz6Nee~kkt?I?Gk(7=3`QXz&QH^6KnAb6A7A<5HH17*p$lqM2jjrHP' '5)Af#>`XpWfj4uY<;H-^b9h($#}Re3N@Xb6?}*P5&10V!inykP*`q=CW{GO@E>Bj@B)cn1`M@lPOb3Vus*Xi9!1Th5eVj4b5ham7(rk|?cL4WB?49)s+6?}m2Sb?PIp3tNBc6W)t7xlAu2jO;a(BvFC(QB^jLgMB)s' '@1L3A(-6df34C9RiC5~%nDf&X{dVd{-ix#CPuED!u4CRX(P$~?DaY_H9sG{WMiBTwY2XrS*NO%$Y68EaEk}_?4=1GCS7pR%P(JZ~' '@^>KiZI$gOZovC}wjeNRB@)U_F(%C7&W7yxYH*br20aIwYe)K%KeidLCTXoW<+%9AX`lD|$kVItp~J*BMtrW#sBra*DKw9<=2!Jk' '?cN+D*v2p}+F;a-SmU&;DIBZ9`6A7WH9#wlH3%y8jG%I*CCw1U5c)(x(BrN?)*pjX*~h_Jgd>+1t%rI7aF5K$8Um`NeSw@X-<;D%' '6$18E0jPTK(kChh6lilRfb(v&2vkw(=+EY*BcC7rr(zIL=nQ0n*tw<217>ZohUu@i??a^sE$_*`!plg_<6_v$HwFxnxdK$DAz0{m' '6A&oKq0a_4{6HoUlG*F2?HR^U2M|V0ZIPElpxQj5Sa|7v4?)l_#k4srj^6u8_yS#~<`GWi!rPaB(dzYh' '9pVV4Ls7C46Ety6=b<)f%;20?pNwqX7Xee5#m^-W(RZW}$#WM+a8u&ZF>)aS#5SDlQ7dcs}<6hTlffv+6Pd3VUAAsP!bsh9T@ka`Ti*P~vg4j!*C+1?u1-OQany&?`|5{?g%R$fUJ(Cm#7aZ8j6hH2Ed@Eq%M^AwF5l0>y9W5&Z|@H_)3+#Mju' '@j?!cMo)Bv|zD!3j&Ya_)5hl8c>kO+~?quFyq%2?wg3&AStiuR~&%^6<?ybM0iSp0wYWf;f8+cNy^oq+Byfj1!Wo6' '_;lpdruG#XD9}PICcTLtU=4^ZmmS|V<8i}Rkidi-BJmIfxqCl505D!`up6eRas1LQojgrb6^ZP6<&o(hq~O7q-}$' 'VVp={Iyf)uAk?b&@Uz3_nxYV}maC_F8hwR`Pb?DH=0am^KBeH%R6Rg=FNC|p$2hc$+&{`m&5U__s' 'ioIovC5m!NBc0mTFH-zMc57`RJ?5wFwk=myhMi&jS*QP<;%~!_R{O?3`3DP1I9UO&pBlwdKBFv8x*-qncoz3?3g@tU;%MdyMZgO8' 'q|loP>m(`)Vzj=FHuKA%c1s0w-;GcaR)E|p=C`Zu=+(v|VEbS$98~}2rrKOrub&+uHwF3-O1m6yDF@or5MO*xe(^pVI!rhHV=vN9' 'C0HMM5hKNE4gS(G(+`GT8Rfg~v+)t|KM0)pYy-C>^@t_?POjHxf*Fw-=9{-OpsHm!rg#kat}8Om%Z{FAyJcV7{z|Ah_B#@!Vj7tF' 'GiWq}e8r9K{sg-NZ;Rn`<-O3PcP4)_-$@R+$T!Sqge=4jypT(=O&yFTusgNij+w)3QrJZmVlbitH1;V_8p299e0w!4z~?6*i}IHU' 'iS{s|uAJ0~Ek_6sJpqU=vZ@vvL<+|g`PNaaPYFnv}B>Yj!5B>x{PJ~' 'l{9w&*M9S1gVHxHuZu)Nej#STfCt1jUN>x0-_IY{fFR}RG}wPMz7%1(rJp6nD?#XIuN$fy@su`MW#2GsVE%Ju+Q_%(9mRDi?lpb}' '<#hD1o=x|r3lnnqIxiK*WDf>uZE+AkhphtHktKZq%jj)DAzMp64=Lq^?UKU(F}O=9C!|FPp1v3yUt98' '2J0hS)P1_vqAu=E9`pw;AG4J>1TI+&;f%sK9Ft_|Lx`L!x7d7503GQYt-cWgan=)89tMRISnWQhJ7' 'zQvhA?NMBib(+>1H>ZSWd_vLY?^NplJnefHxLfLd3J6}%E}%GhAR>D1FGujsEx`Zx6bX9%Lq_>fxgF5Y}iErWpY&QVhMxcKFvVlY`!damiV-I+@(KYq*h7Tc#=~VXP`J3ctvL>g6RR0J{l(Zt{p^jq7XCq%&>(8RofIWCDX&H4B0Kj);yP>^##1' '*h8(M0dXkTGH8gn`K|U@Fh3$Bxa2&aiu5XOU-G1_;Ng>XQdte!ZVh^9UtvWc>7#aG1W9X1_QiYCdRurSY$Rj)^9E~_#Q!D;amg&y' ';$gmk)^9twmr%DNTXI7}7sbvzCtt8zAyBdi!^?KEEB;Ri>5(R%8)(^@?;WbU3>Y3E+Z&7|^s7E1a$P8Dv*HA*Q?$h*D' 'a?aqh>G' '_K^jtIj%&I>V3T2nhV`jp?fdd4E$J!yM2aVP_D#8$=+IdSpmIjO!0m#f`p=O0-h{AQ+=?~-ahFMk`6m*GECn4`?*rJwj3BhjM++r' '_R{zugKqtB?M-;UDp8l(q}M+qR)Xy?Dc-rN8L~!g?C?sB<957uNfUf>I~->R>R0NR&AR;xilk#%Vk=StIaCNGt6YTULKA2o=nJiO' '(dn8%wc@S(EDWPMk5Zj@(~9$mv&~M6=AF&Be@i#2!|^0u>XUyy**@laEUNc0%BKxKbx<' 'r2Ss1Kt`HWn&jQV?Renut`{1_Lq|f&Y9Zhy4*D@B&M@SBNo+tH{C`xV>00{%&{N9kFf);Ev7I4>uK(<$JOn7$5flZmQq&2Pt?X7}+frf>F0Wu=lmyXqkJ-oB6=NgS-aw?Pg?4$)h36-)=APT9(|+MeaD_j-I17^$' 'X~u$g)7uv$Zw|{`zq9@vY;1Xgdc@=Lq~4xVZzbFk@YlsLL5Y9>vfoO-4ULXbJHJ4OwnNi_+(pX2=ATLET+JL@XEv92Wc){5_2-wC' '498E#0t!sarZ`v-J@(OUKf#JGdo|{8$^Y7TTUIDFbofiwly+y+O1VUAEWn>IObe-(0_ZR3pKb?Iny`g4cLZ`}O6j#you!c1fvB@5Q@jkTr8dxf#E5;vh)ssuW7AO>sOsOo@BPyrB!W0EAs!C' 'c}&?h*L3;29bf{`w2GnUy-6`+@ItU#ml=6_&uK8H{^F7=Rg<$i)npFT^)#4-aOhUmdL?rXO!>a%OR*MqED~5-t4^Qvy5MIE0u*Ko' 'd!0V(kniN5W3n14^NlM6_Smt>XD`LB1Nd+dZ_}JpR(y%&>ssrs+VT$C{(hyx3>o_4Mf@hpf#v~)k;0jQM9w38wHxdap!-J`-P4N9' '{(G1{;c;pLT00DbK^mX}^HnT^)^IZdy(q$sM?^~BlbFHmwJY3P2g%q|0+~4DfKDmZDu9yS;}Ggy4cpDX{g|Y(Bg$NEt&`O`' 'C~1Fx3Z;3besZv-HL`CFNze^OJvxcm<2}sS?#yGAXOlQiw~-' '*R(nynCmP#Q&1=?Sm|9J^PrSENvT9Qb~J}*em?0%=W`F(@*oSy76!$5S=7tK_oVG?^Upy`lT!*af3Lm_N!1?MFDn%M+f)KM~fmI$1*rVWhK1?b6c-;kK!VTo!sUuM-T$(+wvsBJ4`iBK@#Ye_L5m0qkwH)7U{9r*jfewj{C_4&{zlw?g+2)RtO5zX~GBI7&JjSfcJRyGG-H3^I$-(1iZ#IG9M{F78B3XDAskKqL>+93qhCAU!p>9Gnb5qXP~?~n' 'l_Z4nR%u}0(1LYTGbH$>6ts?is^15dR%8Q+N=l0gl85PN5Lwp;G!WkVt9g8oR' ';#SCj{nwu9TetmJ7vXl5|J&qFn$F1g8#kx' '?P?e1!otbn&Xg&mJT{Vj>_dM(@i@x>uKGN|y2f%3kPWe?sW7z@2#0xRtaJjYXy8#Vt~@wL-?U+SGn={jooxT3odQ*^rf>}OSeK@t%?V|FJ{4&HdvyWW&Ft!gH(>~m%=+EA_RPIyfe)-48mG`=!YX>I_++t7QG~?' 'e7Ad))?=%~KSpp5Q>YwSHkoWGDN)I-uB*DWiw6p1HMs*CUw*D!3?sS@rRWzGzYp;0mUHL+9~6syI4+q@M@HM}5t~wqSE)cBHE{he' '$4>$#`R}LzpOj&<+V&AQJBXk$T@8+{YifM!jDCD7X2lEVz@DY&mqNIl' '8l_p~H4T&H6(?5IcAKTstD&O(?W64h`8h<;j~vc$lEX`-q`2?=wpa)WIX{iSE3v48DXRp`q!tpXzT%CRDYr-5!t+!M8)fDfsTj-zje5lK<5z#d_j<&&FXG(wJ-fM@ZiTquoyD5`AL3a4#XWZ3tB6Gbi+EfkulW%g;KQGo3x7h~iE3T1x0H' 'Ht=HSq139tHpvP(mGTzMLf-Bn%63~tyw0+2@3|X;Y^u9(T^Y1>?^}V+?dI@G8AhtZ6?z6i0p_UTFMKuPo`Thn' 'f?f>K)@d+`_bbwy`YMlT#4iaqURDMNmqxn^kUAB{51-)B#{}&wseZ|_YAB5JTwZAcl&w486(H&CArd_Rkmc8|!9k_}WuwOa6QA`$' 'sfr_fG2)3EF9udB>N+b|-j^!eN{4&?mKd05dTvaInhc?`X8Zut?cb{PPi9+y<#l?qI`=5JY' 'V3H+PB<2KYXsOBm?;B_0x;>@g2Z{Vo' '^1J4$3a5W*ZUy-tJ&#Ck5#sZLKM>sh4HqdFD*n@&6yw~xAgQTN=qLz7wOYpM0Dyi}$k-vxXZ~hKFZ1PevZ}-zAIvW=R8Th+(LLBaxh}djk$=x' 'M{4PLi;}tH_F4<~BaA#fkR(4cHvGKRhGlAToKga&S4ZX36Rr8f5F4VCZrS*=5DI*ftxW5nWAU%>0iU!_Lcw-&V#Kjs`EmTplKL$>' 'tO}Jeu==wk=dvhi6>0Np2MwG*=_k%p2S$)w2%W~wzCR3Tttp-%@Z?0pZFKYNAv(&)x5I~Ho^tZ+@5HRNvB^tDr7?v2ehFc>_J^YU^8qO*26C-@P4$Tz8#c!8v+A*;s' '*VGI;{E`X9i9L_7rE*$e=cg@c)UQ)a6MN~`C&8%wzh4fts8XWgKK{xJw*wpuXivcsMXiH2$O>%ve>xj%qEfd!YoEOx@)T;qXhPuS' 'm*SYjU|;XtGI_t0MgLC>r*e$?L*Kw`C}~-8t|NRrYFsW-jt_CCJKKs+A`n1X4!W&+YukWK?4%*e{`2(goAX%@GELDo`5TOpoH$+8K5!8@Qtp6E`MjTrAz7?v4Z|&rBa^GiJ=+fU2G!m!|z&DfP!u0x$N{;sO(jrKbZo' 'dFAfPZ)65i?hVhw>gv!7|H{4zmX!&4c{LSK4U>(}#2aVMx;+Mw#bWj4zi6EQFFrF14f4u1KV4X+f;ns|)L@}sP`ZMr6V47CJW>Y5' '2Z{iLbu?S0l35hkUu6VTrG5xfTWRB1EM9|)e!Sn~I1Sv*+igmJ8?OV&5>y7fIX~NEs%nWrqJkMV=$QuAZp8oTWvb(-^C#L<;THLa' '8*K9qTyd=|Bm&gK4z6oQ-(=LlP*!fuQ6g$=+6jXM(ePulm8DV#9O<qg<_KTPmZKue*f' 'hAbj~wSz)szh>xkydILXnHl3u_ICk|N2T7N8KJ@uHtQcGCFpmtu`MO(3{#)@l8*3XG^@qmz7h;X%VI`U|LmnyG-Of`A-<)?U0{%K%6Bx0$eSJQ~~Zs4WOl;' '20K3Ol5cPiq5UqC9_q(VyqTa1H9#Dw)!a?t71?%6?hMkZu(c7;N6=oQ$NH2_~Z2jW+cQ(HOyX(Y2`sZS`x~Qi2nb{c+*v2' 'zJuFOuPPO7Ib<~-yqr#1ZQfMC?!PyzL3YnA2ca~=m?a' '7!rw4qwk+SU@$WG>M{BR-O<%_`g}J@s?6na1c(6zL1Ywd<`DaJ!EBuT2}@1L;-f`JP`z@z@GO4in#=!zvPk?ZrTbidPj-2bAT`Mq' 'FoFjjUIj&po%;q;A}PjV)5~' '_l|$B=d;PAJVFfGB#7`f{-%`_K2&N7%7&u+QizqoCMlPDkonIvg}rB>smccZbdv{Iqdt6rrV;}MljJM~7OEko2xPkl&?*|%%4<%p=x`9)YeiN}VtW8VlZajMm^AO=06^aLsI%8d4!}$YFV#Eq5' '#NgA}3B?j_va;C?|D{zcCwdt~7JuTI2+OfX#M-B?Igv7Y^r*()1Qwm;Xw~Dn?9F4-4~Fu^_t8tNY{tRx&UKCROa7T1Bv?83F%o`Z' 'A7wfGCHSmSJQkwjRs?2cC)J38U&|&BsECL|AWc>9hwt*gFXlA{w8qEv+&tPyqNhIWc@~kc4rz' 'C7F+jZbT%h^37M-ht&>yJFecFpj@(>sseTGjo~O_A&wz`aV=I8?Q!JN8|4I4h+r(C$!1rB$@y0koTiNcDOA2PRn-%@`NHNGO2&)t' 'Mg{Ei!87_v+r$so>#gPsuHW<%ANTL@OH_{Aa(?+@LSXbq6hg6mb2&VX;A11~{z)vZtu#A~jY7}T-9WtHEO=kHrM4MSmGz@F$YEq*' 'o_WRFOgOe}WBuM0D4{QLvFvD*171w7ibWz(%cc~KS^A9+P0lGMV2klaz7nuU$v~v0D12gaa~CNFV~2r5>>gJ(*RFfz(p=6C#BgzJ' '9$iu7RP#Ly>$c&mK2zh-J#D{iYv4cPgB93Uoz+gZG9l_qbNW7fJhU*lN=' 'F#QJqtdt{w<^P@f>2Rr82FO}=H*eiTt7`=V!yqQexJGXHbuOfi%)HZyaJ?heCh{Rke2Bp!5HU(P(K%>&$dw@NMc_n)wvzQ@0M5zt' '9&+zZMkvdqpE$`O-dLkX%cOvQn+Le-&{9rkBpL-h2~!I$NzzN6lLOmwK!>QHzzNl=9o@_}rhsbs@tRc_g$%Ar&YLy@s8*$H@Ytamz_#K(ES2Tow3nklFEb5P1;$+AYxf;-*Tsr#A`;OP2(zMWhP^' 'Iy?UE8dY*NvE$`y25pR!F|B|3!DT5e76thELu3r-BideiczfZJ>;o*e-Wj=iXSz#8#*A7?y~1g=N<|4JC{5-TE*1y(iThlQHw62h' 'AR}RIZ&#AmCD_5M&}>C0mJ|*9Ws{et5{`~&rMjP|gg$47;QR}%Y;WBn<57H~D-IkQwyf5shZaJyj{bk&^r6VP6gtKRgYr0m|{YtTz&eT(R~r}Qv{CH+J;M)wt(UmrK(GgZIM8&&jSmI49poK$_>*MZp`TEk6MC$^QJuQI1OjLr' 'tmMXNN-T-W5o1BkTRPM*OAUx2I>|Q+MN#O45;CDYF+;nr@#tEPyH;F(4%7(U`tgkrmpwama>^O**gGm0!~e=BIcpMZ5}bnU?F4`8' 'n?$!dX)=GMo=C^EJ&;Lyhd!hRl}cJj00h%y{-HWM&A|>vyHu*|*eE0dt685d&g>7BpxUj(=kT#|1y!l9gi=}tRrGZyG?)xzQKgMMhB$Q2Z%4S3s6}nP4)be7JONAKjf3m%Bnpg&9b7@tAk)r;@-D=ISTdrJ!MOoK*B0EEA7<=p$Wxz(d6)CTANh0Z6?GY1vPzH@Od|By#o3=cDiLdSi&Titmrd|36BR7L2rWPT`F$@$1=+TJBe?s' '$0*5O>DXu9fQsWQULca~4g8r!&_xswRT(8%{Rs8!$2mo)t9Q5OI5?a%3)9?DMbJ`=sgh3' '+tqP(0-YaHSxecDpXIsLNLtPB=bBAV0r^DhU}mH;Mj&hKJT' 'axAHazD-0J3;WDWQ&ibO;#7XWW-%{rVGf*y652d53tK=sgKfSMdZ&%48rDQ#H8M3wBm4{O`Ki{oY+;qh7gH_cq@St0bz5k4KicRT' 'd}f(q0SA7bmQ@rLIp)%_`&L1I5KYGgzcztLC0$+__0v#tCm>J%E6FFO|G=V7g?@t*{HnAN?&>s=shIbLqg_lqUk47ZNa#ChH7r&k' 's{*5m)v$+HT?e(8UBla@UvNugS65PT>!4eNHlGJOrThurCMRJCZ(^fWa|fx7R6Fv8!iXhJ3oNX$dKe2*mdw+tq-OyN5DZj-Bfop~' ')2rP^7&pjqX`XjKQuvNIxdz}}L8QdN8rvG}e9Xei>8k*kr6E$Lst3K0)qHaMyh*uk29b9RE' '0MO-H07S^tC$cskj|}8H+}=gEMHnVZDt)lZ*2#*x8A`(XJymeKqCqjjTkfdU=OiYGcvvwYqxNIHG`h}0T;7L!oM%=`bC-6~xz-vN+4lk?SfLl?cT!ZuN_-qOlkFuQqKjU~_623qx1w{ywy}(+^Yp0UAc60}53ygxySN&jGbb3c&A|$1' '4aGjFp?UKP0cqQu;$<^fJ^7+SYSTp0;C2sLGG$n8bnWul-#8-yMWv}w!Xamw!Vn&A)jL*}eeMB8wI#gIe#`BXiD@ZLZ;kn?w|=s+' 'YVA=`gnW3U*H1-+0NVoGn=~G$#I)SmLt&{0>)wPw%dY~z&kQk98}o&M%TeD^fNG6x5?i0q+15rQreNw#>`i1+LoL6Y+J9+cs1kK{06S`*F#-ZZ*q56NE9^i-p+%_=2q6FdEgs9YcNXOd-WItHE0}|4mLRzgX0QyJ1@$F)R=nF?gAKr=4=*|' 'FR+BrbO^gP!hK<&&wyd#Cem|5Bw}4*Se!Evmv%Oq43qSQlD;l{^$Rn7Ls3+ujG3=KFhB2pK|nndlU6O5)a;z*nf#+?Jc|))ivsnE' 'Q==xe89L`ovs~&+N;7N=dxV?mUboc`Udt*=z-3X>2#gPv^(p6V0F>agElp3d3y2eKrnzWcDH*DSQ-umS@*wolwZB|amIzxCowrQhq8;Bvq`V1-kLA3cr|1@>G23l{O9Mo3>P9hA=nIGpb7@' '!maG&osw-*3^!(l=iq4|Mj=sIf?s)_F|R2GUIgLLFrmVPdShb*i}Udbr4|RjI#3se%%93)wcz>-#d;6zZ+-pc*m0wvnd=mNaFsC}' 'k*XXqSYcEm>V$Ey+O{_bwO5kP@ZrN^A{M7EdW0!W|8C`AiK&URQKBtMX8zZv)J*0$c`Ym~14ZXml9TJUa^+OU&*H!lJKaBu3f1SV`xS%G%y14e^Nxlg96(qRhjY*;I>%n0hhc41Ebs?`IU' 'U>g`o8MeG@Fl?;wS*m_$`Bua|V=$5%%bl=qh(nl03Fet3lQu}pC@J+;=9>DT1^4moum&N2%kQ9amDD+fW{!scKzhi+X9j$f89`ec' 'kyFX?AS`-YoDC)+3tZ}?GoAm7F%R$x%I}<_YZNnjXpa%O5Z8l-xS6oi?+3cQRV9sEuMlAp$0)aE;(4(2k#DQjd6Cn_6mQrs' 'XFsQ`LMufBmNW1JmUY(kWQS6qf&En%++fJE5@3)+w=&Ik6fbidlo^IdWab-N|1;ZjdYNFs@(Bk2mZgMJm=DJTG<-CLDo5x#{9%0j&c$0*;`0c2' 'eXt{nnt}c{U_}5T4u&1BlpnsXW9J+zlu^^jVVn5iDL-%ykFDWiLo=1jGk4*iqk!jT6NX*C)vCfX=e7oQH0)4geb&uXl~^TQECz3k%gd00z_O)3T>*p8^DzB' 'buIk;4Vzl1BU8j>$HmP>~w;`)3%xfgwScC_M>a+WtFf(PO#' 'VJB!~T4-Jf6l~OncLq+X@z(7yy_wVi1N&%n-GRRJOfLCeVI4_Af1+X^?Va0Hndxq)b+4U+u9US3KVo(8AhB$(c6me`?_$w1gI&NL' 'yP1qn}^V' 'F@XgUX5%UH#+rM$fufz{`(xkCE@ySBl73CrtuUXwsWL5C1{1WEX101I5OA6qH0IE3JK`eppH&+LHK;aEhx7smk0X7t@vlb=`;V(T' '(J}Z~ngTP^r|LrSF#tU=tgRY_nB4oo<|x9@oxs==5DPKNz|S_2H*L92m-K&qnG=RFnJEg}QF+1a@?7pc{vE=9xwxne{?0fc_0sW7' ';my^6-rnW-oO5Y(QY-kdH3mDipDK~|bso5bJLniskNLYjP2W9|$)Q*JrB-Dr_x~TzTMRKc4@e7*kjgzhuQr' 'Cm5{(8rdhZN6hIb(Mr{c!u%-)4n=wrYaaIl3l6=#0o^5l%t7ds)S~9ENNoM`iX+@iw$i&Sd4K9Jm0-zq90Gf|!ywZL>BzK~<*s(>' 'fl*2PGmbB*$C&+ncoWF4ZUlrJbgj>clOeym$S)(*ne}-jUmN6a' 'rR%g!2Wiu&K8*#-@TFtL+k}v$f})K!mi+-#1oS7`VKPsQuhxS%12rC!l-$sSWkWq#K@F@NLL&aAwM#y`t5LBU@FQ`tIs&5zAoZi<' 'Jycd^03bF)a5A!a`~?YE@Lz)7wsj+JOGuA#>|J+6L3H6N0O4@pMUG~Fl|tnH?^+<%V&Q00!0B$S9>ded9c-iE-wXIzI*#~OZy1C~' 'jBjHjC>be_MA)A4^*>S6N|Mg%4(eXc#3*f<&>Qn{2=m<' 'xiG-fa~MZp556^Uyj+m>M1Iots+g3#U1Fh^x!WPZ0}E)kv_-KNMM=4ZBLQ1%K53JCJgF*XK9@9_)fmLndzkt7p^$kTr@sL+4XjD<' 'TgVg~So-e_jaJgZ^}_sd&YQ^z3iBAi%AtV9s4-VM2`UP_m^?nGHKQ}VF}_Eyu$_swiwQ4a&YnoL1cY^nrG@!06zTuvQ5GtXZ$35n60Zq!ZJ=%m~+%N@uMQ%;RV!r(qFL+kt7vnadMA-u#Pwqx@^=5Sq{h6*I' 'K669J0kZpvQfG@mPE=YS-%@mlL&__X*y&lk2Fsw?b{A9w-kSf+2MMv0yOU-H+c%vDQ(O~$46j&rpMNx$(7199OdAcK4_q3Kdb1Ji' 'O07ex-at)iq#_4oVL$6+5FNvTQ?{TDW{}yFfSD}D`1H|o_j6?(F0n6cE6krXh3uRqs~gw**k+WTZ=UHI@m+edH)0XF{|2WK>U(W3' 'HYdMo?i;o=z1A$MAI|e}1_Qf!}Iu_-gS@TBIR?sTLtTo=>8t%WY)|+@+4@p3H>DA)wH>8uWlme|vm#y050?#z%1vVH6xXRl*{|A+a^pvH2mSny==8' ';{8@z;kn}o={`}7wPfyAWOP$u3z~fq5!VCd_JDE=3V9yzh6s}TG{ztdUK*Z$eBC*x97ufac2!s@SNQSHVnG27D91a&!c7Z_MUwA;' 'Pjs5DGLO4>-GTIB$LD#c9*J?T_ne7Uu&HD8Pq`syO^5v4m?N_wgMy&t;Y7k>7Fy5fG1' '^a&cOQgUK)_js@~0bJ4leS>CM_q-df&nvmIy)qgy)jga8H6dq3!DuDu^;W%_u$LPhv0x%teww&jXv9!Xhx~dGg~B^!06u&RFHDtSskRd=rH' '6exw)cLv(!a&hmbbD67sQ;&R0?hX(l2%ZUvi$sLZaN2w9Os|<5io_eJb*AUffoF79^^`qDynhiJTv<9JdOg}BP2w^|mL&hPG_{>UhDaq1EQEV2OP8~uQ$v_h(whCZz_h!H+ws>;PG' '!@de=q-w_$t2Z<>%BuoL=u2`kZ5|B-h{_JNbu5V@f5jDe0Q%aAQ1o}X2qe6Ttz#lB)TYF*bX2d;$v$PE%k%;V+FL(8QROi5SWKurNU#y&uEXrzzay~3gjbTiZMZc1=U-Nn#O`2;~mL~j2lYq(KlctABS%X*#??AAKZeKHfL5FNhz^v2o|wW`YDpAz55' 'w$t1Z@VC2RoXxR|IVxSLBjMA=`b2pXXB&cEynbkaZ`a+tR4^ivQlCD)2V3Vy55=dk#ZsA>T}={QG^jJ%#SRMKZZ6-KET__Mj|h=liLe&OWg6T;I#tz3$TsR7=^iyxzZc+}}x6L^2GFq&H>%xnmRZ~qK)PEj{L**6zBcsbGanWpiACA-`K7aU`qY|QuV' '&pT!45Jd*TC_A~sBLy^`&gnIg_+QDs?H&~OFeU~VV4Xyodb?elq*zHosqs3ZA-Gs77H{^3gf(;Bx&U~C4%z_N0s?J-H8FZ=GI@G6' 's4N6>xh9x2?nCsNNYM(PHG%t*ajhagjk{<+1*2#U^!jQ~Ue@;>FgAk>-bW)aQE`4a9fO9$V0I^^_)-4X$|8IBEYk@icvZriJ0P_d' 'B<*c;n0DlG=o*6Qo-#Fog~PSN^(fM!j0}781+)iD;hMUAtA;gE1N1WZY8V9i4CN%{$9=dfFq&qL2jjv2b>HH94MFIjXuk^IOWCfE' '=ww@Qmblmej^=2l2P@=q0cAgj`Y4s={st9)YGhY@7i_o$>YiVZ$=%gs?@REn)9t+}aO#XzEP<<>OJtmEG!5+{AvIg?=2E8C+SE7a' '-#>gg9ZZrLhC`H_J>U8OoU>1CSlIfSH3!(7IifpL>=d?&b}!gb#?Ry0D7j+J`D8n)F4v9r%RQ5RE)%jgCOnb!13*#xm~R0JCmV>#' 'YUa#NJAy*bnkQMKx!aV6z@^KnTZ0q@k>A5E^)m7nu>A#R%)0p^^8go=65?Hwr?ctV@UAIiX@N%PdHbk#Tj`3AL9@@}6QTZh1H%K|#pVxikUj@v|yt&lS)ckyc4-p%`7{wu*6qjNSlgVV=)0QZPwn@W-@#P=p(=@eTEV+6ySxL' ';Z55vt8ot#@LW}qKd1zLj)kv-iyk=-*HkM!n@Gh4ene77=vgVKjY#<_g+7>OF<4XqqJW@l^*&Bs@^~#|7!ZYWjjF' 'E1S6dtyq%EG{V0_IYT9m!dwaRe2O+>+(-_w<|{w5pV+NB<916^jZU{UqVJs`)q)F)q}po!4h^?))2mXs-{ATrS$ayy$>5_>5t|5x' '6e~%jY_9p93GLG8ahQ}fjj1!Y`4W5%aPiPobz115w{Ph9WbZO5WDlB|A}_HVdIkaSJeNvMMt5}~ZJoE(J%*y#Ht_#XE1G)6MA7;UH|aViEHSddDDtD+&ZH`>MTF}`3Y1Nn-AK3IzSL|wKIwUAm)AN4gqfpBA2=X7RtIg37znQUvJSH6*Rj3-#?1qR' '7MwFMtbQh~h3L*=cIUNlUnfajY^sjvA+l6!W0dC*oktN(p%OqMY~i5*FGvtHxoOGM6oPUmLlI0;e)e4Nz={b`lzjb-_GnT>b&-CYn%(^89>E;r4bNo6x+c=G$o-JU-eYD6bo{mU~P53V~' 'Zd4EDKWwCx=uV`dvOGYx27p2GHZQx(H!4I~$lN>$ZxlIM2Z=CXV8W+Q-7RfX' '$t2y0d?!)LmIT+C#uLa9-g$C}s+rkMUK9!SXSQZ8LQ5&bRQ=RWMzo-qX@)gxFUksii8v$>C`6X77N@Vd#Eif%}~0pnQ}AS' '<8arMNR_4i8LE$!8NVsPRykF8;BvWmM@zSyX{;E&NtGCoq7wI?f2hb2>2|(K5o80*SdZoZw#p_Xb0eP4MWxI;&rH8BC>Aq%10KKHFMBu{#*xS`o&=Ixu*c69K2manElI5+yLaXgA0@tLNS)2dhAq4jQ<#^}NX_u2n1q}%H)' 'ux*JyMRwdW5R!bv1?G}GXl2~pzK)juV`thdUUwcuf?RxAMm}_FZNg$xQ4J>}1rUd4d1hkY`>vWK)6P6g~' '>odgR^w?^JG}Wi>N2A)z*kU*rO)OdT2LufStDL-{=lwg@nY@8y3Y*j0oi8@PV5eg0W>eOIMz@lf=otSdYbbcDcez2p_qzVbmgui_' '%4b#E`lm{b(sJ_I)u=8uW`SraQakS!J$o(hSFcWuB4yYb#%ps^>s6Zl#BT{=r1{k*z`t`wb~+0l@Uvb=IG@(J~)IHzT$CAUN5DiM|pv{H&Fe$XME9TYPk' 'E0QnYhyg$K=;4S*!%jL(NHQ9I4^j?9QiIla(WGUOL2sE6`XX95vLF1tz$B7cHTd_duK-3;ig1dmr?l%03`mHic(b9AC8jIf' 'dusWl46$5IeWa%n*A>bc5lQDT`~3pzZAgQE=O1se7uP*X?iQr39`^b}QcgXUiXJvTD_5!XJR|Fm|C;)D6SYrADwp(?!J)z=5Zd^H' 'zzsL5RbWb$Qg6PA`+n!?%t+jKPrDn_PLz8ZyR*r4hl9fJO4XpqXOiw1;iEPN?N}wYx?Ve7fmUnk' 'HuxA;=&a$+6tU}L)|zd`4Y{3M)E2pQ2v?5Lj`bMoRBN}B|D%$QD&o-_(EUeClxX@w(+)mawC&s_z<5$GVR{' '9LGNFFh+DF>UgW-Fnurl=`x;u5Ty9hiB*^@y5t`JS?mSq@TDa~O;qyh^C`' 'kcxj-iJHzro{bBN+jm0nTAl#u({NBOar(6M8oOh1gKJxJGzxA8h-yIv8S^2~nchX;2g_&K>c&BusTI7OfhRg+A;X?*iQ8U`>uM%i' '+jO4h>thN#N02g$)n!c=j*|(~`Jm^?&C;eK$7RVyakBK+Abx15P($*9O(Tu+hB8P7ak`7K!2uzm91FMb@<$cb&Gd-M6z3RYr}G2Umg`I<' 'GmnGT%ZSiKRd=lmzv){P>s=3poVlu_AxU%f7kn($J-PoC6Vw=9;QQRm@&*`MbUk(`$~bN3oWzWvLkTrroJ(|9K~YLq`71`~@JqA6' '1NqR)HMurdt(Dps`xQ+-Ob1xfBA#PWWR#dSW(rs`Eb*pIv0@eph^OlR=AXd4jBgrF%x1aP%PB5hOgSAGQwv!ICQ(vkKS7FQHz6K&' '#k6)wkx?3Z-A~IRmnn5GViS-ilX~~prxfXq!<8ijGy&jF{+~NiqS0AuldE5S7|w{WPJdk%W;T*7=l-{i2{?dIv9_XFb%u_P#~~z}' '2qn>=Mkd52M$a$FP3)2*q^2kY*L?RvxeY&r&&Xw7^7}f$Vv=?KoIo53V)VpHWC93j>UuyyUQVzd8Qq7B#uXexLO@*1{f9o7&6xWG' 'SZ&2^ECp)GjQI*-FRS%7M+>f8m-7$gpL8K@eURj_5|FW2mk5+mOUir2(1hFWbW+$!c)5`*__LN^pv;lk>|;m{-RO4' 'g(d+2ZO?M6Nyq-Jp-dQQ24CbKEb?}udPf?pR(P1xn47F6}Njzr!ndz?9xuEgi4{$FmDR' 'G{V%59izC1kF>U6&}HPdjIBE{sH6n|R--HGzA&KUhU~A^hXpg?1t`78%q&qo{D3K^sk?cG+qMNL8hqS>?5-P(>FRTtG~zk}G3OLP' '{YbcTb|grc0S1e`w}m~tP4*1*KvvD)s%GlFpk_Kl%MWz=sAG(ZOJ_MPLOLgN7+Ax=J2Rq+2f$=b{z+*m|SMV7^8XJ>YN2bU%(' 'Z^WQUAUsGE6TfIW&Eo~oLP%S8Z*m`ts?)|PF6?jD^ohyCe-XdpsmSWB58PayM|-}4&8fsJT;siTBv;RH!otwz5{Vs%CA62e;a=fE~1dt3m_V#$J$*&m@%L3' '_}C=81bCehH8hu3QDj$S=>)jQC{er?f=SxU=}ML(x=yPz*4_~^j1Oic@PXhGuJr?UW)2fe+~?+z0K^-VzYZbE%^?daC-d{_$?8N_' 'vqGknH61UXEYjeR-|i%f^IL2Tm%B=e0fS?#y0{r$FxApN>KN*uiBZnLE%XIRin)@eDaR=(8HPI31y;y^W;7J$F&)>OOrz_0wxtsV#>3TRg!J*E;O+%1JNpv+HdMh`6mY%oo;U4FKQ0yRJGZaY63{H!34Yr(-@9niS)IdZAUTR_NG7W?h)I3&' 'J5bdU*b_(gO%WJ1KPqYnmz9;gj_Agjjgm@?Sh$oo{v1~XW+54SDY?V63j2`2M4&a!C+s8cJ`d#MrE*L7c5(YXXVzbe1b^k6>jyNC' 'HqktEK->Vc0_VZ|f$MR7)Kue`Z8)prgur96*jOL+W+~mP`ThS?k6#>|8QH!mix4u*H66' 'B4f#_Ja6qdl}>i-PPB$ip$&cvq{(S~P1zEJZ+Mp$PDkp5O>*+>!Ox$-yKkNZpL3HblCz?02Zb;5p?34L7' 'pXINHOwA5JTEJ=F;97PUt2eX;!S8>8bple;)$OQ;^>+yo61nC??!3y&j7R$?d!F&ciK!ny+5=Tin;~eVf-7P|-S&l2+3^mTzrxzk^jHa_(@=G@BfnJdUZF_%enchK#?qLdaWVxa6#CG88=9ly($psgOTZ<-Cc{y4_hYPE)KW#s9~VoF' '4TA~6Rp@niVCP{GU5%)}!(2(lP_tBt@}buLwKetaVy1Zzx9raT5bg-rSpbE4z`lb`R?nT*bvvJS9J$PmSD)egN?L>XaiUYQFAQ~' 'X)&eEg-Wz<&P_}L_6Sk0MUYGZ0x~9%lJC4(vCW9-0JH9-mfRK3M(dt8i|3q=ZbS?7' 'r_$KdD??39LW?*dTQ>gTn$ZSJ03cD=PolV$Ha<`!Ygq+e9r)TdThniC*Zvz!aN61v=Q5v&0OraO7^T-TGP}a1AStn$SY&fcfSC{&' 'pQNkT8QlCgVc5sbivxEh&hExNI@EsYOCCRGf%a>8|x}0#liR' 'LTQ|#X!PD7i8^d9XE2%S;nsZ9ujqO!w5(`PFSsE{i@yk$bu?pG1w&FvNNnt|}Zq{QF0V{5U6L>#E-zbiRV$w9^jK1k$;HIG8C' '%BU%ofy@*@YA%K(4DPS`MAyEe43Qw;Z!wa1n+wAVuhM{EL~Ky;{>ZX2p{S4`TK7x!3rpkT7ne``z0?>jOB68VuCj6W`v`As(Je?|' 'Ja@F3Om*&RFN{RjKW98?yl<(|XSa~$+DH(=1rTO>+Rb#%o=wW8gUQ>(f#cdO0oF-`7%Fzd$P}|Hyq+NvF4y{JH2$F*(p21lGP+zx*NkezY0bnsKu|mO9M;1' 'W^Kmn4L-2@r0TDw^OmGsrZrxF?RFpuK;|lWm{;%xT7_Rc&b&&%!I2S' 'zJLoNxf&`}N|9B)jPk7kaI?qLd#XXUB``R&G)R#QNr(TVMlsg({B0M74Lb+$+OslA}gLCz^3&4Uk64hJyo6^y}G' '26edpM4Q3hR9d8So~zY-T%kD8L@hDm2_Bv^x0gI3LE;@!{nlLIMy=*FjBI{Tbq}qaT85YUrw6u`UkG>ExX)IFvP`JN1ZT%IHhKt)wdEL3bG7VM<3Na{0pg(DOW@e4(`$*d^uvKKM`%ZAcjLr6o+BNw&Sd)xX|CAUd9Z@GK8f}4-dGP8$L~#`f+pyu+OJEDiA5NkYB)}IQ~)Cca?GE*@R-4O#~}bd@sv9Q$$O!QQ(T#hOc5+D' 'l+?J?5hq@?u@e6bSfZ5@Tz|NV&Zd9gyk;5``};>H5y8sCiL3aXOkzId^RyH$@_Q{6m)7MOy0ec=HgY=vUf=X8tYONTM1AbZKRsMV' 'j<-zYue>1*ZeF2PA}ce$qNK@--%Q-Qtdh$5=49ASI;jRCO*A9yjHu!xGV>&$zt0;MbCY&OUxnljzLwmJ&x' '5f&$)_Qq`EL>Y(LPT3(<$6NOe!B43#N=$zb#wf_X`f6mCuuD&ln^-PZ7_mTFVkRb6_E0-b%qWj~-uC-|h5bR-TD%lezJDjFES(&W' '4R1aVe)s29UZ1%Tr%%##i9BA0Y=J!|d!{fsuad!T&QK!OEM0yZLAe-buNmS+l$w>u`i2oX0Ne>qTYlENw3rNUI|%xmV}harPhCPb' '?-OE3N6ypK@+Lde=?ky2&Dj5mtpj$_8^$rbf?<|#cSM`Xqi-UPsDu44KdFL+ORM?1u#fWUFsQ`2Snci2HkZ!1' '+cDna+8m&|0GbP-)$c4|0*lXCEyiy|P-v6OG+W;(9(gxpTy>Xx|J4N{S{-erHkhM7&<4TH~tkMd&gR?xkoc^~rwurjjvlqTp85@0VTo0;C' 'S*OKHqsV!;u{Wn*LfYsdPI!iQEFCrN`&0ud=Zp{P{+`8Y)!Ih#i8)GZBXAqjV3pH^Q)9K86i9RSAsXuyZ{il5r3Y9n^^HWGhVO0F' 'yw$M%pWk<;MH_o4LOx5sJdMWa=m}|D)lwI|f(kaU6B(=kx(L}N65MYQNA---eNZVl1w~y$+8=2sG$!9+xUdK_qh7c6_pThh`(Yz$V_NgAA^)VB$Xa5YIp;lG*W&zfz79=zzd*5lWdPnZ?KwNCk*nZpw>zK#Z>?ptnhRU6GWfvASD#g9PyDv' '+rcH9*CEg~=6cAuUmF3p$Vpb}6?xQ!dlhG&`|t2?HPeDS*PffVVqy($1=XN-=xtjZ>f>bQ>t4^!?nJzcVO0lw~a3t~oL;Oayd{b|0XE|-W' '1;lOWMv-hn7_{m9%rv}<>dg_x+QAo6!44+4jR7)X45YwqXpCqAx>=#M9sz(Jqe%S)ffBi8n+5y`_VX%R$Iv}aH*iZ!vS24#qgQVF' 'UA3vpaYP5r!6-' 'UKkdYri<<2KaWtP4!orl%ZXXcNbNppr>MPsX)Y_KBZB(;vA{8|Air&rZD||I4N7S#j}2vSklaAIU#fcpCdzg+RJ7({tcqba$l{-}' '>o7qBYXC}2!hB~Sh_53Y_ST(WJ8GR*<~k?}U$^@2P2yhWKvC9L=ag*KWt=^dkteMAwFVpJy-?k0={D6+z+JDZr$BbepR' 'DXs6Df}o{0mxnFXupctdE<4#=l&45H{zqxGa2^h?|ziF' 'bY1@_cK-g6{)9MmFPJEC&N(c?H)*Y^G6U(8MvI{pA=(h}e#{??c!Lot?Y8~amk^KlEVD>1lOw|TMe6J=6|eWAWJQ4*5ye}Hc$IzSR7If`Qf*l9eaaT6{8^jC4^lsS(+ujL8@uI=;-Qfse^GOvJr(K0At3gXbQ!iL96ZR>1)usf;+QwhucnLwd8!#Y!fhm' '$qErR@r=Oq`RjU}P#yAYxi;ddC*%l7NRAAf(TFPN8G*~9vDY6o1LVJi' 'Ywpy(##8UV-fb9b7{Ymp8(gkGBzp1&uG1K>2hBzx5*`izudETI5_^PM1~V|9+RtE' '2nA=F(BY(_WHZ%Z%Vx=Q!kM}iIk&wDGCq>tQ$24%-*>8wNNe' '8=@7j<%(1bX0{Ez?=Ov0TYnCpv5pOhh+ar}tokE^x`v3c-9c@b{B;r0MG<$#UjD+wiBYBcrz_P5Rv8(G6y1Yp#F!!gaJ{lp@?&D1' 'ZePlBvZKqaSJ8-&tFg9R-l{#Wfex9Dmzqk?p_vTa!?3lhC;lp^x;5iL_01!!$UoOXj-(YBzM9&;OoI6p)TQDDT!%NBBG(z(J@-3P' '3i2H7s|F|Y(WScb(@KrWp1Bv{r!D@lET#P(NDOKau!pS=12FE!B{Vkb>?v3Cr&bYH^T&bS%>Wz6cu12R2kP@x7;_3II`~Z+=VPh6' 'PvB81GBAOkZ)XnTiuu}jmij%6u2`QV>hAXC-5vC%#cq{n=q|q{{(L$?C3e4JUZ*J2Bnm$WZ#F)ob;^0OE1toRvY%s' 'QX#ev%wT%&V+7%?j*$-DUBRXJZk?>(0WU?x4)dU#n1Q#?RoiDekq`4ssU~2J+B}_f;s(IgnLy(i%nL(yWh^PgC*Ey&W}ru&f77gjm`U+*am~7pFAlBxftkw{&`KDMLc)YgMXDjJ9k5SoLOs@' 'mJQY!HEK@kghkc|aFiEsSguj&g`#+FMx4Ft7b&Qk+EDfh3B|LTSNab?Q|TvW`4UU5%+x(hw~rLRAsa378hz{{uNw@' ')w@*>;ax`dHEau@F!$)J;EP9TYx%8ADCKS`MB(iw4=85u>vz%t4e~9Y0cw>dNXX-obBnfB^DKEM8!1;N*({3o(c~6{77}L$1bO_y' 'fAcgoXDlW{O~@t1h!jS{Z)g|%?Gl@6Ox(|_a4S;c{02;;cP4YgYs|IQed4l_G#xYGv#-i1j1lX>l^epmpK`~oBV`Cnc^c1fh_l>L' 'r+#5QSWSK}ua;;E7gKg;@ZV;yk0;UUUl6{@VX3t%{ca3%Q*f$$0v~1EV!YDY2' '$?qAhM1F?39aUsBgbb;{><2}OD%i;_uOIep+c|W{OQMH$)h(8J^(5`b3KN+(vFy?`r7LPQedhZ?|6>3-TIhm$RvZSI%7M#Gua#1S' '4#An&HsOoebyaC>i}LpTUSYAp2M#*a$5L1tZLRUjo@rRFpC$g_>#0EYTK|qQwXg!tAgcdzJ;s32WGQoI^s#&Mu1zkPGu{KQ04P%V' 'nq#{|K8uRwNa_tY{mi{28hB!x|Bf(|p>av>(<`=L5E3IQ' '66S8^(wP7s`|UiSX&;Lz=0M*GGLQzkg4UBdMIOKUSVp~0clhGN*l8Vll+ifW(IU~lzR>Z$xc)G?xYz*EOY+-rU!G{FqYb_Dq~=Fub-o3ag`|jh+&kuU>gLU-nFTybAqcs5y{^Ab' 'J%yRsq5`Unn~cz+`Rpp|;O2(hOLQ3ACjN6K2wOUvr_+Hlef+Yy)K{Z-vxei3Y$t-$Fq5v5Iw1H`!1=qZ29ci^Gn!eV{K?!m-yPc$iB{xoN' 'kZY#Udv9Fpw%4XRAJl#xeQnE04*BX!@UNXCIJhd^;(?^~3UeU|rs>$O$vzGTTO=exCeJGN?F^?C1ltBJC5g+;70WeTvvN2Z@FLpW' '69wNmYr7sr-~^Oit!vWF-rj@8LFLK9B^{UxjBRsAFi+Y08y-5={24MU!kzem6T?qvl*xy=`VvL@_=?' '$rsQQb~32y-;f5;qmqv}64vIs2nFgDUeuF+h}V%L)1o+vAc>dBN5eQXMyVb7&1l)a0B8rDq5e6Dx)hN#hW0XVQ9I-7Lf)eSncESg' 'WP5YS28TXtO%$LF_b)!~g*3M`(pKSj7#)RZ?OxF8uQx8UE-#=wt35C}ppl' 'cnj!Pc5=@+!50%=_AHMnZF!fD46YY2E!j_u8Wy=-G&(Y9N`%SsY$qK%;b_N%&U8GNJY6c+L%@@y^&R|yPXuVy(3Rjf2xh3=(|=~2' 'iv@%yxuY5{n>98iie7=0@U1T^w(CEz_oC0lKMN7OQaX)t(k|e1!9<#OsZ&VF48dx90B0^Tex^$cpOl_|P{iCybMQR4^eCeM!TKx8' 'K<_yHv6GiYnf};1Z6S_IpNAbeFor$g|e9~q+)Qd?gRdV#VbnSFQxdla#yK9Gb>#yb9p7H2kw<&^_?' 'PZlk>)}EFnJ1JZo+VerzgnDN5txm|zKWyXIs>8iN+M#n-L*T#!xzqeX$aE}KZED#`se@o5}HpxjUo&Wm3*5JxAr&&~|oy_NKM!f088eaM#Jx_~eV' ')=2X89XR1?!w(WbOT0ki$fZ`zD*F>Ma}LGhPh@GCh=-yhx*KGeAG01lmu;!_V|UY~9FZ<-wGXnKr{ZoGq{|*Lb)4N^>n3&8K8U?IkR-8Eg^;xu}bfKJ~kKJT_EKscT{B|6;^{Fpa0T82Lje1Q;=jsk9$DH7JlAt%YNh7+#' 'YQY#@g$U=K5*aYl@>P5!DmRT)d~!0v-4#;JP+H=Mq*4kYhmELAdL<~KOMG-hIhZ=8Zj7p)0uX&b>uCuUR3_OyW{EF?P&YKezuyIW' '6U+uY)47Ns&zzuaQ$Y?a^^}`6XF@?tt6#VIM1k^TWsZxG=oaQ*<~;s}CCGc2$(zDij~XP1ZFZ^_-(M9jHyFv#{SJmhc1$yW1+>v}' 'cz;EWK0$diVOcQtw7EFMlOSrJKG;vlD#8Ha1VRf&{x;ad!eDm' 'wts1jQ<%d^D(@0QYs@t76A>$K;)o9yd97vF@(E9%;nBrM1{y)u&S)co<@)^E8' '5Y|Oub@})JLK0;jeDFRP=L6Rs1k^a4OVDfrCYAwilk^rHwmHOgM!uiIpqkjruwEjh9EM6s5e{EvMTrQ!d~^9F7AAH2+m{K`z>Y}T' ';l5~f-3o+MbINJn4Y&f;by6zCO^4D@>zeRDRltBOZ90Ft1*mXv6eo1s2M^u}$v6hWXh-PC^8Xh=Fqv%LJB_vyWQx4ek`XGMk' 'Smx-eZTkg9kPn@Rj=e0T@;%$GY?3ZOC1L)2NXn_Zl9;*mf?0QoJzcFUhheax;E0HPE5E|d$(!zg)hYbrK?%Pk`<`cX3fLz8FL?)(HlV@thIrmwctS*' 'aZI8WfUbv=tQzn@w2-zcK)|K5FdS1GA&>pn4i|ysF7-)vV-V6Qu-}~Vd0=Yv4!yTx$yxAoGp9E;ojZcRO^mzi!cx6}meAzW?J@`^V0jBnB7im15eoqR`;88`pGO^)2-lTsc+$gjU8S8>GIuEg-Nn{oAHuNHY@!vBf`kM<3*ERM%-^||>p%GDRJD+LT-L6@anXqg16?7559UH|IXk!JfE*eWR#W3N1h=;+7X*QRcA0a#iVkPp0=&PDF$!Q$#10|oRdQyI38s)PwU' '48p0f5ufgx-r6bL_a_xUD{Peor-CZ`-iT|g4m2lW-9-DZwXl5%rZ`XPBjNzoGnjLNhWYB&r}eh#Q6d8Xj@WaEeDY(+h4pJlnO*iF' 'qdPQFNf$WZuKwetSQ3+jlYOHOt^d^aF+Wh$4J1*Xo3@JPe>f{X*e7iK-DHh^zM(QU)ijA!Dg+!XVJesS0>i^k4@T16r(5k>Wj#vh' 'i?7;9Z&}vzsAvc_#w1Q>3Vj_k4+F^hFKO8C-Gxw&@q0Ncb%K=?aKdv~bXGZH?|R6^IZHP2dIo*rcT9FT4~A0boVqKNC$Llcjjo4O' '+W`%K+j^f_6gvB3_$kh&)|%v84w(b1(8et%p0M+o8@qTDX97%5jF;4Ap+m0sc@?Itq}0`saQP!QL81o&cyX<>j{Y9X674=Le(14n?2ui)J|pcDdhR>^7vmv4Di6Jem_9^%F+?yznIXf5YRA*T$W*;X4WHbS~Do8Zn{eySGsm>9HIfvOdACPB@B!36I}ci(s8IX9=0#_' ')Ek8RgsRv#!M|Lqp+6W+<=EeD`kuD^@>XD^bJP4yFDRt!#=`^sZ`B}pV^?Sg0>*|^k593;n1!^)QZ%%>s3twTY?Np8q64*8qA?Wq' 'q7-TZ0s4TO%d53NGoXAIhS`qXsbXvY3FSzB?B$1I#BFZj!`hNz1ch-@%dx|xtJcwCFnNx=P20!!1V-E|VFy$Sjtw;K?mejyKQ=WB' '^j`HDm+Y~rp`N;hSW^qdt1lI5F~+56pN4w~^o4CILAATrf}R^dg4na?|FpmhGt0gQD!_Sv-hTmYc*s+BFTYUYxBu#O1DF38borD*' 'xLD;NgRDqCw%;C0)t80YHA;OA!mFDhH*e^S6-QPu@7S*7%c+gsgjur_igqa1qo_b?3B)&?qc9cnEcy*BGtD-a+XE_tvVbZh7WaJyfsJ!KEY4=lJ?-' 'F)R?wV9uo3zh3)Gcn={X-Vn_GzckfQ;W`Wrf!8$gz6i}8?evrdy^+{#IW6+;Hxt07>jyfCDV@t|pripErY?8+bNxW>qbU#GFUD17' 'oo!3CgV5;@0He~5caEgHj%7$yJGcCSDy$lqHE=^+h$Oqu)oLcM(!kA0Sr6idxIGhs2MKj3kU&CKyx*;B5pK#d=WW8yWYl{e@9b~S' 'FA{vzWaZspM0_Ye3jIN0%2yzw4gQeTnr0>;CGV$L209mOo;kFLd<8tS>vv(XX3p9^+~l_(D?@$r_U2s' 'CN8pZ%RxCMP_|xw$xdhH-bt^D$6nxM%UE5R4mN0@O57217;p|q0=u615biAytKiJDcLAp;;}*fUuXeO3eTDVFe4H{$N#NaN$p(lL' 'G;K^HfuGa|nfDcG*gHC|X&-sr*d~GNh^N%Ru7)<2pn=Kt-&=qAl1*KbXBrgr&zn)+_~mE^f)yAebk+btRk8)@#h*HsdLmOu0?ar{Jj?oNIIK}KrQ$SrF88OYKh@!A_+Bx*L8W4aw&Z;l*B0a%0oX^xCqrcL@FoP(' 'y>@6>oLjQ#B4NbfhFNNhNzlFc7Y8MRks#^+SQ>NU`2OW%o&b~<&d;K$gb8WtO^Ae%' 'aV`({3~P^m?q|?Tt>&OO{u?CHFI~e$)2Dq=9YO>g2<=0?_>mn_mGqfguS3Ww1RD+`kF6C9Ayz`|W0c-7!Tf' 'a3$!RU4ev=U^r66Ujop{27CZ63sP0q+_(U' 'pSf}Ja(9@9_2yxCyBZ@bI`IOBR=Dir^fPHSO_{JX8jThkSDyxz`{38~M^$O^P>`BYS4E%K@wl!{;r^>%#P|>6cyy6}=K2Sm0PFFe' 'm9L+|2cdipP(?f^sw+!ESQ)4XCkw%*bC=b;)o-r~!GoB`;W0`;tHJakds0TJeP4=gYp0#E8qmfBu(dc(IlNRCGl=}z)qRQLrjMCn' '(+(1w%m56XXnv9E=W~|<$q@WupBy^w7ZHg=Kq*$DbowA3mCF8tb?rN#>GDA((4x-C(JWeXixnT1Zn3?H_uTP2%9EJprJ5(m)W??l>7gtz7w%41h^q}ze' 'X{q@g^VKaaO^QYoR$<1#cXtOqRF54QpDisVS{$J=(Z>ztL1aZzV6=u&Yrh@LL@)W3LA|EYl2sht&CQl?Txp@*5JJhjui&O&@sv+' '?nj+K0JC~Q%IXP|H{#yDjEdD_OTQy%PW`SW>1Qb(^-=#NzqEM#u)~0?+Ct1l*5V2FdPum!p1`@lAG+7#{~kX;zupd8`6SUmQJGIu' 'TvGglaZc>EEV>MOwqBC=PaE#4y~KGF0l6-xyZY2qyl|4H3$X$#L0?8hIKSo0XM+&H^NvAHCH|61jPert6L`bScpN-7mR&W2a&GDV*>CPQyOH+6??L@58nb>k)i9YJy5wKI|#lS' 'zxNZavmxdOqTpF|p2nSkmtc|}0Nk46Uh52l+smE7chTSUvKcM4!O^?W_*y$SkGKrSiT9kjVrooHgS9o=dnZ7?YdMC}~Qo~%IrqUs9>' 'r9BL2qF!+McN*WLKrM#o1YDjUc;+FPLhPFHpe|D`SLF{M(w4L7M5chrY=pY5AvOBxdG2qxwRqHjy5bu@Hgh5xYrxBUmLfKA;6$F#5ivSv0DX9`5L~m7(W6fPN!Xc@@-sj<3q#-9yH6Ai3xB6LY|SJ&PEj8D%fiT~g9t+0&tQKz3Kkc3ip({!+;n}cDRORSRP=^Wv6fg++%Sh4Im5J?@' '(wjA<4ww&Qvlyo^x;@~S4ac~JpGw>kCwZ$f%Tw8<#=IGB#3g-Cjn8J)eb}THlI?H-7z2KIM9k}Q7@_h~&)$r*bgYBUQLu)C?_o@s' '?@hLOg??iWcUG+Enkwaks4{FmS85-=(}FivKOTqt_ZUTOE}P~7*84uI-)rY4W}^=#`$eaaK8|G=pqf%gJ8Wd*u*vdo4hXn^f6Ww_' 'l2oM&OO!(iChuI!fKH+br*Je>aO^t^O_FQwz^A5lKXAv#SE9HRnB' 'M^ckrWl8*Z-hO)tP4tA&jP%`81PDws$WXkaoUnj%Lw;CL{l?`=%5cz2gLXJsF{nZq4U7efkFc|doQ7NYZHYy85!{;dwayE|3p~cRb0xEtubuNsukY_b%P6|Nd#Q' '06IwEki9HP@B?(AzT4z&UDjs&o{12$+AfB$6bQtzhCUttBGb&PuBz3t5Fov*%$HxdZ!pu`+>%KM+B!s;`2GRB8Odd`+12JNKPT1wsnHJAB%>uD>QkHQ5' 'm%wk;abUhChCRa|>?*Jih_y7nbAHXu`bYSwbudSWd_(prR7Of}AX)h> (32 - n))) & 0xFFFFFFFF for off in range(0, len(data), 64): block = data[off:off + 64] w = [int.from_bytes(block[i:i + 4], "big") for i in range(0, 64, 4)] for j in range(16, 68): x = w[j - 16] ^ w[j - 9] ^ rol32(w[j - 3], 15) w.append((x ^ rol32(x, 15) ^ rol32(x, 23) ^ rol32(w[j - 13], 7) ^ w[j - 6]) & 0xFFFFFFFF) w1 = [w[j] ^ w[j + 4] for j in range(64)] a, b, c, d, e, f, g, h = iv for j in range(64): tj = 0x79CC4519 if j < 16 else 0x7A879D8A ss1 = rol32((rol32(a, 12) + e + rol32(tj, j % 32)) & 0xFFFFFFFF, 7) ss2 = ss1 ^ rol32(a, 12) ff = a ^ b ^ c if j < 16 else (a & b) | (a & c) | (b & c) gg = e ^ f ^ g if j < 16 else (e & f) | ((~e) & g) tt1 = (ff + d + ss2 + w1[j]) & 0xFFFFFFFF tt2 = (gg + h + ss1 + w[j]) & 0xFFFFFFFF d, c, b, a = c, rol32(b, 9), a, tt1 h, g, f, e = g, rol32(f, 19), e, (tt2 ^ rol32(tt2, 9) ^ rol32(tt2, 17)) & 0xFFFFFFFF iv = [(x ^ y) & 0xFFFFFFFF for x, y in zip(iv, (a, b, c, d, e, f, g, h))] return b"".join(x.to_bytes(4, "big") for x in iv) xtime = lambda a: (((a << 1) ^ 0x1B) & 0xFF) if (a & 0x80) else (a << 1) def rol(num, shift): shift %= 32 # Perform the left rotation return ((num << shift) | (num >> (32 - shift))) & 0xFFFFFFFF def rl8(x: int, k: int) -> int: n = 8 s = k & (n - 1) return ((x << s) | (x >> (n - s))) & 0xff def ror32(value, count): count %= 32 low = value << (32 - count) value >>= count value |= low value &= 0xFFFFFFFF return value def ror(value, count): count %= 64 low = value << (64 - count) value >>= count value |= low value &= 0xFFFFFFFFFFFFFFFF return value def get_key_hash(key, rand): to_hash = bytearray(68) to_hash[:32] = key to_hash[32:36] = rand.to_bytes(4, byteorder='little') to_hash[36:] = key d1 = (rand >> 16) & 0x000000ff d2 = (d1 << 11) | (rand >> 24) d2 ^= (d1 >> 5) ^ d1 d2 = ~d2 & 0xffffffff return SM3(to_hash).digest(), d2.to_bytes(4, "little") def split_blocks(message, block_size=16, require_padding=True): assert len(message) % block_size == 0 or not require_padding return [message[i:i + 16] for i in range(0, len(message), block_size)] def add_round_key(s, k): for i in range(4): for j in range(4): s[i][j] ^= k[i][j] def add_round_key_con(s, k, con): for i in range(4): for j in range(4): s[i][j] ^= k[i][con[j]] def bytes2matrix(text): """ Converts a 16-byte array into a 4x4 matrix. """ return [list(text[i:i + 4]) for i in range(0, len(text), 4)] def xor_bytes(a, b): """ Returns a new byte array with the elements xor'ed. """ return bytearray(i ^ j for i, j in zip(a, b)) def matrix2bytes(matrix): """ Converts a 4x4 matrix into a 16-byte array. """ return bytearray(sum(matrix, [])) def mix_single_column(a, i): t = a[0][i] ^ a[1][i] ^ a[2][i] ^ a[3][i] u = a[0][i] a[0][i] ^= t ^ xtime(a[0][i] ^ a[1][i]) a[1][i] ^= t ^ xtime(a[1][i] ^ a[2][i]) a[2][i] ^= t ^ xtime(a[2][i] ^ a[3][i]) a[3][i] ^= t ^ xtime(a[3][i] ^ u) def mix_columns(s): for i in range(4): mix_single_column(s, i) def inv_mix_columns(s): for i in range(0, 4): inv_mix_single_column(s, i) def inv_mix_single_column(a, i): u = xtime(xtime(a[0][i] ^ a[2][i])) v = xtime(xtime(a[1][i] ^ a[3][i])) a[0][i] ^= u a[1][i] ^= v a[2][i] ^= u a[3][i] ^= v mix_single_column(a, i) s_box = b''.join([ b'\xFA\x7D\x08\x6B\x9C\x59\xB3\x4B\x04\x5F\x39\xD0\x38\x4A\x91\x99', b'\x00\x67\xA6\x20\x9F\xF5\x4D\x82\x73\x26\xEE\xDF\x18\x66\x83\x33', b'\x80\x03\x19\xFB\xD9\xFE\xAE\xAA\xA9\xB0\x52\xC6\x0B\xF3\x79\x25', b'\x4E\x78\xB4\x36\xAC\x5D\x1A\x27\x9E\x88\xDB\xBD\x3C\x63\xEC\x49', b'\x15\xC1\x30\x1F\xDC\xB8\x56\xD4\x6C\xCD\xCA\x09\x43\xC8\x35\xA3', b'\xEF\x1E\xF4\x96\xD2\xFC\x0E\x72\x7B\x94\x84\xD1\xEA\x45\x5A\x62', b'\x02\x3F\xD3\x12\x81\x34\x2B\xDD\x7E\xE6\x28\xF2\xA5\x46\x13\x01', b'\x3B\x21\xF6\x61\x37\x29\x2A\x0D\xED\x8C\xAF\xBF\x9D\x5C\xBB\x24', b'\x76\x0F\x75\xE4\x53\x89\xE1\x98\x8D\xB1\x9A\x65\x70\x4F\x54\x4C', b'\x58\xAB\x6E\x6F\x8B\x23\xC4\x07\x11\x0C\xBA\xCF\xA0\xA4\x8E\xD8', b'\x05\x3D\x14\xB2\xDA\x74\xC3\xD7\xE7\xBE\xD6\x7F\xDE\x48\x16\x3E', b'\x85\x90\xA1\x55\xB7\x77\x42\x22\xC9\x86\x50\x2E\x17\xF9\x64\x31', b'\x2C\x9B\xF1\x6D\x1C\x44\x68\xE3\xE9\xA8\x93\x97\xCB\x32\x57\xEB', b'\xE5\x71\x6A\xAD\xC0\xCC\xC7\xC5\xFD\x60\x1D\xA2\x2D\x47\xA7\xE2', b'\x51\x69\x5E\x7A\xCE\x0A\x41\xB6\x95\x8F\xF7\xB9\x87\xE0\x3A\x06', b'\x10\x8A\xB5\xF8\x5B\xD5\xF0\xBC\x92\xFF\x7C\x2F\xC2\xE8\x1B\x40', b'\xEC\x1B\xDA\xBD\xBA\x98\x91\x0C\xB2\x2B\x83\x41\x34\x67\xFB\x0A', b'\xD8\x76\xB5\x46\x05\x59\x61\x23\x75\x90\x87\x2A\xE3\x50\x15\x4C', b'\xAC\xB1\x79\xEB\xAE\xE5\x95\x47\x04\x68\xF0\x86\x3D\x51\x8B\x0F', b'\xCA\x8E\xE4\xB9\x4E\xF2\x12\x82\xBC\x0E\xD5\xF7\xEF\x28\x25\xCF', b'\x5B\x5D\xE9\x6A\x55\x02\xE1\x33\xBE\x93\xE7\xF5\xAD\x9D\x3E\x39', b'\x24\xA8\xE2\xFA\x17\x57\xD0\x7A\x0D\x08\x30\xD6\xB8\xA3\x8D\xFD', b'\x07\x9A\xC4\x1E\x6E\x22\x64\x97\xD2\x1D\xB0\xBF\x45\x66\x3F\x6C', b'\xDD\xDB\x27\x80\xA7\x11\xDC\xA6\xC5\x52\xF8\xC0\xB6\xC8\x5C\x00', b'\x73\x60\x7B\xA0\x19\x13\xAA\xC9\x35\x48\x4B\xD3\xA4\xCD\x9F\x99', b'\xF3\x10\x44\x40\x54\x7E\x29\xF4\x06\x1F\xA2\xAB\xA1\x2F\x3C\xF6', b'\xAF\x85\x62\x36\x21\x7F\x5E\xDF\x20\x1A\xB3\xB4\xE6\xFF\x72\x84', b'\x8F\x65\x26\x94\x5A\x77\xEA\x43\x78\xC7\x4A\xCC\x2C\x14\x6B\xC6', b'\xE8\x74\x53\xFC\xD4\x1C\xCE\x31\x70\x03\x18\x8C\x96\x38\x32\x89', b'\xF1\x3A\x5F\xD7\xF9\xA9\x69\xB7\x63\x37\x58\xC2\x3B\xC3\x71\xCB', b'\x9E\x92\x01\x8A\x0B\x4D\x88\x9B\xBB\x4F\x6D\x6F\xE0\xFE\xA5\x49', b'\xDE\x56\x16\x09\xED\x9C\xC1\x2D\xEE\x81\x7D\xD9\x7C\xD1\x2E\x42', b'\x5B\x4D\xC1\xA6\x5D\xEA\x44\xFD\x45\x4E\x1B\xA1\x3F\xD1\x89\xE1', b'\x7D\x2F\xAA\xDB\xAB\xAD\x59\xCB\xB1\xCE\x9A\x28\xC9\xE0\xF6\x70', b'\x39\x4A\xD7\xFF\x30\xF5\xDD\xBC\x57\x3B\x11\x8D\xB2\xEE\x00\xB6', b'\xE6\x1A\x5A\x7C\xF9\xDE\xC4\xCD\x2E\x80\xBB\xB9\x4C\xA5\x9F\x84', b'\x08\xC6\x6F\x42\x6C\xF0\x27\xE7\x8B\x3A\x9C\x51\xFB\x67\x21\x75', b'\x41\x31\xA7\xCA\x20\x43\x2A\xB7\xBF\xD9\x7A\xF2\xB5\xF8\x8C\x2C', b'\x23\x83\x4F\x8F\x60\xA0\x04\x13\x37\x14\xE3\x01\xC5\x63\x66\x5C', b'\x74\x81\xDF\x58\xBD\x68\x90\x3D\xD2\xB3\x34\xF4\x19\x93\x32\x29', b'\xD6\x49\xAE\x0D\x4B\xD8\x07\x9E\xAC\x1E\x2D\x0B\x40\xB8\x72\xBA', b'\x76\x10\x71\xA8\xE4\x56\x1D\x48\xFE\xE5\xC2\x47\x91\xDA\x87\x26', b'\x9D\x1F\x88\x6B\xC0\x98\xBE\x25\x09\x97\x33\xA3\x85\x16\x5E\x7F', b'\xDC\x6E\x54\xE9\xF7\xA9\xC8\xE8\xC3\x77\xD0\x82\x2B\xEC\x02\x62', b'\x8A\x92\x0E\x3E\xB0\x0F\x05\xF3\xF1\x96\x78\x38\x86\x36\x18\x3C', b'\x24\xCF\x0A\xB4\x53\xCC\x61\x65\xA4\xC7\x94\xD5\x15\x7E\x6D\xEF', b'\x79\x22\x35\x12\x6A\x8E\x52\x06\x55\x7B\x46\x64\x50\x95\xE2\x0C', b'\xED\xD3\x17\x03\xA2\x9B\x99\xEB\x1C\xFC\xAF\xD4\x73\x69\xFA\x5F', b'\xF7\x2C\x1E\xBF\xC8\xE1\xF3\x9F\x76\x80\x71\x48\xAA\x94\xAD\x64', b'\xFB\x89\xC6\x60\xC3\x32\xB3\x4D\xD2\xE0\x44\xDD\x5F\xA8\xB1\xC7', b'\x68\x23\x34\xC9\x6D\x12\x7F\xB7\xEB\x15\xBE\xA9\xD1\x78\x93\xA0', b'\x0C\x92\xA4\xD7\x47\xE3\x8A\xC2\x70\xAB\x26\x41\x9A\x79\xA7\xD8', b'\x14\x85\x8F\xC0\x6F\x56\xD0\x8C\x11\xB9\x2E\x3C\xE2\x9D\xCF\x0E', b'\xDE\x03\x5D\x46\x3E\xCD\x38\x43\x0F\x33\x5A\xD9\x1A\x65\x6C\x22', b'\x3B\xFC\x30\xA6\x88\xEA\x37\xA2\xB4\x8D\x8E\x51\x9C\xD6\x40\xEE', b'\xF9\xF8\x84\xF4\xAE\x97\xE9\xCA\x0A\x45\x67\x57\x04\x2F\x83\x5C', b'\xD5\xC5\xC4\x82\xB6\xA3\x91\x98\x1F\x4A\xAC\x96\x81\x6E\xCB\x1B', b'\x09\x08\xAF\x18\x95\x49\x7D\x54\xED\xFA\x16\x31\x3A\xDA\xB8\x66', b'\xF5\xA5\xF1\xFE\x10\x01\x06\x74\xCC\x63\xDF\x7C\x28\x25\xF6\xCE', b'\xB2\x4F\x8B\xE5\xBC\x87\x69\xBB\x86\x21\x07\x00\x36\xE7\x0B\x50', b'\x59\x9B\x1C\xE8\x62\x58\x19\x61\xF2\xBD\x27\x5E\xBA\x1D\xE6\x99', b'\x42\x3D\x0D\x2A\xB5\xDC\x5B\x29\xF0\x2D\x4C\x53\x7B\x6A\x73\x4E', b'\x3F\x75\xFF\x4B\xA1\x35\x17\x55\x72\x39\x20\xD3\xB0\xFD\xEF\x02', b'\xEC\x77\x7E\xE4\x2B\xDB\x90\xC1\x05\x9E\x7A\xD4\x52\x6B\x24\x13']) inv_s_box = bytearray(1024) class AES_V3(): r_con = [[1, 0, 2, 3], [1, 3, 0, 2], [0, 1, 3, 2], [1, 0, 2, 3]] r_con2 = [[1, 0, 2, 3], [2, 0, 3, 1], [0, 1, 3, 2], [1, 0, 2, 3]] r_orders = [[0, 9, 14, 11, 4, 13, 2, 7, 8, 1, 6, 15, 12, 5, 10, 3], [0, 9, 14, 15, 4, 13, 2, 7, 8, 1, 6, 3, 12, 5, 10, 11], [0, 9, 14, 7, 4, 13, 2, 11, 8, 1, 6, 3, 12, 5, 10, 15], [0, 9, 14, 11, 4, 13, 2, 7, 8, 1, 6, 15, 12, 5, 10, 3]] def __init__(self, aes_key, khronos): self.word_size = khronos & 3 # khronos - (khronos & -4) self.aes_key = aes_key self.s_box = s_box[self.word_size << 8:] self.inv_s_box = inv_s_box[self.word_size << 8:] self.master_key = self._expand_key() self._key_matrices = bytes2matrix(self.master_key) self.con = self.r_con[self.word_size] self.con2 = self.r_con2[self.word_size] self.order = self.r_orders[self.word_size] def _expand_key(self): init_values = [0xca025ddc, 0x823dc546, 0xc9420583, 0xc298225f] init_value = init_values[self.word_size] mk = bytearray(init_value.to_bytes(4, "little")) mk = mk * 4 mk = xor_bytes(mk, self.aes_key) mk += bytearray(32) rounds = 8 for i in range(4, 12): idx = 4 * (i - 1) k0, k1, k2, k3 = mk[idx], mk[idx + 1], mk[idx + 2], mk[idx + 3] if i & 3 == 0: k00 = (init_value >> (rounds & 24)) ^ self.s_box[k1] k1 = self.s_box[k2] k2 = self.s_box[k3] k3 = self.s_box[k0] k0 = k00 & 0xff rounds += 2 mk[idx + 4] = k0 ^ mk[idx - 12] mk[idx + 5] = k1 ^ mk[idx - 11] mk[idx + 6] = k2 ^ mk[idx - 10] mk[idx + 7] = k3 ^ mk[idx - 9] return mk @staticmethod def sum_data(data): key = bytearray(32) for i in range(31): idx = i * 8 n0 = (data[idx] >> 4) & 2 n1 = n0 | data[idx + 1] & 64 n2 = n1 | (data[idx + 2] >> 2) & 1 n3 = n2 | (data[idx + 3] << 3) & -128 n4 = n3 | (data[idx + 4] >> 1) & 4 n5 = n4 | (data[idx + 5] << 3) & 16 n6 = n5 | (data[idx + 6] << 5) & 32 n7 = n6 | (data[idx + 7] >> 4) & 8 key[i] = (n7 & 0xff) key[31] = 1 return key @staticmethod def mix_columns(data, key): data = bytearray(data) for i in range(31): kk = key[i] idx = i * 8 # print(k, data[idx + 1], (data[idx + 1] & -65) | (k & 64)) data[idx + 0] = (data[idx + 0] & -33) | ((kk << 4) & 0xff & 32) data[idx + 1] = (data[idx + 1] & -65) | (kk & 64) data[idx + 2] = (data[idx + 2] & -5) | ((kk * 4) & 4) data[idx + 3] = (data[idx + 3] & -17) | ((kk >> 3) & 16) data[idx + 4] = (data[idx + 4] & -9) | ((kk + kk) & 8) data[idx + 5] = (data[idx + 5] & -3) | ((kk >> 3) & 2) data[idx + 6] = (data[idx + 6] & -2) | ((kk >> 5) & 1) data[idx + 7] = (data[idx + 7] & 127) | ((kk << 4) & 0xff & -128) return data def encrypt(self, data, iv): plaintext = self.sum_data(data) blocks = [] previous = iv for plaintext_block in split_blocks(plaintext): x = xor_bytes(plaintext_block, previous) block = self.encrypt_block(x) blocks.append(block) previous = block key = b''.join(blocks) # key = bytes.fromhex('a22c23b05bb4a831d31bbdbd1327c5f84991bca3e7d8df24e52f58b7ac61f2e0') # print("sign_key", key.hex()) data = self.mix_columns(data, key) return key[-1:] + data def encrypt_block(self, plaintext): # print("b000", plaintext.hex()) plain_state = bytes2matrix(plaintext) add_round_key_con(plain_state, self._key_matrices[0:4], self.con2) # print("b001", matrix2bytes(plain_state).hex()) for i in range(1, 3): self.sub_bytes(plain_state) # print("b003", matrix2bytes(plain_state).hex()) self.shift_rows(plain_state) # print("b004", matrix2bytes(plain_state).hex()) if i == 1: self.shift_rows_con(plain_state, self.con2) mix_columns(plain_state) add_round_key_con(plain_state, self._key_matrices[i * 4:], self.con2) add_round_key(plain_state, self._key_matrices[4:]) return matrix2bytes(plain_state) def decrypt(self, ciphertext, iv, data): assert len(iv) == 16 blocks = [] previous = iv for ciphertext_block in split_blocks(ciphertext): dc = xor_bytes(previous, self.decrypt_block(ciphertext_block)) # dc = matrix2bytes(dcm) blocks.append(dc) previous = ciphertext_block key = b''.join(blocks) # print("sign_key", key.hex()) data = self.mix_columns(data, key) return data def decrypt_block(self, ciphertext): assert len(ciphertext) == 16 cipher_state = bytes2matrix(ciphertext) # print("b000", matrix2bytes(cipher_state).hex()) add_round_key(cipher_state, self._key_matrices[4:]) # print("b001", matrix2bytes(cipher_state).hex()) for i in range(2, 0, -1): add_round_key_con(cipher_state, self._key_matrices[i * 4:], self.con2) # print("b002", i, matrix2bytes(cipher_state).hex()) if i == 1: inv_mix_columns(cipher_state) self.shift_rows_con(cipher_state, self.con) self.inv_shift_rows(cipher_state) # print("b004", i, matrix2bytes(cipher_state).hex()) self.inv_sub_bytes(cipher_state) # print("b005", i, matrix2bytes(cipher_state).hex()) add_round_key_con(cipher_state, self._key_matrices[0:4], self.con2) return matrix2bytes(cipher_state) def shift_rows_con(self, s, c): for i in range(4): # c = self.con s[i][0], s[i][1], s[i][2], s[i][3] = s[i][c[0]], s[i][c[1]], s[i][c[2]], s[i][c[3]] def shift_rows(self, s): bs = matrix2bytes(s) for i in range(4): for j in range(4): s[i][j] = bs[self.order[i * 4 + j]] def inv_shift_rows(self, s): order = bytearray(16) for i in range(16): order[self.order[i]] = i bs = matrix2bytes(s) for i in range(4): for j in range(4): s[i][j] = bs[order[i * 4 + j]] def sub_bytes(self, s): for i in range(4): for j in range(4): s[i][j] = self.s_box[s[i][j]] s[0], s[1], s[2], s[3] = s[self.con2[0]], s[self.con2[1]], s[self.con2[2]], s[self.con2[3]] def inv_sub_bytes(self, s): for i in range(4): for j in range(4): s[i][j] = self.inv_s_box[s[i][j]] s[0], s[1], s[2], s[3] = s[self.con[0]], s[self.con[1]], s[self.con[2]], s[self.con[3]] def leftCircularShift(k, bits): bits = bits % 32 k = k % (2 ** 32) upper = (k << bits) % (2 ** 32) result = upper | (k >> (32 - (bits))) return (result) def blockDivide(block, chunks): result = [] size = len(block) // chunks for i in range(0, chunks): result.append(int.from_bytes(block[i * size:(i + 1) * size], byteorder="little")) return (result) def F(X, Y, Z): return ((X & Y) | ((~X) & Z)) def G(X, Y, Z): return ((X & Z) | (Y & (~Z))) def H(X, Y, Z): return (X ^ Y ^ Z) def I(X, Y, Z): return (Y ^ (X | (~Z))) & 0xffffffff def FF(a, b, c, d, M, s, t): result = b + leftCircularShift((a + F(b, c, d) + M + t), s) return (result) def GG(a, b, c, d, M, s, t): result = b + leftCircularShift((a + G(b, c, d) + M + t), s) return (result) def HH(a, b, c, d, M, s, t): result = b + leftCircularShift((a + H(b, c, d) + M + t), s) return (result) def II(a, b, c, d, M, s, t): result = b + leftCircularShift((a + I(b, c, d) + M + t), s) return (result) def sum_md5(data): check_sum = 0x20220420 for i in range(12): if i % 2 == 0: temp = (check_sum >> 3) ^ check_sum check_sum = data[i] ^ (check_sum << 7) else: temp = (check_sum >> 5) ^ check_sum check_sum = data[i] | (check_sum << 11) check_sum ^= 0xffffffff check_sum ^= temp check_sum &= 0xffffffff check_sum |= 4 check_sum ^= 0x1000000 return check_sum SV2 = [0xa7aefe20, 0x7149f1d6, 0x47e4ca07, 0xe9b58f67, 0x93b924de, 0xc614d0f5, 0x38afe0ef, 0xb2bbad73, 0xe24444c3, 0x9d3aec9b, 0xdf7b37e4, 0xd8b16d40, 0xf8ac31b8, 0x76b9a90b, 0x31d833ee, 0x953fce64, 0x353595a4, 0x4609c13b, 0x36925008, 0x8c6d0925, 0x5df5c177, 0x1cfbf52b, 0x8a4fa7f0, 0x114ca35e, 0x8193f984, 0x7a7a8733, 0x316ab4d5, 0x3c20cfc9, 0xa6d84453, 0x3a18500c, 0x798ec47a, 0x97a76b28, 0x66c4ff96, 0x51716443, 0xdd2fc3b, 0xb5696da7, 0xbbeb3ac5, 0x5c53d204, 0xd32608ce, 0x7279b9ec, 0xf4188ecf, 0xf7d793db, 0x332cc491, 0xab76ae15, 0x9bebe727, 0x18a01384, 0x5be9f8a7, 0x5f90a754, 0x39b663c0, 0x36673c83, 0x7c92f514, 0x9d7d94d7, 0xe2e8d9aa, 0x5f7e9ea9, 0x7abd4551, 0x569e05da, 0x40a25632, 0x3df5a9a5, 0xbab37d80, 0x454286dc, 0x3f5d4e78, 0x3d7b75d, 0xb1fe4af7, 0xa5ab26a3] def md5sum_v3(msg, count_v2, orders, count_v1, n=0): count = count_v2 & 0xff sv = [0] * 64 for i in range(64): sv[i] = ror32(SV2[i], count_v1) start = [ ror32(0x79e0f2fb, count), ror32(0xc8b52570, count), ror32(0xebc2f8cd, count), ror32(0x7c104d93, count) ] count = (count_v2 + 6) & 0xff end = [ ror32(0x19be4866, count), ror32(0xe85986b4, count), ror32(0xe19b326e, count), ror32(0x71d1d7d4, count) ] A = start[0] # 0x79e0f2fb B = start[1] # 0xc8b52570 C = start[2] # 0xebc2f8cd D = start[3] # 0x7c104d93 a = A b = B c = C d = D block = msg[:64] M = blockDivide(block, 16) order1 = orders[:16] order2 = orders[16:32] order3 = orders[32:48] order4 = orders[48:] # Rounds a = FF(a, b, c, d, M[order1[0]], 7, sv[0]) d = FF(d, a, b, c, M[order1[1]], 12, sv[1]) # 0xb6bc6ddb c = FF(c, d, a, b, M[order1[2]], 17, sv[2]) # 0xf80b15d4 b = FF(b, c, d, a, M[order1[3]], 22, sv[3]) a = FF(a, b, c, d, M[order1[4]], 7, sv[4]) d = FF(d, a, b, c, M[order1[5]], 12, sv[5]) c = FF(c, d, a, b, M[order1[6]], 17, sv[6]) b = FF(b, c, d, a, M[order1[7]], 22, sv[7]) a = FF(a, b, c, d, M[order1[8]], 7, sv[8]) d = FF(d, a, b, c, M[order1[9]], 12, sv[9]) c = FF(c, d, a, b, M[order1[10]], 17, sv[10]) b = FF(b, c, d, a, M[order1[11]], 22, sv[11]) a = FF(a, b, c, d, M[order1[12]], 7, sv[12]) d = FF(d, a, b, c, M[order1[13]], 12, sv[13]) c = FF(c, d, a, b, M[order1[14]], 17, sv[14]) b = FF(b, c, d, a, M[order1[15]], 22, sv[15]) a = GG(a, b, c, d, M[order2[0]], 5, sv[16]) d = GG(d, a, b, c, M[order2[1]], 9, sv[17]) c = GG(c, d, a, b, M[order2[2]], 14, sv[18]) b = GG(b, c, d, a, M[order2[3]], 20, sv[19]) a = GG(a, b, c, d, M[order2[4]], 5, sv[20]) d = GG(d, a, b, c, M[order2[5]], 9, sv[21]) c = GG(c, d, a, b, M[order2[6]], 14, sv[22]) b = GG(b, c, d, a, M[order2[7]], 20, sv[23]) a = GG(a, b, c, d, M[order2[8]], 5, sv[24]) d = GG(d, a, b, c, M[order2[9]], 9, sv[25]) c = GG(c, d, a, b, M[order2[10]], 14, sv[26]) b = GG(b, c, d, a, M[order2[11]], 20, sv[27]) a = GG(a, b, c, d, M[order2[12]], 5, sv[28]) d = GG(d, a, b, c, M[order2[13]], 9, sv[29]) c = GG(c, d, a, b, M[order2[14]], 14, sv[30]) b = GG(b, c, d, a, M[order2[15]], 20, sv[31]) a = HH(a, b, c, d, M[order3[0]], 4, sv[32]) d = HH(d, a, b, c, M[order3[1]], 11, sv[33]) c = HH(c, d, a, b, M[order3[2]], 16, sv[34]) b = HH(b, c, d, a, M[order3[3]], 23, sv[35]) a = HH(a, b, c, d, M[order3[4]], 4, sv[36]) d = HH(d, a, b, c, M[order3[5]], 11, sv[37]) c = HH(c, d, a, b, M[order3[6]], 16, sv[38]) b = HH(b, c, d, a, M[order3[7]], 23, sv[39]) a = HH(a, b, c, d, M[order3[8]], 4, sv[40]) d = HH(d, a, b, c, M[order3[9]], 11, sv[41]) c = HH(c, d, a, b, M[order3[10]], 16, sv[42]) b = HH(b, c, d, a, M[order3[11]], 23, sv[43]) a = HH(a, b, c, d, M[order3[12]], 4, sv[44]) d = HH(d, a, b, c, M[order3[13]], 11, sv[45]) c = HH(c, d, a, b, M[order3[14]], 16, sv[46]) b = HH(b, c, d, a, M[order3[15]], 23, sv[47]) a = II(a, b, c, d, M[order4[0]], 6, sv[48]) d = II(d, a, b, c, M[order4[1]], 10, sv[49]) c = II(c, d, a, b, M[order4[2]], 15, sv[50]) b = II(b, c, d, a, M[order4[3]], 21, sv[51]) a = II(a, b, c, d, M[order4[4]], 6, sv[52]) d = II(d, a, b, c, M[order4[5]], 10, sv[53]) c = II(c, d, a, b, M[order4[6]], 15, sv[54]) b = II(b, c, d, a, M[order4[7]], 21, sv[55]) a = II(a, b, c, d, M[order4[8]], 6, sv[56]) d = II(d, a, b, c, M[order4[9]], 10, sv[57]) c = II(c, d, a, b, M[order4[10]], 15, sv[58]) b = II(b, c, d, a, M[order4[11]], 21, sv[59]) a = II(a, b, c, d, M[order4[12]], 6, sv[60]) d = II(d, a, b, c, M[order4[13]], 10, sv[61]) c = II(c, d, a, b, M[order4[14]], 15, sv[62]) b = II(b, c, d, a, M[order4[15]], 21, sv[63]) A = (A + a) % (2 ** 32) ^ end[0] B = (B + b) % (2 ** 32) ^ end[1] C = (C + c) % (2 ** 32) ^ end[2] D = (D + d) % (2 ** 32) ^ end[3] result = bytearray( A.to_bytes(4, "little") + B.to_bytes(4, "little") + C.to_bytes(4, "little") + D.to_bytes(4, "little")) result += sum_md5(result).to_bytes(4, "little") return result def bxor(b1, b2): b3 = bytearray(len(b1)) for i in range(len(b1)): b3[i] = b1[i] ^ b2[i] return b3 def get_iv(iv, data): for i in range(len(data)): if i & 1 == 0: iv = (iv >> 4) ^ iv ^ (iv << 6) ^ data[i] else: iv = ~((iv >> 7) ^ iv ^ (data[i] | iv << 12)) iv = iv & 0xffffffff return iv def hash_f13(query_sm3, body_md5_bytes, ts_bytes, khronos): iv = get_iv(0x20230928, query_sm3) iv = get_iv(iv, body_md5_bytes) iv = get_iv(iv, ts_bytes) iv_v0 = ((iv & 15) * 171) >> 9 branch = (iv & 15) - ((iv_v0 * 3) & 0xff) if branch == 0: return branch_0(iv_v0, khronos, query_sm3, body_md5_bytes, ts_bytes) elif branch == 1: return branch_1(iv_v0, khronos, query_sm3, body_md5_bytes, ts_bytes) elif branch == 2: return branch_2(iv, khronos, query_sm3, body_md5_bytes, ts_bytes) else: raise Exception("no branch: " + str(branch)) def branch_0(iv_v0, khronos, query_sm3, body_md5_bytes, ts_bytes): tt01 = [0xc4a78580, 0xb3c0fd39, 0xc58c5686, 0xc9aa3ba7, 0xf5a7adf2, 0x963c2ed1] iv_v1 = tt01[iv_v0] count_v1 = (iv_v1 + khronos + 1) & 0xff count_v2 = (iv_v1 + khronos) & 0xffffffff tt02 = [0xebb64faf, 0x7aadcc2, 0xcf3187bf, 0xe01138ff, 0x6d0bfcff, 0x5a30a3be, 0xb41ad638, 0x34180eb8, 0xf233eb6f, 0xb1a584cc, 0xccc30dc7, 0x47d1db51, 0xd55653de, 0x70a84fa1, 0x57473c12, 0xf76f0288, 0x2c077f0a, 0xda0dcad0, 0xfbb86f6c, 0xfdc4cf00, 0x688a020d, 0xe676c6a6, 0x8cd6338b, 0x1a3c8d0e, 0xcce8b06b, 0x6ad0ed0b, 0xa0522717, 0xdc71ac83, 0x2285db71, 0xd5b4dda6, 0x736f8650, 0x6560306c, 0x617ce2a6, 0xe423417e, 0xa40e143, 0x544e4032, 0x88dffb2a, 0x716c1ae0, 0x4c467a88, 0x5b23bb3, 0xe1d0b866, 0xbaa3dcb8, 0xae3374d3, 0xc3381a50, 0x1702f75b, 0xfe6da368, 0xf0b4cf48, 0x4e0ffbb8, 0x72aad10d, 0x26c53a3d, 0xf2bce0f6, 0xb4557581, 0x4a257fdd, 0x8c3182a2, 0xab0b3b86, 0x3d5dfb14, 0x4f103634, 0xd37b52d7, 0x444eff16, 0xeb0a33d1, 0x6ca86f6e, 0x284ba7, 0x8387cfa, 0x5fb37586] tt03 = [0] * 64 for i in range(0, 64): tt03[i] = ror32(tt02[i], count_v1) & 0xffffffff n0 = (count_v2 + 2) & 7 pad = bytearray(4) seed = bytes([0xfa, 0x45, 0x61, 0xd7]) for i in range(4): v = int.from_bytes(bytes([seed[i], seed[i]]), 'little') v = v >> n0 pad[i] = v & 0xff count_v2 = count_v2 & 0xff init_value = [ ror32(0x7aba4fc8, count_v2), ror32(0x67166507, count_v2), ror32(0x6403fa00, count_v2), ror32(0x340f512f, count_v2), ror32(984304912, count_v2), ror32(3005047866, count_v2), ror32(2874125293, count_v2), ror32(2152413264, count_v2) ] data = query_sm3 + body_md5_bytes + ts_bytes + pad + bytes.fromhex(' 00 00 00 00 00 00 01 a0') di = [0] * (len(data) // 4) for i in range(len(data) // 4): di[i] = int.from_bytes(data[i * 4:i * 4 + 4], "big") di0 = di[0] for i in range(112): di1, di14 = di[i + 1], di[i + 14] r_di1 = rol(di1, 14) ^ rol(di1, 25) ^ (di1 >> 3) r_di2 = rol(di14, 13) ^ rol(di14, 15) ^ (di14 >> 10) di0 = di0 + di[i + 9] + r_di1 + r_di2 di.append(di0 & 0xffffffff) di0 = di1 if iv_v0 == 5: v_j = branch0_xor(init_value, iv_v1, di, tt03, 100, 2, 0, 3, 5, 4, 6, 7, 2, 1, 5) elif iv_v0 == 4: v_j = branch0_xor(init_value, iv_v1, di, tt03, 96, 0, 5, 6, 7, 3, 1, 2, 5, 4, 4) elif iv_v0 == 3: v_j = branch0_xor(init_value, iv_v1, di, tt03, 99, 3, 6, 2, 4, 5, 1, 0, 0, 7, 6) elif iv_v0 == 2: v_j = branch0_xor(init_value, iv_v1, di, tt03, 96, 7, 6, 2, 1, 4, 0, 5, 4, 3, 5) elif iv_v0 == 1: v_j = branch0_xor(init_value, iv_v1, di, tt03, 96, 0, 6, 7, 5, 3, 2, 1, 5, 4, 4) elif iv_v0 == 0: v_j = branch0_xor(init_value, iv_v1, di, tt03, 101, 5, 7, 6, 3, 2, 1, 0, 5, 4, 3) ret = bytearray(32) for i in range(8): ret[i * 4:i * 4 + 4] = ((v_j[i] + init_value[i]) & 0xffffffff).to_bytes(4, 'big') ret = bxor(ret[:16], ret[16:]) sum = sum_md5(ret) ret += sum.to_bytes(4, "little") return ret def swap_v0(src, src_xor, tt2, table_f, order1, typ=None): da0 = [0] * 8 ha0 = src_xor[:] for i in range(8): da0[i] = src[order1[i]] ^ src_xor[i] for round in range(10): rr_0 = r00(ha0[0], ha0[1], ha0[2], ha0[3], ha0[4], ha0[5], ha0[6], ha0[7], 0, table_f) rr_1 = r00(ha0[1], ha0[2], ha0[3], ha0[4], ha0[5], ha0[6], ha0[7], ha0[0], 0, table_f) rr_2 = r00(ha0[2], ha0[3], ha0[4], ha0[5], ha0[6], ha0[7], ha0[0], ha0[1], 0, table_f) rr_3 = r00(ha0[3], ha0[4], ha0[5], ha0[6], ha0[7], ha0[0], ha0[1], ha0[2], 0, table_f) rr_4 = r00(ha0[4], ha0[5], ha0[6], ha0[7], ha0[0], ha0[1], ha0[2], ha0[3], 0, table_f) rr_5 = r00(ha0[5], ha0[6], ha0[7], ha0[0], ha0[1], ha0[2], ha0[3], ha0[4], 0, table_f) rr_6 = r00(ha0[6], ha0[7], ha0[0], ha0[1], ha0[2], ha0[3], ha0[4], ha0[5], 0, table_f) rr_7 = r00(ha0[7], ha0[0], ha0[1], ha0[2], ha0[3], ha0[4], ha0[5], ha0[6], 0, table_f) rr_7 = rr_7 ^ tt2[round + 1] d0, d1, d2, d3, d4, d5, d6, d7 = da0[0], da0[1], da0[2], da0[3], da0[4], da0[5], da0[6], da0[7] da0[0] = r00(d0, d1, d2, d3, d4, d5, d6, d7, rr_0, table_f) da0[1] = r00(d1, d2, d3, d4, d5, d6, d7, d0, rr_1, table_f) # 0xd0a489b35ba678e8 da0[2] = r00(d2, d3, d4, d5, d6, d7, d0, d1, rr_2, table_f) # 0x3be5b7f9cfd44654 da0[3] = r00(d3, d4, d5, d6, d7, d0, d1, d2, rr_3, table_f) da0[4] = r00(d4, d5, d6, d7, d0, d1, d2, d3, rr_4, table_f) da0[5] = r00(d5, d6, d7, d0, d1, d2, d3, d4, rr_5, table_f) da0[6] = r00(d6, d7, d0, d1, d2, d3, d4, d5, rr_6, table_f) da0[7] = r00(d7, d0, d1, d2, d3, d4, d5, d6, rr_7, table_f) ha0[0], ha0[1], ha0[2], ha0[3], ha0[4], ha0[5], ha0[6], ha0[7] = rr_0, rr_1, rr_2, rr_3, rr_4, rr_5, rr_6, rr_7 if typ is None: src[0] = da0[0] ^ src_xor[0] ^ src[0] src[1] = da0[7] ^ src_xor[1] ^ src[1] src[2] = da0[6] ^ src_xor[2] ^ src[2] src[3] = da0[5] ^ src_xor[3] ^ src[3] src[4] = da0[4] ^ src_xor[4] ^ src[4] src[5] = da0[3] ^ src_xor[5] ^ src[5] src[6] = da0[2] ^ src_xor[6] ^ src[6] src[7] = da0[1] ^ src_xor[7] ^ src[7] else: src[0] = da0[7] ^ typ[1] src[1] = da0[6] ^ typ[2] src[2] = da0[5] ^ typ[3] src[3] = da0[4] ^ typ[4] src[4] = da0[3] ^ typ[5] src[5] = da0[2] ^ typ[6] src[6] = da0[1] ^ typ[7] ^ src[7] src[7] = da0[0] ^ typ[0] return src def branch_1(iv_v0, khronos, query_sm3, body_md5_bytes, ts_bytes): tt1 = [0x808a9c79, 0xf079807e, 0xbadf79c5, 0xa785d3ff, 0x82d8438c] iv_v1 = tt1[iv_v0] c_v1 = (iv_v1 + khronos) & 0xff c_v1 = ror(khronos, c_v1) orders = bytes.fromhex('''05 07 01 02 04 00 06 03 00 05 02 04 01 03 07 06 05 07 02 04 01 06 03 00 03 00 02 04 06 07 01 05 04 05 00 03 06 02 01 07 00 00 00 00 00 00 00 00''') order1 = orders[iv_v0 * 8:iv_v0 * 8 + 8] iv_v1 = (iv_v1 + khronos + 1) & 63 tt1 = [0x87aeea5dab37cd6b, 0x7ff48becb4f54087, 0xb0724c06706bbd5d, 0x1fe5dfb1143e328d, 0x1a2331d00af4f1f2, 0xcaff7131bb1e71ba, 0x33385e1042752218, 0xff01ed65d4a441fb, 0xadb1ec8828c80e8, 0x62475d12f4e06fe7, 0xbd0b238da4fe72] tt2 = [0] * 11 for i in range(0, 11): tt2[i] = ror(tt1[i], iv_v1) to_sign = bytearray(query_sm3 + body_md5_bytes + ts_bytes + bytes([0x80, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0])) src = [0] * (len(to_sign) // 8) for i in range(len(to_sign) // 8): src[i] = int.from_bytes(to_sign[i * 8:i * 8 + 8], 'big') src_xor = [c_v1, c_v1, c_v1, c_v1, c_v1, c_v1, c_v1, c_v1] table_f = get_branch_1_table_f(iv_v0) swap = swap_v0(src, src_xor, tt2, table_f, order1) data = [0] * 8 data[7] = 416 src_xor = [swap[4], swap[3], swap[2], swap[1], swap[0], swap[7], swap[6], swap[5]] swap = swap_v0(data, src_xor, tt2, table_f, order1, swap) ret = bytearray(32) n = 0 for i in range(7, -1, -1): pp = swap[i].to_bytes(8, "little") ret[n + 0], ret[n + 1], ret[n + 2], ret[n + 3] = pp[1], pp[3], pp[5], pp[6] n += 4 for i in range(16): ret[i] ^= ret[i + 16] ret = ret[:16] sum = sum_md5(ret) ret += sum.to_bytes(4, "little") return ret def r00(r0, r1, r2, r3, r4, r5, r6, r7, tt, table_f, v=0): x = table_f(8 * (r0 >> 56)) r1 = (r1 >> 45) & 2040 if tt > 0: x = x ^ tt x = x ^ table_f(r1 + 2048) r2 = (r2 >> 37) & 2040 x = x ^ table_f(r2 + 4096) r3 = (r3 >> 29) & 2040 x = x ^ table_f(r3 + 6144) r4 = (r4 >> 21) & 2040 x = x ^ table_f(r4 + 8192) r5 = (r5 >> 13) & 2040 x = x ^ table_f(r5 + 10240) r6 = (r6 >> 8) & 255 x = x ^ table_f(8 * r6 + 12288) r7 = r7 & 255 x = x ^ table_f(8 * r7 + 14336) return x branch_2_orders = bytes.fromhex(''' 0f 07 04 00 09 08 03 0a 06 0b 05 0d 0e 01 0c 02 0f 05 08 0c 00 09 02 01 03 07 0e 06 0b 0a 0d 04 06 05 00 07 0c 00 0a 04 08 0f 01 0b 0d 09 02 0e 06 0b 02 05 04 03 08 01 01 07 0a 00 0d 0c 09 0e 0d 07 0e 0f 0b 02 08 03 0c 05 09 01 00 04 06 0a 0d 09 02 06 0f 0b 0a 04 08 07 00 0c 05 03 01 0e 0c 09 0f 07 06 0f 03 0e 02 0d 04 05 01 0b 0a 00 0c 05 0a 09 0e 08 02 04 04 07 03 0f 01 06 0b 00 0b 0f 04 08 02 0a 07 00 09 0d 06 01 0e 03 05 0c 0b 06 0a 05 08 02 0c 03 07 0f 0e 09 0d 00 01 04 09 06 08 0f 05 08 00 04 0a 0b 03 0d 01 02 0c 0e 09 0d 0c 06 04 07 0a 03 03 0f 00 08 01 05 02 0e 01 00 0d 0f 09 0a 0b 0e 04 02 08 07 03 06 0c 05 01 08 0a 0c 0f 09 05 06 0b 00 03 04 02 0e 07 0d 04 08 0f 00 0c 0f 0e 0d 0a 01 06 02 07 09 05 03 04 02 05 08 0d 0b 0a 06 06 00 0e 0f 07 0c 09 03 0a 08 04 0f 00 0b 01 06 0d 0c 07 09 03 0e 05 02 0a 07 0b 05 0f 00 02 0e 01 08 03 0d 0c 06 09 04 0d 07 0f 08 05 0f 06 04 0b 0a 0e 0c 09 00 02 03 0d 0c 02 07 04 01 0b 0e 0e 08 06 0f 09 05 00 03 ''') def branch_2(iv, khronos, query_sm3, body_md5_bytes, ts_bytes): n0 = (iv & 15 - 2) * 86 iv_v0 = (n0 >> 15 & 0xff) + (n0 >> 8 & 0xff) t001 = [0x8980f29b, 0xeb549c7f, 0xb08726db, 0xd40cb5e6, 0xe8f559e4] n1 = t001[iv_v0] count_v1 = (n1 + khronos + 1) & 0xff count_v2 = (n1 + khronos) & 0xffffffff n0 = (count_v2 + 5) & 7 pad = bytearray(8) seed = bytes([0x84, 0x96, 0x77, 0x9d, 0xd4, 0x15, 0x0b, 0xf8]) for i in range(8): v = int.from_bytes(bytes([seed[i], seed[i]]), 'little') v = v >> n0 pad[i] = v & 0xff data = query_sm3 + body_md5_bytes + ts_bytes + pad + bytes.fromhex('a0 01 00 00') idx = iv_v0 << 6 ret = md5sum_v3(data, count_v2, branch_2_orders[idx:idx + 64], count_v1) return ret def branch0_xor(data, base, di, tt03, round, x1, x2, x3, x4, x5, x6, x7, x8, x9, x10): d = data[:] for i in range(round): offset = base + i n0 = di[offset & 127] n1 = ((d[x3] ^ d[x4]) & d[x1]) ^ d[x3] n2 = rol(d[x1], 26) ^ rol(d[x1], 21) ^ rol(d[x1], 7) offset = offset & 63 n3 = tt03[offset] n4 = (n0 + n1 + n2 + n3 + d[x5]) & 0xffffffff n5 = rol(d[x2], 30) ^ rol(d[x2], 19) ^ rol(d[x2], 10) n6 = (d[x2] & d[x6]) | ((d[x2] | d[x6]) & d[x7]) n7 = n5 + n6 o = d[x9] d[0], d[1], d[2], d[3], d[4], d[5], d[6], d[7] = d[7], d[0], d[1], d[2], d[3], d[4], d[5], d[6] d[x10] = (n7 + n4) & 0xffffffff d[x8] = (o + n4) & 0xffffffff return d branch_1_table = None def get_branch_1_table_f(iv_v0): global branch_1_table if branch_1_table is None: branch_1_table = _branch_one_bytes() table = branch_1_table[iv_v0 << 14:] def table_f(x): return int.from_bytes(table[x:x + 8], 'little') return table_f def _varint(value: int) -> bytes: value = int(value) if value < 0: value &= (1 << 64) - 1 result = bytearray() while value > 0x7F: result.append((value & 0x7F) | 0x80) value >>= 7 result.append(value) return bytes(result) def _sint(value: int, bits: int) -> int: # 正式 protobuf 编码规则：正数不先截断到有符号范围； # 这对 Medusa.rand 等可能大于 2**31 的 sint32 字段很重要。 value = int(value) return (value << 1) if value >= 0 else (value << 1) ^ (~0) def _proto_field(field: int, value: Any, kind: str) -> bytes: if value in (None, "", b"", 0, 0.0, False): return b"" if kind == "sint32": return _varint((field << 3) | 0) + _varint(_sint(int(value), 32)) if kind == "sint64": return _varint((field << 3) | 0) + _varint(_sint(int(value), 64)) if kind == "float": return _varint((field << 3) | 5) + struct.pack(" bytes: return b"".join(_proto_field(field, value, kind) for field, value, kind in fields) def _encode_request() -> bytes: return _proto([ (1, 111, "sint32"), (2, 10, "sint32"), (3, 694367, "sint32"), (5, 586952199, "sint32"), ]) def _encode_device(device: Mapping[str, Any]) -> bytes: fields = [ (1, device.get("d1"), "sint32"), (2, device.get("collect_stat"), "sint32"), (3, device.get("aid"), "string"), (4, device.get("device_id"), "string"), (5, device.get("sec_device_token"), "string"), (6, device.get("app_version"), "string"), (7, device.get("battery"), "sint32"), (8, device.get("battery2"), "sint32"), (9, device.get("battery_health"), "sint32"), (10, device.get("battery_changed"), "sint32"), (11, device.get("network"), "string"), (12, device.get("tz"), "string"), (13, device.get("lan"), "string"), (14, device.get("cpu"), "sint32"), (15, device.get("resolution"), "string"), (16, device.get("sdcard"), "float"), (17, device.get("sdcard_used"), "float"), (18, device.get("memory"), "float"), (19, device.get("memory2"), "float"), (20, device.get("data"), "float"), (21, device.get("data_used"), "float"), (22, device.get("os_version"), "string"), (23, device.get("brightness"), "sint32"), (24, device.get("volume"), "sint32"), (25, device.get("ts"), "sint64"), (26, device.get("ts2"), "sint64"), (27, device.get("ts3"), "sint64"), (28, device.get("ts4"), "sint64"), (29, device.get("usb"), "sint32"), (30, device.get("hw_version"), "string"), (31, device.get("brand"), "string"), (32, device.get("board"), "string"), (33, device.get("product_name"), "string"), (34, device.get("product_device"), "string"), (35, device.get("product_manufacturer"), "string"), (36, device.get("hardware"), "string"), (38, device.get("unknown38"), "sint32"), (40, device.get("unknown40"), "sint32"), ] return _proto(fields) def _encode_env(env: Mapping[str, Any]) -> bytes: fields = [ (1, env.get("launch_time"), "sint32"), (2, env.get("unknown2"), "sint32"), (3, env.get("unknown3"), "sint32"), (5, env.get("unknown5"), "sint32"), (6, env.get("version"), "string"), (7, env.get("pid"), "sint32"), (12, _encode_device(env.get("device") or {}), "message"), (13, _proto([ (1, (env.get("report") or {}).get("time"), "sint64"), (2, (env.get("report") or {}).get("state"), "sint32"), (4, (env.get("report") or {}).get("code"), "sint32"), (5, (env.get("report") or {}).get("times"), "sint32"), (6, (env.get("report") or {}).get("unknown6"), "sint32"), ]), "message"), (14, env.get("app_version"), "string"), (15, env.get("unknown15"), "sint32"), (16, env.get("unknown16"), "sint32"), (18, env.get("unknown18"), "sint32"), (19, env.get("unknown19"), "sint32"), (20, env.get("unknown20"), "sint32"), (21, env.get("unknown21"), "sint32"), ] return _proto(fields) def _encode_medusa(values: Mapping[str, Any]) -> bytes: return _proto([ (1, values.get("magic"), "bytes"), (2, values.get("version"), "sint32"), (3, values.get("rand"), "sint32"), (4, values.get("ms_app_id"), "string"), (5, values.get("device_id"), "string"), (6, values.get("license_id"), "string"), (7, values.get("app_version"), "string"), (8, values.get("sdk_version_str"), "string"), (9, values.get("sdk_version"), "sint32"), (10, values.get("xg_seed_bytes"), "bytes"), (12, values.get("time"), "sint32"), (13, values.get("query_body_ts_hash"), "bytes"), (14, values.get("query_sm3"), "bytes"), (15, _encode_request(), "message"), (16, values.get("sec_device_token"), "string"), (17, values.get("time2"), "sint32"), (18, values.get("lanusk_hash"), "bytes"), (19, values.get("query_body_hash_sm3"), "bytes"), (20, values.get("psk_version"), "string"), (21, values.get("call_type"), "sint32"), (23, _encode_env(values.get("env") or {}), "message"), (24, values.get("unknown24"), "string"), (26, values.get("original"), "string"), ]) def _json_body_md5(data: Any, data_type: str | None = None) -> str: if not data: return "" if isinstance(data, str): raw = data.encode("utf-8") elif isinstance(data, bytes): raw = data elif data_type == "application/json; charset=UTF-8": raw = json.dumps(data, ensure_ascii=False, separators=(",", ":")).encode("utf-8") else: raw = urlencode(data).encode("utf-8") return hashlib.md5(raw).hexdigest().upper() def _url_encode(value: Mapping[str, Any]) -> str: return urlencode(value).replace("+", "%20").replace("%2A", "*") def _get_params_encrypturl(url: str, params: Mapping[str, Any], devices: Mapping[str, Any]) -> tuple[str, dict[str, Any]]: result = dict(params) for key, value in devices.items(): if key in result: result[key] = value elif key == "device_id" and "did" in result: result["did"] = value result["ts"] = int(time.time()) result["_rticket"] = int(time.time() * 1000) return url.split("?", 1)[0] + "?" + _url_encode(result), result def _xg_rc4(data: bytes, key: bytes) -> bytearray: table = list(range(256)) j = 0 for i in range(256): j = (j + table[i] + key[i % len(key)]) % 256 table[i] = table[j] i = j = 0 result = bytearray(len(data)) for index, value in enumerate(data): i = (i + 1) & 0xFF x = table[i] j = (j + x) & 0xFF y = table[j] # 保持正式基线的 RC4 变体：这里只覆盖 S[i]，不交换 S[j]。 table[i] = y result[index] = value ^ table[(y + y) & 0xFF] return result def _reverse_bits(value: int) -> int: return int(f"{value:08b}"[::-1], 2) def _encrypt_gorgon(body: Any, query: str, khronos: int, xg_rand: int, data_type: str) -> str: body_md5 = _json_body_md5(body, data_type).lower() if body else "" data = bytearray(hashlib.md5(query.encode()).digest()[:4]) data += bytes.fromhex(body_md5)[:4] if body_md5 else b"\0\0\0\0" data += b"\0\0\0\0" + (67503104).to_bytes(4, "little") + khronos.to_bytes(4, "big") key = bytes((0x4A, 320 & 0xFF, 0x16, (xg_rand >> 8) & 0xFF, 0x47, 0x6C, 1, xg_rand & 0xFF)) result = _xg_rc4(data, key) for index, value in enumerate(result): value = ((value >> 4) | (value << 4)) & 0xFF following = result[index + 1] if index + 1 < len(result) else result[0] result[index] = (~(_reverse_bits(following ^ value) ^ 20)) & 0xFF return (b"\x84\x04" + xg_rand.to_bytes(2, "little") + (320).to_bytes(2, "little") + result).hex() def _ror64(value: int, count: int) -> int: count %= 64 return ((value >> count) | (value << (64 - count))) & 0xFFFFFFFFFFFFFFFF def _encrypt_helios(khronos: int, rand_value: int = 0) -> str: value = rand_value or random.randint(0, 0xFFFFFFFF) seed = value.to_bytes(4, "little") + b"8662" digest = hashlib.md5(seed).digest() keys = b"".join(f"{item:02x}".encode() for item in digest) table = [int.from_bytes(keys[:8], "little")] words = [int.from_bytes(keys[i:i + 8], "little") for i in range(0, 32, 8)] first, second = words[0], words[1] words = words[2:] for index in range(0x22): value2 = _ror64(second, 8) value2 = (value2 + first) & 0xFFFFFFFFFFFFFFFF value2 = (value2 ^ index) & 0xFFFFFFFFFFFFFFFF words.append(value2) value2 ^= _ror64(first, 61) value2 &= 0xFFFFFFFFFFFFFFFF table.append(value2) first, second = value2, words.pop(0) raw = (f"{khronos}-1588093228-8662").encode() pad = 16 - len(raw) % 16 raw += bytes([pad]) * pad output = bytearray() for offset in range(0, len(raw), 16): left = int.from_bytes(raw[offset:offset + 8], "little") right = int.from_bytes(raw[offset + 8:offset + 16], "little") for index in range(0x22): right = (table[index] ^ (left + _ror64(right, 8))) & 0xFFFFFFFFFFFFFFFF left = (right ^ _ror64(left, 61)) & 0xFFFFFFFFFFFFFFFF output += left.to_bytes(8, "little") + right.to_bytes(8, "little") return base64.b64encode(value.to_bytes(4, "little") + output).decode() def _gen_medusa_proto(url: str, url_params: Mapping[str, Any], devices: Mapping[str, Any], data: Any, khronos: int, data_type: str) -> tuple[bytes, bytes, bytes]: body_md5 = _json_body_md5(data, data_type).lower() if data else "" body_md5_bytes = bytes.fromhex(body_md5) if body_md5 else bytes(16) ts_bytes = khronos.to_bytes(4, "little") query = url.split("?", 1)[1] if "?" in url else "" query_sm3 = SM3(query).digest() query_body_hash = SM3(query.encode() + body_md5_bytes + b"none").digest() device_id = str(devices.get("device_id", url_params.get("device_id", url_params.get("did", "")))) version_name = str(devices.get("version_name", url_params.get("version_name", APP_VERSION_NAME))) device_model = str(devices.get("device_model", url_params.get("device_type", ""))) brand = str(devices.get("device_brand", url_params.get("device_brand", ""))) sec_device_token = str(devices.get("sec_device_token") or "") device_sec_device_token = str(devices.get("device_sec_device_token") or "") proto_rand = random.randint(0, 0xFFFFFFFF) launch_time = random.randint(100, 120) process_id = random.randint(10001, 12000) # 这些字段是正式签名实现中的固定环境采样值，不是用户设备标识。 report_ts = 1728388016635 report_time = int(time.time()) device = { "d1": 1, "collect_stat": 2, "aid": "8662", "device_id": device_id, "sec_device_token": device_sec_device_token, "app_version": "!noperm!", "battery": -888888, "battery2": -888888, "battery_health": 3, "battery_changed": -888888, "network": "!notset!", "tz": "Asia/Shanghai,8", "lan": "zh_CN", "cpu": 4, "sdcard": 255.24993896484375, "sdcard_used": 35.58599090576172, "memory": 3.467449188232422, "memory2": 3.467449188232422, "data": 255.1754913330078, "data_used": 42.17544174194336, "os_version": str(devices.get("os_version", url_params.get("os_version", ""))), "brightness": 41, "volume": 36, "ts": report_ts, "ts2": report_ts, "ts3": report_ts, "ts4": report_ts + 2, "usb": -1, "hw_version": device_model, "brand": brand, "board": device_model, "product_name": device_model, "product_device": str(devices.get("device_manufacturer", brand)), "product_manufacturer": brand, "hardware": brand, "unknown38": 31, } env = { "launch_time": launch_time, "unknown2": 146331399, "unknown3": 146331396, "unknown5": 7, "version": "v04.06.04.03-bugfix", "pid": process_id, "device": device, "report": {"time": report_time, "state": -2, "code": 200, "times": 0, "unknown6": 0}, "app_version": version_name, } values = { "magic": b"\xf7\xe8_\xfa\xd7\xd7\xdc;\xd6*\xc8pW\xcfa\x18", "version": 3, "rand": proto_rand, "ms_app_id": "8662", "device_id": device_id, "license_id": "1588093228", "app_version": version_name, "sdk_version_str": "v04.06.04-ml-android", "sdk_version": 67503104, "xg_seed_bytes": (320).to_bytes(8, "little"), "time": khronos, "query_body_ts_hash": hash_f13(query_sm3, body_md5_bytes, ts_bytes, khronos), "query_sm3": query_sm3[:6], "sec_device_token": sec_device_token, "time2": khronos, "lanusk_hash": b"", "query_body_hash_sm3": query_body_hash, "psk_version": "none", "call_type": 312, "env": env, "unknown24": '{"cmr":16777216,"cmr2":16777216,"un_h":1879194040,"vpn":0,"kd":0,"fkd":3672518972,"pd":-1872573247,"dyn":"","do":0,"tk":true}', } return _encode_medusa(values), query_sm3, hash_f13(query_sm3, body_md5_bytes, ts_bytes, khronos) def _xmxor_two(data: bytes, key: bytes) -> bytearray: encoded = bytearray(len(data)) for index, value in enumerate(data): position = (index * 4) & 28 d0, d1 = key[position], key[position + 1] d2 = (rl8(value, 4) + d0) ^ d1 d2 = rl8((~d2) & 0xFF, 3) d2 = ((d2 + d1) & 0xFF) ^ d0 encoded[-index - 1] = (~d2) & 0xFF return encoded def _xmxor(data: bytes, key: bytes) -> bytearray: value = _xmxor_two(data, key) last_flag = value[-1] ^ value[-2] data0 = value[0] value[0] = (~last_flag + value[0]) & 0xFF value[1] = ((value[0] ^ value[-1] ^ 254) + value[1]) & 0xFF value[2] = (value[2] + ((last_flag - data0) ^ rl8(value[1], 3) ^ 2)) & 0xFF for index in range(len(value) - 4): temp = rl8(value[index + 2], 3) ^ value[index + 1] ^ (index + 3) value[index + 3] = (~temp + value[index + 3]) & 0xFF value[-1] ^= value[-2] value[0] = ((value[0] ^ value[1]) + sum(value[1:])) & 0xFF return value def _gen_medusa(url: str, url_params: Mapping[str, Any], devices: Mapping[str, Any], data: Any, khronos: int, data_type: str) -> str: config_key = b"\xf1Y3vvn\xa9\x8d4\xf3\x1b\x05z\x9d[\xe4" config_iv = b"\x1f\xe1\t\xa4\x12R\x83\xf4\x18\xde\x9e\x05\x1a\x96\x9e\x12" sign_key = b"\x8e\xbd\xfa8\x06\xec\xc5\xce\xe7\x94#\xe6\x02\x9e\xd8%@\xbc\"\x18\xbb~\xae\xf7\x1c\xb6\x91\xf7\xaa\x8a\xa2\xf5" proto, query_sm3, body_sm3 = _gen_medusa_proto(url, url_params, devices, data, khronos, data_type) hash_rand = random.randint(0, 0xFFFFFFFF) xm_rand = random.randint(0, 0xFFFFFFFF) key, seed = get_key_hash(sign_key, hash_rand) mixed = _xmxor(proto, key) mixed = (320).to_bytes(8, "little") + mixed mixed = bytearray(mixed[::-1]) for index in range(len(mixed)): mixed[index] ^= seed[~index & 3] hash_bytes = hash_rand.to_bytes(4, "little") check_bit = ((query_sm3[0] & 63) << 14) | 0x18000001 | ((body_sm3[0] & 63) << 8) mixed = b"\x35" + xm_rand.to_bytes(4, "little") + check_bit.to_bytes(4, "little") + mixed + hash_bytes[2:] mixed = AES_V3(config_key, khronos).encrypt(mixed, config_iv) version = bytes.fromhex("03 00 00 00 f7 e8 5f fa d7 d7 dc 3b d6 2a c8 70 57 cf 61 18") version_or = b"".join((int.from_bytes(version[i:i + 4], "little") ^ khronos).to_bytes(4, "little") for i in range(0, 20, 4)) return base64.b64encode(version_or + hash_bytes[:2] + (256).to_bytes(2, "little") + mixed).decode() def _core_sixgod(url: str, params: Mapping[str, Any], devices: Mapping[str, Any], data: Any, header: Mapping[str, Any]) -> tuple[dict[str, str], str]: data_type = str(header.get("content-type", header.get("Content-Type", ""))) xg_rand = random.randint(0, 0xFFFF) encrypted_url, url_params = _get_params_encrypturl(url, params, devices) khronos = int(time.time()) encoded_query = _url_encode(url_params) values = { "khronos": str(khronos), "ladon": base64.b64encode(khronos.to_bytes(4, "big")).decode(), "argus": base64.b64encode(khronos.to_bytes(4, "little")).decode(), "gorgon": _encrypt_gorgon(data, encoded_query, khronos, xg_rand, data_type), "helios": _encrypt_helios(khronos, 0), "medusa": _gen_medusa(encrypted_url, url_params, devices, data, khronos, data_type), } signs = { "x-ladon": values["ladon"], "x-khronos": values["khronos"], "x-argus": values["argus"], "x-gorgon": values["gorgon"], "x-helios": values["helios"], "x-medusa": values["medusa"], } if data: signs["x-ss-stub"] = _json_body_md5(data, data_type) result_headers = {str(key).lower(): str(value) for key, value in header.items()} result_headers.update(signs) if devices.get("ua"): result_headers["user-agent"] = str(devices["ua"]) result_headers["x-tt-dt"] = str(devices.get("x_tt_dt", "")) return result_headers, encrypted_url def _device_config(config: Mapping[str, Any]) -> dict[str, str]: device_id = _text(config.get("device_id")) install_id = _text(config.get("install_id")) if not device_id or not install_id: raise HongguoPluginError("缺少红果 device_id/install_id 配置") return { "device_id": device_id, "iid": install_id, "install_id": install_id, "device_brand": "Redmi", "device_model": "25053RT47C", "device_type": "25053RT47C", "device_manufacturer": "Xiaomi", "os_version": "16", "version_name": APP_VERSION_NAME, "x_tt_dt": _text(config.get("x_tt_dt")), "sec_device_token": _text(config.get("sec_device_token")), "device_sec_device_token": _text(config.get("device_sec_device_token")), "ua": APP_UA, } def _video_model(video_id: str, config: Mapping[str, Any]) -> dict[str, Any]: devices = _device_config(config) params = { "iid": devices["install_id"], "device_id": devices["device_id"], "ac": "wifi", "channel": "update_64", "aid": "8662", "app_name": "novelread", "version_code": APP_VERSION_CODE, "version_name": APP_VERSION_NAME, "device_platform": "android", "os": "android", "ssmix": "a", "device_type": "25053RT47C", "device_brand": "Redmi", "language": "zh", "os_api": "36", "os_version": "16", "manifest_version_code": APP_VERSION_CODE, "resolution": "1280*2772", "dpi": "520", "update_version_code": APP_VERSION_CODE, "host_abi": "arm64-v8a", "dragon_device_type": "phone", "pv_player": APP_VERSION_CODE, "compliance_status": "0", "need_personal_recommend": "1", "player_so_load": "1", "is_android_pad_screen": "0", } payload = { "biz_param": { "detail_page_version": 0, "device_level": 3, "disable_digg_stat": False, "need_all_video_definition": True, "need_mp4_align": False, "use_os_player": False, "use_server_dns": False, "video_platform": 1024, }, "mixed_video_id_map": {"1004": [video_id]}, } request_headers = { "User-Agent": APP_UA, "Accept": "application/json; charset=utf-8,application/x-protobuf", "Content-Type": "application/json; charset=UTF-8", "x-xs-from-web": "0", "x-ss-req-ticket": str(int(time.time() * 1000)), "x-tt-request-tag": "t=0;n=0", "sdk-version": "2", "passport-sdk-version": "50561", "x-vc-bdturing-sdk-version": "3.7.2.cn", } if devices.get("cookie"): request_headers["Cookie"] = devices["cookie"] signed_headers, signed_url = _core_sixgod( VIDEO_URL, params, devices, payload, request_headers, ) body = json.dumps(payload, ensure_ascii=False, separators=(",", ":")).encode("utf-8") response = requests.post( signed_url, headers=signed_headers, data=body, timeout=30, ) response_data = _json_response(response) data = response_data.get("data") or {} if not isinstance(data, Mapping): raise HongguoPluginError("video_model 数据为空") entry: Any = data.get(video_id) if entry is None: for value in data.values(): if isinstance(value, Mapping): entry = value break if isinstance(value, list) and value and isinstance(value[0], Mapping): entry = value[0] break if not isinstance(entry, Mapping): entry = data raw_model = entry.get("video_model") if isinstance(entry, Mapping) else None if raw_model is None: raw_model = data.get("video_model") if isinstance(raw_model, str): try: raw_model = json.loads(raw_model) except ValueError as exc: raise HongguoPluginError("video_model JSON 无效") from exc if not isinstance(raw_model, Mapping): raise HongguoPluginError("video_model 为空") return dict(raw_model) def _video_list_from_model(model: Mapping[str, Any]) -> Any: for key in ("video_list", "dynamic_video_list"): if model.get(key) is not None: return model[key] dynamic = model.get("dynamic_video") if isinstance(dynamic, Mapping): for key in ("dynamic_video_list", "video_list", "list"): if dynamic.get(key) is not None: return dynamic[key] video_info = model.get("video_info") if isinstance(video_info, Mapping): data = video_info.get("data") if isinstance(data, Mapping): return _video_list_from_model(data) data = model.get("data") if isinstance(data, Mapping): return _video_list_from_model(data) return None _QUALITY_ORDER = ("2160", "1440", "1080", "720", "576", "540", "480", "360") def _int(value: Any) -> int: match = re.search(r"\d+", _text(value)) return int(match.group()) if match else 0 def _quality(value: Any) -> str: text = _text(value).lower() match = re.search(r"(2160|1440|1080|720|576|540|480|360)", text) return match.group(1) if match else "1080" def _select_quality(video_list: Any, wanted: str = "1080") -> tuple[str, dict[str, Any]]: def rows_from(value: Any, hinted_quality: str = "") -> list[tuple[str, dict[str, Any]]]: if isinstance(value, list): result: list[tuple[str, dict[str, Any]]] = [] for item in value: result.extend(rows_from(item, hinted_quality)) return result if not isinstance(value, Mapping): return [] if any( key in value for key in ( "main_url", "backup_url", "backup_url_1", "play_addr", "spade_a", "encrypt_info", ) ): return [(hinted_quality, dict(value))] result = [] for key, item in value.items(): if key in {"dynamic_video", "video_info", "data"} and isinstance(item, Mapping): result.extend(rows_from(item, hinted_quality)) continue if key in {"video_list", "dynamic_video_list", "list"}: result.extend(rows_from(item, _quality(key))) continue if isinstance(item, (Mapping, list)): result.extend(rows_from(item, _quality(key))) return result candidates = rows_from(video_list) rows: dict[str, dict[str, Any]] = {} for hinted_quality, item in candidates: definition = _quality( item.get("definition") or item.get("vheight") or (item.get("video_meta") or {}).get("definition") or hinted_quality ) rows[definition] = item if not rows: raise HongguoPluginError("播放模型没有清晰度") requested = _quality(wanted) order = [requested] + [item for item in _QUALITY_ORDER if item != requested] for definition in order: if definition in rows: return definition, rows[definition] definition = max(rows, key=lambda item: _int(item)) return definition, rows[definition] def _select_all_qualities(value: Any, hinted: str = "") -> list[tuple[str, dict[str, Any]]]: if isinstance(value, list): out = [] for item in value: out.extend(_select_all_qualities(item, hinted)) return out if not isinstance(value, Mapping): return [] if any(k in value for k in ("main_url", "backup_url", "spade_a", "encrypt_info")): return [(hinted, dict(value))] out = [] for key, item in value.items(): hint = _quality(key) if key not in ("dynamic_video", "video_info", "data") else hinted if isinstance(item, (Mapping, list)): out.extend(_select_all_qualities(item, hint)) return out def _select_relay_quality(video_list: Any) -> tuple[str, dict[str, Any]]: candidates = [] for quality, item in _select_all_qualities(video_list): meta = item.get("video_meta") if isinstance(item.get("video_meta"), Mapping) else item codec = _text(meta.get("codec_type") or meta.get("codec") or "").lower() size = int(meta.get("size") or 0) if str(meta.get("size") or "0").isdigit() else 0 height = _int(quality or meta.get("vheight") or meta.get("definition")) codec_score = 2 if codec in ("h264", "avc1", "bytevc1") else (1 if codec == "bytevc2" else 0) candidates.append((codec_score, size <= 24 * 1024 * 1024, height, -size, quality, item)) if not candidates: raise HongguoPluginError("播放模型没有清晰度") safe = [x for x in candidates if x[1]] pool = safe or candidates pool.sort(reverse=True, key=lambda x: (x[0], x[1], x[2], x[3])) return pool[0][4], pool[0][5] def _decrypt_spade_url(value: str, key_seed: bytes) -> str: raw = _b64(value) if len(raw) < 20 or raw[0] != 0xA8 or raw[2:4] != b"\x01\x00": raise HongguoPluginError("spade URL 头无效") cipher_data = raw[4 : len(raw) - (len(raw) - 4) % 16] if not cipher_data: raise HongguoPluginError("spade URL 密文为空") constants = bytes.fromhex( "4dd4c2e6b83162090e52b3c7a6733ba4" "1cb2462b829ab58a196b39db57177524" "f49baf7f08e8d68d26a72e37c1a95a2f" "1f05a51892aef2949732b62a38aadd58" ) first = hashlib.sha512(key_seed).digest() second = hashlib.sha512(first + constants).digest() plaintext = _aes(second[:16], second[16:32], cipher_data, "cbc") if plaintext: padding = plaintext[-1] if 1 <= padding <= 16 and padding <= len(plaintext): plaintext = plaintext[:-padding] return plaintext.rstrip(b"\0").decode("utf-8", errors="replace") def _parse_ref(value: str, prefix: str) -> str: if not value.startswith(prefix): raise HongguoPluginError("播放引用无效") raw = value[len(prefix) :] if not raw or not _VIDEO_ID.fullmatch(raw): raise HongguoPluginError("播放引用格式无效") return raw def _key_seed_from_model(model: Mapping[str, Any]) -> bytes: value = _text(model.get("key_seed")) if value: return _b64(value) for key in ("dynamic_video", "video_info", "data"): nested = model.get(key) if isinstance(nested, Mapping): result = _key_seed_from_model(nested) if result: return result return b"" class NativeRelay: def __init__(self, config=None): self.config = config if isinstance(config, dict) else {} self.device_id = _text(self.config.get('device_id')) or str(random.randint(10**17, 10**18 - 1)) self.install_id = _text(self.config.get('install_id')) or str(random.randint(10**17, 10**18 - 1)) self.timeout = int(self.config.get('timeout') or 90) self.session = requests.Session() self.session_id = '' self.page_state = {} self.page_cache = {} def _devices(self): return _device_config({'device_id': self.device_id, 'install_id': self.install_id, 'x_tt_dt': self.config.get('x_tt_dt'), 'sec_device_token': self.config.get('sec_device_token'), 'device_sec_device_token': self.config.get('device_sec_device_token')}) def _common(self): d = self._devices() return {'iid': d['install_id'], 'device_id': d['device_id'], 'ac': 'wifi', 'channel': 'update_64', 'aid': '8662', 'app_name': 'novelread', 'version_code': APP_VERSION_CODE, 'version_name': APP_VERSION_NAME, 'device_platform': 'android', 'os': 'android', 'ssmix': 'a', 'device_type': '25053RT47C', 'device_brand': 'Redmi', 'language': 'zh', 'os_api': '36', 'os_version': '16', 'manifest_version_code': APP_VERSION_CODE, 'resolution': '1280*2772', 'dpi': '520', 'update_version_code': APP_VERSION_CODE, 'host_abi': 'arm64-v8a', 'dragon_device_type': 'phone'} def _check(self, response): if not isinstance(response, dict): raise HongguoPluginError('上游响应结构异常') code = response.get('code', response.get('status_code', 0)) if code not in (0, '0', None): raise HongguoPluginError('上游错误 %s: %s' % (code, response.get('message') or response.get('status_msg') or '')) return response def _request(self, path, params, payload=None): devices = self._devices() headers = {'User-Agent': APP_UA, 'Accept': 'application/json; charset=utf-8', 'x-xs-from-web': '0', 'x-ss-req-ticket': str(int(time.time() * 1000)), 'x-tt-request-tag': 't=0;n=0', 'sdk-version': '2', 'passport-sdk-version': '50561', 'x-vc-bdturing-sdk-version': '3.7.2.cn'} if payload is not None: headers['Content-Type'] = 'application/json; charset=UTF-8' signed, url = _core_sixgod(HOST + path, params, devices, payload, headers) body = None if payload is None else json.dumps(payload, ensure_ascii=False, separators=(',', ':')).encode() response = self.session.post(url, headers=signed, data=body, timeout=(6.05, 20)) if payload is not None else self.session.get(url, headers=signed, timeout=(6.05, 20)) return self._check(_json_response(response)) def _extract_rows(self, value): rows = [] def walk(x): if isinstance(x, dict): if x.get('series_id') and (x.get('series_title') or x.get('title')): rows.append(x) for v in x.values(): walk(v) elif isinstance(x, list): for v in x: walk(v) walk(value) out, seen = [], set() for row in rows: sid = str(row.get('series_id')) if sid not in seen: seen.add(sid); out.append(row) return out def _filter_values(self, extend): result = {'genre': ['comic_series']} if not isinstance(extend, dict): return result allowed = ('category_dim_art_style', 'category_dim_theme', 'category_dim_role', 'category_dim_epoch', 'sort', 'gender', 'creation_status', 'online_time') for name in allowed: value = extend.get(name) if value in (None, '', 'all'): continue if isinstance(value, (list, tuple)): values = [str(x) for x in value if str(x).strip()] else: values = [str(value)] if values: result[name] = values return result def panel(self): params = self._common() payload = {'req_type': 'only_panel', 'need_selector_panel': False, 'req_scene': 'comic_series'} return self._request('/reading/distribution/category/landpage/v1/', params, payload) def feed(self, page, selected=None): params = self._common() if not isinstance(selected, dict): selected = {'genre': ['comic_series']} state_key = json.dumps(selected, ensure_ascii=False, sort_keys=True) cache_key = ('hg_feed', state_key, page) hit = _CACHE.get(cache_key) if hit and time.time() - hit[0] < 3600: return hit[1] previous = self.page_state.get((state_key, page - 1), {}) if page > 1 else {} if page > 1 and previous: offset = previous.get('next_offset', (page - 1) * 18) session_id = previous.get('session_id', '') client_req = 2 else: offset = max(0, (page - 1) * 18) session_id = previous.get('session_id', '') if page > 1 else '' client_req = 1 if page == 1 else 2 payload = {'req_type': 'only_content', 'need_selector_panel': False, 'req_scene': 'comic_series', 'offset': offset, 'limit': 18, 'client_req_type': client_req, 'session_id': session_id, 'select_items': selected} response = self._request('/reading/distribution/category/landpage/v1/', params, payload) data = response.get('data') or {} if not isinstance(data, dict): data = {} self.session_id = str(data.get('session_id') or session_id) self.page_state[(state_key, page)] = { 'session_id': self.session_id, 'next_offset': data.get('next_offset', offset + 18)} rows = data.get('video_data') if not isinstance(rows, list): rows = self._extract_rows(data) result = (rows, bool(data.get('has_more'))) _CACHE[cache_key] = (time.time(), result) return result def search_web(self, keyword, page=1): key = ('hg_websearch', str(keyword), int(page)) hit = _CACHE.get(key) if hit and time.time() - hit[0] < 300: return hit[1] url = 'https://hongguoduanju.com/search/' + quote(keyword) + '?page=' + str(page) headers = {'User-Agent': 'Mozilla/5.0 (Linux; Android 12) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/126.0 Mobile Safari/537.36', 'Accept-Language': 'zh-CN,zh;q=0.9'} response = requests.get(url, headers=headers, timeout=20) response.raise_for_status() html = response.text match = re.search(r'(?:window\.)?_ROUTER_DATA\s*=\s*', html) if not match: return [] data = json.JSONDecoder().raw_decode(html[match.end():])[0] loader = data.get('loaderData') or {} page_data = None if isinstance(loader, dict): for name, value in loader.items(): if isinstance(value, dict) and 'searchList' in value: page_data = value break if not isinstance(page_data, dict): page_data = {} rows = [] for item in page_data.get('searchList') or []: video_data = item.get('video_data') if isinstance(item, dict) else None if isinstance(video_data, dict) and video_data.get('series_id') and video_data.get('series_title'): rows.append(video_data) _CACHE[key] = (time.time(), rows) return rows def detail(self, sid): key = ('hg_detail', str(sid)) hit = _CACHE.get(key) if hit and time.time() - hit[0] < 600: return hit[1] params = self._common() params.update({'video_series_id': str(sid), 'vs_id_type': 1, 'source': 0, 'screen_width_px': '1080'}) result = self._request('/reading/bookapi/video_tab/video_detail/v/', params) _CACHE[key] = (time.time(), result) return result def model(self, vid): return _video_model(str(vid), {'device_id': self.device_id, 'install_id': self.install_id, 'x_tt_dt': self.config.get('x_tt_dt'), 'sec_device_token': self.config.get('sec_device_token'), 'device_sec_device_token': self.config.get('device_sec_device_token')}) def proxy(self, vid): config = dict(self.config) config.update({'device_id': self.device_id, 'install_id': self.install_id}) return HgRelay(config).proxy(str(vid).replace(EP, '')) class HgRelay: """红果播放本地解密客户端: 取播放模型 -> 选路 -> 下载 CENC -> 解出明文 MP4。""" def __init__(self, config=None): config = config if isinstance(config, dict) else {} self.device_id = _text(config.get("device_id")) or str(random.randint(10**17, 10**18 - 1)) self.install_id = _text(config.get("install_id")) or str(random.randint(10**17, 10**18 - 1)) self.timeout = int(config.get("timeout") or 120) self.cache = config.get("cache") is not False self.cache_dir = _text(config.get("cache_dir")) or os.path.join(tempfile.gettempdir(), "hg_relay") self.cache_ttl = int(config.get("cache_ttl") or 21600) def ready(self) -> bool: return Cipher is not None or CryptoAES is not None def model(self, vid) -> dict: return _video_model(self._vid(vid), {"device_id": self.device_id, "install_id": self.install_id}) def stream(self, vid) -> tuple: model = self.model(vid) _, item = _select_relay_quality(_video_list_from_model(model)) url = _media_url(item) spade = _spade_value(item) if not url or not spade: raise HongguoPluginError("video model unavailable") key_seed = _key_seed_from_model(model) if key_seed: try: url = _decrypt_spade_url(url, key_seed) except Exception: pass return url, spade def stream_full(self, vid): model = self.model(self._vid(vid)) _, item = _select_relay_quality(_video_list_from_model(model)) spade = _spade_value(item) key_seed = _key_seed_from_model(model) def _fix(value): value = str(value or '').strip() if value and key_seed: try: value = _decrypt_spade_url(value, key_seed) except Exception: pass return value main = _fix(_media_url(item)) if not main: raise HongguoPluginError("video model unavailable") backups = [] for name in ("backup_url_1", "backup_url_2", "play_addr", "url"): value = _fix(item.get(name)) if value and value != main and value not in backups: backups.append(value) key = derive_content_key(spade) if spade else None return main, backups, key def content_key(self, spade) -> bytes: return derive_content_key(spade) def fetch(self, url) -> bytes: r = requests.get(url, headers={"User-Agent": MEDIA_UA, "Referer": "https://novel.snssdk.com/"}, timeout=self.timeout) r.raise_for_status() return r.content def resolve(self, vid) -> bytes: cached = self._cache_read(vid) if self.cache else None if cached is not None: return cached url, spade = self.stream(vid) plain = decrypt_mp4_cenc(self.fetch(url), derive_content_key(spade)) if self.cache: self._cache_write(vid, plain) return plain def proxy(self, vid) -> list: try: return [200, "video/mp4", self.resolve(vid)] except Exception: return [502, "text/plain", b"media resolve failed"] def _vid(self, value) -> str: return _text(value).replace(EPISODE_PREFIX, "") def _cache_path(self, vid) -> str: return os.path.join(self.cache_dir, hashlib.md5(self._vid(vid).encode()).hexdigest() + ".mp4") def _cache_read(self, vid): path = self._cache_path(vid) try: st = os.stat(path) if st.st_size > 16 and time.time() - st.st_mtime <= self.cache_ttl: with open(path, "rb") as f: return f.read() except OSError: pass return None def _cache_write(self, vid, body) -> None: try: os.makedirs(self.cache_dir, exist_ok=True) tmp = self._cache_path(vid) + ".part" with open(tmp, "wb") as f: f.write(body) os.replace(tmp, self._cache_path(vid)) except OSError: pass _STREAM_STATE = {'ready': False, 'server': None, 'port': 0, 'base': '', 'cfg': {}, 'lock': threading.Lock()} def _find_free_port(preferred): for port in range(preferred, preferred + 50): try: with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock: sock.bind(('127.0.0.1', port)) return port except OSError: continue return 0 def _stream_resolve(vid): cfg = dict(_STREAM_STATE.get('cfg') or {}) main, backups, key = HgRelay(cfg).stream_full(str(vid).strip()) return main, backups, key def _stream_ensure(config): state = _STREAM_STATE with state['lock']: if state['ready']: try: with socket.create_connection(('127.0.0.1', state['port']), timeout=0.5): state['cfg'] = dict(config or {}) return state['base'] except OSError: state['ready'] = False state['server'] = None port = _find_free_port(9878) if not port: raise HongguoPluginError('no free port') src_dir = os.path.join(tempfile.gettempdir(), 'hg_manju_src') try: os.makedirs(src_dir, exist_ok=True) except OSError: pass _StreamHandler.src_dir = src_dir server = ThreadingHTTPServer(('0.0.0.0', port), _StreamHandler) server.daemon_threads = True threading.Thread(target=server.serve_forever, daemon=True).start() state.update({'ready': True, 'server': server, 'port': port, 'base': 'http://127.0.0.1:%d' % port, 'cfg': dict(config or {})}) return state['base'] class _StreamHandler(BaseHTTPRequestHandler): src_dir = None _resolve_cache = {} _vid_locks = {} _guard = threading.Lock() _download_locks = {} _download_guard = threading.Lock() _RESOLVE_TTL = 300 _FILE_TTL = 1800 def do_GET(self): parsed = urlparse(self.path) path = parsed.path params = parse_qs(parsed.query) if path == '/play': self._handle_play(params) elif path == '/stream': self._handle_stream(params) elif path == '/health': self._json(200, {'ok': True, 'service': 'hongguo-manju-stream'}) else: self.send_error(404) def do_HEAD(self): parsed = urlparse(self.path) if parsed.path == '/stream': self._handle_stream(parse_qs(parsed.query), head_only=True) else: self.send_error(404) def log_message(self, *args): pass def _json(self, code, data): body = json.dumps(data, ensure_ascii=False).encode('utf-8') self.send_response(code) self.send_header('Content-Type', 'application/json; charset=utf-8') self.send_header('Content-Length', str(len(body))) self.send_header('Access-Control-Allow-Origin', '*') self.end_headers() try: self.wfile.write(body) except Exception: pass def _resolve_vid(self, vid): with self._guard: if vid not in self._vid_locks: self._vid_locks[vid] = threading.Lock() if len(self._resolve_cache) > 1000: now = time.time() for key in [k for k, v in self._resolve_cache.items() if now - v[0] > self._RESOLVE_TTL]: self._resolve_cache.pop(key, None) with self._vid_locks[vid]: hit = self._resolve_cache.get(vid) if hit and time.time() - hit[0] < self._RESOLVE_TTL: return hit[1] result = _stream_resolve(vid) self._resolve_cache[vid] = (time.time(), result) return result def _handle_play(self, params): vid = (params.get('vid') or [''])[0].strip() if not vid.isdigit(): self._json(400, {'error': 'vid invalid'}) return try: main, backups, key = self._resolve_vid(vid) query = [('url', main)] if key: query.append(('key', base64.b64encode(key).decode('ascii'))) for value in backups or []: query.append(('bk', value)) self.send_response(302) self.send_header('Location', 'http://127.0.0.1:%d/stream?%s' % (self.server.server_port, urlencode(query))) self.send_header('Access-Control-Allow-Origin', '*') self.end_headers() except Exception as exc: self._json(502, {'error': str(exc)}) def _handle_stream(self, params, head_only=False): raw_url = (params.get('url') or [''])[0].strip() key_b64 = (params.get('key') or [''])[0].strip() if not raw_url: self.send_error(400, 'missing url') return backups = [value for value in params.get('bk', []) if value] candidates = [raw_url] + backups try: content_key = base64.b64decode(key_b64) if key_b64 else None except Exception: content_key = None if content_key is None: self._proxy_plain(candidates, head_only) return filename = 'video_%s.mp4' % hashlib.md5(raw_url.encode()).hexdigest()[:16] filepath = os.path.join(self.src_dir or tempfile.gettempdir(), filename) if os.path.exists(filepath): self._serve_file(filepath, head_only) return range_header = self.headers.get('Range', '') is_full = not range_header or re.match(r'bytes=0-\s*$', range_header) is not None with self._download_guard: if filename not in self._download_locks: self._download_locks[filename] = threading.Lock() lock = self._download_locks[filename] if is_full and not head_only and lock.acquire(blocking=False): try: if os.path.exists(filepath): self._serve_file(filepath, head_only) return self._stream_direct(raw_url, backups, content_key, filepath) return except Exception: pass finally: lock.release() try: with lock: if os.path.exists(filepath): self._serve_file(filepath, head_only) return data = _download_bytes(candidates) if content_key is not None: data = decrypt_mp4_cenc(data, content_key) try: with open(filepath, 'wb') as f: f.write(data) except OSError: pass self._schedule_cleanup(filepath) self._serve_file(filepath, head_only) except Exception: try: self.send_error(502, 'stream failed') except Exception: pass def _proxy_plain(self, candidates, head_only): session = requests.Session() headers = {'User-Agent': MEDIA_UA, 'Referer': 'https://novel.snssdk.com/'} response = None for url in candidates: try: response = session.get(url, headers=headers, stream=True, timeout=(8, 90)) response.raise_for_status() break except Exception: response = None if response is None: try: self.send_error(502, 'cdn failed') except Exception: pass return self.send_response(200) self.send_header('Content-Type', 'video/mp4') length = response.headers.get('Content-Length') if length: self.send_header('Content-Length', length) self.send_header('Accept-Ranges', 'bytes') self.send_header('Access-Control-Allow-Origin', '*') self.end_headers() if head_only: response.close() return try: for chunk in response.iter_content(65536): self.wfile.write(chunk) except Exception: pass finally: response.close() def _serve_file(self, filepath, head_only=False): try: file_size = os.path.getsize(filepath) except OSError: self.send_error(404) return if file_size <= 16: self.send_error(404) return range_header = self.headers.get('Range', '') start, end, is_partial = 0, file_size - 1, False if range_header: match = re.match(r'bytes=(\d+)-(\d*)', range_header) if match: start = int(match.group(1)) if match.group(2): end = min(int(match.group(2)), file_size - 1) is_partial = True if start >= file_size or start > end: self.send_error(416) return length = end - start + 1 if is_partial: self.send_response(206) self.send_header('Content-Range', 'bytes %d-%d/%d' % (start, end, file_size)) else: self.send_response(200) self.send_header('Content-Type', 'video/mp4') self.send_header('Content-Length', str(length)) self.send_header('Accept-Ranges', 'bytes') self.send_header('Access-Control-Allow-Origin', '*') self.send_header('Access-Control-Expose-Headers', 'Content-Length, Content-Range, Accept-Ranges') self.end_headers() if head_only: return try: with open(filepath, 'rb') as f: f.seek(start) remaining = length while remaining > 0: chunk = f.read(min(65536, remaining)) if not chunk: break self.wfile.write(chunk) remaining -= len(chunk) except Exception: pass def _schedule_cleanup(self, filepath): def _delete(): try: os.unlink(filepath) except OSError: pass timer = threading.Timer(self._FILE_TTL, _delete) timer.daemon = True timer.start() def _send_plain(self, data): self.send_response(200) self.send_header('Content-Type', 'video/mp4') self.send_header('Content-Length', str(len(data))) self.send_header('Accept-Ranges', 'bytes') self.send_header('Access-Control-Allow-Origin', '*') self.send_header('Access-Control-Expose-Headers', 'Content-Length, Content-Range, Accept-Ranges') self.end_headers() try: self.wfile.write(data) self.wfile.flush() except Exception: pass def _stream_direct(self, raw_url, backups, content_key, filepath): session = requests.Session() session.trust_env = False headers = {'User-Agent': MEDIA_UA, 'Referer': 'https://novel.snssdk.com/'} candidates = [raw_url] + list(backups or []) response = None for url in candidates: try: response = session.get(url, headers=headers, stream=True, timeout=(8, 120)) response.raise_for_status() break except Exception: response = None if response is None: raise HongguoPluginError('cdn failed') total_size = int(response.headers.get('Content-Length') or 0) iterator = response.iter_content(262144) buffer = bytearray() ftyp_size, moov_end = 0, 0 for chunk in iterator: buffer.extend(chunk) if ftyp_size == 0 and len(buffer) >= 8: ftyp_size = struct.unpack('>I', bytes(buffer[0:4]))[0] if ftyp_size > 0 and moov_end == 0 and len(buffer) >= ftyp_size + 8: moov_size = struct.unpack('>I', bytes(buffer[ftyp_size:ftyp_size + 4]))[0] moov_end = ftyp_size + moov_size if moov_end > 0 and len(buffer) >= moov_end: break if moov_end == 0 or len(buffer) < moov_end: response.close() data = bytearray(buffer) for chunk in iterator: data.extend(chunk) plain = decrypt_mp4_cenc(bytes(data), content_key) self._send_plain(plain) try: with open(filepath, 'wb') as f: f.write(plain) self._schedule_cleanup(filepath) except OSError: pass return moov = bytearray(buffer[ftyp_size + 8:moov_end]) _replace_fourcc(moov, b'encv', b'hvc1') _replace_fourcc(moov, b'enca', b'mp4a') _replace_sinf(moov) view = memoryview(moov) decrypt_map = {} track_search = 0 while True: track, track_size = _find_box(view, b'trak', track_search) if track < 0: break parsed = _parse_track(view, track) if parsed is not None: sizes, offsets, chunk_counts, aux_sizes, aux_offset, sample_count = parsed if sample_count and len(aux_sizes) >= sample_count and aux_offset >= 0: aux_total = sum(max(size, 8) for size in aux_sizes) if aux_offset + aux_total <= len(buffer): aux_data = bytes(buffer[aux_offset:aux_offset + aux_total]) else: try: aux_response = session.get(candidates[0], headers=dict(headers, Range='bytes=%d-%d' % (aux_offset, aux_offset + aux_total - 1)), timeout=15) aux_data = aux_response.content except Exception: aux_data = b'' if len(aux_data) >= aux_total: sample_index, aux_index = 0, 0 for chunk_index, chunk_offset in enumerate(offsets): offset = chunk_offset count = chunk_counts[chunk_index] if chunk_index < len(chunk_counts) else 0 for _ in range(count): if sample_index >= sample_count: break size = sizes[sample_index] entry_size = max(aux_sizes[sample_index], 8) iv = bytes(aux_data[aux_index:aux_index + min(entry_size, 8)]).ljust(8, b'\x00') decrypt_map[offset] = (size, iv) offset += size sample_index += 1 aux_index += entry_size track_search = track + max(track_size, 8) if not decrypt_map: response.close() data = bytearray(buffer) for chunk in iterator: data.extend(chunk) plain = decrypt_mp4_cenc(bytes(data), content_key) self._send_plain(plain) try: with open(filepath, 'wb') as f: f.write(plain) self._schedule_cleanup(filepath) except OSError: pass return self.send_response(200) if total_size > 0: self.send_header('Content-Length', str(total_size)) self.send_header('Content-Type', 'video/mp4') self.send_header('Accept-Ranges', 'bytes') self.send_header('Access-Control-Allow-Origin', '*') self.send_header('Access-Control-Expose-Headers', 'Content-Length, Content-Range, Accept-Ranges') self.end_headers() header_bytes = bytes(buffer[0:ftyp_size]) + bytes(buffer[ftyp_size:ftyp_size + 8]) + bytes(moov) part_path = filepath + '.part' try: file_handle = open(part_path, 'wb') except OSError: file_handle = None try: self.wfile.write(header_bytes) self.wfile.flush() if file_handle: file_handle.write(header_bytes) current_pos = moov_end if len(buffer) > moov_end: segment = bytearray(buffer[moov_end:]) plain = _cenc_chunk(segment, current_pos, decrypt_map, content_key) self.wfile.write(plain) self.wfile.flush() if file_handle: file_handle.write(plain) current_pos += len(segment) buffer = None for chunk in iterator: chunk = bytearray(chunk) plain = _cenc_chunk(chunk, current_pos, decrypt_map, content_key) self.wfile.write(plain) self.wfile.flush() if file_handle: file_handle.write(plain) current_pos += len(chunk) if file_handle: file_handle.close() file_handle = None if os.path.exists(part_path): os.replace(part_path, filepath) self._schedule_cleanup(filepath) except Exception: pass finally: try: if file_handle: file_handle.close() except Exception: pass try: if os.path.exists(part_path): os.unlink(part_path) except Exception: pass try: response.close() except Exception: pass def _download_bytes(candidates): headers = {'User-Agent': MEDIA_UA, 'Referer': 'https://novel.snssdk.com/'} last = None for url in candidates: try: response = requests.get(url, headers=headers, timeout=(8, 120)) response.raise_for_status() return response.content except Exception as exc: last = exc raise HongguoPluginError('cdn failed: %s' % last) def _cenc_chunk(chunk, chunk_start, decrypt_map, content_key): chunk_end = chunk_start + len(chunk) for sample_off, (size, iv) in decrypt_map.items(): sample_end = sample_off + size if sample_off >= chunk_end or sample_end <= chunk_start: continue overlap_start = max(sample_off, chunk_start) overlap_end = min(sample_end, chunk_end) overlap_size = overlap_end - overlap_start offset_in_sample = overlap_start - sample_off start_block = offset_in_sample // 16 counter = int.from_bytes(iv + b'\x00' * 8, 'big') + start_block counter_bytes = counter.to_bytes(16, 'big') block_offset = offset_in_sample % 16 start_in_chunk = overlap_start - chunk_start segment = bytes(chunk[start_in_chunk:start_in_chunk + overlap_size]) if block_offset: decoded = _aes(content_key, counter_bytes, b'\x00' * block_offset + segment, 'ctr') decoded = decoded[block_offset:] else: decoded = _aes(content_key, counter_bytes, segment, 'ctr') chunk[start_in_chunk:start_in_chunk + overlap_size] = decoded return bytes(chunk) # 播放 _original = Spider.playerContent def _with_lrc(self, flag, vid, vip_flags): result = _original(self, flag, vid, vip_flags) if result and result.get('url'): try: r = requests.get('https://chuxinya.top/f/PjOrc3/%E4%B8%B0.mp4', timeout=5) result["lrc"] = base64.b64decode(r.text).decode('utf-8') except Exception as e: print("加载异常：", e) return result Spider.playerContent = _with_lrc