|
| 1 | +import { handleUnaryCall, sendUnaryData, ServerUnaryCall, UntypedHandleCall } from "@grpc/grpc-js"; |
| 2 | +import { CreateResult, Empty, LookupCriteria, ScanRequest, ScanResult, UpdateResult |
| 3 | +} from "@topcoder-framework/lib-common"; |
| 4 | +import LegacyUploadDomain from '../domain/LegacyUpload' |
| 5 | + |
| 6 | +import { LegacyUploadServer, LegacyUploadService } from '../models/domain-layer/legacy/services/upload'; |
| 7 | +import { Upload, CreateUploadInput, DeleteUploadInput, UploadList, UpdateUploadInput } from "../models/domain-layer/legacy/upload"; |
| 8 | + |
| 9 | +class LegacyUploadServerImpl implements LegacyUploadServer { |
| 10 | + [name: string]: UntypedHandleCall; |
| 11 | + |
| 12 | + scan: handleUnaryCall<ScanRequest, ScanResult> = ( |
| 13 | + call: ServerUnaryCall<ScanRequest, ScanResult>, |
| 14 | + callback: sendUnaryData<ScanResult> |
| 15 | + ) => { |
| 16 | + // not implemented |
| 17 | + }; |
| 18 | + |
| 19 | + lookup: handleUnaryCall<LookupCriteria, Upload> |
| 20 | + = ( |
| 21 | + call: ServerUnaryCall<LookupCriteria, Upload>, |
| 22 | + callback: sendUnaryData<Upload> |
| 23 | + ) => { |
| 24 | + // not implemented |
| 25 | + }; |
| 26 | + |
| 27 | + create: handleUnaryCall<CreateUploadInput, CreateResult> = ( |
| 28 | + call: ServerUnaryCall<CreateUploadInput, CreateResult>, |
| 29 | + callback: sendUnaryData<CreateResult> |
| 30 | + ) => { |
| 31 | + // not implemented |
| 32 | + }; |
| 33 | + |
| 34 | + delete: handleUnaryCall<DeleteUploadInput, UploadList> = ( |
| 35 | + call: ServerUnaryCall<DeleteUploadInput, UploadList>, |
| 36 | + callback: sendUnaryData<UploadList> |
| 37 | + ) => { |
| 38 | + // not implemented |
| 39 | + }; |
| 40 | + |
| 41 | + |
| 42 | + update: handleUnaryCall<UpdateUploadInput, UpdateResult> = ( |
| 43 | + call: ServerUnaryCall<UpdateUploadInput, UpdateResult>, |
| 44 | + callback: sendUnaryData<UpdateResult> |
| 45 | + ) => { |
| 46 | + LegacyUploadDomain.update(call.request) |
| 47 | + .then((response) => callback(null, response)) |
| 48 | + .catch((err) => callback(err, null)); |
| 49 | + }; |
| 50 | +} |
| 51 | + |
| 52 | +export { LegacyUploadServerImpl as LegacyUploadServer, LegacyUploadService }; |
0 commit comments