import os,sys; sys.path.append(os.path.abspath(os.path.join(os.path.abspath(os.path.join(os.path.dirname(__file__),'..')),'..'))) from komrade import * from komrade.backend import * def is_valid_msg_d(msg_d): if not type(msg_d)==dict: return False to_name=msg_d.get('_to_name') to_pub=msg_d.get('_to_pub') from_name=msg_d.get('_from_name') from_pub=msg_d.get('_from_pub') msg=msg_d.get('_msg') if to_name and to_pub and from_name and from_pub and msg: return True return False class Message(Logger): def __init__(self,msg_d,from_whom=None,to_whom=None,messenger=None,embedded_msg=None,is_encrypted=False): # check input if not is_valid_msg_d(msg_d): raise KomradeException('This is not a valid msg_d:',msg_d) # set fields self.msg_d=msg_d self.to_name=msg_d.get('_to_name') self.to_pubkey=msg_d.get('_to_pub') self.from_name=msg_d.get('_from_name') self.from_pubkey=msg_d.get('_from_pub') self.msg=msg_d.get('_msg') self.embedded_msg=embedded_msg # only if this message has an embedded one self._route=msg_d.get(ROUTE_KEYNAME) self._from_whom=from_whom self._to_whom=to_whom self.messenger=None self._is_encrypted=None # get operators straight away? if not self._from_whom or not self._to_whom: self.get_whoms() @property def data(self): md={} msg_d=self.msg_d while msg_d: for k,v in msg_d.items(): md[k]=v msg_d = msg_d.get('_msg',{}) if type(msg_d)!=dict: msg_d=None if '_msg' in md and type(md['_msg']) == dict: del md['_msg'] del md[ROUTE_KEYNAME] return md def mark_return_to_sender(self): self._from_whom,self._to_whom = self._to_whom,self._from_whom self.msg_d['_from_pub'],self.msg_d['_to_pub'] = self.msg_d['_to_pub'],self.msg_d['_from_pub'], self.msg_d['_from_name'],self.msg_d['_to_name'] = self.msg_d['_to_name'],self.msg_d['_from_name'], def __repr__(self): msg_d_str=dict_format(self.msg_d,tab=6) return f""" self.from_whom={self.from_whom} self.to_whom={self.to_whom} self.msg_d={msg_d_str} """ def get_whom(self,name): from komrade.backend.operators import locate_an_operator return locate_an_operator(name) @property def from_whom(self): if not self._from_whom: self._from_whom,self._to_whom = self.get_from_whoms() return self._from_whom @property def to_whom(self): if not self._to_whom: self._from_whom,self._to_whom = self.get_from_whoms() return self._to_whom ## loading messages def get_whoms(self): if self._from_whom is not None and self._to_whom is not None: return (self._from_whom,self._to_whom) alleged_from_whom = self.get_whom(self.from_name) alleged_to_whom = self.get_whom(self.to_name) if not self.whom_records_match(alleged_from_whom,alleged_to_whom): raise KomradeException('Records of from_whoms on The Operator and the from_whom do not match. Something fishy going on?') else: self._from_whom = alleged_from_whom self._to_whom = alleged_to_whom return (self._from_whom,self._to_whom) def whom_records_match(self,alleged_from_whom,alleged_to_whom): alleged_from_whom_name = self.from_name alleged_from_whom_pubkey = self.from_pubkey alleged_to_whom_name = self.to_name alleged_to_whom_pubkey = self.to_pubkey # self.log('from_whom names:',alleged_from_whom.name, alleged_from_whom_name) # self.log('from_whom pubs:',alleged_from_whom.pubkey, alleged_from_whom_pubkey) # self.log('to_whom names:',alleged_to_whom.name, alleged_to_whom_name) # self.log('to_whom pubs:',alleged_to_whom.pubkey, alleged_to_whom_pubkey) if alleged_to_whom.name != alleged_to_whom_name: return False if alleged_from_whom.name != alleged_from_whom_name: return False if alleged_to_whom.pubkey != alleged_to_whom_pubkey: return False if alleged_from_whom.pubkey != alleged_from_whom_pubkey: return False return True def decrypt(self,recursive=False): # if not self.is_encrypted: return # get from_whoms self.log(f'attempting to decrypt {self}') # decrypt msg decr_msg_b = SMessage( self.to_whom.privkey, self.from_whom.pubkey ).unwrap(self.msg) self.log('Am I decrypted?',decr_msg_b) decr_msg = pickle.loads(decr_msg_b) self.log('unpickled:',decr_msg) self.msg_encr = self.msg self.msg = decr_msg self.msg_d['_msg'] = decr_msg # self.log('got decr msg back:',decr_msg) # now, is the decrypted message itself a message? if is_valid_msg_d(decr_msg): self.log('this is a valid msg in its own right!',decr_msg) # then ... make that, a message object and decrypt it too! self.msg = Message(decr_msg) # for now this should be rolled out individually ,like an onion # ring_ring on client -> pronto_pronto on server # so we don't need or want to decrypt all at once if recursive: self.msg.decrypt() self.log(f'done decrypting! {self}') return decr_msg @property def is_encrypted(self): return type(self.msg) == bytes # if self.msg._is_encrypted is not None: # return self.msg._is_encrypted def encrypt(self): # each child message should already be encrypted before coming to its parent message ,recursive=False): if self._is_encrypted: return # self.log(f'attempting to encrypt msg {self.msg} from {self.from_whom} to {self.to_whom}') self.log(f'About to encrypt self.msg! I now look like v1: {self}') # binarize msg msg_b = pickle.dumps(self.msg) # self.log('msg_b = ',msg_b) # encrypt it! msg_encr = SMessage( self.from_whom.privkey, self.to_whom.pubkey, ).wrap(msg_b) self.msg_decr = self.msg self.msg = msg_encr self.msg_d['_msg'] = msg_encr self.log(f'Encrypted! I now look like v2: {self}') self._is_encrypted = True ## msg properties @property def has_embedded_msg(self): return type(self.msg) == Message @property def messages(self): # move through msgs recursively def _msgs(): msg=self while True: yield msg if msg.has_embedded_msg: msg=msg.msg break return list(_msgs()) @property def route(self): if type(self.msg)==dict: rte=self.msg.get(ROUTE_KEYNAME) if rte: return rte if self.has_embedded_msg: return self.msg.route return None def test_msg(): phone = TheTelephone() op = TheOperator() pprint(op.pubkey) print('?keychains?') pprint(phone.pubkey) msg={'_route':'forge_new_keys'} resp_msp_obj = phone.ring_ring(msg) print(resp_msp_obj) if __name__ == '__main__': test_msg()