wm: irc-h2o-bot

Info  •  Files  •  Log

Test Files Deleted

--- a/.idea/Test-IRC.iml

+++ b/.idea/Test-IRC.iml

@@ -20,7 +20,6 @@

     <orderEntry type="library" scope="PROVIDED" name="fiber-annotation (v0.2.0, ruby-3.2.1-p31) [gem]" level="application" />

     <orderEntry type="library" scope="PROVIDED" name="fiber-local (v1.0.0, ruby-3.2.1-p31) [gem]" level="application" />

     <orderEntry type="library" scope="PROVIDED" name="io-event (v1.2.2, ruby-3.2.1-p31) [gem]" level="application" />

-    <orderEntry type="library" scope="PROVIDED" name="net-yail (v1.6.2, ruby-3.2.1-p31) [gem]" level="application" />

     <orderEntry type="library" scope="PROVIDED" name="protocol-hpack (v1.4.2, ruby-3.2.1-p31) [gem]" level="application" />

     <orderEntry type="library" scope="PROVIDED" name="protocol-http (v0.24.4, ruby-3.2.1-p31) [gem]" level="application" />

     <orderEntry type="library" scope="PROVIDED" name="protocol-http1 (v0.15.0, ruby-3.2.1-p31) [gem]" level="application" />

--- a/Test_HTTP.rb

+++ /dev/null

@@ -1,44 +1,0 @@

-require 'net/http'

-require 'uri'

-require 'json'

-

-# a = '\n\n'

-# if a.include?('\n')

-#   puts "The string contains '\\n'"

-# else

-#   puts "The string does not contain '\\n'"

-# end

-

-

-uri = URI('https://gpt-gm.h2o.ai/conversation/64ac1344245bd909c99ed909')

-https = Net::HTTP.new(uri.host, uri.port)

-https.use_ssl = true

-

-request = Net::HTTP::Post.new(uri.path)

-

-request['Content-Type'] = 'application/json; charset=UTF-8'

-request['User-Agent'] = 'Mozilla/5.0 Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/113.0.5672.127 Safari/537.36'

-request['Cookie'] = 'h2ogpt-chat=a4fc9f08-6c67-466c-8d36-dd425702d6b4'

-

-request.body = '{"inputs":"aa","parameters":{"temperature":0.1,"truncate":2048,"max_new_tokens":1024,"do_sample":true,"repetition_penalty":1.2,"return_full_text":false},"stream":true,"options":{"id":"6543eb99-e311-4f4e-b791-7af4fcbe556b","response_id":"b194833d-e13c-4390-9d7f-3cf4e4d95430","is_retry":false,"use_cache":false,"web_search_id":""}}'

-

-response = https.request(request)

-

-

-json_strings = response.body.split('data:')

-

-parsed_json_objects = []

-

-json_strings.each do |json_str|

-  if json_str != ''

-    parsed_json_objects << JSON.parse(json_str)

-  end

-end

-

-parsed_json_objects.each do |json_obj|

-  result = json_obj['token']['text']

-  if result == '' then

-    break

-  end

-  print result

-end

--- a/Test_JSON.rb

+++ /dev/null

@@ -1,109 +1,0 @@

-require 'json'

-

-# JSON string to be parsed

-#json_string = 'data:{"name": "John", "age": 30, "city": "New York"}'

-

-# Parse the JSON string

-

-#test = json_string.sub('data:', '')

-

-# parsed_json = JSON.parse(test)

-#

-# # Access the values from the parsed JSON

-# name = parsed_json['name']

-# age = parsed_json['age']

-# city = parsed_json['city']

-#

-# # Output the values

-# puts "Name: #{name}"

-# puts "Age: #{age}"

-# puts "City: #{city}"

-

-

-

-data_string = 'data:{"token":{"id":9856,"text":"Hello","logprob":0.0,"special":false},"generated_text":null,"details":null} data:{"token":{"id":9856,"text":"Hello","logprob":0.0,"special":false},"generated_text":null,"details":null}'

-

-m = 'data:{"token":{"id":9856,"text":"Hello","logprob":0.0,"special":false},"generated_text":null,"details":null}\n'+

-  'data:{"token":{"id":12,"text":"!","logprob":0.0,"special":false},"generated_text":null,"details":null}\n'+

