irresponsible omnibus commit, mostly kraken->helix migrations

1 files changed, 108 insertions, 77 deletions

diff --git a/util/twitch.cr b/util/twitch.cr
index 1e63736..dea1ef1 100644
--- a/util/twitch.cr
+++ b/util/twitch.cr
@@ -7,7 +7,7 @@ require "pretty_print"
 settings = Hash(String, String).new
 
 settings["home"]         = Path.home.to_s
-["access_token", "channel", "channel_id", "client_id", "client_id_twitch", "client_secret", "app_access_token", "eventsub_secret"].each do |key|
+["access_token", "channel", "channel_id", "client_id", "client_id_twitch", "client_secret", "app_access_token", "eventsub_secret", "scopes", "redirect_uri"].each do |key|
   begin
     settings[key] = File.read( settings["home"] + "/.config/twitch/" + key ).chomp
   rescue
@@ -20,9 +20,7 @@ command = ARGV[0]
 client = Twitcr::Client.new( settings )
 
 case command
-when "videos", "lsvideo", "lsvideos"
-  list_videos_kraken( settings, client )
-when "videos_helix" # smaller json, less information
+when "videos", "lsvideo", "lsvideos", "videos_helix" # smaller json, less information
   list_videos_helix( settings, client )
 when "follows", "lsfollow", "lsfollows"
   list_user_follows( settings, client )
@@ -37,21 +35,23 @@ when "follow"
 when "unfollow"
   pp client.unfollow( settings["channel_id"], ARGV[1] )
 when "streams_followed"
-  list_streams_followed( settings, client )
+  list_streams_followed( settings, client, ARGV[1]? || settings["channel_id"].to_u64 )
 when "clips"
   pp JSON.parse( client.get_clips( ARGV[1] ) )
 when "game"
-  pp client.get_games( ARGV[1] )
+  pp JSON.parse( client.get_games( ARGV[1].to_u64? || ARGV[1] ) )
 when "streams"
-  list_streams_v5( settings, client, ARGV[1] )
-when "streams_helix"
   list_streams( settings, JSON.parse( client.get_streams( game_id = client.game_id( ARGV[1] ) ) ) )
+when "streams_kraken"
+  list_streams_v5( settings, client, ARGV[1] )
 when "hosts"
   list_hosts( settings, client )
 when "user"
   pp JSON.parse( client.get_user( ARGV[1] ) )
 when "subs"
-  pp JSON.parse( client.get_subs( client.user( ARGV[1] ).id ) )
+  list_subs( settings, client, ARGV[1] )
+
+  #pp JSON.parse( client.get_subs( client.user( ARGV[1] ).id ) )
 when "eventsubs"
   pp JSON.parse( client.get_eventsubs( ) )
 when "eventsub"
@@ -60,20 +60,20 @@ when "eventunsub"
   pp client.delete_eventsubs!( ARGV[1] )
 when "panels"
   pp JSON.parse( client.get_panels( ARGV[1] ) )
+when "authorize"
+  pp client.authorize()
 when "validate"
   pp JSON.parse( client.get_token_validation() )
 when "app_token"
   pp JSON.parse( client.get_app_token() )
+when "token"
+  pp client.get_token( ARGV[1] )
 when "reset_key"
   pp JSON.parse( client.delete_key!( settings["channel_id"].to_u64 ) )
 when "update"
   update_channel( settings, client, settings["channel_id"].to_u64 )
 when "channel"
-  if ARGV.size > 1
-    pp JSON.parse( client.get_channel( client.user_id( ARGV[1] ) ) )
-  else
-    pp JSON.parse( client.get_channel( ) )
-  end
+  pp JSON.parse( client.get_channel( client.user_id( ARGV[1]? || settings["channel_id"] ) ) )
 else
   puts "ARGV[0] must be one of videos, follows"
 end
@@ -89,14 +89,18 @@ macro fcell( data )
     if celi == 0
       # preserve integrity of primary index at expense of last cell
       celw[-1] = celw[-1] - ( celw.sum( foh ) - winsz )
-    elsif celi != celw.size
-      celw[celw.size]
+    elsif celi != ( celw.size - 1 )
+      celw[( celw.size - 1 ) ]
     else
       celw[celi] = celw[celi] - ( celw.sum( foh ) - winsz ) - ( {{data}}.bytesize - {{data}}.size )
+      if celw[celi] < 0
+        celw[celi] = 0
+      end
     end
   end
   celi+=1
   { celw[celi-1], celw[celi-1], {{data}} }
+  {{debug()}}
 end
 
 macro get_winsz()
@@ -111,6 +115,7 @@ def list_videos_helix( settings, client )
   id = client.user( ARGV[1] ).id
 
   response = JSON.parse( client.get_videos( id ) )
+  pp response
 
   winsz = get_winsz()
 
