Scheduling XPages Code – Part Five

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117

/**
 * Generic GET request method. Don't panic, take a deep breath, and follow me down the rabbit hole to Wonderland!
 */
public static void doGet() {
	try {
		/*
		 * One method call to Utils.initialiseAndProcessResponseAsJson() does all the boilerplating for extracting the request, response and JsonJavaObject
		 * and properly terminating the response. JsonJavaObject is basically the same as a Java Map. All gotchas are handled for you!
		 *
		 * The bit that could be new to most is that Utils.initialiseAndProcessResponseAsJson() takes an anonymous inner class as its method. This is just
		 * a way to pass in a process() method that can interact with the request and response set up by Utils.initialiseAndProcessResponseAsJson()
		 *
		 * With Java 8 it becomes more readable with lambdas:
		 *
		 * GenericHttpRequestUtils.initialiseAndProcessResponseAsJson((request, response, jsonObj) -> {
		 * 	   // do stuff here
		 * });
		 */
		GenericHttpRequestUtils.initialiseAndProcessResponseAsJson(new IXspHttpServletJsonResponseCallback() {

			/* (non-Javadoc)
			 * @see com.paulwithers.IXspHttpServletResponseCallback#process(javax.servlet.http.HttpServletRequest, com.ibm.xsp.webapp.XspHttpServletResponse)
			 */
			public void process(HttpServletRequest request, XspHttpServletResponse response, JsonJavaObject jsonObj)
					throws IOException {

				// A. Has the user requested that the process runs asynchronously?
				boolean async = false;
				if (null != request.getParameter("doAsync")) {
					async = true;
					response.setStatus(HttpServletResponse.SC_ACCEPTED); // Tell the user it's queued, not processed
				}

				// B. Has the user included the "process" that should be run
				if (null == request.getParameter("process")) {
					// Invalid request!!
					response.sendError(HttpServletResponse.SC_BAD_REQUEST,
							"This endpoint expects a process type to be passed");
				} else {

					// We're good to go
					try {
						// pre-Java 8 we need an if statement. switch statements using strings are Java 7+, so FP10+
						if ("loadData".equals(request.getParameter("process"))) {
							// 1. LOAD ADDITIONAL USERS WITHOUT CLEARING THIS DATABASE DOWN
							// Was a number of users passed? We'll default to 200
							int userCount = 200;
							if (null != request.getParameter("userCount")) {
								userCount = Integer.parseInt(request.getParameter("userCount"));
							}
							if (async) {
								// Async request, run in background and confirm in JSON
								Xots.getService().submit(
										new DataInitializerBackground(InitializerType.LOAD, userCount));
								jsonObj.put("message", userCount + " users queued for asynchronous generation");
							} else {
								// In real-time request, run and confirm in JSON
								DataInitializer d = new DataInitializer();
								d.initUsers(userCount);
								d.initStates();
								d.initAllTypes();
								d.run();
								jsonObj.put("message", userCount + " users created");
							}
						} else if ("reloadData".equals(request.getParameter("process"))) {
							// 2. DELETE AND RELOAD ADDITIONAL USERS
							// Same as above, just including deletion. Was a number of users passed? We'll default to 200
							int userCount = 200;
							if (null != request.getParameter("userCount")) {
								userCount = Integer.parseInt(request.getParameter("userCount"));
							}
							if (async) {
								// Async request, run in background and confirm in JSON
								Xots.getService().submit(
										new DataInitializerBackground(InitializerType.RELOAD, userCount));
								jsonObj.put("message", "data clearance and " + userCount
										+ " users queued for asynchronous generation");
							} else {
								// In real-time request, run and confirm in JSON
								DataInitializer d = new DataInitializer();
								d.initDeleteDocuments();
								d.initUsers(userCount);
								d.initStates();
								d.initAllTypes();
								d.run();
								jsonObj.put("message", "data cleared and " + userCount + " users created");
							}
						} else if ("deleteData".equals(request.getParameter("process"))) {
							// 3. JUST CLEAR DOWN THE DATABASE. IF YOU WANT TO CLEAR DOWN THE ARCHIVE, GUESS WHAT - CALL THE REST SERVICE THERE!
							if (async) {
								// Async request, run in background and confirm in JSON
								Xots.getService().submit(new DataInitializerBackground(InitializerType.DELETE));
								jsonObj.put("message", "data clearance queued for asynchronous generation");
							} else {
								// In real-time request, run and confirm in JSON
								DataInitializer d = new DataInitializer();
								d.initDeleteDocuments();
								d.run();
								jsonObj.put("message", "data cleared");
							}
						} else {
							response.sendError(HttpServletResponse.SC_BAD_REQUEST,
									"Invalid process parameter passed");
						}

					} catch (Throwable t) {
						// Whoops! We've hit an unexpected error. Return an error 500
						t.printStackTrace();
						response.sendError(HttpServletResponse.SC_INTERNAL_SERVER_ERROR, t.getMessage());
					}
				}
			}
		});
	} catch (Throwable t) {
		t.printStackTrace();
	}
}