Contents

require 'faraday'

module Chronicle
  module Zulip
    class Proxy
      def initialize(username:, access_token:, realm:)
        @username = username
        @access_token = access_token 
        @realm = realm
      end

      def all_private_messages(anchor: 'newest', since: nil, limit: nil)
        narrow = '[{"negated":false,"operator":"is","operand":"private"}]'
        has_more = true
        count = 0

        while has_more
          response = load_messages(anchor: anchor, narrow: narrow)
          messages = response[:messages].reverse || []
          messages = messages.first(limit - count) if limit
          messages = messages.filter { |message| Time.at(message[:timestamp]) > since } if since

          break unless messages.any?

          messages.each do |message|
            count += 1
            yield message
          end

          has_more = !response[:found_oldest]
          anchor = messages.map { |message| message[:id] }.min - 1
        end
      end

      def load_messages(anchor:, narrow:)
        params = {
          narrow: narrow,
          num_after: '0',
          num_before: '100',
          anchor: anchor,
          apply_markdown: 'false'
        }

        make_request(endpoint: 'messages', params: params)
      end

      def make_request(endpoint:, params: {})
        conn = Faraday.new(
          url: zulip_subdomain,
          params: params
        ) do |conn|
          conn.use Faraday::Response::RaiseError
          conn.request :authorization, :basic, @username, @access_token
        end

        response = conn.get("api/v1/#{endpoint}")
        JSON.parse(response.body, { symbolize_names: true })
      end

      private

      def zulip_subdomain
        "https://#{@realm}.zulipchat.com"
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
chronicle-zulip-0.1.2	lib/chronicle/zulip/proxy.rb