test_project/src/actions/index.js

const getGQL = url => 
    (query, variables={}) => fetch(url, {
        method: 'POST',
        headers: {
            "Content-Type": "application/json",
            ...(localStorage.authToken ? {Authorization: "Bearer " + localStorage.authToken } : {})
        },
        body: JSON.stringify({query, variables})
    }).then(res => res.json())

export const actionPending = name => ({type: 'PROMISE', status: 'PENDING', name})
export const actionResolved = (name, payload) => ({type: 'PROMISE', status: 'RESOLVED', name, payload})
export const actionRejected = (name, error) => ({type: 'PROMISE', status: 'REJECTED', name, error})

let shopGQL = getGQL('/graphql')

export const actionPromise = (name, promise) => 
    async dispatch => {
        dispatch(actionPending(name))
        try{
            let payload = await promise
            dispatch(actionResolved(name, payload)) 
            return payload
        }
        catch(error){
             dispatch(actionRejected(name, error))
        }
    }

const actionAuthLogin = token => ({type:'LOGIN', token})
export const actionAuthLogout = () => ({type:"LOGOUT"})

let log = async (login, password) => {
  let query = `query log($l: String!, $p: String!) {
        login(login: $l, password: $p)
      }`

  let variables = {
      "l": login,
      "p": password
  }

  let token = await shopGQL(query, variables)
  console.log(token)
  return token.data.login
}

const actionLogin = (login, password) => actionPromise("login", log(login, password))

export const actionFullLogin = (login, password) => {
  return async (dispatch) => {
      let result = await dispatch(actionLogin(login, password))
      if(result) {
          dispatch(actionAuthLogin(result))
          dispatch(actionUserInfo())
      }
  }
}

const actionRegister = (login,password) =>
    actionPromise('reg',shopGQL(`mutation reg($login: String!, $password: String!){
        createUser(login:$login, password: $password){
        _id login
    }
}`,{login,password}))

export const actionFullRegister = (login,password) => 
  async dispatch => {
    let payload = await dispatch(actionRegister(login,password))
    if(payload.data.createUser != null){
      await dispatch(actionFullLogin(login,password))
    }
    else {
      console.log("exiciting user")
    }
  }

export const actionTypeAd = (_id,title) =>
    actionPromise('AdFind', shopGQL(`
            query Ad($query:String){
              AdFind(query:$query){
                _id  
                title
                description
                price
                images {
                  url
                }
                comments {
                  _id text owner {login} answerTo { owner { login}}
                }
                createdAt
                owner {login}
              }
            }
        `, {query: JSON.stringify([{field: title},{sort: [{_id: -1}]}])}))

export const actionTypeAdOne = (id) => 
          actionPromise('AdFindOne',shopGQL(`
            query Ad($query:String){
              AdFindOne(query:$query){
                _id
                title
                description
                price
                images {
                  url
                }
                comments {
                  _id text owner {login} answerTo { text owner{ login}}
                }
                createdAt
                owner {login , createdAt}
              }
            }`,{query: JSON.stringify([{_id:id}])}))


// export const actionComments = (ad) => 
//             actionPromise('Comments',shopGQL(`
//             query Comments($query: String){
//               CommentFind(query: $query){
//                 _id
//                 text
//                 owner {login}
//                 ad {_id}
//                 answerTo {text owner{login}}
//               }
//             }`,{query: JSON.stringify([{}])}))

export const actionPostAd = (title,description,price,_id) =>
            actionPromise('PostAd',shopGQL(`
            mutation Post($ad: AdInput){
              AdUpsert(ad: $ad) {
                  _id
                  title
                  description
                  price
                  images {
                    url
                  }
                }
              }`,{ad: {title,description,price,_id}}))

export const actionMyPosts = () =>
    async (dispatch,getState) => {
      let userId = getState().authReducer.payload.sub.id
      return await dispatch(actionPromise('MyPosts',shopGQL(`
        query MyPosts($query: String){
          AdFind(query: $query){
            _id  
            title
            description
            price
            images {
              url
            }
            comments {
              _id text owner {login} answerTo { owner { login}}
            }
          }
        }`,{query: JSON.stringify([{___owner: userId}])})))
      }
    
// export const actionCommentAdd = () =>
//               actionPromise('CommentAdd',shopGQL(`
//               mutation Comment($comment : CommentInput){
//                 CommentUpsert(comment: $comment) {
//                   _id
//                   ad
//                   text
//                 }
//               }`,{comment:{text,answerTo,ad:{_id}}}))

export const actionUploadFile = (file) => {
  let fd = new FormData
  fd.append('photo', file)
  return actionPromise('photo',fetch('/upload', {
    method: "POST",
    headers: localStorage.authToken ? {Authorization: 'Bearer ' + localStorage.authToken} : {},
    body: fd
  }).then(res => res.json()))
};

const actionAvaAdd = (avaId) => 
async (dispatch,getState) => {
  let userId = getState().authReducer.payload.sub.id
  await dispatch (actionPromise('ava',shopGQL(`mutation setAvatar($userId: String, $avaId: ID){
  UserUpsert(user:{_id: $userId, avatar: {_id: $avaId}}){
      _id, avatar{
          _id
      }
  }
}`,{avaId,userId})))
}

export const actionAvaChange = (file) => 
  async (dispatch) => {
   let res =  await dispatch(actionUploadFile(file))
   if(res) {
     await dispatch(actionAvaAdd(res._id))
     await dispatch(actionUserInfo())
   }
  }

export const actionUserInfo = () => 
  async (dispatch,getState) => {
    let userId = getState().authReducer.payload.sub.id
    await dispatch(actionPromise('UserInfo',shopGQL(`
      query UserInfo($query:String){
        UserFindOne(query: $query){
          _id login avatar {url}
        }
      }`,{query: JSON.stringify([{_id: userId}])})))
  }


const regexp = (string) => `/${string.split([" "]).join(['|']).trim()}/`
const toQuery = (queryString, fields = ["title", "description"]) => ({ $or: fields.map(string => ({ [string]: regexp(queryString) }))})
export const actionSearch = (queryString) => 
async (dispatch) =>
  await dispatch(actionPromise('SearchAd',shopGQL(`
  query AdFind($query: String){
    AdFind(query: $query) {
      _id
      title
      description
      price
      images {
        url
      }
    }
  }`,{query: JSON.stringify([toQuery(queryString),
      {
        sort: [{_id: -1}],
        limit: [15]
      }]
    )}
  )
))

// const toRegexp2 = queryString => `/${queryString.split([" "]).join(['|']).trim()}/`
// const toQuery = (queryString, fields = ["id3.artist", "id3.title", "id3.album"]) => ({ $or: fields.map(x => ({ [x]: toRegexp2(queryString) })) })

// const actionSearch = (queryString) =>
//     async dispatch => {
//         let searchData = await dispatch(actionPromise('search', gql(
//             `query trackFind($query: String) {
//             TrackFind(query:$query)
//               {
//                   originalFileName
//                   url
//                   id3 {
//                           title
//                           artist
//                           album
//                       }
//               }
//           }`, {
//             query: JSON.stringify([toQuery(queryString),
//             {
//                 sort: [{ _id: -1 }], //сортировка в обратном хронологическом порядке
//                 limit: [10],  //100 записей максимум
//             }])
//         }
//         )))
//         console.log(searchData)
//     }