robotizer.rb

#!/usr/bin/env ruby

# Inspired from https://github.com/SuperTux88/mumble-bots/blob/master/mumble-music.rb and changed, and changed, and changed
# maybe Code differs more then parts are similar. BTW! only a part of this code is grown in my own brain :@)

# IMPORTANT!
#	At your server had to exist a channel named 'away' and the bots MUST have permission to enter this channel.
#	The bots are automatically created, so you have no chance to register it all :) 
#	Kicking one bot will result in an error and all bots will leave. (They are one family)
#
# What is needed?
#
# You have to checkout 
#	*	https://github.com/dafoxia/opus-ruby
#	*	https://github.com/dafoxia/mumble-ruby
# 			-> mumble2mumble branch!
#
# Build and install gem opus-ruby first, then mumble-ruby
#
# I'm sure more help will be find on Natenom's Sites soon. ( http://natenom.name/ )
#
#

require "mumble-ruby"
require 'rubygems'
require 'thread'
require 'benchmark'

class RobotizerBot
	attr_reader :cli, :host, :port
	attr_writer :awaytime, :disconnecttime
    def initialize botname, bitrate, host, port
		@host =	host
		@port = port
		@myname = botname
		@awaytime = 60
		@disconnecttime = 120
		
		@cli = Mumble::Client.new(host, port) do |conf|
        	conf.username = botname
            conf.password = ""
            conf.bitrate = bitrate
        end
		@bitrate = bitrate
		@prefix = botname
		@activebots = []
		@conn_and_join	= Queue.new
		@create	= Queue.new
		@mychilds = []
		@modulator = []
		(1..120).each do |count|
			@modulator[count-1] = 12.0 / count
			puts @modulator[count-1]
		end
		@modulator += @modulator
		@modulator += @modulator
		@modulator += @modulator
		@modulator += @modulator
    end

	def connect channel, channel2, away, foreignhost, foreignport
		@homechannel = channel2
		@mchan = channel
		@foreignhost = foreignhost
		@foreignport = foreignport
        @cli.connect
		@away = away
		while !@cli.ready
		end
        @cli.join_channel(channel)
		@channelid = @cli.me.channel_id
		@cli.on_text_message do |msg|
			begin
				message = msg.message.split(' ')
				case message[0]
					when "help"
						@cli.text_user(msg.actor, 'please say !help')
					when "!help"
						@cli.text_user(msg.actor, 'No help at this moment. Sorry!')
				end
			end
		end
	end
	
    def get_ready 
		@cli.mumble2mumble true
    end
	
	def run prefix
		@otherprefix = prefix
		spawn_thread :playit
		spawn_thread :termbots
		spawn_thread :speakerworker
	end

	def termbots
		@mychilds.each_with_index do |zeit, index|
			if ( zeit != nil ) && @activebots[index].connected? then
				@activebots[index].join_channel(@away) if  ( ( Time.now - zeit ) >= @awaytime )							# go to away if @awaytime seconds no audio from user appeared
				@activebots[index].disconnect if ( ( Time.now - zeit) >= @disconnecttime ) 								# disconnect bot if @disconnecttime seconds no audio from user appeared
			end
		end
		sleep 1
		
	end
	
	def	speakerworker
		while @create.size >= 1 do 																						# if create-queue is not empty
			index = @create.pop																							# pop a user session number
			if (@activebots[index] == nil) then																			# if bot not exist
				@activebots[index] = Mumble::Client.new(@foreignhost, @foreignport) do |conf|							# create bot socket
					conf.username = @prefix + @cli.users.values_at(index).[](0).name
					conf.password = ""
					conf.bitrate = @bitrate
				end
			end
		end
		
		while @conn_and_join.size >= 1 do																				# if conn and join queue is not empty
			index = @conn_and_join.pop																					# pop a user session number
			if @activebots[index].connected? == false then																# if bot not connected
				@activebots[index].connect																				# connect it to server
				while !@activebots[index].ready
				end																										# wait until we can join
				@activebots[index].mumble2mumble false																	# activate bot
				msg = @activebots[index].get_imgmsg('./icons/m2muser.png')
				@activebots[index].set_comment msg
			end
			while @activebots[index].me.channel_id == nil 
				@activebots[index].join_channel(@homechannel)															# join channel
			end
		end
		sleep 0.1
	end
	
	def playit 
		speakers = @cli.m2m_getspeakers
		maxsize =0
		x = Benchmark.measure { 
			speakers.each do |sessionid|
				if ( sessionid != nil ) then
					if ( @cli.users.values_at(sessionid).[](0) != nil ) then
						if ( @cli.users.values_at(sessionid).[](0).name[0..(@otherprefix.size - 1)] != @otherprefix ) then		# real user
							if @activebots[sessionid] != nil then																# if bot exist
								if ( @activebots[sessionid].connected? ) then													# and connected
									speakersize = @cli.m2m_getsize sessionid
									maxsize =  speakersize if speakersize >= maxsize
									if maxsize >= 1 then
										@activebots[sessionid].join_channel(@homechannel) if @activebots[sessionid].me.channel_id != @homechannel 
										frame = ( @cli.m2m_getframe ( sessionid ) ).unpack ('s*')
										newframe = []
										frame.each_with_index do |sample, index|
											sample = sample * ( (index % 120) / 60)
											newframe << sample
										end
										frame = newframe.pack('s*')
										@activebots[sessionid].m2m_writeframe frame
										@mychilds[sessionid] = Time.now
									end
								end
								@conn_and_join << sessionid																		# of not connected - fill in in connect queue
							else																								# if bot not exist
								@create << sessionid																			# fill in create queue
							end
						end
					end
				end
			end
		}
		if ( 0.007 - x.real ) >= 0 then																						# full loop time should not exceed 0.01 s ( 10 ms)
			sleep  ( 0.007 - x.real ) 																						# we'll keep it slightly shorter that we can hurry up if need
		end
	end

	def spawn_thread(sym)
      Thread.new { loop { send sym } }
    end
    
