Record the voice of the Caller

[HttpPost]
public ActionResult RecordCall(string notificationName, string callLegID, string caller, string apiExtension)
{
	return Content(
	"<Response>" +
	  "<UserInput timeout=\"10\" repeat=\"true\">" +
		"<InitialCommands>" +
		  "<Speak>Hello.</Speak>  " +
		  "<Speak>To record your own voice, please press 1.</Speak>" +
		  "<Speak>To hang up the line, please press 2.</Speak>" +
		"</InitialCommands>" +
		"<Inputs>" +
		  "<Input key=\"1\">" +
			"<Speak>Press 9 for stop recording! Recording start now:</Speak>" +
			"<Record finishedUrl=\"http://yoursite.com/Home/RecordFinished\" FinishDigits=\"9\"/>" +
		  "</Input>" +
		  "<Input key=\"2\">" +
			"<Speak>Good bye!</Speak>" +
			"<Hangup></Hangup>" +
		  "</Input>" +
		"</Inputs>" +
	  "</UserInput>" +
	"</Response>", "text/xml");
}

class RecordCallController < ApplicationController
  
  protect_from_forgery except: :index

  # In routes.rb you need to set the following routing rule
  # post '/record_call' => 'record_call#index'
  
  def index

    render :xml => '<?xml version="1.0" encoding="UTF-8"?>
    <Response>
      <UserInput timeout="10" repeat="true">
        <InitialCommands>
          <Speak>Hello.</Speak>
          <Speak>To record your own voice, please press 1.</Speak>
          <Speak>To hang up the line, please press 2.</Speak>
        </InitialCommands>
        <Inputs>
          <Input key="1">
            <Speak>Press 9 for stop recording! Recording start now:</Speak>
            <Record finishedUrl="http://yoursite.com:3000/record_finished" FinishDigits="9"/>
          </Input>
          <Input key="2">
            <Speak>Good bye!</Speak>
            <Hangup></Hangup>
          </Input>
        </Inputs>
      </UserInput>
    </Response>'
  end

end

<?php
	print "<Response>";
		print "<UserInput timeout=\"10\" repeat=\"true\">";
			print "<InitialCommands>";
				print "<Speak>Hello.</Speak>";	
				print "<Speak>To record your own voice, please press 1.</Speak>";	
				print "<Speak>To hang up the line, please press 2.</Speak>";
			print "</InitialCommands>";	
			print "<Inputs>";	
				print "<Input key=\"1\">";
					print "<Speak>";
						print "Press 9 for stop recording! Recording start now:";
					print "</Speak>";
					print "<Record finishedUrl=\"http://yoursite.com/RecordFinished.php\" FinishDigits=\"9\"/>";	
				print "</Input>";
				print "<Input key=\"2\">";	
					print "<Speak>Good bye!</Speak>";	
					print "<Hangup></Hangup>";
				print "</Input>";
			print "</Inputs>";	
		print "</UserInput>";
	print "</Response>";
?>

using System;
using OPSSDK;
using OPSSDKCommon.Model.Call;
using Ozeki.Media.MediaHandlers;
using Ozeki.VoIP;

namespace OPS_QuickStartExample_CSharp
{
    class Program
    {
        static void Main(string[] args)
        {
            var client = new OpsClient();
            client.ErrorOccurred += (sender, info) =>
                Console.WriteLine(info.Message);

            if (!client.Login("ozekixepbx.ip", "admin", "12345"))
                return;

            var apiExtension = client.GetAPIExtension("9000");
            apiExtension.IncomingCall += IncomingCall;
            Console.ReadLine();
        }