-  'data:{"token":{"id":1265,"text":" How","logprob":0.0,"special":false},"generated_text":null,"details":null}\n'+

-  'data:{"token":{"id":418,"text":" can","logprob":0.0,"special":false},"generated_text":null,"details":null}\n'+

-  'data:{"token":{"id":295,"text":" I","logprob":0.0,"special":false},"generated_text":null,"details":null}\n'+

-  'data:{"token":{"id":733,"text":" help","logprob":0.0,"special":false},"generated_text":null,"details":null}\n'+

-  'data:{"token":{"id":299,"text":" you","logprob":0.0,"special":false},"generated_text":null,"details":null}\n'+

-  'data:{"token":{"id":1722,"text":" today","logprob":0.0,"special":false},"generated_text":null,"details":null}\n'+

-  'data:{"token":{"id":42,"text":"?","logprob":0.0,"special":false},"generated_text":null,"details":null}\n'+

-  'data:{"token":{"id":11,"text":"<|endoftext|>","logprob":0.0,"special":true},"generated_text":"Hello! How can I help you today?","details":null}';

-

-

-

-# Split the data string into individual JSON strings

-json_strings = m.split('\n')

-

-# Initialize an array to store the parsed JSON objects

-parsed_json_objects = []

-

-# Iterate over each JSON string and parse it

-json_strings.each do |json_str|

-  if json_str.start_with?('data:')

-    # Remove the leading "data:" prefix

-    json_data = json_str[5..-1]

-

-    # Parse the JSON string and add it to the parsed_json_objects array

-    parsed_json_objects << JSON.parse(json_data)

-  end

-end

-

-# Print the parsed JSON objects

-parsed_json_objects.each do |json_obj|

-  # puts JSON.pretty_generate(json_obj)

-  print json_obj['token']['text']

-end

-

-

-

-

-data_string = 'data:{"token":{"id":9856,"text":"Hello","logprob":0.0,"special":false},"generated_text":null,"details":null} data:{"token":{"id":9856,"text":"Hello","logprob":0.0,"special":false},"generated_text":null,"details":null}'

-

-# Split the data_string on whitespace followed by "data:" to separate each JSON string

-json_strings = data_string.scan(/data:(\{.*?\})/)

-

-parsed_data = []

-

-json_strings.each do |json_str|

-  # Prepend "data:" to the JSON string since it was removed during splitting

-  # json_str = "data:" + json_str

-

-  # Parse the JSON string

-  parsed_data << JSON.parse(json_str)

-end

-

-# Now you have an array of parsed JSON objects

-parsed_data.each do |data|

-  puts data.inspect

-end

-

-

-

-data_string = 'data:{"token":{"id":9856,"text":"Hello","logprob":0.0,"special":false},"generated_text":null,"details":null} data:{"token":{"id":9856,"text":"Hello","logprob":0.0,"special":false},"generated_text":null,"details":null}'

-

-m = 'data:{"token":{"id":9856,"text":"Hello","logprob":0.0,"special":false},"generated_text":null,"details":null}\n'+

-  'data:{"token":{"id":12,"text":"!","logprob":0.0,"special":false},"generated_text":null,"details":null}\n'+

-  'data:{"token":{"id":1265,"text":" How","logprob":0.0,"special":false},"generated_text":null,"details":null}\n'+

-  'data:{"token":{"id":418,"text":" can","logprob":0.0,"special":false},"generated_text":null,"details":null}\n'+

-  'data:{"token":{"id":295,"text":" I","logprob":0.0,"special":false},"generated_text":null,"details":null}\n'+

-  'data:{"token":{"id":733,"text":" help","logprob":0.0,"special":false},"generated_text":null,"details":null}\n'+

-  'data:{"token":{"id":299,"text":" you","logprob":0.0,"special":false},"generated_text":null,"details":null}\n'+

-  'data:{"token":{"id":1722,"text":" today","logprob":0.0,"special":false},"generated_text":null,"details":null}\n'+

-  'data:{"token":{"id":42,"text":"?","logprob":0.0,"special":false},"generated_text":null,"details":null}\n'+

-  'data:{"token":{"id":11,"text":"<|endoftext|>","logprob":0.0,"special":true},"generated_text":"Hello! How can I help you today?","details":null}';

