Subversion Repositories SmartDukaan

Rev

Rev 3546 | Rev 4948 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
3131 rajveer 1
#
3431 rajveer 2
# Autogenerated by Thrift Compiler (0.7.0)
3131 rajveer 3
#
4
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
5
#
6
 
7
from thrift.Thrift import *
3376 rajveer 8
import shop2020.thriftpy.generic.GenericService
3131 rajveer 9
from ttypes import *
10
from thrift.Thrift import TProcessor
11
from thrift.transport import TTransport
3431 rajveer 12
from thrift.protocol import TBinaryProtocol, TProtocol
3131 rajveer 13
try:
14
  from thrift.protocol import fastbinary
15
except:
16
  fastbinary = None
17
 
18
 
3376 rajveer 19
class Iface(shop2020.thriftpy.generic.GenericService.Iface):
3431 rajveer 20
  def getTickets(self, searchFilter):
3131 rajveer 21
    """
22
    Parameters:
3431 rajveer 23
     - searchFilter
3131 rajveer 24
    """
25
    pass
26
 
3376 rajveer 27
  def getUnassignedTickets(self, ):
3131 rajveer 28
    pass
29
 
3376 rajveer 30
  def updateTicket(self, ticket, activity):
3131 rajveer 31
    """
32
    Parameters:
33
     - ticket
3376 rajveer 34
     - activity
3131 rajveer 35
    """
36
    pass
37
 
3376 rajveer 38
  def insertTicket(self, ticket, activity):
3131 rajveer 39
    """
40
    Parameters:
41
     - ticket
3376 rajveer 42
     - activity
3131 rajveer 43
    """
44
    pass
45
 
3431 rajveer 46
  def getActivities(self, searchFilter):
3131 rajveer 47
    """
48
    Parameters:
3431 rajveer 49
     - searchFilter
3131 rajveer 50
    """
51
    pass
52
 
53
  def insertActivity(self, activity):
54
    """
55
    Parameters:
56
     - activity
57
    """
58
    pass
59
 
3431 rajveer 60
  def markAsRead(self, activityId, agentId):
3131 rajveer 61
    """
62
    Parameters:
3431 rajveer 63
     - activityId
3131 rajveer 64
     - agentId
65
    """
66
    pass
67
 
3431 rajveer 68
  def getAgents(self, searchFilter):
3131 rajveer 69
    """
70
    Parameters:
3431 rajveer 71
     - searchFilter
3131 rajveer 72
    """
73
    pass
74
 
75
  def updatePasswordForAgent(self, agentEmailId, password):
76
    """
77
    Parameters:
78
     - agentEmailId
79
     - password
80
    """
81
    pass
82
 
83
  def getRoleNamesForAgent(self, agentEmailId):
84
    """
85
    Parameters:
86
     - agentEmailId
87
    """
88
    pass
89
 
90
  def getPermissionsForRoleName(self, roleName):
91
    """
92
    Parameters:
93
     - roleName
94
    """
95
    pass
96
 
3376 rajveer 97
  def getLastEmailProcessedTimestamp(self, ):
98
    pass
3131 rajveer 99
 
3376 rajveer 100
  def updateLastEmailProcessedTimestamp(self, timestamp):
101
    """
102
    Parameters:
103
     - timestamp
104
    """
105
    pass
106
 
107
 
108
class Client(shop2020.thriftpy.generic.GenericService.Client, Iface):
3131 rajveer 109
  def __init__(self, iprot, oprot=None):
3376 rajveer 110
    shop2020.thriftpy.generic.GenericService.Client.__init__(self, iprot, oprot)
3131 rajveer 111
 
3431 rajveer 112
  def getTickets(self, searchFilter):
3131 rajveer 113
    """
114
    Parameters:
3431 rajveer 115
     - searchFilter
3131 rajveer 116
    """
3431 rajveer 117
    self.send_getTickets(searchFilter)
3131 rajveer 118
    return self.recv_getTickets()
119
 
3431 rajveer 120
  def send_getTickets(self, searchFilter):
3131 rajveer 121
    self._oprot.writeMessageBegin('getTickets', TMessageType.CALL, self._seqid)
122
    args = getTickets_args()
3431 rajveer 123
    args.searchFilter = searchFilter
3131 rajveer 124
    args.write(self._oprot)
125
    self._oprot.writeMessageEnd()
126
    self._oprot.trans.flush()
127
 
128
  def recv_getTickets(self, ):
129
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
130
    if mtype == TMessageType.EXCEPTION:
131
      x = TApplicationException()
132
      x.read(self._iprot)
133
      self._iprot.readMessageEnd()
134
      raise x
135
    result = getTickets_result()
136
    result.read(self._iprot)
137
    self._iprot.readMessageEnd()
3431 rajveer 138
    if result.success is not None:
3131 rajveer 139
      return result.success
140
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getTickets failed: unknown result");
141
 
3376 rajveer 142
  def getUnassignedTickets(self, ):
143
    self.send_getUnassignedTickets()
144
    return self.recv_getUnassignedTickets()
3131 rajveer 145
 
3376 rajveer 146
  def send_getUnassignedTickets(self, ):
147
    self._oprot.writeMessageBegin('getUnassignedTickets', TMessageType.CALL, self._seqid)
148
    args = getUnassignedTickets_args()
3131 rajveer 149
    args.write(self._oprot)
150
    self._oprot.writeMessageEnd()
151
    self._oprot.trans.flush()
152
 
3376 rajveer 153
  def recv_getUnassignedTickets(self, ):
3131 rajveer 154
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
155
    if mtype == TMessageType.EXCEPTION:
156
      x = TApplicationException()
157
      x.read(self._iprot)
158
      self._iprot.readMessageEnd()
159
      raise x
3376 rajveer 160
    result = getUnassignedTickets_result()
3131 rajveer 161
    result.read(self._iprot)
162
    self._iprot.readMessageEnd()
3431 rajveer 163
    if result.success is not None:
3131 rajveer 164
      return result.success
3376 rajveer 165
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getUnassignedTickets failed: unknown result");
3131 rajveer 166
 
3376 rajveer 167
  def updateTicket(self, ticket, activity):
3131 rajveer 168
    """
169
    Parameters:
170
     - ticket
3376 rajveer 171
     - activity
3131 rajveer 172
    """
3376 rajveer 173
    self.send_updateTicket(ticket, activity)
3131 rajveer 174
    self.recv_updateTicket()
175
 
3376 rajveer 176
  def send_updateTicket(self, ticket, activity):
3131 rajveer 177
    self._oprot.writeMessageBegin('updateTicket', TMessageType.CALL, self._seqid)
178
    args = updateTicket_args()
179
    args.ticket = ticket
3376 rajveer 180
    args.activity = activity
3131 rajveer 181
    args.write(self._oprot)
182
    self._oprot.writeMessageEnd()
183
    self._oprot.trans.flush()
184
 
185
  def recv_updateTicket(self, ):
186
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
187
    if mtype == TMessageType.EXCEPTION:
188
      x = TApplicationException()
189
      x.read(self._iprot)
190
      self._iprot.readMessageEnd()
191
      raise x
192
    result = updateTicket_result()
193
    result.read(self._iprot)
194
    self._iprot.readMessageEnd()
195
    return
196
 
3376 rajveer 197
  def insertTicket(self, ticket, activity):
3131 rajveer 198
    """
199
    Parameters:
200
     - ticket
3376 rajveer 201
     - activity
3131 rajveer 202
    """
3376 rajveer 203
    self.send_insertTicket(ticket, activity)
3131 rajveer 204
    return self.recv_insertTicket()
205
 
3376 rajveer 206
  def send_insertTicket(self, ticket, activity):
3131 rajveer 207
    self._oprot.writeMessageBegin('insertTicket', TMessageType.CALL, self._seqid)
208
    args = insertTicket_args()
209
    args.ticket = ticket
3376 rajveer 210
    args.activity = activity
3131 rajveer 211
    args.write(self._oprot)
212
    self._oprot.writeMessageEnd()
213
    self._oprot.trans.flush()
214
 
215
  def recv_insertTicket(self, ):
216
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
217
    if mtype == TMessageType.EXCEPTION:
218
      x = TApplicationException()
219
      x.read(self._iprot)
220
      self._iprot.readMessageEnd()
221
      raise x
222
    result = insertTicket_result()
223
    result.read(self._iprot)
224
    self._iprot.readMessageEnd()
3431 rajveer 225
    if result.success is not None:
3131 rajveer 226
      return result.success
227
    raise TApplicationException(TApplicationException.MISSING_RESULT, "insertTicket failed: unknown result");
228
 
3431 rajveer 229
  def getActivities(self, searchFilter):
3131 rajveer 230
    """
231
    Parameters:
3431 rajveer 232
     - searchFilter
3131 rajveer 233
    """
3431 rajveer 234
    self.send_getActivities(searchFilter)
3131 rajveer 235
    return self.recv_getActivities()
236
 
3431 rajveer 237
  def send_getActivities(self, searchFilter):
3131 rajveer 238
    self._oprot.writeMessageBegin('getActivities', TMessageType.CALL, self._seqid)
239
    args = getActivities_args()
3431 rajveer 240
    args.searchFilter = searchFilter
3131 rajveer 241
    args.write(self._oprot)
242
    self._oprot.writeMessageEnd()
243
    self._oprot.trans.flush()
244
 
245
  def recv_getActivities(self, ):
246
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
247
    if mtype == TMessageType.EXCEPTION:
248
      x = TApplicationException()
249
      x.read(self._iprot)
250
      self._iprot.readMessageEnd()
251
      raise x
252
    result = getActivities_result()
253
    result.read(self._iprot)
254
    self._iprot.readMessageEnd()
3431 rajveer 255
    if result.success is not None:
3131 rajveer 256
      return result.success
257
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getActivities failed: unknown result");
258
 
259
  def insertActivity(self, activity):
260
    """
261
    Parameters:
262
     - activity
263
    """