        private static void IncomingCall(object sender, VoIPEventArgs e)
        {
            var call = e.Item;
            var lastRecordedFilePath = "c://" + Guid.NewGuid() + ".wav";
            WaveStreamRecorder recorder = null; 
            WaveStreamPlayback player = null;
            var tts = new TextToSpeech();
            call.ConnectAudioSender(tts);

            call.DtmfReceived += (s, ev) =>
            {
                if (ev.Item.Signal == DtmfNamedEvents.Dtmf1)
                {
                    if (tts == null)
                        return;
                    tts.Dispose();
                    tts = null;
                    recorder = new WaveStreamRecorder(lastRecordedFilePath);
                    call.ConnectAudioReceiver(recorder);
                    recorder.StartStreaming();
                }
                else if (ev.Item.Signal == DtmfNamedEvents.Dtmf9)
                {
                    if (recorder == null)
                        return;
                    recorder.Dispose();
                    recorder = null;

                    player = new WaveStreamPlayback(lastRecordedFilePath);
                    call.ConnectAudioSender(player);
                    player.StartStreaming();
                    player.Stopped += (sen, eve) => call.HangUp();
                }
            };

            call.CallStateChanged += (s, ev) =>
            {
                if (ev.Item == CallState.Answered)
                    tts.AddAndStartText("To record your own voice, please press 1. " +
                                        "Press 9 for stop recording!");
                else if (ev.Item.IsCallEnded())
                {
                    if (recorder != null)
                        recorder.Dispose();
                    if (tts != null)
                        tts.Dispose();
                    if (player != null)
                        player.Dispose();
                }
            };

            call.Accept();
        }
    }
}

#!c:/Perl64/bin/perl.exe   
print "Content-Type: text/plain\n\n";
#You have to add the directory route of perl.exe, and print the content type

#Send response by print
print 
'<?xml version="1.0" encoding="UTF-8"?>
<Response>
  <UserInput timeout="10" repeat="true">
    <InitialCommands>
      <Speak>Hello.</Speak>			
      <Speak>To record your own voice, please press 1.</Speak>
      <Speak>To hang up the line, please press 2.</Speak>
    </InitialCommands>
    <Inputs>
      <Input key="1">
        <Speak>Press 9 for stop recording! Recording start now:</Speak>
        <Record finishedUrl="http://yoursite.com/RecordFinished.pl" FinishDigits="9"/>
      </Input>
      <Input key="2">
        <Speak>Good bye!</Speak>	
        <Hangup></Hangup>
      </Input>
    </Inputs>
  </UserInput>
</Response>'

Imports Ozeki.Media.MediaHandlers
Imports OPSSDKCommon.Model.Call
Imports OPSSDK
Imports Ozeki.VoIP

Module Module1
    Public Sub Main(args As String())
        Dim client = New OpsClient()
        AddHandler client.ErrorOccurred, Sub(sender, info)
                                             Console.WriteLine(info.Message)
                                         End Sub

        If Not client.Login("ozekixepbx.ip", "admin", "12345") Then
            Return
        End If

        Dim apiExtension = client.GetAPIExtension("9000")
        AddHandler apiExtension.IncomingCall, AddressOf IncomingCall
        Console.ReadLine()
    End Sub

    Private Sub IncomingCall(sender As Object, e As VoIPEventArgs(Of ICall))
        Dim [call] = e.Item
        Dim lastRecordedFilePath = "c://" & Guid.NewGuid().ToString() & ".wav"
        Dim recorder As WaveStreamRecorder = Nothing
        Dim player As WaveStreamPlayback = Nothing
        Dim tts = New TextToSpeech()
        [call].ConnectAudioSender(tts)

        AddHandler [call].DtmfReceived,
            Sub(s, ev)
                If ev.Item.Signal = DtmfNamedEvents.Dtmf1 Then
                    If tts Is Nothing Then
                        Return
                    End If
                    tts.Dispose()
                    tts = Nothing
                    recorder = New WaveStreamRecorder(lastRecordedFilePath)
                    [call].ConnectAudioReceiver(recorder)
                    recorder.StartStreaming()
                ElseIf ev.Item.Signal = DtmfNamedEvents.Dtmf9 Then
                    If recorder Is Nothing Then
                        Return
                    End If
                    recorder.Dispose()
                    recorder = Nothing

                    player = New WaveStreamPlayback(lastRecordedFilePath)
                    [call].ConnectAudioSender(player)
                    player.StartStreaming()
                    AddHandler player.Stopped, Sub(sen, eve)
                                                   [call].HangUp()
                                               End Sub
                End If
            End Sub

        AddHandler [call].CallStateChanged,
            Sub(s, ev)
                If ev.Item = CallState.Answered Then
                    tts.AddAndStartText("To record your own voice, please press 1. " &
                                        "Press 9 for stop recording!")
                ElseIf ev.Item.IsCallEnded() Then
                    If recorder IsNot Nothing Then
                        recorder.Dispose()
                    End If
                    If tts IsNot Nothing Then
                        tts.Dispose()
                    End If
                    If player IsNot Nothing Then
                        player.Dispose()
                    End If
                End If
            End Sub

        [call].Accept()
    End Sub
End Module