-

-results = data_string.scan(/data:(\{.*?\})/)

-

-parsed_data = results.map { |item| JSON.parse(item[0]) }

-

-parsed_data.each do |data|

-  puts "Name: #{data['token']['text']}"

-  # puts "Age: #{data['age']}"

-  # puts "City: #{data['city']}"

-end

-

--- a/Test_Multi_Threading.rb

+++ /dev/null

@@ -1,94 +1,0 @@

-require 'thread'

-require 'concurrent'

-require 'async'

-require 'async/http/internet'

-

-class Echo

-  include Concurrent::Async

-

-  def echo(msg)

-    sleep(3)

-    print "#{msg}\n"

-  end

-end

-

-horn = Echo.new

-horn.echo('zero')      # synchronous, not thread-safe

-# returns the actual return value of the method

-

-horn.async.echo('one') # asynchronous, non-blocking, thread-safe

-# returns an IVar in the :pending state

-

-horn.async.echo('two') # synchronous, blocking, thread-safe

-# returns an IVar in the :complete state

-

-start = Time.now

-

-Async do |task|

-  http_client = Async::HTTP::Internet.new

-

-  task.async do

-    http_client.get("https://httpbin.org/delay/1.6")

-  end

-

-end

-

-puts "Duration: #{Time.now - start}"

-

-

-executor = Concurrent::ThreadPoolExecutor.new(

-  min_threads: 2,

-  max_threads: 5,

-  max_queue: 10

-)

-

-futures = []

-

-5.times do |i|

-  futures << Concurrent::Future.execute(executor: executor) do

-    puts "Async task #{i} started"

-    sleep(rand(1..5))

-    puts "Async task #{i} finished"

-  end

-end

-

-futures.each(&:wait)

-executor.shutdown

-

-# Define a method that performs some asynchronous task

-def async_task(name)

-  puts "Starting #{name}"

-

-  # Simulate some work

-  sleep(rand(5))

-

-  puts "#{name} completed"

-end

-

-# Create multiple threads for asynchronous execution

-threads = []

-threads << Thread.new { async_task('Task 1') }

-threads << Thread.new { async_task('Task 2') }

-threads << Thread.new { async_task('Task 3') }

-

-# Wait for all threads to complete

-threads.each(&:join)

-

-puts "All tasks completed"

-

-

-

-def Test

-  for i in 0..10 do

-    puts i

-    sleep(rand(0.1..1.0));

-  end

-end

-

-t1 = Thread.new{Test()}

-t2 = Thread.new{Test()}

-puts 'moz'

-t1.join

-

-t2.join

-

--- a/Test_cinch.rb

+++ /dev/null

@@ -1,24 +1,0 @@

-require 'cinch'

-

-hash = { :invalid => :replace, :undef => :replace}

-string = hash.to_s

-

-puts string

-

-bot = Cinch::Bot.new do

-  configure do |c|

-    c.server = 'irc.ircnow.org'

-    c.channels = ['#fpc']

-    c.nick = 'moz0'

-  end

-

-  on :connect do

-    # This block will be executed when the bot connects to the IRC server

-    # You can put your async message sending logic here

-    a = 'a'

-    Channel('#channel').send(a.to_s) # Replace '#channel' with the actual channel name

-    bot.quit # Quit the bot after sending the message

-  end

-end

-

-bot.start

\ No newline at end of file

--- a/ruby-irc.rb

+++ /dev/null

@@ -1,12 +1,0 @@

-require 'IRC'

-

-bot = IRC.new("h2o", "irc.ircnow.org", "6667", "H2O")

-IRCEvent.add_callback('endofmotd') { |event| bot.add_channel('#fpc') }

-IRCEvent.add_callback('invite') { |event| bot.add_channel(event.message) }

-IRCEvent.add_callback('join') { |event|

-    bot.send_message(event.channel, "Hello #{event.from}")

-  IRCEvent.add_callback('privmsg') {|e|

-    puts e.message

-    }

-}

-bot.connect

\ No newline at end of file

--- a/test.rb

+++ /dev/null

@@ -1,254 +1,0 @@

-require 'rubygems'

-require 'net/yail'

-require 'net/http'

-require 'uri'

-require 'json'

-require 'concurrent'

