chore: import paths

Author: xavier-brochard

packages/snap/src/core/handlers/index.ts

@@ -0,0 +1,3 @@
+export * from './onClientRequest';
+export * from './onStart';
+export * from './onWebSocketEvent';

packages/snap/src/core/handlers/onCronjob/backgroundEvents/onAccountsRefresh.ts

@@ -23,6 +23,7 @@ export const onAccountsRefresh: OnCronjobHandler = async () => {
     logger.info('[onAccountsRefresh] Cronjob triggered');
 
     const accounts = await keyring.listAccounts();
+
     const scope = Network.Mainnet;
 
     const accountsWithChangeCheckPromises = accounts.map(async (account) => {

…/core/handlers/onStart/onStartHandler.ts …rc/core/handlers/onStart/StartHandler.tspackages/snap/src/core/handlers/onStart/onStartHandler.ts renamed to packages/snap/src/core/handlers/onStart/StartHandler.ts packages/snap/src/core/handlers/onStart/onStartHandler.ts renamed to packages/snap/src/core/handlers/onStart/StartHandler.ts

@@ -1,7 +1,13 @@
 import type { SubscriptionConnectionManagerPort } from '../../ports/SubscriptionConnectionManagerPort';
 
-export class OnStartHandler {
+export class StartHandler {
   constructor(
     private readonly subscriptionConnectionManager: SubscriptionConnectionManagerPort,
   ) {}
+
+  async handle(): Promise<void> {
+    // Wipe the subscriptions state
+    // Open the connections for all networks
+    // Init the subscriptions
+  }
 }

packages/snap/src/core/handlers/onStart/index.ts

@@ -1 +1 @@
-export * from './onStartHandler';
+export * from './StartHandler';

packages/snap/src/index.ts

@@ -43,7 +43,7 @@ import { installPolyfills } from './infrastructure/polyfills';
 import snapContext, {
   clientRequestHandler,
   keyring,
-  onStartHandler,
+  startHandler,
   state,
   webSocketEventHandler,
 } from './snapContext';
@@ -275,4 +275,4 @@ export const onWebSocketEvent: OnWebSocketEventHandler = async ({ event }) =>
   withCatchAndThrowSnapError(async () => webSocketEventHandler.handle(event));
 
 export const onStart: OnStartHandler = async () =>
-  withCatchAndThrowSnapError(async () => onStartHandler.handle());
+  withCatchAndThrowSnapError(async () => startHandler.handle());

packages/snap/src/snapContext.ts

@@ -4,9 +4,12 @@ import { StateCache } from './core/caching/StateCache';
 import { PriceApiClient } from './core/clients/price-api/PriceApiClient';
 import { SecurityAlertsApiClient } from './core/clients/security-alerts-api/SecurityAlertsApiClient';
 import { TokenMetadataClient } from './core/clients/token-metadata-client/TokenMetadataClient';
-import { ClientRequestHandler } from './core/handlers/onClientRequest';
+import {
+  ClientRequestHandler,
+  StartHandler,
+  WebSocketEventHandler,
+} from './core/handlers';
 import { SolanaKeyring } from './core/handlers/onKeyringRequest/Keyring';
-import { WebSocketEventHandler } from './core/handlers/onWebSocketEvent';
 import type {
   SubscriptionConnectionManagerPort,
   SubscriptionTransportPort,
@@ -64,6 +67,7 @@ export type SnapExecutionContext = {
   subscriptionTransport: SubscriptionTransportPort;
   webSocketService: WebSocketService;
   webSocketEventHandler: WebSocketEventHandler;
+  startHandler: StartHandler;
 };
 
 const configProvider = new ConfigProvider();
@@ -166,6 +170,8 @@ const clientRequestHandler = new ClientRequestHandler(
   logger,
 );
 
+const startHandler = new StartHandler(subscriptionConnectionManager);
+
 const snapContext: SnapExecutionContext = {
   configProvider,
   connection,
@@ -190,6 +196,7 @@ const snapContext: SnapExecutionContext = {
   subscriptionTransport,
   webSocketService,
   webSocketEventHandler,
+  startHandler,
 };
 
 export {
@@ -204,6 +211,7 @@ export {
   priceApiClient,
   sendSolBuilder,
   sendSplTokenBuilder,
+  startHandler,
   state,
   subscriptionConnectionManager,
   subscriptionTransport,