@@ -407,6 +407,39 @@ def async_delete(self, engine_id):
407
407
def delete (self , engine_id ):
408
408
return self .async_delete (engine_id ).get_response ()
409
409
410
+ def delete_user_data (self , engine_id , user_id ):
411
+ """Synchronously delete all user data from Harness Server."""
412
+ return self .async_delete_user_data (engine_id , user_id ).get_response ()
413
+
414
+ def async_delete_user_data (self , engine_id , user_id ):
415
+ """Asynchronouly delete an event from Harness Server.
416
+ :param user_id: user id returned by the HarnessServer when creating the
417
+ event.
418
+ :returns:
419
+ AsyncRequest object.
420
+ """
421
+ request = AsyncRequest ("DELETE" , "%s/%s/%s/%s" % (self .path , engine_id , "entities" , user_id ))
422
+ request .set_response_handler (self ._ok_response_handler )
423
+ self ._connection .make_request (request )
424
+ return request
425
+
426
+ def get_user_data (self , engine_id , user_id ):
427
+ """Synchronously delete all user data from Harness Server."""
428
+ return self .async_get_user_data (engine_id , user_id ).get_response ()
429
+
430
+ def async_get_user_data (self , engine_id , user_id ):
431
+ """Asynchronouly delete an event from Harness Server.
432
+ :param user_id: user id returned by the HarnessServer when creating the
433
+ event.
434
+ :returns:
435
+ AsyncRequest object.
436
+ """
437
+ request = AsyncRequest ("GET" , "%s/%s/%s/%s" % (self .path , engine_id , "entities" , user_id ))
438
+ print (request )
439
+ request .set_response_handler (self ._ok_response_handler )
440
+ self ._connection .make_request (request )
441
+ return request
442
+
410
443
411
444
class QueriesClient (BaseClient ):
412
445
"""
0 commit comments