Message matching
Processing a message is disclosed. For each field group applicable to a message from one or more unique field groups of one or more fields identified using one or more content matchers, a compiled message corresponding to the field group applicable to the message is generated. It is determined whether one or more of the compiled messages matches one or more of the one or more content matchers.
1. A system, comprising:
a processor; and
a memory coupled to the processor and configured to provide the processor with instructions, wherein the processor is configured to:
receive, from a message provider server via a network, a message in a first format, wherein the message is part of a message stream comprising a plurality of messages and wherein the message is comprised of one or more structured field value pairs;
receive one or more content matchers from a subscriber device via the network, wherein the one or more content matchers includes a content matcher, wherein the content matcher indicates one or more messages of the message stream to which the subscriber device is subscribed to receive, wherein the content matcher includes one or more structured field value pairs specified by a subscriber, wherein the one or more structured field value pairs of the content matcher indicate content of the one or more messages to which the subscriber device is subscribed to receive, wherein a first field group of a set of field groups of one or more fields is determined by extracting all field identifiers included in the one or more content matchers;
convert the content matcher into a standardized format, wherein the standardized format rearranges the one or more structured field value pairs of the content matcher in a first determined order;
compile each of the one or more content matchers, wherein compiling at least one of the one or more content matchers includes reversing ordering of each of the one or more field value pairs so that a field value pair becomes a value field pair;
generate a compiled message at least in part by rearranging the one or more structured field values pairs of the message in a second determined order;
determine whether the one or more structured field value pairs of the compiled message matches the one or more structured field value pairs of the converted content matcher, wherein a structured field value pair of the compiled message matches a structured field value pair of the converted content matcher in the event a field of the structured field value pair of the compiled message matches a field of the structured field value pair of the converted content matcher and a value of the structured field value pair of the compiled message matches a value of the structured field value pair of the converted content matcher; and
in response to determining that the one or more structured field value pairs of the compiled message match the one or more structured field value pairs of the converted content matcher, distribute to the subscriber device via the network the message that is comprised of one or more structured field value pairs to the subscriber device.
2. The system of claim 1 , wherein each of the one or more content matchers specifies at least one field and an associated value.
3. The system of claim 2 , wherein the associated value is a Boolean value.
4. The system of claim 1 , wherein the content matcher and the message are specified in JavaScript Object Notation.
5. The system of claim 1 , wherein each of the one or more content matchers is associated with one or more identifiers of one or more subscribers that are identified to receive any message that matches the associated content matcher.
6. The system of claim 1 , wherein the all field identifiers is arranged in the field group in an order associated with an alphabetical order of the all field identifiers.
7. The system of claim 1 , wherein a set of field groups is determined by determining all fields included in each of the one or more content matchers and storing the fields of each content matcher as a grouping only if a same grouping has not been previously stored.
8. The system of claim 1 , wherein the one or more compiled content matchers are stored in a data storage structure that associates each of the one or more compiled content matchers with one or more message subscribers.
9. The system of claim 1 , wherein a field group of a set of field groups is identified as applicable to the message at least in part by determining all fields included in the one or more content matchers and determining which field group of the set of field groups is at least a subset of the all fields of the message.
10. The system of claim 1 , wherein generating the compiled message includes extracting one or more field value pairs included in the message for each field of the one or more field value pairs and ordering one or more field value pairs in the determined order.
11. The system of claim 10 , wherein generating the compiled message includes reversing ordering of each of the one or more field value pairs so that a field value pair becomes a value field pair.
12. The system of claim 1 , wherein determining whether the one or more structured field value pairs of the compiled message matches the one or more structured field value pairs of the converted content matcher includes searching a data storage structure storing a compiled version of one or more content matchers to determine whether the one or more structured field value pairs of the compiled message matches one or more of the one or more structured field value pairs of one or more content matchers.
13. A method, comprising:
receiving, from a message provider server via a network, a message in a first format, wherein the message is part of a message stream comprising a plurality of messages and wherein the message is comprised of one or more structured field value pairs;
receiving one or more content matchers from a subscriber device via the network, wherein the one or more content matchers includes a content matcher, wherein the content matcher indicates one or more messages of the message stream to which the subscriber device is subscribed to receive, wherein the content matcher includes one or more structured field value pairs specified by a subscriber, wherein the one or more structured field value pairs of the content matcher indicate content of the one or more messages to which the subscriber device is subscribed to receive, wherein a first field group of a set of field groups of one or more fields is determined by extracting all field identifiers included in the one or more content matchers;
converting the content matcher into a standardized format, wherein the standardized format rearranges the one or more structured field value pairs of the content matcher in a first determined order;
compiling each of the one or more content matchers, wherein compiling at least one of the one or more content matchers includes reversing ordering of each of the one or more field value pairs so that a field value pair becomes a value field pair;
generating a compiled message at least in part by rearranging the one or more structured field value pairs of the message in a second determined order;
determining, using a processor, whether the one or more structured field value pairs of the compiled message matches the one or more structured field value pairs of the converted content matcher, wherein a structured field value pair of the compiled message matches a structured field value pair of the converted content matcher in the event a field of the structured field value pair of the compiled message matches a field of the structured field value pair of the converted content matcher and a value of the structured field value pair of the compiled message matches a value of the structured field value pair of the converted content matcher; and
in response to determining that the one or more structured field value pairs of the compiled message match the one or more structured field value pairs of the converted content matcher, distributing to the subscriber device via the network the message that is comprised of one or more structured field value pairs to the subscriber device.
14. A computer program product, the computer program product being embodied in a tangible non-transitory computer readable storage medium and comprising computer instructions for:
receiving, from a message provider server via a network, a message in a first format, wherein the message is part of a message stream comprising a plurality of messages and wherein the message is comprised of one or more structured field value pairs;
receiving one or more content matchers from a subscriber device via the network, wherein the one or more content matchers includes a content matcher, wherein the content matcher indicates one or more messages of the message stream to which the subscriber device is subscribed to receive, wherein the content matcher includes one or more structured field value pairs specified by a subscriber, wherein the one or more structured field value pairs of the content matcher indicate content of the one or more messages to which the subscriber device is subscribed to receive, wherein a first field group of a set of field groups of one or more fields is determined by extracting all field identifiers included in the one or more content matchers;
converting the content matcher into a standardized format, wherein the standardized format rearranges the one or more structured field value pairs of the content matcher in a first determined order;
compiling each of the one or more content matchers, wherein compiling at least one of the one or more content matchers includes reversing ordering of each of the one or more field value pairs so that a field value pair becomes a value field pair;
generating a compiled message at least in part by rearranging the one or more structured field value pairs of the message in a second determined order;
determining whether the one or more structured field value pairs of the compiled message matches the one or more structured field value pairs of the converted content matcher, wherein a structured field value pair of the compiled message matches a structured field value pair of the converted content matcher in the event a field of the structured field value pair of the compiled message matches a field of the structured field value pair of the converted content matcher and a value of the structured field value pair of the compiled message matches a value of the structured field value pair of the converted content matcher; and
in response to determining that the one or more structured field value pairs of the compiled message match the one or more structured field value pairs of the converted content matcher, distributing to the subscriber device via the network the message that is comprised of one or more structured field value pairs to the subscriber device.