jetstream-data-sync.desktop.controller.ts

import { HTTP } from '@jetstream/shared/constants';
import { app } from 'electron';
import { z } from 'zod';
import { ENV } from '../config/environment';
import { createRoute, getTokens, handleErrorResponse, RouteValidator } from '../utils/route.utils';

/**
 * FIXME: this file needs to be worked on
 */

export const routeDefinition = {
  pull: {
    controllerFn: () => pull,
    validators: {
      query: z.any(),
      hasSourceOrg: false,
    } satisfies RouteValidator,
  },
  push: {
    controllerFn: () => push,
    validators: {
      query: z.any(),
      body: z.any(),
      hasSourceOrg: false,
    } satisfies RouteValidator,
  },
};

const pull = createRoute(routeDefinition.pull.validators, async ({ query }) => {
  try {
    const { authTokens, extIdentifier } = getTokens();

    return await fetch(`${ENV.SERVER_URL}/desktop-app/data-sync/pull?${new URLSearchParams(query).toString()}`, {
      method: 'GET',
      headers: {
        Accept: 'application/json',
        Authorization: `Bearer ${authTokens?.accessToken}`,
        [HTTP.HEADERS.X_EXT_DEVICE_ID]: extIdentifier.id,
        [HTTP.HEADERS.X_APP_VERSION]: app.getVersion(),
      },
    });
  } catch (ex) {
    return handleErrorResponse(ex);
  }
});

const push = createRoute(routeDefinition.push.validators, async ({ query, body }) => {
  try {
    const { authTokens, extIdentifier } = getTokens();

    return await fetch(`${ENV.SERVER_URL}/desktop-app/data-sync/push?${new URLSearchParams(query).toString()}`, {
      method: 'POST',
      headers: {
        Accept: 'application/json',
        'Content-Type': 'application/json',
        Authorization: `Bearer ${authTokens?.accessToken}`,
        [HTTP.HEADERS.X_EXT_DEVICE_ID]: extIdentifier.id,
        [HTTP.HEADERS.X_APP_VERSION]: app.getVersion(),
      },
      body: JSON.stringify(body),
    });
  } catch (ex) {
    return handleErrorResponse(ex);
  }
});