264
    self.send_insertActivity(activity)
3431 rajveer 265
    return self.recv_insertActivity()
3131 rajveer 266
 
267
  def send_insertActivity(self, activity):
268
    self._oprot.writeMessageBegin('insertActivity', TMessageType.CALL, self._seqid)
269
    args = insertActivity_args()
270
    args.activity = activity
271
    args.write(self._oprot)
272
    self._oprot.writeMessageEnd()
273
    self._oprot.trans.flush()
274
 
275
  def recv_insertActivity(self, ):
276
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
277
    if mtype == TMessageType.EXCEPTION:
278
      x = TApplicationException()
279
      x.read(self._iprot)
280
      self._iprot.readMessageEnd()
281
      raise x
282
    result = insertActivity_result()
283
    result.read(self._iprot)
284
    self._iprot.readMessageEnd()
3431 rajveer 285
    if result.success is not None:
3131 rajveer 286
      return result.success
3431 rajveer 287
    raise TApplicationException(TApplicationException.MISSING_RESULT, "insertActivity failed: unknown result");
3131 rajveer 288
 
3431 rajveer 289
  def markAsRead(self, activityId, agentId):
3131 rajveer 290
    """
291
    Parameters:
3431 rajveer 292
     - activityId
3131 rajveer 293
     - agentId
294
    """
3431 rajveer 295
    self.send_markAsRead(activityId, agentId)
296
    self.recv_markAsRead()
3131 rajveer 297
 
3431 rajveer 298
  def send_markAsRead(self, activityId, agentId):
299
    self._oprot.writeMessageBegin('markAsRead', TMessageType.CALL, self._seqid)
300
    args = markAsRead_args()
301
    args.activityId = activityId
3131 rajveer 302
    args.agentId = agentId
303
    args.write(self._oprot)
304
    self._oprot.writeMessageEnd()
305
    self._oprot.trans.flush()
306
 
3431 rajveer 307
  def recv_markAsRead(self, ):
3131 rajveer 308
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
309
    if mtype == TMessageType.EXCEPTION:
310
      x = TApplicationException()
311
      x.read(self._iprot)
312
      self._iprot.readMessageEnd()
313
      raise x
3431 rajveer 314
    result = markAsRead_result()
3131 rajveer 315
    result.read(self._iprot)
316
    self._iprot.readMessageEnd()
3431 rajveer 317
    return
3131 rajveer 318
 
3431 rajveer 319
  def getAgents(self, searchFilter):
3131 rajveer 320
    """
321
    Parameters:
3431 rajveer 322
     - searchFilter
3131 rajveer 323
    """
3431 rajveer 324
    self.send_getAgents(searchFilter)
325
    return self.recv_getAgents()
3131 rajveer 326
 
3431 rajveer 327
  def send_getAgents(self, searchFilter):
328
    self._oprot.writeMessageBegin('getAgents', TMessageType.CALL, self._seqid)
329
    args = getAgents_args()
330
    args.searchFilter = searchFilter
3131 rajveer 331
    args.write(self._oprot)
332
    self._oprot.writeMessageEnd()
333
    self._oprot.trans.flush()
334
 
3431 rajveer 335
  def recv_getAgents(self, ):
3131 rajveer 336
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
337
    if mtype == TMessageType.EXCEPTION:
338
      x = TApplicationException()
339
      x.read(self._iprot)
340
      self._iprot.readMessageEnd()
341
      raise x
3431 rajveer 342
    result = getAgents_result()
3131 rajveer 343
    result.read(self._iprot)
344
    self._iprot.readMessageEnd()
3431 rajveer 345
    if result.success is not None:
3131 rajveer 346
      return result.success
3431 rajveer 347
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getAgents failed: unknown result");
3131 rajveer 348
 
349
  def updatePasswordForAgent(self, agentEmailId, password):
350
    """
351
    Parameters:
352
     - agentEmailId
353
     - password
354
    """
355
    self.send_updatePasswordForAgent(agentEmailId, password)
356
    self.recv_updatePasswordForAgent()
357
 
358
  def send_updatePasswordForAgent(self, agentEmailId, password):
359
    self._oprot.writeMessageBegin('updatePasswordForAgent', TMessageType.CALL, self._seqid)
360
    args = updatePasswordForAgent_args()
361
    args.agentEmailId = agentEmailId
362
    args.password = password
363
    args.write(self._oprot)
364
    self._oprot.writeMessageEnd()
365
    self._oprot.trans.flush()
366
 
367
  def recv_updatePasswordForAgent(self, ):
368
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
369
    if mtype == TMessageType.EXCEPTION:
370
      x = TApplicationException()
371
      x.read(self._iprot)
372
      self._iprot.readMessageEnd()
373
      raise x
374
    result = updatePasswordForAgent_result()
375
    result.read(self._iprot)
376
    self._iprot.readMessageEnd()
377
    return
378
 
379
  def getRoleNamesForAgent(self, agentEmailId):
380
    """
381
    Parameters:
382
     - agentEmailId
383
    """
384
    self.send_getRoleNamesForAgent(agentEmailId)
385
    return self.recv_getRoleNamesForAgent()
386
 
387
  def send_getRoleNamesForAgent(self, agentEmailId):
388
    self._oprot.writeMessageBegin('getRoleNamesForAgent', TMessageType.CALL, self._seqid)
389
    args = getRoleNamesForAgent_args()
390
    args.agentEmailId = agentEmailId
391
    args.write(self._oprot)
392
    self._oprot.writeMessageEnd()
393
    self._oprot.trans.flush()
394
 
395
  def recv_getRoleNamesForAgent(self, ):
396
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
397
    if mtype == TMessageType.EXCEPTION:
398
      x = TApplicationException()
399
      x.read(self._iprot)
400
      self._iprot.readMessageEnd()
401
      raise x
402
    result = getRoleNamesForAgent_result()
403
    result.read(self._iprot)
404
    self._iprot.readMessageEnd()
3431 rajveer 405
    if result.success is not None:
3131 rajveer 406
      return result.success
407
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getRoleNamesForAgent failed: unknown result");
408
 
409
  def getPermissionsForRoleName(self, roleName):
410
    """
411
    Parameters:
412
     - roleName
413
    """
414
    self.send_getPermissionsForRoleName(roleName)
415
    return self.recv_getPermissionsForRoleName()
416
 
417
  def send_getPermissionsForRoleName(self, roleName):
418
    self._oprot.writeMessageBegin('getPermissionsForRoleName', TMessageType.CALL, self._seqid)
419
    args = getPermissionsForRoleName_args()
420
    args.roleName = roleName
421
    args.write(self._oprot)
422
    self._oprot.writeMessageEnd()
423
    self._oprot.trans.flush()
424
 
425
  def recv_getPermissionsForRoleName(self, ):
426
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
427
    if mtype == TMessageType.EXCEPTION:
428
      x = TApplicationException()
429
      x.read(self._iprot)
430
      self._iprot.readMessageEnd()
431
      raise x
432
    result = getPermissionsForRoleName_result()
433
    result.read(self._iprot)
434
    self._iprot.readMessageEnd()
3431 rajveer 435
    if result.success is not None:
3131 rajveer 436
      return result.success
437
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getPermissionsForRoleName failed: unknown result");
438
 
3376 rajveer 439
  def getLastEmailProcessedTimestamp(self, ):
440
    self.send_getLastEmailProcessedTimestamp()
441
    return self.recv_getLastEmailProcessedTimestamp()
3131 rajveer 442
 
3376 rajveer 443
  def send_getLastEmailProcessedTimestamp(self, ):
444
    self._oprot.writeMessageBegin('getLastEmailProcessedTimestamp', TMessageType.CALL, self._seqid)
445
    args = getLastEmailProcessedTimestamp_args()
446
    args.write(self._oprot)
447
    self._oprot.writeMessageEnd()
448
    self._oprot.trans.flush()
449
 
450
  def recv_getLastEmailProcessedTimestamp(self, ):
451
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
452
    if mtype == TMessageType.EXCEPTION:
453
      x = TApplicationException()
454
      x.read(self._iprot)
455
      self._iprot.readMessageEnd()
456
      raise x
457
    result = getLastEmailProcessedTimestamp_result()
458
    result.read(self._iprot)
459
    self._iprot.readMessageEnd()
3431 rajveer 460
    if result.success is not None:
3376 rajveer 461
      return result.success
462
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getLastEmailProcessedTimestamp failed: unknown result");
463
 
464
  def updateLastEmailProcessedTimestamp(self, timestamp):
465
    """
466
    Parameters:
467
     - timestamp
468
    """
469
    self.send_updateLastEmailProcessedTimestamp(timestamp)
470
    self.recv_updateLastEmailProcessedTimestamp()
471
 
472
  def send_updateLastEmailProcessedTimestamp(self, timestamp):
473
    self._oprot.writeMessageBegin('updateLastEmailProcessedTimestamp', TMessageType.CALL, self._seqid)
474
    args = updateLastEmailProcessedTimestamp_args()
475
    args.timestamp = timestamp
476
    args.write(self._oprot)
477
    self._oprot.writeMessageEnd()
478
    self._oprot.trans.flush()
479
 
480
  def recv_updateLastEmailProcessedTimestamp(self, ):
481
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
482
    if mtype == TMessageType.EXCEPTION:
483
      x = TApplicationException()
484
      x.read(self._iprot)
485
      self._iprot.readMessageEnd()
486
      raise x
487
    result = updateLastEmailProcessedTimestamp_result()
488
    result.read(self._iprot)
489
    self._iprot.readMessageEnd()
490
    return
491
 
492
 
493
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
3131 rajveer 494
  def __init__(self, handler):
3376 rajveer 495
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
3131 rajveer 496
    self._processMap["getTickets"] = Processor.process_getTickets
3376 rajveer 497
    self._processMap["getUnassignedTickets"] = Processor.process_getUnassignedTickets
3131 rajveer 498
    self._processMap["updateTicket"] = Processor.process_updateTicket
