SYSTEMS AND METHODS FOR PROVIDING SERVICES IN A STATELESS APPLICATION FRAMEWORK

• US 20190332389A1
• Filed: 04/27/2018
• Published: 10/31/2019
• Est. Priority Date: 04/27/2018
• Status: Active Grant

• Current Assignee: PayPal, Inc. (PayPal Holdings, Inc.)
• Original Assignee: PayPal, Inc. (PayPal Holdings, Inc.)
• Inventors: Nadimpalli, Venkata Ramana Varma, Shvid, Alexander Y., Pobbathi, Vahini
• Granted Patent: US 10,732,990 B2
• Time in Patent Office: Days
• CPC Class Codes: G06F 9/445 Program loading or initiating bootstrapping G06F9/4401; security arrangements for program loading or initiating G06F21/57
• CPC Class Codes: G06F 9/4843 by program, e.g. task dispatcher, supervisor, operating system
• CPC Class Codes: G06F 9/5027 the resource being a machine, e.g. CPUs, Servers, Terminals
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications
• CPC Class Codes: G06F 9/547 Remote procedure calls [RPC]; Web services

Abstract

Methods and systems for providing a stateless application framework are presented. The stateless application framework is utilized by different applications for implementing different workflows. Each workflow may be associated with one or more state machine configurations representing the different states within the workflow. Upon receiving an indication of an event from an application, a stateless application module transmits a job request to a data processing engine based on a current state of the event. When a response is received from the data processing engine, the state application module determines whether the state of the event has been updated since transmitting the job request. If it is determined that the state has been updated, the stateless application module is configured to transmit another job request to the data processing engine based on the updated state of the event.

Claims

1. A method comprising:

instantiating, by a computer system, a first instance of a stateless application;

accessing, by the first instance of the stateless application, a context database to retrieve a record associated with a user account, wherein the record comprises first context data associated with a context of the user account within a state machine configuration and a first version number associated with a version of the record;

transmitting, by the first instance of the stateless application to a data processing engine, a first job request comprising a job descriptor, the first context data, and the first version number;

in response to receiving, from the data processing engine, a message comprising the first version number, instantiating, by the computer system, a second instance of the stateless application;

accessing, by the second instance of the stateless application, the context database to determine whether the record has been updated since the transmitting of the first job request based on the first version number;

in response to determining that the context record has been updated since the transmitting of the first job request, retrieving, by the second instance of the stateless application, second context data from the record; and

transmitting, by the second instance of the stateless application to the data processing engine, a second job request comprising the job descriptor and the second context data.

2. The method of claim 1, further comprising terminating the first instance of the stateless application after transmitting the first job request.

3. The method of claim 1, further comprising:

in response to receiving a second message from the data processing engine, instantiating a third instance of the stateless application;

accessing, by the third instance of the stateless application, the context database to update the context of the user account by inserting third context data into the record associated with the user account; and

changing, by the third instance of the stateless application, the version of the record by replacing the first version number with a second version number.

4. The method of claim 3, further comprising:

transmitting, by the third instance of the stateless application, a third job request to a second data processing engine, wherein the third job request comprises a second job descriptor, the third context data, and the second version number.

5. The method of claim 1, further comprising receiving an indication of an event associated with the user account, wherein the instantiating of the first instance of the stateless application is responsive to receiving the indication of the event.

6. The method of claim 5, wherein the first job request is associated with a process within a workflow, and wherein the event is an initiation of the workflow.

7. The method of claim 6, wherein the indication comprises the workflow.

8. The method of claim 5, wherein the indication comprises an account identifier associated with the user account and an event identifier associated with the event, wherein the method further comprises:

selecting, from a plurality of state machine configurations, the state machine configuration corresponding to the event; and

generating an identifier based on the user identifier, the event identifier, and a configuration identifier associated with the state machine configuration.

9. The method of claim 8, wherein the first job request comprises the identifier.

10. The method of claim 1, wherein the context database is external to the stateless application.

11. A system comprising:

a non-transitory memory; and

one or more hardware processors coupled with the non-transitory memory and configured to read instructions from the non-transitory memory to cause the system to perform operations comprising;

accessing a context database, to retrieve a record associated with a user account, wherein the record comprises first state data indicating a first state among a plurality of states within a state machine configuration and a first version number associated with a version of the record;

transmitting, to a data processing engine, a first job request comprising a job descriptor, the first state data, and the first version number;

in response to receiving, from the data processing engine, a first response comprising the first version number, accessing the context database to determine whether the record has been updated since the transmitting of the first job request based on the first version number;

in response to determining that the record has been updated since the transmitting of the first job request, retrieving second state data from the record, wherein the second state data indicates a second state within the state machine configuration; and

transmitting, to the data processing engine, a second job request comprising the job descriptor and the second context data.

12. The system of claim 11, wherein the first response received from the data processing engine indicates a completion of a job associated with the job descriptor.

13. The system of claim 11, wherein the operations further comprise:

in response to receiving a second response from the data processing engine, accessing the context database to update the state of the user account by inserting third state data to the record associated with the user account, wherein the third state data indicates a third state within the state machine configuration; and

changing the version of the record by replacing the first version number with a second version number in the record.

14. The system of claim 13, wherein the operations further comprise:

transmitting a third job request to a second data processing engine, wherein the third job request comprises a second job descriptor, the third context data, and the second version number.

15. The system of claim 11, wherein the operations further comprise receiving an indication of an event associated with the user account, wherein the accessing of the context database and the transmitting of the first job request are responsive to receiving the event.

16. The system of claim 15, wherein the first job request is associated with a process within a workflow, and wherein the event is an initiation of the workflow.

17. The system of claim 11, wherein the operations further comprise:

in response to receiving a third message from a second data processing engine, accessing the context database to update the state of the user account by inserting fourth context data to record associated with the user account, wherein the fourth context data indicates a fourth state within the state machine configuration; and

changing the version of the record based on a third version number.

18. The system of claim 11, wherein determining that the record has been updated since the transmitting of the job request comprises:

retrieving the record from the context database, wherein the record comprises a current version number; and

comparing the first version number against the current version number.

19. A non-transitory machine readable medium having stored thereon machine-readable instructions executable to cause a machine to perform operations comprising:

accessing a context database, to retrieve a record associated with a user account, wherein the record comprises first state data indicating a first state among a plurality of states within a state machine configuration and a first version number associated with a version of the record;

transmitting, to a data processing engine, a first job request comprising a job descriptor, the first state data, and the first version number;

in response to receiving, from the data processing engine, a first response comprising the first version number, accessing the context database to determine whether the record has been updated since the transmitting of the first job request based on the first version number;

in response to determining that the record has been updated since the transmitting of the first job request, retrieving second state data from the record, wherein the second state data indicates a second state within the state machine configuration; and

transmitting, to the data processing engine, a second job request comprising the job descriptor and the second context data.

20. The non-transitory machine readable medium of claim 19, wherein determining that the record has been updated comprises:

retrieving the record from the context database, wherein the record comprises a second version number; and

determining that the second version number does not correspond to the first version number, wherein the second job request further comprises the second version number.