rails+fcmpush+HTTP/2+multiplexing

Dir[Rails.root.join('lib/monkey_patches/**/*.rb')].sort.each do |file|
  require file
end

require 'http/2'
require 'socket'
require 'openssl'

module FcmpushClientMonkeyPatch
  HTTP2_BATCH_ENDPOINT = "/v1/projects/プロジェクトID/messages:send".freeze
  REQUEST_TIMEOUT_SEC = 60.freeze # タイムアウト(秒)

  def batch_push(messages, query: {}, headers: {})
    uri = URI.parse(domain)
    host = uri.host

    # SSL接続の準備
    tcp = TCPSocket.new(host, 443)
    ctx = OpenSSL::SSL::SSLContext.new
    ctx.alpn_protocols = ['h2']  # HTTP/2プロトコルを指定
    # ctx.verify_mode = OpenSSL::SSL::VERIFY_NONE
    ssl = OpenSSL::SSL::SSLSocket.new(tcp, ctx)
    ssl.sync_close = true # SSLソケットが閉じられたらTCPも閉じる
    ssl.connect

    # HTTP/2クライアントの作成
    client = HTTP2::Client.new

    # SSLソケットをラップする
    client.on(:frame) do |bytes|
      ssl.write(bytes)
    end

    access_token_refresh
    headers = v1_authorized_header(headers)

    responses = []

    # 複数のストリームを作成してリクエストを送信
    messages.each do |message|
      stream = client.new_stream

      headers = headers.merge({
        ':scheme' => 'https',
        ':method' => 'POST',
        ':authority' => host,
        ':path' => HTTP2_BATCH_ENDPOINT,
        'content-type' => 'application/json'
      })

      response_body = ''

      stream.on(:data) do |data|
        response_body << data
      end

      stream.on(:close) do
        responses << response_body
      end

      # ストリームにヘッダーとボディを送信
      stream.headers(headers, end_stream: false)
      stream.data(message.to_json, end_stream: true)
    end

    begin
      Timeout.timeout(REQUEST_TIMEOUT_SEC) do
        # サーバーからのデータを非同期に受信
        while client.active_stream_count > 0
          data = ssl.read_nonblock(1024, exception: false)
          client << data unless data == :wait_readable
        end
      end
    rescue Timeout::Error
      # この時点でストリームに送信されているリクエストがあれば実行はされるが、接続を閉じるためログには残らない
      responses << JSON.generate({ error: 'timeout' })
    ensure
      ssl.close
    end

    responses
  end

  private
end

Fcmpush::Client.prepend(FcmpushClientMonkeyPatch)

client = Fcmpush.new(プロジェクトID)
responses = client.batch_push(FCMに送信するペイロードのhash)