-require 'async'

-require 'async/http/internet'

-require 'async/http/endpoint'

-require 'IRC'

-

-# executor = Concurrent::ThreadPoolExecutor.new(

-#   min_threads: 2,

-#   max_threads: 5,

-#   max_queue: 10

-# )

-

-config = File.read('CONFIG')

-

-parsed_config = JSON.parse(config)

-Server = parsed_config['IRCServer']

-BotNick = parsed_config['BotNickName']

-$URL = parsed_config['SessionUrl']

-$Cookie = parsed_config['SessionCookie']

-

-$irc = Net::YAIL.new(

-  :address    => 'irc.ircnow.org',

-  :username   => 'Moz_Bot',

-  :realname   => 'Moz_Mozak',

-  :nicknames  => ['h2o-bot0']

-)

-

-

-$bot = IRC.new(

-  BotNick,

-  Server,

-  "6667",

-  "H2O")

-

-

-$is = false

-$currentid = ''

-

-

-$irc.on_welcome proc { |event| $irc.join('#fpc') }

-

-

-$irc.on_invite { |event| $irc.join(event.channel) }

-

-$irc.set_callback(:incoming_invite) { |event| $irc.join(event.channel) }

-

-$irc.hearing_ping {|event| $stderr.puts event.inspect}

-

-$irc.hearing_message(:if => {:pm? => true}) do |event|

-  event.handle!

-end

-

-$irc.on_invite     { |e| $irc.join(e.channel) }

-

-#:if => {:message => "bah"}

-@stack = []

-

-def Push(a,b)

-  @stack << {:peer => a, :message => b}

-

-end

-

-def Send

-  $bot.send_message(@stack[0][':peer'], @stack[0][':message'])

-end

-class Sender

-  include Concurrent::Async

-  $irc0 = Net::YAIL.new(

-    :address    => 'irc.ircnow.org',

-    :username   => 'Moz_Bot',

-    :realname   => 'Moz_Mozak',

-    :nicknames  => ['h2o-bot0']

-  )

-  def Wait(peer)

-      $irc.msg(peer, 'Im thinking...')

-  end

-

-  def SendReq(peer, input, c)

-    uri = URI($URL)

-    https = Net::HTTP.new(uri.host, uri.port)

-    https.use_ssl = true

-

-    request = Net::HTTP::Post.new(uri.path)

-

-    request['Content-Type'] = 'application/json; charset=UTF-8'

-    request['User-Agent'] = 'Pedaret Mozilla/5.0 Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/113.0.5672.127 Safari/537.36'

-    request['Cookie'] = $Cookie

-

-    request.body = '{"inputs":"'+ input.to_s() +'","parameters":{"temperature":0.1,"truncate":2048,"max_new_tokens":1024,"do_sample":true,"repetition_penalty":1.2,"return_full_text":false},"stream":true,"options":{"id":"6543eb99-e311-4f4e-b791-7af4fcbe556b","response_id":"b194833d-e13c-4390-9d7f-3cf4e4d95430","is_retry":false,"use_cache":false,"web_search_id":""}}'

-

-

-    # Async do |task|

-

-      # Async do

-      #   endpoint = Async::HTTP::Endpoint.parse('https://gpt-gm.h2o.ai/conversation/64ac1344245bd909c99ed909')

-      #   http = Async::HTTP::Internet.new

-      #

-      #   request = Async::HTTP::Request.new(:post, endpoint.path,

-      #                                      {'Content-Type' => 'application/json; charset=UTF-8'},

-      #                                      {'Cookie' => 'h2ogpt-chat=a4fc9f08-6c67-466c-8d36-dd425702d6b4'},

-      #                                      '{"inputs":"'+ input.to_s() +'","parameters":{"temperature":0.1,"truncate":2048,"max_new_tokens":1024,"do_sample":true,"repetition_penalty":1.2,"return_full_text":false},"stream":true,"options":{"id":"6543eb99-e311-4f4e-b791-7af4fcbe556b","response_id":"b194833d-e13c-4390-9d7f-3cf4e4d95430","is_retry":false,"use_cache":false,"web_search_id":""}}')

-      #

-      #   response = http.call(endpoint, request)

-      #

-      #   # Process the response

-      #   puts "Response code: #{response.status}"

