feat: skip processing tasks over task quota

packages/backend/src/models/flow.ts

@@ -1,5 +1,6 @@
 import { ValidationError } from 'objection';
 import type { ModelOptions, QueryContext } from 'objection';
+import appConfig from '../config/app';
 import ExtendedQueryBuilder from './query-builder';
 import Base from './base';
 import Step from './step';
@@ -129,6 +130,21 @@ class Flow extends Base {
       type: 'trigger',
     });
   }
+
+  async throwIfQuotaExceeded() {
+    if (!appConfig.isCloud) return;
+
+    const user = await this.$relatedQuery('user');
+    const usageData = await user.$relatedQuery('usageData');
+
+    const hasExceeded = await usageData.checkIfLimitExceeded();
+
+    if (hasExceeded) {
+      throw new Error('The allowed task quota has been exhausted!');
+    }
+
+    return this;
+  }
 }
 
 export default Flow;