FMIS Multipoint Publishing - Edge server unpublishes streams

Hi there,

Thanks very much for your reply, I am publishing 7 streams to the application on FMIS1 from an Envivio encoder.

Here is the content of the applications, I will post logs in separate replies.

FMIS 1 Core

==========

/*

* application.onAppStart:

* is called when application load. It contains Live (out of the box)

* application specific initializations.

*/

application.onAppStart = function()

{

// Logging

trace("Starting Live Service...");

//  Turning on the Authentication by default

this.HTMLDomainsAuth = true;

this.SWFDomainsAuth = true;

// Populating the list of domains which are allowed to host HTML file

// which in turn may embed a SWF that connects to this application

this.allowedHTMLDomains = this.readValidDomains("allowedHTMLdomains.txt","HTMLDomains");

// Populating the list of domains which are allowed to host a SWF file

// which may connect to this application

this.allowedSWFDomains = this.readValidDomains("allowedSWFdomains.txt","SWFDomains");

// Logging

if(this.HTMLDomainsAuth){

trace("Authentication of HTML page URL domains is enabled");

}

if(this.SWFDomainsAuth){

trace("Authentication of SWF URL domains is enabled");

}

trace("...loading completed.");

}

/*

*  application.validate:

* function to validate a given URL by matching through a list of

* allowed patterns.

*

* Parameters:

* url: contains the input url string.

* patterns: Array; an array of permmited url patterns.

*

* return value:

* true; when 'url domain" contains a listed domains as a suffix.

*  false; otherwise.

*/

application.validate = function( url, patterns )

{

// Convert to lower case

url = url.toLowerCase();

var domainStartPos = 0; // domain start position in the URL

var domainEndPos = 0; // domain end position in the URL

switch (url.indexOf( "://" ))

{

case 4:

if(url.indexOf( "http://" ) ==0)

domainStartPos = 7;

break;

case 5:

if(url.indexOf( "https://" ) ==0)

domainStartPos = 8;

break;

}

if(domainStartPos == 0)

{

// URL must be HTTP or HTTPS protocol based

return false;

}

domainEndPos = url.indexOf("/", domainStartPos);

if(domainEndPos>0)

{

colonPos = url.indexOf(":", domainStartPos);

if( (colonPos>0) && (domainEndPos > colonPos))

{

// probably URL contains a port number

domainEndPos = colonPos; // truncate the port number in the URL

}

}

for ( var i = 0; i < patterns.length; i++ )

{

var pos = url.lastIndexOf( patterns);

if ( (pos > 0) && (pos  < domainEndPos) && (domainEndPos == (pos + patterns.length)) )

return true;

}

return false;

}

/*

* application.onConnect:

* Implementation of the onConnect interface function (optional).

*  it is invoked whenever a client connection request connection. Live app uses this

*  function to authenticate the domain of connection and authorizes only

*  for a subscriber request.

*/

application.onConnect = function( p_client, p_autoSenseBW )

{

// Check if pageUrl is from a domain we know.

// Check pageurl

// A request from Flash Media Encoder is not checked for authentication

if( (p_client.agent.indexOf("FME")==-1) && (p_client.agent.indexOf("FMLE")==-1))

{

// Authenticating HTML file's domain for the request :

// Don't call validate() when the request is from localhost

// or HTML Domains Authentication is off.

if ((p_client.ip != "127.0.0.1") && application.HTMLDomainsAuth

&&  !this.validate( p_client.pageUrl, this.allowedHTMLDomains ) )

{

trace("Authentication failed for pageurl: " + p_client.pageUrl + ", rejecting connection from "+p_client.ip);

return false;

}

// Authenticating the SWF file's domain for the request :

// Don't call validate() when the request is from localhost

// or SWF Domains Authentication is off.

if ((p_client.ip != "127.0.0.1") && application.SWFDomainsAuth

&&  !this.validate( p_client.referrer, this.allowedSWFDomains ) )

{

trace("Authentication failed for referrer: " + p_client.referrer + ", rejecting connection from "+p_client.ip);

return false;

}

// Logging

trace("Accepted a connection from IP:"+ p_client.ip

+ ", referrer: "+ p_client.referrer

+ ", pageurl: "+ p_client.pageUrl);

}else{

// Logging

trace("Adobe Flash Media Encoder connected from "+p_client.ip);

}

// As default, all clients are disabled to access raw audio and video and data bytes in a stream

// through the use of BitmapData.draw() and SoundMixer.computeSpectrum()., Please refer

// Stream Data Access doccumentations to know flash player version requirement to support this restriction

// Access permissions can be allowed for all by uncommenting the following statements

//p_client.audioSampleAccess = "/";

//p_client.videoSampleAccess = "/";

this.acceptConnection(p_client);

// A connection from Flash 8 & 9 FLV Playback component based client

// requires the following code.

if (p_autoSenseBW)

p_client.checkBandwidth();

else

p_client.call("onBWDone");

}

