Auto Deploy for Van!
目前為
// ==UserScript==
// @name Van Deploy
// @namespace http://tampermonkey.net/
// @version 0.5.0
// @description Auto Deploy for Van!
// @author Alexander
// @match https://van.huolala.work/projects/835/*
// @match https://van.huolala.work/projects/833/*
// @icon data:image/gif;base64,R0lGODlhAQABAAAAACH5BAEKAAEALAAAAAABAAEAAAICTAEAOw==
// @grant none
// @license MIT
// ==/UserScript==
(function() {
'use strict';
// console.log(' van deploy is running ')
let monitor
const startTime = new Date().getTime()
const sleep = (time = 1000) => new Promise(resolve => setTimeout(resolve, time));
const committerDeployMap = {
'pk.peng': 'stable-1',
'alexander.xie': 'stable-2',
'james.fu': 'stable-3',
'edison.ma': 'stable-4',
}
class DeployTask {
constructor(config) {
this.id = config.id // building id
this.branch = config.branch // branch
this.committer = config.user // committer
this.startTime = new Date().getTime()
// this.config = config
this.status = 'pending' // pending, success, failed, deploying , deployed, undeployed
this.queryId = undefined
this.deployInterval = undefined
this.start()
}
getDom() {
const taskDom = Array.from(document.getElementsByTagName('strong')).find(dom => dom.innerText === this.id)
return taskDom ? taskDom.parentNode.parentNode : null
}
async start () {
try {
console.log('task ', this.id, ' start')
this.status = 'pending'
await this.query()
await this.queueForDeply()
console.log('task is deploying ', this.id)
this.status = 'deploying'
await this.deploy()
this.stop()
} catch (error) {
console.log('deploy error ', error)
this.stop()
}
}
async query() {
return new Promise((resolve, reject) => {
this.queryId = setInterval(() => {
console.log(this.id, ' building status query ')
const dom = this.getDom()
if (!dom) {
return
}
console.log('task is pending', this.id)
const status = dom.getElementsByClassName('anticon')[0].className.split(' ')
if (status.some(classItem => ['anticon-check-circle'].includes(classItem))) {
clearInterval(this.queryId)
this.status = 'success'
resolve()
}
if (status.some(classItem => ['anticon-close-circle'].includes(classItem))) {
clearInterval(this.queryId)
this.status = 'failed'
reject()
}
}, 1000)
})
}
async queueForDeply () {
return new Promise((resolve, reject) => {
console.log('queue for deploy ', this.id)
this.deployInterval = setInterval(() => {
if (monitor.canDeploy()) {
clearInterval(this.deployInterval)
resolve()
}
}, 500)
})
}
async deploy() {
const dom = this.getDom()
let deployed = false
if (!dom) {
return
}
dom.click()
await sleep(3000)
if (!document.getElementsByClassName('ant-dropdown')[0] || getComputedStyle( document.getElementsByClassName('ant-dropdown')[0]).display === 'none') {
document.querySelector('.publish-btn-check button').click()
}
await sleep(1000)
Array.from(document.getElementsByClassName('fast-publish-btn-menu')[0].getElementsByClassName('ant-menu-item-group')).forEach(envDom => {
const envName = envDom.getElementsByClassName('ant-menu-item-group-title')[0].innerText.toLocaleLowerCase().trim()
if (this.branch.includes(envName) ) {
// stg、pre分支发对应的环境
envDom.getElementsByClassName('ant-space-item')[0].click()
} else if (['stg', 'pre'].includes(envName.toLocaleLowerCase())) {
// 特性分支 发stg和pre对应的个人环境
const deployName = committerDeployMap[this.committer]
// envDom.getElementsByClassName('ant-space-item')[0].click()
Array.from(envDom.getElementsByClassName('ant-space-item')).forEach(dployDom => {
if (dployDom.innerText === deployName) {
dployDom.click()
}
})
}
deployed = true
// env.getElementsByClassName('ant-space-item')
})
await sleep(300)
document.querySelector('.publish-btn-check button').click()
if (deployed) {
this.status = 'deployed'
return Promise.resolve()
}
this.status = 'undeployed'
return Promise.reject()
}
stop() {
// deployed, failed
console.log('monitor ', this.queryId, ' stop')
clearInterval(this.queryId)
clearInterval(this.deployInterval)
}
}
class DeloyMonitor {
constructor() {
this.tasksQueue = []
this.monitorId = undefined
this.hibernateId = undefined
}
getTaskNodes () {
let count = 0
let queryIntervalId
const getNodes = () => {
try {
const parentNode = document.getElementsByClassName('task-list-sider__list')[0]
const nodes = parentNode.getElementsByClassName('task-card')
return nodes
} catch (error) {
return null
}
}
return new Promise((resolve, reject) => {
queryIntervalId = setInterval(() => {
count++;
const nodesout = getNodes()
if (nodesout) {
clearInterval(this.hibernateId)
return resolve(nodesout)
}
if (count > 60) {
clearInterval(queryIntervalId)
return reject()
}
}, 1000);
})
}
parseNode(node) {
const id = node.getElementsByClassName('first-line')[0].getElementsByTagName('strong')[0].innerText
const branch = node.getElementsByClassName('branch')[0].innerText.trim()
const user = node.getElementsByClassName('second-line')[0].getElementsByTagName('strong')[0].innerText.split(' ')[1];
// const status = node.className.split(' ')[1];
// pending : anticon-sync anticon-spin
// success : anticon-check-circle
// failed : anticon-close-circle
// deployed : anticon-flag
const status = node.getElementsByClassName('anticon')[0].className.split(' ')
// console.log('id', id, 'status', status)
return { id, branch, user, status }
}
getCurrentUser() {
try {
const myCookie = document.cookie.split(';').reduce((acc, cur) => {
const [key, value] = cur.trim().split('=');
acc[key] = value
return acc
}, {})
const jsonStr = decodeURIComponent(myCookie?.sensorsdata2015jssdkcross || '{}')
const user = JSON.parse(jsonStr)?.distinct_id
return user
} catch (error) {
console.log('parse cookie error', error)
}
}
start () {
if (this.monitorId) {
return console.error('DeloyMonitor has already runned')
}
this.monitorId = setInterval(async () => {
console.log('deloyMonitor is running')
if (!navigator.onLine) {
this.hibernate()
}
try {
const taskNodes = await this.getTaskNodes();
console.log('taskNodes 999', taskNodes)
if (!taskNodes) {
setTimeout(this.reload, 1000)
}
Array.from(taskNodes).forEach(node => {
const { id, branch, user, status } = this.parseNode(node)
console.log('task user', user, this.getCurrentUser())
// add new task
const task = this.tasksQueue.find(item => item.id === id)
const isStgPre = branch.includes('stg') || branch.includes('pre')
const waitingDeploy = status.some(statusClass => ['anticon-sync', 'anticon-spin'].includes(statusClass))
const isMyPush = user === this.getCurrentUser()
// if (isStgPre && !task && waitingDeploy && isMyPush) {
if (isMyPush && !task && waitingDeploy) {
const task = new DeployTask({ id, branch, user, status })
console.log('add new task ', id , task)
this.tasksQueue.push(task)
}
// remove when failed , deployed
if (status.some(statusClass => ['anticon-close-circle', 'anticon-flag'].includes(statusClass))) {
const taskIndex = this.tasksQueue.findIndex(item => item.id === id)
taskIndex !== -1 && console.log('will remove task ', id , task, 'taskIndex', taskIndex)
if (taskIndex !== -1) {
task.stop()
this.tasksQueue.splice(taskIndex, 1)
}
}
// remove when success but undeployed
if (status.some(statusClass => ['anticon-check-circle'].includes(statusClass))) {
const taskIndex = this.tasksQueue.findIndex(item => item.id === id)
const successTask = this.tasksQueue[taskIndex]
if (['undeployed', 'pending'].includes(successTask?.status)) {
successTask.stop()
this.tasksQueue.splice(taskIndex, 1)
}
}
})
} catch (err) {
this.reload()
} finally {
console.clear()
const timespan = parseInt((new Date().getTime() - startTime) / 1000)
console.log('at time', timespan , 'tasks are ',[...this.tasksQueue])
timespan > 3600 && this.reload()
}
}, 5000)
}
stop () {
console.log('monitor stop')
this.tasksQueue.forEach(task => task.stop())
clearInterval(this.monitorId)
this.monitorId = undefined
}
canDeploy (){
return !this.tasksQueue.some(task => task.status === 'deploying')
}
reload() {
window.location.reload()
}
hibernate () {
console.log('hibernate')
this.stop()
this.tasksQueue = []
this.hibernateId = setInterval(() => {
if (navigator.onLine) {
this.start()
clearInterval(this.hibernateId)
this.hibernateId = undefined
}
}, 60 * 1000)
}
}
monitor = new DeloyMonitor()
monitor.start();
window.onbeforeunload = function(e) {
monitor.stop();
};
window.addEventListener('online', () => monitor.start());
window.addEventListener('offline', () => monitor.hibernate());
})();