{"version":3,"sources":["../lib/service.ts","../lib/tools.ts","../lib/config.ts"],"sourcesContent":["import { GrpcObject, ServiceClientConstructor, ServiceDefinition, UntypedServiceImplementation, loadPackageDefinition } from \"@grpc/grpc-js\";\nimport { loadProto } from \"./tools.ts\";\nimport { PackageDefinition } from \"@grpc/proto-loader\";\n\nexport type ServiceOptions = {\n    path: string\n    package: string\n    service: string\n}\n\nexport type GrpcService = {\n    service: ServiceDefinition,\n    mapper: UntypedServiceImplementation\n}\n\nexport default (options: ServiceOptions, mapper: UntypedServiceImplementation): GrpcService => {\n    const definition: PackageDefinition = loadProto(options.path);\n    const grpcObject: GrpcObject = loadPackageDefinition(definition);\n    const grpcPackage: GrpcObject = grpcObject[options.package] as GrpcObject;\n    const grpcService = grpcPackage[options.service] as ServiceClientConstructor;\n    return { service: grpcService.service, mapper }\n}","import { PackageDefinition, loadSync } from \"@grpc/proto-loader\"\nimport grpcConfig from \"./config.ts\"\nimport { join } from 'path'\n\nexport const loadProto = (path: string): PackageDefinition => {\n    return loadSync(join(grpcConfig.path, path), {\n        keepCase: true,\n        longs: String,\n        enums: String,\n        defaults: true,\n        oneofs: true\n    })\n}","import { ConfigLoader } from \"fly-boot\";\n\nexport class GrpcConfigInterface {\n    path: string\n    host: string\n    port: number\n}\n\n/**\n * 服务配置\n */\nexport class GrpcConfig extends GrpcConfigInterface {\n    constructor(options?: any) {\n        super();\n        Object.assign(this, options)\n    }\n}\n\nexport default ConfigLoader.load(GrpcConfig, \"grpc.yml\")"],"mappings":";;;;;;;;;;;;;;;;;;;AAAA;AAAA;AAAA;AAAA;AAAA;AAAA,qBAA6H;;;ACA7H,0BAA4C;;;ACA5C,sBAA6B;AAEtB,IAAM,sBAAN,MAA0B;AAAA,EAC7B;AAAA,EACA;AAAA,EACA;AACJ;AAKO,IAAM,aAAN,cAAyB,oBAAoB;AAAA,EAChD,YAAY,SAAe;AACvB,UAAM;AACN,WAAO,OAAO,MAAM,OAAO;AAAA,EAC/B;AACJ;AAEA,IAAO,iBAAQ,6BAAa,KAAK,YAAY,UAAU;;;ADhBvD,kBAAqB;AAEd,IAAM,YAAY,CAAC,SAAoC;AAC1D,aAAO,kCAAS,kBAAK,eAAW,MAAM,IAAI,GAAG;AAAA,IACzC,UAAU;AAAA,IACV,OAAO;AAAA,IACP,OAAO;AAAA,IACP,UAAU;AAAA,IACV,QAAQ;AAAA,EACZ,CAAC;AACL;;;ADGA,IAAO,kBAAQ,CAAC,SAAyB,WAAsD;AAC3F,QAAM,aAAgC,UAAU,QAAQ,IAAI;AAC5D,QAAM,iBAAyB,sCAAsB,UAAU;AAC/D,QAAM,cAA0B,WAAW,QAAQ,OAAO;AAC1D,QAAM,cAAc,YAAY,QAAQ,OAAO;AAC/C,SAAO,EAAE,SAAS,YAAY,SAAS,OAAO;AAClD;","names":[]}