import urllib.parse
import datetime
from cgi import escape

def application(environ, start_response):
   
    if(environ["PATH_INFO"] == ''):
        result = receiveCall(environ)
    elif(environ["PATH_INFO"] == '/RecordFinished'):
        result = recordFinished(environ)

    response_headers = [('Content-type', 'text/plain'), ('Content-Length', str(len(result)))]
    start_response('200 OK', response_headers)

    return [result]

def receiveCall(environ):
    return """<?xml version="1.0" encoding="UTF-8"?>
            <Response>
              <UserInput timeout="10" repeat="true">
                <InitialCommands>
                  <Speak>Hello.</Speak>			
                  <Speak>To record your own voice, please press 1.</Speak>
                  <Speak>To hang up the line, please press 2.</Speak>
                </InitialCommands>
                <Inputs>
                  <Input key="1">
                    <Speak>Press 9 for stop recording! Recording start now:</Speak>
                    <Record finishedUrl="{0}" FinishDigits="9"/>
                  </Input>
                  <Input key="2">
                    <Speak>Good bye!</Speak>
                    <Hangup></Hangup>
                  </Input>
                </Inputs>
              </UserInput>
            </Response>""".format("http://yoursite.com/RecordFinished")

package pbxsampleapp;

import com.sun.net.httpserver.*;
import java.io.*;
import java.net.*;
import java.util.*;

public class RecordCall 
{
  public static void main(String[] args)
    {
        try
        {
            System.out.println("Starting http server...");
            HttpServer server = HttpServer.create(new InetSocketAddress(InetAddress.getByAddress(new byte[] { 0, 0, 0, 0 }), 12345), 0);
            server.createContext("/callrecoding", new PbxSampleApp.PBXRequestHandler());
            server.start();
            System.out.println("http server running on " + server.getAddress().toString());
        }
        catch (IOException ex) { System.out.println("Error" + ex.toString()); }
    }

    static class PBXRequestHandler implements HttpHandler
    {
        @Override
        public void handle(HttpExchange httpExchange) throws IOException
        {
            Map parameters = parseQuery(httpExchange.getRequestURI().getQuery());
            String response = GetResponse(parameters);
            httpExchange.getResponseHeaders().add("Content-type", "text/xml");
            if (response.length()==0)
                httpExchange.sendResponseHeaders(404, response.length());
            else
                httpExchange.sendResponseHeaders(200, response.length());
            OutputStream os = httpExchange.getResponseBody();
            os.write(response.getBytes());
            os.close();
        }

        private String GetResponse(Map queryparams)
        {
            if (queryparams.containsKey("action"))
            {
                switch (queryparams.get("action").toString())
                {
                    case "RecordCall":
                       return getRecordCallOzML(queryparams);
                    case "RecordFinished":
                        return getRecordFinishedOzMl(queryparams);
                }
            }
            return "";
        }
        
        private String getRecordCallOzML(Map queryparams)
        {
             return "<?xml version=\"1.0\"?>"
                + "<Response>"
                + "<UserInput timeout=\"10\" repeat=\"true\">"
                + "<InitialCommands>"
                + "<Speak>Hello.</Speak>  "
                + "<Speak>To record your own voice, please press 1.</Speak>"
                + "<Speak>To hang up the line, please press 2.</Speak>"
                + "</InitialCommands>"
                + "<Inputs>"
                + "<Input key=\"1\">"
                + "<Speak>Press 9 for stop recording! Recording start now:</Speak>"
                + "<Record finishedUrl=\"http://yoursite.com/callrecoding?action=RecordFinished\" FinishDigits=\"9\"/>"
                + "</Input>"
                + "<Input key=\"2\">"
                + "<Speak>Good bye!</Speak>"
                + "<Hangup></Hangup>"
                + "</Input>"
                + "</Inputs>"
                + "</UserInput>"
                + "</Response>";
        }
        
        private Map<String, String> parseQuery(String params) throws UnsupportedEncodingException
        {
            Map<String, String> query_pairs = new LinkedHashMap<String, String>();
            String[] pairs = params.split("&");
            String paramname;
            String value;
            for (String pair : pairs)
            {
                int idx = pair.indexOf("=");
                paramname = pair.substring(0, idx);
                value = pair.substring(idx + 1);
                query_pairs.put(paramname, value);
                System.out.println(String.format("%s: %s", paramname, value));
            }
            return query_pairs;
        }
    }
}