Class: Skypost::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/skypost/client.rb

Defined Under Namespace

Classes: AuthenticationError, ValidationError

Constant Summary collapse

BASE_URL = 
"https://bsky.social"

Instance Method Summary collapse

Constructor Details

#initialize(identifier = nil, password = nil) ⇒ Client 



11
12
13
14
15
16
 
# File 'lib/skypost/client.rb', line 11

def initialize(identifier = nil, password = nil)
  @identifier = identifier
  @password = password
  @session = nil
  validate_identifier if identifier
end

Instance Method Details

#authenticate ⇒ Object 



18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
 
# File 'lib/skypost/client.rb', line 18

def authenticate
  raise AuthenticationError, "Identifier and password are required" if @identifier.nil? || @password.nil?

  response = connection.post("/xrpc/com.atproto.server.createSession") do |req|
    req.headers["Content-Type"] = "application/json"
    req.body = JSON.generate({
      identifier: @identifier,
      password: @password
    })
  end

  @session = JSON.parse(response.body)
  @session
rescue Faraday::ResourceNotFound => e
  raise AuthenticationError, "Authentication failed: Invalid credentials or incorrect handle format. Your handle should be either your custom domain (e.g., 'username.com') or your Bluesky handle (e.g., 'username.bsky.social')"
rescue Faraday::Error => e
  raise AuthenticationError, "Failed to authenticate: #{e.message}"
end

#post(text) ⇒ Object 



37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
 
# File 'lib/skypost/client.rb', line 37

def post(text)
  ensure_authenticated

  current_time = Time.now.utc.strftime("%Y-%m-%dT%H:%M:%S.%3NZ")
  facets = extract_links(text)
  
  request_body = {
    repo: @session["did"],
    collection: "app.bsky.feed.post",
    record: {
      text: text.gsub(/<a href="[^"]*">|<\/a>/, ''),  # Remove HTML tags but keep link text
      facets: facets,
      createdAt: current_time,
      "$type": "app.bsky.feed.post"
    }
  }

  response = connection.post("/xrpc/com.atproto.repo.createRecord") do |req|
    req.headers["Content-Type"] = "application/json"
    req.headers["Authorization"] = "Bearer #{@session["accessJwt"]}"
    req.body = JSON.generate(request_body)
  end

  JSON.parse(response.body)
rescue Faraday::ResourceNotFound => e
  raise "Failed to post: The API endpoint returned 404. Please check if you're authenticated and using the correct API endpoint."
rescue Faraday::Error => e
  raise "Failed to post: #{e.message}"
end