-      #   puts "Response body: #{response.read}"

-      #

-      #

-      # end

-

-      # request = Async::HTTP::Internet.new

-      #

-      # request['Content-Type'] = 'application/json; charset=UTF-8'

-      # request['User-Agent'] = 'Mozilla/5.0 Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/113.0.5672.127 Safari/537.36'

-      # request['Cookie'] = 'h2ogpt-chat=a4fc9f08-6c67-466c-8d36-dd425702d6b4'

-      #

-      # request.body = '{"inputs":"'+ input.to_s() +'","parameters":{"temperature":0.1,"truncate":2048,"max_new_tokens":1024,"do_sample":true,"repetition_penalty":1.2,"return_full_text":false},"stream":true,"options":{"id":"6543eb99-e311-4f4e-b791-7af4fcbe556b","response_id":"b194833d-e13c-4390-9d7f-3cf4e4d95430","is_retry":false,"use_cache":false,"web_search_id":""}}'

-      #

-

-      # task.async do

-      #   request.post(uri.host)

-      # end

-

-    # end

-

-    begin

-      response = https.request(request)

-

-      #$irc.msg('#fpc', e.message)

-

-      json_strings = response.body.split('data:')

-

-      parsed_json_objects = []

-

-      json_strings.each do |json_str|

-        if json_str != ''

-          parsed_json_objects << JSON.parse(json_str)

-        end

-      end

-

-      counts = 0

-

-      b = ''

-      parsed_json_objects.each do |json_obj|

-        result = json_obj['token']['text']

-        if result == '<|endoftext|>' then

-          break

-        elsif counts >= 50

-        begin

-          $bot.send_message(peer, 'limit reached!')

-          break

-        end

-        elsif result.include?("\n")

-        begin

-          $bot.send_message(peer, b)

-          sleep(0.2)

-          counts += 1

-          #$irc.msg(peer, b)

-          b = ''

-        end

-        else

-          b += result

-        end

-      end

-

-      $bot.send_message(peer, b)

-      #$irc.msg(peer, b)

-

-    rescue StandardError => e

-      $bot.send_message(peer, e)

-      #$irc.msg(peer, e)

-    end

-  end

-

-end

-sender = Sender.new

-

-

-IRCConnection.add_IO_socket(STDIN)

-IRCEvent.add_callback('endofmotd') { |event| $bot.add_channel('#fpc') }

-IRCEvent.add_callback('invite') do |event|

-  puts event.message

-  puts event.channel

-  $bot.add_channel(event.message)

-end

-# IRCEvent.add_callback('join') { |event|

-#   bot.send_message(event.channel, "Hello #{event.from}")

-IRCEvent.add_callback('privmsg') {|event|

-  if event.channel.eql?(BotNick)

-  begin

-    if (event.message.start_with?(".invite"))

-    begin

-        event.message.slice! ".invite "

-        $bot.add_channel(event.message)

-    end

-    else

-      $bot.send_message(event.from, "I'm thinking...")

-      sender.SendReq(event.from, event.message, '')

-    end

-  end

-  else

-    if (event.message.start_with?("h2o"))

-      Push(event.channel, 'Im')

-      Send()

-      # IRCConnection.output_push("PRIVMSG #{event.channel} : moz")

-      $bot.send_message(event.channel, "#{event.from}, I'm thinking...")

-      sender.SendReq(event.channel, event.message, '')

-    end

-  end

-

-}

-

-# }

-

-$bot.connect

-

-

-$irc.heard_msg(:if => {:pm? => true}) do |e|

-  puts(e.nick)

-  sender.async.Wait(e.nick)

-  sender.async.SendReq(e.nick, e.message, $irc)

-  puts('e')

-end

-

-$irc.heard_msg(:if => {:pm? => false}) do |e|

-  if (e.message.start_with?("h2o"))

-    puts(e.channel)

-    sender.async.Wait(e.channel)

-    sender.async.SendReq(e.channel, e.message, $irc)

-    puts('e')

-  end

-end

-

-#$irc.start_listening!

-

-futures = []

-

-

-

-3.times do |i|

-  futures << Concurrent::Future.execute(executor: executor) do

-

-  end

-end

-

-futures.each(&:wait)

-executor.shutdown

-