using Microsoft.Rtc.Signaling;

internal SipEndpoint m_SipEndPoint;
RealTimeServerConnectionManager m_RealTimeServerConnectionManager;
private AutomatedServices m_Services;

m_RealTimeServerConnectionManager = (RealTimeServerConnectionManager)new RealTimeServerTcpConnectionManager();
m_SipEndPoint = new SipEndpoint(textBoxSipUri.Text, SipAuthenticationProtocols.Kerberos, SipTransportType.Tcp, textBoxDomainName.Text);

string stockTicker = "myStockTickerSymbol";
m_Services = new AutomatedServices(stockTicker, m_SipEndPoint, backgroundWorker1);

using Microsoft.Rtc.Signaling;
using System.ComponentModel;
using System.Net;
using System.Net.Mime;

public class AutomatedServices : IOfferAnswer
{
}

private String m_Notification;
private SipEndpoint m_Endpoint;
private BackgroundWorker m_Worker;

public AutomatedServices(String Notification, SipEndpoint endpoint, BackgroundWorker Worker)
{
  //Stock ticker.
  m_Notification = Notification;

  //Validate the endpoint.
  if (endpoint != null)
  {
	m_Endpoint = endpoint;
  }

  else
  {
	throw new InvalidOperationException("Cannot pass a null endpoint to the Notification Operation");
  }

  //Store the URI the ticker symbol is sent to.
  Target To = new Target();
  To.SipUri = "sip:someone@example.com";

  //Send the message.
  m_Worker = Worker;
  SignalingSession Session = new SignalingSession(m_Endpoint, new RealTimeAddress(To.SipUri));
  Session.LocalParticipant.ApplicationContext = To;
  Session.OfferAnswerNegotiation = this;
  Session.MessageReceived += this.MessageReceived;
  Session.BeginParticipate(ParticipateCallback, Session);
}

private void MessageReceived(object sender, MessageReceivedEventArgs e)
{
  SignalingSession session = sender as SignalingSession;
  ContentType contentType = e.ContentType;
  MessageType messageType = e.MessageType;
  string message = String.Empty;

  if (contentType.MediaType.CompareTo("text/plain") == 0 && contentType.CharSet.CompareTo("utf-8") == 0)
  {
	message = Encoding.UTF8.GetString(e.GetBody());
  }
}

private void ParticipateCallback(IAsyncResult ar)
{
  SignalingSession Session = ar.AsyncState as SignalingSession;
  Target To = Session.LocalParticipant.ApplicationContext as Target;
  SipMessageData Response = null;

  try
  {
	Response = Session.EndParticipate(ar);
  }
  catch (OperationTimeoutException e)
  {
	string msg = e.ToString();
  }
  catch (FailureResponseException e)
  {
	string msg = e.ToString();
  }
  catch (ConnectionFailureException e)
  {
	string msg = e.ToString();
  }
  catch (RealTimeException e)
  {
	string msg = e.ToString();
  }
  finally
  {
	if (Response != null)
	{
	Session.BeginSendMessage(MessageType.Message, new ContentType("text/plain"), Encoding.UTF8.GetBytes(m_Notification), SendMessageCallback, Session);
}
  }
}

private void SendMessageCallback(IAsyncResult ar)
{
  SignalingSession Session = ar.AsyncState as SignalingSession;
  SipResponseData Response = null;

  try
  {
	Response = Session.EndSendMessage(ar);
  }
  catch (FailureResponseException e)
  {
	string msg = e.ToString();
  }
  catch (OperationTimeoutException e)
  {
	string msg = e.ToString();
  }
  catch (RealTimeException e)
  {
	string msg = e.ToString();
  }
  finally
  {
	Session.BeginTerminate(TerminateCallback, Session);
  }
}

private void TerminateCallback(IAsyncResult ar)
{
  SignalingSession Session = ar.AsyncState as SignalingSession;
  Session.EndTerminate(ar);
}

public ContentDescription GetAnswer(object sender, ContentDescription offer)
{
  return null;
}

public void HandleOfferInReInvite(object sender, OfferInReInviteEventArgs e)
{
  return;
}

public void HandleOfferInInviteResponse(object sender, OfferInInviteResponseEventArgs e)
{
  return;
}

public ContentDescription GetOffer(object sender)
{
  SignalingSession Session = sender as SignalingSession;
  IPAddress IpAddress;

  // This method is called back every time an outbound INVITE is sent.
  if (Session.Connection != null)
  {
	IpAddress = Session.Connection.LocalEndpoint.Address;
  }
  else
  {
	IpAddress = IPAddress.Any;
  }

  Sdp<SdpGlobalDescription, SdpMediaDescription> SessionDescription = new Sdp<SdpGlobalDescription, SdpMediaDescription>();

  //Set the origin line of the SDP
  //s, t, and v lines are automatically constructed
  SessionDescription.GlobalDescription.Origin.Version = 0;
  SessionDescription.GlobalDescription.Origin.SessionId = "0";
  SessionDescription.GlobalDescription.Origin.UserName = "-";
  SessionDescription.GlobalDescription.Origin.Connection.Set(IpAddress.ToString());

  //Set the connection line
  SessionDescription.GlobalDescription.Connection.TrySet(IpAddress.ToString());

  SdpMediaDescription mditem = new SdpMediaDescription("message");

  mditem.Port = 5060;
  mditem.TransportProtocol = "sip";
  mditem.Formats = "null";

  SdpAttribute aitem = new SdpAttribute("accept-types", "text/plain");

  mditem.Attributes.Add(aitem);

  //Append the Media description to the Global description
  SessionDescription.MediaDescriptions.Add(mditem);

  ContentType ct = new ContentType("application/sdp");

  return new ContentDescription(ct, SessionDescription.GetBytes());
}

public void SetAnswer(object sender, ContentDescription answer)
{
  return;
}

//This class stores the SIP URI
// receiving the service request.
public class Target
{
  string m_SipUri;
  public string SipUri
  {
	get
	{
	return m_SipUri;
}

	set
	{
	SipUriParser TargetUri;

	if (SipUriParser.TryParse(value, out TargetUri))
	{
		m_SipUri = value;
}

	else
	{
		throw new InvalidOperationException("Cannot assign the current value");
}
}
  }
}