Redial: Interactive Telephony : Week 9

Displays

Asterisk + Processing

[redial_NET-ID]
exten => s,n,EAGI(/path/toyour/shellscript/runEAGI.sh);	Pointing to shell script with EAGI
		

#!/bin/sh
/usr/java/jdk1.5.0_10/bin/java -classpath /path/toyour/javaclass/ JEAGIClient $$		
		

/usr/java/jdk1.5.0_10/bin/javac *.java		
		

[sve204@asterisk javaagi]$ mkdir server
[sve204@asterisk javaagi]$ mv JEAGIServer.class server/.
[sve204@asterisk javaagi]$ mv ServerThread.class server/.
[sve204@asterisk javaagi]$ /usr/java/jdk1.5.0_10/bin/java server.JEAGIServer
Server running at asterisk.itp.tsoa.nyu.edu/128.122.151.44  9010
Waiting for a new connection: 		
		

/127.0.0.1:50968 connected.
Waiting for a new connection: 
reading: sve204_gizmo,newcall
broadcasting: sve204_gizmo,newcall
reading: sve204_gizmo,2
broadcasting: sve204_gizmo,2
reading: sve204_gizmo,6
broadcasting: sve204_gizmo,6
reading: sve204_gizmo,#
broadcasting: sve204_gizmo,#
reading: sve204_gizmo,8
broadcasting: sve204_gizmo,8		
		

  client = new Client(this, "asterisk.itp.tsoa.nyu.edu", 9010);  // Port is whatever you set it up to be and asterisk.itp.tsoa.nyu.edu is the host name		
		

if (client.available() > 0) { 
messageFromServer = client.readString();   // Read it as a String 
} 		
		

callerid,digitpressed	
		

import processing.net.*; 

// Declare a client 
Client client; 

// A String to hold whatever the server says 
String messageFromServer = "Waiting for call.";
PFont f; 

int x, y;

void setup() { 
  size(600,200); 
  frameRate(30); 
  // Create the Client 
  client = new Client(this, "asterisk.itp.tsoa.nyu.edu", 9010);  // Port is whatever you set it up to be and asterisk.itp.tsoa.nyu.edu
  background(0); 
  x = width/2;
  y = height/2;
} 

void draw() 
{ 
  background(0); 
  // Display message from server 
  fill(255); 
  ellipse(x,y,50,50);

  // If there is information available to read from the Server 
  if (client.available() > 0) { 
    messageFromServer = client.readString();   // Read it as a String 
    String[] parts = split(messageFromServer,",");
    if (parts.length > 0)
    {
      String part = trim(parts[1]);
      if (part.equals("1"))
      {
         x-=10; 
         y-=10;        
      }
      else if (part.equals("2"))
      {
         y-=10; 
      }
      else if (part.equals("3"))
      {
         y-=10; 
         x+=10;
      }
      else if (part.equals("*"))
      {
         x-=10; 
         y+=10;
      }
      else if (part.equals("0"))
      {
         y+=10; 
      }
      else if (part.equals("#"))
      {
         x+=10; 
         y+=10; 
      }
    }
  } 
} 
		

Doing More

STREAM FILE <filename> <escape digits>
		
Returns: 
failure: 200 result=-1 endpos=<sample offset> 
failure on open: 200 result=0 endpos=0 
success: 200 result=0 endpos=<offset>
digit pressed: 200 result=<digit> endpos=<offset>

Usage: WAIT FOR DIGIT <timeout>

Waits up to <timeout> milliseconds for channel to receive a DTMF digit. 

Use -1 for the <timeout> value if you desire the call to block indefinitely. 

Returns: 
failure: 200 result=-1 
timeout: 200 result=0 
success: 200 result=<digit> 

<digit> is the ascii code for the digit received. 

public void streamFile(String filetostream) {
	try {
		// Stream a file..
		String wait = "STREAM FILE " + filetostream + " #*0123456789\n";
		out.write(wait.getBytes());

		String line = null;
		while ((line = bin.readLine()) != null) {

			String agi_callerid = "agi_callerid:";
			int index = line.indexOf(agi_callerid);
			// See if we can get the phone number (for a new call)
			if (index > -1) {
				id = line.substring(index + agi_callerid.length()+1,line.length());
				client.send(id + ",newcall");
			}
			// The message we want starts with 200, but does not = 1
			else if (line.indexOf("200") == 0 && !line.equals("200 result=1")) {
				// Parse out what digit was pressed
				String result = "200 result=";
				int i = line.indexOf(result);
				if (i > -1) {
					String key = line.substring(i+result.length(),line.length());
					// -1 means hangup
					if (key.equals("-1")) {
						client.send(id+",hangup");
					} else {
						// If this doesn't work we'll send "error"
						String c = "error";
						try {
							// Convert to integer
							c = "" + (char) Integer.parseInt(key);
						} catch (Exception e) {
							// oops
						}
						client.send(id+","+c);
						// tfsos.write(("Message: "+id+","+c+"\n").getBytes());
					}
				}
				out.write(wait.getBytes());
			}
		}
	} catch (Exception e) {
		// There was some sort of error
		System.out.println("SAY ALPHA ERROR \"*#\"");
		System.out.println(e);
		e.printStackTrace();
	}
	//client.quit();  // Take out the quit..
}
		

//jeagi.streamFile("/path/to/file");
jeagi.streamFile("/var/lib/asterisk/sounds/vm-extension");
jeagi.waitForDigits();
		

jeagi.waitForDigits();
		

Asterisk + Flash

                       thisConnection.sendToThisClient(_text + "\0");// \0 for flash EOL
		

var xmls=new XMLSocket();
xmls.connect("asterisk.itp.tsoa.nyu.edu",9001);
xmls.addEventListener(Event.CONNECT,xmlsocketEvent);
xmls.addEventListener(Event.CLOSE,xmlsocketEvent);
xmls.addEventListener(IOErrorEvent.IO_ERROR,xmlsocketEvent);
xmls.addEventListener(DataEvent.DATA, xmlsocketEvent);

function xmlsocketEvent(event):void
{
	switch(event.type)
	{
		case 'ioError':
			trace("ioError");
			break;
		case 'connect':
			trace("Connected");
			break;
		case 'close':
			trace("Disconnected");
			break;
		case 'data':
			trace("data" + event);
	}
}
		

Examples