feat: add scheduler server

packages/scheduler/src/Infra/MySQL/MySQLPredicateRepository.ts

@@ -0,0 +1,27 @@
+import { inject, injectable } from 'inversify'
+import { Repository } from 'typeorm'
+
+import TYPES from '../../Bootstrap/Types'
+import { Predicate } from '../../Domain/Predicate/Predicate'
+import { PredicateRepositoryInterface } from '../../Domain/Predicate/PredicateRepositoryInterface'
+
+@injectable()
+export class MySQLPredicateRepository implements PredicateRepositoryInterface {
+  constructor(
+    @inject(TYPES.ORMPredicateRepository)
+    private ormRepository: Repository<Predicate>,
+  ) {}
+
+  save(predicate: Predicate): Promise<Predicate> {
+    return this.ormRepository.save(predicate)
+  }
+
+  async findByJobUuid(jobUuid: string): Promise<Predicate[]> {
+    return this.ormRepository
+      .createQueryBuilder('predicate')
+      .where('predicate.job_uuid = :jobUuid', {
+        jobUuid,
+      })
+      .getMany()
+  }
+}