499
    self._processMap["insertTicket"] = Processor.process_insertTicket
500
    self._processMap["getActivities"] = Processor.process_getActivities
501
    self._processMap["insertActivity"] = Processor.process_insertActivity
3431 rajveer 502
    self._processMap["markAsRead"] = Processor.process_markAsRead
503
    self._processMap["getAgents"] = Processor.process_getAgents
3131 rajveer 504
    self._processMap["updatePasswordForAgent"] = Processor.process_updatePasswordForAgent
505
    self._processMap["getRoleNamesForAgent"] = Processor.process_getRoleNamesForAgent
506
    self._processMap["getPermissionsForRoleName"] = Processor.process_getPermissionsForRoleName
3376 rajveer 507
    self._processMap["getLastEmailProcessedTimestamp"] = Processor.process_getLastEmailProcessedTimestamp
508
    self._processMap["updateLastEmailProcessedTimestamp"] = Processor.process_updateLastEmailProcessedTimestamp
3131 rajveer 509
 
510
  def process(self, iprot, oprot):
511
    (name, type, seqid) = iprot.readMessageBegin()
512
    if name not in self._processMap:
513
      iprot.skip(TType.STRUCT)
514
      iprot.readMessageEnd()
515
      x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
516
      oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
517
      x.write(oprot)
518
      oprot.writeMessageEnd()
519
      oprot.trans.flush()
520
      return
521
    else:
522
      self._processMap[name](self, seqid, iprot, oprot)
523
    return True
524
 
525
  def process_getTickets(self, seqid, iprot, oprot):
526
    args = getTickets_args()
527
    args.read(iprot)
528
    iprot.readMessageEnd()
529
    result = getTickets_result()
3431 rajveer 530
    result.success = self._handler.getTickets(args.searchFilter)
3131 rajveer 531
    oprot.writeMessageBegin("getTickets", TMessageType.REPLY, seqid)
532
    result.write(oprot)
533
    oprot.writeMessageEnd()
534
    oprot.trans.flush()
535
 
3376 rajveer 536
  def process_getUnassignedTickets(self, seqid, iprot, oprot):
537
    args = getUnassignedTickets_args()
3131 rajveer 538
    args.read(iprot)
539
    iprot.readMessageEnd()
3376 rajveer 540
    result = getUnassignedTickets_result()
541
    result.success = self._handler.getUnassignedTickets()
542
    oprot.writeMessageBegin("getUnassignedTickets", TMessageType.REPLY, seqid)
3131 rajveer 543
    result.write(oprot)
544
    oprot.writeMessageEnd()
545
    oprot.trans.flush()
546
 
547
  def process_updateTicket(self, seqid, iprot, oprot):
548
    args = updateTicket_args()
549
    args.read(iprot)
550
    iprot.readMessageEnd()
551
    result = updateTicket_result()
3376 rajveer 552
    self._handler.updateTicket(args.ticket, args.activity)
3131 rajveer 553
    oprot.writeMessageBegin("updateTicket", TMessageType.REPLY, seqid)
554
    result.write(oprot)
555
    oprot.writeMessageEnd()
556
    oprot.trans.flush()
557
 
558
  def process_insertTicket(self, seqid, iprot, oprot):
559
    args = insertTicket_args()
560
    args.read(iprot)
561
    iprot.readMessageEnd()
562
    result = insertTicket_result()
3376 rajveer 563
    result.success = self._handler.insertTicket(args.ticket, args.activity)
3131 rajveer 564
    oprot.writeMessageBegin("insertTicket", TMessageType.REPLY, seqid)
565
    result.write(oprot)
566
    oprot.writeMessageEnd()
567
    oprot.trans.flush()
568
 
569
  def process_getActivities(self, seqid, iprot, oprot):
570
    args = getActivities_args()
571
    args.read(iprot)
572
    iprot.readMessageEnd()
573
    result = getActivities_result()
3431 rajveer 574
    result.success = self._handler.getActivities(args.searchFilter)
3131 rajveer 575
    oprot.writeMessageBegin("getActivities", TMessageType.REPLY, seqid)
576
    result.write(oprot)
577
    oprot.writeMessageEnd()
578
    oprot.trans.flush()
579
 
580
  def process_insertActivity(self, seqid, iprot, oprot):
581
    args = insertActivity_args()
582
    args.read(iprot)
583
    iprot.readMessageEnd()
584
    result = insertActivity_result()
3431 rajveer 585
    result.success = self._handler.insertActivity(args.activity)
3131 rajveer 586
    oprot.writeMessageBegin("insertActivity", TMessageType.REPLY, seqid)
587
    result.write(oprot)
588
    oprot.writeMessageEnd()
589
    oprot.trans.flush()
590
 
3431 rajveer 591
  def process_markAsRead(self, seqid, iprot, oprot):
592
    args = markAsRead_args()
3131 rajveer 593
    args.read(iprot)
594
    iprot.readMessageEnd()
3431 rajveer 595
    result = markAsRead_result()
596
    self._handler.markAsRead(args.activityId, args.agentId)
597
    oprot.writeMessageBegin("markAsRead", TMessageType.REPLY, seqid)
3131 rajveer 598
    result.write(oprot)
599
    oprot.writeMessageEnd()
600
    oprot.trans.flush()
601
 
3431 rajveer 602
  def process_getAgents(self, seqid, iprot, oprot):
603
    args = getAgents_args()
3131 rajveer 604
    args.read(iprot)
605
    iprot.readMessageEnd()
3431 rajveer 606
    result = getAgents_result()
607
    result.success = self._handler.getAgents(args.searchFilter)
608
    oprot.writeMessageBegin("getAgents", TMessageType.REPLY, seqid)
3131 rajveer 609
    result.write(oprot)
610
    oprot.writeMessageEnd()
611
    oprot.trans.flush()
612
 
613
  def process_updatePasswordForAgent(self, seqid, iprot, oprot):
614
    args = updatePasswordForAgent_args()
615
    args.read(iprot)
616
    iprot.readMessageEnd()
617
    result = updatePasswordForAgent_result()
618
    self._handler.updatePasswordForAgent(args.agentEmailId, args.password)
619
    oprot.writeMessageBegin("updatePasswordForAgent", TMessageType.REPLY, seqid)
620
    result.write(oprot)
621
    oprot.writeMessageEnd()
622
    oprot.trans.flush()
623
 
624
  def process_getRoleNamesForAgent(self, seqid, iprot, oprot):
625
    args = getRoleNamesForAgent_args()
626
    args.read(iprot)
627
    iprot.readMessageEnd()
628
    result = getRoleNamesForAgent_result()
629
    result.success = self._handler.getRoleNamesForAgent(args.agentEmailId)
630
    oprot.writeMessageBegin("getRoleNamesForAgent", TMessageType.REPLY, seqid)
631
    result.write(oprot)
632
    oprot.writeMessageEnd()
633
    oprot.trans.flush()
634
 
635
  def process_getPermissionsForRoleName(self, seqid, iprot, oprot):
636
    args = getPermissionsForRoleName_args()
637
    args.read(iprot)
638
    iprot.readMessageEnd()
639
    result = getPermissionsForRoleName_result()
640
    result.success = self._handler.getPermissionsForRoleName(args.roleName)
641
    oprot.writeMessageBegin("getPermissionsForRoleName", TMessageType.REPLY, seqid)
642
    result.write(oprot)
643
    oprot.writeMessageEnd()
644
    oprot.trans.flush()
645
 
3376 rajveer 646
  def process_getLastEmailProcessedTimestamp(self, seqid, iprot, oprot):
647
    args = getLastEmailProcessedTimestamp_args()
648
    args.read(iprot)
649
    iprot.readMessageEnd()
650
    result = getLastEmailProcessedTimestamp_result()
651
    result.success = self._handler.getLastEmailProcessedTimestamp()
652
    oprot.writeMessageBegin("getLastEmailProcessedTimestamp", TMessageType.REPLY, seqid)
653
    result.write(oprot)
654
    oprot.writeMessageEnd()
655
    oprot.trans.flush()
3131 rajveer 656
 
3376 rajveer 657
  def process_updateLastEmailProcessedTimestamp(self, seqid, iprot, oprot):
658
    args = updateLastEmailProcessedTimestamp_args()
659
    args.read(iprot)
660
    iprot.readMessageEnd()
661
    result = updateLastEmailProcessedTimestamp_result()
662
    self._handler.updateLastEmailProcessedTimestamp(args.timestamp)
663
    oprot.writeMessageBegin("updateLastEmailProcessedTimestamp", TMessageType.REPLY, seqid)
664
    result.write(oprot)
665
    oprot.writeMessageEnd()
666
    oprot.trans.flush()
667
 
668
 
3131 rajveer 669
# HELPER FUNCTIONS AND STRUCTURES
670
 
671
class getTickets_args:
672
  """
673
  Attributes:
3431 rajveer 674
   - searchFilter
3131 rajveer 675
  """
676
 
677
  thrift_spec = (
678
    None, # 0
3431 rajveer 679
    (1, TType.STRUCT, 'searchFilter', (SearchFilter, SearchFilter.thrift_spec), None, ), # 1
3131 rajveer 680
  )
681
 
3431 rajveer 682
  def __init__(self, searchFilter=None,):
683
    self.searchFilter = searchFilter
3131 rajveer 684
 
685
  def read(self, iprot):
686
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
687
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
688
      return
689
    iprot.readStructBegin()
690
    while True:
691
      (fname, ftype, fid) = iprot.readFieldBegin()
692
      if ftype == TType.STOP:
693
        break
694
      if fid == 1:
3431 rajveer 695
        if ftype == TType.STRUCT:
696
          self.searchFilter = SearchFilter()
697
          self.searchFilter.read(iprot)
3131 rajveer 698
        else:
699
          iprot.skip(ftype)
700
      else:
701
        iprot.skip(ftype)
702
      iprot.readFieldEnd()
