Support for Tivos with multiple local IPs

[vladger]

Hello. I have an issue with this software. After setup, with p12 and password, the server is unable to connect to my Tivo Roamio Pro, due to it using two separate local IP addresses on my network: one for the tivo itself (for example 192.168.137.28) and one for the stream with 49152 port (for example 192.168.137.166). There is only one .env variable for Tivo IP address. When i enter the Tivo IP, it gives an error connecting to transcoder. When i enter the Stream IP, it starts proxy but then gives an error connecting to Tivo / getting recordings. Suggestion: add the option to use two IPs using multiple variables.

[lart2150]

When I wrote this it has the assumption both devices are the same like a bolt or edge. I don't have a setup where I can test it but if you change the following in /src/index.ts

proxy({ '/session-streaming': { target: http://${process.env.TIVO_IP ?? ''}:49152, changeOrigin: true } })
to
proxy({ '/session-streaming': { target: http://${process.env.STREAM_IP ?? process.env.TIVO_IP ?? ''}:49152, changeOrigin: true } })

and then set STREAM_IP to the ip of your stream does it work?

[vladger]

Still issues connecting. When script checks tivo IP (no 49152), it gets into this error:

getting tivo
new connection
connecting to tivo
waiting on auth response
getting tivo
[HPM] Proxy created: /session-streaming  -> http://192.168.137.90:49152
info: Server started on port 8000
got auth response
waiting for promise
file:///D:/Downloads/tv-stream-api-main/tv-stream-api-main/src/util/tivo.ts:1
var __defProp=Object.defineProperty;var __name=(target,value)=>__defProp(target,"name",{value,configurable:true});import tls from"node:tls";import fs from"node:fs";import{URL}from"node:url";class Tivo{static{__name(this,"Tivo")}ip;rpcId;mak;sessionID="";bodyId="";socket;data="";received;bodyLength=-1;body="";chunkCount=0;promise;constructor(ip,mak){this.rpcId=0;this.ip=ip;this.mak=mak}async connect(){console.log("connecting to tivo");this.disconnect();const options={host:this.ip,rejectUnauthorized:false,port:1413,pfx:fs.readFileSync("cdata.p12"),passphrase:fs.readFileSync("cdata.password"),ciphers:"DEFAULT@SECLEVEL=0"};this.sessionID=Math.floor(Math.random()*72736+2539520).toString(16);const promise=new Promise((resolve,reject)=>{this.received=resolve;try{this.socket=tls.connect(options,()=>{if(this.socket){this.socket.setEncoding("utf8");this.socket.write(this.buildRequest({"type":"bodyAuthenticate","credential":{"type":"makCredential","key":this.mak}}));this.data="";this.socket.on("data",this.read.bind(this))}});this.socket.on("error",err=>{if(this.socket){this.socket.end()}reject(err)})}catch(e){reject(e)}});console.log("waiting on auth response");const response=await promise;this.received=void 0;this.promise=void 0;console.log("got auth response");const bodyResponse=await this.sendRequest({type:"bodyConfigSearch","bodyId":"-"});this.bodyId=bodyResponse.bodyConfig[0].bodyId}async sendRequestAllPages(content,responseKey,count=50){content.count=50;let response=await this.sendRequest(content);const combinedResponse=response;let offset=count;while(response.isBottom===false){content.offset=offset;offset+=count;response=await this.sendRequest(content);combinedResponse[responseKey]=combinedResponse[responseKey].concat(response[responseKey])}return combinedResponse}async sendRequest(content){while(this.promise){console.log("waiting for promise");await this.promise}this.bodyLength=-1;this.body="";this.data="";const request=this.buildRequest(content);this.promise=new Promise((resolve,reject)=>{this.received=resolve;if(!this.isConnected()){this.connect().then(()=>{if(this.socket){this.socket.write(request)}else{reject("no connection?")}})}else{if(this.socket){this.socket.write(request)}else{reject("no connection?")}}});const response=await this.promise;this.promise=void 0;this.received=void 0;const responseBody=JSON.parse(response);if(responseBody.type==="error"){throw new Error(response)}return responseBody}isConnected(){return this.socket?.writable}disconnect(){if(this.socket?.writable){this.socket.end();if(this.received){this.received("{}");this.received=void 0}}}read(chunk){if(chunk.indexOf("MRPC/2 ")===0){const header=chunk.split("\r\n")[0];this.bodyLength=Number.parseInt(header.split(" ")[2],10);this.body=chunk.split("\r\n\r\n")[1];this.chunkCount=1}else if(this.bodyLength){this.chunkCount++;this.body+=chunk}this.data+=chunk;if(this.received&&this.body&&Buffer.byteLength(this.body,"utf8")>=this.bodyLength){this.received(this.body)}}buildRequest(content){const eol="\r\n";let SchemaVersion=21;if(typeof content.SchemaVersion==="number"){SchemaVersion=content.SchemaVersion;content.SchemaVersion=void 0}if(!content.bodyId&&this.bodyId){content.bodyId=this.bodyId}let bodyIdHeader="";if(this.bodyId){bodyIdHeader=`BodyId: ${this.bodyId}${eol}`}const header="Type: request"+eol+`RpcId: ${this.rpcId++}`+eol+"SchemaVersion: "+SchemaVersion+eol+"Content-Type: application/json"+eol+`RequestType: ${content.type}`+eol+bodyIdHeader+"ResponseCount: single"+eol+eol;const body=JSON.stringify(content)+"\n";return"MRPC/2 "+header.length+" "+body.length+eol+header+body}sendKey(key,options={}){return this.sendRequest({type:"keyEventSend",event:key,...options})}configSearch(options={}){return this.sendRequest({type:"bodyConfigSearch",...options})}tunerState(options={}){return this.sendRequest({type:"tunerStateEventRegister",...options})}whatsOn(options={}){return this.sendRequest({type:"whatsOnSearch",...options})}phoneHome(options={}){return this.sendRequest({type:"phoneHomeRequest",...options})}phoneHomeStatus(options={}){return this.sendRequest({type:"phoneHomeStatusEventRegister",...options})}systemInformation(options={}){return this.sendRequest({type:"systemInformationGet",...options})}uiNavigate(uri,options={}){return this.sendRequest({type:"uiNavigate",uri,...options})}getChannelList(options={}){return this.sendRequest({type:"channelSearch",noLimit:"true",...options})}getRecordingInfo(recordingId){return this.sendRequest({type:"recordingSearch",recordingId})}async getAllRecordings(){const response=await this.sendRequest({type:"recordingFolderItemSearch"});const recordings=[];const allRecordings=new Map;for(const folderItem of response.recordingFolderItem){if(folderItem.collectionType==="series"&&folderItem.folderType!=="suggestion"){const collectionRecordings=await this.sendRequestAllPages({type:"recordingSearch",collectionId:folderItem.collectionId,state:["inProgress","complete"],count:50},"recording");for(const recording of collectionRecordings.recording){if(!allRecordings.has(recording.recordingId)){allRecordings.set(recording.recordingId,recording.recordingId);recordings.push(recording)}}}else if(folderItem.folderType!=="suggestion"){const sRecording=await this.getRecordingInfo(folderItem.childRecordingId);for(const recording of sRecording.recording){if(!allRecordings.has(recording.recordingId)){allRecordings.set(recording.recordingId,recording.recordingId);recordings.push(recording)}}}else if(folderItem.recordingFolderItemId){const folderItems=await this.sendRequest({type:"recordingFolderItemSearch",parentRecordingFolderItemId:folderItem.recordingFolderItemId});for(const folderItem2 of folderItems.recordingFolderItem){const fRecording=await this.getRecordingInfo(folderItem2.childRecordingId);for(const recording of fRecording.recording){if(!allRecordings.has(recording.recordingId)){allRecordings.set(recording.recordingId,recording.recordingId);recordings.push(recording)}}}}}return recordings}async getDownloadUrlForRecording(recordingId,useTs=true){const recordingMeta=await this.sendRequest({type:"idSearch",objectId:recordingId,namespace:"mfs"});const downloadId=recordingMeta.objectId[0].replace("mfs:rc.","");const dUrl=new URL("http://localhost/download/download.TiVo?Container=%2FNowPlaying");dUrl.password=this.mak;dUrl.username="tivo";dUrl.host=this.ip;dUrl.searchParams.append("id",downloadId);useTs&&dUrl.searchParams.append("Format","video/x-tivo-mpeg-ts");return dUrl.toString()}async reboot(){let response=await this.uiNavigate("x-tivo:classicui:restartDvr");await new Promise(resolve=>setTimeout(resolve,5e3));response=await this.sendKey("thumbsDown");response=await this.sendKey("thumbsDown");response=await this.sendKey("thumbsDown");response=await this.sendKey("enter")}}export{Tivo};
                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                

TypeError: response.recordingFolderItem is not iterable
    at Tivo.getAllRecordings (d:\Downloads\tv-stream-api-main\tv-stream-api-main\src\util\tivo.ts:310:43)
    at process.processTicksAndRejections (node:internal/process/task_queues:95:5)
    at getRecordings (d:\Downloads\tv-stream-api-main\tv-stream-api-main\src\route\getMyShows.ts:12:12)

Node.js v18.16.0

if the both variables are set to Stream (ip with with 49152 port) it cannot connect to 1413 port on tivo (it's not on the stream IP):

getting tivo
new connection
connecting to tivo
waiting on auth response
getting tivo
[HPM] Proxy created: /session-streaming  -> http://192.168.137.90:49152
info: Server started on port 8000
node:internal/process/promises:288
            triggerUncaughtException(err, true /* fromPromise */);
            ^

Error: connect ETIMEDOUT 192.168.137.90:1413
    at __node_internal_captureLargerStackTrace (node:internal/errors:490:5)
    at __node_internal_exceptionWithHostPort (node:internal/errors:668:12)
    at TCPConnectWrap.afterConnect [as oncomplete] (node:net:1494:16) {
  errno: -4039,
  code: 'ETIMEDOUT',
  syscall: 'connect',
  address: '192.168.137.90',
  port: 1413
}