public partial class Form1 : Form
{
XmppClientConnection xmppCon
= new XmppClientConnection
(); public Form1()
{
InitializeComponent();
InitXmppSettings();
//Events
xmppCon
.OnAgentEnd += new ObjectHandler
(xmppCon_OnAgentEnd
); //xmppCon.OnAgentItem += new XmppClientConnection.AgentHandler(xmppCon_OnAgentItem);
xmppCon
.OnAgentStart += new ObjectHandler
(xmppCon_OnAgentStart
); xmppCon
.OnWriteXml += new XmlHandler
(xmppCon_OnWriteXml
); xmppCon
.OnReadXml += new XmlHandler
(xmppCon_OnReadXml
);
xmppCon
.OnAuthError += new XmppElementHandler
(xmppCon_OnAuthError
); xmppCon
.OnClose += new ObjectHandler
(xmppCon_OnClose
); xmppCon
.OnError += new ErrorHandler
(xmppCon_OnError
); xmppCon
.OnIq += new IqHandler
(xmppCon_OnIq
); xmppCon
.OnLogin += new ObjectHandler
(xmppCon_OnLogin
); xmppCon
.OnMessage += new MessageHandler
(xmppCon_OnMessage
); xmppCon
.OnPresence += new PresenceHandler
(xmppCon_OnPresence
); xmppCon
.OnRosterEnd += new ObjectHandler
(xmppCon_OnRosterEnd
); xmppCon
.OnRosterItem += new XmppClientConnection
.RosterHandler(xmppCon_OnRosterItem
); xmppCon
.OnRosterStart += new ObjectHandler
(xmppCon_OnRosterStart
);
xmppCon
.ClientSocket.OnReceive += new agsXMPP
.net.BaseSocket.OnSocketDataHandler(ClientSocket_OnReceive
); xmppCon
.ClientSocket.OnSend += new agsXMPP
.net.BaseSocket.OnSocketDataHandler(ClientSocket_OnSend
); }
private void InitXmppSettings()
{
string username = "username@gmail.com";
Jid jid
= new Jid
(username
); xmppCon.Server = jid.Server;
xmppCon.Username = jid.User;
xmppCon.Password = "password";
xmppCon.Priority = 10;
xmppCon.AutoResolveConnectServer = false;
xmppCon.KeepAlive = false;
xmppCon.Port = 5222;
xmppCon.UseCompression = false;
xmppCon.ConnectServer = "talk.l.google.com";
}
void ClientSocket_OnSend(object sender, byte[] data, int count)
{
if (InvokeRequired)
{
BeginInvoke
(new agsXMPP
.net.ClientSocket.OnSocketDataHandler(ClientSocket_OnSend
),
new object[] { sender, data, count
}); return;
}
}
void ClientSocket_OnReceive(object sender, byte[] data, int count)
{
if (InvokeRequired)
{
BeginInvoke
(new agsXMPP
.net.ClientSocket.OnSocketDataHandler(ClientSocket_OnReceive
),
new object[] { sender, data, count
}); return;
}
}
void xmppCon_OnWriteXml(object sender, string xml)
{
if (InvokeRequired)
{
BeginInvoke
(new XmlHandler
(xmppCon_OnWriteXml
),
new object[] { sender, xml
}); return;
}
}
void xmppCon_OnReadXml(object sender, string xml)
{
if (InvokeRequired)
{
BeginInvoke
(new XmlHandler
(xmppCon_OnReadXml
),
new object[] { sender, xml
}); return;
}
}
void xmppCon_OnRosterStart(object sender)
{
if (InvokeRequired)
{
BeginInvoke
(new ObjectHandler
(xmppCon_OnRosterStart
),
new object[] { sender
}); return;
}
}
void xmppCon_OnMessage(object sender, Message msg)
{
if (msg.Body == null)
return;
if (InvokeRequired)
{
BeginInvoke
(new agsXMPP
.protocol.client.MessageHandler(xmppCon_OnMessage
),
new object[] { sender, msg
}); return;
}
// check for xData Message
Element e
= msg
.SelectSingleElement(typeof(Data
)); if (e != null)
{
Data xdata = e as Data;
if (xdata.Type == XDataFormType.form)
{}
}
else
{
if (msg.Type == MessageType.chat)
{
}
}
}
private void xmppCon_OnMessage(object sender, agsXMPP.protocol.client.Message msg, object data)
{
if (InvokeRequired)
{
BeginInvoke
(new MessageCB
(xmppCon_OnMessage
),
new object[] { sender, msg, data
}); return;
}
}
void xmppCon_OnAuthError(object sender, Element e)
{
if (InvokeRequired)
{
BeginInvoke
(new XmppElementHandler
(xmppCon_OnAuthError
),
new object[] { sender, e
}); return;
}
}
void xmppCon_OnAgentStart(object sender)
{
}
void xmppCon_OnAgentEnd(object sender)
{
}
private bool ClientSocket_OnValidateCertificate(System.Security.Cryptography.X509Certificates.X509Certificate certificate, int[] certificateErrors)
{
return true;
}
void xmppCon_OnClose(object sender)
{
if (InvokeRequired)
{
BeginInvoke
(new agsXMPP
.ObjectHandler(xmppCon_OnClose
),
new object[] { sender
}); return;
}
}
void xmppCon_OnError(object sender, Exception ex)
{
if (InvokeRequired)
{
BeginInvoke
(new ErrorHandler
(xmppCon_OnError
),
new object[] { sender, ex
}); return;
}
}
void xmppCon_OnIq(object sender, IQ iq)
{
if (InvokeRequired)
{
BeginInvoke
(new IqHandler
(xmppCon_OnIq
),
new object[] { sender, iq
}); return;
}
Element query = iq.Query;
if (query != null)
{
if (query
.GetType() == typeof(agsXMPP
.protocol.iq.version.Version)) {
// its a version IQ VersionIQ
agsXMPP.protocol.iq.version.Version version = query as agsXMPP.protocol.iq.version.Version;
if (iq.Type == IqType.get)
{
// Somebody wants to know our client version, so send it back
iq.SwitchDirection();
iq.Type = IqType.result;
version.Name = "IM";
version.Ver = "1.0";
version.Os = Environment.OSVersion.ToString();
xmppCon.Send(iq);
}
}
}
}
void xmppCon_OnLogin(object sender)
{
if (InvokeRequired)
{
BeginInvoke
(new ObjectHandler
(xmppCon_OnLogin
),
new object[] { sender
}); return;
}
}
void xmppCon_OnPresence(object sender, Presence pres)
{
if (InvokeRequired)
{
BeginInvoke
(new agsXMPP
.protocol.client.PresenceHandler(xmppCon_OnPresence
),
new object[] { sender, pres
}); return;
}
}
void xmppCon_OnRosterEnd(object sender)
{
if (InvokeRequired)
{
BeginInvoke
(new ObjectHandler
(xmppCon_OnRosterEnd
),
new object[] { sender
}); return;
}
}
void xmppCon_OnRosterItem(object sender, RosterItem item)
{
if (InvokeRequired)
{
BeginInvoke
(new agsXMPP
.XmppClientConnection.RosterHandler(xmppCon_OnRosterItem
),
new object[] { this, item
}); return;
}
}
private void menuItem1_Click(object sender, EventArgs e)
{
this.Close();
Application.Exit();
}
private void menuItem3_Click(object sender, EventArgs e)
{
//xmppCon.UseStartTLS = false;
xmppCon.Open();
}
private void menuItem4_Click(object sender, EventArgs e)
{
xmppCon.Close();
}
}
msathya03
Show profile
Link to this post
This post was edited 2 times, last on 2018-03-22, 09:35 by 