703
    iprot.readStructEnd()
704
 
705
  def write(self, oprot):
706
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
707
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
708
      return
709
    oprot.writeStructBegin('getTickets_args')
3431 rajveer 710
    if self.searchFilter is not None:
711
      oprot.writeFieldBegin('searchFilter', TType.STRUCT, 1)
712
      self.searchFilter.write(oprot)
3131 rajveer 713
      oprot.writeFieldEnd()
714
    oprot.writeFieldStop()
715
    oprot.writeStructEnd()
716
 
3431 rajveer 717
  def validate(self):
718
    return
3131 rajveer 719
 
720
 
721
  def __repr__(self):
722
    L = ['%s=%r' % (key, value)
723
      for key, value in self.__dict__.iteritems()]
724
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
725
 
726
  def __eq__(self, other):
727
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
728
 
729
  def __ne__(self, other):
730
    return not (self == other)
731
 
3431 rajveer 732
class getTickets_result:
3131 rajveer 733
  """
734
  Attributes:
735
   - success
736
  """
737
 
738
  thrift_spec = (
739
    (0, TType.LIST, 'success', (TType.STRUCT,(Ticket, Ticket.thrift_spec)), None, ), # 0
740
  )
741
 
742
  def __init__(self, success=None,):
743
    self.success = success
744
 
745
  def read(self, iprot):
746
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
747
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
748
      return
749
    iprot.readStructBegin()
750
    while True:
751
      (fname, ftype, fid) = iprot.readFieldBegin()
752
      if ftype == TType.STOP:
753
        break
754
      if fid == 0:
755
        if ftype == TType.LIST:
756
          self.success = []
3546 mandeep.dh 757
          (_etype24, _size21) = iprot.readListBegin()
758
          for _i25 in xrange(_size21):
759
            _elem26 = Ticket()
760
            _elem26.read(iprot)
761
            self.success.append(_elem26)
3131 rajveer 762
          iprot.readListEnd()
763
        else:
764
          iprot.skip(ftype)
765
      else:
766
        iprot.skip(ftype)
767
      iprot.readFieldEnd()
768
    iprot.readStructEnd()
769
 
770
  def write(self, oprot):
771
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
772
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
773
      return
3431 rajveer 774
    oprot.writeStructBegin('getTickets_result')
775
    if self.success is not None:
3131 rajveer 776
      oprot.writeFieldBegin('success', TType.LIST, 0)
777
      oprot.writeListBegin(TType.STRUCT, len(self.success))
3546 mandeep.dh 778
      for iter27 in self.success:
779
        iter27.write(oprot)
3131 rajveer 780
      oprot.writeListEnd()
781
      oprot.writeFieldEnd()
782
    oprot.writeFieldStop()
783
    oprot.writeStructEnd()
784
 
3431 rajveer 785
  def validate(self):
786
    return
787
 
788
 
3131 rajveer 789
  def __repr__(self):
790
    L = ['%s=%r' % (key, value)
791
      for key, value in self.__dict__.iteritems()]
792
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
793
 
794
  def __eq__(self, other):
795
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
796
 
797
  def __ne__(self, other):
798
    return not (self == other)
799
 
3431 rajveer 800
class getUnassignedTickets_args:
3376 rajveer 801
 
802
  thrift_spec = (
803
  )
804
 
805
  def read(self, iprot):
806
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
807
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
808
      return
809
    iprot.readStructBegin()
810
    while True:
811
      (fname, ftype, fid) = iprot.readFieldBegin()
812
      if ftype == TType.STOP:
813
        break
814
      else:
815
        iprot.skip(ftype)
816
      iprot.readFieldEnd()
817
    iprot.readStructEnd()
818
 
819
  def write(self, oprot):
820
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
821
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
822
      return
3431 rajveer 823
    oprot.writeStructBegin('getUnassignedTickets_args')
3376 rajveer 824
    oprot.writeFieldStop()
825
    oprot.writeStructEnd()
826
 
3431 rajveer 827
  def validate(self):
828
    return
829
 
830
 
3376 rajveer 831
  def __repr__(self):
832
    L = ['%s=%r' % (key, value)
833
      for key, value in self.__dict__.iteritems()]
834
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
835
 
836
  def __eq__(self, other):
837
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
838
 
839
  def __ne__(self, other):
840
    return not (self == other)
841
 
3431 rajveer 842
class getUnassignedTickets_result:
3376 rajveer 843
  """
844
  Attributes:
845
   - success
846
  """
847
 
848
  thrift_spec = (
849
    (0, TType.LIST, 'success', (TType.STRUCT,(Ticket, Ticket.thrift_spec)), None, ), # 0
850
  )
851
 
852
  def __init__(self, success=None,):
853
    self.success = success
854
 
855
  def read(self, iprot):
856
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
857
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
858
      return
859
    iprot.readStructBegin()
860
    while True:
861
      (fname, ftype, fid) = iprot.readFieldBegin()
862
      if ftype == TType.STOP:
863
        break
864
      if fid == 0:
865
        if ftype == TType.LIST:
866
          self.success = []
3546 mandeep.dh 867
          (_etype31, _size28) = iprot.readListBegin()
868
          for _i32 in xrange(_size28):
869
            _elem33 = Ticket()
870
            _elem33.read(iprot)
871
            self.success.append(_elem33)
3376 rajveer 872
          iprot.readListEnd()
873
        else:
874
          iprot.skip(ftype)
875
      else:
876
        iprot.skip(ftype)
877
      iprot.readFieldEnd()
878
    iprot.readStructEnd()
879
 
880
  def write(self, oprot):
881
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
882
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
883
      return
3431 rajveer 884
    oprot.writeStructBegin('getUnassignedTickets_result')
885
    if self.success is not None:
3376 rajveer 886
      oprot.writeFieldBegin('success', TType.LIST, 0)
887
      oprot.writeListBegin(TType.STRUCT, len(self.success))
3546 mandeep.dh 888
      for iter34 in self.success:
889
        iter34.write(oprot)
3376 rajveer 890
      oprot.writeListEnd()
891
      oprot.writeFieldEnd()
892
    oprot.writeFieldStop()
893
    oprot.writeStructEnd()
894
 
3431 rajveer 895
  def validate(self):
896
    return
3376 rajveer 897
 
898
 
3131 rajveer 899
  def __repr__(self):
900
    L = ['%s=%r' % (key, value)
901
      for key, value in self.__dict__.iteritems()]
902
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
903
 
904
  def __eq__(self, other):
905
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
906
 
907
  def __ne__(self, other):
908
    return not (self == other)
909
 
910
class updateTicket_args:
911
  """
912
  Attributes:
913
   - ticket
3376 rajveer 914
   - activity
3131 rajveer 915
  """
916
 
917
  thrift_spec = (
918
    None, # 0
919
    (1, TType.STRUCT, 'ticket', (Ticket, Ticket.thrift_spec), None, ), # 1
3376 rajveer 920
    (2, TType.STRUCT, 'activity', (Activity, Activity.thrift_spec), None, ), # 2
3131 rajveer 921
  )
922
 
3376 rajveer 923
  def __init__(self, ticket=None, activity=None,):
3131 rajveer 924
    self.ticket = ticket
3376 rajveer 925
    self.activity = activity
3131 rajveer 926
 
927
  def read(self, iprot):
928
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
929
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
930
      return
931
    iprot.readStructBegin()
932
    while True:
933
      (fname, ftype, fid) = iprot.readFieldBegin()
934
      if ftype == TType.STOP:
935
        break
936
      if fid == 1:
937
        if ftype == TType.STRUCT:
938
          self.ticket = Ticket()
939
          self.ticket.read(iprot)
940
        else:
941
          iprot.skip(ftype)
3376 rajveer 942
      elif fid == 2:
943
        if ftype == TType.STRUCT:
944
          self.activity = Activity()
945
          self.activity.read(iprot)
946
        else:
947
          iprot.skip(ftype)
3131 rajveer 948
      else:
949
        iprot.skip(ftype)
950
      iprot.readFieldEnd()
951
    iprot.readStructEnd()
952
 
953
  def write(self, oprot):
954
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
955
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
956
      return
957
    oprot.writeStructBegin('updateTicket_args')
3431 rajveer 958
    if self.ticket is not None:
3131 rajveer 959
      oprot.writeFieldBegin('ticket', TType.STRUCT, 1)
960
      self.ticket.write(oprot)
961
      oprot.writeFieldEnd()
3431 rajveer 962
    if self.activity is not None:
3376 rajveer 963
      oprot.writeFieldBegin('activity', TType.STRUCT, 2)
964
      self.activity.write(oprot)
965
      oprot.writeFieldEnd()
3131 rajveer 966
    oprot.writeFieldStop()
967
    oprot.writeStructEnd()
968
 
3431 rajveer 969
  def validate(self):
970
    return
971
 
972
 
3131 rajveer 973
  def __repr__(self):
974
    L = ['%s=%r' % (key, value)
975
      for key, value in self.__dict__.iteritems()]
976
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
977
 
978
  def __eq__(self, other):
979
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
980
 
981
  def __ne__(self, other):
982
    return not (self == other)
983
 
984
class updateTicket_result:
985
 
986
  thrift_spec = (
987
  )
988
 
989
  def read(self, iprot):
990
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
991
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
992
      return
993
    iprot.readStructBegin()
994
    while True:
995
      (fname, ftype, fid) = iprot.readFieldBegin()
996
      if ftype == TType.STOP:
997
        break
998
      else:
999
        iprot.skip(ftype)
1000
      iprot.readFieldEnd()
1001
    iprot.readStructEnd()
1002
 
1003
  def write(self, oprot):
1004
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1005
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1006
      return
1007
    oprot.writeStructBegin('updateTicket_result')
1008
    oprot.writeFieldStop()
1009
    oprot.writeStructEnd()
1010
 
3431 rajveer 1011
  def validate(self):
1012
    return
1013
 
1014
 
3131 rajveer 1015
  def __repr__(self):
