twenty/packages/twenty-chrome-extension/src/db/person.db.ts

import {
  CreatePersonResponse,
  FindPersonResponse,
  PersonInput,
} from '~/db/types/person.types';
import { Person, PersonFilterInput } from '~/generated/graphql';
import { CREATE_PERSON } from '~/graphql/person/mutations';
import { FIND_PERSON } from '~/graphql/person/queries';

import { callMutation, callQuery } from '../utils/requestDb';
import { isDefined } from 'twenty-shared/utils';

export const fetchPerson = async (
  personFilterData: PersonFilterInput,
): Promise<Person | null> => {
  const data = await callQuery<FindPersonResponse>(FIND_PERSON, {
    filter: {
      ...personFilterData,
    },
  });
  if (isDefined(data?.people.edges)) {
    return data.people.edges.length > 0
      ? isDefined(data.people.edges[0].node)
        ? data.people.edges[0].node
        : null
      : null;
  }
  return null;
};

export const createPerson = async (
  person: PersonInput,
): Promise<string | null> => {
  const data = await callMutation<CreatePersonResponse>(CREATE_PERSON, {
    input: person,
  });
  if (isDefined(data?.createPerson)) {
    return data.createPerson.id;
  }
  return null;
};