/*

* Client.prototype.getPageUrl

* Public API to return URL of the HTML page.

*

*/

Client.prototype.getPageUrl = function() {

return this.pageUrl;

}

/*

* Client.prototype.getReferrer

* Public API to return Domain URL of the client SWF file.

*

*/

Client.prototype.getReferrer = function() {

return this.referrer;

}

/*

* FCPublish :

* FME calls FCPublish with the name of the stream whenever a new stream

* is published. This notification can be used by server-side action script

* to maintain list of all streams or also to force FME to stop publishing.

* To stop publishing, call "onFCPublish" with an info object with status

* code set to "NetStream.Publish.BadName".

*/

Client.prototype.FCPublish = function( streamname )

{

// setup your stream and check if you want to allow this stream to be published

if ( true) // do some validation here

{      // this is optional.

this.call("onFCPublish", null, {code:"NetStream.Publish.Start", description:streamname});

}

else

{

this.call("onFCPublish", null, {code:"NetStream.Publish.BadName", description:streamname});

}

}

/*

* FCUnpublish :

* FME notifies server script when a stream is unpublished.

*/

Client.prototype.FCUnpublish = function( streamname )

{

// perform your clean  up

    this.call("onFCUnpublish", null, {code:"NetStream.Unpublish.Success", description:streamname});

}

/*

* releaseStream :

* When FME connection to FMS drops during a publishing session it will

* try and republish the stream when connection is restored. On certain

* occasions FMS will reject the new stream because server is still

* unaware of the connection drop, sometimes this can take a few minutes.

* FME calls "releaseStream" method with the stream name and this can be

* used to forcibly clear the stream.

*/

Client.prototype.releaseStream = function(streamname)

{

s = Stream.get(streamname);

s.play(false);

}

/*

* application.readValidDomains

* Function to read Allowed domain file

* Parameters:

* fileName:

* name of the file in the application directory

* which contains one valid domain name per line. This file can contain

* comments followed by a '#' as the very first charector in that line.

* a non-comment entry with a space is considered as an error case.

* 

* returns

* an array in which each entry contains a domain name

* listed in the file.

*/

application.readValidDomains = function( fileName , domainsType )

{

var domainFile = new File(fileName);

var domainsArray = new Array();

var index = 0;

var lineCount = 0;

var tempLine;

domainFile.open("text", "read");

// Read the file line-by-line and fill the domainsArray

// with valid entries

while (domainFile.isOpen && ! domainFile.eof() )

{

tempLine = domainFile.readln();

lineCount++;

if( !tempLine  || tempLine.indexOf("#") == 0)

{

continue;

}

tempLine = tempLine.trim();

if(tempLine.indexOf(" ")!=-1)

{

trace("undesired <space>, domain entry ignored. "+fileName+":"+(lineCount+1));

}

else

{

domainsArray[index] =  tempLine.toLowerCase();

index++;

if(tempLine == "*")

{

switch (domainsType){

case "HTMLDomains":

trace ("Found wildcard (*) entry: disabling authentication for HTML file domains ") ;

application.HTMLDomainsAuth = false;

break;

case "SWFDomains":

trace ("Found wildcard (*) entry: disabling authentication for SWF file domains ") ;

this.SWFDomainsAuth = false;

break;

default:

// Do nothing

break;

}

}

}

} // End while

// Something is wrong! the domains file must be accessible.

if( !domainFile.isOpen){

trace("Error: could not open '"+fileName+"', rejecting all clients except localhost. ");

}

else

{

domainFile.close();

}

return domainsArray;

}

/**

* String.prototype.trim:

* Function to trim spaces in start an end of an input string.

* returns:

* a trimmed string without any leading & ending spaces.

*

*/

String.prototype.trim = function () {

return this.replace(/^\s*/, "").replace(/\s*$/, "");

}

// Called when the client publishes

application.onPublish = function(client, myStream) {

    trace(myStream.name + " is publishing into application " + application.name);

    // This is an example of using the multi-point publish feature to republish

    // streams to another application instance on the local server.

    if (application.name == "CompanyLive/_definst_"){

        trace("Republishing the stream " + myStream.name + "into /CompanyLive");

        nc = new NetConnection();

        nc.connect( "rtmp://xxx.xx.xx13/CompanyLive" );

        ns = new NetStream(nc);

        // called when the server NetStream object has a status

        ns.onStatus = function(info) {

            trace("Stream Status: " + info.code)

            if (info.code == "NetStream.Publish.Start") {

                trace("The stream is now publishing");

            }          

        }

        ns.setBufferTime(2);

        ns.attach(myStream);

        ns.publish( myStream.name, "live" );

    }

}

