Function BindCore

plugins/jsvm/binds.go:298–664

BindCore registers common core objects and functions such as sleep, toString, DynamicModel, etc. into the provided runtime.

(vm *goja.Runtime)

// BindCore registers common core objects and functions such as sleep,
// toString, DynamicModel, etc. into the provided runtime.
func BindCore(vm *goja.Runtime) {
	vm.SetFieldNameMapper(FieldMapper{})

	// deprecated: use toString
	vm.Set("readerToString", func(r io.Reader, maxBytes int) (string, error) {
		if maxBytes == 0 {
			maxBytes = router.DefaultMaxMemory
		}

		limitReader := io.LimitReader(r, int64(maxBytes))

		bodyBytes, readErr := io.ReadAll(limitReader)
		if readErr != nil {
			return "", readErr
		}

		return string(bodyBytes), nil
	})

	// note: throw only on reader error
	vm.Set("toBytes", func(raw any, maxReaderBytes int) ([]byte, error) {
		switch v := raw.(type) {
		case nil:
			return []byte{}, nil
		case string:
			return []byte(v), nil
		case []byte:
			return v, nil
		case types.JSONRaw:
			return v, nil
		case io.Reader:
			if maxReaderBytes == 0 {
				maxReaderBytes = router.DefaultMaxMemory
			}

			limitReader := io.LimitReader(v, int64(maxReaderBytes))

			return io.ReadAll(limitReader)
		default:
			b, err := cast.ToUint8SliceE(v)
			if err == nil {
				return b, nil
			}

			str, err := cast.ToStringE(v)
			if err == nil {
				return []byte(str), nil
			}

			// as a last attempt try to json encode the value
			rawBytes, _ := json.Marshal(raw)

			return rawBytes, nil
		}
	})

	// note: throw only on reader error
	vm.Set("toString", func(raw any, maxReaderBytes int) (string, error) {