Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use _getRequestId method in autotest

Best Python code snippet using autotest_python

ACLClient.py

Source:ACLClient.py

...49        self.handle('alluserinformation:aclproto', False, self._onAllUserInformation)50        self.currentRequestId = 151        self.requests = {}52        self.serverId = serverId53    def _getRequestId(self, request):54        requestId = self.currentRequestId55        self.currentRequestId += 156        self.requests[requestId] = request57        return requestId58    def _onLogin(self, proto, spec, message, body):59        self.loginResponse = body60        self.loginEvent.set()61    def login(self, userName, password):62        try:63            (loginSpec, loginRequest) = self.create("login:aclproto", True)64            loginRequest.userName = userName65            loginRequest.password = password66            import threading67            self.loginEvent = threading.Event()68            self.send(self.serverId, self.proto, loginSpec, loginRequest, self._getRequestId(loginRequest))69            self.loginEvent.wait()70            if 0 != self.loginResponse.status:71                raise Exception(self.loginResponse.message)72            else:73                return self.loginResponse.session74        except Exception as e :75            print e76            # è¿å 0-0 è¿ä¸åsession77            return self.loginResponse.session78    def _onLogout(self, proto, spec, message, body):79        self.logoutResponse = body80        self.logoutEvent.set()81    def logout(self,session):82        try:83            (logoutSpec, logoutRequest) = self.create("logout:aclproto", True)84            logoutRequest.session = session85            import threading86            self.logoutEvent = threading.Event()87            self.send(self.serverId, self.proto, logoutSpec, logoutRequest, self._getRequestId(logoutRequest))88            self.logoutEvent.wait()89            if 0 != self.logoutResponse.status:90                raise Exception(self.logoutResponse.message)91            else:92                return self.logoutResponse.message93        except Exception as e:94            print e95    def _onAddResourceType(self, proto, spec, message, body):96        requestId = message.getRequestId()97        if requestId in self.requests:98            p = self.requests[requestId]99            if 0 != body.status:100                p.reject(Exception(body.message))101            else:102                p.fulfill(body.resourceTypeId)103    def addResourceType(self, session, name, description, permissions):104        try:105            p = Promise()106            (rSpec, rRequest) = self.create("addresourcetype:aclproto", True)107            rRequest.session = session108            rRequest.name = name109            rRequest.description = description110            rRequest.permissions = permissions111            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))112            return p113        except Exception as e :114            print e115    def _onDeleteResourceType(self, proto, spec, message, body):116        requestId = message.getRequestId()117        if requestId in self.requests:118            p = self.requests[requestId]119            if 0 != body.status:120                p.reject(Exception(body.message))121            else:122                p.fulfill(body.message)123    def deleteResourceType(self, session, resourceTypeId, force=False):124        try:125            p = Promise()126            (rSpec, rRequest) = self.create("deleteresourcetype:aclproto", True)127            rRequest.session = session128            rRequest.resourceTypeId = resourceTypeId129            rRequest.force = force130            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))131            return p132        except Exception as e:133            print e134    def _onListResourceType(self, proto, spec, message, body):135        requestId = message.getRequestId()136        if requestId in self.requests:137            p = self.requests[requestId]138            if 0 != body.status:139                p.reject(Exception(body.message))140            else:141                p.fulfill(body.resourceTypes)142    def listResourceType(self, session):143        try:144            p = Promise()145            (rSpec, rRequest) = self.create("listresourcetype:aclproto", True)146            rRequest.session = session147            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))148            return p149        except Exception as e:150            print e151    def _onAddResource(self, proto, spec, message, body):152        # self.addResourceResponse = body153        requestId = message.getRequestId()154        if requestId in self.requests:155            p = self.requests[requestId]156            if 0 != body.status:157                p.reject(Exception(body.message))158            else:159                p.fulfill(body.resourceId)160    def addResource(self, session, name, resourceTypeId, contentId, isGroup):161        try:162            p = Promise()163            (rSpec, rRequest) = self.create("addresource:aclproto", True)164            rRequest.session = session165            rRequest.resourceTypeId = resourceTypeId166            rRequest.name = name167            rRequest.contentId = contentId168            rRequest.isGroup = isGroup169            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))170            return p171        except Exception as e :172            print e173    def _onGetResources(self, proto, spec, message, body):174        requestId = message.getRequestId()175        if requestId in self.requests:176            p = self.requests[requestId]177            if 0 != body.status:178                p.reject(Exception(body.message))179            else:180                p.fulfill(body.resources)181    def getResources(self, session, roleId, resourceId, permissionIds):182        try:183            p = Promise()184            (rSpec, rRequest) = self.create("getresources:aclproto", True)185            rRequest.session = session186            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))187            return p188        except Exception as e:189            print e190    def _onAddResourceToGroup(self, proto, spec, message, body):191        requestId = message.getRequestId()192        if requestId in self.requests:193            p = self.requests[requestId]194            if 0 != body.status:195                p.reject(Exception(body.message))196            else:197                p.fulfill(body.message)198    def addResourceToGroup(self, session, groupId, resourceIds):199        try:200            p = Promise()201            (rSpec, rRequest) = self.create("addresourcetogroup:aclproto", True)202            rRequest.session = session203            rRequest.groupId = groupId204            rRequest.resourceIds = resourceIds205            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))206            return p207        except Exception as e:208            print e209    def _onRemoveResourceFromGroup(self, proto, spec, message, body):210        requestId = message.getRequestId()211        if requestId in self.requests:212            p = self.requests[requestId]213            if 0 != body.status:214                p.reject(Exception(body.message))215            else:216                p.fulfill(body.message)217    def removeResourceFromGroup(self, session, groupId, resourceIds):218        try:219            p = Promise()220            (rSpec, rRequest) = self.create("removeresourcefromgroup:aclproto", True)221            rRequest.session = session222            rRequest.groupId = groupId223            rRequest.resourceIds = resourceIds224            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))225            return p226        except Exception as e:227            print e228    def _onHasPermission(self, proto, spec, message, body):229        requestId = message.getRequestId()230        if requestId in self.requests:231            p = self.requests[requestId]232            if 0 != body.status:233                p.reject(Exception(body.message))234            else:235                p.fulfill(body.hasPerm)236    def hasPermission(self, session, resourceId, permission):237        try:238            p = Promise()239            (rSpec, rRequest) = self.create("haspermission:aclproto", True)240            rRequest.session = session241            rRequest.resourceId = resourceId242            rRequest.permission = permission243            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))244            return p245        except Exception as e:246            print e247    def _onAddRole(self, proto, spec, message, body):248        requestId = message.getRequestId()249        if requestId in self.requests:250            p = self.requests[requestId]251            if 0 != body.status:252                p.reject(Exception(body.message))253            else:254                p.fulfill(body.roleId)255    def addRole(self, session, roleName):256        try:257            p = Promise()258            (rSpec, rRequest) = self.create("addrole:aclproto", True)259            rRequest.session = session260            rRequest.roleName = roleName261            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))262            return  p263        except Exception as e :264            print e265    def _onAddUser(self, proto, spec, message, body):266        requestId = message.getRequestId()267        if requestId in self.requests:268            p = self.requests[requestId]269            if 0 != body.status:270                p.reject(Exception(body.message))271            else:272                p.fulfill(body.userId)273    def addUser(self, session, userName, email, password, initalRole):274        try:275            p = Promise()276            (rSpec, rRequest) = self.create("adduser:aclproto", True)277            rRequest.session = session278            rRequest.userName = userName279            rRequest.email = email280            rRequest.password = password281            rRequest.roleId = initalRole282            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))283            return p284        except Exception as e:285            print e286    def _onSetRoleToUser(self, proto, spec, message, body):287        requestId = message.getRequestId()288        if requestId in self.requests:289            p = self.requests[requestId]290            if 0 != body.status:291                p.reject(Exception(body.message))292            else:293                p.fulfill(body.message)294    def setRoleToUser(self, session, userId, roleId):295        try:296            p = Promise()297            (rSpec, rRequest) = self.create("setroletouser:aclproto", True)298            rRequest.session = session299            rRequest.userId = userId300            rRequest.roleId = roleId301            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))302            return p303        except Exception as e:304            print e305    def _onClearRoleFromUser(self, proto, spec, message, body):306        requestId = message.getRequestId()307        if requestId in self.requests:308            p = self.requests[requestId]309            if 0 != body.status:310                p.reject(Exception(body.message))311            else:312                p.fulfill(body.message)313    def clearRoleFromUser(self, session, userId, roleId):314        try:315            p = Promise()316            (rSpec, rRequest) = self.create("clearroleofuser:aclproto", True)317            rRequest.session = session318            rRequest.userId = userId319            rRequest.roleId = roleId320            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))321            return p322        except Exception as e:323            print e324    def _onGrantToRole(self, proto, spec, message, body):325        requestId = message.getRequestId()326        if requestId in self.requests:327            p = self.requests[requestId]328            if 0 != body.status:329                p.reject(Exception(body.message))330            else:331                p.fulfill(body.message)332    def grantToRole(self, session, roleId, parentRoleIds):333        try:334            p = Promise()335            (rSpec, rRequest) = self.create("granttorole:aclproto", True)336            rRequest.session = session337            rRequest.roleId = roleId338            rRequest.parentsRoleId = parentRoleIds339            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))340            return p341        except Exception as e:342            print e343    def _onRevokeFromRole(self, proto, spec, message, body):344        requestId = message.getRequestId()345        if requestId in self.requests:346            p = self.requests[requestId]347            if 0 != body.status:348                p.reject(Exception(body.message))349            else:350                p.fulfill(body.message)351    def revokeFromRole(self, session, roleId, parentRoleIds):352        try:353            p = Promise()354            (rSpec, rRequest) = self.create("revokefromrole:aclproto", True)355            rRequest.session = session356            rRequest.roleId = roleId357            rRequest.parentsRoleId = parentRoleIds358            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))359            return p360        except Exception as e:361            print e362    def _onGrantResourceToRole(self, proto, spec, message, body):363        requestId = message.getRequestId()364        if requestId in self.requests:365            p = self.requests[requestId]366            if 0 != body.status:367                p.reject(Exception(body.message))368            else:369                p.fulfill(body.message)370    def grantResourceToRole(self, session, roleId, resourceId, permissionIds):371        try:372            p = Promise()373            (rSpec, rRequest) = self.create("grantresourcetorole:aclproto", True)374            rRequest.session = session375            rRequest.roleId = roleId376            rRequest.resourceId = resourceId377            rRequest.permissionIds = permissionIds378            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))379            return p380        except Exception as e:381            print e382    def _onRevokeResourceFromRole(self, proto, spec, message, body):383        requestId = message.getRequestId()384        if requestId in self.requests:385            p = self.requests[requestId]386            if 0 != body.status:387                p.reject(Exception(body.message))388            else:389                p.fulfill(body.message)390    def revokeResourceFromRole(self, session, roleId, resourceId):391        try:392            p = Promise()393            (rSpec, rRequest) = self.create("revokeresourcefromrole:aclproto", True)394            rRequest.session = session395            rRequest.roleId = roleId396            rRequest.resourceId = resourceId397            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))398            return p399        except Exception as e:400            print e401    def _onChangeRoleOfUser(self, proto, spec, message, body):402        requestId = message.getRequestId()403        if requestId in self.requests:404            p = self.requests[requestId]405            if 0 != body.status:406                p.reject(Exception(body.message))407            else:408                p.fulfill(body.status)409    def changeRoleOfUser(self, session, userId, roleId):410        try:411            p = Promise()412            (rSpec, rRequest) = self.create("changeroleofuser:aclproto", True)413            rRequest.session = session414            rRequest.userId = userId415            rRequest.roleId = roleId416            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))417            return p418        except Exception as e :419            print e420    def _onChangePassword(self, proto, spec, message, body):421        requestId = message.getRequestId()422        if requestId in self.requests:423            p = self.requests[requestId]424            if 0 != body.status:425                p.reject(Exception(body.message))426            else:427                p.fulfill(body.status)428    def changePassword(self, session,password):429        try:430            p = Promise()431            (rSpec, rRequest) = self.create("changepassword:aclproto", True)432            rRequest.session = session433            rRequest.password = password434            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))435            return p436        except Exception as e :437            print e438    def _onGetResources(self, proto, spec, message, body):439        requestId = message.getRequestId()440        if requestId in self.requests:441            p = self.requests[requestId]442            if 0 != body.status:443                p.reject(Exception(body.message))444            else:445                p.fulfill(body.resources)446    def getResources(self, session):447        try:448            p = Promise()449            (rSpec, rRequest) = self.create("getresources:aclproto", True)450            rRequest.session = session451            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))452            return p453        except Exception as e:454            print e455    def _onListOtherResource(self, proto, spec, message, body):456        requestId = message.getRequestId()457        if requestId in self.requests:458            p = self.requests[requestId]459            if 0 != body.status:460                p.reject(Exception(body.message))461            else:462                p.fulfill( body.resources)463    def listOtherResource(self, session,roleId):464        try:465            p = Promise()466            (rSpec, rRequest) = self.create("listotherresource:aclproto", True)467            rRequest.session = session468            rRequest.roleId = roleId469            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))470            return p471        except Exception as e:472            print e473    def _onGrantPermission(self, proto, spec, message, body):474        requestId = message.getRequestId()475        if requestId in self.requests:476            p = self.requests[requestId]477            if 0 != body.status:478                p.reject(Exception(body.message))479            else:480                p.fulfill(body.status)481    def grantPermission(self, session, roleId, resourceId, permissionId):482        try:483            p = Promise()484            (rSpec, rRequest) = self.create("grantpermission:aclproto", True)485            rRequest.session = session486            rRequest.roleId = roleId487            rRequest.resourceId = resourceId488            rRequest.permissionId = permissionId489            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))490            return p491        except Exception as e :492            print e493    def _onListUser(self, proto, spec, message, body):494        requestId = message.getRequestId()495        if requestId in self.requests:496            p = self.requests[requestId]497            if 0 != body.status:498                p.reject(Exception(body.message))499            else:500                p.fulfill(body.users)501    def listUser(self, session, userId=0):502        try:503            p = Promise()504            (rSpec, rRequest) = self.create("listuser:aclproto", True)505            rRequest.session = session506            rRequest.userId = userId507            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))508            return p509        except Exception as e :510            print e511    def _onChangeUserName(self, proto, spec, message, body):512        requestId = message.getRequestId()513        if requestId in self.requests:514            p = self.requests[requestId]515            if 0 != body.status:516                p.reject(Exception(body.message))517            else:518                p.fulfill( body.status)519    def changeUserName(self, session,userName):520        try:521            p = Promise()522            (rSpec, rRequest) = self.create("changeusername:aclproto", True)523            rRequest.session = session524            rRequest.userName = userName525            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))526            return p527        except Exception as e :528            print e529    def _onChangeRoleName(self, proto, spec, message, body):530        requestId = message.getRequestId()531        if requestId in self.requests:532            p = self.requests[requestId]533            if 0 != body.status:534                p.reject(Exception(body.message))535            else:536                p.fulfill( body.status )537    def changeRoleName(self, session,roleId,roleName):538        try:539            p = Promise()540            (rSpec, rRequest) = self.create("changerolename:aclproto", True)541            rRequest.session = session542            rRequest.roleId = roleId543            rRequest.roleName = roleName544            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))545            return p546        except Exception as e :547            print e548    def _onChangePublicKey(self, proto, spec, message, body):549        requestId = message.getRequestId()550        if requestId in self.requests:551            p = self.requests[requestId]552            if 0 != body.status:553                p.reject(Exception(body.message))554            else:555                p.fulfill(body.status)556    def changePublicKey(self, session,publicKey):557        try:558            p = Promise()559            (rSpec, rRequest) = self.create("changepublickey:aclproto", True)560            rRequest.session = session561            rRequest.publicKey = publicKey562            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))563            return p564        except Exception as e :565            print e566    def _onChangePrivateKey(self, proto, spec, message, body):567        requestId = message.getRequestId()568        if requestId in self.requests:569            p = self.requests[requestId]570            if 0 != body.status:571                p.reject(Exception(body.message))572            else:573                p.fulfill(body.status)574    def changePrivateKey(self, session,privateKey):575        try:576            p = Promise()577            (rSpec, rRequest) = self.create("changeprivatekey:aclproto", True)578            rRequest.session = session579            rRequest.privateKey = privateKey580            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))581            return p582        except Exception as e:583            print e584    def _onGetPublicKey(self, proto, spec, message, body):585        requestId = message.getRequestId()586        if requestId in self.requests:587            p = self.requests[requestId]588            if 0 != body.status:589                p.reject(Exception(body.message))590            else:591                p.fulfill(body.publicKey)592    def getPublicKey(self, session, userId):593        try:594            p = Promise()595            (rSpec, rRequest) = self.create("getpublickey:aclproto", True)596            rRequest.userId = userId597            rRequest.session = session598            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))599            return p600        except Exception as e:601            print e602    def _onDeleteResource(self, proto, spec, message, body):603        requestId = message.getRequestId()604        if requestId in self.requests:605            p = self.requests[requestId]606            if 0 != body.status:607                p.reject(Exception(body.message))608            else:609                p.fulfill(body.status)610    def deleteResource(self, session, resourceId):611        try:612            p = Promise()613            (rSpec, rRequest) = self.create("deleteresource:aclproto", True)614            rRequest.session = session615            rRequest.resourceId = resourceId616            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))617            return p618        except Exception as e :619            print e620    def _onDeleteUser(self, proto, spec, message, body):621        requestId = message.getRequestId()622        if requestId in self.requests:623            p = self.requests[requestId]624            if 0 != body.status:625                p.reject(Exception(body.message))626            else:627                p.fulfill(body.status)628    def deleteUser(self, session, userId):629        try:630            p = Promise()631            (rSpec, rRequest) = self.create("deleteuser:aclproto", True)632            rRequest.session = session633            rRequest.userId = userId634            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))635            return p636        except Exception as e :637            print e638    def _onDeleteRole(self, proto, spec, message, body):639        requestId = message.getRequestId()640        if requestId in self.requests:641            p = self.requests[requestId]642            if 0 != body.status:643                p.reject(Exception(body.message))644            else:645                p.fulfill(body.status)646    def deleteRole(self, session,roleId):647        try:648            p = Promise()649            (rSpec, rRequest) = self.create("deleterole:aclproto", True)650            rRequest.session = session651            rRequest.roleId = roleId652            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))653            return  p654        except Exception as e :655            print e656    def _onListRoles(self, proto, spec, message, body):657        requestId = message.getRequestId()658        if requestId in self.requests:659            p = self.requests[requestId]660            if 0 != body.status:661                p.reject(Exception(body.message))662            else:663                p.fulfill(body.roles)664    def listRoles(self, session):665        try:666            p = Promise()667            (rSpec, rRequest) = self.create("listroles:aclproto", True)668            rRequest.session = session669            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))670            return p671        except Exception as e:672            print e673    def _onListLogin(self, proto, spec, message, body):674        requestId = message.getRequestId()675        if requestId in self.requests:676            p = self.requests[requestId]677            if 0 != body.status:678                p.reject(Exception(body.message))679            else:680                p.fulfill(body.logins)681    def listLogin(self, session):682        try:683            p = Promise()684            (rSpec, rRequest) = self.create("listlogin:aclproto", True)685            rRequest.session = session686            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))687            return p688        except Exception as e :689            print e690    def _onMyRole(self, proto, spec, message, body):691        requestId = message.getRequestId()692        if requestId in self.requests:693            p = self.requests[requestId]694            if 0 != body.status:695                p.reject(Exception(body.message))696            else:697                p.fulfill([body.roleId,body.roleName])698    def myRole(self, session):699        try:700            p = Promise()701            (rSpec, rRequest) = self.create("myrole:aclproto", True)702            rRequest.session = session703            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))704            return p705        except Exception as e :706            print e707    def _onMyInformation(self, proto, spec, message, body):708        requestId = message.getRequestId()709        if requestId in self.requests:710            p = self.requests[requestId]711            if 0 != body.status:712                p.reject(Exception(body.message))713            else:714                p.fulfill(body.information)715    def myInformation(self, session, reqName):716        try:717            p = Promise()718            (rSpec, rRequest) = self.create("myinformation:aclproto", True)719            rRequest.session = session720            rRequest.reqName = reqName721            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))722            return p723        except Exception as e:724            print e725    def _onChangeMyInformation(self, proto, spec, message, body):726        requestId = message.getRequestId()727        if requestId in self.requests:728            p = self.requests[requestId]729            if 0 != body.status:730                p.reject(Exception(body.message))731            else:732                p.fulfill(body.message)733    def changeMyInformation(self, session, reqDic):734        try:735            p = Promise()736            (rSpec, rRequest) = self.create("changemyinformation:aclproto", True)737            rRequest.session = session738            rRequest.reqDic = reqDic739            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))740            return p741        except Exception as e :742            print e743    def _onChangeMyPassword(self, proto, spec, message, body):744        requestId = message.getRequestId()745        if requestId in self.requests:746            p = self.requests[requestId]747            if 0 != body.status:748                p.reject(Exception(body.message))749            else:750                p.fulfill(body.status)751    def changeMyPassword(self, session,oldPassword, newPassword):752        try:753            p = Promise()754            (rSpec, rRequest) = self.create("changemypassword:aclproto", True)755            rRequest.session = session756            rRequest.oldPassword = oldPassword757            rRequest.newPassword = newPassword758            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))759            return p760        except Exception as e :761            print e762    def _onOtherInformation(self, proto, spec, message, body):763        requestId = message.getRequestId()764        if requestId in self.requests:765            p = self.requests[requestId]766            if 0 != body.status:767                p.reject(Exception(body.message))768            else:769                p.fulfill(body.information)770    def otherInformation(self, session, reqName, otherUserId):771        try:772            p = Promise()773            (rSpec, rRequest) = self.create("otherinformation:aclproto", True)774            rRequest.session = session775            rRequest.reqName = reqName776            rRequest.otherUserId = otherUserId777            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))778            return p779        except Exception as e:780            print e781    def _onAllUserInformation(self, proto, spec, message, body):782        requestId = message.getRequestId()783        if requestId in self.requests:784            p = self.requests[requestId]785            if 0 != body.status:786                p.reject(Exception(body.message))787            else:788                p.fulfill(body.information)789    def allUserInformation(self, session, reqName):790        try:791            p = Promise()792            (rSpec, rRequest) = self.create("alluserinformation:aclproto", True)793            rRequest.session = session794            rRequest.reqName = reqName795            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))796            return p797        except Exception as e:...

