Replace ortto External Embedded Webform for Onboarding guide

src/adapters/notifications/MockNotificationAdapter.ts

@@ -11,6 +11,11 @@ import { logger } from '../../utils/logger';
 import { RecurringDonation } from '../../entities/recurringDonation';
 
 export class MockNotificationAdapter implements NotificationAdapterInterface {
+  async subscribeOnboarding(params: { email: string }): Promise<void> {
+    logger.debug('MockNotificationAdapter subscribeOnboarding', params);
+    return Promise.resolve(undefined);
+  }
+
   async createOrttoProfile(params: User): Promise<void> {
     logger.debug('MockNotificationAdapter createOrttoProfile', params);
     return Promise.resolve(undefined);

src/adapters/notifications/NotificationAdapterInterface.ts

@@ -34,6 +34,8 @@ export interface OrttoPerson {
 }
 
 export interface NotificationAdapterInterface {
+  subscribeOnboarding(params: { email: string }): Promise<void>;
+
   createOrttoProfile(params: User): Promise<void>;
 
   updateOrttoPeople(params: OrttoPerson[]): Promise<void>;

src/adapters/notifications/NotificationCenterAdapter.ts

@@ -56,6 +56,21 @@ export class NotificationCenterAdapter implements NotificationAdapterInterface {
     }
   }
 
+  async subscribeOnboarding(params: { email: string }): Promise<void> {
+    try {
+      const { email } = params;
+      if (!email) return;
+      await callSendNotification({
+        eventName: NOTIFICATIONS_EVENT_NAMES.SUBSCRIBE_ONBOARDING,
+        segment: {
+          payload: { email },
+        },
+      });
+    } catch (e) {
+      logger.error('subscribeOnboarding >> error', e);
+    }
+  }
+
   async userSuperTokensCritical(params: {
     user: User;
     eventName: UserStreamBalanceWarning;
@@ -1223,7 +1238,7 @@ interface SendNotificationBody {
   trackId?: string;
   metadata?: any;
   projectId?: string;
-  userWalletAddress: string;
+  userWalletAddress?: string;
   segment?: {
     payload: any;
   };

src/analytics/analytics.ts

@@ -46,5 +46,6 @@ export enum NOTIFICATIONS_EVENT_NAMES {
   SUPER_TOKENS_BALANCE_WEEK = 'One week left in stream balance',
   SUPER_TOKENS_BALANCE_MONTH = 'One month left in stream balance',
   SUPER_TOKENS_BALANCE_DEPLETED = 'Stream balance depleted',
+  SUBSCRIBE_ONBOARDING = 'Subscribe onboarding',
   CREATE_ORTTO_PROFILE = 'Create Ortto profile',
 }

src/resolvers/onboardingFormResolver.ts

@@ -0,0 +1,17 @@
+import { Arg, Query, Resolver } from 'type-graphql';
+import { getNotificationAdapter } from '../adapters/adaptersFactory';
+import { logger } from '../utils/logger';
+
+@Resolver()
+export class OnboardingFormResolver {
+  @Query(_returns => Boolean)
+  async subscribeOnboarding(@Arg('email') email: string): Promise<boolean> {
+    try {
+      await getNotificationAdapter().subscribeOnboarding({ email });
+      return true;
+    } catch (e) {
+      logger.debug('subscribeOnboarding() error', e);
+      return e;
+    }
+  }
+}

src/resolvers/resolvers.ts

@@ -20,6 +20,7 @@ import { ProjectUserInstantPowerViewResolver } from './instantPowerResolver';
 import { AnchorContractAddressResolver } from './anchorContractAddressResolver';
 import { RecurringDonationResolver } from './recurringDonationResolver';
 import { DraftDonationResolver } from './draftDonationResolver';
+import { OnboardingFormResolver } from './onboardingFormResolver';
 
 // eslint-disable-next-line @typescript-eslint/ban-types
 export const getResolvers = (): Function[] => {
@@ -49,5 +50,6 @@ export const getResolvers = (): Function[] => {
 
     AnchorContractAddressResolver,
     RecurringDonationResolver,
+    OnboardingFormResolver,
   ];
 };