+121

spec/did_spec.rb

··· 114 114 did.to_s.should == plc_did 115 115 end 116 116 end 117 117 + 118 118 + describe 'account status' do 119 119 + let(:document) { stub(:pds_endpoint => 'https://pds.ruby.space') } 120 120 + let(:did) { subject.new(plc_did) } 121 121 + 122 122 + before do 123 123 + did.stubs(:document).returns(document) 124 124 + 125 125 + stub_request(:get, 'https://pds.ruby.space/xrpc/com.atproto.sync.getRepoStatus') 126 126 + .with(query: { did: plc_did }) 127 127 + .to_return(http_response) if defined?(http_response) 128 128 + end 129 129 + 130 130 + context 'when repo is active' do 131 131 + let(:http_response) { 132 132 + { body: { active: true }.to_json, headers: { 'Content-Type' => 'application/json' }} 133 133 + } 134 134 + 135 135 + it 'should report active account state' do 136 136 + did.account_status.should == :active 137 137 + did.account_active?.should == true 138 138 + did.account_exists?.should == true 139 139 + end 140 140 + end 141 141 + 142 142 + context 'when repo is inactive' do 143 143 + let(:http_response) { 144 144 + { body: { active: false, status: 'takendown' }.to_json, headers: { 'Content-Type' => 'application/json' }} 145 145 + } 146 146 + 147 147 + it 'should report an inactive existing account' do 148 148 + did.account_status.should == :takendown 149 149 + did.account_active?.should == false 150 150 + did.account_exists?.should == true 151 151 + end 152 152 + end 153 153 + 154 154 + context 'when repo is not found' do 155 155 + let(:http_response) { 156 156 + { status: 400, body: { error: 'RepoNotFound' }.to_json, headers: { 'Content-Type' => 'application/json' }} 157 157 + } 158 158 + 159 159 + it 'should return nil status and report the account as missing' do 160 160 + did.account_status.should be_nil 161 161 + did.account_active?.should == false 162 162 + did.account_exists?.should == false 163 163 + end 164 164 + end 165 165 + 166 166 + context 'when the document has no pds endpoint' do 167 167 + before do 168 168 + did.stubs(:document).returns(stub(:pds_endpoint => nil)) 169 169 + end 170 170 + 171 171 + it 'should return nil status and report the account as missing' do 172 172 + did.account_status.should be_nil 173 173 + did.account_active?.should == false 174 174 + did.account_exists?.should == false 175 175 + end 176 176 + end 177 177 + 178 178 + context 'when active field is not set' do 179 179 + let(:http_response) { 180 180 + { body: { active: nil, status: 'unknown' }.to_json, headers: { 'Content-Type' => 'application/json' }} 181 181 + } 182 182 + 183 183 + it 'should raise APIError' do 184 184 + expect { did.account_status }.to raise_error(DIDKit::APIError) 185 185 + expect { did.account_active? }.to raise_error(DIDKit::APIError) 186 186 + expect { did.account_exists? }.to raise_error(DIDKit::APIError) 187 187 + end 188 188 + end 189 189 + 190 190 + context 'when active is false but status is not set' do 191 191 + let(:http_response) { 192 192 + { body: { active: false, status: nil }.to_json, headers: { 'Content-Type' => 'application/json' }} 193 193 + } 194 194 + 195 195 + it 'should raise APIError' do 196 196 + expect { did.account_status }.to raise_error(DIDKit::APIError) 197 197 + expect { did.account_active? }.to raise_error(DIDKit::APIError) 198 198 + expect { did.account_exists? }.to raise_error(DIDKit::APIError) 199 199 + end 200 200 + end 201 201 + 202 202 + context 'when an error different than RepoNotFound is returned' do 203 203 + let(:http_response) { 204 204 + { status: 400, body: { error: 'UserIsJerry' }.to_json, headers: { 'Content-Type' => 'application/json' }} 205 205 + } 206 206 + 207 207 + it 'should raise APIError' do 208 208 + expect { did.account_status }.to raise_error(DIDKit::APIError) 209 209 + expect { did.account_active? }.to raise_error(DIDKit::APIError) 210 210 + expect { did.account_exists? }.to raise_error(DIDKit::APIError) 211 211 + end 212 212 + end 213 213 + 214 214 + context 'when the response is not application/json' do 215 215 + let(:http_response) { 216 216 + { status: 400, body: 'error', headers: { 'Content-Type' => 'text/html' }} 217 217 + } 218 218 + 219 219 + it 'should raise APIError' do 220 220 + expect { did.account_status }.to raise_error(DIDKit::APIError) 221 221 + expect { did.account_active? }.to raise_error(DIDKit::APIError) 222 222 + expect { did.account_exists? }.to raise_error(DIDKit::APIError) 223 223 + end 224 224 + end 225 225 + 226 226 + context 'when the response is not 200 or 400' do 227 227 + let(:http_response) { 228 228 + { status: 500, body: { error: 'RepoNotFound' }.to_json, headers: { 'Content-Type' => 'application/json' }} 229 229 + } 230 230 + 231 231 + it 'should raise APIError' do 232 232 + expect { did.account_status }.to raise_error(DIDKit::APIError) 233 233 + expect { did.account_active? }.to raise_error(DIDKit::APIError) 234 234 + expect { did.account_exists? }.to raise_error(DIDKit::APIError) 235 235 + end 236 236 + end 237 237 + end 117 238 end

+1 -1

spec/document_spec.rb

··· 174 174 end 175 175 end 176 176 177 177 - describe '#pds_host' do 177 177 + describe '#labeler_host' do 178 178 it 'should return the host part of #atproto_labeler endpoint' do 179 179 doc = subject.new(did, service_json) 180 180 doc.labeler_host.should == 'labels.dholms.xyz'

