Ruby gem for ingesting ATProto repo data from a Tap service (extension of Skyfall gem)
backported some Skyfall::Stream methods from master temporarily
+20
+20
lib/tapfall/stream.rb
+20
lib/tapfall/stream.rb
···
49
49
50
50
private
51
51
52
+
# TMP
53
+
def send_data(data)
54
+
@ws.send(data)
55
+
end
56
+
57
+
def build_websocket_client(url)
58
+
Faye::WebSocket::Client.new(url, nil, { headers: { 'User-Agent' => user_agent }.merge(request_headers) })
59
+
end
60
+
61
+
def ensure_empty_path(url)
62
+
url = url.chomp('/')
63
+
64
+
if URI(url).path != ''
65
+
raise ArgumentError, "Server URL should only include a hostname, without any path"
66
+
end
67
+
68
+
url
69
+
end
70
+
# END
71
+
52
72
def basic_auth(account, password)
53
73
'Basic ' + ["#{account}:#{password}"].pack('m0')
54
74
end