diff --git a/modules/playready.py b/modules/playready.py index 25a4333..da0d584 100644 --- a/modules/playready.py +++ b/modules/playready.py @@ -91,92 +91,89 @@ class PLAYREADY: # ============================================================================================================================== # - def get_challenges(self, device): - try: - session_entry = self.store_session.get(device) - if not session_entry or "cdm" not in session_entry: - return jsonify({"responseData": {"message": f"No Cdm session for {device} has been opened yet. No session to use."}}), 400 - - cdm = session_entry["cdm"] - self.logging.debug(f"[DEBUG] get_challenges - CDM stato prima: {cdm.__dict__}") +def get_challenges(self, device): + try: + # Retrieve the session entry for the given device + session_entry = self.store_session.get(device) + if not session_entry or "cdm" not in session_entry: + return jsonify({"responseData": {"message": f"No CDM session for {device} has been opened yet. No session to use."}}), 400 + + cdm = session_entry["cdm"] + self.logging.debug(f"[DEBUG] get_challenges - CDM state before: {cdm.__dict__}") - # Usa l'ID della sessione memorizzato - stored_session_id = bytes.fromhex(session_entry["session_id"]) - - self.logging.debug(f"[DEBUG] get_challenges - Using stored session ID: {stored_session_id.hex()}") - - wrm_header = None - - # Verifica prima se il PSSH è già un WRM header - if self.pssh.startswith('') + len('') - if start_idx >= 0 and end_idx > start_idx: - wrm_header = decoded_str[start_idx:end_idx] - self.logging.debug(f"[DEBUG] WRM header estratto dal PSSH decodificato") - - # Se non è stato trovato un WRM header nel contenuto decodificato, prova con l'analisi standard - if not wrm_header: - self.logging.debug(f"[DEBUG] Tentativo di analizzare PSSH come PSSH box") - pssh = PSSH(self.pssh) - if pssh.wrm_headers: - wrm_header = pssh.wrm_headers[0] - self.logging.debug(f"[DEBUG] Analisi PSSH riuscita, estratto WRM header") - else: - self.logging.debug(f"[DEBUG] Analisi PSSH riuscita, ma nessun WRM header trovato") - except Exception as e: - self.logging.error(f"[ERROR] Errore nell'analisi PSSH: {str(e)}") - self.logging.debug(f"[DEBUG] Tentativo di usare il PSSH così com'è") - wrm_header = self.pssh # Usa il PSSH così com'è come ultimo tentativo - - if not wrm_header: - self.logging.error(f"[ERROR] Impossibile estrarre un WRM header valido dal PSSH") - return jsonify({"responseData": {"message": "Unable to extract a valid WRM header from PSSH"}}), 500 + # Use the stored session ID + stored_session_id = bytes.fromhex(session_entry["session_id"]) + self.logging.debug(f"[DEBUG] get_challenges - Using stored session ID: {stored_session_id.hex()}") + wrm_header = None + + # Check if the PSSH is already a WRM header + if self.pssh.startswith('') + len('') + if start_idx >= 0 and end_idx > start_idx: + wrm_header = decoded_str[start_idx:end_idx] + self.logging.debug(f"[DEBUG] WRM header extracted from decoded PSSH") + + # If no WRM header was found in the decoded content, try standard parsing + if not wrm_header: + self.logging.debug(f"[DEBUG] Attempting to parse PSSH as a PSSH box") + pssh = PSSH(self.pssh) + if pssh.wrm_headers: + wrm_header = pssh.wrm_headers[0] + self.logging.debug(f"[DEBUG] PSSH parsing successful, extracted WRM header") + else: + self.logging.debug(f"[DEBUG] PSSH parsing successful, but no WRM header found") except Exception as e: - self.logging.error(f"[ERROR] Errore durante la generazione del challenge: {str(e)}, {type(e)}") - import traceback - self.logging.error(traceback.format_exc()) - return jsonify({"responseData": {"message": f"Error generating challenge: {str(e)}"}}), 500 + self.logging.error(f"[ERROR] Error parsing PSSH: {str(e)}") + self.logging.debug(f"[DEBUG] Attempting to use PSSH as-is") + wrm_header = self.pssh # Use the PSSH as-is as a last resort + + if not wrm_header: + self.logging.error(f"[ERROR] Unable to extract a valid WRM header from PSSH") + return jsonify({"responseData": {"message": "Unable to extract a valid WRM header from PSSH"}}), 500 - response_data = {"challenge_b64": base64.b64encode(license_request.encode() if isinstance(license_request, str) else license_request).decode()} - return jsonify({"responseData": response_data}), 200 + try: + self.logging.debug(f"[DEBUG] Requesting challenge with session_id={stored_session_id.hex()} and WRM header={wrm_header[:50]}...") + license_request = cdm.get_license_challenge(session_id=stored_session_id, wrm_header=wrm_header) + + # Verify that the license request was stored in the session + session = cdm._Cdm__sessions.get(stored_session_id) + if session and hasattr(session, 'license_request') and session.license_request: + self.logging.debug(f"[DEBUG] License request was successfully stored in the session") + else: + self.logging.error(f"[ERROR] License request was NOT stored in the session!") + + # Attempt to manually store the license request in the session + if session: + self.logging.debug(f"[DEBUG] Attempting to manually store the license request") + session.license_request = license_request + session.header = wrm_header if isinstance(wrm_header, bytes) else wrm_header.encode('utf-8') + self.logging.debug(f"[DEBUG] License request manually stored in the session") + + except InvalidSession as e: + self.logging.error(f"[ERROR] Invalid Session ID '{stored_session_id.hex()}': {str(e)}") + return jsonify({"responseData": {"message": f"Invalid Session ID '{stored_session_id.hex()}', it may have expired. Error: {str(e)}"}}), 400 except Exception as e: - self.logging.error(f"[ERROR] Errore generale in get_challenges: {str(e)}") - import traceback - self.logging.error(traceback.format_exc()) - return jsonify({"responseData": {"message": f"Errore generale: {str(e)}"}}), 500 + self.logging.error(f"[ERROR] Error generating challenge: {str(e)}, {type(e)}") + return jsonify({"responseData": {"message": f"Error generating challenge: {str(e)}"}}), 500 + + # Encode the license request in base64 and return it + response_data = {"challenge_b64": base64.b64encode(license_request.encode() if isinstance(license_request, str) else license_request).decode()} + return jsonify({"responseData": response_data}), 200 + except Exception as e: + self.logging.error(f"[ERROR] General error in get_challenges: {str(e)}") + return jsonify({"responseData": {"message": f"Error generating challenge: {str(e)}"}}), 500 @@ -187,15 +184,15 @@ class PLAYREADY: session_entry = self.store_session.get(device) if not session_entry or "cdm" not in session_entry: self.logging.debug(f"[DEBUG] No CDM session found for device: {device}") - return jsonify({"responseData": {"message": f"No Cdm session for {device} has been opened yet. No session to use."}}), 400 - + return jsonify({"responseData": {"message": f"No CDM session for {device} has been opened yet. No session to use."}}), 400 + cdm = session_entry["cdm"] - # Controlla lo stato del CDM prima dell'operazione - self.logging.debug(f"[DEBUG] CDM stato prima: {cdm.__dict__}") + # Check the state of the CDM before the operation + self.logging.debug(f"[DEBUG] CDM state before: {cdm.__dict__}") self.logging.debug(f"[DEBUG] Store sessions: {self.store_session}") - # Usa l'ID della sessione memorizzato + # Use the stored session ID stored_session_id = bytes.fromhex(session_entry["session_id"]) self.logging.debug(f"[DEBUG] Using stored session ID: {stored_session_id.hex()}") @@ -203,16 +200,8 @@ class PLAYREADY: if not isinstance(self.license, str) or not self.license.strip(): self.logging.debug("[DEBUG] Invalid or empty license_message") return jsonify({"responseData": {"message": "Invalid or empty license_message."}}), 400 - + try: - # Verifica se esiste una sessione e se ha una richiesta di licenza associata - # Commentato per test - # session = cdm._Cdm__sessions.get(stored_session_id) - # if not session or not hasattr(session, 'license_request') or not session.license_request: - # self.logging.error(f"[ERROR] La sessione non ha una richiesta di licenza associata. È necessario chiamare get_challenge prima di get_keys.") - # return jsonify({"responseData": {"message": "È necessario effettuare prima una richiesta di licenza con get_challenge per questa sessione."}}), 400 - - # Continuare con il tentativo di ottenere le chiavi, anche se la license_request non è stata memorizzata self.logging.info(f"Parsing license for session {stored_session_id.hex()} on device {device}") decoded_license = base64.b64decode(self.license).decode("utf-8", errors="ignore") self.logging.debug(f"[DEBUG] Decoded license: {decoded_license[:50]}...") @@ -220,26 +209,26 @@ class PLAYREADY: try: cdm.parse_license(stored_session_id, decoded_license) except Exception as e: - self.logging.error(f"[ERROR] Errore durante parse_license: {str(e)}") + self.logging.error(f"[ERROR] Error during parse_license: {str(e)}") try: keys = cdm.get_keys(stored_session_id) response_keys = [ { - "key_id": key.key_id.hex, + "key_id": key.key_id.hex(), "key": key.key.hex(), } for key in keys ] self.logging.debug(f"[DEBUG] Extracted keys: {response_keys}") except Exception as e: - self.logging.error(f"[ERROR] Errore durante get_keys: {str(e)}") + self.logging.error(f"[ERROR] Error during get_keys: {str(e)}") import traceback self.logging.error(traceback.format_exc()) return jsonify({"responseData": {"message": f"Error getting keys: {str(e)}"}}), 500 - + except InvalidSession as e: - self.logging.debug(f"[DEBUG] Invalid Session ID '{stored_session_id.hex()}', possibly expired. Errore: {str(e)}") + self.logging.debug(f"[DEBUG] Invalid Session ID '{stored_session_id.hex()}', possibly expired. Error: {str(e)}") return jsonify({"responseData": {"message": f"Invalid Session ID '{stored_session_id.hex()}', it may have expired."}}), 400 except InvalidLicense as e: self.logging.debug(f"[DEBUG] Invalid License: {e}") @@ -247,7 +236,7 @@ class PLAYREADY: except Exception as e: self.logging.debug(f"[DEBUG] Unexpected error: {e}") return jsonify({"responseData": {"message": f"Error, {e}"}}), 500 - + return jsonify({ "responseData": { "message": "Successfully parsed and loaded the Keys from the License message.",