1016
    L = ['%s=%r' % (key, value)
1017
      for key, value in self.__dict__.iteritems()]
1018
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1019
 
1020
  def __eq__(self, other):
1021
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1022
 
1023
  def __ne__(self, other):
1024
    return not (self == other)
1025
 
1026
class insertTicket_args:
1027
  """
1028
  Attributes:
1029
   - ticket
3376 rajveer 1030
   - activity
3131 rajveer 1031
  """
1032
 
1033
  thrift_spec = (
1034
    None, # 0
1035
    (1, TType.STRUCT, 'ticket', (Ticket, Ticket.thrift_spec), None, ), # 1
3376 rajveer 1036
    (2, TType.STRUCT, 'activity', (Activity, Activity.thrift_spec), None, ), # 2
3131 rajveer 1037
  )
1038
 
3376 rajveer 1039
  def __init__(self, ticket=None, activity=None,):
3131 rajveer 1040
    self.ticket = ticket
3376 rajveer 1041
    self.activity = activity
3131 rajveer 1042
 
1043
  def read(self, iprot):
1044
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1045
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1046
      return
1047
    iprot.readStructBegin()
1048
    while True:
1049
      (fname, ftype, fid) = iprot.readFieldBegin()
1050
      if ftype == TType.STOP:
1051
        break
1052
      if fid == 1:
1053
        if ftype == TType.STRUCT:
1054
          self.ticket = Ticket()
1055
          self.ticket.read(iprot)
1056
        else:
1057
          iprot.skip(ftype)
3376 rajveer 1058
      elif fid == 2:
1059
        if ftype == TType.STRUCT:
1060
          self.activity = Activity()
1061
          self.activity.read(iprot)
1062
        else:
1063
          iprot.skip(ftype)
3131 rajveer 1064
      else:
1065
        iprot.skip(ftype)
1066
      iprot.readFieldEnd()
1067
    iprot.readStructEnd()
1068
 
1069
  def write(self, oprot):
1070
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1071
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1072
      return
1073
    oprot.writeStructBegin('insertTicket_args')
3431 rajveer 1074
    if self.ticket is not None:
3131 rajveer 1075
      oprot.writeFieldBegin('ticket', TType.STRUCT, 1)
1076
      self.ticket.write(oprot)
1077
      oprot.writeFieldEnd()
3431 rajveer 1078
    if self.activity is not None:
3376 rajveer 1079
      oprot.writeFieldBegin('activity', TType.STRUCT, 2)
1080
      self.activity.write(oprot)
1081
      oprot.writeFieldEnd()
3131 rajveer 1082
    oprot.writeFieldStop()
1083
    oprot.writeStructEnd()
1084
 
3431 rajveer 1085
  def validate(self):
1086
    return
1087
 
1088
 
3131 rajveer 1089
  def __repr__(self):
1090
    L = ['%s=%r' % (key, value)
1091
      for key, value in self.__dict__.iteritems()]
1092
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1093
 
1094
  def __eq__(self, other):
1095
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1096
 
1097
  def __ne__(self, other):
1098
    return not (self == other)
1099
 
1100
class insertTicket_result:
1101
  """
1102
  Attributes:
1103
   - success
1104
  """
1105
 
1106
  thrift_spec = (
1107
    (0, TType.I64, 'success', None, None, ), # 0
1108
  )
1109
 
1110
  def __init__(self, success=None,):
1111
    self.success = success
1112
 
1113
  def read(self, iprot):
1114
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1115
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1116
      return
1117
    iprot.readStructBegin()
1118
    while True:
1119
      (fname, ftype, fid) = iprot.readFieldBegin()
1120
      if ftype == TType.STOP:
1121
        break
1122
      if fid == 0:
1123
        if ftype == TType.I64:
1124
          self.success = iprot.readI64();
1125
        else:
1126
          iprot.skip(ftype)
1127
      else:
1128
        iprot.skip(ftype)
1129
      iprot.readFieldEnd()
1130
    iprot.readStructEnd()
1131
 
1132
  def write(self, oprot):
1133
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1134
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1135
      return
1136
    oprot.writeStructBegin('insertTicket_result')
3431 rajveer 1137
    if self.success is not None:
3131 rajveer 1138
      oprot.writeFieldBegin('success', TType.I64, 0)
1139
      oprot.writeI64(self.success)
1140
      oprot.writeFieldEnd()
1141
    oprot.writeFieldStop()
1142
    oprot.writeStructEnd()
1143
 
3431 rajveer 1144
  def validate(self):
1145
    return
1146
 
1147
 
3131 rajveer 1148
  def __repr__(self):
1149
    L = ['%s=%r' % (key, value)
1150
      for key, value in self.__dict__.iteritems()]
1151
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1152
 
1153
  def __eq__(self, other):
1154
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1155
 
1156
  def __ne__(self, other):
1157
    return not (self == other)
1158
 
1159
class getActivities_args:
1160
  """
1161
  Attributes:
3431 rajveer 1162
   - searchFilter
3131 rajveer 1163
  """
1164
 
1165
  thrift_spec = (
1166
    None, # 0
3431 rajveer 1167
    (1, TType.STRUCT, 'searchFilter', (SearchFilter, SearchFilter.thrift_spec), None, ), # 1
3131 rajveer 1168
  )
1169
 
3431 rajveer 1170
  def __init__(self, searchFilter=None,):
1171
    self.searchFilter = searchFilter
3131 rajveer 1172
 
1173
  def read(self, iprot):
1174
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1175
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1176
      return
1177
    iprot.readStructBegin()
1178
    while True:
1179
      (fname, ftype, fid) = iprot.readFieldBegin()
1180
      if ftype == TType.STOP:
1181
        break
1182
      if fid == 1:
3431 rajveer 1183
        if ftype == TType.STRUCT:
1184
          self.searchFilter = SearchFilter()
1185
          self.searchFilter.read(iprot)
3131 rajveer 1186
        else:
1187
          iprot.skip(ftype)
1188
      else:
1189
        iprot.skip(ftype)
1190
      iprot.readFieldEnd()
1191
    iprot.readStructEnd()
1192
 
1193
  def write(self, oprot):
1194
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1195
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1196
      return
1197
    oprot.writeStructBegin('getActivities_args')
3431 rajveer 1198
    if self.searchFilter is not None:
1199
      oprot.writeFieldBegin('searchFilter', TType.STRUCT, 1)
1200
      self.searchFilter.write(oprot)
3131 rajveer 1201
      oprot.writeFieldEnd()
1202
    oprot.writeFieldStop()
1203
    oprot.writeStructEnd()
1204
 
3431 rajveer 1205
  def validate(self):
1206
    return
1207
 
1208
 
3131 rajveer 1209
  def __repr__(self):
1210
    L = ['%s=%r' % (key, value)
1211
      for key, value in self.__dict__.iteritems()]
1212
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1213
 
1214
  def __eq__(self, other):
1215
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1216
 
1217
  def __ne__(self, other):
1218
    return not (self == other)
1219
 
1220
class getActivities_result:
1221
  """
1222
  Attributes:
1223
   - success
1224
  """
1225
 
1226
  thrift_spec = (
1227
    (0, TType.LIST, 'success', (TType.STRUCT,(Activity, Activity.thrift_spec)), None, ), # 0
1228
  )
1229
 
1230
  def __init__(self, success=None,):
1231
    self.success = success
1232
 
1233
  def read(self, iprot):
1234
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1235
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1236
      return
1237
    iprot.readStructBegin()
1238
    while True:
1239
      (fname, ftype, fid) = iprot.readFieldBegin()
1240
      if ftype == TType.STOP:
1241
        break
1242
      if fid == 0:
1243
        if ftype == TType.LIST:
1244
          self.success = []
3546 mandeep.dh 1245
          (_etype38, _size35) = iprot.readListBegin()
1246
          for _i39 in xrange(_size35):
1247
            _elem40 = Activity()
1248
            _elem40.read(iprot)
1249
            self.success.append(_elem40)
3131 rajveer 1250
          iprot.readListEnd()
1251
        else:
1252
          iprot.skip(ftype)
1253
      else:
1254
        iprot.skip(ftype)
1255
      iprot.readFieldEnd()
1256
    iprot.readStructEnd()
1257
 
1258
  def write(self, oprot):
1259
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1260
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1261
      return
1262
    oprot.writeStructBegin('getActivities_result')
3431 rajveer 1263
    if self.success is not None:
3131 rajveer 1264
      oprot.writeFieldBegin('success', TType.LIST, 0)
1265
      oprot.writeListBegin(TType.STRUCT, len(self.success))
3546 mandeep.dh 1266
      for iter41 in self.success:
1267
        iter41.write(oprot)
3131 rajveer 1268
      oprot.writeListEnd()
1269
      oprot.writeFieldEnd()
1270
    oprot.writeFieldStop()
1271
    oprot.writeStructEnd()
1272
 
3431 rajveer 1273
  def validate(self):
1274
    return
1275
 
1276
 
3131 rajveer 1277
  def __repr__(self):
1278
    L = ['%s=%r' % (key, value)
1279
      for key, value in self.__dict__.iteritems()]
1280
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1281
 
1282
  def __eq__(self, other):
1283
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1284
 
1285
  def __ne__(self, other):
1286
    return not (self == other)
1287
 
3431 rajveer 1288
class insertActivity_args:
3376 rajveer 1289
  """
1290
  Attributes:
3431 rajveer 1291
   - activity
3376 rajveer 1292
  """
1293
 
1294
  thrift_spec = (
1295
    None, # 0
3431 rajveer 1296
    (1, TType.STRUCT, 'activity', (Activity, Activity.thrift_spec), None, ), # 1
3376 rajveer 1297
  )
1298
 
3431 rajveer 1299
  def __init__(self, activity=None,):
1300
    self.activity = activity
3376 rajveer 1301
 
1302
  def read(self, iprot):
1303
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1304
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1305
      return
1306
    iprot.readStructBegin()
