Class: ChannelService::Processor

Inherits:
Object
  • Object
show all
Includes:
Thrift::Processor
Defined in:
lib/linerb/gen-rb/channel_service.rb

Instance Method Summary collapse

Instance Method Details

#process_approveChannelAndIssueChannelToken(seqid, iprot, oprot) ⇒ Object 



296
297
298
299
300
301
302
303
304
305
 
# File 'lib/linerb/gen-rb/channel_service.rb', line 296

def process_approveChannelAndIssueChannelToken(seqid, iprot, oprot)
  args = read_args(iprot, ApproveChannelAndIssueChannelToken_args)
  result = ApproveChannelAndIssueChannelToken_result.new()
  begin
    result.success = @handler.approveChannelAndIssueChannelToken(args.channelId)
  rescue ::ChannelException => e
    result.e = e
  end
  write_result(result, oprot, 'approveChannelAndIssueChannelToken', seqid)
end

#process_getApprovedChannels(seqid, iprot, oprot) ⇒ Object 



241
242
243
244
245
246
247
248
249
250
 
# File 'lib/linerb/gen-rb/channel_service.rb', line 241

def process_getApprovedChannels(seqid, iprot, oprot)
  args = read_args(iprot, GetApprovedChannels_args)
  result = GetApprovedChannels_result.new()
  begin
    result.success = @handler.getApprovedChannels(args.lastSynced, args.locale)
  rescue ::ChannelException => e
    result.e = e
  end
  write_result(result, oprot, 'getApprovedChannels', seqid)
end

#process_getChannelInfo(seqid, iprot, oprot) ⇒ Object 



307
308
309
310
311
312
313
314
315
316
 
# File 'lib/linerb/gen-rb/channel_service.rb', line 307

def process_getChannelInfo(seqid, iprot, oprot)
  args = read_args(iprot, GetChannelInfo_args)
  result = GetChannelInfo_result.new()
  begin
    result.success = @handler.getChannelInfo(args.channelId, args.locale)
  rescue ::ChannelException => e
    result.e = e
  end
  write_result(result, oprot, 'getChannelInfo', seqid)
end

#process_getChannelNotificationSettings(seqid, iprot, oprot) ⇒ Object 



318
319
320
321
322
323
324
325
326
327
 
# File 'lib/linerb/gen-rb/channel_service.rb', line 318

def process_getChannelNotificationSettings(seqid, iprot, oprot)
  args = read_args(iprot, GetChannelNotificationSettings_args)
  result = GetChannelNotificationSettings_result.new()
  begin
    result.success = @handler.getChannelNotificationSettings(args.locale)
  rescue ::ChannelException => e
    result.e = e
  end
  write_result(result, oprot, 'getChannelNotificationSettings', seqid)
end

#process_getChannelSettings(seqid, iprot, oprot) ⇒ Object 



252
253
254
255
256
257
258
259
260
261
 
# File 'lib/linerb/gen-rb/channel_service.rb', line 252

def process_getChannelSettings(seqid, iprot, oprot)
  args = read_args(iprot, GetChannelSettings_args)
  result = GetChannelSettings_result.new()
  begin
    result.success = @handler.getChannelSettings()
  rescue ::ChannelException => e
    result.e = e
  end
  write_result(result, oprot, 'getChannelSettings', seqid)
end

#process_getCommonDomains(seqid, iprot, oprot) ⇒ Object 



329
330
331
332
333
334
335
336
337
338
 
# File 'lib/linerb/gen-rb/channel_service.rb', line 329

def process_getCommonDomains(seqid, iprot, oprot)
  args = read_args(iprot, GetCommonDomains_args)
  result = GetCommonDomains_result.new()
  begin
    result.success = @handler.getCommonDomains(args.lastSynced)
  rescue ::ChannelException => e
    result.e = e
  end
  write_result(result, oprot, 'getCommonDomains', seqid)
end

#process_getReturnUrlWithRequestTokenForAutoLogin(seqid, iprot, oprot) ⇒ Object 



263
264
265
266
267
268
269
270
271
272
 
# File 'lib/linerb/gen-rb/channel_service.rb', line 263

def process_getReturnUrlWithRequestTokenForAutoLogin(seqid, iprot, oprot)
  args = read_args(iprot, GetReturnUrlWithRequestTokenForAutoLogin_args)
  result = GetReturnUrlWithRequestTokenForAutoLogin_result.new()
  begin
    result.success = @handler.getReturnUrlWithRequestTokenForAutoLogin(args.webLoginRequest)
  rescue ::ChannelException => e
    result.e = e
  end
  write_result(result, oprot, 'getReturnUrlWithRequestTokenForAutoLogin', seqid)