end


@server1_name = "soa.chickenkiller.com"
@server1_port = 64739
@server1_bitrate = 72000
@server1_channel = "NatenomConnect"
@server1_awaychan = "away"
@server1_time2away = 60
@server1_time2disconnect = 120
@server1_BotName = '1' +@server1_name + '_'

@server2_name = "soa.chickenkiller.com"
@server2_port = 64739
@server2_bitrate = 72000
@server2_channel = "Interconnect"
@server2_awaychan = "Interconnect"
@server2_time2away = 60
@server2_time2disconnect = 120
@server2_BotName = '2' +@server2_name + '_'

# BOT-NAME has to be different when spawn on one server!

client1 = RobotizerBot.new @server1_BotName, @server2_bitrate, @server1_name, @server1_port
client2 = RobotizerBot.new @server2_BotName, @server1_bitrate, @server2_name, @server2_port

client1.connect @server1_channel, @server2_channel, @server2_awaychan, client2.host, client2.port
client2.connect @server2_channel, @server1_channel, @server1_awaychan, client1.host, client1.port

client1.get_ready 
client2.get_ready

client2.run @server1_BotName
client1.run @server2_BotName

msg1 = '<a href="mumble://' + client2.host.to_s + ':' + client2.port.to_s + '"><h1>Interconnect-Bot</h1></a>' + client2.cli.get_imgmsg('./icons/mumble2mumble256x256.png')
msg2 = '<a href="mumble://' + client1.host.to_s + ':' + client1.port.to_s + '"><h1>Interconnect-Bot</h1></a>' + client1.cli.get_imgmsg('./icons/mumble2mumble256x256.png')
client1.cli.set_comment msg1
client2.cli.set_comment msg2
puts "running...  ctrl-d to end!"

begin
	t = Thread.new do
		$stdin.gets
          end
	t.join
	rescue Interrupt => e
 end