using System; using System.Threading; using System.Collections; using AsterNET.Manager.Action; using AsterNET.Manager.Event; using AsterNET.Manager.Response; using System.Text.RegularExpressions; using System.Text; using System.Collections.Generic; using System.Reflection; using AsterNET.IO; using System.Threading.Tasks; namespace AsterNET.Manager { /// /// Default implementation of the ManagerConnection interface. /// public class ManagerConnection { #region Variables #if LOGGER private Logger logger = Logger.Instance(); #endif private long actionIdCount = 0; private string hostname; private int port; private string username; private string password; private SocketConnection mrSocket; private Thread mrReaderThread; private ManagerReader mrReader; private int defaultResponseTimeout = 2000; private int defaultEventTimeout = 5000; private int sleepTime = 50; private bool keepAlive = true; private bool keepAliveAfterAuthenticationFailure = false; private string protocolIdentifier; private AsteriskVersion asteriskVersion; private Dictionary responseHandlers; private Dictionary pingHandlers; private Dictionary responseEventHandlers; private int pingInterval = 10000; private object lockSocket = new object(); private object lockSocketWrite = new object(); private object lockHandlers = new object(); private bool enableEvents = true; private string version = string.Empty; private Encoding socketEncoding = Encoding.ASCII; private bool reconnected = false; private bool reconnectEnable = false; private int reconnectCount; private Dictionary registeredEventClasses; private Dictionary> registeredEventHandlers; private event EventHandler internalEvent; private bool fireAllEvents = false; private Thread callerThread; /// Default Fast Reconnect retry counter. private int reconnectRetryFast = 5; /// Default Maximum Reconnect retry counter. private int reconnectRetryMax = 10; /// Default Fast Reconnect interval in milliseconds. private int reconnectIntervalFast = 5000; /// Default Slow Reconnect interval in milliseconds. private int reconnectIntervalMax = 10000; public char[] VAR_DELIMITER = { '|' }; #endregion /// /// Allows you to specifiy how events are fired. If false (default) then /// events will be fired in order. Otherwise events will be fired as they arrive and /// control logic in your application will need to handle synchronization. /// public bool UseASyncEvents = false; #region Events /// /// An UnhandledEvent is triggered on unknown event. /// public event EventHandler UnhandledEvent; /// /// An AgentCallbackLogin is triggered when an agent is successfully logged in. /// public event EventHandler AgentCallbackLogin; /// /// An AgentCallbackLogoff is triggered when an agent that previously logged in is logged of.
///
public event EventHandler AgentCallbackLogoff; /// /// An AgentCalled is triggered when an agent is ring.
/// To enable AgentCalled you have to set eventwhencalled = yes in queues.conf.
///
public event EventHandler AgentCalled; /// /// An AgentCompleteEvent is triggered when at the end of a call if the caller was connected to an agent. /// public event EventHandler AgentComplete; /// /// An AgentConnectEvent is triggered when a caller is connected to an agent. /// public event EventHandler AgentConnect; /// /// An AgentDumpEvent is triggered when an agent dumps the caller while listening to the queue announcement. /// public event EventHandler AgentDump; /// /// An AgentLoginEvent is triggered when an agent is successfully logged in using AgentLogin. /// public event EventHandler AgentLogin; /// /// An AgentCallbackLogoffEvent is triggered when an agent that previously logged in using AgentLogin is logged of. /// public event EventHandler AgentLogoff; /// /// An AgentRingNoAnswer is triggered when an agent was rang and did not answer.
/// To enable AgentRingNoAnswer you have to set eventwhencalled = yes in queues.conf. ///
public event EventHandler AgentRingNoAnswer; /// /// An AgentsCompleteEvent is triggered after the state of all agents has been reported in response to an AgentsAction. /// public event EventHandler AgentsComplete; /// /// An AgentsEvent is triggered for each agent in response to an AgentsAction. /// public event EventHandler Agents; /// /// An AlarmEvent is triggered when a Zap channel leaves alarm state. /// public event EventHandler AlarmClear; /// /// /// public event EventHandler Bridge; /// /// An AlarmEvent is triggered when a Zap channel enters or changes alarm state. /// public event EventHandler Alarm; /// /// A CdrEvent is triggered when a call detail record is generated, usually at the end of a call. /// public event EventHandler Cdr; public event EventHandler DBGetResponse; /// /// A Dial is triggered whenever a phone attempts to dial someone.
///
public event EventHandler Dial; public event EventHandler DTMF; /// /// An DTMFBeginEvent is triggered when a DTMF digit has started on a channel. /// public event EventHandler DTMFBegin; /// /// An DTMFEndEvent is triggered when a DTMF digit has ended on a channel. /// public event EventHandler DTMFEnd; /// /// A DNDStateEvent is triggered by the Zap channel driver when a channel enters or leaves DND (do not disturb) state. /// public event EventHandler DNDState; /// /// An ExtensionStatus is triggered when the state of an extension changes.
///
public event EventHandler ExtensionStatus; /// /// A Hangup is triggered when a channel is hung up.
///
public event EventHandler Hangup; /// /// A HoldedCall is triggered when a channel is put on hold.
///
public event EventHandler HoldedCall; /// /// A Hold is triggered by the SIP channel driver when a channel is put on hold.
///
public event EventHandler Hold; /// /// A Join is triggered when a channel joines a queue.
///
public event EventHandler Join; /// /// A Leave is triggered when a channel leaves a queue.
///
public event EventHandler Leave; /// /// A Link is triggered when two voice channels are linked together and voice data exchange commences.
/// Several Link events may be seen for a single call. This can occur when Asterisk fails to setup a /// native bridge for the call.This is when Asterisk must sit between two telephones and perform /// CODEC conversion on their behalf. ///
public event EventHandler Link; /// /// A LogChannel is triggered when logging is turned on or off.
///
public event EventHandler LogChannel; /// /// A MeetMeJoin is triggered if a channel joins a meet me conference.
///
public event EventHandler MeetMeJoin; /// /// A MeetMeLeave is triggered if a channel leaves a meet me conference.
///
public event EventHandler MeetMeLeave; // public event EventHandler MeetMeStopTalking; /// /// A MeetMeTalkingEvent is triggered when a user starts talking in a meet me conference.
/// To enable talker detection you must pass the option 'T' to the MeetMe application. ///
public event EventHandler MeetMeTalking; /// /// A MessageWaiting is triggered when someone leaves voicemail.
///
public event EventHandler MessageWaiting; /// /// A NewCallerId is triggered when the caller id of a channel changes.
///
public event EventHandler NewCallerId; /// /// A NewChannel is triggered when a new channel is created.
///
public event EventHandler NewChannel; /// /// A NewExten is triggered when a channel is connected to a new extension.
///
public event EventHandler NewExten; /// /// A NewState is triggered when the state of a channel has changed.
///
public event EventHandler NewState; // public event EventHandler Originate; /// /// An OriginateFailure is triggered when the execution of an OriginateAction failed. /// // public event EventHandler OriginateFailure; /// /// An OriginateSuccess is triggered when the execution of an OriginateAction succeeded. /// // public event EventHandler OriginateSuccess; /// /// An OriginateResponse is triggered when the execution of an Originate. /// public event EventHandler OriginateResponse; /// /// A ParkedCall is triggered when a channel is parked (in this case no /// action id is set) and in response to a ParkedCallsAction.
///
public event EventHandler ParkedCall; /// /// A ParkedCallGiveUp is triggered when a channel that has been parked is hung up.
///
public event EventHandler ParkedCallGiveUp; /// /// A ParkedCallsComplete is triggered after all parked calls have been reported in response to a ParkedCallsAction. /// public event EventHandler ParkedCallsComplete; /// /// A ParkedCallTimeOut is triggered when call parking times out for a given channel.
///
public event EventHandler ParkedCallTimeOut; /// /// A PeerEntry is triggered in response to a SIPPeersAction or SIPShowPeerAction and contains information about a peer.
///
public event EventHandler PeerEntry; /// /// A PeerlistComplete is triggered after the details of all peers has been reported in response to an SIPPeersAction or SIPShowPeerAction.
///
public event EventHandler PeerlistComplete; /// /// A PeerStatus is triggered when a SIP or IAX client attempts to registrer at this asterisk server.
///
public event EventHandler PeerStatus; /// /// A QueueEntryEvent is triggered in response to a QueueStatusAction and contains information about an entry in a queue. /// public event EventHandler QueueCallerAbandon; /// /// A QueueEntryEvent is triggered in response to a QueueStatusAction and contains information about an entry in a queue. /// public event EventHandler QueueEntry; /// /// A QueueMemberAddedEvent is triggered when a queue member is added to a queue. /// public event EventHandler QueueMemberAdded; /// /// A QueueMemberEvent is triggered in response to a QueueStatusAction and contains information about a member of a queue. /// public event EventHandler QueueMember; /// /// A QueueMemberPausedEvent is triggered when a queue member is paused or unpaused. /// Replaced by : since Asterisk 12.
/// Removed since : Asterisk 13.
///
public event EventHandler QueueMemberPaused; /// /// A QueueMemberRemovedEvent is triggered when a queue member is removed from a queue. /// public event EventHandler QueueMemberRemoved; /// /// A QueueMemberStatusEvent shows the status of a QueueMemberEvent. /// public event EventHandler QueueMemberStatus; /// /// A QueueParamsEvent is triggered in response to a QueueStatusAction and contains the parameters of a queue. /// public event EventHandler QueueParams; /// /// A QueueStatusCompleteEvent is triggered after the state of all queues has been reported in response to a QueueStatusAction. /// public event EventHandler QueueStatusComplete; /// /// A Registry is triggered when this asterisk server attempts to register /// as a client at another SIP or IAX server.
///
public event EventHandler Registry; /// /// A RenameEvent is triggered when the name of a channel is changed. /// public event EventHandler Rename; /// /// A StatusCompleteEvent is triggered after the state of all channels has been reported in response to a StatusAction. /// public event EventHandler StatusComplete; /// /// A StatusEvent is triggered for each active channel in response to a StatusAction. /// public event EventHandler Status; /// /// /// public event EventHandler Transfer; /// /// An UnholdEvent is triggered by the SIP channel driver when a channel is no longer put on hold. /// public event EventHandler Unhold; /// /// An UnlinkEvent is triggered when a link between two voice channels is discontinued, for example, just before call completion. /// public event EventHandler Unlink; /// /// A UnparkedCallEvent is triggered when a channel that has been parked is resumed. /// public event EventHandler UnparkedCall; /// /// A ZapShowChannelsEvent is triggered on UserEvent in dialplan. /// public event EventHandler UserEvents; /// /// A ZapShowChannelsCompleteEvent is triggered after the state of all zap channels has been reported in response to a ZapShowChannelsAction. /// public event EventHandler ZapShowChannelsComplete; /// /// A ZapShowChannelsEvent is triggered in response to a ZapShowChannelsAction and shows the state of a zap channel. /// public event EventHandler ZapShowChannels; /// /// A ConnectionState is triggered after Connect/Disconnect/Shutdown events. /// public event EventHandler ConnectionState; /// /// A Reload is triggered after Reload events. /// public event EventHandler Reload; /// /// When a variable is set /// public event EventHandler VarSet; /// /// AgiExec is execute /// public event EventHandler AGIExec; /// /// This event is sent when the first user requests a conference and it is instantiated /// public event EventHandler ConfbridgeStart; /// /// This event is sent when a user joins a conference - either one already in progress or as the first user to join a newly instantiated bridge. /// public event EventHandler ConfbridgeJoin; /// /// This event is sent when a user leaves a conference. /// public event EventHandler ConfbridgeLeave; /// /// This event is sent when the last user leaves a conference and it is torn down. /// public event EventHandler ConfbridgeEnd; /// /// This event is sent when the conference detects that a user has either begin or stopped talking. /// public event EventHandler ConfbridgeTalking; /// /// /// public event EventHandler FailedACL; public event EventHandler AttendedTransfer; public event EventHandler BlindTransfer; public event EventHandler BridgeCreate; public event EventHandler BridgeDestroy; public event EventHandler BridgeEnter; public event EventHandler BridgeLeave; /// /// Raised when a dial action has started.
///
public event EventHandler DialBegin; /// /// Raised when a dial action has completed.
///
public event EventHandler DialEnd; /// /// Raised when a caller joins a Queue.
///
public event EventHandler QueueCallerJoin; /// /// Raised when a caller leaves a Queue.
///
public event EventHandler QueueCallerLeave; /// /// A QueueMemberPauseEvent is triggered when a queue member is paused or unpaused.
/// Available since : Asterisk 12. ///
public event EventHandler QueueMemberPause; /// /// Raised when music on hold has started/stopped on a channel.
/// Available since : Asterisk 1.6. ///
public event EventHandler MusicOnHold; /// /// Raised when music on hold has started on a channel.
/// Available since : Asterisk 12. ///
public event EventHandler MusicOnHoldStart; /// /// Raised when music on hold has stopped on a channel.
/// Available since : Asterisk 12. ///
public event EventHandler MusicOnHoldStop; /// /// A ChallengeResponseFailed is triggered when a request's attempt to authenticate has been challenged, and the request failed the authentication challenge. /// public event EventHandler ChallengeResponseFailed; /// /// A InvalidAccountID is triggered when a request fails an authentication check due to an invalid account ID. /// public event EventHandler InvalidAccountID; /// /// A DeviceStateChanged is triggered when a device state changes. /// public event EventHandler DeviceStateChanged; /// /// A ChallengeSent is triggered when an Asterisk service sends an authentication challenge to a request.. /// public event EventHandler ChallengeSent; /// /// A SuccessfulAuth is triggered when a request successfully authenticates with a service. /// public event EventHandler SuccessfulAuth; /// /// Raised when call queue summary /// public event EventHandler QueueSummary; #endregion #region Constructor - ManagerConnection() /// Creates a new instance. public ManagerConnection() { callerThread = Thread.CurrentThread; socketEncoding = Encoding.ASCII; responseHandlers = new Dictionary(); pingHandlers = new Dictionary(); responseEventHandlers = new Dictionary(); registeredEventClasses = new Dictionary(); Helper.RegisterBuiltinEventClasses(registeredEventClasses); registeredEventHandlers = new Dictionary>(); #region Event mapping table Helper.RegisterEventHandler(registeredEventHandlers, typeof(AgentCallbackLoginEvent), arg => fireEvent(AgentCallbackLogin, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(AgentCallbackLogoffEvent), arg => fireEvent(AgentCallbackLogoff, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(AgentCalledEvent), arg => fireEvent(AgentCalled, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(AgentCompleteEvent), arg => fireEvent(AgentComplete, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(AgentConnectEvent), arg => fireEvent(AgentConnect, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(AgentDumpEvent), arg => fireEvent(AgentDump, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(AgentLoginEvent), arg => fireEvent(AgentLogin, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(AgentLogoffEvent), arg => fireEvent(AgentLogoff, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(AgentRingNoAnswerEvent), arg => fireEvent(AgentRingNoAnswer, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(AgentsCompleteEvent), arg => fireEvent(AgentsComplete, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(AgentsEvent), arg => fireEvent(Agents, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(AlarmClearEvent), arg => fireEvent(AlarmClear, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(AlarmEvent), arg => fireEvent(Alarm, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(CdrEvent), arg => fireEvent(Cdr, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(DBGetResponseEvent), arg => fireEvent(DBGetResponse, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(DialEvent), arg => fireEvent(Dial, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(DNDStateEvent), arg => fireEvent(DNDState, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(ExtensionStatusEvent), arg => fireEvent(ExtensionStatus, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(HangupEvent), arg => fireEvent(Hangup, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(HoldedCallEvent), arg => fireEvent(HoldedCall, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(HoldEvent), arg => fireEvent(Hold, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(JoinEvent), arg => fireEvent(Join, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(LeaveEvent), arg => fireEvent(Leave, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(LinkEvent), arg => fireEvent(Link, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(LogChannelEvent), arg => fireEvent(LogChannel, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(MeetmeJoinEvent), arg => fireEvent(MeetMeJoin, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(MeetmeLeaveEvent), arg => fireEvent(MeetMeLeave, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(MeetmeTalkingEvent), arg => fireEvent(MeetMeTalking, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(MessageWaitingEvent), arg => fireEvent(MessageWaiting, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(NewCallerIdEvent), arg => fireEvent(NewCallerId, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(NewChannelEvent), arg => fireEvent(NewChannel, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(NewExtenEvent), arg => fireEvent(NewExten, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(NewStateEvent), arg => fireEvent(NewState, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(OriginateResponseEvent), arg => fireEvent(OriginateResponse, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(ParkedCallEvent), arg => fireEvent(ParkedCall, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(ParkedCallGiveUpEvent), arg => fireEvent(ParkedCallGiveUp, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(ParkedCallsCompleteEvent), arg => fireEvent(ParkedCallsComplete, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(ParkedCallTimeOutEvent), arg => fireEvent(ParkedCallTimeOut, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(PeerEntryEvent), arg => fireEvent(PeerEntry, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(PeerlistCompleteEvent), arg => fireEvent(PeerlistComplete, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(PeerStatusEvent), arg => fireEvent(PeerStatus, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(QueueEntryEvent), arg => fireEvent(QueueEntry, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(QueueMemberAddedEvent), arg => fireEvent(QueueMemberAdded, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(QueueMemberEvent), arg => fireEvent(QueueMember, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(QueueMemberPausedEvent), arg => fireEvent(QueueMemberPaused, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(QueueMemberRemovedEvent), arg => fireEvent(QueueMemberRemoved, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(QueueMemberStatusEvent), arg => fireEvent(QueueMemberStatus, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(QueueParamsEvent), arg => fireEvent(QueueParams, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(QueueStatusCompleteEvent), arg => fireEvent(QueueStatusComplete, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(RegistryEvent), arg => fireEvent(Registry, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(QueueCallerAbandonEvent), arg => fireEvent(QueueCallerAbandon, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(RenameEvent), arg => fireEvent(Rename, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(StatusCompleteEvent), arg => fireEvent(StatusComplete, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(StatusEvent), arg => fireEvent(Status, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(UnholdEvent), arg => fireEvent(Unhold, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(UnlinkEvent), arg => fireEvent(Unlink, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(UnparkedCallEvent), arg => fireEvent(UnparkedCall, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(UserEvent), arg => fireEvent(UserEvents, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(ZapShowChannelsCompleteEvent), arg => fireEvent(ZapShowChannelsComplete, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(ZapShowChannelsEvent), arg => fireEvent(ZapShowChannels, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(ConnectEvent), arg => fireEvent(ConnectionState, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(DisconnectEvent), arg => fireEvent(ConnectionState, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(ReloadEvent), arg => fireEvent(Reload, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(ShutdownEvent), arg => fireEvent(ConnectionState, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(BridgeEvent), arg => fireEvent(Bridge, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(TransferEvent), arg => fireEvent(Transfer, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(DTMFEvent), arg => fireEvent(DTMF, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(DTMFBeginEvent), arg => fireEvent(DTMFBegin, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(DTMFEndEvent), arg => fireEvent(DTMFEnd, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(VarSetEvent), arg => fireEvent(VarSet, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(AGIExecEvent), arg => fireEvent(AGIExec, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(ConfbridgeStartEvent), arg => fireEvent(ConfbridgeStart, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(ConfbridgeJoinEvent), arg => fireEvent(ConfbridgeJoin, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(ConfbridgeLeaveEvent), arg => fireEvent(ConfbridgeLeave, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(ConfbridgeEndEvent), arg => fireEvent(ConfbridgeEnd, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(ConfbridgeTalkingEvent), arg => fireEvent(ConfbridgeTalking, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(FailedACLEvent), arg => fireEvent(FailedACL, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(AttendedTransferEvent), arg => fireEvent(AttendedTransfer, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(BridgeCreateEvent), arg => fireEvent(BridgeCreate, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(BridgeDestroyEvent), arg => fireEvent(BridgeDestroy, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(BridgeEnterEvent), arg => fireEvent(BridgeEnter, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(BridgeLeaveEvent), arg => fireEvent(BridgeLeave, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(BlindTransferEvent), arg => fireEvent(BlindTransfer, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(DialBeginEvent), arg => fireEvent(DialBegin, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(DialEndEvent), arg => fireEvent(DialEnd, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(QueueCallerJoinEvent), arg => fireEvent(QueueCallerJoin, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(QueueCallerLeaveEvent), arg => fireEvent(QueueCallerLeave, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(QueueMemberPauseEvent), arg => fireEvent(QueueMemberPause, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(MusicOnHoldEvent), arg => fireEvent(MusicOnHold, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(MusicOnHoldStartEvent), arg => fireEvent(MusicOnHoldStart, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(MusicOnHoldStopEvent), arg => fireEvent(MusicOnHoldStop, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(ChallengeResponseFailedEvent), arg => fireEvent(ChallengeResponseFailed, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(InvalidAccountIDEvent), arg => fireEvent(InvalidAccountID, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(DeviceStateChangeEvent), arg => fireEvent(DeviceStateChanged, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(ChallengeSentEvent), arg => fireEvent(ChallengeSent, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(SuccessfulAuthEvent), arg => fireEvent(SuccessfulAuth, arg)); Helper.RegisterEventHandler(registeredEventHandlers, typeof(QueueSummaryEvent), arg => fireEvent(QueueSummary, arg)); #endregion this.internalEvent += new EventHandler(internalEventHandler); } #endregion #region Constructor - ManagerConnection(hostname, port, username, password) /// /// Creates a new instance with the given connection parameters. /// /// the hosname of the Asterisk server to connect to. /// the port where Asterisk listens for incoming Manager API connections, usually 5038. /// the username to use for login /// the password to use for login public ManagerConnection(string hostname, int port, string username, string password) : this() { this.hostname = hostname; this.port = port; this.username = username; this.password = password; } #endregion #region Constructor - ManagerConnection(hostname, port, username, password, Encoding socketEncoding) /// /// Creates a new instance with the given connection parameters. /// /// the hosname of the Asterisk server to connect to. /// the port where Asterisk listens for incoming Manager API connections, usually 5038. /// the username to use for login /// the password to use for login /// text encoding to asterisk input/output stream public ManagerConnection(string hostname, int port, string username, string password, Encoding encoding) : this() { this.hostname = hostname; this.port = port; this.username = username; this.password = password; this.socketEncoding = encoding; } #endregion /// /// Default Fast Reconnect retry counter. /// public int ReconnectRetryFast { get { return reconnectRetryFast; } set { reconnectRetryFast = value; } } /// Default Maximum Reconnect retry counter. public int ReconnectRetryMax { get { return reconnectRetryMax; } set { reconnectRetryMax = value; } } /// Default Fast Reconnect interval in milliseconds. public int ReconnectIntervalFast { get { return reconnectIntervalFast; } set { reconnectIntervalFast = value; } } /// Default Slow Reconnect interval in milliseconds. public int ReconnectIntervalMax { get { return reconnectIntervalMax; } set { reconnectIntervalMax = value; } } #region CallerThread internal Thread CallerThread { get { return callerThread; } } #endregion #region internalEventHandler(object sender, ManagerEvent e) private void internalEventHandler(object sender, ManagerEvent e) { int eventHash = e.GetType().Name.GetHashCode(); if (registeredEventHandlers.ContainsKey(eventHash)) { var currentEvent = registeredEventHandlers[eventHash]; if (currentEvent(e)) { return; } } if (fireAllEvents) { fireEvent(UnhandledEvent, e); } } #endregion #region FireAllEvents /// /// If this property set to true then ManagerConnection send all unassigned events to UnhandledEvent handler,
/// if set to false then all unassgned events lost and send only UnhandledEvent.
/// Default: false ///
public bool FireAllEvents { get { return this.fireAllEvents; } set { this.fireAllEvents = value; } } #endregion #region PingInterval /// /// Timeout from Ping to Pong. If no Pong received send Disconnect event. Set to zero to disable. /// public int PingInterval { get { return pingInterval; } set { pingInterval = value; } } #endregion #region Hostname /// Sets the hostname of the asterisk server to connect to.
/// Default is localhost. ///
public string Hostname { get { return hostname; } set { hostname = value; } } #endregion #region Port /// /// Sets the port to use to connect to the asterisk server. This is the port /// specified in asterisk's manager.conf file.
/// Default is 5038. ///
public int Port { get { return port; } set { port = value; } } #endregion #region UserName /// /// Sets the username to use to connect to the asterisk server. This is the /// username specified in asterisk's manager.conf file. /// public string Username { get { return username; } set { username = value; } } #endregion #region Password /// /// Sets the password to use to connect to the asterisk server. This is the /// password specified in asterisk's manager.conf file. /// public string Password { get { return password; } set { password = value; } } #endregion #region DefaultResponseTimeout /// Sets the time in milliseconds the synchronous method /// will wait for a response before throwing a TimeoutException.
/// Default is 2000. ///
public int DefaultResponseTimeout { get { return defaultResponseTimeout; } set { defaultResponseTimeout = value; } } #endregion #region DefaultEventTimeout /// Sets the time in milliseconds the synchronous method /// will wait for a response and the last response event before throwing a TimeoutException.
/// Default is 5000. ///
public int DefaultEventTimeout { get { return defaultEventTimeout; } set { defaultEventTimeout = value; } } #endregion #region SleepTime /// Sets the time in milliseconds the synchronous methods /// SendAction(Action.ManagerAction) and /// SendAction(Action.ManagerAction, long) will sleep between two checks /// for the arrival of a response. This value should be rather small.
/// The sleepTime attribute is also used when checking for the protocol /// identifer.
/// Default is 50. ///
/// this has been replaced by an interrupt based response checking approach. public int SleepTime { get { return sleepTime; } set { sleepTime = value; } } #endregion #region KeepAliveAfterAuthenticationFailure /// Set to true to try reconnecting to ther asterisk serve /// even if the reconnection attempt threw an AuthenticationFailedException.
/// Default is false. ///
public bool KeepAliveAfterAuthenticationFailure { set { keepAliveAfterAuthenticationFailure = value; } get { return keepAliveAfterAuthenticationFailure; } } #endregion #region KeepAlive /// /// Should we attempt to reconnect when the connection is lost?
/// This is set to true after successful login and to false after logoff or after an authentication failure when keepAliveAfterAuthenticationFailure is false. ///
public bool KeepAlive { get { return keepAlive; } set { keepAlive = value; } } #endregion #region SocketEncoding /// /// Socket Encoding - default ASCII /// public Encoding SocketEncoding { get { return socketEncoding; } set { socketEncoding = value; } } #endregion #region Version public string Version { get { return version; } } #endregion #region AsteriskVersion public AsteriskVersion AsteriskVersion { get { return asteriskVersion; } } #endregion #region login(timeout) /// /// Does the real login, following the steps outlined below.
/// Connects to the asterisk server by calling connect() if not already connected
/// Waits until the protocol identifier is received. This is checked every sleepTime ms but not longer than timeout ms in total.
/// Sends a ChallengeAction requesting a challenge for authType MD5.
/// When the ChallengeResponse is received a LoginAction is sent using the calculated key (MD5 hash of the password appended to the received challenge).
///
/// the maximum time to wait for the protocol identifier (in ms) /// /// AuthenticationFailedException if username or password are incorrect and the login action returns an error or if the MD5 /// hash cannot be computed. The connection is closed in this case. /// /// /// TimeoutException if a timeout occurs either while waiting for the /// protocol identifier or when sending the challenge or login /// action. The connection is closed in this case. /// private void login(int timeout) { enableEvents = false; if (reconnected) { #if LOGGER logger.Error("Login during reconnect state."); #endif throw new AuthenticationFailedException("Unable login during reconnect state."); } reconnectEnable = false; DateTime start = DateTime.Now; do { if (connect()) { // Increase delay after connection up to 500 ms Thread.Sleep(10 * sleepTime); // 200 milliseconds delay } try { Thread.Sleep(4 * sleepTime); // 200 milliseconds delay } catch { } if (string.IsNullOrEmpty(protocolIdentifier) && timeout > 0 && Helper.GetMillisecondsFrom(start) > timeout) { disconnect(true); throw new TimeoutException("Timeout waiting for protocol identifier"); } } while (string.IsNullOrEmpty(protocolIdentifier)); ChallengeAction challengeAction = new ChallengeAction(); Response.ManagerResponse response = SendAction(challengeAction, defaultResponseTimeout * 2); if (response is ChallengeResponse) { ChallengeResponse challengeResponse = (ChallengeResponse)response; string key, challenge = challengeResponse.Challenge; try { Util.MD5Support md = Util.MD5Support.GetInstance(); if (challenge != null) md.Update(UTF8Encoding.UTF8.GetBytes(challenge)); if (password != null) md.Update(UTF8Encoding.UTF8.GetBytes(password)); key = Helper.ToHexString(md.DigestData); } catch (Exception ex) { disconnect(true); #if LOGGER logger.Error("Unable to create login key using MD5 Message Digest.", ex); #endif throw new AuthenticationFailedException("Unable to create login key using MD5 Message Digest.", ex); } Action.LoginAction loginAction = new Action.LoginAction(username, "MD5", key); Response.ManagerResponse loginResponse = SendAction(loginAction); if (loginResponse is Response.ManagerError) { disconnect(true); throw new AuthenticationFailedException(loginResponse.Message); } // successfully logged in so assure that we keep trying to reconnect when disconnected reconnectEnable = keepAlive; #if LOGGER logger.Info("Successfully logged in"); #endif asteriskVersion = determineVersion(); #if LOGGER logger.Info("Determined Asterisk version: " + asteriskVersion); #endif enableEvents = true; ConnectEvent ce = new ConnectEvent(this); ce.ProtocolIdentifier = this.protocolIdentifier; DispatchEvent(ce); } else if (response is ManagerError) throw new ManagerException("Unable login to Asterisk - " + response.Message); else throw new ManagerException("Unknown response during login to Asterisk - " + response.GetType().Name + " with message " + response.Message); } #endregion #region determineVersion() protected internal AsteriskVersion determineVersion() { Response.ManagerResponse response; response = SendAction(new Action.CommandAction("core show version"), defaultResponseTimeout * 2); if (response is Response.CommandResponse) { foreach (string line in ((Response.CommandResponse)response).Result) { foreach (Match m in Common.ASTERISK_VERSION.Matches(line)) { if (m.Groups.Count >= 2) { version = m.Groups[1].Value; if (version.StartsWith("1.4.")) { VAR_DELIMITER = new char[] { '|' }; return AsteriskVersion.ASTERISK_1_4; } else if (version.StartsWith("1.6.")) { VAR_DELIMITER = new char[] { '|' }; return Manager.AsteriskVersion.ASTERISK_1_6; } else if (version.StartsWith("1.8.")) { VAR_DELIMITER = new char[] { '|' }; return Manager.AsteriskVersion.ASTERISK_1_8; } else if (version.StartsWith("10.")) { VAR_DELIMITER = new char[] { '|' }; return Manager.AsteriskVersion.ASTERISK_10; } else if (version.StartsWith("11.")) { VAR_DELIMITER = new char[] { ',' }; return Manager.AsteriskVersion.ASTERISK_11; } else if (version.StartsWith("12.")) { VAR_DELIMITER = new char[] { ',' }; return Manager.AsteriskVersion.ASTERISK_12; } else if (version.StartsWith("13.")) { VAR_DELIMITER = new char[] { ',' }; return Manager.AsteriskVersion.ASTERISK_13; } else throw new ManagerException("Unknown Asterisk version " + version); } } } } Response.ManagerResponse showVersionFilesResponse = SendAction(new Action.CommandAction("show version files"), defaultResponseTimeout * 2); if (showVersionFilesResponse is Response.CommandResponse) { IList showVersionFilesResult = ((Response.CommandResponse)showVersionFilesResponse).Result; if (showVersionFilesResult != null && showVersionFilesResult.Count > 0) { string line1; line1 = (string)showVersionFilesResult[0]; if (line1 != null && line1.StartsWith("File")) return AsteriskVersion.ASTERISK_1_2; } } return AsteriskVersion.ASTERISK_1_0; } #endregion #region connect() protected internal bool connect() { bool result = false; bool startReader = false; lock (lockSocket) { if (mrSocket == null) { #if LOGGER logger.Info("Connecting to {0}:{1}", hostname, port); #endif try { mrSocket = new SocketConnection(hostname, port, socketEncoding); result = mrSocket.IsConnected; } #if LOGGER catch (Exception ex) { logger.Info("Connect - Exception : {0}", ex.Message); #else catch { #endif result = false; } if (result) { if (mrReader == null) { mrReader = new ManagerReader(this); mrReaderThread = new Thread(mrReader.Run) { IsBackground = true, Name = "ManagerReader-" + DateTime.Now.Second }; mrReader.Socket = mrSocket; startReader = true; } else { mrReader.Socket = mrSocket; } mrReader.Reinitialize(); } else { mrSocket = null; } } } if (startReader) { mrReaderThread.Start(); } return IsConnected(); } #endregion #region disconnect() /// Closes the socket connection. private void disconnect(bool withDie) { lock (lockSocket) { if (withDie) { reconnectEnable = false; reconnected = false; enableEvents = true; } if (mrReader != null) { if (withDie) { mrReader.Die = true; mrReader = null; } else mrReader.Socket = null; } if (this.mrSocket != null) { mrSocket.Close(); mrSocket = null; } responseEventHandlers.Clear(); responseHandlers.Clear(); pingHandlers.Clear(); } } #endregion #region reconnect(bool init) /// /// Reconnects to the asterisk server when the connection is lost.
/// While keepAlive is true we will try to reconnect. /// Reconnection attempts will be stopped when the logoff() method /// is called or when the login after a successful reconnect results in an /// AuthenticationFailedException suggesting that the manager /// credentials have changed and keepAliveAfterAuthenticationFailure is not set.
/// This method is called when a DisconnectEvent is received from the reader. ///
private void reconnect(bool init) { #if LOGGER logger.Warning("reconnect (init: {0}), reconnectCount:{1}", init, reconnectCount); #endif if (init) reconnectCount = 0; else if (reconnectCount++ > reconnectRetryMax) reconnectEnable = false; if (reconnectEnable) { #if LOGGER logger.Warning("Try reconnect."); #endif enableEvents = false; reconnected = true; disconnect(false); int retryCount = 0; while (reconnectEnable && !mrReader.Die) { if (retryCount >= reconnectRetryMax) reconnectEnable = false; else { try { if (retryCount < reconnectRetryFast) { // Try to reconnect quite fast for the first times // this succeeds if the server has just been restarted #if LOGGER logger.Info("Reconnect delay : {0}, retry : {1}", reconnectIntervalFast, retryCount); #endif Thread.Sleep(reconnectIntervalFast); } else { // slow down after unsuccessful attempts assuming a shutdown of the server #if LOGGER logger.Info("Reconnect delay : {0}, retry : {1}", reconnectIntervalMax, retryCount); #endif Thread.Sleep(reconnectIntervalMax); } } catch (ThreadInterruptedException) { continue; } #if LOGGER catch (Exception ex) { logger.Info("Reconnect delay exception : ", ex.Message); #else catch { #endif continue; } try { #if LOGGER logger.Info("Try connect."); #endif if (connect()) break; } #if LOGGER catch (Exception ex) { logger.Info("Connect exception : ", ex.Message); #else catch { #endif } retryCount++; } } } if (!reconnectEnable) { #if LOGGER logger.Info("Can't reconnect."); #endif enableEvents = true; reconnected = false; disconnect(true); fireEvent(new DisconnectEvent(this)); } } #endregion #region createInternalActionId() /// /// Creates a new unique internal action id based on the hash code of this connection and a sequence. /// private string createInternalActionId() { return this.GetHashCode() + "_" + (this.actionIdCount++); } #endregion #region Login() /// /// Logs in to the Asterisk manager using asterisk's MD5 based /// challenge/response protocol. The login is delayed until the protocol /// identifier has been received by the reader. /// /// AuthenticationFailedException if the username and/or password are incorrect /// TimeoutException if no response is received within the specified timeout period /// /// public void Login() { login(defaultResponseTimeout); } /// /// Log in to the Asterisk manager using asterisk's MD5 based /// challenge/response protocol. The login is delayed until the protocol /// identifier has been received by the reader. /// /// Timeout in milliseconds to login. public void Login(int timeout) { login(timeout); } #endregion #region IsConnected() /// Returns true if there is a socket connection to the /// asterisk server, false otherwise. /// /// /// true if there is a socket connection to the /// asterisk server, false otherwise. /// public bool IsConnected() { bool result = false; lock (lockSocket) result = mrSocket != null && mrSocket.IsConnected; return result; } #endregion #region Logoff() /// /// Sends a LogoffAction and disconnects from the server. /// public void Logoff() { lock (lockSocket) { // stop reconnecting when we got disconnected reconnectEnable = false; if (mrReader != null && mrSocket != null) try { mrReader.IsLogoff = true; SendAction(new Action.LogoffAction()); } catch { } } disconnect(true); } #endregion #region SendAction(action) /// /// Send Action with default timeout. /// /// /// public Response.ManagerResponse SendAction(Action.ManagerAction action) { return SendAction(action, defaultResponseTimeout); } #endregion #region SendAction(action, timeout) /// /// Send action ans with timeout (milliseconds) /// /// action to send /// timeout in milliseconds /// public Response.ManagerResponse SendAction(ManagerAction action, int timeout) { AutoResetEvent autoEvent = new AutoResetEvent(false); ResponseHandler handler = new ResponseHandler(action, autoEvent); int hash = SendAction(action, handler); bool result = autoEvent.WaitOne(timeout <= 0 ? -1 : timeout, true); RemoveResponseHandler(handler); if (result) return handler.Response; throw new TimeoutException("Timeout waiting for response to " + action.Action); } #endregion #region SendAction(action, responseHandler) /// /// Send action ans with timeout (milliseconds) /// /// action to send /// Response Handler /// public int SendAction(ManagerAction action, IResponseHandler responseHandler) { if (action == null) throw new ArgumentException("Unable to send action: action is null."); if (mrSocket == null) throw new SystemException("Unable to send " + action.Action + " action: not connected."); // if the responseHandler is null the user is obviously not interested in the response, thats fine. string internalActionId = string.Empty; if (responseHandler != null) { internalActionId = createInternalActionId(); responseHandler.Hash = internalActionId.GetHashCode(); AddResponseHandler(responseHandler); } SendToAsterisk(action, internalActionId); return responseHandler != null ? responseHandler.Hash : 0; } #endregion #region SendActionAsync(action) /// /// Asynchronously send Action async with default timeout. /// /// action to send public Task SendActionAsync(ManagerAction action) { return SendActionAsync(action, null); } #endregion #region SendActionAsync(action, timeout) /// /// Asynchronously send Action async. /// /// action to send /// cancellation Token public Task SendActionAsync(ManagerAction action, CancellationTokenSource cancellationToken) { var handler = new TaskResponseHandler(action); var source = handler.TaskCompletionSource; SendAction(action, handler); if (cancellationToken != null) cancellationToken.Token.Register(() => { source.TrySetCanceled(); }); return source.Task.ContinueWith(x => { RemoveResponseHandler(handler); return x.Result; }); } #endregion #region SendEventGeneratingAction(action) public ResponseEvents SendEventGeneratingAction(ManagerActionEvent action) { return SendEventGeneratingAction(action, defaultEventTimeout); } #endregion #region SendEventGeneratingAction(action, timeout) /// /// /// /// /// wait timeout in milliseconds /// public ResponseEvents SendEventGeneratingAction(ManagerActionEvent action, int timeout) { if (action == null) throw new ArgumentException("Unable to send action: action is null."); else if (action.ActionCompleteEventClass() == null) throw new ArgumentException("Unable to send action: ActionCompleteEventClass is null."); else if (!typeof(ResponseEvent).IsAssignableFrom(action.ActionCompleteEventClass())) throw new ArgumentException("Unable to send action: ActionCompleteEventClass is not a ResponseEvent."); if (mrSocket == null) throw new SystemException("Unable to send " + action.Action + " action: not connected."); AutoResetEvent autoEvent = new AutoResetEvent(false); ResponseEventHandler handler = new ResponseEventHandler(this, action, autoEvent); string internalActionId = createInternalActionId(); handler.Hash = internalActionId.GetHashCode(); AddResponseHandler(handler); AddResponseEventHandler(handler); SendToAsterisk(action, internalActionId); bool result = autoEvent.WaitOne(timeout <= 0 ? -1 : timeout, true); RemoveResponseHandler(handler); RemoveResponseEventHandler(handler); if (result) return handler.ResponseEvents; throw new EventTimeoutException("Timeout waiting for response or response events to " + action.Action, handler.ResponseEvents); } #endregion #region Response Handler helpers private void AddResponseHandler(IResponseHandler handler) { lock (lockHandlers) { if (handler.Action is PingAction) pingHandlers[handler.Hash] = handler; else responseHandlers[handler.Hash] = handler; } } private void AddResponseEventHandler(IResponseHandler handler) { lock (lockHandlers) responseEventHandlers[handler.Hash] = handler; } /// /// Delete an instance of a class from handlers list. /// /// Class instance . public void RemoveResponseHandler(IResponseHandler handler) { int hash = handler.Hash; if (hash != 0) lock (lockHandlers) if (responseHandlers.ContainsKey(hash)) responseHandlers.Remove(hash); } internal void RemoveResponseEventHandler(IResponseHandler handler) { int hash = handler.Hash; if (hash != 0) lock (lockHandlers) if (responseEventHandlers.ContainsKey(hash)) responseEventHandlers.Remove(hash); } private IResponseHandler GetRemoveResponseHandler(int hash) { IResponseHandler handler = null; if (hash != 0) lock (lockHandlers) if (responseHandlers.ContainsKey(hash)) { handler = responseHandlers[hash]; responseHandlers.Remove(hash); } return handler; } private IResponseHandler GetRemoveResponseEventHandler(int hash) { IResponseHandler handler = null; if (hash != 0) lock (lockHandlers) if (responseEventHandlers.ContainsKey(hash)) { handler = responseEventHandlers[hash]; responseEventHandlers.Remove(hash); } return handler; } private IResponseHandler GetResponseHandler(int hash) { IResponseHandler handler = null; if (hash != 0) lock (lockHandlers) if (responseHandlers.ContainsKey(hash)) handler = responseHandlers[hash]; return handler; } private IResponseHandler GetResponseEventHandler(int hash) { IResponseHandler handler = null; if (hash != 0) lock (lockHandlers) if (responseEventHandlers.ContainsKey(hash)) handler = responseEventHandlers[hash]; return handler; } #endregion #region SendToAsterisk(ManagerAction action, string internalActionId) internal void SendToAsterisk(ManagerAction action, string internalActionId) { if (mrSocket == null) throw new SystemException("Unable to send action: socket is null"); string buffer = BuildAction(action, internalActionId); #if LOGGER logger.Debug("Sent action : '{0}' : {1}", internalActionId, action); #endif if (sa == null) sa = new SendToAsteriskDelegate(sendToAsterisk); sa.Invoke(buffer); } private delegate void SendToAsteriskDelegate(string buffer); private SendToAsteriskDelegate sa = null; private void sendToAsterisk(string buffer) { lock (lockSocketWrite) { mrSocket.Write(buffer); } } #endregion #region BuildAction(action) public string BuildAction(Action.ManagerAction action) { return BuildAction(action, null); } #endregion #region BuildAction(action, internalActionId) public string BuildAction(ManagerAction action, string internalActionId) { MethodInfo getter; object value; StringBuilder sb = new StringBuilder(); string valueAsString = string.Empty; if (typeof(Action.ProxyAction).IsAssignableFrom(action.GetType())) sb.Append(string.Concat("ProxyAction: ", action.Action, Common.LINE_SEPARATOR)); else sb.Append(string.Concat("Action: ", action.Action, Common.LINE_SEPARATOR)); if (string.IsNullOrEmpty(internalActionId)) valueAsString = action.ActionId; else valueAsString = string.Concat(internalActionId, Common.INTERNAL_ACTION_ID_DELIMITER, action.ActionId); if (!string.IsNullOrEmpty(valueAsString)) sb.Append(string.Concat("ActionID: ", valueAsString, Common.LINE_SEPARATOR)); Dictionary getters = Helper.GetGetters(action.GetType()); foreach (string name in getters.Keys) { string nameLower = name.ToLower(Helper.CultureInfo); if (nameLower == "class" || nameLower == "action" || nameLower == "actionid") continue; getter = getters[name]; Type propType = getter.ReturnType; if (!(propType == typeof(string) || propType == typeof(bool) || propType == typeof(double) || propType == typeof(DateTime) || propType == typeof(int) || propType == typeof(long) || propType == typeof(Dictionary) ) ) continue; try { value = getter.Invoke(action, new object[] { }); } catch (UnauthorizedAccessException ex) { #if LOGGER logger.Error("Unable to retrieve property '" + name + "' of " + action.GetType(), ex); continue; #else throw new ManagerException("Unable to retrieve property '" + name + "' of " + action.GetType(), ex); #endif } catch (TargetInvocationException ex) { #if LOGGER logger.Error("Unable to retrieve property '" + name + "' of " + action.GetType(), ex); continue; #else throw new ManagerException("Unable to retrieve property '" + name + "' of " + action.GetType(), ex); #endif } if (value == null) continue; if (value is string) { valueAsString = (string)value; if (valueAsString.Length == 0) continue; } else if (value is bool) valueAsString = ((bool)value ? "true" : "false"); else if (value is DateTime) valueAsString = value.ToString(); else if (value is IDictionary) { valueAsString = Helper.JoinVariables((IDictionary)value, Common.LINE_SEPARATOR, ": "); if (valueAsString.Length == 0) continue; sb.Append(valueAsString); sb.Append(Common.LINE_SEPARATOR); continue; } else valueAsString = value.ToString(); sb.Append(string.Concat(name, ": ", valueAsString, Common.LINE_SEPARATOR)); } IActionVariable actionVar = action as IActionVariable; if (actionVar != null) { var variables = actionVar.GetVariables(); if (variables != null && variables.Count > 0) { sb.Append(string.Concat("Variable: ", Helper.JoinVariables(actionVar.GetVariables(), VAR_DELIMITER, "="), Common.LINE_SEPARATOR)); } } sb.Append(Common.LINE_SEPARATOR); return sb.ToString(); } #endregion #region GetProtocolIdentifier() public string GetProtocolIdentifier() { return this.protocolIdentifier; } #endregion #region RegisterUserEventClass(class) /// /// Register User Event Class /// /// public void RegisterUserEventClass(Type userEventClass) { Helper.RegisterEventClass(registeredEventClasses, userEventClass); } #endregion #region DispatchResponse(response) /// /// This method is called by the reader whenever a ManagerResponse is /// received. The response is dispatched to the associated ManagerResponseHandler. /// /// the response received by the reader /// internal void DispatchResponse(Dictionary buffer) { #if LOGGER logger.Debug("Dispatch response packet : {0}", Helper.JoinVariables(buffer, ", ", ": ")); #endif DispatchResponse(buffer, null); } internal void DispatchResponse(ManagerResponse response) { #if LOGGER logger.Debug("Dispatch response : {0}", response); #endif DispatchResponse(null, response); } internal void DispatchResponse(Dictionary buffer, ManagerResponse response) { string responseActionId = string.Empty; string actionId = string.Empty; IResponseHandler responseHandler = null; if (buffer != null) { if (buffer["response"].ToLower(Helper.CultureInfo) == "error") response = new ManagerError(buffer); else if (buffer.ContainsKey("actionid")) actionId = buffer["actionid"]; } if (response != null) actionId = response.ActionId; if (!string.IsNullOrEmpty(actionId)) { int hash = Helper.GetInternalActionId(actionId).GetHashCode(); responseActionId = Helper.StripInternalActionId(actionId); responseHandler = GetRemoveResponseHandler(hash); if (response != null) response.ActionId = responseActionId; if (responseHandler != null) { if (response == null) { ManagerActionResponse action = responseHandler.Action as ManagerActionResponse; if (action == null || (response = action.ActionCompleteResponseClass() as ManagerResponse) == null) response = Helper.BuildResponse(buffer); else Helper.SetAttributes(response, buffer); response.ActionId = responseActionId; } try { responseHandler.HandleResponse(response); } catch (Exception ex) { #if LOGGER logger.Error("Unexpected exception in responseHandler {0}\n{1}", response, ex); #else throw new ManagerException("Unexpected exception in responseHandler " + responseHandler.GetType().FullName, ex); #endif } } } if (response == null && buffer.ContainsKey("ping") && buffer["ping"] == "Pong") { response = Helper.BuildResponse(buffer); foreach (ResponseHandler pingHandler in pingHandlers.Values) pingHandler.HandleResponse(response); pingHandlers.Clear(); } if (!reconnected) return; if (response == null) { response = Helper.BuildResponse(buffer); response.ActionId = responseActionId; } #if LOGGER logger.Info("Reconnected - DispatchEvent : " + response); #endif #region Support background reconnect if (response is ChallengeResponse) { string key = null; if (response.IsSuccess()) { ChallengeResponse challengeResponse = (ChallengeResponse)response; string challenge = challengeResponse.Challenge; try { Util.MD5Support md = Util.MD5Support.GetInstance(); if (challenge != null) md.Update(UTF8Encoding.UTF8.GetBytes(challenge)); if (password != null) md.Update(UTF8Encoding.UTF8.GetBytes(password)); key = Helper.ToHexString(md.DigestData); } #if LOGGER catch (Exception ex) { logger.Error("Unable to create login key using MD5 Message Digest", ex); #else catch { #endif key = null; } } bool fail = true; if (!string.IsNullOrEmpty(key)) try { Action.LoginAction loginAction = new Action.LoginAction(username, "MD5", key); SendAction(loginAction, null); fail = false; } catch { } if (fail) if (keepAliveAfterAuthenticationFailure) reconnect(true); else disconnect(true); } else if (response is ManagerError) { if (keepAliveAfterAuthenticationFailure) reconnect(true); else disconnect(true); } else if (response is ManagerResponse) { if (response.IsSuccess()) { reconnected = false; enableEvents = true; reconnectEnable = keepAlive; ConnectEvent ce = new ConnectEvent(this); ce.Reconnect = true; ce.ProtocolIdentifier = protocolIdentifier; fireEvent(ce); } else if (keepAliveAfterAuthenticationFailure) reconnect(true); else disconnect(true); } #endregion } #endregion #region DispatchEvent(...) /// /// This method is called by the reader whenever a ManagerEvent is received. /// The event is dispatched to all registered ManagerEventHandlers. /// /// the event received by the reader /// internal void DispatchEvent(Dictionary buffer) { ManagerEvent e = Helper.BuildEvent(registeredEventClasses, this, buffer); DispatchEvent(e); } internal void DispatchEvent(ManagerEvent e) { #if LOGGER logger.Debug("Dispatching event: {0}", e); #endif if (e is ResponseEvent) { ResponseEvent responseEvent = (ResponseEvent)e; if (!string.IsNullOrEmpty(responseEvent.ActionId) && !string.IsNullOrEmpty(responseEvent.InternalActionId)) { ResponseEventHandler eventHandler = (ResponseEventHandler)GetResponseEventHandler(responseEvent.InternalActionId.GetHashCode()); if (eventHandler != null) try { eventHandler.HandleEvent(e); } catch (SystemException ex) { #if LOGGER logger.Error("Unexpected exception", ex); #else throw ex; #endif } } } #region ConnectEvent if (e is ConnectEvent) { string protocol = ((ConnectEvent)e).ProtocolIdentifier; #if LOGGER logger.Info("Connected via {0}", protocol); #endif if (!string.IsNullOrEmpty(protocol) && protocol.StartsWith("Asterisk Call Manager")) { this.protocolIdentifier = protocol; } else { this.protocolIdentifier = (string.IsNullOrEmpty(protocol) ? "Empty" : protocol); #if LOGGER logger.Warning("Unsupported protocol version '{0}'. Use at your own risk.", protocol); #endif } if (reconnected) { #if LOGGER logger.Info("Send Challenge action."); #endif ChallengeAction challengeAction = new ChallengeAction(); try { SendAction(challengeAction, null); } #if LOGGER catch (Exception ex) { logger.Info("Send Challenge fail : ", ex.Message); #else catch { #endif disconnect(true); } return; } } #endregion if (reconnected && e is DisconnectEvent) { ((DisconnectEvent)e).Reconnect = true; fireEvent(e); reconnect(false); } else if (!reconnected && reconnectEnable && (e is DisconnectEvent || e is ShutdownEvent)) { ((ConnectionStateEvent)e).Reconnect = true; fireEvent(e); reconnect(true); } else fireEvent(e); } private void eventComplete(IAsyncResult result) { } private void fireEvent(ManagerEvent e) { if (enableEvents && internalEvent != null) if (UseASyncEvents) internalEvent.BeginInvoke(this, e, new AsyncCallback(eventComplete), null); else internalEvent.Invoke(this, e); } /// /// This method is called when send event to client if subscribed /// /// EventHandler argument /// Event delegate /// ManagerEvent or inherited class. Argument of eventHandler. private bool fireEvent(EventHandler asterEvent, ManagerEvent arg) where T : ManagerEvent { if (asterEvent != null) { asterEvent(this, (T)arg); return true; } return false; } #endregion } }