FWD » Core Development » Base Language

package com.goldencode.testcases;

import com.goldencode.p2j.util.*;

import com.goldencode.p2j.oo.web.WebHandler;

import com.goldencode.p2j.persist.*;

import com.goldencode.testcases.dmo._temp.*;

import com.goldencode.p2j.oo.web.WebResponseWriter;

import com.goldencode.p2j.oo.net.http.StatusCodeEnum;

import com.goldencode.p2j.oo.json.objectmodel.JsonObject;

import com.goldencode.p2j.oo.json.objectmodel.JsonArray;

import com.goldencode.p2j.oo.json.objectmodel.JsonConstruct;

import com.goldencode.p2j.oo.core.Memptr;

import com.goldencode.p2j.oo.json.objectmodel.ObjectModelParser;

import com.goldencode.testcases.dmo.fwd.*;

import com.goldencode.p2j.persist.lock.*;

import static com.goldencode.p2j.util.BlockManager.*;

import static com.goldencode.p2j.util.InternalEntry.Type;

import static com.goldencode.p2j.util.CompareOps.*;

import static com.goldencode.p2j.util.logical.*;

import static com.goldencode.p2j.util.TextOps.*;

import static com.goldencode.p2j.persist.TempTableBuilder.*;

import static com.goldencode.p2j.util.ErrorManager.*;

/**

 * Business logic (converted to Java from the 4GL source code

 * in FwdHandler.cls).

 */

@LegacyService(name = "oepas1.goldencode.web", type = "WEBHANDLER", paths = 

{

   @LegacyWebPath(path = "/fwdHandler/{id}/{value}", order = 1),

   @LegacyWebPath(path = "/fwdHandler/{id}", order = 2),

   @LegacyWebPath(path = "/fwdHandler", order = 3)

})

public class FwdHandler

extends WebHandler

