gitlab.ts

import axios from 'axios'
import fs from 'fs'
import formData from 'form-data'

const env = process.env.NODE_ENV || 'testing'
const config = require('../config/config')[env]

const gitlab = {
  getUserByEmail: async function (email: string) {
    return await axios({
      method: 'get',
      url: 'https://transfer.hft-stuttgart.de/gitlab/api/v4/users?search=' + email,
      headers: { Authorization: 'Bearer ' + config.gitlab.token_readWriteProjects }
    })
      .then(res => res.data[0])
      .catch(function (err) {
        console.error(err)
        return null
      })
  },
  createNewPages: async function (newPagesData: any, newLogoFile: string, template: any) {
    const data = new formData()
    data.append('avatar', fs.createReadStream(newLogoFile))

    return await axios({
      method: 'post',
      url: 'https://transfer.hft-stuttgart.de/gitlab/api/v4/projects/user/' + newPagesData.getOwnerGitlabId() +
                '?name=' + newPagesData.getName() + '&description=' + newPagesData.getDesc() + '&tag_list=website' +
                '&use_custom_template=true&template_name=' + template,
      headers: {
        Authorization: 'Bearer ' + config.gitlab.token_readWriteProjects,
        ...data.getHeaders()
      },
      data: data
    })
      .then(res => res.data)
      .catch(function (err) {
        console.error('ERR Status: ' + err.response.status)
        console.error('ERR Name: ' + err.response.data.message.name)
        console.error('ERR Path: ' + err.response.data.message.path)
        return err.response
      })
  },
  updateProject: async function (updatedProjectData: any, newLogoFile: string) {
    const data = new formData()
    if (newLogoFile) {
      data.append('avatar', fs.createReadStream(newLogoFile))
    }

    return await axios({
      method: 'put',
      url: 'https://transfer.hft-stuttgart.de/gitlab/api/v4/projects/' + updatedProjectData.getId() +
                '?name=' + updatedProjectData.getName() + '&description=' + updatedProjectData.getDesc(),
      headers: {
        Authorization: 'Bearer ' + config.gitlab.token_readWriteProjects,
        ...data.getHeaders()
      },
      data: data
    })
    // .then(res => res.data[0])
      .then(res => res.data)
      .catch(function (err) {
        console.error('ERR Status: ' + err.response.status)
        console.error('ERR Name: ' + err.response.data.message.name)
        console.error('ERR Path: ' + err.response.data.message.path)
        return err.response
      })
  },
  deleteProjectById: async function (projectId: number) {
    // https://docs.gitlab.com/ee/api/projects.html#delete-project
    return await axios({
      method: 'delete',
      url: 'https://transfer.hft-stuttgart.de/gitlab/api/v4/projects/' + projectId,
      headers: {
        Authorization: 'Bearer ' + config.gitlab.token_readWriteProjects
      }
    })
      .then(res => true)
      .catch(function (err) {
        console.error('ERR Status: ' + err.response.status)
        console.error('ERR Name: ' + err.response.data.message.name)
        console.error('ERR Path: ' + err.response.data.message.path)
        return false
      })
  },
  getUserProjects: async function (gitlabUserId: number) {
    return await axios({
      method: 'get',
      url: 'https://transfer.hft-stuttgart.de/gitlab/api/v4/users/' + gitlabUserId + '/projects?owned=true&visibility=public',
      headers: {
        Authorization: 'Bearer ' + config.gitlab.token_readWriteProjects
      }
    })
      .then(res => res.data)
      .catch(function (err) {
        console.error(err)
        return null
      })
  },
  getProjectById: async function (projectId: number) {
    return await axios({
      method: 'get',
      url: 'https://transfer.hft-stuttgart.de/gitlab/api/v4/projects/' + projectId,
      headers: {
        Authorization: 'Bearer ' + config.gitlab.token_readWriteProjects
      }
    })
      .then(res => res.data)
      .catch(function (err) {
        console.error(err)
        return null
      })
  },
  getProjectPipelineLatestStatus: async function (projectId: number) {
    return await axios({
      method: 'get',
      url: 'https://transfer.hft-stuttgart.de/gitlab/api/v4/projects/' + projectId + '/pipelines'
    })
      .then(res => res.data[0].status)
      .catch(function (err) {
        console.error(err)
        return null
      })
  }
}

export = gitlab