+146

spec/plc_operation_spec.rb

··· 208 208 expect { subject.new(json) }.to raise_error(DIDKit::PLCOperation::FormatError) 209 209 end 210 210 end 211 211 + 212 212 + context 'when a service entry is missing fields' do 213 213 + let(:json) { 214 214 + base_json.tap { |h| 215 215 + h['operation']['services'] = { 216 216 + "atproto_pds" => { 217 217 + "endpoint" => "https://pds.dholms.xyz" 218 218 + }, 219 219 + "atproto_labeler" => { 220 220 + "type" => "AtprotoLabeler", 221 221 + "endpoint" => "https://labeler.example.com" 222 222 + } 223 223 + } 224 224 + } 225 225 + } 226 226 + 227 227 + it 'should raise a format error' do 228 228 + expect { subject.new(json) }.to raise_error(DIDKit::PLCOperation::FormatError) 229 229 + end 230 230 + end 231 231 + 232 232 + context 'when services are valid' do 233 233 + let(:json) { 234 234 + base_json.tap { |h| 235 235 + h['operation']['services'] = { 236 236 + "atproto_pds" => { 237 237 + "type" => "AtprotoPersonalDataServer", 238 238 + "endpoint" => "https://pds.dholms.xyz" 239 239 + }, 240 240 + "atproto_labeler" => { 241 241 + "type" => "AtprotoLabeler", 242 242 + "endpoint" => "https://labeler.example.com" 243 243 + }, 244 244 + "custom_service" => { 245 245 + "type" => "OtherService", 246 246 + "endpoint" => "https://custom.example.com" 247 247 + } 248 248 + } 249 249 + } 250 250 + } 251 251 + 252 252 + it 'should parse services into ServiceRecords' do 253 253 + op = subject.new(json) 254 254 + 255 255 + op.services.length.should == 3 256 256 + op.services.each { |s| s.should be_a(DIDKit::ServiceRecord) } 257 257 + 258 258 + pds, labeller, custom = op.services 259 259 + 260 260 + pds.type.should == 'AtprotoPersonalDataServer' 261 261 + pds.endpoint.should == 'https://pds.dholms.xyz' 262 262 + 263 263 + labeller.type.should == 'AtprotoLabeler' 264 264 + labeller.endpoint.should == 'https://labeler.example.com' 265 265 + 266 266 + custom.type.should == 'OtherService' 267 267 + custom.endpoint.should == 'https://custom.example.com' 268 268 + end 269 269 + 270 270 + it 'should allow fetching services by key + type' do 271 271 + op = subject.new(json) 272 272 + 273 273 + custom = op.get_service('custom_service', 'OtherService') 274 274 + custom.should be_a(DIDKit::ServiceRecord) 275 275 + custom.endpoint.should == 'https://custom.example.com' 276 276 + end 277 277 + 278 278 + describe '#pds_endpoint' do 279 279 + it 'should return the endpoint of #atproto_pds' do 280 280 + op = subject.new(json) 281 281 + op.pds_endpoint.should == 'https://pds.dholms.xyz' 282 282 + end 283 283 + end 284 284 + 285 285 + describe '#pds_host' do 286 286 + it 'should return the host part of #atproto_pds endpoint' do 287 287 + op = subject.new(json) 288 288 + op.pds_host.should == 'pds.dholms.xyz' 289 289 + end 290 290 + end 291 291 + 292 292 + describe '#labeler_endpoint' do 293 293 + it 'should return the endpoint of #atproto_labeler' do 294 294 + op = subject.new(json) 295 295 + op.labeler_endpoint.should == 'https://labeler.example.com' 296 296 + end 297 297 + end 298 298 + 299 299 + describe '#labeler_host' do 300 300 + it 'should return the host part of #atproto_labeler endpoint' do 301 301 + op = subject.new(json) 302 302 + op.labeler_host.should == 'labeler.example.com' 303 303 + end 304 304 + end 305 305 + 306 306 + it 'should expose the "labeller" aliases for endpoint and host' do 307 307 + op = subject.new(json) 308 308 + 309 309 + op.labeller_endpoint.should == 'https://labeler.example.com' 310 310 + op.labeller_host.should == 'labeler.example.com' 311 311 + end 312 312 + end 313 313 + 314 314 + context 'when services are valid but the specific ones are missing' do 315 315 + let(:json) { 316 316 + base_json.tap { |h| 317 317 + h['operation']['services'] = { 318 318 + "custom_service" => { 319 319 + "type" => "CustomService", 320 320 + "endpoint" => "https://custom.example.com" 321 321 + } 322 322 + } 323 323 + } 324 324 + } 325 325 + 326 326 + it 'should parse service records' do 327 327 + op = subject.new(json) 328 328 + op.services.length.should == 1 329 329 + end 330 330 + 331 331 + describe '#get_service' do 332 332 + it 'should return nil' do 333 333 + op = subject.new(json) 334 334 + other = op.get_service('other_service', 'OtherService') 335 335 + other.should be_nil 336 336 + end 337 337 + end 338 338 + 339 339 + describe '#pds_endpoint' do 340 340 + it 'should return nil' do 341 341 + op = subject.new(json) 342 342 + op.pds_endpoint.should be_nil 343 343 + op.pds_host.should be_nil 344 344 + end 345 345 + end 346 346 + 347 347 + describe '#labeler_endpoint' do 348 348 + it 'should return nil' do 349 349 + op = subject.new(json) 350 350 + op.labeler_endpoint.should be_nil 351 351 + op.labeller_endpoint.should be_nil 352 352 + op.labeler_host.should be_nil 353 353 + op.labeller_host.should be_nil 354 354 + end 355 355 + end 356 356 + end 211 357 end 212 358 end