1307
    while True:
1308
      (fname, ftype, fid) = iprot.readFieldBegin()
1309
      if ftype == TType.STOP:
1310
        break
1311
      if fid == 1:
3431 rajveer 1312
        if ftype == TType.STRUCT:
1313
          self.activity = Activity()
1314
          self.activity.read(iprot)
3376 rajveer 1315
        else:
1316
          iprot.skip(ftype)
1317
      else:
1318
        iprot.skip(ftype)
1319
      iprot.readFieldEnd()
1320
    iprot.readStructEnd()
1321
 
1322
  def write(self, oprot):
1323
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1324
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1325
      return
3431 rajveer 1326
    oprot.writeStructBegin('insertActivity_args')
1327
    if self.activity is not None:
1328
      oprot.writeFieldBegin('activity', TType.STRUCT, 1)
1329
      self.activity.write(oprot)
3376 rajveer 1330
      oprot.writeFieldEnd()
1331
    oprot.writeFieldStop()
1332
    oprot.writeStructEnd()
1333
 
3431 rajveer 1334
  def validate(self):
1335
    return
1336
 
1337
 
3376 rajveer 1338
  def __repr__(self):
1339
    L = ['%s=%r' % (key, value)
1340
      for key, value in self.__dict__.iteritems()]
1341
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1342
 
1343
  def __eq__(self, other):
1344
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1345
 
1346
  def __ne__(self, other):
1347
    return not (self == other)
1348
 
3431 rajveer 1349
class insertActivity_result:
3376 rajveer 1350
  """
1351
  Attributes:
1352
   - success
1353
  """
1354
 
1355
  thrift_spec = (
3431 rajveer 1356
    (0, TType.I64, 'success', None, None, ), # 0
3376 rajveer 1357
  )
1358
 
1359
  def __init__(self, success=None,):
1360
    self.success = success
1361
 
1362
  def read(self, iprot):
1363
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1364
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1365
      return
1366
    iprot.readStructBegin()
1367
    while True:
1368
      (fname, ftype, fid) = iprot.readFieldBegin()
1369
      if ftype == TType.STOP:
1370
        break
1371
      if fid == 0:
3131 rajveer 1372
        if ftype == TType.I64:
3431 rajveer 1373
          self.success = iprot.readI64();
3131 rajveer 1374
        else:
1375
          iprot.skip(ftype)
1376
      else:
1377
        iprot.skip(ftype)
1378
      iprot.readFieldEnd()
1379
    iprot.readStructEnd()
1380
 
1381
  def write(self, oprot):
1382
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1383
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1384
      return
3431 rajveer 1385
    oprot.writeStructBegin('insertActivity_result')
1386
    if self.success is not None:
1387
      oprot.writeFieldBegin('success', TType.I64, 0)
1388
      oprot.writeI64(self.success)
3131 rajveer 1389
      oprot.writeFieldEnd()
1390
    oprot.writeFieldStop()
1391
    oprot.writeStructEnd()
1392
 
3431 rajveer 1393
  def validate(self):
1394
    return
3131 rajveer 1395
 
1396
 
1397
  def __repr__(self):
1398
    L = ['%s=%r' % (key, value)
1399
      for key, value in self.__dict__.iteritems()]
1400
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1401
 
1402
  def __eq__(self, other):
1403
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1404
 
1405
  def __ne__(self, other):
1406
    return not (self == other)
1407
 
3431 rajveer 1408
class markAsRead_args:
3131 rajveer 1409
  """
1410
  Attributes:
1411
   - activityId
3431 rajveer 1412
   - agentId
3131 rajveer 1413
  """
1414
 
1415
  thrift_spec = (
1416
    None, # 0
1417
    (1, TType.I64, 'activityId', None, None, ), # 1
3431 rajveer 1418
    (2, TType.I64, 'agentId', None, None, ), # 2
3131 rajveer 1419
  )
1420
 
3431 rajveer 1421
  def __init__(self, activityId=None, agentId=None,):
3131 rajveer 1422
    self.activityId = activityId
3431 rajveer 1423
    self.agentId = agentId
3131 rajveer 1424
 
1425
  def read(self, iprot):
1426
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1427
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1428
      return
1429
    iprot.readStructBegin()
1430
    while True:
1431
      (fname, ftype, fid) = iprot.readFieldBegin()
1432
      if ftype == TType.STOP:
1433
        break
1434
      if fid == 1:
1435
        if ftype == TType.I64:
1436
          self.activityId = iprot.readI64();
1437
        else:
1438
          iprot.skip(ftype)
3431 rajveer 1439
      elif fid == 2:
1440
        if ftype == TType.I64:
1441
          self.agentId = iprot.readI64();
1442
        else:
1443
          iprot.skip(ftype)
3131 rajveer 1444
      else:
1445
        iprot.skip(ftype)
1446
      iprot.readFieldEnd()
1447
    iprot.readStructEnd()
1448
 
1449
  def write(self, oprot):
1450
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1451
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1452
      return
3431 rajveer 1453
    oprot.writeStructBegin('markAsRead_args')
1454
    if self.activityId is not None:
3131 rajveer 1455
      oprot.writeFieldBegin('activityId', TType.I64, 1)
1456
      oprot.writeI64(self.activityId)
1457
      oprot.writeFieldEnd()
3431 rajveer 1458
    if self.agentId is not None:
1459
      oprot.writeFieldBegin('agentId', TType.I64, 2)
1460
      oprot.writeI64(self.agentId)
1461
      oprot.writeFieldEnd()
3131 rajveer 1462
    oprot.writeFieldStop()
1463
    oprot.writeStructEnd()
1464
 
3431 rajveer 1465
  def validate(self):
1466
    return
3131 rajveer 1467
 
1468
 
1469
  def __repr__(self):
1470
    L = ['%s=%r' % (key, value)
1471
      for key, value in self.__dict__.iteritems()]
1472
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1473
 
1474
  def __eq__(self, other):
1475
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1476
 
1477
  def __ne__(self, other):
1478
    return not (self == other)
1479
 
3431 rajveer 1480
class markAsRead_result:
3131 rajveer 1481
 
1482
  thrift_spec = (
1483
  )
1484
 
1485
  def read(self, iprot):
1486
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1487
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1488
      return
1489
    iprot.readStructBegin()
1490
    while True:
1491
      (fname, ftype, fid) = iprot.readFieldBegin()
1492
      if ftype == TType.STOP:
1493
        break
1494
      else:
1495
        iprot.skip(ftype)
1496
      iprot.readFieldEnd()
1497
    iprot.readStructEnd()
1498
 
1499
  def write(self, oprot):
1500
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1501
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1502
      return
3431 rajveer 1503
    oprot.writeStructBegin('markAsRead_result')
3131 rajveer 1504
    oprot.writeFieldStop()
1505
    oprot.writeStructEnd()
1506
 
3431 rajveer 1507
  def validate(self):
1508
    return
3131 rajveer 1509
 
1510
 
1511
  def __repr__(self):
1512
    L = ['%s=%r' % (key, value)
1513
      for key, value in self.__dict__.iteritems()]
1514
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1515
 
1516
  def __eq__(self, other):
1517
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1518
 
1519
  def __ne__(self, other):
1520
    return not (self == other)
1521
 
3431 rajveer 1522
class getAgents_args:
3131 rajveer 1523
  """
1524
  Attributes:
3431 rajveer 1525
   - searchFilter
3131 rajveer 1526
  """
1527
 
1528
  thrift_spec = (
1529
    None, # 0
3431 rajveer 1530
    (1, TType.STRUCT, 'searchFilter', (SearchFilter, SearchFilter.thrift_spec), None, ), # 1
3131 rajveer 1531
  )
1532
 
3431 rajveer 1533
  def __init__(self, searchFilter=None,):
1534
    self.searchFilter = searchFilter
3131 rajveer 1535
 
1536
  def read(self, iprot):
1537
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1538
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1539
      return
1540
    iprot.readStructBegin()
1541
    while True:
1542
      (fname, ftype, fid) = iprot.readFieldBegin()
1543
      if ftype == TType.STOP:
1544
        break
1545
      if fid == 1:
1546
        if ftype == TType.STRUCT:
3431 rajveer 1547
          self.searchFilter = SearchFilter()
1548
          self.searchFilter.read(iprot)
3131 rajveer 1549
        else:
1550
          iprot.skip(ftype)
1551
      else:
1552
        iprot.skip(ftype)
1553
      iprot.readFieldEnd()
1554
    iprot.readStructEnd()
1555
 
1556
  def write(self, oprot):
1557
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1558
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1559
      return
3431 rajveer 1560
    oprot.writeStructBegin('getAgents_args')
1561
    if self.searchFilter is not None:
1562
      oprot.writeFieldBegin('searchFilter', TType.STRUCT, 1)
1563
      self.searchFilter.write(oprot)
3131 rajveer 1564
      oprot.writeFieldEnd()
1565
    oprot.writeFieldStop()
1566
    oprot.writeStructEnd()
1567
 
3431 rajveer 1568
  def validate(self):
1569
    return
3131 rajveer 1570
 
1571
 
1572
  def __repr__(self):
1573
    L = ['%s=%r' % (key, value)
1574
      for key, value in self.__dict__.iteritems()]
1575
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1576
 
1577
  def __eq__(self, other):
1578
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1579
 
1580
  def __ne__(self, other):
1581
    return not (self == other)
1582
 
3431 rajveer 1583
class getAgents_result:
3131 rajveer 1584
  """
1585
  Attributes:
1586
   - success
1587
  """
1588
 
1589
  thrift_spec = (
1590
    (0, TType.LIST, 'success', (TType.STRUCT,(Agent, Agent.thrift_spec)), None, ), # 0
1591
  )
1592
 
1593
  def __init__(self, success=None,):
1594
    self.success = success
1595
 
1596
  def read(self, iprot):
1597
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1598
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1599
      return
1600
    iprot.readStructBegin()
