mikutodon.rb

# -*- coding: utf-8 -*-
require "thread"
require 'net/http'
require 'uri'
require "json"
require "eventmachine"
require "faye/websocket"
require 'nokogiri'
require_relative './model.rb'
require_relative "./stream"
require_relative "./create_toot"
require_relative "./toot_operation"
require_relative "./create_notification"
require_relative "./orig_parse"

Plugin.create(:mikutodon) do
  cw  = ""
  vis = "public"

  
  filter_extract_datasources do |ds|
    [{mastodon_home: "mikutodonHomeTimeline", 
      mastodon_local: "mikutodonLocalTimeline",
      mastodon_public: "mikutodonPublicTimeline"}.merge(ds)]
  end

  defactivity "mstdn_fav", "mikutodon ふぁぼ"
  defactivity "mstdn_reblog", "mikutodon ぶーすと"
  defactivity "mstdn_follow", "mikutodon ふぉろー"
  defactivity "mstdn_mention", "mikutodon 返信"
  defactivity "mikutodon_debug_message", "mikutodon デバックメッセージ"

  settings "mikutodon" do
    # エラー対策
    # boolean("Mastodonに投稿する", :mastodon_post)
    input(_("URL"), :account_host)
    input(_("とーくん"), :account_token)
    input(_("CW使用時の警告文"), :cw_text)
    select("公開範囲", :mastodon_vis, { 0 => "公開", 1 => "非収載", 2 => "非公開", 3 => "ダイレクト" , 4=> "Random"})
  end

  # アカウント
  account = {
    :token => UserConfig[:account_token],
    :host => UserConfig[:account_host]
  }



  
  # タイムラインのストリームをスタート
  def timeline_start(account)
    Thread.new{
      toots_home = []
      stream(account, "user", :mastodon_home, toots_home)
    }
    Thread.new{
      toots_local = []
      stream(account, "public:local", :mastodon_local, toots_local)
    }
    Thread.new{
      toots_public = []
      stream(account, "public", :mastodon_public, toots_public)
    }

  end


# ふぁぼふぁぼこまんど
  command(:mastodon_fav,
          name: "お気に入り",
          condition: lambda{ |opt|
            opt.messages.any? { |message|
              message.is_a?(MstdnToot)
            }
          },
          visible: true,
          role: :timeline) do |opt|
    opt.messages.select { |_| _.is_a?(MstdnToot) }.each { |message|
      mstdn_fav(message[:id], account)
    }
  end

  command(:mastodon_reblog,
          name: "ブースト",
          condition: lambda{ |opt|
            opt.messages.any? { |message|
              message.is_a?(MstdnToot)
            }
          },
          visible: true,
          role: :timeline) do |opt|
    opt.messages.select { |_| _.is_a?(MstdnToot) }.each { |message|
      mstdn_reblog(message[:id], account)
    }
  end

  command(:mstdn_tl_retry,
          name: "ストリーミングの再接続",
          condition: lambda{ |opt| $tl_close },
          visible: true,
          role: :timeline) do |opt|
    timeline_start(account)
  end

# CWで投稿するコマンドを追加
  command(:mastodon_cw,
          name: "CWで投稿",
          condition: lambda{ |opt| true },
          visible: true,
          role: :postbox) do |opt|
    cw_text = UserConfig[:cw_text]

    # もしCWの文章が指定されていなかった場合は自動で閲覧注意を挿入
    if cw_text.empty?
      cw_text = "閲覧注意！"
    end

    text = Plugin.create(:gtk).widgetof(opt.widget).widget_post.buffer.text 
    post_toot(text, cw_text, account, UserConfig[:mastodon_vis])    

    Plugin.create(:gtk).widgetof(opt.widget).widget_post.buffer.text = ""
  end



  # 投稿欄を乗っ取りMastodonに投稿
  filter_gui_postbox_post do |gui_postbox, opt|
    text = Plugin.create(:gtk).widgetof(gui_postbox).widget_post.buffer.text

    # もし投稿内容が正規表現なら警告する機能(未実装)
    if text =~ /^s\/.+\/.+\/?$/
#      req_warn = Gtk::Dialog.new
#
#
#      label_str = Gtk::Label.new("失った信頼はもう戻ってきませんが、本当にこの文章を投稿しますか？\n\n#{text}")
#
#      label_str.show
#
#      req_warn.vbox.pack_start(label_str, true, true, 30)
#
#
#      req_warn.add_buttons(["No", Gtk::Dialog::RESPONSE_NO],["Yes", Gtk::Dialog::RESPONSE_YES])
#
#      req_warn.signal_connect("response") do |widget, responsei|
#        case response
#        when Gtk::Dialog::RESPONSE_YES
#          post_toot(text, cw, account, UserConfig[:mastodon_vis])
#        when Gtk::Dialog::RESPONSE_NO
#          activity :system, "test"
#        end
#      end
#      req_warn.show_all
#    else
      activity :mikutodon_debug_message, "正規表現だよ！"
    end

    post_toot(text, cw, account, UserConfig[:mastodon_vis])

    
#    end

    Plugin.create(:gtk).widgetof(gui_postbox).widget_post.buffer.text = ""
  end
    
  # タイムラインの開始を開始
  on_boot do |service|
    timeline_start(account)
  end


end