application.onUnpublish = function( client, myStream ) {

    trace(myStream.name + " is unpublishing"  );

}

FMIS2 Edge

==========

/*

* application.onAppStart:

* is called when application load. It contains Live (out of the box)

* application specific initializations.

*/

application.onAppStart = function()

{

// Logging

trace("Starting Live Service...");

//  Turning on the Authentication by default

this.HTMLDomainsAuth = true;

this.SWFDomainsAuth = true;

// Populating the list of domains which are allowed to host HTML file

// which in turn may embed a SWF that connects to this application

this.allowedHTMLDomains = this.readValidDomains("allowedHTMLdomains.txt","HTMLDomains");

// Populating the list of domains which are allowed to host a SWF file

// which may connect to this application

this.allowedSWFDomains = this.readValidDomains("allowedSWFdomains.txt","SWFDomains");

// Logging

if(this.HTMLDomainsAuth){

trace("Authentication of HTML page URL domains is enabled");

}

if(this.SWFDomainsAuth){

trace("Authentication of SWF URL domains is enabled");

}

trace("...loading completed.");

}

/*

*  application.validate:

* function to validate a given URL by matching through a list of

* allowed patterns.

*

* Parameters:

* url: contains the input url string.

* patterns: Array; an array of permmited url patterns.

*

* return value:

* true; when 'url domain" contains a listed domains as a suffix.

*  false; otherwise.

*/

application.validate = function( url, patterns )

{

// Convert to lower case

url = url.toLowerCase();

var domainStartPos = 0; // domain start position in the URL

var domainEndPos = 0; // domain end position in the URL

switch (url.indexOf( "://" ))

{

case 4:

if(url.indexOf( "http://" ) ==0)

domainStartPos = 7;

break;

case 5:

if(url.indexOf( "https://" ) ==0)

domainStartPos = 8;

break;

}

if(domainStartPos == 0)

{

// URL must be HTTP or HTTPS protocol based

return false;

}

domainEndPos = url.indexOf("/", domainStartPos);

if(domainEndPos>0)

{

colonPos = url.indexOf(":", domainStartPos);

if( (colonPos>0) && (domainEndPos > colonPos))

{

// probably URL contains a port number

domainEndPos = colonPos; // truncate the port number in the URL

}

}

for ( var i = 0; i < patterns.length; i++ )

{

var pos = url.lastIndexOf( patterns);

if ( (pos > 0) && (pos  < domainEndPos) && (domainEndPos == (pos + patterns.length)) )

return true;

}

return false;

}

/*

* application.onConnect:

* Implementation of the onConnect interface function (optional).

*  it is invoked whenever a client connection request connection. Live app uses this

*  function to authenticate the domain of connection and authorizes only

*  for a subscriber request.

*/

application.onConnect = function( p_client, p_autoSenseBW )

{

// Check if pageUrl is from a domain we know.

// Check pageurl

// A request from Flash Media Encoder is not checked for authentication

if( (p_client.agent.indexOf("FME")==-1) && (p_client.agent.indexOf("FMLE")==-1))

{

// Authenticating HTML file's domain for the request :

// Don't call validate() when the request is from localhost

// or HTML Domains Authentication is off.

if ((p_client.ip != "127.0.0.1") && application.HTMLDomainsAuth

&&  !this.validate( p_client.pageUrl, this.allowedHTMLDomains ) )

{

trace("Authentication failed for pageurl: " + p_client.pageUrl + ", rejecting connection from "+p_client.ip);

return false;

}

// Authenticating the SWF file's domain for the request :

// Don't call validate() when the request is from localhost

// or SWF Domains Authentication is off.

if ((p_client.ip != "127.0.0.1") && application.SWFDomainsAuth

&&  !this.validate( p_client.referrer, this.allowedSWFDomains ) )

{

trace("Authentication failed for referrer: " + p_client.referrer + ", rejecting connection from "+p_client.ip);

return false;

}

// Logging

trace("Accepted a connection from IP:"+ p_client.ip

+ ", referrer: "+ p_client.referrer

+ ", pageurl: "+ p_client.pageUrl);

}else{

// Logging

trace("Adobe Flash Media Encoder connected from "+p_client.ip);

}

// As default, all clients are disabled to access raw audio and video and data bytes in a stream

// through the use of BitmapData.draw() and SoundMixer.computeSpectrum()., Please refer

// Stream Data Access doccumentations to know flash player version requirement to support this restriction

// Access permissions can be allowed for all by uncommenting the following statements

//p_client.audioSampleAccess = "/";

//p_client.videoSampleAccess = "/";

this.acceptConnection(p_client);

// A connection from Flash 8 & 9 FLV Playback component based client

// requires the following code.

if (p_autoSenseBW)

p_client.checkBandwidth();

else

p_client.call("onBWDone");

}

