feat(domain-submission): add submission domain to the framework

.yarnrc.yml

@@ -0,0 +1 @@
+nodeLinker: node-modules

CONTRIBUTING.md

@@ -53,7 +53,7 @@ Any line of the commit message cannot be longer than 100 characters.
   │        |        │
   │        |        └─⫸ Summary in present tense. Not capitalized. No period at the end.
   |        |
-  |        └─⫸ Commit Scope: domain-acl|domain-challenge|domain-resource|lib-logger|lib-common|lib-secrets
+  |        └─⫸ Commit Scope: domain-challenge| domain-submission|domain-resource|lib-logger|lib-common|lib-secrets
   |
   └─⫸ Commit Type: feat|fix|docs|chore|refactor|ci|test|perf|revert
 ```

clients/client-relational/package.json

@@ -45,5 +45,5 @@
   "files": [
     "dist-*"
   ],
-  "gitHead": "8c19fdcd36bcccc5e952aa909e4a30caf2943340"
+  "gitHead": "d1f5aa12f078f2e100be4d1e92d5fb7b77a47707"
 }

domains/domain-acl/src/domains/LongComponentStateService.ts

@@ -0,0 +1,69 @@
+import { Metadata } from "@grpc/grpc-js";
+import { promisify } from "util";
+
+import { LegacyLongComponentStateClient } from "../models/domain-layer/legacy/services/long_component_state";
+
+import { GrpcClient } from "../common/GrpcClient";
+
+import {
+  CreateResult,
+  LookupCriteria,
+  ScanRequest,
+  ScanResult,
+  UpdateResult,
+} from "@topcoder-framework/lib-common";
+import {
+  CreateLongComponentStateInput,
+  LongComponentState,
+  UpdateLongComponentStateInput,
+} from "src/models/domain-layer/legacy/long_component_state";
+
+export class LegacyLongComponentStateDomain {
+  constructor(
+    protected grpcServerHost: string,
+    protected grpcServerPort: string
+  ) {}
+
+  protected readonly client: LegacyLongComponentStateClient =
+    new LegacyLongComponentStateClient(
+      `${this.grpcServerHost}:${this.grpcServerPort}`,
+      GrpcClient.credentials,
+      GrpcClient.clientOptions
+    );
+
+  public async scan(
+    param: ScanRequest,
+    metadata: Metadata = new Metadata()
+  ): Promise<ScanResult> {
+    return promisify<ScanRequest, Metadata, ScanResult>(
+      this.client.scan.bind(this.client)
+    )(param, metadata);
+  }
+
+  public async lookup(
+    param: LookupCriteria,
+    metadata: Metadata = new Metadata()
+  ) {
+    return promisify<LookupCriteria, Metadata, LongComponentState>(
+      this.client.lookup.bind(this.client)
+    )(param, metadata);
+  }
+
+  public async create(
+    param: CreateLongComponentStateInput,
+    metadata: Metadata = new Metadata()
+  ) {
+    return promisify<CreateLongComponentStateInput, Metadata, CreateResult>(
+      this.client.create.bind(this.client)
+    )(param, metadata);
+  }
+
+  public async update(
+    param: UpdateLongComponentStateInput,
+    metadata: Metadata = new Metadata()
+  ) {
+    return promisify<UpdateLongComponentStateInput, Metadata, UpdateResult>(
+      this.client.update.bind(this.client)
+    )(param, metadata);
+  }
+}

domains/domain-acl/src/domains/LongSubmissionService.ts

@@ -0,0 +1,45 @@
+import { Metadata } from "@grpc/grpc-js";
+import { promisify } from "util";
+
+import { LegacyLongSubmissionClient } from "../models/domain-layer/legacy/services/long_submission";
+
+import { GrpcClient } from "../common/GrpcClient";
+
+import {
+  CreateResult,
+  ScanRequest,
+  ScanResult,
+} from "@topcoder-framework/lib-common";
+import { CreateLongSubmissionInput } from "src/models/domain-layer/legacy/long_submission";
+
+export class LegacyLongSubmissionDomain {
+  constructor(
+    protected grpcServerHost: string,
+    protected grpcServerPort: string
+  ) {}
+
+  protected readonly client: LegacyLongSubmissionClient =
+    new LegacyLongSubmissionClient(
+      `${this.grpcServerHost}:${this.grpcServerPort}`,
+      GrpcClient.credentials,
+      GrpcClient.clientOptions
+    );
+
+  public async scan(
+    param: ScanRequest,
+    metadata: Metadata = new Metadata()
+  ): Promise<ScanResult> {
+    return promisify<ScanRequest, Metadata, ScanResult>(
+      this.client.scan.bind(this.client)
+    )(param, metadata);
+  }
+
+  public async create(
+    param: CreateLongSubmissionInput,
+    metadata: Metadata = new Metadata()
+  ) {
+    return promisify<CreateLongSubmissionInput, Metadata, CreateResult>(
+      this.client.create.bind(this.client)
+    )(param, metadata);
+  }
+}

domains/domain-acl/src/domains/ResourceSubmissionService.ts

@@ -0,0 +1,58 @@
+import { Metadata } from "@grpc/grpc-js";
+import { promisify } from "util";
+
+import { LegacyResourceSubmissionClient } from "../models/domain-layer/legacy/services/resource_submission";
+
+import { GrpcClient } from "../common/GrpcClient";
+
+import {
+  CreateResult,
+  LookupCriteria,
+  ScanRequest,
+  ScanResult,
+} from "@topcoder-framework/lib-common";
+import {
+  CreateResourceSubmissionInput,
+  ResourceSubmission,
+} from "src/models/domain-layer/legacy/resource_submission";
+
+export class LegacyResourceSubmissionDomain {
+  constructor(
+    protected grpcServerHost: string,
+    protected grpcServerPort: string
+  ) {}
+
+  protected readonly client: LegacyResourceSubmissionClient =
+    new LegacyResourceSubmissionClient(
+      `${this.grpcServerHost}:${this.grpcServerPort}`,
+      GrpcClient.credentials,
+      GrpcClient.clientOptions
+    );
+
+  public async scan(
+    param: ScanRequest,
+    metadata: Metadata = new Metadata()
+  ): Promise<ScanResult> {
+    return promisify<ScanRequest, Metadata, ScanResult>(
+      this.client.scan.bind(this.client)
+    )(param, metadata);
+  }
+
+  public async lookup(
+    param: LookupCriteria,
+    metadata: Metadata = new Metadata()
+  ) {
+    return promisify<LookupCriteria, Metadata, ResourceSubmission>(
+      this.client.lookup.bind(this.client)
+    )(param, metadata);
+  }
+
+  public async create(
+    param: CreateResourceSubmissionInput,
+    metadata: Metadata = new Metadata()
+  ) {
+    return promisify<CreateResourceSubmissionInput, Metadata, CreateResult>(
+      this.client.create.bind(this.client)
+    )(param, metadata);
+  }
+}

domains/domain-acl/src/domains/RoundRegistrationService.ts

@@ -0,0 +1,45 @@
+import { Metadata } from "@grpc/grpc-js";
+import { promisify } from "util";
+
+import { LegacyRoundRegistrationClient } from "../models/domain-layer/legacy/services/round_registration";
+
+import { GrpcClient } from "../common/GrpcClient";
+
+import {
+  CreateResult,
+  ScanRequest,
+  ScanResult,
+} from "@topcoder-framework/lib-common";
+import { CreateRoundRegistrationInput } from "src/models/domain-layer/legacy/round_registration";
+
+export class LegacyRoundRegistrationDomain {
+  constructor(
+    protected grpcServerHost: string,
+    protected grpcServerPort: string
+  ) {}
+
+  protected readonly client: LegacyRoundRegistrationClient =
+    new LegacyRoundRegistrationClient(
+      `${this.grpcServerHost}:${this.grpcServerPort}`,
+      GrpcClient.credentials,
+      GrpcClient.clientOptions
+    );
+
+  public async scan(
+    param: ScanRequest,
+    metadata: Metadata = new Metadata()
+  ): Promise<ScanResult> {
+    return promisify<ScanRequest, Metadata, ScanResult>(
+      this.client.scan.bind(this.client)
+    )(param, metadata);
+  }
+
+  public async create(
+    param: CreateRoundRegistrationInput,
+    metadata: Metadata = new Metadata()
+  ) {
+    return promisify<CreateRoundRegistrationInput, Metadata, CreateResult>(
+      this.client.create.bind(this.client)
+    )(param, metadata);
+  }
+}

domains/domain-acl/src/domains/SubmissionService.ts

@@ -0,0 +1,69 @@
+import { Metadata } from "@grpc/grpc-js";
+import { promisify } from "util";
+
+import { LegacySubmissionClient } from "../models/domain-layer/legacy/services/submission";
+
+import { GrpcClient } from "../common/GrpcClient";
+
+import {
+  CreateResult,
+  LookupCriteria,
+  ScanRequest,
+  ScanResult,
+  UpdateResult,
+} from "@topcoder-framework/lib-common";
+import { LegacySubmission } from "src/models/domain-layer/legacy/submission";
+import {
+  CreateSubmissionInput,
+  UpdateSubmissionInput,
+} from "src/models/domain-layer/legacy/submission";
+
+export class LegacySubmissionDomain {
+  constructor(
+    protected grpcServerHost: string,
+    protected grpcServerPort: string
+  ) {}
+
+  protected readonly client: LegacySubmissionClient =
+    new LegacySubmissionClient(
+      `${this.grpcServerHost}:${this.grpcServerPort}`,
+      GrpcClient.credentials,
+      GrpcClient.clientOptions
+    );
+
+  public async scan(
+    param: ScanRequest,
+    metadata: Metadata = new Metadata()
+  ): Promise<ScanResult> {
+    return promisify<ScanRequest, Metadata, ScanResult>(
+      this.client.scan.bind(this.client)
+    )(param, metadata);
+  }
+
+  public async lookup(
+    param: LookupCriteria,
+    metadata: Metadata = new Metadata()
+  ) {
+    return promisify<LookupCriteria, Metadata, LegacySubmission>(
+      this.client.lookup.bind(this.client)
+    )(param, metadata);
+  }
+
+  public async create(
+    param: CreateSubmissionInput,
+    metadata: Metadata = new Metadata()
+  ) {
+    return promisify<CreateSubmissionInput, Metadata, CreateResult>(
+      this.client.create.bind(this.client)
+    )(param, metadata);
+  }
+
+  public async update(
+    param: UpdateSubmissionInput,
+    metadata: Metadata = new Metadata()
+  ) {
+    return promisify<UpdateSubmissionInput, Metadata, UpdateResult>(
+      this.client.update.bind(this.client)
+    )(param, metadata);
+  }
+}

domains/domain-acl/src/domains/UploadService.ts

@@ -0,0 +1,79 @@
+import { Metadata } from "@grpc/grpc-js";
+import { promisify } from "util";
+
+import { LegacyUploadClient } from "../models/domain-layer/legacy/services/upload";
+
+import { GrpcClient } from "../common/GrpcClient";
+
+import {
+  CreateResult,
+  Empty,
+  LookupCriteria,
+  ScanRequest,
+  ScanResult,
+  UpdateResult,
+} from "@topcoder-framework/lib-common";
+import {
+  CreateUploadInput,
+  DeleteUploadInput,
+  Upload,
+} from "src/models/domain-layer/legacy/upload";
+import { UpdateUploadInput } from "src/models/domain-layer/legacy/upload";
+
+export class LegacyUploadDomain {
+  constructor(
+    protected grpcServerHost: string,
+    protected grpcServerPort: string
+  ) {}
+
+  protected readonly client: LegacyUploadClient = new LegacyUploadClient(
+    `${this.grpcServerHost}:${this.grpcServerPort}`,
+    GrpcClient.credentials,
+    GrpcClient.clientOptions
+  );
+
+  public async scan(
+    param: ScanRequest,
+    metadata: Metadata = new Metadata()
+  ): Promise<ScanResult> {
+    return promisify<ScanRequest, Metadata, ScanResult>(
+      this.client.scan.bind(this.client)
+    )(param, metadata);
+  }
+
+  public async lookup(
+    param: LookupCriteria,
+    metadata: Metadata = new Metadata()
+  ) {
+    return promisify<LookupCriteria, Metadata, Upload>(
+      this.client.lookup.bind(this.client)
+    )(param, metadata);
+  }
+
+  public async create(
+    param: CreateUploadInput,
+    metadata: Metadata = new Metadata()
+  ) {
+    return promisify<CreateUploadInput, Metadata, CreateResult>(
+      this.client.create.bind(this.client)
+    )(param, metadata);
+  }
+
+  public async update(
+    param: UpdateUploadInput,
+    metadata: Metadata = new Metadata()
+  ) {
+    return promisify<UpdateUploadInput, Metadata, UpdateResult>(
+      this.client.update.bind(this.client)
+    )(param, metadata);
+  }
+
+  public async delete(
+    param: LookupCriteria,
+    metadata: Metadata = new Metadata()
+  ) {
+    return promisify<LookupCriteria, Metadata, Empty>(
+      this.client.delete.bind(this.client)
+    )(param, metadata);
+  }
+}