Function connectSocket

frontend/src/modules/auth/auth-socket.js:15–119

(token)

let socketIoClient;

export const connectSocket = (token) => {
  if (socketIoClient && socketIoClient.connected) {
    socketIoClient.disconnect();
  }
  const currentTenant = computed(
    () => store.getters['auth/currentTenant'],
  );
  const currentUser = computed(
    () => store.getters['auth/currentUser'],
  );

  const path = config.env === 'production' || config.env === 'staging'
    ? '/api/socket.io'
    : '/socket.io';

  socketIoClient = io(`${config.websocketsUrl}/user`, {
    path,
    query: {
      token,
    },
    transports: ['websocket'],
    forceNew: true,
  });

  socketIoClient.on('connect', () => {
    console.info('Socket connected');
  });

  socketIoClient.on('disconnect', () => {
    console.info('Socket disconnected');
  });

  socketIoClient.on('integration-completed', (data) => {
    console.info('Integration onboarding done', data);
    store.dispatch(
      'integration/doFind',
      JSON.parse(data).integrationId,
    );
  });

  socketIoClient.on(
    'tenant-plan-upgraded',
    async (data) => {
      console.info(
        'Tenant plan is upgraded. Force a hard refresh!',
        data,
      );
      let parsed = data;
      if (typeof data === 'string') {
        parsed = JSON.parse(data);
      }

      await store.dispatch('auth/doRefreshCurrentUser');

      Message.success(
        `Successfully upgraded to ${parsed.plan} plan`,
      );
    },