activities.js

import gql from 'graphql-tag';
import { client } from './apollo'
// const { createDBConnection } = require('./mongo')

const getActivity = async (portfolio) => {
  const q = gql`
      query ActivityByPortfolioId($portfolio: String!) {
        activityByPortfolioId(portfolio: $portfolio, _size: 9999) {
          data {
            _id
            type
            holding
            isin
            amount
            company
            price
            shares
            date
            broker
            portfolio
          },
        }
      }
    `;

  const result = await client.query({ query: q, variables: { portfolio } })

  return result.data.activityByPortfolioId.data;;
}

const createActivities = async (activities) => {
  console.log('Create Activities', activities.length)

  const promises = activities.map((a) => {
    const q = gql`mutation createActivity($ActivityInput: ActivityInput!) {
      createActivity(data: $ActivityInput)
      { 
        _id
        type
        holding
        isin
        amount
        company
        price
        broker
        shares
        date
        portfolio
      }
    }`;

    return client.mutate({
      mutation: q,
      variables: {
        ActivityInput: a
      }
    })
  })


  return Promise.all(promises).then((res) => {
    return res.map((r) => r.data.createActivity)
  })
}

const updateActivity = async (id, activity) => {
  const q = gql`mutation UpdateAnActivity($ActivityInput: ActivityInput!, $id: ID!) {
    updateActivity(id: $id, data: $ActivityInput)
    { 
      _id
      type
      holding
      isin
      amount
      company
      price
      shares
      broker
      date
      portfolio
    }
  }`;

  return client.mutate({
    mutation: q,
    variables: {
      id: id,
      ActivityInput: activity
    }
  }).then((res) => {
    return res.data.updateActivity;
  })
}

const deleteActivity = async (id) => {
  const q = gql`mutation DeleteAnActivity($id: ID!) {
    deleteActivity(id: $id)
    { 
      _id
    }
  }`;

  return client.mutate({
    mutation: q,
    variables: {
      id: id,
    }
  }).then((res) => {
    return res.data.deleteActivity._id
  })
}

export { getActivity, createActivities, updateActivity, deleteActivity }