end

#process_getUpdatedChannelIds(seqid, iprot, oprot) ⇒ Object 



340
341
342
343
344
345
346
347
348
349
 
# File 'lib/linerb/gen-rb/channel_service.rb', line 340

def process_getUpdatedChannelIds(seqid, iprot, oprot)
  args = read_args(iprot, GetUpdatedChannelIds_args)
  result = GetUpdatedChannelIds_result.new()
  begin
    result.success = @handler.getUpdatedChannelIds(args.channelIds)
  rescue ::ChannelException => e
    result.e = e
  end
  write_result(result, oprot, 'getUpdatedChannelIds', seqid)
end

#process_getWebLoginDisallowedUrl(seqid, iprot, oprot) ⇒ Object 



274
275
276
277
278
279
280
281
282
283
 
# File 'lib/linerb/gen-rb/channel_service.rb', line 274

def process_getWebLoginDisallowedUrl(seqid, iprot, oprot)
  args = read_args(iprot, GetWebLoginDisallowedUrl_args)
  result = GetWebLoginDisallowedUrl_result.new()
  begin
    result.success = @handler.getWebLoginDisallowedUrl(args.webLoginRequest)
  rescue ::ChannelException => e
    result.e = e
  end
  write_result(result, oprot, 'getWebLoginDisallowedUrl', seqid)
end

#process_issueChannelToken(seqid, iprot, oprot) ⇒ Object 



351
352
353
354
355
356
357
358
359
360
 
# File 'lib/linerb/gen-rb/channel_service.rb', line 351

def process_issueChannelToken(seqid, iprot, oprot)
  args = read_args(iprot, IssueChannelToken_args)
  result = IssueChannelToken_result.new()
  begin
    result.success = @handler.issueChannelToken(args.channelId)
  rescue ::ChannelException => e
    result.e = e
  end
  write_result(result, oprot, 'issueChannelToken', seqid)
end

#process_issueRequestTokenWithAuthScheme(seqid, iprot, oprot) ⇒ Object 



362
363
364
365
366
367
368
369
370
371
 
# File 'lib/linerb/gen-rb/channel_service.rb', line 362

def process_issueRequestTokenWithAuthScheme(seqid, iprot, oprot)
  args = read_args(iprot, IssueRequestTokenWithAuthScheme_args)
  result = IssueRequestTokenWithAuthScheme_result.new()
  begin
    result.success = @handler.issueRequestTokenWithAuthScheme(args.channelId, args.otpId, args.authScheme, args.returnUrl)
  rescue ::ChannelException => e
    result.e = e
  end
  write_result(result, oprot, 'issueRequestTokenWithAuthScheme', seqid)
end

#process_reserveCoinUse(seqid, iprot, oprot) ⇒ Object 



373
374
375
376
377
378
379
380
381
382
 
# File 'lib/linerb/gen-rb/channel_service.rb', line 373

def process_reserveCoinUse(seqid, iprot, oprot)
  args = read_args(iprot, ReserveCoinUse_args)
  result = ReserveCoinUse_result.new()
  begin
    result.success = @handler.reserveCoinUse(args.request, args.locale)
  rescue ::ChannelException => e
    result.e = e
  end
  write_result(result, oprot, 'reserveCoinUse', seqid)
end

#process_updateChannelNotificationSetting(seqid, iprot, oprot) ⇒ Object 



384
385
386
387
388
389
390
391
392
393
 
# File 'lib/linerb/gen-rb/channel_service.rb', line 384

def process_updateChannelNotificationSetting(seqid, iprot, oprot)
  args = read_args(iprot, UpdateChannelNotificationSetting_args)
  result = UpdateChannelNotificationSetting_result.new()
  begin
    @handler.updateChannelNotificationSetting(args.setting)
  rescue ::ChannelException => e
    result.e = e
  end
  write_result(result, oprot, 'updateChannelNotificationSetting', seqid)
end

#process_updateChannelSettings(seqid, iprot, oprot) ⇒ Object 



285
286
287
288
289
290
291
292
293
294
 
# File 'lib/linerb/gen-rb/channel_service.rb', line 285

def process_updateChannelSettings(seqid, iprot, oprot)
  args = read_args(iprot, UpdateChannelSettings_args)
  result = UpdateChannelSettings_result.new()
  begin
    @handler.updateChannelSettings(args.channelSettings)
  rescue ::ChannelException => e
    result.e = e
  end
  write_result(result, oprot, 'updateChannelSettings', seqid)
end