tangled
alpha
login
or
join now
mackuba.eu
/
skyfall
6
fork
atom
A Ruby gem for streaming data from the Bluesky/ATProto firehose
6
fork
atom
overview
issues
pulls
pipelines
added frozen string literal directive everywhere
mackuba.eu
2 months ago
be95ad1f
5a71852a
+50
25 changed files
expand all
collapse all
unified
split
lib
skyfall
car_archive.rb
cid.rb
collection.rb
errors.rb
events.rb
extensions.rb
firehose
account_message.rb
commit_message.rb
identity_message.rb
info_message.rb
labels_message.rb
message.rb
operation.rb
sync_message.rb
unknown_message.rb
firehose.rb
jetstream
account_message.rb
commit_message.rb
identity_message.rb
message.rb
operation.rb
unknown_message.rb
jetstream.rb
label.rb
stream.rb
+2
lib/skyfall/car_archive.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative 'cid'
2
4
require_relative 'errors'
3
5
require_relative 'extensions'
+2
lib/skyfall/cid.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative 'errors'
2
4
3
5
require 'base32'
+2
lib/skyfall/collection.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
module Skyfall
2
4
3
5
#
+2
lib/skyfall/errors.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
module Skyfall
2
4
#
3
5
# Wrapper base class for Skyfall error classes.
+2
lib/skyfall/events.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
module Skyfall
2
4
3
5
# @private
+2
lib/skyfall/extensions.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require 'cbor'
2
4
require 'stringio'
3
5
+2
lib/skyfall/firehose.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative 'stream'
2
4
require 'uri'
3
5
+2
lib/skyfall/firehose/account_message.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative '../firehose'
2
4
require_relative 'message'
3
5
+2
lib/skyfall/firehose/commit_message.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative '../car_archive'
2
4
require_relative '../cid'
3
5
require_relative '../firehose'
+2
lib/skyfall/firehose/identity_message.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative '../firehose'
2
4
require_relative 'message'
3
5
+2
lib/skyfall/firehose/info_message.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative '../firehose'
2
4
require_relative 'message'
3
5
+2
lib/skyfall/firehose/labels_message.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative '../firehose'
2
4
require_relative '../label'
3
5
require_relative 'message'
+2
lib/skyfall/firehose/message.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative '../errors'
2
4
require_relative '../extensions'
3
5
require_relative '../firehose'
+2
lib/skyfall/firehose/operation.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative '../collection'
2
4
require_relative '../firehose'
3
5
+2
lib/skyfall/firehose/sync_message.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative '../firehose'
2
4
require_relative 'message'
3
5
+2
lib/skyfall/firehose/unknown_message.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative '../firehose'
2
4
require_relative 'message'
3
5
+2
lib/skyfall/jetstream.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative 'stream'
2
4
3
5
require 'json'
+2
lib/skyfall/jetstream/account_message.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative '../errors'
2
4
require_relative '../jetstream'
3
5
require_relative 'message'
+2
lib/skyfall/jetstream/commit_message.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative '../errors'
2
4
require_relative '../jetstream'
3
5
require_relative 'message'
+2
lib/skyfall/jetstream/identity_message.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative '../errors'
2
4
require_relative '../jetstream'
3
5
require_relative 'message'
+2
lib/skyfall/jetstream/message.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative '../errors'
2
4
require_relative '../jetstream'
3
5
+2
lib/skyfall/jetstream/operation.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative '../collection'
2
4
require_relative '../jetstream'
3
5
+2
lib/skyfall/jetstream/unknown_message.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative '../jetstream'
2
4
require_relative 'message'
3
5
+2
lib/skyfall/label.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require_relative 'errors'
2
4
require 'time'
3
5
+2
lib/skyfall/stream.rb
···
1
1
+
# frozen_string_literal: true
2
2
+
1
3
require 'eventmachine'
2
4
require 'faye/websocket'
3
5
require 'uri'