package org.red5.server.webapp.test;

import org.red5.server.adapter.ApplicationAdapter;
import org.red5.server.api.IConnection;
import org.red5.server.api.IScope;
import org.red5.server.api.stream.IPlayItem;
import org.red5.server.api.stream.IServerStream;
import org.red5.server.api.stream.IStreamCapableConnection;
import org.red5.server.api.stream.support.SimpleBandwidthConfigure;
import org.red5.server.api.stream.support.SimplePlayItem;
import org.red5.server.api.stream.support.StreamUtils;

public class Application extends ApplicationAdapter {
	private IServerStream serverStream;
	private IScope appScope;
	
	@Override
	public boolean appStart(IScope app) {
			appScope = app;
			serverStream = StreamUtils.createServerStream(appScope, "liveX");

			SimplePlayItem item;

			item = new SimplePlayItem();
			item.setStart(0);
			item.setLength(70000);
			item.setName("golfers");
			serverStream.addItem(item);

			item = new SimplePlayItem();
			item.setStart(0);
			item.setLength(244000);
			item.setName("on2_flash8_w_audio");
			serverStream.addItem(item);
			
			item = new SimplePlayItem();
			item.setStart(0);
			item.setLength(166000);
			item.setName("cort2");
			serverStream.addItem(item);

			item = new SimplePlayItem();
			item.setStart(0);
			item.setLength(70000);
			item.setName("golfers");
			serverStream.addItem(item);

			item = new SimplePlayItem();
			item.setStart(0);
			item.setLength(244000);
			item.setName("on2_flash8_w_audio");
			serverStream.addItem(item);
			
			serverStream.start();
			return true;
	}
	
	@Override
	public boolean appConnect(IConnection conn, Object[] params) {
		// Trigger calling of "onBWDone", required for some FLV players
		measureBandwidth(conn);
		if (conn instanceof IStreamCapableConnection) {
			IStreamCapableConnection streamConn = (IStreamCapableConnection) conn;
			SimpleBandwidthConfigure sbc = new SimpleBandwidthConfigure();
			sbc.setMaxBurst(8*1024*1024);
			sbc.setBurst(8*1024*1024);
			sbc.setOverallBandwidth(2*1024*1024);
			streamConn.setBandwidthConfigure(sbc);
		}
/*		if (appScope == conn.getScope()) {
			serverStream =
				StreamUtils.createServerStream(appScope, "live0");
			SimplePlayItem item = new SimplePlayItem();
			item.setStart(0);
			item.setLength(10000);
			item.setName("on2_flash8_w_audio");
			serverStream.addItem(item);
			item = new SimplePlayItem();
			item.setStart(20000);
			item.setLength(10000);
			item.setName("on2_flash8_w_audio");
			serverStream.addItem(item);
			serverStream.start();
		}
*/		return super.appConnect(conn, params);
		
	}

	@Override
	public void appDisconnect(IConnection conn) {
		if (appScope == conn.getScope()) {
			serverStream.close();
		}
		super.appDisconnect(conn);
	}

	public String test(String val){
		log.debug("test called on: "+getName());
		return val + val;
	}

    public Double add(Double a, Double b){
        return a + b;
    }
    public Double subtract(Double a, Double b){
        return a - b;
    }
}