FWD » Core Development » Base Language

**     ME  20210310 Use object variables defined out of block for methods that returns objects.

      object<? extends Memptr> ret = TypeFactory.object(Memptr.class);

            ret.assign(Memptr.getEmpty());

         }

         else

         {

            memptr ptr = TypeFactory.memptr();

            try

            {

               ptr.setLength(size);

               readBytes(pos, ptr);

               ret.assign(ObjectOps.newInstance(Memptr.class, "I", ptr));

            }

            finally

            {

               if (ptr.lengthOf() > 0L)

                  ptr.setLength(0L);

            }

         }

         returnNormal(ret);

      object<? extends ByteBucket> bb = TypeFactory.object(ByteBucket.class);

         bb.assign(ObjectOps.newInstance(ByteBucket.class));

      object<? extends ByteBucket> bb = TypeFactory.object(ByteBucket.class);

         bb.assign(ObjectOps.newInstance(ByteBucket.class, "I", p1));

      object<? extends ByteBucket> bb = TypeFactory.object(ByteBucket.class);

         bb.assign(ObjectOps.newInstance(ByteBucket.class, "II", p1, p2));

** 006 ME  20210310 Increment object reference on option set, decrement on remove.

**     ME  20210310 Return ObjectVar on getOptionObjectValue so the reference is incremented.

      object<? extends _BaseObject_> ret = TypeFactory.object(_BaseObject_.class);

         ret.assign(getOption(p1, object.class));

         returnNormal(ret);

         OptionValueHolder val = options.remove(key);

         if (val != null && val.value() != null && val.type() == "object") {

            object obj = (object) val.value();

            if (obj._isValid())

               ObjectOps.decrement(obj.ref());

         }

         returnNormal(new logical( val != null));

         if (p2._isValid()) 

         {

            ObjectOps.increment(p2.ref());

         }

 **         20210319 Flush output stream on write, replace BigDecimal use for integer/int64.

      // make sure we write everything, do not close the stream though

      target.flush();

      if (value instanceof integer)

      {

         targetValue = ((integer) value).toJavaIntegerType();

      }

      else if (value instanceof int64)

      {

         targetValue = ((int64) value).toJavaLongType();

      }

      else if (value instanceof NumberType)

      {

         targetValue = ((NumberType) value).toBigDecimal().stripTrailingZeros();

         BigDecimal bd = (BigDecimal) value;

         if (bd.scale() == 0) 

         {

            jsonGen.writeNumber(bd.doubleValue());

         }

         else 

         {

            jsonGen.writeNumber(bd);

         }

**     ME  20210319 Fix remove, serialization,error on stream not found.

         catch (NumberFormatException e)

         int pos = idx == null || idx.isUnknown() ? -1 : idx.intValue() - 1;

         if (pos < 0 || pos >= elements.size())

            Object o = elements.remove(pos);

    * @param   method

    *          The actual 'get' method name, used for error message.

    * @param   type

    *          The expected JSON type.

      BaseDataType res = null;

      try

      {

         res = converter.apply(val);

      }

      catch(Exception ex)

      {

         log.log(Level.WARNING, "", ex);

         returnError(ObjectOps.newInstance(JsonError.class));

      }

            export.serializeTempTable(jb, tmpBuffer, true, !omit.isUnknown() && omit.booleanValue());

            returnNormal(true);

         catch (IOException e)

   @Override

   protected void throwStreamNotFound (String streamName) {

      undoThrow(JsonError.newInstance(String.format("Invalid stream parameter to Progress.Json.ObjectModel.JsonArray:WriteStream( ). Could not find open stream \"%s\".", streamName), 16062));

   }

**     ME  20210319 Fix write stream, add method to throw stream not found exception.

      character enc = TypeFactory.initInput(_enc);

      return function(this, "Write", logical.class, new Block((Body) () -> {

         if (!strHndl._isValid() || !(strHndl.get() instanceof Stream))

         {

            ErrorManager.recordOrThrowError(new int[] { 14263, 15351 },

                     new String[] { 

                              "Invalid handle or handle type for STREAM-HANDLE",

                              "WRITE-JSON( ) could not find the specified stream-handle." },

                     false, false, false);

         }

         OutputStream o = new OutputStreamWrapper(strHndl.unwrapStream());

         try

         {

         }

            logical ret = TypeFactory.logical();

               returnError(JsonError.newInstance(e.getMessage(), 0));

            returnNormal(ret);

         }

         else 

         {

            throwStreamNotFound(sname.toStringMessage());

         }

   /**

    * Throw stream not found exception. 

    * 

    * The error number and message is different for JsonArray/JsonObject.

    * 

    * @param streamName

    */

   protected void throwStreamNotFound (String streamName) {

      undoThrow(SysError.newInstance(String.format("WRITE-JSON( ) could not find open stream \"%s\"", streamName), 15343, false, true));

   }

** 012 ME  20210319 Fix error handling, implement missing methods (OE12.2).

**     ME  20210323 Format error message when buffer isn't from a temp-table.

import com.goldencode.p2j.util.ErrorManager;

import java.util.stream.Collectors;

         addPropertyImpl(prop, null, "AddNull");

         checkPropNotExists(prop, "AddNumber");

            addPropertyImpl(prop.toStringMessage(), val.isUnknown() ? (Object) null : Double.parseDouble(val.getValue()));

            undoThrow(JsonError.newInstance(ErrorManager.getInvalidParameterError("value", this,

                     "AddNumber", "Not a valid JSON number."), 16053));

         getPropertyImpl(prop, "GetCharacter", 1, o -> new character((String) o), unknown::new);

         getPropertyImpl(prop, "GetCOMHandle", 2, o -> comhandle.fromResourceId(((Number) o).longValue()), comhandle::new);

         getPropertyImpl(prop, "GetDate", 1, o -> date.parseLiteral((String) o), date::new);

         getPropertyImpl(prop, "GetDatetime", 1, o-> datetime.parseLiteral((String) o), datetime::new);

         getPropertyImpl(prop, "GetDatetimeTZ", 1, o -> datetimetz.parseLiteral((String) o), datetimetz::new);

         getPropertyImpl(prop, "GetDecimal", 2, o -> new decimal((Number) o), decimal::new);

         getPropertyImpl(prop, "GetHandle", 2, o -> handle.fromResourceId(((Number) o).longValue()), handle::new);

         getPropertyImpl(prop, "GetInt64", 2, o -> new int64((Number) o), int64::new);

         getPropertyImpl(prop, "GetInteger", 2, o -> new integer((Number) o), integer::new);

         getPropertyImpl(prop, "GetJsonArray", 5, o -> new object((JsonArray) o), object::new);

         getPropertyImpl(prop, "GetJsonObject", 4, o -> new object((JsonObject) o), object::new);

         checkPropExists(prop, "GetJsonText");

         try

         {

            returnNormal(getJsonText(properties.get(prop.toStringMessage())));

         }

         catch (IOException e)

         {

            log.log(Level.WARNING, "", e);

            returnError(ObjectOps.newInstance(JsonError.class));

         }

         getPropertyImpl(prop, "GetLogical", 3, o -> new logical((Boolean) o), logical::new);

         getPropertyImpl(prop, "GetLongchar", 1, o -> new longchar((String) o), longchar::new);

         getPropertyImpl(prop, "GetLongchar", 1, o ->

            longchar res = TypeFactory.longchar();

            if (!TextOps.isEmpty(cp))

               res.fixCodePage(cp);

            res.assign(o);

         getPropertyImpl(prop, "GetMemptr", 1, o -> new memptr(Base64.getDecoder().decode((String) o)), unknown::new);

         List<character> names = properties.keySet().stream().map(character::new).collect(Collectors.toList());

         returnExtentNormal(names.toArray(new character[names.size()]));

         getPropertyImpl(prop, "GetRaw", 1,

         getPropertyImpl(prop, "GetRecid", 2, o -> new recid(((Number) o).longValue()), recid::new);

         getPropertyImpl(prop, "GetRowid", 1, o ->

         checkPropExists(prop, "GetType");

         Object value = properties.get(prop.toStringMessage());

         returnNormal(new integer(JsonBackend.instance().getJsonDataType(value)));

         checkValidPropName(prop, "Has");

         returnNormal(new logical(properties.containsKey(prop.toStringMessage())));

         checkPropExists(prop, "IsNull");

         Object val = properties.get(prop.toStringMessage());

         returnNormal(new logical(val == null));

      return function(this, "Read", logical.class, new Block((Body) () ->

               returnNormal(readImpl(buf, omit));

         }

         undoThrow(JsonError.newInstance(ErrorManager.getInvalidParameterError("handle", this,

                  "Read", "Not initialized or not a handle to a temp-table/dataset/buffer."), 16070));

         checkPropExists(prop, "Remove");

         Object o = properties.remove(prop.toStringMessage());

         if (o instanceof JsonConstruct)

         {

            ObjectOps.decrement((_BaseObject_) o);

         }

         returnNormal(new logical(true));

         setPropertyImpl(prop, null, "SetNull");

         checkPropExists(prop, "SetNumber");

            addPropertyImpl(prop.toStringMessage(), val.isUnknown() ? (Object) null : Double.parseDouble(val.getValue()));

            undoThrow(JsonError.newInstance(ErrorManager.getInvalidParameterError("value", this,

                     "SetNumber", "Not a valid JSON number."), 16053));

      addPropertyImpl(name, value, "Add");

   }

   /**

    * Implements the {@code add} legacy methods for adding json property to this instance.

    *

    * @param   name

    *          Property name.

    * @param   value

    *          Property value.

    * @param   method

    *          Calling method name, used for error message.

    */

   private void addPropertyImpl(character name, BaseDataType value, String method)

   {

      checkPropNotExists(name, method);

      try

         Object newValue = value != null ? JsonBackend.instance().convertLegacyValueToJson(value) : null;

         addPropertyImpl(name.toStringMessage(), newValue);

         returnNormal(new logical(true));

      catch (ClassCastException e)

      setPropertyImpl(name, value, "Set");

   }

   /**

    * Implements the {@code set} legacy methods for setting json property in this instance.

    *

    * @param   name

    *          Property name.

    * @param   value

    *          Property value.

    */

   private void setPropertyImpl(character name, BaseDataType value, String method)

   {

      checkPropExists(name, method);

      try

         Object newValue = value != null ? JsonBackend.instance().convertLegacyValueToJson(value) : null;

         addPropertyImpl(name.toStringMessage(), newValue);

         returnNormal(new logical(true));

      catch (ClassCastException e)

    * @param   method

    *          Calling method name, used for error message.

    *          

   private void checkValidPropName(character property, String method)

      if (TextOps.isEmpty(property))

      {

         undoThrow(JsonError.newInstance(ErrorManager.getInvalidParameterError("name", this,

                  method, "Can not be UNKNOWN (?) or empty string."), 16055));

      }

    * @param   method

    *          Calling method name, used for error message.

   private void checkPropExists(character property, String method)

      checkValidPropName(property, method);

      String key = property.toStringMessage();

      if (!properties.containsKey(key))

      {

         undoThrow(JsonError.newInstance(String.format("Call to Progress.Json.ObjectModel.JsonObject:%s( ) failed. Property '%s' was not found.", 

                  method, key), 16058));

      }

    * Checks whether the supplied value is valid json property name and whether the property not exists.

    *

    * @param   property

    *          Property name.

    * @param   method

    *          Calling method name, used for error message.

    *

    * @return  {@code true} when the property name is valid, {@code false} otherwise.

    */

   private void checkPropNotExists(character property, String method)

   {

      checkValidPropName(property, method);

      String key = property.toStringMessage();

      if (properties.containsKey(key))

      {

         undoThrow(JsonError.newInstance(String.format("Call to Progress.Json.ObjectModel.JsonObject:%s( ) failed. Attempted to add duplicate property '%s'.", 

                  method, key), 16056));

      }

   }

   /**

    * @param   method

    *          The actual 'get' method name, used for error message.

    * @param   type

    *          The expected JSON type.

                                String method, 

                                int type,

      checkPropExists(propName, method);

      Object val = properties.get(propName.toStringMessage());

      int vtype = JsonBackend.instance().getJsonDataType(val);

      if (vtype == 6)

         returnNormal(nullSupplier.get());

      if (vtype != type)

      {

         undoThrow(JsonError.newInstance(String.format("Call to Progress.Json.ObjectModel.JsonObject:%s( ) failed. Expected a JSON %s value, found a JSON %s value.", 

                  method, JsonBackend.instance().getJsonDataTypeName(type), JsonBackend.instance().getJsonDataTypeName(vtype)), 16060));

      }

      BaseDataType res = null;

      try

      {

         if (val == null)

         {

            res = nullSupplier.get();

         }

         else

         {

            res = converter.apply(val);

         }

      }

      catch(Exception ex)

      {

         log.log(Level.WARNING, "", ex);

      returnNormal(res);

         this.clear();

         try

         {

            export.serializeTempTable(jb, tb, false, !omit.isUnknown() && omit.booleanValue());

            returnNormal(new logical(true));

         }

         catch (IOException e)

         {

            log.log(Level.WARNING, "", e);

            returnError(ObjectOps.newInstance(JsonError.class));

         }

      }));

   }

   protected logical readImpl(BufferImpl buffer, final logical omit)

   {

      return function(this, "Read", logical.class, new Block((Body) () -> {

         if (!buffer._available())

         {

            undoThrow(JsonError.newInstance(ErrorManager.getInvalidParameterError("buffer-handle", this,

                     "Read", "No record in buffer."), 16065));

         }

         if (!buffer.buffer().isTemporary())

         {

            ErrorManager.recordOrThrowError(15378, "JSON methods are only allowed on TEMP-TABLE buffers", false, false);

         }

         ObjectBuilder jb = new ObjectBuilder(this);

         JsonExport export = new JsonExport();

         this.clear();

         try

         {

            export.serializeRecord(jb, (TemporaryBuffer) buffer.buffer(), !omit.isUnknown() && omit.booleanValue());

            returnNormal(new logical(true));

         }

         catch (IOException e)

         this.clear();

            export.serializeDataSet(jb, pds, 

                     false,

                     !b4img.isUnknown() && b4img.booleanValue());

         catch (IOException e)

      object<? extends IhttpRequest> request = TypeFactory.object(IhttpRequest.class);

      return function(this, "Request", object.class, new Block(

      (Init) () ->

      {

         ObjectOps.register(request);

      },

      (Body) () -> 

      {

**     ME  20210310 Add block 'referent' for static methods.

      internalProcedure(RequestBuilder.class, "InitializeRegistry", new Block((Body) () -> {

      return function(RequestBuilder.class, "Registry", object.class, new Block((Body) () -> 

**     ME   20210310 Add block 'referent' for static methods.

      return function(ResponseBuilder.class, "Registry", object.class, new Block((Body) () -> 

** 005 ME  20210310 Use initInput in setter methods to avoid issue with 'invalid' object

**                  when value is directly returned by a method.

   public void setLogger(object<? extends IlogWriter> _poLogger)

      object<? extends IlogWriter> poLogger = TypeFactory.initInput(_poLogger);

   public void setEntity(object<? extends _BaseObject_> _poEntity)

      object<? extends _BaseObject_> poEntity = TypeFactory.initInput(_poEntity);

      externalProcedure(MessageWriter.this, new Block((Init) () -> 

      {

         ObjectOps.register(entity, entityType, logger);

      },

      (Body) () -> 

**     ME  20210310 Add block 'referent' for static methods.

      return function(AuthenticationRequestWriterBuilder.class, "Registry", object.class, new Block((Body) () -> {

**     ME  20210310 Add block 'referent' for static methods.

      return function(BodyWriterBuilder.class, "Build", object.class, new Block((Body)() -> {

      return function(BodyWriterBuilder.class, "Build", object.class, new Block((Body)() -> 

      return function(BodyWriterBuilder.class, "Build", object.class, new Block((Body)() -> 

**     ME  20210310 Add block 'referent' for static methods.

      internalProcedure(BodyWriterRegistry.class, "InitializeRegistry", new Block((Body) ()-> {

**     ME  20210310 Add block 'referent' for static methods.

      return function(EntityWriterBuilder.class, "Build", object.class, new Block((Body)() -> {

      return function(EntityWriterBuilder.class, "Build", object.class, new Block((Body)() -> 

      return function(EntityWriterBuilder.class, "Build", object.class, new Block((Body)() -> 

**     ME  20210310 Add block 'referent' for static methods, use initInput for object params.

      object<? extends BuilderRegistry> registry = TypeFactory.object(BuilderRegistry.class);

      return function(BodyWriterRegistry.class, "Registry", object.class, new Block((Body) () -> {

        registry.assign(REGISTRY.get());

   private static void initializeRegistry(final object<? extends BuilderRegistry> _poRegistry)

      internalProcedure(MessageWriterBuilder.class, "InitializeRegistry", new Block((Body) ()-> {

      return function(MessageWriterBuilder.class, "WriterRegistry", object.class, 

      return function(MessageWriterBuilder.class, "ContentType", character.class, 

         object<? extends IhttpMessage> _poMessage, 

         object<? extends BuilderRegistry> _poRegistry)

      object<? extends IhttpMessage> poMessage = TypeFactory.initInput(_poMessage);

      object<? extends BuilderRegistry> poRegistry = TypeFactory.initInput(_poRegistry);

      return function(MessageWriterBuilder.class, "Build", object.class, new Block((Body)() -> {