Neuron®
The Neuron® is the basis for the creation of open and secure federated networks for smart societies.
Loading...
Searching...
No Matches
SendTextMessage.cs
1using System;
2using System.Collections.Generic;
3using System.Text;
4using System.Threading.Tasks;
5using System.Xml;
6using Waher.Content;
7using Waher.Content.Xml;
8using Waher.IoTGateway;
9using Waher.Networking.HTTP;
10using Waher.Networking.XMPP;
11using Waher.Runtime.Inventory;
12using Waher.Script;
13using Waher.Script.Abstraction.Elements;
14using Waher.Service.IoTBroker.DataStorage;
15
16namespace Waher.Service.IoTBroker.WebServices.Agent.Xmpp
17{
21 public class SendTextMessage : AgentXmppPostResource
22 {
26 public SendTextMessage()
27 : base("Xmpp/SendTextMessage",
28 new KeyValuePair<Type, Expression>(typeof(Dictionary<string, object>), new Expression(jsonPattern)),
29 new KeyValuePair<Type, Expression>(typeof(XmlDocument), new Expression(xmlPattern)))
30 {
31 }
32
33 private static readonly string jsonPattern = Resources.LoadResourceAsText(typeof(SendTextMessage).Namespace + ".JSON.SendTextMessage.req");
34 private static readonly string xmlPattern = Resources.LoadResourceAsText(typeof(SendTextMessage).Namespace + ".XML.SendTextMessage.req");
35
44 public override async Task POST(HttpRequest Request, HttpResponse Response, Dictionary<string, IElement> Parameters)
45 {
46 AccountUser User = AssertUserAuthenticated(Request);
47
48 string To = (string)Parameters["PTo"].AssociatedObjectValue;
49
50 if (string.IsNullOrEmpty(To))
51 throw new BadRequestException("Missing recipient JID.");
52
53 if (!IsValidJID(To))
54 throw new BadRequestException("Recpient must be a Bare or Full JID.");
55
56 string Message = (string)Parameters["PMessage"].AssociatedObjectValue;
57
58 if (string.IsNullOrEmpty(Message))
59 throw new BadRequestException("Message is empty.");
60
61 string Subject = (string)Parameters["PSubject"]?.AssociatedObjectValue;
62 string Language = (string)Parameters["PLanguage"]?.AssociatedObjectValue;
63 string Id = (string)Parameters["PId"]?.AssociatedObjectValue;
64
65 StringBuilder Xml = new StringBuilder();
66
67 if (!string.IsNullOrEmpty(Subject))
68 {
69 Xml.Append("<subject>");
70 Xml.Append(XML.Encode(Subject));
71 Xml.Append("</subject>");
72 }
73
74 Xml.Append("<body>");
75 Xml.Append(XML.Encode(Message));
76 Xml.Append("</body>");
77
78 if (string.IsNullOrEmpty(Id))
79 Id = Guid.NewGuid().ToString();
80
81 bool Result;
82
83 if (XmppServerModule.Server is null)
84 {
85 XmppClient Client = Gateway.XmppClient;
86
87 Result = false;
88
89 if (Client is null)
90 {
91 if (Types.TryGetModuleParameter("XMPP", out object Obj) && Obj is XmppClient Client2)
92 Client = Client2;
93 }
94
95 if (Client is null)
96 throw new ServiceUnavailableException("XMPP Client not available.");
97
98 await Client.SendMessage(QoSLevel.Unacknowledged, MessageType.Chat, Id, To, Xml.ToString(),
99 string.Empty, string.Empty, Language, string.Empty, string.Empty, null, null);
100
101 Result = true;
102 }
103 else
104 {
105 Result = await XmppServerModule.Server.SendMessage("chat", Id,
106 User.Account.UserName + "@" + XmppServerModule.Server.Domain, To,
107 Language, Xml.ToString());
108 }
109
110 await Response.Return(new NamedDictionary<string, object>("StanzaResult", AgentNamespace)
111 {
112 { "sent", Result },
113 { "id", Id }
114 });
115 }
116 }
117}
Waher.Content.NamedDictionary
A Named dictionary is a dictionary, with a local name and a namespace. Use it to return content that ...
Definition: NamedDictionary.cs:13
Waher.Content.Resources
Static class managing loading of resources stored as embedded resources or in content files.
Definition: Resources.cs:15
Waher.Content.Resources.LoadResourceAsText
static string LoadResourceAsText(string ResourceName)
Loads a text resource from an embedded resource.
Definition: Resources.cs:96
Waher.Content.Xml.XML
Helps with common XML-related tasks.
Definition: XML.cs:19
Waher.Content.Xml.XML.Encode
static string Encode(string s)
Encodes a string for use in XML.
Definition: XML.cs:27
Waher.IoTGateway.Gateway
Static class managing the runtime environment of the IoT Gateway.
Definition: Gateway.cs:126
Waher.IoTGateway.Gateway.XmppClient
static XmppClient XmppClient
XMPP Client connection of gateway.
Definition: Gateway.cs:3187
Waher.Networking.HTTP.BadRequestException
The request could not be understood by the server due to malformed syntax. The client SHOULD NOT repe...
Definition: BadRequestException.cs:9
Waher.Networking.HTTP.HttpRequest
Represents an HTTP request.
Definition: HttpRequest.cs:18
Waher.Networking.HTTP.HttpResponse
Represets a response of an HTTP client request.
Definition: HttpResponse.cs:21
Waher.Networking.HTTP.HttpResponse.Return
async Task Return(object Object)
Returns an object to the client. This method can only be called once per response,...
Definition: HttpResponse.cs:895
Waher.Networking.HTTP.ServiceUnavailableException
The server is currently unable to handle the request due to a temporary overloading or maintenance of...
Definition: ServiceUnavailableException.cs:11
Waher.Networking.XMPP.XmppClient
Manages an XMPP client connection. Implements XMPP, as defined in https://tools.ietf....
Definition: XmppClient.cs:59
Waher.Networking.XMPP.XmppClient.SendMessage
Task SendMessage(MessageType Type, string To, string CustomXml, string Body, string Subject, string Language, string ThreadId, string ParentThreadId)
Sends a simple chat message
Definition: XmppClient.cs:5395
Waher.Runtime.Inventory.Types
Static class that dynamically manages types and interfaces available in the runtime environment.
Definition: Types.cs:14
Waher.Runtime.Inventory.Types.TryGetModuleParameter
static bool TryGetModuleParameter(string Name, out object Value)
Tries to get a module parameter value.
Definition: Types.cs:583
Waher.Script.Expression
Class managing a script expression.
Definition: Expression.cs:39
Waher.Service.IoTBroker.DataStorage.Account.UserName
CaseInsensitiveString UserName
User Name of account
Definition: Account.cs:99
Waher.Service.IoTBroker.WebServices.Agent.AgentResource.AssertUserAuthenticated
static AccountUser AssertUserAuthenticated(HttpRequest Request)
Makes sure the request is made by an authenticated API user.
Definition: AgentResource.cs:211
Waher.Service.IoTBroker.WebServices.Agent.AgentResource.AgentNamespace
const string AgentNamespace
https://waher.se/Schema/BrokerAgent.xsd
Definition: AgentResource.cs:28
Waher.Service.IoTBroker.WebServices.Agent.Xmpp.AgentXmppPostResource
Abstract base class for XMPP resources.
Definition: AgentXmppPostResource.cs:20
Waher.Service.IoTBroker.WebServices.Agent.Xmpp.AgentXmppPostResource.IsValidJID
static bool IsValidJID(string JID)
Checks if a string is a valid Bare or Full JID.
Definition: AgentXmppPostResource.cs:57
Waher.Service.IoTBroker.WebServices.Agent.Xmpp.SendTextMessage
Sends a text message to an XMPP recipient.
Definition: SendTextMessage.cs:22
Waher.Service.IoTBroker.WebServices.Agent.Xmpp.SendTextMessage.SendTextMessage
SendTextMessage()
Sends a text message to an XMPP recipient.
Definition: SendTextMessage.cs:26
Waher.Service.IoTBroker.WebServices.Agent.Xmpp.SendTextMessage.POST
override async Task POST(HttpRequest Request, HttpResponse Response, Dictionary< string, IElement > Parameters)
Executes the POST method on the resource.
Definition: SendTextMessage.cs:44
Waher.Service.IoTBroker.XmppServerModule
Service Module hosting the XMPP broker and its components.
Definition: XmppServerModule.cs:109
Waher.Content.Xml
Definition: XmlCodec.cs:11
Waher.Content
Definition: Array.cs:6
Waher.Networking.XMPP.QoSLevel
QoSLevel
Quality of Service Level for asynchronous messages. Support for QoS Levels must be supported by the r...
Definition: QoSLevel.cs:8
Waher.Networking.XMPP.MessageType
MessageType
Type of message received.
Definition: MessageType.cs:7