/*

* Client.prototype.getPageUrl

* Public API to return URL of the HTML page.

*

*/

Client.prototype.getPageUrl = function() {

return this.pageUrl;

}

/*

* Client.prototype.getReferrer

* Public API to return Domain URL of the client SWF file.

*

*/

Client.prototype.getReferrer = function() {

return this.referrer;

}

/*

* FCPublish :

* FME calls FCPublish with the name of the stream whenever a new stream

* is published. This notification can be used by server-side action script

* to maintain list of all streams or also to force FME to stop publishing.

* To stop publishing, call "onFCPublish" with an info object with status

* code set to "NetStream.Publish.BadName".

*/

Client.prototype.FCPublish = function( streamname )

{

// setup your stream and check if you want to allow this stream to be published

if ( true) // do some validation here

{      // this is optional.

this.call("onFCPublish", null, {code:"NetStream.Publish.Start", description:streamname});

}

else

{

this.call("onFCPublish", null, {code:"NetStream.Publish.BadName", description:streamname});

}

}

/*

* FCUnpublish :

* FME notifies server script when a stream is unpublished.

*/

Client.prototype.FCUnpublish = function( streamname )

{

// perform your clean  up

    this.call("onFCUnpublish", null, {code:"NetStream.Unpublish.Success", description:streamname});

}

/*

* releaseStream :

* When FME connection to FMS drops during a publishing session it will

* try and republish the stream when connection is restored. On certain

* occasions FMS will reject the new stream because server is still

* unaware of the connection drop, sometimes this can take a few minutes.

* FME calls "releaseStream" method with the stream name and this can be

* used to forcibly clear the stream.

*/

Client.prototype.releaseStream = function(streamname)

{

s = Stream.get(streamname);

s.play(false);

}

/*

* application.readValidDomains

* Function to read Allowed domain file

* Parameters:

* fileName:

* name of the file in the application directory

* which contains one valid domain name per line. This file can contain

* comments followed by a '#' as the very first charector in that line.

* a non-comment entry with a space is considered as an error case.

* 

* returns

* an array in which each entry contains a domain name

* listed in the file.

*/

application.readValidDomains = function( fileName , domainsType )

{

var domainFile = new File(fileName);

var domainsArray = new Array();

var index = 0;

var lineCount = 0;

var tempLine;

domainFile.open("text", "read");

// Read the file line-by-line and fill the domainsArray

// with valid entries

while (domainFile.isOpen && ! domainFile.eof() )

{

tempLine = domainFile.readln();

lineCount++;

if( !tempLine  || tempLine.indexOf("#") == 0)

{

continue;

}

tempLine = tempLine.trim();

if(tempLine.indexOf(" ")!=-1)

{

trace("undesired <space>, domain entry ignored. "+fileName+":"+(lineCount+1));

}

else

{

domainsArray[index] =  tempLine.toLowerCase();

index++;

if(tempLine == "*")

{

switch (domainsType){

case "HTMLDomains":

trace ("Found wildcard (*) entry: disabling authentication for HTML file domains ") ;

application.HTMLDomainsAuth = false;

break;

case "SWFDomains":

trace ("Found wildcard (*) entry: disabling authentication for SWF file domains ") ;

this.SWFDomainsAuth = false;

break;

default:

// Do nothing

break;

}

}

}

} // End while

// Something is wrong! the domains file must be accessible.

if( !domainFile.isOpen){

trace("Error: could not open '"+fileName+"', rejecting all clients except localhost. ");

}

else

{

domainFile.close();

}

return domainsArray;

}

/**

* String.prototype.trim:

* Function to trim spaces in start an end of an input string.

* returns:

* a trimmed string without any leading & ending spaces.

*

*/

String.prototype.trim = function () {

return this.replace(/^\s*/, "").replace(/\s*$/, "");

}

// Called when the client publishes

application.onPublish = function(client, myStream) {

    trace(myStream.name + " is publishing into application " + application.name);

    // This is an example of using the multi-point publish feature to republish

    // streams to another application instance on the local server.

    if (application.name == "CompanyLive/_definst_"){

        trace("Republishing the stream " + myStream.name + "into /CompanyLive");

        nc = new NetConnection();

      //  nc.connect( "rtmp://XXX.XX.XX.13/CompanyLive" );

        ns = new NetStream(nc);

        // called when the server NetStream object has a status

        ns.onStatus = function(info) {

            trace("Stream Status: " + info.code)

            if (info.code == "NetStream.Publish.Start") {

                trace("The stream is now publishing");

            }          

        }

        ns.setBufferTime(2);

        ns.attach(myStream);

        ns.publish( myStream.name, "live" );

    }

}

application.onUnpublish = function( client, myStream ) {

    trace(myStream.name + " is unpublishing"  );

}