SecurityClient.py

Source:SecurityClient.py

...16        self.handle('revokegrant:securityproto', False, self._onRevokeGrant)17        self.handle('listcontent:securityproto', False, self._onListContent)18        self.handle('deletecontent:securityproto', False, self._onDeleteContent)19        self.handle('checksharer:securityproto', False, self._onCheckSharer)20    def _getRequestId(self, request, func = None):21        requestId = self.currentRequestId22        self.currentRequestId += 123        if func is None:24            self.requests[requestId] = request25        else:26            self.requests[requestId] = (request , func)27        return requestId28    def _onDeleteContent(self, proto, spec, message, body):29        requestId = message.getRequestId()30        if requestId in self.requests:31            p = self.requests[requestId]32            if 0 != body.status:33                p.reject(Exception(body.message))34            else:35                p.fulfill('delete content success!')36    def deleteContent(self, session, contentId):37        try:38            p = Promise()39            (rSpec, rRequest) = self.create("deletecontent:securityproto", True)40            rRequest.session = session41            rRequest.contentId = contentId42            self.deleteContentResponse = None43            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))44            return p45        except Exception as e:46            print e47    def _onListContent(self, proto, spec, message, body):48        requestId = message.getRequestId()49        if requestId in self.requests:50            p = self.requests[requestId]51            if 0 != body.status:52                p.reject(Exception(body.message))53            else:54                p.fulfill(body.contents)55    def listContent(self, session):56        try:57            p = Promise()58            (rSpec, rRequest) = self.create("listcontent:securityproto", True)59            rRequest.session = session60            self.listContentResponse = None61            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))62            return p63        except Exception as e :64            print e65    def _onPutSeriesContent(self, proto, spec, message, body):66        requestId = message.getRequestId()67        if requestId in self.requests:68            p = self.requests[requestId]69            if 0 != body.status:70                p.reject(Exception(body.message))71            else:72                p.fulfill(body.ckIds)73    def putSeriesContent(self, session, seriesContent, publicKey):74        try:75            p = Promise()76            for i in seriesContent:77                enContent = myEncryption.aesEnctypt( i[2],i[1])78                enkey = myEncryption.rsaEncrypt(i[2], publicKey)79                i[1]=enContent80                i[2]=enkey81            (rSpec, rRequest) = self.create("putseriescontent:securityproto", True)82            rRequest.session = session83            s=[]84            for i in seriesContent:85                j = self.createGeneric("Content:SecurityProto")86                j.name = i[0]87                j.content = i[1]88                j.key = i[2]89                s.append(j)90            rRequest.seriesContent = s91            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))92            return p93        except Exception as e :94            print e95    def _onGetSeriesContent(self, proto, spec, message, body):96        requestId = message.getRequestId()97        if requestId in self.requests:98            p, decrypt = self.requests[requestId]99            if 0 != body.status:100                p.reject(Exception(body.message))101            else:102                contentDict={}103                for k,v in body.contentKeys.items():104                    content = decrypt(v.key, v.content)105                    contentDict[k]=content106                p.fulfill(contentDict)107    def getSeriesContent(self, session, contentIds, privateKey):108        try:109            p = Promise()110            (rSpec, rRequest) = self.create("getseriescontent:securityproto", True)111            rRequest.session = session112            cIds=[]113            for i in contentIds:114                cId = self.createGeneric("ConId:SecurityProto")115                cId.name=i[0]116                cId.contentId=i[1]117                cIds.append(cId)118            rRequest.contentIds = cIds119            def decrypt(enKey, enContent):120                key=myEncryption.rsaDecrypt(enKey, privateKey)121                content=myEncryption.aesDectypt(key, enContent)122                return content123            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p, decrypt))124            return p125        except Exception as e :126            print e127    def _onGetKeys(self, proto, spec, message, body):128        requestId = message.getRequestId()129        if requestId in self.requests:130            p, grants = self.requests[requestId]131            if 0 != body.status:132                # self.onGrantToOtherFailed(request.contentId, body.message)133                p.reject(Exception(body.message))134            else:135                grants( body.keys)136                p.fulfill('getkeysuccess')137    def _onPutKeys(self, proto, spec, message, body):138        requestId = message.getRequestId()139        if requestId in self.requests:140            p = self.requests[requestId]141            if 0 != body.status:142                p.reject(Exception(body.message))143            else:144                p.fulfill(body.keyIds)145    def putKeys(self,session, key, contentIds ,otherUserId , publicKey):146        try:147            p = Promise()148            enKey={}149            for k,v in key.items():150                enKey[k]=myEncryption.rsaEncrypt(v,publicKey)151            # newKey = myEncryption.rsaEncrypt(key,publicKey)152            # self.keyId = None153            kCIds=[]154            for k,v in contentIds.items():155                kCId = self.createGeneric("KeyContentId:SecurityProto")156                kCId.key=enKey[k]157                kCId.contentId=v158                kCId.userId=otherUserId159                kCIds.append(kCId)160            (rSpec, rRequest) = self.create("putkeys:securityproto", True)161            rRequest.session = session162            rRequest.KeyContentIds = kCIds163            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))164            return p165        except Exception as e :166            print e167    def grantSeriesToOther(self,session, contentIds, otherUserId , myPrivateKey, otherPublicKey):168        try:169            p = Promise()170            conIds ={}171            for k,v in contentIds.items():172                conIds[k]=v173            (rSpec, rRequest) = self.create("getkeys:securityproto", True)174            rRequest.session = session175            rRequest.contentIds = conIds176            def grants(keys):177                grantKey = {}178                for k,v in keys.items():179                    grantKey[k] = myEncryption.rsaDecrypt(v, myPrivateKey)180                return self.putKeys( session, grantKey, contentIds, otherUserId, otherPublicKey)181            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p, grants))182            return p183        except Exception as e :184            print e185    def _onRevokeGrant(self, proto, spec, message, body):186        requestId = message.getRequestId()187        if requestId in self.requests:188            p = self.requests[requestId]189            if 0 != body.status:190                p.reject(Exception(body.message))191            else:192                p.fulfill(body.status)193    def revokeGrant(self,session, contentIds, otherUserId):194        try:195            p = Promise()196            (rSpec, rRequest) = self.create("revokegrant:securityproto", True)197            rRequest.session = session198            rRequest.contentIds = contentIds199            rRequest.otherUserId = otherUserId200            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))201            return p202        except Exception as e:203            print e204    def _onCheckSharer(self, proto, spec, message, body):205        requestId = message.getRequestId()206        if requestId in self.requests:207            p = self.requests[requestId]208            if 0 != body.status:209                p.reject(Exception(body.message))210            else:211                p.fulfill(body.sharer)212    def checkSharer(self, session, contentId):213        try:214            p = Promise()215            (rSpec, rRequest) = self.create("checksharer:securityproto", True)216            rRequest.session = session217            rRequest.contentId = contentId218            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))219            return p220        except Exception as e:...

