fix current status on sp

Tests for notification middleware and cookie utils

.dockerignore

@@ -6,6 +6,7 @@ node_modules
 # dependencies
 /node_modules
 node_modules
+**/node_modules
 
 .idea
 # testing
@@ -53,4 +54,7 @@ tests/coverage
 
 settings.json
 
-GoSDK/tester/
+GoSDK/tester/
+
+Llama/Models/*
+

.eslintrc.json

@@ -87,10 +87,11 @@
           ],
         // https://www.npmjs.com/package/eslint-plugin-unused-imports
         "no-unused-vars": "off",
-        "@typescript-eslint/no-unused-vars": "off",
+        "@typescript-eslint/no-unused-vars": ["error", {"argsIgnorePattern": "^_"}],
         "@typescript-eslint/no-extra-non-null-assertion": "error",
         "@typescript-eslint/no-floating-promises":"error",
         "@typescript-eslint/await-thenable":"error",
+        "@typescript-eslint/no-non-null-asserted-optional-chain": "error",
         "unused-imports/no-unused-imports": "error",
         "unused-imports/no-unused-vars": [
             "error",
@@ -178,11 +179,13 @@
                 "ignoreReadBeforeAssign": false
             }
         ],
-        "no-var": "error"
+        "no-var": "error",
+        "object-curly-spacing": ["error", "always"],
+        "no-unneeded-ternary": "error"
     },
     "settings": {
         "react": {
             "version": "18.1.0"
         }
     }
-}
+}

.github/workflows/code-analysis.yml

@@ -1,20 +0,0 @@
-name: Code Analysis
-on:
-  push:
-    branches:
-      - master
-  pull_request:
-    types: [opened, synchronize, reopened]
-jobs:
-  sonarcloud:
-    name: SonarCloud
-    runs-on: ubuntu-latest
-    steps:
-      - uses: actions/checkout@v3
-        with:
-          fetch-depth: 0  # Shallow clones should be disabled for a better relevancy of analysis
-      - name: SonarCloud Scan
-        uses: SonarSource/sonarcloud-github-action@master
-        env:
-          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}  # Needed to get PR information, if any
-          SONAR_TOKEN: ${{ secrets.SONAR_TOKEN }}

.github/workflows/codeql-analysis.yml

@@ -40,7 +40,7 @@ jobs:
 
     steps:
     - name: Checkout repository
-      uses: actions/checkout@v3
+      uses: actions/checkout@v4
 
     # Initializes the CodeQL tools for scanning.
     - name: Initialize CodeQL

.github/workflows/common-jobs.yaml

@@ -8,7 +8,21 @@ on:
       - 'release'
 
 jobs:
-  lint:
+  helm-lint:
+    runs-on: ubuntu-latest
+    env:
+      CI_PIPELINE_ID: ${{github.run_number}}
+    steps:
+      - name: Checkout repo
+        uses: actions/checkout@v2
+      - name: Install Helm
+        run: |
+          curl https://raw.githubusercontent.com/helm/helm/main/scripts/get-helm-3 | bash
+      - name: Lint Helm Chart 
+        run: |
+          helm lint ./HelmChart/Public/oneuptime
+          
+  js-lint:
     runs-on: ubuntu-latest
     env:
       CI_PIPELINE_ID: ${{github.run_number}}

.github/workflows/compile.yml

@@ -151,20 +151,6 @@ jobs:
       - run: cd CommonServer && npm install
       - run: cd File && npm install && npm run compile
 
-  compile-helm-chart:
-    runs-on: ubuntu-latest
-    env:
-      CI_PIPELINE_ID: ${{github.run_number}}
-    steps:
-      - uses: actions/checkout@v2
-      - uses: actions/setup-node@v2
-        with:
-          node-version: 18.3.0
-      - run: cd Common && npm install
-      - run: cd Model && npm install
-      - run: cd CommonServer && npm install
-      - run: cd HelmChart && npm install && npm run compile
-
   compile-home:
     runs-on: ubuntu-latest
     env:
@@ -207,20 +193,6 @@ jobs:
       - run: cd CommonServer && npm install
       - run: cd Integration && npm install && npm run compile
 
-  compile-licensing:
-    runs-on: ubuntu-latest
-    env:
-      CI_PIPELINE_ID: ${{github.run_number}}
-    steps:
-      - uses: actions/checkout@v2
-      - uses: actions/setup-node@v2
-        with:
-          node-version: 18.3.0
-      - run: cd Common && npm install
-      - run: cd Model && npm install
-      - run: cd CommonServer && npm install
-      - run: cd Licensing && npm install && npm run compile
-
   compile-notification:
     runs-on: ubuntu-latest
     env:
@@ -262,7 +234,7 @@ jobs:
       - run: cd CommonServer && npm install
       - run: cd Probe && npm install && npm run compile
 
-  compile-probe-api:
+  compile-ingestor:
     runs-on: ubuntu-latest
     env:
       CI_PIPELINE_ID: ${{github.run_number}}
@@ -274,7 +246,7 @@ jobs:
       - run: cd Common && npm install
       - run: cd Model && npm install
       - run: cd CommonServer && npm install
-      - run: cd ProbeAPI && npm install && npm run compile
+      - run: cd Ingestor && npm install && npm run compile
   
 
   compile-realtime:

.github/workflows/docker-build.yml

@@ -40,6 +40,21 @@ jobs:
       - name: build docker image
         run: sudo docker build -f ./LinkShortener/Dockerfile .
 
+  docker-build-otel-collector:
+    runs-on: ubuntu-latest
+    env:
+      CI_PIPELINE_ID: ${{github.run_number}}
+    steps:
+      - name: Checkout 
+        uses: actions/checkout@v2
+
+      - name: Preinstall 
+        run: npm run prerun
+      
+      # build image for accounts service
+      - name: build docker image
+        run: sudo docker build -f ./OTelCollector/Dockerfile .
+
   docker-build-api-reference:
     runs-on: ubuntu-latest
     env:
@@ -131,20 +146,6 @@ jobs:
       - name: build docker image
         run: sudo docker build -f ./Haraka/Dockerfile .
 
-  docker-build-helm-chart:
-    runs-on: ubuntu-latest
-    env:
-      CI_PIPELINE_ID: ${{github.run_number}}
-    steps:
-      - name: Checkout 
-        uses: actions/checkout@v2
-
-      - name: Preinstall 
-        run: npm run prerun
-        
-      # build image for home
-      - name: build docker image
-        run: sudo docker build -f ./HelmChart/Dockerfile .
 
   docker-build-home:
     runs-on: ubuntu-latest
@@ -187,24 +188,10 @@ jobs:
       - name: Preinstall 
         run: npm run prerun
         
-      # build image for licensing
+      # build image for integrations
       - name: build docker image
         run: sudo docker build -f ./Integration/Dockerfile .
 
-  docker-build-licensing:
-    runs-on: ubuntu-latest
-    env:
-      CI_PIPELINE_ID: ${{github.run_number}}
-    steps:
-      - name: Checkout 
-        uses: actions/checkout@v2
-      
-      - name: Preinstall 
-        run: npm run prerun
-
-      # build image for licensing
-      - name: build docker image
-        run: sudo docker build -f ./Licensing/Dockerfile .
 
   docker-build-notification:
     runs-on: ubuntu-latest
@@ -237,7 +224,7 @@ jobs:
       - name: build docker image
         run: sudo docker build -f ./Probe/Dockerfile .
 
-  docker-build-probe-api:
+  docker-build-ingestor:
     runs-on: ubuntu-latest
     env:
       CI_PIPELINE_ID: ${{github.run_number}}
@@ -250,7 +237,7 @@ jobs:
         
       # build image probe api
       - name: build docker image
-        run: sudo docker build -f ./ProbeAPI/Dockerfile .
+        run: sudo docker build -f ./Ingestor/Dockerfile .
 
   docker-build-realtime:
     runs-on: ubuntu-latest

.github/workflows/playwright.yml.skip

@@ -11,7 +11,7 @@ jobs:
     env:
       BASE_URL: http://localhost
     steps:
-    - uses: actions/checkout@v3
+    - uses: actions/checkout@v4
     - uses: actions/setup-node@v3
       with:
         node-version: 16

.github/workflows/release.yml

@@ -25,7 +25,7 @@ jobs:
     permissions:
       contents: write
     steps:
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
       - run: echo "${{needs.generate-build-number.outputs.build_number}}"
@@ -39,6 +39,54 @@ jobs:
           body: |
             ${{steps.build_changelog.outputs.changelog}}
 
+
+  helm-chart-deploy:
+    runs-on: ubuntu-latest
+    needs: generate-build-number
+    env: 
+        CI_COMMIT_AUTHOR: Continuous Integration
+    steps:
+
+      - name: Install Helm 
+        run: curl https://raw.githubusercontent.com/helm/helm/main/scripts/get-helm-3 | bash
+
+      - uses: actions/checkout@v4
+        with:
+          ref: ${{ github.ref }}
+
+      - name:  Build and Package Helm chart
+        run: |
+          cd ..
+          echo '${{ secrets.GPG_PRIVATE_KEY }}' > private.key
+          gpg --import private.key || true
+          rm private.key
+          echo "GPG key imported successfully"
+          gpg --export-secret-keys >~/.gnupg/secring.gpg 
+          echo "GPG key exported successfully"
+          eval `ssh-agent -s`
+          ssh-add - <<< '${{ secrets.HELM_CHART_GITHUB_REPO_DEPLOY_KEY }}'
+          git clone git@github.com:OneUptime/helm-chart.git
+          cd oneuptime/HelmChart/Public
+          helm lint oneuptime
+          helm package --sign --key 'key@oneuptime.com' --keyring ~/.gnupg/secring.gpg oneuptime --version 7.0.${{needs.generate-build-number.outputs.build_number}} --app-version 7.0.${{needs.generate-build-number.outputs.build_number}} 
+          echo "Helm Chart Package created successfully"
+          cd ..
+          ls
+          echo "Copying the package to helm-chart repo"
+          rm -r ../../helm-chart/oneuptime
+          cp -r ./Public/* ../../helm-chart
+          echo "Package copied successfully"
+          cd .. && cd .. && cd helm-chart
+          echo "Updating helm-chart repo"
+          git config --global user.name "${{ env.CI_COMMIT_AUTHOR }}"
+          git config --global user.email "hello@oneuptime.com"
+          echo "Git config set successfully"
+          echo "Adding the package to helm-chart repo"
+          helm repo index .
+          git add -A
+          git commit -m "Helm Chart Release 7.0.${{needs.generate-build-number.outputs.build_number}}"
+          git push origin master
+
   nginx-docker-image-deploy:
     needs: generate-build-number
     runs-on: ubuntu-latest
@@ -54,7 +102,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -114,7 +162,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -159,6 +207,68 @@ jobs:
             GIT_SHA=${{ github.sha }}
             APP_VERSION=7.0.${{needs.generate-build-number.outputs.build_number}}
 
+  otel-collector-docker-image-deploy:
+    needs: generate-build-number
+    runs-on: ubuntu-latest
+    steps:
+      - name: Docker Meta
+        id: meta
+        uses: docker/metadata-action@v4
+        with:
+          images: |
+            oneuptime/otel-collector
+            ghcr.io/oneuptime/otel-collector
+          tags: |
+            type=raw,value=release,enable=true
+            type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
+
+      - uses: actions/checkout@v4
+        with:
+          ref: ${{ github.ref }}
+
+      - uses: actions/setup-node@v2
+        with:
+          node-version: 18.3.0
+
+      - name: Set up QEMU
+        uses: docker/setup-qemu-action@v2
+
+      - name: Set up Docker Buildx
+        uses: docker/setup-buildx-action@v2
+
+      - name: Generate Dockerfile from Dockerfile.tpl
+        run: npm run prerun
+
+      # Build and deploy otel-collector.
+
+      - name: Login to Docker Hub 
+        uses: docker/login-action@v2.2.0
+        with:
+          username: ${{ secrets.DOCKERHUB_USERNAME }}
+          password: ${{ secrets.DOCKERHUB_PASSWORD }}
+
+      - name: Login to GitHub Container Registry
+        uses: docker/login-action@v2.2.0
+        with:
+          registry: ghcr.io
+          username: ${{ github.repository_owner }}
+          password: ${{ secrets.GITHUB_TOKEN }}
+
+      - name: Build and push
+        uses: docker/build-push-action@v4
+        with:
+          file: ./OTelCollector/Dockerfile
+          context: .
+          platforms: linux/amd64,linux/arm64
+          push: true
+          tags: ${{ steps.meta.outputs.tags }}
+          labels: ${{ steps.meta.outputs.labels }}
+          build-args: |
+            GIT_SHA=${{ github.sha }}
+            APP_VERSION=7.0.${{needs.generate-build-number.outputs.build_number}}
+
+
+
   workflow-docker-image-deploy:
     needs: generate-build-number
     runs-on: ubuntu-latest
@@ -174,7 +284,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -234,7 +344,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -294,7 +404,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -354,7 +464,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -399,6 +509,66 @@ jobs:
             GIT_SHA=${{ github.sha }}
             APP_VERSION=7.0.${{needs.generate-build-number.outputs.build_number}}
 
+  test-docker-image-deploy:
+    needs: generate-build-number
+    runs-on: ubuntu-latest
+    steps:
+      - name: Docker Meta
+        id: meta
+        uses: docker/metadata-action@v4
+        with:
+          images: |
+            oneuptime/test
+            ghcr.io/oneuptime/test
+          tags: |
+            type=raw,value=release,enable=true
+            type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
+
+      - uses: actions/checkout@v4
+        with:
+          ref: ${{ github.ref }}
+
+      - uses: actions/setup-node@v2
+        with:
+          node-version: 18.3.0
+
+      - name: Set up QEMU
+        uses: docker/setup-qemu-action@v2
+
+      - name: Set up Docker Buildx
+        uses: docker/setup-buildx-action@v2
+
+      - name: Generate Dockerfile from Dockerfile.tpl
+        run: npm run prerun
+
+      # Build and deploy test.
+
+      - name: Login to Docker Hub 
+        uses: docker/login-action@v2.2.0
+        with:
+          username: ${{ secrets.DOCKERHUB_USERNAME }}
+          password: ${{ secrets.DOCKERHUB_PASSWORD }}
+
+      - name: Login to GitHub Container Registry
+        uses: docker/login-action@v2.2.0
+        with:
+          registry: ghcr.io
+          username: ${{ github.repository_owner }}
+          password: ${{ secrets.GITHUB_TOKEN }}
+
+      - name: Build and push
+        uses: docker/build-push-action@v4
+        with:
+          file: ./Tests/Dockerfile
+          context: .
+          platforms: linux/amd64,linux/arm64
+          push: true
+          tags: ${{ steps.meta.outputs.tags }}
+          labels: ${{ steps.meta.outputs.labels }}
+          build-args: |
+            GIT_SHA=${{ github.sha }}
+            APP_VERSION=7.0.${{needs.generate-build-number.outputs.build_number}}
+
   realtime-docker-image-deploy:
     needs: generate-build-number
     runs-on: ubuntu-latest
@@ -414,7 +584,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -459,7 +629,7 @@ jobs:
             GIT_SHA=${{ github.sha }}
             APP_VERSION=7.0.${{needs.generate-build-number.outputs.build_number}}
 
-  probe-api-docker-image-deploy:
+  ingestor-docker-image-deploy:
     needs: generate-build-number
     runs-on: ubuntu-latest
     steps:
@@ -468,13 +638,13 @@ jobs:
         uses: docker/metadata-action@v4
         with:
           images: |
-            oneuptime/probe-api
-            ghcr.io/oneuptime/probe-api
+            oneuptime/ingestor
+            ghcr.io/oneuptime/ingestor
           tags: |
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -491,7 +661,7 @@ jobs:
       - name: Generate Dockerfile from Dockerfile.tpl
         run: npm run prerun
 
-      # Build and deploy probe-api.
+      # Build and deploy ingestor.
 
       - name: Login to Docker Hub 
         uses: docker/login-action@v2.2.0
@@ -509,7 +679,7 @@ jobs:
       - name: Build and push
         uses: docker/build-push-action@v4
         with:
-          file: ./ProbeAPI/Dockerfile
+          file: ./Ingestor/Dockerfile
           context: .
           platforms: linux/amd64,linux/arm64
           push: true
@@ -534,7 +704,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -579,66 +749,6 @@ jobs:
             GIT_SHA=${{ github.sha }}
             APP_VERSION=7.0.${{needs.generate-build-number.outputs.build_number}}
 
-  licensing-docker-image-deploy:
-    needs: generate-build-number
-    runs-on: ubuntu-latest
-    steps:
-      - name: Docker Meta
-        id: meta
-        uses: docker/metadata-action@v4
-        with:
-          images: |
-            oneuptime/licensing
-            ghcr.io/oneuptime/licensing
-          tags: |
-            type=raw,value=release,enable=true
-            type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
-
-      - uses: actions/checkout@v3
-        with:
-          ref: ${{ github.ref }}
-
-      - uses: actions/setup-node@v2
-        with:
-          node-version: 18.3.0
-
-      - name: Set up QEMU
-        uses: docker/setup-qemu-action@v2
-
-      - name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@v2
-
-      - name: Generate Dockerfile from Dockerfile.tpl
-        run: npm run prerun
-
-      # Build and deploy licensing.
-
-      - name: Login to Docker Hub 
-        uses: docker/login-action@v2.2.0
-        with:
-          username: ${{ secrets.DOCKERHUB_USERNAME }}
-          password: ${{ secrets.DOCKERHUB_PASSWORD }}
-
-      - name: Login to GitHub Container Registry
-        uses: docker/login-action@v2.2.0
-        with:
-          registry: ghcr.io
-          username: ${{ github.repository_owner }}
-          password: ${{ secrets.GITHUB_TOKEN }}
-
-      - name: Build and push
-        uses: docker/build-push-action@v4
-        with:
-          file: ./Licensing/Dockerfile
-          context: .
-          platforms: linux/amd64,linux/arm64
-          push: true
-          tags: ${{ steps.meta.outputs.tags }}
-          labels: ${{ steps.meta.outputs.labels }}
-          build-args: |
-            GIT_SHA=${{ github.sha }}
-            APP_VERSION=7.0.${{needs.generate-build-number.outputs.build_number}}
-
   integrations-docker-image-deploy:
     needs: generate-build-number
     runs-on: ubuntu-latest
@@ -654,7 +764,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -714,7 +824,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -774,7 +884,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -834,7 +944,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -879,65 +989,6 @@ jobs:
             GIT_SHA=${{ github.sha }}
             APP_VERSION=7.0.${{needs.generate-build-number.outputs.build_number}}
 
-  helm-chart-docker-image-deploy:
-    needs: generate-build-number
-    runs-on: ubuntu-latest
-    steps:
-      - name: Docker Meta
-        id: meta
-        uses: docker/metadata-action@v4
-        with:
-          images: |
-            oneuptime/helm-chart
-            ghcr.io/oneuptime/helm-chart
-          tags: |
-            type=raw,value=release,enable=true
-            type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
-
-      - uses: actions/checkout@v3
-        with:
-          ref: ${{ github.ref }}
-
-      - uses: actions/setup-node@v2
-        with:
-          node-version: 18.3.0
-
-      - name: Set up QEMU
-        uses: docker/setup-qemu-action@v2
-
-      - name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@v2
-
-      - name: Generate Dockerfile from Dockerfile.tpl
-        run: npm run prerun
-
-      # Build and deploy helm-chart.
-
-      - name: Login to Docker Hub 
-        uses: docker/login-action@v2.2.0
-        with:
-          username: ${{ secrets.DOCKERHUB_USERNAME }}
-          password: ${{ secrets.DOCKERHUB_PASSWORD }}
-
-      - name: Login to GitHub Container Registry
-        uses: docker/login-action@v2.2.0
-        with:
-          registry: ghcr.io
-          username: ${{ github.repository_owner }}
-          password: ${{ secrets.GITHUB_TOKEN }}
-
-      - name: Build and push
-        uses: docker/build-push-action@v4
-        with:
-          file: ./HelmChart/Dockerfile
-          context: .
-          platforms: linux/amd64,linux/arm64
-          push: true
-          tags: ${{ steps.meta.outputs.tags }}
-          labels: ${{ steps.meta.outputs.labels }}
-          build-args: |
-            GIT_SHA=${{ github.sha }}
-            APP_VERSION=7.0.${{needs.generate-build-number.outputs.build_number}}
 
   haraka-docker-image-deploy:
     needs: generate-build-number
@@ -954,7 +1005,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -1014,7 +1065,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -1075,7 +1126,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -1136,7 +1187,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -1196,7 +1247,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -1256,7 +1307,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -1316,7 +1367,7 @@ jobs:
             type=raw,value=release,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}},pattern={{version}},enable=true
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 

.github/workflows/test-release.yaml

@@ -35,7 +35,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -96,7 +96,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -157,7 +157,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -202,6 +202,69 @@ jobs:
             GIT_SHA=${{ github.sha }}
             APP_VERSION=7.0.${{needs.generate-build-number.outputs.build_number}}
 
+
+          
+  otel-collector-docker-image-deploy:
+    needs: generate-build-number
+    runs-on: ubuntu-latest
+    steps:
+      - name: Docker Meta
+        id: meta
+        uses: docker/metadata-action@v4
+        with:
+          images: |
+            oneuptime/otel-collector
+            ghcr.io/oneuptime/otel-collector
+          tags: |
+            type=raw,value=test,enable=true
+            type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
+            
+
+      - uses: actions/checkout@v4
+        with:
+          ref: ${{ github.ref }}
+
+      - uses: actions/setup-node@v2
+        with:
+          node-version: 18.3.0
+
+      - name: Set up QEMU
+        uses: docker/setup-qemu-action@v2
+
+      - name: Set up Docker Buildx
+        uses: docker/setup-buildx-action@v2
+
+      - name: Generate Dockerfile from Dockerfile.tpl
+        run: npm run prerun
+
+      # Build and deploy otel-collector.
+
+      - name: Login to Docker Hub 
+        uses: docker/login-action@v2.2.0
+        with:
+          username: ${{ secrets.DOCKERHUB_USERNAME }}
+          password: ${{ secrets.DOCKERHUB_PASSWORD }}
+
+      - name: Login to GitHub Container Registry
+        uses: docker/login-action@v2.2.0
+        with:
+          registry: ghcr.io
+          username: ${{ github.repository_owner }}
+          password: ${{ secrets.GITHUB_TOKEN }}
+
+      - name: Build and push
+        uses: docker/build-push-action@v4
+        with:
+          file: ./OTelCollector/Dockerfile
+          context: .
+          platforms: linux/amd64,linux/arm64
+          push: true
+          tags: ${{ steps.meta.outputs.tags }}
+          labels: ${{ steps.meta.outputs.labels }}
+          build-args: |
+            GIT_SHA=${{ github.sha }}
+            APP_VERSION=7.0.${{needs.generate-build-number.outputs.build_number}}
+
   link-shortener-docker-image-deploy:
     needs: generate-build-number
     runs-on: ubuntu-latest
@@ -218,7 +281,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -279,7 +342,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -340,7 +403,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -385,6 +448,69 @@ jobs:
             GIT_SHA=${{ github.sha }}
             APP_VERSION=7.0.${{needs.generate-build-number.outputs.build_number}}
 
+
+
+  test-docker-image-deploy:
+    needs: generate-build-number
+    runs-on: ubuntu-latest
+    steps:
+      - name: Docker Meta
+        id: meta
+        uses: docker/metadata-action@v4
+        with:
+          images: |
+            oneuptime/test
+            ghcr.io/oneuptime/test
+          tags: |
+            type=raw,value=test,enable=true
+            type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
+            
+
+      - uses: actions/checkout@v4
+        with:
+          ref: ${{ github.ref }}
+
+      - uses: actions/setup-node@v2
+        with:
+          node-version: 18.3.0
+
+      - name: Set up QEMU
+        uses: docker/setup-qemu-action@v2
+
+      - name: Set up Docker Buildx
+        uses: docker/setup-buildx-action@v2
+
+      - name: Generate Dockerfile from Dockerfile.tpl
+        run: npm run prerun
+
+      # Build and deploy test.
+
+      - name: Login to Docker Hub 
+        uses: docker/login-action@v2.2.0
+        with:
+          username: ${{ secrets.DOCKERHUB_USERNAME }}
+          password: ${{ secrets.DOCKERHUB_PASSWORD }}
+
+      - name: Login to GitHub Container Registry
+        uses: docker/login-action@v2.2.0
+        with:
+          registry: ghcr.io
+          username: ${{ github.repository_owner }}
+          password: ${{ secrets.GITHUB_TOKEN }}
+
+      - name: Build and push
+        uses: docker/build-push-action@v4
+        with:
+          file: ./Tests/Dockerfile
+          context: .
+          platforms: linux/amd64,linux/arm64
+          push: true
+          tags: ${{ steps.meta.outputs.tags }}
+          labels: ${{ steps.meta.outputs.labels }}
+          build-args: |
+            GIT_SHA=${{ github.sha }}
+            APP_VERSION=7.0.${{needs.generate-build-number.outputs.build_number}}
+
   realtime-docker-image-deploy:
     needs: generate-build-number
     runs-on: ubuntu-latest
@@ -401,7 +527,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -446,7 +572,7 @@ jobs:
             GIT_SHA=${{ github.sha }}
             APP_VERSION=7.0.${{needs.generate-build-number.outputs.build_number}}
 
-  probe-api-docker-image-deploy:
+  ingestor-docker-image-deploy:
     needs: generate-build-number
     runs-on: ubuntu-latest
     steps:
@@ -455,14 +581,14 @@ jobs:
         uses: docker/metadata-action@v4
         with:
           images: |
-            oneuptime/probe-api
-            ghcr.io/oneuptime/probe-api
+            oneuptime/ingestor
+            ghcr.io/oneuptime/ingestor
           tags: |
             type=raw,value=test,enable=true
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -479,7 +605,7 @@ jobs:
       - name: Generate Dockerfile from Dockerfile.tpl
         run: npm run prerun
 
-      # Build and deploy probe-api.
+      # Build and deploy ingestor.
 
       - name: Login to Docker Hub 
         uses: docker/login-action@v2.2.0
@@ -497,7 +623,7 @@ jobs:
       - name: Build and push
         uses: docker/build-push-action@v4
         with:
-          file: ./ProbeAPI/Dockerfile
+          file: ./Ingestor/Dockerfile
           context: .
           platforms: linux/amd64,linux/arm64
           push: true
@@ -523,7 +649,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -568,67 +694,6 @@ jobs:
             GIT_SHA=${{ github.sha }}
             APP_VERSION=7.0.${{needs.generate-build-number.outputs.build_number}}
 
-  licensing-docker-image-deploy:
-    needs: generate-build-number
-    runs-on: ubuntu-latest
-    steps:
-      - name: Docker Meta
-        id: meta
-        uses: docker/metadata-action@v4
-        with:
-          images: |
-            oneuptime/licensing
-            ghcr.io/oneuptime/licensing
-          tags: |
-            type=raw,value=test,enable=true
-            type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
-            
-
-      - uses: actions/checkout@v3
-        with:
-          ref: ${{ github.ref }}
-
-      - uses: actions/setup-node@v2
-        with:
-          node-version: 18.3.0
-
-      - name: Set up QEMU
-        uses: docker/setup-qemu-action@v2
-
-      - name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@v2
-
-      - name: Generate Dockerfile from Dockerfile.tpl
-        run: npm run prerun
-
-      # Build and deploy licensing.
-
-      - name: Login to Docker Hub 
-        uses: docker/login-action@v2.2.0
-        with:
-          username: ${{ secrets.DOCKERHUB_USERNAME }}
-          password: ${{ secrets.DOCKERHUB_PASSWORD }}
-
-      - name: Login to GitHub Container Registry
-        uses: docker/login-action@v2.2.0
-        with:
-          registry: ghcr.io
-          username: ${{ github.repository_owner }}
-          password: ${{ secrets.GITHUB_TOKEN }}
-
-      - name: Build and push
-        uses: docker/build-push-action@v4
-        with:
-          file: ./Licensing/Dockerfile
-          context: .
-          platforms: linux/amd64,linux/arm64
-          push: true
-          tags: ${{ steps.meta.outputs.tags }}
-          labels: ${{ steps.meta.outputs.labels }}
-          build-args: |
-            GIT_SHA=${{ github.sha }}
-            APP_VERSION=7.0.${{needs.generate-build-number.outputs.build_number}}
-
   integrations-docker-image-deploy:
     needs: generate-build-number
     runs-on: ubuntu-latest
@@ -645,7 +710,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -706,7 +771,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -767,7 +832,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -828,7 +893,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -873,66 +938,6 @@ jobs:
             GIT_SHA=${{ github.sha }}
             APP_VERSION=7.0.${{needs.generate-build-number.outputs.build_number}}
 
-  helm-chart-docker-image-deploy:
-    needs: generate-build-number
-    runs-on: ubuntu-latest
-    steps:
-      - name: Docker Meta
-        id: meta
-        uses: docker/metadata-action@v4
-        with:
-          images: |
-            oneuptime/helm-chart
-            ghcr.io/oneuptime/helm-chart
-          tags: |
-            type=raw,value=test,enable=true
-            type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
-            
-
-      - uses: actions/checkout@v3
-        with:
-          ref: ${{ github.ref }}
-
-      - uses: actions/setup-node@v2
-        with:
-          node-version: 18.3.0
-
-      - name: Set up QEMU
-        uses: docker/setup-qemu-action@v2
-
-      - name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@v2
-
-      - name: Generate Dockerfile from Dockerfile.tpl
-        run: npm run prerun
-
-      # Build and deploy helm-chart.
-
-      - name: Login to Docker Hub 
-        uses: docker/login-action@v2.2.0
-        with:
-          username: ${{ secrets.DOCKERHUB_USERNAME }}
-          password: ${{ secrets.DOCKERHUB_PASSWORD }}
-
-      - name: Login to GitHub Container Registry
-        uses: docker/login-action@v2.2.0
-        with:
-          registry: ghcr.io
-          username: ${{ github.repository_owner }}
-          password: ${{ secrets.GITHUB_TOKEN }}
-
-      - name: Build and push
-        uses: docker/build-push-action@v4
-        with:
-          file: ./HelmChart/Dockerfile
-          context: .
-          platforms: linux/amd64,linux/arm64
-          push: true
-          tags: ${{ steps.meta.outputs.tags }}
-          labels: ${{ steps.meta.outputs.labels }}
-          build-args: |
-            GIT_SHA=${{ github.sha }}
-            APP_VERSION=7.0.${{needs.generate-build-number.outputs.build_number}}
 
   haraka-docker-image-deploy:
     needs: generate-build-number
@@ -950,7 +955,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -1011,7 +1016,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -1072,7 +1077,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -1133,7 +1138,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -1194,7 +1199,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -1255,7 +1260,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 
@@ -1316,7 +1321,7 @@ jobs:
             type=semver,value=7.0.${{needs.generate-build-number.outputs.build_number}}-test,pattern={{version}},enable=true
             
 
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.ref }}
 

.github/workflows/test.ingestor.yaml

@@ -1,4 +1,4 @@
-name: Probe Api Test
+name: Ingestor Test
 
 on:
   pull_request: 
@@ -17,5 +17,5 @@ jobs:
       - uses: actions/setup-node@v2
         with:
           node-version: 18.3.0
-      - run: cd ProbeAPI && npm install && npm run test
+      - run: cd Ingestor && npm install && npm run test
   

.gitignore

@@ -88,3 +88,12 @@ Backups/*.tar
 
 Haraka/dkim/keys/private_base64.txt
 Haraka/dkim/keys/public_base64.txt
+
+.eslintcache
+
+HelmChart/Values/*.values.yaml
+
+Llama/Models/tokenizer*
+Llama/Models/llama*
+
+Llama/__pycache__/*

.vscode/launch.json

@@ -99,8 +99,8 @@
         },
         {
             "address": "127.0.0.1",
-            "localRoot": "${workspaceFolder}/ProbeAPI",
-            "name": "Probe API: Debug with Docker",
+            "localRoot": "${workspaceFolder}/Ingestor",
+            "name": "Ingestor: Debug with Docker",
             "port": 9932,
             "remoteRoot": "/usr/src/app",
             "request": "attach",
@@ -125,20 +125,6 @@
             "restart": true,
             "autoAttachChildProcesses": true
         },
-        {
-            "address": "127.0.0.1",
-            "localRoot": "${workspaceFolder}/data-ingestor",
-            "name": "Data Ingestor: Debug with Docker",
-            "port": 9338,
-            "remoteRoot": "/usr/src/app",
-            "request": "attach",
-            "skipFiles": [
-                "<node_internals>/**"
-            ],
-            "type": "node",
-            "restart": true,
-            "autoAttachChildProcesses": true
-        },
         {
             "address": "127.0.0.1",
             "localRoot": "${workspaceFolder}/Notification",
@@ -197,7 +183,7 @@
         },
         {
             "address": "127.0.0.1",
-            "localRoot": "${workspaceFolder}/ProbeAPI",
+            "localRoot": "${workspaceFolder}/Ingestor",
             "name": "Probe API: Debug with Docker",
             "port": 9251,
             "remoteRoot": "/usr/src/app",

Accounts/Dockerfile.tpl

@@ -3,12 +3,10 @@
 #
 
 # Pull base image nodejs image.
-FROM node:current-alpine AS base
+FROM node:current-alpine
 USER root
 RUN mkdir /tmp/npm &&  chmod 2777 /tmp/npm && chown 1000:1000 /tmp/npm && npm config set cache /tmp/npm --global
 
-RUN npm config set fetch-retry-maxtimeout 6000000
-RUN npm config set fetch-retry-mintimeout 1000000
 
 ARG GIT_SHA
 ARG APP_VERSION
@@ -26,9 +24,6 @@ SHELL ["/bin/bash", "-c"]
 
 RUN mkdir /usr/src
 
-# Install common
-
-FROM base AS common
 WORKDIR /usr/src/Common
 COPY ./Common/package*.json /usr/src/Common/
 RUN npm install
@@ -36,9 +31,6 @@ COPY ./Common /usr/src/Common
 
 
 
-# Install Model
-
-FROM base AS model
 WORKDIR /usr/src/Model
 COPY ./Model/package*.json /usr/src/Model/
 RUN npm install
@@ -46,9 +38,6 @@ COPY ./Model /usr/src/Model
 
 
 
-# Install CommonServer
-
-FROM base AS commonserver
 WORKDIR /usr/src/CommonServer
 COPY ./CommonServer/package*.json /usr/src/CommonServer/
 RUN npm install
@@ -59,7 +48,6 @@ COPY ./CommonServer /usr/src/CommonServer
 
 # Install CommonUI
 
-FROM base AS commonui
 WORKDIR /usr/src/CommonUI
 COPY ./CommonUI/package*.json /usr/src/CommonUI/
 RUN npm install --force
@@ -67,22 +55,6 @@ COPY ./CommonUI /usr/src/CommonUI
 
 
 
-#SET ENV Variables
-# Install app
-FROM base AS app
-
-WORKDIR /usr/src/Common
-COPY --from=common /usr/src/Common .
-
-WORKDIR /usr/src/Model
-COPY --from=model /usr/src/Model .
-
-WORKDIR /usr/src/CommonServer
-COPY --from=commonserver /usr/src/CommonServer .
-
-WORKDIR /usr/src/CommonUI
-COPY --from=commonui /usr/src/CommonUI .
-
 
 ENV PRODUCTION=true
 ENV PUPPETEER_SKIP_CHROMIUM_DOWNLOAD=true

Accounts/Serve.ts

@@ -14,11 +14,14 @@ const init: () => Promise<void> = async (): Promise<void> => {
     } catch (err) {
         logger.error('App Init Failed:');
         logger.error(err);
+        throw err;
     }
 };
 
 init().catch((err: Error) => {
     logger.error(err);
+    logger.info('Exiting node process');
+    process.exit(1);
 });
 
 export default app;

Accounts/public/index.html

@@ -108,16 +108,7 @@
   <!-- End Google Tag Manager (noscript) -->
   <noscript>You need to enable JavaScript to run this app.</noscript>
   <div id="root"></div>
-  <!--
-      This HTML file is a template.
-      If you open it directly in the browser, you will see an empty page.
 
-      You can add webfonts, meta tags, or analytics to this file.
-      The build step will place the bundled scripts into the <body> tag.
-
-      To begin the development, run `npm start` or `yarn start`.
-    To create a production bundle, use `npm run build` or `yarn build`.
-    -->
   <script src="/accounts/dist/bundle.js"></script>
   <script>
     tailwind.config = {

Accounts/src/Pages/Login.tsx

@@ -107,7 +107,7 @@ const LoginPage: () => JSX.Element = () => {
                         maxPrimaryButtonWidth={true}
                         footer={
                             <div className="actions pointer text-center mt-4 hover:underline fw-semibold">
-                                <p>
+                                <div>
                                     {!showSsoTip && (
                                         <div
                                             onClick={() => {
@@ -128,13 +128,13 @@ const LoginPage: () => JSX.Element = () => {
                                             your project.
                                         </div>
                                     )}
-                                </p>
+                                </div>
                             </div>
                         }
                     />
                 </div>
                 <div className="mt-10 text-center">
-                    <p className="text-muted mb-0 text-gray-500">
+                    <div className="text-muted mb-0 text-gray-500">
                         Don&apos;t have an account?{' '}
                         <Link
                             to={new Route('/accounts/register')}
@@ -142,7 +142,7 @@ const LoginPage: () => JSX.Element = () => {
                         >
                             Register.
                         </Link>
-                    </p>
+                    </div>
                 </div>
             </div>
         </div>

Accounts/src/Utils/Login.ts

@@ -16,14 +16,15 @@ export default abstract class LoginUtil {
             User
         ) as User;
 
-        const token: string = value['token'] as string;
-
-        UserUtil.setAccessToken(token);
         UserUtil.setEmail(user.email as Email);
         UserUtil.setUserId(user.id as ObjectID);
-        UserUtil.setName(user.name as Name);
+        UserUtil.setName(user.name || new Name(''));
         UserUtil.setIsMasterAdmin(user.isMasterAdmin as boolean);
 
+        if (user.profilePictureId) {
+            UserUtil.setProfilePicId(user.profilePictureId);
+        }
+
         Analytics.userAuth(user.email!);
 
         // go to dashboard, user should be logged in.

AdminDashboard/Dockerfile.tpl

@@ -3,12 +3,10 @@
 #
 
 # Pull base image nodejs image.
-FROM node:current-alpine AS base
+FROM node:current-alpine
 USER root
 RUN mkdir /tmp/npm &&  chmod 2777 /tmp/npm && chown 1000:1000 /tmp/npm && npm config set cache /tmp/npm --global
 
-RUN npm config set fetch-retry-maxtimeout 6000000
-RUN npm config set fetch-retry-mintimeout 1000000
 
 ARG GIT_SHA
 ARG APP_VERSION
@@ -26,18 +24,12 @@ SHELL ["/bin/bash", "-c"]
 
 RUN mkdir /usr/src
 
-# Install common
-
-FROM base AS common
 WORKDIR /usr/src/Common
 COPY ./Common/package*.json /usr/src/Common/
 RUN npm install
 COPY ./Common /usr/src/Common
 
 
-# Install Model
-
-FROM base AS model
 WORKDIR /usr/src/Model
 COPY ./Model/package*.json /usr/src/Model/
 RUN npm install
@@ -45,9 +37,6 @@ COPY ./Model /usr/src/Model
 
 
 
-# Install CommonServer
-
-FROM base AS commonserver
 WORKDIR /usr/src/CommonServer
 COPY ./CommonServer/package*.json /usr/src/CommonServer/
 RUN npm install
@@ -58,29 +47,12 @@ COPY ./CommonServer /usr/src/CommonServer
 
 # Install CommonUI
 
-FROM base AS commonui
 WORKDIR /usr/src/CommonUI
 COPY ./CommonUI/package*.json /usr/src/CommonUI/
 RUN npm install --force
 COPY ./CommonUI /usr/src/CommonUI
 
 
-#SET ENV Variables
-# Install app
-FROM base AS app
-
-WORKDIR /usr/src/Common
-COPY --from=common /usr/src/Common .
-
-WORKDIR /usr/src/Model
-COPY --from=model /usr/src/Model .
-
-WORKDIR /usr/src/CommonServer
-COPY --from=commonserver /usr/src/CommonServer .
-
-WORKDIR /usr/src/CommonUI
-COPY --from=commonui /usr/src/CommonUI .
-
 
 ENV PRODUCTION=true
 ENV PUPPETEER_SKIP_CHROMIUM_DOWNLOAD=true

AdminDashboard/Serve.ts

@@ -13,11 +13,14 @@ const init: () => Promise<void> = async (): Promise<void> => {
     } catch (err) {
         logger.error('App Init Failed:');
         logger.error(err);
+        throw err;
     }
 };
 
 init().catch((err: Error) => {
     logger.error(err);
+    logger.info('Exiting node process');
+    process.exit(1);
 });
 
 export default app;

AdminDashboard/package-lock.json

@@ -66,7 +66,7 @@
                 "moment-timezone": "^0.5.40",
                 "nanoid": "^3.3.2",
                 "nanoid-dictionary": "^4.3.0",
-                "posthog-js": "^1.37.0",
+                "posthog-js": "^1.77.0",
                 "process": "^0.11.10",
                 "reflect-metadata": "^0.1.13",
                 "slugify": "^1.6.5",
@@ -74,7 +74,7 @@
                 "uuid": "^8.3.2"
             },
             "devDependencies": {
-                "@faker-js/faker": "^6.3.1",
+                "@faker-js/faker": "^8.0.2",
                 "@types/jest": "^27.5.2",
                 "@types/node": "^17.0.22",
                 "jest": "^27.5.1",
@@ -86,6 +86,7 @@
             "version": "1.0.0",
             "license": "MIT",
             "dependencies": {
+                "@clickhouse/client": "^0.2.1",
                 "@elastic/elasticsearch": "^8.1.0",
                 "@opentelemetry/api": "^1.1.0",
                 "@opentelemetry/auto-instrumentations-node": "^0.31.0",
@@ -11913,9 +11914,9 @@
             "peer": true
         },
         "node_modules/json5": {
-            "version": "2.2.2",
-            "resolved": "https://registry.npmjs.org/json5/-/json5-2.2.2.tgz",
-            "integrity": "sha512-46Tk9JiOL2z7ytNQWFLpj99RZkVgeHf87yGQKsIkaPz1qSH9UczKH1rO7K3wgRselo0tYMUNfecYpm/p1vC7tQ==",
+            "version": "2.2.3",
+            "resolved": "https://registry.npmjs.org/json5/-/json5-2.2.3.tgz",
+            "integrity": "sha512-XmOWe7eyHYH14cLdVPoyg+GOH3rYX++KpzrylJwSW98t3Nk+U8XOl8FWKOgwtzdb8lXGf6zYwDUzeHMWfxasyg==",
             "dev": true,
             "peer": true,
             "bin": {
@@ -17137,9 +17138,9 @@
             }
         },
         "node_modules/tsconfig-paths/node_modules/json5": {
-            "version": "1.0.1",
-            "resolved": "https://registry.npmjs.org/json5/-/json5-1.0.1.tgz",
-            "integrity": "sha512-aKS4WQjPenRxiQsC93MNfjx+nbF4PAdYzmd/1JIj8HYzqfbu86beTuNgXDzPknWk0n0uARlyewZo4s++ES36Ow==",
+            "version": "1.0.2",
+            "resolved": "https://registry.npmjs.org/json5/-/json5-1.0.2.tgz",
+            "integrity": "sha512-g1MWMLBiz8FKi1e4w0UyVL3w+iJceWAFBAaBnnGKOpNa5f8TLktkbre1+s6oICydWAm+HRUGTmI+//xv2hvXYA==",
             "dev": true,
             "peer": true,
             "dependencies": {
@@ -23463,7 +23464,7 @@
         "Common": {
             "version": "file:../Common",
             "requires": {
-                "@faker-js/faker": "^6.3.1",
+                "@faker-js/faker": "^8.0.2",
                 "@types/crypto-js": "^4.1.1",
                 "@types/jest": "^27.5.2",
                 "@types/nanoid-dictionary": "^4.2.0",
@@ -23477,7 +23478,7 @@
                 "moment-timezone": "^0.5.40",
                 "nanoid": "^3.3.2",
                 "nanoid-dictionary": "^4.3.0",
-                "posthog-js": "^1.37.0",
+                "posthog-js": "^1.77.0",
                 "process": "^0.11.10",
                 "reflect-metadata": "^0.1.13",
                 "slugify": "^1.6.5",
@@ -23510,6 +23511,7 @@
         "CommonServer": {
             "version": "file:../CommonServer",
             "requires": {
+                "@clickhouse/client": "^0.2.1",
                 "@elastic/elasticsearch": "^8.1.0",
                 "@faker-js/faker": "^6.3.1",
                 "@opentelemetry/api": "^1.1.0",
@@ -27674,9 +27676,9 @@
             "peer": true
         },
         "json5": {
-            "version": "2.2.2",
-            "resolved": "https://registry.npmjs.org/json5/-/json5-2.2.2.tgz",
-            "integrity": "sha512-46Tk9JiOL2z7ytNQWFLpj99RZkVgeHf87yGQKsIkaPz1qSH9UczKH1rO7K3wgRselo0tYMUNfecYpm/p1vC7tQ==",
+            "version": "2.2.3",
+            "resolved": "https://registry.npmjs.org/json5/-/json5-2.2.3.tgz",
+            "integrity": "sha512-XmOWe7eyHYH14cLdVPoyg+GOH3rYX++KpzrylJwSW98t3Nk+U8XOl8FWKOgwtzdb8lXGf6zYwDUzeHMWfxasyg==",
             "dev": true,
             "peer": true
         },
@@ -31459,9 +31461,9 @@
             },
             "dependencies": {
                 "json5": {
-                    "version": "1.0.1",
-                    "resolved": "https://registry.npmjs.org/json5/-/json5-1.0.1.tgz",
-                    "integrity": "sha512-aKS4WQjPenRxiQsC93MNfjx+nbF4PAdYzmd/1JIj8HYzqfbu86beTuNgXDzPknWk0n0uARlyewZo4s++ES36Ow==",
+                    "version": "1.0.2",
+                    "resolved": "https://registry.npmjs.org/json5/-/json5-1.0.2.tgz",
+                    "integrity": "sha512-g1MWMLBiz8FKi1e4w0UyVL3w+iJceWAFBAaBnnGKOpNa5f8TLktkbre1+s6oICydWAm+HRUGTmI+//xv2hvXYA==",
                     "dev": true,
                     "peer": true,
                     "requires": {

AdminDashboard/public/index.html

@@ -102,16 +102,7 @@
   <!-- End Google Tag Manager (noscript) -->
     <noscript>You need to enable JavaScript to run this app.</noscript>
     <div id="root"></div>
-    <!--
-      This HTML file is a template.
-      If you open it directly in the browser, you will see an empty page.
 
-      You can add webfonts, meta tags, or analytics to this file.
-      The build step will place the bundled scripts into the <body> tag.
-
-      To begin the development, run `npm start` or `yarn start`.
-      To create a production bundle, use `npm run build` or `yarn build`.
-    -->
     <script src="/admin/dist/bundle.js"></script>
     <script>
       tailwind.config = {

AdminDashboard/src/App.tsx

@@ -19,7 +19,6 @@ import Users from './Pages/Users/Index';
 import Logout from './Pages/Logout/Logout';
 
 // Settings Pages.
-import SettingsHost from './Pages/Settings/Host/Index';
 import SettingsEmail from './Pages/Settings/SMTP/Index';
 import SettingsCallSMS from './Pages/Settings/CallSMS/Index';
 import SettingsProbes from './Pages/Settings/Probes/Index';
@@ -73,12 +72,7 @@ const App: () => JSX.Element = () => {
 
                 <PageRoute
                     path={RouteMap[PageMap.SETTINGS]?.toString() || ''}
-                    element={<SettingsHost />}
-                />
-
-                <PageRoute
-                    path={RouteMap[PageMap.SETTINGS_HOST]?.toString() || ''}
-                    element={<SettingsHost />}
+                    element={<SettingsAuthentication />}
                 />
 
                 <PageRoute

AdminDashboard/src/Pages/Logout/Logout.tsx

@@ -9,12 +9,21 @@ import UserUtil from 'CommonUI/src/Utils/User';
 import Navigation from 'CommonUI/src/Utils/Navigation';
 import { ACCOUNTS_URL } from 'CommonUI/src/Config';
 import UiAnalytics from 'CommonUI/src/Utils/Analytics';
+import ErrorMessage from 'CommonUI/src/Components/ErrorMessage/ErrorMessage';
 
 const Logout: FunctionComponent = (): ReactElement => {
-    useEffect(() => {
+    const [error, setError] = React.useState<string | null>(null);
+
+    const logout: Function = async () => {
         UiAnalytics.logout();
-        UserUtil.logout();
+        await UserUtil.logout();
         Navigation.navigate(ACCOUNTS_URL);
+    };
+
+    useEffect(() => {
+        logout().catch((error: Error) => {
+            setError(error.message || error.toString());
+        });
     }, []);
 
     return (
@@ -35,7 +44,8 @@ const Logout: FunctionComponent = (): ReactElement => {
                 },
             ]}
         >
-            <PageLoader isVisible={true} />
+            {!error ? <PageLoader isVisible={true} /> : <></>}
+            {error ? <ErrorMessage error={error} /> : <></>}
         </Page>
     );
 };

AdminDashboard/src/Pages/Settings/SideMenu.tsx

@@ -11,7 +11,7 @@ const DashboardSideMenu: () => JSX.Element = (): ReactElement => {
     return (
         <SideMenu>
             <SideMenuSection title="Basic">
-                <SideMenuItem
+                {/* <SideMenuItem
                     link={{
                         title: 'Host',
                         to: RouteUtil.populateRouteParams(
@@ -19,7 +19,7 @@ const DashboardSideMenu: () => JSX.Element = (): ReactElement => {
                         ),
                     }}
                     icon={IconProp.Globe}
-                />
+                /> */}
                 <SideMenuItem
                     link={{
                         title: 'Authentication',

ApiReference/Dockerfile.tpl

@@ -1,10 +1,8 @@
 # Pull base image nodejs image.
-FROM node:current-alpine AS base
+FROM node:current-alpine
 USER root
 RUN mkdir /tmp/npm &&  chmod 2777 /tmp/npm && chown 1000:1000 /tmp/npm && npm config set cache /tmp/npm --global
 
-RUN npm config set fetch-retry-maxtimeout 6000000
-RUN npm config set fetch-retry-mintimeout 1000000
 
 ARG GIT_SHA
 ARG APP_VERSION
@@ -22,18 +20,12 @@ SHELL ["/bin/bash", "-c"]
 
 RUN mkdir /usr/src
 
-# Install common
-
-FROM base AS common
 WORKDIR /usr/src/Common
 COPY ./Common/package*.json /usr/src/Common/
 RUN npm install
 COPY ./Common /usr/src/Common
 
 
-# Install Model
-
-FROM base AS model
 WORKDIR /usr/src/Model
 COPY ./Model/package*.json /usr/src/Model/
 RUN npm install
@@ -41,9 +33,6 @@ COPY ./Model /usr/src/Model
 
 
 
-# Install CommonServer
-
-FROM base AS commonserver
 WORKDIR /usr/src/CommonServer
 COPY ./CommonServer/package*.json /usr/src/CommonServer/
 RUN npm install
@@ -52,16 +41,7 @@ COPY ./CommonServer /usr/src/CommonServer
 
 
 # Install app
-FROM base AS app
 
-WORKDIR /usr/src/Common
-COPY --from=common /usr/src/Common .
-
-WORKDIR /usr/src/Model
-COPY --from=model /usr/src/Model .
-
-WORKDIR /usr/src/CommonServer
-COPY --from=commonserver /usr/src/CommonServer .
 
 
 ENV PRODUCTION=true

ApiReference/Index.ts

@@ -93,11 +93,14 @@ const init: () => Promise<void> = async (): Promise<void> => {
     } catch (err) {
         logger.error('App Init Failed:');
         logger.error(err);
+        throw err;
     }
 };
 
 init().catch((err: Error) => {
     logger.error(err);
+    logger.info('Exiting node process');
+    process.exit(1);
 });
 
 export default app;

ApiReference/Service/Model.ts

@@ -1,4 +1,4 @@
-import { ColumnAccessControl } from 'Common/Types/Database/AccessControl/AccessControl';
+import { ColumnAccessControl } from 'Common/Types/BaseDatabase/AccessControl';
 import { getTableColumns } from 'Common/Types/Database/TableColumn';
 import Dictionary from 'Common/Types/Dictionary';
 import ObjectID from 'Common/Types/ObjectID';

Ci/README.md

@@ -1,25 +0,0 @@
-# Setup Production Server
-
-### Run the production.yml file.
-
-run the file specific to the project with their specific names.
-`kubectl create -f production.yml`
-
-# Known Issues
-
-### Issue 1
-
-Sometimes you'll see this error
-
-```
-$ kubectl create -f staging.yaml
-error: SchemaError(io.k8s.api.apps.v1beta2.DeploymentCondition): invalid object doesn't have additional properties
-```
-
-**Solution:**
-
-Run the kubectl command with validate false
-
-```
-$ kubectl create -f staging.yaml --validate=false
-```

Ci/init-script/test.yaml

@@ -1,27 +0,0 @@
-#########
-#Since Kubernetes jobs are immitable (you cannot update it with a new image).
-# To update these jobs, CI deletes the old jobs and recreates them using this file.
-#########
-
-#########
-#UPDATE: Any update to this file should also be accompanied with ../test.yaml
-#########
-
-########-InitScript-##########
-apiVersion: batch/v1
-kind: Job
-metadata:
-    name: InitScript
-spec:
-    template:
-        spec:
-            containers:
-                - name: InitScript
-                  image: localhost:32000/InitScript:test
-                  imagePullPolicy: Always
-                  env:
-                      - name: MONGO_URL
-                        value: 'mongodb://admin:372b60f4-704c-4205-8e5c-45cdbf44b1fc@mongo-0.mongo.default.svc.cluster.local:27017,mongo-1.mongo.default.svc.cluster.local:27017,mongo-2.mongo.default.svc.cluster.local:27017/oneuptimedb?replicaSet=rs0'
-            restartPolicy: Never
----
-###########################

Ci/scripts/checkhash.sh

@@ -1,20 +0,0 @@
-#!/usr/bin/env bash
-
-chmod +x ./ci/scripts/hashexist.sh
-
-if [[ $CI_COMMIT_BRANCH != "master" ]] && [[ $CI_COMMIT_BRANCH != "release" ]]
-then
-    next_stage="skip"
-    
-    # the first argument is always the job name ($1)
-    for ((i = 2; i <= $#; i++ ))
-    do
-        hash_found=`./ci/scripts/hashexist.sh $1 ${!i}`
-        if [[ $hash_found == *"false"* ]]
-        then
-            next_stage="continue"
-        fi
-    done
-    
-    echo $next_stage
-fi

Ci/scripts/clean_install.sh

@@ -1,29 +0,0 @@
-#!/usr/bin/env bash
-echo "
-This script npm install's the every project
-"
-function clean_install {
-  echo "Installing $1"
-  cd $1
-  rm package-lock.json
-  rm -rf node_modules
-  npm install
-  npm audit fix
-  cd ..
-  echo "Complete $1"
-  echo ""
-}
-
-clean_install dashboard
-clean_install accounts 
-clean_install backend
-clean_install home 
-clean_install StatusPage 
-clean_install ApiReference
-clean_install probe
-clean_install AdminDashboard
-clean_install InitScript
-clean_install licensing
-clean_install HelmChart
-clean_install JavaScriptSDK
-clean_install .

Ci/scripts/cleanup.sh

@@ -1,52 +0,0 @@
-#
-sudo dpkg --configure -a
-echo "Running Cleanup Script..."
-if [[ $(which helm) ]]
-then
-  # Remove oneuptime if helm is installed
-  echo "RUNNING COMMAND: sudo helm uninstall oneuptime || echo 'oneuptime not installed'"
-  sudo helm uninstall oneuptime || echo 'oneuptime not installed'
-fi
-
-if [[ $(which microk8s) ]]
-then
-  # Stop microk8s VM
-  echo "Stopping microk8s..."
-  # Delete microk8s cluster so it can be fresh for next job.
-  echo "Delete microk8s Cluster..."
-  echo "RUNNING COMMAND:  sudo usermod -a -G microk8s $USER"
-  sudo usermod -a -G microk8s $USER || echo "microk8s group not found"
-  echo "RUNNING COMMAND: microk8s.reset || 'microk8s cannot delete'"
-  sudo microk8s.reset || 'microk8s cannot delete'
-  echo "RUNNING COMMAND: microk8s.kubectl delete all --all || 'microk8s.kubectl cannot delete'"
-  sudo microk8s.kubectl delete all --all || 'microk8s.kubectl cannot delete'
-  echo "RUNNING COMMAND: microk8s.stop || 'microk8s cannot Stop'"
-  sudo microk8s.stop || "microk8s cannot Stop"
-  echo "RUNNING COMMAND: sudo snap remove microk8s || 'microk8s cannot be removed.'"
-  sudo snap remove microk8s || 'microk8s cannot be removed.'
-fi
-
-if [[ $(which docker) ]]
-then
-  # Stop all docker containers
-  echo "Stop and Delete all docker containers..."
-  echo "RUNNING COMMAND: sudo docker stop \$(sudo docker ps -aq) || echo 'No docker containers'"
-  sudo docker stop $(sudo docker ps -aq) || echo 'No docker containers'
-  # Remove all docker containers.
-  echo "RUNNING COMMAND: sudo docker rm \$(sudo docker ps -aq) || echo 'No docker containers'"
-  sudo docker rm $(sudo docker ps -aq) || echo 'No docker containers'
-  # Delete all locally built images. (Comment this out to reduce build times)
-  # echo "RUNNING COMMAND: sudo docker rmi -f \$(sudo docker images -q) || echo 'No docker containers'"
-  # sudo docker rmi -f $(sudo docker images -q) || echo 'No docker containers'
-  
-  # Comment line below to reduce build times. 
-  # sudo docker system prune -a --volumes --force
-fi
-
-# fix broken unmet dependencies
-sudo apt --fix-broken install -y -y
-
-# remove any service holding port 80
-sudo apt remove apache2 nginx -y
-sudo apt purge apache2 nginx -y
-sudo apt autoremove -y

Ci/scripts/deployment-cleanup.sh

@@ -1,5 +0,0 @@
-curl -X POST "https://api.cloudflare.com/client/v4/zones/${CF_ZONE}/purge_cache" \
-        -H "X-Auth-Email: ${CF_EMAIL}" \
-        -H "X-Auth-Key: ${CF_API_KEY}" \
-        -H "Content-Type: application/json" \
-        --data '{"purge_everything":true}'

Ci/scripts/deployment-production-setup.sh

@@ -1,10 +0,0 @@
-#!/usr/bin/env bash
-
-echo "Connect machine with to communicate with aws cluster"
-# This command will automatically switch to the oneuptime-production cluster
-
-# AWS command. 
-#sudo aws eks update-kubeconfig --region $AWS_DEFAULT_REGION --name fyipe-production
-
-
-doctl kubernetes cluster kubeconfig save 5c53f2a7-e462-48ab-9c02-3fbe281b2568

Ci/scripts/deployment-setup.sh

@@ -1,40 +0,0 @@
-#!/usr/bin/env bash
-
-# Install Kubectl
-curl -LO "https://storage.googleapis.com/kubernetes-release/release/$(curl -s https://storage.googleapis.com/kubernetes-release/release/stable.txt)/bin/linux/amd64/kubectl"
-sudo install -o root -g root -m 0755 kubectl /usr/local/bin/kubectl
-sudo kubectl version --client
-
-# fix dpkg interruption
-sudo dpkg --configure -a
-
-# fix broken unmet dependencies
-sudo apt --fix-broken install -y -y
-
-# # Install and configure aws cli
-# sudo apt-get install -y unzip
-# curl "https://awscli.amazonaws.com/awscli-exe-linux-x86_64.zip" -o "awscliv2.zip" # download latest aws cli version
-# unzip awscliv2.zip
-# sudo ./aws/install
-# aws --version # confirm installation
-
-# # Remove any already existing ~/.aws, /root/.kube or /root/.config directory
-# sudo rm -rf ~/.aws || echo "Directory already deleted"
-# sudo rm -rf /root/.config || echo "Directory already deleted"
-# sudo rm -rf /root/.kube || echo "Directory already deleted"
-
-# # Configure aws cli
-# sudo aws configure set aws_access_key_id $AWS_ACCESS_KEY_ID
-# sudo aws configure set aws_secret_access_key $AWS_SECRET_ACCESS_KEY
-# sudo aws configure set default.region $AWS_DEFAULT_REGION
-# sudo aws configure set default.output json
-
-
-# Install doctl.
-wget https://github.com/digitalocean/doctl/releases/download/v1.71.0/doctl-1.71.0-linux-amd64.tar.gz
-tar xf doctl-1.71.0-linux-amd64.tar.gz
-sudo mv doctl /usr/local/bin
-
-# Setup access token
-doctl auth init -t $DIGITAL_OCEAN_API_KEY
-

Ci/scripts/deployment-staging-setup.sh

@@ -1,5 +0,0 @@
-#!/usr/bin/env bash
-
-echo "Connect machine with to communicate with aws cluster"
-# This command will automatically switch to the oneuptime-staging cluster
-sudo aws eks update-kubeconfig --region $AWS_DEFAULT_REGION --name fyipe-staging

Ci/scripts/docker-build-all-and-push.sh

@@ -1,54 +0,0 @@
-#!/usr/bin/env bash
-
-echo "
-======== IMPORTANT! =========
-This script will take ~30+ mins to complete.
-- Builds a docker container
-- This script takes a long time to run when you run it for the first time
-- Next subsequent executions would be a lot faster.
-"
-
-if [[ ! $(which docker) && ! $(docker  --version) ]]
-then
-  echo -e "\033[91mPlease install Docker. https://docs.docker.com/install"
-  exit
-fi
-
-if [[ ! $(which git) && ! $(docker --git) ]]
-then
-  echo -e "\033[91mPlease install Git. https://git-scm.com/book/en/v2/Getting-Started-Installing-Git"
-  exit
-fi
-
-DIR=$PWD
-ONEUPTIME_DIR="$DIR/.."
-
-chmod +x ./ci/scripts/docker-build-and-push.sh
-function build {
-  ./ci/scripts/docker-build-and-push.sh $1 $2
-}
-
-# cd ..
-
-build dashboard $1
-build accounts $1 
-build backend $1
-build home $1
-build StatusPage $1
-build ApiReference $1
-build probe $1
-build AdminDashboard $1
-build InitScript $1
-build slack $1
-build licensing $1
-build HelmChart $1
-build LighthouseRunner $1
-build ScriptRunner $1
-build ContainerScanner $1
-build ApplicationScanner $1
-build data-ingestor $1
-build realtime $1
-build haraka $1
-build HttpTestServer $1
-
-cd $DIR

Ci/scripts/docker-build-and-push.sh

@@ -1,6 +0,0 @@
-cd $1
-echo "Building $1"
-sudo docker build -t oneuptime/$1:$2 .
-echo "Pushing $1"
-sudo docker push oneuptime/$1:$2
-cd ..

Ci/scripts/docker-install.sh

@@ -1,19 +0,0 @@
-#Install Docker and setup registry and insecure access to it.
-#IF docker is already installed, do not install docker.
-if [[ ! $(which docker) ]]
-then
-    echo "INSTALLING DOCKER"
-    sudo apt-get update
-    sudo apt-get install \
-    apt-transport-https \
-    ca-certificates \
-    curl \
-    gnupg \
-    lsb-release
-    curl -fsSL https://download.docker.com/linux/ubuntu/gpg | sudo gpg --dearmor -o /usr/share/keyrings/docker-archive-keyring.gpg
-    echo \
-     "deb [arch=amd64 signed-by=/usr/share/keyrings/docker-archive-keyring.gpg] https://download.docker.com/linux/ubuntu \
-     $(lsb_release -cs) stable" | sudo tee /etc/apt/sources.list.d/docker.list > /dev/null
-    sudo apt-get update
-    sudo apt-get install docker-ce docker-ce-cli containerd.io
-fi

Ci/scripts/hashexist.sh

@@ -1,25 +0,0 @@
-#!/usr/bin/env bash
-
-# install jq only when it does not exist
-
-function hashExist {
-    # $1 is the job name
-    # $2 is the project
-    if [[ ! $(which jq) ]]
-    then
-        sudo apt-get install -y jq
-    fi
-    PROJECT_HASH=`find $2 -type f ! -path "*node_modules*" ! -path "*build*" -print0 | sort -z | xargs -0 sha256sum | sha256sum`
-    HASH_VALUE=`echo $PROJECT_HASH$1 | sha256sum | head -c 64`
-    RESPONSE=`curl -H "Content-Type: application/json" -d "{\"structuredQuery\": {\"from\": {\"collectionId\": \"builds\"},\"where\": {\"compositeFilter\": {\"op\": \"AND\",\"filters\": [{\"fieldFilter\": {\"field\": {\"fieldPath\": \"project\"},\"op\": \"EQUAL\",\"value\": {\"stringValue\": '$2'}}},{\"fieldFilter\": {\"field\": {\"fieldPath\": \"hash\"},\"op\": \"EQUAL\",\"value\": {\"stringValue\": '$HASH_VALUE'}}}]}}}}" -X POST "https://firestore.googleapis.com/v1/projects/oneuptime-devops/databases/(default)/documents:runQuery"`
-    # if response contains an array of object with document key, then the hash already exist in db
-    document=`jq '.[0].document' <<< "$RESPONSE"`
-    if [[ $document == null ]]
-    then
-        echo false
-    else
-        echo true
-    fi
-}
-
-hashExist $1 $2

Ci/scripts/hosts-setup.sh

@@ -1,31 +0,0 @@
-sudo sed -i '/accounts/c\' /etc/hosts
-ACCOUNTS_IP=`sudo k describe svc oneuptime-accounts | grep Endpoints | cut -d ":" -f 2`
-echo $ACCOUNTS_IP'      accounts.app.local' | sudo tee -a /etc/hosts
-
-sudo sed -i '/AdminDashboard/c\' /etc/hosts
-ADMIN_DASHBOARD_IP=`sudo k describe svc oneuptime-admin | grep Endpoints | cut -d ":" -f 2`
-echo $ADMIN_DASHBOARD_IP'      admin.app.local' | sudo tee -a /etc/hosts
-
-sudo sed -i '/dashboard/c\' /etc/hosts
-DASHBOARD_IP=`sudo k describe svc oneuptime-dashboard | grep Endpoints | cut -d ":" -f 2`
-echo $DASHBOARD_IP'      dashboard.app.local' | sudo tee -a /etc/hosts
-
-sudo sed -i '/backend/c\' /etc/hosts
-BACKEND_IP=`sudo k describe svc oneuptime-backend | grep Endpoints | cut -d ":" -f 2`
-echo $BACKEND_IP'      backend.app.local' | sudo tee -a /etc/hosts
-
-sudo sed -i '/home/c\' /etc/hosts
-HOME_IP=`sudo k describe svc oneuptime-home | grep Endpoints | cut -d ":" -f 2`
-echo $HOME_IP'      home.app.local' | sudo tee -a /etc/hosts
-
-sudo sed -i '/StatusPage/c\' /etc/hosts
-STATUSPAGE_IP=`sudo k describe svc oneuptime-status | grep Endpoints | cut -d ":" -f 2`
-echo $STATUSPAGE_IP'      status.app.local' | sudo tee -a /etc/hosts
-
-sudo sed -i '/ApiReference/c\' /etc/hosts
-ApiReference_IP=`sudo k describe svc oneuptime-ApiReference | grep Endpoints | cut -d ":" -f 2`
-echo $ApiReference_IP'      ApiReference.app.local' | sudo tee -a /etc/hosts
-
-sudo sed -i '/licensing/c\' /etc/hosts
-LICENSING_IP=`sudo k describe svc oneuptime-licensing | grep Endpoints | cut -d ":" -f 2`
-echo $LICENSING_IP'      licensing.app.local' | sudo tee -a /etc/hosts

Ci/scripts/install-helm.sh

@@ -1,9 +0,0 @@
-echo "Installing helm..."
-
-sudo https://baltocdn.com/helm/signing.asc | sudo apt-key add -
-sudo apt-get install apt-transport-https --yes
-sudo echo "deb https://baltocdn.com/helm/stable/debian/ all main" | sudo tee /etc/apt/sources.list.d/helm-stable-debian.list
-sudo apt-get update
-sudo apt-get install helm
-
-echo "Install helm complete."

Ci/scripts/job-status.sh

@@ -1,2 +0,0 @@
-sudo apt-get install -y jq
-curl -s -S  --header "PRIVATE-TOKEN: $PERSONAL_ACCESS_TOKEN" "https://gitlab.com/api/v4/projects/$CI_PROJECT_ID/pipelines/$CI_PIPELINE_ID/jobs?per_page=50" | jq -c ".[] | select(.name==\"$1\") | .status"

Ci/scripts/production-rollback.sh

@@ -1,53 +0,0 @@
-#!/usr/bin/env bash
-echo "
-This script rollbacks every project if any of the deployment fails
-"
-
-chmod +x ./ci/scripts/job-status.sh
-
-function rollback {
-  export status=`./ci/scripts/job-status.sh production_$1`
-  if [[ $status == \"success\" ]]
-    then
-        echo "Rolling back $1"
-        sudo kubectl rollout undo deployment/$1
-    else
-        echo "Rollback skipped $1"
-  fi
-}
-
-function check {
-  export status=`./ci/scripts/job-status.sh production_$1`
-  if [[ $status == \"failed\" ]]
-    then
-        echo "Deployment unsuccessful for $1, rolling back all new deployments"
-        rollback dashboard
-        rollback accounts 
-        rollback backend
-        rollback home
-        rollback StatusPage 
-        rollback ApiReference
-        rollback probe
-        rollback AdminDashboard
-        rollback licensing
-        rollback HelmChart
-        rollback slack
-        exit 1
-    else
-        echo "$1 Deployment successful"
-  fi
-}
-
-check dashboard
-check accounts 
-check backend
-check home 
-check StatusPage 
-check ApiReference
-check probe-1
-check probe-2
-check AdminDashboard
-check licensing
-check InitScript
-check slack
-check HelmChart

Ci/scripts/setup-cluster.sh

@@ -1,26 +0,0 @@
-# Wait for all the services to come online.
-echo "RUNNING COMMAND: echo 'Wait for 10 mins....'"
-echo 'Wait for 10 mins....'
-echo "RUNNING COMMAND: sleep 10m"
-sleep 10m
-# Get the status of all the kubernetes resources for debugging purposes.
-echo "RUNNING COMMAND: sudo k get pods"
-sudo k get pods
-echo "RUNNING COMMAND: sudo k get services"
-sudo k get services
-echo "RUNNING COMMAND: sudo k get rc"
-sudo k get rc
-echo "RUNNING COMMAND: sudo k get deployments"
-sudo k get deployments
-echo "RUNNING COMMAND: sudo k get statefulset"
-sudo k get statefulset
-echo "RUNNING COMMAND: sudo k get pv"
-sudo k get pv
-echo "RUNNING COMMAND: sudo k get pvc"
-sudo k get pvc
-echo "RUNNING COMMAND: sudo k get storageclass"
-sudo k get storageclass
-echo "RUNNING COMMAND: sudo k cluster-info"
-sudo k cluster-info
-echo "RUNNING COMMAND: sudo k get all --all-namespaces"
-sudo k get all --all-namespaces

Ci/scripts/setup-docker.sh

@@ -1,36 +0,0 @@
-# Cleanup
-echo "RUNNING COMMAND:  chmod +x ./ci/cleanup.sh"
-chmod +x ./ci/scripts/cleanup.sh
-echo "RUNNING COMMAND:  ./ci/cleanup.sh"
-./ci/scripts/cleanup.sh
-
-#Install Docker and setup registry and insecure access to it.
-#IF docker is already installed, do not install docker.
-if [[ ! $(which docker) ]]
-then
-    echo "RUNNING COMMAND: curl -sSL https://get.docker.com/ | sh"
-    curl -sSL https://get.docker.com/ | sh
-    echo "RUNNING COMMAND: sudo touch /etc/docker/daemon.json"
-    sudo touch /etc/docker/daemon.json
-    echo "RUNNING COMMAND:  echo -e  "{\n   "insecure-registries": ["localhost:32000"]\n}" | sudo tee -a /etc/docker/daemon.json >> /dev/null"
-    echo -e  "{\n   "insecure-registries": ["localhost:32000"]\n}" | sudo tee -a /etc/docker/daemon.json >> /dev/null
-    echo "RUNNING COMMAND: sudo systemctl restart docker"
-    sudo systemctl restart docker
-fi
-
-# Install packages.
-echo "RUNNING COMMAND:  sudo apt-get update -y && sudo apt-get install -y bash git sudo nodejs"
-sudo apt-get update -y && sudo apt-get install -y bash git sudo nodejs
-
-# Install additional dependencies for puppeteer.
-echo "RUNNING COMMAND: sudo apt-get install -yq gconf-service libasound2 libatk1.0-0 libc6 libcairo2 libcups2 libdbus-1-3 \
-libexpat1 libfontconfig1 libgcc1 libgconf-2-4 libgdk-pixbuf2.0-0 libglib2.0-0 libgtk-3-0 libnspr4 \
-libpango-1.0-0 libpangocairo-1.0-0 libstdc++6 libx11-6 libx11-xcb1 libxcb1 libxcomposite1 \
-libxcursor1 libxdamage1 libxext6 libxfixes3 libxi6 libxrandr2 libxrender1 libxss1 libxtst6 \
-ca-certificates fonts-liberation libappindicator1 libnss3 lsb-release xdg-utils
-"
-sudo apt-get install -yq gconf-service libasound2 libatk1.0-0 libc6 libcairo2 libcups2 libdbus-1-3 \
-libexpat1 libfontconfig1 libgcc1 libgconf-2-4 libgdk-pixbuf2.0-0 libglib2.0-0 libgtk-3-0 libnspr4 \
-libpango-1.0-0 libpangocairo-1.0-0 libstdc++6 libx11-6 libx11-xcb1 libxcb1 libxcomposite1 \
-libxcursor1 libxdamage1 libxext6 libxfixes3 libxi6 libxrandr2 libxrender1 libxss1 libxtst6 \
-ca-certificates fonts-liberation libappindicator1 libnss3 lsb-release xdg-utils wget

Ci/scripts/setup-machine.sh

@@ -1,19 +0,0 @@
-##############
-# IMPORTANT:
-# This script sets the CI/CD machine up to run a build job. It's usually the first script that runs
-##############
-
-# Cleanup
-echo "RUNNING COMMAND:  chmod +x ./ci/cleanup.sh"
-chmod +x ./ci/scripts/cleanup.sh
-echo "RUNNING COMMAND:  ./ci/cleanup.sh"
-./ci/scripts/cleanup.sh
-
-# Setup Machine.
-echo "RUNNING COMMAND:  chmod +x ./HelmChart/public/install.sh"
-chmod +x ./HelmChart/public/install.sh
-echo "RUNNING COMMAND:  ./HelmChart/public/install.sh"
-./HelmChart/public/install.sh ci-install $1
-
-# For dpkg interruption 
-sudo dpkg --configure -a

Ci/scripts/setup.sh

@@ -1,8 +0,0 @@
-# This will download, build and package docker containers.
-echo "RUNNING COMMAND: chmod +x ./ci/docker-build-all-and-push.sh"
-chmod +x ./ci/scripts/docker-build-all-and-push.sh
-./ci/scripts/docker-build-all-and-push.sh test
-# Setup Kubernetes Cluster
-chmod +x ./ci/scripts/setup-cluster.sh
-echo "RUNNING COMMAND: ./ci/setup-cluster.sh"
-./ci/scripts/setup-cluster.sh

Ci/scripts/staging-rollback.sh

@@ -1,58 +0,0 @@
-#!/usr/bin/env bash
-echo "
-This script rollbacks every project if any of the deployment fails
-"
-
-chmod +x ./ci/scripts/job-status.sh
-
-function rollback {
-  export status=`./ci/scripts/job-status.sh staging_$1`
-  if [[ $status == \"success\" ]]
-    then
-        echo "Rolling back $1"
-        sudo kubectl rollout undo deployment/fi-$1
-        if [[ $1 == \"probe\" ]]
-          then
-          echo "Rolling back probe1"
-          sudo kubectl rollout undo deployment/fi-probe1
-          sudo kubectl rollout undo deployment/fi-probe2
-        fi
-    else
-        echo "Rollback skipped $1"
-  fi
-}
-
-function check {
-  export status=`./ci/scripts/job-status.sh staging_$1`
-  if [[ $status == \"failed\" ]]
-    then
-        echo "Deployment unsuccessful for $1, rolling back all new deployments"
-        rollback dashboard
-        rollback accounts 
-        rollback backend
-        rollback home
-        rollback StatusPage 
-        rollback ApiReference
-        rollback probe
-        rollback AdminDashboard
-        rollback licensing
-        rollback HelmChart
-        rollback slack
-        exit 1
-    else
-        echo "$1 Deployment successful"
-  fi
-}
-
-check dashboard
-check accounts 
-check backend
-check home 
-check StatusPage 
-check ApiReference
-check probe-1
-check probe-2
-check AdminDashboard
-check licensing
-check slack
-check HelmChart

Ci/scripts/storehash.sh

@@ -1,23 +0,0 @@
-#!/usr/bin/env bash
-
-chmod +x ./ci/scripts/hashexist.sh
-
-function storeHash {
-    # $1 -> Job Name; $2 -> Project
-    PROJECT_HASH=`find $2 -type f ! -path "*node_modules*" ! -path "*build*" -print0 | sort -z | xargs -0 sha256sum | sha256sum`
-    HASH_VALUE=`echo $PROJECT_HASH$1 | sha256sum | head -c 64`
-    curl -H "Content-Type: application/json" -d "{\"fields\": {\"project\": {\"stringValue\": '$2'},\"hash\": {\"stringValue\": '$HASH_VALUE'}}}"  -X POST "https://firestore.googleapis.com/v1/projects/oneuptime-devops/databases/(default)/documents/builds"
-}
-
-if [[ $CI_COMMIT_BRANCH != "master" ]] && [[ $CI_COMMIT_BRANCH != "release" ]]
-then
-    # the first argument is always the job name ($1)
-    for ((i = 2; i <= $#; i++ ))
-    do
-        hash_exist=`./ci/scripts/hashexist.sh $1 ${!i}`
-        if [[ $hash_exist == *"false"* ]]
-        then
-            storeHash $1 ${!i}
-        fi
-    done
-fi

Ci/scripts/version-setup.sh

@@ -1,35 +0,0 @@
-#!/usr/bin/env bash
-echo "
-This script changes version of every project
-"
-function version {
-  cd $1
-  npm version "6.0.$CI_PIPELINE_ID"
-  cd ..
-}
-
-curl -sL https://deb.nodesource.com/setup_12.x | sudo -E bash -
-sudo apt-get install -y nodejs
-
-version dashboard
-version accounts 
-version backend
-version home 
-version StatusPage 
-version ApiReference
-version probe
-version AdminDashboard
-version InitScript
-version licensing
-version HelmChart
-version JavaScriptSDK
-version oneuptime-le-store
-version oneuptime-acme-http-01
-version LighthouseRunner
-version ScriptRunner
-version ContainerScanner
-version ApplicationScanner
-version data-ingestor
-version realtime
-version ProbeAPI
-version .

Clickhouse/Docs/ClickhouseOps.md

@@ -0,0 +1,42 @@
+# Some basic commands for Clickhouse
+
+## Show tables in the database
+    
+```sql  
+show tables from oneuptime
+```
+
+## Show table structure
+
+```sql
+DESCRIBE TABLE oneuptime.Span
+```
+
+## Show table data
+
+```sql
+select * from table_name
+```
+
+## Delete table data
+
+```sql
+truncate table_name
+```
+
+## Delete table
+
+```sql
+drop table oneuptime.table_name 
+```
+
+## Insert for nested data
+
+```sql
+INSERT INTO opentelemetry_spans (trace_id, span_id, attributes.key, attributes.value) VALUES 
+('trace1', 'span1', ['key1', 'key2'], ['value1', 'value2']),
+('trace2', 'span2', ['keyA', 'keyB'], ['valueA', 'valueB']);
+```
+
+
+

Common/AnalyticsModels/BaseModel.ts

@@ -0,0 +1,261 @@
+import TableColumnType from '../Types/AnalyticsDatabase/TableColumnType';
+import AnalyticsTableColumn from '../Types/AnalyticsDatabase/TableColumn';
+import BadDataException from '../Types/Exception/BadDataException';
+import AnalyticsTableEngine from '../Types/AnalyticsDatabase/AnalyticsTableEngine';
+import ColumnBillingAccessControl from '../Types/BaseDatabase/ColumnBillingAccessControl';
+import TableBillingAccessControl from '../Types/BaseDatabase/TableBillingAccessControl';
+import { TableAccessControl } from '../Types/BaseDatabase/AccessControl';
+import EnableWorkflowOn from '../Types/BaseDatabase/EnableWorkflowOn';
+import ObjectID from '../Types/ObjectID';
+import CommonModel from './CommonModel';
+
+export default class AnalyticsDataModel extends CommonModel {
+    public constructor(data: {
+        tableName: string;
+        singularName: string;
+        pluralName: string;
+        tableEngine?: AnalyticsTableEngine | undefined;
+        tableColumns: Array<AnalyticsTableColumn>;
+        allowAccessIfSubscriptionIsUnpaid?: boolean | undefined;
+        tableBillingAccessControl?: TableBillingAccessControl | undefined;
+        accessControl?: TableAccessControl | undefined;
+        primaryKeys: Array<string>; // this should be the subset of tableColumns
+        enableWorkflowOn?: EnableWorkflowOn | undefined;
+    }) {
+        super({
+            tableColumns: data.tableColumns,
+        });
+        const columns: Array<AnalyticsTableColumn> = [...data.tableColumns];
+
+        this.tableName = data.tableName;
+
+        if (data.tableEngine) {
+            this.tableEngine = data.tableEngine;
+        }
+
+        columns.push(
+            new AnalyticsTableColumn({
+                key: '_id',
+                title: 'ID',
+                description: 'ID of this object',
+                required: true,
+                type: TableColumnType.ObjectID,
+            })
+        );
+
+        columns.push(
+            new AnalyticsTableColumn({
+                key: 'createdAt',
+                title: 'Created',
+                description: 'Date and Time when the object was created.',
+                required: true,
+                type: TableColumnType.Date,
+            })
+        );
+
+        columns.push(
+            new AnalyticsTableColumn({
+                key: 'updatedAt',
+                title: 'Updated',
+                description: 'Date and Time when the object was updated.',
+                required: true,
+                type: TableColumnType.Date,
+            })
+        );
+
+        if (!data.primaryKeys || data.primaryKeys.length === 0) {
+            throw new BadDataException('Primary keys are required');
+        }
+
+        // check if primary keys are subset of tableColumns
+
+        data.primaryKeys.forEach((primaryKey: string) => {
+            const column: AnalyticsTableColumn | undefined = columns.find(
+                (column: AnalyticsTableColumn) => {
+                    return column.key === primaryKey;
+                }
+            );
+
+            if (!column) {
+                throw new BadDataException(
+                    'Primary key ' + primaryKey + ' is not part of tableColumns'
+                );
+            }
+
+            if (!column.required) {
+                throw new BadDataException(
+                    'Primary key ' +
+                        primaryKey +
+                        ' is not required. Primary keys must be required.'
+                );
+            }
+        });
+
+        this.primaryKeys = data.primaryKeys;
+        this.tableColumns = columns;
+        this.singularName = data.singularName;
+        this.pluralName = data.pluralName;
+        this.tableBillingAccessControl = data.tableBillingAccessControl;
+        this.allowAccessIfSubscriptionIsUnpaid =
+            data.allowAccessIfSubscriptionIsUnpaid || false;
+        this.accessControl = data.accessControl;
+        this.enableWorkflowOn = data.enableWorkflowOn;
+
+        // initialize Arrays.
+        for (const column of this.tableColumns) {
+            if (column.type === TableColumnType.NestedModel) {
+                this.setColumnValue(column.key, []);
+            }
+        }
+    }
+
+    private _enableWorkflowOn: EnableWorkflowOn | undefined;
+    public get enableWorkflowOn(): EnableWorkflowOn | undefined {
+        return this._enableWorkflowOn;
+    }
+    public set enableWorkflowOn(v: EnableWorkflowOn | undefined) {
+        this._enableWorkflowOn = v;
+    }
+
+    private _accessControl: TableAccessControl | undefined;
+    public get accessControl(): TableAccessControl | undefined {
+        return this._accessControl;
+    }
+    public set accessControl(v: TableAccessControl | undefined) {
+        this._accessControl = v;
+    }
+
+    private _tableName: string = '';
+    public get tableName(): string {
+        return this._tableName;
+    }
+    public set tableName(v: string) {
+        this._tableName = v;
+    }
+
+    private _tableEngine: AnalyticsTableEngine = AnalyticsTableEngine.MergeTree;
+    public get tableEngine(): AnalyticsTableEngine {
+        return this._tableEngine;
+    }
+    public set tableEngine(v: AnalyticsTableEngine) {
+        this._tableEngine = v;
+    }
+
+    private _primaryKeys: Array<string> = [];
+    public get primaryKeys(): Array<string> {
+        return this._primaryKeys;
+    }
+    public set primaryKeys(v: Array<string>) {
+        this._primaryKeys = v;
+    }
+
+    private _singularName: string = '';
+    public get singularName(): string {
+        return this._singularName;
+    }
+    public set singularName(v: string) {
+        this._singularName = v;
+    }
+
+    private _pluralName: string = '';
+    public get pluralName(): string {
+        return this._pluralName;
+    }
+    public set pluralName(v: string) {
+        this._pluralName = v;
+    }
+
+    private _tableBillingAccessControl: TableBillingAccessControl | undefined;
+    public get tableBillingAccessControl():
+        | TableBillingAccessControl
+        | undefined {
+        return this._tableBillingAccessControl;
+    }
+    public set tableBillingAccessControl(
+        v: TableBillingAccessControl | undefined
+    ) {
+        this._tableBillingAccessControl = v;
+    }
+
+    private _allowAccessIfSubscriptionIsUnpaid: boolean = false;
+    public get allowAccessIfSubscriptionIsUnpaid(): boolean {
+        return this._allowAccessIfSubscriptionIsUnpaid;
+    }
+    public set allowAccessIfSubscriptionIsUnpaid(v: boolean) {
+        this._allowAccessIfSubscriptionIsUnpaid = v;
+    }
+
+    public getTenantColumn(): AnalyticsTableColumn | null {
+        const column: AnalyticsTableColumn | undefined = this.tableColumns.find(
+            (column: AnalyticsTableColumn) => {
+                return column.isTenantId;
+            }
+        );
+
+        if (!column) {
+            return null;
+        }
+
+        return column;
+    }
+
+    public getRequiredColumns(): Array<AnalyticsTableColumn> {
+        return this.tableColumns.filter((column: AnalyticsTableColumn) => {
+            return column.required;
+        });
+    }
+
+    public isDefaultValueColumn(columnName: string): boolean {
+        const column: AnalyticsTableColumn | null =
+            this.getTableColumn(columnName);
+
+        if (!column) {
+            return false;
+        }
+
+        return column.isDefaultValueColumn;
+    }
+
+    public getColumnBillingAccessControl(
+        columnName: string
+    ): ColumnBillingAccessControl | null {
+        const column: AnalyticsTableColumn | null =
+            this.getTableColumn(columnName);
+
+        if (!column) {
+            return null;
+        }
+
+        return column.billingAccessControl || null;
+    }
+
+    public get id(): ObjectID | undefined {
+        return this.getColumnValue('_id') as ObjectID | undefined;
+    }
+    public set id(v: ObjectID | undefined) {
+        this.setColumnValue('_id', v);
+    }
+
+    public get _id(): ObjectID | undefined {
+        return this.getColumnValue('_id') as ObjectID | undefined;
+    }
+    public set _id(v: ObjectID | undefined) {
+        this.setColumnValue('_id', v);
+    }
+
+    public get createdAt(): Date | undefined {
+        return this.getColumnValue('createdAt') as Date | undefined;
+    }
+
+    public set createdAt(v: Date | undefined) {
+        this.setColumnValue('createdAt', v);
+    }
+
+    public get updatedAt(): Date | undefined {
+        return this.getColumnValue('updatedAt') as Date | undefined;
+    }
+
+    public set updatedAt(v: Date | undefined) {
+        this.setColumnValue('updatedAt', v);
+    }
+}

Common/AnalyticsModels/CommonModel.ts

@@ -0,0 +1,178 @@
+// This model will be extended by BaseModel and Nested Mdoel
+
+import AnalyticsTableColumn from '../Types/AnalyticsDatabase/TableColumn';
+import TableColumnType from '../Types/AnalyticsDatabase/TableColumnType';
+import OneUptimeDate from '../Types/Date';
+import BadDataException from '../Types/Exception/BadDataException';
+import { JSONObject, JSONValue } from '../Types/JSON';
+import ObjectID from '../Types/ObjectID';
+
+export type RecordValue =
+    | ObjectID
+    | string
+    | number
+    | boolean
+    | Date
+    | Array<number>
+    | Array<string>
+    | Array<CommonModel>;
+
+export type Record = Array<RecordValue | Record>;
+
+export default class CommonModel {
+    protected data: JSONObject = {};
+
+    private _tableColumns: Array<AnalyticsTableColumn> = [];
+    public get tableColumns(): Array<AnalyticsTableColumn> {
+        return this._tableColumns;
+    }
+    public set tableColumns(v: Array<AnalyticsTableColumn>) {
+        this._tableColumns = v;
+    }
+
+    public setColumnValue(
+        columnName: string,
+        value: JSONValue | Array<CommonModel>
+    ): void {
+        const column: AnalyticsTableColumn | null =
+            this.getTableColumn(columnName);
+
+        if (column) {
+            if (
+                column.type === TableColumnType.ObjectID &&
+                typeof value === 'string'
+            ) {
+                value = new ObjectID(value);
+            }
+
+            if (
+                column.type === TableColumnType.Date &&
+                typeof value === 'string'
+            ) {
+                value = OneUptimeDate.fromString(value);
+            }
+
+            if (
+                column.type === TableColumnType.JSON &&
+                typeof value === 'string'
+            ) {
+                value = JSON.parse(value);
+            }
+
+            if (
+                column.type === TableColumnType.Number &&
+                typeof value === 'string'
+            ) {
+                value = parseInt(value);
+            }
+
+            // decimal
+            if (
+                column.type === TableColumnType.Decimal &&
+                typeof value === 'string'
+            ) {
+                value = parseFloat(value);
+            }
+
+            return (this.data[columnName] = value as any);
+        }
+        throw new BadDataException('Column ' + columnName + ' does not exist');
+    }
+
+    public constructor(data: { tableColumns: Array<AnalyticsTableColumn> }) {
+        this.tableColumns = data.tableColumns;
+    }
+
+    public getColumnValue<T extends RecordValue>(
+        columnName: string
+    ): T | undefined {
+        if (this.getTableColumn(columnName)) {
+            return this.data[columnName] as T;
+        }
+
+        return undefined;
+    }
+
+    public getTableColumn(name: string): AnalyticsTableColumn | null {
+        const column: AnalyticsTableColumn | undefined = this.tableColumns.find(
+            (column: AnalyticsTableColumn) => {
+                return column.key === name;
+            }
+        );
+
+        if (!column) {
+            return null;
+        }
+
+        return column;
+    }
+
+    public getTableColumns(): Array<AnalyticsTableColumn> {
+        return this.tableColumns;
+    }
+
+    public fromJSON(json: JSONObject): CommonModel {
+        for (const key in json) {
+            this.setColumnValue(key, json[key]);
+        }
+
+        return this;
+    }
+
+    public toJSON(): JSONObject {
+        const json: JSONObject = {};
+
+        this.tableColumns.forEach((column: AnalyticsTableColumn) => {
+            const recordValue: RecordValue | undefined = this.getColumnValue(
+                column.key
+            );
+
+            if (recordValue instanceof CommonModel) {
+                json[column.key] = recordValue.toJSON();
+                return;
+            }
+
+            if (recordValue instanceof Array) {
+                if (
+                    recordValue.length > 0 &&
+                    recordValue[0] instanceof CommonModel
+                ) {
+                    json[column.key] = CommonModel.toJSONArray(
+                        recordValue as Array<CommonModel>
+                    );
+                }
+
+                return;
+            }
+
+            json[column.key] = recordValue;
+        });
+
+        return json;
+    }
+
+    public static fromJSONArray<TBaseModel extends CommonModel>(
+        modelType: { new (): CommonModel },
+        jsonArray: Array<JSONObject>
+    ): Array<TBaseModel> {
+        const models: Array<CommonModel> = [];
+
+        jsonArray.forEach((json: JSONObject) => {
+            const model: CommonModel = new modelType();
+            model.fromJSON(json);
+            models.push(model);
+        });
+
+        return models as Array<TBaseModel>;
+    }
+
+    public static toJSONArray(models: Array<CommonModel>): Array<JSONObject> {
+        const json: Array<JSONObject> = [];
+
+        models.forEach((model: CommonModel) => {
+            json.push(model.toJSON());
+        });
+
+        return json;
+    }
+}

Common/AnalyticsModels/NestedModel.ts

@@ -0,0 +1,8 @@
+import AnalyticsTableColumn from '../Types/AnalyticsDatabase/TableColumn';
+import CommonModel from './CommonModel';
+
+export default class NestedModel extends CommonModel {
+    public constructor(data: { tableColumns: Array<AnalyticsTableColumn> }) {
+        super(data);
+    }
+}

Common/Models/AnalyticsBaseModel.ts

@@ -1,104 +0,0 @@
-import TableColumnType from '../Types/BaseDatabase/TableColumnType';
-import AnalyticsTableColumn from '../Types/AnalyticsDatabase/TableColumn';
-import BadDataException from '../Types/Exception/BadDataException';
-import AnalyticsTableEngine from '../Types/AnalyticsDatabase/AnalyticsTableEngine';
-
-export default class AnalyticsDataModel {
-    private _tableColumns: Array<AnalyticsTableColumn> = [];
-    public get tableColumns(): Array<AnalyticsTableColumn> {
-        return this._tableColumns;
-    }
-    public set tableColumns(v: Array<AnalyticsTableColumn>) {
-        this._tableColumns = v;
-    }
-
-    private _tableName: string = '';
-    public get tableName(): string {
-        return this._tableName;
-    }
-    public set tableName(v: string) {
-        this._tableName = v;
-    }
-
-    private _tableEngine: AnalyticsTableEngine = AnalyticsTableEngine.MergeTree;
-    public get tableEngine(): AnalyticsTableEngine {
-        return this._tableEngine;
-    }
-    public set tableEngine(v: AnalyticsTableEngine) {
-        this._tableEngine = v;
-    }
-
-    private _primaryKeys: Array<string> = [];
-    public get primaryKeys(): Array<string> {
-        return this._primaryKeys;
-    }
-    public set primaryKeys(v: Array<string>) {
-        this._primaryKeys = v;
-    }
-
-    public constructor(data: {
-        tableName: string;
-        tableEngine?: AnalyticsTableEngine | undefined;
-        tableColumns: Array<AnalyticsTableColumn>;
-        primaryKeys: Array<string>; // this should be the subset of tableColumns
-    }) {
-        const columns: Array<AnalyticsTableColumn> = [...data.tableColumns];
-
-        this.tableName = data.tableName;
-
-        if (data.tableEngine) {
-            this.tableEngine = data.tableEngine;
-        }
-
-        columns.push(
-            new AnalyticsTableColumn({
-                key: '_id',
-                title: 'ID',
-                description: 'ID of this object',
-                required: true,
-                type: TableColumnType.ObjectID,
-            })
-        );
-
-        columns.push(
-            new AnalyticsTableColumn({
-                key: 'createdAt',
-                title: 'Created',
-                description: 'Date and Time when the object was created.',
-                required: true,
-                type: TableColumnType.Date,
-            })
-        );
-
-        columns.push(
-            new AnalyticsTableColumn({
-                key: 'updatedAt',
-                title: 'Updated',
-                description: 'Date and Time when the object was updated.',
-                required: true,
-                type: TableColumnType.Date,
-            })
-        );
-
-        if (!data.primaryKeys || data.primaryKeys.length === 0) {
-            throw new BadDataException('Primary keys are required');
-        }
-
-        // check if primary keys are subset of tableColumns
-
-        data.primaryKeys.forEach((primaryKey: string) => {
-            if (
-                !columns.find((column: AnalyticsTableColumn) => {
-                    return column.key === primaryKey;
-                })
-            ) {
-                throw new BadDataException(
-                    'Primary key ' + primaryKey + ' is not part of tableColumns'
-                );
-            }
-        });
-
-        this.primaryKeys = data.primaryKeys;
-        this.tableColumns = columns;
-    }
-}

Common/Models/BaseModel.ts

@@ -21,24 +21,22 @@ import Email from '../Types/Email';
 import Phone from '../Types/Phone';
 import PositiveNumber from '../Types/PositiveNumber';
 import Route from '../Types/API/Route';
-import TableColumnType from '../Types/BaseDatabase/TableColumnType';
+import TableColumnType from '../Types/Database/TableColumnType';
 import Permission, {
     instanceOfUserTenantAccessPermission,
     PermissionHelper,
     UserPermission,
     UserTenantAccessPermission,
 } from '../Types/Permission';
-import {
-    ColumnAccessControl,
-    ColumnBillingAccessControl,
-} from '../Types/Database/AccessControl/AccessControl';
+import { ColumnAccessControl } from '../Types/BaseDatabase/AccessControl';
 import { getColumnAccessControlForAllColumns } from '../Types/Database/AccessControl/ColumnAccessControl';
 import BadDataException from '../Types/Exception/BadDataException';
 import { PlanSelect } from '../Types/Billing/SubscriptionPlan';
-import { EnableWorkflowOn } from '../Types/Model/EnableWorkflow';
+import EnableWorkflowOn from '../Types/BaseDatabase/EnableWorkflowOn';
 import IconProp from '../Types/Icon/IconProp';
 import Text from '../Types/Text';
 import { getColumnBillingAccessControlForAllColumns } from '../Types/Database/AccessControl/ColumnBillingAccessControl';
+import ColumnBillingAccessControl from '../Types/BaseDatabase/ColumnBillingAccessControl';
 
 export type DbTypes =
     | string
@@ -255,6 +253,10 @@ export default class BaseModel extends BaseEntity {
         (this as any)[columnName] = value;
     }
 
+    public removeValue(columnName: string): void {
+        (this as any)[columnName] = undefined;
+    }
+
     public doesPermissionHaveConditions(
         permission: Permission
     ): JSONObject | null {

Common/Models/FileModel.ts

@@ -4,7 +4,7 @@ import ColumnLength from '../Types/Database/ColumnLength';
 import ColumnType from '../Types/Database/ColumnType';
 import SlugifyColumn from '../Types/Database/SlugifyColumn';
 import TableColumn from '../Types/Database/TableColumn';
-import TableColumnType from '../Types/BaseDatabase/TableColumnType';
+import TableColumnType from '../Types/Database/TableColumnType';
 import MimeType from '../Types/File/MimeType';
 import ObjectID from '../Types/ObjectID';
 import Permission from '../Types/Permission';

Common/ServiceRoute.ts

@@ -18,8 +18,6 @@ export const IntegrationRoute: Route = new Route('/integration');
 
 export const NotificationRoute: Route = new Route('/notification');
 
-export const HelmRoute: Route = new Route('/helm-chart');
-
 export const AccountsRoute: Route = new Route('/accounts');
 
 export const WorkflowRoute: Route = new Route('/workflow');
@@ -28,4 +26,4 @@ export const ApiReferenceRoute: Route = new Route('/reference');
 
 export const AdminDashboardRoute: Route = new Route('/admin');
 
-export const ProbeApiRoute: Route = new Route('/probe-api');
+export const IngestorRoute: Route = new Route('/ingestor');

Common/Tests/Types/API/HTTPErrorResponse.test.ts

@@ -0,0 +1,61 @@
+import HTTPErrorResponse from '../../../Types/API/HTTPErrorResponse';
+
+describe('HTTPErrorResponse', () => {
+    it('should return an empty string when data is null', () => {
+        const httpResponse: HTTPErrorResponse = new HTTPErrorResponse(
+            404,
+            { data: null },
+            {}
+        );
+        expect(httpResponse.message).toBe('');
+    });
+
+    it('should return the message from the "data" property if present', () => {
+        const httpResponse: HTTPErrorResponse = new HTTPErrorResponse(
+            200,
+            { data: 'Data message' },
+            {}
+        );
+        expect(httpResponse.message).toBe('Data message');
+    });
+
+    it('should return the message from the "message" property if present', () => {
+        const httpResponse: HTTPErrorResponse = new HTTPErrorResponse(
+            200,
+            { message: 'Message message' },
+            {}
+        );
+        expect(httpResponse.message).toBe('Message message');
+    });
+
+    it('should return the message from the "error" property if no other message properties are present', () => {
+        const httpResponse: HTTPErrorResponse = new HTTPErrorResponse(
+            500,
+            { error: 'Error message' },
+            {}
+        );
+        expect(httpResponse.message).toBe('Error message');
+    });
+
+    it('should return an empty string when no relevant message properties are present', () => {
+        const httpResponse: HTTPErrorResponse = new HTTPErrorResponse(
+            204,
+            { otherProperty: 'Other message' },
+            {}
+        );
+        expect(httpResponse.message).toBe('');
+    });
+
+    it('should prioritize "data" > "message" > "error" when multiple message properties are present', () => {
+        const httpResponse: HTTPErrorResponse = new HTTPErrorResponse(
+            201,
+            {
+                data: 'Data message',
+                message: 'Message message',
+                error: 'Error message',
+            },
+            {}
+        );
+        expect(httpResponse.message).toBe('Data message');
+    });
+});

Common/Tests/Types/Database/Date.test.ts

@@ -0,0 +1,82 @@
+import DatabaseDate from '../../../Types/Database/Date';
+import moment from 'moment';
+import InBetween from '../../../Types/Database/InBetween';
+import { JSONObject } from '../../../Types/JSON';
+
+describe('DatabaseDate', () => {
+    describe('asDateStartOfTheDayEndOfTheDayForDatabaseQuery', () => {
+        it('should return InBetween object for a valid Date input', () => {
+            const inputDate: Date = new Date('2023-10-24T12:00:00Z');
+            const result: JSONObject =
+                DatabaseDate.asDateStartOfTheDayEndOfTheDayForDatabaseQuery(
+                    inputDate
+                ).toJSON();
+
+            const expectedStart: string = moment(inputDate)
+                .startOf('day')
+                .format('YYYY-MM-DD HH:mm:ss');
+            const expectedEnd: string = moment(inputDate)
+                .endOf('day')
+                .format('YYYY-MM-DD HH:mm:ss');
+            expect(result).toEqual({
+                startValue: expectedStart,
+                endValue: expectedEnd,
+                _type: 'InBetween',
+            });
+        });
+
+        it('should return InBetween object for a valid Date string input', () => {
+            const inputDate: string = '2023-10-24T12:00:00Z';
+            const result: JSONObject =
+                DatabaseDate.asDateStartOfTheDayEndOfTheDayForDatabaseQuery(
+                    inputDate
+                ).toJSON();
+            const expectedStart: string = moment(inputDate)
+                .startOf('day')
+                .format('YYYY-MM-DD HH:mm:ss');
+            const expectedEnd: string = moment(inputDate)
+                .endOf('day')
+                .format('YYYY-MM-DD HH:mm:ss');
+            expect(result).toEqual({
+                startValue: expectedStart,
+                endValue: expectedEnd,
+                _type: 'InBetween',
+            });
+        });
+
+        it('should handle invalid date string gracefully', () => {
+            const inputDate: string = 'invalid-date';
+            const result: JSONObject =
+                DatabaseDate.asDateStartOfTheDayEndOfTheDayForDatabaseQuery(
+                    inputDate
+                ).toJSON();
+            expect(result).toEqual({
+                startValue: 'Invalid date',
+                endValue: 'Invalid date',
+                _type: 'InBetween',
+            });
+        });
+
+        it('should handle empty string input gracefully', () => {
+            const inputDate: string = '';
+            const result: JSONObject =
+                DatabaseDate.asDateStartOfTheDayEndOfTheDayForDatabaseQuery(
+                    inputDate
+                ).toJSON();
+            expect(result).toEqual({
+                startValue: 'Invalid date',
+                endValue: 'Invalid date',
+                _type: 'InBetween',
+            });
+        });
+
+        it('should be a type of InBetween', () => {
+            const inputDate: string = '2023-10-24T12:00:00Z';
+            const result: InBetween =
+                DatabaseDate.asDateStartOfTheDayEndOfTheDayForDatabaseQuery(
+                    inputDate
+                );
+            expect(result).toBeInstanceOf(InBetween);
+        });
+    });
+});

Common/Tests/Types/Database/EqualToOrNull.test.ts

@@ -0,0 +1,70 @@
+import EqualToOrNull from '../../../Types/Database/EqualToOrNull';
+import BadDataException from '../../../Types/Exception/BadDataException';
+import { JSONObject } from '../../../Types/JSON';
+
+describe('EqualToOrNull', () => {
+    it('should create an EqualToOrNull object with a valid value', () => {
+        const value: string = 'oneuptime';
+        const equalObj: EqualToOrNull = new EqualToOrNull(value);
+        expect(equalObj.value).toBe(value);
+    });
+
+    it('should get the value property of an EqualToOrNull object', () => {
+        const value: string = 'oneuptime';
+        const equalObj: EqualToOrNull = new EqualToOrNull(value);
+        expect(equalObj.value).toBe(value);
+    });
+
+    it('should set the value property of an EqualToOrNull object', () => {
+        const equalObj: EqualToOrNull = new EqualToOrNull('oldValue');
+        equalObj.value = 'newValue';
+        expect(equalObj.value).toBe('newValue');
+    });
+
+    it('should return the correct string representation using toString method', () => {
+        const equalObj: EqualToOrNull = new EqualToOrNull('oneuptime');
+        expect(equalObj.toString()).toBe('oneuptime');
+    });
+
+    it('should generate the correct JSON representation using toJSON method', () => {
+        const equalObj: EqualToOrNull = new EqualToOrNull('oneuptime');
+        const expectedJSON: JSONObject = {
+            _type: 'EqualToOrNull',
+            value: 'oneuptime',
+        };
+        expect(equalObj.toJSON()).toEqual(expectedJSON);
+    });
+
+    it('should create an EqualToOrNull object from valid JSON input', () => {
+        const jsonInput: JSONObject = {
+            _type: 'EqualToOrNull',
+            value: 'oneuptime',
+        };
+        const equalObj: EqualToOrNull = EqualToOrNull.fromJSON(jsonInput);
+        expect(equalObj.value).toBe('oneuptime');
+    });
+
+    it('should throw a BadDataException when using invalid JSON input', () => {
+        const jsonInput: JSONObject = {
+            _type: 'InvalidType',
+            value: 'oneuptime',
+        };
+        expect(() => {
+            return EqualToOrNull.fromJSON(jsonInput);
+        }).toThrow(BadDataException);
+    });
+
+    it('should be a type of EqualToOrNull', () => {
+        const equalObj: EqualToOrNull = new EqualToOrNull('oneuptime');
+        expect(equalObj).toBeInstanceOf(EqualToOrNull);
+    });
+
+    it('should handle null value when using fromJSON method', () => {
+        const jsonInput: JSONObject = {
+            _type: 'EqualToOrNull',
+            value: null,
+        };
+        const equalObj: EqualToOrNull = EqualToOrNull.fromJSON(jsonInput);
+        expect(equalObj.value).toBeNull();
+    });
+});

Common/Tests/Types/Database/InBetween.test.ts

@@ -0,0 +1,80 @@
+import InBetween from '../../../Types/Database/InBetween';
+import BadDataException from '../../../Types/Exception/BadDataException';
+import { JSONObject } from '../../../Types/JSON';
+
+describe('InBetween', () => {
+    it('should create an InBetween object with valid start and end values', () => {
+        const startValue: number = 10;
+        const endValue: number = 20;
+        const betweenObj: InBetween = new InBetween(startValue, endValue);
+        expect(betweenObj.startValue).toBe(10);
+        expect(betweenObj.endValue).toBe(20);
+    });
+
+    it('should generate the correct JSON representation using toJSON method', () => {
+        const startValue: number = 10;
+        const endValue: number = 20;
+        const betweenObj: InBetween = new InBetween(startValue, endValue);
+        const expectedJSON: JSONObject = {
+            _type: 'InBetween',
+            startValue: 10,
+            endValue: 20,
+        };
+        expect(betweenObj.toJSON()).toEqual(expectedJSON);
+    });
+
+    it('should create an InBetween object from valid JSON input', () => {
+        const jsonInput: JSONObject = {
+            _type: 'InBetween',
+            startValue: 10,
+            endValue: 20,
+        };
+        const betweenObj: InBetween = InBetween.fromJSON(jsonInput);
+        expect(betweenObj.startValue).toBe(10);
+        expect(betweenObj.endValue).toBe(20);
+    });
+
+    it('should throw a BadDataException when using invalid JSON input', () => {
+        const jsonInput: JSONObject = {
+            _type: 'InvalidType',
+            startValue: 10,
+            endValue: 20,
+        };
+        expect(() => {
+            return InBetween.fromJSON(jsonInput);
+        }).toThrow(BadDataException);
+    });
+
+    it('should return a string with start and end values matching', () => {
+        const startValue: number = 15;
+        const endValue: number = 15;
+        const betweenObj: InBetween = new InBetween(startValue, endValue);
+        expect(betweenObj.toString()).toBe('15');
+    });
+
+    it('should return a string with start and end values different', () => {
+        const startValue: number = 10;
+        const endValue: number = 20;
+        const betweenObj: InBetween = new InBetween(startValue, endValue);
+        expect(betweenObj.toString()).toBe('10 - 20');
+    });
+
+    it('should return the start value as a string', () => {
+        const startValue: number = 10;
+        const endValue: number = 20;
+        const betweenObj: InBetween = new InBetween(startValue, endValue);
+        expect(betweenObj.toStartValueString()).toBe('10');
+    });
+
+    it('should return the end value as a string', () => {
+        const startValue: number = 10;
+        const endValue: number = 20;
+        const betweenObj: InBetween = new InBetween(startValue, endValue);
+        expect(betweenObj.toEndValueString()).toBe('20');
+    });
+
+    it('should be a type of InBetween', () => {
+        const inBetweenObj: InBetween = new InBetween(10, 15);
+        expect(inBetweenObj).toBeInstanceOf(InBetween);
+    });
+});

Common/Tests/Types/JSONFunctions.test.ts

@@ -0,0 +1,52 @@
+import BaseModel from '../../Models/BaseModel';
+import { JSONObject } from '../../Types/JSON';
+import JSONFunctions from '../../Types/JSONFunctions';
+
+describe('JSONFunctions Class', () => {
+    let baseModel: BaseModel;
+
+    beforeEach(() => {
+        baseModel = new BaseModel();
+    });
+
+    describe('isEmptyObject Method', () => {
+        test('Returns true for an empty object', () => {
+            const emptyObj: JSONObject = {};
+            expect(JSONFunctions.isEmptyObject(emptyObj)).toBe(true);
+        });
+
+        test('Returns false for a non-empty object', () => {
+            const nonEmptyObj: JSONObject = { key: 'value' };
+            expect(JSONFunctions.isEmptyObject(nonEmptyObj)).toBe(false);
+        });
+
+        test('Returns true for null or undefined', () => {
+            expect(JSONFunctions.isEmptyObject(null)).toBe(true);
+            expect(JSONFunctions.isEmptyObject(undefined)).toBe(true);
+        });
+    });
+
+    describe('toJSON and fromJSON Methods', () => {
+        test('toJSON returns a valid JSON object', () => {
+            const json: JSONObject = JSONFunctions.toJSON(baseModel, BaseModel);
+            expect(json).toEqual(expect.objectContaining({}));
+        });
+
+        test('toJSONObject returns a valid JSON object', () => {
+            const json: JSONObject = JSONFunctions.toJSONObject(
+                baseModel,
+                BaseModel
+            );
+            expect(json).toEqual(expect.objectContaining({}));
+        });
+
+        test('fromJSON returns a BaseModel instance', () => {
+            const json: JSONObject = { name: 'oneuptime' };
+            const result: BaseModel | BaseModel[] = JSONFunctions.fromJSON(
+                json,
+                BaseModel
+            );
+            expect(result).toBeInstanceOf(BaseModel);
+        });
+    });
+});

Common/Tests/Types/SerializableObject.test.ts

@@ -0,0 +1,44 @@
+import NotImplementedException from '../../Types/Exception/NotImplementedException';
+import { JSONObject } from '../../Types/JSON';
+import SerializableObject from '../../Types/SerializableObject';
+
+describe('SerializableObject Class', () => {
+    let serializableObject: SerializableObject;
+
+    beforeEach(() => {
+        serializableObject = new SerializableObject();
+    });
+
+    test('Constructor initializes an instance of SerializableObject', () => {
+        expect(serializableObject).toBeInstanceOf(SerializableObject);
+    });
+
+    describe('toJSON Method', () => {
+        test('Throws NotImplementedException when called', () => {
+            expect(() => {
+                return serializableObject.toJSON();
+            }).toThrow(NotImplementedException);
+        });
+    });
+
+    describe('fromJSON Method', () => {
+        test('Throws NotImplementedException when called', () => {
+            expect(() => {
+                return SerializableObject.fromJSON({});
+            }).toThrow(NotImplementedException);
+        });
+    });
+
+    describe('fromJSON Instance Method', () => {
+        test('Returns the result from the static fromJSON method', () => {
+            const json: JSONObject = { key: 'value' };
+            const expectedResult: SerializableObject = new SerializableObject();
+            jest.spyOn(SerializableObject, 'fromJSON').mockReturnValue(
+                expectedResult
+            );
+            const result: SerializableObject =
+                serializableObject.fromJSON(json);
+            expect(result).toBe(expectedResult);
+        });
+    });
+});

Common/Tests/Utils/API.test.ts

@@ -349,6 +349,10 @@ const httpMethodTests: Array<HTTPMethodType> = [
         name: 'delete',
         method: HTTPMethod.DELETE,
     },
+    {
+        name: 'head',
+        method: HTTPMethod.HEAD,
+    },
 ];
 
 describe.each(httpMethodTests)('$name', ({ name, method }: HTTPMethodType) => {

Common/Tests/Utils/Analytics.test.ts

@@ -0,0 +1,85 @@
+import Analytics from '../../Utils/Analytics';
+import Email from '../../Types/Email';
+import { JSONObject } from '../../Types/JSON';
+import posthog from 'posthog-js';
+
+jest.mock('posthog-js', () => {
+    return {
+        init: jest.fn(),
+        identify: jest.fn(),
+        reset: jest.fn(),
+        capture: jest.fn(),
+    };
+});
+
+const apiHost: string = 'https://example.com';
+const apiKey: string = 'your-api-key';
+
+describe('Analytics Class', () => {
+    afterEach(() => {
+        jest.clearAllMocks();
+    });
+
+    it('should initialize the Analytics class', () => {
+        const analytics: Analytics = new Analytics(apiHost, apiKey);
+
+        expect(posthog.init).toHaveBeenCalledWith(apiKey, {
+            api_host: apiHost,
+            autocapture: false,
+        });
+        expect(analytics.isInitialized).toBe(true);
+    });
+
+    it('should not initialize if apiHost and apiKey are not provided', () => {
+        const analytics: Analytics = new Analytics('', '');
+
+        expect(posthog.init).not.toHaveBeenCalled();
+        expect(analytics.isInitialized).toBe(false);
+    });
+
+    it('should authenticate a user', () => {
+        const analytics: Analytics = new Analytics(apiHost, apiKey);
+        const email: Email = new Email('test@example.com');
+
+        analytics.userAuth(email);
+        expect(posthog.identify).toHaveBeenCalledWith(email.toString());
+    });
+
+    it('should not authenticate a user if not initialized', () => {
+        const analytics: Analytics = new Analytics('', '');
+        const email: Email = new Email('test@example.com');
+
+        analytics.userAuth(email);
+        expect(posthog.identify).not.toHaveBeenCalled();
+    });
+
+    it('should reset the user session on logout', () => {
+        const analytics: Analytics = new Analytics(apiHost, apiKey);
+
+        analytics.logout();
+        expect(posthog.reset).toHaveBeenCalled();
+    });
+
+    it('should not reset the user session if not initialized', () => {
+        const analytics: Analytics = new Analytics('', '');
+
+        analytics.logout();
+        expect(posthog.reset).not.toHaveBeenCalled();
+    });
+
+    it('should capture an event with optional data', () => {
+        const analytics: Analytics = new Analytics(apiHost, apiKey);
+        const eventName: string = 'testEvent';
+        const data: JSONObject = { key: 'value' };
+
+        analytics.capture(eventName, data);
+        expect(posthog.capture).toHaveBeenCalledWith(eventName, data);
+    });
+
+    it('should not capture an event if not initialized', () => {
+        const analytics: Analytics = new Analytics('', '');
+
+        analytics.capture('testEvent');
+        expect(posthog.capture).not.toHaveBeenCalled();
+    });
+});

Common/Tests/Utils/CronTime.test.ts

@@ -0,0 +1,34 @@
+import {
+    EVERY_MINUTE,
+    EVERY_DAY,
+    EVERY_HOUR,
+    EVERY_FIVE_MINUTE,
+    EVERY_FIVE_SECONDS,
+    EVERY_WEEK,
+} from '../../Utils/CronTime';
+
+describe('CronTime', () => {
+    test('should return every minute', () => {
+        expect(EVERY_MINUTE).toEqual('* * * * *');
+    });
+
+    test('should return every day', () => {
+        expect(EVERY_DAY).toEqual('0 8 * * *');
+    });
+
+    test('should return every hour', () => {
+        expect(EVERY_HOUR).toEqual('1 * * * *');
+    });
+
+    test('should return every five minute', () => {
+        expect(EVERY_FIVE_MINUTE).toEqual('*/5 * * * *');
+    });
+
+    test('should return every five seconds', () => {
+        expect(EVERY_FIVE_SECONDS).toEqual('*/5 * * * * *');
+    });
+
+    test('should return every week', () => {
+        expect(EVERY_WEEK).toEqual('0 0 * * 0');
+    });
+});

Common/Tests/Utils/Faker.test.ts

@@ -0,0 +1,38 @@
+import Faker from '../../Utils/Faker';
+import Email from '../../Types/Email';
+import Name from '../../Types/Name';
+import Phone from '../../Types/Phone';
+
+describe('Faker Class', () => {
+    it('should generate a random name with alphanumeric characters', () => {
+        expect(Faker.generateName()).toMatch(/^[a-zA-Z0-9]{10}$/);
+    });
+
+    it('should generate a random company name', () => {
+        expect(Faker.generateCompanyName()).toBeTruthy();
+    });
+
+    it('should generate a string of random numbers of specified length', () => {
+        expect(Faker.randomNumbers(8)).toMatch(/^\d{8}$/);
+    });
+
+    it('should generate a user full name', () => {
+        const userFullName: Name = Faker.generateUserFullName();
+        expect(userFullName).toHaveProperty('name');
+        expect(userFullName.name).toBeTruthy();
+    });
+
+    it('should generate a valid email address', () => {
+        const email: Email = Faker.generateEmail();
+        expect(email.email).toMatch(
+            /^[A-Z0-9._%+-]+@[A-Z0-9.-]+\.[A-Z]{2,9}$/i
+        );
+    });
+
+    it('should generate a valid phone number', () => {
+        const phone: Phone = Faker.generatePhone();
+        expect(phone.phone).toMatch(
+            /^[+]?[(]?[0-9]{3}[)]?[-\s.]?[0-9]{3}[-\s.]?[0-9]{4,7}$/
+        );
+    });
+});

Common/Tests/Utils/Slug.test.ts

@@ -1,9 +1,12 @@
 import Slug from '../../Utils/Slug';
 describe('Slug.getSlug()', () => {
-    test('should  return empty string, if name is empty ', () => {
+    test('should return empty string, if name is empty ', () => {
         expect(Slug.getSlug('')).toEqual('');
         expect(Slug.getSlug('     ')).toEqual('');
     });
+    test('should generate a slug from a valid name when name is null', () => {
+        expect(Slug.getSlug(null)).toMatch(/^[a-z0-9-]+$/);
+    });
     test('should replaces spaces in nonEmpty with hyphen -', () => {
         expect(Slug.getSlug('this is slug')).toMatch(/this-is-slug/g);
     });

Common/Types/API/Hostname.ts

@@ -20,6 +20,8 @@ export default class Hostname extends DatabaseProperty {
     }
 
     public set hostname(value: string) {
+        value = value.trim();
+
         if (Hostname.isValid(value)) {
             this._route = value;
         } else {

Common/Types/API/URL.ts

@@ -209,7 +209,15 @@ export default class URL extends DatabaseProperty {
         return this;
     }
 
-    public addQueryParam(paramName: string, value: string): URL {
+    public addQueryParam(
+        paramName: string,
+        value: string,
+        encode?: boolean | undefined
+    ): URL {
+        if (encode) {
+            value = encodeURIComponent(value);
+        }
+
         this.params[paramName] = value;
         return this;
     }

Common/Types/AnalyticsDatabase/TableColumn.ts

@@ -1,7 +1,12 @@
-import TableColumnType from '../BaseDatabase/TableColumnType';
+import { ColumnAccessControl } from '../BaseDatabase/AccessControl';
+import ColumnBillingAccessControl from '../BaseDatabase/ColumnBillingAccessControl';
+import TableColumnType from '../AnalyticsDatabase/TableColumnType';
+import { JSONValue } from '../JSON';
+import NestedModel from '../../AnalyticsModels/NestedModel';
 
 export default class AnalyticsTableColumn {
     private _key: string = 'id';
+
     public get key(): string {
         return this._key;
     }
@@ -33,7 +38,15 @@ export default class AnalyticsTableColumn {
         this._required = v;
     }
 
-    private _type: TableColumnType = TableColumnType.ShortText;
+    private _isTenantId: boolean = false;
+    public get isTenantId(): boolean {
+        return this._isTenantId;
+    }
+    public set isTenantId(v: boolean) {
+        this._isTenantId = v;
+    }
+
+    private _type: TableColumnType = TableColumnType.Text;
     public get type(): TableColumnType {
         return this._type;
     }
@@ -41,17 +54,96 @@ export default class AnalyticsTableColumn {
         this._type = v;
     }
 
+    private _forceGetDefaultValueOnCreate?:
+        | (() => Date | string | number | boolean)
+        | undefined;
+    public get forceGetDefaultValueOnCreate():
+        | (() => Date | string | number | boolean)
+        | undefined {
+        return this._forceGetDefaultValueOnCreate;
+    }
+    public set forceGetDefaultValueOnCreate(
+        v: (() => Date | string | number | boolean) | undefined
+    ) {
+        this._forceGetDefaultValueOnCreate = v;
+    }
+
+    private _defaultValue: JSONValue | undefined;
+    public get defaultValue(): JSONValue {
+        return this._defaultValue;
+    }
+    public set defaultValue(v: JSONValue) {
+        this._defaultValue = v;
+    }
+
+    public get isDefaultValueColumn(): boolean {
+        return Boolean(this.defaultValue !== undefined);
+    }
+
+    private _billingAccessControl?: ColumnBillingAccessControl | undefined;
+    public get billingAccessControl(): ColumnBillingAccessControl | undefined {
+        return this._billingAccessControl;
+    }
+    public set billingAccessControl(v: ColumnBillingAccessControl | undefined) {
+        this._billingAccessControl = v;
+    }
+
+    private _allowAccessIfSubscriptionIsUnpaid: boolean = false;
+    public get allowAccessIfSubscriptionIsUnpaid(): boolean {
+        return this._allowAccessIfSubscriptionIsUnpaid;
+    }
+    public set allowAccessIfSubscriptionIsUnpaid(v: boolean) {
+        this._allowAccessIfSubscriptionIsUnpaid = v;
+    }
+
+    private _accessControl: ColumnAccessControl | undefined;
+    public get accessControl(): ColumnAccessControl | undefined {
+        return this._accessControl;
+    }
+    public set accessControl(v: ColumnAccessControl | undefined) {
+        this._accessControl = v;
+    }
+
+    private _nestedModel?: NestedModel | undefined;
+    public get nestedModel(): NestedModel | undefined {
+        return this._nestedModel;
+    }
+    public set nestedModel(v: NestedModel | undefined) {
+        this._nestedModel = v;
+    }
+
     public constructor(data: {
         key: string;
+        nestedModel?: NestedModel | undefined;
         title: string;
         description: string;
         required: boolean;
+        defaultValue?: JSONValue | undefined;
         type: TableColumnType;
+        billingAccessControl?: ColumnBillingAccessControl | undefined;
+        isTenantId?: boolean | undefined;
+        accessControl?: ColumnAccessControl | undefined;
+        allowAccessIfSubscriptionIsUnpaid?: boolean | undefined;
+        forceGetDefaultValueOnCreate?:
+            | (() => Date | string | number | boolean)
+            | undefined;
     }) {
+        if (data.type === TableColumnType.NestedModel && !data.nestedModel) {
+            throw new Error('NestedModel is required when type is NestedModel');
+        }
+
+        this.accessControl = data.accessControl;
         this.key = data.key;
         this.title = data.title;
         this.description = data.description;
         this.required = data.required;
         this.type = data.type;
+        this.isTenantId = data.isTenantId || false;
+        this.forceGetDefaultValueOnCreate = data.forceGetDefaultValueOnCreate;
+        this.defaultValue = data.defaultValue;
+        this.billingAccessControl = data.billingAccessControl;
+        this.allowAccessIfSubscriptionIsUnpaid =
+            data.allowAccessIfSubscriptionIsUnpaid || false;
+        this.nestedModel = data.nestedModel;
     }
 }

Common/Types/AnalyticsDatabase/TableColumnType.ts

@@ -0,0 +1,15 @@
+enum ColumnType {
+    ObjectID = 'Object ID',
+    Date = 'Date',
+    Boolean = 'Boolean',
+    Number = 'Number',
+    Text = 'Text',
+    NestedModel = 'Nested Model',
+    JSON = 'JSON',
+    Decimal = 'Decimal',
+    ArrayNumber = 'Array of Numbers',
+    ArrayText = 'Array of Text',
+    LongNumber = 'Long Number',
+}
+
+export default ColumnType;

Common/Types/BaseDatabase/AccessControl.ts

@@ -0,0 +1,11 @@
+import Permission from '../Permission';
+
+export interface ColumnAccessControl {
+    read: Array<Permission>;
+    create: Array<Permission>;
+    update: Array<Permission>;
+}
+
+export interface TableAccessControl extends ColumnAccessControl {
+    delete: Array<Permission>;
+}

Common/Types/BaseDatabase/ColumnBillingAccessControl.ts

@@ -0,0 +1,7 @@
+import { PlanSelect } from '../Billing/SubscriptionPlan';
+
+export default interface ColumnBillingAccessControl {
+    create: PlanSelect;
+    read: PlanSelect;
+    update: PlanSelect;
+}

Common/Types/BaseDatabase/DatabaseCommonInteractionProps.ts

@@ -20,4 +20,5 @@ export default interface DatabaseCommonInteractionProps {
     ignoreHooks?: boolean | undefined;
     currentPlan?: PlanSelect | undefined;
     isSubscriptionUnpaid?: boolean | undefined;
+    isMasterAdmin?: boolean | undefined;
 }

Common/Types/BaseDatabase/DatabaseCommonInteractionPropsUtil.ts

@@ -0,0 +1,73 @@
+import Permission, { UserPermission } from '../Permission';
+import DatabaseCommonInteractionProps from './DatabaseCommonInteractionProps';
+
+export default class DatabaseCommonInteractionPropsUtil {
+    public static getUserPermissions(
+        props: DatabaseCommonInteractionProps
+    ): Array<UserPermission> {
+        // Check first if the user has Global Permissions.
+        // Global permissions includes all the tenantId user has access to.
+        // and it includes all the global permissions that applies to all the tenant, like PUBLIC.
+        if (!props.userGlobalAccessPermission) {
+            props.userGlobalAccessPermission = {
+                globalPermissions: [Permission.Public],
+                projectIds: [],
+                _type: 'UserGlobalAccessPermission',
+            };
+        }
+
+        // If the PUBLIC Permission is not found in global permissions, include it.
+        if (
+            props.userGlobalAccessPermission &&
+            !props.userGlobalAccessPermission.globalPermissions.includes(
+                Permission.Public
+            )
+        ) {
+            props.userGlobalAccessPermission.globalPermissions.push(
+                Permission.Public
+            ); // add public permission if not already.
+        }
+
+        // If the CurrentUser Permission is not found in global permissions, include it.
+        if (
+            props.userId &&
+            props.userGlobalAccessPermission &&
+            !props.userGlobalAccessPermission.globalPermissions.includes(
+                Permission.CurrentUser
+            )
+        ) {
+            props.userGlobalAccessPermission.globalPermissions.push(
+                Permission.CurrentUser
+            );
+        }
+
+        let userPermissions: Array<UserPermission> = [];
+
+        // Include global permission in userPermissions.
+
+        if (props.userGlobalAccessPermission) {
+            /// take global permissions.
+            userPermissions =
+                props.userGlobalAccessPermission.globalPermissions.map(
+                    (permission: Permission) => {
+                        return {
+                            permission: permission,
+                            labelIds: [],
+                            _type: 'UserPermission',
+                        };
+                    }
+                );
+        }
+
+        if (props.tenantId && props.userTenantAccessPermission) {
+            // Include Tenant Permission in userPermissions.
+            userPermissions = [
+                ...userPermissions,
+                ...(props.userTenantAccessPermission[props.tenantId.toString()]
+                    ?.permissions || []),
+            ];
+        }
+
+        return userPermissions;
+    }
+}

Common/Types/BaseDatabase/EnableWorkflowOn.ts

@@ -0,0 +1,6 @@
+export default interface EnableWorkflowOn {
+    create?: boolean | undefined;
+    update?: boolean | undefined;
+    delete?: boolean | undefined;
+    read?: boolean | undefined;
+}

Common/Types/BaseDatabase/TableBillingAccessControl.ts

@@ -0,0 +1,8 @@
+import { PlanSelect } from '../Billing/SubscriptionPlan';
+
+export default interface TableBillingAccessControl {
+    create: PlanSelect;
+    read: PlanSelect;
+    update: PlanSelect;
+    delete: PlanSelect;
+}

Common/Types/Call/CallRequest.ts

@@ -28,3 +28,14 @@ export interface CallRequestMessage {
 export default interface CallRequest extends CallRequestMessage {
     to: Phone;
 }
+
+export const isHighRiskPhoneNumber: Function = (
+    phoneNumber: Phone
+): boolean => {
+    // Pakistan
+    if (phoneNumber.toString().startsWith('+92')) {
+        return true;
+    }
+
+    return false;
+};

Common/Types/Database/AccessControl/AccessControl.ts

@@ -1,25 +0,0 @@
-import { PlanSelect } from '../../Billing/SubscriptionPlan';
-import Permission from '../../Permission';
-
-export interface ColumnAccessControl {
-    read: Array<Permission>;
-    create: Array<Permission>;
-    update: Array<Permission>;
-}
-
-export interface TableAccessControl extends ColumnAccessControl {
-    delete: Array<Permission>;
-}
-
-export interface BillingAccessControl {
-    create: PlanSelect;
-    read: PlanSelect;
-    update: PlanSelect;
-    delete: PlanSelect;
-}
-
-export interface ColumnBillingAccessControl {
-    create: PlanSelect;
-    read: PlanSelect;
-    update: PlanSelect;
-}

Common/Types/Database/AccessControl/ColumnAccessControl.ts

@@ -2,7 +2,7 @@ import 'reflect-metadata';
 import BaseModel from '../../../Models/BaseModel';
 import Dictionary from '../../Dictionary';
 import { ReflectionMetadataType } from '../../Reflection';
-import { ColumnAccessControl } from './AccessControl';
+import { ColumnAccessControl } from '../../BaseDatabase/AccessControl';
 
 const accessControlSymbol: Symbol = Symbol('ColumnAccessControl');
 

Common/Types/Database/AccessControl/ColumnBillingAccessControl.ts

@@ -2,7 +2,7 @@ import 'reflect-metadata';
 import BaseModel from '../../../Models/BaseModel';
 import Dictionary from '../../Dictionary';
 import { ReflectionMetadataType } from '../../Reflection';
-import { ColumnBillingAccessControl } from './AccessControl';
+import ColumnBillingAccessControl from '../../BaseDatabase/ColumnBillingAccessControl';
 
 const accessControlSymbol: Symbol = Symbol('ColumnBillingAccessControl');
 

Common/Types/Database/AccessControl/TableAccessControl.ts

@@ -1,4 +1,4 @@
-import { TableAccessControl } from './AccessControl';
+import { TableAccessControl } from '../../BaseDatabase/AccessControl';
 
 export default (accessControl: TableAccessControl) => {
     return (ctr: Function) => {

Common/Types/Database/AccessControl/TableBillingAccessControl.ts

@@ -1,6 +1,6 @@
-import { BillingAccessControl } from './AccessControl';
+import TableBillingAccessControl from '../../BaseDatabase/TableBillingAccessControl';
 
-export default (accessControl: BillingAccessControl) => {
+export default (accessControl: TableBillingAccessControl) => {
     return (ctr: Function) => {
         if (accessControl.create) {
             ctr.prototype.createBillingPlan = accessControl.create;

Common/Types/Database/ColumnLength.ts

@@ -1,4 +1,4 @@
-import TableColumnType from '../BaseDatabase/TableColumnType';
+import TableColumnType from './TableColumnType';
 
 enum ColumnLength {
     Version = 30,

Common/Types/Database/EnableWorkflow.ts

@@ -0,0 +1,7 @@
+import EnableWorkflowOn from '../BaseDatabase/EnableWorkflowOn';
+
+export default (enableWorkflowOn: EnableWorkflowOn) => {
+    return (ctr: Function) => {
+        ctr.prototype.enableWorkflowOn = enableWorkflowOn;
+    };
+};

Common/Types/Database/TableColumn.ts

@@ -2,7 +2,7 @@ import 'reflect-metadata';
 import BaseModel from '../../Models/BaseModel';
 import Dictionary from '../Dictionary';
 import { ReflectionMetadataType } from '../Reflection';
-import TableColumnType from '../BaseDatabase/TableColumnType';
+import TableColumnType from './TableColumnType';
 
 const tableColumn: Symbol = Symbol('TableColumn');
 

Common/Types/Date.ts

@@ -29,6 +29,10 @@ export default class OneUptimeDate {
         return this.getSomeDaysAgo(new PositiveNumber(1));
     }
 
+    public static fromUnixNano(timestamp: number): Date {
+        return moment(timestamp / 1000000).toDate();
+    }
+
     public static getSecondsTo(date: Date): number {
         date = this.fromString(date);
         const dif: number = date.getTime() - this.getCurrentDate().getTime();
@@ -98,6 +102,10 @@ export default class OneUptimeDate {
         return days.positiveNumber * 24 * 60 * 60;
     }
 
+    public static getMillisecondsInDays(days: PositiveNumber | number): number {
+        return this.getSecondsInDays(days) * 1000;
+    }
+
     public static getSomeHoursAgo(hours: PositiveNumber | number): Date {
         if (!(hours instanceof PositiveNumber)) {
             hours = new PositiveNumber(hours);
@@ -221,7 +229,7 @@ export default class OneUptimeDate {
         let hasMins: boolean = false;
         if (hours !== '00') {
             hasHours = true;
-            text += hours + ' hours';
+            text += hours + ' hours ';
         }
 
         if (mins !== '00' || hasHours) {
@@ -231,7 +239,7 @@ export default class OneUptimeDate {
                 text += ', ';
             }
 
-            text += mins + ' minutes';
+            text += mins + ' minutes ';
         }
 
         if (!(hasHours && hasMins)) {
@@ -351,6 +359,12 @@ export default class OneUptimeDate {
         return moment(date).isAfter(startDate);
     }
 
+    public static isEqualBySeconds(date: Date, startDate: Date): boolean {
+        date = this.fromString(date);
+        startDate = this.fromString(startDate);
+        return moment(date).isSame(startDate, 'seconds');
+    }
+
     public static hasExpired(expirationDate: Date): boolean {
         expirationDate = this.fromString(expirationDate);
         return !moment(this.getCurrentDate()).isBefore(expirationDate);

Common/Types/Icon/IconProp.ts

@@ -10,12 +10,15 @@ enum IconProp {
     Settings = 'Settings',
     Criteria = 'Criteria',
     Notification = 'Notification',
+    Squares = 'Squares',
     Help = 'Help',
     JSON = 'JSON',
     Signal = 'Signal',
     Database = 'Database',
     ChevronDown = 'ChevronDown',
     Pencil = 'Pencil',
+    Flag = 'Flag',
+    Copy = 'Copy',
     ChevronRight = 'ChevronRight',
     ChevronUp = 'ChevronUp',
     Play = 'Play',
@@ -25,6 +28,7 @@ enum IconProp {
     Home = 'Home',
     Graph = 'Graph',
     Variable = 'Variable',
+    ListBullet = 'ListBullet',
     Image = 'Image',
     Grid = 'Grid',
     More = 'More',

Common/Types/JSON.ts

@@ -123,6 +123,7 @@ export type JSONValue =
     | Array<JSONValue>
     | Array<Permission>
     | Array<JSONValue>
+    | Array<ObjectID>
     | CallRequest
     | undefined
     | null;

Common/Types/JSONFunctions.ts

@@ -4,7 +4,7 @@ import OneUptimeDate from './Date';
 import BaseModel from '../Models/BaseModel';
 import { JSONArray, JSONObject, JSONValue, ObjectType } from './JSON';
 import { TableColumnMetadata } from '../Types/Database/TableColumn';
-import TableColumnType from './BaseDatabase/TableColumnType';
+import TableColumnType from './Database/TableColumnType';
 import SerializableObject from './SerializableObject';
 import SerializableObjectDictionary from './SerializableObjectDictionary';
 import JSON5 from 'json5';

Common/Types/Model/EnableWorkflow.ts

@@ -1,12 +0,0 @@
-export interface EnableWorkflowOn {
-    create?: boolean | undefined;
-    update?: boolean | undefined;
-    delete?: boolean | undefined;
-    read?: boolean | undefined;
-}
-
-export default (enableWorkflowOn: EnableWorkflowOn) => {
-    return (ctr: Function) => {
-        ctr.prototype.enableWorkflowOn = enableWorkflowOn;
-    };
-};

Common/Types/Monitor/CriteriaFilter.ts

@@ -9,6 +9,7 @@ export enum CheckOn {
     RequestBody = 'Request Body',
     RequestHeader = 'Request Header',
     RequestHeaderValue = 'Request Header Value',
+    JavaScriptExpression = 'JavaScript Expression',
 }
 
 export interface CriteriaFilter {
@@ -34,6 +35,7 @@ export enum FilterType {
     False = 'False',
     NotRecievedInMinutes = 'Not Recieved In Minutes',
     RecievedInMinutes = 'Recieved In Minutes',
+    EvaluatesToTrue = 'Evaluates To True',
 }
 
 export enum FilterCondition {

Common/Types/Monitor/MonitorCriteriaInstance.ts

@@ -76,7 +76,7 @@ export default class MonitorCriteriaInstance extends DatabaseProperty {
             changeMonitorStatus: true,
             createIncidents: false,
             name: 'Check if online',
-            description: 'This criteria checks if the monitor is online',
+            description: `This criteria checks if the ${arg.monitorType} is online`,
         };
 
         if (
@@ -118,8 +118,8 @@ export default class MonitorCriteriaInstance extends DatabaseProperty {
                 ],
                 incidents: [
                     {
-                        title: `${arg.monitorType} monitor is offline`,
-                        description: `${arg.monitorType} monitor is currently offline.`,
+                        title: `${arg.monitorType} is offline`,
+                        description: `${arg.monitorType} is currently offline.`,
                         incidentSeverityId: arg.incidentSeverityId,
                         autoResolveIncident: true,
                         id: ObjectID.generate().toString(),
@@ -129,7 +129,7 @@ export default class MonitorCriteriaInstance extends DatabaseProperty {
                 changeMonitorStatus: true,
                 createIncidents: true,
                 name: 'Check if offline',
-                description: 'This criteria checks if the monitor is offline',
+                description: `This criteria checks if the ${arg.monitorType} is offline`,
             };
         }
 
@@ -155,8 +155,8 @@ export default class MonitorCriteriaInstance extends DatabaseProperty {
                 ],
                 incidents: [
                     {
-                        title: `${arg.monitorType} monitor is offline`,
-                        description: `${arg.monitorType} monitor is currently offline.`,
+                        title: `${arg.monitorType} is offline`,
+                        description: `${arg.monitorType} is currently offline.`,
                         incidentSeverityId: arg.incidentSeverityId,
                         autoResolveIncident: true,
                         id: ObjectID.generate().toString(),
@@ -166,7 +166,7 @@ export default class MonitorCriteriaInstance extends DatabaseProperty {
                 changeMonitorStatus: true,
                 createIncidents: true,
                 name: 'Check if offline',
-                description: 'This criteria checks if the monitor is offline',
+                description: `This criteria checks if the ${arg.monitorType} is offline`,
             };
         }
 
@@ -184,8 +184,8 @@ export default class MonitorCriteriaInstance extends DatabaseProperty {
                 ],
                 incidents: [
                     {
-                        title: `${arg.monitorType} monitor is offline`,
-                        description: `${arg.monitorType} monitor is currently offline.`,
+                        title: `${arg.monitorType} is offline`,
+                        description: `${arg.monitorType} is currently offline.`,
                         incidentSeverityId: arg.incidentSeverityId,
                         autoResolveIncident: true,
                         id: ObjectID.generate().toString(),
@@ -195,7 +195,7 @@ export default class MonitorCriteriaInstance extends DatabaseProperty {
                 changeMonitorStatus: true,
                 createIncidents: true,
                 name: 'Check if offline',
-                description: 'This criteria checks if the monitor is offline',
+                description: `This criteria checks if the ${arg.monitorType} is offline`,
             };
         }