On Thu, Nov 05, 2020 at 03:08:23PM +0800, Li Yuanchao wrote:

webhook.js will listen to webhook message from 'gitee.com' or 'github.com' if catch 'push' message, call push_hook.rb to send message to git-mirror through message queue

Signed-off-by: Li Yuanchao lyc163mail@163.com

container/webhook/root/push_hook.rb | 15 +++++++++++++++ container/webhook/root/webhook.js | 22 ++++++++++++++++++++++ 2 files changed, 37 insertions(+) create mode 100755 container/webhook/root/push_hook.rb create mode 100755 container/webhook/root/webhook.js

diff --git a/container/webhook/root/push_hook.rb b/container/webhook/root/push_hook.rb new file mode 100755 index 0000000..e467ccd --- /dev/null +++ b/container/webhook/root/push_hook.rb @@ -0,0 +1,15 @@ +#!/usr/bin/env ruby +# SPDX-License-Identifier: MulanPSL-2.0+ +# Copyright (c) 2020 Huawei Technologies Co., Ltd. All rights reserved. +# frozen_string_literal: true

+require 'bunny'

+connection = Bunny.new('amqp://172.17.0.1:5672') +connection.start +channel = connection.create_channel

The blank line can be deleted.

Thanks, Xijian

+queue = channel.queue('web_hook') +message = ARGV[0] +queue.publish(message) +connection.close diff --git a/container/webhook/root/webhook.js b/container/webhook/root/webhook.js new file mode 100755 index 0000000..a98576c --- /dev/null +++ b/container/webhook/root/webhook.js @@ -0,0 +1,22 @@ +const http = require('http') +const spawn = require('child_process').spawn +const createHandler = require('git-webhook-handler') +// if users want to use webhook, they need to config webhook on their code warehouse('gitee.com' or 'github.com'), +// and use url: http://183.134.196.212:11301/webhook, secret: webhook@git. +const handler = createHandler({ path: '/webhook', secret: 'webhook@git' })

+handler.on('error', function(err){

• console.error('Error:', err.message)

+})

+handler.on('push', function(event){

• console.log(event.payload.repository.url)
• spawn('ruby', ['push_hook.rb', event.payload.repository.url])

+})

+http.createServer(function(req, res){

• handler(req, res, function(err){

• res.statusCode = 404
  

• res.end('no such location')
  

• })

+}).listen(11301)

2.23.0