chore: release

packages/cart/tsconfig.json

@@ -3,6 +3,7 @@
     "target": "ES2019",
     "module": "commonjs",
     "moduleResolution": "node",
+    "declaration": true,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
     "allowSyntheticDefaultImports": true,

packages/facade/tsconfig-base.json

@@ -1,5 +1,5 @@
 {
-  "extends": "../../node_modules/@restorecommerce/dev/tsconfig.json",
+  "extends": "../dev/tsconfig.json",
   "compilerOptions": {
     "paths": {
       "@modules": ["src/modules/index"],

packages/grpc-client/package.json

@@ -23,6 +23,7 @@
     "lodash": "^4.17.21",
     "nice-grpc": "^2.1.7",
     "nice-grpc-client-middleware-deadline": "^2.0.10",
+    "nice-grpc-client-middleware-retry": "^3.1.7",
     "protobufjs": "^7.2.6",
     "retry": "^0.13.1",
     "rxjs": "^7.8.1",

packages/grpc-client/src/index.ts

@@ -4,6 +4,7 @@ import {
   createClientFactory as createClientFactoryInternal,
   DefaultCallOptions,
   createChannel,
+  ClientError,
 } from 'nice-grpc';
 import { CompatServiceDefinition, NormalizedServiceDefinition } from 'nice-grpc/lib/service-definitions';
 import {
@@ -15,6 +16,7 @@ import {
 } from './middleware';
 import { createLogger } from '@restorecommerce/logger';
 import { deadlineMiddleware } from 'nice-grpc-client-middleware-deadline';
+import { retryMiddleware } from 'nice-grpc-client-middleware-retry';
 
 export interface GrpcClientConfig {
   logger: ReturnType<typeof createLogger>;
@@ -31,13 +33,26 @@ export function createClient<Service extends CompatServiceDefinition>(
   let factory = createClientFactoryInternal()
     .use<WithRequestID>(loggingMiddleware(config.logger, config.omittedFields))
     .use<WithRequestID>(tracingMiddleware)
-    .use<WithRequestID>(metaMiddleware);
+    .use<WithRequestID>(metaMiddleware)
+    .use<WithRequestID>(retryMiddleware);
 
   if (config.timeout) {
     factory = factory.use(deadlineMiddleware);
     factory = factory.use(internalDeadlineMiddleware(config.timeout));
   }
 
+  if (!defaultCallOptions) {
+    defaultCallOptions = {};
+  }
+  defaultCallOptions = Object.assign(defaultCallOptions, {
+    '*': {
+      retryMaxAttempts: 5,
+      retry: true,
+    },
+    onRetryableError(error: ClientError, attempt: number, delayMs: number) {
+      config.logger.error(`Call failed (${attempt}), retrying in ${delayMs}ms`, { code: error.code, message: error.message, stack: error.stack });
+    }
+  });
   return factory.create(definition, channel, defaultCallOptions);
 }
 

packages/rc-grpc-clients/package.json

@@ -28,7 +28,6 @@
   },
   "devDependencies": {
     "@restorecommerce/dev": "^0.0.9",
-    "@restorecommerce/protos": "^6.8.0",
     "@types/jest": "^29.5.3",
     "@types/node": "^20.4.1",
     "jest": "^29.6.1",
@@ -46,8 +45,8 @@
     "build:compile": "tsc -p tsconfig.lib.json",
     "prepublishOnly": "npm run build",
     "generate": "npm-run-all generate:client generate:server",
-    "generate:client": "protoc --experimental_allow_proto3_optional --ts_proto_opt=stringEnums=true,outputClientImpl=false,env=node,useOptionals=all,initializeFieldsAsUndefined=false,outputJsonMethods=true,outputSchema=true,useExactTypes=false,outputServices=nice-grpc,outputServices=generic-definitions --proto_path=../protos --plugin=../../node_modules/.bin/protoc-gen-ts_proto --ts_proto_out=./src/generated ../protos/io/restorecommerce/*.proto ../protos/grpc/health/v1/*.proto ../protos/grpc/reflection/v1alpha/*.proto ../protos/test/*.proto ../protos/echo/*.proto ../protos/google/**/*.proto",
-    "generate:server": "protoc --experimental_allow_proto3_optional --ts_proto_opt=stringEnums=true,outputClientImpl=false,env=node,useOptionals=all,initializeFieldsAsUndefined=false,outputJsonMethods=true,outputSchema=true,useExactTypes=false,outputServices=nice-grpc,outputServices=generic-definitions,snakeToCamel=false --proto_path=../protos --plugin=../../node_modules/.bin/protoc-gen-ts_proto --ts_proto_out=./src/generated-server ../protos/io/restorecommerce/*.proto ../protos/grpc/health/v1/*.proto ../protos/grpc/reflection/v1alpha/*.proto ../protos/test/*.proto ../protos/echo/*.proto  ../protos/google/**/*.proto",
+    "generate:client": "protoc --experimental_allow_proto3_optional --ts_proto_opt=stringEnums=true,outputClientImpl=false,env=node,useOptionals=all,initializeFieldsAsUndefined=false,outputJsonMethods=true,outputSchema=true,useExactTypes=false,outputServices=nice-grpc,outputServices=generic-definitions --proto_path=../protos --plugin=../../node_modules/.bin/protoc-gen-ts_proto --ts_proto_out=./src/generated ../protos/**/*.proto ../protos/**/**/*.proto ../protos/**/**/**/*.proto",
+    "generate:server": "protoc --experimental_allow_proto3_optional --ts_proto_opt=stringEnums=true,outputClientImpl=false,env=node,useOptionals=all,initializeFieldsAsUndefined=false,outputJsonMethods=true,outputSchema=true,useExactTypes=false,outputServices=nice-grpc,outputServices=generic-definitions,snakeToCamel=false --proto_path=../protos --plugin=../../node_modules/.bin/protoc-gen-ts_proto --ts_proto_out=./src/generated-server ../protos/**/*.proto ../protos/**/**/*.proto ../protos/**/**/**/*.proto",
     "test": "jest",
     "pretest": "run-s prebuild"
   },

packages/rc-grpc-clients/tsconfig-base.json

@@ -1,5 +1,5 @@
 {
-  "extends": "../../node_modules/@restorecommerce/dev/tsconfig.json",
+  "extends": "../dev/tsconfig.json",
   "compilerOptions": {
     "esModuleInterop": false,
     "allowSyntheticDefaultImports": true,

packages/scs-jobs/src/index.ts

@@ -156,7 +156,12 @@ export const runWorker = async (queue: string, concurrency: number, cfg: any, lo
   worker.on('error', err => logger.error(`worker#${queue} error`, err));
   worker.on('closed', () => logger.verbose(`worker#${queue} closed`));
   worker.on('progress', (j, p) => logger.debug(`worker#${queue} job#${j.id} progress`, p));
-  worker.on('failed', (j, err) => logger.error(`worker#${queue} job#${j.id} failed`, err));
+  worker.on('failed', async (j, err) => {
+    logger.error(`worker#${queue} job#${j.id} failed`, err);
+    await jobEvents.emit('jobFailed', { id: j.id, schedule_type: j.data.schedule_type, error: err.message, type: j.name }).catch(err => {
+      logger.error(`Error emitting jobFailed event for ${j.name}`, err);
+    });
+  });
   worker.on('closing', msg => logger.verbose(`worker#${queue} closing: ${msg}`));
   worker.on('completed', j => logger.info(`worker#${queue} job#${j.id} completed`));
   worker.on('stalled', j => logger.warn(`worker#${queue} job#${j} stalled`));