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 = 404res.end('no such location')- })
+}).listen(11301)
2.23.0