{

   private Ttorderline_1_1.Buf ttorderline = TemporaryBuffer.define(FwdHandler.class, Ttorderline_1_1.Buf.class, "ttorderline", "ttOrderLine", false, false);

   private Ttorder_2_1.Buf ttorder = TemporaryBuffer.define(FwdHandler.class, Ttorder_2_1.Buf.class, "ttorder", "ttOrder", false, false);

   private Ttorderitem_1_1.Buf ttorderitem = TemporaryBuffer.define(FwdHandler.class, Ttorderitem_1_1.Buf.class, "ttorderitem", "ttOrderItem", false, false);

   private Ttordercustomer_1_1.Buf ttordercustomer = TemporaryBuffer.define(FwdHandler.class, Ttordercustomer_1_1.Buf.class, "ttordercustomer", "ttOrderCustomer", false, false);

   private Ttcustomer_1_1.Buf ttcustomer = TemporaryBuffer.define(FwdHandler.class, Ttcustomer_1_1.Buf.class, "ttcustomer", "ttCustomer", false, false);

   Customer.Buf customer = RecordBuffer.define(FwdHandler.class, Customer.Buf.class, "fwd", "customer", "customer");

   Order_.Buf order_ = RecordBuffer.define(FwdHandler.class, Order_.Buf.class, "fwd", "order_", "order");

   private final DataSet dsOrder = DataSetManager.define("dsOrder", false, false)

         .forBuffers(ttordercustomer, ttorderitem, ttorder, ttorderline)

         .addDataRelation("customerOrder", false, false, false, false, false, ttordercustomer, ttorder, new DataSet.FieldPair("customerNum", "customerNum"))

         .addDataRelation("Relation2", false, false, false, false, false, ttorderline, ttorderitem, new DataSet.FieldPair("itemNum", "itemNum"))

         .addDataRelation("Relation3", false, true, false, false, false, ttorder, ttorderline, new DataSet.FieldPair("orderNum", "orderNum"))

         .generate();

   public void __FwdHandler_execute__()

   {

      externalProcedure(FwdHandler.class, FwdHandler.this, new Block((Body) () -> 

      {

         RecordBuffer.openScope(ttcustomer, ttordercustomer, ttorderitem, ttorder, ttorderline);

         onBlockLevel(Condition.ERROR, Action.THROW);

         {

         }

      }));

   }

   @LegacySignature(type = Type.CONSTRUCTOR)

   public void __FwdHandler_constructor__()

   {

      internalProcedure(FwdHandler.class, this, "__FwdHandler_constructor__", new Block((Body) () -> 

      {

         __web_WebHandler_constructor__();

      }));

   }

   @LegacySignature(type = Type.METHOD, name = "HandleNotAllowedMethod", returns = "INTEGER", parameters = 

   {

      @LegacyParameter(name = "poRequest", type = "OBJECT", qualified = "openedge.web.iwebrequest", mode = "INPUT")

   })

   @Override

   protected integer handleNotAllowedMethod(final object<? extends com.goldencode.p2j.oo.web.IwebRequest> _poRequest)

   {

      object<? extends com.goldencode.p2j.oo.web.IwebRequest> poRequest = TypeFactory.initInput(_poRequest);

      return function(FwdHandler.class, this, "HandleNotAllowedMethod", integer.class, new Block((Body) () -> 

      {

         undoThrowTopLevel(ObjectOps.newInstance(com.goldencode.p2j.oo.lang.AppError.class, "I", "METHOD NOT IMPLEMENTED"));

      }));

   }

   @LegacySignature(type = Type.METHOD, name = "HandleNotImplemented", returns = "INTEGER", parameters = 

   {

      @LegacyParameter(name = "poRequest", type = "OBJECT", qualified = "openedge.web.iwebrequest", mode = "INPUT")

   })

   @Override

   protected integer handleNotImplemented(final object<? extends com.goldencode.p2j.oo.web.IwebRequest> _poRequest)

   {

      object<? extends com.goldencode.p2j.oo.web.IwebRequest> poRequest = TypeFactory.initInput(_poRequest);

      return function(FwdHandler.class, this, "HandleNotImplemented", integer.class, new Block((Body) () -> 

      {

         undoThrowTopLevel(ObjectOps.newInstance(com.goldencode.p2j.oo.lang.AppError.class, "I", "METHOD NOT IMPLEMENTED"));

      }));

   }

   @LegacySignature(type = Type.METHOD, name = "HandleGet", returns = "INTEGER", parameters = 

   {

      @LegacyParameter(name = "poRequest", type = "OBJECT", qualified = "openedge.web.iwebrequest", mode = "INPUT")

   })

   @Override

   /*------------------------------------------------------------------------------

               Purpose: Default handler for the HTTP GET method. The request being 

                        serviced and an optional status code is returned. A zero or 

                        null value means this method will deal with all errors.                                                               

               Notes:                                                                        

       ------------------------------------------------------------------------------*/   

   protected integer handleGet(final object<? extends com.goldencode.p2j.oo.web.IwebRequest> _poRequest)

   {

      object<? extends com.goldencode.p2j.oo.web.IwebRequest> poRequest = TypeFactory.initInput(_poRequest);

      object<? extends com.goldencode.p2j.oo.net.http.IhttpResponse> oResponse = TypeFactory.object(com.goldencode.p2j.oo.net.http.IhttpResponse.class);

      object<? extends WebResponseWriter> oWriter = TypeFactory.object(WebResponseWriter.class);

      object<? extends com.goldencode.p2j.oo.core.LegacyString> oBody = TypeFactory.object(com.goldencode.p2j.oo.core.LegacyString.class);

      integer pathId = TypeFactory.integer();

      character pathVal = TypeFactory.character();

      longchar jsonData = TypeFactory.longchar();

      /* The WebResponseWriter ensures that the status line and

                 all headers are writted out before the message body/entity. */

      return function(FwdHandler.class, this, "HandleGet", integer.class, new Block((Init) () -> 

      {

         ObjectOps.register(oBody, oWriter, oResponse);

      }, 

      (Body) () -> 

      {

         /* The WebResponse body is a wrapper around an entire HTTP response message.

                    It contains a status code and reason; headers; cookies and a message body.

                    API-level doc for this and related classes can be found at

                    https://documentation.progress.com/output/oehttpclient/      */

         oResponse.assign(ObjectOps.newInstance(com.goldencode.p2j.oo.web.WebResponse.class));

         silent(() -> pathId.assign(new integer(poRequest.ref().getPathParameter(new character("id")))));

         silent(() -> pathVal.assign(poRequest.ref().getPathParameter(new character("value"))));

         oResponse.ref().setStatusCode(new integer(_or(isEqual(pathVal, ""), () -> isEqual(pathVal, "orders")) ? StatusCodeEnum.ok : StatusCodeEnum.badRequest));

         oResponse.ref().setContentType(new character("text/plain"));

         /* This body object can be a string or something else (JsonObject for instance) */

         if (_isGreaterThan(pathId, 0))

         {

            AdaptiveQuery query0 = new AdaptiveQuery();

            forEach("loopLabel0", new Block((Init) () -> 

            {

               RecordBuffer.openScope(customer);

               query0.initialize(customer, "customer.customernum = ?", null, "customer.customernum asc", new Object[]

               {

                  pathId

               }, LockType.NONE);

            }, 

            (Body) () -> 

            {

               query0.next();

               {

                  ttcustomer.create();

                  new BufferCopy(customer, ttcustomer).run(true);

                  ttordercustomer.create();

                  new BufferCopy(customer, ttordercustomer).run(true);

               }

            }));

            if ((asTempTable(ttcustomer).hasRecords()).booleanValue())

            {

               if (_isEqual(pathVal, "orders"))

               {

                  AdaptiveQuery query1 = new AdaptiveQuery();

                  forEach("loopLabel1", new Block((Init) () -> 

                  {

                     RecordBuffer.openScope(order_);

                     query1.initialize(order_, "order_.customernum = ?", null, "order_.customernum asc", new Object[]

                     {

                        pathId

                     }, LockType.NONE);

                  }, 

                  (Body) () -> 

                  {

                     query1.next();

                     {

                        ttorder.create();

                        new BufferCopy(order_, ttorder).run(true);

                     }

                  }));

                  dsOrder.writeJson(new TargetData("longchar", jsonData), new logical(true), new character("utf-8"));

                  oBody.assign(ObjectOps.newInstance(com.goldencode.p2j.oo.core.LegacyString.class, "I", jsonData));

               }

               else

               {

                  tempTable(ttcustomer).unwrapJsonData().writeJson(new TargetData("longchar", jsonData), new logical(true), new character("utf-8"));

                  oBody.assign(ObjectOps.newInstance(com.goldencode.p2j.oo.core.LegacyString.class, "I", jsonData));

               }

               oResponse.ref().setContentType(new character("application/json"));

            }

            else

            {

               oBody.assign(ObjectOps.newInstance(com.goldencode.p2j.oo.core.LegacyString.class, "I", substitute("Customer not found &1", pathId)));

               oResponse.ref().setStatusCode(new integer(StatusCodeEnum.notFound));

            }

         }

         else

         {

            oBody.assign(ObjectOps.newInstance(com.goldencode.p2j.oo.core.LegacyString.class, "I", getWebRequestInfo(poRequest).ref().getJsonText()));

            oResponse.ref().setContentType(new character("application/json"));

         }

         oResponse.ref().setEntity(new object(oBody));

         /* HTTP messages require a content type */

         oResponse.ref().setContentLength(new integer(oBody.ref().getSize()));

         oWriter.assign(ObjectOps.newInstance(WebResponseWriter.class, "I", oResponse));

         oWriter.ref().open();

         /* Finish writing the response message */

         oWriter.ref().close();

         /* A response of 0 means that this handler will build the entire response;

                    a non-zero value is mapped to a static handler in the webapp's /static/error folder.

                    The mappings are maintained in the webapps's WEB-INF/web.xml 

                    A predefined set of HTTP status codes is provided in the OpenEdge.Net.HTTP.StatusCodeEnum 

                    enumeration */

         returnNormal(0);

      }, 

      (Fini) () -> 

      {

         tempTable(ttcustomer).unwrapEmptyTempTable().deleteAll();

         tempTable(ttordercustomer).unwrapEmptyTempTable().deleteAll();

         tempTable(ttorder).unwrapEmptyTempTable().deleteAll();

      }));

   }

   @LegacySignature(type = Type.METHOD, name = "HandlePut", returns = "INTEGER", parameters = 

   {

      @LegacyParameter(name = "poRequest", type = "OBJECT", qualified = "openedge.web.iwebrequest", mode = "INPUT")

   })

   @Override

   /*------------------------------------------------------------------------------

             Purpose:                                                                

             Notes:                                                                        

     ------------------------------------------------------------------------------*/   

   protected integer handlePut(final object<? extends com.goldencode.p2j.oo.web.IwebRequest> _poRequest)

   {

      object<? extends com.goldencode.p2j.oo.web.IwebRequest> poRequest = TypeFactory.initInput(_poRequest);

      object<? extends com.goldencode.p2j.oo.net.http.IhttpResponse> oResponse = TypeFactory.object(com.goldencode.p2j.oo.net.http.IhttpResponse.class);

      object<? extends WebResponseWriter> oWriter = TypeFactory.object(WebResponseWriter.class);

      object<? extends com.goldencode.p2j.oo.core.LegacyString> oBody = TypeFactory.object(com.goldencode.p2j.oo.core.LegacyString.class);

      integer pathId = TypeFactory.integer();

      character pathVal = TypeFactory.character();

      longchar jsonData = TypeFactory.longchar();

      /* The WebResponseWriter ensures that the status line and

                 all headers are writted out before the message body/entity. */

      return function(FwdHandler.class, this, "HandlePut", integer.class, new Block((Init) () -> 

      {

         ObjectOps.register(oBody, oWriter, oResponse);

      }, 

      (Body) () -> 

      {

         /* The WebResponse body is a wrapper around an entire HTTP response message.

                    It contains a status code and reason; headers; cookies and a message body.

                    API-level doc for this and related classes can be found at

                    https://documentation.progress.com/output/oehttpclient/      */

         oResponse.assign(ObjectOps.newInstance(com.goldencode.p2j.oo.web.WebResponse.class));

         silent(() -> pathId.assign(new integer(poRequest.ref().getPathParameter(new character("id")))));

         silent(() -> pathVal.assign(poRequest.ref().getPathParameter(new character("value"))));

         oResponse.ref().setStatusCode(new integer(_isNotEqual(pathId, 0) ? StatusCodeEnum.ok : StatusCodeEnum.badRequest));

         oResponse.ref().setContentType(new character("text/plain"));

         /* This body object can be a string or something else (JsonObject for instance) */

         if (_isGreaterThan(pathId, 0))

         {

            AdaptiveQuery query2 = new AdaptiveQuery();

            forEach("loopLabel2", new Block((Init) () -> 

            {

               RecordBuffer.openScope(customer);

               query2.initialize(customer, "customer.customernum = ?", null, "customer.customernum asc", new Object[]

               {

                  pathId

               }, LockType.NONE);

            }, 

            (Body) () -> 

            {

               //  if id exists we will update customer

               query2.next();

               {

                  ttcustomer.create();

                  new BufferCopy(customer, ttcustomer).run(true);

               }

            }));

            if ((asTempTable(ttcustomer).hasRecords()).booleanValue())

            {

               if (_isNotEqual(pathVal, ""))

               {

                  ttcustomer.setCustomername(substitute("&1-id=&2_val=&3", ttcustomer.getCustomername(), pathId, pathVal));

               }

               else

               {

                  ttcustomer.setCustomername(substitute("&1_id=&2", ttcustomer.getCustomername(), pathId));

               }

               tempTable(ttcustomer).unwrapJsonData().writeJson(new TargetData("longchar", jsonData), new logical(true), new character("utf-8"));

               oBody.assign(ObjectOps.newInstance(com.goldencode.p2j.oo.core.LegacyString.class, "I", jsonData));

            }

            else

            {

               oBody.assign(ObjectOps.newInstance(com.goldencode.p2j.oo.core.LegacyString.class, "I", substitute("Customer &1 not found for update", pathId)));

               oResponse.ref().setStatusCode(new integer(StatusCodeEnum.notFound));

            }

            oResponse.ref().setContentType(new character("application/json"));

         }

         else

         {

            if ((ObjectOps.typeOf(poRequest.ref().getEntity(), JsonConstruct.class)).booleanValue())

            {

               oBody.assign(ObjectOps.newInstance(com.goldencode.p2j.oo.core.LegacyString.class, "I", pipeWebRequest(poRequest).ref().getJsonText()));

            }

            else

            {

               oBody.assign(ObjectOps.newInstance(com.goldencode.p2j.oo.core.LegacyString.class, "I", getWebRequestInfo(poRequest).ref().getJsonText()));

            }

            oResponse.ref().setContentType(new character("application/json"));

         }

         oResponse.ref().setEntity(new object(oBody));

         /* HTTP messages require a content type */

         oResponse.ref().setContentLength(new integer(oBody.ref().getSize()));

         oWriter.assign(ObjectOps.newInstance(WebResponseWriter.class, "I", oResponse));

         oWriter.ref().open();

         /* Finish writing the response message */

         oWriter.ref().close();

         /* A response of 0 means that this handler will build the entire response;

                    a non-zero value is mapped to a static handler in the webapp's /static/error folder.

                    The mappings are maintained in the webapps's WEB-INF/web.xml 

                    A predefined set of HTTP status codes is provided in the OpenEdge.Net.HTTP.StatusCodeEnum 

                    enumeration */

         returnNormal(0);

      }, 

      (Fini) () -> 

      {

         tempTable(ttcustomer).unwrapEmptyTempTable().deleteAll();

      }));

   }

   @LegacySignature(type = Type.METHOD, name = "HandlePost", returns = "INTEGER", parameters = 

   {

      @LegacyParameter(name = "poRequest", type = "OBJECT", qualified = "openedge.web.iwebrequest", mode = "INPUT")

   })

   @Override

   /*------------------------------------------------------------------------------

              Purpose:                                                                

              Notes:                                                                        

      ------------------------------------------------------------------------------*/   

   protected integer handlePost(final object<? extends com.goldencode.p2j.oo.web.IwebRequest> _poRequest)

   {

      object<? extends com.goldencode.p2j.oo.web.IwebRequest> poRequest = TypeFactory.initInput(_poRequest);

      object<? extends com.goldencode.p2j.oo.net.http.IhttpResponse> oResponse = TypeFactory.object(com.goldencode.p2j.oo.net.http.IhttpResponse.class);

      object<? extends WebResponseWriter> oWriter = TypeFactory.object(WebResponseWriter.class);

      object<? extends com.goldencode.p2j.oo.core.LegacyString> oBody = TypeFactory.object(com.goldencode.p2j.oo.core.LegacyString.class);

      integer pathId = TypeFactory.integer();

      character pathVal = TypeFactory.character();

      longchar jsonData = TypeFactory.longchar();

      /* The WebResponseWriter ensures that the status line and

                 all headers are writted out before the message body/entity. */

      return function(FwdHandler.class, this, "HandlePost", integer.class, new Block((Init) () -> 

      {

         ObjectOps.register(oBody, oWriter, oResponse);

      }, 

      (Body) () -> 

      {

         /* The WebResponse body is a wrapper around an entire HTTP response message.

                    It contains a status code and reason; headers; cookies and a message body.

                    API-level doc for this and related classes can be found at

                    https://documentation.progress.com/output/oehttpclient/      */

         oResponse.assign(ObjectOps.newInstance(com.goldencode.p2j.oo.web.WebResponse.class));

         silent(() -> pathId.assign(new integer(poRequest.ref().getPathParameter(new character("id")))));

         silent(() -> pathVal.assign(poRequest.ref().getPathParameter(new character("value"))));

         oResponse.ref().setStatusCode(new integer(_notUnknown(pathId) ? StatusCodeEnum.ok : StatusCodeEnum.badRequest));

         oResponse.ref().setContentType(new character("text/plain"));

         /* This body object can be a string or something else (JsonObject for instance) */

         if (_isGreaterThan(pathId, 0))

         {

            AdaptiveQuery query3 = new AdaptiveQuery();

            forEach("loopLabel3", new Block((Init) () -> 

            {

               RecordBuffer.openScope(customer);

               query3.initialize(customer, "customer.customernum = ?", null, "customer.customernum asc", new Object[]

               {

                  pathId

               }, LockType.NONE);

            }, 

            (Body) () -> 

            {

               //  check if customer exist in databse

               query3.next();

               {

                  ttcustomer.create();

                  new BufferCopy(customer, ttcustomer).run(true);

               }

            }));

            if ((asTempTable(ttcustomer).hasRecords()).booleanValue())

            {

               oBody.assign(ObjectOps.newInstance(com.goldencode.p2j.oo.core.LegacyString.class, "I", substitute("Customer exist in database and we can not create with given id =  &1", pathId)));

               oResponse.ref().setStatusCode(new integer(StatusCodeEnum.forbidden));

               oResponse.ref().setContentType(new character("application/json"));

            }

            else

            {

               ttcustomer.create();

               ttcustomer.setCustomernum(pathId);

               ttcustomer.setCustomername(pathVal);

               tempTable(ttcustomer).unwrapJsonData().writeJson(new TargetData("longchar", jsonData), new logical(true), new character("utf-8"));

               oBody.assign(ObjectOps.newInstance(com.goldencode.p2j.oo.core.LegacyString.class, "I", jsonData));

               oResponse.ref().setContentType(new character("application/json"));

            }

         }

         else

         {

            oBody.assign(ObjectOps.newInstance(com.goldencode.p2j.oo.core.LegacyString.class, "I", getWebRequestInfo(poRequest).ref().getJsonText()));

            oResponse.ref().setContentType(new character("application/json"));

         }

         oResponse.ref().setEntity(new object(oBody));

         /* HTTP messages require a content type */

         oResponse.ref().setContentLength(new integer(oBody.ref().getSize()));

         oWriter.assign(ObjectOps.newInstance(WebResponseWriter.class, "I", oResponse));

         oWriter.ref().open();

         /* Finish writing the response message */

         oWriter.ref().close();

         /* A response of 0 means that this handler will build the entire response;

                    a non-zero value is mapped to a static handler in the webapp's /static/error folder.

                    The mappings are maintained in the webapps's WEB-INF/web.xml 

                    A predefined set of HTTP status codes is provided in the OpenEdge.Net.HTTP.StatusCodeEnum 

                    enumeration */

         returnNormal(0);

      }, 

      (Fini) () -> 

      {

         tempTable(ttcustomer).unwrapEmptyTempTable().deleteAll();

      }));

   }

   @LegacySignature(type = Type.METHOD, name = "HandleDelete", returns = "INTEGER", parameters = 

   {

      @LegacyParameter(name = "poRequest", type = "OBJECT", qualified = "openedge.web.iwebrequest", mode = "INPUT")

   })

   @Override

   /*------------------------------------------------------------------------------

             Purpose:                                                                

             Notes:                                                                        

     ------------------------------------------------------------------------------*/   

   protected integer handleDelete(final object<? extends com.goldencode.p2j.oo.web.IwebRequest> _poRequest)

   {

      object<? extends com.goldencode.p2j.oo.web.IwebRequest> poRequest = TypeFactory.initInput(_poRequest);

      object<? extends com.goldencode.p2j.oo.net.http.IhttpResponse> oResponse = TypeFactory.object(com.goldencode.p2j.oo.net.http.IhttpResponse.class);

      object<? extends WebResponseWriter> oWriter = TypeFactory.object(WebResponseWriter.class);

      object<? extends com.goldencode.p2j.oo.core.LegacyString> oBody = TypeFactory.object(com.goldencode.p2j.oo.core.LegacyString.class);

      integer pathId = TypeFactory.integer();

      character pathVal = TypeFactory.character();

      /* The WebResponseWriter ensures that the status line and

                 all headers are writted out before the message body/entity. */

      return function(FwdHandler.class, this, "HandleDelete", integer.class, new Block((Init) () -> 

      {

         ObjectOps.register(oBody, oWriter, oResponse);

      }, 

      (Body) () -> 

      {

         /* The WebResponse body is a wrapper around an entire HTTP response message.

                    It contains a status code and reason; headers; cookies and a message body.

                    API-level doc for this and related classes can be found at

                    https://documentation.progress.com/output/oehttpclient/      */

         oResponse.assign(ObjectOps.newInstance(com.goldencode.p2j.oo.web.WebResponse.class));

         silent(() -> pathId.assign(new integer(poRequest.ref().getPathParameter(new character("id")))));

         silent(() -> pathVal.assign(poRequest.ref().getPathParameter(new character("value"))));

         oResponse.ref().setStatusCode(new integer(_isEqual(pathVal, "") ? StatusCodeEnum.ok : StatusCodeEnum.badRequest));

         oResponse.ref().setContentType(new character("text/plain"));

         /* This body object can be a string or something else (JsonObject for instance) */

         if (_isGreaterThan(pathId, 0))

         {

            AdaptiveQuery query4 = new AdaptiveQuery();

            forEach("loopLabel4", new Block((Init) () -> 

            {

               RecordBuffer.openScope(customer);

               query4.initialize(customer, "customer.customernum = ?", null, "customer.customernum asc", new Object[]

               {

                  pathId

               }, LockType.NONE);

            }, 

            (Body) () -> 

            {

               //  update cust

               query4.next();

               {

                  ttcustomer.create();

                  new BufferCopy(customer, ttcustomer).run(true);

               }

            }));

            if ((asTempTable(ttcustomer).hasRecords()).booleanValue())

            {

               ttcustomer.deleteRecord();

               oBody.assign(ObjectOps.newInstance(com.goldencode.p2j.oo.core.LegacyString.class, "I", substitute("Customer with id &1 was deleted", pathId)));

               oResponse.ref().setContentType(new character("application/json"));

            }

            else

            {

               oBody.assign(ObjectOps.newInstance(com.goldencode.p2j.oo.core.LegacyString.class, "I", substitute("Customer not found &1", pathId)));

               oResponse.ref().setStatusCode(new integer(StatusCodeEnum.notFound));

            }

         }

         else

         {

            oBody.assign(ObjectOps.newInstance(com.goldencode.p2j.oo.core.LegacyString.class, "I", getWebRequestInfo(poRequest).ref().getJsonText()));

            oResponse.ref().setContentType(new character("application/json"));

         }

         oResponse.ref().setEntity(new object(oBody));

         /* HTTP messages require a content type */

         oResponse.ref().setContentLength(new integer(oBody.ref().getSize()));

         oWriter.assign(ObjectOps.newInstance(WebResponseWriter.class, "I", oResponse));

         oWriter.ref().open();

         /* Finish writing the response message */

         oWriter.ref().close();

         /* A response of 0 means that this handler will build the entire response;

                    a non-zero value is mapped to a static handler in the webapp's /static/error folder.

                    The mappings are maintained in the webapps's WEB-INF/web.xml 

                    A predefined set of HTTP status codes is provided in the OpenEdge.Net.HTTP.StatusCodeEnum 

                    enumeration */

         returnNormal(0);

      }, 

      (Fini) () -> 

      {

         tempTable(ttcustomer).unwrapEmptyTempTable().deleteAll();

      }));

   }

   @LegacySignature(type = Type.METHOD, name = "pipeWebRequest", returns = "OBJECT", qualified = "progress.json.objectmodel.jsonobject", parameters = 

   {

      @LegacyParameter(name = "poRequest", type = "OBJECT", qualified = "openedge.web.iwebrequest", mode = "INPUT")

   })

   protected object<? extends com.goldencode.p2j.oo.json.objectmodel.JsonObject> pipeWebRequest(final object<? extends com.goldencode.p2j.oo.web.IwebRequest> _poRequest)

   {

      object<? extends com.goldencode.p2j.oo.web.IwebRequest> poRequest = TypeFactory.initInput(_poRequest);

      object<? extends JsonObject> jsonRsp = TypeFactory.object(JsonObject.class);

      object<? extends ObjectModelParser> jsonParser = TypeFactory.object(ObjectModelParser.class);

      object<? extends com.goldencode.p2j.oo.lang.LegacyError> err_top = UndoableFactory.object(com.goldencode.p2j.oo.lang.LegacyError.class);

      return function(FwdHandler.class, this, "pipeWebRequest", object.class, new Block((Init) () -> 

      {

         ObjectOps.register(jsonParser, jsonRsp);

         catchError(com.goldencode.p2j.oo.lang.LegacyError.class, 

         err -> 

         {

            err_top.assign(err);

            jsonRsp.ref().add(new character("parseError"), err.ref().getMessage(new integer(1)));

         });

      }, 

      (Body) () -> 

      {

         jsonRsp.assign(ObjectOps.newInstance(JsonObject.class));

         jsonParser.assign(ObjectOps.newInstance(ObjectModelParser.class));

         addJson(jsonRsp, new character("original"), ObjectOps.cast(poRequest.ref().getEntity(), JsonConstruct.class));         

         //  TODO: not supported in FWD addJson(jsonRsp, 'parsed', jsonParser:Parse(web-context)).

         returnNormal(jsonRsp);

         silent(() -> 

         {

         });

      }, 

      (Fini) () -> 

      {

         silent(() -> ObjectOps.delete(jsonParser));

      }));

   }

   @LegacySignature(type = Type.METHOD, name = "addJson", parameters = 

   {

      @LegacyParameter(name = "jsonRsp", type = "OBJECT", qualified = "progress.json.objectmodel.jsonobject", mode = "INPUT"),

      @LegacyParameter(name = "propName", type = "CHARACTER", mode = "INPUT"),

      @LegacyParameter(name = "jsonObj", type = "OBJECT", qualified = "progress.json.objectmodel.jsonconstruct", mode = "INPUT")

   })

   protected void addJson(final object<? extends JsonObject> _jsonRsp, final character _propName, final object<? extends JsonConstruct> _jsonObj)

   {

      object<? extends JsonObject> jsonRsp = TypeFactory.initInput(_jsonRsp);

      character propName = TypeFactory.initInput(_propName);

      object<? extends JsonConstruct> jsonObj = TypeFactory.initInput(_jsonObj);

      internalProcedure(FwdHandler.class, this, "addJson", new Block((Body) () -> 

      {

         if ((ObjectOps.typeOf(jsonObj, JsonObject.class)).booleanValue())

         {

            jsonRsp.ref().add_1(propName, ObjectOps.cast(jsonObj, JsonObject.class));

         }

         else

         {

            jsonRsp.ref().add(propName, ObjectOps.cast(jsonObj, JsonArray.class));

         }

      }));

   }

   @LegacySignature(type = Type.METHOD, name = "getWebRequestInfo", returns = "OBJECT", qualified = "progress.json.objectmodel.jsonobject", parameters = 

   {

      @LegacyParameter(name = "poRequest", type = "OBJECT", qualified = "openedge.web.iwebrequest", mode = "INPUT")

   })

   protected object<? extends com.goldencode.p2j.oo.json.objectmodel.JsonObject> getWebRequestInfo(final object<? extends com.goldencode.p2j.oo.web.IwebRequest> _poRequest)

   {

      object<? extends com.goldencode.p2j.oo.web.IwebRequest> poRequest = TypeFactory.initInput(_poRequest);

      object<? extends JsonObject> jsonRsp = TypeFactory.object(JsonObject.class);

      object<? extends JsonObject> jsonObj = TypeFactory.object(JsonObject.class);

      character pathParams = TypeFactory.character();

      integer numItem = TypeFactory.integer();

      longchar contentVal = TypeFactory.longchar();

      character headerList = TypeFactory.character("Content-Type,Accept,Accept-Language,Accept-Encoding,Accept-Charset,Authorization,Cookie,From,Host,User-Agent");

      return function(FwdHandler.class, this, "getWebRequestInfo", object.class, new Block((Init) () -> 

      {

         ObjectOps.register(jsonObj, jsonRsp);

      }, 

      (Body) () -> 

      {

         jsonRsp.assign(ObjectOps.newInstance(JsonObject.class));

         jsonRsp.ref().add(new character("Method"), poRequest.ref().getMethod());

         jsonRsp.ref().add(new character("CharacterEncoding"), poRequest.ref().getCharacterEncoding());

         jsonRsp.ref().add(new character("ContentLength"), poRequest.ref().getContentLength());         

         // poRequest:ContentMD5 - proprety not implemented

         // md5Content = poRequest:ContentMD5.

         // jsonRsp:Add('ContentMD5', get-string(md5Content,1)).

         jsonRsp.ref().add(new character("ContentType"), poRequest.ref().getContentType());

         jsonRsp.ref().add(new character("DefaultCookieDomain"), poRequest.ref().getDefaultCookieDomain());

         jsonRsp.ref().add(new character("DefaultCookiePath"), poRequest.ref().getDefaultCookiePath());

         jsonRsp.ref().add(new character("LocalAddress"), poRequest.ref().getLocalAddress());

         jsonRsp.ref().add(new character("LocalPort"), poRequest.ref().getLocalPort());

         jsonRsp.ref().add(new character("PathInfo"), poRequest.ref().getPathInfo());

         jsonRsp.ref().add(new character("PathParameterNames"), poRequest.ref().getPathParameterNames());

         jsonRsp.ref().add(new character("RemoteAddress"), poRequest.ref().getRemoteAddress());

         jsonRsp.ref().add(new character("RemoteHost"), poRequest.ref().getRemoteHost());

         jsonRsp.ref().add(new character("RemotePort"), poRequest.ref().getRemotePort());

         jsonRsp.ref().add(new character("RemoteUser"), poRequest.ref().getRemoteUser());

         jsonRsp.ref().add(new character("ResolvedTransportPath"), poRequest.ref().getResolvedTransportPath());         

         //  jsonRsp:Add('ResolvedWebAppPath', poRequest:ResolvedWebAppPath).

         jsonRsp.ref().add(new character("ServerSoftware"), poRequest.ref().getServerSoftware());

         jsonRsp.ref().add(new character("TransferEncoding"), poRequest.ref().getTransferEncoding());

         jsonRsp.ref().add(new character("TransportPath"), poRequest.ref().getTransportPath());

         jsonRsp.ref().add(new character("URI"), poRequest.ref().getUri().ref().toLegacyString());

         jsonRsp.ref().add(new character("UriTemplate"), poRequest.ref().getUriTemplate());

         jsonRsp.ref().add(new character("Version"), poRequest.ref().getVersion());

         jsonRsp.ref().add(new character("WebAppPath"), poRequest.ref().getWebAppPath());

         pathParams.assign(poRequest.ref().getPathParameterNames());

         if (_isGreaterThan(pathParams, ""))

         {

            jsonObj.assign(ObjectOps.newInstance(JsonObject.class));

            jsonRsp.ref().add_1(new character("path"), jsonObj);

            loopLabel5:

            for (numItem.assign(1); _isLessThanOrEqual(numItem, numEntries(pathParams)); numItem.increment())

            {

               jsonObj.ref().add(entry(numItem, pathParams), poRequest.ref().getPathParameter(entry(numItem, pathParams)));

            }

         }

         pathParams.assign(poRequest.ref().getContextNames());

         if (_isGreaterThan(pathParams, ""))

         {

            jsonObj.assign(ObjectOps.newInstance(JsonObject.class));

            jsonRsp.ref().add_1(new character("ContextNames"), jsonObj);

            IntegerExpression resExpr0 = new IntegerExpression()

            {

               public integer execute()

               {

                  return numEntries(pathParams);

               }

            };

            ToClause toClause0 = new ToClause(numItem, 1, resExpr0);

            OnPhrase[] onPhrase0 = new OnPhrase[]

            {

               new OnPhrase(Condition.STOP, Action.NEXT, "loopLabel6")

            };

            doTo(TransactionType.SUB, "loopLabel6", toClause0, onPhrase0, new Block((Body) () -> 

            {

               {

                  silent(() -> contentVal.assign(poRequest.ref().getContextValue(entry(numItem, pathParams))));

                  if (_isGreaterThan(contentVal, ""))

                  {

                     silent(() -> jsonObj.ref().add(entry(numItem, pathParams), contentVal));

                  }

               }

            }));

         }

         jsonObj.assign(ObjectOps.newInstance(JsonObject.class));

         jsonRsp.ref().add_1(new character("headers"), jsonObj);

         loopLabel7:

         for (numItem.assign(1); _isLessThanOrEqual(numItem, numEntries(headerList)); numItem.increment())

         {

            if ((poRequest.ref().hasHeader(entry(numItem, headerList))).booleanValue())

            {

               jsonObj.ref().add(entry(numItem, headerList), poRequest.ref().getHeader(entry(numItem, headerList)).ref().getValue());

            }

         }

         if ((poRequest.ref().getEntity().isValid()).booleanValue())

         {

            if ((ObjectOps.typeOf(poRequest.ref().getEntity(), JsonObject.class)).booleanValue())

            {

               jsonRsp.ref().add_1(new character("Body"), ObjectOps.cast(poRequest.ref().getEntity(), JsonObject.class));

            }

            else

            {

               if ((ObjectOps.typeOf(poRequest.ref().getEntity(), JsonArray.class)).booleanValue())

               {

                  jsonRsp.ref().add(new character("Body"), ObjectOps.cast(poRequest.ref().getEntity(), JsonArray.class));

               }

               else

               {

                  if ((ObjectOps.typeOf(poRequest.ref().getEntity(), Memptr.class)).booleanValue())

                  {

                     jsonRsp.ref().add(new character("Body"), ObjectOps.cast(poRequest.ref().getEntity(), Memptr.class).ref().getString(new int64(new integer(1))));

                  }

               }

            }

         }

         returnNormal(jsonRsp);

      }));

   }

   @LegacySignature(type = Type.CONSTRUCTOR)

   public static void __FwdHandler_constructor__static__()

   {

      externalProcedure(FwdHandler.class, new Block((Body) () -> 

      {

         onBlockLevel(Condition.ERROR, Action.THROW);

      }));

   }

}