Merge branch 'next' into questionnaire-screen

apps/api/src/app/widgets/usecases/get-feed-count/get-feed-count.usecase.ts

@@ -1,7 +1,7 @@
 import { Injectable } from '@nestjs/common';
 import { MessageRepository, SubscriberRepository } from '@novu/dal';
 import { ChannelTypeEnum } from '@novu/shared';
-import { buildMessageCountKey, CachedQuery } from '@novu/application-generic';
+import { buildMessageCountKey, CachedQuery, InstrumentUsecase } from '@novu/application-generic';
 
 import { GetFeedCountCommand } from './get-feed-count.command';
 import { ApiException } from '../../../shared/exceptions/api.exception';
@@ -13,6 +13,7 @@ export class GetFeedCount {
     private subscriberRepository: SubscriberRepository
   ) {}
 
+  @InstrumentUsecase()
   @CachedQuery({
     builder: ({ environmentId, subscriberId, ...command }: GetFeedCountCommand) =>
       buildMessageCountKey().cache({

apps/api/src/app/widgets/usecases/get-notifications-feed/get-notifications-feed.usecase.ts

@@ -6,6 +6,7 @@ import {
   buildSubscriberKey,
   CachedEntity,
   CachedQuery,
+  InstrumentUsecase,
 } from '@novu/application-generic';
 import { MessageRepository, SubscriberEntity, SubscriberRepository } from '@novu/dal';
 
@@ -33,6 +34,7 @@ export class GetNotificationsFeed {
     }
   }
 
+  @InstrumentUsecase()
   @CachedQuery({
     builder: ({ environmentId, subscriberId, ...command }: GetNotificationsFeedCommand) =>
       buildFeedKey().cache({

apps/dashboard/src/pages/workflows.tsx

@@ -6,8 +6,17 @@ import { RiSearch2Line } from 'react-icons/ri';
 import { CreateWorkflowButton } from '@/components/create-workflow-button';
 import { OptInModal } from '@/components/opt-in-modal';
 import { PageMeta } from '@/components/page-meta';
+import { useTelemetry } from '../hooks';
+import { TelemetryEvent } from '../utils/telemetry';
+import { useEffect } from 'react';
 
 export const WorkflowsPage = () => {
+  const track = useTelemetry();
+
+  useEffect(() => {
+    track(TelemetryEvent.WORKFLOWS_PAGE_VISIT);
+  }, [track]);
+
   return (
     <>
       <PageMeta title="Workflows" />

apps/dashboard/src/utils/telemetry.ts

@@ -5,4 +5,5 @@ export enum TelemetryEvent {
   CREATE_ORGANIZATION_FORM_SUBMITTED = 'Create Organization Form Submitted',
   USE_CASE_SELECTED = 'Use Case Selected',
   USE_CASE_SKIPPED = 'Use Case Skipped',
+  WORKFLOWS_PAGE_VISIT = 'Workflows page visit',
 }

package.json

@@ -40,7 +40,7 @@
     "preinstall": "npx only-allow pnpm",
     "preview:pkg:build": "nx affected -t build --base=origin/next --head=HEAD --exclude='*,!tag:package:public'",
     "preview:pkg:publish": "node scripts/publish-preview-packages.mjs",
-    "release": "nx release",
+    "release": "node scripts/release.mjs",
     "setup:project": "npx --yes pnpm@9.11.0 i && node scripts/setup-env-files.js && pnpm build",
     "start:api:dev": "cross-env nx run @novu/api:start:dev",
     "start:api:test": "cross-env nx run-many --target=start:test --projects=@novu/api",

scripts/release.mjs

@@ -0,0 +1,46 @@
+import { releaseChangelog, releasePublish, releaseVersion } from 'nx/release/index.js';
+import yargs from 'yargs/yargs';
+import { hideBin } from 'yargs/helpers';
+
+(async () => {
+  const options = yargs(hideBin(process.argv))
+    .version(false)
+    .option('version', {
+      description: 'Explicit version specifier to use, if overriding conventional commits',
+      type: 'string',
+    })
+    .option('dryRun', {
+      alias: 'd',
+      description: 'Whether or not to perform a dry-run of the release process, defaults to true',
+      type: 'boolean',
+    })
+    .option('verbose', {
+      description: 'Whether or not to enable verbose logging, defaults to false',
+      type: 'boolean',
+      default: false,
+    })
+    .parse();
+
+  const { workspaceVersion, projectsVersionData } = await releaseVersion({
+    specifier: options.version,
+    dryRun: options.dryRun,
+    verbose: options.verbose,
+    projects: ['tag:package:public'],
+  });
+
+  await releaseChangelog({
+    versionData: projectsVersionData,
+    version: workspaceVersion,
+    dryRun: options.dryRun,
+    verbose: options.verbose,
+    projects: ['tag:package:public'],
+  });
+
+  // The returned number value from releasePublish will be zero if all projects are published successfully, non-zero if not
+  const publishStatus = await releasePublish({
+    dryRun: options.dryRun,
+    verbose: options.verbose,
+    projects: ['tag:package:public'],
+  });
+  process.exit(publishStatus);
+})();