templClient.py

Source:templClient.py

...15        self.handle('createversion:templ_json', False, self._onCreateVersion)16        self.currentRequestId = 117        self.requests = {}18        self.serverId = serverId19    def _getRequestId(self, request):20        requestId = self.currentRequestId21        self.currentRequestId += 122        self.requests[requestId] = request23        return requestId24    def _onUpContent(self, proto, spec, message, body):25        requestId = message.getRequestId()26        if requestId in self.requests:27            p = self.requests[requestId]28            if 0 != body.status:29                p.reject(Exception(body.message))30            else:31                p.fulfill(body.message)32    def upContent(self, session, name, version, contents):#ä¸ä¼ æ¨¡æ¿æä»¶33        try:34            p = Promise()35            (rSpec, rRequest) = self.create("upcontent:templ_json", True)36            rRequest.session = session37            rRequest.name = name38            rRequest.version = version39            rRequest.contents = contents40            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))41            return p42        except Exception as e :43            print e44    def _onJsonRelation(self, proto, spec, message, body):45        requestId = message.getRequestId()46        if requestId in self.requests:47            p = self.requests[requestId]48            if 0 != body.status:49                p.reject(Exception(body.message))50            else:51                p.fulfill(body.message)52    def jsonRelation(self, session, JsonRelationName, version):#æ£æ¥è¯¥æ¨¡æ¿çæ¬çç´æ¥åºç±»53        try:54            p = Promise()55            (rSpec, rRequest) = self.create("jsonrelation:templ_json", True)56            rRequest.session = session57            rRequest.JsonRelationName = JsonRelationName58            rRequest.version = version59            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))60            return p61        except Exception as e :62            print e63    def _onBaseCheck(self, proto, spec, message, body):64        requestId = message.getRequestId()65        if requestId in self.requests:66            p = self.requests[requestId]67            if 0 != body.status:68                p.reject(Exception(body.message))69            else:70                p.fulfill(body.message)71    def baseCheck(self, session, BaseName, version):#æ£æ¥è¯¥æ¨¡æ¿ææçåºç±»ï¼åæ¬åºç±»çåºç±»72        try:73            p = Promise()74            (rSpec, rRequest) = self.create("basecheck:templ_json", True)75            rRequest.session = session76            rRequest.BaseName = BaseName77            rRequest.version = version78            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))79            return p80        except Exception as e :81            print e82    def _onDownLoad(self, proto, spec, message, body):83        requestId = message.getRequestId()84        if requestId in self.requests:85            p = self.requests[requestId]86            if 0 != body.status:87                p.reject(Exception(body.message))88            else:89                p.fulfill(body.message)90    def downLoad(self, session, TemplName, version):#ä¸è½½åå§æ¨¡æ¿contentåå®¹91        try:92            p = Promise()93            (rSpec, rRequest) = self.create("download:templ_json", True)94            rRequest.session = session95            rRequest.TemplName = TemplName96            rRequest.version = version97            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))98            return p99        except Exception as e :100            print e101    def _onGetJsonCon(self, proto, spec, message, body):102        requestId = message.getRequestId()103        if requestId in self.requests:104            p = self.requests[requestId]105            if 0 != body.status:106                p.reject(Exception(body.message))107            else:108                p.fulfill(body.message)109    def getJsonCon(self, session, JsonAttrName, version):#è·åå¯¹åºæ¨¡æ¿ï¼çæ¬çJsonåå®¹110        try:111            p = Promise()112            (rSpec, rRequest) = self.create("getjsoncon:templ_json", True)113            rRequest.session = session114            rRequest.JsonAttrName = JsonAttrName115            rRequest.version = version116            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))117            return p118        except Exception as e :119            print e120    def _onGrantAuthority(self, proto, spec, message, body):121        requestId = message.getRequestId()122        if requestId in self.requests:123            p = self.requests[requestId]124            if 0 != body.status:125                p.reject(Exception(body.message))126            else:127                p.fulfill(body.message)128    def grantAuthority(self, session, userId):#æææä½129        try:130            p = Promise()131            (rSpec, rRequest) = self.create("grantauthority:templ_json", True)132            rRequest.session = session133            rRequest.name = userId134            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))135            return p136        except Exception as e :137            print e138    def _onTemplMerge(self, proto, spec, message, body):139        requestId = message.getRequestId()140        if requestId in self.requests:141            p = self.requests[requestId]142            if 0 != body.status:143                p.reject(Exception(body.message))144            else:145                p.fulfill(body.message)146    def templMerge(self, session):#æ¨¡æ¿åå¹¶147        try:148            p = Promise()149            (rSpec, rRequest) = self.create("templmerge:templ_json", True)150            rRequest.session = session151            # rRequest.name = userId152            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))153            return p154        except Exception as e :155            print e156    def _onCreateVersion(self, proto, spec, message, body):157        requestId = message.getRequestId()158        if requestId in self.requests:159            p = self.requests[requestId]160            if 0 != body.status:161                p.reject(Exception(body.message))162            else:163                p.fulfill(body.message)164    def createVersion(self, session, name, version, contents):#ä¸ºå·²ææ¨¡æ¿åå»ºæ°çæ¬165        try:166            p = Promise()167            (rSpec, rRequest) = self.create("createversion:templ_json", True)168            rRequest.session = session169            rRequest.name = name170            rRequest.version = version171            rRequest.contents = contents172            self.send(self.serverId, self.proto, rSpec, rRequest, self._getRequestId(p))173            return p174        except Exception as e :...

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.