@@ -129,61 +134,40 @@ def list_videos_helix( settings, client )
     celi=0
 
     printf( format,
-      *fcell( video["url"].as_s[12..] ),
-      *fcell( video["created_at"].as_s.[0..15] ),
+      *fcell( video["url"].as_s ),
+      *fcell( video["created_at"].as_s[0..15] ),
       *fcell( video["type"].as_s[0].to_s ),
       *fcell( video["duration"].as_s[ /([0-9]+[a-z]+)/, 1 ] ),
       *fcell( video["view_count"].as_i.to_s ),
-    # helix doesn't report game?!
-    # *fcell( video["game"].as_s ),
-      *fcell( video["title"].as_s.chomp ),
+      *fcell( video["title"].as_s.chomp),
       *fcell( video["description"].as_s.chomp ),
-    )
-
-  end
-
-end
-
-def list_videos_kraken( settings, client )
-
-  # FIXME: handle UInt32 more gracefully
-  # also: implement Twitcr::User so we can restrict valid strings
-  id = client.user( ARGV[1] ).id
-
-  response = JSON.parse( client.get_channels_videos( id ) )
-
-  winsz = get_winsz()
-
-  # cell widths
-  celw=[0,0,0,0,0,0,0,0]
-  # cell index
-  celi=0
-
-  format = "%*.*s %-*.*s %*.*s %*.*s %*.*s %-*.*s %-*.*s %-*.*s\n"
-
-  # format overhead
-  foh = format.delete( "^ " ).size
-
-  response["videos"].as_a.each do |video|
-
-    celi=0
-
-    begin
-      printf( format,
-        *fcell( video["url"].as_s[12..] ),
-        *fcell( video["created_at"].as_s[0..15] ),
-        *fcell( video["broadcast_type"].as_s[0].to_s ),
-        *fcell( video["length"].as_i.to_s ),
-        *fcell( video["views"].as_i.to_s ),
-        *fcell( video["game"].as_s ),
-        *fcell( video["title"].to_s.chomp ),
-        *fcell( video["description"].to_s.chomp ),
-      )
-    rescue ex
-      puts ex.message
-      pp video
-    end
-
+)
+#pp celw
+#  if video["title"].as_s.chomp.bytesize > celw[celi]
+#    celw[celi] = video["title"].as_s.chomp.bytesize
+#  end
+#  if celw.sum( foh ) > winsz
+#    # don't exceed winsz, even on screwball wide characters
+#    if celi == 0
+#      # preserve integrity of primary index at expense of last cell
+#      celw[-1] = celw[-1] - ( celw.sum( foh ) - winsz ) # 33 - 13 = 20
+#    elsif celi != ( celw.size - 1 )
+#      puts
+#      pp foh   # 5
+#      # sum = 93
+#      pp winsz # 80
+#      pp celi  # 5
+#      pp celw  # [39, 16, 1, 8, 1, 33]
+#      pp celw.size # 6
+#      celw[( celw.size-1 )]
+#    else
+#      celw[celi] = celw[celi] - ( celw.sum( foh ) - winsz ) - ( video["title"].as_s.chomp.bytesize - video["title"].as_s.chomp.size )
+#    end
+#  end
+#  celi+=1
+#  printf( "%*.*s\n", celw[celi-1], celw[celi-1], video["title"].as_s.chomp )
+#
+#    )
 
   end
 
@@ -544,7 +528,49 @@ def list_streams( settings, response )
 
 end
 
-def list_streams_followed( settings, client )
+def list_subs( settings, client, user_id )
+
+  user_id = client.user( user_id ).id
+
+  winsz = get_winsz()
+
+  # cell widths
+  celw=[0,0,0]
+  # cell index
+  celi=0
+
+  format = "%-*.*s %-*.*s %-*.*s\n"
+
+  # format overhead
+  foh = format.delete( "^ " ).size
+
+  response = JSON.parse( client.get_subs( user_id ) )
+
+  pp response
+
+#  response["data"].as_a.sort{ |a, b| b["viewer_count"].as_i <=> a["viewer_count"].as_i }.each do |stream|
+  response["data"].as_a.each do |stream|
+
+    celi=0
+
+    begin
+      printf( format,
+        *fcell( stream["plan_name"].as_s[0].to_s ),
+        *fcell( stream["gifter_login"].as_s ),
+        *fcell( stream["user_login"].to_s ),
+      )
+    rescue ex
+      pp ex
+      pp stream
+    end
+
+  end
+  puts response["points"]
+
+end
+def list_streams_followed( settings, client, user_id )
+
+  user_id = client.user( user_id ).id
 
   winsz = get_winsz()
 
@@ -558,22 +584,25 @@ def list_streams_followed( settings, client )
   # format overhead
   foh = format.delete( "^ " ).size
 
-  response = JSON.parse( client.get_streams_followed() )
+  response = JSON.parse( client.get_streams_followed( user_id ) )
 
   pp response
 
-  response["streams"].as_a.sort{ |a, b| b["viewers"].as_i <=> a["viewers"].as_i }.each do |stream|
+#  response["data"].as_a.sort{ |a, b| b["viewer_count"].as_i <=> a["viewer_count"].as_i }.each do |stream|
+  response["data"].as_a.each do |stream|
 
     celi=0
 
     begin
       printf( format,
-        *fcell( stream["channel"]["url"].as_s[12..] ),
-        *fcell( stream["stream_type"].as_s[0].to_s ),
-        *fcell( stream["viewers"].as_i.to_s ),
-        *fcell( stream["channel"]["followers"].as_i.to_s ),
-        *fcell( stream["game"].as_s ),
-        *fcell( stream["channel"]["status"].to_s ),
+        #*fcell( stream["user_login"].as_s[12..] ),
+        *fcell( "twitch.tv/#{ stream["user_login"].as_s }" ),
+        *fcell( stream["type"].as_s[0].to_s ),
+        *fcell( stream["viewer_count"].as_i.to_s ),
+        #*fcell( stream["channel"]["followers"].as_i.to_s ),
+        *fcell( "0" ),
+        *fcell( stream["game_name"].as_s ),
+        *fcell( stream["title"].to_s ),
       )
     rescue ex
       pp ex
@@ -586,6 +615,8 @@ end
 
 def update_channel( settings, client, id )
 
-   pp JSON.parse( client.put_channel!( id, game: ARGV[1], status: ARGV[2] ) )
+   response = client.put_channel!( id, game: ARGV[1], title: ARGV[2] )
+   pp response
+   pp JSON.parse( client.get_channel( settings["channel_id"].to_u64 ) )
 
 end