1601
    while True:
1602
      (fname, ftype, fid) = iprot.readFieldBegin()
1603
      if ftype == TType.STOP:
1604
        break
1605
      if fid == 0:
1606
        if ftype == TType.LIST:
1607
          self.success = []
3546 mandeep.dh 1608
          (_etype45, _size42) = iprot.readListBegin()
1609
          for _i46 in xrange(_size42):
1610
            _elem47 = Agent()
1611
            _elem47.read(iprot)
1612
            self.success.append(_elem47)
3131 rajveer 1613
          iprot.readListEnd()
1614
        else:
1615
          iprot.skip(ftype)
1616
      else:
1617
        iprot.skip(ftype)
1618
      iprot.readFieldEnd()
1619
    iprot.readStructEnd()
1620
 
1621
  def write(self, oprot):
1622
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1623
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1624
      return
3431 rajveer 1625
    oprot.writeStructBegin('getAgents_result')
1626
    if self.success is not None:
3131 rajveer 1627
      oprot.writeFieldBegin('success', TType.LIST, 0)
1628
      oprot.writeListBegin(TType.STRUCT, len(self.success))
3546 mandeep.dh 1629
      for iter48 in self.success:
1630
        iter48.write(oprot)
3131 rajveer 1631
      oprot.writeListEnd()
1632
      oprot.writeFieldEnd()
1633
    oprot.writeFieldStop()
1634
    oprot.writeStructEnd()
1635
 
3431 rajveer 1636
  def validate(self):
1637
    return
3131 rajveer 1638
 
1639
 
1640
  def __repr__(self):
1641
    L = ['%s=%r' % (key, value)
1642
      for key, value in self.__dict__.iteritems()]
1643
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1644
 
1645
  def __eq__(self, other):
1646
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1647
 
1648
  def __ne__(self, other):
1649
    return not (self == other)
1650
 
1651
class updatePasswordForAgent_args:
1652
  """
1653
  Attributes:
1654
   - agentEmailId
1655
   - password
1656
  """
1657
 
1658
  thrift_spec = (
1659
    None, # 0
1660
    (1, TType.STRING, 'agentEmailId', None, None, ), # 1
1661
    (2, TType.STRING, 'password', None, None, ), # 2
1662
  )
1663
 
1664
  def __init__(self, agentEmailId=None, password=None,):
1665
    self.agentEmailId = agentEmailId
1666
    self.password = password
1667
 
1668
  def read(self, iprot):
1669
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1670
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1671
      return
1672
    iprot.readStructBegin()
1673
    while True:
1674
      (fname, ftype, fid) = iprot.readFieldBegin()
1675
      if ftype == TType.STOP:
1676
        break
1677
      if fid == 1:
1678
        if ftype == TType.STRING:
1679
          self.agentEmailId = iprot.readString();
1680
        else:
1681
          iprot.skip(ftype)
1682
      elif fid == 2:
1683
        if ftype == TType.STRING:
1684
          self.password = iprot.readString();
1685
        else:
1686
          iprot.skip(ftype)
1687
      else:
1688
        iprot.skip(ftype)
1689
      iprot.readFieldEnd()
1690
    iprot.readStructEnd()
1691
 
1692
  def write(self, oprot):
1693
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1694
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1695
      return
1696
    oprot.writeStructBegin('updatePasswordForAgent_args')
3431 rajveer 1697
    if self.agentEmailId is not None:
3131 rajveer 1698
      oprot.writeFieldBegin('agentEmailId', TType.STRING, 1)
1699
      oprot.writeString(self.agentEmailId)
1700
      oprot.writeFieldEnd()
3431 rajveer 1701
    if self.password is not None:
3131 rajveer 1702
      oprot.writeFieldBegin('password', TType.STRING, 2)
1703
      oprot.writeString(self.password)
1704
      oprot.writeFieldEnd()
1705
    oprot.writeFieldStop()
1706
    oprot.writeStructEnd()
1707
 
3431 rajveer 1708
  def validate(self):
1709
    return
1710
 
1711
 
3131 rajveer 1712
  def __repr__(self):
1713
    L = ['%s=%r' % (key, value)
1714
      for key, value in self.__dict__.iteritems()]
1715
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1716
 
1717
  def __eq__(self, other):
1718
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1719
 
1720
  def __ne__(self, other):
1721
    return not (self == other)
1722
 
1723
class updatePasswordForAgent_result:
1724
 
1725
  thrift_spec = (
1726
  )
1727
 
1728
  def read(self, iprot):
1729
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1730
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1731
      return
1732
    iprot.readStructBegin()
1733
    while True:
1734
      (fname, ftype, fid) = iprot.readFieldBegin()
1735
      if ftype == TType.STOP:
1736
        break
1737
      else:
1738
        iprot.skip(ftype)
1739
      iprot.readFieldEnd()
1740
    iprot.readStructEnd()
1741
 
1742
  def write(self, oprot):
1743
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1744
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1745
      return
1746
    oprot.writeStructBegin('updatePasswordForAgent_result')
1747
    oprot.writeFieldStop()
1748
    oprot.writeStructEnd()
1749
 
3431 rajveer 1750
  def validate(self):
1751
    return
1752
 
1753
 
3131 rajveer 1754
  def __repr__(self):
1755
    L = ['%s=%r' % (key, value)
1756
      for key, value in self.__dict__.iteritems()]
1757
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1758
 
1759
  def __eq__(self, other):
1760
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1761
 
1762
  def __ne__(self, other):
1763
    return not (self == other)
1764
 
1765
class getRoleNamesForAgent_args:
1766
  """
1767
  Attributes:
1768
   - agentEmailId
1769
  """
1770
 
1771
  thrift_spec = (
1772
    None, # 0
1773
    (1, TType.STRING, 'agentEmailId', None, None, ), # 1
1774
  )
1775
 
1776
  def __init__(self, agentEmailId=None,):
1777
    self.agentEmailId = agentEmailId
1778
 
1779
  def read(self, iprot):
1780
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1781
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1782
      return
1783
    iprot.readStructBegin()
1784
    while True:
1785
      (fname, ftype, fid) = iprot.readFieldBegin()
1786
      if ftype == TType.STOP:
1787
        break
1788
      if fid == 1:
1789
        if ftype == TType.STRING:
1790
          self.agentEmailId = iprot.readString();
1791
        else:
1792
          iprot.skip(ftype)
1793
      else:
1794
        iprot.skip(ftype)
1795
      iprot.readFieldEnd()
1796
    iprot.readStructEnd()
1797
 
1798
  def write(self, oprot):
1799
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1800
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1801
      return
1802
    oprot.writeStructBegin('getRoleNamesForAgent_args')
3431 rajveer 1803
    if self.agentEmailId is not None:
3131 rajveer 1804
      oprot.writeFieldBegin('agentEmailId', TType.STRING, 1)
1805
      oprot.writeString(self.agentEmailId)
1806
      oprot.writeFieldEnd()
1807
    oprot.writeFieldStop()
1808
    oprot.writeStructEnd()
1809
 
3431 rajveer 1810
  def validate(self):
1811
    return
1812
 
1813
 
3131 rajveer 1814
  def __repr__(self):
1815
    L = ['%s=%r' % (key, value)
1816
      for key, value in self.__dict__.iteritems()]
1817
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1818
 
1819
  def __eq__(self, other):
1820
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1821
 
1822
  def __ne__(self, other):
1823
    return not (self == other)
1824
 
1825
class getRoleNamesForAgent_result:
1826
  """
1827
  Attributes:
1828
   - success
1829
  """
1830
 
