Commit 431580e1 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Minor changes. 



Signed-off-by: default avatarCristiano Urban <cristiano.urban@inaf.it>
parent fc395107

transfer_service/db_connector.py

+8 −8
Original line number Diff line number Diff line
@@ -721,36 +721,36 @@ class DbConnector(object): 
                if not conn.closed:

                    conn.rollback()

                    

    def updateGroupRead(self, groupsToAdd, groupsToRemove, nodeVOSPath):

    def updateGroupRead(self, groupToAdd, groupToRemove, nodeVOSPath):

        with self.getConnection() as conn:

            try:

                cursor = conn.cursor(cursor_factory = RealDictCursor)

                cursor.execute("""

                    UPDATE node c

                    SET group_read = update_array(c.group_read, %s::VARCHAR[], %s::VARCHAR[])

                    SET group_read = update_array(c.group_read, %s, %s)

                    FROM node n

                    WHERE c.path <@ n.path AND n.node_id = id_from_vos_path(%s);

                    """,

                    (groupsToAdd,

                     groupsToRemove,

                    (groupToAdd,

                     groupToRemove,

                     nodeVOSPath,))

                conn.commit()

            except Exception as e:

                if not conn.closed:

                    conn.rollback()

                    

    def updateGroupWrite(self, groupsToAdd, groupsToRemove, nodeVOSPath):

    def updateGroupWrite(self, groupToAdd, groupToRemove, nodeVOSPath):

        with self.getConnection() as conn:

            try:

                cursor = conn.cursor(cursor_factory = RealDictCursor)

                cursor.execute("""

                    UPDATE node c

                    SET group_write = update_array(c.group_write, %s::VARCHAR[], %s::VARCHAR[])

                    SET group_write = update_array(c.group_write, %s, %s)

                    FROM node n

                    WHERE c.path <@ n.path AND n.node_id = id_from_vos_path(%s);

                    """,

                    (groupsToAdd,

                     groupsToRemove,

                    (groupToAdd,

                     groupToRemove,

                     nodeVOSPath,))

                conn.commit()

            except Exception as e:

transfer_service/group_rw_rpc_server.py

+1 −0
Original line number Diff line number Diff line
@@ -56,6 +56,7 @@ class GroupRwRPCServer(RedisRPCServer): 
            jobType = requestType.split('_')[0]

            vospacePath = requestBody["vospacePath"]

            groupname = requestBody["groupName"]

            self.logger.info(f"groupName: {groupname}")

            #groupInDb = self.dbConn.userExists(groupname)

            #groupInfo = self.systemUtils.userInfo(groupname)