View Options

	diff --git a/Wearg/Notifications.tcl b/Wearg/Notifications.tcl
	index e375975..4fbe56a 100644
	--- a/Wearg/Notifications.tcl
	+++ b/Wearg/Notifications.tcl
	@@ -1,113 +1,114 @@
	package require json

	namespace eval notifications {
	proc init {} {
	::broker::bind [registry get broker.queue.notifications] ::notifications::on_broker_message

	bind * * * * ::notifications::channel_notify
	}

	proc bind {service project group type callback} {
	global notificationsbinds
	set entry [list $service $project $group $type $callback]

	if {[info exists notificationsbinds]} {
	foreach bind $notificationsbinds {
	if {$bind == $entry} {
	# Bind is already here
	return
	}
	}
	}

	lappend notificationsbinds $entry
	}

	proc binds {} {
	global notificationsbinds

	if {[info exists notificationsbinds]} {
	return $notificationsbinds
	}

	return ""
	}

	proc is_matching_notification_bind {bind notification} {
	set bindFields "service project group type callback"

	# We want to ensure the first four bind fields match the values of the notification dictionary
	foreach $bindFields $bind {}
	set fields [lrange $bindFields 0 end-1]
	foreach field $fields {
	if {![string match [set $field] [dict get $notification $field]]} {
	return 0
	}
	}

	return 1
	}

	proc on_broker_message {queue message} {
	set notification [json::json2dict $message]
	set message [dict get $notification text]

	foreach field "service project group rawContent type text link" {
	lappend params [dict get $notification $field]
	}

	set matchingBinds 0
	foreach bind [binds] {
	if {[is_matching_notification_bind $bind $notification]} {
	set callback [lindex $bind 4]
	$callback {*}$params
	incr matchingBinds
	}
	}
	if {$matchingBinds == 0} {
	putdebug "No bind for queue $queue message $message"
	}
	}

	proc get_notification_channel {project group} {
	if {$project == "Wolfplex"} {
	return "#wolfplex"
	}
	if {$project == "Keruald"} {
	return "#nasqueron-logs"
	}
	if {$project == "Nasqueron"} {
	switch $group {
	tasacora { return "#tasacora" }
	docker { return "#nasqueron-ops" }
	ops { return "#nasqueron-ops" }
	orgz { return "#nasqueron-ops" }
	+ devtools { return "#nasqueron-logs" }
	nasqueron { return "#nasqueron-logs" }
	default {
	putdebug "Message for unknown group: $project $group"
	return "#nasqueron-logs"
	}
	}
	}
	return ""
	}

	proc channel_notify {service project group rawContent type text link} {
	set channel [get_notification_channel $project $group]
	if {$channel == ""} {
	return
	}

	set message $text
	if {$link != ""} {
	append message " — $link"
	}

	if {$service == "Phabricator" \|\| $type == "push" \|\| $type == "ping" \|\| $type == "repository" \|\| $type == "create" \|\| $type == "status"} {
	putquick "PRIVMSG $channel :$message"
	} {
	# These probably need some love on the notifications center
	putdebug "Message for $channel: $message (service: $service, type: $type)"
	}
	}
	}

File Metadata

Mime Type: text/x-diff
Expires: Mon, Nov 25, 15:15 (1 d, 4 h)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 2260446
Default Alt Text: (3 KB)

No OneTemporary
Actions

View Options

File Metadata

Event Timeline

No OneTemporaryActions

View Options

File Metadata

Event Timeline

No OneTemporary
Actions