1831
  thrift_spec = (
1832
    (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0
1833
  )
1834
 
1835
  def __init__(self, success=None,):
1836
    self.success = success
1837
 
1838
  def read(self, iprot):
1839
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1840
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1841
      return
1842
    iprot.readStructBegin()
1843
    while True:
1844
      (fname, ftype, fid) = iprot.readFieldBegin()
1845
      if ftype == TType.STOP:
1846
        break
1847
      if fid == 0:
1848
        if ftype == TType.LIST:
1849
          self.success = []
3546 mandeep.dh 1850
          (_etype52, _size49) = iprot.readListBegin()
1851
          for _i53 in xrange(_size49):
1852
            _elem54 = iprot.readString();
1853
            self.success.append(_elem54)
3131 rajveer 1854
          iprot.readListEnd()
1855
        else:
1856
          iprot.skip(ftype)
1857
      else:
1858
        iprot.skip(ftype)
1859
      iprot.readFieldEnd()
1860
    iprot.readStructEnd()
1861
 
1862
  def write(self, oprot):
1863
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1864
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1865
      return
1866
    oprot.writeStructBegin('getRoleNamesForAgent_result')
3431 rajveer 1867
    if self.success is not None:
3131 rajveer 1868
      oprot.writeFieldBegin('success', TType.LIST, 0)
1869
      oprot.writeListBegin(TType.STRING, len(self.success))
3546 mandeep.dh 1870
      for iter55 in self.success:
1871
        oprot.writeString(iter55)
3131 rajveer 1872
      oprot.writeListEnd()
1873
      oprot.writeFieldEnd()
1874
    oprot.writeFieldStop()
1875
    oprot.writeStructEnd()
1876
 
3431 rajveer 1877
  def validate(self):
1878
    return
1879
 
1880
 
3131 rajveer 1881
  def __repr__(self):
1882
    L = ['%s=%r' % (key, value)
1883
      for key, value in self.__dict__.iteritems()]
1884
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1885
 
1886
  def __eq__(self, other):
1887
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1888
 
1889
  def __ne__(self, other):
1890
    return not (self == other)
1891
 
1892
class getPermissionsForRoleName_args:
1893
  """
1894
  Attributes:
1895
   - roleName
1896
  """
1897
 
1898
  thrift_spec = (
1899
    None, # 0
1900
    (1, TType.STRING, 'roleName', None, None, ), # 1
1901
  )
1902
 
1903
  def __init__(self, roleName=None,):
1904
    self.roleName = roleName
1905
 
1906
  def read(self, iprot):
1907
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1908
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1909
      return
1910
    iprot.readStructBegin()
1911
    while True:
1912
      (fname, ftype, fid) = iprot.readFieldBegin()
1913
      if ftype == TType.STOP:
1914
        break
1915
      if fid == 1:
1916
        if ftype == TType.STRING:
1917
          self.roleName = iprot.readString();
1918
        else:
1919
          iprot.skip(ftype)
1920
      else:
1921
        iprot.skip(ftype)
1922
      iprot.readFieldEnd()
1923
    iprot.readStructEnd()
1924
 
1925
  def write(self, oprot):
1926
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1927
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1928
      return
1929
    oprot.writeStructBegin('getPermissionsForRoleName_args')
3431 rajveer 1930
    if self.roleName is not None:
3131 rajveer 1931
      oprot.writeFieldBegin('roleName', TType.STRING, 1)
1932
      oprot.writeString(self.roleName)
1933
      oprot.writeFieldEnd()
1934
    oprot.writeFieldStop()
1935
    oprot.writeStructEnd()
1936
 
3431 rajveer 1937
  def validate(self):
1938
    return
1939
 
1940
 
3131 rajveer 1941
  def __repr__(self):
1942
    L = ['%s=%r' % (key, value)
1943
      for key, value in self.__dict__.iteritems()]
1944
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1945
 
1946
  def __eq__(self, other):
1947
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1948
 
1949
  def __ne__(self, other):
1950
    return not (self == other)
1951
 
1952
class getPermissionsForRoleName_result:
1953
  """
1954
  Attributes:
1955
   - success
1956
  """
1957
 
1958
  thrift_spec = (
1959
    (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0
1960
  )
1961
 
1962
  def __init__(self, success=None,):
1963
    self.success = success
1964
 
1965
  def read(self, iprot):
1966
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1967
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1968
      return
1969
    iprot.readStructBegin()
1970
    while True:
1971
      (fname, ftype, fid) = iprot.readFieldBegin()
1972
      if ftype == TType.STOP:
1973
        break
1974
      if fid == 0:
1975
        if ftype == TType.LIST:
1976
          self.success = []
3546 mandeep.dh 1977
          (_etype59, _size56) = iprot.readListBegin()
1978
          for _i60 in xrange(_size56):
1979
            _elem61 = iprot.readString();
1980
            self.success.append(_elem61)
3131 rajveer 1981
          iprot.readListEnd()
1982
        else:
1983
          iprot.skip(ftype)
1984
      else:
1985
        iprot.skip(ftype)
1986
      iprot.readFieldEnd()
1987
    iprot.readStructEnd()
1988
 
1989
  def write(self, oprot):
1990
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1991
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1992
      return
1993
    oprot.writeStructBegin('getPermissionsForRoleName_result')
3431 rajveer 1994
    if self.success is not None:
3131 rajveer 1995
      oprot.writeFieldBegin('success', TType.LIST, 0)
1996
      oprot.writeListBegin(TType.STRING, len(self.success))
3546 mandeep.dh 1997
      for iter62 in self.success:
1998
        oprot.writeString(iter62)
3131 rajveer 1999
      oprot.writeListEnd()
2000
      oprot.writeFieldEnd()
2001
    oprot.writeFieldStop()
2002
    oprot.writeStructEnd()
2003
 
3431 rajveer 2004
  def validate(self):
2005
    return
2006
 
2007
 
3131 rajveer 2008
  def __repr__(self):
2009
    L = ['%s=%r' % (key, value)
2010
      for key, value in self.__dict__.iteritems()]
2011
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2012
 
2013
  def __eq__(self, other):
2014
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2015
 
2016
  def __ne__(self, other):
2017
    return not (self == other)
2018
 
3376 rajveer 2019
class getLastEmailProcessedTimestamp_args:
3131 rajveer 2020
 
3376 rajveer 2021
  thrift_spec = (
2022
  )
2023
 
2024
  def read(self, iprot):
2025
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2026
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2027
      return
2028
    iprot.readStructBegin()
2029
    while True:
2030
      (fname, ftype, fid) = iprot.readFieldBegin()
2031
      if ftype == TType.STOP:
2032
        break
2033
      else:
2034
        iprot.skip(ftype)
2035
      iprot.readFieldEnd()
2036
    iprot.readStructEnd()
2037
 
2038
  def write(self, oprot):
2039
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2040
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2041
      return
2042
    oprot.writeStructBegin('getLastEmailProcessedTimestamp_args')
2043
    oprot.writeFieldStop()
2044
    oprot.writeStructEnd()
2045
 
3431 rajveer 2046
  def validate(self):
2047
    return
2048
 
2049
 
3376 rajveer 2050
  def __repr__(self):
2051
    L = ['%s=%r' % (key, value)
2052
      for key, value in self.__dict__.iteritems()]
2053
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2054
 
2055
  def __eq__(self, other):
2056
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2057
 
2058
  def __ne__(self, other):
2059
    return not (self == other)
2060
 
2061
class getLastEmailProcessedTimestamp_result:
2062
  """
2063
  Attributes:
2064
   - success
2065
  """
2066
 
2067
  thrift_spec = (
2068
    (0, TType.I64, 'success', None, None, ), # 0
2069
  )
2070
 
2071
  def __init__(self, success=None,):
2072
    self.success = success
2073
 
2074
  def read(self, iprot):
2075
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2076
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2077
      return
2078
    iprot.readStructBegin()
2079
    while True:
2080
      (fname, ftype, fid) = iprot.readFieldBegin()
2081
      if ftype == TType.STOP:
2082
        break
2083
      if fid == 0:
2084
        if ftype == TType.I64:
2085
          self.success = iprot.readI64();
2086
        else:
2087
          iprot.skip(ftype)
2088
      else:
2089
        iprot.skip(ftype)
2090
      iprot.readFieldEnd()
2091
    iprot.readStructEnd()
2092
 
2093
  def write(self, oprot):
2094
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2095
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2096
      return
2097
    oprot.writeStructBegin('getLastEmailProcessedTimestamp_result')
3431 rajveer 2098
    if self.success is not None:
3376 rajveer 2099
      oprot.writeFieldBegin('success', TType.I64, 0)
2100
      oprot.writeI64(self.success)
2101
      oprot.writeFieldEnd()
2102
    oprot.writeFieldStop()
2103
    oprot.writeStructEnd()
2104
 
3431 rajveer 2105
  def validate(self):
2106
    return
2107
 
2108
 
3376 rajveer 2109
  def __repr__(self):
2110
    L = ['%s=%r' % (key, value)
2111
      for key, value in self.__dict__.iteritems()]
2112
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2113
 
2114
  def __eq__(self, other):
2115
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2116
 
2117
  def __ne__(self, other):
2118
    return not (self == other)
2119
 
2120
class updateLastEmailProcessedTimestamp_args:
2121
  """
2122
  Attributes:
2123
   - timestamp
2124
  """
2125
 
2126
  thrift_spec = (
2127
    None, # 0
2128
    (1, TType.I64, 'timestamp', None, None, ), # 1
2129
  )
2130
 
2131
  def __init__(self, timestamp=None,):
2132
    self.timestamp = timestamp
2133
 
2134
  def read(self, iprot):
2135
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2136
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2137
      return
2138
    iprot.readStructBegin()
2139
    while True:
2140
      (fname, ftype, fid) = iprot.readFieldBegin()
2141
      if ftype == TType.STOP:
2142
        break
2143
      if fid == 1:
2144
        if ftype == TType.I64:
2145
          self.timestamp = iprot.readI64();
2146
        else:
2147
          iprot.skip(ftype)
2148
      else:
2149
        iprot.skip(ftype)
2150
      iprot.readFieldEnd()
2151
    iprot.readStructEnd()
2152
 
2153
  def write(self, oprot):
2154
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2155
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2156
      return
2157
    oprot.writeStructBegin('updateLastEmailProcessedTimestamp_args')
3431 rajveer 2158
    if self.timestamp is not None:
3376 rajveer 2159
      oprot.writeFieldBegin('timestamp', TType.I64, 1)
2160
      oprot.writeI64(self.timestamp)
2161
      oprot.writeFieldEnd()
2162
    oprot.writeFieldStop()
2163
    oprot.writeStructEnd()
2164
 
3431 rajveer 2165
  def validate(self):
2166
    return
2167
 
2168
 
3376 rajveer 2169
  def __repr__(self):
2170
    L = ['%s=%r' % (key, value)
2171
      for key, value in self.__dict__.iteritems()]
2172
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2173
 
2174
  def __eq__(self, other):
2175
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2176
 
2177
  def __ne__(self, other):
2178
    return not (self == other)
2179
 
2180
class updateLastEmailProcessedTimestamp_result:
2181
 
2182
  thrift_spec = (
2183
  )
2184
 
2185
  def read(self, iprot):
2186
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
2187
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
2188
      return
2189
    iprot.readStructBegin()
2190
    while True:
2191
      (fname, ftype, fid) = iprot.readFieldBegin()
2192
      if ftype == TType.STOP:
2193
        break
2194
      else:
2195
        iprot.skip(ftype)
2196
      iprot.readFieldEnd()
2197
    iprot.readStructEnd()
2198
 
2199
  def write(self, oprot):
2200
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
2201
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
2202
      return
2203
    oprot.writeStructBegin('updateLastEmailProcessedTimestamp_result')
2204
    oprot.writeFieldStop()
2205
    oprot.writeStructEnd()
2206
 
3431 rajveer 2207
  def validate(self):
2208
    return
2209
 
2210
 
3376 rajveer 2211
  def __repr__(self):
2212
    L = ['%s=%r' % (key, value)
2213
      for key, value in self.__dict__.iteritems()]
2214
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
2215
 
2216
  def __eq__(self, other):
2217
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
2218
 
2219
  def __ne__(self, other):
2220
    return not (self == other)