Universal automatic data update detection and publication

Patent metadata

Field	Value
Publication number	US-10810228-B2
Application number	US-201615236683-A
Country	US
Kind code	B2
Filing date	Aug 15, 2016
Priority date	Nov 2, 2015
Publication date	Oct 20, 2020
Grant date	Oct 20, 2020

Abstract

Universal automatic data update detection and publication may include receiving a request for requested information, which includes an information element associated with a structured data location in a structured data storage unit, identifying a predicate referencing the structured data location, including the predicate in a predicates registry by compiling the predicate into an intermediate representation, creating an asynchronous message bus channel corresponding to the predicate, detecting a data operation for the structured data storage unit, wherein the information element is associated with the data operation, evaluating the intermediate representation, determining a predicate domain change type corresponding to the data operation, generating a change notification including an indication of the change type, and publishing the change notification to the asynchronous message bus channel such that a presentation via the client device is updated in response to the change notification.

First claim

What is claimed is:

1. A method of universal automatic data update detection and publication, the method comprising:
receiving, at a server, from a client device, a request for requested information, wherein the requested information includes an information element associated with a structured data location in a structured data storage unit;
transmitting a response to the client device, the response including the requested information for presentation via the client device;
after transmitting the response to the client device:
identifying a first predicate referencing the structured data location, wherein the first predicate is associated with a first action;
including the first predicate in a predicates registry, wherein including the first predicate in the predicates registry comprises unifying the first predicate and at least a second predicate in the predicates registry into an intermediate representation, wherein the intermediate representation comprises the first predicate associated with the first action and a second action associated with the second predicate;
creating an asynchronous message bus channel corresponding to the first predicate and subscribing the client device to the asynchronous message bus channel after including the predicate in the predicates registry;
detecting a data operation configured to modify the information element;
evaluating the intermediate representation in response to detecting the data operation, wherein evaluating the intermediate representation comprises determining whether the first predicate of the intermediate representation matches the data operation based on a value of the information element preceding the data operation and the value of the information element subsequent to the data operation; and
upon a determination that the first predicate of the intermediate representation matches the data operation:
determining a change type corresponding to modification of the information element by the data operation;
generating a change notification including an indication of the change type; and
publishing the change notification to the asynchronous message bus channel, such that the presentation via the client device is updated in response to the change notification.

2. The method of claim 1 , wherein the first predicate includes:
a path term indicating the structured data location in the structured data storage unit;
an operator term; and
a value term.

3. The method of claim 1 , wherein including the first predicate in the predicates registry, detecting the data operation, evaluating the intermediate representation, determining the change type, and generating the change notification are performed by a record watcher unit.

4. The method of claim 1 , wherein creating the asynchronous message bus channel and publishing the change notification are performed by an asynchronous message bus unit.

5. The method of claim 1 , wherein the first action comprises publishing the change notification to the asynchronous message bus channel.

6. The method of claim 1 , wherein detecting the data operation comprises intercepting a request to perform the data operation prior to performing the data operation.

7. The method of claim 1 , wherein the data operation comprises an insert operation, an update operation, or a delete operation.

8. The method of claim 1 , wherein evaluating the intermediate representation comprises traversing a structure of the intermediate representation.

9. The method of claim 1 , wherein determining the change type comprises:
identifying the change type as exit in response to a determination that the first predicate of the intermediate representation matches the value of the information element preceding the data operation and does not match the value of the information element subsequent to the data operation;
identifying the change type as enter in response to a determination that the first predicate does not match the value of the information element preceding the data operation and matches the value of the information element subsequent to the data operation; and
identifying the change type as change, in response to a determination that the first predicate matches the value of the information element preceding the data operation and matches the value of the information element subsequent to the data operation.

10. The method of claim 1 , wherein evaluating the intermediate representation comprises determining that the first predicate of the intermediate representation matches a value of the information element before the modification of the information element by the data operation and does not match the value of the information element after the modification of the information element by the data operation, and wherein the change type is determined as exit.

11. The method of claim 1 , wherein evaluating the intermediate representation comprises determining that the first predicate does not match a value of the information element before the modification of the information element by the data operation and matches the value of the information element after the modification of the information by the data operation, and wherein the change type is determined as enter.

12. A non-transitory computer-readable storage medium, comprising executable instructions that, when executed by a processor, facilitate performance of operations, comprising:
receiving, at a server, from a client device, a request for requested information, wherein the requested information includes an information element associated with a structured data location in a structured data storage unit;
transmitting a response to the client device, the response including the requested information for presentation via the client device;
after transmitting the response to the client device:
including, in a predicates registry, a first predicate referencing the structured data location, wherein including the first predicate in the predicates registry comprises unifying the first predicate and at least a second predicate in the predicates registry into an intermediate representation, wherein the first predicate is associated with a first action, the second predicate is associated with a second action, and the intermediate representation associates the first predicate with the first action and the second action;
subscribing the client device to an asynchronous message bus channel after including the first predicate in the predicates registry;
detecting a data operation for the structured data storage unit, wherein the information element is associated with the data operation;
evaluating the intermediate representation in response to detecting the data operation, wherein evaluating the intermediate representation comprises determining whether the first predicate of the intermediate representation matches the data operation based on a value of the information element preceding the data operation and the value of the information element subsequent to the data operation; and
upon a determination that the first predicate of the intermediate representation matches the data operation:
publishing a change notification to the asynchronous message bus channel, such that the presentation via the client device is updated in response to the change notification.

13. The non-transitory computer-readable storage medium of claim 12 , wherein:
the first predicate comprises:
a path term indicating the structured data location in the structured data storage unit;
an operator term; and
a value term.

14. The non-transitory computer-readable storage medium of claim 13 , wherein the operations comprise creating the asynchr

Assignees

• Servicenow Inc

Inventors

• Hastie Matthew Duncan
• Lee Jennifer
• Bahry Brent
• Laethem Jared

Classifications

• G06F9/542 Primary

  Event management; Broadcasting; Multicasting; Notifications · CPC title

• G06F16/00

  Information retrieval; Database structures therefor; File system structures therefor · CPC title

• G06F16/2358

  Change logging, detection, and notification (replication G06F16/27) · CPC title

• G06F16/273 Primary

  Asynchronous replication or reconciliation · CPC title